package com.google.firebase.messaging; import android.app.Application; import android.app.NotificationManager; import android.content.Context; import android.content.SharedPreferences; import android.os.Binder; import android.os.Build; import android.os.Bundle; import androidx.annotation.Keep; import androidx.annotation.NonNull; import androidx.annotation.Nullable; import androidx.annotation.VisibleForTesting; import com.google.android.gms.internal.measurement.i1; import com.google.android.gms.measurement.internal.c2; import java.io.IOException; import java.lang.ref.WeakReference; import java.util.Objects; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.Executor; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /* JADX INFO: loaded from: classes2.dex */ public class FirebaseMessaging { /* JADX INFO: renamed from: l, reason: collision with root package name */ public static d0 f24118l; /* JADX INFO: renamed from: n, reason: collision with root package name */ public static ScheduledThreadPoolExecutor f24120n; /* JADX INFO: renamed from: a, reason: collision with root package name */ public final ua.g f24121a; /* JADX INFO: renamed from: b, reason: collision with root package name */ public final Context f24122b; /* JADX INFO: renamed from: c, reason: collision with root package name */ public final p f24123c; /* JADX INFO: renamed from: d, reason: collision with root package name */ public final z f24124d; /* JADX INFO: renamed from: e, reason: collision with root package name */ public final o f24125e; /* JADX INFO: renamed from: f, reason: collision with root package name */ public final Executor f24126f; /* JADX INFO: renamed from: g, reason: collision with root package name */ public final Executor f24127g; /* JADX INFO: renamed from: h, reason: collision with root package name */ public final w8.t f24128h; /* JADX INFO: renamed from: i, reason: collision with root package name */ public final s f24129i; @Nullable private final fb.a iid; /* JADX INFO: renamed from: j, reason: collision with root package name */ public boolean f24130j; /* JADX INFO: renamed from: k, reason: collision with root package name */ public static final long f24117k = TimeUnit.HOURS.toSeconds(8); /* JADX INFO: renamed from: m, reason: collision with root package name */ public static gb.a f24119m = new com.google.firebase.components.g(6); /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */ public FirebaseMessaging(ua.g gVar, @Nullable fb.a aVar, gb.a aVar2, gb.a aVar3, hb.d dVar, gb.a aVar4, db.c cVar) { this(gVar, aVar, aVar2, aVar3, dVar, aVar4, cVar, new s(gVar.f33401a)); gVar.a(); } public static void b(f0 f0Var, long j10) { synchronized (FirebaseMessaging.class) { try { if (f24120n == null) { f24120n = new ScheduledThreadPoolExecutor(1, new m.c("TAG", 2)); } f24120n.schedule(f0Var, j10, TimeUnit.SECONDS); } catch (Throwable th) { throw th; } } } public static synchronized FirebaseMessaging c() { return getInstance(ua.g.b()); } public static synchronized d0 d(Context context) { try { if (f24118l == null) { f24118l = new d0(context); } } catch (Throwable th) { throw th; } return f24118l; } @NonNull @Keep public static synchronized FirebaseMessaging getInstance(@NonNull ua.g gVar) { FirebaseMessaging firebaseMessaging; gVar.a(); firebaseMessaging = (FirebaseMessaging) gVar.f33404d.get(FirebaseMessaging.class); com.google.android.gms.common.internal.w.f(firebaseMessaging, "Firebase Messaging component is not present"); return firebaseMessaging; } @Nullable public static t6.g getTransportFactory() { return (t6.g) f24119m.get(); } public final String a() { w8.h hVarF; c0 tokenWithoutTriggeringSync = getTokenWithoutTriggeringSync(); if (!tokenNeedsRefresh(tokenWithoutTriggeringSync)) { return tokenWithoutTriggeringSync.f24161a; } String strB = s.b(this.f24121a); z zVar = this.f24124d; n nVar = new n(this, strB, tokenWithoutTriggeringSync); synchronized (zVar) { hVarF = (w8.h) zVar.f24290b.get(strB); if (hVarF == null) { hVarF = nVar.b().f(zVar.f24289a, new androidx.media3.exoplayer.analytics.g(zVar, strB, 17)); zVar.f24290b.put(strB, hVarF); } } try { return (String) w8.k.a(hVarF); } catch (InterruptedException | ExecutionException e10) { throw new IOException(e10); } } public final void e() { w8.t tVarD; int i10; d8.b bVar = this.f24123c.f24234c; if (bVar.f25011c.f() >= 241100000) { d8.o oVarA = d8.o.a(bVar.f25010b); Bundle bundle = Bundle.EMPTY; synchronized (oVarA) { i10 = oVarA.f25044d; oVarA.f25044d = i10 + 1; } tVarD = oVarA.b(new d8.m(i10, 5, bundle, 1)).e(d8.p.f25045a, d8.d.f25018a); } else { tVarD = w8.k.d(new IOException("SERVICE_NOT_AVAILABLE")); } tVarD.d(this.f24126f, new k(this, 2)); } public final boolean f() { Context context = this.f24122b; ua.b.B(context); if (!(Build.VERSION.SDK_INT >= 29)) { return false; } if (!(Binder.getCallingUid() == context.getApplicationInfo().uid)) { context.getPackageName(); return false; } if (!"com.google.android.gms".equals(((NotificationManager) context.getSystemService(NotificationManager.class)).getNotificationDelegate())) { return false; } ua.g gVar = this.f24121a; gVar.a(); if (gVar.f33404d.get(wa.d.class) != null) { return true; } return r.a() && f24119m != null; } public final synchronized void g(long j10) { b(new f0(this, Math.min(Math.max(30L, 2 * j10), f24117k)), j10); this.f24130j = true; } @Nullable @VisibleForTesting public c0 getTokenWithoutTriggeringSync() { c0 c0VarA; d0 d0VarD = d(this.f24122b); ua.g gVar = this.f24121a; gVar.a(); String strC = "[DEFAULT]".equals(gVar.f33402b) ? "" : gVar.c(); String strB = s.b(this.f24121a); synchronized (d0VarD) { c0VarA = c0.a(d0VarD.f24165a.getString(strC + "|T|" + strB + "|*", null)); } return c0VarA; } @VisibleForTesting public boolean tokenNeedsRefresh(@Nullable c0 c0Var) { if (c0Var != null) { String strA = this.f24129i.a(); if (System.currentTimeMillis() <= c0Var.f24163c + c0.f24159d && strA.equals(c0Var.f24162b)) { return false; } } return true; } public FirebaseMessaging(ua.g gVar, @Nullable fb.a aVar, gb.a aVar2, gb.a aVar3, hb.d dVar, gb.a aVar4, db.c cVar, s sVar) { this(gVar, aVar, aVar4, cVar, sVar, new p(gVar, sVar, aVar2, aVar3, dVar), Executors.newSingleThreadExecutor(new m.c("Firebase-Messaging-Task", 2)), new ScheduledThreadPoolExecutor(1, new m.c("Firebase-Messaging-Init", 2)), new ThreadPoolExecutor(0, 1, 30L, TimeUnit.SECONDS, new LinkedBlockingQueue(), new m.c("Firebase-Messaging-File-Io", 2))); } public FirebaseMessaging(ua.g gVar, @Nullable fb.a aVar, gb.a aVar2, db.c cVar, final s sVar, final p pVar, Executor executor, Executor executor2, Executor executor3) { final int i10 = 0; this.f24130j = false; f24119m = aVar2; this.f24121a = gVar; this.f24125e = new o(this, cVar); gVar.a(); final Context context = gVar.f33401a; this.f24122b = context; i1 i1Var = new i1(); this.f24129i = sVar; this.f24123c = pVar; this.f24124d = new z(executor); this.f24126f = executor2; this.f24127g = executor3; gVar.a(); Context context2 = gVar.f33401a; if (context2 instanceof Application) { ((Application) context2).registerActivityLifecycleCallbacks(i1Var); } else { Objects.toString(context2); } if (aVar != null) { aVar.a(); } executor2.execute(new Runnable(this) { // from class: com.google.firebase.messaging.l /* JADX INFO: renamed from: b, reason: collision with root package name */ public final /* synthetic */ FirebaseMessaging f24208b; { this.f24208b = this; } @Override // java.lang.Runnable public final void run() { w8.t tVarD; int i11; int i12 = i10; FirebaseMessaging firebaseMessaging = this.f24208b; switch (i12) { case 0: if (firebaseMessaging.f24125e.b() && firebaseMessaging.tokenNeedsRefresh(firebaseMessaging.getTokenWithoutTriggeringSync())) { synchronized (firebaseMessaging) { if (!firebaseMessaging.f24130j) { firebaseMessaging.g(0L); } break; } return; } return; default: Context context3 = firebaseMessaging.f24122b; ua.b.B(context3); boolean zF = firebaseMessaging.f(); if (Build.VERSION.SDK_INT >= 29) { SharedPreferences sharedPreferencesI = c2.i(context3); if (!sharedPreferencesI.contains("proxy_retention") || sharedPreferencesI.getBoolean("proxy_retention", false) != zF) { d8.b bVar = firebaseMessaging.f24123c.f24234c; if (bVar.f25011c.f() >= 241100000) { Bundle bundle = new Bundle(); bundle.putBoolean("proxy_retention", zF); d8.o oVarA = d8.o.a(bVar.f25010b); synchronized (oVarA) { i11 = oVarA.f25044d; oVarA.f25044d = i11 + 1; } tVarD = oVarA.b(new d8.m(i11, 4, bundle, 0)); } else { tVarD = w8.k.d(new IOException("SERVICE_NOT_AVAILABLE")); } tVarD.d(new m.a(22), new androidx.media3.exoplayer.analytics.u(4, context3, zF)); } } if (firebaseMessaging.f()) { firebaseMessaging.e(); return; } return; } } }); final int i11 = 1; final ScheduledThreadPoolExecutor scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1, new m.c("Firebase-Messaging-Topics-Io", 2)); int i12 = j0.f24196j; w8.t tVarC = w8.k.c(new Callable() { // from class: com.google.firebase.messaging.i0 @Override // java.util.concurrent.Callable public final Object call() { h0 h0Var; Context context3 = context; ScheduledExecutorService scheduledExecutorService = scheduledThreadPoolExecutor; FirebaseMessaging firebaseMessaging = this; s sVar2 = sVar; p pVar2 = pVar; synchronized (h0.class) { try { WeakReference weakReference = h0.f24180c; h0Var = weakReference != null ? (h0) weakReference.get() : null; if (h0Var == null) { SharedPreferences sharedPreferences = context3.getSharedPreferences("com.google.android.gms.appid", 0); h0 h0Var2 = new h0(sharedPreferences, scheduledExecutorService); synchronized (h0Var2) { h0Var2.f24181a = b0.a(sharedPreferences, scheduledExecutorService); } h0.f24180c = new WeakReference(h0Var2); h0Var = h0Var2; } } catch (Throwable th) { throw th; } } return new j0(firebaseMessaging, sVar2, h0Var, pVar2, context3, scheduledExecutorService); } }, scheduledThreadPoolExecutor); this.f24128h = tVarC; tVarC.d(executor2, new k(this, i11)); executor2.execute(new Runnable(this) { // from class: com.google.firebase.messaging.l /* JADX INFO: renamed from: b, reason: collision with root package name */ public final /* synthetic */ FirebaseMessaging f24208b; { this.f24208b = this; } @Override // java.lang.Runnable public final void run() { w8.t tVarD; int i112; int i122 = i11; FirebaseMessaging firebaseMessaging = this.f24208b; switch (i122) { case 0: if (firebaseMessaging.f24125e.b() && firebaseMessaging.tokenNeedsRefresh(firebaseMessaging.getTokenWithoutTriggeringSync())) { synchronized (firebaseMessaging) { if (!firebaseMessaging.f24130j) { firebaseMessaging.g(0L); } break; } return; } return; default: Context context3 = firebaseMessaging.f24122b; ua.b.B(context3); boolean zF = firebaseMessaging.f(); if (Build.VERSION.SDK_INT >= 29) { SharedPreferences sharedPreferencesI = c2.i(context3); if (!sharedPreferencesI.contains("proxy_retention") || sharedPreferencesI.getBoolean("proxy_retention", false) != zF) { d8.b bVar = firebaseMessaging.f24123c.f24234c; if (bVar.f25011c.f() >= 241100000) { Bundle bundle = new Bundle(); bundle.putBoolean("proxy_retention", zF); d8.o oVarA = d8.o.a(bVar.f25010b); synchronized (oVarA) { i112 = oVarA.f25044d; oVarA.f25044d = i112 + 1; } tVarD = oVarA.b(new d8.m(i112, 4, bundle, 0)); } else { tVarD = w8.k.d(new IOException("SERVICE_NOT_AVAILABLE")); } tVarD.d(new m.a(22), new androidx.media3.exoplayer.analytics.u(4, context3, zF)); } } if (firebaseMessaging.f()) { firebaseMessaging.e(); return; } return; } } }); } }