package androidx.media3.exoplayer.audio;

import android.app.Activity;
import android.media.AudioTrack;
import android.net.Uri;
import android.os.Build;
import android.os.Handler;
import android.os.Looper;
import android.view.View;
import android.widget.EditText;
import android.widget.TextView;
import androidx.fragment.app.FragmentActivity;
import androidx.media3.exoplayer.audio.AudioSink;
import androidx.media3.exoplayer.hls.playlist.HlsMediaPlaylist;
import androidx.media3.exoplayer.rtsp.RtspHeaders;
import androidx.media3.exoplayer.source.ProgressiveMediaSource;
import com.pichillilorenzo.flutter_inappwebview_android.credential_database.URLCredentialContract;
import fa.o;
import ie.v3;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
import java.nio.charset.Charset;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Calendar;
import java.util.Date;
import java.util.Locale;
import java.util.Timer;
import java.util.logging.Logger;
import kotlinx.coroutines.y;
import okhttp3.OkHttpClient;
import org.drive_hunter.R;
import v6.q;
import v6.v;
import ve.u;
import xyz.netfly.mobile.player.t;
import xyz.netfly.ui.vod_info.VodInfoActivity;
import xyz.stream.api.database.IptvManager$IptvAuth$Type;
import xyz.stream.api.entity.LiveChannelEntity;
import xyz.stream.download.DownloadManager;
import xyz.stream.view.BindingDialogBuilder;

/* JADX INFO: loaded from: classes.dex */
public final /* synthetic */ class j implements Runnable {

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

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

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

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

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

    public /* synthetic */ j(Object obj, Object obj2, Object obj3, Object obj4, int i10) {
        this.f2950a = i10;
        this.f2951b = obj;
        this.f2952c = obj2;
        this.f2953d = obj3;
        this.f2954e = obj4;
    }

    @Override // java.lang.Runnable
    public final void run() throws Throwable {
        String str;
        byte[] bArrCopyOfRange;
        o oVar;
        FileInputStream fileInputStream;
        FileChannel channel;
        FileChannel channel2;
        String str2;
        String queryParameter;
        HttpURLConnection httpURLConnection;
        int i10 = this.f2950a;
        str = "";
        HttpURLConnection httpURLConnection2 = null;
        Object obj = this.f2954e;
        Object obj2 = this.f2953d;
        Object obj3 = this.f2952c;
        Object obj4 = this.f2951b;
        switch (i10) {
            case 0:
                DefaultAudioSink.lambda$releaseAudioTrackAsync$1((AudioTrack) obj4, (AudioSink.Listener) obj3, (Handler) obj2, (AudioSink.AudioTrackConfig) obj);
                return;
            case 1:
                a7.a aVar = (a7.a) obj4;
                v vVar = (v) obj3;
                t6.h hVar = (t6.h) obj2;
                q qVar = (q) obj;
                Logger logger = a7.a.f385f;
                aVar.getClass();
                Logger logger2 = a7.a.f385f;
                try {
                    w6.n nVar = ((w6.m) aVar.f388c).get(((v6.l) vVar).f33708a);
                    if (nVar == null) {
                        String str3 = String.format("Transport backend '%s' is not registered", ((v6.l) vVar).f33708a);
                        logger2.warning(str3);
                        new IllegalArgumentException(str3);
                        hVar.getClass();
                    } else {
                        ((c7.l) aVar.f390e).L(new androidx.media3.exoplayer.hls.b(aVar, vVar, ((com.google.android.datatransport.cct.d) nVar).c(qVar), 5));
                        hVar.getClass();
                    }
                    return;
                } catch (Exception e10) {
                    logger2.warning("Error scheduling event " + e10.getMessage());
                    hVar.getClass();
                    return;
                }
            case 2:
                ((lc.a) obj4).f30206b.error((String) obj3, (String) obj2, obj);
                return;
            case 3:
                t tVar = (t) obj4;
                String str4 = (String) obj3;
                String str5 = (String) obj2;
                String str6 = (String) obj;
                if (Build.VERSION.SDK_INT >= 33 && g0.d.a(tVar.f35007a, "android.permission.POST_NOTIFICATIONS") != 0) {
                    androidx.core.app.f.c(tVar.f35007a, new String[]{"android.permission.POST_NOTIFICATIONS"}, 1001);
                }
                tVar.f35016j.startDownload(tVar.f35030x.getId().intValue(), tVar.f35030x.getSourceType().intValue(), tVar.f35030x.getTitle(), tVar.f35030x.getBackdropPath(), null, null, null, tVar.f35030x.getRuntime(), str4, null, str5, str6);
                return;
            case 4:
                t.c((t) obj4, (String) obj3, (ke.n) obj2, (String) obj);
                return;
            case 5:
                xyz.netfly.player.n nVar2 = (xyz.netfly.player.n) obj4;
                String str7 = (String) obj3;
                String str8 = (String) obj2;
                String str9 = (String) obj;
                nVar2.getClass();
                String strD = xyz.netfly.player.n.d(str7, str8);
                StringBuilder sb = new StringBuilder();
                sb.append(nVar2.f35221g);
                String str10 = File.separator;
                File file = new File(defpackage.e.o(sb, str10, strD));
                int i11 = 17;
                if (!nVar2.f35232r && file.exists()) {
                    if (file.length() < 100) {
                        nVar2.f(0, str9, str7, str8);
                        return;
                    } else {
                        new Thread(new androidx.emoji2.text.v(nVar2, file, strD, i11)).start();
                        return;
                    }
                }
                if (nVar2.f35230p != null) {
                    File file2 = new File(nVar2.f35230p, str8);
                    if (file2.exists()) {
                        xyz.stream.api.q.g().getClass();
                        String strJ = xyz.stream.api.q.j();
                        File file3 = new File(nVar2.f35221g + str10 + file2.getName());
                        try {
                            String strI = kotlinx.coroutines.flow.h.I(strJ);
                            Charset charset = StandardCharsets.UTF_8;
                            byte[] bArrCopyOfRange2 = Arrays.copyOfRange(strI.getBytes(charset), 0, 32);
                            bArrCopyOfRange = Arrays.copyOfRange(strI.getBytes(charset), 0, 24);
                            oVar = new o(bArrCopyOfRange2, 0, 2);
                            fileInputStream = new FileInputStream(file2);
                        } catch (Exception e11) {
                            e11.printStackTrace();
                            xyz.stream.utils.h.c("Error decrypting file: " + e11);
                        }
                        try {
                            FileOutputStream fileOutputStream = new FileOutputStream(file3);
                            try {
                                channel = fileInputStream.getChannel();
                                try {
                                    channel2 = fileOutputStream.getChannel();
                                } finally {
                                }
                            } finally {
                            }
                            try {
                                ByteBuffer byteBufferAllocate = ByteBuffer.allocate(ProgressiveMediaSource.DEFAULT_LOADING_CHECK_INTERVAL_BYTES);
                                while (channel.read(byteBufferAllocate) > 0) {
                                    byteBufferAllocate.flip();
                                    byte[] bArr = new byte[byteBufferAllocate.remaining()];
                                    byteBufferAllocate.get(bArr);
                                    channel2.write(ByteBuffer.wrap(oVar.c(bArrCopyOfRange, bArr)));
                                    byteBufferAllocate.clear();
                                }
                                xyz.stream.utils.h.b("File decrypted successfully");
                                if (channel2 != null) {
                                    channel2.close();
                                }
                                channel.close();
                                fileOutputStream.close();
                                fileInputStream.close();
                                new Thread(new androidx.emoji2.text.v(nVar2, file3, strD, i11)).start();
                                return;
                            } finally {
                            }
                        } finally {
                        }
                    }
                }
                nVar2.f(0, str9, str7, str8);
                return;
            case 6:
                pe.g gVar = (pe.g) obj4;
                String str11 = (String) obj3;
                Integer num = (Integer) obj2;
                String str12 = (String) obj;
                if (gVar.G0.f27210a.getVisibility() == 0) {
                    View view = gVar.N0;
                    if (view == null) {
                        view = gVar.E0.f26889a;
                    }
                    y.W(gVar.G0.f27210a);
                    y.M(view, null);
                    gVar.M0 = view;
                }
                try {
                    Uri uri = Uri.parse(str11);
                    queryParameter = uri.getQueryParameter(URLCredentialContract.FeedEntry.COLUMN_NAME_USERNAME);
                    String queryParameter2 = uri.getQueryParameter(URLCredentialContract.FeedEntry.COLUMN_NAME_PASSWORD);
                    if (queryParameter == null) {
                        queryParameter = "";
                    }
                    str = queryParameter2 != null ? queryParameter2 : "";
                    try {
                        if (queryParameter.isEmpty() || str.isEmpty()) {
                            if (uri.getUserInfo() != null) {
                                String[] strArrSplit = uri.getUserInfo().split(":", 2);
                                String str13 = (strArrSplit.length > 0 && queryParameter.isEmpty()) ? strArrSplit[0] : queryParameter;
                                try {
                                    if (strArrSplit.length > 1 && str.isEmpty()) {
                                        str = strArrSplit[1];
                                    }
                                    queryParameter = str13;
                                } catch (Exception unused) {
                                    str2 = str;
                                    str = str13;
                                    queryParameter = str;
                                    str = str2;
                                }
                            }
                        }
                    } catch (Exception unused2) {
                        str2 = str;
                        str = queryParameter;
                    }
                    break;
                } catch (Exception unused3) {
                    str2 = "";
                }
                String[] strArr = {queryParameter, str};
                final FragmentActivity fragmentActivityRequireActivity = gVar.requireActivity();
                final String str14 = strArr[0];
                final String str15 = strArr[1];
                final u.e eVar = new u.e();
                eVar.f33128d = gVar;
                eVar.f33125a = num;
                eVar.f33126b = str12;
                eVar.f33127c = str11;
                if (fragmentActivityRequireActivity == null || fragmentActivityRequireActivity.isFinishing() || fragmentActivityRequireActivity.isDestroyed()) {
                    return;
                }
                BindingDialogBuilder.with(fragmentActivityRequireActivity, new c7.g(28)).theme(R.style.CustomDialog).setup(new BindingDialogBuilder.DialogSetup() { // from class: uf.c
                    @Override // xyz.stream.view.BindingDialogBuilder.DialogSetup
                    public final void setup(v3.a aVar2, e.m mVar) {
                        u.e eVar2 = eVar;
                        v3 v3Var = (v3) aVar2;
                        IptvManager$IptvAuth$Type[] iptvManager$IptvAuth$TypeArr = {IptvManager$IptvAuth$Type.f35778a};
                        int[] iArr = {0};
                        ArrayList arrayList = new ArrayList();
                        Activity activity = fragmentActivityRequireActivity;
                        arrayList.add(activity.getString(R.string.iptv_auth_type_username_password));
                        arrayList.add(activity.getString(R.string.iptv_auth_type_token));
                        arrayList.add(activity.getString(R.string.iptv_auth_type_auth));
                        arrayList.add(activity.getString(R.string.iptv_auth_type_cookie));
                        arrayList.add(activity.getString(R.string.iptv_auth_type_referer));
                        arrayList.add(activity.getString(R.string.iptv_auth_type_custom_header));
                        EditText editText = v3Var.f27556c;
                        String str16 = str14;
                        if (str16 == null) {
                            str16 = "";
                        }
                        editText.setText(str16);
                        String str17 = str15;
                        v3Var.f27555b.setText(str17 != null ? str17 : "");
                        r.l(activity, v3Var, iptvManager$IptvAuth$TypeArr[0], false);
                        v3Var.f27557d.setOnClickListener(new g(activity, arrayList, iArr, iptvManager$IptvAuth$TypeArr, v3Var));
                        v3Var.f27558e.setOnClickListener(new xyz.netfly.ads.i(eVar2, mVar, 10));
                        v3Var.f27559f.setOnClickListener(new g(v3Var, activity, eVar2, iptvManager$IptvAuth$TypeArr, mVar));
                        v3Var.f27556c.post(new p000if.e(v3Var, 13));
                    }
                }).width(720).maskOwner(fragmentActivityRequireActivity).show();
                return;
            case 7:
                ve.v vVar2 = (ve.v) obj4;
                TextView textView = (TextView) obj3;
                TextView textView2 = (TextView) obj2;
                LiveChannelEntity liveChannelEntity = (LiveChannelEntity) obj;
                OkHttpClient okHttpClient = ve.v.E;
                vVar2.getClass();
                if (textView != null && textView2 != null) {
                    switch (Calendar.getInstance().get(7)) {
                        case 1:
                            str = "Sunday";
                            break;
                        case 2:
                            str = "Monday";
                            break;
                        case 3:
                            str = "Tuesday";
                            break;
                        case 4:
                            str = "Wednesday";
                            break;
                        case 5:
                            str = "Thursday";
                            break;
                        case 6:
                            str = "Friday";
                            break;
                        case 7:
                            str = "Saturday";
                            break;
                    }
                    String str16 = str;
                    Date date = new Date();
                    vVar2.f33938r = date;
                    new Handler(Looper.getMainLooper()).post(new j(textView2, new SimpleDateFormat("dd/MM/yyyy HH:mm:ss", Locale.getDefault()).format(date), textView, str16, 8));
                    if (vVar2.A == null) {
                        Timer timer = new Timer();
                        vVar2.A = timer;
                        timer.schedule(new u(vVar2, textView2), 0L, 1000L);
                    }
                }
                if (vVar2.B == liveChannelEntity.getId().intValue()) {
                    return;
                }
                vVar2.B = liveChannelEntity.getId().intValue();
                xyz.stream.api.o.f().y(vVar2.B);
                return;
            case 8:
                OkHttpClient okHttpClient2 = ve.v.E;
                ((TextView) obj4).setText((String) obj3);
                ((TextView) obj2).setText((String) obj);
                return;
            case 9:
                VodInfoActivity vodInfoActivity = (VodInfoActivity) obj4;
                String str17 = (String) obj3;
                String str18 = (String) obj2;
                String str19 = (String) obj;
                int i12 = VodInfoActivity.V;
                vodInfoActivity.getClass();
                if (Build.VERSION.SDK_INT >= 33 && g0.d.a(vodInfoActivity, "android.permission.POST_NOTIFICATIONS") != 0) {
                    androidx.core.app.f.c(vodInfoActivity, new String[]{"android.permission.POST_NOTIFICATIONS"}, 1001);
                }
                DownloadManager.getInstance().startDownload(vodInfoActivity.f35660b.getId().intValue(), vodInfoActivity.f35660b.getSourceType().intValue(), vodInfoActivity.f35660b.getTitle(), vodInfoActivity.f35660b.getBackdropPath(), null, null, null, vodInfoActivity.f35660b.getRuntime(), str17, null, str18, str19);
                return;
            case 10:
                String str20 = (String) obj3;
                String str21 = (String) obj2;
                String str22 = (String) obj;
                ((xyz.stream.api.q) obj4).getClass();
                try {
                    try {
                        httpURLConnection = (HttpURLConnection) new URL(str20).openConnection();
                    } catch (Exception e12) {
                        e = e12;
                    }
                } catch (Throwable th) {
                    th = th;
                }
                try {
                    httpURLConnection.setRequestMethod(str21);
                    httpURLConnection.setDoInput(true);
                    httpURLConnection.setUseCaches(false);
                    httpURLConnection.setRequestProperty(RtspHeaders.CONTENT_TYPE, "application/json");
                    httpURLConnection.setRequestProperty("Charset", "UTF-8");
                    if (!str21.equals("DELETE")) {
                        httpURLConnection.setDoOutput(true);
                        OutputStream outputStream = httpURLConnection.getOutputStream();
                        try {
                            outputStream.write(str22.getBytes());
                            outputStream.flush();
                            outputStream.close();
                        } finally {
                        }
                    }
                    int responseCode = httpURLConnection.getResponseCode();
                    if (responseCode == 200 && !str21.equals(HlsMediaPlaylist.Interstitial.CUE_TRIGGER_POST)) {
                        xyz.stream.api.q.n(str21 + " | " + str20 + " | success | " + str22);
                    } else if (responseCode != 200 && str20.contains("play/") && !str20.contains("live/") && !str20.contains("down/")) {
                        xyz.stream.api.q.n(str21 + " | " + str20 + " | error: " + responseCode + " | " + httpURLConnection.getResponseMessage());
                    }
                    httpURLConnection.disconnect();
                    return;
                } catch (Exception e13) {
                    e = e13;
                    httpURLConnection2 = httpURLConnection;
                    xyz.stream.api.q.n(str21 + " error: " + e.getMessage());
                    if (httpURLConnection2 != null) {
                        httpURLConnection2.disconnect();
                        return;
                    }
                    return;
                } catch (Throwable th2) {
                    th = th2;
                    httpURLConnection2 = httpURLConnection;
                    if (httpURLConnection2 != null) {
                        httpURLConnection2.disconnect();
                    }
                    throw th;
                }
            default:
                xyz.stream.utils.o.a((xyz.stream.utils.o) obj4, (String) obj3, (String) obj2, (String) obj);
                return;
        }
    }
}