package com.google.firebase.messaging;

import L1.Y0;
import a3.InterfaceC0232d;
import android.app.Application;
import android.app.NotificationManager;
import android.app.PendingIntent;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.os.Binder;
import android.os.Build;
import android.os.Bundle;
import android.text.TextUtils;
import android.util.Log;
import androidx.annotation.Keep;
import com.google.android.gms.internal.measurement.AbstractC0366e2;
import com.google.android.gms.internal.measurement.C1;
import e4.AbstractC0566j;
import java.io.IOException;
import java.lang.ref.WeakReference;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import o1.C0925b;
import r.C0966e;
import x1.ThreadFactoryC1100a;
import y1.AbstractC1111a;

/* JADX INFO: loaded from: classes.dex */
public class FirebaseMessaging {

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public static S.g f5845l;

    /* JADX INFO: renamed from: n, reason: collision with root package name */
    public static ScheduledThreadPoolExecutor f5847n;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final I2.g f5848a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final Context f5849b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final A2.p f5850c;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final k f5851d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final O4.c f5852e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final ScheduledThreadPoolExecutor f5853f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final ThreadPoolExecutor f5854g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final P1.o f5855h;
    public final V1.f i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    public boolean f5856j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public static final long f5844k = TimeUnit.HOURS.toSeconds(8);

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public static Z2.a f5846m = new N2.g(6);

    public FirebaseMessaging(I2.g gVar, Z2.a aVar, Z2.a aVar2, InterfaceC0232d interfaceC0232d, Z2.a aVar3, W2.d dVar) {
        final int i = 1;
        final int i5 = 0;
        gVar.a();
        Context context = gVar.f932a;
        final V1.f fVar = new V1.f();
        fVar.f2985b = 0;
        fVar.f2986c = context;
        gVar.a();
        C0925b c0925b = new C0925b(gVar.f932a);
        final A2.p pVar = new A2.p();
        pVar.f48a = gVar;
        pVar.f49b = fVar;
        pVar.f50c = c0925b;
        pVar.f51d = aVar;
        pVar.f52e = aVar2;
        pVar.f53f = interfaceC0232d;
        ExecutorService executorServiceNewSingleThreadExecutor = Executors.newSingleThreadExecutor(new ThreadFactoryC1100a("Firebase-Messaging-Task"));
        ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1, new ThreadFactoryC1100a("Firebase-Messaging-Init"));
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(0, 1, 30L, TimeUnit.SECONDS, new LinkedBlockingQueue(), new ThreadFactoryC1100a("Firebase-Messaging-File-Io"));
        this.f5856j = false;
        f5846m = aVar3;
        this.f5848a = gVar;
        this.f5852e = new O4.c(this, dVar);
        gVar.a();
        final Context context2 = gVar.f932a;
        this.f5849b = context2;
        Y0 y02 = new Y0();
        this.i = fVar;
        this.f5850c = pVar;
        this.f5851d = new k(executorServiceNewSingleThreadExecutor);
        this.f5853f = scheduledThreadPoolExecutor;
        this.f5854g = threadPoolExecutor;
        gVar.a();
        if (context instanceof Application) {
            ((Application) context).registerActivityLifecycleCallbacks(y02);
        } else {
            Log.w("FirebaseMessaging", "Context " + context + " was not an application, can't register for lifecycle callbacks. Some notification events may be dropped as a result.");
        }
        scheduledThreadPoolExecutor.execute(new Runnable(this) { // from class: com.google.firebase.messaging.n

            /* JADX INFO: renamed from: l, reason: collision with root package name */
            public final /* synthetic */ FirebaseMessaging f5909l;

            {
                this.f5909l = this;
            }

            @Override // java.lang.Runnable
            public final void run() {
                switch (i5) {
                    case 0:
                        FirebaseMessaging firebaseMessaging = this.f5909l;
                        if (firebaseMessaging.f5852e.b()) {
                            firebaseMessaging.k();
                        }
                        break;
                    default:
                        FirebaseMessaging firebaseMessaging2 = this.f5909l;
                        Context context3 = firebaseMessaging2.f5849b;
                        AbstractC0566j.o(context3);
                        AbstractC1111a.m(context3, firebaseMessaging2.f5850c, firebaseMessaging2.j());
                        if (firebaseMessaging2.j()) {
                            firebaseMessaging2.g();
                        }
                        break;
                }
            }
        });
        final ScheduledThreadPoolExecutor scheduledThreadPoolExecutor2 = new ScheduledThreadPoolExecutor(1, new ThreadFactoryC1100a("Firebase-Messaging-Topics-Io"));
        int i6 = D.f5827j;
        P1.o oVarC = C1.c(scheduledThreadPoolExecutor2, new Callable() { // from class: com.google.firebase.messaging.C
            @Override // java.util.concurrent.Callable
            public final Object call() {
                B b2;
                Context context3 = context2;
                ScheduledThreadPoolExecutor scheduledThreadPoolExecutor3 = scheduledThreadPoolExecutor2;
                FirebaseMessaging firebaseMessaging = this;
                V1.f fVar2 = fVar;
                A2.p pVar2 = pVar;
                synchronized (B.class) {
                    try {
                        WeakReference weakReference = B.f5820b;
                        b2 = weakReference != null ? (B) weakReference.get() : null;
                        if (b2 == null) {
                            SharedPreferences sharedPreferences = context3.getSharedPreferences("com.google.android.gms.appid", 0);
                            B b4 = new B();
                            synchronized (b4) {
                                b4.f5821a = F3.e.e(sharedPreferences, scheduledThreadPoolExecutor3);
                            }
                            B.f5820b = new WeakReference(b4);
                            b2 = b4;
                        }
                    } catch (Throwable th) {
                        throw th;
                    }
                }
                return new D(firebaseMessaging, fVar2, b2, pVar2, context3, scheduledThreadPoolExecutor3);
            }
        });
        this.f5855h = oVarC;
        oVarC.d(scheduledThreadPoolExecutor, new o(this, i5));
        scheduledThreadPoolExecutor.execute(new Runnable(this) { // from class: com.google.firebase.messaging.n

            /* JADX INFO: renamed from: l, reason: collision with root package name */
            public final /* synthetic */ FirebaseMessaging f5909l;

            {
                this.f5909l = this;
            }

            @Override // java.lang.Runnable
            public final void run() {
                switch (i) {
                    case 0:
                        FirebaseMessaging firebaseMessaging = this.f5909l;
                        if (firebaseMessaging.f5852e.b()) {
                            firebaseMessaging.k();
                        }
                        break;
                    default:
                        FirebaseMessaging firebaseMessaging2 = this.f5909l;
                        Context context3 = firebaseMessaging2.f5849b;
                        AbstractC0566j.o(context3);
                        AbstractC1111a.m(context3, firebaseMessaging2.f5850c, firebaseMessaging2.j());
                        if (firebaseMessaging2.j()) {
                            firebaseMessaging2.g();
                        }
                        break;
                }
            }
        });
    }

    public static void b(Runnable runnable, long j5) {
        synchronized (FirebaseMessaging.class) {
            try {
                if (f5847n == null) {
                    f5847n = new ScheduledThreadPoolExecutor(1, new ThreadFactoryC1100a("TAG"));
                }
                f5847n.schedule(runnable, j5, TimeUnit.SECONDS);
            } catch (Throwable th) {
                throw th;
            }
        }
    }

    public static synchronized FirebaseMessaging c() {
        return getInstance(I2.g.d());
    }

    public static synchronized S.g d(Context context) {
        try {
            if (f5845l == null) {
                f5845l = new S.g(context);
            }
        } catch (Throwable th) {
            throw th;
        }
        return f5845l;
    }

    @Keep
    public static synchronized FirebaseMessaging getInstance(I2.g gVar) {
        FirebaseMessaging firebaseMessaging;
        gVar.a();
        firebaseMessaging = (FirebaseMessaging) gVar.f935d.get(FirebaseMessaging.class);
        s1.z.h("Firebase Messaging component is not present", firebaseMessaging);
        return firebaseMessaging;
    }

    public final String a() throws IOException {
        P1.h hVarJ;
        x xVarF = f();
        if (!m(xVarF)) {
            return xVarF.f5948a;
        }
        String strB = V1.f.b(this.f5848a);
        k kVar = this.f5851d;
        synchronized (kVar) {
            hVarJ = (P1.h) ((C0966e) kVar.f5902b).get(strB);
            if (hVarJ == null) {
                if (Log.isLoggable("FirebaseMessaging", 3)) {
                    Log.d("FirebaseMessaging", "Making new request for: " + strB);
                }
                A2.p pVar = this.f5850c;
                hVarJ = pVar.k(pVar.p(V1.f.b((I2.g) pVar.f48a), "*", new Bundle())).k(this.f5854g, new p(this, strB, xVarF, 0)).j((ExecutorService) kVar.f5901a, new C0503g(1, kVar, strB));
                ((C0966e) kVar.f5902b).put(strB, hVarJ);
            } else if (Log.isLoggable("FirebaseMessaging", 3)) {
                Log.d("FirebaseMessaging", "Joining ongoing request for: " + strB);
            }
        }
        try {
            return (String) C1.a(hVarJ);
        } catch (InterruptedException | ExecutionException e2) {
            throw new IOException(e2);
        }
    }

    public final String e() {
        I2.g gVar = this.f5848a;
        gVar.a();
        return "[DEFAULT]".equals(gVar.f933b) ? "" : gVar.f();
    }

    public final x f() {
        x xVarB;
        S.g gVarD = d(this.f5849b);
        String strE = e();
        String strB = V1.f.b(this.f5848a);
        synchronized (gVarD) {
            xVarB = x.b(((SharedPreferences) gVarD.f2797k).getString(S.g.B(strE, strB), null));
        }
        return xVarB;
    }

    public final void g() {
        P1.o oVarK;
        int i;
        C0925b c0925b = (C0925b) this.f5850c.f50c;
        if (c0925b.f9384c.a() >= 241100000) {
            o1.m mVarB = o1.m.b(c0925b.f9383b);
            Bundle bundle = Bundle.EMPTY;
            synchronized (mVarB) {
                i = mVarB.f9416k;
                mVarB.f9416k = i + 1;
            }
            oVarK = mVarB.c(new o1.l(i, 5, bundle, 1)).i(o1.h.f9397m, o1.d.f9391m);
        } else {
            oVarK = C1.k(new IOException("SERVICE_NOT_AVAILABLE"));
        }
        oVarK.d(this.f5853f, new o(this, 1));
    }

    public final void h(v vVar) {
        if (TextUtils.isEmpty(vVar.f5939k.getString("google.to"))) {
            throw new IllegalArgumentException("Missing 'to'");
        }
        Intent intent = new Intent("com.google.android.gcm.intent.SEND");
        Intent intent2 = new Intent();
        intent2.setPackage("com.google.example.invalidpackage");
        Context context = this.f5849b;
        intent.putExtra("app", PendingIntent.getBroadcast(context, 0, intent2, 67108864));
        intent.setPackage("com.google.android.gms");
        intent.putExtras(vVar.f5939k);
        context.sendOrderedBroadcast(intent, "com.google.android.gtalkservice.permission.GTALK_SERVICE");
    }

    public final void i(boolean z5) {
        O4.c cVar = this.f5852e;
        synchronized (cVar) {
            cVar.a();
            q qVar = (q) cVar.f2321c;
            if (qVar != null) {
                ((N2.m) ((W2.d) cVar.f2320b)).c(qVar);
                cVar.f2321c = null;
            }
            I2.g gVar = ((FirebaseMessaging) cVar.f2323e).f5848a;
            gVar.a();
            SharedPreferences.Editor editorEdit = gVar.f932a.getSharedPreferences("com.google.firebase.messaging", 0).edit();
            editorEdit.putBoolean("auto_init", z5);
            editorEdit.apply();
            if (z5) {
                ((FirebaseMessaging) cVar.f2323e).k();
            }
            cVar.f2322d = Boolean.valueOf(z5);
        }
    }

    public final boolean j() {
        Context context = this.f5849b;
        AbstractC0566j.o(context);
        if (Build.VERSION.SDK_INT >= 29) {
            if (!(Binder.getCallingUid() == context.getApplicationInfo().uid)) {
                Log.e("FirebaseMessaging", "error retrieving notification delegate for package " + context.getPackageName());
                return false;
            }
            if ("com.google.android.gms".equals(((NotificationManager) context.getSystemService(NotificationManager.class)).getNotificationDelegate())) {
                if (Log.isLoggable("FirebaseMessaging", 3)) {
                    Log.d("FirebaseMessaging", "GMS core is set for proxying");
                }
                I2.g gVar = this.f5848a;
                gVar.a();
                if (gVar.f935d.get(K2.a.class) != null || (AbstractC0366e2.h() && f5846m != null)) {
                    return true;
                }
            }
        } else if (Log.isLoggable("FirebaseMessaging", 3)) {
            Log.d("FirebaseMessaging", "Platform doesn't support proxying.");
            return false;
        }
        return false;
    }

    public final void k() {
        if (m(f())) {
            synchronized (this) {
                if (!this.f5856j) {
                    l(0L);
                }
            }
        }
    }

    public final synchronized void l(long j5) {
        b(new z(this, Math.min(Math.max(30L, 2 * j5), f5844k)), j5);
        this.f5856j = true;
    }

    public final boolean m(x xVar) {
        if (xVar != null) {
            return System.currentTimeMillis() > xVar.f5950c + x.f5947d || !this.i.a().equals(xVar.f5949b);
        }
        return true;
    }
}