package com.strmr.ps.data.repository; import android.util.Log; import androidx.media3.container.NalUnitUtil; import com.strmr.ps.data.event.PlaybackStateManager; import com.strmr.ps.data.local.dao.EpisodeWatchStatusDao; import com.strmr.ps.data.local.entity.EpisodeWatchStatus; import com.strmr.ps.data.local.entity.PlaybackProgress; import com.strmr.ps.data.model.ContentItem; import com.strmr.ps.data.model.trakt.TraktScrobbleEpisode; import com.strmr.ps.data.model.trakt.TraktScrobbleIds; import com.strmr.ps.data.model.trakt.TraktScrobbleMovie; import com.strmr.ps.data.model.trakt.TraktScrobbleRequest; import com.strmr.ps.data.model.trakt.TraktScrobbleShow; import com.strmr.ps.data.remote.api.TraktApiService; import dagger.Lazy; import defpackage.ck1; import defpackage.cr4; import defpackage.e6a; import defpackage.fi7; import defpackage.kp6; import defpackage.kq; import defpackage.m02; import defpackage.m12; import defpackage.n41; import defpackage.n89; import defpackage.pq6; import defpackage.q38; import defpackage.s38; import defpackage.sc2; import defpackage.wj0; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutorService; import javax.inject.Inject; import javax.inject.Singleton; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.Boxing; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import okhttp3.ResponseBody; import retrofit2.HttpException; import retrofit2.Response; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u0000~\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\u000b\n\u0002\b\t\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\n\n\u0002\u0010\u0006\n\u0002\b\u001c\b\u0007\u0018\u0000 T2\u00020\u0001:\u0001TBU\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\u0006\u0010\u0007\u001a\u00020\u0006\u0012\u0006\u0010\t\u001a\u00020\b\u0012\f\u0010\f\u001a\b\u0012\u0004\u0012\u00020\u000b0\n\u0012\f\u0010\u000e\u001a\b\u0012\u0004\u0012\u00020\r0\n\u0012\u0006\u0010\u0010\u001a\u00020\u000f\u0012\u0006\u0010\u0012\u001a\u00020\u0011¢\u0006\u0004\b\u0013\u0010\u0014J6\u0010\u001e\u001a\b\u0012\u0004\u0012\u00020\u001b0\u001a2\u0006\u0010\u0016\u001a\u00020\u00152\n\b\u0002\u0010\u0018\u001a\u0004\u0018\u00010\u00172\n\b\u0002\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0086@¢\u0006\u0004\b\u001c\u0010\u001dJN\u0010&\u001a\b\u0012\u0004\u0012\u00020\"0\u001a2\u0006\u0010\u0016\u001a\u00020\u00152\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010!\u001a\u00020\u001f2\u0006\u0010#\u001a\u00020\"2\n\b\u0002\u0010\u0018\u001a\u0004\u0018\u00010\u00172\n\b\u0002\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0086@¢\u0006\u0004\b$\u0010%JF\u0010)\u001a\b\u0012\u0004\u0012\u00020\u001b0\u001a2\u0006\u0010\u0016\u001a\u00020\u00152\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010!\u001a\u00020\u001f2\n\b\u0002\u0010\u0018\u001a\u0004\u0018\u00010\u00172\n\b\u0002\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0086@¢\u0006\u0004\b'\u0010(J\r\u0010*\u001a\u00020\u001b¢\u0006\u0004\b*\u0010+J<\u00100\u001a\u00020\u001b2\u0006\u0010-\u001a\u00020,2\u0006\u0010/\u001a\u00020.2\u0006\u0010\u0016\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u00172\b\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0082@¢\u0006\u0004\b0\u00101J\u0019\u00103\u001a\u00020\u001b2\b\u00102\u001a\u0004\u0018\u00010,H\u0002¢\u0006\u0004\b3\u00104J#\u00105\u001a\u00020\"2\b\u0010\u0018\u001a\u0004\u0018\u00010\u00172\b\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0002¢\u0006\u0004\b5\u00106J+\u00107\u001a\u00020,2\u0006\u0010\u0016\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u00172\b\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0002¢\u0006\u0004\b7\u00108J\u001f\u0010:\u001a\u0002092\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010!\u001a\u00020\u001fH\u0002¢\u0006\u0004\b:\u0010;J3\u0010=\u001a\u00020.2\u0006\u0010\u0016\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u00172\b\u0010\u0019\u001a\u0004\u0018\u00010\u00172\u0006\u0010<\u001a\u000209H\u0002¢\u0006\u0004\b=\u0010>J,\u0010?\u001a\u00020\u001b2\u0006\u0010\u0016\u001a\u00020\u00152\b\u0010\u0018\u001a\u0004\u0018\u00010\u00172\b\u0010\u0019\u001a\u0004\u0018\u00010\u0017H\u0082@¢\u0006\u0004\b?\u0010\u001dJ2\u0010B\u001a\u00020\u001b2\u0006\u0010@\u001a\u00020\u00172\u0006\u0010\u0018\u001a\u00020\u00172\u0006\u0010\u0019\u001a\u00020\u00172\b\u0010A\u001a\u0004\u0018\u00010,H\u0082@¢\u0006\u0004\bB\u0010CR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010DR\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010ER\u0014\u0010\u0007\u001a\u00020\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0007\u0010FR\u0014\u0010\t\u001a\u00020\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\t\u0010GR\u001a\u0010\f\u001a\b\u0012\u0004\u0012\u00020\u000b0\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\f\u0010HR\u001a\u0010\u000e\u001a\b\u0012\u0004\u0012\u00020\r0\n8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000e\u0010HR\u0014\u0010\u0010\u001a\u00020\u000f8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0010\u0010IR\u0014\u0010\u0012\u001a\u00020\u00118\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0012\u0010JR\u0016\u0010K\u001a\u00020\u001f8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bK\u0010LR\u0016\u0010M\u001a\u00020\"8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bM\u0010NR\u0016\u0010O\u001a\u00020\u00178\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bO\u0010PR\u0016\u0010Q\u001a\u00020\u001f8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bQ\u0010LR\u0018\u0010R\u001a\u0004\u0018\u00010,8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\bR\u0010S¨\u0006U"}, d2 = {"Lcom/strmr/ps/data/repository/TraktScrobbleRepository;", "", "Lcom/strmr/ps/data/remote/api/TraktApiService;", "traktApiService", "Lcom/strmr/ps/data/repository/TraktAccountRepository;", "accountRepository", "Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;", "episodeWatchStatusDao", "Lcom/strmr/ps/data/repository/TraktStatusProvider;", "traktStatusProvider", "Ldagger/Lazy;", "Lcom/strmr/ps/data/repository/TraktSyncRepository;", "traktSyncRepository", "Lcom/strmr/ps/data/repository/ContinueWatchingRepository;", "continueWatchingRepository", "Lcom/strmr/ps/data/event/PlaybackStateManager;", "playbackStateManager", "Lcom/strmr/ps/data/repository/TraktActivitiesCache;", "activitiesCache", "", "(Lcom/strmr/ps/data/remote/api/TraktApiService;Lcom/strmr/ps/data/repository/TraktAccountRepository;Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;Lcom/strmr/ps/data/repository/TraktStatusProvider;Ldagger/Lazy;Ldagger/Lazy;Lcom/strmr/ps/data/event/PlaybackStateManager;Lcom/strmr/ps/data/repository/TraktActivitiesCache;)V", "Lcom/strmr/ps/data/model/ContentItem;", "contentItem", "", "season", PlaybackProgress.TYPE_EPISODE, "Lq38;", "Le6a;", "startWatching-BWLJW6A", "(Lcom/strmr/ps/data/model/ContentItem;Ljava/lang/Integer;Ljava/lang/Integer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "startWatching", "", "currentPositionMs", "durationMs", "", "isPaused", "updateProgress-bMdYcbs", "(Lcom/strmr/ps/data/model/ContentItem;JJZLjava/lang/Integer;Ljava/lang/Integer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "updateProgress", "stopWatching-hUnOzRk", "(Lcom/strmr/ps/data/model/ContentItem;JJLjava/lang/Integer;Ljava/lang/Integer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "stopWatching", "resetState", "()V", "", "accessToken", "Lcom/strmr/ps/data/model/trakt/TraktScrobbleRequest;", "request", "sendPauseWithSessionRecovery", "(Ljava/lang/String;Lcom/strmr/ps/data/model/trakt/TraktScrobbleRequest;Lcom/strmr/ps/data/model/ContentItem;Ljava/lang/Integer;Ljava/lang/Integer;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "stoppingSessionKey", "resetStateIfStillOwner", "(Ljava/lang/String;)V", "isValidEpisodeInfo", "(Ljava/lang/Integer;Ljava/lang/Integer;)Z", "generateSessionKey", "(Lcom/strmr/ps/data/model/ContentItem;Ljava/lang/Integer;Ljava/lang/Integer;)Ljava/lang/String;", "", "calculateProgress", "(JJ)D", "progress", "buildScrobbleRequest", "(Lcom/strmr/ps/data/model/ContentItem;Ljava/lang/Integer;Ljava/lang/Integer;D)Lcom/strmr/ps/data/model/trakt/TraktScrobbleRequest;", "handleWatchedSideEffects", "showTmdbId", "title", "markEpisodeWatchedLocally", "(IIILjava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lcom/strmr/ps/data/remote/api/TraktApiService;", "Lcom/strmr/ps/data/repository/TraktAccountRepository;", "Lcom/strmr/ps/data/local/dao/EpisodeWatchStatusDao;", "Lcom/strmr/ps/data/repository/TraktStatusProvider;", "Ldagger/Lazy;", "Lcom/strmr/ps/data/event/PlaybackStateManager;", "Lcom/strmr/ps/data/repository/TraktActivitiesCache;", "lastUpdateTime", "J", "hasScrobbled", "Z", "consecutiveRecoveryFailures", "I", "rateLimitBackoffUntilMs", "currentSessionKey", "Ljava/lang/String;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class TraktScrobbleRepository { private static final int MAX_CONSECUTIVE_FAILURES = 3; private static final double SCROBBLE_THRESHOLD = 90.0d; @kp6 private static final String TAG = "TraktScrobble"; private static final double TRAKT_PAUSE_LIMIT = 80.0d; private static final long UPDATE_INTERVAL_MS = 30000; @kp6 private final TraktAccountRepository accountRepository; @kp6 private final TraktActivitiesCache activitiesCache; private int consecutiveRecoveryFailures; @kp6 private final Lazy continueWatchingRepository; @pq6 private volatile String currentSessionKey; @kp6 private final EpisodeWatchStatusDao episodeWatchStatusDao; private boolean hasScrobbled; private long lastUpdateTime; @kp6 private final PlaybackStateManager playbackStateManager; private long rateLimitBackoffUntilMs; @kp6 private final TraktApiService traktApiService; @kp6 private final TraktStatusProvider traktStatusProvider; @kp6 private final Lazy traktSyncRepository; @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public /* synthetic */ class WhenMappings { public static final /* synthetic */ int[] $EnumSwitchMapping$0; static { int[] iArr = new int[ContentItem.ItemType.values().length]; try { iArr[ContentItem.ItemType.MOVIE.ordinal()] = 1; } catch (NoSuchFieldError unused) { } try { iArr[ContentItem.ItemType.TV_SHOW.ordinal()] = 2; } catch (NoSuchFieldError unused2) { } $EnumSwitchMapping$0 = iArr; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktScrobbleRepository$handleWatchedSideEffects$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.TraktScrobbleRepository", f = "TraktScrobbleRepository.kt", i = {0, 0, 0, 0, 1, 1, 1, 1}, l = {579, 580, 589}, m = "handleWatchedSideEffects", n = {"this", "contentItem", "season", PlaybackProgress.TYPE_EPISODE, "this", "contentItem", "season", PlaybackProgress.TYPE_EPISODE}, s = {"L$0", "L$1", "L$2", "L$3", "L$0", "L$1", "L$2", "L$3"}) public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation 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 TraktScrobbleRepository.this.handleWatchedSideEffects(null, null, null, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktScrobbleRepository$markEpisodeWatchedLocally$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.TraktScrobbleRepository", f = "TraktScrobbleRepository.kt", i = {0, 0, 0, 0, 0, 1, 1, 1, 2, 2, 2}, l = {609, 613, 615}, m = "markEpisodeWatchedLocally", n = {"this", "title", "showTmdbId", "season", PlaybackProgress.TYPE_EPISODE, "showTmdbId", "season", PlaybackProgress.TYPE_EPISODE, "showTmdbId", "season", PlaybackProgress.TYPE_EPISODE}, s = {"L$0", "L$1", "I$0", "I$1", "I$2", "I$0", "I$1", "I$2", "I$0", "I$1", "I$2"}) public static final class C04521 extends ContinuationImpl { int I$0; int I$1; int I$2; Object L$0; Object L$1; int label; /* synthetic */ Object result; public C04521(Continuation 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 TraktScrobbleRepository.this.markEpisodeWatchedLocally(0, 0, 0, null, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktScrobbleRepository$sendPauseWithSessionRecovery$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.TraktScrobbleRepository", f = "TraktScrobbleRepository.kt", i = {0, 0, 0, 0, 0, 0, 1, 1, 1, 1, 2, 2}, l = {414, 438, 442}, m = "sendPauseWithSessionRecovery", n = {"this", "accessToken", "request", "contentItem", "season", PlaybackProgress.TYPE_EPISODE, "this", "accessToken", "request", "contentItem", "this", "contentItem"}, s = {"L$0", "L$1", "L$2", "L$3", "L$4", "L$5", "L$0", "L$1", "L$2", "L$3", "L$0", "L$1"}) public static final class C04531 extends ContinuationImpl { Object L$0; Object L$1; Object L$2; Object L$3; Object L$4; Object L$5; int label; /* synthetic */ Object result; public C04531(Continuation 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 TraktScrobbleRepository.this.sendPauseWithSessionRecovery(null, null, null, null, null, this); } } @Inject public TraktScrobbleRepository(@kp6 TraktApiService traktApiService, @kp6 TraktAccountRepository traktAccountRepository, @kp6 EpisodeWatchStatusDao episodeWatchStatusDao, @kp6 TraktStatusProvider traktStatusProvider, @kp6 Lazy lazy, @kp6 Lazy lazy2, @kp6 PlaybackStateManager playbackStateManager, @kp6 TraktActivitiesCache traktActivitiesCache) { cr4.g(traktApiService, "traktApiService"); cr4.g(traktAccountRepository, "accountRepository"); cr4.g(episodeWatchStatusDao, "episodeWatchStatusDao"); cr4.g(traktStatusProvider, "traktStatusProvider"); cr4.g(lazy, "traktSyncRepository"); cr4.g(lazy2, "continueWatchingRepository"); cr4.g(playbackStateManager, "playbackStateManager"); cr4.g(traktActivitiesCache, "activitiesCache"); this.traktApiService = traktApiService; this.accountRepository = traktAccountRepository; this.episodeWatchStatusDao = episodeWatchStatusDao; this.traktStatusProvider = traktStatusProvider; this.traktSyncRepository = lazy; this.continueWatchingRepository = lazy2; this.playbackStateManager = playbackStateManager; this.activitiesCache = traktActivitiesCache; } /* JADX INFO: Access modifiers changed from: private */ public final TraktScrobbleRequest buildScrobbleRequest(ContentItem contentItem, Integer season, Integer episode, double progress) { TraktScrobbleIds traktScrobbleIds = new TraktScrobbleIds(null, Integer.valueOf(contentItem.getTmdbId()), contentItem.getImdbId(), null, 9, null); int i = WhenMappings.$EnumSwitchMapping$0[contentItem.getItemType().ordinal()]; if (i == 1) { return new TraktScrobbleRequest(new TraktScrobbleMovie(traktScrobbleIds), null, null, progress, "1.1.72", null, 38, null); } if (i == 2) { return new TraktScrobbleRequest(null, new TraktScrobbleShow(traktScrobbleIds), (season == null || episode == null || season.intValue() <= 0 || episode.intValue() <= 0) ? null : new TraktScrobbleEpisode(season.intValue(), episode.intValue()), progress, "1.1.72", null, 33, null); } throw new IllegalArgumentException("Cannot scrobble non-content item type: " + contentItem.getItemType()); } /* JADX INFO: Access modifiers changed from: private */ public final double calculateProgress(long currentPositionMs, long durationMs) { if (durationMs > 0) { return (currentPositionMs / durationMs) * 100.0d; } return 0.0d; } /* JADX INFO: Access modifiers changed from: private */ public final String generateSessionKey(ContentItem contentItem, Integer season, Integer episode) { int i = WhenMappings.$EnumSwitchMapping$0[contentItem.getItemType().ordinal()]; if (i == 1) { return n41.k("movie_", contentItem.getTmdbId()); } if (i != 2) { return n41.k("unknown_", contentItem.getTmdbId()); } return "show_" + contentItem.getTmdbId() + "_s" + season + "_e" + episode; } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:8:0x0014 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object handleWatchedSideEffects(ContentItem contentItem, Integer num, Integer num2, Continuation continuation) { AnonymousClass1 anonymousClass1; TraktScrobbleRepository traktScrobbleRepository; ContentItem contentItem2; Integer num3; int tmdbId; int iIntValue; int iIntValue2; String title; 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); } } AnonymousClass1 anonymousClass12 = anonymousClass1; Object obj = anonymousClass12.result; ck1 ck1Var = ck1.a; int i2 = anonymousClass12.label; e6a e6aVar = e6a.a; if (i2 == 0) { s38.b(obj); boolean z = contentItem.getItemType() == ContentItem.ItemType.MOVIE; this.traktStatusProvider.removeFromWatchlist(contentItem.getTmdbId()); TraktSyncRepository traktSyncRepository = this.traktSyncRepository.get(); int tmdbId2 = contentItem.getTmdbId(); anonymousClass12.L$0 = this; anonymousClass12.L$1 = contentItem; anonymousClass12.L$2 = num; anonymousClass12.L$3 = num2; anonymousClass12.label = 1; if (traktSyncRepository.removeFromWatchlistLocally(tmdbId2, z, anonymousClass12) != ck1Var) { traktScrobbleRepository = this; } return ck1Var; } if (i2 != 1) { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); return e6aVar; } num3 = (Integer) anonymousClass12.L$3; num = (Integer) anonymousClass12.L$2; contentItem2 = (ContentItem) anonymousClass12.L$1; traktScrobbleRepository = (TraktScrobbleRepository) anonymousClass12.L$0; s38.b(obj); traktScrobbleRepository.continueWatchingRepository.get().invalidateCache(); traktScrobbleRepository.activitiesCache.invalidate(); if (contentItem2.getItemType() == ContentItem.ItemType.TV_SHOW && num != null && num3 != null) { tmdbId = contentItem2.getTmdbId(); iIntValue = num.intValue(); iIntValue2 = num3.intValue(); title = contentItem2.getTitle(); anonymousClass12.L$0 = null; anonymousClass12.L$1 = null; anonymousClass12.L$2 = null; anonymousClass12.L$3 = null; anonymousClass12.label = 3; if (traktScrobbleRepository.markEpisodeWatchedLocally(tmdbId, iIntValue, iIntValue2, title, anonymousClass12) != ck1Var) { return ck1Var; } } return e6aVar; } num2 = (Integer) anonymousClass12.L$3; num = (Integer) anonymousClass12.L$2; contentItem = (ContentItem) anonymousClass12.L$1; traktScrobbleRepository = (TraktScrobbleRepository) anonymousClass12.L$0; s38.b(obj); PlaybackStateManager playbackStateManager = traktScrobbleRepository.playbackStateManager; anonymousClass12.L$0 = traktScrobbleRepository; anonymousClass12.L$1 = contentItem; anonymousClass12.L$2 = num; anonymousClass12.L$3 = num2; anonymousClass12.label = 2; if (playbackStateManager.a(anonymousClass12) != ck1Var) { Integer num4 = num2; contentItem2 = contentItem; num3 = num4; traktScrobbleRepository.continueWatchingRepository.get().invalidateCache(); traktScrobbleRepository.activitiesCache.invalidate(); if (contentItem2.getItemType() == ContentItem.ItemType.TV_SHOW) { tmdbId = contentItem2.getTmdbId(); iIntValue = num.intValue(); iIntValue2 = num3.intValue(); title = contentItem2.getTitle(); anonymousClass12.L$0 = null; anonymousClass12.L$1 = null; anonymousClass12.L$2 = null; anonymousClass12.L$3 = null; anonymousClass12.label = 3; if (traktScrobbleRepository.markEpisodeWatchedLocally(tmdbId, iIntValue, iIntValue2, title, anonymousClass12) != ck1Var) { } } return e6aVar; } return ck1Var; } /* JADX INFO: Access modifiers changed from: private */ public final boolean isValidEpisodeInfo(Integer season, Integer episode) { return season != null && episode != null && season.intValue() > 0 && episode.intValue() > 0; } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Code restructure failed: missing block: B:35:0x00d5, code lost: if (r0.upsert(r15, r14) == r5) goto L36; */ /* JADX WARN: Removed duplicated region for block: B:8:0x001e */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object markEpisodeWatchedLocally(int i, int i2, int i3, String str, Continuation continuation) { C04521 c04521; String str2; int i4; TraktScrobbleRepository traktScrobbleRepository; int i5 = i; int i6 = i2; if (continuation instanceof C04521) { c04521 = (C04521) continuation; int i7 = c04521.label; if ((i7 & Integer.MIN_VALUE) != 0) { c04521.label = i7 - Integer.MIN_VALUE; } else { c04521 = new C04521(continuation); } } C04521 c045212 = c04521; Object episodeStatus = c045212.result; ck1 ck1Var = ck1.a; int i8 = c045212.label; try { } catch (Exception e) { Log.e(TAG, "Failed to mark episode watched locally", e); } if (i8 == 0) { s38.b(episodeStatus); EpisodeWatchStatusDao episodeWatchStatusDao = this.episodeWatchStatusDao; c045212.L$0 = this; str2 = str; c045212.L$1 = str2; c045212.I$0 = i5; c045212.I$1 = i6; c045212.I$2 = i3; c045212.label = 1; episodeStatus = episodeWatchStatusDao.getEpisodeStatus(i5, i6, i3, c045212); if (episodeStatus == ck1Var) { return ck1Var; } i4 = i3; traktScrobbleRepository = this; } else { if (i8 != 1) { if (i8 != 2 && i8 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(episodeStatus); return e6a.a; } int i9 = c045212.I$2; i6 = c045212.I$1; int i10 = c045212.I$0; str2 = (String) c045212.L$1; TraktScrobbleRepository traktScrobbleRepository2 = (TraktScrobbleRepository) c045212.L$0; s38.b(episodeStatus); i4 = i9; i5 = i10; traktScrobbleRepository = traktScrobbleRepository2; } String str3 = str2; EpisodeWatchStatus episodeWatchStatus = (EpisodeWatchStatus) episodeStatus; long jCurrentTimeMillis = System.currentTimeMillis(); if (episodeWatchStatus != null) { EpisodeWatchStatusDao episodeWatchStatusDao2 = traktScrobbleRepository.episodeWatchStatusDao; c045212.L$0 = null; c045212.L$1 = null; c045212.I$0 = i5; c045212.I$1 = i6; c045212.I$2 = i4; c045212.label = 2; if (episodeWatchStatusDao2.markWatched(i5, i6, i4, jCurrentTimeMillis, jCurrentTimeMillis, c045212) == ck1Var) { return ck1Var; } return e6a.a; } int i11 = i5; int i12 = i6; int i13 = i4; EpisodeWatchStatusDao episodeWatchStatusDao3 = traktScrobbleRepository.episodeWatchStatusDao; EpisodeWatchStatus episodeWatchStatus2 = new EpisodeWatchStatus(i11, i12, i13, null, null, true, 1, Boxing.boxLong(jCurrentTimeMillis), str3, null, jCurrentTimeMillis, 536, null); c045212.L$0 = null; c045212.L$1 = null; c045212.I$0 = i11; c045212.I$1 = i12; c045212.I$2 = i13; c045212.label = 3; } /* JADX INFO: Access modifiers changed from: private */ public final void resetStateIfStillOwner(String stoppingSessionKey) { if (cr4.b(this.currentSessionKey, stoppingSessionKey)) { resetState(); } else { this.hasScrobbled = false; } } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Code restructure failed: missing block: B:84:0x01c1, code lost: if (r1.pauseScrobble(r4, r0, r6) != r7) goto L86; */ /* JADX WARN: Removed duplicated region for block: B:104:0x0205 */ /* JADX WARN: Removed duplicated region for block: B:107:0x0210 */ /* JADX WARN: Removed duplicated region for block: B:108:0x0217 */ /* JADX WARN: Removed duplicated region for block: B:111:0x0231 */ /* JADX WARN: Removed duplicated region for block: B:114:0x023b */ /* JADX WARN: Removed duplicated region for block: B:124:0x00fd A[EXC_TOP_SPLITTER, SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:7:0x001f */ /* JADX WARN: Removed duplicated region for block: B:95:0x01ed A[Catch: Exception -> 0x0205, TryCatch #9 {Exception -> 0x0205, blocks: (B:93:0x01e9, B:95:0x01ed, B:98:0x01f4, B:100:0x01fa, B:102:0x0200), top: B:137:0x01e9 }] */ /* JADX WARN: Removed duplicated region for block: B:96:0x01f1 */ /* JADX WARN: Removed duplicated region for block: B:98:0x01f4 A[Catch: Exception -> 0x0205, TryCatch #9 {Exception -> 0x0205, blocks: (B:93:0x01e9, B:95:0x01ed, B:98:0x01f4, B:100:0x01fa, B:102:0x0200), top: B:137:0x01e9 }] */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object sendPauseWithSessionRecovery(String str, TraktScrobbleRequest traktScrobbleRequest, ContentItem contentItem, Integer num, Integer num2, Continuation continuation) { C04531 c04531; ContentItem contentItem2; Integer num3; Integer num4; TraktScrobbleRepository traktScrobbleRepository; TraktApiService traktApiService; String str2; String str3; Integer num5; TraktScrobbleRequest traktScrobbleRequest2; Integer num6; String str4; e6a e6aVar; TraktScrobbleRepository traktScrobbleRepository2; TraktScrobbleRequest traktScrobbleRequest3; String str5; ContentItem contentItem3; Response response; ResponseBody responseBodyErrorBody; HttpException httpException; Response response2; ResponseBody responseBodyErrorBody2; String str6 = str; TraktScrobbleRequest traktScrobbleRequest4 = traktScrobbleRequest; e6a e6aVar2 = e6a.a; if (continuation instanceof C04531) { c04531 = (C04531) continuation; int i = c04531.label; if ((i & Integer.MIN_VALUE) != 0) { c04531.label = i - Integer.MIN_VALUE; } else { c04531 = new C04531(continuation); } } Object obj = c04531.result; ck1 ck1Var = ck1.a; int i2 = c04531.label; try { if (i2 == 0) { s38.b(obj); try { traktApiService = this.traktApiService; str2 = "Bearer " + str6; c04531.L$0 = this; c04531.L$1 = str6; c04531.L$2 = traktScrobbleRequest4; contentItem2 = contentItem; } catch (HttpException e) { e = e; contentItem2 = contentItem; } try { c04531.L$3 = contentItem2; num3 = num; try { c04531.L$4 = num3; num4 = num2; try { c04531.L$5 = num4; c04531.label = 1; if (traktApiService.pauseScrobble(str2, traktScrobbleRequest4, c04531) != ck1Var) { str3 = str6; num5 = num4; traktScrobbleRequest2 = traktScrobbleRequest4; num6 = num3; traktScrobbleRepository = this; traktScrobbleRepository.consecutiveRecoveryFailures = 0; return e6aVar2; } } catch (HttpException e2) { e = e2; traktScrobbleRepository = this; if (e.code() != 422) { if (e.code() == 429) { throw e; } throw e; } try { response = e.response(); } catch (Exception unused) { } String strString = (response == null || (responseBodyErrorBody = response.errorBody()) == null) ? null : responseBodyErrorBody.string(); ExecutorService executorService = kq.a; String title = contentItem2.getTitle(); if (num3 == null || num4 == null) { str4 = ""; } else { str4 = " S" + num3 + "E" + num4; } e6aVar = e6aVar2; kq.h(TAG, "Pause scrobble 422 for " + title + str4 + " (tmdb=" + contentItem2.getTmdbId() + ") — body: " + (strString != null ? n89.bb(200, strString) : null)); if (strString != null && n89.l(strString, "Use stop to scrobble", true)) { kq.h(TAG, "Trakt 422: progress >= 80%, skipping (CW entry preserved from last pause)"); traktScrobbleRepository.consecutiveRecoveryFailures = 0; return e6aVar; } try { TraktApiService traktApiService2 = traktScrobbleRepository.traktApiService; String str7 = "Bearer " + str6; c04531.L$0 = traktScrobbleRepository; c04531.L$1 = str6; c04531.L$2 = traktScrobbleRequest4; c04531.L$3 = contentItem2; c04531.L$4 = null; c04531.L$5 = null; c04531.label = 2; if (traktApiService2.startScrobble(str7, traktScrobbleRequest4, c04531) != ck1Var) { traktScrobbleRequest3 = traktScrobbleRequest4; traktScrobbleRepository2 = traktScrobbleRepository; str5 = str6; contentItem3 = contentItem2; TraktApiService traktApiService3 = traktScrobbleRepository2.traktApiService; String str8 = "Bearer " + str5; c04531.L$0 = traktScrobbleRepository2; c04531.L$1 = contentItem3; c04531.L$2 = null; c04531.L$3 = null; c04531.label = 3; } return ck1Var; } catch (Exception e3) { e = e3; traktScrobbleRepository2 = traktScrobbleRepository; traktScrobbleRepository2.consecutiveRecoveryFailures++; if (e instanceof HttpException) { } if (httpException == null) { ExecutorService executorService2 = kq.a; int i3 = traktScrobbleRepository2.consecutiveRecoveryFailures; String message = e.getMessage(); if (strString == null) { } StringBuilder sbK = fi7.k("Scrobble recovery failed (", i3, "/3): ", message, " — body: "); sbK.append(strBb); kq.h(TAG, sbK.toString()); if (traktScrobbleRepository2.consecutiveRecoveryFailures >= 3) { } } } } } catch (HttpException e4) { e = e4; num4 = num2; traktScrobbleRepository = this; if (e.code() != 422) { } } } catch (HttpException e5) { e = e5; num3 = num; num4 = num2; traktScrobbleRepository = this; if (e.code() != 422) { } } return ck1Var; } if (i2 != 1) { if (i2 == 2) { contentItem3 = (ContentItem) c04531.L$3; TraktScrobbleRequest traktScrobbleRequest5 = (TraktScrobbleRequest) c04531.L$2; str5 = (String) c04531.L$1; TraktScrobbleRepository traktScrobbleRepository3 = (TraktScrobbleRepository) c04531.L$0; try { s38.b(obj); traktScrobbleRequest3 = traktScrobbleRequest5; e6aVar = e6aVar2; traktScrobbleRepository2 = traktScrobbleRepository3; try { TraktApiService traktApiService32 = traktScrobbleRepository2.traktApiService; String str82 = "Bearer " + str5; c04531.L$0 = traktScrobbleRepository2; c04531.L$1 = contentItem3; c04531.L$2 = null; c04531.L$3 = null; c04531.label = 3; } catch (Exception e6) { e = e6; traktScrobbleRepository2.consecutiveRecoveryFailures++; if (e instanceof HttpException) { } if (httpException == null) { } } } catch (Exception e7) { e = e7; e6aVar = e6aVar2; traktScrobbleRepository2 = traktScrobbleRepository3; traktScrobbleRepository2.consecutiveRecoveryFailures++; if (e instanceof HttpException) { } if (httpException == null) { } } } else { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } contentItem3 = (ContentItem) c04531.L$1; traktScrobbleRepository2 = (TraktScrobbleRepository) c04531.L$0; try { s38.b(obj); e6aVar = e6aVar2; ExecutorService executorService3 = kq.a; kq.h(TAG, "Session re-established successfully for " + contentItem3.getTitle()); traktScrobbleRepository2.consecutiveRecoveryFailures = 0; } catch (Exception e8) { e = e8; e6aVar = e6aVar2; traktScrobbleRepository2.consecutiveRecoveryFailures++; if (e instanceof HttpException) { } if (httpException == null) { } } } traktScrobbleRepository2.consecutiveRecoveryFailures++; try { httpException = e instanceof HttpException ? (HttpException) e : null; } catch (Exception unused2) { } String strString2 = (httpException == null || (response2 = httpException.response()) == null || (responseBodyErrorBody2 = response2.errorBody()) == null) ? null : responseBodyErrorBody2.string(); ExecutorService executorService22 = kq.a; int i32 = traktScrobbleRepository2.consecutiveRecoveryFailures; String message2 = e.getMessage(); String strBb = strString2 == null ? n89.bb(200, strString2) : null; StringBuilder sbK2 = fi7.k("Scrobble recovery failed (", i32, "/3): ", message2, " — body: "); sbK2.append(strBb); kq.h(TAG, sbK2.toString()); if (traktScrobbleRepository2.consecutiveRecoveryFailures >= 3) { kq.h(TAG, "Disabling scrobble updates after 3 consecutive failures"); traktScrobbleRepository2.currentSessionKey = null; } } else { num5 = (Integer) c04531.L$5; num6 = (Integer) c04531.L$4; ContentItem contentItem4 = (ContentItem) c04531.L$3; traktScrobbleRequest2 = (TraktScrobbleRequest) c04531.L$2; str3 = (String) c04531.L$1; TraktScrobbleRepository traktScrobbleRepository4 = (TraktScrobbleRepository) c04531.L$0; try { s38.b(obj); contentItem2 = contentItem4; traktScrobbleRepository = traktScrobbleRepository4; } catch (HttpException e9) { e = e9; num4 = num5; str6 = str3; num3 = num6; traktScrobbleRequest4 = traktScrobbleRequest2; contentItem2 = contentItem4; traktScrobbleRepository = traktScrobbleRepository4; if (e.code() != 422) { } } try { traktScrobbleRepository.consecutiveRecoveryFailures = 0; return e6aVar2; } catch (HttpException e10) { e = e10; TraktScrobbleRequest traktScrobbleRequest6 = traktScrobbleRequest2; num4 = num5; str6 = str3; num3 = num6; traktScrobbleRequest4 = traktScrobbleRequest6; if (e.code() != 422) { } } } return e6aVar; } catch (CancellationException e11) { throw e11; } } /* JADX INFO: renamed from: startWatching-BWLJW6A$default, reason: not valid java name */ public static /* synthetic */ Object m152startWatchingBWLJW6A$default(TraktScrobbleRepository traktScrobbleRepository, ContentItem contentItem, Integer num, Integer num2, Continuation continuation, int i, Object obj) { if ((i & 2) != 0) { num = null; } if ((i & 4) != 0) { num2 = null; } return traktScrobbleRepository.m155startWatchingBWLJW6A(contentItem, num, num2, continuation); } /* JADX INFO: renamed from: stopWatching-hUnOzRk$default, reason: not valid java name */ public static /* synthetic */ Object m153stopWatchinghUnOzRk$default(TraktScrobbleRepository traktScrobbleRepository, ContentItem contentItem, long j, long j2, Integer num, Integer num2, Continuation continuation, int i, Object obj) { if ((i & 8) != 0) { num = null; } if ((i & 16) != 0) { num2 = null; } return traktScrobbleRepository.m156stopWatchinghUnOzRk(contentItem, j, j2, num, num2, continuation); } /* JADX INFO: renamed from: updateProgress-bMdYcbs$default, reason: not valid java name */ public static /* synthetic */ Object m154updateProgressbMdYcbs$default(TraktScrobbleRepository traktScrobbleRepository, ContentItem contentItem, long j, long j2, boolean z, Integer num, Integer num2, Continuation continuation, int i, Object obj) { if ((i & 16) != 0) { num = null; } if ((i & 32) != 0) { num2 = null; } return traktScrobbleRepository.m157updateProgressbMdYcbs(contentItem, j, j2, z, num, num2, continuation); } public final void resetState() { this.hasScrobbled = false; this.lastUpdateTime = 0L; this.currentSessionKey = null; this.consecutiveRecoveryFailures = 0; this.rateLimitBackoffUntilMs = 0L; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: startWatching-BWLJW6A, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m155startWatchingBWLJW6A(@kp6 ContentItem contentItem, @pq6 Integer num, @pq6 Integer num2, @kp6 Continuation> continuation) throws Throwable { TraktScrobbleRepository$startWatching$1 traktScrobbleRepository$startWatching$1; if (continuation instanceof TraktScrobbleRepository$startWatching$1) { traktScrobbleRepository$startWatching$1 = (TraktScrobbleRepository$startWatching$1) continuation; int i = traktScrobbleRepository$startWatching$1.label; if ((i & Integer.MIN_VALUE) != 0) { traktScrobbleRepository$startWatching$1.label = i - Integer.MIN_VALUE; } else { traktScrobbleRepository$startWatching$1 = new TraktScrobbleRepository$startWatching$1(this, continuation); } } Object objF = traktScrobbleRepository$startWatching$1.result; ck1 ck1Var = ck1.a; int i2 = traktScrobbleRepository$startWatching$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; TraktScrobbleRepository$startWatching$2 traktScrobbleRepository$startWatching$2 = new TraktScrobbleRepository$startWatching$2(contentItem, this, num, num2, null); traktScrobbleRepository$startWatching$1.label = 1; objF = wj0.f(m02Var, traktScrobbleRepository$startWatching$2, traktScrobbleRepository$startWatching$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ @pq6 /* JADX INFO: renamed from: stopWatching-hUnOzRk, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m156stopWatchinghUnOzRk(@kp6 ContentItem contentItem, long j, long j2, @pq6 Integer num, @pq6 Integer num2, @kp6 Continuation> continuation) throws Throwable { TraktScrobbleRepository$stopWatching$1 traktScrobbleRepository$stopWatching$1; if (continuation instanceof TraktScrobbleRepository$stopWatching$1) { traktScrobbleRepository$stopWatching$1 = (TraktScrobbleRepository$stopWatching$1) continuation; int i = traktScrobbleRepository$stopWatching$1.label; if ((i & Integer.MIN_VALUE) != 0) { traktScrobbleRepository$stopWatching$1.label = i - Integer.MIN_VALUE; } else { traktScrobbleRepository$stopWatching$1 = new TraktScrobbleRepository$stopWatching$1(this, continuation); } } Object objF = traktScrobbleRepository$stopWatching$1.result; ck1 ck1Var = ck1.a; int i2 = traktScrobbleRepository$stopWatching$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; TraktScrobbleRepository$stopWatching$2 traktScrobbleRepository$stopWatching$2 = new TraktScrobbleRepository$stopWatching$2(this, contentItem, num, num2, j, j2, null); traktScrobbleRepository$stopWatching$1.label = 1; objF = wj0.f(m02Var, traktScrobbleRepository$stopWatching$2, traktScrobbleRepository$stopWatching$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ @pq6 /* JADX INFO: renamed from: updateProgress-bMdYcbs, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m157updateProgressbMdYcbs(@kp6 ContentItem contentItem, long j, long j2, boolean z, @pq6 Integer num, @pq6 Integer num2, @kp6 Continuation> continuation) throws Throwable { TraktScrobbleRepository$updateProgress$1 traktScrobbleRepository$updateProgress$1; if (continuation instanceof TraktScrobbleRepository$updateProgress$1) { traktScrobbleRepository$updateProgress$1 = (TraktScrobbleRepository$updateProgress$1) continuation; int i = traktScrobbleRepository$updateProgress$1.label; if ((i & Integer.MIN_VALUE) != 0) { traktScrobbleRepository$updateProgress$1.label = i - Integer.MIN_VALUE; } else { traktScrobbleRepository$updateProgress$1 = new TraktScrobbleRepository$updateProgress$1(this, continuation); } } Object objF = traktScrobbleRepository$updateProgress$1.result; ck1 ck1Var = ck1.a; int i2 = traktScrobbleRepository$updateProgress$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; TraktScrobbleRepository$updateProgress$2 traktScrobbleRepository$updateProgress$2 = new TraktScrobbleRepository$updateProgress$2(contentItem, this, num, num2, z, j, j2, null); traktScrobbleRepository$updateProgress$1.label = 1; objF = wj0.f(m02Var, traktScrobbleRepository$updateProgress$2, traktScrobbleRepository$updateProgress$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } }