package d.f.a.r2;

import android.content.Context;
import android.os.RemoteException;
import android.os.SystemProperties;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.dss.ups.main.McuPlugin;
import com.cvte.vman.VmanMiddleWare;
import com.cvte.vman.listener.OnFwUpgradeListener;
import com.cvte.vman.utils.CLog;
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 f.a.j;
import f.a.w.b.a;
import f.a.w.e.d.c;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: UpgradeUtils.java */
/* JADX INFO: loaded from: classes.dex */
public class f3 {
    public static f.a.i<Boolean> a(boolean z, SDKUpgradeResult sDKUpgradeResult) {
        return z ? f.a.i.m(Boolean.valueOf(z)) : new f.a.w.e.d.j(new a.e(new UpgradeException(sDKUpgradeResult)));
    }

    public static f.a.i<Boolean> b(final d.f.a.p2.p0 p0Var) {
        return a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.r2.m0
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                Objects.requireNonNull(p0Var);
                return f3.a(true, SDKUpgradeResult.UPGRADE_ERROR);
            }
        });
    }

    public static f.a.i<Boolean> c(final Context context, final d.f.a.p2.p0 p0Var, final int i2, final String str) {
        return a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.r2.m1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                return f3.a(((d.f.a.p2.t0) p0Var).e(str), SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new f.a.v.d() { // from class: d.f.a.r2.u0
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                final int i3 = i2;
                final String strQ = str;
                final d.f.a.p2.t0 t0Var = (d.f.a.p2.t0) p0Var2;
                Objects.requireNonNull(t0Var);
                if (TextUtils.isEmpty(strQ)) {
                    strQ = u2.q("/MAC/", "MAC.*\\.bin");
                }
                return new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.a
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) throws IOException {
                        t0 t0Var2 = t0Var;
                        String str2 = strQ;
                        int i4 = i3;
                        Objects.requireNonNull(t0Var2);
                        Log.i("upgradeMac", "path:" + str2);
                        File file = new File(str2);
                        FileInputStream fileInputStream = new FileInputStream(file);
                        byte[] bArr = new byte[fileInputStream.available()];
                        fileInputStream.read(bArr);
                        fileInputStream.close();
                        Log.i("UpgradeHisiHelper", "upgradeMac bytes:" + t0Var2.b(bArr) + " type:" + i4);
                        boolean macByFuncType = VmanMiddleWare.getInstance().getAtCfgControl().setMacByFuncType(i4, bArr);
                        if (macByFuncType) {
                            file.delete();
                        }
                        ((c.a) jVar).d(Boolean.valueOf(macByFuncType));
                    }
                });
            }
        });
    }

    public static f.a.i<Boolean> d(final Context context, final d.f.a.p2.p0 p0Var) {
        return a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.r2.z0
            /* JADX WARN: Removed duplicated region for block: B:22:0x0068  */
            @Override // f.a.v.d
            /*
                Code decompiled incorrectly, please refer to instructions dump.
                To view partially-correct add '--show-bad-code' argument
            */
            public final java.lang.Object apply(java.lang.Object r6) {
                /*
                    r5 = this;
                    d.f.a.p2.p0 r0 = r1
                    java.lang.Boolean r6 = (java.lang.Boolean) r6
                    d.f.a.p2.t0 r0 = (d.f.a.p2.t0) r0
                    java.util.Objects.requireNonNull(r0)
                    d.i.f.g.a r6 = d.i.c.a.e()
                    d.i.f.g.a r1 = d.i.f.g.a.MT9666
                    r2 = 1
                    if (r6 == r1) goto L6a
                    d.i.f.g.a r6 = d.i.c.a.e()
                    d.i.f.g.a r1 = d.i.f.g.a.MT8195
                    if (r6 != r1) goto L1b
                    goto L6a
                L1b:
                    java.lang.String r6 = ""
                    boolean r1 = android.text.TextUtils.isEmpty(r6)
                    r3 = 0
                    if (r1 == 0) goto L35
                    java.lang.String r6 = d.f.a.p2.t0.f3051e
                    boolean r6 = d.f.a.p2.r0.b(r6)
                    if (r6 == 0) goto L68
                    java.lang.String r6 = d.f.a.p2.t0.f3053g
                    boolean r6 = d.f.a.p2.r0.b(r6)
                    if (r6 == 0) goto L68
                    goto L99
                L35:
                    java.lang.String r1 = java.io.File.separator
                    boolean r4 = r6.endsWith(r1)
                    if (r4 != 0) goto L41
                    java.lang.String r6 = d.b.a.a.a.p(r6, r1)
                L41:
                    java.lang.StringBuilder r1 = d.b.a.a.a.B(r6)
                    java.lang.String r4 = d.f.a.p2.t0.f3050d
                    r1.append(r4)
                    java.lang.String r1 = r1.toString()
                    boolean r1 = r0.d(r1)
                    if (r1 == 0) goto L68
                    java.lang.StringBuilder r6 = d.b.a.a.a.B(r6)
                    java.lang.String r1 = d.f.a.p2.t0.f3052f
                    r6.append(r1)
                    java.lang.String r6 = r6.toString()
                    boolean r6 = r0.d(r6)
                    if (r6 == 0) goto L68
                    goto L99
                L68:
                    r2 = r3
                    goto L99
                L6a:
                    java.lang.String r6 = d.b.a.a.a.f(r2)
                    java.lang.StringBuilder r0 = new java.lang.StringBuilder
                    r0.<init>()
                    java.lang.String r1 = "isMcuFileExist name = "
                    r0.append(r1)
                    r0.append(r6)
                    java.lang.String r0 = r0.toString()
                    java.lang.String r1 = "UpgradeHisiHelper"
                    android.util.Log.i(r1, r0)
                    java.lang.StringBuilder r0 = new java.lang.StringBuilder
                    r0.<init>()
                    java.lang.String r1 = d.f.a.p2.t0.f3048b
                    r0.append(r1)
                    r0.append(r6)
                    java.lang.String r6 = r0.toString()
                    boolean r2 = d.f.a.p2.r0.b(r6)
                L99:
                    com.seewo.sdk.model.SDKUpgradeResult r6 = com.seewo.sdk.model.SDKUpgradeResult.BIN_NOT_FOUND
                    f.a.i r6 = d.f.a.r2.f3.a(r2, r6)
                    return r6
                */
                throw new UnsupportedOperationException("Method not decompiled: d.f.a.r2.z0.apply(java.lang.Object):java.lang.Object");
            }
        }).k(new f.a.v.d() { // from class: d.f.a.r2.y0
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                final Context context2 = context;
                final d.f.a.p2.t0 t0Var = (d.f.a.p2.t0) p0Var2;
                Objects.requireNonNull(t0Var);
                d.i.f.g.a aVarE = d.i.c.a.e();
                d.i.f.g.a aVar = d.i.f.g.a.MT9666;
                final String strF = "";
                if (aVarE == aVar || d.i.c.a.e() == d.i.f.g.a.MT8195) {
                    String strF2 = d.b.a.a.a.f(1);
                    Log.i("UpgradeHisiHelper", "upgradeMcu 9666 filename = " + strF2);
                    strF = u2.f(d.f.a.p2.t0.f3048b + strF2);
                } else if (TextUtils.isEmpty("")) {
                    strF = u2.f(d.f.a.p2.t0.f3051e);
                }
                Log.i("UpgradeHisiHelper", "upgradeMcu path = " + strF);
                return f3.a((d.i.c.a.r() || d.i.c.a.e() == aVar || d.i.c.a.e() == d.i.f.g.a.MT8195) ? ((Boolean) new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.a0
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) {
                        t0 t0Var2 = t0Var;
                        String str = strF;
                        Objects.requireNonNull(t0Var2);
                        VmanMiddleWare.getInstance().getFwUpgrade().setFirmwareUpgrade(1, str);
                        VmanMiddleWare.getInstance().registerListener(3585, new OnFwUpgradeListener(t0Var2, jVar) { // from class: com.ifpdos.debugmenu.upgrade.UpgradeHisiHelper$1
                            public final /* synthetic */ j a;

                            {
                                this.a = jVar;
                            }

                            @Override // com.cvte.vman.listener.OnFwUpgradeListener
                            public void onFwUpgradeStat(int i2, int i3) {
                                CLog.d("McuUpgradeTool get type = " + i2 + " stat = " + i3);
                                if (i3 == 0 || i3 == 2) {
                                    VmanMiddleWare.getInstance().unregisterListener(this);
                                    ((c.a) this.a).d(Boolean.valueOf(i3 == 0));
                                    ((c.a) this.a).b();
                                }
                            }
                        });
                    }
                }).p().y(60L, TimeUnit.SECONDS).o(new f.a.v.d() { // from class: d.f.a.p2.z
                    @Override // f.a.v.d
                    public final Object apply(Object obj2) {
                        t0 t0Var2 = t0.a;
                        return Boolean.FALSE;
                    }
                }).g(((RxAppCompatActivity) context2).bindUntilEvent(ActivityEvent.DESTROY)).f()).booleanValue() : ((Boolean) new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.e
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) {
                        Context context3 = context2;
                        String str = strF;
                        try {
                            if (new McuPlugin().upgradeFirmware(context3, str, true, new UpsPluginListener(jVar))) {
                                return;
                            }
                            c.a aVar2 = (c.a) jVar;
                            aVar2.d(Boolean.FALSE);
                            aVar2.b();
                        } catch (Exception e2) {
                            Log.e("UpgradeHisiHelper", "upgradeMcu Err", e2);
                            ((c.a) jVar).c(new UpgradeException(SDKUpgradeResult.UPGRADE_ERROR));
                        }
                    }
                }).p().y(120L, TimeUnit.SECONDS).o(new f.a.v.d() { // from class: d.f.a.p2.s
                    @Override // f.a.v.d
                    public final Object apply(Object obj2) {
                        t0 t0Var2 = t0.a;
                        return Boolean.FALSE;
                    }
                }).g(((RxAppCompatActivity) context2).bindUntilEvent(ActivityEvent.DESTROY)).f()).booleanValue(), SDKUpgradeResult.UPGRADE_ERROR);
            }
        }).y(120L, TimeUnit.SECONDS);
    }

    public static f.a.i<Boolean> e(final d.f.a.p2.p0 p0Var) {
        return a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.r2.j1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                Objects.requireNonNull((d.f.a.p2.t0) p0Var);
                String str = SystemProperties.get("ro.CVT_DEF_UPGRADEBIN_NAME", "");
                String strV = TextUtils.isEmpty(str) ? d.f.a.p2.t0.f3049c : d.b.a.a.a.v(new StringBuilder(), d.f.a.p2.t0.f3048b, str);
                String str2 = d.f.a.p2.r0.a;
                boolean z = false;
                if (TextUtils.isEmpty(strV)) {
                    Log.e("UpgradeHelper", "File name empty");
                } else {
                    File fileE = u2.e(strV, false);
                    if (fileE != null) {
                        if (h3.q(fileE.getAbsolutePath())) {
                            Log.e("UpgradeHelper", "File not found");
                        } else {
                            z = true;
                        }
                    }
                }
                return f3.a(z, SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new f.a.v.d() { // from class: d.f.a.r2.g0
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.t0 t0Var = (d.f.a.p2.t0) p0Var;
                if (t0Var.A != null) {
                    try {
                        Log.e("UpgradeHisiHelper", "upgradeSystem " + t0Var.A.eventUsbUpgradeDoUpgrade());
                        t0Var.A.eventUsbUpgradeDoUpgrade();
                    } catch (RemoteException unused) {
                    }
                }
                return f3.a(true, SDKUpgradeResult.UPGRADE_ERROR);
            }
        });
    }

    public static f.a.i<Boolean> f(final Context context, final d.f.a.p2.p0 p0Var, final int i2, final String str) {
        return a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new f.a.v.d() { // from class: d.f.a.r2.t
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                return f3.a(((d.f.a.p2.t0) p0Var).d(str), SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new f.a.v.d() { // from class: d.f.a.r2.b1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                return ((d.f.a.p2.t0) p0Var).n(context, i2, str);
            }
        });
    }
}