package com.google.android.datatransport.cct;

import android.content.Context;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Build;
import android.telephony.TelephonyManager;
import android.util.Log;
import android.util.SparseArray;
import androidx.credentials.CredentialOption;
import androidx.media3.exoplayer.hls.playlist.HlsMediaPlaylist;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import com.google.android.datatransport.cct.b;
import com.google.android.datatransport.runtime.e;
import com.strmr.ps.data.repository.ScreenConfigRepository;
import defpackage.bv2;
import defpackage.c91;
import defpackage.g11;
import defpackage.hr3;
import defpackage.jm7;
import defpackage.kj;
import defpackage.mq1;
import defpackage.mv9;
import defpackage.n41;
import defpackage.nl2;
import defpackage.ol2;
import defpackage.ps2;
import defpackage.qy4;
import defpackage.r00;
import defpackage.r11;
import defpackage.rk6;
import defpackage.sg5;
import defpackage.th5;
import defpackage.u80;
import defpackage.wg5;
import defpackage.wu2;
import defpackage.x50;
import defpackage.xg5;
import defpackage.xp0;
import defpackage.y50;
import defpackage.zk2;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.UnknownHostException;
import java.nio.charset.Charset;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;

/* JADX INFO: loaded from: classes.dex */
final class b implements mv9 {
    public final mq1 a;
    public final ConnectivityManager b;
    public final Context c;
    public final URL d;
    public final r11 e;
    public final r11 f;
    public final int g;

    public static final class a {
        public final URL a;
        public final u80 b;
        public final String c;

        public a(URL url, u80 u80Var, String str) {
            this.a = url;
            this.b = u80Var;
            this.c = str;
        }
    }

    /* JADX INFO: renamed from: com.google.android.datatransport.cct.b$b, reason: collision with other inner class name */
    public static final class C0084b {
        public final int a;
        public final URL b;
        public final long c;

        public C0084b(int i, URL url, long j) {
            this.a = i;
            this.b = url;
            this.c = j;
        }
    }

    public b(Context context, r11 r11Var, r11 r11Var2) {
        qy4 qy4Var = new qy4();
        r00.a.a(qy4Var);
        qy4Var.d = true;
        this.a = qy4Var.a();
        this.c = context;
        this.b = (ConnectivityManager) context.getSystemService("connectivity");
        this.d = c(xp0.c);
        this.e = r11Var2;
        this.f = r11Var;
        this.g = 130000;
    }

    public static URL c(String str) {
        try {
            return new URL(str);
        } catch (MalformedURLException e) {
            throw new IllegalArgumentException(n41.n("Invalid url: ", str), e);
        }
    }

    /* JADX WARN: Can't wrap try/catch for region: R(13:0|2|(1:4)(1:5)|6|(1:8)(9:10|(1:12)(2:13|(0))|15|(1:18)|19|26|20|24|25)|9|15|(0)|19|26|20|24|25) */
    /* JADX WARN: Code restructure failed: missing block: B:22:0x00f5, code lost:
    
        r0 = move-exception;
     */
    /* JADX WARN: Code restructure failed: missing block: B:23:0x00f6, code lost:
    
        defpackage.th5.b("CctTransportBackend", "Unable to find version code for package", r0);
     */
    /* JADX WARN: Removed duplicated region for block: B:18:0x00df  */
    @Override // defpackage.mv9
    /*
        Code decompiled incorrectly, please refer to instructions dump.
    */
    public final e a(e eVar) {
        int type;
        int subtype;
        String simOperator;
        NetworkInfo activeNetworkInfo = this.b.getActiveNetworkInfo();
        e.a aVarN = eVar.n();
        ((HashMap) aVarN.c()).put("sdk-version", String.valueOf(Build.VERSION.SDK_INT));
        aVarN.a("model", Build.MODEL);
        aVarN.a("hardware", Build.HARDWARE);
        aVarN.a("device", Build.DEVICE);
        aVarN.a("product", Build.PRODUCT);
        aVarN.a("os-uild", Build.ID);
        aVarN.a("manufacturer", Build.MANUFACTURER);
        aVarN.a("fingerprint", Build.FINGERPRINT);
        Calendar.getInstance();
        aVarN.c().put("tz-offset", String.valueOf(TimeZone.getDefault().getOffset(Calendar.getInstance().getTimeInMillis()) / 1000));
        int i = -1;
        if (activeNetworkInfo == null) {
            SparseArray sparseArray = rk6.c.a;
            type = -1;
        } else {
            type = activeNetworkInfo.getType();
        }
        ((HashMap) aVarN.c()).put("net-type", String.valueOf(type));
        if (activeNetworkInfo != null) {
            subtype = activeNetworkInfo.getSubtype();
            if (subtype == -1) {
                SparseArray sparseArray2 = rk6.b.a;
                subtype = 100;
            } else if (((rk6.b) rk6.b.a.get(subtype)) == null) {
            }
            ((HashMap) aVarN.c()).put("mobile-subtype", String.valueOf(subtype));
            aVarN.a("country", Locale.getDefault().getCountry());
            aVarN.a("locale", Locale.getDefault().getLanguage());
            Context context = this.c;
            simOperator = ((TelephonyManager) context.getSystemService("phone")).getSimOperator();
            if (simOperator == null) {
                simOperator = "";
            }
            aVarN.a("mcc_mnc", simOperator);
            i = context.getPackageManager().getPackageInfo(context.getPackageName(), 0).versionCode;
            aVarN.a("application_build", Integer.toString(i));
            return aVarN.b();
        }
        SparseArray sparseArray3 = rk6.b.a;
        subtype = 0;
        ((HashMap) aVarN.c()).put("mobile-subtype", String.valueOf(subtype));
        aVarN.a("country", Locale.getDefault().getCountry());
        aVarN.a("locale", Locale.getDefault().getLanguage());
        Context context2 = this.c;
        simOperator = ((TelephonyManager) context2.getSystemService("phone")).getSimOperator();
        if (simOperator == null) {
        }
        aVarN.a("mcc_mnc", simOperator);
        i = context2.getPackageManager().getPackageInfo(context2.getPackageName(), 0).versionCode;
        aVarN.a("application_build", Integer.toString(i));
        return aVarN.b();
    }

    /* JADX WARN: Type inference failed for: r0v5, types: [com.google.android.datatransport.cct.a] */
    @Override // defpackage.mv9
    public final y50 b(x50 x50Var) {
        int i;
        String str;
        Object objA;
        sg5.a aVarK;
        HashMap map = new HashMap();
        for (e eVar : x50Var.b()) {
            String strL = eVar.l();
            if (map.containsKey(strL)) {
                ((List) map.get(strL)).add(eVar);
            } else {
                ArrayList arrayList = new ArrayList();
                arrayList.add(eVar);
                map.put(strL, arrayList);
            }
        }
        ArrayList arrayList2 = new ArrayList();
        Iterator it = map.entrySet().iterator();
        while (true) {
            i = 5;
            if (!it.hasNext()) {
                break;
            }
            Map.Entry entry = (Map.Entry) it.next();
            e eVar2 = (e) ((List) entry.getValue()).get(0);
            wg5.a aVarA = wg5.a();
            jm7 jm7Var = jm7.a;
            aVarA.f();
            aVarA.g(this.f.a());
            aVarA.h(this.e.a());
            g11.a aVarA2 = g11.a();
            aVarA2.c();
            kj.a aVarA3 = kj.a();
            aVarA3.m(Integer.valueOf(eVar2.i("sdk-version")));
            aVarA3.j(eVar2.b("model"));
            aVarA3.f(eVar2.b("hardware"));
            aVarA3.d(eVar2.b("device"));
            aVarA3.l(eVar2.b("product"));
            aVarA3.k(eVar2.b("os-uild"));
            aVarA3.h(eVar2.b("manufacturer"));
            aVarA3.e(eVar2.b("fingerprint"));
            aVarA3.c(eVar2.b("country"));
            aVarA3.g(eVar2.b("locale"));
            aVarA3.i(eVar2.b("mcc_mnc"));
            aVarA3.b(eVar2.b("application_build"));
            aVarA2.b(aVarA3.a());
            aVarA.b(aVarA2.a());
            try {
                aVarA.d(Integer.valueOf(Integer.parseInt((String) entry.getKey())));
            } catch (NumberFormatException unused) {
                aVarA.e((String) entry.getKey());
            }
            ArrayList arrayList3 = new ArrayList();
            for (e eVar3 : (List) entry.getValue()) {
                zk2 zk2VarE = eVar3.e();
                nl2 nl2Var = zk2VarE.a;
                byte[] bArr = zk2VarE.b;
                if (nl2Var.equals(new nl2("proto"))) {
                    aVarK = sg5.k(bArr);
                } else if (nl2Var.equals(new nl2("json"))) {
                    aVarK = sg5.j(new String(bArr, Charset.forName("UTF-8")));
                } else {
                    String strConcat = "TRuntime.".concat("CctTransportBackend");
                    if (Log.isLoggable(strConcat, 5)) {
                        Log.w(strConcat, "Received event of unsupported encoding " + nl2Var + ". Skipping...");
                    }
                }
                aVarK.d(eVar3.f());
                aVarK.e(eVar3.m());
                String str2 = (String) eVar3.c().get("tz-offset");
                aVarK.h(str2 == null ? 0L : Long.valueOf(str2).longValue());
                rk6.a aVarA4 = rk6.a();
                aVarA4.c((rk6.c) rk6.c.a.get(eVar3.i("net-type")));
                aVarA4.b((rk6.b) rk6.b.a.get(eVar3.i("mobile-subtype")));
                aVarK.g(aVarA4.a());
                if (eVar3.d() != null) {
                    aVarK.c(eVar3.d());
                }
                if (eVar3.j() != null) {
                    c91.a aVarA5 = c91.a();
                    bv2.a aVarA6 = bv2.a();
                    wu2.a aVarA7 = wu2.a();
                    aVarA7.b(eVar3.j());
                    aVarA6.b(aVarA7.a());
                    aVarA5.b(aVarA6.a());
                    c91.b bVar = c91.b.a;
                    aVarA5.c();
                    aVarK.b(aVarA5.a());
                }
                if (eVar3.g() != null || eVar3.h() != null) {
                    ps2.a aVarA8 = ps2.a();
                    if (eVar3.g() != null) {
                        aVarA8.b(eVar3.g());
                    }
                    if (eVar3.h() != null) {
                        aVarA8.c(eVar3.h());
                    }
                    aVarK.f(aVarA8.a());
                }
                arrayList3.add(aVarK.a());
            }
            aVarA.c(arrayList3);
            arrayList2.add(aVarA.a());
        }
        u80 u80VarA = u80.a(arrayList2);
        byte[] bArrC = x50Var.c();
        URL urlC = this.d;
        if (bArrC != null) {
            try {
                xp0 xp0VarB = xp0.b(x50Var.c());
                str = xp0VarB.b;
                if (str == null) {
                    str = null;
                }
                String str3 = xp0VarB.a;
                if (str3 != null) {
                    urlC = c(str3);
                }
            } catch (IllegalArgumentException unused2) {
                return y50.a();
            }
        } else {
            str = null;
        }
        try {
            a aVar = new a(urlC, u80VarA, str);
            ?? r0 = new hr3() { // from class: com.google.android.datatransport.cct.a
                public final Object a(Object obj) {
                    b.a aVar2 = (b.a) obj;
                    URL url = aVar2.a;
                    if (Log.isLoggable("TRuntime.".concat("CctTransportBackend"), 4)) {
                        String.format("Making request to: %s", url);
                    }
                    HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
                    httpURLConnection.setConnectTimeout(30000);
                    b bVar2 = this.a;
                    httpURLConnection.setReadTimeout(bVar2.g);
                    httpURLConnection.setDoOutput(true);
                    httpURLConnection.setInstanceFollowRedirects(false);
                    httpURLConnection.setRequestMethod(HlsMediaPlaylist.Interstitial.CUE_TRIGGER_POST);
                    httpURLConnection.setRequestProperty(RtspHeaders.USER_AGENT, "datatransport/3.3.0 android/");
                    httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_ENCODING, "gzip");
                    httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_TYPE, "application/json");
                    httpURLConnection.setRequestProperty("Accept-Encoding", "gzip");
                    String str4 = aVar2.c;
                    if (str4 != null) {
                        httpURLConnection.setRequestProperty("X-Goog-Api-Key", str4);
                    }
                    try {
                        OutputStream outputStream = httpURLConnection.getOutputStream();
                        try {
                            GZIPOutputStream gZIPOutputStream = new GZIPOutputStream(outputStream);
                            try {
                                bVar2.a.a(new BufferedWriter(new OutputStreamWriter(gZIPOutputStream)), aVar2.b);
                                gZIPOutputStream.close();
                                if (outputStream != null) {
                                    outputStream.close();
                                }
                                int responseCode = httpURLConnection.getResponseCode();
                                Integer numValueOf = Integer.valueOf(responseCode);
                                if (Log.isLoggable("TRuntime.".concat("CctTransportBackend"), 4)) {
                                    String.format("Status Code: %d", numValueOf);
                                }
                                th5.a("CctTransportBackend", "Content-Type: %s", httpURLConnection.getHeaderField(RtspHeaders.CONTENT_TYPE));
                                th5.a("CctTransportBackend", "Content-Encoding: %s", httpURLConnection.getHeaderField(RtspHeaders.CONTENT_ENCODING));
                                if (responseCode == 302 || responseCode == 301 || responseCode == 307) {
                                    return new b.C0084b(responseCode, new URL(httpURLConnection.getHeaderField(RtspHeaders.LOCATION)), 0L);
                                }
                                if (responseCode != 200) {
                                    return new b.C0084b(responseCode, null, 0L);
                                }
                                InputStream inputStream = httpURLConnection.getInputStream();
                                try {
                                    InputStream gZIPInputStream = "gzip".equals(httpURLConnection.getHeaderField(RtspHeaders.CONTENT_ENCODING)) ? new GZIPInputStream(inputStream) : inputStream;
                                    try {
                                        b.C0084b c0084b = new b.C0084b(responseCode, null, xg5.a(new BufferedReader(new InputStreamReader(gZIPInputStream))).b());
                                        if (gZIPInputStream != null) {
                                            gZIPInputStream.close();
                                        }
                                        if (inputStream != null) {
                                            inputStream.close();
                                        }
                                        return c0084b;
                                    } finally {
                                    }
                                } finally {
                                }
                            } finally {
                            }
                        } finally {
                        }
                    } catch (ConnectException e) {
                        e = e;
                        th5.b("CctTransportBackend", "Couldn't open connection, returning with 500", e);
                        return new b.C0084b(CredentialOption.PRIORITY_OIDC_OR_SIMILAR, null, 0L);
                    } catch (UnknownHostException e2) {
                        e = e2;
                        th5.b("CctTransportBackend", "Couldn't open connection, returning with 500", e);
                        return new b.C0084b(CredentialOption.PRIORITY_OIDC_OR_SIMILAR, null, 0L);
                    } catch (IOException e3) {
                        e = e3;
                        th5.b("CctTransportBackend", "Couldn't encode request, returning with 400", e);
                        return new b.C0084b(ScreenConfigRepository.MAX_ROWS_PER_PROFILE, null, 0L);
                    } catch (ol2 e4) {
                        e = e4;
                        th5.b("CctTransportBackend", "Couldn't encode request, returning with 400", e);
                        return new b.C0084b(ScreenConfigRepository.MAX_ROWS_PER_PROFILE, null, 0L);
                    }
                }
            };
            do {
                objA = r0.a(aVar);
                URL url = ((C0084b) objA).b;
                if (url != null) {
                    th5.a("CctTransportBackend", "Following redirect to: %s", url);
                    aVar = new a(url, aVar.b, aVar.c);
                } else {
                    aVar = null;
                }
                if (aVar == null) {
                    break;
                }
                i--;
            } while (i >= 1);
            C0084b c0084b = (C0084b) objA;
            int i2 = c0084b.a;
            if (i2 == 200) {
                return y50.e(c0084b.c);
            }
            if (i2 < 500 && i2 != 404) {
                return i2 == 400 ? y50.d() : y50.a();
            }
            return y50.f();
        } catch (IOException e) {
            th5.b("CctTransportBackend", "Could not make request to the backend", e);
            return y50.f();
        }
    }
}