- Freeswitch-trunk - FreeSWITCH Mailing Lists

[commit] r8739 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 02 Jun '08

02 Jun '08

Author: anthm Date: Mon Jun 2 12:40:44 2008 New Revision: 8739 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c Log: wait there's more Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c Mon Jun 2 12:40:44 2008 @@ -413,7 +413,8 @@ if (probe_euser && probe_host && (profile = sofia_glue_find_profile(probe_host))) { sql = switch_mprintf("select sip_registrations.sip_user, sip_registrations.sip_host, sip_registrations.status, " - "sip_registrations.rpid,'', sip_dialogs.uuid, sip_dialogs.state, sip_dialogs.direction " + "sip_registrations.rpid,'', sip_dialogs.uuid, sip_dialogs.state, sip_dialogs.direction, " + "sip_dialogs.sip_to_user, sip_dialogs.sip_to_host " "from sip_registrations left join sip_dialogs on " "(sip_dialogs.sip_from_user = sip_registrations.sip_user) " "and sip_dialogs.sip_from_host = sip_registrations.sip_host " @@ -668,15 +669,22 @@ char *status = argv[2]; char *rpid = argv[3]; char *proto = argv[4]; + char *to_user = NULL; char *uuid = NULL; char *state = NULL; char *direction = NULL; switch_event_t *event; + char to_buf[128] = ""; if (argc > 5) { uuid = switch_str_nil(argv[5]); state = switch_str_nil(argv[6]); direction = switch_str_nil(argv[7]); + if (argc > 8) { + switch_set_string(to_buf, argv[8]); + switch_url_decode(to_buf); + to_user = to_buf; + } } if (switch_strlen_zero(proto)) { @@ -693,6 +701,10 @@ switch_event_add_header(event, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog"); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "event_count", "%d", 0); + if (!switch_strlen_zero(to_user)) { + switch_event_add_header(event, SWITCH_STACK_BOTTOM, "to-user", "%s", to_user); + } + if (switch_strlen_zero(state)) { switch_event_add_header(event, SWITCH_STACK_BOTTOM, "unique-id", "%s", SOFIA_CHAT_PROTO); switch_event_add_header(event, SWITCH_STACK_BOTTOM, "channel-state", "%s", "CS_HANGUP"); @@ -875,8 +887,8 @@ const char *from_user = switch_str_nil(switch_event_get_header(helper->event, "variable_sip_from_user")); const char *clean_to_user = NULL; const char *clean_from_user = NULL; - - + const char *p_to_user = switch_str_nil(switch_event_get_header(helper->event, "to-user")); + if (is_dialog) { SWITCH_STANDARD_STREAM(stream); } @@ -1012,6 +1024,10 @@ } if (switch_strlen_zero(from_id)) { + from_id = p_to_user; + } + + if (switch_strlen_zero(from_id)) { switch_snprintf(status_line, sizeof(status_line), "On The Phone"); } else { switch_snprintf(status_line, sizeof(status_line), "Talk %s", switch_str_nil(from_id));

1 0

[commit] r8738 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 02 Jun '08

02 Jun '08

Author: anthm Date: Mon Jun 2 11:48:56 2008 New Revision: 8738 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c Log: update Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia.c Mon Jun 2 11:48:56 2008 @@ -1520,6 +1520,7 @@ //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "ping success %s\n", gateway->name); if (gateway->state == REG_STATE_FAILED) { gateway->state = REG_STATE_UNREGED; + gateway->retry = 0; } gateway->status = SOFIA_GATEWAY_UP; } else {

1 0

[commit] r8737 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 02 Jun '08

02 Jun '08

Author: anthm Date: Mon Jun 2 11:42:59 2008 New Revision: 8737 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c Log: some more presence changes Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_presence.c Mon Jun 2 11:42:59 2008 @@ -743,7 +743,7 @@ } -static char *gen_pidf(char *user_agent, char *id, char *url, char *open, char *rpid, char *prpid, char *status, char *note, const char **ct) +static char *gen_pidf(char *user_agent, char *id, char *url, char *open, char *rpid, char *prpid, char *status, const char **ct) { if (switch_stristr("polycom", user_agent)) { *ct = "application/xpidf+xml"; @@ -751,6 +751,9 @@ "<?xml version=\"1.0\"?>\n" "<!DOCTYPE presence PUBLIC \"-//IETF//DTD RFCxxxx XPIDF 1.0//EN\" \"xpidf.dtd\">\n" "<presence>\n" + " <status>\n" + " <note>%s</note>\n" + " </status>\n" " <presentity uri=\"%s;method=SUBSCRIBE\" />\n" " <atom id=\"%s\">\n" " <address uri=\"%s;user=ip\" priority=\"0.800000\">\n" @@ -758,20 +761,17 @@ " <msnsubstatus substatus=\"%s\" />\n" " </address>\n" " </atom>\n" - "</presence>\n", id, id, url, open, prpid + "</presence>\n", status, id, id, url, open, prpid ); } else { *ct = "application/pidf+xml"; return switch_mprintf( - "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?>\n" - "<presence xmlns='urn:ietf:params:xml:ns:pidf'\n" - "xmlns:dm='urn:ietf:params:xml:ns:pidf:data-model'\n" - "xmlns:rpid='urn:ietf:params:xml:ns:pidf:rpid'\n" - "xmlns:c='urn:ietf:params:xml:ns:pidf:cipid'\n" - "entity='pres:%s'>\n" - " <status>\n" - " <note>%s</note>\n" - " </status>\n" + "<?xml version=\"1.0\" encoding=\"ISO-8859-1\"?> \n" + "<presence xmlns='urn:ietf:params:xml:ns:pidf' \n" + "xmlns:dm='urn:ietf:params:xml:ns:pidf:data-model' \n" + "xmlns:rpid='urn:ietf:params:xml:ns:pidf:rpid' \n" + "xmlns:c='urn:ietf:params:xml:ns:pidf:cipid' entity='%s'>\n" + " <tuple id='t6a5ed77e'>\n" " <status>\r\n" " <basic>%s</basic>\n" @@ -780,9 +780,10 @@ " <dm:person id='p06360c4a'>\n" " <rpid:activities>\r\n" " <rpid:%s/>\n" - " </rpid:activities>" + " </rpid:activities>\n" + " <dm:note>%s</dm:note>" " </dm:person>\n" - "</presence>", id, status, prpid, rpid); + "</presence>", id, prpid, rpid, status); } } @@ -792,7 +793,7 @@ struct presence_helper *helper = (struct presence_helper *) pArg; sofia_profile_t *profile = helper->profile; char *pl = NULL; - char *clean_id = NULL, *id = NULL, *note = NULL; + char *clean_id = NULL, *id = NULL; uint32_t in = atoi(argv[13]); char *status = argv[14]; char *rpid = argv[15]; @@ -910,9 +911,19 @@ if (!strcasecmp(state, "cs_hangup")) { astate = "terminated"; } else if (switch_strlen_zero(astate)) { + //char *buf; + //switch_event_serialize(helper->event, &buf, SWITCH_FALSE); + //switch_assert(buf); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_INFO, "CHANNEL_DATA:\n%s\n", buf); + //free(buf); + astate = switch_str_nil(switch_event_get_header(helper->event, "answer-state")); if (switch_strlen_zero(astate)) { - astate = dft_state; + if (is_dialog) { + astate = dft_state; + } else { + astate = "terminated"; + } } } @@ -989,11 +1000,10 @@ if (!is_dialog) { + char status_line[256] = ""; if (in) { - char status_line[256] = ""; - if (!strcmp(astate, "early")) { - switch_snprintf(status_line, sizeof(status_line), "R %s", switch_str_nil(from_id)); + switch_snprintf(status_line, sizeof(status_line), "Ring %s", switch_str_nil(from_id)); rpid = "on-the-phone"; } else if (!strcmp(astate, "confirmed")) { char *dest = switch_event_get_header(helper->event, "Caller-Destination-Number"); @@ -1002,36 +1012,42 @@ } if (switch_strlen_zero(from_id)) { - switch_snprintf(status_line, sizeof(status_line), "Available"); + switch_snprintf(status_line, sizeof(status_line), "On The Phone"); } else { - switch_snprintf(status_line, sizeof(status_line), "T %s", switch_str_nil(from_id)); - rpid = "on-the-phone"; + switch_snprintf(status_line, sizeof(status_line), "Talk %s", switch_str_nil(from_id)); } + rpid = "on-the-phone"; } else if (!strcmp(astate, "terminated")) { - switch_snprintf(status_line, sizeof(status_line), "Available"); + if (!strcasecmp(rpid, "on-the-phone")) { + switch_snprintf(status_line, sizeof(status_line), "Dialing"); + } else { + switch_snprintf(status_line, sizeof(status_line), "Available"); + } + } else { + switch_set_string(status_line, status); } - note = switch_mprintf("<dm:note>%s</dm:note>", status_line); open = "open"; } else { - note = NULL; open = "closed"; } + + if (!strncasecmp(status_line, "registered", 10)) { + switch_snprintf(status_line, sizeof(status_line), "Available"); + } prpid = translate_rpid(rpid); - pl = gen_pidf(user_agent, id, profile->url, open, rpid, prpid, status, note, &ct); + pl = gen_pidf(user_agent, clean_id, profile->url, open, rpid, prpid, status_line, &ct); } } else { if (in) { - note = switch_mprintf("<dm:note>%s</dm:note>", status); open = "open"; } else { - note = NULL; open = "closed"; } prpid = translate_rpid(rpid); - pl = gen_pidf(user_agent, id, profile->url, open, rpid, prpid, status, note, &ct); + pl = gen_pidf(user_agent, clean_id, profile->url, open, rpid, prpid, status, &ct); } switch_snprintf(exp, sizeof(exp), "active;expires=%ld", (long) exptime); @@ -1042,7 +1058,6 @@ switch_safe_free(id); switch_safe_free(clean_id); - switch_safe_free(note); switch_safe_free(pl); switch_safe_free(to);

1 0

[commit] r8736 - freeswitch/trunk/src/mod/xml_int/mod_xml_ldap
by Freeswitch SVN 01 Jun '08

01 Jun '08

Author: jskopis Date: Sun Jun 1 15:48:20 2008 New Revision: 8736 Added: freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/lutil_ldap.h Modified: freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/Makefile freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c Log: Added sasl support. Added support for search filters Modified: freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/Makefile ============================================================================== --- freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/Makefile (original) +++ freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/Makefile Sun Jun 1 15:48:20 2008 @@ -5,13 +5,14 @@ LDAPLA=$(LDAP_DIR)/libraries/libldap_r/libldap_r.la LIBLBERLA=$(LDAP_DIR)/libraries/liblber/liblber.la +LIBLUTILA=$(LDAP_DIR)/libraries/liblutil/liblutil.a LOCAL_CFLAGS=-DWITH_OPENLDAP -DLDAP_DEPRECATED -I$(LDAP_DIR)/include DEFAULT_ARGS= --prefix=$(PREFIX) --disable-shared --with-pic --disable-slapd DEFAULT_ARGS+= --disable-slurpd --disable-relay --disable-bdb --disable-hdb -LOCAL_LIBADD=$(LDAPLA) $(LIBLBERLA) +LOCAL_LIBADD=$(LDAPLA) $(LIBLBERLA) $(LIBLUTILA) include $(switch_srcdir)/build/modmake.rules @@ -19,6 +20,6 @@ $(GETLIB) $(LDAP).tgz cd $(LDAP_DIR) && CFLAGS="`echo $(CFLAGS) | sed -e 's:-std=c99::'`" ./configure $(DEFAULT_ARGS) -$(LDAPLA) $(LIBLBERLA): $(LDAP_DIR) +$(LIBLUTILA) $(LDAPLA) $(LIBLBERLA): $(LDAP_DIR) cd $(LDAP_DIR) && $(MAKE) $(TOUCH_TARGET) Added: freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/lutil_ldap.h ============================================================================== --- (empty file) +++ freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/lutil_ldap.h Sun Jun 1 15:48:20 2008 @@ -0,0 +1,58 @@ +/* $OpenLDAP: pkg/ldap/include/lutil_ldap.h,v 1.9.2.4 2008/02/11 23:24:10 kurt Exp $ */ +/* This work is part of OpenLDAP Software <http://www.openldap.org/>. + * + * Copyright 1998-2008 The OpenLDAP Foundation. + * All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted only as authorized by the OpenLDAP + * Public License. + * + * A copy of this license is available in file LICENSE in the + * top-level directory of the distribution or, alternatively, at + * <http://www.OpenLDAP.org/license.html>. + */ + +#ifndef _LUTIL_LDAP_H +#define _LUTIL_LDAP_H 1 + +#include <ldap_cdefs.h> +#include <lber_types.h> + +/* + * Include file for lutil LDAP routines + */ + +LDAP_BEGIN_DECL + +LDAP_LUTIL_F( void ) +lutil_sasl_freedefs LDAP_P(( + void *defaults )); + +LDAP_LUTIL_F( void * ) +lutil_sasl_defaults LDAP_P(( + LDAP *ld, + char *mech, + char *realm, + char *authcid, + char *passwd, + char *authzid )); + +LDAP_LUTIL_F( int ) +lutil_sasl_interact LDAP_P(( + LDAP *ld, unsigned flags, void *defaults, void *p )); + +LDAP_END_DECL + +#endif /* _LUTIL_LDAP_H */ + +typedef struct lutil_sasl_defaults_s { + char *mech; + char *realm; + char *authcid; + char *passwd; + char *authzid; + char **resps; + int nresps; +} lutilSASLdefaults; + Modified: freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c ============================================================================== --- freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c (original) +++ freeswitch/trunk/src/mod/xml_int/mod_xml_ldap/mod_xml_ldap.c Sun Jun 1 15:48:20 2008 @@ -42,6 +42,8 @@ #else #include <lber.h> #include <ldap.h> +#include <sasl/sasl.h> +#include "lutil_ldap.h" #endif typedef enum { @@ -55,18 +57,18 @@ SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_xml_ldap_shutdown); SWITCH_MODULE_DEFINITION(mod_xml_ldap, mod_xml_ldap_load, mod_xml_ldap_shutdown, NULL); -struct xml_binding { +typedef struct xml_binding { char *bindings; char *host; - char *ldap_base; + char *basedn; char *binddn; char *bindpass; - char *queryfmt; -}; + char *filter; + char **attrs; + lutilSASLdefaults *defaults; +} xml_binding_t; -typedef struct xml_binding xml_binding_t; - -struct ldap_c { +typedef struct ldap_c { LDAP *ld; LDAPMessage *msg; LDAPMessage *entry; @@ -76,8 +78,8 @@ char *val; char **keyvals; char **valvals; - -}; + char *sp; +} ldap_ctx; static switch_status_t xml_ldap_directory_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off); static switch_status_t xml_ldap_dialplan_result(void *ldap_connection, xml_binding_t *binding, switch_xml_t *xml, int *off); @@ -223,10 +225,12 @@ int desired_version = LDAP_VERSION3; xml_ldap_query_type_t query_type; char *dir_exten = NULL, *dir_domain = NULL; - char *filter = "(objectClass=*)"; - char *search_base = NULL; - int off = 0; + char *search_filter = NULL, *search_base = NULL; + int off = 0, ret = 1; + + //char *buf; + //buf = malloc(4096); if (!binding) { @@ -287,15 +291,18 @@ if ((sub = switch_xml_add_child_d(sub, "user", off++))) { switch_xml_set_attr_d(sub, "id", dir_exten); } + } - search_base = switch_mprintf(binding->queryfmt, dir_exten, dir_domain, binding->ldap_base); + search_filter = switch_mprintf(binding->filter, dir_exten); + search_base = switch_mprintf(binding->basedn, dir_domain); free(dir_exten); dir_exten = NULL; free(dir_domain); dir_domain = NULL; + } else { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "something bad happened during the query construction phase likely exten(%s) or domain(%s) is null\n", dir_exten, @@ -314,7 +321,7 @@ sub = switch_xml_add_child_d(xml, "context", off++); } - search_base = switch_mprintf(binding->queryfmt, dir_exten, dir_domain, binding->ldap_base); + break; case XML_LDAP_PHRASE: @@ -327,7 +334,7 @@ - if ((ldap->ld = ldap_init(binding->host, LDAP_PORT)) == NULL) { + if ((ldap->ld = (LDAP*)ldap_init(binding->host, LDAP_PORT)) == NULL) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to connect to ldap server.%s\n", binding->host); goto cleanup; } @@ -336,12 +343,24 @@ goto cleanup; } - if (ldap_bind_s(ldap->ld, binding->binddn, binding->bindpass, auth_method) != LDAP_SUCCESS) { - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to bind to ldap server %s as %s\n", binding->host, binding->binddn); - goto cleanup; + ldap_set_option( ldap->ld, LDAP_OPT_X_SASL_SECPROPS, &ldap->sp ); + + + + if (binding->binddn) { + if (ldap_bind_s(ldap->ld, binding->binddn, binding->bindpass, auth_method) != LDAP_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to bind to ldap server %s as %s\n", binding->host, binding->binddn); + goto cleanup; + } + } else { + if (ldap_sasl_interactive_bind_s( ldap->ld, NULL, binding->defaults->mech, NULL, NULL,(unsigned)LDAP_SASL_SIMPLE, lutil_sasl_interact , binding->defaults ) != LDAP_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Unable to sasl_bind to ldap server %s as %s\n", binding->host, binding->defaults->authcid); + goto cleanup; + } } - if (ldap_search_s(ldap->ld, search_base, LDAP_SCOPE_SUBTREE, filter, NULL, 0, &ldap->msg) != LDAP_SUCCESS) { + if (ldap_search_s(ldap->ld, search_base, LDAP_SCOPE_SUBTREE, search_filter, NULL, 0, &ldap->msg) != LDAP_SUCCESS) { + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Query failed: -b \"%s\" \"%s\"\n", search_base, search_filter); goto cleanup; } @@ -353,6 +372,8 @@ goto cleanup; } + ret = 0; + cleanup: if (ldap->msg) { ldap_msgfree(ldap->msg); @@ -362,8 +383,17 @@ ldap_unbind_s(ldap->ld); } + switch_safe_free(search_filter); switch_safe_free(search_base); + //switch_xml_toxml_buf(xml,buf,0,0,1); + //switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "providing:\n%s\n", buf); + + if(ret) { + switch_xml_free(xml); + return NULL; + } + return xml; } @@ -393,35 +423,50 @@ } memset(binding, 0, sizeof(*binding)); + if (!(binding->defaults = malloc(sizeof(lutilSASLdefaults)))) { + goto done; + } + memset(binding->defaults, 0, sizeof(lutilSASLdefaults)); + for (param = switch_xml_child(binding_tag, "param"); param; param = param->next) { char *var = (char *) switch_xml_attr_soft(param, "name"); char *val = (char *) switch_xml_attr_soft(param, "value"); - if (!strcasecmp(var, "queryfmt")) { + if (!strcasecmp(var, "filter")) { binding->bindings = (char *) switch_xml_attr_soft(param, "bindings"); if (val) { - binding->queryfmt = strdup(val); + binding->filter = strdup(val); } - } else if (!strcasecmp(var, "base")) { - binding->ldap_base = strdup(val); + } else if (!strcasecmp(var, "basedn")) { + binding->basedn = strdup(val); } else if (!strcasecmp(var, "binddn")) { binding->binddn = strdup(val); } else if (!strcasecmp(var, "bindpass")) { binding->bindpass = strdup(val); } else if (!strcasecmp(var, "host")) { binding->host = strdup(val); + } else if (!strcasecmp(var, "mech")) { + binding->defaults->mech = strdup(val); + } else if (!strcasecmp(var, "realm")) { + binding->defaults->realm = strdup(val); + } else if (!strcasecmp(var, "authcid")) { + binding->defaults->authcid = strdup(val); + } else if (!strcasecmp(var, "authzid")) { + binding->defaults->authzid = strdup(val); } + } - if (!binding->ldap_base || !binding->binddn || !binding->bindpass || !binding->queryfmt) { + if (!binding->basedn || !binding->filter) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, - "You must define \"base\", \"binddn\", \"bindpass\", and \"queryfmt\" in mod_xml_ldap.conf.xml\n"); + "You must define \"basedn\", and \"filter\" in mod_xml_ldap.conf.xml\n"); continue; } - switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding [%s] XML Fetch Function [%s] [%s]\n", - switch_strlen_zero(bname) ? "N/A" : bname, binding->ldap_base, binding->bindings ? binding->bindings : "all"); + + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "Binding [%s] XML Fetch Function [%s] (%s) [%s]\n", + switch_strlen_zero(bname) ? "N/A" : bname, binding->basedn, binding->filter, binding->bindings ? binding->bindings : "all"); switch_xml_bind_search_function(xml_ldap_search, switch_xml_parse_section_string(bname), binding);

1 0

[commit] r8735 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 31 May '08

31 May '08

Author: stkn Date: Sat May 31 16:55:28 2008 New Revision: 8735 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Log: update event callback after db schema changes Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Sat May 31 16:55:28 2008 @@ -225,13 +225,13 @@ if (argc >= 3) { if (switch_event_create_subclass(&s_event, SWITCH_EVENT_CUSTOM, MY_EVENT_EXPIRE) == SWITCH_STATUS_SUCCESS) { - switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "profile-name", "%s", argv[6]); + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "profile-name", "%s", argv[8]); switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "call-id", "%s", argv[0]); switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "user", "%s", argv[1]); switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "host", "%s", argv[2]); switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "contact", "%s", argv[3]); - switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "expires", "%s", argv[4]); - switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "user-agent", "%s", argv[5]); + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "expires", "%s", argv[6]); + switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "user-agent", "%s", argv[7]); switch_event_fire(&s_event); } }

1 0

[commit] r8734 - in freeswitch/trunk/src: . mod/languages/mod_spidermonkey
by Freeswitch SVN 31 May '08

31 May '08

Author: anthm Date: Sat May 31 12:48:54 2008 New Revision: 8734 Modified: freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.c freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.h freeswitch/trunk/src/switch_core_io.c Log: keep hangup hook in the session thread Modified: freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.c ============================================================================== --- freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.c (original) +++ freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.c Sat May 31 12:48:54 2008 @@ -38,18 +38,17 @@ #include <curl/curl.h> #endif static int foo = 0; +static void check_hangup_hook(struct js_session *jss); SWITCH_MODULE_LOAD_FUNCTION(mod_spidermonkey_load); SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_spidermonkey_shutdown); SWITCH_MODULE_DEFINITION(mod_spidermonkey, mod_spidermonkey_load, mod_spidermonkey_shutdown, NULL); -#define METHOD_SANITY_CHECK() do { \ -if (!jss || !jss->session) { \ - eval_some_js("~throw new Error(\"You must call the session.originate method before calling this method!\");", cx, obj, rval); \ - *rval = BOOLEAN_TO_JSVAL(JS_FALSE); \ - return JS_FALSE; \ - } \ - } while(foo == 1) +#define METHOD_SANITY_CHECK() if (!jss || !jss->session) { \ + eval_some_js("~throw new Error(\"You must call the session.originate method before calling this method!\");", cx, obj, rval); \ + *rval = BOOLEAN_TO_JSVAL(JS_FALSE); \ + return JS_FALSE; \ + } else check_hangup_hook(jss) #define CHANNEL_SANITY_CHECK() do { \ if (!switch_channel_ready(channel)) { \ @@ -1148,11 +1147,11 @@ jss->stack_depth--; return SWITCH_STATUS_FALSE; } - + check_hangup_hook(jss); JS_ResumeRequest(cb_state->cx, cb_state->saveDepth); JS_CallFunction(cb_state->cx, cb_state->obj, cb_state->function, argc, argv, &cb_state->ret); cb_state->saveDepth = JS_SuspendRequest(cb_state->cx); - + check_hangup_hook(jss); jss->stack_depth--; return SWITCH_STATUS_SUCCESS; } @@ -1420,7 +1419,9 @@ args.input_callback = dtmf_func; args.buf = bp; args.buflen = len; + check_hangup_hook(jss); switch_ivr_record_file(jss->session, &fh, file_name, &args, limit); + check_hangup_hook(jss); JS_ResumeRequest(cx, cb_state.saveDepth); *rval = cb_state.ret; @@ -1470,7 +1471,9 @@ args.input_callback = dtmf_func; args.buf = bp; args.buflen = len; + check_hangup_hook(jss); switch_ivr_collect_digits_callback(jss->session, &args, to); + check_hangup_hook(jss); JS_ResumeRequest(cx, cb_state.saveDepth); *rval = cb_state.ret; @@ -1544,9 +1547,9 @@ args.input_callback = dtmf_func; args.buf = bp; args.buflen = len; - + check_hangup_hook(jss); switch_ivr_phrase_macro(jss->session, phrase_name, phrase_data, phrase_lang, &args); - + check_hangup_hook(jss); JS_ResumeRequest(cx, cb_state.saveDepth); *rval = cb_state.ret; @@ -1559,7 +1562,8 @@ int argc = 0; jsval ret; - if (jss->on_hangup && (jss->hook_state == CS_HANGUP || jss->hook_state == CS_ROUTING)) { + if (!jss->check_state && jss->on_hangup && (jss->hook_state == CS_HANGUP || jss->hook_state == CS_ROUTING)) { + jss->check_state++; argv[argc++] = OBJECT_TO_JSVAL(jss->obj); if (jss->hook_state == CS_HANGUP) { argv[argc++] = STRING_TO_JSVAL(JS_NewStringCopyZ(jss->cx, "hangup")); @@ -1579,7 +1583,7 @@ switch_channel_state_t state = switch_channel_get_state(channel); if (jss->hook_state != state) { jss->hook_state = state; - check_hangup_hook(jss); + jss->check_state = 0; } } @@ -1673,7 +1677,9 @@ args.input_callback = dtmf_func; args.buf = bp; args.buflen = len; + check_hangup_hook(jss); switch_ivr_play_file(jss->session, &fh, file_name, &args); + check_hangup_hook(jss); JS_ResumeRequest(cx, cb_state.saveDepth); *rval = cb_state.ret; @@ -1862,7 +1868,9 @@ args.buflen = len; switch_core_speech_flush_tts(&jss->speech->sh); + check_hangup_hook(jss); switch_ivr_speak_text_handle(jss->session, &jss->speech->sh, &jss->speech->codec, NULL, text, &args); + check_hangup_hook(jss); JS_ResumeRequest(cx, cb_state.saveDepth); *rval = cb_state.ret; @@ -2011,7 +2019,7 @@ if (argc > 0) { JS_ValueToInt32(cx, argv[0], &timeout); } - + check_hangup_hook(jss); saveDepth = JS_SuspendRequest(cx); for (;;) { if (((elapsed = (unsigned int) ((switch_timestamp_now() - started) / 1000)) > (switch_time_t) timeout) @@ -2029,7 +2037,7 @@ switch_yield(1000); } JS_ResumeRequest(cx, saveDepth); - + check_hangup_hook(jss); return JS_TRUE; } @@ -2050,7 +2058,7 @@ if (argc > 0) { JS_ValueToInt32(cx, argv[0], &timeout); } - + check_hangup_hook(jss); saveDepth = JS_SuspendRequest(cx); for (;;) { if (((elapsed = (unsigned int) ((switch_timestamp_now() - started) / 1000)) > (switch_time_t) timeout) @@ -2067,7 +2075,7 @@ switch_yield(1000); } JS_ResumeRequest(cx, saveDepth); - + check_hangup_hook(jss); return JS_TRUE; } @@ -2097,7 +2105,9 @@ if ((application_interface = switch_loadable_module_get_application_interface(app_name))) { if (application_interface->application_function) { saveDepth = JS_SuspendRequest(cx); + check_hangup_hook(jss); switch_core_session_exec(jss->session, application_interface, app_arg); + check_hangup_hook(jss); JS_ResumeRequest(cx, saveDepth); retval = JS_TRUE; } Modified: freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.h ============================================================================== --- freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.h (original) +++ freeswitch/trunk/src/mod/languages/mod_spidermonkey/mod_spidermonkey.h Sat May 31 12:48:54 2008 @@ -146,6 +146,7 @@ char *rdnis; char *context; char *username; + int check_state; struct js_session_speech *speech; }; Modified: freeswitch/trunk/src/switch_core_io.c ============================================================================== --- freeswitch/trunk/src/switch_core_io.c (original) +++ freeswitch/trunk/src/switch_core_io.c Sat May 31 12:48:54 2008 @@ -634,6 +634,11 @@ status = SWITCH_STATUS_SUCCESS; break; default: + if (ptime_mismatch) { + status = perform_write(session, frame, flags, stream_id); + return SWITCH_STATUS_SUCCESS; + } + switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Codec %s decoder error!\n", frame->codec->codec_interface->interface_name); return status; }

1 0

[commit] r8733 - freeswitch/trunk/src/mod/applications/mod_commands
by Freeswitch SVN 30 May '08

30 May '08

Author: anthm Date: Fri May 30 17:02:04 2008 New Revision: 8733 Modified: freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c Log: make global_setvar only have 2 fields so you can set foo=bar=blah w/o quotes Modified: freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c ============================================================================== --- freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c (original) +++ freeswitch/trunk/src/mod/applications/mod_commands/mod_commands.c Fri May 30 17:02:04 2008 @@ -2246,7 +2246,7 @@ #define GLOBAL_SETVAR_SYNTAX "<var> <value>" SWITCH_STANDARD_API(global_setvar_function) { - char *mycmd = NULL, *argv[3] = { 0 }; + char *mycmd = NULL, *argv[2] = { 0 }; int argc = 0; if (!switch_strlen_zero(cmd) && (mycmd = strdup(cmd))) {

1 0

[commit] r8732 - freeswitch/trunk/src/mod/endpoints/mod_portaudio
by Freeswitch SVN 30 May '08

30 May '08

Author: anthm Date: Fri May 30 16:59:14 2008 New Revision: 8732 Modified: freeswitch/trunk/src/mod/endpoints/mod_portaudio/mod_portaudio.c Log: make mod_portaudio less chatty on startup Modified: freeswitch/trunk/src/mod/endpoints/mod_portaudio/mod_portaudio.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_portaudio/mod_portaudio.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_portaudio/mod_portaudio.c Fri May 30 16:59:14 2008 @@ -152,7 +152,7 @@ static switch_status_t engage_device(int samplerate, int codec_ms); static switch_status_t engage_ring_device(int sample_rate, int channels); static void deactivate_ring_device(void); -static int dump_info(void); +static int dump_info(int verbose); static switch_status_t load_config(void); static int get_dev_by_name(char *name, int in); static int get_dev_by_number(int number, int in); @@ -690,7 +690,7 @@ Pa_Initialize(); - if (dump_info()) { + if (dump_info(0)) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Couldn't find any audio devices!\n"); return SWITCH_STATUS_TERM; } @@ -987,7 +987,7 @@ return SWITCH_STATUS_SUCCESS; } -static int dump_info(void) +static int dump_info(int verbose) { int i, numDevices, defaultDisplayed; const PaDeviceInfo *deviceInfo; @@ -1010,6 +1010,11 @@ } switch_log_printf(SWITCH_CHANNEL_LOG_CLEAN, SWITCH_LOG_INFO, "Number of devices = %d\n", numDevices); + + if (!verbose) { + return 0; + } + for (i = 0; i < numDevices; i++) { switch_log_printf(SWITCH_CHANNEL_LOG_CLEAN, SWITCH_LOG_INFO, "%s", line); deviceInfo = Pa_GetDeviceInfo(i); @@ -1082,7 +1087,7 @@ PrintSupportedStandardSampleRates(&inputParameters, &outputParameters); } } - + switch_log_printf(SWITCH_CHANNEL_LOG_CLEAN, SWITCH_LOG_INFO, "%s", line); return 0; @@ -1615,7 +1620,7 @@ } else if (!strcasecmp(argv[0], "devlist")) { func = devlist; } else if (!strcasecmp(argv[0], "dump")) { - dump_info(); + dump_info(1); goto done; } else if (!strcasecmp(argv[0], "list")) { func = list_calls;

1 0

[commit] r8731 - freeswitch/trunk/src/mod/endpoints/mod_sofia
by Freeswitch SVN 30 May '08

30 May '08

Author: mikej Date: Fri May 30 16:29:32 2008 New Revision: 8731 Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Log: don't free reason string passed to nua_respond before we are done using it. (nh scope instead of session) Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.c Fri May 30 16:29:32 2008 @@ -988,7 +988,7 @@ } switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "Overlap Dial with %d %s\n", code, reason); - nua_respond(tech_pvt->nh, code, reason, TAG_IF(to_uri, SIPTAG_CONTACT_STR(to_uri)), + nua_respond(tech_pvt->nh, code, su_strdup(tech_pvt->nh->nh_home, reason), TAG_IF(to_uri, SIPTAG_CONTACT_STR(to_uri)), SIPTAG_SUPPORTED_STR(NULL), SIPTAG_ACCEPT_STR(NULL), TAG_IF(!switch_strlen_zero(max_forwards), SIPTAG_MAX_FORWARDS_STR(max_forwards)), TAG_END()); if (!switch_channel_test_flag(channel, CF_ANSWERED)) { @@ -1003,12 +1003,12 @@ sofia_glue_tech_patch_sdp(tech_pvt); sofia_glue_tech_proxy_remote_addr(tech_pvt); } - nua_respond(tech_pvt->nh, code, reason, SIPTAG_CONTACT_STR(tech_pvt->reply_contact), + nua_respond(tech_pvt->nh, code, su_strdup(tech_pvt->nh->nh_home, reason), SIPTAG_CONTACT_STR(tech_pvt->reply_contact), SOATAG_USER_SDP_STR(tech_pvt->local_sdp_str), SOATAG_REUSE_REJECTED(1), SOATAG_ORDERED_USER(1), SOATAG_AUDIO_AUX("cn telephone-event"), NUTAG_INCLUDE_EXTRA_SDP(1), TAG_END()); } else { - nua_respond(tech_pvt->nh, code, reason, SIPTAG_CONTACT_STR(tech_pvt->reply_contact), TAG_END()); + nua_respond(tech_pvt->nh, code, su_strdup(tech_pvt->nh->nh_home, reason), SIPTAG_CONTACT_STR(tech_pvt->reply_contact), TAG_END()); } if (!switch_channel_test_flag(channel, CF_ANSWERED) && code >= 300) { switch_set_flag_locked(tech_pvt, TFLAG_BYE); Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/mod_sofia.h Fri May 30 16:29:32 2008 @@ -91,6 +91,7 @@ #include <sofia-sip/su_log.h> #include <sofia-sip/nea.h> #include <sofia-sip/msg_addr.h> +#include "nua_stack.h" typedef enum { DTMF_2833, Modified: freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c ============================================================================== --- freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c (original) +++ freeswitch/trunk/src/mod/endpoints/mod_sofia/sofia_reg.c Fri May 30 16:29:32 2008 @@ -35,7 +35,6 @@ * */ #include "mod_sofia.h" -#include "nua_stack.h" static void sofia_reg_kill_reg(sofia_gateway_t *gateway_ptr, int unreg) {

1 0

[commit] r8730 - freeswitch/trunk/src
by Freeswitch SVN 30 May '08

30 May '08

Author: anthm Date: Fri May 30 14:11:05 2008 New Revision: 8730 Modified: freeswitch/trunk/src/switch_ivr_originate.c Log: add failed_xml_cdr magic variable Modified: freeswitch/trunk/src/switch_ivr_originate.c ============================================================================== --- freeswitch/trunk/src/switch_ivr_originate.c (original) +++ freeswitch/trunk/src/switch_ivr_originate.c Fri May 30 14:11:05 2008 @@ -1202,6 +1202,7 @@ } done: + *cause = SWITCH_CAUSE_UNALLOCATED; if (caller_channel && !switch_channel_ready(caller_channel)) { @@ -1216,8 +1217,18 @@ *cause = SWITCH_CAUSE_SUCCESS; } else { + const char *cdr_var = NULL; + int cdr_total = 0; + switch_xml_t cdr; + char *xml_text; + char buf[128] = "", buf2[128] = ""; + + if (caller_channel) { + cdr_var = switch_channel_get_variable(caller_channel, "failed_xml_cdr_prefix"); + } + if (peer_channel) { - *cause = switch_channel_get_cause(peer_channel); + *cause = switch_channel_get_cause(peer_channel); } else { for (i = 0; i < and_argc; i++) { if (!peer_channels[i]) { @@ -1227,6 +1238,28 @@ break; } } + + if (cdr_var) { + for (i = 0; i < and_argc; i++) { + if (!peer_sessions[i]) { + continue; + } + + if (switch_ivr_generate_xml_cdr(peer_sessions[i], &cdr) == SWITCH_STATUS_SUCCESS) { + if ((xml_text = switch_xml_toxml(cdr, SWITCH_FALSE))) { + switch_snprintf(buf, sizeof(buf), "%s_%d", cdr_var, ++cdr_total); + switch_channel_set_variable(caller_channel, buf, xml_text); + switch_safe_free(xml_text); + } + switch_xml_free(cdr); + cdr = NULL; + } + + } + switch_snprintf(buf, sizeof(buf), "%s_total", cdr_var); + switch_snprintf(buf2, sizeof(buf2), "%d", cdr_total ? cdr_total : 0); + switch_channel_set_variable(caller_channel, buf, buf2); + } if (!*cause) { if (reason) {

1 0