package com.strmr.ps.data.repository;

import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import com.strmr.ps.data.local.entity.TraktAccount;
import com.strmr.ps.data.model.trakt.TraktLastActivities;
import com.strmr.ps.data.remote.api.TraktApiService;
import defpackage.ck1;
import defpackage.cr4;
import defpackage.kp6;
import defpackage.mg6;
import defpackage.pq6;
import defpackage.rg6;
import defpackage.s38;
import defpackage.vx8;
import java.util.concurrent.CancellationException;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.jvm.internal.ContinuationImpl;
import kotlin.coroutines.jvm.internal.DebugMetadata;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u00006\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0007\u0018\u0000 \u00182\u00020\u0001:\u0001\u0018B\u0019\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J\u0012\u0010\t\u001a\u0004\u0018\u00010\bH\u0086@¢\u0006\u0004\b\t\u0010\nJ\r\u0010\f\u001a\u00020\u000b¢\u0006\u0004\b\f\u0010\rR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010\u000eR\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010\u000fR\u0018\u0010\u0010\u001a\u0004\u0018\u00010\b8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0010\u0010\u0011R\u0016\u0010\u0013\u001a\u00020\u00128\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b\u0013\u0010\u0014R\u0014\u0010\u0016\u001a\u00020\u00158\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0016\u0010\u0017¨\u0006\u0019"}, d2 = {"Lcom/strmr/ps/data/repository/TraktActivitiesCache;", "", "Lcom/strmr/ps/data/remote/api/TraktApiService;", "traktApiService", "Lcom/strmr/ps/data/repository/TraktAccountRepository;", "accountRepository", "<init>", "(Lcom/strmr/ps/data/remote/api/TraktApiService;Lcom/strmr/ps/data/repository/TraktAccountRepository;)V", "Lcom/strmr/ps/data/model/trakt/TraktLastActivities;", "getActivities", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Le6a;", "invalidate", "()V", "Lcom/strmr/ps/data/remote/api/TraktApiService;", "Lcom/strmr/ps/data/repository/TraktAccountRepository;", "cached", "Lcom/strmr/ps/data/model/trakt/TraktLastActivities;", "", "cachedAtMs", "J", "Lmg6;", "mutex", "Lmg6;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class TraktActivitiesCache {
    private static final long CACHE_TTL_MS = 60000;

    @kp6
    private static final String TAG = "TraktActivitiesCache";

    @kp6
    private final TraktAccountRepository accountRepository;

    @pq6
    private volatile TraktLastActivities cached;
    private volatile long cachedAtMs;

    @kp6
    private final mg6 mutex;

    @kp6
    private final TraktApiService traktApiService;

    /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktActivitiesCache$getActivities$1, reason: invalid class name */
    @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @DebugMetadata(c = "com.strmr.ps.data.repository.TraktActivitiesCache", f = "TraktActivitiesCache.kt", i = {0, 0, 1, 1, 2, 2}, l = {76, NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED, 51}, m = "getActivities", n = {"this", "$this$withLock_u24default$iv", "this", "$this$withLock_u24default$iv", "this", "$this$withLock_u24default$iv"}, s = {"L$0", "L$1", "L$0", "L$1", "L$0", "L$1"})
    public static final class AnonymousClass1 extends ContinuationImpl {
        Object L$0;
        Object L$1;
        int label;
        /* synthetic */ Object result;

        public AnonymousClass1(Continuation<? super AnonymousClass1> continuation) {
            super(continuation);
        }

        @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl
        @pq6
        public final Object invokeSuspend(@kp6 Object obj) {
            this.result = obj;
            this.label |= Integer.MIN_VALUE;
            return TraktActivitiesCache.this.getActivities(this);
        }
    }

    @Inject
    public TraktActivitiesCache(@kp6 TraktApiService traktApiService, @kp6 TraktAccountRepository traktAccountRepository) {
        cr4.g(traktApiService, "traktApiService");
        cr4.g(traktAccountRepository, "accountRepository");
        this.traktApiService = traktApiService;
        this.accountRepository = traktAccountRepository;
        this.mutex = rg6.a();
    }

    /* JADX WARN: Multi-variable type inference failed */
    /* JADX WARN: Removed duplicated region for block: B:52:0x00bb  */
    /* JADX WARN: Removed duplicated region for block: B:53:0x00be A[Catch: all -> 0x005a, TRY_LEAVE, TryCatch #4 {all -> 0x005a, blocks: (B:25:0x0055, B:50:0x00b7, B:53:0x00be, B:54:0x00c8), top: B:72:0x0055 }] */
    /* JADX WARN: Removed duplicated region for block: B:7:0x0015  */
    /* JADX WARN: Type inference failed for: r2v0, types: [ck1, java.lang.Object] */
    /* JADX WARN: Type inference failed for: r2v1, types: [mg6] */
    /* JADX WARN: Type inference failed for: r2v2 */
    /* JADX WARN: Type inference failed for: r2v3 */
    @pq6
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object getActivities(@kp6 Continuation<? super TraktLastActivities> continuation) {
        AnonymousClass1 anonymousClass1;
        mg6 mg6Var;
        TraktActivitiesCache traktActivitiesCache;
        TraktLastActivities traktLastActivities;
        mg6 mg6Var2;
        TraktActivitiesCache traktActivitiesCache2;
        TraktAccount traktAccount;
        mg6 mg6Var3;
        TraktActivitiesCache traktActivitiesCache3;
        if (continuation instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) continuation;
            int i = anonymousClass1.label;
            if ((i & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i - Integer.MIN_VALUE;
            } else {
                anonymousClass1 = new AnonymousClass1(continuation);
            }
        }
        Object lastActivities = anonymousClass1.result;
        ?? r2 = ck1.a;
        int i2 = anonymousClass1.label;
        try {
        } catch (Throwable th) {
            th = th;
        }
        try {
            if (i2 == 0) {
                s38.b(lastActivities);
                long jCurrentTimeMillis = System.currentTimeMillis();
                TraktLastActivities traktLastActivities2 = this.cached;
                if (traktLastActivities2 != null && jCurrentTimeMillis - this.cachedAtMs < 60000) {
                    return traktLastActivities2;
                }
                mg6Var = this.mutex;
                anonymousClass1.L$0 = this;
                anonymousClass1.L$1 = mg6Var;
                anonymousClass1.label = 1;
                if (mg6Var.a(anonymousClass1) != r2) {
                    traktActivitiesCache = this;
                }
                return r2;
            }
            if (i2 != 1) {
                if (i2 != 2) {
                    if (i2 != 3) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    mg6Var3 = (mg6) anonymousClass1.L$1;
                    traktActivitiesCache3 = (TraktActivitiesCache) anonymousClass1.L$0;
                    try {
                        s38.b(lastActivities);
                        TraktLastActivities traktLastActivities3 = (TraktLastActivities) lastActivities;
                        traktActivitiesCache3.cached = traktLastActivities3;
                        traktActivitiesCache3.cachedAtMs = System.currentTimeMillis();
                        traktLastActivities = traktLastActivities3;
                    } catch (CancellationException e) {
                        throw e;
                    } catch (Exception e2) {
                        e = e2;
                        Log.w(TAG, "Failed to fetch activities: " + e.getMessage());
                        traktLastActivities = null;
                    }
                    mg6Var = mg6Var3;
                    mg6Var.c(null);
                    return traktLastActivities;
                }
                mg6Var2 = (mg6) anonymousClass1.L$1;
                traktActivitiesCache2 = (TraktActivitiesCache) anonymousClass1.L$0;
                try {
                    s38.b(lastActivities);
                    traktAccount = (TraktAccount) lastActivities;
                    if (traktAccount != null) {
                        mg6Var = mg6Var2;
                        traktLastActivities = null;
                        mg6Var.c(null);
                        return traktLastActivities;
                    }
                    String strBuildAuthHeader = traktActivitiesCache2.accountRepository.buildAuthHeader(traktAccount.getAccessToken());
                    try {
                        TraktApiService traktApiService = traktActivitiesCache2.traktApiService;
                        anonymousClass1.L$0 = traktActivitiesCache2;
                        anonymousClass1.L$1 = mg6Var2;
                        anonymousClass1.label = 3;
                        lastActivities = traktApiService.getLastActivities(strBuildAuthHeader, anonymousClass1);
                    } catch (CancellationException e3) {
                        throw e3;
                    } catch (Exception e4) {
                        e = e4;
                        mg6Var3 = mg6Var2;
                        Log.w(TAG, "Failed to fetch activities: " + e.getMessage());
                        traktLastActivities = null;
                    }
                    if (lastActivities != r2) {
                        mg6Var3 = mg6Var2;
                        traktActivitiesCache3 = traktActivitiesCache2;
                        TraktLastActivities traktLastActivities32 = (TraktLastActivities) lastActivities;
                        traktActivitiesCache3.cached = traktLastActivities32;
                        traktActivitiesCache3.cachedAtMs = System.currentTimeMillis();
                        traktLastActivities = traktLastActivities32;
                        mg6Var = mg6Var3;
                        mg6Var.c(null);
                        return traktLastActivities;
                    }
                    return r2;
                } catch (Throwable th2) {
                    th = th2;
                    r2 = mg6Var2;
                    r2.c(null);
                    throw th;
                }
            }
            mg6 mg6Var4 = (mg6) anonymousClass1.L$1;
            traktActivitiesCache = (TraktActivitiesCache) anonymousClass1.L$0;
            s38.b(lastActivities);
            mg6Var = mg6Var4;
            traktLastActivities = traktActivitiesCache.cached;
            if (traktLastActivities != null && System.currentTimeMillis() - traktActivitiesCache.cachedAtMs < 60000) {
                mg6Var.c(null);
                return traktLastActivities;
            }
            TraktAccountRepository traktAccountRepository = traktActivitiesCache.accountRepository;
            anonymousClass1.L$0 = traktActivitiesCache;
            anonymousClass1.L$1 = mg6Var;
            anonymousClass1.label = 2;
            Object objRefreshTokenIfNeeded = traktAccountRepository.refreshTokenIfNeeded(anonymousClass1);
            if (objRefreshTokenIfNeeded != r2) {
                mg6Var2 = mg6Var;
                lastActivities = objRefreshTokenIfNeeded;
                traktActivitiesCache2 = traktActivitiesCache;
                traktAccount = (TraktAccount) lastActivities;
                if (traktAccount != null) {
                }
            }
            return r2;
        } catch (Throwable th3) {
            r2 = mg6Var;
            th = th3;
            r2.c(null);
            throw th;
        }
    }

    public final void invalidate() {
        this.cachedAtMs = 0L;
        this.cached = null;
    }
}