b.smali
.class public final Llg/b;
.super Ljava/lang/Object;
.source "ChatRepo.kt"
# annotations
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000\u00a8\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0008\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\t\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u0008\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0010\u000b\n\u0002\u0008\u0004\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0008\u0014\u0008\u00c6\u0002\u0018\u00002\u00020\u0001B\u0007\u0008\u0002\u00a2\u0006\u0002\u0010\u0002J\u0010\u0010\u001d\u001a\u00020\u001e2\u0006\u0010\u001f\u001a\u00020 H\u0007J\u0019\u0010!\u001a\u00020\u001e2\u0006\u0010\"\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$J\u001b\u0010%\u001a\u0004\u0018\u00010&2\u0006\u0010\'\u001a\u00020(H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010)J\u001b\u0010*\u001a\u0004\u0018\u00010+2\u0006\u0010\'\u001a\u00020,H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010-J\u0016\u0010.\u001a\u0008\u0012\u0004\u0012\u0002000/2\u0006\u00101\u001a\u00020#H\u0007J\u001b\u00102\u001a\u0004\u0018\u0001032\u0006\u00104\u001a\u00020\u0004H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u00105J\u001b\u00106\u001a\u0004\u0018\u0001072\u0006\u0010\"\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$J\u0016\u00108\u001a\u0008\u0012\u0004\u0012\u0002090/2\u0006\u0010:\u001a\u00020\u0004H\u0007J\u0016\u0010;\u001a\u0008\u0012\u0004\u0012\u00020<0/2\u0006\u0010=\u001a\u00020\u0004H\u0007J\u0019\u0010>\u001a\u00020?2\u0006\u0010@\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$J\u0010\u0010A\u001a\u00020\u001e2\u0006\u0010\"\u001a\u00020#H\u0007J\u0018\u0010A\u001a\u00020\u001e2\u0006\u0010\"\u001a\u00020#2\u0006\u0010B\u001a\u00020#H\u0007J(\u0010C\u001a\u0012\u0012\u000c\u0012\n\u0012\u0004\u0012\u000203\u0018\u00010E\u0018\u00010D2\u0006\u0010\"\u001a\u00020#2\u0006\u0010F\u001a\u000207H\u0007J!\u0010G\u001a\u0002072\u0006\u0010\"\u001a\u00020#2\u0006\u0010F\u001a\u000207H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010HJ\u0010\u0010I\u001a\u00020\u001e2\u0006\u0010\u001f\u001a\u00020 H\u0007J\u0010\u0010J\u001a\u00020\u001e2\u0006\u00104\u001a\u00020\u0004H\u0007J\u0019\u0010K\u001a\u00020\u001e2\u0006\u0010L\u001a\u000203H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010MJ!\u0010K\u001a\u00020\u001e2\u000e\u0010L\u001a\n\u0012\u0004\u0012\u000203\u0018\u00010EH\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010NJ#\u0010O\u001a\u0004\u0018\u0001032\u0006\u0010P\u001a\u00020\u00042\u0006\u0010\"\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010QJ#\u0010R\u001a\u0004\u0018\u0001032\u0006\u0010S\u001a\u00020\u00042\u0006\u0010\"\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010QJ!\u0010T\u001a\u00020\u001e2\u0006\u0010\"\u001a\u00020#2\u0006\u0010U\u001a\u00020#H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010VJ\u0019\u0010W\u001a\u00020\u001e2\u0006\u0010X\u001a\u000203H\u0086@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010MR\u000e\u0010\u0003\u001a\u00020\u0004X\u0082T\u00a2\u0006\u0002\n\u0000R\u0016\u0010\u0005\u001a\u0004\u0018\u00010\u00068BX\u0082\u0004\u00a2\u0006\u0006\u001a\u0004\u0008\u0007\u0010\u0008R\u0016\u0010\t\u001a\u0004\u0018\u00010\n8BX\u0082\u0004\u00a2\u0006\u0006\u001a\u0004\u0008\u000b\u0010\u000cR\u001b\u0010\r\u001a\u00020\u000e8BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\u0011\u0010\u0012\u001a\u0004\u0008\u000f\u0010\u0010R\u001b\u0010\u0013\u001a\u00020\u00148BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\u0017\u0010\u0012\u001a\u0004\u0008\u0015\u0010\u0016R\u001d\u0010\u0018\u001a\u0004\u0018\u00010\u00198BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\u001c\u0010\u0012\u001a\u0004\u0008\u001a\u0010\u001b\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u0006Y"
}
d2 = {
"Lcom/shopee/foody/driver/im/business/ChatRepo;",
"",
"()V",
"TAG",
"",
"conversationDao",
"Lcom/shopee/foody/driver/db/user/im/DbConversationDao;",
"getConversationDao",
"()Lcom/shopee/foody/driver/db/user/im/DbConversationDao;",
"dbMsgDao",
"Lcom/shopee/foody/driver/db/user/im/DbMessageDao;",
"getDbMsgDao",
"()Lcom/shopee/foody/driver/db/user/im/DbMessageDao;",
"httpService",
"Lcom/shopee/foody/driver/im/business/network/service/ChatHttpService;",
"getHttpService",
"()Lcom/shopee/foody/driver/im/business/network/service/ChatHttpService;",
"httpService$delegate",
"Lkotlin/Lazy;",
"imConditionService",
"Lcom/shopee/foody/driver/conditiontask/custom/im/IMConditionTaskService;",
"getImConditionService",
"()Lcom/shopee/foody/driver/conditiontask/custom/im/IMConditionTaskService;",
"imConditionService$delegate",
"okTcpService",
"Lcom/shopee/foody/driver/oktcp/IOkTcpService;",
"getOkTcpService",
"()Lcom/shopee/foody/driver/oktcp/IOkTcpService;",
"okTcpService$delegate",
"addNewMsgArriveObserver",
"",
"callback",
"Lcom/shopee/foody/driver/oktcp/PushCallback;",
"clearLocalConversion",
"conversationID",
"",
"(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"fetchChatMsgContent",
"Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsg;",
"req",
"Lcom/shopee/foody/driver/im/business/network/model/GetChatMessagesRequest;",
"(Lcom/shopee/foody/driver/im/business/network/model/GetChatMessagesRequest;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"fetchChatMsgIds",
"Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsgid;",
"Lcom/shopee/foody/driver/im/business/network/model/GetChatMessageIdsRequest;",
"(Lcom/shopee/foody/driver/im/business/network/model/GetChatMessageIdsRequest;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"getConversationInfo",
"Lcom/shopee/foody/driver/user/model/common/Result;",
"Lcom/shopee/foody/driver/im/business/network/model/bff/ConvInfo;",
"conversationId",
"getDbMsgByRequestId",
"Lcom/shopee/foody/driver/db/user/im/DBChatMessage;",
"requestId",
"(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"getFailedMsgCount",
"",
"getOrderInfo",
"Lcom/shopee/foody/driver/order/OrderResp;",
"orderId",
"getStoreInfo",
"Lcom/shopee/foody/driver/order/StoreInfoResp;",
"storeId",
"isMsgInDb",
"",
"msgId",
"markRead",
"messageId",
"readLocalDbMsg",
"Lkotlinx/coroutines/flow/Flow;",
"",
"limit",
"readLocalDbMsgSize",
"(JILkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"removeObserver",
"resendMsg",
"saveMsgToDb",
"chatMsg",
"(Lcom/shopee/foody/driver/db/user/im/DBChatMessage;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"(Ljava/util/List;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"sendImageMsg",
"localPath",
"(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"sendTextMsg",
"text",
"updateConversationLastMsgId",
"lastMsgId",
"(JJLkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"updateDbMsg",
"dbChatMessage",
"driver_indonesiaRelease"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# static fields
.field public static final a:Lkotlin/Lazy;
.field public static final b:Lkotlin/Lazy;
.field public static final c:Lkotlin/Lazy;
.field public static final d:Llg/b;
# direct methods
.method public static constructor <clinit>()V
.registers 1
new-instance v0, Llg/b;
invoke-direct {v0}, Llg/b;-><init>()V
sput-object v0, Llg/b;->d:Llg/b;
sget-object v0, Llg/b$k;->a:Llg/b$k;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
sput-object v0, Llg/b;->a:Lkotlin/Lazy;
sget-object v0, Llg/b$g;->a:Llg/b$g;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
sput-object v0, Llg/b;->b:Lkotlin/Lazy;
sget-object v0, Llg/b$f;->a:Llg/b$f;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
sput-object v0, Llg/b;->c:Lkotlin/Lazy;
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 final synthetic a(Llg/b;)Lpe/d;
.registers 1
invoke-virtual {p0}, Llg/b;->a()Lpe/d;
move-result-object p0
return-object p0
.end method
.method public static final synthetic b(Llg/b;)Lrg/a;
.registers 1
invoke-virtual {p0}, Llg/b;->c()Lrg/a;
move-result-object p0
return-object p0
.end method
# virtual methods
.method public final a(JILkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(JI",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/Integer;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p4, Llg/b$l;
if-eqz v0, :cond_13
move-object v0, p4
check-cast v0, Llg/b$l;
iget v1, v0, Llg/b$l;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$l;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$l;
invoke-direct {v0, p0, p4}, Llg/b$l;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p4, v0, Llg/b$l;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$l;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget p1, v0, Llg/b$l;->f:I
iget-wide p1, v0, Llg/b$l;->e:J
iget-object p1, v0, Llg/b$l;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p4}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_51
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p4}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p4
if-eqz p4, :cond_5a
iput-object p0, v0, Llg/b$l;->d:Ljava/lang/Object;
iput-wide p1, v0, Llg/b$l;->e:J
iput p3, v0, Llg/b$l;->f:I
iput v3, v0, Llg/b$l;->b:I
invoke-interface {p4, p1, p2, p3, v0}, Lpe/f;->a(JILkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p4
if-ne p4, v1, :cond_51
return-object v1
:cond_51
:goto_51
check-cast p4, Ljava/lang/Integer;
if-eqz p4, :cond_5a
invoke-virtual {p4}, Ljava/lang/Integer;->intValue()I
move-result p1
goto :goto_5b
:cond_5a
const/4 p1, 0x0
:goto_5b
invoke-static {p1}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object p1
return-object p1
.end method
.method public final a(JJLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 28
.annotation system Ldalvik/annotation/Signature;
value = {
"(JJ",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
move-object/from16 v0, p0
move-wide/from16 v1, p1
move-object/from16 v3, p5
instance-of v4, v3, Llg/b$o;
if-eqz v4, :cond_19
move-object v4, v3
check-cast v4, Llg/b$o;
iget v5, v4, Llg/b$o;->b:I
const/high16 v6, -0x80000000
and-int v7, v5, v6
if-eqz v7, :cond_19
sub-int/2addr v5, v6
iput v5, v4, Llg/b$o;->b:I
goto :goto_1e
:cond_19
new-instance v4, Llg/b$o;
invoke-direct {v4, v0, v3}, Llg/b$o;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_1e
iget-object v3, v4, Llg/b$o;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v5
iget v6, v4, Llg/b$o;->b:I
const/4 v7, 0x1
const/4 v8, 0x2
if-eqz v6, :cond_59
if-eq v6, v7, :cond_47
if-ne v6, v8, :cond_3f
iget-object v1, v4, Llg/b$o;->e:Ljava/lang/Object;
check-cast v1, Lpe/c;
iget-wide v1, v4, Llg/b$o;->g:J
iget-wide v5, v4, Llg/b$o;->f:J
iget-object v4, v4, Llg/b$o;->d:Ljava/lang/Object;
check-cast v4, Llg/b;
invoke-static {v3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_ad
:cond_3f
new-instance v1, Ljava/lang/IllegalStateException;
const-string v2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {v1, v2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw v1
:cond_47
iget-wide v1, v4, Llg/b$o;->g:J
iget-wide v6, v4, Llg/b$o;->f:J
iget-object v9, v4, Llg/b$o;->d:Ljava/lang/Object;
check-cast v9, Llg/b;
invoke-static {v3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
move-wide/from16 v20, v6
move-object v6, v9
move-wide v9, v1
move-wide/from16 v1, v20
goto :goto_74
:cond_59
invoke-static {v3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual/range {p0 .. p0}, Llg/b;->a()Lpe/d;
move-result-object v3
if-eqz v3, :cond_79
iput-object v0, v4, Llg/b$o;->d:Ljava/lang/Object;
iput-wide v1, v4, Llg/b$o;->f:J
move-wide/from16 v9, p3
iput-wide v9, v4, Llg/b$o;->g:J
iput v7, v4, Llg/b$o;->b:I
invoke-interface {v3, v1, v2, v4}, Lpe/d;->c(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v3
if-ne v3, v5, :cond_73
return-object v5
:cond_73
move-object v6, v0
:goto_74
check-cast v3, Lpe/c;
if-eqz v3, :cond_7c
goto :goto_8c
:cond_79
move-wide/from16 v9, p3
move-object v6, v0
:cond_7c
new-instance v3, Lpe/c;
const/4 v12, 0x0
const-wide/16 v15, 0x0
const/16 v17, 0x0
const/16 v18, 0xd
const/16 v19, 0x0
move-object v11, v3
move-wide v13, v1
invoke-direct/range {v11 .. v19}, Lpe/c;-><init>(IJJLjava/lang/String;ILkotlin/jvm/internal/DefaultConstructorMarker;)V
:goto_8c
move-wide/from16 v20, v9
move-object v9, v6
move-wide v6, v1
move-wide/from16 v1, v20
invoke-virtual {v3, v1, v2}, Lpe/c;->a(J)V
invoke-virtual {v9}, Llg/b;->a()Lpe/d;
move-result-object v10
if-eqz v10, :cond_ae
iput-object v9, v4, Llg/b$o;->d:Ljava/lang/Object;
iput-wide v6, v4, Llg/b$o;->f:J
iput-wide v1, v4, Llg/b$o;->g:J
iput-object v3, v4, Llg/b$o;->e:Ljava/lang/Object;
iput v8, v4, Llg/b$o;->b:I
invoke-interface {v10, v3, v4}, Lpe/d;->a(Lpe/c;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v3
if-ne v3, v5, :cond_ac
return-object v5
:cond_ac
move-wide v5, v6
:goto_ad
move-wide v6, v5
:cond_ae
sget-object v3, Llg/c;->a:Llg/c;
new-instance v4, Ljava/lang/StringBuilder;
invoke-direct {v4}, Ljava/lang/StringBuilder;-><init>()V
const-string v5, "updateConversationLastMsgId(). conversationId: "
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v6, v7}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
const-string v5, ", lastMsgId: "
invoke-virtual {v4, v5}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4, v1, v2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v1
const/4 v2, 0x0
invoke-static {v3, v1, v2, v8, v2}, Llg/c;->b(Llg/c;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)V
sget-object v1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object v1
.end method
.method public final a(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(J",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p3, Llg/b$a;
if-eqz v0, :cond_13
move-object v0, p3
check-cast v0, Llg/b$a;
iget v1, v0, Llg/b$a;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$a;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$a;
invoke-direct {v0, p0, p3}, Llg/b$a;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p3, v0, Llg/b$a;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$a;->b:I
const/4 v3, 0x2
const/4 v4, 0x1
if-eqz v2, :cond_44
if-eq v2, v4, :cond_3a
if-ne v2, v3, :cond_32
iget-wide p1, v0, Llg/b$a;->e:J
iget-object p1, v0, Llg/b$a;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_6e
:cond_32
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_3a
iget-wide p1, v0, Llg/b$a;->e:J
iget-object v2, v0, Llg/b$a;->d:Ljava/lang/Object;
check-cast v2, Llg/b;
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_5b
:cond_44
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->a()Lpe/d;
move-result-object p3
if-eqz p3, :cond_5a
iput-object p0, v0, Llg/b$a;->d:Ljava/lang/Object;
iput-wide p1, v0, Llg/b$a;->e:J
iput v4, v0, Llg/b$a;->b:I
invoke-interface {p3, p1, p2, v0}, Lpe/d;->b(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p3
if-ne p3, v1, :cond_5a
return-object v1
:cond_5a
move-object v2, p0
:goto_5b
invoke-virtual {v2}, Llg/b;->b()Lpe/f;
move-result-object p3
if-eqz p3, :cond_6e
iput-object v2, v0, Llg/b$a;->d:Ljava/lang/Object;
iput-wide p1, v0, Llg/b$a;->e:J
iput v3, v0, Llg/b$a;->b:I
invoke-interface {p3, p1, p2, v0}, Lpe/f;->d(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
if-ne p1, v1, :cond_6e
return-object v1
:cond_6e
:goto_6e
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final a(Lcom/shopee/foody/driver/im/business/network/model/GetChatMessageIdsRequest;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/im/business/network/model/GetChatMessageIdsRequest;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsgid;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$c;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$c;
iget v1, v0, Llg/b$c;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$c;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$c;
invoke-direct {v0, p0, p2}, Llg/b$c;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$c;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$c;->b:I
const/4 v3, 0x1
const/4 v4, 0x0
if-eqz v2, :cond_3a
if-ne v2, v3, :cond_32
iget-object p1, v0, Llg/b$c;->e:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/im/business/network/model/GetChatMessageIdsRequest;
iget-object p1, v0, Llg/b$c;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
:try_start_2e
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
:try_end_31
.catch Ljava/lang/Exception; {:try_start_2e .. :try_end_31} :catch_62
goto :goto_50
:cond_32
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_3a
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
:try_start_3d
invoke-virtual {p0}, Llg/b;->e()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
move-result-object p2
if-eqz p2, :cond_53
iput-object p0, v0, Llg/b$c;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$c;->e:Ljava/lang/Object;
iput v3, v0, Llg/b$c;->b:I
invoke-interface {p2, p1, v0}, Lcom/shopee/foody/driver/oktcp/IOkTcpService;->sendReq(Lmc/b;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_50
return-object v1
:cond_50
:goto_50
check-cast p2, Lcom/squareup/wire/Message;
goto :goto_54
:cond_53
move-object p2, v4
:goto_54
if-eqz p2, :cond_5a
check-cast p2, Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsgid;
move-object v4, p2
goto :goto_7e
:cond_5a
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type com.shopee.foody.driver.im.business.network.model.proto.action.ResponseChatMsgid"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
:try_end_62
.catch Ljava/lang/Exception; {:try_start_3d .. :try_end_62} :catch_62
:catch_62
move-exception p1
sget-object p2, Llg/c;->a:Llg/c;
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "fetchChatMsgIds() failed, error msg: "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object p1
invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
const/4 v0, 0x2
invoke-static {p2, p1, v4, v0, v4}, Llg/c;->b(Llg/c;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)V
:goto_7e
return-object v4
.end method
.method public final a(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"J",
"Lkotlin/coroutines/Continuation<",
"-",
"Lpe/a;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->d()Lyd/a;
move-result-object v0
invoke-virtual {v0, p1, p2, p3, p4}, Lyd/a;->a(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
return-object p1
.end method
.method public final a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lpe/a;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$d;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$d;
iget v1, v0, Llg/b$d;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$d;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$d;
invoke-direct {v0, p0, p2}, Llg/b$d;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$d;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$d;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Llg/b$d;->e:Ljava/lang/Object;
check-cast p1, Ljava/lang/String;
iget-object p1, v0, Llg/b$d;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_4f
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p2
if-eqz p2, :cond_52
iput-object p0, v0, Llg/b$d;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$d;->e:Ljava/lang/Object;
iput v3, v0, Llg/b$d;->b:I
invoke-interface {p2, p1, v0}, Lpe/f;->a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_4f
return-object v1
:cond_4f
:goto_4f
check-cast p2, Lpe/a;
goto :goto_53
:cond_52
const/4 p2, 0x0
:goto_53
return-object p2
.end method
.method public final a(Ljava/util/List;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/util/List<",
"Lpe/a;",
">;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$m;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$m;
iget v1, v0, Llg/b$m;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$m;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$m;
invoke-direct {v0, p0, p2}, Llg/b$m;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$m;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$m;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_3d
if-ne v2, v3, :cond_35
iget-object p1, v0, Llg/b$m;->f:Ljava/lang/Object;
check-cast p1, Ljava/util/List;
iget-object p1, v0, Llg/b$m;->e:Ljava/lang/Object;
check-cast p1, Ljava/util/List;
iget-object p1, v0, Llg/b$m;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_59
:cond_35
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_3d
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
if-eqz p1, :cond_59
sget-object p2, Llg/b;->d:Llg/b;
invoke-virtual {p2}, Llg/b;->b()Lpe/f;
move-result-object p2
if-eqz p2, :cond_59
iput-object p0, v0, Llg/b$m;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$m;->e:Ljava/lang/Object;
iput-object p1, v0, Llg/b$m;->f:Ljava/lang/Object;
iput v3, v0, Llg/b$m;->b:I
invoke-interface {p2, p1, v0}, Lpe/f;->a(Ljava/util/List;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
if-ne p1, v1, :cond_59
return-object v1
:cond_59
:goto_59
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final a(Lng/b;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lng/b;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsg;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$b;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$b;
iget v1, v0, Llg/b$b;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$b;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$b;
invoke-direct {v0, p0, p2}, Llg/b$b;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$b;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$b;->b:I
const/4 v3, 0x1
const/4 v4, 0x0
if-eqz v2, :cond_3a
if-ne v2, v3, :cond_32
iget-object p1, v0, Llg/b$b;->e:Ljava/lang/Object;
check-cast p1, Lng/b;
iget-object p1, v0, Llg/b$b;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
:try_start_2e
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
:try_end_31
.catch Ljava/lang/Exception; {:try_start_2e .. :try_end_31} :catch_62
goto :goto_50
:cond_32
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_3a
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
:try_start_3d
invoke-virtual {p0}, Llg/b;->e()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
move-result-object p2
if-eqz p2, :cond_53
iput-object p0, v0, Llg/b$b;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$b;->e:Ljava/lang/Object;
iput v3, v0, Llg/b$b;->b:I
invoke-interface {p2, p1, v0}, Lcom/shopee/foody/driver/oktcp/IOkTcpService;->sendReq(Lmc/b;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_50
return-object v1
:cond_50
:goto_50
check-cast p2, Lcom/squareup/wire/Message;
goto :goto_54
:cond_53
move-object p2, v4
:goto_54
if-eqz p2, :cond_5a
check-cast p2, Lcom/shopee/foody/driver/im/business/network/model/proto/action/ResponseChatMsg;
move-object v4, p2
goto :goto_7e
:cond_5a
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type com.shopee.foody.driver.im.business.network.model.proto.action.ResponseChatMsg"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
:try_end_62
.catch Ljava/lang/Exception; {:try_start_3d .. :try_end_62} :catch_62
:catch_62
move-exception p1
sget-object p2, Llg/c;->a:Llg/c;
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "fetchChatMsgContent() failed, error msg: "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Ljava/lang/Exception;->getMessage()Ljava/lang/String;
move-result-object p1
invoke-virtual {v0, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
const/4 v0, 0x2
invoke-static {p2, p1, v4, v0, v4}, Llg/c;->b(Llg/c;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)V
:goto_7e
return-object v4
.end method
.method public final a(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lpe/a;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$n;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$n;
iget v1, v0, Llg/b$n;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$n;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$n;
invoke-direct {v0, p0, p2}, Llg/b$n;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$n;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$n;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Llg/b$n;->e:Ljava/lang/Object;
check-cast p1, Lpe/a;
iget-object p1, v0, Llg/b$n;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_4f
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p2
if-eqz p2, :cond_4f
iput-object p0, v0, Llg/b$n;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$n;->e:Ljava/lang/Object;
iput v3, v0, Llg/b$n;->b:I
invoke-interface {p2, p1, v0}, Lpe/f;->a(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
if-ne p1, v1, :cond_4f
return-object v1
:cond_4f
:goto_4f
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final a(JI)Lkotlinx/coroutines/flow/Flow;
.registers 5
.annotation build Landroidx/annotation/AnyThread;
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"(JI)",
"Lkotlinx/coroutines/flow/Flow<",
"Ljava/util/List<",
"Lpe/a;",
">;>;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object v0
if-eqz v0, :cond_b
invoke-interface {v0, p1, p2, p3}, Lpe/f;->a(JI)Lkotlinx/coroutines/flow/Flow;
move-result-object p1
goto :goto_c
:cond_b
const/4 p1, 0x0
:goto_c
return-object p1
.end method
.method public final a()Lpe/d;
.registers 2
sget-object v0, Lke/a;->e:Lke/a;
invoke-virtual {v0}, Lke/a;->b()Lcom/shopee/foody/driver/db/user/UserDB;
move-result-object v0
if-eqz v0, :cond_d
invoke-virtual {v0}, Lcom/shopee/foody/driver/db/user/UserDB;->b()Lpe/d;
move-result-object v0
goto :goto_e
:cond_d
const/4 v0, 0x0
:goto_e
return-object v0
.end method
.method public final a(J)Ltk/d;
.registers 4
.annotation build Landroidx/annotation/WorkerThread;
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"(J)",
"Ltk/d<",
"Lcom/shopee/foody/driver/im/business/network/model/bff/ConvInfo;",
">;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->c()Lrg/a;
move-result-object v0
invoke-virtual {v0, p1, p2}, Lrg/a;->a(J)Ltk/d;
move-result-object p1
return-object p1
.end method
.method public final a(Ljava/lang/String;)Ltk/d;
.registers 3
.annotation build Landroidx/annotation/WorkerThread;
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
")",
"Ltk/d<",
"Lcom/shopee/foody/driver/order/OrderResp;",
">;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->c()Lrg/a;
move-result-object v0
invoke-virtual {v0, p1}, Lrg/a;->a(Ljava/lang/String;)Ltk/d;
move-result-object p1
return-object p1
.end method
.method public final a(JJ)V
.registers 12
.annotation build Landroidx/annotation/AnyThread;
.end annotation
new-instance v6, Llg/b$j;
const/4 v5, 0x0
move-object v0, v6
move-wide v1, p1
move-wide v3, p3
invoke-direct/range {v0 .. v5}, Llg/b$j;-><init>(JJLkotlin/coroutines/Continuation;)V
invoke-static {v6}, Lhe/b;->b(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;
return-void
.end method
.method public final a(Lii/a;)V
.registers 4
.annotation build Landroidx/annotation/AnyThread;
.end annotation
invoke-virtual {p0}, Llg/b;->e()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
move-result-object v0
if-eqz v0, :cond_f
sget-object v1, Lcom/shopee/protocol/action/CommandExt;->CMD_BIZ_CHAT_RECV:Lcom/shopee/protocol/action/CommandExt;
invoke-virtual {v1}, Lcom/shopee/protocol/action/CommandExt;->getValue()I
move-result v1
invoke-interface {v0, v1, p1}, Lcom/shopee/foody/driver/oktcp/IOkTcpService;->observePush(ILii/a;)V
:cond_f
return-void
.end method
.method public final b(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(J",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/Integer;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p3, Llg/b$e;
if-eqz v0, :cond_13
move-object v0, p3
check-cast v0, Llg/b$e;
iget v1, v0, Llg/b$e;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$e;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$e;
invoke-direct {v0, p0, p3}, Llg/b$e;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p3, v0, Llg/b$e;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$e;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_37
if-ne v2, v3, :cond_2f
iget-wide p1, v0, Llg/b$e;->e:J
iget-object p1, v0, Llg/b$e;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_4d
:cond_2f
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_37
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p3
if-eqz p3, :cond_50
iput-object p0, v0, Llg/b$e;->d:Ljava/lang/Object;
iput-wide p1, v0, Llg/b$e;->e:J
iput v3, v0, Llg/b$e;->b:I
invoke-interface {p3, p1, p2, v0}, Lpe/f;->a(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p3
if-ne p3, v1, :cond_4d
return-object v1
:cond_4d
:goto_4d
check-cast p3, Ljava/lang/Integer;
goto :goto_51
:cond_50
const/4 p3, 0x0
:goto_51
return-object p3
.end method
.method public final b(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 6
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"J",
"Lkotlin/coroutines/Continuation<",
"-",
"Lpe/a;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->d()Lyd/a;
move-result-object v0
invoke-virtual {v0, p1, p2, p3, p4}, Lyd/a;->b(Ljava/lang/String;JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
return-object p1
.end method
.method public final b(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lpe/a;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Llg/b$p;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Llg/b$p;
iget v1, v0, Llg/b$p;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$p;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$p;
invoke-direct {v0, p0, p2}, Llg/b$p;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Llg/b$p;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$p;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Llg/b$p;->e:Ljava/lang/Object;
check-cast p1, Lpe/a;
iget-object p1, v0, Llg/b$p;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_54
:cond_31
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_39
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p2
if-eqz p2, :cond_54
new-array v2, v3, [Lpe/a;
const/4 v4, 0x0
aput-object p1, v2, v4
iput-object p0, v0, Llg/b$p;->d:Ljava/lang/Object;
iput-object p1, v0, Llg/b$p;->e:Ljava/lang/Object;
iput v3, v0, Llg/b$p;->b:I
invoke-interface {p2, v2, v0}, Lle/a;->b([Ljava/lang/Object;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
if-ne p1, v1, :cond_54
return-object v1
:cond_54
:goto_54
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final b()Lpe/f;
.registers 2
sget-object v0, Lke/a;->e:Lke/a;
invoke-virtual {v0}, Lke/a;->b()Lcom/shopee/foody/driver/db/user/UserDB;
move-result-object v0
if-eqz v0, :cond_d
invoke-virtual {v0}, Lcom/shopee/foody/driver/db/user/UserDB;->c()Lpe/f;
move-result-object v0
goto :goto_e
:cond_d
const/4 v0, 0x0
:goto_e
return-object v0
.end method
.method public final b(Ljava/lang/String;)Ltk/d;
.registers 3
.annotation build Landroidx/annotation/WorkerThread;
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
")",
"Ltk/d<",
"Lcom/shopee/foody/driver/order/StoreInfoResp;",
">;"
}
.end annotation
invoke-virtual {p0}, Llg/b;->c()Lrg/a;
move-result-object v0
invoke-virtual {v0, p1}, Lrg/a;->d(Ljava/lang/String;)Ltk/d;
move-result-object p1
return-object p1
.end method
.method public final b(J)V
.registers 5
.annotation build Landroidx/annotation/AnyThread;
.end annotation
new-instance v0, Llg/b$i;
const/4 v1, 0x0
invoke-direct {v0, p1, p2, v1}, Llg/b$i;-><init>(JLkotlin/coroutines/Continuation;)V
invoke-static {v0}, Lhe/b;->b(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;
return-void
.end method
.method public final b(Lii/a;)V
.registers 3
.annotation build Landroidx/annotation/AnyThread;
.end annotation
invoke-virtual {p0}, Llg/b;->e()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
move-result-object v0
if-eqz v0, :cond_9
invoke-interface {v0, p1}, Lcom/shopee/foody/driver/oktcp/IOkTcpService;->unRegisterPushObserver(Lii/a;)V
:cond_9
return-void
.end method
.method public final c(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 8
.annotation system Ldalvik/annotation/Signature;
value = {
"(J",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/Boolean;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p3, Llg/b$h;
if-eqz v0, :cond_13
move-object v0, p3
check-cast v0, Llg/b$h;
iget v1, v0, Llg/b$h;->b:I
const/high16 v2, -0x80000000
and-int v3, v1, v2
if-eqz v3, :cond_13
sub-int/2addr v1, v2
iput v1, v0, Llg/b$h;->b:I
goto :goto_18
:cond_13
new-instance v0, Llg/b$h;
invoke-direct {v0, p0, p3}, Llg/b$h;-><init>(Llg/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p3, v0, Llg/b$h;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v1
iget v2, v0, Llg/b$h;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_37
if-ne v2, v3, :cond_2f
iget-wide p1, v0, Llg/b$h;->e:J
iget-object p1, v0, Llg/b$h;->d:Ljava/lang/Object;
check-cast p1, Llg/b;
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_4d
:cond_2f
new-instance p1, Ljava/lang/IllegalStateException;
const-string p2, "call to \'resume\' before \'invoke\' with coroutine"
invoke-direct {p1, p2}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p1
:cond_37
invoke-static {p3}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p0}, Llg/b;->b()Lpe/f;
move-result-object p3
if-eqz p3, :cond_50
iput-object p0, v0, Llg/b$h;->d:Ljava/lang/Object;
iput-wide p1, v0, Llg/b$h;->e:J
iput v3, v0, Llg/b$h;->b:I
invoke-interface {p3, p1, p2, v0}, Lpe/f;->e(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p3
if-ne p3, v1, :cond_4d
return-object v1
:cond_4d
:goto_4d
check-cast p3, Lpe/a;
goto :goto_51
:cond_50
const/4 p3, 0x0
:goto_51
if-eqz p3, :cond_54
goto :goto_55
:cond_54
const/4 v3, 0x0
:goto_55
invoke-static {v3}, Lkotlin/coroutines/jvm/internal/Boxing;->boxBoolean(Z)Ljava/lang/Boolean;
move-result-object p1
return-object p1
.end method
.method public final c()Lrg/a;
.registers 2
sget-object v0, Llg/b;->c:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lrg/a;
return-object v0
.end method
.method public final c(Ljava/lang/String;)V
.registers 3
.annotation build Landroidx/annotation/AnyThread;
.end annotation
sget-object v0, Lwd/a;->c:Lwd/a;
invoke-virtual {v0}, Lwd/a;->a()Lyd/a;
move-result-object v0
invoke-virtual {v0, p1}, Lzd/a;->b(Ljava/lang/String;)V
return-void
.end method
.method public final d()Lyd/a;
.registers 2
sget-object v0, Llg/b;->b:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lyd/a;
return-object v0
.end method
.method public final e()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
.registers 2
sget-object v0, Llg/b;->a:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/shopee/foody/driver/oktcp/IOkTcpService;
return-object v0
.end method