X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=bindings%2Fsamples%2Fhello3.c;h=3a6c9ad92077c3f785b4080bba7bfb974abd0576;hb=65353dce81a629e042800bb7b86fcd869a76727e;hp=477e47bd1c5c7256891749ae6710a14349e7ed1a;hpb=e17ae412245ba9afb33ff6a0f1f665b4d66d4da4;p=src%2Fapp-framework-binder.git diff --git a/bindings/samples/hello3.c b/bindings/samples/hello3.c index 477e47bd..3a6c9ad9 100644 --- a/bindings/samples/hello3.c +++ b/bindings/samples/hello3.c @@ -1,5 +1,5 @@ /* - * Copyright (C) 2015-2018 "IoT.bzh" + * Copyright (C) 2015-2020 "IoT.bzh" * Author "Fulup Ar Foll" * * Licensed under the Apache License, Version 2.0 (the "License"); @@ -19,6 +19,8 @@ #include #include #include +#include +#include #include #include #include @@ -29,7 +31,7 @@ #include #if !defined(APINAME) -#define APINAME "hello3" +#define APINAME "hello" #endif static pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER; @@ -422,7 +424,7 @@ static void broadcast(afb_req_t request) afb_req_success(request, NULL, NULL); pthread_mutex_unlock(&mutex); } else if (name != NULL) { - if (0 > afb_daemon_broadcast_event(name, object)) + if (0 > afb_daemon_broadcast_event(name, json_object_get(object))) afb_req_fail(request, "failed", "broadcast error"); else afb_req_success(request, NULL, NULL); @@ -467,6 +469,11 @@ static void setloa (afb_req_t request) afb_req_reply_f(request, NULL, NULL, "LOA set to %d", loa); } +static void ok (afb_req_t request) +{ + afb_req_reply_f(request, NULL, NULL, NULL); +} + static void setctx (afb_req_t request) { struct json_object *x = afb_req_json(request); @@ -530,6 +537,35 @@ static void ref(afb_req_t request) afb_req_unref(request); } +static void mute(afb_req_t request) +{ +} + +static void mutebug(afb_req_t request) +{ + afb_req_addref(request); +} + +void queue_cb(int signum, void *arg) +{ + afb_req_t request = arg; + afb_req_reply(request, NULL, NULL, NULL); + afb_req_unref(request); +} + +static void queue(afb_req_t request) +{ + afb_req_addref(request); + afb_api_queue_job(afb_req_get_api(request), queue_cb, request, NULL, 0); +} + +static void settings(afb_req_t request) +{ + afb_api_t api = afb_req_get_api(request); + struct json_object *object = afb_api_settings(api); + afb_req_reply(request, json_object_get(object), NULL, NULL); +} + static void rootdir (afb_req_t request) { ssize_t s; @@ -584,8 +620,162 @@ static void locale (afb_req_t request) } } +static void in_after (afb_req_t request) +{ + int rc; + const char *ts, *ty; + char *te; + double td; + struct timespec t; + + /* get the type */ + ty = afb_req_value(request, "type") ?: "call"; + if (strcmp(ty, "call") && strcmp(ty, "callsync") + && strcmp(ty, "subcall") && strcmp(ty, "subcallsync")) + return afb_req_reply(request, NULL, "invalid", "bad type"); + + /* get the delay */ + ts = afb_req_value(request, "delay"); + if (!ts) + return afb_req_reply(request, NULL, "invalid", "no delay"); + td = strtod(ts, &te); + if (*te || td < 0 || td > 3e6) /* a month is the biggest accepted */ + return afb_req_reply(request, NULL, "invalid", "bad delay"); + + /* wait for that time */ + if (td > 0) { + t.tv_nsec = (long)(1e6 * modf(td, &td)); + t.tv_sec = (time_t)td; + do { + rc = nanosleep(&t, &t); + } while (rc != 0 && errno == EINTR); + + if (rc) + return afb_req_reply(request, NULL, "error", "sleep failed"); + } + + /* do the call */ + if (!strcmp(ty, "subcallsync")) + subcall(request); + else if (!strcmp(ty, "subcall")) + subcallsync(request); + else if (!strcmp(ty, "callsync")) + callsync(request); + else + call(request); +} + +static void *thread_after (void *closure) +{ + afb_req_t request = closure; + in_after (request); + afb_req_unref(request); + return NULL; +} + +static void after (afb_req_t request) +{ + int rc; + pthread_t tid; + pthread_attr_t attr; + + afb_req_addref(request); + + pthread_attr_init(&attr); + pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); + rc =pthread_create(&tid, &attr, thread_after, request); + pthread_attr_destroy(&attr); + + if (rc != 0) { + afb_req_unref(request); + afb_req_reply(request, NULL, "cant-start", NULL); + } +} + static void api (afb_req_t request); +/** + * Definition of an authorization entry + */ +static struct afb_auth auths[] = { + { /* 0 */ + .type = afb_auth_Or, + .first = &auths[1], + .next = &auths[9], + }, + { /* 1 */ + .type = afb_auth_And, + .first = &auths[2], + .next = &auths[3], + }, + { /* 2 */ + .type = afb_auth_Yes + }, + { /* 3 */ + .type = afb_auth_And, + .first = &auths[4], + .next = &auths[5], + }, + { /* 4 */ + .type = afb_auth_LOA, + .loa = 0 + }, + { /* 5 */ + .type = afb_auth_Or, + .first = &auths[6], + .next = &auths[7], + }, + { /* 6 */ + .type = afb_auth_No + }, + { /* 7 */ + .type = afb_auth_Not, + .first = &auths[8] + }, + { /* 8 */ + .type = afb_auth_Yes + }, + { /* 9 */ + .type = afb_auth_And, + .first = &auths[10], + .next = &auths[13], + }, + { /* 10 */ + .type = afb_auth_Or, + .first = &auths[12], + .next = &auths[11], + }, + { /* 11 */ + .type = afb_auth_Not, + .first = &auths[13] + }, + { /* 12 */ + .type = afb_auth_Token + }, + { /* 13 */ + .type = afb_auth_And, + .first = &auths[14], + .next = &auths[17], + }, + { /* 14 */ + .type = afb_auth_Or, + .first = &auths[16], + .next = &auths[15], + }, + { /* 15 */ + .type = afb_auth_Not, + .first = &auths[16] + }, + { /* 16 */ + .type = afb_auth_Permission, + .text = "permission" + }, + { /* 17 */ + .type = afb_auth_Yes + } +}; + + // NOTE: this sample does not use session to keep test a basic as possible // in real application most APIs should be protected with AFB_SESSION_CHECK static const struct afb_verb_v3 verbs[]= { @@ -611,11 +801,16 @@ static const struct afb_verb_v3 verbs[]= { { .verb="appid", .callback=appid }, { .verb="uid", .callback=uid }, { .verb="exit", .callback=exitnow }, - { .verb="close", .callback=closess }, - { .verb="set-loa", .callback=setloa }, + { .verb="close", .callback=closess, .session=AFB_SESSION_CLOSE }, + { .verb="set-loa", .callback=setloa, .auth = &auths[0] }, + { .verb="has-loa-1", .callback=ok, .session=AFB_SESSION_LOA_1 }, + { .verb="has-loa-2", .callback=ok, .session=AFB_SESSION_LOA_2 }, + { .verb="has-loa-3", .callback=ok, .session=AFB_SESSION_LOA_3 }, { .verb="setctx", .callback=setctx, .vcbdata = (void*)(intptr_t)1 }, { .verb="setctxif", .callback=setctx, .vcbdata = (void*)(intptr_t)0 }, { .verb="getctx", .callback=getctx }, + { .verb="checktok", .callback=ok, .session=AFB_SESSION_CHECK }, + { .verb="reftok", .callback=ok, .session=AFB_SESSION_CHECK | AFB_SESSION_REFRESH }, { .verb="info", .callback=info }, { .verb="eventloop", .callback=eventloop }, { .verb="dbus", .callback=dbus }, @@ -625,6 +820,11 @@ static const struct afb_verb_v3 verbs[]= { { .verb="rootdir", .callback=rootdir}, { .verb="locale", .callback=locale}, { .verb="api", .callback=api}, + { .verb="mute", .callback=mute}, + { .verb="mutebug", .callback=mutebug}, + { .verb="queue", .callback=queue}, + { .verb="settings", .callback=settings}, + { .verb="after", .callback=after}, { .verb=NULL} }; @@ -713,6 +913,7 @@ static void api (afb_req_t request) } sapi->api = afb_api_new_api(api, apiname, NULL, 1, apipreinit, NULL); if (!sapi->api) { + free(sapi); afb_req_reply_f(request, NULL, "cant-create", "%m"); goto end; }