package o4;

import android.database.Cursor;
import android.os.Build;
import android.text.TextUtils;
import androidx.room.RoomDatabase;
import androidx.room.s0;
import androidx.work.ExistingWorkPolicy;
import androidx.work.WorkInfo$State;
import androidx.work.b0;
import androidx.work.i0;
import androidx.work.impl.WorkDatabase;
import androidx.work.impl.background.systemalarm.RescheduleReceiver;
import androidx.work.impl.workers.ConstraintTrackingWorker;
import androidx.work.u;
import androidx.work.x;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.UUID;
import xyz.stream.utils.e0;

/* JADX INFO: loaded from: classes.dex */
public final class d implements Runnable {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final androidx.work.impl.g f31381a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final androidx.work.impl.c f31382b = new androidx.work.impl.c();

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

    public d(androidx.work.impl.g gVar) {
        this.f31381a = gVar;
    }

    /* JADX WARN: Removed duplicated region for block: B:109:0x020b  */
    /* JADX WARN: Removed duplicated region for block: B:113:0x0226  */
    /* JADX WARN: Removed duplicated region for block: B:206:0x01b1 A[SYNTHETIC] */
    /* JADX WARN: Removed duplicated region for block: B:80:0x0195  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public static boolean a(androidx.work.impl.g gVar) {
        boolean zA;
        boolean z10;
        boolean z11;
        boolean z12;
        boolean z13;
        boolean z14;
        long j10;
        WorkInfo$State workInfo$State;
        boolean z15;
        boolean z16;
        Iterator it;
        boolean z17;
        boolean z18;
        WorkInfo$State workInfo$State2;
        long j11;
        boolean z19;
        List listEmptyList;
        boolean z20;
        boolean z21;
        boolean z22;
        List<androidx.work.impl.g> list = gVar.f4605g;
        if (list != null) {
            zA = false;
            for (androidx.work.impl.g gVar2 : list) {
                if (gVar2.f4606h) {
                    u uVarC = u.c();
                    String.format("Already enqueued work ids (%s).", TextUtils.join(", ", gVar2.f4603e));
                    uVarC.f(new Throwable[0]);
                } else {
                    zA |= a(gVar2);
                }
            }
        } else {
            zA = false;
        }
        String[] strArr = (String[]) androidx.work.impl.g.b(gVar).toArray(new String[0]);
        String name = gVar.getName();
        long jCurrentTimeMillis = System.currentTimeMillis();
        androidx.work.impl.o oVar = gVar.f4599a;
        WorkDatabase workDatabase = oVar.f4625c;
        boolean z23 = strArr != null && strArr.length > 0;
        WorkInfo$State workInfo$State3 = WorkInfo$State.f4518c;
        WorkInfo$State workInfo$State4 = WorkInfo$State.f4521f;
        WorkInfo$State workInfo$State5 = WorkInfo$State.f4519d;
        if (z23) {
            z11 = false;
            z12 = false;
            z10 = true;
            for (String str : strArr) {
                n4.o oVarP = ((n4.r) workDatabase.workSpecDao()).p(str);
                if (oVarP == null) {
                    u uVarC2 = u.c();
                    String.format("Prerequisite %s doesn't exist; not enqueuing", str);
                    uVarC2.b(new Throwable[0]);
                    z14 = zA;
                    break;
                }
                WorkInfo$State workInfo$State6 = oVarP.f30819b;
                z10 &= workInfo$State6 == workInfo$State3;
                if (workInfo$State6 == workInfo$State5) {
                    z12 = true;
                } else if (workInfo$State6 == workInfo$State4) {
                    z11 = true;
                }
            }
        } else {
            z10 = true;
            z11 = false;
            z12 = false;
        }
        boolean z24 = !TextUtils.isEmpty(name);
        WorkInfo$State workInfo$State7 = WorkInfo$State.f4516a;
        if (!z24 || z23) {
            z13 = z24;
            z14 = zA;
            j10 = jCurrentTimeMillis;
            workInfo$State = workInfo$State7;
            z15 = false;
            z16 = z23;
            it = gVar.f4602d.iterator();
            boolean z25 = z15;
            while (it.hasNext()) {
                i0 i0Var = (i0) it.next();
                n4.o oVar2 = i0Var.f4567b;
                if (z16 && !z10) {
                    if (z12) {
                        oVar2.f30819b = workInfo$State5;
                    } else if (z11) {
                        oVar2.f30819b = workInfo$State4;
                    } else {
                        oVar2.f30819b = WorkInfo$State.f4520e;
                    }
                    workInfo$State2 = workInfo$State4;
                    j11 = j10;
                } else if (oVar2.c()) {
                    workInfo$State2 = workInfo$State4;
                    j11 = j10;
                    oVar2.f30831n = 0L;
                } else {
                    j11 = j10;
                    oVar2.f30831n = j11;
                    workInfo$State2 = workInfo$State4;
                }
                if (Build.VERSION.SDK_INT <= 25) {
                    androidx.work.e eVar = oVar2.f30827j;
                    String str2 = oVar2.f30820c;
                    if (!str2.equals(ConstraintTrackingWorker.class.getName()) && (eVar.f4552d || eVar.f4553e)) {
                        androidx.work.h hVar = new androidx.work.h();
                        hVar.b(oVar2.f30822e.f4565a);
                        hVar.putString("androidx.work.impl.workers.ConstraintTrackingWorker.ARGUMENT_CLASS_NAME", str2);
                        oVar2.f30820c = ConstraintTrackingWorker.class.getName();
                        oVar2.f30822e = hVar.a();
                    }
                }
                WorkInfo$State workInfo$State8 = workInfo$State;
                if (oVar2.f30819b == workInfo$State8) {
                    z25 = true;
                }
                n4.r rVar = (n4.r) workDatabase.workSpecDao();
                Object obj = rVar.f30838b;
                RoomDatabase roomDatabase = (RoomDatabase) obj;
                roomDatabase.assertNotSuspendingTransaction();
                roomDatabase.beginTransaction();
                try {
                    ((androidx.room.i) rVar.f30839c).e(oVar2);
                    ((RoomDatabase) obj).setTransactionSuccessful();
                    roomDatabase.endTransaction();
                    UUID uuid = i0Var.f4566a;
                    if (z16) {
                        int length = strArr.length;
                        int i10 = 0;
                        while (i10 < length) {
                            Iterator it2 = it;
                            String[] strArr2 = strArr;
                            int i11 = length;
                            n4.a aVar = new n4.a(uuid.toString(), strArr[i10]);
                            e0 e0Var = (e0) workDatabase.dependencyDao();
                            ((RoomDatabase) e0Var.f36128b).assertNotSuspendingTransaction();
                            ((RoomDatabase) e0Var.f36128b).beginTransaction();
                            try {
                                ((androidx.room.i) e0Var.f36129c).e(aVar);
                                ((RoomDatabase) e0Var.f36128b).setTransactionSuccessful();
                                ((RoomDatabase) e0Var.f36128b).endTransaction();
                                i10++;
                                length = i11;
                                it = it2;
                                strArr = strArr2;
                            } catch (Throwable th) {
                                RoomDatabase roomDatabase2 = (RoomDatabase) e0Var.f36128b;
                                throw th;
                            }
                        }
                    }
                    String[] strArr3 = strArr;
                    Iterator it3 = it;
                    for (String str3 : i0Var.f4568c) {
                        n4.t tVarWorkTagDao = workDatabase.workTagDao();
                        n4.s sVar = new n4.s(str3, uuid.toString());
                        xyz.stream.utils.f fVar = (xyz.stream.utils.f) tVarWorkTagDao;
                        ((RoomDatabase) fVar.f36132b).assertNotSuspendingTransaction();
                        ((RoomDatabase) fVar.f36132b).beginTransaction();
                        try {
                            ((androidx.room.i) fVar.f36133c).e(sVar);
                            ((RoomDatabase) fVar.f36132b).setTransactionSuccessful();
                        } finally {
                            RoomDatabase roomDatabase3 = (RoomDatabase) fVar.f36132b;
                        }
                    }
                    if (z13) {
                        n4.j jVarWorkNameDao = workDatabase.workNameDao();
                        n4.i iVar = new n4.i(name, uuid.toString());
                        fe.h hVar2 = (fe.h) jVarWorkNameDao;
                        ((RoomDatabase) hVar2.f26080b).assertNotSuspendingTransaction();
                        ((RoomDatabase) hVar2.f26080b).beginTransaction();
                        try {
                            ((androidx.room.i) hVar2.f26081c).e(iVar);
                            ((RoomDatabase) hVar2.f26080b).setTransactionSuccessful();
                        } finally {
                            RoomDatabase roomDatabase4 = (RoomDatabase) hVar2.f26080b;
                        }
                    }
                    workInfo$State4 = workInfo$State2;
                    j10 = j11;
                    it = it3;
                    strArr = strArr3;
                    workInfo$State = workInfo$State8;
                } finally {
                    roomDatabase.endTransaction();
                }
            }
            z17 = z25;
            z18 = true;
        } else {
            ArrayList arrayListQ = ((n4.r) workDatabase.workSpecDao()).q(name);
            if (!arrayListQ.isEmpty()) {
                ExistingWorkPolicy existingWorkPolicy = ExistingWorkPolicy.f4498b;
                boolean z26 = z23;
                ExistingWorkPolicy existingWorkPolicy2 = ExistingWorkPolicy.f4499c;
                z14 = zA;
                ExistingWorkPolicy existingWorkPolicy3 = gVar.f4601c;
                if (existingWorkPolicy3 == existingWorkPolicy || existingWorkPolicy3 == existingWorkPolicy2) {
                    n4.b bVarDependencyDao = workDatabase.dependencyDao();
                    ArrayList arrayList = new ArrayList();
                    Iterator it4 = arrayListQ.iterator();
                    while (it4.hasNext()) {
                        Iterator it5 = it4;
                        n4.n nVar = (n4.n) it4.next();
                        boolean z27 = z24;
                        String str4 = nVar.f30816a;
                        WorkInfo$State workInfo$State9 = workInfo$State7;
                        e0 e0Var2 = (e0) bVarDependencyDao;
                        e0Var2.getClass();
                        n4.b bVar = bVarDependencyDao;
                        long j12 = jCurrentTimeMillis;
                        s0 s0VarK = s0.k(1, "SELECT COUNT(*)>0 FROM dependency WHERE prerequisite_id=?");
                        if (str4 == null) {
                            s0VarK.d(1);
                        } else {
                            s0VarK.l(1, str4);
                        }
                        ((RoomDatabase) e0Var2.f36128b).assertNotSuspendingTransaction();
                        Cursor cursorC = androidx.room.util.b.c((RoomDatabase) e0Var2.f36128b, s0VarK);
                        try {
                            if (cursorC.moveToFirst()) {
                                z20 = false;
                                if (cursorC.getInt(0) != 0) {
                                    z21 = true;
                                }
                                if (!z21) {
                                    WorkInfo$State workInfo$State10 = nVar.f30817b;
                                    boolean z28 = z10 & (workInfo$State10 == workInfo$State3 ? true : z20);
                                    if (workInfo$State10 == workInfo$State5) {
                                        z22 = true;
                                    } else {
                                        z22 = z12;
                                        if (workInfo$State10 == workInfo$State4) {
                                            z11 = true;
                                        }
                                    }
                                    arrayList.add(nVar.f30816a);
                                    z10 = z28;
                                    z12 = z22;
                                }
                                bVarDependencyDao = bVar;
                                it4 = it5;
                                z24 = z27;
                                workInfo$State7 = workInfo$State9;
                                jCurrentTimeMillis = j12;
                            } else {
                                z20 = false;
                            }
                            z21 = z20;
                            if (!z21) {
                            }
                            bVarDependencyDao = bVar;
                            it4 = it5;
                            z24 = z27;
                            workInfo$State7 = workInfo$State9;
                            jCurrentTimeMillis = j12;
                        } finally {
                            cursorC.close();
                            s0VarK.m();
                        }
                    }
                    z13 = z24;
                    j10 = jCurrentTimeMillis;
                    workInfo$State = workInfo$State7;
                    if (existingWorkPolicy3 == existingWorkPolicy2 && (z11 || z12)) {
                        n4.r rVar2 = (n4.r) workDatabase.workSpecDao();
                        Iterator it6 = rVar2.q(name).iterator();
                        while (it6.hasNext()) {
                            rVar2.c(((n4.n) it6.next()).f30816a);
                        }
                        z19 = false;
                        z11 = false;
                        listEmptyList = Collections.emptyList();
                    } else {
                        z19 = z12;
                        listEmptyList = arrayList;
                    }
                    strArr = (String[]) listEmptyList.toArray(strArr);
                    z16 = strArr.length > 0;
                    z12 = z19;
                    z15 = false;
                } else {
                    if (existingWorkPolicy3 == ExistingWorkPolicy.f4497a) {
                        Iterator it7 = arrayListQ.iterator();
                        while (it7.hasNext()) {
                            WorkInfo$State workInfo$State11 = ((n4.n) it7.next()).f30817b;
                            if (workInfo$State11 == workInfo$State7 || workInfo$State11 == WorkInfo$State.f4517b) {
                                z18 = true;
                                z17 = false;
                            }
                        }
                    }
                    new b(oVar, name).run();
                    n4.p pVarWorkSpecDao = workDatabase.workSpecDao();
                    Iterator it8 = arrayListQ.iterator();
                    while (it8.hasNext()) {
                        ((n4.r) pVarWorkSpecDao).c(((n4.n) it8.next()).f30816a);
                    }
                    z13 = z24;
                    j10 = jCurrentTimeMillis;
                    workInfo$State = workInfo$State7;
                    z16 = z26;
                    z15 = true;
                }
            }
            it = gVar.f4602d.iterator();
            boolean z252 = z15;
            while (it.hasNext()) {
            }
            z17 = z252;
            z18 = true;
        }
        gVar.f4606h = z18;
        return z14 | z17;
    }

    @Override // java.lang.Runnable
    public final void run() {
        androidx.work.impl.c cVar = this.f31382b;
        androidx.work.impl.g gVar = this.f31381a;
        try {
            gVar.getClass();
            androidx.work.impl.o oVar = gVar.f4599a;
            if (androidx.work.impl.g.a(gVar, new HashSet())) {
                throw new IllegalStateException(String.format("WorkContinuation has cycles (%s)", gVar));
            }
            WorkDatabase workDatabase = oVar.f4625c;
            workDatabase.beginTransaction();
            try {
                boolean zA = a(gVar);
                workDatabase.setTransactionSuccessful();
                if (zA) {
                    g.a(oVar.f4623a, RescheduleReceiver.class, true);
                    androidx.work.impl.f.a(oVar.f4624b, oVar.f4625c, oVar.f4627e);
                }
                cVar.a(b0.f4536a);
            } finally {
                workDatabase.endTransaction();
            }
        } catch (Throwable th) {
            cVar.a(new x(th));
        }
    }
}