aboutsummaryrefslogtreecommitdiffstats
path: root/src/aft.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/aft.c')
-rw-r--r--src/aft.c70
1 files changed, 48 insertions, 22 deletions
diff --git a/src/aft.c b/src/aft.c
index 3ce4c0f..b5dd29b 100644
--- a/src/aft.c
+++ b/src/aft.c
@@ -27,7 +27,10 @@
#define CONTROL_PREFIX "aft"
// default api to print log when apihandle not avaliable
afb_api_t AFB_default;
-static int CtrlCreateApi(AFB_ApiT apiHandle, const char *configPath);
+
+static CtlConfigT *CtrlLoadConfigJson(AFB_ApiT apiHandle, json_object *configJ);
+static CtlConfigT *CtrlLoadConfigFile(AFB_ApiT apiHandle, const char *configPath);
+static int CtrlCreateApi(AFB_ApiT apiHandle, CtlConfigT *ctrlConfig);
// Config Section definition
static CtlSectionT ctrlSections[] = {
@@ -47,13 +50,33 @@ static void ctrlapi_ping(AFB_ReqT request) {
}
static void ctrlapi_load(AFB_ReqT request) {
- const char *configPath = afb_req_value(request, "filepath");
+ const char *configPath = NULL;
+ json_object *reqArgs = afb_req_json(request), *configuration = NULL ;
afb_api_t apiHandle = afb_req_get_api(request);
- if(!CtrlCreateApi(apiHandle, configPath))
- AFB_ReqSuccess(request, NULL, NULL);
- else
- AFB_ReqFailF(request, "Error", "Not able to load test API with the configuration file: %s", configPath);
+ if(!json_object_object_get_ex(reqArgs, "configuration", &configuration)) {
+ AFB_ReqFailF(request, "Error", "No 'configuration' key found in request arguments: %s", json_object_get_string(reqArgs));
+ return;
+ }
+
+ switch(json_object_get_type(configuration)) {
+ case json_type_string:
+ configPath = json_object_get_string(configuration);
+ if(CtrlCreateApi(apiHandle, CtrlLoadConfigFile(apiHandle, configPath)))
+ AFB_ReqFailF(request, "Error", "Not able to load test API with the file: %s", configPath);
+ else
+ AFB_ReqSuccess(request, NULL, NULL);
+ break;
+ case json_type_object:
+ if(CtrlCreateApi(apiHandle, CtrlLoadConfigJson(apiHandle, configuration)))
+ AFB_ReqFailF(request, "Error", "Not able to load test API with the JSON: %s", json_object_get_string(configuration));
+ else
+ AFB_ReqSuccess(request, NULL, NULL);
+ break;
+ default:
+ AFB_ReqFailF(request, "Error", "the found JSON isn't valid type, it should be a string indicating a filepath to the JSON to load or an object representing the configuration. We got: %s", json_object_get_string(configuration));
+ break;
+ }
}
static void ctrlapi_exit(AFB_ReqT request) {
@@ -91,9 +114,6 @@ static int CtrlInitOneApi(AFB_ApiT apiHandle) {
return CtlConfigExec(apiHandle, ctrlConfig);
}
-// next generation dynamic API-V3 mode
-#include <signal.h>
-
static int CtrlLoadOneApi(void *cbdata, AFB_ApiT apiHandle) {
CtlConfigT *ctrlConfig = (CtlConfigT *)cbdata;
@@ -120,23 +140,28 @@ static int CtrlLoadOneApi(void *cbdata, AFB_ApiT apiHandle) {
return err;
}
-static int CtrlCreateApi(AFB_ApiT apiHandle, const char *configPath) {
+static CtlConfigT *CtrlLoadConfigJson(AFB_ApiT apiHandle, json_object *configJ) {
+ return CtlLoadMetaDataJson(apiHandle, configJ, CONTROL_PREFIX);
+}
+
+static CtlConfigT *CtrlLoadConfigFile(AFB_ApiT apiHandle, const char *configPath) {
+ return CtlLoadMetaDataUsingPrefix(apiHandle, configPath, CONTROL_PREFIX);
+}
+
+static int CtrlCreateApi(AFB_ApiT apiHandle, CtlConfigT *ctrlConfig) {
int err = 0;
json_object *resourcesJ = NULL, *eventsJ = NULL;
- CtlConfigT *ctrlConfig = NULL;
-// load config file and create API
- ctrlConfig = CtlLoadMetaDataUsingPrefix(apiHandle, configPath, CONTROL_PREFIX);
+
if(!ctrlConfig) {
AFB_ApiError(apiHandle,
- "CtrlBindingDyn No valid control config file in:\n-- %s",
- configPath);
- return ERROR;
+ "CtrlBindingDyn No valid control config file loaded.");
+ return ERROR;
}
if(!ctrlConfig->api) {
AFB_ApiError(apiHandle,
"CtrlBindingDyn API Missing from metadata in:\n-- %s",
- configPath);
+ json_object_get_string(ctrlConfig->configJ));
return ERROR;
}
@@ -158,9 +183,10 @@ static int CtrlCreateApi(AFB_ApiT apiHandle, const char *configPath) {
wrap_json_object_add(ctrlConfig->configJ, resourcesJ);
wrap_json_object_add(ctrlConfig->configJ, eventsJ);
- if(afb_api_new_api(apiHandle, ctrlConfig->api, ctrlConfig->info, 1, CtrlLoadOneApi, ctrlConfig))
- return err;
- return -1;
+ if(! afb_api_new_api(apiHandle, ctrlConfig->api, ctrlConfig->info, 1, CtrlLoadOneApi, ctrlConfig))
+ return ERROR;
+
+ return 0;
}
int afbBindingEntry(afb_api_t apiHandle) {
@@ -169,7 +195,7 @@ int afbBindingEntry(afb_api_t apiHandle) {
const char *envDirList = NULL, *configPath = NULL;
AFB_default = apiHandle;
- AFB_ApiNotice(apiHandle, "Controller in afbBindingEntry");
+ AFB_ApiDebug(apiHandle, "Controller in afbBindingEntry");
envDirList = getEnvDirList(CONTROL_PREFIX, "CONFIG_PATH");
@@ -188,5 +214,5 @@ int afbBindingEntry(afb_api_t apiHandle) {
return ERROR;
}
- return CtrlCreateApi(apiHandle, configPath);
+ return CtrlCreateApi(apiHandle, CtrlLoadConfigFile(apiHandle, configPath));
}