package com.ifpdos.debugmenu.action.abs_items;

import android.content.Context;
import android.content.DialogInterface;
import android.util.Log;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.base.ItemButtonAction;
import com.trello.rxlifecycle3.android.ActivityEvent;
import com.trello.rxlifecycle3.components.support.RxAppCompatActivity;
import d.f.a.c1;
import d.f.a.p2.p0;
import d.f.a.p2.t0;
import d.f.a.r2.t2;
import d.f.a.r2.v2;
import d.f.a.s1.e;
import f.a.i;
import f.a.t.a;
import f.a.v.c;

/* JADX INFO: loaded from: classes.dex */
public abstract class AbsUpgradeItem extends ItemButtonAction implements c1 {
    public String TAG;
    private e mActionFinishCallback;
    private final a mCompositeDisposable;
    public final p0 upgradeHandler;

    public AbsUpgradeItem(Context context) {
        super(context);
        this.TAG = getClass().getSimpleName();
        this.upgradeHandler = t0.a;
        this.mCompositeDisposable = new a();
    }

    private void upgradeCheckUSB() {
        Log.d(this.TAG, "upgradeCheckUSB: beginning to find usb...");
        c.n.a.Z(true);
        new v2(new v2.a() { // from class: com.ifpdos.debugmenu.action.abs_items.AbsUpgradeItem.1
            @Override // d.f.a.r2.v2.a
            public void onFail() {
                Log.d(AbsUpgradeItem.this.TAG, "upgradeCheckUSB: ending to find usb, find no effective usb device, ignore upgrade action...");
                AbsUpgradeItem.this.onFindUsbFailed();
            }

            @Override // d.f.a.r2.v2.a
            public void onSuccess() {
                Log.d(AbsUpgradeItem.this.TAG, "upgradeCheckUSB: ending to find usb, find a effective usb device, prepare upgrade action...");
                AbsUpgradeItem.this.onFindUsbSuccess();
            }
        }).a();
    }

    public abstract int getDialogMessageStringId();

    public abstract int getUpgradeDialogTitle();

    public abstract c<Throwable> getUpgradeExceptionHandler();

    public abstract i<Boolean> getUpgradeObservableTask();

    public abstract c<Boolean> getUpgradeResultHandler();

    public /* synthetic */ void h() {
        c.n.a.o();
        upgradeCheckUSB();
    }

    public /* synthetic */ void i(DialogInterface dialogInterface) {
        e eVar = this.mActionFinishCallback;
        if (eVar != null) {
            eVar.call();
        }
    }

    @Override // com.ifpdos.debugmenu.action.base.ItemButtonAction, d.f.a.j2.e.e.a
    public void onClick(Context context, d.f.a.j2.e.e eVar) {
        upgradeCheckUSB();
    }

    public void onFindUsbFailed() {
        Log.d(this.TAG, "onFindUsbFailed: cancel the upgrade action ... ");
        c.n.a.Z(false);
        d.b.a.a.a.J(R.string.str_export_log_fail_no_usb, k.c.a.c.c());
        e eVar = this.mActionFinishCallback;
        if (eVar != null) {
            eVar.call();
        }
    }

    public void onFindUsbSuccess() {
        Log.d(this.TAG, "onFindUsbSuccess: start the upgrade action ... ");
        c.n.a.Z(false);
        upgrade();
    }

    @Override // com.ifpdos.debugmenu.action.base.ItemButtonAction, d.f.a.j2.e.e.a
    public void onLongClick(Context context, d.f.a.j2.e.e eVar) {
    }

    @Override // d.f.a.c1
    public void quickAction(e eVar) {
        this.mActionFinishCallback = eVar;
        c.n.a.U(R.string.str_debug_upgrade, getDialogMessageStringId(), new e() { // from class: d.f.a.p1.nh.b
            @Override // d.f.a.s1.e
            public final void call() {
                this.a.h();
            }
        }, new DialogInterface.OnCancelListener() { // from class: d.f.a.p1.nh.a
            @Override // android.content.DialogInterface.OnCancelListener
            public final void onCancel(DialogInterface dialogInterface) {
                this.f2844b.i(dialogInterface);
            }
        });
    }

    public void upgrade() {
        t2.e();
        c.n.a.a0(getUpgradeDialogTitle());
        i<Boolean> upgradeObservableTask = getUpgradeObservableTask();
        this.mCompositeDisposable.b(upgradeObservableTask.w(f.a.z.a.f4044c).g(((RxAppCompatActivity) this.mContext).bindUntilEvent(ActivityEvent.DESTROY)).t(getUpgradeResultHandler(), getUpgradeExceptionHandler()));
    }
}