Move from controller functions to afb functions

Move from controller 'afb-definitions.h' functions to
application framework 'afb/afb-binding.h' functions.

Change-Id: I4cd62af881ef8ac949b082ede9dfcc4736d1e12c
Signed-off-by: Jonathan Aillet <jonathan.aillet@iot.bzh>

1 files changed, 35 insertions, 35 deletions

diff --git a/plugins/lib/bluealsa/hal-bluealsa.c b/plugins/lib/bluealsa/hal-bluealsa.c
index c8cfe98..502bfc6 100644
--- a/plugins/lib/bluealsa/hal-bluealsa.c
+++ b/plugins/lib/bluealsa/hal-bluealsa.c
@@ -48,7 +48,7 @@ CTLP_CAPI_REGISTER(HAL_BLUEALSA_PLUGIN_NAME)
 // Call at initialization time ('requires' are forbidden at this stage)
 CTLP_ONLOAD(plugin, callbacks)
 {
-	AFB_ApiNotice(plugin->api, "%s Plugin Registered correctly: uid='%s' 'info='%s'", HAL_BLUEALSA_PLUGIN_NAME, plugin->uid, plugin->info);
+	AFB_API_NOTICE(plugin->api, "%s Plugin Registered correctly: uid='%s' 'info='%s'", HAL_BLUEALSA_PLUGIN_NAME, plugin->uid, plugin->info);
 	return 0;
 }
 
@@ -63,8 +63,8 @@ CTLP_INIT(plugin, callbacks)
 				      "info", "Init Bluez-Alsa hal plugin",
 				      "action", "plugin://hal-bluealsa#init");
 
-	if (!(ctrlConfig = (CtlConfigT *) AFB_ApiGetUserData(plugin->api))) {
-		AFB_ApiError(plugin->api, "Can't get current hal controller config");
+	if (!(ctrlConfig = (CtlConfigT *) afb_api_get_userdata(plugin->api))) {
+		AFB_API_ERROR(plugin->api, "Can't get current hal controller config");
 		goto fail;
 	}
 
@@ -73,16 +73,16 @@ CTLP_INIT(plugin, callbacks)
 		idx++;
 
 	if (!ctrlConfig->sections[idx].key) {
-		AFB_ApiError(plugin->api, "Wasn't able to add '%s' as a new onload, 'onload' section not found", json_object_get_string(actionsToAdd));
+		AFB_API_ERROR(plugin->api, "Wasn't able to add '%s' as a new onload, 'onload' section not found", json_object_get_string(actionsToAdd));
 		goto fail;
 	}
 
 	if(AddActionsToSection(plugin->api, &ctrlConfig->sections[idx], actionsToAdd, 0)) {
-		AFB_ApiError(plugin->api, "Wasn't able to add '%s' as a new onload to %s", json_object_get_string(actionsToAdd), ctrlConfig->sections[idx].uid);
+		AFB_API_ERROR(plugin->api, "Wasn't able to add '%s' as a new onload to %s", json_object_get_string(actionsToAdd), ctrlConfig->sections[idx].uid);
 		goto fail;
 	}
 
-	AFB_ApiNotice(plugin->api, "Plugin initialization of %s plugin correctly done", HAL_BLUEALSA_PLUGIN_NAME);
+	AFB_API_NOTICE(plugin->api, "Plugin initialization of %s plugin correctly done", HAL_BLUEALSA_PLUGIN_NAME);
 
 	return 0;
 fail:
@@ -94,7 +94,7 @@ fail:
 // Call at controller onload time
 CTLP_CAPI(init, source, argsJ, queryJ)
 {
-	AFB_ApiNotice(source->api, "Controller onload event");
+	AFB_API_NOTICE(source->api, "Controller onload event");
 
 	CtlPluginT * plugin = source->plugin;
 
@@ -123,29 +123,29 @@ CTLP_CAPI(init, source, argsJ, queryJ)
 				"a2dp", &a2dpParamsJ);
 
 	if (error) {
-		AFB_ApiError(plugin->api, "%s: wrong parameters", __func__);
+		AFB_API_ERROR(plugin->api, "%s: wrong parameters", __func__);
 		goto fail;
 	}
 
 	if (scoParamsJ) {
-		AFB_ApiInfo(plugin->api, "%s: sco parameters: %s", __func__, json_object_get_string(scoParamsJ));
+		AFB_API_INFO(plugin->api, "%s: sco parameters: %s", __func__, json_object_get_string(scoParamsJ));
 		error = wrap_json_unpack(scoParamsJ, "{s:s,s:s,s?i !}",
 				"mic", &pluginData->sco.mic,
 				"zone", &pluginData->sco.speaker,
 				"delayms", &pluginData->sco.delayms);
 		if (error) {
-			AFB_ApiError(plugin->api, "%s: wrong sco parameters: err %s", __func__, wrap_json_get_error_string(error));
+			AFB_API_ERROR(plugin->api, "%s: wrong sco parameters: err %s", __func__, wrap_json_get_error_string(error));
 			goto fail;
 		}
 	}
 
 	if (a2dpParamsJ) {
-		AFB_ApiInfo(plugin->api, "%s: a2dp parameters: %s", __func__, json_object_get_string(a2dpParamsJ));
+		AFB_API_INFO(plugin->api, "%s: a2dp parameters: %s", __func__, json_object_get_string(a2dpParamsJ));
 		error = wrap_json_unpack(a2dpParamsJ, "{s:s,s?i !}",
 				"zone", &pluginData->a2dp.zone,
 				"delayms", &pluginData->a2dp.delayms);
 		if (error) {
-			AFB_ApiError(plugin->api, "%s: wrong a2dp parameters: err=%s", __func__, wrap_json_get_error_string(error));
+			AFB_API_ERROR(plugin->api, "%s: wrong a2dp parameters: err=%s", __func__, wrap_json_get_error_string(error));
 			goto fail;
 		}
 	}
@@ -171,13 +171,13 @@ static int halBlueAlsaTransportEventCB(sd_event_source* src, int fd, uint32_t re
 	struct ba_msg_event event;
 	ssize_t ret;
 
-	AFB_ApiDebug(plugin->api, "--- %s ----!", __func__);
+	AFB_API_DEBUG(plugin->api, "--- %s ----!", __func__);
 
 	if ((revents & EPOLLIN) == 0)
 		goto done;
 
 	if (revents & EPOLLHUP) {
-		AFB_ApiInfo(plugin->api, "Lost connection with bluealsa on interface %s", watch->interface);
+		AFB_API_INFO(plugin->api, "Lost connection with bluealsa on interface %s", watch->interface);
 		sd_event_source_unref(src);
 		close(fd);
 		halBlueAlsaRegister(plugin, watch->interface);
@@ -188,7 +188,7 @@ static int halBlueAlsaTransportEventCB(sd_event_source* src, int fd, uint32_t re
 		continue;
 
 	if (ret != sizeof(event)) {
-		AFB_ApiError(plugin->api, "Couldn't read event: %s", strerror(ret == -1 ? errno : EBADMSG));
+		AFB_API_ERROR(plugin->api, "Couldn't read event: %s", strerror(ret == -1 ? errno : EBADMSG));
 		goto done;
 	}
 
@@ -461,7 +461,7 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 		delayms = pluginData->a2dp.delayms;
 		playbackZoneS = pluginData->a2dp.zone;
 	} else {
-		AFB_ApiError(plugin->api, "%s: unsupported transport type", __func__ );
+		AFB_API_ERROR(plugin->api, "%s: unsupported transport type", __func__ );
 		goto fail;
 	}
 
@@ -556,8 +556,8 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 	/* In softmixer, this will create a transaction verb (whose name is transactionUidS),
 	 * will be used later to destroy all the created objects upon transport removal */
 
-	if (AFB_ServiceSync(plugin->api, SMIXER_API_NAME, "attach", requestJ, &returnJ)) {
-		AFB_ApiError(plugin->api, "Error calling attach verb of mixer" );
+	if (afb_api_call_sync_legacy(plugin->api, SMIXER_API_NAME, "attach", requestJ, &returnJ)) {
+		AFB_API_ERROR(plugin->api, "Error calling attach verb of mixer" );
 		goto done;
 	}
 
@@ -572,7 +572,7 @@ static int halBlueAlsaAttachTransportStreams(bluealsa_transport_t * transport) {
 fail:
 	return -1;
 done:
-	AFB_ApiDebug(plugin->api, "DONE.");
+	AFB_API_DEBUG(plugin->api, "DONE.");
 	return ret;
 }
 
@@ -583,7 +583,7 @@ static int halBluezAlsaRemoveTransportStream(bluealsa_transport_t * transport) {
 	json_object* requestJ = NULL;
 	json_object* returnJ = NULL;
 
-	AFB_ApiInfo(plugin->api, "Call transaction detach verb %s", transport->transactionUidS);
+	AFB_API_INFO(plugin->api, "Call transaction detach verb %s", transport->transactionUidS);
 	if (transport->transactionUidS == NULL)
 		goto fail;
 
@@ -593,8 +593,8 @@ static int halBluezAlsaRemoveTransportStream(bluealsa_transport_t * transport) {
 
 	json_object_object_add(requestJ, "action", json_object_new_string("remove"));
 
-	if (AFB_ServiceSync(plugin->api, SMIXER_API_NAME, transport->transactionUidS, requestJ, &returnJ)) {
-		AFB_ApiError(plugin->api, "Error calling attach verb of mixer" );
+	if (afb_api_call_sync_legacy(plugin->api, SMIXER_API_NAME, transport->transactionUidS, requestJ, &returnJ)) {
+		AFB_API_ERROR(plugin->api, "Error calling attach verb of mixer" );
 		goto fail;
 	}
 
@@ -616,14 +616,14 @@ static int halBlueAlsaFetchTransports(bluealsa_watch * watch) {
 	bluealsa_transport_t * transport_list = &pluginData->transport_list;
 	bluealsa_transport_t * transport = NULL;
 
-	AFB_ApiDebug(plugin->api, "Fetching available transports of interface %s", watch->interface);
+	AFB_API_DEBUG(plugin->api, "Fetching available transports of interface %s", watch->interface);
 
 	if ((nbTransports = bluealsa_get_transports(watch->fd, &transports)) == -1) {
-		AFB_ApiError(plugin->api, "Couldn't get transports: %s", strerror(errno));
+		AFB_API_ERROR(plugin->api, "Couldn't get transports: %s", strerror(errno));
 		goto done;
 	}
 
-	AFB_ApiDebug(plugin->api, "Got %zu transport(s)", nbTransports);
+	AFB_API_DEBUG(plugin->api, "Got %zu transport(s)", nbTransports);
 
 	for (int ix=0; ix<nbTransports; ix++) {
 		char addr[18];
@@ -637,27 +637,27 @@ static int halBlueAlsaFetchTransports(bluealsa_watch * watch) {
 		else
 			typeS = "unknown";
 
-		AFB_ApiDebug(plugin->api, "Transport %d: type %s, dev %s", ix, typeS, addr);
+		AFB_API_DEBUG(plugin->api, "Transport %d: type %s, dev %s", ix, typeS, addr);
 
 		if (halBlueAlsaTransportFind(watch, transport_list, ba_transport)) {
-			AFB_ApiDebug(plugin->api, "This transport is already streamed");
+			AFB_API_DEBUG(plugin->api, "This transport is already streamed");
 			continue;
 		}
 
-		AFB_ApiInfo(plugin->api, "Registering transport type %s, dev %s", typeS, addr);
+		AFB_API_INFO(plugin->api, "Registering transport type %s, dev %s", typeS, addr);
 		transport = halBlueAlsaTransportsAdd(watch, transport_list, ba_transport);
 		if (transport == NULL) {
-			AFB_ApiError(plugin->api, "Failed to register this transport");
+			AFB_API_ERROR(plugin->api, "Failed to register this transport");
 			goto done;
 		}
 
 		// Do the softmixer stuff
 		if (halBlueAlsaAttachTransportStreams(transport) != 0) {
-			AFB_ApiError(plugin->api, "Failed create transport streams");
+			AFB_API_ERROR(plugin->api, "Failed create transport streams");
 			goto done;
 		}
 
-		AFB_ApiDebug(plugin->api, "%s: transaction id %s", __func__, transport->transactionUidS);
+		AFB_API_DEBUG(plugin->api, "%s: transaction id %s", __func__, transport->transactionUidS);
 
 	}
 
@@ -673,7 +673,7 @@ static int halBlueAlsaRegister(CtlPluginT* plugin, const char * interface) {
     sd_event *sdLoop;
     sd_event_source* evtsrc;
 
-    sdLoop = AFB_GetEventLoop(plugin->api);
+    sdLoop = afb_api_get_event_loop(plugin->api);
 
     enum ba_event transport_mask = BA_EVENT_TRANSPORT_ADDED |
 //    							   BA_EVENT_TRANSPORT_CHANGED |
@@ -687,20 +687,20 @@ static int halBlueAlsaRegister(CtlPluginT* plugin, const char * interface) {
     watch->plugin    = plugin;
 
     if ((watch->fd = bluealsa_open(interface)) == -1) {
-    	AFB_ApiError(plugin->api, "BlueALSA connection failed: %s", strerror(errno));
+        AFB_API_ERROR(plugin->api, "BlueALSA connection failed: %s", strerror(errno));
     	goto fail;
     }
 
 	halBlueAlsaFetchTransports(watch);
 
     if (bluealsa_subscribe(watch->fd, transport_mask) == -1) {
-    	AFB_ApiError(plugin->api, "BlueALSA subscription failed: %s", strerror(errno));
+        AFB_API_ERROR(plugin->api, "BlueALSA subscription failed: %s", strerror(errno));
     	goto fail;
     }
 
     // Register sound event to the main loop of the binder
     if ((ret = sd_event_add_io(sdLoop, &evtsrc, watch->fd, EPOLLIN, halBlueAlsaTransportEventCB, watch)) < 0) {
-        AFB_ApiError(plugin->api,
+        AFB_API_ERROR(plugin->api,
         		     "%s: Failed to register event fd to io loop",
 					 __func__);
         goto fail;