package com.google.firebase.sessions;

import A4.d;
import A4.j;
import C0.B;
import C4.c;
import C4.e;
import O1.InterfaceC0569i;
import Q4.m;
import S1.g;
import V4.C;
import V4.E;
import Y4.C0851q;
import Y4.InterfaceC0843i;
import Y4.InterfaceC0844j;
import android.content.Context;
import android.util.Log;
import androidx.media3.extractor.ts.TsExtractor;
import java.io.IOException;
import java.util.concurrent.atomic.AtomicReference;
import kotlin.jvm.internal.D;
import kotlin.jvm.internal.h;
import kotlin.jvm.internal.o;
import kotlin.jvm.internal.w;
import m3.AbstractC2467b;
import w4.C3137A;

/* JADX INFO: loaded from: classes3.dex */
public final class SessionDatastoreImpl implements SessionDatastore {
    private static final String TAG = "FirebaseSessionsRepo";
    private final j backgroundDispatcher;
    private final Context context;
    private final AtomicReference<FirebaseSessionsData> currentSessionFromDatastore;
    private final InterfaceC0843i firebaseSessionDataFlow;
    private static final Companion Companion = new Companion(null);
    private static final M4.a dataStore$delegate = android.support.v4.media.session.b.D(SessionDataStoreConfigs.INSTANCE.getSESSIONS_CONFIG_NAME(), new B(SessionDatastoreImpl$Companion$dataStore$2.INSTANCE), 12);

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

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

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            return SessionDatastoreImpl.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) {
            B4.a aVar = B4.a.f492a;
            int i6 = this.label;
            if (i6 == 0) {
                AbstractC2467b.l(obj);
                InterfaceC0843i interfaceC0843i = SessionDatastoreImpl.this.firebaseSessionDataFlow;
                final SessionDatastoreImpl sessionDatastoreImpl = SessionDatastoreImpl.this;
                InterfaceC0844j interfaceC0844j = new InterfaceC0844j() { // from class: com.google.firebase.sessions.SessionDatastoreImpl.1.1
                    @Override // Y4.InterfaceC0844j
                    public final Object emit(FirebaseSessionsData firebaseSessionsData, d dVar) {
                        sessionDatastoreImpl.currentSessionFromDatastore.set(firebaseSessionsData);
                        return C3137A.f25453a;
                    }
                };
                this.label = 1;
                if (interfaceC0843i.collect(interfaceC0844j, this) == aVar) {
                    return aVar;
                }
            } else {
                if (i6 != 1) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                AbstractC2467b.l(obj);
            }
            return C3137A.f25453a;
        }
    }

    public static final class Companion {
        static final /* synthetic */ m[] $$delegatedProperties;

        static {
            w wVar = new w(Companion.class);
            D.f20116a.getClass();
            $$delegatedProperties = new m[]{wVar};
        }

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

        /* JADX INFO: Access modifiers changed from: private */
        public final InterfaceC0569i getDataStore(Context context) {
            return (InterfaceC0569i) SessionDatastoreImpl.dataStore$delegate.a(context, $$delegatedProperties[0]);
        }

        private Companion() {
        }
    }

    public static final class FirebaseSessionDataKeys {
        public static final FirebaseSessionDataKeys INSTANCE = new FirebaseSessionDataKeys();
        private static final S1.e SESSION_ID = new S1.e("session_id");

        private FirebaseSessionDataKeys() {
        }

        public final S1.e getSESSION_ID() {
            return SESSION_ID;
        }
    }

    /* JADX INFO: renamed from: com.google.firebase.sessions.SessionDatastoreImpl$updateSessionId$1, reason: invalid class name and case insensitive filesystem */
    @e(c = "com.google.firebase.sessions.SessionDatastoreImpl$updateSessionId$1", f = "SessionDatastore.kt", l = {TsExtractor.TS_STREAM_TYPE_DVBSUBS}, m = "invokeSuspend")
    public static final class C12911 extends C4.j implements J4.e {
        final /* synthetic */ String $sessionId;
        int label;

        /* JADX INFO: renamed from: com.google.firebase.sessions.SessionDatastoreImpl$updateSessionId$1$1, reason: invalid class name and collision with other inner class name */
        @e(c = "com.google.firebase.sessions.SessionDatastoreImpl$updateSessionId$1$1", f = "SessionDatastore.kt", l = {}, m = "invokeSuspend")
        public static final class C00071 extends C4.j implements J4.e {
            final /* synthetic */ String $sessionId;
            /* synthetic */ Object L$0;
            int label;

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

            @Override // C4.a
            public final d create(Object obj, d dVar) {
                C00071 c00071 = new C00071(this.$sessionId, dVar);
                c00071.L$0 = obj;
                return c00071;
            }

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

            @Override // C4.a
            public final Object invokeSuspend(Object obj) {
                B4.a aVar = B4.a.f492a;
                if (this.label != 0) {
                    throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                }
                AbstractC2467b.l(obj);
                ((S1.b) this.L$0).d(FirebaseSessionDataKeys.INSTANCE.getSESSION_ID(), this.$sessionId);
                return C3137A.f25453a;
            }
        }

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

        @Override // C4.a
        public final d create(Object obj, d dVar) {
            return SessionDatastoreImpl.this.new C12911(this.$sessionId, dVar);
        }

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

        @Override // C4.a
        public final Object invokeSuspend(Object obj) {
            B4.a aVar = B4.a.f492a;
            int i6 = this.label;
            try {
                if (i6 == 0) {
                    AbstractC2467b.l(obj);
                    InterfaceC0569i dataStore = SessionDatastoreImpl.Companion.getDataStore(SessionDatastoreImpl.this.context);
                    C00071 c00071 = new C00071(this.$sessionId, null);
                    this.label = 1;
                    if (L4.a.C(dataStore, c00071, this) == aVar) {
                        return aVar;
                    }
                } else {
                    if (i6 != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    AbstractC2467b.l(obj);
                }
            } catch (IOException e6) {
                Log.w(SessionDatastoreImpl.TAG, "Failed to update session Id: " + e6);
            }
            return C3137A.f25453a;
        }
    }

    public SessionDatastoreImpl(Context context, j backgroundDispatcher) {
        o.h(context, "context");
        o.h(backgroundDispatcher, "backgroundDispatcher");
        this.context = context;
        this.backgroundDispatcher = backgroundDispatcher;
        this.currentSessionFromDatastore = new AtomicReference<>();
        final C0851q c0851q = new C0851q(Companion.getDataStore(context).getData(), new SessionDatastoreImpl$firebaseSessionDataFlow$1(null), 1);
        this.firebaseSessionDataFlow = new InterfaceC0843i() { // from class: com.google.firebase.sessions.SessionDatastoreImpl$special$$inlined$map$1

            /* JADX INFO: renamed from: com.google.firebase.sessions.SessionDatastoreImpl$special$$inlined$map$1$2, reason: invalid class name */
            public static final class AnonymousClass2<T> implements InterfaceC0844j {
                final /* synthetic */ InterfaceC0844j $this_unsafeFlow;
                final /* synthetic */ SessionDatastoreImpl this$0;

                /* JADX INFO: renamed from: com.google.firebase.sessions.SessionDatastoreImpl$special$$inlined$map$1$2$1, reason: invalid class name */
                @e(c = "com.google.firebase.sessions.SessionDatastoreImpl$special$$inlined$map$1$2", f = "SessionDatastore.kt", l = {223}, m = "emit")
                public static final class AnonymousClass1 extends c {
                    Object L$0;
                    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 AnonymousClass2.this.emit(null, this);
                    }
                }

                public AnonymousClass2(InterfaceC0844j interfaceC0844j, SessionDatastoreImpl sessionDatastoreImpl) {
                    this.$this_unsafeFlow = interfaceC0844j;
                    this.this$0 = sessionDatastoreImpl;
                }

                /* JADX WARN: Removed duplicated region for block: B:7:0x0013  */
                @Override // Y4.InterfaceC0844j
                /*
                    Code decompiled incorrectly, please refer to instructions dump.
                */
                public final Object emit(Object obj, d dVar) {
                    AnonymousClass1 anonymousClass1;
                    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 obj2 = anonymousClass1.result;
                    B4.a aVar = B4.a.f492a;
                    int i7 = anonymousClass1.label;
                    if (i7 == 0) {
                        AbstractC2467b.l(obj2);
                        InterfaceC0844j interfaceC0844j = this.$this_unsafeFlow;
                        FirebaseSessionsData firebaseSessionsDataMapSessionsData = this.this$0.mapSessionsData((g) obj);
                        anonymousClass1.label = 1;
                        if (interfaceC0844j.emit(firebaseSessionsDataMapSessionsData, anonymousClass1) == aVar) {
                            return aVar;
                        }
                    } else {
                        if (i7 != 1) {
                            throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                        }
                        AbstractC2467b.l(obj2);
                    }
                    return C3137A.f25453a;
                }
            }

            @Override // Y4.InterfaceC0843i
            public Object collect(InterfaceC0844j interfaceC0844j, d dVar) {
                Object objCollect = c0851q.collect(new AnonymousClass2(interfaceC0844j, this), dVar);
                return objCollect == B4.a.f492a ? objCollect : C3137A.f25453a;
            }
        };
        E.y(E.c(backgroundDispatcher), null, null, new AnonymousClass1(null), 3);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final FirebaseSessionsData mapSessionsData(g gVar) {
        return new FirebaseSessionsData((String) gVar.b(FirebaseSessionDataKeys.INSTANCE.getSESSION_ID()));
    }

    @Override // com.google.firebase.sessions.SessionDatastore
    public String getCurrentSessionId() {
        FirebaseSessionsData firebaseSessionsData = this.currentSessionFromDatastore.get();
        if (firebaseSessionsData != null) {
            return firebaseSessionsData.getSessionId();
        }
        return null;
    }

    @Override // com.google.firebase.sessions.SessionDatastore
    public void updateSessionId(String sessionId) {
        o.h(sessionId, "sessionId");
        E.y(E.c(this.backgroundDispatcher), null, null, new C12911(sessionId, null), 3);
    }
}