package xyz.stream.api;

import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Locale;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import okhttp3.OkHttpClient;
import xyz.stream.api.database.entity.ServerEntity;

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

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

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

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

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

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

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

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

    public /* synthetic */ p(q qVar, String str, String str2, String str3, String str4, xyz.stream.utils.y yVar) {
        this.f35921d = qVar;
        this.f35919b = str;
        this.f35920c = str2;
        this.f35922e = str3;
        this.f35923f = str4;
        this.f35924g = yVar;
    }

    @Override // java.lang.Runnable
    public final void run() {
        Object obj = this.f35923f;
        int i10 = this.f35918a;
        Object obj2 = this.f35924g;
        Object obj3 = this.f35922e;
        Object obj4 = this.f35921d;
        switch (i10) {
            case 0:
                q qVar = (q) obj4;
                String str = this.f35919b;
                String str2 = this.f35920c;
                String str3 = (String) obj3;
                String str4 = (String) obj;
                xyz.stream.utils.y yVar = (xyz.stream.utils.y) obj2;
                qVar.getClass();
                try {
                    String strL = q.l(str, str2, str3, str4);
                    if (strL == null || strL.isEmpty()) {
                        yVar.r(new Exception("result is empty"));
                    } else {
                        List listAsList = Arrays.asList(strL.split("\n"));
                        int i11 = Integer.parseInt((String) listAsList.get(0));
                        if (listAsList.size() >= 3 && i11 == 200) {
                            yVar.n((String) listAsList.get(2));
                        } else if (i11 == -107) {
                            yVar.r(new Exception("restart app"));
                        } else if (i11 == -100 || i11 == -101 || i11 == -104) {
                            yVar.r(new Exception(q.e((String) listAsList.get(0))));
                        } else {
                            Integer num = (Integer) ((Map) qVar.f35931f).get(str3);
                            if (num == null) {
                                ((Map) qVar.f35931f).put(str3, 1);
                                Thread.sleep(1000L);
                                qVar.d(str, str2, str3, str4, yVar);
                            } else if (num.intValue() >= 14) {
                                ((Map) qVar.f35931f).remove(str3);
                                yVar.r(new Exception(q.e((String) listAsList.get(0))));
                            } else {
                                ((Map) qVar.f35931f).put(str3, Integer.valueOf(num.intValue() + 1));
                                Thread.sleep(1000L);
                                qVar.d(str, str2, str3, str4, yVar);
                            }
                        }
                    }
                } catch (Exception e10) {
                    yVar.r(e10);
                    return;
                }
                break;
            default:
                xyz.stream.api.database.f fVar = (xyz.stream.api.database.f) obj4;
                xyz.stream.api.database.e eVar = (xyz.stream.api.database.e) obj3;
                String str5 = this.f35919b;
                Integer num2 = (Integer) obj;
                Map map = (Map) obj2;
                xyz.stream.api.database.f fVar2 = xyz.stream.api.database.f.f35806f;
                fVar.getClass();
                eVar.i(0, str5);
                Locale locale = Locale.US;
                String str6 = this.f35920c;
                String lowerCase = str6.toLowerCase(locale);
                if (lowerCase.contains(".m3u8") || lowerCase.contains(".mpd") || lowerCase.startsWith("rtmp://") || lowerCase.startsWith("rtsp://") || lowerCase.startsWith("mms://") || lowerCase.startsWith("rtp://") || lowerCase.startsWith("udp://")) {
                    ServerEntity serverEntityJ = fVar.j(num2, str5, str6, "", eVar);
                    if (serverEntityJ == null) {
                        eVar.h("Failed to parse IPTV data.");
                    } else {
                        int i12 = fVar.f35810c;
                        fVar.f35810c = 0;
                        eVar.n(serverEntityJ, i12);
                    }
                } else {
                    String lowerCase2 = str6.toLowerCase(locale);
                    if (lowerCase2.startsWith("http://") || lowerCase2.startsWith("https://")) {
                        TimeUnit timeUnit = TimeUnit.SECONDS;
                        xyz.stream.api.database.c cVar = new xyz.stream.api.database.c(num2, str5, str6, eVar, fVar);
                        xyz.stream.utils.z zVarE = xyz.stream.utils.z.e();
                        zVarE.getClass();
                        OkHttpClient okHttpClientBuild = xyz.stream.utils.z.f36195b;
                        if (timeUnit != null) {
                            okHttpClientBuild = okHttpClientBuild.newBuilder().callTimeout(30L, timeUnit).connectTimeout(30L, timeUnit).readTimeout(30L, timeUnit).writeTimeout(30L, timeUnit).build();
                        }
                        zVarE.c(str6, map, cVar, okHttpClientBuild);
                    } else {
                        eVar.h("Invalid IPTV URL.");
                    }
                }
                break;
        }
    }

    public /* synthetic */ p(xyz.stream.api.database.f fVar, xyz.stream.api.database.e eVar, String str, String str2, Integer num, HashMap map) {
        this.f35921d = fVar;
        this.f35922e = eVar;
        this.f35919b = str;
        this.f35920c = str2;
        this.f35923f = num;
        this.f35924g = map;
    }
}