package com.strmr.ps.data.repository; import android.util.Log; import android.util.LruCache; import androidx.media3.container.NalUnitUtil; import com.strmr.ps.data.model.omdb.OMDbEpisode; import com.strmr.ps.data.model.omdb.OMDbSeasonResponse; import com.strmr.ps.data.model.trakt.TraktEpisodeFull; import com.strmr.ps.data.remote.api.OMDbApiService; import com.strmr.ps.data.remote.api.TraktApiService; import defpackage.ak1; import defpackage.bk1; import defpackage.ck1; import defpackage.cp4; import defpackage.cr4; import defpackage.dp4; import defpackage.e6a; import defpackage.gr3; import defpackage.i50; import defpackage.ik2; import defpackage.kp6; import defpackage.m02; import defpackage.m12; import defpackage.n89; import defpackage.pq6; import defpackage.q07; import defpackage.s38; import defpackage.sc2; import defpackage.to4; import defpackage.vx8; import defpackage.wj0; import defpackage.wo5; import defpackage.y41; import java.util.ArrayList; import java.util.Iterator; import java.util.LinkedHashMap; 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; import kotlin.coroutines.jvm.internal.SuspendLambda; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u00004\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\u0006\b\u0007\u0018\u0000 \u00152\u00020\u0001:\u0001\u0015B\u0019\b\u0007\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005¢\u0006\u0004\b\u0006\u0010\u0007J$\u0010\r\u001a\b\u0012\u0004\u0012\u00020\f0\u000b2\u0006\u0010\u000e\u001a\u00020\n2\u0006\u0010\u000f\u001a\u00020\u0010H\u0086@¢\u0006\u0002\u0010\u0011J$\u0010\u0012\u001a\b\u0012\u0004\u0012\u00020\f0\u000b2\u0006\u0010\u000e\u001a\u00020\n2\u0006\u0010\u0013\u001a\u00020\u0010H\u0082@¢\u0006\u0002\u0010\u0011J$\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\f0\u000b2\u0006\u0010\u000e\u001a\u00020\n2\u0006\u0010\u0013\u001a\u00020\u0010H\u0082@¢\u0006\u0002\u0010\u0011R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004¢\u0006\u0002\n\u0000R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082\u0004¢\u0006\u0002\n\u0000R \u0010\b\u001a\u0014\u0012\u0004\u0012\u00020\n\u0012\n\u0012\b\u0012\u0004\u0012\u00020\f0\u000b0\tX\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\u0016"}, d2 = {"Lcom/strmr/ps/data/repository/EpisodeRatingsRepository;", "", "omDbApiService", "Lcom/strmr/ps/data/remote/api/OMDbApiService;", "traktApiService", "Lcom/strmr/ps/data/remote/api/TraktApiService;", "", "(Lcom/strmr/ps/data/remote/api/OMDbApiService;Lcom/strmr/ps/data/remote/api/TraktApiService;)V", "cache", "Landroid/util/LruCache;", "", "", "Lcom/strmr/ps/data/repository/EpisodeRating;", "getRatings", "imdbId", "totalSeasons", "", "(Ljava/lang/String;ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "fetchOmdbSeason", "season", "fetchTraktSeason", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class EpisodeRatingsRepository { @kp6 private static final String TAG = "EpisodeRatingsRepo"; @kp6 private final LruCache> cache; @kp6 private final OMDbApiService omDbApiService; @kp6 private final TraktApiService traktApiService; /* JADX INFO: renamed from: com.strmr.ps.data.repository.EpisodeRatingsRepository$fetchOmdbSeason$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.EpisodeRatingsRepository", f = "EpisodeRatingsRepository.kt", i = {0, 0}, l = {76}, m = "fetchOmdbSeason", n = {"imdbId", "season"}, s = {"L$0", "I$0"}) public static final class AnonymousClass1 extends ContinuationImpl { int I$0; Object L$0; 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 EpisodeRatingsRepository.this.fetchOmdbSeason(null, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.EpisodeRatingsRepository$fetchTraktSeason$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.EpisodeRatingsRepository", f = "EpisodeRatingsRepository.kt", i = {0, 0}, l = {103}, m = "fetchTraktSeason", n = {"imdbId", "season"}, s = {"L$0", "I$0"}) public static final class C03251 extends ContinuationImpl { int I$0; Object L$0; int label; /* synthetic */ Object result; public C03251(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 EpisodeRatingsRepository.this.fetchTraktSeason(null, 0, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.EpisodeRatingsRepository$getRatings$2, reason: invalid class name */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/repository/EpisodeRating;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.EpisodeRatingsRepository$getRatings$2", f = "EpisodeRatingsRepository.kt", i = {}, l = {41}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class AnonymousClass2 extends SuspendLambda implements gr3>, Object> { final /* synthetic */ String $imdbId; final /* synthetic */ int $totalSeasons; int label; /* JADX INFO: renamed from: com.strmr.ps.data.repository.EpisodeRatingsRepository$getRatings$2$2, reason: invalid class name and collision with other inner class name */ @Metadata(d1 = {"\u0000\u0014\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0004\u001a\u001a\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00030\u0002\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00030\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0004\u0010\u0005"}, d2 = {"Lak1;", "Lq07;", "", "Lcom/strmr/ps/data/repository/EpisodeRating;", "", "(Lak1;)Lq07;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.EpisodeRatingsRepository$getRatings$2$2", f = "EpisodeRatingsRepository.kt", i = {0}, l = {NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED, NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED}, m = "invokeSuspend", n = {"trakt"}, s = {"L$0"}) @vx8 public static final class C01002 extends SuspendLambda implements gr3, ? extends List>>, Object> { final /* synthetic */ String $imdbId; final /* synthetic */ int $totalSeasons; private /* synthetic */ Object L$0; int label; final /* synthetic */ EpisodeRatingsRepository this$0; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C01002(int i, EpisodeRatingsRepository episodeRatingsRepository, String str, Continuation continuation) { super(2, continuation); this.$totalSeasons = i; this.this$0 = episodeRatingsRepository; this.$imdbId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { C01002 c01002 = new C01002(this.$totalSeasons, this.this$0, this.$imdbId, continuation); c01002.L$0 = obj; return c01002; } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation, ? extends List>> continuation) { return ((C01002) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { List list; List list2; ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); ak1 ak1Var = (ak1) this.L$0; dp4 dp4Var = new dp4(1, this.$totalSeasons, 1); EpisodeRatingsRepository episodeRatingsRepository = this.this$0; String str = this.$imdbId; ArrayList arrayList = new ArrayList(y41.p(dp4Var, 10)); Iterator it = dp4Var.iterator(); while (((cp4) it).c) { arrayList.add(wj0.a(ak1Var, null, new EpisodeRatingsRepository$getRatings$2$2$omdb$1$1(episodeRatingsRepository, str, ((to4) it).nextInt(), null), 3)); } dp4 dp4Var2 = new dp4(1, this.$totalSeasons, 1); EpisodeRatingsRepository episodeRatingsRepository2 = this.this$0; String str2 = this.$imdbId; ArrayList arrayList2 = new ArrayList(y41.p(dp4Var2, 10)); Iterator it2 = dp4Var2.iterator(); while (((cp4) it2).c) { arrayList2.add(wj0.a(ak1Var, null, new EpisodeRatingsRepository$getRatings$2$2$trakt$1$1(episodeRatingsRepository2, str2, ((to4) it2).nextInt(), null), 3)); } this.L$0 = arrayList2; this.label = 1; obj = i50.a(arrayList, this); if (obj != ck1Var) { list = arrayList2; } return ck1Var; } if (i != 1) { if (i != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } list2 = (List) this.L$0; s38.b(obj); return new q07(list2, y41.ac((Iterable) obj)); } list = (List) this.L$0; s38.b(obj); ArrayList arrayListAc = y41.ac((Iterable) obj); this.L$0 = arrayListAc; this.label = 2; Object objA = i50.a(list, this); if (objA != ck1Var) { list2 = arrayListAc; obj = objA; return new q07(list2, y41.ac((Iterable) obj)); } return ck1Var; } } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(String str, int i, Continuation continuation) { super(2, continuation); this.$imdbId = str; this.$totalSeasons = i; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return EpisodeRatingsRepository.this.new AnonymousClass2(this.$imdbId, this.$totalSeasons, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((AnonymousClass2) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); List list = (List) EpisodeRatingsRepository.this.cache.get(this.$imdbId); if (list != null) { return list; } C01002 c01002 = new C01002(this.$totalSeasons, EpisodeRatingsRepository.this, this.$imdbId, null); this.label = 1; obj = bk1.c(c01002, this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } q07 q07Var = (q07) obj; List list2 = (List) q07Var.a; List list3 = (List) q07Var.b; List list4 = list2; int iH = wo5.h(y41.p(list4, 10)); if (iH < 16) { iH = 16; } LinkedHashMap linkedHashMap = new LinkedHashMap(iH); for (Object obj2 : list4) { EpisodeRating episodeRating = (EpisodeRating) obj2; linkedHashMap.put(episodeRating.getSeason() + "-" + episodeRating.getEpisode(), obj2); } List list5 = list3; ArrayList arrayList = new ArrayList(y41.p(list5, 10)); for (EpisodeRating episodeRating2 : list5) { EpisodeRating episodeRating3 = (EpisodeRating) linkedHashMap.get(episodeRating2.getSeason() + "-" + episodeRating2.getEpisode()); if (episodeRating3 == null || episodeRating3.getRating() == null) { episodeRating2.getRating(); } else { episodeRating2 = episodeRating3; } arrayList.add(episodeRating2); } if (!arrayList.isEmpty()) { list2 = arrayList; } List list6 = list2; EpisodeRatingsRepository.this.cache.put(this.$imdbId, list6); return list6; } } @Inject public EpisodeRatingsRepository(@kp6 OMDbApiService oMDbApiService, @kp6 TraktApiService traktApiService) { cr4.g(oMDbApiService, "omDbApiService"); cr4.g(traktApiService, "traktApiService"); this.omDbApiService = oMDbApiService; this.traktApiService = traktApiService; this.cache = new LruCache<>(10); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Removed duplicated region for block: B:7:0x001b */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object fetchOmdbSeason(String str, int i, Continuation> continuation) { AnonymousClass1 anonymousClass1; int i2; OMDbSeasonResponse oMDbSeasonResponse; List episodes; Integer numBe; String str2 = str; if (continuation instanceof AnonymousClass1) { anonymousClass1 = (AnonymousClass1) continuation; int i3 = anonymousClass1.label; if ((i3 & Integer.MIN_VALUE) != 0) { anonymousClass1.label = i3 - Integer.MIN_VALUE; } else { anonymousClass1 = new AnonymousClass1(continuation); } } Object seasonRatings = anonymousClass1.result; ck1 ck1Var = ck1.a; int i4 = anonymousClass1.label; ik2 ik2Var = ik2.a; if (i4 == 0) { s38.b(seasonRatings); try { OMDbApiService oMDbApiService = this.omDbApiService; anonymousClass1.L$0 = str2; anonymousClass1.I$0 = i; anonymousClass1.label = 1; seasonRatings = oMDbApiService.getSeasonRatings("45757c20", str2, i, anonymousClass1); if (seasonRatings == ck1Var) { return ck1Var; } i2 = i; oMDbSeasonResponse = (OMDbSeasonResponse) seasonRatings; if (cr4.b(oMDbSeasonResponse.getResponse(), "True")) { } return ik2Var; } catch (Exception e) { e = e; i2 = i; } } else { if (i4 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } int i5 = anonymousClass1.I$0; String str3 = (String) anonymousClass1.L$0; try { s38.b(seasonRatings); i2 = i5; str2 = str3; try { oMDbSeasonResponse = (OMDbSeasonResponse) seasonRatings; if (cr4.b(oMDbSeasonResponse.getResponse(), "True") || (episodes = oMDbSeasonResponse.getEpisodes()) == null) { return ik2Var; } ArrayList arrayList = new ArrayList(); for (OMDbEpisode oMDbEpisode : episodes) { String episode = oMDbEpisode.getEpisode(); if (episode != null && (numBe = n89.be(episode)) != null) { int iIntValue = numBe.intValue(); String imdbRating = oMDbEpisode.getImdbRating(); episodeRating = new EpisodeRating(i2, iIntValue, imdbRating != null ? n89.bd(imdbRating) : null, oMDbEpisode.getTitle(), null, 16, null); } if (episodeRating != null) { arrayList.add(episodeRating); } } return arrayList; } catch (Exception e2) { e = e2; } } catch (Exception e3) { e = e3; i2 = i5; str2 = str3; } } Log.e(TAG, "Failed to fetch OMDb season " + i2 + " for " + str2, e); return ik2Var; } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:36:0x0092 */ /* JADX WARN: Removed duplicated region for block: B:8:0x0014 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object fetchTraktSeason(String str, int i, Continuation> continuation) { C03251 c03251; TraktApiService traktApiService; Exception exc; if (continuation instanceof C03251) { c03251 = (C03251) continuation; int i2 = c03251.label; if ((i2 & Integer.MIN_VALUE) != 0) { c03251.label = i2 - Integer.MIN_VALUE; } else { c03251 = new C03251(continuation); } } C03251 c032512 = c03251; Object seasonEpisodes$default = c032512.result; ck1 ck1Var = ck1.a; int i3 = c032512.label; if (i3 == 0) { s38.b(seasonEpisodes$default); try { traktApiService = this.traktApiService; c032512.L$0 = str; c032512.I$0 = i; c032512.label = 1; } catch (Exception e) { e = e; exc = e; Log.e(TAG, "Failed to fetch Trakt season " + i + " for " + str, exc); return ik2.a; } try { seasonEpisodes$default = TraktApiService.DefaultImpls.getSeasonEpisodes$default(traktApiService, str, i, null, c032512, 4, null); if (seasonEpisodes$default == ck1Var) { return ck1Var; } str = str; i = i; } catch (Exception e2) { exc = e2; str = str; i = i; Log.e(TAG, "Failed to fetch Trakt season " + i + " for " + str, exc); return ik2.a; } } else { if (i3 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } i = c032512.I$0; str = (String) c032512.L$0; try { s38.b(seasonEpisodes$default); } catch (Exception e3) { e = e3; exc = e; Log.e(TAG, "Failed to fetch Trakt season " + i + " for " + str, exc); return ik2.a; } } ArrayList arrayList = new ArrayList(); for (TraktEpisodeFull traktEpisodeFull : (List) seasonEpisodes$default) { Integer number = traktEpisodeFull.getNumber(); EpisodeRating episodeRating = null; if (number != null) { int iIntValue = number.intValue(); Double rating = traktEpisodeFull.getRating(); if (rating != null) { Float fBoxFloat = Boxing.boxFloat((float) rating.doubleValue()); Float f = fBoxFloat.floatValue() > 0.0f ? fBoxFloat : null; Integer season = traktEpisodeFull.getSeason(); episodeRating = new EpisodeRating(season != null ? season.intValue() : i, iIntValue, f, traktEpisodeFull.getTitle(), RatingSource.TRAKT); } } if (episodeRating != null) { arrayList.add(episodeRating); } } return arrayList; } @pq6 public final Object getRatings(@kp6 String str, int i, @kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new AnonymousClass2(str, i, null), continuation); } }