1 files changed, 67 insertions, 22 deletions

diff --git a/plugins/lib/bluetooth/hal-bt-data.c b/plugins/lib/bluetooth/hal-bt-data.c
index f3cb0e4..6a70495 100644
--- a/plugins/lib/bluetooth/hal-bt-data.c
+++ b/plugins/lib/bluetooth/hal-bt-data.c
@@ -23,6 +23,7 @@
 
 #include <wrap-json.h>
 
+#include "hal-bt.h"
 #include "hal-bt-data.h"
 
 /*******************************************************************************
@@ -96,9 +97,9 @@ struct HalBtDeviceData *HalBtDataAddBtDeviceToBtDeviceList(struct HalBtDeviceDat
 
 	if(wrap_json_unpack(currentSingleBtDeviceDataJ,
 			    "{s:s s:s s:s}",
-			    "Name", &currentBtDeviceName,
-			    "Address", &currentBtDeviceAddress,
-			    "Path", &currentBtDevicePath)) {
+			    "name", &currentBtDeviceName,
+			    "address", &currentBtDeviceAddress,
+			    "adapter", &currentBtDevicePath)) {
 		HalBtDataRemoveSelectedBtDeviceFromList(firstBtDeviceData, currentBtDeviceData);
 		return NULL;
 	}
@@ -168,14 +169,59 @@ struct HalBtDeviceData *HalBtDataSearchBtDeviceByAddress(struct HalBtDeviceData
 	return NULL;
 }
 
-int HalBtDataHandleReceivedSingleBtDeviceData(struct HalBtPluginData *halBtPluginData, json_object *currentSingleBtDeviceDataJ)
+int HalBtDataHandleReceivedMediaBtDeviceData(struct HalBtPluginData *halBtPluginData, json_object *currentSingleBtMediaDataJ)
 {
-	int btProfilesCount;
+	const char *currentBtType = NULL, *currentBtAction = NULL;
+
+	AFB_ApiT api = halBtPluginData->currentHalApiHandle;
+	json_object *returnedJ, *returnedBtList = NULL;
+	int err = 0;
+
+	wrap_json_unpack(currentSingleBtMediaDataJ, "{s:s}", "type", &currentBtType);
+
+	if(currentBtType && strcmp(currentBtType, "transport"))
+		return 0;
+
+	wrap_json_unpack(currentSingleBtMediaDataJ, "{s:s}", "action", &currentBtAction);
+
+	if(currentBtAction && strcmp(currentBtAction, "added") && strcmp(currentBtAction, "removed"))
+		return 0;
+
+	// UGLY HACK: This should be actually detecting if a device is disconnected
+	// SPEC-2010 has been created to track the removal of this.
+	usleep(1000 * 100);
+
+	if(AFB_ServiceSync(api, BT_MANAGER_API, BT_MANAGER_GET_DEVICES_VERB, NULL, &returnedJ)) {
+		AFB_ApiError(api, "Error during call to verb '%s' of '%s' api (%s)",
+			BT_MANAGER_GET_DEVICES_VERB,
+			BT_MANAGER_API,
+			json_object_get_string(returnedJ));
+		return -1;
+	}
+	else if(wrap_json_unpack(returnedJ, "{s:{s:o}}", "response", "devices", &returnedBtList)) {
+		AFB_ApiError(api,
+			     "Couldn't get bluetooth device list during call to verb '%s' of api '%s'",
+			     BT_MANAGER_GET_DEVICES_VERB,
+			     BT_MANAGER_API);
+		json_object_put(returnedJ);
+		return -1;
+	}
 
-	unsigned int idx = 0, currentBtDeviceIsConnected, currentBtDeviceIsA2DP;
+	if((returnedBtList) && (err = HalBtDataHandleReceivedMutlipleBtDeviceData(halBtPluginData, returnedBtList)))
+		err = 10 * err;
 
-	char *currentBtDeviceAddress, *currentBtDeviceIsConnectedString, *currentBtDeviceIsAVPConnectedString;
+	json_object_put(returnedJ);
+
+	return err;
+}
+
+int HalBtDataHandleReceivedSingleBtDeviceData(struct HalBtPluginData *halBtPluginData, json_object *currentSingleBtDeviceDataJ)
+{
+	unsigned int currentBtDeviceIsConnected = 0;
+	unsigned int currentBtDeviceIsA2DP = 0;
+	unsigned int idx = 0;
 
+	char *currentBtDeviceAddress;
 	json_object *currentBtAllProfilesJ = NULL, *currentBtCurrentProfileJ;
 
 	struct HalBtDeviceData *currentBtDevice;
@@ -183,11 +229,10 @@ int HalBtDataHandleReceivedSingleBtDeviceData(struct HalBtPluginData *halBtPlugi
 		return -1;
 
 	if(wrap_json_unpack(currentSingleBtDeviceDataJ,
-			    "{s:s s:s s:s s?:o}",
-			    "Address", &currentBtDeviceAddress,
-			    "Connected", &currentBtDeviceIsConnectedString,
-			    "AVPConnected", &currentBtDeviceIsAVPConnectedString,
-			    "UUIDs", &currentBtAllProfilesJ)) {
+			    "{s:s s:b s?:o}",
+			    "address", &currentBtDeviceAddress,
+			    "connected", &currentBtDeviceIsConnected,
+			    "uuids", &currentBtAllProfilesJ)) {
 		return -2;
 	}
 
@@ -197,7 +242,7 @@ int HalBtDataHandleReceivedSingleBtDeviceData(struct HalBtPluginData *halBtPlugi
 	}
 
 	if(json_object_is_type(currentBtAllProfilesJ, json_type_array)) {
-		btProfilesCount = json_object_array_length(currentBtAllProfilesJ);
+		int btProfilesCount = json_object_array_length(currentBtAllProfilesJ);
 
 		while(idx < btProfilesCount) {
 			currentBtCurrentProfileJ = json_object_array_get_idx(currentBtAllProfilesJ, idx);
@@ -211,17 +256,10 @@ int HalBtDataHandleReceivedSingleBtDeviceData(struct HalBtPluginData *halBtPlugi
 			idx++;
 		}
 	}
-	else if(json_object_is_type(currentBtAllProfilesJ, json_type_string) &&
-		! strncasecmp(json_object_get_string(currentBtAllProfilesJ), A2DP_AUDIOSOURCE_UUID, sizeof(A2DP_AUDIOSOURCE_UUID))) {
-		currentBtDeviceIsA2DP = 1;
-	}
 
 	if(! currentBtDeviceIsA2DP)
 		return 0;
 
-	currentBtDeviceIsConnected = ((! strncmp(currentBtDeviceIsConnectedString, "True", strlen(currentBtDeviceIsConnectedString))) &&
-				      (! strncmp(currentBtDeviceIsAVPConnectedString, "True", strlen(currentBtDeviceIsAVPConnectedString))));
-
 	currentBtDevice = HalBtDataSearchBtDeviceByAddress(&halBtPluginData->first, currentBtDeviceAddress);
 
 	if(currentBtDevice && ! currentBtDeviceIsConnected) {
@@ -268,9 +306,16 @@ int HalBtDataHandleReceivedMutlipleBtDeviceData(struct HalBtPluginData *halBtPlu
 	btDeviceNumber = json_object_array_length(currentMultipleBtDeviceDataJ);
 
 	for(idx = 0; idx < btDeviceNumber; idx++) {
-		if((err = HalBtDataHandleReceivedSingleBtDeviceData(halBtPluginData, json_object_array_get_idx(currentMultipleBtDeviceDataJ, (unsigned int) idx)))) {
+		struct json_object *jobj = json_object_array_get_idx(currentMultipleBtDeviceDataJ, (unsigned int) idx);
+		struct json_object *val;
+
+		if(!json_object_object_get_ex(jobj, "properties", &val))
+			continue;
+
+		err = HalBtDataHandleReceivedSingleBtDeviceData(halBtPluginData, val);
+
+		if(err)
 			return ((int) idx * err * 10);
-		}
 	}
 
 	return 0;