Fast Orange v3.5.3版本的 MD5 值为:33b91aba50c566533dfd683a85f79158

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


package com.free.vpn.proxy.hotspot;

import android.content.Context;
import android.content.SharedPreferences;
import android.util.Base64;
import com.free.vpn.proxy.hotspot.data.model.analytics.AnalyticsKeysKt;
import com.free.vpn.proxy.hotspot.data.model.analytics.LoginStatusEvent;
import com.free.vpn.proxy.hotspot.data.model.auth.Account;
import com.free.vpn.proxy.hotspot.data.model.auth.AccountApiEndpointType;
import com.free.vpn.proxy.hotspot.data.model.auth.AccountResponse;
import com.free.vpn.proxy.hotspot.data.model.auth.Device;
import com.free.vpn.proxy.hotspot.data.model.auth.Subscription;
import com.free.vpn.proxy.hotspot.data.model.auth.SubscriptionStatus;
import com.free.vpn.proxy.hotspot.data.model.auth.User;
import com.free.vpn.proxy.hotspot.data.model.auth.VipStatus;
import com.free.vpn.proxy.hotspot.data.model.billing.Processing;
import com.free.vpn.proxy.hotspot.domain.feature.metric.binom.BinomInstallPostbackWorker;
import com.ig.analytics.sdk.Tracker;
import java.net.SocketTimeoutException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Set;
import java.util.concurrent.TimeUnit;
import kotlinx.coroutines.CoroutineScope;
import kotlinx.coroutines.CoroutineScopeKt;
import kotlinx.coroutines.Dispatchers;
import kotlinx.coroutines.Job;
import kotlinx.coroutines.SupervisorKt;
import kotlinx.coroutines.flow.FlowKt;
import kotlinx.coroutines.flow.MutableStateFlow;
import kotlinx.coroutines.flow.SharingStarted;
import kotlinx.coroutines.flow.StateFlow;
import kotlinx.coroutines.flow.StateFlowKt;

public final class e9 extends p13 implements ih1 {
    public static final String[] j = {"test1710@test.wa", "demika002@gmail.com", "dashka.pastuh@gmail.com", "piskasobaki@gmail.com"};
    public final Context b;
    public final CoroutineScope c;
    public final CoroutineScope d;
    public final MutableStateFlow e;
    public final MutableStateFlow f;
    public final MutableStateFlow g;
    public boolean h;
    public boolean i;

    public e9(Context context) {
        super(context);
        this.b = context;
        a9.k(context);
        this.c = CoroutineScopeKt.CoroutineScope(Dispatchers.getMain());
        this.d = CoroutineScopeKt.CoroutineScope(Dispatchers.getIO().plus(SupervisorKt.SupervisorJob$default((Job) null, 1, (Object) null)));
        this.e = StateFlowKt.MutableStateFlow(m());
        this.f = StateFlowKt.MutableStateFlow(x());
        this.g = StateFlowKt.MutableStateFlow(y());
    }

    public static VipStatus j(Account account, Subscription subscription, Subscription subscription2) {
        if ((subscription2 == null || subscription2.isExpired()) ? false : true) {
            return VipStatus.Vip;
        }
        if ((subscription == null || subscription.isExpired()) ? false : true) {
            return VipStatus.General;
        }
        if (subscription2 != null || subscription != null) {
            return VipStatus.None;
        }
        VipStatus vipStatus = account != null ? account.getVipStatus() : null;
        return vipStatus == null ? VipStatus.None : vipStatus;
    }

    public final boolean A() {
        if (!B().isActive() || !x74.L0(o(), "samplemail", false)) {
            return false;
        }
        return true;
    }

    public final SubscriptionStatus B() {
        return (SubscriptionStatus) C().getValue();
    }

    public final StateFlow C() {
        return FlowKt.stateIn(FlowKt.combine(this.e, this.f, this.g, new lq1(1, this, null)), this.d, SharingStarted.Companion.WhileSubscribed$default(SharingStarted.INSTANCE, 0L, 0L, 1, null), r());
    }

    public final String D() {
        return c(AnalyticsKeysKt.KEY_TRAFFIC_SOURCE);
    }

    public final long E() {
        if (u80.t()) {
            return 599999000L;
        }
        return a(TimeUnit.MINUTES.toMillis(5L), "prs_max_time");
    }

    public final VipStatus F() {
        return (VipStatus) G().getValue();
    }

    public final StateFlow G() {
        d9 d9Var = new d9(this);
        return FlowKt.stateIn(FlowKt.combine(this.e, this.f, this.g, d9Var), this.d, SharingStarted.Companion.WhileSubscribed$default(SharingStarted.INSTANCE, 0L, 0L, 1, null), j(m(), x(), y()));
    }

    public final Subscription H() {
        Subscription y = y();
        if (y != null) {
            return y;
        }
        Account m = m();
        if (m != null) {
            return m.getVipSubscription();
        }
        return null;
    }

    public final boolean I() {
        Boolean bool;
        Subscription H = H();
        Subscription v = v();
        if (H == null) {
            H = v;
        }
        if (H != null) {
            bool = Boolean.valueOf(H.isLifetime());
        } else {
            bool = null;
        }
        return to.p0(bool, false);
    }

    public final boolean J() {
        return d("prs_completed", false);
    }

    public final void K(AccountResponse accountResponse, int i) {
        String str;
        LoginStatusEvent loginStatusEvent;
        String message;
        String str2;
        String str3;
        String str4;
        String productId;
        String source;
        String platform;
        String utmTerm;
        String trafficSource;
        String gclid;
        String clickId;
        String phone;
        String email;
        y13.x(i, "source");
        if (accountResponse != null) {
            boolean isError = accountResponse.getIsError();
            String str5 = "";
            String str6 = LoginStatusEvent.ERROR_EVENT_ERROR_TOKEN;
            if (!isError) {
                Account account = accountResponse.getAccount();
                if (account != null) {
                    if (account.getSuccess()) {
                        int[] F = n05.F(6);
                        SharedPreferences sharedPreferences = this.a;
                        String str7 = null;
                        if (F[sharedPreferences.getInt("login_source", 0)] == 1) {
                            if (i != 0) {
                                SharedPreferences.Editor edit = sharedPreferences.edit();
                                zs4.n(edit, "editor");
                                edit.putInt("login_source", i - 1);
                                edit.apply();
                            } else {
                                throw null;
                            }
                        }
                        String token = account.getToken();
                        if (token != null) {
                            if (!(!x74.a1(token))) {
                                token = null;
                            }
                            if (token != null) {
                                g("nekot_tnuocca", token);
                            }
                        }
                        L(account);
                        User user = account.getUser();
                        if (user != null && (email = user.getEmail()) != null) {
                            if (!(!x74.a1(email))) {
                                email = null;
                            }
                            if (email != null) {
                                g("nigol_ntuocca", email);
                            }
                        }
                        User user2 = account.getUser();
                        if (user2 != null && (phone = user2.getPhone()) != null) {
                            if (!(!x74.a1(phone))) {
                                phone = null;
                            }
                            if (phone != null) {
                                g("nigol_ntuocca", phone);
                            }
                        }
                        User user3 = account.getUser();
                        if (user3 != null && (clickId = user3.getClickId()) != null) {
                            if (!(!x74.a1(clickId))) {
                                clickId = null;
                            }
                            if (clickId != null) {
                                g(AnalyticsKeysKt.KEY_CLICK_ID, clickId);
                                BinomInstallPostbackWorker.INSTANCE.start(this.b, 0L, true);
                            }
                        }
                        User user4 = account.getUser();
                        if (user4 != null && (gclid = user4.getGclid()) != null) {
                            if (!(!x74.a1(gclid))) {
                                gclid = null;
                            }
                            if (gclid != null) {
                                if (!x74.a1(c(AnalyticsKeysKt.KEY_GOOGLE_CLICK_ID))) {
                                    gclid = null;
                                }
                                if (gclid != null) {
                                    g(AnalyticsKeysKt.KEY_GOOGLE_CLICK_ID, gclid);
                                }
                            }
                        }
                        User user5 = account.getUser();
                        if (user5 != null && (trafficSource = user5.getTrafficSource()) != null) {
                            if (!(!x74.a1(trafficSource))) {
                                trafficSource = null;
                            }
                            if (trafficSource != null) {
                                if (!x74.a1(D())) {
                                    trafficSource = null;
                                }
                                if (trafficSource != null) {
                                    g(AnalyticsKeysKt.KEY_TRAFFIC_SOURCE, trafficSource);
                                }
                            }
                        }
                        User user6 = account.getUser();
                        if (user6 != null && (utmTerm = user6.getUtmTerm()) != null) {
                            if (!(!x74.a1(utmTerm))) {
                                utmTerm = null;
                            }
                            if (utmTerm != null) {
                                if (!x74.a1(c("utm_term"))) {
                                    utmTerm = null;
                                }
                                if (utmTerm != null) {
                                    g("utm_term", utmTerm);
                                }
                            }
                        }
                        User user7 = account.getUser();
                        if (user7 != null && (platform = user7.getPlatform()) != null) {
                            if (!(!x74.a1(platform))) {
                                platform = null;
                            }
                            if (platform != null) {
                                if (!x74.a1(c(AnalyticsKeysKt.KEY_PLATFORM))) {
                                    platform = null;
                                }
                                if (platform != null) {
                                    g(AnalyticsKeysKt.KEY_PLATFORM, platform);
                                }
                            }
                        }
                        User user8 = account.getUser();
                        if (user8 != null && (source = user8.getSource()) != null) {
                            if (!(!x74.a1(source))) {
                                source = null;
                            }
                            if (source != null) {
                                if (!x74.a1(c("src"))) {
                                    source = null;
                                }
                                if (source != null) {
                                    S(source);
                                }
                            }
                        }
                        String radiusLogin = account.getRadiusLogin();
                        if (radiusLogin != null) {
                            if (!(!x74.a1(radiusLogin))) {
                                radiusLogin = null;
                            }
                            if (radiusLogin != null) {
                                String E = u80.E(0, radiusLogin);
                                if (E == null) {
                                    E = "";
                                }
                                g("radius_login", E);
                            }
                        }
                        String radiusPassword = account.getRadiusPassword();
                        if (radiusPassword != null) {
                            if (!(!x74.a1(radiusPassword))) {
                                radiusPassword = null;
                            }
                            if (radiusPassword != null) {
                                String E2 = u80.E(0, radiusPassword);
                                if (E2 != null) {
                                    str5 = E2;
                                }
                                g("radius_pass", str5);
                            }
                        }
                        Subscription generalSubscription = account.getGeneralSubscription();
                        if (generalSubscription != null && (productId = generalSubscription.getProductId()) != null) {
                            if (!x74.a1(productId)) {
                                str7 = productId;
                            }
                            if (str7 != null) {
                                g("noitpircsbus_yek", str7);
                            }
                        }
                        if (d("branch_token", false)) {
                            str4 = LoginStatusEvent.EVENT_SUCCESS_TOKEN;
                        } else {
                            str4 = LoginStatusEvent.SUCCESS_EVENT;
                        }
                        loginStatusEvent = new LoginStatusEvent(str4, (int) a(0L, "app_init_counter"), o(), q(), accountResponse.getEndpointType(), null, 32, null);
                    } else {
                        if (d("branch_token", false)) {
                            str3 = LoginStatusEvent.ERROR_EVENT_ERROR_TOKEN;
                        } else {
                            str3 = LoginStatusEvent.ERROR_EVENT_INCORRECT;
                        }
                        loginStatusEvent = new LoginStatusEvent(str3, (int) a(0L, "app_init_counter"), o(), q(), accountResponse.getEndpointType(), null, 32, null);
                    }
                } else {
                    return;
                }
            } else {
                if (accountResponse.getErrorException() instanceof SocketTimeoutException) {
                    str6 = LoginStatusEvent.ERROR_EVENT_TIMEOUT;
                } else if (!d("branch_token", false)) {
                    str = LoginStatusEvent.ERROR_EVENT_INCORRECT;
                    int a = (int) a(0L, "app_init_counter");
                    String o = o();
                    String q = q();
                    AccountApiEndpointType endpointType = accountResponse.getEndpointType();
                    message = accountResponse.getMessage();
                    if (message != null) {
                        str2 = "";
                    } else {
                        str2 = message;
                    }
                    loginStatusEvent = new LoginStatusEvent(str, a, o, q, endpointType, str2);
                }
                str = str6;
                int a2 = (int) a(0L, "app_init_counter");
                String o2 = o();
                String q2 = q();
                AccountApiEndpointType endpointType2 = accountResponse.getEndpointType();
                message = accountResponse.getMessage();
                if (message != null) {
                }
                loginStatusEvent = new LoginStatusEvent(str, a2, o2, q2, endpointType2, str2);
            }
            Tracker.track(loginStatusEvent);
        }
    }

    public final void L(Account account) {
        MutableStateFlow mutableStateFlow;
        Object value;
        User user;
        String email;
        io.sentry.a2.b().k(new c9(0, account, this));
        if (account != null && (user = account.getUser()) != null && (email = user.getEmail()) != null) {
            if (!da.E0(j, email)) {
                email = null;
            }
            if (email != null) {
                h("sandbox_enabled", true);
            }
        }
        f(account, Account.class, "ntuocca");
        do {
            mutableStateFlow = this.e;
            value = mutableStateFlow.getValue();
        } while (!mutableStateFlow.compareAndSet(value, account));
    }

    public final void M(String str) {
        zs4.o(str, "value");
        byte[] bytes = str.getBytes(dw.a);
        zs4.n(bytes, "getBytes(...)");
        String encodeToString = Base64.encodeToString(bytes, 0);
        zs4.n(encodeToString, "pass");
        g("acc_pwd", encodeToString);
    }

    public final void N(List list) {
        SharedPreferences.Editor edit = this.a.edit();
        ArrayList arrayList = new ArrayList(q00.A0(list, 10));
        Iterator it = list.iterator();
        while (it.hasNext()) {
            arrayList.add(((yx4) it.next()).a);
        }
        edit.putStringSet("allowed_protocols", t00.L1(arrayList));
        edit.apply();
    }

    public final void O() {
        h("logout", true);
    }

    public final void P(Subscription subscription) {
        ex0.N(this.a, Subscription.class, subscription, "sandbox_subscription", false);
        this.f.setValue(subscription);
    }

    public final void Q(Subscription subscription) {
        ex0.N(this.a, Subscription.class, subscription, "sandbox_vip_subscription", false);
        this.g.setValue(subscription);
    }

    public final void R(Processing processing) {
        String str;
        if (processing != null) {
            str = processing.getKey();
        } else {
            str = null;
        }
        SharedPreferences sharedPreferences = this.a;
        zs4.o(sharedPreferences, "<this>");
        SharedPreferences.Editor edit = sharedPreferences.edit();
        zs4.n(edit, "editor");
        if (str == null) {
            edit.remove("sandboxTargetProcessing");
        } else {
            edit.putString("sandboxTargetProcessing", str);
        }
        edit.apply();
    }

    public final void S(String str) {
        if (!zs4.h(c("src"), str) && x74.R0(str, "referral")) {
            SharedPreferences sharedPreferences = a9.a;
            if (sharedPreferences != null) {
                jf2.w(sharedPreferences, "ref_dialog_show", true);
            } else {
                zs4.s0("prefs");
                throw null;
            }
        }
        g("src", str);
    }

    public final void k() {
        MutableStateFlow mutableStateFlow;
        Object value;
        i("ntuocca");
        i("nigol_ntuocca");
        i("nekot_tnuocca");
        i("acc_pwd");
        do {
            mutableStateFlow = this.e;
            value = mutableStateFlow.getValue();
        } while (!mutableStateFlow.compareAndSet(value, null));
    }

    public final void l(Device device) {
        ArrayList<Device> devices;
        zs4.o(device, "device");
        try {
            Account m = m();
            if (m != null && (devices = m.getDevices()) != null) {
                devices.remove(device);
            }
            L(m);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public final Account m() {
        return (Account) b(null, Account.class, "ntuocca");
    }

    public final StateFlow n() {
        SharingStarted WhileSubscribed$default = SharingStarted.Companion.WhileSubscribed$default(SharingStarted.INSTANCE, 0L, 0L, 1, null);
        MutableStateFlow mutableStateFlow = this.e;
        return FlowKt.stateIn(mutableStateFlow, this.d, WhileSubscribed$default, mutableStateFlow.getValue());
    }

    public final String o() {
        return c("nigol_ntuocca");
    }

    public final String p() {
        String c = c("acc_pwd");
        if (!(!x74.a1(c))) {
            return c;
        }
        byte[] decode = Base64.decode(c, 0);
        zs4.n(decode, "decode(pass, Base64.DEFAULT)");
        return new String(decode, dw.a);
    }

    public final String q() {
        return c("nekot_tnuocca");
    }

    public final SubscriptionStatus r() {
        Subscription v = v();
        SubscriptionStatus subscriptionStatus = v != null ? v.getSubscriptionStatus() : null;
        SubscriptionStatus subscriptionStatus2 = SubscriptionStatus.NONE;
        if (subscriptionStatus == null) {
            subscriptionStatus = subscriptionStatus2;
        }
        Subscription H = H();
        SubscriptionStatus subscriptionStatus3 = H != null ? H.getSubscriptionStatus() : null;
        if (subscriptionStatus3 != null) {
            subscriptionStatus2 = subscriptionStatus3;
        }
        return (subscriptionStatus.isActive() ^ true) & subscriptionStatus2.isActive() ? subscriptionStatus2 : subscriptionStatus;
    }

    public final ArrayList s() {
        List t = t();
        ArrayList arrayList = new ArrayList(q00.A0(t, 10));
        Iterator it = t.iterator();
        while (it.hasNext()) {
            arrayList.add(((yx4) it.next()).a);
        }
        return arrayList;
    }

    public final List t() {
        Set<String> stringSet = this.a.getStringSet("allowed_protocols", null);
        if (stringSet == null) {
            return da.u1(yx4.values());
        }
        ArrayList arrayList = new ArrayList();
        Iterator<T> it = stringSet.iterator();
        while (it.hasNext()) {
            yx4 i = w11.i((String) it.next());
            if (i != null) {
                arrayList.add(i);
            }
        }
        return arrayList;
    }

    public final String u() {
        return c(AnalyticsKeysKt.KEY_CLICK_ID);
    }

    public final Subscription v() {
        Subscription x = x();
        if (x != null) {
            return x;
        }
        Account m = m();
        if (m != null) {
            return m.getGeneralSubscription();
        }
        return null;
    }

    public final boolean w() {
        return n().getValue() != null;
    }

    public final Subscription x() {
        return (Subscription) ex0.u(this.a, Subscription.class, null, "sandbox_subscription", false);
    }

    public final Subscription y() {
        return (Subscription) ex0.u(this.a, Subscription.class, null, "sandbox_vip_subscription", false);
    }

    public final Processing z() {
        String string = this.a.getString("sandboxTargetProcessing", null);
        if (string != null) {
            return Processing.INSTANCE.parse(string);
        }
        return null;
    }
}