package com.ifpdos.debugmenu.action;

import android.annotation.SuppressLint;
import android.content.Context;
import android.content.DialogInterface;
import android.text.TextUtils;
import android.util.Log;
import c.n.a;
import com.cvte.vman.VmanMiddleWare;
import com.cvte.vman.impl.AtCfgControlManager;
import com.ifpdos.debugmenu.DebugMenuApplication;
import com.ifpdos.debugmenu.R;
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.f.a.c1;
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.v.d;
import f.a.w.e.d.c;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.util.Objects;

/* JADX INFO: loaded from: classes.dex */
public class UpgradeHDCP1Action extends ItemButtonAction implements c1 {
    private static final String TAG = "UpgradeHDCP1Action";
    private e mActionFinishCallback;
    private v2 mFindFrontUSBHelper;
    private p0 upgradeHandler;

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

    /* JADX INFO: Access modifiers changed from: private */
    public void showConfirmDialog() {
        a.V(R.string.str_debug_upgrade, R.string.str_debug_upgrade_hdcp1_hint, new e() { // from class: d.f.a.p1.g9
            @Override // d.f.a.s1.e
            public final void call() {
                this.a.j();
            }
        });
    }

    @SuppressLint({"CheckResult"})
    private void upgrade() {
        t2.e();
        a.a0(R.string.str_debug_upgrade_hdcp1);
        final Context context = this.mContext;
        final p0 p0Var = this.upgradeHandler;
        final String str = "";
        f3.a(p0Var != null, SDKUpgradeResult.INVALID_MACHINE).k(new d() { // from class: d.f.a.r2.e2
            @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.d("hdcp_key/", "^[a-zA-Z].*HDCPkey.*\\.bin") : d.b.a.a.a.a0(str2), SDKUpgradeResult.BIN_NOT_FOUND);
            }
        }).k(new d() { // from class: d.f.a.r2.e1
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                d.f.a.p2.p0 p0Var2 = p0Var;
                final Context context2 = context;
                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("hdcp_key/", "^[a-zA-Z].*HDCPkey.*\\.bin");
                }
                return new f.a.w.e.d.c(new f.a.k() { // from class: d.f.a.p2.d
                    @Override // f.a.k
                    public final void subscribe(f.a.j jVar) throws IOException {
                        t0 t0Var2 = t0Var;
                        String str2 = strQ;
                        Context context3 = context2;
                        Objects.requireNonNull(t0Var2);
                        Log.i("UpgradeHisiHelper", "upgradeHDCP1 path:" + str2);
                        File file = new File(str2);
                        FileInputStream fileInputStream = new FileInputStream(file);
                        byte[] bArr = new byte[fileInputStream.available()];
                        fileInputStream.read(bArr);
                        Log.i("UpgradeHisiHelper", "upgradeHDCP1:" + t0Var2.b(bArr));
                        fileInputStream.close();
                        try {
                            boolean dataBuff = VmanMiddleWare.getInstance().getAtCfgControl().setDataBuff(AtCfgControlManager.IDX_HDCP_14_KEY, bArr);
                            Log.i("UpgradeHisiHelper", "upgradeHDCP1 result:" + dataBuff);
                            if (dataBuff) {
                                byte[] bArr2 = {(byte) (r5 & 255), (byte) ((r5 >> 8) & 255), (byte) (255 & (r5 >> 16)), (byte) (r5 >>> 24)};
                                Log.i("UpgradeHisiHelper", "IDX_HDCP_14_KEY write , file_id=" + c.n.a.H(file.getName()));
                                dataBuff = dataBuff && VmanMiddleWare.getInstance(context3).getAtCfgControl().setDataBuff(AtCfgControlManager.IDX_HDCP_14_ID, bArr2);
                                file.delete();
                            }
                            ((c.a) jVar).d(Boolean.valueOf(dataBuff));
                        } catch (Exception e2) {
                            StringBuilder sbB = d.b.a.a.a.B("upgradeHDCP1 Exception:");
                            sbB.append(e2.getMessage());
                            Log.i("UpgradeHisiHelper", sbB.toString());
                        }
                    }
                });
            }
        }).w(f.a.z.a.f4044c).g(((RxAppCompatActivity) this.mContext).bindUntilEvent(ActivityEvent.DESTROY)).u(new f.a.v.c() { // from class: d.f.a.p1.j9
            @Override // f.a.v.c
            public final void accept(Object obj) {
                c.n.a.f0(R.string.str_debug_upgrade_hdcp1, ((Boolean) obj).booleanValue());
            }
        }, new f.a.v.c() { // from class: d.f.a.p1.f9
            @Override // f.a.v.c
            public final void accept(Object obj) {
                Throwable th = (Throwable) obj;
                c.n.a.f0(R.string.str_debug_upgrade_hdcp1, false);
                if (th instanceof UpgradeException) {
                    UpgradeException upgradeException = (UpgradeException) th;
                    if (upgradeException.getErrorReason() != SDKUpgradeResult.BIN_NOT_FOUND && upgradeException.getErrorReason() != SDKUpgradeResult.SUCCESS) {
                        d.f.a.r2.t2.c(new d.f.a.s1.e() { // from class: d.f.a.p1.i9
                            @Override // d.f.a.s1.e
                            public final void call() {
                            }
                        });
                        c.n.a.Y("HDCP1", upgradeException.getErrorReason().name());
                    }
                    d.b.a.a.a.L(upgradeException, DebugMenuApplication.f1956b, "HDCP1");
                }
            }
        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
    }

    private void upgradeCheckUSB() {
        a.Z(true);
        v2 v2Var = new v2(new v2.a() { // from class: com.ifpdos.debugmenu.action.UpgradeHDCP1Action.1
            @Override // d.f.a.r2.v2.a
            public void onFail() {
                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() {
                a.Z(false);
                UpgradeHDCP1Action.this.showConfirmDialog();
            }
        });
        this.mFindFrontUSBHelper = v2Var;
        v2Var.a();
    }

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

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

    public /* synthetic */ void j() {
        a.o();
        upgrade();
    }

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

    @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;
        a.U(R.string.str_debug_upgrade, R.string.str_debug_upgrade_hdcp1_hint, new e() { // from class: d.f.a.p1.h9
            @Override // d.f.a.s1.e
            public final void call() {
                this.a.h();
            }
        }, new DialogInterface.OnCancelListener() { // from class: d.f.a.p1.k9
            @Override // android.content.DialogInterface.OnCancelListener
            public final void onCancel(DialogInterface dialogInterface) {
                this.f2796b.i(dialogInterface);
            }
        });
    }
}