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

import android.util.Log;
import com.cvte.va.sdk.mica.api.DeviceStatusManager;
import com.cvte.va.sdk.mica.enumclass.UsbTypeEnum;
import com.cvte.va.sdk.mica.enumclass.VolumeControlEnum;
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.ByodModeVolumeControlBody;
import g.a.a.a.a;
import g.f.c.b.h.pc.controlByodModeVolumeSystemServiceCoreAdapter;
import g.h.a.i;
import java.io.BufferedReader;
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.NoWhenBranchMatchedException;
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 c extends m implements Function1<IRequest, Response> {
    public c(Object obj) {
        super(1, obj, controlByodModeVolumeSystemServiceCoreAdapter.class, "controlByodModeVolume", "controlByodModeVolume(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 {
        VolumeControlEnum volumeControlEnum;
        UsbTypeEnum usbTypeEnum;
        IRequest iRequest2 = iRequest;
        o.f(iRequest2, "p0");
        controlByodModeVolumeSystemServiceCoreAdapter controlbyodmodevolumesystemservicecoreadapter = (controlByodModeVolumeSystemServiceCoreAdapter) this.receiver;
        Objects.requireNonNull(controlbyodmodevolumesystemservicecoreadapter);
        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 {
                controlByodModeVolumeSystemServiceCoreAdapter.a aVar = controlbyodmodevolumesystemservicecoreadapter.f4602b;
                o.f(strC, "json");
                o.f(aVar, "token");
                String str = strC.length() == 0 ? "{}" : strC;
                UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
                ByodModeVolumeControlBody byodModeVolumeControlBody = (ByodModeVolumeControlBody) ((IConverter) udiGlobal.get(e0.a(IConverter.class))).fromJson(str, aVar);
                o.f(iRequest2, "request");
                o.f(byodModeVolumeControlBody, "paramParse");
                ((IRequestTracker) udiGlobal.get(e0.a(IRequestTracker.class))).onParseRequestSuccess(iRequest2, null, strC, byodModeVolumeControlBody);
                SystemServiceCore systemServiceCore = controlbyodmodevolumesystemservicecoreadapter.a;
                String url = iRequest2.getUrl();
                Map<String, String> fields = iRequest2.getFields();
                o.f(byodModeVolumeControlBody, "body");
                o.f(url, "uri");
                o.f(fields, "fields");
                Objects.requireNonNull(systemServiceCore);
                int iOrdinal = byodModeVolumeControlBody.getControl().ordinal();
                if (iOrdinal == 0) {
                    volumeControlEnum = VolumeControlEnum.MIC_MUTE;
                } else if (iOrdinal == 1) {
                    volumeControlEnum = VolumeControlEnum.SPEAKER_MUTE;
                } else if (iOrdinal == 2) {
                    volumeControlEnum = VolumeControlEnum.VOLUME_UP;
                } else {
                    if (iOrdinal != 3) {
                        throw new NoWhenBranchMatchedException();
                    }
                    volumeControlEnum = VolumeControlEnum.VOLUME_DOWN;
                }
                int iOrdinal2 = byodModeVolumeControlBody.getType().ordinal();
                if (iOrdinal2 == 0) {
                    usbTypeEnum = UsbTypeEnum.USB_TYPE_B;
                } else {
                    if (iOrdinal2 != 1) {
                        throw new NoWhenBranchMatchedException();
                    }
                    usbTypeEnum = UsbTypeEnum.USB_TYPE_C;
                }
                int byodModeVolume = DeviceStatusManager.getInstance().setByodModeVolume(volumeControlEnum, usbTypeEnum);
                StringBuilder sbF = a.F("Byom[udi]: controlByodModeVolume: control = ");
                sbF.append(byodModeVolumeControlBody.getControl());
                sbF.append(", type = ");
                sbF.append(byodModeVolumeControlBody.getType());
                sbF.append(",result:");
                sbF.append(byodModeVolume);
                Log.d("SystemServiceCore", sbF.toString());
                return Response.INSTANCE.makeOkResponse();
            } catch (MissingFieldException e2) {
                o.f(iRequest2, "request");
                o.f(e2, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strC, e2);
                return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(a.i(e2, a.K("params ", strC, ", miss field : "))));
            } catch (Throwable th) {
                o.f(iRequest2, "request");
                o.f(th, "throwable");
                ((IRequestTracker) UdiGlobal.INSTANCE.get(e0.a(IRequestTracker.class))).onParseRequestFailed(iRequest2, null, strC, th);
                return Response.INSTANCE.makeErrorResponse(400, new Response.ErrorBody(a.t("params decode failed: ", strC)));
            }
        } catch (Throwable th2) {
            try {
                throw th2;
            } catch (Throwable th3) {
                i.E(bufferedReader, th2);
                throw th3;
            }
        }
    }
}