package com.fonbet.sdk;

import android.annotation.SuppressLint;
import android.support.annotation.Nullable;
import android.support.p001v4.util.Pair;
import android.text.TextUtils;
import com.fonbet.core.util.NetworkUtils;
import com.fonbet.sdk.AuthModule.Callback;
import com.fonbet.sdk.auth.request.SignInDefaultBlueRequestBody;
import com.fonbet.sdk.auth.request.SignInDefaultRedRequestBody;
import com.fonbet.sdk.auth.response.AuthInfo;
import com.fonbet.sdk.auth.response.ProfileInfo;
import com.fonbet.sdk.auth.response.UserSettingsInfo;
import com.fonbet.sdk.core.request.BaseJsAgentRequestBody;
import com.fonbet.sdk.core.request.BaseSignedRequestBody;
import com.fonbet.sdk.util.Signer;
import java.util.concurrent.Callable;
import p013io.reactivex.Single;
import p013io.reactivex.SingleEmitter;
import p013io.reactivex.SingleOnSubscribe;
import p013io.reactivex.android.schedulers.AndroidSchedulers;
import p013io.reactivex.annotations.NonNull;
import p013io.reactivex.functions.Consumer;
import p013io.reactivex.functions.Function;
import p013io.reactivex.schedulers.Schedulers;
import retrofit2.Retrofit;
import retrofit2.Retrofit.Builder;
import retrofit2.adapter.rxjava2.RxJava2CallAdapterFactory;
import retrofit2.http.Body;
import retrofit2.http.POST;
import retrofit2.http.Url;

public class AuthHandle extends ApiHandle {

    /* renamed from: com.fonbet.sdk.AuthHandle$10 */
    class C162110 implements SingleOnSubscribe<AuthInfo> {
        C162110() {
        }

        public void subscribe(SingleEmitter<AuthInfo> singleEmitter) throws Exception {
            SessionInfo sessionInfoOrFail = AuthHandle.this.api.local.sessionInfoOrFail();
            AuthHandle.this.api.local.saveAuth(null);
            AuthHandle.this.api.authModule.callback.onSignedOut();
            final BaseSignedRequestBody sign = AuthHandle.this.api.authModule.createUnsignedBody(String.valueOf(sessionInfoOrFail.getClientId()), AuthHandle.this.api.local.passwordOrFail(), sessionInfoOrFail).sign();
            AuthHandle.this.api.authModule.signOut(sign).subscribe(new UrlExhaustingSingleEmitter(AuthHandle.this, new Callable<Single<AuthInfo>>() {
                public Single<AuthInfo> call() throws Exception {
                    return AuthHandle.this.api.authModule.signOut(sign);
                }
            }, singleEmitter));
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$1 */
    class C16221 implements Function<Pair<AuthInfo, Boolean>, AuthInfo> {
        C16221() {
        }

        public AuthInfo apply(Pair<AuthInfo, Boolean> pair) throws Exception {
            return (AuthInfo) pair.first;
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$4 */
    class C16254 implements Function<AuthInfo, Pair<AuthInfo, Boolean>> {
        C16254() {
        }

        public Pair<AuthInfo, Boolean> apply(AuthInfo authInfo) throws Exception {
            boolean z = authInfo.isSessionCreated() && !authInfo.requiresRulesConfirmation();
            return new Pair(authInfo, Boolean.valueOf(z));
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$6 */
    class C16276 implements Consumer<AuthInfo> {
        C16276() {
        }

        public void accept(@NonNull AuthInfo authInfo) throws Exception {
            AuthHandle.this.api.local.saveSessionInfo(new SessionInfoImpl(AuthHandle.this.api.local.sessionInfo(), authInfo));
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$7 */
    class C16287 implements SingleOnSubscribe<AuthInfo> {
        C16287() {
        }

        public void subscribe(SingleEmitter<AuthInfo> singleEmitter) throws Exception {
            SessionInfo sessionInfoOrFail = AuthHandle.this.api.local.sessionInfoOrFail();
            final BaseSignedRequestBody sign = AuthHandle.this.api.authModule.createUnsignedBody(String.valueOf(sessionInfoOrFail.getClientId()), AuthHandle.this.api.local.passwordOrFail(), sessionInfoOrFail).sign();
            AuthHandle.this.api.authModule.sessionInfo(sign).subscribe(new UrlExhaustingSingleEmitter(AuthHandle.this, new Callable<Single<AuthInfo>>() {
                public Single<AuthInfo> call() throws Exception {
                    return AuthHandle.this.api.authModule.sessionInfo(sign);
                }
            }, singleEmitter));
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$8 */
    class C16298 implements SingleOnSubscribe<ProfileInfo> {

        /* renamed from: com.fonbet.sdk.AuthHandle$8$2 */
        class C10832 implements Callable<Single<ProfileInfo>> {
            C10832() {
            }

            public Single<ProfileInfo> call() throws Exception {
                return AuthHandle.this.profile();
            }
        }

        C16298() {
        }

        public void subscribe(SingleEmitter<ProfileInfo> singleEmitter) throws Exception {
            AuthHandle.this.api.authModule.profile(new BaseJsAgentRequestBody(AuthHandle.this.api.local.sessionInfoOrFail().getClientId(), AuthHandle.this.api.local.sessionInfoOrFail().getFsid(), AuthHandle.this.api.deviceInfoModule) {
                public BaseSignedRequestBody sign() {
                    return (BaseSignedRequestBody) Signer.sign(this, AuthHandle.this.api.signModule.transformKey(AuthHandle.this.api.local.passwordOrFail()));
                }
            }).subscribe(new UrlExhaustingSingleEmitter(AuthHandle.this, new C10832(), singleEmitter));
        }
    }

    /* renamed from: com.fonbet.sdk.AuthHandle$9 */
    class C16319 implements SingleOnSubscribe<UserSettingsInfo> {

        /* renamed from: com.fonbet.sdk.AuthHandle$9$2 */
        class C10842 implements Callable<Single<UserSettingsInfo>> {
            C10842() {
            }

            public Single call() throws Exception {
                return AuthHandle.this.userSettings();
            }
        }

        C16319() {
        }

        public void subscribe(SingleEmitter<UserSettingsInfo> singleEmitter) throws Exception {
            AuthHandle.this.api.authModule.userSettings(new BaseJsAgentRequestBody(AuthHandle.this.api.local.sessionInfoOrFail().getClientId(), AuthHandle.this.api.local.sessionInfoOrFail().getFsid(), AuthHandle.this.api.deviceInfoModule) {
                public BaseSignedRequestBody sign() {
                    return (BaseSignedRequestBody) Signer.sign(this, AuthHandle.this.api.signModule.transformKey(AuthHandle.this.api.local.passwordOrFail()));
                }
            }).subscribe(new UrlExhaustingSingleEmitter(AuthHandle.this, new C10842(), singleEmitter));
        }
    }

    public static class BlueDefault extends AuthModule<SignInDefaultBlueRequestBody> {
        private BlueApi service;

        private interface BlueApi {
            @POST
            Single<ProfileInfo> profile(@Url String str, @Body BaseJsAgentRequestBody baseJsAgentRequestBody);

            @POST
            Single<AuthInfo> sessionInfo(@Url String str, @Body SignInDefaultBlueRequestBody signInDefaultBlueRequestBody);

            @POST
            Single<AuthInfo> signIn(@Url String str, @Body SignInDefaultBlueRequestBody signInDefaultBlueRequestBody);

            @POST
            Single<AuthInfo> signOut(@Url String str, @Body SignInDefaultBlueRequestBody signInDefaultBlueRequestBody);

            @POST
            Single<UserSettingsInfo> userSettings(@Url String str, @Body BaseJsAgentRequestBody baseJsAgentRequestBody);
        }

        @android.support.annotation.NonNull
        public String serverName() {
            return "js";
        }

        public BlueDefault(Callback callback) {
            super(callback);
        }

        @android.support.annotation.NonNull
        public SignInDefaultBlueRequestBody createUnsignedBody(String str, @android.support.annotation.NonNull String str2, @Nullable SessionInfo sessionInfo) {
            return new SignInDefaultBlueRequestBody(str, str2, this.userInfo, sessionInfo, this.signModule);
        }

        public void createService(Retrofit retrofit) {
            this.service = (BlueApi) retrofit.create(BlueApi.class);
        }

        @android.support.annotation.NonNull
        public Single<AuthInfo> signIn(@android.support.annotation.NonNull SignInDefaultBlueRequestBody signInDefaultBlueRequestBody) {
            return this.service.signIn(this.apiHandle.fullUrl("session/login"), signInDefaultBlueRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<AuthInfo> sessionInfo(@android.support.annotation.NonNull SignInDefaultBlueRequestBody signInDefaultBlueRequestBody) {
            return this.service.sessionInfo(this.apiHandle.fullUrl("session/info"), signInDefaultBlueRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<AuthInfo> signOut(@android.support.annotation.NonNull SignInDefaultBlueRequestBody signInDefaultBlueRequestBody) {
            return this.service.signOut(this.apiHandle.fullUrl("session/logout"), signInDefaultBlueRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<ProfileInfo> profile(@android.support.annotation.NonNull BaseJsAgentRequestBody baseJsAgentRequestBody) {
            return this.service.profile(this.apiHandle.fullUrl("account/api/v3/profile/load"), baseJsAgentRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<UserSettingsInfo> userSettings(@android.support.annotation.NonNull BaseJsAgentRequestBody baseJsAgentRequestBody) {
            return this.service.userSettings(this.apiHandle.fullUrl("client/clientProfile"), baseJsAgentRequestBody);
        }
    }

    public static class RedDefault extends AuthModule<SignInDefaultRedRequestBody> {
        private RedApi service;

        private interface RedApi {
            @POST
            Single<ProfileInfo> profile(@Url String str, @Body BaseJsAgentRequestBody baseJsAgentRequestBody);

            @POST
            Single<AuthInfo> sessionInfo(@Url String str, @Body SignInDefaultRedRequestBody signInDefaultRedRequestBody);

            @POST
            Single<AuthInfo> signInById(@Url String str, @Body SignInDefaultRedRequestBody signInDefaultRedRequestBody);

            @POST
            Single<AuthInfo> signInByMail(@Url String str, @Body SignInDefaultRedRequestBody signInDefaultRedRequestBody);

            @POST
            Single<AuthInfo> signInByPhone(@Url String str, @Body SignInDefaultRedRequestBody signInDefaultRedRequestBody);

            @POST
            Single<AuthInfo> signOut(@Url String str, @Body SignInDefaultRedRequestBody signInDefaultRedRequestBody);

            @POST
            Single<UserSettingsInfo> userSettings(@Url String str, @Body BaseJsAgentRequestBody baseJsAgentRequestBody);
        }

        @android.support.annotation.NonNull
        public String serverName() {
            return "reg_tsupis";
        }

        public RedDefault(Callback callback) {
            super(callback);
        }

        @android.support.annotation.NonNull
        public SignInDefaultRedRequestBody createUnsignedBody(String str, @android.support.annotation.NonNull String str2, @Nullable SessionInfo sessionInfo) {
            return new SignInDefaultRedRequestBody(str, str2, this.userInfo, sessionInfo, this.signModule);
        }

        public void createService(Retrofit retrofit) {
            this.service = (RedApi) retrofit.create(RedApi.class);
        }

        @SuppressLint({"WrongConstant"})
        @android.support.annotation.NonNull
        public Single<AuthInfo> signIn(@android.support.annotation.NonNull SignInDefaultRedRequestBody signInDefaultRedRequestBody) {
            switch (signInDefaultRedRequestBody.getType()) {
                case 1:
                    return this.service.signInById(this.apiHandle.fullUrl("session/loginById"), signInDefaultRedRequestBody);
                case 2:
                    return this.service.signInByPhone(this.apiHandle.fullUrl("session/loginByPhone"), signInDefaultRedRequestBody);
                case 3:
                    return this.service.signInByMail(this.apiHandle.fullUrl("session/loginByMail"), signInDefaultRedRequestBody);
                default:
                    StringBuilder stringBuilder = new StringBuilder();
                    stringBuilder.append("Unknown auth type: ");
                    stringBuilder.append(signInDefaultRedRequestBody.getType());
                    throw new IllegalStateException(stringBuilder.toString());
            }
        }

        @android.support.annotation.NonNull
        public Single<AuthInfo> sessionInfo(@android.support.annotation.NonNull SignInDefaultRedRequestBody signInDefaultRedRequestBody) {
            return this.service.sessionInfo(this.apiHandle.fullUrl("session/info"), signInDefaultRedRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<AuthInfo> signOut(@android.support.annotation.NonNull SignInDefaultRedRequestBody signInDefaultRedRequestBody) {
            return this.service.signOut(this.apiHandle.fullUrl("session/logout"), signInDefaultRedRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<ProfileInfo> profile(@android.support.annotation.NonNull BaseJsAgentRequestBody baseJsAgentRequestBody) {
            return this.service.profile(this.apiHandle.fullUrl("account/api/v3/profile/load"), baseJsAgentRequestBody);
        }

        @android.support.annotation.NonNull
        public Single<UserSettingsInfo> userSettings(@android.support.annotation.NonNull BaseJsAgentRequestBody baseJsAgentRequestBody) {
            return this.service.userSettings(this.apiHandle.fullUrl("client/clientProfile"), baseJsAgentRequestBody);
        }
    }

    protected String contextName() {
        return this.api.authModule.serverName();
    }

    AuthHandle(FonProvider fonProvider) {
        super(fonProvider);
        fonProvider.authModule.createService(new Builder().baseUrl(baseUrl()).client(NetworkUtils.createClient(fonProvider.httpClientBuilder(), contextName(), fonProvider.configWrapper().getConfig(), fonProvider.logger)).addConverterFactory(NetworkUtils.createGsonConverterFactory()).addCallAdapterFactory(RxJava2CallAdapterFactory.createWithScheduler(Schedulers.m200io())).build());
        fonProvider.authModule.setApiHandle(this);
        fonProvider.authModule.setUserInfo(fonProvider.deviceInfoModule);
        fonProvider.authModule.setSignModule(fonProvider.signModule);
    }

    public boolean isSignedIn() {
        SessionInfo sessionInfo = this.api.local.sessionInfo();
        return (sessionInfo == null || TextUtils.isEmpty(sessionInfo.getFsid())) ? false : true;
    }

    @android.support.annotation.NonNull
    public Single<AuthInfo> signIn(final String str, @android.support.annotation.NonNull final String str2) {
        return Single.create(new SingleOnSubscribe<AuthInfo>() {
            public void subscribe(SingleEmitter<AuthInfo> singleEmitter) throws Exception {
                final BaseSignedRequestBody sign = AuthHandle.this.api.authModule.createUnsignedBody(str, str2, null).sign();
                AuthHandle.this.api.authModule.signIn(sign).subscribe(new UrlExhaustingSingleEmitter(AuthHandle.this, new Callable<Single<AuthInfo>>() {
                    public Single<AuthInfo> call() throws Exception {
                        return AuthHandle.this.api.authModule.signIn(sign);
                    }
                }, singleEmitter));
            }
        }).observeOn(Schedulers.m200io()).map(new C16254()).doOnSuccess(new Consumer<Pair<AuthInfo, Boolean>>() {
            public void accept(Pair<AuthInfo, Boolean> pair) throws Exception {
                if (((Boolean) pair.second).booleanValue()) {
                    AuthInfo authInfo = (AuthInfo) pair.first;
                    AuthHandle.this.api.local.saveAuth(authInfo.getClientId(), str2, authInfo);
                    AuthHandle.this.api.local.saveLastSignInTimestamp(AuthHandle.this.api.local.currentTimeMillis());
                }
            }
        }).observeOn(AndroidSchedulers.mainThread()).doOnSuccess(new Consumer<Pair<AuthInfo, Boolean>>() {
            public void accept(Pair<AuthInfo, Boolean> pair) throws Exception {
                AuthInfo authInfo = (AuthInfo) pair.first;
                boolean booleanValue = ((Boolean) pair.second).booleanValue();
                if (authInfo.isSessionCreated()) {
                    AuthHandle.this.api.authModule.callback.onSignedIn(authInfo, authInfo.getClientId(), str2, booleanValue);
                }
            }
        }).map(new C16221());
    }

    @android.support.annotation.NonNull
    public Single<AuthInfo> sessionInfo() {
        return Single.create(new C16287()).observeOn(Schedulers.m200io()).doOnSuccess(new C16276());
    }

    @android.support.annotation.NonNull
    public Single<ProfileInfo> profile() {
        return Single.create(new C16298());
    }

    @android.support.annotation.NonNull
    public Single<UserSettingsInfo> userSettings() {
        return Single.create(new C16319());
    }

    @android.support.annotation.NonNull
    public Single<AuthInfo> signOut() {
        return Single.create(new C162110());
    }
}