diff options
Diffstat (limited to 'plugins/alsa/alsa-api-mixer.c')
| -rw-r--r-- | plugins/alsa/alsa-api-mixer.c | 150 |
1 files changed, 150 insertions, 0 deletions
diff --git a/plugins/alsa/alsa-api-mixer.c b/plugins/alsa/alsa-api-mixer.c new file mode 100644 index 0000000..f1619c2 --- /dev/null +++ b/plugins/alsa/alsa-api-mixer.c @@ -0,0 +1,150 @@ +/* + * Copyright (C) 2018 "IoT.bzh" + * Author Fulup Ar Foll <fulup@iot.bzh> + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + +#define _GNU_SOURCE // needed for vasprintf + +#include "alsa-softmixer.h" +#include <string.h> + +// Fulup need to be cleanup with new controller version +extern Lua2cWrapperT Lua2cWrap; + +// API + +static void MixerApiVerbCB(AFB_ReqT request) { + json_object *responseJ, *backendJ = NULL, *frontendJ = NULL, *zonesJ = NULL, *streamsJ = NULL; + // retrieve action handle from request and execute the request + json_object *argsJ = afb_request_json(request); + SoftMixerHandleT *mixerHandle = (SoftMixerHandleT*) afb_request_get_vcbdata(request); + int error; + int close = 0; + + CtlSourceT *source = alloca(sizeof (CtlSourceT)); + source->uid = mixerHandle->uid; + source->api = request->dynapi; + source->request = request; + source->context = mixerHandle; + + error = wrap_json_unpack(argsJ, "{s?b s?o,s?o,s?o,s?o !}" + , "close", &close + , "backend", &backendJ + , "frontend", &frontendJ + , "zones", &zonesJ + , "streams", &streamsJ + ); + if (error) { + AFB_ReqFailF(request, "MixerApiVerbCB", "missing 'uid|backend|frontend|zones|streams' mixer=%s", json_object_get_string(argsJ)); + goto OnErrorExit; + } + + // Free attached resources and free mixer + if (close) { + AFB_ReqFailF(request, "MixerApiVerbCB", "(Fulup) Close action still to be done mixer=%s", json_object_get_string(argsJ)); + goto OnErrorExit; + } + + if (backendJ) { + error = SndBackend(source, backendJ); + if (error) goto OnErrorExit; + } + + if (frontendJ) { + error = SndFrontend(source, frontendJ); + if (error) goto OnErrorExit; + } + + if (zonesJ) { + error = SndZones(source, zonesJ); + if (error) goto OnErrorExit; + } + + if (streamsJ) { + error = SndStreams(source, streamsJ, &responseJ); + if (error) goto OnErrorExit; + } + + + AFB_ReqSucess(request, responseJ, mixerHandle->uid); + return; + +OnErrorExit: + return; +} + +CTLP_LUA2C(_mixer_new_, source, argsJ, responseJ) { + SoftMixerHandleT *mixerHandle = calloc(1, sizeof (SoftMixerHandleT)); + json_object *backendJ = NULL, *frontendJ = NULL, *zonesJ = NULL, *streamsJ = NULL; + int error; + assert(source->api); + + if (json_object_get_type(argsJ) != json_type_object) { + AFB_ApiError(source->api, "_mixer_new_: invalid object type= %s", json_object_get_string(argsJ)); + goto OnErrorExit; + } + + error = wrap_json_unpack(argsJ, "{ss,s?s,s?o,s?o,s?o,s?o !}" + , "uid", &mixerHandle->uid + , "info", &mixerHandle->info + , "backend", &backendJ + , "frontend", &frontendJ + , "zones", &zonesJ + , "streams", &streamsJ); + if (error) { + AFB_ApiNotice(source->api, "_mixer_new_ missing 'uid|backend|frontend|zones|streams' mixer=%s", json_object_get_string(argsJ)); + goto OnErrorExit; + } + + // make sure string do not get deleted + mixerHandle->uid = strdup(mixerHandle->uid); + if (mixerHandle->info)mixerHandle->info = strdup(mixerHandle->info); + + // create mixer verb within API. + error = afb_dynapi_add_verb(source->api, mixerHandle->uid, mixerHandle->info, MixerApiVerbCB, mixerHandle, NULL, 0); + if (error) { + AFB_ApiError(source->api, "_mixer_new_ mixer=%s fail to register API verb", mixerHandle->uid); + return -1; + } + + // make sure sub command get access to mixer handle + source->context = mixerHandle; + + if (backendJ) { + error = SndBackend(source, backendJ); + if (error) goto OnErrorExit; + } + + if (frontendJ) { + error = SndFrontend(source, frontendJ); + if (error) goto OnErrorExit; + } + + if (zonesJ) { + error = SndZones(source, zonesJ); + if (error) goto OnErrorExit; + } + + if (streamsJ) { + error = SndStreams(source, streamsJ, responseJ); + if (error) goto OnErrorExit; + } + + return 0; + +OnErrorExit: + return -1; +}
\ No newline at end of file |