X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=include%2Fafb-req-itf.h;h=111b1d5321ee0791276a245715ccb775933c9395;hb=6b9b3b16ac738f99bddde3d7d375f9986bb1c09a;hp=c593440bb4d843ce09d6a46243a215465ca8c0eb;hpb=70558f02b1c030c4290a0146313e3052fc0ea715;p=src%2Fapp-framework-binder.git diff --git a/include/afb-req-itf.h b/include/afb-req-itf.h index c593440b..111b1d53 100644 --- a/include/afb-req-itf.h +++ b/include/afb-req-itf.h @@ -15,56 +15,127 @@ * limitations under the License. */ +#pragma once + struct json_object; struct afb_arg { const char *name; const char *value; - size_t size; - int is_file; + const char *path; }; struct afb_req_itf { - struct afb_arg (*get)(void *data, const char *name); - void (*iterate)(void *data, int (*iterator)(void *closure, struct afb_arg arg), void *closure); - void (*fail)(void *data, const char *status, const char *info); - void (*success)(void *data, struct json_object *obj, const char *info); + struct json_object *(*json)(void *req_closure); + struct afb_arg (*get)(void *req_closure, const char *name); + void (*success)(void *req_closure, struct json_object *obj, const char *info); + void (*fail)(void *req_closure, const char *status, const char *info); + const char *(*raw)(void *req_closure, size_t *size); + void (*send)(void *req_closure, const char *buffer, size_t size); + void *(*context_get)(void *ctx_closure); + void (*context_set)(void *ctx_closure, void *context, void (*free_context)(void*)); + int (*session_create)(void *req_closure); + int (*session_check)(void *req_closure, int refresh); + void (*session_close)(void *req_closure); }; struct afb_req { const struct afb_req_itf *itf; - void *data; - void **context; + void *req_closure; + void *ctx_closure; }; static inline struct afb_arg afb_req_get(struct afb_req req, const char *name) { - return req.itf->get(req.data, name); + return req.itf->get(req.req_closure, name); } -static inline const char *afb_req_argument(struct afb_req req, const char *name) +static inline const char *afb_req_value(struct afb_req req, const char *name) { return afb_req_get(req, name).value; } -static inline int afb_req_is_argument_file(struct afb_req req, const char *name) +static inline const char *afb_req_path(struct afb_req req, const char *name) { - return afb_req_get(req, name).is_file; + return afb_req_get(req, name).path; } -static inline void afb_req_iterate(struct afb_req req, int (*iterator)(void *closure, struct afb_arg arg), void *closure) +static inline struct json_object *afb_req_json(struct afb_req req) +{ + return req.itf->json(req.req_closure); +} + +static inline void afb_req_success(struct afb_req req, struct json_object *obj, const char *info) { - req.itf->iterate(req.data, iterator, closure); + req.itf->success(req.req_closure, obj, info); } static inline void afb_req_fail(struct afb_req req, const char *status, const char *info) { - req.itf->fail(req.data, status, info); + req.itf->fail(req.req_closure, status, info); } -static inline void afb_req_success(struct afb_req req, struct json_object *obj, const char *info) +static inline const char *afb_req_raw(struct afb_req req, size_t *size) +{ + return req.itf->raw(req.req_closure, size); +} + +static inline void afb_req_send(struct afb_req req, const char *buffer, size_t size) +{ + req.itf->send(req.req_closure, buffer, size); +} + +static inline void *afb_req_context_get(struct afb_req req) +{ + return req.itf->context_get(req.ctx_closure); +} + +static inline void afb_req_context_set(struct afb_req req, void *context, void (*free_context)(void*)) +{ + return req.itf->context_set(req.ctx_closure, context, free_context); +} + +static inline void afb_req_context_clear(struct afb_req req) { - req.itf->success(req.data, obj, info); + afb_req_context_set(req, NULL, NULL); +} + +static inline int afb_req_session_create(struct afb_req req) +{ + int result = req.itf->session_create(req.req_closure); + if (!result) + afb_req_fail(req, "fail", "Can't create the session"); + return result; +} + +static inline int afb_req_session_check(struct afb_req req, int refresh) +{ + int result = req.itf->session_check(req.req_closure, refresh); + if (!result) + afb_req_fail(req, "fail", "Token chek failed for the session"); + return result; +} + +static inline void afb_req_session_close(struct afb_req req) +{ + req.itf->session_close(req.req_closure); +} + +#include + +static inline struct afb_req *afb_req_store(struct afb_req req) +{ + struct afb_req *result = malloc(sizeof *result); + if (result != NULL) + *result = req; + return result; +} + +static inline struct afb_req afb_req_unstore(struct afb_req *req) +{ + struct afb_req result = *req; + free(req); + return result; } #if !defined(_GNU_SOURCE) @@ -72,7 +143,6 @@ static inline void afb_req_success(struct afb_req req, struct json_object *obj, #endif #include -#include #include static inline void afb_req_fail_v(struct afb_req req, const char *status, const char *info, va_list args)