summaryrefslogtreecommitdiffstats
path: root/src/ahl-policy-utils.c
diff options
context:
space:
mode:
authorTai Vuong <tvuong@audiokinetic.com>2017-10-27 21:40:20 -0400
committerTai Vuong <tvuong@audiokinetic.com>2017-10-27 21:40:20 -0400
commit8a584f01b46d251fdc5de8b071eff755d99f0090 (patch)
tree625bfb4d66933b8fd18428027aa38c8a708368ce /src/ahl-policy-utils.c
parent9b7e1d0361d1a5eee415e453ae79925084552c68 (diff)
Add JSON object parameters for policy functions call, fix various bug and code stabilisation
Diffstat (limited to 'src/ahl-policy-utils.c')
-rw-r--r--src/ahl-policy-utils.c312
1 files changed, 312 insertions, 0 deletions
diff --git a/src/ahl-policy-utils.c b/src/ahl-policy-utils.c
new file mode 100644
index 0000000..52c5862
--- /dev/null
+++ b/src/ahl-policy-utils.c
@@ -0,0 +1,312 @@
+/*
+ * Copyright (C) 2017 "Audiokinetic Inc"
+ *
+ * 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.
+ */
+
+#include "ahl-policy-utils.h"
+#include "wrap-json.h"
+#include <json-c/json.h>
+#include <glib.h>
+
+void Add_Endpoint_Property_Double( EndpointInfoT * io_pEndpointInfo, char * in_pPropertyName, double in_dPropertyValue)
+{
+ json_object * propValueJ = json_object_new_double(in_dPropertyValue);
+ g_hash_table_insert(io_pEndpointInfo->pPropTable, in_pPropertyName, propValueJ);
+}
+
+
+void Add_Endpoint_Property_Int( EndpointInfoT * io_pEndpointInfo, char * in_pPropertyName, int in_iPropertyValue)
+{
+ json_object * propValueJ = json_object_new_int(in_iPropertyValue);
+ g_hash_table_insert(io_pEndpointInfo->pPropTable, in_pPropertyName, propValueJ);
+}
+
+void Add_Endpoint_Property_String( EndpointInfoT * io_pEndpointInfo, char * in_pPropertyName, const char * in_pPropertyValue)
+{
+ json_object * propValueJ = json_object_new_string(in_pPropertyValue);
+ g_hash_table_insert(io_pEndpointInfo->pPropTable, in_pPropertyName, propValueJ);
+}
+
+int PolicyCtxStructToJSON(AHLPolicyCtxT * pPolicyCtx, json_object **ppPolicyCxtJ)
+{
+ if(pPolicyCtx == NULL)
+ {
+ AFB_ERROR("Policy context is NULL");
+ return AHL_FAIL;
+ }
+
+ //Create json object for HALList
+ json_object *HallListJ = json_object_new_array();
+ for(int i=0; i<pPolicyCtx->pHALList->len; i++)
+ {
+ char *hallname = g_ptr_array_index(pPolicyCtx->pHALList, i);
+ json_object *hallNameJ = json_object_new_string(hallname);
+ json_object_array_add(HallListJ, hallNameJ);
+ }
+
+ int err = wrap_json_pack(ppPolicyCxtJ, "{s:i,s:o}",
+ "number_roles", (int)g_hash_table_size(pPolicyCtx->pRoleInfo),
+ "halllist", HallListJ);
+ if (err) {
+ AFB_ERROR("Unable to pack JSON endpoint, =%s", wrap_json_get_error_string(err));
+ }
+
+ return AHL_SUCCESS;
+}
+
+
+ int PolicyCtxJSONToStruct(json_object *CtxJ, int *pNbAudioRole, GPtrArray *pHALList)
+{
+ if(CtxJ == NULL || pHALList == NULL)
+ {
+ AFB_ERROR("Invalid arguments to PolicyCtxJSONToStruct");
+ return AHL_FAIL;
+ }
+
+ json_object *HallListJ = NULL;
+ int err = wrap_json_unpack(CtxJ, "{s:i, s:o}",
+ "number_roles", &pNbAudioRole,
+ "halllist", &HallListJ);
+ if (err) {
+ AFB_ERROR("Unable to unpack JSON endpoint, =%s", wrap_json_get_error_string(err));
+ return AHL_FAIL;
+ }
+
+ if(HallListJ)
+ {
+ int nbHall = json_object_array_length(HallListJ);
+ //Create HallList
+ for(int i=0; i<nbHall; i++)
+ {
+ char * pHAL = NULL;
+ json_object * jHAL = json_object_array_get_idx(HallListJ,i);
+ if (jHAL) {
+ pHAL = (char *)json_object_get_string(jHAL);
+ char * pHALName = g_strdup( pHAL );
+ g_ptr_array_add( pHALList, pHALName );
+ }
+ }
+ }
+
+ return AHL_SUCCESS;
+}
+
+int PolicyEndpointStructToJSON(EndpointInfoT * pEndpointInfo, json_object **ppPolicyEndpointJ)
+{
+ if(pEndpointInfo == NULL || pEndpointInfo->pPropTable == NULL)
+ {
+ AFB_ERROR("Invalid PolicyEndpointStructToJSON arguments");
+ return AHL_FAIL;
+ }
+
+ //Create json object for PropTable
+ json_object *pPropTableJ = json_object_new_array();
+ if(pEndpointInfo->pPropTable) {
+ GHashTableIter iter;
+ gpointer key, value;
+ g_hash_table_iter_init (&iter, pEndpointInfo->pPropTable);
+ while (g_hash_table_iter_next (&iter, &key, &value))
+ {
+ json_object *pPropertyJ = NULL;
+ int error=wrap_json_pack(&pPropertyJ, "{s:s,s:o}",
+ "property_name", (char*)key,
+ "property_value", value
+ );
+ if(error)
+ {
+ AFB_ERROR("Unable to pack JSON endpoint, =%s", wrap_json_get_error_string(error));
+ return AHL_FAIL;
+ }
+ json_object_array_add(pPropTableJ, pPropertyJ);
+ }
+ AFB_DEBUG("json object query=%s", json_object_get_string(pPropTableJ));
+ }
+
+ //Create json object for Endpoint
+ int err= wrap_json_pack(ppPolicyEndpointJ, "{s:i,s:i,s:s,s:s,s:s,s:s,s:s,s:i,s:s,s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:o}",
+ "endpoint_id", pEndpointInfo->endpointID,
+ "endpoint_type", pEndpointInfo->type,
+ "device_name", pEndpointInfo->gsDeviceName,
+ "display_name", pEndpointInfo->gsDisplayName,
+ "device_uri", pEndpointInfo->gsDeviceURI,
+ "device_domain", pEndpointInfo->gsDeviceDomain,
+ "audio_role",pEndpointInfo->pRoleName,
+ "device_uri_type", pEndpointInfo->deviceURIType,
+ "hal_api_name", pEndpointInfo->gsHALAPIName,
+ "alsa_cardNum", pEndpointInfo->alsaInfo.cardNum,
+ "alsa_deviceNum", pEndpointInfo->alsaInfo.deviceNum,
+ "alsa_subDeviceNum", pEndpointInfo->alsaInfo.subDeviceNum,
+ "format_samplerate", pEndpointInfo->format.sampleRate,
+ "format_numchannels", pEndpointInfo->format.numChannels,
+ "format_sampletype",pEndpointInfo->format.sampleType,
+ "volume", pEndpointInfo->iVolume,
+ "property_table", pPropTableJ
+ );
+ if (err) {
+ AFB_ERROR("Unable to pack JSON endpoint, =%s", wrap_json_get_error_string(err));
+ return AHL_FAIL;
+ }
+ AFB_DEBUG("JSON endpoint information=%s", json_object_get_string(*ppPolicyEndpointJ));
+ return AHL_SUCCESS;
+}
+
+int PolicyStreamStructToJSON(StreamInfoT * pPolicyStream, json_object **ppPolicyStreamJ)
+{
+ if(pPolicyStream == NULL)
+ {
+ AFB_ERROR("Invalid arguments to PolicyStreamStructToJSON");
+ return AHL_FAIL;
+ }
+
+ json_object * pEndpointJ = NULL;
+ int iRet = PolicyEndpointStructToJSON(pPolicyStream->pEndpointInfo, &pEndpointJ);
+ if (iRet) {
+ return iRet;
+ }
+
+ //Create json object for stream
+ int err = wrap_json_pack(ppPolicyStreamJ, "{s:i,s:i,s:i,s:I,s:i,s:s,s:i,s:i,s:o}",
+ "stream_id", pPolicyStream->streamID,
+ "stream_state", pPolicyStream->streamState,
+ "stream_mute", pPolicyStream->streamMute,
+ "stream_state_event", &pPolicyStream->streamStateEvent,
+ "endpoint_sel_mod", pPolicyStream->endpointSelMode,
+ "role_name", pPolicyStream->pRoleName,
+ "priority", pPolicyStream->iPriority,
+ "interrupt_behavior", pPolicyStream->eInterruptBehavior,
+ "endpoint_info", pEndpointJ
+ );
+ if (err) {
+ AFB_ERROR("Unable to pack JSON endpoint, =%s", wrap_json_get_error_string(err));
+ return AHL_FAIL;
+ }
+
+ AFB_DEBUG("JSON stream information=%s", json_object_get_string(*ppPolicyStreamJ));
+
+ return AHL_SUCCESS;
+}
+
+int PolicyCtxJSONToEndpoint(json_object *pEndpointJ, EndpointInfoT * pEndpointInfo)
+{
+ if(pEndpointJ == NULL || pEndpointInfo == NULL /*|| pEndpointInfo->pPropTable == NULL */ )
+ {
+ AFB_ERROR("Invalid arguments for PolicyCtxJSONToEndpoint");
+ return AHL_FAIL;
+ }
+
+ //Unpack Endpoint
+ json_object *pPropTableJ = NULL;
+ int err = wrap_json_unpack(pEndpointJ, "{s:i,s:i,s:s,s:s,s:s,s:s,s:s,s:i,s:s,s:i,s:i,s:i,s:i,s:i,s:i,s:i,s:o}",
+ "endpoint_id", &pEndpointInfo->endpointID,
+ "endpoint_type", &pEndpointInfo->type,
+ "device_name", &pEndpointInfo->gsDeviceName,
+ "display_name", &pEndpointInfo->gsDisplayName,
+ "device_uri", &pEndpointInfo->gsDeviceURI,
+ "device_domain", &pEndpointInfo->gsDeviceDomain,
+ "audio_role", &pEndpointInfo->pRoleName,
+ "device_uri_type", &pEndpointInfo->deviceURIType,
+ "hal_api_name", &pEndpointInfo->gsHALAPIName,
+ "alsa_cardNum", &pEndpointInfo->alsaInfo.cardNum,
+ "alsa_deviceNum", &pEndpointInfo->alsaInfo.deviceNum,
+ "alsa_subDeviceNum", &pEndpointInfo->alsaInfo.subDeviceNum,
+ "format_samplerate", &pEndpointInfo->format.sampleRate,
+ "format_numchannels", &pEndpointInfo->format.numChannels,
+ "format_sampletype",&pEndpointInfo->format.sampleType,
+ "volume", &pEndpointInfo->iVolume,
+ "property_table", &pPropTableJ
+ );
+ if (err) {
+ AFB_ERROR("Unable to unpack JSON endpoint, =%s", wrap_json_get_error_string(err));
+ return AHL_FAIL;
+ }
+
+ // Unpack prop table
+ if(pPropTableJ)
+ {
+ pEndpointInfo->pPropTable = g_hash_table_new(g_str_hash, g_str_equal);
+
+ int nbProperties = json_object_array_length(pPropTableJ);
+ for(int i=0; i<nbProperties; i++)
+ {
+ json_object * propJ = json_object_array_get_idx(pPropTableJ,i);
+ if (propJ) {
+ char * pPropertyName = NULL;
+ json_object * pPropertyValueJ = NULL;
+
+ int err=wrap_json_unpack(propJ, "{s:s,s:o}",
+ "property_name", &pPropertyName,
+ "property_value", &pPropertyValueJ);
+ if (err) {
+ AFB_ERROR("Unable to unpack JSON endpoint, = %s", wrap_json_get_error_string(err));
+ return AHL_FAIL;
+ }
+
+ // Object type detection for property value (string = state, numeric = property)
+ json_type jType = json_object_get_type(pPropertyValueJ);
+ switch (jType) {
+ case json_type_double:
+ Add_Endpoint_Property_Double(pEndpointInfo,pPropertyName,json_object_get_double(pPropertyValueJ));
+ break;
+ case json_type_int:
+ Add_Endpoint_Property_Int(pEndpointInfo,pPropertyName,json_object_get_int(pPropertyValueJ));
+ break;
+ case json_type_string:
+ Add_Endpoint_Property_String(pEndpointInfo,pPropertyName,json_object_get_string(pPropertyValueJ));
+ break;
+ default:
+ AFB_ERROR("Invalid property argument Property value not a valid json object query=%s", json_object_get_string(pPropertyValueJ));
+ return AHL_FAIL;
+ }
+ }
+ }
+ }
+
+ return AHL_SUCCESS;
+}
+
+int PolicyCtxJSONToStream(json_object *pStreamJ, StreamInfoT * pPolicyStream)
+{
+ if(pStreamJ == NULL || pPolicyStream == NULL)
+ {
+ AFB_ERROR("Invalid arguments for PolicyCtxJSONToStream");
+ return AHL_FAIL;
+ }
+
+ //Unpack StreamInfo
+ json_object *pEndpointJ = NULL;
+ AFB_WARNING("json object query=%s", json_object_get_string(pStreamJ));
+ int err=wrap_json_unpack(pStreamJ, "{s:i,s:i,s:i,s:I,s:i,s:s,s:i,s:i,s:o}",
+ "stream_id", &pPolicyStream->streamID,
+ "stream_state", &pPolicyStream->streamState,
+ "stream_mute", &pPolicyStream->streamMute,
+ "stream_state_event", &pPolicyStream->streamStateEvent,
+ "endpoint_sel_mod", &pPolicyStream->endpointSelMode,
+ "role_name", &pPolicyStream->pRoleName,
+ "priority", &pPolicyStream->iPriority,
+ "interrupt_behavior", &pPolicyStream->eInterruptBehavior,
+ "endpoint_info", &pEndpointJ
+ );
+
+ if (err) {
+ AFB_ERROR("Unable to parse JSON stream information=%s", json_object_get_string(pStreamJ));
+ return AHL_FAIL;
+ }
+
+ int iRet = PolicyCtxJSONToEndpoint(pEndpointJ,pPolicyStream->pEndpointInfo);
+ if (iRet) {
+ return iRet;
+ }
+ return AHL_SUCCESS;
+}
+ \ No newline at end of file