package com.strmr.ps.data.repository; import android.util.Log; import androidx.media3.container.NalUnitUtil; import com.google.android.gms.measurement.api.AppMeasurementSdk; import com.strmr.ps.data.local.dao.PremiumizeAccountDao; import com.strmr.ps.data.local.entity.PlaybackProgress; import com.strmr.ps.data.local.entity.PremiumizeAccount; import com.strmr.ps.data.model.DebridError; import com.strmr.ps.data.model.DebridProvider; import com.strmr.ps.data.model.debrid.DebridFileItem; import com.strmr.ps.data.model.debrid.DebridService; import com.strmr.ps.data.model.debrid.FolderBreadcrumb; import com.strmr.ps.data.model.debrid.VideoExtensions; import com.strmr.ps.data.remote.api.PremiumizeApiService; import com.strmr.ps.data.remote.api.PremiumizeAuthService; import com.strmr.ps.data.remote.model.premiumize.PremiumizeAccountResponse; import com.strmr.ps.data.remote.model.premiumize.PremiumizeBreadcrumb; import com.strmr.ps.data.remote.model.premiumize.PremiumizeCacheCheckResponse; import com.strmr.ps.data.remote.model.premiumize.PremiumizeContent; import com.strmr.ps.data.remote.model.premiumize.PremiumizeDeviceCodeResponse; import com.strmr.ps.data.remote.model.premiumize.PremiumizeDirectLinkResponse; import com.strmr.ps.data.remote.model.premiumize.PremiumizeFolderItem; import com.strmr.ps.data.remote.model.premiumize.PremiumizeFolderListResponse; import com.strmr.ps.data.remote.model.premiumize.PremiumizeTokenResponse; import com.strmr.ps.data.supabase.DeviceManager; import com.strmr.ps.data.supabase.SettingsSyncManager; import dagger.Lazy; import defpackage.ak1; import defpackage.bk1; import defpackage.ck1; import defpackage.cr4; import defpackage.e6a; import defpackage.f21; import defpackage.kp6; import defpackage.kq; import defpackage.m02; import defpackage.m12; import defpackage.n41; import defpackage.n89; import defpackage.pq6; import defpackage.pw7; import defpackage.q38; import defpackage.qo9; import defpackage.s38; import defpackage.sc2; import defpackage.vo2; import defpackage.vw2; import defpackage.vx8; import defpackage.wo5; import defpackage.y41; import java.io.IOException; import java.net.SocketTimeoutException; import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Collection; import java.util.Iterator; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.concurrent.ExecutorService; import javax.inject.Inject; import javax.inject.Singleton; import kotlin.Metadata; import kotlin.coroutines.Continuation; import kotlin.coroutines.jvm.internal.Boxing; import kotlin.coroutines.jvm.internal.ContinuationImpl; import kotlin.coroutines.jvm.internal.DebugMetadata; import okhttp3.ResponseBody; import retrofit2.HttpException; import retrofit2.Response; /* JADX INFO: loaded from: classes3.dex */ @Singleton @Metadata(d1 = {"\u0000®\u0001\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u000b\n\u0002\u0010 \n\u0000\n\u0002\u0010$\n\u0002\u0010\u000b\n\u0002\b\u0003\n\u0002\u0010\b\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\u0007\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0010\t\n\u0002\b\u0005\n\u0002\u0018\u0002\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0002\b\b\n\u0002\u0018\u0002\n\u0002\b\u0006\b\u0007\u0018\u0000 {2\u00020\u0001:\u0001{BE\b\u0007\u0012\u0006\u0010\u0003\u001a\u00020\u0002\u0012\u0006\u0010\u0005\u001a\u00020\u0004\u0012\u0006\u0010\u0007\u001a\u00020\u0006\u0012\f\u0010\n\u001a\b\u0012\u0004\u0012\u00020\t0\b\u0012\f\u0010\f\u001a\b\u0012\u0004\u0012\u00020\u000b0\b\u0012\u0006\u0010\u000e\u001a\u00020\r¢\u0006\u0004\b\u000f\u0010\u0010J\u0012\u0010\u0012\u001a\u0004\u0018\u00010\u0011H\u0086@¢\u0006\u0004\b\u0012\u0010\u0013J\u0016\u0010\u0017\u001a\b\u0012\u0004\u0012\u00020\u00150\u0014H\u0086@¢\u0006\u0004\b\u0016\u0010\u0013J \u0010\u001d\u001a\n\u0012\u0006\u0012\u0004\u0018\u00010\u001a0\u00142\u0006\u0010\u0019\u001a\u00020\u0018H\u0086@¢\u0006\u0004\b\u001b\u0010\u001cJ\u001e\u0010 \u001a\b\u0012\u0004\u0012\u00020\u00110\u00142\u0006\u0010\u001e\u001a\u00020\u0018H\u0086@¢\u0006\u0004\b\u001f\u0010\u001cJ\u001e\u0010#\u001a\b\u0012\u0004\u0012\u00020\u00110\u00142\u0006\u0010!\u001a\u00020\u0018H\u0086@¢\u0006\u0004\b\"\u0010\u001cJ\u0016\u0010%\u001a\b\u0012\u0004\u0012\u00020\u00110\u0014H\u0086@¢\u0006\u0004\b$\u0010\u0013J2\u0010,\u001a\u0016\u0012\u0012\u0012\u0010\u0012\u0004\u0012\u00020\u0018\u0012\u0006\u0012\u0004\u0018\u00010)0(0\u00142\f\u0010'\u001a\b\u0012\u0004\u0012\u00020\u00180&H\u0096@¢\u0006\u0004\b*\u0010+J\u0012\u0010.\u001a\u0004\u0018\u00010-H\u0096@¢\u0006\u0004\b.\u0010\u0013JF\u00106\u001a\b\u0012\u0004\u0012\u00020\u00180\u00142\u0006\u0010/\u001a\u00020\u00182\b\u00100\u001a\u0004\u0018\u00010-2\b\u00101\u001a\u0004\u0018\u00010-2\b\u00102\u001a\u0004\u0018\u00010-2\b\u00103\u001a\u0004\u0018\u00010\u0018H\u0096@¢\u0006\u0004\b4\u00105J\u0010\u00108\u001a\u000207H\u0096@¢\u0006\u0004\b8\u0010\u0013J\u0010\u00109\u001a\u00020)H\u0096@¢\u0006\u0004\b9\u0010\u0013J\u0012\u0010:\u001a\u0004\u0018\u00010\u0018H\u0096@¢\u0006\u0004\b:\u0010\u0013J\u0012\u0010;\u001a\u0004\u0018\u00010\u0018H\u0086@¢\u0006\u0004\b;\u0010\u0013J\u0017\u0010=\u001a\u0004\u0018\u00010-2\u0006\u0010<\u001a\u00020\u0011¢\u0006\u0004\b=\u0010>J\u001c\u0010A\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020?0&0\u0014H\u0096@¢\u0006\u0004\b@\u0010\u0013J(\u0010A\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020?0&0\u00142\n\b\u0002\u0010B\u001a\u0004\u0018\u00010\u0018H\u0086@¢\u0006\u0004\bC\u0010\u001cJ&\u0010F\u001a\u000e\u0012\n\u0012\b\u0012\u0004\u0012\u00020D0&0\u00142\b\u0010B\u001a\u0004\u0018\u00010\u0018H\u0086@¢\u0006\u0004\bE\u0010\u001cJ\u001e\u0010K\u001a\b\u0012\u0004\u0012\u00020\u00180\u00142\u0006\u0010H\u001a\u00020GH\u0096@¢\u0006\u0004\bI\u0010JJ\u001e\u0010N\u001a\b\u0012\u0004\u0012\u0002070\u00142\u0006\u0010L\u001a\u00020\u0018H\u0086@¢\u0006\u0004\bM\u0010\u001cJ\u001e\u0010P\u001a\b\u0012\u0004\u0012\u0002070\u00142\u0006\u0010B\u001a\u00020\u0018H\u0086@¢\u0006\u0004\bO\u0010\u001cJ&\u0010T\u001a\b\u0012\u0004\u0012\u0002070\u00142\u0006\u0010L\u001a\u00020\u00182\u0006\u0010Q\u001a\u00020\u0018H\u0086@¢\u0006\u0004\bR\u0010SJ&\u0010V\u001a\b\u0012\u0004\u0012\u0002070\u00142\u0006\u0010B\u001a\u00020\u00182\u0006\u0010Q\u001a\u00020\u0018H\u0086@¢\u0006\u0004\bU\u0010SJ*\u0010\\\u001a\b\u0012\u0004\u0012\u0002070\u00142\u0006\u0010X\u001a\u00020W2\n\b\u0002\u0010Y\u001a\u0004\u0018\u00010\u0018H\u0086@¢\u0006\u0004\bZ\u0010[JG\u0010_\u001a\u0004\u0018\u00010\u00182\u0006\u0010^\u001a\u00020]2\b\u00100\u001a\u0004\u0018\u00010-2\n\b\u0002\u00101\u001a\u0004\u0018\u00010-2\n\b\u0002\u00102\u001a\u0004\u0018\u00010-2\n\b\u0002\u00103\u001a\u0004\u0018\u00010\u0018H\u0002¢\u0006\u0004\b_\u0010`J \u0010b\u001a\u0002072\u0006\u0010<\u001a\u00020\u00112\u0006\u0010a\u001a\u00020\u0018H\u0082@¢\u0006\u0004\bb\u0010cJ\u0017\u0010e\u001a\u00020\u00182\u0006\u0010d\u001a\u00020\u0018H\u0002¢\u0006\u0004\be\u0010fJ\u0010\u0010g\u001a\u000207H\u0082@¢\u0006\u0004\bg\u0010\u0013R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010hR\u0014\u0010\u0005\u001a\u00020\u00048\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0005\u0010iR\u0014\u0010\u0007\u001a\u00020\u00068\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0007\u0010jR\u001a\u0010\n\u001a\b\u0012\u0004\u0012\u00020\t0\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\n\u0010kR\u001a\u0010\f\u001a\b\u0012\u0004\u0012\u00020\u000b0\b8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\f\u0010kR\u0014\u0010\u000e\u001a\u00020\r8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u000e\u0010lR\u001a\u0010n\u001a\u00020m8\u0016X\u0096\u0004¢\u0006\f\n\u0004\bn\u0010o\u001a\u0004\bp\u0010qR\u001a\u0010r\u001a\u00020\u00188\u0016X\u0096D¢\u0006\f\n\u0004\br\u0010s\u001a\u0004\bt\u0010uR\u0014\u0010w\u001a\u00020v8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\bw\u0010xR\u0014\u0010z\u001a\u00020\u00188BX\u0082\u0004¢\u0006\u0006\u001a\u0004\by\u0010u¨\u0006|"}, d2 = {"Lcom/strmr/ps/data/repository/PremiumizeRepository;", "Lcom/strmr/ps/data/repository/IDebridLibraryProvider;", "Lcom/strmr/ps/data/remote/api/PremiumizeApiService;", "premiumizeApiService", "Lcom/strmr/ps/data/remote/api/PremiumizeAuthService;", "premiumizeAuthService", "Lcom/strmr/ps/data/local/dao/PremiumizeAccountDao;", "accountDao", "Ldagger/Lazy;", "Lcom/strmr/ps/data/supabase/SettingsSyncManager;", "settingsSyncManager", "Lcom/strmr/ps/data/supabase/DeviceManager;", "deviceManager", "Lcom/strmr/ps/data/repository/LinkFilterPreferences;", "linkFilterPreferences", "", "(Lcom/strmr/ps/data/remote/api/PremiumizeApiService;Lcom/strmr/ps/data/remote/api/PremiumizeAuthService;Lcom/strmr/ps/data/local/dao/PremiumizeAccountDao;Ldagger/Lazy;Ldagger/Lazy;Lcom/strmr/ps/data/repository/LinkFilterPreferences;)V", "Lcom/strmr/ps/data/local/entity/PremiumizeAccount;", "getAccount", "(Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "Lq38;", "Lcom/strmr/ps/data/remote/model/premiumize/PremiumizeDeviceCodeResponse;", "requestDeviceCode-IoAF18A", "requestDeviceCode", "", "deviceCode", "Lcom/strmr/ps/data/remote/model/premiumize/PremiumizeTokenResponse;", "pollForToken-gIAlu-s", "(Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "pollForToken", "accessToken", "saveOAuthToken-gIAlu-s", "saveOAuthToken", "apiKey", "verifyAndSaveApiKey-gIAlu-s", "verifyAndSaveApiKey", "refreshAccountInfo-IoAF18A", "refreshAccountInfo", "", "hashes", "", "", "checkCacheStatus-gIAlu-s", "(Ljava/util/List;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "checkCacheStatus", "", "getAccountExpirationStatus", "magnetOrHash", "fileIdx", "season", PlaybackProgress.TYPE_EPISODE, "airDate", "resolveToDirectLink-hUnOzRk", "(Ljava/lang/String;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "resolveToDirectLink", "Le6a;", "clearAccount", "hasAccount", "getApiKey", "getApiKeyMasked", "account", "getDaysRemaining", "(Lcom/strmr/ps/data/local/entity/PremiumizeAccount;)Ljava/lang/Integer;", "Lcom/strmr/ps/data/model/debrid/DebridFileItem;", "getLibraryItems-IoAF18A", "getLibraryItems", "folderId", "getLibraryItems-gIAlu-s", "Lcom/strmr/ps/data/model/debrid/FolderBreadcrumb;", "getFolderBreadcrumbs-gIAlu-s", "getFolderBreadcrumbs", "Lcom/strmr/ps/data/model/debrid/DebridFileItem$File;", "file", "resolveLibraryFile-gIAlu-s", "(Lcom/strmr/ps/data/model/debrid/DebridFileItem$File;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "resolveLibraryFile", "itemId", "deleteItem-gIAlu-s", "deleteItem", "deleteFolder-gIAlu-s", "deleteFolder", "newName", "renameItem-0E7RQCE", "(Ljava/lang/String;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "renameItem", "renameFolder-0E7RQCE", "renameFolder", "", "resolveTimestamp", "fileName", "deleteMostRecent-0E7RQCE", "(JLjava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", "deleteMostRecent", "Lcom/strmr/ps/data/remote/model/premiumize/PremiumizeDirectLinkResponse;", "response", "selectBestLink", "(Lcom/strmr/ps/data/remote/model/premiumize/PremiumizeDirectLinkResponse;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/Integer;Ljava/lang/String;)Ljava/lang/String;", "filename", "cleanupCloudItem", "(Lcom/strmr/ps/data/local/entity/PremiumizeAccount;Ljava/lang/String;Lkotlin/coroutines/Continuation;)Ljava/lang/Object;", AppMeasurementSdk.ConditionalUserProperty.NAME, "normalizeForMatch", "(Ljava/lang/String;)Ljava/lang/String;", "triggerCloudSync", "Lcom/strmr/ps/data/remote/api/PremiumizeApiService;", "Lcom/strmr/ps/data/remote/api/PremiumizeAuthService;", "Lcom/strmr/ps/data/local/dao/PremiumizeAccountDao;", "Ldagger/Lazy;", "Lcom/strmr/ps/data/repository/LinkFilterPreferences;", "Lcom/strmr/ps/data/model/DebridProvider;", "provider", "Lcom/strmr/ps/data/model/DebridProvider;", "getProvider", "()Lcom/strmr/ps/data/model/DebridProvider;", "serviceName", "Ljava/lang/String;", "getServiceName", "()Ljava/lang/String;", "Lak1;", "syncScope", "Lak1;", "getClientId", "clientId", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @vx8 public final class PremiumizeRepository implements IDebridLibraryProvider { @kp6 private static final String PROVIDER_ID = "premiumize"; @kp6 private static final String TAG = "PremiumizeRepository"; @kp6 private final PremiumizeAccountDao accountDao; @kp6 private final Lazy deviceManager; @kp6 private final LinkFilterPreferences linkFilterPreferences; @kp6 private final PremiumizeApiService premiumizeApiService; @kp6 private final PremiumizeAuthService premiumizeAuthService; @kp6 private final DebridProvider provider; @kp6 private final String serviceName; @kp6 private final Lazy settingsSyncManager; @kp6 private final ak1 syncScope; /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$cleanupCloudItem$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.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {0, 0, 1, 1, 2, 3}, l = {459, 461, 479, 481}, m = "cleanupCloudItem", n = {"this", "filename", "this", "filename", "matchingItem", "matchingItem"}, s = {"L$0", "L$1", "L$0", "L$1", "L$0", "L$0"}) public static final class AnonymousClass1 extends ContinuationImpl { Object L$0; Object L$1; int label; /* synthetic */ Object result; public AnonymousClass1(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.cleanupCloudItem(null, null, this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$clearAccount$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {0}, l = {494, 497}, m = "clearAccount", n = {"this"}, s = {"L$0"}) public static final class C03681 extends ContinuationImpl { Object L$0; int label; /* synthetic */ Object result; public C03681(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.clearAccount(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$getAccountExpirationStatus$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {}, l = {275}, m = "getAccountExpirationStatus", n = {}, s = {}) public static final class C03691 extends ContinuationImpl { int label; /* synthetic */ Object result; public C03691(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.getAccountExpirationStatus(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$getApiKey$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {}, l = {505}, m = "getApiKey", n = {}, s = {}) public static final class C03701 extends ContinuationImpl { int label; /* synthetic */ Object result; public C03701(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.getApiKey(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$getApiKeyMasked$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {}, l = {512}, m = "getApiKeyMasked", n = {}, s = {}) public static final class C03711 extends ContinuationImpl { int label; /* synthetic */ Object result; public C03711(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.getApiKeyMasked(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$hasAccount$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {}, l = {503}, m = "hasAccount", n = {}, s = {}) public static final class C03721 extends ContinuationImpl { int label; /* synthetic */ Object result; public C03721(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.hasAccount(this); } } /* JADX INFO: renamed from: com.strmr.ps.data.repository.PremiumizeRepository$triggerCloudSync$1, reason: invalid class name and case insensitive filesystem */ @Metadata(k = 3, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED) @DebugMetadata(c = "com.strmr.ps.data.repository.PremiumizeRepository", f = "PremiumizeRepository.kt", i = {}, l = {890}, m = "triggerCloudSync", n = {}, s = {}) public static final class C03731 extends ContinuationImpl { int label; /* synthetic */ Object result; public C03731(Continuation continuation) { super(continuation); } @Override // kotlin.coroutines.jvm.internal.BaseContinuationImpl @pq6 public final Object invokeSuspend(@kp6 Object obj) { this.result = obj; this.label |= Integer.MIN_VALUE; return PremiumizeRepository.this.triggerCloudSync(this); } } @Inject public PremiumizeRepository(@kp6 PremiumizeApiService premiumizeApiService, @kp6 PremiumizeAuthService premiumizeAuthService, @kp6 PremiumizeAccountDao premiumizeAccountDao, @kp6 Lazy lazy, @kp6 Lazy lazy2, @kp6 LinkFilterPreferences linkFilterPreferences) { cr4.g(premiumizeApiService, "premiumizeApiService"); cr4.g(premiumizeAuthService, "premiumizeAuthService"); cr4.g(premiumizeAccountDao, "accountDao"); cr4.g(lazy, "settingsSyncManager"); cr4.g(lazy2, "deviceManager"); cr4.g(linkFilterPreferences, "linkFilterPreferences"); this.premiumizeApiService = premiumizeApiService; this.premiumizeAuthService = premiumizeAuthService; this.accountDao = premiumizeAccountDao; this.settingsSyncManager = lazy; this.deviceManager = lazy2; this.linkFilterPreferences = linkFilterPreferences; this.provider = DebridProvider.PREMIUMIZE; this.serviceName = "premiumize"; m12 m12Var = sc2.a; this.syncScope = bk1.a(m02.c); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Code restructure failed: missing block: B:51:0x0142, code lost: if (r1 == r3) goto L55; */ /* JADX WARN: Code restructure failed: missing block: B:54:0x0153, code lost: if (r1 == r3) goto L55; */ /* JADX WARN: Code restructure failed: missing block: B:56:0x0156, code lost: r2 = r1; r1 = r2; */ /* JADX WARN: Removed duplicated region for block: B:59:0x0163 */ /* JADX WARN: Removed duplicated region for block: B:61:0x0179 */ /* JADX WARN: Removed duplicated region for block: B:8:0x001a */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object cleanupCloudItem(PremiumizeAccount premiumizeAccount, String str, Continuation continuation) { AnonymousClass1 anonymousClass1; PremiumizeRepository premiumizeRepository; PremiumizeFolderListResponse premiumizeFolderListResponse; Object next; Object objM111deleteItemgIAlus; Throwable thA; String str2 = str; if (continuation instanceof AnonymousClass1) { anonymousClass1 = (AnonymousClass1) continuation; int i = anonymousClass1.label; if ((i & Integer.MIN_VALUE) != 0) { anonymousClass1.label = i - Integer.MIN_VALUE; } else { anonymousClass1 = new AnonymousClass1(continuation); } } AnonymousClass1 anonymousClass12 = anonymousClass1; Object objListFolder$default = anonymousClass12.result; ck1 ck1Var = ck1.a; int i2 = anonymousClass12.label; e6a e6aVar = e6a.a; if (i2 == 0) { s38.b(objListFolder$default); if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = this.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); anonymousClass12.L$0 = this; anonymousClass12.L$1 = str2; anonymousClass12.label = 1; objListFolder$default = PremiumizeApiService.DefaultImpls.listFolderWithToken$default(premiumizeApiService, authHeader, null, null, anonymousClass12, 4, null); if (objListFolder$default != ck1Var) { premiumizeRepository = this; premiumizeFolderListResponse = (PremiumizeFolderListResponse) objListFolder$default; } } else { PremiumizeApiService premiumizeApiService2 = this.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); anonymousClass12.L$0 = this; anonymousClass12.L$1 = str2; anonymousClass12.label = 2; objListFolder$default = PremiumizeApiService.DefaultImpls.listFolder$default(premiumizeApiService2, apiKey, null, null, anonymousClass12, 4, null); if (objListFolder$default != ck1Var) { premiumizeRepository = this; premiumizeFolderListResponse = (PremiumizeFolderListResponse) objListFolder$default; } } return ck1Var; } if (i2 == 1) { str2 = (String) anonymousClass12.L$1; premiumizeRepository = (PremiumizeRepository) anonymousClass12.L$0; s38.b(objListFolder$default); premiumizeFolderListResponse = (PremiumizeFolderListResponse) objListFolder$default; } else { if (i2 != 2) { if (i2 != 3 && i2 != 4) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } PremiumizeFolderItem premiumizeFolderItem = (PremiumizeFolderItem) anonymousClass12.L$0; s38.b(objListFolder$default); Object obj = ((q38) objListFolder$default).a; thA = q38.a(obj); if (thA == null) { ExecutorService executorService = kq.a; kq.a(TAG, n41.o("Cloud sanitization: failed to delete PM ", premiumizeFolderItem.getType(), " '", premiumizeFolderItem.getName(), "'"), thA); return e6aVar; } ExecutorService executorService2 = kq.a; kq.h(TAG, n41.o("Cloud sanitization: removed PM ", premiumizeFolderItem.getType(), " '", premiumizeFolderItem.getName(), "'")); return e6aVar; } str2 = (String) anonymousClass12.L$1; premiumizeRepository = (PremiumizeRepository) anonymousClass12.L$0; s38.b(objListFolder$default); premiumizeFolderListResponse = (PremiumizeFolderListResponse) objListFolder$default; } if (!cr4.b(premiumizeFolderListResponse.getStatus(), "success") || premiumizeFolderListResponse.getContent() == null) { ExecutorService executorService3 = kq.a; kq.h(TAG, "Cloud sanitization: failed to list PM root folder"); return e6aVar; } ExecutorService executorService4 = kq.a; kq.h(TAG, "Cloud sanitization: PM root folder has " + premiumizeFolderListResponse.getContent().size() + " items, searching for '" + str2 + "'"); Iterator it = premiumizeFolderListResponse.getContent().iterator(); while (true) { if (!it.hasNext()) { next = null; break; } next = it.next(); if (cr4.b(((PremiumizeFolderItem) next).getName(), str2)) { break; } } PremiumizeFolderItem premiumizeFolderItem2 = (PremiumizeFolderItem) next; if (premiumizeFolderItem2 == null) { ExecutorService executorService5 = kq.a; kq.h(TAG, "Cloud sanitization: no PM item found for '" + str2 + "'"); return e6aVar; } if (cr4.b(premiumizeFolderItem2.getType(), "folder")) { String id = premiumizeFolderItem2.getId(); anonymousClass12.L$0 = premiumizeFolderItem2; anonymousClass12.L$1 = null; anonymousClass12.label = 3; objM111deleteItemgIAlus = premiumizeRepository.m110deleteFoldergIAlus(id, anonymousClass12); } else { String id2 = premiumizeFolderItem2.getId(); anonymousClass12.L$0 = premiumizeFolderItem2; anonymousClass12.L$1 = null; anonymousClass12.label = 4; objM111deleteItemgIAlus = premiumizeRepository.m111deleteItemgIAlus(id2, anonymousClass12); } thA = q38.a(obj); if (thA == null) { } } /* JADX INFO: renamed from: deleteMostRecent-0E7RQCE$default, reason: not valid java name */ public static /* synthetic */ Object m108deleteMostRecent0E7RQCE$default(PremiumizeRepository premiumizeRepository, long j, String str, Continuation continuation, int i, Object obj) { if ((i & 2) != 0) { str = null; } return premiumizeRepository.m112deleteMostRecent0E7RQCE(j, str, continuation); } private final String getClientId() { return "943947168"; } /* JADX INFO: renamed from: getLibraryItems-gIAlu-s$default, reason: not valid java name */ public static /* synthetic */ Object m109getLibraryItemsgIAlus$default(PremiumizeRepository premiumizeRepository, String str, Continuation continuation, int i, Object obj) { if ((i & 1) != 0) { str = null; } return premiumizeRepository.m114getLibraryItemsgIAlus(str, continuation); } private final String normalizeForMatch(String name) { String lowerCase = name.toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); return n89.bg(new pw7("[.\\-_\\s]+").f(" ", n89.ba(lowerCase, lowerCase))).toString(); } private final String selectBestLink(PremiumizeDirectLinkResponse response, Integer fileIdx, Integer season, Integer episode, String airDate) { String lowerCase; Object next; Object next2; boolean z; List content = response.getContent(); List list = content; if (list == null || list.isEmpty()) { Log.w(TAG, "selectBestLink: No content array in response"); return null; } List listAn = y41.an(".mkv", ".mp4", ".avi", ".mov", ".wmv", ".m4v", ".webm", ".ts", ".m2ts"); List listAn2 = y41.an(".srt", ".sub", ".idx", ".ass", ".ssa", ".nfo", ".txt", ".jpg", ".jpeg", ".png", ".gif", ".exe", ".rar", ".zip", ".7z"); ArrayList arrayList = new ArrayList(); Iterator it = content.iterator(); while (true) { lowerCase = ""; boolean z2 = false; if (!it.hasNext()) { break; } Object next3 = it.next(); String path = ((PremiumizeContent) next3).getPath(); if (path != null) { lowerCase = path.toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); } List list2 = listAn; if ((list2 instanceof Collection) && list2.isEmpty()) { z = false; } else { Iterator it2 = list2.iterator(); while (it2.hasNext()) { if (n89.r(lowerCase, (String) it2.next(), false)) { z = true; break; } } z = false; } List list3 = listAn2; if (!(list3 instanceof Collection) || !list3.isEmpty()) { Iterator it3 = list3.iterator(); while (true) { if (!it3.hasNext()) { break; } if (n89.r(lowerCase, (String) it3.next(), false)) { z2 = true; break; } } } if (z && !z2) { arrayList.add(next3); } } StringBuilder sbR = vw2.r("selectBestLink: ", content.size(), " total files, ", " video files, fileIdx=", arrayList.size()); sbR.append(fileIdx); sbR.append(", season="); sbR.append(season); sbR.append(", episode="); sbR.append(episode); Log.w(TAG, sbR.toString()); if (fileIdx != null && fileIdx.intValue() < content.size()) { PremiumizeContent premiumizeContent = content.get(fileIdx.intValue()); String path2 = premiumizeContent.getPath(); if (path2 != null) { lowerCase = path2.toLowerCase(Locale.ROOT); cr4.f(lowerCase, "toLowerCase(...)"); } List list4 = listAn; if (!(list4 instanceof Collection) || !list4.isEmpty()) { Iterator it4 = list4.iterator(); while (it4.hasNext()) { if (n89.r(lowerCase, (String) it4.next(), false)) { Log.w(TAG, "Using fileIdx " + fileIdx + ": " + premiumizeContent.getPath()); String streamLink = premiumizeContent.getStreamLink(); return streamLink == null ? premiumizeContent.getLink() : streamLink; } } } Log.w(TAG, "fileIdx " + fileIdx + " is not a video file: " + premiumizeContent.getPath()); } if (season != null && episode != null && !arrayList.isEmpty()) { ArrayList arrayList2 = new ArrayList(); Iterator it5 = arrayList.iterator(); while (it5.hasNext()) { String path3 = ((PremiumizeContent) it5.next()).getPath(); if (path3 != null) { arrayList2.add(path3); } } String strD = vo2.d(arrayList2, season.intValue(), episode.intValue(), airDate); if (strD == null) { strD = vo2.c(arrayList2, season.intValue(), episode.intValue(), airDate); } if (strD != null) { Iterator it6 = arrayList.iterator(); while (true) { if (!it6.hasNext()) { next2 = null; break; } next2 = it6.next(); if (cr4.b(((PremiumizeContent) next2).getPath(), strD)) { break; } } PremiumizeContent premiumizeContent2 = (PremiumizeContent) next2; if (premiumizeContent2 != null) { Log.w(TAG, "Found episode S" + season + "E" + episode + " by filename: " + premiumizeContent2.getPath()); String streamLink2 = premiumizeContent2.getStreamLink(); return streamLink2 == null ? premiumizeContent2.getLink() : streamLink2; } } Log.w(TAG, "Could not find episode S" + season + "E" + episode + " by filename pattern in " + arrayList.size() + " video files"); } Iterator it7 = arrayList.iterator(); if (it7.hasNext()) { next = it7.next(); if (it7.hasNext()) { Long size = ((PremiumizeContent) next).getSize(); long jLongValue = size != null ? size.longValue() : 0L; do { Object next4 = it7.next(); Long size2 = ((PremiumizeContent) next4).getSize(); long jLongValue2 = size2 != null ? size2.longValue() : 0L; if (jLongValue < jLongValue2) { next = next4; jLongValue = jLongValue2; } } while (it7.hasNext()); } } else { next = null; } PremiumizeContent premiumizeContent3 = (PremiumizeContent) next; if (premiumizeContent3 == null) { Log.w(TAG, "No video files found in " + content.size() + " files"); return null; } Log.w(TAG, "Fallback to largest video: " + premiumizeContent3.getPath() + " (" + premiumizeContent3.getSize() + " bytes)"); String streamLink3 = premiumizeContent3.getStreamLink(); return streamLink3 == null ? premiumizeContent3.getLink() : streamLink3; } public static /* synthetic */ String selectBestLink$default(PremiumizeRepository premiumizeRepository, PremiumizeDirectLinkResponse premiumizeDirectLinkResponse, Integer num, Integer num2, Integer num3, String str, int i, Object obj) { if ((i & 4) != 0) { num2 = null; } if ((i & 8) != 0) { num3 = null; } if ((i & 16) != 0) { str = null; } return premiumizeRepository.selectBestLink(premiumizeDirectLinkResponse, num, num2, num3, str); } /* JADX INFO: Access modifiers changed from: private */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object triggerCloudSync(Continuation continuation) { C03731 c03731; if (continuation instanceof C03731) { c03731 = (C03731) continuation; int i = c03731.label; if ((i & Integer.MIN_VALUE) != 0) { c03731.label = i - Integer.MIN_VALUE; } else { c03731 = new C03731(continuation); } } Object objC = c03731.result; ck1 ck1Var = ck1.a; int i2 = c03731.label; e6a e6aVar = e6a.a; try { if (i2 == 0) { s38.b(objC); String strE = this.deviceManager.get().e(); if (strE == null) { Log.w(TAG, "Skipping cloud sync: device not linked (no access token)"); return e6aVar; } PremiumizeRepository$triggerCloudSync$result$1 premiumizeRepository$triggerCloudSync$result$1 = new PremiumizeRepository$triggerCloudSync$result$1(this, strE, null); c03731.label = 1; objC = qo9.c(5000L, premiumizeRepository$triggerCloudSync$result$1, c03731); if (objC == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objC); } if (cr4.b((Boolean) objC, Boxing.boxBoolean(true))) { Log.w(TAG, "Premiumize cloud sync completed successfully"); } else { Log.w(TAG, "Premiumize cloud sync timed out or returned false — pending deletion flag preserved"); } } catch (Exception e) { Log.w(TAG, "Premiumize cloud sync failed — pending deletion flag preserved", e); } return e6aVar; } /* JADX WARN: Code restructure failed: missing block: B:39:0x00a6, code lost: if (r10 == r1) goto L40; */ /* JADX WARN: Removed duplicated region for block: B:44:0x00b7 A[Catch: Exception -> 0x0034, TryCatch #0 {Exception -> 0x0034, blocks: (B:14:0x002f, B:41:0x00a9, B:42:0x00ab, B:44:0x00b7, B:46:0x00bd, B:55:0x00fb, B:49:0x00d8, B:50:0x00e0, B:52:0x00e6, B:54:0x00f8, B:57:0x0121, B:60:0x012b, B:21:0x0043, B:37:0x0090, B:32:0x0073, B:34:0x007a, B:38:0x0093), top: B:64:0x0023 }] */ /* JADX WARN: Removed duplicated region for block: B:59:0x0129 */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* JADX INFO: renamed from: checkCacheStatus-gIAlu-s */ /* Code decompiled incorrectly, please refer to instructions dump. */ public Object mo66checkCacheStatusgIAlus(@kp6 List list, @kp6 Continuation>> continuation) { PremiumizeRepository$checkCacheStatus$1 premiumizeRepository$checkCacheStatus$1; PremiumizeRepository premiumizeRepository; PremiumizeCacheCheckResponse premiumizeCacheCheckResponse; String message; if (continuation instanceof PremiumizeRepository$checkCacheStatus$1) { premiumizeRepository$checkCacheStatus$1 = (PremiumizeRepository$checkCacheStatus$1) continuation; int i = premiumizeRepository$checkCacheStatus$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$checkCacheStatus$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$checkCacheStatus$1 = new PremiumizeRepository$checkCacheStatus$1(this, continuation); } } Object account = premiumizeRepository$checkCacheStatus$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$checkCacheStatus$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$checkCacheStatus$1.L$0 = this; premiumizeRepository$checkCacheStatus$1.L$1 = list; premiumizeRepository$checkCacheStatus$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$checkCacheStatus$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 != 1) { if (i2 == 2) { list = (List) premiumizeRepository$checkCacheStatus$1.L$0; s38.b(account); premiumizeCacheCheckResponse = (PremiumizeCacheCheckResponse) account; if (cr4.b(premiumizeCacheCheckResponse.getStatus(), "success")) { } message = premiumizeCacheCheckResponse.getMessage(); if (message == null) { } return s38.a(new Exception(message)); } if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } list = (List) premiumizeRepository$checkCacheStatus$1.L$0; s38.b(account); premiumizeCacheCheckResponse = (PremiumizeCacheCheckResponse) account; if (cr4.b(premiumizeCacheCheckResponse.getStatus(), "success") || premiumizeCacheCheckResponse.getResponse() == null) { message = premiumizeCacheCheckResponse.getMessage(); if (message == null) { message = "Cache check failed"; } return s38.a(new Exception(message)); } Map mapM = wo5.m(y41.bt(list, premiumizeCacheCheckResponse.getResponse())); ExecutorService executorService = kq.a; int i3 = 0; if (!mapM.isEmpty()) { Iterator it = mapM.entrySet().iterator(); while (it.hasNext()) { if (((Boolean) ((Map.Entry) it.next()).getValue()).booleanValue()) { i3++; } } } kq.h(TAG, "Cache check: " + i3 + " of " + list.size() + " cached"); return mapM; } list = (List) premiumizeRepository$checkCacheStatus$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$checkCacheStatus$1.L$0; s38.b(account); PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return vw2.d("No Premiumize account configured"); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$checkCacheStatus$1.L$0 = list; premiumizeRepository$checkCacheStatus$1.L$1 = null; premiumizeRepository$checkCacheStatus$1.label = 2; account = premiumizeApiService.checkCacheWithToken(authHeader, list, premiumizeRepository$checkCacheStatus$1); if (account == ck1Var) { } premiumizeCacheCheckResponse = (PremiumizeCacheCheckResponse) account; if (cr4.b(premiumizeCacheCheckResponse.getStatus(), "success")) { } message = premiumizeCacheCheckResponse.getMessage(); if (message == null) { } return s38.a(new Exception(message)); } PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$checkCacheStatus$1.L$0 = list; premiumizeRepository$checkCacheStatus$1.L$1 = null; premiumizeRepository$checkCacheStatus$1.label = 3; account = premiumizeApiService2.checkCache(apiKey, list, premiumizeRepository$checkCacheStatus$1); return ck1Var; } catch (Exception e) { Log.e(TAG, "Failed to check cache status", e); return s38.a(e); } } /* JADX WARN: Code restructure failed: missing block: B:21:0x006a, code lost: if (r2.triggerCloudSync(r0) == r1) goto L22; */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public Object clearAccount(@kp6 Continuation continuation) { C03681 c03681; PremiumizeRepository premiumizeRepository; if (continuation instanceof C03681) { c03681 = (C03681) continuation; int i = c03681.label; if ((i & Integer.MIN_VALUE) != 0) { c03681.label = i - Integer.MIN_VALUE; } else { c03681 = new C03681(continuation); } } Object obj = c03681.result; ck1 ck1Var = ck1.a; int i2 = c03681.label; if (i2 == 0) { s38.b(obj); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; c03681.L$0 = this; c03681.label = 1; if (premiumizeAccountDao.deleteAccount("premiumize", c03681) != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 != 1) { if (i2 != 2) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); return e6a.a; } premiumizeRepository = (PremiumizeRepository) c03681.L$0; s38.b(obj); ExecutorService executorService = kq.a; kq.h(TAG, "Premiumize account cleared"); premiumizeRepository.settingsSyncManager.get().e("premiumize"); c03681.L$0 = null; c03681.label = 2; } /* JADX WARN: Code restructure failed: missing block: B:41:0x00b2, code lost: if (r12 == r2) goto L42; */ /* JADX WARN: Removed duplicated region for block: B:46:0x00c3 A[Catch: Exception -> 0x0038, HttpException -> 0x003b, TryCatch #2 {HttpException -> 0x003b, Exception -> 0x0038, blocks: (B:14:0x0033, B:43:0x00b5, B:44:0x00b7, B:46:0x00c3, B:48:0x00c6, B:51:0x00cd, B:23:0x004a, B:39:0x009c, B:34:0x007f, B:36:0x0086, B:40:0x009f), top: B:56:0x0027 }] */ /* JADX WARN: Removed duplicated region for block: B:48:0x00c6 A[Catch: Exception -> 0x0038, HttpException -> 0x003b, TryCatch #2 {HttpException -> 0x003b, Exception -> 0x0038, blocks: (B:14:0x0033, B:43:0x00b5, B:44:0x00b7, B:46:0x00c3, B:48:0x00c6, B:51:0x00cd, B:23:0x004a, B:39:0x009c, B:34:0x007f, B:36:0x0086, B:40:0x009f), top: B:56:0x0027 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ @pq6 /* JADX INFO: renamed from: deleteFolder-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m110deleteFoldergIAlus(@kp6 String str, @kp6 Continuation> continuation) { PremiumizeRepository$deleteFolder$1 premiumizeRepository$deleteFolder$1; PremiumizeRepository premiumizeRepository; PremiumizeAccountResponse premiumizeAccountResponse; if (continuation instanceof PremiumizeRepository$deleteFolder$1) { premiumizeRepository$deleteFolder$1 = (PremiumizeRepository$deleteFolder$1) continuation; int i = premiumizeRepository$deleteFolder$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$deleteFolder$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$deleteFolder$1 = new PremiumizeRepository$deleteFolder$1(this, continuation); } } Object account = premiumizeRepository$deleteFolder$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$deleteFolder$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$deleteFolder$1.L$0 = this; premiumizeRepository$deleteFolder$1.L$1 = str; premiumizeRepository$deleteFolder$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$deleteFolder$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str = (String) premiumizeRepository$deleteFolder$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$deleteFolder$1.L$0; s38.b(account); } else { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { return e6a.a; } String message = premiumizeAccountResponse.getMessage(); if (message == null) { message = "Failed to delete folder"; } Log.e(TAG, "Failed to delete folder: ".concat(message)); return s38.a(new Exception(message)); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$deleteFolder$1.L$0 = str; premiumizeRepository$deleteFolder$1.L$1 = null; premiumizeRepository$deleteFolder$1.label = 2; account = premiumizeApiService.deleteFolderWithToken(authHeader, str, premiumizeRepository$deleteFolder$1); if (account == ck1Var) { } premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$deleteFolder$1.L$0 = str; premiumizeRepository$deleteFolder$1.L$1 = null; premiumizeRepository$deleteFolder$1.label = 3; account = premiumizeApiService2.deleteFolder(apiKey, str, premiumizeRepository$deleteFolder$1); } return ck1Var; } catch (HttpException e) { Log.e(TAG, "Failed to delete folder: HTTP " + e.code(), e); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e.code()), e)); } catch (Exception e2) { Log.e(TAG, "Failed to delete folder", e2); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e2.getMessage(), e2)); } } /* JADX WARN: Code restructure failed: missing block: B:41:0x00b2, code lost: if (r12 == r2) goto L42; */ /* JADX WARN: Removed duplicated region for block: B:46:0x00c3 A[Catch: Exception -> 0x0038, HttpException -> 0x003b, TryCatch #2 {HttpException -> 0x003b, Exception -> 0x0038, blocks: (B:14:0x0033, B:43:0x00b5, B:44:0x00b7, B:46:0x00c3, B:48:0x00c6, B:51:0x00cd, B:23:0x004a, B:39:0x009c, B:34:0x007f, B:36:0x0086, B:40:0x009f), top: B:56:0x0027 }] */ /* JADX WARN: Removed duplicated region for block: B:48:0x00c6 A[Catch: Exception -> 0x0038, HttpException -> 0x003b, TryCatch #2 {HttpException -> 0x003b, Exception -> 0x0038, blocks: (B:14:0x0033, B:43:0x00b5, B:44:0x00b7, B:46:0x00c3, B:48:0x00c6, B:51:0x00cd, B:23:0x004a, B:39:0x009c, B:34:0x007f, B:36:0x0086, B:40:0x009f), top: B:56:0x0027 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0015 */ @pq6 /* JADX INFO: renamed from: deleteItem-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m111deleteItemgIAlus(@kp6 String str, @kp6 Continuation> continuation) { PremiumizeRepository$deleteItem$1 premiumizeRepository$deleteItem$1; PremiumizeRepository premiumizeRepository; PremiumizeAccountResponse premiumizeAccountResponse; if (continuation instanceof PremiumizeRepository$deleteItem$1) { premiumizeRepository$deleteItem$1 = (PremiumizeRepository$deleteItem$1) continuation; int i = premiumizeRepository$deleteItem$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$deleteItem$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$deleteItem$1 = new PremiumizeRepository$deleteItem$1(this, continuation); } } Object account = premiumizeRepository$deleteItem$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$deleteItem$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$deleteItem$1.L$0 = this; premiumizeRepository$deleteItem$1.L$1 = str; premiumizeRepository$deleteItem$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$deleteItem$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str = (String) premiumizeRepository$deleteItem$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$deleteItem$1.L$0; s38.b(account); } else { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { return e6a.a; } String message = premiumizeAccountResponse.getMessage(); if (message == null) { message = "Failed to delete item"; } Log.e(TAG, "Failed to delete item: ".concat(message)); return s38.a(new Exception(message)); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$deleteItem$1.L$0 = str; premiumizeRepository$deleteItem$1.L$1 = null; premiumizeRepository$deleteItem$1.label = 2; account = premiumizeApiService.deleteItemWithToken(authHeader, str, premiumizeRepository$deleteItem$1); if (account == ck1Var) { } premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$deleteItem$1.L$0 = str; premiumizeRepository$deleteItem$1.L$1 = null; premiumizeRepository$deleteItem$1.label = 3; account = premiumizeApiService2.deleteItem(apiKey, str, premiumizeRepository$deleteItem$1); } return ck1Var; } catch (HttpException e) { Log.e(TAG, "Failed to delete item: HTTP " + e.code(), e); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e.code()), e)); } catch (Exception e2) { Log.e(TAG, "Failed to delete item", e2); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e2.getMessage(), e2)); } } /* JADX WARN: Multi-variable type inference failed */ /* JADX WARN: Not initialized variable reg: 20, insn: 0x009a: MOVE (r1 I:??[OBJECT, ARRAY]) = (r20 I:??[OBJECT, ARRAY]), block:B:26:0x0093 */ /* JADX WARN: Path cross not found for [B:151:0x0499, B:188:0x0542], limit reached: 268 */ /* JADX WARN: Path cross not found for [B:188:0x0542, B:151:0x0499], limit reached: 268 */ /* JADX WARN: Removed duplicated region for block: B:119:0x03fc A[Catch: Exception -> 0x01a4, TRY_LEAVE, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:151:0x0499 A[Catch: Exception -> 0x053e, TryCatch #11 {Exception -> 0x053e, blocks: (B:149:0x048f, B:151:0x0499, B:153:0x049f, B:154:0x04a9), top: B:242:0x048f }] */ /* JADX WARN: Removed duplicated region for block: B:176:0x04fb A[Catch: Exception -> 0x0537, TRY_LEAVE, TryCatch #6 {Exception -> 0x0537, blocks: (B:174:0x04f7, B:176:0x04fb), top: B:234:0x04f7 }] */ /* JADX WARN: Removed duplicated region for block: B:200:0x0593 */ /* JADX WARN: Removed duplicated region for block: B:205:0x05a6 A[Catch: Exception -> 0x01a4, TRY_ENTER, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:207:0x05c8 A[Catch: Exception -> 0x01a4, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:217:0x065d A[Catch: Exception -> 0x01a4, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:218:0x068f A[Catch: Exception -> 0x01a4, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:255:0x029b A[SYNTHETIC] */ /* JADX WARN: Removed duplicated region for block: B:43:0x0158 */ /* JADX WARN: Removed duplicated region for block: B:45:0x0164 A[Catch: Exception -> 0x004d, TRY_ENTER, TryCatch #2 {Exception -> 0x004d, blocks: (B:14:0x0041, B:15:0x0046, B:20:0x0055, B:31:0x00eb, B:34:0x010c, B:45:0x0164, B:47:0x016a), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:63:0x01e0 A[Catch: Exception -> 0x01a4, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:69:0x023b A[Catch: Exception -> 0x01a4, TryCatch #14 {Exception -> 0x01a4, blocks: (B:215:0x0657, B:217:0x065d, B:218:0x068f, B:202:0x05a0, B:205:0x05a6, B:207:0x05c8, B:209:0x0615, B:212:0x0636, B:199:0x0568, B:117:0x03f6, B:119:0x03fc, B:60:0x01d4, B:61:0x01d6, B:63:0x01e0, B:66:0x01e8, B:67:0x0233, B:69:0x023b, B:71:0x0259, B:72:0x025d, B:73:0x029b, B:74:0x02b5, B:76:0x02be, B:78:0x02cb, B:80:0x02d9, B:82:0x02e1, B:83:0x02e5, B:86:0x02f8, B:88:0x031d, B:89:0x0327, B:91:0x032d, B:93:0x0344, B:95:0x034b, B:100:0x0357, B:101:0x0359, B:103:0x035d, B:104:0x037c, B:107:0x0382, B:109:0x03a7, B:110:0x03b6, B:112:0x03bc, B:114:0x03cf, B:116:0x03d5, B:219:0x06bf, B:53:0x01a1, B:49:0x0195, B:56:0x01a7), top: B:227:0x0032 }] */ /* JADX WARN: Removed duplicated region for block: B:8:0x001a */ /* JADX WARN: Type inference failed for: r0v47, types: [java.lang.StringBuilder] */ /* JADX WARN: Type inference failed for: r15v1 */ /* JADX WARN: Type inference failed for: r15v10 */ /* JADX WARN: Type inference failed for: r15v11 */ /* JADX WARN: Type inference failed for: r15v12, types: [java.lang.String] */ /* JADX WARN: Type inference failed for: r15v2 */ /* JADX WARN: Type inference failed for: r15v20 */ /* JADX WARN: Type inference failed for: r15v21 */ /* JADX WARN: Type inference failed for: r15v22 */ /* JADX WARN: Type inference failed for: r15v23 */ /* JADX WARN: Type inference failed for: r15v24 */ /* JADX WARN: Type inference failed for: r15v25 */ /* JADX WARN: Type inference failed for: r15v26 */ /* JADX WARN: Type inference failed for: r15v27 */ /* JADX WARN: Type inference failed for: r15v28 */ /* JADX WARN: Type inference failed for: r15v29 */ /* JADX WARN: Type inference failed for: r15v3 */ /* JADX WARN: Type inference failed for: r15v30 */ /* JADX WARN: Type inference failed for: r15v31 */ /* JADX WARN: Type inference failed for: r15v32 */ /* JADX WARN: Type inference failed for: r15v33 */ /* JADX WARN: Type inference failed for: r15v34 */ /* JADX WARN: Type inference failed for: r15v35 */ /* JADX WARN: Type inference failed for: r15v36 */ /* JADX WARN: Type inference failed for: r15v4 */ /* JADX WARN: Type inference failed for: r15v5 */ /* JADX WARN: Type inference failed for: r15v6 */ /* JADX WARN: Type inference failed for: r15v7 */ /* JADX WARN: Type inference failed for: r15v8 */ /* JADX WARN: Type inference failed for: r15v9 */ /* JADX WARN: Type inference failed for: r2v0, types: [java.lang.String] */ /* JADX WARN: Type inference failed for: r2v1 */ /* JADX WARN: Type inference failed for: r2v11 */ /* JADX WARN: Type inference failed for: r2v12 */ /* JADX WARN: Type inference failed for: r2v17 */ /* JADX WARN: Type inference failed for: r2v25 */ /* JADX WARN: Type inference failed for: r2v3 */ /* JADX WARN: Type inference failed for: r2v30, types: [java.lang.StringBuilder] */ /* JADX WARN: Type inference failed for: r2v4 */ /* JADX WARN: Type inference failed for: r2v5 */ /* JADX WARN: Type inference failed for: r2v6 */ /* JADX WARN: Type inference failed for: r2v63 */ /* JADX WARN: Type inference failed for: r2v64 */ /* JADX WARN: Type inference failed for: r2v65 */ /* JADX WARN: Type inference failed for: r2v66 */ /* JADX WARN: Type inference failed for: r2v7 */ /* JADX WARN: Type inference failed for: r2v9, types: [com.strmr.ps.data.remote.model.premiumize.PremiumizeFolderItem] */ /* JADX WARN: Type inference failed for: r31v2 */ /* JADX WARN: Type inference failed for: r31v3 */ /* JADX WARN: Type inference failed for: r31v4 */ /* JADX WARN: Type inference failed for: r3v4, types: [java.lang.StringBuilder] */ /* JADX WARN: Type inference failed for: r4v0, types: [int] */ /* JADX WARN: Type inference failed for: r4v10, types: [com.strmr.ps.data.remote.model.premiumize.PremiumizeFolderItem, java.lang.Object] */ /* JADX WARN: Type inference failed for: r4v2, types: [com.strmr.ps.data.remote.model.premiumize.PremiumizeFolderItem, java.lang.Object] */ /* JADX WARN: Type inference failed for: r4v5 */ /* JADX WARN: Type inference failed for: r5v12 */ /* JADX WARN: Type inference failed for: r5v13 */ /* JADX WARN: Type inference failed for: r5v14 */ /* JADX WARN: Type inference failed for: r5v15 */ /* JADX WARN: Type inference failed for: r5v17 */ /* JADX WARN: Type inference failed for: r5v18 */ /* JADX WARN: Type inference failed for: r5v2 */ /* JADX WARN: Type inference failed for: r5v3, types: [long] */ /* JADX WARN: Type inference failed for: r5v34 */ /* JADX WARN: Type inference failed for: r5v38 */ /* JADX WARN: Type inference failed for: r5v4 */ /* JADX WARN: Type inference failed for: r5v5 */ /* JADX WARN: Type inference failed for: r5v50 */ /* JADX WARN: Type inference failed for: r5v51 */ /* JADX WARN: Type inference failed for: r5v52 */ /* JADX WARN: Type inference failed for: r5v53 */ /* JADX WARN: Type inference failed for: r5v54 */ /* JADX WARN: Type inference failed for: r5v55 */ /* JADX WARN: Type inference failed for: r5v56 */ /* JADX WARN: Type inference failed for: r5v57 */ /* JADX WARN: Type inference failed for: r5v58 */ /* JADX WARN: Type inference failed for: r5v59 */ /* JADX WARN: Type inference failed for: r5v6 */ /* JADX WARN: Type inference failed for: r5v60 */ /* JADX WARN: Type inference failed for: r5v7 */ /* JADX WARN: Type inference failed for: r5v8, types: [long] */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:129:0x0440 -> B:130:0x0442). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:146:0x0487 -> B:225:0x048c). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:194:0x0550 -> B:199:0x0568). Please report as a decompilation issue!!! */ /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:196:0x0559 -> B:166:0x04dc). Please report as a decompilation issue!!! */ /* JADX ERROR: JadxRuntimeException in pass: RegionMakerVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't find top splitter block for handler:B:131:0x0446 at jadx.core.utils.BlockUtils.getTopSplitterForHandler(BlockUtils.java:1182) at jadx.core.dex.visitors.regions.maker.ExcHandlersRegionMaker.collectHandlerRegions(ExcHandlersRegionMaker.java:53) at jadx.core.dex.visitors.regions.maker.ExcHandlersRegionMaker.process(ExcHandlersRegionMaker.java:38) at jadx.core.dex.visitors.regions.RegionMakerVisitor.visit(RegionMakerVisitor.java:27) */ @defpackage.pq6 /* JADX INFO: renamed from: deleteMostRecent-0E7RQCE, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final java.lang.Object m112deleteMostRecent0E7RQCE(long r31, @defpackage.pq6 java.lang.String r33, @defpackage.kp6 kotlin.coroutines.Continuation> r34) { /* Method dump skipped, instruction units count: 1768 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: com.strmr.ps.data.repository.PremiumizeRepository.m112deleteMostRecent0E7RQCE(long, java.lang.String, kotlin.coroutines.Continuation):java.lang.Object"); } @pq6 public final Object getAccount(@kp6 Continuation continuation) { return this.accountDao.getAccount("premiumize", continuation); } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public Object getAccountExpirationStatus(@kp6 Continuation continuation) { C03691 c03691; Long expiresAt; if (continuation instanceof C03691) { c03691 = (C03691) continuation; int i = c03691.label; if ((i & Integer.MIN_VALUE) != 0) { c03691.label = i - Integer.MIN_VALUE; } else { c03691 = new C03691(continuation); } } Object account = c03691.result; ck1 ck1Var = ck1.a; int i2 = c03691.label; if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; c03691.label = 1; account = premiumizeAccountDao.getAccount("premiumize", c03691); if (account == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount != null && (expiresAt = premiumizeAccount.getExpiresAt()) != null) { long jLongValue = expiresAt.longValue(); long jCurrentTimeMillis = System.currentTimeMillis(); if (jLongValue <= jCurrentTimeMillis) { return Boxing.boxInt((int) ((jCurrentTimeMillis - jLongValue) / ((long) 86400000))); } } return null; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public Object getApiKey(@kp6 Continuation continuation) { C03701 c03701; if (continuation instanceof C03701) { c03701 = (C03701) continuation; int i = c03701.label; if ((i & Integer.MIN_VALUE) != 0) { c03701.label = i - Integer.MIN_VALUE; } else { c03701 = new C03701(continuation); } } Object account = c03701.result; ck1 ck1Var = ck1.a; int i2 = c03701.label; if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; c03701.label = 1; account = premiumizeAccountDao.getAccount("premiumize", c03701); if (account == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount != null) { return premiumizeAccount.getApiKey(); } return null; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object getApiKeyMasked(@kp6 Continuation continuation) { C03711 c03711; String apiKey; if (continuation instanceof C03711) { c03711 = (C03711) continuation; int i = c03711.label; if ((i & Integer.MIN_VALUE) != 0) { c03711.label = i - Integer.MIN_VALUE; } else { c03711 = new C03711(continuation); } } Object account = c03711.result; ck1 ck1Var = ck1.a; int i2 = c03711.label; if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; c03711.label = 1; account = premiumizeAccountDao.getAccount("premiumize", c03711); if (account == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null || (apiKey = premiumizeAccount.getApiKey()) == null) { return null; } if (apiKey.length() <= 8) { return "****"; } String strBb = n89.bb(4, apiKey); int length = apiKey.length(); String strSubstring = apiKey.substring(length - (4 > length ? length : 4)); cr4.f(strSubstring, "substring(...)"); return vw2.l(strBb, "****", strSubstring); } @pq6 public final Integer getDaysRemaining(@kp6 PremiumizeAccount account) { cr4.g(account, "account"); Long expiresAt = account.getExpiresAt(); if (expiresAt == null) { return null; } long jLongValue = expiresAt.longValue(); long jCurrentTimeMillis = System.currentTimeMillis(); if (jLongValue <= jCurrentTimeMillis) { return 0; } return Integer.valueOf((int) ((jLongValue - jCurrentTimeMillis) / ((long) 86400000))); } /* JADX WARN: Code restructure failed: missing block: B:41:0x00b9, code lost: if (r12 == r1) goto L42; */ /* JADX WARN: Removed duplicated region for block: B:46:0x00ca A[Catch: Exception -> 0x0033, TryCatch #0 {Exception -> 0x0033, blocks: (B:13:0x002e, B:43:0x00bc, B:44:0x00be, B:46:0x00ca, B:49:0x00d3, B:51:0x00db, B:53:0x00ee, B:54:0x00f4, B:56:0x00fa, B:59:0x010e, B:19:0x003e, B:39:0x009f, B:34:0x007f, B:36:0x0085, B:40:0x00a2), top: B:64:0x0026 }] */ /* JADX WARN: Removed duplicated region for block: B:51:0x00db A[Catch: Exception -> 0x0033, TryCatch #0 {Exception -> 0x0033, blocks: (B:13:0x002e, B:43:0x00bc, B:44:0x00be, B:46:0x00ca, B:49:0x00d3, B:51:0x00db, B:53:0x00ee, B:54:0x00f4, B:56:0x00fa, B:59:0x010e, B:19:0x003e, B:39:0x009f, B:34:0x007f, B:36:0x0085, B:40:0x00a2), top: B:64:0x0026 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: getFolderBreadcrumbs-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m113getFolderBreadcrumbsgIAlus(@pq6 String str, @kp6 Continuation>> continuation) { PremiumizeRepository$getFolderBreadcrumbs$1 premiumizeRepository$getFolderBreadcrumbs$1; PremiumizeRepository premiumizeRepository; PremiumizeFolderListResponse premiumizeFolderListResponse; if (continuation instanceof PremiumizeRepository$getFolderBreadcrumbs$1) { premiumizeRepository$getFolderBreadcrumbs$1 = (PremiumizeRepository$getFolderBreadcrumbs$1) continuation; int i = premiumizeRepository$getFolderBreadcrumbs$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$getFolderBreadcrumbs$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$getFolderBreadcrumbs$1 = new PremiumizeRepository$getFolderBreadcrumbs$1(this, continuation); } } Object account = premiumizeRepository$getFolderBreadcrumbs$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$getFolderBreadcrumbs$1.label; try { if (i2 == 0) { s38.b(account); if (str == null) { return y41.am(new FolderBreadcrumb(null, "Root")); } PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$getFolderBreadcrumbs$1.L$0 = this; premiumizeRepository$getFolderBreadcrumbs$1.L$1 = str; premiumizeRepository$getFolderBreadcrumbs$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$getFolderBreadcrumbs$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str = (String) premiumizeRepository$getFolderBreadcrumbs$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$getFolderBreadcrumbs$1.L$0; s38.b(account); } else { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; if (!cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { String message = premiumizeFolderListResponse.getMessage(); if (message == null) { message = "Failed to get breadcrumbs"; } return s38.a(new Exception(message)); } ArrayList arrayListAr = y41.ar(new FolderBreadcrumb(null, "Root")); List breadcrumbs = premiumizeFolderListResponse.getBreadcrumbs(); if (breadcrumbs != null) { for (PremiumizeBreadcrumb premiumizeBreadcrumb : breadcrumbs) { String id = premiumizeBreadcrumb.getId(); String name = premiumizeBreadcrumb.getName(); if (name == null) { name = ""; } arrayListAr.add(new FolderBreadcrumb(id, name)); } } return arrayListAr; } s38.b(account); premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; if (!cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); Boolean boolBoxBoolean = Boxing.boxBoolean(true); premiumizeRepository$getFolderBreadcrumbs$1.L$0 = null; premiumizeRepository$getFolderBreadcrumbs$1.L$1 = null; premiumizeRepository$getFolderBreadcrumbs$1.label = 2; account = premiumizeApiService.listFolderWithToken(authHeader, str, boolBoxBoolean, premiumizeRepository$getFolderBreadcrumbs$1); if (account == ck1Var) { } premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; if (!cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); Boolean boolBoxBoolean2 = Boxing.boxBoolean(true); premiumizeRepository$getFolderBreadcrumbs$1.L$0 = null; premiumizeRepository$getFolderBreadcrumbs$1.L$1 = null; premiumizeRepository$getFolderBreadcrumbs$1.label = 3; account = premiumizeApiService2.listFolder(apiKey, str, boolBoxBoolean2, premiumizeRepository$getFolderBreadcrumbs$1); } return ck1Var; } catch (Exception e) { Log.e(TAG, "Failed to get breadcrumbs", e); return s38.a(e); } } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridLibraryProvider @pq6 /* JADX INFO: renamed from: getLibraryItems-IoAF18A */ /* Code decompiled incorrectly, please refer to instructions dump. */ public Object mo70getLibraryItemsIoAF18A(@kp6 Continuation>> continuation) { PremiumizeRepository$getLibraryItems$1 premiumizeRepository$getLibraryItems$1; if (continuation instanceof PremiumizeRepository$getLibraryItems$1) { premiumizeRepository$getLibraryItems$1 = (PremiumizeRepository$getLibraryItems$1) continuation; int i = premiumizeRepository$getLibraryItems$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$getLibraryItems$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$getLibraryItems$1 = new PremiumizeRepository$getLibraryItems$1(this, continuation); } } Object obj = premiumizeRepository$getLibraryItems$1.result; Object obj2 = ck1.a; int i2 = premiumizeRepository$getLibraryItems$1.label; if (i2 != 0) { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(obj); return ((q38) obj).a; } s38.b(obj); premiumizeRepository$getLibraryItems$1.label = 1; Object objM114getLibraryItemsgIAlus = m114getLibraryItemsgIAlus(null, premiumizeRepository$getLibraryItems$1); return objM114getLibraryItemsgIAlus == obj2 ? obj2 : objM114getLibraryItemsgIAlus; } /* JADX WARN: Removed duplicated region for block: B:101:0x020c */ /* JADX WARN: Removed duplicated region for block: B:50:0x00d7 A[Catch: Exception -> 0x003d, HttpException -> 0x0040, TryCatch #2 {HttpException -> 0x0040, Exception -> 0x003d, blocks: (B:15:0x0038, B:47:0x00c8, B:48:0x00cb, B:50:0x00d7, B:53:0x00df, B:54:0x00f4, B:56:0x00fa, B:58:0x010c, B:67:0x0176, B:59:0x012a, B:61:0x0148, B:63:0x014f, B:65:0x0159, B:66:0x015d, B:68:0x017b, B:81:0x01a2, B:94:0x01c6, B:97:0x01cc, B:84:0x01a9, B:85:0x01ad, B:87:0x01b3, B:89:0x01bd, B:92:0x01c2, B:93:0x01c5, B:71:0x0184, B:72:0x0189, B:74:0x018f, B:76:0x0199, B:79:0x019e, B:80:0x01a1, B:99:0x0204, B:102:0x020e, B:24:0x004f, B:41:0x00a7, B:35:0x0084, B:37:0x008a, B:43:0x00ac), top: B:107:0x002c }] */ /* JADX WARN: Removed duplicated region for block: B:56:0x00fa A[Catch: Exception -> 0x003d, HttpException -> 0x0040, TryCatch #2 {HttpException -> 0x0040, Exception -> 0x003d, blocks: (B:15:0x0038, B:47:0x00c8, B:48:0x00cb, B:50:0x00d7, B:53:0x00df, B:54:0x00f4, B:56:0x00fa, B:58:0x010c, B:67:0x0176, B:59:0x012a, B:61:0x0148, B:63:0x014f, B:65:0x0159, B:66:0x015d, B:68:0x017b, B:81:0x01a2, B:94:0x01c6, B:97:0x01cc, B:84:0x01a9, B:85:0x01ad, B:87:0x01b3, B:89:0x01bd, B:92:0x01c2, B:93:0x01c5, B:71:0x0184, B:72:0x0189, B:74:0x018f, B:76:0x0199, B:79:0x019e, B:80:0x01a1, B:99:0x0204, B:102:0x020e, B:24:0x004f, B:41:0x00a7, B:35:0x0084, B:37:0x008a, B:43:0x00ac), top: B:107:0x002c }] */ /* JADX WARN: Removed duplicated region for block: B:70:0x0182 */ /* JADX WARN: Removed duplicated region for block: B:71:0x0184 A[Catch: Exception -> 0x003d, HttpException -> 0x0040, TryCatch #2 {HttpException -> 0x0040, Exception -> 0x003d, blocks: (B:15:0x0038, B:47:0x00c8, B:48:0x00cb, B:50:0x00d7, B:53:0x00df, B:54:0x00f4, B:56:0x00fa, B:58:0x010c, B:67:0x0176, B:59:0x012a, B:61:0x0148, B:63:0x014f, B:65:0x0159, B:66:0x015d, B:68:0x017b, B:81:0x01a2, B:94:0x01c6, B:97:0x01cc, B:84:0x01a9, B:85:0x01ad, B:87:0x01b3, B:89:0x01bd, B:92:0x01c2, B:93:0x01c5, B:71:0x0184, B:72:0x0189, B:74:0x018f, B:76:0x0199, B:79:0x019e, B:80:0x01a1, B:99:0x0204, B:102:0x020e, B:24:0x004f, B:41:0x00a7, B:35:0x0084, B:37:0x008a, B:43:0x00ac), top: B:107:0x002c }] */ /* JADX WARN: Removed duplicated region for block: B:83:0x01a8 */ /* JADX WARN: Removed duplicated region for block: B:84:0x01a9 A[Catch: Exception -> 0x003d, HttpException -> 0x0040, TryCatch #2 {HttpException -> 0x0040, Exception -> 0x003d, blocks: (B:15:0x0038, B:47:0x00c8, B:48:0x00cb, B:50:0x00d7, B:53:0x00df, B:54:0x00f4, B:56:0x00fa, B:58:0x010c, B:67:0x0176, B:59:0x012a, B:61:0x0148, B:63:0x014f, B:65:0x0159, B:66:0x015d, B:68:0x017b, B:81:0x01a2, B:94:0x01c6, B:97:0x01cc, B:84:0x01a9, B:85:0x01ad, B:87:0x01b3, B:89:0x01bd, B:92:0x01c2, B:93:0x01c5, B:71:0x0184, B:72:0x0189, B:74:0x018f, B:76:0x0199, B:79:0x019e, B:80:0x01a1, B:99:0x0204, B:102:0x020e, B:24:0x004f, B:41:0x00a7, B:35:0x0084, B:37:0x008a, B:43:0x00ac), top: B:107:0x002c }] */ /* JADX WARN: Removed duplicated region for block: B:8:0x0018 */ /* JADX WARN: Removed duplicated region for block: B:96:0x01ca */ @pq6 /* JADX INFO: renamed from: getLibraryItems-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m114getLibraryItemsgIAlus(@pq6 String str, @kp6 Continuation>> continuation) { PremiumizeRepository$getLibraryItems$2 premiumizeRepository$getLibraryItems$2; String str2; PremiumizeRepository premiumizeRepository; String str3; PremiumizeFolderListResponse premiumizeFolderListResponse; String str4; String message; ArrayList arrayList; int i; Object file; if (continuation instanceof PremiumizeRepository$getLibraryItems$2) { premiumizeRepository$getLibraryItems$2 = (PremiumizeRepository$getLibraryItems$2) continuation; int i2 = premiumizeRepository$getLibraryItems$2.label; if ((i2 & Integer.MIN_VALUE) != 0) { premiumizeRepository$getLibraryItems$2.label = i2 - Integer.MIN_VALUE; } else { premiumizeRepository$getLibraryItems$2 = new PremiumizeRepository$getLibraryItems$2(this, continuation); } } PremiumizeRepository$getLibraryItems$2 premiumizeRepository$getLibraryItems$22 = premiumizeRepository$getLibraryItems$2; Object account = premiumizeRepository$getLibraryItems$22.result; ck1 ck1Var = ck1.a; int i3 = premiumizeRepository$getLibraryItems$22.label; try { if (i3 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$getLibraryItems$22.L$0 = this; str2 = str; premiumizeRepository$getLibraryItems$22.L$1 = str2; premiumizeRepository$getLibraryItems$22.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$getLibraryItems$22); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i3 != 1) { if (i3 == 2) { str3 = (String) premiumizeRepository$getLibraryItems$22.L$0; s38.b(account); premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; str4 = str3; if (cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { List content = premiumizeFolderListResponse.getContent(); arrayList = new ArrayList(y41.p(content, 10)); while (r0.hasNext()) { } int i4 = 0; if (arrayList.isEmpty()) { } if (arrayList.isEmpty()) { } ExecutorService executorService = kq.a; if (str4 == null) { } kq.h(TAG, "Library folder " + str4 + ": " + arrayList.size() + " items (" + i + " folders, " + i4 + " files)"); return arrayList; } message = premiumizeFolderListResponse.getMessage(); if (message == null) { } return s38.a(new Exception(message)); } if (i3 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } str3 = (String) premiumizeRepository$getLibraryItems$22.L$0; s38.b(account); premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; str4 = str3; if (cr4.b(premiumizeFolderListResponse.getStatus(), "success") && premiumizeFolderListResponse.getContent() != null) { List content2 = premiumizeFolderListResponse.getContent(); arrayList = new ArrayList(y41.p(content2, 10)); for (PremiumizeFolderItem premiumizeFolderItem : content2) { if (cr4.b(premiumizeFolderItem.getType(), "folder")) { file = new DebridFileItem.Folder(premiumizeFolderItem.getId(), premiumizeFolderItem.getName(), "premiumize", DebridService.INSTANCE.getDisplayName("premiumize"), null, str4, null, 80, null); } else { boolean zIsVideoFile = VideoExtensions.INSTANCE.isVideoFile(premiumizeFolderItem.getName()); String id = premiumizeFolderItem.getId(); String name = premiumizeFolderItem.getName(); String displayName = DebridService.INSTANCE.getDisplayName("premiumize"); Long size = premiumizeFolderItem.getSize(); long jLongValue = size != null ? size.longValue() : 0L; String mimeType = premiumizeFolderItem.getMimeType(); String streamLink = premiumizeFolderItem.getStreamLink(); if (streamLink == null) { streamLink = premiumizeFolderItem.getLink(); } String str5 = str4; file = new DebridFileItem.File(id, name, "premiumize", displayName, jLongValue, mimeType, streamLink, str5, null, null, zIsVideoFile, false, 2816, null); str4 = str5; } arrayList.add(file); } int i42 = 0; if (arrayList.isEmpty()) { Iterator it = arrayList.iterator(); i = 0; while (it.hasNext()) { if ((((DebridFileItem) it.next()) instanceof DebridFileItem.Folder) && (i = i + 1) < 0) { y41.bl(); throw null; } } } else { i = 0; } if (arrayList.isEmpty()) { Iterator it2 = arrayList.iterator(); while (it2.hasNext()) { if ((((DebridFileItem) it2.next()) instanceof DebridFileItem.File) && (i42 = i42 + 1) < 0) { y41.bl(); throw null; } } } ExecutorService executorService2 = kq.a; if (str4 == null) { str4 = "root"; } kq.h(TAG, "Library folder " + str4 + ": " + arrayList.size() + " items (" + i + " folders, " + i42 + " files)"); return arrayList; } message = premiumizeFolderListResponse.getMessage(); if (message == null) { message = "Failed to get folder contents"; } return s38.a(new Exception(message)); } str2 = (String) premiumizeRepository$getLibraryItems$22.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$getLibraryItems$22.L$0; s38.b(account); PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$getLibraryItems$22.L$0 = str2; premiumizeRepository$getLibraryItems$22.L$1 = null; premiumizeRepository$getLibraryItems$22.label = 2; String str6 = str2; account = PremiumizeApiService.DefaultImpls.listFolderWithToken$default(premiumizeApiService, authHeader, str6, null, premiumizeRepository$getLibraryItems$22, 4, null); if (account != ck1Var) { str3 = str6; premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; str4 = str3; if (cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { } message = premiumizeFolderListResponse.getMessage(); if (message == null) { } return s38.a(new Exception(message)); } } else { String str7 = str2; PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$getLibraryItems$22.L$0 = str7; premiumizeRepository$getLibraryItems$22.L$1 = null; premiumizeRepository$getLibraryItems$22.label = 3; account = PremiumizeApiService.DefaultImpls.listFolder$default(premiumizeApiService2, apiKey, str7, null, premiumizeRepository$getLibraryItems$22, 4, null); if (account != ck1Var) { str3 = str7; premiumizeFolderListResponse = (PremiumizeFolderListResponse) account; str4 = str3; if (cr4.b(premiumizeFolderListResponse.getStatus(), "success")) { } message = premiumizeFolderListResponse.getMessage(); if (message == null) { } return s38.a(new Exception(message)); } } return ck1Var; } catch (HttpException e) { ExecutorService executorService3 = kq.a; kq.a(TAG, "Failed to get library items: HTTP " + e.code(), e); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e.code()), e)); } catch (Exception e2) { ExecutorService executorService4 = kq.a; kq.a(TAG, "Failed to get library items", e2); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e2.getMessage(), e2)); } } @Override // com.strmr.ps.data.repository.IDebridProvider @kp6 public DebridProvider getProvider() { return this.provider; } @Override // com.strmr.ps.data.repository.IDebridProvider @kp6 public String getServiceName() { return this.serviceName; } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* Code decompiled incorrectly, please refer to instructions dump. */ public Object hasAccount(@kp6 Continuation continuation) { C03721 c03721; if (continuation instanceof C03721) { c03721 = (C03721) continuation; int i = c03721.label; if ((i & Integer.MIN_VALUE) != 0) { c03721.label = i - Integer.MIN_VALUE; } else { c03721 = new C03721(continuation); } } Object account = c03721.result; ck1 ck1Var = ck1.a; int i2 = c03721.label; if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; c03721.label = 1; account = premiumizeAccountDao.getAccount("premiumize", c03721); if (account == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); } return Boxing.boxBoolean(account != null); } /* JADX WARN: Removed duplicated region for block: B:8:0x0018 */ @pq6 /* JADX INFO: renamed from: pollForToken-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m115pollForTokengIAlus(@kp6 String str, @kp6 Continuation> continuation) throws IOException { PremiumizeRepository$pollForToken$1 premiumizeRepository$pollForToken$1; String strString; ResponseBody responseBodyErrorBody; if (continuation instanceof PremiumizeRepository$pollForToken$1) { premiumizeRepository$pollForToken$1 = (PremiumizeRepository$pollForToken$1) continuation; int i = premiumizeRepository$pollForToken$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$pollForToken$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$pollForToken$1 = new PremiumizeRepository$pollForToken$1(this, continuation); } } PremiumizeRepository$pollForToken$1 premiumizeRepository$pollForToken$12 = premiumizeRepository$pollForToken$1; Object objPollForToken$default = premiumizeRepository$pollForToken$12.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$pollForToken$12.label; q38.b bVarA = null; try { if (i2 == 0) { s38.b(objPollForToken$default); PremiumizeAuthService premiumizeAuthService = this.premiumizeAuthService; String clientId = getClientId(); premiumizeRepository$pollForToken$12.label = 1; objPollForToken$default = PremiumizeAuthService.DefaultImpls.pollForToken$default(premiumizeAuthService, clientId, str, null, premiumizeRepository$pollForToken$12, 4, null); if (objPollForToken$default == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objPollForToken$default); } PremiumizeTokenResponse premiumizeTokenResponse = (PremiumizeTokenResponse) objPollForToken$default; if (premiumizeTokenResponse.getAccessToken() != null) { ExecutorService executorService = kq.a; kq.h(TAG, "Token received successfully"); return premiumizeTokenResponse; } if (!cr4.b(premiumizeTokenResponse.getError(), "authorization_pending")) { if (cr4.b(premiumizeTokenResponse.getError(), "access_denied")) { return s38.a(new Exception("Access denied by user")); } if (premiumizeTokenResponse.getError() != null) { String errorDescription = premiumizeTokenResponse.getErrorDescription(); if (errorDescription == null) { errorDescription = premiumizeTokenResponse.getError(); } return s38.a(new Exception(errorDescription)); } } return null; } catch (HttpException e) { Response response = e.response(); if (response == null || (responseBodyErrorBody = response.errorBody()) == null) { strString = null; } else { try { strString = responseBodyErrorBody.string(); responseBodyErrorBody.close(); } catch (Throwable th) { try { throw th; } catch (Throwable th2) { f21.a(responseBodyErrorBody, th); throw th2; } } } e.code(); if (strString == null || !n89.l(strString, "authorization_pending", false)) { if (strString != null && n89.l(strString, "access_denied", false)) { bVarA = vw2.d("Access denied by user"); } else if (strString == null || !n89.l(strString, "expired", false)) { Log.e(TAG, "Failed to poll for token: HTTP " + e.code(), e); bVarA = s38.a(e); } else { bVarA = vw2.d("Device code expired"); } } return bVarA; } catch (Exception e2) { Log.e(TAG, "Failed to poll for token", e2); return s38.a(e2); } } /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: refreshAccountInfo-IoAF18A, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m116refreshAccountInfoIoAF18A(@kp6 Continuation> continuation) { PremiumizeRepository$refreshAccountInfo$1 premiumizeRepository$refreshAccountInfo$1; PremiumizeRepository premiumizeRepository; if (continuation instanceof PremiumizeRepository$refreshAccountInfo$1) { premiumizeRepository$refreshAccountInfo$1 = (PremiumizeRepository$refreshAccountInfo$1) continuation; int i = premiumizeRepository$refreshAccountInfo$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$refreshAccountInfo$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$refreshAccountInfo$1 = new PremiumizeRepository$refreshAccountInfo$1(this, continuation); } } Object account = premiumizeRepository$refreshAccountInfo$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$refreshAccountInfo$1.label; if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$refreshAccountInfo$1.L$0 = this; premiumizeRepository$refreshAccountInfo$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$refreshAccountInfo$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 != 1) { if (i2 == 2) { s38.b(account); return ((q38) account).a; } if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); return ((q38) account).a; } premiumizeRepository = (PremiumizeRepository) premiumizeRepository$refreshAccountInfo$1.L$0; s38.b(account); PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return vw2.d("No Premiumize account configured"); } if (premiumizeAccount.isOAuthAccount()) { String accessToken = premiumizeAccount.getAccessToken(); cr4.d(accessToken); premiumizeRepository$refreshAccountInfo$1.L$0 = null; premiumizeRepository$refreshAccountInfo$1.label = 2; Object objM120saveOAuthTokengIAlus = premiumizeRepository.m120saveOAuthTokengIAlus(accessToken, premiumizeRepository$refreshAccountInfo$1); if (objM120saveOAuthTokengIAlus != ck1Var) { return objM120saveOAuthTokengIAlus; } } else { if (premiumizeAccount.getApiKey() == null) { return vw2.d("No valid credentials"); } String apiKey = premiumizeAccount.getApiKey(); premiumizeRepository$refreshAccountInfo$1.L$0 = null; premiumizeRepository$refreshAccountInfo$1.label = 3; Object objM121verifyAndSaveApiKeygIAlus = premiumizeRepository.m121verifyAndSaveApiKeygIAlus(apiKey, premiumizeRepository$refreshAccountInfo$1); if (objM121verifyAndSaveApiKeygIAlus != ck1Var) { return objM121verifyAndSaveApiKeygIAlus; } } return ck1Var; } /* JADX WARN: Code restructure failed: missing block: B:41:0x00c3, code lost: if (r12 == r1) goto L42; */ /* JADX WARN: Removed duplicated region for block: B:46:0x00d4 A[Catch: Exception -> 0x003a, HttpException -> 0x003d, TryCatch #2 {HttpException -> 0x003d, Exception -> 0x003a, blocks: (B:14:0x0035, B:43:0x00c6, B:44:0x00c8, B:46:0x00d4, B:48:0x00d7, B:51:0x00e0, B:23:0x0050, B:39:0x00ab, B:34:0x008c, B:36:0x0093, B:40:0x00ae), top: B:56:0x0025 }] */ /* JADX WARN: Removed duplicated region for block: B:48:0x00d7 A[Catch: Exception -> 0x003a, HttpException -> 0x003d, TryCatch #2 {HttpException -> 0x003d, Exception -> 0x003a, blocks: (B:14:0x0035, B:43:0x00c6, B:44:0x00c8, B:46:0x00d4, B:48:0x00d7, B:51:0x00e0, B:23:0x0050, B:39:0x00ab, B:34:0x008c, B:36:0x0093, B:40:0x00ae), top: B:56:0x0025 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: renameFolder-0E7RQCE, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m117renameFolder0E7RQCE(@kp6 String str, @kp6 String str2, @kp6 Continuation> continuation) { PremiumizeRepository$renameFolder$1 premiumizeRepository$renameFolder$1; PremiumizeRepository premiumizeRepository; PremiumizeAccountResponse premiumizeAccountResponse; if (continuation instanceof PremiumizeRepository$renameFolder$1) { premiumizeRepository$renameFolder$1 = (PremiumizeRepository$renameFolder$1) continuation; int i = premiumizeRepository$renameFolder$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$renameFolder$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$renameFolder$1 = new PremiumizeRepository$renameFolder$1(this, continuation); } } Object account = premiumizeRepository$renameFolder$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$renameFolder$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$renameFolder$1.L$0 = this; premiumizeRepository$renameFolder$1.L$1 = str; premiumizeRepository$renameFolder$1.L$2 = str2; premiumizeRepository$renameFolder$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$renameFolder$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str2 = (String) premiumizeRepository$renameFolder$1.L$2; str = (String) premiumizeRepository$renameFolder$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$renameFolder$1.L$0; s38.b(account); } else { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { return e6a.a; } String message = premiumizeAccountResponse.getMessage(); if (message == null) { message = "Failed to rename folder"; } return s38.a(new Exception(message)); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$renameFolder$1.L$0 = str; premiumizeRepository$renameFolder$1.L$1 = str2; premiumizeRepository$renameFolder$1.L$2 = null; premiumizeRepository$renameFolder$1.label = 2; account = premiumizeApiService.renameFolderWithToken(authHeader, str, str2, premiumizeRepository$renameFolder$1); if (account == ck1Var) { } premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$renameFolder$1.L$0 = str; premiumizeRepository$renameFolder$1.L$1 = str2; premiumizeRepository$renameFolder$1.L$2 = null; premiumizeRepository$renameFolder$1.label = 3; account = premiumizeApiService2.renameFolder(apiKey, str, str2, premiumizeRepository$renameFolder$1); } return ck1Var; } catch (HttpException e) { Log.e(TAG, "Failed to rename folder: HTTP " + e.code(), e); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e.code()), e)); } catch (Exception e2) { Log.e(TAG, "Failed to rename folder", e2); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e2.getMessage(), e2)); } } /* JADX WARN: Code restructure failed: missing block: B:41:0x00c3, code lost: if (r12 == r1) goto L42; */ /* JADX WARN: Removed duplicated region for block: B:46:0x00d4 A[Catch: Exception -> 0x003a, HttpException -> 0x003d, TryCatch #2 {HttpException -> 0x003d, Exception -> 0x003a, blocks: (B:14:0x0035, B:43:0x00c6, B:44:0x00c8, B:46:0x00d4, B:48:0x00d7, B:51:0x00e0, B:23:0x0050, B:39:0x00ab, B:34:0x008c, B:36:0x0093, B:40:0x00ae), top: B:56:0x0025 }] */ /* JADX WARN: Removed duplicated region for block: B:48:0x00d7 A[Catch: Exception -> 0x003a, HttpException -> 0x003d, TryCatch #2 {HttpException -> 0x003d, Exception -> 0x003a, blocks: (B:14:0x0035, B:43:0x00c6, B:44:0x00c8, B:46:0x00d4, B:48:0x00d7, B:51:0x00e0, B:23:0x0050, B:39:0x00ab, B:34:0x008c, B:36:0x0093, B:40:0x00ae), top: B:56:0x0025 }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x0013 */ @pq6 /* JADX INFO: renamed from: renameItem-0E7RQCE, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m118renameItem0E7RQCE(@kp6 String str, @kp6 String str2, @kp6 Continuation> continuation) { PremiumizeRepository$renameItem$1 premiumizeRepository$renameItem$1; PremiumizeRepository premiumizeRepository; PremiumizeAccountResponse premiumizeAccountResponse; if (continuation instanceof PremiumizeRepository$renameItem$1) { premiumizeRepository$renameItem$1 = (PremiumizeRepository$renameItem$1) continuation; int i = premiumizeRepository$renameItem$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$renameItem$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$renameItem$1 = new PremiumizeRepository$renameItem$1(this, continuation); } } Object account = premiumizeRepository$renameItem$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$renameItem$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$renameItem$1.L$0 = this; premiumizeRepository$renameItem$1.L$1 = str; premiumizeRepository$renameItem$1.L$2 = str2; premiumizeRepository$renameItem$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$renameItem$1); if (account != ck1Var) { premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str2 = (String) premiumizeRepository$renameItem$1.L$2; str = (String) premiumizeRepository$renameItem$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$renameItem$1.L$0; s38.b(account); } else { if (i2 != 2) { if (i2 != 3) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { return e6a.a; } String message = premiumizeAccountResponse.getMessage(); if (message == null) { message = "Failed to rename item"; } return s38.a(new Exception(message)); } s38.b(account); premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount = (PremiumizeAccount) account; if (premiumizeAccount == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$renameItem$1.L$0 = str; premiumizeRepository$renameItem$1.L$1 = str2; premiumizeRepository$renameItem$1.L$2 = null; premiumizeRepository$renameItem$1.label = 2; account = premiumizeApiService.renameItemWithToken(authHeader, str, str2, premiumizeRepository$renameItem$1); if (account == ck1Var) { } premiumizeAccountResponse = (PremiumizeAccountResponse) account; if (cr4.b(premiumizeAccountResponse.getStatus(), "success")) { } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$renameItem$1.L$0 = str; premiumizeRepository$renameItem$1.L$1 = str2; premiumizeRepository$renameItem$1.L$2 = null; premiumizeRepository$renameItem$1.label = 3; account = premiumizeApiService2.renameItem(apiKey, str, str2, premiumizeRepository$renameItem$1); } return ck1Var; } catch (HttpException e) { Log.e(TAG, "Failed to rename item: HTTP " + e.code(), e); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e.code()), e)); } catch (Exception e2) { Log.e(TAG, "Failed to rename item", e2); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e2.getMessage(), e2)); } } /* JADX WARN: Removed duplicated region for block: B:8:0x0016 */ @pq6 /* JADX INFO: renamed from: requestDeviceCode-IoAF18A, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m119requestDeviceCodeIoAF18A(@kp6 Continuation> continuation) { PremiumizeRepository$requestDeviceCode$1 premiumizeRepository$requestDeviceCode$1; if (continuation instanceof PremiumizeRepository$requestDeviceCode$1) { premiumizeRepository$requestDeviceCode$1 = (PremiumizeRepository$requestDeviceCode$1) continuation; int i = premiumizeRepository$requestDeviceCode$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$requestDeviceCode$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$requestDeviceCode$1 = new PremiumizeRepository$requestDeviceCode$1(this, continuation); } } PremiumizeRepository$requestDeviceCode$1 premiumizeRepository$requestDeviceCode$12 = premiumizeRepository$requestDeviceCode$1; Object objRequestDeviceCode$default = premiumizeRepository$requestDeviceCode$12.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$requestDeviceCode$12.label; try { if (i2 == 0) { s38.b(objRequestDeviceCode$default); PremiumizeAuthService premiumizeAuthService = this.premiumizeAuthService; String clientId = getClientId(); premiumizeRepository$requestDeviceCode$12.label = 1; objRequestDeviceCode$default = PremiumizeAuthService.DefaultImpls.requestDeviceCode$default(premiumizeAuthService, clientId, null, premiumizeRepository$requestDeviceCode$12, 2, null); if (objRequestDeviceCode$default == ck1Var) { return ck1Var; } } else { if (i2 != 1) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } s38.b(objRequestDeviceCode$default); } PremiumizeDeviceCodeResponse premiumizeDeviceCodeResponse = (PremiumizeDeviceCodeResponse) objRequestDeviceCode$default; ExecutorService executorService = kq.a; kq.h(TAG, "Device code requested: " + premiumizeDeviceCodeResponse.getUserCode()); return premiumizeDeviceCodeResponse; } catch (Exception e) { Log.e(TAG, "Failed to request device code", e); return s38.a(e); } } @Override // com.strmr.ps.data.repository.IDebridLibraryProvider @pq6 /* JADX INFO: renamed from: resolveLibraryFile-gIAlu-s */ public Object mo75resolveLibraryFilegIAlus(@kp6 DebridFileItem.File file, @kp6 Continuation> continuation) { String streamUrl = file.getStreamUrl(); if (streamUrl == null) { return vw2.d("No stream URL available for file"); } file.getName(); return streamUrl; } /* JADX WARN: Removed duplicated region for block: B:123:0x039e */ /* JADX WARN: Removed duplicated region for block: B:52:0x0145 */ /* JADX WARN: Removed duplicated region for block: B:54:0x0167 */ /* JADX WARN: Removed duplicated region for block: B:73:0x01f1 A[Catch: Exception -> 0x0070, UnknownHostException -> 0x0073, SocketTimeoutException -> 0x0076, HttpException -> 0x0079, TryCatch #4 {SocketTimeoutException -> 0x0076, UnknownHostException -> 0x0073, HttpException -> 0x0079, Exception -> 0x0070, blocks: (B:90:0x0281, B:23:0x006b, B:70:0x01d8, B:71:0x01e5, B:73:0x01f1, B:75:0x01ff, B:77:0x022a, B:91:0x0297, B:92:0x02b5, B:95:0x02bf, B:97:0x02c8, B:100:0x02d1, B:102:0x02d9, B:104:0x02e1, B:107:0x02ea, B:110:0x0314, B:108:0x0301, B:109:0x030b, B:34:0x0094, B:64:0x01a5, B:58:0x0177, B:60:0x017d, B:66:0x01b4), top: B:131:0x002f }] */ /* JADX WARN: Removed duplicated region for block: B:7:0x001d */ /* JADX WARN: Removed duplicated region for block: B:92:0x02b5 A[Catch: Exception -> 0x0070, UnknownHostException -> 0x0073, SocketTimeoutException -> 0x0076, HttpException -> 0x0079, TryCatch #4 {SocketTimeoutException -> 0x0076, UnknownHostException -> 0x0073, HttpException -> 0x0079, Exception -> 0x0070, blocks: (B:90:0x0281, B:23:0x006b, B:70:0x01d8, B:71:0x01e5, B:73:0x01f1, B:75:0x01ff, B:77:0x022a, B:91:0x0297, B:92:0x02b5, B:95:0x02bf, B:97:0x02c8, B:100:0x02d1, B:102:0x02d9, B:104:0x02e1, B:107:0x02ea, B:110:0x0314, B:108:0x0301, B:109:0x030b, B:34:0x0094, B:64:0x01a5, B:58:0x0177, B:60:0x017d, B:66:0x01b4), top: B:131:0x002f }] */ @Override // com.strmr.ps.data.repository.IDebridProvider @pq6 /* JADX INFO: renamed from: resolveToDirectLink-hUnOzRk */ /* Code decompiled incorrectly, please refer to instructions dump. */ public Object mo76resolveToDirectLinkhUnOzRk(@kp6 String str, @pq6 Integer num, @pq6 Integer num2, @pq6 Integer num3, @pq6 String str2, @kp6 Continuation> continuation) { PremiumizeRepository$resolveToDirectLink$1 premiumizeRepository$resolveToDirectLink$1; Throwable authenticationFailed; Integer num4; String strConcat; String str3; Integer num5; Integer num6; PremiumizeRepository premiumizeRepository; PremiumizeAccount premiumizeAccount; Integer num7; String str4; Integer num8; PremiumizeRepository premiumizeRepository2; Integer num9; Integer num10; Integer num11; PremiumizeRepository premiumizeRepository3; String str5; Integer num12; Integer num13; PremiumizeDirectLinkResponse premiumizeDirectLinkResponse; String str6; Integer num14; Integer num15; Integer num16; PremiumizeRepository premiumizeRepository4; PremiumizeDirectLinkResponse premiumizeDirectLinkResponse2; String str7; PremiumizeDirectLinkResponse premiumizeDirectLinkResponse3; String filename; if (continuation instanceof PremiumizeRepository$resolveToDirectLink$1) { premiumizeRepository$resolveToDirectLink$1 = (PremiumizeRepository$resolveToDirectLink$1) continuation; int i = premiumizeRepository$resolveToDirectLink$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$resolveToDirectLink$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$resolveToDirectLink$1 = new PremiumizeRepository$resolveToDirectLink$1(this, continuation); } } Object account = premiumizeRepository$resolveToDirectLink$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$resolveToDirectLink$1.label; try { if (i2 == 0) { s38.b(account); PremiumizeAccountDao premiumizeAccountDao = this.accountDao; premiumizeRepository$resolveToDirectLink$1.L$0 = this; premiumizeRepository$resolveToDirectLink$1.L$1 = str; premiumizeRepository$resolveToDirectLink$1.L$2 = num; num4 = num2; premiumizeRepository$resolveToDirectLink$1.L$3 = num4; premiumizeRepository$resolveToDirectLink$1.L$4 = num3; premiumizeRepository$resolveToDirectLink$1.L$5 = str2; premiumizeRepository$resolveToDirectLink$1.label = 1; account = premiumizeAccountDao.getAccount("premiumize", premiumizeRepository$resolveToDirectLink$1); if (account != ck1Var) { strConcat = str; str3 = str2; num5 = num; num6 = num3; premiumizeRepository = this; } return ck1Var; } if (i2 == 1) { str3 = (String) premiumizeRepository$resolveToDirectLink$1.L$5; num6 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$4; num4 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$3; num5 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$2; strConcat = (String) premiumizeRepository$resolveToDirectLink$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$resolveToDirectLink$1.L$0; s38.b(account); } else { if (i2 == 2) { premiumizeAccount = (PremiumizeAccount) premiumizeRepository$resolveToDirectLink$1.L$6; String str8 = (String) premiumizeRepository$resolveToDirectLink$1.L$5; Integer num17 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$4; Integer num18 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$3; Integer num19 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$2; strConcat = (String) premiumizeRepository$resolveToDirectLink$1.L$1; PremiumizeRepository premiumizeRepository5 = (PremiumizeRepository) premiumizeRepository$resolveToDirectLink$1.L$0; s38.b(account); str4 = str8; premiumizeRepository2 = premiumizeRepository5; num8 = num17; num4 = num18; num7 = num19; num9 = (Integer) account; if (num9 == null) { Log.w(TAG, "Account expired " + num9 + " days ago"); return s38.a(new DebridError.AccountExpired(DebridProvider.PREMIUMIZE, num9)); } if (!n89.ar(strConcat, "magnet:", false)) { strConcat = "magnet:?xt=urn:btih:".concat(strConcat); } if (premiumizeAccount.isOAuthAccount()) { PremiumizeApiService premiumizeApiService = premiumizeRepository2.premiumizeApiService; String authHeader = premiumizeAccount.getAuthHeader(); cr4.d(authHeader); premiumizeRepository$resolveToDirectLink$1.L$0 = premiumizeRepository2; premiumizeRepository$resolveToDirectLink$1.L$1 = num7; premiumizeRepository$resolveToDirectLink$1.L$2 = num4; premiumizeRepository$resolveToDirectLink$1.L$3 = num8; premiumizeRepository$resolveToDirectLink$1.L$4 = str4; premiumizeRepository$resolveToDirectLink$1.L$5 = premiumizeAccount; premiumizeRepository$resolveToDirectLink$1.L$6 = null; premiumizeRepository$resolveToDirectLink$1.label = 3; account = premiumizeApiService.getDirectLinkWithToken(authHeader, strConcat, premiumizeRepository$resolveToDirectLink$1); if (account != ck1Var) { num11 = num7; premiumizeRepository3 = premiumizeRepository2; str5 = str4; num12 = num4; num13 = num8; premiumizeDirectLinkResponse = (PremiumizeDirectLinkResponse) account; str6 = str5; num14 = num13; num15 = num12; num16 = num11; premiumizeRepository4 = premiumizeRepository3; premiumizeDirectLinkResponse2 = premiumizeDirectLinkResponse; if (cr4.b(premiumizeDirectLinkResponse2.getStatus(), "success")) { } } } else { PremiumizeApiService premiumizeApiService2 = premiumizeRepository2.premiumizeApiService; String apiKey = premiumizeAccount.getApiKey(); cr4.d(apiKey); premiumizeRepository$resolveToDirectLink$1.L$0 = premiumizeRepository2; premiumizeRepository$resolveToDirectLink$1.L$1 = num7; premiumizeRepository$resolveToDirectLink$1.L$2 = num4; premiumizeRepository$resolveToDirectLink$1.L$3 = num8; premiumizeRepository$resolveToDirectLink$1.L$4 = str4; premiumizeRepository$resolveToDirectLink$1.L$5 = premiumizeAccount; premiumizeRepository$resolveToDirectLink$1.L$6 = null; premiumizeRepository$resolveToDirectLink$1.label = 4; account = premiumizeApiService2.getDirectLink(apiKey, strConcat, premiumizeRepository$resolveToDirectLink$1); if (account != ck1Var) { num10 = num8; premiumizeDirectLinkResponse = (PremiumizeDirectLinkResponse) account; premiumizeRepository4 = premiumizeRepository2; num15 = num4; str6 = str4; num14 = num10; num16 = num7; premiumizeDirectLinkResponse2 = premiumizeDirectLinkResponse; if (cr4.b(premiumizeDirectLinkResponse2.getStatus(), "success")) { } } } return ck1Var; } if (i2 != 3) { if (i2 != 4) { if (i2 != 5) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } str7 = (String) premiumizeRepository$resolveToDirectLink$1.L$1; premiumizeDirectLinkResponse3 = (PremiumizeDirectLinkResponse) premiumizeRepository$resolveToDirectLink$1.L$0; try { s38.b(account); } catch (Exception e) { e = e; ExecutorService executorService = kq.a; kq.a(TAG, "Cloud sanitization failed for PM " + premiumizeDirectLinkResponse3.getFilename(), e); } return str7; } premiumizeAccount = (PremiumizeAccount) premiumizeRepository$resolveToDirectLink$1.L$5; str4 = (String) premiumizeRepository$resolveToDirectLink$1.L$4; num10 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$3; num4 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$2; num7 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$1; premiumizeRepository2 = (PremiumizeRepository) premiumizeRepository$resolveToDirectLink$1.L$0; s38.b(account); premiumizeDirectLinkResponse = (PremiumizeDirectLinkResponse) account; premiumizeRepository4 = premiumizeRepository2; num15 = num4; str6 = str4; num14 = num10; num16 = num7; premiumizeDirectLinkResponse2 = premiumizeDirectLinkResponse; if (cr4.b(premiumizeDirectLinkResponse2.getStatus(), "success")) { String message = premiumizeDirectLinkResponse2.getMessage(); if (message == null) { message = "Failed to resolve link"; } return s38.a((n89.l(message, "expired", true) || n89.l(message, "premium", true)) ? new DebridError.AccountExpired(DebridProvider.PREMIUMIZE, null, 2, null) : (n89.l(message, "auth", true) || n89.l(message, "token", true) || n89.l(message, "invalid", true)) ? new DebridError.AuthenticationFailed(DebridProvider.PREMIUMIZE, null, 2, null) : new DebridError.Unknown(DebridProvider.PREMIUMIZE, message, null, 4, null)); } String strSelectBestLink = premiumizeRepository4.selectBestLink(premiumizeDirectLinkResponse2, num16, num15, num14, str6); PremiumizeRepository premiumizeRepository6 = premiumizeRepository4; Integer num20 = num15; Integer num21 = num14; if (strSelectBestLink == null) { return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, "No playable content found", null, 4, null)); } Log.w(TAG, "Resolved direct link: " + premiumizeDirectLinkResponse2.getFilename() + ", season=" + num20 + ", episode=" + num21); if (!premiumizeRepository6.linkFilterPreferences.getCloudSanitizationEnabled() || premiumizeDirectLinkResponse2.getFilename() == null) { return strSelectBestLink; } try { ExecutorService executorService2 = kq.a; String filename2 = premiumizeDirectLinkResponse2.getFilename(); List content = premiumizeDirectLinkResponse2.getContent(); kq.h(TAG, "Cloud sanitization: removing PM '" + filename2 + "' (" + (content != null ? content.size() : 0) + " files)"); filename = premiumizeDirectLinkResponse2.getFilename(); premiumizeRepository$resolveToDirectLink$1.L$0 = premiumizeDirectLinkResponse2; premiumizeRepository$resolveToDirectLink$1.L$1 = strSelectBestLink; premiumizeRepository$resolveToDirectLink$1.L$2 = null; premiumizeRepository$resolveToDirectLink$1.L$3 = null; premiumizeRepository$resolveToDirectLink$1.L$4 = null; premiumizeRepository$resolveToDirectLink$1.L$5 = null; premiumizeRepository$resolveToDirectLink$1.label = 5; } catch (Exception e2) { e = e2; str7 = strSelectBestLink; premiumizeDirectLinkResponse3 = premiumizeDirectLinkResponse2; ExecutorService executorService3 = kq.a; kq.a(TAG, "Cloud sanitization failed for PM " + premiumizeDirectLinkResponse3.getFilename(), e); } if (premiumizeRepository6.cleanupCloudItem(premiumizeAccount, filename, premiumizeRepository$resolveToDirectLink$1) != ck1Var) { str7 = strSelectBestLink; return str7; } return ck1Var; } premiumizeAccount = (PremiumizeAccount) premiumizeRepository$resolveToDirectLink$1.L$5; str5 = (String) premiumizeRepository$resolveToDirectLink$1.L$4; num13 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$3; num12 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$2; num11 = (Integer) premiumizeRepository$resolveToDirectLink$1.L$1; premiumizeRepository3 = (PremiumizeRepository) premiumizeRepository$resolveToDirectLink$1.L$0; s38.b(account); premiumizeDirectLinkResponse = (PremiumizeDirectLinkResponse) account; str6 = str5; num14 = num13; num15 = num12; num16 = num11; premiumizeRepository4 = premiumizeRepository3; premiumizeDirectLinkResponse2 = premiumizeDirectLinkResponse; if (cr4.b(premiumizeDirectLinkResponse2.getStatus(), "success")) { } } PremiumizeAccount premiumizeAccount2 = (PremiumizeAccount) account; if (premiumizeAccount2 == null) { return s38.a(new DebridError.NoAccount(DebridProvider.PREMIUMIZE)); } premiumizeRepository$resolveToDirectLink$1.L$0 = premiumizeRepository; premiumizeRepository$resolveToDirectLink$1.L$1 = strConcat; premiumizeRepository$resolveToDirectLink$1.L$2 = num5; premiumizeRepository$resolveToDirectLink$1.L$3 = num4; premiumizeRepository$resolveToDirectLink$1.L$4 = num6; premiumizeRepository$resolveToDirectLink$1.L$5 = str3; premiumizeRepository$resolveToDirectLink$1.L$6 = premiumizeAccount2; premiumizeRepository$resolveToDirectLink$1.label = 2; Object accountExpirationStatus = premiumizeRepository.getAccountExpirationStatus(premiumizeRepository$resolveToDirectLink$1); if (accountExpirationStatus != ck1Var) { String str9 = str3; premiumizeAccount = premiumizeAccount2; account = accountExpirationStatus; num7 = num5; str4 = str9; PremiumizeRepository premiumizeRepository7 = premiumizeRepository; num8 = num6; premiumizeRepository2 = premiumizeRepository7; num9 = (Integer) account; if (num9 == null) { } } return ck1Var; } catch (SocketTimeoutException e3) { Log.e(TAG, "Failed to resolve direct link: timeout", e3); return s38.a(new DebridError.ServiceDown(DebridProvider.PREMIUMIZE, null, e3, 2, null)); } catch (UnknownHostException e4) { Log.e(TAG, "Failed to resolve direct link: DNS error", e4); return s38.a(new DebridError.DnsError(DebridProvider.PREMIUMIZE, e4)); } catch (HttpException e5) { Log.e(TAG, "Failed to resolve direct link: HTTP " + e5.code(), e5); int iCode = e5.code(); if (iCode == 401 || iCode == 403) { authenticationFailed = new DebridError.AuthenticationFailed(DebridProvider.PREMIUMIZE, e5); } else if (iCode != 500) { switch (iCode) { case 502: case 503: case 504: authenticationFailed = new DebridError.ServiceDown(DebridProvider.PREMIUMIZE, Boxing.boxInt(e5.code()), e5); break; default: authenticationFailed = new DebridError.Unknown(DebridProvider.PREMIUMIZE, n41.k("HTTP ", e5.code()), e5); break; } } return s38.a(authenticationFailed); } catch (Exception e6) { Log.e(TAG, "Failed to resolve direct link", e6); return s38.a(new DebridError.Unknown(DebridProvider.PREMIUMIZE, e6.getMessage(), e6)); } } /* JADX WARN: Removed duplicated region for block: B:43:0x00d6 A[Catch: Exception -> 0x0042, TryCatch #0 {Exception -> 0x0042, blocks: (B:15:0x003e, B:22:0x0059, B:68:0x016b, B:25:0x006c, B:41:0x00d2, B:43:0x00d6, B:45:0x00df, B:47:0x00ef, B:52:0x0106, B:54:0x010c, B:56:0x011b, B:58:0x0129, B:60:0x0137, B:62:0x013d, B:64:0x014b, B:28:0x007d, B:35:0x00a1, B:37:0x00af, B:72:0x0192, B:75:0x019a, B:31:0x0084), top: B:79:0x0030 }] */ /* JADX WARN: Removed duplicated region for block: B:44:0x00dd */ /* JADX WARN: Removed duplicated region for block: B:51:0x0103 */ /* JADX WARN: Removed duplicated region for block: B:54:0x010c A[Catch: Exception -> 0x0042, TryCatch #0 {Exception -> 0x0042, blocks: (B:15:0x003e, B:22:0x0059, B:68:0x016b, B:25:0x006c, B:41:0x00d2, B:43:0x00d6, B:45:0x00df, B:47:0x00ef, B:52:0x0106, B:54:0x010c, B:56:0x011b, B:58:0x0129, B:60:0x0137, B:62:0x013d, B:64:0x014b, B:28:0x007d, B:35:0x00a1, B:37:0x00af, B:72:0x0192, B:75:0x019a, B:31:0x0084), top: B:79:0x0030 }] */ /* JADX WARN: Removed duplicated region for block: B:55:0x0119 */ /* JADX WARN: Removed duplicated region for block: B:58:0x0129 A[Catch: Exception -> 0x0042, TryCatch #0 {Exception -> 0x0042, blocks: (B:15:0x003e, B:22:0x0059, B:68:0x016b, B:25:0x006c, B:41:0x00d2, B:43:0x00d6, B:45:0x00df, B:47:0x00ef, B:52:0x0106, B:54:0x010c, B:56:0x011b, B:58:0x0129, B:60:0x0137, B:62:0x013d, B:64:0x014b, B:28:0x007d, B:35:0x00a1, B:37:0x00af, B:72:0x0192, B:75:0x019a, B:31:0x0084), top: B:79:0x0030 }] */ /* JADX WARN: Removed duplicated region for block: B:59:0x0135 */ /* JADX WARN: Removed duplicated region for block: B:62:0x013d A[Catch: Exception -> 0x0042, TryCatch #0 {Exception -> 0x0042, blocks: (B:15:0x003e, B:22:0x0059, B:68:0x016b, B:25:0x006c, B:41:0x00d2, B:43:0x00d6, B:45:0x00df, B:47:0x00ef, B:52:0x0106, B:54:0x010c, B:56:0x011b, B:58:0x0129, B:60:0x0137, B:62:0x013d, B:64:0x014b, B:28:0x007d, B:35:0x00a1, B:37:0x00af, B:72:0x0192, B:75:0x019a, B:31:0x0084), top: B:79:0x0030 }] */ /* JADX WARN: Removed duplicated region for block: B:63:0x0149 */ /* JADX WARN: Removed duplicated region for block: B:66:0x0169 */ /* JADX WARN: Removed duplicated region for block: B:67:0x016a */ /* JADX WARN: Removed duplicated region for block: B:70:0x0190 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:71:0x0191 A[RETURN] */ /* JADX WARN: Removed duplicated region for block: B:7:0x001f */ @pq6 /* JADX INFO: renamed from: saveOAuthToken-gIAlu-s, reason: not valid java name */ /* Code decompiled incorrectly, please refer to instructions dump. */ public final Object m120saveOAuthTokengIAlus(@kp6 String str, @kp6 Continuation> continuation) { PremiumizeRepository$saveOAuthToken$1 premiumizeRepository$saveOAuthToken$1; PremiumizeRepository premiumizeRepository; PremiumizeAccountResponse premiumizeAccountResponse; String str2; long j; PremiumizeAccount premiumizeAccount; PremiumizeAccountDao premiumizeAccountDao; PremiumizeAccount premiumizeAccount2; String str3 = str; if (continuation instanceof PremiumizeRepository$saveOAuthToken$1) { premiumizeRepository$saveOAuthToken$1 = (PremiumizeRepository$saveOAuthToken$1) continuation; int i = premiumizeRepository$saveOAuthToken$1.label; if ((i & Integer.MIN_VALUE) != 0) { premiumizeRepository$saveOAuthToken$1.label = i - Integer.MIN_VALUE; } else { premiumizeRepository$saveOAuthToken$1 = new PremiumizeRepository$saveOAuthToken$1(this, continuation); } } Object accountInfoWithToken = premiumizeRepository$saveOAuthToken$1.result; ck1 ck1Var = ck1.a; int i2 = premiumizeRepository$saveOAuthToken$1.label; try { if (i2 == 0) { s38.b(accountInfoWithToken); PremiumizeApiService premiumizeApiService = this.premiumizeApiService; premiumizeRepository$saveOAuthToken$1.L$0 = this; premiumizeRepository$saveOAuthToken$1.L$1 = str3; premiumizeRepository$saveOAuthToken$1.label = 1; accountInfoWithToken = premiumizeApiService.getAccountInfoWithToken("Bearer " + str3, premiumizeRepository$saveOAuthToken$1); if (accountInfoWithToken != ck1Var) { premiumizeRepository = this; } } else if (i2 == 1) { str3 = (String) premiumizeRepository$saveOAuthToken$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$saveOAuthToken$1.L$0; s38.b(accountInfoWithToken); } else { if (i2 != 2) { if (i2 != 3) { if (i2 != 4) { throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine"); } PremiumizeAccount premiumizeAccount3 = (PremiumizeAccount) premiumizeRepository$saveOAuthToken$1.L$0; s38.b(accountInfoWithToken); return premiumizeAccount3; } premiumizeAccount2 = (PremiumizeAccount) premiumizeRepository$saveOAuthToken$1.L$2; premiumizeAccountResponse = (PremiumizeAccountResponse) premiumizeRepository$saveOAuthToken$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$saveOAuthToken$1.L$0; s38.b(accountInfoWithToken); ExecutorService executorService = kq.a; kq.h(TAG, "Premiumize OAuth account saved: " + premiumizeAccountResponse.getCustomerId()); premiumizeRepository$saveOAuthToken$1.L$0 = premiumizeAccount2; premiumizeRepository$saveOAuthToken$1.L$1 = null; premiumizeRepository$saveOAuthToken$1.L$2 = null; premiumizeRepository$saveOAuthToken$1.label = 4; return premiumizeRepository.triggerCloudSync(premiumizeRepository$saveOAuthToken$1) != ck1Var ? ck1Var : premiumizeAccount2; } long j2 = premiumizeRepository$saveOAuthToken$1.J$0; PremiumizeAccountResponse premiumizeAccountResponse2 = (PremiumizeAccountResponse) premiumizeRepository$saveOAuthToken$1.L$2; String str4 = (String) premiumizeRepository$saveOAuthToken$1.L$1; premiumizeRepository = (PremiumizeRepository) premiumizeRepository$saveOAuthToken$1.L$0; s38.b(accountInfoWithToken); str2 = str4; j = j2; premiumizeAccountResponse = premiumizeAccountResponse2; PremiumizeAccount premiumizeAccount4 = (PremiumizeAccount) accountInfoWithToken; String apiKey = premiumizeAccount4 == null ? premiumizeAccount4.getApiKey() : null; String customerId = premiumizeAccountResponse.getCustomerId(); String str5 = (premiumizeAccountResponse.getPremiumUntil() != null || premiumizeAccountResponse.getPremiumUntil().longValue() <= j / ((long) 1000)) ? "free" : "premium"; Long premiumUntil = premiumizeAccountResponse.getPremiumUntil(); Long lBoxLong = premiumUntil == null ? Boxing.boxLong(premiumUntil.longValue() * ((long) 1000)) : null; Double pointsUsed = premiumizeAccountResponse.getPointsUsed(); Double pointsAvailable = premiumizeAccountResponse.getPointsAvailable(); Double spaceUsed = premiumizeAccountResponse.getSpaceUsed(); Long lBoxLong2 = spaceUsed == null ? Boxing.boxLong((long) spaceUsed.doubleValue()) : null; Double fairUseUsed = premiumizeAccountResponse.getFairUseUsed(); premiumizeAccount = new PremiumizeAccount("premiumize", apiKey, str2, customerId, null, null, str5, lBoxLong, pointsUsed, pointsAvailable, null, lBoxLong2, null, fairUseUsed == null ? Boxing.boxLong((long) fairUseUsed.doubleValue()) : null, j, j); premiumizeAccountDao = premiumizeRepository.accountDao; premiumizeRepository$saveOAuthToken$1.L$0 = premiumizeRepository; premiumizeRepository$saveOAuthToken$1.L$1 = premiumizeAccountResponse; premiumizeRepository$saveOAuthToken$1.L$2 = premiumizeAccount; premiumizeRepository$saveOAuthToken$1.label = 3; if (premiumizeAccountDao.upsert(premiumizeAccount, premiumizeRepository$saveOAuthToken$1) == ck1Var) { premiumizeAccount2 = premiumizeAccount; ExecutorService executorService2 = kq.a; kq.h(TAG, "Premiumize OAuth account saved: " + premiumizeAccountResponse.getCustomerId()); premiumizeRepository$saveOAuthToken$1.L$0 = premiumizeAccount2; premiumizeRepository$saveOAuthToken$1.L$1 = null; premiumizeRepository$saveOAuthToken$1.L$2 = null; premiumizeRepository$saveOAuthToken$1.label = 4; if (premiumizeRepository.triggerCloudSync(premiumizeRepository$saveOAuthToken$1) != ck1Var) { } } } PremiumizeAccountResponse premiumizeAccountResponse3 = (PremiumizeAccountResponse) accountInfoWithToken; if (!cr4.b(premiumizeAccountResponse3.getStatus(), "success")) { String message = premiumizeAccountResponse3.getMessage(); if (message == null) { message = "Failed to get account info"; } Log.w(TAG, "Premiumize OAuth verification failed: ".concat(message)); return s38.a(new Exception(message)); } long jCurrentTimeMillis = System.currentTimeMillis(); PremiumizeAccountDao premiumizeAccountDao2 = premiumizeRepository.accountDao; premiumizeRepository$saveOAuthToken$1.L$0 = premiumizeRepository; premiumizeRepository$saveOAuthToken$1.L$1 = str3; premiumizeRepository$saveOAuthToken$1.L$2 = premiumizeAccountResponse3; premiumizeRepository$saveOAuthToken$1.J$0 = jCurrentTimeMillis; premiumizeRepository$saveOAuthToken$1.label = 2; Object account = premiumizeAccountDao2.getAccount("premiumize", premiumizeRepository$saveOAuthToken$1); if (account != ck1Var) { premiumizeAccountResponse = premiumizeAccountResponse3; accountInfoWithToken = account; str2 = str3; j = jCurrentTimeMillis; PremiumizeAccount premiumizeAccount42 = (PremiumizeAccount) accountInfoWithToken; if (premiumizeAccount42 == null) { } String customerId2 = premiumizeAccountResponse.getCustomerId(); if (premiumizeAccountResponse.getPremiumUntil() != null) { String str52 = (premiumizeAccountResponse.getPremiumUntil() != null || premiumizeAccountResponse.getPremiumUntil().longValue() <= j / ((long) 1000)) ? "free" : "premium"; Long premiumUntil2 = premiumizeAccountResponse.getPremiumUntil(); if (premiumUntil2 == null) { } Double pointsUsed2 = premiumizeAccountResponse.getPointsUsed(); Double pointsAvailable2 = premiumizeAccountResponse.getPointsAvailable(); Double spaceUsed2 = premiumizeAccountResponse.getSpaceUsed(); if (spaceUsed2 == null) { } Double fairUseUsed2 = premiumizeAccountResponse.getFairUseUsed(); premiumizeAccount = new PremiumizeAccount("premiumize", apiKey, str2, customerId2, null, null, str52, lBoxLong, pointsUsed2, pointsAvailable2, null, lBoxLong2, null, fairUseUsed2 == null ? Boxing.boxLong((long) fairUseUsed2.doubleValue()) : null, j, j); premiumizeAccountDao = premiumizeRepository.accountDao; premiumizeRepository$saveOAuthToken$1.L$0 = premiumizeRepository; premiumizeRepository$saveOAuthToken$1.L$1 = premiumizeAccountResponse; premiumizeRepository$saveOAuthToken$1.L$2 = premiumizeAccount; premiumizeRepository$saveOAuthToken$1.label = 3; if (premiumizeAccountDao.upsert(premiumizeAccount, premiumizeRepository$saveOAuthToken$1) == ck1Var) { } } } } catch (Exception e) { Log.e(TAG, "Failed to save OAuth token", e); return s38.a(e); } } /* JADX ERROR: JadxRuntimeException in pass: ModVisitor jadx.core.utils.exceptions.JadxRuntimeException: Can't remove SSA var: r14v2 com.strmr.ps.data.local.entity.PremiumizeAccount, still in use, count: 2, list: (r14v2 com.strmr.ps.data.local.entity.PremiumizeAccount) from 0x00f7: MOVE (r34v1 com.strmr.ps.data.local.entity.PremiumizeAccount) = (r14v2 com.strmr.ps.data.local.entity.PremiumizeAccount) (r14v2 com.strmr.ps.data.local.entity.PremiumizeAccount) from 0x00e9: MOVE (r34v4 com.strmr.ps.data.local.entity.PremiumizeAccount) = (r14v2 com.strmr.ps.data.local.entity.PremiumizeAccount) at jadx.core.utils.InsnRemover.removeSsaVar(InsnRemover.java:162) at jadx.core.utils.InsnRemover.unbindResult(InsnRemover.java:127) at jadx.core.utils.InsnRemover.unbindInsn(InsnRemover.java:91) at jadx.core.utils.InsnRemover.addAndUnbind(InsnRemover.java:57) at jadx.core.dex.visitors.ModVisitor.removeStep(ModVisitor.java:463) at jadx.core.dex.visitors.ModVisitor.visit(ModVisitor.java:97) */ @defpackage.pq6 /* JADX INFO: renamed from: verifyAndSaveApiKey-gIAlu-s, reason: not valid java name */ public final java.lang.Object m121verifyAndSaveApiKeygIAlus(@defpackage.kp6 java.lang.String r34, @defpackage.kp6 kotlin.coroutines.Continuation> r35) { /* Method dump skipped, instruction units count: 427 To view this dump add '--comments-level debug' option */ throw new UnsupportedOperationException("Method not decompiled: com.strmr.ps.data.repository.PremiumizeRepository.m121verifyAndSaveApiKeygIAlus(java.lang.String, kotlin.coroutines.Continuation):java.lang.Object"); } }