package com.google.ads.interactivemedia.v3.internal;

import android.content.Context;
import androidx.annotation.Nullable;
import androidx.annotation.WorkerThread;
import com.google.ads.interactivemedia.v3.api.signals.SecureSignalsAdapter;
import defpackage.e;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;
import w8.h;
import w8.i;
import w8.j;
import w8.k;
import w8.t;

/* JADX INFO: loaded from: classes2.dex */
public final class zzgd {
    private final List zza = new ArrayList(0);
    private final i zzb = new i();
    private final i zzc = new i();
    private final Context zzd;
    private final ExecutorService zze;
    private final zzfd zzf;

    @Nullable
    private Integer zzg;

    public zzgd(Context context, ExecutorService executorService, zzfd zzfdVar) {
        this.zzd = context;
        this.zze = executorService;
        this.zzf = zzfdVar;
    }

    public static /* synthetic */ h zza(zzgd zzgdVar, h hVar) {
        final List list = (List) hVar.g();
        return k.whenAllComplete(list).e(zzgdVar.zze, new w8.b() { // from class: com.google.ads.interactivemedia.v3.internal.zzfw
            @Override // w8.b
            public final Object then(h hVar2) {
                return list;
            }
        });
    }

    public static /* synthetic */ Void zzd(zzgd zzgdVar, h hVar) {
        zzgdVar.zzc.trySetResult(zzgdVar.zza);
        return null;
    }

    private final void zzi(com.google.ads.interactivemedia.v3.impl.data.zzbq zzbqVar, Exception exc) {
        this.zzf.zzg(com.google.ads.interactivemedia.v3.impl.data.zzbp.NATIVE_ESP, zzbqVar, exc);
    }

    private final void zzj(zzft zzftVar) {
        this.zza.remove(zzftVar);
    }

    private static final Exception zzk(zzft zzftVar, Exception exc) {
        return new Exception(e.k("Exception with SecureSignalsAdapter ", zzftVar.zze(), ":", zzftVar.zzf()), exc);
    }

    public final h zzb() {
        this.zzb.f34224a.e(this.zze, new w8.b() { // from class: com.google.ads.interactivemedia.v3.internal.zzgb
            @Override // w8.b
            public final Object then(h hVar) {
                List<zzft> list = (List) hVar.g();
                ArrayList arrayList = new ArrayList(list.size());
                for (final zzft zzftVar : list) {
                    final zzgd zzgdVar = this.zza;
                    h hVarZzc = zzftVar.zzc();
                    w8.e eVar = new w8.e() { // from class: com.google.ads.interactivemedia.v3.internal.zzfv
                        @Override // w8.e
                        public final void onFailure(Exception exc) {
                            zzgdVar.zzh(zzftVar, exc);
                        }
                    };
                    t tVar = (t) hVarZzc;
                    tVar.getClass();
                    tVar.c(j.f34225a, eVar);
                    arrayList.add(hVarZzc);
                }
                return arrayList;
            }
        }).f(this.zze, new zzfy(this)).e(this.zze, new zzfz(this)).e(this.zze, new w8.b() { // from class: com.google.ads.interactivemedia.v3.internal.zzgc
            @Override // w8.b
            public final Object then(h hVar) {
                zzgd.zzd(this.zza, hVar);
                return null;
            }
        });
        return this.zzc.f34224a;
    }

    @WorkerThread
    public final h zzc(@Nullable List list, @Nullable Integer num) {
        if (num.intValue() == 0) {
            this.zzb.b(new Exception("No adapters to load"));
            return this.zzb.f34224a;
        }
        this.zzg = num;
        Iterator it = list.iterator();
        while (it.hasNext()) {
            String str = (String) it.next();
            zzft zzftVar = null;
            try {
                Class<?> cls = Class.forName(str, false, zzgd.class.getClassLoader());
                Class<?>[] interfaces = cls.getInterfaces();
                String name = SecureSignalsAdapter.class.getName();
                int length = interfaces.length;
                int i10 = 0;
                while (true) {
                    if (i10 >= length) {
                        break;
                    }
                    if (interfaces[i10].getName().equals(name)) {
                        zzftVar = new zzft((SecureSignalsAdapter) cls.getDeclaredConstructor(new Class[0]).newInstance(new Object[0]), str, this.zzd);
                        break;
                    }
                    i10++;
                }
            } catch (Throwable unused) {
            }
            if (zzftVar != null) {
                try {
                    this.zza.add(zzftVar);
                } catch (Exception e10) {
                    zzi(com.google.ads.interactivemedia.v3.impl.data.zzbq.LOAD_ADAPTER, new Exception("Exception with SecureSignalsAdapter ".concat(String.valueOf(str)), e10));
                }
            }
        }
        this.zzb.trySetResult(this.zza);
        return this.zzb.f34224a;
    }

    @WorkerThread
    public final List zze() {
        t tVarF;
        try {
            t tVarE = this.zzc.f34224a.e(this.zze, new w8.b() { // from class: com.google.ads.interactivemedia.v3.internal.zzfx
                @Override // w8.b
                public final Object then(h hVar) {
                    List<zzft> list = (List) hVar.g();
                    ArrayList arrayList = new ArrayList(list.size());
                    for (final zzft zzftVar : list) {
                        final zzgd zzgdVar = this.zza;
                        h hVarZzb = zzftVar.zzb();
                        w8.e eVar = new w8.e() { // from class: com.google.ads.interactivemedia.v3.internal.zzfu
                            @Override // w8.e
                            public final void onFailure(Exception exc) {
                                zzgdVar.zzg(zzftVar, exc);
                            }
                        };
                        t tVar = (t) hVarZzb;
                        tVar.getClass();
                        tVar.c(j.f34225a, eVar);
                        arrayList.add(tVar);
                    }
                    return arrayList;
                }
            }).f(this.zze, new zzfy(this)).e(this.zze, new zzfz(this));
            if (this.zzg == null) {
                tVarF = k.e(new ArrayList());
            } else {
                tVarF = k.f(tVarE, r1.intValue(), TimeUnit.MILLISECONDS);
                w8.e eVar = new w8.e() { // from class: com.google.ads.interactivemedia.v3.internal.zzga
                    @Override // w8.e
                    public final void onFailure(Exception exc) {
                        this.zza.zzf(exc);
                    }
                };
                tVarF.getClass();
                tVarF.c(j.f34225a, eVar);
            }
            return (List) k.a(tVarF);
        } catch (InterruptedException | ExecutionException unused) {
            return new ArrayList();
        }
    }

    public final /* synthetic */ void zzf(Exception exc) {
        zzi(com.google.ads.interactivemedia.v3.impl.data.zzbq.COLLECT_SIGNALS, exc);
    }

    public final /* synthetic */ void zzg(zzft zzftVar, Exception exc) {
        zzj(zzftVar);
        zzi(com.google.ads.interactivemedia.v3.impl.data.zzbq.COLLECT_SIGNALS, zzk(zzftVar, exc));
    }

    public final /* synthetic */ void zzh(zzft zzftVar, Exception exc) {
        zzj(zzftVar);
        zzi(com.google.ads.interactivemedia.v3.impl.data.zzbq.INIT, zzk(zzftVar, exc));
    }
}