res_ari_channels.c File Reference

Channel resources. More...

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

Include dependency graph for res_ari_channels.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_channels_answer_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 /channels/{channelId}/answer. More...
static void	ast_ari_channels_continue_in_dialplan_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 /channels/{channelId}/continue. More...
int	ast_ari_channels_continue_in_dialplan_parse_body (struct ast_json *body, struct ast_ari_channels_continue_in_dialplan_args *args)
	Body parsing function for /channels/{channelId}/continue. More...
static void	ast_ari_channels_create_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 /channels/create. More...
int	ast_ari_channels_create_parse_body (struct ast_json *body, struct ast_ari_channels_create_args *args)
	Body parsing function for /channels/create. More...
static void	ast_ari_channels_dial_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 /channels/{channelId}/dial. More...
int	ast_ari_channels_dial_parse_body (struct ast_json *body, struct ast_ari_channels_dial_args *args)
	Body parsing function for /channels/{channelId}/dial. More...
static void	ast_ari_channels_external_media_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 /channels/externalMedia. More...
int	ast_ari_channels_external_media_parse_body (struct ast_json *body, struct ast_ari_channels_external_media_args *args)
	Body parsing function for /channels/externalMedia. More...
static void	ast_ari_channels_get_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 /channels/{channelId}. More...
static void	ast_ari_channels_get_channel_var_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 /channels/{channelId}/variable. More...
int	ast_ari_channels_get_channel_var_parse_body (struct ast_json *body, struct ast_ari_channels_get_channel_var_args *args)
	Body parsing function for /channels/{channelId}/variable. More...
static void	ast_ari_channels_hangup_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 /channels/{channelId}. More...
int	ast_ari_channels_hangup_parse_body (struct ast_json *body, struct ast_ari_channels_hangup_args *args)
	Body parsing function for /channels/{channelId}. More...
static void	ast_ari_channels_hold_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 /channels/{channelId}/hold. More...
static void	ast_ari_channels_list_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 /channels. More...
static void	ast_ari_channels_move_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 /channels/{channelId}/move. More...
int	ast_ari_channels_move_parse_body (struct ast_json *body, struct ast_ari_channels_move_args *args)
	Body parsing function for /channels/{channelId}/move. More...
static void	ast_ari_channels_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 /channels/{channelId}/mute. More...
int	ast_ari_channels_mute_parse_body (struct ast_json *body, struct ast_ari_channels_mute_args *args)
	Body parsing function for /channels/{channelId}/mute. More...
static void	ast_ari_channels_originate_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 /channels. More...
int	ast_ari_channels_originate_parse_body (struct ast_json *body, struct ast_ari_channels_originate_args *args)
	Body parsing function for /channels. More...
static void	ast_ari_channels_originate_with_id_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 /channels/{channelId}. More...
int	ast_ari_channels_originate_with_id_parse_body (struct ast_json *body, struct ast_ari_channels_originate_with_id_args *args)
	Body parsing function for /channels/{channelId}. More...
static void	ast_ari_channels_play_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 /channels/{channelId}/play. More...
int	ast_ari_channels_play_parse_body (struct ast_json *body, struct ast_ari_channels_play_args *args)
	Body parsing function for /channels/{channelId}/play. More...
static void	ast_ari_channels_play_with_id_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 /channels/{channelId}/play/{playbackId}. More...
int	ast_ari_channels_play_with_id_parse_body (struct ast_json *body, struct ast_ari_channels_play_with_id_args *args)
	Body parsing function for /channels/{channelId}/play/{playbackId}. More...
static void	ast_ari_channels_record_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 /channels/{channelId}/record. More...
int	ast_ari_channels_record_parse_body (struct ast_json *body, struct ast_ari_channels_record_args *args)
	Body parsing function for /channels/{channelId}/record. More...
static void	ast_ari_channels_redirect_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 /channels/{channelId}/redirect. More...
int	ast_ari_channels_redirect_parse_body (struct ast_json *body, struct ast_ari_channels_redirect_args *args)
	Body parsing function for /channels/{channelId}/redirect. More...
static void	ast_ari_channels_ring_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 /channels/{channelId}/ring. More...
static void	ast_ari_channels_ring_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 /channels/{channelId}/ring. More...
static void	ast_ari_channels_rtpstatistics_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 /channels/{channelId}/rtp_statistics. More...
static void	ast_ari_channels_send_dtmf_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 /channels/{channelId}/dtmf. More...
int	ast_ari_channels_send_dtmf_parse_body (struct ast_json *body, struct ast_ari_channels_send_dtmf_args *args)
	Body parsing function for /channels/{channelId}/dtmf. More...
static void	ast_ari_channels_set_channel_var_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 /channels/{channelId}/variable. More...
int	ast_ari_channels_set_channel_var_parse_body (struct ast_json *body, struct ast_ari_channels_set_channel_var_args *args)
	Body parsing function for /channels/{channelId}/variable. More...
static void	ast_ari_channels_snoop_channel_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 /channels/{channelId}/snoop. More...
int	ast_ari_channels_snoop_channel_parse_body (struct ast_json *body, struct ast_ari_channels_snoop_channel_args *args)
	Body parsing function for /channels/{channelId}/snoop. More...
static void	ast_ari_channels_snoop_channel_with_id_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 /channels/{channelId}/snoop/{snoopId}. More...
int	ast_ari_channels_snoop_channel_with_id_parse_body (struct ast_json *body, struct ast_ari_channels_snoop_channel_with_id_args *args)
	Body parsing function for /channels/{channelId}/snoop/{snoopId}. More...
static void	ast_ari_channels_start_moh_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 /channels/{channelId}/moh. More...
int	ast_ari_channels_start_moh_parse_body (struct ast_json *body, struct ast_ari_channels_start_moh_args *args)
	Body parsing function for /channels/{channelId}/moh. More...
static void	ast_ari_channels_start_silence_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 /channels/{channelId}/silence. More...
static void	ast_ari_channels_stop_moh_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 /channels/{channelId}/moh. More...
static void	ast_ari_channels_stop_silence_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 /channels/{channelId}/silence. More...
static void	ast_ari_channels_unhold_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 /channels/{channelId}/hold. More...
static void	ast_ari_channels_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 /channels/{channelId}/mute. More...
int	ast_ari_channels_unmute_parse_body (struct ast_json *body, struct ast_ari_channels_unmute_args *args)
	Body parsing function for /channels/{channelId}/mute. 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 - Channel 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_answer,res_stasis_playback,res_stasis_recording,res_stasis_snoop", }
static const struct ast_module_info *	ast_module_info = &__mod_info
static struct stasis_rest_handlers	channels
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_answer
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_continue
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_dial
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_dtmf
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_hold
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_moh
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_move
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_mute
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_play
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_play_playbackId
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_record
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_redirect
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_ring
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_rtp_statistics
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_silence
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_snoop
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_snoop_snoopId
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_channelId_variable
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_create
	REST handler for /api-docs/channels.json. More...
static struct stasis_rest_handlers	channels_externalMedia
	REST handler for /api-docs/channels.json. More...

Detailed Description

Channel resources.

Author

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

Definition in file res_ari_channels.c.

Macro Definition Documentation

MAX_VALS

#define MAX_VALS   128

Definition at line 55 of file res_ari_channels.c.

Referenced by ast_ari_channels_play_cb(), and ast_ari_channels_play_with_id_cb().

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 3180 of file res_ari_channels.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 3180 of file res_ari_channels.c.

ast_ari_channels_answer_cb()

static void ast_ari_channels_answer_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 /channels/{channelId}/answer.

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 966 of file res_ari_channels.c.

References ast_ari_channels_answer(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_answer_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_answer_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_answer(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/answer\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/answer\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_continue_in_dialplan_cb()

static void ast_ari_channels_continue_in_dialplan_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 /channels/{channelId}/continue.

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 713 of file res_ari_channels.c.

References ast_ari_channels_continue_in_dialplan(), ast_ari_channels_continue_in_dialplan_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_continue_in_dialplan_args::channel_id, ast_ari_channels_continue_in_dialplan_args::context, ast_ari_channels_continue_in_dialplan_args::extension, ast_ari_channels_continue_in_dialplan_args::label, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_continue_in_dialplan_args::priority, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_continue_in_dialplan_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, "context") == 0) {
         args.context = (i->value);
      } else
      if (strcmp(i->name, "extension") == 0) {
         args.extension = (i->value);
      } else
      if (strcmp(i->name, "priority") == 0) {
         args.priority = atoi(i->value);
      } else
      if (strcmp(i->name, "label") == 0) {
         args.label = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_continue_in_dialplan_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_continue_in_dialplan(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/continue\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/continue\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_continue_in_dialplan_parse_body()

int ast_ari_channels_continue_in_dialplan_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_continue_in_dialplan_args *	args
	)

Body parsing function for /channels/{channelId}/continue.

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 681 of file res_ari_channels.c.

References ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_continue_in_dialplan_args::context, ast_ari_channels_continue_in_dialplan_args::extension, ast_ari_channels_continue_in_dialplan_args::label, and ast_ari_channels_continue_in_dialplan_args::priority.

Referenced by ast_ari_channels_continue_in_dialplan_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "context");
   if (field) {
      args->context = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "extension");
   if (field) {
      args->extension = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "priority");
   if (field) {
      args->priority = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "label");
   if (field) {
      args->label = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_create_cb()

static void ast_ari_channels_create_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 /channels/create.

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 308 of file res_ari_channels.c.

References ast_ari_channels_create_args::app, ast_ari_channels_create_args::app_args, ast_ari_channels_create(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_create_args::channel_id, ast_ari_channels_create_args::endpoint, ast_ari_channels_create_args::formats, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_create_args::originator, ast_ari_channels_create_args::other_channel_id, ast_ari_response::response_code, ast_variable::value, and ast_ari_channels_create_args::variables.

{
   struct ast_ari_channels_create_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, "endpoint") == 0) {
         args.endpoint = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      if (strcmp(i->name, "otherChannelId") == 0) {
         args.other_channel_id = (i->value);
      } else
      if (strcmp(i->name, "originator") == 0) {
         args.originator = (i->value);
      } else
      if (strcmp(i->name, "formats") == 0) {
         args.formats = (i->value);
      } else
      {}
   }
   args.variables = body;
   ast_ari_channels_create(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 409: /* Channel with given unique ID already exists. */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/create\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/create\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_create_parse_body()

int ast_ari_channels_create_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_create_args *	args
	)

Body parsing function for /channels/create.

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 264 of file res_ari_channels.c.

References ast_ari_channels_create_args::app, ast_ari_channels_create_args::app_args, ast_json_object_get(), ast_json_string_get(), ast_ari_channels_create_args::channel_id, ast_ari_channels_create_args::endpoint, ast_ari_channels_create_args::formats, ast_ari_channels_create_args::originator, and ast_ari_channels_create_args::other_channel_id.

Referenced by ast_ari_channels_create().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "endpoint");
   if (field) {
      args->endpoint = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "channelId");
   if (field) {
      args->channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "otherChannelId");
   if (field) {
      args->other_channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "originator");
   if (field) {
      args->originator = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "formats");
   if (field) {
      args->formats = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_dial_cb()

static void ast_ari_channels_dial_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 /channels/{channelId}/dial.

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 2691 of file res_ari_channels.c.

References ast_ari_channels_dial(), ast_ari_channels_dial_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_dial_args::caller, ast_ari_channels_dial_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_ari_channels_dial_args::timeout, and ast_variable::value.

{
   struct ast_ari_channels_dial_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, "caller") == 0) {
         args.caller = (i->value);
      } else
      if (strcmp(i->name, "timeout") == 0) {
         args.timeout = atoi(i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_dial_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_dial(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: /* Channel cannot be found. */
   case 409: /* Channel cannot be dialed. */
      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 /channels/{channelId}/dial\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/dial\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_dial_parse_body()

int ast_ari_channels_dial_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_dial_args *	args
	)

Body parsing function for /channels/{channelId}/dial.

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 2667 of file res_ari_channels.c.

References ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_dial_args::caller, and ast_ari_channels_dial_args::timeout.

Referenced by ast_ari_channels_dial_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "caller");
   if (field) {
      args->caller = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "timeout");
   if (field) {
      args->timeout = ast_json_integer_get(field);
   }
   return 0;
}

ast_ari_channels_external_media_cb()

static void ast_ari_channels_external_media_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 /channels/externalMedia.

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 2866 of file res_ari_channels.c.

References ast_ari_channels_external_media_args::app, ast_ari_channels_external_media(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_external_media_args::channel_id, ast_ari_channels_external_media_args::connection_type, ast_ari_channels_external_media_args::data, ast_ari_channels_external_media_args::direction, ast_ari_channels_external_media_args::encapsulation, ast_ari_channels_external_media_args::external_host, ast_ari_channels_external_media_args::format, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_ari_channels_external_media_args::transport, ast_variable::value, and ast_ari_channels_external_media_args::variables.

{
   struct ast_ari_channels_external_media_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "external_host") == 0) {
         args.external_host = (i->value);
      } else
      if (strcmp(i->name, "encapsulation") == 0) {
         args.encapsulation = (i->value);
      } else
      if (strcmp(i->name, "transport") == 0) {
         args.transport = (i->value);
      } else
      if (strcmp(i->name, "connection_type") == 0) {
         args.connection_type = (i->value);
      } else
      if (strcmp(i->name, "format") == 0) {
         args.format = (i->value);
      } else
      if (strcmp(i->name, "direction") == 0) {
         args.direction = (i->value);
      } else
      if (strcmp(i->name, "data") == 0) {
         args.data = (i->value);
      } else
      {}
   }
   args.variables = body;
   ast_ari_channels_external_media(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 400: /* Invalid parameters */
   case 409: /* Channel is not in a Stasis application; Channel is already bridged */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/externalMedia\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/externalMedia\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_external_media_parse_body()

int ast_ari_channels_external_media_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_external_media_args *	args
	)

Body parsing function for /channels/externalMedia.

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 2814 of file res_ari_channels.c.

References ast_ari_channels_external_media_args::app, ast_json_object_get(), ast_json_string_get(), ast_ari_channels_external_media_args::channel_id, ast_ari_channels_external_media_args::connection_type, ast_ari_channels_external_media_args::data, ast_ari_channels_external_media_args::direction, ast_ari_channels_external_media_args::encapsulation, ast_ari_channels_external_media_args::external_host, ast_ari_channels_external_media_args::format, and ast_ari_channels_external_media_args::transport.

Referenced by ast_ari_channels_external_media().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "channelId");
   if (field) {
      args->channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "external_host");
   if (field) {
      args->external_host = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "encapsulation");
   if (field) {
      args->encapsulation = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "transport");
   if (field) {
      args->transport = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "connection_type");
   if (field) {
      args->connection_type = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "format");
   if (field) {
      args->format = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "direction");
   if (field) {
      args->direction = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "data");
   if (field) {
      args->data = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_get_cb()

static void ast_ari_channels_get_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 /channels/{channelId}.

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 385 of file res_ari_channels.c.

References ast_ari_channels_get(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_get_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_get_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_get(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: /* Channel not found */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_get_channel_var_cb()

static void ast_ari_channels_get_channel_var_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 /channels/{channelId}/variable.

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 2298 of file res_ari_channels.c.

References ast_ari_channels_get_channel_var(), ast_ari_channels_get_channel_var_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_variable(), ast_log, ast_ari_channels_get_channel_var_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_variable::value, and ast_ari_channels_get_channel_var_args::variable.

{
   struct ast_ari_channels_get_channel_var_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, "variable") == 0) {
         args.variable = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_get_channel_var_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_get_channel_var(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 400: /* Missing variable parameter. */
   case 404: /* Channel or variable not found */
   case 409: /* Channel not in a Stasis application */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_variable(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/variable\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/variable\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_get_channel_var_parse_body()

int ast_ari_channels_get_channel_var_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_get_channel_var_args *	args
	)

Body parsing function for /channels/{channelId}/variable.

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 2278 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_channels_get_channel_var_args::variable.

Referenced by ast_ari_channels_get_channel_var_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "variable");
   if (field) {
      args->variable = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_hangup_cb()

static void ast_ari_channels_hangup_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 /channels/{channelId}.

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 616 of file res_ari_channels.c.

References ast_ari_channels_hangup(), ast_ari_channels_hangup_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_hangup_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_hangup_args::reason, ast_ari_channels_hangup_args::reason_code, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_hangup_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, "reason_code") == 0) {
         args.reason_code = (i->value);
      } else
      if (strcmp(i->name, "reason") == 0) {
         args.reason = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_hangup_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_hangup(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 400: /* Invalid reason for hangup provided */
   case 404: /* Channel 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 /channels/{channelId}\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_hangup_parse_body()

int ast_ari_channels_hangup_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_hangup_args *	args
	)

Body parsing function for /channels/{channelId}.

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 592 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), ast_ari_channels_hangup_args::reason, and ast_ari_channels_hangup_args::reason_code.

Referenced by ast_ari_channels_hangup_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "reason_code");
   if (field) {
      args->reason_code = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "reason");
   if (field) {
      args->reason = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_hold_cb()

static void ast_ari_channels_hold_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 /channels/{channelId}/hold.

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 1424 of file res_ari_channels.c.

References ast_ari_channels_hold(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_hold_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_hold_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_hold(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/hold\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/hold\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_list_cb()

static void ast_ari_channels_list_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 /channels.

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 64 of file res_ari_channels.c.

References ast_ari_channels_list(), ast_ari_response_error(), ast_ari_validate_channel_fn(), ast_ari_validate_list(), ast_log, LOG_ERROR, ast_ari_response::message, NULL, and ast_ari_response::response_code.

{
   struct ast_ari_channels_list_args args = {};
#if defined(AST_DEVMODE)
   int is_valid;
   int code;
#endif /* AST_DEVMODE */

   ast_ari_channels_list(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_channel_fn());
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_move_cb()

static void ast_ari_channels_move_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 /channels/{channelId}/move.

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 809 of file res_ari_channels.c.

References ast_ari_channels_move_args::app, ast_ari_channels_move_args::app_args, ast_ari_channels_move(), ast_ari_channels_move_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_move_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_move_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, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_move_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_move(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
      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 /channels/{channelId}/move\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/move\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_move_parse_body()

int ast_ari_channels_move_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_move_args *	args
	)

Body parsing function for /channels/{channelId}/move.

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 785 of file res_ari_channels.c.

References ast_ari_channels_move_args::app, ast_ari_channels_move_args::app_args, ast_json_object_get(), and ast_json_string_get().

Referenced by ast_ari_channels_move_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_mute_cb()

static void ast_ari_channels_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 /channels/{channelId}/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 1271 of file res_ari_channels.c.

References ast_ari_channels_mute(), ast_ari_channels_mute_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_mute_args::channel_id, ast_ari_channels_mute_args::direction, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_mute_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, "direction") == 0) {
         args.direction = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_mute_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/mute\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/mute\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_mute_parse_body()

int ast_ari_channels_mute_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_mute_args *	args
	)

Body parsing function for /channels/{channelId}/mute.

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 1251 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_channels_mute_args::direction.

Referenced by ast_ari_channels_mute_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "direction");
   if (field) {
      args->direction = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_originate_cb()

static void ast_ari_channels_originate_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 /channels.

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 175 of file res_ari_channels.c.

References ast_ari_channels_originate_args::app, ast_ari_channels_originate_args::app_args, ast_ari_channels_originate(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_originate_args::caller_id, ast_ari_channels_originate_args::channel_id, ast_ari_channels_originate_args::context, ast_ari_channels_originate_args::endpoint, ast_ari_channels_originate_args::extension, ast_ari_channels_originate_args::formats, ast_ari_channels_originate_args::label, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_originate_args::originator, ast_ari_channels_originate_args::other_channel_id, ast_ari_channels_originate_args::priority, ast_ari_response::response_code, ast_ari_channels_originate_args::timeout, ast_variable::value, and ast_ari_channels_originate_args::variables.

{
   struct ast_ari_channels_originate_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, "endpoint") == 0) {
         args.endpoint = (i->value);
      } else
      if (strcmp(i->name, "extension") == 0) {
         args.extension = (i->value);
      } else
      if (strcmp(i->name, "context") == 0) {
         args.context = (i->value);
      } else
      if (strcmp(i->name, "priority") == 0) {
         args.priority = atol(i->value);
      } else
      if (strcmp(i->name, "label") == 0) {
         args.label = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      if (strcmp(i->name, "callerId") == 0) {
         args.caller_id = (i->value);
      } else
      if (strcmp(i->name, "timeout") == 0) {
         args.timeout = atoi(i->value);
      } else
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      if (strcmp(i->name, "otherChannelId") == 0) {
         args.other_channel_id = (i->value);
      } else
      if (strcmp(i->name, "originator") == 0) {
         args.originator = (i->value);
      } else
      if (strcmp(i->name, "formats") == 0) {
         args.formats = (i->value);
      } else
      {}
   }
   args.variables = body;
   ast_ari_channels_originate(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 400: /* Invalid parameters for originating a channel. */
   case 409: /* Channel with given unique ID already exists. */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_originate_parse_body()

int ast_ari_channels_originate_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_originate_args *	args
	)

Body parsing function for /channels.

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 107 of file res_ari_channels.c.

References ast_ari_channels_originate_args::app, ast_ari_channels_originate_args::app_args, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_originate_args::caller_id, ast_ari_channels_originate_args::channel_id, ast_ari_channels_originate_args::context, ast_ari_channels_originate_args::endpoint, ast_ari_channels_originate_args::extension, ast_ari_channels_originate_args::formats, ast_ari_channels_originate_args::label, ast_ari_channels_originate_args::originator, ast_ari_channels_originate_args::other_channel_id, ast_ari_channels_originate_args::priority, and ast_ari_channels_originate_args::timeout.

Referenced by ast_ari_channels_originate().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "endpoint");
   if (field) {
      args->endpoint = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "extension");
   if (field) {
      args->extension = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "context");
   if (field) {
      args->context = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "priority");
   if (field) {
      args->priority = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "label");
   if (field) {
      args->label = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "callerId");
   if (field) {
      args->caller_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "timeout");
   if (field) {
      args->timeout = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "channelId");
   if (field) {
      args->channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "otherChannelId");
   if (field) {
      args->other_channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "originator");
   if (field) {
      args->originator = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "formats");
   if (field) {
      args->formats = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_originate_with_id_cb()

static void ast_ari_channels_originate_with_id_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 /channels/{channelId}.

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 500 of file res_ari_channels.c.

References ast_ari_channels_originate_with_id_args::app, ast_ari_channels_originate_with_id_args::app_args, ast_ari_channels_originate_with_id(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_originate_with_id_args::caller_id, ast_ari_channels_originate_with_id_args::channel_id, ast_ari_channels_originate_with_id_args::context, ast_ari_channels_originate_with_id_args::endpoint, ast_ari_channels_originate_with_id_args::extension, ast_ari_channels_originate_with_id_args::formats, ast_ari_channels_originate_with_id_args::label, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_originate_with_id_args::originator, ast_ari_channels_originate_with_id_args::other_channel_id, ast_ari_channels_originate_with_id_args::priority, ast_ari_response::response_code, ast_ari_channels_originate_with_id_args::timeout, ast_variable::value, and ast_ari_channels_originate_with_id_args::variables.

{
   struct ast_ari_channels_originate_with_id_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, "endpoint") == 0) {
         args.endpoint = (i->value);
      } else
      if (strcmp(i->name, "extension") == 0) {
         args.extension = (i->value);
      } else
      if (strcmp(i->name, "context") == 0) {
         args.context = (i->value);
      } else
      if (strcmp(i->name, "priority") == 0) {
         args.priority = atol(i->value);
      } else
      if (strcmp(i->name, "label") == 0) {
         args.label = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      if (strcmp(i->name, "callerId") == 0) {
         args.caller_id = (i->value);
      } else
      if (strcmp(i->name, "timeout") == 0) {
         args.timeout = atoi(i->value);
      } else
      if (strcmp(i->name, "otherChannelId") == 0) {
         args.other_channel_id = (i->value);
      } else
      if (strcmp(i->name, "originator") == 0) {
         args.originator = (i->value);
      } else
      if (strcmp(i->name, "formats") == 0) {
         args.formats = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   args.variables = body;
   ast_ari_channels_originate_with_id(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 400: /* Invalid parameters for originating a channel. */
   case 409: /* Channel with given unique ID already exists. */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_originate_with_id_parse_body()

int ast_ari_channels_originate_with_id_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_originate_with_id_args *	args
	)

Body parsing function for /channels/{channelId}.

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 436 of file res_ari_channels.c.

References ast_ari_channels_originate_with_id_args::app, ast_ari_channels_originate_with_id_args::app_args, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_originate_with_id_args::caller_id, ast_ari_channels_originate_with_id_args::context, ast_ari_channels_originate_with_id_args::endpoint, ast_ari_channels_originate_with_id_args::extension, ast_ari_channels_originate_with_id_args::formats, ast_ari_channels_originate_with_id_args::label, ast_ari_channels_originate_with_id_args::originator, ast_ari_channels_originate_with_id_args::other_channel_id, ast_ari_channels_originate_with_id_args::priority, and ast_ari_channels_originate_with_id_args::timeout.

Referenced by ast_ari_channels_originate_with_id().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "endpoint");
   if (field) {
      args->endpoint = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "extension");
   if (field) {
      args->extension = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "context");
   if (field) {
      args->context = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "priority");
   if (field) {
      args->priority = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "label");
   if (field) {
      args->label = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "callerId");
   if (field) {
      args->caller_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "timeout");
   if (field) {
      args->timeout = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "otherChannelId");
   if (field) {
      args->other_channel_id = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "originator");
   if (field) {
      args->originator = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "formats");
   if (field) {
      args->formats = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_play_cb()

static void ast_ari_channels_play_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 /channels/{channelId}/play.

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 1861 of file res_ari_channels.c.

References ARRAY_LEN, ast_app_separate_args, ast_ari_channels_play(), ast_ari_channels_play_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_playback(), ast_free, ast_log, ast_malloc, ast_strdup, ast_ari_channels_play_args::channel_id, ast_ari_channels_play_args::lang, LOG_ERROR, MAX_VALS, ast_ari_channels_play_args::media, ast_ari_channels_play_args::media_count, ast_ari_channels_play_args::media_parse, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_play_args::offsetms, ast_ari_channels_play_args::playback_id, ast_ari_response::response_code, ast_ari_channels_play_args::skipms, and ast_variable::value.

{
   struct ast_ari_channels_play_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, "media") == 0) {
         /* Parse comma separated list */
         char *vals[MAX_VALS];
         size_t j;

         args.media_parse = ast_strdup(i->value);
         if (!args.media_parse) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         if (strlen(args.media_parse) == 0) {
            /* ast_app_separate_args can't handle "" */
            args.media_count = 1;
            vals[0] = args.media_parse;
         } else {
            args.media_count = ast_app_separate_args(
               args.media_parse, ',', vals,
               ARRAY_LEN(vals));
         }

         if (args.media_count == 0) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         if (args.media_count >= MAX_VALS) {
            ast_ari_response_error(response, 400,
               "Bad Request",
               "Too many values for media");
            goto fin;
         }

         args.media = ast_malloc(sizeof(*args.media) * args.media_count);
         if (!args.media) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         for (j = 0; j < args.media_count; ++j) {
            args.media[j] = (vals[j]);
         }
      } else
      if (strcmp(i->name, "lang") == 0) {
         args.lang = (i->value);
      } else
      if (strcmp(i->name, "offsetms") == 0) {
         args.offsetms = atoi(i->value);
      } else
      if (strcmp(i->name, "skipms") == 0) {
         args.skipms = atoi(i->value);
      } else
      if (strcmp(i->name, "playbackId") == 0) {
         args.playback_id = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_play_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_play(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_playback(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/play\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/play\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   ast_free(args.media_parse);
   ast_free(args.media);
   return;
}

ast_ari_channels_play_parse_body()

int ast_ari_channels_play_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_play_args *	args
	)

Body parsing function for /channels/{channelId}/play.

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 1800 of file res_ari_channels.c.

References ast_free, AST_JSON_ARRAY, ast_json_array_get(), ast_json_array_size(), ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_json_typeof(), ast_malloc, ast_ari_channels_play_args::lang, ast_ari_channels_play_args::media, ast_ari_channels_play_args::media_count, ast_ari_channels_play_args::offsetms, ast_ari_channels_play_args::playback_id, and ast_ari_channels_play_args::skipms.

Referenced by ast_ari_channels_play_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "media");
   if (field) {
      /* If they were silly enough to both pass in a query param and a
       * JSON body, free up the query value.
       */
      ast_free(args->media);
      if (ast_json_typeof(field) == AST_JSON_ARRAY) {
         /* Multiple param passed as array */
         size_t i;
         args->media_count = ast_json_array_size(field);
         args->media = ast_malloc(sizeof(*args->media) * args->media_count);

         if (!args->media) {
            return -1;
         }

         for (i = 0; i < args->media_count; ++i) {
            args->media[i] = ast_json_string_get(ast_json_array_get(field, i));
         }
      } else {
         /* Multiple param passed as single value */
         args->media_count = 1;
         args->media = ast_malloc(sizeof(*args->media) * args->media_count);
         if (!args->media) {
            return -1;
         }
         args->media[0] = ast_json_string_get(field);
      }
   }
   field = ast_json_object_get(body, "lang");
   if (field) {
      args->lang = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "offsetms");
   if (field) {
      args->offsetms = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "skipms");
   if (field) {
      args->skipms = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "playbackId");
   if (field) {
      args->playback_id = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_play_with_id_cb()

static void ast_ari_channels_play_with_id_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 /channels/{channelId}/play/{playbackId}.

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 2035 of file res_ari_channels.c.

References ARRAY_LEN, ast_app_separate_args, ast_ari_channels_play_with_id(), ast_ari_channels_play_with_id_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_playback(), ast_free, ast_log, ast_malloc, ast_strdup, ast_ari_channels_play_with_id_args::channel_id, ast_ari_channels_play_with_id_args::lang, LOG_ERROR, MAX_VALS, ast_ari_channels_play_with_id_args::media, ast_ari_channels_play_with_id_args::media_count, ast_ari_channels_play_with_id_args::media_parse, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_channels_play_with_id_args::offsetms, ast_ari_channels_play_with_id_args::playback_id, ast_ari_response::response_code, ast_ari_channels_play_with_id_args::skipms, and ast_variable::value.

{
   struct ast_ari_channels_play_with_id_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, "media") == 0) {
         /* Parse comma separated list */
         char *vals[MAX_VALS];
         size_t j;

         args.media_parse = ast_strdup(i->value);
         if (!args.media_parse) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         if (strlen(args.media_parse) == 0) {
            /* ast_app_separate_args can't handle "" */
            args.media_count = 1;
            vals[0] = args.media_parse;
         } else {
            args.media_count = ast_app_separate_args(
               args.media_parse, ',', vals,
               ARRAY_LEN(vals));
         }

         if (args.media_count == 0) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         if (args.media_count >= MAX_VALS) {
            ast_ari_response_error(response, 400,
               "Bad Request",
               "Too many values for media");
            goto fin;
         }

         args.media = ast_malloc(sizeof(*args.media) * args.media_count);
         if (!args.media) {
            ast_ari_response_alloc_failed(response);
            goto fin;
         }

         for (j = 0; j < args.media_count; ++j) {
            args.media[j] = (vals[j]);
         }
      } else
      if (strcmp(i->name, "lang") == 0) {
         args.lang = (i->value);
      } else
      if (strcmp(i->name, "offsetms") == 0) {
         args.offsetms = atoi(i->value);
      } else
      if (strcmp(i->name, "skipms") == 0) {
         args.skipms = atoi(i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      if (strcmp(i->name, "playbackId") == 0) {
         args.playback_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_play_with_id_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_play_with_id(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_playback(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/play/{playbackId}\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/play/{playbackId}\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   ast_free(args.media_parse);
   ast_free(args.media);
   return;
}

ast_ari_channels_play_with_id_parse_body()

int ast_ari_channels_play_with_id_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_play_with_id_args *	args
	)

Body parsing function for /channels/{channelId}/play/{playbackId}.

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 1978 of file res_ari_channels.c.

References ast_free, AST_JSON_ARRAY, ast_json_array_get(), ast_json_array_size(), ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_json_typeof(), ast_malloc, ast_ari_channels_play_with_id_args::lang, ast_ari_channels_play_with_id_args::media, ast_ari_channels_play_with_id_args::media_count, ast_ari_channels_play_with_id_args::offsetms, and ast_ari_channels_play_with_id_args::skipms.

Referenced by ast_ari_channels_play_with_id_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "media");
   if (field) {
      /* If they were silly enough to both pass in a query param and a
       * JSON body, free up the query value.
       */
      ast_free(args->media);
      if (ast_json_typeof(field) == AST_JSON_ARRAY) {
         /* Multiple param passed as array */
         size_t i;
         args->media_count = ast_json_array_size(field);
         args->media = ast_malloc(sizeof(*args->media) * args->media_count);

         if (!args->media) {
            return -1;
         }

         for (i = 0; i < args->media_count; ++i) {
            args->media[i] = ast_json_string_get(ast_json_array_get(field, i));
         }
      } else {
         /* Multiple param passed as single value */
         args->media_count = 1;
         args->media = ast_malloc(sizeof(*args->media) * args->media_count);
         if (!args->media) {
            return -1;
         }
         args->media[0] = ast_json_string_get(field);
      }
   }
   field = ast_json_object_get(body, "lang");
   if (field) {
      args->lang = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "offsetms");
   if (field) {
      args->offsetms = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "skipms");
   if (field) {
      args->skipms = ast_json_integer_get(field);
   }
   return 0;
}

ast_ari_channels_record_cb()

static void ast_ari_channels_record_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 /channels/{channelId}/record.

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 2196 of file res_ari_channels.c.

References ast_ari_channels_record(), ast_ari_channels_record_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_live_recording(), ast_log, ast_true(), ast_ari_channels_record_args::beep, ast_ari_channels_record_args::channel_id, ast_ari_channels_record_args::format, ast_ari_channels_record_args::if_exists, LOG_ERROR, ast_ari_channels_record_args::max_duration_seconds, ast_ari_channels_record_args::max_silence_seconds, ast_ari_response::message, ast_variable::name, ast_ari_channels_record_args::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_ari_channels_record_args::terminate_on, and ast_variable::value.

{
   struct ast_ari_channels_record_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, "name") == 0) {
         args.name = (i->value);
      } else
      if (strcmp(i->name, "format") == 0) {
         args.format = (i->value);
      } else
      if (strcmp(i->name, "maxDurationSeconds") == 0) {
         args.max_duration_seconds = atoi(i->value);
      } else
      if (strcmp(i->name, "maxSilenceSeconds") == 0) {
         args.max_silence_seconds = atoi(i->value);
      } else
      if (strcmp(i->name, "ifExists") == 0) {
         args.if_exists = (i->value);
      } else
      if (strcmp(i->name, "beep") == 0) {
         args.beep = ast_true(i->value);
      } else
      if (strcmp(i->name, "terminateOn") == 0) {
         args.terminate_on = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_record_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_record(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 400: /* Invalid parameters */
   case 404: /* Channel not found */
   case 409: /* Channel is not in a Stasis application; the channel is currently bridged with other hcannels; A recording with the same name already exists on the system and can not be overwritten because it is in progress or ifExists=fail */
   case 422: /* The format specified is unknown on this system */
      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 /channels/{channelId}/record\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/record\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_record_parse_body()

int ast_ari_channels_record_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_record_args *	args
	)

Body parsing function for /channels/{channelId}/record.

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 2152 of file res_ari_channels.c.

References ast_json_integer_get(), ast_json_is_true(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_record_args::beep, ast_ari_channels_record_args::format, ast_ari_channels_record_args::if_exists, ast_ari_channels_record_args::max_duration_seconds, ast_ari_channels_record_args::max_silence_seconds, ast_ari_channels_record_args::name, and ast_ari_channels_record_args::terminate_on.

Referenced by ast_ari_channels_record_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "name");
   if (field) {
      args->name = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "format");
   if (field) {
      args->format = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "maxDurationSeconds");
   if (field) {
      args->max_duration_seconds = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "maxSilenceSeconds");
   if (field) {
      args->max_silence_seconds = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "ifExists");
   if (field) {
      args->if_exists = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "beep");
   if (field) {
      args->beep = ast_json_is_true(field);
   }
   field = ast_json_object_get(body, "terminateOn");
   if (field) {
      args->terminate_on = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_redirect_cb()

static void ast_ari_channels_redirect_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 /channels/{channelId}/redirect.

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 894 of file res_ari_channels.c.

References ast_ari_channels_redirect(), ast_ari_channels_redirect_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_redirect_args::channel_id, ast_ari_channels_redirect_args::endpoint, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_redirect_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, "endpoint") == 0) {
         args.endpoint = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_redirect_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_redirect(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 400: /* Endpoint parameter not provided */
   case 404: /* Channel or endpoint not found */
   case 409: /* Channel not in a Stasis application */
   case 422: /* Endpoint is not the same type as the channel */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/redirect\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/redirect\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_redirect_parse_body()

int ast_ari_channels_redirect_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_redirect_args *	args
	)

Body parsing function for /channels/{channelId}/redirect.

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 874 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_channels_redirect_args::endpoint.

Referenced by ast_ari_channels_redirect_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "endpoint");
   if (field) {
      args->endpoint = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_ring_cb()

static void ast_ari_channels_ring_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 /channels/{channelId}/ring.

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 1026 of file res_ari_channels.c.

References ast_ari_channels_ring(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_ring_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_ring_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_ring(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/ring\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/ring\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_ring_stop_cb()

static void ast_ari_channels_ring_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 /channels/{channelId}/ring.

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 1086 of file res_ari_channels.c.

References ast_ari_channels_ring_stop(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_ring_stop_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_ring_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_ring_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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/ring\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/ring\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_rtpstatistics_cb()

static void ast_ari_channels_rtpstatistics_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 /channels/{channelId}/rtp_statistics.

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 2763 of file res_ari_channels.c.

References ast_ari_channels_rtpstatistics(), ast_ari_response_error(), ast_ari_validate_rtpstat(), ast_log, ast_ari_channels_rtpstatistics_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_rtpstatistics_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_rtpstatistics(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: /* Channel cannot be found. */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_rtpstat(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/rtp_statistics\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/rtp_statistics\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_send_dtmf_cb()

static void ast_ari_channels_send_dtmf_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 /channels/{channelId}/dtmf.

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 1175 of file res_ari_channels.c.

References ast_ari_channels_send_dtmf_args::after, ast_ari_channels_send_dtmf(), ast_ari_channels_send_dtmf_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_send_dtmf_args::before, ast_ari_channels_send_dtmf_args::between, ast_ari_channels_send_dtmf_args::channel_id, ast_ari_channels_send_dtmf_args::dtmf, ast_ari_channels_send_dtmf_args::duration, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_send_dtmf_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, "dtmf") == 0) {
         args.dtmf = (i->value);
      } else
      if (strcmp(i->name, "before") == 0) {
         args.before = atoi(i->value);
      } else
      if (strcmp(i->name, "between") == 0) {
         args.between = atoi(i->value);
      } else
      if (strcmp(i->name, "duration") == 0) {
         args.duration = atoi(i->value);
      } else
      if (strcmp(i->name, "after") == 0) {
         args.after = atoi(i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_send_dtmf_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_send_dtmf(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 400: /* DTMF is required */
   case 404: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/dtmf\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/dtmf\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_send_dtmf_parse_body()

int ast_ari_channels_send_dtmf_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_send_dtmf_args *	args
	)

Body parsing function for /channels/{channelId}/dtmf.

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 1139 of file res_ari_channels.c.

References ast_ari_channels_send_dtmf_args::after, ast_json_integer_get(), ast_json_object_get(), ast_json_string_get(), ast_ari_channels_send_dtmf_args::before, ast_ari_channels_send_dtmf_args::between, ast_ari_channels_send_dtmf_args::dtmf, and ast_ari_channels_send_dtmf_args::duration.

Referenced by ast_ari_channels_send_dtmf_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "dtmf");
   if (field) {
      args->dtmf = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "before");
   if (field) {
      args->before = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "between");
   if (field) {
      args->between = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "duration");
   if (field) {
      args->duration = ast_json_integer_get(field);
   }
   field = ast_json_object_get(body, "after");
   if (field) {
      args->after = ast_json_integer_get(field);
   }
   return 0;
}

ast_ari_channels_set_channel_var_cb()

static void ast_ari_channels_set_channel_var_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 /channels/{channelId}/variable.

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 2385 of file res_ari_channels.c.

References ast_ari_channels_set_channel_var(), ast_ari_channels_set_channel_var_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_set_channel_var_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_variable::value, ast_ari_channels_set_channel_var_args::value, and ast_ari_channels_set_channel_var_args::variable.

{
   struct ast_ari_channels_set_channel_var_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, "variable") == 0) {
         args.variable = (i->value);
      } else
      if (strcmp(i->name, "value") == 0) {
         args.value = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_set_channel_var_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_set_channel_var(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 400: /* Missing variable parameter. */
   case 404: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
      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 /channels/{channelId}/variable\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/variable\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_set_channel_var_parse_body()

int ast_ari_channels_set_channel_var_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_set_channel_var_args *	args
	)

Body parsing function for /channels/{channelId}/variable.

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 2361 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), ast_ari_channels_set_channel_var_args::value, and ast_ari_channels_set_channel_var_args::variable.

Referenced by ast_ari_channels_set_channel_var_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "variable");
   if (field) {
      args->variable = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "value");
   if (field) {
      args->value = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_snoop_channel_cb()

static void ast_ari_channels_snoop_channel_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 /channels/{channelId}/snoop.

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 2487 of file res_ari_channels.c.

References ast_ari_channels_snoop_channel_args::app, ast_ari_channels_snoop_channel_args::app_args, ast_ari_channels_snoop_channel(), ast_ari_channels_snoop_channel_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_snoop_channel_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_ari_channels_snoop_channel_args::snoop_id, ast_ari_channels_snoop_channel_args::spy, ast_variable::value, and ast_ari_channels_snoop_channel_args::whisper.

{
   struct ast_ari_channels_snoop_channel_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, "spy") == 0) {
         args.spy = (i->value);
      } else
      if (strcmp(i->name, "whisper") == 0) {
         args.whisper = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      if (strcmp(i->name, "snoopId") == 0) {
         args.snoop_id = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_snoop_channel_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_snoop_channel(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 400: /* Invalid parameters */
   case 404: /* Channel not found */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/snoop\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/snoop\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_snoop_channel_parse_body()

int ast_ari_channels_snoop_channel_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_snoop_channel_args *	args
	)

Body parsing function for /channels/{channelId}/snoop.

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 2451 of file res_ari_channels.c.

References ast_ari_channels_snoop_channel_args::app, ast_ari_channels_snoop_channel_args::app_args, ast_json_object_get(), ast_json_string_get(), ast_ari_channels_snoop_channel_args::snoop_id, ast_ari_channels_snoop_channel_args::spy, and ast_ari_channels_snoop_channel_args::whisper.

Referenced by ast_ari_channels_snoop_channel_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "spy");
   if (field) {
      args->spy = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "whisper");
   if (field) {
      args->whisper = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "snoopId");
   if (field) {
      args->snoop_id = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_snoop_channel_with_id_cb()

static void ast_ari_channels_snoop_channel_with_id_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 /channels/{channelId}/snoop/{snoopId}.

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 2593 of file res_ari_channels.c.

References ast_ari_channels_snoop_channel_with_id_args::app, ast_ari_channels_snoop_channel_with_id_args::app_args, ast_ari_channels_snoop_channel_with_id(), ast_ari_channels_snoop_channel_with_id_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_channel(), ast_log, ast_ari_channels_snoop_channel_with_id_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, ast_ari_channels_snoop_channel_with_id_args::snoop_id, ast_ari_channels_snoop_channel_with_id_args::spy, ast_variable::value, and ast_ari_channels_snoop_channel_with_id_args::whisper.

{
   struct ast_ari_channels_snoop_channel_with_id_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, "spy") == 0) {
         args.spy = (i->value);
      } else
      if (strcmp(i->name, "whisper") == 0) {
         args.whisper = (i->value);
      } else
      if (strcmp(i->name, "app") == 0) {
         args.app = (i->value);
      } else
      if (strcmp(i->name, "appArgs") == 0) {
         args.app_args = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      if (strcmp(i->name, "snoopId") == 0) {
         args.snoop_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_snoop_channel_with_id_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_snoop_channel_with_id(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 400: /* Invalid parameters */
   case 404: /* Channel not found */
      is_valid = 1;
      break;
   default:
      if (200 <= code && code <= 299) {
         is_valid = ast_ari_validate_channel(
            response->message);
      } else {
         ast_log(LOG_ERROR, "Invalid error response %d for /channels/{channelId}/snoop/{snoopId}\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/snoop/{snoopId}\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_snoop_channel_with_id_parse_body()

int ast_ari_channels_snoop_channel_with_id_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_snoop_channel_with_id_args *	args
	)

Body parsing function for /channels/{channelId}/snoop/{snoopId}.

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 2561 of file res_ari_channels.c.

References ast_ari_channels_snoop_channel_with_id_args::app, ast_ari_channels_snoop_channel_with_id_args::app_args, ast_json_object_get(), ast_json_string_get(), ast_ari_channels_snoop_channel_with_id_args::spy, and ast_ari_channels_snoop_channel_with_id_args::whisper.

Referenced by ast_ari_channels_snoop_channel_with_id_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "spy");
   if (field) {
      args->spy = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "whisper");
   if (field) {
      args->whisper = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "app");
   if (field) {
      args->app = ast_json_string_get(field);
   }
   field = ast_json_object_get(body, "appArgs");
   if (field) {
      args->app_args = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_start_moh_cb()

static void ast_ari_channels_start_moh_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 /channels/{channelId}/moh.

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 1557 of file res_ari_channels.c.

References ast_ari_channels_start_moh(), ast_ari_channels_start_moh_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_start_moh_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_ari_channels_start_moh_args::moh_class, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_start_moh_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, "mohClass") == 0) {
         args.moh_class = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_start_moh_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_start_moh(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/moh\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/moh\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_start_moh_parse_body()

int ast_ari_channels_start_moh_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_start_moh_args *	args
	)

Body parsing function for /channels/{channelId}/moh.

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 1537 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_channels_start_moh_args::moh_class.

Referenced by ast_ari_channels_start_moh_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "mohClass");
   if (field) {
      args->moh_class = ast_json_string_get(field);
   }
   return 0;
}

ast_ari_channels_start_silence_cb()

static void ast_ari_channels_start_silence_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 /channels/{channelId}/silence.

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 1687 of file res_ari_channels.c.

References ast_ari_channels_start_silence(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_start_silence_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_start_silence_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_start_silence(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/silence\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/silence\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_stop_moh_cb()

static void ast_ari_channels_stop_moh_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 /channels/{channelId}/moh.

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 1627 of file res_ari_channels.c.

References ast_ari_channels_stop_moh(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_stop_moh_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_stop_moh_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_stop_moh(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/moh\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/moh\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_stop_silence_cb()

static void ast_ari_channels_stop_silence_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 /channels/{channelId}/silence.

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 1747 of file res_ari_channels.c.

References ast_ari_channels_stop_silence(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_stop_silence_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_stop_silence_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_stop_silence(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/silence\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/silence\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_unhold_cb()

static void ast_ari_channels_unhold_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 /channels/{channelId}/hold.

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 1484 of file res_ari_channels.c.

References ast_ari_channels_unhold(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_unhold_args::channel_id, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_unhold_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, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   ast_ari_channels_unhold(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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/hold\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/hold\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_unmute_cb()

static void ast_ari_channels_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 /channels/{channelId}/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 1354 of file res_ari_channels.c.

References ast_ari_channels_unmute(), ast_ari_channels_unmute_parse_body(), ast_ari_response_alloc_failed(), ast_ari_response_error(), ast_ari_validate_void(), ast_log, ast_ari_channels_unmute_args::channel_id, ast_ari_channels_unmute_args::direction, LOG_ERROR, ast_ari_response::message, ast_variable::name, ast_variable::next, NULL, ast_ari_response::response_code, and ast_variable::value.

{
   struct ast_ari_channels_unmute_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, "direction") == 0) {
         args.direction = (i->value);
      } else
      {}
   }
   for (i = path_vars; i; i = i->next) {
      if (strcmp(i->name, "channelId") == 0) {
         args.channel_id = (i->value);
      } else
      {}
   }
   if (ast_ari_channels_unmute_parse_body(body, &args)) {
      ast_ari_response_alloc_failed(response);
      goto fin;
   }
   ast_ari_channels_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: /* Channel not found */
   case 409: /* Channel not in a Stasis application */
   case 412: /* Channel in invalid state */
      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 /channels/{channelId}/mute\n", code);
         is_valid = 0;
      }
   }

   if (!is_valid) {
      ast_log(LOG_ERROR, "Response validation failed for /channels/{channelId}/mute\n");
      ast_ari_response_error(response, 500,
         "Internal Server Error", "Response validation failed");
   }
#endif /* AST_DEVMODE */

fin: __attribute__((unused))
   return;
}

ast_ari_channels_unmute_parse_body()

int ast_ari_channels_unmute_parse_body	(	struct ast_json *	body,
		struct ast_ari_channels_unmute_args *	args
	)

Body parsing function for /channels/{channelId}/mute.

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 1334 of file res_ari_channels.c.

References ast_json_object_get(), ast_json_string_get(), and ast_ari_channels_unmute_args::direction.

Referenced by ast_ari_channels_unmute_cb().

{
   struct ast_json *field;
   /* Parse query parameters out of it */
   field = ast_json_object_get(body, "direction");
   if (field) {
      args->direction = ast_json_string_get(field);
   }
   return 0;
}

AST_MODULE_SELF_SYM()

struct ast_module* AST_MODULE_SELF_SYM

(

void

)

Definition at line 3180 of file res_ari_channels.c.

load_module()

static int load_module ( void  )

static

Definition at line 3161 of file res_ari_channels.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(&channels);
   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 3155 of file res_ari_channels.c.

References ast_ari_remove_handler().

Referenced by load_module().

{
   ast_ari_remove_handler(&channels);
   return 0;
}

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "RESTful API module - Channel 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_answer,res_stasis_playback,res_stasis_recording,res_stasis_snoop", }

static

Definition at line 3180 of file res_ari_channels.c.

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 3180 of file res_ari_channels.c.

channels

struct stasis_rest_handlers channels

static

REST handler for /api-docs/channels.json.

Definition at line 3145 of file res_ari_channels.c.

channels_channelId

struct stasis_rest_handlers channels_channelId

static

REST handler for /api-docs/channels.json.

Definition at line 3124 of file res_ari_channels.c.

channels_channelId_answer

struct stasis_rest_handlers channels_channelId_answer

static

REST handler for /api-docs/channels.json.

Definition at line 2981 of file res_ari_channels.c.

channels_channelId_continue

struct stasis_rest_handlers channels_channelId_continue

static

REST handler for /api-docs/channels.json.

Definition at line 2954 of file res_ari_channels.c.

channels_channelId_dial

struct stasis_rest_handlers channels_channelId_dial

static

REST handler for /api-docs/channels.json.

Definition at line 3106 of file res_ari_channels.c.

channels_channelId_dtmf

struct stasis_rest_handlers channels_channelId_dtmf

static

REST handler for /api-docs/channels.json.

Definition at line 3000 of file res_ari_channels.c.

channels_channelId_hold

struct stasis_rest_handlers channels_channelId_hold

static

REST handler for /api-docs/channels.json.

Definition at line 3019 of file res_ari_channels.c.

channels_channelId_moh

struct stasis_rest_handlers channels_channelId_moh

static

REST handler for /api-docs/channels.json.

Definition at line 3029 of file res_ari_channels.c.

channels_channelId_move

struct stasis_rest_handlers channels_channelId_move

static

REST handler for /api-docs/channels.json.

Definition at line 2963 of file res_ari_channels.c.

channels_channelId_mute

struct stasis_rest_handlers channels_channelId_mute

static

REST handler for /api-docs/channels.json.

Definition at line 3009 of file res_ari_channels.c.

channels_channelId_play

struct stasis_rest_handlers channels_channelId_play

static

REST handler for /api-docs/channels.json.

Definition at line 3059 of file res_ari_channels.c.

channels_channelId_play_playbackId

struct stasis_rest_handlers channels_channelId_play_playbackId

static

REST handler for /api-docs/channels.json.

Definition at line 3049 of file res_ari_channels.c.

channels_channelId_record

struct stasis_rest_handlers channels_channelId_record

static

REST handler for /api-docs/channels.json.

Definition at line 3068 of file res_ari_channels.c.

channels_channelId_redirect

struct stasis_rest_handlers channels_channelId_redirect

static

REST handler for /api-docs/channels.json.

Definition at line 2972 of file res_ari_channels.c.

channels_channelId_ring

struct stasis_rest_handlers channels_channelId_ring

static

REST handler for /api-docs/channels.json.

Definition at line 2990 of file res_ari_channels.c.

channels_channelId_rtp_statistics

struct stasis_rest_handlers channels_channelId_rtp_statistics

static

REST handler for /api-docs/channels.json.

Definition at line 3115 of file res_ari_channels.c.

channels_channelId_silence

struct stasis_rest_handlers channels_channelId_silence

static

REST handler for /api-docs/channels.json.

Definition at line 3039 of file res_ari_channels.c.

channels_channelId_snoop

struct stasis_rest_handlers channels_channelId_snoop

static

REST handler for /api-docs/channels.json.

Definition at line 3097 of file res_ari_channels.c.

channels_channelId_snoop_snoopId

struct stasis_rest_handlers channels_channelId_snoop_snoopId

static

REST handler for /api-docs/channels.json.

Definition at line 3087 of file res_ari_channels.c.

channels_channelId_variable

struct stasis_rest_handlers channels_channelId_variable

static

REST handler for /api-docs/channels.json.

Definition at line 3077 of file res_ari_channels.c.

channels_create

struct stasis_rest_handlers channels_create

static

REST handler for /api-docs/channels.json.

Definition at line 2945 of file res_ari_channels.c.

channels_externalMedia

struct stasis_rest_handlers channels_externalMedia

static

REST handler for /api-docs/channels.json.

Definition at line 3136 of file res_ari_channels.c.