package androidx.work.impl;

import android.content.Context;
import android.database.Cursor;
import android.os.CancellationSignal;
import androidx.annotation.Nullable;
import androidx.room.RoomDatabase;
import androidx.room.s0;
import androidx.work.ListenableWorker;
import androidx.work.WorkInfo$State;
import androidx.work.WorkerParameters;
import androidx.work.impl.background.systemalarm.RescheduleReceiver;
import androidx.work.j0;
import androidx.work.l0;
import androidx.work.s;
import androidx.work.u;
import com.google.android.gms.measurement.internal.u1;
import com.google.common.util.concurrent.w;
import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.ExecutorService;
import n4.t;
import xyz.stream.utils.e0;

/* JADX INFO: loaded from: classes.dex */
public final class r implements Runnable {
    public static final /* synthetic */ int V = 0;
    public t Q;
    public ArrayList R;
    public String S;
    public androidx.work.impl.utils.futures.i T;
    public volatile boolean U;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public Context f4644a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public String f4645b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public List f4646c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public l0 f4647d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public n4.o f4648e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public ListenableWorker f4649f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public p4.a f4650g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public s f4651h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public androidx.work.c f4652i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public androidx.work.impl.foreground.a f4653j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public WorkDatabase f4654k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public n4.p f4655l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public n4.b f4656m;

    @Nullable
    w mInnerFuture;

    static {
        u.e("WorkerWrapper");
    }

    public final void a(s sVar) {
        if (!(sVar instanceof androidx.work.r)) {
            if (sVar instanceof androidx.work.q) {
                u uVarC = u.c();
                String.format("Worker result RETRY for %s", this.S);
                uVarC.d(new Throwable[0]);
                d();
                return;
            }
            u uVarC2 = u.c();
            String.format("Worker result FAILURE for %s", this.S);
            uVarC2.d(new Throwable[0]);
            if (this.f4648e.c()) {
                e();
                return;
            } else {
                h();
                return;
            }
        }
        u uVarC3 = u.c();
        String.format("Worker result SUCCESS for %s", this.S);
        uVarC3.d(new Throwable[0]);
        if (this.f4648e.c()) {
            e();
            return;
        }
        n4.b bVar = this.f4656m;
        String str = this.f4645b;
        n4.p pVar = this.f4655l;
        WorkDatabase workDatabase = this.f4654k;
        workDatabase.beginTransaction();
        try {
            ((n4.r) pVar).A(WorkInfo$State.f4518c, str);
            ((n4.r) pVar).y(str, ((androidx.work.r) this.f4651h).f4692a);
            long jCurrentTimeMillis = System.currentTimeMillis();
            for (String str2 : ((e0) bVar).j(str)) {
                if (((n4.r) pVar).l(str2) == WorkInfo$State.f4520e && ((e0) bVar).s(str2)) {
                    u uVarC4 = u.c();
                    String.format("Setting status to enqueued for %s", str2);
                    uVarC4.d(new Throwable[0]);
                    ((n4.r) pVar).A(WorkInfo$State.f4516a, str2);
                    ((n4.r) pVar).z(jCurrentTimeMillis, str2);
                }
            }
            workDatabase.setTransactionSuccessful();
            workDatabase.endTransaction();
            f(false);
        } catch (Throwable th) {
            workDatabase.endTransaction();
            f(false);
            throw th;
        }
    }

    public final void b(String str) {
        LinkedList linkedList = new LinkedList();
        linkedList.add(str);
        while (!linkedList.isEmpty()) {
            String str2 = (String) linkedList.remove();
            n4.r rVar = (n4.r) this.f4655l;
            if (rVar.l(str2) != WorkInfo$State.f4521f) {
                rVar.A(WorkInfo$State.f4519d, str2);
            }
            linkedList.addAll(((e0) this.f4656m).j(str2));
        }
    }

    public final void c() {
        boolean zI = i();
        String str = this.f4645b;
        WorkDatabase workDatabase = this.f4654k;
        if (!zI) {
            workDatabase.beginTransaction();
            try {
                WorkInfo$State workInfo$StateL = ((n4.r) this.f4655l).l(str);
                ((u.e) workDatabase.workProgressDao()).f(str);
                if (workInfo$StateL == null) {
                    f(false);
                } else if (workInfo$StateL == WorkInfo$State.f4517b) {
                    a(this.f4651h);
                } else if (!workInfo$StateL.a()) {
                    d();
                }
                workDatabase.setTransactionSuccessful();
                workDatabase.endTransaction();
            } catch (Throwable th) {
                workDatabase.endTransaction();
                throw th;
            }
        }
        List list = this.f4646c;
        if (list != null) {
            Iterator it = list.iterator();
            while (it.hasNext()) {
                ((e) it.next()).c(str);
            }
            f.a(this.f4652i, workDatabase, list);
        }
    }

    public final void d() {
        String str = this.f4645b;
        n4.p pVar = this.f4655l;
        WorkDatabase workDatabase = this.f4654k;
        workDatabase.beginTransaction();
        try {
            ((n4.r) pVar).A(WorkInfo$State.f4516a, str);
            ((n4.r) pVar).z(System.currentTimeMillis(), str);
            ((n4.r) pVar).v(-1L, str);
            workDatabase.setTransactionSuccessful();
        } finally {
            workDatabase.endTransaction();
            f(true);
        }
    }

    public final void e() {
        String str = this.f4645b;
        n4.p pVar = this.f4655l;
        WorkDatabase workDatabase = this.f4654k;
        workDatabase.beginTransaction();
        try {
            ((n4.r) pVar).z(System.currentTimeMillis(), str);
            ((n4.r) pVar).A(WorkInfo$State.f4516a, str);
            ((n4.r) pVar).x(str);
            ((n4.r) pVar).v(-1L, str);
            workDatabase.setTransactionSuccessful();
        } finally {
            workDatabase.endTransaction();
            f(false);
        }
    }

    public final void f(boolean z10) {
        ListenableWorker listenableWorker;
        this.f4654k.beginTransaction();
        try {
            if (!((n4.r) this.f4654k.workSpecDao()).r()) {
                o4.g.a(this.f4644a, RescheduleReceiver.class, false);
            }
            if (z10) {
                ((n4.r) this.f4655l).A(WorkInfo$State.f4516a, this.f4645b);
                ((n4.r) this.f4655l).v(-1L, this.f4645b);
            }
            if (this.f4648e != null && (listenableWorker = this.f4649f) != null && listenableWorker.isRunInForeground()) {
                androidx.work.impl.foreground.a aVar = this.f4653j;
                String str = this.f4645b;
                d dVar = (d) aVar;
                synchronized (dVar.f4582j) {
                    dVar.f4577e.remove(str);
                    dVar.f();
                }
            }
            this.f4654k.setTransactionSuccessful();
            this.f4654k.endTransaction();
            this.T.set(Boolean.valueOf(z10));
        } catch (Throwable th) {
            this.f4654k.endTransaction();
            throw th;
        }
    }

    public final void g() {
        n4.r rVar = (n4.r) this.f4655l;
        String str = this.f4645b;
        WorkInfo$State workInfo$StateL = rVar.l(str);
        if (workInfo$StateL == WorkInfo$State.f4517b) {
            u uVarC = u.c();
            String.format("Status for %s is RUNNING;not doing any work and rescheduling for later execution", str);
            uVarC.a(new Throwable[0]);
            f(true);
            return;
        }
        u uVarC2 = u.c();
        String.format("Status for %s is %s; not doing any work", str, workInfo$StateL);
        uVarC2.a(new Throwable[0]);
        f(false);
    }

    public final void h() {
        String str = this.f4645b;
        WorkDatabase workDatabase = this.f4654k;
        workDatabase.beginTransaction();
        try {
            b(str);
            ((n4.r) this.f4655l).y(str, ((androidx.work.p) this.f4651h).f4691a);
            workDatabase.setTransactionSuccessful();
        } finally {
            workDatabase.endTransaction();
            f(false);
        }
    }

    public final boolean i() {
        if (!this.U) {
            return false;
        }
        u uVarC = u.c();
        String.format("Work interrupted for %s", this.S);
        uVarC.a(new Throwable[0]);
        if (((n4.r) this.f4655l).l(this.f4645b) == null) {
            f(false);
        } else {
            f(!r0.a());
        }
        return true;
    }

    /* JADX WARN: Removed duplicated region for block: B:39:0x00f2  */
    /* JADX WARN: Removed duplicated region for block: B:40:0x00f8  */
    /* JADX WARN: Removed duplicated region for block: B:58:0x01b7  */
    /* JADX WARN: Removed duplicated region for block: B:61:0x01c7  */
    /* JADX WARN: Removed duplicated region for block: B:62:0x01e3  */
    @Override // java.lang.Runnable
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final void run() {
        boolean zC;
        androidx.work.i iVarA;
        ListenableWorker listenableWorker;
        boolean z10;
        xyz.stream.utils.f fVar = (xyz.stream.utils.f) this.Q;
        String str = this.f4645b;
        ArrayList<String> arrayListU = fVar.u(str);
        this.R = arrayListU;
        StringBuilder sbN = u1.n("Work [ id=", str, ", tags={ ");
        boolean z11 = true;
        for (String str2 : arrayListU) {
            if (z11) {
                z11 = false;
            } else {
                sbN.append(", ");
            }
            sbN.append(str2);
        }
        sbN.append(" } ]");
        this.S = sbN.toString();
        n4.p pVar = this.f4655l;
        if (i()) {
            return;
        }
        WorkDatabase workDatabase = this.f4654k;
        workDatabase.beginTransaction();
        try {
            n4.o oVarP = ((n4.r) pVar).p(str);
            this.f4648e = oVarP;
            if (oVarP == null) {
                u uVarC = u.c();
                String.format("Didn't find WorkSpec for id %s", str);
                uVarC.b(new Throwable[0]);
                f(false);
                workDatabase.setTransactionSuccessful();
            } else {
                WorkInfo$State workInfo$State = oVarP.f30819b;
                WorkInfo$State workInfo$State2 = WorkInfo$State.f4516a;
                if (workInfo$State != workInfo$State2) {
                    g();
                    workDatabase.setTransactionSuccessful();
                    u uVarC2 = u.c();
                    String.format("%s is not in ENQUEUED state. Nothing more to do.", this.f4648e.f30820c);
                    uVarC2.a(new Throwable[0]);
                } else {
                    if (!oVarP.c()) {
                        n4.o oVar = this.f4648e;
                        if (oVar.f30819b == workInfo$State2 && oVar.f30828k > 0) {
                        }
                        workDatabase.setTransactionSuccessful();
                        workDatabase.endTransaction();
                        zC = this.f4648e.c();
                        androidx.work.c cVar = this.f4652i;
                        if (zC) {
                            androidx.work.m mVarCreateInputMergerWithDefaultFallback = cVar.f4541d.createInputMergerWithDefaultFallback(this.f4648e.f30821d);
                            if (mVarCreateInputMergerWithDefaultFallback == null) {
                                u uVarC3 = u.c();
                                String.format("Could not create Input Merger %s", this.f4648e.f30821d);
                                uVarC3.b(new Throwable[0]);
                                h();
                                return;
                            }
                            ArrayList arrayList = new ArrayList();
                            arrayList.add(this.f4648e.f30822e);
                            n4.r rVar = (n4.r) pVar;
                            rVar.getClass();
                            s0 s0VarK = s0.k(1, "SELECT output FROM workspec WHERE id IN (SELECT prerequisite_id FROM dependency WHERE work_spec_id=?)");
                            if (str == null) {
                                s0VarK.d(1);
                            } else {
                                s0VarK.l(1, str);
                            }
                            RoomDatabase roomDatabase = (RoomDatabase) rVar.f30838b;
                            roomDatabase.assertNotSuspendingTransaction();
                            Cursor cursorQuery = roomDatabase.query(s0VarK, (CancellationSignal) null);
                            try {
                                ArrayList arrayList2 = new ArrayList(cursorQuery.getCount());
                                while (cursorQuery.moveToNext()) {
                                    arrayList2.add(androidx.work.i.a(cursorQuery.getBlob(0)));
                                }
                                cursorQuery.close();
                                s0VarK.m();
                                arrayList.addAll(arrayList2);
                                iVarA = mVarCreateInputMergerWithDefaultFallback.a(arrayList);
                            } catch (Throwable th) {
                                cursorQuery.close();
                                s0VarK.m();
                                throw th;
                            }
                        } else {
                            iVarA = this.f4648e.f30822e;
                        }
                        UUID uuidFromString = UUID.fromString(str);
                        ArrayList arrayList3 = this.R;
                        int i10 = this.f4648e.f30828k;
                        ExecutorService executorService = cVar.f4538a;
                        p4.a aVar = this.f4650g;
                        o4.q qVar = new o4.q(workDatabase, aVar);
                        o4.p pVar2 = new o4.p(workDatabase, this.f4653j, aVar);
                        WorkerParameters workerParameters = new WorkerParameters();
                        workerParameters.f4524a = uuidFromString;
                        workerParameters.f4525b = iVarA;
                        workerParameters.f4526c = new HashSet(arrayList3);
                        workerParameters.f4527d = this.f4647d;
                        workerParameters.f4528e = i10;
                        workerParameters.f4529f = executorService;
                        workerParameters.f4530g = aVar;
                        j0 j0Var = cVar.f4540c;
                        workerParameters.f4531h = j0Var;
                        workerParameters.f4532i = qVar;
                        workerParameters.f4533j = pVar2;
                        if (this.f4649f == null) {
                            this.f4649f = j0Var.createWorkerWithDefaultFallback(this.f4644a, this.f4648e.f30820c, workerParameters);
                        }
                        listenableWorker = this.f4649f;
                        if (listenableWorker != null) {
                            u uVarC4 = u.c();
                            String.format("Could not create Worker %s", this.f4648e.f30820c);
                            uVarC4.b(new Throwable[0]);
                            h();
                            return;
                        }
                        if (listenableWorker.isUsed()) {
                            u uVarC5 = u.c();
                            String.format("Received an already-used Worker %s; WorkerFactory should return new instances", this.f4648e.f30820c);
                            uVarC5.b(new Throwable[0]);
                            h();
                            return;
                        }
                        this.f4649f.setUsed();
                        workDatabase.beginTransaction();
                        try {
                            if (((n4.r) pVar).l(str) == workInfo$State2) {
                                ((n4.r) pVar).A(WorkInfo$State.f4517b, str);
                                ((n4.r) pVar).s(str);
                                z10 = true;
                            } else {
                                z10 = false;
                            }
                            workDatabase.setTransactionSuccessful();
                            if (!z10) {
                                g();
                                return;
                            }
                            if (i()) {
                                return;
                            }
                            androidx.work.impl.utils.futures.i iVar = new androidx.work.impl.utils.futures.i();
                            o4.o oVar2 = new o4.o(this.f4644a, this.f4648e, this.f4649f, pVar2, this.f4650g);
                            p4.c cVar2 = (p4.c) aVar;
                            cVar2.f31625c.execute(oVar2);
                            androidx.work.impl.utils.futures.i iVar2 = oVar2.f31404a;
                            iVar2.g(new p(this, iVar2, iVar), cVar2.f31625c);
                            iVar.g(new p(this, iVar, this.S), cVar2.f31623a);
                            return;
                        } finally {
                        }
                    }
                    long jCurrentTimeMillis = System.currentTimeMillis();
                    n4.o oVar3 = this.f4648e;
                    if (oVar3.f30831n != 0 && jCurrentTimeMillis < oVar3.a()) {
                        u uVarC6 = u.c();
                        String.format("Delaying execution for %s because it is being executed before schedule.", this.f4648e.f30820c);
                        uVarC6.a(new Throwable[0]);
                        f(true);
                        workDatabase.setTransactionSuccessful();
                    }
                    workDatabase.setTransactionSuccessful();
                    workDatabase.endTransaction();
                    zC = this.f4648e.c();
                    androidx.work.c cVar3 = this.f4652i;
                    if (zC) {
                    }
                    UUID uuidFromString2 = UUID.fromString(str);
                    ArrayList arrayList32 = this.R;
                    int i102 = this.f4648e.f30828k;
                    ExecutorService executorService2 = cVar3.f4538a;
                    p4.a aVar2 = this.f4650g;
                    o4.q qVar2 = new o4.q(workDatabase, aVar2);
                    o4.p pVar22 = new o4.p(workDatabase, this.f4653j, aVar2);
                    WorkerParameters workerParameters2 = new WorkerParameters();
                    workerParameters2.f4524a = uuidFromString2;
                    workerParameters2.f4525b = iVarA;
                    workerParameters2.f4526c = new HashSet(arrayList32);
                    workerParameters2.f4527d = this.f4647d;
                    workerParameters2.f4528e = i102;
                    workerParameters2.f4529f = executorService2;
                    workerParameters2.f4530g = aVar2;
                    j0 j0Var2 = cVar3.f4540c;
                    workerParameters2.f4531h = j0Var2;
                    workerParameters2.f4532i = qVar2;
                    workerParameters2.f4533j = pVar22;
                    if (this.f4649f == null) {
                    }
                    listenableWorker = this.f4649f;
                    if (listenableWorker != null) {
                    }
                }
            }
        } finally {
            workDatabase.endTransaction();
        }
    }
}