package com.google.android.gms.internal.ads;

import android.content.Context;
import android.os.Binder;
import android.os.Bundle;
import android.os.IBinder;
import android.os.IInterface;
import android.os.Parcel;
import android.os.RemoteException;
import androidx.annotation.Nullable;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import java.io.ByteArrayInputStream;
import java.nio.charset.StandardCharsets;
import java.util.ArrayDeque;
import java.util.Arrays;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.Callable;
import org.json.JSONObject;

/* JADX INFO: loaded from: classes2.dex */
public final class ev0 extends zi implements kz {

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

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

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final kv0 f10934c;

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

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

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

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

    public ev0(Context context, a30 a30Var, a00 a00Var, h70 h70Var, kv0 kv0Var, ArrayDeque arrayDeque, nd1 nd1Var) {
        super("com.google.android.gms.ads.internal.request.IAdRequestService");
        ao.a(context);
        this.f10932a = context;
        this.f10933b = a30Var;
        this.f10938g = a00Var;
        this.f10934c = kv0Var;
        this.f10935d = h70Var;
        this.f10936e = arrayDeque;
        this.f10937f = nd1Var;
    }

    public static vc1 V2(tz tzVar, cd1 cd1Var, z70 z70Var) {
        nv nvVar = new nv(z70Var, tzVar, 9);
        return cd1Var.a(ih1.k(tzVar.f17031a), zzfno.GMS_SIGNALS).b(nvVar).a(w80.Q).f();
    }

    public static vc1 W2(vc1 vc1Var, cd1 cd1Var, jv jvVar, md1 md1Var, id1 id1Var) {
        lv lvVarA = jvVar.a("AFMA_getAdDictionary", za2.f19208j, i2.f12331f);
        ni.u(vc1Var, id1Var);
        vc1 vc1VarF = cd1Var.a(vc1Var, zzfno.BUILD_URL).b(lvVarA).f();
        if (((Boolean) ip.f12589c.j()).booleanValue()) {
            ih1.z1(wu1.s(vc1VarF), new uz0(md1Var, id1Var, 6), b30.f9365g);
        }
        return vc1VarF;
    }

    @Nullable
    private final synchronized bv0 zzr(String str) {
        Iterator it = this.f10936e.iterator();
        while (it.hasNext()) {
            bv0 bv0Var = (bv0) it.next();
            if (bv0Var.f9663c.equals(str)) {
                it.remove();
                return bv0Var;
            }
        }
        return null;
    }

    @Override // com.google.android.gms.internal.ads.kz
    public final void D2(String str, oz ozVar) {
        X2(T2(str), ozVar, null);
    }

    @Override // com.google.android.gms.internal.ads.kz
    public final void E0(tz tzVar, oz ozVar) {
        X2(S2(tzVar, Binder.getCallingUid()), ozVar, tzVar);
    }

    @Override // com.google.android.gms.internal.ads.zi
    public final boolean Q2(int i10, Parcel parcel, Parcel parcel2) throws RemoteException {
        pz pzVar;
        oz mzVar = null;
        switch (i10) {
            case 1:
                aj.e(parcel);
                parcel2.writeNoException();
                aj.c(parcel2, null);
                return true;
            case 2:
                IBinder strongBinder = parcel.readStrongBinder();
                if (strongBinder != null) {
                    IInterface iInterfaceQueryLocalInterface = strongBinder.queryLocalInterface("com.google.android.gms.ads.internal.request.IAdResponseListener");
                    if (iInterfaceQueryLocalInterface instanceof lz) {
                    }
                }
                aj.e(parcel);
                parcel2.writeNoException();
                return true;
            case 3:
            default:
                return false;
            case 4:
                tz tzVar = (tz) aj.a(parcel, tz.CREATOR);
                IBinder strongBinder2 = parcel.readStrongBinder();
                if (strongBinder2 != null) {
                    IInterface iInterfaceQueryLocalInterface2 = strongBinder2.queryLocalInterface("com.google.android.gms.ads.internal.request.INonagonStreamingResponseListener");
                    mzVar = iInterfaceQueryLocalInterface2 instanceof oz ? (oz) iInterfaceQueryLocalInterface2 : new mz(strongBinder2);
                }
                aj.e(parcel);
                S(tzVar, mzVar);
                parcel2.writeNoException();
                return true;
            case 5:
                tz tzVar2 = (tz) aj.a(parcel, tz.CREATOR);
                IBinder strongBinder3 = parcel.readStrongBinder();
                if (strongBinder3 != null) {
                    IInterface iInterfaceQueryLocalInterface3 = strongBinder3.queryLocalInterface("com.google.android.gms.ads.internal.request.INonagonStreamingResponseListener");
                    mzVar = iInterfaceQueryLocalInterface3 instanceof oz ? (oz) iInterfaceQueryLocalInterface3 : new mz(strongBinder3);
                }
                aj.e(parcel);
                d1(tzVar2, mzVar);
                parcel2.writeNoException();
                return true;
            case 6:
                tz tzVar3 = (tz) aj.a(parcel, tz.CREATOR);
                IBinder strongBinder4 = parcel.readStrongBinder();
                if (strongBinder4 != null) {
                    IInterface iInterfaceQueryLocalInterface4 = strongBinder4.queryLocalInterface("com.google.android.gms.ads.internal.request.INonagonStreamingResponseListener");
                    mzVar = iInterfaceQueryLocalInterface4 instanceof oz ? (oz) iInterfaceQueryLocalInterface4 : new mz(strongBinder4);
                }
                aj.e(parcel);
                E0(tzVar3, mzVar);
                parcel2.writeNoException();
                return true;
            case 7:
                String string = parcel.readString();
                IBinder strongBinder5 = parcel.readStrongBinder();
                if (strongBinder5 != null) {
                    IInterface iInterfaceQueryLocalInterface5 = strongBinder5.queryLocalInterface("com.google.android.gms.ads.internal.request.INonagonStreamingResponseListener");
                    mzVar = iInterfaceQueryLocalInterface5 instanceof oz ? (oz) iInterfaceQueryLocalInterface5 : new mz(strongBinder5);
                }
                aj.e(parcel);
                D2(string, mzVar);
                parcel2.writeNoException();
                return true;
            case 8:
                iz izVar = (iz) aj.a(parcel, iz.CREATOR);
                IBinder strongBinder6 = parcel.readStrongBinder();
                if (strongBinder6 == null) {
                    pzVar = null;
                } else {
                    IInterface iInterfaceQueryLocalInterface6 = strongBinder6.queryLocalInterface("com.google.android.gms.ads.internal.request.ITrustlessTokenListener");
                    pzVar = iInterfaceQueryLocalInterface6 instanceof pz ? (pz) iInterfaceQueryLocalInterface6 : new pz(strongBinder6, "com.google.android.gms.ads.internal.request.ITrustlessTokenListener", 0);
                }
                aj.e(parcel);
                if (!((Boolean) bq.f9624a.j()).booleanValue()) {
                    try {
                        Parcel parcelO = pzVar.O();
                        parcelO.writeString("");
                        aj.b(parcelO, izVar);
                        pzVar.O0(1, parcelO);
                    } catch (RemoteException unused) {
                        p7.l0.h();
                    }
                    break;
                } else {
                    this.f10935d.getClass();
                    String str = izVar.f12651a;
                    ih1.z1(ih1.k(null), new zv1(this, pzVar, izVar), b30.f9365g);
                }
                parcel2.writeNoException();
                return true;
            case 9:
                String string2 = parcel.readString();
                aj.e(parcel);
                zzi(string2);
                parcel2.writeNoException();
                return true;
        }
    }

    public final vc1 R2(tz tzVar, int i10) {
        bv0 bv0VarZzr;
        vc1 vc1VarF;
        gv gvVar = m7.n.C.f30479r;
        Context context = this.f10932a;
        jv jvVarA = gvVar.a(context, q7.a.w(), this.f10937f);
        h70 h70Var = (h70) this.f10935d;
        h70Var.getClass();
        z70 z70Var = new z70(((a80) h70Var).f8525c, new v71(tzVar, i10));
        lv lvVarA = jvVarA.a("google.afma.response.normalize", cv0.f10089d, w80.f17920l);
        if (((Boolean) vp.f17744a.j()).booleanValue()) {
            bv0VarZzr = zzr(tzVar.f17037g);
            if (bv0VarZzr == null) {
                p7.l0.g("Request contained a PoolKey but no matching parameters were found.");
            }
        } else {
            String str = tzVar.zzj;
            bv0VarZzr = null;
            if (str != null && !str.isEmpty()) {
                p7.l0.g("Request contained a PoolKey but split request is disabled.");
            }
        }
        bv0 bv0Var = bv0VarZzr;
        id1 id1VarD = bv0Var == null ? id1.d(context, 9) : bv0Var.f9664d;
        md1 md1Var = (md1) z70Var.f19107c.zzb();
        md1Var.b(tzVar.f17031a.getStringArrayList("ad_types"));
        jv0 jv0Var = new jv0(tzVar.f17036f, md1Var, id1VarD);
        hv0 hv0Var = new hv0(context, tzVar.f17032b.f32212a, this.f10938g, i10, null);
        cd1 cd1Var = (cd1) z70Var.f19115k.zzb();
        id1 id1VarD2 = id1.d(context, 11);
        zzfno zzfnoVar = zzfno.PRE_PROCESS;
        zzfno zzfnoVar2 = zzfno.HTTP;
        if (bv0Var == null) {
            vc1 vc1VarV2 = V2(tzVar, cd1Var, z70Var);
            vc1 vc1VarW2 = W2(vc1VarV2, cd1Var, jvVarA, md1Var, id1VarD);
            id1 id1VarD3 = id1.d(context, 10);
            vc1 vc1VarF2 = new vu0(cd1Var, zzfnoVar2, Arrays.asList(vc1VarW2, vc1VarV2)).l(new ae0(vc1VarW2, tzVar, vc1VarV2)).a(jv0Var).a(new ld1(id1VarD3)).a(hv0Var).f();
            ni.L(vc1VarF2, md1Var, id1VarD3, false);
            ni.u(vc1VarF2, id1VarD2);
            vc1VarF = new vu0(cd1Var, zzfnoVar, Arrays.asList(vc1VarV2, vc1VarW2, vc1VarF2)).l(new bo0(tzVar, vc1VarF2, vc1VarV2, vc1VarW2, 1)).b(lvVarA).f();
        } else {
            iv0 iv0Var = new iv0(bv0Var.f9662b, bv0Var.f9661a);
            id1 id1VarD4 = id1.d(context, 10);
            vc1 vc1VarF3 = cd1Var.a(ih1.k(iv0Var), zzfnoVar2).a(jv0Var).a(new ld1(id1VarD4)).a(hv0Var).f();
            ni.L(vc1VarF3, md1Var, id1VarD4, false);
            bv1 bv1VarK = ih1.k(bv0Var);
            ni.u(vc1VarF3, id1VarD2);
            vc1VarF = new vu0(cd1Var, zzfnoVar, Arrays.asList(vc1VarF3, bv1VarK)).l(new zu0(vc1VarF3, bv1VarK, 0)).b(lvVarA).f();
        }
        ni.L(vc1VarF, md1Var, id1VarD2, false);
        return vc1VarF;
    }

    @Override // com.google.android.gms.internal.ads.kz
    public final void S(tz tzVar, oz ozVar) {
        Bundle bundle;
        if (((Boolean) n7.y.f31093e.f31096c.b(ao.B2)).booleanValue() && (bundle = tzVar.f17040j) != null) {
            com.bytedance.sdk.component.adexpress.dynamic.dynamicview.b.n(m7.n.C.f30472k, bundle, zzdxh.SERVICE_CONNECTED.a());
        }
        vc1 vc1VarR2 = R2(tzVar, Binder.getCallingUid());
        X2(vc1VarR2, ozVar, tzVar);
        if (((Boolean) op.f15142i.j()).booleanValue()) {
            kv0 kv0Var = this.f10934c;
            Objects.requireNonNull(kv0Var);
            vc1VarR2.g(new dv0(kv0Var, 1), this.f10933b);
        }
    }

    public final com.google.common.util.concurrent.w S2(final tz tzVar, int i10) {
        if (!((Boolean) vp.f17744a.j()).booleanValue()) {
            return ih1.q0(new Exception("Split request is disabled."));
        }
        ac1 ac1Var = tzVar.zzi;
        if (ac1Var == null) {
            return ih1.q0(new Exception("Pool configuration missing from request."));
        }
        if (ac1Var.f8633d == 0 || ac1Var.f8634e == 0) {
            return ih1.q0(new Exception("Caching is disabled."));
        }
        gv gvVar = m7.n.C.f30479r;
        q7.a aVarW = q7.a.w();
        nd1 nd1Var = this.f10937f;
        Context context = this.f10932a;
        jv jvVarA = gvVar.a(context, aVarW, nd1Var);
        h70 h70Var = (h70) this.f10935d;
        h70Var.getClass();
        z70 z70Var = new z70(((a80) h70Var).f8525c, new v71(tzVar, i10));
        cd1 cd1Var = (cd1) z70Var.f19115k.zzb();
        final vc1 vc1VarV2 = V2(tzVar, cd1Var, z70Var);
        md1 md1Var = (md1) z70Var.f19107c.zzb();
        final id1 id1VarD = id1.d(context, 9);
        final vc1 vc1VarW2 = W2(vc1VarV2, cd1Var, jvVarA, md1Var, id1VarD);
        return new vu0(cd1Var, zzfno.GET_URL_AND_CACHE_KEY, Arrays.asList(vc1VarV2, vc1VarW2)).l(new Callable() { // from class: com.google.android.gms.internal.ads.av0
            @Override // java.util.concurrent.Callable
            public final Object call() {
                ev0 ev0Var = this.f9290a;
                com.google.common.util.concurrent.w wVar = vc1VarW2;
                com.google.common.util.concurrent.w wVar2 = vc1VarV2;
                tz tzVar2 = tzVar;
                id1 id1Var = id1VarD;
                ev0Var.getClass();
                String str = ((uz) wVar.get()).f17454i;
                bv0 bv0Var = new bv0((uz) wVar.get(), (JSONObject) wVar2.get(), tzVar2.f17037g, id1Var);
                synchronized (ev0Var) {
                    synchronized (ev0Var) {
                        int iIntValue = ((Long) vp.f17745b.j()).intValue();
                        while (true) {
                            ArrayDeque arrayDeque = ev0Var.f10936e;
                            if (arrayDeque.size() >= iIntValue) {
                                arrayDeque.removeFirst();
                            }
                        }
                    }
                    return new ByteArrayInputStream(str.getBytes(StandardCharsets.UTF_8));
                }
                ev0Var.f10936e.addLast(bv0Var);
                return new ByteArrayInputStream(str.getBytes(StandardCharsets.UTF_8));
            }
        }).f();
    }

    public final com.google.common.util.concurrent.w T2(String str) {
        if (((Boolean) vp.f17744a.j()).booleanValue()) {
            return zzr(str) == null ? ih1.q0(new Exception("URL to be removed not found for cache key: ".concat(String.valueOf(str)))) : ih1.k(new yu0());
        }
        return ih1.q0(new Exception("Split request is disabled."));
    }

    public final com.google.common.util.concurrent.w U2(tz tzVar, int i10) {
        gv gvVar = m7.n.C.f30479r;
        q7.a aVarW = q7.a.w();
        Context context = this.f10932a;
        jv jvVarA = gvVar.a(context, aVarW, this.f10937f);
        if (!((Boolean) zp.f19362a.j()).booleanValue()) {
            return ih1.q0(new Exception("Signal collection disabled."));
        }
        h70 h70Var = (h70) this.f10935d;
        h70Var.getClass();
        v71 v71Var = new v71(tzVar, i10);
        a80 a80Var = ((a80) h70Var).f8525c;
        z70 z70Var = new z70(a80Var, v71Var);
        og2 og2Var = a80Var.S0;
        Context context2 = a80Var.f8523b.f12750b;
        vj1.i(context2);
        Object objZzb = og2Var.zzb();
        j71 j71VarA = z70Var.a();
        a30 a30Var = b30.f9359a;
        vj1.i(a30Var);
        List list = tzVar.f17035e;
        vj1.i(list);
        s71 s71Var = new s71(a30Var, list);
        gg2 gg2VarB = jg2.b(z70Var.f19108d);
        gg2 gg2VarB2 = jg2.b(z70Var.f19109e);
        jg2.b(z70Var.f19110f);
        gg2 gg2VarB3 = jg2.b(z70Var.f19111g);
        gg2 gg2VarB4 = jg2.b(z70Var.f19112h);
        jg2.b(z70Var.f19113i);
        gg2 gg2VarB5 = jg2.b(z70Var.f19114j);
        vj1.i(a30Var);
        og2 og2Var2 = z70Var.f19107c;
        md1 md1Var = (md1) og2Var2.zzb();
        cr0 cr0Var = (cr0) a80Var.f8543l.zzb();
        HashSet hashSet = new HashSet();
        hashSet.add((p71) objZzb);
        hashSet.add(j71VarA);
        hashSet.add(s71Var);
        tn tnVar = ao.C6;
        n7.y yVar = n7.y.f31093e;
        if (((Boolean) yVar.f31096c.b(tnVar)).booleanValue()) {
            hashSet.add((n61) gg2VarB.zzb());
        }
        tn tnVar2 = ao.D6;
        yn ynVar = yVar.f31096c;
        if (((Boolean) ynVar.b(tnVar2)).booleanValue()) {
            hashSet.add((n61) gg2VarB2.zzb());
        }
        if (((Boolean) ynVar.b(ao.F6)).booleanValue()) {
            hashSet.add((n61) gg2VarB3.zzb());
        }
        if (((Boolean) ynVar.b(ao.G6)).booleanValue()) {
            hashSet.add((n61) gg2VarB4.zzb());
        }
        if (((Boolean) ynVar.b(ao.H3)).booleanValue()) {
            hashSet.add((n61) gg2VarB5.zzb());
        }
        p61 p61Var = new p61(context2, a30Var, hashSet, md1Var, cr0Var);
        lv lvVarA = jvVarA.a("google.afma.request.getSignals", za2.f19208j, w80.f17920l);
        id1 id1VarD = id1.d(context, 22);
        cd1 cd1Var = (cd1) z70Var.f19115k.zzb();
        zzfno zzfnoVar = zzfno.GET_SIGNALS;
        Bundle bundle = tzVar.f17031a;
        xc1 xc1VarB = cd1Var.a(ih1.k(bundle), zzfnoVar).a(new ld1(id1VarD)).b(new nv(p61Var, tzVar, 10));
        zzfno zzfnoVar2 = zzfno.JS_SIGNALS;
        vc1 vc1VarF = xc1VarB.f18411e.a(xc1VarB.f(), zzfnoVar2).b(lvVarA).f();
        md1 md1Var2 = (md1) og2Var2.zzb();
        md1Var2.b(bundle.getStringArrayList("ad_types"));
        md1Var2.d(bundle.getBundle("extras"));
        ni.L(vc1VarF, md1Var2, id1VarD, true);
        if (((Boolean) op.f15143j.j()).booleanValue()) {
            kv0 kv0Var = this.f10934c;
            Objects.requireNonNull(kv0Var);
            vc1VarF.g(new dv0(kv0Var, 0), this.f10933b);
        }
        return vc1VarF;
    }

    public final void X2(com.google.common.util.concurrent.w wVar, oz ozVar, tz tzVar) {
        ih1.z1(ih1.e1(wVar, new io0(1), b30.f9359a), new zv1(this, tzVar, ozVar), b30.f9365g);
    }

    @Override // com.google.android.gms.internal.ads.kz
    public final void d1(tz tzVar, oz ozVar) {
        Bundle bundle;
        if (((Boolean) n7.y.f31093e.f31096c.b(ao.B2)).booleanValue() && (bundle = tzVar.f17040j) != null) {
            com.bytedance.sdk.component.adexpress.dynamic.dynamicview.b.n(m7.n.C.f30472k, bundle, zzdxh.SERVICE_CONNECTED.a());
        }
        X2(U2(tzVar, Binder.getCallingUid()), ozVar, tzVar);
    }

    @Override // com.google.android.gms.internal.ads.kz
    public final void zzi(String str) throws RemoteException {
        int callingUid = Binder.getCallingUid();
        tn tnVar = ao.f8992nf;
        n7.y yVar = n7.y.f31093e;
        if (((Boolean) yVar.f31096c.b(tnVar)).booleanValue()) {
            String str2 = (String) yVar.f31096c.b(ao.f9009of);
            if (str2.isEmpty()) {
                return;
            }
            rq1<String> rq1Var = new rq1(ru.c(new kq1(',')), str2);
            p7.l0.g("AdRequestServiceImpl: Preconnecting");
            for (String str3 : rq1Var) {
                Context context = this.f10932a;
                hv0 hv0Var = new hv0(context, str, this.f10938g, callingUid, "HEAD");
                HashMap map = new HashMap();
                map.put(RtspHeaders.USER_AGENT, m7.n.C.f30464c.A(context, str));
                try {
                    gv0 gv0VarA = hv0Var.zza(new fv0(str3, 30000, map, new byte[0], ""));
                    if (gv0VarA.f11893a != 200) {
                        int i10 = gv0VarA.f11893a;
                        StringBuilder sb = new StringBuilder(String.valueOf(i10).length() + 32);
                        sb.append("Unexpected preconnect response: ");
                        sb.append(i10);
                        throw new RemoteException(sb.toString());
                    }
                } catch (Exception e10) {
                    throw new RemoteException(e10.getMessage());
                }
            }
        }
    }
}