security_events: Fix error caused by DTD validation error
[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_stasis</depend>
37         <support_level>core</support_level>
38  ***/
39
40 #include "asterisk.h"
41
42 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
43
44 #include "asterisk/app.h"
45 #include "asterisk/module.h"
46 #include "asterisk/stasis_app.h"
47 #include "ari/resource_mailboxes.h"
48 #if defined(AST_DEVMODE)
49 #include "ari/ari_model_validators.h"
50 #endif
51
52 #define MAX_VALS 128
53
54 /*!
55  * \brief Parameter parsing callback for /mailboxes.
56  * \param get_params GET parameters in the HTTP request.
57  * \param path_vars Path variables extracted from the request.
58  * \param headers HTTP headers.
59  * \param[out] response Response to the HTTP request.
60  */
61 static void ast_ari_mailboxes_list_cb(
62         struct ast_tcptls_session_instance *ser,
63         struct ast_variable *get_params, struct ast_variable *path_vars,
64         struct ast_variable *headers, struct ast_ari_response *response)
65 {
66         struct ast_ari_mailboxes_list_args args = {};
67         RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
68 #if defined(AST_DEVMODE)
69         int is_valid;
70         int code;
71 #endif /* AST_DEVMODE */
72
73         ast_ari_mailboxes_list(headers, &args, response);
74 #if defined(AST_DEVMODE)
75         code = response->response_code;
76
77         switch (code) {
78         case 0: /* Implementation is still a stub, or the code wasn't set */
79                 is_valid = response->message == NULL;
80                 break;
81         case 500: /* Internal Server Error */
82         case 501: /* Not Implemented */
83                 is_valid = 1;
84                 break;
85         default:
86                 if (200 <= code && code <= 299) {
87                         is_valid = ast_ari_validate_list(response->message,
88                                 ast_ari_validate_mailbox_fn());
89                 } else {
90                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes\n", code);
91                         is_valid = 0;
92                 }
93         }
94
95         if (!is_valid) {
96                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes\n");
97                 ast_ari_response_error(response, 500,
98                         "Internal Server Error", "Response validation failed");
99         }
100 #endif /* AST_DEVMODE */
101
102 fin: __attribute__((unused))
103         return;
104 }
105 /*!
106  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
107  * \param get_params GET parameters in the HTTP request.
108  * \param path_vars Path variables extracted from the request.
109  * \param headers HTTP headers.
110  * \param[out] response Response to the HTTP request.
111  */
112 static void ast_ari_mailboxes_get_cb(
113         struct ast_tcptls_session_instance *ser,
114         struct ast_variable *get_params, struct ast_variable *path_vars,
115         struct ast_variable *headers, struct ast_ari_response *response)
116 {
117         struct ast_ari_mailboxes_get_args args = {};
118         struct ast_variable *i;
119         RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
120 #if defined(AST_DEVMODE)
121         int is_valid;
122         int code;
123 #endif /* AST_DEVMODE */
124
125         for (i = path_vars; i; i = i->next) {
126                 if (strcmp(i->name, "mailboxName") == 0) {
127                         args.mailbox_name = (i->value);
128                 } else
129                 {}
130         }
131         ast_ari_mailboxes_get(headers, &args, response);
132 #if defined(AST_DEVMODE)
133         code = response->response_code;
134
135         switch (code) {
136         case 0: /* Implementation is still a stub, or the code wasn't set */
137                 is_valid = response->message == NULL;
138                 break;
139         case 500: /* Internal Server Error */
140         case 501: /* Not Implemented */
141         case 404: /* Mailbox not found */
142                 is_valid = 1;
143                 break;
144         default:
145                 if (200 <= code && code <= 299) {
146                         is_valid = ast_ari_validate_mailbox(
147                                 response->message);
148                 } else {
149                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
150                         is_valid = 0;
151                 }
152         }
153
154         if (!is_valid) {
155                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
156                 ast_ari_response_error(response, 500,
157                         "Internal Server Error", "Response validation failed");
158         }
159 #endif /* AST_DEVMODE */
160
161 fin: __attribute__((unused))
162         return;
163 }
164 int ast_ari_mailboxes_update_parse_body(
165         struct ast_json *body,
166         struct ast_ari_mailboxes_update_args *args)
167 {
168         struct ast_json *field;
169         /* Parse query parameters out of it */
170         field = ast_json_object_get(body, "oldMessages");
171         if (field) {
172                 args->old_messages = ast_json_integer_get(field);
173         }
174         field = ast_json_object_get(body, "newMessages");
175         if (field) {
176                 args->new_messages = ast_json_integer_get(field);
177         }
178         return 0;
179 }
180
181 /*!
182  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
183  * \param get_params GET parameters in the HTTP request.
184  * \param path_vars Path variables extracted from the request.
185  * \param headers HTTP headers.
186  * \param[out] response Response to the HTTP request.
187  */
188 static void ast_ari_mailboxes_update_cb(
189         struct ast_tcptls_session_instance *ser,
190         struct ast_variable *get_params, struct ast_variable *path_vars,
191         struct ast_variable *headers, struct ast_ari_response *response)
192 {
193         struct ast_ari_mailboxes_update_args args = {};
194         struct ast_variable *i;
195         RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
196 #if defined(AST_DEVMODE)
197         int is_valid;
198         int code;
199 #endif /* AST_DEVMODE */
200
201         for (i = get_params; i; i = i->next) {
202                 if (strcmp(i->name, "oldMessages") == 0) {
203                         args.old_messages = atoi(i->value);
204                 } else
205                 if (strcmp(i->name, "newMessages") == 0) {
206                         args.new_messages = atoi(i->value);
207                 } else
208                 {}
209         }
210         for (i = path_vars; i; i = i->next) {
211                 if (strcmp(i->name, "mailboxName") == 0) {
212                         args.mailbox_name = (i->value);
213                 } else
214                 {}
215         }
216         /* Look for a JSON request entity */
217         body = ast_http_get_json(ser, headers);
218         if (!body) {
219                 switch (errno) {
220                 case EFBIG:
221                         ast_ari_response_error(response, 413, "Request Entity Too Large", "Request body too large");
222                         goto fin;
223                 case ENOMEM:
224                         ast_ari_response_error(response, 500, "Internal Server Error", "Error processing request");
225                         goto fin;
226                 case EIO:
227                         ast_ari_response_error(response, 400, "Bad Request", "Error parsing request body");
228                         goto fin;
229                 }
230         }
231         if (ast_ari_mailboxes_update_parse_body(body, &args)) {
232                 ast_ari_response_alloc_failed(response);
233                 goto fin;
234         }
235         ast_ari_mailboxes_update(headers, &args, response);
236 #if defined(AST_DEVMODE)
237         code = response->response_code;
238
239         switch (code) {
240         case 0: /* Implementation is still a stub, or the code wasn't set */
241                 is_valid = response->message == NULL;
242                 break;
243         case 500: /* Internal Server Error */
244         case 501: /* Not Implemented */
245         case 404: /* Mailbox not found */
246                 is_valid = 1;
247                 break;
248         default:
249                 if (200 <= code && code <= 299) {
250                         is_valid = ast_ari_validate_void(
251                                 response->message);
252                 } else {
253                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
254                         is_valid = 0;
255                 }
256         }
257
258         if (!is_valid) {
259                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
260                 ast_ari_response_error(response, 500,
261                         "Internal Server Error", "Response validation failed");
262         }
263 #endif /* AST_DEVMODE */
264
265 fin: __attribute__((unused))
266         return;
267 }
268 /*!
269  * \brief Parameter parsing callback for /mailboxes/{mailboxName}.
270  * \param get_params GET parameters in the HTTP request.
271  * \param path_vars Path variables extracted from the request.
272  * \param headers HTTP headers.
273  * \param[out] response Response to the HTTP request.
274  */
275 static void ast_ari_mailboxes_delete_cb(
276         struct ast_tcptls_session_instance *ser,
277         struct ast_variable *get_params, struct ast_variable *path_vars,
278         struct ast_variable *headers, struct ast_ari_response *response)
279 {
280         struct ast_ari_mailboxes_delete_args args = {};
281         struct ast_variable *i;
282         RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
283 #if defined(AST_DEVMODE)
284         int is_valid;
285         int code;
286 #endif /* AST_DEVMODE */
287
288         for (i = path_vars; i; i = i->next) {
289                 if (strcmp(i->name, "mailboxName") == 0) {
290                         args.mailbox_name = (i->value);
291                 } else
292                 {}
293         }
294         ast_ari_mailboxes_delete(headers, &args, response);
295 #if defined(AST_DEVMODE)
296         code = response->response_code;
297
298         switch (code) {
299         case 0: /* Implementation is still a stub, or the code wasn't set */
300                 is_valid = response->message == NULL;
301                 break;
302         case 500: /* Internal Server Error */
303         case 501: /* Not Implemented */
304         case 404: /* Mailbox not found */
305                 is_valid = 1;
306                 break;
307         default:
308                 if (200 <= code && code <= 299) {
309                         is_valid = ast_ari_validate_void(
310                                 response->message);
311                 } else {
312                         ast_log(LOG_ERROR, "Invalid error response %d for /mailboxes/{mailboxName}\n", code);
313                         is_valid = 0;
314                 }
315         }
316
317         if (!is_valid) {
318                 ast_log(LOG_ERROR, "Response validation failed for /mailboxes/{mailboxName}\n");
319                 ast_ari_response_error(response, 500,
320                         "Internal Server Error", "Response validation failed");
321         }
322 #endif /* AST_DEVMODE */
323
324 fin: __attribute__((unused))
325         return;
326 }
327
328 /*! \brief REST handler for /api-docs/mailboxes.{format} */
329 static struct stasis_rest_handlers mailboxes_mailboxName = {
330         .path_segment = "mailboxName",
331         .is_wildcard = 1,
332         .callbacks = {
333                 [AST_HTTP_GET] = ast_ari_mailboxes_get_cb,
334                 [AST_HTTP_PUT] = ast_ari_mailboxes_update_cb,
335                 [AST_HTTP_DELETE] = ast_ari_mailboxes_delete_cb,
336         },
337         .num_children = 0,
338         .children = {  }
339 };
340 /*! \brief REST handler for /api-docs/mailboxes.{format} */
341 static struct stasis_rest_handlers mailboxes = {
342         .path_segment = "mailboxes",
343         .callbacks = {
344                 [AST_HTTP_GET] = ast_ari_mailboxes_list_cb,
345         },
346         .num_children = 1,
347         .children = { &mailboxes_mailboxName, }
348 };
349
350 static int load_module(void)
351 {
352         int res = 0;
353         stasis_app_ref();
354         res |= ast_ari_add_handler(&mailboxes);
355         return res;
356 }
357
358 static int unload_module(void)
359 {
360         ast_ari_remove_handler(&mailboxes);
361         stasis_app_unref();
362         return 0;
363 }
364
365 AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "RESTful API module - Mailboxes resources",
366         .load = load_module,
367         .unload = unload_module,
368         .nonoptreq = "res_ari,res_stasis",
369         );