2 * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
23 #ifdef TIZEN_FEATURE_BT_DPM
24 #include "bt-service-dpm.h"
31 #include "bluetooth-api.h"
32 #include "bt-internal-types.h"
34 #include "bt-service-common.h"
35 #include "bt-service-event.h"
36 #include "bt-service-util.h"
37 #include "bt-service-obex-agent.h"
38 #include "bt-service-obex-server.h"
39 #include "bt-service-agent.h"
41 #define DBUS_TIMEOUT 20 * 1000 /* 20 Seconds */
42 #define BT_OBEX_SERVER_AGENT_PATH "/org/obex/server_agent"
44 #define BT_OBEX_SERVICE "org.bluez.obex"
45 #define BT_OBEX_MANAGER "org.bluez.obex.AgentManager1"
46 #define BT_OBEX_PATH "/org/bluez/obex"
48 #define BT_OBEX_PATH_PREFIX "/opt/usr/media"
49 #define BT_OBEX_DEFAULT_PATH "/opt/usr/home/owner/media"
50 #define BT_OBEX_PATH_MAX_LENGTH 255
66 GDBusMethodInvocation *reply_context;
73 unsigned char contact_auth_info[5];
86 bt_auth_info_t *auth_info;
87 bt_server_info_t *native_server;
88 bt_server_info_t *custom_server;
89 } bt_obex_agent_info_t;
97 static GSList *transfers;
98 static bt_obex_agent_info_t agent_info;
99 static GSList *session_list = NULL;
101 static bt_session_info_t *__bt_find_session_by_path(char *transfer_path)
104 bt_session_info_t *session;
106 retv_if(transfer_path == NULL, NULL);
108 for (l = session_list; l != NULL; l = l->next) {
114 if (g_strcmp0(session->path, transfer_path) == 0)
121 static GQuark __bt_obex_error_quark(void)
123 static GQuark quark = 0;
125 quark = g_quark_from_static_string("agent");
130 static bt_transfer_info_t *__bt_find_transfer_by_id(int transfer_id)
133 bt_transfer_info_t *transfer;
135 for (l = transfers; l != NULL; l = l->next) {
138 if (transfer == NULL)
141 if (transfer->transfer_id == transfer_id)
148 bt_transfer_info_t *__bt_find_transfer_by_address(const char *address)
152 bt_transfer_info_t *transfer;
154 retv_if(address == NULL, NULL);
156 for (l = transfers; l != NULL; l = l->next) {
159 if (transfer == NULL)
162 if (g_strcmp0(transfer->address, address) == 0)
169 static bt_transfer_info_t *__bt_find_transfer_by_path(const char *transfer_path)
172 bt_transfer_info_t *transfer;
174 retv_if(transfer_path == NULL, NULL);
176 for (l = transfers; l != NULL; l = l->next) {
179 if (transfer == NULL)
182 if (g_strcmp0(transfer->path, transfer_path) == 0)
189 static void __bt_free_server_info(bt_server_info_t *server_info)
191 ret_if(server_info == NULL);
193 g_free(server_info->sender);
194 g_free(server_info->dest_path);
198 static void __bt_free_auth_info(bt_auth_info_t *auto_info)
200 ret_if(auto_info == NULL);
202 g_free(auto_info->filename);
203 g_free(auto_info->transfer_path);
204 g_free(auto_info->device_name);
205 g_free(auto_info->address);
209 static void __bt_free_transfer_info(bt_transfer_info_t *transfer_info)
211 ret_if(transfer_info == NULL);
213 g_free(transfer_info->path);
214 g_free(transfer_info->filename);
215 g_free(transfer_info->file_path);
216 g_free(transfer_info->type);
217 g_free(transfer_info->device_name);
218 g_free(transfer_info->address);
219 g_free(transfer_info);
222 void _bt_obex_check_pending_transfer(const char *address)
225 GVariant *param = NULL;
226 bt_transfer_info_t *transfer_info = __bt_find_transfer_by_address(address);
227 if (transfer_info != NULL) {
228 int result = BLUETOOTH_ERROR_CANCEL;
229 param = g_variant_new("(issssstii)", result,
230 transfer_info->filename,
232 transfer_info->device_name,
233 transfer_info->file_path,
234 transfer_info->address,
235 transfer_info->file_size,
236 transfer_info->transfer_id,
237 agent_info.server_type);
238 _bt_send_event(BT_OPP_SERVER_EVENT,
239 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_COMPLETED,
241 transfers = g_slist_remove(transfers, transfer_info);
242 __bt_free_transfer_info(transfer_info);
247 static char *__bt_get_remote_device_name(const char *bdaddress)
249 char *device_path = NULL;
252 GVariant *result = NULL;
254 GDBusProxy *device_proxy;
255 GDBusConnection *conn;
257 retv_if(bdaddress == NULL, NULL);
259 device_path = _bt_get_device_object_path((char *)bdaddress);
260 retv_if(device_path == NULL, NULL);
262 conn = _bt_gdbus_get_system_gconn();
263 retv_if(conn == NULL, NULL);
264 BT_INFO("Device_path %s", device_path);
265 device_proxy = g_dbus_proxy_new_sync(conn, G_DBUS_PROXY_FLAGS_NONE,
268 BT_PROPERTIES_INTERFACE,
272 retv_if(device_proxy == NULL, NULL);
274 result = g_dbus_proxy_call_sync(device_proxy, "GetAll",
275 g_variant_new("(s)", BT_DEVICE_INTERFACE),
276 G_DBUS_CALL_FLAGS_NONE,
280 BT_ERR("DBus Error : %s", err->message);
284 if (result == NULL) {
285 BT_ERR("g_dbus_proxy_call_sync function return NULL");
288 g_variant_get(result, "(@a{sv})", &value);
291 GVariant *temp_value = g_variant_lookup_value(value, "Alias",
292 G_VARIANT_TYPE_STRING);
293 g_variant_get(temp_value, "s", &name);
295 g_variant_unref(temp_value);
298 DBG_SECURE("Alias Name [%s]", name);
300 temp_value = g_variant_lookup_value(value, "Name", G_VARIANT_TYPE_STRING);
301 g_variant_get(temp_value, "s", &name);
303 g_variant_unref(temp_value);
304 DBG_SECURE("Name = %s", name);
307 g_variant_unref(result);
308 g_object_unref(device_proxy);
312 static void __bt_get_remote_device_name_authinfo(const char *bdaddress,
313 char **device_name, unsigned char *auth_info)
315 char *device_path = NULL;
317 gboolean is_alias_set;
319 GVariant *result = NULL;
321 GDBusProxy *device_proxy;
322 GDBusConnection *conn;
324 ret_if(bdaddress == NULL);
326 device_path = _bt_get_device_object_path((char *)bdaddress);
327 ret_if(device_path == NULL);
329 conn = _bt_gdbus_get_system_gconn();
330 ret_if(conn == NULL);
331 BT_INFO("Device_path %s", device_path);
332 device_proxy = g_dbus_proxy_new_sync(conn, G_DBUS_PROXY_FLAGS_NONE,
335 BT_PROPERTIES_INTERFACE,
339 ret_if(device_proxy == NULL);
341 result = g_dbus_proxy_call_sync(device_proxy, "GetAll",
342 g_variant_new("(s)", BT_DEVICE_INTERFACE),
343 G_DBUS_CALL_FLAGS_NONE,
347 BT_ERR("DBus Error : %s", err->message);
351 if (result == NULL) {
352 BT_ERR("g_dbus_proxy_call_sync function return NULL");
355 g_variant_get(result, "(@a{sv})", &value);
358 GVariant *temp_value = g_variant_lookup_value(value, "Alias",
359 G_VARIANT_TYPE_STRING);
360 g_variant_get(temp_value, "s", &name);
362 g_variant_unref(temp_value);
365 DBG_SECURE("Alias Name [%s]", name);
367 temp_value = g_variant_lookup_value(value, "Name", G_VARIANT_TYPE_STRING);
368 g_variant_get(temp_value, "s", &name);
370 g_variant_unref(temp_value);
371 DBG_SECURE("Name = %s", name);
373 temp_value = g_variant_lookup_value(value, "IsAliasSet", G_VARIANT_TYPE_BOOLEAN);
375 is_alias_set = g_variant_get_boolean(temp_value);
376 g_variant_unref(temp_value);
378 is_alias_set = FALSE;
381 if (is_alias_set == FALSE)
382 __bt_get_auth_info(value, (char *)auth_info);
384 g_variant_unref(result);
385 g_object_unref(device_proxy);
387 *device_name = g_strdup(name);
392 static int __bt_get_transfer_id(const char *path)
398 tmp = strrchr(path, 'r') + 1;
399 retv_if(tmp == NULL, -1);
404 static GDBusProxy *__bt_get_transfer_proxy(const char *transfer_path)
406 GDBusConnection *conn;
410 conn = _bt_gdbus_get_session_gconn();
411 retv_if(conn == NULL, NULL);
413 proxy = g_dbus_proxy_new_sync(conn, G_DBUS_PROXY_FLAGS_NONE,
414 NULL, BT_OBEX_SERVICE_NAME,
416 BT_OBEX_TRANSFER_INTERFACE,
420 BT_ERR("Error : %s", err->message);
428 static GDBusProxy *__bt_get_transfer_properties_proxy(const char *transfer_path)
430 GDBusConnection *conn;
433 conn = _bt_gdbus_get_session_gconn();
434 retv_if(conn == NULL, NULL);
436 proxy = g_dbus_proxy_new_sync(conn, G_DBUS_PROXY_FLAGS_NONE,
437 NULL, BT_OBEX_SERVICE_NAME,
439 BT_PROPERTIES_INTERFACE,
442 BT_ERR("Error : %s", err->message);
449 static int __bt_get_transfer_properties(bt_transfer_info_t *transfer_info,
450 const char *transfer_path)
452 GDBusProxy *transfer_proxy;
453 GVariant *result = NULL;
455 GVariantIter *iter = NULL;
456 BT_CHECK_PARAMETER(transfer_info, return);
457 BT_CHECK_PARAMETER(transfer_path, return);
459 transfer_proxy = __bt_get_transfer_properties_proxy(transfer_path);
461 retv_if(transfer_proxy == NULL, BLUETOOTH_ERROR_INTERNAL);
463 result = g_dbus_proxy_call_sync(transfer_proxy, "GetAll",
464 g_variant_new("(s)", BT_OBEX_TRANSFER_INTERFACE),
465 G_DBUS_CALL_FLAGS_NONE,
470 BT_ERR("DBus Error : %s", err->message);
474 if (result == NULL) {
475 BT_ERR("g_dbus_proxy_call_sync function return NULL");
479 g_variant_get(result, "(a{sv})", &iter);
480 g_variant_unref(result);
485 while (g_variant_iter_loop(iter, "{sv}", &key, &val)) {
486 if (g_strcmp0(key, "Operation") == 0) {
487 transfer_info->type = g_variant_dup_string(val, &len);
488 } else if (g_strcmp0(key, "Name") == 0) {
489 transfer_info->filename = g_variant_dup_string(val, &len);
490 } else if (g_strcmp0(key, "Size") == 0) {
491 transfer_info->file_size = g_variant_get_uint64(val);
492 } else if (g_strcmp0(key, "Address") == 0) {
493 transfer_info->address = g_variant_dup_string(val, &len);
494 BT_INFO("addressss %s", transfer_info->address);
495 } else if (g_strcmp0(key, "Filename") == 0) {
496 transfer_info->file_path = g_variant_dup_string(val, &len);
497 if (!transfer_info->file_path)
498 transfer_info->file_path = g_strdup(transfer_info->filename);
501 g_variant_iter_free(iter);
503 if (transfer_info->address == NULL)
505 transfer_info->device_name = __bt_get_remote_device_name(transfer_info->address);
506 transfer_info->transfer_id = __bt_get_transfer_id(transfer_path);
507 if (!transfer_info->device_name)
508 transfer_info->device_name = g_strdup(transfer_info->address);
510 if (transfer_info->type == NULL)
513 transfer_info->path = g_strdup(transfer_path);
516 g_object_unref(transfer_proxy);
517 return BLUETOOTH_ERROR_NONE;
520 g_object_unref(transfer_proxy);
521 return BLUETOOTH_ERROR_INTERNAL;
524 static gboolean __bt_authorize_cb(GDBusMethodInvocation *context,
528 char *device_name = NULL;
529 unsigned char auth_info[5] = {0, };
530 int result = BLUETOOTH_ERROR_NONE;
531 GDBusProxy *transfer_properties_proxy;
532 char * bdaddress = NULL;
535 GVariant *param = NULL;
537 bt_session_info_t *session_info = NULL;
538 #ifdef TIZEN_FEATURE_BT_DPM
539 int value = DPM_BT_ERROR;
542 BT_DBG(" path [%s] \n", path);
544 transfer_properties_proxy = __bt_get_transfer_properties_proxy(path);
546 retv_if(transfer_properties_proxy == NULL, FALSE);
548 ret = g_dbus_proxy_call_sync(transfer_properties_proxy, "GetAll",
549 g_variant_new("(s)", BT_OBEX_TRANSFER_INTERFACE),
550 G_DBUS_CALL_FLAGS_NONE,
554 BT_ERR("DBus Error : %s", err->message);
559 BT_ERR("g_dbus_proxy_call_sync function return NULL");
562 g_variant_get(ret, "(a{sv})", &iter);
563 g_variant_unref(ret);
565 g_object_unref(transfer_properties_proxy);
569 __bt_free_auth_info(agent_info.auth_info);
571 agent_info.auth_info = g_malloc(sizeof(bt_auth_info_t));
573 memset(agent_info.auth_info, 0, sizeof(bt_auth_info_t));
575 agent_info.auth_info->reply_context = context;
577 agent_info.auth_info->transfer_path = g_strdup(path);
579 #ifdef TIZEN_FEATURE_BT_DPM
580 _bt_dpm_get_allow_bluetooth_mode(&value);
581 if (value == DPM_BT_HANDSFREE_ONLY) {
582 /* Free auth info in next function */
583 _bt_obex_server_reject_authorize();
591 while (g_variant_iter_loop(iter, "{sv}", &key, &val)) {
592 if (g_strcmp0(key, "Name") == 0)
593 agent_info.auth_info->filename = g_variant_dup_string(val, &len);
594 else if (g_strcmp0(key, "Address") == 0)
595 bdaddress = g_variant_dup_string(val, &len);
596 else if (g_strcmp0(key, "Size") == 0)
597 agent_info.auth_info->file_size = g_variant_get_uint64(val);
599 g_variant_iter_free(iter);
602 __bt_get_remote_device_name_authinfo(bdaddress, &device_name, auth_info);
605 device_name = g_strdup(bdaddress);
607 agent_info.auth_info->address = g_strdup(bdaddress);
608 agent_info.auth_info->device_name = device_name;
609 memcpy(agent_info.auth_info->contact_auth_info, auth_info, 5);
611 session_info = __bt_find_session_by_path((char *)path);
612 if (NULL == session_info) {
613 session_info = g_malloc0(sizeof(bt_session_info_t));
614 session_info->path = g_strdup(path);
615 session_info->address = g_strdup(bdaddress);
616 session_info->authorized = FALSE;
617 session_list = g_slist_append(session_list, session_info);
620 g_object_unref(transfer_properties_proxy);
623 if (agent_info.server_type == BT_CUSTOM_SERVER) {
624 /* No need to send the event */
625 _bt_obex_server_accept_authorize(agent_info.auth_info->filename, FALSE);
629 if (session_info->authorized == FALSE) {
630 _bt_launch_system_popup(BT_AGENT_EVENT_EXCHANGE_REQUEST, device_name,
631 auth_info, NULL, NULL, BT_OBEX_SERVER_AGENT_PATH);
633 param = g_variant_new("(istss)", result,
634 agent_info.auth_info->filename,
635 agent_info.auth_info->file_size,
636 agent_info.auth_info->address,
637 agent_info.auth_info->device_name);
638 _bt_send_event(BT_OPP_SERVER_EVENT,
639 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_AUTHORIZE, param);
645 void _bt_obex_transfer_started(const char *transfer_path)
647 bt_transfer_info_t *transfer_info;
648 request_info_t *req_info;
649 GVariant *out_param1 = NULL;
650 GVariant *param = NULL;
651 GVariantBuilder *builder = NULL;
652 int result = BLUETOOTH_ERROR_NONE;
655 BT_DBG("%s", transfer_path);
657 transfer_info = g_malloc0(sizeof(bt_transfer_info_t));
659 if (agent_info.auth_info != NULL
660 && g_strcmp0(transfer_path, agent_info.auth_info->transfer_path) == 0) {
661 transfer_info->filename = g_strdup(agent_info.auth_info->filename);
662 transfer_info->file_size = agent_info.auth_info->file_size;
663 transfer_info->type = g_strdup(TRANSFER_PUT);
664 transfer_info->path = g_strdup(agent_info.auth_info->transfer_path);
665 transfer_info->device_name = g_strdup(agent_info.auth_info->device_name);
666 transfer_info->transfer_id = __bt_get_transfer_id(transfer_path);
667 transfer_info->file_path = agent_info.auth_info->file_path;
668 transfer_info->address = g_strdup(agent_info.auth_info->address);
671 if (__bt_get_transfer_properties(transfer_info, transfer_path) < 0) {
672 BT_ERR("Get Properties failed");
673 __bt_free_transfer_info(transfer_info);
676 agent_info.server_type = BT_FTP_SERVER;
679 if (agent_info.server_type == BT_CUSTOM_SERVER) {
680 if (agent_info.custom_server == NULL) {
681 __bt_free_transfer_info(transfer_info);
682 __bt_free_auth_info(agent_info.auth_info);
683 agent_info.auth_info = NULL;
687 req_info = _bt_get_request_info(agent_info.accept_id);
688 if (req_info == NULL || req_info->context == NULL) {
689 BT_ERR("info is NULL");
693 agent_info.accept_id = 0;
694 result = BLUETOOTH_ERROR_NONE;
695 GArray *g_out_param1 = NULL;
696 g_out_param1 = g_array_new(FALSE, FALSE, sizeof(gchar));
697 if (out_param1 == NULL) {
698 out_param1 = g_variant_new_from_data((const GVariantType *)"ay",
699 g_out_param1->data, g_out_param1->len,
703 g_dbus_method_invocation_return_value(req_info->context,
704 g_variant_new("(iv)", result, out_param1));
705 g_array_free(g_out_param1, TRUE);
706 _bt_delete_request_list(req_info->req_id);
709 transfers = g_slist_append(transfers, transfer_info);
711 BT_DBG("Transfer id %d", transfer_info->transfer_id);
713 builder = g_variant_builder_new(G_VARIANT_TYPE("ay"));
714 for (i = 0; i < 5; i++) {
715 if (agent_info.auth_info)
716 g_variant_builder_add(builder, "y", agent_info.auth_info->contact_auth_info[i]);
719 param = g_variant_new("(isssstii(ay))", result,
720 transfer_info->device_name,
721 transfer_info->filename,
723 transfer_info->address,
724 transfer_info->file_size,
725 transfer_info->transfer_id,
726 agent_info.server_type,
729 __bt_free_auth_info(agent_info.auth_info);
730 agent_info.auth_info = NULL;
732 g_variant_builder_unref(builder);
734 _bt_send_event(BT_OPP_SERVER_EVENT,
735 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_STARTED,
739 void _bt_obex_transfer_progress(const char *transfer_path,
743 bt_transfer_info_t *transfer_info;
744 int current_progress = 0;
745 int previous_progress;
746 GVariant *param = NULL;
747 int result = BLUETOOTH_ERROR_NONE;
749 transfer_info = __bt_find_transfer_by_path(transfer_path);
750 ret_if(transfer_info == NULL);
752 current_progress = (int)(((gdouble)transferred /
753 (gdouble)transfer_info->file_size) * 100);
755 previous_progress = (int)(((gdouble)transfer_info->progress /
756 (gdouble)transfer_info->file_size) * 100);
758 if (current_progress == previous_progress) {
759 BT_DBG("Same Percentage Value: Do not emit Signal");
763 transfer_info->progress = transferred;
764 param = g_variant_new("(isssstiii)", result,
765 transfer_info->filename,
767 transfer_info->device_name,
768 transfer_info->address,
769 transfer_info->file_size,
770 transfer_info->transfer_id,
772 agent_info.server_type);
773 _bt_send_event(BT_OPP_SERVER_EVENT,
774 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_PROGRESS,
779 void _bt_obex_transfer_completed(const char *transfer_path, gboolean success)
781 bt_transfer_info_t *transfer_info;
782 GVariantBuilder *builder = NULL;
783 GVariant *param = NULL;
786 BT_DBG("Transfer [%s] Success [%d] \n", transfer_path, success);
788 result = (success == TRUE) ? BLUETOOTH_ERROR_NONE
789 : BLUETOOTH_ERROR_CANCEL;
791 transfer_info = __bt_find_transfer_by_path(transfer_path);
793 if (transfer_info == NULL) {
794 BT_DBG("Very small files receiving case, did not get Active status from obexd");
795 if (agent_info.auth_info == NULL ||
796 g_strcmp0(transfer_path,
797 agent_info.auth_info->transfer_path) != 0) {
798 BT_ERR("auth_info is NULL, returning");
802 transfer_info = g_new0(bt_transfer_info_t, 1);
804 transfer_info->filename = g_strdup(agent_info.auth_info->filename);
805 transfer_info->file_size = agent_info.auth_info->file_size;
806 transfer_info->type = g_strdup(TRANSFER_PUT);
807 transfer_info->path = g_strdup(agent_info.auth_info->transfer_path);
808 transfer_info->device_name = g_strdup(agent_info.auth_info->device_name);
809 transfer_info->transfer_id = __bt_get_transfer_id(transfer_path);
810 transfer_info->file_path = agent_info.auth_info->file_path;
811 transfer_info->address = g_strdup(agent_info.auth_info->address);
813 builder = g_variant_builder_new(G_VARIANT_TYPE("ay"));
814 for (i = 0; i < 5; i++)
815 g_variant_builder_add(builder, "y", agent_info.auth_info->contact_auth_info[i]);
817 param = g_variant_new("(isssstii(ay))", result,
818 transfer_info->device_name,
819 transfer_info->filename,
821 transfer_info->address,
822 transfer_info->file_size,
823 transfer_info->transfer_id,
824 agent_info.server_type,
826 _bt_send_event(BT_OPP_SERVER_EVENT,
827 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_STARTED,
829 g_variant_builder_unref(builder);
831 param = g_variant_new("(issssstii)", result,
832 transfer_info->filename,
834 transfer_info->device_name,
835 transfer_info->file_path,
836 transfer_info->address,
837 transfer_info->file_size,
838 transfer_info->transfer_id,
839 agent_info.server_type);
840 _bt_send_event(BT_OPP_SERVER_EVENT,
841 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_COMPLETED,
843 transfers = g_slist_remove(transfers, transfer_info);
844 __bt_free_transfer_info(transfer_info);
847 void _bt_obex_transfer_connected(const char *obj_path)
851 int result = BLUETOOTH_ERROR_NONE;
852 GVariant *param = NULL;
853 bt_transfer_info_t *transfer_info = NULL;
855 transfer_info = g_new0(bt_transfer_info_t, 1);
856 __bt_get_transfer_properties(transfer_info, obj_path);
857 INFO_SECURE("Address[%s] Name[%s] TransferID[%d] ", transfer_info->address,
858 transfer_info->device_name, transfer_info->transfer_id);
860 param = g_variant_new("(issi)", result, transfer_info->address,
861 transfer_info->device_name, transfer_info->transfer_id);
863 _bt_send_event(BT_OPP_SERVER_EVENT,
864 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_CONNECTED,
867 __bt_free_transfer_info(transfer_info);
871 void _bt_obex_transfer_disconnected(char * obj_path)
875 int result = BLUETOOTH_ERROR_NONE;
876 GVariant *param = NULL;
877 bt_session_info_t *session = NULL;
878 int transfer_id = -1;
880 session = __bt_find_session_by_path(obj_path);
881 ret_if(session == NULL);
883 transfer_id = __bt_get_transfer_id(obj_path);
884 DBG_SECURE("transfer_id: [%d]", transfer_id);
886 DBG_SECURE("%s", session->address);
887 param = g_variant_new("(isi)", result, session->address, transfer_id);
888 _bt_send_event(BT_OPP_SERVER_EVENT,
889 BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_DISCONNECTED,
891 session_list = g_slist_remove(session_list, session);
892 g_free(session->address);
893 g_free(session->path);
898 int _bt_register_obex_server(void)
900 GDBusConnection *g_conn;
901 GDBusProxy *manager_proxy;
902 GVariant *result = NULL;
903 GError *g_error = NULL;
905 /* Get the session bus. */
906 g_conn = _bt_gdbus_get_session_gconn();
907 retv_if(g_conn == NULL, BLUETOOTH_ERROR_INTERNAL);
909 _bt_obex_agent_new(BT_OBEX_SERVER_AGENT_PATH);
911 _bt_obex_setup(BT_OBEX_SERVER_AGENT_PATH);
913 _bt_obex_set_authorize_cb(BT_OBEX_SERVER_AGENT_PATH,
914 __bt_authorize_cb, NULL);
916 manager_proxy = g_dbus_proxy_new_sync(g_conn, G_DBUS_PROXY_FLAGS_NONE,
917 NULL, BT_OBEX_SERVICE,
922 if (manager_proxy == NULL)
923 return BLUETOOTH_ERROR_INTERNAL;
925 result = g_dbus_proxy_call_sync(manager_proxy, "RegisterAgent",
926 g_variant_new("(o)", BT_OBEX_SERVER_AGENT_PATH),
927 G_DBUS_CALL_FLAGS_NONE,
931 if (g_error != NULL) {
932 BT_ERR("Agent registration failed: %s\n", g_error->message);
933 g_object_unref(manager_proxy);
934 g_error_free(g_error);
935 return BLUETOOTH_ERROR_INTERNAL;
939 g_variant_unref(result);
941 agent_info.proxy = manager_proxy;
943 return BLUETOOTH_ERROR_NONE;
946 int _bt_unregister_obex_server(void)
948 GVariant *result = NULL;
949 GError *g_error = NULL;
951 retv_if(agent_info.proxy == NULL,
952 BLUETOOTH_ERROR_INTERNAL);
954 result = g_dbus_proxy_call_sync(agent_info.proxy, "UnregisterAgent",
955 g_variant_new("(o)", BT_OBEX_SERVER_AGENT_PATH),
956 G_DBUS_CALL_FLAGS_NONE,
959 if (g_error != NULL) {
960 BT_ERR("Agent unregistration failed: %s", g_error->message);
961 g_error_free(g_error);
965 g_variant_unref(result);
967 _bt_obex_agent_destroy(BT_OBEX_SERVER_AGENT_PATH);
968 g_object_unref(agent_info.proxy);
969 agent_info.proxy = NULL;
971 return BLUETOOTH_ERROR_NONE;
974 gboolean __bt_check_folder_path(const char *dest_path)
978 retv_if(dest_path == NULL, FALSE);
980 dp = opendir(dest_path);
983 BT_ERR("The directory does not exist");
992 char *__bt_transfer_folder_path(char *dest_path)
994 char *dst_path = (char *)g_malloc0(BT_OBEX_PATH_MAX_LENGTH);
995 if (g_str_has_prefix(dest_path, BT_OBEX_PATH_PREFIX))
996 snprintf(dst_path, BT_OBEX_PATH_MAX_LENGTH, BT_OBEX_DEFAULT_PATH"%s", dest_path + strlen(BT_OBEX_PATH_PREFIX));
998 snprintf(dst_path, BT_OBEX_PATH_MAX_LENGTH, "%s", dest_path);
1000 BT_INFO("obex transfed path : %s", dst_path);
1004 int _bt_obex_server_allocate(char *sender, const char *dest_path, int app_pid, gboolean is_native)
1009 dst_path = __bt_transfer_folder_path((char *)dest_path);
1011 if (__bt_check_folder_path(dst_path) == FALSE) {
1013 return BLUETOOTH_ERROR_INVALID_PARAM;
1016 if (is_native == TRUE) {
1017 if (agent_info.native_server) {
1018 BT_ERR("obex native server busy");
1020 return BLUETOOTH_ERROR_DEVICE_BUSY;
1023 /* Force to change the control to native */
1024 agent_info.native_server = g_malloc0(sizeof(bt_server_info_t));
1025 agent_info.native_server->dest_path = g_strdup(dst_path);
1026 agent_info.native_server->sender = g_strdup(sender);
1027 agent_info.native_server->app_pid = app_pid;
1028 agent_info.server_type = BT_NATIVE_SERVER;
1029 _bt_unregister_osp_server_in_agent(BT_OBEX_SERVER, NULL);
1031 if (agent_info.custom_server) {
1032 BT_ERR("obex custom server busy");
1034 return BLUETOOTH_ERROR_DEVICE_BUSY;
1037 /* Force to change the control to custom */
1038 agent_info.custom_server = g_malloc0(sizeof(bt_server_info_t));
1039 agent_info.custom_server->dest_path = g_strdup(dst_path);
1040 agent_info.custom_server->sender = g_strdup(sender);
1041 agent_info.custom_server->app_pid = app_pid;
1042 agent_info.server_type = BT_CUSTOM_SERVER;
1043 _bt_register_osp_server_in_agent(BT_OBEX_SERVER, NULL, NULL, -1);
1048 return BLUETOOTH_ERROR_NONE;
1051 int _bt_obex_server_deallocate(int app_pid, gboolean is_native)
1053 if (is_native == TRUE) {
1054 retv_if(agent_info.native_server == NULL,
1055 BLUETOOTH_ERROR_AGENT_DOES_NOT_EXIST);
1057 retv_if(agent_info.native_server->app_pid != app_pid,
1058 BLUETOOTH_ERROR_ACCESS_DENIED);
1060 __bt_free_server_info(agent_info.native_server);
1061 agent_info.native_server = NULL;
1063 /* Change the control to custom */
1064 if (agent_info.custom_server) {
1065 agent_info.server_type = BT_CUSTOM_SERVER;
1066 _bt_register_osp_server_in_agent(BT_OBEX_SERVER,
1070 retv_if(agent_info.custom_server == NULL,
1071 BLUETOOTH_ERROR_AGENT_DOES_NOT_EXIST);
1073 retv_if(agent_info.custom_server->app_pid != app_pid,
1074 BLUETOOTH_ERROR_ACCESS_DENIED);
1076 __bt_free_server_info(agent_info.custom_server);
1077 agent_info.custom_server = NULL;
1079 _bt_unregister_osp_server_in_agent(BT_OBEX_SERVER, NULL);
1081 /* Change the control to native */
1082 if (agent_info.native_server)
1083 agent_info.server_type = BT_NATIVE_SERVER;
1086 return BLUETOOTH_ERROR_NONE;
1089 int _bt_obex_server_accept_authorize(const char *filename, gboolean is_native)
1091 char file_path[BT_FILE_PATH_MAX] = { 0 };
1092 bt_server_info_t *server_info;
1094 BT_CHECK_PARAMETER(filename, return);
1096 retv_if(agent_info.auth_info == NULL, BLUETOOTH_ERROR_INTERNAL);
1098 retv_if(agent_info.auth_info->reply_context == NULL,
1099 BLUETOOTH_ERROR_INTERNAL);
1101 if (is_native == TRUE)
1102 server_info = agent_info.native_server;
1104 server_info = agent_info.custom_server;
1106 retv_if(server_info == NULL, BLUETOOTH_ERROR_INTERNAL);
1108 if (server_info->dest_path != NULL)
1109 snprintf(file_path, sizeof(file_path), "%s/%s",
1110 server_info->dest_path, filename);
1112 snprintf(file_path, sizeof(file_path), "%s", filename);
1114 g_dbus_method_invocation_return_value(agent_info.auth_info->reply_context,
1115 g_variant_new("(s)", &file_path));
1116 agent_info.auth_info->reply_context = NULL;
1117 agent_info.auth_info->file_path = g_strdup(file_path);
1118 g_free(agent_info.auth_info->filename);
1119 agent_info.auth_info->filename = g_strdup(filename);
1121 return BLUETOOTH_ERROR_NONE;
1124 void _bt_obex_server_reply_accept(void)
1126 GVariant *param = NULL;
1127 bt_session_info_t *session_info = NULL;
1128 int result = BLUETOOTH_ERROR_NONE;
1129 param = g_variant_new("(istss)", result,
1130 agent_info.auth_info->filename,
1131 agent_info.auth_info->file_size,
1132 agent_info.auth_info->address,
1133 agent_info.auth_info->device_name);
1134 BT_INFO("Send Obex Authorize");
1135 _bt_send_event(BT_OPP_SERVER_EVENT, BLUETOOTH_EVENT_OBEX_SERVER_TRANSFER_AUTHORIZE, param);
1137 session_info = __bt_find_session_by_path(agent_info.auth_info->transfer_path);
1139 if (NULL == session_info)
1140 BT_ERR("Couldn't get the session info from the list");
1142 session_info->authorized = TRUE;
1145 int _bt_obex_server_reject_authorize(void)
1149 retv_if(agent_info.auth_info->reply_context == NULL,
1150 BLUETOOTH_ERROR_INTERNAL);
1152 g_error = g_error_new(__bt_obex_error_quark(),
1153 BT_OBEX_AGENT_ERROR_CANCEL,
1156 g_dbus_method_invocation_return_gerror(agent_info.auth_info->reply_context,
1158 g_error_free(g_error);
1160 __bt_free_auth_info(agent_info.auth_info);
1161 agent_info.auth_info = NULL;
1163 return BLUETOOTH_ERROR_NONE;
1166 int _bt_obex_server_set_destination_path(const char *dest_path,
1169 bt_server_info_t *server_info;
1170 BT_CHECK_PARAMETER(dest_path, return);
1173 dst_path = __bt_transfer_folder_path((char *)dest_path);
1177 dp = opendir(dst_path);
1180 BT_ERR("The directory does not exist");
1182 return BLUETOOTH_ERROR_INVALID_PARAM;
1187 if (is_native == TRUE)
1188 server_info = agent_info.native_server;
1190 server_info = agent_info.custom_server;
1193 BT_ERR("obex server info is NULL");
1195 return BLUETOOTH_ERROR_AGENT_DOES_NOT_EXIST;
1198 g_free(server_info->dest_path);
1199 server_info->dest_path = g_strdup(dst_path);
1202 return BLUETOOTH_ERROR_NONE;
1205 int _bt_obex_server_set_root(const char *root)
1207 GVariant *result = NULL;
1208 GError *g_error = NULL;
1209 GVariant *folder = NULL;
1210 char *string = "Root";
1213 BT_CHECK_PARAMETER(root, return);
1216 dst_root = __bt_transfer_folder_path((char *)root);
1218 if (!agent_info.proxy) {
1219 BT_ERR("obex agent_info proxy error");
1221 return BLUETOOTH_ERROR_INTERNAL;
1224 dp = opendir(dst_root);
1227 BT_ERR("The directory does not exist");
1229 return BLUETOOTH_ERROR_INVALID_PARAM;
1234 folder = g_variant_new_string(dst_root);
1235 result = g_dbus_proxy_call_sync(agent_info.proxy, "SetProperty",
1236 g_variant_new("(sv)", string, folder),
1237 G_DBUS_CALL_FLAGS_NONE,
1242 BT_ERR("SetProperty Fail: %s", g_error->message);
1243 g_error_free(g_error);
1245 return BLUETOOTH_ERROR_INTERNAL;
1249 g_variant_unref(result);
1252 return BLUETOOTH_ERROR_NONE;
1255 int _bt_obex_server_cancel_transfer(int transfer_id)
1257 bt_transfer_info_t *transfer = NULL;
1259 GVariant *result = NULL;
1262 transfer = __bt_find_transfer_by_id(transfer_id);
1264 retv_if(transfer == NULL, BLUETOOTH_ERROR_NOT_FOUND);
1265 proxy = __bt_get_transfer_proxy(transfer->path);
1267 retv_if(proxy == NULL, BLUETOOTH_ERROR_INTERNAL);
1269 result = g_dbus_proxy_call_sync(proxy, "Cancel", NULL,
1270 G_DBUS_CALL_FLAGS_NONE,
1271 DBUS_TIMEOUT, NULL, &err);
1273 BT_ERR("Dbus Err: %s", err->message);
1274 g_clear_error(&err);
1277 g_object_unref(proxy);
1280 g_variant_unref(result);
1282 return BLUETOOTH_ERROR_NONE;
1285 int _bt_obex_server_cancel_all_transfers(void)
1288 bt_transfer_info_t *transfer;
1290 for (l = transfers; l != NULL; l = l->next) {
1293 if (transfer == NULL)
1296 _bt_obex_server_cancel_transfer(transfer->transfer_id);
1299 return BLUETOOTH_ERROR_NONE;
1302 int _bt_obex_server_is_activated(gboolean *activated)
1304 BT_CHECK_PARAMETER(activated, return);
1306 if (agent_info.custom_server)
1311 return BLUETOOTH_ERROR_NONE;
1314 int _bt_obex_server_check_allocation(gboolean *allocation)
1316 BT_CHECK_PARAMETER(allocation, return);
1318 if (agent_info.native_server || agent_info.custom_server)
1321 *allocation = FALSE;
1323 return BLUETOOTH_ERROR_NONE;
1326 int _bt_obex_server_check_termination(char *sender)
1328 BT_CHECK_PARAMETER(sender, return);
1330 if (agent_info.native_server) {
1331 if (g_strcmp0(sender, agent_info.native_server->sender) == 0) {
1332 _bt_obex_server_deallocate(agent_info.native_server->app_pid,
1337 if (agent_info.custom_server) {
1338 if (g_strcmp0(sender, agent_info.custom_server->sender) == 0) {
1339 _bt_obex_server_deallocate(agent_info.custom_server->app_pid,
1344 return BLUETOOTH_ERROR_NONE;
1347 int _bt_obex_server_is_receiving(gboolean *receiving)
1349 BT_CHECK_PARAMETER(receiving, return);
1351 if (transfers == NULL || g_slist_length(transfers) == 0)
1356 return BLUETOOTH_ERROR_NONE;
1359 gboolean __bt_obex_server_accept_timeout_cb(gpointer user_data)
1361 request_info_t *req_info;
1362 GVariant *out_param1 = NULL;
1363 int result = BLUETOOTH_ERROR_TIMEOUT;
1365 /* Already reply in _bt_obex_transfer_started */
1366 retv_if(agent_info.accept_id == 0, FALSE);
1368 req_info = _bt_get_request_info(agent_info.accept_id);
1369 if (req_info == NULL || req_info->context == NULL) {
1370 BT_ERR("info is NULL");
1374 agent_info.accept_id = 0;
1375 GArray *g_out_param1 = NULL;
1376 g_out_param1 = g_array_new(FALSE, FALSE, sizeof(gchar));
1377 if (out_param1 == NULL) {
1378 out_param1 = g_variant_new_from_data((const GVariantType *)"ay",
1379 g_out_param1->data, g_out_param1->len,
1383 g_dbus_method_invocation_return_value(req_info->context,
1384 g_variant_new("(iv)", result, out_param1));
1385 g_array_free(g_out_param1, TRUE);
1386 _bt_delete_request_list(req_info->req_id);
1391 /* To support the BOT */
1392 int _bt_obex_server_accept_connection(int request_id)
1394 if (!_bt_agent_reply_authorize(TRUE))
1395 return BLUETOOTH_ERROR_INTERNAL;
1397 agent_info.accept_id = request_id;
1399 g_timeout_add(BT_SERVER_ACCEPT_TIMEOUT,
1400 (GSourceFunc)__bt_obex_server_accept_timeout_cb,
1403 return BLUETOOTH_ERROR_NONE;
1406 /* To support the BOT */
1407 int _bt_obex_server_reject_connection(void)
1409 if (!_bt_agent_reply_authorize(FALSE))
1410 return BLUETOOTH_ERROR_INTERNAL;
1412 return BLUETOOTH_ERROR_NONE;
1415 int _bt_opp_get_server_progress(int transfer_id, guint8 *progress)
1417 bt_transfer_info_t *requested_transfer = NULL;
1418 requested_transfer = __bt_find_transfer_by_id(transfer_id);
1419 if (requested_transfer == NULL) {
1420 BT_ERR("No Matching Inbound transfer");
1421 return BLUETOOTH_ERROR_NOT_FOUND;
1424 *progress = (int)(((double)requested_transfer->progress /
1425 requested_transfer->file_size) * 100);
1427 BT_DBG("Percentage: %d", *progress);
1428 return BLUETOOTH_ERROR_NONE;