package defpackage;

import android.content.Context;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import defpackage.kg7;
import java.util.concurrent.atomic.AtomicReference;
import kotlin.Metadata;
import kotlin.reflect.KProperty;

/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\b\u0000\u0018\u00002\u00020\u0001:\u0002\u0002\u0003¨\u0006\u0004"}, d2 = {"Lkk8;", "Lcom/google/firebase/sessions/a;", "b", "c", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
@vx8
public final class kk8 implements com.google.firebase.sessions.a {
    public static final b e = new b();
    public static final ig7 f = dg7.a(hk8.a, new cz7(a.a));
    public final Context a;
    public final gj1 b;
    public final AtomicReference c = new AtomicReference();
    public final ok8 d;

    @Metadata(d1 = {"\u0000\u000e\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0003\u0010\u0005\u001a\u00020\u00022\u0006\u0010\u0001\u001a\u00020\u0000H\n¢\u0006\u0004\b\u0003\u0010\u0004"}, d2 = {"Lqk1;", "ex", "Lkg7;", "invoke", "(Lqk1;)Lkg7;", "<anonymous>"}, k = 3, mv = {1, 8, 0})
    public static final class a extends u55 implements sq3<qk1, kg7> {
        public static final a a = new a(1);

        @Override // defpackage.sq3
        public final Object invoke(Object obj) {
            qk1 qk1Var = (qk1) obj;
            cr4.g(qk1Var, "ex");
            Log.w("FirebaseSessionsRepo", "CorruptionException in sessions DataStore in " + oi7.b() + '.', qk1Var);
            return new lf6(true);
        }
    }

    @Metadata(d1 = {"\u0000\u0010\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u000e\n\u0002\b\u0003\b\u0082\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004¨\u0006\u0005"}, d2 = {"Lkk8$b;", "", "", "TAG", "Ljava/lang/String;", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class b {
        public static final /* synthetic */ KProperty[] a = {iw7.a.property2(new jk7(b.class))};
    }

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\bÂ\u0002\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lkk8$c;", "", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class c {
        public static final kg7.a a = new kg7.a("session_id");
    }

    public kk8(Context context, gj1 gj1Var) {
        this.a = context;
        this.b = gj1Var;
        e.getClass();
        this.d = new ok8(new k93(((br1) f.getValue(context, b.a[0])).getD(), new lk8(3, null)), this);
        wj0.c(bk1.a(gj1Var), null, null, new jk8(this, null), 3);
    }

    @Override // com.google.firebase.sessions.a
    public final String a() {
        x13 x13Var = (x13) this.c.get();
        if (x13Var != null) {
            return x13Var.a;
        }
        return null;
    }

    @Override // com.google.firebase.sessions.a
    public final void b(String str) {
        cr4.g(str, "sessionId");
        wj0.c(bk1.a(this.b), null, null, new qk8(this, str, null), 3);
    }
}
