package com.google.firebase.messaging;

import android.content.Context;
import android.content.Intent;
import android.util.Base64;
import android.util.Log;
import com.google.android.gms.internal.measurement.C1;
import java.util.concurrent.ExecutorService;
import r.C0966e;
import w1.AbstractC1092b;

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public static final Object f5899c = new Object();

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public static J f5900d;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Object f5901a;

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

    public k(ExecutorService executorService) {
        this.f5902b = new C0966e(0);
        this.f5901a = executorService;
    }

    public static P1.o a(Context context, Intent intent, boolean z5) {
        J j5;
        if (Log.isLoggable("FirebaseMessaging", 3)) {
            Log.d("FirebaseMessaging", "Binding to service");
        }
        synchronized (f5899c) {
            try {
                if (f5900d == null) {
                    f5900d = new J(context);
                }
                j5 = f5900d;
            } finally {
            }
        }
        if (!z5) {
            return j5.b(intent).i(new r0.c(), new B2.c(24));
        }
        if (w.v().y(context)) {
            synchronized (G.f5858b) {
                try {
                    G.a(context);
                    boolean booleanExtra = intent.getBooleanExtra("com.google.firebase.iid.WakeLockHolder.wakefulintent", false);
                    intent.putExtra("com.google.firebase.iid.WakeLockHolder.wakefulintent", true);
                    if (!booleanExtra) {
                        G.f5859c.a(G.f5857a);
                    }
                    j5.b(intent).a(new N2.a(7, intent));
                } finally {
                }
            }
        } else {
            j5.b(intent);
        }
        return C1.l(-1);
    }

    public P1.o b(final Intent intent) {
        String stringExtra = intent.getStringExtra("gcm.rawData64");
        if (stringExtra != null) {
            intent.putExtra("rawData", Base64.decode(stringExtra, 0));
            intent.removeExtra("gcm.rawData64");
        }
        boolean zB = AbstractC1092b.b();
        final Context context = (Context) this.f5901a;
        boolean z5 = zB && context.getApplicationInfo().targetSdkVersion >= 26;
        final boolean z6 = (intent.getFlags() & 268435456) != 0;
        if (z5 && !z6) {
            return a(context, intent, z6);
        }
        r0.c cVar = (r0.c) this.f5902b;
        return C1.c(cVar, new CallableC0505i(0, context, intent)).j(cVar, new P1.a() { // from class: com.google.firebase.messaging.j
            @Override // P1.a
            public final Object f(P1.h hVar) {
                if (!AbstractC1092b.b() || ((Integer) hVar.f()).intValue() != 402) {
                    return hVar;
                }
                return k.a(context, intent, z6).i(new r0.c(), new B2.c(23));
            }
        });
    }

    public k(Context context) {
        this.f5901a = context;
        this.f5902b = new r0.c();
    }
}