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

import com.cvte.va.sdk.mica.api.DeviceStatusManager;
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.json.TypeToken;
import com.ifpdos.udi.sdk.service.sdk.log.IRequestTracker;
import com.ifpdos.udi.sdk.service.sdk.log.Log;
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.core.pc.EnableBody;
import g.f.c.b.a.pc.setMicMuteEnableAudioServiceCoreAdapter;
import g.f.c.b.a.pc.util.VaAudioUtil;
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.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;
import kotlinx.serialization.json.internal.AbstractJsonLexerKt;

/* JADX INFO: renamed from: g.f.c.b.a.a.o, 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\u0007\u0018\u0000 \f2\u00020\u0001:\u0005\f\r\u000e\u000f\u0010B\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\u0011"}, d2 = {"Lcom/ifpdos/udi/service/audio/pc/MicMuteEnableApi;", "", "receiver", "Lcom/ifpdos/udi/service/audio/pc/AudioServiceCore;", "(Lcom/ifpdos/udi/service/audio/pc/AudioServiceCore;)V", "api", "Lcom/ifpdos/udi/sdk/service/sdk/server/Api;", "getApi", "()Lcom/ifpdos/udi/sdk/service/sdk/server/Api;", "getApiList", "", "getStaticApiList", "Companion", "GetterRequest", "GetterResponse", "SetterRequest", "SetterResponse", "audio_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
public final class MicMuteEnableApi {
    public static final MicMuteEnableApi a = null;

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

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

    /* JADX INFO: renamed from: g.f.c.b.a.a.o$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, setMicMuteEnableAudioServiceCoreAdapter.class, "setMicMuteEnable", "setMicMuteEnable(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 {
            IRequest iRequest2 = iRequest;
            o.f(iRequest2, "p0");
            setMicMuteEnableAudioServiceCoreAdapter setmicmuteenableaudioservicecoreadapter = (setMicMuteEnableAudioServiceCoreAdapter) this.receiver;
            Objects.requireNonNull(setmicmuteenableaudioservicecoreadapter);
            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 {
                    setMicMuteEnableAudioServiceCoreAdapter.a aVar = setmicmuteenableaudioservicecoreadapter.f4279b;
                    o.f(strC, "json");
                    o.f(aVar, "token");
                    String str = strC.length() == 0 ? "{}" : strC;
                    UdiGlobal udiGlobal = UdiGlobal.INSTANCE;
                    EnableBody enableBody = (EnableBody) ((IConverter) udiGlobal.get(e0.a(IConverter.class))).fromJson(str, aVar);
                    o.f(iRequest2, "request");
                    o.f(enableBody, "paramParse");
                    ((IRequestTracker) udiGlobal.get(e0.a(IRequestTracker.class))).onParseRequestSuccess(iRequest2, null, strC, enableBody);
                    AudioServiceCore audioServiceCore = setmicmuteenableaudioservicecoreadapter.a;
                    String url = iRequest2.getUrl();
                    Map<String, String> fields = iRequest2.getFields();
                    o.f(enableBody, "body");
                    o.f(url, "uri");
                    o.f(fields, "fields");
                    Objects.requireNonNull(audioServiceCore);
                    VaAudioUtil vaAudioUtil = VaAudioUtil.a;
                    boolean enable = enableBody.getEnable();
                    int micMute = ((DeviceStatusManager) VaAudioUtil.f4290b.getValue()).setMicMute(enable);
                    Log.d$default(Log.INSTANCE, "VaAudioUtil", "setMicMute: [" + enable + "] -> [" + micMute + AbstractJsonLexerKt.END_LIST, null, 4, null);
                    return (micMute == 0 ? new d() : new d(Response.INSTANCE.getINTERNAL_SERVER_ERROR())).a;
                } 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(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(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;
                }
            }
        }
    }

    /* JADX INFO: renamed from: g.f.c.b.a.a.o$b */
    @Metadata(k = 3, mv = {1, 6, 0}, xi = 48)
    public /* synthetic */ class b extends m implements Function1<IRequest, Response> {
        public b(Object obj) {
            super(1, obj, isMicMuteEnableAudioServiceCoreAdapter.class, "isMicMuteEnable", "isMicMuteEnable(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) {
            IRequest iRequest2 = iRequest;
            o.f(iRequest2, "p0");
            isMicMuteEnableAudioServiceCoreAdapter ismicmuteenableaudioservicecoreadapter = (isMicMuteEnableAudioServiceCoreAdapter) this.receiver;
            Objects.requireNonNull(ismicmuteenableaudioservicecoreadapter);
            o.f(iRequest2, "request");
            AudioServiceCore audioServiceCore = ismicmuteenableaudioservicecoreadapter.a;
            String url = iRequest2.getUrl();
            Map<String, String> fields = iRequest2.getFields();
            o.f(url, "uri");
            o.f(fields, "fields");
            Objects.requireNonNull(audioServiceCore);
            VaAudioUtil vaAudioUtil = VaAudioUtil.a;
            int micMute = ((DeviceStatusManager) VaAudioUtil.f4290b.getValue()).getMicMute();
            Log.d$default(Log.INSTANCE, "VaAudioUtil", g.a.a.a.a.l("isMicMute -> ", micMute), null, 4, null);
            EnableBody enableBody = new EnableBody(micMute == 1);
            o.f(enableBody, "response");
            p pVar = new p();
            o.f(pVar, "token");
            return Response.INSTANCE.makeOkResponse(((IConverter) UdiGlobal.INSTANCE.get(e0.a(IConverter.class))).toJson(enableBody, pVar));
        }
    }

    /* JADX INFO: renamed from: g.f.c.b.a.a.o$c */
    @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/audio/pc/MicMuteEnableApi$Companion$TOKEN$1", "Lcom/ifpdos/udi/sdk/service/sdk/json/TypeToken;", "Lcom/ifpdos/udi/service/core/pc/EnableBody;", "audio_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
    public static final class c extends TypeToken<EnableBody> {
    }

    /* JADX INFO: renamed from: g.f.c.b.a.a.o$d */
    @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/audio/pc/MicMuteEnableApi$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;", "audio_release"}, k = 1, mv = {1, 6, 0}, xi = 48)
    public static final class d {
        public final Response a;

        public d() {
            this.a = Response.INSTANCE.makeOkResponse();
        }

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

    public MicMuteEnableApi(AudioServiceCore audioServiceCore) {
        o.f(audioServiceCore, "receiver");
        this.f4293c = new Api("v1/audio/pc/mic/mute/enable", true, 0, null, new a(new setMicMuteEnableAudioServiceCoreAdapter(audioServiceCore)), 3, new b(new isMicMuteEnableAudioServiceCoreAdapter(audioServiceCore)), 3, false, 8, null);
    }
}