package com.ifpdos.debugmenu.action;

import android.content.Context;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.dss.ups.mic.mic3308.Plugin;
import com.cvte.vman.VmanMiddleWare;
import com.ifpdos.debugmenu.DebugMenuApplication;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.UpgradeMicTAction;
import com.ifpdos.debugmenu.action.base.ItemButtonAction;
import com.ifpdos.debugmenu.entity.UpgradeException;
import com.seewo.sdk.model.SDKUpgradeResult;
import com.trello.rxlifecycle3.android.ActivityEvent;
import com.trello.rxlifecycle3.components.support.RxAppCompatActivity;
import d.b.a.a.a;
import d.f.a.j2.e.e;
import d.f.a.p2.p0;
import d.f.a.p2.t0;
import d.f.a.r2.f3;
import d.f.a.r2.t2;
import d.f.a.r2.u2;
import d.f.a.r2.v2;
import f.a.i;
import f.a.v.d;
import f.a.w.b.a;
import f.a.w.e.d.c;
import f.a.w.e.d.j;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public class UpgradeMicTAction extends ItemButtonAction {
    public static final String FILE_MIC = a.t(new StringBuilder(), "/mic.upd");
    private static final String TAG = "UpgradeMicAction";
    private f.a.t.a mCompositeDisposable;
    private v2 mFindFrontUSBHelper;
    private p0 upgradeHandler;

    public UpgradeMicTAction(Context context) {
        super(context);
        this.upgradeHandler = t0.a;
        this.mCompositeDisposable = new f.a.t.a();
        this.mContext = context;
    }

    private i<Boolean> checkPoint(boolean z, SDKUpgradeResult sDKUpgradeResult) {
        return z ? i.m(Boolean.valueOf(z)) : new j(new a.e(new UpgradeException(sDKUpgradeResult)));
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void upgrade() {
        t2.e();
        c.n.a.a0(R.string.str_upgrade_mic);
        String mcuBinNameToUp = VmanMiddleWare.getInstance().getFwUpgrade().getMcuBinNameToUp(9);
        Log.i(TAG, "file=" + mcuBinNameToUp);
        final String strP = u2.p(mcuBinNameToUp);
        d.b.a.a.a.O("path=", strP, TAG);
        f.a.t.a aVar = this.mCompositeDisposable;
        final Context context = this.mContext;
        final p0 p0Var = this.upgradeHandler;
        aVar.b(f3.a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new d() { // from class: d.f.a.r2.j2
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                String str = strP;
                Objects.requireNonNull((d.f.a.p2.t0) p0Var2);
                return f3.a(TextUtils.isEmpty(str) ? d.f.a.p2.r0.c(".*\\.upd") : d.b.a.a.a.a0(str), SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new d() { // from class: d.f.a.r2.t1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                final Context context2 = context;
                final String strP2 = strP;
                final d.f.a.p2.t0 t0Var = (d.f.a.p2.t0) p0Var2;
                Objects.requireNonNull(t0Var);
                if (TextUtils.isEmpty(strP2)) {
                    strP2 = u2.p(".*\\.upd");
                }
                Log.e("UpgradeHisiHelper", "upgradeMic3308 path = " + strP2);
                final d.f.a.p2.q0 q0Var = null;
                return new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.g
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) {
                        t0 t0Var2 = t0Var;
                        Context context3 = context2;
                        String str = strP2;
                        q0 q0Var2 = q0Var;
                        Objects.requireNonNull(t0Var2);
                        try {
                            Log.i("UpgradeHisiHelper", "micPlugin res " + new Plugin().upgradeFirmware(context3, str, true, new s0(t0Var2, jVar, q0Var2)));
                        } catch (Exception e2) {
                            Log.e("UpgradeHisiHelper", "Err", e2);
                            ((c.a) jVar).c(new UpgradeException(SDKUpgradeResult.UPGRADE_ERROR));
                        }
                    }
                }).y(5L, TimeUnit.MINUTES).j(new f.a.v.e() { // from class: d.f.a.p2.m0
                    @Override // f.a.v.e
                    public final boolean test(Object obj2) {
                        t0 t0Var2 = t0.a;
                        return ((Float) obj2).floatValue() == 1.0f;
                    }
                }).k(new f.a.v.d() { // from class: d.f.a.p2.j
                    @Override // f.a.v.d
                    public final Object apply(Object obj2) {
                        t0 t0Var2 = t0.a;
                        return f.a.i.m(Boolean.TRUE);
                    }
                });
            }
        }).w(f.a.z.a.f4044c).n(f.a.s.b.a.a()).g(((RxAppCompatActivity) this.mContext).bindUntilEvent(ActivityEvent.DESTROY)).u(new f.a.v.c() { // from class: d.f.a.p1.sd
            @Override // f.a.v.c
            public final void accept(Object obj) {
                String str = UpgradeMicTAction.FILE_MIC;
                c.n.a.f0(R.string.str_upgrade_mic, ((Boolean) obj).booleanValue());
            }
        }, new f.a.v.c() { // from class: d.f.a.p1.td
            @Override // f.a.v.c
            public final void accept(Object obj) {
                Throwable th = (Throwable) obj;
                String str = UpgradeMicTAction.FILE_MIC;
                c.n.a.f0(R.string.str_upgrade_mic, false);
                if (th instanceof UpgradeException) {
                    d.b.a.a.a.L((UpgradeException) th, DebugMenuApplication.f1956b, "MIC");
                }
            }
        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c));
    }

    @Override // com.ifpdos.debugmenu.action.base.ItemButtonAction, d.f.a.j2.e.e.a
    public void onClick(Context context, e eVar) {
        c.n.a.Z(true);
        v2 v2Var = new v2(new v2.a() { // from class: com.ifpdos.debugmenu.action.UpgradeMicTAction.1
            @Override // d.f.a.r2.v2.a
            public void onFail() {
                c.n.a.Z(false);
                d.b.a.a.a.J(R.string.str_export_log_fail_no_usb, k.c.a.c.c());
            }

            @Override // d.f.a.r2.v2.a
            public void onSuccess() {
                c.n.a.Z(false);
                UpgradeMicTAction.this.upgrade();
            }
        });
        this.mFindFrontUSBHelper = v2Var;
        v2Var.a();
    }

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