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.f;
import com.strmr.ps.data.event.TraktErrorNotifier;
import com.strmr.ps.data.local.entity.PendingTraktAction;
import com.strmr.ps.data.repository.TraktOfflineQueueRepository;
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.h32;
import defpackage.io6;
import defpackage.kp6;
import defpackage.s38;
import defpackage.vx8;
import java.util.Iterator;
import java.util.List;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.Boxing;
import kotlin.coroutines.jvm.internal.ContinuationImpl;

/* 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/TraktOfflineQueueWorker;", "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)
public final class TraktOfflineQueueWorker extends CoroutineWorker {

    @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0003\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\u0007\u001a\u00020\u00068\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0007\u0010\b¨\u0006\t"}, d2 = {"Lcom/strmr/ps/background/TraktOfflineQueueWorker$a;", "", "", "TAG", "Ljava/lang/String;", "WORK_NAME", "", "DELAY_BETWEEN_ACTIONS_MS", "J", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public static final class 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/TraktOfflineQueueWorker$b;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @InstallIn({SingletonComponent.class})
    @EntryPoint
    public interface b {
        TraktErrorNotifier traktErrorNotifier();

        TraktOfflineQueueRepository traktOfflineQueueRepository();

        TraktSyncRepository traktSyncRepository();
    }

    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public /* synthetic */ class c {
        public static final /* synthetic */ int[] a;

        static {
            int[] iArr = new int[PendingTraktAction.ActionType.values().length];
            try {
                iArr[PendingTraktAction.ActionType.MARK_MOVIE_WATCHED.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_MOVIE_UNWATCHED.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_SHOW_WATCHED.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_SHOW_UNWATCHED.ordinal()] = 4;
            } catch (NoSuchFieldError unused4) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_SEASON_WATCHED.ordinal()] = 5;
            } catch (NoSuchFieldError unused5) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_EPISODE_WATCHED.ordinal()] = 6;
            } catch (NoSuchFieldError unused6) {
            }
            try {
                iArr[PendingTraktAction.ActionType.MARK_EPISODE_UNWATCHED.ordinal()] = 7;
            } catch (NoSuchFieldError unused7) {
            }
            try {
                iArr[PendingTraktAction.ActionType.ADD_TO_COLLECTION.ordinal()] = 8;
            } catch (NoSuchFieldError unused8) {
            }
            try {
                iArr[PendingTraktAction.ActionType.REMOVE_FROM_COLLECTION.ordinal()] = 9;
            } catch (NoSuchFieldError unused9) {
            }
            try {
                iArr[PendingTraktAction.ActionType.ADD_TO_WATCHLIST.ordinal()] = 10;
            } catch (NoSuchFieldError unused10) {
            }
            try {
                iArr[PendingTraktAction.ActionType.REMOVE_FROM_WATCHLIST.ordinal()] = 11;
            } catch (NoSuchFieldError unused11) {
            }
            try {
                iArr[PendingTraktAction.ActionType.ADD_RATING.ordinal()] = 12;
            } catch (NoSuchFieldError unused12) {
            }
            try {
                iArr[PendingTraktAction.ActionType.REMOVE_RATING.ordinal()] = 13;
            } catch (NoSuchFieldError unused13) {
            }
            a = iArr;
        }
    }

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

    public static Object g(PendingTraktAction pendingTraktAction, TraktSyncRepository traktSyncRepository, Continuation continuation) {
        boolean zB = cr4.b(pendingTraktAction.getContentType(), "MOVIE");
        switch (c.a[pendingTraktAction.getActionType().ordinal()]) {
            case 1:
                return traktSyncRepository.markMovieWatched(pendingTraktAction.getTmdbId(), continuation);
            case 2:
                return traktSyncRepository.markMovieUnwatched(pendingTraktAction.getTmdbId(), continuation);
            case 3:
                return traktSyncRepository.markShowWatched(pendingTraktAction.getTmdbId(), continuation);
            case 4:
                return traktSyncRepository.markShowUnwatched(pendingTraktAction.getTmdbId(), continuation);
            case 5:
                Integer season = pendingTraktAction.getSeason();
                if (season == null) {
                    return Boxing.boxBoolean(false);
                }
                return traktSyncRepository.markSeasonWatched(pendingTraktAction.getTmdbId(), season.intValue(), continuation);
            case 6:
                Integer season2 = pendingTraktAction.getSeason();
                if (season2 == null) {
                    return Boxing.boxBoolean(false);
                }
                int iIntValue = season2.intValue();
                Integer episode = pendingTraktAction.getEpisode();
                if (episode == null) {
                    return Boxing.boxBoolean(false);
                }
                return traktSyncRepository.markEpisodeWatched(pendingTraktAction.getTmdbId(), iIntValue, episode.intValue(), continuation);
            case 7:
                Integer season3 = pendingTraktAction.getSeason();
                if (season3 == null) {
                    return Boxing.boxBoolean(false);
                }
                int iIntValue2 = season3.intValue();
                Integer episode2 = pendingTraktAction.getEpisode();
                if (episode2 == null) {
                    return Boxing.boxBoolean(false);
                }
                return traktSyncRepository.markEpisodeUnwatched(pendingTraktAction.getTmdbId(), iIntValue2, episode2.intValue(), continuation);
            case 8:
                return traktSyncRepository.addToCollection(pendingTraktAction.getTmdbId(), zB, continuation);
            case 9:
                return traktSyncRepository.removeFromCollection(pendingTraktAction.getTmdbId(), zB, continuation);
            case 10:
                return traktSyncRepository.addToWatchlist(pendingTraktAction.getTmdbId(), zB, continuation);
            case 11:
                return traktSyncRepository.removeFromWatchlist(pendingTraktAction.getTmdbId(), zB, continuation);
            case 12:
                Integer rating = pendingTraktAction.getRating();
                if (rating == null) {
                    return Boxing.boxBoolean(false);
                }
                return traktSyncRepository.addRating(pendingTraktAction.getTmdbId(), zB, rating.intValue(), continuation);
            case 13:
                return traktSyncRepository.removeRating(pendingTraktAction.getTmdbId(), zB, continuation);
            default:
                throw new io6();
        }
    }

    /* JADX WARN: Can't wrap try/catch for region: R(4:57|58|81|59) */
    /* JADX WARN: Code restructure failed: missing block: B:39:0x0115, code lost:
    
        if (r0 == r3) goto L74;
     */
    /* JADX WARN: Code restructure failed: missing block: B:60:0x01bd, code lost:
    
        if (r11.markFailed(r14, "Action returned false", r2) == r3) goto L74;
     */
    /* JADX WARN: Code restructure failed: missing block: B:64:0x01c7, code lost:
    
        r0 = e;
     */
    /* JADX WARN: Code restructure failed: missing block: B:66:0x020b, code lost:
    
        if (r11.markFailed(r5, r0, r2) == r3) goto L74;
     */
    /* JADX WARN: Code restructure failed: missing block: B:73:0x0239, code lost:
    
        if (r11.cleanupFailedActions(r0) == r3) goto L74;
     */
    /* JADX WARN: Removed duplicated region for block: B:36:0x0101  */
    /* JADX WARN: Removed duplicated region for block: B:38:0x0106  */
    /* JADX WARN: Removed duplicated region for block: B:44:0x0131  */
    /* JADX WARN: Removed duplicated region for block: B:50:0x0173  */
    /* JADX WARN: Removed duplicated region for block: B:51:0x0175 A[Catch: Exception -> 0x0068, PHI: r0 r2 r4 r5 r7 r8 r9 r10 r11 r12 r13
      0x0175: PHI (r0v8 java.lang.Object) = (r0v17 java.lang.Object), (r0v1 java.lang.Object) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r2v9 com.strmr.ps.background.m) = (r2v10 com.strmr.ps.background.m), (r2v2 com.strmr.ps.background.m) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r4v5 int) = (r4v6 int), (r4v21 int) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r5v6 int) = (r5v8 int), (r5v0 int) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r7v5 int) = (r7v6 int), (r7v18 int) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r8v2 com.strmr.ps.data.local.entity.PendingTraktAction) = (r8v3 com.strmr.ps.data.local.entity.PendingTraktAction), (r8v14 com.strmr.ps.data.local.entity.PendingTraktAction) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r9v4 java.util.Iterator) = (r9v5 java.util.Iterator), (r9v18 java.util.Iterator) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r10v4 com.strmr.ps.data.repository.TraktSyncRepository) = (r10v5 com.strmr.ps.data.repository.TraktSyncRepository), (r10v12 com.strmr.ps.data.repository.TraktSyncRepository) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r11v4 com.strmr.ps.data.repository.TraktOfflineQueueRepository) = 
      (r11v5 com.strmr.ps.data.repository.TraktOfflineQueueRepository)
      (r11v11 com.strmr.ps.data.repository.TraktOfflineQueueRepository)
     binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r12v4 com.strmr.ps.background.TraktOfflineQueueWorker$b) = (r12v5 com.strmr.ps.background.TraktOfflineQueueWorker$b), (r12v11 com.strmr.ps.background.TraktOfflineQueueWorker$b) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE]
      0x0175: PHI (r13v4 com.strmr.ps.background.TraktOfflineQueueWorker) = (r13v5 com.strmr.ps.background.TraktOfflineQueueWorker), (r13v11 com.strmr.ps.background.TraktOfflineQueueWorker) binds: [B:49:0x0171, B:25:0x0094] A[DONT_GENERATE, DONT_INLINE], TryCatch #0 {Exception -> 0x0068, blocks: (B:48:0x0157, B:51:0x0175, B:53:0x017d, B:56:0x019c, B:57:0x019e, B:16:0x0060, B:22:0x007d, B:25:0x0094), top: B:79:0x0023 }] */
    /* JADX WARN: Removed duplicated region for block: B:53:0x017d A[Catch: Exception -> 0x0068, TryCatch #0 {Exception -> 0x0068, blocks: (B:48:0x0157, B:51:0x0175, B:53:0x017d, B:56:0x019c, B:57:0x019e, B:16:0x0060, B:22:0x007d, B:25:0x0094), top: B:79:0x0023 }] */
    /* JADX WARN: Removed duplicated region for block: B:57:0x019e A[Catch: Exception -> 0x0068, TRY_LEAVE, TryCatch #0 {Exception -> 0x0068, blocks: (B:48:0x0157, B:51:0x0175, B:53:0x017d, B:56:0x019c, B:57:0x019e, B:16:0x0060, B:22:0x007d, B:25:0x0094), top: B:79:0x0023 }] */
    /* JADX WARN: Removed duplicated region for block: B:69:0x0213  */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0017  */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:56:0x019c -> B:42:0x012b). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:62:0x01c1 -> B:63:0x01c3). Please report as a decompilation issue!!! */
    /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:66:0x020b -> B:14:0x004d). Please report as a decompilation issue!!! */
    @Override // androidx.work.CoroutineWorker
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object f(ContinuationImpl continuationImpl) {
        m mVar;
        int i;
        TraktOfflineQueueWorker traktOfflineQueueWorker;
        b bVar;
        TraktOfflineQueueRepository traktOfflineQueueRepository;
        TraktSyncRepository traktSyncRepository;
        Iterator it;
        PendingTraktAction pendingTraktAction;
        int i2;
        m mVar2;
        int i3;
        b bVar2;
        TraktOfflineQueueRepository traktOfflineQueueRepository2;
        TraktSyncRepository traktSyncRepository2;
        TraktOfflineQueueWorker traktOfflineQueueWorker2;
        if (continuationImpl instanceof m) {
            mVar = (m) continuationImpl;
            int i4 = mVar.m;
            if ((i4 & Integer.MIN_VALUE) != 0) {
                mVar.m = i4 - Integer.MIN_VALUE;
            } else {
                mVar = new m(this, continuationImpl);
            }
        }
        Object objG = mVar.k;
        ck1 ck1Var = ck1.a;
        int i5 = mVar.m;
        int i6 = 1;
        try {
        } catch (Exception e) {
            e = e;
            i = i6;
            Log.e("TraktOfflineQueueWorker", "Error processing action " + pendingTraktAction.getId() + ": " + pendingTraktAction.getActionType(), e);
            long id = pendingTraktAction.getId();
            String message = e.getMessage();
            mVar.a = traktOfflineQueueWorker;
            mVar.b = bVar;
            mVar.c = traktOfflineQueueRepository;
            mVar.d = traktSyncRepository;
            mVar.e = it;
            mVar.f = null;
            mVar.i = i2;
            mVar.j = i5;
            mVar.m = 7;
        }
        switch (i5) {
            case 0:
                s38.b(objG);
                Context context = this.a;
                cr4.f(context, "getApplicationContext(...)");
                b bVar3 = (b) EntryPointAccessors.fromApplication(context, b.class);
                TraktOfflineQueueRepository traktOfflineQueueRepository3 = bVar3.traktOfflineQueueRepository();
                TraktSyncRepository traktSyncRepository3 = bVar3.traktSyncRepository();
                mVar.a = this;
                mVar.b = bVar3;
                mVar.c = traktOfflineQueueRepository3;
                mVar.d = traktSyncRepository3;
                mVar.m = 1;
                Object objHasPendingActions = traktOfflineQueueRepository3.hasPendingActions(mVar);
                if (objHasPendingActions != ck1Var) {
                    bVar2 = bVar3;
                    objG = objHasPendingActions;
                    traktOfflineQueueRepository2 = traktOfflineQueueRepository3;
                    traktSyncRepository2 = traktSyncRepository3;
                    traktOfflineQueueWorker2 = this;
                    if (((Boolean) objG).booleanValue()) {
                        return f.a.b();
                    }
                    mVar.a = traktOfflineQueueWorker2;
                    mVar.b = bVar2;
                    mVar.c = traktOfflineQueueRepository2;
                    mVar.d = traktSyncRepository2;
                    mVar.m = 2;
                    objG = traktOfflineQueueRepository2.getPendingActions(mVar);
                    break;
                }
                return ck1Var;
            case 1:
                traktSyncRepository2 = mVar.d;
                traktOfflineQueueRepository2 = mVar.c;
                bVar2 = mVar.b;
                traktOfflineQueueWorker2 = mVar.a;
                s38.b(objG);
                if (((Boolean) objG).booleanValue()) {
                }
                break;
            case 2:
                traktSyncRepository2 = mVar.d;
                traktOfflineQueueRepository2 = mVar.c;
                bVar2 = mVar.b;
                traktOfflineQueueWorker2 = mVar.a;
                s38.b(objG);
                List list = (List) objG;
                list.size();
                traktOfflineQueueRepository = traktOfflineQueueRepository2;
                bVar = bVar2;
                traktOfflineQueueWorker = traktOfflineQueueWorker2;
                i2 = 0;
                it = list.iterator();
                mVar2 = mVar;
                traktSyncRepository = traktSyncRepository2;
                i3 = 0;
                if (it.hasNext()) {
                    PendingTraktAction pendingTraktAction2 = (PendingTraktAction) it.next();
                    mVar2.a = traktOfflineQueueWorker;
                    mVar2.b = bVar;
                    mVar2.c = traktOfflineQueueRepository;
                    mVar2.d = traktSyncRepository;
                    mVar2.e = it;
                    mVar2.f = pendingTraktAction2;
                    mVar2.i = i2;
                    mVar2.j = i3;
                    mVar2.m = 3;
                    if (h32.a(500L, mVar2) != ck1Var) {
                        pendingTraktAction = pendingTraktAction2;
                        i5 = i3;
                        mVar = mVar2;
                        mVar.a = traktOfflineQueueWorker;
                        mVar.b = bVar;
                        mVar.c = traktOfflineQueueRepository;
                        mVar.d = traktSyncRepository;
                        mVar.e = it;
                        mVar.f = pendingTraktAction;
                        mVar.i = i2;
                        mVar.j = i5;
                        mVar.m = 4;
                        traktOfflineQueueWorker.getClass();
                        objG = g(pendingTraktAction, traktSyncRepository, mVar);
                        if (objG == ck1Var) {
                            if (((Boolean) objG).booleanValue()) {
                                long id2 = pendingTraktAction.getId();
                                mVar.a = traktOfflineQueueWorker;
                                mVar.b = bVar;
                                mVar.c = traktOfflineQueueRepository;
                                mVar.d = traktSyncRepository;
                                mVar.e = it;
                                mVar.f = pendingTraktAction;
                                mVar.i = i2;
                                mVar.j = i5;
                                i = i6;
                                mVar.m = 6;
                                break;
                            } else {
                                long id3 = pendingTraktAction.getId();
                                mVar.a = traktOfflineQueueWorker;
                                mVar.b = bVar;
                                mVar.c = traktOfflineQueueRepository;
                                mVar.d = traktSyncRepository;
                                mVar.e = it;
                                mVar.f = pendingTraktAction;
                                mVar.i = i2;
                                mVar.j = i5;
                                mVar.m = 5;
                                if (traktOfflineQueueRepository.markCompleted(id3, mVar) == ck1Var) {
                                }
                                mVar2 = mVar;
                                i3 = i5;
                                i2 += i6;
                                if (it.hasNext()) {
                                    if (i3 > 0 && i2 == 0) {
                                        bVar.traktErrorNotifier().a(TraktErrorNotifier.b.b, "Trakt is unavailable. Queued actions will retry later.");
                                    }
                                    mVar2.a = null;
                                    mVar2.b = null;
                                    mVar2.c = null;
                                    mVar2.d = null;
                                    mVar2.e = null;
                                    mVar2.f = null;
                                    mVar2.i = i3;
                                    mVar2.m = 8;
                                    break;
                                }
                            }
                        }
                    }
                }
                return ck1Var;
            case 3:
                i5 = mVar.j;
                i2 = mVar.i;
                pendingTraktAction = mVar.f;
                it = mVar.e;
                traktSyncRepository = mVar.d;
                traktOfflineQueueRepository = mVar.c;
                bVar = mVar.b;
                traktOfflineQueueWorker = mVar.a;
                s38.b(objG);
                mVar.a = traktOfflineQueueWorker;
                mVar.b = bVar;
                mVar.c = traktOfflineQueueRepository;
                mVar.d = traktSyncRepository;
                mVar.e = it;
                mVar.f = pendingTraktAction;
                mVar.i = i2;
                mVar.j = i5;
                mVar.m = 4;
                traktOfflineQueueWorker.getClass();
                objG = g(pendingTraktAction, traktSyncRepository, mVar);
                if (objG == ck1Var) {
                }
                return ck1Var;
            case 4:
                i5 = mVar.j;
                i2 = mVar.i;
                pendingTraktAction = mVar.f;
                it = mVar.e;
                traktSyncRepository = mVar.d;
                traktOfflineQueueRepository = mVar.c;
                bVar = mVar.b;
                traktOfflineQueueWorker = mVar.a;
                s38.b(objG);
                if (((Boolean) objG).booleanValue()) {
                }
                return ck1Var;
            case 5:
                i5 = mVar.j;
                i2 = mVar.i;
                PendingTraktAction pendingTraktAction3 = mVar.f;
                it = mVar.e;
                traktSyncRepository = mVar.d;
                traktOfflineQueueRepository = mVar.c;
                bVar = mVar.b;
                traktOfflineQueueWorker = mVar.a;
                s38.b(objG);
                mVar2 = mVar;
                i3 = i5;
                i2 += i6;
                if (it.hasNext()) {
                }
                return ck1Var;
            case 6:
                i5 = mVar.j;
                i2 = mVar.i;
                PendingTraktAction pendingTraktAction4 = mVar.f;
                it = mVar.e;
                traktSyncRepository = mVar.d;
                traktOfflineQueueRepository = mVar.c;
                bVar = mVar.b;
                traktOfflineQueueWorker = mVar.a;
                s38.b(objG);
                i = 1;
                mVar2 = mVar;
                i3 = i5 + 1;
                i6 = i;
                if (it.hasNext()) {
                }
                return ck1Var;
            case 7:
                i5 = mVar.j;
                i2 = mVar.i;
                Iterator it2 = mVar.e;
                TraktSyncRepository traktSyncRepository4 = mVar.d;
                TraktOfflineQueueRepository traktOfflineQueueRepository4 = mVar.c;
                b bVar4 = mVar.b;
                TraktOfflineQueueWorker traktOfflineQueueWorker3 = mVar.a;
                s38.b(objG);
                i = 1;
                traktOfflineQueueWorker = traktOfflineQueueWorker3;
                bVar = bVar4;
                traktOfflineQueueRepository = traktOfflineQueueRepository4;
                traktSyncRepository = traktSyncRepository4;
                it = it2;
                mVar2 = mVar;
                i3 = i5 + 1;
                i6 = i;
                if (it.hasNext()) {
                }
                return ck1Var;
            case 8:
                i3 = mVar.i;
                s38.b(objG);
                return i3 == 0 ? f.a.b() : new f.a.b();
            default:
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
        }
    }
}