package com.ifpdos.debugmenu.action;

import android.content.Context;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.dss.ups.camera.Plugin;
import com.ifpdos.debugmenu.DebugMenuApplication;
import com.ifpdos.debugmenu.R;
import com.ifpdos.debugmenu.action.UpgradeCameraAction;
import com.ifpdos.debugmenu.action.base.ItemButtonAction;
import com.ifpdos.debugmenu.entity.UpgradeException;
import com.ifpdos.debugmenu.entity.UpsPluginListener;
import com.seewo.sdk.model.SDKUpgradeResult;
import com.trello.rxlifecycle3.android.ActivityEvent;
import com.trello.rxlifecycle3.components.support.RxAppCompatActivity;
import d.f.a.p1.o2;
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.v2;
import d.f.a.s1.e;
import f.a.t.a;
import f.a.v.d;
import f.a.w.e.d.c;
import java.util.Objects;
import k.c.a.c;
import org.json.JSONObject;

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

    /* JADX INFO: renamed from: com.ifpdos.debugmenu.action.UpgradeCameraAction$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_camera_hint, new e() { // from class: d.f.a.p1.l8
                @Override // d.f.a.s1.e
                public final void call() {
                    UpgradeCameraAction.AnonymousClass1 anonymousClass1 = this.a;
                    Objects.requireNonNull(anonymousClass1);
                    c.n.a.o();
                    UpgradeCameraAction.this.upgrade();
                }
            }, o2.a);
        }
    }

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

    /* JADX INFO: Access modifiers changed from: private */
    public void upgrade() {
        t2.e();
        c.n.a.a0(R.string.str_upgrade_camera);
        a aVar = this.mCompositeDisposable;
        final Context context = this.mContext;
        final p0 p0Var = this.upgradeHandler;
        final String str = "";
        aVar.b(f3.a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new d() { // from class: d.f.a.r2.k0
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                String str2 = str;
                Objects.requireNonNull((d.f.a.p2.t0) p0Var2);
                return f3.a(TextUtils.isEmpty(str2) ? d.f.a.p2.r0.c("Camera---.*") : d.b.a.a.a.a0(str2), SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new d() { // from class: d.f.a.r2.i1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                final Context context2 = context;
                final String strP = str;
                Objects.requireNonNull((d.f.a.p2.t0) p0Var2);
                if (TextUtils.isEmpty(strP)) {
                    strP = u2.p("Camera---.*");
                }
                Log.e("UpgradeHisiHelper", "upgradeCamera path = " + strP);
                return new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.h0
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) {
                        Context context3 = context2;
                        String str2 = strP;
                        if (!d.f.a.g2.a.a(context3)) {
                            try {
                                boolean zUpgradeFirmware = new Plugin().upgradeFirmware(context3, str2, true, new UpsPluginListener(jVar));
                                Log.i("UpgradeHisiHelper", "upgradeCamera res " + zUpgradeFirmware);
                                if (zUpgradeFirmware) {
                                    return;
                                }
                                c.a aVar2 = (c.a) jVar;
                                aVar2.d(Boolean.FALSE);
                                aVar2.b();
                                return;
                            } catch (Exception e2) {
                                Log.e("UpgradeHisiHelper", "upgradeCamera Err", e2);
                                ((c.a) jVar).c(new UpgradeException(SDKUpgradeResult.UPGRADE_ERROR));
                                return;
                            }
                        }
                        Log.i("UpgradeHisiHelper", "upgradeCamera Zyzh");
                        com.cvte.dss.ups.camera.zyzh.Plugin plugin = new com.cvte.dss.ups.camera.zyzh.Plugin();
                        try {
                            JSONObject jSONObject = new JSONObject();
                            jSONObject.put("upgrade_pls", true);
                            boolean zUpgradeFirmware2 = plugin.upgradeFirmware(context3, "", str2, true, jSONObject.toString(), new UpsPluginListener(jVar));
                            Log.i("UpgradeHisiHelper", "upgradeCamera res " + zUpgradeFirmware2);
                            if (zUpgradeFirmware2) {
                                return;
                            }
                            c.a aVar3 = (c.a) jVar;
                            aVar3.d(Boolean.FALSE);
                            aVar3.b();
                        } catch (Exception e3) {
                            Log.e("UpgradeHisiHelper", "upgradeCamera Err", e3);
                            ((c.a) jVar).c(new UpgradeException(SDKUpgradeResult.UPGRADE_ERROR));
                        }
                    }
                });
            }
        }).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.n8
            @Override // f.a.v.c
            public final void accept(Object obj) {
                if (d.b.a.a.a.Z((Boolean) obj, R.string.str_upgrade_camera) && d.i.f.c.c.f("persist.vendor.need_reboot_upgrade_cam", "0").equals("1")) {
                    c.n.a.N(2000L);
                }
            }
        }, new f.a.v.c() { // from class: d.f.a.p1.m8
            @Override // f.a.v.c
            public final void accept(Object obj) {
                Throwable th = (Throwable) obj;
                c.n.a.f0(R.string.str_upgrade_camera, false);
                if (th instanceof UpgradeException) {
                    d.b.a.a.a.L((UpgradeException) th, DebugMenuApplication.f1956b, "Camera");
                }
            }
        }, 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, 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) {
    }
}