Initial version of HAL with Set/Get operation

3 files changed, 139 insertions, 115 deletions

diff --git a/HAL-afb/HAL-interface/hal-interface.c b/HAL-afb/HAL-interface/hal-interface.c
index 1f39a81..f4fc8df 100644
--- a/HAL-afb/HAL-interface/hal-interface.c
+++ b/HAL-afb/HAL-interface/hal-interface.c
@@ -52,12 +52,10 @@ STATIC void halSubscribe(afb_req request) {
     }
 }
 
-
-
 // Map HAL ctlName to ctlLabel
 STATIC int halCtlStringToIndex (const char* label) {
 
-    for (int idx = 0;   halCtls[idx].ctl.numid; idx++) {
+    for (int idx = 0;  halCtls[idx].tag != EndHalCrlTag; idx++) {
        if (!strcmp (halCtls[idx].label, label)) return idx;
     }
     
@@ -67,7 +65,7 @@ STATIC int halCtlStringToIndex (const char* label) {
 
 STATIC int halCtlTagToIndex (halCtlsEnumT tag) {
 
-    for (int idx = 0;  halCtls[idx].ctl.numid; idx++) {
+    for (int idx = 0;  halCtls[idx].tag != EndHalCrlTag; idx++) {
        if (halCtls[idx].tag == tag) return idx;
     }
     
@@ -93,122 +91,98 @@ PUBLIC void halListCtls(afb_req request) {
     afb_req_success (request, ctlsHalJ, NULL);
 }
 
-
 STATIC int halGetCtlIndex (afb_req request, struct json_object*ctlInJ) {
     struct json_object *tmpJ;
-    int tag, index;
+    int tag, index, done;
 
     // check 1st short command mode [tag1, tag2, ...]
-    tag = json_object_get_type (ctlInJ);
-    
-    if (!tag) {
-        json_object_object_get_ex (ctlInJ, "tag" , &tmpJ);
-        tag = json_object_get_int(tmpJ);
-    }
-    
-    if (tag) {
-        index = halCtlTagToIndex((halCtlsEnumT) tag);
-    } else {
-        // tag was not provided let's try label
-        const char *label;
+    enum json_type jtype = json_object_get_type (ctlInJ);
+    switch (jtype) {
+        case json_type_array: 
+            tmpJ = json_object_array_get_idx (ctlInJ, 0);
+            tag = json_object_get_int(tmpJ);
+            index = halCtlTagToIndex(tag);  
+            break;
+            
+        case json_type_int: 
+            tag = json_object_get_int(ctlInJ);
+            index = halCtlTagToIndex(tag);  
+            break;
         
-        json_object_object_get_ex (ctlInJ, "label" , &tmpJ);
-        label = json_object_get_string(tmpJ);
-        index = halCtlStringToIndex(label);
+        case json_type_object:
+            done = json_object_object_get_ex (ctlInJ, "tag" , &tmpJ);
+            if (done) {
+                tag = json_object_get_int(tmpJ);
+                index = halCtlTagToIndex(tag);  
+            } else {
+                const char *label;
+                done = json_object_object_get_ex (ctlInJ, "label" , &tmpJ);
+                if (!done) goto OnErrorExit;
+                label = json_object_get_string(tmpJ);
+                index = halCtlStringToIndex(label);
+            }
+            break;
+        
+        default: 
+            goto OnErrorExit;
     }
+    
 
-    if (index < 0) {
-        afb_req_fail_f(request, "ctl-invalid", "No Label/Tag given ctl='%s'", json_object_get_string(ctlInJ));
-        goto OnErrorExit;                
-    }
+    if (index < 0) goto OnErrorExit;
     
     // return corresponding lowlevel numid to querylist
     return index;
     
     OnErrorExit:
+        afb_req_fail_f(request, "ctl-invalid", "No Label/Tag given ctl='%s'", json_object_get_string(ctlInJ));
         return -1;
 } 
 
-// HAL normalise volume values to 0-100%
-STATIC struct json_object *UnNormaliseValue(const alsaHalCtlMapT *halCtls,  struct json_object *valuesJ) {
-    int length;
-
-    // assert response as the right length    
-    length = json_object_array_length(valuesJ);
-    if (length != halCtls->count) {
-        AFB_WARNING ("UnNormaliseValue invalid ctl='%s' values count=%d len=%d", halCtls->name, halCtls->count, length);
-        return NULL;
-    }
-    
-    json_object *normalisedJ= json_object_new_array();
-    for (int idx=0; idx < halCtls->count; idx++) {
-        int value;
-        
-        // use last value in array when number of values does not match with actual ctl count
-        if (idx < length) {
-            json_object *valueJ = json_object_array_get_idx (valuesJ, idx);
-            value = json_object_get_int(valueJ);
-            
-            // cleanup and normalise value
-            if (value > halCtls->maxval) value= halCtls->maxval;
-            if (value < halCtls->minval) value= halCtls->minval;
-
-            // If Integer move from 0-100% to effective value
-            if (halCtls->type == SND_CTL_ELEM_TYPE_INTEGER) {
-                value = (value * (halCtls->maxval-halCtls->minval))/100;
-            } 
-        }
-        
-        // add unnormalised value into response
-        json_object_array_add(normalisedJ, json_object_new_int(value));  
-    }
-    
-    return (normalisedJ);
-}
-
 
 // Translate high level control to low level and call lower layer
 PUBLIC void halSetCtls(afb_req request) {
-    int err, index;
+    int err, done, index;
     struct json_object *ctlsInJ, *ctlsOutJ, *queryJ, *valuesJ, *responseJ;
 
     // get query from request
     ctlsInJ = afb_req_json(request);
-    ctlsOutJ = json_object_new_array();
     
     switch (json_object_get_type(ctlsInJ)) {
         case json_type_object: {
+            ctlsOutJ = json_object_new_object();
+            
             // control is in literal form {tag=xxx, label=xxx, value=xxxx}
             index = halGetCtlIndex (request, ctlsInJ);
-            if (index <=0) goto OnErrorExit;
+            if (index < 0) goto OnErrorExit;
             
-            err= json_object_object_get_ex (ctlsInJ, "value" , &valuesJ);
-            if (err) {
+            done= json_object_object_get_ex (ctlsInJ, "val" , &valuesJ);
+            if (!done) {
                 afb_req_fail_f(request, "ctl-invalid", "No val=[val1, ...] ctl='%s'", json_object_get_string(ctlsInJ));
                 goto OnErrorExit;                                
             }
             
-            json_object_array_add (ctlsOutJ, json_object_new_int(halCtls[index].ctl.numid));
-            json_object_array_add (ctlsOutJ, UnNormaliseValue (&halCtls[index].ctl, valuesJ));                
+            json_object_object_add (ctlsOutJ, "id", json_object_new_int(halCtls[index].ctl.numid));
+            json_object_object_add (ctlsOutJ,"val", SetGetNormaliseVolumes (ACTION_SET, &halCtls[index].ctl, valuesJ));                
             break;
         }
         
         case json_type_array: {
+            ctlsOutJ = json_object_new_array();
             
             for (int idx= 0; idx < json_object_array_length (ctlsInJ); idx++) {
                 struct json_object *ctlInJ = json_object_array_get_idx (ctlsInJ, idx);
                 index= halGetCtlIndex (request, ctlInJ);
-                if (index<=0) goto OnErrorExit;
+                if (index < 0) goto OnErrorExit;
 
-                err= json_object_object_get_ex (ctlInJ, "value" , &valuesJ);
-                if (err) {
+                done= json_object_object_get_ex (ctlInJ, "val" , &valuesJ);
+                if (!done) {
                     afb_req_fail_f(request, "ctl-invalid", "No val=[val1, ...] ctl='%s'", json_object_get_string(ctlsInJ));
                     goto OnErrorExit;                                
                 }
                 // let's create alsa low level set control request
-                struct json_object *ctlOutJ = json_object_new_array();
-                json_object_array_add (ctlOutJ, json_object_new_int(halCtls[index].ctl.numid));
-                json_object_array_add (ctlOutJ, UnNormaliseValue (&halCtls[index].ctl, valuesJ));                
+                struct json_object *ctlOutJ = json_object_new_object();
+                json_object_object_add (ctlOutJ, "id", json_object_new_int(halCtls[index].ctl.numid));
+                json_object_object_add (ctlOutJ, "val", SetGetNormaliseVolumes (ACTION_SET, &halCtls[index].ctl, valuesJ));                
                 
                 json_object_array_add (ctlsOutJ, ctlOutJ);
             }
@@ -225,19 +199,12 @@ PUBLIC void halSetCtls(afb_req request) {
     json_object_object_add(queryJ, "devid", json_object_new_string (halDevid));
     json_object_object_add(queryJ, "numid", ctlsOutJ);
 
-    err= afb_service_call_sync("alsacore", "setctls", queryJ, &responseJ);
+    err= afb_service_call_sync("alsacore", "setctl", queryJ, &responseJ);
     if (err) {
         afb_req_fail_f(request, "subcall:alsacore/setctl", "%s", json_object_get_string(responseJ));
         goto OnErrorExit;        
     }
     
-    // Let ignore info data if any and keep on response
-    json_object_object_get_ex (responseJ, "response", &responseJ);
-    
-    // map back low level response to HAL ctl with normalised values
-    //struct json_object *halResponse =  CtlSetPrepareResponse(request, responseJ);
-    //if (!halResponse) goto OnErrorExit;
-   
     afb_req_success (request, NULL, NULL);
     return;
 
@@ -246,7 +213,7 @@ OnErrorExit:
 };
 
 // Remap low level controls into HAL hight level ones
-STATIC json_object *CtlGetPrepareResponse(afb_req request, struct json_object *ctlsJ) {
+STATIC json_object *HalGetPrepareResponse(afb_req request, struct json_object *ctlsJ) {
     struct json_object *halResponseJ;
 
     // make sure return controls have a valid type
@@ -264,7 +231,7 @@ STATIC json_object *CtlGetPrepareResponse(afb_req request, struct json_object *c
         int numid;
 
         sndCtlJ = json_object_array_get_idx(ctlsJ, idx);
-        if (!json_object_object_get_ex(sndCtlJ, "numid", &numidJ) ||  !json_object_object_get_ex(sndCtlJ, "val", &valJ)) {
+        if (!json_object_object_get_ex(sndCtlJ, "id", &numidJ) ||  !json_object_object_get_ex(sndCtlJ, "val", &valJ)) {
             afb_req_fail_f(request, "ctl-invalid", "Invalid Control return from alsa/getcontrol ctl=%s", json_object_get_string(sndCtlJ));
             goto OnErrorExit;
         }
@@ -279,7 +246,7 @@ STATIC json_object *CtlGetPrepareResponse(afb_req request, struct json_object *c
                 struct json_object *halCtlJ = json_object_new_object();
                 json_object_object_add(halCtlJ, "label", json_object_new_string(halCtls[idx].label)); // idx+1 == HAL/NUMID
                 json_object_object_add(halCtlJ, "tag"  , json_object_new_int(halCtls[idx].tag)); // idx+1 == HAL/NUMID
-                json_object_object_add(halCtlJ, "val"  , GetNormaliseVolume(&halCtls[idx].ctl, valJ));
+                json_object_object_add(halCtlJ, "val"  , SetGetNormaliseVolumes(ACTION_GET, &halCtls[idx].ctl, valJ));
                 json_object_array_add(halResponseJ, halCtlJ);
                 break;
             }           
@@ -308,7 +275,7 @@ PUBLIC void halGetCtls(afb_req request) {
         case json_type_object: {
 
             index = halGetCtlIndex (request, ctlsInJ);
-            if (index <=0) goto OnErrorExit;
+            if (index < 0) goto OnErrorExit;
             json_object_array_add (ctlsOutJ, json_object_new_int(halCtls[index].ctl.numid));
             break;
         }
@@ -318,7 +285,7 @@ PUBLIC void halGetCtls(afb_req request) {
             for (int idx= 0; idx < json_object_array_length (ctlsInJ); idx++) {
                 struct json_object *ctlInJ = json_object_array_get_idx (ctlsInJ, idx);
                 index= halGetCtlIndex (request, ctlInJ);
-                if (index<=0) goto OnErrorExit;
+                if (index < 0) goto OnErrorExit;
                 json_object_array_add (ctlsOutJ, json_object_new_int(halCtls[index].ctl.numid));
             }
             break;
@@ -344,7 +311,7 @@ PUBLIC void halGetCtls(afb_req request) {
     json_object_object_get_ex (responseJ, "response", &responseJ);
     
     // map back low level response to HAL ctl with normalised values
-    struct json_object *halResponse =  CtlGetPrepareResponse(request, responseJ);
+    struct json_object *halResponse =  HalGetPrepareResponse(request, responseJ);
     if (!halResponse) goto OnErrorExit;
    
     afb_req_success (request, halResponse, NULL);
@@ -361,7 +328,7 @@ PUBLIC void halServiceEvent(const char *evtname, struct json_object *eventJ) {
     
     AFB_NOTICE("halServiceEvent evtname=%s [msg=%s]", evtname, json_object_get_string(eventJ));
     
-    json_object_object_get_ex (eventJ, "values" , &valuesJ);
+    json_object_object_get_ex (eventJ, "val" , &valuesJ);
     if (!valuesJ) {
         AFB_ERROR("halServiceEvent novalues: evtname=%s [msg=%s]", evtname, json_object_get_string(eventJ));
         return;
@@ -387,7 +354,7 @@ STATIC int UpdateOneSndCtl (alsaHalCtlMapT *ctl, struct json_object *sndCtlJ) {
     json_object_object_get_ex (sndCtlJ, "name" , &tmpJ);
     ctl->name  = (char*)json_object_get_string(tmpJ);
     
-    json_object_object_get_ex (sndCtlJ, "numid" , &tmpJ);
+    json_object_object_get_ex (sndCtlJ, "id" , &tmpJ);
     ctl->numid  = json_object_get_int(tmpJ);
     
     // make sure we face a valid Alsa Low level ctl
@@ -547,6 +514,7 @@ PUBLIC afb_verb_v2 halServiceApi[] = {
     { .verb = "ping",     .callback = pingtest},
     { .verb = "ctl-list", .callback = halListCtls},
     { .verb = "ctl-get",  .callback = halGetCtls},
+    { .verb = "ctl-set",  .callback = halSetCtls},
     { .verb = "evt-sub",  .callback = halSubscribe},
     { .verb = NULL} /* marker for end of the array */
 };
diff --git a/HAL-afb/HAL-interface/hal-interface.h b/HAL-afb/HAL-interface/hal-interface.h
index afe480e..c31c145 100644
--- a/HAL-afb/HAL-interface/hal-interface.h
+++ b/HAL-afb/HAL-interface/hal-interface.h
@@ -23,6 +23,11 @@
 
 #include "audio-interface.h"
 
+typedef enum {
+    ACTION_SET,
+    ACTION_GET
+} ActionSetGetT;
+
 typedef struct {
     int min;
     int max;
@@ -69,7 +74,7 @@ PUBLIC void halServiceEvent(const char *evtname, struct json_object *object);
 PUBLIC int  halServiceInit (const char *apiPrefix, alsaHalSndCardT *alsaHalSndCard);
 
 // hal-volmap.c
-PUBLIC struct json_object *GetNormaliseVolume(const alsaHalCtlMapT *halCtls,  struct json_object *valuesJ);
+PUBLIC struct json_object *SetGetNormaliseVolumes(ActionSetGetT action, const alsaHalCtlMapT *halCtls,  struct json_object *valuesJ);
 
 
 #endif /* SHAREHALLIB_H */
diff --git a/HAL-afb/HAL-interface/hal-volmap.c b/HAL-afb/HAL-interface/hal-volmap.c
index de99974..2b619fd 100644
--- a/HAL-afb/HAL-interface/hal-volmap.c
+++ b/HAL-afb/HAL-interface/hal-volmap.c
@@ -24,26 +24,30 @@
 
 
 typedef enum {  
-   DB_NORMALIZE_LINEAR,
-   DB_NORMALIZE_MATH,           
+   NORMALIZE_NONE=0,  
+   NORMALIZE_DB_LINEAR,
+   NORMALIZE_DB_MATH,           
+   NORMALIZE_LINEAR,           
 } enumRandeModeDB_T;
 
+
 // Return Value express from 0-100%
 STATIC int dbNormalizeVal (enumRandeModeDB_T normaliseMode, const alsaHalDBscaleT *dbscale, int value) {
     double normalized, min_norm;
-    
+
     // To get real DB from TLV DB values should be divided by 100
     switch (normaliseMode) {
-        case DB_NORMALIZE_LINEAR:
-            normalized = ((double)(value-dbscale->min)/(double)(dbscale->max-dbscale->min))*100;
+        case NORMALIZE_DB_LINEAR:
+            normalized = ((double)(value-dbscale->min)/(double)(dbscale->max-dbscale->min));
             break;
             
-        case  DB_NORMALIZE_MATH:
+        case  NORMALIZE_DB_MATH:
             normalized = exp10((double)(value - dbscale->max) / 6000.0);
             if (dbscale->min != SND_CTL_TLV_DB_GAIN_MUTE) {
-                    min_norm = exp10((double)(dbscale->min - dbscale->max) / 6000.0);
+                    min_norm = exp10((double)(dbscale->min - dbscale->max) / 20);
                     normalized = (normalized - min_norm) / (1 - min_norm);
             }
+            
             break;
             
         default:
@@ -54,35 +58,82 @@ STATIC int dbNormalizeVal (enumRandeModeDB_T normaliseMode, const alsaHalDBscale
 }
 
 // HAL normalise volume values to 0-100%
-PUBLIC struct json_object *GetNormaliseVolume(const alsaHalCtlMapT *halCtls,  struct json_object *valuesJ) {
-    int useNormalizeDB;
+PUBLIC struct json_object *SetGetNormaliseVolumes(ActionSetGetT action, const alsaHalCtlMapT *halCtls,  struct json_object *valuesJ) {
+    enumRandeModeDB_T useNormalizeDB;
+    int length;
+
+    // If Integer look for DBscale
+    if (halCtls->type == SND_CTL_ELEM_TYPE_INTEGER) {
     
-    // If not valid db_scale let's use raw_scale
-    if (!halCtls->dbscale || (halCtls->dbscale->min >= halCtls->dbscale->max)) {
+        // If not valid db_scale let's use raw_scale
+        if (!halCtls->dbscale || (halCtls->dbscale->min >= halCtls->dbscale->max)) {
        
         // dbscale is invalid let's try raw range
         if (halCtls->minval >= halCtls->maxval) goto ExitOnError;
         
         // Use Raw Scale Model
-        useNormalizeDB= 0;
+        useNormalizeDB= NORMALIZE_LINEAR;
         
-    } else { // db_scale looks OK let's use it
-        if ((halCtls->dbscale->max - halCtls->dbscale->min) <= MAX_LINEAR_DB_SCALE * 100) useNormalizeDB= DB_NORMALIZE_LINEAR;
-        else useNormalizeDB =  DB_NORMALIZE_MATH;
-            
-    }
+        } else { // db_scale looks OK let's use it
+            if ((halCtls->dbscale->max - halCtls->dbscale->min) <= MAX_LINEAR_DB_SCALE * 100) useNormalizeDB= NORMALIZE_DB_LINEAR;
+            else useNormalizeDB = NORMALIZE_LINEAR; // Fulup not sure how to handle this useNormalizeDB=NORMALIZE_DB_MATH;            
+        }
+    } else useNormalizeDB= NORMALIZE_NONE;
+    
     
     // loop on values to normalise
-    int length = json_object_array_length(valuesJ);   
+    enum json_type jtype=json_object_get_type(valuesJ);
+    if (jtype == json_type_array) length = json_object_array_length(valuesJ);   
+    else length = 1;
+    
     json_object *normalisedJ= json_object_new_array();
-    for (int idx=0; idx <length; idx++) {
-        json_object *valueJ = json_object_array_get_idx (valuesJ, idx);
-        int value = json_object_get_int(valueJ);
+    for (int idx=0; idx < length; idx++) {
+        int value;
+        
+        if (jtype == json_type_array) {
+            json_object *valueJ = json_object_array_get_idx (valuesJ, idx);
+            value = json_object_get_int(valueJ);
+        } else {
+            value = json_object_get_int(valuesJ);
+        }
                
         // If Integer scale to 0/100
         if (halCtls->type == SND_CTL_ELEM_TYPE_INTEGER) {
-            if (useNormalizeDB) value = dbNormalizeVal (useNormalizeDB, halCtls->dbscale, value);
-            else value = 100* (value - halCtls->minval) / (halCtls->maxval - halCtls->minval);
+            
+            switch (action) {
+                    
+                case ACTION_GET:
+                    switch (useNormalizeDB) {                            
+                        case NORMALIZE_LINEAR:
+                            value = 100* (value - halCtls->minval) / (halCtls->maxval - halCtls->minval);
+                            break;
+                        case NORMALIZE_DB_MATH: //ToBeDone
+                            value = dbNormalizeVal (useNormalizeDB, halCtls->dbscale, value);
+                            break;
+                        case NORMALIZE_NONE: 
+                        default:
+                            value = value;
+                    }
+                    break;
+                    
+                case ACTION_SET:    
+                    switch (useNormalizeDB) {                            
+                        case NORMALIZE_LINEAR:
+                            value = (value * (halCtls->maxval - halCtls->minval))/100;
+                            break;
+                        case NORMALIZE_DB_MATH: //ToBeDone
+                            value = dbNormalizeVal (useNormalizeDB, halCtls->dbscale, value);
+                            break;
+                        case NORMALIZE_NONE: 
+                        default:
+                            value = value;
+                    }
+                    break;
+                    
+                default: 
+                    AFB_NOTICE ("SetGetNormaliseVolumes: invalid action value=%d", (int)action);
+                    goto ExitOnError;    
+            }
         } 
         
         json_object_array_add(normalisedJ, json_object_new_int(value));