package com.strmr.ps.data.repository; import android.content.Context; import android.content.SharedPreferences; import android.util.Log; import androidx.credentials.exceptions.publickeycredential.DomExceptionUtils; import androidx.media3.container.NalUnitUtil; import androidx.media3.exoplayer.analytics.AnalyticsListener; import androidx.media3.extractor.text.ttml.TtmlNode; import com.google.android.gms.common.internal.ImagesContract; import com.google.android.gms.measurement.api.AppMeasurementSdk; import com.google.gson.Gson; import com.strmr.ps.data.local.dao.AddonConfigDao; import com.strmr.ps.data.local.dao.AddonDisclaimerDao; import com.strmr.ps.data.local.dao.InstalledAddonDao; import com.strmr.ps.data.local.dao.RowConfigDao; import com.strmr.ps.data.local.entity.AddonConfigEntity; import com.strmr.ps.data.local.entity.AddonDisclaimerAcceptance; import com.strmr.ps.data.local.entity.AddonWithConfigs; import com.strmr.ps.data.local.entity.InstalledAddonEntity; import com.strmr.ps.data.model.addon.InstalledAddon; import com.strmr.ps.data.model.addon.StremioCatalog; import com.strmr.ps.data.model.addon.StremioManifest; import com.strmr.ps.data.model.addon.StremioResource; import com.strmr.ps.data.service.StremioAddonService; import com.strmr.ps.data.supabase.DeviceManager; import com.strmr.ps.data.supabase.SettingsSyncManager; import dagger.Lazy; import dagger.hilt.android.qualifiers.ApplicationContext; import defpackage.ak1; import defpackage.bk1; import defpackage.ck1; import defpackage.cr4; import defpackage.e6a; import defpackage.fi7; import defpackage.gr3; import defpackage.hx9; import defpackage.ik2; import defpackage.j43; import defpackage.kp6; import defpackage.kq; import defpackage.l43; import defpackage.m02; import defpackage.m12; import defpackage.n41; import defpackage.n89; import defpackage.pq6; import defpackage.q38; import defpackage.s38; import defpackage.sc2; import defpackage.uz1; import defpackage.vw2; import defpackage.vx8; import defpackage.wj0; import defpackage.y41; import java.net.URL; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; import java.util.HashSet; import java.util.Iterator; import java.util.List; import java.util.Map; import java.util.Objects; import java.util.concurrent.ExecutorService; import javax.inject.Inject; import javax.inject.Singleton; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.Boxing; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import kotlin.coroutines.jvm.internal.SuspendLambda; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u0000²\u0001\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0005\n\u0002\u0010\u000e\n\u0002\b\u000e\n\u0002\u0010\u000b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0010\b\n\u0002\b\u000e\n\u0002\u0018\u0002\n\u0002\b\u0006\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0007\u0018\u0000 |2\u00020\u0001:\u0003|}~B_\b\u0007\u0012\b\b\u0001\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\u0006\u0010\u000b\u001a\u00020\n\u0012\u0006\u0010\r\u001a\u00020\f\u0012\u0006\u0010\u000f\u001a\u00020\u000e\u0012\f\u0010\u0012\u001a\b\u0012\u0004\u0012\u00020\u00110\u0010\u0012\f\u0010\u0014\u001a\b\u0012\u0004\u0012\u00020\u00130\u0010¢\u0006\u0004\b\u0015\u0010\u0016J\u0019\u0010\u001a\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00190\u00180\u0017¢\u0006\u0004\b\u001a\u0010\u001bJ\u0019\u0010\u001c\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u00190\u00180\u0017¢\u0006\u0004\b\u001c\u0010\u001bJ\u0016\u0010\u001d\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b\u001d\u0010\u001eJ\u001a\u0010!\u001a\u0004\u0018\u00010\u00192\u0006\u0010 \u001a\u00020\u001fH\u0086@¢\u0006\u0004\b!\u0010\"J\u001a\u0010$\u001a\u0004\u0018\u00010\u00192\u0006\u0010#\u001a\u00020\u001fH\u0086@¢\u0006\u0004\b$\u0010\"J\u001e\u0010%\u001a\b\u0012\u0004\u0012\u00020\u00190\u00182\u0006\u0010#\u001a\u00020\u001fH\u0086@¢\u0006\u0004\b%\u0010\"J\u0016\u0010&\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b&\u0010\u001eJ\u0016\u0010'\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b'\u0010\u001eJ\u0016\u0010(\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b(\u0010\u001eJ\u0016\u0010)\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b)\u0010\u001eJ\u0016\u0010*\u001a\b\u0012\u0004\u0012\u00020\u00190\u0018H\u0086@¢\u0006\u0004\b*\u0010\u001eJ\u001e\u0010,\u001a\b\u0012\u0004\u0012\u00020\u00190\u00182\u0006\u0010+\u001a\u00020\u001fH\u0086@¢\u0006\u0004\b,\u0010\"J(\u00103\u001a\b\u0012\u0004\u0012\u00020\u0019002\u0006\u0010-\u001a\u00020\u001f2\b\b\u0002\u0010/\u001a\u00020.H\u0086@¢\u0006\u0004\b1\u00102J0\u00108\u001a\b\u0012\u0004\u0012\u00020\u0019002\u0006\u00104\u001a\u00020\u001f2\u0006\u00105\u001a\u00020\u001f2\b\b\u0002\u0010/\u001a\u00020.H\u0086@¢\u0006\u0004\b6\u00107J0\u0010=\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020\u001f0\u0018002\u0006\u00109\u001a\u00020\u001f2\n\b\u0002\u0010:\u001a\u0004\u0018\u00010\u001fH\u0086@¢\u0006\u0004\b;\u0010\u001a\u00020\u001fH\u0086@¢\u0006\u0004\b@\u0010\"J\u001e\u0010D\u001a\b\u0012\u0004\u0012\u00020B002\u0006\u0010 \u001a\u00020\u001fH\u0086@¢\u0006\u0004\bC\u0010\"J\u001e\u0010G\u001a\b\u0012\u0004\u0012\u00020E002\u0006\u0010 \u001a\u00020\u001fH\u0086@¢\u0006\u0004\bF\u0010\"J(\u0010J\u001a\u00020E2\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010H\u001a\u00020\u001f2\u0006\u0010I\u001a\u00020\u001fH\u0086@¢\u0006\u0004\bJ\u0010KJ\"\u0010L\u001a\u0004\u0018\u00010\u001f2\u0006\u0010 \u001a\u00020\u001f2\u0006\u0010H\u001a\u00020\u001fH\u0086@¢\u0006\u0004\bL\u0010", "(Landroid/content/Context;Lcom/strmr/ps/data/local/dao/InstalledAddonDao;Lcom/strmr/ps/data/local/dao/AddonConfigDao;Lcom/strmr/ps/data/local/dao/AddonDisclaimerDao;Lcom/strmr/ps/data/local/dao/RowConfigDao;Lcom/strmr/ps/data/service/StremioAddonService;Lcom/google/gson/Gson;Ldagger/Lazy;Ldagger/Lazy;)V", "Lj43;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "observeAllAddons", "()Lj43;", "observeEnabledAddons", "getEnabledAddons", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "", "instanceId", "getInstalledAddon", "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "addonId", "getInstalledAddonByAddonId", "getAddonInstances", "getAllInstalledAddons", "getSubtitleAddons", "getCatalogAddons", "getSearchAddons", "getMetadataAddons", "capability", "getAddonsByCapability", ImagesContract.URL, "", "allowMultipleInstances", "Lq38;", "installAddon-0E7RQCE", "(Ljava/lang/String;ZLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "installAddon", "manifestUrl", "configuredUrl", "installConfiguredAddon-BWLJW6A", "(Ljava/lang/String;Ljava/lang/String;ZLkotlin/coroutines/Continuation;)Ljava/lang/Object;", "installConfiguredAddon", "bundleJson", "bundleSourceUrl", "installBundle-0E7RQCE", "(Ljava/lang/String;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "installBundle", "bundleId", "Lcom/strmr/ps/data/repository/AddonRepository$BundleUpdateResult;", "updateBundle-gIAlu-s", "updateBundle", "Lcom/strmr/ps/data/local/entity/InstalledAddonEntity;", "refreshAddon-gIAlu-s", "refreshAddon", "Le6a;", "uninstallAddon-gIAlu-s", "uninstallAddon", "fieldId", AppMeasurementSdk.ConditionalUserProperty.VALUE, "updateConfig", "(Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "getConfigValue", "enabled", "setAddonEnabled", "", "priority", "setAddonPriority", "(Ljava/lang/String;ILkotlin/coroutines/Continuation;)Ljava/lang/Object;", "moveAddonUp", "moveAddonDown", "updateLastUsed", "isGlobalDisclaimerAccepted", "()Z", "acceptGlobalDisclaimer", "()V", "isAddonDisclaimerAccepted", "acceptAddonDisclaimer", "hasStreamAddons", "getAddonCount", "Lcom/strmr/ps/data/model/addon/StremioManifest;", "manifest", "baseUrl", "instanceNumber", "createAddonEntity", "(Lcom/strmr/ps/data/model/addon/StremioManifest;Ljava/lang/String;Ljava/lang/String;Ljava/lang/String;I)Lcom/strmr/ps/data/local/entity/InstalledAddonEntity;", "fullUrl", "Lhx9;", "detectConfiguredUrl", "(Ljava/lang/String;)Lhx9;", "Lcom/strmr/ps/data/model/addon/StremioResource;", "parseResources", "(Lcom/strmr/ps/data/model/addon/StremioManifest;)Ljava/util/List;", "triggerRowSync", "triggerCloudSync", "Landroid/content/Context;", "Lcom/strmr/ps/data/local/dao/InstalledAddonDao;", "Lcom/strmr/ps/data/local/dao/AddonConfigDao;", "Lcom/strmr/ps/data/local/dao/AddonDisclaimerDao;", "Lcom/strmr/ps/data/local/dao/RowConfigDao;", "Lcom/strmr/ps/data/service/StremioAddonService;", "Lcom/google/gson/Gson;", "Ldagger/Lazy;", "Landroid/content/SharedPreferences;", "kotlin.jvm.PlatformType", "prefs", "Landroid/content/SharedPreferences;", "Lak1;", "syncScope", "Lak1;", "Companion", "AddonAlreadyInstalledException", "BundleUpdateResult", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class AddonRepository { @kp6 private static final String ADDON_PREFS = "addon_prefs"; @kp6 private static final String PREF_GLOBAL_DISCLAIMER_ACCEPTED = "global_disclaimer_accepted"; @kp6 private static final String TAG = "AddonRepository"; @kp6 private final InstalledAddonDao addonDao; @kp6 private final AddonConfigDao configDao; @kp6 private final Context context; @kp6 private final Lazy deviceManager; @kp6 private final AddonDisclaimerDao disclaimerDao; @kp6 private final Gson gson; private final SharedPreferences prefs; @kp6 private final RowConfigDao rowConfigDao; @kp6 private final Lazy settingsSyncManager; @kp6 private final StremioAddonService stremioAddonService; @kp6 private final ak1 syncScope; @Metadata(d1 = {"\u0000 \n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0010\u000e\n\u0000\n\u0002\u0010\b\n\u0002\b\u0013\n\u0002\u0010\u000b\n\u0002\b\u0004\b\u0086\b\u0018\u00002\u00020\u0001B/\u0012\u0006\u0010\u0002\u001a\u00020\u0003\u0012\u0006\u0010\u0004\u001a\u00020\u0005\u0012\u0006\u0010\u0006\u001a\u00020\u0005\u0012\u0006\u0010\u0007\u001a\u00020\u0005\u0012\u0006\u0010\b\u001a\u00020\u0005¢\u0006\u0004\b\t\u0010\nJ\t\u0010\u0012\u001a\u00020\u0003HÆ\u0003J\t\u0010\u0013\u001a\u00020\u0005HÆ\u0003J\t\u0010\u0014\u001a\u00020\u0005HÆ\u0003J\t\u0010\u0015\u001a\u00020\u0005HÆ\u0003J\t\u0010\u0016\u001a\u00020\u0005HÆ\u0003J;\u0010\u0017\u001a\u00020\u00002\b\b\u0002\u0010\u0002\u001a\u00020\u00032\b\b\u0002\u0010\u0004\u001a\u00020\u00052\b\b\u0002\u0010\u0006\u001a\u00020\u00052\b\b\u0002\u0010\u0007\u001a\u00020\u00052\b\b\u0002\u0010\b\u001a\u00020\u0005HÆ\u0001J\u0013\u0010\u0018\u001a\u00020\u00192\b\u0010\u001a\u001a\u0004\u0018\u00010\u0001HÖ\u0003J\t\u0010\u001b\u001a\u00020\u0005HÖ\u0001J\t\u0010\u001c\u001a\u00020\u0003HÖ\u0001R\u0011\u0010\u0002\u001a\u00020\u0003¢\u0006\b\n\u0000\u001a\u0004\b\u000b\u0010\fR\u0011\u0010\u0004\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\r\u0010\u000eR\u0011\u0010\u0006\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\u000f\u0010\u000eR\u0011\u0010\u0007\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\u0010\u0010\u000eR\u0011\u0010\b\u001a\u00020\u0005¢\u0006\b\n\u0000\u001a\u0004\b\u0011\u0010\u000e¨\u0006\u001d"}, d2 = {"Lcom/strmr/ps/data/repository/AddonRepository$BundleUpdateResult;", "", "bundleId", "", "oldVersion", "", "newVersion", "updatedCount", "newAddonsCount", "", "(Ljava/lang/String;IIII)V", "getBundleId", "()Ljava/lang/String;", "getOldVersion", "()I", "getNewVersion", "getUpdatedCount", "getNewAddonsCount", "component1", "component2", "component3", "component4", "component5", "copy", "equals", "", "other", "hashCode", "toString", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final /* data */ class BundleUpdateResult { @kp6 private final String bundleId; private final int newAddonsCount; private final int newVersion; private final int oldVersion; private final int updatedCount; public BundleUpdateResult(@kp6 String str, int i, int i2, int i3, int i4) { cr4.g(str, "bundleId"); this.bundleId = str; this.oldVersion = i; this.newVersion = i2; this.updatedCount = i3; this.newAddonsCount = i4; } public static /* synthetic */ BundleUpdateResult copy$default(BundleUpdateResult bundleUpdateResult, String str, int i, int i2, int i3, int i4, int i5, Object obj) { if ((i5 & 1) != 0) { str = bundleUpdateResult.bundleId; } if ((i5 & 2) != 0) { i = bundleUpdateResult.oldVersion; } if ((i5 & 4) != 0) { i2 = bundleUpdateResult.newVersion; } if ((i5 & 8) != 0) { i3 = bundleUpdateResult.updatedCount; } if ((i5 & 16) != 0) { i4 = bundleUpdateResult.newAddonsCount; } int i6 = i4; int i7 = i2; return bundleUpdateResult.copy(str, i, i7, i3, i6); } @kp6 /* JADX INFO: renamed from: component1, reason: from getter */ public final String getBundleId() { return this.bundleId; } /* JADX INFO: renamed from: component2, reason: from getter */ public final int getOldVersion() { return this.oldVersion; } /* JADX INFO: renamed from: component3, reason: from getter */ public final int getNewVersion() { return this.newVersion; } /* JADX INFO: renamed from: component4, reason: from getter */ public final int getUpdatedCount() { return this.updatedCount; } /* JADX INFO: renamed from: component5, reason: from getter */ public final int getNewAddonsCount() { return this.newAddonsCount; } @kp6 public final BundleUpdateResult copy(@kp6 String bundleId, int oldVersion, int newVersion, int updatedCount, int newAddonsCount) { cr4.g(bundleId, "bundleId"); return new BundleUpdateResult(bundleId, oldVersion, newVersion, updatedCount, newAddonsCount); } public boolean equals(@pq6 Object other) { if (this == other) { return true; } if (!(other instanceof BundleUpdateResult)) { return false; } BundleUpdateResult bundleUpdateResult = (BundleUpdateResult) other; return cr4.b(this.bundleId, bundleUpdateResult.bundleId) && this.oldVersion == bundleUpdateResult.oldVersion && this.newVersion == bundleUpdateResult.newVersion && this.updatedCount == bundleUpdateResult.updatedCount && this.newAddonsCount == bundleUpdateResult.newAddonsCount; } @kp6 public final String getBundleId() { return this.bundleId; } public final int getNewAddonsCount() { return this.newAddonsCount; } public final int getNewVersion() { return this.newVersion; } public final int getOldVersion() { return this.oldVersion; } public final int getUpdatedCount() { return this.updatedCount; } public int hashCode() { return Integer.hashCode(this.newAddonsCount) + fi7.a(this.updatedCount, fi7.a(this.newVersion, fi7.a(this.oldVersion, this.bundleId.hashCode() * 31, 31), 31), 31); } @kp6 public String toString() { String str = this.bundleId; int i = this.oldVersion; int i2 = this.newVersion; int i3 = this.updatedCount; int i4 = this.newAddonsCount; StringBuilder sbV = n41.v("BundleUpdateResult(bundleId=", i, str, ", oldVersion=", ", newVersion="); sbV.append(i2); sbV.append(", updatedCount="); sbV.append(i3); sbV.append(", newAddonsCount="); return n41.q(sbV, i4, ")"); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$acceptAddonDisclaimer$2, reason: invalid class name */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$acceptAddonDisclaimer$2", f = "AddonRepository.kt", i = {}, l = {976}, m = "invokeSuspend", n = {}, s = {}) public static final class AnonymousClass2 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $addonId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass2(String str, Continuation continuation) { super(2, continuation); this.$addonId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new AnonymousClass2(this.$addonId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((AnonymousClass2) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); AddonDisclaimerDao addonDisclaimerDao = AddonRepository.this.disclaimerDao; AddonDisclaimerAcceptance addonDisclaimerAcceptance = new AddonDisclaimerAcceptance(this.$addonId, System.currentTimeMillis(), 1); this.label = 1; if (addonDisclaimerDao.acceptDisclaimer(addonDisclaimerAcceptance, this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getAddonCount$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\b\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "", "(Lak1;)I"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getAddonCount$2", f = "AddonRepository.kt", i = {}, l = {998}, m = "invokeSuspend", n = {}, s = {}) public static final class C02592 extends SuspendLambda implements gr3, Object> { int label; public C02592(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02592(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02592) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByType("stream", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return Boxing.boxInt(((List) obj).size()); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getAddonInstances$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getAddonInstances$2", f = "AddonRepository.kt", i = {}, l = {118}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02602 extends SuspendLambda implements gr3>, Object> { final /* synthetic */ String $addonId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02602(String str, Continuation continuation) { super(2, continuation); this.$addonId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02602(this.$addonId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02602) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$addonId; this.label = 1; obj = installedAddonDao.getAddonsByAddonIdWithConfigs(str, this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getAddonsByCapability$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getAddonsByCapability$2", f = "AddonRepository.kt", i = {}, l = {196}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02612 extends SuspendLambda implements gr3>, Object> { final /* synthetic */ String $capability; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02612(String str, Continuation continuation) { super(2, continuation); this.$capability = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02612(this.$capability, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02612) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$capability; this.label = 1; obj = installedAddonDao.getEnabledAddonsByCapabilityWithConfigs(str, this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getAllInstalledAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getAllInstalledAddons$2", f = "AddonRepository.kt", i = {1}, l = {127, 128}, m = "invokeSuspend", n = {"streamAddons"}, s = {"L$0"}) @vx8 public static final class C02622 extends SuspendLambda implements gr3>, Object> { Object L$0; int label; public C02622(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02622(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02622) create(ak1Var, continuation)).invokeSuspend(e6a.a); } /* JADX WARN: Removed duplicated region for block: B:20:0x0069 */ /* JADX WARN: Removed duplicated region for block: B:26:0x0097 A[LOOP:1: B:24:0x0091->B:26:0x0097, LOOP_END] */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object invokeSuspend(Object obj) { List list; ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByTypeWithConfigs("stream", this); if (obj != ck1Var) { } return ck1Var; } if (i != 1) { if (i != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } list = (List) this.L$0; s38.b(obj); ArrayList arrayListAu = y41.au((List) obj, list); HashSet hashSet = new HashSet(); ArrayList arrayList = new ArrayList(); for (Object obj2 : arrayListAu) { if (hashSet.add(((AddonWithConfigs) obj2).getAddon().getInstanceId())) { arrayList.add(obj2); } } ArrayList arrayList2 = new ArrayList(y41.p(arrayList, 10)); for (AddonWithConfigs addonWithConfigs : arrayList) { arrayList2.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList2; } s38.b(obj); List list2 = (List) obj; InstalledAddonDao installedAddonDao2 = AddonRepository.this.addonDao; this.L$0 = list2; this.label = 2; Object enabledAddonsByTypeWithConfigs = installedAddonDao2.getEnabledAddonsByTypeWithConfigs("catalog", this); if (enabledAddonsByTypeWithConfigs != ck1Var) { list = list2; obj = enabledAddonsByTypeWithConfigs; ArrayList arrayListAu2 = y41.au((List) obj, list); HashSet hashSet2 = new HashSet(); ArrayList arrayList3 = new ArrayList(); while (r5.hasNext()) { } ArrayList arrayList22 = new ArrayList(y41.p(arrayList3, 10)); while (r0.hasNext()) { } return arrayList22; } return ck1Var; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getCatalogAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getCatalogAddons$2", f = "AddonRepository.kt", i = {}, l = {165}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02632 extends SuspendLambda implements gr3>, Object> { int label; public C02632(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02632(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02632) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByTypeWithConfigs("catalog", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getConfigValue$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\u0010\u0002\u001a\u0004\u0018\u00010\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "", "(Lak1;)Ljava/lang/String;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getConfigValue$2", f = "AddonRepository.kt", i = {}, l = {879}, m = "invokeSuspend", n = {}, s = {}) public static final class C02642 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $fieldId; final /* synthetic */ String $instanceId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02642(String str, String str2, Continuation continuation) { super(2, continuation); this.$instanceId = str; this.$fieldId = str2; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02642(this.$instanceId, this.$fieldId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02642) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i != 0) { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); return obj; } s38.b(obj); AddonConfigDao addonConfigDao = AddonRepository.this.configDao; String str = this.$instanceId; String str2 = this.$fieldId; this.label = 1; Object configValue = addonConfigDao.getConfigValue(str, str2, this); return configValue == ck1Var ? ck1Var : configValue; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getEnabledAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getEnabledAddons$2", f = "AddonRepository.kt", i = {}, l = {91}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02652 extends SuspendLambda implements gr3>, Object> { int label; public C02652(Continuation continuation) { super(2, continuation); } /* JADX INFO: Access modifiers changed from: private */ public static final CharSequence invokeSuspend$lambda$0(AddonWithConfigs addonWithConfigs) { return addonWithConfigs.getAddon().getName() + "(" + addonWithConfigs.getAddon().getInstanceId() + ")"; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02652(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02652) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByTypeWithConfigs("stream", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; ExecutorService executorService = kq.a; List list2 = list; kq.h(AddonRepository.TAG, "getEnabledAddons: Found " + list.size() + " stream addons: " + y41.ai(list2, null, null, null, new a(0), 31)); ArrayList arrayList = new ArrayList(y41.p(list2, 10)); for (AddonWithConfigs addonWithConfigs : list2) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getInstalledAddon$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u0004\u0018\u00010\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Lcom/strmr/ps/data/model/addon/InstalledAddon;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getInstalledAddon$2", f = "AddonRepository.kt", i = {}, l = {101}, m = "invokeSuspend", n = {}, s = {}) public static final class C02662 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $instanceId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02662(String str, Continuation continuation) { super(2, continuation); this.$instanceId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02662(this.$instanceId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02662) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$instanceId; this.label = 1; obj = installedAddonDao.getAddonByInstanceIdWithConfigs(str, this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } AddonWithConfigs addonWithConfigs = (AddonWithConfigs) obj; if (addonWithConfigs == null) { return null; } return InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs()); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getInstalledAddonByAddonId$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u0004\u0018\u00010\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Lcom/strmr/ps/data/model/addon/InstalledAddon;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getInstalledAddonByAddonId$2", f = "AddonRepository.kt", i = {}, l = {109}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02672 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $addonId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02672(String str, Continuation continuation) { super(2, continuation); this.$addonId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02672(this.$addonId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02672) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$addonId; this.label = 1; obj = installedAddonDao.getAddonsByAddonIdWithConfigs(str, this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } AddonWithConfigs addonWithConfigs = (AddonWithConfigs) y41.ab((List) obj); if (addonWithConfigs != null) { return InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs()); } return null; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getMetadataAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getMetadataAddons$2", f = "AddonRepository.kt", i = {}, l = {185}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02682 extends SuspendLambda implements gr3>, Object> { int label; public C02682(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02682(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02682) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByCapabilityWithConfigs("meta", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; list.size(); List list2 = list; ArrayList arrayList = new ArrayList(y41.p(list2, 10)); for (AddonWithConfigs addonWithConfigs : list2) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getSearchAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getSearchAddons$2", f = "AddonRepository.kt", i = {}, l = {174}, m = "invokeSuspend", n = {}, s = {}) @vx8 public static final class C02692 extends SuspendLambda implements gr3>, Object> { int label; public C02692(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02692(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02692) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByTypeWithConfigs("search", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } return arrayList; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$getSubtitleAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010 \n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0003\u001a\b\u0012\u0004\u0012\u00020\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lak1;", "", "Lcom/strmr/ps/data/model/addon/InstalledAddon;", "", "(Lak1;)Ljava/util/List;"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$getSubtitleAddons$2", f = "AddonRepository.kt", i = {1}, l = {141, 144}, m = "invokeSuspend", n = {"subtitleTypedAddons"}, s = {"L$0"}) @vx8 public static final class C02702 extends SuspendLambda implements gr3>, Object> { Object L$0; int label; public C02702(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02702(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation> continuation) { return ((C02702) create(ak1Var, continuation)).invokeSuspend(e6a.a); } /* JADX WARN: Removed duplicated region for block: B:20:0x0069 */ /* JADX WARN: Removed duplicated region for block: B:26:0x0097 A[LOOP:1: B:24:0x0091->B:26:0x0097, LOOP_END] */ /* JADX WARN: Removed duplicated region for block: B:30:0x00c2 A[LOOP:2: B:28:0x00bc->B:30:0x00c2, LOOP_END] */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object invokeSuspend(Object obj) { List list; ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByTypeWithConfigs("subtitles", this); if (obj != ck1Var) { } return ck1Var; } if (i != 1) { if (i != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } list = (List) this.L$0; s38.b(obj); List list2 = (List) obj; ArrayList arrayListAu = y41.au(list2, list); HashSet hashSet = new HashSet(); ArrayList arrayList = new ArrayList(); for (Object obj2 : arrayListAu) { if (hashSet.add(((AddonWithConfigs) obj2).getAddon().getInstanceId())) { arrayList.add(obj2); } } ArrayList arrayList2 = new ArrayList(y41.p(arrayList, 10)); for (AddonWithConfigs addonWithConfigs : arrayList) { arrayList2.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } arrayList2.size(); list.size(); list2.size(); for (InstalledAddon installedAddon : arrayList2) { installedAddon.getName(); installedAddon.getAddonType(); y41.bk(installedAddon.getCapabilities(), 3).toString(); } return arrayList2; } s38.b(obj); List list3 = (List) obj; InstalledAddonDao installedAddonDao2 = AddonRepository.this.addonDao; this.L$0 = list3; this.label = 2; Object enabledAddonsByCapabilityWithConfigs = installedAddonDao2.getEnabledAddonsByCapabilityWithConfigs("subtitles", this); if (enabledAddonsByCapabilityWithConfigs != ck1Var) { list = list3; obj = enabledAddonsByCapabilityWithConfigs; List list22 = (List) obj; ArrayList arrayListAu2 = y41.au(list22, list); HashSet hashSet2 = new HashSet(); ArrayList arrayList3 = new ArrayList(); while (r1.hasNext()) { } ArrayList arrayList22 = new ArrayList(y41.p(arrayList3, 10)); while (r2.hasNext()) { } arrayList22.size(); list.size(); list22.size(); while (r7.hasNext()) { } return arrayList22; } return ck1Var; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$hasStreamAddons$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "", "(Lak1;)Z"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$hasStreamAddons$2", f = "AddonRepository.kt", i = {}, l = {991}, m = "invokeSuspend", n = {}, s = {}) public static final class C02712 extends SuspendLambda implements gr3, Object> { int label; public C02712(Continuation continuation) { super(2, continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02712(continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02712) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getEnabledAddonsByType("stream", this); if (obj == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return Boxing.boxBoolean(!((Collection) obj).isEmpty()); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$isAddonDisclaimerAccepted$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0010\u000b\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "", "", "(Lak1;)Z"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$isAddonDisclaimerAccepted$2", f = "AddonRepository.kt", i = {}, l = {969}, m = "invokeSuspend", n = {}, s = {}) public static final class C02722 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $addonId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02722(String str, Continuation continuation) { super(2, continuation); this.$addonId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02722(this.$addonId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02722) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i != 0) { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); return obj; } s38.b(obj); AddonDisclaimerDao addonDisclaimerDao = AddonRepository.this.disclaimerDao; String str = this.$addonId; this.label = 1; Object objHasAcceptedDisclaimer = addonDisclaimerDao.hasAcceptedDisclaimer(str, this); return objHasAcceptedDisclaimer == ck1Var ? ck1Var : objHasAcceptedDisclaimer; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$moveAddonDown$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$moveAddonDown$2", f = "AddonRepository.kt", i = {1}, l = {928, 935}, m = "invokeSuspend", n = {"index$iv"}, s = {"I$0"}) @vx8 public static final class C02732 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $instanceId; int I$0; Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02732(String str, Continuation continuation) { super(2, continuation); this.$instanceId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02732(this.$instanceId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02732) create(ak1Var, continuation)).invokeSuspend(e6a.a); } /* JADX WARN: Code restructure failed: missing block: B:12:0x0038, code lost: if (r10 == r0) goto L33; */ /* JADX WARN: Code restructure failed: missing block: B:32:0x009f, code lost: if (r7.updatePriority(r10, r6, r9) == r0) goto L33; */ /* JADX WARN: Code restructure failed: missing block: B:33:0x00a1, code lost: return r0; */ /* JADX WARN: Removed duplicated region for block: B:29:0x0081 */ /* JADX WARN: Removed duplicated region for block: B:36:0x00a7 */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:32:0x009f -> B:7:0x001b). Please report as a decompilation issue!!! */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object invokeSuspend(Object obj) { int i; Iterator it; AddonRepository addonRepository; ck1 ck1Var = ck1.a; int i2 = this.label; e6a e6aVar = e6a.a; if (i2 == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getAllAddonsSorted(this); } else if (i2 == 1) { s38.b(obj); } else { if (i2 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } int i3 = this.I$0; it = (Iterator) this.L$1; addonRepository = (AddonRepository) this.L$0; s38.b(obj); i = i3; if (it.hasNext()) { AddonRepository.this.triggerCloudSync(); return e6aVar; } Object next = it.next(); i3 = i + 1; if (i < 0) { y41.bm(); throw null; } InstalledAddonDao installedAddonDao2 = addonRepository.addonDao; String instanceId = ((InstalledAddonEntity) next).getInstanceId(); this.L$0 = addonRepository; this.L$1 = it; this.I$0 = i3; this.label = 2; } ArrayList arrayListBp = y41.bp((Collection) obj); String str = this.$instanceId; Iterator it2 = arrayListBp.iterator(); i = 0; int i4 = 0; while (true) { if (!it2.hasNext()) { i4 = -1; break; } if (cr4.b(((InstalledAddonEntity) it2.next()).getInstanceId(), str)) { break; } i4++; } if (i4 >= 0 && i4 < arrayListBp.size() - 1) { Collections.swap(arrayListBp, i4, i4 + 1); AddonRepository addonRepository2 = AddonRepository.this; it = arrayListBp.iterator(); addonRepository = addonRepository2; if (it.hasNext()) { } } return e6aVar; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$moveAddonUp$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$moveAddonUp$2", f = "AddonRepository.kt", i = {1}, l = {910, 917}, m = "invokeSuspend", n = {"index$iv"}, s = {"I$0"}) @vx8 public static final class C02742 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $instanceId; int I$0; Object L$0; Object L$1; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02742(String str, Continuation continuation) { super(2, continuation); this.$instanceId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02742(this.$instanceId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02742) create(ak1Var, continuation)).invokeSuspend(e6a.a); } /* JADX WARN: Code restructure failed: missing block: B:11:0x003a, code lost: if (r10 == r0) goto L30; */ /* JADX WARN: Removed duplicated region for block: B:26:0x007b */ @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object invokeSuspend(Object obj) { int i; AddonRepository addonRepository; Iterator it; ck1 ck1Var = ck1.a; int i2 = this.label; e6a e6aVar = e6a.a; if (i2 == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; this.label = 1; obj = installedAddonDao.getAllAddonsSorted(this); } else { if (i2 != 1) { if (i2 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } int i3 = this.I$0; it = (Iterator) this.L$1; AddonRepository addonRepository2 = (AddonRepository) this.L$0; s38.b(obj); i = i3; addonRepository = addonRepository2; while (it.hasNext()) { Object next = it.next(); int i4 = i + 1; if (i < 0) { y41.bm(); throw null; } InstalledAddonDao installedAddonDao2 = addonRepository.addonDao; String instanceId = ((InstalledAddonEntity) next).getInstanceId(); this.L$0 = addonRepository; this.L$1 = it; this.I$0 = i4; this.label = 2; if (installedAddonDao2.updatePriority(instanceId, i, this) == ck1Var) { return ck1Var; } i = i4; } AddonRepository.this.triggerCloudSync(); return e6aVar; } s38.b(obj); } ArrayList arrayListBp = y41.bp((Collection) obj); String str = this.$instanceId; Iterator it2 = arrayListBp.iterator(); i = 0; int i5 = 0; while (true) { if (!it2.hasNext()) { i5 = -1; break; } if (cr4.b(((InstalledAddonEntity) it2.next()).getInstanceId(), str)) { break; } i5++; } if (i5 <= 0) { return e6aVar; } Collections.swap(arrayListBp, i5, i5 - 1); addonRepository = AddonRepository.this; it = arrayListBp.iterator(); while (it.hasNext()) { } AddonRepository.this.triggerCloudSync(); return e6aVar; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$setAddonEnabled$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$setAddonEnabled$2", f = "AddonRepository.kt", i = {}, l = {889}, m = "invokeSuspend", n = {}, s = {}) public static final class C02752 extends SuspendLambda implements gr3, Object> { final /* synthetic */ boolean $enabled; final /* synthetic */ String $instanceId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02752(String str, boolean z, Continuation continuation) { super(2, continuation); this.$instanceId = str; this.$enabled = z; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02752(this.$instanceId, this.$enabled, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02752) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$instanceId; boolean z = this.$enabled; this.label = 1; if (installedAddonDao.setAddonEnabled(str, z, this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } AddonRepository.this.triggerCloudSync(); return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$setAddonPriority$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$setAddonPriority$2", f = "AddonRepository.kt", i = {}, l = {900}, m = "invokeSuspend", n = {}, s = {}) public static final class C02762 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $instanceId; final /* synthetic */ int $priority; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02762(String str, int i, Continuation continuation) { super(2, continuation); this.$instanceId = str; this.$priority = i; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02762(this.$instanceId, this.$priority, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02762) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$instanceId; int i2 = this.$priority; this.label = 1; if (installedAddonDao.updatePriority(str, i2, this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } AddonRepository.this.triggerCloudSync(); return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$triggerCloudSync$1, reason: invalid class name */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$triggerCloudSync$1", f = "AddonRepository.kt", i = {}, l = {AnalyticsListener.EVENT_AUDIO_SINK_ERROR}, m = "invokeSuspend", n = {}, s = {}) public static final class AnonymousClass1 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $accessToken; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AnonymousClass1(String str, Continuation continuation) { super(2, continuation); this.$accessToken = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new AnonymousClass1(this.$accessToken, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((AnonymousClass1) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; try { if (i == 0) { s38.b(obj); SettingsSyncManager settingsSyncManager = (SettingsSyncManager) AddonRepository.this.settingsSyncManager.get(); this.label = 1; if (settingsSyncManager.h(this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } ExecutorService executorService = kq.a; kq.h(AddonRepository.TAG, "Addon cloud sync triggered successfully"); } catch (Exception e) { Log.w(AddonRepository.TAG, "Addon cloud sync failed", e); } return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$triggerRowSync$1, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$triggerRowSync$1", f = "AddonRepository.kt", i = {}, l = {844}, m = "invokeSuspend", n = {}, s = {}) public static final class C02771 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $accessToken; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02771(String str, Continuation continuation) { super(2, continuation); this.$accessToken = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02771(this.$accessToken, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02771) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; try { if (i == 0) { s38.b(obj); SettingsSyncManager settingsSyncManager = (SettingsSyncManager) AddonRepository.this.settingsSyncManager.get(); this.label = 1; if (settingsSyncManager.l(this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } ExecutorService executorService = kq.a; kq.h(AddonRepository.TAG, "Row config cloud sync triggered successfully"); } catch (Exception e) { Log.w(AddonRepository.TAG, "Row config cloud sync failed", e); } return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$updateConfig$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$updateConfig$2", f = "AddonRepository.kt", i = {}, l = {862}, m = "invokeSuspend", n = {}, s = {}) public static final class C02782 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $fieldId; final /* synthetic */ String $instanceId; final /* synthetic */ String $value; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02782(String str, String str2, String str3, Continuation continuation) { super(2, continuation); this.$instanceId = str; this.$fieldId = str2; this.$value = str3; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02782(this.$instanceId, this.$fieldId, this.$value, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02782) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); AddonConfigDao addonConfigDao = AddonRepository.this.configDao; AddonConfigEntity addonConfigEntity = new AddonConfigEntity(this.$instanceId, this.$fieldId, this.$value); this.label = 1; if (addonConfigDao.upsertConfig(addonConfigEntity, this) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } AddonRepository.this.triggerCloudSync(); return e6a.a; } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$updateLastUsed$2, reason: invalid class name and case insensitive filesystem */ @Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\u0010\u0002\u001a\u00020\u0001*\u00020\u0000H\n¢\u0006\u0004\b\u0002\u0010\u0003"}, d2 = {"Lak1;", "Le6a;", "", "(Lak1;)V"}, k = 3, mv = {2, 0, 0}) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$updateLastUsed$2", f = "AddonRepository.kt", i = {}, l = {946}, m = "invokeSuspend", n = {}, s = {}) public static final class C02792 extends SuspendLambda implements gr3, Object> { final /* synthetic */ String $instanceId; int label; /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public C02792(String str, Continuation continuation) { super(2, continuation); this.$instanceId = str; } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Continuation create(Object obj, Continuation continuation) { return AddonRepository.this.new C02792(this.$instanceId, continuation); } @Override // defpackage.gr3 public final Object invoke(ak1 ak1Var, Continuation continuation) { return ((C02792) create(ak1Var, continuation)).invokeSuspend(e6a.a); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { ck1 ck1Var = ck1.a; int i = this.label; if (i == 0) { s38.b(obj); InstalledAddonDao installedAddonDao = AddonRepository.this.addonDao; String str = this.$instanceId; this.label = 1; if (InstalledAddonDao.DefaultImpls.updateLastUsed$default(installedAddonDao, str, 0L, this, 2, null) == ck1Var) { return ck1Var; } } else { if (i != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); } return e6a.a; } } @Inject public AddonRepository(@ApplicationContext @kp6 Context context, @kp6 InstalledAddonDao installedAddonDao, @kp6 AddonConfigDao addonConfigDao, @kp6 AddonDisclaimerDao addonDisclaimerDao, @kp6 RowConfigDao rowConfigDao, @kp6 StremioAddonService stremioAddonService, @kp6 Gson gson, @kp6 Lazy lazy, @kp6 Lazy lazy2) { cr4.g(context, "context"); cr4.g(installedAddonDao, "addonDao"); cr4.g(addonConfigDao, "configDao"); cr4.g(addonDisclaimerDao, "disclaimerDao"); cr4.g(rowConfigDao, "rowConfigDao"); cr4.g(stremioAddonService, "stremioAddonService"); cr4.g(gson, "gson"); cr4.g(lazy, "settingsSyncManager"); cr4.g(lazy2, "deviceManager"); this.context = context; this.addonDao = installedAddonDao; this.configDao = addonConfigDao; this.disclaimerDao = addonDisclaimerDao; this.rowConfigDao = rowConfigDao; this.stremioAddonService = stremioAddonService; this.gson = gson; this.settingsSyncManager = lazy; this.deviceManager = lazy2; this.prefs = context.getSharedPreferences(ADDON_PREFS, 0); m12 m12Var = sc2.a; this.syncScope = bk1.a(m02.c); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:15:0x003a */ /* JADX WARN: Removed duplicated region for block: B:22:0x0052 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final InstalledAddonEntity createAddonEntity(StremioManifest manifest, String baseUrl, String manifestUrl, String instanceId, int instanceNumber) { String str; String json; String str2; List resources = manifest.getResources(); String json2 = null; if (resources != null) { ArrayList arrayList = new ArrayList(); for (Object obj : resources) { if (obj instanceof String) { str2 = (String) obj; } else if (obj instanceof Map) { Object obj2 = ((Map) obj).get(AppMeasurementSdk.ConditionalUserProperty.NAME); str2 = obj2 instanceof String ? (String) obj2 : null; } if (str2 != null) { arrayList.add(str2); } } String strAi = y41.ai(arrayList, ",", null, null, null, 62); str = strAi == null ? "stream" : strAi; } String str3 = manifest.supportsStreaming() ? "stream" : manifest.supportsSubtitles() ? "subtitles" : manifest.supportsCatalogs() ? "catalog" : manifest.supportsMeta() ? "meta" : manifest.supportsSearch() ? "search" : "other"; ExecutorService executorService = kq.a; kq.h(TAG, "Addon type determined: " + str3 + " (resources: " + manifest.getResourceNames() + ")"); hx9 hx9VarDetectConfiguredUrl = detectConfiguredUrl(baseUrl); String str4 = (String) hx9VarDetectConfiguredUrl.a; String str5 = (String) hx9VarDetectConfiguredUrl.b; boolean zBooleanValue = ((Boolean) hx9VarDetectConfiguredUrl.c).booleanValue(); Objects.toString(manifest.getTypes()); Objects.toString(manifest.getResources()); manifest.supportsMovies(); manifest.supportsSeries(); manifest.supportsStreaming(); boolean zSupportsMovies = manifest.supportsMovies(); String str6 = TtmlNode.COMBINE_ALL; if (!zSupportsMovies || !manifest.supportsSeries()) { if (manifest.supportsMovies()) { str6 = "movies"; } else if (manifest.supportsSeries()) { str6 = "tv"; } } String str7 = str6; try { List parsedCatalogs = manifest.getParsedCatalogs(); json = !parsedCatalogs.isEmpty() ? this.gson.toJson(parsedCatalogs) : null; } catch (Exception e) { Log.w(TAG, "Failed to serialize catalogs", e); json = null; } try { List resources2 = parseResources(manifest); if (!resources2.isEmpty()) { json2 = this.gson.toJson(resources2); } } catch (Exception e2) { Log.w(TAG, "Failed to serialize resources", e2); } String str8 = json2; String id = manifest.getId(); String str9 = id == null ? "" : id; String name = manifest.getName(); return new InstalledAddonEntity(instanceId, str9, instanceNumber, name == null ? "" : name, manifest.getVersion(), manifest.getDescription(), str4, manifestUrl, str5, zBooleanValue, str3, str, null, null, 100, true, true, str7, System.currentTimeMillis(), null, json, str8, false, null, null, null, null, null, 264241152, null); } private final hx9 detectConfiguredUrl(String fullUrl) { try { URL url = new URL(fullUrl); String path = url.getPath(); cr4.d(path); if (n89.ab(path) || path.equals(DomExceptionUtils.SEPARATOR) || path.length() <= 1) { return new hx9<>(fullUrl, null, Boolean.FALSE); } StringBuilder sb = new StringBuilder(); sb.append(url.getProtocol()); sb.append("://"); sb.append(url.getHost()); if (url.getPort() != -1 && url.getPort() != url.getDefaultPort()) { sb.append(":"); sb.append(url.getPort()); } return new hx9<>(sb.toString(), fullUrl, Boolean.TRUE); } catch (Exception e) { Log.w(TAG, "Failed to parse URL for configuration detection: " + fullUrl, e); return new hx9<>(fullUrl, null, Boolean.FALSE); } } /* JADX INFO: renamed from: installAddon-0E7RQCE$default, reason: not valid java name */ public static /* synthetic */ Object m56installAddon0E7RQCE$default(AddonRepository addonRepository, String str, boolean z, Continuation continuation, int i, Object obj) { if ((i & 2) != 0) { z = false; } return addonRepository.m59installAddon0E7RQCE(str, z, continuation); } /* JADX INFO: renamed from: installBundle-0E7RQCE$default, reason: not valid java name */ public static /* synthetic */ Object m57installBundle0E7RQCE$default(AddonRepository addonRepository, String str, String str2, Continuation continuation, int i, Object obj) { if ((i & 2) != 0) { str2 = null; } return addonRepository.m60installBundle0E7RQCE(str, str2, continuation); } /* JADX INFO: renamed from: installConfiguredAddon-BWLJW6A$default, reason: not valid java name */ public static /* synthetic */ Object m58installConfiguredAddonBWLJW6A$default(AddonRepository addonRepository, String str, String str2, boolean z, Continuation continuation, int i, Object obj) { if ((i & 4) != 0) { z = false; } return addonRepository.m61installConfiguredAddonBWLJW6A(str, str2, z, continuation); } /* JADX INFO: Access modifiers changed from: private */ public final List parseResources(StremioManifest manifest) { List resources = manifest.getResources(); ik2 ik2Var = ik2.a; if (resources == null) { return ik2Var; } ArrayList arrayList = new ArrayList(); for (Object obj : resources) { StremioResource stremioResource = null; stremioResource = null; if (obj instanceof String) { String str = (String) obj; List types = manifest.getTypes(); if (types == null) { types = ik2Var; } stremioResource = new StremioResource(str, types, null); } else if (obj instanceof Map) { Map map = (Map) obj; Object obj2 = map.get(AppMeasurementSdk.ConditionalUserProperty.NAME); String str2 = obj2 instanceof String ? (String) obj2 : null; if (str2 != null) { Object obj3 = map.get("types"); List types2 = obj3 instanceof List ? (List) obj3 : null; if (types2 == null && (types2 = manifest.getTypes()) == null) { types2 = ik2Var; } Object obj4 = map.get("idPrefixes"); stremioResource = new StremioResource(str2, types2, obj4 instanceof List ? (List) obj4 : null); } } if (stremioResource != null) { arrayList.add(stremioResource); } } return arrayList; } /* JADX INFO: Access modifiers changed from: private */ public final void triggerCloudSync() { String strE = this.deviceManager.get().e(); if (strE != null) { wj0.c(this.syncScope, null, null, new AnonymousClass1(strE, null), 3); } else { ExecutorService executorService = kq.a; kq.h(TAG, "Skipping cloud sync: device not linked (no access token)"); } } private final void triggerRowSync() { String strE = this.deviceManager.get().e(); if (strE != null) { wj0.c(this.syncScope, null, null, new C02771(strE, null), 3); } else { ExecutorService executorService = kq.a; kq.h(TAG, "Skipping row sync: device not linked (no access token)"); } } @pq6 public final Object acceptAddonDisclaimer(@kp6 String str, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new AnonymousClass2(str, null), continuation); return objF == ck1.a ? objF : e6a.a; } public final void acceptGlobalDisclaimer() { fi7.p(this.prefs, PREF_GLOBAL_DISCLAIMER_ACCEPTED, true); } @pq6 public final Object getAddonCount(@kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02592(null), continuation); } @pq6 public final Object getAddonInstances(@kp6 String str, @kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02602(str, null), continuation); } @pq6 public final Object getAddonsByCapability(@kp6 String str, @kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02612(str, null), continuation); } @pq6 public final Object getAllInstalledAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02622(null), continuation); } @pq6 public final Object getCatalogAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02632(null), continuation); } @pq6 public final Object getConfigValue(@kp6 String str, @kp6 String str2, @kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02642(str, str2, null), continuation); } @pq6 public final Object getEnabledAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02652(null), continuation); } @pq6 public final Object getInstalledAddon(@kp6 String str, @kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02662(str, null), continuation); } @pq6 public final Object getInstalledAddonByAddonId(@kp6 String str, @kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02672(str, null), continuation); } @pq6 public final Object getMetadataAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02682(null), continuation); } @pq6 public final Object getSearchAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02692(null), continuation); } @pq6 public final Object getSubtitleAddons(@kp6 Continuation> continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02702(null), continuation); } @pq6 public final Object hasStreamAddons(@kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02712(null), continuation); } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: installAddon-0E7RQCE, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m59installAddon0E7RQCE(@kp6 String str, boolean z, @kp6 Continuation> continuation) throws Throwable { AddonRepository$installAddon$1 addonRepository$installAddon$1; if (continuation instanceof AddonRepository$installAddon$1) { addonRepository$installAddon$1 = (AddonRepository$installAddon$1) continuation; int i = addonRepository$installAddon$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$installAddon$1.label = i - Integer.MIN_VALUE; } else { addonRepository$installAddon$1 = new AddonRepository$installAddon$1(this, continuation); } } Object objF = addonRepository$installAddon$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$installAddon$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$installAddon$2 addonRepository$installAddon$2 = new AddonRepository$installAddon$2(str, z, this, null); addonRepository$installAddon$1.label = 1; objF = wj0.f(m02Var, addonRepository$installAddon$2, addonRepository$installAddon$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: installBundle-0E7RQCE, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m60installBundle0E7RQCE(@kp6 String str, @pq6 String str2, @kp6 Continuation>> continuation) throws Throwable { AddonRepository$installBundle$1 addonRepository$installBundle$1; if (continuation instanceof AddonRepository$installBundle$1) { addonRepository$installBundle$1 = (AddonRepository$installBundle$1) continuation; int i = addonRepository$installBundle$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$installBundle$1.label = i - Integer.MIN_VALUE; } else { addonRepository$installBundle$1 = new AddonRepository$installBundle$1(this, continuation); } } Object objF = addonRepository$installBundle$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$installBundle$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$installBundle$2 addonRepository$installBundle$2 = new AddonRepository$installBundle$2(str, this, str2, null); addonRepository$installBundle$1.label = 1; objF = wj0.f(m02Var, addonRepository$installBundle$2, addonRepository$installBundle$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: installConfiguredAddon-BWLJW6A, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m61installConfiguredAddonBWLJW6A(@kp6 String str, @kp6 String str2, boolean z, @kp6 Continuation> continuation) throws Throwable { AddonRepository$installConfiguredAddon$1 addonRepository$installConfiguredAddon$1; if (continuation instanceof AddonRepository$installConfiguredAddon$1) { addonRepository$installConfiguredAddon$1 = (AddonRepository$installConfiguredAddon$1) continuation; int i = addonRepository$installConfiguredAddon$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$installConfiguredAddon$1.label = i - Integer.MIN_VALUE; } else { addonRepository$installConfiguredAddon$1 = new AddonRepository$installConfiguredAddon$1(this, continuation); } } Object objF = addonRepository$installConfiguredAddon$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$installConfiguredAddon$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$installConfiguredAddon$2 addonRepository$installConfiguredAddon$2 = new AddonRepository$installConfiguredAddon$2(str2, this, z, str, null); addonRepository$installConfiguredAddon$1.label = 1; objF = wj0.f(m02Var, addonRepository$installConfiguredAddon$2, addonRepository$installConfiguredAddon$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } @pq6 public final Object isAddonDisclaimerAccepted(@kp6 String str, @kp6 Continuation continuation) { m12 m12Var = sc2.a; return wj0.f(m02.c, new C02722(str, null), continuation); } public final boolean isGlobalDisclaimerAccepted() { return this.prefs.getBoolean(PREF_GLOBAL_DISCLAIMER_ACCEPTED, false); } @pq6 public final Object moveAddonDown(@kp6 String str, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02732(str, null), continuation); return objF == ck1.a ? objF : e6a.a; } @pq6 public final Object moveAddonUp(@kp6 String str, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02742(str, null), continuation); return objF == ck1.a ? objF : e6a.a; } @kp6 public final j43> observeAllAddons() { final j43> allAddonsWithConfigs = this.addonDao.getAllAddonsWithConfigs(); return new j43>() { // from class: com.strmr.ps.data.repository.AddonRepository$observeAllAddons$$inlined$map$1 /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$observeAllAddons$$inlined$map$1$2, reason: invalid class name */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class AnonymousClass2 implements l43 { final /* synthetic */ l43 $this_unsafeFlow; /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$observeAllAddons$$inlined$map$1$2$1, reason: invalid class name */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$observeAllAddons$$inlined$map$1$2", f = "AddonRepository.kt", i = {}, l = {50}, m = "emit", n = {}, s = {}) public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return AnonymousClass2.this.emit(null, this); } } public AnonymousClass2(l43 l43Var) { this.$this_unsafeFlow = l43Var; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // defpackage.l43 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object emit(Object obj, Continuation continuation) { AnonymousClass1 anonymousClass1; if (continuation instanceof AnonymousClass1) { anonymousClass1 = (AnonymousClass1) continuation; int i = anonymousClass1.label; if ((i & Integer.MIN_VALUE) != 0) { anonymousClass1.label = i - Integer.MIN_VALUE; } else { anonymousClass1 = new AnonymousClass1(continuation); } } Object obj2 = anonymousClass1.result; ck1 ck1Var = ck1.a; int i2 = anonymousClass1.label; if (i2 == 0) { s38.b(obj2); l43 l43Var = this.$this_unsafeFlow; List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } anonymousClass1.label = 1; if (l43Var.emit(arrayList, anonymousClass1) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj2); } return e6a.a; } } @Override // defpackage.j43 public Object collect(l43 l43Var, Continuation continuation) { Object objCollect = allAddonsWithConfigs.collect(new AnonymousClass2(l43Var), continuation); return objCollect == ck1.a ? objCollect : e6a.a; } }; } @kp6 public final j43> observeEnabledAddons() { final j43> enabledAddonsWithConfigs = this.addonDao.getEnabledAddonsWithConfigs(); return new j43>() { // from class: com.strmr.ps.data.repository.AddonRepository$observeEnabledAddons$$inlined$map$1 /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$observeEnabledAddons$$inlined$map$1$2, reason: invalid class name */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public static final class AnonymousClass2 implements l43 { final /* synthetic */ l43 $this_unsafeFlow; /* JADX INFO: renamed from: com.strmr.ps.data.repository.AddonRepository$observeEnabledAddons$$inlined$map$1$2$1, reason: invalid class name */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.AddonRepository$observeEnabledAddons$$inlined$map$1$2", f = "AddonRepository.kt", i = {}, l = {50}, m = "emit", n = {}, s = {}) public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl public final Object invokeSuspend(Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return AnonymousClass2.this.emit(null, this); } } public AnonymousClass2(l43 l43Var) { this.$this_unsafeFlow = l43Var; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // defpackage.l43 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object emit(Object obj, Continuation continuation) { AnonymousClass1 anonymousClass1; if (continuation instanceof AnonymousClass1) { anonymousClass1 = (AnonymousClass1) continuation; int i = anonymousClass1.label; if ((i & Integer.MIN_VALUE) != 0) { anonymousClass1.label = i - Integer.MIN_VALUE; } else { anonymousClass1 = new AnonymousClass1(continuation); } } Object obj2 = anonymousClass1.result; ck1 ck1Var = ck1.a; int i2 = anonymousClass1.label; if (i2 == 0) { s38.b(obj2); l43 l43Var = this.$this_unsafeFlow; List list = (List) obj; ArrayList arrayList = new ArrayList(y41.p(list, 10)); for (AddonWithConfigs addonWithConfigs : list) { arrayList.add(InstalledAddon.INSTANCE.fromEntity(addonWithConfigs.getAddon(), addonWithConfigs.getConfigs())); } anonymousClass1.label = 1; if (l43Var.emit(arrayList, anonymousClass1) == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj2); } return e6a.a; } } @Override // defpackage.j43 public Object collect(l43 l43Var, Continuation continuation) { Object objCollect = enabledAddonsWithConfigs.collect(new AnonymousClass2(l43Var), continuation); return objCollect == ck1.a ? objCollect : e6a.a; } }; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: refreshAddon-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m62refreshAddongIAlus(@kp6 String str, @kp6 Continuation> continuation) throws Throwable { AddonRepository$refreshAddon$1 addonRepository$refreshAddon$1; if (continuation instanceof AddonRepository$refreshAddon$1) { addonRepository$refreshAddon$1 = (AddonRepository$refreshAddon$1) continuation; int i = addonRepository$refreshAddon$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$refreshAddon$1.label = i - Integer.MIN_VALUE; } else { addonRepository$refreshAddon$1 = new AddonRepository$refreshAddon$1(this, continuation); } } Object objF = addonRepository$refreshAddon$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$refreshAddon$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$refreshAddon$2 addonRepository$refreshAddon$2 = new AddonRepository$refreshAddon$2(this, str, null); addonRepository$refreshAddon$1.label = 1; objF = wj0.f(m02Var, addonRepository$refreshAddon$2, addonRepository$refreshAddon$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } @pq6 public final Object setAddonEnabled(@kp6 String str, boolean z, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02752(str, z, null), continuation); return objF == ck1.a ? objF : e6a.a; } @pq6 public final Object setAddonPriority(@kp6 String str, int i, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02762(str, i, null), continuation); return objF == ck1.a ? objF : e6a.a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: uninstallAddon-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m63uninstallAddongIAlus(@kp6 String str, @kp6 Continuation> continuation) throws Throwable { AddonRepository$uninstallAddon$1 addonRepository$uninstallAddon$1; if (continuation instanceof AddonRepository$uninstallAddon$1) { addonRepository$uninstallAddon$1 = (AddonRepository$uninstallAddon$1) continuation; int i = addonRepository$uninstallAddon$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$uninstallAddon$1.label = i - Integer.MIN_VALUE; } else { addonRepository$uninstallAddon$1 = new AddonRepository$uninstallAddon$1(this, continuation); } } Object objF = addonRepository$uninstallAddon$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$uninstallAddon$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$uninstallAddon$2 addonRepository$uninstallAddon$2 = new AddonRepository$uninstallAddon$2(this, str, null); addonRepository$uninstallAddon$1.label = 1; objF = wj0.f(m02Var, addonRepository$uninstallAddon$2, addonRepository$uninstallAddon$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: updateBundle-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m64updateBundlegIAlus(@kp6 String str, @kp6 Continuation> continuation) throws Throwable { AddonRepository$updateBundle$1 addonRepository$updateBundle$1; if (continuation instanceof AddonRepository$updateBundle$1) { addonRepository$updateBundle$1 = (AddonRepository$updateBundle$1) continuation; int i = addonRepository$updateBundle$1.label; if ((i & Integer.MIN_VALUE) != 0) { addonRepository$updateBundle$1.label = i - Integer.MIN_VALUE; } else { addonRepository$updateBundle$1 = new AddonRepository$updateBundle$1(this, continuation); } } Object objF = addonRepository$updateBundle$1.result; ck1 ck1Var = ck1.a; int i2 = addonRepository$updateBundle$1.label; if (i2 == 0) { s38.b(objF); m12 m12Var = sc2.a; m02 m02Var = m02.c; AddonRepository$updateBundle$2 addonRepository$updateBundle$2 = new AddonRepository$updateBundle$2(str, this, null); addonRepository$updateBundle$1.label = 1; objF = wj0.f(m02Var, addonRepository$updateBundle$2, addonRepository$updateBundle$1); if (objF == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objF); } return ((q38) objF).a; } @pq6 public final Object updateConfig(@kp6 String str, @kp6 String str2, @kp6 String str3, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02782(str, str2, str3, null), continuation); return objF == ck1.a ? objF : e6a.a; } @pq6 public final Object updateLastUsed(@kp6 String str, @kp6 Continuation continuation) throws Throwable { m12 m12Var = sc2.a; Object objF = wj0.f(m02.c, new C02792(str, null), continuation); return objF == ck1.a ? objF : e6a.a; } @Metadata(d1 = {"\u0000\u0016\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0006\u0018\u00002\u00060\u0001j\u0002`\u0002B\u0019\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\b\b\u0002\u0010\u0005\u001a\u00020\u0004¢\u0006\u0004\b\u0006\u0010\u0007R\u0011\u0010\u0003\u001a\u00020\u0004¢\u0006\b\n\u0000\u001a\u0004\b\b\u0010\t¨\u0006\n"}, d2 = {"Lcom/strmr/ps/data/repository/AddonRepository$AddonAlreadyInstalledException;", "Ljava/lang/Exception;", "Lkotlin/Exception;", "existingName", "", "message", "", "(Ljava/lang/String;Ljava/lang/String;)V", "getExistingName", "()Ljava/lang/String;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) public static final class AddonAlreadyInstalledException extends Exception { @kp6 private final String existingName; public /* synthetic */ AddonAlreadyInstalledException(String str, String str2, int i, uz1 uz1Var) { this(str, (i & 2) != 0 ? vw2.ab("This addon is already installed as \"", str, "\". Would you like to add another instance?") : str2); } @kp6 public final String getExistingName() { return this.existingName; } /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */ public AddonAlreadyInstalledException(@kp6 String str, @kp6 String str2) { super(str2); cr4.g(str, "existingName"); cr4.g(str2, "message"); this.existingName = str; } } }