Initial version with dynamic APIs

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