BLE Gatt Client Socket write and notify implementation

[platform/core/connectivity/bluetooth-frwk.git] / bt-service-adaptation / services / bt-request-handler.c

diff --git a/bt-service-adaptation/services/bt-request-handler.c b/bt-service-adaptation/services/bt-request-handler.c
index ded26a9..b9cf221 100644 (file)
--- a/bt-service-adaptation/services/bt-request-handler.c
+++ b/bt-service-adaptation/services/bt-request-handler.c
@@ -229,6 +229,7 @@ static gboolean __bt_is_sync_function(int service_function)
                        || service_function == BT_GATT_GET_INCLUDED_SERVICES
                        || service_function == BT_GATT_GET_CHARACTERISTIC_PROPERTIES
                        || service_function == BT_GATT_WATCH_CHARACTERISTIC
+                       || service_function == BT_GATT_ACQUIRE_WRITE
 #endif
                        || service_function == BT_AUDIO_SELECT_ROLE
                        || service_function == BT_OBEX_SERVER_ACCEPT_CONNECTION)
@@ -2414,6 +2415,47 @@ int __bt_bluez_request(int function_name,
        }
 
        /* Async: Remote Interaction  */
+       case BT_GATT_ACQUIRE_WRITE: {
+
+               int fd = -1;
+               int mtu = -1;
+               bluetooth_gatt_client_char_prop_info_t param;
+
+               BT_INFO("GATT Client ACQUIRE WRITE recived");
+
+               sender = (char*)g_dbus_method_invocation_get_sender(context);
+
+               __bt_service_get_parameters(in_param1, &param,
+                                       sizeof(bluetooth_gatt_client_char_prop_info_t));
+
+
+               result   = _bt_gatt_acquire_write(&param , &fd, &mtu);
+
+               g_array_append_vals(*out_param1, &mtu, sizeof(int));
+
+               if (BLUETOOTH_ERROR_NONE == result)
+                       BT_INFO("GATT Client: Save Invocation data for characteristic props app[%s] fd[ %d]", sender, fd);
+               else {
+                       BT_ERR("Gatt Client Acqure Write");
+                       break;
+               }
+
+               GUnixFDList *fd_list = NULL;
+               GError *error = NULL;
+
+               /* Add socket fd to unix_fd_list */
+               fd_list = g_unix_fd_list_new();
+               g_unix_fd_list_append(fd_list, fd, &error);
+
+               _bt_service_method_return_with_unix_fd_list(
+                               context, *out_param1, result, fd_list);
+
+               close(fd);
+               g_object_unref(fd_list);
+
+               break;
+       }
+       /* Async: Remote Interaction  */
        case BT_CONNECT_LE: {
                bluetooth_device_address_t address = { {0} };
                gboolean auto_connect;
@@ -2645,6 +2687,9 @@ int __bt_bluez_request(int function_name,
                bluetooth_gatt_client_char_prop_info_t param;
                int client_id;
                gboolean is_notify;
+               int fd = -1;
+               int mtu = 0;
+
 
                memset(&param, 0x00, sizeof(bluetooth_gatt_client_char_prop_info_t));
 
@@ -2657,14 +2702,38 @@ int __bt_bluez_request(int function_name,
                __bt_service_get_parameters(in_param3, &is_notify,
                                sizeof(gboolean));
 
-               result = _bt_gatt_watch_characteristic(&param , client_id, is_notify);
-               if (BLUETOOTH_ERROR_NONE == result) {
-                       BT_INFO("GATT Client: Save Invocation data for characteristic props app[%s]", sender);
 
-                       /* Save the informations to invocation */
-                       _bt_save_invocation_context(context, result, sender,
-                                       function_name,
-                                       (gpointer)g_memdup(&param, sizeof(bluetooth_gatt_client_char_prop_info_t)));
+               if (is_notify == true) {
+                       result   = _bt_gatt_acquire_notify(&param , &fd, &mtu);
+                       if (BLUETOOTH_ERROR_NONE == result && fd > -1) {
+                               BT_INFO("GATT Client: Save Invocation data for characteristic props app[%s] fd[ %d]", sender, fd);
+
+                               GUnixFDList *fd_list = NULL;
+                               GError *error = NULL;
+
+                               g_array_append_vals(*out_param1, &mtu, sizeof(int));
+                               /* Add socket fd to unix_fd_list */
+                               fd_list = g_unix_fd_list_new();
+                               g_unix_fd_list_append(fd_list, fd, &error);
+                               g_assert_no_error(error);
+                               close(fd);
+                               _bt_service_method_return_with_unix_fd_list(
+                               context, *out_param1, result, fd_list);
+
+                               g_object_unref(fd_list);
+                       } else
+                               goto normal;
+               } else {
+
+normal:
+                       result = _bt_gatt_watch_characteristic(&param , client_id, is_notify);
+                       if (BLUETOOTH_ERROR_NONE == result) {
+                               BT_INFO("GATT Client: Save Invocation data for characteristic props app[%s]", sender);
+
+                               /* Save the informations to invocation */
+                               _bt_save_invocation_context(context, result, sender, function_name,
+                                        (gpointer)g_memdup(&param, sizeof(bluetooth_gatt_client_char_prop_info_t)));
+                       }
                }
                break;
        }
@@ -3612,6 +3681,7 @@ gboolean __bt_service_check_privilege(int function_name,
 #ifdef TIZEN_GATT_CLIENT
        case BT_GATT_READ_DESCRIPTOR_VALUE:              /* GATT Client */
        case BT_GATT_WRITE_CHARACTERISTIC_VALUE_BY_TYPE: /* GATT Client */
+       case BT_GATT_ACQUIRE_WRITE:
        case BT_GATT_WRITE_DESCRIPTOR_VALUE:             /* GATT Client */
        case BT_GATT_WATCH_CHARACTERISTIC:               /* GATT Client */
        case BT_GATT_CLIENT_REGISTER:                    /* GATT Client */
@@ -3631,6 +3701,7 @@ gboolean __bt_service_check_privilege(int function_name,
        case BT_GATT_SERVER_DELETE_SERVICE:
        case BT_GATT_SERVER_SEND_RESPONSE:
        case BT_GATT_SERVER_ACQURE_WRITE_RESPONSE:
+       case BT_GATT_SERVER_ACQUIRE_NOTIFY_RESPONSE:
        case BT_GATT_SERVER_SEND_INDICATION:
        case BT_GATT_SERVER_UPDATE_VALUE:
        case BT_GATT_SERVER_DEREGISTER: