afb-evt: Refactor processing of broadcasted events
[src/app-framework-binder.git] / src / afb-evt.h
1 /*
2  * Copyright (C) 2016-2019 "IoT.bzh"
3  * Author: José Bollo <jose.bollo@iot.bzh>
4  *
5  * Licensed under the Apache License, Version 2.0 (the "License");
6  * you may not use this file except in compliance with the License.
7  * You may obtain a copy of the License at
8  *
9  *   http://www.apache.org/licenses/LICENSE-2.0
10  *
11  * Unless required by applicable law or agreed to in writing, software
12  * distributed under the License is distributed on an "AS IS" BASIS,
13  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14  * See the License for the specific language governing permissions and
15  * limitations under the License.
16  */
17
18 #pragma once
19
20 struct afb_event_x1;
21 struct afb_event_x2;
22 struct afb_evtid;
23 struct afb_session;
24 struct json_object;
25 struct afb_evt_listener;
26
27 struct afb_evt_itf
28 {
29         void (*push)(void *closure, const char *event, int evtid, struct json_object *object);
30         void (*broadcast)(void *closure, const char *event, struct json_object *object);
31         void (*add)(void *closure, const char *event, int evtid);
32         void (*remove)(void *closure, const char *event, int evtid);
33 };
34
35 extern struct afb_evt_listener *afb_evt_listener_create(const struct afb_evt_itf *itf, void *closure);
36
37 extern int afb_evt_broadcast(const char *event, struct json_object *object);
38
39 extern struct afb_evt_listener *afb_evt_listener_addref(struct afb_evt_listener *listener);
40 extern void afb_evt_listener_unref(struct afb_evt_listener *listener);
41
42 extern struct afb_evtid *afb_evt_evtid_create(const char *fullname);
43 extern struct afb_evtid *afb_evt_evtid_create2(const char *prefix, const char *name);
44
45 extern struct afb_evtid *afb_evt_evtid_addref(struct afb_evtid *evtid);
46
47 extern void afb_evt_evtid_unref(struct afb_evtid *evtid);
48
49 extern const char *afb_evt_evtid_fullname(struct afb_evtid *evtid);
50 extern int afb_evt_evtid_id(struct afb_evtid *evtid);
51
52 extern const char *afb_evt_evtid_name(struct afb_evtid *evtid);
53
54 extern int afb_evt_evtid_push(struct afb_evtid *evtid, struct json_object *obj);
55
56 extern int afb_evt_evtid_broadcast(struct afb_evtid *evtid, struct json_object *object);
57
58 extern int afb_evt_watch_add_evtid(struct afb_evt_listener *listener, struct afb_evtid *evtid);
59 extern int afb_evt_watch_sub_evtid(struct afb_evt_listener *listener, struct afb_evtid *evtid);
60
61
62
63 extern struct afb_event_x2 *afb_evt_event_x2_create(const char *fullname);
64 extern struct afb_event_x2 *afb_evt_event_x2_create2(const char *prefix, const char *name);
65 extern const char *afb_evt_event_x2_fullname(struct afb_event_x2 *event);
66 extern int afb_evt_event_x2_id(struct afb_event_x2 *eventid);
67 extern struct afb_event_x2 *afb_evt_event_x2_addref(struct afb_event_x2 *eventid);
68 extern void afb_evt_event_x2_unref(struct afb_event_x2 *eventid);
69
70 extern int afb_evt_event_x2_push(struct afb_event_x2 *eventid, struct json_object *object);
71 extern int afb_evt_event_x2_unhooked_push(struct afb_event_x2 *eventid, struct json_object *object);
72
73 extern int afb_evt_event_x2_add_watch(struct afb_evt_listener *listener, struct afb_event_x2 *eventid);
74 extern int afb_evt_event_x2_remove_watch(struct afb_evt_listener *listener, struct afb_event_x2 *eventid);
75
76 extern struct afb_evtid *afb_evt_event_x2_to_evtid(struct afb_event_x2 *eventid);
77 extern struct afb_event_x2 *afb_evt_event_x2_from_evtid(struct afb_evtid *evtid);
78
79 #if WITH_LEGACY_BINDING_V1 || WITH_LEGACY_BINDING_V2
80 extern struct afb_event_x1 afb_evt_event_from_evtid(struct afb_evtid *evtid);
81 #endif
82
83 #if WITH_AFB_HOOK
84 extern struct afb_evtid *afb_evt_evtid_hooked_addref(struct afb_evtid *evtid);
85 extern void afb_evt_evtid_hooked_unref(struct afb_evtid *evtid);
86 extern const char *afb_evt_evtid_hooked_name(struct afb_evtid *evtid);
87 extern int afb_evt_evtid_hooked_push(struct afb_evtid *evtid, struct json_object *obj);
88 extern int afb_evt_evtid_hooked_broadcast(struct afb_evtid *evtid, struct json_object *object);
89 extern void afb_evt_update_hooks();
90 #endif