Your TV v2.0.2 - C0100m.java 源代码

package G0;

import androidx.media3.exoplayer.rtsp.RtspHeaders;
import b.AbstractC0294a;
import com.bumptech.glide.load.Key;
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.net.URLEncoder;
import javax.net.ssl.HttpsURLConnection;
import kotlin.coroutines.Continuation;
import kotlin.coroutines.intrinsics.IntrinsicsKt;
import kotlin.coroutines.jvm.internal.SuspendLambda;
import kotlinx.coroutines.CoroutineScope;

public final class C0100m extends SuspendLambda implements X0.p {

    public final String f1238a;

    public final String f1239b;

    public final long f1240c;

    public C0100m(String str, String str2, long j2, Continuation continuation) {
        super(2, continuation);
        this.f1238a = str;
        this.f1239b = str2;
        this.f1240c = j2;
    }

    @Override
    public final Continuation create(Object obj, Continuation continuation) {
        return new C0100m(this.f1238a, this.f1239b, this.f1240c, continuation);
    }

    @Override
    public final Object invoke(Object obj, Object obj2) {
        return ((C0100m) create((CoroutineScope) obj, (Continuation) obj2)).invokeSuspend(M0.k.f1656a);
    }

    @Override
    public final Object invokeSuspend(Object obj) {
        BufferedReader bufferedReader;
        IntrinsicsKt.getCOROUTINE_SUSPENDED();
        b.b.R(obj);
        URLConnection openConnection = new URL(A.g.n("https://yourtv.horsenma.top/m3u/", URLEncoder.encode(this.f1238a, Key.STRING_CHARSET_NAME))).openConnection();
        kotlin.jvm.internal.j.c(openConnection, "null cannot be cast to non-null type javax.net.ssl.HttpsURLConnection");
        HttpsURLConnection httpsURLConnection = (HttpsURLConnection) openConnection;
        httpsURLConnection.setRequestMethod("GET");
        httpsURLConnection.setRequestProperty("X-API-Key", this.f1239b);
        httpsURLConnection.setRequestProperty(RtspHeaders.ACCEPT, "application/octet-stream, application/json");
        httpsURLConnection.setConnectTimeout(15000);
        httpsURLConnection.setReadTimeout(15000);
        try {
            int responseCode = httpsURLConnection.getResponseCode();
            String str = null;
            if (responseCode == 200) {
                int contentLength = httpsURLConnection.getContentLength();
                System.currentTimeMillis();
                if (contentLength == 0) {
                    httpsURLConnection.disconnect();
                    return null;
                }
                InputStream inputStream = httpsURLConnection.getInputStream();
                kotlin.jvm.internal.j.d(inputStream, "getInputStream(...)");
                bufferedReader = new BufferedReader(new InputStreamReader(inputStream, e1.a.f4716a), 8192);
                try {
                    String I2 = AbstractC0294a.I(bufferedReader);
                    if (I2.length() == 0) {
                        System.currentTimeMillis();
                        bufferedReader.close();
                        httpsURLConnection.disconnect();
                        return null;
                    }
                    bufferedReader.close();
                    str = I2;
                } finally {
                    try {
                        throw th;
                    } finally {
                    }
                }
            } else if (responseCode != 404) {
                InputStream errorStream = httpsURLConnection.getErrorStream();
                if (errorStream != null) {
                    bufferedReader = new BufferedReader(new InputStreamReader(errorStream, e1.a.f4716a), 8192);
                    try {
                        AbstractC0294a.I(bufferedReader);
                        bufferedReader.close();
                    } finally {
                    }
                }
                httpsURLConnection.getResponseCode();
            }
            httpsURLConnection.disconnect();
            return str;
        } catch (Throwable th) {
            httpsURLConnection.disconnect();
            throw th;
        }
    }
}