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

import android.util.Log;
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.json.TypeToken;
import com.ifpdos.udi.sdk.service.sdk.log.IRequestTracker;
import com.ifpdos.udi.sdk.service.sdk.server.Api;
import com.ifpdos.udi.sdk.service.sdk.server.IRequest;
import com.ifpdos.udi.sdk.service.sdk.server.Response;
import com.ifpdos.udi.service.ups.pc.DeviceMode;
import com.ifpdos.udi.service.ups.pc.FirmwareUpgradeStatusData;
import com.ifpdos.udi.service.ups.pc.UpgradeData;
import g.f.c.b.k.pc.proxy.UpsProxy;
import g.h.a.i;
import java.io.BufferedReader;
import java.io.File;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.Reader;
import java.util.Map;
import java.util.Objects;
import kotlin.Metadata;
import kotlin.Pair;
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: renamed from: g.f.c.b.k.a.q, reason: from Kotlin metadata */
/* JADX INFO: loaded from: classes.dex */
@Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0003\n\u0002\u0010 \n\u0002\b\u0005\u0018\u0000 \f2\u00020\u0001:\u0003\f\r\u000eB\u000f\b\u0016\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\f\u0010\t\u001a\b\u0012\u0004\u0012\u00020\u00060\nJ\f\u0010\u000b\u001a\b\u0012\u0004\u0012\u00020\u00060\nR\u0011\u0010\u0005\u001a\u00020\u0006¢\u0006\b\n\u0000\u001a\u0004\b\u0007\u0010\b¨\u0006\u000f"}, d2 = {"Lcom/ifpdos/udi/service/ups/pc/UpsUpgradeApi;", "", "receiver", "Lcom/ifpdos/udi/service/ups/pc/UpsCore;", "(Lcom/ifpdos/udi/service/ups/pc/UpsCore;)V", "api", "Lcom/ifpdos/udi/sdk/service/sdk/server/Api;", "getApi", "()Lcom/ifpdos/udi/sdk/service/sdk/server/Api;", "getApiList", "", "getStaticApiList", "Companion", "SetterRequest", "SetterResponse", "ups_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class UpsUpgradeApi {
    public static final UpsUpgradeApi a = null;

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public static final b f4818b = new b();

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final Api f4819c;

    /* JADX INFO: renamed from: g.f.c.b.k.a.q$a */
    @Metadata(k = 3, mv = {1, 6, 0}, xi = 48)
    public /* synthetic */ class a extends m implements Function1<IRequest, Response> {
        public a(Object obj) {
            super(1, obj, postUpsUpgradeUpsCoreAdapter.class, "postUpsUpgrade", "postUpsUpgrade(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;
            c cVar;
            IRequest iRequest2 = iRequest;
            o.f(iRequest2, "p0");
            postUpsUpgradeUpsCoreAdapter postupsupgradeupscoreadapter = (postUpsUpgradeUpsCoreAdapter) this.receiver;
            Objects.requireNonNull(postupsupgradeupscoreadapter);
            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;
            }
            try {
                IJsonObject iJsonObjectG = udiCompileUtils.g(g.a.a.a.a.P("otakey", new Pair(udiCompileUtils.i(iRequest2.getUrl()).get(3), "String")));
                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, null, strC, th3);
                        companion = Response.INSTANCE;
                        errorBody = new Response.ErrorBody(g.a.a.a.a.t("params decode failed: ", strC));
                        return companion.makeErrorResponse(400, errorBody);
                    }
                } else {
                    iJsonObjectA = null;
                }
                if (iJsonObjectA == null || (iJsonObjectMerge = iJsonObjectG.merge(iJsonObjectA)) == null) {
                    iJsonObjectMerge = iJsonObjectG;
                }
                try {
                    UpgradeData upgradeData = (UpgradeData) udiCompileUtils.b(iJsonObjectMerge, postupsupgradeupscoreadapter.f4835b);
                    udiCompileUtils.f(iRequest2, strC, upgradeData, null);
                    UpsCore upsCore = postupsupgradeupscoreadapter.a;
                    String url = iRequest2.getUrl();
                    Map<String, String> fields = iRequest2.getFields();
                    o.f(upgradeData, "body");
                    o.f(url, "uri");
                    o.f(fields, "fields");
                    Objects.requireNonNull(upsCore);
                    String otakey = upgradeData.getOtakey();
                    String path = upgradeData.getPath();
                    Log.i("UpsCore", "otaKey is " + otakey + ", firmwarePath is " + path);
                    if (new File(path).exists()) {
                        UpgradeRequest upgradeRequest = new UpgradeRequest(DeviceMode.INTERNAL, otakey, otakey, path, true, null, null);
                        UpsProxy upsProxy = upsCore.f4815f;
                        if (upsProxy == null) {
                            o.n("proxy");
                            throw null;
                        }
                        InvokeStatus invokeStatusB = upsProxy.b(upgradeRequest);
                        cVar = new c(new Response(invokeStatusB.f4799v, invokeStatusB.f4800w));
                    } else {
                        Log.i("UpsCore", "firmware file is not firmwarePath");
                        cVar = new c(UpsCore.f4811b);
                    }
                    return cVar.a;
                } catch (MissingFieldException e2) {
                    UdiCompileUtils udiCompileUtils2 = UdiCompileUtils.a;
                    udiCompileUtils2.e(iRequest2, strC, e2, null);
                    return udiCompileUtils2.d(null, iJsonObjectG.toString(), strC, e2.getMissingFields());
                } catch (Throwable th4) {
                    o.f(iRequest2, "request");
                    o.f(th4, "throwable");
                    ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strC, th4);
                    companion = Response.INSTANCE;
                    errorBody = new Response.ErrorBody(g.a.a.a.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(g.a.a.a.a.t("params decode failed: ", g.a.a.a.a.j((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class)), iRequest2, null, strC, e3))));
            }
        }
    }

    /* JADX INFO: renamed from: g.f.c.b.k.a.q$b */
    @Metadata(d1 = {"\u0000\u000f\n\u0000\n\u0002\u0018\u0002\n\u0002\u0018\u0002\n\u0000*\u0001\u0000\b\n\u0018\u00002\b\u0012\u0004\u0012\u00020\u00020\u0001¨\u0006\u0003"}, d2 = {"com/ifpdos/udi/service/ups/pc/UpsUpgradeApi$Companion$TOKEN$1", "Lcom/ifpdos/udi/sdk/service/sdk/json/TypeToken;", "Lcom/ifpdos/udi/service/ups/pc/FirmwareUpgradeStatusData;", "ups_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
    public static final class b extends TypeToken<FirmwareUpgradeStatusData> {
    }

    /* JADX INFO: renamed from: g.f.c.b.k.a.q$c */
    @Metadata(d1 = {"\u0000\"\n\u0002\u0018\u0002\n\u0002\u0010\u0000\n\u0002\b\u0002\n\u0002\u0010\b\n\u0000\n\u0002\u0018\u0002\n\u0002\b\u0002\n\u0002\u0018\u0002\n\u0002\b\u0004\u0018\u00002\u00020\u0001B\u0007\b\u0016¢\u0006\u0002\u0010\u0002B\u0017\b\u0016\u0012\u0006\u0010\u0003\u001a\u00020\u0004\u0012\u0006\u0010\u0005\u001a\u00020\u0006¢\u0006\u0002\u0010\u0007B\u000f\b\u0016\u0012\u0006\u0010\b\u001a\u00020\t¢\u0006\u0002\u0010\nR\u0011\u0010\b\u001a\u00020\t¢\u0006\b\n\u0000\u001a\u0004\b\u000b\u0010\f¨\u0006\r"}, d2 = {"Lcom/ifpdos/udi/service/ups/pc/UpsUpgradeApi$SetterResponse;", "", "()V", "code", "", "error", "Lcom/ifpdos/udi/sdk/service/sdk/server/Response$ErrorBody;", "(ILcom/ifpdos/udi/sdk/service/sdk/server/Response$ErrorBody;)V", "response", "Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", "(Lcom/ifpdos/udi/sdk/service/sdk/server/Response;)V", "getResponse", "()Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", "ups_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
    public static final class c {
        public final Response a;

        public c(Response response) {
            o.f(response, "response");
            this.a = response;
        }
    }

    public UpsUpgradeApi(UpsCore upsCore) {
        o.f(upsCore, "receiver");
        this.f4819c = new Api("v1/ups/upgrade/{otakey}", true, 7, null, new a(new postUpsUpgradeUpsCoreAdapter(upsCore)), 7, null, 0, false, 200, null);
    }
}