From 40b7650e4c95481889c1e37dea57be7de018e37d Mon Sep 17 00:00:00 2001 From: José Bollo Date: Fri, 9 Nov 2018 18:56:05 +0100 Subject: devtools: Refactoring, bug fix, new IDL MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The programs from devtools are rewritten to use common improved code with bug fixes. At the same time, the tool afb-genskel accept a new JSON format for describing apis. Change-Id: I38fd25be448bdc0339df63a570bddf53d37b9c3f Signed-off-by: José Bollo --- src/devtools/CMakeLists.txt | 6 +- src/devtools/exprefs.c | 183 +++++----- src/devtools/exprefs.h | 23 ++ src/devtools/genskel.c | 828 ------------------------------------------ src/devtools/genskel.md | 1 + src/devtools/getref.c | 84 +++++ src/devtools/getref.h | 23 ++ src/devtools/idl-monitor.json | 296 +++++++++++++++ src/devtools/json2c.c | 202 ++++++----- src/devtools/json2c.h | 28 ++ src/devtools/main-exprefs.c | 102 ++++++ src/devtools/main-genskel.c | 711 ++++++++++++++++++++++++++++++++++++ src/devtools/main-json2c.c | 103 ++++++ 13 files changed, 1570 insertions(+), 1020 deletions(-) create mode 100644 src/devtools/exprefs.h delete mode 100644 src/devtools/genskel.c create mode 100644 src/devtools/genskel.md create mode 100644 src/devtools/getref.c create mode 100644 src/devtools/getref.h create mode 100644 src/devtools/idl-monitor.json create mode 100644 src/devtools/json2c.h create mode 100644 src/devtools/main-exprefs.c create mode 100644 src/devtools/main-genskel.c create mode 100644 src/devtools/main-json2c.c diff --git a/src/devtools/CMakeLists.txt b/src/devtools/CMakeLists.txt index 6dfe788b..05edaffd 100644 --- a/src/devtools/CMakeLists.txt +++ b/src/devtools/CMakeLists.txt @@ -16,9 +16,9 @@ # limitations under the License. ########################################################################### -ADD_EXECUTABLE(afb-genskel genskel.c) -ADD_EXECUTABLE(afb-exprefs exprefs.c) -ADD_EXECUTABLE(afb-json2c json2c.c) +ADD_EXECUTABLE(afb-genskel main-genskel.c exprefs.c getref.c json2c.c) +ADD_EXECUTABLE(afb-exprefs main-exprefs.c exprefs.c getref.c) +ADD_EXECUTABLE(afb-json2c main-json2c.c json2c.c) TARGET_LINK_LIBRARIES(afb-genskel ${link_libraries}) TARGET_LINK_LIBRARIES(afb-exprefs ${link_libraries}) diff --git a/src/devtools/exprefs.c b/src/devtools/exprefs.c index 4459f2c4..cfd39410 100644 --- a/src/devtools/exprefs.c +++ b/src/devtools/exprefs.c @@ -43,105 +43,91 @@ #define _GNU_SOURCE #include #include -#include #include +#include "getref.h" +#include "exprefs.h" + /** * records path to the expanded node */ struct path { struct json_object *object; /**< node being expanded */ - struct path *upper; /**< link to upper expanded nodes */ + const struct path *upper; /**< link to upper expanded nodes */ }; /** - * root of the JSON being parsed - */ -struct json_object *root; - -/** - * Search for a reference of type "#/a/b/c" int the - * parsed JSON object + * Returns the top object */ -struct json_object *search(const char *path) +static inline struct json_object *top(const struct path *path) { - char *d; - struct json_object *i; - - /* does it match #/ at the beginning? */ - if (path[0] != '#' || (path[0] && path[1] != '/')) - return NULL; - - /* search from root to target */ - i = root; - d = strdupa(path+2); - d = strtok(d, "/"); - while(i && d) { - if (!json_object_object_get_ex(i, d, &i)) - return NULL; - d = strtok(NULL, "/"); - } - return i; + while (path->upper) + path = path->upper; + return path->object; } /** * Expands the node designated by path and returns its expanded form */ -struct json_object *expand(struct path path) +static struct json_object *expand(const struct path *upper) { - struct path *p; - struct json_object *o, *x; + struct path here; + struct json_object *object, *x; int n, i; struct json_object_iterator ji, jn; /* expansion depends of the type of the node */ - switch (json_object_get_type(path.object)) { + here.upper = upper; + object = upper->object; + switch (json_object_get_type(object)) { case json_type_object: /* for object, look if it contains a property "$ref" */ - if (json_object_object_get_ex(path.object, "$ref", &o)) { - /* yes, reference, try to substitute its target */ - if (!json_object_is_type(o, json_type_string)) { - fprintf(stderr, "found a $ref not being string. Is: %s\n", json_object_get_string(o)); + if (json_object_object_get_ex(object, "$ref", &here.object)) { + /* check that "$ref" value is a string */ + if (!json_object_is_type(here.object, json_type_string)) { + fprintf(stderr, "found a $ref not being string. Is: %s\n", json_object_get_string(here.object)); exit(1); } - x = search(json_object_get_string(o)); - if (!x) { - fprintf(stderr, "$ref not found. Was: %s\n", json_object_get_string(o)); + /* yes, reference, try to substitute its target */ + i = search$ref(top(upper), json_object_get_string(here.object), &x); + if (!i) { + fprintf(stderr, "$ref not found. Was: %s\n", json_object_get_string(here.object)); exit(1); } - p = &path; - while(p) { - if (x == p->object) { - fprintf(stderr, "$ref recursive. Was: %s\n", json_object_get_string(o)); + /* check not recursive */ + upper = &here; + while(upper) { + if (x == upper->object) { + fprintf(stderr, "$ref recursive. Was: %s\n", json_object_get_string(here.object)); exit(1); } - p = p->upper; + upper = upper->upper; } - /* cool found, return a new instance of the target */ - return json_object_get(x); + /* found. return a new instance of the target */ + return x; } /* no, expand the values */ - ji = json_object_iter_begin(path.object); - jn = json_object_iter_end(path.object); + ji = json_object_iter_begin(object); + jn = json_object_iter_end(object); while (!json_object_iter_equal(&ji, &jn)) { - o = json_object_iter_peek_value(&ji); - x = expand((struct path){ .object = o, .upper = &path }); - if (x != o) - json_object_object_add(path.object, json_object_iter_peek_name(&ji), x); + here.object = json_object_iter_peek_value(&ji); + x = expand(&here); + if (x != here.object) + json_object_object_add(object, json_object_iter_peek_name(&ji), json_object_get(x)); json_object_iter_next(&ji); } break; case json_type_array: /* expand the values of arrays */ i = 0; - n = (int)json_object_array_length(path.object); + n = (int)json_object_array_length(object); while (i != n) { - o = json_object_array_get_idx(path.object, i); - x = expand((struct path){ .object = o, .upper = &path }); - if (x != o) - json_object_array_put_idx(path.object, i, x); + here.object = json_object_array_get_idx(object, i); + x = expand(&here); + if (x != here.object) + json_object_array_put_idx(object, i, json_object_get(x)); i++; } break; @@ -150,49 +136,62 @@ struct json_object *expand(struct path path) break; } /* return the given node */ - return path.object; + return object; } -/** - * process a file and prints its expansion on stdout - */ -void process(char *filename) +struct json_object *exp$refs(struct json_object *root) { - /* translate - */ - if (!strcmp(filename, "-")) - filename = "/dev/stdin"; + struct path top = { .object = root, .upper = NULL }; + return expand(&top); +} - /* check access */ - if (access(filename, R_OK)) { - fprintf(stderr, "can't access file %s\n", filename); - exit(1); - } +static int is_tree(struct json_object *object, const struct path *upper) +{ + struct path here; + int n, i; + struct json_object_iterator ji, jn; - /* read the file */ - root = json_object_from_file(filename); - if (!root) { - fprintf(stderr, "reading file %s produced null\n", filename); - exit(1); + switch (json_object_get_type(object)) { + case json_type_object: + case json_type_array: + /* check recursive */ + here.upper = upper; + while (upper) { + if (upper->object == object) + return 0; + upper = upper->upper; + } + here.object = object; + switch (json_object_get_type(object)) { + case json_type_object: + ji = json_object_iter_begin(object); + jn = json_object_iter_end(object); + while (!json_object_iter_equal(&ji, &jn)) { + if (!is_tree(json_object_iter_peek_value(&ji), &here)) + return 0; + json_object_iter_next(&ji); + } + break; + case json_type_array: + i = 0; + n = (int)json_object_array_length(object); + while (i != n) { + if (!is_tree(json_object_array_get_idx(object, i), &here)) + return 0; + i++; + } + break; + default: + break; + } + break; + default: + break; } - - /* expand */ - root = expand((struct path){ .object = root, .upper = NULL }); - - /* print the result */ - json_object_to_file_ext ("/dev/stdout", root, JSON_C_TO_STRING_PRETTY); - - /* clean up */ - json_object_put(root); + return 1; } -/** process the list of files or stdin if none */ -int main(int ac, char **av) +int exp$refs_is_tree(struct json_object *root) { - if (!*++av) - process("-"); - else { - do { process(*av); } while(*++av); - } - return 0; + return is_tree(root, NULL); } - diff --git a/src/devtools/exprefs.h b/src/devtools/exprefs.h new file mode 100644 index 00000000..8def4b67 --- /dev/null +++ b/src/devtools/exprefs.h @@ -0,0 +1,23 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#pragma once + +struct json_object; + +extern struct json_object *exp$refs(struct json_object *root); +extern int exp$refs_is_tree(struct json_object *root); diff --git a/src/devtools/genskel.c b/src/devtools/genskel.c deleted file mode 100644 index 80dcd381..00000000 --- a/src/devtools/genskel.c +++ /dev/null @@ -1,828 +0,0 @@ -/* - * Copyright (C) 2016-2019 "IoT.bzh" - * Author José Bollo - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -/* - * This simple program expands the object { "$ref": "#/path/to/a/target" } - * - * For example: - * - * { - * "type":{ - * "a": "int", - * "b": { "$ref": "#/type/a" } - * } - * } - * - * will be exapanded to - * - * { - * "type":{ - * "a": "int", - * "b": "int" - * } - * } - * - * Invocation: program [file|-]... - * - * without arguments, it reads the input. - */ - -#define _GNU_SOURCE -#include -#include -#include -#include - -#include - -#define T(x) ((x) && *(x)) -#define oom(x) do{if(!(x)){fprintf(stderr,"out of memory\n");exit(1);}}while(0) - -/** - * records path to the expanded node - */ -struct path -{ - struct json_object *object; /**< node being expanded */ - struct path *upper; /**< link to upper expanded nodes */ -}; - -/** - * root of the JSON being parsed - */ -int version = 3; -struct json_object *root = NULL; -struct json_object *d_perms = NULL; -struct json_object *a_perms = NULL; -const char *preinit = NULL; -const char *init = NULL; -const char *onevent = NULL; -const char *api = NULL; -const char *scope = NULL; -const char *prefix = NULL; -const char *postfix = NULL; -const char *provideclass = NULL; -const char *requireclass = NULL; -const char *requireapi = NULL; -char *capi = NULL; -int priv = -1; -int noconc = -1; -int cpp = 0; - -/** - * Search for a reference of type "#/a/b/c" in the - * parsed JSON object (root) - */ -struct json_object *search(const char *path) -{ - char *d; - struct json_object *i; - - /* does it match #/ at the beginning? */ - if (path[0] != '#' || (path[0] && path[1] != '/')) - return NULL; - - /* search from root to target */ - i = root; - d = strdupa(path+2); - d = strtok(d, "/"); - while(i && d) { - if (!json_object_object_get_ex(i, d, &i)) - return NULL; - d = strtok(NULL, "/"); - } - return i; -} - -/** - * Expands the node designated by path and returns its expanded form - */ -struct json_object *expand_$ref(struct path path) -{ - struct path *p; - struct json_object *o, *x; - int n, i; - struct json_object_iterator ji, jn; - - /* expansion depends of the type of the node */ - switch (json_object_get_type(path.object)) { - case json_type_object: - /* for object, look if it contains a property "$ref" */ - if (json_object_object_get_ex(path.object, "$ref", &o)) { - /* yes, reference, try to substitute its target */ - if (!json_object_is_type(o, json_type_string)) { - fprintf(stderr, "found a $ref not being string. Is: %s\n", json_object_get_string(o)); - exit(1); - } - x = search(json_object_get_string(o)); - if (!x) { - fprintf(stderr, "$ref not found. Was: %s\n", json_object_get_string(o)); - exit(1); - } - p = &path; - while(p) { - if (x == p->object) { - fprintf(stderr, "$ref recursive. Was: %s\n", json_object_get_string(o)); - exit(1); - } - p = p->upper; - } - /* cool found, return a new instance of the target */ - return json_object_get(x); - } - /* no, expand the values */ - ji = json_object_iter_begin(path.object); - jn = json_object_iter_end(path.object); - while (!json_object_iter_equal(&ji, &jn)) { - o = json_object_iter_peek_value(&ji); - x = expand_$ref((struct path){ .object = o, .upper = &path }); - if (x != o) - json_object_object_add(path.object, json_object_iter_peek_name(&ji), x); - json_object_iter_next(&ji); - } - break; - case json_type_array: - /* expand the values of arrays */ - i = 0; - n = (int)json_object_array_length(path.object); - while (i != n) { - o = json_object_array_get_idx(path.object, i); - x = expand_$ref((struct path){ .object = o, .upper = &path }); - if (x != o) - json_object_array_put_idx(path.object, i, x); - i++; - } - break; - default: - /* otherwise no expansion */ - break; - } - - /* return the given node */ - return path.object; -} - -/* create c name by replacing non alpha numeric characters with underscores */ -char *cify(const char *str) -{ - char *r = strdup(str); - int i = 0; - while (r && r[i]) { - if (!isalnum(r[i])) - r[i] = '_'; - i++; - } - return r; -} - -/* format the specification as a C string */ -char *make_info(const char *text, int split) -{ - const char *a, *b; - char *desc, c, buf[3] = {0}; - size_t len; - int i, pos, e; - - /* estimated length */ - a = b = text; - len = 1; - while((c = *b++)) { - len += 1 + ('"' == c); - } - - len += 7 * (1 + len / 72); - desc = malloc(len); - oom(desc); - - len = pos = 0; - if (!split) - desc[len++] = '"'; - b = a; - while((c = *b++)) { - if (c == '"') { - buf[0] = '\\'; - buf[1] = '"'; - buf[2] = 0; - } - else if (c == '\\') { - switch ((c = *b++)) { - case 0: - b--; - buf[0] = 0; - break; - case '/': - buf[0] = '/'; - buf[1] = 0; - break; - default: - buf[0] = '\\'; - buf[1] = c; - buf[2] = 0; - break; - } - } - else { - buf[0] = c; - buf[1] = 0; - } - i = e = 0; - while (buf[i]) { - if (split) { - if (pos >= 77 && !e) { - desc[len++] = '"'; - desc[len++] = '\n'; - pos = 0; - } - if (pos == 0) { - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = '"'; - pos = 5; - } - } - c = buf[i++]; - desc[len++] = c; - e = !e && c == '\\'; - pos++; - } - } - desc[len++] = '"'; - if (split) - desc[len++] = '\n'; - desc[len] = 0; - return desc; -} - -/* make the description of the object */ -char *make_desc(struct json_object *o) -{ - return make_info(json_object_to_json_string_ext(o, 0), 1); -} - -/* get the permission odescription if set */ -struct json_object *permissions_of_verb(struct json_object *obj) -{ - struct json_object *x, *y; - - if (json_object_object_get_ex(obj, "x-permissions", &x)) - return x; - - if (json_object_object_get_ex(obj, "get", &x)) - if (json_object_object_get_ex(x, "x-permissions", &y)) - return y; - - return NULL; -} - -/* output the array of permissions */ -void print_perms() -{ - int i, n; - const char *fmtstr = cpp ? "\t%s" : "\t{ %s }"; - - n = a_perms ? (int)json_object_array_length(a_perms) : 0; - if (n) { - printf("static const struct afb_auth _afb_auths_%s[] = {\n" , capi); - i = 0; - while (i < n) { - printf(fmtstr, json_object_get_string(json_object_array_get_idx(a_perms, i))); - printf(",\n"+(++i == n)); - } - printf("};\n\n"); - } -} - -/* - * search in the global object 'd_perm' the computed representation - * of the permission described either by 'obj' or 'desc' - */ -struct json_object *new_perm(struct json_object *obj, const char *desc) -{ - const char *tag; - char *b; - struct json_object *x, *y; - - tag = obj ? json_object_to_json_string_ext(obj, 0) : desc; - if (!json_object_object_get_ex(d_perms, tag, &y)) { - - /* creates the d_perms dico and the a_perms array */ - if (!d_perms) { - d_perms = json_object_new_object(); - a_perms = json_object_new_array(); - } - - /* creates the reference in the structure */ - asprintf(&b, "&_afb_auths_%s[%d]", capi, (int)json_object_array_length(a_perms)); - x = json_object_new_string(desc); - y = json_object_new_string(b); - json_object_array_add(a_perms, x); - json_object_object_add(d_perms, tag, y); - free(b); - } - return y; -} - -struct json_object *decl_perm(struct json_object *obj); - -enum optype { And, Or }; - -/* recursive declare and/or permissions */ -struct json_object *decl_perm_a(enum optype op, struct json_object *obj) -{ - int i, n; - char *a; - const char *opstr, *fmtstr; - struct json_object *x, *y; - - if (cpp) { - fmtstr = "afb::auth_%s(%s, %s)"; - opstr = op==And ? "and" : "or"; - } else { - fmtstr = ".type = afb_auth_%s, .first = %s, .next = %s"; - opstr = op==And ? "And" : "Or"; - } - x = NULL; - i = n = obj ? (int)json_object_array_length(obj) : 0; - while (i) { - y = decl_perm(json_object_array_get_idx(obj, --i)); - if (!y) - ; - else if (!x) - x = y; - else if (x != y) { - asprintf(&a, fmtstr, opstr, json_object_get_string(y), json_object_get_string(x)); - x = new_perm(NULL, a); - free(a); - } - } - return x; -} - -/* declare the permission for obj */ -struct json_object *decl_perm(struct json_object *obj) -{ - char *a; - const char *fmt; - struct json_object *x, *y; - - if (json_object_object_get_ex(d_perms, json_object_to_json_string_ext(obj, 0), &x)) - return x; - - if (json_object_object_get_ex(obj, "permission", &x)) { - if (cpp) - fmt = "afb::auth_permission(\"%s\")"; - else - fmt = ".type = afb_auth_Permission, .text = \"%s\""; - asprintf(&a, fmt, json_object_get_string(x)); - y = new_perm(obj, a); - free(a); - } - else if (json_object_object_get_ex(obj, "anyOf", &x)) { - y = decl_perm_a(Or, x); - } - else if (json_object_object_get_ex(obj, "allOf", &x)) { - y = decl_perm_a(And, x); - } - else if (json_object_object_get_ex(obj, "not", &x)) { - x = decl_perm(x); - if (cpp) - fmt = "afb::auth_not(%s)"; - else - fmt = ".type = afb_auth_Not, .first = %s"; - asprintf(&a, fmt, json_object_get_string(x)); - y = new_perm(obj, a); - free(a); - } - else if (json_object_object_get_ex(obj, "LOA", &x)) - y = NULL; - else if (json_object_object_get_ex(obj, "session", &x)) - y = NULL; - else - y = NULL; - - return y; -} - -void declare_permissions(const char *name, struct json_object *obj) -{ - struct json_object *p; - - p = permissions_of_verb(obj); - if (p) - decl_perm(p); -} - - -#define SESSION_CLOSE 0x000001 -#define SESSION_RENEW 0x000010 -#define SESSION_CHECK 0x000100 -#define SESSION_LOA_1 0x001000 -#define SESSION_LOA_2 0x011000 -#define SESSION_LOA_3 0x111000 -#define SESSION_MASK 0x111111 - - -int get_session(struct json_object *obj); - -int get_session_a(int and, struct json_object *obj) -{ - int i, n, x, y; - - n = obj ? (int)json_object_array_length(obj) : 0; - if (n == 0) - return 0; - - i = n; - x = get_session(json_object_array_get_idx(obj, --i)); - while (i) { - y = get_session(json_object_array_get_idx(obj, --i)); - if (and) - x &= y; - else - x |= y; - } - return x; -} - -int get_session(struct json_object *obj) -{ - int y; - const char *a; - struct json_object *x; - - y = 0; - if (json_object_object_get_ex(obj, "anyOf", &x)) { - y = get_session_a(1, x); - } - else if (json_object_object_get_ex(obj, "allOf", &x)) { - y = get_session_a(0, x); - } - else if (json_object_object_get_ex(obj, "not", &x)) { - y = ~get_session(x) & SESSION_MASK; - } - else if (json_object_object_get_ex(obj, "LOA", &x)) { - switch (json_object_get_int(x)) { - case 3: y = SESSION_LOA_3; break; - case 2: y = SESSION_LOA_2; break; - case 1: y = SESSION_LOA_1; break; - default: break; - } - } - else if (json_object_object_get_ex(obj, "session", &x)) { - a = json_object_get_string(x); - if (!strcmp(a, "check")) - y = SESSION_CHECK; - else if (!strcmp(a, "close")) - y = SESSION_CLOSE; - } - else if (json_object_object_get_ex(obj, "token", &x)) { - a = json_object_get_string(x); - if (!strcmp(a, "refresh")) - y = SESSION_RENEW; - } - - return y; -} - -void print_session(struct json_object *p) -{ - int s, c, l; - - s = p ? get_session(p) : 0; - c = 1; - if (s & SESSION_CHECK) { - printf("%s", "|AFB_SESSION_CHECK" + c); - c = 0; - } - if (s & SESSION_LOA_3 & ~SESSION_LOA_2) - l = 3; - else if (s & SESSION_LOA_2 & ~SESSION_LOA_1) - l = 2; - else if (s & SESSION_LOA_1) - l = 1; - else - l = 0; - if (l) { - printf("%s%d", "|AFB_SESSION_LOA_" + c, l); - c = 0; - } - if (s & SESSION_CLOSE) { - printf("%s", "|AFB_SESSION_CLOSE" + c); - c = 0; - } - if (s & SESSION_RENEW) { - printf("%s", "|AFB_SESSION_REFRESH" + c); - c = 0; - } - if (c) - printf("AFB_SESSION_NONE"); -} - -void print_verb(const char *name) -{ - printf("%s%s%s" , prefix, name, postfix); -} - -void print_declare_verb(const char *name, struct json_object *obj) -{ - if (T(scope)) - printf("%s ", scope); - printf("void "); - print_verb(name); - printf("(afb_req_t req);\n"); -} - -void print_struct_verb(const char *name, struct json_object *obj) -{ - struct json_object *p, *i; - const char *info; - - info = NULL; - if (json_object_object_get_ex(obj, "description", &i)) - info = json_object_get_string(i); - - p = permissions_of_verb(obj); - printf( - " {\n" - " .verb = \"%s\",\n" - " .callback = " - , name - ); - print_verb(name); - printf( - ",\n" - " .auth = %s,\n" - " .info = %s,\n" - , p && decl_perm(p) ? json_object_get_string(decl_perm(p)) : "NULL" - , info ? make_info(info, 0) : "NULL" - ); - if (version == 3) - printf( - " .vcbdata = NULL,\n" - ); - printf( - " .session = " - ); - print_session(p); - if (version == 3) - printf( - ",\n" - " .glob = 0" - ); - printf( - "\n" - " },\n" - ); -} - -void enum_verbs(void (*func)(const char *name, struct json_object *obj)) -{ - struct json_object_iterator ji, jn; - struct json_object *paths, *obj; - const char *name; - - /* search the verbs */ - paths = search("#/paths"); - if (!paths) - return; - - /* list the verbs and sort it */ - ji = json_object_iter_begin(paths); - jn = json_object_iter_end(paths); - while (!json_object_iter_equal(&ji, &jn)) { - name = json_object_iter_peek_name(&ji); - obj = json_object_iter_peek_value(&ji); - name += (*name == '/'); - func(name, obj); - json_object_iter_next(&ji); - } -} - -void getvarbool(int *var, const char *path, int defval) -{ - struct json_object *o; - - if (*var != 0 && *var != 1) { - o = search(path); - if (o && json_object_is_type(o, json_type_boolean)) - *var = json_object_get_boolean(o); - else - *var = !!defval; - } -} - -void getvar(const char **var, const char *path, const char *defval) -{ - struct json_object *o; - - if (!*var) { - o = search(path); - if (o && json_object_is_type(o, json_type_string)) - *var = json_object_get_string(o); - else - *var = defval; - } -} - -/** - * process a file and prints its expansion on stdout - */ -void process(char *filename) -{ - char *desc; - const char *info; - - /* translate - */ - if (!strcmp(filename, "-")) - filename = "/dev/stdin"; - - /* check access */ - if (access(filename, R_OK)) { - fprintf(stderr, "can't access file %s\n", filename); - exit(1); - } - - /* read the file */ - root = json_object_from_file(filename); - if (!root) { - fprintf(stderr, "reading file %s produced null\n", filename); - exit(1); - } - - /* create the description */ - desc = make_desc(root); - - /* expand references */ - root = expand_$ref((struct path){ .object = root, .upper = NULL }); - - /* get some names */ - getvar(&api, "#/info/x-binding-c-generator/api", NULL); - getvar(&preinit, "#/info/x-binding-c-generator/preinit", NULL); - getvar(&init, "#/info/x-binding-c-generator/init", NULL); - getvar(&onevent, "#/info/x-binding-c-generator/onevent", NULL); - getvar(&scope, "#/info/x-binding-c-generator/scope", "static"); - getvar(&prefix, "#/info/x-binding-c-generator/prefix", "afb_verb_"); - getvar(&postfix, "#/info/x-binding-c-generator/postfix", "_cb"); - getvar(&provideclass, "#/info/x-binding-c-generator/provide-class", NULL); - getvar(&requireclass, "#/info/x-binding-c-generator/require-class", NULL); - getvar(&requireapi, "#/info/x-binding-c-generator/require-api", NULL); - getvarbool(&priv, "#/info/x-binding-c-generator/private", 0); - getvarbool(&noconc, "#/info/x-binding-c-generator/noconcurrency", 0); - getvar(&api, "#/info/title", "?"); - info = NULL; - getvar(&info, "#/info/description", NULL); - capi = cify(api); - - /* get the API name */ - printf( - "\n" - "static const char _afb_description_%s[] =\n" - "%s" - ";\n" - "\n" - , capi, desc - ); - enum_verbs(declare_permissions); - print_perms(); - enum_verbs(print_declare_verb); - printf( - "\n" - "static const struct afb_verb_v%d _afb_verbs_%s[] = {\n" - , version, capi - ); - enum_verbs(print_struct_verb); - printf( - " {\n" - " .verb = NULL,\n" - " .callback = NULL,\n" - " .auth = NULL,\n" - " .info = NULL,\n" - ); - if (version == 3) - printf( - " .vcbdata = NULL,\n" - ); - printf( - " .session = 0" - ); - if (version == 3) - printf( - ",\n" - " .glob = 0" - ); - printf( - "\n" - " }\n" - "};\n" - ); - - if (T(preinit) || T(init) || T(onevent)) { - printf("\n"); - if (T(preinit)) { - if (T(scope)) printf("%s ", scope); - printf("int %s(%s);\n", preinit, version==3 ? "afb_api_t api" : ""); - } - if (T(init)) { - if (T(scope)) printf("%s ", scope); - printf("int %s(%s);\n", init, version==3 ? "afb_api_t api" : ""); - } - if (T(onevent)) { - if (T(scope)) printf("%s ", scope); - printf("void %s(%sconst char *event, struct json_object *object);\n", - onevent, version==3 ? "afb_api_t api, " : ""); - } - } - - printf( - "\n" - "%sconst struct afb_binding_v%d %s%s = {\n" - " .api = \"%s\",\n" - " .specification = _afb_description_%s,\n" - " .info = %s,\n" - " .verbs = _afb_verbs_%s,\n" - " .preinit = %s,\n" - " .init = %s,\n" - " .onevent = %s,\n" - , priv ? "static " : "" - , version - , priv ? "_afb_binding_" : version==3 ? "afbBindingV3" : "afbBindingV2" - , priv ? capi : "" - , api - , capi - , info ? make_info(info, 0) : "NULL" - , capi - , T(preinit) ? preinit : "NULL" - , T(init) ? init : "NULL" - , T(onevent) ? onevent : "NULL" - ); - - - if (version == 3) - printf( - " .userdata = NULL,\n" - " .provide_class = %s%s%s,\n" - " .require_class = %s%s%s,\n" - " .require_api = %s%s%s,\n" - , T(provideclass) ? "\"" : "", T(provideclass) ? provideclass : "NULL", T(provideclass) ? "\"" : "" - , T(requireclass) ? "\"" : "", T(requireclass) ? requireclass : "NULL", T(requireclass) ? "\"" : "" - , T(requireapi) ? "\"" : "", T(requireapi) ? requireapi : "NULL", T(requireapi) ? "\"" : "" - ); - - - printf( - " .noconcurrency = %d\n" - "};\n" - "\n" - , !!noconc - ); - - /* clean up */ - json_object_put(root); - free(desc); -} - -/** process the list of files or stdin if none */ -int main(int ac, char **av) -{ - int r, w; - av++; - - r = w = 0; - while (av[r]) { - if (!(strcmp(av[r], "-x") && strcmp(av[r], "--cpp"))) { - cpp = 1; - r++; - } else if (!strcmp(av[r], "-2")) { - version = 2; - r++; - } else if (!strcmp(av[r], "-3")) { - version = 3; - r++; - } else { - av[w++] = av[r++]; - } - } - av[w] = NULL; - if (!*av) - process("-"); - else { - do { process(*av++); } while(*av); - } - return 0; -} - diff --git a/src/devtools/genskel.md b/src/devtools/genskel.md new file mode 100644 index 00000000..8b137891 --- /dev/null +++ b/src/devtools/genskel.md @@ -0,0 +1 @@ + diff --git a/src/devtools/getref.c b/src/devtools/getref.c new file mode 100644 index 00000000..9e829dd5 --- /dev/null +++ b/src/devtools/getref.c @@ -0,0 +1,84 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/* + * This simple program expands the object { "$ref": "#/path/to/a/target" } + * + * For example: + * + * { + * "type":{ + * "a": "int", + * "b": { "$ref": "#/type/a" } + * } + * } + * + * will be exapanded to + * + * { + * "type":{ + * "a": "int", + * "b": "int" + * } + * } + * + * Invocation: program [file|-]... + * + * without arguments, it reads the input. + */ + +#define _GNU_SOURCE +#include +#include + +#include + +#include "getref.h" + +/** + * Search for a reference of type "#/a/b/c" int the + * parsed JSON root object + */ +int search$ref(struct json_object *root, const char *ref, struct json_object **result) +{ + char *d; + struct json_object *i; + + /* does it match #/ at the beginning? */ + if (ref[0] != '#' || (ref[0] && ref[1] != '/')) { + fprintf(stderr, "$ref invalid. Was: %s", ref); + return 0; + } + + /* search from root to target */ + i = root; + d = strdupa(ref+2); + d = strtok(d, "/"); + while(i && d) { + if (!json_object_object_get_ex(i, d, &i)) + return 0; + d = strtok(NULL, "/"); + } + if (result) + *result = i; + return 1; +} + +struct json_object *get$ref(struct json_object *root, const char *ref) +{ + struct json_object *result; + return search$ref(root, ref, &result) ? result : NULL; +} diff --git a/src/devtools/getref.h b/src/devtools/getref.h new file mode 100644 index 00000000..afa3838a --- /dev/null +++ b/src/devtools/getref.h @@ -0,0 +1,23 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#pragma once + +struct json_object; + +extern int search$ref(struct json_object *root, const char *ref, struct json_object **result); +extern struct json_object *get$ref(struct json_object *root, const char *ref); diff --git a/src/devtools/idl-monitor.json b/src/devtools/idl-monitor.json new file mode 100644 index 00000000..5afc29d0 --- /dev/null +++ b/src/devtools/idl-monitor.json @@ -0,0 +1,296 @@ +{ + "afbidl": "0.1", + "info": { + "description": "monitoring of bindings and internals", + "title": "monitor", + "version": "1.0" + }, + "generator": { + "genskel": { + "version": 2, + "prefix": "f_", + "postfix": "", + "preinit": null, + "init": null, + "onevent": null, + "scope": "static", + "private": true + } + }, + "api": { + "name": "monitor", + "verbs": { + "get": { + "description": "Get monitoring data.", + "permissions": { "session": "check" }, + "request": { "$ref": "#/schemas/get-request" }, + "reply": { "$ref": "#/schemas/get-reply" } + }, + "set": { + "description": "Set monitoring actions.", + "permissions": { "session": "check" }, + "request": { "$ref": "#/schemas/set-request" }, + "reply": { "$ref": "#/schemas/any" } + }, + "trace": { + "description": "Set monitoring actions.", + "permissions": { "session": "check" }, + "request": { "$ref": "#/schemas/trace-request" }, + "reply": { "$ref": "#/schemas/any" } + }, + "session": { + "description": "describes the session.", + "permissions": { "session": "check" }, + "request": { "$ref": "#/schemas/session-request" }, + "reply": { "$ref": "#/schemas/any" } + } + } + }, + "schemas": { + "any": { + "title": "Any value", + "type": [ "null", "boolean", "object", "array", "number", "string" ] + }, + "set-request": { + "type": "object", + "properties": { + "verbosity": { "$ref": "#/schemas/set-verbosity" } + } + }, + "set-verbosity": { + "anyOf": [ + { "$ref": "#/schemas/verbosity-map" }, + { "$ref": "#/schemas/verbosity-level" } + ] + }, + "get-request": { + "type": "object", + "properties": { + "verbosity": { "$ref": "#/schemas/get-verbosity" }, + "apis": { "$ref": "#/schemas/get-apis" } + } + }, + "get-reply": { + "type": "object", + "properties": { + "verbosity": { "$ref": "#/schemas/verbosity-map" }, + "apis": { "type": "object" } + } + }, + "get-verbosity": { + "anyOf": [ + { "type": "boolean" }, + { "type": "array", "items": { "type": "string" } }, + { "type": "object" } + ] + }, + "get-apis": { + "anyOf": [ + { "type": "boolean" }, + { "type": "array", "items": { "type": "string" } }, + { "type": "object" } + ] + }, + "verbosity-map": { + "type": "object", + "patternProperties": { "^.*$": { "$ref": "#/schemas/verbosity-level" } } + }, + "verbosity-level": { + "enum": [ "debug", 3, "info", 2, "notice", "warning", 1, "error", 0 ] + }, + "trace-request": { + "type": "object", + "properties": { + "add": { "$ref": "#/schemas/trace-add" }, + "drop": { "$ref": "#/schemas/trace-drop" } + } + }, + "trace-add": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-add-object" } }, + { "$ref": "#/schemas/trace-add-any" } + ] + }, + "trace-add-any": { + "anyOf": [ + { "$ref": "#/schemas/trace-add-request" }, + { "$ref": "#/schemas/trace-add-object" } + ] + }, + "trace-add-object": { + "type": "object", + "properties": { + "name": { "type": "string", "description": "name of the generated event", "default": "trace" }, + "tag": { "type": "string", "description": "tag for grouping traces", "default": "trace" }, + "api": { "type": "string", "description": "api for requests, daemons and services" }, + "verb": { "type": "string", "description": "verb for requests" }, + "uuid": { "type": "string", "description": "uuid of session for requests" }, + "pattern": { "type": "string", "description": "pattern for events" }, + "request": { "$ref": "#/schemas/trace-add-request" }, + "daemon": { "$ref": "#/schemas/trace-add-daemon" }, + "service": { "$ref": "#/schemas/trace-add-service" }, + "event": { "$ref": "#/schemas/trace-add-event" }, + "session": { "$ref": "#/schemas/trace-add-session" }, + "for": { "$ref": "#/schemas/trace-add" } + }, + "examples": [ + { "tag": "1", "for": [ "common", { "api": "xxx", "request": "*", "daemon": "*", "service": "*" } ] } + ] + }, + "trace-add-request": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-request-names" } }, + { "$ref": "#/schemas/trace-request-names" } + ] + }, + "trace-request-names": { + "title": "name of traceable items of requests", + "enum": [ + "*", + "addref", + "all", + "args", + "begin", + "common", + "context", + "context_get", + "context_set", + "end", + "event", + "extra", + "get", + "json", + "life", + "ref", + "reply", + "result", + "session", + "session_close", + "session_set_LOA", + "simple", + "store", + "stores", + "subcall", + "subcall_result", + "subcalls", + "subcallsync", + "subcallsync_result", + "subscribe", + "unref", + "unstore", + "unsubscribe", + "vverbose" + ] + }, + "trace-add-daemon": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-daemon-names" } }, + { "$ref": "#/schemas/trace-daemon-names" } + ] + }, + "trace-daemon-names": { + "title": "name of traceable items of daemons", + "enum": [ + "*", + "all", + "common", + "event_broadcast_after", + "event_broadcast_before", + "event_make", + "extra", + "get_event_loop", + "get_system_bus", + "get_user_bus", + "queue_job", + "require_api", + "require_api_result", + "rootdir_get_fd", + "rootdir_open_locale", + "unstore_req", + "vverbose" + ] + }, + "trace-add-service": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-service-names" } }, + { "$ref": "#/schemas/trace-service-names" } + ] + }, + "trace-service-names": { + "title": "name of traceable items of services", + "enum": [ + "*", + "all", + "call", + "call_result", + "callsync", + "callsync_result", + "on_event_after", + "on_event_before", + "start_after", + "start_before" + ] + }, + "trace-add-event": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-event-names" } }, + { "$ref": "#/schemas/trace-event-names" } + ] + }, + "trace-event-names": { + "title": "name of traceable items of events", + "enum": [ + "*", + "all", + "broadcast_after", + "broadcast_before", + "common", + "create", + "drop", + "extra", + "name", + "push_after", + "push_before" + ] + }, + "trace-add-session": { + "anyOf": [ + { "type": "array", "items": { "$ref": "#/schemas/trace-session-names" } }, + { "$ref": "#/schemas/trace-session-names" } + ] + }, + "trace-session-names": { + "title": "name of traceable items for sessions", + "enum": [ + "*", + "addref", + "all", + "close", + "common", + "create", + "destroy", + "renew", + "unref" + ] + }, + "trace-drop": { + "anyOf": [ + { "type": "boolean" }, + { + "type": "object", + "properties": { + "event": { "anyOf": [ { "type": "string" }, { "type": "array", "items": "string" } ] }, + "tag": { "anyOf": [ { "type": "string" }, { "type": "array", "items": "string" } ] }, + "uuid": { "anyOf": [ { "type": "string" }, { "type": "array", "items": "string" } ] } + } + } + ] + }, + "session-request": { + "type": "object", + "properties": { + "refresh-token": { "type": "boolean" } + } + } + } +} diff --git a/src/devtools/json2c.c b/src/devtools/json2c.c index 9bb9e9bf..c26ef84a 100644 --- a/src/devtools/json2c.c +++ b/src/devtools/json2c.c @@ -42,133 +42,141 @@ #define _GNU_SOURCE #include +#include +#include #include -#include #include -#define oom(x) do{if(!(x)){fprintf(stderr,"out of memory\n");exit(1);}}while(0) - -/** - * root of the JSON being parsed - */ -struct json_object *root = NULL; - -char *make_desc(struct json_object *o) +static size_t s2c(const char *str, const char *prefix, int width, int lprf, char *out) { - const char *a, *b; - char *desc, c, buf[3]; + char c, buf[4]; size_t len; - int i, pos, e; - - a = b = json_object_to_json_string_ext(root, 0); - len = 1; - while((c = *b++)) { - len += 1 + ('"' == c); - } - - len += 7 * (1 + len / 72); - desc = malloc(len); - oom(desc); + int i, pos; +#define P(x) do{ if (out) out[len] = (x); len++; pos++; }while(0) + /* translate the string */ len = pos = 0; - b = a; - while((c = *b++)) { - if (c == '"') { + for(;;) { + /* get the char to convert */ + c = *str++; + + /* set buf with next char */ + switch(c) { + case '\\': + c = *str++; + if (c) { + if (c == '/') { + /* remove ugly \/ put by json-c */ + buf[0] = '/'; + buf[1] = 0; + } else { + buf[0] = '\\'; + buf[1] = c; + buf[2] = 0; + } + break; + } + /*@fallthrough@*/ + case 0: + if (!len) P('"'); + if (!len || pos) { + P('"'); + if (prefix) P('\n'); + } + P(0); + return len; + case '"': buf[0] = '\\'; buf[1] = '"'; buf[2] = 0; - } - else if (c == '\\') { - switch ((c = *b++)) { - case '/': - buf[0] = '/'; - buf[1] = 0; - break; - case 0: - b--; - /*@fallthrough@*/ - default: + break; + case '\n': + buf[0] = '\\'; + buf[1] = 'n'; + buf[2] = 0; + break; + case '\t': + buf[0] = '\\'; + buf[1] = 't'; + buf[2] = 0; + break; + default: + if (0 < c && c < ' ') { buf[0] = '\\'; - buf[1] = c; - buf[2] = 0; + buf[1] = (char)('0' + ((c >> 3) & 7)); + buf[2] = (char)('0' + ((c >> 0) & 7)); + buf[3] = 0; + } else { + buf[0] = c; + buf[1] = 0; break; } + break; } - else { - buf[0] = c; - buf[1] = 0; + /* add the char in the output */ + if (pos == 0) { + for(i = 0 ; i < lprf ; i++) + P(prefix[i]); + P('"'); } - i = e = 0; - while (buf[i]) { - if (pos >= 77 && !e) { - desc[len++] = '"'; - desc[len++] = '\n'; - pos = 0; - } - if (pos == 0) { - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = ' '; - desc[len++] = '"'; - pos = 5; - } - c = buf[i++]; - desc[len++] = c; - e = !e && c == '\\'; - pos++; + for(i = 0 ; buf[i] ; i++) + P(buf[i]); + if (pos >= width - 1) { + P('"'); + P('\n'); + pos = 0; } } - desc[len++] = '"'; - desc[len++] = '\n'; - desc[len] = 0; - return desc; + while(c); +#undef P } -/** - * process a file and prints its expansion on stdout - */ -void process(char *filename) +char *str2c(const char *str, const char *prefix, int width) { - char *desc; + size_t len; + int lprf; + char *out; - /* translate - */ - if (!strcmp(filename, "-")) - filename = "/dev/stdin"; + /* ensure defaults */ + len = prefix ? strlen(prefix) : 0; + lprf = len > INT_MAX ? INT_MAX : (int)len; + width = width <= 0 || width - 2 <= lprf ? INT_MAX : width; - /* check access */ - if (access(filename, R_OK)) { - fprintf(stderr, "can't access file %s\n", filename); - exit(1); - } + /* compute final size*/ + len = s2c(str, prefix, width, lprf, NULL); - /* read the file */ - root = json_object_from_file(filename); - if (!root) { - fprintf(stderr, "reading file %s produced null\n", filename); - exit(1); - } + /* allocate the memory */ + out = malloc(len); + if (!out) + return NULL; - /* create the description */ - desc = make_desc(root); + /* make the output */ + s2c(str, prefix, width, lprf, out); + return out; +} - printf("%s", desc); +char *str2c_std(const char *str) +{ + return str2c(str, "\t", 71); +} - /* clean up */ - json_object_put(root); - free(desc); +char *str2c_inl(const char *str) +{ + return str2c(str, 0, 0); } -/** process the list of files or stdin if none */ -int main(int ac, char **av) +char *json2c(struct json_object *object, const char *prefix, int width) { - if (!*++av) - process("-"); - else { - do { process(*av); } while(*++av); - } - return 0; + return str2c(json_object_to_json_string_ext(object, 0), prefix, width); } +char *json2c_std(struct json_object *object) +{ + return str2c_std(json_object_to_json_string_ext(object, 0)); +} +char *json2c_inl(struct json_object *object) +{ + return str2c_inl(json_object_to_json_string_ext(object, 0)); +} diff --git a/src/devtools/json2c.h b/src/devtools/json2c.h new file mode 100644 index 00000000..9c4e7e26 --- /dev/null +++ b/src/devtools/json2c.h @@ -0,0 +1,28 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#pragma once + +struct json_object; + +extern char *str2c(const char *str, const char *prefix, int width); +extern char *str2c_std(const char *str); +extern char *str2c_inl(const char *str); + +extern char *json2c(struct json_object *object, const char *prefix, int width); +extern char *json2c_std(struct json_object *object); +extern char *json2c_inl(struct json_object *object); diff --git a/src/devtools/main-exprefs.c b/src/devtools/main-exprefs.c new file mode 100644 index 00000000..5a114a2a --- /dev/null +++ b/src/devtools/main-exprefs.c @@ -0,0 +1,102 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/* + * This simple program expands the object { "$ref": "#/path/to/a/target" } + * + * For example: + * + * { + * "type":{ + * "a": "int", + * "b": { "$ref": "#/type/a" } + * } + * } + * + * will be exapanded to + * + * { + * "type":{ + * "a": "int", + * "b": "int" + * } + * } + * + * Invocation: program [file|-]... + * + * without arguments, it reads the input. + */ + +#define _GNU_SOURCE +#include +#include +#include + +#include + +#include "exprefs.h" + +/** + * process a file and prints its expansion on stdout + */ +void process(char *filename) +{ + struct json_object *root; + + /* translate - */ + if (!strcmp(filename, "-")) + filename = "/dev/stdin"; + + /* check access */ + if (access(filename, R_OK)) { + fprintf(stderr, "can't access file %s\n", filename); + exit(1); + } + + /* read the file */ + root = json_object_from_file(filename); + if (!root) { + fprintf(stderr, "reading file %s produced null\n", filename); + exit(1); + } + + /* expand */ + root = exp$refs(root); + + /* check if tree */ + if (!exp$refs_is_tree(root)) { + fprintf(stderr, "expansion of %s doesn't produce a tree\n", filename); + exit(1); + } + + /* print the result */ + json_object_to_file_ext ("/dev/stdout", root, JSON_C_TO_STRING_PRETTY); + + /* clean up */ + json_object_put(root); +} + +/** process the list of files or stdin if none */ +int main(int ac, char **av) +{ + if (!*++av) + process("-"); + else { + do { process(*av); } while(*++av); + } + return 0; +} + diff --git a/src/devtools/main-genskel.c b/src/devtools/main-genskel.c new file mode 100644 index 00000000..bad7ee97 --- /dev/null +++ b/src/devtools/main-genskel.c @@ -0,0 +1,711 @@ +/* + * Copyright (C) 2016-2019 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#define _GNU_SOURCE +#include +#include +#include +#include + +#include + +#include "getref.h" +#include "exprefs.h" +#include "json2c.h" + +#define TEST(x) ((x) && *(x)) +#define OOM(x) do{if(!(x)){fprintf(stderr,"out of memory\n");exit(1);}}while(0) + +/** + * root of the JSON being parsed + */ +int version = 3; +struct json_object *root = NULL; +struct json_object *d_perms = NULL; +struct json_object *a_perms = NULL; +const char *preinit = NULL; +const char *init = NULL; +const char *onevent = NULL; +const char *api = NULL; +const char *scope = NULL; +const char *prefix = NULL; +const char *postfix = NULL; +const char *provideclass = NULL; +const char *requireclass = NULL; +const char *requireapi = NULL; +const char *info = NULL; +char *capi = NULL; +int priv = -1; +int noconc = -1; +int cpp = 0; +enum idl { + idl_afbidl = 0, + idl_openapi = 1 +} idl = idl_openapi; + + + +/* create c name by replacing non alpha numeric characters with underscores */ +char *cify(const char *str) +{ + char *r = strdup(str); + int i = 0; + while (r && r[i]) { + if (!isalnum(r[i])) + r[i] = '_'; + i++; + } + return r; +} + +/* get the permission odescription if set */ +struct json_object *permissions_of_verb(struct json_object *obj) +{ + struct json_object *x, *y; + + if (idl == idl_afbidl) + return json_object_object_get_ex(obj, "permissions", &x) ? x : NULL; + + if (json_object_object_get_ex(obj, "x-permissions", &x)) + return x; + + if (json_object_object_get_ex(obj, "get", &x)) + if (json_object_object_get_ex(x, "x-permissions", &y)) + return y; + + return NULL; +} + +/* output the array of permissions */ +void print_perms() +{ + int i, n; + const char *fmtstr = cpp ? "\t%s" : "\t{ %s }"; + + n = a_perms ? (int)json_object_array_length(a_perms) : 0; + if (n) { + printf("static const struct afb_auth _afb_auths_%s[] = {\n" , capi); + i = 0; + while (i < n) { + printf(fmtstr, json_object_get_string(json_object_array_get_idx(a_perms, i))); + printf(",\n"+(++i == n)); + } + printf("};\n\n"); + } +} + +/* + * search in the global object 'd_perm' the computed representation + * of the permission described either by 'obj' or 'desc' + */ +struct json_object *new_perm(struct json_object *obj, const char *desc) +{ + const char *tag; + char *b; + struct json_object *x, *y; + + tag = obj ? json_object_to_json_string_ext(obj, 0) : desc; + if (!json_object_object_get_ex(d_perms, tag, &y)) { + + /* creates the d_perms dico and the a_perms array */ + if (!d_perms) { + d_perms = json_object_new_object(); + a_perms = json_object_new_array(); + } + + /* creates the reference in the structure */ + asprintf(&b, "&_afb_auths_%s[%d]", capi, (int)json_object_array_length(a_perms)); + x = json_object_new_string(desc); + y = json_object_new_string(b); + json_object_array_add(a_perms, x); + json_object_object_add(d_perms, tag, y); + free(b); + } + return y; +} + +struct json_object *decl_perm(struct json_object *obj); + +enum optype { And, Or }; + +/* recursive declare and/or permissions */ +struct json_object *decl_perm_a(enum optype op, struct json_object *obj) +{ + int i, n; + char *a; + const char *opstr, *fmtstr; + struct json_object *x, *y; + + if (cpp) { + fmtstr = "afb::auth_%s(%s, %s)"; + opstr = op==And ? "and" : "or"; + } else { + fmtstr = ".type = afb_auth_%s, .first = %s, .next = %s"; + opstr = op==And ? "And" : "Or"; + } + x = NULL; + i = n = obj ? (int)json_object_array_length(obj) : 0; + while (i) { + y = decl_perm(json_object_array_get_idx(obj, --i)); + if (!y) + ; + else if (!x) + x = y; + else if (x != y) { + asprintf(&a, fmtstr, opstr, json_object_get_string(y), json_object_get_string(x)); + x = new_perm(NULL, a); + free(a); + } + } + return x; +} + +/* declare the permission for obj */ +struct json_object *decl_perm(struct json_object *obj) +{ + char *a; + const char *fmt; + struct json_object *x, *y; + + if (json_object_object_get_ex(d_perms, json_object_to_json_string_ext(obj, 0), &x)) + return x; + + if (json_object_object_get_ex(obj, "permission", &x)) { + if (cpp) + fmt = "afb::auth_permission(\"%s\")"; + else + fmt = ".type = afb_auth_Permission, .text = \"%s\""; + asprintf(&a, fmt, json_object_get_string(x)); + y = new_perm(obj, a); + free(a); + } + else if (json_object_object_get_ex(obj, "anyOf", &x)) { + y = decl_perm_a(Or, x); + } + else if (json_object_object_get_ex(obj, "allOf", &x)) { + y = decl_perm_a(And, x); + } + else if (json_object_object_get_ex(obj, "not", &x)) { + x = decl_perm(x); + if (cpp) + fmt = "afb::auth_not(%s)"; + else + fmt = ".type = afb_auth_Not, .first = %s"; + asprintf(&a, fmt, json_object_get_string(x)); + y = new_perm(obj, a); + free(a); + } + else if (json_object_object_get_ex(obj, "LOA", &x)) + y = NULL; + else if (json_object_object_get_ex(obj, "session", &x)) + y = NULL; + else + y = NULL; + + return y; +} + +void declare_permissions(const char *name, struct json_object *obj) +{ + struct json_object *p; + + p = permissions_of_verb(obj); + if (p) + decl_perm(p); +} + + +#define SESSION_CLOSE 0x000001 +#define SESSION_RENEW 0x000010 +#define SESSION_CHECK 0x000100 +#define SESSION_LOA_1 0x001000 +#define SESSION_LOA_2 0x011000 +#define SESSION_LOA_3 0x111000 +#define SESSION_MASK 0x111111 + + +int get_session(struct json_object *obj); + +int get_session_a(int and, struct json_object *obj) +{ + int i, n, x, y; + + n = obj ? (int)json_object_array_length(obj) : 0; + if (n == 0) + return 0; + + i = n; + x = get_session(json_object_array_get_idx(obj, --i)); + while (i) { + y = get_session(json_object_array_get_idx(obj, --i)); + if (and) + x &= y; + else + x |= y; + } + return x; +} + +int get_session(struct json_object *obj) +{ + int y; + const char *a; + struct json_object *x; + + y = 0; + if (json_object_object_get_ex(obj, "anyOf", &x)) { + y = get_session_a(1, x); + } + else if (json_object_object_get_ex(obj, "allOf", &x)) { + y = get_session_a(0, x); + } + else if (json_object_object_get_ex(obj, "not", &x)) { + y = ~get_session(x) & SESSION_MASK; + } + else if (json_object_object_get_ex(obj, "LOA", &x)) { + switch (json_object_get_int(x)) { + case 3: y = SESSION_LOA_3; break; + case 2: y = SESSION_LOA_2; break; + case 1: y = SESSION_LOA_1; break; + default: break; + } + } + else if (json_object_object_get_ex(obj, "session", &x)) { + a = json_object_get_string(x); + if (!strcmp(a, "check")) + y = SESSION_CHECK; + else if (!strcmp(a, "close")) + y = SESSION_CLOSE; + } + else if (json_object_object_get_ex(obj, "token", &x)) { + a = json_object_get_string(x); + if (!strcmp(a, "refresh")) + y = SESSION_RENEW; + } + + return y; +} + +void print_session(struct json_object *p) +{ + int s, c, l; + + s = p ? get_session(p) : 0; + c = 1; + if (s & SESSION_CHECK) { + printf("%s", "|AFB_SESSION_CHECK" + c); + c = 0; + } + if (s & SESSION_LOA_3 & ~SESSION_LOA_2) + l = 3; + else if (s & SESSION_LOA_2 & ~SESSION_LOA_1) + l = 2; + else if (s & SESSION_LOA_1) + l = 1; + else + l = 0; + if (l) { + printf("%s%d", "|AFB_SESSION_LOA_" + c, l); + c = 0; + } + if (s & SESSION_CLOSE) { + printf("%s", "|AFB_SESSION_CLOSE" + c); + c = 0; + } + if (s & SESSION_RENEW) { + printf("%s", "|AFB_SESSION_REFRESH" + c); + c = 0; + } + if (c) + printf("AFB_SESSION_NONE"); +} + +void print_verb(const char *name) +{ + printf("%s%s%s" , prefix, name, postfix); +} + +void print_declare_verb(const char *name, struct json_object *obj) +{ + if (TEST(scope)) + printf("%s ", scope); + printf("void "); + print_verb(name); + printf("(afb_req_t req);\n"); +} + +void print_struct_verb(const char *name, struct json_object *obj) +{ + struct json_object *p, *i; + const char *info; + + info = NULL; + if (json_object_object_get_ex(obj, "description", &i)) + info = json_object_get_string(i); + + p = permissions_of_verb(obj); + printf( + " {\n" + " .verb = \"%s\",\n" + " .callback = " + , name + ); + print_verb(name); + printf( + ",\n" + " .auth = %s,\n" + " .info = %s,\n" + , p && decl_perm(p) ? json_object_get_string(decl_perm(p)) : "NULL" + , info ? str2c_inl(info) : "NULL" + ); + if (version == 3) + printf( + " .vcbdata = NULL,\n" + ); + printf( + " .session = " + ); + print_session(p); + if (version == 3) + printf( + ",\n" + " .glob = 0" + ); + printf( + "\n" + " },\n" + ); +} + +void getvarbool(int *var, const char *path, int defval) +{ + struct json_object *o; + + if (*var != 0 && *var != 1) { + o = get$ref(root, path); + if (o && json_object_is_type(o, json_type_boolean)) + *var = json_object_get_boolean(o); + else + *var = !!defval; + } +} + +void getvar(const char **var, const char *path, const char *defval) +{ + struct json_object *o; + + if (!*var) { + o = get$ref(root, path); + if (o && json_object_is_type(o, json_type_string)) + *var = json_object_get_string(o); + else + *var = defval; + } +} + +/******************************************************************************/ + +void openapi_getvars() +{ + getvar(&api, "#/info/x-binding-c-generator/api", NULL); + getvar(&preinit, "#/info/x-binding-c-generator/preinit", NULL); + getvar(&init, "#/info/x-binding-c-generator/init", NULL); + getvar(&onevent, "#/info/x-binding-c-generator/onevent", NULL); + getvar(&scope, "#/info/x-binding-c-generator/scope", "static"); + getvar(&prefix, "#/info/x-binding-c-generator/prefix", "afb_verb_"); + getvar(&postfix, "#/info/x-binding-c-generator/postfix", "_cb"); + getvar(&provideclass, "#/info/x-binding-c-generator/provide-class", NULL); + getvar(&requireclass, "#/info/x-binding-c-generator/require-class", NULL); + getvar(&requireapi, "#/info/x-binding-c-generator/require-api", NULL); + getvarbool(&priv, "#/info/x-binding-c-generator/private", 0); + getvarbool(&noconc, "#/info/x-binding-c-generator/noconcurrency", 0); + getvar(&api, "#/info/title", "?"); + getvar(&info, "#/info/description", NULL); +} + +void openapi_enum_verbs(void (*func)(const char *name, struct json_object *obj)) +{ + struct json_object_iterator ji, jn; + struct json_object *paths, *obj; + const char *name; + + /* search the verbs */ + paths = get$ref(root, "#/paths"); + if (!paths) + return; + + /* list the verbs and sort it */ + ji = json_object_iter_begin(paths); + jn = json_object_iter_end(paths); + while (!json_object_iter_equal(&ji, &jn)) { + name = json_object_iter_peek_name(&ji); + obj = json_object_iter_peek_value(&ji); + name += (*name == '/'); + func(name, obj); + json_object_iter_next(&ji); + } +} + +/******************************************************************************/ + +void afbidl_getvars() +{ + getvar(&preinit, "#/generator/genskel/preinit", NULL); + getvar(&init, "#/generator/genskel/init", NULL); + getvar(&onevent, "#/generator/genskel/onevent", NULL); + getvar(&scope, "#/generator/genskel/scope", "static"); + getvar(&prefix, "#/generator/genskel/prefix", "afb_verb_"); + getvar(&postfix, "#/generator/genskel/postfix", "_cb"); + getvar(&provideclass, "#/generator/genskel/provide-class", NULL); + getvar(&requireclass, "#/generator/genskel/require-class", NULL); + getvar(&requireapi, "#/generator/genskel/require-api", NULL); + getvarbool(&priv, "#/generator/genskel/private", 0); + getvarbool(&noconc, "#/generator/genskel/noconcurrency", 0); + getvar(&api, "#/api/name", NULL); + getvar(&api, "#/info/title", "?"); + getvar(&info, "#/info/description", NULL); +} + +void afbidl_enum_verbs(void (*func)(const char *name, struct json_object *obj)) +{ + struct json_object_iterator ji, jn; + struct json_object *verbs, *obj; + const char *name; + + /* search the verbs */ + verbs = get$ref(root, "#/api/verbs"); + if (!verbs) + return; + + /* list the verbs and sort it */ + ji = json_object_iter_begin(verbs); + jn = json_object_iter_end(verbs); + while (!json_object_iter_equal(&ji, &jn)) { + name = json_object_iter_peek_name(&ji); + obj = json_object_iter_peek_value(&ji); + func(name, obj); + json_object_iter_next(&ji); + } +} + +/******************************************************************************/ + +void detectidl() +{ + struct json_object *o; + + o = get$ref(root, "#/openapi"); + if (o) { + idl = idl_openapi; + return; + } + o = get$ref(root, "#/afbidl"); + if (o) { + idl = idl_afbidl; + return; + } +} + +/** + * process a file and prints its expansion on stdout + */ +void process(char *filename) +{ + char *desc; + + void (*getvars)(); + void (*enum_verbs)(void (*)(const char*, struct json_object*)); + + /* translate - */ + if (!strcmp(filename, "-")) + filename = "/dev/stdin"; + + /* check access */ + if (access(filename, R_OK)) { + fprintf(stderr, "can't access file %s\n", filename); + exit(1); + } + + /* read the file */ + root = json_object_from_file(filename); + if (!root) { + fprintf(stderr, "reading file %s produced null\n", filename); + exit(1); + } + + /* create the description (before expanding $ref ) */ + desc = json2c_std(root); + + /* expand references */ + root = exp$refs(root); + + /* detect the idl */ + detectidl(); + switch(idl) { + default: + case idl_afbidl: + getvars = afbidl_getvars; + enum_verbs = afbidl_enum_verbs; + break; + case idl_openapi: + getvars = openapi_getvars; + enum_verbs = openapi_enum_verbs; + break; + } + + /* get some names */ + getvars(); + capi = cify(api); + + /* get the API name */ + printf( + "\n" + "static const char _afb_description_%s[] =\n" + "%s" + ";\n" + "\n" + , capi, desc + ); + enum_verbs(declare_permissions); + print_perms(); + enum_verbs(print_declare_verb); + printf( + "\n" + "static const struct afb_verb_v%d _afb_verbs_%s[] = {\n" + , version, capi + ); + enum_verbs(print_struct_verb); + printf( + " {\n" + " .verb = NULL,\n" + " .callback = NULL,\n" + " .auth = NULL,\n" + " .info = NULL,\n" + ); + if (version == 3) + printf( + " .vcbdata = NULL,\n" + ); + printf( + " .session = 0" + ); + if (version == 3) + printf( + ",\n" + " .glob = 0" + ); + printf( + "\n" + " }\n" + "};\n" + ); + + if (TEST(preinit) || TEST(init) || TEST(onevent)) { + printf("\n"); + if (TEST(preinit)) { + if (TEST(scope)) printf("%s ", scope); + printf("int %s(%s);\n", preinit, version==3 ? "afb_api_t api" : ""); + } + if (TEST(init)) { + if (TEST(scope)) printf("%s ", scope); + printf("int %s(%s);\n", init, version==3 ? "afb_api_t api" : ""); + } + if (TEST(onevent)) { + if (TEST(scope)) printf("%s ", scope); + printf("void %s(%sconst char *event, struct json_object *object);\n", + onevent, version==3 ? "afb_api_t api, " : ""); + } + } + + printf( + "\n" + "%sconst struct afb_binding_v%d %s%s = {\n" + " .api = \"%s\",\n" + " .specification = _afb_description_%s,\n" + " .info = %s,\n" + " .verbs = _afb_verbs_%s,\n" + " .preinit = %s,\n" + " .init = %s,\n" + " .onevent = %s,\n" + , priv ? "static " : "" + , version + , priv ? "_afb_binding_" : version==3 ? "afbBindingV3" : "afbBindingV2" + , priv ? capi : "" + , api + , capi + , info ? str2c_inl(info) : "NULL" + , capi + , TEST(preinit) ? preinit : "NULL" + , TEST(init) ? init : "NULL" + , TEST(onevent) ? onevent : "NULL" + ); + + + if (version == 3) + printf( + " .userdata = NULL,\n" + " .provide_class = %s%s%s,\n" + " .require_class = %s%s%s,\n" + " .require_api = %s%s%s,\n" + , TEST(provideclass) ? "\"" : "", TEST(provideclass) ? provideclass : "NULL", TEST(provideclass) ? "\"" : "" + , TEST(requireclass) ? "\"" : "", TEST(requireclass) ? requireclass : "NULL", TEST(requireclass) ? "\"" : "" + , TEST(requireapi) ? "\"" : "", TEST(requireapi) ? requireapi : "NULL", TEST(requireapi) ? "\"" : "" + ); + + + printf( + " .noconcurrency = %d\n" + "};\n" + "\n" + , !!noconc + ); + + /* clean up */ + json_object_put(root); + free(desc); +} + +/** process the list of files or stdin if none */ +int main(int ac, char **av) +{ + int r, w; + av++; + + r = w = 0; + while (av[r]) { + if (!(strcmp(av[r], "-x") && strcmp(av[r], "--cpp"))) { + cpp = 1; + r++; + } else if (!strcmp(av[r], "-2")) { + version = 2; + r++; + } else if (!strcmp(av[r], "-3")) { + version = 3; + r++; + } else { + av[w++] = av[r++]; + } + } + av[w] = NULL; + if (!*av) + process("-"); + else { + do { process(*av++); } while(*av); + } + return 0; +} + diff --git a/src/devtools/main-json2c.c b/src/devtools/main-json2c.c new file mode 100644 index 00000000..eb0c7a05 --- /dev/null +++ b/src/devtools/main-json2c.c @@ -0,0 +1,103 @@ +/* + * Copyright (C) 2016, 2017, 2018 "IoT.bzh" + * Author José Bollo + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ +/* + * This simple program expands the object { "$ref": "#/path/to/a/target" } + * + * For example: + * + * { + * "type":{ + * "a": "int", + * "b": { "$ref": "#/type/a" } + * } + * } + * + * will be exapanded to + * + * { + * "type":{ + * "a": "int", + * "b": "int" + * } + * } + * + * Invocation: program [file|-]... + * + * without arguments, it reads the input. + */ + +#define _GNU_SOURCE +#include +#include +#include + +#include + +#include "json2c.h" + +/** + * process a file and prints its expansion on stdout + */ +void process(char *filename) +{ + char *desc; + struct json_object *root; + + /* translate - */ + if (!strcmp(filename, "-")) + filename = "/dev/stdin"; + + /* check access */ + if (access(filename, R_OK)) { + fprintf(stderr, "can't access file %s\n", filename); + exit(1); + } + + /* read the file */ + root = json_object_from_file(filename); + if (!root) { + fprintf(stderr, "reading file %s produced null\n", filename); + exit(1); + } + + /* create the description */ + desc = json2c_std(root); + if (!desc) { + fprintf(stderr, "out of memory\n"); + exit(1); + } + + /* print the description */ + printf("%s", desc); + + /* clean up */ + json_object_put(root); + free(desc); +} + +/** process the list of files or stdin if none */ +int main(int ac, char **av) +{ + if (!*++av) + process("-"); + else { + do { process(*av); } while(*++av); + } + return 0; +} + + -- cgit 1.2.3-korg