红果免费短剧 v6.2.3.32版本的 MD5 值为：a6b05492607eab2c8a25f26d2f238ae0

以下内容为反编译后的 a.java 源代码，内容仅作参考

package com.dragon.read.y;

import android.app.Application;
import com.bytedance.bdinstall.Level;
import com.bytedance.common.wschannel.event.ConnectEvent;
import com.bytedance.common.wschannel.model.WsChannelMsg;
import com.bytedance.sync.SyncSDK;
import com.bytedance.sync.f;
import com.bytedance.sync.i;
import com.bytedance.sync.interfaze.o;
import com.bytedance.sync.interfaze.p;
import com.dragon.read.app.SingleAppContext;
import com.dragon.read.base.util.LogWrapper;
import com.dragon.read.component.biz.callback.NsWebSocketCallback;
import com.dragon.read.util.DebugManager;
import com.ss.android.common.applog.NetUtil;
import com.ss.android.common.applog.TeaAgent;
import com.ss.android.deviceregister.DeviceRegisterManager;
import java.util.LinkedHashMap;
import java.util.Map;
import java.util.concurrent.atomic.AtomicBoolean;
import kotlin.jvm.internal.Intrinsics;
import org.json.JSONObject;

public final class a {

    public static p f96075b;

    public static final a f96074a = new a();

    private static final AtomicBoolean f96076c = new AtomicBoolean(false);
    private static final DeviceRegisterManager.OnDeviceConfigUpdateListener d = new c();

    public static final class b implements o {
        b() {
        }

        @Override
        public boolean a() {
            boolean b2 = com.dragon.read.websocket.c.f().b();
            boolean a2 = com.dragon.read.websocket.c.f().a();
            LogWrapper.debug("ByteSyncLaunchMgr", "isConnect: " + a2 + ",isInited:" + b2, new Object[0]);
            if (!a2 || !b2) {
                return false;
            }
            return true;
        }

        @Override
        public void a(p listener) {
            Intrinsics.checkNotNullParameter(listener, "listener");
            a aVar = a.f96074a;
            a.f96075b = listener;
        }

        @Override
        public void a(WsChannelMsg wsMsg) {
            Intrinsics.checkNotNullParameter(wsMsg, "wsMsg");
            try {
                com.dragon.read.websocket.c.f().b(wsMsg);
            } catch (Exception e) {
                LogWrapper.error("ByteSyncLaunchMgr", e.getMessage(), new Object[0]);
            }
        }
    }

    public static final class c implements DeviceRegisterManager.OnDeviceConfigUpdateListener {
        c() {
        }

        @Override
        public void onDidLoadLocally(boolean z) {
            a.f96074a.a();
        }

        @Override
        public void onDeviceRegistrationInfoChanged(String str, String str2) {
            a.f96074a.a();
        }

        @Override
        public void onRemoteConfigUpdate(boolean z, boolean z2) {
            a.f96074a.a();
        }
    }

    private a() {
    }

    static final class C3644a implements i {

        public static final C3644a f96077a = new C3644a();

        C3644a() {
        }

        @Override
        public final Map<String, String> a() {
            LinkedHashMap linkedHashMap = new LinkedHashMap();
            NetUtil.putCommonParamsWithLevel(linkedHashMap, true, Level.L1);
            return linkedHashMap;
        }
    }

    private final String b() {
        if (DebugManager.inst().isBOEMode()) {
            return "https://bsync-goapi-boe.bytedance.net";
        }
        return "https://bsync.snssdk.com";
    }

    private final int c() {
        if (DebugManager.inst().isBOEMode()) {
            return 20138;
        }
        return 20176;
    }

    public final void a() {
        boolean z;
        boolean z2;
        a aVar;
        boolean z3;
        String serverDeviceId = TeaAgent.getServerDeviceId();
        String installId = TeaAgent.getInstallId();
        LogWrapper.info("ByteSyncLaunchMgr", "deviceId= %s, installId= %s", serverDeviceId, installId);
        String str = serverDeviceId;
        if (str != null && str.length() != 0) {
            z = false;
        } else {
            z = true;
        }
        if (!z) {
            String str2 = installId;
            if (str2 != null && str2.length() != 0) {
                z3 = false;
            } else {
                z3 = true;
            }
            if (!z3) {
                z2 = false;
                if (z2) {
                    aVar = this;
                } else {
                    aVar = null;
                }
                if (aVar == null && f96076c.compareAndSet(false, true)) {
                    LogWrapper.debug("ByteSyncLaunchMgr", "start deviceId: " + serverDeviceId + ", installId: " + installId, new Object[0]);
                    SyncSDK.start(serverDeviceId, installId);
                    return;
                }
            }
        }
        z2 = true;
        if (z2) {
        }
        if (aVar == null) {
        }
    }

    public final void a(ConnectEvent connectEvent, JSONObject jSONObject) {
        p pVar = f96075b;
        if (pVar != null) {
            pVar.a(connectEvent);
        }
    }

    public final void a(Application application, boolean z) {
        Intrinsics.checkNotNullParameter(application, "application");
        LogWrapper.info("ByteSyncLaunchMgr", "switchToV2= %b", Boolean.valueOf(z));
        Application application2 = application;
        SyncSDK.init(application2, new f.a(String.valueOf(SingleAppContext.inst(application2).getAid()), 1, c()).a(b()).b("https://mon.snssdk.com").c(z).a(C3644a.f96077a).a(new b()).a());
        DeviceRegisterManager.addOnDeviceConfigUpdateListener(d);
        a();
        NsWebSocketCallback.IMPL.onSyncInitEnd();
    }
}