res_srtp: Add support for libsrtp2.1.
[asterisk/asterisk.git] / res / res_ari_mailboxes.c
1 /*
2  * Asterisk -- An open source telephony toolkit.
3  *
4  * Copyright (C) 2013, Digium, Inc.
5  *
6  * Jonathan Rose <jrose@digium.com>
7  *
8  * See http://www.asterisk.org for more information about
9  * the Asterisk project. Please do not directly contact
10  * any of the maintainers of this project for assistance;
11  * the project provides a web site, mailing lists and IRC
12  * channels for your use.
13  *
14  * This program is free software, distributed under the terms of
15  * the GNU General Public License Version 2. See the LICENSE file
16  * at the top of the source tree.
17  */
18
19 /*
20  * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
21  * !!!!!                               DO NOT EDIT                        !!!!!
22  * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
23  * This file is generated by a mustache template. Please see the original
24  * template in rest-api-templates/res_ari_resource.c.mustache
25  */
26
27 /*! \file
28  *
29  * \brief Mailboxes resources
30  *
31  * \author Jonathan Rose <jrose@digium.com>
32  */
33
34 /*** MODULEINFO
35         <depend type="module">res_ari</depend>
36         <depend type="module">res_ari_model</depend>
37         <depend type="module">res_stasis</depend>
38         <support_level>core</support_level>
39  ***/
40
41 #include "asterisk.h"
42
43 #include "asterisk/app.h"
44 #include "asterisk/module.h"
45 #include "asterisk/stasis_app.h"
46 #include "ari/resource_mailboxes.h"
47 #if defined(AST_DEVMODE)
48 #include "ari/ari_model_validators.h"
49 #endif
50
51 #define MAX_VALS 128
52
53 /*!
54  * \brief Parameter parsing callback for /mailboxes.
55  * \param get_params GET parameters in the HTTP request.
56  * \param path_vars Path variables extracted from the request.
57  * \param headers HTTP headers.
58  * \param[out] response Response to the HTTP request.
59  */
60 static void ast_ari_mailboxes_list_cb(
61         struct ast_tcptls_session_instance *ser,
62         struct ast_variable *get_params, struct ast_variable *path_vars,
63         struct ast_variable *headers, struct ast_json *body, struct ast_ari_response *response)
64 {
65         struct ast_ari_mailboxes_list_args args = {};
66 #if defined(AST_DEVMODE)
67         int is_valid;
68         int code;
69 #endif /* AST_DEVMODE */
70
71         ast_ari_mailboxes_list(headers, &args, response);
72 #if defined(AST_DEVMODE)
73         code = response->response_code;
74
75         switch (code) {
76         case 0: /* Implementation is still a stub, or the code wasn't set */
77                 is_valid = response->message == NULL;
78                 break;
79         case 500: /* Internal Server Error */
80         case 501: /* Not Implemented */
81                 is_valid = 1;
82                 break;
83         default:
84                 if (200 <= code && code <= 299) {
85                         is_valid = ast_ari_validate_list(response->message,
86                                 ast_ari_validate_mailbox_fn());
87                 } else {
88                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes\n", code);
89                         is_valid = 0;
90                 }
91         }
92
93         if (!is_valid) {
94                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes\n");
95                 ast_ari_response_error(response, 500,
96                         "Internal Server Error", "Response validation failed");
97         }
98 #endif /* AST_DEVMODE */
99
100 fin: __attribute__((unused))
101         return;
102 }
103 /*!
104  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
105  * \param get_params GET parameters in the HTTP request.
106  * \param path_vars Path variables extracted from the request.
107  * \param headers HTTP headers.
108  * \param[out] response Response to the HTTP request.
109  */
110 static void ast_ari_mailboxes_get_cb(
111         struct ast_tcptls_session_instance *ser,
112         struct ast_variable *get_params, struct ast_variable *path_vars,
113         struct ast_variable *headers, struct ast_json *body, struct ast_ari_response *response)
114 {
115         struct ast_ari_mailboxes_get_args args = {};
116         struct ast_variable *i;
117 #if defined(AST_DEVMODE)
118         int is_valid;
119         int code;
120 #endif /* AST_DEVMODE */
121
122         for (i = path_vars; i; i = i->next) {
123                 if (strcmp(i->name, "mailboxName") == 0) {
124                         args.mailbox_name = (i->value);
125                 } else
126                 {}
127         }
128         ast_ari_mailboxes_get(headers, &args, response);
129 #if defined(AST_DEVMODE)
130         code = response->response_code;
131
132         switch (code) {
133         case 0: /* Implementation is still a stub, or the code wasn't set */
134                 is_valid = response->message == NULL;
135                 break;
136         case 500: /* Internal Server Error */
137         case 501: /* Not Implemented */
138         case 404: /* Mailbox not found */
139                 is_valid = 1;
140                 break;
141         default:
142                 if (200 <= code && code <= 299) {
143                         is_valid = ast_ari_validate_mailbox(
144                                 response->message);
145                 } else {
146                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
147                         is_valid = 0;
148                 }
149         }
150
151         if (!is_valid) {
152                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
153                 ast_ari_response_error(response, 500,
154                         "Internal Server Error", "Response validation failed");
155         }
156 #endif /* AST_DEVMODE */
157
158 fin: __attribute__((unused))
159         return;
160 }
161 int ast_ari_mailboxes_update_parse_body(
162         struct ast_json *body,
163         struct ast_ari_mailboxes_update_args *args)
164 {
165         struct ast_json *field;
166         /* Parse query parameters out of it */
167         field = ast_json_object_get(body, "oldMessages");
168         if (field) {
169                 args->old_messages = ast_json_integer_get(field);
170         }
171         field = ast_json_object_get(body, "newMessages");
172         if (field) {
173                 args->new_messages = ast_json_integer_get(field);
174         }
175         return 0;
176 }
177
178 /*!
179  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
180  * \param get_params GET parameters in the HTTP request.
181  * \param path_vars Path variables extracted from the request.
182  * \param headers HTTP headers.
183  * \param[out] response Response to the HTTP request.
184  */
185 static void ast_ari_mailboxes_update_cb(
186         struct ast_tcptls_session_instance *ser,
187         struct ast_variable *get_params, struct ast_variable *path_vars,
188         struct ast_variable *headers, struct ast_json *body, struct ast_ari_response *response)
189 {
190         struct ast_ari_mailboxes_update_args args = {};
191         struct ast_variable *i;
192 #if defined(AST_DEVMODE)
193         int is_valid;
194         int code;
195 #endif /* AST_DEVMODE */
196
197         for (i = get_params; i; i = i->next) {
198                 if (strcmp(i->name, "oldMessages") == 0) {
199                         args.old_messages = atoi(i->value);
200                 } else
201                 if (strcmp(i->name, "newMessages") == 0) {
202                         args.new_messages = atoi(i->value);
203                 } else
204                 {}
205         }
206         for (i = path_vars; i; i = i->next) {
207                 if (strcmp(i->name, "mailboxName") == 0) {
208                         args.mailbox_name = (i->value);
209                 } else
210                 {}
211         }
212         if (ast_ari_mailboxes_update_parse_body(body, &args)) {
213                 ast_ari_response_alloc_failed(response);
214                 goto fin;
215         }
216         ast_ari_mailboxes_update(headers, &args, response);
217 #if defined(AST_DEVMODE)
218         code = response->response_code;
219
220         switch (code) {
221         case 0: /* Implementation is still a stub, or the code wasn't set */
222                 is_valid = response->message == NULL;
223                 break;
224         case 500: /* Internal Server Error */
225         case 501: /* Not Implemented */
226         case 404: /* Mailbox not found */
227                 is_valid = 1;
228                 break;
229         default:
230                 if (200 <= code && code <= 299) {
231                         is_valid = ast_ari_validate_void(
232                                 response->message);
233                 } else {
234                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
235                         is_valid = 0;
236                 }
237         }
238
239         if (!is_valid) {
240                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
241                 ast_ari_response_error(response, 500,
242                         "Internal Server Error", "Response validation failed");
243         }
244 #endif /* AST_DEVMODE */
245
246 fin: __attribute__((unused))
247         return;
248 }
249 /*!
250  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
251  * \param get_params GET parameters in the HTTP request.
252  * \param path_vars Path variables extracted from the request.
253  * \param headers HTTP headers.
254  * \param[out] response Response to the HTTP request.
255  */
256 static void ast_ari_mailboxes_delete_cb(
257         struct ast_tcptls_session_instance *ser,
258         struct ast_variable *get_params, struct ast_variable *path_vars,
259         struct ast_variable *headers, struct ast_json *body, struct ast_ari_response *response)
260 {
261         struct ast_ari_mailboxes_delete_args args = {};
262         struct ast_variable *i;
263 #if defined(AST_DEVMODE)
264         int is_valid;
265         int code;
266 #endif /* AST_DEVMODE */
267
268         for (i = path_vars; i; i = i->next) {
269                 if (strcmp(i->name, "mailboxName") == 0) {
270                         args.mailbox_name = (i->value);
271                 } else
272                 {}
273         }
274         ast_ari_mailboxes_delete(headers, &args, response);
275 #if defined(AST_DEVMODE)
276         code = response->response_code;
277
278         switch (code) {
279         case 0: /* Implementation is still a stub, or the code wasn't set */
280                 is_valid = response->message == NULL;
281                 break;
282         case 500: /* Internal Server Error */
283         case 501: /* Not Implemented */
284         case 404: /* Mailbox not found */
285                 is_valid = 1;
286                 break;
287         default:
288                 if (200 <= code && code <= 299) {
289                         is_valid = ast_ari_validate_void(
290                                 response->message);
291                 } else {
292                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
293                         is_valid = 0;
294                 }
295         }
296
297         if (!is_valid) {
298                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
299                 ast_ari_response_error(response, 500,
300                         "Internal Server Error", "Response validation failed");
301         }
302 #endif /* AST_DEVMODE */
303
304 fin: __attribute__((unused))
305         return;
306 }
307
308 /*! \brief REST handler for /api-docs/mailboxes.json */
309 static struct stasis_rest_handlers mailboxes_mailboxName = {
310         .path_segment = "mailboxName",
311         .is_wildcard = 1,
312         .callbacks = {
313                 [AST_HTTP_GET] = ast_ari_mailboxes_get_cb,
314                 [AST_HTTP_PUT] = ast_ari_mailboxes_update_cb,
315                 [AST_HTTP_DELETE] = ast_ari_mailboxes_delete_cb,
316         },
317         .num_children = 0,
318         .children = {  }
319 };
320 /*! \brief REST handler for /api-docs/mailboxes.json */
321 static struct stasis_rest_handlers mailboxes = {
322         .path_segment = "mailboxes",
323         .callbacks = {
324                 [AST_HTTP_GET] = ast_ari_mailboxes_list_cb,
325         },
326         .num_children = 1,
327         .children = { &mailboxes_mailboxName, }
328 };
329
330 static int unload_module(void)
331 {
332         ast_ari_remove_handler(&mailboxes);
333         stasis_app_unref();
334         return 0;
335 }
336
337 static int load_module(void)
338 {
339         int res = 0;
340
341         CHECK_ARI_MODULE_LOADED();
342
343
344         stasis_app_ref();
345         res |= ast_ari_add_handler(&mailboxes);
346         if (res) {
347                 unload_module();
348                 return AST_MODULE_LOAD_DECLINE;
349         }
350
351         return AST_MODULE_LOAD_SUCCESS;
352 }
353
354 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "RESTful API module - Mailboxes resources",
355         .support_level = AST_MODULE_SUPPORT_CORE,
356         .load = load_module,
357         .unload = unload_module,
358         .nonoptreq = "res_ari,res_stasis",
359 );