stasis_system.c

/*
 * Asterisk -- An open source telephony toolkit.
 *
 * Copyright (C) 2013, Digium, Inc.
 *
 * Jason Parker <jparker@digium.com>
 *
 * See http://www.asterisk.org for more information about
 * the Asterisk project. Please do not directly contact
 * any of the maintainers of this project for assistance;
 * the project provides a web site, mailing lists and IRC
 * channels for your use.
 *
 * This program is free software, distributed under the terms of
 * the GNU General Public License Version 2. See the LICENSE file
 * at the top of the source tree.
 */

/*! \file
 *
 * \brief Stasis Messages and Data Types for System events
 *
 * \author Jason Parker <jparker@digium.com>
 */

/*** MODULEINFO
	<support_level>core</support_level>
 ***/

#include "asterisk.h"

#include "asterisk/astobj2.h"
#include "asterisk/stasis.h"
#include "asterisk/stasis_system.h"

/*** DOCUMENTATION
	<managerEvent language="en_US" name="Registry">
		<managerEventInstance class="EVENT_FLAG_SYSTEM">
			<synopsis>Raised when an outbound registration completes.</synopsis>
			<syntax>
				<parameter name="ChannelType">
					<para>The type of channel that was registered (or not).</para>
				</parameter>
				<parameter name="Username">
					<para>The username portion of the registration.</para>
				</parameter>
				<parameter name="Domain">
					<para>The address portion of the registration.</para>
				</parameter>
				<parameter name="Status">
					<para>The status of the registration request.</para>
					<enumlist>
						<enum name="Registered"/>
						<enum name="Unregistered"/>
						<enum name="Rejected"/>
						<enum name="Failed"/>
					</enumlist>
				</parameter>
				<parameter name="Cause">
					<para>What caused the rejection of the request, if available.</para>
				</parameter>
			</syntax>
		</managerEventInstance>
	</managerEvent>
 ***/

/*! \brief The \ref stasis topic for system level changes */
static struct stasis_topic *system_topic;

static struct ast_manager_event_blob *system_registry_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_available_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_offertimerstart_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_requested_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_requestacknowledged_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_callerstopmonitoring_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_callerstartmonitoring_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_callerrecalling_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_recallcomplete_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_failure_to_ami(struct stasis_message *message);
static struct ast_manager_event_blob *cc_monitorfailed_to_ami(struct stasis_message *message);

STASIS_MESSAGE_TYPE_DEFN(ast_network_change_type);
STASIS_MESSAGE_TYPE_DEFN(ast_system_registry_type,
	.to_ami = system_registry_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_available_type,
	.to_ami = cc_available_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_offertimerstart_type,
	.to_ami = cc_offertimerstart_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_requested_type,
	.to_ami = cc_requested_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_requestacknowledged_type,
	.to_ami = cc_requestacknowledged_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_callerstopmonitoring_type,
	.to_ami = cc_callerstopmonitoring_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_callerstartmonitoring_type,
	.to_ami = cc_callerstartmonitoring_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_callerrecalling_type,
	.to_ami = cc_callerrecalling_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_recallcomplete_type,
	.to_ami = cc_recallcomplete_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_failure_type,
	.to_ami = cc_failure_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cc_monitorfailed_type,
	.to_ami = cc_monitorfailed_to_ami,
	);
STASIS_MESSAGE_TYPE_DEFN(ast_cluster_discovery_type);

void ast_system_publish_registry(const char *channeltype, const char *username, const char *domain, const char *status, const char *cause)
{
	struct ast_json *registry;
	struct ast_json_payload *payload;
	struct stasis_message *message;

	if (!ast_system_registry_type()) {
		return;
	}

	registry = ast_json_pack("{s: s, s: s, s: s, s: s, s: s, s: s}",
		"type", "registry",
		"channeltype", channeltype,
		"username", username,
		"domain", domain,
		"status", status,
		"cause", S_OR(cause, ""));

	payload = ast_json_payload_create(registry);
	ast_json_unref(registry);
	if (!payload) {
		return;
	}

	message = stasis_message_create(ast_system_registry_type(), payload);
	ao2_ref(payload, -1);
	if (!message) {
		return;
	}

	stasis_publish(ast_system_topic(), message);
	ao2_ref(message, -1);
}

static struct ast_manager_event_blob *system_registry_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	const char *channeltype;
	const char *username;
	const char *domain;
	const char *status;
	const char *cause;
	RAII_VAR(struct ast_str *, cause_string, ast_str_create(32), ast_free);

	if (!cause_string) {
		return NULL;
	}

	channeltype = ast_json_string_get(ast_json_object_get(payload->json, "channeltype"));
	username = ast_json_string_get(ast_json_object_get(payload->json, "username"));
	domain = ast_json_string_get(ast_json_object_get(payload->json, "domain"));
	status = ast_json_string_get(ast_json_object_get(payload->json, "status"));
	cause = ast_json_string_get(ast_json_object_get(payload->json, "cause"));

	if (!ast_strlen_zero(cause)) {
		ast_str_set(&cause_string, 0, "Cause: %s\r\n", cause);
	}

	return ast_manager_event_blob_create(EVENT_FLAG_SYSTEM, "Registry",
		"ChannelType: %s\r\n"
		"Username: %s\r\n"
		"Domain: %s\r\n"
		"Status: %s\r\n"
		"%s",
		channeltype, username, domain, status, ast_str_buffer(cause_string));
}

static struct ast_manager_event_blob *cc_available_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *callee;
	const char *service;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	callee = ast_json_string_get(ast_json_object_get(payload->json, "callee"));
	service = ast_json_string_get(ast_json_object_get(payload->json, "service"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCAvailable",
		"CoreID: %d\r\n"
		"Callee: %s\r\n"
		"Service: %s\r\n",
		core_id, callee, service);
}

static struct ast_manager_event_blob *cc_offertimerstart_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;
	unsigned int expires;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));
	expires = ast_json_integer_get(ast_json_object_get(payload->json, "expires"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCOfferTimerStart",
		"CoreID: %d\r\n"
		"Caller: %s\r\n"
		"Expires: %u\r\n",
		core_id, caller, expires);
}

static struct ast_manager_event_blob *cc_requested_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;
	const char *callee;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));
	callee = ast_json_string_get(ast_json_object_get(payload->json, "callee"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCRequested",
		"CoreID: %d\r\n"
		"Caller: %s\r\n"
		"Callee: %s\r\n",
		core_id, caller, callee);
}

static struct ast_manager_event_blob *cc_requestacknowledged_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCRequestAcknowledged",
		"CoreID: %d\r\n"
		"Caller: %s\r\n",
		core_id, caller);
}

static struct ast_manager_event_blob *cc_callerstopmonitoring_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCCallerStopMonitoring",
		"CoreID: %d\r\n"
		"Caller: %s\r\n",
		core_id, caller);
}

static struct ast_manager_event_blob *cc_callerstartmonitoring_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCCallerStartMonitoring",
		"CoreID: %d\r\n"
		"Caller: %s\r\n",
		core_id, caller);
}

static struct ast_manager_event_blob *cc_callerrecalling_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCCallerRecalling",
		"CoreID: %d\r\n"
		"Caller: %s\r\n",
		core_id, caller);
}

static struct ast_manager_event_blob *cc_recallcomplete_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCRecallComplete",
		"CoreID: %d\r\n"
		"Caller: %s\r\n",
		core_id, caller);
}

static struct ast_manager_event_blob *cc_failure_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *caller;
	const char *reason;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	caller = ast_json_string_get(ast_json_object_get(payload->json, "caller"));
	reason = ast_json_string_get(ast_json_object_get(payload->json, "reason"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCFailure",
		"CoreID: %d\r\n"
		"Caller: %s\r\n"
		"Reason: %s\r\n",
		core_id, caller, reason);
}

static struct ast_manager_event_blob *cc_monitorfailed_to_ami(struct stasis_message *message)
{
	struct ast_json_payload *payload = stasis_message_data(message);
	int core_id;
	const char *callee;

	core_id = ast_json_integer_get(ast_json_object_get(payload->json, "core_id"));
	callee = ast_json_string_get(ast_json_object_get(payload->json, "callee"));

	return ast_manager_event_blob_create(EVENT_FLAG_CC, "CCMonitorFailed",
		"CoreID: %d\r\n"
		"Callee: %s\r\n",
		core_id, callee);
}

struct stasis_topic *ast_system_topic(void)
{
	return system_topic;
}

/*! \brief Cleanup the \ref stasis system level items */
static void stasis_system_cleanup(void)
{
	ao2_cleanup(system_topic);
	system_topic = NULL;
	STASIS_MESSAGE_TYPE_CLEANUP(ast_network_change_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_system_registry_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_available_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_offertimerstart_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_requested_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_requestacknowledged_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_callerstopmonitoring_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_callerstartmonitoring_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_callerrecalling_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_recallcomplete_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_failure_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cc_monitorfailed_type);
	STASIS_MESSAGE_TYPE_CLEANUP(ast_cluster_discovery_type);
}

/*! \brief Initialize the system level items for \ref stasis */
int ast_stasis_system_init(void)
{
	ast_register_cleanup(stasis_system_cleanup);

	system_topic = stasis_topic_create("system:all");
	if (!system_topic) {
		return 1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_network_change_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_system_registry_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_available_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_offertimerstart_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_requested_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_requestacknowledged_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerstopmonitoring_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerstartmonitoring_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_callerrecalling_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_recallcomplete_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_failure_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cc_monitorfailed_type) != 0) {
		return -1;
	}

	if (STASIS_MESSAGE_TYPE_INIT(ast_cluster_discovery_type) != 0) {
		return -1;
	}

	return 0;
}