Adding service interface layer logic for request processing
[platform/core/connectivity/zigbee-manager.git] / zigbee-daemon / zigbee-interface / src / zigbee_service_dbus_interface_zcl_scene.c
index 6c242de..1c42d98 100644 (file)
 
 #include "zigbee_service_interface_common.h"
 
+#include <zblib_driver_zcl_scene.h>
+
+static void on_zcl_scene_add_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_add_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gchar scene_id,
        gshort transition_time,
@@ -31,175 +46,483 @@ static gboolean on_zcl_scene_add_scene(ZigbeeZcl_scene *zcl_scene_object,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneAddScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
+
+       GVariantIter *iter = NULL;
+       gint i = 0;
+
+       gboolean ret;
+
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneAddScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+       req.scene_id = scene_id;
+       req.transition_time = transition_time;
+       g_variant_get(scene_name, "ay", &iter);
+       while (g_variant_iter_loop(iter, "y", req.scene_name[i])) {
+               i++;
+               if (i >= ZIGBEE_ZCL_GROUP_NAME_MAX_LEN + 1)
+                       break;
+       }
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
-       NOT_USED(scene_id);
-       NOT_USED(transition_time);
-       NOT_USED(ext_length);
-       NOT_USED(scene_name);
-       NOT_USED(ext_field_set);
+       i = 0;
+       req.ext_field_set_len = ext_length;
+       req.ext_field_set = g_malloc0(ext_length);
+       g_variant_get(ext_field_set, "aq", &iter);
+       while (g_variant_iter_loop(iter, "q", req.ext_field_set[i])) {
+               i++;
+               if (i >= ext_length)
+                       break;
+       }
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_ADD_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_add_scene_resp, resp_cb_data);
+
+       /* Free resource */
+       g_free(req.ext_field_set);
+
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_view_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_view_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gchar scene_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneViewScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
-       NOT_USED(scene_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneViewScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+       req.scene_id = scene_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_VIEW_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_view_scene_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_remove_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_remove_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gchar scene_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneRemoveScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
-       NOT_USED(scene_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneRemoveScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+       req.scene_id = scene_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_REMOVE_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_remove_scene_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_store_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_store_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gchar scene_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneStoreScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
-       NOT_USED(scene_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneStoreScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+       req.scene_id = scene_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_STORE_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_store_scene_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_recall_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_recall_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gchar scene_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneRecallScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
-       NOT_USED(scene_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneRecallScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+       req.scene_id = scene_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_RECALL_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_recall_scene_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_remove_all_scene_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_remove_all_scene(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneRemoveAllScene_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneRemoveAllScene_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_REMOVE_ALL_SCENE,
+               &req, sizeof(req),
+               on_zcl_scene_remove_all_scene_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }
 
+static void on_zcl_scene_get_scene_membership_resp(ZigBeeServiceInterface *service_interface,
+       guint request_id, gpointer resp_data, guint resp_data_len, gpointer resp_cb_data)
+{
+       ZigbeeServiceInterfaceRespCbData_t *cb_data =
+               (ZigbeeServiceInterfaceRespCbData_t *)resp_cb_data;
+
+       NOT_USED(cb_data);
+       NOT_USED(service_interface);
+       NOT_USED(request_id);
+       NOT_USED(resp_data);
+       NOT_USED(resp_data_len);
+}
+
 static gboolean on_zcl_scene_get_scene_membership(ZigbeeZcl_scene *zcl_scene_object,
        GDBusMethodInvocation *invocation,
        gshort node_id,
-       gchar dst_ep,
+       gchar dest_ep,
        gshort group_id,
        gpointer user_data)
 {
        ZigBeeServiceInterface *service_interface = (ZigBeeServiceInterface *)user_data;
+       ZigbeeZclSceneGetSceneMembership_t req;
+       ZigbeeServiceInterfaceRespCbData_t *resp_cb_data = NULL;
 
-       NOT_USED(zcl_scene_object);
-       NOT_USED(invocation);
-       NOT_USED(service_interface);
-       NOT_USED(node_id);
-       NOT_USED(dst_ep);
-       NOT_USED(group_id);
+       gboolean ret;
 
-       /*
-        * TODO -
-        * Create and send request for processing
-        */
+       memset(&req, 0x0, sizeof(ZigbeeZclSceneGetSceneMembership_t));
+
+       /* Update request structure */
+       req.node_id = node_id;
+       req.dest_ep = dest_ep;
+       req.group_id = group_id;
+
+       /* Allocate response callback data */
+       resp_cb_data =
+               zigbee_service_dbus_interface_create_resp_cb_data(zcl_scene_object,
+                       invocation, NULL, 0);
+       if (NULL == resp_cb_data) {
+               Z_LOGE("zigbee_service_dbus_interface_create_resp_cb_data failed!");
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
+
+       /* Dispatch request */
+       ret = zigbee_service_dbus_interface_dispatch_request(service_interface,
+               ZBLIB_DRIVER_TYPE_ZCL_SCENE,
+               ZBLIB_ZCL_SCENE_OPS_GET_SCENE_MEMBERSHIP,
+               &req, sizeof(req),
+               on_zcl_scene_get_scene_membership_resp, resp_cb_data);
+       if (FALSE == ret) {
+               Z_LOGE("zigbee_service_dbus_interface_dispatch_request failed!");
+
+               /* Free response callback data */
+               zigbee_service_dbus_interface_destroy_resp_cb_data(resp_cb_data);
+
+               /* Send failure response */
+               ZIGBEE_DBUS_FAIL_RESPONSE(invocation, ZIGBEE_DBUS_DEFAULT_REQ_FAILED_MSG);
+
+               return TRUE;
+       }
 
        return TRUE;
 }