resource_bridges.h File Reference

Generated file - declares stubs to be implemented in res/ari/resource_bridges.c. More...

#include "asterisk/ari.h"

Include dependency graph for resource_bridges.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	ast_ari_bridges_add_channel_args
struct	ast_ari_bridges_clear_video_source_args
struct	ast_ari_bridges_create_args
struct	ast_ari_bridges_create_with_id_args
struct	ast_ari_bridges_destroy_args
struct	ast_ari_bridges_get_args
struct	ast_ari_bridges_list_args
struct	ast_ari_bridges_play_args
struct	ast_ari_bridges_play_with_id_args
struct	ast_ari_bridges_record_args
struct	ast_ari_bridges_remove_channel_args
struct	ast_ari_bridges_set_video_source_args
struct	ast_ari_bridges_start_moh_args
struct	ast_ari_bridges_stop_moh_args

Functions
void	ast_ari_bridges_add_channel (struct ast_variable *headers, struct ast_ari_bridges_add_channel_args *args, struct ast_ari_response *response)
	Add a channel to a bridge. More...
int	ast_ari_bridges_add_channel_parse_body (struct ast_json *body, struct ast_ari_bridges_add_channel_args *args)
	Body parsing function for /bridges/{bridgeId}/addChannel. More...
void	ast_ari_bridges_clear_video_source (struct ast_variable *headers, struct ast_ari_bridges_clear_video_source_args *args, struct ast_ari_response *response)
	Removes any explicit video source in a multi-party mixing bridge. This operation has no effect on bridges with two or fewer participants. When no explicit video source is set, talk detection will be used to determine the active video stream. More...
void	ast_ari_bridges_create (struct ast_variable *headers, struct ast_ari_bridges_create_args *args, struct ast_ari_response *response)
	Create a new bridge. More...
int	ast_ari_bridges_create_parse_body (struct ast_json *body, struct ast_ari_bridges_create_args *args)
	Body parsing function for /bridges. More...
void	ast_ari_bridges_create_with_id (struct ast_variable *headers, struct ast_ari_bridges_create_with_id_args *args, struct ast_ari_response *response)
	Create a new bridge. More...
int	ast_ari_bridges_create_with_id_parse_body (struct ast_json *body, struct ast_ari_bridges_create_with_id_args *args)
	Body parsing function for /bridges/{bridgeId}. More...
void	ast_ari_bridges_destroy (struct ast_variable *headers, struct ast_ari_bridges_destroy_args *args, struct ast_ari_response *response)
	Shut down a bridge. More...
void	ast_ari_bridges_get (struct ast_variable *headers, struct ast_ari_bridges_get_args *args, struct ast_ari_response *response)
	Get bridge details. More...
void	ast_ari_bridges_list (struct ast_variable *headers, struct ast_ari_bridges_list_args *args, struct ast_ari_response *response)
	List all active bridges in Asterisk. More...
void	ast_ari_bridges_play (struct ast_variable *headers, struct ast_ari_bridges_play_args *args, struct ast_ari_response *response)
	Start playback of media on a bridge. More...
int	ast_ari_bridges_play_parse_body (struct ast_json *body, struct ast_ari_bridges_play_args *args)
	Body parsing function for /bridges/{bridgeId}/play. More...
void	ast_ari_bridges_play_with_id (struct ast_variable *headers, struct ast_ari_bridges_play_with_id_args *args, struct ast_ari_response *response)
	Start playback of media on a bridge. More...
int	ast_ari_bridges_play_with_id_parse_body (struct ast_json *body, struct ast_ari_bridges_play_with_id_args *args)
	Body parsing function for /bridges/{bridgeId}/play/{playbackId}. More...
void	ast_ari_bridges_record (struct ast_variable *headers, struct ast_ari_bridges_record_args *args, struct ast_ari_response *response)
	Start a recording. More...
int	ast_ari_bridges_record_parse_body (struct ast_json *body, struct ast_ari_bridges_record_args *args)
	Body parsing function for /bridges/{bridgeId}/record. More...
void	ast_ari_bridges_remove_channel (struct ast_variable *headers, struct ast_ari_bridges_remove_channel_args *args, struct ast_ari_response *response)
	Remove a channel from a bridge. More...
int	ast_ari_bridges_remove_channel_parse_body (struct ast_json *body, struct ast_ari_bridges_remove_channel_args *args)
	Body parsing function for /bridges/{bridgeId}/removeChannel. More...
void	ast_ari_bridges_set_video_source (struct ast_variable *headers, struct ast_ari_bridges_set_video_source_args *args, struct ast_ari_response *response)
	Set a channel as the video source in a multi-party mixing bridge. This operation has no effect on bridges with two or fewer participants. More...
void	ast_ari_bridges_start_moh (struct ast_variable *headers, struct ast_ari_bridges_start_moh_args *args, struct ast_ari_response *response)
	Play music on hold to a bridge or change the MOH class that is playing. More...
int	ast_ari_bridges_start_moh_parse_body (struct ast_json *body, struct ast_ari_bridges_start_moh_args *args)
	Body parsing function for /bridges/{bridgeId}/moh. More...
void	ast_ari_bridges_stop_moh (struct ast_variable *headers, struct ast_ari_bridges_stop_moh_args *args, struct ast_ari_response *response)
	Stop playing music on hold to a bridge. More...

Detailed Description

Generated file - declares stubs to be implemented in res/ari/resource_bridges.c.

Bridge resources

Author

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

Definition in file resource_bridges.h.

Function Documentation

ast_ari_bridges_add_channel()

void ast_ari_bridges_add_channel	(	struct ast_variable *	headers,
		struct ast_ari_bridges_add_channel_args *	args,
		struct ast_ari_response *	response
	)

Add a channel to a bridge.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 191 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
    RAII_VAR(struct control_list *, list, NULL, ao2_cleanup);
    size_t i;
    int has_error = 0;
 
    if (!bridge) {
        /* Response filled in by find_bridge() */
        return;
    }
 
    list = control_list_create(response, args->channel_count, args->channel);
    if (!list) {
        /* Response filled in by control_list_create() */
        return;
    }
 
    for (i = 0; i < list->count; ++i) {
        stasis_app_control_clear_roles(list->controls[i]);
        if (!ast_strlen_zero(args->role)) {
            if (stasis_app_control_add_role(list->controls[i], args->role)) {
                ast_ari_response_alloc_failed(response);
                return;
            }
        }
 
        /* Apply bridge features to each of the channel controls */
        if (!stasis_app_control_bridge_features_init(list->controls[i])) {
            stasis_app_control_absorb_dtmf_in_bridge(list->controls[i], args->absorb_dtmf);
            stasis_app_control_mute_in_bridge(list->controls[i], args->mute);
            stasis_app_control_inhibit_colp_in_bridge(list->controls[i], args->inhibit_connected_line_updates);
        }
    }
 
    for (i = 0; i < list->count; ++i) {
        if ((has_error = check_add_remove_channel(response, list->controls[i],
                 stasis_app_control_add_channel_to_bridge(
                    list->controls[i], bridge)))) {
            break;
        }
    }
 
    if (!has_error) {
        ast_ari_response_no_content(response);
    }
}

References ao2_cleanup, args, ast_ari_response_alloc_failed(), ast_ari_response_no_content(), ast_strlen_zero(), check_add_remove_channel(), control_list_create(), find_bridge(), NULL, RAII_VAR, stasis_app_control_absorb_dtmf_in_bridge(), stasis_app_control_add_channel_to_bridge(), stasis_app_control_add_role(), stasis_app_control_bridge_features_init(), stasis_app_control_clear_roles(), stasis_app_control_inhibit_colp_in_bridge(), and stasis_app_control_mute_in_bridge().

Referenced by ast_ari_bridges_add_channel_cb().

ast_ari_bridges_add_channel_parse_body()

int ast_ari_bridges_add_channel_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_add_channel_args *	args
	)

Body parsing function for /bridges/{bridgeId}/addChannel.

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 408 of file res_ari_bridges.c.

{
    struct ast_json *field;
    /* Parse query parameters out of it */
    field = ast_json_object_get(body, "channel");
    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->channel);
        if (ast_json_typeof(field) == AST_JSON_ARRAY) {
            /* Multiple param passed as array */
            size_t i;
            args->channel_count = ast_json_array_size(field);
            args->channel = ast_malloc(sizeof(*args->channel) * args->channel_count);
 
            if (!args->channel) {
                return -1;
            }
 
            for (i = 0; i < args->channel_count; ++i) {
                args->channel[i] = ast_json_string_get(ast_json_array_get(field, i));
            }
        } else {
            /* Multiple param passed as single value */
            args->channel_count = 1;
            args->channel = ast_malloc(sizeof(*args->channel) * args->channel_count);
            if (!args->channel) {
                return -1;
            }
            args->channel[0] = ast_json_string_get(field);
        }
    }
    field = ast_json_object_get(body, "role");
    if (field) {
        args->role = ast_json_string_get(field);
    }
    field = ast_json_object_get(body, "absorbDTMF");
    if (field) {
        args->absorb_dtmf = ast_json_is_true(field);
    }
    field = ast_json_object_get(body, "mute");
    if (field) {
        args->mute = ast_json_is_true(field);
    }
    field = ast_json_object_get(body, "inhibitConnectedLineUpdates");
    if (field) {
        args->inhibit_connected_line_updates = ast_json_is_true(field);
    }
    return 0;
}

References args, ast_free, AST_JSON_ARRAY, ast_json_array_get(), ast_json_array_size(), ast_json_is_true(), ast_json_object_get(), ast_json_string_get(), ast_json_typeof(), and ast_malloc.

Referenced by ast_ari_bridges_add_channel_cb().

ast_ari_bridges_clear_video_source()

void ast_ari_bridges_clear_video_source	(	struct ast_variable *	headers,
		struct ast_ari_bridges_clear_video_source_args *	args,
		struct ast_ari_response *	response
	)

Removes any explicit video source in a multi-party mixing bridge. This operation has no effect on bridges with two or fewer participants. When no explicit video source is set, talk detection will be used to determine the active video stream.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 1067 of file resource_bridges.c.

{
    struct ast_bridge *bridge;
 
    bridge = find_bridge(response, args->bridge_id);
    if (!bridge) {
        return;
    }
 
    ast_bridge_lock(bridge);
    ast_bridge_set_talker_src_video_mode(bridge);
    ast_bridge_unlock(bridge);
 
    ao2_ref(bridge, -1);
    ast_ari_response_no_content(response);
}

References ao2_ref, args, ast_ari_response_no_content(), ast_bridge_lock, ast_bridge_set_talker_src_video_mode(), ast_bridge_unlock, and find_bridge().

Referenced by ast_ari_bridges_clear_video_source_cb().

ast_ari_bridges_create()

void ast_ari_bridges_create	(	struct ast_variable *	headers,
		struct ast_ari_bridges_create_args *	args,
		struct ast_ari_response *	response
	)

Create a new bridge.

This bridge persists until it has been shut down, or Asterisk has been shut down.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 946 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, NULL, ao2_cleanup);
    RAII_VAR(struct ast_bridge_snapshot *, snapshot, NULL, ao2_cleanup);
 
    if (ast_bridge_topic_exists(args->bridge_id)) {
        ast_ari_response_error(
            response, 409, "Conflict",
            "Bridge with id '%s' already exists", args->bridge_id);
        return;
    }
 
    bridge = stasis_app_bridge_create(args->type, args->name, args->bridge_id);
    if (!bridge) {
        ast_ari_response_error(
            response, 500, "Internal Error",
            "Unable to create bridge. Possible duplicate bridge id '%s'", args->bridge_id);
        return;
    }
 
    ast_bridge_lock(bridge);
    snapshot = ast_bridge_snapshot_create(bridge);
    ast_bridge_unlock(bridge);
 
    if (!snapshot) {
        ast_ari_response_error(
            response, 500, "Internal Error",
            "Unable to create snapshot for new bridge");
        return;
    }
 
    ast_ari_response_ok(response,
        ast_bridge_snapshot_to_json(snapshot, stasis_app_get_sanitizer()));
}

References ao2_cleanup, args, ast_ari_response_error(), ast_ari_response_ok(), ast_bridge_lock, ast_bridge_snapshot_create(), ast_bridge_snapshot_to_json(), ast_bridge_topic_exists(), ast_bridge_unlock, NULL, RAII_VAR, stasis_app_bridge_create(), and stasis_app_get_sanitizer().

Referenced by ast_ari_bridges_create_cb().

ast_ari_bridges_create_parse_body()

int ast_ari_bridges_create_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_create_args *	args
	)

Body parsing function for /bridges.

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_bridges.c.

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

References args, ast_json_object_get(), and ast_json_string_get().

Referenced by ast_ari_bridges_create_cb().

ast_ari_bridges_create_with_id()

void ast_ari_bridges_create_with_id	(	struct ast_variable *	headers,
		struct ast_ari_bridges_create_with_id_args *	args,
		struct ast_ari_response *	response
	)

Create a new bridge.

This bridge persists until it has been shut down, or Asterisk has been shut down.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 983 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, NULL, ao2_cleanup);
    RAII_VAR(struct ast_bridge_snapshot *, snapshot, NULL, ao2_cleanup);
 
    if (ast_bridge_topic_exists(args->bridge_id)) {
        ast_ari_response_error(
            response, 409, "Conflict",
            "Bridge with id '%s' already exists", args->bridge_id);
        return;
    }
 
    bridge = stasis_app_bridge_create(args->type, args->name, args->bridge_id);
    if (!bridge) {
        ast_ari_response_error(
            response, 500, "Internal Error",
            "Unable to create bridge");
        return;
    }
 
    ast_bridge_lock(bridge);
    snapshot = ast_bridge_snapshot_create(bridge);
    ast_bridge_unlock(bridge);
 
    if (!snapshot) {
        ast_ari_response_error(
            response, 500, "Internal Error",
            "Unable to create snapshot for new bridge");
        return;
    }
 
    ast_ari_response_ok(response,
        ast_bridge_snapshot_to_json(snapshot, stasis_app_get_sanitizer()));
}

References ao2_cleanup, args, ast_ari_response_error(), ast_ari_response_ok(), ast_bridge_lock, ast_bridge_snapshot_create(), ast_bridge_snapshot_to_json(), ast_bridge_topic_exists(), ast_bridge_unlock, NULL, RAII_VAR, stasis_app_bridge_create(), and stasis_app_get_sanitizer().

Referenced by ast_ari_bridges_create_with_id_cb().

ast_ari_bridges_create_with_id_parse_body()

int ast_ari_bridges_create_with_id_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_create_with_id_args *	args
	)

Body parsing function for /bridges/{bridgeId}.

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 198 of file res_ari_bridges.c.

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

References args, ast_json_object_get(), and ast_json_string_get().

Referenced by ast_ari_bridges_create_with_id_cb().

ast_ari_bridges_destroy()

void ast_ari_bridges_destroy	(	struct ast_variable *	headers,
		struct ast_ari_bridges_destroy_args *	args,
		struct ast_ari_response *	response
	)

Shut down a bridge.

If any channels are in this bridge, they will be removed and resume whatever they were doing beforehand.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 882 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
    if (!bridge) {
        return;
    }
 
    stasis_app_bridge_destroy(args->bridge_id);
    ast_ari_response_no_content(response);
}

References ao2_cleanup, args, ast_ari_response_no_content(), ast_channel::bridge, find_bridge(), RAII_VAR, and stasis_app_bridge_destroy().

Referenced by ast_ari_bridges_destroy_cb().

ast_ari_bridges_get()

void ast_ari_bridges_get	(	struct ast_variable *	headers,
		struct ast_ari_bridges_get_args *	args,
		struct ast_ari_response *	response
	)

Get bridge details.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 866 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge_snapshot *, snapshot, ast_bridge_get_snapshot_by_uniqueid(args->bridge_id), ao2_cleanup);
    if (!snapshot) {
        ast_ari_response_error(
            response, 404, "Not Found",
            "Bridge not found");
        return;
    }
 
    ast_ari_response_ok(response,
        ast_bridge_snapshot_to_json(snapshot, stasis_app_get_sanitizer()));
}

References ao2_cleanup, args, ast_ari_response_error(), ast_ari_response_ok(), ast_bridge_get_snapshot_by_uniqueid(), ast_bridge_snapshot_to_json(), RAII_VAR, ast_channel::snapshot, and stasis_app_get_sanitizer().

Referenced by ast_ari_bridges_get_cb().

ast_ari_bridges_list()

void ast_ari_bridges_list	(	struct ast_variable *	headers,
		struct ast_ari_bridges_list_args *	args,
		struct ast_ari_response *	response
	)

List all active bridges in Asterisk.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 895 of file resource_bridges.c.

{
    RAII_VAR(struct ao2_container *, bridges, NULL, ao2_cleanup);
    RAII_VAR(struct ast_json *, json, NULL, ast_json_unref);
    struct ao2_iterator i;
    struct ast_bridge *bridge;
 
    bridges = ast_bridges();
    if (!bridges) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    json = ast_json_array_create();
    if (!json) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    i = ao2_iterator_init(bridges, 0);
    while ((bridge = ao2_iterator_next(&i))) {
        struct ast_bridge_snapshot *snapshot;
        struct ast_json *json_bridge = NULL;
 
        /* Invisible bridges don't get shown externally and have no snapshot */
        if (ast_test_flag(&bridge->feature_flags, AST_BRIDGE_FLAG_INVISIBLE)) {
            ao2_ref(bridge, -1);
            continue;
        }
 
        snapshot = ast_bridge_get_snapshot(bridge);
        if (snapshot) {
            json_bridge = ast_bridge_snapshot_to_json(snapshot, stasis_app_get_sanitizer());
            ao2_ref(snapshot, -1);
        }
 
        ao2_ref(bridge, -1);
 
        if (!json_bridge || ast_json_array_append(json, json_bridge)) {
            ao2_iterator_destroy(&i);
            ast_ari_response_alloc_failed(response);
            return;
        }
    }
    ao2_iterator_destroy(&i);
 
    ast_ari_response_ok(response, ast_json_ref(json));
}

References ao2_cleanup, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_ari_response_alloc_failed(), ast_ari_response_ok(), AST_BRIDGE_FLAG_INVISIBLE, ast_bridge_get_snapshot(), ast_bridge_snapshot_to_json(), ast_bridges(), ast_json_array_append(), ast_json_array_create(), ast_json_ref(), ast_json_unref(), ast_test_flag, bridges, ast_bridge::feature_flags, NULL, RAII_VAR, and stasis_app_get_sanitizer().

Referenced by ast_ari_bridges_list_cb().

ast_ari_bridges_play()

void ast_ari_bridges_play	(	struct ast_variable *	headers,
		struct ast_ari_bridges_play_args *	args,
		struct ast_ari_response *	response
	)

Start playback of media on a bridge.

The media URI may be any of a number of URI's. Currently sound:, recording:, number:, digits:, characters:, and tone: URI's are supported. This operation creates a playback resource that can be used to control the playback of media (pause, rewind, fast forward, etc.)

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 616 of file resource_bridges.c.

{
    ari_bridges_handle_play(args->bridge_id,
    args->media,
    args->media_count,
    args->lang,
    args->offsetms,
    args->skipms,
    args->playback_id,
    response);
}

References args, and ari_bridges_handle_play().

Referenced by ast_ari_bridges_play_cb().

ast_ari_bridges_play_parse_body()

int ast_ari_bridges_play_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_play_args *	args
	)

Body parsing function for /bridges/{bridgeId}/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 1012 of file res_ari_bridges.c.

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

References args, 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(), and ast_malloc.

Referenced by ast_ari_bridges_play_cb().

ast_ari_bridges_play_with_id()

void ast_ari_bridges_play_with_id	(	struct ast_variable *	headers,
		struct ast_ari_bridges_play_with_id_args *	args,
		struct ast_ari_response *	response
	)

Start playback of media on a bridge.

The media URI may be any of a number of URI's. Currently sound:, recording:, number:, digits:, characters:, and tone: URI's are supported. This operation creates a playback resource that can be used to control the playback of media (pause, rewind, fast forward, etc.)

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 630 of file resource_bridges.c.

{
    ari_bridges_handle_play(args->bridge_id,
    args->media,
    args->media_count,
    args->lang,
    args->offsetms,
    args->skipms,
    args->playback_id,
    response);
}

References args, and ari_bridges_handle_play().

Referenced by ast_ari_bridges_play_with_id_cb().

ast_ari_bridges_play_with_id_parse_body()

int ast_ari_bridges_play_with_id_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_play_with_id_args *	args
	)

Body parsing function for /bridges/{bridgeId}/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 1191 of file res_ari_bridges.c.

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

References args, 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(), and ast_malloc.

Referenced by ast_ari_bridges_play_with_id_cb().

ast_ari_bridges_record()

void ast_ari_bridges_record	(	struct ast_variable *	headers,
		struct ast_ari_bridges_record_args *	args,
		struct ast_ari_response *	response
	)

Start a recording.

This records the mixed audio from all channels participating in this bridge.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 644 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
    RAII_VAR(struct ast_channel *, record_channel, NULL, ast_hangup);
    RAII_VAR(struct stasis_app_control *, control, NULL, ao2_cleanup);
    RAII_VAR(struct stasis_app_recording *, recording, NULL, ao2_cleanup);
    RAII_VAR(char *, recording_url, NULL, ast_free);
    RAII_VAR(struct ast_json *, json, NULL, ast_json_unref);
    RAII_VAR(struct stasis_app_recording_options *, options, NULL, ao2_cleanup);
    RAII_VAR(char *, uri_encoded_name, NULL, ast_free);
    RAII_VAR(struct stasis_forward *, channel_forward, NULL, stasis_forward_cancel);
 
    struct stasis_topic *channel_topic;
    struct stasis_topic *bridge_topic;
    size_t uri_name_maxlen;
    struct bridge_channel_control_thread_data *thread_data;
    pthread_t threadid;
 
    ast_assert(response != NULL);
 
    if (bridge == NULL) {
        return;
    }
 
    if (!(record_channel = prepare_bridge_media_channel("Recorder"))) {
        ast_ari_response_error(
            response, 500, "Internal Server Error", "Failed to create recording channel");
        return;
    }
 
    bridge_topic = ast_bridge_topic(bridge);
    channel_topic = ast_channel_topic(record_channel);
 
    /* Forward messages from the recording channel topic to the bridge topic so that anything listening for
     * messages on the bridge topic will receive the recording start/stop messages. Other messages that would
     * go to this channel will be suppressed since the channel is marked as internal.
     */
    if (!bridge_topic || !channel_topic || !(channel_forward = stasis_forward_all(channel_topic, bridge_topic))) {
        ast_ari_response_error(
            response, 500, "Internal Error", "Could not forward record channel stasis messages to bridge topic");
        return;
    }
 
    if (ast_unreal_channel_push_to_bridge(record_channel, bridge,
        AST_BRIDGE_CHANNEL_FLAG_IMMOVABLE | AST_BRIDGE_CHANNEL_FLAG_LONELY)) {
        ast_ari_response_error(
            response, 500, "Internal Error", "Failed to put recording channel into the bridge");
        return;
    }
 
    control = stasis_app_control_create(record_channel);
    if (control == NULL) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    options = stasis_app_recording_options_create(args->name, args->format);
    if (options == NULL) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    ast_string_field_build(options, target, "bridge:%s", args->bridge_id);
    options->max_silence_seconds = args->max_silence_seconds;
    options->max_duration_seconds = args->max_duration_seconds;
    options->terminate_on =
        stasis_app_recording_termination_parse(args->terminate_on);
    options->if_exists =
        stasis_app_recording_if_exists_parse(args->if_exists);
    options->beep = args->beep;
 
    if (options->terminate_on == STASIS_APP_RECORDING_TERMINATE_INVALID) {
        ast_ari_response_error(
            response, 400, "Bad Request",
            "terminateOn invalid");
        return;
    }
 
    if (options->if_exists == AST_RECORD_IF_EXISTS_ERROR) {
        ast_ari_response_error(
            response, 400, "Bad Request",
            "ifExists invalid");
        return;
    }
 
    if (!ast_get_format_for_file_ext(options->format)) {
        ast_ari_response_error(
            response, 422, "Unprocessable Entity",
            "specified format is unknown on this system");
        return;
    }
 
    recording = stasis_app_control_record(control, options);
    if (recording == NULL) {
        switch(errno) {
        case EINVAL:
            /* While the arguments are invalid, we should have
             * caught them prior to calling record.
             */
            ast_ari_response_error(
                response, 500, "Internal Server Error",
                "Error parsing request");
            break;
        case EEXIST:
            ast_ari_response_error(response, 409, "Conflict",
                "Recording '%s' already exists and can not be overwritten",
                args->name);
            break;
        case ENOMEM:
            ast_ari_response_alloc_failed(response);
            break;
        case EPERM:
            ast_ari_response_error(
                response, 400, "Bad Request",
                "Recording name invalid");
            break;
        default:
            ast_log(LOG_WARNING,
                "Unrecognized recording error: %s\n",
                strerror(errno));
            ast_ari_response_error(
                response, 500, "Internal Server Error",
                "Internal Server Error");
            break;
        }
        return;
    }
 
    uri_name_maxlen = strlen(args->name) * 3;
    uri_encoded_name = ast_malloc(uri_name_maxlen);
    if (!uri_encoded_name) {
        ast_ari_response_alloc_failed(response);
        return;
    }
    ast_uri_encode(args->name, uri_encoded_name, uri_name_maxlen, ast_uri_http);
 
    if (ast_asprintf(&recording_url, "/recordings/live/%s",
            uri_encoded_name) == -1) {
        recording_url = NULL;
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    json = stasis_app_recording_to_json(recording);
    if (!json) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    thread_data = ast_calloc(1, sizeof(*thread_data));
    if (!thread_data) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    thread_data->bridge_channel = record_channel;
    thread_data->control = control;
    thread_data->forward = channel_forward;
 
    if (ast_pthread_create_detached(&threadid, NULL, bridge_channel_control_thread, thread_data)) {
        ast_ari_response_alloc_failed(response);
        ast_free(thread_data);
        return;
    }
 
    /* These are owned by the other thread now, so we don't want RAII_VAR disposing of them. */
    record_channel = NULL;
    control = NULL;
    channel_forward = NULL;
 
    ast_ari_response_created(response, recording_url, ast_json_ref(json));
}

References ao2_cleanup, args, ast_ari_response_alloc_failed(), ast_ari_response_created(), ast_ari_response_error(), ast_asprintf, ast_assert, AST_BRIDGE_CHANNEL_FLAG_IMMOVABLE, AST_BRIDGE_CHANNEL_FLAG_LONELY, ast_bridge_topic(), ast_calloc, ast_channel_topic(), ast_free, ast_get_format_for_file_ext(), ast_hangup(), ast_json_ref(), ast_json_unref(), ast_log, ast_malloc, ast_pthread_create_detached, AST_RECORD_IF_EXISTS_ERROR, ast_string_field_build, ast_unreal_channel_push_to_bridge(), ast_uri_encode(), ast_uri_http, ast_channel::bridge, bridge_channel_control_thread_data::bridge_channel, bridge_channel_control_thread(), ast_channel::channel_forward, bridge_channel_control_thread_data::control, errno, find_bridge(), bridge_channel_control_thread_data::forward, LOG_WARNING, NULL, options, prepare_bridge_media_channel(), RAII_VAR, stasis_app_control_create(), stasis_app_control_record(), stasis_app_recording_if_exists_parse(), stasis_app_recording_options_create(), STASIS_APP_RECORDING_TERMINATE_INVALID, stasis_app_recording_termination_parse(), stasis_app_recording_to_json(), stasis_forward_all(), and stasis_forward_cancel().

Referenced by ast_ari_bridges_record_cb().

ast_ari_bridges_record_parse_body()

int ast_ari_bridges_record_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_record_args *	args
	)

Body parsing function for /bridges/{bridgeId}/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 1366 of file res_ari_bridges.c.

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

References args, ast_json_integer_get(), ast_json_is_true(), ast_json_object_get(), and ast_json_string_get().

Referenced by ast_ari_bridges_record_cb().

ast_ari_bridges_remove_channel()

void ast_ari_bridges_remove_channel	(	struct ast_variable *	headers,
		struct ast_ari_bridges_remove_channel_args *	args,
		struct ast_ari_response *	response
	)

Remove a channel from a bridge.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 241 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
    RAII_VAR(struct control_list *, list, NULL, ao2_cleanup);
    size_t i;
 
    if (!bridge) {
        /* Response filled in by find_bridge() */
        return;
    }
 
    list = control_list_create(response, args->channel_count, args->channel);
    if (!list) {
        /* Response filled in by control_list_create() */
        return;
    }
 
    /* Make sure all of the channels are in this bridge */
    for (i = 0; i < list->count; ++i) {
        if (stasis_app_get_bridge(list->controls[i]) != bridge) {
            ast_log(LOG_WARNING, "Channel %s not in bridge %s\n",
                args->channel[i], args->bridge_id);
            ast_ari_response_error(response, 422,
                "Unprocessable Entity",
                "Channel not in this bridge");
            return;
        }
    }
 
    /* Now actually remove it */
    for (i = 0; i < list->count; ++i) {
        stasis_app_control_remove_channel_from_bridge(list->controls[i],
            bridge);
    }
 
    ast_ari_response_no_content(response);
}

References ao2_cleanup, args, ast_ari_response_error(), ast_ari_response_no_content(), ast_log, control_list_create(), find_bridge(), LOG_WARNING, NULL, RAII_VAR, stasis_app_control_remove_channel_from_bridge(), and stasis_app_get_bridge().

Referenced by ast_ari_bridges_remove_channel_cb().

ast_ari_bridges_remove_channel_parse_body()

int ast_ari_bridges_remove_channel_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_remove_channel_args *	args
	)

Body parsing function for /bridges/{bridgeId}/removeChannel.

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 589 of file res_ari_bridges.c.

{
    struct ast_json *field;
    /* Parse query parameters out of it */
    field = ast_json_object_get(body, "channel");
    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->channel);
        if (ast_json_typeof(field) == AST_JSON_ARRAY) {
            /* Multiple param passed as array */
            size_t i;
            args->channel_count = ast_json_array_size(field);
            args->channel = ast_malloc(sizeof(*args->channel) * args->channel_count);
 
            if (!args->channel) {
                return -1;
            }
 
            for (i = 0; i < args->channel_count; ++i) {
                args->channel[i] = ast_json_string_get(ast_json_array_get(field, i));
            }
        } else {
            /* Multiple param passed as single value */
            args->channel_count = 1;
            args->channel = ast_malloc(sizeof(*args->channel) * args->channel_count);
            if (!args->channel) {
                return -1;
            }
            args->channel[0] = ast_json_string_get(field);
        }
    }
    return 0;
}

References args, ast_free, AST_JSON_ARRAY, ast_json_array_get(), ast_json_array_size(), ast_json_object_get(), ast_json_string_get(), ast_json_typeof(), and ast_malloc.

Referenced by ast_ari_bridges_remove_channel_cb().

ast_ari_bridges_set_video_source()

void ast_ari_bridges_set_video_source	(	struct ast_variable *	headers,
		struct ast_ari_bridges_set_video_source_args *	args,
		struct ast_ari_response *	response
	)

Set a channel as the video source in a multi-party mixing bridge. This operation has no effect on bridges with two or fewer participants.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 1032 of file resource_bridges.c.

{
    struct ast_bridge *bridge;
    struct stasis_app_control *control;
 
    bridge = find_bridge(response, args->bridge_id);
    if (!bridge) {
        return;
    }
 
    control = find_channel_control(response, args->channel_id);
    if (!control) {
        ao2_ref(bridge, -1);
        return;
    }
 
    if (stasis_app_get_bridge(control) != bridge) {
        ast_ari_response_error(response, 422,
            "Unprocessable Entity",
            "Channel not in this bridge");
        ao2_ref(bridge, -1);
        ao2_ref(control, -1);
        return;
    }
 
    stasis_app_send_command(control, bridge_set_video_source_cb,
        ao2_bump(bridge), __ao2_cleanup);
 
    ao2_ref(bridge, -1);
    ao2_ref(control, -1);
 
    ast_ari_response_no_content(response);
}

References __ao2_cleanup(), ao2_bump, ao2_ref, args, ast_ari_response_error(), ast_ari_response_no_content(), stasis_app_control::bridge, bridge_set_video_source_cb(), find_bridge(), find_channel_control(), stasis_app_get_bridge(), and stasis_app_send_command().

Referenced by ast_ari_bridges_set_video_source_cb().

ast_ari_bridges_start_moh()

void ast_ari_bridges_start_moh	(	struct ast_variable *	headers,
		struct ast_ari_bridges_start_moh_args *	args,
		struct ast_ari_response *	response
	)

Play music on hold to a bridge or change the MOH class that is playing.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 819 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
    struct ast_channel *moh_channel;
    const char *moh_class = args->moh_class;
 
    if (!bridge) {
        /* The response is provided by find_bridge() */
        return;
    }
 
    moh_channel = stasis_app_bridge_moh_channel(bridge);
    if (!moh_channel) {
        ast_ari_response_alloc_failed(response);
        return;
    }
 
    ast_moh_start(moh_channel, moh_class, NULL);
    ast_channel_cleanup(moh_channel);
 
    ast_ari_response_no_content(response);
 
}

References ao2_cleanup, args, ast_ari_response_alloc_failed(), ast_ari_response_no_content(), ast_channel_cleanup, ast_moh_start(), ast_channel::bridge, find_bridge(), NULL, RAII_VAR, and stasis_app_bridge_moh_channel().

Referenced by ast_ari_bridges_start_moh_cb().

ast_ari_bridges_start_moh_parse_body()

int ast_ari_bridges_start_moh_parse_body	(	struct ast_json *	body,
		struct ast_ari_bridges_start_moh_args *	args
	)

Body parsing function for /bridges/{bridgeId}/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 867 of file res_ari_bridges.c.

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

References args, ast_json_object_get(), and ast_json_string_get().

Referenced by ast_ari_bridges_start_moh_cb().

ast_ari_bridges_stop_moh()

void ast_ari_bridges_stop_moh	(	struct ast_variable *	headers,
		struct ast_ari_bridges_stop_moh_args *	args,
		struct ast_ari_response *	response
	)

Stop playing music on hold to a bridge.

This will only stop music on hold being played via POST bridges/{bridgeId}/moh.

Parameters

	headers	HTTP headers
	args	Swagger parameters
[out]	response	HTTP response

Definition at line 845 of file resource_bridges.c.

{
    RAII_VAR(struct ast_bridge *, bridge, find_bridge(response, args->bridge_id), ao2_cleanup);
 
    if (!bridge) {
        /* the response is provided by find_bridge() */
        return;
    }
 
    if (stasis_app_bridge_moh_stop(bridge)) {
        ast_ari_response_error(
            response, 409, "Conflict",
            "Bridge isn't playing music");
        return;
    }
 
    ast_ari_response_no_content(response);
}

References ao2_cleanup, args, ast_ari_response_error(), ast_ari_response_no_content(), ast_channel::bridge, find_bridge(), RAII_VAR, and stasis_app_bridge_moh_stop().

Referenced by ast_ari_bridges_stop_moh_cb().