#include "geofence_server_internal.h"
#include "geofence_server_db.h"
+static int connectedFence = -1;
static gboolean __geofence_check_fence_status(int fence_status, GeofenceItemData *item_data)
{
FUNC_ENTRANCE_SERVER
return ret;
}
+static bool __check_for_match(char *str1, char *str2)
+{
+ if (g_strrstr(str1, str2) == NULL)
+ return false;
+ return true;
+}
+
+static void bt_le_scan_result_cb(int result, bt_adapter_le_device_scan_result_info_s *info, void *user_data)
+{
+ int ret = BT_ERROR_NONE;
+ GeofenceServer *geofence_server = (GeofenceServer *) user_data;
+ LOGI_GEOFENCE("Current addresses: %s", geofence_server->ble_info);
+
+ if (info == NULL) {
+ LOGI_GEOFENCE("Stopping scan as there is no BLE address found");
+ ret = bt_adapter_le_stop_scan();
+ if (ret != BT_ERROR_NONE)
+ LOGE_GEOFENCE("Unable to stop the BLE scan, error: %d", ret);
+ return;
+ }
+ LOGI_GEOFENCE("Received address: %s", info->remote_address);
+
+ if (!g_ascii_strcasecmp(geofence_server->ble_info, "")) {
+ g_stpcpy(geofence_server->ble_info, info->remote_address);
+ } else if (!__check_for_match(geofence_server->ble_info, info->remote_address)) { /* If duplicate does not exist */
+ char *p = g_strjoin(";", geofence_server->ble_info, info->remote_address, NULL);
+ g_stpcpy(geofence_server->ble_info, p);
+ g_free(p);
+ } else {
+ LOGI_GEOFENCE("Stopping scan. Address: %s already exist in the string %s", info->remote_address, geofence_server->ble_info);
+ ret = bt_adapter_le_stop_scan();
+ if (ret != BT_ERROR_NONE)
+ LOGE_GEOFENCE("Unable to stop the BLE scan, error: %d", ret);
+ /* Add the string to the database. */
+ if (connectedFence != -1)
+ geofence_manager_set_ble_info_to_geofence(connectedFence, geofence_server->ble_info);
+ }
+}
+
+static void emit_bt_geofence_proximity_changed(GeofenceServer *geofence_server, int fence_id, int fence_proximity_status)
+{
+ FUNC_ENTRANCE_SERVER
+ LOGD_GEOFENCE("emit_bt_geofence_proximity_changed");
+ char *app_id = NULL;
+ int ret = FENCE_ERR_NONE;
+
+ ret = geofence_manager_get_appid_from_geofence(fence_id, &app_id);
+ if (ret != FENCE_ERR_NONE) {
+ LOGE("Error getting the app_id for fence id[%d]", fence_id);
+ return;
+ }
+ GeofenceItemData *item_data = __get_item_by_fence_id(fence_id, geofence_server);
+ if (item_data == NULL) {
+ LOGD_GEOFENCE("getting item data failed. fence_id [%d]", fence_id);
+ g_free(app_id);
+ return;
+ }
+
+ if (fence_proximity_status != item_data->common_info.proximity_status) {
+ geofence_dbus_server_send_geofence_proximity_changed(geofence_server->geofence_dbus_server, app_id, fence_id, item_data->common_info.access_type, fence_proximity_status, GEOFENCE_PROXIMITY_PROVIDER_BLUETOOTH);
+ if (fence_proximity_status == GEOFENCE_PROXIMITY_NEAR) {
+ LOGD_GEOFENCE("BT Fence. Scanning for BLE and storing in DB");
+ g_stpcpy(geofence_server->ble_info, "");
+ ret = bt_adapter_le_start_scan(bt_le_scan_result_cb, geofence_server);
+ if (ret != BT_ERROR_NONE)
+ LOGE_GEOFENCE("Fail to start ble scan. %d", ret);
+ }
+ item_data->common_info.proximity_status = fence_proximity_status;
+ }
+ g_free(app_id);
+}
+
+
static void emit_bt_geofence_inout_changed(GeofenceServer *geofence_server, GeofenceItemData *item_data, int fence_status)
{
FUNC_ENTRANCE_SERVER
- char *app_id = (char *)g_malloc0(sizeof(char)*APP_ID_LEN);
+ char *app_id = (char *)g_malloc0(sizeof(char) *APP_ID_LEN);
g_strlcpy(app_id, item_data->common_info.appid, APP_ID_LEN);
if (app_id == NULL) {
LOGD_GEOFENCE("get app_id failed. fence_id [%d]", item_data->common_info.fence_id);
return;
}
- if (fence_status == GEOFENCE_FENCE_STATE_IN) {
+ if (fence_status == GEOFENCE_FENCE_STATE_IN)
geofence_dbus_server_send_geofence_inout_changed(geofence_server->geofence_dbus_server, app_id, item_data->common_info.fence_id, item_data->common_info.access_type, GEOFENCE_EMIT_STATE_IN);
- } else if (fence_status == GEOFENCE_FENCE_STATE_OUT) {
+ else if (fence_status == GEOFENCE_FENCE_STATE_OUT)
geofence_dbus_server_send_geofence_inout_changed(geofence_server->geofence_dbus_server, app_id, item_data->common_info.fence_id, item_data->common_info.access_type, GEOFENCE_EMIT_STATE_OUT);
- }
- if (item_data->client_status == GEOFENCE_CLIENT_STATUS_START) {
+ if (item_data->client_status == GEOFENCE_CLIENT_STATUS_START)
item_data->client_status = GEOFENCE_CLIENT_STATUS_RUNNING;
- }
+
if (app_id)
- free(app_id);
+ g_free(app_id);
}
static void __geofence_check_bt_fence_type(gboolean connected, const char *bssid, void *data)
continue;
fence_type = item_data->common_info.type;
-
+
if (fence_type != GEOFENCE_TYPE_BT)
continue;
-
+
bt_info_from_list = (bssid_info_s *) item_data->priv;
if (bt_info_from_list == NULL || bt_info_from_list->enabled == FALSE)
continue;
-
+
ret = geofence_manager_get_bssid_info(fence_id, &bt_info_from_db);
if (bt_info_from_db == NULL) {
}
LOGD_GEOFENCE("bt_info->bssid [%s]", bt_info_from_db->bssid);
- if (g_ascii_strcasecmp(bt_info_from_db->bssid, bssid) == 0) {
+ if (!g_ascii_strcasecmp(bt_info_from_db->bssid, bssid) || !g_ascii_strcasecmp(g_strdelimit(bt_info_from_db->bssid, "-", ':'), bssid)) {
if (connected) { /* connected => FENCE_IN*/
if (__geofence_check_fence_status(GEOFENCE_FENCE_STATE_IN, item_data) == TRUE) {
LOGD_GEOFENCE("Emitted to fence_id [%d] GEOFENCE_FENCE_STATE_IN", fence_id);
+ connectedFence = fence_id;
emit_bt_geofence_inout_changed(geofence_server, item_data, GEOFENCE_FENCE_STATE_IN);
+ emit_bt_geofence_proximity_changed(geofence_server, fence_id, GEOFENCE_PROXIMITY_NEAR);
}
} else { /* disconnected => FENCE_OUT*/
if (__geofence_check_fence_status(GEOFENCE_FENCE_STATE_OUT, item_data) == TRUE) {
LOGD_GEOFENCE("Emitted to fence_id [%d] GEOFENCE_FENCE_STATE_OUT", fence_id);
+ connectedFence = -1;
emit_bt_geofence_inout_changed(geofence_server, item_data, GEOFENCE_FENCE_STATE_OUT);
+ emit_bt_geofence_proximity_changed(geofence_server, fence_id, GEOFENCE_PROXIMITY_UNCERTAIN);
}
}
}
bt_info_from_db = NULL;
bt_info_from_list = NULL;
}
-
LOGD_GEOFENCE("exit");
}
void bt_adp_disable(gboolean connected, void *user_data)
{
FUNC_ENTRANCE_SERVER
- GeofenceServer * geofence_server = (GeofenceServer *) user_data;
+ GeofenceServer *geofence_server = (GeofenceServer *) user_data;
g_return_if_fail(geofence_server);
int fence_id = 0;
if (__geofence_check_fence_status(GEOFENCE_FENCE_STATE_OUT, item_data) == TRUE) {
LOGD_GEOFENCE("Emitted to fence_id [%d] GEOFENCE_FENCE_STATE_OUT", fence_id);
emit_bt_geofence_inout_changed(geofence_server, item_data, GEOFENCE_FENCE_STATE_OUT);
+ emit_bt_geofence_proximity_changed(geofence_server, fence_id, GEOFENCE_PROXIMITY_UNCERTAIN);
}
}
}
projects / platform / core / location / geofence-server.git / blobdiff