package com.seewo.ota.update.device.model.vman;

import android.content.Context;
import android.os.Build;
import android.util.Log;
import com.google.gson.reflect.TypeToken;
import com.seewo.ota.data.a;
import com.seewo.ota.v.s.s.h0;
import com.seewo.ota.v.s.s.q0;
import f.e;
import f.g;
import f.i;
import f.t;
import f.w.d;
import f.w.k.a.f;
import f.w.k.a.k;
import f.z.c.p;
import g.a.i0;
import g.a.x0;
import java.io.File;
import java.util.ArrayList;
import java.util.List;

/* JADX INFO: compiled from: BaseVmanUpdateTask.kt */
/* JADX INFO: loaded from: classes.dex */
@i
public abstract class BaseVmanUpdateTask<T> extends h0 implements g.a.h0 {
    private final /* synthetic */ g.a.h0 $$delegate_0;
    private final TypeToken<T> typeOfTypeToken;
    private final e waitUpgradeQueue$delegate;

    /* JADX INFO: renamed from: com.seewo.ota.update.device.model.vman.BaseVmanUpdateTask$run$1, reason: invalid class name */
    /* JADX INFO: compiled from: BaseVmanUpdateTask.kt */
    @i
    @f(c = "com.seewo.ota.update.device.model.vman.BaseVmanUpdateTask$run$1", f = "BaseVmanUpdateTask.kt", l = {68}, m = "invokeSuspend")
    static final class AnonymousClass1 extends k implements p<g.a.h0, d<? super t>, Object> {
        private /* synthetic */ Object L$0;
        Object L$1;
        Object L$2;
        Object L$3;
        Object L$4;
        boolean Z$0;
        int label;
        final /* synthetic */ BaseVmanUpdateTask<T> this$0;

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        AnonymousClass1(BaseVmanUpdateTask<T> baseVmanUpdateTask, d<? super AnonymousClass1> dVar) {
            super(2, dVar);
            this.this$0 = baseVmanUpdateTask;
        }

        @Override // f.w.k.a.a
        public final d<t> create(Object obj, d<?> dVar) {
            AnonymousClass1 anonymousClass1 = new AnonymousClass1(this.this$0, dVar);
            anonymousClass1.L$0 = obj;
            return anonymousClass1;
        }

        @Override // f.z.c.p
        public final Object invoke(g.a.h0 h0Var, d<? super t> dVar) {
            return ((AnonymousClass1) create(h0Var, dVar)).invokeSuspend(t.a);
        }

        /* JADX WARN: Multi-variable type inference failed */
        /* JADX WARN: Path cross not found for [B:30:0x00f5, B:33:0x00fa], limit reached: 35 */
        /* JADX WARN: Removed duplicated region for block: B:15:0x0086  */
        /* JADX WARN: Removed duplicated region for block: B:21:0x00e3  */
        /* JADX WARN: Removed duplicated region for block: B:35:0x00ff  */
        /* JADX WARN: Unsupported multi-entry loop pattern (BACK_EDGE: B:18:0x00b5 -> B:19:0x00bb). Please report as a decompilation issue!!! */
        @Override // f.w.k.a.a
        /*
            Code decompiled incorrectly, please refer to instructions dump.
            To view partially-correct add '--show-bad-code' argument
        */
        public final java.lang.Object invokeSuspend(java.lang.Object r20) throws java.lang.Throwable {
            /*
                Method dump skipped, instruction units count: 271
                To view this dump add '--comments-level debug' option
            */
            throw new UnsupportedOperationException("Method not decompiled: com.seewo.ota.update.device.model.vman.BaseVmanUpdateTask.AnonymousClass1.invokeSuspend(java.lang.Object):java.lang.Object");
        }
    }

    /* JADX WARN: 'this' call moved to the top of the method (can break code semantics) */
    public BaseVmanUpdateTask(Context context, TypeToken<T> typeToken) {
        this(context, typeToken, null, 4, null);
        f.z.d.k.e(context, "context");
        f.z.d.k.e(typeToken, "typeOfTypeToken");
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    public BaseVmanUpdateTask(Context context, TypeToken<T> typeToken, q0 q0Var) {
        super(context, q0Var);
        f.z.d.k.e(context, "context");
        f.z.d.k.e(typeToken, "typeOfTypeToken");
        this.typeOfTypeToken = typeToken;
        this.$$delegate_0 = i0.a(x0.b());
        this.waitUpgradeQueue$delegate = g.a(new BaseVmanUpdateTask$waitUpgradeQueue$2(this));
    }

    private final TypeToken<List<T>> getListTypeToken() {
        TypeToken<List<T>> typeToken = (TypeToken<List<T>>) TypeToken.getParameterized(List.class, this.typeOfTypeToken.getType());
        if (typeToken != null) {
            return typeToken;
        }
        throw new NullPointerException("null cannot be cast to non-null type com.google.gson.reflect.TypeToken<kotlin.collections.List<T of com.seewo.ota.update.device.model.vman.BaseVmanUpdateTask>>");
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final List<T> getWaitUpgradeQueue() {
        return (List) this.waitUpgradeQueue$delegate.getValue();
    }

    public abstract void checkVersion(List<T> list);

    public final boolean checkVersions() {
        if (!getWaitUpgradeQueue().isEmpty()) {
            Log.d(getName(), "checkVersions: waitUpgradeQueue is empty, last upgrade not finished.");
            return true;
        }
        checkVersion(getWaitUpgradeQueue());
        List<T> waitUpgradeQueue = getWaitUpgradeQueue();
        saveWaitUpgradeQueue();
        return !waitUpgradeQueue.isEmpty();
    }

    public void clearWaitUpgradeQueue() {
        a.g().c(getName());
        getWaitUpgradeQueue().clear();
    }

    public final boolean fileExists(String str) {
        f.z.d.k.e(str, "<this>");
        boolean zExists = new File(str).exists();
        d.e.h.e.e.a("fileExists", "fileExists: " + str + ", " + zExists);
        return zExists;
    }

    @Override // com.seewo.ota.v.s.s.r0
    public /* bridge */ /* synthetic */ String getBeforeUpdateTip() {
        return super.getBeforeUpdateTip();
    }

    @Override // g.a.h0
    public f.w.g getCoroutineContext() {
        return this.$$delegate_0.getCoroutineContext();
    }

    @Override // com.seewo.ota.v.s.s.r0
    public String getName() {
        String simpleName = getClass().getSimpleName();
        f.z.d.k.d(simpleName, "javaClass.simpleName");
        return simpleName;
    }

    @Override // com.seewo.ota.v.s.s.r0
    public abstract /* synthetic */ String getUpdateTip();

    @Override // com.seewo.ota.v.s.s.r0
    public /* bridge */ /* synthetic */ String isInExceptionalState() {
        return super.isInExceptionalState();
    }

    @Override // com.seewo.ota.v.s.s.r0
    public boolean isNeedRun() {
        if (Build.VERSION.SDK_INT < 34) {
            Log.d(getName(), "isNeedRun: platform not support.");
            return false;
        }
        if (!isSupportOtaUpgrade()) {
            Log.d(getName(), "isNeedRun: not support ota upgrade.");
            return false;
        }
        boolean zCheckVersions = checkVersions();
        Log.d(getName(), "isNeedRun: versionsMismatch=" + zCheckVersions);
        return zCheckVersions;
    }

    public abstract boolean isSupportOtaUpgrade();

    public abstract boolean needReboot(T t);

    public List<T> restoreWaitUpgradeQueue() {
        List<T> listU = a.g().u(getName(), getListTypeToken().getType());
        return listU == null ? new ArrayList() : listU;
    }

    @Override // com.seewo.ota.v.s.s.r0
    public void run() {
        Log.i(getName(), "run: ");
        if (!getWaitUpgradeQueue().isEmpty()) {
            g.a.g.d(this, null, null, new AnonymousClass1(this, null), 3, null);
        } else {
            Log.d(getName(), "run: waitUpgradeQueue is empty");
            onUpdateCallback(false);
        }
    }

    public void saveWaitUpgradeQueue() {
        a.g().V(getName(), getWaitUpgradeQueue());
    }

    public abstract Object upgrade(T t, d<? super Boolean> dVar);

    public /* synthetic */ BaseVmanUpdateTask(Context context, TypeToken typeToken, q0 q0Var, int i2, f.z.d.g gVar) {
        this(context, typeToken, (i2 & 4) != 0 ? null : q0Var);
    }
}