package com.google.android.datatransport.cct;

import android.content.Context;
import android.content.pm.PackageManager;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Build;
import android.telephony.TelephonyManager;
import android.util.Log;
import androidx.media3.exoplayer.hls.playlist.HlsMediaPlaylist;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import com.bumptech.glide.g;
import com.google.android.datatransport.cct.internal.NetworkConnectionInfo$MobileSubtype;
import com.google.android.datatransport.cct.internal.NetworkConnectionInfo$NetworkType;
import com.google.firebase.encoders.EncodingException;
import defpackage.e;
import e.y;
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.util.Calendar;
import java.util.Locale;
import java.util.Map;
import java.util.TimeZone;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
import l.b0;
import tv.danmaku.ijk.media.player.IjkEventListener;
import u6.i;
import u6.s;
import v6.q;
import w6.n;

/* JADX INFO: loaded from: classes2.dex */
public final class d implements n {

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

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

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

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

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final e7.a f7731e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final e7.a f7732f;

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

    public d(Context context, e7.a aVar, e7.a aVar2) {
        cb.d dVar = new cb.d();
        i.f33298a.a(dVar);
        dVar.f4951d = true;
        this.f7727a = new y(dVar);
        this.f7729c = context;
        this.f7728b = (ConnectivityManager) context.getSystemService("connectivity");
        this.f7730d = d(a.f7718b);
        this.f7731e = aVar2;
        this.f7732f = aVar;
        this.f7733g = 130000;
    }

    public static b a(b bVar, c cVar) {
        URL url = cVar.redirectUrl;
        if (url == null) {
            return null;
        }
        g.c("CctTransportBackend", "Following redirect to: %s", url);
        return new b(cVar.redirectUrl, bVar.f7724b, bVar.apiKey);
    }

    public static c b(d dVar, b bVar) throws IOException {
        dVar.getClass();
        URL url = bVar.f7723a;
        if (Log.isLoggable(g.k("CctTransportBackend"), 4)) {
            String.format("Making request to: %s", url);
        }
        HttpURLConnection httpURLConnection = (HttpURLConnection) bVar.f7723a.openConnection();
        httpURLConnection.setConnectTimeout(30000);
        httpURLConnection.setReadTimeout(dVar.f7733g);
        httpURLConnection.setDoOutput(true);
        httpURLConnection.setInstanceFollowRedirects(false);
        httpURLConnection.setRequestMethod(HlsMediaPlaylist.Interstitial.CUE_TRIGGER_POST);
        httpURLConnection.setRequestProperty(RtspHeaders.USER_AGENT, String.format("datatransport/%s android/", "3.1.9"));
        httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_ENCODING, "gzip");
        httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_TYPE, "application/json");
        httpURLConnection.setRequestProperty("Accept-Encoding", "gzip");
        String str = bVar.apiKey;
        if (str != null) {
            httpURLConnection.setRequestProperty("X-Goog-Api-Key", str);
        }
        try {
            OutputStream outputStream = httpURLConnection.getOutputStream();
            try {
                GZIPOutputStream gZIPOutputStream = new GZIPOutputStream(outputStream);
                try {
                    dVar.f7727a.l(new BufferedWriter(new OutputStreamWriter(gZIPOutputStream)), bVar.f7724b);
                    gZIPOutputStream.close();
                    if (outputStream != null) {
                        outputStream.close();
                    }
                    int responseCode = httpURLConnection.getResponseCode();
                    Integer numValueOf = Integer.valueOf(responseCode);
                    if (Log.isLoggable(g.k("CctTransportBackend"), 4)) {
                        String.format("Status Code: %d", numValueOf);
                    }
                    g.c("CctTransportBackend", "Content-Type: %s", httpURLConnection.getHeaderField(RtspHeaders.CONTENT_TYPE));
                    g.c("CctTransportBackend", "Content-Encoding: %s", httpURLConnection.getHeaderField(RtspHeaders.CONTENT_ENCODING));
                    if (responseCode == 302 || responseCode == 301 || responseCode == 307) {
                        return new c(responseCode, new URL(httpURLConnection.getHeaderField(RtspHeaders.LOCATION)), 0L);
                    }
                    if (responseCode != 200) {
                        return new c(responseCode, null, 0L);
                    }
                    InputStream inputStream = httpURLConnection.getInputStream();
                    try {
                        InputStream gZIPInputStream = "gzip".equals(httpURLConnection.getHeaderField(RtspHeaders.CONTENT_ENCODING)) ? new GZIPInputStream(inputStream) : inputStream;
                        try {
                            c cVar = new c(responseCode, null, s.a(new BufferedReader(new InputStreamReader(gZIPInputStream))).f33356a);
                            if (gZIPInputStream != null) {
                                gZIPInputStream.close();
                            }
                            if (inputStream != null) {
                                inputStream.close();
                            }
                            return cVar;
                        } finally {
                        }
                    } catch (Throwable th) {
                        if (inputStream != null) {
                            try {
                                inputStream.close();
                            } catch (Throwable th2) {
                                th.addSuppressed(th2);
                            }
                        }
                        throw th;
                    }
                } finally {
                }
            } catch (Throwable th3) {
                if (outputStream != null) {
                    try {
                        outputStream.close();
                    } catch (Throwable th4) {
                        th3.addSuppressed(th4);
                    }
                }
                throw th3;
            }
        } catch (EncodingException | IOException unused) {
            g.k("CctTransportBackend");
            return new c(IjkEventListener.VIDEO_SIZE_CHANGED, null, 0L);
        } catch (ConnectException | UnknownHostException unused2) {
            g.k("CctTransportBackend");
            return new c(IjkEventListener.BUFFERING_START, null, 0L);
        }
    }

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

    public final v6.i c(q qVar) {
        int subtype;
        NetworkInfo activeNetworkInfo = this.f7728b.getActiveNetworkInfo();
        b0 b0VarC = qVar.c();
        int i10 = Build.VERSION.SDK_INT;
        Map map = (Map) b0VarC.f29644f;
        if (map == null) {
            throw new IllegalStateException("Property \"autoMetadata\" has not been set");
        }
        map.put("sdk-version", String.valueOf(i10));
        b0VarC.a("model", Build.MODEL);
        b0VarC.a("hardware", Build.HARDWARE);
        b0VarC.a("device", Build.DEVICE);
        b0VarC.a("product", Build.PRODUCT);
        b0VarC.a("os-uild", Build.ID);
        b0VarC.a("manufacturer", Build.MANUFACTURER);
        b0VarC.a("fingerprint", Build.FINGERPRINT);
        Calendar.getInstance();
        long offset = TimeZone.getDefault().getOffset(Calendar.getInstance().getTimeInMillis()) / 1000;
        Map map2 = (Map) b0VarC.f29644f;
        if (map2 == null) {
            throw new IllegalStateException("Property \"autoMetadata\" has not been set");
        }
        map2.put("tz-offset", String.valueOf(offset));
        int iA = activeNetworkInfo == null ? NetworkConnectionInfo$NetworkType.NONE.a() : activeNetworkInfo.getType();
        Map map3 = (Map) b0VarC.f29644f;
        if (map3 == null) {
            throw new IllegalStateException("Property \"autoMetadata\" has not been set");
        }
        map3.put("net-type", String.valueOf(iA));
        int i11 = -1;
        if (activeNetworkInfo == null) {
            subtype = NetworkConnectionInfo$MobileSubtype.UNKNOWN_MOBILE_SUBTYPE.a();
        } else {
            subtype = activeNetworkInfo.getSubtype();
            if (subtype == -1) {
                subtype = NetworkConnectionInfo$MobileSubtype.COMBINED.a();
            } else if (NetworkConnectionInfo$MobileSubtype.forNumber(subtype) == null) {
                subtype = 0;
            }
        }
        Map map4 = (Map) b0VarC.f29644f;
        if (map4 == null) {
            throw new IllegalStateException("Property \"autoMetadata\" has not been set");
        }
        map4.put("mobile-subtype", String.valueOf(subtype));
        b0VarC.a("country", Locale.getDefault().getCountry());
        b0VarC.a("locale", Locale.getDefault().getLanguage());
        Context context = this.f7729c;
        b0VarC.a("mcc_mnc", ((TelephonyManager) context.getSystemService("phone")).getSimOperator());
        try {
            i11 = context.getPackageManager().getPackageInfo(context.getPackageName(), 0).versionCode;
        } catch (PackageManager.NameNotFoundException unused) {
            g.k("CctTransportBackend");
        }
        b0VarC.a("application_build", Integer.toString(i11));
        return b0VarC.d();
    }
}