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);
    }
}