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

import android.content.Context;
import android.os.RecoverySystem;
import android.util.Log;
import com.ifpdos.udi.sdk.service.sdk.UdiGlobal;
import com.ifpdos.udi.sdk.service.sdk.json.IConverter;
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.StreamingData;
import com.ifpdos.udi.service.system.pc.SystemUpgradeBody;
import g.e.a.a.a;
import g.f.c.b.d.pc.utils.PropertiesUtils;
import g.f.c.b.d.pc.utils.ShellUtils;
import g.f.c.b.h.pc.ota.OtaHelper;
import g.f.c.b.h.pc.ota.UpgradeEngineWrapper;
import g.f.c.b.h.pc.ota.b;
import g.f.c.b.h.pc.ota.g;
import g.f.c.b.h.pc.upgradeSystemServiceCoreAdapter;
import g.h.a.i;
import java.io.BufferedReader;
import java.io.File;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Map;
import java.util.Objects;
import kotlin.Metadata;
import kotlin.io.f;
import kotlin.jvm.functions.Function1;
import kotlin.jvm.internal.m;
import kotlin.jvm.internal.o;
import kotlin.reflect.w.internal.y0.n.c2.c;
import kotlin.text.Charsets;

/* JADX INFO: loaded from: classes.dex */
@Metadata(k = 3, mv = {1, 6, 0}, xi = 48)
public final /* synthetic */ class e0 extends m implements Function1<IRequest, Response> {
    public e0(Object obj) {
        super(1, obj, upgradeSystemServiceCoreAdapter.class, "upgrade", "upgrade(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 Exception {
        String strA;
        f0 f0Var;
        IRequest iRequest2 = iRequest;
        o.f(iRequest2, "p0");
        upgradeSystemServiceCoreAdapter upgradesystemservicecoreadapter = (upgradeSystemServiceCoreAdapter) this.receiver;
        Objects.requireNonNull(upgradesystemservicecoreadapter);
        o.f(iRequest2, "request");
        Reader inputStreamReader = new InputStreamReader(iRequest2.getData(), Charsets.f9181b);
        BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, 8192);
        try {
            String strC = f.c(bufferedReader);
            i.E(bufferedReader, null);
            try {
                upgradeSystemServiceCoreAdapter.a aVar = upgradesystemservicecoreadapter.f4591b;
                o.f(strC, "json");
                o.f(aVar, "token");
                String str = strC.length() == 0 ? "{}" : strC;
                UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
                SystemUpgradeBody systemUpgradeBody = (SystemUpgradeBody) ((IConverter) udiGlobal.get(kotlin.jvm.internal.e0.a(IConverter.class))).fromJson(str, aVar);
                o.f(iRequest2, "request");
                o.f(systemUpgradeBody, "paramParse");
                ((IRequestTracker) udiGlobal.get(kotlin.jvm.internal.e0.a(IRequestTracker.class))).onParseRequestSuccess(iRequest2, null, strC, systemUpgradeBody);
                SystemServiceCore systemServiceCore = upgradesystemservicecoreadapter.a;
                String url = iRequest2.getUrl();
                Map<String, String> fields = iRequest2.getFields();
                o.f(systemUpgradeBody, "body");
                o.f(url, "uri");
                o.f(fields, "fields");
                Objects.requireNonNull(systemServiceCore);
                OtaHelper otaHelper = OtaHelper.a;
                Context context = systemServiceCore.a;
                o.f(context, "context");
                o.f(systemUpgradeBody, "body");
                Log.d("OtaHelper", "upgrade system with: " + systemUpgradeBody);
                UpgradeEngineWrapper upgradeEngineWrapper = UpgradeEngineWrapper.a;
                if (UpgradeEngineWrapper.f4625c) {
                    f0Var = new f0(OtaHelper.f4615b);
                } else {
                    if (systemUpgradeBody.getStreamingData() != null) {
                        Log.d("OtaHelper", "upgrade streamingData");
                        strA = systemUpgradeBody.getPath();
                    } else {
                        Log.d("OtaHelper", "upgrade prepareUpgradeFile");
                        strA = a.A(systemUpgradeBody.getPath(), systemUpgradeBody.getCopyTo());
                        if (strA == null) {
                            f0Var = new f0(OtaHelper.f4616c);
                        }
                    }
                    b bVar = new b(systemUpgradeBody, context);
                    StreamingData streamingData = systemUpgradeBody.getStreamingData();
                    o.f(context, "context");
                    o.f(strA, "otaFile");
                    o.f(bVar, "callback");
                    if (PropertiesUtils.a.c("ro.en_ab_partitions", true)) {
                        c.h0(g.f.c.b.d.pc.utils.b.a, null, null, new g(streamingData, strA, bVar, null), 3, null);
                    } else {
                        Log.d("UpgradeEngineWrapper", "recoveryByAndroidApi");
                        bVar.a(0.1f);
                        if (!o.a(strA, "/data/ota_package/update.zip")) {
                            String strU = g.a.a.a.a.u("cp ", strA, " /data/ota_package/update.zip");
                            Log.d("UpgradeEngineWrapper", "runUpgradeCommand: (" + strU + ')');
                            ShellUtils.a aVarA = ShellUtils.a.a(strU, true);
                            if (aVarA.a != 0) {
                                StringBuilder sb = new StringBuilder();
                                sb.append(aVarA.f4391c);
                                sb.append('(');
                                throw new Exception(g.a.a.a.a.w(sb, aVarA.a, ')'));
                            }
                        }
                        RecoverySystem.installPackage(context, new File("/data/ota_package/update.zip"));
                        bVar.onSuccess();
                    }
                    f0Var = new f0();
                }
                return f0Var.a;
            } catch (MissingFieldException e2) {
                o.f(iRequest2, "request");
                o.f(e2, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(kotlin.jvm.internal.e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strC, e2);
                return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(g.a.a.a.a.i(e2, g.a.a.a.a.K("params ", strC, ", miss field : "))));
            } catch (Throwable th) {
                o.f(iRequest2, "request");
                o.f(th, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(kotlin.jvm.internal.e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strC, th);
                return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(g.a.a.a.a.t("params decode failed: ", strC)));
            }
        } catch (Throwable th2) {
            try {
                throw th2;
            } catch (Throwable th3) {
                i.E(bufferedReader, th2);
                throw th3;
            }
        }
    }
}