package com.ifpdos.debugmenu.action;

import android.content.Context;
import android.text.TextUtils;
import android.util.Log;
import com.ifpdos.debugmenu.DebugMenuApplication;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.UpgradeOtaAction;
import com.ifpdos.debugmenu.action.base.ItemButtonAction;
import com.ifpdos.debugmenu.entity.UpgradeException;
import com.ifpdos.debugmenu.event.ActivityEvent;
import com.seewo.sdk.model.SDKUpgradeResult;
import com.trello.rxlifecycle3.components.support.RxAppCompatActivity;
import d.f.a.p2.p0;
import d.f.a.p2.r0;
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 d.i.f.g.d;
import f.a.i;
import f.a.k;
import f.a.l;
import f.a.t.a;
import f.a.w.b.a;
import f.a.w.e.d.j;
import java.util.Objects;
import k.c.a.c;

/* JADX INFO: loaded from: classes.dex */
public class UpgradeOtaAction extends ItemButtonAction {
    private static final String TAG = "UpgradeOtaAction";
    private a mCompositeDisposable;
    private v2 mFindFrontUSBHelper;
    private p0 upgradeHandler;

    /* JADX INFO: renamed from: com.ifpdos.debugmenu.action.UpgradeOtaAction$1, reason: invalid class name */
    public class AnonymousClass1 implements v2.a {
        public AnonymousClass1() {
        }

        @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, c.c());
        }

        @Override // d.f.a.r2.v2.a
        public void onSuccess() {
            c.n.a.Z(false);
            c.n.a.W(R.string.str_debug_upgrade, R.string.str_debug_upgrade_ota, new e() { // from class: d.f.a.p1.de
                @Override // d.f.a.s1.e
                public final void call() {
                    UpgradeOtaAction.AnonymousClass1 anonymousClass1 = this.a;
                    Objects.requireNonNull(anonymousClass1);
                    c.n.a.o();
                    UpgradeOtaAction.this.upgradeOta();
                }
            }, new e() { // from class: d.f.a.p1.ee
                @Override // d.f.a.s1.e
                public final void call() {
                }
            });
        }
    }

    public UpgradeOtaAction(Context context) {
        super(context);
        this.upgradeHandler = t0.a;
        this.mCompositeDisposable = new 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)));
    }

    public static boolean isRemount() {
        d dVarB = d.i.c.a.b("mount | grep overlay ");
        StringBuilder sbB = d.b.a.a.a.B("isRemountResult: ");
        sbB.append(dVarB.a);
        sbB.append(" ,successMsg:");
        sbB.append(dVarB.f3659b);
        sbB.append(" ,errorMsg:");
        sbB.append(dVarB.f3660c);
        Log.d(TAG, sbB.toString());
        return !TextUtils.isEmpty(dVarB.f3659b);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public void upgradeOta() {
        if (isRemount()) {
            c.n.a.V(R.string.str_debug_upgrade, R.string.str_debug_upgrade_ota_remount_error, new e() { // from class: d.f.a.p1.ce
                @Override // d.f.a.s1.e
                public final void call() {
                    c.n.a.o();
                    d.i.c.a.b("sh /system/bin/unremount.sh");
                }
            });
            return;
        }
        t2.e();
        c.n.a.a0(R.string.str_debug_upgrade_ota);
        c.c().g(new ActivityEvent.UpgradeDialogUpdateProgress(R.string.str_debug_upgrade_ota, 0.0f));
        f.a.t.a aVar = this.mCompositeDisposable;
        f.a.w.e.d.e eVar = new f.a.w.e.d.e(checkPoint(this.upgradeHandler != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.p1.ie
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                return this.f2775b.h((Boolean) obj);
            }
        }).k(new f.a.v.d() { // from class: d.f.a.p1.he
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                return this.f2763b.i((Boolean) obj);
            }
        }).w(f.a.z.a.f4044c).n(f.a.s.b.a.a()).g(((RxAppCompatActivity) this.mContext).bindUntilEvent(com.trello.rxlifecycle3.android.ActivityEvent.DESTROY)), new f.a.v.c() { // from class: d.f.a.p1.fe
            @Override // f.a.v.c
            public final void accept(Object obj) {
                Float f2 = (Float) obj;
                Log.i("UpgradeOtaAction", "doAfterNext " + f2);
                k.c.a.c.c().g(new ActivityEvent.UpgradeDialogUpdateProgress(R.string.str_debug_upgrade_ota, f2.floatValue()));
            }
        });
        f.a.v.a aVar2 = new f.a.v.a() { // from class: d.f.a.p1.je
            @Override // f.a.v.a
            public final void run() {
                this.a.j();
            }
        };
        f.a.v.c<? super Throwable> cVar = f.a.w.b.a.f3726c;
        f.a.v.a aVar3 = f.a.w.b.a.f3725b;
        aVar.b(eVar.i(cVar, cVar, aVar2, aVar3).i(cVar, new f.a.v.c() { // from class: d.f.a.p1.ge
            @Override // f.a.v.c
            public final void accept(Object obj) {
                Throwable th = (Throwable) obj;
                c.n.a.f0(R.string.str_debug_upgrade_ota, false);
                if (th instanceof UpgradeException) {
                    d.b.a.a.a.L((UpgradeException) th, DebugMenuApplication.f1956b, "OTA PACKAGE");
                }
            }
        }, aVar3, aVar3).u(cVar, f.a.w.b.a.f3727d, aVar3, cVar));
    }

    public l h(Boolean bool) {
        Objects.requireNonNull((t0) this.upgradeHandler);
        return checkPoint(TextUtils.isEmpty("") ? r0.b(t0.v) : d.b.a.a.a.a0(""), SDKUpgradeResult.BIN_NOT_FOUND);
    }

    public l i(Boolean bool) {
        p0 p0Var = this.upgradeHandler;
        final Context context = this.mContext;
        final t0 t0Var = (t0) p0Var;
        Objects.requireNonNull(t0Var);
        final String str = "/data/ota_package/update.zip";
        final String str2 = "";
        f.a.w.e.d.c cVar = new f.a.w.e.d.c(new k() { // from class: d.f.a.p2.b0
            /* JADX WARN: Removed duplicated region for block: B:15:0x0071  */
            /* JADX WARN: Removed duplicated region for block: B:50:0x0160  */
            /* JADX WARN: Removed duplicated region for block: B:53:0x01f1  */
            /* JADX WARN: Removed duplicated region for block: B:54:0x01fd  */
            @Override // f.a.k
            /*
                Code decompiled incorrectly, please refer to instructions dump.
                To view partially-correct add '--show-bad-code' argument
            */
            public final void subscribe(f.a.j r20) {
                /*
                    Method dump skipped, instruction units count: 556
                    To view this dump add '--comments-level debug' option
                */
                throw new UnsupportedOperationException("Method not decompiled: d.f.a.p2.b0.subscribe(f.a.j):void");
            }
        });
        f.a.v.a aVar = new f.a.v.a() { // from class: d.f.a.p2.q
            @Override // f.a.v.a
            public final void run() {
                String str3 = str;
                Log.i("UpgradeHisiHelper", "upgrade doOnComplete");
                d.i.f.g.d dVarC = d.i.c.a.c("rm " + str3, false);
                StringBuilder sbB = d.b.a.a.a.B("upgrade rm file result: ");
                sbB.append(dVarC.a);
                Log.i("UpgradeHisiHelper", sbB.toString());
            }
        };
        f.a.v.c<? super Throwable> cVar2 = f.a.w.b.a.f3726c;
        f.a.v.a aVar2 = f.a.w.b.a.f3725b;
        return cVar.i(cVar2, cVar2, aVar, aVar2).i(cVar2, new f.a.v.c() { // from class: d.f.a.p2.o
            @Override // f.a.v.c
            public final void accept(Object obj) {
                String str3 = str;
                Log.e("UpgradeHisiHelper", "upgrade doOnError :", (Throwable) obj);
                d.i.f.g.d dVarC = d.i.c.a.c("rm " + str3, false);
                StringBuilder sbB = d.b.a.a.a.B("upgrade rm file result: ");
                sbB.append(dVarC.a);
                Log.i("UpgradeHisiHelper", sbB.toString());
            }
        }, aVar2, aVar2).g(((RxAppCompatActivity) context).bindUntilEvent(com.trello.rxlifecycle3.android.ActivityEvent.DESTROY));
    }

    public void j() {
        Log.d(TAG, "doOnComplete");
        c.n.a.f0(R.string.str_debug_upgrade_ota, true);
        c.n.a.e0(c.n.a.D(DebugMenuApplication.f1956b, SDKUpgradeResult.SUCCESS, "OTA PACKAGE"));
        c.n.a.N(1000L);
        ((t0) this.upgradeHandler).a();
    }

    @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) {
        c.n.a.Z(true);
        v2 v2Var = new v2(new AnonymousClass1());
        this.mFindFrontUSBHelper = v2Var;
        v2Var.a();
    }

    @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) {
    }
}