123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846 |
- /*
- * Asterisk -- An open source telephony toolkit.
- *
- * Copyright (C) 2012 - 2013, Digium, Inc.
- *
- * David M. Lee, II <dlee@digium.com>
- *
- * See http://www.asterisk.org for more information about
- * the Asterisk project. Please do not directly contact
- * any of the maintainers of this project for assistance;
- * the project provides a web site, mailing lists and IRC
- * channels for your use.
- *
- * This program is free software, distributed under the terms of
- * the GNU General Public License Version 2. See the LICENSE file
- * at the top of the source tree.
- */
- /*
- * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
- * !!!!! DO NOT EDIT !!!!!
- * !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
- * This file is generated by a mustache template. Please see the original
- * template in rest-api-templates/res_ari_resource.c.mustache
- */
- /*! \file
- *
- * \brief Recording resources
- *
- * \author David M. Lee, II <dlee@digium.com>
- */
- /*** MODULEINFO
- <depend type="module">res_ari</depend>
- <depend type="module">res_stasis</depend>
- <support_level>core</support_level>
- ***/
- #include "asterisk.h"
- ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
- #include "asterisk/app.h"
- #include "asterisk/module.h"
- #include "asterisk/stasis_app.h"
- #include "ari/resource_recordings.h"
- #if defined(AST_DEVMODE)
- #include "ari/ari_model_validators.h"
- #endif
- #define MAX_VALS 128
- /*!
- * \brief Parameter parsing callback for /recordings/stored.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_list_stored_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_list_stored_args args = {};
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- ast_ari_recordings_list_stored(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_list(response->message,
- ast_ari_validate_stored_recording_fn());
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/stored\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/stored\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/stored/{recordingName}.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_get_stored_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_get_stored_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_get_stored(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_stored_recording(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/stored/{recordingName}\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/stored/{recordingName}\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/stored/{recordingName}.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_delete_stored_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_delete_stored_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_delete_stored(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/stored/{recordingName}\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/stored/{recordingName}\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- int ast_ari_recordings_copy_stored_parse_body(
- struct ast_json *body,
- struct ast_ari_recordings_copy_stored_args *args)
- {
- struct ast_json *field;
- /* Parse query parameters out of it */
- field = ast_json_object_get(body, "destinationRecordingName");
- if (field) {
- args->destination_recording_name = ast_json_string_get(field);
- }
- return 0;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/stored/{recordingName}/copy.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_copy_stored_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_copy_stored_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = get_params; i; i = i->next) {
- if (strcmp(i->name, "destinationRecordingName") == 0) {
- args.destination_recording_name = (i->value);
- } else
- {}
- }
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- /* Look for a JSON request entity */
- body = ast_http_get_json(ser, headers);
- if (!body) {
- switch (errno) {
- case EFBIG:
- ast_ari_response_error(response, 413, "Request Entity Too Large", "Request body too large");
- goto fin;
- case ENOMEM:
- ast_ari_response_error(response, 500, "Internal Server Error", "Error processing request");
- goto fin;
- case EIO:
- ast_ari_response_error(response, 400, "Bad Request", "Error parsing request body");
- goto fin;
- }
- }
- if (ast_ari_recordings_copy_stored_parse_body(body, &args)) {
- ast_ari_response_alloc_failed(response);
- goto fin;
- }
- ast_ari_recordings_copy_stored(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- case 409: /* A recording with the same name already exists on the system */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_stored_recording(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/stored/{recordingName}/copy\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/stored/{recordingName}/copy\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_get_live_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_get_live_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_get_live(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_live_recording(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_cancel_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_cancel_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_cancel(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}/stop.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_stop_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_stop_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_stop(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}/stop\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}/stop\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}/pause.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_pause_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_pause_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_pause(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- case 409: /* Recording not in session */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}/pause\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}/pause\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}/pause.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_unpause_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_unpause_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_unpause(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- case 409: /* Recording not in session */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}/pause\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}/pause\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}/mute.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_mute_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_mute_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_mute(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- case 409: /* Recording not in session */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}/mute\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}/mute\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*!
- * \brief Parameter parsing callback for /recordings/live/{recordingName}/mute.
- * \param get_params GET parameters in the HTTP request.
- * \param path_vars Path variables extracted from the request.
- * \param headers HTTP headers.
- * \param[out] response Response to the HTTP request.
- */
- static void ast_ari_recordings_unmute_cb(
- struct ast_tcptls_session_instance *ser,
- struct ast_variable *get_params, struct ast_variable *path_vars,
- struct ast_variable *headers, struct ast_ari_response *response)
- {
- struct ast_ari_recordings_unmute_args args = {};
- struct ast_variable *i;
- RAII_VAR(struct ast_json *, body, NULL, ast_json_unref);
- #if defined(AST_DEVMODE)
- int is_valid;
- int code;
- #endif /* AST_DEVMODE */
- for (i = path_vars; i; i = i->next) {
- if (strcmp(i->name, "recordingName") == 0) {
- args.recording_name = (i->value);
- } else
- {}
- }
- ast_ari_recordings_unmute(headers, &args, response);
- #if defined(AST_DEVMODE)
- code = response->response_code;
- switch (code) {
- case 0: /* Implementation is still a stub, or the code wasn't set */
- is_valid = response->message == NULL;
- break;
- case 500: /* Internal Server Error */
- case 501: /* Not Implemented */
- case 404: /* Recording not found */
- case 409: /* Recording not in session */
- is_valid = 1;
- break;
- default:
- if (200 <= code && code <= 299) {
- is_valid = ast_ari_validate_void(
- response->message);
- } else {
- ast_log(LOG_ERROR, "Invalid error response %d for /recordings/live/{recordingName}/mute\n", code);
- is_valid = 0;
- }
- }
- if (!is_valid) {
- ast_log(LOG_ERROR, "Response validation failed for /recordings/live/{recordingName}/mute\n");
- ast_ari_response_error(response, 500,
- "Internal Server Error", "Response validation failed");
- }
- #endif /* AST_DEVMODE */
- fin: __attribute__((unused))
- return;
- }
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_stored_recordingName_copy = {
- .path_segment = "copy",
- .callbacks = {
- [AST_HTTP_POST] = ast_ari_recordings_copy_stored_cb,
- },
- .num_children = 0,
- .children = { }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_stored_recordingName = {
- .path_segment = "recordingName",
- .is_wildcard = 1,
- .callbacks = {
- [AST_HTTP_GET] = ast_ari_recordings_get_stored_cb,
- [AST_HTTP_DELETE] = ast_ari_recordings_delete_stored_cb,
- },
- .num_children = 1,
- .children = { &recordings_stored_recordingName_copy, }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_stored = {
- .path_segment = "stored",
- .callbacks = {
- [AST_HTTP_GET] = ast_ari_recordings_list_stored_cb,
- },
- .num_children = 1,
- .children = { &recordings_stored_recordingName, }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_live_recordingName_stop = {
- .path_segment = "stop",
- .callbacks = {
- [AST_HTTP_POST] = ast_ari_recordings_stop_cb,
- },
- .num_children = 0,
- .children = { }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_live_recordingName_pause = {
- .path_segment = "pause",
- .callbacks = {
- [AST_HTTP_POST] = ast_ari_recordings_pause_cb,
- [AST_HTTP_DELETE] = ast_ari_recordings_unpause_cb,
- },
- .num_children = 0,
- .children = { }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_live_recordingName_mute = {
- .path_segment = "mute",
- .callbacks = {
- [AST_HTTP_POST] = ast_ari_recordings_mute_cb,
- [AST_HTTP_DELETE] = ast_ari_recordings_unmute_cb,
- },
- .num_children = 0,
- .children = { }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_live_recordingName = {
- .path_segment = "recordingName",
- .is_wildcard = 1,
- .callbacks = {
- [AST_HTTP_GET] = ast_ari_recordings_get_live_cb,
- [AST_HTTP_DELETE] = ast_ari_recordings_cancel_cb,
- },
- .num_children = 3,
- .children = { &recordings_live_recordingName_stop,&recordings_live_recordingName_pause,&recordings_live_recordingName_mute, }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings_live = {
- .path_segment = "live",
- .callbacks = {
- },
- .num_children = 1,
- .children = { &recordings_live_recordingName, }
- };
- /*! \brief REST handler for /api-docs/recordings.{format} */
- static struct stasis_rest_handlers recordings = {
- .path_segment = "recordings",
- .callbacks = {
- },
- .num_children = 2,
- .children = { &recordings_stored,&recordings_live, }
- };
- static int load_module(void)
- {
- int res = 0;
- stasis_app_ref();
- res |= ast_ari_add_handler(&recordings);
- return res;
- }
- static int unload_module(void)
- {
- ast_ari_remove_handler(&recordings);
- stasis_app_unref();
- return 0;
- }
- AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_DEFAULT, "RESTful API module - Recording resources",
- .support_level = AST_MODULE_SUPPORT_CORE,
- .load = load_module,
- .unload = unload_module,
- .nonoptreq = "res_ari,res_stasis",
- );
|