1 files changed, 49 insertions, 14 deletions

diff --git a/plugins/lib/bluealsa/hal-bluealsa.c b/plugins/lib/bluealsa/hal-bluealsa.c
index 10a61ae..415b160 100644
--- a/plugins/lib/bluealsa/hal-bluealsa.c
+++ b/plugins/lib/bluealsa/hal-bluealsa.c
@@ -29,9 +29,12 @@
 #include <urcu/list.h>
 
 #include "hal-bluealsa.h"
+#include "4a-hal-utilities-data.h"
 
 #define HAL_BLUEALSA_PLUGIN_NAME "hal-bluealsa"
 
+#define A2DP_LISTEN_FORMAT	"S16_LE"
+
 #define SCO_TALK_RATE 44100
 #define SCO_TALK_FORMAT "S16_LE"
 
@@ -65,17 +68,29 @@ CTLP_INIT(plugin, callbacks)
 {
 	json_object *actionsToAdd = NULL;
 	CtlConfigT *ctrlConfig;
-
-	wrap_json_pack(&actionsToAdd, "{s:s s:s s:s}",
-				      "uid", "init-bluealsa-plugin",
-				      "info", "Init Bluez-Alsa hal plugin",
-				      "action", "plugin://hal-bluealsa#init");
+	struct SpecificHalData *currentHalData;
 
 	if (!(ctrlConfig = (CtlConfigT *) afb_api_get_userdata(plugin->api))) {
 		AFB_API_ERROR(plugin->api, "Can't get current hal controller config");
 		goto fail;
 	}
 
+	if (!(currentHalData = (struct SpecificHalData *) ctrlConfig->external)) {
+		AFB_API_ERROR(plugin->api, "Can't get current hal controller data");
+		goto fail;
+	}
+
+	if (currentHalData->status != HAL_STATUS_AVAILABLE) {
+		AFB_API_WARNING(plugin->api,
+					   "Controller initialization of %s plugin cannot be done because hal is not ready to be used", HAL_BLUEALSA_PLUGIN_NAME);
+		goto done;
+	}
+
+	wrap_json_pack(&actionsToAdd, "{s:s s:s s:s}",
+				      "uid", "init-bluealsa-plugin",
+				      "info", "Init Bluez-Alsa hal plugin",
+				      "action", "plugin://hal-bluealsa#init");
+
 	int idx = 0;
 	while (ctrlConfig->sections[idx].key && strcasecmp(ctrlConfig->sections[idx].key, "onload"))
 		idx++;
@@ -91,10 +106,11 @@ CTLP_INIT(plugin, callbacks)
 	}
 
 	AFB_API_NOTICE(plugin->api, "Plugin initialization of %s plugin correctly done", HAL_BLUEALSA_PLUGIN_NAME);
-
+done:
 	return 0;
 fail:
-	json_object_put(actionsToAdd);
+	if (actionsToAdd)
+		json_object_put(actionsToAdd);
 	return -1;
 }
 
@@ -373,12 +389,14 @@ fail:
 static json_object* halBlueAlsaListenCapture(
 	const char * listenCaptureS,
 	json_object * pcmplugParamsJ,
+	json_object * captureParamsJ,
 	json_object * sourceJ) {
 
 	json_object * captureJ = json_object_new_object();
 
 	json_object_object_add(captureJ, "uid", json_object_new_string(listenCaptureS));
 	json_object_object_add(captureJ, "pcmplug_params", pcmplugParamsJ);
+	json_object_object_add(captureJ, "params", captureParamsJ);
 	json_object_object_add(captureJ, "source", sourceJ);
 
 	return captureJ;
@@ -400,11 +418,20 @@ static json_object * halBlueAlsaTalkPlayback(
 	return playbackJ;
 }
 
-static json_object * halBlueAlsaScoTalkParamsJ() {
+static json_object * halBlueAlsaScoTalkParamsJ(uint32_t sampling) {
 	json_object * paramsJ = json_object_new_object();
 
-	json_object_object_add(paramsJ, "rate",   json_object_new_int(SCO_TALK_RATE));
+	json_object_object_add(paramsJ, "rate",   json_object_new_int(sampling));
 	json_object_object_add(paramsJ, "format", json_object_new_string(SCO_TALK_FORMAT));
+	json_object_object_add(paramsJ, "channels", json_object_new_int(1));
+	return paramsJ;
+}
+
+static json_object * halBlueAlsaListenParamsJ(uint32_t sampling) {
+	json_object * paramsJ = json_object_new_object();
+
+	json_object_object_add(paramsJ, "rate",   json_object_new_int(sampling));
+	json_object_object_add(paramsJ, "format", json_object_new_string(A2DP_LISTEN_FORMAT));
 	return paramsJ;
 }
 
@@ -447,6 +474,7 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 	json_object* playbackJ = NULL;
 
 	json_object* pcmplugParamsJ, *pcmplugParamsJ2 = NULL;
+	json_object* captureParamsJ;
 
 	json_object* streamsJ = NULL;
 	json_object* streamJ = NULL;
@@ -502,13 +530,15 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 	else
 		json_object_object_add(sourceJ, "channels", halBlueAlsaSCOTransportChannels(transportTypeS));
 
-	json_object_object_add(requestJ, "captures", halBlueAlsaListenCapture(captureS, pcmplugParamsJ, sourceJ));
+	captureParamsJ = halBlueAlsaListenParamsJ(ba_transport->sampling);
+
+	json_object_object_add(requestJ, "captures", halBlueAlsaListenCapture(captureS, pcmplugParamsJ, captureParamsJ, sourceJ));
 
 	if (ba_transport->type & BA_PCM_TYPE_SCO) {
 		playbackJ = json_object_new_object();
 		// that is a shame that deep copy in not available in the current json-c version
 		pcmplugParamsJ2 = halBlueAlsaPcmPlugParams(watch->interface, addr, transportTypeS);
-		json_object * paramsJ = halBlueAlsaScoTalkParamsJ();
+		json_object * paramsJ = halBlueAlsaScoTalkParamsJ(ba_transport->sampling);
 
 		json_object_object_add(playbackJ, "channels", halBlueAlsaSCOTransportChannels(transportTypeS));
 		json_object_object_add(requestJ, "playbacks", halBlueAlsaTalkPlayback(playbackS, pcmplugParamsJ2, paramsJ, playbackJ));
@@ -541,7 +571,7 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 
 	json_object_array_add(streamsJ, streamJ);
 
-	/* In case of SCO, to have full-duplex, we instantiate a stream for talk */
+	/* In case of SCO, to have full-duplex, we instantiate a stream for 'talk' */
 	if (ba_transport->type & BA_PCM_TYPE_SCO ) {
 
 		streamJ = json_object_new_object();
@@ -630,7 +660,7 @@ static int halBlueAlsaFetchTransports(bluealsa_watch * watch) {
 		else
 			typeS = "unknown";
 
-		AFB_API_DEBUG(plugin->api, "Transport %d: type %s (%x), dev %s", ix, typeS, ba_transport->type, addr);
+		AFB_API_DEBUG(plugin->api, "Transport %d: type %s (%x), dev %s, codec %d", ix, typeS, ba_transport->type, addr, ba_transport->codec);
 
 		if (BA_PCM_TYPE(ba_transport->type) == BA_PCM_TYPE_SCO &&
 			ba_transport->codec == 0) {
@@ -775,6 +805,11 @@ static int name_changed_cb(sd_bus_message *m, void *userdata, sd_bus_error * ret
 
 	const char * signature = sd_bus_message_get_signature(m, 1);
 
+	/* simply ignore silently that spurious message */
+	if (strcmp(signature,"s") == 0) {
+		goto done;
+	}
+
 	if (strcmp(signature,"sss") != 0) {
         AFB_API_ERROR(plugin->api, "%s: wrong message signature '%s'", __func__, signature);
 		goto done;
@@ -867,7 +902,7 @@ static int halBlueAlsaRegisterAll(CtlPluginT* plugin) {
 		goto failed;
 	}
 
-	AFB_API_ERROR(plugin->api, "Ask DBus for the list of services");
+	AFB_API_INFO(plugin->api, "Ask DBus for the list of services");
 
 	ret = sd_bus_call_method_async(bus,
 								   &slot,