package com.seewo.ota.activity.n2;

import android.app.Application;
import android.content.BroadcastReceiver;
import android.content.ComponentName;
import android.content.Context;
import android.content.Intent;
import android.content.IntentFilter;
import android.content.ServiceConnection;
import android.os.Bundle;
import android.os.IBinder;
import android.os.RemoteException;
import android.os.UserHandle;
import android.os.UserManager;
import android.text.TextUtils;
import android.util.Log;
import androidx.lifecycle.q;
import androidx.lifecycle.r;
import com.seewo.ota.OTAApplication;
import com.seewo.ota.R;
import d.e.b.a.a;
import d.e.b.a.b;
import d.e.h.a.b;
import f.e0.s;
import f.k;
import f.z.d.l;
import java.io.File;
import java.util.Iterator;

/* JADX INFO: compiled from: UpdateInfoViewModel.kt */
/* JADX INFO: loaded from: classes.dex */
public final class b extends androidx.lifecycle.a {

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    private d.e.b.a.b f2066d;

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    private final ServiceConnection f2067e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    private final BroadcastReceiver f2068f;

    /* JADX INFO: renamed from: g, reason: collision with root package name */
    private final f.e f2069g;

    /* JADX INFO: renamed from: h, reason: collision with root package name */
    private final q<b.a> f2070h;

    /* JADX INFO: renamed from: i, reason: collision with root package name */
    private final q<String> f2071i;

    /* JADX INFO: renamed from: j, reason: collision with root package name */
    private final q<Boolean> f2072j;

    /* JADX INFO: renamed from: k, reason: collision with root package name */
    private final q<C0053b> f2073k;
    private final q<Integer> l;
    private final q<k<Integer, Integer>> m;
    private final q<Integer> n;
    private final q<Integer> o;
    private final q<Boolean> p;
    private final q<Boolean> q;
    private boolean r;

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    private final class a extends a.AbstractBinderC0083a {
        public a() {
        }

        @Override // d.e.b.a.a
        public void I(int i2) {
            Log.d("UpdateInfoViewModel", "onUpgradeCallback: " + i2);
            b.this.v().k(Integer.valueOf(i2));
        }

        @Override // d.e.b.a.a
        public void d(int i2) {
            Log.d("UpdateInfoViewModel", "onUpgradeProgress: " + i2);
            b.this.u().k(Integer.valueOf(i2));
        }

        @Override // d.e.b.a.a
        public void g(int i2) {
            Log.d("UpdateInfoViewModel", "onCheckResult: " + i2);
            if (i2 == 0) {
                b.this.n().k(b.a.HAVE);
                b.this.s();
            } else if (i2 != 1) {
                b.this.n().k(b.a.NONE);
            } else {
                b.this.n().k(b.a.NONE);
            }
            b.this.m().k(Integer.valueOf(i2));
        }

        @Override // d.e.b.a.a
        public void j(int i2, int i3) {
            Log.d("UpdateInfoViewModel", "onDownloadResult: " + i2 + " ,progress: " + i3);
            if (i2 == 1) {
                b.this.A().k(Boolean.TRUE);
                b.this.n().k(b.a.DOWNLOADING);
            } else if (i2 == 2) {
                b.this.A().k(Boolean.FALSE);
                b.this.n().k(b.a.DOWNLOADED);
            } else if (i2 != 3) {
                b.this.n().k(b.a.NONE);
                b.this.A().k(Boolean.FALSE);
            } else {
                b.this.A().k(Boolean.FALSE);
                b.this.n().k(b.a.DOWNLOAD_PAUSED);
            }
            b.this.r().k(new k<>(Integer.valueOf(i2), Integer.valueOf(i3)));
        }
    }

    /* JADX INFO: renamed from: com.seewo.ota.activity.n2.b$b, reason: collision with other inner class name */
    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    public final class C0053b {
        private final String a;

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        private final long f2075b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        private final String f2076c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        private final boolean f2077d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        private final boolean f2078e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        private final boolean f2079f;

        public C0053b(b bVar, String str, long j2, String str2, boolean z, boolean z2, boolean z3) {
            f.z.d.k.e(str, "version");
            f.z.d.k.e(str2, "content");
            this.a = str;
            this.f2075b = j2;
            this.f2076c = str2;
            this.f2077d = z;
            this.f2078e = z2;
            this.f2079f = z3;
        }

        public final String a() {
            return this.f2076c;
        }

        public final long b() {
            return this.f2075b;
        }

        public final String c() {
            return this.a;
        }

        public final boolean d() {
            return this.f2077d;
        }

        public final boolean e() {
            return this.f2079f;
        }

        public final boolean f() {
            return this.f2078e;
        }
    }

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    public /* synthetic */ class c {
        public static final /* synthetic */ int[] a;

        static {
            int[] iArr = new int[b.a.values().length];
            iArr[b.a.DOWNLOADED.ordinal()] = 1;
            a = iArr;
        }
    }

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    public static final class d extends q<Boolean> {
        d() {
        }

        @Override // androidx.lifecycle.q, androidx.lifecycle.LiveData
        public /* bridge */ /* synthetic */ void m(Object obj) {
            n(((Boolean) obj).booleanValue());
        }

        public void n(boolean z) {
            if (f.z.d.k.a(e(), Boolean.valueOf(z))) {
                return;
            }
            Log.d("UpdateInfoViewModel", "isAutoOtaUpdateEnable: " + z);
            super.m(Boolean.valueOf(z));
            com.seewo.vcommons.data.c.q(b.this.f(), z);
        }
    }

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    public static final class e extends BroadcastReceiver {
        e() {
        }

        @Override // android.content.BroadcastReceiver
        public void onReceive(Context context, Intent intent) {
            f.z.d.k.e(context, "context");
            f.z.d.k.e(intent, "intent");
            b.this.y().k(Boolean.valueOf(com.seewo.vcommons.data.c.k(b.this.f())));
        }
    }

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    public static final class f implements ServiceConnection {
        f() {
        }

        @Override // android.content.ServiceConnection
        public void onServiceConnected(ComponentName componentName, IBinder iBinder) {
            f.z.d.k.e(componentName, "name");
            f.z.d.k.e(iBinder, "service");
            Log.d("UpdateInfoViewModel", "OTA onServiceConnected");
            b.this.f2066d = b.a.J(iBinder);
            if (b.this.f2066d != null) {
                try {
                    d.e.b.a.b bVar = b.this.f2066d;
                    f.z.d.k.c(bVar);
                    bVar.G(b.this.new a(), 1);
                    q<b.a> qVarN = b.this.n();
                    b.a[] aVarArrValues = b.a.values();
                    d.e.b.a.b bVar2 = b.this.f2066d;
                    f.z.d.k.c(bVar2);
                    qVarN.k(aVarArrValues[bVar2.H(1)]);
                } catch (Exception e2) {
                    Log.e("UpdateInfoViewModel", e2.getMessage(), e2);
                }
                b.this.s();
                b.this.t().k(Boolean.valueOf(com.seewo.vcommons.data.c.a(b.this.f(), "KEY_DISABLE_SYSTEM_UPDATE", false)));
            }
        }

        @Override // android.content.ServiceConnection
        public void onServiceDisconnected(ComponentName componentName) {
            f.z.d.k.e(componentName, "name");
            Log.d("UpdateInfoViewModel", "OTA onServiceDisconnected");
            b.this.f2066d = null;
        }
    }

    /* JADX INFO: compiled from: UpdateInfoViewModel.kt */
    static final class g extends l implements f.z.c.a<UserManager> {
        g() {
            super(0);
        }

        @Override // f.z.c.a
        /* JADX INFO: renamed from: b, reason: merged with bridge method [inline-methods] */
        public final UserManager invoke() {
            return (UserManager) ((OTAApplication) b.this.f()).getSystemService(UserManager.class);
        }
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public b(Application application) {
        super(application);
        f.z.d.k.e(application, "application");
        this.f2067e = new f();
        this.f2068f = new e();
        this.f2069g = f.g.a(new g());
        this.f2070h = new q<>();
        this.f2071i = new q<>();
        this.f2072j = new q<>();
        this.f2073k = new q<>();
        this.l = new q<>();
        this.m = new q<>();
        this.n = new q<>();
        this.o = new q<>();
        this.p = new d();
        this.q = new q<>(Boolean.FALSE);
        k();
        G();
        this.f2071i.k(p());
        this.p.k(Boolean.valueOf(com.seewo.vcommons.data.c.k(f())));
        this.f2070h.h(new r() { // from class: com.seewo.ota.activity.n2.a
            @Override // androidx.lifecycle.r
            public final void a(Object obj) {
                b.g(this.a, (b.a) obj);
            }
        });
    }

    private final void G() {
        IntentFilter intentFilter = new IntentFilter();
        intentFilter.addAction("com.ifpdos.action.AUTO_OTA_UPDATE_CHANGED");
        f().registerReceiver(this.f2068f, intentFilter);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public static final void g(b bVar, b.a aVar) {
        f.z.d.k.e(bVar, "this$0");
        if ((aVar == null ? -1 : c.a[aVar.ordinal()]) == 1) {
            bVar.m.k(new k<>(2, 100));
        }
    }

    private final void k() {
        Intent intent = new Intent("com.seewo.ota.service.OTARefreshService");
        intent.setPackage("com.seewo.ota");
        OTAApplication.f1907b.bindServiceAsUser(intent, this.f2067e, 1, UserHandle.SYSTEM);
    }

    private final File l() {
        Application applicationF = f();
        f.z.d.k.d(applicationF, "getApplication<Application>()");
        String string = applicationF.getResources().getString(R.string.path_usb_ota_file_name);
        f.z.d.k.d(string, "context.resources.getStr…g.path_usb_ota_file_name)");
        String string2 = applicationF.getResources().getString(R.string.path_usb_ota_file_parent);
        f.z.d.k.d(string2, "context.resources.getStr…path_usb_ota_file_parent)");
        StringBuilder sb = new StringBuilder();
        if (TextUtils.isEmpty(string2)) {
            sb.append(q());
        } else {
            sb.append(string2);
        }
        if (TextUtils.isEmpty(string)) {
            sb.append("update.zip");
        } else {
            sb.append(string);
        }
        Log.d("UpdateInfoViewModel", "getAutoUsbUpdateFile:" + ((Object) sb));
        Iterator<d.e.h.c.a> it = com.seewo.ota.v.q.U(applicationF).iterator();
        while (it.hasNext()) {
            File file = new File(it.next().a + ((Object) sb));
            Log.e("UpdateInfoViewModel", "usbUpdateFile :" + file.getPath() + "  ,exist: " + file.exists());
            if (file.exists()) {
                return file;
            }
        }
        return null;
    }

    private final String p() {
        if (f().getResources().getBoolean(R.bool.support_show_custom_version)) {
            String strL = com.seewo.vcommons.data.d.l("ro.custom.version.number", "");
            if (!TextUtils.isEmpty(strL)) {
                f.z.d.k.d(strL, "customVersion");
                return strL;
            }
        }
        String strH = com.seewo.vcommons.data.d.h();
        f.z.d.k.d(strH, "getProductVersion()");
        return s.h(strH, "\\", "", false, 4, null);
    }

    private final String q() {
        return "/upgrade_" + d.e.h.e.b.b() + '/';
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void s() {
        Log.d("UpdateInfoViewModel", "getInfoFromBundle: ");
        try {
            d.e.b.a.b bVar = this.f2066d;
            f.z.d.k.c(bVar);
            Bundle bundleC = bVar.C(1);
            String string = bundleC.getString("UPDATE_VERSION", "");
            long j2 = bundleC.getLong("UPDATE_SIZE", 0L);
            String string2 = bundleC.getString("UPDATE_DESC", "");
            boolean z = bundleC.getBoolean("UPDATE_IS_FORCE_UPDATE", false);
            boolean z2 = bundleC.getBoolean("UPDATE_IS_SILENT_DOWNLOAD", false);
            q<C0053b> qVar = this.f2073k;
            f.z.d.k.d(string, "newVersion");
            f.z.d.k.d(string2, "updateContent");
            qVar.k(new C0053b(this, string, j2, string2, z, z2, this.r));
        } catch (RemoteException e2) {
            Log.e("UpdateInfoViewModel", "getInfoFromBundle: ", e2);
        }
    }

    private final UserManager w() {
        Object value = this.f2069g.getValue();
        f.z.d.k.d(value, "<get-userManager>(...)");
        return (UserManager) value;
    }

    public final q<Boolean> A() {
        return this.q;
    }

    public final boolean B() {
        return f().getResources().getBoolean(R.bool.support_local_ota);
    }

    public final boolean C() {
        return f().getResources().getBoolean(R.bool.support_usb_update_direct);
    }

    public final boolean E() {
        return ((OTAApplication) f()).getResources().getBoolean(R.bool.support_child_user_ota) && !w().isAdminUser();
    }

    public final void F() {
        try {
            d.e.b.a.b bVar = this.f2066d;
            f.z.d.k.c(bVar);
            bVar.cancel(1);
            this.q.k(Boolean.FALSE);
        } catch (Exception e2) {
            Log.e("UpdateInfoViewModel", "pauseDownload: ", e2);
        }
    }

    public final void H(boolean z) {
        this.p.k(Boolean.valueOf(z));
    }

    public final void I(boolean z) {
        this.r = z;
    }

    public final void J(boolean z) {
        this.r = z;
        try {
            d.e.b.a.b bVar = this.f2066d;
            f.z.d.k.c(bVar);
            bVar.x(1, false);
        } catch (Exception e2) {
            this.l.k(2);
            Log.e("UpdateInfoViewModel", "startCheckUpdate: ", e2);
        }
    }

    public final void K() {
        try {
            d.e.b.a.b bVar = this.f2066d;
            f.z.d.k.c(bVar);
            bVar.s(1);
            this.q.k(Boolean.TRUE);
        } catch (Exception e2) {
            this.m.k(new k<>(0, 0));
            Log.e("UpdateInfoViewModel", "startDownload: ", e2);
        }
    }

    public final void L() {
        Log.d("UpdateInfoViewModel", "startUpgrade: ");
        try {
            d.e.b.a.b bVar = this.f2066d;
            if (bVar != null) {
                bVar.y(1);
            }
        } catch (Exception e2) {
            Log.e("UpdateInfoViewModel", "startUpgrade: ", e2);
        }
    }

    public final void M(String str) {
        f.z.d.k.e(str, "path");
        Log.d("UpdateInfoViewModel", "updateSystemByFile:" + str);
        try {
            d.e.b.a.b bVar = this.f2066d;
            if (bVar != null) {
                bVar.v(str);
            }
        } catch (RemoteException e2) {
            d.e.h.e.e.c("UpdateInfoViewModel", "updateSystemByFile: ", e2);
        }
    }

    public final void N() {
        Log.d("UpdateInfoViewModel", "updateSystemOfUsbDirect: ");
        File fileL = l();
        if (fileL == null) {
            Log.d("UpdateInfoViewModel", "updateSystemOfUsbDirect: unable direct");
            d.e.c.a.c.e(f(), R.string.system_update_check_usb_ota_not_exist);
        } else {
            String path = fileL.getPath();
            f.z.d.k.d(path, "file.path");
            M(path);
        }
    }

    @Override // androidx.lifecycle.v
    protected void d() {
        super.d();
        f().unbindService(this.f2067e);
        f().unregisterReceiver(this.f2068f);
    }

    public final q<Integer> m() {
        return this.l;
    }

    public final q<b.a> n() {
        return this.f2070h;
    }

    public final q<String> o() {
        return this.f2071i;
    }

    public final q<k<Integer, Integer>> r() {
        return this.m;
    }

    public final q<Boolean> t() {
        return this.f2072j;
    }

    public final q<Integer> u() {
        return this.n;
    }

    public final q<Integer> v() {
        return this.o;
    }

    public final q<C0053b> x() {
        return this.f2073k;
    }

    public final q<Boolean> y() {
        return this.p;
    }

    public final boolean z() {
        return this.r;
    }
}