package g.f.c.b.h.pc;

import android.util.Log;
import com.cvte.vman.VmanMiddleWare;
import com.ifpdos.udi.sdk.service.sdk.UdiGlobal;
import com.ifpdos.udi.sdk.service.sdk.json.IJsonObject;
import com.ifpdos.udi.sdk.service.sdk.json.MissingFieldException;
import com.ifpdos.udi.sdk.service.sdk.log.IRequestTracker;
import com.ifpdos.udi.sdk.service.sdk.server.IRequest;
import com.ifpdos.udi.sdk.service.sdk.server.Response;
import com.ifpdos.udi.service.system.pc.SystemUpgradeInformationBody;
import com.ifpdos.udi.service.system.pc.UseStreaming;
import g.a.a.a.a;
import g.f.c.b.d.pc.utils.PropertiesUtils;
import g.f.c.b.h.pc.ota.OtaHelper;
import g.h.a.i;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.collections.EmptyList;
import kotlin.collections.j;
import kotlin.io.f;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.e0;
import kotlin.jvm.internal.m;
import kotlin.jvm.internal.o;
import kotlin.text.Charsets;

/* JADX INFO: loaded from: classes.dex */
@Metadata(k = 3, mv = {1, 6, 0}, xi = 48)
public final /* synthetic */ class u extends m implements Function1<IRequest, Response> {
    public u(Object obj) {
        super(1, obj, getOtaInformationSystemServiceCoreAdapter.class, "getOtaInformation", "getOtaInformation(Lcom/ifpdos/udi/sdk/service/sdk/server/IRequest;)Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", 0);
    }

    @Override // kotlin.jvm.functions.Function1
    public Response invoke(IRequest iRequest) throws IOException {
        String strC;
        Response.Companion companion;
        Response.ErrorBody errorBody;
        IJsonObject iJsonObjectA;
        IJsonObject iJsonObjectMerge;
        v vVar;
        IRequest iRequest2 = iRequest;
        o.f(iRequest2, "p0");
        getOtaInformationSystemServiceCoreAdapter getotainformationsystemservicecoreadapter = (getOtaInformationSystemServiceCoreAdapter) this.receiver;
        Objects.requireNonNull(getotainformationsystemservicecoreadapter);
        o.f(iRequest2, "request");
        UdiCompileUtils udiCompileUtils = UdiCompileUtils.a;
        if (udiCompileUtils.c(iRequest2)) {
            Reader inputStreamReader = new InputStreamReader(iRequest2.getData(), Charsets.f9181b);
            BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, 8192);
            try {
                strC = f.c(bufferedReader);
                i.E(bufferedReader, null);
            } catch (Throwable th) {
                try {
                    throw th;
                } catch (Throwable th2) {
                    i.E(bufferedReader, th);
                    throw th2;
                }
            }
        } else {
            strC = null;
        }
        List<Pair<String, String>> listO = a.O("useStreaming", "Boolean");
        try {
            IJsonObject iJsonObjectH = udiCompileUtils.h(iRequest2.getFields(), listO);
            if (strC != null) {
                try {
                    iJsonObjectA = udiCompileUtils.a(strC);
                } catch (Throwable th3) {
                    o.f(iRequest2, "request");
                    o.f(th3, "throwable");
                    ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, listO, strC, th3);
                    companion = Response.INSTANCE;
                    errorBody = new Response.ErrorBody(a.t("params decode failed: ", strC));
                    return companion.makeErrorResponse(400, errorBody);
                }
            } else {
                iJsonObjectA = null;
            }
            if (iJsonObjectA == null || (iJsonObjectMerge = iJsonObjectH.merge(iJsonObjectA)) == null) {
                iJsonObjectMerge = iJsonObjectH;
            }
            try {
                UseStreaming useStreaming = (UseStreaming) udiCompileUtils.b(iJsonObjectMerge, getotainformationsystemservicecoreadapter.f4606b);
                udiCompileUtils.f(iRequest2, strC, useStreaming, listO);
                SystemServiceCore systemServiceCore = getotainformationsystemservicecoreadapter.a;
                String url = iRequest2.getUrl();
                Map<String, String> fields = iRequest2.getFields();
                o.f(useStreaming, "body");
                o.f(url, "uri");
                o.f(fields, "fields");
                Objects.requireNonNull(systemServiceCore);
                OtaHelper otaHelper = OtaHelper.a;
                boolean zA = o.a(useStreaming.getUseStreaming(), Boolean.TRUE);
                PropertiesUtils propertiesUtils = PropertiesUtils.a;
                if (!propertiesUtils.c("ro.ota.only_support_streaming", false) || zA) {
                    List listK = j.K("recovery");
                    if (propertiesUtils.c("ro.en_ab_partitions", true)) {
                        listK.add("ab");
                    }
                    String strL = propertiesUtils.l("ro.build.version.time", "");
                    String modelName = VmanMiddleWare.getInstance().getDevcieCtrl().getModelName();
                    if (modelName == null || modelName.length() == 0) {
                        modelName = propertiesUtils.l("persist.sys.product.model", "empty");
                    }
                    if (o.a("empty", modelName)) {
                        modelName = propertiesUtils.l("ro.customer.product.model", "empty");
                    }
                    if (o.a(modelName, "empty")) {
                        modelName = propertiesUtils.l("ro.product.model", "empty");
                    }
                    SystemUpgradeInformationBody systemUpgradeInformationBody = new SystemUpgradeInformationBody(strL, modelName, propertiesUtils.l("ro.product.otakey", ""), listK);
                    Log.d("OtaHelper", "ota information: " + systemUpgradeInformationBody);
                    vVar = new v(systemUpgradeInformationBody);
                } else {
                    Log.d("OtaHelper", "getOtaInformation: unUse streaming upgrade");
                    vVar = new v(new SystemUpgradeInformationBody("", "", "", EmptyList.f9307f));
                }
                return vVar.a;
            } catch (MissingFieldException e2) {
                UdiCompileUtils udiCompileUtils2 = UdiCompileUtils.a;
                udiCompileUtils2.e(iRequest2, strC, e2, listO);
                return udiCompileUtils2.d(iJsonObjectH.toString(), null, strC, e2.getMissingFields());
            } catch (Throwable th4) {
                o.f(iRequest2, "request");
                o.f(th4, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, listO, strC, th4);
                companion = Response.INSTANCE;
                errorBody = new Response.ErrorBody(a.t("params decode failed: ", strC));
                return companion.makeErrorResponse(400, errorBody);
            }
        } catch (Exception e3) {
            o.f(iRequest2, "request");
            o.f(e3, "throwable");
            return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(a.t("params decode failed: ", a.j((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class)), iRequest2, listO, strC, e3))));
        }
    }
}