e.smali

.class public final Lej/e;
.super Ljava/lang/Object;
.source "PushProcessor.kt"

# interfaces
.implements Lcom/shopee/foody/push/service/IPushMessageService$b;
.implements Lej/b;
.implements Llc/a$a;


# annotations
.annotation runtime Lkotlin/Metadata;
    bv = {
        0x1,
        0x0,
        0x3
    }
    d1 = {
        "\u0000v\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\u0008\u0007\n\u0002\u0010\u0008\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u0002\u0008\u00c6\u0002\u0018\u00002\u00020\u00012\u00020\u00022\u00020\u0003B\u0007\u0008\u0002\u00a2\u0006\u0002\u0010\u0004J\u0010\u0010\u000f\u001a\u00020\u00102\u0008\u0010\u0011\u001a\u0004\u0018\u00010\u0012J\u0016\u0010\u000f\u001a\u00020\u00102\u000e\u0010\u0013\u001a\n\u0012\u0004\u0012\u00020\u0012\u0018\u00010\u0014J\u0010\u0010\u0015\u001a\u00020\u00102\u0006\u0010\u0016\u001a\u00020\u0017H\u0016J\u0010\u0010\u0018\u001a\u00020\u00102\u0006\u0010\u0019\u001a\u00020\u001aH\u0016J\u001e\u0010\u001b\u001a\u00020\u00102\u000c\u0010\u001c\u001a\u0008\u0012\u0004\u0012\u00020\u001d0\u00142\u0006\u0010\u001e\u001a\u00020\u001fH\u0016J\u0010\u0010 \u001a\u00020\u00102\u0006\u0010!\u001a\u00020\u0017H\u0002J\u000e\u0010\"\u001a\u00020\u00102\u0006\u0010#\u001a\u00020\tJ\u000e\u0010$\u001a\u00020\u00102\u0006\u0010#\u001a\u00020\u0002J\u0016\u0010%\u001a\u00020\u00102\u0006\u0010&\u001a\u00020\'2\u0006\u0010#\u001a\u00020\u000eJ\u000e\u0010(\u001a\u00020\u00102\u0006\u0010#\u001a\u00020\tJ\u000e\u0010)\u001a\u00020\u00102\u0006\u0010#\u001a\u00020\u0002J\u0016\u0010*\u001a\u00020\u00102\u0006\u0010&\u001a\u00020\'2\u0006\u0010#\u001a\u00020\u000eJ\u000c\u0010+\u001a\u00020\'*\u00020\u001fH\u0002J\u0016\u0010,\u001a\u0004\u0018\u00010\u0012*\u0004\u0018\u00010-2\u0006\u0010\u001e\u001a\u00020\u001fJ\u001e\u0010,\u001a\u00020\u0012*\u00020\u00062\u0006\u0010\u001e\u001a\u00020\u001f2\n\u0008\u0002\u0010.\u001a\u0004\u0018\u00010\u0006R\u000e\u0010\u0005\u001a\u00020\u0006X\u0082T\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u0007\u001a\u000e\u0012\u0004\u0012\u00020\u0006\u0012\u0004\u0012\u00020\t0\u0008X\u0082\u000e\u00a2\u0006\u0002\n\u0000R\u0014\u0010\n\u001a\u0008\u0012\u0004\u0012\u00020\u00020\u000bX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001a\u0010\u000c\u001a\u000e\u0012\n\u0012\u0008\u0012\u0004\u0012\u00020\u000e0\u000b0\rX\u0082\u000e\u00a2\u0006\u0002\n\u0000\u00a8\u0006/"
    }
    d2 = {
        "Lcom/shopee/foody/driver/push/PushProcessor;",
        "Lcom/shopee/foody/push/service/IPushMessageService$IPushMessageListener;",
        "Lcom/shopee/foody/driver/push/IFcmNotiProcessor;",
        "Lcom/shopee/app/network/processors/notification/NotificationProcessor$INotificationProcessor;",
        "()V",
        "TAG",
        "",
        "mCrNotiProcessorsMap",
        "Lcom/shopee/foody/driver/push/ProcessorContainer;",
        "Lcom/shopee/foody/driver/push/ICoreServerNotiProcessor;",
        "mFcmNotiProcessList",
        "Ljava/util/concurrent/ConcurrentLinkedQueue;",
        "mWssProcessorsMap",
        "Landroid/util/SparseArray;",
        "Lcom/shopee/foody/driver/push/IWssPushMessageProcessor;",
        "markPushRead",
        "",
        "pushItem",
        "Lcom/shopee/foody/push/core/message/PushItem;",
        "pushItems",
        "",
        "onFcmNotiMessageReceived",
        "fcmNotiMessage",
        "Lcom/shopee/foody/driver/notiservice/fcm/FcmNotiMessage;",
        "onNotificationReceived",
        "notification",
        "Lcom/shopee/protocol/action/Notification;",
        "onPushMessageReceived",
        "pushDetails",
        "Lcom/shopee/foody/push/service/PushDetail;",
        "isSync",
        "",
        "processApprlFromFcm",
        "notiMessage",
        "registerCoreServerNotiProcessor",
        "processor",
        "registerFcmNotiProcessor",
        "registerProcessor",
        "channel",
        "",
        "unregisterCoreServerNotiProcessor",
        "unregisterFcmNotiProcessor",
        "unregisterProcessor",
        "isSync2ReadType",
        "toPushItem",
        "Lcom/shopee/foody/push/core/message/PushMessage;",
        "createTime",
        "driver_indonesiaRelease"
    }
    k = 0x1
    mv = {
        0x1,
        0x1,
        0x10
    }
.end annotation


# static fields
.field public static a:Landroid/util/SparseArray;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Landroid/util/SparseArray<",
            "Ljava/util/concurrent/ConcurrentLinkedQueue<",
            "Lej/c;",
            ">;>;"
        }
    .end annotation
.end field

.field public static final b:Ljava/util/concurrent/ConcurrentLinkedQueue;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Ljava/util/concurrent/ConcurrentLinkedQueue<",
            "Lej/b;",
            ">;"
        }
    .end annotation
.end field

.field public static c:Lej/d;
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "Lej/d<",
            "Ljava/lang/String;",
            "Lej/a;",
            ">;"
        }
    .end annotation
.end field

.field public static final d:Lej/e;


# direct methods
.method public static constructor <clinit>()V
    .registers 1

    new-instance v0, Lej/e;

    invoke-direct {v0}, Lej/e;-><init>()V

    sput-object v0, Lej/e;->d:Lej/e;

    new-instance v0, Landroid/util/SparseArray;

    invoke-direct {v0}, Landroid/util/SparseArray;-><init>()V

    sput-object v0, Lej/e;->a:Landroid/util/SparseArray;

    new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V

    sput-object v0, Lej/e;->b:Ljava/util/concurrent/ConcurrentLinkedQueue;

    new-instance v0, Lej/d;

    invoke-direct {v0}, Lej/d;-><init>()V

    sput-object v0, Lej/e;->c:Lej/d;

    return-void
.end method

.method public constructor <init>()V
    .registers 1

    invoke-direct {p0}, Ljava/lang/Object;-><init>()V

    return-void
.end method

.method public static synthetic a(Lej/e;Ljava/lang/String;ZLjava/lang/String;ILjava/lang/Object;)Lcom/shopee/foody/push/core/message/PushItem;
    .registers 6

    and-int/lit8 p4, p4, 0x2

    if-eqz p4, :cond_5

    const/4 p3, 0x0

    :cond_5
    invoke-virtual {p0, p1, p2, p3}, Lej/e;->a(Ljava/lang/String;ZLjava/lang/String;)Lcom/shopee/foody/push/core/message/PushItem;

    move-result-object p0

    return-object p0
.end method


# virtual methods
.method public final a(Z)I
    .registers 2

    if-eqz p1, :cond_4

    const/4 p1, 0x1

    goto :goto_5

    :cond_4
    const/4 p1, 0x2

    :goto_5
    return p1
.end method

.method public final a(Lcom/shopee/foody/push/core/message/PushMessage;Z)Lcom/shopee/foody/push/core/message/PushItem;
    .registers 5

    const/4 v0, 0x0

    if-eqz p1, :cond_1d

    invoke-virtual {p1}, Lcom/shopee/foody/push/core/message/PushMessage;->getData()Lcom/shopee/foody/push/core/message/PushDataSection;

    move-result-object v1

    if-eqz v1, :cond_1d

    invoke-virtual {v1}, Lcom/shopee/foody/push/core/message/PushDataSection;->getSeq_id()Ljava/lang/String;

    move-result-object v1

    if-eqz v1, :cond_1d

    invoke-virtual {p1}, Lcom/shopee/foody/push/core/message/PushMessage;->getData()Lcom/shopee/foody/push/core/message/PushDataSection;

    move-result-object p1

    if-eqz p1, :cond_19

    invoke-virtual {p1}, Lcom/shopee/foody/push/core/message/PushDataSection;->getCreate_time()Ljava/lang/String;

    move-result-object v0

    :cond_19
    invoke-virtual {p0, v1, p2, v0}, Lej/e;->a(Ljava/lang/String;ZLjava/lang/String;)Lcom/shopee/foody/push/core/message/PushItem;

    move-result-object v0

    :cond_1d
    return-object v0
.end method

.method public final a(Ljava/lang/String;ZLjava/lang/String;)Lcom/shopee/foody/push/core/message/PushItem;
    .registers 6

    sget-object v0, Lcg/b;->a:Lcg/b;

    invoke-virtual {v0}, Lcg/b;->a()J

    move-result-wide v0

    invoke-static {v0, v1}, Ljava/lang/String;->valueOf(J)Ljava/lang/String;

    move-result-object v0

    new-instance v1, Lcom/shopee/foody/push/core/message/PushItem;

    invoke-virtual {p0, p2}, Lej/e;->a(Z)I

    move-result p2

    if-eqz p3, :cond_13

    goto :goto_14

    :cond_13
    move-object p3, v0

    :goto_14
    invoke-direct {v1, p1, p2, p3, v0}, Lcom/shopee/foody/push/core/message/PushItem;-><init>(Ljava/lang/String;ILjava/lang/String;Ljava/lang/String;)V

    return-object v1
.end method

.method public final a(ILej/c;)V
    .registers 5

    sget-object v0, Lej/e;->a:Landroid/util/SparseArray;

    invoke-virtual {v0, p1}, Landroid/util/SparseArray;->get(I)Ljava/lang/Object;

    move-result-object v0

    if-nez v0, :cond_12

    sget-object v0, Lej/e;->a:Landroid/util/SparseArray;

    new-instance v1, Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-direct {v1}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V

    invoke-virtual {v0, p1, v1}, Landroid/util/SparseArray;->put(ILjava/lang/Object;)V

    :cond_12
    sget-object v0, Lej/e;->a:Landroid/util/SparseArray;

    invoke-virtual {v0, p1}, Landroid/util/SparseArray;->get(I)Ljava/lang/Object;

    move-result-object p1

    check-cast p1, Ljava/util/concurrent/ConcurrentLinkedQueue;

    if-eqz p1, :cond_26

    invoke-virtual {p1, p2}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z

    move-result v0

    if-eqz v0, :cond_23

    goto :goto_26

    :cond_23
    invoke-virtual {p1, p2}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z

    :cond_26
    :goto_26
    return-void
.end method

.method public a(Lbi/b;)V
    .registers 5

    sget-object v0, Ljd/b;->c:Ljd/b$a;

    invoke-virtual {v0}, Ljd/b$a;->b()Z

    move-result v0

    if-eqz v0, :cond_14

    sget-object v0, Lqa/d;->e:Lqa/d$a;

    new-instance v1, Lej/e$c;

    invoke-direct {v1, p1}, Lej/e$c;-><init>(Lbi/b;)V

    const-string v2, "PushProcessor"

    invoke-virtual {v0, v2, v1}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    :cond_14
    sget-object v0, Lej/e;->b:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :goto_1a
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v1

    if-eqz v1, :cond_2a

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Lej/b;

    invoke-interface {v1, p1}, Lej/b;->a(Lbi/b;)V

    goto :goto_1a

    :cond_2a
    return-void
.end method

.method public final a(Lcom/shopee/foody/push/core/message/PushItem;)V
    .registers 8

    if-nez p1, :cond_3

    return-void

    :cond_3
    sget-object v0, Lkotlinx/coroutines/GlobalScope;->INSTANCE:Lkotlinx/coroutines/GlobalScope;

    invoke-static {}, Lmd/e;->b()Lmd/d;

    move-result-object v1

    const/4 v2, 0x0

    new-instance v3, Lej/e$b;

    const/4 v4, 0x0

    invoke-direct {v3, p1, v4}, Lej/e$b;-><init>(Lcom/shopee/foody/push/core/message/PushItem;Lkotlin/coroutines/Continuation;)V

    const/4 v4, 0x2

    const/4 v5, 0x0

    invoke-static/range {v0 .. v5}, Lkotlinx/coroutines/BuildersKt;->launch$default(Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/CoroutineStart;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lkotlinx/coroutines/Job;

    return-void
.end method

.method public a(Lcom/shopee/protocol/action/Notification;)V
    .registers 6

    sget-object v0, Ljd/b;->c:Ljd/b$a;

    invoke-virtual {v0}, Ljd/b$a;->b()Z

    move-result v0

    const-string v1, "PushProcessor"

    if-eqz v0, :cond_14

    sget-object v0, Lqa/d;->e:Lqa/d$a;

    new-instance v2, Lej/e$d;

    invoke-direct {v2, p1}, Lej/e$d;-><init>(Lcom/shopee/protocol/action/Notification;)V

    invoke-virtual {v0, v1, v2}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    :cond_14
    sget-object v0, Lej/f;->a:Lej/f;

    invoke-virtual {v0, p1}, Lej/f;->b(Lcom/shopee/protocol/action/Notification;)Lkotlinx/coroutines/Job;

    iget-object v0, p1, Lcom/shopee/protocol/action/Notification;->task_name:Ljava/lang/String;

    if-eqz v0, :cond_26

    invoke-interface {v0}, Ljava/lang/CharSequence;->length()I

    move-result v0

    if-nez v0, :cond_24

    goto :goto_26

    :cond_24
    const/4 v0, 0x0

    goto :goto_27

    :cond_26
    :goto_26
    const/4 v0, 0x1

    :goto_27
    if-nez v0, :cond_51

    sget-object v0, Lqa/d;->e:Lqa/d$a;

    sget-object v2, Lej/e$e;->a:Lej/e$e;

    invoke-virtual {v0, v1, v2}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    sget-object v0, Lej/e;->c:Lej/d;

    iget-object v2, p1, Lcom/shopee/protocol/action/Notification;->task_name:Ljava/lang/String;

    const-string v3, "notification.task_name"

    invoke-static {v2, v3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V

    invoke-virtual {v0, v2}, Lej/d;->a(Ljava/lang/Object;)Ljava/util/Queue;

    move-result-object v0

    invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :goto_41
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v2

    if-eqz v2, :cond_51

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v2

    check-cast v2, Lej/a;

    invoke-interface {v2, p1}, Lej/a;->a(Lcom/shopee/protocol/action/Notification;)V

    goto :goto_41

    :cond_51
    iget-object v0, p1, Lcom/shopee/protocol/action/Notification;->noticode:Ljava/lang/Integer;

    if-nez v0, :cond_56

    goto :goto_5c

    :cond_56
    invoke-virtual {v0}, Ljava/lang/Integer;->intValue()I

    move-result v0

    if-eqz v0, :cond_83

    :goto_5c
    sget-object v0, Lqa/d;->e:Lqa/d$a;

    sget-object v2, Lej/e$f;->a:Lej/e$f;

    invoke-virtual {v0, v1, v2}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    sget-object v0, Lej/e;->c:Lej/d;

    iget-object v1, p1, Lcom/shopee/protocol/action/Notification;->noticode:Ljava/lang/Integer;

    invoke-static {v1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;

    move-result-object v1

    invoke-virtual {v0, v1}, Lej/d;->a(Ljava/lang/Object;)Ljava/util/Queue;

    move-result-object v0

    invoke-interface {v0}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object v0

    :goto_73
    invoke-interface {v0}, Ljava/util/Iterator;->hasNext()Z

    move-result v1

    if-eqz v1, :cond_83

    invoke-interface {v0}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Lej/a;

    invoke-interface {v1, p1}, Lej/a;->a(Lcom/shopee/protocol/action/Notification;)V

    goto :goto_73

    :cond_83
    return-void
.end method

.method public final a(Lej/a;)V
    .registers 5

    sget-object v0, Ljd/b;->c:Ljd/b$a;

    invoke-virtual {v0}, Ljd/b$a;->b()Z

    move-result v0

    if-eqz v0, :cond_14

    sget-object v0, Lqa/d;->e:Lqa/d$a;

    new-instance v1, Lej/e$g;

    invoke-direct {v1, p1}, Lej/e$g;-><init>(Lej/a;)V

    const-string v2, "PushProcessor"

    invoke-virtual {v0, v2, v1}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    :cond_14
    invoke-interface {p1}, Lej/a;->b()Ljava/lang/String;

    move-result-object v0

    const/4 v1, 0x0

    const/4 v2, 0x1

    if-eqz v0, :cond_25

    invoke-interface {v0}, Ljava/lang/CharSequence;->length()I

    move-result v0

    if-nez v0, :cond_23

    goto :goto_25

    :cond_23
    const/4 v0, 0x0

    goto :goto_26

    :cond_25
    :goto_25
    const/4 v0, 0x1

    :goto_26
    if-eqz v0, :cond_2f

    invoke-interface {p1}, Lej/a;->a()I

    move-result v0

    if-nez v0, :cond_2f

    return-void

    :cond_2f
    invoke-interface {p1}, Lej/a;->b()Ljava/lang/String;

    move-result-object v0

    if-eqz v0, :cond_3b

    invoke-interface {v0}, Ljava/lang/CharSequence;->length()I

    move-result v0

    if-nez v0, :cond_3c

    :cond_3b
    const/4 v1, 0x1

    :cond_3c
    if-eqz v1, :cond_4c

    sget-object v0, Lej/e;->c:Lej/d;

    invoke-interface {p1}, Lej/a;->a()I

    move-result v1

    invoke-static {v1}, Ljava/lang/String;->valueOf(I)Ljava/lang/String;

    move-result-object v1

    invoke-virtual {v0, v1, p1}, Lej/d;->a(Ljava/lang/Object;Ljava/lang/Object;)V

    goto :goto_59

    :cond_4c
    sget-object v0, Lej/e;->c:Lej/d;

    invoke-interface {p1}, Lej/a;->b()Ljava/lang/String;

    move-result-object v1

    invoke-static {v1}, Ljava/lang/String;->valueOf(Ljava/lang/Object;)Ljava/lang/String;

    move-result-object v1

    invoke-virtual {v0, v1, p1}, Lej/d;->a(Ljava/lang/Object;Ljava/lang/Object;)V

    :goto_59
    return-void
.end method

.method public final a(Lej/b;)V
    .registers 5

    sget-object v0, Ljd/b;->c:Ljd/b$a;

    invoke-virtual {v0}, Ljd/b$a;->b()Z

    move-result v0

    if-eqz v0, :cond_11

    sget-object v0, Lqa/d;->e:Lqa/d$a;

    sget-object v1, Lej/e$h;->a:Lej/e$h;

    const-string v2, "PushProcessor"

    invoke-virtual {v0, v2, v1}, Lqa/d$a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function0;)V

    :cond_11
    sget-object v0, Lej/e;->b:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z

    move-result v0

    if-nez v0, :cond_1e

    sget-object v0, Lej/e;->b:Ljava/util/concurrent/ConcurrentLinkedQueue;

    invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z

    :cond_1e
    return-void
.end method

.method public final a(Ljava/util/List;)V
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/List<",
            "Lcom/shopee/foody/push/core/message/PushItem;",
            ">;)V"
        }
    .end annotation

    if-eqz p1, :cond_b

    invoke-interface {p1}, Ljava/util/Collection;->isEmpty()Z

    move-result v0

    if-eqz v0, :cond_9

    goto :goto_b

    :cond_9
    const/4 v0, 0x0

    goto :goto_c

    :cond_b
    :goto_b
    const/4 v0, 0x1

    :goto_c
    if-eqz v0, :cond_f

    return-void

    :cond_f
    sget-object v1, Lkotlinx/coroutines/GlobalScope;->INSTANCE:Lkotlinx/coroutines/GlobalScope;

    invoke-static {}, Lmd/e;->b()Lmd/d;

    move-result-object v2

    const/4 v3, 0x0

    new-instance v4, Lej/e$a;

    const/4 v0, 0x0

    invoke-direct {v4, p1, v0}, Lej/e$a;-><init>(Ljava/util/List;Lkotlin/coroutines/Continuation;)V

    const/4 v5, 0x2

    const/4 v6, 0x0

    invoke-static/range {v1 .. v6}, Lkotlinx/coroutines/BuildersKt;->launch$default(Lkotlinx/coroutines/CoroutineScope;Lkotlin/coroutines/CoroutineContext;Lkotlinx/coroutines/CoroutineStart;Lkotlin/jvm/functions/Function2;ILjava/lang/Object;)Lkotlinx/coroutines/Job;

    return-void
.end method

.method public a(Ljava/util/List;Z)V
    .registers 6
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/util/List<",
            "Lfl/a;",
            ">;Z)V"
        }
    .end annotation

    sget-object v0, Lej/f;->a:Lej/f;

    invoke-virtual {v0, p1}, Lej/f;->a(Ljava/util/List;)V

    invoke-interface {p1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object p1

    :cond_9
    invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z

    move-result v0

    if-eqz v0, :cond_3d

    invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v0

    check-cast v0, Lfl/a;

    invoke-virtual {v0}, Lcom/shopee/foody/push/core/message/PushMessage;->getData()Lcom/shopee/foody/push/core/message/PushDataSection;

    move-result-object v1

    if-eqz v1, :cond_9

    invoke-virtual {v1}, Lcom/shopee/foody/push/core/message/PushDataSection;->getChannel()I

    move-result v1

    sget-object v2, Lej/e;->a:Landroid/util/SparseArray;

    invoke-virtual {v2, v1}, Landroid/util/SparseArray;->get(I)Ljava/lang/Object;

    move-result-object v1

    check-cast v1, Ljava/util/concurrent/ConcurrentLinkedQueue;

    if-eqz v1, :cond_9

    invoke-interface {v1}, Ljava/lang/Iterable;->iterator()Ljava/util/Iterator;

    move-result-object v1

    :goto_2d
    invoke-interface {v1}, Ljava/util/Iterator;->hasNext()Z

    move-result v2

    if-eqz v2, :cond_9

    invoke-interface {v1}, Ljava/util/Iterator;->next()Ljava/lang/Object;

    move-result-object v2

    check-cast v2, Lej/c;

    invoke-interface {v2, v0, p2}, Lej/c;->a(Lcom/shopee/foody/push/core/message/PushMessage;Z)V

    goto :goto_2d

    :cond_3d
    return-void
.end method