res_stasis: Enable transfers and provide events when they occur.

This change enables transfers within ARI created bridges and adds events
for when they occur. Unlike other events these will be received if *any*
subscribed object is involved in the transfer.

(closes issue ASTERISK-22984)
Reported by: David M. Lee

Review: https://reviewboard.asterisk.org/r/3120/
........

Merged revisions 407153 from http://svn.asterisk.org/svn/asterisk/branches/12


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@407154 65c4cc65-6c06-0410-ace0-fbb531ad65f3

1 files changed, 151 insertions, 2 deletions

diff --git a/main/stasis_bridges.c b/main/stasis_bridges.c
index b8d4ae8e1..eb020163d 100644
--- a/main/stasis_bridges.c
+++ b/main/stasis_bridges.c
@@ -133,7 +133,11 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 	</managerEvent>
  ***/
 
+static struct ast_json *attended_transfer_to_json(struct stasis_message *msg,
+	const struct stasis_message_sanitizer *sanitize);
 static struct ast_manager_event_blob *attended_transfer_to_ami(struct stasis_message *message);
+static struct ast_json *blind_transfer_to_json(struct stasis_message *msg,
+	const struct stasis_message_sanitizer *sanitize);
 static struct ast_manager_event_blob *blind_transfer_to_ami(struct stasis_message *message);
 static struct ast_json *ast_channel_entered_bridge_to_json(
 	struct stasis_message *msg,
@@ -157,8 +161,12 @@ STASIS_MESSAGE_TYPE_DEFN(ast_channel_entered_bridge_type,
 	.to_json = ast_channel_entered_bridge_to_json);
 STASIS_MESSAGE_TYPE_DEFN(ast_channel_left_bridge_type,
 	.to_json = ast_channel_left_bridge_to_json);
-STASIS_MESSAGE_TYPE_DEFN(ast_blind_transfer_type, .to_ami = blind_transfer_to_ami);
-STASIS_MESSAGE_TYPE_DEFN(ast_attended_transfer_type, .to_ami = attended_transfer_to_ami);
+STASIS_MESSAGE_TYPE_DEFN(ast_blind_transfer_type,
+	.to_json = blind_transfer_to_json,
+	.to_ami = blind_transfer_to_ami);
+STASIS_MESSAGE_TYPE_DEFN(ast_attended_transfer_type,
+	.to_json = attended_transfer_to_json,
+	.to_ami = attended_transfer_to_ami);
 /*! @} */
 
 struct stasis_cache *ast_bridge_cache(void)
@@ -614,6 +622,43 @@ static const char *result_strs[] = {
 	[AST_BRIDGE_TRANSFER_SUCCESS] = "Success",
 };
 
+static struct ast_json *blind_transfer_to_json(struct stasis_message *msg,
+	const struct stasis_message_sanitizer *sanitize)
+{
+	struct ast_bridge_blob *blob = stasis_message_data(msg);
+	struct ast_json *json_channel, *out;
+	const struct timeval *tv = stasis_message_timestamp(msg);
+
+	json_channel = ast_channel_snapshot_to_json(blob->channel, sanitize);
+	if (!json_channel) {
+		return NULL;
+	}
+
+	out = ast_json_pack("{s: s, s: o, s: o, s: O, s: O, s: s, s: o}",
+		"type", "BridgeBlindTransfer",
+		"timestamp", ast_json_timeval(*tv, NULL),
+		"channel", json_channel,
+		"exten", ast_json_object_get(blob->blob, "exten"),
+		"context", ast_json_object_get(blob->blob, "context"),
+		"result", result_strs[ast_json_integer_get(ast_json_object_get(blob->blob, "result"))],
+		"is_external", ast_json_boolean(ast_json_integer_get(ast_json_object_get(blob->blob, "is_external"))));
+
+	if (!out) {
+		return NULL;
+	}
+
+	if (blob->bridge) {
+		struct ast_json *json_bridge = ast_bridge_snapshot_to_json(blob->bridge, sanitize);
+
+		if (!json_bridge || ast_json_object_set(out, "bridge", json_bridge)) {
+			ast_json_unref(out);
+			return NULL;
+		}
+	}
+
+	return out;
+}
+
 static struct ast_manager_event_blob *blind_transfer_to_ami(struct stasis_message *msg)
 {
 	RAII_VAR(struct ast_str *, channel_state, NULL, ast_free_ptr);
@@ -685,6 +730,110 @@ void ast_bridge_publish_blind_transfer(int is_external, enum ast_transfer_result
 	stasis_publish(ast_bridge_topic_all(), msg);
 }
 
+static struct ast_json *attended_transfer_to_json(struct stasis_message *msg,
+	const struct stasis_message_sanitizer *sanitize)
+{
+	struct ast_attended_transfer_message *transfer_msg = stasis_message_data(msg);
+	RAII_VAR(struct ast_json *, out, NULL, ast_json_unref);
+	struct ast_json *json_transferer1, *json_transferer2, *json_bridge, *json_channel;
+	const struct timeval *tv = stasis_message_timestamp(msg);
+	int res = 0;
+
+	json_transferer1 = ast_channel_snapshot_to_json(transfer_msg->to_transferee.channel_snapshot, sanitize);
+	if (!json_transferer1) {
+		return NULL;
+	}
+
+	json_transferer2 = ast_channel_snapshot_to_json(transfer_msg->to_transfer_target.channel_snapshot, sanitize);
+	if (!json_transferer2) {
+		ast_json_unref(json_transferer1);
+		return NULL;
+	}
+
+	out = ast_json_pack("{s: s, s: o, s: o, s: o, s: s, s: o}",
+		"type", "BridgeAttendedTransfer",
+		"timestamp", ast_json_timeval(*tv, NULL),
+		"transferer_first_leg", json_transferer1,
+		"transferer_second_leg", json_transferer2,
+		"result", result_strs[transfer_msg->result],
+		"is_external", ast_json_boolean(transfer_msg->is_external));
+	if (!out) {
+		return NULL;
+	}
+
+	if (transfer_msg->to_transferee.bridge_snapshot) {
+		json_bridge = ast_bridge_snapshot_to_json(transfer_msg->to_transferee.bridge_snapshot, sanitize);
+
+		if (!json_bridge) {
+			return NULL;
+		}
+
+		res |= ast_json_object_set(out, "transferer_first_leg_bridge", json_bridge);
+	}
+
+	if (transfer_msg->to_transfer_target.bridge_snapshot) {
+		json_bridge = ast_bridge_snapshot_to_json(transfer_msg->to_transfer_target.bridge_snapshot, sanitize);
+
+		if (!json_bridge) {
+			return NULL;
+		}
+
+		res |= ast_json_object_set(out, "transferer_second_leg_bridge", json_bridge);
+	}
+
+	switch (transfer_msg->dest_type) {
+	case AST_ATTENDED_TRANSFER_DEST_BRIDGE_MERGE:
+		res |= ast_json_object_set(out, "destination_type", ast_json_string_create("bridge"));
+		res |= ast_json_object_set(out, "destination_bridge", ast_json_string_create(transfer_msg->dest.bridge));
+		break;
+	case AST_ATTENDED_TRANSFER_DEST_APP:
+		res |= ast_json_object_set(out, "destination_type", ast_json_string_create("application"));
+		res |= ast_json_object_set(out, "destination_application", ast_json_string_create(transfer_msg->dest.app));
+		break;
+	case AST_ATTENDED_TRANSFER_DEST_LINK:
+		res |= ast_json_object_set(out, "destination_type", ast_json_string_create("link"));
+
+		json_channel = ast_channel_snapshot_to_json(transfer_msg->dest.links[0], sanitize);
+		if (!json_channel) {
+			return NULL;
+		}
+		res |= ast_json_object_set(out, "destination_link_first_leg", json_channel);
+
+		json_channel = ast_channel_snapshot_to_json(transfer_msg->dest.links[1], sanitize);
+		if (!json_channel) {
+			return NULL;
+		}
+		res |= ast_json_object_set(out, "destination_link_second_leg", json_channel);
+
+		break;
+	case AST_ATTENDED_TRANSFER_DEST_THREEWAY:
+		res |= ast_json_object_set(out, "destination_type", ast_json_string_create("threeway"));
+
+		json_channel = ast_channel_snapshot_to_json(transfer_msg->dest.threeway.channel_snapshot, sanitize);
+		if (!json_channel) {
+			return NULL;
+		}
+		res |= ast_json_object_set(out, "destination_threeway_channel", json_channel);
+
+		json_bridge = ast_bridge_snapshot_to_json(transfer_msg->dest.threeway.bridge_snapshot, sanitize);
+		if (!json_bridge) {
+			return NULL;
+		}
+		res |= ast_json_object_set(out, "destination_threeway_bridge", json_bridge);
+
+		break;
+	case AST_ATTENDED_TRANSFER_DEST_FAIL:
+		res |= ast_json_object_set(out, "destination_type", ast_json_string_create("fail"));
+		break;
+	}
+
+	if (res) {
+		return NULL;
+	}
+
+	return ast_json_ref(out);
+}
+
 static struct ast_manager_event_blob *attended_transfer_to_ami(struct stasis_message *msg)
 {
 	RAII_VAR(struct ast_str *, variable_data, ast_str_create(64), ast_free_ptr);