package com.revenuecat.purchases.storage;

import A4.d;
import B4.a;
import C4.c;
import C4.e;
import C4.j;
import V4.C;
import V4.E;
import V4.H;
import V4.N;
import V4.x0;
import android.content.Context;
import android.support.v4.media.session.b;
import com.revenuecat.purchases.InternalRevenueCatAPI;
import com.revenuecat.purchases.LogHandler;
import com.revenuecat.purchases.LogLevel;
import com.revenuecat.purchases.common.Config;
import com.revenuecat.purchases.common.LogWrapperKt;
import com.revenuecat.purchases.models.Checksum;
import com.revenuecat.purchases.utils.DefaultUrlConnectionFactory;
import com.revenuecat.purchases.utils.UrlConnection;
import com.revenuecat.purchases.utils.UrlConnectionFactory;
import java.io.IOException;
import java.io.InputStream;
import java.net.URI;
import java.net.URL;
import java.util.Iterator;
import java.util.List;
import kotlin.jvm.internal.h;
import kotlin.jvm.internal.o;
import kotlin.jvm.internal.p;
import m3.AbstractC2467b;
import w4.C3137A;
import w4.k;

/* JADX INFO: loaded from: classes3.dex */
@InternalRevenueCatAPI
public final class DefaultFileRepository implements FileRepository {
    private final LocalFileCache fileCacheManager;
    private final C ioScope;
    private final LogHandler logHandler;
    private final KeyedDeferredValueStore<CacheKey, URI> store;
    private final UrlConnectionFactory urlConnectionFactory;

    public static final class CacheKey {
        private final Checksum checksum;
        private final URL url;

        public CacheKey(URL url, Checksum checksum) {
            o.h(url, "url");
            this.url = url;
            this.checksum = checksum;
        }

        public static /* synthetic */ CacheKey copy$default(CacheKey cacheKey, URL url, Checksum checksum, int i6, Object obj) {
            if ((i6 & 1) != 0) {
                url = cacheKey.url;
            }
            if ((i6 & 2) != 0) {
                checksum = cacheKey.checksum;
            }
            return cacheKey.copy(url, checksum);
        }

        public final URL component1() {
            return this.url;
        }

        public final Checksum component2() {
            return this.checksum;
        }

        public final CacheKey copy(URL url, Checksum checksum) {
            o.h(url, "url");
            return new CacheKey(url, checksum);
        }

        public boolean equals(Object obj) {
            if (this == obj) {
                return true;
            }
            if (!(obj instanceof CacheKey)) {
                return false;
            }
            CacheKey cacheKey = (CacheKey) obj;
            return o.c(this.url, cacheKey.url) && o.c(this.checksum, cacheKey.checksum);
        }

        public final Checksum getChecksum() {
            return this.checksum;
        }

        public final URL getUrl() {
            return this.url;
        }

        public int hashCode() {
            int iHashCode = this.url.hashCode() * 31;
            Checksum checksum = this.checksum;
            return iHashCode + (checksum == null ? 0 : checksum.hashCode());
        }

        public String toString() {
            return "CacheKey(url=" + this.url + ", checksum=" + this.checksum + ')';
        }
    }

    public static abstract class Error extends IOException {

        public static final class ChecksumValidationFailed extends Error {
            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public ChecksumValidationFailed(String message) {
                super(message, null);
                o.h(message, "message");
            }
        }

        public static final class FailedToCreateCacheDirectory extends Error {
            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public FailedToCreateCacheDirectory(String url) {
                super("Failed to create cache directory for ".concat(url), null);
                o.h(url, "url");
            }
        }

        public static final class FailedToFetchFileFromRemoteSource extends Error {
            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public FailedToFetchFileFromRemoteSource(String message) {
                super(message, null);
                o.h(message, "message");
            }
        }

        public static final class FailedToSaveCachedFile extends Error {
            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public FailedToSaveCachedFile(String message) {
                super(message, null);
                o.h(message, "message");
            }
        }

        public /* synthetic */ Error(String str, h hVar) {
            this(str);
        }

        private Error(String str) {
            super(str);
        }
    }

    /* JADX INFO: renamed from: com.revenuecat.purchases.storage.DefaultFileRepository$downloadFile$1, reason: invalid class name */
    @e(c = "com.revenuecat.purchases.storage.DefaultFileRepository", f = "DefaultFileRepository.kt", l = {131}, m = "downloadFile")
    public static final class AnonymousClass1 extends c {
        Object L$0;
        Object L$1;
        int label;
        /* synthetic */ Object result;

        public AnonymousClass1(d dVar) {
            super(dVar);
        }

        @Override // C4.a
        public final Object invokeSuspend(Object obj) {
            this.result = obj;
            this.label |= Integer.MIN_VALUE;
            return DefaultFileRepository.this.downloadFile(null, this);
        }
    }

    /* JADX INFO: renamed from: com.revenuecat.purchases.storage.DefaultFileRepository$downloadFile$2, reason: invalid class name */
    @e(c = "com.revenuecat.purchases.storage.DefaultFileRepository$downloadFile$2", f = "DefaultFileRepository.kt", l = {}, m = "invokeSuspend")
    public static final class AnonymousClass2 extends j implements J4.e {
        final /* synthetic */ URL $url;
        int label;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public AnonymousClass2(URL url, d dVar) {
            super(2, dVar);
            this.$url = url;
        }

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            return DefaultFileRepository.this.new AnonymousClass2(this.$url, dVar);
        }

        @Override // J4.e
        public final Object invoke(C c6, d dVar) {
            return ((AnonymousClass2) create(c6, dVar)).invokeSuspend(C3137A.f25453a);
        }

        @Override // C4.a
        public final Object invokeSuspend(Object obj) throws IOException {
            a aVar = a.f492a;
            if (this.label != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            AbstractC2467b.l(obj);
            URL url = this.$url;
            LogLevel logLevel = LogLevel.VERBOSE;
            LogHandler currentLogHandler = LogWrapperKt.getCurrentLogHandler();
            if (Config.INSTANCE.getLogLevel().compareTo(logLevel) <= 0) {
                currentLogHandler.v(com.google.android.recaptcha.internal.a.j(logLevel, new StringBuilder("[Purchases] - ")), "Downloading remote file from " + url);
            }
            UrlConnectionFactory urlConnectionFactory = DefaultFileRepository.this.urlConnectionFactory;
            String string = this.$url.toString();
            o.g(string, "url.toString()");
            UrlConnection urlConnectionCreateConnection$default = UrlConnectionFactory.createConnection$default(urlConnectionFactory, string, null, 2, null);
            if (urlConnectionCreateConnection$default.getResponseCode() == 200) {
                return urlConnectionCreateConnection$default;
            }
            urlConnectionCreateConnection$default.disconnect();
            throw new IOException("HTTP " + urlConnectionCreateConnection$default.getResponseCode() + " when downloading file at: " + this.$url);
        }
    }

    /* JADX INFO: renamed from: com.revenuecat.purchases.storage.DefaultFileRepository$generateOrGetCachedFileURL$2, reason: invalid class name and case insensitive filesystem */
    public static final class C14412 extends p implements J4.a {
        final /* synthetic */ Checksum $checksum;
        final /* synthetic */ URL $url;

        /* JADX INFO: renamed from: com.revenuecat.purchases.storage.DefaultFileRepository$generateOrGetCachedFileURL$2$1, reason: invalid class name */
        @e(c = "com.revenuecat.purchases.storage.DefaultFileRepository$generateOrGetCachedFileURL$2$1", f = "DefaultFileRepository.kt", l = {118}, m = "invokeSuspend")
        public static final class AnonymousClass1 extends j implements J4.e {
            final /* synthetic */ Checksum $checksum;
            final /* synthetic */ URL $url;
            Object L$0;
            int label;
            final /* synthetic */ DefaultFileRepository this$0;

            /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
            public AnonymousClass1(DefaultFileRepository defaultFileRepository, URL url, Checksum checksum, d dVar) {
                super(2, dVar);
                this.this$0 = defaultFileRepository;
                this.$url = url;
                this.$checksum = checksum;
            }

            @Override // C4.a
            public final d create(Object obj, d dVar) {
                return new AnonymousClass1(this.this$0, this.$url, this.$checksum, dVar);
            }

            @Override // J4.e
            public final Object invoke(C c6, d dVar) {
                return ((AnonymousClass1) create(c6, dVar)).invokeSuspend(C3137A.f25453a);
            }

            @Override // C4.a
            public final Object invokeSuspend(Object obj) throws Error.FailedToFetchFileFromRemoteSource, Error.FailedToCreateCacheDirectory {
                URI uri;
                a aVar = a.f492a;
                int i6 = this.label;
                if (i6 == 0) {
                    AbstractC2467b.l(obj);
                    URI uriGenerateLocalFilesystemURI = this.this$0.fileCacheManager.generateLocalFilesystemURI(this.$url, this.$checksum);
                    if (uriGenerateLocalFilesystemURI == null) {
                        String string = this.$url.toString();
                        o.g(string, "url.toString()");
                        Error.FailedToCreateCacheDirectory failedToCreateCacheDirectory = new Error.FailedToCreateCacheDirectory(string);
                        this.this$0.logHandler.e("FileRepository", "Failed to create cache directory for " + this.$url, failedToCreateCacheDirectory);
                        throw failedToCreateCacheDirectory;
                    }
                    if (this.this$0.fileCacheManager.cachedContentExists(uriGenerateLocalFilesystemURI)) {
                        return uriGenerateLocalFilesystemURI;
                    }
                    DefaultFileRepository defaultFileRepository = this.this$0;
                    URL url = this.$url;
                    this.L$0 = uriGenerateLocalFilesystemURI;
                    this.label = 1;
                    Object objDownloadFile = defaultFileRepository.downloadFile(url, this);
                    if (objDownloadFile == aVar) {
                        return aVar;
                    }
                    uri = uriGenerateLocalFilesystemURI;
                    obj = objDownloadFile;
                } else {
                    if (i6 != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    uri = (URI) this.L$0;
                    AbstractC2467b.l(obj);
                }
                this.this$0.saveCachedFile(uri, (UrlConnection) obj, this.$checksum);
                return uri;
            }
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C14412(URL url, Checksum checksum) {
            super(0);
            this.$url = url;
            this.$checksum = checksum;
        }

        @Override // J4.a
        public final H invoke() {
            return E.e(DefaultFileRepository.this.ioScope, null, new AnonymousClass1(DefaultFileRepository.this, this.$url, this.$checksum, null), 3);
        }
    }

    /* JADX INFO: renamed from: com.revenuecat.purchases.storage.DefaultFileRepository$prefetch$1, reason: invalid class name and case insensitive filesystem */
    @e(c = "com.revenuecat.purchases.storage.DefaultFileRepository$prefetch$1", f = "DefaultFileRepository.kt", l = {94}, m = "invokeSuspend")
    public static final class C14421 extends j implements J4.e {
        final /* synthetic */ List<k> $urls;
        Object L$0;
        Object L$1;
        Object L$2;
        int label;
        final /* synthetic */ DefaultFileRepository this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public C14421(List<k> list, DefaultFileRepository defaultFileRepository, d dVar) {
            super(2, dVar);
            this.$urls = list;
            this.this$0 = defaultFileRepository;
        }

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            return new C14421(this.$urls, this.this$0, dVar);
        }

        @Override // J4.e
        public final Object invoke(C c6, d dVar) {
            return ((C14421) create(c6, dVar)).invokeSuspend(C3137A.f25453a);
        }

        /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:19:0x0053 -> B:13:0x0030). Please report as a decompilation issue!!! */
        @Override // C4.a
        public final Object invokeSuspend(Object obj) {
            Iterator it;
            DefaultFileRepository defaultFileRepository;
            URL url;
            a aVar = a.f492a;
            int i6 = this.label;
            if (i6 == 0) {
                AbstractC2467b.l(obj);
                List<k> list = this.$urls;
                DefaultFileRepository defaultFileRepository2 = this.this$0;
                it = list.iterator();
                defaultFileRepository = defaultFileRepository2;
            } else {
                if (i6 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                url = (URL) this.L$2;
                it = (Iterator) this.L$1;
                defaultFileRepository = (DefaultFileRepository) this.L$0;
                try {
                    AbstractC2467b.l(obj);
                } catch (IOException e6) {
                    defaultFileRepository.logHandler.e("FileRepository", "Prefetch failed for " + url + ": " + e6, e6);
                }
            }
            while (it.hasNext()) {
                k kVar = (k) it.next();
                url = (URL) kVar.f25469a;
                Checksum checksum = (Checksum) kVar.f25470b;
                this.L$0 = defaultFileRepository;
                this.L$1 = it;
                this.L$2 = url;
                this.label = 1;
                if (defaultFileRepository.generateOrGetCachedFileURL(url, checksum, this) == aVar) {
                    return aVar;
                }
            }
            return C3137A.f25453a;
        }
    }

    public DefaultFileRepository(KeyedDeferredValueStore<CacheKey, URI> store, LocalFileCache fileCacheManager, C ioScope, LogHandler logHandler, UrlConnectionFactory urlConnectionFactory) {
        o.h(store, "store");
        o.h(fileCacheManager, "fileCacheManager");
        o.h(ioScope, "ioScope");
        o.h(logHandler, "logHandler");
        o.h(urlConnectionFactory, "urlConnectionFactory");
        this.store = store;
        this.fileCacheManager = fileCacheManager;
        this.ioScope = ioScope;
        this.logHandler = logHandler;
        this.urlConnectionFactory = urlConnectionFactory;
    }

    /* 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 downloadFile(URL url, d dVar) throws Error.FailedToFetchFileFromRemoteSource {
        AnonymousClass1 anonymousClass1;
        DefaultFileRepository defaultFileRepository;
        if (dVar instanceof AnonymousClass1) {
            anonymousClass1 = (AnonymousClass1) dVar;
            int i6 = anonymousClass1.label;
            if ((i6 & Integer.MIN_VALUE) != 0) {
                anonymousClass1.label = i6 - Integer.MIN_VALUE;
            } else {
                anonymousClass1 = new AnonymousClass1(dVar);
            }
        }
        Object objH = anonymousClass1.result;
        a aVar = a.f492a;
        int i7 = anonymousClass1.label;
        if (i7 == 0) {
            AbstractC2467b.l(objH);
            try {
                c5.e eVar = N.f8259a;
                c5.d dVar2 = c5.d.f13466b;
                AnonymousClass2 anonymousClass2 = new AnonymousClass2(url, null);
                anonymousClass1.L$0 = this;
                anonymousClass1.L$1 = url;
                anonymousClass1.label = 1;
                objH = E.H(dVar2, anonymousClass2, anonymousClass1);
                if (objH == aVar) {
                    return aVar;
                }
                defaultFileRepository = this;
            } catch (IOException e6) {
                e = e6;
                defaultFileRepository = this;
                String str = "Failed to fetch file from remote source: " + url + ". Error: " + e.getLocalizedMessage();
                defaultFileRepository.logHandler.e("FileRepository", str, e);
                throw new Error.FailedToFetchFileFromRemoteSource(str);
            }
        } else {
            if (i7 != 1) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            url = (URL) anonymousClass1.L$1;
            defaultFileRepository = (DefaultFileRepository) anonymousClass1.L$0;
            try {
                AbstractC2467b.l(objH);
            } catch (IOException e7) {
                e = e7;
                String str2 = "Failed to fetch file from remote source: " + url + ". Error: " + e.getLocalizedMessage();
                defaultFileRepository.logHandler.e("FileRepository", str2, e);
                throw new Error.FailedToFetchFileFromRemoteSource(str2);
            }
        }
        return (UrlConnection) objH;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void saveCachedFile(URI uri, UrlConnection urlConnection, Checksum checksum) {
        try {
            try {
                InputStream inputStream = urlConnection.getInputStream();
                try {
                    this.fileCacheManager.saveData(inputStream, uri, checksum);
                    b.j(inputStream, null);
                } finally {
                }
            } finally {
                urlConnection.disconnect();
            }
        } catch (Checksum.ChecksumValidationException e6) {
            String str = "Checksum validation failed for " + uri + ": " + e6.getMessage();
            this.logHandler.e("FileRepository", str, e6);
            throw new Error.ChecksumValidationFailed(str);
        } catch (IOException e7) {
            String str2 = "Failed to save cached file: " + uri + ". Error: " + e7.getLocalizedMessage();
            this.logHandler.e("FileRepository", str2, e7);
            throw new Error.FailedToSaveCachedFile(str2);
        }
    }

    @Override // com.revenuecat.purchases.storage.FileRepository
    public Object generateOrGetCachedFileURL(URL url, Checksum checksum, d dVar) {
        return this.store.getOrPut(new CacheKey(url, checksum), new C14412(url, checksum)).await(dVar);
    }

    @Override // com.revenuecat.purchases.storage.FileRepository
    public URI getFile(URL url, Checksum checksum) {
        o.h(url, "url");
        URI uriGenerateLocalFilesystemURI = this.fileCacheManager.generateLocalFilesystemURI(url, checksum);
        if (uriGenerateLocalFilesystemURI == null || !this.fileCacheManager.cachedContentExists(uriGenerateLocalFilesystemURI)) {
            return null;
        }
        return uriGenerateLocalFilesystemURI;
    }

    public final KeyedDeferredValueStore<CacheKey, URI> getStore$purchases_defaultsBc8Release() {
        return this.store;
    }

    @Override // com.revenuecat.purchases.storage.FileRepository
    public void prefetch(List<k> urls) {
        o.h(urls, "urls");
        E.y(this.ioScope, null, null, new C14421(urls, this, null), 3);
    }

    /* JADX WARN: Illegal instructions before constructor call */
    public DefaultFileRepository(KeyedDeferredValueStore keyedDeferredValueStore, LocalFileCache localFileCache, C c6, LogHandler logHandler, UrlConnectionFactory urlConnectionFactory, int i6, h hVar) {
        KeyedDeferredValueStore keyedDeferredValueStore2 = (i6 & 1) != 0 ? new KeyedDeferredValueStore(null, 1, null) : keyedDeferredValueStore;
        if ((i6 & 4) != 0) {
            c5.e eVar = N.f8259a;
            c6 = E.c(c5.d.f13466b.plus(x0.f8349a));
        }
        this(keyedDeferredValueStore2, localFileCache, c6, (i6 & 8) != 0 ? LogWrapperKt.getCurrentLogHandler() : logHandler, (i6 & 16) != 0 ? new DefaultUrlConnectionFactory() : urlConnectionFactory);
    }

    /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */
    public DefaultFileRepository(Context context) {
        this(null, new DefaultFileCache(context), null, null, null, 29, null);
        o.h(context, "context");
    }
}