+++ /dev/null
-/*
- * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
- * Copyright (C) 2005/2006, Anthony Minessale II <anthmct@yahoo.com>
- *
- * 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 <anthmct@yahoo.com>
- * Portions created by the Initial Developer are Copyright (C)
- * the Initial Developer. All Rights Reserved.
- *
- * Contributor(s):
- *
- * Anthony Minessale II <anthmct@yahoo.com>
- *
- *
- * mod_xmpp_event.c -- XMPP Event Logger
- *
- */
-#include <switch.h>
-#include <iksemel.h>
-
-SWITCH_MODULE_LOAD_FUNCTION(mod_xmpp_event_load);
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xmpp_event_shutdown);
-SWITCH_MODULE_RUNTIME_FUNCTION(mod_xmpp_event_runtime);
-SWITCH_MODULE_DEFINITION(mod_xmpp_event, mod_xmpp_event_load, mod_xmpp_event_shutdown, mod_xmpp_event_runtime);
-
-static int RUNNING = 0;
-static iksfilter *my_filter;
-static int opt_timeout = 30;
-static int opt_use_tls = 0;
-
-/* stuff we keep per session */
-struct session {
- iksparser *parser;
- iksid *acc;
- char *pass;
- int features;
- int authorized;
- int counter;
- int job_done;
-};
-
-static struct {
- char *jid;
- char *passwd;
- char *target_jid;
- int debug;
- struct session session;
-} globals;
-
-static void event_handler(switch_event_t *event)
-{
- char *buf;
- iks *msg;
- int loops = 0;
-
- if (!RUNNING) {
- return;
- }
-
- while (!globals.session.authorized) {
- switch_yield(100000);
- if (loops++ > 5) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Nothing to do with this Event!\n");
- return;
- }
- }
-
- switch (event->event_id) {
- default:
- switch_event_serialize(event, &buf);
- //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "\nEVENT\n--------------------------------\n%s\n", buf);
- msg = iks_make_msg(IKS_TYPE_NONE, globals.target_jid, buf);
- iks_insert_attrib(msg, "subject", "Event");
- iks_send(globals.session.parser, msg);
- iks_delete(msg);
- switch_safe_free(buf);
- break;
- }
-}
-
-
-
-SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_jid, globals.jid)
- SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_target_jid, globals.target_jid)
- SWITCH_DECLARE_GLOBAL_STRING_FUNC(set_global_passwd, globals.passwd)
-
-
- static switch_status_t load_config(void)
-{
- switch_status_t status = SWITCH_STATUS_FALSE;
- char *cf = "xmpp_event.conf";
- switch_xml_t cfg, xml, settings, param;
- int count = 0;
-
- memset(&globals, 0, sizeof(globals));
-
- if (!(xml = switch_xml_open_cfg(cf, &cfg, NULL))) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "open of %s failed\n", cf);
- return SWITCH_STATUS_TERM;
- }
-
- if ((settings = switch_xml_child(cfg, "settings"))) {
- for (param = switch_xml_child(settings, "param"); param; param = param->next) {
- char *var = (char *) switch_xml_attr_soft(param, "name");
- char *val = (char *) switch_xml_attr_soft(param, "value");
-
- if (!strcmp(var, "jid")) {
- set_global_jid(val);
- count++;
- } else if (!strcmp(var, "target-jid")) {
- set_global_target_jid(val);
- count++;
- } else if (!strcmp(var, "passwd")) {
- set_global_passwd(val);
- count++;
- } else if (!strcmp(var, "debug")) {
- globals.debug = atoi(val);
- }
- }
- }
-
- switch_xml_free(xml);
-
- if (count == 3) {
- /* TBD use config to pick what events to bind to */
- if (switch_event_bind((char *) modname, SWITCH_EVENT_ALL, SWITCH_EVENT_SUBCLASS_ANY, event_handler, NULL) != SWITCH_STATUS_SUCCESS) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't bind!\n");
- return SWITCH_STATUS_GENERR;
- }
-
- status = SWITCH_STATUS_SUCCESS;
- }
-
- return status;
-
-}
-
-static int on_result(struct session *sess, ikspak * pak)
-{
- iks *msg, *ctag;
-
- msg = iks_make_pres(IKS_SHOW_AVAILABLE, "Available");
- ctag = iks_insert(msg, "c");
- iks_insert_attrib(ctag, "node", "http://www.freeswitch.org/xmpp/client/caps");
- iks_insert_attrib(ctag, "ver", "1.0.0.1");
- iks_insert_attrib(ctag, "client", "libdingaling");
- iks_insert_attrib(ctag, "xmlns", "http://jabber.org/protocol/caps");
-
- iks_send(sess->parser, msg);
- iks_delete(msg);
-
- return IKS_FILTER_EAT;
-}
-
-static int on_stream(struct session *sess, int type, iks * node)
-{
- sess->counter = opt_timeout;
-
- switch (type) {
- case IKS_NODE_START:
- if (opt_use_tls && !iks_is_secure(sess->parser)) {
- iks_start_tls(sess->parser);
- }
- break;
- case IKS_NODE_NORMAL:
- if (strcmp("stream:features", iks_name(node)) == 0) {
- sess->features = iks_stream_features(node);
- if (opt_use_tls && !iks_is_secure(sess->parser))
- break;
- if (sess->authorized) {
- iks *t;
- if (sess->features & IKS_STREAM_BIND) {
- t = iks_make_resource_bind(sess->acc);
- iks_send(sess->parser, t);
- iks_delete(t);
- }
- if (sess->features & IKS_STREAM_SESSION) {
- t = iks_make_session();
- iks_insert_attrib(t, "id", "auth");
- iks_send(sess->parser, t);
- iks_delete(t);
- }
- } else {
- if (sess->features & IKS_STREAM_SASL_MD5)
- iks_start_sasl(sess->parser, IKS_SASL_DIGEST_MD5, sess->acc->user, sess->pass);
- else if (sess->features & IKS_STREAM_SASL_PLAIN)
- iks_start_sasl(sess->parser, IKS_SASL_PLAIN, sess->acc->user, sess->pass);
- }
- } else if (strcmp("failure", iks_name(node)) == 0) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "sasl authentication failed\n");
- } else if (strcmp("success", iks_name(node)) == 0) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "server connected\n");
- sess->authorized = 1;
- iks_send_header(sess->parser, sess->acc->server);
- } else {
- ikspak *pak;
-
- pak = iks_packet(node);
- iks_filter_packet(my_filter, pak);
- if (sess->job_done == 1)
- return IKS_HOOK;
- }
- break;
-#if 0
- case IKS_NODE_STOP:
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "server disconnected\n");
- break;
-
- case IKS_NODE_ERROR:
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "stream error\n");
- break;
-#endif
-
- }
-
- if (node)
- iks_delete(node);
- return IKS_OK;
-}
-
-
-static int on_subscribe(void *user_data, ikspak * pak)
-{
- char *from = iks_find_attrib(pak->x, "from");
- struct session *sess = (struct session *) user_data;
-
- iks *msg = iks_make_s10n(IKS_TYPE_SUBSCRIBED, from, "mod_xmpp_event");
- iks_send(sess->parser, msg);
- iks_delete(msg);
-
- msg = iks_make_s10n(IKS_TYPE_SUBSCRIBE, from, "mod_xmpp_event");
- iks_send(sess->parser, msg);
- iks_delete(msg);
-
- return IKS_FILTER_EAT;
-}
-
-static int on_msg(void *user_data, ikspak * pak)
-{
- char *cmd = iks_find_cdata(pak->x, "body");
- char *arg = NULL;
- switch_stream_handle_t stream = { 0 };
- char retbuf[2048] = "";
- char *p;
- iks *msg;
-
- if ((p = strchr(cmd, '\r')) != 0) {
- *p++ = '\0';
- } else if ((p = strchr(cmd, '\n')) != 0) {
- *p++ = '\0';
- }
-
- if ((arg = strchr(cmd, ' ')) != 0) {
- *arg++ = '\0';
- }
-
- stream.data = retbuf;
- stream.end = stream.data;
- stream.data_size = sizeof(retbuf);
- stream.write_function = switch_console_stream_write;
- switch_api_execute(cmd, arg, NULL, &stream);
-
-
- msg = iks_make_msg(IKS_TYPE_NONE, globals.target_jid, retbuf);
- iks_insert_attrib(msg, "subject", "Reply");
- iks_send(globals.session.parser, msg);
- iks_delete(msg);
-
-
- return 0;
-}
-
-static int on_error(void *user_data, ikspak * pak)
-{
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "authorization failed\n");
- return IKS_FILTER_EAT;
-}
-
-static void on_log(struct session *sess, const char *data, size_t size, int is_incoming)
-{
- if (iks_is_secure(sess->parser))
- fprintf(stderr, "Sec");
- if (is_incoming)
- fprintf(stderr, "RECV");
- else
- fprintf(stderr, "SEND");
- fprintf(stderr, "[%s]\n", data);
-}
-
-static void j_setup_filter(struct session *sess)
-{
- if (my_filter)
- iks_filter_delete(my_filter);
- my_filter = iks_filter_new();
- iks_filter_add_rule(my_filter, on_msg, 0,
- IKS_RULE_TYPE, IKS_PAK_MESSAGE, IKS_RULE_SUBTYPE, IKS_TYPE_CHAT, IKS_RULE_FROM, globals.target_jid, IKS_RULE_DONE);
- iks_filter_add_rule(my_filter, (iksFilterHook *) on_result, sess,
- IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_RESULT, IKS_RULE_ID, "auth", IKS_RULE_DONE);
- iks_filter_add_rule(my_filter, on_error, sess, IKS_RULE_TYPE, IKS_PAK_IQ, IKS_RULE_SUBTYPE, IKS_TYPE_ERROR, IKS_RULE_ID, "auth", IKS_RULE_DONE);
-
- iks_filter_add_rule(my_filter, on_subscribe, sess, IKS_RULE_TYPE, IKS_PAK_S10N, IKS_RULE_SUBTYPE, IKS_TYPE_SUBSCRIBE, IKS_RULE_DONE);
-
-}
-
-static void xmpp_connect(char *jabber_id, char *pass)
-{
- while (RUNNING == 1) {
- int e;
-
- memset(&globals.session, 0, sizeof(globals.session));
- globals.session.parser = iks_stream_new(IKS_NS_CLIENT, &globals.session, (iksStreamHook *) on_stream);
- if (globals.debug)
- iks_set_log_hook(globals.session.parser, (iksLogHook *) on_log);
- globals.session.acc = iks_id_new(iks_parser_stack(globals.session.parser), jabber_id);
- if (NULL == globals.session.acc->resource) {
- /* user gave no resource name, use the default */
- char tmp[512];
- sprintf(tmp, "%s@%s/%s", globals.session.acc->user, globals.session.acc->server, modname);
- globals.session.acc = iks_id_new(iks_parser_stack(globals.session.parser), tmp);
- }
- globals.session.pass = pass;
-
- j_setup_filter(&globals.session);
-
- e = iks_connect_tcp(globals.session.parser, globals.session.acc->server, IKS_JABBER_PORT);
- switch (e) {
- case IKS_OK:
- break;
- case IKS_NET_NODNS:
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "hostname lookup failed\n");
- case IKS_NET_NOCONN:
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "connection failed\n");
- default:
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "io error %d\n", e);
- switch_sleep(5000000);
- continue;
- }
-
- globals.session.counter = opt_timeout;
- while (RUNNING == 1) {
- e = iks_recv(globals.session.parser, 1);
-
- if (globals.session.job_done) {
- break;
- }
-
- if (IKS_HOOK == e) {
- break;
- }
-
- if (IKS_OK != e) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "io error %d\n", e);
- switch_sleep(5000000);
- break;
- }
-
- if (!globals.session.authorized) {
- if (IKS_NET_TLSFAIL == e) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "tls handshake failed\n");
- switch_sleep(5000000);
- break;
- }
-
- if (globals.session.counter == 0) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "network timeout\n");
- switch_sleep(5000000);
- break;
- }
- }
- }
-
- iks_disconnect(globals.session.parser);
- iks_parser_delete(globals.session.parser);
- globals.session.authorized = 0;
- }
- RUNNING = 0;
-
-}
-
-SWITCH_MODULE_LOAD_FUNCTION(mod_xmpp_event_load)
-{
- /* connect my internal structure to the blank pointer passed to me */
- *module_interface = switch_loadable_module_create_module_interface(pool, modname);
-
- if (load_config() != SWITCH_STATUS_SUCCESS) {
- return SWITCH_STATUS_FALSE;
- }
-
- /* indicate that the module should continue to be loaded */
- return SWITCH_STATUS_SUCCESS;
-}
-
-
-SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xmpp_event_shutdown)
-{
-
- if (RUNNING) {
- RUNNING = -1;
- while (RUNNING) {
- switch_yield(1000);
- }
- }
-
- return SWITCH_STATUS_SUCCESS;
-}
-
-SWITCH_MODULE_RUNTIME_FUNCTION(mod_xmpp_event_runtime)
-{
- RUNNING = 1;
- xmpp_connect(globals.jid, globals.passwd);
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "disconnecting client %d\n", RUNNING);
- return RUNNING ? SWITCH_STATUS_SUCCESS : SWITCH_STATUS_TERM;
-}
-
-/* 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 expandtab:
- */
+++ /dev/null
-<?xml version="1.0" encoding="Windows-1252"?>\r
-<VisualStudioProject\r
- ProjectType="Visual C++"\r
- Version="8.00"\r
- Name="mod_xmpp_event"\r
- ProjectGUID="{F10BE67C-A8FF-4CB2-AF29-D46D2590DC59}"\r
- RootNamespace="mod_xmpp_event"\r
- Keyword="Win32Proj"\r
- >\r
- <Platforms>\r
- <Platform\r
- Name="Win32"\r
- />\r
- </Platforms>\r
- <ToolFiles>\r
- </ToolFiles>\r
- <Configurations>\r
- <Configuration\r
- Name="Debug|Win32"\r
- OutputDirectory="$(ConfigurationName)"\r
- IntermediateDirectory="$(ConfigurationName)"\r
- ConfigurationType="2"\r
- InheritedPropertySheets="$(VCInstallDir)VCProjectDefaults\UpgradeFromVC71.vsprops"\r
- CharacterSet="2"\r
- >\r
- <Tool\r
- Name="VCPreBuildEventTool"\r
- CommandLine=""\r
- />\r
- <Tool\r
- Name="VCCustomBuildTool"\r
- />\r
- <Tool\r
- Name="VCXMLDataGeneratorTool"\r
- />\r
- <Tool\r
- Name="VCWebServiceProxyGeneratorTool"\r
- />\r
- <Tool\r
- Name="VCMIDLTool"\r
- />\r
- <Tool\r
- Name="VCCLCompilerTool"\r
- Optimization="0"\r
- AdditionalIncludeDirectories=""$(InputDir)..\..\..\include";"$(InputDir)..\..\..\..\libs\include";"$(InputDir)..\..\..\..\libs\iksemel\include""\r
- PreprocessorDefinitions="WIN32;_DEBUG;_WINDOWS;_USRDLL;MOD_EXPORTS"\r
- MinimalRebuild="true"\r
- BasicRuntimeChecks="3"\r
- RuntimeLibrary="3"\r
- UsePrecompiledHeader="0"\r
- WarningLevel="4"\r
- WarnAsError="true"\r
- Detect64BitPortabilityProblems="true"\r
- DebugInformationFormat="3"\r
- />\r
- <Tool\r
- Name="VCManagedResourceCompilerTool"\r
- />\r
- <Tool\r
- Name="VCResourceCompilerTool"\r
- />\r
- <Tool\r
- Name="VCPreLinkEventTool"\r
- />\r
- <Tool\r
- Name="VCLinkerTool"\r
- AdditionalDependencies="Ws2_32.lib"\r
- ShowProgress="0"\r
- OutputFile="$(SolutionDir)$(OutDir)/mod/$(InputName).dll"\r
- LinkIncremental="1"\r
- AdditionalLibraryDirectories=""..\..\..\..\w32\vsnet\$(OutDir)";"..\..\..\..\libs\iksemel\$(OutDir)""\r
- GenerateDebugInformation="true"\r
- ProgramDatabaseFile="$(OutDir)$(TargetName).pdb"\r
- SubSystem="2"\r
- ImportLibrary="$(OutDir)/mod_xmpp_event.lib"\r
- TargetMachine="1"\r
- />\r
- <Tool\r
- Name="VCALinkTool"\r
- />\r
- <Tool\r
- Name="VCManifestTool"\r
- />\r
- <Tool\r
- Name="VCXDCMakeTool"\r
- />\r
- <Tool\r
- Name="VCBscMakeTool"\r
- />\r
- <Tool\r
- Name="VCFxCopTool"\r
- />\r
- <Tool\r
- Name="VCAppVerifierTool"\r
- />\r
- <Tool\r
- Name="VCWebDeploymentTool"\r
- />\r
- <Tool\r
- Name="VCPostBuildEventTool"\r
- />\r
- </Configuration>\r
- <Configuration\r
- Name="Release|Win32"\r
- OutputDirectory="$(ConfigurationName)"\r
- IntermediateDirectory="$(ConfigurationName)"\r
- ConfigurationType="2"\r
- InheritedPropertySheets="$(VCInstallDir)VCProjectDefaults\UpgradeFromVC71.vsprops"\r
- CharacterSet="2"\r
- >\r
- <Tool\r
- Name="VCPreBuildEventTool"\r
- CommandLine=""\r
- />\r
- <Tool\r
- Name="VCCustomBuildTool"\r
- />\r
- <Tool\r
- Name="VCXMLDataGeneratorTool"\r
- />\r
- <Tool\r
- Name="VCWebServiceProxyGeneratorTool"\r
- />\r
- <Tool\r
- Name="VCMIDLTool"\r
- />\r
- <Tool\r
- Name="VCCLCompilerTool"\r
- AdditionalIncludeDirectories=""$(InputDir)..\..\..\include";"$(InputDir)..\..\..\..\libs\include";"$(InputDir)..\..\..\..\libs\iksemel\include""\r
- PreprocessorDefinitions="WIN32;NDEBUG;_WINDOWS;_USRDLL;MOD_EXPORTS"\r
- RuntimeLibrary="2"\r
- UsePrecompiledHeader="0"\r
- WarningLevel="4"\r
- WarnAsError="true"\r
- Detect64BitPortabilityProblems="true"\r
- DebugInformationFormat="3"\r
- />\r
- <Tool\r
- Name="VCManagedResourceCompilerTool"\r
- />\r
- <Tool\r
- Name="VCResourceCompilerTool"\r
- />\r
- <Tool\r
- Name="VCPreLinkEventTool"\r
- />\r
- <Tool\r
- Name="VCLinkerTool"\r
- AdditionalDependencies="Ws2_32.lib"\r
- ShowProgress="0"\r
- OutputFile="$(SolutionDir)$(OutDir)/mod/$(InputName).dll"\r
- LinkIncremental="1"\r
- AdditionalLibraryDirectories=""..\..\..\..\w32\vsnet\$(OutDir)";"..\..\..\..\libs\iksemel\$(OutDir)""\r
- GenerateDebugInformation="true"\r
- ProgramDatabaseFile="$(OutDir)$(TargetName).pdb"\r
- SubSystem="2"\r
- OptimizeReferences="2"\r
- EnableCOMDATFolding="2"\r
- LinkTimeCodeGeneration="1"\r
- ImportLibrary="$(OutDir)/mod_xmpp_event.lib"\r
- TargetMachine="1"\r
- />\r
- <Tool\r
- Name="VCALinkTool"\r
- />\r
- <Tool\r
- Name="VCManifestTool"\r
- />\r
- <Tool\r
- Name="VCXDCMakeTool"\r
- />\r
- <Tool\r
- Name="VCBscMakeTool"\r
- />\r
- <Tool\r
- Name="VCFxCopTool"\r
- />\r
- <Tool\r
- Name="VCAppVerifierTool"\r
- />\r
- <Tool\r
- Name="VCWebDeploymentTool"\r
- />\r
- <Tool\r
- Name="VCPostBuildEventTool"\r
- />\r
- </Configuration>\r
- </Configurations>\r
- <References>\r
- </References>\r
- <Files>\r
- <Filter\r
- Name="Source Files"\r
- Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"\r
- UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}"\r
- >\r
- <File\r
- RelativePath="mod_xmpp_event.c"\r
- >\r
- </File>\r
- </Filter>\r
- <Filter\r
- Name="Header Files"\r
- Filter="h;hpp;hxx;hm;inl;inc;xsd"\r
- UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}"\r
- >\r
- </Filter>\r
- <Filter\r
- Name="Resource Files"\r
- Filter="rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx"\r
- UniqueIdentifier="{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}"\r
- >\r
- </Filter>\r
- </Files>\r
- <Globals>\r
- </Globals>\r
-</VisualStudioProject>\r
projects / thirdparty / freeswitch.git / commitdiff
