package com.cvte.dss.ups.main;

import android.content.Context;
import android.util.Log;
import com.cvte.dss.ups.main.BasePlugin;
import com.cvte.dss.ups.main.http_server.OtaHttpServerManager;
import com.cvte.dss.ups.main.system_ota.Constant;
import com.cvte.dss.ups.main.system_ota.OtaHttpServerEnableBody;
import com.cvte.dss.ups.main.system_ota.PayloadSpec;
import com.cvte.dss.ups.main.system_ota.PayloadSpecs;
import com.cvte.dss.ups.plugin.IUpsPlugin;
import com.ifpdos.udi.sdk.UdiSdk;
import g.h.a.i;
import java.io.File;
import java.io.IOException;
import java.util.List;
import java.util.Objects;
import kotlin.Lazy;
import kotlin.Metadata;
import kotlin.Unit;
import kotlin.jvm.internal.e0;
import kotlin.jvm.internal.o;
import kotlin.jvm.internal.z;
import kotlin.reflect.KProperty;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.Response;
import okhttp3.ResponseBody;
import okhttp3.n0.connection.RealCall;

/* JADX INFO: loaded from: classes.dex */
@Metadata(bv = {1, 0, 3}, d1 = {"\u0000T\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0010\u000e\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u000b\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0010\u0002\n\u0002\b\u000f\n\u0002\u0018\u0002\n\u0002\b\t\n\u0002\u0018\u0002\n\u0002\b\t\u0018\u00002\u00020\u0001B\u0007¢\u0006\u0004\b8\u0010\u001aJ\u0011\u0010\u0003\u001a\u0004\u0018\u00010\u0002H\u0002¢\u0006\u0004\b\u0003\u0010\u0004J\u0011\u0010\u0006\u001a\u0004\u0018\u00010\u0005H\u0002¢\u0006\u0004\b\u0006\u0010\u0007J'\u0010\u000e\u001a\u00020\r2\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\n\u001a\u00020\b2\u0006\u0010\f\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\u000e\u0010\u000fJ/\u0010\u0012\u001a\u00020\r2\u0006\u0010\n\u001a\u00020\b2\u0006\u0010\u0011\u001a\u00020\u00102\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\f\u001a\u00020\u000bH\u0002¢\u0006\u0004\b\u0012\u0010\u0013J\u0017\u0010\u0017\u001a\u00020\u00162\u0006\u0010\u0015\u001a\u00020\u0014H\u0002¢\u0006\u0004\b\u0017\u0010\u0018J\u000f\u0010\u0019\u001a\u00020\u0016H\u0002¢\u0006\u0004\b\u0019\u0010\u001aJ\u000f\u0010\u001b\u001a\u00020\rH\u0002¢\u0006\u0004\b\u001b\u0010\u001cJ\u000f\u0010\u001d\u001a\u00020\bH\u0014¢\u0006\u0004\b\u001d\u0010\u001eJ\u000f\u0010\u001f\u001a\u00020\bH\u0014¢\u0006\u0004\b\u001f\u0010\u001eJ\u000f\u0010 \u001a\u00020\rH\u0014¢\u0006\u0004\b \u0010\u001cJ\u000f\u0010!\u001a\u00020\rH\u0014¢\u0006\u0004\b!\u0010\u001cJ\u000f\u0010\"\u001a\u00020\bH\u0014¢\u0006\u0004\b\"\u0010\u001eJ\u000f\u0010#\u001a\u00020\bH\u0014¢\u0006\u0004\b#\u0010\u001eJ\u000f\u0010$\u001a\u00020\bH\u0014¢\u0006\u0004\b$\u0010\u001eJ\u000f\u0010%\u001a\u00020\bH\u0014¢\u0006\u0004\b%\u0010\u001eJ\u0019\u0010(\u001a\u0004\u0018\u00010\u00052\u0006\u0010'\u001a\u00020&H\u0016¢\u0006\u0004\b(\u0010)J7\u0010+\u001a\u00020\r2\u0006\u0010'\u001a\u00020&2\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\n\u001a\u00020\b2\u0006\u0010*\u001a\u00020\r2\u0006\u0010\f\u001a\u00020\u000bH\u0016¢\u0006\u0004\b+\u0010,J)\u0010.\u001a\u00020\u00162\b\u0010-\u001a\u0004\u0018\u00010\b2\u0006\u0010\t\u001a\u00020\b2\u0006\u0010\f\u001a\u00020\u000bH\u0016¢\u0006\u0004\b.\u0010/R\u001d\u00105\u001a\u0002008B@\u0002X\u0082\u0084\u0002¢\u0006\f\n\u0004\b1\u00102\u001a\u0004\b3\u00104R\u0018\u00106\u001a\u0004\u0018\u00010\r8\u0002@\u0002X\u0082\u000e¢\u0006\u0006\n\u0004\b6\u00107¨\u00069"}, d2 = {"Lcom/cvte/dss/ups/main/DsuPlugin;", "Lcom/cvte/dss/ups/main/BasePlugin;", "Lcom/cvte/dss/ups/main/BasePlugin$SystemInfo;", "invokeUdiGetSystemInfo", "()Lcom/cvte/dss/ups/main/BasePlugin$SystemInfo;", "Lcom/cvte/dss/ups/plugin/IUpsPlugin$FirmwareInfo;", "getFirmwareInfoFromUdi", "()Lcom/cvte/dss/ups/plugin/IUpsPlugin$FirmwareInfo;", "", "id", "path", "Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;", "listener", "", "upgradeFirmwareByStreaming", "(Ljava/lang/String;Ljava/lang/String;Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;)Z", "Lcom/cvte/dss/ups/main/BasePlugin$StreamingData;", "streamingData", "doUpgradeFirmware", "(Ljava/lang/String;Lcom/cvte/dss/ups/main/BasePlugin$StreamingData;Ljava/lang/String;Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;)Z", "Lcom/cvte/dss/ups/main/system_ota/OtaHttpServerEnableBody;", "otaHttpServerEnableBody", "", "doOperateHttpServer", "(Lcom/cvte/dss/ups/main/system_ota/OtaHttpServerEnableBody;)V", "closeHttpServer", "()V", "checkUseStreaming", "()Z", "getName", "()Ljava/lang/String;", "getType", "getReboot", "getMonopolize", "getOtaInformationUrl", "getOtaUpgradeUrl", "getOtaUpgradeStatusNotify", "getOtaUpgradeResultNotify", "Landroid/content/Context;", "context", "getFirmwareInfo", "(Landroid/content/Context;)Lcom/cvte/dss/ups/plugin/IUpsPlugin$FirmwareInfo;", "force", "upgradeFirmware", "(Landroid/content/Context;Ljava/lang/String;Ljava/lang/String;ZLcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;)Z", "data", "onNewResultEvent", "(Ljava/lang/String;Ljava/lang/String;Lcom/cvte/dss/ups/plugin/IUpsPlugin$IUpgradeStatusListener;)V", "Lcom/cvte/dss/ups/main/http_server/OtaHttpServerManager;", "mOtaHttpServerManager$delegate", "Lkotlin/Lazy;", "getMOtaHttpServerManager", "()Lcom/cvte/dss/ups/main/http_server/OtaHttpServerManager;", "mOtaHttpServerManager", "mUseStreaming", "Ljava/lang/Boolean;", "<init>", "lib_release"}, k = 1, mv = {1, 4, 0})
public final class DsuPlugin extends BasePlugin {
    public static final /* synthetic */ KProperty[] $$delegatedProperties = {e0.c(new z(e0.a(DsuPlugin.class), "mOtaHttpServerManager", "getMOtaHttpServerManager()Lcom/cvte/dss/ups/main/http_server/OtaHttpServerManager;"))};

    /* JADX INFO: renamed from: mOtaHttpServerManager$delegate, reason: from kotlin metadata */
    private final Lazy mOtaHttpServerManager = i.D2(DsuPlugin$mOtaHttpServerManager$2.INSTANCE);
    private Boolean mUseStreaming;

    private final boolean checkUseStreaming() {
        List<String> capabilities;
        BasePlugin.SystemInfo systemInfoInvokeUdiGetSystemInfo = invokeUdiGetSystemInfo();
        boolean zContains = (systemInfoInvokeUdiGetSystemInfo == null || (capabilities = systemInfoInvokeUdiGetSystemInfo.getCapabilities()) == null) ? false : capabilities.contains("ab");
        this.mUseStreaming = Boolean.valueOf(zContains);
        return zContains;
    }

    private final void closeHttpServer() {
        doOperateHttpServer(new OtaHttpServerEnableBody(false, ""));
    }

    private final void doOperateHttpServer(OtaHttpServerEnableBody otaHttpServerEnableBody) {
        getMOtaHttpServerManager().operateLocalHttpServer(otaHttpServerEnableBody);
    }

    private final boolean doUpgradeFirmware(String path, BasePlugin.StreamingData streamingData, String id, IUpsPlugin.IUpgradeStatusListener listener) {
        registerUpgradeEvent(id, listener);
        doOperateHttpServer(new OtaHttpServerEnableBody(true, path));
        String strG = getMGson().g(new BasePlugin.SystemUpgradeBody(Constant.OTA_SERVER_URL_COMPLETE, getMRebootOnSuccess(), streamingData));
        o.b(strG, "body");
        if (invokeUdiUpgrade(strG)) {
            return true;
        }
        closeHttpServer();
        return false;
    }

    private final IUpsPlugin.FirmwareInfo getFirmwareInfoFromUdi() {
        BasePlugin.SystemInfo systemInfoInvokeUdiGetSystemInfo = invokeUdiGetSystemInfo();
        if (systemInfoInvokeUdiGetSystemInfo == null) {
            return null;
        }
        if (systemInfoInvokeUdiGetSystemInfo.getKey().length() == 0) {
            return null;
        }
        this.mUseStreaming = Boolean.valueOf(systemInfoInvokeUdiGetSystemInfo.getCapabilities().contains("ab"));
        return new IUpsPlugin.FirmwareInfo(getName(), systemInfoInvokeUdiGetSystemInfo.getModel(), getType(), systemInfoInvokeUdiGetSystemInfo.getVersion(), systemInfoInvokeUdiGetSystemInfo.getKey(), getReboot(), getMonopolize(), systemInfoInvokeUdiGetSystemInfo.getKey());
    }

    private final OtaHttpServerManager getMOtaHttpServerManager() {
        Lazy lazy = this.mOtaHttpServerManager;
        KProperty kProperty = $$delegatedProperties[0];
        return (OtaHttpServerManager) lazy.getValue();
    }

    private final BasePlugin.SystemInfo invokeUdiGetSystemInfo() {
        BasePlugin.SystemInfo systemInfo;
        OkHttpClient.a aVarNewOkHttpClientBuilder = UdiSdk.newOkHttpClientBuilder();
        Objects.requireNonNull(aVarNewOkHttpClientBuilder);
        OkHttpClient okHttpClient = new OkHttpClient(aVarNewOkHttpClientBuilder);
        Request.a aVar = new Request.a();
        aVar.f(getOtaInformationUrl());
        try {
            Response responseJ = ((RealCall) okHttpClient.b(aVar.a())).j();
            try {
                if (responseJ.c()) {
                    ResponseBody responseBody = responseJ.f9647r;
                    systemInfo = (BasePlugin.SystemInfo) getMGson().b(responseBody != null ? responseBody.g() : null, BasePlugin.SystemInfo.class);
                } else {
                    systemInfo = new BasePlugin.SystemInfo(null, null, null, null, 15, null);
                }
                Log.i(BasePlugin.TAG, "udi ota information request: " + systemInfo + ", " + responseJ);
                i.E(responseJ, null);
                return systemInfo;
            } finally {
            }
        } catch (Exception e2) {
            StringBuilder sb = new StringBuilder();
            sb.append("getFirmwareInfo");
            e2.printStackTrace();
            sb.append(Unit.a);
            Log.e(BasePlugin.TAG, sb.toString());
            return null;
        }
    }

    private final boolean upgradeFirmwareByStreaming(String id, String path, IUpsPlugin.IUpgradeStatusListener listener) throws IOException {
        PayloadSpec payloadSpecForNonStreaming = PayloadSpecs.forNonStreaming(new File(path));
        o.b(payloadSpecForNonStreaming, "payloadSpec");
        long offset = payloadSpecForNonStreaming.getOffset();
        long size = payloadSpecForNonStreaming.getSize();
        List<String> properties = payloadSpecForNonStreaming.getProperties();
        o.b(properties, "payloadSpec.properties");
        if (doUpgradeFirmware(path, new BasePlugin.StreamingData(offset, size, properties), id, listener)) {
            return true;
        }
        onFailure(id, "fail to upgrade firmware", listener);
        return false;
    }

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

    @Override // com.cvte.dss.ups.main.BasePlugin
    public boolean getMonopolize() {
        return false;
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getName() {
        return getType();
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getOtaInformationUrl() {
        String fullUrl = UdiSdk.getFullUrl("/v1/system/ota/information?useStreaming=true");
        o.b(fullUrl, "UdiSdk.getFullUrl(\"/v1/s…ation?useStreaming=true\")");
        return fullUrl;
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getOtaUpgradeResultNotify() {
        return "v1/system/ota/upgrade/result";
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getOtaUpgradeStatusNotify() {
        return "v1/system/ota/upgrade/status";
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getOtaUpgradeUrl() {
        String fullUrl = UdiSdk.getFullUrl("/v1/system/ota/upgrade");
        o.b(fullUrl, "UdiSdk.getFullUrl(\"/v1/system/ota/upgrade\")");
        return fullUrl;
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public boolean getReboot() {
        return true;
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public String getType() {
        return "dsu";
    }

    @Override // com.cvte.dss.ups.main.BasePlugin
    public void onNewResultEvent(String data, String id, IUpsPlugin.IUpgradeStatusListener listener) {
        o.g(id, "id");
        o.g(listener, "listener");
        closeHttpServer();
        super.onNewResultEvent(data, id, listener);
    }

    @Override // com.cvte.dss.ups.main.BasePlugin, com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String id, String path, boolean force, IUpsPlugin.IUpgradeStatusListener listener) {
        o.g(context, "context");
        o.g(id, "id");
        o.g(path, "path");
        o.g(listener, "listener");
        Boolean bool = this.mUseStreaming;
        boolean zBooleanValue = bool != null ? bool.booleanValue() : checkUseStreaming();
        if (getMRunInDsu() == null) {
            setMRunInDsu(Boolean.valueOf(isRunningInDsu(context)));
        }
        if (!o.a(getMRunInDsu(), Boolean.FALSE) || !zBooleanValue) {
            return super.upgradeFirmware(context, id, path, force, listener);
        }
        if (checkParamsLegalBeforeUpgrade(context, id)) {
            return upgradeFirmwareByStreaming(id, path, listener);
        }
        Log.e(BasePlugin.TAG, "upgradeFirmware: checkParamsLegalBeforeUpgrade failed");
        return false;
    }
}