From 19bc13783a7451c81848ea132614a8df11c7740a Mon Sep 17 00:00:00 2001 From: "Forlot Romain [IoT.bzh]" Date: Mon, 4 Sep 2017 23:37:22 +0200 Subject: Initial commit Change-Id: I2bb38bffdd92602659670901b8442201b7c56214 Signed-off-by: Romain Forlot --- .../signal-composer-binding.cpp | 90 ++++++++++++++++++++++ 1 file changed, 90 insertions(+) create mode 100644 signal-composer-binding/signal-composer-binding.cpp (limited to 'signal-composer-binding/signal-composer-binding.cpp') diff --git a/signal-composer-binding/signal-composer-binding.cpp b/signal-composer-binding/signal-composer-binding.cpp new file mode 100644 index 0000000..24b81f6 --- /dev/null +++ b/signal-composer-binding/signal-composer-binding.cpp @@ -0,0 +1,90 @@ +/* + * Copyright (C) 2015, 2016 "IoT.bzh" + * Author "Romain Forlot" + * + * 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. + */ + +#include "signal-composer-binding.hpp" +#include "signal-composer-apidef.h" +#include "wrap-json.h" +#include "signal-composer.hpp" + +SignalComposer SigComp; + +/// @brief callback for receiving message from low binding. Treatment itself is made in SigComp class. +void onEvent(const char *event, json_object *object) +{ + SigComp.treatMessage(object); +} +/// @brief entry point for client subscription request. Treatment itself is made in SigComp class. +void subscribe(afb_req request) +{ + if(SigComp.subscribe(request)) + afb_req_success(request, NULL, NULL); + else + afb_req_fail(request, "error", NULL); +} + +/// @brief entry point for client un-subscription request. Treatment itself is made in SigComp class. +void unsubscribe(afb_req request) +{ + if(SigComp.unsubscribe(request)) + afb_req_success(request, NULL, NULL); + else + afb_req_fail(request, "error when unsubscribe", NULL); +} + +/// @brief verb that loads JSON configuration (old SigComp.json file now) +void load(afb_req request) +{ + json_object* args = afb_req_json(request); + const char* confd; + + wrap_json_unpack(args, "{s:s}", "path", &confd); + int ret = SigComp.parseConfigAndSubscribe(confd); + if( ret == 0) + afb_req_success(request, NULL, NULL); + else + afb_req_fail_f(request, "Loading configuration or subscription error", "Error code: %d", ret); +} + +/// @brief entry point for get requests. Treatment itself is made in SigComp class. +void get(afb_req request) +{ + json_object *jobj; + if(SigComp.get(request, &jobj)) + { + afb_req_success(request, jobj, NULL); + } else { + afb_req_fail(request, "error", NULL); + } +} + +/// @brief entry point for systemD timers. Treatment itself is made in SigComp class. +/// @param[in] source: systemD timer, t: time of tick, data: interval (ms). +int ticked(sd_event_source *source, uint64_t t, void* data) +{ + SigComp.tick(source, t, data); + return 0; +} + +/// @brief Initialize the binding. +/// +/// @return Exit code, zero if success. +int init_service() +{ + AFB_DEBUG("SigComp level binding is initializing"); + AFB_NOTICE("SigComp level binding is initialized and running"); + return 0; +} -- cgit 1.2.3-korg