diff options
Diffstat (limited to 'ctl-dispatch/ctl-config.c')
| -rw-r--r-- | ctl-dispatch/ctl-config.c | 176 |
1 files changed, 176 insertions, 0 deletions
diff --git a/ctl-dispatch/ctl-config.c b/ctl-dispatch/ctl-config.c new file mode 100644 index 0000000..b7c0d54 --- /dev/null +++ b/ctl-dispatch/ctl-config.c @@ -0,0 +1,176 @@ +/* + * Copyright (C) 2016 "IoT.bzh" + * Author Fulup Ar Foll <fulup@iot.bzh> + * + * 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, something express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + * Reference: + * Json load using json_unpack https://jansson.readthedocs.io/en/2.9/apiref.html#parsing-and-validating-values + */ + +#define _GNU_SOURCE +#include <stdio.h> +#include <string.h> + +#include "filescan-utils.h" +#include "ctl-config.h" + + +// Load control config file + +PUBLIC char* CtlConfigSearch(const char *dirList) { + int index, err; + char controlFile [CONTROL_MAXPATH_LEN]; + + strncpy(controlFile, CONTROL_CONFIG_PRE "-", CONTROL_MAXPATH_LEN); + strncat(controlFile, GetBinderName(), CONTROL_MAXPATH_LEN); + + // search for default dispatch config file + json_object* responseJ = ScanForConfig(dirList, CTL_SCAN_RECURSIVE, controlFile, ".json"); + + // We load 1st file others are just warnings + for (index = 0; index < json_object_array_length(responseJ); index++) { + json_object *entryJ = json_object_array_get_idx(responseJ, index); + + char *filename; + char*fullpath; + err = wrap_json_unpack(entryJ, "{s:s, s:s !}", "fullpath", &fullpath, "filename", &filename); + if (err) { + AFB_ERROR("CTL-INIT HOOPs invalid JSON entry= %s", json_object_get_string(entryJ)); + return NULL; + } + + if (index == 0) { + if (strcasestr(filename, controlFile)) { + char filepath[CONTROL_MAXPATH_LEN]; + strncpy(filepath, fullpath, sizeof (filepath)); + strncat(filepath, "/", sizeof (filepath)); + strncat(filepath, filename, sizeof (filepath)); + return (strdup(filepath)); + } + } + } + + // no config found + return NULL; +} + +PUBLIC int CtlConfigExec(CtlConfigT *ctlConfig) { + // best effort to initialise everything before starting + if (ctlConfig->requireJ) { + + void DispatchRequireOneApi(json_object * bindindJ) { + const char* requireBinding = json_object_get_string(bindindJ); + int err = afb_daemon_require_api(requireBinding, 1); + if (err) { + AFB_WARNING("CTL-LOAD-CONFIG:REQUIRE Fail to get=%s", requireBinding); + } + } + + if (json_object_get_type(ctlConfig->requireJ) == json_type_array) { + for (int idx = 0; idx < json_object_array_length(ctlConfig->requireJ); idx++) { + DispatchRequireOneApi(json_object_array_get_idx(ctlConfig->requireJ, idx)); + } + } else { + DispatchRequireOneApi(ctlConfig->requireJ); + } + } + +#ifdef CONTROL_SUPPORT_LUA + int err= LuaConfigExec(); + if (err) goto OnErrorExit; +#endif + + // Loop on every section and process config + int errcount=0; + for (int idx = 0; ctlConfig->sections[idx].key != NULL; idx++) { + errcount += ctlConfig->sections[idx].loadCB(&ctlConfig->sections[idx], NULL); + } + return errcount; + +OnErrorExit: + return 1; +} + +PUBLIC CtlConfigT *CtlConfigLoad(const char* filepath, CtlSectionT *sections) { + json_object *ctlConfigJ; + CtlConfigT *ctlConfig; + int err; + +#ifdef CONTROL_SUPPORT_LUA + err= LuaConfigLoad(); + if (err) goto OnErrorExit; +#endif + + // Search for config in filepath + filepath = CtlConfigSearch(filepath); + + if (!filepath) { + AFB_ERROR("CTL-LOAD-CONFIG No JSON Config found invalid JSON %s ", filepath); + goto OnErrorExit; + } + + // Load JSON file + ctlConfigJ = json_object_from_file(filepath); + if (!ctlConfigJ) { + AFB_ERROR("CTL-LOAD-CONFIG Not invalid JSON %s ", filepath); + goto OnErrorExit; + } + + AFB_INFO("CTL-LOAD-CONFIG: loading config filepath=%s", filepath); + + json_object *metadataJ; + int done = json_object_object_get_ex(ctlConfigJ, "metadata", &metadataJ); + if (done) { + ctlConfig = calloc(1, sizeof (CtlConfigT)); + err = wrap_json_unpack(metadataJ, "{ss,ss,ss,s?s,s?o !}", "label", &ctlConfig->label, "version", &ctlConfig->version + , "api", &ctlConfig->api, "info", &ctlConfig->info, "require", &ctlConfig->requireJ); + if (err) { + AFB_ERROR("CTL-LOAD-CONFIG:METADATA Missing something label|api|version|[info]|[require] in:\n-- %s", json_object_get_string(metadataJ)); + goto OnErrorExit; + } + + // Should replace this with API name change + if (ctlConfig->api) { + err = afb_daemon_rename_api(ctlConfig->api); + if (err) AFB_WARNING("Fail to rename api to:%s", ctlConfig->api); + } + + } + + //load config sections + err = 0; + ctlConfig->sections = sections; + for (int idx = 0; sections[idx].key != NULL; idx++) { + json_object * sectionJ; + int done = json_object_object_get_ex(ctlConfigJ, sections[idx].key, §ionJ); + if (!done) { + AFB_ERROR("CtlConfigLoad: fail to find '%s' section in config '%s'", sections[idx].key, filepath); + err++; + } else { + err += sections[idx].loadCB(§ions[idx], sectionJ); + } + + } + if (err) goto OnErrorExit; + + return (ctlConfig); + +OnErrorExit: + free(ctlConfig); + return NULL; +} + + + + |