package K1;

import E3.g;
import F3.L;
import J3.q;
import android.database.sqlite.SQLiteDatabase;
import android.util.Log;
import androidx.compose.runtime.State;
import androidx.credentials.playservices.HiddenActivity;
import androidx.media3.common.FlagSet;
import androidx.media3.common.MediaMetadata;
import androidx.media3.common.Player;
import androidx.media3.common.SimpleBasePlayer;
import androidx.media3.common.TrackGroup;
import androidx.media3.common.Tracks;
import androidx.media3.common.util.Consumer;
import androidx.media3.common.util.ListenerSet;
import androidx.media3.exoplayer.trackselection.DefaultTrackSelector;
import androidx.media3.exoplayer.trackselection.ExoTrackSelection;
import androidx.media3.exoplayer.trackselection.RandomTrackSelection;
import androidx.media3.exoplayer.trackselection.TrackSelectionUtil;
import androidx.media3.extractor.BinarySearchSeeker;
import androidx.media3.extractor.FlacStreamMetadata;
import androidx.media3.extractor.mp4.FragmentedMp4Extractor;
import androidx.media3.extractor.mp4.Track;
import androidx.media3.extractor.text.CuesWithTiming;
import androidx.media3.extractor.text.SubtitleExtractor;
import coil.EventListener;
import coil.ImageLoader;
import coil.request.ImageRequest;
import com.google.android.gms.tasks.Continuation;
import com.google.android.gms.tasks.OnSuccessListener;
import com.google.android.gms.tasks.SuccessContinuation;
import com.google.android.gms.tasks.Task;
import com.google.crypto.tink.shaded.protobuf.C1256d;
import com.google.firebase.crashlytics.internal.CrashlyticsNativeComponentDeferredProxy;
import com.google.firebase.crashlytics.internal.CrashlyticsRemoteConfigListener;
import com.google.firebase.crashlytics.internal.RemoteConfigDeferredProxy;
import com.google.firebase.crashlytics.internal.common.SessionReportingCoordinator;
import com.google.firebase.crashlytics.internal.common.Utils;
import com.google.firebase.crashlytics.internal.concurrency.CrashlyticsWorker;
import com.google.firebase.encoders.EncodingException;
import com.google.firebase.firestore.auth.FirebaseAuthCredentialsProvider;
import com.google.firebase.firestore.core.Transaction;
import com.google.firebase.inject.Deferred;
import com.google.firebase.inject.Provider;
import com.google.firebase.sessions.EventGDTLogger;
import com.google.firebase.sessions.SessionEvent;
import com.revenuecat.purchases.common.networking.RCHTTPStatusCodes;
import com.revenuecat.purchases.ui.revenuecatui.activity.PaywallActivity;
import com.revenuecat.purchases.ui.revenuecatui.activity.PaywallResult;
import g.InterfaceC2048b;
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.URL;
import java.net.UnknownHostException;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.zip.GZIPInputStream;
import java.util.zip.GZIPOutputStream;
import m1.r;
import m3.AbstractC2478m;
import o4.f;
import okhttp3.EventListener;
import q3.n;
import q3.w;
import x3.C3222g;
import y3.C3270g;

/* JADX INFO: loaded from: classes.dex */
public final /* synthetic */ class b implements OnSuccessListener, ListenerSet.Event, ListenerSet.IterationFinishedEvent, q, DefaultTrackSelector.TrackInfo.Factory, TrackSelectionUtil.AdaptiveTrackSelectionFactory, BinarySearchSeeker.SeekTimestampConverter, g, Consumer, EventListener.Factory, Deferred.DeferredHandler, Continuation, o3.d, InterfaceC2048b, EventListener.Factory, z3.b {

    /* JADX INFO: renamed from: a, reason: collision with root package name */
    public final /* synthetic */ int f4040a;

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

    public /* synthetic */ b(Object obj, int i6) {
        this.f4040a = i6;
        this.f4041b = obj;
    }

    @Override // androidx.media3.common.util.Consumer
    public void accept(Object obj) {
        switch (this.f4040a) {
            case 12:
                ((SubtitleExtractor) this.f4041b).lambda$parseAndWriteToOutput$0((CuesWithTiming) obj);
                break;
            default:
                ((L) this.f4041b).a((CuesWithTiming) obj);
                break;
        }
    }

    @Override // E3.g
    public Object apply(Object obj) {
        switch (this.f4040a) {
            case 11:
                return ((FragmentedMp4Extractor) this.f4041b).modifyTrack((Track) obj);
            default:
                return ((EventGDTLogger) this.f4041b).encode((SessionEvent) obj);
        }
    }

    @Override // z3.b
    public Object b() {
        C3270g c3270g = (C3270g) ((C3222g) this.f4041b).f26027i;
        SQLiteDatabase sQLiteDatabaseA = c3270g.a();
        sQLiteDatabaseA.beginTransaction();
        try {
            sQLiteDatabaseA.compileStatement("DELETE FROM log_event_dropped").execute();
            sQLiteDatabaseA.compileStatement("UPDATE global_log_event_state SET last_metrics_upload_ms=" + c3270g.f26192b.f()).execute();
            sQLiteDatabaseA.setTransactionSuccessful();
            sQLiteDatabaseA.endTransaction();
            return null;
        } catch (Throwable th) {
            sQLiteDatabaseA.endTransaction();
            throw th;
        }
    }

    public C1256d c(f fVar) throws IOException {
        p3.b bVar = (p3.b) this.f4041b;
        String strL = AbstractC2478m.l("CctTransportBackend");
        boolean zIsLoggable = Log.isLoggable(strL, 4);
        URL url = (URL) fVar.f21850c;
        if (zIsLoggable) {
            Log.i(strL, String.format("Making request to: %s", url));
        }
        HttpURLConnection httpURLConnection = (HttpURLConnection) url.openConnection();
        httpURLConnection.setConnectTimeout(30000);
        httpURLConnection.setReadTimeout(bVar.f22980g);
        httpURLConnection.setDoOutput(true);
        httpURLConnection.setInstanceFollowRedirects(false);
        httpURLConnection.setRequestMethod("POST");
        httpURLConnection.setRequestProperty("User-Agent", "datatransport/3.3.0 android/");
        httpURLConnection.setRequestProperty("Content-Encoding", "gzip");
        httpURLConnection.setRequestProperty("Content-Type", "application/json");
        httpURLConnection.setRequestProperty("Accept-Encoding", "gzip");
        String str = (String) fVar.f21849b;
        if (str != null) {
            httpURLConnection.setRequestProperty("X-Goog-Api-Key", str);
        }
        try {
            OutputStream outputStream = httpURLConnection.getOutputStream();
            try {
                GZIPOutputStream gZIPOutputStream = new GZIPOutputStream(outputStream);
                try {
                    bVar.f22974a.encode((n) fVar.f21851d, new BufferedWriter(new OutputStreamWriter(gZIPOutputStream)));
                    gZIPOutputStream.close();
                    if (outputStream != null) {
                        outputStream.close();
                    }
                    int responseCode = httpURLConnection.getResponseCode();
                    Integer numValueOf = Integer.valueOf(responseCode);
                    String strL2 = AbstractC2478m.l("CctTransportBackend");
                    if (Log.isLoggable(strL2, 4)) {
                        Log.i(strL2, String.format("Status Code: %d", numValueOf));
                    }
                    AbstractC2478m.g("CctTransportBackend", "Content-Type: %s", httpURLConnection.getHeaderField("Content-Type"));
                    AbstractC2478m.g("CctTransportBackend", "Content-Encoding: %s", httpURLConnection.getHeaderField("Content-Encoding"));
                    if (responseCode == 302 || responseCode == 301 || responseCode == 307) {
                        return new C1256d(responseCode, new URL(httpURLConnection.getHeaderField("Location")), 0L);
                    }
                    if (responseCode != 200) {
                        return new C1256d(responseCode, null, 0L);
                    }
                    InputStream inputStream = httpURLConnection.getInputStream();
                    try {
                        InputStream gZIPInputStream = "gzip".equals(httpURLConnection.getHeaderField("Content-Encoding")) ? new GZIPInputStream(inputStream) : inputStream;
                        try {
                            C1256d c1256d = new C1256d(responseCode, null, w.a(new BufferedReader(new InputStreamReader(gZIPInputStream))).f23724a);
                            if (gZIPInputStream != null) {
                                gZIPInputStream.close();
                            }
                            if (inputStream != null) {
                                inputStream.close();
                            }
                            return c1256d;
                        } 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 e6) {
            e = e6;
            AbstractC2478m.i(e, "CctTransportBackend", "Couldn't encode request, returning with 400");
            return new C1256d(RCHTTPStatusCodes.BAD_REQUEST, null, 0L);
        } catch (ConnectException e7) {
            e = e7;
            AbstractC2478m.i(e, "CctTransportBackend", "Couldn't open connection, returning with 500");
            return new C1256d(500, null, 0L);
        } catch (UnknownHostException e8) {
            e = e8;
            AbstractC2478m.i(e, "CctTransportBackend", "Couldn't open connection, returning with 500");
            return new C1256d(500, null, 0L);
        } catch (IOException e9) {
            e = e9;
            AbstractC2478m.i(e, "CctTransportBackend", "Couldn't encode request, returning with 400");
            return new C1256d(RCHTTPStatusCodes.BAD_REQUEST, null, 0L);
        }
    }

    @Override // coil.EventListener.Factory
    public coil.EventListener create(ImageRequest imageRequest) {
        return ImageLoader.Builder.eventListener$lambda$15((coil.EventListener) this.f4041b, imageRequest);
    }

    @Override // androidx.media3.exoplayer.trackselection.TrackSelectionUtil.AdaptiveTrackSelectionFactory
    public ExoTrackSelection createAdaptiveTrackSelection(ExoTrackSelection.Definition definition) {
        return ((RandomTrackSelection.Factory) this.f4041b).lambda$createTrackSelections$0(definition);
    }

    public float d(float f6) {
        return ((r) this.f4041b).f20472k.a() * f6;
    }

    @Override // com.google.firebase.inject.Deferred.DeferredHandler
    public void handle(Provider provider) {
        switch (this.f4040a) {
            case 15:
                ((CrashlyticsNativeComponentDeferredProxy) this.f4041b).lambda$new$0(provider);
                break;
            case 16:
                RemoteConfigDeferredProxy.lambda$setupListener$0((CrashlyticsRemoteConfigListener) this.f4041b, provider);
                break;
            default:
                ((FirebaseAuthCredentialsProvider) this.f4041b).lambda$new$1(provider);
                break;
        }
    }

    @Override // androidx.media3.common.util.ListenerSet.Event
    public void invoke(Object obj) {
        switch (this.f4040a) {
            case 4:
                ((Player.Listener) obj).onTracksChanged((Tracks) this.f4041b);
                break;
            default:
                ((Player.Listener) obj).onMediaMetadataChanged((MediaMetadata) this.f4041b);
                break;
        }
    }

    @Override // g.InterfaceC2048b
    public void onActivityResult(Object obj) {
        switch (this.f4040a) {
            case 24:
                PaywallActivity.exitOfferLauncher$lambda$0((PaywallActivity) this.f4041b, (PaywallResult) obj);
                break;
            default:
                ((J4.c) ((State) this.f4041b).getValue()).invoke(obj);
                break;
        }
    }

    @Override // com.google.android.gms.tasks.OnSuccessListener
    public void onSuccess(Object obj) {
        Object obj2 = this.f4041b;
        switch (this.f4040a) {
            case 0:
                int i6 = HiddenActivity.f11302c;
                ((d) obj2).invoke(obj);
                break;
            case 1:
                int i7 = HiddenActivity.f11302c;
                ((d) obj2).invoke(obj);
                break;
            case 2:
                int i8 = HiddenActivity.f11302c;
                ((d) obj2).invoke(obj);
                break;
            default:
                int i9 = HiddenActivity.f11302c;
                ((d) obj2).invoke(obj);
                break;
        }
    }

    @Override // com.google.android.gms.tasks.Continuation
    public Object then(Task task) {
        switch (this.f4040a) {
            case 17:
                return Boolean.valueOf(((SessionReportingCoordinator) this.f4041b).onReportSendComplete(task));
            case 18:
                return Utils.lambda$awaitEvenIfOnMainThread$0((CountDownLatch) this.f4041b, task);
            case 19:
                return CrashlyticsWorker.lambda$submit$1((Runnable) this.f4041b, task);
            case 20:
                return CrashlyticsWorker.lambda$submitTaskOnSuccess$5((SuccessContinuation) this.f4041b, task);
            default:
                return ((Transaction) this.f4041b).lambda$lookup$0(task);
        }
    }

    @Override // androidx.media3.extractor.BinarySearchSeeker.SeekTimestampConverter
    public long timeUsToTargetTime(long j4) {
        return ((FlacStreamMetadata) this.f4041b).getSampleNumber(j4);
    }

    @Override // androidx.media3.exoplayer.trackselection.DefaultTrackSelector.TrackInfo.Factory
    public List create(int i6, TrackGroup trackGroup, int[] iArr) {
        return DefaultTrackSelector.lambda$selectImageTrack$4((DefaultTrackSelector.Parameters) this.f4041b, i6, trackGroup, iArr);
    }

    @Override // androidx.media3.common.util.ListenerSet.IterationFinishedEvent
    public void invoke(Object obj, FlagSet flagSet) {
        ((SimpleBasePlayer) this.f4041b).lambda$new$0((Player.Listener) obj, flagSet);
    }
}