package com.cvte.dss.ups.camera;

import android.content.Context;
import android.util.Log;
import com.cvte.dss.ups.camera.model.FirmwareInfoList;
import com.cvte.dss.ups.camera.model.OtaFirmwareInfo;
import com.cvte.dss.ups.camera.model.OtaUpgradeResult;
import com.cvte.dss.ups.camera.model.UpgradeStatus;
import com.cvte.dss.ups.plugin.IUpsPlugin;
import com.ifpdos.udi.sdk.IEventHandler;
import com.ifpdos.udi.sdk.UdiSdk;
import g.e.b.j;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.concurrent.TimeUnit;
import okhttp3.MediaType;
import okhttp3.OkHttpClient;
import okhttp3.Request;
import okhttp3.RequestBody;
import okhttp3.Response;
import okhttp3.ResponseBody;
import okhttp3.n0.connection.RealCall;

/* JADX INFO: loaded from: classes.dex */
public abstract class BaseUdiPlugin implements IUpsPlugin {
    private final OkHttpClient client;
    private IEventHandler mUdiEventHandler;
    private final String TAG = getClass().getSimpleName();
    private final j mGson = new j();

    public BaseUdiPlugin() {
        OkHttpClient.a aVarNewOkHttpClientBuilder = UdiSdk.newOkHttpClientBuilder();
        TimeUnit timeUnit = TimeUnit.MINUTES;
        aVarNewOkHttpClientBuilder.b(3L, timeUnit);
        aVarNewOkHttpClientBuilder.d(3L, timeUnit);
        aVarNewOkHttpClientBuilder.f9579f = true;
        this.client = new OkHttpClient(aVarNewOkHttpClientBuilder);
    }

    /* JADX WARN: Type inference fix 'apply assigned field type' failed
    java.lang.UnsupportedOperationException: ArgType.getObject(), call class: class jadx.core.dex.instructions.args.ArgType$UnknownArg
    	at jadx.core.dex.instructions.args.ArgType.getObject(ArgType.java:593)
    	at jadx.core.dex.attributes.nodes.ClassTypeVarsAttr.getTypeVarsMapFor(ClassTypeVarsAttr.java:35)
    	at jadx.core.dex.nodes.utils.TypeUtils.replaceClassGenerics(TypeUtils.java:177)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.insertExplicitUseCast(FixTypesVisitor.java:397)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.tryFieldTypeWithNewCasts(FixTypesVisitor.java:359)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.applyFieldType(FixTypesVisitor.java:309)
    	at jadx.core.dex.visitors.typeinference.FixTypesVisitor.visit(FixTypesVisitor.java:94)
     */
    private List<IUpsPlugin.FirmwareInfo> getFirmwareInfoList() {
        ArrayList arrayList = new ArrayList();
        Request.a aVar = new Request.a();
        aVar.f(UdiSdk.getFullUrl(getOtaInformationUrl()));
        try {
            Response responseJ = ((RealCall) this.client.b(aVar.a())).j();
            try {
                FirmwareInfoList firmwareInfoList = null;
                if (responseJ.c()) {
                    ResponseBody responseBody = responseJ.f9647r;
                    firmwareInfoList = (FirmwareInfoList) this.mGson.b(responseBody != null ? responseBody.g() : null, FirmwareInfoList.class);
                }
                Log.i(this.TAG, "udi ota information request: " + firmwareInfoList + ", " + responseJ);
                if (firmwareInfoList == null) {
                    responseJ.close();
                    return arrayList;
                }
                List<OtaFirmwareInfo> list = firmwareInfoList.getList();
                if (list != null && !list.isEmpty()) {
                    for (OtaFirmwareInfo otaFirmwareInfo : list) {
                        arrayList.add(new IUpsPlugin.FirmwareInfo(getName(), otaFirmwareInfo.getModule(), getType(), otaFirmwareInfo.getVersion(), otaFirmwareInfo.getOtaKey(), otaFirmwareInfo.isReboot(), otaFirmwareInfo.isMonopolize(), otaFirmwareInfo.getId()));
                    }
                    responseJ.close();
                    return arrayList;
                }
                Log.e(this.TAG, "getFirmwareInfo: list is empty");
                responseJ.close();
                return arrayList;
            } finally {
            }
        } catch (Exception e2) {
            Log.e(this.TAG, "getFirmwareInfo", e2);
            return new ArrayList();
        }
    }

    private void registerUpgradeStatusListener(final IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener, String str) {
        final ArrayList arrayList = new ArrayList();
        final String str2 = getUpgradeStatusUrl() + "/" + str;
        final String str3 = getUpgradeResultUrl() + "/" + str;
        arrayList.add(str2);
        arrayList.add(str3);
        IEventHandler iEventHandler = new IEventHandler() { // from class: com.cvte.dss.ups.camera.BaseUdiPlugin.1
            @Override // com.ifpdos.udi.sdk.IEventHandler
            public void onEvent(String str4, String str5) {
                if (str2.equals(str4)) {
                    iUpgradeStatusListener.onProcess(((UpgradeStatus) BaseUdiPlugin.this.mGson.b(str5, UpgradeStatus.class)).getProgress());
                } else if (str3.equals(str4)) {
                    OtaUpgradeResult otaUpgradeResult = (OtaUpgradeResult) BaseUdiPlugin.this.mGson.b(str5, OtaUpgradeResult.class);
                    if (otaUpgradeResult.isError()) {
                        iUpgradeStatusListener.onFailed(otaUpgradeResult.getMessage());
                    } else {
                        iUpgradeStatusListener.onComplete();
                    }
                    UdiSdk.unregisterEvents((List<String>) arrayList, BaseUdiPlugin.this.mUdiEventHandler);
                }
            }
        };
        this.mUdiEventHandler = iEventHandler;
        UdiSdk.registerEvents(arrayList, iEventHandler);
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public IUpsPlugin.FirmwareInfo getFirmwareInfo(Context context) {
        List<IUpsPlugin.FirmwareInfo> firmwareInfoList = getFirmwareInfoList();
        if (firmwareInfoList.isEmpty()) {
            return null;
        }
        return firmwareInfoList.get(0);
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public List<IUpsPlugin.FirmwareInfo> getFirmwareInfos(Context context) {
        return getFirmwareInfoList();
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public List<IUpsPlugin.FirmwareInfo> getFirmwareInfosWithOptions(Context context, String str) {
        return getFirmwareInfoList();
    }

    public abstract String getName();

    public abstract String getOtaInformationUrl();

    public abstract String getType();

    public abstract String getUpgradeResultUrl();

    public abstract String getUpgradeStatusUrl();

    public abstract String getUpgradeUrl();

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String str, String str2, boolean z2, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        HashMap map = new HashMap();
        map.put("path", str2);
        RequestBody requestBodyCreate = RequestBody.create(this.mGson.g(map), MediaType.b("application/json; charset=utf-8"));
        String str3 = getUpgradeUrl() + "/" + str;
        Request.a aVar = new Request.a();
        aVar.f(UdiSdk.getFullUrl(str3));
        aVar.d(requestBodyCreate);
        try {
            Response responseJ = ((RealCall) this.client.b(aVar.a())).j();
            try {
                boolean zC = responseJ.c();
                if (zC) {
                    registerUpgradeStatusListener(iUpgradeStatusListener, str);
                }
                responseJ.close();
                return zC;
            } finally {
            }
        } catch (IOException unused) {
            return false;
        }
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String str, String str2, boolean z2, String str3, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        return upgradeFirmware(context, str, str2, z2, iUpgradeStatusListener);
    }

    @Override // com.cvte.dss.ups.plugin.IUpsPlugin
    public boolean upgradeFirmware(Context context, String str, boolean z2, IUpsPlugin.IUpgradeStatusListener iUpgradeStatusListener) {
        IUpsPlugin.FirmwareInfo firmwareInfo = getFirmwareInfo(context);
        if (firmwareInfo == null) {
            return false;
        }
        return upgradeFirmware(context, firmwareInfo.getId(), str, z2, iUpgradeStatusListener);
    }
}