package com.strmr.ps.background;

import android.content.Context;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import androidx.work.CoroutineWorker;
import androidx.work.WorkerParameters;
import androidx.work.d;
import androidx.work.f;
import com.strmr.ps.data.event.TraktErrorNotifier;
import com.strmr.ps.data.local.entity.TraktAccount;
import com.strmr.ps.data.remote.TraktETagInterceptor;
import com.strmr.ps.data.repository.SyncResult;
import com.strmr.ps.data.repository.TraktAccountRepository;
import com.strmr.ps.data.repository.TraktSyncRepository;
import dagger.hilt.EntryPoint;
import dagger.hilt.InstallIn;
import dagger.hilt.android.EntryPointAccessors;
import dagger.hilt.components.SingletonComponent;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.ed1;
import defpackage.fn6;
import defpackage.hs2;
import defpackage.io6;
import defpackage.kp6;
import defpackage.osa;
import defpackage.q07;
import defpackage.s38;
import defpackage.uw6;
import defpackage.vx8;
import defpackage.x57;
import defpackage.yx9;
import java.net.SocketTimeoutException;
import java.net.UnknownHostException;
import java.util.Collections;
import java.util.concurrent.CancellationException;
import java.util.concurrent.TimeUnit;
import kotlin.Metadata;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import retrofit2.HttpException;

/* JADX INFO: loaded from: classes.dex */
@Metadata(d1 = {"\u0000\u0016\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\u0018\u00002\u00020\u0001:\u0002\b\tB\u0017\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007¨\u0006\n"}, d2 = {"Lcom/strmr/ps/background/TraktSyncWorker;", "Landroidx/work/CoroutineWorker;", "Landroid/content/Context;", "appContext", "Landroidx/work/WorkerParameters;", "params", "<init>", "(Landroid/content/Context;Landroidx/work/WorkerParameters;)V", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "b", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class TraktSyncWorker extends CoroutineWorker {

    @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\r\n\u0002\u0010\t\n\u0002\b\u0004\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0005\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0005\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0006\u0010\u0004R\u0014\u0010\u0007\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0007\u0010\u0004R\u0014\u0010\b\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\b\u0010\u0004R\u0014\u0010\t\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\t\u0010\u0004R\u0014\u0010\n\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\n\u0010\u0004R\u0014\u0010\u000b\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000b\u0010\u0004R\u0014\u0010\f\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\f\u0010\u0004R\u0014\u0010\r\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\r\u0010\u0004R\u0014\u0010\u000e\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000e\u0010\u0004R\u0014\u0010\u000f\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000f\u0010\u0004R\u0014\u0010\u0011\u001a\u00020\u00108\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0011\u0010\u0012R\u0014\u0010\u0013\u001a\u00020\u00108\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0013\u0010\u0012¨\u0006\u0014"}, d2 = {"Lcom/strmr/ps/background/TraktSyncWorker$a;", "", "", "TAG", "Ljava/lang/String;", "ONE_TIME_WORK_NAME", "INITIAL_SYNC_WORK_NAME", "PERIODIC_WORK_NAME", "KEY_IS_INITIAL_SYNC", "KEY_IS_MANUAL_SYNC", "KEY_PROGRESS", "KEY_STATUS", "KEY_ERROR_TYPE", "ERROR_TYPE_AUTH", "ERROR_TYPE_SERVER", "ERROR_TYPE_NETWORK", "", "SYNC_INTERVAL_HOURS", "J", "BACKOFF_DELAY_SECONDS", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public static final class a {
        public static void a(Context context) {
            ed1.a aVar = new ed1.a();
            aVar.a = fn6.b;
            ed1 ed1VarA = aVar.a();
            uw6.a aVar2 = new uw6.a(TraktSyncWorker.class);
            aVar2.c.j = ed1VarA;
            q07[] q07VarArr = {new q07("is_manual_sync", Boolean.TRUE)};
            d.a aVar3 = new d.a();
            q07 q07Var = q07VarArr[0];
            aVar3.b(q07Var.b, (String) q07Var.a);
            aVar2.c.e = aVar3.a();
            TimeUnit timeUnit = TimeUnit.SECONDS;
            uw6 uw6Var = (uw6) ((uw6.a) aVar2.d(1L)).a();
            osa osaVarD = osa.d(context);
            osaVarD.getClass();
            osaVarD.c("trakt_sync_worker", hs2.a, Collections.singletonList(uw6Var));
        }

        public static void b(Context context) {
            ed1.a aVar = new ed1.a();
            aVar.a = fn6.b;
            ed1 ed1VarA = aVar.a();
            uw6.a aVar2 = new uw6.a(TraktSyncWorker.class);
            aVar2.c.j = ed1VarA;
            TimeUnit timeUnit = TimeUnit.SECONDS;
            uw6 uw6Var = (uw6) ((uw6.a) aVar2.d(30L)).a();
            osa osaVarD = osa.d(context);
            osaVarD.getClass();
            osaVarD.c("trakt_sync_worker", hs2.b, Collections.singletonList(uw6Var));
        }

        public static void c(Context context) {
            ed1.a aVar = new ed1.a();
            aVar.a = fn6.b;
            ed1 ed1VarA = aVar.a();
            uw6.a aVar2 = new uw6.a(TraktSyncWorker.class);
            aVar2.c.j = ed1VarA;
            q07[] q07VarArr = {new q07("is_initial_sync", Boolean.TRUE)};
            d.a aVar3 = new d.a();
            q07 q07Var = q07VarArr[0];
            aVar3.b(q07Var.b, (String) q07Var.a);
            aVar2.c.e = aVar3.a();
            TimeUnit timeUnit = TimeUnit.SECONDS;
            uw6 uw6Var = (uw6) ((uw6.a) aVar2.d(30L)).a();
            osa osaVarD = osa.d(context);
            osaVarD.getClass();
            osaVarD.c("trakt_initial_sync", hs2.a, Collections.singletonList(uw6Var));
        }

        public static void d(Context context) {
            ed1.a aVar = new ed1.a();
            aVar.a = fn6.b;
            aVar.b = true;
            ed1 ed1VarA = aVar.a();
            TimeUnit timeUnit = TimeUnit.HOURS;
            x57.a aVar2 = new x57.a(TraktSyncWorker.class, 6L);
            aVar2.c.j = ed1VarA;
            TimeUnit timeUnit2 = TimeUnit.SECONDS;
            osa.d(context).b("trakt_periodic_sync", (x57) ((x57.a) aVar2.d(30L)).a());
        }
    }

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\bg\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/background/TraktSyncWorker$b;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @InstallIn({SingletonComponent.class})
    @EntryPoint
    public interface b {
        TraktAccountRepository traktAccountRepository();

        TraktETagInterceptor traktETagInterceptor();

        TraktErrorNotifier traktErrorNotifier();

        TraktSyncRepository traktSyncRepository();
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public TraktSyncWorker(@kp6 Context context, @kp6 WorkerParameters workerParameters) {
        super(context, workerParameters);
        cr4.g(context, "appContext");
        cr4.g(workerParameters, "params");
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:155:0x0306  */
    /* JADX WARN: Removed duplicated region for block: B:169:0x0395 A[LOOP:2: B:168:0x0393->B:169:0x0395, LOOP_END] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x001f  */
    /* JADX WARN: Removed duplicated region for block: B:86:0x015e A[Catch: CancellationException -> 0x0056, Exception -> 0x011e, SocketTimeoutException -> 0x0123, UnknownHostException -> 0x0128, HttpException -> 0x012d, TRY_ENTER, TryCatch #5 {CancellationException -> 0x0056, blocks: (B:16:0x0049, B:82:0x0154, B:83:0x0156, B:86:0x015e, B:89:0x017a, B:90:0x018a, B:92:0x0194, B:94:0x0198, B:97:0x01c7, B:98:0x01d9, B:100:0x01e3, B:102:0x01e7, B:104:0x01f7, B:106:0x0209, B:118:0x0222, B:120:0x022a, B:122:0x024f, B:124:0x0253, B:127:0x0278, B:128:0x028a, B:130:0x0294, B:131:0x0299, B:31:0x0072, B:60:0x011b, B:48:0x00de, B:49:0x00ec, B:51:0x00f8, B:56:0x0103, B:78:0x0140), top: B:172:0x003b }] */
    /* JADX WARN: Removed duplicated region for block: B:92:0x0194 A[Catch: CancellationException -> 0x0056, Exception -> 0x011e, SocketTimeoutException -> 0x0123, UnknownHostException -> 0x0128, HttpException -> 0x012d, TryCatch #5 {CancellationException -> 0x0056, blocks: (B:16:0x0049, B:82:0x0154, B:83:0x0156, B:86:0x015e, B:89:0x017a, B:90:0x018a, B:92:0x0194, B:94:0x0198, B:97:0x01c7, B:98:0x01d9, B:100:0x01e3, B:102:0x01e7, B:104:0x01f7, B:106:0x0209, B:118:0x0222, B:120:0x022a, B:122:0x024f, B:124:0x0253, B:127:0x0278, B:128:0x028a, B:130:0x0294, B:131:0x0299, B:31:0x0072, B:60:0x011b, B:48:0x00de, B:49:0x00ec, B:51:0x00f8, B:56:0x0103, B:78:0x0140), top: B:172:0x003b }] */
    /* JADX WARN: Type inference failed for: r2v16 */
    /* JADX WARN: Type inference failed for: r2v17 */
    /* JADX WARN: Type inference failed for: r2v18 */
    /* JADX WARN: Type inference failed for: r2v19 */
    /* JADX WARN: Type inference failed for: r2v40 */
    /* JADX WARN: Type inference failed for: r2v41 */
    /* JADX WARN: Type inference failed for: r2v42 */
    /* JADX WARN: Type inference failed for: r2v43 */
    /* JADX WARN: Type inference failed for: r2v44 */
    /* JADX WARN: Type inference failed for: r2v45 */
    /* JADX WARN: Type inference failed for: r2v46 */
    /* JADX WARN: Type inference failed for: r2v47 */
    /* JADX WARN: Type inference failed for: r2v48 */
    /* JADX WARN: Type inference failed for: r2v49 */
    /* JADX WARN: Type inference failed for: r2v5, types: [com.strmr.ps.background.TraktSyncWorker$b] */
    /* JADX WARN: Type inference failed for: r2v50 */
    /* JADX WARN: Type inference failed for: r2v51 */
    /* JADX WARN: Type inference failed for: r2v52 */
    /* JADX WARN: Type inference failed for: r2v6, types: [com.strmr.ps.background.TraktSyncWorker$b] */
    /* JADX WARN: Type inference failed for: r2v7, types: [com.strmr.ps.background.TraktSyncWorker$b] */
    /* JADX WARN: Type inference failed for: r2v8, types: [com.strmr.ps.background.TraktSyncWorker$b] */
    @Override // androidx.work.CoroutineWorker
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object f(ContinuationImpl continuationImpl) {
        n nVar;
        ?? r2;
        ?? r22;
        ?? r23;
        ?? r24;
        int iCode;
        int i;
        b bVar;
        TraktSyncWorker traktSyncWorker;
        String str;
        String str2;
        b bVar2;
        b bVar3;
        SyncResult syncResult;
        b bVar4;
        Object obj = "is_initial_sync";
        String str3 = "Trakt server error (";
        String str4 = "Trakt auth error (";
        if (continuationImpl instanceof n) {
            nVar = (n) continuationImpl;
            int i2 = nVar.e;
            if ((i2 & Integer.MIN_VALUE) != 0) {
                nVar.e = i2 - Integer.MIN_VALUE;
            } else {
                nVar = new n(this, continuationImpl);
            }
        }
        Object objSyncAllWithResult = nVar.c;
        ck1 ck1Var = ck1.a;
        int i3 = nVar.e;
        try {
            try {
                try {
                    if (i3 == 0) {
                        s38.b(objSyncAllWithResult);
                        Context context = this.a;
                        cr4.f(context, "getApplicationContext(...)");
                        b bVar5 = (b) EntryPointAccessors.fromApplication(context, b.class);
                        TraktAccountRepository traktAccountRepository = bVar5.traktAccountRepository();
                        nVar.a = this;
                        nVar.b = bVar5;
                        nVar.e = 1;
                        Object activeAccount = traktAccountRepository.getActiveAccount(nVar);
                        if (activeAccount != ck1Var) {
                            bVar = bVar5;
                            objSyncAllWithResult = activeAccount;
                            traktSyncWorker = this;
                        }
                        return ck1Var;
                    }
                    if (i3 != 1) {
                        try {
                            if (i3 == 2) {
                                b bVar6 = (b) nVar.a;
                                s38.b(objSyncAllWithResult);
                                str = "Trakt is currently unavailable. Your library may be out of date.";
                                str2 = "), will retry";
                                bVar2 = bVar6;
                                syncResult = (SyncResult) objSyncAllWithResult;
                                bVar4 = bVar2;
                                if (!(syncResult instanceof SyncResult.Success)) {
                                }
                            } else {
                                if (i3 != 3) {
                                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                                }
                                b bVar7 = (b) nVar.a;
                                s38.b(objSyncAllWithResult);
                                str = "Trakt is currently unavailable. Your library may be out of date.";
                                str2 = "), will retry";
                                bVar3 = bVar7;
                                syncResult = (SyncResult) objSyncAllWithResult;
                                bVar4 = bVar3;
                                if (!(syncResult instanceof SyncResult.Success)) {
                                    q07[] q07VarArr = {new q07("progress", Boxing.boxFloat(1.0f)), yx9.a("Sync complete!", "status")};
                                    d.a aVar = new d.a();
                                    for (int i4 = 0; i4 < 2; i4++) {
                                        q07 q07Var = q07VarArr[i4];
                                        aVar.b(q07Var.getB(), (String) q07Var.a);
                                    }
                                    return new f.a.c(aVar.a());
                                }
                                if (syncResult instanceof SyncResult.AuthError) {
                                    Log.e("TraktSyncWorker", "Trakt auth error (" + ((SyncResult.AuthError) syncResult).getCode() + "), not retrying - user needs to re-authenticate");
                                    q07[] q07VarArr2 = {yx9.a("Authentication failed - please re-link Trakt", "status"), yx9.a("auth", "error_type")};
                                    d.a aVar2 = new d.a();
                                    for (int i5 = 0; i5 < 2; i5++) {
                                        q07 q07Var2 = q07VarArr2[i5];
                                        aVar2.b(q07Var2.getB(), (String) q07Var2.getA());
                                    }
                                    return new f.a.C0067a(aVar2.a());
                                }
                                try {
                                    if (!(syncResult instanceof SyncResult.ServerError)) {
                                        String str5 = str;
                                        if (syncResult instanceof SyncResult.NetworkError) {
                                            Log.w("TraktSyncWorker", "Trakt network error, will retry: " + ((SyncResult.NetworkError) syncResult).getMessage());
                                            bVar4.traktErrorNotifier().a(TraktErrorNotifier.b.c, str5);
                                            return f.a.a();
                                        }
                                        if (!(syncResult instanceof SyncResult.Skipped)) {
                                            throw new io6();
                                        }
                                        ((SyncResult.Skipped) syncResult).getReason();
                                        q07[] q07VarArr3 = {yx9.a(Boxing.boxFloat(1.0f), "progress"), yx9.a(((SyncResult.Skipped) syncResult).getReason(), "status")};
                                        d.a aVar3 = new d.a();
                                        for (int i6 = 0; i6 < 2; i6++) {
                                            q07 q07Var3 = q07VarArr3[i6];
                                            aVar3.b(q07Var3.getB(), (String) q07Var3.getA());
                                        }
                                        return new f.a.c(aVar3.a());
                                    }
                                    int code = ((SyncResult.ServerError) syncResult).getCode();
                                    StringBuilder sb = new StringBuilder("Trakt server error (");
                                    sb.append(code);
                                    str3 = str2;
                                    try {
                                        sb.append(str3);
                                        Log.w("TraktSyncWorker", sb.toString());
                                        bVar4.traktErrorNotifier().a(TraktErrorNotifier.b.c, str);
                                        return f.a.a();
                                    } catch (HttpException e) {
                                        e = e;
                                        str4 = str;
                                        r24 = bVar4;
                                        TraktErrorNotifier traktErrorNotifier = r24.traktErrorNotifier();
                                        iCode = e.code();
                                        if (iCode != 401 || iCode == 403) {
                                            Log.e("TraktSyncWorker", "Trakt auth error (HTTP " + e.code() + "), not retrying", e);
                                            q07[] q07VarArr4 = {yx9.a("Authentication failed - please re-link Trakt", "status"), yx9.a("auth", "error_type")};
                                            d.a aVar4 = new d.a();
                                            for (i = 0; i < 2; i++) {
                                                q07 q07Var4 = q07VarArr4[i];
                                                aVar4.b(q07Var4.getB(), (String) q07Var4.getA());
                                            }
                                            return new f.a.C0067a(aVar4.a());
                                        }
                                        if (iCode == 429) {
                                            Log.w("TraktSyncWorker", "Trakt rate limited, will retry", e);
                                            return f.a.a();
                                        }
                                        if (500 > iCode || iCode >= 600) {
                                            Log.e("TraktSyncWorker", "Trakt HTTP error (" + e.code() + str3, e);
                                            traktErrorNotifier.a(TraktErrorNotifier.b.c, str4);
                                            return f.a.a();
                                        }
                                        Log.w("TraktSyncWorker", "Trakt server error (HTTP " + e.code() + str3, e);
                                        traktErrorNotifier.a(TraktErrorNotifier.b.c, str4);
                                        return f.a.a();
                                    }
                                } catch (SocketTimeoutException e2) {
                                    e = e2;
                                    r23 = bVar4;
                                    Log.w("TraktSyncWorker", "Network timeout, will retry", e);
                                    r23.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                } catch (UnknownHostException e3) {
                                    e = e3;
                                    r22 = bVar4;
                                    Log.w("TraktSyncWorker", "Network unavailable, will retry", e);
                                    r22.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                } catch (HttpException e4) {
                                    e = e4;
                                    r24 = bVar4;
                                } catch (Exception e5) {
                                    e = e5;
                                    r2 = bVar4;
                                    Log.e("TraktSyncWorker", "Trakt sync error", e);
                                    r2.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                }
                            }
                        } catch (SocketTimeoutException e6) {
                            e = e6;
                            str4 = "Trakt is currently unavailable. Your library may be out of date.";
                            r23 = obj;
                            Log.w("TraktSyncWorker", "Network timeout, will retry", e);
                            r23.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        } catch (UnknownHostException e7) {
                            e = e7;
                            str4 = "Trakt is currently unavailable. Your library may be out of date.";
                            r22 = obj;
                            Log.w("TraktSyncWorker", "Network unavailable, will retry", e);
                            r22.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        } catch (HttpException e8) {
                            e = e8;
                            str4 = "Trakt is currently unavailable. Your library may be out of date.";
                            str3 = "), will retry";
                            r24 = obj;
                            TraktErrorNotifier traktErrorNotifier2 = r24.traktErrorNotifier();
                            iCode = e.code();
                            if (iCode != 401) {
                            }
                            Log.e("TraktSyncWorker", "Trakt auth error (HTTP " + e.code() + "), not retrying", e);
                            q07[] q07VarArr42 = {yx9.a("Authentication failed - please re-link Trakt", "status"), yx9.a("auth", "error_type")};
                            d.a aVar42 = new d.a();
                            while (i < 2) {
                            }
                            return new f.a.C0067a(aVar42.a());
                        } catch (Exception e9) {
                            e = e9;
                            str4 = "Trakt is currently unavailable. Your library may be out of date.";
                            r2 = obj;
                            Log.e("TraktSyncWorker", "Trakt sync error", e);
                            r2.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        }
                    } else {
                        bVar = nVar.b;
                        traktSyncWorker = (TraktSyncWorker) nVar.a;
                        s38.b(objSyncAllWithResult);
                    }
                    if (((TraktAccount) objSyncAllWithResult) == null) {
                        return f.a.b();
                    }
                    WorkerParameters workerParameters = traktSyncWorker.b;
                    WorkerParameters workerParameters2 = traktSyncWorker.b;
                    str = "Trakt is currently unavailable. Your library may be out of date.";
                    Object obj2 = workerParameters.b.a.get("is_manual_sync");
                    str2 = "), will retry";
                    if (obj2 instanceof Boolean ? ((Boolean) obj2).booleanValue() : false) {
                        bVar.traktETagInterceptor().a();
                    }
                    try {
                        workerParameters2.b.a.get("is_initial_sync");
                        workerParameters2.b.a.get("is_manual_sync");
                        try {
                            Object obj3 = workerParameters2.b.a.get("is_initial_sync");
                            if (obj3 instanceof Boolean ? ((Boolean) obj3).booleanValue() : false) {
                                try {
                                    TraktSyncRepository traktSyncRepository = bVar.traktSyncRepository();
                                    o oVar = new o(traktSyncWorker, null);
                                    nVar.a = bVar;
                                    nVar.b = null;
                                    nVar.e = 2;
                                    objSyncAllWithResult = traktSyncRepository.syncAllWithResult(oVar, nVar);
                                    if (objSyncAllWithResult != ck1Var) {
                                        bVar2 = bVar;
                                        syncResult = (SyncResult) objSyncAllWithResult;
                                        bVar4 = bVar2;
                                        if (!(syncResult instanceof SyncResult.Success)) {
                                        }
                                    }
                                } catch (SocketTimeoutException e10) {
                                    e = e10;
                                    obj = bVar;
                                    str4 = str;
                                    r23 = obj;
                                    Log.w("TraktSyncWorker", "Network timeout, will retry", e);
                                    r23.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                } catch (UnknownHostException e11) {
                                    e = e11;
                                    obj = bVar;
                                    str4 = str;
                                    r22 = obj;
                                    Log.w("TraktSyncWorker", "Network unavailable, will retry", e);
                                    r22.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                } catch (HttpException e12) {
                                    e = e12;
                                    obj = bVar;
                                    str4 = str;
                                    str3 = str2;
                                    r24 = obj;
                                    TraktErrorNotifier traktErrorNotifier22 = r24.traktErrorNotifier();
                                    iCode = e.code();
                                    if (iCode != 401) {
                                    }
                                    Log.e("TraktSyncWorker", "Trakt auth error (HTTP " + e.code() + "), not retrying", e);
                                    q07[] q07VarArr422 = {yx9.a("Authentication failed - please re-link Trakt", "status"), yx9.a("auth", "error_type")};
                                    d.a aVar422 = new d.a();
                                    while (i < 2) {
                                    }
                                    return new f.a.C0067a(aVar422.a());
                                } catch (Exception e13) {
                                    e = e13;
                                    obj = bVar;
                                    str4 = str;
                                    r2 = obj;
                                    Log.e("TraktSyncWorker", "Trakt sync error", e);
                                    r2.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                                    return f.a.a();
                                }
                            } else {
                                TraktSyncRepository traktSyncRepository2 = bVar.traktSyncRepository();
                                nVar.a = bVar;
                                nVar.b = null;
                                nVar.e = 3;
                                objSyncAllWithResult = TraktSyncRepository.syncAllWithResult$default(traktSyncRepository2, null, nVar, 1, null);
                                if (objSyncAllWithResult != ck1Var) {
                                    bVar3 = bVar;
                                    syncResult = (SyncResult) objSyncAllWithResult;
                                    bVar4 = bVar3;
                                    if (!(syncResult instanceof SyncResult.Success)) {
                                    }
                                }
                            }
                            return ck1Var;
                        } catch (SocketTimeoutException e14) {
                            e = e14;
                            str4 = str;
                            r23 = bVar;
                            Log.w("TraktSyncWorker", "Network timeout, will retry", e);
                            r23.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        } catch (UnknownHostException e15) {
                            e = e15;
                            str4 = str;
                            r22 = bVar;
                            Log.w("TraktSyncWorker", "Network unavailable, will retry", e);
                            r22.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        } catch (HttpException e16) {
                            e = e16;
                            str4 = str;
                            str3 = str2;
                            r24 = bVar;
                            TraktErrorNotifier traktErrorNotifier222 = r24.traktErrorNotifier();
                            iCode = e.code();
                            if (iCode != 401) {
                            }
                            Log.e("TraktSyncWorker", "Trakt auth error (HTTP " + e.code() + "), not retrying", e);
                            q07[] q07VarArr4222 = {yx9.a("Authentication failed - please re-link Trakt", "status"), yx9.a("auth", "error_type")};
                            d.a aVar4222 = new d.a();
                            while (i < 2) {
                            }
                            return new f.a.C0067a(aVar4222.a());
                        } catch (Exception e17) {
                            e = e17;
                            str4 = str;
                            r2 = bVar;
                            Log.e("TraktSyncWorker", "Trakt sync error", e);
                            r2.traktErrorNotifier().a(TraktErrorNotifier.b.c, str4);
                            return f.a.a();
                        }
                    } catch (SocketTimeoutException e18) {
                        e = e18;
                    } catch (UnknownHostException e19) {
                        e = e19;
                    } catch (HttpException e20) {
                        e = e20;
                    } catch (Exception e21) {
                        e = e21;
                    }
                } catch (CancellationException e22) {
                    Log.w("TraktSyncWorker", "Trakt sync cancelled", e22);
                    throw e22;
                }
            } catch (HttpException e23) {
                e = e23;
            }
        } catch (SocketTimeoutException e24) {
            e = e24;
        } catch (UnknownHostException e25) {
            e = e25;
        } catch (Exception e26) {
            e = e26;
        }
    }
}