Fast Orange v3.5.3版本的 MD5 值为:33b91aba50c566533dfd683a85f79158
以下内容为反编译后的 a54.java 源代码,内容仅作参考
package com.free.vpn.proxy.hotspot;
import android.content.Context;
import android.content.SharedPreferences;
import androidx.lifecycle.CoroutineLiveDataKt;
import androidx.work.WorkRequest;
import com.free.vpn.proxy.hotspot.data.model.socket.SocketEvent;
import kotlin.Result;
import kotlin.ResultKt;
import kotlinx.coroutines.BuildersKt__Builders_commonKt;
import kotlinx.coroutines.CoroutineScope;
import kotlinx.coroutines.CoroutineScopeKt;
import kotlinx.coroutines.Dispatchers;
import kotlinx.coroutines.channels.ProducerScope;
import kotlinx.coroutines.flow.Flow;
import kotlinx.coroutines.flow.FlowKt;
public final class a54 {
public final Context a;
public final ih1 b;
public final q84 c;
public final CoroutineScope d = CoroutineScopeKt.CoroutineScope(Dispatchers.getIO());
public final ni1 e;
public final r44 f;
public final Flow g;
public a54(Context context, ih1 ih1Var, q84 q84Var) {
Object m4425constructorimpl;
SharedPreferences sharedPreferences;
this.a = context;
this.b = ih1Var;
this.c = q84Var;
ni1 ni1Var = new ni1();
ni1Var.b = "/socket.io/";
ni1Var.l = true;
ni1Var.t = true;
ni1Var.n = null;
ni1Var.k = new String[]{"websocket", "polling"};
ni1Var.o = true;
ni1Var.q = CoroutineLiveDataKt.DEFAULT_TIMEOUT;
ni1Var.r = WorkRequest.MIN_BACKOFF_MILLIS;
ni1Var.s = 60000L;
ni1Var.p = Integer.MAX_VALUE;
this.e = ni1Var;
try {
Result.Companion companion = Result.INSTANCE;
sharedPreferences = a9.a;
} catch (Throwable th) {
Result.Companion companion2 = Result.INSTANCE;
m4425constructorimpl = Result.m4425constructorimpl(ResultKt.createFailure(th));
}
if (sharedPreferences != null) {
String string = sharedPreferences.getString("socket_url", "https://wss.fosocket.com/");
m4425constructorimpl = Result.m4425constructorimpl(oi1.a(string == null ? "https://wss.fosocket.com/" : string, ni1Var));
if (Result.m4427exceptionOrNullimpl(m4425constructorimpl) != null) {
try {
m4425constructorimpl = Result.m4425constructorimpl(oi1.a("https://wss.fosocket.com/", this.e));
} catch (Throwable th2) {
Result.Companion companion3 = Result.INSTANCE;
m4425constructorimpl = Result.m4425constructorimpl(ResultKt.createFailure(th2));
}
}
this.f = (r44) (Result.m4429isFailureimpl(m4425constructorimpl) ? null : m4425constructorimpl);
Flow callbackFlow = FlowKt.callbackFlow(new v44(this, null));
this.g = callbackFlow;
FlowKt.launchIn(FlowKt.onEach(callbackFlow, new y44(this, null)), this.d);
FlowKt.launchIn(FlowKt.onEach(FlowKt.distinctUntilChanged(FlowKt.filterNotNull(new s91(((e9) this.b).n(), 3))), new x44(this, null)), this.d);
return;
}
zs4.s0("prefs");
throw null;
}
public static final void a(a54 a54Var) {
a54Var.c.b().e(new ks(new t44(), new xy4(yv2.z, 19)));
}
public static final void b(a54 a54Var, ProducerScope producerScope, SocketEvent socketEvent) {
BuildersKt__Builders_commonKt.launch$default(a54Var.d, null, null, new z44(producerScope, socketEvent, null), 3, null);
}
}