X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafm-user-daemon.c;h=732c1c65bc189aa39d96d9b18cc88e6169e603fd;hb=2a319cf90daa6e3b01e8139923f7073e1c9bcf28;hp=324e9a839462b21cde785e6a2342e210c1054adc;hpb=63c180a63657bc7dd55bab423ea0c2751c87310b;p=src%2Fapp-framework-main.git

diff --git a/src/afm-user-daemon.c b/src/afm-user-daemon.c
index 324e9a8..732c1c6 100644
--- a/src/afm-user-daemon.c
+++ b/src/afm-user-daemon.c
@@ -1,5 +1,5 @@
 /*
- Copyright (C) 2015-2018 IoT.bzh
+ Copyright (C) 2015-2019 IoT.bzh
 
  author: José Bollo <jose.bollo@iot.bzh>
 
@@ -48,7 +48,7 @@ static const char versionstr[] =
 	"\n"
 	"  %s  version="AFM_VERSION"\n"
 	"\n"
-	"  Copyright (C) 2015, 2016, 2017 \"IoT.bzh\"\n"
+	"  Copyright (C) 2015-2019 \"IoT.bzh\"\n"
 	"  AFB comes with ABSOLUTELY NO WARRANTY.\n"
 	"  Licence Apache 2\n"
 	"\n";
@@ -113,14 +113,23 @@ static const char *uri;
  * 
  */
 static void on_pws_hangup(void *closure);
-static void on_pws_reply_success(void *closure, void *request, struct json_object *result, const char *info);
-static void on_pws_reply_fail(void *closure, void *request, const char *status, const char *info);
+static void on_pws_reply(void *closure, void *request, struct json_object *obj, const char *error, const char *info);
+#if !defined(AFB_PROTO_WS_VERSION) || (AFB_PROTO_WS_VERSION < 3)
+static void on_pws_reply_success(void *closure, void *request, struct json_object *result, const char *info)
+	{ on_pws_reply(closure, request, result, NULL, info); }
+static void on_pws_reply_fail(void *closure, void *request, const char *error, const char *info)
+	{ on_pws_reply(closure, request, NULL, error, info); }
+#endif
 static void on_pws_event_broadcast(void *closure, const char *event_name, struct json_object *data);
 
 /* the callback interface for pws */
 static struct afb_proto_ws_client_itf pws_itf = {
+#if !defined(AFB_PROTO_WS_VERSION) || (AFB_PROTO_WS_VERSION < 3)
 	.on_reply_success = on_pws_reply_success,
 	.on_reply_fail = on_pws_reply_fail,
+#else
+	.on_reply = on_pws_reply,
+#endif
 	.on_event_broadcast = on_pws_event_broadcast,
 };
 
@@ -156,16 +165,13 @@ static void attempt_connect_pws(int count)
 	}
 }
 
-static void on_pws_reply_success(void *closure, void *request, struct json_object *result, const char *info)
-{
-	struct sd_bus_message *smsg = request;
-	jbus_reply_j(smsg, result);
-}
-
-static void on_pws_reply_fail(void *closure, void *request, const char *status, const char *info)
+static void on_pws_reply(void *closure, void *request, struct json_object *obj, const char *error, const char *info)
 {
 	struct sd_bus_message *smsg = request;
-	jbus_reply_error_s(smsg, status);
+	if (error)
+		jbus_reply_error_s(smsg, error);
+	else
+		jbus_reply_j(smsg, obj);
 }
 
 static void on_pws_event_broadcast(void *closure, const char *event_name, struct json_object *data)
@@ -187,12 +193,17 @@ static void propagate(struct sd_bus_message *smsg, struct json_object *obj, void
 {
 	int rc;
 	const char *verb = closure;
+	const char *onbehalf = NULL; /* TODO: on behalf of the client */
 
 	INFO("method %s propagated for %s", verb, json_object_to_json_string(obj));
 	if (!pws)
 		jbus_reply_error_s(smsg, "disconnected");
 	else {
+#if defined(AFB_PROTO_WS_VERSION) && (AFB_PROTO_WS_VERSION >= 3)
+		rc = afb_proto_ws_client_call(pws, verb, obj, sessionid, smsg, onbehalf);
+#else
 		rc = afb_proto_ws_client_call(pws, verb, obj, sessionid, smsg);
+#endif
 		if (rc < 0)
 			ERROR("calling %s(%s) failed: %m\n", verb, json_object_to_json_string(obj));
 	}