package com.google.android.datatransport.runtime.scheduling.jobscheduling;

import android.content.Context;
import com.google.android.datatransport.runtime.e;
import com.google.android.datatransport.runtime.j;
import com.google.android.datatransport.runtime.scheduling.jobscheduling.Uploader;
import defpackage.e11;
import defpackage.f67;
import defpackage.h11;
import defpackage.hq2;
import defpackage.jna;
import defpackage.kta;
import defpackage.mv9;
import defpackage.nl2;
import defpackage.q36;
import defpackage.r11;
import defpackage.rk7;
import defpackage.s86;
import defpackage.th5;
import defpackage.v50;
import defpackage.w75;
import defpackage.wg9;
import defpackage.wl1;
import defpackage.x50;
import defpackage.y50;
import defpackage.z32;
import defpackage.zk2;
import defpackage.zk7;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Objects;
import java.util.concurrent.Executor;
import javax.inject.Inject;

/* JADX INFO: loaded from: classes.dex */
public class Uploader {
    public final Context a;
    public final v50 b;
    public final hq2 c;
    public final kta d;
    public final Executor e;
    public final wg9 f;
    public final r11 g;
    public final r11 h;
    public final e11 i;

    @Inject
    public Uploader(Context context, v50 v50Var, hq2 hq2Var, kta ktaVar, Executor executor, wg9 wg9Var, @jna r11 r11Var, @s86 r11 r11Var2, e11 e11Var) {
        this.a = context;
        this.b = v50Var;
        this.c = hq2Var;
        this.d = ktaVar;
        this.e = executor;
        this.f = wg9Var;
        this.g = r11Var;
        this.h = r11Var2;
        this.i = e11Var;
    }

    public final void a(final j jVar, int i) {
        y50 y50VarB;
        mv9 mv9VarE = this.b.e(jVar.b());
        long jMax = 0;
        y50.e(0L);
        while (true) {
            final int i2 = 0;
            wg9.a aVar = new wg9.a(this) { // from class: r9a
                public final /* synthetic */ Uploader b;

                {
                    this.b = this;
                }

                @Override // wg9.a
                public final Object execute() {
                    switch (i2) {
                        case 0:
                            return Boolean.valueOf(this.b.c.ar(jVar));
                        default:
                            return this.b.c.be(jVar);
                    }
                }
            };
            wg9 wg9Var = this.f;
            if (!((Boolean) wg9Var.b(aVar)).booleanValue()) {
                wg9Var.b(new wl1(this, jMax, jVar));
                return;
            }
            final int i3 = 1;
            Iterable iterable = (Iterable) wg9Var.b(new wg9.a(this) { // from class: r9a
                public final /* synthetic */ Uploader b;

                {
                    this.b = this;
                }

                @Override // wg9.a
                public final Object execute() {
                    switch (i3) {
                        case 0:
                            return Boolean.valueOf(this.b.c.ar(jVar));
                        default:
                            return this.b.c.be(jVar);
                    }
                }
            });
            if (!iterable.iterator().hasNext()) {
                return;
            }
            if (mv9VarE == null) {
                th5.a("Uploader", "Unknown backend for %s, deleting event batch for it...", jVar);
                y50VarB = y50.a();
            } else {
                ArrayList arrayList = new ArrayList();
                Iterator it = iterable.iterator();
                while (it.hasNext()) {
                    arrayList.add(((f67) it.next()).a());
                }
                if (jVar.c() != null) {
                    e11 e11Var = this.i;
                    Objects.requireNonNull(e11Var);
                    h11 h11Var = (h11) wg9Var.b(new q36(e11Var, 17));
                    e.a aVarA = e.a();
                    aVarA.f(this.g.a());
                    aVarA.l(this.h.a());
                    aVarA.k("GDT_CLIENT_METRICS");
                    nl2 nl2Var = new nl2("proto");
                    h11Var.getClass();
                    zk7 zk7Var = rk7.a;
                    zk7Var.getClass();
                    ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream();
                    try {
                        zk7Var.a(h11Var, byteArrayOutputStream);
                    } catch (IOException unused) {
                    }
                    aVarA.e(new zk2(nl2Var, byteArrayOutputStream.toByteArray()));
                    arrayList.add(mv9VarE.a(aVarA.b()));
                }
                x50.a aVarA2 = x50.a();
                aVarA2.b(arrayList);
                aVarA2.c(jVar.c());
                y50VarB = mv9VarE.b(aVarA2.a());
            }
            if (y50VarB.c() == y50.a.b) {
                wg9Var.b(new z32(this, iterable, jVar, jMax));
                this.d.b(jVar, i + 1, true);
                return;
            }
            wg9Var.b(new w75(this, iterable, 17));
            if (y50VarB.c() == y50.a.a) {
                jMax = Math.max(jMax, y50VarB.b());
                if (jVar.c() != null) {
                    wg9Var.b(new q36(this, 19));
                }
            } else if (y50VarB.c() == y50.a.d) {
                HashMap map = new HashMap();
                Iterator it2 = iterable.iterator();
                while (it2.hasNext()) {
                    String strL = ((f67) it2.next()).a().l();
                    if (map.containsKey(strL)) {
                        map.put(strL, Integer.valueOf(((Integer) map.get(strL)).intValue() + 1));
                    } else {
                        map.put(strL, 1);
                    }
                }
                wg9Var.b(new w75(this, map, 18));
            }
        }
    }
}