From 2b77a50d5c578d92ac692b872f5a51c227c29334 Mon Sep 17 00:00:00 2001 From: fulup Date: Wed, 18 Oct 2017 11:31:33 +0200 Subject: 1st V2/pre-V3 version --- ctl-lib/ctl-event.c | 94 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 94 insertions(+) create mode 100644 ctl-lib/ctl-event.c (limited to 'ctl-lib/ctl-event.c') diff --git a/ctl-lib/ctl-event.c b/ctl-lib/ctl-event.c new file mode 100644 index 0000000..b9be1c7 --- /dev/null +++ b/ctl-lib/ctl-event.c @@ -0,0 +1,94 @@ +/* + * Copyright (C) 2016 "IoT.bzh" + * Author Fulup Ar Foll + * + * 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. + * + */ + +#define _GNU_SOURCE +#include +#include + +#include "ctl-config.h" + + +// Event dynamic API-V3 mode +#ifdef AFB_BINDING_PREV3 +PUBLIC void CtrlDispatchApiEvent (AFB_ApiT apiHandle, const char *evtLabel, struct json_object *eventJ) { + AFB_ApiNotice (apiHandle, "Received event=%s, query=%s", evtLabel, json_object_get_string(eventJ)); + + // retrieve section config from api handle + CtlConfigT *ctrlConfig = (CtlConfigT*) afb_dynapi_get_userdata(apiHandle); + + CtlActionT* actions = ctrlConfig->sections[CTL_SECTION_EVENT].actions; + + int index= ActionLabelToIndex(actions, evtLabel); + if (index < 0) { + AFB_ApiWarning(apiHandle, "CtlDispatchEvent: fail to find label=%s in action event section", evtLabel); + return; + } + + // create a dummy source for action + CtlSourceT source; + source.label = actions[index].label; + source.api = actions[index].api; + source.request = NULL; + + // Best effort ignoring error to exec corresponding action + (void) ActionExecOne (&source, &actions[index], eventJ); + +} +#else +// In API-V2 controller config is unique and static +extern CtlConfigT *ctrlConfig; + +// call action attached to even name if any +PUBLIC void CtrlDispatchV2Event(const char *evtLabel, json_object *eventJ) { + CtlActionT* actions = ctrlConfig->sections[CTL_SECTION_EVENT].actions; + + int index= ActionLabelToIndex(actions, evtLabel); + if (index < 0) { + AFB_WARNING ("CtlDispatchEvent: fail to find label=%s in action event section", evtLabel); + return; + } + + CtlSourceT source; + source.label = actions[index].label; + source.api = actions[index].api; + source.request = AFB_ReqNone; + + // Best effort ignoring error to exec corresponding action + (void) ActionExecOne (&source, &actions[index], eventJ); +} +#endif + +// onload section receive one action or an array of actions +PUBLIC int EventConfig(AFB_ApiT apiHandle, CtlSectionT *section, json_object *actionsJ) { + + // Load time parse actions in config file + if (actionsJ != NULL) { + section->actions= ActionConfig(apiHandle, actionsJ, 1); + + if (!section->actions) { + AFB_ApiError (apiHandle, "EventLoad config fail processing onload actions"); + goto OnErrorExit; + } + } + + return 0; + +OnErrorExit: + return 1; + +} -- cgit 1.2.3-korg