BLE Gatt Server Socket notify implementation.
[platform/core/connectivity/bluetooth-frwk.git] / bt-oal / bluez_hal / src / bt-hal-gatt-server.c
1 /*
2  * BLUETOOOTH HAL
3  *
4  * Copyright (c) 2015 - 2016 Samsung Electronics Co., Ltd. All rights reserved.
5  *
6  * Contact:  Anupam Roy <anupam.r@samsung.com>
7  *
8  * Licensed under the Apache License, Version 2.0 (the "License");
9  * you may not use this file except in compliance with the License.
10  * You may obtain a copy of the License at
11  *
12  *              http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing, software
15  * distributed under the License is distributed on an "AS IS" BASIS,
16  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17  * See the License for the specific language governing permissions and
18  * limitations under the License.
19  *
20  */
21
22 #include <hardware/bluetooth.h>
23 #include <hardware/bt_gatt.h>
24 #include <stdio.h>
25 #include <stdlib.h>
26 #include <errno.h>
27 #include <string.h>
28 #include <gio/gio.h>
29 #include <glib.h>
30 #include <dlog.h>
31 #include <vconf.h>
32 #include <stdbool.h>
33 #include <stddef.h>
34 #include <string.h>
35 #include <fcntl.h>
36
37 #include "bt-hal.h"
38 #include "bt-hal-log.h"
39 #include "bt-hal-msg.h"
40 #include "bt-hal-utils.h"
41 #include "bt-hal-dbus-common-utils.h"
42
43 #include "bt-hal-adapter-le.h"
44 #include "bt-hal-event-receiver.h"
45
46 #define NUMBER_OF_FLAGS 10
47
48 #define GATT_SERV_INTERFACE             "org.bluez.GattService1"
49 #define GATT_CHAR_INTERFACE             "org.bluez.GattCharacteristic1"
50 #define GATT_DESC_INTERFACE             "org.bluez.GattDescriptor1"
51
52 #define BT_GATT_SERVICE_NAME    "org.frwk.gatt_service"
53 #define GATT_SERV_OBJECT_PATH   "/service"
54
55 static GDBusProxy *manager_gproxy = NULL;
56
57 /************************************************************************************
58  **  Static variables
59  ************************************************************************************/
60 extern const btgatt_callbacks_t *bt_gatt_callbacks;
61 guint owner_id;
62 GDBusConnection *g_conn = NULL;
63 //GDBusConnection *conn = NULL;
64 GDBusNodeInfo *manager_node_info = NULL;
65 guint manager_id;
66
67 /* Global handles which needs to be incremented during each addition */
68 static int gatt_service_handle = 10;
69 static int gatt_char_handle = 20;
70 static int gatt_desc_handle = 30;
71
72 struct gatt_service_info {
73         gchar *serv_path;
74         guint serv_id;
75         gchar *service_uuid;
76         guint manager_id;
77         guint prop_id;
78         GSList *char_data;
79         gboolean is_svc_registered;
80         gboolean is_svc_primary;
81         int service_handle;
82 };
83
84 struct gatt_char_info {
85         gchar *char_path;
86         guint char_id;
87         gchar *char_uuid;
88         gchar *char_value;
89         gchar *char_flags[NUMBER_OF_FLAGS];
90         int value_length;
91         int flags_length;
92         int char_handle;
93         GSList *desc_data;
94 };
95
96 struct gatt_desc_info {
97         gchar *desc_path;
98         guint desc_id;
99         gchar *desc_uuid;
100         gchar *desc_value;
101         gchar *desc_flags[NUMBER_OF_FLAGS];
102         int value_length;
103         int flags_length;
104         int desc_handle;
105 };
106
107 /**
108  * GATT Server Request type
109  */
110 typedef enum {
111         BT_HAL_GATT_REQUEST_TYPE_READ = 0x00,       /* Read Requested */
112         BT_HAL_GATT_REQUEST_TYPE_WRITE = 0x01,      /* Write Requested */
113         BT_HAL_GATT_REQUEST_TYPE_EXEC_WRITE = 0x02, /* Exec Write Requested */
114         BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_WRITE = 0x03, /* Exec Write Requested */
115         BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_NOTIFY = 0x04, /* Exec Write Requested */
116 } bt_gatt_request_type_e;
117
118 struct gatt_req_info {
119         gchar *attr_path;
120         gchar *svc_path;
121         guint  request_id;
122         guint  offset;
123         bt_gatt_request_type_e request_type;  /* Read or Write request */
124         GDBusMethodInvocation *context;
125 };
126
127 struct gatt_server_app {
128         int slot;
129         char *app_path;
130         GSList *services;
131 };
132
133 /* Linked List of gatt server app's */
134 static GSList *gatt_server_apps = NULL;
135
136 static GSList *gatt_services = NULL;
137
138 static int conn_id = 0;
139
140 /* Linked List of connected Remote GATT clients */
141 static GSList *gatt_client_info_list = NULL;
142
143 /* GATT Client Info List Structure */
144 struct gatt_client_info_t {
145         int connection_id;                               /* This value will uniquely identify a GATT client-server connection */
146         int instance_id;                                 /* This value unique identifies a GATT server instance */
147         char *addr;                                      /* Remote GATT client address */
148         GSList *gatt_req_info_list;                              /* List of transactions per Connection*/
149 };
150
151 static handle_stack_msg event_cb = NULL;
152
153 typedef struct {
154         uint32_t instance_data;
155         bt_uuid_t uuid;
156 } hal_register_server_data;
157
158 typedef struct {
159         uint32_t instance_data;
160         uint32_t srvc_hdl;
161         bt_uuid_t uuid;
162         uint8_t is_primary;
163 } hal_gatt_service_added;
164
165 typedef struct {
166         uint32_t instance_data;
167         uint32_t srvc_hdl;
168 } hal_gatt_service_started;
169
170 typedef struct {
171         uint32_t instance_data;
172         uint32_t srvc_hdl;
173 } hal_gatt_service_deleted;
174
175 typedef struct {
176         uint32_t instance_data;
177         uint32_t srvc_hdl;
178         uint32_t char_hdl;
179         bt_uuid_t uuid;
180 } hal_gatt_char_added;
181
182 typedef struct {
183         uint32_t instance_data;
184         uint32_t srvc_hdl;
185         uint32_t desc_hdl;
186         bt_uuid_t uuid;
187 } hal_gatt_desc_added;
188
189 #define CHECK_BTGATT_INIT() if (bt_gatt_callbacks == NULL)\
190 {\
191         ERR("%s: BTGATT not initialized", __FUNCTION__);\
192         return BT_STATUS_NOT_READY;\
193 } else {\
194         DBG("%s", __FUNCTION__);\
195 }
196
197 static gboolean __bt_hal_gatt_service_added_cb(gpointer user_data);
198
199 static void __bt_hal_gatt_deinit(char *app_path);
200
201 static void __bt_hal_register_application_cb(GObject *object,
202                                 GAsyncResult *res, gpointer user_data);
203
204 static void __bt_hal_unregister_application_cb(GObject *object, GAsyncResult *res,
205                 gpointer user_data);
206
207 static GDBusProxy *__bt_gatt_gdbus_get_gatt_manager_proxy(const gchar *service,
208                 const gchar *path, const gchar *interface);
209
210 /* Introspection data for the service we are exporting */
211 static const gchar service_introspection_xml[] =
212 "<node name='/'>"
213 "  <interface name='org.freedesktop.DBus.Properties'>"
214 "    <property type='s' name='UUID' access='read'>"
215 "    </property>"
216 "        <property type='b' name='primary' access='read'>"
217 "        </property>"
218 "        <property type='o' name='Device' access='read'>"
219 "        </property>"
220 "        <property type='ao' name='Characteristics' access='read'>"
221 "        </property>"
222 "        <property type='s' name='Includes' access='read'>"
223 "        </property>"
224 "  </interface>"
225 "</node>";
226
227 /* Introspection data for the characteristics we are exporting */
228 static const gchar characteristics_introspection_xml[] =
229 "<node name='/'>"
230 "  <interface name='org.bluez.GattCharacteristic1'>"
231 "        <method name='ReadValue'>"
232 "               <arg type='s' name='address' direction='in'/>"
233 "               <arg type='y' name='id' direction='in'/>"
234 "               <arg type='q' name='offset' direction='in'/>"
235 "               <arg type='ay' name='Value' direction='out'/>"
236 "        </method>"
237 "        <method name='WriteValue'>"
238 "               <arg type='s' name='address' direction='in'/>"
239 "               <arg type='u' name='id' direction='in'/>"
240 "               <arg type='q' name='offset' direction='in'/>"
241 "               <arg type='b' name='response_needed' direction='in'/>"
242 "               <arg type='ay' name='value' direction='in'/>"
243 "        </method>"
244 "       <method name ='AcquireWrite'>"
245 "      <arg type='a{sv}' name='properties' direction='in'/>"
246 "               <arg type='h' name='fd' direction='out'/>"
247 "               <arg type='q' name='mtu' direction='out'/>"
248 "        </method>"
249 "       <method name = 'AcquireNotify'>"
250 "               <arg type='a{sv}' name='properties' direction='in'/>"
251 "               <arg type='h' name='fd' direction='out'/>"
252 "               <arg type='q' name='mtu' direction='out'/>"
253 "        </method>"
254 "        <method name='StartNotify'>"
255 "        </method>"
256 "        <method name='StopNotify'>"
257 "        </method>"
258 "        <method name='IndicateConfirm'>"
259 "               <arg type='s' name='address' direction='in'/>"
260 "               <arg type='b' name='complete' direction='in'/>"
261 "        </method>"
262 "  </interface>"
263 "  <interface name='org.freedesktop.DBus.Properties'>"
264 "    <property type='s' name='UUID' access='read'>"
265 "    </property>"
266 "    <property type='o' name='Service' access='read'>"
267 "    </property>"
268 "    <property type='ay' name='Value' access='readwrite'>"
269 "    </property>"
270 "        <property type='b' name='Notifying' access='read'>"
271 "        </property>"
272 "    <property type='as' name='Flags' access='read'>"
273 "    </property>"
274 "    <property type='s' name='Unicast' access='read'>"
275 "    </property>"
276 "        <property type='ao' name='Descriptors' access='read'>"
277 "        </property>"
278 "        <property type='b' name='WriteAcquired' access='read'>"
279 "        </property>"
280 "        <property type='b' name='NotifyAcquired' access='read'>"
281 "        </property>"
282 "  </interface>"
283 "</node>";
284
285 /* Introspection data for the descriptor we are exporting */
286 static const gchar descriptor_introspection_xml[] =
287 "<node name='/'>"
288 "  <interface name='org.bluez.GattDescriptor1'>"
289 "        <method name='ReadValue'>"
290 "               <arg type='s' name='address' direction='in'/>"
291 "               <arg type='u' name='id' direction='in'/>"
292 "               <arg type='q' name='offset' direction='in'/>"
293 "               <arg type='ay' name='Value' direction='out'/>"
294 "        </method>"
295 "        <method name='WriteValue'>"
296 "               <arg type='s' name='address' direction='in'/>"
297 "               <arg type='u' name='id' direction='in'/>"
298 "               <arg type='q' name='offset' direction='in'/>"
299 "               <arg type='b' name='response_needed' direction='in'/>"
300 "               <arg type='ay' name='value' direction='in'/>"
301 "        </method>"
302 "  </interface>"
303 "  <interface name='org.freedesktop.DBus.Properties'>"
304 "    <property type='s' name='UUID' access='read'>"
305 "    </property>"
306 "    <property type='o' name='Characteristic' access='read'>"
307 "    </property>"
308 "    <property type='ay' name='Value' access='read'>"
309 "    </property>"
310 "    <property type='as' name='Flags' access='read'>"
311 "    </property>"
312 "  </interface>"
313 "</node>";
314
315
316 static const gchar manager_introspection_xml[] =
317 "<node name='/'>"
318 "  <interface name='org.freedesktop.DBus.ObjectManager'>"
319 "    <method name='GetManagedObjects'>"
320 "     <arg type='a{oa{sa{sv}}}' name='object_paths_interfaces_and_properties' direction='out'/>"
321 "        </method>"
322 "  </interface>"
323 "</node>";
324
325 GSList *_bt_get_service_list_from_server(int instance)
326 {
327         GSList *l;
328         INFO("Number of GATT Server apps [%d]", g_slist_length(gatt_server_apps));
329         INFO("Find App with slot [%d]", instance);
330
331         for (l = gatt_server_apps; l; l = g_slist_next(l)) {
332                 struct gatt_server_app *app = (struct gatt_server_app *)l->data;
333
334                 if (app->slot == instance) {
335                         INFO("App slot [%d] Found, Number of services registered [%d]",
336                                         app->slot, g_slist_length(app->services));
337                         return app->services;
338                 }
339         }
340         return NULL;
341 }
342
343 void _bt_remote_service_from_gatt_server(int instance, int service_handle)
344 {
345         GSList *l;
346         GSList *l1;
347
348         for (l = gatt_server_apps; l; l = g_slist_next(l)) {
349                 struct gatt_server_app *app = (struct gatt_server_app *)l->data;
350
351                 if (app->slot == instance) {
352                         for (l1 = app->services; l1; l1 = g_slist_next(l1)) {
353                                 struct gatt_service_info *srv = (struct gatt_service_info *)l1->data;
354                                 if (srv->service_handle == service_handle) {
355                                         app->services = g_slist_remove(app->services, srv);
356                                         return;
357                                 }
358                         }
359                 }
360         }
361 }
362
363 void _bt_hal_update_gatt_service_in_gatt_server(int slot, struct gatt_service_info *serv_info)
364 {
365         GSList *l;
366         for (l = gatt_server_apps; l; l = g_slist_next(l)) {
367                 struct gatt_server_app *app = (struct gatt_server_app *)l->data;
368
369                 if (app->slot == slot) {
370                         INFO("Updating service in GATT server's service list service handle [%d] slot [%d]",
371                                 serv_info->service_handle, slot);
372                         app->services = g_slist_append(app->services, serv_info);
373                 }
374         }
375 }
376
377 static struct gatt_client_info_t *__bt_find_remote_gatt_client_info(char *address)
378 {
379         GSList *l;
380         struct gatt_client_info_t *info = NULL;
381
382         for (l = gatt_client_info_list; l != NULL; l = g_slist_next(l)) {
383                 info = (struct gatt_client_info_t*)l->data;
384                 if (info == NULL)
385                         continue;
386
387                 if (!g_strcmp0(info->addr, address)) {
388                         INFO("Remote GATT client found addr[%s]", info->addr);
389                         return info;
390                 }
391         }
392         return NULL;
393 }
394
395 static struct gatt_client_info_t *__bt_find_remote_gatt_client_info_from_conn(int conn_id)
396 {
397         GSList *l;
398         struct gatt_client_info_t *info = NULL;
399
400         for (l = gatt_client_info_list; l != NULL; l = g_slist_next(l)) {
401                 info = (struct gatt_client_info_t*)l->data;
402                 if (info == NULL)
403                         continue;
404
405                 if (info->connection_id == conn_id) {
406                         INFO("Remote GATT client found addr[%s]", info->addr);
407                         return info;
408                 }
409         }
410         return NULL;
411 }
412
413 static struct gatt_req_info *__bt_find_remote_gatt_client_request_info(int conn_id, int trans_id)
414 {
415         GSList *l;
416         GSList *l1;
417
418         struct gatt_client_info_t *info = NULL;
419         struct gatt_req_info *info1 = NULL;
420
421         for (l = gatt_client_info_list; l != NULL; l = g_slist_next(l)) {
422                 info = (struct gatt_client_info_t*)l->data;
423
424                 if (info == NULL)
425                         continue;
426                 if (info->connection_id == conn_id) {
427
428                         for (l1 = info->gatt_req_info_list; l1; l1 = g_slist_next(l1)) {
429
430                                 info1 = (struct gatt_req_info*)l1->data;
431                                 if (info1 == NULL)
432                                         continue;
433
434                                 if (info1->request_id == trans_id) {
435                                         INFO("Remote GATT client found addr[%s]", info->addr);
436                                         return info1;
437                                 }
438                         }
439                 }
440         }
441         return NULL;
442 }
443
444 void _bt_hal_gatt_connected_state_event(gboolean is_connected, char *address)
445 {
446         struct hal_ev_gatt_server_connected ev;
447         struct gatt_client_info_t *conn_info = NULL;
448         int instance = -1;
449         memset(&ev, 0, sizeof(ev));
450
451         /* Find Server Instance */
452         _bt_hal_get_gatt_server_instance_initialized(&instance);
453         if (instance == -1) {
454                 ERR("Not even a single GATT server is registered");
455                 return;
456         }
457
458         /* Convert address to hex */
459         _bt_hal_convert_addr_string_to_type(ev.bdaddr, address);
460
461         /* Create Connection ID */
462         /* Check if device is already in connected list */
463         conn_info = __bt_find_remote_gatt_client_info(address);
464
465
466         /* If disconnected, and conn info found, then remove conn info */
467         if (is_connected == FALSE) {
468                 DBG("GATT Disconnected");
469                 if (conn_info) {
470                         INFO("Remove GATT client info from List..");
471                         /* Remove info from List */
472                         gatt_client_info_list = g_slist_remove(gatt_client_info_list, conn_info);
473                         INFO("Total num of connected GATT clients [%d]", g_slist_length(gatt_client_info_list));
474
475                         if (!event_cb)
476                                 ERR("GATT callback not registered");
477                         else {
478                                 DBG("GATT callback registered: server if [%d] Is Connected [%d] addr[%s] conn ID [%d]",
479                                                 conn_info->instance_id, is_connected, conn_info->addr, conn_info->connection_id);
480                                 ev.conn_id = conn_info->connection_id;
481                                 ev.server_instance = conn_info->instance_id;
482                                 ev.connected = is_connected;
483
484                                 event_cb(HAL_EV_GATT_SERVER_CONNECTED, (void *)&ev, sizeof(ev));
485                         }
486                         g_free(conn_info->addr);
487                         g_free(conn_info);
488                 }
489                 /* If connected, and conn info NOT found, then add conn info */
490         } else {
491                 if (!conn_info) {
492                         /* Save Connection info */
493                         conn_info = g_new0(struct gatt_client_info_t, 1);
494                         conn_info->addr = g_strdup(address);
495                         INFO("Added GATT client addr[%s]", conn_info->addr);
496                         conn_info->connection_id = ++conn_id;
497                         conn_info->instance_id = instance;
498                         gatt_client_info_list = g_slist_append(gatt_client_info_list, conn_info);
499                         INFO("Total num of connected GATT clients [%d]", g_slist_length(gatt_client_info_list));
500
501                         if (!event_cb)
502                                 ERR("GATT callback not registered");
503                         else {
504                                 DBG("GATT callback registered: server if [%d] Is Connected [%d] addr[%s] conn ID [%d]",
505                                                 conn_info->instance_id, is_connected, conn_info->addr, conn_info->connection_id);
506                                 ev.conn_id = conn_info->connection_id;
507                                 ev.server_instance = conn_info->instance_id;
508                                 ev.connected = is_connected;
509
510                                 event_cb(HAL_EV_GATT_SERVER_CONNECTED, (void *)&ev, sizeof(ev));
511                         }
512                 }
513         }
514         /* Send GATT connected or disconnected event */
515 }
516
517 static struct gatt_service_info *__bt_gatt_find_gatt_service_from_char(const char *char_path, int *char_hdl)
518 {
519         GSList *l1, *l2;
520
521         for (l1 = gatt_services; l1 != NULL; l1 = l1->next) {
522                 struct gatt_service_info *serv_info = l1->data;
523
524                 for (l2 = serv_info->char_data; l2 != NULL; l2 = l2->next) {
525                         struct gatt_char_info *char_info = l2->data;
526
527                         if (g_strcmp0(char_info->char_path, char_path)
528                                         == 0) {
529                                 *char_hdl = char_info->char_handle;
530                                 return serv_info;
531                         }
532                 }
533         }
534         ERR("Gatt service not found");
535         return NULL;
536 }
537
538 char *__bt_gatt_find_char_path_from_handle(int char_hdl)
539 {
540         GSList *l1, *l2;
541
542         for (l1 = gatt_services; l1 != NULL; l1 = l1->next) {
543                 struct gatt_service_info *serv_info = l1->data;
544
545                 for (l2 = serv_info->char_data; l2 != NULL; l2 = l2->next) {
546                         struct gatt_char_info *char_info = l2->data;
547
548                         if (char_info->char_handle == char_hdl)
549                                 return char_info->char_path;
550                 }
551         }
552         ERR("Not found");
553         return NULL;
554 }
555
556 struct gatt_char_info *__bt_gatt_find_char_info_from_handle(int char_hdl)
557 {
558         GSList *l1, *l2;
559
560         for (l1 = gatt_services; l1 != NULL; l1 = l1->next) {
561                 struct gatt_service_info *serv_info = l1->data;
562
563                 for (l2 = serv_info->char_data; l2 != NULL; l2 = l2->next) {
564                         struct gatt_char_info *char_info = l2->data;
565
566                         if (char_info->char_handle == char_hdl)
567                                 return char_info;
568                 }
569         }
570         ERR("Not found");
571         return NULL;
572 }
573
574 static struct gatt_service_info *__bt_gatt_find_gatt_service_from_desc(const char *desc_path, int *desc_hdl)
575 {
576         GSList *l1, *l2, *l3;
577
578         for (l1 = gatt_services; l1 != NULL; l1 = l1->next) {
579                 struct gatt_service_info *serv_info = l1->data;
580
581                 for (l2 = serv_info->char_data; l2 != NULL; l2 = l2->next) {
582                         struct gatt_char_info *char_info = l2->data;
583
584                         for (l3 = char_info->desc_data; l3 != NULL; l3 = l3->next) {
585                                 struct gatt_desc_info *desc_info = l3->data;
586
587                                 if (g_strcmp0(desc_info->desc_path, desc_path)
588                                                 == 0) {
589                                         *desc_hdl = desc_info->desc_handle;
590                                         return serv_info;
591                                 }
592                         }
593                 }
594         }
595         ERR("Gatt service not found");
596         return NULL;
597 }
598
599 static void __bt_gatt_manager_method_call(GDBusConnection *connection,
600                 const gchar *sender,
601                 const gchar *object_path,
602                 const gchar *interface_name,
603                 const gchar *method_name,
604                 GVariant *parameters,
605                 GDBusMethodInvocation *invocation,
606                 gpointer user_data)
607 {
608         GSList *l = NULL;
609
610         if (g_strcmp0(method_name, "GetManagedObjects") == 0) {
611                 GVariantBuilder *builder;
612                 GVariantBuilder *inner_builder1 = NULL;
613                 GVariant *svc_char = NULL;
614                 GSList *l4;
615                 GSList *gatt_services = NULL;
616                 int *instance;
617                 instance = (int*)user_data;
618                 gboolean writeAcquired = FALSE;
619                 gboolean notifyAcquired = FALSE;
620
621                 DBG("Getting values for service, chars and descriptors");
622                 DBG("GATT Server App for which services are requested [%d]", *instance);
623
624                 /*Main Builder */
625                 builder = g_variant_builder_new(
626                                 G_VARIANT_TYPE("a{oa{sa{sv}}}"));
627
628
629                 gatt_services = _bt_get_service_list_from_server(*instance);
630
631                 if (g_slist_length(gatt_services) == 0) {
632                         ERR("No registered GATT services!!!!");
633                         g_dbus_method_invocation_return_value(invocation, NULL);
634                         g_variant_builder_unref(builder);
635                         return;
636                 }
637
638                 for (l = gatt_services; l != NULL; l = l->next) {
639                         GVariantBuilder *svc_builder = NULL;
640                         GVariantBuilder *inner_builder = NULL;
641                         struct gatt_service_info *serv_info = l->data;
642                         INFO("GATT Service fetched handle [%d]", serv_info->service_handle);
643
644                         /* Prepare inner builder for GattService1 interface */
645                         DBG("Creating builder for service");
646                         svc_builder = g_variant_builder_new(
647                                         G_VARIANT_TYPE("a{sa{sv}}"));
648                         inner_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
649
650                         g_variant_builder_add(inner_builder, "{sv}", "UUID",
651                                         g_variant_new_string(serv_info->service_uuid));
652
653                         g_variant_builder_add(inner_builder, "{sv}", "Primary",
654                                         g_variant_new_boolean(serv_info->is_svc_primary));
655
656                         /*Characteristics*/
657                         inner_builder1 = g_variant_builder_new(G_VARIANT_TYPE("ao"));
658                         DBG("Adding Charatarisitcs list");
659                         for (l4 = serv_info->char_data; l4 != NULL; l4 = l4->next) {
660                                 struct gatt_char_info *char_info = l4->data;
661                                 INFO("GATT Char handle [%d] found in GATT service handle [%d]",
662                                                 char_info->char_handle, serv_info->service_handle);
663                                 g_variant_builder_add(inner_builder1, "o",
664                                                 char_info->char_path);
665                                 DBG("%s", char_info->char_path);
666                         }
667
668                         svc_char = g_variant_new("ao", inner_builder1);
669                         g_variant_builder_add(inner_builder, "{sv}", "Characteristics",
670                                         svc_char);
671
672                         g_variant_builder_add(svc_builder, "{sa{sv}}",
673                                         GATT_SERV_INTERFACE,
674                                         inner_builder);
675
676                         g_variant_builder_add(builder, "{oa{sa{sv}}}",
677                                         serv_info->serv_path,
678                                         svc_builder);
679
680                         g_variant_builder_unref(inner_builder1);
681
682                         /* Prepare inner builder for GattCharacteristic1 interface */
683
684                         GSList *l2 = serv_info->char_data;
685                         DBG("Creating builder for characteristics \n");
686
687                         if (l2 == NULL)
688                                 DBG("characteristic data is NULL");
689
690                         for (l2 = serv_info->char_data; l2 != NULL; l2 = l2->next) {
691
692                                 GVariantBuilder *char_builder = NULL;
693                                 GVariantBuilder *inner_builder = NULL;
694                                 GVariantBuilder *builder1 = NULL;
695                                 GVariantBuilder *builder2 = NULL;
696                                 GVariantBuilder *builder3 = NULL;
697                                 GVariant *char_val = NULL;
698                                 GVariant *flags_val = NULL;
699                                 GVariant *char_desc = NULL;
700                                 char *unicast = NULL;
701                                 gboolean notify = FALSE;
702                                 int i = 0;
703
704                                 char_builder = g_variant_builder_new(
705                                                 G_VARIANT_TYPE(
706                                                         "a{sa{sv}}"));
707                                 inner_builder = g_variant_builder_new(
708                                                 G_VARIANT_TYPE(
709                                                         "a{sv}"));
710
711                                 struct gatt_char_info *char_info = l2->data;
712                                 if (char_info == NULL) {
713                                         ERR("char_info is NULL");
714                                         continue;
715                                 }
716
717                                 /*Uuid*/
718                                 g_variant_builder_add(inner_builder, "{sv}", "UUID",
719                                                 g_variant_new_string(char_info->char_uuid));
720                                 /*Service*/
721                                 g_variant_builder_add(inner_builder, "{sv}", "Service",
722                                                 g_variant_new("o", serv_info->serv_path));
723                                 /*Value*/
724                                 builder1 = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
725
726                                 if (char_info->char_value != NULL) {
727                                         for (i = 0; i < char_info->value_length; i++) {
728                                                 g_variant_builder_add(builder1, "y",
729                                                                 char_info->char_value[i]);
730                                         }
731                                         char_val = g_variant_new("ay", builder1);
732                                         g_variant_builder_add(inner_builder, "{sv}",
733                                                         "Value", char_val);
734                                 }
735                                 /*Flags*/
736                                 builder2 = g_variant_builder_new(G_VARIANT_TYPE("as"));
737                                 for (i = 0; i < char_info->flags_length; i++) {
738                                         g_variant_builder_add(builder2, "s",
739                                                         char_info->char_flags[i]);
740                                         if (strncmp(char_info->char_flags[i], "write-without-response", 16) == 0)
741                                                 writeAcquired = TRUE;
742
743                                         if (strncmp(char_info->char_flags[i], "notify", 4) == 0)
744                                                 notifyAcquired = TRUE;
745                                 }
746
747                                 flags_val = g_variant_new("as", builder2);
748                                 g_variant_builder_add(inner_builder, "{sv}", "Flags",
749                                                 flags_val);
750
751                                 /* Notifying */
752                                 g_variant_builder_add(inner_builder, "{sv}", "Notifying",
753                                                 g_variant_new("b", notify));
754
755                                 /* Unicast */
756                                 g_variant_builder_add(inner_builder, "{sv}", "WriteAcquired",
757                                                                         g_variant_new("b", writeAcquired));
758
759                                 /* NotifyAcquired */
760                                                         g_variant_builder_add(inner_builder, "{sv}", "NotifyAcquired",
761                                                                         g_variant_new("b", notifyAcquired));
762
763                                 /* Unicast */
764                                 unicast = g_strdup("00:00:00:00:00:00");
765                                 g_variant_builder_add(inner_builder, "{sv}", "Unicast",
766                                                 g_variant_new("s", unicast));
767
768                                 /*Descriptors*/
769                                 builder3 = g_variant_builder_new(G_VARIANT_TYPE("ao"));
770                                 DBG("Adding Descriptors list");
771
772                                 for (l4 = char_info->desc_data; l4 != NULL; l4 = l4->next) {
773                                         struct gatt_desc_info *desc_info = l4->data;
774                                         INFO("GATT Descriptor handle [%d] found inside GATT Char handle [%d] found in GATT service handle [%d]",
775                                                         desc_info->desc_handle, char_info->char_handle, serv_info->service_handle);
776                                         g_variant_builder_add(builder3, "o",
777                                                         desc_info->desc_path);
778                                         DBG("%s", desc_info->desc_path);
779                                 }
780
781                                 char_desc = g_variant_new("ao", builder3);
782                                 g_variant_builder_add(inner_builder, "{sv}", "Descriptors",
783                                                 char_desc);
784
785                                 g_variant_builder_add(char_builder, "{sa{sv}}",
786                                                 GATT_CHAR_INTERFACE , inner_builder);
787                                 g_variant_builder_add(builder, "{oa{sa{sv}}}",
788                                                 char_info->char_path, char_builder);
789
790                                 /*Prepare inner builder for GattDescriptor1 interface*/
791
792                                 GSList *l3 = char_info->desc_data;
793
794                                 if (l3 == NULL)
795                                         DBG("descriptor data is NULL");
796
797                                 for (l3 = char_info->desc_data; l3 != NULL; l3 = l3->next) {
798
799                                         DBG("Creating builder for descriptor \n");
800
801                                         GVariantBuilder *desc_builder = NULL;
802                                         GVariantBuilder *inner_builder = NULL;
803                                         GVariantBuilder *builder1 = NULL;
804                                         GVariantBuilder *builder2 = NULL;
805                                         GVariant *desc_val = NULL;
806
807                                         desc_builder = g_variant_builder_new(
808                                                         G_VARIANT_TYPE(
809                                                                 "a{sa{sv}}"));
810                                         inner_builder = g_variant_builder_new(
811                                                         G_VARIANT_TYPE(
812                                                                 "a{sv}"));
813
814                                         struct gatt_desc_info *desc_info = l3->data;
815                                         if (desc_info == NULL) {
816                                                 ERR("desc_info is NULL");
817                                                 continue;
818                                         }
819
820                                         /*Uuid*/
821                                         g_variant_builder_add(inner_builder,
822                                                         "{sv}", "UUID",
823                                                         g_variant_new_string(
824                                                                 desc_info->desc_uuid));
825
826                                         /*Characteristic*/
827                                         g_variant_builder_add(inner_builder, "{sv}",
828                                                         "Characteristic",
829                                                         g_variant_new("o",
830                                                                 char_info->char_path));
831
832                                         /*Value*/
833                                         builder1 = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
834
835                                         if (desc_info->desc_value != NULL) {
836                                                 for (i = 0; i < desc_info->value_length; i++) {
837                                                         g_variant_builder_add(builder1, "y",
838                                                                         desc_info->desc_value[i]);
839                                                 }
840                                                 desc_val = g_variant_new("ay", builder1);
841                                                 g_variant_builder_add(inner_builder, "{sv}",
842                                                                 "Value", desc_val);
843                                         }
844
845                                         /*Flags*/
846                                         builder2 = g_variant_builder_new(G_VARIANT_TYPE("as"));
847
848                                         for (i = 0; i < desc_info->flags_length; i++) {
849                                                 g_variant_builder_add(builder2, "s",
850                                                                 desc_info->desc_flags[i]);
851                                         }
852
853                                         flags_val = g_variant_new("as", builder2);
854                                         g_variant_builder_add(inner_builder, "{sv}", "Flags",
855                                                         flags_val);
856
857                                         g_variant_builder_add(desc_builder, "{sa{sv}}",
858                                                         GATT_DESC_INTERFACE,
859                                                         inner_builder);
860
861                                         g_variant_builder_add(builder, "{oa{sa{sv}}}",
862                                                         desc_info->desc_path,
863                                                         desc_builder);
864
865                                         /*unref descriptor builder pointers*/
866                                         g_variant_builder_unref(builder1);
867                                         g_variant_builder_unref(builder2);
868                                         g_variant_builder_unref(inner_builder);
869                                         g_variant_builder_unref(desc_builder);
870                                 }
871
872                                 if (unicast)
873                                         g_free(unicast);
874                                 /*unref char builder pointers*/
875                                 g_variant_builder_unref(builder1);
876                                 g_variant_builder_unref(builder2);
877                                 g_variant_builder_unref(builder3);
878                                 g_variant_builder_unref(inner_builder);
879                                 g_variant_builder_unref(char_builder);
880                         }
881
882                         /*unref service builder pointers*/
883                         g_variant_builder_unref(inner_builder);
884                         g_variant_builder_unref(svc_builder);
885
886                 }
887                 /* Return builder as method reply */
888                 DBG("Sending gatt service builder values to Bluez");
889                 g_dbus_method_invocation_return_value(invocation,
890                                 g_variant_new(
891                                         "(a{oa{sa{sv}}})",
892                                         builder));
893         }
894
895         /* Free User Data */
896         g_free(user_data);
897 }
898
899 static void __bt_gatt_desc_method_call(GDBusConnection *connection,
900                 const gchar *sender,
901                 const gchar *object_path,
902                 const gchar *interface_name,
903                 const gchar *method_name,
904                 GVariant *parameters,
905                 GDBusMethodInvocation *invocation,
906                 gpointer user_data)
907 {
908
909         if (g_strcmp0(method_name, "ReadValue") == 0) {
910                 struct hal_ev_gatt_server_read_req ev;
911
912                 gchar *addr = NULL;
913                 guint req_id = 0;
914                 guint16 offset = 0;
915                 struct gatt_client_info_t *conn_info = NULL;
916                 struct gatt_req_info *req_info = NULL;
917                 struct gatt_service_info *svc_info = NULL;
918                 int desc_hdl = -1;
919
920                 DBG("ReadValue");
921                 DBG("Application path = %s", object_path);
922                 DBG("Sender = %s", sender);
923
924                 svc_info = __bt_gatt_find_gatt_service_from_desc(object_path, &desc_hdl);
925                 if (svc_info == NULL) {
926                         ERR("Coudn't find service for %s", object_path);
927                         g_dbus_method_invocation_return_value(invocation, NULL);
928                         return;
929                 }
930
931                 g_variant_get(parameters, "(&suq)", &addr, &req_id, &offset);
932                 DBG("Request id = %u, Offset = %u", req_id, offset);
933
934                 /* Check if device is already in connected list */
935                 conn_info = __bt_find_remote_gatt_client_info(addr);
936
937                 if (conn_info == NULL) {
938                         ERR("Coudn't find Connection info for %s", addr);
939                         g_dbus_method_invocation_return_value(invocation, NULL);
940                         return;
941                 }
942
943                 if (!event_cb) {
944                         ERR("GATT callback NOT registered");
945                         g_dbus_method_invocation_return_value(invocation, NULL);
946                         return;
947                 }
948
949                 /* Store requests information */
950                 req_info = g_new0(struct gatt_req_info, 1);
951                 req_info->attr_path = g_strdup(object_path);
952                 req_info->svc_path = g_strdup(svc_info->serv_path);
953                 req_info->request_id = req_id;
954                 req_info->offset = offset;
955                 req_info->context = invocation;
956
957                 /* Append request info in list of requests for the particular connection */
958                 conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
959
960                 /* Send HAL event */
961                 memset(&ev, 0, sizeof(ev));
962                 ev.conn_id = conn_info->connection_id;
963                 ev.trans_id = req_id;
964                 ev.att_handle = desc_hdl;
965                 ev.offset = offset;
966                 ev.is_long = false; /* TODO*/
967
968                 /* Convert address to hex */
969                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
970
971                 event_cb(HAL_EV_GATT_READ_REQUESTED, (void *)&ev, sizeof(ev));
972                 return;
973         } else if (g_strcmp0(method_name, "WriteValue") == 0) {
974
975                 GVariant *var = NULL;
976                 gchar *addr = NULL;
977                 guint req_id = 0;
978                 guint16 offset = 0;
979                 gboolean response_needed = FALSE;
980                 struct hal_ev_gatt_server_write_req ev;
981                 int desc_hdl = -1;
982                 int len;
983
984                 struct gatt_service_info *svc_info = NULL;
985                 struct gatt_client_info_t *conn_info = NULL;
986                 struct gatt_req_info *req_info = NULL;
987
988                 memset(&ev, 0, sizeof(ev));
989
990                 DBG("WriteValue");
991                 DBG("Application path = %s", object_path);
992                 DBG("Sender = %s", sender);
993
994                 g_variant_get(parameters, "(&suqb@ay)",
995                                 &addr, &req_id, &offset, &response_needed, &var);
996                 DBG("Request id = %u, Offset = %u", req_id, offset);
997
998                 /* Check if device is already in connected list */
999                 conn_info = __bt_find_remote_gatt_client_info(addr);
1000
1001                 svc_info = __bt_gatt_find_gatt_service_from_desc(object_path, &desc_hdl);
1002
1003                 if (conn_info == NULL || svc_info == NULL || event_cb == NULL) {
1004                         g_variant_unref(var);
1005                         if (response_needed)
1006                                 g_dbus_method_invocation_return_value(invocation, NULL);
1007                         else
1008                                 g_object_unref(invocation);
1009                         return;
1010                 }
1011
1012                 len = g_variant_get_size(var);
1013                 if (len > 0 && len < 600) {
1014                         char *data;
1015                         data = (char *)g_variant_get_data(var);
1016                         memcpy(ev.value, data, len);
1017                         ev.length = len;
1018                 }
1019                 if (response_needed) {
1020                         /* Store request information */
1021                         req_info = g_new0(struct gatt_req_info, 1);
1022                         req_info->attr_path = g_strdup(object_path);
1023                         req_info->svc_path = g_strdup(svc_info->serv_path);
1024                         req_info->request_id = req_id;
1025                         req_info->offset = offset;
1026                         req_info->context = invocation;
1027
1028                         /* Append request info in list of requests for the particular connection */
1029                         conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
1030                 } else {
1031                         g_object_unref(invocation);
1032                 }
1033
1034                 /* Send HAL event */
1035                 ev.conn_id = conn_info->connection_id;
1036                 ev.trans_id = req_id;
1037                 ev.att_handle = desc_hdl;
1038                 ev.offset = offset;
1039                 ev.need_rsp = response_needed;
1040                 ev.is_prep = 0;
1041
1042                 /* Convert address to hex */
1043                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
1044
1045                 event_cb(HAL_EV_GATT_WRITE_REQUESTED, (void *)&ev, sizeof(ev));
1046
1047                 g_variant_unref(var);
1048                 return;
1049         }
1050 }
1051
1052 static void __bt_gatt_char_method_call(GDBusConnection *connection,
1053                 const gchar *sender,
1054                 const gchar *object_path,
1055                 const gchar *interface_name,
1056                 const gchar *method_name,
1057                 GVariant *parameters,
1058                 GDBusMethodInvocation *invocation,
1059                 gpointer user_data)
1060 {
1061         if (g_strcmp0(method_name, "ReadValue") == 0) {
1062                 gchar *addr = NULL;
1063                 guint req_id = 0;
1064                 guint16 offset = 0;
1065                 struct hal_ev_gatt_server_read_req ev;
1066                 int char_hdl = -1;
1067
1068                 struct gatt_req_info *req_info = NULL;
1069                 struct gatt_client_info_t *conn_info = NULL;
1070                 struct gatt_service_info *svc_info = NULL;
1071
1072                 DBG("Application path = %s", object_path);
1073                 DBG("Sender = %s", sender);
1074
1075                 /* Check if device is already in connected list */
1076                 conn_info = __bt_find_remote_gatt_client_info(addr);
1077
1078                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1079
1080                 if (svc_info == NULL || conn_info == NULL) {
1081                         g_dbus_method_invocation_return_value(invocation, NULL);
1082                         return;
1083                 }
1084
1085                 if (!event_cb) {
1086                         ERR("GATT callback NOT registered");
1087                         g_dbus_method_invocation_return_value(invocation, NULL);
1088                         return;
1089                 }
1090
1091                 g_variant_get(parameters, "(&suq)", &addr, &req_id, &offset);
1092                 DBG("Request id = %u, Offset = %u", req_id, offset);
1093
1094                 /* Store requets information */
1095                 req_info = g_new0(struct gatt_req_info, 1);
1096                 req_info->attr_path = g_strdup(object_path);
1097                 req_info->svc_path = g_strdup(svc_info->serv_path);
1098                 req_info->request_id = req_id;
1099                 req_info->request_type = BT_HAL_GATT_REQUEST_TYPE_READ;
1100                 req_info->offset = offset;
1101                 req_info->context = invocation;
1102
1103                 /* Append request info in list of requests for the particular connection */
1104                 conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
1105
1106                 /* Send HAL event */
1107                 memset(&ev, 0, sizeof(ev));
1108                 ev.conn_id = conn_info->connection_id;
1109                 ev.trans_id = req_id;
1110                 ev.att_handle = char_hdl;
1111                 ev.offset = offset;
1112                 ev.is_long = false; /* TODO*/
1113
1114                 /* Convert address to hex */
1115                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
1116
1117                 event_cb(HAL_EV_GATT_READ_REQUESTED, (void *)&ev, sizeof(ev));
1118                 return;
1119         } else if (g_strcmp0(method_name, "WriteValue") == 0) {
1120                 GVariant *var = NULL;
1121                 gchar *addr = NULL;
1122                 guint req_id = 0;
1123                 guint16 offset = 0;
1124                 gboolean response_needed = FALSE;
1125                 struct hal_ev_gatt_server_write_req ev;
1126                 int char_hdl = -1;
1127                 int len;
1128
1129                 struct gatt_service_info *svc_info = NULL;
1130                 struct gatt_req_info *req_info = NULL;
1131                 struct gatt_client_info_t *conn_info = NULL;
1132
1133                 memset(&ev, 0, sizeof(ev));
1134
1135                 DBG("WriteValue");
1136                 DBG("Application path = %s", object_path);
1137                 DBG("Sender = %s", sender);
1138
1139                 g_variant_get(parameters, "(&suqb@ay)",
1140                                 &addr, &req_id, &offset, &response_needed, &var);
1141                 DBG("Request id = %u, Offset = %u", req_id, offset);
1142
1143                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1144
1145                 /* Check if device is already in connected list */
1146                 conn_info = __bt_find_remote_gatt_client_info(addr);
1147
1148                 if (svc_info == NULL || conn_info == NULL || event_cb == NULL) {
1149                         g_variant_unref(var);
1150                         if (response_needed)
1151                                 g_dbus_method_invocation_return_value(invocation, NULL);
1152                         else
1153                                 g_object_unref(invocation);
1154                         return;
1155                 }
1156
1157                 len = g_variant_get_size(var);
1158                 if (len > 0 && len < 600) {
1159                         char *data;
1160                         data = (char *)g_variant_get_data(var);
1161                         memcpy(ev.value, data, len);
1162                         ev.length = len;
1163                 }
1164
1165                 if (response_needed) {
1166                         /* Store requets information */
1167                         req_info = g_new0(struct gatt_req_info, 1);
1168                         req_info->attr_path = g_strdup(object_path);
1169                         req_info->svc_path = g_strdup(svc_info->serv_path);
1170                         req_info->request_id = req_id;
1171                         req_info->request_type = BT_HAL_GATT_REQUEST_TYPE_WRITE;
1172                         req_info->offset = offset;
1173                         req_info->context = invocation;
1174
1175                         /* Append request info in list of requests for the particular connection */
1176                         conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
1177
1178                 } else {
1179                         g_object_unref(invocation);
1180                 }
1181
1182                 /* Send HAL event */
1183                 ev.conn_id = conn_info->connection_id;
1184                 ev.trans_id = req_id;
1185                 ev.att_handle = char_hdl;
1186                 ev.offset = offset;
1187                 ev.need_rsp = response_needed;
1188                 ev.is_prep = 0;
1189
1190                 /* Convert address to hex */
1191                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
1192
1193                 event_cb(HAL_EV_GATT_WRITE_REQUESTED, (void *)&ev, sizeof(ev));
1194
1195                 g_variant_unref(var);
1196                 return;
1197
1198         } else if (g_strcmp0(method_name, "StartNotify") == 0) {
1199                 DBG("StartNotify");
1200 #ifdef TIZEN_BT_HAL
1201                 struct gatt_service_info *svc_info = NULL;
1202                 struct hal_ev_gatt_server_notifcation_change ev;
1203                 int char_hdl = -1;
1204
1205                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1206                 if (svc_info == NULL || event_cb == NULL)
1207                         return;
1208
1209                 /* Send HAL event */
1210                 memset(&ev, 0, sizeof(ev));
1211                 ev.conn_id = -1;  /*TODO Bluez does not provide remote GATT client address, so no conn_id */
1212                 ev.trans_id = -1; /*TODO Bluez does not provide request id or transacion ID */
1213                 ev.att_handle = char_hdl;
1214                 ev.notify = true;
1215
1216                 /* Convert address to hex */
1217                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, "00:00:00:00:00"); /* TODO Bluez Does not provide address of GATT client */
1218
1219                 event_cb(HAL_EV_GATT_NOTIFICATION_CHANGE, (void *)&ev, sizeof(ev));
1220 #endif
1221
1222         } else if (g_strcmp0(method_name, "StopNotify") == 0) {
1223                 DBG("StopNotify");
1224 #ifdef TIZEN_BT_HAL
1225                 struct gatt_service_info *svc_info = NULL;
1226                 struct hal_ev_gatt_server_notifcation_change ev;
1227                 int char_hdl = -1;
1228
1229                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1230                 if (svc_info == NULL || event_cb == NULL)
1231                         return;
1232
1233                 /* Send HAL event */
1234                 memset(&ev, 0, sizeof(ev));
1235                 ev.conn_id = -1;  /*TODO Bluez does not provide remote GATT client address, so no conn_id */
1236                 ev.trans_id = -1; /*TODO Bluez does not provide request id or transacion ID */
1237                 ev.att_handle = char_hdl;
1238                 ev.notify = false;
1239
1240                 /* Convert address to hex */
1241                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, "00:00:00:00:00"); /* TODO Bluez DOes not provide address of GATT client */
1242
1243                 event_cb(HAL_EV_GATT_NOTIFICATION_CHANGE, (void *)&ev, sizeof(ev));
1244 #endif
1245
1246         } else if (g_strcmp0(method_name, "IndicateConfirm") == 0) {
1247                 gchar *addr = NULL;
1248                 gboolean complete = FALSE;
1249                 int char_hdl = -1;
1250
1251                 struct gatt_service_info *svc_info = NULL;
1252                 struct gatt_client_info_t *conn_info = NULL;
1253
1254                 struct hal_ev_gatt_server_indicate_cfm ev;
1255
1256                 DBG("IndicateConfirm");
1257                 DBG("Application path = %s", object_path);
1258                 DBG("Sender = %s", sender);
1259
1260                 g_variant_get(parameters, "(&sb)", &addr, &complete);
1261                 DBG("Remote Device address number = %s", addr);
1262                 DBG("Is Indicate confirmation for last device [%d]", complete);
1263
1264                 /* Check if device is already in connected list */
1265                 conn_info = __bt_find_remote_gatt_client_info(addr);
1266
1267                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1268
1269                 if (svc_info == NULL || conn_info == NULL
1270                         || event_cb == NULL) {
1271                         return;
1272                 }
1273
1274                 /* Send HAL event */
1275                 memset(&ev, 0, sizeof(ev));
1276                 ev.conn_id = conn_info->connection_id;
1277                 ev.trans_id = -1; /*TODO Bluez does not provide Transaction ID or request ID */
1278                 ev.att_handle = char_hdl;
1279
1280                 /* Convert address to hex */
1281                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
1282
1283                 event_cb(HAL_EV_GATT_INDICATE_CFM, (void *)&ev, sizeof(ev));
1284         } else if (g_strcmp0(method_name, "AcquireWrite") == 0) {
1285
1286                                 uint16_t mtu = 512;
1287                                 int char_hdl = -1;
1288                                 struct hal_ev_gatt_server_acquire_write_res  ev;
1289                                 struct gatt_service_info *svc_info = NULL;
1290                                 struct gatt_req_info *req_info = NULL;
1291                                 struct gatt_client_info_t *conn_info = NULL;
1292                                 char * dev_path = NULL;
1293                                 char * link = 0;
1294                                 char  addr[BT_HAL_ADDRESS_STRING_SIZE];
1295
1296                                 DBG("AcquireWrite");
1297                                 DBG("Application path = %s", object_path);
1298                                 DBG("Sender = %s", sender);
1299
1300                                 GVariantIter* iter;
1301                                 g_variant_get(parameters, "(a{sv})", &iter);
1302                                 char* key = NULL;
1303                                 GVariant* value = NULL;
1304                                 while (g_variant_iter_loop(iter, "{sv}", &key, &value)) {
1305                                                 if (g_strcmp0(key, "MTU") == 0)
1306                                                         g_variant_get(value, "i", &mtu);
1307                                                 else if (g_strcmp0(key, "link") == 0)
1308                                                         g_variant_get(value, "s", &link);
1309                                                 else if (g_strcmp0(key, "device") == 0)
1310                                                         g_variant_get(value, "o", &dev_path);
1311                                 }
1312
1313                                 DBG("AcquireWrite   values retived");
1314                                 DBG(" path  %s LINK = %s, MTU = %u", addr, link, mtu);
1315
1316                                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1317
1318                                 _bt_hal_convert_device_path_to_address(dev_path, addr);
1319
1320                                 DBG("remote adress %s", addr);
1321
1322                                 /* Check if device is already in connected list */
1323                                 conn_info = __bt_find_remote_gatt_client_info(addr);
1324
1325                                 if (conn_info == NULL) {
1326                                         ERR("Cleint info not found\n");
1327                                         goto done;
1328                                 }
1329
1330                                 if (svc_info == NULL) {
1331                                         ERR("svc_info  info not found\n");
1332                                         goto done;
1333                                 }
1334
1335                                 /* Store requets information */
1336                                 req_info = g_new0(struct gatt_req_info, 1);
1337                                 req_info->attr_path = g_strdup(object_path);
1338                                 req_info->svc_path = g_strdup(svc_info->serv_path);
1339                                 req_info->request_id = conn_info->connection_id;
1340                                 req_info->request_type = BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_WRITE;
1341                                 req_info->offset = mtu;
1342                                 req_info->context = invocation;
1343
1344                                 /* Append request info in list of requests for the particular connection */
1345                                 conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
1346
1347                                 /* Send HAL event */
1348                                 memset(&ev, 0, sizeof(ev));
1349                                 ev.conn_id = conn_info->connection_id;
1350                                 ev.char_handl = char_hdl;
1351                                 ev.mtu = mtu;
1352                                 ev.trans_id = conn_info->connection_id;
1353                                 _bt_hal_convert_addr_string_to_type(ev.bdaddr, addr);
1354                                 event_cb(HAL_EV_GATT_SERVER_ACQUIRE_WRITE_RES, (void *)&ev, sizeof(ev));
1355
1356                                 DBG("HAL_EV_GATT_ACQUIRE_WRITE_RES   called");
1357
1358
1359                         return;
1360                 } else if (g_strcmp0(method_name, "AcquireNotify") == 0) {
1361
1362                                 uint16_t mtu = 512;
1363                                 int char_hdl = -1;
1364                                 struct hal_ev_gatt_server_acquire_notify  ev;
1365                                 struct gatt_service_info *svc_info = NULL;
1366                                 struct gatt_client_info_t *conn_info = NULL;
1367                                 struct gatt_req_info *req_info = NULL;
1368                                 char * link = 0;
1369                                 int len = 0;
1370
1371                                 DBG("AcquireNotify");
1372                                 DBG("Application path = %s", object_path);
1373                                 DBG("Sender = %s", sender);
1374
1375                                 GVariantIter* iter;
1376                                 g_variant_get(parameters, "(a{sv})", &iter);
1377                                 char* key = NULL;
1378                                 GVariant* value = NULL;
1379                                 while (g_variant_iter_loop(iter, "{sv}", &key, &value)) {
1380                                                 if (g_strcmp0(key, "MTU") == 0)
1381                                                         g_variant_get(value, "q", &mtu);
1382                                 }
1383
1384                                 DBG("AcquireNotify  values retived");
1385                                 DBG(" MTU = %u",  mtu);
1386
1387                                 svc_info = __bt_gatt_find_gatt_service_from_char(object_path, &char_hdl);
1388
1389                         if (svc_info == NULL) {
1390                                         ERR("svc_info  info not found\n");
1391                                         goto done;
1392                                 }
1393
1394                                 /* Store requets information */
1395                                 req_info = g_new0(struct gatt_req_info, 1);
1396                                 req_info->attr_path = g_strdup(object_path);
1397                                 req_info->svc_path = g_strdup(svc_info->serv_path);
1398                                 req_info->request_id = 33;
1399                                 req_info->request_type = BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_NOTIFY;
1400                                 req_info->offset = mtu;
1401                                 req_info->context = invocation;
1402
1403                                 conn_info = g_new0(struct gatt_client_info_t, 1);
1404                                 conn_info->addr = g_strdup(object_path);
1405                                 INFO("Added GATT client path[%s]", conn_info->addr);
1406                                 conn_info->connection_id = 33;
1407                                 conn_info->instance_id = 33;
1408                                 /* Append request info in list of requests for the particular connection */
1409                                 conn_info->gatt_req_info_list = g_slist_append(conn_info->gatt_req_info_list, req_info);
1410                                 gatt_client_info_list = g_slist_append(gatt_client_info_list, conn_info);
1411
1412                                 /* Send HAL event */
1413                                 memset(&ev, 0, sizeof(ev));
1414                                 ev.conn_id = 33;
1415                                 ev.char_handl = char_hdl;
1416                                 ev.mtu = mtu;
1417                                 ev.trans_id = 33;
1418
1419                                 event_cb(HAL_EV_GATT_SERVER_ACQUIRE_NOTIFY_RES, (void *)&ev, sizeof(ev));
1420
1421                                 DBG("HAL_EV_GATT_ACQUIRE_NOTIFY_RES   called");
1422
1423                                 return;
1424         }
1425
1426 done:
1427         g_dbus_method_invocation_return_value(invocation, NULL);
1428 }
1429
1430 gboolean __bt_hal_gatt_emit_interface_removed(gchar *object_path, gchar *interface)
1431 {
1432         gboolean ret;
1433         GError *error = NULL;
1434         GVariantBuilder *array_builder;
1435
1436         array_builder = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
1437         g_variant_builder_init(array_builder, G_VARIANT_TYPE("as"));
1438         g_variant_builder_add(array_builder, "s", interface);
1439
1440         ret = g_dbus_connection_emit_signal(g_conn, NULL, "/",
1441                         "org.freedesktop.Dbus.Objectmanager",
1442                         "InterfacesRemoved",
1443                         g_variant_new("(oas)",
1444                                 object_path, array_builder),
1445                         &error);
1446
1447         if (!ret) {
1448                 if (error != NULL) {
1449                         /* dbus gives error cause */
1450                         ERR("d-bus api failure: errcode[%x], message[%s]",
1451                                         error->code, error->message);
1452                         g_clear_error(&error);
1453                 }
1454         }
1455         g_variant_builder_unref(array_builder);
1456
1457         return ret;
1458 }
1459
1460 static void __bt_hal_gatt_free_descriptor_info(struct gatt_desc_info *desc_info)
1461 {
1462         int i;
1463
1464         if (!desc_info)
1465                 return;
1466
1467         g_free(desc_info->desc_path);
1468         g_free(desc_info->desc_uuid);
1469         g_free(desc_info->desc_value);
1470
1471         for (i = 0; i < desc_info->flags_length; i++)
1472                 g_free(desc_info->desc_flags[i]);
1473
1474         g_free(desc_info);
1475 }
1476
1477 static void __bt_hal_gatt_free_characteristic_info(struct gatt_char_info *char_info)
1478 {
1479         int i;
1480
1481         if (!char_info)
1482                 return;
1483
1484         g_free(char_info->char_path);
1485         g_free(char_info->char_uuid);
1486         g_free(char_info->char_value);
1487
1488         for (i = 0; i < char_info->flags_length; i++)
1489                 g_free(char_info->char_flags[i]);
1490
1491         g_free(char_info);
1492 }
1493
1494
1495 static void __bt_hal_gatt_free_service_info(struct gatt_service_info *svc_info)
1496 {
1497         if (!svc_info)
1498                 return;
1499
1500         g_free(svc_info->serv_path);
1501         g_free(svc_info->service_uuid);
1502         g_free(svc_info);
1503 }
1504
1505 static const GDBusInterfaceVTable desc_interface_vtable = {
1506         __bt_gatt_desc_method_call,
1507         NULL,
1508         NULL,
1509 };
1510
1511 static const GDBusInterfaceVTable char_interface_vtable = {
1512         __bt_gatt_char_method_call,
1513         NULL,
1514         NULL,
1515 };
1516
1517 static const GDBusInterfaceVTable serv_interface_vtable = {
1518         NULL,
1519         NULL,
1520         NULL,
1521 };
1522
1523 static const GDBusInterfaceVTable manager_interface_vtable = {
1524         __bt_gatt_manager_method_call,
1525         NULL,
1526         NULL
1527 };
1528
1529
1530 static GDBusNodeInfo *__bt_gatt_create_method_node_info(
1531                 const gchar *introspection_data)
1532 {
1533         GError *err = NULL;
1534         GDBusNodeInfo *node_info = NULL;
1535
1536         if (introspection_data == NULL)
1537                 return NULL;
1538
1539
1540         DBG("Create new node info");
1541         node_info = g_dbus_node_info_new_for_xml(introspection_data, &err);
1542
1543         if (err) {
1544                 ERR("Unable to create node: %s", err->message);
1545                 g_clear_error(&err);
1546                 return NULL;
1547         }
1548
1549         return node_info;
1550 }
1551
1552 /* To send stack event to hal-av handler */
1553 void _bt_hal_register_gatt_server_handler_cb(handle_stack_msg cb)
1554 {
1555         event_cb = cb;
1556 }
1557
1558 void _bt_hal_unregister_gatt_server_handler_cb(void)
1559 {
1560         event_cb = NULL;
1561 }
1562
1563 static gboolean __bt_hal_gatt_desc_added_cb(gpointer user_data)
1564 {
1565         struct hal_ev_gatt_desc_added ev;
1566         hal_gatt_desc_added *data = (hal_gatt_desc_added*) user_data;
1567
1568         /* Prepare to GATT characteristic added event */
1569         memset(&ev, 0, sizeof(ev));
1570         ev.status = BT_STATUS_SUCCESS;
1571         ev.server_instance = data->instance_data;
1572         memcpy(ev.desc_uuid, data->uuid.uu, sizeof(data->uuid.uu));
1573         ev.service_handle = data->srvc_hdl;
1574         ev.desc_handle = data->desc_hdl;
1575
1576         if (!event_cb)
1577                 ERR("GATT Descriptor Added callback registered");
1578         else {
1579                 DBG("GATT Descriptor Added: server if [%d] Service handle [%d] Descriptor Handle [%d]",
1580                                 data->instance_data, data->srvc_hdl, data->desc_hdl);
1581
1582                 event_cb(HAL_EV_GATT_DESC_ADDED, (void *)&ev, sizeof(ev));
1583         }
1584
1585         g_free(data);
1586         return FALSE;
1587 }
1588
1589 static gboolean __bt_hal_gatt_char_added_cb(gpointer user_data)
1590 {
1591         struct hal_ev_gatt_char_added ev;
1592         hal_gatt_char_added *data = (hal_gatt_char_added*) user_data;
1593
1594         /* Prepare to GATT characteristic added event */
1595         memset(&ev, 0, sizeof(ev));
1596         ev.status = BT_STATUS_SUCCESS;
1597         ev.server_instance = data->instance_data;
1598         memcpy(ev.char_uuid, data->uuid.uu, sizeof(data->uuid.uu));
1599         ev.service_handle = data->srvc_hdl;
1600         ev.char_handle = data->char_hdl;
1601
1602         if (!event_cb)
1603                 ERR("GATT Characteristic Added callback registered");
1604         else {
1605                 DBG("GATT Characteristic Added: server if [%d] Service handle [%d] Characteristic handle [%d]",
1606                                 data->instance_data, data->srvc_hdl, data->char_hdl);
1607
1608                 event_cb(HAL_EV_GATT_CHAR_ADDED, (void *)&ev, sizeof(ev));
1609         }
1610
1611         g_free(data);
1612         return FALSE;
1613 }
1614
1615 static gboolean __bt_hal_gatt_service_added_cb(gpointer user_data)
1616 {
1617         struct hal_ev_gatt_service_added ev;
1618         hal_gatt_service_added *data = (hal_gatt_service_added*) user_data;
1619
1620         /* Prepare to GATT Service added event */
1621         memset(&ev, 0, sizeof(ev));
1622         ev.status = BT_STATUS_SUCCESS;
1623         ev.server_instance = data->instance_data;
1624         memcpy(ev.svc_uuid, data->uuid.uu, sizeof(data->uuid.uu));
1625         ev.service_handle = data->srvc_hdl;
1626         ev.is_primary = data->is_primary;
1627
1628         if (!event_cb)
1629                 ERR("GATT Service Added callback registered");
1630         else {
1631                 DBG("GATT Service Added: server if [%d] Service handle [%d]",
1632                                 data->instance_data,  data->srvc_hdl);
1633                 event_cb(HAL_EV_GATT_SERVICE_ADDED, (void *)&ev, sizeof(ev));
1634         }
1635
1636         g_free(data);
1637         return FALSE;
1638 }
1639
1640 static gboolean __bt_hal_gatt_service_started_cb(gpointer user_data)
1641 {
1642         struct hal_ev_gatt_service_started ev;
1643         hal_gatt_service_started *data = (hal_gatt_service_started*) user_data;
1644
1645         /* Prepare to GATT Service added event */
1646         memset(&ev, 0, sizeof(ev));
1647         ev.status = BT_STATUS_SUCCESS;
1648         ev.server_instance = data->instance_data;
1649         ev.service_handle = data->srvc_hdl;
1650
1651         if (!event_cb)
1652                 ERR("GATT Service Started callback registered");
1653         else {
1654                 DBG("GATT Service Started: server if [%d] Service handle [%d]",
1655                                 data->instance_data,  data->srvc_hdl);
1656                 event_cb(HAL_EV_GATT_SERVICE_STARTED, (void *)&ev, sizeof(ev));
1657         }
1658
1659         g_free(data);
1660         return FALSE;
1661 }
1662
1663 static gboolean __bt_hal_gatt_service_deleted_cb(gpointer user_data)
1664 {
1665         struct hal_ev_gatt_service_deleted ev;
1666         hal_gatt_service_deleted *data = (hal_gatt_service_deleted*) user_data;
1667
1668         /* Prepare to GATT Service added event */
1669         memset(&ev, 0, sizeof(ev));
1670         ev.status = BT_STATUS_SUCCESS;
1671         ev.server_instance = data->instance_data;
1672         ev.service_handle = data->srvc_hdl;
1673
1674         if (!event_cb)
1675                 ERR("GATT Service Deleted callback registered");
1676         else {
1677                 DBG("GATT Service Deleted: server if [%d] Service handle [%d]",
1678                                 data->instance_data,  data->srvc_hdl);
1679                 event_cb(HAL_EV_GATT_SERVICE_DELETED, (void *)&ev, sizeof(ev));
1680         }
1681
1682         g_free(data);
1683         return FALSE;
1684 }
1685
1686 static gboolean __bt_hal_register_slot_id_cb(gpointer user_data)
1687 {
1688         struct hal_ev_server_instance_registered ev;
1689         hal_register_server_data *data = (hal_register_server_data*) user_data;
1690
1691         /* Prepare to send AV connecting event */
1692         memset(&ev, 0, sizeof(ev));
1693         ev.status = BT_STATUS_SUCCESS;
1694         ev.server_instance = data->instance_data;
1695         memcpy(ev.app_uuid, data->uuid.uu, sizeof(ev.app_uuid));
1696
1697         if (!event_cb)
1698                 ERR("GATT Register Server Instance Callback not registered");
1699         else {
1700                 DBG("Server Instance is registered!! server if [%d]", data->instance_data);
1701                 event_cb(HAL_EV_SERVER_INSTANCE_INITIALIZED, (void *)&ev, sizeof(ev));
1702         }
1703
1704         g_free(data);
1705         return FALSE;
1706 }
1707
1708 static bt_status_t gatt_server_register_app(bt_uuid_t *uuid)
1709 {
1710         CHECK_BTGATT_INIT();
1711         int status = BT_STATUS_FAIL;
1712         int server_if;
1713         DBG("Register server instance request");
1714         hal_register_server_data *user_data = g_malloc0(sizeof(hal_register_server_data));
1715
1716         /* Check if slot available */
1717         server_if = _bt_hal_get_available_adv_slot_id(uuid);
1718
1719         if (server_if == -1) {
1720                 ERR("Allocation of server instance failed");
1721                 g_free(user_data);
1722                 return status;
1723         } else {
1724                 user_data->instance_data = server_if;
1725                 DBG("Allocated new Advertising slot with Stack [%d]", user_data->instance_data);
1726         }
1727
1728         /*
1729          * As we need to provide async callback to user from HAL, simply schedule a
1730          * callback method which will carry actual result
1731          */
1732         memcpy(user_data->uuid.uu, uuid->uu, sizeof(bt_uuid_t));
1733         g_idle_add(__bt_hal_register_slot_id_cb, (gpointer)user_data);
1734
1735         /* If available, then return success, else return error */
1736         return BT_STATUS_SUCCESS;
1737 }
1738
1739 void _bt_hal_remove_gatt_server_from_list(int server_if)
1740 {
1741         GSList *l;
1742         struct gatt_server_app *info = NULL;
1743
1744         for (l = gatt_server_apps; l != NULL;) {
1745                 info = (struct gatt_server_app*)l->data;
1746                 l = g_slist_next(l);
1747                 if (info == NULL)
1748                         continue;
1749                 if (info->slot == server_if) {
1750                         INFO("Found Matching GATT Server in List path[%s] slot [%d]",
1751                                 info->app_path, info->slot);
1752
1753                         /* Only if all services are deleted from the GATT Server, then only Unregister it.
1754                         Reason: it is possible, GATT Server app oly wants to disable multi advertising
1755                         In above case, only advertising block will be deallocated, Gatt Server will remain
1756                         unaffected */
1757                         if (info->services == NULL) {
1758                                 gatt_server_apps = g_slist_remove(gatt_server_apps, (gpointer)info);
1759                                 INFO("Total gatt server apps still existing after removing above is [%d]",
1760                                                 g_slist_length(gatt_server_apps));
1761
1762                                 /* DBUS Unregister only for current app */
1763                                 __bt_hal_gatt_deinit(info->app_path);
1764
1765                                 g_free(info->app_path);
1766                                 g_free(info);
1767                                 return;
1768                         } else {
1769                                 INFO("GATT Server still has services count[%d] in it..Can not remove it!!!",
1770                                         g_slist_length(info->services));
1771                         }
1772                 }
1773         }
1774 }
1775
1776 static bt_status_t gatt_server_unregister_app(int server_if)
1777 {
1778         CHECK_BTGATT_INIT();
1779         DBG("Un-Register server instance request [%d]", server_if);
1780
1781         if (_bt_hal_is_advertising_in_slot(server_if) == FALSE)
1782                 _bt_hal_free_server_slot(server_if);
1783
1784         /* If server_if belongs to a GATT Server, then delete the GATT server from List */
1785         _bt_hal_remove_gatt_server_from_list(server_if);
1786         return BT_STATUS_SUCCESS;
1787 }
1788
1789 static bt_status_t gatt_server_open(int server_if, const bt_bdaddr_t *bd_addr, bool is_direct)
1790 {
1791         CHECK_BTGATT_INIT();
1792         return BT_STATUS_SUCCESS;
1793 }
1794
1795 static bt_status_t gatt_server_close(int server_if, const bt_bdaddr_t *bd_addr, int conn_id)
1796 {
1797         CHECK_BTGATT_INIT();
1798         return BT_STATUS_SUCCESS;
1799 }
1800
1801 static void __bt_gatt_close_gdbus_connection(void)
1802 {
1803         GError *err = NULL;
1804         DBG("+");
1805
1806         if (g_conn == NULL)
1807                 return;
1808
1809         if (!g_dbus_connection_flush_sync(g_conn, NULL, &err)) {
1810                 ERR("Fail to flush the connection: %s", err->message);
1811                 g_error_free(err);
1812                 err = NULL;
1813         }
1814
1815         if (!g_dbus_connection_close_sync(g_conn, NULL, &err)) {
1816                 if (err) {
1817                         ERR("Fail to close the dbus connection: %s", err->message);
1818                         g_error_free(err);
1819                 }
1820         }
1821
1822         g_object_unref(g_conn);
1823         g_conn = NULL;
1824         DBG("-");
1825 }
1826
1827 static GDBusConnection *__bt_gatt_get_gdbus_connection(void)
1828 {
1829         GDBusConnection *local_system_gconn = NULL;
1830         char *address;
1831         GError *err = NULL;
1832
1833         if (g_conn == NULL) {
1834                 address = g_dbus_address_get_for_bus_sync(G_BUS_TYPE_SYSTEM, NULL, &err);
1835                 if (address == NULL) {
1836                         if (err) {
1837                                 ERR("Failed to get bus address: %s", err->message);
1838                                 g_clear_error(&err);
1839                         }
1840                         return NULL;
1841                 }
1842
1843                 g_conn = g_dbus_connection_new_for_address_sync(address,
1844                                 G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT |
1845                                 G_DBUS_CONNECTION_FLAGS_MESSAGE_BUS_CONNECTION,
1846                                 NULL, /* GDBusAuthObserver */
1847                                 NULL,
1848                                 &err);
1849                 if (!g_conn) {
1850                         if (err) {
1851                                 ERR("Unable to connect to dbus: %s", err->message);
1852                                 g_clear_error(&err);
1853                         }
1854                         return NULL;
1855                 }
1856         } else if (g_dbus_connection_is_closed(g_conn)) {
1857                 address = g_dbus_address_get_for_bus_sync(G_BUS_TYPE_SYSTEM, NULL, &err);
1858                 if (address == NULL) {
1859                         if (err) {
1860                                 ERR("Failed to get bus address: %s", err->message);
1861                                 g_clear_error(&err);
1862                         }
1863                         return NULL;
1864                 }
1865
1866                 local_system_gconn = g_dbus_connection_new_for_address_sync(address,
1867                                 G_DBUS_CONNECTION_FLAGS_AUTHENTICATION_CLIENT |
1868                                 G_DBUS_CONNECTION_FLAGS_MESSAGE_BUS_CONNECTION,
1869                                 NULL, /* GDBusAuthObserver */
1870                                 NULL,
1871                                 &err);
1872
1873                 if (!local_system_gconn) {
1874                         ERR("Unable to connect to dbus: %s", err->message);
1875                         g_clear_error(&err);
1876                 }
1877
1878                 g_conn = local_system_gconn;
1879         }
1880
1881         return g_conn;
1882 }
1883
1884 static char* __bt_hal_convert_uuid_to_string(bt_uuid_t *srvc_id)
1885 {
1886         char uuid_buf[5];
1887         const char *uuid;
1888
1889         uuid = btuuid2str(srvc_id->uu);
1890         DBG("Original UUID [%s]", uuid);
1891
1892         if (_bt_hal_uuid_is_standard(srvc_id) == TRUE) {
1893                 /* Extract Standard UUID string */
1894                 memcpy(uuid_buf, &uuid[4], 4);
1895                 uuid_buf[4] = '\0';
1896                 DBG("Converted string [%s]", uuid_buf);
1897                 return g_strdup(uuid_buf);
1898         } else
1899                 return strdup(uuid);
1900 }
1901
1902 int __bt_hal_add_service_to_dbus(char *app_path, int slot, btgatt_srvc_id_t *srvc_id)
1903 {
1904         gboolean ret;
1905         /* For GATT service specific */
1906         GDBusNodeInfo *node_info;
1907         guint object_id;
1908         gchar *path = NULL;
1909         struct gatt_service_info *serv_info = NULL;
1910         GVariantBuilder *builder = NULL;
1911         GVariantBuilder *builder1 = NULL;
1912         GVariantBuilder *inner_builder = NULL;
1913         gboolean svc_primary = TRUE;
1914         GError *error = NULL;
1915         hal_gatt_service_added *user_data = NULL;
1916         DBG("Service add to DBUS slot [%d]", slot);
1917
1918         node_info = __bt_gatt_create_method_node_info(
1919                         service_introspection_xml);
1920
1921         if (node_info == NULL)
1922                 return BT_STATUS_FAIL;
1923
1924         DBG("Add new GATT Service: Current GATT Service handle [%d]", gatt_service_handle);
1925         path = g_strdup_printf("%s"GATT_SERV_OBJECT_PATH"%d", app_path, ++gatt_service_handle);
1926         DBG("gatt service path is [%s]", path);
1927
1928         object_id = g_dbus_connection_register_object(g_conn, path,
1929                         node_info->interfaces[0],
1930                         &serv_interface_vtable,
1931                         NULL, NULL, &error);
1932
1933         if (object_id == 0) {
1934                 ERR("failed to register: %s", error->message);
1935                 g_error_free(error);
1936                 g_free(path);
1937                 return BT_STATUS_FAIL;
1938         }
1939         /* Add object_id/gatt service information; it's required at the time of
1940          *  service unregister and Getmanagedobjects
1941          */
1942         serv_info = g_new0(struct gatt_service_info, 1);
1943
1944         serv_info->serv_path = g_strdup(path);
1945         serv_info->serv_id = object_id;
1946         serv_info->service_uuid = __bt_hal_convert_uuid_to_string(&srvc_id->id.uuid);//g_strdup(btuuid2str(srvc_id->id.uuid.uu));
1947         serv_info->is_svc_registered = FALSE;
1948         serv_info->is_svc_primary = svc_primary;
1949         DBG("Service Handle to be added is [%d]", gatt_service_handle);
1950         serv_info->service_handle = gatt_service_handle;
1951
1952         /* Update service in GATT Server service List */
1953         gatt_services = g_slist_append(gatt_services, serv_info);
1954
1955         /* emit interfacesadded signal here for service path */
1956         builder = g_variant_builder_new(G_VARIANT_TYPE("a{sa{sv}}"));
1957         inner_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
1958
1959         g_variant_builder_add(inner_builder, "{sv}",
1960                         "UUID", g_variant_new_string(btuuid2str(srvc_id->id.uuid.uu)));
1961
1962         g_variant_builder_add(inner_builder, "{sv}",
1963                         "Primary", g_variant_new_boolean(svc_primary));
1964
1965         builder1 = g_variant_builder_new(G_VARIANT_TYPE("ao"));
1966
1967         g_variant_builder_add(inner_builder, "{sv}", "Characteristics",
1968                         g_variant_new("ao", builder1));
1969
1970         g_variant_builder_add(builder, "{sa{sv}}",
1971                         GATT_SERV_INTERFACE, inner_builder);
1972
1973         ret = g_dbus_connection_emit_signal(g_conn, NULL, "/",
1974                         "org.freedesktop.Dbus.ObjectManager",
1975                         "InterfacesAdded",
1976                         g_variant_new("(oa{sa{sv}})",
1977                                 path, builder),
1978                         &error);
1979         if (!ret) {
1980                 if (error) {
1981                         /* dbus gives error cause */
1982                         ERR("d-bus api failure: errcode[%x], message[%s]",
1983                                         error->code, error->message);
1984                         g_clear_error(&error);
1985                 }
1986         }
1987
1988         /* Send Service handle to application */
1989         user_data = g_malloc0(sizeof(hal_gatt_service_added));
1990         user_data->srvc_hdl = serv_info->service_handle;
1991         user_data->instance_data = slot;
1992         memcpy(user_data->uuid.uu, srvc_id->id.uuid.uu, sizeof(srvc_id->id.uuid.uu));
1993         g_idle_add(__bt_hal_gatt_service_added_cb, (gpointer)user_data);
1994
1995         /* Save newly created service in GATT Server's service list */
1996         _bt_hal_update_gatt_service_in_gatt_server(slot, serv_info);
1997
1998         /* Free data */
1999         g_free(path);
2000         g_variant_builder_unref(inner_builder);
2001         g_variant_builder_unref(builder);
2002         g_variant_builder_unref(builder1);
2003         return BT_STATUS_SUCCESS;
2004 }
2005
2006 static void __bt_hal_unregister_application_cb(GObject *object, GAsyncResult *res,
2007                 gpointer user_data)
2008 {
2009         char *app_path = (char*)user_data;
2010         INFO("UnregisterApplication is completed app [%s]", app_path);
2011         GError *error = NULL;
2012         GVariant *result = NULL;
2013
2014         if (manager_gproxy)
2015         result = g_dbus_proxy_call_finish(manager_gproxy, res, &error);
2016
2017         if (result == NULL) {
2018                 /* dBUS-RPC is failed */
2019                 ERR("Dbus-RPC is failed\n");
2020
2021                 if (error != NULL) {
2022                         /* dBUS gives error cause */
2023                         ERR("D-Bus API failure: errCode[%x], message[%s]\n",
2024                                         error->code, error->message);
2025                         g_clear_error(&error);
2026                 }
2027         } else {
2028                 g_variant_unref(result);
2029         }
2030         g_free(app_path);
2031 }
2032
2033 static void __bt_hal_gatt_deinit(char *app_path)
2034 {
2035         GDBusProxy *proxy = NULL;
2036         char *data;
2037         INFO("+");
2038
2039         /* Step1: Remove requested App */
2040         proxy = __bt_gatt_gdbus_get_gatt_manager_proxy("org.bluez",
2041                         "/org/bluez/hci0", "org.bluez.GattManager1");
2042
2043         if (proxy == NULL)
2044                 return;
2045
2046         INFO("UnregisterApplication : path [%s]", app_path);
2047
2048         /* Async Call to Unregister Service */
2049         data = g_strdup(app_path);
2050         g_dbus_proxy_call(proxy,
2051                         "UnregisterApplication",
2052                         g_variant_new("(o)",
2053                                 app_path),
2054                         G_DBUS_CALL_FLAGS_NONE, -1,
2055                         NULL,
2056                         (GAsyncReadyCallback)__bt_hal_unregister_application_cb,
2057                         (gpointer)data);
2058
2059         /* If requested app is last GATT Server app, then clean all resources */
2060         if (gatt_server_apps == NULL) {
2061                 INFO("All GATT servers are removed, clean all DBUS resources");
2062                 if (owner_id) {
2063                         /* unregister the exported interface for object manager
2064                            g_conn and manager_id are common for all GATT servers */
2065                         g_dbus_connection_unregister_object(g_conn,
2066                                         manager_id);
2067                         manager_id = 0;
2068                         g_bus_unown_name(owner_id);
2069                         owner_id = 0;
2070
2071                         g_object_unref(manager_gproxy);
2072                         manager_gproxy = NULL;
2073
2074                         /* Close the GDBUS connection */
2075                         __bt_gatt_close_gdbus_connection();
2076                 }
2077         }
2078         INFO("-");
2079 }
2080
2081 int __bt_hal_gatt_init(void)
2082 {
2083         GDBusConnection *conn = NULL;
2084         DBG("+");
2085         /* Only once for ALL GATT Servers */
2086         if (owner_id == 0) {
2087                 owner_id = g_bus_own_name(G_BUS_TYPE_SYSTEM,
2088                                 BT_GATT_SERVICE_NAME,
2089                                 G_BUS_NAME_OWNER_FLAGS_NONE,
2090                                 NULL, NULL, NULL, NULL, NULL);
2091         }
2092         INFO("Owner ID [%d]", owner_id);
2093
2094         /* Only once for ALL GATT Servers conn = g_conn(global)*/
2095         conn = __bt_gatt_get_gdbus_connection();
2096         if (!conn) {
2097                 ERR("Unable to get connection");
2098                 return BT_STATUS_FAIL;
2099         }
2100
2101         /* Only once for ALL GATT Servers */
2102         if (manager_node_info == NULL) {
2103                 /* Register ObjectManager interface */
2104                 manager_node_info = __bt_gatt_create_method_node_info(
2105                                 manager_introspection_xml);
2106
2107                 if (manager_node_info == NULL) {
2108                         ERR("failed to get node info");
2109                         return BT_STATUS_FAIL;
2110                 }
2111         }
2112
2113         INFO("-");
2114         return BT_STATUS_SUCCESS;
2115 }
2116
2117 void _bt_hal_is_gatt_server_initialzed(int slot, char **app_path)
2118 {
2119         GSList *l;
2120
2121         for (l = gatt_server_apps; l; l = g_slist_next(l)) {
2122                 struct gatt_server_app *app = (struct gatt_server_app *)l->data;
2123                 if (app->slot == slot) {
2124                         INFO("GATT Server app found app path [%s] instance [%d]",
2125                                         app->app_path, app->slot);
2126                         *app_path = app->app_path;
2127                         return;
2128                 }
2129         }
2130         /* GATT Server not found */
2131         *app_path = NULL;
2132 }
2133
2134 void _bt_hal_update_gatt_server_path(int slot, char *app_path)
2135 {
2136         if (app_path == NULL)
2137                 return;
2138
2139         struct gatt_server_app *app = g_malloc0(sizeof(struct gatt_server_app));
2140         app->app_path = g_strdup(app_path);
2141         app->slot = slot;
2142         gatt_server_apps = g_slist_append(gatt_server_apps, app);
2143         INFO("GATT Server: Path [%s] Slot [%d]-> Updated", app_path, slot);
2144
2145 }
2146
2147
2148 static bt_status_t gatt_server_add_service(int server_if, btgatt_srvc_id_t *srvc_id,
2149                 int num_handles)
2150 {
2151         CHECK_BTGATT_INIT();
2152         char *app_path = NULL;
2153         GError *error = NULL;
2154         int *app_id = NULL;
2155         guint manager_id;
2156
2157         int result = BT_STATUS_SUCCESS;
2158
2159         DBG("GATT Server Add service request: Instance ID[%d] Is Primary [%d] UUID [%s]",
2160                         server_if, srvc_id->is_primary, btuuid2str(srvc_id->id.uuid.uu));
2161
2162         /* Check if this GATT server Application is already registered with DBUS */
2163         _bt_hal_is_gatt_server_initialzed(server_if, &app_path);
2164
2165         if (app_path != NULL) {
2166                 DBG("GATT server path is already defined [%s]", app_path);
2167                 return __bt_hal_add_service_to_dbus(app_path, server_if, srvc_id);
2168         } else {
2169                 DBG("GATT server application path for instance [%d] is not defined yet", server_if);
2170                 result = __bt_hal_gatt_init();
2171                 if (result != BT_STATUS_SUCCESS)
2172                         return result;
2173
2174                 /* Only once for each GATT Server */
2175                 app_path = g_strdup_printf("/com/%d", server_if);
2176
2177                 app_id = g_malloc0(sizeof(int));
2178                 *app_id = server_if;
2179
2180                 manager_id = g_dbus_connection_register_object(g_conn, app_path,
2181                                 manager_node_info->interfaces[0],
2182                                 &manager_interface_vtable,
2183                                 (gpointer)app_id, NULL, &error);
2184
2185                 if (manager_id == 0) {
2186                         ERR("failed to register: %s", error->message);
2187                         g_error_free(error);
2188                         goto failed;
2189                 }
2190
2191                 /* For current GATT Server, app_path is created, save it in Table */
2192                 _bt_hal_update_gatt_server_path(server_if, app_path);
2193
2194                 /* Add GATT Service to DBUS */
2195                 if (__bt_hal_add_service_to_dbus(app_path, server_if, srvc_id) != BT_STATUS_SUCCESS)
2196                         goto failed;
2197
2198                 g_free(app_path);
2199         }
2200
2201         INFO("Successfully added service");
2202         return BT_STATUS_SUCCESS;
2203 failed:
2204
2205         g_free(app_id);
2206
2207         if (app_path)
2208                 g_free(app_path);
2209         INFO("Service addition failed!!");
2210         return BT_STATUS_FAIL;
2211 }
2212
2213 static bt_status_t gatt_server_add_included_service(int server_if, int service_handle,
2214                 int included_handle)
2215 {
2216         CHECK_BTGATT_INIT();
2217         return BT_STATUS_SUCCESS;
2218 }
2219
2220
2221 static gboolean __bt_is_service_last_in_server_list(int instance, int service_handle)
2222 {
2223         GSList *l;
2224         GSList *gatt_services = NULL;
2225         int len;
2226         struct gatt_service_info *info = NULL;
2227
2228         gatt_services =  _bt_get_service_list_from_server(instance);
2229
2230         len = g_slist_length(gatt_services);
2231         l = g_slist_nth(gatt_services, len -1);
2232         if (NULL == l)
2233                 return FALSE;
2234
2235         info = l->data;
2236
2237         if (info->service_handle == service_handle)
2238                 return TRUE;
2239         return FALSE;
2240 }
2241
2242 static struct gatt_service_info *__bt_gatt_find_gatt_service_info(int instance,
2243                 int service_handle)
2244 {
2245         GSList *l;
2246         GSList *gatt_services = NULL;
2247         INFO("Find Service: svc handle [%d] from GATT Server slot[%d]", service_handle, instance);
2248
2249         gatt_services = _bt_get_service_list_from_server(instance);
2250
2251         for (l = gatt_services; l != NULL; l = g_slist_next(l)) {
2252                 struct gatt_service_info *info = l->data;
2253                 INFO("Got one service with handle [%d]", info->service_handle);
2254                 if (info->service_handle == service_handle)
2255                         return info;
2256         }
2257         ERR("Gatt service with handle [%d] not found", service_handle);
2258         return NULL;
2259 }
2260
2261 static bt_status_t gatt_server_add_characteristic(int slot, int service_handle,
2262                 bt_uuid_t *uuid, int properties,
2263                 int permissions)
2264 {
2265         gboolean ret;
2266         GError *error = NULL;
2267         guint object_id;
2268         GDBusNodeInfo *node_info;
2269         gchar *path = NULL;
2270         GVariantBuilder *builder = NULL;
2271         GVariantBuilder *inner_builder = NULL;
2272         struct gatt_service_info *serv_info = NULL;
2273         struct gatt_char_info *char_info = NULL;
2274         GVariantBuilder *builder2 = NULL;
2275         GVariantBuilder *builder3 = NULL;
2276         GVariant *flags_val = NULL;
2277         int i = 0;
2278         char *char_flags[NUMBER_OF_FLAGS];
2279         int flag_count = 0;
2280         hal_gatt_char_added *user_data = NULL;
2281         int *app_id;
2282
2283         CHECK_BTGATT_INIT();
2284         DBG("Add new characteristic to GATT Service handle [%d]", service_handle);
2285         DBG("Properties of new charateristic [%d] Permission [%d]", properties, permissions);
2286
2287         serv_info = __bt_gatt_find_gatt_service_info(slot, service_handle);
2288         if (serv_info == NULL)
2289                 return BT_STATUS_FAIL;
2290
2291         node_info = __bt_gatt_create_method_node_info(
2292                         characteristics_introspection_xml);
2293
2294         if (node_info == NULL)
2295                 return BT_STATUS_FAIL;
2296
2297         DBG("Add new GATT characteristic: Current GATT char handle [%d]", gatt_char_handle);
2298         path = g_strdup_printf("%s/characteristic%d", serv_info->serv_path, ++gatt_char_handle);
2299         DBG("gatt characteristic path is [%s]", path);
2300
2301         app_id = g_malloc0(sizeof(int));
2302         *app_id = slot;
2303
2304         object_id = g_dbus_connection_register_object(g_conn, path,
2305                         node_info->interfaces[0],
2306                         &char_interface_vtable,
2307                         (gpointer)app_id, NULL, &error);
2308
2309         if (object_id == 0) {
2310                 ERR("failed to register: %s", error->message);
2311                 g_error_free(error);
2312                 g_free(path);
2313                 g_free(app_id);
2314                 return BT_STATUS_FAIL;
2315         }
2316
2317         if (permissions & BT_HAL_GATT_PERMISSION_ENCRYPT_READ)
2318                 properties |= BT_HAL_GATT_CHARACTERISTIC_PROPERTY_ENCRYPT_READ;
2319         if (permissions & BT_HAL_GATT_PERMISSION_ENCRYPT_AUTHENTICATED_READ)
2320                 properties |= BT_HAL_GATT_CHARACTERISTIC_PROPERTY_ENCRYPT_AUTHENTICATED_READ;
2321         if (permissions & BT_HAL_GATT_PERMISSION_ENCRYPT_WRITE)
2322                 properties |= BT_HAL_GATT_CHARACTERISTIC_PROPERTY_ENCRYPT_WRITE;
2323         if (permissions & BT_HAL_GATT_PERMISSION_ENCRYPT_AUTHENTICATED_WRITE)
2324                 properties |= BT_HAL_GATT_CHARACTERISTIC_PROPERTY_ENCRYPT_AUTHENTICATED_WRITE;
2325
2326         flag_count = bt_hal_gatt_convert_prop2string(properties, char_flags);
2327
2328         char_info = g_new0(struct gatt_char_info, 1);
2329
2330         char_info->char_path = g_strdup(path);
2331         char_info->char_id = object_id;
2332         char_info->char_uuid = __bt_hal_convert_uuid_to_string(uuid);//g_strdup(btuuid2str(uuid->uu));
2333         for (i = 0; i < flag_count; i++)
2334                 char_info->char_flags[i] = char_flags[i];
2335
2336
2337         char_info->flags_length = flag_count;
2338         char_info->char_handle = gatt_char_handle;
2339
2340
2341         builder = g_variant_builder_new(G_VARIANT_TYPE("a{sa{sv}}"));
2342         inner_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
2343
2344         g_variant_builder_add(inner_builder, "{sv}", "UUID",
2345                         g_variant_new("s", char_info->char_uuid));
2346         g_variant_builder_add(inner_builder, "{sv}", "Service",
2347                         g_variant_new("o", serv_info->serv_path));
2348
2349         builder2 = g_variant_builder_new(G_VARIANT_TYPE("as"));
2350
2351         for (i = 0; i < flag_count; i++)
2352                 g_variant_builder_add(builder2, "s", char_flags[i]);
2353
2354         flags_val = g_variant_new("as", builder2);
2355         g_variant_builder_add(inner_builder, "{sv}", "Flags",
2356                         flags_val);
2357
2358         builder3 = g_variant_builder_new(G_VARIANT_TYPE("ao"));
2359
2360         g_variant_builder_add(inner_builder, "{sv}", "Descriptors",
2361                         g_variant_new("ao", builder3));
2362
2363         g_variant_builder_add(builder, "{sa{sv}}",
2364                         GATT_CHAR_INTERFACE,
2365                         inner_builder);
2366
2367         ret = g_dbus_connection_emit_signal(g_conn, NULL, "/",
2368                         "org.freedesktop.Dbus.ObjectManager",
2369                         "InterfacesAdded",
2370                         g_variant_new("(oa{sa{sv}})",
2371                                 path, builder),
2372                         &error);
2373         if (!ret) {
2374                 if (error) {
2375                         /* dbus gives error cause */
2376                         ERR("d-bus api failure: errcode[%x], message[%s]",
2377                                         error->code, error->message);
2378                         g_clear_error(&error);
2379                 }
2380         }
2381
2382         //*char_path = g_strdup(path);
2383
2384         //new_char = TRUE;
2385
2386
2387         /* Send Service handle to application */
2388         user_data = g_malloc0(sizeof(hal_gatt_char_added));
2389         user_data->srvc_hdl = serv_info->service_handle;
2390         user_data->char_hdl = gatt_char_handle;
2391         user_data->instance_data = slot;
2392         memcpy(user_data->uuid.uu, uuid->uu, sizeof(uuid->uu));
2393         g_idle_add(__bt_hal_gatt_char_added_cb, (gpointer)user_data);
2394
2395         /* Save newly created charatcristic to GATT Server's service's characteristic  list */
2396         serv_info->char_data = g_slist_append(serv_info->char_data, char_info);
2397
2398         /* Free data */
2399         g_free(path);
2400
2401         g_variant_builder_unref(inner_builder);
2402         g_variant_builder_unref(builder);
2403         g_variant_builder_unref(builder2);
2404         g_variant_builder_unref(builder3);
2405
2406         return BT_STATUS_SUCCESS;
2407 }
2408
2409 static bt_status_t gatt_server_add_descriptor(int slot, int service_handle, bt_uuid_t *uuid,
2410                 int permissions)
2411 {
2412         CHECK_BTGATT_INIT();
2413
2414 //      static int desc_id = 1;
2415         GError *error = NULL;
2416         guint object_id;
2417         GDBusNodeInfo *node_info;
2418         gchar *path = NULL;
2419         GVariantBuilder *builder = NULL;
2420         GVariantBuilder *inner_builder = NULL;
2421
2422         struct gatt_char_info *char_info = NULL;
2423         struct gatt_desc_info *desc_info = NULL;
2424         struct gatt_service_info *serv_info = NULL;
2425
2426         gchar **line_argv = NULL;
2427         char *serv_path;
2428         char *char_path = NULL;
2429         GSList *l;
2430
2431         GVariantBuilder *builder2 = NULL;
2432         GVariant *flags_val = NULL;
2433         int i = 0;
2434         char *desc_flags[NUMBER_OF_FLAGS];
2435         int flag_count = 0;
2436         int *app_id;
2437
2438         hal_gatt_desc_added *user_data = NULL;
2439 #if 0
2440         if (new_char) {
2441                 desc_id = 1;
2442                 new_char = FALSE;
2443         }
2444 #endif
2445         /* Fetch service data for the GATT server */
2446         serv_info = __bt_gatt_find_gatt_service_info(slot, service_handle);
2447         if (serv_info == NULL)
2448                 return BT_STATUS_FAIL;
2449
2450         /* Fetch list of characteristics from the service info */
2451         l = serv_info->char_data;
2452
2453         /* Fetch last char info from the characteristic list */
2454         char_info = g_slist_last(l)->data;
2455         if (char_info == NULL)
2456                 return BT_STATUS_FAIL;
2457
2458         /* Fetch characteristic path from char info */
2459         char_path = char_info->char_path;
2460
2461         line_argv = g_strsplit_set(char_path, "/", 0);
2462         serv_path = g_strdup_printf("/%s/%s/%s", line_argv[1], line_argv[2], line_argv[3]);
2463
2464
2465         node_info = __bt_gatt_create_method_node_info(
2466                         descriptor_introspection_xml);
2467
2468         if (node_info == NULL) {
2469                 g_strfreev(line_argv);
2470                 g_free(serv_path);
2471                 return BT_STATUS_FAIL;
2472         }
2473
2474         DBG("Add new Descriptor: Current GATT desc handle [%d]", gatt_desc_handle);
2475
2476         path = g_strdup_printf("%s/descriptor%d", char_path, ++gatt_desc_handle);
2477         DBG("gatt descriptor path is [%s]", path);
2478
2479         app_id = g_malloc0(sizeof(int));
2480         *app_id = slot;
2481
2482         object_id = g_dbus_connection_register_object(g_conn, path,
2483                         node_info->interfaces[0],
2484                         &desc_interface_vtable,
2485                         (gpointer)app_id, NULL, &error);
2486
2487         if (object_id == 0) {
2488                 ERR("failed to register: %s", error->message);
2489                 g_error_free(error);
2490                 g_free(path);
2491                 g_strfreev(line_argv);
2492                 g_free(serv_path);
2493                 g_free(app_id);
2494                 return BT_STATUS_FAIL;
2495         }
2496
2497         flag_count = bt_hal_gatt_convert_perm2string(permissions, desc_flags);
2498
2499         desc_info = g_new0(struct gatt_desc_info, 1);
2500
2501         desc_info->desc_path = g_strdup(path);
2502         desc_info->desc_id = object_id;
2503         desc_info->desc_uuid = __bt_hal_convert_uuid_to_string(uuid);//g_strdup(btuuid2str(uuid->uu));
2504
2505         for (i = 0; i < flag_count; i++)
2506                 desc_info->desc_flags[i] = desc_flags[i];
2507
2508         desc_info->flags_length = flag_count;
2509         desc_info->desc_handle = gatt_desc_handle;
2510
2511
2512         builder = g_variant_builder_new(G_VARIANT_TYPE("a{sa{sv}}"));
2513         inner_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
2514
2515         g_variant_builder_add(inner_builder, "{sv}", "UUID",
2516                         g_variant_new("s", btuuid2str(uuid->uu)));
2517         g_variant_builder_add(inner_builder, "{sv}", "Characteristic",
2518                         g_variant_new("o", char_path));
2519
2520         builder2 = g_variant_builder_new(G_VARIANT_TYPE("as"));
2521
2522         for (i = 0; i < flag_count; i++)
2523                 g_variant_builder_add(builder2, "s", desc_flags[i]);
2524
2525         flags_val = g_variant_new("as", builder2);
2526         g_variant_builder_add(inner_builder, "{sv}", "Flags",
2527                         flags_val);
2528
2529         g_variant_builder_add(builder, "{sa{sv}}",
2530                         GATT_DESC_INTERFACE,
2531                         inner_builder);
2532
2533         g_dbus_connection_emit_signal(g_conn, NULL, "/",
2534                         "org.freedesktop.Dbus.ObjectManager",
2535                         "InterfacesAdded",
2536                         g_variant_new("(oa{sa{sv}})",
2537                                 path, builder),
2538                         &error);
2539         if (error != NULL) {
2540                 ERR("g_dbus_connection_emit_signal failed: errCode[%x], message[%s]",
2541                                 error->code, error->message);
2542                 g_clear_error(&error);
2543         }
2544
2545         //*desc_path = g_strdup(path);
2546
2547         /* Save newly created descriptor to GATT server's service's characteristic */
2548         char_info->desc_data = g_slist_append(char_info->desc_data, desc_info);
2549
2550         /* Send descriptor handle to application */
2551         user_data = g_malloc0(sizeof(hal_gatt_desc_added));
2552         user_data->srvc_hdl = serv_info->service_handle;
2553         user_data->desc_hdl = gatt_desc_handle;
2554         user_data->instance_data = slot;
2555         memcpy(user_data->uuid.uu, uuid->uu, sizeof(uuid->uu));
2556         g_idle_add(__bt_hal_gatt_desc_added_cb, (gpointer)user_data);
2557
2558         /* Free data */
2559         g_free(path);
2560         g_free(serv_path);
2561         g_strfreev(line_argv);
2562         g_variant_builder_unref(inner_builder);
2563         g_variant_builder_unref(builder);
2564         return BT_STATUS_SUCCESS;
2565 }
2566
2567 static void __bt_hal_register_application_cb(GObject *object, GAsyncResult *res, gpointer user_data)
2568 {
2569         GError *error = NULL;
2570         GVariant *result;
2571         char *data = (char*) user_data;
2572         INFO("RegisterApplication is completed path [%s]", data);
2573
2574         result = g_dbus_proxy_call_finish(manager_gproxy, res, &error);
2575
2576         if (result == NULL) {
2577                 /* dBUS-RPC is failed */
2578                 ERR("Dbus-RPC is failed\n");
2579
2580                 if (error != NULL) {
2581                         /* dBUS gives error cause */
2582                         ERR("D-Bus API failure: errCode[%x], message[%s]\n",
2583                                         error->code, error->message);
2584                         g_clear_error(&error);
2585                 }
2586         } else {
2587                 g_variant_unref(result);
2588         }
2589         g_free(data);
2590 }
2591
2592 static GDBusProxy *__bt_hal_gatt_gdbus_init_manager_proxy(const gchar *service,
2593                 const gchar *path, const gchar *interface)
2594 {
2595         GDBusProxy *proxy;
2596         GError *err = NULL;
2597
2598         if (g_conn == NULL)
2599                 g_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM,
2600                                 NULL, &err);
2601
2602         if (!g_conn) {
2603                 if (err) {
2604                         ERR("Unable to connect to gdbus: %s", err->message);
2605                         g_clear_error(&err);
2606                 }
2607                 return NULL;
2608         }
2609
2610         proxy =  g_dbus_proxy_new_sync(g_conn,
2611                         G_DBUS_PROXY_FLAGS_NONE, NULL,
2612                         service, path,
2613                         interface, NULL, &err);
2614
2615         if (!proxy) {
2616                 if (err) {
2617                         ERR("Unable to create proxy: %s", err->message);
2618                         g_clear_error(&err);
2619                 }
2620                 return NULL;
2621         }
2622         manager_gproxy = proxy;
2623
2624         return proxy;
2625 }
2626
2627 static GDBusProxy *__bt_gatt_gdbus_get_gatt_manager_proxy(const gchar *service,
2628                 const gchar *path, const gchar *interface)
2629 {
2630         return (manager_gproxy) ? manager_gproxy :
2631                 __bt_hal_gatt_gdbus_init_manager_proxy(service,
2632                                 path, interface);
2633 }
2634
2635 static void __bt_register_application_to_dbus(int slot)
2636 {
2637         GDBusProxy *proxy = NULL;
2638         char *app_path = NULL;
2639         char *data;
2640         DBG("RegisterApplication slot [%d]", slot);
2641
2642         /* It is impossible that app path is still not initialized */
2643         _bt_hal_is_gatt_server_initialzed(slot, &app_path);
2644
2645         proxy = __bt_gatt_gdbus_get_gatt_manager_proxy("org.bluez",
2646                         "/org/bluez/hci0", "org.bluez.GattManager1");
2647
2648         data = g_strdup(app_path);
2649         g_dbus_proxy_call(proxy,
2650                         "RegisterApplication",
2651                         g_variant_new("(oa{sv})",
2652                                 app_path, NULL),
2653                         G_DBUS_CALL_FLAGS_NONE, -1,
2654                         NULL,
2655                         (GAsyncReadyCallback)__bt_hal_register_application_cb,
2656                         (gpointer)data);
2657         INFO("GATT server started");
2658 }
2659
2660 static bt_status_t gatt_server_start_service(int server_if, int service_handle, int transport)
2661 {
2662         CHECK_BTGATT_INIT();
2663         struct gatt_service_info *serv_info = NULL;
2664         hal_gatt_service_started *user_data = NULL;
2665         DBG("Start GATT Service svc hdl [%d], slot [%d]", service_handle, server_if);
2666
2667         /* Fetch service data for the GATT server */
2668         serv_info = __bt_gatt_find_gatt_service_info(server_if, service_handle);
2669         if (serv_info == NULL)
2670                 return BT_STATUS_FAIL;
2671
2672         if (serv_info->is_svc_registered)
2673                 DBG("service already registered \n");
2674
2675         serv_info->is_svc_registered = TRUE;
2676
2677         /* Send Service handle to application */
2678         user_data = g_malloc0(sizeof(hal_gatt_service_started));
2679         user_data->srvc_hdl = serv_info->service_handle;
2680         user_data->instance_data = server_if;
2681         g_idle_add(__bt_hal_gatt_service_started_cb, (gpointer)user_data);
2682
2683         /* If this is nth Service that is started, then register application at this point */
2684         if (__bt_is_service_last_in_server_list(server_if, service_handle)) {
2685                 DBG("This is the last service started from the GATT Server's list of services handle [%d]",
2686                         service_handle);
2687                 __bt_register_application_to_dbus(server_if);
2688         }
2689
2690         return BT_STATUS_SUCCESS;
2691 }
2692
2693 static bt_status_t gatt_server_stop_service(int server_if, int service_handle)
2694 {
2695         CHECK_BTGATT_INIT();
2696         INFO("Stop service successful");
2697         return BT_STATUS_SUCCESS;
2698 }
2699
2700 static bt_status_t gatt_server_delete_service(int server_if, int service_handle)
2701 {
2702         CHECK_BTGATT_INIT();
2703         struct gatt_service_info *serv_info = NULL;
2704         hal_gatt_service_deleted *user_data = NULL;
2705         GSList *l = NULL;
2706         GSList *l1 = NULL;
2707         int err = BT_STATUS_SUCCESS;
2708         int ret = BT_STATUS_SUCCESS;
2709         INFO("Slot [%d] service handle [%d]", server_if, service_handle);
2710
2711         /* Fetch service data for the GATT server */
2712         serv_info = __bt_gatt_find_gatt_service_info(server_if, service_handle);
2713         if (serv_info == NULL) {
2714                 ERR("Could not find service info svc handle [%d] server slot [%d]",
2715                                 service_handle, server_if);
2716                 return BT_STATUS_FAIL;
2717         }
2718
2719         if (serv_info->is_svc_registered == FALSE) {
2720                 ERR("service Not registered path [%s] handle [%d]",
2721                         serv_info->serv_path, service_handle);
2722         }
2723
2724         for (l = serv_info->char_data; l != NULL; l = g_slist_next(l)) {
2725                 struct gatt_char_info *char_info = l->data;
2726
2727                 if (char_info == NULL)
2728                         break;
2729
2730                 for (l1 = char_info->desc_data; l1 != NULL; l1 = g_slist_next(l1)) {
2731                         struct gatt_desc_info *desc_info = l1->data;
2732
2733                         if (desc_info == NULL)
2734                                 break;
2735
2736                         ret = g_dbus_connection_unregister_object(g_conn,
2737                                         desc_info->desc_id);
2738                         if (ret) {
2739                                 __bt_hal_gatt_emit_interface_removed(
2740                                                 desc_info->desc_path,
2741                                                 GATT_DESC_INTERFACE);
2742                         } else {
2743                                 err = BT_STATUS_FAIL;
2744                         }
2745
2746                         /* list remove & free */
2747                         char_info->desc_data = g_slist_remove(char_info->desc_data, desc_info);
2748                         __bt_hal_gatt_free_descriptor_info(desc_info);
2749                 }
2750
2751                 g_slist_free(char_info->desc_data);
2752                 char_info->desc_data = NULL;
2753
2754                 ret = g_dbus_connection_unregister_object(g_conn,
2755                                 char_info->char_id);
2756                 if (ret) {
2757                         __bt_hal_gatt_emit_interface_removed(char_info->char_path,
2758                                         GATT_CHAR_INTERFACE);
2759                 } else {
2760                         INFO("Err");
2761                         err = BT_STATUS_FAIL;
2762                 }
2763
2764                 /* list remove & free */
2765                 serv_info->char_data = g_slist_remove(serv_info->char_data, char_info);
2766                 __bt_hal_gatt_free_characteristic_info(char_info);
2767         }
2768
2769         g_slist_free(serv_info->char_data);
2770         serv_info->char_data = NULL;
2771
2772         ret = g_dbus_connection_unregister_object(g_conn, serv_info->serv_id);
2773         if (ret) {
2774                 __bt_hal_gatt_emit_interface_removed(serv_info->serv_path,
2775                                 GATT_SERV_INTERFACE);
2776         } else {
2777                 INFO("Failed!!");
2778                 err = BT_STATUS_FAIL;
2779         }
2780
2781         ret = g_dbus_connection_unregister_object(g_conn, serv_info->prop_id);
2782         if (ret)
2783                 DBG("Unregistered the service on properties interface");
2784
2785         /* Remove from global list */
2786         gatt_services = g_slist_remove(gatt_services, serv_info);
2787         INFO("After removing from global list total service dount [%d]", g_slist_length(gatt_services));
2788
2789         /* Remove from GATT Server's list of services */
2790         _bt_remote_service_from_gatt_server(server_if, service_handle);
2791
2792         if (gatt_services == NULL)
2793                 INFO("All GATT Services of all GATT Servers are unregistered");
2794
2795         if (err == BT_STATUS_SUCCESS) {
2796                 INFO("Send GATT Service deleted Event");
2797                 /* Send Service handle to application */
2798                 user_data = g_malloc0(sizeof(hal_gatt_service_deleted));
2799                 user_data->srvc_hdl = serv_info->service_handle;
2800                 user_data->instance_data = server_if;
2801                 g_idle_add(__bt_hal_gatt_service_deleted_cb, (gpointer)user_data);
2802         }
2803
2804         /* Free the service */
2805         __bt_hal_gatt_free_service_info(serv_info);
2806         return err;
2807 }
2808
2809 static gboolean __bt_gatt_get_service_state(const char *service_path)
2810 {
2811         struct gatt_service_info *svc_info = NULL;
2812         GSList *l = NULL;
2813         for (l = gatt_services; l; l = g_slist_next(l)) {
2814
2815                 svc_info = (struct gatt_service_info *)l->data;
2816
2817
2818                 if (!g_strcmp0(svc_info->serv_path, service_path)) {
2819                         DBG("Return the state of the gatt service %d",
2820                                         svc_info->is_svc_registered);
2821                         return svc_info->is_svc_registered;
2822                 }
2823         }
2824
2825         DBG("gatt service info is NULL");
2826         return FALSE;
2827 }
2828
2829 static bt_status_t gatt_server_send_indication(int server_if, int attribute_handle, int conn_id,
2830                 int len, int confirm, char* p_value)
2831 {
2832         CHECK_BTGATT_INIT();
2833
2834         /* For Notifying */
2835         GVariantBuilder *outer_builder;
2836         GVariantBuilder *invalidated_builder;
2837
2838         /* For Value update via PropertyChange */
2839         GVariantBuilder *outer_builder1;
2840         GVariantBuilder *inner_builder1;
2841         GVariantBuilder *invalidated_builder1;
2842         GVariant *update_value = NULL;
2843
2844         /* Other variables */
2845         struct gatt_client_info_t *conn_info = NULL;
2846         gchar *serv_path = NULL;
2847         char *char_path = NULL;
2848         gchar **line_argv = NULL;
2849         gboolean notify = TRUE;
2850         gboolean ret = TRUE;
2851         int err = BT_STATUS_SUCCESS;
2852         char addr[20];
2853         GError *error = NULL;
2854         int i;
2855
2856         memset(addr, 0x00, sizeof(addr));
2857
2858         conn_info = __bt_find_remote_gatt_client_info_from_conn(conn_id);
2859         if (conn_info == NULL) {
2860                 ERR("No Connection Inforamtion!!!");
2861                 return BT_STATUS_FAIL;
2862         }
2863
2864         DBG("Send Indication to GATT client addr [%s]", conn_info->addr);
2865
2866         char_path = __bt_gatt_find_char_path_from_handle(attribute_handle);
2867         if (char_path == NULL)
2868                 return BT_STATUS_FAIL;
2869
2870         line_argv = g_strsplit_set(char_path, "/", 0);
2871         serv_path = g_strdup_printf("/%s/%s/%s", line_argv[1], line_argv[2], line_argv[3]);
2872
2873         if (!__bt_gatt_get_service_state(serv_path)) {
2874                 DBG("service not registered for this characteristic \n");
2875                 g_free(serv_path);
2876                 g_strfreev(line_argv);
2877                 return BT_STATUS_FAIL;
2878         }
2879
2880         outer_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
2881         invalidated_builder = g_variant_builder_new(G_VARIANT_TYPE("as"));
2882
2883         g_variant_builder_add(outer_builder, "{sv}", "Notifying",
2884                         g_variant_new("b", notify));
2885
2886         _bt_hal_convert_addr_type_to_string(addr, (unsigned char *)conn_info->addr);
2887
2888         g_variant_builder_add(outer_builder, "{sv}", "Unicast",
2889                         g_variant_new("s", addr));
2890
2891         DBG("Set characteristic Notification \n");
2892         ret = g_dbus_connection_emit_signal(g_conn, NULL,
2893                         char_path,
2894                         "org.freedesktop.DBus.Properties",
2895                         "PropertiesChanged",
2896                         g_variant_new("(sa{sv}as)",
2897                                 "org.bluez.GattCharacteristic1",
2898                                 outer_builder, invalidated_builder),
2899                         &error);
2900
2901         if (!ret) {
2902                 if (error != NULL) {
2903                         ERR("D-Bus API failure: errCode[%x], \
2904                                         message[%s]",
2905                                         error->code, error->message);
2906                         g_clear_error(&error);
2907                 }
2908                 err = BT_STATUS_FAIL;
2909         }
2910
2911         g_variant_builder_unref(outer_builder);
2912         g_variant_builder_unref(invalidated_builder);
2913
2914
2915         /* Notifying Done, now update Value to Bluez via PropertyChanged */
2916         invalidated_builder1 = g_variant_builder_new(G_VARIANT_TYPE("as"));
2917
2918         inner_builder1 = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
2919         for (i = 0; i < len; i++)
2920                 g_variant_builder_add(inner_builder1, "y", p_value[i]);
2921
2922         update_value = g_variant_new("ay", inner_builder1);
2923
2924
2925         outer_builder1 = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
2926         g_variant_builder_add(outer_builder1, "{sv}", "Value",
2927                         update_value);
2928
2929         DBG("Updating characteristic value \n");
2930         ret = g_dbus_connection_emit_signal(g_conn, NULL,
2931                         char_path,
2932                         "org.freedesktop.DBus.Properties",
2933                         "PropertiesChanged",
2934                         g_variant_new("(sa{sv}as)",
2935                                 "org.bluez.GattCharacteristic1",
2936                                 outer_builder1, invalidated_builder1),
2937                         &error);
2938
2939         if (!ret) {
2940                 if (error != NULL) {
2941                         ERR("D-Bus API failure: errCode[%x], \
2942                                         message[%s]",
2943                                         error->code, error->message);
2944                         g_clear_error(&error);
2945                 }
2946                 err = BT_STATUS_FAIL;
2947         } else {
2948                 struct gatt_char_info *char_info = NULL;
2949
2950                 char_info = __bt_gatt_find_char_info_from_handle(attribute_handle);
2951                 if (char_info == NULL) {
2952                         g_free(serv_path);
2953                         g_strfreev(line_argv);
2954                         g_variant_builder_unref(inner_builder1);
2955                         g_variant_builder_unref(outer_builder1);
2956                         g_variant_builder_unref(invalidated_builder1);
2957
2958                         return BT_STATUS_FAIL;
2959                 }
2960
2961                 char_info->value_length = len;
2962
2963                 char_info->char_value = (char *)realloc(char_info->char_value, len);
2964                 if (char_info->char_value) {
2965                         for (i = 0; i < len; i++)
2966                                 char_info->char_value[i] = p_value[i];
2967                 }
2968         }
2969
2970         g_free(serv_path);
2971         g_strfreev(line_argv);
2972         g_variant_builder_unref(inner_builder1);
2973         g_variant_builder_unref(outer_builder1);
2974         g_variant_builder_unref(invalidated_builder1);
2975
2976         return err;
2977 }
2978
2979 static bt_status_t gatt_server_send_response(int conn_id, int trans_id,
2980                 int status, btgatt_response_t *response)
2981 {
2982         CHECK_BTGATT_INIT();
2983
2984         struct gatt_req_info *req_info = NULL;
2985         struct gatt_client_info_t *conn_info = NULL;
2986         int i;
2987
2988         DBG("GATT Server Send Response Conn ID [%d]", conn_id);
2989
2990         conn_info = __bt_find_remote_gatt_client_info_from_conn(conn_id);
2991         if (conn_info == NULL) {
2992                 ERR("No Connection Inforamtion!!!");
2993                 return BT_STATUS_FAIL;
2994         }
2995
2996         req_info =  __bt_find_remote_gatt_client_request_info(conn_id, trans_id);
2997         if (req_info == NULL) {
2998                 ERR("No Request Inforamtion!!!");
2999                 return BT_STATUS_FAIL;
3000         }
3001
3002         if (status != BT_STATUS_SUCCESS) {
3003                 ERR("resp_state is 0x%X", status);
3004
3005                 g_dbus_method_invocation_return_dbus_error(req_info->context,
3006                                 "org.bluez.Error.Failed", "Application Error");
3007
3008                 conn_info->gatt_req_info_list = g_slist_remove(conn_info->gatt_req_info_list, req_info);
3009
3010                 req_info->context = NULL;
3011                 if (req_info->attr_path)
3012                         g_free(req_info->attr_path);
3013                 if (req_info->svc_path)
3014                         g_free(req_info->svc_path);
3015                 g_free(req_info);
3016
3017                 return BT_STATUS_SUCCESS;
3018         }
3019
3020         DBG("Reponse Value length [%d]", response->attr_value.len);
3021         DBG("Request type: [%d]", req_info->request_type);
3022
3023         /* DEBUG */
3024         for (i = 0; i < response->attr_value.len; i++)
3025                 DBG("Resonse [%d] = [0x%x]", response->attr_value.value[i]);
3026
3027         if (req_info->request_type == BT_HAL_GATT_REQUEST_TYPE_READ) {
3028                 GVariantBuilder *inner_builder = NULL;
3029                 inner_builder = g_variant_builder_new(G_VARIANT_TYPE("ay"));
3030
3031                 if (response->attr_value.len > 0) {
3032                         for (i = 0; i < response->attr_value.len; i++)
3033                                 g_variant_builder_add(inner_builder, "y", response->attr_value.value[i]);
3034                 }
3035                 g_dbus_method_invocation_return_value(req_info->context,
3036                                 g_variant_new("(ay)", inner_builder));
3037
3038                 g_variant_builder_unref(inner_builder);
3039         } else {
3040                 g_dbus_method_invocation_return_value(req_info->context, NULL);
3041         }
3042         conn_info->gatt_req_info_list = g_slist_remove(conn_info->gatt_req_info_list, req_info);
3043
3044         req_info->context = NULL;
3045         if (req_info->attr_path)
3046                 g_free(req_info->attr_path);
3047         if (req_info->svc_path)
3048                 g_free(req_info->svc_path);
3049         g_free(req_info);
3050
3051         return BT_STATUS_SUCCESS;
3052 }
3053
3054
3055 static bt_status_t gatt_server_send_acquire_response(int conn_id, int trans_id,
3056                 int status, int fd, int mtu, void *fdlist)
3057 {
3058         CHECK_BTGATT_INIT();
3059
3060         struct gatt_req_info *req_info = NULL;
3061         struct gatt_client_info_t *conn_info = NULL;
3062         int i;
3063
3064         DBG("GATT Server Send Response Conn ID [%d]", conn_id);
3065
3066         conn_info = __bt_find_remote_gatt_client_info_from_conn(conn_id);
3067         if (conn_info == NULL) {
3068                 ERR("No Connection Inforamtion!!!");
3069                 return BT_STATUS_FAIL;
3070         }
3071
3072         req_info =  __bt_find_remote_gatt_client_request_info(conn_id, trans_id);
3073         if (req_info == NULL) {
3074                 ERR("No Request Inforamtion!!!");
3075                 return BT_STATUS_FAIL;
3076         }
3077
3078         if (status != BT_STATUS_SUCCESS) {
3079                 ERR("resp_state is 0x%X", status);
3080
3081                 g_dbus_method_invocation_return_dbus_error(req_info->context,
3082                                 "org.bluez.Error.Failed", "Application Error");
3083
3084                 conn_info->gatt_req_info_list = g_slist_remove(conn_info->gatt_req_info_list, req_info);
3085
3086                 req_info->context = NULL;
3087                 if (req_info->attr_path)
3088                         g_free(req_info->attr_path);
3089                 if (req_info->svc_path)
3090                         g_free(req_info->svc_path);
3091                 g_free(req_info);
3092
3093                 return BT_STATUS_SUCCESS;
3094         }
3095
3096
3097          if (req_info->request_type == BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_WRITE) {
3098
3099                 INFO("GATT Server Send Response BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_WRITE to bluez  %d\n", fd);
3100                 g_dbus_method_invocation_return_value_with_unix_fd_list(
3101                                 req_info->context, g_variant_new("(hq)", 0, mtu), (GUnixFDList*)fdlist);
3102
3103         } else if (req_info->request_type == BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_NOTIFY) {
3104
3105                 INFO("GATT Server Send Response BT_HAL_GATT_REQUEST_TYPE_ACQUIRE_NOTIFY  to bluez  %d\n", fd);
3106                 g_dbus_method_invocation_return_value_with_unix_fd_list(
3107                                 req_info->context, g_variant_new("(hq)", 0, mtu), (GUnixFDList*)fdlist);
3108
3109         } else {
3110                 g_dbus_method_invocation_return_value(req_info->context, NULL);
3111         }
3112         conn_info->gatt_req_info_list = g_slist_remove(conn_info->gatt_req_info_list, req_info);
3113
3114         req_info->context = NULL;
3115         if (req_info->attr_path)
3116                 g_free(req_info->attr_path);
3117         if (req_info->svc_path)
3118                 g_free(req_info->svc_path);
3119         g_free(req_info);
3120
3121         return BT_STATUS_SUCCESS;
3122 }
3123
3124
3125 static bt_status_t gatt_server_update_att_value(int server_if, int attribute_handle,
3126                 int value_length, char* att_value)
3127 {
3128         CHECK_BTGATT_INIT();
3129
3130         /* Other variables */
3131         char *char_path = NULL;
3132         gboolean ret = TRUE;
3133         GError *error = NULL;
3134
3135         GVariantBuilder *outer_builder;
3136         GVariantBuilder *inner_builder;
3137         GVariantBuilder *invalidated_builder;
3138         GVariant *update_value = NULL;
3139         int err = BT_STATUS_SUCCESS;
3140         int i = 0;
3141         gchar **line_argv = NULL;
3142         gchar *serv_path = NULL;
3143
3144         char_path = __bt_gatt_find_char_path_from_handle(attribute_handle);
3145         if (char_path == NULL)
3146                 return BT_STATUS_FAIL;
3147
3148         line_argv = g_strsplit_set(char_path, "/", 0);
3149         serv_path = g_strdup_printf("/%s/%s/%s", line_argv[1], line_argv[2], line_argv[3]);
3150
3151         if (!__bt_gatt_get_service_state(serv_path)) {
3152                 DBG("service not registered for this characteristic \n");
3153                 g_free(serv_path);
3154                 g_strfreev(line_argv);
3155                 return BT_STATUS_FAIL;
3156         }
3157
3158         g_free(serv_path);
3159         line_argv = g_strsplit_set(char_path, "/", 0);
3160         serv_path = g_strdup_printf("/%s/%s/%s", line_argv[1], line_argv[2], line_argv[3]);
3161
3162         if (!__bt_gatt_get_service_state(serv_path)) {
3163                 DBG("service not registered for this characteristic \n");
3164                 g_free(serv_path);
3165                 g_strfreev(line_argv);
3166                 return BT_STATUS_FAIL;
3167         }
3168
3169         outer_builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
3170         invalidated_builder = g_variant_builder_new(G_VARIANT_TYPE("as"));
3171
3172         inner_builder = g_variant_builder_new(G_VARIANT_TYPE_ARRAY);
3173         for (i = 0; i < value_length; i++)
3174                 g_variant_builder_add(inner_builder, "y", att_value[i]);
3175
3176         update_value = g_variant_new("ay", inner_builder);
3177
3178         g_variant_builder_add(outer_builder, "{sv}", "Value",
3179                         update_value);
3180
3181         DBG("Updating characteristic value \n");
3182         ret = g_dbus_connection_emit_signal(g_conn, NULL,
3183                         char_path,
3184                         "org.freedesktop.DBus.Properties",
3185                         "PropertiesChanged",
3186                         g_variant_new("(sa{sv}as)",
3187                                 "org.bluez.GattCharacteristic1",
3188                                 outer_builder, invalidated_builder),
3189                         &error);
3190
3191         if (!ret) {
3192                 if (error != NULL) {
3193                         ERR("D-Bus API failure: errCode[%x], \
3194                                         message[%s]",
3195                                         error->code, error->message);
3196                         g_clear_error(&error);
3197                 }
3198                 err = BT_STATUS_FAIL;
3199         } else {
3200                 struct gatt_char_info *char_info = NULL;
3201
3202                 char_info = __bt_gatt_find_char_info_from_handle(attribute_handle);
3203                 if (char_info == NULL) {
3204                         g_free(serv_path);
3205                         g_strfreev(line_argv);
3206                         g_variant_builder_unref(inner_builder);
3207                         g_variant_builder_unref(outer_builder);
3208                         g_variant_builder_unref(invalidated_builder);
3209
3210                         return BT_STATUS_FAIL;
3211                 }
3212
3213                 char_info->value_length = value_length;
3214
3215                 char_info->char_value = (char *)realloc(char_info->char_value, value_length);
3216                 if (char_info->char_value) {
3217                         for (i = 0; i < value_length; i++)
3218                                 char_info->char_value[i] = att_value[i];
3219                 }
3220         }
3221
3222         /* Free data */
3223         g_free(serv_path);
3224         g_strfreev(line_argv);
3225         g_variant_builder_unref(inner_builder);
3226         g_variant_builder_unref(outer_builder);
3227         g_variant_builder_unref(invalidated_builder);
3228
3229         return err;
3230 }
3231
3232 static bt_status_t gatt_server_listen(int server_if, bool start)
3233 {
3234         CHECK_BTGATT_INIT();
3235         /* Send Data to LE Module */
3236         return _bt_hal_enable_advertising(server_if, start, FALSE);
3237 }
3238
3239 static bt_status_t gatt_server_set_adv_data(int server_if, bool set_scan_rsp, bool include_name,
3240                 bool include_txpower, int min_interval, int max_interval, int appearance,
3241                 uint16_t manufacturer_len, char* manufacturer_data,
3242                 uint16_t service_data_len, char* service_data,
3243                 uint16_t service_uuid_len, char* service_uuid)
3244 {
3245         CHECK_BTGATT_INIT();
3246         return BT_STATUS_SUCCESS;
3247 }
3248
3249 static bt_status_t gatt_server_multi_adv_enable(int server_if)
3250 {
3251         CHECK_BTGATT_INIT();
3252         /* Send Enable Advertising request to LE Module */
3253         return _bt_hal_enable_advertising(server_if, TRUE, TRUE);
3254 }
3255
3256 static bt_status_t gatt_server_multi_adv_update(int server_if, int min_interval, int max_interval, int adv_type,
3257                 int chnl_map, int tx_power, int timeout_s)
3258 {
3259         CHECK_BTGATT_INIT();
3260         DBG("+");
3261         /* Send Advertising parameters to LE Module */
3262         return _bt_hal_set_advertising_params(server_if, min_interval, max_interval, adv_type,
3263                         chnl_map, tx_power, timeout_s);
3264 }
3265
3266 static bt_status_t gatt_server_multi_adv_set_inst_data(btgatt_adv_param_setup_t adv_param_setup)
3267 {
3268         CHECK_BTGATT_INIT();
3269         DBG("+");
3270         /* Send Data to LE Module */
3271         return _bt_hal_set_advertising_data(adv_param_setup);
3272 }
3273
3274 static bt_status_t gatt_server_multi_adv_disable(int server_if)
3275 {
3276         CHECK_BTGATT_INIT();
3277         /* Send Data to LE Module */
3278         return _bt_hal_enable_advertising(server_if, FALSE, TRUE);
3279 }
3280
3281 static bt_status_t gatt_server_get_mtu_size(int conn_id, int *mtu_size)
3282 {
3283         CHECK_BTGATT_INIT();
3284         char *object_path = NULL;
3285
3286         GDBusProxy *device_proxy;
3287         GError *error = NULL;
3288         GVariant *value;
3289         GVariant *tmp_value;
3290         GDBusConnection *conn;
3291         GVariant *result = NULL;
3292         int ret = BT_STATUS_SUCCESS;
3293         struct gatt_client_info_t *conn_info = NULL;
3294         unsigned int mtu;
3295
3296         if (mtu_size == NULL)
3297                 return BT_STATUS_PARM_INVALID;
3298
3299         /* GDBUS Connection Info validate */
3300         conn = _bt_hal_get_system_gconn();
3301         if (conn == NULL) {
3302                 ERR("Could not get System DBUS Connection");
3303                 return  BT_STATUS_FAIL;
3304         }
3305
3306         /* Connection Info validate */
3307         conn_info = __bt_find_remote_gatt_client_info_from_conn(conn_id);
3308         if (conn_info == NULL) {
3309                 ERR("No Connection Inforamtion!!!");
3310                 return BT_STATUS_FAIL;
3311         }
3312
3313
3314         object_path = _bt_hal_get_device_object_path(conn_info->addr);
3315         if (object_path == NULL)
3316                 return BT_STATUS_FAIL;
3317
3318         device_proxy = g_dbus_proxy_new_sync(conn, G_DBUS_PROXY_FLAGS_NONE,
3319                         NULL, BT_HAL_BLUEZ_NAME, object_path,
3320                         BT_HAL_PROPERTIES_INTERFACE,  NULL, NULL);
3321
3322         g_free(object_path);
3323         if (device_proxy == NULL)
3324                 return BT_STATUS_FAIL;
3325
3326         result = g_dbus_proxy_call_sync(device_proxy, "GetAll",
3327                         g_variant_new("(s)", BT_HAL_DEVICE_INTERFACE),
3328                         G_DBUS_CALL_FLAGS_NONE,
3329                         -1,
3330                         NULL,
3331                         &error);
3332         if (result == NULL) {
3333                 if (error != NULL) {
3334                         ERR("Error occured in Proxy call [%s]\n", error->message);
3335                         g_error_free(error);
3336                 }
3337                 g_object_unref(device_proxy);
3338                 return BT_STATUS_FAIL;
3339         }
3340
3341         g_variant_get(result , "(@a{sv})", &value);
3342         g_variant_unref(result);
3343
3344         tmp_value = g_variant_lookup_value(value, "AttMtu", G_VARIANT_TYPE_UINT16);
3345         if (tmp_value == NULL) {
3346                 g_object_unref(device_proxy);
3347                 g_variant_unref(value);
3348                 return BT_STATUS_FAIL;
3349         }
3350
3351         mtu = g_variant_get_uint16(tmp_value);
3352
3353         DBG("ATT MTU : [%d]", mtu);
3354
3355         g_variant_unref(tmp_value);
3356         g_variant_unref(value);
3357         g_object_unref(device_proxy);
3358
3359         *mtu_size = (int) mtu;
3360
3361         return ret;
3362 }
3363
3364 const btgatt_server_interface_t btgatt_server_interface = {
3365         gatt_server_register_app,
3366         gatt_server_unregister_app,
3367         gatt_server_open,
3368         gatt_server_close,
3369         gatt_server_add_service,
3370         gatt_server_add_included_service,
3371         gatt_server_add_characteristic,
3372         gatt_server_add_descriptor,
3373         gatt_server_start_service,
3374         gatt_server_stop_service,
3375         gatt_server_delete_service,
3376         gatt_server_send_indication,
3377         gatt_server_send_response,
3378         gatt_server_update_att_value,
3379         gatt_server_listen,
3380         gatt_server_set_adv_data,
3381         gatt_server_multi_adv_enable,
3382         gatt_server_multi_adv_update,
3383         gatt_server_multi_adv_set_inst_data,
3384         gatt_server_multi_adv_disable,
3385         gatt_server_get_mtu_size,
3386         gatt_server_send_acquire_response
3387 };