package x3;

import F.h0;
import I0.C0290e0;
import android.content.Context;
import android.database.Cursor;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import androidx.media3.exoplayer.analytics.u;
import com.google.crypto.tink.shaded.protobuf.C1256d;
import java.io.IOException;
import java.net.URL;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.concurrent.Executor;
import m3.AbstractC2478m;
import p3.C2721a;
import q3.EnumC2846B;
import q3.I;
import q3.J;
import q3.L;
import q3.m;
import q3.o;
import q3.p;
import q3.q;
import q3.r;
import q3.s;
import q3.t;
import q3.v;
import q3.x;
import r3.i;
import r3.j;
import r3.l;
import r3.n;
import s3.C2909a;
import s3.C2914f;
import s3.InterfaceC2915g;
import u3.C2964a;
import y3.C3265b;
import y3.C3270g;
import y3.InterfaceC3266c;
import y3.InterfaceC3267d;

/* JADX INFO: renamed from: x3.g, reason: case insensitive filesystem */
/* JADX INFO: loaded from: classes.dex */
public final class C3222g {

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

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

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

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

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

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final z3.c f26024f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    public final u4.c f26025g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    public final u4.c f26026h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    public final InterfaceC3266c f26027i;

    public C3222g(Context context, C2914f c2914f, InterfaceC3267d interfaceC3267d, C3218c c3218c, Executor executor, z3.c cVar, u4.c cVar2, u4.c cVar3, InterfaceC3266c interfaceC3266c) {
        this.f26019a = context;
        this.f26020b = c2914f;
        this.f26021c = interfaceC3267d;
        this.f26022d = c3218c;
        this.f26023e = executor;
        this.f26024f = cVar;
        this.f26025g = cVar2;
        this.f26026h = cVar3;
        this.f26027i = interfaceC3266c;
    }

    public final void a(j jVar, int i6) {
        long j4;
        C2909a c2909a;
        String str;
        C2909a c2909a2;
        int i7;
        C1256d c1256dC;
        String str2;
        Integer numValueOf;
        Iterator it;
        t tVar;
        int i8;
        final C3222g c3222g = this;
        final j jVar2 = jVar;
        final int i9 = 1;
        final int i10 = 0;
        InterfaceC2915g interfaceC2915gA = c3222g.f26020b.a(jVar2.f23972a);
        long jMax = 0;
        while (true) {
            z3.b bVar = new z3.b(c3222g) { // from class: x3.e

                /* JADX INFO: renamed from: b, reason: collision with root package name */
                public final /* synthetic */ C3222g f26015b;

                {
                    this.f26015b = c3222g;
                }

                @Override // z3.b
                public final Object b() {
                    Boolean bool;
                    switch (i10) {
                        case 0:
                            j jVar3 = jVar2;
                            C3270g c3270g = (C3270g) this.f26015b.f26021c;
                            SQLiteDatabase sQLiteDatabaseA = c3270g.a();
                            sQLiteDatabaseA.beginTransaction();
                            try {
                                Long lB = C3270g.b(sQLiteDatabaseA, jVar3);
                                if (lB == null) {
                                    bool = Boolean.FALSE;
                                } else {
                                    Cursor cursorRawQuery = c3270g.a().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{lB.toString()});
                                    try {
                                        Boolean boolValueOf = Boolean.valueOf(cursorRawQuery.moveToNext());
                                        cursorRawQuery.close();
                                        bool = boolValueOf;
                                    } catch (Throwable th) {
                                        cursorRawQuery.close();
                                        throw th;
                                    }
                                }
                                sQLiteDatabaseA.setTransactionSuccessful();
                                return bool;
                            } finally {
                                sQLiteDatabaseA.endTransaction();
                            }
                        default:
                            C3270g c3270g2 = (C3270g) this.f26015b.f26021c;
                            c3270g2.getClass();
                            return (Iterable) c3270g2.c(new h0(21, c3270g2, jVar2));
                    }
                }
            };
            C3270g c3270g = (C3270g) c3222g.f26024f;
            if (!((Boolean) c3270g.g(bVar)).booleanValue()) {
                c3270g.g(new u(c3222g, jMax, jVar2));
                return;
            }
            Iterable iterable = (Iterable) c3270g.g(new z3.b(c3222g) { // from class: x3.e

                /* JADX INFO: renamed from: b, reason: collision with root package name */
                public final /* synthetic */ C3222g f26015b;

                {
                    this.f26015b = c3222g;
                }

                @Override // z3.b
                public final Object b() {
                    Boolean bool;
                    switch (i9) {
                        case 0:
                            j jVar3 = jVar2;
                            C3270g c3270g2 = (C3270g) this.f26015b.f26021c;
                            SQLiteDatabase sQLiteDatabaseA = c3270g2.a();
                            sQLiteDatabaseA.beginTransaction();
                            try {
                                Long lB = C3270g.b(sQLiteDatabaseA, jVar3);
                                if (lB == null) {
                                    bool = Boolean.FALSE;
                                } else {
                                    Cursor cursorRawQuery = c3270g2.a().rawQuery("SELECT 1 FROM events WHERE context_id = ? LIMIT 1", new String[]{lB.toString()});
                                    try {
                                        Boolean boolValueOf = Boolean.valueOf(cursorRawQuery.moveToNext());
                                        cursorRawQuery.close();
                                        bool = boolValueOf;
                                    } catch (Throwable th) {
                                        cursorRawQuery.close();
                                        throw th;
                                    }
                                }
                                sQLiteDatabaseA.setTransactionSuccessful();
                                return bool;
                            } finally {
                                sQLiteDatabaseA.endTransaction();
                            }
                        default:
                            C3270g c3270g22 = (C3270g) this.f26015b.f26021c;
                            c3270g22.getClass();
                            return (Iterable) c3270g22.c(new h0(21, c3270g22, jVar2));
                    }
                }
            });
            if (!iterable.iterator().hasNext()) {
                return;
            }
            byte[] bArr = jVar2.f23973b;
            if (interfaceC2915gA == null) {
                AbstractC2478m.g("Uploader", "Unknown backend for %s, deleting event batch for it...", jVar2);
                c2909a2 = new C2909a(3, -1L);
                j4 = jMax;
            } else {
                ArrayList<i> arrayList = new ArrayList();
                Iterator it2 = iterable.iterator();
                while (it2.hasNext()) {
                    arrayList.add(((C3265b) it2.next()).f26187c);
                }
                if ((bArr != null ? i9 : i10) != 0) {
                    InterfaceC3266c interfaceC3266c = c3222g.f26027i;
                    Objects.requireNonNull(interfaceC3266c);
                    C2964a c2964a = (C2964a) c3270g.g(new C3221f(interfaceC3266c, i10));
                    C0290e0 c0290e0 = new C0290e0();
                    c0290e0.f2365g = new HashMap();
                    c0290e0.f2363e = Long.valueOf(c3222g.f26025g.f());
                    c0290e0.f2364f = Long.valueOf(c3222g.f26026h.f());
                    c0290e0.f2360b = "GDT_CLIENT_METRICS";
                    o3.b bVar2 = new o3.b("proto");
                    c2964a.getClass();
                    c0290e0.f2362d = new l(bVar2, n.f23984a.encode(c2964a));
                    arrayList.add(((p3.b) interfaceC2915gA).a(c0290e0.c()));
                }
                p3.b bVar3 = (p3.b) interfaceC2915gA;
                HashMap map = new HashMap();
                for (i iVar : arrayList) {
                    String str3 = iVar.f23962a;
                    if (map.containsKey(str3)) {
                        ((List) map.get(str3)).add(iVar);
                    } else {
                        ArrayList arrayList2 = new ArrayList();
                        arrayList2.add(iVar);
                        map.put(str3, arrayList2);
                    }
                }
                ArrayList arrayList3 = new ArrayList();
                Iterator it3 = map.entrySet().iterator();
                while (it3.hasNext()) {
                    Map.Entry entry = (Map.Entry) it3.next();
                    i iVar2 = (i) ((List) entry.getValue()).get(i10);
                    L l = L.f23631a;
                    long jF = bVar3.f22979f.f();
                    long jF2 = bVar3.f22978e.f();
                    o oVar = new o(new m(Integer.valueOf(iVar2.b("sdk-version")), iVar2.a("model"), iVar2.a("hardware"), iVar2.a("device"), iVar2.a("product"), iVar2.a("os-uild"), iVar2.a("manufacturer"), iVar2.a("fingerprint"), iVar2.a("locale"), iVar2.a("country"), iVar2.a("mcc_mnc"), iVar2.a("application_build")));
                    try {
                        numValueOf = Integer.valueOf(Integer.parseInt((String) entry.getKey()));
                        str2 = null;
                    } catch (NumberFormatException unused) {
                        str2 = (String) entry.getKey();
                        numValueOf = null;
                    }
                    ArrayList arrayList4 = new ArrayList();
                    for (i iVar3 : (List) entry.getValue()) {
                        l lVar = iVar3.f23964c;
                        long j6 = jMax;
                        o3.b bVar4 = lVar.f23981a;
                        boolean zEquals = bVar4.equals(new o3.b("proto"));
                        byte[] bArr2 = lVar.f23982b;
                        if (zEquals) {
                            tVar = new t();
                            tVar.f23704e = bArr2;
                            it = it3;
                        } else {
                            it = it3;
                            if (bVar4.equals(new o3.b("json"))) {
                                String str4 = new String(bArr2, Charset.forName("UTF-8"));
                                t tVar2 = new t();
                                tVar2.f23705f = str4;
                                tVar = tVar2;
                            } else {
                                String strL = AbstractC2478m.l("CctTransportBackend");
                                if (Log.isLoggable(strL, 5)) {
                                    Log.w(strL, "Received event of unsupported encoding " + bVar4 + ". Skipping...");
                                }
                                jMax = j6;
                                it3 = it;
                            }
                        }
                        tVar.f23700a = Long.valueOf(iVar3.f23965d);
                        tVar.f23703d = Long.valueOf(iVar3.f23966e);
                        String str5 = (String) iVar3.f23967f.get("tz-offset");
                        tVar.f23706g = Long.valueOf(str5 == null ? 0L : Long.valueOf(str5).longValue());
                        tVar.f23707h = new x((J) J.f23629a.get(iVar3.b("net-type")), (I) I.f23627a.get(iVar3.b("mobile-subtype")));
                        Integer num = iVar3.f23963b;
                        if (num != null) {
                            tVar.f23701b = num;
                        }
                        Integer num2 = iVar3.f23968g;
                        if (num2 != null) {
                            s sVar = new s(new r(num2));
                            EnumC2846B enumC2846B = EnumC2846B.f23625a;
                            tVar.f23702c = new p(sVar);
                        }
                        byte[] bArr3 = iVar3.f23971j;
                        byte[] bArr4 = iVar3.f23970i;
                        if (bArr4 != null || bArr3 != null) {
                            if (bArr4 == null) {
                                bArr4 = null;
                            }
                            if (bArr3 == null) {
                                bArr3 = null;
                            }
                            tVar.f23708i = new q(bArr4, bArr3);
                        }
                        String strN = tVar.f23700a == null ? " eventTimeMs" : "";
                        if (tVar.f23703d == null) {
                            strN = strN.concat(" eventUptimeMs");
                        }
                        if (tVar.f23706g == null) {
                            strN = Z0.o.n(strN, " timezoneOffsetSeconds");
                        }
                        if (!strN.isEmpty()) {
                            throw new IllegalStateException("Missing required properties:".concat(strN));
                        }
                        arrayList4.add(new q3.u(tVar.f23700a.longValue(), tVar.f23701b, tVar.f23702c, tVar.f23703d.longValue(), tVar.f23704e, tVar.f23705f, tVar.f23706g.longValue(), tVar.f23707h, tVar.f23708i));
                        jMax = j6;
                        it3 = it;
                    }
                    arrayList3.add(new v(jF, jF2, oVar, numValueOf, str2, arrayList4));
                    jMax = jMax;
                    it3 = it3;
                    i10 = 0;
                }
                j4 = jMax;
                q3.n nVar = new q3.n(arrayList3);
                URL urlB = bVar3.f22977d;
                if (bArr != null) {
                    try {
                        C2721a c2721aA = C2721a.a(bArr);
                        str = c2721aA.f22973b;
                        if (str == null) {
                            str = null;
                        }
                        String str6 = c2721aA.f22972a;
                        if (str6 != null) {
                            urlB = p3.b.b(str6);
                        }
                    } catch (IllegalArgumentException unused2) {
                        c2909a = new C2909a(3, -1L);
                    }
                } else {
                    str = null;
                }
                try {
                    o4.f fVar = new o4.f(urlB, nVar, str);
                    K1.b bVar5 = new K1.b(bVar3, 28);
                    int i11 = 5;
                    do {
                        c1256dC = bVar5.c(fVar);
                        URL url = (URL) c1256dC.f13774c;
                        if (url != null) {
                            AbstractC2478m.g("CctTransportBackend", "Following redirect to: %s", url);
                            fVar = new o4.f(url, (q3.n) fVar.f21851d, (String) fVar.f21849b);
                        } else {
                            fVar = null;
                        }
                        if (fVar == null) {
                            break;
                        } else {
                            i11--;
                        }
                    } while (i11 >= 1);
                    int i12 = c1256dC.f13772a;
                    if (i12 == 200) {
                        c2909a2 = new C2909a(1, c1256dC.f13773b);
                    } else {
                        if (i12 >= 500 || i12 == 404) {
                            c2909a = new C2909a(2, -1L);
                        } else if (i12 == 400) {
                            try {
                                c2909a = new C2909a(4, -1L);
                            } catch (IOException e6) {
                                e = e6;
                                AbstractC2478m.i(e, "CctTransportBackend", "Could not make request to the backend");
                                i7 = 2;
                                c2909a2 = new C2909a(2, -1L);
                            }
                        } else {
                            c2909a = new C2909a(3, -1L);
                        }
                        c2909a2 = c2909a;
                    }
                } catch (IOException e7) {
                    e = e7;
                }
            }
            i7 = 2;
            int i13 = c2909a2.f24198a;
            if (i13 == i7) {
                c3270g.g(new com.google.firebase.crashlytics.internal.a(this, iterable, jVar, j4));
                this.f26022d.a(jVar, i6 + 1, true);
                return;
            }
            c3222g = this;
            jVar2 = jVar;
            jMax = j4;
            c3270g.g(new h0(18, c3222g, iterable));
            if (i13 == 1) {
                jMax = Math.max(jMax, c2909a2.f24199b);
                if (bArr != null) {
                    c3270g.g(new K1.b(c3222g, 29));
                }
            } else {
                if (i13 == 4) {
                    HashMap map2 = new HashMap();
                    Iterator it4 = iterable.iterator();
                    while (it4.hasNext()) {
                        String str7 = ((C3265b) it4.next()).f26187c.f23962a;
                        if (map2.containsKey(str7)) {
                            map2.put(str7, Integer.valueOf(((Integer) map2.get(str7)).intValue() + 1));
                        } else {
                            map2.put(str7, 1);
                        }
                    }
                    i8 = 1;
                    c3270g.g(new h0(19, c3222g, map2));
                }
                i9 = i8;
                i10 = 0;
            }
            i8 = 1;
            i9 = i8;
            i10 = 0;
        }
    }
}