X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-client-demo.c;h=b1191044b3cbe31237f1479b20d8b6589e1abb74;hb=a63851bb4726c89d9a3c5755d78d1c4bbc3f3b2e;hp=349a027449c2730951ef3bf471577d3fff0a5e31;hpb=c7e9786d408f13d8f8f43c6b68da916bbb1ed5f3;p=src%2Fapp-framework-binder.git diff --git a/src/afb-client-demo.c b/src/afb-client-demo.c index 349a0274..b1191044 100644 --- a/src/afb-client-demo.c +++ b/src/afb-client-demo.c @@ -1,5 +1,5 @@ -/* - * Copyright (C) 2015, 2016 "IoT.bzh" +/* + * Copyright (C) 2015, 2016, 2017 "IoT.bzh" * Author "Fulup Ar Foll" * Author José Bollo * @@ -29,93 +29,165 @@ #include #include +#include -#include "afb-common.h" #include "afb-wsj1.h" #include "afb-ws-client.h" +/* declaration of functions */ static void on_hangup(void *closure, struct afb_wsj1 *wsj1); static void on_call(void *closure, const char *api, const char *verb, struct afb_wsj1_msg *msg); static void on_event(void *closure, const char *event, struct afb_wsj1_msg *msg); static int io_event_callback(sd_event_source *src, int fd, uint32_t revents, void *closure); static void emit(const char *api, const char *verb, const char *object); +/* the callback interface for wsj1 */ static struct afb_wsj1_itf itf = { .on_hangup = on_hangup, .on_call = on_call, .on_event = on_event }; +/* global variables */ static struct afb_wsj1 *wsj1; static int exonrep; static int callcount; +static int human; +static int raw; static sd_event_source *evsrc; +/* print usage of the program */ static void usage(int status, char *arg0) { char *name = strrchr(arg0, '/'); name = name ? name + 1 : arg0; - fprintf(status ? stderr : stdin, "usage: %s uri [api verb data]\n", name); + fprintf(status ? stderr : stdout, "usage: %s [-H [-r]] uri [api verb [data]]\n", name); exit(status); } +/* entry function */ int main(int ac, char **av, char **env) { - if (ac != 2 && ac != 5) - usage(1, av[0]); - if (!strcmp(av[1], "-h") || !strcmp(av[1], "--help")) - usage(0, av[0]); + int rc; + char *a0; + sd_event *loop; + + /* get the program name */ + a0 = av[0]; + + /* check options */ + while (ac > 1 && av[1][0] == '-') { + if (av[1][1] == '-') { + /* long option */ + + if (!strcmp(av[1], "--human")) /* request for human output */ + human = 1; + + else if (!strcmp(av[1], "--raw")) /* request for raw output */ + raw = 1; + + /* emit usage and exit */ + else + usage(!!strcmp(av[1], "--help"), a0); + } else { + /* short option(s) */ + for (rc = 1 ; av[1][rc] ; rc++) + switch (av[1][rc]) { + case 'H': human = 1; break; + case 'r': raw = 1; break; + default: usage(av[1][rc] != 'h', a0); + } + } + av++; + ac--; + } + + /* check the argument count */ + if (ac != 2 && ac != 4 && ac != 5) + usage(1, a0); + + /* set raw by default */ + if (!human) + raw = 1; - wsj1 = afb_ws_client_connect_wsj1(av[1], &itf, NULL); + /* get the default event loop */ + rc = sd_event_default(&loop); + if (rc < 0) { + fprintf(stderr, "connection to default event loop failed: %s\n", strerror(-rc)); + return 1; + } + + /* connect the websocket wsj1 to the uri given by the first argument */ + wsj1 = afb_ws_client_connect_wsj1(loop, av[1], &itf, NULL); if (wsj1 == NULL) { fprintf(stderr, "connection to %s failed: %m\n", av[1]); return 1; } + /* test the behaviour */ if (ac == 2) { + /* get requests from stdin */ fcntl(0, F_SETFL, O_NONBLOCK); - sd_event_add_io(afb_common_get_event_loop(), &evsrc, 0, EPOLLIN, io_event_callback, NULL); + sd_event_add_io(loop, &evsrc, 0, EPOLLIN, io_event_callback, NULL); } else { + /* the request is defined by the arguments */ exonrep = 1; emit(av[2], av[3], av[4]); } + + /* loop until end */ for(;;) - sd_event_run(afb_common_get_event_loop(), 30000000); + sd_event_run(loop, 30000000); return 0; } +/* called when wsj1 hangsup */ static void on_hangup(void *closure, struct afb_wsj1 *wsj1) { printf("ON-HANGUP\n"); + fflush(stdout); exit(0); } +/* called when wsj1 receives a method invocation */ static void on_call(void *closure, const char *api, const char *verb, struct afb_wsj1_msg *msg) { int rc; - printf("ON-CALL %s/%s(%s)\n", api, verb, afb_wsj1_msg_object_s(msg)); + if (raw) + printf("ON-CALL %s/%s(%s)\n", api, verb, afb_wsj1_msg_object_s(msg)); + if (human) + printf("ON-CALL %s/%s:\n%s\n", api, verb, + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); rc = afb_wsj1_reply_error_s(msg, "\"unimplemented\"", NULL); if (rc < 0) fprintf(stderr, "replying failed: %m\n"); } +/* called when wsj1 receives an event */ static void on_event(void *closure, const char *event, struct afb_wsj1_msg *msg) { - printf("ON-EVENT %s(%s)\n", event, afb_wsj1_msg_object_s(msg)); -} - -static void event(const char *event, const char *object) -{ - int rc; - - rc = afb_wsj1_send_event_s(wsj1, event, object); - if (rc < 0) - fprintf(stderr, "sending !%s(%s) failed: %m\n", event, object); + if (raw) + printf("ON-EVENT %s(%s)\n", event, afb_wsj1_msg_object_s(msg)); + if (human) + printf("ON-EVENT %s:\n%s\n", event, + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); } +/* called when wsj1 receives a reply */ static void on_reply(void *closure, struct afb_wsj1_msg *msg) { - printf("ON-REPLY %s: %s\n", (char*)closure, afb_wsj1_msg_object_s(msg)); + if (raw) + printf("ON-REPLY %s: %s\n", (char*)closure, afb_wsj1_msg_object_s(msg)); + if (human) + printf("ON-REPLY %s: %s\n%s\n", (char*)closure, + afb_wsj1_msg_is_reply_ok(msg) ? "OK" : "ERROR", + json_object_to_json_string_ext(afb_wsj1_msg_object_j(msg), + JSON_C_TO_STRING_PRETTY)); + fflush(stdout); free(closure); callcount--; if (exonrep && !callcount) @@ -123,13 +195,17 @@ static void on_reply(void *closure, struct afb_wsj1_msg *msg) exit(0); } +/* makes a call */ static void call(const char *api, const char *verb, const char *object) { static int num = 0; char *key; int rc; + /* allocates an id for the request */ rc = asprintf(&key, "%d:%s/%s", ++num, api, verb); + + /* send the request */ callcount++; rc = afb_wsj1_call_s(wsj1, api, verb, object, on_reply, key); if (rc < 0) { @@ -138,14 +214,28 @@ static void call(const char *api, const char *verb, const char *object) } } +/* sends an event */ +static void event(const char *event, const char *object) +{ + int rc; + + rc = afb_wsj1_send_event_s(wsj1, event, object); + if (rc < 0) + fprintf(stderr, "sending !%s(%s) failed: %m\n", event, object); +} + +/* emits either a call (when api!='!') or an event */ static void emit(const char *api, const char *verb, const char *object) { + if (object == NULL || object[0] == 0) + object = "null"; if (api[0] == '!' && api[1] == 0) event(verb, object); else call(api, verb, object); } +/* called when something happens on stdin */ static int io_event_callback(sd_event_source *src, int fd, uint32_t revents, void *closure) { static size_t count = 0; @@ -171,7 +261,7 @@ static int io_event_callback(sd_event_source *src, int fd, uint32_t revents, voi count += (size_t)rc; /* normalise the buffer content */ - /* TODO: handle backspace \x7f */ + /* TODO: handle backspace \x7f ? */ /* process the lines */ pos = 0; @@ -186,9 +276,13 @@ static int io_event_callback(sd_event_source *src, int fd, uint32_t revents, voi rest[0] = i; while(i < count && line[i] != '\n') i++; rest[1] = i; if (i == count) break; line[i++] = 0; - if (api[0] == api[1] || verb[0] == verb[1] || rest[0] == rest[1]) - fprintf(stderr, "bad line: %s\n", line+pos); - else { + if (api[0] == api[1]) { + /* empty line */ + } else if (line[api[0]] == '#') { + /* comment */ + } else if (verb[0] == verb[1]) { + fprintf(stderr, "verb missing, bad line: %s\n", line+pos); + } else { line[api[1]] = line[verb[1]] = 0; emit(line + api[0], line + verb[0], line + rest[0]); }