漫天星 v3.0.2 - e.java 源代码

package f.p.d.c;

import com.junyue.basic.app.App;
import com.junyue.basic.bean.User;
import com.junyue.novel.modules.bookstore.bean.BookCommentResult;
import f.p.c.z.h;
import f.p.c.z.y;
import f.p.d.c.e;
import i.t;
import java.io.IOException;
import java.lang.annotation.Annotation;
import java.net.Proxy;
import java.net.ProxySelector;
import java.net.SocketAddress;
import java.net.URI;
import java.util.Collections;
import java.util.List;
import java.util.concurrent.TimeUnit;
import kotlin.jvm.functions.Function1;
import okhttp3.OkHttpClient;
import okhttp3.internal.proxy.NullProxySelector;
import okhttp3.logging.HttpLoggingInterceptor;

public final class e {
    public static final List<Class<? extends Annotation>> a = Collections.singletonList(f.p.c.v.a.class);

    public static class a implements HttpLoggingInterceptor.Logger {
        public void log(String str) {
            f.n.a.b.a.c("HttpUtils", str, new Object[0]);
        }
    }

    public static class b implements Runnable {
        public static t a(f.a.a.a.d.a aVar) {
            aVar.K("login_over", true);
            return t.a;
        }

        @Override
        public void run() {
            f.p.c.m.c.l().d(User.class);
            e.a.b.c.c q = App.q();
            if (q == null || q.isFinishing()) {
                q = App.r();
            }
            h.a(q, -1, new Function1() {
                public final Object invoke(Object obj) {
                    return e.b.a((f.a.a.a.d.a) obj);
                }
            });
        }
    }

    public static class c {
        public static final OkHttpClient a = e.d().readTimeout(BookCommentResult.COMMENT_TIME_OUT, TimeUnit.MILLISECONDS).writeTimeout(BookCommentResult.COMMENT_TIME_OUT, TimeUnit.MILLISECONDS).connectTimeout(15000, TimeUnit.MILLISECONDS).build();
    }

    public static class C0078e {
        public static final OkHttpClient a = new OkHttpClient.Builder().addNetworkInterceptor(new HttpLoggingInterceptor(new a()).setLevel(HttpLoggingInterceptor.Level.BODY)).addInterceptor(new f.p.d.c.d()).readTimeout(60, TimeUnit.SECONDS).writeTimeout(60, TimeUnit.SECONDS).connectTimeout(60, TimeUnit.SECONDS).build();

        public static class a implements HttpLoggingInterceptor.Logger {
            public void log(String str) {
                e.a.b.f.d.a("HttpUtils", str, new Object[0]);
            }
        }
    }

    public static class f {
        public static final OkHttpClient a = new OkHttpClient.Builder().addNetworkInterceptor(new HttpLoggingInterceptor(new a()).setLevel(HttpLoggingInterceptor.Level.BODY)).addInterceptor(new g()).build();

        public static class a implements HttpLoggingInterceptor.Logger {
            public void log(String str) {
                e.a.b.f.d.a("HttpUtils", str, new Object[0]);
            }
        }
    }

    public static OkHttpClient.Builder a() {
        return b(true);
    }

    public static OkHttpClient.Builder b(boolean z) {
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        if (z) {
            builder.addNetworkInterceptor(new HttpLoggingInterceptor(new a()).setLevel(HttpLoggingInterceptor.Level.BODY));
        }
        if (c()) {
            builder.proxySelector(new d(null));
        } else {
            builder.proxy(Proxy.NO_PROXY).proxySelector(new NullProxySelector());
        }
        return builder;
    }

    public static boolean c() {
        return false;
    }

    public static OkHttpClient.Builder d() {
        return a().addInterceptor(new f.p.d.c.b()).addInterceptor(new f.p.d.c.f()).addInterceptor(new f.p.d.c.d());
    }

    public static OkHttpClient e() {
        return c.a;
    }

    public static OkHttpClient f() {
        return C0078e.a;
    }

    public static OkHttpClient g() {
        return f.a;
    }

    public static boolean h(Annotation[] annotationArr) {
        for (Annotation annotation : annotationArr) {
            if (a.contains(annotation.annotationType())) {
                return true;
            }
        }
        return false;
    }

    public static void i() {
        if (User.k()) {
            y.a(new b());
        }
    }

    public static class d extends ProxySelector {
        public final ProxySelector a;

        public d() {
            this.a = ProxySelector.getDefault();
        }

        public final boolean a(URI uri) {
            String host = uri.getHost();
            return "127.0.0.1".equals(host) || "localhost".equals(host);
        }

        @Override
        public void connectFailed(URI uri, SocketAddress socketAddress, IOException iOException) {
            if (uri == null || socketAddress == null || iOException == null) {
                throw new IllegalArgumentException("Arguments can't be null.");
            }
        }

        @Override
        public List<Proxy> select(URI uri) {
            if (uri != null) {
                return (this.a == null || a(uri)) ? Collections.singletonList(Proxy.NO_PROXY) : this.a.select(uri);
            }
            throw new IllegalArgumentException("uri must not be null");
        }

        public d(a aVar) {
            this();
        }
    }
}