summaryrefslogtreecommitdiffstats
path: root/helloworld-subscribe-event/helloworld-event-service-binding.c
diff options
context:
space:
mode:
Diffstat (limited to 'helloworld-subscribe-event/helloworld-event-service-binding.c')
-rw-r--r--helloworld-subscribe-event/helloworld-event-service-binding.c107
1 files changed, 107 insertions, 0 deletions
diff --git a/helloworld-subscribe-event/helloworld-event-service-binding.c b/helloworld-subscribe-event/helloworld-event-service-binding.c
new file mode 100644
index 0000000..632142a
--- /dev/null
+++ b/helloworld-subscribe-event/helloworld-event-service-binding.c
@@ -0,0 +1,107 @@
+/*
+ * Copyright (C) 2016-2019 "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.
+ */
+#define _GNU_SOURCE
+#include <stdio.h>
+#include <string.h>
+#include <json-c/json.h>
+
+#define AFB_BINDING_VERSION 3
+#include <afb/afb-binding.h>
+
+#include <afb-timer.h>
+
+static afb_event_t event;
+static TimerHandleT *timer;
+
+static void timerCount()
+{
+ static int timerCount = 0;
+ int listeners = 0;
+
+ if(afb_event_is_valid(event))
+ listeners = afb_event_push(event, json_object_new_int(timerCount));
+
+ timerCount++;
+}
+
+static void startTimer(afb_req_t request)
+{
+ char *timeruid;
+ timer = (TimerHandleT*)calloc (1, sizeof(TimerHandleT));
+ timer->delay = (uint) 1000;
+ timer->count = -1; // run forever
+ timer->uid = timeruid;
+ TimerEvtStart(request->api, timer, timerCount, NULL);
+
+ afb_req_success(request, NULL, "startTimer");
+
+ AFB_REQ_NOTICE(request, "Invoked at startTimer");
+}
+
+static void subscribeSample(afb_req_t request)
+{
+ // Event not valid ? then creating one.
+ if(! afb_event_is_valid(event))
+ event = afb_api_make_event(request->api, "timerCount");
+
+ if(afb_req_subscribe(request, event) < 0) {
+ afb_req_fail(request, "Error", "Subscription operation failed");
+ return;
+ }
+
+ afb_req_success(request, NULL, "subscribeSample");
+
+ AFB_REQ_NOTICE(request, "Invoked at subscribe invocation");
+}
+
+static void unsubscribeSample(afb_req_t request)
+{
+ if(! afb_event_is_valid(event)) {
+ afb_req_fail(request, "Invalid", "Event not valid");
+ return;
+ }
+
+ if(afb_req_unsubscribe(request, event) < 0) {
+ afb_req_fail(request, "Error", "Unsubscription operation failed");
+ return;
+ }
+
+ afb_req_success(request, NULL, NULL);
+ AFB_REQ_NOTICE(request, "Invoked at unsubscribe invocation");
+}
+
+static const afb_verb_t verbs[] = {
+ /*Without security*/
+ {.verb = "startTimer", .session = AFB_SESSION_NONE, .callback = startTimer, .auth = NULL},
+
+ {.verb = "subscribe", .session = AFB_SESSION_NONE, .callback = subscribeSample, .auth = NULL},
+ {.verb = "unsubscribe", .session = AFB_SESSION_NONE, .callback = unsubscribeSample, .auth = NULL},
+ {NULL}
+};
+
+const afb_binding_t afbBindingExport = {
+ .api = "helloworld-event",
+ .specification = NULL,
+ .verbs = verbs,
+ .preinit = NULL,
+ .init = NULL,
+ .onevent = NULL,
+ .userdata = NULL,
+ .provide_class = NULL,
+ .require_class = NULL,
+ .require_api = NULL,
+ .noconcurrency = 0
+};