X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=plugins%2Faudio%2Faudio-api.c;h=74a1be95b552734860f987d13910afc86b315292;hb=0d170147150b90678225b55548215d09d8273e6d;hp=9d4f3cb6c39cfa4ee1cf6d75208cb5f137ee406c;hpb=e2d857c5f05f84de8e2642ff9272a80ea9e5fed6;p=src%2Fapp-framework-binder.git diff --git a/plugins/audio/audio-api.c b/plugins/audio/audio-api.c index 9d4f3cb6..74a1be95 100644 --- a/plugins/audio/audio-api.c +++ b/plugins/audio/audio-api.c @@ -1,6 +1,6 @@ /* * Copyright (C) 2015 "IoT.bzh" - * Author "Fulup Ar Foll" + * Author "Manuel Bachmann" * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by @@ -16,36 +16,187 @@ * along with this program. If not, see . */ +#include "audio-api.h" +#include "audio-alsa.h" -#include "local-def.h" -STATIC json_object* wrongApi (AFB_request *request, void* handle) { - int zero=0; - int bug=1234; - int impossible; +/* ------ LOCAL HELPER FUNCTIONS --------- */ + +/* private client context creation ; default values */ +STATIC audioCtxHandleT* initAudioCtx () { + + audioCtxHandleT *actx; + + actx = malloc (sizeof(audioCtxHandleT)); + actx->idx = -1; + actx->volume = 25; + actx->channels = 2; + actx->mute = 0; + + return actx; +} + +STATIC AFB_error releaseAudio (audioCtxHandleT *actx) { + + /* power it off */ + _alsa_free (actx->idx); + + /* clean client context */ + actx->idx = -1; + + return AFB_SUCCESS; +} + +/* called when client session dies [e.g. client quits for more than 15mns] */ +STATIC json_object* freeAudio (AFB_clientCtx *client) { + + releaseAudio (client->ctx); + free (client->ctx); - impossible=bug/zero; + return jsonNewMessage (AFB_SUCCESS, "Released radio and client context"); +} + + +/* ------ PUBLIC PLUGIN FUNCTIONS --------- */ + +STATIC json_object* init (AFB_request *request) { /* AFB_SESSION_CREATE */ + + audioCtxHandleT *actx; + json_object *jresp; + int idx; + + /* create a private client context */ + actx = initAudioCtx(); + request->client->ctx = (audioCtxHandleT*)actx; + + _alsa_init("default", actx); + + jresp = json_object_new_object(); + json_object_object_add (jresp, "token", json_object_new_string (request->client->token)); + return jresp; +} + +STATIC json_object* volume (AFB_request *request) { /* AFB_SESSION_CHECK */ + + audioCtxHandleT *actx = (audioCtxHandleT*)request->client->ctx; + const char *value = getQueryValue (request, "value"); + json_object *jresp; + int volume; + char volume_str[256]; + + /* no "?value=" parameter : return current state */ + if (!value) { + actx->volume = _alsa_get_volume (actx->idx); + snprintf (volume_str, sizeof(volume_str), "%d", actx->volume); + jresp = json_object_new_object(); + json_object_object_add (jresp, "volume", json_object_new_string(volume_str)); + } + + /* "?value=" parameter, set volume */ + else { + volume = atoi (value); + if (100 < volume < 0) { + request->errcode = MHD_HTTP_SERVICE_UNAVAILABLE; + return (jsonNewMessage (AFB_FAIL, "Volume must be between 0 and 100")); + } + actx->volume = volume; + _alsa_set_volume (actx->idx, actx->volume); + + snprintf (volume_str, sizeof(volume_str), "%d", actx->volume); + jresp = json_object_new_object(); + json_object_object_add (jresp, "volume", json_object_new_string(volume_str)); + } + + return jresp; +} + +STATIC json_object* channels (AFB_request *request) { /* AFB_SESSION_CHECK */ + + audioCtxHandleT *actx = (audioCtxHandleT*)request->client->ctx; + const char *value = getQueryValue (request, "value"); + json_object *jresp = json_object_new_object(); + char channels_str[256]; + + /* no "?value=" parameter : return current state */ + if (!value) { + snprintf (channels_str, sizeof(channels_str), "%d", actx->channels); + json_object_object_add (jresp, "channels", json_object_new_string (channels_str)); + } + + /* "?value=" parameter, set channels */ + else { + actx->channels = atoi (value); + _alsa_set_channels (actx->idx, actx->channels); + + snprintf (channels_str, sizeof(channels_str), "%d", actx->channels); + json_object_object_add (jresp, "channels", json_object_new_string (channels_str)); + } + + return jresp; } +STATIC json_object* mute (AFB_request *request) { /* AFB_SESSION_CHECK */ + + audioCtxHandleT *actx = (audioCtxHandleT*)request->client->ctx; + const char *value = getQueryValue (request, "value"); + json_object *jresp = json_object_new_object(); + /* no "?value=" parameter : return current state */ + if (!value) { + actx->mute = _alsa_get_mute (actx->idx); + actx->mute ? + json_object_object_add (jresp, "mute", json_object_new_string ("on")) + : json_object_object_add (jresp, "mute", json_object_new_string ("off")); + } -STATIC struct { - void * somedata; -} handle; + /* "?value=" parameter is "1" or "on" */ + else if ( atoi(value) == 1 || !strcasecmp(value, "on") ) { + actx->mute = 1; + _alsa_set_mute (actx->idx, actx->mute); + json_object_object_add (jresp, "mute", json_object_new_string ("on")); + } -STATIC AFB_restapi pluginApis[]= { - {"ping" , AFB_SESSION_NONE, (AFB_apiCB)apiPingTest,"Ping Application Framework"}, - {"error" , AFB_SESSION_NONE, (AFB_apiCB)wrongApi , "Ping Application Framework"}, + /* "?value=" parameter is "0" or "off" */ + else if ( atoi(value) == 0 || !strcasecmp(value, "off") ) { + actx->mute = 0; + _alsa_set_mute (actx->idx, actx->mute); + json_object_object_add (jresp, "mute", json_object_new_string ("off")); + } + + return jresp; +} + +STATIC json_object* refresh (AFB_request *request) { /* AFB_SESSION_RENEW */ + json_object *jresp = json_object_new_object(); + json_object_object_add(jresp, "token", json_object_new_string (request->client->token)); + return jresp; +} + +STATIC json_object* ping (AFB_request *request) { /* AFB_SESSION_NONE */ + return jsonNewMessage(AFB_SUCCESS, "Ping Binder Daemon - Radio API"); +} + + +STATIC AFB_restapi pluginApis[]= { + {"init" , AFB_SESSION_CREATE, (AFB_apiCB)init , "Audio API - init"}, + {"volume" , AFB_SESSION_CHECK, (AFB_apiCB)volume , "Audio API - volume"}, + {"channels", AFB_SESSION_CHECK, (AFB_apiCB)channels , "Audio API - channels"}, + {"mute" , AFB_SESSION_CHECK, (AFB_apiCB)mute , "Audio API - mute"}, + {"refresh", AFB_SESSION_RENEW, (AFB_apiCB)refresh , "Audio API - refresh"}, + {"ping" , AFB_SESSION_NONE, (AFB_apiCB)ping , "Audio API - ping"}, {NULL} }; -PUBLIC AFB_plugin *alsaRegister () { - AFB_plugin *plugin = malloc (sizeof (AFB_plugin)); - plugin->type = AFB_PLUGIN_JSON; - plugin->info = "Application Framework Binder Service"; - plugin->prefix= "alsa"; - plugin->apis = pluginApis; +PUBLIC AFB_plugin *audioRegister () { + AFB_plugin *plugin = malloc (sizeof(AFB_plugin)); + plugin->type = AFB_PLUGIN_JSON; + plugin->info = "Application Framework Binder - Audio plugin"; + plugin->prefix = "audio"; + plugin->apis = pluginApis; + + plugin->freeCtxCB = freeAudio; + return (plugin); -}; \ No newline at end of file +};