summaryrefslogtreecommitdiffstats
path: root/helloworld-subscribe-event/helloworld-service-binding.c
diff options
context:
space:
mode:
authorronan <ronan.lemartret@iot.bzh>2019-10-10 11:44:25 +0200
committerronan <ronan.lemartret@iot.bzh>2019-11-04 11:47:06 +0100
commit895e65610c78eb883b70c971c2c29e300ca063d3 (patch)
tree2c67a5d3c45204dd8cb86192d5a51a4cb03328f2 /helloworld-subscribe-event/helloworld-service-binding.c
parent7a5a796cdbd2658cf6f621aab209849818a67839 (diff)
- Add dependency on agl-libafb-helpers, very useful on agl binding. - Add subscription button on html interface. - After starting the timer, you can subscribe and so unsubscribe to a timer event. - Update the README.md. Bug-AGL: SPEC-2778 Signed-off-by: ronan <ronan.lemartret@iot.bzh> Change-Id: I8cc08a191a93972082060d267276df467b053589 Signed-off-by: ronan <ronan.lemartret@iot.bzh>
Diffstat (limited to 'helloworld-subscribe-event/helloworld-service-binding.c')
-rw-r--r--helloworld-subscribe-event/helloworld-service-binding.c133
1 files changed, 0 insertions, 133 deletions
diff --git a/helloworld-subscribe-event/helloworld-service-binding.c b/helloworld-subscribe-event/helloworld-service-binding.c
deleted file mode 100644
index ce525e7..0000000
--- a/helloworld-subscribe-event/helloworld-service-binding.c
+++ /dev/null
@@ -1,133 +0,0 @@
-/*
- * Copyright (C) 2016-2018 "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>
-
-static afb_event_t event;
-
-static void pingSample(afb_req_t request)
-{
- static int pingcount = 0;
- int listeners = 0;
-
- if(afb_event_is_valid(event))
- listeners = afb_event_push(event, json_object_new_int(pingcount));
-
- afb_req_success_f(request, json_object_new_int(pingcount), "Ping count = %d, Event listeners = %d", pingcount, listeners);
-
- AFB_API_NOTICE(afbBindingV3root, "Verbosity macro at level notice invoked at ping invocation, count = %d, event listeners = %d", pingcount, listeners);
-
- pingcount++;
-}
-
-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, "PingCount");
-
-
- if(afb_req_subscribe(request, event) < 0) {
- afb_req_fail(request, "Error", "Subscription operation failed");
- return;
- }
-
- afb_req_success(request, NULL, NULL);
-
- AFB_API_NOTICE(request->api, "Verbosity macro at level notice 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_API_NOTICE(request->api, "Verbosity macro at level notice invoked at unsubscribe invocation");
-}
-
-// testArgsSample - return success only if argument is set to {"cezam": "open"}
-static void testArgsSample(afb_req_t request)
-{
- json_object *tmpJ;
- json_object *res = json_object_new_object();
- json_object *queryJ = afb_req_json(request);
-
- json_bool success = json_object_object_get_ex(queryJ, "cezam", &tmpJ);
- if (!success) {
- afb_req_fail_f(request, "ERROR", "key cezam not found in '%s'", json_object_get_string(queryJ));
- return;
- }
-
- if (json_object_get_type(tmpJ) != json_type_string) {
- afb_req_fail(request, "ERROR", "key cezam not a string");
- return;
- }
-
- if (strncmp(json_object_get_string(tmpJ), "open", 4) == 0) {
- json_object_object_add(res, "code", json_object_new_int(123456789));
- afb_req_success(request, res, NULL);
- return;
- }
-
- afb_req_fail_f(request, "ERROR", "value of cezam (%s) is not the expected one.",
- json_object_get_string(queryJ));
-}
-
-static const struct afb_auth _afb_auths_monitor[] = {
- {.type = afb_auth_Permission, .text = "urn:AGL:permission:monitor:public:set"},
- {.type = afb_auth_Permission, .text = "urn:AGL:permission:monitor:public:get"},
- {.type = afb_auth_Or, .first = &_afb_auths_monitor[1], .next = &_afb_auths_monitor[0]}
-};
-
-static const afb_verb_t verbs[] = {
- /*Without security*/
- {.verb = "ping", .session = AFB_SESSION_NONE, .callback = pingSample, .auth = NULL},
-
- /*With security "urn:AGL:permission:monitor:public:get"*/
- /*{ .verb = "ping" , .session = AFB_SESSION_NONE, .callback = pingSample , .auth = &_afb_auths_monitor[1]},*/
-
- {.verb = "subscribe", .session = AFB_SESSION_NONE, .callback = subscribeSample, .auth = NULL},
- {.verb = "unsubscribe", .session = AFB_SESSION_NONE, .callback = unsubscribeSample, .auth = NULL},
- {.verb = "testargs", .session = AFB_SESSION_NONE, .callback = testArgsSample, .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
-};