ag-agent/bluetooth-ag-agent.c

   1 /*
   2  * Bluetooth-ag-agent
   3  *
   4  * Copyright (c) 2014 - 2015 Samsung Electronics Co., Ltd. All rights reserved.
   5  *
   6  * Contact:     Hocheol Seo <hocheol.seo@samsung.com>
   7  *              Chethan T N <chethan.tn@samsung.com>
   8  *              Chanyeol Park <chanyeol.park@samsung.com>
   9  *              Rakesh MK <rakesh.mk@samsung.com>
  10  *
  11  * Licensed under the Apache License, Version 2.0 (the "License");
  12  * you may not use this file except in compliance with the License.
  13  * You may obtain a copy of the License at
  14  *
  15  *              http://www.apache.org/licenses/LICENSE-2.0
  16  *
  17  * Unless required by applicable law or agreed to in writing, software
  18  * distributed under the License is distributed on an "AS IS" BASIS,
  19  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  20  * See the License for the specific language governing permissions and
  21  * limitations under the License.
  22  *
  23  */
  24 #include <stdio.h>
  25 #include <stdlib.h>
  26 #include <signal.h>
  27 #include <sys/poll.h>
  28 #include <gio/gunixfdlist.h>
  29 #include <bundle_internal.h>
  30 #include "bluetooth-ag-agent.h"
  31 #include "bluetooth-ag-handler.h"
  32
  33 #include <TapiUtility.h>
  34 #include <ITapiSim.h>
  35 #include <ITapiModem.h>
  36 #include <TelNetwork.h>
  37 #include <app.h>
  38 #include <aul.h>
  39 #include <system_info.h>
  40
  41 #include "contacts.h"
  42 #include "appsvc.h"
  43
  44 static GMainLoop *gmain_loop = NULL;
  45 static GDBusProxy *service_gproxy;
  46 static int owner_sig_id = -1;
  47 static int name_owner_sig_id = -1;
  48 GDBusConnection *ag_dbus_conn = NULL;
  49 gchar *remote_dev_path = NULL;
  50 gboolean wbs_en;
  51 uint16_t hfp_ver;
  52 uint16_t hsp_ver;
  53 static TapiHandle *tapi_handle;
  54 extern wbs_options wbs_opts;
  55 GSList *active_devices = NULL;
  56 static gchar *local_addr = NULL;
  57 static GDBusProxy *app_gproxy;
  58 static gboolean call_launch_requested = FALSE;
  59 static gchar* sco_owner = NULL;
  60 static guint sco_open_timer_id = 0;
  61 static gboolean sco_open_request = FALSE;
  62 static guint hf_bluez_id;
  63 static guint hs_bluez_id;
  64 static guint app_id;
  65 #ifdef TIZEN_MEDIA_ENHANCE
  66 static int media_sig_id = -1;
  67 static int media_state_sig_id = -1;
  68 static bt_ag_media_transport_state_t transport_state;
  69 #endif
  70
  71 #define HSP_AG_UUID "00001112-0000-1000-8000-00805f9b34fb"
  72 #define HFP_AG_UUID "0000111f-0000-1000-8000-00805f9b34fb"
  73 #ifdef TIZEN_MEDIA_ENHANCE
  74 #define A2DP_SINK_UUID "0000110b-0000-1000-8000-00805f9b34fb"
  75 #endif
  76 #define DEFAULT_ADAPTER_OBJECT_PATH "/org/bluez/hci0"
  77
  78 #ifdef TIZEN_SUPPORT_LUNAR_DEVICE
  79 #define VCONF_KEY_BT_LUNAR_ENABLED "db/wms/bt_loop_device_hfp_connected"
  80 #endif
  81
  82 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
  83 #define CALL_APP_ID "org.tizen.call-ui"
  84 #endif
  85
  86 #if defined(TIZEN_SUPPORT_DUAL_HF)
  87 #define VCONF_KEY_BT_HOST_BT_MAC_ADDR "db/wms/host_bt_mac"
  88 #define MAX_CONNECTED_DEVICES 2
  89 #else
  90 #define MAX_CONNECTED_DEVICES 1
  91 #endif
  92
  93 #define BT_AG_SIG_NUM 3
  94 static struct sigaction bt_ag_sigoldact[BT_AG_SIG_NUM];
  95 static int bt_ag_sig_to_handle[] = { SIGABRT, SIGSEGV, SIGTERM };
  96
  97 /*Below Inrospection data is exposed to bluez from agent*/
  98 static const gchar ag_agent_bluez_introspection_xml[] =
  99 "<node name='/'>"
 100 " <interface name='org.bluez.Profile1'>"
 101 "     <method name='NewConnection'>"
 102 "          <arg type='o' name='device' direction='in'/>"
 103 "          <arg type='h' name='fd' direction='in'/>"
 104 "          <arg type='a{sv}' name='options' direction='in'/>"
 105 "     </method>"
 106 "     <method name='RequestDisconnection'>"
 107 "          <arg type='o' name='device' direction='in'/>"
 108 "     </method>"
 109 " </interface>"
 110 "</node>";
 111
 112 /*Below Introspection data is exposed to application from agent*/
 113 static const gchar ag_agent_app_introspection_xml[] =
 114 "<node name='/'>"
 115 "  <interface name='Org.Hfp.App.Interface'>"
 116 "     <method name='RegisterApplication'>"
 117 "          <arg type='s' name='path' direction='in'/>"
 118 "          <arg type='s' name='address' direction='in'/>"
 119 "     </method>"
 120 "     <method name='UnregisterApplication'>"
 121 "          <arg type='s' name='path' direction='in'/>"
 122 "     </method>"
 123 "     <method name='IncomingCall'>"
 124 "          <arg type='s' name='path' direction='in'/>"
 125 "          <arg type='s' name='number' direction='in'/>"
 126 "          <arg type='i' name='id' direction='in'/>"
 127 "     </method>"
 128 "     <method name='OutgoingCall'>"
 129 "          <arg type='s' name='path' direction='in'/>"
 130 "          <arg type='s' name='number' direction='in'/>"
 131 "          <arg type='i' name='id' direction='in'/>"
 132 "     </method>"
 133 "     <method name='ChangeCallStatus'>"
 134 "          <arg type='s' name='path' direction='in'/>"
 135 "          <arg type='s' name='number' direction='in'/>"
 136 "          <arg type='i' name='status' direction='in'/>"
 137 "          <arg type='i' name='id' direction='in'/>"
 138 "     </method>"
 139 "     <method name='GetProperties'>"
 140 "               <arg type='a{sv}' name='properties' direction='out'/>"
 141 "     </method>"
 142 "       <method name='Disconnect'>"
 143 "       </method>"
 144 "       <method name='IsConnected'>"
 145 "               <arg type='b' name='connected' direction='out'/>"
 146 "       </method>"
 147 "       <method name='IndicateCall'>"
 148 "       </method>"
 149 "       <method name='CancelCall'>"
 150 "       </method>"
 151 "       <method name='Play'>"
 152 "       </method>"
 153 "       <method name='Stop'>"
 154 "       </method>"
 155 "       <method name='IsPlaying'>"
 156 "       <arg type='b' name='playing' direction='out'/>"
 157 "       </method>"
 158 "       <method name='GetSpeakerGain'>"
 159 "               <arg type='q' name='gain' direction='out'/>"
 160 "       </method>"
 161 "       <method name='GetMicrophoneGain'>"
 162 "               <arg type='q' name='gain' direction='out'/>"
 163 "       </method>"
 164 "       <method name='SetSpeakerGain'>"
 165 "               <arg type='q' name='gain' direction='in'/>"
 166 "       </method>"
 167 "       <method name='SetMicrophoneGain'>"
 168 "               <arg type='q' name='gain' direction='in'/>"
 169 "       </method>"
 170 "       <method name='SetVoiceDial'>"
 171 "               <arg type='b' name='enable' direction='in'/>"
 172 "       </method>"
 173 "       <method name='CheckPrivilege'>"
 174 "       </method>"
 175 "  </interface>"
 176 "</node>";
 177
 178 struct event {
 179         const char *cmd;
 180         int (*callback)(bt_ag_info_t *hs, const char *buf);
 181 };
 182
 183 struct sco_socket_addr {
 184         sa_family_t     sco_family;
 185         bt_addr         sco_bdaddr;
 186 };
 187
 188 typedef struct {
 189         uint16_t setting;
 190 } bt_voice;
 191
 192 struct ag_codec {
 193         bt_ag_info_t *bt_ag_info;
 194         char *codec_status;
 195 };
 196
 197 bt_ag_status_t ag = {
 198         .telephony_ready = FALSE,
 199         .features = 0,
 200         .er_mode = 3,
 201         .er_ind = 0,
 202         .rh = BT_RSP_HOLD_NOT_SUPPORTED,
 203         .number = NULL,
 204         .number_type = 0,
 205         .ring_timer = 0,
 206         .sdp_features = 0,
 207 };
 208 static void __bt_ag_agent_sigterm_handler(int signo);
 209 static gboolean __bt_ag_agent_connection(gint32 fd, const gchar *device_path,
 210                                                 const gchar *object_path);
 211 static gboolean __bt_ag_agent_connection_release(bt_ag_info_t *hs);
 212 static gboolean __bt_ag_event_handler(GIOChannel *channel, GIOCondition cond,
 213         void *user_data);
 214 static int __bt_ag_sco_connect(bt_ag_info_t *hs);
 215 void _bt_ag_set_headset_state(bt_ag_info_t *hs, hs_state_t state);
 216 static void __bt_ag_agent_reg_sim_event(TapiHandle *handle, void *user_data);
 217 static void __bt_ag_agent_dereg_sim_event(TapiHandle *handle);
 218 static void __bt_ag_name_owner_changed_cb(GDBusConnection *connection,
 219                                         const gchar *sender_name,
 220                                         const gchar *object_path,
 221                                         const gchar *interface_name,
 222                                         const gchar *signal_name,
 223                                         GVariant *parameters,
 224                                         gpointer user_data);
 225
 226 static void __bt_convert_addr_type_to_rev_string(char *address,
 227                                 unsigned char *addr)
 228 {
 229         ret_if(address == NULL);
 230         ret_if(addr == NULL);
 231
 232         g_snprintf(address, BT_ADDRESS_STRING_SIZE,
 233                         "%2.2X:%2.2X:%2.2X:%2.2X:%2.2X:%2.2X",
 234                         addr[5], addr[4], addr[3], addr[2], addr[1], addr[0]);
 235 }
 236
 237 static GDBusProxy *__bt_ag_gdbus_init_service_proxy(const gchar *service,
 238                                 const gchar *path, const gchar *interface)
 239 {
 240         FN_START;
 241
 242         GDBusProxy *proxy;
 243         GError *err = NULL;
 244
 245         if (ag_dbus_conn == NULL)
 246                 ag_dbus_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &err);
 247
 248         if (!ag_dbus_conn) {
 249                 if (err) {
 250                         ERR("Unable to connect to gdbus: %s", err->message);
 251                         g_clear_error(&err);
 252                 }
 253                 return NULL;
 254         }
 255
 256         proxy =  g_dbus_proxy_new_sync(ag_dbus_conn,
 257                         G_DBUS_PROXY_FLAGS_NONE, NULL,
 258                         service, path,
 259                         interface, NULL, &err);
 260
 261         if (!proxy) {
 262                 if (err) {
 263                         ERR("Unable to create proxy: %s", err->message);
 264                         g_clear_error(&err);
 265                 }
 266                 return NULL;
 267         }
 268
 269         FN_END;
 270         return proxy;
 271 }
 272
 273 static GDBusProxy *__bt_ag_gdbus_get_app_proxy(const gchar *service,
 274                                 const gchar *path, const gchar *interface)
 275 {
 276         return (app_gproxy) ? app_gproxy :
 277                         __bt_ag_gdbus_init_service_proxy(service,
 278                                         path, interface);
 279 }
 280
 281 static int __bt_ag_agent_gdbus_method_send(const char *service,
 282                                 const gchar *path, const char *interface,
 283                                 const char *method, gboolean response,
 284                                 GVariant *parameters)
 285 {
 286         FN_START;
 287
 288         GVariant *ret;
 289         GDBusProxy *proxy;
 290         GError *error = NULL;
 291
 292         proxy = __bt_ag_gdbus_get_app_proxy(service, path, interface);
 293         if (!proxy)
 294                 return BT_HFP_AGENT_ERROR_INTERNAL;
 295
 296         if (response) {
 297                 ret = g_dbus_proxy_call_sync(proxy,
 298                                         method, parameters,
 299                                         G_DBUS_CALL_FLAGS_NONE, -1,
 300                                         NULL, &error);
 301                 if (ret == NULL) {
 302                         /* dBUS-RPC is failed */
 303                         ERR("dBUS-RPC is failed");
 304                         if (error != NULL) {
 305                                 /* dBUS gives error cause */
 306                                 ERR("D-Bus API failure: errCode[%x], message[%s]",
 307                                         error->code, error->message);
 308
 309                                 g_clear_error(&error);
 310                         }
 311                         return BT_HFP_AGENT_ERROR_INTERNAL;
 312                 }
 313
 314                 g_variant_unref(ret);
 315         } else {
 316                 g_dbus_proxy_call(proxy,
 317                                         method, parameters,
 318                                         G_DBUS_CALL_FLAGS_NONE, 2000,
 319                                         NULL, NULL, NULL);
 320         }
 321         return BT_HFP_AGENT_ERROR_NONE;
 322 }
 323
 324 gboolean _bt_ag_agent_emit_signal(
 325                                 GDBusConnection *connection,
 326                                 const char *path,
 327                                 const char *interface,
 328                                 const char *name,
 329                                 GVariant *property)
 330 {
 331         FN_START;
 332
 333         GError *error = NULL;
 334         gboolean ret;
 335         ret =  g_dbus_connection_emit_signal(connection,
 336                                 NULL, path, interface,
 337                                 name, property,
 338                                 &error);
 339         if (!ret) {
 340                 if (error != NULL) {
 341                         /* dBUS gives error cause */
 342                         ERR("D-Bus API failure: errCode[%x], message[%s]",
 343                                 error->code, error->message);
 344                         g_clear_error(&error);
 345                 }
 346         }
 347         INFO_C("Emit Signal done = [%s]", name);
 348
 349         FN_END;
 350         return ret;
 351 }
 352
 353 gboolean _bt_ag_agent_emit_property_changed(
 354                                 GDBusConnection *connection,
 355                                 const char *path,
 356                                 const char *interface,
 357                                 const char *name,
 358                                 GVariant *property)
 359 {
 360         FN_START;
 361
 362         gboolean ret;
 363         GVariant *var_data;
 364
 365         var_data = g_variant_new("(sv)",        name, property);
 366
 367         ret =  _bt_ag_agent_emit_signal(connection,
 368                                 path, interface,
 369                                 "PropertyChanged", var_data);
 370         FN_END;
 371         return ret;
 372 }
 373
 374 static void __bt_ag_agent_start_watch(bt_ag_info_t *bt_ag_info)
 375 {
 376         bt_ag_info->watch_id = g_io_add_watch(bt_ag_info->io_chan,
 377                         G_IO_IN | G_IO_ERR | G_IO_HUP | G_IO_NVAL,
 378                         (GIOFunc) __bt_ag_event_handler, bt_ag_info);
 379 }
 380
 381 static void __bt_ag_agent_remove_watch(guint *watch_id)
 382 {
 383         DBG("Remove IO watch ID %d", *watch_id);
 384         if (*watch_id > 0) {
 385                 g_source_remove(*watch_id);
 386                 *watch_id = 0;
 387         }
 388 }
 389
 390 #if defined(TIZEN_SUPPORT_DUAL_HF)
 391 gboolean __bt_ag_agent_is_companion_device(const char *addr)
 392 {
 393 #if defined(TIZEN_WEARABLE)
 394         char *host_device_address = NULL;
 395         host_device_address = vconf_get_str(VCONF_KEY_BT_HOST_BT_MAC_ADDR);
 396
 397         if (!host_device_address) {
 398                 INFO("Failed to get a companion device address");
 399                 return FALSE;
 400         }
 401
 402         if (g_strcmp0(host_device_address, addr) == 0) {
 403                 INFO("addr[%s] is companion device", addr);
 404                 return TRUE;
 405         }
 406
 407         return FALSE;
 408 #else
 409         /* TODO : Need to add companion device check condition for Phone models */
 410         return FALSE;
 411 #endif
 412 }
 413
 414 void __bt_convert_device_path_to_address(const gchar *device_path,
 415                                                 char *device_address)
 416 {
 417         char address[BT_ADDRESS_STRING_SIZE] = { 0 };
 418         char *dev_addr;
 419
 420         ret_if(device_path == NULL);
 421         ret_if(device_address == NULL);
 422
 423         dev_addr = strstr(device_path, "dev_");
 424         if (dev_addr != NULL) {
 425                 char *pos = NULL;
 426                 dev_addr += 4;
 427                 g_strlcpy(address, dev_addr, sizeof(address));
 428
 429                 while ((pos = strchr(address, '_')) != NULL) {
 430                         *pos = ':';
 431                 }
 432
 433                 g_strlcpy(device_address, address, BT_ADDRESS_STRING_SIZE);
 434         }
 435 }
 436
 437 static gboolean  __bt_ag_agent_is_companion_device_connected(void)
 438 {
 439         GSList *l;
 440
 441         for (l = active_devices ; l; l = l->next) {
 442                 bt_ag_info_t *data = l->data;
 443
 444                 if (data->is_companion_device) {
 445                         DBG("Companion device found");
 446                         return TRUE;
 447                 }
 448         }
 449
 450         return FALSE;
 451 }
 452
 453 gboolean __bt_ag_agent_check_dual_hf_condition(const gchar *device_path)
 454 {
 455         char device_address[BT_ADDRESS_STRING_SIZE] = { 0 };
 456         gboolean is_companion_device;
 457
 458         __bt_convert_device_path_to_address(device_path, device_address);
 459         is_companion_device = __bt_ag_agent_is_companion_device(device_address);
 460
 461         DBG(" device_address[%s]", device_address);
 462         DBG(" is_companion_device[%d]", is_companion_device);
 463
 464         if (__bt_ag_agent_is_companion_device_connected()) {
 465                 if (is_companion_device)
 466                         return FALSE;
 467         } else {
 468                 if (!is_companion_device)
 469                         return FALSE;
 470         }
 471
 472         return TRUE;
 473 }
 474 #endif /* TIZEN_SUPPORT_DUAL_HF */
 475
 476 static gboolean __bt_is_phone_locked(int *phone_lock_state)
 477 {
 478         FN_START;
 479         int ret;
 480
 481         if (NULL == phone_lock_state)
 482                 return FALSE;
 483
 484         ret = vconf_get_int(VCONFKEY_IDLE_LOCK_STATE, phone_lock_state);
 485         if (ret != 0) {
 486                 ERR("Failed to read  [%s]\n", VCONFKEY_IDLE_LOCK_STATE);
 487                 return FALSE;
 488         }
 489
 490         FN_END;
 491         return TRUE;
 492 }
 493
 494 static gboolean __bt_get_outgoing_callapp_type(int *callapp_type)
 495 {
 496         FN_START;
 497
 498         if (NULL == callapp_type)
 499                 return FALSE;
 500
 501 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
 502         *callapp_type = BT_VOICE_CALL;
 503         FN_END;
 504         return TRUE;
 505 #else
 506 #if 0
 507         int ret;
 508         ret = vconf_get_int(
 509                         VCONFKEY_CISSAPPL_OUTGOING_CALL_TYPE_INT,
 510                         callapp_type);
 511         if (ret != 0) {
 512                 ERR("Failed to read  [%s]\n",
 513                         VCONFKEY_CISSAPPL_OUTGOING_CALL_TYPE_INT);
 514                 return FALSE;
 515         }
 516
 517         INFO(" [%s] = [%d]\n",
 518                 VCONFKEY_CISSAPPL_OUTGOING_CALL_TYPE_INT, *callapp_type);
 519 #endif
 520         /* The vconf value does not include in platform. */
 521         *callapp_type = BT_VOICE_CALL;
 522         FN_END;
 523         return TRUE;
 524 #endif
 525 }
 526
 527 static gboolean __bt_get_outgoing_call_condition(int *condition)
 528 {
 529         FN_START;
 530
 531         if (NULL == condition)
 532                 return FALSE;
 533
 534 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
 535         *condition = BT_MO_ONLY_UNLOCKED;
 536         FN_END;
 537         return TRUE;
 538 #else
 539 #if 0
 540         int ret;
 541         ret = vconf_get_int(
 542                         VCONFKEY_CISSAPPL_OUTGOING_CALL_CONDITIONS_INT,
 543                         condition);
 544         if (ret != 0) {
 545                 ERR("Failed to read  [%s]\n",
 546                         VCONFKEY_CISSAPPL_OUTGOING_CALL_CONDITIONS_INT);
 547                 return FALSE;
 548         }
 549 #endif
 550         /* The vconf value does not include in platform. */
 551         *condition = BT_MO_ONLY_UNLOCKED;
 552         FN_END;
 553         return TRUE;
 554 #endif
 555 }
 556
 557 #if defined(TIZEN_WEARABLE) && defined(TIZEN_TELEPHONY_ENABLED)
 558 static gboolean  __bt_ag_agent_launch_call_app(const char *number)
 559 {
 560         FN_START;
 561         bundle *b;
 562
 563         DBG_SECURE("number(%s)", number);
 564
 565         b = bundle_create();
 566         if (NULL == b) {
 567                 ERR("bundle_create() Failed");
 568                 return FALSE;
 569         }
 570
 571         bundle_add(b, "launch-type", "MO");
 572         bundle_add(b, "dial-type", "HEADSET");
 573
 574         if (strlen(number) != 0)
 575                 bundle_add(b, "number", number);
 576
 577         aul_launch_app_async(CALL_APP_ID, b);
 578         bundle_free(b);
 579
 580         FN_END;
 581         return TRUE;
 582 }
 583 #endif
 584
 585 static void *__bt_ag_agent_launch_call_req(void *arg)
 586 {
 587         FN_START;
 588         bundle *b = (bundle *)arg;
 589         if (appsvc_run_service(b, 0, NULL, NULL) < 0)
 590                 ERR("Unable to run app svc");
 591         bundle_free(b);
 592         call_launch_requested = FALSE;
 593         FN_END;
 594         return NULL;
 595 }
 596
 597 static gboolean __bt_ag_agent_make_call(const char *number)
 598 {
 599         FN_START;
 600
 601 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
 602         FN_END;
 603         return __bt_ag_agent_launch_call_app(number);
 604 #else
 605         char telnum[BT_MAX_TEL_NUM_STRING];
 606         bundle *b;
 607         pthread_t thread_id;
 608
 609         if (call_launch_requested == TRUE) {
 610                 DBG("Launch request is in progress");
 611                 return TRUE;
 612         }
 613
 614         b = bundle_create();
 615         if (NULL == b)
 616                 return FALSE;
 617
 618         appsvc_set_operation(b, APPSVC_OPERATION_CALL);
 619         snprintf(telnum, sizeof(telnum), "tel:%s", number);
 620         appsvc_set_uri(b, telnum);
 621         appsvc_add_data(b, "ctindex", "-1");
 622
 623         call_launch_requested = TRUE;
 624         if (pthread_create(&thread_id, NULL,
 625                         (void *)&__bt_ag_agent_launch_call_req,
 626                                         (void *)b) < 0) {
 627                 ERR("pthread_create() is failed");
 628                 call_launch_requested = FALSE;
 629                 return FALSE;
 630         }
 631         if (pthread_detach(thread_id) < 0)
 632                 ERR("pthread_detach() is failed");
 633
 634         FN_END;
 635         return TRUE;
 636 #endif
 637 }
 638
 639 static gboolean __bt_ag_agent_make_video_call(const char *mo_number)
 640 {
 641         FN_START;
 642         bundle *kb;
 643
 644         kb = bundle_create();
 645         if (NULL == kb)
 646                 return FALSE;
 647
 648         bundle_add(kb, "KEY_CALL_TYPE", "MO");
 649         bundle_add(kb, "number", mo_number);
 650         aul_launch_app("org.tizen.vtmain", kb);
 651         bundle_free(kb);
 652
 653         FN_END;
 654         return TRUE;
 655 }
 656
 657 gboolean _bt_ag_agent_answer_call(unsigned int call_id,
 658                                 const gchar *path, const gchar *sender)
 659 {
 660         FN_START;
 661
 662         if (path == NULL || sender == NULL) {
 663                 DBG("Invalid Arguments");
 664                 return FALSE;
 665         }
 666
 667         DBG("Application path = %s", path);
 668         DBG("Call Id = %d", call_id);
 669         DBG("Sender = %s", sender);
 670
 671         _bt_ag_agent_emit_signal(ag_dbus_conn, path,
 672                                         BT_AG_SERVICE_NAME, "Answer",
 673                                         g_variant_new("(u)", call_id));
 674         FN_END;
 675         return TRUE;
 676 }
 677
 678 gboolean _bt_ag_agent_reject_call(unsigned int call_id,
 679                                 const gchar *path, const gchar *sender)
 680 {
 681         FN_START;
 682
 683         if (path == NULL || sender == NULL) {
 684                 DBG("Invalid Arguments");
 685                 return FALSE;
 686         }
 687
 688         DBG("Application path = %s", path);
 689         DBG("Call Id = %d", call_id);
 690         DBG("Sender = %s", sender);
 691
 692         _bt_ag_agent_emit_signal(ag_dbus_conn, path,
 693                                         BT_AG_SERVICE_NAME, "Reject",
 694                                         g_variant_new("(u)", call_id));
 695         FN_END;
 696         return TRUE;
 697 }
 698
 699 gboolean _bt_ag_agent_release_call(unsigned int call_id,
 700                                 const gchar *path, const gchar *sender)
 701 {
 702         FN_START;
 703
 704         if (path == NULL || sender == NULL) {
 705                 DBG("Invalid Arguments");
 706                 return FALSE;
 707         }
 708
 709         DBG("Application path = %s", path);
 710         DBG("Call Id = %d", call_id);
 711         DBG("Sender = %s", sender);
 712
 713         _bt_ag_agent_emit_signal(ag_dbus_conn, path,
 714                                         BT_AG_SERVICE_NAME, "Release",
 715                                         g_variant_new("(u)", call_id));
 716
 717         FN_END;
 718         return TRUE;
 719 }
 720
 721 bt_hfp_agent_error_t _bt_ag_agent_dial_num(const gchar *number, guint flags)
 722 {
 723         bt_hfp_agent_error_t error_code = BT_HFP_AGENT_ERROR_NONE;
 724         int callapp_type;
 725         int phone_lock_state;
 726         int condition;
 727
 728         FN_START;
 729
 730         if (number == NULL) {
 731                 ERR("Invalid Argument");
 732                 error_code = BT_HFP_AGENT_ERROR_INVALID_PARAM;
 733                 goto fail;
 734         }
 735
 736         DBG("Number = %s", number);
 737         DBG("flags = %d", flags);
 738
 739         if (!__bt_is_phone_locked(&phone_lock_state)) {
 740                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 741                 goto fail;
 742         }
 743
 744         if (!__bt_get_outgoing_callapp_type(&callapp_type)) {
 745                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 746                 goto fail;
 747         }
 748
 749         if (!__bt_get_outgoing_call_condition(&condition)) {
 750                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 751                 goto fail;
 752         }
 753
 754         if (condition == BT_MO_ONLY_UNLOCKED && phone_lock_state ==
 755                 VCONFKEY_IDLE_LOCK) {
 756                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 757                 goto fail;
 758         }
 759
 760         if (callapp_type == BT_VIDEO_CALL) {
 761                 if (!__bt_ag_agent_make_video_call(number)) {
 762                         ERR("Problem launching application");
 763                         error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 764                         goto fail;
 765                 }
 766         } else {
 767                 if (!__bt_ag_agent_make_call(number)) {
 768                         ERR("Problem launching application");
 769                         error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 770                         goto fail;
 771                 }
 772         }
 773
 774 fail:
 775         FN_END;
 776         return error_code;
 777 }
 778
 779 bt_hfp_agent_error_t _bt_ag_agent_dial_memory(unsigned int location)
 780 {
 781         bt_hfp_agent_error_t error_code = BT_HFP_AGENT_ERROR_NONE;
 782         char *number = NULL;
 783         contacts_filter_h filter = NULL;
 784         contacts_query_h query = NULL;
 785         contacts_list_h list = NULL;
 786         contacts_record_h record = NULL;
 787         unsigned int projections[] = {
 788                 _contacts_speeddial.number,
 789         };
 790
 791         FN_START;
 792
 793         DBG("location = %d", location);
 794
 795         /*Get number from contacts location*/
 796         if (contacts_connect() != CONTACTS_ERROR_NONE) {
 797                 ERR(" contacts_connect failed");
 798                 return BT_HFP_AGENT_ERROR_INTERNAL;
 799         }
 800
 801         contacts_filter_create(_contacts_speeddial._uri, &filter);
 802
 803         if (filter == NULL)
 804                 goto done;
 805
 806         if (contacts_filter_add_int(filter,
 807                 _contacts_speeddial.speeddial_number,
 808                 CONTACTS_MATCH_EQUAL, location) !=
 809                 CONTACTS_ERROR_NONE) {
 810                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 811                 goto done;
 812         }
 813
 814         contacts_query_create(_contacts_speeddial._uri, &query);
 815
 816         if (query == NULL)
 817                 goto done;
 818
 819         contacts_query_set_filter(query, filter);
 820
 821         if (contacts_query_set_projection(query, projections,
 822                                 sizeof(projections)/sizeof(unsigned int)) !=
 823                                 CONTACTS_ERROR_NONE) {
 824                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 825                 goto done;
 826         }
 827
 828         if (contacts_db_get_records_with_query(query, 0, 1, &list) !=
 829                                 CONTACTS_ERROR_NONE) {
 830                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 831                 goto done;
 832         }
 833
 834         if (contacts_list_first(list) != CONTACTS_ERROR_NONE) {
 835                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 836                 goto done;
 837         }
 838
 839         if (contacts_list_get_current_record_p(list, &record) !=
 840                                 CONTACTS_ERROR_NONE) {
 841                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 842                 goto done;
 843         }
 844
 845         if (record == NULL)
 846                 goto done;
 847
 848         if (contacts_record_get_str(record, _contacts_speeddial.number, &number)
 849                 != CONTACTS_ERROR_NONE) {
 850                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 851                 goto done;
 852         }
 853
 854         if (number == NULL) {
 855                 ERR("No number at the location");
 856                 error_code = BT_HFP_AGENT_ERROR_INVALID_MEMORY_INDEX;
 857                 goto done;
 858         }
 859
 860         DBG("number %s", number);
 861
 862         /*Make Voice call*/
 863         if (!__bt_ag_agent_make_call(number)) {
 864                 ERR("Problem launching application");
 865                 error_code = BT_HFP_AGENT_ERROR_INTERNAL;
 866         }
 867
 868         g_free(number);
 869 done:
 870         if (list != NULL)
 871                 contacts_list_destroy(list, TRUE);
 872
 873         if (filter != NULL)
 874                 contacts_filter_destroy(filter);
 875
 876         if (query != NULL)
 877                 contacts_query_destroy(query);
 878
 879         contacts_disconnect();
 880
 881         FN_END;
 882
 883         return error_code;
 884 }
 885
 886 bt_hfp_agent_error_t _bt_ag_agent_send_dtmf(const gchar *dtmf,
 887                                 const gchar *path, const gchar *sender)
 888 {
 889         bt_hfp_agent_error_t ret;
 890
 891         FN_START;
 892
 893         if (dtmf == NULL || path == NULL || sender == NULL) {
 894                 ERR("Invalid Argument");
 895                 return FALSE;
 896         }
 897
 898         DBG("Dtmf = %s", dtmf);
 899         DBG("Application path = %s", path);
 900         DBG("Sender = %s", sender);
 901
 902         ret = __bt_ag_agent_gdbus_method_send(sender,
 903                                 path, TELEPHONY_APP_INTERFACE,
 904                                 "SendDtmf", FALSE,
 905                                 g_variant_new("(s)", dtmf));
 906
 907         return ret;
 908 }
 909
 910 gboolean _bt_ag_agent_threeway_call(unsigned int chld_value,
 911                                 const gchar *path, const gchar *sender)
 912 {
 913         FN_START;
 914
 915         if (path == NULL || sender == NULL) {
 916                 DBG("Invalid Arguments");
 917                 return FALSE;
 918         }
 919
 920         DBG("Application path = %s", path);
 921         DBG("Value = %d", chld_value);
 922         DBG("Sender = %s", sender);
 923
 924 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
 925         /* Check if AG supports (i.e. ag_chld_str = "0,1,2") the requested CHLD;
 926         if not return FALSE */
 927         if (chld_value != 0 && chld_value != 1 && chld_value != 2)
 928                 return FALSE;
 929 #else
 930         if (chld_value != 0 && chld_value != 1 && chld_value != 2 &&
 931                                 chld_value != 3)
 932                 return FALSE;
 933 #endif
 934         _bt_ag_agent_emit_signal(ag_dbus_conn, path,
 935                                         BT_AG_SERVICE_NAME, "Threeway",
 936                                         g_variant_new("(u)", chld_value));
 937         FN_END;
 938         return TRUE;
 939 }
 940
 941 bt_hfp_agent_error_t _bt_ag_agent_dial_last_num(void *device)
 942 {
 943         bt_hfp_agent_error_t err_code = BT_HFP_AGENT_ERROR_NONE;
 944         char *last_num = NULL;
 945         int type;
 946         int callapp_type;
 947         int phone_lock_state;
 948         int condition;
 949         contacts_list_h list = NULL;
 950         contacts_query_h query = NULL;
 951         contacts_filter_h filter = NULL;
 952         contacts_record_h record = NULL;
 953         unsigned int projections[] = {
 954                 _contacts_phone_log.address,
 955                 _contacts_phone_log.log_type,
 956         };
 957
 958         FN_START;
 959
 960         if (contacts_connect() != CONTACTS_ERROR_NONE) {
 961                 ERR(" contacts_connect failed");
 962                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
 963                 return err_code;
 964         }
 965
 966         contacts_filter_create(_contacts_phone_log._uri, &filter);
 967
 968         if (filter == NULL)
 969                 goto done;
 970
 971         if (contacts_filter_add_int(filter, _contacts_phone_log.log_type,
 972                                 CONTACTS_MATCH_EQUAL,
 973                                 CONTACTS_PLOG_TYPE_VOICE_OUTGOING) !=
 974                                 CONTACTS_ERROR_NONE) {
 975                 ERR(" contacts_filter_add_int failed");
 976                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
 977                 goto done;
 978         }
 979
 980         if (contacts_filter_add_operator(filter, CONTACTS_FILTER_OPERATOR_OR) !=
 981                                 CONTACTS_ERROR_NONE) {
 982                 ERR(" contacts_filter_add_operator failed");
 983                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
 984                 goto done;
 985         }
 986
 987         if (contacts_filter_add_int(filter, _contacts_phone_log.log_type,
 988                                 CONTACTS_MATCH_EQUAL,
 989                                 CONTACTS_PLOG_TYPE_VIDEO_OUTGOING) !=
 990                                 CONTACTS_ERROR_NONE) {
 991                 ERR(" contacts_filter_add_int failed");
 992                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
 993                 goto done;
 994         }
 995
 996         contacts_query_create(_contacts_phone_log._uri, &query);
 997
 998         if (query == NULL)
 999                 goto done;
1000
1001         contacts_query_set_filter(query, filter);
1002
1003         if (contacts_query_set_projection(query, projections,
1004                                 sizeof(projections)/sizeof(unsigned int)) !=
1005                                 CONTACTS_ERROR_NONE) {
1006                 ERR(" contacts_query_set_projection failed");
1007                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1008                 goto done;
1009         }
1010
1011         if (contacts_query_set_sort(query, _contacts_phone_log.log_time, false)
1012                 != CONTACTS_ERROR_NONE) {
1013                 ERR(" contacts_query_set_sort failed");
1014                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1015                 goto done;
1016         }
1017
1018         if (contacts_db_get_records_with_query(query, 0, 1, &list)  !=
1019                                 CONTACTS_ERROR_NONE) {
1020                 ERR(" contacts_db_get_records_with_query failed");
1021                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1022                 goto done;
1023         }
1024
1025         if (contacts_list_first(list)  != CONTACTS_ERROR_NONE) {
1026                 ERR(" contacts_list_first failed");
1027                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1028                 goto done;
1029         }
1030
1031         if (contacts_list_get_current_record_p(list, &record)  !=
1032                                 CONTACTS_ERROR_NONE) {
1033                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1034                 goto done;
1035         }
1036
1037         if (record == NULL)
1038                 goto done;
1039
1040         if (contacts_record_get_str(record, _contacts_phone_log.address,
1041                                 &last_num) != CONTACTS_ERROR_NONE) {
1042                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1043                 goto done;
1044         }
1045
1046         if (last_num == NULL) {
1047                 ERR("No last number");
1048                 err_code = BT_HFP_AGENT_ERROR_NO_CALL_LOGS;
1049                 goto done;
1050         }
1051
1052         if (!__bt_is_phone_locked(&phone_lock_state)) {
1053                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1054                 goto done;
1055         }
1056
1057         if (!__bt_get_outgoing_callapp_type(&callapp_type)) {
1058                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1059                 goto done;
1060         }
1061
1062         if (!__bt_get_outgoing_call_condition(&condition)) {
1063                 ERR(" Failed to get the call condition");
1064                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1065                 goto done;
1066         }
1067
1068         if (condition == BT_MO_ONLY_UNLOCKED &&
1069                 phone_lock_state == VCONFKEY_IDLE_LOCK) {
1070                 ERR(" call condition and phone lock state check fail");
1071                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1072                 goto done;
1073         }
1074
1075         switch (callapp_type) {
1076         case BT_VOICE_CALL:
1077                 if (!__bt_ag_agent_make_call(last_num)) {
1078                         ERR("Problem launching application");
1079                         err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1080                 }
1081                 break;
1082         case BT_VIDEO_CALL:
1083                 if (!__bt_ag_agent_make_video_call(last_num)) {
1084                         ERR("Problem launching application");
1085                         err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1086                 }
1087                 break;
1088         case BT_FOLLOW_CALL_LOG:
1089                 if (contacts_record_get_int(record,
1090                         _contacts_phone_log.log_type,
1091                         &type) != CONTACTS_ERROR_NONE) {
1092                         err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1093                         break;
1094                 }
1095                 if (type == CONTACTS_PLOG_TYPE_VOICE_OUTGOING) {
1096                         if (!__bt_ag_agent_make_call(last_num)) {
1097                                 ERR("Problem launching application");
1098                                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1099                         }
1100                 } else if (type == CONTACTS_PLOG_TYPE_VIDEO_OUTGOING) {
1101                         if (!__bt_ag_agent_make_video_call(last_num)) {
1102                                 ERR("Problem launching application");
1103                                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1104                         }
1105                 } else {
1106                                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1107                 }
1108                 break;
1109         default:
1110                 err_code = BT_HFP_AGENT_ERROR_INTERNAL;
1111                 break;
1112         }
1113
1114 done:
1115
1116         if (list != NULL)
1117                 contacts_list_destroy(list, TRUE);
1118
1119         if (filter != NULL)
1120                 contacts_filter_destroy(filter);
1121
1122         if (query != NULL)
1123                 contacts_query_destroy(query);
1124
1125         contacts_disconnect();
1126
1127         if (last_num != NULL)
1128                 g_free(last_num);
1129
1130         FN_END;
1131
1132         return err_code;
1133 }
1134
1135 bt_hfp_agent_error_t _bt_ag_agent_vendor_cmd(const gchar *cmd,
1136                 const gchar *path, const gchar *sender)
1137 {
1138         bt_hfp_agent_error_t ret;
1139
1140         FN_START;
1141
1142         if (cmd == NULL || path == NULL || sender == NULL) {
1143                 ERR("Invalid Argument");
1144                 return BT_HFP_AGENT_ERROR_INVALID_PARAM;
1145         }
1146
1147         DBG("cmd = %s", cmd);
1148         DBG("Application path = %s", path);
1149         DBG("Sender = %s", sender);
1150
1151         ret = __bt_ag_agent_gdbus_method_send(sender,
1152                                 path, TELEPHONY_APP_INTERFACE,
1153                                 "VendorCmd", FALSE,
1154                                 g_variant_new("(s)", cmd));
1155         FN_END;
1156         return ret;
1157 }
1158
1159 gboolean _bt_ag_agent_get_signal_quality(void *device)
1160 {
1161         gint rssi;
1162
1163         FN_START;
1164
1165         if (vconf_get_int(VCONFKEY_TELEPHONY_RSSI, &rssi)) {
1166                 DBG("VCONFKEY_TELEPHONY_RSSI failed\n");
1167                 goto fail;
1168         }
1169
1170         DBG("RSSI : %d", rssi);
1171
1172         _bt_hfp_signal_quality_reply(rssi, BT_SIGNAL_QUALITY_BER,
1173                 device);
1174
1175         FN_END;
1176         return TRUE;
1177 fail:
1178         FN_END;
1179         _bt_hfp_signal_quality_reply(-1, -1, device);
1180         return FALSE;
1181 }
1182
1183 gboolean _bt_ag_agent_get_battery_status(void *device)
1184 {
1185         gint battery_chrg_status;
1186         gint battery_capacity;
1187
1188         FN_START;
1189
1190         if (vconf_get_int(VCONFKEY_SYSMAN_BATTERY_CHARGE_NOW,
1191                                                 &battery_chrg_status)) {
1192                 DBG("VCONFKEY_SYSMAN_BATTERY_CHARGE_NOW failed\n");
1193                 goto fail;
1194         }
1195
1196         DBG("Status : %d\n", battery_chrg_status);
1197
1198         if (vconf_get_int(VCONFKEY_SYSMAN_BATTERY_CAPACITY,
1199                                                 &battery_capacity)) {
1200                 DBG("VCONFKEY_SYSMAN_BATTERY_CAPACITY failed\n");
1201                 goto fail;
1202         }
1203
1204         DBG("Capacity : %d\n", battery_capacity);
1205
1206         _bt_hfp_battery_property_reply(device,
1207                 battery_chrg_status, battery_capacity);
1208         FN_END;
1209         return TRUE;
1210
1211 fail:
1212         _bt_hfp_battery_property_reply(device, -1, -1);
1213         FN_END;
1214         return FALSE;
1215 }
1216
1217 gboolean _bt_ag_agent_get_operator_name(void *device)
1218 {
1219         char *operator_name;
1220         FN_START;
1221
1222         operator_name = vconf_get_str(VCONFKEY_TELEPHONY_NWNAME);
1223         if (NULL == operator_name) {
1224                 DBG("vconf_get_str failed");
1225                 _bt_hfp_operator_reply(NULL, device);
1226                 return FALSE;
1227         }
1228
1229         DBG("operator_name  = [%s]", operator_name);
1230
1231         _bt_hfp_operator_reply(operator_name, device);
1232
1233         free(operator_name);
1234
1235         FN_END;
1236         return TRUE;
1237 }
1238
1239 gboolean _bt_hfp_agent_nrec_status(gboolean status,
1240                         void *t_device)
1241 {
1242         FN_START;
1243         bt_ag_info_t *hs = (bt_ag_info_t *)t_device;
1244
1245         DBG("NREC status = %d", status);
1246         if (status)
1247                 hs->nrec_status = FALSE;
1248         else
1249                 hs->nrec_status = TRUE;
1250
1251         _bt_ag_agent_emit_signal(ag_dbus_conn, hs->path,
1252                                         BT_AG_SERVICE_NAME, "NrecStatusChanged",
1253                                         g_variant_new("(b)", status));
1254         FN_END;
1255         return TRUE;
1256 }
1257
1258 gboolean _bt_ag_agent_get_imei_number(void *device)
1259 {
1260         FN_START;
1261         char *imei_number;
1262
1263         imei_number = tel_get_misc_me_imei_sync(tapi_handle);
1264         if (NULL == imei_number) {
1265                 ERR("tel_get_misc_me_imei_sync for imei_number failed");
1266                 goto fail;
1267         }
1268
1269         if (!g_utf8_validate(imei_number, -1, NULL)) {
1270                 free(imei_number);
1271                 ERR("get_imei_number : invalid UTF8");
1272                 goto fail;
1273         }
1274
1275         DBG_SECURE("imei_number  = [%s]", imei_number);
1276         _bt_hfp_get_imei_number_reply(imei_number, device);
1277         free(imei_number);
1278         FN_END;
1279         return TRUE;
1280
1281 fail:
1282         _bt_hfp_get_imei_number_reply(NULL, device);
1283         FN_END;
1284         return FALSE;
1285 }
1286
1287 void _bt_ag_agent_get_manufacturer_name(void *device)
1288 {
1289         FN_START;
1290         char *manufacturer_name;
1291         int ret;
1292
1293         ret = system_info_get_platform_string("http://tizen.org/system/manufacturer",
1294                                                 &manufacturer_name);
1295         if (SYSTEM_INFO_ERROR_NONE != ret) {
1296                 ERR("Get manufacturer_name failed : %d", ret);
1297                 if (NULL != manufacturer_name)
1298                         free(manufacturer_name);
1299
1300                 manufacturer_name = g_strdup("Unknown");
1301         } else if (!g_utf8_validate(manufacturer_name, -1, NULL)) {
1302                 free(manufacturer_name);
1303                 manufacturer_name = g_strdup("Unknown");
1304                 ERR("get_manufacturer_name : invalid UTF8");
1305         }
1306
1307         DBG_SECURE("manufacturer_name  = [%s]", manufacturer_name);
1308         _bt_hfp_get_device_manufacturer_reply(manufacturer_name, device);
1309         free(manufacturer_name);
1310         FN_END;
1311 }
1312
1313 void _bt_ag_agent_get_imsi(void *device)
1314 {
1315         FN_START;
1316         TelSimImsiInfo_t imsi;
1317         memset (&imsi, 0, sizeof(TelSimImsiInfo_t));
1318         if (tel_get_sim_imsi(tapi_handle, &imsi) != TAPI_API_SUCCESS) {
1319                 ERR("tel_get_sim_imsi failed");
1320                 goto fail;
1321         }
1322         DBG_SECURE("tapi values %s %s %s", imsi.szMcc, imsi.szMnc, imsi.szMsin);
1323
1324         _bt_hfp_get_imsi_reply(imsi.szMcc, imsi.szMnc, imsi.szMsin, device);
1325         FN_END;
1326         return;
1327 fail:
1328         _bt_hfp_get_imsi_reply(NULL, NULL, NULL, device);
1329         FN_END;
1330 }
1331
1332 int _bt_ag_agent_registration_status_convert(int result)
1333 {
1334         switch (result) {
1335         case TAPI_NETWORK_SERVICE_LEVEL_NO:
1336                 return BT_AGENT_NETWORK_REG_STATUS_NOT_REGISTER;
1337         case TAPI_NETWORK_SERVICE_LEVEL_EMERGENCY:
1338                 return BT_AGENT_NETWORK_REG_STATUS_EMERGENCY;
1339         case TAPI_NETWORK_SERVICE_LEVEL_FULL:
1340                 return BT_AGENT_NETWORK_REG_STATUS_REGISTER_HOME_NETWORK;
1341         case TAPI_NETWORK_SERVICE_LEVEL_SEARCH:
1342                 return BT_AGENT_NETWORK_REG_STATUS_SEARCH;
1343         default:
1344                 return BT_AGENT_NETWORK_REG_STATUS_UNKNOWN;
1345         }
1346         return result;
1347 }
1348
1349 void _bt_ag_agent_get_creg_status(void *device)
1350 {
1351         FN_START;
1352         int result = 0;
1353         int ret = 0;
1354         int n = 1;
1355         int registration_status = 0;
1356         int roam_status = 0;
1357
1358         ret = tel_get_property_int(tapi_handle, TAPI_PROP_NETWORK_CIRCUIT_STATUS,
1359                                 &result);
1360         if (ret != TAPI_API_SUCCESS) {
1361                 ERR("tel_get_property_int failed");
1362                 return;
1363         }
1364         registration_status =
1365                         _bt_ag_agent_registration_status_convert(result);
1366
1367         DBG_SECURE("Registration status %d", result);
1368         DBG_SECURE("Mapped Status %d", registration_status);
1369         if (registration_status ==
1370                         BT_AGENT_NETWORK_REG_STATUS_REGISTER_HOME_NETWORK) {
1371                 ret = vconf_get_int(VCONFKEY_TELEPHONY_SVC_ROAM, &roam_status);
1372                 if (ret != 0) {
1373                         ERR("Get roaming status failed err = %d\n", ret);
1374                         return;
1375                 }
1376                 DBG_SECURE("Roam status %d", roam_status);
1377                 if (roam_status == 1) {
1378                         registration_status =
1379                                         BT_AGENT_NETWORK_REG_STATUS_REGISTERED_ROAMING;
1380                 }
1381         }
1382
1383         _bt_hfp_get_creg_status_reply(n, registration_status, device);
1384
1385         FN_END;
1386         return;
1387 }
1388
1389 void _bt_ag_agent_get_model_name(void *device)
1390 {
1391         FN_START;
1392         char *model_name;
1393         int ret;
1394
1395         ret = system_info_get_platform_string("http://tizen.org/system/model_name", &model_name);
1396         if (SYSTEM_INFO_ERROR_NONE != ret) {
1397                 ERR("Get model_name failed: %d", ret);
1398                 if (NULL != model_name)
1399                         free(model_name);
1400
1401                 model_name = g_strdup("Unknown");
1402         } else if (!g_utf8_validate(model_name, -1, NULL)) {
1403                 free(model_name);
1404                 model_name = g_strdup("Unknown");
1405                 ERR("get_model_name : invalid UTF8");
1406         }
1407
1408         DBG_SECURE("model_name  = [%s]", model_name);
1409         _bt_hfp_get_model_info_reply(model_name, device);
1410         free(model_name);
1411         FN_END;
1412 }
1413
1414 void _bt_ag_agent_get_revision_information(void *device)
1415 {
1416         FN_START;
1417         char *revision_info;
1418         int ret;
1419
1420         ret = system_info_get_platform_string("http://tizen.org/system/build.string",
1421                                 &revision_info);
1422         if (SYSTEM_INFO_ERROR_NONE != ret) {
1423                 ERR("Get revision_info failed: %d", ret);
1424                 if (NULL != revision_info)
1425                         free(revision_info);
1426
1427                 revision_info = g_strdup("Unknown");
1428         } else if (!g_utf8_validate(revision_info, -1, NULL)) {
1429                         free(revision_info);
1430                         revision_info = g_strdup("Unknown");
1431                         ERR("get_revision_info: invalid UTF8");
1432                 }
1433
1434         DBG_SECURE("revision_info  = [%s]", revision_info);
1435         _bt_hfp_get_revision_info_reply(revision_info, device);
1436         free(revision_info);
1437         FN_END;
1438 }
1439
1440 #if defined(TIZEN_WEARABLE) && defined(TIZEN_BT_HFP_AG_ENABLE)
1441 static gboolean __bt_ag_agent_launch_voice_dial(gboolean activate)
1442 {
1443         FN_START;
1444         bundle *b;
1445
1446         b = bundle_create();
1447         if (NULL == b) {
1448                 ERR("bundle_create() Failed");
1449                 return FALSE;
1450         }
1451
1452         bundle_add(b, "domain", "bt_headset");
1453         if (!activate)
1454                 bundle_add(b, "action_type", "deactivate");
1455
1456         aul_launch_app_async("org.tizen.svoice", b);
1457         bundle_free(b);
1458         FN_END;
1459         return TRUE;
1460 }
1461 #else
1462 static gboolean __bt_ag_agent_launch_voice_dial(gboolean activate)
1463 {
1464         FN_START;
1465         app_control_h service = NULL;
1466
1467         app_control_create(&service);
1468
1469         if (service == NULL) {
1470                 ERR("Service create failed");
1471                 return FALSE;
1472         }
1473
1474         app_control_set_app_id(service, "org.tizen.svoice");
1475         app_control_set_operation(service, APP_CONTROL_OPERATION_DEFAULT);
1476         if (app_control_add_extra_data(service, "domain", "bt_headset")
1477                                         != APP_CONTROL_ERROR_NONE) {
1478                 ERR("app_control_add_extra_data failed");
1479                 app_control_destroy(service);
1480                 return FALSE;
1481         }
1482
1483         if (!activate)
1484                 if (app_control_add_extra_data(service, "action_type", "deactivate")
1485                                         != APP_CONTROL_ERROR_NONE) {
1486                         ERR("app_control_add_extra_data failed");
1487                         app_control_destroy(service);
1488                         return FALSE;
1489                 }
1490
1491         if (app_control_send_launch_request(service, NULL, NULL) !=
1492                                                 APP_CONTROL_ERROR_NONE) {
1493                 ERR("launch failed");
1494                 app_control_destroy(service);
1495                 return FALSE;
1496         }
1497
1498         app_control_destroy(service);
1499         FN_END;
1500         return TRUE;
1501 }
1502 #endif
1503
1504 gboolean _bt_ag_agent_voice_dial(gboolean activate)
1505 {
1506         DBG("Activate = %d", activate);
1507
1508         return __bt_ag_agent_launch_voice_dial(activate);
1509 }
1510
1511 static void __bt_ag_codec_negotiation_info_reset(bt_ag_info_t *hs,
1512                                         gboolean reset)
1513 {
1514         hs->codec_info.is_negotiating = FALSE;
1515         hs->codec_info.requested_by_hf = FALSE;
1516         hs->codec_info.sending_codec = 0;
1517         if (reset) {
1518                 hs->codec_info.remote_codecs = 0;
1519                 hs->codec_info.final_codec = 0;
1520                 hs->nrec_status = FALSE;
1521         }
1522
1523         if (hs->codec_info.nego_timer) {
1524                 g_source_remove(hs->codec_info.nego_timer);
1525                 hs->codec_info.nego_timer = 0;
1526         }
1527         wbs_opts.wbs_enable = wbs_en;
1528 }
1529
1530 static gboolean __bt_ag_codec_negotiation_finished(gpointer user_data)
1531 {
1532         struct ag_codec *data = (struct ag_codec *)user_data;
1533
1534         if (g_strcmp0(data->codec_status, "finish") == 0) {
1535                 DBG("Codec negotiation finished");
1536                 __bt_ag_sco_connect(data->bt_ag_info);
1537                 __bt_ag_codec_negotiation_info_reset(data->bt_ag_info, FALSE);
1538                 g_free (data->codec_status);
1539                 g_free (data);
1540                 return TRUE;
1541         } else if (g_strcmp0(data->codec_status, "timeout") == 0) {
1542                 DBG("Timeout is occured in codec negotiation");
1543         }
1544
1545         if (data->bt_ag_info->codec_info.requested_by_hf) {
1546                 __bt_ag_codec_negotiation_info_reset(data->bt_ag_info, FALSE);
1547         } else {
1548                 __bt_ag_sco_connect(data->bt_ag_info);
1549                 __bt_ag_codec_negotiation_info_reset(data->bt_ag_info, FALSE);
1550         }
1551         g_free (data->codec_status);
1552         g_free (data);
1553
1554         return FALSE;
1555 }
1556
1557 static bt_hfp_agent_error_t __bt_ag_set_codec(void *device, char *method)
1558 {
1559         GDBusProxy *proxy;
1560         GVariant *ret;
1561         GError *err = NULL;
1562         bt_ag_info_t *bt_ag_info = (bt_ag_info_t *)device;
1563
1564         proxy =  g_dbus_proxy_new_sync(ag_dbus_conn,
1565                         G_DBUS_PROXY_FLAGS_NONE, NULL,
1566                         BLUEZ_SERVICE_NAME, DEFAULT_ADAPTER_OBJECT_PATH,
1567                         BT_ADAPTER_INTERFACE, NULL, &err);
1568
1569         if (!proxy) {
1570                 if (err) {
1571                         ERR("Unable to create proxy: %s", err->message);
1572                         g_clear_error(&err);
1573                 }
1574                 return BT_HFP_AGENT_ERROR_INTERNAL;
1575         }
1576
1577         ret = g_dbus_proxy_call_sync(proxy, method,
1578                         g_variant_new("(ss)", "Gateway", bt_ag_info->remote_addr),
1579                         G_DBUS_CALL_FLAGS_NONE, -1,
1580                         NULL, &err);
1581         if (ret == NULL) {
1582                 /* dBUS-RPC is failed */
1583                 ERR("dBUS-RPC is failed");
1584                 if (err != NULL) {
1585                         /* dBUS gives error cause */
1586                         ERR("D-Bus API failure: errCode[%x], message[%s]",
1587                                err->code, err->message);
1588
1589                         g_clear_error(&err);
1590                 }
1591                 return BT_HFP_AGENT_ERROR_INTERNAL;
1592         }
1593         g_variant_unref(ret);
1594
1595         return BT_HFP_AGENT_ERROR_NONE;
1596 }
1597
1598 static bt_hfp_agent_error_t __bt_ag_codec_selection_setup(bt_ag_info_t *hs,
1599                         uint32_t codec)
1600 {
1601         bt_hfp_agent_error_t err = BT_HFP_AGENT_ERROR_NONE;
1602
1603         DBG("Codec setup [%x]", codec);
1604
1605         /* 1. Compare sending codec & recieved code */
1606         if (hs->codec_info.sending_codec != codec)
1607                 err = BT_HFP_AGENT_ERROR_INTERNAL;
1608
1609         /* 2. Send WB or NB command */
1610         switch (codec) {
1611         case BT_CVSD_CODEC_ID:
1612                 err = __bt_ag_set_codec(hs, "SetNbParameters");
1613                 break;
1614         case BT_MSBC_CODEC_ID:
1615                 err = __bt_ag_set_codec(hs, "SetWbsParameters");
1616                 break;
1617         default:
1618                 err = BT_HFP_AGENT_ERROR_INTERNAL;
1619                 break;
1620         }
1621
1622         /* If the vendor specific calling returns error or codec is not correct,
1623          * we send CVSD Codec parameter to MM module. and also returns
1624          * normal value to HF
1625         */
1626         if (err != BT_HFP_AGENT_ERROR_NONE)
1627                 codec = BT_CVSD_CODEC_ID;
1628
1629         hs->codec_info.final_codec = codec;
1630
1631         return err;
1632 }
1633
1634 static bt_hfp_agent_error_t __bt_hfp_send_bcs_command(bt_ag_info_t *hs,
1635                         gboolean init_by_hf)
1636 {
1637         uint32_t codec;
1638         struct ag_codec *data = g_new0(struct ag_codec, 1);
1639
1640 #ifdef TIZEN_KIRAN
1641         codec = BT_CVSD_CODEC_ID;
1642 #else
1643         if (hs->codec_info.remote_codecs & BT_MSBC_CODEC_MASK)
1644                 codec = BT_MSBC_CODEC_ID;
1645         else
1646                 codec = BT_CVSD_CODEC_ID;
1647 #endif
1648
1649         if (wbs_opts.wbs_enable == FALSE)
1650                 codec = BT_CVSD_CODEC_ID;
1651
1652         hs->codec = codec;
1653
1654         if (_bt_ag_send_at(hs, "\r\n+BCS: %d\r\n", codec) < 0)
1655                 return BT_HFP_AGENT_ERROR_INTERNAL;
1656         else
1657                 DBG("Send +BCS:%d\n", codec);
1658
1659         /* Send +BCS command to HF, and wait some times */
1660         hs->codec_info.is_negotiating = TRUE;
1661         hs->codec_info.sending_codec = codec;
1662         hs->codec_info.requested_by_hf = init_by_hf;
1663         hs->codec_info.final_codec = codec;
1664
1665         data->bt_ag_info = hs;
1666         data->codec_status = g_strdup ("timeout");
1667
1668         hs->codec_info.nego_timer = g_timeout_add_seconds(
1669                         HFP_CODEC_NEGOTIATION_TIMEOUT,
1670                         (GSourceFunc)__bt_ag_codec_negotiation_finished,
1671                         data);
1672
1673         return BT_HFP_AGENT_ERROR_NONE;
1674 }
1675
1676
1677 static bt_hfp_agent_error_t __bt_hfp_codec_connection_setup(
1678                                 bt_ag_info_t *hs, gboolean init_by_hf)
1679 {
1680         DBG("Request to codec connection by %s", init_by_hf ? "HF" : "AG");
1681
1682         if (hs->state < HEADSET_STATE_CONNECTED)
1683                 return BT_HFP_AGENT_ERROR_NOT_CONNECTED;
1684
1685         if (hs->codec_info.is_negotiating == TRUE) {
1686                 /* In codec negotiation, return and wait */
1687                 ERR("Codec nogotiation is in progress");
1688                 return BT_HFP_AGENT_ERROR_BUSY;
1689         }
1690
1691         /* Not support Codec Negotiation or Not recieved BAC command */
1692         if (!(ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION) ||
1693                                 hs->codec_info.remote_codecs == 0) {
1694                 ERR("No support for Codec Negotiation or receive BAC command");
1695                 if (init_by_hf) {
1696                         return BT_HFP_AGENT_ERROR_INTERNAL;
1697                 } else {
1698                         __bt_ag_sco_connect(hs);
1699                         return BT_HFP_AGENT_ERROR_INTERNAL;
1700                 }
1701         }
1702
1703         /* If HF initiated codec connection setup, it should send OK command
1704          * before +BCS command transmission.
1705          */
1706         if (init_by_hf)
1707                 return HFP_STATE_MNGR_ERR_NONE;
1708         else
1709                 return __bt_hfp_send_bcs_command(hs, init_by_hf);
1710 }
1711
1712
1713 static int __hfp_parse_available_codecs(const char *cmd, uint32_t *codecs)
1714 {
1715         char *str = NULL;
1716         *codecs = 0x00000000;
1717
1718         str = strchr(cmd, '=');
1719         if (str == NULL)
1720                 return -EINVAL;
1721
1722         while (str != NULL) {
1723                 str++;
1724
1725                 if (atoi(str) == BT_CVSD_CODEC_ID)
1726                         *codecs |= BT_CVSD_CODEC_MASK;
1727                 else if (atoi(str) == BT_MSBC_CODEC_ID)
1728                         *codecs |= BT_MSBC_CODEC_MASK;
1729
1730                 str = strchr(str, ',');
1731         }
1732
1733         if (*codecs == 0x00000000)
1734                 return -EINVAL;
1735
1736         return 0;
1737 }
1738
1739 /* AT+BAC (Bluetooth Available Codecs) */
1740 static int __bt_hfp_available_codecs(bt_ag_info_t *hs, const char *buf)
1741 {
1742         uint32_t codecs = 0x00000000;
1743         hfp_state_manager_err_t err = HFP_STATE_MNGR_ERR_NONE;
1744
1745         if (!(ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION)) {
1746                 err = HFP_STATE_MNGR_ERR_AG_FAILURE;
1747         } else if (__hfp_parse_available_codecs(buf, &codecs) < 0) {
1748                 err = HFP_STATE_MNGR_ERR_AG_FAILURE;
1749         } else {
1750                 DBG("Update remote available codecs [%x]", codecs);
1751                 hs->codec_info.remote_codecs = codecs;
1752         }
1753
1754         _bt_ag_send_response(hs, err);
1755
1756         /* Reset codec information and
1757          * restart codec connection setup by AG
1758          */
1759         hs->codec_info.final_codec = 0;
1760         if (hs->codec_info.nego_timer) {
1761                 hs->codec_info.is_negotiating = FALSE;
1762                 hs->codec_info.requested_by_hf = FALSE;
1763                 hs->codec_info.sending_codec = 0;
1764                 g_source_remove(hs->codec_info.nego_timer);
1765                 __bt_hfp_codec_connection_setup(hs, FALSE);
1766         }
1767
1768         return 0;
1769 }
1770
1771 /* AT+BCC (Bluetooth Codec Connection) */
1772 static int __bt_hfp_codec_connection(bt_ag_info_t *hs, const char *buf)
1773 {
1774         hfp_state_manager_err_t err = HFP_STATE_MNGR_ERR_NONE;
1775
1776         err = __bt_hfp_codec_connection_setup(hs, TRUE);
1777
1778         _bt_ag_send_response(hs, err);
1779
1780         if (err == HFP_STATE_MNGR_ERR_NONE)
1781                 err = __bt_hfp_send_bcs_command(hs, TRUE);
1782
1783         if (err != HFP_STATE_MNGR_ERR_NONE)
1784                 ERR("Fail to request codec connection setup");
1785
1786         return 0;
1787 }
1788
1789 /* AT+BCS (Bluetooth Codec Selection) */
1790 static int __bt_hfp_codec_selection(bt_ag_info_t *hs, const char *buf)
1791 {
1792         uint32_t codec = 0x00000000;
1793         hfp_state_manager_err_t err = HFP_STATE_MNGR_ERR_NONE;
1794         struct ag_codec *data = g_new0(struct ag_codec, 1);
1795
1796         /* Timer reset */
1797         if (hs->codec_info.nego_timer) {
1798                 g_source_remove(hs->codec_info.nego_timer);
1799                 hs->codec_info.nego_timer = 0;
1800         }
1801
1802         if (!(ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION))
1803                 err = HFP_STATE_MNGR_ERR_AG_FAILURE;
1804         else if (__hfp_parse_available_codecs(buf, &codec) < 0)
1805                 err = HFP_STATE_MNGR_ERR_AG_FAILURE;
1806         else if (__bt_ag_codec_selection_setup(hs, codec) !=
1807                                         BT_HFP_AGENT_ERROR_NONE)
1808                 err = HFP_STATE_MNGR_ERR_AG_FAILURE;
1809
1810         data->bt_ag_info = hs;
1811         data->codec_status = g_strdup ("finish");
1812         _bt_ag_send_response(hs, err);
1813         __bt_ag_codec_negotiation_finished(data);
1814
1815         return 0;
1816 }
1817
1818 static void __bt_ag_str2ba(const char *str, bt_addr *ba)
1819 {
1820         int i;
1821         for (i = 5; i >= 0; i--, str += 3)
1822                 ba->b[i] = strtol(str, NULL, 16);
1823 }
1824
1825 static const char *__bt_ag_state2str(hs_state_t state)
1826 {
1827         switch (state) {
1828         case HEADSET_STATE_DISCONNECTED:
1829                 return "disconnected";
1830         case HEADSET_STATE_CONNECTING:
1831                 return "connecting";
1832         case HEADSET_STATE_CONNECTED:
1833                 return "connected";
1834         case HEADSET_STATE_PLAY_IN_PROGRESS:
1835                 return "Play In Progress";
1836         case HEADSET_STATE_ON_CALL:
1837                 return "On Call";
1838         }
1839
1840         return NULL;
1841 }
1842
1843 void _bt_convert_addr_string_to_type_rev(unsigned char *addr,
1844                                         const char *address)
1845 {
1846         int i;
1847         char *ptr = NULL;
1848
1849         ret_if(address == NULL);
1850         ret_if(addr == NULL);
1851
1852         for (i = 0; i < 6; i++) {
1853                 addr[5 - i] = strtol(address, &ptr, 16);
1854                 if (ptr[0] != '\0') {
1855                         if (ptr[0] != ':')
1856                                 return;
1857
1858                         address = ptr + 1;
1859                 }
1860         }
1861 }
1862
1863 static gboolean __bt_ag_check_nval(GIOChannel *chan)
1864 {
1865         struct pollfd file_desc;
1866
1867         memset(&file_desc, 0, sizeof(file_desc));
1868         file_desc.fd = g_io_channel_unix_get_fd(chan);
1869         file_desc.events = POLLNVAL;
1870
1871         if (poll(&file_desc, 1, 0) > 0 && (POLLNVAL & file_desc.revents))
1872                 return TRUE;
1873
1874         return FALSE;
1875 }
1876
1877 static int __bt_ag_sco_connect(bt_ag_info_t *hs)
1878 {
1879         struct sco_socket_addr sco_addr;
1880         int err;
1881         GIOChannel *io;
1882         int sco_skt;
1883         bt_voice bt_vo;
1884         bt_ag_slconn_t *slconn = hs->slc;
1885         /*guint watch_id;*/
1886
1887         if (hs->state != HEADSET_STATE_CONNECTED)
1888                 return BT_HFP_AGENT_ERROR_NOT_CONNECTED;
1889 #ifdef TIZEN_MEDIA_ENHANCE
1890         _bt_ag_agent_check_transport_state();
1891 #endif
1892
1893         /* Create Sco socket */
1894         sco_skt = socket(AF_BLUETOOTH, SOCK_SEQPACKET, BT_SCO_PRTCL);
1895         if (sco_skt < 0) {
1896                 ERR("ERROR: Create socket failed.\n");
1897                 return BT_HFP_AGENT_ERROR_INTERNAL;
1898         }
1899
1900         /* Bind Sco Socket to Local BD addr */
1901         memset(&sco_addr, 0, sizeof(sco_addr));
1902         sco_addr.sco_family = AF_BLUETOOTH;
1903
1904         __bt_ag_str2ba(local_addr, &sco_addr.sco_bdaddr);
1905         DBG("Local BD address: %s", local_addr);
1906
1907         err = bind(sco_skt, (struct sockaddr *) &sco_addr, sizeof(sco_addr));
1908         if (err < 0) {
1909                 ERR("ERROR: sco socket binding failed");
1910                 ERR("Close SCO skt");
1911                 close(sco_skt);
1912                 return BT_HFP_AGENT_ERROR_INTERNAL;
1913         }
1914
1915         DBG("Socket FD : %d", sco_skt);
1916
1917         io = g_io_channel_unix_new(sco_skt);
1918         g_io_channel_set_close_on_unref(io, TRUE);
1919         /*g_io_channel_set_flags(io, G_IO_FLAG_NONBLOCK, NULL);
1920         g_io_channel_set_buffered(io, FALSE);
1921         g_io_channel_set_encoding(io, NULL, NULL);*/
1922
1923         if ((ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION) &&
1924                 (slconn && (slconn->hs_features &
1925                         BT_HF_FEATURE_CODEC_NEGOTIATION)) &&
1926                         wbs_opts.wbs_enable == TRUE) {
1927                 bt_vo.setting = (hs->codec == BT_MSBC_CODEC_ID) ?
1928                                 BT_HFP_MSBC_VOICE : BT_HFP_CVSD_VOICE;
1929
1930                 DBG("set Bluetooth voice: %d", bt_vo.setting);
1931                 err = setsockopt(sco_skt, BT_SOCKET_LEVEL,
1932                                         BT_VOICE_NUM, &bt_vo, sizeof(bt_vo));
1933                 if (err < 0) {
1934                         ERR("ERROR: sco socket set socket option failed");
1935                         ERR("Close SCO skt");
1936                         close(sco_skt);
1937                         return BT_HFP_AGENT_ERROR_INTERNAL;
1938                 }
1939         } else {
1940                 DBG("Set NB codec parameter");
1941                 __bt_ag_set_codec(hs, "SetNbParameters");
1942         }
1943
1944         memset(&sco_addr, 0, sizeof(sco_addr));
1945         sco_addr.sco_family = AF_BLUETOOTH;
1946         __bt_ag_str2ba(hs->remote_addr, &sco_addr.sco_bdaddr);
1947         DBG("remotel BD address: %s", hs->remote_addr);
1948
1949         err = connect(sco_skt, (struct sockaddr *) &sco_addr, sizeof(sco_addr));
1950         if (err < 0 && !(errno == EINPROGRESS || errno == EAGAIN)) {
1951                 ERR("ERROR: sco socket connect failed : %d", err);
1952                 ERR("Close SCO skt");
1953                 close(sco_skt);
1954                 return BT_HFP_AGENT_ERROR_INTERNAL;
1955         }
1956
1957         /* Disabling the watch since SCO is connected */
1958         /*watch_id = __bt_ag_set_watch(io,
1959                         (GIOFunc) __bt_ag_sco_connect_cb, hs);
1960         if (watch_id)
1961                 DBG("SCO watch set Success");*/
1962
1963         hs->sco = io;
1964
1965         _bt_ag_set_headset_state(hs, HEADSET_STATE_ON_CALL);
1966         return BT_HFP_AGENT_ERROR_NONE;
1967 }
1968
1969 static void __bt_ag_close_sco(bt_ag_info_t *hs)
1970 {
1971         DBG("");
1972         if (hs->sco) {
1973                 int sock = g_io_channel_unix_get_fd(hs->sco);
1974                 shutdown(sock, SHUT_RDWR);
1975                 g_io_channel_unref(hs->sco);
1976                 hs->sco = NULL;
1977         }
1978
1979         if (hs->sco_id)
1980                 __bt_ag_agent_remove_watch(&hs->sco_id);
1981 }
1982
1983 static gboolean __bt_ag_sco_server_conn_cb(GIOChannel *chan,
1984                                 GIOCondition cond, gpointer user_data)
1985 {
1986         bt_ag_info_t *ag_info = user_data;
1987
1988         DBG("");
1989         if (cond & G_IO_NVAL)
1990                 return FALSE;
1991
1992         if (cond & (G_IO_HUP | G_IO_ERR)) {
1993                 ag_info->sco = NULL;
1994                 if (ag_info->sco_id)
1995                         __bt_ag_agent_remove_watch(&ag_info->sco_id);
1996
1997                 if (ag_info->watch_id)
1998                         _bt_ag_set_headset_state(ag_info, HEADSET_STATE_CONNECTED);
1999                 return FALSE;
2000         }
2001         return TRUE;
2002 }
2003
2004 static gboolean __bt_ag_sco_server_cb(GIOChannel *chan,
2005                                 GIOCondition cond, gpointer user_data)
2006 {
2007         bt_ag_info_t *ag_info = user_data;
2008         int sco_skt;
2009         int cli_sco_sock;
2010         GIOChannel *sco_io;
2011         bt_ag_slconn_t *slconn = ag_info->slc;
2012         bt_voice bt_vo;
2013         int err;
2014
2015         if ((cond & (G_IO_NVAL | G_IO_HUP | G_IO_ERR)) ||
2016                                 __bt_ag_check_nval(chan)) {
2017                 ERR("cond or chan is not valid");
2018                 return FALSE;
2019         }
2020
2021         INFO_C("Incoming SCO....");
2022
2023         if (ag_info->state < HEADSET_STATE_CONNECTED)
2024                 return BT_HFP_AGENT_ERROR_NOT_CONNECTED;
2025
2026         sco_skt = g_io_channel_unix_get_fd(chan);
2027
2028         cli_sco_sock = accept(sco_skt, NULL, NULL);
2029         if (cli_sco_sock < 0) {
2030                 ERR("accept is failed");
2031                 return TRUE;
2032         }
2033
2034         sco_io = g_io_channel_unix_new(cli_sco_sock);
2035         g_io_channel_set_close_on_unref(sco_io, TRUE);
2036         g_io_channel_set_encoding(sco_io, NULL, NULL);
2037         g_io_channel_set_flags(sco_io, G_IO_FLAG_NONBLOCK, NULL);
2038         g_io_channel_set_buffered(sco_io, FALSE);
2039
2040         if ((ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION) &&
2041                 (slconn && (slconn->hs_features &
2042                         BT_HF_FEATURE_CODEC_NEGOTIATION)) &&
2043                         wbs_opts.wbs_enable == TRUE) {
2044                 bt_vo.setting = (ag_info->codec == BT_MSBC_CODEC_ID) ?
2045                                 BT_HFP_MSBC_VOICE : BT_HFP_CVSD_VOICE;
2046
2047                 DBG("set Bluetooth voice: %d", bt_vo.setting);
2048                 err = setsockopt(cli_sco_sock, BT_SOCKET_LEVEL,
2049                                         BT_VOICE_NUM, &bt_vo, sizeof(bt_vo));
2050                 if (err < 0) {
2051                         ERR("Sco socket set socket option failed");
2052                         close(cli_sco_sock);
2053                         return FALSE;
2054                 }
2055         }
2056
2057         ag_info->sco = sco_io;
2058         ag_info->sco_id = g_io_add_watch(sco_io, G_IO_HUP | G_IO_ERR | G_IO_NVAL,
2059                                         __bt_ag_sco_server_conn_cb, ag_info);
2060
2061         if (remote_dev_path)
2062                 g_free(remote_dev_path);
2063
2064         remote_dev_path = g_strdup(ag_info->path);
2065
2066         _bt_ag_set_headset_state(ag_info, HEADSET_STATE_ON_CALL);
2067
2068         return TRUE;
2069 }
2070
2071 static int __bt_ag_start_sco_server(bt_ag_info_t *hs)
2072 {
2073         DBG("Start SCO server");
2074         struct sco_socket_addr addr;
2075         GIOChannel *sco_io;
2076         int sco_skt;
2077         bdaddr_t bd_addr = {{0},};
2078
2079         if (hs->sco_server_started) {
2080                 DBG("Already exsist");
2081                 return BT_HFP_AGENT_ERROR_ALREADY_EXSIST;
2082         }
2083
2084         /* Create socket */
2085         sco_skt = socket(AF_BLUETOOTH, SOCK_SEQPACKET, BT_SCO_PRTCL);
2086         if (sco_skt < 0) {
2087                 ERR("Can't create socket:\n");
2088                 return BT_HFP_AGENT_ERROR_INTERNAL;
2089         }
2090
2091         /* Bind to local address */
2092         memset(&addr, 0, sizeof(addr));
2093         addr.sco_family = AF_BLUETOOTH;
2094
2095         _bt_convert_addr_string_to_type_rev(bd_addr.b, hs->remote_addr);
2096         DBG("Bind to address %s", hs->remote_addr);
2097         memcpy(&addr.sco_bdaddr, &bd_addr, sizeof(bdaddr_t));
2098
2099         if (bind(sco_skt, (struct sockaddr *) &addr, sizeof(addr)) < 0) {
2100                 ERR("Can't bind socket:\n");
2101                 goto error;
2102         }
2103
2104         if (listen(sco_skt, 1)) {
2105                 ERR("Can not listen on the socket:\n");
2106                 goto error;
2107         }
2108
2109         sco_io = g_io_channel_unix_new(sco_skt);
2110         g_io_channel_set_close_on_unref(sco_io, TRUE);
2111         g_io_channel_set_encoding(sco_io, NULL, NULL);
2112         g_io_channel_set_flags(sco_io, G_IO_FLAG_NONBLOCK, NULL);
2113         g_io_channel_set_buffered(sco_io, FALSE);
2114
2115         hs->sco_server = sco_io;
2116         hs->sco_watch_id = g_io_add_watch(sco_io,
2117                         G_IO_IN | G_IO_HUP | G_IO_ERR |
2118                         G_IO_NVAL, __bt_ag_sco_server_cb, hs);
2119
2120         hs->sco_server_started = TRUE;
2121         return BT_HFP_AGENT_ERROR_NONE;
2122
2123 error:
2124         close(sco_skt);
2125         return BT_HFP_AGENT_ERROR_INTERNAL;
2126 }
2127
2128 void __bt_ag_stop_sco_server(bt_ag_info_t *hs)
2129 {
2130         DBG("Stop SCO server");
2131         if (hs->sco_server) {
2132                 g_io_channel_shutdown(hs->sco_server, TRUE, NULL);
2133                 g_io_channel_unref(hs->sco_server);
2134                 hs->sco_server = NULL;
2135         }
2136         hs->sco_server_started = FALSE;
2137 }
2138
2139 static int __bt_ag_headset_close_rfcomm(bt_ag_info_t *hs)
2140 {
2141         GIOChannel *rfcomm = hs->rfcomm;
2142
2143         if (rfcomm) {
2144                 g_io_channel_shutdown(rfcomm, TRUE, NULL);
2145                 g_io_channel_unref(rfcomm);
2146                 hs->rfcomm = NULL;
2147         }
2148
2149         g_free(hs->slc);
2150         hs->slc = NULL;
2151
2152         return 0;
2153 }
2154
2155 static gboolean __bt_ag_sco_cb(GIOChannel *chan, GIOCondition cond,
2156                         bt_ag_info_t *hs)
2157 {
2158         if (cond & G_IO_NVAL)
2159                 return FALSE;
2160
2161         if (name_owner_sig_id != -1)
2162                 g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
2163                                         name_owner_sig_id);
2164         name_owner_sig_id = -1;
2165         g_free(sco_owner);
2166         sco_owner = NULL;
2167
2168         DBG("Audio connection disconnected");
2169         _bt_ag_set_headset_state(hs, HEADSET_STATE_CONNECTED);
2170
2171         return FALSE;
2172 }
2173
2174 void _bt_ag_set_headset_state(bt_ag_info_t *hs, hs_state_t state)
2175 {
2176         bt_ag_slconn_t *slconn = hs->slc;
2177         const char *hs_state;
2178         hs_state_t org_state = hs->state;
2179         gboolean val = FALSE;
2180
2181         if (org_state == state)
2182                 return;
2183
2184         hs_state = __bt_ag_state2str(state);
2185
2186         switch (state) {
2187         case HEADSET_STATE_CONNECTING:
2188                 _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2189                                         hs->path,
2190                                         BT_HEADSET_INTERFACE, "State",
2191                                         g_variant_new("s", hs_state));
2192                 hs->state = state;
2193                 break;
2194
2195         case HEADSET_STATE_CONNECTED:
2196                 if (hs->state != HEADSET_STATE_PLAY_IN_PROGRESS)
2197                         _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2198                                         hs->path,
2199                                         BT_HEADSET_INTERFACE, "State",
2200                                         g_variant_new("s", hs_state));
2201
2202                 if (hs->state < state) {
2203                         val = TRUE;
2204                         active_devices = g_slist_append(active_devices, hs);
2205                         _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2206                                                 hs->path,
2207                                                 BT_HEADSET_INTERFACE,
2208                                                 "Connected",
2209                                                 g_variant_new("b", val));
2210
2211                         DBG("Device %s connected\n", hs->remote_addr);
2212 #if defined(TIZEN_SUPPORT_DUAL_HF)
2213                          if (!hs->is_companion_device)
2214                                 __bt_ag_start_sco_server(hs);
2215 #else
2216                         __bt_ag_start_sco_server(hs);
2217 #endif
2218
2219                         /* Set default code as Gateway NB */
2220                         __bt_ag_set_codec(hs, "SetNbParameters");
2221                 } else if (hs->state == HEADSET_STATE_ON_CALL) {
2222                         val = FALSE;
2223                         _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2224                                                 hs->path,
2225                                                 BT_HEADSET_INTERFACE,
2226                                                 "Playing",
2227                                                 g_variant_new("b", val));
2228                 }
2229                 hs->state = state;
2230                 break;
2231
2232         case HEADSET_STATE_DISCONNECTED:
2233                 __bt_ag_close_sco(hs);
2234                 __bt_ag_headset_close_rfcomm(hs);
2235
2236                 if (hs->state == HEADSET_STATE_ON_CALL) {
2237                         val = FALSE;
2238                         _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2239                                                 hs->path,
2240                                                 BT_HEADSET_INTERFACE,
2241                                                 "Playing",
2242                                                 g_variant_new("b", val));
2243                 }
2244
2245                 val = FALSE;
2246                 _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2247                                 hs->path,
2248                                 BT_HEADSET_INTERFACE,
2249                                 "Connected",
2250                                 g_variant_new("b", val));
2251                 if (hs->state > HEADSET_STATE_CONNECTING)
2252                         _bt_hfp_device_disconnected(hs);
2253
2254                 active_devices = g_slist_remove(active_devices, hs);
2255
2256                 __bt_ag_codec_negotiation_info_reset(hs, TRUE);
2257 #if 0 /* SCO is crashed if below is called when SCO is opened by hf-agent */
2258                 __bt_ag_set_codec(hs, "SetNbParameters");
2259 #endif
2260                 hs->codec = 0;
2261
2262                 /* Since SCO server is binded on remote address */
2263                 /* Need to stop SCO server once heasdet disconencted*/
2264                 if(hs->sco_server_started)
2265                         __bt_ag_stop_sco_server(hs);
2266
2267                 g_free(hs->remote_addr);
2268                 g_free(hs->slc);
2269                 g_free(hs);
2270                 break;
2271
2272         case HEADSET_STATE_PLAY_IN_PROGRESS:
2273         case HEADSET_STATE_ON_CALL:
2274                 val = TRUE;
2275                 _bt_ag_agent_emit_property_changed(ag_dbus_conn,
2276                                         hs->path,
2277                                         BT_HEADSET_INTERFACE, "State",
2278                                         g_variant_new("s", hs_state));
2279
2280                 /*add watch for sco data */
2281                 hs->sco_id = g_io_add_watch(hs->sco,
2282                                         G_IO_ERR | G_IO_NVAL,
2283                                         (GIOFunc) __bt_ag_sco_cb, hs);
2284
2285                 _bt_ag_agent_emit_property_changed(
2286                                 ag_dbus_conn, hs->path,
2287                                 BT_HEADSET_INTERFACE, "Playing",
2288                                 g_variant_new("b", val));
2289
2290                 if (slconn->microphone_gain >= 0)
2291                         _bt_ag_send_at(hs, "\r\n+VGM=%u\r\n",
2292                                 slconn->microphone_gain);
2293
2294                 if (slconn->speaker_gain >= 0)
2295                         _bt_ag_send_at(hs, "\r\n+VGS=%u\r\n",
2296                                 slconn->speaker_gain);
2297
2298                 hs->state = state;
2299                 break;
2300
2301         default:
2302                 hs->state = state;
2303                 break;
2304         }
2305
2306         INFO("STATE CHANGED from [%s(%d)] to [%s(%d)]",
2307                 __bt_ag_state2str(org_state), org_state, __bt_ag_state2str(state), state);
2308 }
2309
2310 static struct event at_event_callbacks[] = {
2311         { "AT+BRSF", _bt_hfp_supported_features },
2312         { "AT+CIND", _bt_hfp_report_indicators },
2313         { "AT+CMER", _bt_hfp_enable_indicators },
2314         { "AT+CHLD", _bt_hfp_call_hold },
2315         { "ATA", _bt_hfp_answer_call },
2316         { "ATD", _bt_hfp_dial_number },
2317         { "AT+VG", _bt_hfp_signal_gain_setting },
2318         { "AT+CHUP", _bt_hfp_terminate_call },
2319         { "AT+CKPD", _bt_hfp_key_press },
2320         { "AT+CLIP", _bt_hfp_cli_notification },
2321         { "AT+BTRH", _bt_hfp_response_and_hold },
2322         { "AT+BLDN", _bt_hfp_last_dialed_number },
2323         { "AT+VTS", _bt_hfp_dtmf_tone },
2324         { "AT+CNUM", _bt_hfp_subscriber_number },
2325         { "AT+CLCC", _bt_hfp_list_current_calls },
2326         { "AT+CMEE", _bt_hfp_extended_errors },
2327         { "AT+CCWA", _bt_hfp_call_waiting_notify },
2328         { "AT+COPS", _bt_hfp_operator_selection },
2329         { "AT+NREC", _bt_hfp_nr_and_ec },
2330         { "AT+BVRA", _bt_hfp_voice_dial },
2331         { "AT+XAPL", _bt_hfp_apl_command },
2332         { "AT+IPHONEACCEV", _bt_hfp_apl_command },
2333         { "AT+BIA", _bt_hfp_indicators_activation },
2334         { "AT+CPBS", _bt_hfp_select_pb_memory },
2335         { "AT+CPBR", _bt_hfp_read_pb_entries},
2336         { "AT+CPBF", _bt_hfp_find_pb_entires },
2337         { "AT+CSCS", _bt_hfp_select_character_set },
2338         { "AT+CSQ", _bt_hfp_get_signal_quality },
2339         { "AT+CBC", _bt_hfp_get_battery_charge_status },
2340         { "AT+CPAS", _bt_hfp_get_activity_status },
2341         { "AT+CGSN", _bt_hfp_get_equipment_identity },
2342         { "AT+CGMM", _bt_hfp_get_model_information },
2343         { "AT+CGMI", _bt_hfp_get_device_manufacturer },
2344         { "AT+CGMR", _bt_hfp_get_revision_information },
2345         { "AT+BAC", __bt_hfp_available_codecs },
2346         { "AT+BCC", __bt_hfp_codec_connection },
2347         { "AT+BCS", __bt_hfp_codec_selection },
2348         { "AT+XSAT", _bt_hfp_vendor_cmd },
2349         { "AT+CIMI", _bt_hfp_get_imsi },
2350         { "AT+CREG", _bt_hfp_get_creg_status },
2351         { 0 }
2352 };
2353
2354 int num_of_secure_command = 4;
2355 static const char* secure_command[] = {"CLCC", "CLIP", "CPBR", "CCWA"};
2356
2357 void __bt_ag_agent_print_at_buffer(char *message, const char *buf)
2358 {
2359
2360         int i = 0;
2361         char s[MAX_BUFFER_SIZE] = {0, };
2362         gboolean hide = FALSE;
2363
2364         gboolean is_security_command = FALSE;
2365         char *xsat_ptr;
2366
2367         strncpy(s, buf, MAX_BUFFER_SIZE - 1);
2368
2369         for (i=0; i<num_of_secure_command; i++) {
2370                 if (strstr(buf, secure_command[i])) {
2371                         is_security_command = TRUE;
2372                         break;
2373                 }
2374         }
2375
2376 done:
2377         /* +XSAT: 11,DISC */
2378         xsat_ptr =  strstr(s, "11,DISC,");
2379         if (xsat_ptr) {
2380                 xsat_ptr = xsat_ptr + 8;
2381                 int x = 0;
2382                 while (xsat_ptr[x] != '\0' && xsat_ptr[x] != '\r' && xsat_ptr[x] != '\n') {
2383                         xsat_ptr[x] = 'X';
2384                         x++;
2385                 }
2386         }
2387
2388         /* AT+XSAT=11,Q_CT,X,XXXX */
2389         xsat_ptr =  strstr(s, "11,Q_CT,");
2390         if (xsat_ptr) {
2391                 xsat_ptr = xsat_ptr + 8;
2392                 int x = 0;
2393                 while (xsat_ptr[x] != '\0' && xsat_ptr[x] != '\r' && xsat_ptr[x] != '\n') {
2394                         if (x > 1) /* ignore 0 and 1 position */
2395                                 xsat_ptr[x] = 'X';
2396                         x++;
2397                 }
2398         }
2399
2400         i = 0;
2401         while (s[i] != '\0') {
2402                 if (s[i] == '\r' || s[i] == '\n') {
2403                         s[i] = '.';
2404                 } else {
2405                         if (s[i] == '\"')
2406                                 hide = hide ? FALSE : TRUE;
2407                         else if (is_security_command && hide) {
2408                                 if (i % 2)
2409                                         s[i] = 'X';
2410                         }
2411                 }
2412                 i++;
2413         }
2414         if (message)
2415                 INFO("%s Buffer = [%s], Len(%d)", message, s, strlen(s));
2416         else
2417                 INFO("[%s]", s);
2418 }
2419
2420 static int __bt_ag_at_handler(bt_ag_info_t *hs, const char *buf)
2421 {
2422         struct event *ev;
2423
2424         __bt_ag_agent_print_at_buffer("[AG AT CMD][RCVD] :", buf);
2425
2426         for (ev = at_event_callbacks; ev->cmd; ev++) {
2427                 if (!strncmp(buf, ev->cmd, strlen(ev->cmd)))
2428                         return ev->callback(hs, buf);
2429         }
2430
2431         return -EINVAL;
2432 }
2433
2434 static int __bt_ag_send_at_valist(bt_ag_info_t *hdset, va_list list,
2435                         char *list_format)
2436 {
2437         ssize_t final_written, count;
2438         char rsp_buffer[MAX_BUFFER_SIZE];
2439         int fd;
2440         int err;
2441
2442         count = vsnprintf(rsp_buffer, sizeof(rsp_buffer), list_format, list);
2443         if (count < 0) {
2444                 ERR("count is %d", count);
2445                 return -EINVAL;
2446         }
2447
2448         if (!hdset->io_chan) {
2449                 ERR("__bt_ag_send_at_valist: headset not connected");
2450                 return -EIO;
2451         }
2452
2453         final_written = 0;
2454
2455         fd = g_io_channel_unix_get_fd(hdset->io_chan);
2456
2457         if (fd != 0) {
2458                 while (final_written < count) {
2459                         ssize_t written;
2460
2461                         do {
2462                                 written = write(fd, rsp_buffer + final_written,
2463                                                 count - final_written);
2464                         } while (written < 0 && errno == EINTR);
2465
2466                         if (written < 0) {
2467                                 err = -errno;
2468                                 ERR("write failed : %s (%d)", strerror(-err), -err);
2469                                 return -errno;
2470                         }
2471
2472                         final_written += written;
2473                 }
2474
2475                 /* Synchronize the sending buffer */
2476                 sync();
2477                 fsync(fd);
2478         } else {
2479                 ERR("FD is 0. remote_addr : %s", hdset->remote_addr);
2480                 return -1;
2481         }
2482
2483         __bt_ag_agent_print_at_buffer("[AG AT CMD][SENT]", rsp_buffer);
2484
2485         return 0;
2486 }
2487
2488 int __attribute__((format(printf, 2, 3)))
2489                         _bt_ag_send_at(bt_ag_info_t *hs, char *format, ...)
2490 {
2491         va_list ap;
2492         int ret;
2493
2494         va_start(ap, format);
2495         ret = __bt_ag_send_at_valist(hs, ap, format);
2496         va_end(ap);
2497
2498         return ret;
2499 }
2500
2501 void __attribute__((format(printf, 3, 4)))
2502                 _bt_ag_send_foreach_headset(GSList *devices,
2503                                 int (*cmp) (bt_ag_info_t *hs),
2504                                 char *format, ...)
2505 {
2506         GSList *l;
2507         va_list ap;
2508
2509         for (l = devices; l != NULL; l = l->next) {
2510                 bt_ag_info_t *hs = l->data;
2511                 int ret;
2512
2513                 if (cmp && cmp(hs) != 0)
2514                         continue;
2515
2516                 va_start(ap, format);
2517                 ret = __bt_ag_send_at_valist(hs, ap, format);
2518                 if (ret < 0)
2519                         ERR("Failed to send to headset: %s (%d)",
2520                                         strerror(-ret), -ret);
2521                 va_end(ap);
2522         }
2523 }
2524
2525 int _bt_ag_send_response(bt_ag_info_t *hs, hfp_state_manager_err_t err)
2526 {
2527         if ((err != HFP_STATE_MNGR_ERR_NONE) && hs->slc->is_cme_enabled)
2528                 return _bt_ag_send_at(hs, "\r\n+CME ERROR: %d\r\n", err);
2529
2530         switch (err) {
2531         case HFP_STATE_MNGR_ERR_NONE:
2532                 return _bt_ag_send_at(hs, "\r\nOK\r\n");
2533         case HFP_STATE_MNGR_ERR_NO_NETWORK_SERVICE:
2534                 return _bt_ag_send_at(hs, "\r\nNO CARRIER\r\n");
2535         default:
2536                 return _bt_ag_send_at(hs, "\r\nERROR\r\n");
2537         }
2538 }
2539
2540 static gboolean __bt_ag_event_handler(GIOChannel *channel,
2541                                 GIOCondition cond, void *user_data)
2542 {
2543         bt_ag_slconn_t *slconn;
2544         unsigned char event_buf[MAX_BUFFER_SIZE];
2545         ssize_t len;
2546         size_t available_buffer;
2547         int fd;
2548         bt_ag_info_t *bt_ag_info = (bt_ag_info_t *)user_data;
2549
2550
2551         if (cond & G_IO_NVAL)
2552                 return FALSE;
2553
2554         slconn = bt_ag_info->slc;
2555         if (cond & (G_IO_ERR | G_IO_HUP)) {
2556                 if (bt_ag_info->watch_id)
2557                         __bt_ag_agent_remove_watch(&bt_ag_info->watch_id);
2558
2559                 ERR("ERR or HUP on RFCOMM socket");
2560                 INFO_C("Disconnected [AG role] [Terminated by remote dev]");
2561                 goto failed;
2562         }
2563
2564         fd = g_io_channel_unix_get_fd(channel);
2565         len = read(fd, event_buf, sizeof(event_buf) - 1);
2566
2567         if (len < 0)
2568                 return FALSE;
2569         available_buffer = sizeof(slconn->buffer) - (slconn->start) -
2570                                 (slconn->length) - 1;
2571         if (available_buffer < (size_t) len) {
2572                 ERR("Buffer over flow");
2573                 goto failed;
2574         }
2575
2576         memcpy(&slconn->buffer[slconn->start], event_buf, len);
2577         slconn->length += len;
2578
2579         slconn->buffer[slconn->start + slconn->length] = '\0';
2580
2581         while (slconn->length > 0) {
2582                 char *get_cr;
2583                 int err;
2584                 off_t cmd_len;
2585
2586                 get_cr = strchr(&slconn->buffer[slconn->start], '\r');
2587                 if (!get_cr)
2588                         break;
2589
2590                 cmd_len = 1 + (off_t) get_cr -
2591                         (off_t) &slconn->buffer[slconn->start];
2592                 *get_cr = '\0';
2593
2594                 if (cmd_len > 1) {
2595                         DBG("Call AT handler");
2596                         err = __bt_ag_at_handler(bt_ag_info,
2597                                         &slconn->buffer[slconn->start]);
2598                 } else {
2599                         ERR("Failed to call AT handler");
2600                         err = 0;
2601                 }
2602
2603                 if (err == -EINVAL) {
2604                         ERR("Unrecognized command: %s",
2605                                 &slconn->buffer[slconn->start]);
2606                         err = _bt_ag_send_response(bt_ag_info,
2607                                         HFP_STATE_MNGR_ERR_NOT_SUPPORTED);
2608                         if (err < 0)
2609                                 goto failed;
2610                 } else if (err < 0)
2611                         ERR("Error handling command %s: %s (%d)",
2612                                                 &slconn->buffer[slconn->start],
2613                                                 strerror(-err), -err);
2614
2615                 slconn->start += cmd_len;
2616                 slconn->length -= cmd_len;
2617
2618                 if (!slconn->length)
2619                         slconn->start = 0;
2620         }
2621         return TRUE;
2622 failed:
2623         ERR("Failed in event handler - SLC Disconnect");
2624         _bt_ag_set_headset_state(bt_ag_info,
2625                                         HEADSET_STATE_DISCONNECTED);
2626         return FALSE;
2627 }
2628
2629 static gboolean __bt_ag_agent_connection(gint32 fd, const gchar *device_path,
2630                                                 const gchar *object_path)
2631 {
2632         GIOFlags flags;
2633
2634         bt_ag_info_t *bt_ag_info = g_new0(bt_ag_info_t, 1);
2635         struct sockaddr_remote address;
2636         socklen_t address_len;
2637
2638         INFO_C("Connected [AG role]");
2639         bt_ag_info->rfcomm = NULL;
2640         bt_ag_info->slc = NULL;
2641         bt_ag_info->hfp_active = TRUE;
2642         bt_ag_info->vr_blacklisted = FALSE;
2643         bt_ag_info->state = HEADSET_STATE_DISCONNECTED;
2644         bt_ag_info->sco_server_started = FALSE;
2645         __bt_ag_codec_negotiation_info_reset(bt_ag_info, TRUE);
2646
2647         bt_ag_info->path = device_path;
2648         DBG("device_path = [%s]", device_path);
2649
2650         address_len = sizeof(address);
2651         if (getpeername(fd, (struct sockaddr *) &address, &address_len) != 0)
2652                 ERR("BD_ADDR is NULL");
2653
2654         DBG("RFCOMM connection for HFP/HSP is completed. Fd = [%d]", fd);
2655         bt_ag_info->fd = fd;
2656         bt_ag_info->io_chan = g_io_channel_unix_new(bt_ag_info->fd);
2657         flags = g_io_channel_get_flags(bt_ag_info->io_chan);
2658
2659         flags &= ~G_IO_FLAG_NONBLOCK;
2660         flags &= G_IO_FLAG_MASK;
2661         g_io_channel_set_flags(bt_ag_info->io_chan, flags, NULL);
2662         g_io_channel_set_encoding(bt_ag_info->io_chan, NULL, NULL);
2663         g_io_channel_set_buffered(bt_ag_info->io_chan, FALSE);
2664
2665         bt_ag_info->rfcomm = g_io_channel_ref(bt_ag_info->io_chan);
2666
2667         bt_ag_info->remote_addr = g_malloc0(BT_ADDRESS_STRING_SIZE);
2668         __bt_convert_addr_type_to_rev_string(bt_ag_info->remote_addr,
2669                                                 address.remote_bdaddr.b);
2670
2671 #if defined(TIZEN_SUPPORT_DUAL_HF)
2672         bt_ag_info->is_companion_device =
2673                         __bt_ag_agent_is_companion_device(bt_ag_info->remote_addr);
2674 #endif
2675
2676         DBG("remote Device Address = [%s]", bt_ag_info->remote_addr);
2677
2678         if (g_strcmp0(object_path, BT_HS_AG_AGENT_OBJECT_PATH) == 0) {
2679                 DBG("HSP connection completed");
2680                 _bt_ag_set_headset_state(bt_ag_info,
2681                                                 HEADSET_STATE_CONNECTED);
2682         }
2683         else {
2684                 DBG("HFP connection connecting");
2685                 _bt_ag_set_headset_state(bt_ag_info,
2686                                                 HEADSET_STATE_CONNECTING);
2687         }
2688
2689         __bt_ag_agent_start_watch(bt_ag_info);
2690
2691         bt_ag_info->slc = g_new0(bt_ag_slconn_t, 1);
2692         bt_ag_info->slc->speaker_gain = 15;
2693         bt_ag_info->slc->microphone_gain = 15;
2694         bt_ag_info->slc->is_nrec = TRUE;
2695
2696         return TRUE;
2697 }
2698
2699 static gboolean __bt_ag_agent_is_device_vr_blacklisted(const char *lap_addr)
2700 {
2701         char *buffer;
2702         FILE *fp;
2703         long size;
2704         size_t result;
2705         char *token;
2706         char *saveptr;
2707
2708         fp = fopen(AGENT_VR_BLACKLIST_FILE, "r");
2709
2710         if (fp == NULL) {
2711                 ERR("Unable to open VR blacklist file");
2712                 return FALSE;
2713         }
2714
2715         fseek(fp, 0, SEEK_END);
2716         size = ftell(fp);
2717         if (size <= 0) {
2718                 ERR("size is not a positive number");
2719                 fclose(fp);
2720                 return FALSE;
2721         }
2722
2723         rewind(fp);
2724
2725         buffer = g_malloc0(sizeof(char) * size);
2726         if (buffer == NULL) {
2727                 ERR("g_malloc0 is failed");
2728                 fclose(fp);
2729                 return FALSE;
2730         }
2731         result = fread((char *)buffer, 1, size, fp);
2732         fclose(fp);
2733         if (result != size) {
2734                 ERR("Read Error");
2735                 g_free(buffer);
2736                 return FALSE;
2737         }
2738
2739         token= strtok_r(buffer, "=", &saveptr);
2740         if (token == NULL) {
2741                 g_free(buffer);
2742                 return FALSE;
2743         }
2744
2745         while ((token = strtok_r(NULL, ",", &saveptr))) {
2746                 if (strlen(token) > 8)
2747                         token[8] = '\0';
2748                 if (0 == g_strcmp0(token, lap_addr)) {
2749                         INFO("Voice Recognition blacklisted");
2750                         g_free(buffer);
2751                         return TRUE;
2752                 }
2753         }
2754         g_free(buffer);
2755         return FALSE;
2756 }
2757
2758 static gboolean __bt_sco_open_delay_timeout_cb(gpointer user_data)
2759 {
2760         bt_ag_info_t *bt_ag_info = (bt_ag_info_t *)user_data;
2761         sco_open_timer_id = 0;
2762         DBG("sco_open_request (%d)", sco_open_request);
2763
2764         if (sco_open_request && bt_ag_info->state == HEADSET_STATE_CONNECTED) {
2765                 bt_ag_slconn_t *slconn = bt_ag_info->slc;
2766
2767                 INFO("try to open SCO");
2768                 sco_open_request = FALSE;
2769
2770                 if ((ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION) &&
2771                                 (slconn && (slconn->hs_features &
2772                                         BT_HF_FEATURE_CODEC_NEGOTIATION))) {
2773                         switch (bt_ag_info->codec_info.final_codec) {
2774                         case BT_CVSD_CODEC_ID:
2775                                 __bt_ag_set_codec(bt_ag_info, "SetNbParameters");
2776                                 __bt_ag_sco_connect(bt_ag_info);
2777                                 break;
2778                         case BT_MSBC_CODEC_ID:
2779                                 __bt_ag_set_codec(bt_ag_info, "SetWbsParameters");
2780                                 __bt_ag_sco_connect(bt_ag_info);
2781                                 break;
2782                         default:
2783                                 __bt_hfp_codec_connection_setup(bt_ag_info, FALSE);
2784                                 break;
2785                         }
2786                 } else
2787                         __bt_ag_sco_connect(bt_ag_info);
2788         }
2789
2790         return FALSE;
2791 }
2792
2793 /*
2794 * Service level connection complete
2795 * indication and state management
2796 */
2797 void _bt_ag_slconn_complete(bt_ag_info_t *hs)
2798 {
2799         char lap_address[BT_LOWER_ADDRESS_LENGTH];
2800
2801         DBG("HFP Service Level Connection established\n");
2802
2803         /* Check device Voice Recognition blacklist status */
2804         g_strlcpy(lap_address, hs->remote_addr, sizeof(lap_address));
2805         hs->vr_blacklisted =
2806                 __bt_ag_agent_is_device_vr_blacklisted(lap_address);
2807
2808         if (sco_open_timer_id > 0) {
2809                 g_source_remove(sco_open_timer_id);
2810                 sco_open_timer_id = 0;
2811         }
2812
2813         sco_open_request = FALSE;
2814         sco_open_timer_id = g_timeout_add(BT_SCO_OPEN_DELAY_TIMER,
2815                                                 __bt_sco_open_delay_timeout_cb, hs);
2816
2817         _bt_ag_set_headset_state(hs, HEADSET_STATE_CONNECTED);
2818 }
2819
2820 static gboolean __bt_ag_agent_connection_release(bt_ag_info_t *hs)
2821 {
2822
2823         g_io_channel_shutdown(hs->io_chan, TRUE, NULL);
2824         g_io_channel_unref(hs->io_chan);
2825         hs->io_chan = NULL;
2826
2827         if (hs->sco) {
2828                 __bt_ag_close_sco(hs);
2829                 _bt_ag_set_headset_state(hs, HEADSET_STATE_CONNECTED);
2830                 hs->sco = NULL;
2831         }
2832         __bt_ag_agent_remove_watch(&hs->watch_id);
2833
2834         _bt_ag_set_headset_state(hs, HEADSET_STATE_DISCONNECTED);
2835         return TRUE;
2836 }
2837
2838 static GQuark __bt_ag_agent_error_quark(void)
2839 {
2840         FN_START;
2841
2842         static GQuark quark = 0;
2843         if (!quark)
2844                 quark = g_quark_from_static_string("ag-agent");
2845
2846         FN_END;
2847         return quark;
2848 }
2849
2850 static GError *__bt_ag_agent_set_error(bt_hfp_agent_error_t error)
2851 {
2852         FN_START;
2853         ERR("error[%d]\n", error);
2854
2855         switch (error) {
2856         case BT_HFP_AGENT_ERROR_NOT_AVAILABLE:
2857                 return g_error_new(BT_AG_AGENT_ERROR, error,
2858                                         BT_ERROR_NOT_AVAILABLE);
2859         case BT_HFP_AGENT_ERROR_NOT_CONNECTED:
2860         return g_error_new(BT_AG_AGENT_ERROR, error,
2861                                         BT_ERROR_NOT_CONNECTED);
2862         case BT_HFP_AGENT_ERROR_BUSY:
2863                 return g_error_new(BT_AG_AGENT_ERROR, error,
2864                                                 BT_ERROR_BUSY);
2865         case BT_HFP_AGENT_ERROR_INVALID_PARAM:
2866                 return g_error_new(BT_AG_AGENT_ERROR, error,
2867                                                 BT_ERROR_INVALID_PARAM);
2868         case BT_HFP_AGENT_ERROR_ALREADY_EXSIST:
2869                 return g_error_new(BT_AG_AGENT_ERROR, error,
2870                                                 BT_ERROR_ALREADY_EXSIST);
2871         case BT_HFP_AGENT_ERROR_ALREADY_CONNECTED:
2872                 return g_error_new(BT_AG_AGENT_ERROR, error,
2873                                                 BT_ERROR_ALREADY_CONNECTED);
2874         case BT_HFP_AGENT_ERROR_NO_MEMORY:
2875                 return g_error_new(BT_AG_AGENT_ERROR, error,
2876                                                 BT_ERROR_NO_MEMORY);
2877         case BT_HFP_AGENT_ERROR_I_O_ERROR:
2878                 return g_error_new(BT_AG_AGENT_ERROR, error,
2879                                                 BT_ERROR_I_O_ERROR);
2880         case BT_HFP_AGENT_ERROR_OPERATION_NOT_AVAILABLE:
2881                 return g_error_new(BT_AG_AGENT_ERROR, error,
2882                                         BT_ERROR_OPERATION_NOT_AVAILABLE);
2883         case BT_HFP_AGENT_ERROR_BATTERY_STATUS:
2884                 return g_error_new(BT_AG_AGENT_ERROR, error,
2885                                         BT_ERROR_BATTERY);
2886         case BT_HFP_AGENT_ERROR_SIGNAL_STATUS:
2887                 return g_error_new(BT_AG_AGENT_ERROR, error,
2888                                         BT_ERROR_SIGNAL);
2889         case BT_HFP_AGENT_ERROR_NO_CALL_LOGS:
2890                 return g_error_new(BT_AG_AGENT_ERROR, error,
2891                                         BT_ERROR_NO_CALL_LOG);
2892         case BT_HFP_AGENT_ERROR_INTERNAL:
2893         default:
2894                 return g_error_new(BT_AG_AGENT_ERROR, error,
2895                                                 BT_ERROR_INTERNAL);
2896         }
2897         FN_END;
2898 }
2899
2900 static bt_ag_info_t *__bt_get_active_headset(const gchar *device_path)
2901 {
2902         GSList *l;
2903
2904         for (l = active_devices ; l; l = l->next) {
2905                 bt_ag_info_t *data = l->data;
2906                 if (device_path == NULL) /*just to avoid crash incase of "play" when dailed from device[NEEDS TO BE CHANGED]*/
2907                         return data;
2908                 if (g_strcmp0(data->path, device_path) == 0) {
2909                         INFO("Active device found");
2910                         return data;
2911                 }
2912         }
2913
2914         INFO("Active device not found");
2915         return NULL;
2916 }
2917
2918 static void __bt_ag_agent_method(GDBusConnection *connection,
2919                         const gchar *sender,
2920                         const gchar *object_path,
2921                         const gchar *interface_name,
2922                         const gchar *method_name,
2923                         GVariant *parameters,
2924                         GDBusMethodInvocation *invocation,
2925                         gpointer user_data)
2926 {
2927         FN_START;
2928
2929         INFO("method %s", method_name);
2930         INFO("object_path %s", object_path);
2931         int ret = BT_HFP_AGENT_ERROR_NONE;
2932         GError *err = NULL;
2933         const gchar *device_path = NULL;
2934
2935         if (g_strcmp0(method_name, "NewConnection") == 0) {
2936                 gint32 fd;
2937                 int index = 0;
2938                 GDBusMessage *msg;
2939                 GUnixFDList *fd_list;
2940                 GVariant *options = NULL;
2941                 int device_count = 0;
2942                 GSList *l;
2943
2944                 device_count = g_slist_length(active_devices);
2945
2946                 INFO("device_count %d", device_count);
2947
2948                 if (device_count >= MAX_CONNECTED_DEVICES) {
2949                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2950                         goto fail;
2951                 }
2952
2953                 g_variant_get(parameters, "(oha{sv})",
2954                                                 &device_path, &index, &options);
2955 #if defined(TIZEN_SUPPORT_DUAL_HF)
2956                 if (device_count &&
2957                         __bt_ag_agent_check_dual_hf_condition(device_path) == FALSE) {
2958                         INFO("not allow to connect 2nd HF connection");
2959                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2960                         goto fail;
2961                 }
2962 #endif
2963                 msg = g_dbus_method_invocation_get_message(invocation);
2964                 fd_list = g_dbus_message_get_unix_fd_list(msg);
2965                 if (fd_list == NULL) {
2966                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2967                         goto fail;
2968                 }
2969
2970                 fd = g_unix_fd_list_get(fd_list, index, NULL);
2971                 if (fd == -1) {
2972                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2973                         goto fail;
2974                 }
2975
2976                 DBG("FD is = [%d], device_path = [%s]\n", fd, device_path);
2977
2978                 if (!__bt_ag_agent_connection(fd, device_path, object_path)) {
2979                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2980                         goto fail;
2981                 }
2982
2983                 g_dbus_method_invocation_return_value(invocation, NULL);
2984         } else if (g_strcmp0(method_name, "RequestDisconnection") == 0) {
2985                 GSList *l;
2986
2987                 g_variant_get(parameters, "(o)", &device_path);
2988                 INFO("device_path %s", device_path);
2989
2990                 for (l = active_devices; l; l = l->next) {
2991                         bt_ag_info_t *data = l->data;
2992
2993                         INFO("data->path %s", data->path);
2994                         if (g_strcmp0(data->path, device_path) == 0) {
2995                                 if (!__bt_ag_agent_connection_release(data)) {
2996                                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
2997                                         goto fail;
2998                                 }
2999                                 INFO_C("Disconnected [AG role] [Terminated by local host]");
3000                                 g_dbus_method_invocation_return_value(invocation, NULL);
3001                         }
3002                 }
3003         } else if (g_strcmp0(method_name, "RegisterApplication") == 0) {
3004                 gchar *path = NULL;
3005                 gchar *address = NULL;
3006                 g_variant_get(parameters, "(&s&s)", &path, &address);
3007                 /*local_addr = malloc(strlen(address));
3008                 memcpy(local_addr, address, strlen(address));*/
3009
3010                 DBG("Sender = %s, Application path = %s\n", sender, path);
3011                 ret = _bt_hfp_register_telephony_agent(TRUE, path, sender);
3012                 if (ret)
3013                         goto fail;
3014
3015                 if (local_addr)
3016                         g_free(local_addr);
3017
3018                 local_addr = g_strdup(address);
3019                 DBG("Address = %s\n", local_addr);
3020                 g_dbus_method_invocation_return_value(invocation, NULL);
3021         } else if (g_strcmp0(method_name, "UnregisterApplication") == 0) {
3022                 gchar *path = NULL;
3023                 g_variant_get(parameters, "(&s)", &path);
3024
3025                 DBG("Application path = %s\n", path);
3026                 DBG("Sender = %s\n", sender);
3027
3028                 ret = _bt_hfp_register_telephony_agent(FALSE, path, sender);
3029                 if (ret)
3030                         goto fail;
3031
3032                 g_dbus_method_invocation_return_value(invocation, NULL);
3033         } else if (g_strcmp0(method_name, "IncomingCall") == 0) {
3034                 gchar *path = NULL;
3035                 gchar *number = NULL;
3036                 gint call_id = 0;
3037
3038                 g_variant_get(parameters, "(&s&si)", &path, &number, &call_id);
3039
3040                 DBG("Application path = %s", path);
3041                 DBG_SECURE("Phone number = %s", number);
3042                 DBG("Call id = %d", call_id);
3043
3044                 DBG("Sender = %s", sender);
3045
3046                 ret = _bt_hfp_incoming_call(path, number, call_id, sender);
3047                 if (ret)
3048                         goto fail;
3049                 g_dbus_method_invocation_return_value(invocation, NULL);
3050         } else if (g_strcmp0(method_name, "OutgoingCall") == 0) {
3051                 gchar *path = NULL;
3052                 gchar *number = NULL;
3053                 gint call_id = 0;
3054
3055                 g_variant_get(parameters, "(&s&si)", &path, &number, &call_id);
3056
3057                 DBG("Application path = %s", path);
3058                 DBG_SECURE("Phone number = %s", number);
3059                 DBG("Call id = %d", call_id);
3060
3061                 DBG("Sender = %s", sender);
3062
3063                 ret = _bt_hfp_outgoing_call(path, number, call_id, sender);
3064                 if (ret)
3065                         goto fail;
3066                 g_dbus_method_invocation_return_value(invocation, NULL);
3067         } else if (g_strcmp0(method_name, "ChangeCallStatus") == 0) {
3068                 gchar *path = NULL;
3069                 gchar *number = NULL;
3070                 gint status = 0;
3071                 gint call_id = 0;
3072                 GSList *l;
3073
3074                 g_variant_get(parameters, "(&s&sii)",
3075                                         &path, &number, &status, &call_id);
3076                 DBG("Application path = %s\n", path);
3077                 DBG_SECURE("Number = %s\n", number);
3078                 DBG("Status = %d\n", status);
3079                 DBG("Call id = %d\n", call_id);
3080                 DBG("Sender = %s\n", sender);
3081
3082                 ret = _bt_hfp_change_call_status(path,
3083                                         number, status, call_id, sender);
3084
3085                 if (_bt_hfp_is_call_exist() == FALSE) {
3086                         for (l = active_devices; l; l = l->next) {
3087                                 bt_ag_info_t *data = l->data;
3088
3089                                 if(data->state == HEADSET_STATE_ON_CALL) {
3090                                         __bt_ag_close_sco(data);
3091                                         _bt_ag_set_headset_state(data,
3092                                                 HEADSET_STATE_CONNECTED);
3093                                 }
3094                         }
3095                 }
3096
3097                 if (ret)
3098                         goto fail;
3099                 g_dbus_method_invocation_return_value(invocation, NULL);
3100         } else if (g_strcmp0(method_name, "GetProperties") == 0) {
3101                 GVariantBuilder *builder;
3102                 GVariant *var_data;
3103                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3104
3105                 if (bt_ag_info) {
3106                         gchar *codec = g_strdup("codec");
3107                         gchar *nrec = g_strdup("nrec");
3108
3109                         builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
3110
3111                         g_variant_builder_add(builder, "{sv}",
3112                                         codec, g_variant_new("u", bt_ag_info->codec_info.final_codec));
3113                         g_variant_builder_add(builder, "{sv}",
3114                                         nrec, g_variant_new("b", bt_ag_info->nrec_status));
3115
3116                         var_data = g_variant_new("(a{sv})", builder);
3117                         g_variant_builder_unref(builder);
3118                         g_dbus_method_invocation_return_value(invocation, var_data);
3119
3120                         g_free(codec);
3121                         g_free(nrec);
3122                 }
3123         } else if (g_strcmp0(method_name, "Disconnect") == 0) {
3124                 char hdset_address[18] = { 0, };
3125                 GSList *l;
3126
3127                 for (l = active_devices; l; l = l->next) {
3128                         bt_ag_info_t *data = l->data;
3129
3130                         __bt_convert_addr_type_to_rev_string(hdset_address,
3131                                         (unsigned char *)data->remote_addr);
3132
3133                         DBG("Disconnect Headset %s, %s\n",
3134                                                 hdset_address, data->path);
3135                         _bt_ag_set_headset_state(data,
3136                                                 HEADSET_STATE_DISCONNECTED);
3137                 }
3138                 g_dbus_method_invocation_return_value(invocation, NULL);
3139         } else if (g_strcmp0(method_name, "IsConnected") == 0) {
3140                 gboolean is_connected = FALSE;
3141                 GSList *l;
3142
3143                 for (l = active_devices; l; l = l->next) {
3144                         bt_ag_info_t *data = l->data;
3145
3146                         if(data->state == HEADSET_STATE_CONNECTED)
3147                                 is_connected = TRUE;
3148                 }
3149                 DBG("is_connected : %s",
3150                                 is_connected ? "Connected":"Disconnected");
3151
3152                 g_dbus_method_invocation_return_value(invocation,
3153                                 g_variant_new("(b)", is_connected));
3154         } else if (g_strcmp0(method_name, "IndicateCall") == 0) {
3155                 GSList *l;
3156
3157                 if (0 == g_slist_length(active_devices)) {
3158                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3159                         goto fail;
3160                 }
3161
3162                 if (ag.ring_timer) {
3163                         DBG("IndicateCall received when already indicating");
3164                         g_dbus_method_invocation_return_value(invocation, NULL);
3165                 }
3166
3167                 for (l = active_devices; l; l = l->next) {
3168                         bt_ag_info_t *data = l->data;
3169
3170                         if(data->state >= HEADSET_STATE_CONNECTED)
3171                                 _bt_ag_send_at(data, "\r\nRING\r\n");
3172                 }
3173
3174                 __bt_ring_timer_cb(NULL);
3175                 ag.ring_timer = g_timeout_add(AG_RING_INTERVAL,
3176                                 __bt_ring_timer_cb, NULL);
3177                 g_dbus_method_invocation_return_value(invocation, NULL);
3178         } else if (g_strcmp0(method_name, "CancelCall") == 0) {
3179                 if (0 == g_slist_length(active_devices)) {
3180                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3181                         goto fail;
3182                 }
3183
3184                 if (ag.ring_timer) {
3185                         g_source_remove(ag.ring_timer);
3186                         ag.ring_timer = 0;
3187                 } else
3188                         DBG("Got CancelCall method call but no call is active");
3189
3190                 g_dbus_method_invocation_return_value(invocation, NULL);
3191         } else if (g_strcmp0(method_name, "Play") == 0) {
3192                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3193                 bt_ag_slconn_t *slconn = NULL;
3194
3195                 if (bt_ag_info) {
3196                         slconn = bt_ag_info->slc;
3197                 } else {
3198                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3199                         goto fail;
3200                 }
3201
3202 #ifndef __TIZEN_OPEN__
3203 #ifdef MDM_PHASE_2
3204                 int mode;
3205                 if ( slconn && FALSE == slconn->is_voice_recognition_running &&
3206                                 mdm_get_service() == MDM_RESULT_SUCCESS) {
3207                         mode = mdm_get_allow_bluetooth_outgoing_call();
3208                         mdm_release_service();
3209
3210                         if (mode == MDM_RESTRICTED) {
3211                                 ERR("[MDM] Not allow the outgoing call");
3212                                 ret = BT_HFP_AGENT_ERROR_OPERATION_NOT_AVAILABLE;
3213                                 goto fail;
3214                         }
3215                 }
3216 #endif
3217 #endif
3218
3219                 switch (bt_ag_info->state) {
3220                 case HEADSET_STATE_CONNECTING:
3221                 case HEADSET_STATE_DISCONNECTED:
3222                         ERR("HEADSET_STATE  ERROR");
3223                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3224                         break;
3225                 case HEADSET_STATE_CONNECTED:
3226                         break;
3227                 case HEADSET_STATE_PLAY_IN_PROGRESS:
3228                         ERR("Play In Progress");
3229                         ret = BT_HFP_AGENT_ERROR_BUSY;
3230                         break;
3231                 default:
3232                         break;
3233                 }
3234                 if (ret)
3235                         goto fail;
3236
3237                 if (sco_open_timer_id > 0) {
3238                         INFO("SCO open delay");
3239                         sco_open_request = TRUE;
3240                         g_dbus_method_invocation_return_value(invocation, NULL);
3241                         return;
3242                 }
3243
3244                 if ((ag.features & BT_AG_FEATURE_CODEC_NEGOTIATION) &&
3245                                 (slconn && (slconn->hs_features &
3246                                         BT_HF_FEATURE_CODEC_NEGOTIATION))) {
3247                         switch (bt_ag_info->codec_info.final_codec) {
3248                         case BT_CVSD_CODEC_ID:
3249                                 __bt_ag_set_codec(bt_ag_info, "SetNbParameters");
3250                                 ret = __bt_ag_sco_connect(bt_ag_info);
3251                                 break;
3252                         case BT_MSBC_CODEC_ID:
3253                                 __bt_ag_set_codec(bt_ag_info, "SetWbsParameters");
3254                                 ret = __bt_ag_sco_connect(bt_ag_info);
3255                                 break;
3256                         default:
3257                                 ret = __bt_hfp_codec_connection_setup(bt_ag_info, FALSE);
3258                                 break;
3259                         }
3260                 } else
3261                         ret = __bt_ag_sco_connect(bt_ag_info);
3262
3263                 if (ret)
3264                         goto fail;
3265
3266                 g_free(sco_owner);
3267                 sco_owner = g_strdup(sender);
3268
3269                 g_dbus_method_invocation_return_value(invocation, NULL);
3270
3271                 name_owner_sig_id = g_dbus_connection_signal_subscribe(ag_dbus_conn,
3272                                         NULL, NULL, "NameOwnerChanged", NULL, NULL, 0,
3273                                         __bt_ag_name_owner_changed_cb, NULL, NULL);
3274         } else if (g_strcmp0(method_name, "Stop") == 0) {
3275                 GSList *l;
3276
3277                 for (l = active_devices; l; l = l->next) {
3278                         bt_ag_info_t *data = l->data;
3279
3280                         if(data->state > HEADSET_STATE_CONNECTED) {
3281                                 __bt_ag_close_sco(data);
3282                                 _bt_ag_set_headset_state(data,
3283                                         HEADSET_STATE_CONNECTED);
3284                         }
3285                 }
3286
3287                 g_dbus_method_invocation_return_value(invocation, NULL);
3288         } else if (g_strcmp0(method_name, "IsPlaying") == 0) {
3289                 gboolean is_playing = FALSE;
3290                 GSList *l;
3291
3292                 for (l = active_devices; l; l = l->next) {
3293                         bt_ag_info_t *data = l->data;
3294
3295                         if(data->state == HEADSET_STATE_ON_CALL)
3296                                 is_playing = TRUE;
3297                 }
3298                 DBG("is_playing : %s", is_playing ? "Playing":"Not Playing");
3299
3300                 g_dbus_method_invocation_return_value(invocation,
3301                                 g_variant_new("(b)", is_playing));
3302         } else if (g_strcmp0(method_name, "GetSpeakerGain") == 0) {
3303                 bt_ag_slconn_t *slconn = NULL;
3304                 guint16 gain_value = 0;
3305                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3306
3307                 if (bt_ag_info == NULL) {
3308                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3309                         goto fail;
3310                 }
3311
3312                 if (bt_ag_info->state < HEADSET_STATE_CONNECTED) {
3313                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3314                         goto fail;
3315                 }
3316
3317                 slconn = bt_ag_info->slc;
3318                 if (slconn)
3319                         gain_value = (guint16) slconn->speaker_gain;
3320
3321                 g_dbus_method_invocation_return_value(invocation,
3322                                 g_variant_new("(q)", gain_value));
3323         } else if (g_strcmp0(method_name, "SetSpeakerGain") == 0) {
3324                 guint16 gain = 0;
3325                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3326
3327                 g_variant_get(parameters, "(q)", &gain);
3328                 DBG("Speaker gain = %d\n", gain);
3329
3330                 if (bt_ag_info == NULL) {
3331                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3332                         goto fail;
3333                 }
3334
3335                 ret = _bt_hfp_set_speaker_gain(bt_ag_info, gain);
3336                 if (ret)
3337                         goto fail;
3338                 g_dbus_method_invocation_return_value(invocation, NULL);
3339         } else if (g_strcmp0(method_name, "GetMicrophoneGain") == 0) {
3340                 bt_ag_slconn_t *slconn = NULL;
3341                 guint16 gain_value = 0;
3342                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3343
3344                 if (bt_ag_info == NULL) {
3345                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3346                         goto fail;
3347                 }
3348
3349                 if (bt_ag_info->state < HEADSET_STATE_CONNECTED) {
3350                         ret = BT_HFP_AGENT_ERROR_NOT_CONNECTED;
3351                         goto fail;
3352                 }
3353
3354                 slconn = bt_ag_info->slc;
3355                 if (slconn)
3356                         gain_value = (guint16) slconn->microphone_gain;
3357
3358                 g_dbus_method_invocation_return_value(invocation,
3359                                 g_variant_new("(q)", gain_value));
3360         } else if (g_strcmp0(method_name, "SetMicrophoneGain") == 0) {
3361                 guint16 gain = 0;
3362                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3363
3364                 g_variant_get(parameters, "(q)", &gain);
3365                 DBG("Microphone gain = %d\n", gain);
3366
3367                 if (bt_ag_info == NULL) {
3368                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3369                         goto fail;
3370                 }
3371
3372                 ret = _bt_hfp_set_microphone_gain(bt_ag_info, gain);
3373                 if (ret)
3374                         goto fail;
3375                 g_dbus_method_invocation_return_value(invocation, NULL);
3376         } else if (g_strcmp0(method_name, "SetVoiceDial") == 0) {
3377                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3378                 if (bt_ag_info == NULL) {
3379                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3380                         goto fail;
3381                 }
3382
3383                 bt_ag_slconn_t *slconn = bt_ag_info->slc;
3384                 gboolean enable;
3385
3386                 g_variant_get(parameters, "(b)", &enable);
3387                 DBG("VoiceDail enable = %d\n", enable);
3388
3389                 if ((slconn && !(slconn->hs_features &
3390                                         BT_HF_FEATURE_VOICE_RECOGNITION)))
3391                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
3392                 else if (bt_ag_info->vr_blacklisted)
3393                         ret = BT_HFP_AGENT_ERROR_INTERNAL;
3394                 else
3395                         ret = _bt_hfp_set_voice_dial(bt_ag_info, enable);
3396
3397                 if (slconn)
3398                         slconn->is_voice_recognition_running = enable;
3399
3400                 if (ret)
3401                         goto fail;
3402                 g_dbus_method_invocation_return_value(invocation, NULL);
3403         } else if (g_strcmp0(method_name, "SendVendorAtCmd") == 0) {
3404                 gchar *cmd;
3405                 bt_ag_info_t *bt_ag_info = __bt_get_active_headset(remote_dev_path);
3406                 if (bt_ag_info == NULL) {
3407                         ret = BT_HFP_AGENT_ERROR_NOT_AVAILABLE;
3408                         goto fail;
3409                 }
3410
3411                 g_variant_get(parameters, "(&s)", &cmd);
3412                 if (cmd == NULL){
3413                         ret = BT_HFP_AGENT_ERROR_INVALID_PARAM;
3414                         goto fail;
3415                 }
3416
3417                 DBG("vendor cmd = %s", cmd);
3418
3419                 ret = _bt_hfp_send_vendor_cmd(bt_ag_info, cmd);
3420                 if (ret)
3421                         goto fail;
3422                 g_dbus_method_invocation_return_value(invocation, NULL);
3423         } else if (g_strcmp0(method_name, "CheckPrivilege") == 0) {
3424                 DBG("Already pass dbus SMACK for bt-service::platform");
3425                 /* Return success */
3426                 g_dbus_method_invocation_return_value(invocation, NULL);
3427         }
3428
3429         INFO("-");
3430         return;
3431
3432 fail:
3433         err = __bt_ag_agent_set_error(ret);
3434         g_dbus_method_invocation_return_gerror(invocation, err);
3435         g_error_free(err);
3436         INFO("-");
3437 }
3438
3439 static const GDBusInterfaceVTable method_table = {
3440         __bt_ag_agent_method,
3441         NULL,
3442         NULL,
3443 };
3444
3445 static GDBusNodeInfo *__bt_ag_create_method_node_info
3446                                         (const gchar *introspection_data)
3447 {
3448         GError *err = NULL;
3449         GDBusNodeInfo *node_info = NULL;
3450
3451         if (introspection_data == NULL)
3452                 return NULL;
3453
3454         node_info = g_dbus_node_info_new_for_xml(introspection_data, &err);
3455
3456         if (err) {
3457                 ERR("Unable to create node: %s", err->message);
3458                 g_clear_error(&err);
3459         }
3460         return node_info;
3461 }
3462
3463 static GDBusConnection *__bt_ag_get_gdbus_connection(void)
3464 {
3465         FN_START;
3466
3467         GError *err = NULL;
3468
3469         if (ag_dbus_conn == NULL)
3470                 ag_dbus_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &err);
3471
3472         if (!ag_dbus_conn) {
3473                 if (err) {
3474                         ERR("Unable to connect to dbus: %s", err->message);
3475                         g_clear_error(&err);
3476                 }
3477                 return NULL;
3478         }
3479         FN_END;
3480
3481         return ag_dbus_conn;
3482 }
3483
3484 static gboolean __bt_ag_register_profile_methods(void)
3485 {
3486         FN_START;
3487         GError *error = NULL;
3488         guint owner_id;
3489         GDBusNodeInfo *node_info;
3490         gchar *path;
3491
3492         owner_id = g_bus_own_name(G_BUS_TYPE_SYSTEM,
3493                                 BT_AG_SERVICE_NAME,
3494                                 G_BUS_NAME_OWNER_FLAGS_NONE,
3495                                 NULL, NULL, NULL,
3496                                 NULL, NULL);
3497
3498         DBG("owner_id is [%d]", owner_id);
3499
3500         node_info = __bt_ag_create_method_node_info(
3501                                 ag_agent_bluez_introspection_xml);
3502         if (node_info == NULL)
3503                 return FALSE;
3504
3505         path = g_strdup(BT_AG_AGENT_OBJECT_PATH);
3506         DBG("path is [%s]", path);
3507
3508         hf_bluez_id = g_dbus_connection_register_object(ag_dbus_conn, path,
3509                                         node_info->interfaces[0],
3510                                         &method_table,
3511                                         NULL, NULL, &error);
3512         if (hf_bluez_id == 0) {
3513                 ERR("Failed to register: %s", error->message);
3514                 g_error_free(error);
3515                 g_free(path);
3516                 return FALSE;
3517         }
3518         g_free(path);
3519
3520         /* Ag register profile methods for HSP*/
3521
3522         path = g_strdup(BT_HS_AG_AGENT_OBJECT_PATH);
3523         DBG("path is [%s]", path);
3524
3525         hs_bluez_id = g_dbus_connection_register_object(ag_dbus_conn, path,
3526                                         node_info->interfaces[0],
3527                                         &method_table,
3528                                         NULL, NULL, &error);
3529         if (hs_bluez_id == 0) {
3530                 ERR("Failed to register: %s", error->message);
3531                 g_error_free(error);
3532                 g_free(path);
3533                 return FALSE;
3534         }
3535         g_free(path);
3536
3537         node_info = __bt_ag_create_method_node_info
3538                                 (ag_agent_app_introspection_xml);
3539         if (node_info == NULL)
3540                 return FALSE;
3541
3542         path = g_strdup(BT_AG_AGENT_OBJECT_PATH);
3543         DBG("path is [%s]", path);
3544
3545         app_id = g_dbus_connection_register_object(ag_dbus_conn, path,
3546                                                 node_info->interfaces[0],
3547                                                 &method_table,
3548                                                 NULL, NULL, &error);
3549         if (app_id == 0) {
3550                 ERR("Failed to register: %s", error->message);
3551                 g_error_free(error);
3552                 g_free(path);
3553                 return FALSE;
3554         }
3555         g_free(path);
3556
3557         FN_END;
3558         return TRUE;
3559 }
3560
3561 static void __bt_ag_unregister_profile_methods(void)
3562 {
3563         DBG("");
3564
3565         if (hf_bluez_id > 0) {
3566                 g_dbus_connection_unregister_object(ag_dbus_conn,
3567                                                         hf_bluez_id);
3568                 hf_bluez_id = 0;
3569         }
3570
3571         if (hs_bluez_id > 0) {
3572                 g_dbus_connection_unregister_object(ag_dbus_conn,
3573                                                         hs_bluez_id);
3574                 hs_bluez_id = 0;
3575         }
3576
3577         if (app_id > 0) {
3578                 g_dbus_connection_unregister_object(ag_dbus_conn,
3579                                                         app_id);
3580                 app_id = 0;
3581         }
3582 }
3583
3584 static GDBusProxy *__bt_ag_gdbus_get_service_proxy(const gchar *service,
3585                                 const gchar *path, const gchar *interface)
3586 {
3587         return (service_gproxy) ? service_gproxy :
3588                         __bt_ag_gdbus_init_service_proxy(service,
3589                                         path, interface);
3590 }
3591
3592 static void __bt_ag_agent_register(gchar *path, uint16_t profile_version,
3593                                 char *profile_uuid, const char* profile_name)
3594 {
3595         FN_START;
3596         GDBusProxy *proxy;
3597         GVariant *ret;
3598         GError *error = NULL;
3599         GVariantBuilder *builder;
3600
3601         proxy = __bt_ag_gdbus_get_service_proxy(BLUEZ_SERVICE_NAME,
3602                 "/org/bluez", BLUEZ_PROFILE_MGMT_INTERFACE);
3603         if (proxy == NULL)
3604                 return;
3605
3606
3607         builder = g_variant_builder_new(G_VARIANT_TYPE("a{sv}"));
3608
3609         g_variant_builder_add(builder, "{sv}",
3610                         "Name", g_variant_new("s",
3611                         profile_name));
3612         g_variant_builder_add(builder, "{sv}",
3613                         "Version", g_variant_new("q", profile_version));
3614         /*g_variant_builder_add(builder, "{sv}",
3615                         "Role", g_variant_new("s","client"));*/
3616         if (g_strcmp0(path, BT_AG_AGENT_OBJECT_PATH) == 0) {
3617                 g_variant_builder_add(builder, "{sv}",
3618                                 "features", g_variant_new("q", ag.sdp_features));
3619         }
3620
3621         ret = g_dbus_proxy_call_sync(proxy, "RegisterProfile",
3622                                         g_variant_new("(osa{sv})", path,
3623                                                         profile_uuid, builder),
3624                                         G_DBUS_CALL_FLAGS_NONE, -1,
3625                                         NULL, &error);
3626         g_variant_builder_unref(builder);
3627         /* set the name and role for the profile*/
3628         if (ret == NULL) {
3629                 /* dBUS-RPC is failed */
3630                 ERR("dBUS-RPC is failed");
3631
3632                 if (error != NULL) {
3633                         /* dBUS gives error cause */
3634                         ERR("D-Bus API failure: errCode[%x], message[%s]",
3635                                         error->code, error->message);
3636
3637                         g_clear_error(&error);
3638                 }
3639                 g_free(path);
3640                 return;
3641         }
3642         g_variant_unref(ret);
3643         g_free(path);
3644
3645         FN_END;
3646         return;
3647 }
3648
3649 static void __bt_ag_agent_unregister(gchar *path)
3650 {
3651         FN_START;
3652         GDBusProxy *proxy;
3653         GVariant *ret;
3654         GError *error = NULL;
3655
3656         proxy = __bt_ag_gdbus_get_service_proxy(BLUEZ_SERVICE_NAME,
3657                 "/org/bluez", BLUEZ_PROFILE_MGMT_INTERFACE);
3658         if (proxy == NULL)
3659                 return;
3660
3661
3662         ret = g_dbus_proxy_call_sync(proxy, "UnregisterProfile",
3663                                         g_variant_new("(o)", path),
3664                                         G_DBUS_CALL_FLAGS_NONE, -1,
3665                                         NULL, &error);
3666         g_free(path);
3667         /* set the name and role for the profile*/
3668         if (ret == NULL) {
3669                 /* dBUS-RPC is failed */
3670                 ERR("dBUS-RPC is failed");
3671
3672                 if (error != NULL) {
3673                         /* dBUS gives error cause */
3674                         ERR("D-Bus API failure: errCode[%x], message[%s]",
3675                                         error->code, error->message);
3676
3677                         g_clear_error(&error);
3678                 }
3679                 return;
3680         }
3681         g_variant_unref(ret);
3682
3683         if (local_addr) {
3684                 g_free(local_addr);
3685                 local_addr = NULL;
3686         }
3687         FN_END;
3688         return;
3689 }
3690
3691 static void __bt_ag_agent_battery_status_cb(keynode_t *node)
3692 {
3693         int batt = vconf_keynode_get_int(node);
3694
3695         _bt_hfp_set_property_value("BatteryBarsChanged", batt);
3696 }
3697
3698 static void __bt_ag_agent_network_signal_status_cb(keynode_t *node)
3699 {
3700         int signal_bar = vconf_keynode_get_int(node);
3701
3702         BT_CHECK_SIGNAL_STRENGTH(signal_bar);
3703         _bt_hfp_set_property_value("SignalBarsChanged", signal_bar);
3704 }
3705
3706 #ifdef TIZEN_SUPPORT_LUNAR_DEVICE
3707 static void __bt_ag_agent_lunar_connection_status_cb(keynode_t *node)
3708 {
3709         gboolean status = vconf_keynode_get_bool(node);
3710         GSList *l;
3711         DBG("status = %d", status);
3712
3713         if (status == TRUE) {
3714                 for (l = active_devices; l; l = l->next) {
3715                         bt_ag_info_t *data = l->data;
3716                         _bt_ag_send_at(data, "\r\n+BSIR:1\r\n");
3717                 }
3718         }
3719 }
3720 #endif
3721
3722 static void __bt_ag_agent_network_register_status_cb(keynode_t *node)
3723 {
3724         int service = vconf_keynode_get_int(node);
3725         bt_hfp_agent_network_registration_status_t network_service;
3726         int roam_status;
3727         int ret;
3728
3729         DBG("Current Signal Level = [%d] \n", service);
3730
3731         switch (service) {
3732         case VCONFKEY_TELEPHONY_SVCTYPE_NONE:
3733         case VCONFKEY_TELEPHONY_SVCTYPE_NOSVC:
3734         case VCONFKEY_TELEPHONY_SVCTYPE_SEARCH:
3735                 service = 0;
3736                 break;
3737         default:
3738                 service = 1;
3739                 break;
3740         }
3741
3742         ret = vconf_get_int(VCONFKEY_TELEPHONY_SVC_ROAM, &roam_status);
3743         if (ret != 0) {
3744                 ERR("Get roaming status failed err = %d\n", ret);
3745                 return;
3746         }
3747
3748         if (roam_status == 0 && service == 1)
3749                 network_service = BT_AGENT_NETWORK_REG_STATUS_HOME;
3750         else if (roam_status == 1 && service == 1)
3751                 network_service = BT_AGENT_NETWORK_REG_STATUS_ROAMING;
3752         else
3753                 network_service = BT_AGENT_NETWORK_REG_STATUS_UNKOWN;
3754
3755         _bt_hfp_set_property_value("RegistrationChanged", network_service);
3756 }
3757
3758 static void __bt_ag_agent_subscribe_vconf_updates(void)
3759 {
3760         int ret;
3761
3762         DBG("\n");
3763
3764         ret = vconf_notify_key_changed(VCONFKEY_SYSMAN_BATTERY_CAPACITY,
3765                                 (void *)__bt_ag_agent_battery_status_cb, NULL);
3766         if (0 != ret) {
3767                 ERR("Subsrciption to battery status failed err =  [%d]\n", ret);
3768         }
3769
3770         ret = vconf_notify_key_changed(VCONFKEY_TELEPHONY_RSSI,
3771                         (void *)__bt_ag_agent_network_signal_status_cb, NULL);
3772         if (0 != ret) {
3773                 ERR("Subsrciption to netowrk signal failed err =  [%d]\n", ret);
3774         }
3775
3776         ret = vconf_notify_key_changed(VCONFKEY_TELEPHONY_SVCTYPE,
3777                         (void *)__bt_ag_agent_network_register_status_cb, NULL);
3778         if (0 != ret) {
3779                 ERR("Subsrciption to network failed err =  [%d]\n", ret);
3780         }
3781 #ifdef TIZEN_SUPPORT_LUNAR_DEVICE
3782         ret = vconf_notify_key_changed(VCONF_KEY_BT_LUNAR_ENABLED,
3783                         (void *)__bt_ag_agent_lunar_connection_status_cb, NULL);
3784         if (0 != ret) {
3785                 ERR("Subsrciption to lunar connection failed err =  [%d]\n", ret);
3786         }
3787 #endif
3788 }
3789
3790 static void __bt_ag_agent_release_vconf_updates(void)
3791 {
3792         int ret;
3793
3794         DBG("\n");
3795
3796         ret = vconf_ignore_key_changed(VCONFKEY_SYSMAN_BATTERY_CAPACITY,
3797                         (vconf_callback_fn)__bt_ag_agent_battery_status_cb);
3798         if (0 != ret) {
3799                 ERR("vconf_ignore_key_changed failed\n");
3800         }
3801
3802         ret = vconf_ignore_key_changed(VCONFKEY_TELEPHONY_RSSI,
3803                 (vconf_callback_fn)__bt_ag_agent_network_signal_status_cb);
3804         if (0 != ret) {
3805                 ERR("vconf_ignore_key_changed failed\n");
3806         }
3807
3808         ret = vconf_ignore_key_changed(VCONFKEY_TELEPHONY_SVCTYPE,
3809                 (vconf_callback_fn)__bt_ag_agent_network_register_status_cb);
3810         if (0 != ret) {
3811                 ERR("vconf_ignore_key_changed failed\n");
3812         }
3813 }
3814
3815 static gboolean __bt_ag_agent_send_subscriber_number_changed(
3816                                                         const char *number)
3817 {
3818         const char *property = g_strdup("SubscriberNumberChanged");
3819
3820         FN_START;
3821
3822         DBG("Number is %s", number);
3823
3824         if (!_bt_hfp_set_property_name(property, number)) {
3825                 DBG("Error- set property for subscriber no change  - ERROR\n");
3826                 g_free((void *)property);
3827                 return FALSE;
3828         }
3829         g_free((void *)property);
3830         FN_END;
3831         return TRUE;
3832 }
3833 static void __bt_ag_agent_sigterm_handler(int signo)
3834 {
3835         int i;
3836         GSList *l;
3837
3838         ERR_C("***** Signal handler came with signal %d *****", signo);
3839
3840         for (l = active_devices ; l; l = l->next) {
3841                 bt_ag_info_t *data = l->data;
3842                 if (!__bt_ag_agent_connection_release(data))
3843                         ERR("__bt_ag_agent_connection_release failed");
3844         }
3845         if (ag_dbus_conn)
3846                 g_dbus_connection_flush(ag_dbus_conn, NULL, NULL, NULL);
3847
3848         if (gmain_loop) {
3849                 g_main_loop_quit(gmain_loop);
3850                 DBG("Exiting");
3851                 gmain_loop = NULL;
3852         } else {
3853                 INFO("Terminating AG agent");
3854                 exit(0);
3855         }
3856
3857         if (signo == SIGTERM)
3858                 return;
3859
3860         for (i = 0; i < BT_AG_SIG_NUM; i++)
3861                 sigaction(bt_ag_sig_to_handle[i], &(bt_ag_sigoldact[i]), NULL);
3862
3863         raise(signo);
3864 }
3865
3866 static void  __bt_ag_agent_tel_cb(TapiHandle *handle,
3867                                 int result,
3868                                 void *data,
3869                                 void *user_data)
3870 {
3871         TelSimMsisdnList_t *number;
3872         gchar *subscriber_number;
3873
3874         ERR("*********** result = %d", result);
3875
3876         if (result == TAPI_API_SIM_LOCKED ||
3877                 result == TAPI_API_SIM_NOT_INITIALIZED ||
3878                 result == TAPI_API_SERVICE_NOT_READY) {
3879                 DBG("initializing the tapi event for SIM status");
3880                 __bt_ag_agent_reg_sim_event(handle, user_data);
3881                 return;
3882         }
3883
3884         if (data == NULL)
3885                 return;
3886
3887         number = (TelSimMsisdnList_t *)data;
3888         subscriber_number = g_strdup(number->list[0].num);
3889         __bt_ag_agent_send_subscriber_number_changed(subscriber_number);
3890         g_free(subscriber_number);
3891 }
3892
3893 static void __bt_ag_agent_on_noti_sim_status (TapiHandle *handle,
3894                 const char *noti_id, void *data, void *user_data)
3895 {
3896         TelSimCardStatus_t *status = data;
3897         int tapi_result;
3898
3899         DBG("event TAPI_NOTI_SIM_STATUS received!! status[%d]", *status);
3900
3901         if (*status == TAPI_SIM_STATUS_SIM_INIT_COMPLETED) {
3902                 __bt_ag_agent_dereg_sim_event(handle);
3903                 tapi_result = tel_get_sim_msisdn(handle, __bt_ag_agent_tel_cb,
3904                                         user_data);
3905                 if (tapi_result != TAPI_API_SUCCESS)
3906                         ERR("Fail to get sim info: %d", tapi_result);
3907         }
3908 }
3909
3910 static void __bt_ag_agent_reg_sim_event (TapiHandle *handle, void *user_data)
3911 {
3912         int ret;
3913         ret = tel_register_noti_event(handle, TAPI_NOTI_SIM_STATUS,
3914                 __bt_ag_agent_on_noti_sim_status, user_data);
3915
3916         if (ret != TAPI_API_SUCCESS)
3917                 ERR("event register failed(%d)", ret);
3918 }
3919
3920 static void __bt_ag_agent_dereg_sim_event (TapiHandle *handle)
3921 {
3922         int ret;
3923         ret = tel_deregister_noti_event(handle, TAPI_NOTI_SIM_STATUS);
3924
3925         if (ret != TAPI_API_SUCCESS)
3926                 ERR("event deregister failed(%d)", ret);
3927 }
3928
3929 static void __bt_ag_name_owner_changed_cb(GDBusConnection *connection,
3930                                         const gchar *sender_name,
3931                                         const gchar *object_path,
3932                                         const gchar *interface_name,
3933                                         const gchar *signal_name,
3934                                         GVariant *parameters,
3935                                         gpointer user_data)
3936 {
3937         FN_START;
3938         char *name_owner = NULL;
3939         char *old_owner = NULL;
3940         char *new_owner = NULL;
3941
3942         if (strcasecmp(signal_name, "NameOwnerChanged") == 0) {
3943                 GSList *l;
3944
3945                 g_variant_get(parameters, "(sss)", &name_owner, &old_owner, &new_owner);
3946
3947                 _bt_hfp_release_all_calls_by_sender(name_owner);
3948
3949                 if (sco_owner == NULL)
3950                         return;
3951
3952                 if (strcasecmp(name_owner, sco_owner) == 0) {
3953                         if (name_owner_sig_id != -1)
3954                                 g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
3955                                                         name_owner_sig_id);
3956                         name_owner_sig_id = -1;
3957                         g_free(sco_owner);
3958                         sco_owner = NULL;
3959
3960                         for (l = active_devices ; l; l = l->next) {
3961                                 bt_ag_info_t *data = l->data;
3962
3963                                 if (data->sco) {
3964                                         __bt_ag_close_sco(data);
3965                                         _bt_ag_set_headset_state(data,
3966                                                 HEADSET_STATE_CONNECTED);
3967                                 }
3968                         }
3969                 }
3970         }
3971 }
3972
3973 static void __bt_ag_agent_filter_cb(GDBusConnection *connection,
3974                                         const gchar *sender_name,
3975                                         const gchar *object_path,
3976                                         const gchar *interface_name,
3977                                         const gchar *signal_name,
3978                                         GVariant *parameters,
3979                                         gpointer user_data)
3980 {
3981         FN_START;
3982         char *path = NULL;
3983         GVariant *optional_param;
3984
3985         if (strcasecmp(signal_name, "InterfacesAdded") == 0) {
3986
3987                 g_variant_get(parameters, "(&o@a{sa{sv}})",
3988                                                         &path, &optional_param);
3989                 if (!path) {
3990                         ERR("Invalid adapter path");
3991                         return;
3992                 }
3993
3994                 INFO("Adapter Path = [%s]", path);
3995                 if (strcasecmp(path, DEFAULT_ADAPTER_OBJECT_PATH) == 0) {
3996                         gchar *path = g_strdup(BT_AG_AGENT_OBJECT_PATH);
3997                         __bt_ag_agent_register(path, hfp_ver,
3998                                  HFP_AG_UUID, "Hands-Free Audio Gateway");
3999
4000                         path =  g_strdup(BT_HS_AG_AGENT_OBJECT_PATH);
4001                         __bt_ag_agent_register(path, hsp_ver,
4002                                 HSP_AG_UUID, "Headset Audio Gateway");
4003                 }
4004         } else if (strcasecmp(signal_name, "InterfacesRemoved") == 0) {
4005                 g_variant_get(parameters, "(&o@as)", &path, &optional_param);
4006                 if (!path) {
4007                         ERR("Invalid adapter path");
4008                         return;
4009                 }
4010
4011                 INFO("Adapter Path = [%s]", path);
4012                 if (strcasecmp(path, DEFAULT_ADAPTER_OBJECT_PATH) == 0) {
4013                         gchar *path = g_strdup(BT_AG_AGENT_OBJECT_PATH);
4014                         __bt_ag_agent_unregister(path);
4015
4016                         path =  g_strdup(BT_HS_AG_AGENT_OBJECT_PATH);
4017                         __bt_ag_agent_unregister(path);
4018                 }
4019         }
4020
4021         FN_END;
4022 }
4023
4024 static void __bt_ag_agent_dbus_deinit(void)
4025 {
4026
4027         if (service_gproxy) {
4028                 g_object_unref(service_gproxy);
4029                 service_gproxy = NULL;
4030         }
4031
4032         if (app_gproxy) {
4033                 g_object_unref(app_gproxy);
4034                 app_gproxy = NULL;
4035         }
4036
4037         if (ag_dbus_conn) {
4038                 __bt_ag_unregister_profile_methods();
4039
4040                 if (owner_sig_id != -1)
4041                         g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
4042                                                 owner_sig_id);
4043
4044                 if (name_owner_sig_id != -1)
4045                         g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
4046                                                 name_owner_sig_id);
4047 #ifdef TIZEN_MEDIA_ENHANCE
4048                 if (media_sig_id != -1)
4049                         g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
4050                                                 media_sig_id);
4051
4052                 if (media_state_sig_id != -1)
4053                         g_dbus_connection_signal_unsubscribe(ag_dbus_conn,
4054                                                 media_state_sig_id);
4055 #endif
4056                 name_owner_sig_id = -1;
4057                 g_free(sco_owner);
4058                 sco_owner = NULL;
4059
4060                 g_object_unref(ag_dbus_conn);
4061                 ag_dbus_conn= NULL;
4062         }
4063         return;
4064 }
4065
4066 static int __bt_ag_agent_get_adapter_path(GDBusConnection *conn, char *path)
4067 {
4068         GError *err = NULL;
4069         GDBusProxy *manager_proxy = NULL;
4070         GVariant *result = NULL;
4071         char *adapter_path = NULL;
4072
4073         if (conn == NULL)
4074                 return BT_HFP_AGENT_ERROR_INTERNAL;
4075
4076         manager_proxy =  g_dbus_proxy_new_sync(conn,
4077                         G_DBUS_PROXY_FLAGS_NONE, NULL,
4078                         BLUEZ_SERVICE_NAME,
4079                         "/",
4080                         BT_MANAGER_INTERFACE,
4081                         NULL, &err);
4082
4083         if (!manager_proxy) {
4084                 ERR("Unable to create proxy: %s", err->message);
4085                 goto fail;
4086         }
4087
4088         result = g_dbus_proxy_call_sync(manager_proxy, "DefaultAdapter", NULL,
4089                         G_DBUS_CALL_FLAGS_NONE, -1, NULL, &err);
4090         if (!result) {
4091                 if (err != NULL)
4092                         ERR("Fail to get DefaultAdapter (Error: %s)", err->message);
4093                 else
4094                         ERR("Fail to get DefaultAdapter");
4095
4096                 goto fail;
4097         }
4098
4099         if (g_strcmp0(g_variant_get_type_string(result), "(o)")) {
4100                 ERR("Incorrect result\n");
4101                 goto fail;
4102         }
4103
4104         g_variant_get(result, "(&o)", &adapter_path);
4105
4106         if (adapter_path == NULL ||
4107                 strlen(adapter_path) >= BT_ADAPTER_OBJECT_PATH_MAX) {
4108                 ERR("Adapter path is inproper\n");
4109                 goto fail;
4110         }
4111
4112         if (path)
4113                 g_strlcpy(path, adapter_path, BT_ADAPTER_OBJECT_PATH_MAX);
4114
4115         g_variant_unref(result);
4116         g_object_unref(manager_proxy);
4117
4118         return 0;
4119
4120 fail:
4121         g_clear_error(&err);
4122
4123         if (result)
4124                 g_variant_unref(result);
4125
4126         if (manager_proxy)
4127                 g_object_unref(manager_proxy);
4128
4129         return BT_HFP_AGENT_ERROR_INTERNAL;
4130
4131 }
4132
4133 #ifdef TIZEN_MEDIA_ENHANCE
4134 void _bt_ag_agent_check_transport_state(void)
4135 {
4136         FN_START;
4137
4138         if (transport_state == MEDIA_TRANSPORT_STATE_PLAYING) {
4139                 GDBusProxy *proxy;
4140                 GVariant *ret;
4141                 GError *err = NULL;
4142
4143                 proxy =  g_dbus_proxy_new_sync(ag_dbus_conn,
4144                                 G_DBUS_PROXY_FLAGS_NONE, NULL,
4145                                 "org.PulseAudio2", A2DP_SOURCE_ENDPOINT,
4146                                 BLUEZ_MEDIA_ENDPOINT_INTERFACE, NULL, &err);
4147
4148                 if (!proxy) {
4149                         if (err) {
4150                                 ERR("Unable to create proxy: %s", err->message);
4151                                 g_clear_error(&err);
4152                         }
4153                         return;
4154                 }
4155                 INFO_C("SuspendMedia initiated");
4156
4157                 g_dbus_proxy_call(proxy,
4158                                         "SuspendMedia", NULL,
4159                                         G_DBUS_CALL_FLAGS_NONE, 2000,
4160                                         NULL, NULL, NULL);
4161                 transport_state = MEDIA_TRANSPORT_STATE_IDLE;
4162         }
4163
4164         FN_END;
4165 }
4166
4167 static void __bt_ag_agent_transport_state_update(const char *value)
4168 {
4169
4170         if (!g_strcmp0(value, "idle"))
4171                 transport_state = MEDIA_TRANSPORT_STATE_IDLE;
4172         else if (!g_strcmp0(value, "pending") || !g_strcmp0(value, "active"))
4173                 transport_state = MEDIA_TRANSPORT_STATE_PLAYING;
4174         else
4175                 transport_state =  MEDIA_TRANSPORT_STATE_DISCONNECTED;
4176
4177         INFO_C("transport_state %d", transport_state);
4178 }
4179
4180 static void __bt_ag_agent_media_filter_cb(GDBusConnection *connection,
4181                                         const gchar *sender_name,
4182                                         const gchar *object_path,
4183                                         const gchar *interface_name,
4184                                         const gchar *signal_name,
4185                                         GVariant *parameters,
4186                                         gpointer user_data)
4187 {
4188         FN_START;
4189         char *inter = NULL;
4190         GVariant *dict_param = NULL;
4191         GVariant *optional_param = NULL;
4192
4193         if (strcasecmp(signal_name, "PropertiesChanged") == 0) {
4194                 if (g_strcmp0(g_variant_get_type_string(parameters),
4195                                                         "(sa{sv}as)")) {
4196                         ERR("Incorrect parameters\n");
4197                         return;
4198                 }
4199
4200                 g_variant_get(parameters, "(&s@a{sv}@as)",
4201                                         &inter, &dict_param, &optional_param);
4202                 if (dict_param && (!g_strcmp0(inter,
4203                                 BLUEZ_MEDIA_TRANSPORT_INTERFACE))){
4204                         GVariantIter *iter = NULL;
4205                         const gchar *key = NULL;
4206                         GVariant *value_var = NULL;
4207                         gchar *value = NULL;
4208                         g_variant_get(dict_param, "a{sv}", &iter);
4209                         while (g_variant_iter_loop(
4210                                         iter, "{sv}", &key, &value_var)) {
4211                                 DBG("key %s", key);
4212                                 if (g_strcmp0(key, "State") == 0) {
4213                                         value = g_variant_get_string(
4214                                                                 value_var,
4215                                                                 NULL);
4216                                         DBG("value %s", value);
4217                                         __bt_ag_agent_transport_state_update(value);
4218                                         break;
4219                                 }
4220                         }
4221                         g_variant_iter_free(iter);
4222                         g_variant_unref(dict_param);
4223                 }
4224         } else if (strcasecmp(signal_name, "ProfileStateChanged") == 0) {
4225                 char *profile_uuid = NULL;
4226                 int state = 0;
4227
4228                 g_variant_get(parameters, "(&si)", &profile_uuid, &state);
4229                 if ((g_strcmp0(profile_uuid, A2DP_SINK_UUID) == 0)  &&
4230                         (state == BT_PROFILE_STATE_DISCONNECTED)) {
4231                         DBG("Updating the transport state");
4232                         __bt_ag_agent_transport_state_update("Disconnect");
4233                 }
4234         }
4235
4236         FN_END;
4237 }
4238 #endif
4239 static void __bt_ag_agent_dbus_init(void)
4240 {
4241         FN_START;
4242
4243         if (__bt_ag_get_gdbus_connection() == NULL) {
4244                 ERR("Error in creating the gdbus connection\n");
4245                 return;
4246         }
4247         if (!__bt_ag_register_profile_methods()) {
4248                 ERR("Error in HFP / HSP register_profile_methods\n");
4249                 return;
4250         }
4251
4252         if(!__bt_ag_agent_get_adapter_path(ag_dbus_conn , NULL)) {
4253
4254                 gchar *path = g_strdup(BT_AG_AGENT_OBJECT_PATH);
4255                 __bt_ag_agent_register(path, hfp_ver,
4256                          HFP_AG_UUID, "Hands-Free Audio Gateway");
4257
4258                 path = g_strdup(BT_HS_AG_AGENT_OBJECT_PATH);
4259                 __bt_ag_agent_register(path, hsp_ver,
4260                         HSP_AG_UUID, "Headset Audio Gateway");
4261         }
4262
4263         owner_sig_id = g_dbus_connection_signal_subscribe(ag_dbus_conn,
4264                                 NULL, BT_MANAGER_INTERFACE, NULL, NULL, NULL, 0,
4265                                 __bt_ag_agent_filter_cb, NULL, NULL);
4266 #ifdef TIZEN_MEDIA_ENHANCE
4267         media_sig_id = g_dbus_connection_signal_subscribe(ag_dbus_conn,
4268                                 NULL, BT_PROPERTIES_INTERFACE, NULL, NULL,
4269                                 NULL, 0, __bt_ag_agent_media_filter_cb,
4270                                 NULL, NULL);
4271
4272         media_state_sig_id = g_dbus_connection_signal_subscribe(ag_dbus_conn,
4273                                 NULL, BLUEZ_DEVICE_INTERFACE, NULL, NULL,
4274                                 NULL, 0, __bt_ag_agent_media_filter_cb,
4275                                 NULL, NULL);
4276
4277         transport_state = MEDIA_TRANSPORT_STATE_DISCONNECTED;
4278 #endif
4279         FN_END;
4280         return;
4281 }
4282
4283 static uint32_t __bt_ag_agent_get_ag_features(void)
4284 {
4285
4286         uint32_t ag_features = BT_AG_FEATURE_EC_AND_NR |
4287                                 BT_AG_FEATURE_REJECT_CALL |
4288                                 BT_AG_FEATURE_ENHANCED_CALL_STATUS |
4289                                 BT_AG_FEATURE_THREE_WAY_CALL |
4290 #ifndef TIZEN_KIRAN
4291                                 BT_AG_FEATURE_VOICE_RECOGNITION |
4292 #endif
4293                                 BT_AG_FEATURE_EXTENDED_ERROR_RESULT_CODES;
4294
4295         wbs_en = TRUE;
4296 #if defined(TIZEN_BT_HFP_AG_ENABLE)
4297         hfp_ver = HFP_VERSION_1_6;
4298 #else
4299         hfp_ver = HFP_VERSION_1_5;
4300 #endif
4301         hsp_ver = HSP_VERSION_1_2;
4302
4303         if (hfp_ver == HFP_VERSION_1_6)
4304                 ag_features |= BT_AG_FEATURE_CODEC_NEGOTIATION;
4305         return ag_features;
4306 }
4307
4308 void *__bt_ag_agent_telephony_init(void *arg) {
4309
4310         int tapi_result;
4311         uint32_t ag_features = *((uint32_t *)arg);
4312
4313         INFO_C("Initializing the telephony info");
4314
4315         _bt_hfp_initialize_telephony_manager(ag_features);
4316         __bt_ag_agent_subscribe_vconf_updates();
4317
4318         tapi_handle = tel_init(NULL);
4319         tapi_result = tel_get_sim_msisdn(tapi_handle, __bt_ag_agent_tel_cb,
4320                                         NULL);
4321         if (tapi_result != TAPI_API_SUCCESS)
4322                 ERR("Fail to get sim info: %d", tapi_result);
4323         return NULL;
4324 }
4325
4326 int main(void)
4327 {
4328         int i;
4329         uint32_t ag_features;
4330         struct sigaction sa;
4331         pthread_t thread_id;
4332
4333         INFO_C("Starting Bluetooth AG agent");
4334
4335         g_type_init();
4336
4337         ag_features = __bt_ag_agent_get_ag_features();
4338
4339         ag.sdp_features = (uint16_t) ag_features & 0x1F;
4340
4341         if (hfp_ver == HFP_VERSION_1_6 && wbs_en == TRUE)
4342                 ag.sdp_features |= BT_AG_FEATURE_SDP_WIDEBAND_SPEECH;
4343
4344         memset(&sa, 0, sizeof(sa));
4345         sa.sa_flags = SA_NOCLDSTOP;
4346         sa.sa_handler = __bt_ag_agent_sigterm_handler;
4347
4348         for (i = 0; i < BT_AG_SIG_NUM; i++)
4349                 sigaction(bt_ag_sig_to_handle[i], &sa, &(bt_ag_sigoldact[i]));
4350
4351         gmain_loop = g_main_loop_new(NULL, FALSE);
4352
4353         if (gmain_loop == NULL) {
4354                 ERR("GMainLoop create failed");
4355                 return EXIT_FAILURE;
4356         }
4357
4358         __bt_ag_agent_dbus_init();
4359         if (pthread_create(&thread_id, NULL,
4360                         (void *)&__bt_ag_agent_telephony_init,
4361                                         &ag_features) < 0) {
4362                 ERR("pthread_create() is failed");
4363                 return EXIT_FAILURE;
4364         }
4365
4366         if (pthread_detach(thread_id) < 0) {
4367                 ERR("pthread_detach() is failed");
4368         }
4369
4370         g_main_loop_run(gmain_loop);
4371
4372         DBG("Cleaning up");
4373
4374         tel_deinit(tapi_handle);
4375
4376         __bt_ag_agent_dbus_deinit();
4377         _bt_hfp_deinitialize_telephony_manager();
4378         __bt_ag_agent_release_vconf_updates();
4379
4380         if (remote_dev_path)
4381                 g_free(remote_dev_path);
4382
4383         if (gmain_loop)
4384                 g_main_loop_unref(gmain_loop);
4385
4386         INFO_C("Terminating Bluetooth AG agent");
4387         return 0;
4388 }