package m7;

import android.app.Activity;
import android.content.Context;
import android.content.pm.PackageManager;
import android.os.Looper;
import android.util.Base64;
import android.view.MotionEvent;
import android.view.View;
import androidx.annotation.Nullable;
import com.google.android.gms.internal.ads.ao;
import com.google.android.gms.internal.ads.b30;
import com.google.android.gms.internal.ads.bg;
import com.google.android.gms.internal.ads.ce;
import com.google.android.gms.internal.ads.cg;
import com.google.android.gms.internal.ads.ch1;
import com.google.android.gms.internal.ads.de;
import com.google.android.gms.internal.ads.fh1;
import com.google.android.gms.internal.ads.gi1;
import com.google.android.gms.internal.ads.ih1;
import com.google.android.gms.internal.ads.jg;
import com.google.android.gms.internal.ads.ng;
import com.google.android.gms.internal.ads.nh;
import com.google.android.gms.internal.ads.qe;
import com.google.android.gms.internal.ads.qg;
import com.google.android.gms.internal.ads.rg;
import com.google.android.gms.internal.ads.sg;
import com.google.android.gms.internal.ads.th;
import com.google.android.gms.internal.ads.tn;
import com.google.android.gms.internal.ads.vg;
import com.google.android.gms.internal.ads.vu0;
import com.google.android.gms.internal.ads.wf;
import com.google.android.gms.internal.ads.xf;
import com.google.android.gms.internal.ads.xg;
import com.google.android.gms.internal.ads.yn;
import java.io.UnsupportedEncodingException;
import java.security.GeneralSecurityException;
import java.util.Vector;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;
import java.util.concurrent.atomic.AtomicReference;
import n5.q;
import n5.s;
import n7.x;
import n7.y;
import p7.r0;
import xyz.stream.utils.a0;

/* JADX INFO: loaded from: classes2.dex */
public final class g implements Runnable, qg {
    public static final long S = System.currentTimeMillis();
    public int R;

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final boolean f30436e;

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

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

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final ch1 f30439h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public Context f30440i;

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

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    public q7.a f30442k;

    /* JADX INFO: renamed from: l, reason: collision with root package name */
    public final q7.a f30443l;

    /* JADX INFO: renamed from: m, reason: collision with root package name */
    public final boolean f30444m;

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final Vector f30432a = new Vector();

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final AtomicReference f30433b = new AtomicReference();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final AtomicReference f30434c = new AtomicReference();
    public final CountDownLatch Q = new CountDownLatch(1);

    public g(Context context, q7.a aVar) {
        this.f30440i = context;
        this.f30441j = context;
        this.f30442k = aVar;
        this.f30443l = aVar;
        ExecutorService executorServiceNewCachedThreadPool = Executors.newCachedThreadPool();
        this.f30438g = executorServiceNewCachedThreadPool;
        tn tnVar = ao.V2;
        y yVar = y.f31093e;
        boolean zBooleanValue = ((Boolean) yVar.f31096c.b(tnVar)).booleanValue();
        this.f30444m = zBooleanValue;
        this.f30439h = ch1.a(context, executorServiceNewCachedThreadPool, zBooleanValue);
        tn tnVar2 = ao.S2;
        yn ynVar = yVar.f31096c;
        this.f30436e = ((Boolean) ynVar.b(tnVar2)).booleanValue();
        this.f30437f = ((Boolean) ynVar.b(ao.W2)).booleanValue();
        if (((Boolean) ynVar.b(ao.U2)).booleanValue()) {
            this.R = 2;
        } else {
            this.R = 1;
        }
        if (!((Boolean) ynVar.b(ao.f8850f4)).booleanValue()) {
            this.f30435d = f();
        }
        if (((Boolean) ynVar.b(ao.Y3)).booleanValue()) {
            b30.f9359a.execute(this);
            return;
        }
        q7.e eVar = x.f31085g.f31086a;
        if (Looper.myLooper() == Looper.getMainLooper()) {
            b30.f9359a.execute(this);
        } else {
            run();
        }
    }

    public static final ng i(Context context, q7.a aVar, boolean z10, boolean z11) {
        ng ngVarH;
        ce ceVarF = de.F();
        ceVarF.c();
        ((de) ceVarF.f8617b).H(z10);
        String str = aVar.f32212a;
        ceVarF.c();
        ((de) ceVarF.f8617b).G(str);
        de deVar = (de) ceVarF.e();
        Context applicationContext = context.getApplicationContext();
        if (applicationContext != null) {
            context = applicationContext;
        }
        synchronized (ng.class) {
            fh1 fh1Var = new fh1();
            fh1Var.f11225b = false;
            byte b10 = (byte) (fh1Var.f11229f | 1);
            fh1Var.f11226c = true;
            fh1Var.f11227d = 100L;
            fh1Var.f11228e = 300L;
            fh1Var.f11229f = (byte) (((byte) (((byte) (((byte) (((byte) (b10 | 2)) | 4)) | 8)) | 16)) | 32);
            String strB = deVar.B();
            if (strB == null) {
                throw new NullPointerException("Null clientVersion");
            }
            fh1Var.f11224a = strB;
            fh1Var.f11225b = deVar.C();
            fh1Var.f11229f = (byte) (fh1Var.f11229f | 1);
            ngVarH = ng.h(context, Executors.newCachedThreadPool(), fh1Var.a(), z11);
        }
        return ngVarH;
    }

    @Nullable
    private final qg zzs() {
        return ((!this.f30436e || this.f30435d) && this.R == 2) ? (qg) this.f30434c.get() : (qg) this.f30433b.get();
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final void a(int i10, int i11, int i12) {
        qg qgVarZzs = zzs();
        if (qgVarZzs == null) {
            this.f30432a.add(new Object[]{Integer.valueOf(i10), Integer.valueOf(i11), Integer.valueOf(i12)});
            return;
        }
        g();
        try {
            qgVarZzs.a(i10, i11, i12);
        } catch (NullPointerException unused) {
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final String b(Context context) {
        try {
            return (String) ih1.A0(new o0.d(this, context, 1), this.f30438g).get(((Integer) y.f31093e.f31096c.b(ao.f8963m3)).intValue(), TimeUnit.MILLISECONDS);
        } catch (InterruptedException | ExecutionException unused) {
            return Integer.toString(17);
        } catch (TimeoutException unused2) {
            String str = this.f30443l.f32212a;
            long j10 = S;
            try {
                wf wfVarB = xf.B();
                wfVarB.c();
                ((xf) wfVarB.f8617b).D(str);
                wfVarB.c();
                ((xf) wfVarB.f8617b).C("0.825731049");
                String packageName = context.getPackageName();
                wfVarB.c();
                ((xf) wfVarB.f8617b).F(packageName);
                long jCurrentTimeMillis = (System.currentTimeMillis() - j10) / 1000;
                wfVarB.c();
                ((xf) wfVarB.f8617b).H(jCurrentTimeMillis);
                long jCurrentTimeMillis2 = System.currentTimeMillis() / 1000;
                wfVarB.c();
                ((xf) wfVarB.f8617b).E(jCurrentTimeMillis2);
                try {
                    long j11 = context.getPackageManager().getPackageInfo(context.getPackageName(), 0).versionCode;
                    wfVarB.c();
                    ((xf) wfVarB.f8617b).G(j11);
                } catch (PackageManager.NameNotFoundException unused3) {
                    wfVarB.c();
                    ((xf) wfVarB.f8617b).G(-1L);
                }
                bg bgVarB = jg.b(null, ((xf) wfVarB.e()).b());
                bgVarB.c();
                ((cg) bgVarB.f8617b).E(5);
                bgVarB.c();
                ((cg) bgVarB.f8617b).F(2);
                return Base64.encodeToString(((cg) bgVarB.e()).b(), 11);
            } catch (UnsupportedEncodingException | GeneralSecurityException unused4) {
                return Integer.toString(7);
            }
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final void c(StackTraceElement[] stackTraceElementArr) {
        qg qgVarZzs;
        boolean zBooleanValue = ((Boolean) y.f31093e.f31096c.b(ao.f9080t3)).booleanValue();
        CountDownLatch countDownLatch = this.Q;
        if (zBooleanValue) {
            if (countDownLatch.getCount() != 0 || (qgVarZzs = zzs()) == null) {
                return;
            }
            try {
                qgVarZzs.c(stackTraceElementArr);
                return;
            } catch (NullPointerException unused) {
                return;
            }
        }
        try {
            countDownLatch.await();
            qg qgVarZzs2 = zzs();
            if (qgVarZzs2 != null) {
                qgVarZzs2.c(stackTraceElementArr);
            }
        } catch (InterruptedException | NullPointerException unused2) {
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final String d(Context context) {
        return e(context);
    }

    public final String e(Context context) {
        try {
            this.Q.await();
            qg qgVarZzs = zzs();
            if (qgVarZzs == null) {
                return "";
            }
            g();
            Context applicationContext = context.getApplicationContext();
            if (applicationContext != null) {
                context = applicationContext;
            }
            return qgVarZzs.d(context);
        } catch (InterruptedException | NullPointerException unused) {
            return "";
        }
    }

    public final boolean f() {
        Context context = this.f30440i;
        a0 a0Var = new a0();
        a0Var.f36098a = this;
        return new gi1(this.f30440i, ih1.T(context, this.f30439h), a0Var, ((Boolean) y.f31093e.f31096c.b(ao.T2)).booleanValue()).b();
    }

    public final void g() {
        Vector<Object[]> vector = this.f30432a;
        qg qgVarZzs = zzs();
        if (vector.isEmpty() || qgVarZzs == null) {
            return;
        }
        for (Object[] objArr : vector) {
            try {
                int length = objArr.length;
                if (length == 1) {
                    qgVarZzs.zzd((MotionEvent) objArr[0]);
                } else if (length == 3) {
                    qgVarZzs.a(((Integer) objArr[0]).intValue(), ((Integer) objArr[1]).intValue(), ((Integer) objArr[2]).intValue());
                }
            } catch (NullPointerException unused) {
            }
        }
        vector.clear();
    }

    public final void h(boolean z10) {
        String str = this.f30442k.f32212a;
        Context context = this.f30440i;
        Context applicationContext = context.getApplicationContext();
        if (applicationContext != null) {
            context = applicationContext;
        }
        ce ceVarF = de.F();
        ceVarF.c();
        ((de) ceVarF.f8617b).H(z10);
        ceVarF.c();
        ((de) ceVarF.f8617b).G(str);
        de deVar = (de) ceVarF.e();
        Object obj = sg.f16429a0;
        s sVar = new s();
        sVar.f30880b = deVar.B();
        sVar.f30879a = deVar.C();
        sVar.f30881c = deVar.D();
        deVar.E();
        synchronized (sg.class) {
            try {
                if (!sg.f16430b0) {
                    sg.f16431c0 = System.currentTimeMillis() / 1000;
                    rg.W = sg.l(context, sVar.f30879a);
                    tn tnVar = ao.f8766a4;
                    y yVar = y.f31093e;
                    if (((Boolean) yVar.f31096c.b(tnVar)).booleanValue()) {
                        sg.f16432d0 = xg.a(context);
                    }
                    ExecutorService executorService = rg.W.f14220b;
                    if (((Boolean) yVar.f31096c.b(ao.f8783b4)).booleanValue() && executorService != null) {
                        sg.f16433e0 = th.a(context, executorService);
                    }
                    if (((Boolean) yVar.f31096c.b(ao.f8914j3)).booleanValue()) {
                        sg.f16434f0 = new nh();
                    }
                    if (((Boolean) yVar.f31096c.b(ao.f9014p3)).booleanValue() || ((qe) sVar.f30881c).F()) {
                        sg.f16436h0 = new vg(context, executorService);
                    }
                    if (((Boolean) yVar.f31096c.b(ao.f8930k3)).booleanValue() || ((qe) sVar.f30881c).D()) {
                        sg.f16435g0 = new vu0(context, executorService, (qe) sVar.f30881c, sg.f16436h0);
                    }
                    sg.f16430b0 = true;
                }
            } catch (Throwable th) {
                throw th;
            }
        }
        this.f30433b.set(new sg(context, sVar));
    }

    @Override // java.lang.Runnable
    public final void run() {
        boolean z10;
        try {
            tn tnVar = ao.f8850f4;
            y yVar = y.f31093e;
            if (((Boolean) yVar.f31096c.b(tnVar)).booleanValue()) {
                this.f30435d = f();
            }
            boolean z11 = this.f30442k.f32215d;
            boolean z12 = false;
            int i10 = 1;
            if (!((Boolean) yVar.f31096c.b(ao.f9095u1)).booleanValue() && z11) {
                z12 = true;
            }
            if ((!this.f30436e || this.f30435d) && this.R != 1) {
                long jCurrentTimeMillis = System.currentTimeMillis();
                try {
                    ng ngVarI = i(this.f30440i, this.f30442k, z12, this.f30444m);
                    this.f30434c.set(ngVarI);
                    if (this.f30437f) {
                        synchronized (ngVarI) {
                            z10 = ngVarI.R;
                        }
                        if (!z10) {
                            this.R = 1;
                            h(z12);
                        }
                    }
                } catch (NullPointerException e10) {
                    this.R = 1;
                    h(z12);
                    this.f30439h.c(2031, System.currentTimeMillis() - jCurrentTimeMillis, e10);
                }
            } else {
                h(z12);
                if (this.R == 2) {
                    this.f30438g.execute(new q(i10, this, z12));
                }
            }
            this.Q.countDown();
            this.f30440i = null;
            this.f30442k = null;
        } catch (Throwable th) {
            this.Q.countDown();
            this.f30440i = null;
            this.f30442k = null;
            throw th;
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final void zzd(MotionEvent motionEvent) {
        qg qgVarZzs = zzs();
        if (qgVarZzs == null) {
            this.f30432a.add(new Object[]{motionEvent});
            return;
        }
        g();
        try {
            qgVarZzs.zzd(motionEvent);
        } catch (NullPointerException unused) {
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final String zzf(Context context, String str, View view, Activity activity) {
        try {
            this.Q.await();
            qg qgVarZzs = zzs();
            if (((Boolean) y.f31093e.f31096c.b(ao.Sb)).booleanValue()) {
                r0 r0Var = n.C.f30464c;
                r0.i(view, 4);
            }
            if (qgVarZzs == null) {
                return "";
            }
            g();
            Context applicationContext = context.getApplicationContext();
            if (applicationContext != null) {
                context = applicationContext;
            }
            return qgVarZzs.zzf(context, str, view, activity);
        } catch (InterruptedException | NullPointerException unused) {
            return "";
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final String zzg(Context context, String str, View view) {
        return zzf(context, str, view, null);
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final void zzh(View view) {
        qg qgVarZzs = zzs();
        if (qgVarZzs != null) {
            try {
                qgVarZzs.zzh(view);
            } catch (NullPointerException unused) {
            }
        }
    }

    @Override // com.google.android.gms.internal.ads.qg
    public final String zzj(Context context, View view, Activity activity) {
        tn tnVar = ao.Rb;
        y yVar = y.f31093e;
        boolean zBooleanValue = ((Boolean) yVar.f31096c.b(tnVar)).booleanValue();
        yn ynVar = yVar.f31096c;
        try {
            if (!zBooleanValue) {
                qg qgVarZzs = zzs();
                if (((Boolean) ynVar.b(ao.Sb)).booleanValue()) {
                    r0 r0Var = n.C.f30464c;
                    r0.i(view, 2);
                }
                return qgVarZzs != null ? qgVarZzs.zzj(context, view, activity) : "";
            }
            this.Q.await();
            qg qgVarZzs2 = zzs();
            if (((Boolean) ynVar.b(ao.Sb)).booleanValue()) {
                r0 r0Var2 = n.C.f30464c;
                r0.i(view, 2);
            }
            return qgVarZzs2 != null ? qgVarZzs2.zzj(context, view, activity) : "";
        } catch (InterruptedException | NullPointerException unused) {
            return "";
        }
    }
}