X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafm-user-daemon.c;h=14977b0111f72582cacaefc528ada75223bfc015;hb=b13e73d8452f5e40a8465b37b22e8a299fb036ae;hp=7c7824d69575f5c481c4cbe61642e6ac3bb056b6;hpb=550ca0ae2bb9138c85fda941b67d4db1da1609ed;p=src%2Fapp-framework-main.git diff --git a/src/afm-user-daemon.c b/src/afm-user-daemon.c index 7c7824d..14977b0 100644 --- a/src/afm-user-daemon.c +++ b/src/afm-user-daemon.c @@ -1,5 +1,5 @@ /* - Copyright 2015, 2016, 2017 IoT.bzh + Copyright (C) 2015-2018 IoT.bzh author: José Bollo @@ -16,6 +16,7 @@ limitations under the License. */ +#define _GNU_SOURCE #include #include #include @@ -26,438 +27,186 @@ #include #include +#include +#include + #include "verbose.h" #include "utils-jbus.h" #include "utils-json.h" -#include "afm.h" -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD -# include "afm-db.h" -#else -# include "afm-udb.h" -#endif -#include "afm-launch-mode.h" -#include "afm-run.h" + +#define AFM_USER_DBUS_PATH "/org/AGL/afm/user" /* * name of the application */ static const char appname[] = "afm-user-daemon"; +/* + * string for printing version + */ +static const char versionstr[] = + "\n" + " %s version="AFM_VERSION"\n" + "\n" + " Copyright (C) 2015, 2016, 2017 \"IoT.bzh\"\n" + " AFB comes with ABSOLUTELY NO WARRANTY.\n" + " Licence Apache 2\n" + "\n"; + /* * string for printing usage */ static const char usagestr[] = -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - "usage: %s [-q] [-v] [-m mode] [-r rootdir]... [-a appdir]...\n" - "\n" - " -a appdir adds an application directory\n" - " -r rootdir adds a root directory of applications\n" - " -m mode set default launch mode (local or remote)\n" -#else - "usage: %s [option(s)]\n" + "usage: %s [option(s)] afm-main-uri\n" "\n" -#endif " -d run as a daemon\n" " -u addr address of user D-Bus to use\n" - " -s addr address of system D-Bus to use\n" " -q quiet\n" " -v verbose\n" + " -V version\n" "\n"; /* * Option definition for getopt_long */ -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD -static const char options_s[] = "hdqvr:a:m:"; -static struct option options_l[] = { - { "root", required_argument, NULL, 'r' }, - { "application", required_argument, NULL, 'a' }, - { "mode", required_argument, NULL, 'm' }, -#else -static const char options_s[] = "hdqv"; +static const char options_s[] = "hdqvVu:"; static struct option options_l[] = { -#endif { "user-dbus", required_argument, NULL, 'u' }, - { "system-dbus", required_argument, NULL, 's' }, { "daemon", no_argument, NULL, 'd' }, { "quiet", no_argument, NULL, 'q' }, { "verbose", no_argument, NULL, 'v' }, { "help", no_argument, NULL, 'h' }, + { "version", no_argument, NULL, 'V' }, { NULL, 0, NULL, 0 } }; /* - * Connections to D-Bus - * This is an array for using the function - * jbus_read_write_dispatch_multiple - * directly without transformations. - */ -static struct jbus *jbuses[2]; -#define system_bus jbuses[0] -#define user_bus jbuses[1] - -/* - * Handle to the database of applications - */ -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD -static struct afm_db *afdb; -#else -static struct afm_udb *afudb; -#endif - -/* - * Returned error strings - */ -const char error_nothing[] = "[]"; -const char error_bad_request[] = "\"bad request\""; -const char error_not_found[] = "\"not found\""; -const char error_cant_start[] = "\"can't start\""; -const char error_system[] = "\"system error\""; - - -/* - * retrieves the 'runid' in 'obj' parameters received with the - * request 'smsg' for the 'method'. - * - * Returns 1 in case of success. - * Otherwise, if the 'runid' can't be retrived, an error stating - * the bad request is replied for 'smsg' and 0 is returned. - */ -static int onrunid(struct sd_bus_message *smsg, struct json_object *obj, - const char *method, int *runid) -{ - if (!j_read_integer(obj, runid) - && !j_read_integer_at(obj, "runid", runid)) { - INFO("bad request method %s: %s", method, - json_object_to_json_string(obj)); - jbus_reply_error_s(smsg, error_bad_request); - return 0; - } - - INFO("method %s called for %d", method, *runid); - return 1; -} - -/* - * Sends the reply 'resp' to the request 'smsg' if 'resp' is not NULL. - * Otherwise, when 'resp' is NULL replies the error string 'errstr'. - */ -static void reply(struct sd_bus_message *smsg, struct json_object *resp, - const char *errstr) -{ - if (resp) - jbus_reply_j(smsg, resp); - else - jbus_reply_error_s(smsg, errstr); -} - -/* - * Sends the reply "true" to the request 'smsg' if 'status' is zero. - * Otherwise, when 'status' is not zero replies the error string 'errstr'. - */ -static void reply_status(struct sd_bus_message *smsg, int status, const char *errstr) -{ - if (status) - jbus_reply_error_s(smsg, errstr); - else - jbus_reply_s(smsg, "true"); -} - -/* - * On query "runnables" from 'smsg' with parameters of 'obj'. - * - * Nothing is expected in 'obj' that can be anything. + * The methods propagated */ -static void on_runnables(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - struct json_object *resp; - INFO("method runnables called"); -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - resp = afm_db_application_list(afdb); -#else - resp = afm_udb_applications_public(afudb); -#endif - jbus_reply_j(smsg, resp); - json_object_put(resp); -} +static const char *methods[] = { + "runnables", + "detail", + "start", + "once", + "terminate", + "pause", + "resume", + "stop", + "continue", + "runners", + "state", + "install", + "uninstall", + NULL +}; /* - * On query "detail" from 'smsg' with parameters of 'obj'. + * Connections */ -static void on_detail(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - const char *appid; - struct json_object *resp; - - /* get the parameters */ - if (j_read_string(obj, &appid)) - ; /* appid as a string */ - else if (j_read_string_at(obj, "id", &appid)) - ; /* appid as obj.id string */ - else { - INFO("method detail called but bad request!"); - jbus_reply_error_s(smsg, error_bad_request); - return; - } - - /* wants details for appid */ - INFO("method detail called for %s", appid); -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - resp = afm_db_get_application_public(afdb, appid); -#else - resp = afm_udb_get_application_public(afudb, appid); -#endif - reply(smsg, resp, error_not_found); - json_object_put(resp); -} +static struct sd_event *evloop; +static struct jbus *user_bus; +static struct afb_proto_ws *pws; +static char *sessionid; +static const char *uri; /* - * On query "start" from 'smsg' with parameters of 'obj'. + * */ -static void on_start(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - const char *appid, *modestr; - char *uri; - struct json_object *appli, *resp; - int runid; - char runidstr[20]; - enum afm_launch_mode mode; - - /* get the parameters */ - mode = invalid_launch_mode; - if (j_read_string(obj, &appid)) { - mode = get_default_launch_mode(); - } else if (j_read_string_at(obj, "id", &appid)) { - if (j_read_string_at(obj, "mode", &modestr)) { - mode = launch_mode_of_name(modestr); - } else { - mode = get_default_launch_mode(); - } - } - if (!is_valid_launch_mode(mode)) { - jbus_reply_error_s(smsg, error_bad_request); - return; - } - - /* get the application */ - INFO("method start called for %s mode=%s", appid, - name_of_launch_mode(mode)); -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - appli = afm_db_get_application(afdb, appid); -#else - appli = afm_udb_get_application_private(afudb, appid); +static void on_pws_hangup(void *closure); +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 - if (appli == NULL) { - jbus_reply_error_s(smsg, error_not_found); - return; - } - - /* launch the application */ - uri = NULL; - runid = afm_run_start(appli, mode, &uri); - if (runid <= 0) { - jbus_reply_error_s(smsg, error_cant_start); - free(uri); - return; - } - - if (uri == NULL) { - /* returns only the runid */ - snprintf(runidstr, sizeof runidstr, "%d", runid); - runidstr[sizeof runidstr - 1] = 0; - jbus_reply_s(smsg, runidstr); - return; - } - - /* returns the runid and its uri */ - resp = json_object_new_object(); - if (resp != NULL && j_add_integer(resp, "runid", runid) - && j_add_string(resp, "uri", uri)) - jbus_reply_j(smsg, resp); - else { - afm_run_terminate(runid); - jbus_reply_error_s(smsg, error_system); - } - json_object_put(resp); - free(uri); -} - -/* - * On query "once" from 'smsg' with parameters of 'obj'. - */ -static void on_once(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - const char *appid; - struct json_object *appli, *resp; - int runid; - - /* get the parameters */ - if (!j_read_string(obj, &appid) && !j_read_string_at(obj, "id", &appid)) { - jbus_reply_error_s(smsg, error_bad_request); - return; - } +static void on_pws_event_broadcast(void *closure, const char *event_name, struct json_object *data); - /* get the application */ - INFO("method once called for %s", appid); -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - appli = afm_db_get_application(afdb, appid); +/* 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 - appli = afm_udb_get_application_private(afudb, appid); + .on_reply = on_pws_reply, #endif - if (appli == NULL) { - jbus_reply_error_s(smsg, error_not_found); - return; - } - - /* launch the application */ - runid = afm_run_once(appli); - if (runid <= 0) { - jbus_reply_error_s(smsg, error_cant_start); - return; - } - - /* returns the state */ - resp = afm_run_state(runid); - reply(smsg, resp, error_not_found); - json_object_put(resp); -} - -/* - * On query "pause" from 'smsg' with parameters of 'obj'. - */ -static void on_pause(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - int runid, status; - if (onrunid(smsg, obj, "pause", &runid)) { - status = afm_run_pause(runid); - reply_status(smsg, status, error_not_found); - } -} + .on_event_broadcast = on_pws_event_broadcast, +}; -/* - * On query "resume" from 'smsg' with parameters of 'obj'. - */ -static void on_resume(struct sd_bus_message *smsg, struct json_object *obj, void *unused) +static int try_connect_pws() { - int runid, status; - if (onrunid(smsg, obj, "resume", &runid)) { - status = afm_run_resume(runid); - reply_status(smsg, status, error_not_found); + pws = afb_ws_client_connect_api(evloop, uri, &pws_itf, NULL); + if (pws == NULL) { + fprintf(stderr, "connection to %s failed: %m\n", uri); + return 0; } + afb_proto_ws_on_hangup(pws, on_pws_hangup); + return 1; } -/* - * On query "stop" from 'smsg' with parameters of 'obj'. - */ -static void on_stop(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - NOTICE("call to obsolete 'stop'"); - on_pause(smsg, obj, unused); -} - -/* - * On query "continue" from 'smsg' with parameters of 'obj'. - */ -static void on_continue(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - NOTICE("call to obsolete 'continue'"); - on_resume(smsg, obj, unused); -} - -/* - * On query "terminate" from 'smsg' with parameters of 'obj'. - */ -static void on_terminate(struct sd_bus_message *smsg, struct json_object *obj, void *unused) -{ - int runid, status; - if (onrunid(smsg, obj, "terminate", &runid)) { - status = afm_run_terminate(runid); - reply_status(smsg, status, error_not_found); - } -} +static void attempt_connect_pws(int count); -/* - * On query "runners" from 'smsg' with parameters of 'obj'. - */ -static void on_runners(struct sd_bus_message *smsg, struct json_object *obj, void *unused) +static int timehand(sd_event_source *s, uint64_t usec, void *userdata) { - struct json_object *resp; - INFO("method runners called"); - resp = afm_run_list(); - jbus_reply_j(smsg, resp); - json_object_put(resp); + sd_event_source_unref(s); + attempt_connect_pws((int)(intptr_t)userdata); + return 0; } -/* - * On query "state" from 'smsg' with parameters of 'obj'. - */ -static void on_state(struct sd_bus_message *smsg, struct json_object *obj, void *unused) +static void attempt_connect_pws(int count) { - int runid; - struct json_object *resp; - if (onrunid(smsg, obj, "state", &runid)) { - resp = afm_run_state(runid); - reply(smsg, resp, error_not_found); - json_object_put(resp); + sd_event_source *s; + if (!try_connect_pws()) { + if (--count <= 0) { + ERROR("Definitely disconnected"); + exit(1); + } + sd_event_add_time(evloop, &s, CLOCK_MONOTONIC, 5000000, 0, timehand, (void*)(intptr_t)count); } } -/* - * Calls the system daemon to achieve application management of - * the 'method' gotten from 'smsg' with the parameter's string 'msg'. - * - * The principle is very simple: call the corresponding system method - * and reply its response to the caller. - * - * The request and reply is synchronous and is blocking. - * It is possible to implment it in an asynchrounous way but it - * would brake the common behaviour. It would be a call like - * jbus_call_ss(system_bus, method, msg, callback, smsg) - */ -static void propagate(struct sd_bus_message *smsg, const char *msg, const char *method) +static void on_pws_reply(void *closure, void *request, struct json_object *obj, const char *error, const char *info) { - char *reply; - INFO("method %s propagated with %s", method, msg); - reply = jbus_call_ss_sync(system_bus, method, msg); - if (reply) { - jbus_reply_s(smsg, reply); - free(reply); - } + struct sd_bus_message *smsg = request; + if (error) + jbus_reply_error_s(smsg, error); else - jbus_reply_error_s(smsg, error_system); + jbus_reply_j(smsg, obj); } -#if defined(EXPLICIT_CALL) -/* - * On query "install" from 'smsg' with parameters of 'msg'. - */ -static void on_install(struct sd_bus_message *smsg, const char *msg, void *unused) +static void on_pws_event_broadcast(void *closure, const char *event_name, struct json_object *data) { - return propagate(smsg, msg, "install"); + jbus_send_signal_j(user_bus, "changed", data); } -/* - * On query "uninstall" from 'smsg' with parameters of 'msg'. - */ -static void on_uninstall(struct sd_bus_message *smsg, const char *msg, void *unused) +/* called when pws hangsup */ +static void on_pws_hangup(void *closure) { - return propagate(smsg, msg, "uninstall"); + struct afb_proto_ws *apw = pws; + pws = NULL; + afb_proto_ws_unref(apw); + attempt_connect_pws(10); } -#endif -/* - * On system signaling that applications list changed - */ -static void on_signal_changed(struct json_object *obj, void *unused) +/* propagate the call to the service */ +static void propagate(struct sd_bus_message *smsg, struct json_object *obj, void *closure) { - /* update the database */ -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - afm_db_update_applications(afdb); + 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 - afm_udb_update(afudb); + rc = afb_proto_ws_client_call(pws, verb, obj, sessionid, smsg); #endif - /* re-propagate now */ - jbus_send_signal_j(user_bus, "changed", obj); + if (rc < 0) + ERROR("calling %s(%s) failed: %m\n", verb, json_object_to_json_string(obj)); + } } /* @@ -519,23 +268,22 @@ fail: int main(int ac, char **av) { int i, daemon = 0, rc; -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - enum afm_launch_mode mode; -#endif - struct sd_event *evloop; - struct sd_bus *sysbus, *usrbus; - const char *sys_bus_addr, *usr_bus_addr; + struct sd_bus *usrbus; + const char *usr_bus_addr; + const char **iter; LOGAUTH(appname); /* first interpretation of arguments */ - sys_bus_addr = NULL; usr_bus_addr = NULL; while ((i = getopt_long(ac, av, options_s, options_l, NULL)) >= 0) { switch (i) { case 'h': printf(usagestr, appname); return 0; + case 'V': + printf(versionstr, appname); + return 0; case 'q': if (verbosity) verbosity--; @@ -546,26 +294,9 @@ int main(int ac, char **av) case 'd': daemon = 1; break; -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - case 'r': - break; - case 'a': - break; - case 'm': - mode = launch_mode_of_name(optarg); - if (!is_valid_launch_mode(mode)) { - ERROR("invalid mode '%s'", optarg); - return 1; - } - set_default_launch_mode(mode); - break; -#endif case 'u': usr_bus_addr = optarg; break; - case 's': - sys_bus_addr = optarg; - break; case ':': ERROR("missing argument value"); return 1; @@ -575,58 +306,19 @@ int main(int ac, char **av) } } - /* init random generator */ - srandom((unsigned int)time(NULL)); - - /* init runners */ - if (afm_run_init()) { - ERROR("afm_run_init failed"); - return 1; - } - - /* init framework */ -#ifdef LEGACY_MODE_WITHOUT_SYSTEMD - afdb = afm_db_create(); - if (!afdb) { - ERROR("afm_db_create failed"); + /* check argument count */ + if (optind >= ac) { + ERROR("Uri to the framework is missing"); return 1; } - if (afm_db_add_root(afdb, FWK_APP_DIR)) { - ERROR("can't add root %s", FWK_APP_DIR); + if (optind + 1 != ac) { + ERROR("Extra parameters found"); return 1; } + uri = av[optind]; - /* second interpretation of arguments */ - optind = 1; - while ((i = getopt_long(ac, av, options_s, options_l, NULL)) >= 0) { - switch (i) { - case 'r': - if (afm_db_add_root(afdb, optarg)) { - ERROR("can't add root %s", optarg); - return 1; - } - break; - case 'a': - if (afm_db_add_application(afdb, optarg)) { - ERROR("can't add application %s", optarg); - return 1; - } - break; - } - } - - /* update the database */ - if (afm_db_update_applications(afdb)) { - ERROR("afm_update_applications failed"); - return 1; - } -#else - afudb = afm_udb_create(0, 1, "afm-appli-"); - if (!afudb) { - ERROR("afm_udb_create failed"); - return 1; - } -#endif + /* init sessionid */ + asprintf(&sessionid, "%d-%s", (int)getuid(), appname); /* daemonize if requested */ if (daemon && daemonize()) { @@ -640,16 +332,6 @@ int main(int ac, char **av) ERROR("can't create event loop"); return 1; } - rc = open_bus(&sysbus, 0, sys_bus_addr); - if (rc < 0) { - ERROR("can't create system bus"); - return 1; - } - rc = sd_bus_attach_event(sysbus, evloop, 0); - if (rc < 0) { - ERROR("can't attach system bus to event loop"); - return 1; - } rc = open_bus(&usrbus, 1, usr_bus_addr); if (rc < 0) { ERROR("can't create user bus"); @@ -661,16 +343,9 @@ int main(int ac, char **av) return 1; } - /* connects to the system bus */ - system_bus = create_jbus(sysbus, AFM_SYSTEM_DBUS_PATH); - if (!system_bus) { - ERROR("create_jbus failed for system"); - return 1; - } - - /* observe signals of system */ - if(jbus_on_signal_j(system_bus, "changed", on_signal_changed, NULL)) { - ERROR("adding signal observer failed"); + /* connect to framework */ + if (!try_connect_pws()) { + ERROR("connection to %s failed: %m\n", uri); return 1; } @@ -682,27 +357,11 @@ int main(int ac, char **av) } /* init services */ - if (jbus_add_service_j(user_bus, "runnables", on_runnables, NULL) - || jbus_add_service_j(user_bus, "detail", on_detail, NULL) - || jbus_add_service_j(user_bus, "start", on_start, NULL) - || jbus_add_service_j(user_bus, "once", on_once, NULL) - || jbus_add_service_j(user_bus, "terminate", on_terminate, NULL) - || jbus_add_service_j(user_bus, "pause", on_pause, NULL) - || jbus_add_service_j(user_bus, "resume", on_resume, NULL) - || jbus_add_service_j(user_bus, "stop", on_stop, NULL) - || jbus_add_service_j(user_bus, "continue", on_continue, NULL) - || jbus_add_service_j(user_bus, "runners", on_runners, NULL) - || jbus_add_service_j(user_bus, "state", on_state, NULL) -#if defined(EXPLICIT_CALL) - || jbus_add_service_s(user_bus, "install", on_install, NULL) - || jbus_add_service_s(user_bus, "uninstall", on_uninstall, NULL) -#else - || jbus_add_service_s(user_bus, "install", (void (*)(struct sd_bus_message *, const char *, void *))propagate, "install") - || jbus_add_service_s(user_bus, "uninstall", (void (*)(struct sd_bus_message *, const char *, void *))propagate, "uninstall") -#endif - ) { - ERROR("adding services failed"); - return 1; + for (iter = methods ; *iter ; iter ++) { + if (jbus_add_service_j(user_bus, *iter, propagate, (void*)*iter)) { + ERROR("adding services failed"); + return 1; + } } /* start servicing */ @@ -717,17 +376,3 @@ int main(int ac, char **av) return 0; } - - - - - - - - - - - - - -