流利说-英语 v8.47.26版本的 MD5 值为：0079dce5ff96e6cdbc95c261b3f51387

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

package com.liulishuo.lingodarwin.center.network;

import com.liulishuo.cert_pinner.CanaryReleasingConfig;
import com.liulishuo.lingodarwin.center.frame.DWApkConfig;
import com.liulishuo.lingodarwin.center.frame.i;
import com.liulishuo.lingodarwin.center.network.e;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.LinkedHashMap;
import java.util.List;
import java.util.Map;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.internal.t;
import okhttp3.Dispatcher;
import okhttp3.Interceptor;
import okhttp3.OkHttpClient;
import okhttp3.logging.HttpLoggingInterceptor;
import retrofit2.Retrofit;
import retrofit2.adapter.rxjava.RxJavaCallAdapterFactory;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.converter.gson.KGsonConverterFactory;
import rx.Observable;
import rx.subjects.BehaviorSubject;

@kotlin.i
public final class e {
    private String baseUrl;
    private boolean diI;
    private Map<String, String> diJ;
    private Map<String, String> diK;
    private final List<Interceptor> diL;
    private final BehaviorSubject<Object> diM;
    private final n diN;
    private final kotlin.d diO;
    private final kotlin.d diP;
    private final kotlin.d diQ;
    private final k diR;
    private final Map<String, Retrofit> diS;
    public static final a diY = new a(null);
    private static final h diT = new h();
    private static final HttpLoggingInterceptor diU = new HttpLoggingInterceptor(c.dja);
    private static final f diV = new f(b.diZ);
    private static final j diW = new j();
    private static final m diX = new m();

    private final Interceptor aMG() {
        return (Interceptor) this.diO.getValue();
    }

    public final Retrofit aMH() {
        return (Retrofit) this.diP.getValue();
    }

    public final Retrofit aMI() {
        return (Retrofit) this.diQ.getValue();
    }

    public e(String baseUrl) {
        t.g(baseUrl, "baseUrl");
        this.baseUrl = baseUrl;
        this.diJ = new LinkedHashMap();
        this.diK = new LinkedHashMap();
        this.diL = new ArrayList();
        this.diM = BehaviorSubject.create();
        this.diN = new n();
        this.diO = kotlin.e.bJ(new kotlin.jvm.a.a<Interceptor>() {
            @Override
            public final Interceptor invoke() {
                final com.liulishuo.cert_pinner.a aVar = new com.liulishuo.cert_pinner.a("https://pecado.llscdn.com/public_key_pinning/production/pkp");
                aVar.a(kotlin.k.E(new CanaryReleasingConfig(Double.valueOf(1.0d), Double.valueOf(0.0d)), Long.valueOf(System.currentTimeMillis())));
                return com.liulishuo.cert_pinner.k.b(new kotlin.jvm.a.a<Boolean>() {
                    {
                        super(0);
                    }

                    @Override
                    public Boolean invoke() {
                        return Boolean.valueOf(invoke2());
                    }

                    public final boolean invoke2() {
                        com.liulishuo.cert_pinner.a aVar2 = com.liulishuo.cert_pinner.a.this;
                        String deviceId = com.liulishuo.lingodarwin.center.helper.a.getDeviceId(com.liulishuo.lingodarwin.center.frame.b.getApp());
                        t.e(deviceId, "ContextHelper.getDeviceI…licationContext.getApp())");
                        return aVar2.fg(deviceId);
                    }
                });
            }
        });
        this.diP = kotlin.e.bJ(new kotlin.jvm.a.a<Retrofit>() {
            {
                super(0);
            }

            @Override
            public final Retrofit invoke() {
                Retrofit.Builder client = new Retrofit.Builder().baseUrl(e.diY.u(e.this.getBaseUrl(), true)).client(e.this.ea(false));
                client.addCallAdapterFactory(RxJavaCallAdapterFactory.createAsync());
                client.addCallAdapterFactory(RxJava2CallAdapterFactory.createAsync());
                client.addCallAdapterFactory(a.diA.aMv());
                client.addConverterFactory(KGsonConverterFactory.INSTANCE);
                return client.callbackExecutor(i.a.aKR()).build();
            }
        });
        this.diQ = kotlin.e.bJ(new kotlin.jvm.a.a<Retrofit>() {
            {
                super(0);
            }

            @Override
            public final Retrofit invoke() {
                Retrofit.Builder builder = new Retrofit.Builder();
                e.a aVar = e.diY;
                String aHF = com.liulishuo.lingodarwin.center.c.c.aHF();
                t.e(aHF, "DWConfig.getOverlordBaseUrl()");
                Retrofit.Builder client = builder.baseUrl(aVar.u(aHF, true)).client(e.this.ea(false));
                client.addCallAdapterFactory(RxJavaCallAdapterFactory.createAsync());
                client.addCallAdapterFactory(RxJava2CallAdapterFactory.createAsync());
                client.addCallAdapterFactory(a.diA.aMv());
                client.addConverterFactory(KGsonConverterFactory.INSTANCE);
                return client.callbackExecutor(i.a.aKR()).build();
            }
        });
        this.diR = new k();
        this.diS = new LinkedHashMap();
    }

    public final String getBaseUrl() {
        return this.baseUrl;
    }

    public final Observable<Object> aME() {
        BehaviorSubject<Object> unAuthSubject = this.diM;
        t.e(unAuthSubject, "unAuthSubject");
        return unAuthSubject;
    }

    public final BehaviorSubject<Integer> aMF() {
        return this.diN.aMX();
    }

    public final e dZ(boolean z) {
        this.diI = z;
        return this;
    }

    public final <T> T getService(Class<T> serviceClass) {
        t.g(serviceClass, "serviceClass");
        return (T) a(this, serviceClass, null, true, false, 10, null);
    }

    public static Object a(e eVar, Class cls, String str, boolean z, boolean z2, int i, Object obj) {
        if ((i & 2) != 0) {
            str = eVar.baseUrl;
        }
        if ((i & 4) != 0) {
            z = true;
        }
        if ((i & 8) != 0) {
            z2 = false;
        }
        return eVar.a(cls, str, z, z2);
    }

    public final <T> T a(Class<T> serviceClass, String baseUrl, boolean z, boolean z2) {
        t.g(serviceClass, "serviceClass");
        t.g(baseUrl, "baseUrl");
        String str = diY.u(baseUrl, z) + z2;
        Retrofit retrofit = this.diS.get(str);
        if (retrofit != null) {
            return (T) retrofit.create(serviceClass);
        }
        Retrofit.Builder client = new Retrofit.Builder().baseUrl(diY.u(baseUrl, z)).client(ea(z2));
        client.addCallAdapterFactory(RxJavaCallAdapterFactory.createAsync());
        client.addCallAdapterFactory(RxJava2CallAdapterFactory.createAsync());
        client.addCallAdapterFactory(com.liulishuo.lingodarwin.center.network.a.diA.aMv());
        client.addConverterFactory(KGsonConverterFactory.INSTANCE);
        Retrofit retrofitCurrent = client.callbackExecutor(i.a.aKR()).build();
        Map<String, Retrofit> map = this.diS;
        t.e(retrofitCurrent, "retrofitCurrent");
        map.put(str, retrofitCurrent);
        return (T) retrofitCurrent.create(serviceClass);
    }

    public final e a(Interceptor interceptor) {
        t.g(interceptor, "interceptor");
        this.diL.add(interceptor);
        return this;
    }

    public final e b(Interceptor interceptor) {
        t.g(interceptor, "interceptor");
        e eVar = this;
        eVar.diL.add(0, interceptor);
        return eVar;
    }

    public final OkHttpClient aMJ() {
        return d.djf.aMU();
    }

    public final OkHttpClient aMK() {
        OkHttpClient aMS = d.djf.aMS();
        t.e(aMS, "OkHttpClientHolder.SIMPLE_OK_HTTP_CLIENT");
        return aMS;
    }

    public final OkHttpClient aML() {
        OkHttpClient OK_DOWNLOAD_HTTP_CLIENT = d.djf.aMT();
        t.e(OK_DOWNLOAD_HTTP_CLIENT, "OK_DOWNLOAD_HTTP_CLIENT");
        return OK_DOWNLOAD_HTTP_CLIENT;
    }

    public final OkHttpClient aMM() {
        OkHttpClient aMV = d.djf.aMV();
        t.e(aMV, "OkHttpClientHolder.WEB_SOCKET_OK_HTTP_CLIENT");
        return aMV;
    }

    public static OkHttpClient.Builder a(e eVar, boolean z, boolean z2, int i, Object obj) {
        if ((i & 2) != 0) {
            z2 = true;
        }
        return eVar.m(z, z2);
    }

    public final OkHttpClient.Builder m(boolean z, boolean z2) {
        OkHttpClient.Builder builder = d.djf.aMU().newBuilder();
        if (z) {
            builder.addInterceptor(diT);
        }
        k kVar = new k();
        kVar.r(this.diK);
        builder.addInterceptor(kVar);
        if (!this.diJ.isEmpty()) {
            i iVar = new i();
            iVar.q(this.diJ);
            builder.addInterceptor(iVar);
        }
        if (!this.diL.isEmpty()) {
            Iterator<Interceptor> it = this.diL.iterator();
            while (it.hasNext()) {
                builder.addInterceptor(it.next());
            }
        }
        if (this.diI) {
            builder.addInterceptor(diV);
            builder.addInterceptor(diW);
        }
        builder.addNetworkInterceptor(aMG());
        if (z2) {
            builder.addNetworkInterceptor(this.diN);
        }
        builder.eventListenerFactory(com.liulishuo.thanossdk.network.d.iTp.dkp());
        t.e(builder, "builder");
        return builder;
    }

    public final OkHttpClient ea(boolean z) {
        OkHttpClient build = a(this, z, false, 2, null).build();
        t.e(build, "getHttpClientBuilder(needGzip).build()");
        return build;
    }

    public final void aMN() {
        Object ae = com.liulishuo.d.c.ae(com.liulishuo.lingodarwin.loginandregister.a.b.class);
        t.e(ae, "PluginManager.safeGet(Lo…dRegisterApi::class.java)");
        if (((com.liulishuo.lingodarwin.loginandregister.a.b) ae).bua()) {
            this.diM.onNext(null);
        }
    }

    public final OkHttpClient aMO() {
        OkHttpClient build = m(false, false).build();
        t.e(build, "getHttpClientBuilder(nee…erceptor = false).build()");
        return build;
    }

    public final OkHttpClient.Builder aMP() {
        OkHttpClient.Builder builder = d.djf.aMU().newBuilder().addInterceptor(o.dju.aMZ());
        if (!this.diJ.isEmpty()) {
            i iVar = new i();
            iVar.q(this.diJ);
            builder.addInterceptor(iVar);
        }
        t.e(builder, "builder");
        return builder;
    }

    @kotlin.i
    public static final class d {
        private static final OkHttpClient djb;
        private static final OkHttpClient djc;
        private static final OkHttpClient djd;
        private static final OkHttpClient dje;
        public static final d djf;

        static {
            d dVar = new d();
            djf = dVar;
            djb = s.djz.aNe().build();
            djc = s.djz.aNe().connectTimeout(30L, TimeUnit.SECONDS).readTimeout(30L, TimeUnit.SECONDS).build();
            djd = dVar.build();
            dje = dVar.build().newBuilder().addInterceptor(o.dju.aMZ()).build();
        }

        private d() {
        }

        public final OkHttpClient aMS() {
            return djb;
        }

        public final OkHttpClient aMT() {
            return djc;
        }

        public final OkHttpClient aMU() {
            return djd;
        }

        public final OkHttpClient aMV() {
            return dje;
        }

        private final OkHttpClient build() {
            OkHttpClient.Builder readTimeout = djb.newBuilder().connectTimeout(10L, TimeUnit.SECONDS).readTimeout(30L, TimeUnit.SECONDS);
            e.diU.setLevel(HttpLoggingInterceptor.Level.BODY);
            if (DWApkConfig.isDebug() || DWApkConfig.afa()) {
                readTimeout.addInterceptor(e.diU);
            }
            com.liulishuo.lingodarwin.center.c.d("CertPinner", "creating interceptor", new Object[0]);
            com.liulishuo.cert_pinner.l.a(com.liulishuo.cert_pinner.o.cac);
            String deviceId = com.liulishuo.lingodarwin.center.helper.a.getDeviceId(com.liulishuo.lingodarwin.center.frame.b.getApp());
            t.e(deviceId, "ContextHelper.getDeviceI…p()\n                    )");
            readTimeout.addNetworkInterceptor(com.liulishuo.cert_pinner.k.a(deviceId, null, null, 6, null));
            readTimeout.addInterceptor(e.diX);
            readTimeout.dns(com.liulishuo.lingodarwin.center.network.c.aMy());
            readTimeout.eventListenerFactory(com.liulishuo.thanossdk.network.d.iTp.dkp());
            readTimeout.dispatcher(new Dispatcher(i.a.aKQ()));
            OkHttpClient build = readTimeout.build();
            t.e(build, "builder.build()");
            return build;
        }
    }

    @kotlin.i
    public static final class a {
        private a() {
        }

        public a(kotlin.jvm.internal.o oVar) {
            this();
        }

        public final String u(String targetUrl, boolean z) {
            t.g(targetUrl, "targetUrl");
            if (kotlin.text.m.b(targetUrl, "http", false, 2, (Object) null)) {
                return targetUrl;
            }
            if (z) {
                return "https://" + targetUrl;
            }
            return "http://" + targetUrl;
        }
    }

    @kotlin.i
    static final class c implements HttpLoggingInterceptor.Logger {
        public static final c dja = new c();

        c() {
        }

        @Override
        public final void log(String str) {
            com.liulishuo.lingodarwin.center.c.d("DWApiManager", "api request msg is ==> %s", str);
        }
    }

    @kotlin.i
    static final class b implements HttpLoggingInterceptor.Logger {
        public static final b diZ = new b();

        b() {
        }

        @Override
        public final void log(String str) {
            com.liulishuo.lingodarwin.center.c.d("DWApiManager", "CURL Request: \n%s", str);
        }
    }
}