package com.ifpdos.factorytest.udi;

import com.ifpdos.factorytest.udi.UsbTestApi;
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.server.IRequest;
import com.ifpdos.udi.sdk.service.sdk.server.Response;
import com.seewo.vcommons.constants.SeewoIntent;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.Reader;
import kotlin.Metadata;
import kotlin.Pair;
import kotlin.TuplesKt;
import kotlin.collections.MapsKt;
import kotlin.io.CloseableKt;
import kotlin.io.TextStreamsKt;
import kotlin.jvm.internal.Intrinsics;
import kotlin.text.Charsets;

/* JADX INFO: compiled from: UsbTestApi.kt */
/* 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\b\u0003\n\u0002\u0018\u0002\n\u0000\n\u0002\u0018\u0002\n\u0000*\u0001\u0006\u0018\u00002\u00020\u0001B\r\u0012\u0006\u0010\u0002\u001a\u00020\u0003¢\u0006\u0002\u0010\u0004J\u000e\u0010\b\u001a\u00020\t2\u0006\u0010\n\u001a\u00020\u000bR\u0010\u0010\u0005\u001a\u00020\u0006X\u0082\u0004¢\u0006\u0004\n\u0002\u0010\u0007R\u000e\u0010\u0002\u001a\u00020\u0003X\u0082\u0004¢\u0006\u0002\n\u0000¨\u0006\f"}, d2 = {"Lcom/ifpdos/factorytest/udi/usbTestUdiHandlerServiceAdapter;", "", "receiver", "Lcom/ifpdos/factorytest/udi/UdiHandlerService;", "(Lcom/ifpdos/factorytest/udi/UdiHandlerService;)V", "TOKEN", "com/ifpdos/factorytest/udi/usbTestUdiHandlerServiceAdapter$TOKEN$1", "Lcom/ifpdos/factorytest/udi/usbTestUdiHandlerServiceAdapter$TOKEN$1;", "usbTest", "Lcom/ifpdos/udi/sdk/service/sdk/server/Response;", "request", "Lcom/ifpdos/udi/sdk/service/sdk/server/IRequest;", "app_generalRelease"}, k = 1, mv = {1, 8, 0}, xi = 48)
public final class usbTestUdiHandlerServiceAdapter {
    private final usbTestUdiHandlerServiceAdapter$TOKEN$1 TOKEN;
    private final UdiHandlerService receiver;

    /* JADX WARN: Type inference failed for: r2v1, types: [com.ifpdos.factorytest.udi.usbTestUdiHandlerServiceAdapter$TOKEN$1] */
    public usbTestUdiHandlerServiceAdapter(UdiHandlerService receiver) {
        Intrinsics.checkNotNullParameter(receiver, "receiver");
        this.receiver = receiver;
        this.TOKEN = new TypeToken<UsbTestTypeBody>() { // from class: com.ifpdos.factorytest.udi.usbTestUdiHandlerServiceAdapter$TOKEN$1
        };
    }

    public final Response usbTest(IRequest request) {
        String text;
        IJsonObject iJsonObjectFromJson;
        IJsonObject iJsonObjectMerge;
        Intrinsics.checkNotNullParameter(request, "request");
        if (UdiCompileUtils.INSTANCE.hasBody(request)) {
            Reader inputStreamReader = new InputStreamReader(request.getData(), Charsets.UTF_8);
            BufferedReader bufferedReader = inputStreamReader instanceof BufferedReader ? (BufferedReader) inputStreamReader : new BufferedReader(inputStreamReader, 8192);
            try {
                text = TextStreamsKt.readText(bufferedReader);
                CloseableKt.closeFinally(bufferedReader, null);
            } finally {
            }
        } else {
            text = null;
        }
        try {
            IJsonObject iJsonObjectParamsToJsonObject = UdiCompileUtils.INSTANCE.paramsToJsonObject(MapsKt.mapOf(TuplesKt.to(SeewoIntent.KEY_FILE_TYPE, new Pair(UdiCompileUtils.INSTANCE.splitUriParts(request.getUrl()).get(4), "com.ifpdos.factorytest.udi.UsbTestTypeEnum"))));
            if (text != null) {
                try {
                    iJsonObjectFromJson = UdiCompileUtils.INSTANCE.fromJson(text);
                } catch (Throwable th) {
                    UdiCompileUtils.onParseRequestFailed$default(UdiCompileUtils.INSTANCE, request, text, th, null, 8, null);
                    return UdiCompileUtils.INSTANCE.newParamsDecodeFailedResponse(text);
                }
            } else {
                iJsonObjectFromJson = null;
            }
            if (iJsonObjectFromJson == null || (iJsonObjectMerge = iJsonObjectParamsToJsonObject.merge(iJsonObjectFromJson)) == null) {
                iJsonObjectMerge = iJsonObjectParamsToJsonObject;
            }
            try {
                UsbTestTypeBody usbTestTypeBody = (UsbTestTypeBody) UdiCompileUtils.INSTANCE.fromJson(iJsonObjectMerge, this.TOKEN);
                UdiCompileUtils.onParseRequestSuccess$default(UdiCompileUtils.INSTANCE, request, text, usbTestTypeBody, null, 8, null);
                return this.receiver.usbTest(new UsbTestApi.SetterRequest(usbTestTypeBody, request.getUrl(), request.getFields())).getResponse();
            } catch (MissingFieldException e) {
                UdiCompileUtils.onParseRequestFailed$default(UdiCompileUtils.INSTANCE, request, text, e, null, 8, null);
                return UdiCompileUtils.INSTANCE.newMissingFieldsResponse(null, iJsonObjectParamsToJsonObject.toString(), text, e.getMissingFields());
            } catch (Throwable th2) {
                UdiCompileUtils.onParseRequestFailed$default(UdiCompileUtils.INSTANCE, request, text, th2, null, 8, null);
                return UdiCompileUtils.INSTANCE.newParamsDecodeFailedResponse(text);
            }
        } catch (Exception e2) {
            UdiCompileUtils.onParseRequestFailed$default(UdiCompileUtils.INSTANCE, request, text, e2, null, 8, null);
            return UdiCompileUtils.INSTANCE.newParamsDecodeFailedResponse(String.valueOf(e2.getMessage()));
        }
    }
}