b.smali
.class public final Lyd/b;
.super Ljava/lang/Object;
.source "IMRequestAdapter.kt"
# interfaces
.implements Lae/b;
# annotations
.annotation system Ldalvik/annotation/MemberClasses;
value = {
Lyd/b$a;
}
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/lang/Object;",
"Lae/b<",
"Lyd/c;",
"Lcom/shopee/protocol/ResponseCommon;",
">;"
}
.end annotation
.annotation runtime Lkotlin/Metadata;
bv = {
0x1,
0x0,
0x3
}
d1 = {
"\u0000j\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0002\u0008\u0005\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0004\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u000e\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0007\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0012\n\u0002\u0008\t\u0018\u0000 72\u000e\u0012\u0004\u0012\u00020\u0002\u0012\u0004\u0012\u00020\u00030\u0001:\u00017B\u0005\u00a2\u0006\u0002\u0010\u0004J\u0012\u0010\u0012\u001a\u00020\u00132\u0008\u0010\u0014\u001a\u0004\u0018\u00010\u0015H\u0002J\u0019\u0010\u0016\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u0017H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0019J\u0010\u0010\u001a\u001a\u00020\u001b2\u0006\u0010\u001c\u001a\u00020\u0002H\u0016J\u0010\u0010\u001d\u001a\u00020\u00022\u0006\u0010\u001e\u001a\u00020\u001bH\u0016J\u0019\u0010\u001f\u001a\u00020\u00032\u0006\u0010\u001e\u001a\u00020\u001bH\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010 J\u0019\u0010!\u001a\u00020\u00032\u0006\u0010\"\u001a\u00020#H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$J\u0008\u0010%\u001a\u00020\u0017H\u0016J\u000e\u0010&\u001a\u0008\u0012\u0004\u0012\u00020\u00020\'H\u0016J\u0010\u0010(\u001a\u00020\u00172\u0006\u0010)\u001a\u00020\u0002H\u0016J\u0010\u0010*\u001a\u00020+2\u0006\u0010)\u001a\u00020\u0002H\u0016J\u0012\u0010,\u001a\u00020-2\u0008\u0010.\u001a\u0004\u0018\u00010/H\u0002J\u0019\u00100\u001a\u00020\u00132\u0006\u00101\u001a\u00020#H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$J\u0010\u00102\u001a\u00020\u00132\u0006\u0010)\u001a\u00020\u0002H\u0016J\u0019\u00103\u001a\u00020\u00132\u0006\u0010\u001e\u001a\u00020\u001bH\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010 J\u0019\u00104\u001a\u00020\u00132\u0006\u0010\u001e\u001a\u00020\u001bH\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010 J\u0019\u00105\u001a\u00020\u00132\u0006\u0010\u001e\u001a\u00020\u001bH\u0096@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010 J\u0019\u00106\u001a\u00020\u00132\u0006\u00101\u001a\u00020#H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010$R\u001d\u0010\u0005\u001a\u0004\u0018\u00010\u00068BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\t\u0010\n\u001a\u0004\u0008\u0007\u0010\u0008R\u0014\u0010\u000b\u001a\u0008\u0012\u0004\u0012\u00020\u00020\u000cX\u0082\u0004\u00a2\u0006\u0002\n\u0000R\u001d\u0010\r\u001a\u0004\u0018\u00010\u000e8BX\u0082\u0084\u0002\u00a2\u0006\u000c\n\u0004\u0008\u0011\u0010\n\u001a\u0004\u0008\u000f\u0010\u0010\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u00068"
}
d2 = {
"Lcom/shopee/foody/driver/conditiontask/custom/im/IMRequestAdapter;",
"Lcom/shopee/foody/driver/conditiontask/internal/adapters/ITaskAdapter;",
"Lcom/shopee/foody/driver/conditiontask/custom/im/IMServiceSendChatReq;",
"Lcom/shopee/protocol/ResponseCommon;",
"()V",
"mOkTcpService",
"Lcom/shopee/foody/driver/oktcp/IOkTcpService;",
"getMOkTcpService",
"()Lcom/shopee/foody/driver/oktcp/IOkTcpService;",
"mOkTcpService$delegate",
"Lkotlin/Lazy;",
"mProceedingRequests",
"Ljava/util/concurrent/ConcurrentLinkedQueue;",
"mUploadService",
"Lcom/shopee/android/upload/service/IUploadService;",
"getMUploadService",
"()Lcom/shopee/android/upload/service/IUploadService;",
"mUploadService$delegate",
"assertNotNull",
"",
"any",
"",
"assertUploadSuccess",
"",
"path",
"(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"buildTaskInfo",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"rawRequest",
"convertTaskInfoToRawRequest",
"taskInfo",
"doRequest",
"(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"doSendReq",
"dbMsg",
"Lcom/shopee/foody/driver/db/user/im/DBChatMessage;",
"(Lcom/shopee/foody/driver/db/user/im/DBChatMessage;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
"getBizID",
"getRawRequestType",
"Ljava/lang/Class;",
"getRequestId",
"req",
"isReqInProceeding",
"",
"parseImageInfo",
"Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;",
"content",
"",
"preparePic",
"dbChatMessage",
"recordReq",
"taskCanceled",
"taskExecutedFailed",
"taskExecutedSucceed",
"uploadPic",
"Companion",
"driver_indonesiaRelease"
}
k = 0x1
mv = {
0x1,
0x1,
0x10
}
.end annotation
# instance fields
.field public final a:Ljava/util/concurrent/ConcurrentLinkedQueue;
.annotation system Ldalvik/annotation/Signature;
value = {
"Ljava/util/concurrent/ConcurrentLinkedQueue<",
"Lyd/c;",
">;"
}
.end annotation
.end field
.field public final b:Lkotlin/Lazy;
.field public final c:Lkotlin/Lazy;
# direct methods
.method public static constructor <clinit>()V
.registers 2
new-instance v0, Lyd/b$a;
const/4 v1, 0x0
invoke-direct {v0, v1}, Lyd/b$a;-><init>(Lkotlin/jvm/internal/DefaultConstructorMarker;)V
return-void
.end method
.method public constructor <init>()V
.registers 2
invoke-direct {p0}, Ljava/lang/Object;-><init>()V
new-instance v0, Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-direct {v0}, Ljava/util/concurrent/ConcurrentLinkedQueue;-><init>()V
iput-object v0, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
sget-object v0, Lyd/b$f;->a:Lyd/b$f;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
iput-object v0, p0, Lyd/b;->b:Lkotlin/Lazy;
sget-object v0, Lyd/b$g;->a:Lyd/b$g;
invoke-static {v0}, Lfa/a;->a(Lkotlin/jvm/functions/Function0;)Lkotlin/Lazy;
move-result-object v0
iput-object v0, p0, Lyd/b;->c:Lkotlin/Lazy;
return-void
.end method
.method public static final synthetic a(Lyd/b;)Lcom/shopee/android/upload/service/IUploadService;
.registers 1
invoke-virtual {p0}, Lyd/b;->c()Lcom/shopee/android/upload/service/IUploadService;
move-result-object p0
return-object p0
.end method
# virtual methods
.method public bridge synthetic a(Ljava/lang/Object;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
.registers 2
check-cast p1, Lyd/c;
invoke-virtual {p0, p1}, Lyd/b;->a(Lyd/c;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
move-result-object p1
return-object p1
.end method
.method public a(Lyd/c;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
.registers 21
new-instance v18, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
move-object/from16 v0, v18
sget-object v1, Lwd/b;->c:Lwd/b;
invoke-virtual {v1}, Lwd/b;->a()Ljava/lang/String;
move-result-object v2
invoke-virtual/range {p1 .. p1}, Lyd/c;->a()Ljava/lang/String;
move-result-object v6
sget-object v10, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;->PERSIST:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;
sget-object v11, Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;->NETWORK:Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;
const/4 v1, 0x0
const/4 v3, 0x0
const/4 v4, 0x0
const-string v12, "IMRequest"
const/4 v5, 0x3
const/4 v7, 0x0
const/4 v8, 0x0
const/4 v9, 0x0
const/4 v13, 0x0
const-wide/16 v14, 0x12c
const/16 v16, 0x11cd
const/16 v17, 0x0
invoke-direct/range {v0 .. v17}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;-><init>(Ljava/lang/String;Ljava/lang/String;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;IILjava/lang/String;Ljava/lang/String;Ljava/util/HashMap;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/RequestType;Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskType;Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;Ljava/lang/String;Ljava/lang/String;JILkotlin/jvm/internal/DefaultConstructorMarker;)V
return-object v18
.end method
.method public final a([B)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
.registers 6
if-eqz p1, :cond_18
sget-object v0, Lfc/d;->f:Lfc/d;
invoke-virtual {v0}, Lfc/d;->a()Lcom/squareup/wire/Wire;
move-result-object v0
const/4 v1, 0x0
array-length v2, p1
const-class v3, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
invoke-virtual {v0, p1, v1, v2, v3}, Lcom/squareup/wire/Wire;->parseFrom([BIILjava/lang/Class;)Lcom/squareup/wire/Message;
move-result-object p1
const-string v0, "CoreServerRegister.WIRE.\u2026nfo::class.java\n )"
invoke-static {p1, v0}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
check-cast p1, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
return-object p1
:cond_18
sget-object p1, Llg/c;->a:Llg/c;
const/4 v0, 0x2
const/4 v1, 0x0
const-string v2, "Input can not be null"
invoke-static {p1, v2, v1, v0, v1}, Llg/c;->b(Llg/c;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)V
throw v1
.end method
.method public bridge synthetic a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Ljava/lang/Object;
.registers 2
invoke-virtual {p0, p1}, Lyd/b;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lyd/c;
move-result-object p1
return-object p1
.end method
.method public a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
iget-object p2, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p0, p1}, Lyd/b;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lyd/c;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final synthetic a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 9
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Ljava/lang/String;",
"Lkotlin/coroutines/Continuation<",
"-",
"Ljava/lang/String;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lyd/b$b;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lyd/b$b;
iget v1, v0, Lyd/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, Lyd/b$b;->b:I
goto :goto_18
:cond_13
new-instance v0, Lyd/b$b;
invoke-direct {v0, p0, p2}, Lyd/b$b;-><init>(Lyd/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lyd/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, Lyd/b$b;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_39
if-ne v2, v3, :cond_31
iget-object p1, v0, Lyd/b$b;->e:Ljava/lang/Object;
check-cast p1, Ljava/lang/String;
iget-object p1, v0, Lyd/b$b;->d:Ljava/lang/Object;
check-cast p1, Lyd/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_57
: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
sget-object p2, Lkk/a;->d:Lkk/a;
sget-object v2, Ldf/g;->h:Ldf/g;
invoke-virtual {v2}, Ldf/g;->u()Ljava/lang/String;
move-result-object v2
new-instance v4, Lyd/b$c;
const/4 v5, 0x0
invoke-direct {v4, p0, p1, v5}, Lyd/b$c;-><init>(Lyd/b;Ljava/lang/String;Lkotlin/coroutines/Continuation;)V
iput-object p0, v0, Lyd/b$b;->d:Ljava/lang/Object;
iput-object p1, v0, Lyd/b$b;->e:Ljava/lang/Object;
iput v3, v0, Lyd/b$b;->b:I
invoke-virtual {p2, v2, v4, v0}, Lkk/a;->a(Ljava/lang/String;Lkotlin/jvm/functions/Function1;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p2
if-ne p2, v1, :cond_57
return-object v1
:cond_57
:goto_57
check-cast p2, Lwb/c;
if-eqz p2, :cond_72
invoke-virtual {p2}, Lwb/c;->a()I
move-result p1
if-nez p1, :cond_66
invoke-virtual {p2}, Lwb/c;->b()Ljava/lang/String;
move-result-object p1
return-object p1
:cond_66
new-instance p1, Lif/b;
invoke-virtual {p2}, Lwb/c;->a()I
move-result p2
const-string v0, "Upload image failed"
invoke-direct {p1, v0, p2}, Lif/b;-><init>(Ljava/lang/String;I)V
throw p1
:cond_72
new-instance p1, Lif/c;
const-string p2, "Upload image failed."
invoke-direct {p1, p2}, Lif/c;-><init>(Ljava/lang/String;)V
throw p1
.end method
.method public final synthetic a(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 7
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lpe/a;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lcom/shopee/protocol/ResponseCommon;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lyd/b$e;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lyd/b$e;
iget v1, v0, Lyd/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, Lyd/b$e;->b:I
goto :goto_18
:cond_13
new-instance v0, Lyd/b$e;
invoke-direct {v0, p0, p2}, Lyd/b$e;-><init>(Lyd/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lyd/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, Lyd/b$e;->b:I
const/4 v3, 0x1
if-eqz v2, :cond_3d
if-ne v2, v3, :cond_35
iget-object p1, v0, Lyd/b$e;->f:Ljava/lang/Object;
check-cast p1, Lng/c;
iget-object p1, v0, Lyd/b$e;->e:Ljava/lang/Object;
check-cast p1, Lpe/a;
iget-object v0, v0, Lyd/b$e;->d:Ljava/lang/Object;
check-cast v0, Lyd/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_60
: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
invoke-virtual {p1}, Lpe/a;->v()I
move-result p2
if-eqz p2, :cond_7c
new-instance p2, Lng/c;
invoke-direct {p2, p1}, Lng/c;-><init>(Lpe/a;)V
invoke-virtual {p0}, Lyd/b;->b()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
move-result-object v2
if-eqz v2, :cond_63
iput-object p0, v0, Lyd/b$e;->d:Ljava/lang/Object;
iput-object p1, v0, Lyd/b$e;->e:Ljava/lang/Object;
iput-object p2, v0, Lyd/b$e;->f:Ljava/lang/Object;
iput v3, v0, Lyd/b$e;->b:I
invoke-interface {v2, p2, 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_60
return-object v1
:cond_60
:goto_60
check-cast p2, Lcom/squareup/wire/Message;
goto :goto_64
:cond_63
const/4 p2, 0x0
:goto_64
if-eqz p2, :cond_74
check-cast p2, Lcom/shopee/protocol/ResponseCommon;
sget-object v0, Llg/c;->a:Llg/c;
invoke-virtual {p1}, Lpe/a;->s()Ljava/lang/String;
move-result-object p1
const-string v1, "IM condition-service, msg send success."
invoke-virtual {v0, v1, p1}, Llg/c;->b(Ljava/lang/String;Ljava/lang/String;)V
return-object p2
:cond_74
new-instance p1, Lkotlin/TypeCastException;
const-string p2, "null cannot be cast to non-null type com.shopee.protocol.ResponseCommon"
invoke-direct {p1, p2}, Lkotlin/TypeCastException;-><init>(Ljava/lang/String;)V
throw p1
:cond_7c
new-instance p2, Ljava/lang/IllegalStateException;
new-instance v0, Ljava/lang/StringBuilder;
invoke-direct {v0}, Ljava/lang/StringBuilder;-><init>()V
const-string v1, "Msg has already been sent successfully. id: "
invoke-virtual {v0, v1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {p1}, Lpe/a;->m()J
move-result-wide v1
invoke-virtual {v0, v1, v2}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;
invoke-virtual {v0}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object p1
invoke-direct {p2, p1}, Ljava/lang/IllegalStateException;-><init>(Ljava/lang/String;)V
throw p2
.end method
.method public a()Ljava/lang/String;
.registers 2
const-string v0, "IMRequest"
return-object v0
.end method
.method public a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lyd/c;
.registers 3
new-instance v0, Lyd/c;
invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getQueryID()Ljava/lang/String;
move-result-object p1
invoke-direct {v0, p1}, Lyd/c;-><init>(Ljava/lang/String;)V
return-object v0
.end method
.method public final b()Lcom/shopee/foody/driver/oktcp/IOkTcpService;
.registers 2
iget-object v0, p0, Lyd/b;->b: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
.method public b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
iget-object p2, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p0, p1}, Lyd/b;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lyd/c;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public final synthetic b(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
invoke-virtual {p1}, Lpe/a;->d()[B
move-result-object v0
invoke-virtual {p0, v0}, Lyd/b;->a([B)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
move-result-object v0
sget-object v1, Lug/c;->a:Lug/c$a;
sget-object v2, Lug/b;->g:Lug/b;
const-string v3, "chatImageConfig"
invoke-static {v2, v3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
iget-object v0, v0, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;->imageUrl:Ljava/lang/String;
const-string v3, "imgContent.imageUrl"
invoke-static {v0, v3}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
invoke-virtual {v1, v2, v0}, Lug/c$a;->a(Lug/b;Ljava/lang/String;)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
move-result-object v0
invoke-virtual {p0, v0}, Lyd/b;->e(Ljava/lang/Object;)V
if-eqz v0, :cond_3a
invoke-virtual {v0}, Lcom/squareup/wire/Message;->toByteArray()[B
move-result-object v0
if-eqz v0, :cond_3a
invoke-virtual {p1, v0}, Lpe/a;->a([B)V
sget-object v0, Llg/b;->d:Llg/b;
invoke-virtual {v0, p1, p2}, Llg/b;->b(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object p2
if-ne p1, p2, :cond_37
return-object p1
:cond_37
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
:cond_3a
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object p1
if-ne v0, p1, :cond_41
return-object v0
:cond_41
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public b(Lyd/c;)Ljava/lang/String;
.registers 2
invoke-virtual {p1}, Lyd/c;->a()Ljava/lang/String;
move-result-object p1
return-object p1
.end method
.method public bridge synthetic b(Ljava/lang/Object;)V
.registers 2
check-cast p1, Lyd/c;
invoke-virtual {p0, p1}, Lyd/b;->d(Lyd/c;)V
return-void
.end method
.method public final c()Lcom/shopee/android/upload/service/IUploadService;
.registers 2
iget-object v0, p0, Lyd/b;->c:Lkotlin/Lazy;
invoke-interface {v0}, Lkotlin/Lazy;->getValue()Ljava/lang/Object;
move-result-object v0
check-cast v0, Lcom/shopee/android/upload/service/IUploadService;
return-object v0
.end method
.method public c(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 21
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lcom/shopee/protocol/ResponseCommon;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
move-object/from16 v0, p0
move-object/from16 v1, p2
instance-of v2, v1, Lyd/b$d;
if-eqz v2, :cond_17
move-object v2, v1
check-cast v2, Lyd/b$d;
iget v3, v2, Lyd/b$d;->b:I
const/high16 v4, -0x80000000
and-int v5, v3, v4
if-eqz v5, :cond_17
sub-int/2addr v3, v4
iput v3, v2, Lyd/b$d;->b:I
goto :goto_1c
:cond_17
new-instance v2, Lyd/b$d;
invoke-direct {v2, v0, v1}, Lyd/b$d;-><init>(Lyd/b;Lkotlin/coroutines/Continuation;)V
:goto_1c
iget-object v1, v2, Lyd/b$d;->a:Ljava/lang/Object;
invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;
move-result-object v3
iget v4, v2, Lyd/b$d;->b:I
const-wide/16 v5, 0x0
const/4 v7, 0x1
const/4 v8, 0x2
const/4 v9, 0x4
const/4 v10, 0x0
packed-switch v4, :pswitch_data_194
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
:pswitch_35
iget-object v3, v2, Lyd/b$d;->f:Ljava/lang/Object;
check-cast v3, Lpe/a;
iget-object v3, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v3, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v2, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v2, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_172
:pswitch_46
iget-object v3, v2, Lyd/b$d;->f:Ljava/lang/Object;
check-cast v3, Lpe/a;
iget-object v3, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v3, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v2, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v2, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_161
:pswitch_57
iget-object v3, v2, Lyd/b$d;->f:Ljava/lang/Object;
check-cast v3, Lpe/a;
iget-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v4, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v2, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v2, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_f4
:pswitch_68
iget-object v3, v2, Lyd/b$d;->f:Ljava/lang/Object;
check-cast v3, Lpe/a;
iget-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v4, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v2, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v2, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_12b
:pswitch_79
iget-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v4, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v11, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_ce
:pswitch_85
iget-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
check-cast v4, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
iget-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
check-cast v11, Lyd/b;
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
move-object v1, v4
goto :goto_b6
:pswitch_92
invoke-static {v1}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual/range {p1 .. p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskRetryCount()I
move-result v1
if-lez v1, :cond_b3
invoke-virtual/range {p1 .. p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskRetryCount()I
move-result v1
int-to-long v11, v1
const-wide/16 v13, 0x7d0
mul-long v11, v11, v13
iput-object v0, v2, Lyd/b$d;->d:Ljava/lang/Object;
move-object/from16 v1, p1
iput-object v1, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput v7, v2, Lyd/b$d;->b:I
invoke-static {v11, v12, v2}, Lkotlinx/coroutines/DelayKt;->delay(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v4
if-ne v4, v3, :cond_b5
return-object v3
:cond_b3
move-object/from16 v1, p1
:cond_b5
move-object v11, v0
:goto_b6
sget-object v4, Llg/b;->d:Llg/b;
invoke-virtual {v1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getQueryID()Ljava/lang/String;
move-result-object v12
iput-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
iput-object v1, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput v8, v2, Lyd/b$d;->b:I
invoke-virtual {v4, v12, v2}, Llg/b;->a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v4
if-ne v4, v3, :cond_c9
return-object v3
:cond_c9
move-object/from16 v17, v4
move-object v4, v1
move-object/from16 v1, v17
:goto_ce
check-cast v1, Lpe/a;
if-eqz v1, :cond_173
invoke-static {v1}, Lpe/b;->b(Lpe/a;)Z
move-result v12
if-eqz v12, :cond_162
invoke-virtual {v1}, Lpe/a;->k()I
move-result v12
if-eqz v12, :cond_151
if-eq v12, v7, :cond_11a
if-eq v12, v8, :cond_e4
goto/16 :goto_162
:cond_e4
iput-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
iput-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput-object v1, v2, Lyd/b$d;->f:Ljava/lang/Object;
iput v9, v2, Lyd/b$d;->b:I
invoke-virtual {v11, v1, v2}, Lyd/b;->c(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v2
if-ne v2, v3, :cond_f3
return-object v3
:cond_f3
move-object v3, v1
:goto_f4
sget-object v1, Llg/c;->a:Llg/c;
invoke-virtual {v3}, Lpe/a;->s()Ljava/lang/String;
move-result-object v2
const-string v4, "IM condition-service, pic upload success."
invoke-virtual {v1, v4, v2}, Llg/c;->b(Ljava/lang/String;Ljava/lang/String;)V
new-instance v1, Lcom/shopee/protocol/ResponseCommon;
invoke-virtual {v3}, Lpe/a;->s()Ljava/lang/String;
move-result-object v12
invoke-static {v10}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v13
invoke-static {v10}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v14
invoke-static {v5, v6}, Lkotlin/coroutines/jvm/internal/Boxing;->boxLong(J)Ljava/lang/Long;
move-result-object v15
invoke-static {v9}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v16
move-object v11, v1
invoke-direct/range {v11 .. v16}, Lcom/shopee/protocol/ResponseCommon;-><init>(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Long;Ljava/lang/Integer;)V
return-object v1
:cond_11a
iput-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
iput-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput-object v1, v2, Lyd/b$d;->f:Ljava/lang/Object;
const/4 v4, 0x3
iput v4, v2, Lyd/b$d;->b:I
invoke-virtual {v11, v1, v2}, Lyd/b;->b(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v2
if-ne v2, v3, :cond_12a
return-object v3
:cond_12a
move-object v3, v1
:goto_12b
sget-object v1, Llg/c;->a:Llg/c;
invoke-virtual {v3}, Lpe/a;->s()Ljava/lang/String;
move-result-object v2
const-string v4, "IM condition-service, pic convert success."
invoke-virtual {v1, v4, v2}, Llg/c;->b(Ljava/lang/String;Ljava/lang/String;)V
new-instance v1, Lcom/shopee/protocol/ResponseCommon;
invoke-virtual {v3}, Lpe/a;->s()Ljava/lang/String;
move-result-object v12
invoke-static {v10}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v13
invoke-static {v10}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v14
invoke-static {v5, v6}, Lkotlin/coroutines/jvm/internal/Boxing;->boxLong(J)Ljava/lang/Long;
move-result-object v15
invoke-static {v9}, Lkotlin/coroutines/jvm/internal/Boxing;->boxInt(I)Ljava/lang/Integer;
move-result-object v16
move-object v11, v1
invoke-direct/range {v11 .. v16}, Lcom/shopee/protocol/ResponseCommon;-><init>(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Long;Ljava/lang/Integer;)V
return-object v1
:cond_151
iput-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
iput-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput-object v1, v2, Lyd/b$d;->f:Ljava/lang/Object;
const/4 v4, 0x5
iput v4, v2, Lyd/b$d;->b:I
invoke-virtual {v11, v1, v2}, Lyd/b;->a(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v1
if-ne v1, v3, :cond_161
return-object v3
:cond_161
:goto_161
return-object v1
:cond_162
:goto_162
iput-object v11, v2, Lyd/b$d;->d:Ljava/lang/Object;
iput-object v4, v2, Lyd/b$d;->e:Ljava/lang/Object;
iput-object v1, v2, Lyd/b$d;->f:Ljava/lang/Object;
const/4 v4, 0x6
iput v4, v2, Lyd/b$d;->b:I
invoke-virtual {v11, v1, v2}, Lyd/b;->a(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v1
if-ne v1, v3, :cond_172
return-object v3
:cond_172
:goto_172
return-object v1
:cond_173
new-instance v1, Lzd/b;
new-instance v2, Ljava/lang/StringBuilder;
invoke-direct {v2}, Ljava/lang/StringBuilder;-><init>()V
const-string v3, "Request id:"
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v4}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getQueryID()Ljava/lang/String;
move-result-object v3
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
const-string v3, " can not be found in db"
invoke-virtual {v2, v3}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v2
invoke-direct {v1, v2}, Lzd/b;-><init>(Ljava/lang/String;)V
throw v1
nop
:pswitch_data_194
.packed-switch 0x0
:pswitch_92
:pswitch_85
:pswitch_79
:pswitch_68
:pswitch_57
:pswitch_46
:pswitch_35
.end packed-switch
.end method
.method public final synthetic c(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 14
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lpe/a;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
instance-of v0, p2, Lyd/b$h;
if-eqz v0, :cond_13
move-object v0, p2
check-cast v0, Lyd/b$h;
iget v1, v0, Lyd/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, Lyd/b$h;->b:I
goto :goto_18
:cond_13
new-instance v0, Lyd/b$h;
invoke-direct {v0, p0, p2}, Lyd/b$h;-><init>(Lyd/b;Lkotlin/coroutines/Continuation;)V
:goto_18
iget-object p2, v0, Lyd/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, Lyd/b$h;->b:I
const/4 v3, 0x3
const/4 v4, 0x2
const/4 v5, 0x1
if-eqz v2, :cond_77
if-eq v2, v5, :cond_64
if-eq v2, v4, :cond_50
if-ne v2, v3, :cond_48
iget-object p1, v0, Lyd/b$h;->i:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
iget-object p1, v0, Lyd/b$h;->h:Ljava/lang/Object;
check-cast p1, Ljava/lang/String;
iget-object p1, v0, Lyd/b$h;->g:Ljava/lang/Object;
check-cast p1, Ljava/lang/String;
iget-object p1, v0, Lyd/b$h;->f:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
iget-object p1, v0, Lyd/b$h;->e:Ljava/lang/Object;
check-cast p1, Lpe/a;
iget-object p1, v0, Lyd/b$h;->d:Ljava/lang/Object;
check-cast p1, Lyd/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto/16 :goto_111
:cond_48
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_50
iget-object p1, v0, Lyd/b$h;->g:Ljava/lang/Object;
check-cast p1, Ljava/lang/String;
iget-object v2, v0, Lyd/b$h;->f:Ljava/lang/Object;
check-cast v2, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
iget-object v4, v0, Lyd/b$h;->e:Ljava/lang/Object;
check-cast v4, Lpe/a;
iget-object v5, v0, Lyd/b$h;->d:Ljava/lang/Object;
check-cast v5, Lyd/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
goto :goto_ba
:cond_64
iget-object p1, v0, Lyd/b$h;->f:Ljava/lang/Object;
check-cast p1, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
iget-object v2, v0, Lyd/b$h;->e:Ljava/lang/Object;
check-cast v2, Lpe/a;
iget-object v5, v0, Lyd/b$h;->d:Ljava/lang/Object;
check-cast v5, Lyd/b;
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
move-object v10, v2
move-object v2, p1
move-object p1, v10
goto :goto_9c
:cond_77
invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V
invoke-virtual {p1}, Lpe/a;->d()[B
move-result-object p2
invoke-virtual {p0, p2}, Lyd/b;->a([B)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
move-result-object p2
iget-object v2, p2, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;->imageUrl:Ljava/lang/String;
const-string v6, "imgContent.imageUrl"
invoke-static {v2, v6}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
iput-object p0, v0, Lyd/b$h;->d:Ljava/lang/Object;
iput-object p1, v0, Lyd/b$h;->e:Ljava/lang/Object;
iput-object p2, v0, Lyd/b$h;->f:Ljava/lang/Object;
iput v5, v0, Lyd/b$h;->b:I
invoke-virtual {p0, v2, v0}, Lyd/b;->a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v2
if-ne v2, v1, :cond_98
return-object v1
:cond_98
move-object v5, p0
move-object v10, v2
move-object v2, p2
move-object p2, v10
:goto_9c
check-cast p2, Ljava/lang/String;
iget-object v6, v2, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;->thumbUrl:Ljava/lang/String;
const-string v7, "imgContent.thumbUrl"
invoke-static {v6, v7}, Lkotlin/jvm/internal/Intrinsics;->checkExpressionValueIsNotNull(Ljava/lang/Object;Ljava/lang/String;)V
iput-object v5, v0, Lyd/b$h;->d:Ljava/lang/Object;
iput-object p1, v0, Lyd/b$h;->e:Ljava/lang/Object;
iput-object v2, v0, Lyd/b$h;->f:Ljava/lang/Object;
iput-object p2, v0, Lyd/b$h;->g:Ljava/lang/Object;
iput v4, v0, Lyd/b$h;->b:I
invoke-virtual {v5, v6, v0}, Lyd/b;->a(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object v4
if-ne v4, v1, :cond_b6
return-object v1
:cond_b6
move-object v10, v4
move-object v4, p1
move-object p1, p2
move-object p2, v10
:goto_ba
check-cast p2, Ljava/lang/String;
new-instance v6, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;
invoke-direct {v6}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;-><init>()V
invoke-virtual {v6, p1}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;->imageUrl(Ljava/lang/String;)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;
move-result-object v6
invoke-virtual {v6, p2}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;->thumbUrl(Ljava/lang/String;)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;
move-result-object v6
iget-object v7, v2, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;->thumbHeight:Ljava/lang/Integer;
invoke-virtual {v6, v7}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;->thumbHeight(Ljava/lang/Integer;)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;
move-result-object v6
iget-object v7, v2, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;->thumbWidth:Ljava/lang/Integer;
invoke-virtual {v6, v7}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;->thumbWidth(Ljava/lang/Integer;)Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;
move-result-object v6
invoke-virtual {v6}, Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo$Builder;->build()Lcom/shopee/foody/driver/im/business/network/model/proto/ChatImageInfo;
move-result-object v6
sget-object v7, Llg/c;->a:Llg/c;
new-instance v8, Ljava/lang/StringBuilder;
invoke-direct {v8}, Ljava/lang/StringBuilder;-><init>()V
const-string v9, "Pic upload result: "
invoke-virtual {v8, v9}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;
invoke-virtual {v8, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;
invoke-virtual {v8}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;
move-result-object v8
invoke-virtual {v4}, Lpe/a;->s()Ljava/lang/String;
move-result-object v9
invoke-virtual {v7, v8, v9}, Llg/c;->b(Ljava/lang/String;Ljava/lang/String;)V
invoke-virtual {v6}, Lcom/squareup/wire/Message;->toByteArray()[B
move-result-object v7
invoke-virtual {v4, v7}, Lpe/a;->a([B)V
sget-object v7, Llg/b;->d:Llg/b;
iput-object v5, v0, Lyd/b$h;->d:Ljava/lang/Object;
iput-object v4, v0, Lyd/b$h;->e:Ljava/lang/Object;
iput-object v2, v0, Lyd/b$h;->f:Ljava/lang/Object;
iput-object p1, v0, Lyd/b$h;->g:Ljava/lang/Object;
iput-object p2, v0, Lyd/b$h;->h:Ljava/lang/Object;
iput-object v6, v0, Lyd/b$h;->i:Ljava/lang/Object;
iput v3, v0, Lyd/b$h;->b:I
invoke-virtual {v7, v4, v0}, Llg/b;->b(Lpe/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
move-result-object p1
if-ne p1, v1, :cond_111
return-object v1
:cond_111
:goto_111
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public bridge synthetic c(Ljava/lang/Object;)Z
.registers 2
check-cast p1, Lyd/c;
invoke-virtual {p0, p1}, Lyd/b;->c(Lyd/c;)Z
move-result p1
return p1
.end method
.method public c(Lyd/c;)Z
.registers 3
iget-object v0, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->contains(Ljava/lang/Object;)Z
move-result p1
return p1
.end method
.method public d(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
.registers 3
.annotation system Ldalvik/annotation/Signature;
value = {
"(",
"Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
"Lkotlin/coroutines/Continuation<",
"-",
"Lkotlin/Unit;",
">;)",
"Ljava/lang/Object;"
}
.end annotation
iget-object p2, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {p0, p1}, Lyd/b;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Lyd/c;
move-result-object p1
invoke-virtual {p2, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->remove(Ljava/lang/Object;)Z
sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;
return-object p1
.end method
.method public bridge synthetic d(Ljava/lang/Object;)Ljava/lang/String;
.registers 2
check-cast p1, Lyd/c;
invoke-virtual {p0, p1}, Lyd/b;->b(Lyd/c;)Ljava/lang/String;
move-result-object p1
return-object p1
.end method
.method public d(Lyd/c;)V
.registers 3
iget-object v0, p0, Lyd/b;->a:Ljava/util/concurrent/ConcurrentLinkedQueue;
invoke-virtual {v0, p1}, Ljava/util/concurrent/ConcurrentLinkedQueue;->add(Ljava/lang/Object;)Z
return-void
.end method
.method public final e(Ljava/lang/Object;)V
.registers 5
if-eqz p1, :cond_3
return-void
:cond_3
sget-object p1, Llg/c;->a:Llg/c;
const/4 v0, 0x2
const/4 v1, 0x0
const-string v2, "Input can not be null"
invoke-static {p1, v2, v1, v0, v1}, Llg/c;->b(Llg/c;Ljava/lang/String;Ljava/lang/String;ILjava/lang/Object;)V
throw v1
.end method