package com.strmr.ps.data.repository; import android.content.Context; import android.net.ConnectivityManager; import android.net.Network; import android.net.NetworkCapabilities; import androidx.media3.container.NalUnitUtil; import androidx.media3.extractor.metadata.dvbsi.AppInfoTableDecoder; import com.strmr.ps.data.local.dao.PendingTraktActionDao; import com.strmr.ps.data.local.entity.PendingTraktAction; import com.strmr.ps.data.local.entity.PlaybackProgress; import dagger.hilt.android.qualifiers.ApplicationContext; import defpackage.ck1; import defpackage.cr4; import defpackage.e6a; import defpackage.j43; import defpackage.kp6; import defpackage.pq6; import defpackage.s38; import java.util.List; 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; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u0000P\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0016\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\t\b\u0007\u0018\u0000 82\u00020\u0001:\u00018B\u001b\b\u0007\u0012\b\b\u0001\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007J\r\u0010\t\u001a\u00020\b¢\u0006\u0004\b\t\u0010\nJ\u0018\u0010\u000e\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u000e\u0010\u000fJ\u0018\u0010\u0010\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0010\u0010\u000fJ\u0018\u0010\u0011\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0011\u0010\u000fJ\u0018\u0010\u0012\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0012\u0010\u000fJ \u0010\u0014\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0014\u0010\u0015J(\u0010\u0017\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u000b2\u0006\u0010\u0016\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0017\u0010\u0018J(\u0010\u0019\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u0013\u001a\u00020\u000b2\u0006\u0010\u0016\u001a\u00020\u000bH\u0086@¢\u0006\u0004\b\u0019\u0010\u0018J \u0010\u001b\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\bH\u0086@¢\u0006\u0004\b\u001b\u0010\u001cJ \u0010\u001d\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\bH\u0086@¢\u0006\u0004\b\u001d\u0010\u001cJ \u0010\u001e\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\bH\u0086@¢\u0006\u0004\b\u001e\u0010\u001cJ \u0010\u001f\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\bH\u0086@¢\u0006\u0004\b\u001f\u0010\u001cJ(\u0010!\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\b2\u0006\u0010 \u001a\u00020\u000bH\u0086@¢\u0006\u0004\b!\u0010\"J \u0010#\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000b2\u0006\u0010\u001a\u001a\u00020\bH\u0086@¢\u0006\u0004\b#\u0010\u001cJ\u0016\u0010&\u001a\b\u0012\u0004\u0012\u00020%0$H\u0086@¢\u0006\u0004\b&\u0010'J\u0010\u0010(\u001a\u00020\bH\u0086@¢\u0006\u0004\b(\u0010'J\u0013\u0010*\u001a\b\u0012\u0004\u0012\u00020\u000b0)¢\u0006\u0004\b*\u0010+J\u0018\u0010.\u001a\u00020\r2\u0006\u0010-\u001a\u00020,H\u0086@¢\u0006\u0004\b.\u0010/J\"\u00102\u001a\u00020\r2\u0006\u0010-\u001a\u00020,2\b\u00101\u001a\u0004\u0018\u000100H\u0086@¢\u0006\u0004\b2\u00103J\u0010\u00104\u001a\u00020\rH\u0086@¢\u0006\u0004\b4\u0010'J\u0010\u00105\u001a\u00020\rH\u0086@¢\u0006\u0004\b5\u0010'R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u00106R\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u00107¨\u00069"}, d2 = {"Lcom/strmr/ps/data/repository/TraktOfflineQueueRepository;", "", "Landroid/content/Context;", "context", "Lcom/strmr/ps/data/local/dao/PendingTraktActionDao;", "pendingActionDao", "", "(Landroid/content/Context;Lcom/strmr/ps/data/local/dao/PendingTraktActionDao;)V", "", "isOnline", "()Z", "", "tmdbId", "Le6a;", "queueMarkMovieWatched", "(ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "queueMarkMovieUnwatched", "queueMarkShowWatched", "queueMarkShowUnwatched", "season", "queueMarkSeasonWatched", "(IILkotlin/coroutines/Continuation;)Ljava/lang/Object;", PlaybackProgress.TYPE_EPISODE, "queueMarkEpisodeWatched", "(IIILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "queueMarkEpisodeUnwatched", "isMovie", "queueAddToCollection", "(IZLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "queueRemoveFromCollection", "queueAddToWatchlist", "queueRemoveFromWatchlist", "rating", "queueAddRating", "(IZILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "queueRemoveRating", "", "Lcom/strmr/ps/data/local/entity/PendingTraktAction;", "getPendingActions", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "hasPendingActions", "Lj43;", "observePendingCount", "()Lj43;", "", "actionId", "markCompleted", "(JLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "", "error", "markFailed", "(JLjava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "clearAll", "cleanupFailedActions", "Landroid/content/Context;", "Lcom/strmr/ps/data/local/dao/PendingTraktActionDao;", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public final class TraktOfflineQueueRepository { @kp6 private static final String TAG = "TraktOfflineQueue"; @kp6 private final Context context; @kp6 private final PendingTraktActionDao pendingActionDao; /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$cleanupFailedActions$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {}, l = {263}, m = "cleanupFailedActions", n = {}, s = {}) public static final class AnonymousClass1 extends ContinuationImpl { 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 TraktOfflineQueueRepository.this.cleanupFailedActions(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$clearAll$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {}, l = {255}, m = "clearAll", n = {}, s = {}) public static final class C04361 extends ContinuationImpl { int label; /* synthetic */ Object result; public C04361(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 TraktOfflineQueueRepository.this.clearAll(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$markCompleted$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {239}, m = "markCompleted", n = {"actionId"}, s = {"J$0"}) public static final class C04371 extends ContinuationImpl { long J$0; int label; /* synthetic */ Object result; public C04371(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 TraktOfflineQueueRepository.this.markCompleted(0L, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$markFailed$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {247}, m = "markFailed", n = {"error", "actionId"}, s = {"L$0", "J$0"}) public static final class C04381 extends ContinuationImpl { long J$0; Object L$0; int label; /* synthetic */ Object result; public C04381(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 TraktOfflineQueueRepository.this.markFailed(0L, null, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueAddRating$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {197}, m = "queueAddRating", n = {"tmdbId", "rating"}, s = {"I$0", "I$1"}) public static final class C04391 extends ContinuationImpl { int I$0; int I$1; int label; /* synthetic */ Object result; public C04391(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 TraktOfflineQueueRepository.this.queueAddRating(0, false, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueAddToCollection$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {144}, m = "queueAddToCollection", n = {"tmdbId", "isMovie"}, s = {"I$0", "Z$0"}) public static final class C04401 extends ContinuationImpl { int I$0; boolean Z$0; int label; /* synthetic */ Object result; public C04401(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 TraktOfflineQueueRepository.this.queueAddToCollection(0, false, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueAddToWatchlist$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {170}, m = "queueAddToWatchlist", n = {"tmdbId", "isMovie"}, s = {"I$0", "Z$0"}) public static final class C04411 extends ContinuationImpl { int I$0; boolean Z$0; int label; /* synthetic */ Object result; public C04411(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 TraktOfflineQueueRepository.this.queueAddToWatchlist(0, false, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkEpisodeUnwatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0, 0}, l = {131}, m = "queueMarkEpisodeUnwatched", n = {"tmdbId", "season", PlaybackProgress.TYPE_EPISODE}, s = {"I$0", "I$1", "I$2"}) public static final class C04421 extends ContinuationImpl { int I$0; int I$1; int I$2; int label; /* synthetic */ Object result; public C04421(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 TraktOfflineQueueRepository.this.queueMarkEpisodeUnwatched(0, 0, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkEpisodeWatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0, 0}, l = {AppInfoTableDecoder.APPLICATION_INFORMATION_TABLE_ID}, m = "queueMarkEpisodeWatched", n = {"tmdbId", "season", PlaybackProgress.TYPE_EPISODE}, s = {"I$0", "I$1", "I$2"}) public static final class C04431 extends ContinuationImpl { int I$0; int I$1; int I$2; int label; /* synthetic */ Object result; public C04431(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 TraktOfflineQueueRepository.this.queueMarkEpisodeWatched(0, 0, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkMovieUnwatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {61}, m = "queueMarkMovieUnwatched", n = {"tmdbId"}, s = {"I$0"}) public static final class C04441 extends ContinuationImpl { int I$0; int label; /* synthetic */ Object result; public C04441(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 TraktOfflineQueueRepository.this.queueMarkMovieUnwatched(0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkMovieWatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED}, m = "queueMarkMovieWatched", n = {"tmdbId"}, s = {"I$0"}) public static final class C04451 extends ContinuationImpl { int I$0; int label; /* synthetic */ Object result; public C04451(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 TraktOfflineQueueRepository.this.queueMarkMovieWatched(0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkSeasonWatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {101}, m = "queueMarkSeasonWatched", n = {"tmdbId", "season"}, s = {"I$0", "I$1"}) public static final class C04461 extends ContinuationImpl { int I$0; int I$1; int label; /* synthetic */ Object result; public C04461(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 TraktOfflineQueueRepository.this.queueMarkSeasonWatched(0, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkShowUnwatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {87}, m = "queueMarkShowUnwatched", n = {"tmdbId"}, s = {"I$0"}) public static final class C04471 extends ContinuationImpl { int I$0; int label; /* synthetic */ Object result; public C04471(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 TraktOfflineQueueRepository.this.queueMarkShowUnwatched(0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueMarkShowWatched$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {74}, m = "queueMarkShowWatched", n = {"tmdbId"}, s = {"I$0"}) public static final class C04481 extends ContinuationImpl { int I$0; int label; /* synthetic */ Object result; public C04481(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 TraktOfflineQueueRepository.this.queueMarkShowWatched(0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueRemoveFromCollection$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {157}, m = "queueRemoveFromCollection", n = {"tmdbId", "isMovie"}, s = {"I$0", "Z$0"}) public static final class C04491 extends ContinuationImpl { int I$0; boolean Z$0; int label; /* synthetic */ Object result; public C04491(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 TraktOfflineQueueRepository.this.queueRemoveFromCollection(0, false, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueRemoveFromWatchlist$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0, 0}, l = {183}, m = "queueRemoveFromWatchlist", n = {"tmdbId", "isMovie"}, s = {"I$0", "Z$0"}) public static final class C04501 extends ContinuationImpl { int I$0; boolean Z$0; int label; /* synthetic */ Object result; public C04501(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 TraktOfflineQueueRepository.this.queueRemoveFromWatchlist(0, false, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.TraktOfflineQueueRepository$queueRemoveRating$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.TraktOfflineQueueRepository", f = "TraktOfflineQueueRepository.kt", i = {0}, l = {210}, m = "queueRemoveRating", n = {"tmdbId"}, s = {"I$0"}) public static final class C04511 extends ContinuationImpl { int I$0; int label; /* synthetic */ Object result; public C04511(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 TraktOfflineQueueRepository.this.queueRemoveRating(0, false, this); } } @Inject public TraktOfflineQueueRepository(@ApplicationContext @kp6 Context context, @kp6 PendingTraktActionDao pendingTraktActionDao) { cr4.g(context, "context"); cr4.g(pendingTraktActionDao, "pendingActionDao"); this.context = context; this.pendingActionDao = pendingTraktActionDao; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object cleanupFailedActions(@kp6 Continuation continuation) { AnonymousClass1 anonymousClass1; 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 obj = anonymousClass1.result; ck1 ck1Var = ck1.a; int i2 = anonymousClass1.label; if (i2 == 0) { s38.b(obj); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; anonymousClass1.label = 1; if (PendingTraktActionDao.DefaultImpls.deleteFailedActions$default(pendingTraktActionDao, 0, anonymousClass1, 1, null) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object clearAll(@kp6 Continuation continuation) { C04361 c04361; if (continuation instanceof C04361) { c04361 = (C04361) continuation; int i = c04361.label; if ((i & Integer.MIN_VALUE) != 0) { c04361.label = i - Integer.MIN_VALUE; } else { c04361 = new C04361(continuation); } } Object obj = c04361.result; ck1 ck1Var = ck1.a; int i2 = c04361.label; if (i2 == 0) { s38.b(obj); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04361.label = 1; if (pendingTraktActionDao.deleteAll(c04361) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } @pq6 public final Object getPendingActions(@kp6 Continuation> continuation) { return PendingTraktActionDao.DefaultImpls.getPendingWithRetriesLeft$default(this.pendingActionDao, 0, continuation, 1, null); } @pq6 public final Object hasPendingActions(@kp6 Continuation continuation) { return this.pendingActionDao.hasPendingActions(continuation); } public final boolean isOnline() { NetworkCapabilities networkCapabilities; Object systemService = this.context.getSystemService("connectivity"); cr4.e(systemService, "null cannot be cast to non-null type android.net.ConnectivityManager"); ConnectivityManager connectivityManager = (ConnectivityManager) systemService; Network activeNetwork = connectivityManager.getActiveNetwork(); if (activeNetwork == null || (networkCapabilities = connectivityManager.getNetworkCapabilities(activeNetwork)) == null) { return false; } return networkCapabilities.hasCapability(12); } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object markCompleted(long j, @kp6 Continuation continuation) { C04371 c04371; if (continuation instanceof C04371) { c04371 = (C04371) continuation; int i = c04371.label; if ((i & Integer.MIN_VALUE) != 0) { c04371.label = i - Integer.MIN_VALUE; } else { c04371 = new C04371(continuation); } } Object obj = c04371.result; ck1 ck1Var = ck1.a; int i2 = c04371.label; if (i2 == 0) { s38.b(obj); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04371.J$0 = j; c04371.label = 1; if (pendingTraktActionDao.delete(j, c04371) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:8:0x0014 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object markFailed(long j, @pq6 String str, @kp6 Continuation continuation) { C04381 c04381; if (continuation instanceof C04381) { c04381 = (C04381) continuation; int i = c04381.label; if ((i & Integer.MIN_VALUE) != 0) { c04381.label = i - Integer.MIN_VALUE; } else { c04381 = new C04381(continuation); } } C04381 c043812 = c04381; Object obj = c043812.result; ck1 ck1Var = ck1.a; int i2 = c043812.label; if (i2 == 0) { s38.b(obj); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c043812.L$0 = str; c043812.J$0 = j; c043812.label = 1; if (PendingTraktActionDao.DefaultImpls.incrementRetry$default(pendingTraktActionDao, j, 0L, str, c043812, 2, null) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } @kp6 public final j43 observePendingCount() { return this.pendingActionDao.observePendingCount(); } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueAddRating(int i, boolean z, int i2, @kp6 Continuation continuation) { C04391 c04391; if (continuation instanceof C04391) { c04391 = (C04391) continuation; int i3 = c04391.label; if ((i3 & Integer.MIN_VALUE) != 0) { c04391.label = i3 - Integer.MIN_VALUE; } else { c04391 = new C04391(continuation); } } Object obj = c04391.result; ck1 ck1Var = ck1.a; int i4 = c04391.label; if (i4 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.ADD_RATING, i, z ? "MOVIE" : "TV_SHOW", null, null, Boxing.boxInt(i2), 0, null, 0L, null, 1969, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04391.I$0 = i; c04391.I$1 = i2; c04391.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04391) == ck1Var) { return ck1Var; } } else { if (i4 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0019 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueAddToCollection(int i, boolean z, @kp6 Continuation continuation) { C04401 c04401; if (continuation instanceof C04401) { c04401 = (C04401) continuation; int i2 = c04401.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04401.label = i2 - Integer.MIN_VALUE; } else { c04401 = new C04401(continuation); } } Object obj = c04401.result; ck1 ck1Var = ck1.a; int i3 = c04401.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.ADD_TO_COLLECTION, i, z ? "MOVIE" : "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04401.I$0 = i; c04401.Z$0 = z; c04401.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04401) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0019 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueAddToWatchlist(int i, boolean z, @kp6 Continuation continuation) { C04411 c04411; if (continuation instanceof C04411) { c04411 = (C04411) continuation; int i2 = c04411.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04411.label = i2 - Integer.MIN_VALUE; } else { c04411 = new C04411(continuation); } } Object obj = c04411.result; ck1 ck1Var = ck1.a; int i3 = c04411.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.ADD_TO_WATCHLIST, i, z ? "MOVIE" : "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04411.I$0 = i; c04411.Z$0 = z; c04411.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04411) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkEpisodeUnwatched(int i, int i2, int i3, @kp6 Continuation continuation) { C04421 c04421; if (continuation instanceof C04421) { c04421 = (C04421) continuation; int i4 = c04421.label; if ((i4 & Integer.MIN_VALUE) != 0) { c04421.label = i4 - Integer.MIN_VALUE; } else { c04421 = new C04421(continuation); } } Object obj = c04421.result; ck1 ck1Var = ck1.a; int i5 = c04421.label; if (i5 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_EPISODE_UNWATCHED, i, "TV_SHOW", Boxing.boxInt(i2), Boxing.boxInt(i3), null, 0, null, 0L, null, 1985, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04421.I$0 = i; c04421.I$1 = i2; c04421.I$2 = i3; c04421.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04421) == ck1Var) { return ck1Var; } } else { if (i5 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkEpisodeWatched(int i, int i2, int i3, @kp6 Continuation continuation) { C04431 c04431; if (continuation instanceof C04431) { c04431 = (C04431) continuation; int i4 = c04431.label; if ((i4 & Integer.MIN_VALUE) != 0) { c04431.label = i4 - Integer.MIN_VALUE; } else { c04431 = new C04431(continuation); } } Object obj = c04431.result; ck1 ck1Var = ck1.a; int i5 = c04431.label; if (i5 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_EPISODE_WATCHED, i, "TV_SHOW", Boxing.boxInt(i2), Boxing.boxInt(i3), null, 0, null, 0L, null, 1985, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04431.I$0 = i; c04431.I$1 = i2; c04431.I$2 = i3; c04431.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04431) == ck1Var) { return ck1Var; } } else { if (i5 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkMovieUnwatched(int i, @kp6 Continuation continuation) { C04441 c04441; if (continuation instanceof C04441) { c04441 = (C04441) continuation; int i2 = c04441.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04441.label = i2 - Integer.MIN_VALUE; } else { c04441 = new C04441(continuation); } } Object obj = c04441.result; ck1 ck1Var = ck1.a; int i3 = c04441.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_MOVIE_UNWATCHED, i, "MOVIE", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04441.I$0 = i; c04441.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04441) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkMovieWatched(int i, @kp6 Continuation continuation) { C04451 c04451; if (continuation instanceof C04451) { c04451 = (C04451) continuation; int i2 = c04451.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04451.label = i2 - Integer.MIN_VALUE; } else { c04451 = new C04451(continuation); } } Object obj = c04451.result; ck1 ck1Var = ck1.a; int i3 = c04451.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_MOVIE_WATCHED, i, "MOVIE", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04451.I$0 = i; c04451.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04451) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkSeasonWatched(int i, int i2, @kp6 Continuation continuation) { C04461 c04461; if (continuation instanceof C04461) { c04461 = (C04461) continuation; int i3 = c04461.label; if ((i3 & Integer.MIN_VALUE) != 0) { c04461.label = i3 - Integer.MIN_VALUE; } else { c04461 = new C04461(continuation); } } Object obj = c04461.result; ck1 ck1Var = ck1.a; int i4 = c04461.label; if (i4 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_SEASON_WATCHED, i, "TV_SHOW", Boxing.boxInt(i2), null, null, 0, null, 0L, null, 2017, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04461.I$0 = i; c04461.I$1 = i2; c04461.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04461) == ck1Var) { return ck1Var; } } else { if (i4 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkShowUnwatched(int i, @kp6 Continuation continuation) { C04471 c04471; if (continuation instanceof C04471) { c04471 = (C04471) continuation; int i2 = c04471.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04471.label = i2 - Integer.MIN_VALUE; } else { c04471 = new C04471(continuation); } } Object obj = c04471.result; ck1 ck1Var = ck1.a; int i3 = c04471.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_SHOW_UNWATCHED, i, "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04471.I$0 = i; c04471.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04471) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueMarkShowWatched(int i, @kp6 Continuation continuation) { C04481 c04481; if (continuation instanceof C04481) { c04481 = (C04481) continuation; int i2 = c04481.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04481.label = i2 - Integer.MIN_VALUE; } else { c04481 = new C04481(continuation); } } Object obj = c04481.result; ck1 ck1Var = ck1.a; int i3 = c04481.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.MARK_SHOW_WATCHED, i, "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04481.I$0 = i; c04481.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04481) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0019 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueRemoveFromCollection(int i, boolean z, @kp6 Continuation continuation) { C04491 c04491; if (continuation instanceof C04491) { c04491 = (C04491) continuation; int i2 = c04491.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04491.label = i2 - Integer.MIN_VALUE; } else { c04491 = new C04491(continuation); } } Object obj = c04491.result; ck1 ck1Var = ck1.a; int i3 = c04491.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.REMOVE_FROM_COLLECTION, i, z ? "MOVIE" : "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04491.I$0 = i; c04491.Z$0 = z; c04491.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04491) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0019 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueRemoveFromWatchlist(int i, boolean z, @kp6 Continuation continuation) { C04501 c04501; if (continuation instanceof C04501) { c04501 = (C04501) continuation; int i2 = c04501.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04501.label = i2 - Integer.MIN_VALUE; } else { c04501 = new C04501(continuation); } } Object obj = c04501.result; ck1 ck1Var = ck1.a; int i3 = c04501.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.REMOVE_FROM_WATCHLIST, i, z ? "MOVIE" : "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04501.I$0 = i; c04501.Z$0 = z; c04501.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04501) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object queueRemoveRating(int i, boolean z, @kp6 Continuation continuation) { C04511 c04511; if (continuation instanceof C04511) { c04511 = (C04511) continuation; int i2 = c04511.label; if ((i2 & Integer.MIN_VALUE) != 0) { c04511.label = i2 - Integer.MIN_VALUE; } else { c04511 = new C04511(continuation); } } Object obj = c04511.result; ck1 ck1Var = ck1.a; int i3 = c04511.label; if (i3 == 0) { s38.b(obj); PendingTraktAction pendingTraktAction = new PendingTraktAction(0L, PendingTraktAction.ActionType.REMOVE_RATING, i, z ? "MOVIE" : "TV_SHOW", null, null, null, 0, null, 0L, null, 2033, null); PendingTraktActionDao pendingTraktActionDao = this.pendingActionDao; c04511.I$0 = i; c04511.label = 1; if (pendingTraktActionDao.insert(pendingTraktAction, c04511) == ck1Var) { return ck1Var; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } }