src/afb-apis.c

   1 /*
   2  * Copyright (C) 2016 "IoT.bzh"
   3  * Author "Fulup Ar Foll"
   4  * Author José Bollo <jose.bollo@iot.bzh>
   5  *
   6  * Licensed under the Apache License, Version 2.0 (the "License");
   7  * you may not use this file except in compliance with the License.
   8  * You may obtain a copy of the License at
   9  *
  10  *   http://www.apache.org/licenses/LICENSE-2.0
  11  *
  12  * Unless required by applicable law or agreed to in writing, software
  13  * distributed under the License is distributed on an "AS IS" BASIS,
  14  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  15  * See the License for the specific language governing permissions and
  16  * limitations under the License.
  17  */
  18
  19 #define _GNU_SOURCE
  20
  21 #include <stdlib.h>
  22 #include <stdio.h>
  23 #include <string.h>
  24
  25 #include "session.h"
  26 #include "verbose.h"
  27 #include "afb-apis.h"
  28 #include "afb-context.h"
  29 #include <afb/afb-req-itf.h>
  30
  31 struct api_desc {
  32         struct afb_api api;
  33         const char *name;
  34         size_t namelen;
  35 };
  36
  37 static struct api_desc *apis_array = NULL;
  38 static int apis_count = 0;
  39
  40 int afb_apis_count()
  41 {
  42         return apis_count;
  43 }
  44
  45 int afb_apis_add(const char *name, struct afb_api api)
  46 {
  47         struct api_desc *apis;
  48         size_t len;
  49         int i;
  50
  51         /* check existing or not */
  52         len = strlen(name);
  53         if (len == 0) {
  54                 ERROR("empty api name forbidden");
  55                 goto error;
  56         }
  57
  58         /* check previously existing plugin */
  59         for (i = 0 ; i < apis_count ; i++) {
  60                 if (!strcasecmp(apis_array[i].name, name)) {
  61                         ERROR("api of name %s already exists", name);
  62                         goto error;
  63                 }
  64         }
  65
  66         /* allocates enough memory */
  67         apis = realloc(apis_array, ((unsigned)apis_count + 1) * sizeof * apis);
  68         if (apis == NULL) {
  69                 ERROR("out of memory");
  70                 goto error;
  71         }
  72         apis_array = apis;
  73
  74         /* record the plugin */
  75         apis = &apis_array[apis_count];
  76         apis->api = api;
  77         apis->namelen = len;
  78         apis->name = name;
  79         apis_count++;
  80
  81         return 0;
  82
  83 error:
  84         return -1;
  85 }
  86
  87 void afb_apis_call_(struct afb_req req, struct afb_context *context, const char *api, const char *verb)
  88 {
  89         afb_apis_call(req, context, api, strlen(api), verb, strlen(verb));
  90 }
  91
  92 void afb_apis_call(struct afb_req req, struct afb_context *context, const char *api, size_t lenapi, const char *verb, size_t lenverb)
  93 {
  94         int i;
  95         const struct api_desc *a;
  96
  97         a = apis_array;
  98         for (i = 0 ; i < apis_count ; i++, a++) {
  99                 if (a->namelen == lenapi && !strncasecmp(a->name, api, lenapi)) {
 100                         context->api_index = i;
 101                         a->api.call(a->api.closure, req, context, verb, lenverb);
 102                         return;
 103                 }
 104         }
 105         afb_req_fail(req, "fail", "api not found");
 106 }
 107