package com.seewo.ota.v.u;

import android.content.Context;
import android.util.Log;
import com.cvte.vman.VmanMiddleWare;
import com.cvte.vman.types.EnumRGBLedOtaState;
import com.seewo.libmyousdk.model.DubboResponseInfo;
import com.seewo.ota.R;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: UpgradeController.java */
/* JADX INFO: loaded from: classes.dex */
public class r implements s {

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private static volatile r f2621f;
    private Context a;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    private n f2622b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    private boolean f2623c = false;

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private boolean f2624d = false;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private final Map<String, s> f2625e = new HashMap();

    public static r d() {
        if (f2621f == null) {
            synchronized (r.class) {
                if (f2621f == null) {
                    f2621f = new r();
                }
            }
        }
        return f2621f;
    }

    static /* synthetic */ Boolean h(n nVar, String str, boolean z, boolean z2, Long l) throws Exception {
        boolean zD = nVar.d(str);
        if (zD) {
            d.e.e.d.g().f(d.e.e.e.a.d().a(), Boolean.valueOf(z)).J(Boolean.FALSE).N();
            nVar.a(str, z2);
        }
        return Boolean.valueOf(zD);
    }

    private void k(int i2, Object obj) {
        Iterator<s> it = this.f2625e.values().iterator();
        while (it.hasNext()) {
            it.next().c(i2, obj);
        }
    }

    @Override // com.seewo.ota.v.u.s
    public void a(int i2) {
        Log.d("UpgradeController", "onCopyProgress " + i2);
        Iterator<s> it = this.f2625e.values().iterator();
        while (it.hasNext()) {
            it.next().a(i2);
        }
    }

    @Override // com.seewo.ota.v.u.s
    public void b() {
        if (this.a.getResources().getBoolean(R.bool.support_ota_update_custom_app)) {
            com.seewo.vcommons.data.d.u("persist.sys.apk_boot_install", DubboResponseInfo.STATUS_OK);
        }
        if (this.a.getResources().getBoolean(R.bool.support_change_rgb_led)) {
            VmanMiddleWare.getInstance().getRGBLedCtrl().setLedOtaState(EnumRGBLedOtaState.LED_OTA_UPDATING);
        }
        com.seewo.vcommons.data.d.u("sys.in_system_firmware_ota", "true");
        if (!d.e.g.b.f3546b.a()) {
            this.f2624d = true;
            d.e.g.b.f3546b.c(true, false);
        }
        Iterator<s> it = this.f2625e.values().iterator();
        while (it.hasNext()) {
            it.next().b();
        }
    }

    @Override // com.seewo.ota.v.u.s
    public void c(int i2, Object obj) {
        Log.d("UpgradeController", "onUpgradeCallback " + i2 + "   " + obj);
        if (i2 == 6) {
            k(i2, obj);
            return;
        }
        if (i2 != 5) {
            com.seewo.ota.util.s.a().c(this.a, R.string.hardware_updating_dialog_fail);
        }
        com.seewo.vcommons.data.d.u("sys.in_system_firmware_ota", "false");
        this.f2623c = false;
        if (this.a.getResources().getBoolean(R.bool.support_change_rgb_led)) {
            if (i2 == 5) {
                VmanMiddleWare.getInstance().getRGBLedCtrl().setLedOtaState(EnumRGBLedOtaState.LED_OTA_UPDATE_SUCCESSFUL);
            } else {
                VmanMiddleWare.getInstance().getRGBLedCtrl().setLedOtaState(EnumRGBLedOtaState.LED_OTA_UPDATE_FAILURE);
            }
        }
        if (this.f2624d) {
            this.f2624d = false;
            d.e.g.b.f3546b.c(false, false);
        }
        k(i2, obj);
    }

    public n e() {
        if (this.f2622b == null) {
            this.f2622b = t.b().a(this.a, this);
        }
        return this.f2622b;
    }

    public void f(Context context) {
        this.a = context.getApplicationContext();
    }

    public boolean g() {
        return this.f2623c;
    }

    public /* synthetic */ void i(String str, Boolean bool) throws Exception {
        if (bool.booleanValue()) {
            return;
        }
        Log.e("UpgradeController", "upgrade error! ERROR_INVALID_UPGRADE_PACKAGE");
        c(0, str);
    }

    public /* synthetic */ void j(String str, Throwable th) throws Exception {
        Log.e("UpgradeController", "upgrade error! ");
        c(0, str);
    }

    public void l(String str, s sVar) {
        if (sVar != null) {
            d.e.h.e.e.a("UpgradeController", "registerUpgradeListener key:" + str + "  listener:" + sVar);
            this.f2625e.put(str, sVar);
        }
    }

    public void m(String str) {
        this.f2625e.remove(str);
        d.e.h.e.e.a("UpgradeController", "registerUpgradeListener key:" + str);
    }

    public synchronized void n(final String str, final boolean z, final boolean z2) {
        if (this.f2623c) {
            Log.d("UpgradeController", "isUpgrading,waiting");
            return;
        }
        Log.d("UpgradeController", "upgradeSystem, path:" + str + "  , isAutoUpgrade:" + z + "  , isReboot:" + z2);
        final n nVarE = e();
        if (nVarE != null) {
            this.f2623c = true;
            b();
            Log.d("UpgradeController", "start upgradeSystem");
            e.a.h.V(1000L, TimeUnit.MILLISECONDS).T(e.a.x.a.b()).F(new e.a.t.d() { // from class: com.seewo.ota.v.u.k
                @Override // e.a.t.d
                public final Object apply(Object obj) {
                    return r.h(nVarE, str, z, z2, (Long) obj);
                }
            }).G(e.a.q.b.a.a()).P(new e.a.t.c() { // from class: com.seewo.ota.v.u.j
                @Override // e.a.t.c
                public final void accept(Object obj) throws Exception {
                    this.a.i(str, (Boolean) obj);
                }
            }, new e.a.t.c() { // from class: com.seewo.ota.v.u.i
                @Override // e.a.t.c
                public final void accept(Object obj) throws Exception {
                    this.a.j(str, (Throwable) obj);
                }
            });
        } else {
            Log.e("UpgradeController", "not support ota upgrade processor!");
        }
    }

    @Override // com.seewo.ota.v.u.s, android.os.RecoverySystem.ProgressListener
    public void onProgress(int i2) {
        Log.d("UpgradeController", "onProgress " + i2);
        Iterator<s> it = this.f2625e.values().iterator();
        while (it.hasNext()) {
            it.next().onProgress(i2);
        }
    }
}