Recording resources. More...

#include "asterisk.h"
#include "asterisk/app.h"
#include "asterisk/module.h"
#include "asterisk/stasis_app.h"
#include "ari/resource_recordings.h"
#include "ari/ari_model_validators.h"

Include dependency graph for res_ari_recordings.c:

Go to the source code of this file.

Macros
#define	MAX_VALS 128

Functions
static void	__reg_module (void)

static void	__unreg_module (void)

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/stored/{recordingName}/copy. More...

int	ast_ari_recordings_copy_stored_parse_body (struct ast_json body, struct ast_ari_recordings_copy_stored_args args)
	Body parsing function for /recordings/stored/{recordingName}/copy. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/stored/{recordingName}. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/stored/{recordingName}. More...

static void	ast_ari_recordings_get_stored_file_cb (struct ast_tcptls_session_instance ser, struct ast_variable get_params, struct ast_variable path_vars, struct ast_variable headers, struct ast_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/stored/{recordingName}/file. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/stored. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}/mute. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}/pause. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}/stop. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}/mute. More...

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_json body, struct ast_ari_response response)
	Parameter parsing callback for /recordings/live/{recordingName}/pause. More...

struct ast_module *	AST_MODULE_SELF_SYM (void)

static int	load_module (void)

static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "RESTful API module - Recording resources" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_ari,res_ari_model,res_stasis,res_stasis_recording", }

static const struct ast_module_info *	ast_module_info = &__mod_info

static struct stasis_rest_handlers	recordings
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_live
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_live_recordingName
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_live_recordingName_mute
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_live_recordingName_pause
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_live_recordingName_stop
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_stored
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_stored_recordingName
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_stored_recordingName_copy
	REST handler for /api-docs/recordings.json. More...

static struct stasis_rest_handlers	recordings_stored_recordingName_file
	REST handler for /api-docs/recordings.json. More...

Detailed Description

Recording resources.

Author: David M. Lee, II dlee@.nosp@m.digi.nosp@m.um.co.nosp@m.m

Definition in file res_ari_recordings.c.

Macro Definition Documentation

◆ MAX_VALS

#define MAX_VALS 128

Definition at line 52 of file res_ari_recordings.c.

Function Documentation

◆ __reg_module()

static void __reg_module ( void )

static

Definition at line 892 of file res_ari_recordings.c.

◆ __unreg_module()

static void __unreg_module ( void )

static

Definition at line 892 of file res_ari_recordings.c.

◆ ast_ari_recordings_cancel_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 426 of file res_ari_recordings.c.

References ast_ari_recordings_cancel(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_cancel_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_cancel_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_copy_stored_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/stored/{recordingName}/copy.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 299 of file res_ari_recordings.c.

References ast_ari_recordings_copy_stored(), ast_ari_recordings_copy_stored_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_stored_recording(), ast_log, ast_ari_recordings_copy_stored_args::destination_recording_name, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_copy_stored_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_copy_stored_args args = {};
    struct ast_variable *i;
 #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
       {}
    }
    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;
 }

◆ ast_ari_recordings_copy_stored_parse_body()

int ast_ari_recordings_copy_stored_parse_body	(	struct ast_json *	body,
		struct ast_ari_recordings_copy_stored_args *	args
	)

Body parsing function for /recordings/stored/{recordingName}/copy.

Parameters

	body	The JSON body from which to parse parameters.
[out]	args	The args structure to parse into.

Return values

zero	on success
non-zero	on failure

Definition at line 279 of file res_ari_recordings.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_recordings_copy_stored_args::destination_recording_name.

Referenced by ast_ari_recordings_copy_stored_cb().

 {
    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;
 }

◆ ast_ari_recordings_delete_stored_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/stored/{recordingName}.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 169 of file res_ari_recordings.c.

References ast_ari_recordings_delete_stored(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_delete_stored_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_delete_stored_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_get_live_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 368 of file res_ari_recordings.c.

References ast_ari_recordings_get_live(), ast_ari_response_error(), ast_ari_validate_live_recording(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_get_live_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_get_live_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_get_stored_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/stored/{recordingName}.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 111 of file res_ari_recordings.c.

References ast_ari_recordings_get_stored(), ast_ari_response_error(), ast_ari_validate_stored_recording(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_get_stored_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_get_stored_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_get_stored_file_cb()

static void ast_ari_recordings_get_stored_file_cb	(	struct ast_tcptls_session_instance *	ser,
		struct ast_variable *	get_params,
		struct ast_variable *	path_vars,
		struct ast_variable *	headers,
		struct ast_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/stored/{recordingName}/file.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 227 of file res_ari_recordings.c.

References ast_ari_recordings_get_stored_file(), ast_ari_response_error(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_get_stored_file_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_get_stored_file_args args = {};
    struct ast_variable *i;
 #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_file(ser, 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 403: /* The recording file could not be opened */
    case 404: /* Recording not found */
       is_valid = 1;
       break;
    default:
       if (200 <= code && code <= 299) {
          /* No validation on a raw binary response */
          is_valid = 1;
       } else {
          ast_log(LOG_ERROR, "Invalid error response %d for /recordings/stored/{recordingName}/file\n", code);
          is_valid = 0;
       }
    }
 
    if (!is_valid) {
       ast_log(LOG_ERROR, "Response validation failed for /recordings/stored/{recordingName}/file\n");
       ast_ari_response_error(response, 500,
          "Internal Server Error", "Response validation failed");
    }
 #endif /* AST_DEVMODE */
 
 fin: __attribute__((unused))
    return;
 }

◆ ast_ari_recordings_list_stored_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/stored.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 61 of file res_ari_recordings.c.

References ast_ari_recordings_list_stored(), ast_ari_response_error(), ast_ari_validate_list(), ast_ari_validate_stored_recording_fn(), ast_log, LOG_ERROR, ast_ari_response::message, NULL, and ast_ari_response::response_code.

 {
    struct ast_ari_recordings_list_stored_args args = {};
 #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;
 }

◆ ast_ari_recordings_mute_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}/mute.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 660 of file res_ari_recordings.c.

References ast_ari_recordings_mute(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_mute_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_mute_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_pause_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}/pause.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 542 of file res_ari_recordings.c.

References ast_ari_recordings_pause(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_pause_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_pause_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_stop_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}/stop.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 484 of file res_ari_recordings.c.

References ast_ari_recordings_stop(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_stop_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_stop_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_unmute_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}/mute.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 719 of file res_ari_recordings.c.

References ast_ari_recordings_unmute(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_unmute_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_unmute_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ ast_ari_recordings_unpause_cb()

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_json *	body,
		struct ast_ari_response *	response
	)

static

Parameter parsing callback for /recordings/live/{recordingName}/pause.

Parameters

	get_params	GET parameters in the HTTP request.
	path_vars	Path variables extracted from the request.
	headers	HTTP headers.
[out]	response	Response to the HTTP request.

Definition at line 601 of file res_ari_recordings.c.

References ast_ari_recordings_unpause(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_recordings_unpause_args::recording_name, ast_ari_response::response_code, and ast_variable::value.

 {
    struct ast_ari_recordings_unpause_args args = {};
    struct ast_variable *i;
 #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;
 }

◆ AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM ( void )

Definition at line 892 of file res_ari_recordings.c.

◆ load_module()

static int load_module ( void )

static

Definition at line 873 of file res_ari_recordings.c.

References ast_ari_add_handler(), AST_MODFLAG_DEFAULT, AST_MODULE_INFO(), AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, AST_MODULE_SUPPORT_CORE, ASTERISK_GPL_KEY, and unload_module().

 {
    int res = 0;
 
 
    res |= ast_ari_add_handler(&recordings);
    if (res) {
       unload_module();
       return AST_MODULE_LOAD_DECLINE;
    }
 
    return AST_MODULE_LOAD_SUCCESS;
 }

◆ unload_module()

static int unload_module ( void )

static

Definition at line 867 of file res_ari_recordings.c.

References ast_ari_remove_handler().

Referenced by load_module().

 {
    ast_ari_remove_handler(&recordings);
    return 0;
 }

Variable Documentation

◆ __mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "RESTful API module - Recording resources" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = "30ef0c93b36035ec78c9cfd712d36d9b" , .support_level = AST_MODULE_SUPPORT_CORE, .load = load_module, .unload = unload_module, .requires = "res_ari,res_ari_model,res_stasis,res_stasis_recording", }

static

Definition at line 892 of file res_ari_recordings.c.

◆ ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 892 of file res_ari_recordings.c.