@ -2559,6 +2559,229 @@ static void ast_ari_channels_set_channel_var_cb(
}
# endif /* AST_DEVMODE */
fin : __attribute__ ( ( unused ) )
return ;
}
int ast_ari_channels_get_channel_vars_parse_body (
struct ast_json * body ,
struct ast_ari_channels_get_channel_vars_args * args )
{
struct ast_json * field ;
/* Parse query parameters out of it */
field = ast_json_object_get ( body , " variables " ) ;
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 - > variables ) ;
if ( ast_json_typeof ( field ) = = AST_JSON_ARRAY ) {
/* Multiple param passed as array */
size_t i ;
args - > variables_count = ast_json_array_size ( field ) ;
args - > variables = ast_malloc ( sizeof ( * args - > variables ) * args - > variables_count ) ;
if ( ! args - > variables ) {
return - 1 ;
}
for ( i = 0 ; i < args - > variables_count ; + + i ) {
args - > variables [ i ] = ast_json_string_get ( ast_json_array_get ( field , i ) ) ;
}
} else {
/* Multiple param passed as single value */
args - > variables_count = 1 ;
args - > variables = ast_malloc ( sizeof ( * args - > variables ) * args - > variables_count ) ;
if ( ! args - > variables ) {
return - 1 ;
}
args - > variables [ 0 ] = ast_json_string_get ( field ) ;
}
}
return 0 ;
}
/*!
* \ brief Parameter parsing callback for / channels / { channelId } / variables .
* \ param ser TCP / TLS session object
* \ param get_params GET parameters in the HTTP request .
* \ param path_vars Path variables extracted from the request .
* \ param headers HTTP headers .
* \ param body
* \ param [ out ] response Response to the HTTP request .
*/
static void ast_ari_channels_get_channel_vars_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 )
{
struct ast_ari_channels_get_channel_vars_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 , " variables " ) = = 0 ) {
/* Parse comma separated list */
char * vals [ MAX_VALS ] ;
size_t j ;
args . variables_parse = ast_strdup ( i - > value ) ;
if ( ! args . variables_parse ) {
ast_ari_response_alloc_failed ( response ) ;
goto fin ;
}
if ( strlen ( args . variables_parse ) = = 0 ) {
/* ast_app_separate_args can't handle "" */
args . variables_count = 1 ;
vals [ 0 ] = args . variables_parse ;
} else {
args . variables_count = ast_app_separate_args (
args . variables_parse , ' , ' , vals ,
ARRAY_LEN ( vals ) ) ;
}
if ( args . variables_count = = 0 ) {
ast_ari_response_alloc_failed ( response ) ;
goto fin ;
}
if ( args . variables_count > = MAX_VALS ) {
ast_ari_response_error ( response , 400 ,
" Bad Request " ,
" Too many values for variables " ) ;
goto fin ;
}
args . variables = ast_malloc ( sizeof ( * args . variables ) * args . variables_count ) ;
if ( ! args . variables ) {
ast_ari_response_alloc_failed ( response ) ;
goto fin ;
}
for ( j = 0 ; j < args . variables_count ; + + j ) {
args . variables [ j ] = ( vals [ j ] ) ;
}
} 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_vars_parse_body ( body , & args ) ) {
ast_ari_response_alloc_failed ( response ) ;
goto fin ;
}
ast_ari_channels_get_channel_vars ( 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 variables 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_variables (
response - > message ) ;
} else {
ast_log ( LOG_ERROR , " Invalid error response %d for /channels/{channelId}/variables \n " , code ) ;
is_valid = 0 ;
}
}
if ( ! is_valid ) {
ast_log ( LOG_ERROR , " Response validation failed for /channels/{channelId}/variables \n " ) ;
ast_ari_response_error ( response , 500 ,
" Internal Server Error " , " Response validation failed " ) ;
}
# endif /* AST_DEVMODE */
fin : __attribute__ ( ( unused ) )
ast_free ( args . variables_parse ) ;
ast_free ( args . variables ) ;
return ;
}
int ast_ari_channels_set_channel_vars_parse_body (
struct ast_json * body ,
struct ast_ari_channels_set_channel_vars_args * args )
{
/* Parse query parameters out of it */
return 0 ;
}
/*!
* \ brief Parameter parsing callback for / channels / { channelId } / variables .
* \ param ser TCP / TLS session object
* \ param get_params GET parameters in the HTTP request .
* \ param path_vars Path variables extracted from the request .
* \ param headers HTTP headers .
* \ param body
* \ param [ out ] response Response to the HTTP request .
*/
static void ast_ari_channels_set_channel_vars_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 )
{
struct ast_ari_channels_set_channel_vars_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
{ }
}
args . variables = body ;
ast_ari_channels_set_channel_vars ( 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 variables 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}/variables \n " , code ) ;
is_valid = 0 ;
}
}
if ( ! is_valid ) {
ast_log ( LOG_ERROR , " Response validation failed for /channels/{channelId}/variables \n " ) ;
ast_ari_response_error ( response , 500 ,
" Internal Server Error " , " Response validation failed " ) ;
}
# endif /* AST_DEVMODE */
fin : __attribute__ ( ( unused ) )
return ;
}
@ -3310,6 +3533,16 @@ static struct stasis_rest_handlers channels_channelId_variable = {
. children = { }
} ;
/*! \brief REST handler for /api-docs/channels.json */
static struct stasis_rest_handlers channels_channelId_variables = {
. path_segment = " variables " ,
. callbacks = {
[ AST_HTTP_GET ] = ast_ari_channels_get_channel_vars_cb ,
[ AST_HTTP_POST ] = ast_ari_channels_set_channel_vars_cb ,
} ,
. num_children = 0 ,
. children = { }
} ;
/*! \brief REST handler for /api-docs/channels.json */
static struct stasis_rest_handlers channels_channelId_snoop_snoopId = {
. path_segment = " snoopId " ,
. is_wildcard = 1 ,
@ -3364,8 +3597,8 @@ static struct stasis_rest_handlers channels_channelId = {
[ AST_HTTP_POST ] = ast_ari_channels_originate_with_id_cb ,
[ AST_HTTP_DELETE ] = ast_ari_channels_hangup_cb ,
} ,
. num_children = 1 8 ,
. children = { & channels_channelId_continue , & channels_channelId_move , & channels_channelId_redirect , & channels_channelId_answer , & channels_channelId_ring , & channels_channelId_progress , & channels_channelId_dtmf , & channels_channelId_mute , & channels_channelId_hold , & channels_channelId_moh , & channels_channelId_silence , & channels_channelId_play , & channels_channelId_record , & channels_channelId_variable , & channels_channelId_ snoop, & channels_channelId_dial , & channels_channelId_rtp_statistics , & channels_channelId_transfer_progress , }
. num_children = 1 9 ,
. children = { & channels_channelId_continue , & channels_channelId_move , & channels_channelId_redirect , & channels_channelId_answer , & channels_channelId_ring , & channels_channelId_progress , & channels_channelId_dtmf , & channels_channelId_mute , & channels_channelId_hold , & channels_channelId_moh , & channels_channelId_silence , & channels_channelId_play , & channels_channelId_record , & channels_channelId_variable , & channels_channelId_ variables, & channels_channelId_ snoop, & channels_channelId_dial , & channels_channelId_rtp_statistics , & channels_channelId_transfer_progress , }
} ;
/*! \brief REST handler for /api-docs/channels.json */
static struct stasis_rest_handlers channels_externalMedia = {