X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=plugins%2Fsamples%2FSamplePost.c;h=aab54e91f7117e9f44d878fb1c3e08350f8c98c0;hb=c0453c34a58aac8150300ab829149a0ca4d9e5ee;hp=56c3f24b22a773f3d80c16d5489bdf4f1d7068cd;hpb=5472e85501418302959040eacb819c57f849d63e;p=src%2Fapp-framework-binder.git diff --git a/plugins/samples/SamplePost.c b/plugins/samples/SamplePost.c index 56c3f24b..aab54e91 100644 --- a/plugins/samples/SamplePost.c +++ b/plugins/samples/SamplePost.c @@ -16,104 +16,99 @@ * along with this program. If not, see . */ +#define _GNU_SOURCE +#include +#include +#include -#include "local-def.h" +#include "afb-plugin.h" +#include "afb-req-itf.h" + + +static int fillargs(json_object *args, struct afb_arg arg) +{ + json_object *obj; + + obj = json_object_new_object(); + json_object_object_add (obj, "value", json_object_new_string(arg.value)); + json_object_object_add (obj, "size", json_object_new_int64((int64_t)arg.size)); + json_object_object_add (obj, "is_file", json_object_new_boolean(arg.is_file)); + json_object_object_add (args, arg.name && *arg.name ? arg.name : "", obj); + return 1; /* continue to iterate */ +} + +// Sample Generic Ping Debug API +static void getPingTest(struct afb_req request) +{ + static int pingcount = 0; + json_object *query; + + query = json_object_new_object(); + afb_req_iterate(request, (void*)fillargs, query); + + afb_req_success_f(request, query, "Ping Binder Daemon count=%d", ++pingcount); +} // With content-type=json data are directly avaliable in request->post->data -STATIC json_object* GetJsonByPost (AFB_request *request) { +static void GetJsonByPost (struct afb_req request) +{ json_object* jresp; - char query [256]; - int len; - - // check if we have some post data - if (request->post == NULL) request->post->data="NoData"; - - // Get all query string [Note real app should probably use value=getQueryValue(request,"key")] - len = getQueryAll (request, query, sizeof(query)); - if (len == 0) strncpy (query, "NoSearchQueryList", sizeof(query)); - - // for debug/test return response to caller - jresp = jsonNewMessage(AFB_SUCCESS, "GetJsonByPost query={%s} PostData: [%s]", query, request->post->data); - - return (jresp); -} + json_object *query; + struct afb_arg arg; + query = json_object_new_object(); + afb_req_iterate(request, (void*)fillargs, query); + arg = afb_req_get(request, ""); + jresp = arg.value ? json_tokener_parse(arg.value) : NULL; + afb_req_success_f(request, jresp, "GetJsonByPost query={%s}", json_object_to_json_string(query)); +} // Upload a file and execute a function when upload is done -STATIC json_object* UploadAppli (AFB_request *request, AFB_PostItem *item) { - - char *destination = "applications"; - - // This is called after PostForm and then after DonePostForm - if (item == NULL) { - AFB_PostCtx *postFileCtx = getPostContext(request); - if (postFileCtx != NULL) { - - // request Application Framework to install application - - request->errcode = MHD_HTTP_OK; // or error is something went wrong; - request->jresp = jsonNewMessage(AFB_FAIL,"UploadFile Post Request file=[%s] done", postFileCtx->path); - } - } - - // upload multi iteration logic is handle by getPostedFile - return (getPostFile (request, item, destination)); +static void Uploads (struct afb_req request, const char *destination) +{ + afb_req_fail_f(request, "unimplemented", "destination: %s", destination); } -// Simples Upload case just upload a file -STATIC json_object* UploadMusic (AFB_request *request, AFB_PostItem *item) { - - char *destination = "musics"; +// Upload a file and execute a function when upload is done +static void UploadAppli (struct afb_req request) +{ + Uploads(request, "applications"); +} - // upload multi iteration logic is handle by getPostedFile - return (getPostFile (request, item, destination)); +// Simples Upload case just upload a file +static void UploadMusic (struct afb_req request) +{ + Uploads(request, "musics"); } // PostForm callback is called multiple times (one or each key within form, or once per file buffer) // When file has been fully uploaded call is call with item==NULL -STATIC json_object* UploadImage (AFB_request *request, AFB_PostItem *item) { - - // note if directory is relative it will be prefixed by request->config->sessiondir - char *destination = "images"; - - // This is called after PostForm and then after DonePostForm - if (item == NULL) { - AFB_PostCtx *postFileCtx = getPostContext(request); - - // if postFileCtx == NULL then an error happen [getPostedFile automatically reports errors] - if (postFileCtx != NULL) { - // Do something with your newly upload filepath=postFileCtx->path - request->errcode = MHD_HTTP_OK; - request->jresp = jsonNewMessage(AFB_FAIL,"UploadFile Post Request file=[%s] done", postFileCtx->path); - - // Note: should not return here in order getPostedFile to clear Post resources. - } - } - - // upload multi iteration logic is handle by getPostedFile - return (getPostFile (request, item, destination)); +static void UploadImage (struct afb_req request) +{ + Uploads(request, "images"); } // NOTE: this sample does not use session to keep test a basic as possible // in real application upload-xxx should be protected with AFB_SESSION_CHECK -STATIC AFB_restapi pluginApis[]= { - {"ping" , AFB_SESSION_NONE , (AFB_apiCB)getPingTest ,"Ping Rest Test Service"}, - {"upload-json" , AFB_SESSION_NONE , (AFB_apiCB)GetJsonByPost ,"Demo for Json Buffer on Post"}, - {"upload-image" , AFB_SESSION_NONE , (AFB_apiCB)UploadImage ,"Demo for file upload"}, - {"upload-music" , AFB_SESSION_NONE , (AFB_apiCB)UploadMusic ,"Demo for file upload"}, - {"upload-appli" , AFB_SESSION_NONE , (AFB_apiCB)UploadAppli ,"Demo for file upload"}, +static const struct AFB_restapi pluginApis[]= { + {"ping" , AFB_SESSION_NONE , getPingTest ,"Ping Rest Test Service"}, + {"upload-json" , AFB_SESSION_NONE , GetJsonByPost ,"Demo for Json Buffer on Post"}, + {"upload-image" , AFB_SESSION_NONE , UploadImage ,"Demo for file upload"}, + {"upload-music" , AFB_SESSION_NONE , UploadMusic ,"Demo for file upload"}, + {"upload-appli" , AFB_SESSION_NONE , UploadAppli ,"Demo for file upload"}, {NULL} }; -PUBLIC AFB_plugin *pluginRegister () { - AFB_plugin *plugin = malloc (sizeof (AFB_plugin)); - plugin->type = AFB_PLUGIN_JSON; - plugin->info = "Application Framework Binder Service"; - plugin->prefix= "post"; // url base - plugin->apis = pluginApis; - plugin->handle= (void*) "What ever you want"; - - return (plugin); +static const struct AFB_plugin plugin_desc = { + .type = AFB_PLUGIN_JSON, + .info = "Sample with Post Upload Files", + .prefix = "post", + .apis = pluginApis +}; + +const struct AFB_plugin *pluginRegister (const struct AFB_interface *itf) +{ + return &plugin_desc; };