package com.cvte.dss.ups.dth_typc;

import android.content.Context;
import android.text.TextUtils;
import android.util.Log;
import com.cvte.dss.ups.dth_typc.UploadProgressBody;
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 d.b.a.a.a;
import f.a.i;
import f.a.j;
import f.a.k;
import f.a.w.e.d.c;
import g.h0.c.a0;
import g.h0.c.g;
import g.h0.c.l;
import java.io.File;
import java.util.List;
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: UpgradeManager.kt */
/* JADX INFO: loaded from: classes.dex */
public final class UpgradeManager {
    public static final UpgradeManager INSTANCE = new UpgradeManager();
    private static final float MAX_PROGRESS = 0.95f;
    private static final String TAG = "UpgradeManager";
    private static final String UPGRADE_ERR = "upgrade fail";
    private static OkHttpClient httpClient;
    private static IUpsPlugin.IUpgradeStatusListener progressListener;
    private static OkHttpClient udiClient;

    /* JADX INFO: compiled from: UpgradeManager.kt */
    public static final class OTAData {

        @SerializedName("progress")
        private float progress;

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

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

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

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

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

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

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

        public final void setProgress(float f2) {
            this.progress = f2;
        }

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

    /* JADX INFO: compiled from: UpgradeManager.kt */
    public static final class RetimerInfo {

        @SerializedName("key")
        private String key;

        @SerializedName("model")
        private String model;

        @SerializedName("version")
        private String version;

        public RetimerInfo(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 */ RetimerInfo copy$default(RetimerInfo retimerInfo, String str, String str2, String str3, int i2, Object obj) {
            if ((i2 & 1) != 0) {
                str = retimerInfo.key;
            }
            if ((i2 & 2) != 0) {
                str2 = retimerInfo.model;
            }
            if ((i2 & 4) != 0) {
                str3 = retimerInfo.version;
            }
            return retimerInfo.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 RetimerInfo copy(String str, String str2, String str3) {
            l.g(str, "key");
            l.g(str2, "model");
            l.g(str3, "version");
            return new RetimerInfo(str, str2, str3);
        }

        public boolean equals(Object obj) {
            if (this == obj) {
                return true;
            }
            if (!(obj instanceof RetimerInfo)) {
                return false;
            }
            RetimerInfo retimerInfo = (RetimerInfo) obj;
            return l.a(this.key, retimerInfo.key) && l.a(this.model, retimerInfo.model) && l.a(this.version, retimerInfo.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 final void setKey(String str) {
            l.g(str, "<set-?>");
            this.key = str;
        }

        public final void setModel(String str) {
            l.g(str, "<set-?>");
            this.model = str;
        }

        public final void setVersion(String str) {
            l.g(str, "<set-?>");
            this.version = str;
        }

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

    /* JADX INFO: compiled from: UpgradeManager.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 gVar) {
            this(z, (i2 & 2) != 0 ? "" : str);
        }
    }

    private UpgradeManager() {
    }

    public static final /* synthetic */ OkHttpClient access$getHttpClient$p(UpgradeManager upgradeManager) {
        OkHttpClient okHttpClient = httpClient;
        if (okHttpClient != null) {
            return okHttpClient;
        }
        l.m("httpClient");
        throw null;
    }

    public static final /* synthetic */ IUpsPlugin.IUpgradeStatusListener access$getProgressListener$p(UpgradeManager upgradeManager) {
        IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener = progressListener;
        if (iUpgradeStatusListener != null) {
            return iUpgradeStatusListener;
        }
        l.m("progressListener");
        throw null;
    }

    private final void addUpgradeProgressListener() {
        final Gson gson = new Gson();
        UdiSdk.registerEvents((List<String>) g.c0.g.u("v1/device/dth_typec/ota/upgrade/result", "v1/device/dth_typec/ota/upgrade/status"), new IEventHandler() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.addUpgradeProgressListener.1
            @Override // com.ifpdos.udi.sdk.IEventHandler
            public final void onEvent(String str, String str2) {
                if (l.a("v1/device/dth_typec/ota/upgrade/status", str)) {
                    UpgradeManager.INSTANCE.upgradeProgress(str2, gson);
                }
                if (l.a("v1/device/dth_typec/ota/upgrade/result", str)) {
                    UpgradeManager upgradeManager = UpgradeManager.INSTANCE;
                    l.b(str2, "data");
                    upgradeManager.upgradeResult(str2, gson);
                }
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void startUpgradeByUdi(final String str, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        new c(new k<Boolean>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUpgradeByUdi.1
            @Override // f.a.k
            public final void subscribe(j<Boolean> jVar) {
                l.g(jVar, "it");
                StringBuilder sb = new StringBuilder();
                sb.append("{\"path\": \"data/monitor/");
                c.a aVar = (c.a) jVar;
                aVar.d(Boolean.valueOf(UpgradeManager.INSTANCE.startUpgradeRequest(a.v(sb, str, "\" }"))));
            }
        }).w(f.a.z.a.f4044c).n(f.a.s.b.a.a()).t(new f.a.v.c<Boolean>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUpgradeByUdi.2
            @Override // f.a.v.c
            public final void accept(Boolean bool) {
                Log.i(UpgradeManager.TAG, "startOTA finish: " + bool);
            }
        }, new f.a.v.c<Throwable>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUpgradeByUdi.3
            @Override // f.a.v.c
            public final void accept(Throwable th) {
                Log.i(UpgradeManager.TAG, "startOTA err", th);
            }
        });
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final boolean startUpgradeRequest(String str) {
        try {
            Response responseExecute = UdiSdk.newOkHttpClientBuilder().readTimeout(1L, TimeUnit.MINUTES).build().newCall(new Request.Builder().url(UdiSdk.getFullUrl("/v1/device/dth_typec/ota/upgrade")).post(RequestBody.create(MediaType.parse("application/json;charset=utf-8"), str)).build()).execute();
            if (responseExecute.code() != 200) {
                IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener = progressListener;
                if (iUpgradeStatusListener == null) {
                    l.m("progressListener");
                    throw null;
                }
                iUpgradeStatusListener.onFailed(UPGRADE_ERR);
            }
            return responseExecute.code() == 200;
        } catch (Exception unused) {
            IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener2 = progressListener;
            if (iUpgradeStatusListener2 != null) {
                iUpgradeStatusListener2.onFailed(UPGRADE_ERR);
                return false;
            }
            l.m("progressListener");
            throw null;
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    /* JADX WARN: Type inference failed for: r7v1, types: [T, java.lang.String] */
    /* JADX WARN: Type inference failed for: r7v6, types: [T, okhttp3.MultipartBody] */
    public final void startUploadFile(final String str, String str2, final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        File file = new File(str2);
        if (!file.exists() || !file.isFile()) {
            iUpgradeStatusListener.onFailed("no find file");
            return;
        }
        final a0 a0Var = new a0();
        a0Var.f4099b = MessageDigestUtils.getMd5(new File(str2));
        RequestBody requestBodyCreate = RequestBody.create(MediaType.parse("application/octet-stream"), file);
        final a0 a0Var2 = new a0();
        a0Var2.f4099b = new MultipartBody.Builder().setType(MultipartBody.FORM).addFormDataPart("file", file.getName(), requestBodyCreate).build();
        new c(new k<Boolean>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUploadFile.1
            @Override // f.a.k
            public final void subscribe(j<Boolean> jVar) {
                l.g(jVar, "it");
                ((c.a) jVar).d(Boolean.valueOf(UpgradeManager.INSTANCE.uploadFileReal(str, (String) a0Var.f4099b, (MultipartBody) a0Var2.f4099b)));
            }
        }).w(f.a.z.a.f4044c).n(f.a.s.b.a.a()).u(new f.a.v.c<Boolean>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUploadFile.2
            @Override // f.a.v.c
            public final void accept(Boolean bool) {
                l.b(bool, "it");
                if (bool.booleanValue()) {
                    UpgradeManager.INSTANCE.startUpgradeByUdi(str, iUpgradeStatusListener);
                } else {
                    iUpgradeStatusListener.onFailed("upgrade err");
                }
            }
        }, new f.a.v.c<Throwable>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.startUploadFile.3
            @Override // f.a.v.c
            public final void accept(Throwable th) {
                Log.i(UpgradeManager.TAG, "startUpLoad:err " + th);
            }
        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
    }

    private final void udiInit(Context context) {
        UdiSdk.init(context, "xZLhe1TbN4veM3On0bwZ7a0MoHkdQKLrJUgk4mCxpIiI4HGLLVQX6gn2SvA=");
        OkHttpClient okHttpClientBuild = UdiSdk.newOkHttpClientBuilder().build();
        l.b(okHttpClientBuild, "UdiSdk.newOkHttpClientBuilder().build()");
        udiClient = okHttpClientBuild;
    }

    private final void upgradeFor3399(final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener, final String str, Context context) {
        i.h(new k<String>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.upgradeFor3399.1
            @Override // f.a.k
            public final void subscribe(j<String> jVar) {
                l.g(jVar, "it");
                Request requestBuild = new Request.Builder().url("http://192.168.153.253:8455/token").build();
                UpgradeManager upgradeManager = UpgradeManager.INSTANCE;
                OkHttpClient.Builder builder = new OkHttpClient.Builder();
                TimeUnit timeUnit = TimeUnit.SECONDS;
                OkHttpClient okHttpClientBuild = builder.connectTimeout(60L, timeUnit).readTimeout(60L, timeUnit).build();
                l.b(okHttpClientBuild, "OkHttpClient.Builder().c…TimeUnit.SECONDS).build()");
                UpgradeManager.httpClient = okHttpClientBuild;
                ResponseBody responseBodyBody = UpgradeManager.access$getHttpClient$p(upgradeManager).newCall(requestBuild).execute().body();
                String strString = responseBodyBody != null ? responseBodyBody.string() : null;
                if (TextUtils.isEmpty(strString)) {
                    ((c.a) jVar).d("");
                } else if (strString != null) {
                    ((c.a) jVar).d(strString);
                } else {
                    l.l();
                    throw null;
                }
            }
        }).w(f.a.z.a.f4044c).n(f.a.s.b.a.a()).u(new f.a.v.c<String>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.upgradeFor3399.2
            @Override // f.a.v.c
            public final void accept(String str2) {
                UpgradeManager upgradeManager = UpgradeManager.INSTANCE;
                if (str2 != null) {
                    upgradeManager.startUploadFile(str2, str, iUpgradeStatusListener);
                } else {
                    l.l();
                    throw null;
                }
            }
        }, new f.a.v.c<Throwable>() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager.upgradeFor3399.3
            @Override // f.a.v.c
            public final void accept(Throwable th) {
                Log.i(UpgradeManager.TAG, "startUpgrade err: " + th);
            }
        }, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void upgradeProgress(String str, Gson gson) {
        if (a.b0("upgradeProgress: ", str, TAG, str)) {
            return;
        }
        try {
            float progress = ((OTAData) gson.fromJson(str, OTAData.class)).getProgress();
            if (progress > 1.0f) {
                Log.i(TAG, "upgradeProgress:onFailed ");
                IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener = progressListener;
                if (iUpgradeStatusListener == null) {
                    l.m("progressListener");
                    throw null;
                }
                iUpgradeStatusListener.onFailed("upgrade more than 1.0f");
            }
            float f2 = (progress / 2) + 0.5f;
            if (f2 < 1.0f && progress != 0.0f) {
                IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener2 = progressListener;
                if (iUpgradeStatusListener2 == null) {
                    l.m("progressListener");
                    throw null;
                }
                iUpgradeStatusListener2.onProcess(f2);
            }
            if (progress == 1.0f) {
                IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener3 = progressListener;
                if (iUpgradeStatusListener3 != null) {
                    iUpgradeStatusListener3.onProcess(1.0f);
                } else {
                    l.m("progressListener");
                    throw null;
                }
            }
        } catch (Exception unused) {
            Log.i(TAG, "upgradeProgress:onFailed exception ");
            IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener4 = progressListener;
            if (iUpgradeStatusListener4 != null) {
                iUpgradeStatusListener4.onFailed("upgrade err");
            } else {
                l.m("progressListener");
                throw null;
            }
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final void upgradeResult(String str, Gson gson) {
        if (TextUtils.isEmpty(str)) {
            return;
        }
        Log.i(TAG, "upgradeResult: " + str);
        if (((UpgradeResultNotify) gson.fromJson(str, UpgradeResultNotify.class)).getError()) {
            IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener = progressListener;
            if (iUpgradeStatusListener != null) {
                iUpgradeStatusListener.onFailed(UPGRADE_ERR);
                return;
            } else {
                l.m("progressListener");
                throw null;
            }
        }
        IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener2 = progressListener;
        if (iUpgradeStatusListener2 != null) {
            iUpgradeStatusListener2.onComplete();
        } else {
            l.m("progressListener");
            throw null;
        }
    }

    /* JADX INFO: Access modifiers changed from: private */
    public final boolean uploadFileReal(String str, String str2, MultipartBody multipartBody) {
        Request requestBuild = new Request.Builder().url("http://192.168.153.253:8455/upload").header("token", str).header("md5", str2).post(new UploadProgressBody(multipartBody, new UploadProgressBody.Callback() { // from class: com.cvte.dss.ups.dth_typc.UpgradeManager$uploadFileReal$request$1
            @Override // com.cvte.dss.ups.dth_typc.UploadProgressBody.Callback
            public final void onProgress(long j2, long j3) {
                StringBuilder sbB = a.B("onProgress: ");
                float f2 = (j3 / j2) * 0.95f;
                sbB.append(f2);
                Log.i("UpgradeManager", sbB.toString());
                UpgradeManager.access$getProgressListener$p(UpgradeManager.INSTANCE).onProcess(f2 / 2);
            }
        })).build();
        OkHttpClient okHttpClient = httpClient;
        if (okHttpClient != null) {
            return okHttpClient.newCall(requestBuild).execute().code() == 200;
        }
        l.m("httpClient");
        throw null;
    }

    public final IUpsPlugin.FirmwareInfo getFirmwareInfo(Context context) {
        l.g(context, "context");
        udiInit(context);
        Request requestBuild = new Request.Builder().url(UdiSdk.getFullUrl("v1/device/dth_typec/ota/information")).build();
        OkHttpClient okHttpClient = udiClient;
        if (okHttpClient == null) {
            l.m("udiClient");
            throw null;
        }
        ResponseBody responseBodyBody = okHttpClient.newCall(requestBuild).execute().body();
        String strString = responseBodyBody != null ? responseBodyBody.string() : null;
        Log.i(TAG, "getFirmwareInfo: " + strString);
        RetimerInfo retimerInfo = (RetimerInfo) new Gson().fromJson(strString, RetimerInfo.class);
        return new IUpsPlugin.FirmwareInfo("dth-typec", retimerInfo.getModel(), "dth-typec", retimerInfo.getVersion(), retimerInfo.getKey(), false, false);
    }

    public final void startUpgrade(Context context, String str, boolean z, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        l.g(context, "context");
        l.g(str, "path");
        l.g(iUpgradeStatusListener, "listener");
        progressListener = iUpgradeStatusListener;
        File file = new File(str);
        if (!file.exists()) {
            StringBuilder sbB = a.B("startUpgrade: file.exists()");
            sbB.append(file.exists());
            Log.i(TAG, sbB.toString());
            iUpgradeStatusListener.onFailed("file no find");
            return;
        }
        udiInit(context);
        addUpgradeProgressListener();
        if (BoardTypeUtils.INSTANCE.isSlotMachine()) {
            upgradeFor3399(iUpgradeStatusListener, str, context);
        } else {
            startUpgradeRequest(a.q("{\"path\": \"", str, "\" }"));
        }
    }
}