package com.google.firebase.sessions;

import android.app.Service;
import android.content.Intent;
import android.os.Build;
import android.os.Bundle;
import android.os.DeadObjectException;
import android.os.Handler;
import android.os.HandlerThread;
import android.os.IBinder;
import android.os.Looper;
import android.os.Message;
import android.os.Messenger;
import android.util.Log;
import androidx.media3.container.NalUnitUtil;
import androidx.media3.exoplayer.upstream.CmcdData;
import com.google.firebase.sessions.d;
import defpackage.cr4;
import defpackage.gk8;
import defpackage.nl8;
import defpackage.pg2;
import defpackage.rk8;
import defpackage.tg2;
import defpackage.vx8;
import defpackage.xg2;
import defpackage.y03;
import java.util.ArrayList;
import java.util.Objects;
import kotlin.Metadata;

/* JADX INFO: loaded from: classes2.dex */
@Metadata(d1 = {"\u0000\f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0005\b\u0000\u0018\u00002\u00020\u0001:\u0002\u0004\u0005B\u0007¢\u0006\u0004\b\u0002\u0010\u0003¨\u0006\u0006"}, d2 = {"Lcom/google/firebase/sessions/SessionLifecycleService;", "Landroid/app/Service;", "<init>", "()V", CmcdData.OBJECT_TYPE_AUDIO_ONLY, "b", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
public final class SessionLifecycleService extends Service {
    public final HandlerThread a = new HandlerThread("FirebaseSessions_HandlerThread");
    public b b;
    public Messenger c;

    @Metadata(d1 = {"\u0000\u0018\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\b\n\u0002\b\u0003\n\u0002\u0010\u000e\n\u0002\b\u0007\b\u0080\u0003\u0018\u00002\u00020\u0001R\u0014\u0010\u0003\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u0003\u0010\u0004R\u0014\u0010\u0005\u001a\u00020\u00028\u0002X\u0082T¢\u0006\u0006\n\u0004\b\u0005\u0010\u0004R\u0014\u0010\u0007\u001a\u00020\u00068\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u0007\u0010\bR\u0014\u0010\t\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\t\u0010\u0004R\u0014\u0010\n\u001a\u00020\u00028\u0006X\u0086T¢\u0006\u0006\n\u0004\b\n\u0010\u0004R\u0014\u0010\u000b\u001a\u00020\u00068\u0006X\u0086T¢\u0006\u0006\n\u0004\b\u000b\u0010\bR\u0014\u0010\f\u001a\u00020\u00068\u0006X\u0086T¢\u0006\u0006\n\u0004\b\f\u0010\b¨\u0006\r"}, d2 = {"Lcom/google/firebase/sessions/SessionLifecycleService$a;", "", "", "BACKGROUNDED", "I", "CLIENT_BOUND", "", "CLIENT_CALLBACK_MESSENGER", "Ljava/lang/String;", "FOREGROUNDED", "SESSION_UPDATED", "SESSION_UPDATE_EXTRA", "TAG", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    public static final class a {
    }

    @Metadata(d1 = {"\u0000\n\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000\b\u0000\u0018\u00002\u00020\u0001¨\u0006\u0002"}, d2 = {"Lcom/google/firebase/sessions/SessionLifecycleService$b;", "Landroid/os/Handler;", "com.google.firebase-firebase-sessions"}, k = 1, mv = {1, 8, 0}, xi = NalUnitUtil.H265_NAL_UNIT_TYPE_UNSPECIFIED)
    @vx8
    public static final class b extends Handler {
        public boolean a;
        public long b;
        public final ArrayList c;

        public b(Looper looper) {
            super(looper);
            this.c = new ArrayList();
        }

        public final void a(Messenger messenger) {
            if (this.a) {
                rk8 rk8Var = d.a.a().e;
                if (rk8Var != null) {
                    c(messenger, rk8Var.a);
                    return;
                } else {
                    cr4.n("currentSession");
                    throw null;
                }
            }
            Object objB = y03.c().b(com.google.firebase.sessions.a.class);
            cr4.f(objB, "Firebase.app[SessionDatastore::class.java]");
            String strA = ((com.google.firebase.sessions.a) objB).a();
            if (strA != null) {
                c(messenger, strA);
            }
        }

        public final void b() {
            d dVarA = d.a.a();
            int i = dVarA.d + 1;
            dVarA.d = i;
            String strA = i == 0 ? dVarA.c : dVarA.a();
            String str = dVarA.c;
            int i2 = dVarA.d;
            dVarA.a.getClass();
            dVarA.e = new rk8(i2, System.currentTimeMillis() * 1000, strA, str);
            Object objB = y03.c().b(com.google.firebase.sessions.b.class);
            cr4.f(objB, "Firebase.app[SessionFirelogPublisher::class.java]");
            com.google.firebase.sessions.b bVar = (com.google.firebase.sessions.b) objB;
            rk8 rk8Var = d.a.a().e;
            if (rk8Var == null) {
                cr4.n("currentSession");
                throw null;
            }
            bVar.a(rk8Var);
            for (Messenger messenger : new ArrayList(this.c)) {
                cr4.f(messenger, "it");
                a(messenger);
            }
            Object objB2 = y03.c().b(com.google.firebase.sessions.a.class);
            cr4.f(objB2, "Firebase.app[SessionDatastore::class.java]");
            com.google.firebase.sessions.a aVar = (com.google.firebase.sessions.a) objB2;
            rk8 rk8Var2 = d.a.a().e;
            if (rk8Var2 == null) {
                cr4.n("currentSession");
                throw null;
            }
            aVar.b(rk8Var2.a);
        }

        public final void c(Messenger messenger, String str) {
            try {
                Bundle bundle = new Bundle();
                bundle.putString("SessionUpdateExtra", str);
                Message messageObtain = Message.obtain(null, 3, 0, 0);
                messageObtain.setData(bundle);
                messenger.send(messageObtain);
            } catch (DeadObjectException unused) {
                Objects.toString(messenger);
                this.c.remove(messenger);
            } catch (Exception e) {
                Log.w("SessionLifecycleService", "Unable to push new session to " + messenger + '.', e);
            }
        }

        /* JADX WARN: Removed duplicated region for block: B:32:0x00b8  */
        /* JADX WARN: Removed duplicated region for block: B:43:0x00e9  */
        @Override // android.os.Handler
        /*
            Code decompiled incorrectly, please refer to instructions dump.
        */
        public final void handleMessage(Message message) {
            cr4.g(message, "msg");
            if (this.b > message.getWhen()) {
                message.getWhen();
                return;
            }
            int i = message.what;
            if (i != 1) {
                if (i == 2) {
                    message.getWhen();
                    this.b = message.getWhen();
                    return;
                }
                if (i != 4) {
                    Log.w("SessionLifecycleService", "Received unexpected event from the SessionLifecycleClient: " + message);
                    super.handleMessage(message);
                    return;
                }
                Messenger messenger = message.replyTo;
                ArrayList arrayList = this.c;
                arrayList.add(messenger);
                Messenger messenger2 = message.replyTo;
                cr4.f(messenger2, "msg.replyTo");
                a(messenger2);
                Objects.toString(message.replyTo);
                message.getWhen();
                arrayList.size();
                return;
            }
            message.getWhen();
            if (this.a) {
                long when = message.getWhen() - this.b;
                nl8.c.getClass();
                Object objB = y03.c().b(nl8.class);
                cr4.f(objB, "Firebase.app[SessionsSettings::class.java]");
                nl8 nl8Var = (nl8) objB;
                Bundle bundle = nl8Var.a.a;
                pg2 pg2Var = null;
                pg2 pg2Var2 = bundle.containsKey("firebase_sessions_sessions_restart_timeout") ? new pg2(tg2.g(bundle.getInt("firebase_sessions_sessions_restart_timeout"), xg2.e)) : null;
                if (pg2Var2 != null) {
                    long jG = pg2Var2.a;
                    int i2 = pg2.d;
                    if (jG <= 0 || pg2.f(jG)) {
                        gk8 gk8Var = nl8Var.b.b().b;
                        if (gk8Var == null) {
                            cr4.n("sessionConfigs");
                            throw null;
                        }
                        Integer num = gk8Var.c;
                        if (num != null) {
                            int i3 = pg2.d;
                            pg2Var = new pg2(tg2.g(num.intValue(), xg2.e));
                        }
                        if (pg2Var != null) {
                            jG = pg2Var.a;
                            int i4 = pg2.d;
                            if (jG <= 0 || pg2.f(jG)) {
                                int i5 = pg2.d;
                                jG = tg2.g(30, xg2.f);
                            }
                        }
                    }
                    if (when > pg2.d(jG)) {
                        b();
                    }
                }
            } else {
                this.a = true;
                b();
            }
            this.b = message.getWhen();
        }
    }

    @Override // android.app.Service
    public final IBinder onBind(Intent intent) {
        if (intent != null) {
            intent.getAction();
            Messenger messenger = Build.VERSION.SDK_INT >= 33 ? (Messenger) intent.getParcelableExtra("ClientCallbackMessenger", Messenger.class) : (Messenger) intent.getParcelableExtra("ClientCallbackMessenger");
            if (messenger != null) {
                Message messageObtain = Message.obtain(null, 4, 0, 0);
                messageObtain.replyTo = messenger;
                b bVar = this.b;
                if (bVar != null) {
                    bVar.sendMessage(messageObtain);
                }
            }
            Messenger messenger2 = this.c;
            if (messenger2 != null) {
                return messenger2.getBinder();
            }
        }
        return null;
    }

    @Override // android.app.Service
    public final void onCreate() {
        super.onCreate();
        HandlerThread handlerThread = this.a;
        handlerThread.start();
        Looper looper = handlerThread.getLooper();
        cr4.f(looper, "handlerThread.looper");
        this.b = new b(looper);
        this.c = new Messenger(this.b);
    }

    @Override // android.app.Service
    public final void onDestroy() {
        super.onDestroy();
        this.a.quit();
    }
}