package com.cvte.dss.ups.main;

import android.content.Context;
import android.util.Log;
import com.cvte.dss.ups.main.CountingFileRequestBody;
import com.cvte.dss.ups.plugin.IUpsPlugin;
import com.google.gson.Gson;
import com.google.gson.annotations.SerializedName;
import com.ifpdos.udi.sdk.IEventHandler;
import com.ifpdos.udi.sdk.UdiSdk;
import com.seewo.sdk.model.SDKKeyboardCode;
import d.b.a.a.a;
import g.a0;
import g.c0.g;
import g.h0.c.l;
import g.h0.c.x;
import g.k;
import g.k0.e;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.TimeUnit;
import okhttp3.MediaType;
import okhttp3.MultipartBody;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;

/* JADX INFO: compiled from: BasePlugin.kt */
/* JADX INFO: loaded from: classes.dex */
public abstract class BasePlugin implements IUpsPlugin {
    public static final Companion Companion = new Companion(null);
    public static final String TAG = "UPS-PLUGIN-DSU";
    private IEventHandler iEventHandler;
    private int retryCount;
    private Boolean runInDsu;
    private final Gson gson = new Gson();
    private final CopyOnWriteArrayList<String> upgradingList = new CopyOnWriteArrayList<>();
    private final List<String> packagesOnlyInDus = g.u("com.cvte.udi.service.core", "com.seewo.osservice");

    /* JADX INFO: compiled from: BasePlugin.kt */
    public static final class Companion {
        private Companion() {
        }

        public /* synthetic */ Companion(g.h0.c.g gVar) {
            this();
        }
    }

    /* JADX INFO: compiled from: BasePlugin.kt */
    public static final class SystemInfo {

        @SerializedName("key")
        private final String key;

        @SerializedName("model")
        private final String model;

        @SerializedName("version")
        private final String version;

        public SystemInfo() {
            this(null, null, null, 7, null);
        }

        public SystemInfo(String str, String str2, String str3) {
            l.g(str, "key");
            l.g(str2, "model");
            l.g(str3, "version");
            this.key = str;
            this.model = str2;
            this.version = str3;
        }

        public static /* synthetic */ SystemInfo copy$default(SystemInfo systemInfo, String str, String str2, String str3, int i2, Object obj) {
            if ((i2 & 1) != 0) {
                str = systemInfo.key;
            }
            if ((i2 & 2) != 0) {
                str2 = systemInfo.model;
            }
            if ((i2 & 4) != 0) {
                str3 = systemInfo.version;
            }
            return systemInfo.copy(str, str2, str3);
        }

        public final String component1() {
            return this.key;
        }

        public final String component2() {
            return this.model;
        }

        public final String component3() {
            return this.version;
        }

        public final SystemInfo copy(String str, String str2, String str3) {
            l.g(str, "key");
            l.g(str2, "model");
            l.g(str3, "version");
            return new SystemInfo(str, str2, str3);
        }

        public boolean equals(Object obj) {
            if (this == obj) {
                return true;
            }
            if (!(obj instanceof SystemInfo)) {
                return false;
            }
            SystemInfo systemInfo = (SystemInfo) obj;
            return l.a(this.key, systemInfo.key) && l.a(this.model, systemInfo.model) && l.a(this.version, systemInfo.version);
        }

        public final String getKey() {
            return this.key;
        }

        public final String getModel() {
            return this.model;
        }

        public final String getVersion() {
            return this.version;
        }

        public int hashCode() {
            String str = this.key;
            int iHashCode = (str != null ? str.hashCode() : 0) * 31;
            String str2 = this.model;
            int iHashCode2 = (iHashCode + (str2 != null ? str2.hashCode() : 0)) * 31;
            String str3 = this.version;
            return iHashCode2 + (str3 != null ? str3.hashCode() : 0);
        }

        public String toString() {
            StringBuilder sbB = a.B("SystemInfo(key=");
            sbB.append(this.key);
            sbB.append(", model=");
            sbB.append(this.model);
            sbB.append(", version=");
            return a.v(sbB, this.version, ")");
        }

        public /* synthetic */ SystemInfo(String str, String str2, String str3, int i2, g.h0.c.g gVar) {
            this((i2 & 1) != 0 ? "" : str, (i2 & 2) != 0 ? "" : str2, (i2 & 4) != 0 ? "" : str3);
        }
    }

    /* JADX INFO: compiled from: BasePlugin.kt */
    public static final class UpgradeBody {

        @SerializedName("path")
        private final String path;

        @SerializedName("rebootOnSuccess")
        private final boolean rebootOnSuccess;

        public UpgradeBody(String str, boolean z) {
            l.g(str, "path");
            this.path = str;
            this.rebootOnSuccess = z;
        }

        public static /* synthetic */ UpgradeBody copy$default(UpgradeBody upgradeBody, String str, boolean z, int i2, Object obj) {
            if ((i2 & 1) != 0) {
                str = upgradeBody.path;
            }
            if ((i2 & 2) != 0) {
                z = upgradeBody.rebootOnSuccess;
            }
            return upgradeBody.copy(str, z);
        }

        public final String component1() {
            return this.path;
        }

        public final boolean component2() {
            return this.rebootOnSuccess;
        }

        public final UpgradeBody copy(String str, boolean z) {
            l.g(str, "path");
            return new UpgradeBody(str, z);
        }

        public boolean equals(Object obj) {
            if (this != obj) {
                if (obj instanceof UpgradeBody) {
                    UpgradeBody upgradeBody = (UpgradeBody) obj;
                    if (l.a(this.path, upgradeBody.path)) {
                        if (this.rebootOnSuccess == upgradeBody.rebootOnSuccess) {
                        }
                    }
                }
                return false;
            }
            return true;
        }

        public final String getPath() {
            return this.path;
        }

        public final boolean getRebootOnSuccess() {
            return this.rebootOnSuccess;
        }

        /* JADX WARN: Multi-variable type inference failed */
        /* JADX WARN: Type inference failed for: r1v1, types: [int] */
        /* JADX WARN: Type inference failed for: r1v2 */
        /* JADX WARN: Type inference failed for: r1v3 */
        public int hashCode() {
            String str = this.path;
            int iHashCode = (str != null ? str.hashCode() : 0) * 31;
            boolean z = this.rebootOnSuccess;
            ?? r1 = z;
            if (z) {
                r1 = 1;
            }
            return iHashCode + r1;
        }

        public String toString() {
            StringBuilder sbB = a.B("UpgradeBody(path=");
            sbB.append(this.path);
            sbB.append(", rebootOnSuccess=");
            sbB.append(this.rebootOnSuccess);
            sbB.append(")");
            return sbB.toString();
        }
    }

    /* JADX INFO: compiled from: BasePlugin.kt */
    public static final class UpgradeResultNotify {

        @SerializedName("error")
        private final boolean error;

        @SerializedName("message")
        private final String message;

        public UpgradeResultNotify(boolean z, String str) {
            l.g(str, "message");
            this.error = z;
            this.message = str;
        }

        public static /* synthetic */ UpgradeResultNotify copy$default(UpgradeResultNotify upgradeResultNotify, boolean z, String str, int i2, Object obj) {
            if ((i2 & 1) != 0) {
                z = upgradeResultNotify.error;
            }
            if ((i2 & 2) != 0) {
                str = upgradeResultNotify.message;
            }
            return upgradeResultNotify.copy(z, str);
        }

        public final boolean component1() {
            return this.error;
        }

        public final String component2() {
            return this.message;
        }

        public final UpgradeResultNotify copy(boolean z, String str) {
            l.g(str, "message");
            return new UpgradeResultNotify(z, str);
        }

        public boolean equals(Object obj) {
            if (this != obj) {
                if (obj instanceof UpgradeResultNotify) {
                    UpgradeResultNotify upgradeResultNotify = (UpgradeResultNotify) obj;
                    if (!(this.error == upgradeResultNotify.error) || !l.a(this.message, upgradeResultNotify.message)) {
                    }
                }
                return false;
            }
            return true;
        }

        public final boolean getError() {
            return this.error;
        }

        public final String getMessage() {
            return this.message;
        }

        /* JADX WARN: Multi-variable type inference failed */
        /* JADX WARN: Type inference failed for: r0v1, types: [int] */
        /* JADX WARN: Type inference failed for: r0v4 */
        /* JADX WARN: Type inference failed for: r0v5 */
        public int hashCode() {
            boolean z = this.error;
            ?? r0 = z;
            if (z) {
                r0 = 1;
            }
            int i2 = r0 * 31;
            String str = this.message;
            return i2 + (str != null ? str.hashCode() : 0);
        }

        public String toString() {
            StringBuilder sbB = a.B("UpgradeResultNotify(error=");
            sbB.append(this.error);
            sbB.append(", message=");
            return a.v(sbB, this.message, ")");
        }

        public /* synthetic */ UpgradeResultNotify(boolean z, String str, int i2, g.h0.c.g gVar) {
            this(z, (i2 & 2) != 0 ? "" : str);
        }
    }

    /* JADX INFO: compiled from: BasePlugin.kt */
    public static final class UpgradeStatusNotify {

        @SerializedName("progress")
        private final float progress;

        public UpgradeStatusNotify(float f2) {
            this.progress = f2;
        }

        public static /* synthetic */ UpgradeStatusNotify copy$default(UpgradeStatusNotify upgradeStatusNotify, float f2, int i2, Object obj) {
            if ((i2 & 1) != 0) {
                f2 = upgradeStatusNotify.progress;
            }
            return upgradeStatusNotify.copy(f2);
        }

        public final float component1() {
            return this.progress;
        }

        public final UpgradeStatusNotify copy(float f2) {
            return new UpgradeStatusNotify(f2);
        }

        public boolean equals(Object obj) {
            if (this != obj) {
                return (obj instanceof UpgradeStatusNotify) && Float.compare(this.progress, ((UpgradeStatusNotify) obj).progress) == 0;
            }
            return true;
        }

        public final float getProgress() {
            return this.progress;
        }

        public int hashCode() {
            return Float.hashCode(this.progress);
        }

        public String toString() {
            StringBuilder sbB = a.B("UpgradeStatusNotify(progress=");
            sbB.append(this.progress);
            sbB.append(")");
            return sbB.toString();
        }
    }

    private final boolean doUpgradeFirmware(String str, final String str2, final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) throws IOException {
        final Map mapV = g.v(new k(getOtaUpgradeStatusNotify(), new BasePlugin$doUpgradeFirmware$eventHandler$1(this)), new k(getOtaUpgradeResultNotify(), new BasePlugin$doUpgradeFirmware$eventHandler$2(this)));
        if (this.iEventHandler == null) {
            this.iEventHandler = new IEventHandler() { // from class: com.cvte.dss.ups.main.BasePlugin.doUpgradeFirmware.1
                @Override // com.ifpdos.udi.sdk.IEventHandler
                public final void onEvent(String str3, String str4) {
                    e eVar;
                    a.O("receive new event: ", str3, BasePlugin.TAG);
                    if (mapV.containsKey(str3) && (eVar = (e) mapV.get(str3)) != null) {
                    }
                }
            };
        }
        UdiSdk.registerEvents((Set<String>) mapV.keySet(), this.iEventHandler);
        String json = this.gson.toJson(new UpgradeBody(str, l.a(this.runInDsu, Boolean.TRUE) ? false : getReboot()));
        OkHttpClient.Builder builderNewOkHttpClientBuilder = UdiSdk.newOkHttpClientBuilder();
        TimeUnit timeUnit = TimeUnit.MINUTES;
        OkHttpClient okHttpClientBuild = builderNewOkHttpClientBuilder.connectTimeout(3L, timeUnit).readTimeout(3L, timeUnit).retryOnConnectionFailure(true).build();
        Request.Builder builderUrl = new Request.Builder().url(getOtaUpgradeUrl());
        RequestBody.Companion companion = RequestBody.Companion;
        l.b(json, "body");
        Response responseExecute = okHttpClientBuild.newCall(builderUrl.post(companion.create(json, MediaType.Companion.get("application/json;charset=utf-8"))).build()).execute();
        try {
            Log.i(TAG, "udi ota upgrade request: " + responseExecute);
            if (!responseExecute.isSuccessful()) {
                UdiSdk.unregisterEvents(this.iEventHandler);
            }
            boolean zIsSuccessful = responseExecute.isSuccessful();
            f.a.y.a.B(responseExecute, null);
            return zIsSuccessful;
        } finally {
        }
    }

    private final String getFileUploadToken() throws IOException {
        Request requestBuild = new Request.Builder().url("http://192.168.153.253:8455/token").header("Connection", "close").build();
        OkHttpClient.Builder builder = new OkHttpClient.Builder();
        TimeUnit timeUnit = TimeUnit.MINUTES;
        OkHttpClient.Builder timeout = builder.connectTimeout(3L, timeUnit).readTimeout(3L, timeUnit);
        boolean z = true;
        Response responseExecute = timeout.retryOnConnectionFailure(true).build().newCall(requestBuild).execute();
        try {
            Log.i(TAG, "http token get request: " + responseExecute);
            if (!responseExecute.isSuccessful()) {
                f.a.y.a.B(responseExecute, null);
                return "";
            }
            ResponseBody responseBodyBody = responseExecute.body();
            String strString = responseBodyBody != null ? responseBodyBody.string() : null;
            if (strString != null) {
                if (strString.length() != 0) {
                    z = false;
                }
            }
            if (z) {
                f.a.y.a.B(responseExecute, null);
                return "";
            }
            f.a.y.a.B(responseExecute, null);
            return strString;
        } finally {
        }
    }

    private final String getMd5OfFile(File file) throws IOException {
        FileInputStream fileInputStream = new FileInputStream(file);
        try {
            MessageDigest messageDigest = MessageDigest.getInstance("MD5");
            byte[] bArr = new byte[1024];
            for (int i2 = fileInputStream.read(bArr, 0, 1024); i2 > -1; i2 = fileInputStream.read(bArr, 0, 1024)) {
                messageDigest.update(bArr, 0, i2);
            }
            byte[] bArrDigest = messageDigest.digest();
            char[] cArr = k.a.a.a.b.a.a;
            char[] cArr2 = k.a.a.a.b.a.a;
            int length = bArrDigest.length;
            char[] cArr3 = new char[length << 1];
            int i3 = 0;
            for (int i4 = 0; i4 < length; i4++) {
                int i5 = i3 + 1;
                cArr3[i3] = cArr2[(bArrDigest[i4] & 240) >>> 4];
                i3 = i5 + 1;
                cArr3[i5] = cArr2[bArrDigest[i4] & SDKKeyboardCode.FUNCTION_KEY_BOARD_L];
            }
            String str = new String(cArr3);
            l.b(str, "DigestUtils.md5Hex(inputStream)");
            return str;
        } catch (NoSuchAlgorithmException e2) {
            throw new IllegalArgumentException(e2);
        }
    }

    private final boolean isAppInstalled(Context context, String str) {
        try {
            context.getPackageManager().getApplicationEnabledSetting(str);
            return true;
        } catch (IllegalArgumentException unused) {
            return false;
        }
    }

    private final boolean isRunningInDsu(Context context) {
        List<String> list = this.packagesOnlyInDus;
        if ((list instanceof Collection) && list.isEmpty()) {
            return false;
        }
        Iterator<T> it = list.iterator();
        while (it.hasNext()) {
            if (isAppInstalled(context, (String) it.next())) {
                return true;
            }
        }
        return false;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final float normalizeProgress(float f2, float f3, float f4, float f5, float f6) {
        if (f2 < f3) {
            return f5;
        }
        if (f2 > f4) {
            return f6;
        }
        return (((f2 - f3) * (f6 - f5)) / (f4 - f3)) + f5;
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void onFailure(String str, String str2, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        Log.e(TAG, "id " + str + " upgrade fail,reason:" + str2);
        this.upgradingList.remove(str);
        iUpgradeStatusListener.onFailed(str2);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void onNewResultEvent(String str, final String str2, final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        if (str != null) {
            UdiSdk.unregisterEvents(this.iEventHandler);
            UpgradeResultNotify upgradeResultNotify = (UpgradeResultNotify) this.gson.fromJson(str, UpgradeResultNotify.class);
            StringBuilder sbB = a.B("udi upgrade ");
            sbB.append(getName());
            sbB.append(" result: ");
            sbB.append(upgradeResultNotify);
            Log.i(TAG, sbB.toString());
            if (upgradeResultNotify.getError()) {
                onFailure(str2, upgradeResultNotify.getMessage(), iUpgradeStatusListener);
            } else {
                if (!l.a(Boolean.TRUE, this.runInDsu)) {
                    new Thread(new Runnable() { // from class: com.cvte.dss.ups.main.BasePlugin.onNewResultEvent.1
                        @Override // java.lang.Runnable
                        public final void run() throws InterruptedException {
                            int i2;
                            if (BasePlugin.this.getReboot()) {
                                Thread.sleep(30000L);
                                i2 = 36;
                            } else {
                                i2 = 5;
                            }
                            int i3 = 0;
                            while (true) {
                                IUpsPlugin.FirmwareInfo firmwareInfo = BasePlugin.this.getFirmwareInfo();
                                if ((firmwareInfo != null ? firmwareInfo.getVersion() : null) != null) {
                                    BasePlugin.this.upgradingList.remove(str2);
                                    iUpgradeStatusListener.onProcess(1.0f);
                                    iUpgradeStatusListener.onComplete();
                                    return;
                                }
                                Log.d(BasePlugin.TAG, "version null,retry :" + i3);
                                Thread.sleep(5000L);
                                int i4 = i3 + 1;
                                if (i3 >= i2) {
                                    BasePlugin.this.onFailure(str2, "can't get version after upgrade", iUpgradeStatusListener);
                                    return;
                                }
                                i3 = i4;
                            }
                        }
                    }).start();
                    return;
                }
                this.upgradingList.remove(str2);
                iUpgradeStatusListener.onProcess(1.0f);
                iUpgradeStatusListener.onComplete();
            }
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void onNewStatusEvent(String str, String str2, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        if (str != null) {
            UpgradeStatusNotify upgradeStatusNotify = (UpgradeStatusNotify) this.gson.fromJson(str, UpgradeStatusNotify.class);
            float f2 = 0.5f;
            if (l.a(Boolean.TRUE, this.runInDsu)) {
                f2 = 0.0f;
            } else {
                int i2 = this.retryCount;
                if (i2 != 0) {
                    f2 = 0.5f + (i2 * 0.01f);
                }
            }
            float fNormalizeProgress = normalizeProgress(upgradeStatusNotify.getProgress(), 0.0f, 1.0f, f2, 0.9f);
            Log.i(TAG, "on progress: " + fNormalizeProgress);
            iUpgradeStatusListener.onProcess(fNormalizeProgress);
        }
    }

    /* JADX WARN: Multi-variable type inference failed */
    private final String uploadFile(String str, final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) throws InterruptedException, IOException {
        Response responseExecute;
        int i2;
        this.retryCount = 0;
        do {
            String fileUploadToken = getFileUploadToken();
            int i3 = 1;
            if ((fileUploadToken.length() == 0) == true) {
                Log.e(TAG, "fail to get file upload token");
            } else {
                File file = new File(str);
                if (!file.exists()) {
                    Log.e(TAG, "file not exists: " + str);
                    return "";
                }
                final x xVar = new x();
                xVar.f4110b = 0.0f;
                float f2 = (this.retryCount * 0.01f) + 0.5f;
                MultipartBody multipartBodyBuild = new MultipartBody.Builder(null, i3, 0 == true ? 1 : 0).setType(MultipartBody.FORM).addFormDataPart("file", file.getName(), new CountingFileRequestBody(file, "application/octet-stream", new CountingFileRequestBody.ProgressListener() { // from class: com.cvte.dss.ups.main.BasePlugin$uploadFile$fileRequestBody$1
                    @Override // com.cvte.dss.ups.main.CountingFileRequestBody.ProgressListener
                    public final void transferred(float f3) {
                        float fNormalizeProgress = this.this$0.normalizeProgress(f3, 0.0f, 100.0f, 0.0f, 0.5f);
                        if (fNormalizeProgress - xVar.f4110b >= 0.1f) {
                            Log.i(BasePlugin.TAG, "upload progress: " + f3 + ", " + fNormalizeProgress);
                            if (this.this$0.retryCount == 0) {
                                iUpgradeStatusListener.onProcess(fNormalizeProgress);
                            }
                            xVar.f4110b = fNormalizeProgress;
                        }
                    }
                })).build();
                String md5OfFile = getMd5OfFile(file);
                StringBuilder sbB = a.B("upload file: ");
                sbB.append(file.getName());
                sbB.append(", md5: ");
                sbB.append(md5OfFile);
                sbB.append(", token: ");
                sbB.append(fileUploadToken);
                sbB.append("，retryCount: ");
                sbB.append(this.retryCount);
                Log.i(TAG, sbB.toString());
                Request requestBuild = new Request.Builder().url("http://192.168.153.253:8455/upload").header("token", fileUploadToken).header("md5", md5OfFile).header("Connection", "close").post(multipartBodyBuild).build();
                OkHttpClient.Builder builder = new OkHttpClient.Builder();
                TimeUnit timeUnit = TimeUnit.MINUTES;
                try {
                    responseExecute = builder.connectTimeout(3L, timeUnit).readTimeout(3L, timeUnit).retryOnConnectionFailure(true).build().newCall(requestBuild).execute();
                    try {
                        Log.i(TAG, "http upload request: " + responseExecute);
                    } finally {
                    }
                } catch (Exception e2) {
                    StringBuilder sb = new StringBuilder();
                    sb.append("Error");
                    e2.printStackTrace();
                    sb.append(a0.a);
                    Log.e(TAG, sb.toString());
                    iUpgradeStatusListener.onProcess(f2);
                }
                if (responseExecute.isSuccessful()) {
                    iUpgradeStatusListener.onProcess(f2);
                    String str2 = "/data/monitor/" + fileUploadToken;
                    f.a.y.a.B(responseExecute, null);
                    return str2;
                }
                iUpgradeStatusListener.onProcess(f2);
                f.a.y.a.B(responseExecute, null);
                Thread.sleep(5000L);
                StringBuilder sb2 = new StringBuilder();
                sb2.append("Error");
                e2.printStackTrace();
                sb2.append(a0.a);
                Log.e(TAG, sb2.toString());
                iUpgradeStatusListener.onProcess(f2);
                Thread.sleep(5000L);
            }
            i2 = this.retryCount;
            this.retryCount = i2 + 1;
        } while (i2 < 2);
        return "";
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public IUpsPlugin.FirmwareInfo getFirmwareInfo(Context context) {
        l.g(context, "context");
        return getFirmwareInfo();
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public List<IUpsPlugin.FirmwareInfo> getFirmwareInfos(Context context) {
        l.g(context, "context");
        return IUpsPlugin.DefaultImpls.getFirmwareInfos(this, context);
    }

    public final Gson getGson() {
        return this.gson;
    }

    public abstract boolean getMonopolize();

    public abstract String getName();

    public abstract String getOtaInformationUrl();

    public abstract String getOtaUpgradeResultNotify();

    public abstract String getOtaUpgradeStatusNotify();

    public abstract String getOtaUpgradeUrl();

    public abstract boolean getReboot();

    public abstract String getType();

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String str, boolean z, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        String id;
        l.g(context, "context");
        l.g(str, "path");
        l.g(iUpgradeStatusListener, "listener");
        IUpsPlugin.FirmwareInfo firmwareInfo = getFirmwareInfo();
        if (firmwareInfo == null || (id = firmwareInfo.getId()) == null) {
            return false;
        }
        return upgradeFirmware(context, id, str, z, iUpgradeStatusListener);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final IUpsPlugin.FirmwareInfo getFirmwareInfo() {
        SystemInfo systemInfo;
        try {
            Response responseExecute = UdiSdk.newOkHttpClientBuilder().build().newCall(new Request.Builder().url(getOtaInformationUrl()).build()).execute();
            try {
                if (responseExecute.isSuccessful()) {
                    ResponseBody responseBodyBody = responseExecute.body();
                    systemInfo = (SystemInfo) this.gson.fromJson(responseBodyBody != null ? responseBodyBody.string() : null, SystemInfo.class);
                } else {
                    systemInfo = new SystemInfo(null, null, null, 7, null);
                }
                Log.i(TAG, "udi ota information request: " + systemInfo + ", " + responseExecute);
                if (systemInfo.getKey().length() == 0) {
                    f.a.y.a.B(responseExecute, null);
                    return null;
                }
                IUpsPlugin.FirmwareInfo firmwareInfo = new IUpsPlugin.FirmwareInfo(getName(), systemInfo.getModel(), getType(), systemInfo.getVersion(), systemInfo.getKey(), getReboot(), getMonopolize(), systemInfo.getKey());
                f.a.y.a.B(responseExecute, null);
                return firmwareInfo;
            } finally {
            }
        } catch (Exception e2) {
            StringBuilder sb = new StringBuilder();
            sb.append("getFirmwareInfo");
            e2.printStackTrace();
            sb.append(a0.a);
            Log.e(TAG, sb.toString());
            return null;
        }
        StringBuilder sb2 = new StringBuilder();
        sb2.append("getFirmwareInfo");
        e2.printStackTrace();
        sb2.append(a0.a);
        Log.e(TAG, sb2.toString());
        return null;
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String str, String str2, boolean z, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) throws InterruptedException, IOException {
        Object next;
        l.g(context, "context");
        l.g(str, "id");
        l.g(str2, "path");
        l.g(iUpgradeStatusListener, "listener");
        Iterator<T> it = getFirmwareInfos(context).iterator();
        while (true) {
            if (!it.hasNext()) {
                next = null;
                break;
            }
            next = it.next();
            if (l.a(((IUpsPlugin.FirmwareInfo) next).getId(), str)) {
                break;
            }
        }
        if (((IUpsPlugin.FirmwareInfo) next) == null) {
            return false;
        }
        if (this.upgradingList.contains(str)) {
            Log.e(TAG, "Plugin Busy");
            return false;
        }
        if (this.runInDsu == null) {
            this.runInDsu = Boolean.valueOf(isRunningInDsu(context));
        }
        this.upgradingList.add(str);
        if (l.a(Boolean.TRUE, this.runInDsu)) {
            Log.i(TAG, "run in dsu, do not need upload");
        } else {
            str2 = uploadFile(str2, iUpgradeStatusListener);
        }
        if (str2.length() == 0) {
            onFailure(str, "fail to upload firmware", iUpgradeStatusListener);
            return false;
        }
        if (doUpgradeFirmware(str2, str, iUpgradeStatusListener)) {
            return true;
        }
        onFailure(str, "fail to upgrade firmware", iUpgradeStatusListener);
        return false;
    }
}