RummyCircle v11000.89 - JuspayContainerActivity.java 源代码

package com.games24x7.pgpayment.ui;

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import androidx.fragment.app.FragmentActivity;
import com.facebook.imagepipeline.cache.A;
import com.games24x7.pgpayment.R;
import com.games24x7.pgpayment.comm.internal.RxBusData;
import com.games24x7.pgpayment.comm.internal.RxBusJuspay;
import com.games24x7.pgpayment.manager.JuspayManager;
import in.juspay.services.HyperServices;
import io.reactivex.disposables.a;
import io.reactivex.disposables.b;
import io.reactivex.internal.operators.observable.k;
import io.reactivex.o;
import io.reactivex.p;
import java.util.LinkedHashMap;
import java.util.Map;
import kotlin.Metadata;
import kotlin.jvm.internal.Intrinsics;
import org.jetbrains.annotations.NotNull;
import org.json.JSONObject;

@Metadata
public final class JuspayContainerActivity extends FragmentActivity {

    @NotNull
    public Map<Integer, View> _$_findViewCache = new LinkedHashMap();

    @NotNull
    private a compositeDisposable = new a();
    private HyperServices hyperServices;
    private View loaderLayout;

    private final void getDataFromIntent() {
        Bundle extras = getIntent().getExtras();
        String string = extras != null ? extras.getString(JuspayManager.PAYLOAD, "{}") : null;
        Intrinsics.c(string);
        handleJuspayRequest(new RxBusData(2, new JSONObject(string), null, 4, null));
    }

    private final o<RxBusData> getRequestObserver() {
        return new o<RxBusData>() {
            public void onError(@NotNull Throwable th) {
                Intrinsics.checkNotNullParameter(th, "e");
                Log.d("Acr", "Bus error" + th);
            }

            public void onNext(@NotNull RxBusData rxBusData) {
                Intrinsics.checkNotNullParameter(rxBusData, "json");
                Log.d("Acr", "Bus received" + rxBusData);
                JuspayContainerActivity.this.handleJuspayRequest(rxBusData);
            }

            public void onSubscribe(@NotNull b bVar) {
                a aVar;
                Intrinsics.checkNotNullParameter(bVar, "d");
                aVar = JuspayContainerActivity.this.compositeDisposable;
                aVar.b(bVar);
            }

            public void onComplete() {
            }
        };
    }

    public final void handleJuspayRequest(com.games24x7.pgpayment.comm.internal.RxBusData r6) {
        throw new UnsupportedOperationException("Method not decompiled: com.games24x7.pgpayment.ui.JuspayContainerActivity.handleJuspayRequest(com.games24x7.pgpayment.comm.internal.RxBusData):void");
    }

    private final void handleResponse(RxBusData rxBusData) {
        RxBusJuspay.getInstance().publishResult(rxBusData);
        if (rxBusData == null || rxBusData.getEventId() != 2) {
            return;
        }
        finish();
    }

    private final void initiateRxBusJuspayListeners() {
        k f = RxBusJuspay.getInstance().listenRequest().f(io.reactivex.schedulers.a.a);
        p pVar = io.reactivex.android.schedulers.a.a;
        A.s(pVar);
        f.c(pVar).a(getRequestObserver());
    }

    private final void sendErrorEvent(String str) {
        Log.d("Acr", "JuspayActivity something went wrong");
    }

    public void _$_clearFindViewByIdCache() {
        this._$_findViewCache.clear();
    }

    public View _$_findCachedViewById(int i) {
        Map<Integer, View> map = this._$_findViewCache;
        View view = map.get(Integer.valueOf(i));
        if (view != null) {
            return view;
        }
        View findViewById = findViewById(i);
        if (findViewById == null) {
            return null;
        }
        map.put(Integer.valueOf(i), findViewById);
        return findViewById;
    }

    public final void hideLoader() {
        View view = this.loaderLayout;
        if (view == null) {
            return;
        }
        view.setVisibility(8);
    }

    public void onBackPressed() {
        HyperServices hyperServices = this.hyperServices;
        if (Intrinsics.a(hyperServices != null ? Boolean.valueOf(hyperServices.onBackPressed()) : null, Boolean.FALSE)) {
            super/*androidx.activity.ComponentActivity*/.onBackPressed();
            handleResponse(new RxBusData(4, new JSONObject(), null, 4, null));
        }
    }

    public void onCreate(Bundle bundle) {
        super.onCreate(bundle);
        Log.e("Acr", "JuspayActivity ONCREATE");
        setContentView(R.layout.activity_juspay_container);
        setupView();
        this.hyperServices = JuspayManager.INSTANCE.getHyperServices();
        initiateRxBusJuspayListeners();
        getDataFromIntent();
    }

    public void onDestroy() {
        super.onDestroy();
        Log.d("Acr", "JuspayActivity ON DESTROY");
        HyperServices hyperServices = this.hyperServices;
        if (hyperServices != null) {
            hyperServices.resetActivity(this);
        }
        this.compositeDisposable.dispose();
    }

    public final void showLoader() {
        View view = this.loaderLayout;
        if (view == null) {
            return;
        }
        view.setVisibility(0);
    }

    private final void setupView() {
    }
}