package com.google.firebase.sessions.settings;

import A4.d;
import A4.k;
import B4.a;
import C4.c;
import C4.j;
import O1.InterfaceC0569i;
import S1.b;
import S1.e;
import S1.g;
import V4.C;
import V4.E;
import Y4.InterfaceC0843i;
import Y4.O;
import android.util.Log;
import java.io.IOException;
import kotlin.jvm.internal.h;
import kotlin.jvm.internal.o;
import m3.AbstractC2467b;
import w4.C3137A;
import x4.AbstractC3229F;

/* JADX INFO: loaded from: classes3.dex */
public final class SettingsCache {

    @Deprecated
    public static final String TAG = "SettingsCache";
    private final InterfaceC0569i dataStore;
    private SessionConfigs sessionConfigs;
    private static final Companion Companion = new Companion(null);
    private static final e SESSIONS_ENABLED = new e(LocalOverrideSettings.SESSIONS_ENABLED);
    private static final e SAMPLING_RATE = new e(LocalOverrideSettings.SAMPLING_RATE);
    private static final e RESTART_TIMEOUT_SECONDS = new e("firebase_sessions_restart_timeout");
    private static final e CACHE_DURATION_SECONDS = new e("firebase_sessions_cache_duration");
    private static final e CACHE_UPDATED_TIME = new e("firebase_sessions_cache_updated_time");

    /* JADX INFO: renamed from: com.google.firebase.sessions.settings.SettingsCache$1, reason: invalid class name */
    @C4.e(c = "com.google.firebase.sessions.settings.SettingsCache$1", f = "SettingsCache.kt", l = {46}, m = "invokeSuspend")
    public static final class AnonymousClass1 extends j implements J4.e {
        Object L$0;
        int label;

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

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            return SettingsCache.this.new AnonymousClass1(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) {
            SettingsCache settingsCache;
            a aVar = a.f492a;
            int i6 = this.label;
            if (i6 == 0) {
                AbstractC2467b.l(obj);
                SettingsCache settingsCache2 = SettingsCache.this;
                InterfaceC0843i data = settingsCache2.dataStore.getData();
                this.L$0 = settingsCache2;
                this.label = 1;
                Object objL = O.l(data, this);
                if (objL == aVar) {
                    return aVar;
                }
                settingsCache = settingsCache2;
                obj = objL;
            } else {
                if (i6 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                settingsCache = (SettingsCache) this.L$0;
                AbstractC2467b.l(obj);
            }
            settingsCache.updateSessionConfigs(new b(AbstractC3229F.I(((g) obj).a()), true));
            return C3137A.f25453a;
        }
    }

    public static final class Companion {
        public /* synthetic */ Companion(h hVar) {
            this();
        }

        public final e getCACHE_DURATION_SECONDS() {
            return SettingsCache.CACHE_DURATION_SECONDS;
        }

        public final e getCACHE_UPDATED_TIME() {
            return SettingsCache.CACHE_UPDATED_TIME;
        }

        public final e getRESTART_TIMEOUT_SECONDS() {
            return SettingsCache.RESTART_TIMEOUT_SECONDS;
        }

        public final e getSAMPLING_RATE() {
            return SettingsCache.SAMPLING_RATE;
        }

        public final e getSESSIONS_ENABLED() {
            return SettingsCache.SESSIONS_ENABLED;
        }

        private Companion() {
        }
    }

    /* JADX INFO: renamed from: com.google.firebase.sessions.settings.SettingsCache$updateConfigValue$1, reason: invalid class name and case insensitive filesystem */
    @C4.e(c = "com.google.firebase.sessions.settings.SettingsCache", f = "SettingsCache.kt", l = {119}, m = "updateConfigValue")
    public static final class C12931<T> extends c {
        int label;
        /* synthetic */ Object result;

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

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

    /* JADX INFO: renamed from: com.google.firebase.sessions.settings.SettingsCache$updateConfigValue$2, reason: invalid class name */
    @C4.e(c = "com.google.firebase.sessions.settings.SettingsCache$updateConfigValue$2", f = "SettingsCache.kt", l = {}, m = "invokeSuspend")
    public static final class AnonymousClass2 extends j implements J4.e {
        final /* synthetic */ e $key;
        final /* synthetic */ T $value;
        /* synthetic */ Object L$0;
        int label;
        final /* synthetic */ SettingsCache this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        public AnonymousClass2(T t6, e eVar, SettingsCache settingsCache, d dVar) {
            super(2, dVar);
            this.$value = t6;
            this.$key = eVar;
            this.this$0 = settingsCache;
        }

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            AnonymousClass2 anonymousClass2 = new AnonymousClass2(this.$value, this.$key, this.this$0, dVar);
            anonymousClass2.L$0 = obj;
            return anonymousClass2;
        }

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

        @Override // C4.a
        public final Object invokeSuspend(Object obj) {
            a aVar = a.f492a;
            if (this.label != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            AbstractC2467b.l(obj);
            b bVar = (b) this.L$0;
            Object obj2 = this.$value;
            if (obj2 != null) {
                bVar.d(this.$key, obj2);
            } else {
                e key = this.$key;
                bVar.getClass();
                o.h(key, "key");
                bVar.c();
                bVar.f6135a.remove(key);
            }
            this.this$0.updateSessionConfigs(bVar);
            return C3137A.f25453a;
        }
    }

    public SettingsCache(InterfaceC0569i dataStore) throws Throwable {
        o.h(dataStore, "dataStore");
        this.dataStore = dataStore;
        E.C(k.f106a, new AnonymousClass1(null));
    }

    /* 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 <T> Object updateConfigValue(e eVar, T t6, d dVar) {
        C12931 c12931;
        if (dVar instanceof C12931) {
            c12931 = (C12931) dVar;
            int i6 = c12931.label;
            if ((i6 & Integer.MIN_VALUE) != 0) {
                c12931.label = i6 - Integer.MIN_VALUE;
            } else {
                c12931 = new C12931(dVar);
            }
        }
        Object obj = c12931.result;
        a aVar = a.f492a;
        int i7 = c12931.label;
        try {
            if (i7 == 0) {
                AbstractC2467b.l(obj);
                InterfaceC0569i interfaceC0569i = this.dataStore;
                AnonymousClass2 anonymousClass2 = new AnonymousClass2(t6, eVar, this, null);
                c12931.label = 1;
                if (L4.a.C(interfaceC0569i, anonymousClass2, c12931) == aVar) {
                    return aVar;
                }
            } else {
                if (i7 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                AbstractC2467b.l(obj);
            }
        } catch (IOException e6) {
            Log.w(TAG, "Failed to update cache config value: " + e6);
        }
        return C3137A.f25453a;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void updateSessionConfigs(g gVar) {
        this.sessionConfigs = new SessionConfigs((Boolean) gVar.b(SESSIONS_ENABLED), (Double) gVar.b(SAMPLING_RATE), (Integer) gVar.b(RESTART_TIMEOUT_SECONDS), (Integer) gVar.b(CACHE_DURATION_SECONDS), (Long) gVar.b(CACHE_UPDATED_TIME));
    }

    public final boolean hasCacheExpired$com_google_firebase_firebase_sessions() {
        SessionConfigs sessionConfigs = this.sessionConfigs;
        if (sessionConfigs == null) {
            o.n("sessionConfigs");
            throw null;
        }
        Long cacheUpdatedTime = sessionConfigs.getCacheUpdatedTime();
        SessionConfigs sessionConfigs2 = this.sessionConfigs;
        if (sessionConfigs2 != null) {
            Integer cacheDuration = sessionConfigs2.getCacheDuration();
            return cacheUpdatedTime == null || cacheDuration == null || (System.currentTimeMillis() - cacheUpdatedTime.longValue()) / ((long) 1000) >= ((long) cacheDuration.intValue());
        }
        o.n("sessionConfigs");
        throw null;
    }

    /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final Object removeConfigs$com_google_firebase_firebase_sessions(d dVar) {
        SettingsCache$removeConfigs$1 settingsCache$removeConfigs$1;
        if (dVar instanceof SettingsCache$removeConfigs$1) {
            settingsCache$removeConfigs$1 = (SettingsCache$removeConfigs$1) dVar;
            int i6 = settingsCache$removeConfigs$1.label;
            if ((i6 & Integer.MIN_VALUE) != 0) {
                settingsCache$removeConfigs$1.label = i6 - Integer.MIN_VALUE;
            } else {
                settingsCache$removeConfigs$1 = new SettingsCache$removeConfigs$1(this, dVar);
            }
        }
        Object obj = settingsCache$removeConfigs$1.result;
        a aVar = a.f492a;
        int i7 = settingsCache$removeConfigs$1.label;
        try {
            if (i7 == 0) {
                AbstractC2467b.l(obj);
                InterfaceC0569i interfaceC0569i = this.dataStore;
                SettingsCache$removeConfigs$2 settingsCache$removeConfigs$2 = new SettingsCache$removeConfigs$2(this, null);
                settingsCache$removeConfigs$1.label = 1;
                if (L4.a.C(interfaceC0569i, settingsCache$removeConfigs$2, settingsCache$removeConfigs$1) == aVar) {
                    return aVar;
                }
            } else {
                if (i7 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                AbstractC2467b.l(obj);
            }
        } catch (IOException e6) {
            Log.w(TAG, "Failed to remove config values: " + e6);
        }
        return C3137A.f25453a;
    }

    public final Integer sessionRestartTimeout() {
        SessionConfigs sessionConfigs = this.sessionConfigs;
        if (sessionConfigs != null) {
            return sessionConfigs.getSessionRestartTimeout();
        }
        o.n("sessionConfigs");
        throw null;
    }

    public final Double sessionSamplingRate() {
        SessionConfigs sessionConfigs = this.sessionConfigs;
        if (sessionConfigs != null) {
            return sessionConfigs.getSessionSamplingRate();
        }
        o.n("sessionConfigs");
        throw null;
    }

    public final Boolean sessionsEnabled() {
        SessionConfigs sessionConfigs = this.sessionConfigs;
        if (sessionConfigs != null) {
            return sessionConfigs.getSessionEnabled();
        }
        o.n("sessionConfigs");
        throw null;
    }

    public final Object updateSamplingRate(Double d6, d dVar) {
        Object objUpdateConfigValue = updateConfigValue(SAMPLING_RATE, d6, dVar);
        return objUpdateConfigValue == a.f492a ? objUpdateConfigValue : C3137A.f25453a;
    }

    public final Object updateSessionCacheDuration(Integer num, d dVar) {
        Object objUpdateConfigValue = updateConfigValue(CACHE_DURATION_SECONDS, num, dVar);
        return objUpdateConfigValue == a.f492a ? objUpdateConfigValue : C3137A.f25453a;
    }

    public final Object updateSessionCacheUpdatedTime(Long l, d dVar) {
        Object objUpdateConfigValue = updateConfigValue(CACHE_UPDATED_TIME, l, dVar);
        return objUpdateConfigValue == a.f492a ? objUpdateConfigValue : C3137A.f25453a;
    }

    public final Object updateSessionRestartTimeout(Integer num, d dVar) {
        Object objUpdateConfigValue = updateConfigValue(RESTART_TIMEOUT_SECONDS, num, dVar);
        return objUpdateConfigValue == a.f492a ? objUpdateConfigValue : C3137A.f25453a;
    }

    public final Object updateSettingsEnabled(Boolean bool, d dVar) {
        Object objUpdateConfigValue = updateConfigValue(SESSIONS_ENABLED, bool, dVar);
        return objUpdateConfigValue == a.f492a ? objUpdateConfigValue : C3137A.f25453a;
    }
}