X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-hsrv.c;h=efbb93560abebfc990f1422fdd4018be0757bf74;hb=94014f46d4751492133f65b12f1dea1cfa36d021;hp=6136655200b9047cec7405387db1dceb137efabd;hpb=8449480d29d2e03d9094ddce82557b251deb6567;p=src%2Fapp-framework-binder.git diff --git a/src/afb-hsrv.c b/src/afb-hsrv.c index 61366552..efbb9356 100644 --- a/src/afb-hsrv.c +++ b/src/afb-hsrv.c @@ -26,22 +26,20 @@ #include -#include "local-def.h" #include "afb-method.h" #include "afb-hreq.h" #include "afb-hsrv.h" -#include "afb-websock.h" -#include "afb-apis.h" #include "afb-req-itf.h" #include "verbose.h" #include "utils-upoll.h" + #define JSON_CONTENT "application/json" #define FORM_CONTENT MHD_HTTP_POST_ENCODING_MULTIPART_FORMDATA -struct afb_hsrv_handler { - struct afb_hsrv_handler *next; +struct hsrv_handler { + struct hsrv_handler *next; const char *prefix; size_t length; int (*handler) (struct afb_hreq *, void *); @@ -49,7 +47,7 @@ struct afb_hsrv_handler { int priority; }; -struct afb_diralias { +struct hsrv_alias { const char *alias; const char *directory; size_t lendir; @@ -58,174 +56,13 @@ struct afb_diralias { struct afb_hsrv { unsigned refcount; - struct afb_hsrv_handler *handlers; + struct hsrv_handler *handlers; struct MHD_Daemon *httpd; struct upoll *upoll; char *cache_to; }; - -static struct afb_hsrv_handler *new_handler( - struct afb_hsrv_handler *head, - const char *prefix, - int (*handler) (struct afb_hreq *, void *), - void *data, - int priority) -{ - struct afb_hsrv_handler *link, *iter, *previous; - size_t length; - - /* get the length of the prefix without its leading / */ - length = strlen(prefix); - while (length && prefix[length - 1] == '/') - length--; - - /* allocates the new link */ - link = malloc(sizeof *link); - if (link == NULL) - return NULL; - - /* initialize it */ - link->prefix = prefix; - link->length = length; - link->handler = handler; - link->data = data; - link->priority = priority; - - /* adds it */ - previous = NULL; - iter = head; - while (iter && (priority < iter->priority || (priority == iter->priority && length <= iter->length))) { - previous = iter; - iter = iter->next; - } - link->next = iter; - if (previous == NULL) - return link; - previous->next = link; - return head; -} - -int afb_hsrv_add_handler( - struct afb_hsrv *hsrv, - const char *prefix, - int (*handler) (struct afb_hreq *, void *), - void *data, - int priority) -{ - struct afb_hsrv_handler *head; - - head = new_handler(hsrv->handlers, prefix, handler, data, priority); - if (head == NULL) - return 0; - hsrv->handlers = head; - return 1; -} - -int afb_hreq_one_page_api_redirect( - struct afb_hreq *hreq, - void *data) -{ - size_t plen; - char *url; - - if (hreq->lentail >= 2 && hreq->tail[1] == '#') - return 0; - /* - * Here we have for example: - * url = "/pre/dir/page" lenurl = 13 - * tail = "/dir/page" lentail = 9 - * - * We will produce "/pre/#!dir/page" - * - * Let compute plen that include the / at end (for "/pre/") - */ - plen = hreq->lenurl - hreq->lentail + 1; - url = alloca(hreq->lenurl + 3); - memcpy(url, hreq->url, plen); - url[plen++] = '#'; - url[plen++] = '!'; - memcpy(&url[plen], &hreq->tail[1], hreq->lentail); - return afb_hreq_redirect_to(hreq, url); -} - -static int afb_hreq_websocket_switch(struct afb_hreq *hreq, void *data) -{ - int later; - - afb_hreq_context(hreq); - if (hreq->lentail != 0 || !afb_websock_check(hreq, &later)) - return 0; - - if (!later) { - struct afb_websock *ws = afb_websock_create(hreq); - if (ws != NULL) - hreq->upgrade = 1; - } - return 1; -} - -static int afb_hreq_rest_api(struct afb_hreq *hreq, void *data) -{ - const char *api, *verb; - size_t lenapi, lenverb; - struct AFB_clientCtx *context; - - api = &hreq->tail[strspn(hreq->tail, "/")]; - lenapi = strcspn(api, "/"); - verb = &api[lenapi]; - verb = &verb[strspn(verb, "/")]; - lenverb = strcspn(verb, "/"); - - if (!(*api && *verb && lenapi && lenverb)) - return 0; - - context = afb_hreq_context(hreq); - return afb_apis_handle(afb_hreq_to_req(hreq), context, api, lenapi, verb, lenverb); -} - -static int handle_alias(struct afb_hreq *hreq, void *data) -{ - struct afb_diralias *da = data; - - if (hreq->method != afb_method_get) { - afb_hreq_reply_error(hreq, MHD_HTTP_METHOD_NOT_ALLOWED); - return 1; - } - - if (!afb_hreq_valid_tail(hreq)) { - afb_hreq_reply_error(hreq, MHD_HTTP_FORBIDDEN); - return 1; - } - - return afb_hreq_reply_file(hreq, da->dirfd, &hreq->tail[1]); -} - -int afb_hsrv_add_alias(struct afb_hsrv *hsrv, const char *prefix, const char *alias, int priority) -{ - struct afb_diralias *da; - int dirfd; - - dirfd = open(alias, O_PATH|O_DIRECTORY); - if (dirfd < 0) { - /* TODO message */ - return 0; - } - da = malloc(sizeof *da); - if (da != NULL) { - da->alias = prefix; - da->directory = alias; - da->lendir = strlen(da->directory); - da->dirfd = dirfd; - if (afb_hsrv_add_handler(hsrv, prefix, handle_alias, da, priority)) - return 1; - free(da); - } - close(dirfd); - return 0; -} - static void reply_error(struct MHD_Connection *connection, unsigned int status) { char *buffer; @@ -275,7 +112,7 @@ static int access_handler( struct afb_hreq *hreq; enum afb_method method; struct afb_hsrv *hsrv; - struct afb_hsrv_handler *iter; + struct hsrv_handler *iter; const char *type; hsrv = cls; @@ -382,10 +219,102 @@ static int new_client_handler(void *cls, const struct sockaddr *addr, socklen_t return MHD_YES; } -/* infinite loop */ -static void hsrv_handle_event(struct MHD_Daemon *httpd) +static struct hsrv_handler *new_handler( + struct hsrv_handler *head, + const char *prefix, + int (*handler) (struct afb_hreq *, void *), + void *data, + int priority) { - MHD_run(httpd); + struct hsrv_handler *link, *iter, *previous; + size_t length; + + /* get the length of the prefix without its leading / */ + length = strlen(prefix); + while (length && prefix[length - 1] == '/') + length--; + + /* allocates the new link */ + link = malloc(sizeof *link); + if (link == NULL) + return NULL; + + /* initialize it */ + link->prefix = prefix; + link->length = length; + link->handler = handler; + link->data = data; + link->priority = priority; + + /* adds it */ + previous = NULL; + iter = head; + while (iter && (priority < iter->priority || (priority == iter->priority && length <= iter->length))) { + previous = iter; + iter = iter->next; + } + link->next = iter; + if (previous == NULL) + return link; + previous->next = link; + return head; +} + +static int handle_alias(struct afb_hreq *hreq, void *data) +{ + struct hsrv_alias *da = data; + + if (hreq->method != afb_method_get) { + afb_hreq_reply_error(hreq, MHD_HTTP_METHOD_NOT_ALLOWED); + return 1; + } + + if (!afb_hreq_valid_tail(hreq)) { + afb_hreq_reply_error(hreq, MHD_HTTP_FORBIDDEN); + return 1; + } + + return afb_hreq_reply_file(hreq, da->dirfd, &hreq->tail[1]); +} + +int afb_hsrv_add_handler( + struct afb_hsrv *hsrv, + const char *prefix, + int (*handler) (struct afb_hreq *, void *), + void *data, + int priority) +{ + struct hsrv_handler *head; + + head = new_handler(hsrv->handlers, prefix, handler, data, priority); + if (head == NULL) + return 0; + hsrv->handlers = head; + return 1; +} + +int afb_hsrv_add_alias(struct afb_hsrv *hsrv, const char *prefix, const char *alias, int priority) +{ + struct hsrv_alias *da; + int dirfd; + + dirfd = open(alias, O_PATH|O_DIRECTORY); + if (dirfd < 0) { + /* TODO message */ + return 0; + } + da = malloc(sizeof *da); + if (da != NULL) { + da->alias = prefix; + da->directory = alias; + da->lendir = strlen(da->directory); + da->dirfd = dirfd; + if (afb_hsrv_add_handler(hsrv, prefix, handle_alias, da, priority)) + return 1; + free(da); + } + close(dirfd); + return 0; } int afb_hsrv_set_cache_timeout(struct afb_hsrv *hsrv, int duration) @@ -402,7 +331,7 @@ int afb_hsrv_set_cache_timeout(struct afb_hsrv *hsrv, int duration) return 1; } -int _afb_hsrv_start(struct afb_hsrv *hsrv, uint16_t port, unsigned int connection_timeout) +int afb_hsrv_start(struct afb_hsrv *hsrv, uint16_t port, unsigned int connection_timeout) { struct upoll *upoll; struct MHD_Daemon *httpd; @@ -435,14 +364,14 @@ int _afb_hsrv_start(struct afb_hsrv *hsrv, uint16_t port, unsigned int connectio fprintf(stderr, "Error: connection to upoll of httpd failed"); return 0; } - upoll_on_readable(upoll, (void*)hsrv_handle_event); + upoll_on_readable(upoll, (void*)MHD_run); hsrv->httpd = httpd; hsrv->upoll = upoll; return 1; } -void _afb_hsrv_stop(struct afb_hsrv *hsrv) +void afb_hsrv_stop(struct afb_hsrv *hsrv) { if (hsrv->upoll) upoll_close(hsrv->upoll); @@ -464,67 +393,8 @@ void afb_hsrv_put(struct afb_hsrv *hsrv) { assert(hsrv->refcount != 0); if (!--hsrv->refcount) { - _afb_hsrv_stop(hsrv); + afb_hsrv_stop(hsrv); free(hsrv); } } -static int my_default_init(struct afb_hsrv *hsrv, AFB_session * session) -{ - int idx; - - if (!afb_hsrv_add_handler(hsrv, session->config->rootapi, afb_hreq_websocket_switch, NULL, 20)) - return 0; - - if (!afb_hsrv_add_handler(hsrv, session->config->rootapi, afb_hreq_rest_api, NULL, 10)) - return 0; - - for (idx = 0; session->config->aliasdir[idx].url != NULL; idx++) - if (!afb_hsrv_add_alias (hsrv, session->config->aliasdir[idx].url, session->config->aliasdir[idx].path, 0)) - return 0; - - if (!afb_hsrv_add_alias(hsrv, "", session->config->rootdir, -10)) - return 0; - - if (!afb_hsrv_add_handler(hsrv, session->config->rootbase, afb_hreq_one_page_api_redirect, NULL, -20)) - return 0; - - return 1; -} - -int afb_hsrv_start(AFB_session * session) -{ - int rc; - struct afb_hsrv *hsrv; - - hsrv = afb_hsrv_create(); - if (hsrv == NULL) { - fprintf(stderr, "memory allocation failure\n"); - return 0; - } - - if (!afb_hsrv_set_cache_timeout(hsrv, session->config->cacheTimeout) - || !my_default_init(hsrv, session)) { - printf("Error: initialisation of httpd failed"); - afb_hsrv_put(hsrv); - return 0; - } - - if (verbosity) { - printf("AFB:notice Waiting port=%d rootdir=%s\n", session->config->httpdPort, session->config->rootdir); - printf("AFB:notice Browser URL= http:/*localhost:%d\n", session->config->httpdPort); - } - - rc = _afb_hsrv_start(hsrv, (uint16_t) session->config->httpdPort, 15); - if (!rc) - return 0; - - session->hsrv = hsrv; - return 1; -} - -void afb_hsrv_stop(AFB_session * session) -{ - _afb_hsrv_stop(session->hsrv); -} -