package com.strmr.ps.data.service; import android.util.LruCache; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.upstream.CmcdData; import androidx.media3.session.legacy.PlaybackStateCompat; import com.google.android.gms.common.internal.ImagesContract; import com.strmr.ps.data.model.DebridError; import com.strmr.ps.data.model.DebridProvider; import com.strmr.ps.data.model.StreamInfo; import com.strmr.ps.data.model.addon.InstalledAddon; import com.strmr.ps.data.remote.AddonStreamClient; import com.strmr.ps.data.remote.model.stremio.BehaviorHints; import com.strmr.ps.data.remote.model.stremio.ProxyHeaders; import com.strmr.ps.data.remote.model.stremio.StremioStream; import com.strmr.ps.data.repository.AddonRepository; import com.strmr.ps.data.repository.AllDebridRepository; import com.strmr.ps.data.repository.IDebridProvider; import com.strmr.ps.data.repository.LinkFilterPreferences; import com.strmr.ps.data.repository.PreferencesRepository; import com.strmr.ps.data.repository.PremiumizeRepository; import com.strmr.ps.data.repository.RealDebridRepository; import com.strmr.ps.data.repository.TorBoxRepository; import defpackage.bk1; import defpackage.ck1; import defpackage.cr4; import defpackage.dd; import defpackage.dr4; import defpackage.e6a; import defpackage.ed; import defpackage.fd; import defpackage.fi7; import defpackage.gd; import defpackage.gj1; import defpackage.h32; import defpackage.hd; import defpackage.id; import defpackage.io6; import defpackage.j43; import defpackage.jd; import defpackage.k63; import defpackage.kc8; import defpackage.kd; import defpackage.kp6; import defpackage.kq; import defpackage.ld; import defpackage.m02; import defpackage.m12; import defpackage.n41; import defpackage.n89; import defpackage.nc; import defpackage.ng1; import defpackage.oc; import defpackage.od0; import defpackage.pc; import defpackage.q07; import defpackage.q38; import defpackage.qc; import defpackage.rx4; import defpackage.s38; import defpackage.sc; import defpackage.sc2; import defpackage.vw2; import defpackage.vx8; import defpackage.wj0; import defpackage.xc; import defpackage.y41; import defpackage.yc; import defpackage.zc; import defpackage.zd9; import java.io.IOException; import java.net.SocketTimeoutException; import java.net.URLEncoder; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Collection; import java.util.Date; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.LinkedHashSet; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.Set; import java.util.concurrent.CancellationException; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; import javax.inject.Inject; import javax.inject.Singleton; import kotlin.Metadata; import kotlin.coroutines.jvm.internal.Boxing; import kotlin.coroutines.jvm.internal.ContinuationImpl; import retrofit2.HttpException; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u00006\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0007\u0018\u00002\u00020\u0001:\u0002\u0012\u0013BD\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\u0011\u0010\r\u001a\r\u0012\u0004\u0012\u00020\u000b0\n¢\u0006\u0002\b\f\u0012\u0006\u0010\u000f\u001a\u00020\u000e¢\u0006\u0004\b\u0010\u0010\u0011¨\u0006\u0014"}, d2 = {"Lcom/strmr/ps/data/service/AddonResolutionService;", "", "Lcom/strmr/ps/data/repository/AddonRepository;", "addonRepository", "Lcom/strmr/ps/data/remote/AddonStreamClient;", "addonStreamClient", "Lcom/strmr/ps/data/service/LinkFilterService;", "linkFilterService", "Lcom/strmr/ps/data/repository/LinkFilterPreferences;", "linkFilterPreferences", "", "Lcom/strmr/ps/data/repository/IDebridProvider;", "Lz15;", "debridProviders", "Lcom/strmr/ps/data/repository/PreferencesRepository;", "preferencesRepository", "", "(Lcom/strmr/ps/data/repository/AddonRepository;Lcom/strmr/ps/data/remote/AddonStreamClient;Lcom/strmr/ps/data/service/LinkFilterService;Lcom/strmr/ps/data/repository/LinkFilterPreferences;Ljava/util/List;Lcom/strmr/ps/data/repository/PreferencesRepository;)V", "b", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class AddonResolutionService { public final AddonRepository a; public final AddonStreamClient b; public final LinkFilterService c; public final LinkFilterPreferences d; public final List e; public final PreferencesRepository f; public final LruCache g; public final ng1 h; @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\b\u0082\b\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/strmr/ps/data/service/AddonResolutionService$a;", "", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final /* data */ class a { public final String a; public final long b; public a(String str, long j) { cr4.g(str, ImagesContract.URL); this.a = str; this.b = j; } public final boolean equals(Object obj) { if (this == obj) { return true; } if (!(obj instanceof a)) { return false; } a aVar = (a) obj; return cr4.b(this.a, aVar.a) && this.b == aVar.b; } public final int hashCode() { return Long.hashCode(this.b) + (this.a.hashCode() * 31); } public final String toString() { return "CachedLink(url=" + this.a + ", resolvedAtMs=" + this.b + ")"; } } @Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0010\t\n\u0002\b\u0002\n\u0002\u0010\b\n\u0002\b\u0005\b\u0086\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0006\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0006\u0010\u0007R\u0014\u0010\t\u001a\u00020\b8\u0002X\u0082T¢\u0006\u0006\n\u0004\b\t\u0010\nR\u0014\u0010\u000b\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u000b\u0010\u0007R\u0014\u0010\f\u001a\u00020\u00058\u0002X\u0082T¢\u0006\u0006\n\u0004\b\f\u0010\u0007¨\u0006\r"}, d2 = {"Lcom/strmr/ps/data/service/AddonResolutionService$b;", "", "", "TAG", "Ljava/lang/String;", "", "ADDON_TIMEOUT_MS", "J", "", "MAX_DEBRID_RETRIES", "I", "DEBRID_RETRY_BASE_MS", "RESOLVED_LINK_TTL_MS", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class b { } @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public /* synthetic */ class c { public static final /* synthetic */ int[] a; static { int[] iArr = new int[LinkFilterPreferences.SortMethod.values().length]; try { iArr[LinkFilterPreferences.SortMethod.QUALITY.ordinal()] = 1; } catch (NoSuchFieldError unused) { } try { iArr[LinkFilterPreferences.SortMethod.BITRATE.ordinal()] = 2; } catch (NoSuchFieldError unused2) { } try { iArr[LinkFilterPreferences.SortMethod.FILE_SIZE.ordinal()] = 3; } catch (NoSuchFieldError unused3) { } try { iArr[LinkFilterPreferences.SortMethod.SEEDS.ordinal()] = 4; } catch (NoSuchFieldError unused4) { } try { iArr[LinkFilterPreferences.SortMethod.DEBRID_SERVICE.ordinal()] = 5; } catch (NoSuchFieldError unused5) { } a = iArr; } } @Inject public AddonResolutionService(@kp6 AddonRepository addonRepository, @kp6 AddonStreamClient addonStreamClient, @kp6 LinkFilterService linkFilterService, @kp6 LinkFilterPreferences linkFilterPreferences, @kp6 List list, @kp6 PreferencesRepository preferencesRepository) { cr4.g(addonRepository, "addonRepository"); cr4.g(addonStreamClient, "addonStreamClient"); cr4.g(linkFilterService, "linkFilterService"); cr4.g(linkFilterPreferences, "linkFilterPreferences"); cr4.g(list, "debridProviders"); cr4.g(preferencesRepository, "preferencesRepository"); this.a = addonRepository; this.b = addonStreamClient; this.c = linkFilterService; this.d = linkFilterPreferences; this.e = list; this.f = preferencesRepository; this.g = new LruCache(50); gj1.b bVarB = zd9.b(); m12 m12Var = sc2.a; this.h = bk1.a(gj1.b.a.c((rx4) bVarB, m02.c)); } /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public static final Object a(AddonResolutionService addonResolutionService, List list, ContinuationImpl continuationImpl) { com.strmr.ps.data.service.a aVar; List list2; ConcurrentHashMap concurrentHashMap; List list3; AddonResolutionService addonResolutionService2 = addonResolutionService; if (continuationImpl instanceof com.strmr.ps.data.service.a) { aVar = (com.strmr.ps.data.service.a) continuationImpl; int i = aVar.i; if ((i & Integer.MIN_VALUE) != 0) { aVar.i = i - Integer.MIN_VALUE; } else { aVar = new com.strmr.ps.data.service.a(addonResolutionService2, continuationImpl); } } Object obj = aVar.e; ck1 ck1Var = ck1.a; int i2 = aVar.i; if (i2 == 0) { s38.b(obj); if (!list.isEmpty()) { ArrayList arrayList = new ArrayList(); for (Object obj2 : list) { if (!n89.ab(((StreamInfo) obj2).getInfoHash())) { arrayList.add(obj2); } } if (!arrayList.isEmpty()) { int i3 = 0; if (!arrayList.isEmpty()) { Iterator it = arrayList.iterator(); int i4 = 0; while (it.hasNext()) { if (((StreamInfo) it.next()).isDirectUrl() && (i4 = i4 + 1) < 0) { y41.bl(); throw null; } } } if (!arrayList.isEmpty()) { Iterator it2 = arrayList.iterator(); while (it2.hasNext()) { if (!((StreamInfo) it2.next()).isDirectUrl() && (i3 = i3 + 1) < 0) { y41.bl(); throw null; } } } arrayList.size(); ArrayList arrayList2 = new ArrayList(y41.p(arrayList, 10)); Iterator it3 = arrayList.iterator(); while (it3.hasNext()) { String lowerCase = ((StreamInfo) it3.next()).getInfoHash().toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); arrayList2.add(lowerCase); } List listT = y41.t(arrayList2); ConcurrentHashMap concurrentHashMap2 = new ConcurrentHashMap(); com.strmr.ps.data.service.c cVar = new com.strmr.ps.data.service.c(addonResolutionService2, listT, concurrentHashMap2, null); aVar.a = addonResolutionService2; aVar.b = list; aVar.c = listT; aVar.d = concurrentHashMap2; aVar.i = 1; if (bk1.c(cVar, aVar) == ck1Var) { return ck1Var; } list2 = listT; concurrentHashMap = concurrentHashMap2; list3 = list; } } return list; } if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } ConcurrentHashMap concurrentHashMap3 = aVar.d; list2 = aVar.c; list3 = aVar.b; AddonResolutionService addonResolutionService3 = aVar.a; s38.b(obj); concurrentHashMap = concurrentHashMap3; addonResolutionService2 = addonResolutionService3; concurrentHashMap.size(); list2.size(); List list4 = list3; ArrayList arrayList3 = new ArrayList(y41.p(list4, 10)); for (StreamInfo streamInfoCopy$default : list4) { String lowerCase2 = streamInfoCopy$default.getInfoHash().toLowerCase(Locale.ROOT); cr4.f(lowerCase2, "toLowerCase(...)"); Set set = !n89.ab(lowerCase2) ? (Set) concurrentHashMap.get(lowerCase2) : null; boolean zAb = n89.ab(lowerCase2); if (set != null && !set.isEmpty()) { List listBj = y41.bj(new nc(addonResolutionService2), set); DebridProvider debridProvider = (DebridProvider) y41.z(listBj); streamInfoCopy$default = StreamInfo.copy$default(streamInfoCopy$default, null, null, null, 0L, null, null, null, null, null, null, false, null, true, debridProvider, listBj, addonResolutionService2.f.getDebridPriority(debridProvider.getServiceId()), null, false, null, false, null, null, null, null, null, null, null, false, null, null, null, null, null, false, null, null, -61441, 15, null); } else if ((!streamInfoCopy$default.isDirectUrl() || !zAb) && streamInfoCopy$default.isDirectUrl() && !zAb) { streamInfoCopy$default = StreamInfo.copy$default(streamInfoCopy$default, null, null, null, 0L, null, null, null, null, null, null, false, null, false, null, null, 100, null, false, null, false, null, null, null, null, null, null, null, false, null, null, null, null, null, false, null, null, -36865, 15, null); } arrayList3.add(streamInfoCopy$default); } return arrayList3; } public static final ArrayList b(AddonResolutionService addonResolutionService, List list, InstalledAddon installedAddon) { ProxyHeaders proxyHeaders; ArrayList arrayList = new ArrayList(); Iterator it = list.iterator(); while (it.hasNext()) { StremioStream stremioStream = (StremioStream) it.next(); StreamInfo fromExternalUrl = null; try { String url = stremioStream.getUrl(); if (url != null) { n89.bb(60, url); } stremioStream.getInfoHash(); String name = stremioStream.getName(); if (name != null) { n89.bb(80, name); } String title = stremioStream.getTitle(); if (title != null) { n89.bb(80, title); } if (stremioStream.isDirectUrl()) { StreamInfo.Companion companion = StreamInfo.INSTANCE; String url2 = stremioStream.getUrl(); cr4.d(url2); String name2 = stremioStream.getName(); String title2 = stremioStream.getTitle(); String description = stremioStream.getDescription(); BehaviorHints behaviorHints = stremioStream.getBehaviorHints(); String filename = behaviorHints != null ? behaviorHints.getFilename() : null; BehaviorHints behaviorHints2 = stremioStream.getBehaviorHints(); Long videoSize = behaviorHints2 != null ? behaviorHints2.getVideoSize() : null; String addonId = installedAddon.getAddonId(); String name3 = installedAddon.getName(); String infoHash = stremioStream.getInfoHash(); BehaviorHints behaviorHints3 = stremioStream.getBehaviorHints(); String bingeGroup = behaviorHints3 != null ? behaviorHints3.getBingeGroup() : null; BehaviorHints behaviorHints4 = stremioStream.getBehaviorHints(); fromExternalUrl = companion.parseFromDirectUrl(url2, name2, title2, description, filename, videoSize, addonId, name3, infoHash, bingeGroup, (behaviorHints4 == null || (proxyHeaders = behaviorHints4.getProxyHeaders()) == null) ? null : proxyHeaders.getRequest()); } else if (stremioStream.isTorrent()) { StreamInfo.Companion companion2 = StreamInfo.INSTANCE; String infoHash2 = stremioStream.getInfoHash(); cr4.d(infoHash2); String effectiveTitle = stremioStream.getEffectiveTitle(); Integer fileIdx = stremioStream.getFileIdx(); List sources = stremioStream.getSources(); String addonId2 = installedAddon.getAddonId(); String name4 = installedAddon.getName(); BehaviorHints behaviorHints5 = stremioStream.getBehaviorHints(); fromExternalUrl = companion2.parseFromTorrentStream(infoHash2, effectiveTitle, fileIdx, sources, addonId2, name4, behaviorHints5 != null ? behaviorHints5.getBingeGroup() : null); } else { String externalUrl = stremioStream.getExternalUrl(); if (externalUrl != null && !n89.ab(externalUrl) && cr4.b(installedAddon.getAddonId(), "community.watchhub")) { fromExternalUrl = StreamInfo.INSTANCE.parseFromExternalUrl(stremioStream.getExternalUrl(), stremioStream.getName(), stremioStream.getDescription(), installedAddon.getAddonId(), installedAddon.getName()); } } } catch (Exception e) { ExecutorService executorService = kq.a; kq.h("AddonResolutionService", "Failed to parse stream: " + e.getMessage()); } if (fromExternalUrl != null) { arrayList.add(fromExternalUrl); } } return arrayList; } /* JADX WARN: Code restructure failed: missing block: B:26:0x0092, code lost: if (r10 == r1) goto L27; */ /* JADX WARN: Code restructure failed: missing block: B:37:0x00a7, code lost: r9 = r2; r7 = null; */ /* JADX WARN: Removed duplicated region for block: B:19:0x005d */ /* JADX WARN: Removed duplicated region for block: B:25:0x0083 */ /* JADX WARN: Removed duplicated region for block: B:32:0x00a9 */ /* JADX WARN: Removed duplicated region for block: B:35:0x00b2 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:26:0x0092 -> B:28:0x0095). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. */ public static final Object c(AddonResolutionService addonResolutionService, ContinuationImpl continuationImpl) { e eVar; Collection arrayList; Iterator it; IDebridProvider iDebridProvider; Collection collection; Iterator it2; q07 q07Var; if (continuationImpl instanceof e) { eVar = (e) continuationImpl; int i = eVar.f; if ((i & Integer.MIN_VALUE) != 0) { eVar.f = i - Integer.MIN_VALUE; } else { eVar = new e(addonResolutionService, continuationImpl); } } Object apiKey = eVar.d; ck1 ck1Var = ck1.a; int i2 = eVar.f; if (i2 == 0) { s38.b(apiKey); List list = addonResolutionService.e; arrayList = new ArrayList(); it = list.iterator(); if (it.hasNext()) { } } else { if (i2 != 1) { if (i2 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } iDebridProvider = eVar.c; it2 = eVar.b; collection = eVar.a; s38.b(apiKey); String str = (String) apiKey; if (str != null) { q07Var = new q07(iDebridProvider.getProvider().getServiceId(), str); it = it2; } else { it = it2; q07Var = null; } arrayList = collection; if (q07Var != null) { arrayList.add(q07Var); } if (it.hasNext()) { return (List) arrayList; } IDebridProvider iDebridProvider2 = (IDebridProvider) it.next(); eVar.a = arrayList; eVar.b = it; eVar.c = iDebridProvider2; eVar.f = 1; Object objHasAccount = iDebridProvider2.hasAccount(eVar); if (objHasAccount != ck1Var) { it2 = it; iDebridProvider = iDebridProvider2; collection = arrayList; apiKey = objHasAccount; if (!((Boolean) apiKey).booleanValue()) { eVar.a = collection; eVar.b = it2; eVar.c = iDebridProvider; eVar.f = 2; apiKey = iDebridProvider.getApiKey(eVar); } } return ck1Var; } iDebridProvider = eVar.c; it2 = eVar.b; collection = eVar.a; s38.b(apiKey); if (!((Boolean) apiKey).booleanValue()) { } } } public static final double d(AddonResolutionService addonResolutionService, StreamInfo streamInfo, LinkFilterPreferences.SortMethod sortMethod) { addonResolutionService.getClass(); int i = c.a[sortMethod.ordinal()]; if (i == 1) { return streamInfo.getQuality().getSortOrder(); } if (i == 2) { Double estimatedBitrateMbps = streamInfo.getEstimatedBitrateMbps(); if (estimatedBitrateMbps != null) { return estimatedBitrateMbps.doubleValue(); } return 0.0d; } if (i == 3) { return streamInfo.getSizeBytes(); } if (i == 4) { return streamInfo.getSeeds() != null ? r0.intValue() : 0; } if (i == 5) { return 1000 - streamInfo.getProviderPriority(); } throw new io6(); } public static final List e(AddonResolutionService addonResolutionService, List list, Set set) { int i; LinkFilterPreferences linkFilterPreferences; LinkFilterPreferences.SortMethod sortMethod; LinkFilterPreferences.SortMethod sortMethod2; LinkFilterPreferences.SortMethod sortMethod3; AddonResolutionService addonResolutionService2; List listAu; LinkFilterPreferences linkFilterPreferences2 = addonResolutionService.d; LinkFilterPreferences.SortMethod primarySortMethod = linkFilterPreferences2.getPrimarySortMethod(); LinkFilterPreferences.SortMethod secondarySortMethod = linkFilterPreferences2.getSecondarySortMethod(); LinkFilterPreferences.SortMethod tertiarySortMethod = linkFilterPreferences2.getTertiarySortMethod(); if (list.isEmpty()) { addonResolutionService2 = addonResolutionService; linkFilterPreferences = linkFilterPreferences2; sortMethod = primarySortMethod; sortMethod2 = secondarySortMethod; sortMethod3 = tertiarySortMethod; } else { ArrayList arrayList = new ArrayList(); LinkedHashMap linkedHashMap = new LinkedHashMap(); Iterator it = list.iterator(); while (it.hasNext()) { StreamInfo streamInfo = (StreamInfo) it.next(); String strG = g(streamInfo); if (strG == null) { arrayList.add(streamInfo); } else { Object arrayList2 = linkedHashMap.get(strG); if (arrayList2 == null) { arrayList2 = new ArrayList(); linkedHashMap.put(strG, arrayList2); } ((List) arrayList2).add(streamInfo); } } LinkedHashMap linkedHashMap2 = new LinkedHashMap(); Iterator it2 = linkedHashMap.entrySet().iterator(); while (true) { i = 1; if (!it2.hasNext()) { break; } Map.Entry entry = (Map.Entry) it2.next(); if (((List) entry.getValue()).size() > 1) { linkedHashMap2.put(entry.getKey(), entry.getValue()); } } String str = "AddonResolutionService"; int i2 = 10; if (!linkedHashMap2.isEmpty()) { ExecutorService executorService = kq.a; int size = linkedHashMap2.size(); Collection collectionValues = linkedHashMap2.values(); ArrayList arrayList3 = new ArrayList(y41.p(collectionValues, 10)); Iterator it3 = collectionValues.iterator(); while (it3.hasNext()) { arrayList3.add(Integer.valueOf(((List) it3.next()).size())); } kq.h("AddonResolutionService", "dedup: " + size + " groups merging, sizes=" + arrayList3); } ArrayList arrayList4 = new ArrayList(); for (Object obj : list) { if (((StreamInfo) obj).getSizeBytes() > 0) { arrayList4.add(obj); } } LinkedHashMap linkedHashMap3 = new LinkedHashMap(); for (Object obj2 : arrayList4) { StreamInfo streamInfo2 = (StreamInfo) obj2; q07 q07Var = new q07(Long.valueOf(streamInfo2.getSizeBytes() / 10485760), streamInfo2.getQuality().getLabel()); Object arrayList5 = linkedHashMap3.get(q07Var); if (arrayList5 == null) { arrayList5 = new ArrayList(); linkedHashMap3.put(q07Var, arrayList5); } ((List) arrayList5).add(obj2); } LinkedHashMap linkedHashMap4 = new LinkedHashMap(); for (Map.Entry entry2 : linkedHashMap3.entrySet()) { if (((List) entry2.getValue()).size() > 1) { linkedHashMap4.put(entry2.getKey(), entry2.getValue()); } } Iterator it4 = linkedHashMap4.entrySet().iterator(); while (it4.hasNext()) { Map.Entry entry3 = (Map.Entry) it4.next(); q07 q07Var2 = (q07) entry3.getKey(); List list2 = (List) entry3.getValue(); List list3 = list2; ArrayList arrayList6 = new ArrayList(y41.p(list3, i2)); Iterator it5 = list3.iterator(); while (it5.hasNext()) { arrayList6.add(g((StreamInfo) it5.next())); } List listT = y41.t(arrayList6); if (listT.size() > i) { ArrayList arrayList7 = new ArrayList(y41.p(list3, 10)); Iterator it6 = list3.iterator(); while (it6.hasNext()) { StreamInfo streamInfo3 = (StreamInfo) it6.next(); String scraperName = streamInfo3.getScraperName(); LinkFilterPreferences linkFilterPreferences3 = linkFilterPreferences2; LinkedHashMap linkedHashMap5 = linkedHashMap; String strAi = y41.ai(streamInfo3.getCachedProviders(), "+", null, null, new od0(18), 30); DebridProvider debridProvider = streamInfo3.getDebridProvider(); String strBb = null; String serviceId = debridProvider != null ? debridProvider.getServiceId() : null; Iterator it7 = it4; boolean zIsCached = streamInfo3.isCached(); List list4 = list2; String infoHash = streamInfo3.getInfoHash(); LinkFilterPreferences.SortMethod sortMethod4 = secondarySortMethod; LinkFilterPreferences.SortMethod sortMethod5 = tertiarySortMethod; long sizeBytes = streamInfo3.getSizeBytes(); Iterator it8 = it6; String label = streamInfo3.getQuality().getLabel(); LinkFilterPreferences.SortMethod sortMethod6 = primarySortMethod; String strBb2 = n89.bb(60, streamInfo3.getFileName()); ArrayList arrayList8 = arrayList; String directUrl = streamInfo3.getDirectUrl(); if (directUrl != null) { strBb = n89.bb(60, directUrl); } StringBuilder sbM = fi7.m("[scr=", scraperName, "|cp=", strAi, "|prim="); sbM.append(serviceId); sbM.append("|isCached="); sbM.append(zIsCached); sbM.append("|hash='"); sbM.append(infoHash); sbM.append("'|size="); sbM.append(sizeBytes); vw2.aa(sbM, "|q=", label, "|fn=", strBb2); sbM.append("|du="); sbM.append(strBb); sbM.append("]"); arrayList7.add(sbM.toString()); linkFilterPreferences2 = linkFilterPreferences3; str = str; it4 = it7; list2 = list4; secondarySortMethod = sortMethod4; tertiarySortMethod = sortMethod5; linkedHashMap = linkedHashMap5; it6 = it8; primarySortMethod = sortMethod6; arrayList = arrayList8; } LinkFilterPreferences.SortMethod sortMethod7 = primarySortMethod; LinkFilterPreferences.SortMethod sortMethod8 = secondarySortMethod; String str2 = str; ExecutorService executorService2 = kq.a; kq.h(str2, "dedup MISS ~" + (((Number) q07Var2.a).longValue() * ((long) 10)) + "MB/" + q07Var2.b + ": " + list2.size() + " streams, keys=" + listT + ", items=" + arrayList7); str = str2; i2 = 10; linkFilterPreferences2 = linkFilterPreferences2; secondarySortMethod = sortMethod8; tertiarySortMethod = tertiarySortMethod; primarySortMethod = sortMethod7; arrayList = arrayList; i = 1; } else { i2 = 10; } } linkFilterPreferences = linkFilterPreferences2; sortMethod = primarySortMethod; sortMethod2 = secondarySortMethod; sortMethod3 = tertiarySortMethod; ArrayList arrayList9 = arrayList; LinkedHashMap linkedHashMap6 = linkedHashMap; Collection collectionValues2 = linkedHashMap6.values(); if (!(collectionValues2 instanceof Collection) || !collectionValues2.isEmpty()) { Iterator it9 = collectionValues2.iterator(); while (it9.hasNext()) { if (((List) it9.next()).size() != 1) { ArrayList arrayList10 = new ArrayList(); Iterator it10 = linkedHashMap6.entrySet().iterator(); while (it10.hasNext()) { List list5 = (List) ((Map.Entry) it10.next()).getValue(); if (list5.size() == 1) { arrayList10.add(list5.get(0)); } else { List list6 = list5; StreamInfo streamInfo4 = (StreamInfo) y41.aq(new qc(new oc()), list6); if (streamInfo4 == null) { streamInfo4 = (StreamInfo) list5.get(0); } StreamInfo streamInfo5 = streamInfo4; LinkedHashSet linkedHashSet = new LinkedHashSet(); for (StreamInfo streamInfo6 : list6) { linkedHashSet.addAll(streamInfo6.getCachedProviders()); DebridProvider debridProvider2 = streamInfo6.getDebridProvider(); if (debridProvider2 != null) { linkedHashSet.add(debridProvider2); } } List listBj = y41.bj(new pc(addonResolutionService), linkedHashSet); DebridProvider debridProvider3 = (DebridProvider) y41.ab(listBj); if (debridProvider3 == null) { debridProvider3 = streamInfo5.getDebridProvider(); } DebridProvider debridProvider4 = debridProvider3; arrayList10.add(StreamInfo.copy$default(streamInfo5, null, null, null, 0L, null, null, null, null, null, null, false, null, !listBj.isEmpty() || streamInfo5.isCached(), debridProvider4, listBj, debridProvider4 != null ? addonResolutionService.f.getDebridPriority(debridProvider4.getServiceId()) : streamInfo5.getProviderPriority(), null, false, null, false, null, null, null, null, null, null, null, false, null, null, null, null, null, false, null, null, -61441, 15, null)); } } addonResolutionService2 = addonResolutionService; listAu = y41.au(arrayList9, arrayList10); if (linkFilterPreferences.getDisableSortingForCustomAddons() || set.isEmpty()) { return y41.bj(new ld(new dd(new kd(new jd(new id(new yc(), addonResolutionService2, sortMethod), addonResolutionService2, sortMethod2), addonResolutionService2, sortMethod3))), listAu); } ArrayList arrayList11 = new ArrayList(); ArrayList arrayList12 = new ArrayList(); for (Object obj3 : listAu) { if (set.contains(((StreamInfo) obj3).getScraperId())) { arrayList11.add(obj3); } else { arrayList12.add(obj3); } } return y41.au(y41.bj(new hd(new zc(new gd(new fd(new ed(new xc(), addonResolutionService2, sortMethod), addonResolutionService2, sortMethod2), addonResolutionService2, sortMethod3))), arrayList12), arrayList11); } } } addonResolutionService2 = addonResolutionService; } listAu = list; if (linkFilterPreferences.getDisableSortingForCustomAddons()) { } return y41.bj(new ld(new dd(new kd(new jd(new id(new yc(), addonResolutionService2, sortMethod), addonResolutionService2, sortMethod2), addonResolutionService2, sortMethod3))), listAu); } public static String g(StreamInfo streamInfo) { String infoHash = streamInfo.getInfoHash(); Locale locale = Locale.ROOT; String lowerCase = infoHash.toLowerCase(locale); cr4.f(lowerCase, "toLowerCase(...)"); String string = n89.bg(lowerCase).toString(); if (!n89.ab(string)) { String strBb = n89.bb(40, string); if (strBb.length() >= 32) { return "h:".concat(strBb); } } String lowerCase2 = n89.bg(streamInfo.getFileName()).toString().toLowerCase(locale); cr4.f(lowerCase2, "toLowerCase(...)"); if (n89.ab(lowerCase2)) { lowerCase2 = null; } if (lowerCase2 != null) { return fi7.h("f:", lowerCase2, "|", streamInfo.getQuality().getLabel()); } if (streamInfo.getSizeBytes() <= 0) { return null; } return "s:" + ((streamInfo.getSizeBytes() + PlaybackStateCompat.ACTION_SET_PLAYBACK_SPEED) / 8388608) + "|" + streamInfo.getQuality().getLabel(); } /* JADX WARN: Can't wrap try/catch for region: R(13:97|215|98|(1:100)(1:101)|102|103|104|105|225|106|(3:108|109|(1:112))(0)|131|200) */ /* JADX WARN: Can't wrap try/catch for region: R(5:92|93|213|94|(13:97|215|98|(1:100)(1:101)|102|103|104|105|225|106|(3:108|109|(1:112))(0)|131|200)) */ /* JADX WARN: Code restructure failed: missing block: B:116:0x0432, code lost: r0 = e; */ /* JADX WARN: Code restructure failed: missing block: B:117:0x0433, code lost: r5 = r18; */ /* JADX WARN: Code restructure failed: missing block: B:121:0x043d, code lost: r0 = e; */ /* JADX WARN: Code restructure failed: missing block: B:122:0x043e, code lost: r17 = r7; */ /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Not initialized variable reg: 10, insn: 0x0074: MOVE (r15 I:??[OBJECT, ARRAY]) = (r10 I:??[OBJECT, ARRAY]), block:B:16:0x0063 */ /* JADX WARN: Not initialized variable reg: 12, insn: 0x006f: MOVE (r2 I:??[long, double]) = (r12 I:??[long, double]), block:B:16:0x0063 */ /* JADX WARN: Not initialized variable reg: 14, insn: 0x0070: MOVE (r13 I:??[OBJECT, ARRAY]) = (r14 I:??[OBJECT, ARRAY]), block:B:16:0x0063 */ /* JADX WARN: Not initialized variable reg: 15, insn: 0x0071: MOVE (r14 I:??[OBJECT, ARRAY]) = (r15 I:??[OBJECT, ARRAY]), block:B:16:0x0063 */ /* JADX WARN: Not initialized variable reg: 3, insn: 0x0063: MOVE (r1 I:??[OBJECT, ARRAY]) = (r3 I:??[OBJECT, ARRAY]), block:B:16:0x0063 */ /* JADX WARN: Path cross not found for [B:134:0x04a2, B:91:0x0367], limit reached: 218 */ /* JADX WARN: Removed duplicated region for block: B:100:0x03b2 */ /* JADX WARN: Removed duplicated region for block: B:101:0x03b5 */ /* JADX WARN: Removed duplicated region for block: B:108:0x03e2 A[Catch: Exception -> 0x0432, TRY_LEAVE, TryCatch #8 {Exception -> 0x0432, blocks: (B:106:0x03cb, B:108:0x03e2, B:148:0x0506, B:150:0x051d, B:175:0x0609, B:177:0x0620), top: B:225:0x03cb }] */ /* JADX WARN: Removed duplicated region for block: B:118:0x0436 A[PHI: r1 r2 r4 r6 r10 r12 r14 r15 r16 r17 r18 r25 0x0436: PHI (r1v14 com.strmr.ps.data.model.DebridProvider) = (r1v6 com.strmr.ps.data.model.DebridProvider) (r1v7 com.strmr.ps.data.model.DebridProvider) (r1v15 com.strmr.ps.data.model.DebridProvider) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r2v12 ??) = (r2v67 ??), (r2v68 ??), (r2v69 ??) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r4v11 ??) = (r4v51 ??), (r4v52 ??), (r4v53 ??) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r6v8 ??) = (r6v58 ??), (r6v59 ??), (r6v60 ??) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r10v8 com.strmr.ps.data.service.d) = (r10v4 com.strmr.ps.data.service.d), (r10v5 com.strmr.ps.data.service.d), (r10v9 com.strmr.ps.data.service.d) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r12v8 ??) = (r12v52 ??), (r12v53 ??), (r12v54 ??) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r14v8 java.lang.String) = (r14v3 java.lang.String), (r14v4 java.lang.String), (r14v9 java.lang.String) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r15v7 java.lang.String) = (r15v3 java.lang.String), (r15v4 java.lang.String), (r15v8 java.lang.String) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r16v7 e6a) = (r16v3 e6a), (r16v4 e6a), (r16v8 e6a) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r17v5 java.lang.String) = (r17v1 java.lang.String), (r17v2 java.lang.String), (r17v8 java.lang.String) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r18v2 ck1) = (r18v0 ck1), (r18v1 ck1), (r18v3 ck1) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE] 0x0436: PHI (r25v6 ??) = (r25v39 ??), (r25v40 ??), (r25v41 ??) binds: [B:176:0x061e, B:149:0x051b, B:107:0x03e0] A[DONT_GENERATE, DONT_INLINE]] */ /* JADX WARN: Removed duplicated region for block: B:144:0x04f1 */ /* JADX WARN: Removed duplicated region for block: B:145:0x04f2 */ /* JADX WARN: Removed duplicated region for block: B:150:0x051d A[Catch: Exception -> 0x0432, TRY_LEAVE, TryCatch #8 {Exception -> 0x0432, blocks: (B:106:0x03cb, B:108:0x03e2, B:148:0x0506, B:150:0x051d, B:175:0x0609, B:177:0x0620), top: B:225:0x03cb }] */ /* JADX WARN: Removed duplicated region for block: B:171:0x05f4 */ /* JADX WARN: Removed duplicated region for block: B:172:0x05f5 */ /* JADX WARN: Removed duplicated region for block: B:177:0x0620 A[Catch: Exception -> 0x0432, TRY_LEAVE, TryCatch #8 {Exception -> 0x0432, blocks: (B:106:0x03cb, B:108:0x03e2, B:148:0x0506, B:150:0x051d, B:175:0x0609, B:177:0x0620), top: B:225:0x03cb }] */ /* JADX WARN: Removed duplicated region for block: B:207:0x074b */ /* JADX WARN: Removed duplicated region for block: B:69:0x02bd */ /* JADX WARN: Removed duplicated region for block: B:7:0x0019 */ /* JADX WARN: Removed duplicated region for block: B:87:0x033b */ /* JADX WARN: Removed duplicated region for block: B:88:0x035f */ /* JADX WARN: Type inference failed for: r0v10, types: [com.strmr.ps.data.repository.TorBoxRepository] */ /* JADX WARN: Type inference failed for: r0v120, types: [java.lang.StringBuilder] */ /* JADX WARN: Type inference failed for: r0v160 */ /* JADX WARN: Type inference failed for: r0v19, types: [com.strmr.ps.data.repository.AllDebridRepository] */ /* JADX WARN: Type inference failed for: r0v32, types: [com.strmr.ps.data.repository.RealDebridRepository] */ /* JADX WARN: Type inference failed for: r0v36 */ /* JADX WARN: Type inference failed for: r0v4 */ /* JADX WARN: Type inference failed for: r0v50, types: [com.strmr.ps.data.repository.PremiumizeRepository] */ /* JADX WARN: Type inference failed for: r0v55, types: [com.strmr.ps.data.repository.TorBoxRepository] */ /* JADX WARN: Type inference failed for: r0v68, types: [com.strmr.ps.data.repository.AllDebridRepository] */ /* JADX WARN: Type inference failed for: r0v82, types: [com.strmr.ps.data.repository.RealDebridRepository] */ /* JADX WARN: Type inference failed for: r12v1 */ /* JADX WARN: Type inference failed for: r12v10, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r12v11 */ /* JADX WARN: Type inference failed for: r12v12 */ /* JADX WARN: Type inference failed for: r12v13 */ /* JADX WARN: Type inference failed for: r12v14 */ /* JADX WARN: Type inference failed for: r12v15 */ /* JADX WARN: Type inference failed for: r12v16 */ /* JADX WARN: Type inference failed for: r12v17 */ /* JADX WARN: Type inference failed for: r12v18 */ /* JADX WARN: Type inference failed for: r12v19, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r12v2 */ /* JADX WARN: Type inference failed for: r12v20 */ /* JADX WARN: Type inference failed for: r12v21 */ /* JADX WARN: Type inference failed for: r12v22 */ /* JADX WARN: Type inference failed for: r12v23 */ /* JADX WARN: Type inference failed for: r12v24 */ /* JADX WARN: Type inference failed for: r12v27 */ /* JADX WARN: Type inference failed for: r12v3, types: [long] */ /* JADX WARN: Type inference failed for: r12v30 */ /* JADX WARN: Type inference failed for: r12v31 */ /* JADX WARN: Type inference failed for: r12v33, types: [long] */ /* JADX WARN: Type inference failed for: r12v34, types: [long] */ /* JADX WARN: Type inference failed for: r12v36, types: [long] */ /* JADX WARN: Type inference failed for: r12v37, types: [long] */ /* JADX WARN: Type inference failed for: r12v39, types: [long] */ /* JADX WARN: Type inference failed for: r12v4, types: [long] */ /* JADX WARN: Type inference failed for: r12v40, types: [long] */ /* JADX WARN: Type inference failed for: r12v42 */ /* JADX WARN: Type inference failed for: r12v43 */ /* JADX WARN: Type inference failed for: r12v44 */ /* JADX WARN: Type inference failed for: r12v45 */ /* JADX WARN: Type inference failed for: r12v46 */ /* JADX WARN: Type inference failed for: r12v47 */ /* JADX WARN: Type inference failed for: r12v48 */ /* JADX WARN: Type inference failed for: r12v49 */ /* JADX WARN: Type inference failed for: r12v5 */ /* JADX WARN: Type inference failed for: r12v50 */ /* JADX WARN: Type inference failed for: r12v51 */ /* JADX WARN: Type inference failed for: r12v52 */ /* JADX WARN: Type inference failed for: r12v53 */ /* JADX WARN: Type inference failed for: r12v54 */ /* JADX WARN: Type inference failed for: r12v55 */ /* JADX WARN: Type inference failed for: r12v56 */ /* JADX WARN: Type inference failed for: r12v6 */ /* JADX WARN: Type inference failed for: r12v7 */ /* JADX WARN: Type inference failed for: r12v8 */ /* JADX WARN: Type inference failed for: r12v9, types: [long] */ /* JADX WARN: Type inference failed for: r13v1 */ /* JADX WARN: Type inference failed for: r13v10 */ /* JADX WARN: Type inference failed for: r13v21 */ /* JADX WARN: Type inference failed for: r13v22 */ /* JADX WARN: Type inference failed for: r13v6 */ /* JADX WARN: Type inference failed for: r13v9 */ /* JADX WARN: Type inference failed for: r19v10 */ /* JADX WARN: Type inference failed for: r19v11 */ /* JADX WARN: Type inference failed for: r19v12 */ /* JADX WARN: Type inference failed for: r19v2 */ /* JADX WARN: Type inference failed for: r19v3 */ /* JADX WARN: Type inference failed for: r19v4 */ /* JADX WARN: Type inference failed for: r19v5 */ /* JADX WARN: Type inference failed for: r19v6 */ /* JADX WARN: Type inference failed for: r19v7 */ /* JADX WARN: Type inference failed for: r19v8 */ /* JADX WARN: Type inference failed for: r19v9 */ /* JADX WARN: Type inference failed for: r20v1 */ /* JADX WARN: Type inference failed for: r22v2 */ /* JADX WARN: Type inference failed for: r23v1 */ /* JADX WARN: Type inference failed for: r25v0, types: [kotlin.coroutines.jvm.internal.ContinuationImpl] */ /* JADX WARN: Type inference failed for: r25v1 */ /* JADX WARN: Type inference failed for: r25v10 */ /* JADX WARN: Type inference failed for: r25v11 */ /* JADX WARN: Type inference failed for: r25v12 */ /* JADX WARN: Type inference failed for: r25v13 */ /* JADX WARN: Type inference failed for: r25v14 */ /* JADX WARN: Type inference failed for: r25v15 */ /* JADX WARN: Type inference failed for: r25v16 */ /* JADX WARN: Type inference failed for: r25v17 */ /* JADX WARN: Type inference failed for: r25v18 */ /* JADX WARN: Type inference failed for: r25v19 */ /* JADX WARN: Type inference failed for: r25v2, types: [boolean] */ /* JADX WARN: Type inference failed for: r25v20 */ /* JADX WARN: Type inference failed for: r25v21 */ /* JADX WARN: Type inference failed for: r25v22 */ /* JADX WARN: Type inference failed for: r25v23 */ /* JADX WARN: Type inference failed for: r25v24 */ /* JADX WARN: Type inference failed for: r25v25 */ /* JADX WARN: Type inference failed for: r25v26 */ /* JADX WARN: Type inference failed for: r25v27 */ /* JADX WARN: Type inference failed for: r25v28 */ /* JADX WARN: Type inference failed for: r25v29 */ /* JADX WARN: Type inference failed for: r25v3, types: [boolean] */ /* JADX WARN: Type inference failed for: r25v30 */ /* JADX WARN: Type inference failed for: r25v31 */ /* JADX WARN: Type inference failed for: r25v32 */ /* JADX WARN: Type inference failed for: r25v33 */ /* JADX WARN: Type inference failed for: r25v34 */ /* JADX WARN: Type inference failed for: r25v35 */ /* JADX WARN: Type inference failed for: r25v36 */ /* JADX WARN: Type inference failed for: r25v37 */ /* JADX WARN: Type inference failed for: r25v38 */ /* JADX WARN: Type inference failed for: r25v39 */ /* JADX WARN: Type inference failed for: r25v4 */ /* JADX WARN: Type inference failed for: r25v40 */ /* JADX WARN: Type inference failed for: r25v41 */ /* JADX WARN: Type inference failed for: r25v42 */ /* JADX WARN: Type inference failed for: r25v43 */ /* JADX WARN: Type inference failed for: r25v5 */ /* JADX WARN: Type inference failed for: r25v6 */ /* JADX WARN: Type inference failed for: r25v7, types: [boolean] */ /* JADX WARN: Type inference failed for: r25v8 */ /* JADX WARN: Type inference failed for: r25v9 */ /* JADX WARN: Type inference failed for: r2v0, types: [long] */ /* JADX WARN: Type inference failed for: r2v1 */ /* JADX WARN: Type inference failed for: r2v10 */ /* JADX WARN: Type inference failed for: r2v11 */ /* JADX WARN: Type inference failed for: r2v12 */ /* JADX WARN: Type inference failed for: r2v13, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v14, types: [long] */ /* JADX WARN: Type inference failed for: r2v15 */ /* JADX WARN: Type inference failed for: r2v16 */ /* JADX WARN: Type inference failed for: r2v17 */ /* JADX WARN: Type inference failed for: r2v18 */ /* JADX WARN: Type inference failed for: r2v19 */ /* JADX WARN: Type inference failed for: r2v2 */ /* JADX WARN: Type inference failed for: r2v20 */ /* JADX WARN: Type inference failed for: r2v21 */ /* JADX WARN: Type inference failed for: r2v22 */ /* JADX WARN: Type inference failed for: r2v23 */ /* JADX WARN: Type inference failed for: r2v24, types: [long] */ /* JADX WARN: Type inference failed for: r2v28 */ /* JADX WARN: Type inference failed for: r2v29 */ /* JADX WARN: Type inference failed for: r2v30 */ /* JADX WARN: Type inference failed for: r2v31 */ /* JADX WARN: Type inference failed for: r2v32 */ /* JADX WARN: Type inference failed for: r2v33 */ /* JADX WARN: Type inference failed for: r2v34 */ /* JADX WARN: Type inference failed for: r2v37 */ /* JADX WARN: Type inference failed for: r2v38 */ /* JADX WARN: Type inference failed for: r2v4 */ /* JADX WARN: Type inference failed for: r2v42, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v44, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v48, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v5, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v50, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v54, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v56, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v6, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r2v60 */ /* JADX WARN: Type inference failed for: r2v61 */ /* JADX WARN: Type inference failed for: r2v62 */ /* JADX WARN: Type inference failed for: r2v63 */ /* JADX WARN: Type inference failed for: r2v64 */ /* JADX WARN: Type inference failed for: r2v65 */ /* JADX WARN: Type inference failed for: r2v66 */ /* JADX WARN: Type inference failed for: r2v67 */ /* JADX WARN: Type inference failed for: r2v68 */ /* JADX WARN: Type inference failed for: r2v69 */ /* JADX WARN: Type inference failed for: r2v7 */ /* JADX WARN: Type inference failed for: r2v70 */ /* JADX WARN: Type inference failed for: r2v71 */ /* JADX WARN: Type inference failed for: r2v9 */ /* JADX WARN: Type inference failed for: r4v10 */ /* JADX WARN: Type inference failed for: r4v11 */ /* JADX WARN: Type inference failed for: r4v12, types: [int] */ /* JADX WARN: Type inference failed for: r4v14, types: [int] */ /* JADX WARN: Type inference failed for: r4v15 */ /* JADX WARN: Type inference failed for: r4v16 */ /* JADX WARN: Type inference failed for: r4v18 */ /* JADX WARN: Type inference failed for: r4v21, types: [int] */ /* JADX WARN: Type inference failed for: r4v24 */ /* JADX WARN: Type inference failed for: r4v25 */ /* JADX WARN: Type inference failed for: r4v26 */ /* JADX WARN: Type inference failed for: r4v27 */ /* JADX WARN: Type inference failed for: r4v3 */ /* JADX WARN: Type inference failed for: r4v32 */ /* JADX WARN: Type inference failed for: r4v33 */ /* JADX WARN: Type inference failed for: r4v34 */ /* JADX WARN: Type inference failed for: r4v35 */ /* JADX WARN: Type inference failed for: r4v36 */ /* JADX WARN: Type inference failed for: r4v37 */ /* JADX WARN: Type inference failed for: r4v38 */ /* JADX WARN: Type inference failed for: r4v39 */ /* JADX WARN: Type inference failed for: r4v40 */ /* JADX WARN: Type inference failed for: r4v41 */ /* JADX WARN: Type inference failed for: r4v42 */ /* JADX WARN: Type inference failed for: r4v45 */ /* JADX WARN: Type inference failed for: r4v46 */ /* JADX WARN: Type inference failed for: r4v47 */ /* JADX WARN: Type inference failed for: r4v48 */ /* JADX WARN: Type inference failed for: r4v49 */ /* JADX WARN: Type inference failed for: r4v50 */ /* JADX WARN: Type inference failed for: r4v51 */ /* JADX WARN: Type inference failed for: r4v52 */ /* JADX WARN: Type inference failed for: r4v53 */ /* JADX WARN: Type inference failed for: r4v54 */ /* JADX WARN: Type inference failed for: r4v55 */ /* JADX WARN: Type inference failed for: r4v7, types: [int] */ /* JADX WARN: Type inference failed for: r4v8, types: [int] */ /* JADX WARN: Type inference failed for: r4v9 */ /* JADX WARN: Type inference failed for: r6v0, types: [int] */ /* JADX WARN: Type inference failed for: r6v1 */ /* JADX WARN: Type inference failed for: r6v10, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r6v11 */ /* JADX WARN: Type inference failed for: r6v12 */ /* JADX WARN: Type inference failed for: r6v13 */ /* JADX WARN: Type inference failed for: r6v14 */ /* JADX WARN: Type inference failed for: r6v15 */ /* JADX WARN: Type inference failed for: r6v16 */ /* JADX WARN: Type inference failed for: r6v17 */ /* JADX WARN: Type inference failed for: r6v18 */ /* JADX WARN: Type inference failed for: r6v19, types: [com.strmr.ps.data.service.AddonResolutionService] */ /* JADX WARN: Type inference failed for: r6v2 */ /* JADX WARN: Type inference failed for: r6v20 */ /* JADX WARN: Type inference failed for: r6v21 */ /* JADX WARN: Type inference failed for: r6v22 */ /* JADX WARN: Type inference failed for: r6v23 */ /* JADX WARN: Type inference failed for: r6v24 */ /* JADX WARN: Type inference failed for: r6v3, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v34 */ /* JADX WARN: Type inference failed for: r6v36 */ /* JADX WARN: Type inference failed for: r6v37 */ /* JADX WARN: Type inference failed for: r6v39, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v4, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v40, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v42, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v43, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v45, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v46, types: [java.util.Iterator] */ /* JADX WARN: Type inference failed for: r6v48 */ /* JADX WARN: Type inference failed for: r6v49 */ /* JADX WARN: Type inference failed for: r6v5 */ /* JADX WARN: Type inference failed for: r6v50 */ /* JADX WARN: Type inference failed for: r6v51 */ /* JADX WARN: Type inference failed for: r6v52 */ /* JADX WARN: Type inference failed for: r6v53 */ /* JADX WARN: Type inference failed for: r6v54 */ /* JADX WARN: Type inference failed for: r6v55 */ /* JADX WARN: Type inference failed for: r6v56 */ /* JADX WARN: Type inference failed for: r6v57 */ /* JADX WARN: Type inference failed for: r6v58 */ /* JADX WARN: Type inference failed for: r6v59 */ /* JADX WARN: Type inference failed for: r6v6 */ /* JADX WARN: Type inference failed for: r6v60 */ /* JADX WARN: Type inference failed for: r6v61 */ /* JADX WARN: Type inference failed for: r6v62 */ /* JADX WARN: Type inference failed for: r6v7 */ /* JADX WARN: Type inference failed for: r6v8 */ /* JADX WARN: Type inference failed for: r6v9, types: [java.util.Iterator] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:118:0x0436 -> B:131:0x0495). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:194:0x06d5 -> B:223:0x06de). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:199:0x071c -> B:200:0x071e). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:204:0x0729 -> B:201:0x0720). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:87:0x033b -> B:67:0x02b7). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object f(StreamInfo streamInfo, long j, ContinuationImpl continuationImpl) throws Throwable { d dVar; IDebridProvider iDebridProvider; IDebridProvider iDebridProvider2; String str; e6a e6aVar; ?? r4; ?? r6; long j2; ?? r2; String str2; String str3; DebridProvider debridProvider; DebridProvider debridProvider2; ?? r12; String str4; String str5; d dVar2; ?? r25; ?? r13; ?? it; String str6; ?? r62; IDebridProvider iDebridProvider3; ?? r22; DebridProvider debridProvider3; Exception e; boolean z; ?? r0; String str7; ?? r122; ?? r63; IDebridProvider iDebridProvider4; ?? r23; DebridProvider debridProvider4; Object objM138deleteByHashgIAlus; boolean zBooleanValue; ck1 ck1Var; IDebridProvider iDebridProvider5; Object objM67deleteByHashgIAlus; boolean zBooleanValue2; ?? r24; IDebridProvider iDebridProvider6; Object objM126deleteByHashgIAlus; boolean zBooleanValue3; ?? r42; Object objM112deleteMostRecent0E7RQCE; ?? r43; ?? r26; ?? r252; ?? r123; ?? r64; ?? r44; ?? r253; ?? r124; ?? r65; ?? r27; ?? r28 = j; if (continuationImpl instanceof d) { dVar = (d) continuationImpl; int i = dVar.m; if ((i & Integer.MIN_VALUE) != 0) { dVar.m = i - Integer.MIN_VALUE; } else { dVar = new d(this, continuationImpl); } } Object objHasAccount = dVar.k; dr4.c(); ck1 ck1Var2 = ck1.a; ?? r66 = dVar.m; String str8 = ")"; e6a e6aVar2 = e6a.a; try { } catch (Exception e2) { e = e2; iDebridProvider2 = iDebridProvider; str = ")"; e6aVar = e6aVar2; d dVar3 = dVar; r4 = streamInfo; r6 = r28; r2 = j2; str3 = str2; debridProvider2 = debridProvider; r12 = r66; str5 = str4; dVar2 = dVar3; ExecutorService executorService = kq.a; kq.a("AddonResolutionService", fi7.h("Cloud sanitization failed for ", iDebridProvider2.getServiceName(), ": ", e.getMessage()), e); r24 = r2; r44 = r4; r64 = r6; r123 = r12; r252 = continuationImpl; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str9 = str8; e6a e6aVar3 = e6aVar2; if (r43 == 0) { } return e6aVar3; } switch (r66) { case 0: r25 = 0; s38.b(objHasAccount); if (!this.d.getCloudSanitizationEnabled()) { ExecutorService executorService2 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: disabled in settings, skipping"); return e6aVar2; } String string = n89.bg(streamInfo.getInfoHash()).toString(); String lowerCase = n89.bg(n89.az(n89.ai(string, "magnet:?xt=urn:btih:"), "&")).toString().toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); if (n89.ab(lowerCase) || lowerCase.length() < 32) { lowerCase = null; } DebridProvider debridProvider5 = streamInfo.getDebridProvider(); String fileName = streamInfo.getFileName(); String str10 = n89.ab(fileName) ? null : fileName; ExecutorService executorService3 = kq.a; String str11 = lowerCase == null ? "(empty/invalid)" : lowerCase; Date date = new Date((long) r28); d dVar4 = dVar; String str12 = lowerCase; ?? M = fi7.m("Cloud sanitization: starting cleanup rawHash='", string, "', normalizedHash=", str11, ", targetProvider="); M.append(debridProvider5); M.append(", fileName="); M.append(str10); M.append(", resolveTimestamp="); M.append(r28); M.append(" ("); M.append(date); M.append(")"); kq.h("AddonResolutionService", M.toString()); r43 = 0; r62 = this; debridProvider2 = debridProvider5; str3 = str10; dVar2 = dVar4; str5 = str12; it = this.e.iterator(); r26 = r28; while (it.hasNext()) { IDebridProvider iDebridProvider7 = (IDebridProvider) it.next(); if (debridProvider2 == null || iDebridProvider7.getProvider() == debridProvider2) { try { } catch (Exception e3) { e = e3; ?? r19 = r26; iDebridProvider3 = iDebridProvider7; r22 = r43; dVar = dVar2; str6 = str3; debridProvider3 = debridProvider2; r13 = r19; ExecutorService executorService4 = kq.a; DebridProvider debridProvider6 = debridProvider3; d dVar5 = dVar; kq.a("AddonResolutionService", fi7.h("Cloud sanitization: ", iDebridProvider3.getServiceName(), " hasAccount() threw: ", e.getMessage()), e); z = r22 == true ? 1 : 0; iDebridProvider2 = iDebridProvider3; r0 = r25; r2 = r13; debridProvider2 = debridProvider6; str3 = str6; dVar2 = dVar5; r6 = r62; r12 = it; continuationImpl = r25; if (r0 == 0) { } } dVar2.a = r62; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = it; dVar2.f = iDebridProvider7; dVar2.i = r26; dVar2.j = r43; dVar2.m = 1; objHasAccount = iDebridProvider7.hasAccount(dVar2); if (objHasAccount != ck1Var2) { ?? r192 = r26; iDebridProvider3 = iDebridProvider7; r22 = r43; dVar = dVar2; str6 = str3; debridProvider3 = debridProvider2; r13 = r192; r62 = r62; it = it; r25 = r25; try { } catch (Exception e4) { e = e4; ExecutorService executorService42 = kq.a; DebridProvider debridProvider62 = debridProvider3; d dVar52 = dVar; kq.a("AddonResolutionService", fi7.h("Cloud sanitization: ", iDebridProvider3.getServiceName(), " hasAccount() threw: ", e.getMessage()), e); z = r22 == true ? 1 : 0; iDebridProvider2 = iDebridProvider3; r0 = r25; r2 = r13; debridProvider2 = debridProvider62; str3 = str6; dVar2 = dVar52; r6 = r62; r12 = it; continuationImpl = r25; if (r0 == 0) { } } boolean zBooleanValue4 = ((Boolean) objHasAccount).booleanValue(); ?? r193 = r13; debridProvider2 = debridProvider3; iDebridProvider2 = iDebridProvider3; str3 = str6; dVar2 = dVar; z = r22 == true ? 1 : 0; r2 = r193; r0 = zBooleanValue4; r6 = r62; r12 = it; continuationImpl = r25; if (r0 == 0) { ExecutorService executorService5 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: skipping " + iDebridProvider2.getServiceName() + " (no account)"); r43 = z ? 1 : 0; r26 = r2; r62 = r6; it = r12; r25 = continuationImpl; while (it.hasNext()) { } } else { boolean z2 = z; r4 = (z2 ? 1 : 0) + 1; try { } catch (Exception e5) { e = e5; str = str8; e6aVar = e6aVar2; } if (iDebridProvider2 instanceof RealDebridRepository) { if (str5 != null) { ExecutorService executorService6 = kq.a; StringBuilder sb = new StringBuilder(); e6aVar = e6aVar2; sb.append("Cloud sanitization: trying RD deleteByHash for "); sb.append(str5); kq.h("AddonResolutionService", sb.toString()); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 2; objM126deleteByHashgIAlus = ((RealDebridRepository) iDebridProvider2).m126deleteByHashgIAlus(str5, dVar2); if (objM126deleteByHashgIAlus != ck1Var2) { ?? r194 = r2; iDebridProvider6 = iDebridProvider2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r194; r4 = r4; continuationImpl = continuationImpl; try { } catch (Exception e6) { e = e6; str = str8; } zBooleanValue3 = ((Boolean) (!(objM126deleteByHashgIAlus instanceof q38.b) ? Boxing.boxBoolean(continuationImpl) : objM126deleteByHashgIAlus)).booleanValue(); ExecutorService executorService7 = kq.a; boolean zB = q38.b(objM126deleteByHashgIAlus); str = str8; StringBuilder sb2 = new StringBuilder(); ck1Var = ck1Var2; sb2.append("Cloud sanitization: RD deleteByHash result: success="); sb2.append(zB); sb2.append(", found="); sb2.append(zBooleanValue3); kq.h("AddonResolutionService", sb2.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue3) { kq.h("AddonResolutionService", "Cloud sanitization: RD hash not found, falling back to deleteMostRecent"); dVar2.a = r23; dVar2.b = str5; dVar2.c = debridProvider4; dVar2.d = str7; dVar2.e = r63; dVar2.f = iDebridProvider6; dVar2.i = r122; dVar2.j = r4; dVar2.m = 3; Object objM127deleteMostRecent0E7RQCE = ((RealDebridRepository) iDebridProvider6).m127deleteMostRecent0E7RQCE(r122, str7, dVar2); ck1Var2 = ck1Var; if (objM127deleteMostRecent0E7RQCE != ck1Var2) { ExecutorService executorService8 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: RD deleteMostRecent fallback result: " + q38.b(objM127deleteMostRecent0E7RQCE)); } } ?? r195 = r63; r65 = r23; r27 = r122; r124 = r195; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; } } else { str = str8; e6aVar = e6aVar2; try { } catch (Exception e7) { e = e7; ExecutorService executorService9 = kq.a; kq.a("AddonResolutionService", fi7.h("Cloud sanitization failed for ", iDebridProvider2.getServiceName(), ": ", e.getMessage()), e); r24 = r2; r44 = r4; r64 = r6; r123 = r12; r252 = continuationImpl; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str92 = str8; e6a e6aVar32 = e6aVar2; if (r43 == 0) { } return e6aVar32; } ExecutorService executorService10 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying RD deleteMostRecent (no hash)"); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 4; Object objM127deleteMostRecent0E7RQCE2 = ((RealDebridRepository) iDebridProvider2).m127deleteMostRecent0E7RQCE(r2, str3, dVar2); if (objM127deleteMostRecent0E7RQCE2 != ck1Var2) { ?? r196 = r2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r196; ExecutorService executorService11 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: RD deleteMostRecent result: " + q38.b(objM127deleteMostRecent0E7RQCE2)); ?? r1952 = r63; r65 = r23; r27 = r122; r124 = r1952; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; } } e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } } else { str = str8; e6aVar = e6aVar2; if (iDebridProvider2 instanceof AllDebridRepository) { if (str5 != null) { ExecutorService executorService12 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying AD deleteByHash for " + str5); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 5; objM67deleteByHashgIAlus = ((AllDebridRepository) iDebridProvider2).m67deleteByHashgIAlus(str5, dVar2); if (objM67deleteByHashgIAlus != ck1Var2) { ?? r197 = r2; iDebridProvider5 = iDebridProvider2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r197; r4 = r4; continuationImpl = continuationImpl; Object objBoxBoolean = Boxing.boxBoolean(continuationImpl); if (objM67deleteByHashgIAlus instanceof q38.b) { objBoxBoolean = objM67deleteByHashgIAlus; } zBooleanValue2 = ((Boolean) objBoxBoolean).booleanValue(); ExecutorService executorService13 = kq.a; boolean zB2 = q38.b(objM67deleteByHashgIAlus); StringBuilder sb3 = new StringBuilder(); ck1Var = ck1Var2; sb3.append("Cloud sanitization: AD deleteByHash result: success="); sb3.append(zB2); sb3.append(", found="); sb3.append(zBooleanValue2); kq.h("AddonResolutionService", sb3.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue2) { kq.h("AddonResolutionService", "Cloud sanitization: AD hash not found, falling back to deleteMostRecent"); dVar2.a = r23; dVar2.b = str5; dVar2.c = debridProvider4; dVar2.d = str7; dVar2.e = r63; dVar2.f = iDebridProvider5; dVar2.i = r122; dVar2.j = r4; dVar2.m = 6; Object objM69deleteMostRecent0E7RQCE = ((AllDebridRepository) iDebridProvider5).m69deleteMostRecent0E7RQCE(r122, str7, dVar2); ck1Var2 = ck1Var; if (objM69deleteMostRecent0E7RQCE != ck1Var2) { ExecutorService executorService14 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: AD deleteMostRecent fallback result: " + q38.b(objM69deleteMostRecent0E7RQCE)); } } ?? r19522 = r63; r65 = r23; r27 = r122; r124 = r19522; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; } } else { ExecutorService executorService15 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying AD deleteMostRecent (no hash)"); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 7; Object objM69deleteMostRecent0E7RQCE2 = ((AllDebridRepository) iDebridProvider2).m69deleteMostRecent0E7RQCE(r2, str3, dVar2); if (objM69deleteMostRecent0E7RQCE2 != ck1Var2) { ?? r198 = r2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r198; ExecutorService executorService16 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: AD deleteMostRecent result: " + q38.b(objM69deleteMostRecent0E7RQCE2)); ?? r195222 = r63; r65 = r23; r27 = r122; r124 = r195222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; } } } else if (iDebridProvider2 instanceof TorBoxRepository) { if (str5 != null) { ExecutorService executorService17 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying TB deleteByHash for " + str5); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 8; objM138deleteByHashgIAlus = ((TorBoxRepository) iDebridProvider2).m138deleteByHashgIAlus(str5, dVar2); if (objM138deleteByHashgIAlus != ck1Var2) { ?? r199 = r2; iDebridProvider4 = iDebridProvider2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r199; r4 = r4; continuationImpl = continuationImpl; Object objBoxBoolean2 = Boxing.boxBoolean(continuationImpl); if (objM138deleteByHashgIAlus instanceof q38.b) { objBoxBoolean2 = objM138deleteByHashgIAlus; } zBooleanValue = ((Boolean) objBoxBoolean2).booleanValue(); ExecutorService executorService18 = kq.a; boolean zB3 = q38.b(objM138deleteByHashgIAlus); StringBuilder sb4 = new StringBuilder(); ck1Var = ck1Var2; sb4.append("Cloud sanitization: TB deleteByHash result: success="); sb4.append(zB3); sb4.append(", found="); sb4.append(zBooleanValue); kq.h("AddonResolutionService", sb4.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue) { kq.h("AddonResolutionService", "Cloud sanitization: TB hash not found, falling back to deleteMostRecent"); dVar2.a = r23; dVar2.b = str5; dVar2.c = debridProvider4; dVar2.d = str7; dVar2.e = r63; dVar2.f = iDebridProvider4; dVar2.i = r122; dVar2.j = r4; dVar2.m = 9; Object objM139deleteMostRecent0E7RQCE = ((TorBoxRepository) iDebridProvider4).m139deleteMostRecent0E7RQCE(r122, str7, dVar2); ck1Var2 = ck1Var; if (objM139deleteMostRecent0E7RQCE != ck1Var2) { ExecutorService executorService19 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: TB deleteMostRecent fallback result: " + q38.b(objM139deleteMostRecent0E7RQCE)); } } else { ck1Var2 = ck1Var; } ?? r1952222 = r63; r65 = r23; r27 = r122; r124 = r1952222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; } } else { ExecutorService executorService20 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying TB deleteMostRecent (no hash)"); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 10; Object objM139deleteMostRecent0E7RQCE2 = ((TorBoxRepository) iDebridProvider2).m139deleteMostRecent0E7RQCE(r2, str3, dVar2); if (objM139deleteMostRecent0E7RQCE2 != ck1Var2) { ?? r1910 = r2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r1910; ExecutorService executorService21 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: TB deleteMostRecent result: " + q38.b(objM139deleteMostRecent0E7RQCE2)); ?? r19522222 = r63; r65 = r23; r27 = r122; r124 = r19522222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; } } } else if (iDebridProvider2 instanceof PremiumizeRepository) { ExecutorService executorService22 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: trying PM deleteMostRecent (no hash-based method)"); dVar2.a = r6; dVar2.b = str5; dVar2.c = debridProvider2; dVar2.d = str3; dVar2.e = r12; dVar2.f = iDebridProvider2; dVar2.i = r2; dVar2.j = r4; dVar2.m = 11; objM112deleteMostRecent0E7RQCE = ((PremiumizeRepository) iDebridProvider2).m112deleteMostRecent0E7RQCE(r2, str3, dVar2); if (objM112deleteMostRecent0E7RQCE != ck1Var2) { ?? r1911 = r2; iDebridProvider6 = iDebridProvider2; r23 = r6; r63 = r12; debridProvider4 = debridProvider2; str7 = str3; r122 = r1911; r4 = r4; continuationImpl = continuationImpl; try { } catch (Exception e8) { e = e8; String str13 = str7; debridProvider2 = debridProvider4; iDebridProvider2 = iDebridProvider6; ?? r20 = r63; r6 = r23; r2 = r122; str3 = str13; r12 = r20; ExecutorService executorService92 = kq.a; kq.a("AddonResolutionService", fi7.h("Cloud sanitization failed for ", iDebridProvider2.getServiceName(), ": ", e.getMessage()), e); r24 = r2; r44 = r4; r64 = r6; r123 = r12; r252 = continuationImpl; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str922 = str8; e6a e6aVar322 = e6aVar2; if (r43 == 0) { } return e6aVar322; } ExecutorService executorService23 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: PM deleteMostRecent result: " + q38.b(objM112deleteMostRecent0E7RQCE)); ?? r195222222 = r63; r65 = r23; r27 = r122; r124 = r195222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; } } else { ExecutorService executorService24 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: no cleanup handler for " + iDebridProvider2.getServiceName() + ", skipping"); try { } catch (Exception e9) { e = e9; r4 = z2 ? 1 : 0; ExecutorService executorService922 = kq.a; kq.a("AddonResolutionService", fi7.h("Cloud sanitization failed for ", iDebridProvider2.getServiceName(), ": ", e.getMessage()), e); r24 = r2; r44 = r4; r64 = r6; r123 = r12; r252 = continuationImpl; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str9222 = str8; e6a e6aVar3222 = e6aVar2; if (r43 == 0) { } return e6aVar3222; } Boxing.boxInt(r4); r42 = z2 ? 1 : 0; r27 = r2; r65 = r6; r124 = r12; r253 = continuationImpl; } r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } } } } return ck1Var2; } } String str92222 = str8; e6a e6aVar32222 = e6aVar2; if (r43 == 0) { ExecutorService executorService25 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: no providers processed (targetProvider=" + debridProvider2 + ", total=" + r62.e.size() + str92222); } return e6aVar32222; case 1: r25 = 0; r25 = 0; int i2 = dVar.j; long j3 = dVar.i; iDebridProvider3 = dVar.f; Iterator it2 = dVar.e; str6 = dVar.d; DebridProvider debridProvider7 = dVar.c; str5 = dVar.b; AddonResolutionService addonResolutionService = dVar.a; try { s38.b(objHasAccount); debridProvider3 = debridProvider7; r13 = j3; it = it2; r62 = addonResolutionService; r22 = i2; } catch (Exception e10) { e = e10; debridProvider3 = debridProvider7; r13 = j3; it = it2; r62 = addonResolutionService; r22 = i2; ExecutorService executorService422 = kq.a; DebridProvider debridProvider622 = debridProvider3; d dVar522 = dVar; kq.a("AddonResolutionService", fi7.h("Cloud sanitization: ", iDebridProvider3.getServiceName(), " hasAccount() threw: ", e.getMessage()), e); z = r22 == true ? 1 : 0; iDebridProvider2 = iDebridProvider3; r0 = r25; r2 = r13; debridProvider2 = debridProvider622; str3 = str6; dVar2 = dVar522; r6 = r62; r12 = it; continuationImpl = r25; if (r0 == 0) { } } boolean zBooleanValue42 = ((Boolean) objHasAccount).booleanValue(); ?? r1932 = r13; debridProvider2 = debridProvider3; iDebridProvider2 = iDebridProvider3; str3 = str6; dVar2 = dVar; z = r22 == true ? 1 : 0; r2 = r1932; r0 = zBooleanValue42; r6 = r62; r12 = it; continuationImpl = r25; if (r0 == 0) { } break; case 2: continuationImpl = 0; int i3 = dVar.j; long j4 = dVar.i; iDebridProvider6 = dVar.f; Iterator it3 = dVar.e; str7 = dVar.d; DebridProvider debridProvider8 = dVar.c; String str14 = dVar.b; AddonResolutionService addonResolutionService2 = dVar.a; s38.b(objHasAccount); objM126deleteByHashgIAlus = ((q38) objHasAccount).getA(); e6aVar = e6aVar2; debridProvider4 = debridProvider8; str5 = str14; dVar2 = dVar; r4 = i3; r23 = addonResolutionService2; r63 = it3; r122 = j4; zBooleanValue3 = ((Boolean) (!(objM126deleteByHashgIAlus instanceof q38.b) ? Boxing.boxBoolean(continuationImpl) : objM126deleteByHashgIAlus)).booleanValue(); ExecutorService executorService72 = kq.a; boolean zB4 = q38.b(objM126deleteByHashgIAlus); str = str8; StringBuilder sb22 = new StringBuilder(); ck1Var = ck1Var2; sb22.append("Cloud sanitization: RD deleteByHash result: success="); sb22.append(zB4); sb22.append(", found="); sb22.append(zBooleanValue3); kq.h("AddonResolutionService", sb22.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue3) { } ?? r1952222222 = r63; r65 = r23; r27 = r122; r124 = r1952222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str922222 = str8; e6a e6aVar322222 = e6aVar2; if (r43 == 0) { } return e6aVar322222; case 3: continuationImpl = 0; int i4 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider8 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider9 = dVar.c; String str15 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a2 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider9; str5 = str15; dVar2 = dVar; r4 = i4; ExecutorService executorService26 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: RD deleteMostRecent fallback result: " + q38.b(a2)); ?? r19522222222 = r63; r65 = r23; r27 = r122; r124 = r19522222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str9222222 = str8; e6a e6aVar3222222 = e6aVar2; if (r43 == 0) { } return e6aVar3222222; case 4: continuationImpl = 0; int i5 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider9 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider10 = dVar.c; String str16 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a3 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider10; str5 = str16; dVar2 = dVar; r4 = i5; ExecutorService executorService27 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: RD deleteMostRecent result: " + q38.b(a3)); ?? r195222222222 = r63; r65 = r23; r27 = r122; r124 = r195222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str92222222 = str8; e6a e6aVar32222222 = e6aVar2; if (r43 == 0) { } return e6aVar32222222; case 5: continuationImpl = 0; int i6 = dVar.j; long j5 = dVar.i; iDebridProvider5 = dVar.f; Iterator it4 = dVar.e; str7 = dVar.d; DebridProvider debridProvider11 = dVar.c; String str17 = dVar.b; AddonResolutionService addonResolutionService3 = dVar.a; s38.b(objHasAccount); objM67deleteByHashgIAlus = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider11; str5 = str17; dVar2 = dVar; r4 = i6; r23 = addonResolutionService3; r63 = it4; r122 = j5; Object objBoxBoolean3 = Boxing.boxBoolean(continuationImpl); if (objM67deleteByHashgIAlus instanceof q38.b) { } zBooleanValue2 = ((Boolean) objBoxBoolean3).booleanValue(); ExecutorService executorService132 = kq.a; boolean zB22 = q38.b(objM67deleteByHashgIAlus); StringBuilder sb32 = new StringBuilder(); ck1Var = ck1Var2; sb32.append("Cloud sanitization: AD deleteByHash result: success="); sb32.append(zB22); sb32.append(", found="); sb32.append(zBooleanValue2); kq.h("AddonResolutionService", sb32.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue2) { } ?? r1952222222222 = r63; r65 = r23; r27 = r122; r124 = r1952222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str922222222 = str8; e6a e6aVar322222222 = e6aVar2; if (r43 == 0) { } return e6aVar322222222; case 6: continuationImpl = 0; int i7 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider10 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider12 = dVar.c; String str18 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a4 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider12; str5 = str18; dVar2 = dVar; r4 = i7; ExecutorService executorService28 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: AD deleteMostRecent fallback result: " + q38.b(a4)); ?? r19522222222222 = r63; r65 = r23; r27 = r122; r124 = r19522222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str9222222222 = str8; e6a e6aVar3222222222 = e6aVar2; if (r43 == 0) { } return e6aVar3222222222; case 7: continuationImpl = 0; int i8 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider11 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider13 = dVar.c; String str19 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a5 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider13; str5 = str19; dVar2 = dVar; r4 = i8; ExecutorService executorService29 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: AD deleteMostRecent result: " + q38.b(a5)); ?? r195222222222222 = r63; r65 = r23; r27 = r122; r124 = r195222222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str92222222222 = str8; e6a e6aVar32222222222 = e6aVar2; if (r43 == 0) { } return e6aVar32222222222; case 8: continuationImpl = 0; int i9 = dVar.j; long j6 = dVar.i; iDebridProvider4 = dVar.f; Iterator it5 = dVar.e; str7 = dVar.d; DebridProvider debridProvider14 = dVar.c; String str20 = dVar.b; AddonResolutionService addonResolutionService4 = dVar.a; s38.b(objHasAccount); objM138deleteByHashgIAlus = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider14; str5 = str20; dVar2 = dVar; r4 = i9; r23 = addonResolutionService4; r63 = it5; r122 = j6; Object objBoxBoolean22 = Boxing.boxBoolean(continuationImpl); if (objM138deleteByHashgIAlus instanceof q38.b) { } zBooleanValue = ((Boolean) objBoxBoolean22).booleanValue(); ExecutorService executorService182 = kq.a; boolean zB32 = q38.b(objM138deleteByHashgIAlus); StringBuilder sb42 = new StringBuilder(); ck1Var = ck1Var2; sb42.append("Cloud sanitization: TB deleteByHash result: success="); sb42.append(zB32); sb42.append(", found="); sb42.append(zBooleanValue); kq.h("AddonResolutionService", sb42.toString()); r23 = r23; r4 = r4; r63 = r63; r122 = r122; continuationImpl = continuationImpl; if (zBooleanValue) { } ?? r1952222222222222 = r63; r65 = r23; r27 = r122; r124 = r1952222222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str922222222222 = str8; e6a e6aVar322222222222 = e6aVar2; if (r43 == 0) { } return e6aVar322222222222; case 9: continuationImpl = 0; int i10 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider12 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider15 = dVar.c; String str21 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a6 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider15; str5 = str21; dVar2 = dVar; r4 = i10; ExecutorService executorService30 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: TB deleteMostRecent fallback result: " + q38.b(a6)); ?? r19522222222222222 = r63; r65 = r23; r27 = r122; r124 = r19522222222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str9222222222222 = str8; e6a e6aVar3222222222222 = e6aVar2; if (r43 == 0) { } return e6aVar3222222222222; case 10: continuationImpl = 0; int i11 = dVar.j; r122 = dVar.i; IDebridProvider iDebridProvider13 = dVar.f; r63 = dVar.e; str7 = dVar.d; DebridProvider debridProvider16 = dVar.c; String str22 = dVar.b; r23 = dVar.a; s38.b(objHasAccount); Object a7 = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider16; str5 = str22; dVar2 = dVar; r4 = i11; ExecutorService executorService31 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: TB deleteMostRecent result: " + q38.b(a7)); ?? r195222222222222222 = r63; r65 = r23; r27 = r122; r124 = r195222222222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str92222222222222 = str8; e6a e6aVar32222222222222 = e6aVar2; if (r43 == 0) { } return e6aVar32222222222222; case 11: int i12 = dVar.j; long j7 = dVar.i; iDebridProvider6 = dVar.f; Iterator it6 = dVar.e; str7 = dVar.d; DebridProvider debridProvider17 = dVar.c; continuationImpl = 0; String str23 = dVar.b; AddonResolutionService addonResolutionService5 = dVar.a; s38.b(objHasAccount); objM112deleteMostRecent0E7RQCE = ((q38) objHasAccount).getA(); str = ")"; e6aVar = e6aVar2; debridProvider4 = debridProvider17; str5 = str23; dVar2 = dVar; r4 = i12; r23 = addonResolutionService5; r63 = it6; r122 = j7; ExecutorService executorService232 = kq.a; kq.h("AddonResolutionService", "Cloud sanitization: PM deleteMostRecent result: " + q38.b(objM112deleteMostRecent0E7RQCE)); ?? r1952222222222222222 = r63; r65 = r23; r27 = r122; r124 = r1952222222222222222; str3 = str7; debridProvider2 = debridProvider4; r42 = r4; r253 = continuationImpl; r24 = r27; r44 = r42; r64 = r65; r123 = r124; r252 = r253; e6aVar2 = e6aVar; str8 = str; r26 = r24; r43 = r44; r62 = r64; it = r123; r25 = r252; while (it.hasNext()) { } String str922222222222222 = str8; e6a e6aVar322222222222222 = e6aVar2; if (r43 == 0) { } return e6aVar322222222222222; default: throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } } /* JADX WARN: Code restructure failed: missing block: B:7:0x001b, code lost: if (r6.size() < r0.getMinLinkCountForAutoselect()) goto L8; */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final StreamInfo h(kc8 kc8Var, boolean z, String str) { Object next; Object next2; cr4.g(kc8Var, "result"); List list = kc8Var.a; LinkFilterPreferences linkFilterPreferences = this.d; Object obj = null; if (linkFilterPreferences.getAutoselectEnabled()) { if (!z) { } if (str != null && !n89.ab(str)) { List list2 = list; Iterator it = list2.iterator(); while (true) { if (!it.hasNext()) { next = null; break; } next = it.next(); StreamInfo streamInfo = (StreamInfo) next; if (cr4.b(streamInfo.getBingeGroup(), str) && streamInfo.isCached()) { break; } } StreamInfo streamInfo2 = (StreamInfo) next; if (streamInfo2 == null) { Iterator it2 = list2.iterator(); while (true) { if (!it2.hasNext()) { next2 = null; break; } next2 = it2.next(); if (cr4.b(((StreamInfo) next2).getBingeGroup(), str)) { break; } } streamInfo2 = (StreamInfo) next2; } if (streamInfo2 != null) { return streamInfo2; } } Iterator it3 = list.iterator(); while (true) { if (!it3.hasNext()) { break; } Object next3 = it3.next(); if (((StreamInfo) next3).isCached()) { obj = next3; break; } } StreamInfo streamInfo3 = (StreamInfo) obj; return streamInfo3 == null ? (StreamInfo) y41.ab(list) : streamInfo3; } return null; } /* JADX WARN: Removed duplicated region for block: B:8:0x0016 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object i(StreamInfo streamInfo, Integer num, Integer num2, String str, DebridProvider debridProvider, boolean z, ContinuationImpl continuationImpl) { f fVar; String serviceId; Object obj; String str2; AddonResolutionService addonResolutionService; String directUrl; if (continuationImpl instanceof f) { fVar = (f) continuationImpl; int i = fVar.e; if ((i & Integer.MIN_VALUE) != 0) { fVar.e = i - Integer.MIN_VALUE; } else { fVar = new f(this, continuationImpl); } } f fVar2 = fVar; Object obj2 = fVar2.c; ck1 ck1Var = ck1.a; int i2 = fVar2.e; if (i2 == 0) { s38.b(obj2); if (streamInfo.isDirectUrl() && (directUrl = streamInfo.getDirectUrl()) != null && !n89.ab(directUrl)) { streamInfo.getDirectUrl(); return streamInfo.getDirectUrl(); } String infoHash = streamInfo.getInfoHash(); if (n89.ab(infoHash)) { return s38.a(new IllegalArgumentException("Stream has no infoHash or directUrl")); } String lowerCase = infoHash.toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); int iIntValue = num != null ? num.intValue() : -1; int iIntValue2 = num2 != null ? num2.intValue() : -1; if (debridProvider == null || (serviceId = debridProvider.getServiceId()) == null) { serviceId = ""; } StringBuilder sb = new StringBuilder(); sb.append(lowerCase); sb.append("_"); sb.append(iIntValue); sb.append("_"); sb.append(iIntValue2); String strS = n41.s(sb, "_", serviceId); a aVar = (a) this.g.get(strS); if (aVar != null) { long j = aVar.b; if (System.currentTimeMillis() - j < 1500000) { long jCurrentTimeMillis = (System.currentTimeMillis() - j) / ((long) 1000); return aVar.a; } } fVar2.a = this; fVar2.b = strS; fVar2.e = 1; Object objJ = j(streamInfo, num, num2, str, debridProvider, z, fVar2); if (objJ == ck1Var) { return ck1Var; } obj = objJ; str2 = strS; addonResolutionService = this; } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } str2 = fVar2.b; addonResolutionService = fVar2.a; s38.b(obj2); obj = ((q38) obj2).a; } if (!(obj instanceof q38.b)) { LruCache lruCache = addonResolutionService.g; s38.b(obj); lruCache.put(str2, new a((String) obj, System.currentTimeMillis())); } return obj; } /* JADX WARN: Code restructure failed: missing block: B:40:0x014b, code lost: if (r2 == r7) goto L63; */ /* JADX WARN: Removed duplicated region for block: B:51:0x018e */ /* JADX WARN: Removed duplicated region for block: B:61:0x01c8 */ /* JADX WARN: Removed duplicated region for block: B:67:0x01fc A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:68:0x01fd */ /* JADX WARN: Removed duplicated region for block: B:69:0x0200 */ /* JADX WARN: Removed duplicated region for block: B:8:0x0018 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:64:0x01f6 -> B:65:0x01f8). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:69:0x0200 -> B:49:0x0188). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object j(StreamInfo streamInfo, Integer num, Integer num2, String str, DebridProvider debridProvider, boolean z, ContinuationImpl continuationImpl) { g gVar; AddonResolutionService addonResolutionService; StreamInfo streamInfo2; Integer num3; Integer num4; String str2; DebridProvider debridProvider2; Object obj; boolean z2; DebridProvider debridProvider3; Integer num5; StreamInfo streamInfo3; AddonResolutionService addonResolutionService2; Object objK; StreamInfo streamInfo4; Integer num6; Iterator it; AddonResolutionService addonResolutionService3; String str3; Integer num7; DebridProvider debridProvider4; DebridProvider debridProvider5; Iterator it2; IDebridProvider iDebridProvider; if (continuationImpl instanceof g) { gVar = (g) continuationImpl; int i = gVar.o; if ((i & Integer.MIN_VALUE) != 0) { gVar.o = i - Integer.MIN_VALUE; } else { gVar = new g(this, continuationImpl); } } g gVar2 = gVar; Object obj2 = gVar2.m; ck1 ck1Var = ck1.a; int i2 = gVar2.o; if (i2 == 0) { s38.b(obj2); if (debridProvider != null) { gVar2.a = this; gVar2.b = streamInfo; gVar2.c = num; gVar2.d = num2; gVar2.e = str; gVar2.f = debridProvider; gVar2.l = z; gVar2.o = 1; Object objK2 = k(debridProvider, streamInfo, num, num2, str, gVar2); if (objK2 != ck1Var) { addonResolutionService = this; num4 = num2; str2 = str; debridProvider2 = debridProvider; obj = objK2; z2 = z; streamInfo2 = streamInfo; num3 = num; } return ck1Var; } addonResolutionService = this; streamInfo2 = streamInfo; num3 = num; num4 = num2; str2 = str; debridProvider2 = debridProvider; debridProvider3 = streamInfo2.getDebridProvider(); if (debridProvider3 != null || debridProvider3 == debridProvider2) { num5 = num3; streamInfo3 = streamInfo2; addonResolutionService2 = addonResolutionService; AddonResolutionService addonResolutionService4 = addonResolutionService2; streamInfo4 = streamInfo3; num6 = num5; it = y41.bj(new sc(), addonResolutionService4.e).iterator(); addonResolutionService3 = addonResolutionService4; str3 = str2; num7 = num4; while (it.hasNext()) { } return s38.a(new IllegalStateException("No debrid provider available to resolve torrent")); } gVar2.a = addonResolutionService; gVar2.b = streamInfo2; gVar2.c = num3; gVar2.d = num4; gVar2.e = str2; gVar2.f = debridProvider2; gVar2.i = debridProvider3; gVar2.o = 2; AddonResolutionService addonResolutionService5 = addonResolutionService; Integer num8 = num3; StreamInfo streamInfo5 = streamInfo2; objK = addonResolutionService5.k(debridProvider3, streamInfo5, num8, num4, str2, gVar2); addonResolutionService2 = addonResolutionService5; streamInfo3 = streamInfo5; num5 = num8; } else if (i2 == 1) { z2 = gVar2.l; debridProvider2 = gVar2.f; str2 = gVar2.e; num4 = gVar2.d; num3 = gVar2.c; streamInfo2 = gVar2.b; AddonResolutionService addonResolutionService6 = gVar2.a; s38.b(obj2); obj = ((q38) obj2).a; addonResolutionService = addonResolutionService6; } else { if (i2 == 2) { debridProvider3 = gVar2.i; debridProvider2 = gVar2.f; str2 = gVar2.e; num4 = gVar2.d; num5 = gVar2.c; streamInfo3 = gVar2.b; addonResolutionService2 = gVar2.a; s38.b(obj2); objK = ((q38) obj2).a; if (!(objK instanceof q38.b)) { return objK; } ExecutorService executorService = kq.a; kq.h("AddonResolutionService", "Preferred provider " + debridProvider3 + " failed, trying others"); AddonResolutionService addonResolutionService42 = addonResolutionService2; streamInfo4 = streamInfo3; num6 = num5; it = y41.bj(new sc(), addonResolutionService42.e).iterator(); addonResolutionService3 = addonResolutionService42; str3 = str2; num7 = num4; while (it.hasNext()) { } return s38.a(new IllegalStateException("No debrid provider available to resolve torrent")); } if (i2 != 3) { if (i2 != 4) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } Iterator it3 = gVar2.j; DebridProvider debridProvider6 = gVar2.i; DebridProvider debridProvider7 = gVar2.f; String str4 = gVar2.e; Integer num9 = gVar2.d; Integer num10 = gVar2.c; StreamInfo streamInfo6 = gVar2.b; AddonResolutionService addonResolutionService7 = gVar2.a; s38.b(obj2); Object objK3 = ((q38) obj2).a; it2 = it3; debridProvider3 = debridProvider6; addonResolutionService3 = addonResolutionService7; streamInfo4 = streamInfo6; num6 = num10; num7 = num9; str3 = str4; if (objK3 instanceof q38.b) { return objK3; } it = it2; debridProvider2 = debridProvider7; while (it.hasNext()) { IDebridProvider iDebridProvider2 = (IDebridProvider) it.next(); if (iDebridProvider2.getProvider() != debridProvider3 && iDebridProvider2.getProvider() != debridProvider2) { gVar2.a = addonResolutionService3; gVar2.b = streamInfo4; gVar2.c = num6; gVar2.d = num7; gVar2.e = str3; gVar2.f = debridProvider2; gVar2.i = debridProvider3; gVar2.j = it; gVar2.k = iDebridProvider2; gVar2.o = 3; Object objHasAccount = iDebridProvider2.hasAccount(gVar2); if (objHasAccount != ck1Var) { debridProvider4 = debridProvider2; it2 = it; obj2 = objHasAccount; debridProvider5 = debridProvider3; iDebridProvider = iDebridProvider2; if (((Boolean) obj2).booleanValue()) { it = it2; debridProvider3 = debridProvider5; debridProvider2 = debridProvider4; while (it.hasNext()) { } } else { DebridProvider provider = iDebridProvider.getProvider(); gVar2.a = addonResolutionService3; gVar2.b = streamInfo4; gVar2.c = num6; gVar2.d = num7; gVar2.e = str3; gVar2.f = debridProvider4; gVar2.i = debridProvider5; gVar2.j = it2; gVar2.k = null; gVar2.o = 4; StreamInfo streamInfo7 = streamInfo4; AddonResolutionService addonResolutionService8 = addonResolutionService3; objK3 = addonResolutionService8.k(provider, streamInfo7, num6, num7, str3, gVar2); if (objK3 != ck1Var) { debridProvider3 = debridProvider5; debridProvider7 = debridProvider4; if (objK3 instanceof q38.b) { } } } } return ck1Var; } } return s38.a(new IllegalStateException("No debrid provider available to resolve torrent")); } iDebridProvider = gVar2.k; it2 = gVar2.j; debridProvider5 = gVar2.i; debridProvider4 = gVar2.f; str3 = gVar2.e; num7 = gVar2.d; num6 = gVar2.c; streamInfo4 = gVar2.b; addonResolutionService3 = gVar2.a; s38.b(obj2); if (((Boolean) obj2).booleanValue()) { } } if (!(obj instanceof q38.b)) { return obj; } if (z2) { ExecutorService executorService2 = kq.a; kq.h("AddonResolutionService", "Forced provider " + debridProvider2 + " failed and fallback suppressed"); return obj; } ExecutorService executorService3 = kq.a; kq.h("AddonResolutionService", "Forced provider " + debridProvider2 + " failed, trying fallbacks"); debridProvider3 = streamInfo2.getDebridProvider(); if (debridProvider3 != null) { } num5 = num3; streamInfo3 = streamInfo2; addonResolutionService2 = addonResolutionService; AddonResolutionService addonResolutionService422 = addonResolutionService2; streamInfo4 = streamInfo3; num6 = num5; it = y41.bj(new sc(), addonResolutionService422.e).iterator(); addonResolutionService3 = addonResolutionService422; str3 = str2; num7 = num4; while (it.hasNext()) { } return s38.a(new IllegalStateException("No debrid provider available to resolve torrent")); } /* JADX WARN: Can't wrap try/catch for region: R(6:119|42|43|120|44|(2:46|105)(4:47|48|54|(2:57|(1:59)(5:60|(5:70|(4:83|(2:92|(3:94|(2:96|(0))|99)(1:72))|63|(2:103|(1:126)(6:106|107|108|110|40|(0)))(5:109|108|110|40|(0)))(0)|73|111|112)|62|63|(0)(0)))(1:56))) */ /* JADX WARN: Code restructure failed: missing block: B:100:0x01e1, code lost: if (r8.code() == 429) goto L63; */ /* JADX WARN: Code restructure failed: missing block: B:49:0x0156, code lost: r0 = e; */ /* JADX WARN: Code restructure failed: missing block: B:50:0x0157, code lost: r13 = r9; r4 = r12; r6 = r17; r7 = r18; r11 = r20; r10 = r21; r9 = r22; r12 = r2; r2 = r23; */ /* JADX WARN: Path cross not found for [B:70:0x019e, B:62:0x0190], limit reached: 113 */ /* JADX WARN: Path cross not found for [B:99:0x01db, B:96:0x01d6], limit reached: 113 */ /* JADX WARN: Removed duplicated region for block: B:103:0x01e6 */ /* JADX WARN: Removed duplicated region for block: B:109:0x0257 */ /* JADX WARN: Removed duplicated region for block: B:119:0x010b A[EXC_TOP_SPLITTER, SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:56:0x017e A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:57:0x017f */ /* JADX WARN: Removed duplicated region for block: B:72:0x01a2 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0017 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:106:0x024a -> B:107:0x024b). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:109:0x0257 -> B:108:0x0252). Please report as a decompilation issue!!! */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object k(DebridProvider debridProvider, StreamInfo streamInfo, Integer num, Integer num2, String str, ContinuationImpl continuationImpl) { h hVar; DebridProvider debridProvider2; Object next; String str2; AddonResolutionService addonResolutionService; h hVar2; Object objD; IDebridProvider iDebridProvider; int i; StreamInfo streamInfo2; Integer num3; Integer num4; String str3; DebridProvider debridProvider3; StreamInfo streamInfo3; Integer num5; Integer num6; String str4; String str5; IDebridProvider iDebridProvider2; int i2; Exception e; Object objA; IDebridProvider iDebridProvider3; DebridProvider debridProvider4; Integer num7; String str6; AddonResolutionService addonResolutionService2; Integer num8; StreamInfo streamInfo4; String str7; Object obj; Throwable th; Integer num9; Integer num10; String str8; String str9; h hVar3; IDebridProvider iDebridProvider4; if (continuationImpl instanceof h) { hVar = (h) continuationImpl; int i3 = hVar.o; if ((i3 & Integer.MIN_VALUE) != 0) { hVar.o = i3 - Integer.MIN_VALUE; } else { hVar = new h(this, continuationImpl); } } Object obj2 = hVar.m; ck1 ck1Var = ck1.a; int i4 = hVar.o; Object obj3 = null; if (i4 == 0) { s38.b(obj2); String lowerCase = streamInfo.getInfoHash().toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); StringBuilder sb = new StringBuilder("magnet:?xt=urn:btih:"); sb.append(lowerCase); List sources = streamInfo.getSources(); if (sources != null) { for (String str10 : sources) { sb.append("&tr="); sb.append(URLEncoder.encode(str10, "UTF-8")); } } String string = sb.toString(); Iterator it = this.e.iterator(); while (true) { if (!it.hasNext()) { debridProvider2 = debridProvider; next = null; break; } next = it.next(); debridProvider2 = debridProvider; if (((IDebridProvider) next).getProvider() == debridProvider2) { break; } } IDebridProvider iDebridProvider5 = (IDebridProvider) next; if (iDebridProvider5 == null) { return s38.a(new IllegalStateException(vw2.ab("Provider ", debridProvider2.getDisplayName(), " not available"))); } str2 = string; addonResolutionService = this; hVar2 = hVar; objD = vw2.d("No attempts made"); iDebridProvider = iDebridProvider5; i = 0; streamInfo2 = streamInfo; num3 = num; num4 = num2; str3 = str; if (i < 3) { } ExecutorService executorService = kq.a; kq.a("AddonResolutionService", "Failed to resolve with " + debridProvider2 + " after 3 attempts", null); return objD; } if (i4 != 1) { if (i4 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } i2 = hVar.l; Object obj4 = hVar.k; iDebridProvider3 = hVar.j; str6 = hVar.i; str7 = hVar.f; num7 = hVar.e; num8 = hVar.d; streamInfo4 = hVar.c; debridProvider4 = hVar.b; addonResolutionService2 = hVar.a; s38.b(obj2); ck1 ck1Var2 = ck1Var; objD = obj4; AddonResolutionService addonResolutionService3 = addonResolutionService2; str3 = str7; debridProvider2 = debridProvider4; num4 = num7; iDebridProvider = iDebridProvider3; str2 = str6; hVar2 = hVar; streamInfo2 = streamInfo4; i = i2 + 1; num3 = num8; obj3 = null; addonResolutionService = addonResolutionService3; ck1Var = ck1Var2; if (i < 3) { try { } catch (Exception e2) { e = e2; num9 = num3; num10 = num4; str8 = str3; str9 = str2; hVar3 = hVar2; iDebridProvider4 = iDebridProvider; } Integer fileIdx = streamInfo2.getFileIdx(); hVar2.a = addonResolutionService; hVar2.b = debridProvider2; hVar2.c = streamInfo2; hVar2.d = num3; hVar2.e = num4; hVar2.f = str3; hVar2.i = str2; hVar2.j = iDebridProvider; hVar2.k = obj3; hVar2.l = i; hVar2.o = 1; num9 = num3; num10 = num4; str8 = str3; str9 = str2; hVar3 = hVar2; iDebridProvider4 = iDebridProvider; objA = iDebridProvider4.mo76resolveToDirectLinkhUnOzRk(str9, fileIdx, num9, num10, str8, hVar3); if (objA == ck1Var) { return ck1Var; } debridProvider3 = debridProvider2; i2 = i; iDebridProvider2 = iDebridProvider4; str5 = str9; num5 = num9; num6 = num10; str4 = str8; streamInfo3 = streamInfo2; hVar = hVar3; Integer num11 = num6; iDebridProvider3 = iDebridProvider2; debridProvider4 = debridProvider3; num7 = num11; Integer num12 = num5; str6 = str5; addonResolutionService2 = addonResolutionService; num8 = num12; streamInfo4 = streamInfo3; str7 = str4; obj = objA; if (!(obj instanceof q38.b)) { return obj; } Throwable thA = q38.a(obj); if (thA == null) { objD = obj; debridProvider2 = debridProvider4; } else { addonResolutionService2.getClass(); if (!(thA instanceof DebridError.ServiceDown) && !(thA instanceof DebridError.NetworkError) && !(thA instanceof DebridError.DnsError)) { if (!(thA instanceof DebridError.NoAccount) && !(thA instanceof DebridError.AccountExpired) && !(thA instanceof DebridError.AuthenticationFailed) && !(thA instanceof DebridError.NotCached)) { if (!(thA instanceof SocketTimeoutException) && !(thA instanceof UnknownHostException) && !(thA instanceof IOException)) { if (thA instanceof HttpException) { HttpException httpException = (HttpException) thA; th = thA; int iCode = httpException.code(); if (500 <= iCode) { if (iCode >= 600) { } } } else { th = thA; } } if (i2 >= 2) { long j = ((long) (1 << i2)) * 1000; ExecutorService executorService2 = kq.a; ck1 ck1Var3 = ck1Var; kq.h("AddonResolutionService", "Retryable error from " + debridProvider4 + " (attempt " + (i2 + 1) + "/2), retrying in " + j + "ms: " + th.getMessage()); hVar.a = addonResolutionService2; hVar.b = debridProvider4; hVar.c = streamInfo4; hVar.d = num8; hVar.e = num7; hVar.f = str7; hVar.i = str6; hVar.j = iDebridProvider3; hVar.k = obj; i2 = i2; hVar.l = i2; hVar.o = 2; ck1Var2 = ck1Var3; if (h32.a(j, hVar) == ck1Var2) { return ck1Var2; } obj4 = obj; objD = obj4; AddonResolutionService addonResolutionService32 = addonResolutionService2; str3 = str7; debridProvider2 = debridProvider4; num4 = num7; iDebridProvider = iDebridProvider3; str2 = str6; hVar2 = hVar; streamInfo2 = streamInfo4; i = i2 + 1; num3 = num8; obj3 = null; addonResolutionService = addonResolutionService32; ck1Var = ck1Var2; if (i < 3) { } } else { ck1Var2 = ck1Var; objD = obj; debridProvider2 = debridProvider4; addonResolutionService32 = addonResolutionService2; str3 = str7; num4 = num7; iDebridProvider = iDebridProvider3; str2 = str6; hVar2 = hVar; streamInfo2 = streamInfo4; i = i2 + 1; num3 = num8; obj3 = null; addonResolutionService = addonResolutionService32; ck1Var = ck1Var2; if (i < 3) { } } } ExecutorService executorService3 = kq.a; kq.h("AddonResolutionService", "Non-retryable error from " + debridProvider4 + ": " + th.getClass().getSimpleName()); return obj; } th = thA; if (i2 >= 2) { } } } ExecutorService executorService4 = kq.a; kq.a("AddonResolutionService", "Failed to resolve with " + debridProvider2 + " after 3 attempts", null); return objD; } i2 = hVar.l; iDebridProvider2 = hVar.j; str5 = hVar.i; str4 = hVar.f; num6 = hVar.e; num5 = hVar.d; streamInfo3 = hVar.c; debridProvider3 = hVar.b; addonResolutionService = hVar.a; try { try { s38.b(obj2); objA = ((q38) obj2).a; } catch (Exception e3) { e = e3; objA = s38.a(e); } Integer num112 = num6; iDebridProvider3 = iDebridProvider2; debridProvider4 = debridProvider3; num7 = num112; Integer num122 = num5; str6 = str5; addonResolutionService2 = addonResolutionService; num8 = num122; streamInfo4 = streamInfo3; str7 = str4; obj = objA; if (!(obj instanceof q38.b)) { } } catch (CancellationException e4) { throw e4; } } public final void l(StreamInfo streamInfo, long j) { cr4.g(streamInfo, "streamInfo"); wj0.c(this.h, null, null, new i(this, streamInfo, j, null), 3); } public final j43 m(String str, int i, int i2, Integer num, String str2) { cr4.g(str, "imdbId"); return k63.e(new k(str, i, i2, this, str2, num, null)); } public final j43 n(Integer num, String str) { cr4.g(str, "imdbId"); return k63.e(new m(str, this, num, null)); } public final j43 o(Integer num, String str, Integer num2, Integer num3, String str2, String str3) { return k63.e(new n(str, str2, this, str3, num, num2, num3, null)); } }