FS-10820 [mod_kazoo] eventstream configuration

src/mod/event_handlers/mod_kazoo/Makefile.am

@@ -3,12 +3,29 @@ MODNAME=mod_kazoo
 
 if HAVE_ERLANG
 
+KAZOO_DEFS=kazoo_definitions.o
+
 mod_LTLIBRARIES = mod_kazoo.la
-mod_kazoo_la_SOURCES  = mod_kazoo.c kazoo_utils.c kazoo_node.c kazoo_event_stream.c kazoo_fetch_agent.c kazoo_commands.c kazoo_dptools.c
+mod_kazoo_la_SOURCES  = mod_kazoo.c kazoo_utils.c kazoo_dptools.c kazoo_tweaks.c
+mod_kazoo_la_SOURCES  += kazoo_api.c kazoo_commands.c kazoo_config.c
+mod_kazoo_la_SOURCES  += kazoo_message.c
+mod_kazoo_la_SOURCES  += kazoo_ei_config.c kazoo_ei_utils.c kazoo_event_stream.c
+mod_kazoo_la_SOURCES  += kazoo_fetch_agent.c kazoo_node.c
+
 mod_kazoo_la_CFLAGS   = $(AM_CFLAGS) @ERLANG_CFLAGS@ -D_REENTRANT
-mod_kazoo_la_LIBADD   = $(switch_builddir)/libfreeswitch.la
+mod_kazoo_la_LIBADD   = $(KAZOO_DEFS) $(switch_builddir)/libfreeswitch.la
 mod_kazoo_la_LDFLAGS  = -avoid-version -module -no-undefined -shared @ERLANG_LDFLAGS@
 
+BUILT_SOURCES = $(KAZOO_DEFS)
+
+$(KAZOO_DEFS): kazoo.conf.xml
+
+.S.o: $<
+	@$(CC) $(CFLAGS) -o $@ -c $<
+
+install-exec-am:
+	@install `which epmd` $(DESTDIR)$(bindir)/fs_epmd
+
 else
 install: error
 all: error

src/mod/event_handlers/mod_kazoo/kazoo_commands.c

@@ -31,6 +31,7 @@
  *
  */
 #include "mod_kazoo.h"
+#include <curl/curl.h>
 #include <switch_curl.h>
 
 #define UUID_SET_DESC "Set a variable"
@@ -42,7 +43,49 @@
 #define KZ_HTTP_PUT_DESC "upload a local freeswitch file to a url"
 #define KZ_HTTP_PUT_SYNTAX "localfile url"
 
-SWITCH_STANDARD_API(uuid_setvar_function) {
+#define KZ_FIRST_OF_DESC "returns first-of existing event header in params"
+#define KZ_FIRST_OF_SYNTAX "list of headers to check"
+
+#define MAX_FIRST_OF 25
+
+SWITCH_STANDARD_API(kz_first_of) {
+	char delim = '|';
+	char *mycmd = NULL, *argv[MAX_FIRST_OF] = { 0 };
+	int n, argc = 0;
+	switch_event_header_t *header = NULL;
+	if (!zstr(cmd) && (mycmd = strdup(cmd))) {
+		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG1, "FIRST-OF %s\n", mycmd);
+		if (!zstr(mycmd) && *mycmd == '^' && *(mycmd+1) == '^') {
+			mycmd += 2;
+			delim = *mycmd++;
+		}
+		argc = switch_separate_string(mycmd, delim, argv, (sizeof(argv) / sizeof(argv[0])));
+		for(n=0; n < argc; n++) {
+			char* item = argv[n];
+			if(*item == '#') {
+				if(*(++item) != '\0') {
+					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG1, "RETURNING default %s\n", item);
+					stream->write_function(stream, item);
+					break;
+				}
+			} else {
+				switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG1, "CHECKING %s\n", item);
+				header = switch_event_get_header_ptr(stream->param_event, item);
+				if(header) {
+					switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG1, "RETURNING %s : %s\n", item, header->value);
+					stream->write_function(stream, header->value);
+					break;
+				}
+			}
+		}
+	}
+
+	switch_safe_free(mycmd);
+	return SWITCH_STATUS_SUCCESS;
+}
+
+switch_status_t kz_uuid_setvar(int urldecode, const char *cmd,  switch_core_session_t *session,  switch_stream_handle_t *stream)
+{
 	switch_core_session_t *psession = NULL;
 	char *mycmd = NULL, *argv[3] = { 0 };
 	int argc = 0;
@@ -67,7 +110,11 @@ SWITCH_STANDARD_API(uuid_setvar_function) {
 					switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "No variable name specified.\n");
 					stream->write_function(stream, "-ERR No variable specified\n");
 				} else {
+					if(urldecode) {
+						switch_url_decode(var_value);
+					}
 					switch_channel_set_variable(channel, var_name, var_value);
+					kz_check_set_profile_var(channel, var_name, var_value);
 					stream->write_function(stream, "+OK\n");
 				}
 
@@ -92,8 +139,20 @@ SWITCH_STANDARD_API(uuid_setvar_function) {
 	return SWITCH_STATUS_SUCCESS;
 }
 
-SWITCH_STANDARD_API(uuid_setvar_multi_function) {
+SWITCH_STANDARD_API(uuid_setvar_function)
+{
+	return kz_uuid_setvar(0, cmd, session, stream);
+}
+
+SWITCH_STANDARD_API(uuid_setvar_encoded_function)
+{
+	return kz_uuid_setvar(1, cmd, session, stream);
+}
+
+switch_status_t kz_uuid_setvar_multi(int urldecode, const char *cmd,  switch_core_session_t *session,  switch_stream_handle_t *stream)
+{
 	switch_core_session_t *psession = NULL;
+	char delim = ';';
 	char *mycmd = NULL, *vars, *argv[64] = { 0 };
 	int argc = 0;
 	char *var_name, *var_value = NULL;
@@ -104,12 +163,15 @@ SWITCH_STANDARD_API(uuid_setvar_multi_function) {
 			goto done;
 		}
 		*vars++ = '\0';
-
+		if (*vars == '^' && *(vars+1) == '^') {
+			vars += 2;
+			delim = *vars++;
+		}
 		if ((psession = switch_core_session_locate(uuid))) {
 			switch_channel_t *channel = switch_core_session_get_channel(psession);
 			switch_event_t *event;
 			int x, y = 0;
-			argc = switch_separate_string(vars, ';', argv, (sizeof(argv) / sizeof(argv[0])));
+			argc = switch_separate_string(vars, delim, argv, (sizeof(argv) / sizeof(argv[0])));
 
 			for (x = 0; x < argc; x++) {
 				var_name = argv[x];
@@ -120,16 +182,11 @@ SWITCH_STANDARD_API(uuid_setvar_multi_function) {
 					switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "No variable name specified.\n");
 					stream->write_function(stream, "-ERR No variable specified\n");
 				} else {
+					if(urldecode) {
+						switch_url_decode(var_value);
+					}
 					switch_channel_set_variable(channel, var_name, var_value);
-					if (!strcasecmp(var_name, "effective_callee_id_number")) {
-						switch_channel_set_profile_var(channel, "callee_id_number", var_value);
-					} else if (!strcasecmp(var_name, "effective_callee_id_name")) {
-						switch_channel_set_profile_var(channel, "callee_id_name", var_value);
-					} else if (!strcasecmp(var_name, "effective_caller_id_number")) {
-						switch_channel_set_profile_var(channel, "caller_id_number", var_value);
-					} else if (!strcasecmp(var_name, "effective_caller_id_name")) {
-						switch_channel_set_profile_var(channel, "caller_id_name", var_value);
-					};
+					kz_check_set_profile_var(channel, var_name, var_value);
 
 					y++;
 				}
@@ -158,6 +215,21 @@ SWITCH_STANDARD_API(uuid_setvar_multi_function) {
 	return SWITCH_STATUS_SUCCESS;
 }
 
+SWITCH_STANDARD_API(uuid_setvar_multi_function)
+{
+	return kz_uuid_setvar_multi(0, cmd, session, stream);
+}
+
+SWITCH_STANDARD_API(uuid_setvar_multi_encoded_function)
+{
+	return kz_uuid_setvar_multi(1, cmd, session, stream);
+}
+
+static size_t body_callback(char *buffer, size_t size, size_t nitems, void *userdata)
+{
+	return size * nitems;
+}
+
 static size_t header_callback(char *buffer, size_t size, size_t nitems, void *userdata)
 {
 	switch_event_t* event = (switch_event_t*)userdata;
@@ -182,6 +254,7 @@ SWITCH_STANDARD_API(kz_http_put)
 	switch_event_t *params = NULL;
 	char *url = NULL;
 	char *filename = NULL;
+	int delete_file = 0;
 
 	switch_curl_slist_t *headers = NULL;  /* optional linked-list of HTTP headers */
 	char *ext;  /* file extension, used for MIME type identification */
@@ -276,9 +349,12 @@ SWITCH_STANDARD_API(kz_http_put)
 	switch_curl_easy_setopt(curl_handle, CURLOPT_INFILESIZE_LARGE, (curl_off_t)file_info.st_size);
 	switch_curl_easy_setopt(curl_handle, CURLOPT_FOLLOWLOCATION, 1);
 	switch_curl_easy_setopt(curl_handle, CURLOPT_MAXREDIRS, 10);
+	switch_curl_easy_setopt(curl_handle, CURLOPT_FAILONERROR, 1);
 	switch_curl_easy_setopt(curl_handle, CURLOPT_USERAGENT, "freeswitch-http-cache/1.0");
 	switch_curl_easy_setopt(curl_handle, CURLOPT_HEADERDATA, stream->param_event);
 	switch_curl_easy_setopt(curl_handle, CURLOPT_HEADERFUNCTION, header_callback);
+	switch_curl_easy_setopt(curl_handle, CURLOPT_WRITEFUNCTION, body_callback);
+
 	switch_curl_easy_setopt(curl_handle, CURLOPT_SSL_VERIFYPEER, 0L);
 	switch_curl_easy_perform(curl_handle);
 	switch_curl_easy_getinfo(curl_handle, CURLINFO_RESPONSE_CODE, &httpRes);
@@ -286,22 +362,24 @@ SWITCH_STANDARD_API(kz_http_put)
 
 	if (httpRes == 200 || httpRes == 201 || httpRes == 202 || httpRes == 204) {
 		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "%s saved to %s\n", filename, url);
-		switch_event_add_header(stream->param_event, SWITCH_STACK_BOTTOM, "API-Output", "%s saved to %s\n", filename, url);
-		stream->write_function(stream, "+OK\n");
+		switch_event_add_header(stream->param_event, SWITCH_STACK_BOTTOM, "API-Output", "%s saved to %s", filename, url);
+		stream->write_function(stream, "+OK %s saved to %s", filename, url);
+		delete_file = 1;
 	} else {
 		error = switch_mprintf("Received HTTP error %ld trying to save %s to %s", httpRes, filename, url);
 		switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "%s\n", error);
 		switch_event_add_header(stream->param_event, SWITCH_STACK_BOTTOM, "API-Error", "%s", error);
 		switch_event_add_header(stream->param_event, SWITCH_STACK_BOTTOM, "API-HTTP-Error", "%ld", httpRes);
-		stream->write_function(stream, "-ERR ");
-		stream->write_function(stream, error);
-		stream->write_function(stream, "\n");
+		stream->write_function(stream, "-ERR %s", error);
 		status = SWITCH_STATUS_GENERR;
 	}
 
 done:
 	if (file_to_put) {
 		fclose(file_to_put);
+		if(delete_file) {
+			remove(filename);
+		}
 	}
 
 	if (headers) {
@@ -326,9 +404,14 @@ done:
 
 void add_kz_commands(switch_loadable_module_interface_t **module_interface, switch_api_interface_t *api_interface) {
 	SWITCH_ADD_API(api_interface, "kz_uuid_setvar_multi", UUID_SET_DESC, uuid_setvar_multi_function, UUID_MULTISET_SYNTAX);
+	SWITCH_ADD_API(api_interface, "kz_uuid_setvar_multi_encoded", UUID_SET_DESC, uuid_setvar_multi_encoded_function, UUID_MULTISET_SYNTAX);
 	switch_console_set_complete("add kz_uuid_setvar_multi ::console::list_uuid");
+	switch_console_set_complete("add kz_uuid_setvar_multi_encoded ::console::list_uuid");
 	SWITCH_ADD_API(api_interface, "kz_uuid_setvar", UUID_MULTISET_DESC, uuid_setvar_function, UUID_SET_SYNTAX);
+	SWITCH_ADD_API(api_interface, "kz_uuid_setvar_encoded", UUID_MULTISET_DESC, uuid_setvar_encoded_function, UUID_SET_SYNTAX);
 	switch_console_set_complete("add kz_uuid_setvar ::console::list_uuid");
+	switch_console_set_complete("add kz_uuid_setvar_encoded ::console::list_uuid");
 	SWITCH_ADD_API(api_interface, "kz_http_put", KZ_HTTP_PUT_DESC, kz_http_put, KZ_HTTP_PUT_SYNTAX);
+	SWITCH_ADD_API(api_interface, "first-of", KZ_FIRST_OF_DESC, kz_first_of, KZ_FIRST_OF_SYNTAX);
 }
 

src/mod/event_handlers/mod_kazoo/kazoo_config.h

+/*
+* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+* Copyright (C) 2005-2012, Anthony Minessale II <anthm@freeswitch.org>
+*
+* Version: MPL 1.1
+*
+* The contents of this file are subject to the Mozilla Public License Version
+* 1.1 (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+* http://www.mozilla.org/MPL/
+*
+* Software distributed under the License is distributed on an "AS IS" basis,
+* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+* for the specific language governing rights and limitations under the
+* License.
+*
+* The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+*
+* The Initial Developer of the Original Code is
+* Anthony Minessale II <anthm@freeswitch.org>
+* Portions created by the Initial Developer are Copyright (C)
+* the Initial Developer. All Rights Reserved.
+*
+* Based on mod_skel by
+* Anthony Minessale II <anthm@freeswitch.org>
+*
+* Contributor(s):
+*
+* Daniel Bryars <danb@aeriandi.com>
+* Tim Brown <tim.brown@aeriandi.com>
+* Anthony Minessale II <anthm@freeswitch.org>
+* William King <william.king@quentustech.com>
+* Mike Jerris <mike@jerris.com>
+*
+* kazoo.c -- Sends FreeSWITCH events to an AMQP broker
+*
+*/
+
+#ifndef KAZOO_CONFIG_H
+#define KAZOO_CONFIG_H
+
+#include <switch.h>
+
+
+struct kazoo_config_t {
+	  switch_hash_t *hash;
+	  switch_memory_pool_t *pool;
+};
+
+switch_status_t kazoo_config_loglevels(switch_memory_pool_t *pool, switch_xml_t cfg, kazoo_loglevels_ptr *ptr);
+switch_status_t kazoo_config_filters(switch_memory_pool_t *pool, switch_xml_t cfg, kazoo_filter_ptr *ptr);
+switch_status_t kazoo_config_fields(kazoo_config_ptr definitions, switch_memory_pool_t *pool, switch_xml_t cfg, kazoo_fields_ptr *ptr);
+
+switch_status_t kazoo_config_event_handler(kazoo_config_ptr definitions, kazoo_config_ptr root, switch_xml_t cfg, kazoo_event_profile_ptr *ptr);
+switch_status_t kazoo_config_fetch_handler(kazoo_config_ptr definitions, kazoo_config_ptr root, switch_xml_t cfg, kazoo_fetch_profile_ptr *ptr);
+kazoo_config_ptr kazoo_config_event_handlers(kazoo_config_ptr definitions, switch_xml_t cfg);
+kazoo_config_ptr kazoo_config_fetch_handlers(kazoo_config_ptr definitions, switch_xml_t cfg);
+kazoo_config_ptr kazoo_config_definitions(switch_xml_t cfg);
+switch_status_t kazoo_config_field(kazoo_config_ptr definitions, switch_memory_pool_t *pool, switch_xml_t cfg, kazoo_field_ptr *ptr);
+void destroy_config(kazoo_config_ptr *ptr);
+
+#endif /* KAZOO_CONFIG_H */
+

src/mod/event_handlers/mod_kazoo/kazoo_definitions.S

+    .global kz_default_config
+    .global kz_default_config_size
+    .section .rodata
+kz_default_config:
+    .incbin "kazoo.conf.xml"
+1:
+kz_default_config_size:
+    .int 1b - kz_default_config

src/mod/event_handlers/mod_kazoo/kazoo_ei.h

+#ifndef KAZOO_EI_H
+#define KAZOO_EI_H
+
+#include <switch.h>
+#include <ei.h>
+
+#define MODNAME "mod_kazoo"
+#define BUNDLE "community"
+#define RELEASE "v1.5.0-1"
+#define VERSION "mod_kazoo v1.5.0-1 community"
+
+#define KZ_MAX_SEPARATE_STRINGS 10
+
+typedef enum {KAZOO_FETCH_PROFILE, KAZOO_EVENT_PROFILE} kazoo_profile_type;
+
+typedef enum {ERLANG_TUPLE, ERLANG_MAP} kazoo_json_term;
+
+typedef struct ei_xml_agent_s ei_xml_agent_t;
+typedef ei_xml_agent_t *ei_xml_agent_ptr;
+
+typedef struct kazoo_event kazoo_event_t;
+typedef kazoo_event_t *kazoo_event_ptr;
+
+typedef struct kazoo_event_profile kazoo_event_profile_t;
+typedef kazoo_event_profile_t *kazoo_event_profile_ptr;
+
+typedef struct kazoo_fetch_profile kazoo_fetch_profile_t;
+typedef kazoo_fetch_profile_t *kazoo_fetch_profile_ptr;
+
+typedef struct kazoo_config_t kazoo_config;
+typedef kazoo_config *kazoo_config_ptr;
+
+#include "kazoo_fields.h"
+#include "kazoo_config.h"
+
+struct ei_send_msg_s {
+	ei_x_buff buf;
+	erlang_pid pid;
+};
+typedef struct ei_send_msg_s ei_send_msg_t;
+
+struct ei_received_msg_s {
+	ei_x_buff buf;
+	erlang_msg msg;
+};
+typedef struct ei_received_msg_s ei_received_msg_t;
+
+
+typedef struct ei_event_stream_s ei_event_stream_t;
+typedef struct ei_node_s ei_node_t;
+
+struct ei_event_binding_s {
+	char id[SWITCH_UUID_FORMATTED_LENGTH + 1];
+	switch_event_node_t *node;
+	switch_event_types_t type;
+	const char *subclass_name;
+	ei_event_stream_t* stream;
+	kazoo_event_ptr event;
+
+	struct ei_event_binding_s *next;
+};
+typedef struct ei_event_binding_s ei_event_binding_t;
+
+struct ei_event_stream_s {
+	switch_memory_pool_t *pool;
+	ei_event_binding_t *bindings;
+	switch_queue_t *queue;
+	switch_socket_t *acceptor;
+	switch_pollset_t *pollset;
+	switch_pollfd_t *pollfd;
+	switch_socket_t *socket;
+	switch_mutex_t *socket_mutex;
+	switch_bool_t connected;
+	char remote_ip[48];
+	uint16_t remote_port;
+	char local_ip[48];
+	uint16_t local_port;
+	erlang_pid pid;
+	uint32_t flags;
+	ei_node_t *node;
+	short event_stream_framing;
+	struct ei_event_stream_s *next;
+};
+
+struct ei_node_s {
+	int nodefd;
+	switch_atomic_t pending_bgapi;
+	switch_atomic_t receive_handlers;
+	switch_memory_pool_t *pool;
+	ei_event_stream_t *event_streams;
+	switch_mutex_t *event_streams_mutex;
+	switch_queue_t *send_msgs;
+	switch_queue_t *received_msgs;
+	char *peer_nodename;
+	switch_time_t created_time;
+	switch_socket_t *socket;
+	char remote_ip[48];
+	uint16_t remote_port;
+	char local_ip[48];
+	uint16_t local_port;
+	uint32_t flags;
+	int legacy;
+	short event_stream_framing;
+	struct ei_node_s *next;
+};
+
+
+struct xml_fetch_reply_s {
+	char uuid_str[SWITCH_UUID_FORMATTED_LENGTH + 1];
+	char *xml_str;
+	struct xml_fetch_reply_s *next;
+};
+typedef struct xml_fetch_reply_s xml_fetch_reply_t;
+
+struct fetch_handler_s {
+	erlang_pid pid;
+	struct fetch_handler_s *next;
+};
+typedef struct fetch_handler_s fetch_handler_t;
+
+struct ei_xml_client_s {
+	ei_node_t *ei_node;
+	fetch_handler_t *fetch_handlers;
+	struct ei_xml_client_s *next;
+};
+typedef struct ei_xml_client_s ei_xml_client_t;
+
+struct ei_xml_agent_s {
+	switch_memory_pool_t *pool;
+	switch_xml_section_t section;
+	switch_thread_rwlock_t *lock;
+	ei_xml_client_t *clients;
+	switch_mutex_t *current_client_mutex;
+	ei_xml_client_t *current_client;
+	switch_mutex_t *replies_mutex;
+	switch_thread_cond_t *new_reply;
+	xml_fetch_reply_t *replies;
+	kazoo_fetch_profile_ptr profile;
+
+};
+
+struct globals_s {
+	switch_memory_pool_t *pool;
+	switch_atomic_t threads;
+	switch_socket_t *acceptor;
+	struct ei_cnode_s ei_cnode;
+	switch_thread_rwlock_t *ei_nodes_lock;
+	ei_node_t *ei_nodes;
+
+	switch_xml_binding_t *config_fetch_binding;
+	switch_xml_binding_t *directory_fetch_binding;
+	switch_xml_binding_t *dialplan_fetch_binding;
+	switch_xml_binding_t *channels_fetch_binding;
+	switch_xml_binding_t *languages_fetch_binding;
+	switch_xml_binding_t *chatplan_fetch_binding;
+
+	switch_hash_t *event_filter;
+	int epmdfd;
+	int num_worker_threads;
+	switch_bool_t nat_map;
+	switch_bool_t ei_shortname;
+	int ei_compat_rel;
+	char *ip;
+	char *hostname;
+	char *ei_cookie;
+	char *ei_nodename;
+//	char *kazoo_var_prefix;
+//	int var_prefix_length;
+	uint32_t flags;
+	int send_all_headers;
+	int send_all_private_headers;
+	int connection_timeout;
+	int receive_timeout;
+	int receive_msg_preallocate;
+	int event_stream_preallocate;
+	int send_msg_batch;
+	short event_stream_framing;
+	switch_port_t port;
+	int config_fetched;
+	int io_fault_tolerance;
+	kazoo_event_profile_ptr events;
+	kazoo_config_ptr definitions;
+	kazoo_config_ptr event_handlers;
+	kazoo_config_ptr fetch_handlers;
+	kazoo_json_term  json_encoding;
+
+	int enable_legacy;
+//	char *profile_vars_prefixes[KZ_MAX_SEPARATE_STRINGS];
+//	char *kazoo_var_prefixes[KZ_MAX_SEPARATE_STRINGS];
+//	char *profile_vars_prefixes;
+//	char *kazoo_var_prefixes;
+	char **profile_vars_prefixes;
+	char **kazoo_var_prefixes;
+
+};
+typedef struct globals_s globals_t;
+extern globals_t kazoo_globals;
+
+/* kazoo_event_stream.c */
+ei_event_stream_t *find_event_stream(ei_event_stream_t *event_streams, const erlang_pid *from);
+
+//ei_event_stream_t *new_event_stream(ei_event_stream_t **event_streams, const erlang_pid *from);
+ei_event_stream_t *new_event_stream(ei_node_t *ei_node, const erlang_pid *from);
+
+
+switch_status_t remove_event_stream(ei_event_stream_t **event_streams, const erlang_pid *from);
+switch_status_t remove_event_streams(ei_event_stream_t **event_streams);
+unsigned long get_stream_port(const ei_event_stream_t *event_stream);
+switch_status_t add_event_binding(ei_event_stream_t *event_stream, const char *event_name);
+//switch_status_t add_event_binding(ei_event_stream_t *event_stream, const switch_event_types_t event_type, const char *subclass_name);
+switch_status_t remove_event_binding(ei_event_stream_t *event_stream, const switch_event_types_t event_type, const char *subclass_name);
+switch_status_t remove_event_bindings(ei_event_stream_t *event_stream);
+
+/* kazoo_node.c */
+switch_status_t new_kazoo_node(int nodefd, ErlConnect *conn);
+
+/* kazoo_ei_utils.c */
+void close_socket(switch_socket_t **sock);
+void close_socketfd(int *sockfd);
+switch_socket_t *create_socket_with_port(switch_memory_pool_t *pool, switch_port_t port);
+switch_socket_t *create_socket(switch_memory_pool_t *pool);
+switch_status_t create_ei_cnode(const char *ip_addr, const char *name, struct ei_cnode_s *ei_cnode);
+switch_status_t ei_compare_pids(const erlang_pid *pid1, const erlang_pid *pid2);
+void ei_encode_switch_event_headers(ei_x_buff *ebuf, switch_event_t *event);
+void ei_encode_switch_event_headers_2(ei_x_buff *ebuf, switch_event_t *event, int decode);
+void ei_encode_json(ei_x_buff *ebuf, cJSON *JObj);
+void ei_link(ei_node_t *ei_node, erlang_pid * from, erlang_pid * to);
+void ei_encode_switch_event(ei_x_buff * ebuf, switch_event_t *event);
+int ei_helper_send(ei_node_t *ei_node, erlang_pid* to, ei_x_buff *buf);
+int ei_decode_atom_safe(char *buf, int *index, char *dst);
+int ei_decode_string_or_binary_limited(char *buf, int *index, int maxsize, char *dst);
+int ei_decode_string_or_binary(char *buf, int *index, char **dst);
+switch_status_t create_acceptor();
+switch_hash_t *create_default_filter();
+
+void fetch_config();
+
+switch_status_t kazoo_load_config();
+void kazoo_destroy_config();
+
+
+#define _ei_x_encode_string(buf, string) { ei_x_encode_binary(buf, string, strlen(string)); }
+
+/* kazoo_fetch_agent.c */
+switch_status_t bind_fetch_agents();
+switch_status_t unbind_fetch_agents();
+switch_status_t remove_xml_clients(ei_node_t *ei_node);
+switch_status_t add_fetch_handler(ei_node_t *ei_node, erlang_pid *from, switch_xml_binding_t *binding);
+switch_status_t remove_fetch_handlers(ei_node_t *ei_node, erlang_pid *from);
+switch_status_t fetch_reply(char *uuid_str, char *xml_str, switch_xml_binding_t *binding);
+switch_status_t handle_api_command_streams(ei_node_t *ei_node, switch_stream_handle_t *stream);
+
+void bind_event_profiles(kazoo_event_ptr event);
+void rebind_fetch_profiles(kazoo_config_ptr fetch_handlers);
+switch_status_t kazoo_config_handlers(switch_xml_t cfg);
+
+/* runtime */
+SWITCH_MODULE_RUNTIME_FUNCTION(mod_kazoo_runtime);
+
+#endif /* KAZOO_EI_H */
+
+/* For Emacs:
+ * Local Variables:
+ * mode:c
+ * indent-tabs-mode:t
+ * tab-width:4
+ * c-basic-offset:4
+ * End:
+ * For VIM:
+ * vim:set softtabstop=4 shiftwidth=4 tabstop=4:
+ */

src/mod/event_handlers/mod_kazoo/kazoo_message.h

+/*
+* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+* Copyright (C) 2005-2012, Anthony Minessale II <anthm@freeswitch.org>
+*
+* Version: MPL 1.1
+*
+* The contents of this file are subject to the Mozilla Public License Version
+* 1.1 (the "License"); you may not use this file except in compliance with
+* the License. You may obtain a copy of the License at
+* http://www.mozilla.org/MPL/
+*
+* Software distributed under the License is distributed on an "AS IS" basis,
+* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License
+* for the specific language governing rights and limitations under the
+* License.
+*
+* The Original Code is FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
+*
+* The Initial Developer of the Original Code is
+* Anthony Minessale II <anthm@freeswitch.org>
+* Portions created by the Initial Developer are Copyright (C)
+* the Initial Developer. All Rights Reserved.
+*
+* Based on mod_skel by
+* Anthony Minessale II <anthm@freeswitch.org>
+*
+* Contributor(s):
+*
+* Daniel Bryars <danb@aeriandi.com>
+* Tim Brown <tim.brown@aeriandi.com>
+* Anthony Minessale II <anthm@freeswitch.org>
+* William King <william.king@quentustech.com>
+* Mike Jerris <mike@jerris.com>
+*
+* kazoo.c -- Sends FreeSWITCH events to an AMQP broker
+*
+*/
+
+#ifndef KAZOO_MESSAGE_H
+#define KAZOO_MESSAGE_H
+
+#include <switch.h>
+
+typedef struct {
+    uint64_t timestamp;
+    uint64_t start;
+    uint64_t filter;
+    uint64_t serialize;
+    uint64_t print;
+    uint64_t rk;
+} kazoo_message_times_t, *kazoo_message_times_ptr;
+
+typedef struct {
+    cJSON *JObj;
+} kazoo_message_t, *kazoo_message_ptr;
+
+void kazoo_cJSON_AddItemToObject(cJSON *object, const char *string, cJSON *item);
+cJSON * kazoo_event_add_field_to_json(cJSON *dst, switch_event_t *src, kazoo_field_ptr field);
+kazoo_message_ptr kazoo_message_create_event(switch_event_t* evt, kazoo_event_ptr event, kazoo_event_profile_ptr profile);
+kazoo_message_ptr kazoo_message_create_fetch(switch_event_t* evt, kazoo_fetch_profile_ptr profile);
+
+void kazoo_message_destroy(kazoo_message_ptr *msg);
+
+
+#endif /* KAZOO_MESSAGE_H */
+