confbridge_manager.c File Reference

Confbridge manager events for stasis messages. More...

#include "asterisk.h"
#include "asterisk/channel.h"
#include "asterisk/bridge.h"
#include "asterisk/stasis.h"
#include "asterisk/stasis_channels.h"
#include "asterisk/stasis_bridges.h"
#include "asterisk/manager.h"
#include "asterisk/stasis_message_router.h"
#include "include/confbridge.h"
#include "asterisk/message.h"
#include "asterisk/stream.h"

Include dependency graph for confbridge_manager.c:

Go to the source code of this file.

Functions
static struct ast_json *	bridge_to_json (struct ast_bridge_snapshot *bridge_snapshot)
static struct ast_json *	channel_to_json (struct ast_channel_snapshot *channel_snapshot, struct ast_json *conf_blob, struct ast_json *labels_blob)
void	conf_send_event_to_participants (struct confbridge_conference *conference, struct ast_channel *chan, struct stasis_message *msg)
	Send events to bridge participants. More...
static void	confbridge_atxfer_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_end_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
const char *	confbridge_event_type_to_string (struct stasis_message_type *event_type)
	Get the string representation of a confbridge stasis message type. More...
static void	confbridge_join_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_leave_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_mute_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_publish_manager_event (struct stasis_message *message, struct ast_str *extra_text)
static void	confbridge_start_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_start_record_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_stop_record_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_talking_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static void	confbridge_unmute_cb (void *data, struct stasis_subscription *sub, struct stasis_message *message)
static int	get_admin_header (struct ast_str **extra_text, struct stasis_message *message)
static int	get_bool_header (struct ast_str **extra_text, struct stasis_message *message, const char *json_key, const char *ami_header)
static int	get_muted_header (struct ast_str **extra_text, struct stasis_message *message)
int	manager_confbridge_init (void)
	register stasis message routers to handle manager events for confbridge messages More...
void	manager_confbridge_shutdown (void)
	unregister stasis message routers to handle manager events for confbridge messages More...
static struct ast_json *	pack_bridge_and_channel (struct ast_json *json_bridge, struct ast_json *json_channel, struct stasis_message *msg)
static struct ast_json *	pack_bridge_and_channels (struct ast_json *json_bridge, struct ast_json *json_channels, struct stasis_message *msg)
static struct ast_json *	pack_snapshots (struct ast_bridge_snapshot *bridge_snapshot, struct ast_channel_snapshot *channel_snapshot, struct ast_json *conf_blob, struct ast_json *labels_blob, struct stasis_message *msg)
static void	send_message (const char *msg_name, char *conf_name, struct ast_json *json_object, struct ast_channel *chan)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_end_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_join_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_leave_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_mute_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_start_record_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_start_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_stop_record_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_talking_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_unmute_type)
	STASIS_MESSAGE_TYPE_DEFN (confbridge_welcome_type)

Variables
static struct stasis_message_router *	bridge_state_router
static struct stasis_message_router *	channel_state_router

Detailed Description

Confbridge manager events for stasis messages.

Author

Jonathan Rose jrose.nosp@m.@dig.nosp@m.ium.c.nosp@m.om

Definition in file confbridge_manager.c.

Function Documentation

bridge_to_json()

static struct ast_json * bridge_to_json ( struct ast_bridge_snapshot *  bridge_snapshot )

static

Definition at line 338 of file confbridge_manager.c.

{
    struct ast_json *json_bridge = ast_bridge_snapshot_to_json(bridge_snapshot, NULL);
 
    if (!json_bridge) {
        return NULL;
    }
 
    /* These items have no use in the context of bridge participant info. */
    ast_json_object_del(json_bridge, "technology");
    ast_json_object_del(json_bridge, "bridge_type");
    ast_json_object_del(json_bridge, "bridge_class");
    ast_json_object_del(json_bridge, "creator");
    ast_json_object_del(json_bridge, "channels");
 
    return json_bridge;
}

References ast_bridge_snapshot_to_json(), ast_json_object_del(), and NULL.

Referenced by conf_send_event_to_participants(), and pack_snapshots().

channel_to_json()

static struct ast_json * channel_to_json ( struct ast_channel_snapshot *  channel_snapshot, struct ast_json *  conf_blob, struct ast_json *  labels_blob  )

static

Definition at line 303 of file confbridge_manager.c.

{
    struct ast_json *json_channel = ast_channel_snapshot_to_json(channel_snapshot, NULL);
 
    if (!json_channel) {
        return NULL;
    }
 
    /* These items are removed for privacy reasons. */
    ast_json_object_del(json_channel, "dialplan");
    ast_json_object_del(json_channel, "connected");
    ast_json_object_del(json_channel, "accountcode");
 
    /* conf_blob contains flags such as talking, admin, mute, etc. */
    if (conf_blob) {
        struct ast_json *conf_copy = ast_json_copy(conf_blob);
 
        if (!conf_copy) {
            ast_json_unref(json_channel);
            return NULL;
        }
        ast_json_object_del(conf_copy, "conference");
        ast_json_object_update(json_channel, conf_copy);
        ast_json_unref(conf_copy);
    }
 
    /* labels_blob contains the msid labels to correlate to streams. */
    if (labels_blob) {
        ast_json_object_update(json_channel, labels_blob);
    }
 
    return json_channel;
}

References ast_channel_snapshot_to_json(), ast_json_copy(), ast_json_object_del(), ast_json_object_update(), ast_json_unref(), and NULL.

Referenced by conf_send_event_to_participants(), and pack_snapshots().

conf_send_event_to_participants()

void conf_send_event_to_participants	(	struct confbridge_conference *	conference,
		struct ast_channel *	chan,
		struct stasis_message *	msg
	)

Send events to bridge participants.

Since

15.7

16.1

Parameters

conference	The conference bridge
chan	The channel triggering the action
msg	The stasis message describing the event

Definition at line 453 of file confbridge_manager.c.

{
    struct ast_bridge_blob *obj = stasis_message_data(msg);
    struct ast_json *extras = obj->blob;
    struct user_profile u_profile = {{0}};
    int source_send_events = 0;
    int source_echo_events = 0;
    struct ast_json* json_channels = NULL;
    struct confbridge_user *user;
    const char *msg_name = confbridge_event_type_to_string(stasis_message_type(msg));
 
    ast_debug(3, "Distributing %s event to participants\n", msg_name);
 
    /* This could be a channel level event or a bridge level event */
    if (chan) {
        if (!conf_find_user_profile(chan, NULL, &u_profile)) {
            ast_log(LOG_ERROR, "Unable to retrieve user profile for channel '%s'\n",
                ast_channel_name(chan));
            return;
        }
        source_send_events = ast_test_flag(&u_profile, USER_OPT_SEND_EVENTS);
        source_echo_events = ast_test_flag(&u_profile, USER_OPT_ECHO_EVENTS);
        ast_debug(3, "send_events: %d  echo_events: %d for profile %s\n",
            source_send_events, source_echo_events, u_profile.name);
    }
 
    /* Now send a message to the participants with the json string. */
    ao2_lock(conference);
    AST_LIST_TRAVERSE(&conference->active_list, user, list) {
        struct ast_json *json_object;
 
        /*
         * If the msg type is join, we need to capture all targets channel info so we can
         * send a welcome message to the source channel with all current participants.
         */
        if (source_send_events && stasis_message_type(msg) == confbridge_join_type()) {
            struct ast_channel_snapshot *target_snapshot;
            struct ast_json *target_json_channel;
 
            target_snapshot = ast_channel_snapshot_get_latest(ast_channel_uniqueid(user->chan));
            if (!target_snapshot) {
                ast_log(LOG_ERROR, "Unable to get a channel snapshot for '%s'\n",
                    ast_channel_name(user->chan));
                continue;
            }
 
            target_json_channel = channel_to_json(target_snapshot, extras, NULL);
            ao2_ref(target_snapshot, -1);
 
            if (!json_channels) {
                json_channels = ast_json_array_create();
                if (!json_channels) {
                    ast_log(LOG_ERROR, "Unable to allocate json array\n");
                    ast_json_unref(target_json_channel);
                    return;
                }
            }
 
            ast_json_array_append(json_channels, target_json_channel);
        }
 
        /* Don't send a message to the user that triggered the event. */
        if (!source_echo_events && user->chan == chan) {
            ast_debug(3, "Skipping queueing %s message to '%s'. Same channel.\n", msg_name,
                ast_channel_name(user->chan));
            continue;
        }
 
        /* Don't send a message to users in profiles not sending events. */
        if (!ast_test_flag(&user->u_profile, USER_OPT_SEND_EVENTS)) {
            ast_debug(3, "Skipping queueing %s message to '%s'. Not receiving events.\n", msg_name,
                ast_channel_name(user->chan));
            continue;
        }
 
        json_object = pack_snapshots(obj->bridge, obj->channel, extras, NULL, msg);
 
        if (!json_object) {
            ast_log(LOG_ERROR, "Unable to convert %s message to json\n", msg_name);
            continue;
        }
 
        send_message(msg_name, conference->name, json_object, user->chan);
        ast_json_unref(json_object);
    }
    ao2_unlock(conference);
 
    /*
     * If this is a join event, send the welcome message to just the joining user
     * if it's not audio-only or otherwise restricted.
     */
    if (source_send_events && json_channels
        && stasis_message_type(msg) == confbridge_join_type()) {
        struct ast_json *json_object;
        struct ast_json *json_bridge;
        const char *welcome_msg_name = confbridge_event_type_to_string(confbridge_welcome_type());
 
        json_bridge = bridge_to_json(obj->bridge);
        json_object = pack_bridge_and_channels(json_bridge, json_channels, msg);
        if (!json_object) {
            ast_log(LOG_ERROR, "Unable to convert ConfbridgeWelcome message to json\n");
            return;
        }
        ast_json_string_set(ast_json_object_get(json_object, "type"), welcome_msg_name);
 
        send_message(welcome_msg_name, conference->name, json_object, chan);
        ast_json_unref(json_object);
    }
}

References confbridge_conference::active_list, ao2_lock, ao2_ref, ao2_unlock, ast_channel_name(), ast_channel_snapshot_get_latest(), ast_channel_uniqueid(), ast_debug, ast_json_array_append(), ast_json_array_create(), ast_json_object_get(), ast_json_string_set(), ast_json_unref(), AST_LIST_TRAVERSE, ast_log, ast_test_flag, ast_bridge_blob::blob, ast_bridge_blob::bridge, bridge_to_json(), confbridge_user::chan, ast_bridge_blob::channel, channel_to_json(), conf_find_user_profile(), confbridge_event_type_to_string(), confbridge_join_type(), confbridge_welcome_type(), confbridge_user::conference, confbridge_user::list, LOG_ERROR, confbridge_conference::name, user_profile::name, NULL, pack_bridge_and_channels(), pack_snapshots(), send_message(), stasis_message_data(), stasis_message_type(), confbridge_user::u_profile, user, USER_OPT_ECHO_EVENTS, and USER_OPT_SEND_EVENTS.

Referenced by send_conf_stasis().

confbridge_atxfer_cb()

static void confbridge_atxfer_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 663 of file confbridge_manager.c.

{
    struct ast_attended_transfer_message *msg = stasis_message_data(message);
 
    if (msg->result != AST_BRIDGE_TRANSFER_SUCCESS) {
        return;
    }
 
    /*
     * This callback will get called for ALL attended transfers
     * so we need to make sure this transfer belongs to
     * a conference bridge before trying to handle it.
     */
    if (msg->dest_type == AST_ATTENDED_TRANSFER_DEST_APP
        && strcmp(msg->dest.app, "ConfBridge") == 0) {
        confbridge_handle_atxfer(msg);
    }
}

References ast_attended_transfer_message::app, AST_ATTENDED_TRANSFER_DEST_APP, AST_BRIDGE_TRANSFER_SUCCESS, confbridge_handle_atxfer(), ast_attended_transfer_message::dest, ast_attended_transfer_message::dest_type, ast_attended_transfer_message::result, and stasis_message_data().

Referenced by manager_confbridge_init().

confbridge_end_cb()

static void confbridge_end_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 634 of file confbridge_manager.c.

{
    confbridge_publish_manager_event(message, NULL);
}

References confbridge_publish_manager_event(), and NULL.

Referenced by manager_confbridge_init().

confbridge_event_type_to_string()

const char * confbridge_event_type_to_string

(

struct stasis_message_type *

event_type

)

Get the string representation of a confbridge stasis message type.

Since

15.5

Parameters

event_type

The confbridge event type such as 'confbridge_welcome_type()'

Return values

The	string representation of the message type
unknown	if not found

Definition at line 276 of file confbridge_manager.c.

{
    if (event_type == confbridge_start_type()) {
        return "ConfbridgeStart";
    } else if (event_type == confbridge_end_type()) {
        return "ConfbridgeEnd";
    } else if (event_type == confbridge_join_type()) {
        return "ConfbridgeJoin";
    } else if (event_type == confbridge_leave_type()) {
        return "ConfbridgeLeave";
    } else if (event_type == confbridge_start_record_type()) {
        return "ConfbridgeRecord";
    } else if (event_type == confbridge_stop_record_type()) {
        return "ConfbridgeStopRecord";
    } else if (event_type == confbridge_mute_type()) {
        return "ConfbridgeMute";
    } else if (event_type == confbridge_unmute_type()) {
        return "ConfbridgeUnmute";
    } else if (event_type == confbridge_talking_type()) {
        return "ConfbridgeTalking";
    } else if (event_type == confbridge_welcome_type()) {
        return "ConfbridgeWelcome";
    } else {
        return "unknown";
    }
}

References confbridge_end_type(), confbridge_join_type(), confbridge_leave_type(), confbridge_mute_type(), confbridge_start_record_type(), confbridge_start_type(), confbridge_stop_record_type(), confbridge_talking_type(), confbridge_unmute_type(), and confbridge_welcome_type().

Referenced by conf_send_event_to_participants(), confbridge_publish_manager_event(), pack_bridge_and_channel(), pack_bridge_and_channels(), and send_message().

confbridge_join_cb()

static void confbridge_join_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 651 of file confbridge_manager.c.

{
    struct ast_str *extra_text = NULL;
 
    if (!get_admin_header(&extra_text, message)
        && !get_muted_header(&extra_text, message)) {
        confbridge_publish_manager_event(message, extra_text);
    }
    ast_free(extra_text);
}

References ast_free, confbridge_publish_manager_event(), get_admin_header(), get_muted_header(), and NULL.

Referenced by manager_confbridge_init().

confbridge_leave_cb()

static void confbridge_leave_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 640 of file confbridge_manager.c.

{
    struct ast_str *extra_text = NULL;
 
    if (!get_admin_header(&extra_text, message)) {
        confbridge_publish_manager_event(message, extra_text);
    }
    ast_free(extra_text);
}

References ast_free, confbridge_publish_manager_event(), get_admin_header(), and NULL.

Referenced by manager_confbridge_init().

confbridge_mute_cb()

static void confbridge_mute_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 695 of file confbridge_manager.c.

{
    struct ast_str *extra_text = NULL;
 
    if (!get_admin_header(&extra_text, message)) {
        confbridge_publish_manager_event(message, extra_text);
    }
    ast_free(extra_text);
}

References ast_free, confbridge_publish_manager_event(), get_admin_header(), and NULL.

Referenced by manager_confbridge_init().

confbridge_publish_manager_event()

static void confbridge_publish_manager_event ( struct stasis_message *  message, struct ast_str *  extra_text  )

static

Definition at line 564 of file confbridge_manager.c.

{
    struct ast_bridge_blob *blob = stasis_message_data(message);
    const char *event = confbridge_event_type_to_string(stasis_message_type(message));
    const char *conference_name;
    RAII_VAR(struct ast_str *, bridge_text, NULL, ast_free);
    RAII_VAR(struct ast_str *, channel_text, NULL, ast_free);
 
    ast_assert(blob != NULL);
    ast_assert(event != NULL);
 
    bridge_text = ast_manager_build_bridge_state_string(blob->bridge);
    if (!bridge_text) {
        return;
    }
 
    conference_name = ast_json_string_get(ast_json_object_get(blob->blob, "conference"));
    ast_assert(conference_name != NULL);
 
    if (blob->channel) {
        struct confbridge_conference *conference = conf_find_bridge(conference_name);
 
        channel_text = ast_manager_build_channel_state_string(blob->channel);
        ao2_cleanup(conference);
    }
 
    manager_event(EVENT_FLAG_CALL, event,
        "Conference: %s\r\n"
        "%s"
        "%s"
        "%s",
        conference_name,
        ast_str_buffer(bridge_text),
        channel_text ? ast_str_buffer(channel_text) : "",
        extra_text ? ast_str_buffer(extra_text) : "");
}

References ao2_cleanup, ast_assert, ast_free, ast_json_object_get(), ast_json_string_get(), ast_manager_build_bridge_state_string(), ast_manager_build_channel_state_string(), ast_str_buffer(), ast_bridge_blob::blob, ast_bridge_blob::channel, conf_find_bridge(), confbridge_event_type_to_string(), EVENT_FLAG_CALL, manager_event, NULL, RAII_VAR, stasis_message_data(), and stasis_message_type().

Referenced by confbridge_end_cb(), confbridge_join_cb(), confbridge_leave_cb(), confbridge_mute_cb(), confbridge_start_cb(), confbridge_start_record_cb(), confbridge_stop_record_cb(), confbridge_talking_cb(), and confbridge_unmute_cb().

confbridge_start_cb()

static void confbridge_start_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 628 of file confbridge_manager.c.

{
    confbridge_publish_manager_event(message, NULL);
}

References confbridge_publish_manager_event(), and NULL.

Referenced by manager_confbridge_init().

confbridge_start_record_cb()

static void confbridge_start_record_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 683 of file confbridge_manager.c.

{
    confbridge_publish_manager_event(message, NULL);
}

References confbridge_publish_manager_event(), and NULL.

Referenced by manager_confbridge_init().

confbridge_stop_record_cb()

static void confbridge_stop_record_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 689 of file confbridge_manager.c.

{
    confbridge_publish_manager_event(message, NULL);
}

References confbridge_publish_manager_event(), and NULL.

Referenced by manager_confbridge_init().

confbridge_talking_cb()

static void confbridge_talking_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 717 of file confbridge_manager.c.

{
    RAII_VAR(struct ast_str *, extra_text, NULL, ast_free);
    const struct ast_bridge_blob *blob = stasis_message_data(message);
    const char *talking_status = ast_json_string_get(ast_json_object_get(blob->blob, "talking_status"));
    if (!talking_status) {
        return;
    }
 
    ast_str_append_event_header(&extra_text, "TalkingStatus", talking_status);
    if (!extra_text) {
        return;
    }
 
    if (!get_admin_header(&extra_text, message)) {
        confbridge_publish_manager_event(message, extra_text);
    }
}

References ast_free, ast_json_object_get(), ast_json_string_get(), ast_str_append_event_header(), ast_bridge_blob::blob, confbridge_publish_manager_event(), get_admin_header(), NULL, RAII_VAR, and stasis_message_data().

Referenced by manager_confbridge_init().

confbridge_unmute_cb()

static void confbridge_unmute_cb ( void *  data, struct stasis_subscription *  sub, struct stasis_message *  message  )

static

Definition at line 706 of file confbridge_manager.c.

{
    struct ast_str *extra_text = NULL;
 
    if (!get_admin_header(&extra_text, message)) {
        confbridge_publish_manager_event(message, extra_text);
    }
    ast_free(extra_text);
}

References ast_free, confbridge_publish_manager_event(), get_admin_header(), and NULL.

Referenced by manager_confbridge_init().

get_admin_header()

static int get_admin_header ( struct ast_str **  extra_text, struct stasis_message *  message  )

static

Definition at line 618 of file confbridge_manager.c.

{
    return get_bool_header(extra_text, message, "admin", "Admin");
}

References get_bool_header().

Referenced by confbridge_join_cb(), confbridge_leave_cb(), confbridge_mute_cb(), confbridge_talking_cb(), and confbridge_unmute_cb().

get_bool_header()

static int get_bool_header ( struct ast_str **  extra_text, struct stasis_message *  message, const char *  json_key, const char *  ami_header  )

static

Definition at line 603 of file confbridge_manager.c.

{
    const struct ast_bridge_blob *blob = stasis_message_data(message);
    const struct ast_json *obj;
 
    obj = ast_json_object_get(blob->blob, json_key);
    if (!obj) {
        return -1;
    }
 
    return ast_str_append_event_header(extra_text, ami_header,
        AST_YESNO(ast_json_is_true(obj)));
}

References ast_json_is_true(), ast_json_object_get(), ast_str_append_event_header(), AST_YESNO, ast_bridge_blob::blob, and stasis_message_data().

Referenced by get_admin_header(), and get_muted_header().

get_muted_header()

static int get_muted_header ( struct ast_str **  extra_text, struct stasis_message *  message  )

static

Definition at line 623 of file confbridge_manager.c.

{
    return get_bool_header(extra_text, message, "muted", "Muted");
}

References get_bool_header().

Referenced by confbridge_join_cb().

manager_confbridge_init()

int manager_confbridge_init

(

void

)

register stasis message routers to handle manager events for confbridge messages

Since

12.0

Return values

0	success
non-zero	failure

Definition at line 760 of file confbridge_manager.c.

{
    STASIS_MESSAGE_TYPE_INIT(confbridge_start_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_end_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_join_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_leave_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_start_record_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_stop_record_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_mute_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_unmute_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_talking_type);
    STASIS_MESSAGE_TYPE_INIT(confbridge_welcome_type);
 
    bridge_state_router = stasis_message_router_create(
        ast_bridge_topic_all());
 
    if (!bridge_state_router) {
        return -1;
    }
 
    if (stasis_message_router_add(bridge_state_router,
            confbridge_start_type(),
            confbridge_start_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_end_type(),
            confbridge_end_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_join_type(),
            confbridge_join_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            ast_attended_transfer_type(),
            confbridge_atxfer_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_leave_type(),
            confbridge_leave_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_start_record_type(),
            confbridge_start_record_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_stop_record_type(),
            confbridge_stop_record_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_mute_type(),
            confbridge_mute_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_unmute_type(),
            confbridge_unmute_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(bridge_state_router,
            confbridge_talking_type(),
            confbridge_talking_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
 
    channel_state_router = stasis_message_router_create(
        ast_channel_topic_all());
 
    if (!channel_state_router) {
        manager_confbridge_shutdown();
        return -1;
    }
 
    if (stasis_message_router_add(channel_state_router,
            confbridge_start_type(),
            confbridge_start_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_end_type(),
            confbridge_end_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_join_type(),
            confbridge_join_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_leave_type(),
            confbridge_leave_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_start_record_type(),
            confbridge_start_record_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_stop_record_type(),
            confbridge_stop_record_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_mute_type(),
            confbridge_mute_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_unmute_type(),
            confbridge_unmute_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
    if (stasis_message_router_add(channel_state_router,
            confbridge_talking_type(),
            confbridge_talking_cb,
            NULL)) {
        manager_confbridge_shutdown();
        return -1;
    }
 
    /* FYI: confbridge_welcome_type is never routed */
 
    return 0;
}

References ast_attended_transfer_type(), ast_bridge_topic_all(), ast_channel_topic_all(), bridge_state_router, channel_state_router, confbridge_atxfer_cb(), confbridge_end_cb(), confbridge_end_type(), confbridge_join_cb(), confbridge_join_type(), confbridge_leave_cb(), confbridge_leave_type(), confbridge_mute_cb(), confbridge_mute_type(), confbridge_start_cb(), confbridge_start_record_cb(), confbridge_start_record_type(), confbridge_start_type(), confbridge_stop_record_cb(), confbridge_stop_record_type(), confbridge_talking_cb(), confbridge_talking_type(), confbridge_unmute_cb(), confbridge_unmute_type(), confbridge_welcome_type(), manager_confbridge_shutdown(), NULL, stasis_message_router_add(), stasis_message_router_create, and STASIS_MESSAGE_TYPE_INIT.

Referenced by load_module().

manager_confbridge_shutdown()

void manager_confbridge_shutdown

(

void

)

unregister stasis message routers to handle manager events for confbridge messages

Since

12.0

Definition at line 737 of file confbridge_manager.c.

                                       {
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_start_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_end_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_join_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_leave_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_start_record_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_stop_record_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_mute_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_unmute_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_talking_type);
    STASIS_MESSAGE_TYPE_CLEANUP(confbridge_welcome_type);
 
    if (bridge_state_router) {
        stasis_message_router_unsubscribe(bridge_state_router);
        bridge_state_router = NULL;
    }
 
    if (channel_state_router) {
        stasis_message_router_unsubscribe(channel_state_router);
        channel_state_router = NULL;
    }
}

References bridge_state_router, channel_state_router, confbridge_end_type(), confbridge_join_type(), confbridge_leave_type(), confbridge_mute_type(), confbridge_start_record_type(), confbridge_start_type(), confbridge_stop_record_type(), confbridge_talking_type(), confbridge_unmute_type(), confbridge_welcome_type(), NULL, stasis_message_router_unsubscribe(), and STASIS_MESSAGE_TYPE_CLEANUP.

Referenced by manager_confbridge_init(), and unload_module().

pack_bridge_and_channel()

static struct ast_json * pack_bridge_and_channel ( struct ast_json *  json_bridge, struct ast_json *  json_channel, struct stasis_message *  msg  )

static

Definition at line 356 of file confbridge_manager.c.

{
    const struct timeval *tv = stasis_message_timestamp(msg);
    const char *msg_name = confbridge_event_type_to_string(stasis_message_type(msg));
 
    return ast_json_pack("{s: s, s: o, s: o, s: [o*]}",
        "type", msg_name,
        "timestamp", ast_json_timeval(*tv, NULL),
        "bridge", json_bridge,
        "channels", json_channel);
}

References ast_json_pack(), ast_json_timeval(), confbridge_event_type_to_string(), NULL, stasis_message_timestamp(), and stasis_message_type().

Referenced by pack_snapshots().

pack_bridge_and_channels()

static struct ast_json * pack_bridge_and_channels ( struct ast_json *  json_bridge, struct ast_json *  json_channels, struct stasis_message *  msg  )

static

Definition at line 370 of file confbridge_manager.c.

{
    const struct timeval *tv = stasis_message_timestamp(msg);
    const char *msg_name = confbridge_event_type_to_string(stasis_message_type(msg));
 
    return ast_json_pack("{s: s, s: o, s: o, s: o}",
        "type", msg_name,
        "timestamp", ast_json_timeval(*tv, NULL),
        "bridge", json_bridge,
        "channels", json_channels);
}

References ast_json_pack(), ast_json_timeval(), confbridge_event_type_to_string(), NULL, stasis_message_timestamp(), and stasis_message_type().

Referenced by conf_send_event_to_participants().

pack_snapshots()

static struct ast_json * pack_snapshots ( struct ast_bridge_snapshot *  bridge_snapshot, struct ast_channel_snapshot *  channel_snapshot, struct ast_json *  conf_blob, struct ast_json *  labels_blob, struct stasis_message *  msg  )

static

Definition at line 384 of file confbridge_manager.c.

{
    struct ast_json *json_bridge;
    struct ast_json *json_channel;
 
    json_bridge = bridge_to_json(bridge_snapshot);
    json_channel = channel_to_json(channel_snapshot, conf_blob, labels_blob);
 
    return pack_bridge_and_channel(json_bridge, json_channel, msg);
}

References bridge_to_json(), channel_to_json(), and pack_bridge_and_channel().

Referenced by conf_send_event_to_participants().

send_message()

static void send_message ( const char *  msg_name, char *  conf_name, struct ast_json *  json_object, struct ast_channel *  chan  )

static

Definition at line 397 of file confbridge_manager.c.

{
    struct ast_msg_data *data_msg;
    struct ast_msg_data_attribute attrs[] = {
        { .type = AST_MSG_DATA_ATTR_FROM, conf_name },
        { .type = AST_MSG_DATA_ATTR_CONTENT_TYPE, .value = "application/x-asterisk-confbridge-event+json"},
        { .type = AST_MSG_DATA_ATTR_BODY, },
    };
    char *json;
    int rc = 0;
    struct ast_frame f;
    RAII_VAR(struct ast_bridge_channel *, bridge_chan, NULL, ao2_cleanup);
 
    bridge_chan = ast_channel_get_bridge_channel(chan);
    if (!bridge_chan) {
        /* Don't complain if we can't get the bridge_chan. The channel is probably gone. */
        return;
    }
 
    json = ast_json_dump_string_format(json_object, AST_JSON_PRETTY);
    if (!json) {
        ast_log(LOG_ERROR, "Unable to convert json_object for %s message to string\n", msg_name);
        return;
    }
    attrs[2].value = json;
 
    data_msg = ast_msg_data_alloc(AST_MSG_DATA_SOURCE_TYPE_IN_DIALOG, attrs, ARRAY_LEN(attrs));
    if (!data_msg) {
        ast_log(LOG_ERROR, "Unable to create %s message for channel '%s'\n", msg_name,
            ast_channel_name(chan));
        ast_json_free(json);
        return;
    }
 
    memset(&f, 0, sizeof(f));
    f.frametype = AST_FRAME_TEXT_DATA;
    f.data.ptr = data_msg;
    f.datalen = ast_msg_data_get_length(data_msg);
 
    rc = ast_bridge_channel_queue_frame(bridge_chan, &f);
    ast_free(data_msg);
    if (rc != 0) {
        /* Don't complain if we can't send a leave message. The channel is probably gone. */
        if (strcmp(confbridge_event_type_to_string(confbridge_leave_type()), msg_name) != 0) {
            ast_log(LOG_ERROR, "Failed to queue %s message to '%s'\n%s\n", msg_name,
                ast_channel_name(chan), json);
        }
        ast_json_free(json);
        return;
    }
 
    ast_debug(3, "Queued %s message to '%s'\n%s\n", msg_name, ast_channel_name(chan), json);
    ast_json_free(json);
}

References ao2_cleanup, ARRAY_LEN, ast_bridge_channel_queue_frame(), ast_channel_get_bridge_channel(), ast_channel_name(), ast_debug, AST_FRAME_TEXT_DATA, ast_free, ast_json_dump_string_format(), ast_json_free(), AST_JSON_PRETTY, ast_log, ast_msg_data_alloc(), AST_MSG_DATA_ATTR_BODY, AST_MSG_DATA_ATTR_CONTENT_TYPE, AST_MSG_DATA_ATTR_FROM, ast_msg_data_get_length(), AST_MSG_DATA_SOURCE_TYPE_IN_DIALOG, confbridge_event_type_to_string(), confbridge_leave_type(), ast_frame::data, ast_frame::datalen, ast_frame::frametype, LOG_ERROR, NULL, ast_frame::ptr, RAII_VAR, ast_msg_data_attribute::type, and ast_msg_data_attribute::value.

Referenced by conf_send_event_to_participants().

STASIS_MESSAGE_TYPE_DEFN() [1/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_end_type

)

STASIS_MESSAGE_TYPE_DEFN() [2/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_join_type

)

STASIS_MESSAGE_TYPE_DEFN() [3/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_leave_type

)

STASIS_MESSAGE_TYPE_DEFN() [4/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_mute_type

)

STASIS_MESSAGE_TYPE_DEFN() [5/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_start_record_type

)

STASIS_MESSAGE_TYPE_DEFN() [6/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_start_type

)

STASIS_MESSAGE_TYPE_DEFN() [7/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_stop_record_type

)

STASIS_MESSAGE_TYPE_DEFN() [8/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_talking_type

)

STASIS_MESSAGE_TYPE_DEFN() [9/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_unmute_type

)

STASIS_MESSAGE_TYPE_DEFN() [10/10]

STASIS_MESSAGE_TYPE_DEFN

(

confbridge_welcome_type

)

Variable Documentation

bridge_state_router

struct stasis_message_router* bridge_state_router

static

Definition at line 256 of file confbridge_manager.c.

Referenced by manager_confbridge_init(), and manager_confbridge_shutdown().

channel_state_router

struct stasis_message_router* channel_state_router

static

Definition at line 257 of file confbridge_manager.c.

Referenced by manager_confbridge_init(), and manager_confbridge_shutdown().