package em; import android.os.Bundle; import cn.jpush.android.local.JPushConstants; import com.google.android.gms.common.GoogleApiAvailabilityLight; import com.google.gson.Gson; import com.meizu.cloud.pushsdk.notification.model.AdvanceSetting; import com.uber.autodispose.a0; import com.xingin.alpha.bean.StreamDispatchInfo; import com.xingin.alpha.config.LiveAppStartInfo; import dw2.r; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import kotlin.Lazy; import kotlin.LazyKt__LazyJVMKt; import kotlin.Metadata; import kotlin.Unit; import kotlin.collections.CollectionsKt___CollectionsKt; import kotlin.jvm.functions.Function0; import kotlin.jvm.functions.Function1; import kotlin.jvm.internal.Intrinsics; import kotlin.jvm.internal.Lambda; import kotlin.text.StringsKt__StringsJVMKt; import kotlin.text.StringsKt__StringsKt; import sy.n0; import sy.v0; import tv.danmaku.ijk.media.player.IjkMediaMeta; import wu2.c; import wu2.e; import y7.f; import z60.h; @Metadata(bv = {}, d1 = {"\u00008\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\f\n\u0002\u0010\u000b\n\u0000\n\u0002\u0010\b\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\b\bÆ\u0002\u0018\u00002\u00020\u0001B\t\b\u0002¢\u0006\u0004\b-\u0010.J\u0006\u0010\u0003\u001a\u00020\u0002J\u000e\u0010\u0006\u001a\u00020\u00042\u0006\u0010\u0005\u001a\u00020\u0004J\u000e\u0010\t\u001a\u00020\u00022\u0006\u0010\b\u001a\u00020\u0007J\u0016\u0010\u000b\u001a\u00020\u00042\u0006\u0010\n\u001a\u00020\u00042\u0006\u0010\u0005\u001a\u00020\u0004J\u000e\u0010\f\u001a\u00020\u00042\u0006\u0010\n\u001a\u00020\u0004J\u0010\u0010\u000e\u001a\u00020\u00042\u0006\u0010\r\u001a\u00020\u0004H\u0002J\u0018\u0010\u0011\u001a\u00020\u00042\u0006\u0010\u000f\u001a\u00020\u00042\u0006\u0010\u0010\u001a\u00020\u0004H\u0002J\b\u0010\u0012\u001a\u00020\u0002H\u0002J\b\u0010\u0013\u001a\u00020\u0002H\u0002J\b\u0010\u0015\u001a\u00020\u0014H\u0002R\"\u0010\u0017\u001a\u00020\u00168\u0006@\u0006X\u000e¢\u0006\u0012\n\u0004\b\u0017\u0010\u0018\u001a\u0004\b\u0019\u0010\u001a\"\u0004\b\u001b\u0010\u001cR\"\u0010\u001d\u001a\u00020\u00168\u0006@\u0006X\u000e¢\u0006\u0012\n\u0004\b\u001d\u0010\u0018\u001a\u0004\b\u001e\u0010\u001a\"\u0004\b\u001f\u0010\u001cR\"\u0010 \u001a\u00020\u00148\u0006@\u0006X\u000e¢\u0006\u0012\n\u0004\b \u0010!\u001a\u0004\b\"\u0010#\"\u0004\b$\u0010%RK\u0010,\u001a2\u0012\u0014\u0012\u0012\u0012\u0004\u0012\u00020\u00040&j\b\u0012\u0004\u0012\u00020\u0004`'0&j\u0018\u0012\u0014\u0012\u0012\u0012\u0004\u0012\u00020\u00040&j\b\u0012\u0004\u0012\u00020\u0004`'`'8BX\u0002¢\u0006\f\n\u0004\b(\u0010)\u001a\u0004\b*\u0010+¨\u0006/"}, d2 = {"Lem/c;", "", "", "g", "", "playUrl", GoogleApiAvailabilityLight.TRACKING_SOURCE_NOTIFICATION, "Lcom/xingin/alpha/bean/StreamDispatchInfo;", "dispatchInfo", "r", "roomId", "i", h.f160753a, "originalUrl", "d", "url", com.alipay.sdk.cons.c.f18128f, "e", "c", "k", "", "j", "", "cdnType", "I", "getCdnType", "()I", "o", "(I)V", "playFormat", "getPlayFormat", com.igexin.push.core.d.c.f25536c, "supportHevc", "Z", "getSupportHevc", "()Z", "q", "(Z)V", "Ljava/util/ArrayList;", "Lkotlin/collections/ArrayList;", "cdnUrlConfig$delegate", "Lkotlin/Lazy;", f.f156778k, "()Ljava/util/ArrayList;", "cdnUrlConfig", "<init>", "()V", "alpha_library_release"}, k = 1, mv = {1, 6, 0}) /* compiled from: LivePlayConfig.kt */ public final class c { /* renamed from: a reason: collision with root package name */ public static final c f73021a = new c(); /* renamed from: b reason: collision with root package name */ public static int f73022b; /* renamed from: c reason: collision with root package name */ public static int f73023c; /* renamed from: d reason: collision with root package name */ public static boolean f73024d = true; /* renamed from: e reason: collision with root package name */ public static final HashMap<String, String> f73025e = new HashMap<>(); /* renamed from: f reason: collision with root package name */ public static final Lazy f73026f = LazyKt__LazyJVMKt.lazy(a.f73027a); @Metadata(d1 = {"\u0000\u0010\n\u0000\n\u0002\u0018\u0002\n\u0002\u0010\u000e\n\u0002\u0018\u0002\n\u0000\u0010\u0000\u001a2\u0012\u0014\u0012\u0012\u0012\u0004\u0012\u00020\u00020\u0001j\b\u0012\u0004\u0012\u00020\u0002`\u00030\u0001j\u0018\u0012\u0014\u0012\u0012\u0012\u0004\u0012\u00020\u00020\u0001j\b\u0012\u0004\u0012\u00020\u0002`\u0003`\u0003H\n¢\u0006\u0002\b\u0004"}, d2 = {"<anonymous>", "Ljava/util/ArrayList;", "", "Lkotlin/collections/ArrayList;", "invoke"}, k = 3, mv = {1, 6, 0}, xi = 48) /* compiled from: LivePlayConfig.kt */ public static final class a extends Lambda implements Function0<ArrayList<ArrayList<String>>> { /* renamed from: a reason: collision with root package name */ public static final a f73027a = new a(); public a() { super(0); } @Override // kotlin.jvm.functions.Function0 public final ArrayList<ArrayList<String>> invoke() { return ak.c.f3514a.h(); } } @Metadata(d1 = {"\u0000\u0010\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u000e\n\u0002\b\u0002\u0010\u0000\u001a\u00020\u00012\u000e\u0010\u0002\u001a\n \u0004*\u0004\u0018\u00010\u00030\u0003H\n¢\u0006\u0002\b\u0005"}, d2 = {"<anonymous>", "", "jsonString", "", "kotlin.jvm.PlatformType", "invoke"}, k = 3, mv = {1, 6, 0}, xi = 48) /* compiled from: LivePlayConfig.kt */ public static final class b extends Lambda implements Function1<String, Unit> { /* renamed from: a reason: collision with root package name */ public static final b f73028a = new b(); public b() { super(1); } /* Return type fixed from 'java.lang.Object' to match base method */ /* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */ @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(String str) { invoke(str); return Unit.INSTANCE; } public final void invoke(String str) { Intrinsics.checkNotNullExpressionValue(str, "jsonString"); if (str.length() > 0) { LiveAppStartInfo liveAppStartInfo = (LiveAppStartInfo) new Gson().fromJson(str, LiveAppStartInfo.class); c cVar = c.f73021a; cVar.o(liveAppStartInfo.a()); cVar.p(liveAppStartInfo.b()); } } } @Metadata(d1 = {"\u0000\u000e\n\u0000\n\u0002\u0010\u0002\n\u0000\n\u0002\u0010\u0003\n\u0000\u0010\u0000\u001a\u00020\u00012\u0006\u0010\u0002\u001a\u00020\u0003H\n¢\u0006\u0002\b\u0004"}, d2 = {"<anonymous>", "", AdvanceSetting.NETWORK_TYPE, "", "invoke"}, k = 3, mv = {1, 6, 0}, xi = 48) /* renamed from: em.c$c reason: collision with other inner class name */ /* compiled from: LivePlayConfig.kt */ public static final class C0801c extends Lambda implements Function1<Throwable, Unit> { /* renamed from: a reason: collision with root package name */ public static final C0801c f73029a = new C0801c(); public C0801c() { super(1); } /* Return type fixed from 'java.lang.Object' to match base method */ /* JADX DEBUG: Method arguments types fixed to match base method, original types: [java.lang.Object] */ @Override // kotlin.jvm.functions.Function1 public /* bridge */ /* synthetic */ Unit invoke(Throwable th3) { invoke(th3); return Unit.INSTANCE; } public final void invoke(Throwable th3) { Intrinsics.checkNotNullParameter(th3, AdvanceSetting.NETWORK_TYPE); v0.f131783a.b("LivePlayConfig", th3, "observeLiveAppStartInfo"); } } public static final String l(c.a aVar) { Intrinsics.checkNotNullParameter(aVar, AdvanceSetting.NETWORK_TYPE); return aVar.a(); } public static final boolean m(String str) { Intrinsics.checkNotNullParameter(str, AdvanceSetting.NETWORK_TYPE); return !StringsKt__StringsJVMKt.isBlank(str); } public final void c() { ak.c cVar = ak.c.f3514a; if (cVar.e0() != null) { Integer e04 = cVar.e0(); f73022b = e04 != null ? e04.intValue() : 0; } } public final String d(String str) { String suitableIp = n0.f131715a.e().getSuitableIp(false, str); boolean z14 = true; if ((str.length() == 0) || iw.a.f92453a.a()) { return str; } if (StringsKt__StringsKt.contains((CharSequence) str, (CharSequence) "live.xhscdn.com", false)) { if (!(suitableIp == null || suitableIp.length() == 0)) { return StringsKt__StringsJVMKt.replace(str, "live.xhscdn.com", suitableIp + "/live.xhscdn.com", false); } } if (!(StringsKt__StringsKt.contains((CharSequence) str, (CharSequence) "live-ali.xhscdn.com", false))) { return str; } if (!(suitableIp == null || suitableIp.length() == 0)) { z14 = false; } if (z14) { return str; } return StringsKt__StringsJVMKt.replace(str, "live-ali.xhscdn.com", suitableIp + "/live-ali.xhscdn.com", false); } public final String e(String str, String str2) { List list = StringsKt__StringsKt.split$default((CharSequence) str, new String[]{str2}, false, 0, 6, (Object) null); if (list.size() <= 1 || ((String) CollectionsKt___CollectionsKt.first(list)).length() <= 7) { return str; } return JPushConstants.HTTP_PRE + str2 + ((String) CollectionsKt___CollectionsKt.last(list)); } public final ArrayList<ArrayList<String>> f() { return (ArrayList) f73026f.getValue(); } public final void g() { c(); k(); } public final String h(String str) { Intrinsics.checkNotNullParameter(str, "roomId"); return "http://live.xhscdn.com/live/" + str + ".flv"; } public final String i(String str, String str2) { Intrinsics.checkNotNullParameter(str, "roomId"); Intrinsics.checkNotNullParameter(str2, "playUrl"); v0 v0Var = v0.f131783a; StringBuilder sb3 = new StringBuilder(); sb3.append("getSuitableIp -- "); n0 n0Var = n0.f131715a; sb3.append(n0Var.e().getSuitableIp(false, str2)); sb3.append(" -- "); HashMap<String, String> hashMap = f73025e; sb3.append(hashMap.get(str)); v0Var.c("LivePlayConfig", null, sb3.toString()); if (StringsKt__StringsKt.contains$default((CharSequence) str2, (CharSequence) "live.xhscdn.com", false, 2, (Object) null)) { String str3 = hashMap.get(str); if (!(str3 == null || str3.length() == 0)) { String str4 = hashMap.get(str); if (str4 == null) { return ""; } return str4; } } return n0Var.e().getSuitableIp(false, str2); } public final boolean j() { return vt2.f.g().f("isUnicomKing", false); } public final void k() { r<R> W0 = e.f151437y.Q("live_app_start").M0(a.f73019a).u0(b.f73020a).W0(gw2.a.a()); Intrinsics.checkNotNullExpressionValue(W0, "XyLonglink.subscribePush…dSchedulers.mainThread())"); a0 a0Var = a0.D; Intrinsics.checkNotNullExpressionValue(a0Var, "UNBOUND"); bj2.h.f(W0, a0Var, b.f73028a, C0801c.f73029a); } /* JADX WARNING: Code restructure failed: missing block: B:12:0x0053, code lost: if (j() != false) goto L_0x0055; */ public final String n(String str) { int i10; String str2; String str3 = str; Intrinsics.checkNotNullParameter(str3, "playUrl"); if (f().size() <= 1 || ((ArrayList) CollectionsKt___CollectionsKt.first((List) f())).isEmpty() || f().get(1).isEmpty()) { return str3; } Bundle h10 = h.f73038a.h(str3); ak.a aVar = ak.a.f3508a; if (aVar.o()) { i10 = f73022b; if (h10 != null) { i10 = h10.getInt("cdn", i10); } } i10 = 0; int i14 = aVar.p() ? f73023c : 0; if (h10 != null) { i14 = h10.getInt(IjkMediaMeta.IJKM_KEY_BITRATE, i14); } ArrayList<String> arrayList = (ArrayList) CollectionsKt___CollectionsKt.first((List) f()); ArrayList<String> arrayList2 = f().get(1); Intrinsics.checkNotNullExpressionValue(arrayList2, "cdnUrlConfig[1]"); ArrayList<String> arrayList3 = arrayList2; if (StringsKt__StringsKt.contains$default((CharSequence) str3, (CharSequence) "live.xhscdn.com", false, 2, (Object) null)) { str3 = e(str3, "live.xhscdn.com"); } else if (StringsKt__StringsKt.contains$default((CharSequence) str3, (CharSequence) "live-ali.xhscdn.com", false, 2, (Object) null)) { str3 = e(str3, "live-ali.xhscdn.com"); } if (!(StringsKt__StringsKt.contains$default((CharSequence) str3, (CharSequence) "live.xhscdn.com", false, 2, (Object) null))) { String str4 = str3; for (String str5 : arrayList) { if (StringsKt__StringsKt.contains$default((CharSequence) str4, (CharSequence) str5, false, 2, (Object) null)) { str4 = StringsKt__StringsJVMKt.replace$default(str4, str5, "live.xhscdn.com", false, 4, (Object) null); } } str3 = str4; } loop1: while (true) { str2 = str3; for (T t14 : arrayList3) { if (!Intrinsics.areEqual(t14, ".flv") && (StringsKt__StringsKt.contains$default((CharSequence) str2, (CharSequence) t14, false, 2, (Object) null))) { str3 = StringsKt__StringsJVMKt.replace$default(str2, (String) t14, ".flv", false, 4, (Object) null); } } break loop1; } if (i10 > 0 && arrayList.size() > i10) { Object obj = arrayList.get(i10); Intrinsics.checkNotNullExpressionValue(obj, "cdnArr[cdn]"); str2 = StringsKt__StringsJVMKt.replace$default(str2, "live.xhscdn.com", (String) obj, false, 4, (Object) null); } String str6 = str2; if (i14 > 0 && arrayList3.size() > i14) { String str7 = arrayList3.get(i14); Intrinsics.checkNotNullExpressionValue(str7, "flagArr[format]"); str6 = StringsKt__StringsJVMKt.replace$default(str6, ".flv", str7, false, 4, (Object) null); } return d(str6); } public final void o(int i10) { f73022b = i10; } public final void p(int i10) { f73023c = i10; } public final void q(boolean z14) { f73024d = z14; } public final void r(StreamDispatchInfo streamDispatchInfo) { Intrinsics.checkNotNullParameter(streamDispatchInfo, "dispatchInfo"); for (T t14 : streamDispatchInfo.getData().getStreamIpList()) { HashMap<String, String> hashMap = f73025e; String roomId = t14.getRoomId(); String str = (String) CollectionsKt___CollectionsKt.firstOrNull((List) t14.getSuggestionIp()); if (str == null && (str = (String) CollectionsKt___CollectionsKt.firstOrNull((List) t14.getBackupIp())) == null) { str = ""; } hashMap.put(roomId, str); } } }