afm-binding: use binding api v3
[src/app-framework-main.git] / src / afm-user-daemon.c
index aa5ed83..22c3d81 100644 (file)
@@ -1,5 +1,5 @@
 /*
- Copyright 2015, 2016, 2017 IoT.bzh
+ Copyright (C) 2015-2018 IoT.bzh
 
  author: José Bollo <jose.bollo@iot.bzh>
 
 #include <afb/afb-ws-client.h>
 #include <afb/afb-proto-ws.h>
 
-#include "afm.h"
 #include "verbose.h"
 #include "utils-jbus.h"
 #include "utils-json.h"
 
+#define AFM_USER_DBUS_PATH     "/org/AGL/afm/user"
+
 /*
  * name of the application
  */
@@ -112,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,
 };
 
@@ -155,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)