package com.google.firebase.messaging;

import android.app.Application;
import android.content.Context;
import android.content.Intent;
import android.content.SharedPreferences;
import android.content.pm.ApplicationInfo;
import android.content.pm.PackageManager;
import android.os.Bundle;
import android.util.Log;
import androidx.annotation.Keep;
import com.google.android.gms.ads.RequestConfiguration;
import com.google.android.gms.common.internal.Preconditions;
import com.google.android.gms.common.util.concurrent.NamedThreadFactory;
import com.google.android.gms.tasks.OnSuccessListener;
import com.google.android.gms.tasks.SuccessContinuation;
import com.google.android.gms.tasks.Task;
import com.google.android.gms.tasks.Tasks;
import com.google.firebase.messaging.FirebaseMessaging;
import com.google.firebase.messaging.r0;
import com.google.firebase.messaging.w0;
import java.io.IOException;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executor;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import n4.a;

/* loaded from: classes2.dex */
public class FirebaseMessaging {

    /* renamed from: n, reason: collision with root package name */
    private static final long f5484n = TimeUnit.HOURS.toSeconds(8);

    /* renamed from: o, reason: collision with root package name */
    private static w0 f5485o;

    /* renamed from: p, reason: collision with root package name */
    static o2.g f5486p;

    /* renamed from: q, reason: collision with root package name */
    static ScheduledExecutorService f5487q;

    /* renamed from: a, reason: collision with root package name */
    private final w3.f f5488a;

    /* renamed from: b, reason: collision with root package name */
    private final p4.e f5489b;

    /* renamed from: c, reason: collision with root package name */
    private final Context f5490c;

    /* renamed from: d, reason: collision with root package name */
    private final b0 f5491d;

    /* renamed from: e, reason: collision with root package name */
    private final r0 f5492e;

    /* renamed from: f, reason: collision with root package name */
    private final a f5493f;

    /* renamed from: g, reason: collision with root package name */
    private final Executor f5494g;

    /* renamed from: h, reason: collision with root package name */
    private final Executor f5495h;

    /* renamed from: i, reason: collision with root package name */
    private final Executor f5496i;

    /* renamed from: j, reason: collision with root package name */
    private final Task f5497j;

    /* renamed from: k, reason: collision with root package name */
    private final g0 f5498k;

    /* renamed from: l, reason: collision with root package name */
    private boolean f5499l;

    /* renamed from: m, reason: collision with root package name */
    private final Application.ActivityLifecycleCallbacks f5500m;

    /* JADX INFO: Access modifiers changed from: private */
    class a {

        /* renamed from: a, reason: collision with root package name */
        private final l4.d f5501a;

        /* renamed from: b, reason: collision with root package name */
        private boolean f5502b;

        /* renamed from: c, reason: collision with root package name */
        private l4.b f5503c;

        /* renamed from: d, reason: collision with root package name */
        private Boolean f5504d;

        a(l4.d dVar) {
            this.f5501a = dVar;
        }

        /* JADX INFO: Access modifiers changed from: private */
        public /* synthetic */ void d(l4.a aVar) {
            if (c()) {
                FirebaseMessaging.this.y();
            }
        }

        private Boolean e() {
            ApplicationInfo applicationInfo;
            Bundle bundle;
            Context k10 = FirebaseMessaging.this.f5488a.k();
            SharedPreferences sharedPreferences = k10.getSharedPreferences("com.google.firebase.messaging", 0);
            if (sharedPreferences.contains("auto_init")) {
                return Boolean.valueOf(sharedPreferences.getBoolean("auto_init", false));
            }
            try {
                PackageManager packageManager = k10.getPackageManager();
                if (packageManager == null || (applicationInfo = packageManager.getApplicationInfo(k10.getPackageName(), 128)) == null || (bundle = applicationInfo.metaData) == null || !bundle.containsKey("firebase_messaging_auto_init_enabled")) {
                    return null;
                }
                return Boolean.valueOf(applicationInfo.metaData.getBoolean("firebase_messaging_auto_init_enabled"));
            } catch (PackageManager.NameNotFoundException unused) {
                return null;
            }
        }

        synchronized void b() {
            if (this.f5502b) {
                return;
            }
            Boolean e10 = e();
            this.f5504d = e10;
            if (e10 == null) {
                l4.b bVar = new l4.b() { // from class: com.google.firebase.messaging.y
                    @Override // l4.b
                    public final void a(l4.a aVar) {
                        FirebaseMessaging.a.this.d(aVar);
                    }
                };
                this.f5503c = bVar;
                this.f5501a.b(w3.b.class, bVar);
            }
            this.f5502b = true;
        }

        synchronized boolean c() {
            Boolean bool;
            b();
            bool = this.f5504d;
            return bool != null ? bool.booleanValue() : FirebaseMessaging.this.f5488a.u();
        }
    }

    FirebaseMessaging(w3.f fVar, n4.a aVar, o4.b bVar, o4.b bVar2, p4.e eVar, o2.g gVar, l4.d dVar) {
        this(fVar, aVar, bVar, bVar2, eVar, gVar, dVar, new g0(fVar.k()));
    }

    @Keep
    static synchronized FirebaseMessaging getInstance(w3.f fVar) {
        FirebaseMessaging firebaseMessaging;
        synchronized (FirebaseMessaging.class) {
            firebaseMessaging = (FirebaseMessaging) fVar.i(FirebaseMessaging.class);
            Preconditions.checkNotNull(firebaseMessaging, "Firebase Messaging component is not present");
        }
        return firebaseMessaging;
    }

    private static synchronized w0 k(Context context) {
        w0 w0Var;
        synchronized (FirebaseMessaging.class) {
            if (f5485o == null) {
                f5485o = new w0(context);
            }
            w0Var = f5485o;
        }
        return w0Var;
    }

    private String l() {
        return "[DEFAULT]".equals(this.f5488a.n()) ? RequestConfiguration.MAX_AD_CONTENT_RATING_UNSPECIFIED : this.f5488a.p();
    }

    public static o2.g n() {
        return f5486p;
    }

    private void o(String str) {
        if ("[DEFAULT]".equals(this.f5488a.n())) {
            if (Log.isLoggable("FirebaseMessaging", 3)) {
                Log.d("FirebaseMessaging", "Invoking onNewToken for app: " + this.f5488a.n());
            }
            Intent intent = new Intent("com.google.firebase.messaging.NEW_TOKEN");
            intent.putExtra("token", str);
            new o(this.f5490c).k(intent);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Task r(final String str, final w0.a aVar) {
        return this.f5491d.e().onSuccessTask(this.f5496i, new SuccessContinuation() { // from class: com.google.firebase.messaging.x
            @Override // com.google.android.gms.tasks.SuccessContinuation
            public final Task then(Object obj) {
                Task s10;
                s10 = FirebaseMessaging.this.s(str, aVar, (String) obj);
                return s10;
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ Task s(String str, w0.a aVar, String str2) {
        k(this.f5490c).f(l(), str, str2, this.f5498k.a());
        if (aVar == null || !str2.equals(aVar.f5678a)) {
            o(str2);
        }
        return Tasks.forResult(str2);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void t() {
        if (p()) {
            y();
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void u(b1 b1Var) {
        if (p()) {
            b1Var.o();
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public /* synthetic */ void v() {
        m0.c(this.f5490c);
    }

    private synchronized void x() {
        if (!this.f5499l) {
            z(0L);
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void y() {
        if (A(m())) {
            x();
        }
    }

    boolean A(w0.a aVar) {
        return aVar == null || aVar.b(this.f5498k.a());
    }

    String h() {
        final w0.a m10 = m();
        if (!A(m10)) {
            return m10.f5678a;
        }
        final String c10 = g0.c(this.f5488a);
        try {
            return (String) Tasks.await(this.f5492e.b(c10, new r0.a() { // from class: com.google.firebase.messaging.w
                @Override // com.google.firebase.messaging.r0.a
                public final Task start() {
                    Task r10;
                    r10 = FirebaseMessaging.this.r(c10, m10);
                    return r10;
                }
            }));
        } catch (InterruptedException | ExecutionException e10) {
            throw new IOException(e10);
        }
    }

    void i(Runnable runnable, long j10) {
        synchronized (FirebaseMessaging.class) {
            if (f5487q == null) {
                f5487q = new ScheduledThreadPoolExecutor(1, new NamedThreadFactory("TAG"));
            }
            f5487q.schedule(runnable, j10, TimeUnit.SECONDS);
        }
    }

    Context j() {
        return this.f5490c;
    }

    w0.a m() {
        return k(this.f5490c).d(l(), g0.c(this.f5488a));
    }

    public boolean p() {
        return this.f5493f.c();
    }

    boolean q() {
        return this.f5498k.g();
    }

    synchronized void w(boolean z10) {
        this.f5499l = z10;
    }

    synchronized void z(long j10) {
        i(new x0(this, Math.min(Math.max(30L, 2 * j10), f5484n)), j10);
        this.f5499l = true;
    }

    FirebaseMessaging(w3.f fVar, n4.a aVar, o4.b bVar, o4.b bVar2, p4.e eVar, o2.g gVar, l4.d dVar, g0 g0Var) {
        this(fVar, aVar, eVar, gVar, dVar, g0Var, new b0(fVar, g0Var, bVar, bVar2, eVar), p.f(), p.c(), p.b());
    }

    FirebaseMessaging(w3.f fVar, n4.a aVar, p4.e eVar, o2.g gVar, l4.d dVar, g0 g0Var, b0 b0Var, Executor executor, Executor executor2, Executor executor3) {
        this.f5499l = false;
        f5486p = gVar;
        this.f5488a = fVar;
        this.f5489b = eVar;
        this.f5493f = new a(dVar);
        Context k10 = fVar.k();
        this.f5490c = k10;
        r rVar = new r();
        this.f5500m = rVar;
        this.f5498k = g0Var;
        this.f5495h = executor;
        this.f5491d = b0Var;
        this.f5492e = new r0(executor);
        this.f5494g = executor2;
        this.f5496i = executor3;
        Context k11 = fVar.k();
        if (k11 instanceof Application) {
            ((Application) k11).registerActivityLifecycleCallbacks(rVar);
        } else {
            Log.w("FirebaseMessaging", "Context " + k11 + " was not an application, can't register for lifecycle callbacks. Some notification events may be dropped as a result.");
        }
        if (aVar != null) {
            aVar.a(new a.InterfaceC0195a() { // from class: com.google.firebase.messaging.s
            });
        }
        executor2.execute(new Runnable() { // from class: com.google.firebase.messaging.t
            @Override // java.lang.Runnable
            public final void run() {
                FirebaseMessaging.this.t();
            }
        });
        Task e10 = b1.e(this, g0Var, b0Var, k10, p.g());
        this.f5497j = e10;
        e10.addOnSuccessListener(executor2, new OnSuccessListener() { // from class: com.google.firebase.messaging.u
            @Override // com.google.android.gms.tasks.OnSuccessListener
            public final void onSuccess(Object obj) {
                FirebaseMessaging.this.u((b1) obj);
            }
        });
        executor2.execute(new Runnable() { // from class: com.google.firebase.messaging.v
            @Override // java.lang.Runnable
            public final void run() {
                FirebaseMessaging.this.v();
            }
        });
    }
}