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         );