导航菜单
登录 注册

页面标题

页面副标题

FanCode v7.24.0 - d.java 源代码

正在查看： FanCode v7.24.0 应用的 d.java JAVA 源代码文件

本页面展示 JAVA 反编译生成的源代码文件，支持语法高亮显示。 仅供安全研究与技术分析使用，严禁用于任何非法用途。请遵守相关法律法规。 


package qc;

import android.content.Context;
import android.os.Handler;
import android.os.Looper;
import android.util.Pair;
import android.widget.Toast;
import com.google.android.gms.common.internal.ImagesContract;
import com.newrelic.agent.android.instrumentation.Instrumented;
import com.newrelic.agent.android.instrumentation.okhttp3.OkHttp3Instrumentation;
import h4.b;
import java.security.KeyStore;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
import javax.net.ssl.TrustManager;
import javax.net.ssl.TrustManagerFactory;
import javax.net.ssl.X509TrustManager;
import jm.c1;
import jm.m0;
import jm.o0;
import jm.r1;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.coroutines.CoroutineContext;
import kotlin.jvm.functions.Function0;
import kotlin.jvm.functions.Function2;
import kotlin.jvm.internal.DefaultConstructorMarker;
import kotlin.jvm.internal.Intrinsics;
import kotlin.jvm.internal.Lambda;
import kotlin.jvm.internal.SourceDebugExtension;
import mc.b;
import okhttp3.Interceptor;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import org.jetbrains.annotations.NotNull;
import org.json.JSONObject;
import qc.b;
import qc.d;
import qc.f;
import rl.n;

@Metadata
@Instrumented
@SourceDebugExtension({"SMAP\nBaseRepository.kt\nKotlin\n*S Kotlin\n*F\n+ 1 BaseRepository.kt\ncom/fancode/core/respository/BaseRepository\n+ 2 fake.kt\nkotlin/jvm/internal/FakeKt\n*L\n1#1,238:1\n1#2:239\n*E\n"})
public class d {

    @NotNull
    public static final a j = new a(null);
    private static String k;
    private Context b;
    private String c;
    private boolean f;
    private final int a = 60;

    @NotNull
    private final rl.g d = rl.h.a(new e());

    @NotNull
    private final rl.g e = rl.h.a(new b());

    @NotNull
    private String g = "https://uat.fancode.com/graphql";

    @NotNull
    private String h = "";

    @NotNull
    private final c i = new c();

    @Metadata
    public static final class a {
        private a() {
        }

        public a(DefaultConstructorMarker defaultConstructorMarker) {
            this();
        }
    }

    @Metadata
    static final class b extends Lambda implements Function0<h4.b> {
        b() {
            super(0);
        }

        @NotNull
        public final h4.b invoke() {
            return d.this.n();
        }
    }

    @Metadata
    public static final class c implements b.a {

        @NotNull
        private final rl.g a;

        @Metadata
        static final class a extends Lambda implements Function0<j> {
            final d a;

            a(d dVar) {
                super(0);
                this.a = dVar;
            }

            public final j invoke() {
                Context context = this.a.b;
                if (context == null) {
                    Intrinsics.throwUninitializedPropertyAccessException("context");
                    context = null;
                }
                return g.g(context);
            }
        }

        @kotlin.coroutines.jvm.internal.f(c = "com.fancode.core.respository.BaseRepository$authenticator$1$getUpdatedToken$1", f = "BaseRepository.kt", l = {142}, m = "invokeSuspend")
        @Metadata
        static final class b extends kotlin.coroutines.jvm.internal.l implements Function2<m0, kotlin.coroutines.d<? super String>, Object> {
            int b;
            final d c;

            b(d dVar, kotlin.coroutines.d<? super b> dVar2) {
                super(2, dVar2);
                this.c = dVar;
            }

            public final Object invoke(@NotNull m0 m0Var, kotlin.coroutines.d<? super String> dVar) {
                return create(m0Var, dVar).invokeSuspend(Unit.a);
            }

            @NotNull
            public final kotlin.coroutines.d<Unit> create(Object obj, @NotNull kotlin.coroutines.d<?> dVar) {
                return new b(this.c, dVar);
            }

            public final Object invokeSuspend(@NotNull Object obj) {
                b.c a;
                String a2;
                Object c = ul.b.c();
                int i = this.b;
                if (i == 0) {
                    n.b(obj);
                    d dVar = this.c;
                    Context context = dVar.b;
                    if (context == null) {
                        Intrinsics.throwUninitializedPropertyAccessException("context");
                        context = null;
                    }
                    String b = g.g(context).b();
                    Intrinsics.checkNotNullExpressionValue(b, "getInstance(context).refreshToken");
                    this.b = 1;
                    obj = dVar.r(b, this);
                    if (obj == c) {
                        return c;
                    }
                } else {
                    if (i != 1) {
                        throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
                    }
                    n.b(obj);
                }
                b.C0137b c0137b = (b.C0137b) obj;
                return (c0137b == null || (a = c0137b.a()) == null || (a2 = a.a()) == null) ? "" : a2;
            }
        }

        c() {
            this.a = rl.h.a(new a(d.this));
        }

        public static final void k(d dVar) {
            Intrinsics.checkNotNullParameter(dVar, "this$0");
            mc.a.e.a().d();
            Context context = dVar.b;
            if (context == null) {
                Intrinsics.throwUninitializedPropertyAccessException("context");
                context = null;
            }
            Toast.makeText(context, "You are logged out", 0).show();
        }

        @Override
        public boolean a(int i, String str, @NotNull String str2) {
            Intrinsics.checkNotNullParameter(str2, ImagesContract.URL);
            if (str != null) {
                try {
                    if (new JSONObject(str).has("errors")) {
                        JSONObject jSONObject = new JSONObject(str);
                        jSONObject.getJSONArray("errors").getJSONObject(0).getJSONArray("path");
                        jSONObject.getJSONArray("errors").getJSONObject(0).getJSONObject("error");
                        return jSONObject.getJSONArray("errors").getJSONObject(0).getInt("status") == qc.a.a;
                    }
                } catch (Exception e) {
                    sc.d.a("update access token exception is " + e);
                }
            }
            return i == qc.a.a;
        }

        @Override
        public String b() {
            Context context = d.this.b;
            if (context == null) {
                Intrinsics.throwUninitializedPropertyAccessException("context");
                context = null;
            }
            return (String) new i(g.g(context), "").d().second;
        }

        @Override
        public void c(@NotNull Response response) {
            Intrinsics.checkNotNullParameter(response, "response");
            String str = response.headers().get("entitlementtoken");
            boolean z = true;
            if (str != null) {
                if (!(str.length() == 0)) {
                    d.k = str;
                    j().c().a().d("entitlement_token", d.k);
                }
            }
            String str2 = response.headers().get("invalidateentitlementtoken");
            if (str2 != null && str2.length() != 0) {
                z = false;
            }
            if (z) {
                return;
            }
            d.k = null;
            j().c().a().c("entitlement_token");
        }

        @Override
        public void d(@NotNull String str) {
            Intrinsics.checkNotNullParameter(str, "accessToken");
            j().c().a().d("access_token", str);
        }

        @Override
        public void e(boolean z) {
            String b2 = j().c().a().b("access_token", "");
            Intrinsics.checkNotNullExpressionValue(b2, "device.database.sharedPr…nt.User.ACCESS_TOKEN, \"\")");
            boolean z2 = b2.length() > 0;
            if (z || z2) {
                Handler handler = new Handler(Looper.getMainLooper());
                final d dVar = d.this;
                handler.post(new Runnable() {
                    @Override
                    public final void run() {
                        d.c.k(d.this);
                    }
                });
            }
        }

        @Override
        @NotNull
        public Pair<String, String> f() {
            Pair<String, String> d = new i(j(), "").d();
            Intrinsics.checkNotNullExpressionValue(d, "HttpHeaders(device, \"\").tokenHeaderPair");
            return d;
        }

        @Override
        @NotNull
        public String g(boolean z) {
            return (String) jm.i.f((CoroutineContext) null, new b(d.this, null), 1, (Object) null);
        }

        @Override
        public boolean h(int i, String str, @NotNull String str2) {
            Intrinsics.checkNotNullParameter(str2, ImagesContract.URL);
            return i == qc.a.a;
        }

        @NotNull
        public final j j() {
            Object value = this.a.getValue();
            Intrinsics.checkNotNullExpressionValue(value, "<get-device>(...)");
            return (j) value;
        }
    }

    @kotlin.coroutines.jvm.internal.f(c = "com.fancode.core.respository.BaseRepository$initialize$1", f = "BaseRepository.kt", l = {}, m = "invokeSuspend")
    @Metadata
    static final class C0147d extends kotlin.coroutines.jvm.internal.l implements Function2<m0, kotlin.coroutines.d<? super Unit>, Object> {
        int b;
        final Context c;
        final d d;

        C0147d(Context context, d dVar, kotlin.coroutines.d<? super C0147d> dVar2) {
            super(2, dVar2);
            this.c = context;
            this.d = dVar;
        }

        public final Object invoke(@NotNull m0 m0Var, kotlin.coroutines.d<? super Unit> dVar) {
            return create(m0Var, dVar).invokeSuspend(Unit.a);
        }

        @NotNull
        public final kotlin.coroutines.d<Unit> create(Object obj, @NotNull kotlin.coroutines.d<?> dVar) {
            return new C0147d(this.c, this.d, dVar);
        }

        public final Object invokeSuspend(@NotNull Object obj) {
            ul.b.c();
            if (this.b != 0) {
                throw new IllegalStateException("call to 'resume' before 'invoke' with coroutine");
            }
            n.b(obj);
            rc.a aVar = new rc.a(this.c);
            d dVar = this.d;
            String b = aVar.b("advertiser_id", "");
            dVar.h = b != null ? b : "";
            d.k = aVar.b("entitlement_token", null);
            return Unit.a;
        }
    }

    @Metadata
    static final class e extends Lambda implements Function0<OkHttpClient> {
        e() {
            super(0);
        }

        @NotNull
        public final OkHttpClient invoke() {
            return d.this.o();
        }
    }

    @kotlin.coroutines.jvm.internal.f(c = "com.fancode.core.respository.BaseRepository", f = "BaseRepository.kt", l = {130}, m = "refreshAccessToken")
    @Metadata
    static final class f extends kotlin.coroutines.jvm.internal.d {
        Object a;
        int c;

        f(kotlin.coroutines.d<? super f> dVar) {
            super(dVar);
        }

        public final Object invokeSuspend(@NotNull Object obj) {
            this.a = obj;
            this.c |= Integer.MIN_VALUE;
            return d.this.r(null, this);
        }
    }

    private final String h() {
        if (this.h.length() == 0) {
            Context context = this.b;
            if (context == null) {
                Intrinsics.throwUninitializedPropertyAccessException("context");
                context = null;
            }
            String b2 = new rc.a(context).b("advertiser_id", "");
            this.h = b2 != null ? b2 : "";
        }
        return this.h;
    }

    private final Interceptor j() {
        return new Interceptor() {
            public final Response intercept(Interceptor.Chain chain) {
                Response k2;
                k2 = d.k(d.this, chain);
                return k2;
            }
        };
    }

    public static final Response k(d dVar, Interceptor.Chain chain) {
        Intrinsics.checkNotNullParameter(dVar, "this$0");
        Intrinsics.checkNotNullParameter(chain, "chain");
        Context context = dVar.b;
        String str = null;
        if (context == null) {
            Intrinsics.throwUninitializedPropertyAccessException("context");
            context = null;
        }
        j g = g.g(context);
        String str2 = dVar.c;
        if (str2 == null) {
            Intrinsics.throwUninitializedPropertyAccessException("apiKey");
        } else {
            str = str2;
        }
        i iVar = new i(g, str);
        Request request = chain.request();
        Request.Builder addHeader = iVar.a(request.newBuilder()).addHeader("expcapability", "true").addHeader("guestid", dVar.h());
        String str3 = k;
        if (str3 != null) {
            addHeader.addHeader("entitlementtoken", str3);
        }
        addHeader.method(request.method(), request.body());
        return chain.proceed(OkHttp3Instrumentation.build(addHeader));
    }

    private final OkHttpClient l() {
        return (OkHttpClient) this.d.getValue();
    }

    private final X509TrustManager m() {
        try {
            TrustManagerFactory trustManagerFactory = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
            trustManagerFactory.init((KeyStore) null);
            TrustManager[] trustManagers = trustManagerFactory.getTrustManagers();
            boolean z = true;
            if (trustManagers.length != 1 || !(trustManagers[0] instanceof X509TrustManager)) {
                z = false;
            }
            if (z) {
                TrustManager trustManager = trustManagers[0];
                Intrinsics.checkNotNull(trustManager, "null cannot be cast to non-null type javax.net.ssl.X509TrustManager");
                return (X509TrustManager) trustManager;
            }
            throw new IllegalStateException(("Unexpected default trust managers:" + Arrays.toString(trustManagers)).toString());
        } catch (Exception e2) {
            e2.printStackTrace();
            return null;
        }
    }

    public final h4.b n() {
        return r4.b.a(new b.a().j(this.f ? this.g : "https://www.fancode.com/graphql"), l()).l("wss://www.fancode.com/listen").a();
    }

    public final OkHttpClient o() {
        OkHttpClient.Builder dns = new OkHttpClient.Builder().dns(new qc.f(f.b.IPV4_FIRST));
        long j2 = this.a;
        TimeUnit timeUnit = TimeUnit.SECONDS;
        OkHttpClient.Builder writeTimeout = dns.connectTimeout(j2, timeUnit).readTimeout(this.a, timeUnit).writeTimeout(this.a, timeUnit);
        writeTimeout.addInterceptor(j());
        writeTimeout.addInterceptor(new qc.b(this.i));
        X509TrustManager m = m();
        if (m != null) {
            writeTimeout.sslSocketFactory(new h(), m);
        }
        return writeTimeout.build();
    }

    @NotNull
    public final h4.b i() {
        return (h4.b) this.e.getValue();
    }

    public final void p(@NotNull Context context, @NotNull String str, boolean z) {
        Intrinsics.checkNotNullParameter(context, "context");
        Intrinsics.checkNotNullParameter(str, "apiKey");
        q(context, str, z, "https://uat.fancode.com/graphql");
    }

    public final void q(@NotNull Context context, @NotNull String str, boolean z, @NotNull String str2) {
        Intrinsics.checkNotNullParameter(context, "context");
        Intrinsics.checkNotNullParameter(str, "apiKey");
        Intrinsics.checkNotNullParameter(str2, "stageUrl");
        this.b = context;
        this.c = str;
        this.g = str2;
        this.f = z;
        jm.i.d(r1.a, c1.c(), (o0) null, new C0147d(context, this, null), 2, (Object) null);
    }

    public final java.lang.Object r(@org.jetbrains.annotations.NotNull java.lang.String r5, @org.jetbrains.annotations.NotNull kotlin.coroutines.d<? super mc.b.C0137b> r6) {
        throw new UnsupportedOperationException("Method not decompiled: qc.d.r(java.lang.String, kotlin.coroutines.d):java.lang.Object");
    }
}