e.smali

.class public final Lfe/e;
.super Ljava/lang/Object;
.source "TasksDispatcher.kt"


# annotations
.annotation runtime Lkotlin/Metadata;
    bv = {
        0x1,
        0x0,
        0x3
    }
    d1 = {
        "\u0000(\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0008\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0008\u0003\n\u0002\u0010\u000e\n\u0002\u0008\u0015\u0008\u00c0\u0002\u0018\u00002\u00020\u0001B\u0007\u0008\u0002\u00a2\u0006\u0002\u0010\u0002J\u0019\u0010\u0005\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tJ\u0015\u0010\n\u001a\u00020\u00062\u0006\u0010\u000b\u001a\u00020\u000cH\u0000\u00a2\u0006\u0002\u0008\rJ\u0015\u0010\u000e\u001a\u00020\u00062\u0006\u0010\u000f\u001a\u00020\u0008H\u0000\u00a2\u0006\u0002\u0008\u0010J\u0019\u0010\u0011\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tJ\r\u0010\u0012\u001a\u00020\u0006H\u0000\u00a2\u0006\u0002\u0008\u0013J\u0019\u0010\u0014\u001a\u00020\u00062\u0006\u0010\u000b\u001a\u00020\u000cH\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015J\u0019\u0010\u0016\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tJ\u0019\u0010\u0017\u001a\u00020\u00062\u0006\u0010\u000b\u001a\u00020\u000cH\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\u0015J\u0015\u0010\u0018\u001a\u00020\u00062\u0006\u0010\u000b\u001a\u00020\u000cH\u0000\u00a2\u0006\u0002\u0008\u0019J\u0015\u0010\u001a\u001a\u00020\u00062\u0006\u0010\u001b\u001a\u00020\u000cH\u0000\u00a2\u0006\u0002\u0008\u001cJ\u0019\u0010\u001d\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tJ\u0019\u0010\u001e\u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tJ\u0012\u0010\u001f\u001a\u0004\u0018\u00010\u00082\u0006\u0010\u000b\u001a\u00020\u000cH\u0002J\u0019\u0010 \u001a\u00020\u00062\u0006\u0010\u0007\u001a\u00020\u0008H\u0082@\u00f8\u0001\u0000\u00a2\u0006\u0002\u0010\tR\u0010\u0010\u0003\u001a\u0004\u0018\u00010\u0004X\u0082\u000e\u00a2\u0006\u0002\n\u0000\u0082\u0002\u0004\n\u0002\u0008\u0019\u00a8\u0006!"
    }
    d2 = {
        "Lcom/shopee/foody/driver/conditiontask/internal/executor/TasksDispatcher;",
        "",
        "()V",
        "mDbUpdatesObserverJob",
        "Lkotlinx/coroutines/Job;",
        "cancelProceedingTask",
        "",
        "taskInfo",
        "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
        "(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
        "cancelTask",
        "queryID",
        "",
        "cancelTask$driver_indonesiaRelease",
        "dispatchNewAddTask",
        "info",
        "dispatchNewAddTask$driver_indonesiaRelease",
        "dispatchTaskByCondition",
        "listenDBUpdates",
        "listenDBUpdates$driver_indonesiaRelease",
        "markTasksInDbToCancelState",
        "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;",
        "notifyTaskOverdue",
        "reExecutePreTasksInDb",
        "reExecuteTask",
        "reExecuteTask$driver_indonesiaRelease",
        "resumePreUnFinishedTasksByBizID",
        "bizID",
        "resumePreUnFinishedTasksByBizID$driver_indonesiaRelease",
        "resumeTaskIfPaused",
        "saveToDb",
        "searchTaskInAllRunningTasks",
        "sendToExecutor",
        "driver_indonesiaRelease"
    }
    k = 0x1
    mv = {
        0x1,
        0x1,
        0x10
    }
.end annotation


# static fields
.field public static a:Lkotlinx/coroutines/Job;

.field public static final b:Lfe/e;


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

    new-instance v0, Lfe/e;

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

    sput-object v0, Lfe/e;->b:Lfe/e;

    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(Lfe/e;Ljava/lang/String;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
    .registers 2

    invoke-virtual {p0, p1}, Lfe/e;->d(Ljava/lang/String;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    move-result-object p0

    return-object p0
.end method


# virtual methods
.method public final synthetic a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 7
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$a;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$a;

    iget v1, v0, Lfe/e$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, Lfe/e$a;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$a;

    invoke-direct {v0, p0, p2}, Lfe/e$a;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$a;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$a;->b:I

    const/4 v3, 0x1

    if-eqz v2, :cond_39

    if-ne v2, v3, :cond_31

    iget-object p1, v0, Lfe/e$a;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v0, v0, Lfe/e$a;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_49

    :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

    iput-object p0, v0, Lfe/e$a;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$a;->e:Ljava/lang/Object;

    iput v3, v0, Lfe/e$a;->b:I

    invoke-virtual {p1, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->markCanceled$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_49

    return-object v1

    :cond_49
    :goto_49
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Mark proceeding task status to CANCEL, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    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<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$g;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$g;

    iget v1, v0, Lfe/e$g;->b:I

    const/high16 v2, -0x80000000

    and-int v3, v1, v2

    if-eqz v3, :cond_13

    sub-int/2addr v1, v2

    iput v1, v0, Lfe/e$g;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$g;

    invoke-direct {v0, p0, p2}, Lfe/e$g;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$g;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$g;->b:I

    const/4 v3, 0x2

    const/4 v4, 0x1

    if-eqz v2, :cond_4c

    if-eq v2, v4, :cond_40

    if-ne v2, v3, :cond_38

    iget-object p1, v0, Lfe/e$g;->f:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v1, v0, Lfe/e$g;->e:Ljava/lang/Object;

    check-cast v1, Ljava/lang/String;

    iget-object v0, v0, Lfe/e$g;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_97

    :cond_38
    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_40
    iget-object p1, v0, Lfe/e$g;->e:Ljava/lang/Object;

    check-cast p1, Ljava/lang/String;

    iget-object v2, v0, Lfe/e$g;->d:Ljava/lang/Object;

    check-cast v2, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_6b

    :cond_4c
    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    sget-object p2, Lke/a;->e:Lke/a;

    invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;

    move-result-object p2

    if-eqz p2, :cond_cb

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;

    move-result-object p2

    if-eqz p2, :cond_cb

    iput-object p0, v0, Lfe/e$g;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$g;->e:Ljava/lang/Object;

    iput v4, v0, Lfe/e$g;->b:I

    invoke-interface {p2, p1, v0}, Lde/a;->c(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_6a

    return-object v1

    :cond_6a
    move-object v2, p0

    :goto_6b
    check-cast p2, Ljava/util/List;

    if-eqz p2, :cond_cb

    invoke-static {p2}, Lkotlin/collections/CollectionsKt___CollectionsKt;->firstOrNull(Ljava/util/List;)Ljava/lang/Object;

    move-result-object p2

    check-cast p2, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    if-eqz p2, :cond_cb

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object v4

    sget-object v5, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->FAILED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-eq v4, v5, :cond_b2

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object v4

    sget-object v5, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->SUCCEED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-eq v4, v5, :cond_b2

    iput-object v2, v0, Lfe/e$g;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$g;->e:Ljava/lang/Object;

    iput-object p2, v0, Lfe/e$g;->f:Ljava/lang/Object;

    iput v3, v0, Lfe/e$g;->b:I

    invoke-virtual {p2, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->markCanceled$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p1

    if-ne p1, v1, :cond_96

    return-object v1

    :cond_96
    move-object p1, p2

    :goto_97
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Mark old db task status to CANCEL, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1

    :cond_b2
    new-instance p1, Ljava/lang/StringBuilder;

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

    const-string v0, "Skip cancel task because this task is finished executed, "

    invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p2

    invoke-virtual {p1, p2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    goto :goto_d0

    :cond_cb
    const-string p1, "Skip cancel task because this task not exist"

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    :goto_d0
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final a()V
    .registers 5

    sget-object v0, Lfe/e;->a:Lkotlinx/coroutines/Job;

    const/4 v1, 0x0

    if-eqz v0, :cond_b

    const/4 v2, 0x2

    const-string v3, "User info updates, restart db observe flow"

    invoke-static {v0, v3, v1, v2, v1}, Lkotlinx/coroutines/JobKt;->cancel$default(Lkotlinx/coroutines/Job;Ljava/lang/String;Ljava/lang/Throwable;ILjava/lang/Object;)V

    :cond_b
    new-instance v0, Lfe/e$f;

    invoke-direct {v0, v1}, Lfe/e$f;-><init>(Lkotlin/coroutines/Continuation;)V

    invoke-static {v0}, Lhe/b;->c(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;

    move-result-object v0

    sput-object v0, Lfe/e;->a:Lkotlinx/coroutines/Job;

    return-void
.end method

.method public final a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)V
    .registers 4

    new-instance v0, Lfe/e$c;

    const/4 v1, 0x0

    invoke-direct {v0, p1, v1}, Lfe/e$c;-><init>(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)V

    invoke-static {v0}, Lhe/b;->c(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;

    return-void
.end method

.method public final a(Ljava/lang/String;)V
    .registers 4

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

    move-result v0

    const/4 v1, 0x1

    if-lez v0, :cond_9

    const/4 v0, 0x1

    goto :goto_a

    :cond_9
    const/4 v0, 0x0

    :goto_a
    if-eqz v0, :cond_1c

    invoke-static {p1}, Lkotlin/text/StringsKt__StringsJVMKt;->isBlank(Ljava/lang/CharSequence;)Z

    move-result v0

    xor-int/2addr v0, v1

    if-eqz v0, :cond_1c

    new-instance v0, Lfe/e$b;

    const/4 v1, 0x0

    invoke-direct {v0, v1, p1}, Lfe/e$b;-><init>(Lkotlin/coroutines/Continuation;Ljava/lang/String;)V

    invoke-static {v0}, Lhe/b;->c(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;

    :cond_1c
    return-void
.end method

.method public final synthetic b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$d;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$d;

    iget v1, v0, Lfe/e$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, Lfe/e$d;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$d;

    invoke-direct {v0, p0, p2}, Lfe/e$d;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$d;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$d;->b:I

    const/4 v3, 0x3

    const/4 v4, 0x2

    const/4 v5, 0x1

    if-eqz v2, :cond_60

    if-eq v2, v5, :cond_54

    if-eq v2, v4, :cond_44

    if-ne v2, v3, :cond_3c

    iget-object p1, v0, Lfe/e$d;->f:Ljava/lang/Object;

    check-cast p1, Lfe/c;

    iget-object p1, v0, Lfe/e$d;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object p1, v0, Lfe/e$d;->d:Ljava/lang/Object;

    check-cast p1, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto/16 :goto_bd

    :cond_3c
    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_44
    iget-object p1, v0, Lfe/e$d;->f:Ljava/lang/Object;

    check-cast p1, Lfe/c;

    iget-object v2, v0, Lfe/e$d;->e:Ljava/lang/Object;

    check-cast v2, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v4, v0, Lfe/e$d;->d:Ljava/lang/Object;

    check-cast v4, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_a2

    :cond_54
    iget-object p1, v0, Lfe/e$d;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object p1, v0, Lfe/e$d;->d:Ljava/lang/Object;

    check-cast p1, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_78

    :cond_60
    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    sget-object p2, Lhe/a;->b:Lhe/a;

    invoke-virtual {p2, p1}, Lhe/a;->b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Z

    move-result p2

    if-eqz p2, :cond_7b

    iput-object p0, v0, Lfe/e$d;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$d;->e:Ljava/lang/Object;

    iput v5, v0, Lfe/e$d;->b:I

    invoke-virtual {p0, p1, v0}, Lfe/e;->c(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p1

    if-ne p1, v1, :cond_78

    return-object v1

    :cond_78
    :goto_78
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1

    :cond_7b
    sget-object p2, Lhe/a;->b:Lhe/a;

    new-instance v2, Lfe/e$e;

    const/4 v5, 0x0

    invoke-direct {v2, p1, v5}, Lfe/e$e;-><init>(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)V

    invoke-virtual {p2, p1, v2}, Lhe/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/jvm/functions/Function1;)V

    sget-object p2, Lfe/a;->b:Lfe/a;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskWaitingCondition()Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;

    move-result-object v2

    invoke-virtual {p2, v2}, Lfe/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;)Lfe/c;

    move-result-object p2

    iput-object p0, v0, Lfe/e$d;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$d;->e:Ljava/lang/Object;

    iput-object p2, v0, Lfe/e$d;->f:Ljava/lang/Object;

    iput v4, v0, Lfe/e$d;->b:I

    invoke-virtual {p1, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->updateTaskVersion$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object v2

    if-ne v2, v1, :cond_9f

    return-object v1

    :cond_9f
    move-object v4, p0

    move-object v2, p1

    move-object p1, p2

    :goto_a2
    const-string p2, "Update task version"

    invoke-static {p2}, Lhe/b;->b(Ljava/lang/String;)V

    if-eqz p1, :cond_bd

    new-instance p2, Lge/a;

    invoke-direct {p2, v2}, Lge/a;-><init>(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)V

    iput-object v4, v0, Lfe/e$d;->d:Ljava/lang/Object;

    iput-object v2, v0, Lfe/e$d;->e:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$d;->f:Ljava/lang/Object;

    iput v3, v0, Lfe/e$d;->b:I

    invoke-virtual {p1, p2, v0}, Lfe/c;->a(Lge/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p1

    if-ne p1, v1, :cond_bd

    return-object v1

    :cond_bd
    :goto_bd
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final synthetic b(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 11
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Ljava/lang/String;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$i;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$i;

    iget v1, v0, Lfe/e$i;->b:I

    const/high16 v2, -0x80000000

    and-int v3, v1, v2

    if-eqz v3, :cond_13

    sub-int/2addr v1, v2

    iput v1, v0, Lfe/e$i;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$i;

    invoke-direct {v0, p0, p2}, Lfe/e$i;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$i;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$i;->b:I

    const/4 v3, 0x3

    const/4 v4, 0x2

    const/4 v5, 0x1

    if-eqz v2, :cond_61

    if-eq v2, v5, :cond_55

    if-eq v2, v4, :cond_44

    if-ne v2, v3, :cond_3c

    iget-object p1, v0, Lfe/e$i;->f:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v1, v0, Lfe/e$i;->e:Ljava/lang/Object;

    check-cast v1, Ljava/lang/String;

    iget-object v0, v0, Lfe/e$i;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto/16 :goto_f2

    :cond_3c
    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_44
    iget-object p1, v0, Lfe/e$i;->f:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v2, v0, Lfe/e$i;->e:Ljava/lang/Object;

    check-cast v2, Ljava/lang/String;

    iget-object v4, v0, Lfe/e$i;->d:Ljava/lang/Object;

    check-cast v4, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto/16 :goto_e1

    :cond_55
    iget-object p1, v0, Lfe/e$i;->e:Ljava/lang/Object;

    check-cast p1, Ljava/lang/String;

    iget-object v2, v0, Lfe/e$i;->d:Ljava/lang/Object;

    check-cast v2, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_80

    :cond_61
    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    sget-object p2, Lke/a;->e:Lke/a;

    invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;

    move-result-object p2

    if-eqz p2, :cond_10d

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;

    move-result-object p2

    if-eqz p2, :cond_10d

    iput-object p0, v0, Lfe/e$i;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$i;->e:Ljava/lang/Object;

    iput v5, v0, Lfe/e$i;->b:I

    invoke-interface {p2, p1, v0}, Lde/a;->c(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_7f

    return-object v1

    :cond_7f
    move-object v2, p0

    :goto_80
    check-cast p2, Ljava/util/List;

    if-eqz p2, :cond_10d

    invoke-static {p2}, Lkotlin/collections/CollectionsKt___CollectionsKt;->firstOrNull(Ljava/util/List;)Ljava/lang/Object;

    move-result-object p2

    check-cast p2, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    if-eqz p2, :cond_10d

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskVersion()Ljava/lang/String;

    move-result-object v6

    sget-object v7, Lwd/b;->c:Lwd/b;

    invoke-virtual {v7}, Lwd/b;->a()Ljava/lang/String;

    move-result-object v7

    invoke-static {v6, v7}, Lkotlin/jvm/internal/Intrinsics;->areEqual(Ljava/lang/Object;Ljava/lang/Object;)Z

    move-result v6

    xor-int/2addr v5, v6

    if-nez v5, :cond_cf

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object v5

    sget-object v6, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->SUCCEED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-eq v5, v6, :cond_cf

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object v5

    sget-object v6, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->FAILED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-eq v5, v6, :cond_cf

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object v5

    sget-object v6, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->CANCELED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-ne v5, v6, :cond_b6

    goto :goto_cf

    :cond_b6
    new-instance p1, Ljava/lang/StringBuilder;

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

    const-string v0, "Skip re-execute task because this task is in proceeding, "

    invoke-virtual {p1, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p2

    invoke-virtual {p1, p2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    goto :goto_112

    :cond_cf
    :goto_cf
    iput-object v2, v0, Lfe/e$i;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$i;->e:Ljava/lang/Object;

    iput-object p2, v0, Lfe/e$i;->f:Ljava/lang/Object;

    iput v4, v0, Lfe/e$i;->b:I

    invoke-virtual {p2, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->resetStatus$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object v4

    if-ne v4, v1, :cond_de

    return-object v1

    :cond_de
    move-object v4, v2

    move-object v2, p1

    move-object p1, p2

    :goto_e1
    sget-object p2, Lfe/e;->b:Lfe/e;

    iput-object v4, v0, Lfe/e$i;->d:Ljava/lang/Object;

    iput-object v2, v0, Lfe/e$i;->e:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$i;->f:Ljava/lang/Object;

    iput v3, v0, Lfe/e$i;->b:I

    invoke-virtual {p2, p1, v0}, Lfe/e;->b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_f2

    return-object v1

    :cond_f2
    :goto_f2
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Re execute task, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1

    :cond_10d
    const-string p1, "Skip re-execute task because this task can not be found in db"

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    :goto_112
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final b(Ljava/lang/String;)V
    .registers 4

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

    move-result v0

    const/4 v1, 0x1

    if-lez v0, :cond_9

    const/4 v0, 0x1

    goto :goto_a

    :cond_9
    const/4 v0, 0x0

    :goto_a
    if-eqz v0, :cond_1c

    invoke-static {p1}, Lkotlin/text/StringsKt__StringsJVMKt;->isBlank(Ljava/lang/CharSequence;)Z

    move-result v0

    xor-int/2addr v0, v1

    if-eqz v0, :cond_1c

    new-instance v0, Lfe/e$j;

    const/4 v1, 0x0

    invoke-direct {v0, v1, p1}, Lfe/e$j;-><init>(Lkotlin/coroutines/Continuation;Ljava/lang/String;)V

    invoke-static {v0}, Lhe/b;->c(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;

    :cond_1c
    return-void
.end method

.method public final synthetic c(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 9
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$h;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$h;

    iget v1, v0, Lfe/e$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, Lfe/e$h;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$h;

    invoke-direct {v0, p0, p2}, Lfe/e$h;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$h;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$h;->b:I

    const/4 v3, 0x1

    if-eqz v2, :cond_39

    if-ne v2, v3, :cond_31

    iget-object p1, v0, Lfe/e$h;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v0, v0, Lfe/e$h;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_6d

    :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

    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v2, "Task dispatched overdue, max "

    invoke-virtual {p2, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getExpireTime()J

    move-result-wide v4

    invoke-virtual {p2, v4, v5}, Ljava/lang/StringBuilder;->append(J)Ljava/lang/StringBuilder;

    const-string v2, "s, "

    invoke-virtual {p2, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object v2

    invoke-virtual {p2, v2}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p2

    invoke-static {p2}, Lhe/b;->b(Ljava/lang/String;)V

    iput-object p0, v0, Lfe/e$h;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$h;->e:Ljava/lang/Object;

    iput v3, v0, Lfe/e$h;->b:I

    invoke-virtual {p1, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->markCanceled$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_6d

    return-object v1

    :cond_6d
    :goto_6d
    sget-object p2, Lae/a;->b:Lae/a;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskBizID()Ljava/lang/String;

    move-result-object v0

    invoke-virtual {p2, v0}, Lae/a;->a(Ljava/lang/String;)Lae/b;

    move-result-object p2

    if-eqz p2, :cond_9f

    invoke-interface {p2, p1}, Lae/b;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Ljava/lang/Object;

    move-result-object p2

    if-eqz p2, :cond_9f

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

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskBizID()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {v0, p1}, Lbe/a;->a(Ljava/lang/String;)Ljava/util/concurrent/ConcurrentLinkedQueue;

    move-result-object p1

    if-eqz p1, :cond_9f

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

    move-result-object p1

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

    move-result v0

    if-eqz v0, :cond_9f

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

    move-result-object v0

    check-cast v0, Lbe/b;

    invoke-interface {v0, p2}, Lbe/b;->b(Ljava/lang/Object;)V

    goto :goto_8f

    :cond_9f
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final c(Ljava/lang/String;)V
    .registers 4

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

    move-result v0

    const/4 v1, 0x1

    if-lez v0, :cond_9

    const/4 v0, 0x1

    goto :goto_a

    :cond_9
    const/4 v0, 0x0

    :goto_a
    if-eqz v0, :cond_1c

    invoke-static {p1}, Lkotlin/text/StringsKt__StringsJVMKt;->isBlank(Ljava/lang/CharSequence;)Z

    move-result v0

    xor-int/2addr v0, v1

    if-eqz v0, :cond_1c

    new-instance v0, Lfe/e$k;

    const/4 v1, 0x0

    invoke-direct {v0, v1, p1}, Lfe/e$k;-><init>(Lkotlin/coroutines/Continuation;Ljava/lang/String;)V

    invoke-static {v0}, Lhe/b;->c(Lkotlin/jvm/functions/Function2;)Lkotlinx/coroutines/Job;

    :cond_1c
    return-void
.end method

.method public final d(Ljava/lang/String;)Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;
    .registers 3

    sget-object v0, Lfe/b;->b:Lfe/b;

    invoke-virtual {v0, p1}, Lfe/b;->a(Ljava/lang/String;)Lge/a;

    move-result-object p1

    if-eqz p1, :cond_d

    invoke-virtual {p1}, Lge/a;->d()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    move-result-object p1

    goto :goto_e

    :cond_d
    const/4 p1, 0x0

    :goto_e
    return-object p1
.end method

.method public final synthetic d(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 7
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$l;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$l;

    iget v1, v0, Lfe/e$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, Lfe/e$l;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$l;

    invoke-direct {v0, p0, p2}, Lfe/e$l;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$l;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$l;->b:I

    const/4 v3, 0x1

    if-eqz v2, :cond_39

    if-ne v2, v3, :cond_31

    iget-object p1, v0, Lfe/e$l;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v0, v0, Lfe/e$l;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    invoke-static {p2}, 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 {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskStatus()Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    move-result-object p2

    sget-object v2, Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;->CANCELED:Lcom/shopee/foody/driver/conditiontask/internal/tasks/enums/TaskStatus;

    if-ne p2, v2, :cond_6a

    iput-object p0, v0, Lfe/e$l;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$l;->e:Ljava/lang/Object;

    iput v3, v0, Lfe/e$l;->b:I

    invoke-virtual {p1, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->markProcessing$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_51

    return-object v1

    :cond_51
    :goto_51
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Mark proceeding task status from CANCEL to PROCESSING, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    goto :goto_82

    :cond_6a
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Skip re-execute task because this task is in proceeding, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    :goto_82
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final synthetic e(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 7
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$m;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$m;

    iget v1, v0, Lfe/e$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, Lfe/e$m;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$m;

    invoke-direct {v0, p0, p2}, Lfe/e$m;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$m;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$m;->b:I

    const/4 v3, 0x1

    if-eqz v2, :cond_39

    if-ne v2, v3, :cond_31

    iget-object p1, v0, Lfe/e$m;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v0, v0, Lfe/e$m;->d:Ljava/lang/Object;

    check-cast v0, Lfe/e;

    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, Lke/a;->e:Lke/a;

    invoke-virtual {p2}, Lke/a;->a()Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;

    move-result-object p2

    if-eqz p2, :cond_57

    invoke-virtual {p2}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfoDB;->b()Lde/a;

    move-result-object p2

    if-eqz p2, :cond_57

    iput-object p0, v0, Lfe/e$m;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$m;->e:Ljava/lang/Object;

    iput v3, v0, Lfe/e$m;->b:I

    invoke-interface {p2, p1, v0}, Lde/a;->b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_57

    return-object v1

    :cond_57
    :goto_57
    new-instance p2, Ljava/lang/StringBuilder;

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

    const-string v0, "Save persist-task to db, "

    invoke-virtual {p2, v0}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object p1

    invoke-virtual {p2, p1}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p2}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object p1

    invoke-static {p1}, Lhe/b;->b(Ljava/lang/String;)V

    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method

.method public final synthetic f(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;
    .registers 10
    .annotation system Ldalvik/annotation/Signature;
        value = {
            "(",
            "Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;",
            "Lkotlin/coroutines/Continuation<",
            "-",
            "Lkotlin/Unit;",
            ">;)",
            "Ljava/lang/Object;"
        }
    .end annotation

    instance-of v0, p2, Lfe/e$n;

    if-eqz v0, :cond_13

    move-object v0, p2

    check-cast v0, Lfe/e$n;

    iget v1, v0, Lfe/e$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, Lfe/e$n;->b:I

    goto :goto_18

    :cond_13
    new-instance v0, Lfe/e$n;

    invoke-direct {v0, p0, p2}, Lfe/e$n;-><init>(Lfe/e;Lkotlin/coroutines/Continuation;)V

    :goto_18
    iget-object p2, v0, Lfe/e$n;->a:Ljava/lang/Object;

    invoke-static {}, Lkotlin/coroutines/intrinsics/IntrinsicsKt__IntrinsicsKt;->getCOROUTINE_SUSPENDED()Ljava/lang/Object;

    move-result-object v1

    iget v2, v0, Lfe/e$n;->b:I

    const/4 v3, 0x3

    const/4 v4, 0x2

    const/4 v5, 0x1

    if-eqz v2, :cond_60

    if-eq v2, v5, :cond_54

    if-eq v2, v4, :cond_48

    if-ne v2, v3, :cond_40

    iget-object p1, v0, Lfe/e$n;->g:Ljava/lang/Object;

    check-cast p1, Lfe/c;

    iget-object p1, v0, Lfe/e$n;->f:Ljava/lang/Object;

    check-cast p1, Lge/a;

    iget-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object p1, v0, Lfe/e$n;->d:Ljava/lang/Object;

    check-cast p1, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto/16 :goto_d6

    :cond_40
    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_48
    iget-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object p1, v0, Lfe/e$n;->d:Ljava/lang/Object;

    check-cast p1, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_86

    :cond_54
    iget-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    check-cast p1, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;

    iget-object v2, v0, Lfe/e$n;->d:Ljava/lang/Object;

    check-cast v2, Lfe/e;

    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    goto :goto_71

    :cond_60
    invoke-static {p2}, Lkotlin/ResultKt;->throwOnFailure(Ljava/lang/Object;)V

    iput-object p0, v0, Lfe/e$n;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    iput v5, v0, Lfe/e$n;->b:I

    invoke-virtual {p1, v0}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->markProcessing$driver_indonesiaRelease(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p2

    if-ne p2, v1, :cond_70

    return-object v1

    :cond_70
    move-object v2, p0

    :goto_71
    sget-object p2, Lhe/a;->b:Lhe/a;

    invoke-virtual {p2, p1}, Lhe/a;->b(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)Z

    move-result p2

    if-eqz p2, :cond_89

    iput-object v2, v0, Lfe/e$n;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    iput v4, v0, Lfe/e$n;->b:I

    invoke-virtual {v2, p1, v0}, Lfe/e;->c(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p1

    if-ne p1, v1, :cond_86

    return-object v1

    :cond_86
    :goto_86
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1

    :cond_89
    sget-object p2, Lhe/a;->b:Lhe/a;

    new-instance v4, Lfe/e$o;

    const/4 v5, 0x0

    invoke-direct {v4, p1, v5}, Lfe/e$o;-><init>(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/coroutines/Continuation;)V

    invoke-virtual {p2, p1, v4}, Lhe/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;Lkotlin/jvm/functions/Function1;)V

    new-instance p2, Lge/a;

    invoke-direct {p2, p1}, Lge/a;-><init>(Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;)V

    sget-object v4, Lfe/a;->b:Lfe/a;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->getTaskWaitingCondition()Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;

    move-result-object v5

    invoke-virtual {v4, v5}, Lfe/a;->a(Lcom/shopee/foody/driver/conditiontask/internal/conditions/Condition;)Lfe/c;

    move-result-object v4

    new-instance v5, Ljava/lang/StringBuilder;

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

    const-string v6, "Send runtime-task to "

    invoke-virtual {v5, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v5, v4}, Ljava/lang/StringBuilder;->append(Ljava/lang/Object;)Ljava/lang/StringBuilder;

    const-string v6, ", "

    invoke-virtual {v5, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {p1}, Lcom/shopee/foody/driver/conditiontask/internal/db/TaskInfo;->simpleInfoStr$driver_indonesiaRelease()Ljava/lang/String;

    move-result-object v6

    invoke-virtual {v5, v6}, Ljava/lang/StringBuilder;->append(Ljava/lang/String;)Ljava/lang/StringBuilder;

    invoke-virtual {v5}, Ljava/lang/StringBuilder;->toString()Ljava/lang/String;

    move-result-object v5

    invoke-static {v5}, Lhe/b;->b(Ljava/lang/String;)V

    if-eqz v4, :cond_d6

    iput-object v2, v0, Lfe/e$n;->d:Ljava/lang/Object;

    iput-object p1, v0, Lfe/e$n;->e:Ljava/lang/Object;

    iput-object p2, v0, Lfe/e$n;->f:Ljava/lang/Object;

    iput-object v4, v0, Lfe/e$n;->g:Ljava/lang/Object;

    iput v3, v0, Lfe/e$n;->b:I

    invoke-virtual {v4, p2, v0}, Lfe/c;->a(Lge/a;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;

    move-result-object p1

    if-ne p1, v1, :cond_d6

    return-object v1

    :cond_d6
    :goto_d6
    sget-object p1, Lkotlin/Unit;->INSTANCE:Lkotlin/Unit;

    return-object p1
.end method