Don't send communities in triggered updates. Comms now flood!
[trust_router.git] / include / tr_comm.h
1 /*
2  * Copyright (c) 2012, 2015, JANET(UK)
3  * All rights reserved.
4  *
5  * Redistribution and use in source and binary forms, with or without
6  * modification, are permitted provided that the following conditions
7  * are met:
8  *
9  * 1. Redistributions of source code must retain the above copyright
10  *    notice, this list of conditions and the following disclaimer.
11  *
12  * 2. Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * 3. Neither the name of JANET(UK) nor the names of its contributors
17  *    may be used to endorse or promote products derived from this software
18  *    without specific prior written permission.
19  *
20  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
21  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
22  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS
23  * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
24  * COPYRIGHT HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT,
25  * INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
26  * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
27  * SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT,
29  * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
30  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
31  * OF THE POSSIBILITY OF SUCH DAMAGE.
32  *
33  */
34
35 #ifndef TR_COMM_H
36 #define TR_COMM_H
37
38 #include <talloc.h>
39 #include <time.h>
40
41 #include <tr_idp.h>
42 #include <tr_rp.h>
43 #include <tr_apc.h>
44
45 typedef struct tr_comm_table TR_COMM_TABLE;
46
47 typedef enum tr_comm_type {
48   TR_COMM_UNKNOWN,
49   TR_COMM_APC,
50   TR_COMM_COI
51 } TR_COMM_TYPE;
52
53 typedef struct tr_comm {
54   struct tr_comm *next;
55   TR_NAME *id;
56   TR_COMM_TYPE type;
57   TR_APC *apcs;
58   TR_NAME *owner_realm; /* what realm owns this community? */
59   TR_NAME *owner_contact; /* contact email */
60   time_t expiration_interval; /*Minutes to key expiration; only valid for an APC*/
61   unsigned int refcount; /* how many TR_COMM_MEMBs refer to this community? */
62 } TR_COMM;
63
64 /* community membership - link realms to their communities */
65 typedef struct tr_comm_memb {
66   struct tr_comm_memb *next;
67   struct tr_comm_memb *origin_next; /* for multiple copies from different origins */
68   TR_IDP_REALM *idp; /* only set one of idp and rp, other null */
69   TR_RP_REALM *rp; /* only set one of idp and rp, other null */
70   TR_COMM *comm;
71   TR_NAME *origin;
72   json_t *provenance; /* array of names of systems traversed */
73   unsigned int interval;
74   struct timespec *expiry;
75   int triggered; /* do we need to send this with triggered updates? */
76 } TR_COMM_MEMB;
77
78 /* table of communities/memberships */
79 struct tr_comm_table {
80   TR_COMM *comms; /* all communities */
81   TR_IDP_REALM *idp_realms; /* all idp realms */
82   TR_RP_REALM *rp_realms; /* all rp realms */
83   TR_COMM_MEMB *memberships; /* head of the linked list of membership records */
84 }; 
85
86 typedef enum tr_realm_role {
87   TR_ROLE_UNKNOWN=0,
88   TR_ROLE_IDP,
89   TR_ROLE_RP
90 } TR_REALM_ROLE;
91
92 typedef struct tr_realm {
93   TR_REALM_ROLE role;
94   TR_RP_REALM *rp;
95   TR_IDP_REALM *idp;
96 } TR_REALM;
97
98 /* nb, not all iterator routines use all members */
99 typedef struct tr_comm_iter {
100   TR_COMM *cur_comm;
101   TR_COMM_MEMB *cur_memb;
102   TR_NAME *match; /* realm or comm to match */
103   TR_REALM *realm; /* handle so caller does not have to manage memory, private */
104 } TR_COMM_ITER;
105
106
107 TR_COMM_TABLE *tr_comm_table_new(TALLOC_CTX *mem_ctx);
108 void tr_comm_table_free(TR_COMM_TABLE *ctab);
109
110 TR_COMM_TABLE *tr_comm_table_new(TALLOC_CTX *mem_ctx);
111 void tr_comm_table_free(TR_COMM_TABLE *ctab);
112 void tr_comm_table_add_comm(TR_COMM_TABLE *ctab, TR_COMM *new);
113 void tr_comm_table_remove_comm(TR_COMM_TABLE *ctab, TR_COMM *comm);
114 void tr_comm_table_add_memb(TR_COMM_TABLE *ctab, TR_COMM_MEMB *new);
115 void tr_comm_table_remove_memb(TR_COMM_TABLE *ctab, TR_COMM_MEMB *memb);
116 TR_COMM_MEMB *tr_comm_table_find_memb_origin(TR_COMM_TABLE *ctab, TR_NAME *realm, TR_NAME *comm, TR_NAME *origin);
117 TR_COMM_MEMB *tr_comm_table_find_memb(TR_COMM_TABLE *ctab, TR_NAME *realm, TR_NAME *comm);
118 TR_COMM_MEMB *tr_comm_table_find_rp_memb_origin(TR_COMM_TABLE *ctab, TR_NAME *rp_realm, TR_NAME *comm, TR_NAME *origin);
119 TR_COMM_MEMB *tr_comm_table_find_rp_memb(TR_COMM_TABLE *ctab, TR_NAME *rp_realm, TR_NAME *comm);
120 TR_COMM_MEMB *tr_comm_table_find_idp_memb_origin(TR_COMM_TABLE *ctab, TR_NAME *idp_realm, TR_NAME *comm, TR_NAME *origin);
121 TR_COMM_MEMB *tr_comm_table_find_idp_memb(TR_COMM_TABLE *ctab, TR_NAME *idp_realm, TR_NAME *comm);
122 TR_COMM *tr_comm_table_find_comm(TR_COMM_TABLE *ctab, TR_NAME *comm_id);
123 size_t tr_comm_table_size(TR_COMM_TABLE *ctab);
124
125 TR_COMM_MEMB *tr_comm_memb_new(TALLOC_CTX *mem_ctx);
126 void tr_comm_memb_free(TR_COMM_MEMB *memb);
127 TR_REALM_ROLE tr_comm_memb_get_role(TR_COMM_MEMB *memb);
128 void tr_comm_memb_set_rp_realm(TR_COMM_MEMB *memb, TR_RP_REALM *realm);
129 TR_RP_REALM *tr_comm_memb_get_rp_realm(TR_COMM_MEMB *memb);
130 void tr_comm_memb_set_idp_realm(TR_COMM_MEMB *memb, TR_IDP_REALM *realm);
131 TR_IDP_REALM *tr_comm_memb_get_idp_realm(TR_COMM_MEMB *memb);
132 void tr_comm_memb_set_comm(TR_COMM_MEMB *memb, TR_COMM *comm);
133 TR_COMM *tr_comm_memb_get_comm(TR_COMM_MEMB *memb);
134 TR_NAME *tr_comm_memb_get_origin(TR_COMM_MEMB *memb);
135 TR_NAME *tr_comm_memb_dup_origin(TR_COMM_MEMB *memb);
136 json_t *tr_comm_memb_get_provenance(TR_COMM_MEMB *memb);
137 void tr_comm_memb_set_provenance(TR_COMM_MEMB *memb, json_t *prov);
138 void tr_comm_memb_add_to_provenance(TR_COMM_MEMB *memb, TR_NAME *hop);
139 size_t tr_comm_memb_provenance_len(TR_COMM_MEMB *memb);
140 void tr_comm_memb_set_interval(TR_COMM_MEMB *memb, unsigned int interval);
141 unsigned int tr_comm_memb_get_interval(TR_COMM_MEMB *memb);
142 void tr_comm_memb_set_expiry(TR_COMM_MEMB *memb, struct timespec *time);
143 struct timespec *tr_comm_memb_get_expiry(TR_COMM_MEMB *memb);
144 int tr_comm_memb_is_expired(TR_COMM_MEMB *memb, struct timespec *curtime);
145 void tr_comm_set_triggered(TR_COMM_MEMB *memb, int trig);
146 int tr_comm_is_triggered(TR_COMM_MEMB *memb);
147
148 TR_COMM *tr_comm_new(TALLOC_CTX *mem_ctx);
149 void tr_comm_free(TR_COMM *comm);
150 void tr_comm_set_id(TR_COMM *comm, TR_NAME *id);
151 TR_NAME *tr_comm_get_id(TR_COMM *comm);
152 TR_NAME *tr_comm_dup_id(TR_COMM *comm);
153 void tr_comm_set_apcs(TR_COMM *comm, TR_APC *apc);
154 TR_APC *tr_comm_get_apcs(TR_COMM *comm);
155 void tr_comm_set_type(TR_COMM *comm, TR_COMM_TYPE type);
156 TR_COMM_TYPE tr_comm_get_type(TR_COMM *comm);
157 void tr_comm_set_owner_realm(TR_COMM *comm, TR_NAME *realm);
158 TR_NAME *tr_comm_get_owner_realm(TR_COMM *comm);
159 TR_NAME *tr_comm_dup_owner_realm(TR_COMM *comm);
160 void tr_comm_set_owner_contact(TR_COMM *comm, TR_NAME *contact);
161 TR_NAME *tr_comm_get_owner_contact(TR_COMM *comm);
162 TR_NAME *tr_comm_dup_owner_contact(TR_COMM *comm);
163 void tr_comm_add_idp_realm(TR_COMM_TABLE *ctab, TR_COMM *comm, TR_IDP_REALM *realm, json_t *provenance, struct timespec *expiry);
164 void tr_comm_add_rp_realm(TR_COMM_TABLE *ctab, TR_COMM *comm, TR_RP_REALM *realm, json_t *provenance, struct timespec *expiry);
165 TR_RP_REALM *tr_comm_find_rp(TR_COMM_TABLE *ctab, TR_COMM *comm, TR_NAME *rp_realm);
166 TR_IDP_REALM *tr_comm_find_idp(TR_COMM_TABLE *ctab, TR_COMM *comm, TR_NAME *idp_realm);
167 const char *tr_comm_type_to_str(TR_COMM_TYPE type);
168 TR_COMM_TYPE tr_comm_type_from_str(const char *s);
169 void tr_comm_incref(TR_COMM *comm);
170 void tr_comm_decref(TR_COMM *comm);
171 unsigned int tr_comm_get_refcount(TR_COMM *comm);
172
173 /* for iterating over communities within a realm or realms within a community */
174 TR_COMM_ITER *tr_comm_iter_new(TALLOC_CTX *mem_ctx);
175 void tr_comm_iter_free(TR_COMM_ITER *iter);
176
177 /* iterate over all communities in a table */
178 TR_COMM *tr_comm_table_iter_first(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab);
179 TR_COMM *tr_comm_table_iter_next(TR_COMM_ITER *);
180
181 /* these iterate over communities for a realm */
182 TR_COMM *tr_comm_iter_first(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *realm);
183 TR_COMM *tr_comm_iter_next(TR_COMM_ITER *iter);
184 TR_COMM *tr_comm_iter_first_rp(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *realm);
185 TR_COMM *tr_comm_iter_next_rp(TR_COMM_ITER *iter);
186 TR_COMM *tr_comm_iter_first_idp(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *realm);
187 TR_COMM *tr_comm_iter_next_idp(TR_COMM_ITER *iter);
188
189 /* iterate over realms for a community */
190 TR_REALM *tr_realm_iter_first(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *comm);
191 TR_REALM *tr_realm_iter_next(TR_COMM_ITER *iter);
192 TR_RP_REALM *tr_rp_realm_iter_first(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *comm);
193 TR_RP_REALM *tr_rp_realm_iter_next(TR_COMM_ITER *iter);
194 TR_IDP_REALM *tr_idp_realm_iter_first(TR_COMM_ITER *iter, TR_COMM_TABLE *ctab, TR_NAME *comm);
195 TR_IDP_REALM *tr_idp_realm_iter_next(TR_COMM_ITER *iter);
196
197 /* iterate over members with different origins */
198 TR_COMM_MEMB *tr_comm_memb_iter_first(TR_COMM_ITER *iter, TR_COMM_MEMB *memb);
199 TR_COMM_MEMB *tr_comm_memb_iter_next(TR_COMM_ITER *iter);
200
201 /* general realm stuff, should probably move */
202 TR_NAME *tr_realm_get_id(TR_REALM *realm);
203 TR_NAME *tr_realm_dup_id(TR_REALM *realm);
204
205 const char *tr_realm_role_to_str(TR_REALM_ROLE role);
206 TR_REALM_ROLE tr_realm_role_from_str(const char *s);
207
208 #endif