X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fafb-hswitch.c;h=f0308455ea25c1b26af5d5bfd684b7b5909902f2;hb=f1b901ed676b2d45ec8e6ae3d6ef2f94d79f9ee6;hp=606d2664f853408c9fd5ec432db0dc950bc29fc4;hpb=19fb390ec60890d55bafe7a4c887b1453509f7ef;p=src%2Fapp-framework-binder.git diff --git a/src/afb-hswitch.c b/src/afb-hswitch.c index 606d2664..f0308455 100644 --- a/src/afb-hswitch.c +++ b/src/afb-hswitch.c @@ -21,7 +21,10 @@ #include #include +#include + #include "afb-req-itf.h" +#include "afb-context.h" #include "afb-hreq.h" #include "afb-apis.h" #include "session.h" @@ -31,7 +34,6 @@ int afb_hswitch_apis(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, "/"); @@ -42,8 +44,10 @@ int afb_hswitch_apis(struct afb_hreq *hreq, void *data) if (!(*api && *verb && lenapi && lenverb)) return 0; - context = afb_hreq_context(hreq); - afb_apis_call(afb_hreq_to_req(hreq), context, api, lenapi, verb, lenverb); + if (afb_hreq_init_context(hreq) < 0) + afb_hreq_reply_error(hreq, MHD_HTTP_INTERNAL_SERVER_ERROR); + else + afb_apis_call(afb_hreq_to_req(hreq), &hreq->context, api, lenapi, verb, lenverb); return 1; } @@ -77,7 +81,12 @@ int afb_hswitch_websocket_switch(struct afb_hreq *hreq, void *data) if (hreq->lentail != 0) return 0; - return afb_websock_check_upgrade(hreq /* TODO: protocols here */); + if (afb_hreq_init_context(hreq) < 0) { + afb_hreq_reply_error(hreq, MHD_HTTP_INTERNAL_SERVER_ERROR); + return 1; + } + + return afb_websock_check_upgrade(hreq); }