package com.strmr.ps.data.repository;

import android.content.Context;
import android.content.SharedPreferences;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import com.google.android.gms.measurement.api.AppMeasurementSdk;
import com.google.gson.JsonElement;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;
import dagger.hilt.android.qualifiers.ApplicationContext;
import defpackage.ak1;
import defpackage.bk1;
import defpackage.cr4;
import defpackage.e6a;
import defpackage.fx4;
import defpackage.gj1;
import defpackage.kp6;
import defpackage.m02;
import defpackage.m12;
import defpackage.n89;
import defpackage.pq6;
import defpackage.rx4;
import defpackage.s38;
import defpackage.sc2;
import defpackage.sq3;
import defpackage.uz1;
import defpackage.vx8;
import defpackage.wj0;
import defpackage.zd9;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.Set;
import javax.inject.Inject;
import javax.inject.Singleton;
import kotlin.Metadata;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: loaded from: classes3.dex */
@Singleton
@Metadata(d1 = {"\u0000j\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u0006\n\u0002\b\b\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0004\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010%\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0002\u0010$\n\u0002\b\u0003\b\u0007\u0018\u0000 12\u00020\u0001:\u00011B\u0013\b\u0007\u0012\b\b\u0001\u0010\u0003\u001a\u00020\u0002¢\u0006\u0004\b\u0004\u0010\u0005J\u0017\u0010\t\u001a\u00020\b2\u0006\u0010\u0007\u001a\u00020\u0006H\u0002¢\u0006\u0004\b\t\u0010\nJ\u0019\u0010\f\u001a\u0004\u0018\u00010\u000b2\u0006\u0010\u0007\u001a\u00020\u0006H\u0002¢\u0006\u0004\b\f\u0010\rJ\u000f\u0010\u000e\u001a\u0004\u0018\u00010\u0006¢\u0006\u0004\b\u000e\u0010\u000fJ\u0015\u0010\u0011\u001a\u00020\b2\u0006\u0010\u0010\u001a\u00020\u0006¢\u0006\u0004\b\u0011\u0010\nJ\r\u0010\u0012\u001a\u00020\b¢\u0006\u0004\b\u0012\u0010\u0013J\r\u0010\u0015\u001a\u00020\u0014¢\u0006\u0004\b\u0015\u0010\u0016J\u001b\u0010\u001a\u001a\b\u0012\u0004\u0012\u00020\u00140\u00172\u0006\u0010\u0010\u001a\u00020\u0006¢\u0006\u0004\b\u0018\u0010\u0019J\u0019\u0010\u001b\u001a\u0004\u0018\u00010\u000b2\b\u0010\u0007\u001a\u0004\u0018\u00010\u0006¢\u0006\u0004\b\u001b\u0010\rJ3\u0010\u001e\u001a\u0004\u0018\u00010\u000b2\b\u0010\u0007\u001a\u0004\u0018\u00010\u00062\u0018\b\u0002\u0010\u001d\u001a\u0012\u0012\u0006\u0012\u0004\u0018\u00010\u000b\u0012\u0004\u0012\u00020\b\u0018\u00010\u001c¢\u0006\u0004\b\u001e\u0010\u001fR\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\u0003\u0010 R\u0014\u0010\"\u001a\u00020!8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b\"\u0010#R\u0014\u0010%\u001a\u00020$8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b%\u0010&R\u0014\u0010(\u001a\u00020'8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b(\u0010)R \u0010+\u001a\u000e\u0012\u0004\u0012\u00020\u0006\u0012\u0004\u0012\u00020\u000b0*8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b+\u0010,RT\u00100\u001aB\u0012\f\u0012\n -*\u0004\u0018\u00010\u00060\u0006\u0012\f\u0012\n -*\u0004\u0018\u00010.0. -* \u0012\f\u0012\n -*\u0004\u0018\u00010\u00060\u0006\u0012\f\u0012\n -*\u0004\u0018\u00010.0.\u0018\u00010/0*8\u0002X\u0082\u0004¢\u0006\u0006\n\u0004\b0\u0010,¨\u00062"}, d2 = {"Lcom/strmr/ps/data/repository/OmdbRepository;", "", "Landroid/content/Context;", "context", "<init>", "(Landroid/content/Context;)V", "", "imdbId", "Le6a;", "launchFetch", "(Ljava/lang/String;)V", "", "fetchRating", "(Ljava/lang/String;)Ljava/lang/Double;", "getApiKey", "()Ljava/lang/String;", "apiKey", "saveApiKey", "clearApiKey", "()V", "", "isEnabled", "()Z", "Lq38;", "verifyApiKey-IoAF18A", "(Ljava/lang/String;)Ljava/lang/Object;", "verifyApiKey", "getCachedRating", "Lkotlin/Function1;", "onReady", "getOrFetchRating", "(Ljava/lang/String;Lsq3;)Ljava/lang/Double;", "Landroid/content/Context;", "Landroid/content/SharedPreferences;", "prefs", "Landroid/content/SharedPreferences;", "Lokhttp3/OkHttpClient;", "httpClient", "Lokhttp3/OkHttpClient;", "Lak1;", "scope", "Lak1;", "", "cache", "Ljava/util/Map;", "kotlin.jvm.PlatformType", "Lfx4;", "", "inFlight", "Companion", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class OmdbRepository {

    @kp6
    private static final String BASE_URL = "https://www.omdbapi.com";
    private static final int CACHE_MAX = 256;

    /* JADX INFO: renamed from: Companion, reason: from kotlin metadata */
    @kp6
    public static final Companion INSTANCE = new Companion(null);

    @kp6
    private static final String KEY_API_KEY = "omdb_api_key";

    @kp6
    private static final String PREFS_NAME = "omdb_prefs";

    @kp6
    private static final String TAG = "OmdbRepository";

    @kp6
    private static final String VALIDATION_IMDB_ID = "tt0111161";

    @pq6
    private static volatile OmdbRepository instance;

    @kp6
    private final Map<String, Double> cache;

    @kp6
    private final Context context;

    @kp6
    private final OkHttpClient httpClient;
    private final Map<String, fx4> inFlight;

    @kp6
    private final SharedPreferences prefs;

    @kp6
    private final ak1 scope;

    @Metadata(d1 = {"\u0000$\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\u0004\n\u0002\u0010\b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\b\u0086\u0003\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b\u0002\u0010\u0003R\u000e\u0010\u0004\u001a\u00020\u0005X\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\u0006\u001a\u00020\u0005X\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\u0007\u001a\u00020\u0005X\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\b\u001a\u00020\u0005X\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\t\u001a\u00020\nX\u0082T¢\u0006\u0002\n\u0000R\u000e\u0010\u000b\u001a\u00020\u0005X\u0082T¢\u0006\u0002\n\u0000R\"\u0010\u000e\u001a\u0004\u0018\u00010\r2\b\u0010\f\u001a\u0004\u0018\u00010\r@BX\u0086\u000e¢\u0006\b\n\u0000\u001a\u0004\b\u000f\u0010\u0010¨\u0006\u0011"}, d2 = {"Lcom/strmr/ps/data/repository/OmdbRepository$Companion;", "", "<init>", "()V", "TAG", "", "PREFS_NAME", "KEY_API_KEY", "BASE_URL", "CACHE_MAX", "", "VALIDATION_IMDB_ID", AppMeasurementSdk.ConditionalUserProperty.VALUE, "Lcom/strmr/ps/data/repository/OmdbRepository;", "instance", "getInstance", "()Lcom/strmr/ps/data/repository/OmdbRepository;", "app_sideloadRelease"}, k = 1, mv = {2, 0, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class Companion {
        public /* synthetic */ Companion(uz1 uz1Var) {
            this();
        }

        @pq6
        public final OmdbRepository getInstance() {
            return OmdbRepository.instance;
        }

        private Companion() {
        }
    }

    @Inject
    public OmdbRepository(@ApplicationContext @kp6 Context context) {
        cr4.g(context, "context");
        this.context = context;
        SharedPreferences sharedPreferences = context.getSharedPreferences(PREFS_NAME, 0);
        cr4.f(sharedPreferences, "getSharedPreferences(...)");
        this.prefs = sharedPreferences;
        this.httpClient = new OkHttpClient();
        gj1.b bVarB = zd9.b();
        m12 m12Var = sc2.a;
        this.scope = bk1.a(gj1.b.a.c((rx4) bVarB, m02.c));
        Map<String, Double> mapSynchronizedMap = Collections.synchronizedMap(new LinkedHashMap<String, Double>() { // from class: com.strmr.ps.data.repository.OmdbRepository$cache$1
            @Override // java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ boolean containsKey(Object obj) {
                if (obj instanceof String) {
                    return containsKey((String) obj);
                }
                return false;
            }

            public /* bridge */ boolean containsValue(Double d) {
                return super.containsValue((Object) d);
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ Set<Map.Entry<String, Double>> entrySet() {
                return getEntries();
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ Double get(Object obj) {
                if (obj instanceof String) {
                    return get((String) obj);
                }
                return null;
            }

            public /* bridge */ Set<Map.Entry<String, Double>> getEntries() {
                return super.entrySet();
            }

            public /* bridge */ Set<String> getKeys() {
                return super.keySet();
            }

            public final /* bridge */ Double getOrDefault(Object obj, Double d) {
                return !(obj instanceof String) ? d : getOrDefault((String) obj, d);
            }

            public /* bridge */ int getSize() {
                return super.size();
            }

            public /* bridge */ Collection<Double> getValues() {
                return super.values();
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ Set<String> keySet() {
                return getKeys();
            }

            @Override // java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ Double remove(Object obj) {
                if (obj instanceof String) {
                    return remove((String) obj);
                }
                return null;
            }

            @Override // java.util.LinkedHashMap
            public boolean removeEldestEntry(Map.Entry<String, Double> eldest) {
                cr4.g(eldest, "eldest");
                return size() > 256;
            }

            @Override // java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ int size() {
                return getSize();
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ Collection<Double> values() {
                return getValues();
            }

            public /* bridge */ boolean containsKey(String str) {
                return super.containsKey((Object) str);
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ boolean containsValue(Object obj) {
                if (obj instanceof Double) {
                    return containsValue((Double) obj);
                }
                return false;
            }

            public /* bridge */ Double get(String str) {
                return (Double) super.get((Object) str);
            }

            public /* bridge */ Double getOrDefault(String str, Double d) {
                return (Double) super.getOrDefault((Object) str, d);
            }

            public /* bridge */ Double remove(String str) {
                return (Double) super.remove((Object) str);
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ /* synthetic */ Object get(Object obj) {
                if (obj instanceof String) {
                    return get((String) obj);
                }
                return null;
            }

            @Override // java.util.LinkedHashMap, java.util.HashMap, java.util.Map
            public final /* bridge */ /* synthetic */ Object getOrDefault(Object obj, Object obj2) {
                return !(obj instanceof String) ? obj2 : getOrDefault((String) obj, (Double) obj2);
            }

            @Override // java.util.HashMap, java.util.AbstractMap, java.util.Map
            public final /* bridge */ /* synthetic */ Object remove(Object obj) {
                if (obj instanceof String) {
                    return remove((String) obj);
                }
                return null;
            }

            @Override // java.util.HashMap, java.util.Map
            public final /* bridge */ boolean remove(Object obj, Object obj2) {
                if ((obj instanceof String) && (obj2 instanceof Double)) {
                    return remove((String) obj, (Double) obj2);
                }
                return false;
            }

            public /* bridge */ boolean remove(String str, Double d) {
                return super.remove((Object) str, (Object) d);
            }
        });
        cr4.f(mapSynchronizedMap, "synchronizedMap(...)");
        this.cache = mapSynchronizedMap;
        this.inFlight = Collections.synchronizedMap(new LinkedHashMap());
        instance = this;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final Double fetchRating(String imdbId) {
        Double dBc;
        String apiKey = getApiKey();
        if (apiKey != null) {
            try {
                Response responseExecute = this.httpClient.newCall(new Request.Builder().url("https://www.omdbapi.com/?apikey=" + apiKey + "&i=" + imdbId + "&tomatoes=true").get().build()).execute();
                ResponseBody responseBodyBody = responseExecute.body();
                String strString = responseBodyBody != null ? responseBodyBody.string() : null;
                responseExecute.close();
                if (responseExecute.isSuccessful() && strString != null && !n89.ab(strString)) {
                    JsonObject asJsonObject = JsonParser.parseString(strString).getAsJsonObject();
                    if (asJsonObject.has("Response") && n89.u(asJsonObject.get("Response").getAsString(), "True")) {
                        JsonElement jsonElement = asJsonObject.get("imdbRating");
                        String asString = jsonElement != null ? jsonElement.getAsString() : null;
                        if (asString != null) {
                            if (asString.equals("N/A")) {
                                asString = null;
                            }
                            if (asString != null && (dBc = n89.bc(asString)) != null) {
                                if (dBc.doubleValue() <= 0.0d) {
                                    dBc = null;
                                }
                                if (dBc != null) {
                                    double dDoubleValue = dBc.doubleValue();
                                    if (dDoubleValue > 10.0d) {
                                        dDoubleValue = 10.0d;
                                    }
                                    return Double.valueOf(dDoubleValue);
                                }
                            }
                        }
                    }
                }
            } catch (Exception e) {
                Log.w(TAG, "OMDb fetch failed for " + imdbId + ": " + e.getMessage());
                return null;
            }
        }
        return null;
    }

    /* JADX WARN: Multi-variable type inference failed */
    public static /* synthetic */ Double getOrFetchRating$default(OmdbRepository omdbRepository, String str, sq3 sq3Var, int i, Object obj) {
        if ((i & 2) != 0) {
            sq3Var = null;
        }
        return omdbRepository.getOrFetchRating(str, sq3Var);
    }

    private final void launchFetch(String imdbId) {
        Map<String, fx4> map = this.inFlight;
        cr4.f(map, "inFlight");
        synchronized (map) {
            if (this.inFlight.get(imdbId) != null) {
                return;
            }
            Map<String, fx4> map2 = this.inFlight;
            cr4.f(map2, "inFlight");
            map2.put(imdbId, wj0.c(this.scope, null, null, new OmdbRepository$launchFetch$1$1(this, imdbId, null), 3));
        }
    }

    public final void clearApiKey() {
        this.prefs.edit().remove(KEY_API_KEY).apply();
        this.cache.clear();
    }

    @pq6
    public final String getApiKey() {
        return this.prefs.getString(KEY_API_KEY, null);
    }

    @pq6
    public final Double getCachedRating(@pq6 String imdbId) {
        Double d;
        if (imdbId == null || n89.ab(imdbId) || (d = this.cache.get(imdbId)) == null || Double.isNaN(d.doubleValue())) {
            return null;
        }
        return d;
    }

    @pq6
    public final Double getOrFetchRating(@pq6 String imdbId, @pq6 sq3<? super Double, e6a> onReady) {
        if (isEnabled() && imdbId != null && !n89.ab(imdbId)) {
            Double d = this.cache.get(imdbId);
            if (d == null) {
                if (onReady == null) {
                    launchFetch(imdbId);
                    return null;
                }
                Map<String, fx4> map = this.inFlight;
                cr4.f(map, "inFlight");
                synchronized (map) {
                    try {
                        if (this.inFlight.get(imdbId) == null) {
                            Map<String, fx4> map2 = this.inFlight;
                            cr4.f(map2, "inFlight");
                            map2.put(imdbId, wj0.c(this.scope, null, null, new OmdbRepository$getOrFetchRating$1$1(this, imdbId, onReady, null), 3));
                        } else {
                            wj0.c(this.scope, null, null, new OmdbRepository$getOrFetchRating$1$2(this, imdbId, onReady, null), 3);
                        }
                    } catch (Throwable th) {
                        throw th;
                    }
                }
                return null;
            }
            if (!Double.isNaN(d.doubleValue())) {
                return d;
            }
        }
        return null;
    }

    public final boolean isEnabled() {
        String apiKey = getApiKey();
        return !(apiKey == null || n89.ab(apiKey));
    }

    public final void saveApiKey(@kp6 String apiKey) {
        cr4.g(apiKey, "apiKey");
        this.prefs.edit().putString(KEY_API_KEY, apiKey).apply();
        this.cache.clear();
    }

    @kp6
    /* JADX INFO: renamed from: verifyApiKey-IoAF18A, reason: not valid java name */
    public final Object m107verifyApiKeyIoAF18A(@kp6 String apiKey) {
        String asString;
        cr4.g(apiKey, "apiKey");
        try {
            Response responseExecute = this.httpClient.newCall(new Request.Builder().url("https://www.omdbapi.com/?apikey=" + apiKey + "&i=tt0111161").get().build()).execute();
            ResponseBody responseBodyBody = responseExecute.body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            responseExecute.close();
            if (responseExecute.isSuccessful() && strString != null && !n89.ab(strString)) {
                JsonObject asJsonObject = JsonParser.parseString(strString).getAsJsonObject();
                if (asJsonObject.has("Response") && n89.u(asJsonObject.get("Response").getAsString(), "True")) {
                    return Boolean.TRUE;
                }
                JsonElement jsonElement = asJsonObject.get("Error");
                if (jsonElement == null || (asString = jsonElement.getAsString()) == null) {
                    asString = "Invalid API key";
                }
                return s38.a(new Exception(asString));
            }
            return s38.a(new Exception("HTTP " + responseExecute.code()));
        } catch (Exception e) {
            Log.e(TAG, "OMDb key validation error", e);
            return s38.a(e);
        }
    }
}