summaryrefslogtreecommitdiffstats
path: root/signal-composer-binding/signal-composer-binding.cpp
diff options
context:
space:
mode:
authorForlot Romain [IoT.bzh] <claneys@iot.bzh>2017-09-04 23:37:22 +0200
committerRomain Forlot <romain.forlot@iot.bzh>2017-12-14 10:59:55 +0100
commit19bc13783a7451c81848ea132614a8df11c7740a (patch)
treeb61995b1af0914559f6de6461bda3dd76f2e724c /signal-composer-binding/signal-composer-binding.cpp
parent29168eb150eae139685c40c0bec22a5b7485cb66 (diff)
Initial commit
Change-Id: I2bb38bffdd92602659670901b8442201b7c56214 Signed-off-by: Romain Forlot <romain.forlot@iot.bzh>
Diffstat (limited to 'signal-composer-binding/signal-composer-binding.cpp')
-rw-r--r--signal-composer-binding/signal-composer-binding.cpp90
1 files changed, 90 insertions, 0 deletions
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" <romain.forlot@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, 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;
+}