sofia_presence.c

Bug Summary

File:	src/mod/endpoints/mod_sofia/sofia_presence.c
Warning:	line 562, column 30 Null pointer passed as an argument to a 'nonnull' parameter
Annotated Source Code

Press '?' to see keyboard shortcuts
Show analyzer invocation
clang -cc1 -triple x86_64-pc-linux-gnu -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name sofia_presence.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-eagerly-assume -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -mrelocation-model pic -pic-level 2 -mthread-model posix -menable-no-infs -menable-no-nans -menable-unsafe-fp-math -fno-signed-zeros -mreassociate -freciprocal-math -fno-trapping-math -ffp-contract=fast -ffast-math -ffinite-math-only -masm-verbose -mconstructor-aliases -munwind-tables -fuse-init-array -target-cpu x86-64 -dwarf-column-info -debugger-tuning=gdb -momit-leaf-frame-pointer -resource-dir /usr/lib/llvm-7/lib/clang/7.0.1 -D HAVE_CONFIG_H -I . -I ../../../../src/include -I ../../../../libs/esl/src/include -I ../../../../libs/xmlrpc-c -I /drone/src/src/include -I /drone/src/src/include -I /drone/src/libs/libteletone/src -D SWITCH_API_VISIBILITY=1 -D CJSON_API_VISIBILITY=1 -D HAVE_VISIBILITY=1 -I /usr/include/uuid -I /drone/src/src/include -I /drone/src/src/include -I /drone/src/libs/libteletone/src -D SWITCH_API_VISIBILITY=1 -D CJSON_API_VISIBILITY=1 -D HAVE_VISIBILITY=1 -D HAVE_OPENSSL -I . -I /usr/include/sofia-sip-1.13 -D HAVE_STIRSHAKEN -D PIC -internal-isystem /usr/local/include -internal-isystem /usr/lib/llvm-7/lib/clang/7.0.1/include -internal-externc-isystem /usr/include/x86_64-linux-gnu -internal-externc-isystem /include -internal-externc-isystem /usr/include -O2 -Wno-unused-result -Wno-misleading-indentation -std=c99 -fdebug-compilation-dir /drone/src/src/mod/endpoints/mod_sofia -ferror-limit 19 -fmessage-length 0 -fvisibility hidden -fobjc-runtime=gcc -fdiagnostics-show-option -vectorize-loops -vectorize-slp -analyzer-output=html -o /drone/src/scan-build/2021-10-18-150934-401-1 -x c sofia_presence.c -faddrsig
1/*
* FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application
* Copyright (C) 2005-2014, 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.
*
* Contributor(s):
*
* Anthony Minessale II <anthm@freeswitch.org>
* Ken Rice <krice@freeswitch.org>
* Paul D. Tinsley <pdt at jackhammer.org>
* Bret McDanel <trixter AT 0xdecafbad.com>
* Raymond Chandler <intralanman@freeswitch.org>
* William King <william.king@quentustech.com>
* Emmanuel Schmidbauer <e.schmidbauer@gmail.com>
* David Knell <david.knell@telng.com>
*
* sofia_presence.c -- SOFIA SIP Endpoint (presence code)
*
*/
38#include "mod_sofia.h"
39#include "switch_stun.h"

41#define SUB_OVERLAP300 300
42struct state_helper {
switch_hash_t *hash;
sofia_profile_t *profile;
switch_memory_pool_t *pool;
int total;
47};


50static int sofia_presence_mwi_callback(void *pArg, int argc, char **argv, char **columnNames);
51static int sofia_presence_mwi_callback2(void *pArg, int argc, char **argv, char **columnNames);
52static int sofia_presence_sub_reg_callback(void *pArg, int argc, char **argv, char **columnNames);
53static int sofia_presence_resub_callback(void *pArg, int argc, char **argv, char **columnNames);
54static int sofia_presence_sub_callback(void *pArg, int argc, char **argv, char **columnNames);
55static int broadsoft_sla_gather_state_callback(void *pArg, int argc, char **argv, char **columnNames);
56static int broadsoft_sla_notify_callback(void *pArg, int argc, char **argv, char **columnNames);
57static int sync_sla(sofia_profile_t *profile, const char *to_user, const char *to_host, switch_bool_t clear, switch_bool_t unseize, const char *call_id);
58static int sofia_dialog_probe_callback(void *pArg, int argc, char **argv, char **columnNames);
59static int sofia_dialog_probe_notify_callback(void *pArg, int argc, char **argv, char **columnNames);

61struct pres_sql_cb {
sofia_profile_t *profile;
int ttl;
64};

66static int sofia_presence_send_sql(void *pArg, int argc, char **argv, char **columnNames);

68struct dialog_helper {
char state[128];
char status[512];
char rpid[512];
char presence_id[1024];
int hits;
74};

76struct resub_helper {
sofia_profile_t *profile;
switch_event_t *event;
int rowcount;
int noreg;
81};

83struct rfc4235_helper {
switch_hash_t *hash;
sofia_profile_t *profile;
switch_memory_pool_t *pool;
switch_event_t *event;
int rowcount;
89};

91struct presence_helper {
sofia_profile_t *profile;
switch_event_t *event;
switch_stream_handle_t stream;
char last_uuid[512];
int hup;
int calls_up;

99};

101switch_status_t sofia_presence_chat_send(switch_event_t *message_event)

103{
char *prof = NULL((void*)0), *user = NULL((void*)0), *host = NULL((void*)0);
sofia_profile_t *profile = NULL((void*)0);
char *ffrom = NULL((void*)0);
nua_handle_t *msg_nh;
char *contact = NULL((void*)0);
char *dup = NULL((void*)0);
switch_status_t status = SWITCH_STATUS_FALSE;
const char *ct = "text/html";
sofia_destination_t *dst = NULL((void*)0);
char *to_uri = NULL((void*)0);
switch_console_callback_match_t *list = NULL((void*)0);
switch_console_callback_match_node_t *m;
char *remote_ip = NULL((void*)0);
char *user_via = NULL((void*)0);
//char *contact_str = NULL;
char *dup_dest = NULL((void*)0);
char *p = NULL((void*)0);
char *remote_host = NULL((void*)0);
const char *proto;
const char *from;
const char *to;
//const char *subject;
const char *body;
const char *type;
const char *from_full;
char header[256] = "";
char *route_uri = NULL((void*)0);
const char *network_ip = NULL((void*)0), *network_port = NULL((void*)0), *from_proto;
char *extra_headers = NULL((void*)0);
char uuid_str[SWITCH_UUID_FORMATTED_LENGTH256 + 1];
int mstatus = 0, sanity = 0;
const char *blocking;
int is_blocking = 0;

proto = switch_event_get_header(message_event, "proto")switch_event_get_header_idx(message_event, "proto", -1);
from_proto = switch_event_get_header(message_event, "from_proto")switch_event_get_header_idx(message_event, "from_proto", -1);
from = switch_event_get_header(message_event, "from")switch_event_get_header_idx(message_event, "from", -1);
to = switch_event_get_header(message_event, "to")switch_event_get_header_idx(message_event, "to", -1);
//subject = switch_event_get_header(message_event, "subject");
body = switch_event_get_body(message_event);
type = switch_event_get_header(message_event, "type")switch_event_get_header_idx(message_event, "type", -1);
from_full = switch_event_get_header(message_event, "from_full")switch_event_get_header_idx(message_event, "from_full", -1);
blocking = switch_event_get_header(message_event, "blocking")switch_event_get_header_idx(message_event, "blocking", -1);
is_blocking = switch_true(blocking);

network_ip = switch_event_get_header(message_event, "to_sip_ip")switch_event_get_header_idx(message_event, "to_sip_ip", -1);
network_port = switch_event_get_header(message_event, "to_sip_port")switch_event_get_header_idx(message_event, "to_sip_port", -1);

extra_headers = sofia_glue_get_extra_headers_from_event(message_event, SOFIA_SIP_HEADER_PREFIX"sip_h_");

if (!to) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 155, ((void*)0), SWITCH_LOG_ERROR, "Missing To: header.\n");
goto end;
}

if (!from) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 160, ((void*)0), SWITCH_LOG_ERROR, "Missing From: header.\n");
goto end;
}

if (!zstr(type)_zstr(type)) {
ct = type;
}

dup = strdup(to);
switch_assert(dup)((dup) ? (void) (0) : __assert_fail ("dup", "sofia_presence.c"
, 169, __extension__ __PRETTY_FUNCTION__));
prof = dup;

/* Do we have a user of the form profile/user[@host]? */
if ((user = strchr(prof, '/'))) {
*user++ = '\0';
} else {
user = prof;
prof = NULL((void*)0);
}

if (!prof) {
prof = switch_event_get_header(message_event, "sip_profile")switch_event_get_header_idx(message_event, "sip_profile", -1);
}

if (!strncasecmp(user, "sip:", 4)) {
to_uri = user;
}

if ((host = strchr(user, '@'))) {
if (!to_uri) {
	*host++ = '\0';
} else {
	host++;
}
if (!prof) {
	prof = host;
}
}

if (!prof || !(profile = sofia_glue_find_profile(prof)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 199, prof))) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 200, ((void*)0), SWITCH_LOG_ERROR,
"Chat proto [%s]\nfrom [%s]\nto [%s]\n%s\nInvalid Profile %s\n", proto, from, to,
				  body ? body : "[no body]", prof ? prof : "NULL");
goto end;
}

if (zstr(host)_zstr(host)) {
host = profile->domain_name;
if (zstr(host)_zstr(host)) {
	host = prof;
}
}


if (to_uri) {
switch_console_push_match(&list, to_uri);
}  else if (!(list = sofia_reg_find_reg_url_multi(profile, user, host))) {
sofia_profile_t *test;

if ((test = sofia_glue_find_profile(host)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 219, host))) {
	sofia_glue_release_profile(test)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 220, test);
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 221, ((void*)0), SWITCH_LOG_WARNING, "Not sending to local box for %s@%s\n", user, host);
	/* our box let's not send it */
} else {
	char *tmp;
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 225, ((void*)0), SWITCH_LOG_DEBUG, "Can't find registered user %s@%s\n", user, host);
	tmp = switch_mprintf("sip:%s@%s", user, host);
	switch_console_push_match(&list, tmp);
	free(tmp);
}

}

if (!strcasecmp(proto, SOFIA_CHAT_PROTO"sip")) {
from = from_full;
} else {
char *fp, *p = NULL((void*)0);


fp = strdup(from);
switch_assert(fp)((fp) ? (void) (0) : __assert_fail ("fp", "sofia_presence.c",
 240, __extension__ __PRETTY_FUNCTION__));


if ((p = strchr(fp, '@'))) {
	*p++ = '\0';
}

if (zstr(p)_zstr(p)) {
	p = profile->domain_name;
	if (zstr(p)_zstr(p)) {
		p = host;
	}
}

if (switch_stristr("global", proto)) {
	if (!from_proto || !strcasecmp(from_proto, SOFIA_CHAT_PROTO"sip")) {
		ffrom = switch_mprintf("\"%s\" <sip:%s@%s>", fp, fp, p);
	} else {
		ffrom = switch_mprintf("\"%s\" <sip:%s+%s@%s>", fp, from_proto, fp, p);
	}

} else {
	ffrom = switch_mprintf("\"%s\" <sip:%s+%s@%s>", fp, from_proto ? from_proto : proto, fp, p);
}

from = ffrom;
switch_safe_free(fp)if (fp) {free(fp);fp=((void*)0);};
}

if (!list) {
switch_event_t *event;

switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 272, ((void*)0), SWITCH_LOG_ERROR,
"Chat proto [%s]\nfrom [%s]\nto [%s]\n%s\nNobody to send to: Profile %s\n", proto, from, to,
				  body ? body : "[no body]", prof);
// emit no recipient event
if (switch_event_create_subclass(&event, SWITCH_EVENT_CUSTOM, MY_EVENT_ERROR)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 276, &event, SWITCH_EVENT_CUSTOM
, "sofia::error") == SWITCH_STATUS_SUCCESS) {
	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Error-Type", "chat");
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Error-Reason", "no recipient");
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Chat-Send-To", to);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Chat-Send-From", from);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Chat-Send-Profile", prof);
	switch_event_add_body(event, "%s", body);
	switch_event_fire(&event)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 283, &event, ((void*)0));
}

goto end;
}

for (m = list->head; m; m = m->next) {

if (!(dst = sofia_glue_get_destination(m->val))) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 292, ((void*)0), SWITCH_LOG_CRIT, "Memory Error!\n");
	break;
}

/* sofia_glue is running sofia_overcome_sip_uri_weakness we do not, not sure if it matters */

if (dst->route_uri) {
	dup_dest = strdup(dst->route_uri);
} else  {
	dup_dest = strdup(dst->to);
}

switch_assert(dup_dest)((dup_dest) ? (void) (0) : __assert_fail ("dup_dest", "sofia_presence.c"
, 304, __extension__ __PRETTY_FUNCTION__));

remote_host = strdup(dup_dest);
if (!zstr(remote_host)_zstr(remote_host)) {
	switch_split_user_domain(remote_host, NULL((void*)0), &remote_ip);
}

if (!zstr(remote_ip)_zstr(remote_ip) && sofia_glue_check_nat(profile, remote_ip)) {
	char *ptr = NULL((void*)0);
	if ((ptr = sofia_glue_find_parameter(dst->contact, "transport="))) {
		sofia_transport_t transport = sofia_glue_str2transport( ptr + 10 );
		user_via = sofia_glue_create_external_via(NULL((void*)0), profile, transport);
	} else {
		user_via = sofia_glue_create_external_via(NULL((void*)0), profile, SOFIA_TRANSPORT_UDP);
	}
}

status = SWITCH_STATUS_SUCCESS;

if ((p = strstr(dup_dest, ";fs_"))) {
	*p = '\0';
}

/* if this cries, add contact here too, change the 1 to 0 and omit the safe_free */

//printf("DEBUG To: [%s] From: [%s] Contact: [%s] RURI [%s] ip [%s] port [%s]\n", to, from, contact, dst->route_uri, network_ip, network_port);

//DUMP_EVENT(message_event);

if (zstr(dst->route_uri)_zstr(dst->route_uri) && !zstr(user)_zstr(user) && !zstr(network_ip)_zstr(network_ip) && (zstr(host)_zstr(host) || strcmp(network_ip, host))) {
	route_uri = switch_mprintf("sip:%s@%s:%s", user, network_ip, network_port);
}

msg_nh = nua_handle(profile->nua, NULL((void*)0),
					TAG_END()(tag_type_t)0, (tag_value_t)0);

nua_handle_bind(msg_nh, &mod_sofia_globals.destroy_private);

switch_snprintf(header, sizeof(header), "X-FS-Sending-Message: %s", switch_core_get_uuid());

switch_uuid_str(uuid_str, sizeof(uuid_str));

if (is_blocking) {
	switch_mutex_lock(profile->flag_mutex);
	switch_core_hash_insert(profile->chat_hash, uuid_str, &mstatus)switch_core_hash_insert_destructor(profile->chat_hash, uuid_str
, &mstatus, ((void*)0));
	switch_mutex_unlock(profile->flag_mutex);
}

nua_message(msg_nh,
			TAG_IF(dst->route_uri, NUTAG_PROXY(dst->route_uri))!(dst->route_uri) ? tag_skip : ntatag_default_proxy, urltag_url_v
((dst->route_uri)),
			TAG_IF(route_uri, NUTAG_PROXY(route_uri))!(route_uri) ? tag_skip : ntatag_default_proxy, urltag_url_v(
(route_uri)),
			TAG_IF(dst->route, SIPTAG_ROUTE_STR(dst->route))!(dst->route) ? tag_skip : siptag_route_str, tag_str_v(dst
->route),
			SIPTAG_FROM_STR(from)siptag_from_str, tag_str_v(from),
			TAG_IF(contact, NUTAG_URL(contact))!(contact) ? tag_skip : nutag_url, urltag_url_v(contact),
			SIPTAG_TO_STR(dup_dest)siptag_to_str, tag_str_v(dup_dest),
			SIPTAG_CALL_ID_STR(uuid_str)siptag_call_id_str, tag_str_v(uuid_str),
			TAG_IF(user_via, SIPTAG_VIA_STR(user_via))!(user_via) ? tag_skip : siptag_via_str, tag_str_v(user_via),
			SIPTAG_CONTENT_TYPE_STR(ct)siptag_content_type_str, tag_str_v(ct),
			SIPTAG_PAYLOAD_STR(body)siptag_payload_str, tag_str_v(body),
			SIPTAG_HEADER_STR(header)siptag_header_str, tag_str_v((header)),
			TAG_IF(!zstr(extra_headers), SIPTAG_HEADER_STR(extra_headers))!(!_zstr(extra_headers)) ? tag_skip : siptag_header_str, tag_str_v
((extra_headers)),
			TAG_END()(tag_type_t)0, (tag_value_t)0);


if (is_blocking) {
	sanity = 200;

	while(!mstatus && --sanity && !nua_handle_is_destroyed(msg_nh)) {
		switch_yield(100000)switch_sleep(100000);;
	}

	if (!(mstatus > 199 && mstatus < 300)) {
		status = SWITCH_STATUS_FALSE;
	}

	switch_event_add_header(message_event, SWITCH_STACK_BOTTOM, "Delivery-Result-Code", "%d", mstatus);

	switch_mutex_lock(profile->flag_mutex);
	switch_core_hash_delete(profile->chat_hash, uuid_str);
	switch_mutex_unlock(profile->flag_mutex);
}

sofia_glue_free_destination(dst);
switch_safe_free(dup_dest)if (dup_dest) {free(dup_dest);dup_dest=((void*)0);};
switch_safe_free(user_via)if (user_via) {free(user_via);user_via=((void*)0);};
switch_safe_free(remote_host)if (remote_host) {free(remote_host);remote_host=((void*)0);};
}

end:

if (list) {
switch_console_free_matches(&list);
}

switch_safe_free(contact)if (contact) {free(contact);contact=((void*)0);};
switch_safe_free(route_uri)if (route_uri) {free(route_uri);route_uri=((void*)0);};
switch_safe_free(ffrom)if (ffrom) {free(ffrom);ffrom=((void*)0);};
switch_safe_free(dup)if (dup) {free(dup);dup=((void*)0);};

if (profile) {
switch_thread_rwlock_unlock(profile->rwlock);
}

return status;
408}

410void sofia_presence_cancel(void)
411{
char *sql;
sofia_profile_t *profile;
struct presence_helper helper = { 0 };
switch_console_callback_match_t *matches;
switch_bool_t r;

if (!mod_sofia_globals.profile_hash) {
return;
}

if (list_profiles_full(NULL((void*)0), NULL((void*)0), &matches, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
switch_console_callback_match_node_t *m;


for (m = matches->head; m; m = m->next) {
	if ((profile = sofia_glue_find_profile(m->val)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 427, m->val))) {
		if (profile->pres_type == PRES_TYPE_FULL) {
			helper.profile = profile;
			helper.event = NULL((void*)0);

			sql = switch_mprintf("select proto,sip_user,sip_host,sub_to_user,sub_to_host,event,contact,call_id,full_from,"
								 "full_via,expires,user_agent,accept,profile_name,network_ip"
								 ",-1,'unavailable','unavailable' from sip_subscriptions where "
								 "event='presence' and hostname='%q' and profile_name='%q'",
								 mod_sofia_globals.hostname, profile->name);

			r = sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_sub_callback, &helper);
			switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

			if (r != SWITCH_TRUE) {
				sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 442, profile);
				continue;
			}
		}
		sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 446, profile);
	}
}

switch_console_free_matches(&matches);

}
453}

455char *sofia_presence_translate_rpid(char *in, char *ext)
456{
char *r = in;

if (in && (switch_stristr("null", in))) {
in = NULL((void*)0);
}

if (!in) {
in = ext;
}

if (!in) {
return NULL((void*)0);
}

if (!strcasecmp(in, "dnd") || !strcasecmp(in, "idle")) {
r = "busy";
}

return r;
476}

478struct mwi_helper {
sofia_profile_t *profile;
int total;
481};

483static void actual_sofia_presence_mwi_event_handler(switch_event_t *event)
484{
char *account, *dup_account, *yn, *host, *user;
char *sql;
sofia_profile_t *profile = NULL((void*)0);
switch_stream_handle_t stream = { 0 };
switch_event_header_t *hp;
struct mwi_helper h = { 0 };
const char *pname = NULL((void*)0);
const char *call_id;
const char *sub_call_id;
int for_everyone = 0;

switch_assert(event != NULL)((event != ((void*)0)) ? (void) (0) : __assert_fail ("event != ((void*)0)"
, "sofia_presence.c", 496, __extension__ __PRETTY_FUNCTION__)
);

if (!(account = switch_event_get_header(event, "mwi-message-account")switch_event_get_header_idx(event, "mwi-message-account", -1))) {
14
←
Assuming 'account' is not null→
15
←
Taking false branch→
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 499, ((void*)0), SWITCH_LOG_ERROR, "Missing required Header 'MWI-Message-Account'\n");
return;
}

if (!(yn = switch_event_get_header(event, "mwi-messages-waiting")switch_event_get_header_idx(event, "mwi-messages-waiting", -1
))) {
16
←
Assuming 'yn' is not null→
17
←
Taking false branch→
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 504, ((void*)0), SWITCH_LOG_ERROR, "Missing required Header 'MWI-Messages-Waiting'\n");
return;
}

call_id = switch_event_get_header(event, "call-id")switch_event_get_header_idx(event, "call-id", -1);
sub_call_id = switch_event_get_header(event, "sub-call-id")switch_event_get_header_idx(event, "sub-call-id", -1);

if (!call_id && !sub_call_id) {
18
←
Assuming 'call_id' is non-null→
for_everyone = 1;
}


dup_account = strdup(account);
switch_assert(dup_account != NULL)((dup_account != ((void*)0)) ? (void) (0) : __assert_fail ("dup_account != ((void*)0)"
, "sofia_presence.c", 517, __extension__ __PRETTY_FUNCTION__)
);
switch_split_user_domain(dup_account, &user, &host);
19
←
Value assigned to 'host'→


if ((pname = switch_event_get_header(event, "sofia-profile")switch_event_get_header_idx(event, "sofia-profile", -1))) {
20
←
Assuming 'pname' is null→
21
←
Taking false branch→
profile = sofia_glue_find_profile(pname)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 522, pname);
}

if (!profile) {
22
←
Taking true branch→
if (!host || !(profile = sofia_glue_find_profile(host)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 526, host))) {
23
←
Assuming 'host' is null→
	char *sql;
	char buf[512] = "";
	switch_console_callback_match_t *matches;

	sql = switch_mprintf("select profile_name from sip_registrations where hostname='%q' and (sip_host='%q' or mwi_host='%q')",
						 mod_sofia_globals.hostname, host, host);

	if (list_profiles_full(NULL((void*)0), NULL((void*)0), &matches, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
24
←
Assuming the condition is false→
25
←
Taking false branch→
		switch_console_callback_match_node_t *m;

		for (m = matches->head; m; m = m->next) {
			if ((profile = sofia_glue_find_profile(m->val)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 538, m->val))) {

				sofia_glue_execute_sql2str(profile, profile->dbh_mutex, sql, buf, sizeof(buf));
				if (!zstr(buf)_zstr(buf)) {
					break;
				}
				sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 544, profile);
			}
		}

		switch_console_free_matches(&matches);
	}

	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

	if (!(profile = sofia_glue_find_profile(buf)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 553, buf))) {
26
←
Assuming 'profile' is not null→
27
←
Taking false branch→
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 554, ((void*)0), SWITCH_LOG_ERROR, "Cannot find profile %s\n", switch_str_nil(host)(host ? host : ""));
		switch_safe_free(dup_account)if (dup_account) {free(dup_account);dup_account=((void*)0);};
		return;
	}
}
}


if (profile->domain_name && strcasecmp(profile->domain_name, host)) {
28
←
Assuming the condition is true→
29
←
Null pointer passed as an argument to a 'nonnull' parameter
host = profile->domain_name;
}

h.profile = profile;
h.total = 0;

SWITCH_STANDARD_STREAM(stream)memset(&stream, 0, sizeof(stream)); stream.data = malloc(
1024); ((stream.data) ? (void) (0) : __assert_fail ("stream.data"
, "sofia_presence.c", 569, __extension__ __PRETTY_FUNCTION__)
); memset(stream.data, 0, 1024); stream.end = stream.data; stream
.data_size = 1024; stream.write_function = switch_console_stream_write
; stream.raw_write_function = switch_console_stream_raw_write
; stream.alloc_len = 1024; stream.alloc_chunk = 1024;

for (hp = event->headers; hp; hp = hp->next) {
if (!strncasecmp(hp->name, "mwi-", 4)) {
	char *tmp = NULL((void*)0);
	char *value = hp->value;
	if (!strcasecmp(hp->name, "mwi-message-account") && strncasecmp(hp->value, "sip:", 4)) {
		tmp = switch_mprintf("sip:%s", hp->value);
		value = tmp;
	}
	stream.write_function(&stream, "%s: %s\r\n", hp->name + 4, value);
	switch_safe_free(tmp)if (tmp) {free(tmp);tmp=((void*)0);};
}
}

stream.write_function(&stream, "\r\n");

sql = NULL((void*)0);

if (for_everyone) {
sql = switch_mprintf("select proto,sip_user,sip_host,sub_to_user,sub_to_host,event,contact,call_id,full_from,"
					 "full_via,expires,user_agent,accept,profile_name,network_ip"
					 ",'%q',full_to,network_ip,network_port from sip_subscriptions "
					 "where hostname='%q' and event='message-summary' "
					 "and sub_to_user='%q' and (sub_to_host='%q' or presence_hosts like '%%%q%%')",
					 stream.data, mod_sofia_globals.hostname, user, host, host);
} else if (sub_call_id) {
sql = switch_mprintf("select proto,sip_user,sip_host,sub_to_user,sub_to_host,event,contact,call_id,full_from,"
					 "full_via,expires,user_agent,accept,profile_name,network_ip"
					 ",'%q',full_to,network_ip,network_port from sip_subscriptions where "
					 "hostname='%q' and event='message-summary' "
					 "and sub_to_user='%q' and (sub_to_host='%q' or presence_hosts like '%%%q%%') and call_id='%q'",
					 stream.data, mod_sofia_globals.hostname, user, host, host, sub_call_id);
}


if (sql) {
sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_mwi_callback, &h);
free(sql);
sql = NULL((void*)0);

}

if (for_everyone) {
sql = switch_mprintf("select sip_user,sip_host,contact,profile_name,network_ip,'%q',call_id "
					 "from sip_registrations where hostname='%q' and mwi_user='%q' and mwi_host='%q'",
					 stream.data, mod_sofia_globals.hostname, user, host);
} else if (call_id) {
sql = switch_mprintf("select sip_user,sip_host,contact,profile_name,network_ip,'%q',call_id "
					 "from sip_registrations where hostname='%q' and call_id='%q'",
					 stream.data, mod_sofia_globals.hostname, call_id);
}

if (sql) {
switch_assert(sql != NULL)((sql != ((void*)0)) ? (void) (0) : __assert_fail ("sql != ((void*)0)"
, "sofia_presence.c", 623, __extension__ __PRETTY_FUNCTION__)
);
sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_mwi_callback2, &h);
free(sql);
sql = NULL((void*)0);
}

switch_safe_free(stream.data)if (stream.data) {free(stream.data);stream.data=((void*)0);};
switch_safe_free(dup_account)if (dup_account) {free(dup_account);dup_account=((void*)0);};
sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 631, profile);
632}

634static int sofia_presence_dialog_callback(void *pArg, int argc, char **argv, char **columnNames)
635{
struct dialog_helper *helper = (struct dialog_helper *) pArg;
switch_core_session_t *session = NULL((void*)0);
switch_channel_t *channel = NULL((void*)0);
int done = 0;

if (argc >= 4) {

if (argc == 5 && !zstr(argv[4])_zstr(argv[4])) {
	if ((session = switch_core_session_locate(argv[4])switch_core_session_perform_locate(argv[4], "sofia_presence.c"
, (const char *)__func__, 644))) {
		channel = switch_core_session_get_channel(session);

		if (!switch_channel_test_flag(channel, CF_ANSWERED) &&
			switch_true(switch_channel_get_variable_dup(channel, "presence_disable_early", SWITCH_FALSE, -1))) {
			done++;
		}

		switch_core_session_rwunlock(session);
	} else {
		return 0;
	}
}

if (done) {
	return 0;
}

if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 663, ((void*)0), SWITCH_LOG_CRIT, "CHECK DIALOG state[%s] status[%s] rpid[%s] pres[%s] uuid[%s]\n",
					  argv[0], argv[1], argv[2], argv[3], argv[4]);
}

if (!helper->hits) {
	switch_set_string(helper->state, argv[0])switch_copy_string(helper->state, argv[0], sizeof(helper->
state));
	switch_set_string(helper->status, argv[1])switch_copy_string(helper->status, argv[1], sizeof(helper->
status));
	switch_set_string(helper->rpid, argv[2])switch_copy_string(helper->rpid, argv[2], sizeof(helper->
rpid));
	switch_set_string(helper->presence_id, argv[3])switch_copy_string(helper->presence_id, argv[3], sizeof(helper
->presence_id));
}
helper->hits++;
}

return 0;
677}


680static void do_normal_probe(switch_event_t *event)
681{
char *sql;
struct resub_helper h = { 0 };
char *to = switch_event_get_header(event, "to")switch_event_get_header_idx(event, "to", -1);
char *proto = switch_event_get_header(event, "proto")switch_event_get_header_idx(event, "proto", -1);
char *profile_name = switch_event_get_header(event, "sip_profile")switch_event_get_header_idx(event, "sip_profile", -1);
char *probe_user = NULL((void*)0), *probe_euser, *probe_host, *p;
struct dialog_helper dh = { { 0 } };
char *sub_call_id = switch_event_get_header(event, "sub-call-id")switch_event_get_header_idx(event, "sub-call-id", -1);
sofia_profile_t *profile;

//DUMP_EVENT(event);

if (!proto || strcasecmp(proto, SOFIA_CHAT_PROTO"sip") != 0) {
return;
}

if (!to || !(probe_user = strdup(to))) {
return;
}

if ((probe_host = strchr(probe_user, '@'))) {
*probe_host++ = '\0';
}
probe_euser = probe_user;
if ((p = strchr(probe_euser, '+')) && p != probe_euser) {
probe_euser = (p + 1);
}

if (probe_host &&
((profile = sofia_glue_find_profile(probe_host)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 711, probe_host)) || (profile_name && (profile = sofia_glue_find_profile(profile_name)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 711, profile_name))))) {
sql = switch_mprintf("select state,status,rpid,presence_id,uuid from sip_dialogs "
					 "where hostname='%q' and profile_name='%q' and call_info_state != 'seized' and "
					 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') order by rcd desc",
					 mod_sofia_globals.hostname, profile->name, probe_euser, probe_host, probe_euser, probe_host);


sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_dialog_callback, &dh);

h.profile = profile;

switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

sql = switch_mprintf("select sip_registrations.sip_user, "
						 "sip_registrations.sub_host, "
						 "sip_registrations.status, "
						 "sip_registrations.rpid, "
						 "'', "
						 "sip_dialogs.uuid, "
						 "sip_dialogs.state, "
						 "sip_dialogs.direction, "
						 "sip_dialogs.sip_to_user, "
						 "sip_dialogs.sip_to_host, "

						 "sip_presence.status,"
						 "sip_presence.rpid,"
						 "sip_dialogs.presence_id, "
						 "sip_presence.open_closed,"
						 "'%q','%q','%q' "
						 "from sip_registrations "

						 "left join sip_dialogs on "
						 "sip_dialogs.hostname = sip_registrations.hostname and sip_dialogs.profile_name = sip_registrations.profile_name and ("
						 "sip_dialogs.presence_id = sip_registrations.sip_user %q '@' %q sip_registrations.sub_host "
						 "or (sip_dialogs.sip_from_user = sip_registrations.sip_user "
						 "and sip_dialogs.sip_from_host = sip_registrations.sip_host)) "

						 "left join sip_presence on "
						 "sip_presence.hostname=sip_registrations.hostname and "
						 "(sip_registrations.sip_user=sip_presence.sip_user and sip_registrations.orig_server_host=sip_presence.sip_host and "
						 "sip_registrations.profile_name=sip_presence.profile_name) "
						 "where sip_registrations.hostname='%q' and sip_registrations.profile_name='%q' and sip_dialogs.call_info_state != 'seized' "
						 "and sip_dialogs.presence_id='%q@%q' or (sip_registrations.sip_user='%q' and "
						 "(sip_registrations.orig_server_host='%q' or sip_registrations.sub_host='%q' "
						 "))",
						 dh.status, dh.rpid, switch_str_nil(sub_call_id)(sub_call_id ? sub_call_id : ""),
						 switch_sql_concat(), switch_sql_concat(),
						 mod_sofia_globals.hostname, profile->name, probe_euser, probe_host,  probe_euser, probe_host, probe_host);



switch_assert(sql)((sql) ? (void) (0) : __assert_fail ("sql", "sofia_presence.c"
, 762, __extension__ __PRETTY_FUNCTION__));

if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 765, ((void*)0), SWITCH_LOG_INFO, "%s START_PRESENCE_PROBE_SQL\n", profile->name);
}

if (mod_sofia_globals.debug_presence > 1) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 769, ((void*)0), SWITCH_LOG_ERROR, "%s DUMP PRESENCE_PROBE_SQL:\n%s\n", profile->name, sql);
}

sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_resub_callback, &h);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

if (!h.rowcount) {
	h.noreg++;

	/* find ones with presence_id defined that are not registred */
	sql = switch_mprintf("select sip_from_user, sip_from_host, 'Registered', '', '', "
						 "uuid, state, direction, "
						 "sip_to_user, sip_to_host,"
						 "'%q','%q',presence_id, '','','' "

						 "from sip_dialogs "

						 "where call_info_state != 'seized' and hostname='%q' and profile_name='%q' and (presence_id='%q@%q' or "
						 "(sip_from_user='%q' and (sip_from_host='%q' or sip_to_host='%q')))",
						 mod_sofia_globals.hostname, profile->name,
						 dh.status, dh.rpid, probe_euser, probe_host,  probe_euser, probe_host, probe_host);

	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 792, ((void*)0), SWITCH_LOG_INFO, "%s START_PRESENCE_PROBE_SQL\n", profile->name);
	}

	if (mod_sofia_globals.debug_presence > 1) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 796, ((void*)0), SWITCH_LOG_ERROR, "%s DUMP PRESENCE_PROBE_SQL:\n%s\n", profile->name, sql);
	}

	sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_resub_callback, &h);
	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 803, ((void*)0), SWITCH_LOG_INFO, "%s END_PRESENCE_PROBE_SQL\n\n", profile->name);
	}
}

if (!h.rowcount) {
	switch_event_t *sevent;
	if (switch_event_create(&sevent, SWITCH_EVENT_PRESENCE_IN)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 809, &sevent, SWITCH_EVENT_PRESENCE_IN
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "login", profile->name);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
		switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "from", "%s@%s", probe_euser, probe_host);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "status", "Unregistered");
		switch_event_fire(&sevent)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 815, &sevent, ((void*)0));
	}
}


sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 820, profile);
}


switch_safe_free(probe_user)if (probe_user) {free(probe_user);probe_user=((void*)0);};
825}

827static void do_dialog_probe(switch_event_t *event)
828{
// Received SUBSCRIBE for "dialog" events.
// Return a complete list of dialogs for the monitored entity.
char *sql;
char *to = switch_event_get_header(event, "to")switch_event_get_header_idx(event, "to", -1);
char *probe_user = NULL((void*)0), *probe_euser, *probe_host, *p;

if (!to || !(probe_user = strdup(to))) {
return;
}

if ((probe_host = strchr(probe_user, '@'))) {
*probe_host++ = '\0';
}
probe_euser = probe_user;
if ((p = strchr(probe_euser, '+')) && p != probe_euser) {
probe_euser = (p + 1);
}

if (probe_host) {
char *sub_call_id = switch_event_get_header(event, "sub-call-id")switch_event_get_header_idx(event, "sub-call-id", -1);
char *profile_name = switch_event_get_header(event, "sip_profile")switch_event_get_header_idx(event, "sip_profile", -1);
sofia_profile_t *profile = sofia_glue_find_profile(probe_host)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 850, probe_host);
struct rfc4235_helper *h4235 = {0};
switch_memory_pool_t *pool;

if (!profile && profile_name) {
	profile = sofia_glue_find_profile(profile_name)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 855, profile_name);
}

if (!profile) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 859, ((void*)0), SWITCH_LOG_WARNING, "Cannot find profile for domain %s\n", probe_host);
	goto end;
}

// We need all dialogs with presence_id matching the subscription entity,
// or from a registered set matching the subscription entity.
// We need the "proto" of the subscription in case it is for the special "conf" or "park".
sql = switch_mprintf(
					 "select sip_subscriptions.proto, '%q','%q',"
					 "sip_dialogs.uuid, sip_dialogs.call_id, sip_dialogs.state, sip_dialogs.direction, "
					 "sip_dialogs.sip_to_user, sip_dialogs.sip_to_host, "
					 "sip_dialogs.sip_from_user, sip_dialogs.sip_from_host, "
					 "sip_dialogs.contact, sip_dialogs.contact_user, sip_dialogs.contact_host, "
					 "sip_dialogs.sip_to_tag, sip_dialogs.sip_from_tag, sip_subscriptions.orig_proto "
					 "from sip_dialogs "
					 "left join sip_subscriptions on sip_subscriptions.hostname=sip_dialogs.hostname and "
					 "sip_subscriptions.profile_name=sip_dialogs.profile_name and "
					 "sip_subscriptions.call_id='%q' "
					 "left join sip_registrations on sip_registrations.hostname=sip_dialogs.hostname and "
					 "sip_registrations.profile_name=sip_dialogs.profile_name and "
					 "(sip_dialogs.sip_from_user = sip_registrations.sip_user and sip_dialogs.sip_from_host = '%q' and "
					 "(sip_dialogs.sip_from_host = sip_registrations.orig_server_host or "
					 "sip_dialogs.sip_from_host = sip_registrations.sip_host) ) "
					 "where sip_dialogs.hostname='%q' and sip_dialogs.profile_name='%q' and "
					 "sip_dialogs.call_info_state != 'seized' and sip_dialogs.presence_id='%q@%q' or (sip_registrations.sip_user='%q' and "
					 "(sip_registrations.orig_server_host='%q' or sip_registrations.sub_host='%q' "
					 "or sip_registrations.presence_hosts like '%%%q%%'))",
					 probe_euser, probe_host,
					 sub_call_id, probe_host,
					 mod_sofia_globals.hostname, profile->name,
					 probe_euser, probe_host,
					 probe_euser, probe_host, probe_host, probe_host);
switch_assert(sql)((sql) ? (void) (0) : __assert_fail ("sql", "sofia_presence.c"
, 891, __extension__ __PRETTY_FUNCTION__));

if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 894, ((void*)0),SWITCH_LOG_INFO, "%s START DIALOG_PROBE_SQL %s@%s\n", profile->name,probe_euser, probe_host);
}

if (mod_sofia_globals.debug_presence > 1) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 898, ((void*)0), SWITCH_LOG_DEBUG, "%s DUMP DIALOG_PROBE_SQL:\n%s\n", profile->name, sql);
}

switch_core_new_memory_pool(&pool)switch_core_perform_new_memory_pool(&pool, "sofia_presence.c"
, (const char *)__func__, 901);
h4235 = switch_core_alloc(pool, sizeof(*h4235))switch_core_perform_alloc(pool, sizeof(*h4235), "sofia_presence.c"
, (const char *)__func__, 902);
h4235->pool = pool;
h4235->profile = profile;
switch_core_hash_init(&h4235->hash)switch_core_hash_init_case(&h4235->hash, SWITCH_TRUE);
sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_dialog_probe_callback, h4235);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 909, ((void*)0), SWITCH_LOG_INFO, "%s END DIALOG_PROBE_SQL\n\n", profile->name);
}


sql = switch_mprintf("update sip_subscriptions set version=version+1 where call_id='%q'", sub_call_id);

if (mod_sofia_globals.debug_presence > 1) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 916, ((void*)0), SWITCH_LOG_DEBUG, "%s DUMP DIALOG_PROBE set version sql:\n%s\n", profile->name, sql);
}
sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};


// The dialog_probe_callback has built up the dialogs to be included in the NOTIFY.
// Now send the "full" dialog event to the triggering subscription.
sql = switch_mprintf("select call_id,expires,sub_to_user,sub_to_host,event,version, "
					 "'full',full_to,full_from,contact,network_ip,network_port "
					 "from sip_subscriptions "
					 "where hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and call_id='%q'",
					 mod_sofia_globals.hostname, profile->name, probe_euser, probe_host, sub_call_id);

if (mod_sofia_globals.debug_presence > 1) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 931, ((void*)0), SWITCH_LOG_DEBUG, "%s DUMP DIALOG_PROBE subscription sql:\n%s\n", profile->name, sql);
}

sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_dialog_probe_notify_callback, h4235);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 937, profile);
switch_core_hash_destroy(&h4235->hash);
h4235 = NULL((void*)0);
switch_core_destroy_memory_pool(&pool)switch_core_perform_destroy_memory_pool(&pool, "sofia_presence.c"
, (const char *)__func__, 940);
}

end:

switch_safe_free(probe_user)if (probe_user) {free(probe_user);probe_user=((void*)0);};
946}

948static void send_conference_data(sofia_profile_t *profile, switch_event_t *event)
949{
char *sql;
struct pres_sql_cb cb = {profile, 0};
const char *call_id = switch_event_get_header(event, "call_id")switch_event_get_header_idx(event, "call_id", -1);
const char *from_user = switch_event_get_header(event, "conference-name")switch_event_get_header_idx(event, "conference-name", -1);
const char *from_host = switch_event_get_header(event, "conference-domain")switch_event_get_header_idx(event, "conference-domain", -1);
const char *event_str = switch_event_get_header(event, "conference-event")switch_event_get_header_idx(event, "conference-event", -1);
const char *notfound = switch_event_get_header(event, "notfound")switch_event_get_header_idx(event, "notfound", -1);
const char *body = switch_event_get_body(event);
const char *type = "application/conference-info+xml";
const char *final = switch_event_get_header(event, "final")switch_event_get_header_idx(event, "final", -1);

if (!event_str) {
event_str = "conference";
}

if (!strcasecmp(event_str, "refer")) {
type = "message/sipfrag";
}


if (!(from_user && from_host)) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 971, ((void*)0), SWITCH_LOG_ERROR, "Event information not given\n");
return;
}

if (switch_true(notfound)) {
sql = switch_mprintf("update sip_subscriptions set expires=%ld where "
					 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q'",
					 (long)switch_epoch_time_now(NULL((void*)0)),
					 mod_sofia_globals.hostname, profile->name,
					 from_user, from_host, event_str);

sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
}

if (call_id) {
  if (switch_true(final)) {
  sql = switch_mprintf("update sip_subscriptions set expires=%ld where "
					  "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q' "
					   "and call_id = '%q' ",
					   (long)0,
					   mod_sofia_globals.hostname, profile->name,
					   from_user, from_host, event_str, call_id);

  sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
  }

sql = switch_mprintf("select full_to, full_from, contact %q ';_;isfocus', expires, call_id, event, network_ip, network_port, "
					 "'%q' as ct,'%q' as pt "
					 " from sip_subscriptions where "
					 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q' "
					 "and call_id = '%q' ",
					 switch_sql_concat(),
					 type,
					 switch_str_nil(body)(body ? body : ""),
					 mod_sofia_globals.hostname, profile->name,
					 from_user, from_host, event_str, call_id);
} else {
 if (switch_true(final)) {
 sql = switch_mprintf("update sip_subscriptions set expires=%ld where "
					  "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q'",
					  (long)0,
					  mod_sofia_globals.hostname, profile->name,
					  from_user, from_host, event_str);

 sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
 }

sql = switch_mprintf("select full_to, full_from, contact %q ';_;isfocus', expires, call_id, event, network_ip, network_port, "
					 "'%q' as ct,'%q' as pt "
					 " from sip_subscriptions where "
					 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q'",
					 switch_sql_concat(),
					 type,
					 switch_str_nil(body)(body ? body : ""),
					 mod_sofia_globals.hostname, profile->name,
					 from_user, from_host, event_str);
}

sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_send_sql, &cb);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

if (switch_true(final)) {
if (call_id) {
	sql = switch_mprintf("delete from sip_subscriptions where "
						 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q' "
						 "and call_id = '%q' ",
						 mod_sofia_globals.hostname, profile->name,
						 from_user, from_host, event_str, call_id);

} else {
	sql = switch_mprintf("delete from sip_subscriptions where "
						 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q'",
						 mod_sofia_globals.hostname, profile->name,
						 from_user, from_host, event_str);
}

sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
}


1051}

1053static void conference_data_event_handler(switch_event_t *event)
1054{
const char *pname;
//const char *from_user = switch_event_get_header(event, "conference-name");
//const char *from_host = switch_event_get_header(event, "conference-domain");
const char *host = switch_event_get_header(event, "conference-domain")switch_event_get_header_idx(event, "conference-domain", -1);
char *dup_domain = NULL((void*)0);
sofia_profile_t *profile = NULL((void*)0);

if (zstr(host)_zstr(host)) {
dup_domain = switch_core_get_domain(SWITCH_TRUE);
host = dup_domain;
}

if ((pname = switch_event_get_header(event, "sofia-profile")switch_event_get_header_idx(event, "sofia-profile", -1))) {
profile = sofia_glue_find_profile(pname)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 1068, pname);
}

if (host && !profile) {
profile = sofia_glue_find_profile(host)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 1072, host);
}

if (profile) {
send_conference_data(profile, event);
sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1077, profile);
} else {
switch_console_callback_match_t *matches;

if (list_profiles_full(NULL((void*)0), NULL((void*)0), &matches, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
	switch_console_callback_match_node_t *m;

	for (m = matches->head; m; m = m->next) {
		if ((profile = sofia_glue_find_profile(m->val)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 1085, m->val))) {
			send_conference_data(profile, event);
			sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1087, profile);
		}
	}

	switch_console_free_matches(&matches);
}
}

switch_safe_free(dup_domain)if (dup_domain) {free(dup_domain);dup_domain=((void*)0);};
1096}

1098static switch_event_t *actual_sofia_presence_event_handler(switch_event_t *event)
1099{
sofia_profile_t *profile = NULL((void*)0);
char *from = switch_event_get_header(event, "from")switch_event_get_header_idx(event, "from", -1);
char *proto = switch_event_get_header(event, "proto")switch_event_get_header_idx(event, "proto", -1);
char *rpid = switch_event_get_header(event, "rpid")switch_event_get_header_idx(event, "rpid", -1);
char *status = switch_event_get_header(event, "status")switch_event_get_header_idx(event, "status", -1);
char *event_type = switch_event_get_header(event, "event_type")switch_event_get_header_idx(event, "event_type", -1);
char *alt_event_type = switch_event_get_header(event, "alt_event_type")switch_event_get_header_idx(event, "alt_event_type", -1);
//char *event_subtype = switch_event_get_header(event, "event_subtype");
char *sql = NULL((void*)0);
char *euser = NULL((void*)0), *user = NULL((void*)0), *host = NULL((void*)0);
char *call_info = switch_event_get_header(event, "presence-call-info")switch_event_get_header_idx(event, "presence-call-info", -1);
char *call_id = switch_event_get_header(event, "call-id")switch_event_get_header_idx(event, "call-id", -1);
char *presence_source = switch_event_get_header(event, "presence-source")switch_event_get_header_idx(event, "presence-source", -1);
char *call_info_state = switch_event_get_header(event, "presence-call-info-state")switch_event_get_header_idx(event, "presence-call-info-state"
, -1);
const char *uuid = switch_event_get_header(event, "unique-id")switch_event_get_header_idx(event, "unique-id", -1);
switch_console_callback_match_t *matches = NULL((void*)0);
struct presence_helper helper = { 0 };
int hup = 0;
switch_event_t *s_event = NULL((void*)0);

if (!mod_sofia_globals.running) {
goto done;
}

if (zstr(proto)_zstr(proto) || !strcasecmp(proto, "any")) {
proto = SOFIA_CHAT_PROTO"sip";
}

//DUMP_EVENT(event);

if (rpid && !strcasecmp(rpid, "n/a")) {
rpid = NULL((void*)0);
}

if (status && !strcasecmp(status, "n/a")) {
status = NULL((void*)0);
}

if (!zstr(uuid)_zstr(uuid) && !switch_ivr_uuid_exists(uuid)) {
status = "CS_HANGUP";
}


if ((status && switch_stristr("CS_HANGUP", status)) || (!zstr(uuid)_zstr(uuid) && !switch_ivr_uuid_exists(uuid))) {
status = "Available";
hup = 1;
}

if (rpid) {
rpid = sofia_presence_translate_rpid(rpid, status);
}

if (event->event_id == SWITCH_EVENT_ROSTER) {
if (list_profiles_full(NULL((void*)0), NULL((void*)0), &matches, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
	switch_console_callback_match_node_t *m;

	for (m = matches->head; m; m = m->next) {
		if ((profile = sofia_glue_find_profile(m->val)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 1157, m->val))) {
			if (profile->pres_type != PRES_TYPE_FULL) {


				if (!mod_sofia_globals.profile_hash) {
					switch_console_free_matches(&matches);
					sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1163, profile);
					goto done;
				}

				if (from) {

					sql = switch_mprintf("update sip_subscriptions set version=version+1 where hostname='%q' and profile_name='%q' and "
										 "sip_subscriptions.event='presence' and sip_subscriptions.full_from like '%%%q%%'",
										 mod_sofia_globals.hostname, profile->name, from);

					if (mod_sofia_globals.debug_presence > 1) {
						switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1174, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
					}

					sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);


					sql = switch_mprintf("select sip_subscriptions.proto,sip_subscriptions.sip_user,sip_subscriptions.sip_host,"
										 "sip_subscriptions.sub_to_user,sip_subscriptions.sub_to_host,sip_subscriptions.event,"
										 "sip_subscriptions.contact,sip_subscriptions.call_id,sip_subscriptions.full_from,"
										 "sip_subscriptions.full_via,sip_subscriptions.expires,sip_subscriptions.user_agent,"
										 "sip_subscriptions.accept,sip_subscriptions.profile_name,sip_subscriptions.network_ip"
										 ",1,'%q','%q',sip_presence.status,sip_presence.rpid,sip_presence.open_closed,'','','','','sip',"
										 " sip_subscriptions.full_to,sip_subscriptions.network_ip,sip_subscriptions.network_port "
										 "from sip_subscriptions left join sip_presence on "
										 "(sip_subscriptions.sub_to_user=sip_presence.sip_user and "
										 "sip_subscriptions.sub_to_host=sip_presence.sip_host and "
										 "sip_subscriptions.profile_name=sip_presence.profile_name and "
										 "sip_presence.profile_name=sip_subscriptions.profile_name) "
										 "where sip_subscriptions.hostname='%q' and sip_subscriptions.profile_name='%q' and "
										 "sip_subscriptions.event='presence' and sip_subscriptions.full_from like '%%%q%%'",
										 switch_str_nil(status)(status ? status : ""), switch_str_nil(rpid)(rpid ? rpid : ""), mod_sofia_globals.hostname, profile->name, from);
				} else {

					sql = switch_mprintf("update sip_subscriptions set version=version+1 where hostname='%q' and profile_name='%q' and "
										 "sip_subscriptions.event='presence'", mod_sofia_globals.hostname, profile->name);

					if (mod_sofia_globals.debug_presence > 1) {
						switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1201, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
					}

					sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);

					sql = switch_mprintf("select sip_subscriptions.proto,sip_subscriptions.sip_user,sip_subscriptions.sip_host,"
										 "sip_subscriptions.sub_to_user,sip_subscriptions.sub_to_host,sip_subscriptions.event,"
										 "sip_subscriptions.contact,sip_subscriptions.call_id,sip_subscriptions.full_from,"
										 "sip_subscriptions.full_via,sip_subscriptions.expires,sip_subscriptions.user_agent,"
										 "sip_subscriptions.accept,sip_subscriptions.profile_name,sip_subscriptions.network_ip"
										 ",1,'%q','%q',sip_presence.status,sip_presence.rpid,sip_presence.open_closed,'','','','','sip',"
										 "sip_subscriptions.full_to,sip_subscriptions.network_ip,sip_subscriptions.network_port "
										 "from sip_subscriptions left join sip_presence on "
										 "(sip_subscriptions.sub_to_user=sip_presence.sip_user and "
										 "sip_subscriptions.sub_to_host=sip_presence.sip_host and "
										 "sip_subscriptions.profile_name=sip_presence.profile_name and "
										 "sip_subscriptions.hostname = sip_presence.hostname) "
										 "where sip_subscriptions.hostname='%q' and sip_subscriptions.profile_name='%q' and "
										 "sip_subscriptions.event='presence'", switch_str_nil(status)(status ? status : ""),
										 switch_str_nil(rpid)(rpid ? rpid : ""), mod_sofia_globals.hostname, profile->name);
				}

				switch_assert(sql != NULL)((sql != ((void*)0)) ? (void) (0) : __assert_fail ("sql != ((void*)0)"
, "sofia_presence.c", 1223, __extension__ __PRETTY_FUNCTION__
));


				if (mod_sofia_globals.debug_presence > 0) {
					switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1227, ((void*)0), SWITCH_LOG_WARNING, "%s is passive, skipping\n", (char *) profile->name);
				}
				sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1229, profile);
				continue;
			}
			memset(&helper, 0, sizeof(helper));
			helper.profile = profile;
			helper.event = NULL((void*)0);
			sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_sub_callback, &helper);
			switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
			sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1237, profile);
		}
	}
	switch_console_free_matches(&matches);
}

switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
goto done;
}

if (zstr(event_type)_zstr(event_type)) {
event_type = "presence";
}

if (zstr(alt_event_type)_zstr(alt_event_type)) {
if (!strcasecmp(event_type, "presence")) {
	alt_event_type = "dialog";
} else {
	alt_event_type = "presence";
}
}

if (from && (user = strdup(from))) {
if ((host = strchr(user, '@'))) {
	char *p;
	*host++ = '\0';
	if ((p = strchr(host, '/'))) {
		*p = '\0';
	}
} else {
	switch_safe_free(user)if (user) {free(user);user=((void*)0);};
	goto done;
}
if ((euser = strchr(user, '+')) && euser != user) {
	euser++;
} else {
	euser = user;
}
} else {
goto done;
}

switch (event->event_id) {
case SWITCH_EVENT_PRESENCE_PROBE:
{
	char *probe_type = switch_event_get_header(event, "probe-type")switch_event_get_header_idx(event, "probe-type", -1);

	if (!probe_type || strcasecmp(probe_type, "dialog")) {
		/* NORMAL PROBE */
		do_normal_probe(event);
	} else {
		/* DIALOG PROBE */
		do_dialog_probe(event);
	}
}
goto done;

default:
break;
}

if (!mod_sofia_globals.profile_hash) {
goto done;
}

if (list_profiles_full(NULL((void*)0), NULL((void*)0), &matches, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) {
switch_console_callback_match_node_t *m;

for (m = matches->head; m; m = m->next) {
	struct dialog_helper dh = { { 0 } };

	if ((profile = sofia_glue_find_profile(m->val)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 1308, m->val))) {
		if (profile->pres_type != PRES_TYPE_FULL) {
			if (mod_sofia_globals.debug_presence > 0) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1311, ((void*)0), SWITCH_LOG_WARNING, "%s is passive, skipping\n", (char *) profile->name);
			}
			sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1313, profile);
			continue;
		}


		if (mod_sofia_globals.debug_sla > 1) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1319, ((void*)0), SWITCH_LOG_ERROR, "SLA EVENT:\n");
			DUMP_EVENT(event){char *event_str;switch_event_serialize(event, &event_str
, SWITCH_FALSE);switch_log_printf(SWITCH_CHANNEL_ID_LOG, "sofia_presence.c"
, (const char *)__func__, 1320, ((void*)0), SWITCH_LOG_CRIT, "DUMP\n%s\n"
, event_str);free(event_str);};

			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1322, ((void*)0), SWITCH_LOG_ERROR, "CHECK CALL_INFO [%s]\n", switch_str_nil(call_info)(call_info ? call_info : ""));
		}

		if (call_info) {

			if (uuid) {
				sql = switch_mprintf("update sip_dialogs set call_info='%q',call_info_state='%q' where "
									 "hostname='%q' and profile_name='%q' and uuid='%q'",
									 call_info, call_info_state, mod_sofia_globals.hostname, profile->name, uuid);
			} else {
				sql = switch_mprintf("update sip_dialogs set call_info='%q', call_info_state='%q' where hostname='%q' and profile_name='%q' and "
									 "((sip_dialogs.sip_from_user='%q' and sip_dialogs.sip_from_host='%q') or presence_id='%q@%q') and call_info='%q'",

									 call_info, call_info_state, mod_sofia_globals.hostname, profile->name, euser, host, euser, host, call_info);

			}

			if (mod_sofia_globals.debug_sla > 1) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1340, ((void*)0), SWITCH_LOG_ERROR, "STATE SQL %s\n", sql);
			}
			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);



			if (mod_sofia_globals.debug_sla > 1) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1347, ((void*)0), SWITCH_LOG_ERROR, "PROCESS PRESENCE EVENT\n");
			}

			sync_sla(profile, euser, host, SWITCH_TRUE, SWITCH_TRUE, call_id);
		}

		if (!strcmp(proto, "dp")) {
			sql = switch_mprintf("update sip_presence set rpid='%q',status='%q' where hostname='%q' and profile_name='%q' and "
								 "sip_user='%q' and sip_host='%q'",
								 rpid, status, mod_sofia_globals.hostname, profile->name, euser, host);
			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
			proto = SOFIA_CHAT_PROTO"sip";
		}

		if (zstr(uuid)_zstr(uuid)) {

			sql = switch_mprintf("select state,status,rpid,presence_id,uuid from sip_dialogs "
								 "where call_info_state != 'seized' and hostname='%q' and profile_name='%q' and "
								 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') order by rcd desc",
								 mod_sofia_globals.hostname, profile->name, euser, host, euser, host);
		} else {
			sql = switch_mprintf("select state,status,rpid,presence_id,uuid from sip_dialogs "
								 "where uuid != '%q' and call_info_state != 'seized' and hostname='%q' and profile_name='%q' and "
								 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') order by rcd desc",
								 uuid, mod_sofia_globals.hostname, profile->name, euser, host, euser, host);
		}

		sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_dialog_callback, &dh);

		if (mod_sofia_globals.debug_presence > 0) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1377, ((void*)0), SWITCH_LOG_CRIT, "CHECK SQL: %s@%s [%s]\nhits: %d\n", euser, host, sql, dh.hits);
		}

		switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

		if (hup && dh.hits > 0) {
			/* sigh, mangle this packet to simulate a call that is up instead of hungup */
			hup = 0;
			event->flags |= EF_UNIQ_HEADERS;

			if (!strcasecmp(dh.state, "early")) {
				status = "CS_ROUTING";
				if (rpid) {
					rpid = sofia_presence_translate_rpid(rpid, status);
				}

				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Answer-State", "early");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "status", status);
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Channel-State", status);
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Channel-Call-State", "EARLY");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "astate", "early");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "answer-state", "early");
			} else {
				status = "CS_EXECUTE";
				if (rpid) {
					rpid = sofia_presence_translate_rpid(rpid, status);
				}

				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Answer-State", "answered");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "status", status);
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Channel-State", status);
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Channel-Call-State", "ACTIVE");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "astate", "confirmed");
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "answer-state", "confirmed");
			}
		}



		if (zstr(call_id)_zstr(call_id) && (dh.hits && presence_source && (!strcasecmp(presence_source, "register") || switch_stristr("register", status)))) {
			sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1417, profile);
			goto done;
		}

		if (zstr(call_id)_zstr(call_id)) {

			sql = switch_mprintf("update sip_subscriptions set version=version+1 where hostname='%q' and profile_name='%q' and "
								 "sip_subscriptions.event != 'line-seize' "
								 "and sip_subscriptions.proto='%q' and (event='%q' or event='%q') and sub_to_user='%q' and "
								 "(sub_to_host='%q' or sub_to_host='%q' or sub_to_host='%q' or "
								 "presence_hosts like '%%%q%%') and "
								 "(sip_subscriptions.profile_name = '%q' or presence_hosts like '%%%q%%')",
								 mod_sofia_globals.hostname, profile->name,
								 proto, event_type, alt_event_type, euser, host, profile->sipip,
								 profile->extsipip ? profile->extsipip : "N/A", host, profile->name, host);


			if (mod_sofia_globals.debug_presence > 1) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1435, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
			}

			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);



			sql = switch_mprintf("select distinct sip_subscriptions.proto,sip_subscriptions.sip_user,sip_subscriptions.sip_host,"
								 "sip_subscriptions.sub_to_user,sip_subscriptions.sub_to_host,sip_subscriptions.event,"
								 "sip_subscriptions.contact,sip_subscriptions.call_id,sip_subscriptions.full_from,"
								 "sip_subscriptions.full_via,sip_subscriptions.expires,sip_subscriptions.user_agent,"
								 "sip_subscriptions.accept,sip_subscriptions.profile_name"
								 ",'%q','%q','%q',sip_presence.status,sip_presence.rpid,sip_presence.open_closed,'%q','%q',"
								 "sip_subscriptions.version, '%q',sip_subscriptions.orig_proto,sip_subscriptions.full_to,"
								 "sip_subscriptions.network_ip, sip_subscriptions.network_port "
								 "from sip_subscriptions "
								 "left join sip_presence on "
								 "(sip_subscriptions.sub_to_user=sip_presence.sip_user and sip_subscriptions.sub_to_host=sip_presence.sip_host and "
								 "sip_subscriptions.profile_name=sip_presence.profile_name and sip_subscriptions.hostname=sip_presence.hostname) "

								 "where sip_subscriptions.hostname='%q' and sip_subscriptions.profile_name='%q' and "
								 "sip_subscriptions.event != 'line-seize' and "
								 "sip_subscriptions.proto='%q' and "
								 "(event='%q' or event='%q') and sub_to_user='%q' "
								 "and (sub_to_host='%q' or sub_to_host='%q' or sub_to_host='%q' or presence_hosts like '%%%q%%') ",


								 switch_str_nil(status)(status ? status : ""), switch_str_nil(rpid)(rpid ? rpid : ""), host,
								 dh.status,dh.rpid,dh.presence_id, mod_sofia_globals.hostname, profile->name, proto,
								 event_type, alt_event_type, euser, host, profile->sipip,
								 profile->extsipip ? profile->extsipip : "N/A", host);
		} else {

			sql = switch_mprintf("update sip_subscriptions set version=version+1 where sip_subscriptions.event != 'line-seize' and "
								 "sip_subscriptions.call_id='%q'", call_id);



			if (mod_sofia_globals.debug_presence > 1) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1474, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
			}

			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);


			sql = switch_mprintf("select distinct sip_subscriptions.proto,sip_subscriptions.sip_user,sip_subscriptions.sip_host,"
								 "sip_subscriptions.sub_to_user,sip_subscriptions.sub_to_host,sip_subscriptions.event,"
								 "sip_subscriptions.contact,sip_subscriptions.call_id,sip_subscriptions.full_from,"
								 "sip_subscriptions.full_via,sip_subscriptions.expires,sip_subscriptions.user_agent,"
								 "sip_subscriptions.accept,sip_subscriptions.profile_name"
								 ",'%q','%q','%q',sip_presence.status,sip_presence.rpid,sip_presence.open_closed,'%q','%q',"
								 "sip_subscriptions.version, '%q',sip_subscriptions.orig_proto,sip_subscriptions.full_to,"
								 "sip_subscriptions.network_ip, sip_subscriptions.network_port "
								 "from sip_subscriptions "
								 "left join sip_presence on "
								 "(sip_subscriptions.sub_to_user=sip_presence.sip_user and sip_subscriptions.sub_to_host=sip_presence.sip_host and "
								 "sip_subscriptions.profile_name=sip_presence.profile_name and sip_subscriptions.hostname=sip_presence.hostname) "

								 "where sip_subscriptions.hostname='%q' and sip_subscriptions.profile_name='%q' and "
								 "sip_subscriptions.event != 'line-seize' and "
								 "sip_subscriptions.call_id='%q'",

								 switch_str_nil(status)(status ? status : ""), switch_str_nil(rpid)(rpid ? rpid : ""), host,
								 dh.status,dh.rpid,dh.presence_id, mod_sofia_globals.hostname, profile->name, call_id);

		}

		helper.hup = hup;
		helper.calls_up = dh.hits;
		helper.profile = profile;
		helper.event = event;
		SWITCH_STANDARD_STREAM(helper.stream)memset(&helper.stream, 0, sizeof(helper.stream)); helper.
stream.data = malloc(1024); ((helper.stream.data) ? (void) (0
) : __assert_fail ("helper.stream.data", "sofia_presence.c", 1506
, __extension__ __PRETTY_FUNCTION__)); memset(helper.stream.data
, 0, 1024); helper.stream.end = helper.stream.data; helper.stream
.data_size = 1024; helper.stream.write_function = switch_console_stream_write
; helper.stream.raw_write_function = switch_console_stream_raw_write
; helper.stream.alloc_len = 1024; helper.stream.alloc_chunk =
 1024;
		switch_assert(helper.stream.data)((helper.stream.data) ? (void) (0) : __assert_fail ("helper.stream.data"
, "sofia_presence.c", 1507, __extension__ __PRETTY_FUNCTION__
));

		if (mod_sofia_globals.debug_presence > 0) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1510, ((void*)0), SWITCH_LOG_INFO, "%s START_PRESENCE_SQL (%s)\n",
							  event->event_id == SWITCH_EVENT_PRESENCE_IN ? "IN" : "OUT", profile->name);
		}

		if (mod_sofia_globals.debug_presence) {
			char *buf;
			switch_event_serialize(event, &buf, SWITCH_FALSE);
			switch_assert(buf)((buf) ? (void) (0) : __assert_fail ("buf", "sofia_presence.c"
, 1517, __extension__ __PRETTY_FUNCTION__));
			if (mod_sofia_globals.debug_presence > 1) {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1519, ((void*)0), SWITCH_LOG_ERROR, "DUMP PRESENCE SQL:\n%s\nEVENT DUMP:\n%s\n", sql, buf);
			} else {
				switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1521, ((void*)0), SWITCH_LOG_ERROR, "EVENT DUMP:\n%s\n", buf);
			}
			free(buf);
		}

		sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_sub_callback, &helper);
		switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

		if (mod_sofia_globals.debug_presence > 0) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1530, ((void*)0), SWITCH_LOG_INFO, "%s END_PRESENCE_SQL (%s)\n",
							  event->event_id == SWITCH_EVENT_PRESENCE_IN ? "IN" : "OUT", profile->name);
		}

1534#if 0
		if (hup && dh.hits < 1) {
			/* so many phones get confused when whe hangup we have to reprobe to get them all to reset to absolute states so the lights stay correct */
			if (switch_event_create(&s_event, SWITCH_EVENT_PRESENCE_PROBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 1537, &s_event, SWITCH_EVENT_PRESENCE_PROBE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
				switch_event_add_header_string(s_event, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
				switch_event_add_header_string(s_event, SWITCH_STACK_BOTTOM, "login", profile->name);
				switch_event_add_header_string(s_event, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
				switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "from", "%s@%s", euser, host);
				switch_event_add_header(s_event, SWITCH_STACK_BOTTOM, "to", "%s@%s", euser, host);
				switch_event_add_header_string(s_event, SWITCH_STACK_BOTTOM, "event_type", "presence");
				switch_event_add_header_string(s_event, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog");
				sofia_event_fire(profile, &s_event);
			}
		}
1548#endif

		if (!zstr((char *) helper.stream.data)_zstr((char *) helper.stream.data)) {
			char *this_sql = (char *) helper.stream.data;
			char *next = NULL((void*)0);
			char *last = NULL((void*)0);

			do {
				if ((next = strchr(this_sql, ';'))) {
					*next++ = '\0';
					while (*next == '\n' || *next == ' ' || *next == '\r') {
						*next++ = '\0';
					}
				}

				if (!zstr(this_sql)_zstr(this_sql) && (!last || strcmp(last, this_sql))) {
					sofia_glue_execute_sql(profile, &this_sql, SWITCH_FALSE);
					last = this_sql;
				}
				this_sql = next;
			} while (this_sql);
		}
		switch_safe_free(helper.stream.data)if (helper.stream.data) {free(helper.stream.data);helper.stream
.data=((void*)0);};
		helper.stream.data = NULL((void*)0);

		sofia_glue_release_profile(profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 1573, profile);
	}
}
switch_console_free_matches(&matches);
}

done:

switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
switch_safe_free(user)if (user) {free(user);user=((void*)0);};

return s_event;
1585}

1587static int EVENT_THREAD_RUNNING = 0;
1588static int EVENT_THREAD_STARTED = 0;

1590static void do_flush(void)
1591{
void *pop = NULL((void*)0);

while (mod_sofia_globals.presence_queue && switch_queue_trypop(mod_sofia_globals.presence_queue, &pop) == SWITCH_STATUS_SUCCESS && pop) {
switch_event_t *event = (switch_event_t *) pop;
switch_event_destroy(&event);
}

1599}

1601void *SWITCH_THREAD_FUNC sofia_presence_event_thread_run(switch_thread_t *thread, void *obj)
1602{
void *pop;
int done = 0;

switch_mutex_lock(mod_sofia_globals.mutex);
if (!EVENT_THREAD_RUNNING) {
1
Assuming 'EVENT_THREAD_RUNNING' is 0→
2
←
Taking true branch→
EVENT_THREAD_RUNNING++;
mod_sofia_globals.threads++;
} else {
done = 1;
}
switch_mutex_unlock(mod_sofia_globals.mutex);

if (done) {
3
←
Taking false branch→
return NULL((void*)0);
}

switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1619, ((void*)0), SWITCH_LOG_CONSOLE, "Event Thread Started\n");

while (mod_sofia_globals.running == 1) {
4
←
Assuming the condition is true→
5
←
Loop condition is true.  Entering loop body→
int count = 0;

if (switch_queue_pop(mod_sofia_globals.presence_queue, &pop) == SWITCH_STATUS_SUCCESS) {
6
←
Assuming the condition is true→
7
←
Taking true branch→
	switch_event_t *event = (switch_event_t *) pop;

	if (!pop) {
8
←
Assuming 'pop' is non-null→
9
←
Taking false branch→
		break;
	}

	if (mod_sofia_globals.presence_flush) {
10
←
Assuming the condition is false→
11
←
Taking false branch→
		switch_mutex_lock(mod_sofia_globals.mutex);
		if (mod_sofia_globals.presence_flush) {
			do_flush();
			mod_sofia_globals.presence_flush = 0;
		}
		switch_mutex_unlock(mod_sofia_globals.mutex);
	}

	switch(event->event_id) {
12
←
Control jumps to 'case SWITCH_EVENT_MESSAGE_WAITING:'  at line 1641→
	case SWITCH_EVENT_MESSAGE_WAITING:
		actual_sofia_presence_mwi_event_handler(event);
13
←
Calling 'actual_sofia_presence_mwi_event_handler'→
		break;
	case SWITCH_EVENT_CONFERENCE_DATA:
		conference_data_event_handler(event);
		break;
	default:
		do {
			switch_event_t *ievent = event;
			event = actual_sofia_presence_event_handler(ievent);
			switch_event_destroy(&ievent);
		} while (event);
		break;
	}

	switch_event_destroy(&event);
	count++;
}
}

do_flush();

switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1663, ((void*)0), SWITCH_LOG_CONSOLE, "Event Thread Ended\n");

switch_mutex_lock(mod_sofia_globals.mutex);
mod_sofia_globals.threads--;
EVENT_THREAD_RUNNING = EVENT_THREAD_STARTED = 0;
switch_mutex_unlock(mod_sofia_globals.mutex);

return NULL((void*)0);
1671}

1673void sofia_presence_event_thread_start(void)
1674{
//switch_thread_t *thread;
switch_threadattr_t *thd_attr = NULL((void*)0);
int done = 0;

switch_mutex_lock(mod_sofia_globals.mutex);
if (!EVENT_THREAD_STARTED) {
EVENT_THREAD_STARTED++;
} else {
done = 1;
}
switch_mutex_unlock(mod_sofia_globals.mutex);

if (done) {
return;
}

switch_threadattr_create(&thd_attr, mod_sofia_globals.pool);
//switch_threadattr_detach_set(thd_attr, 1);
switch_threadattr_stacksize_set(thd_attr, SWITCH_THREAD_STACKSIZE240 * 1024);
switch_threadattr_priority_set(thd_attr, SWITCH_PRI_IMPORTANT);
switch_thread_create(&mod_sofia_globals.presence_thread, thd_attr, sofia_presence_event_thread_run, NULL((void*)0), mod_sofia_globals.pool);
1696}


1699void sofia_presence_event_handler(switch_event_t *event)
1700{
switch_event_t *cloned_event;

if (!EVENT_THREAD_STARTED) {
sofia_presence_event_thread_start();
switch_yield(500000)switch_sleep(500000);;
}

switch_event_dup(&cloned_event, event);
switch_assert(cloned_event)((cloned_event) ? (void) (0) : __assert_fail ("cloned_event",
 "sofia_presence.c", 1709, __extension__ __PRETTY_FUNCTION__)
);

if (switch_queue_trypush(mod_sofia_globals.presence_queue, cloned_event) != SWITCH_STATUS_SUCCESS) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1712, ((void*)0), SWITCH_LOG_ERROR, "Presence queue overloaded.... Flushing queue\n");
switch_mutex_lock(mod_sofia_globals.mutex);
mod_sofia_globals.presence_flush = 1;
switch_mutex_unlock(mod_sofia_globals.mutex);
switch_event_destroy(&cloned_event);
}


1720}


1723static int sofia_presence_sub_reg_callback(void *pArg, int argc, char **argv, char **columnNames)
1724{
sofia_profile_t *profile = (sofia_profile_t *) pArg;
char *user = argv[3];
char *host = argv[2];
switch_event_t *event;
char *event_name = argv[5];
char *expires = argv[10];



if (!strcasecmp(event_name, "message-summary")) {

if (switch_event_create(&event, SWITCH_EVENT_MESSAGE_QUERY)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 1736, &event, SWITCH_EVENT_MESSAGE_QUERY
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Message-Account", "sip:%s@%s", user, host);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "VM-Sofia-Profile", profile->name);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "VM-sub-call-id", argv[7]);

	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1742, ((void*)0), SWITCH_LOG_ERROR, "Create MESSAGE QUERY EVENT...\n");
		DUMP_EVENT(event){char *event_str;switch_event_serialize(event, &event_str
, SWITCH_FALSE);switch_log_printf(SWITCH_CHANNEL_ID_LOG, "sofia_presence.c"
, (const char *)__func__, 1743, ((void*)0), SWITCH_LOG_CRIT, "DUMP\n%s\n"
, event_str);free(event_str);};
	}


	sofia_event_fire(profile, &event);
}
return 0;
}

if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_PROBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 1752, &event, SWITCH_EVENT_PRESENCE_PROBE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", profile->url);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", "%s@%s", user, host);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "event_type", "presence");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "event_subtype", "probe");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto-specific-event-name", event_name);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "expires", expires);
sofia_event_fire(profile, &event);
}

return 0;
1765}

1767static int sofia_presence_resub_callback(void *pArg, int argc, char **argv, char **columnNames)
1768{
struct resub_helper *h = (struct resub_helper *) pArg;
sofia_profile_t *profile = h->profile;
char *user = argv[0];
char *host = argv[1];
char *status = argv[2];
char *rpid = argv[3];
char *proto = argv[4];
char *call_id = NULL((void*)0);
char *presence_id = NULL((void*)0);
char *to_user = NULL((void*)0);
char *uuid = NULL((void*)0);
char *state = NULL((void*)0);
char *direction = NULL((void*)0);
switch_event_t *event;
char to_buf[128] = "";
switch_event_header_t *hp;
char *free_me = NULL((void*)0);
int do_event = 1, i;


if (mod_sofia_globals.debug_presence > 1) {
for (i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1791, ((void*)0),SWITCH_LOG_WARNING,  "sofia_presence_resub_callback: %d [%s]=[%s]\n", i, columnNames[i], argv[i]);
}
}

if (argc > 5) {
uuid = argv[5];
state = switch_str_nil(argv[6])(argv[6] ? argv[6] : "");
direction = switch_str_nil(argv[7])(argv[7] ? argv[7] : "");
if (argc > 8) {
	switch_set_string(to_buf, argv[8])switch_copy_string(to_buf, argv[8], sizeof(to_buf));
	switch_url_decode(to_buf);
	to_user = to_buf;
}
if (argc > 10 && !zstr(argv[10])_zstr(argv[10]) && !zstr(argv[11])_zstr(argv[11])) {
	status = argv[10];
	rpid = argv[11];
}

if (argc > 12 && !zstr(argv[12])_zstr(argv[12]) && strchr(argv[12], '@')) {
	char *p;

	presence_id = argv[12];
	free_me = strdup(presence_id);
	switch_assert(free_me)((free_me) ? (void) (0) : __assert_fail ("free_me", "sofia_presence.c"
, 1814, __extension__ __PRETTY_FUNCTION__));
	if ((p = strchr(free_me, '@'))) *p = '\0';
	user = free_me;
}

if (argc > 16) {
	call_id = argv[16];
}

}

if (!zstr(uuid)_zstr(uuid) && !switch_ivr_uuid_exists(uuid)) {
if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1827, ((void*)0), SWITCH_LOG_NOTICE, "%s SKIPPING NOT FOUND UUID %s\n", profile->name, uuid);
}
do_event = 0;
}

if (zstr(proto)_zstr(proto)) {
proto = NULL((void*)0);
}

if (mod_sofia_globals.debug_presence > 0) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1837, ((void*)0), SWITCH_LOG_NOTICE, "%s PRESENCE_PROBE %s@%s\n", profile->name, user, host);
}

if (do_event && switch_event_create(&event, SWITCH_EVENT_PRESENCE_IN)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 1840, &event, SWITCH_EVENT_PRESENCE_IN
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", proto ? proto : SOFIA_CHAT_PROTO"sip");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", profile->url);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);

switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", "%s@%s", user, host);

if (h->noreg) {
	switch_event_add_header(event, SWITCH_STACK_BOTTOM, "Force-Direction", "inbound");
}

if (!zstr(call_id)_zstr(call_id)) {
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "call-id", call_id);
}

//switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "resub", "true");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "status", status);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "rpid", rpid);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "event_type", "presence");
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog");
switch_event_add_header(event, SWITCH_STACK_BOTTOM, "event_count", "%d", 0);

if (!zstr(to_user)_zstr(to_user)) {
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to-user", to_user);
}

if (zstr(state)_zstr(state)) {
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "channel-state", "CS_HANGUP");
	//switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "answer-state", "resubscribe");
} else {
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "channel-state", "CS_ROUTING");
	if (uuid) {
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "unique-id", uuid);
	}
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "answer-state", state);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "astate", state);
	switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "presence-call-direction", direction);
}

if (h->event) {
	for (hp = h->event->headers; hp; hp = hp->next) {
		if (!strncasecmp(hp->name, "fwd-", 4)) {
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, hp->name + 4, hp->value);
		}
	}
}

sofia_event_fire(profile, &event);
}

switch_safe_free(free_me)if (free_me) {free(free_me);free_me=((void*)0);};


h->rowcount++;


return 0;
1897}

1899char *get_display_name_from_contact(const char *in, char* dst)
1900{
// name-addr      =  [ display-name ] LAQUOT addr-spec RAQUOT
// display-name   =  *(token LWS)/ quoted-string
// return whatever comes before the left angle bracket, stripped of whitespace and quotes
char *p;
char *buf;

strcpy(dst, "");
if (strchr(in, '<') && strchr(in, '>')) {
buf = strdup(in);
switch_assert(buf)((buf) ? (void) (0) : __assert_fail ("buf", "sofia_presence.c"
, 1910, __extension__ __PRETTY_FUNCTION__));
p = strchr(buf, '<');
*p = '\0';
if (!zstr(buf)_zstr(buf)) {
	p = switch_strip_whitespace(buf);
	if (p) {
		if (*p == '"') {
			if (end_of(p+1)*(*p+1 == '\0' ? p+1 : p+1 + strlen(p+1) - 1) == '"') {
				char *q = strdup(p + 1);
				switch_assert(q)((q) ? (void) (0) : __assert_fail ("q", "sofia_presence.c", 1919
, __extension__ __PRETTY_FUNCTION__));
				end_of(q)*(*q == '\0' ? q : q + strlen(q) - 1) = '\0';
				strcpy(dst, q);
				switch_safe_free(q)if (q) {free(q);q=((void*)0);};
			}
		} else {
			strcpy(dst, p);
		}
		switch_safe_free(p)if (p) {free(p);p=((void*)0);};
	}
}
switch_safe_free(buf)if (buf) {free(buf);buf=((void*)0);};
}
return dst;
1933}

1935static int sofia_dialog_probe_callback(void *pArg, int argc, char **argv, char **columnNames)
1936{
struct rfc4235_helper *h = (struct rfc4235_helper *) pArg;

char *proto = argv[0];
char *user = argv[1];
char *host = argv[2];
char *uuid = argv[3];
char *call_id = argv[4];
char *state = argv[5];
char *direction = argv[6];
char *to_user = argv[7];
char *to_host = argv[8];
char *from_user = argv[9];
//    char *from_host = argv[10];
char *contact = switch_str_nil(argv[11])(argv[11] ? argv[11] : "");
char *contact_user = switch_str_nil(argv[12])(argv[12] ? argv[12] : "");
char *contact_host = switch_str_nil(argv[13])(argv[13] ? argv[13] : "");
char *to_tag = switch_str_nil(argv[14])(argv[14] ? argv[14] : "");
char *from_tag = switch_str_nil(argv[15])(argv[15] ? argv[15] : "");
char *orig_proto = switch_str_nil(argv[16])(argv[16] ? argv[16] : "");

const char *event_status = "";
char *data = NULL((void*)0), *tmp;
char key[256] = "";
char *local_user;
char *local_host;
char *remote_user;
char *remote_host;
char *remote_uri;
char *local_user_param = NULL((void*)0);
char remote_display_buf[512];
char *buf_to_free = NULL((void*)0);
int bInternal = 0;
int i;
int skip_proto = 0;

if (mod_sofia_globals.debug_presence > 1) {
for (i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1974, ((void*)0),SWITCH_LOG_WARNING,  "sofia_dialog_probe_callback: %d [%s]=[%s]\n", i, columnNames[i], argv[i]);
}
}

if (zstr(to_user)_zstr(to_user) || zstr(contact_user)_zstr(contact_user)) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1979, ((void*)0), SWITCH_LOG_WARNING, "sofia_dialog_probe_callback: not enough info to generate a dialog entry\n");
return 0;
}

// Usually we report the dialogs FROM the probed user.  The exception is when the monitored endpoint is internal,
// and its presence_id is set in the dialplan.  Reverse the direction if this is not a registered entity.
if (!strcmp(direction, "inbound") && strcmp(user, from_user) ) {
// If inbound and the entity is not the caller (i.e. internal to FS), then the direction is reversed
// because it is not going through the B2BUA
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 1988, ((void*)0), SWITCH_LOG_DEBUG, "sofia_dialog_probe_callback: endpt is internal\n");
direction = !strcasecmp(direction, "outbound") ? "inbound" : "outbound";
bInternal = 1;
}

if (!strcasecmp(direction, "outbound")) {
direction = "recipient";
}
else {
direction = "initiator";
}

if (!zstr(orig_proto)_zstr(orig_proto) && !strcmp(orig_proto, SOFIA_CHAT_PROTO"sip")) {
skip_proto = 1;
}

local_host = to_host;
if (proto && !strcasecmp(proto, "queue")) {
local_user = to_user;
local_user_param = switch_mprintf(";proto=%s", proto);
event_status = "hold";
if (skip_proto) {
	buf_to_free = switch_mprintf("sip:%s", to_user);
} else {
	buf_to_free = switch_mprintf("sip:queue+%s", to_user);
}
remote_uri = buf_to_free;
strcpy(remote_display_buf, "queue");
remote_user = to_user;
remote_host = local_host;
}
else if (proto && !strcasecmp(proto, "park")) {
local_user = to_user;
local_user_param = switch_mprintf(";proto=%s", proto);
event_status = "hold";
if (skip_proto) {
	buf_to_free = switch_mprintf("sip:%s", to_user);
} else {
	buf_to_free = switch_mprintf("sip:park+%s", to_user);
}
remote_uri = buf_to_free;
strcpy(remote_display_buf, "park");
remote_user = to_user;
remote_host = local_host;
}
else if (proto && !strcasecmp(proto, "pickup")) {
local_user = to_user;
local_user_param = switch_mprintf(";proto=%s", proto);
event_status = "hold";
if (skip_proto) {
	buf_to_free = switch_mprintf("sip:%s", to_user);
} else {
	buf_to_free = switch_mprintf("sip:pickup+%s", to_user);
}
remote_uri = buf_to_free;
strcpy(remote_display_buf, "pickup");
remote_user = to_user;
remote_host = local_host;
}
else if (proto && !strcasecmp(proto, "conf")) {
local_user = to_user;
local_user_param = switch_mprintf(";proto=%s", proto);
if (skip_proto) {
	buf_to_free = switch_mprintf("sip:%s@%s", to_user, host);
} else {
	buf_to_free = switch_mprintf("sip:conf+%s@%s", to_user, host);
}
remote_uri = buf_to_free;
strcpy(remote_display_buf, "conference");
remote_user = to_user;
remote_host = local_host;
}
else if (bInternal) {
local_user = to_user;
get_display_name_from_contact(contact, remote_display_buf);
buf_to_free = sofia_glue_strip_uri(contact);
remote_uri = buf_to_free;
remote_user = contact_user;
remote_host = contact_host;
} else {
local_user = from_user;
buf_to_free = switch_mprintf("**%s@%s", from_user, local_host);
remote_uri = buf_to_free;
strcpy(remote_display_buf, to_user);
remote_user = to_user;
remote_host = local_host;
}

switch_snprintf(key, sizeof(key), "%s%s", user, host);
data = switch_core_hash_find(h->hash, key);
if (!data) {
data = "";
}
tmp = switch_core_sprintf(h->pool, "%s"
					  "<dialog id=\"%s\" call-id=\"%s\" local-tag=\"%s\" remote-tag=\"%s\" direction=\"%s\">\n"
					  " <state>%s</state>\n"
					  " <local>\n"
					  "  <identity display=\"%s\">sip:%s@%s%s</identity>\n"
					  "  <target uri=\"sip:%s@%s\">\n"
					  "   <param pname=\"+sip.rendering\" pvalue=\"%s\"/>\n"
					  "  </target>\n"
					  " </local>\n"
					  " <remote>\n"
					  "  <identity display=\"%s\">sip:%s@%s</identity>\n"
					  "  <target uri=\"%s\"/>\n"
					  " </remote>\n"
					  "</dialog>\n",
					  data,
					  uuid, call_id, to_tag, from_tag, direction,
					  state,
					  local_user, local_user, local_host, switch_str_nil(local_user_param)(local_user_param ? local_user_param : ""),
					  local_user, local_host,
					  !strcasecmp(event_status, "hold") ? "no" : "yes",
					  remote_display_buf, remote_user, remote_host,
					  remote_uri
					  );
switch_core_hash_insert(h->hash, key, tmp)switch_core_hash_insert_destructor(h->hash, key, tmp, ((void
*)0));
switch_safe_free(local_user_param)if (local_user_param) {free(local_user_param);local_user_param
=((void*)0);};
switch_safe_free(buf_to_free)if (buf_to_free) {free(buf_to_free);buf_to_free=((void*)0);};

h->rowcount++;

return 0;
2111}

2113#define SOFIA_PRESENCE_COLLISION_DELTA50 50
2114#define SOFIA_PRESENCE_ROLLOVER_YEAR(86400 * 365 * 50) (86400 * 365 * SOFIA_PRESENCE_COLLISION_DELTA50)
2115static uint32_t check_presence_epoch(void)
2116{
time_t now = switch_epoch_time_now(NULL((void*)0));
uint32_t callsequence = (uint32_t)((now - mod_sofia_globals.presence_epoch) * SOFIA_PRESENCE_COLLISION_DELTA50);

if (!mod_sofia_globals.presence_year || callsequence >= SOFIA_PRESENCE_ROLLOVER_YEAR(86400 * 365 * 50)) {
struct tm tm;
switch_mutex_lock(mod_sofia_globals.mutex);
tm = *(localtime(&now));

if (tm.tm_year != mod_sofia_globals.presence_year) {
	mod_sofia_globals.presence_epoch = (uint32_t)now - (tm.tm_yday * 86400) - (tm.tm_hour * 60 * 60) - (tm.tm_min * 60) - tm.tm_sec;
	mod_sofia_globals.presence_year = tm.tm_year;
	callsequence = (uint32_t)(((uint32_t)now - mod_sofia_globals.presence_epoch) * SOFIA_PRESENCE_COLLISION_DELTA50);
}

switch_mutex_unlock(mod_sofia_globals.mutex);
}

return callsequence;
2135}

2137uint32_t sofia_presence_get_cseq(sofia_profile_t *profile)
2138{
uint32_t callsequence;
int diff = 0;

switch_mutex_lock(profile->ireg_mutex);

callsequence = check_presence_epoch();

if (profile->last_cseq) {
diff = callsequence - profile->last_cseq;
if (diff <= 0 && diff > -100000) {
	callsequence = ++profile->last_cseq;
}
}

profile->last_cseq = callsequence;

switch_mutex_unlock(profile->ireg_mutex);

return callsequence;

2159}


2162#define send_presence_notify(_a,_b,_c,_d,_e,_f,_g,_h,_i,_j,_k,_l)_send_presence_notify(_a,_b,_c,_d,_e,_f,_g,_h,_i,_j,_k,_l,"sofia_presence.c"
, (const char *)__func__, 2162) \
2163_send_presence_notify(_a,_b,_c,_d,_e,_f,_g,_h,_i,_j,_k,_l,__FILE__"sofia_presence.c", __SWITCH_FUNC__(const char *)__func__, __LINE__2163)

2165static void _send_presence_notify(sofia_profile_t *profile,
						  const char *full_to,
						  const char *full_from,
						  const char *o_contact,
						  const char *expires,
						  const char *call_id,
						  const char *event,
						  const char *remote_ip,
						  const char *remote_port,
						  const char *ct,
						  const char *pl,
						  const char *call_info,
						  const char *file, const char *func, int line
						 )
2179{
char sstr[128] = "";
nua_handle_t *nh;
int exptime = 0;
char expires_str[10] = "";
sip_cseq_t *cseq = NULL((void*)0);
uint32_t callsequence;
uint32_t now = (uint32_t) switch_epoch_time_now(NULL((void*)0));

sofia_destination_t *dst = NULL((void*)0);
char *contact_str, *contact, *user_via = NULL((void*)0), *send_contact = NULL((void*)0);
char *route_uri = NULL((void*)0), *o_contact_dup = NULL((void*)0), *tmp, *to_uri, *dcs = NULL((void*)0);
const char *tp;
char *cparams = NULL((void*)0);
char *path = NULL((void*)0);

if (zstr(full_to)_zstr(full_to) || zstr(full_from)_zstr(full_from) || zstr(o_contact)_zstr(o_contact)) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2196, ((void*)0), SWITCH_LOG_WARNING, "MISSING DATA TO SEND NOTIFY.\n");
return;
}

if ((cparams = strstr(o_contact, ";_;"))) {
cparams += 3;
}

if (!switch_stristr("fs_nat=yes", o_contact)) {
path = sofia_glue_get_path_from_contact((char *) o_contact);
}

dst = sofia_glue_get_destination((char *) o_contact);
switch_assert(dst)((dst) ? (void) (0) : __assert_fail ("dst", "sofia_presence.c"
, 2209, __extension__ __PRETTY_FUNCTION__));

if (!zstr(dst->contact)_zstr(dst->contact)) {
contact = sofia_glue_get_url_from_contact(dst->contact, 1);
} else {
contact = strdup(o_contact);
}

if (dst->route_uri) {
route_uri = sofia_glue_strip_uri(dst->route_uri);
tmp = (char *)route_uri;
} else {
tmp = (char *)o_contact;
}

o_contact_dup = sofia_glue_get_url_from_contact(tmp, 1);

if ((tp = switch_stristr("transport=", o_contact_dup))) {
tp += 10;
}

if (zstr(tp)_zstr(tp)) {
tp = "udp";
}

if (!zstr(remote_ip)_zstr(remote_ip) && sofia_glue_check_nat(profile, remote_ip)) {
sofia_transport_t transport = sofia_glue_str2transport(tp);

switch (transport) {
case SOFIA_TRANSPORT_TCP:
	contact_str = profile->tcp_public_contact;
	break;
case SOFIA_TRANSPORT_TCP_TLS:
	contact_str = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?
		profile->tls_public_contact : profile->tcp_public_contact;
	break;
default:
	contact_str = profile->public_url;
	break;
}
user_via = sofia_glue_create_external_via(NULL((void*)0), profile, transport);
} else {
sofia_transport_t transport = sofia_glue_str2transport(tp);
switch (transport) {
case SOFIA_TRANSPORT_TCP:
	contact_str = profile->tcp_contact;
	break;
case SOFIA_TRANSPORT_TCP_TLS:
	contact_str = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?
		profile->tls_contact : profile->tcp_contact;
	break;
default:
	contact_str = profile->url;
	break;
}
}


if ((to_uri = sofia_glue_get_url_from_contact((char *)full_to, 1))) {
char *p;

if ((p = strstr(to_uri, "sip:"))) {
	char *q;

	p += 4;
	if ((q = strchr(p, '@'))) {
		*q++ = '\0';

		if ((dcs = switch_string_replace(contact_str, "mod_sofia", p))) {
			contact_str = dcs;
		}

	}
}

free(to_uri);
}

if (expires) {
long ltmp = atol(expires);

if (ltmp > 0) {
	exptime = (ltmp - now);
} else {
	exptime = 0;
}
}

if (exptime <= 0) {
switch_snprintf(sstr, sizeof(sstr), "terminated;reason=noresource");
} else {
switch_snprintf(sstr, sizeof(sstr), "active;expires=%u", (unsigned) exptime);
}

if (mod_sofia_globals.debug_presence > 1 || mod_sofia_globals.debug_sla > 1) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2304, ((void*)0), SWITCH_LOG_ERROR, "SEND PRES NOTIFY:\n"
				  "file[%s]\nfunc[%s]\nline[%d]\n"
				  "profile[%s]\nvia[%s]\nip[%s]\nport[%s]\nroute[%s]\ncontact[%s]\nto[%s]\nfrom[%s]\nurl[%s]\ncall_id[%s]\nexpires_str[%s]\n"
				  "event[%s]\nct[%s]\npl[%s]\ncall_info[%s]\nexptime[%ld]\n",
				  file, func, line,
				  profile->name,
				  switch_str_nil(user_via)(user_via ? user_via : ""),
				  remote_ip,
				  remote_port,
				  route_uri,
				  o_contact,
				  full_to,
				  full_from,
				  contact,
				  call_id,
				  expires_str,
				  event,
				  switch_str_nil(ct)(ct ? ct : ""),
				  switch_str_nil(pl)(pl ? pl : ""),
				  switch_str_nil(call_info)(call_info ? call_info : ""),
				  (long)exptime
				  );
}


callsequence = sofia_presence_get_cseq(profile);

if (cparams) {
send_contact = switch_mprintf("%s;%s", contact_str, cparams);
contact_str = send_contact;
}

nh = nua_handle(profile->nua, NULL((void*)0), NUTAG_URL(contact)nutag_url, urltag_url_v(contact), SIPTAG_CONTACT_STR(contact_str)siptag_contact_str, tag_str_v(contact_str), TAG_END()(tag_type_t)0, (tag_value_t)0);
cseq = sip_cseq_create(nua_handle_get_home(nh), callsequence, SIP_METHOD_NOTIFYsip_method_notify, "NOTIFY");
nua_handle_bind(nh, &mod_sofia_globals.destroy_private);


nua_notify(nh,
	   NUTAG_NEWSUB(1)nutag_newsub, tag_bool_v(1),
	   TAG_IF(route_uri, NUTAG_PROXY(route_uri))!(route_uri) ? tag_skip : ntatag_default_proxy, urltag_url_v(
(route_uri)),
	   TAG_IF(dst->route, SIPTAG_ROUTE_STR(dst->route))!(dst->route) ? tag_skip : siptag_route_str, tag_str_v(dst
->route),
	   TAG_IF(user_via, SIPTAG_VIA_STR(user_via))!(user_via) ? tag_skip : siptag_via_str, tag_str_v(user_via),
	   TAG_IF(path, SIPTAG_RECORD_ROUTE_STR(path))!(path) ? tag_skip : siptag_record_route_str, tag_str_v(path),

	   SIPTAG_FROM_STR(full_to)siptag_from_str, tag_str_v(full_to),
	   SIPTAG_TO_STR(full_from)siptag_to_str, tag_str_v(full_from),

	   SIPTAG_CALL_ID_STR(call_id)siptag_call_id_str, tag_str_v(call_id),
	   TAG_IF(*expires_str, SIPTAG_EXPIRES_STR(expires_str))!(*expires_str) ? tag_skip : siptag_expires_str, tag_str_v(expires_str
),
	   SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr),
	   SIPTAG_EVENT_STR(event)siptag_event_str, tag_str_v(event),
	   TAG_IF(!zstr(ct), SIPTAG_CONTENT_TYPE_STR(ct))!(!_zstr(ct)) ? tag_skip : siptag_content_type_str, tag_str_v
(ct),
	   TAG_IF(!zstr(pl), SIPTAG_PAYLOAD_STR(pl))!(!_zstr(pl)) ? tag_skip : siptag_payload_str, tag_str_v(pl),
	   TAG_IF(!zstr(call_info), SIPTAG_CALL_INFO_STR(call_info))!(!_zstr(call_info)) ? tag_skip : siptag_call_info_str, tag_str_v
(call_info),
	   TAG_IF(!exptime, SIPTAG_EXPIRES_STR("0"))!(!exptime) ? tag_skip : siptag_expires_str, tag_str_v("0"),
	   SIPTAG_CSEQ(cseq)siptag_cseq, siptag_cseq_v(cseq),
	   TAG_END()(tag_type_t)0, (tag_value_t)0);


switch_safe_free(route_uri)if (route_uri) {free(route_uri);route_uri=((void*)0);};
switch_safe_free(dcs)if (dcs) {free(dcs);dcs=((void*)0);};
switch_safe_free(contact)if (contact) {free(contact);contact=((void*)0);};

sofia_glue_free_destination(dst);
switch_safe_free(user_via)if (user_via) {free(user_via);user_via=((void*)0);};
switch_safe_free(o_contact_dup)if (o_contact_dup) {free(o_contact_dup);o_contact_dup=((void*
)0);};
switch_safe_free(send_contact)if (send_contact) {free(send_contact);send_contact=((void*)0)
;};
switch_safe_free(path)if (path) {free(path);path=((void*)0);};
2372}


2375static int sofia_dialog_probe_notify_callback(void *pArg, int argc, char **argv, char **columnNames)
2376{
struct rfc4235_helper *sh = (struct rfc4235_helper *) pArg;
char key[256] = "";
char *data = NULL((void*)0);
char *call_id = argv[0];
char *expires = argv[1];
char *user = argv[2];
char *host = argv[3];
char *event = argv[4];
char *version = argv[5];
char *notify_state = argv[6];
char *full_to = argv[7];
char *full_from = argv[8];
char *contact = argv[9];
char *remote_ip = argv[10];
char *remote_port = argv[11];

switch_stream_handle_t stream = { 0 };
char *to;
const char *pl = NULL((void*)0);
const char *ct = "application/dialog-info+xml";

if (mod_sofia_globals.debug_presence > 0) {
int i;
for(i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2401, ((void*)0), SWITCH_LOG_CRIT, "arg %d[%s] = [%s]\n", i, columnNames[i], argv[i]);
}
}


if (mod_sofia_globals.debug_presence > 0) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2407, ((void*)0), SWITCH_LOG_NOTICE,
				  "SEND DIALOG\nTo:      \t%s@%s\nFrom:    \t%s@%s\nCall-ID:  \t%s\n",
				  user, host, user, host, call_id);
}

to = switch_mprintf("sip:%s@%s", user, host);

SWITCH_STANDARD_STREAM(stream)memset(&stream, 0, sizeof(stream)); stream.data = malloc(
1024); ((stream.data) ? (void) (0) : __assert_fail ("stream.data"
, "sofia_presence.c", 2414, __extension__ __PRETTY_FUNCTION__
)); memset(stream.data, 0, 1024); stream.end = stream.data; stream
.data_size = 1024; stream.write_function = switch_console_stream_write
; stream.raw_write_function = switch_console_stream_raw_write
; stream.alloc_len = 1024; stream.alloc_chunk = 1024;

if (zstr(version)_zstr(version)) {
version = "0";
}

stream.write_function(&stream,
				  "<?xml version=\"1.0\"?>\n"
				  "<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" "
				  "version=\"%s\" state=\"%s\" entity=\"%s\">\n",
				  version,
				  notify_state, to);

switch_snprintf(key, sizeof(key), "%s%s", user, host);

data = switch_core_hash_find(sh->hash, key);

if (data) {
stream.write_function(&stream, "%s\n", data);
}

stream.write_function(&stream, "</dialog-info>\n");
pl = stream.data;
ct = "application/dialog-info+xml";

if (mod_sofia_globals.debug_presence > 0 && pl) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2440, ((void*)0), SWITCH_LOG_DEBUG, "send payload:\n%s\n", pl);
}


send_presence_notify(sh->profile,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 full_to,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 full_from,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 contact,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 expires,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 call_id,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 event,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 remote_ip,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 remote_port,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 ct,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 pl,_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 NULL_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456)
				 )_send_presence_notify(sh->profile,full_to,full_from,contact
,expires,call_id,event,remote_ip,remote_port,ct,pl,((void*)0)
,"sofia_presence.c", (const char *)__func__, 2456);


switch_safe_free(to)if (to) {free(to);to=((void*)0);};
switch_safe_free(stream.data)if (stream.data) {free(stream.data);stream.data=((void*)0);};

return 0;
2463}

2465static char *translate_rpid(char *in)
2466{
char *r = in;

if (in && (strstr(in, "null") || strstr(in, "NULL"))) {
in = NULL((void*)0);
}

if (zstr(in)_zstr(in)) {
return NULL((void*)0);
}

if (!strcasecmp(in, "unknown")) {
r = NULL((void*)0);
goto end;
}

if (!strcasecmp(in, "busy")) {
r = in;
goto end;
}

if (!strcasecmp(in, "unavailable")) {
r = "away";
goto end;
}

if (!strcasecmp(in, "idle")) {
r = "busy";
}

end:
return r;
2498}


2501static char *gen_pidf(char *user_agent, char *id, char *url, char *open, char *rpid, char *prpid, char *status, const char **ct)
2502{
char *ret = NULL((void*)0);

if (switch_stristr("polycom", user_agent)) {
*ct = "application/xpidf+xml";

/* If unknown/none prpid is provided, just show the user as online. */
if (!prpid || !strcasecmp(prpid, "unknown")) {
	prpid = "online";
}

/* of course!, lets make a big deal over dashes. Now the stupidity is complete. */
if (!strcmp(prpid, "on-the-phone")) {
	prpid = "onthephone";
}

if (zstr(open)_zstr(open)) {
	open = "open";
}

ret = switch_mprintf("<?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"
					 "   <status status=\"%s\" />\n"
					 "   <msnsubstatus substatus=\"%s\" />\n"
					 "  </address>\n"
					 " </atom>\n"
					 "</presence>\n", status, id, id, url, open, prpid);
} else {
char *xml_rpid = NULL((void*)0);

*ct = "application/pidf+xml";

if (!strcasecmp(open, "closed")) {
	status = "Unregistered";
	prpid = NULL((void*)0);
}

if (!strncasecmp(status, "Registered", 10)) {
	status = "Available";
}

if (!strcasecmp(status, "Available")) {
	prpid = NULL((void*)0);
}


if (!strcasecmp(status, "Unregistered")) {
	prpid = NULL((void*)0);
	open = "closed";
}

if (zstr(rpid)_zstr(rpid)) {
	prpid = NULL((void*)0);
}


if (zstr(status)_zstr(status) && !zstr(prpid)_zstr(prpid)) {
	status = "Available";
	prpid = NULL((void*)0);
}

if (prpid) {
	xml_rpid = switch_mprintf("  <rpid:activities>\r\n"
							  "   <rpid:%s/>\n"
							  "  </rpid:activities>\n", prpid);
}

ret = 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' entity='%s'>\n"
					 " <tuple id='t6a5ed77e'>\n"
					 "  <status>\r\n"
					 "   <basic>%s</basic>\n"
					 "  </status>\n"
					 " </tuple>\n"
					 " <dm:person id='p06360c4a'>\n"
					 "%s"
					 "  <dm:note>%s</dm:note>\n"
					 " </dm:person>\n"
					 "</presence>", id, open, switch_str_nil(xml_rpid)(xml_rpid ? xml_rpid : ""), status);


switch_safe_free(xml_rpid)if (xml_rpid) {free(xml_rpid);xml_rpid=((void*)0);};
}


return ret;
2598}

2600static int sofia_presence_sub_callback(void *pArg, int argc, char **argv, char **columnNames)
2601{
struct presence_helper *helper = (struct presence_helper *) pArg;
char *pl = NULL((void*)0);
char *clean_id = NULL((void*)0), *id = NULL((void*)0);
char *proto = argv[0];
char *user = argv[1];
char *host = argv[2];
char *sub_to_user = argv[3];
char *event = argv[5];
char *contact = argv[6];
char *call_id = argv[7];
char *full_from = argv[8];
//char *full_via = argv[9];
char *expires = argv[10];
char *user_agent = argv[11];
char *profile_name = argv[13];
uint32_t in = 0;
char *status = argv[14];
char *rpid = argv[15];
char *sub_to_host = argv[16];
char *open_closed = NULL((void*)0);
char *dialog_status = NULL((void*)0);
char *dialog_rpid = NULL((void*)0);
//char *default_dialog = "partial";
char *default_dialog = "full";
const char *ct = "no/idea";

char *to = NULL((void*)0);
char *open;
char *prpid;

int is_dialog = 0;
sofia_profile_t *ext_profile = NULL((void*)0), *profile = helper->profile;

char status_line[256] = "";
char *version = "0";
char *presence_id = NULL((void*)0);
char *free_me = NULL((void*)0);
int holding = 0;
char *orig_proto = NULL((void*)0);
int skip_proto = 0;
char *full_to = NULL((void*)0);
char *ip = NULL((void*)0);
char *port = 0;
const char *call_state = NULL((void*)0);
const char *astate = NULL((void*)0);
const char *event_status = NULL((void*)0);
const char *force_event_status = NULL((void*)0);
char *contact_str, *contact_stripped;

if (mod_sofia_globals.debug_presence > 0) {
int i;
for(i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2654, ((void*)0), SWITCH_LOG_CRIT, "arg %d[%s] = [%s]\n", i, columnNames[i], argv[i]);
}
DUMP_EVENT(helper->event){char *event_str;switch_event_serialize(helper->event, &
event_str, SWITCH_FALSE);switch_log_printf(SWITCH_CHANNEL_ID_LOG
, "sofia_presence.c", (const char *)__func__, 2656, ((void*)0
), SWITCH_LOG_CRIT, "DUMP\n%s\n", event_str);free(event_str);
};
}

if (argc > 18) {
if (!zstr(argv[17])_zstr(argv[17])) {
	status = argv[17];
}
if (!zstr(argv[18])_zstr(argv[18])) {
	rpid = argv[18];
}
open_closed = argv[19];
}

if (argc > 20) {
dialog_status = argv[20];
dialog_rpid = argv[21];
version = argv[22];
presence_id = argv[23];
orig_proto = argv[24];
full_to = argv[25];
ip = argv[26];
port = argv[27];
}

if (!zstr(ip)_zstr(ip) && sofia_glue_check_nat(profile, ip)) {
char *ptr;
if ((ptr = sofia_glue_find_parameter(contact, "transport="))) {
	sofia_transport_t transport = sofia_glue_str2transport( ptr + 10 );

	switch (transport) {
	case SOFIA_TRANSPORT_TCP:
		contact_str = profile->tcp_public_contact;
		break;
	case SOFIA_TRANSPORT_TCP_TLS:
		contact_str = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?
			profile->tls_public_contact : profile->tcp_public_contact;
		break;
	default:
		contact_str = profile->public_url;
		break;
	}
} else {
	contact_str = profile->public_url;
}
} else {
char *ptr;
if ((ptr = sofia_glue_find_parameter(contact, "transport="))) {
	sofia_transport_t transport = sofia_glue_str2transport( ptr + 10 );

	switch (transport) {
	case SOFIA_TRANSPORT_TCP:
		contact_str = profile->tcp_contact;
		break;
	case SOFIA_TRANSPORT_TCP_TLS:
		contact_str = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?
			profile->tls_contact : profile->tcp_contact;
		break;
	default:
		contact_str = profile->url;
		break;
	}
} else {
	contact_str = profile->url;
}
}


if (!zstr(presence_id)_zstr(presence_id) && strchr(presence_id, '@')) {
char *p;

free_me = strdup(presence_id);

switch_assert(free_me)((free_me) ? (void) (0) : __assert_fail ("free_me", "sofia_presence.c"
, 2728, __extension__ __PRETTY_FUNCTION__));

if ((p = strchr(free_me, '@'))) {
	*p = '\0';
}

user = free_me;
}


if (!zstr(orig_proto)_zstr(orig_proto) && !strcmp(orig_proto, SOFIA_CHAT_PROTO"sip")) {
skip_proto = 1;
}

in = helper->event && helper->event->event_id == SWITCH_EVENT_PRESENCE_IN;

if (zstr(rpid)_zstr(rpid)) {
rpid = "unknown";
}

if (zstr(status)_zstr(status)) {
if (!strcasecmp(rpid, "busy")) {
	status = "Busy";
} else if (!strcasecmp(rpid, "unavailable")) {
	status = "Idle";
} else if (!strcasecmp(rpid, "away")) {
	status = "Idle";
} else {
	status = "Available";
}
}

if (status && !strncasecmp(status, "hold", 4)) {
holding = 1;
}

if (profile_name && strcasecmp(profile_name, helper->profile->name)) {
if ((ext_profile = sofia_glue_find_profile(profile_name)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 2765, profile_name))) {
	profile = ext_profile;
}
}


if (!strcasecmp(proto, SOFIA_CHAT_PROTO"sip") || skip_proto) {
clean_id = switch_mprintf("sip:%s@%s", sub_to_user, sub_to_host);
} else {
clean_id = switch_mprintf("sip:%s+%s@%s", proto, sub_to_user, sub_to_host);
}



if (!rpid) {
rpid = "unknown";
}

//	if (!strcasecmp(proto, SOFIA_CHAT_PROTO) || skip_proto) {
//		clean_id = switch_mprintf("sip:%s@%s", sub_to_user, sub_to_host);
//} else {
//		clean_id = switch_mprintf("sip:%s+%s@%s", proto, sub_to_user, sub_to_host);
//}

if (mod_sofia_globals.debug_presence > 0) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2790, ((void*)0), SWITCH_LOG_NOTICE,
				  "SEND PRESENCE\nTo:      \t%s@%s\nFrom:    \t%s@%s\nCall-ID:  \t%s\nProfile:\t%s [%s]\n\n",
				  user, host, sub_to_user, sub_to_host, call_id, profile_name, helper->profile->name);
}

if (!strcasecmp(sub_to_host, host) && !skip_proto) {
/* same host */
id = switch_mprintf("sip:%s+%s@%s", proto, sub_to_user, sub_to_host);
} else if (strcasecmp(proto, SOFIA_CHAT_PROTO"sip") && !skip_proto) {
/*encapsulate */
id = switch_mprintf("sip:%s+%s+%s@%s", proto, sub_to_user, sub_to_host, host);
} else {
id = switch_mprintf("sip:%s@%s", sub_to_user, sub_to_host);
}

to = switch_mprintf("sip:%s@%s", user, host);

is_dialog = !strcmp(event, "dialog");

if (helper->hup && helper->calls_up > 0) {
call_state = "CS_EXECUTE";
astate = "active";
event_status = "Active";
force_event_status = NULL((void*)0);
} else {
if (helper->event) {
	call_state = switch_event_get_header(helper->event, "channel-state")switch_event_get_header_idx(helper->event, "channel-state"
, -1);
	astate = switch_str_nil(switch_event_get_header(helper->event, "astate"))(switch_event_get_header_idx(helper->event, "astate", -1) ?
 switch_event_get_header_idx(helper->event, "astate", -1) :
 "");
	event_status = switch_str_nil(switch_event_get_header(helper->event, "status"))(switch_event_get_header_idx(helper->event, "status", -1) ?
 switch_event_get_header_idx(helper->event, "status", -1) :
 "");
	force_event_status = switch_str_nil(switch_event_get_header(helper->event, "force-status"))(switch_event_get_header_idx(helper->event, "force-status"
, -1) ? switch_event_get_header_idx(helper->event, "force-status"
, -1) : "");
}
}

if (helper->event) {
switch_stream_handle_t stream = { 0 };
const char *direction = switch_str_nil(switch_event_get_header(helper->event, "presence-call-direction"))(switch_event_get_header_idx(helper->event, "presence-call-direction"
, -1) ? switch_event_get_header_idx(helper->event, "presence-call-direction"
, -1) : "");
//const char *force_direction = switch_str_nil(switch_event_get_header(helper->event, "force-direction"));
const char *uuid = switch_str_nil(switch_event_get_header(helper->event, "unique-id"))(switch_event_get_header_idx(helper->event, "unique-id", -
1) ? switch_event_get_header_idx(helper->event, "unique-id"
, -1) : "");
const char *resub = switch_str_nil(switch_event_get_header(helper->event, "resub"))(switch_event_get_header_idx(helper->event, "resub", -1) ?
 switch_event_get_header_idx(helper->event, "resub", -1) :
 "");
const char *answer_state = switch_str_nil(switch_event_get_header(helper->event, "answer-state"))(switch_event_get_header_idx(helper->event, "answer-state"
, -1) ? switch_event_get_header_idx(helper->event, "answer-state"
, -1) : "");
const char *dft_state;
const char *from_id = NULL((void*)0), *from_name = NULL((void*)0);
const char *to_user = switch_str_nil(switch_event_get_header(helper->event, "variable_sip_to_user"))(switch_event_get_header_idx(helper->event, "variable_sip_to_user"
, -1) ? switch_event_get_header_idx(helper->event, "variable_sip_to_user"
, -1) : "");
const char *from_user = switch_str_nil(switch_event_get_header(helper->event, "variable_sip_from_user"))(switch_event_get_header_idx(helper->event, "variable_sip_from_user"
, -1) ? switch_event_get_header_idx(helper->event, "variable_sip_from_user"
, -1) : "");
const char *disable_early = switch_str_nil(switch_event_get_header(helper->event, "variable_presence_disable_early"))(switch_event_get_header_idx(helper->event, "variable_presence_disable_early"
, -1) ? switch_event_get_header_idx(helper->event, "variable_presence_disable_early"
, -1) : "");
const char *answer_epoch = switch_str_nil(switch_event_get_header(helper->event, "variable_answer_epoch"))(switch_event_get_header_idx(helper->event, "variable_answer_epoch"
, -1) ? switch_event_get_header_idx(helper->event, "variable_answer_epoch"
, -1) : "");
int answered = 0;
char *clean_to_user = NULL((void*)0);
char *clean_from_user = NULL((void*)0);
int force_status = 0;
int term = 0;

if (answer_epoch) {
	answered = atoi(answer_epoch);
}


//if (user_agent && switch_stristr("snom", user_agent) && uuid) {
//	default_dialog = "full" ;
//}

if (call_state && !strcasecmp(call_state, "cs_hangup")) {
	astate = "hangup";
	holding = 0;
	term = 1;
} else {

	if (event_status && !strncasecmp(event_status, "hold", 4)) {
		holding = 1;
	}

	if (force_event_status && !event_status) {
		event_status = force_event_status;
	}

	if (event_status && !strncasecmp(event_status, "hold", 4)) {
		holding = 1;
	}
}

if (!strcasecmp(direction, "inbound")) {
	from_id = switch_str_nil(switch_event_get_header(helper->event, "Caller-Destination-Number"))(switch_event_get_header_idx(helper->event, "Caller-Destination-Number"
, -1) ? switch_event_get_header_idx(helper->event, "Caller-Destination-Number"
, -1) : "");

} else {
	from_id = switch_str_nil(switch_event_get_header(helper->event, "Caller-Caller-ID-Number"))(switch_event_get_header_idx(helper->event, "Caller-Caller-ID-Number"
, -1) ? switch_event_get_header_idx(helper->event, "Caller-Caller-ID-Number"
, -1) : "");
	from_name = switch_event_get_header(helper->event, "Caller-Caller-ID-Name")switch_event_get_header_idx(helper->event, "Caller-Caller-ID-Name"
, -1);

	if (zstr(from_id)_zstr(from_id)) {
		from_id = switch_str_nil(switch_event_get_header(helper->event, "Other-Leg-Caller-ID-Number"))(switch_event_get_header_idx(helper->event, "Other-Leg-Caller-ID-Number"
, -1) ? switch_event_get_header_idx(helper->event, "Other-Leg-Caller-ID-Number"
, -1) : "");
	}

	if (zstr(from_name)_zstr(from_name)) {
		from_name = switch_event_get_header(helper->event, "Other-Leg-Caller-ID-Name")switch_event_get_header_idx(helper->event, "Other-Leg-Caller-ID-Name"
, -1);
	}

}

2887#if 0
char *buf;
switch_event_serialize(helper->event, &buf, SWITCH_FALSE);
switch_assert(buf)((buf) ? (void) (0) : __assert_fail ("buf", "sofia_presence.c"
, 2890, __extension__ __PRETTY_FUNCTION__));
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2891, ((void*)0), SWITCH_LOG_INFO, "CHANNEL_DATA:\n%s\n", buf);
free(buf);
2893#endif

if (is_dialog) {
	// Usually we report the dialogs FROM the probed user.  The exception is when the monitored endpoint is internal,
	// and its presence_id is set in the dialplan.  Reverse the direction if this is not a registered entity.
	const char *caller = switch_str_nil(switch_event_get_header(helper->event, "caller-username"))(switch_event_get_header_idx(helper->event, "caller-username"
, -1) ? switch_event_get_header_idx(helper->event, "caller-username"
, -1) : "");
	SWITCH_STANDARD_STREAM(stream)memset(&stream, 0, sizeof(stream)); stream.data = malloc(
1024); ((stream.data) ? (void) (0) : __assert_fail ("stream.data"
, "sofia_presence.c", 2899, __extension__ __PRETTY_FUNCTION__
)); memset(stream.data, 0, 1024); stream.end = stream.data; stream
.data_size = 1024; stream.write_function = switch_console_stream_write
; stream.raw_write_function = switch_console_stream_raw_write
; stream.alloc_len = 1024; stream.alloc_chunk = 1024;
	if (!strcmp(direction, "inbound") && strcmp(sub_to_user,  caller)) {
		// If inbound and the entity is not the caller (i.e. internal to FS), then the direction is reversed
		// because it is not going through the B2BUA
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 2903, ((void*)0), SWITCH_LOG_DEBUG1, "sofia_presence_sub_callback: endpt is internal\n");
		direction = !strcasecmp(direction, "outbound") ? "inbound" : "outbound";
	}

}

if (!strcasecmp(direction, "outbound")) {
	direction = "recipient";
	dft_state = "early";
} else {
	direction = "initiator";
	dft_state = "confirmed";
}

if (is_dialog) {
	if (zstr(version)_zstr(version)) {
		version = "0";
	}

	stream.write_function(&stream,
						  "<?xml version=\"1.0\"?>\n"
						  "<dialog-info xmlns=\"urn:ietf:params:xml:ns:dialog-info\" "
						  "version=\"%s\" state=\"%s\" entity=\"%s\">\n", version, default_dialog, clean_id);

}

if (!zstr(uuid)_zstr(uuid)) {
	if (!zstr(answer_state)_zstr(answer_state)) {
		astate = answer_state;
	}

	if (zstr(astate)_zstr(astate)) {
		if (is_dialog) {
			astate = dft_state;
		} else {
			astate = "terminated";
		}
	}

	if (!strcasecmp(astate, "answered")) {
		astate = "confirmed";
	}


	if (is_dialog) {

		if (!strcasecmp(astate, "ringing")) {
			if (!strcasecmp(direction, "recipient")) {
				astate = "early";
			} else {
				astate = "confirmed";
			}
		}

		if (holding) {
			if (profile->pres_held_type == PRES_HELD_CONFIRMED) {
				astate = "confirmed";
			} else if (profile->pres_held_type == PRES_HELD_TERMINATED) {
				astate = "terminated";
			} else {
				astate = "early";
			}
		}


		if (!strcasecmp(astate, "hangup")) {
			astate = "terminated";
		}

		stream.write_function(&stream, "<dialog id=\"%s\" direction=\"%s\">\n", uuid, direction);
		stream.write_function(&stream, "<state>%s</state>\n", astate);
	} else {
		if (!strcasecmp(astate, "ringing")) {
			astate = "early";
		}
	}


	if ((sofia_test_pflag(profile, PFLAG_PRESENCE_DISABLE_EARLY)((profile)->pflags[PFLAG_PRESENCE_DISABLE_EARLY] ? 1 : 0) || switch_true(disable_early)) &&
		((!zstr(astate)_zstr(astate) && (!strcasecmp(astate, "early") || !strcasecmp(astate, "ringing") || (!strcasecmp(astate, "terminated") && !answered))))) {
		switch_safe_free(stream.data)if (stream.data) {free(stream.data);stream.data=((void*)0);};
		goto end;
	}

	if (!strcasecmp(astate, "early") || !strcasecmp(astate, "confirmed")) {

		clean_to_user = switch_mprintf("%s", sub_to_user ? sub_to_user : to_user);
		clean_from_user = switch_mprintf("%s", from_id ? from_id : from_user);

		if (is_dialog) {
			if (!zstr(clean_to_user)_zstr(clean_to_user) && !zstr(clean_from_user)_zstr(clean_from_user)) {
				stream.write_function(&stream, "<local>\n<identity display=\"%s\">sip:%s@%s</identity>\n", clean_to_user, clean_to_user, host);
				stream.write_function(&stream, "<target uri=\"sip:%s@%s\">\n", clean_to_user, host);
				stream.write_function(&stream, "<param pname=\"+sip.rendering\" pvalue=\"%s\"/>\n", holding ? "no" : "yes");

				stream.write_function(&stream, "</target>\n</local>\n");
				if (switch_true(switch_event_get_header(helper->event, "Presence-Privacy")switch_event_get_header_idx(helper->event, "Presence-Privacy"
, -1))) {
					stream.write_function(&stream, "<remote>\n<identity display=\"Anonymous\">sip:anonymous@anonymous.invalid</identity>\n");
				} else {
					stream.write_function(&stream, "<remote>\n<identity display=\"%s\">sip:%s@%s</identity>\n",
										  from_name ? from_name : clean_from_user, clean_from_user,
										  host);
				}
				stream.write_function(&stream, "<target uri=\"sip:**%s@%s\"/>\n", clean_to_user, host);
				stream.write_function(&stream, "</remote>\n");

			} else if (!strcasecmp(proto, "queue")) {
				stream.write_function(&stream, "<local>\n<identity display=\"queue\">sip:%s@%s;proto=queue</identity>\n",
									  !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<target uri=\"sip:%s@%s;proto=fifo\">\n", !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<param pname=\"+sip.rendering\" pvalue=\"no\"/>\n</target>\n</local>\n");
				stream.write_function(&stream, "<remote>\n<identity display=\"queue\">sip:%s@%s</identity>\n", uuid, host);
				if (skip_proto) {
					stream.write_function(&stream, "<target uri=\"sip:%s@%s\"/>\n", uuid, host);
				} else {
					stream.write_function(&stream, "<target uri=\"sip:queue+%s@%s\"/>\n", uuid, host);
				}

				stream.write_function(&stream, "</remote>\n");
			} else if (!strcasecmp(proto, "park")) {
				stream.write_function(&stream, "<local>\n<identity display=\"park\">sip:%s@%s;proto=park</identity>\n",
									  !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<target uri=\"sip:%s@%s;proto=park\">\n", !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<param pname=\"+sip.rendering\" pvalue=\"no\"/>\n</target>\n</local>\n");
				stream.write_function(&stream, "<remote>\n<identity display=\"park\">sip:%s</identity>\n", uuid);
				if (skip_proto) {
					stream.write_function(&stream, "<target uri=\"sip:%s@%s\"/>\n", uuid, host);
				} else {
					stream.write_function(&stream, "<target uri=\"sip:park+%s@%s\"/>\n", uuid, host);
				}
				stream.write_function(&stream, "</remote>\n");
			} else if (!strcasecmp(proto, "pickup")) {
				stream.write_function(&stream, "<local>\n<identity display=\"pickup\">sip:%s@%s;proto=pickup</identity>\n",
									  !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<target uri=\"sip:%s@%s;proto=pickup\">\n", !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<param pname=\"+sip.rendering\" pvalue=\"no\"/>\n</target>\n</local>\n");
				stream.write_function(&stream, "<remote>\n<identity display=\"pickup\">sip:%s@%s</identity>\n", uuid, host);
				if (skip_proto) {
					stream.write_function(&stream, "<target uri=\"sip:%s@%s\"/>\n", uuid, host);
				} else {
					stream.write_function(&stream, "<target uri=\"sip:pickup+%s@%s\"/>\n", uuid, host);
				}
				stream.write_function(&stream, "</remote>\n");
			} else if (!strcasecmp(proto, "conf")) {
				stream.write_function(&stream, "<local>\n<identity display=\"conference\">sip:%s@%s;proto=conference</identity>\n",
									  !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<target uri=\"sip:%s@%s;proto=conference\">\n",
									  !zstr(clean_to_user)_zstr(clean_to_user) ? clean_to_user : "unknown", host);
				stream.write_function(&stream, "<param pname=\"+sip.rendering\" pvalue=\"yes\"/>\n</target>\n</local>\n");
				stream.write_function(&stream, "<remote>\n<identity display=\"conference\">sip:%s@%s</identity>\n", uuid, host);
				if (skip_proto) {
					stream.write_function(&stream, "<target uri=\"sip:%s@%s\"/>\n", uuid, host);
				} else {
					stream.write_function(&stream, "<target uri=\"sip:conf+%s@%s\"/>\n", uuid, host);
				}
				stream.write_function(&stream, "</remote>\n");
			}
		}

		switch_safe_free(clean_to_user)if (clean_to_user) {free(clean_to_user);clean_to_user=((void*
)0);};
		switch_safe_free(clean_from_user)if (clean_from_user) {free(clean_from_user);clean_from_user=(
(void*)0);};
	}
	if (is_dialog) {
		stream.write_function(&stream, "</dialog>\n");
	}
}

if (is_dialog) {
	stream.write_function(&stream, "</dialog-info>\n");
	pl = stream.data;
	ct = "application/dialog-info+xml";
}

if (!zstr(astate)_zstr(astate) && !zstr(uuid)_zstr(uuid) &&
	helper && helper->stream.data && strcmp(helper->last_uuid, uuid) && strcasecmp(astate, "terminated") && strchr(uuid, '-')) {
	helper->stream.write_function(&helper->stream, "update sip_dialogs set state='%q' where hostname='%q' and profile_name='%q' and uuid='%q';",
								  astate, mod_sofia_globals.hostname, profile->name, uuid);
	switch_copy_string(helper->last_uuid, uuid, sizeof(helper->last_uuid));
}

if (zstr(astate)_zstr(astate)) astate = "";

if (!is_dialog) {
	switch_set_string(status_line, status)switch_copy_string(status_line, status, sizeof(status_line));

	if (in) {
		open = "open";

		if (switch_false(resub)) {
			const char *direction = switch_event_get_header(helper->event, "Caller-Direction")switch_event_get_header_idx(helper->event, "Caller-Direction"
, -1);
			const char *op, *what = "Ring";

			if (direction && !strcasecmp(direction, "outbound")) {
				op = switch_event_get_header(helper->event, "Other-Leg-Caller-ID-Number")switch_event_get_header_idx(helper->event, "Other-Leg-Caller-ID-Number"
, -1);
			} else {
				op = switch_event_get_header(helper->event, "Caller-Callee-ID-Number")switch_event_get_header_idx(helper->event, "Caller-Callee-ID-Number"
, -1);
			}

			if (zstr(op)_zstr(op)) {
				op = switch_event_get_header(helper->event, "Caller-Destination-Number")switch_event_get_header_idx(helper->event, "Caller-Destination-Number"
, -1);
			}

			if (direction) {
				what = strcasecmp(direction, "outbound") ? "Call" : "Ring";
			}

			if (!strcmp(astate, "early")) {
				if (!zstr(op)_zstr(op)) {
					//switch_snprintf(status_line, sizeof(status_line), "%sing", what);
					//} else {
					if (sofia_test_pflag(profile, PFLAG_PRESENCE_PRIVACY)((profile)->pflags[PFLAG_PRESENCE_PRIVACY] ? 1 : 0)) {
						switch_snprintf(status_line, sizeof(status_line), "%s", what);
					} else {
						switch_snprintf(status_line, sizeof(status_line), "%s %s", what, op);
					}
				}

				rpid = "on-the-phone";
				force_status = 1;

			} else if (!strcmp(astate, "confirmed")) {
				if (!zstr(op)_zstr(op)) {
					if (sofia_test_pflag(profile, PFLAG_PRESENCE_PRIVACY)((profile)->pflags[PFLAG_PRESENCE_PRIVACY] ? 1 : 0)) {
						switch_snprintf(status_line, sizeof(status_line), "On The Phone");
					} else {
						switch_snprintf(status_line, sizeof(status_line), "Talk %s", op);
					}
				} else {
					switch_snprintf(status_line, sizeof(status_line), "On The Phone");
				}

				rpid = "on-the-phone";
				force_status = 1;
			} else if (!strcmp(astate, "terminated") || !strcmp(astate, "hangup")) {
				//rpid = "online";
				//dialog_rpid = "";
				//force_event_status = "Available";
				term = 1;
			}

			if (!term && !strcmp(status, "hold")) {
				rpid = "on-the-phone";
				if (!zstr(op)_zstr(op)) {
					if (sofia_test_pflag(profile, PFLAG_PRESENCE_PRIVACY)((profile)->pflags[PFLAG_PRESENCE_PRIVACY] ? 1 : 0)) {
						switch_snprintf(status_line, sizeof(status_line), "Hold");
					} else {
						switch_snprintf(status_line, sizeof(status_line), "Hold %s", op);
					}
					force_status = 1;
				}
			}
		}
	} else {
		open = "closed";
	}

	if (!zstr(open_closed)_zstr(open_closed)) {
		open = open_closed;
	}

	prpid = translate_rpid(rpid);

	if (!zstr(dialog_status)_zstr(dialog_status) && !force_status) {
		status = dialog_status;
		switch_set_string(status_line, status)switch_copy_string(status_line, status, sizeof(status_line));
	}

	if (!zstr(force_event_status)_zstr(force_event_status)) {
		switch_set_string(status_line, force_event_status)switch_copy_string(status_line, force_event_status, sizeof(status_line
));
	}

	if (!zstr(dialog_rpid)_zstr(dialog_rpid)) {
		prpid = rpid = dialog_rpid;
	}

	contact_stripped = sofia_glue_strip_uri(contact_str);
	pl = gen_pidf(user_agent, clean_id, contact_stripped, open, rpid, prpid, status_line, &ct);
	free(contact_stripped);
}

} else {
if (in) {
	open = "open";
} else {
	open = "closed";
}

if (!zstr(open_closed)_zstr(open_closed)) {
	open = open_closed;
}

prpid = translate_rpid(rpid);

if (!zstr(dialog_status)_zstr(dialog_status)) {
	status = dialog_status;
}

if (!zstr(dialog_rpid)_zstr(dialog_rpid)) {
	prpid = rpid = dialog_rpid;
}

contact_stripped = sofia_glue_strip_uri(contact_str);
pl = gen_pidf(user_agent, clean_id, contact_stripped, open, rpid, prpid, status, &ct);
free(contact_stripped);
}


if (!is_dialog && helper->event && !switch_stristr("registered", status_line)){
const char *uuid = switch_event_get_header_nil(helper->event, "unique-id")(switch_event_get_header_idx(helper->event, "unique-id", -
1) ? switch_event_get_header_idx(helper->event, "unique-id"
, -1) : "");
const char *register_source = switch_event_get_header_nil(helper->event, "register-source")(switch_event_get_header_idx(helper->event, "register-source"
, -1) ? switch_event_get_header_idx(helper->event, "register-source"
, -1) : "");

if (!zstr(uuid)_zstr(uuid) && strchr(uuid, '-') && !zstr(status_line)_zstr(status_line) && !zstr(rpid)_zstr(rpid) && (zstr(register_source)_zstr(register_source) || strcasecmp(register_source, "register"))) {
	char *sql = switch_mprintf("update sip_dialogs set rpid='%q',status='%q' where hostname='%q' and profile_name='%q' and uuid='%q'",
							   rpid, status_line,
							   mod_sofia_globals.hostname, profile->name, uuid);
	sofia_glue_execute_sql(profile, &sql, SWITCH_TRUE);
}
}

send_presence_notify(profile, full_to, full_from, contact, expires, call_id, event, ip, port, ct, pl, NULL)_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,ip,port,ct,pl,((void*)0),"sofia_presence.c", (
const char *)__func__, 3222);


end:

switch_safe_free(free_me)if (free_me) {free(free_me);free_me=((void*)0);};

if (ext_profile) {
sofia_glue_release_profile(ext_profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 3230, ext_profile);
}

switch_safe_free(id)if (id) {free(id);id=((void*)0);};
switch_safe_free(clean_id)if (clean_id) {free(clean_id);clean_id=((void*)0);};
switch_safe_free(pl)if (pl) {free(pl);pl=((void*)0);};
switch_safe_free(to)if (to) {free(to);to=((void*)0);};

return 0;
3239}

3241static int sofia_presence_mwi_callback(void *pArg, int argc, char **argv, char **columnNames)
3242{
//char *sub_to_user = argv[3];
//char *sub_to_host = argv[4];
char *event = argv[5];
char *contact = argv[6];
char *call_id = argv[7];
char *full_from = argv[8];
char *expires = argv[10];
char *profile_name = argv[13];
char *body = argv[15];
char *full_to = argv[16];
char *remote_ip = argv[17];
char *remote_port = argv[18];

struct mwi_helper *h = (struct mwi_helper *) pArg;
sofia_profile_t *ext_profile = NULL((void*)0), *profile = h->profile;


if (mod_sofia_globals.debug_presence > 0) {
int i;
for(i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3263, ((void*)0), SWITCH_LOG_CRIT, "arg %d[%s] = [%s]\n", i, columnNames[i], argv[i]);
}
}

if (profile_name && strcasecmp(profile_name, h->profile->name)) {
if ((ext_profile = sofia_glue_find_profile(profile_name)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 3268, profile_name))) {
	profile = ext_profile;
}
}

send_presence_notify(profile,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 full_to,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 full_from,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 contact,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 expires,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 call_id,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 event,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 remote_ip,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 remote_port,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 "application/simple-message-summary",_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 body,_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 NULL_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
)
				 )_send_presence_notify(profile,full_to,full_from,contact,expires
,call_id,event,remote_ip,remote_port,"application/simple-message-summary"
,body,((void*)0),"sofia_presence.c", (const char *)__func__, 3285
);


h->total++;

if (ext_profile) {
sofia_glue_release_profile(ext_profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 3291, ext_profile);
}

return 0;
3295}

3297static int sofia_presence_mwi_callback2(void *pArg, int argc, char **argv, char **columnNames)
3298{
const char *user = argv[0];
const char *host = argv[1];
const char *event = "message-summary";
const char *contenttype = "application/simple-message-summary";
const char *body = argv[5];
const char *o_contact = argv[2];
const char *network_ip = argv[4];
const char *call_id = argv[6];

char *profile_name = argv[3];
struct mwi_helper *h = (struct mwi_helper *) pArg;
sofia_profile_t *ext_profile = NULL((void*)0), *profile = h->profile;

if (profile_name && strcasecmp(profile_name, h->profile->name)) {
if ((ext_profile = sofia_glue_find_profile(profile_name)sofia_glue_find_profile__("sofia_presence.c", (const char *)__func__
, 3313, profile_name))) {
	profile = ext_profile;
}
}

if (!sofia_test_pflag(profile, PFLAG_MWI_USE_REG_CALLID)((profile)->pflags[PFLAG_MWI_USE_REG_CALLID] ? 1 : 0)) {
call_id = NULL((void*)0);
}

sofia_glue_send_notify(profile, user, host, event, contenttype, body, o_contact, network_ip, call_id);

if (ext_profile) {
sofia_glue_release_profile(ext_profile)sofia_glue_release_profile__("sofia_presence.c", (const char *
)__func__, 3325, ext_profile);
}

return 0;
3329}

3331static int broadsoft_sla_notify_callback(void *pArg, int argc, char **argv, char **columnNames)
3332{
struct state_helper *sh = (struct state_helper *) pArg;
char key[256] = "";
char *data = NULL((void*)0), *tmp;
char *call_id = argv[0];
//char *expires = argv[1];
char *user = argv[2];
char *host = argv[3];
char *event = argv[4];
int i;


if (mod_sofia_globals.debug_sla > 1) {
for (i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3346, ((void*)0), SWITCH_LOG_ERROR, "SLA3: %d [%s]=[%s]\n", i, columnNames[i], argv[i]);
}
}

switch_snprintf(key, sizeof(key), "%s%s", user, host);
data = switch_core_hash_find(sh->hash, key);

if (data) {
tmp = switch_core_sprintf(sh->pool, "%s,<sip:%s>;appearance-index=*;appearance-state=idle", data, host);
} else {
tmp = switch_core_sprintf(sh->pool, "<sip:%s>;appearance-index=*;appearance-state=idle", host);
}


if (!strcasecmp(event, "line-seize")) {
char *hack;

if ((hack = (char *) switch_stristr("=seized", tmp))) {
	switch_snprintf(hack, 7, "=idle  ");
}
}

if (mod_sofia_globals.debug_sla > 1) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3369, ((void*)0), SWITCH_LOG_ERROR, "DB PRES NOTIFY: [%s]\n[%s]\n[%s]\n[%s]\n[%s]\n[%s]\n[%s]\n[%s]\n[%s]\n",
				  argv[5], argv[6], argv[7], argv[8], call_id, event, argv[9], argv[10], tmp);

}

send_presence_notify(sh->profile, argv[5], argv[6], argv[7], argv[8], call_id, event, argv[9], argv[10], NULL, NULL, tmp)_send_presence_notify(sh->profile,argv[5],argv[6],argv[7],
argv[8],call_id,event,argv[9],argv[10],((void*)0),((void*)0),
tmp,"sofia_presence.c", (const char *)__func__, 3374);

sh->total++;

return 0;
3379}

3381static int broadsoft_sla_gather_state_callback(void *pArg, int argc, char **argv, char **columnNames)
3382{
struct state_helper *sh = (struct state_helper *) pArg;
char key[256] = "";
switch_core_session_t *session;
const char *callee_name = NULL((void*)0), *callee_number = NULL((void*)0);
char *data = NULL((void*)0), *tmp;
char *user = argv[0];
char *host = argv[1];
char *info = argv[2];
char *state = argv[3];
char *uuid = argv[4];
int i;

if (mod_sofia_globals.debug_sla > 1) {
for (i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3397, ((void*)0), SWITCH_LOG_ERROR, "SLA2: %d [%s]=[%s]\n", i, columnNames[i], argv[i]);
}
}

if (zstr(info)_zstr(info)) {
return 0;
}

if (zstr(state)_zstr(state)) {
state = "idle";
}

switch_snprintf(key, sizeof(key), "%s%s", user, host);

data = switch_core_hash_find(sh->hash, key);

if (strcasecmp(state, "idle") && uuid && (session = switch_core_session_locate(uuid)switch_core_session_perform_locate(uuid, "sofia_presence.c", (
const char *)__func__, 3413))) {
switch_channel_t *channel = switch_core_session_get_channel(session);

if (switch_channel_test_flag(channel, CF_ORIGINATOR) || switch_channel_test_flag(channel, CF_BRIDGE_ORIGINATOR) ||
	switch_channel_inbound_display(channel)((switch_channel_direction(channel) == SWITCH_CALL_DIRECTION_INBOUND
 && !switch_channel_test_flag(channel, CF_BLEG)) || (
switch_channel_direction(channel) == SWITCH_CALL_DIRECTION_OUTBOUND
 && switch_channel_test_flag(channel, CF_DIALPLAN))) || switch_channel_test_flag(channel, CF_SLA_BARGING)) {
	if (!switch_channel_test_flag(channel, CF_ANSWERED)) state = "progressing";
	callee_name = switch_channel_get_variable(channel, "callee_id_name")switch_channel_get_variable_dup(channel, "callee_id_name", SWITCH_TRUE
, -1);
	callee_number = switch_channel_get_variable(channel, "callee_id_number")switch_channel_get_variable_dup(channel, "callee_id_number", SWITCH_TRUE
, -1);

	if (zstr(callee_number)_zstr(callee_number)) {
		callee_number = switch_channel_get_variable(channel, "destination_number")switch_channel_get_variable_dup(channel, "destination_number"
, SWITCH_TRUE, -1);
	}

} else {
	callee_name = switch_channel_get_variable(channel, "caller_id_name")switch_channel_get_variable_dup(channel, "caller_id_name", SWITCH_TRUE
, -1);
	callee_number = switch_channel_get_variable(channel, "caller_id_number")switch_channel_get_variable_dup(channel, "caller_id_number", SWITCH_TRUE
, -1);
}

if (zstr(callee_name)_zstr(callee_name) && !zstr(callee_number)_zstr(callee_number)) {
	callee_name = callee_number;
}

if (!zstr(callee_number)_zstr(callee_number)) {
	callee_number = switch_sanitize_number(switch_core_session_strdup(session, callee_number)switch_core_perform_session_strdup(session, callee_number, "sofia_presence.c"
, (const char *)__func__, 3436));
}

if (!zstr(callee_name)_zstr(callee_name)) {
	char *tmp = switch_core_session_strdup(session, callee_name)switch_core_perform_session_strdup(session, callee_name, "sofia_presence.c"
, (const char *)__func__, 3440);
	switch_url_decode(tmp);
	callee_name = switch_sanitize_number(tmp);
}


//if (switch_channel_get_state(channel) != CS_EXECUTE) {
	//callee_number = NULL;
//}

switch_core_session_rwunlock(session);
}

if (data && strstr(data, info)) {
return 0;
}


if (!zstr(callee_number)_zstr(callee_number)) {
if (zstr(callee_name)_zstr(callee_name)) {
	callee_name = "unknown";
}

if (data) {
	tmp = switch_core_sprintf(sh->pool,
							  "%s,<sip:%s>;%s;appearance-state=%s;appearance-uri=\"\\\"%s\\\" <sip:%s@%s>\"",
							  data, host, info, state, callee_name, callee_number, host);
} else {
	tmp = switch_core_sprintf(sh->pool,
							  "<sip:%s>;%s;appearance-state=%s;appearance-uri=\"\\\"%s\\\" <sip:%s@%s>\"",
							  host, info, state, callee_name, callee_number, host);
}
} else {
if (data) {
	tmp = switch_core_sprintf(sh->pool, "%s,<sip:%s>;%s;appearance-state=%s", data, host, info, state);
} else {
	tmp = switch_core_sprintf(sh->pool, "<sip:%s>;%s;appearance-state=%s", host, info, state);
}
}

switch_core_hash_insert(sh->hash, key, tmp)switch_core_hash_insert_destructor(sh->hash, key, tmp, ((void
*)0));

return 0;
3483}

3485static int sync_sla(sofia_profile_t *profile, const char *to_user, const char *to_host, switch_bool_t clear, switch_bool_t unseize, const char *call_id)
3486{
struct state_helper *sh;
switch_memory_pool_t *pool;
char *sql;
int total = 0;


if (clear) {
struct pres_sql_cb cb = {profile, 0};


if (call_id) {

	sql = switch_mprintf("update sip_subscriptions set version=version+1,expires=%ld where "
						 "call_id='%q' "
						 "and event='line-seize'", (long) switch_epoch_time_now(NULL((void*)0)),
						 call_id);

	sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);

	if (mod_sofia_globals.debug_sla > 1) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3507, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
	}
	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

	sql = switch_mprintf("select full_to, full_from, contact, -1, call_id, event, network_ip, network_port, "
						 "NULL as ct, NULL as pt "
						 " from sip_subscriptions where call_id='%q' "

						 "and event='line-seize'", call_id);

	sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_send_sql, &cb);
	if (mod_sofia_globals.debug_sla > 1) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3519, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
	}
	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
} else {

	sql = switch_mprintf("update sip_subscriptions set version=version+1,expires=%ld where "
						 "hostname='%q' and profile_name='%q' "
						 "and sub_to_user='%q' and sub_to_host='%q' "

						 "and event='line-seize'", (long) switch_epoch_time_now(NULL((void*)0)),
						 mod_sofia_globals.hostname, profile->name, to_user, to_host
						 );

	if (mod_sofia_globals.debug_sla > 1) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3533, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
	}

	sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);


	sql = switch_mprintf("select full_to, full_from, contact, -1, call_id, event, network_ip, network_port, "
						 "NULL as ct, NULL as pt "
						 " from sip_subscriptions where "
						 "hostname='%q' and profile_name='%q' "
						 "and sub_to_user='%q' and sub_to_host='%q' "
						 "and event='line-seized'",
						 mod_sofia_globals.hostname, profile->name, to_user, to_host
						 );

	sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_send_sql, &cb);

	if (mod_sofia_globals.debug_sla > 1) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3551, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
	}

	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
}


sql = switch_mprintf("delete from sip_dialogs where hostname='%q' and profile_name='%q' and "
					 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') "
					 "and call_info_state='seized'", mod_sofia_globals.hostname, profile->name, to_user, to_host, to_user, to_host);


if (mod_sofia_globals.debug_sla > 1) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3564, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
}
sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
}


switch_core_new_memory_pool(&pool)switch_core_perform_new_memory_pool(&pool, "sofia_presence.c"
, (const char *)__func__, 3571);
sh = switch_core_alloc(pool, sizeof(*sh))switch_core_perform_alloc(pool, sizeof(*sh), "sofia_presence.c"
, (const char *)__func__, 3572);
sh->pool = pool;
switch_core_hash_init(&sh->hash)switch_core_hash_init_case(&sh->hash, SWITCH_TRUE);

sql = switch_mprintf("select sip_from_user,sip_from_host,call_info,call_info_state,uuid from sip_dialogs "
				 "where call_info_state is not null and call_info_state != '' and call_info_state != 'idle' and hostname='%q' and profile_name='%q' "
				 "and ((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') "
				 "and profile_name='%q'",
				 mod_sofia_globals.hostname, profile->name, to_user, to_host, to_user, to_host, profile->name);


if (mod_sofia_globals.debug_sla > 1) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3584, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
}
sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, broadsoft_sla_gather_state_callback, sh);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};


if (!zstr(call_id)_zstr(call_id)) {

if (unseize) {
	sql = switch_mprintf("select call_id,expires,sub_to_user,sub_to_host,event,full_to,full_from,contact,expires,network_ip,network_port "
						 "from sip_subscriptions where call_id='%q' and hostname='%q' and profile_name='%q' "
						 "and (event='call-info' or event='line-seize')",
						 call_id, mod_sofia_globals.hostname, profile->name);

} else {
	sql = switch_mprintf("select call_id,expires,sub_to_user,sub_to_host,event,full_to,full_from,contact,expires,network_ip,network_port "
						 "from sip_subscriptions where call_id='%q' and hostname='%q' and profile_name='%q' and event='call-info'",
						 call_id, mod_sofia_globals.hostname, profile->name);
}

} else {

if (unseize) {
	sql = switch_mprintf("select call_id,expires,sub_to_user,sub_to_host,event,full_to,full_from,contact,expires,network_ip,network_port "
						 "from sip_subscriptions "
						 "where hostname='%q' and profile_name='%q' "
						 "and sub_to_user='%q' and sub_to_host='%q' "
						 "and (event='call-info' or event='line-seize') and (profile_name='%q' or presence_hosts like '%%%q%%')",
						 mod_sofia_globals.hostname, profile->name, to_user, to_host, profile->name, to_host);
} else {
	sql = switch_mprintf("select call_id,expires,sub_to_user,sub_to_host,event,full_to,full_from,contact,expires,network_ip,network_port "
						 "from sip_subscriptions "
						 "where hostname='%q' and profile_name='%q' "
						 "and sub_to_user='%q' and sub_to_host='%q' " "and (event='call-info') and "
						 "(profile_name='%q' or presence_hosts like '%%%q%%')",
						 mod_sofia_globals.hostname, profile->name, to_user, to_host, profile->name, to_host);
}
}

if (mod_sofia_globals.debug_sla > 1) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3624, ((void*)0), SWITCH_LOG_ERROR, "PRES SQL %s\n", sql);
}

sh->profile = profile;
sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, broadsoft_sla_notify_callback, sh);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
total = sh->total;
switch_core_hash_destroy(&sh->hash);

sh = NULL((void*)0);
switch_core_destroy_memory_pool(&pool)switch_core_perform_destroy_memory_pool(&pool, "sofia_presence.c"
, (const char *)__func__, 3634);





return total;

3642}

3644void sofia_presence_handle_sip_i_subscribe(int status,
								   char const *phrase,
								   nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, sofia_private_t *sofia_private, sip_t const *sip,
								   sofia_dispatch_event_t *de,
								   tagi_t tags[])
3649{

long exp_delta = 0;
char exp_delta_str[30] = "";
uint32_t sub_max_deviation_var = 0;
sip_to_t const *to;
const char *from_user = NULL((void*)0), *from_host = NULL((void*)0);
const char *to_user = NULL((void*)0), *to_host = NULL((void*)0);
char *my_to_user = NULL((void*)0);
char *sql, *event = NULL((void*)0);
char *proto = "sip";
char *orig_proto = "";
char *alt_proto = NULL((void*)0);
char *d_user = NULL((void*)0);
char *contact_str = "";
const char *call_id = NULL((void*)0);
char *to_str = NULL((void*)0);
char *full_from = NULL((void*)0);
char *full_to = NULL((void*)0);
char *full_via = NULL((void*)0);
char *full_agent = NULL((void*)0);
char *sstr;
switch_event_t *sevent;
int sub_state = nua_substate_pending;
int sent_reply = 0;
sip_contact_t const *contact;
const char *ipv6;
const char *contact_user = NULL((void*)0);
const char *contact_host = NULL((void*)0);
const char *contact_port = NULL((void*)0);
sofia_nat_parse_t np = { { 0 } };
int found_proto = 0;
const char *use_to_tag;
char to_tag[13] = "";
char buf[1025] = "";
char *orig_to_user = NULL((void*)0);
char *p;
uint32_t callsequence;
  sip_cseq_t * cseq;

if (!sip) {
return;
}

to = sip->sip_to;
contact = sip->sip_contact;

np.fs_path = 1;
if (!(contact_str = sofia_glue_gen_contact_str(profile, sip, nh, de, &np))) {
nua_respond(nh, 481, "INVALID SUBSCRIPTION", TAG_END()(tag_type_t)0, (tag_value_t)0);
return;
}

if (sip->sip_to && sip->sip_to->a_tag) {
use_to_tag = sip->sip_to->a_tag;
} else {
switch_stun_random_string(to_tag, 12, NULL((void*)0));
use_to_tag = to_tag;
}

if (sip->sip_contact) {
contact_host = sip->sip_contact->m_url->url_host;
contact_port = sip->sip_contact->m_url->url_port;
contact_user = sip->sip_contact->m_url->url_user;
}

full_agent = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_user_agent);

//tl_gets(tags, NUTAG_SUBSTATE_REF(sub_state), TAG_END());

//sip->sip_subscription_state->ss_substate

if (sip->sip_subscription_state && sip->sip_subscription_state->ss_substate) {
if (switch_stristr("terminated", sip->sip_subscription_state->ss_substate)) {
	sub_state = nua_substate_terminated;
} else if (switch_stristr("active", sip->sip_subscription_state->ss_substate)) {
	sub_state = nua_substate_active;
}
}

event = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_event);

if (to) {
to_str = switch_mprintf("sip:%s@%s", to->a_url->url_user, to->a_url->url_host);
to_user = to->a_url->url_user;
to_host = to->a_url->url_host;
}

if (profile->sub_domain) {
to_host = profile->sub_domain;
}

if (sip->sip_from) {
from_user = sip->sip_from->a_url->url_user;
from_host = sip->sip_from->a_url->url_host;
} else {
from_user = "n/a";
from_host = "n/a";
}

if ((exp_delta = sip->sip_expires ? sip->sip_expires->ex_delta : 3600)) {
if ((profile->force_subscription_expires > 0) && (profile->force_subscription_expires < (uint32_t)exp_delta)) {
	exp_delta = profile->force_subscription_expires;
}
}

if ((sub_max_deviation_var = profile->sip_subscription_max_deviation)) {
int sub_deviation;
srand( (unsigned) ( (unsigned)(intptr_t)switch_thread_self() + switch_micro_time_now() ) );
/* random negative number between 0 and negative sub_max_deviation_var: */
sub_deviation = ( rand() % sub_max_deviation_var ) - sub_max_deviation_var;
if ( (exp_delta + sub_deviation) > 45 ) {
	exp_delta += sub_deviation;
}
}

if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3766, ((void*)0), SWITCH_LOG_ERROR, "DELTA %ld\n", exp_delta);
}

if (!exp_delta) {
sub_state = nua_substate_terminated;
}

switch_snprintf(exp_delta_str, sizeof(exp_delta_str), "%ld", exp_delta);

if (!strcmp("as-feature-event", event)) {
sip_authorization_t const *authorization = NULL((void*)0);
auth_res_t auth_res = AUTH_FORBIDDEN;
char key[128] = "";
switch_event_t *v_event = NULL((void*)0);


if (sip->sip_authorization) {
	authorization = sip->sip_authorization;
} else if (sip->sip_proxy_authorization) {
	authorization = sip->sip_proxy_authorization;
}

if (authorization) {
	char network_ip[80];
	int network_port;
	sofia_glue_get_addr(de->data->e_msg, network_ip, sizeof(network_ip), &network_port);
	auth_res = sofia_reg_parse_auth(profile, authorization, sip, de,
									(char *) sip->sip_request->rq_method_name, key, sizeof(key), network_ip, network_port, &v_event, 0,
									REG_REGISTER, to_user, NULL((void*)0), NULL((void*)0), NULL((void*)0));
	if (v_event) switch_event_destroy(&v_event);
} else if (sofia_reg_handle_register(nua, profile, nh, sip, de, REG_REGISTER, key, sizeof(key), &v_event, NULL, NULL, NULL)sofia_reg_handle_register_token(nua, profile, nh, sip, de, REG_REGISTER
, key, sizeof(key), &v_event, ((void*)0), ((void*)0), ((void
*)0), ((void*)0))) {
	if (v_event) switch_event_destroy(&v_event);
	goto end;
}

if ((auth_res != AUTH_OK && auth_res != AUTH_RENEWED)) {
	nua_respond(nh, SIP_401_UNAUTHORIZED401, sip_401_Unauthorized, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	goto end;
}
} else if (sofia_test_pflag(profile, PFLAG_AUTH_SUBSCRIPTIONS)((profile)->pflags[PFLAG_AUTH_SUBSCRIPTIONS] ? 1 : 0)) {
sip_authorization_t const *authorization = NULL((void*)0);
auth_res_t auth_res = AUTH_FORBIDDEN;
char keybuf[128] = "";
char *key;
size_t keylen;
switch_event_t *v_event = NULL((void*)0);

key = keybuf;
keylen = sizeof(keybuf);

if (sip->sip_authorization) {
	authorization = sip->sip_authorization;
} else if (sip->sip_proxy_authorization) {
	authorization = sip->sip_proxy_authorization;
}

if (authorization) {
	char network_ip[80];
	int network_port;
	sofia_glue_get_addr(de->data->e_msg, network_ip, sizeof(network_ip), &network_port);
	auth_res = sofia_reg_parse_auth(profile, authorization, sip, de,
									(char *) sip->sip_request->rq_method_name, key, keylen, network_ip, network_port, NULL((void*)0), 0,
									REG_INVITE, NULL((void*)0), NULL((void*)0), NULL((void*)0), NULL((void*)0));
} else if ( sofia_reg_handle_register(nua, profile, nh, sip, de, REG_INVITE, key, (uint32_t)keylen, &v_event, NULL, NULL, NULL)sofia_reg_handle_register_token(nua, profile, nh, sip, de, REG_INVITE
, key, (uint32_t)keylen, &v_event, ((void*)0), ((void*)0)
, ((void*)0), ((void*)0))) {
	if (v_event) {
		switch_event_destroy(&v_event);
	}

	goto end;
}

if ((auth_res != AUTH_OK && auth_res != AUTH_RENEWED)) {
	nua_respond(nh, SIP_401_UNAUTHORIZED401, sip_401_Unauthorized, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	goto end;
}
}

orig_to_user = su_strdup(nua_handle_home(nh)((su_home_t *)(nh)), to_user);

if (to_user && (p = strchr(to_user, '+')) && p != to_user) {
char *h;
if ((proto = (d_user = strdup(to_user)))) {
	if ((my_to_user = strchr(d_user, '+'))) {
		*my_to_user++ = '\0';
		to_user = my_to_user;
		if ((h = strchr(to_user, '+')) || (h = strchr(to_user, '@'))) {
			*h++ = '\0';
			to_host = h;
		}
	}
}

if (!(proto && to_host)) {
	nua_respond(nh, SIP_404_NOT_FOUND404, sip_404_Not_found, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	goto end;
}

found_proto++;
}

call_id = sip->sip_call_id->i_id;
full_from = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_from);
full_to = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_to);
full_via = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_via);


if (sip->sip_expires && sip->sip_expires->ex_delta > 31536000) {
sip->sip_expires->ex_delta = 31536000;
}

if (sofia_test_pflag(profile, PFLAG_PRESENCE_MAP)((profile)->pflags[PFLAG_PRESENCE_MAP] ? 1 : 0) && !found_proto && (alt_proto = switch_ivr_check_presence_mapping(to_user, to_host))) {
orig_proto = proto;
proto = alt_proto;
}

if ((sub_state != nua_substate_terminated)) {
sql = switch_mprintf("select contact from sip_subscriptions where call_id='%q' and profile_name='%q' and hostname='%q'",
					 call_id, profile->name, mod_sofia_globals.hostname);
sofia_glue_execute_sql2str(profile, profile->dbh_mutex, sql, buf, sizeof(buf));


if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3888, ((void*)0), SWITCH_LOG_ERROR,
					  "check subs sql: %s [%s]\n", sql, buf);
}

switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

if (!zstr(buf)_zstr(buf)) {
	sub_state = nua_substate_active;
}
}

if (sub_state == nua_substate_active) {
char *contact = contact_str;

sstr = switch_mprintf("active;expires=%ld", exp_delta);

if (strstr(buf, "fs_path=") && !strstr(contact_str, "fs_path=")) {
	char *e = strchr(buf,';');
	size_t l = e ? e-buf : strlen(buf);
	if (!strncmp(contact_str,buf,l)) {
		contact = buf;
	}
}

sql = switch_mprintf("update sip_subscriptions "
					 "set expires=%ld, "
					 "network_ip='%q',network_port='%d',sip_user='%q',sip_host='%q',full_via='%q',full_to='%q',full_from='%q',contact='%q' "
					 "where call_id='%q' and profile_name='%q' and hostname='%q'",
					 (long) switch_epoch_time_now(NULL((void*)0)) + exp_delta,
					 np.network_ip, np.network_port, from_user, from_host, full_via, full_to, full_from, contact,

					 call_id, profile->name, mod_sofia_globals.hostname);

if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3922, ((void*)0), SWITCH_LOG_ERROR,
					  "re-subscribe event %s, sql: %s\n", event, sql);
}

sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
} else {

if (sub_state == nua_substate_terminated) {
	sql = switch_mprintf("delete from sip_subscriptions where call_id='%q' and profile_name='%q' and hostname='%q'",
						 call_id, profile->name, mod_sofia_globals.hostname);

	if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3934, ((void*)0), SWITCH_LOG_ERROR,
						  "sub del sql: %s\n", sql);
	}

	switch_assert(sql != NULL)((sql != ((void*)0)) ? (void) (0) : __assert_fail ("sql != ((void*)0)"
, "sofia_presence.c", 3938, __extension__ __PRETTY_FUNCTION__
));
	sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
	sstr = switch_mprintf("terminated;reason=noresource");

} else {
	sip_accept_t *ap = sip->sip_accept;
	char accept_header[256] = "";

	sub_state = nua_substate_active;

	while (ap) {
		switch_snprintf(accept_header + strlen(accept_header), sizeof(accept_header) - strlen(accept_header),
						"%s%s ", ap->ac_type, ap->ac_next ? "," : "");
		ap = ap->ac_next;
	}

	sql = switch_mprintf("insert into sip_subscriptions "
						 "(proto,sip_user,sip_host,sub_to_user,sub_to_host,presence_hosts,event,contact,call_id,full_from,"
						 "full_via,expires,user_agent,accept,profile_name,hostname,network_port,network_ip,version,orig_proto, full_to) "
						 "values ('%q','%q','%q','%q','%q','%q','%q','%q','%q','%q','%q',%ld,'%q','%q','%q','%q','%d','%q',-1,'%q','%q;tag=%q')",
						 proto, from_user, from_host, to_user, to_host, profile->presence_hosts ? profile->presence_hosts : "",
						 event, contact_str, call_id, full_from, full_via,
						 (long) switch_epoch_time_now(NULL((void*)0)) + exp_delta,
						 full_agent, accept_header, profile->name, mod_sofia_globals.hostname,
						 np.network_port, np.network_ip, orig_proto, full_to, use_to_tag);

	switch_assert(sql != NULL)((sql != ((void*)0)) ? (void) (0) : __assert_fail ("sql != ((void*)0)"
, "sofia_presence.c", 3964, __extension__ __PRETTY_FUNCTION__
));


	if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 3968, ((void*)0), SWITCH_LOG_NOTICE, "%s SUBSCRIBE %s@%s %s@%s\n%s\n",
						  profile->name, from_user, from_host, to_user, to_host, sql);
	}


	sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
	sstr = switch_mprintf("active;expires=%ld", exp_delta);
}

}

if ( sip->sip_event && sip->sip_event->o_type && !strcasecmp(sip->sip_event->o_type, "ua-profile") && contact_host ) {
char *uri = NULL((void*)0);
char *ct = "application/url";
char *extra_headers = NULL((void*)0);

if ( contact_port ) {
	uri = switch_mprintf("sip:%s:%s", contact_host, contact_port);
} else {
	uri = switch_mprintf("sip:%s", contact_host);
}

if ( uri ) {
	switch_event_t *params = NULL((void*)0);
	/* Grandstream REALLY uses a header called Message Body */
	extra_headers = switch_mprintf("MessageBody: %s\r\n", profile->pnp_prov_url);
	if (sofia_test_pflag(profile, PFLAG_SUBSCRIBE_RESPOND_200_OK)((profile)->pflags[PFLAG_SUBSCRIBE_RESPOND_200_OK] ? 1 : 0
)) {
		nua_respond(nh, SIP_200_OK200, sip_200_OK, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	} else {
		nua_respond(nh, SIP_202_ACCEPTED202, sip_202_Accepted, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	}

	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4000, ((void*)0), SWITCH_LOG_DEBUG, "sending pnp NOTIFY for %s to provision to %s\n", uri, profile->pnp_prov_url);

	switch_event_create(&params, SWITCH_EVENT_NOTIFY)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4002, &params, SWITCH_EVENT_NOTIFY
, ((void*)0));
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "profile", profile->name);
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "event-string", sip->sip_event->o_type);
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "to-uri", uri);
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "from-uri", uri);
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "extra-headers", extra_headers);
	switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "content-type", ct);
	switch_event_add_body(params, "%s", profile->pnp_prov_url);
	switch_event_fire(&params)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4010, &params, ((void*)0));

	switch_safe_free(uri)if (uri) {free(uri);uri=((void*)0);};
	switch_safe_free(extra_headers)if (extra_headers) {free(extra_headers);extra_headers=((void*
)0);};

	goto end;
}
}

if (status < 200) {
char *sticky = NULL((void*)0);
char *contactstr, *cs = NULL((void*)0);
char *p = NULL((void*)0), *new_contactstr = NULL((void*)0);
sofia_transport_t transport;

if (np.is_nat) {
	char params[128] = "";
	if (contact->m_url->url_params) {
		switch_snprintf(params, sizeof(params), ";%s", contact->m_url->url_params);
	}
	ipv6 = strchr(np.network_ip, ':');
	sticky = switch_mprintf("sip:%s@%s%s%s:%d%s", contact_user, ipv6 ? "[" : "", np.network_ip, ipv6 ? "]" : "", np.network_port, params);
}

if (np.is_auto_nat) {
	contactstr = profile->public_url;
} else {
	contactstr = profile->url;
}

if (sip->sip_via) {
	transport = sofia_glue_via2transport(sip->sip_via);
} else {
	transport = sofia_glue_url2transport(contact->m_url);
}

if (transport == SOFIA_TRANSPORT_TCP) {
	if (np.is_auto_nat) {
		cs = profile->tcp_public_contact;
	} else {
		cs = profile->tcp_contact;
	}
} else if (transport == SOFIA_TRANSPORT_TCP_TLS) {
	if (np.is_auto_nat) {
		cs = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?	profile->tls_public_contact : profile->tcp_public_contact;
	} else {
		cs = sofia_test_pflag(profile, PFLAG_TLS)((profile)->pflags[PFLAG_TLS] ? 1 : 0) ?	profile->tls_contact : profile->tcp_contact;
	}
}

if (cs) {
	contactstr = cs;
}


if (nh) {
	/* nua_dialog_usage_set_refresh_range(nh->nh_ds->ds_usage, exp_delta + SUB_OVERLAP, exp_delta + SUB_OVERLAP); */
	nua_handle_dialog_usage_set_refresh_range(nh, exp_delta, exp_delta);
}

if (contactstr && (p = strchr(contactstr, '@'))) {
	if (strrchr(p, '>')) {
		new_contactstr = switch_mprintf("<sip:%s%s", orig_to_user, p);
	} else {
		new_contactstr = switch_mprintf("<sip:%s%s>", orig_to_user, p);
	}
}

if (nh) {
	sip_to_tag(nua_handle_get_home(nh), sip->sip_to, use_to_tag);
}

if (mod_sofia_globals.debug_presence > 0) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4083, ((void*)0), SWITCH_LOG_DEBUG, "Responding to SUBSCRIBE with 202 Accepted\n");
}
if (sofia_test_pflag(profile, PFLAG_SUBSCRIBE_RESPOND_200_OK)((profile)->pflags[PFLAG_SUBSCRIBE_RESPOND_200_OK] ? 1 : 0
)) {
	nua_respond(nh, SIP_200_OK200, sip_200_OK,
				SIPTAG_TO(sip->sip_to)siptag_to, siptag_to_v(sip->sip_to),
				TAG_IF(new_contactstr, SIPTAG_CONTACT_STR(new_contactstr))!(new_contactstr) ? tag_skip : siptag_contact_str, tag_str_v(
new_contactstr),
				NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg),
				SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr), SIPTAG_EXPIRES_STR(exp_delta_str)siptag_expires_str, tag_str_v(exp_delta_str), TAG_IF(sticky, NUTAG_PROXY(sticky))!(sticky) ? tag_skip : ntatag_default_proxy, urltag_url_v((sticky
)), TAG_END()(tag_type_t)0, (tag_value_t)0);
} else {
	nua_respond(nh, SIP_202_ACCEPTED202, sip_202_Accepted,
				SIPTAG_TO(sip->sip_to)siptag_to, siptag_to_v(sip->sip_to),
				TAG_IF(new_contactstr, SIPTAG_CONTACT_STR(new_contactstr))!(new_contactstr) ? tag_skip : siptag_contact_str, tag_str_v(
new_contactstr),
				NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg),
				SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr), SIPTAG_EXPIRES_STR(exp_delta_str)siptag_expires_str, tag_str_v(exp_delta_str), TAG_IF(sticky, NUTAG_PROXY(sticky))!(sticky) ? tag_skip : ntatag_default_proxy, urltag_url_v((sticky
)), TAG_END()(tag_type_t)0, (tag_value_t)0);
}

switch_safe_free(new_contactstr)if (new_contactstr) {free(new_contactstr);new_contactstr=((void
*)0);};
switch_safe_free(sticky)if (sticky) {free(sticky);sticky=((void*)0);};

if (sub_state == nua_substate_terminated) {
	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4104, ((void*)0), SWITCH_LOG_DEBUG, "Sending NOTIFY with Expires [0] and State [%s]\n", sstr);
	}

	if (zstr(full_agent)_zstr(full_agent) || (*full_agent != 'z' && *full_agent != 'Z')) {
		/* supress endless loop bug with zoiper */
		callsequence = sofia_presence_get_cseq(profile);
		cseq = sip_cseq_create(nua_handle_get_home(nh), callsequence, SIP_METHOD_NOTIFYsip_method_notify, "NOTIFY");
		nua_notify(nh,
				   SIPTAG_EXPIRES_STR("0")siptag_expires_str, tag_str_v("0"),
				   SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr),
				   SIPTAG_CSEQ(cseq)siptag_cseq, siptag_cseq_v(cseq),
				   TAG_END()(tag_type_t)0, (tag_value_t)0);
	}


}
}

if (sub_state == nua_substate_terminated) {
char *full_call_info = NULL((void*)0);
char *p = NULL((void*)0);

if (sip->sip_call_info) {
	full_call_info = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_call_info);
	if ((p = strchr(full_call_info, ';'))) {
		p++;
	}

4132#if 0
	nua_notify(nh,
			   SIPTAG_EXPIRES_STR("0")siptag_expires_str, tag_str_v("0"),
			   SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr), TAG_IF(full_call_info, SIPTAG_CALL_INFO_STR(full_call_info))!(full_call_info) ? tag_skip : siptag_call_info_str, tag_str_v
(full_call_info), TAG_END()(tag_type_t)0, (tag_value_t)0);
4136#endif

	if (!strcasecmp(event, "line-seize")) {
		if (mod_sofia_globals.debug_sla > 1) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4140, ((void*)0), SWITCH_LOG_ERROR, "CANCEL LINE SEIZE\n");
		}

		sql = switch_mprintf("delete from sip_dialogs where hostname='%q' and profile_name='%q' and "
							 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') "
							 "and call_info_state='seized'",
							 mod_sofia_globals.hostname, profile->name, to_user, to_host, to_user, to_host);


		if (mod_sofia_globals.debug_sla > 1) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4150, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
		}
		sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);

		sync_sla(profile, to_user, to_host, SWITCH_FALSE, SWITCH_FALSE, NULL((void*)0));
	}

	su_free(nua_handle_get_home(nh), full_call_info);

}

} else {
if (!strcasecmp(event, "line-seize")) {
	char *full_call_info = NULL((void*)0);
	char *p;
	switch_time_t now;

	if (sip->sip_call_info) {
		full_call_info = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_call_info);
		if ((p = strchr(full_call_info, ';'))) {
			p++;
		}
		callsequence = sofia_presence_get_cseq(profile);
		cseq = sip_cseq_create(nua_handle_get_home(nh), callsequence, SIP_METHOD_NOTIFYsip_method_notify, "NOTIFY");
		nua_notify(nh,
				   SIPTAG_FROM(sip->sip_to)siptag_from, siptag_from_v(sip->sip_to),
				   SIPTAG_TO(sip->sip_from)siptag_to, siptag_to_v(sip->sip_from),
				   SIPTAG_EXPIRES_STR(exp_delta_str)siptag_expires_str, tag_str_v(exp_delta_str),
				   SIPTAG_CSEQ(cseq)siptag_cseq, siptag_cseq_v(cseq),
				   SIPTAG_SUBSCRIPTION_STATE_STR(sstr)siptag_subscription_state_str, tag_str_v(sstr),
				   SIPTAG_EVENT_STR("line-seize")siptag_event_str, tag_str_v("line-seize"), TAG_IF(full_call_info, SIPTAG_CALL_INFO_STR(full_call_info))!(full_call_info) ? tag_skip : siptag_call_info_str, tag_str_v
(full_call_info), TAG_END()(tag_type_t)0, (tag_value_t)0);




		sql = switch_mprintf("delete from sip_dialogs where hostname='%q' and profile_name='%q' and "
							 "((sip_from_user='%q' and sip_from_host='%q') or presence_id='%q@%q') "
							 "and call_info_state='seized' and profile_name='%q'",
							 mod_sofia_globals.hostname, profile->name, to_user, to_host, to_user, to_host, profile->name);


		if (mod_sofia_globals.debug_sla > 1) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4192, ((void*)0), SWITCH_LOG_ERROR, "CLEAR SQL %s\n", sql);
		}
		sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);

		now = switch_epoch_time_now(NULL((void*)0));
		sql = switch_mprintf("insert into sip_dialogs (sip_from_user,sip_from_host,call_info,call_info_state,hostname,expires,rcd,profile_name) "
							 "values ('%q','%q','%q','seized','%q',%"TIME_T_FMT"ld"",%ld,'%q')",
							 to_user, to_host, switch_str_nil(p)(p ? p : ""), mod_sofia_globals.hostname,
							 switch_epoch_time_now(NULL((void*)0)) + exp_delta, (long)now, profile->name);

		if (mod_sofia_globals.debug_sla > 1) {
			switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4203, ((void*)0), SWITCH_LOG_ERROR, "SEIZE SQL %s\n", sql);
		}
		sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
		sync_sla(profile, to_user, to_host, SWITCH_FALSE, SWITCH_FALSE, NULL((void*)0));

		su_free(nua_handle_get_home(nh), full_call_info);
	}
} else if (!strcasecmp(event, "call-info")) {
	sync_sla(profile, to_user, to_host, SWITCH_FALSE, SWITCH_FALSE, call_id);
}
}

sent_reply++;

switch_safe_free(sstr)if (sstr) {free(sstr);sstr=((void*)0);};

if (!strcasecmp(event, "as-feature-event")) {
switch_event_t *event;
char sip_cseq[40] = "";

switch_snprintf(sip_cseq, sizeof(sip_cseq), "%d", sip->sip_cseq->cs_seq);
switch_event_create(&event, SWITCH_EVENT_PHONE_FEATURE_SUBSCRIBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4224, &event, SWITCH_EVENT_PHONE_FEATURE_SUBSCRIBE
, ((void*)0));
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "user", from_user);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "host", from_host);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "contact", contact_str);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "call-id", call_id);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "cseq", sip_cseq);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "profile_name", profile->name);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "hostname", mod_sofia_globals.hostname);

if (sip->sip_payload) {
	switch_xml_t xml = NULL((void*)0);
	char *pd_dup = NULL((void*)0);

	pd_dup = strdup(sip->sip_payload->pl_data);

	switch_assert(pd_dup)((pd_dup) ? (void) (0) : __assert_fail ("pd_dup", "sofia_presence.c"
, 4240, __extension__ __PRETTY_FUNCTION__));

	if ((xml = switch_xml_parse_str(pd_dup, strlen(pd_dup)))) {
		switch_xml_t device = NULL((void*)0);

		if ((device = switch_xml_child(xml, "device"))) {
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "device", device->txt);
		}

		if (xml->name && !strcmp(xml->name, "SetDoNotDisturb")) {
			switch_xml_t action = NULL((void*)0);

			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Action", "SetDoNotDisturb");
			if ((action = switch_xml_child(xml, "doNotDisturbOn"))) {
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Enabled", action->txt);
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Name", action->name);
			}
		}

		if (xml->name && !strcmp(xml->name, "SetForwarding")) {
			switch_xml_t cfwd_type, cfwd_enable, cfwd_target;

			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Action", "SetCallForward");
			if ((cfwd_type = switch_xml_child(xml, "forwardingType"))
				&& (cfwd_enable = switch_xml_child(xml, "activateForward"))
				&& (cfwd_target = switch_xml_child(xml, "forwardDN"))) {

				if (!strcmp(cfwd_type->txt, "forwardImmediate")) {
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Enabled", cfwd_enable->txt);
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Name", "forward_immediate");
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Value", cfwd_target->txt);
				} else if (!strcmp(cfwd_type->txt, "forwardBusy")) {
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Enabled", cfwd_enable->txt);
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Name", "forward_busy");
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Value", cfwd_target->txt);
				} else if (!strcmp(cfwd_type->txt, "forwardNoAns")) {
					switch_xml_t rc;

					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Feature-Enabled", cfwd_enable->txt);
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Name", "forward_no_answer");
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Action-Value", cfwd_target->txt);
					if ((rc = switch_xml_child(xml, "ringCount"))) {
						switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "ringCount", rc->txt);
					}
				}
			}
		}

		switch_xml_free(xml);
	}

	switch_safe_free(pd_dup)if (pd_dup) {free(pd_dup);pd_dup=((void*)0);};
}
switch_event_fire(&event)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4293, &event, ((void*)0));
} else if (!strcasecmp(event, "message-summary")) {
if ((sql = switch_mprintf("select proto,sip_user,'%q',sub_to_user,sub_to_host,event,contact,call_id,full_from,"
						  "full_via,expires,user_agent,accept,profile_name,network_ip"
						  " from sip_subscriptions where hostname='%q' and profile_name='%q' and "
						  "event='message-summary' and sub_to_user='%q' "
						  "and (sip_host='%q' or presence_hosts like '%%%q%%') and call_id='%q'",
						  to_host, mod_sofia_globals.hostname, profile->name,
						  to_user, to_host, to_host, call_id))) {

	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4304, ((void*)0), SWITCH_LOG_ERROR,
						  "SUBSCRIBE MWI SQL: %s\n", sql);
	}


	sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_sub_reg_callback, profile);

	switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
}
} else 	if (!strcasecmp(event, "conference")) {
switch_event_t *event;
switch_event_create(&event, SWITCH_EVENT_CONFERENCE_DATA_QUERY)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4315, &event, SWITCH_EVENT_CONFERENCE_DATA_QUERY
, ((void*)0));
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Conference-Name", to_user);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Conference-Domain", to_host);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Query-From", from_user);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Query-From-Domain", from_host);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Call-Id", call_id);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "Sofia-Profile", profile->name);
switch_event_fire(&event)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4322, &event, ((void*)0));
}

end:

if (strcasecmp(event, "call-info") && strcasecmp(event, "line-seize")) {

if (to_user && (strstr(to_user, "ext+") || strstr(to_user, "user+"))) {
	char protocol[80];
	char *p;

	switch_copy_string(protocol, to_user, sizeof(protocol));
	if ((p = strchr(protocol, '+'))) {
		*p = '\0';
	}

	if (switch_event_create(&sevent, SWITCH_EVENT_PRESENCE_IN)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4338, &sevent, SWITCH_EVENT_PRESENCE_IN
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto", protocol);
		if (!zstr(orig_proto)_zstr(orig_proto)) {
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "orig_proto", orig_proto);
		}
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "login", profile->name);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
		switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "from", "%s@%s", to_user, to_host);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "rpid", "active");
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "status", "Click To Call");
		switch_event_fire(&sevent)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4348, &sevent, ((void*)0));
	}

} else if (to_user && (strcasecmp(proto, SOFIA_CHAT_PROTO"sip") != 0)) {
	if (switch_event_create(&sevent, SWITCH_EVENT_PRESENCE_PROBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4352, &sevent, SWITCH_EVENT_PRESENCE_PROBE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto", proto);
		if (!zstr(orig_proto)_zstr(orig_proto)) {
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "orig_proto", orig_proto);
		}
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "login", profile->name);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
		switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "from", "%s@%s", from_user, from_host);
		switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "to", "%s%s%s@%s", proto, "+", to_user, to_host);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto-specific-event-name", event);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "event_type", "presence");
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog");
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
		switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sub-call-id", call_id);
		switch_event_fire(&sevent)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4367, &sevent, ((void*)0));

	}
} else {

	if (!strcasecmp(event, "dialog")) {
		if (switch_event_create(&sevent, SWITCH_EVENT_PRESENCE_PROBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4373, &sevent, SWITCH_EVENT_PRESENCE_PROBE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "probe-type", "dialog");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "login", profile->name);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
			switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "from", "%s@%s", from_user, from_host);
			switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "to", "%s@%s", to_user, to_host);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto-specific-event-name", event);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "event_type", "presence");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sub-call-id", call_id);
			switch_event_fire(&sevent)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4386, &sevent, ((void*)0));
		}
	} else if (!strcasecmp(event, "presence")) {
		if (switch_event_create(&sevent, SWITCH_EVENT_PRESENCE_PROBE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4389, &sevent, SWITCH_EVENT_PRESENCE_PROBE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "login", profile->name);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "presence-source", "subscribe");
			switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "from", "%s@%s", from_user, from_host);
			switch_event_add_header(sevent, SWITCH_STACK_BOTTOM, "to", "%s@%s", to_user, to_host);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "expires", exp_delta_str);
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "alt_event_type", "dialog");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "rpid", "unknown");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "status", "Registered");
			switch_event_add_header_string(sevent, SWITCH_STACK_BOTTOM, "sub-call-id", call_id);
			switch_event_fire(&sevent)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4401, &sevent, ((void*)0));
		}
	}
}
}

if (event) {
su_free(nua_handle_get_home(nh), event);
}

if (full_from) {
su_free(nua_handle_get_home(nh), full_from);
}
if (full_to) {
su_free(nua_handle_get_home(nh), full_to);
}

if (full_via) {
su_free(nua_handle_get_home(nh), full_via);
}
if (full_agent) {
su_free(nua_handle_get_home(nh), full_agent);
}

switch_safe_free(d_user)if (d_user) {free(d_user);d_user=((void*)0);};
switch_safe_free(to_str)if (to_str) {free(to_str);to_str=((void*)0);};
switch_safe_free(contact_str)if (contact_str) {free(contact_str);contact_str=((void*)0);};
switch_safe_free(alt_proto)if (alt_proto) {free(alt_proto);alt_proto=((void*)0);};

if (!sent_reply) {
nua_respond(nh, 481, "INVALID SUBSCRIPTION", TAG_END()(tag_type_t)0, (tag_value_t)0);
}

if (!sofia_private || !sofia_private->is_call) {
nua_handle_destroy(nh);
}

4438}


4441sofia_gateway_subscription_t *sofia_find_gateway_subscription(sofia_gateway_t *gateway_ptr, const char *event)
4442{
sofia_gateway_subscription_t *gw_sub_ptr;
for (gw_sub_ptr = gateway_ptr->subscriptions; gw_sub_ptr; gw_sub_ptr = gw_sub_ptr->next) {
if (!strcasecmp(gw_sub_ptr->event, event)) {
	/* this is the gateway subscription we are interested in */
	return gw_sub_ptr;
}
}
return NULL((void*)0);
4451}

4453void sofia_presence_handle_sip_r_subscribe(int status,
								   char const *phrase,
								   nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, sofia_private_t *sofia_private, sip_t const *sip,
								   sofia_dispatch_event_t *de,
								   tagi_t tags[])
4458{
sip_event_t const *o = NULL((void*)0);
sofia_gateway_subscription_t *gw_sub_ptr;
sofia_gateway_t *gateway = NULL((void*)0);

if (!sip) {
return;
}

tl_gets(tags, SIPTAG_EVENT_REF(o)siptag_event_ref, siptag_event_vr(&(o)), TAG_END()(tag_type_t)0, (tag_value_t)0);
/* o->o_type: message-summary (for example) */
if (!o) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4470, ((void*)0), SWITCH_LOG_ERROR, "Event information not given\n");
return;
}

if (!sofia_private || zstr(sofia_private->gateway_name)_zstr(sofia_private->gateway_name)) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4475, ((void*)0), SWITCH_LOG_ERROR, "Gateway information missing\n");
return;
}


if (!(gateway = sofia_reg_find_gateway(sofia_private->gateway_name)sofia_reg_find_gateway__("sofia_presence.c", (const char *)__func__
, 4480, sofia_private->gateway_name))) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4481, ((void*)0), SWITCH_LOG_ERROR, "Gateway information missing\n");
return;
}


/* Find the subscription if one exists */
if (!(gw_sub_ptr = sofia_find_gateway_subscription(gateway, o->o_type))) {
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4488, ((void*)0), SWITCH_LOG_WARNING, "Could not find gateway subscription.  Gateway: %s.  Subscription Event: %s\n",
				  gateway->name, o->o_type);
goto end;
}

/* Update the subscription status for the subscription */
switch (status) {
case 200:
case 202:
/* TODO: in the spec it is possible for the other side to change the original expiry time,
 * this needs to be researched (eg, what sip header this information will be in) and implemented.
 * Although, since it seems the sofia stack is pretty much handling the subscription expiration
 * anyway, then maybe its not even worth bothering.
 */
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4502, ((void*)0), SWITCH_LOG_DEBUG, "got 200 OK response, updated state to SUB_STATE_SUBSCRIBE.\n");
gw_sub_ptr->state = SUB_STATE_SUBSCRIBE;
break;
case 100:
break;
default:
switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4508, ((void*)0), SWITCH_LOG_WARNING, "status (%d) != 200, updated state to SUB_STATE_FAILED.\n", status);
gw_sub_ptr->state = SUB_STATE_FAILED;

break;
}

end:
sofia_reg_release_gateway(gateway)sofia_reg_release_gateway__("sofia_presence.c", (const char *
)__func__, 4515, gateway);;

4517}


4520static int sofia_presence_send_sql(void *pArg, int argc, char **argv, char **columnNames)
4521{
struct pres_sql_cb *cb = (struct pres_sql_cb *) pArg;


if (mod_sofia_globals.debug_presence > 0) {
int i;
for(i = 0; i < argc; i++) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4528, ((void*)0), SWITCH_LOG_CRIT, "arg %d[%s] = [%s]\n", i, columnNames[i], argv[i]);
}
}

send_presence_notify(cb->profile, argv[0], argv[1], argv[2], argv[3], argv[4], argv[5], argv[6], argv[7], argv[8], argv[9], NULL)_send_presence_notify(cb->profile,argv[0],argv[1],argv[2],
argv[3],argv[4],argv[5],argv[6],argv[7],argv[8],argv[9],((void
*)0),"sofia_presence.c", (const char *)__func__, 4532);
cb->ttl++;

return 0;
4536}


4539uint32_t sofia_presence_contact_count(sofia_profile_t *profile, const char *contact_str)
4540{
char buf[32] = "";
char *sql;

sql = switch_mprintf("select count(*) from sip_subscriptions where hostname='%q' and profile_name='%q' and contact='%q'",
				 mod_sofia_globals.hostname, profile->name, contact_str);

sofia_glue_execute_sql2str(profile, profile->dbh_mutex, sql, buf, sizeof(buf));
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
return atoi(buf);
4550}

4552void sofia_presence_handle_sip_i_publish(nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh, sofia_private_t *sofia_private, sip_t const *sip,
								 sofia_dispatch_event_t *de,
								 tagi_t tags[])
4555{

sip_from_t const *from;
char *from_user = NULL((void*)0);
char *from_host = NULL((void*)0);
char *rpid = "";
sip_payload_t *payload;
char *event_type = NULL((void*)0);
char etag[9] = "";
char expstr[30] = "";
long exp = 0, exp_delta = 3600;
char *pd_dup = NULL((void*)0);
int count = 1, sub_count = 1;
char *contact_str;
sofia_nat_parse_t np = { { 0 } };

if (!sip) {
return;
}

from = sip->sip_from;
payload = sip->sip_payload;

np.fs_path = 1;
contact_str = sofia_glue_gen_contact_str(profile, sip, nh, de, &np);

if (from) {
from_user = (char *) from->a_url->url_user;
from_host = (char *) from->a_url->url_host;
}

exp_delta = (sip->sip_expires ? sip->sip_expires->ex_delta : 3600);
if ((profile->force_publish_expires > 0) && (profile->force_publish_expires < (uint32_t)exp_delta)) {
exp_delta = profile->force_publish_expires;
}

if (exp_delta < 0) {
exp = exp_delta;
} else {
exp = (long) switch_epoch_time_now(NULL((void*)0)) + exp_delta;
}

if (payload) {
switch_xml_t xml, note, person, tuple, status, basic, act;
switch_event_t *event;
char *sql;
char *full_agent = NULL((void*)0);
char network_ip[80];
int network_port = 0;

sofia_glue_get_addr(de->data->e_msg, network_ip, sizeof(network_ip), &network_port);

pd_dup = strdup(payload->pl_data);

switch_assert(pd_dup)((pd_dup) ? (void) (0) : __assert_fail ("pd_dup", "sofia_presence.c"
, 4609, __extension__ __PRETTY_FUNCTION__));

if ((xml = switch_xml_parse_str(pd_dup, strlen(pd_dup)))) {
	char *open_closed = "", *note_txt = "";

	if (sip->sip_user_agent) {
		full_agent = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_user_agent);
	}

	if ((tuple = switch_xml_child(xml, "tuple")) && (status = switch_xml_child(tuple, "status"))
		&& (basic = switch_xml_child(status, "basic"))) {
		open_closed = basic->txt;

		if ((note = switch_xml_child(tuple, "note"))) {
			rpid = note_txt = note->txt;
		} else if ((note = switch_xml_child(tuple, "dm:note"))) {
			rpid = note_txt = note->txt;
		}
	}

	if ((person = switch_xml_child(xml, "dm:person"))) {
		if ((note = switch_xml_child(person, "dm:note"))) {
			note_txt = note->txt;
		} else if ((note = switch_xml_child(person, "rpid:note"))) {
			note_txt = note->txt;
		}
		if ((act = switch_xml_child(person, "rpid:activities")) && act->child && act->child->name) {
			if ((rpid = strchr(act->child->name, ':'))) {
				rpid++;
			} else {
				rpid = act->child->name;
			}
		}
		if (zstr(note_txt)_zstr(note_txt)) note_txt = "Available";
	}

	if (!strcasecmp(open_closed, "closed")) {
		rpid = note_txt = "Unregistered";
		if (sofia_test_pflag(profile, PFLAG_MULTIREG)((profile)->pflags[PFLAG_MULTIREG] ? 1 : 0)) {
			count = sofia_reg_reg_count(profile, from_user, from_host);

			if (count != 1) {
				/* Don't broadcast offline when there is more than one client or one signing off makes them all appear to sign off on some clients */
				count = 0;
			} else {
				sub_count = sofia_presence_contact_count(profile, contact_str);
			}
		}
	}

	event_type = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_event);

	if (count) {
		if ((sql = switch_mprintf("delete from sip_presence where sip_user='%q' and sip_host='%q' "
								  " and profile_name='%q' and hostname='%q'",
								  from_user, from_host, profile->name, mod_sofia_globals.hostname))) {
			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
		}

		if (sub_count > 0 && (sql = switch_mprintf("insert into sip_presence (sip_user, sip_host, status, rpid, expires, user_agent,"
												   " profile_name, hostname, open_closed, network_ip, network_port) "
												   "values ('%q','%q','%q','%q',%ld,'%q','%q','%q','%q','%q','%d')",
												   from_user, from_host, note_txt, rpid, exp, full_agent, profile->name,
												   mod_sofia_globals.hostname, open_closed, network_ip, network_port))) {

			sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
		}

	} else if (contact_str) {
		struct pres_sql_cb cb = {profile, 0};

		sql = switch_mprintf("select full_to, full_from, contact, expires, call_id, event, network_ip, network_port, "
							 "'application/pidf+xml' as ct,'%q' as pt "
							 " from sip_subscriptions where "
							 "hostname='%q' and profile_name='%q' and sub_to_user='%q' and sub_to_host='%q' and event='%q'"
							 "and contact = '%q' ",

							 switch_str_nil(payload->pl_data)(payload->pl_data ? payload->pl_data : ""),
							 mod_sofia_globals.hostname, profile->name,
							 from_user, from_host, event_type, contact_str);

		sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_send_sql, &cb);
		switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};
	}

	if (sub_count > 0) {
		if (switch_event_create(&event, SWITCH_EVENT_PRESENCE_IN)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4695, &event, SWITCH_EVENT_PRESENCE_IN
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "rpid", rpid);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", profile->url);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "user-agent", full_agent);
			switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from", "%s@%s", from_user, from_host);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "status", note_txt);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "event_type", event_type);
			switch_event_fire(&event)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4704, &event, ((void*)0));
		}
	}

	if (event_type) {
		su_free(nua_handle_get_home(nh), event_type);
	}

	if (full_agent) {
		su_free(nua_handle_get_home(nh), full_agent);
	}

	switch_xml_free(xml);
}
} else {
char *sql = switch_mprintf("update sip_presence set expires=%ld where sip_user='%q' and sip_host='%q' and profile_name='%q' and hostname='%q'",
						   exp, from_user, from_host, profile->name, mod_sofia_globals.hostname);
sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
}

switch_safe_free(pd_dup)if (pd_dup) {free(pd_dup);pd_dup=((void*)0);};

switch_snprintf(expstr, sizeof(expstr), "%d", exp_delta);
switch_stun_random_string(etag, 8, NULL((void*)0));

if (sub_count > 0) {
nua_respond(nh, SIP_200_OK200, sip_200_OK, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), SIPTAG_ETAG_STR(etag)siptag_etag_str, tag_str_v(etag), SIPTAG_EXPIRES_STR(expstr)siptag_expires_str, tag_str_v(expstr), TAG_END()(tag_type_t)0, (tag_value_t)0);
} else {
nua_respond(nh, SIP_404_NOT_FOUND404, sip_404_Not_found, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
}

switch_safe_free(contact_str)if (contact_str) {free(contact_str);contact_str=((void*)0);};
4736}

4738void sofia_presence_set_hash_key(char *hash_key, int32_t len, sip_t const *sip)
4739{
url_t *to = sip->sip_to->a_url;
url_t *from = sip->sip_from->a_url;
switch_snprintf(hash_key, len, "%s%s%s", from->url_user, from->url_host, to->url_user);
4743}

4745void sofia_presence_handle_sip_i_message(int status,
								 char const *phrase,
								 nua_t *nua, sofia_profile_t *profile, nua_handle_t *nh,
								 switch_core_session_t *session,
								 sofia_private_t *sofia_private, sip_t const *sip,
								 sofia_dispatch_event_t *de,
								 tagi_t tags[])
4752{

if (sip) {
sip_from_t const *from = sip->sip_from;
const char *from_user = NULL((void*)0);
const char *from_host = NULL((void*)0);
sip_to_t const *to = sip->sip_to;
const char *to_user = NULL((void*)0);
const char *to_host = NULL((void*)0);
sip_payload_t *payload = sip->sip_payload;
char *msg = NULL((void*)0);
const char *us;
char network_ip[80];
int network_port = 0;
switch_channel_t *channel = NULL((void*)0);


if (!sofia_test_pflag(profile, PFLAG_ENABLE_CHAT)((profile)->pflags[PFLAG_ENABLE_CHAT] ? 1 : 0)) {
	goto end;
}


if (session) {
	channel = switch_core_session_get_channel(session);
}

if (sofia_test_pflag(profile, PFLAG_AUTH_MESSAGES)((profile)->pflags[PFLAG_AUTH_MESSAGES] ? 1 : 0)) {
	sip_authorization_t const *authorization = NULL((void*)0);
	auth_res_t auth_res = AUTH_FORBIDDEN;
	char keybuf[128] = "";
	char *key;
	size_t keylen;
	switch_event_t *v_event = NULL((void*)0);

	key = keybuf;
	keylen = sizeof(keybuf);

	if (sip->sip_authorization) {
		authorization = sip->sip_authorization;
	} else if (sip->sip_proxy_authorization) {
		authorization = sip->sip_proxy_authorization;
	}

	if (authorization) {
		char network_ip[80];
		int network_port;
		sofia_glue_get_addr(de->data->e_msg, network_ip, sizeof(network_ip), &network_port);
		auth_res = sofia_reg_parse_auth(profile, authorization, sip, de,
										(char *) sip->sip_request->rq_method_name, key, keylen, network_ip, network_port, NULL((void*)0), 0,
										REG_INVITE, NULL((void*)0), NULL((void*)0), NULL((void*)0), NULL((void*)0));
	} else if ( sofia_reg_handle_register(nua, profile, nh, sip, de, REG_INVITE, key, (uint32_t)keylen, &v_event, NULL, NULL, NULL)sofia_reg_handle_register_token(nua, profile, nh, sip, de, REG_INVITE
, key, (uint32_t)keylen, &v_event, ((void*)0), ((void*)0)
, ((void*)0), ((void*)0))) {
		if (v_event) {
			switch_event_destroy(&v_event);
		}

		goto end;
	}

	if ((auth_res != AUTH_OK && auth_res != AUTH_RENEWED)) {
		nua_respond(nh, SIP_401_UNAUTHORIZED401, sip_401_Unauthorized, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
		goto end;
	}

	if (channel) {
		switch_channel_set_variable(channel, "sip_authorized", "true")switch_channel_set_variable_var_check(channel, "sip_authorized"
, "true", SWITCH_TRUE);
	}
}

if ((us = sofia_glue_get_unknown_header(sip, "X-FS-Sending-Message")) && !strcmp(us, switch_core_get_uuid())) {
	switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 4821, ((void*)0), SWITCH_LOG_WARNING, "Not sending message to ourselves!\n");
	nua_respond(nh, SIP_503_SERVICE_UNAVAILABLE503, sip_503_Service_unavailable, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
	return;
}

if (sip->sip_content_type && sip->sip_content_type->c_subtype) {
	if (strstr(sip->sip_content_type->c_subtype, "composing")) {
		goto end;
	}
}


sofia_glue_get_addr(de->data->e_msg, network_ip, sizeof(network_ip), &network_port);


if (from) {
	from_user = from->a_url->url_user;
	from_host = from->a_url->url_host;
}

if (to) {
	to_user = to->a_url->url_user;
	to_host = to->a_url->url_host;
}

if (!to_user) {
	goto end;
}

if (payload) {
	msg = payload->pl_data;
}

if (nh) {
	char hash_key[512];
	private_object_t *tech_pvt;
	switch_event_t *event, *event_dup;
	char *to_addr;
	char *from_addr;
	char *p;
	char *full_from;
	char proto[512] = SOFIA_CHAT_PROTO"sip";
	sip_unknown_t *un;
	int first_history_info = 1;

	full_from = sip_header_as_string(nua_handle_get_home(nh), (void *) sip->sip_from);

	if ((p = strchr(to_user, '+')) && p != to_user) {
		switch_copy_string(proto, to_user, sizeof(proto));
		p = strchr(proto, '+');
		*p++ = '\0';

		if ((to_addr = strdup(p))) {
			if ((p = strchr(to_addr, '+'))) {
				*p = '@';
			}
		}
	} else {
		to_addr = switch_mprintf("%s@%s", to_user, to_host);
	}

	from_addr = switch_mprintf("%s@%s", from_user, from_host);

	if (sofia_test_pflag(profile, PFLAG_IN_DIALOG_CHAT)((profile)->pflags[PFLAG_IN_DIALOG_CHAT] ? 1 : 0)) {
		sofia_presence_set_hash_key(hash_key, sizeof(hash_key), sip);
	}

	if (switch_event_create(&event, SWITCH_EVENT_MESSAGE)switch_event_create_subclass_detailed("sofia_presence.c", (const
 char * )(const char *)__func__, 4888, &event, SWITCH_EVENT_MESSAGE
, ((void*)0)) == SWITCH_STATUS_SUCCESS) {
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "login", profile->url);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "proto", SOFIA_CHAT_PROTO"sip");

		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to_proto", proto);

		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from", from_addr);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from_user", from_user);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from_host", from_host);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to_user", to_user);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to_host", to_host);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from_sip_ip", network_ip);
		switch_event_add_header(event, SWITCH_STACK_BOTTOM, "from_sip_port", "%d", network_port);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "to", to_addr);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "subject", "SIMPLE MESSAGE");
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "context", profile->context);

		if (sip->sip_content_type && sip->sip_content_type->c_subtype) {
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "type", sip->sip_content_type->c_type);
		} else {
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "type", "text/plain");
		}

		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "from_full", full_from);
		switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_profile", profile->name);


		if (sip->sip_call_info) {
			sip_call_info_t *call_info = sip->sip_call_info;
			char *ci = sip_header_as_string(nua_handle_home(nh)((su_home_t *)(nh)), (void *) call_info);
			switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_call_info", ci);
		}

		/* Loop thru unknown Headers Here so we can do something with them */
		for (un = sip->sip_unknown; un; un = un->un_next) {
			if (!strncasecmp(un->un_name, "Diversion", 9)) {
				/* Basic Diversion Support for Diversion Indication in SIP */
				/* draft-levy-sip-diversion-08 */
				if (!zstr(un->un_value)_zstr(un->un_value)) {
					char *tmp_name;
					if ((tmp_name = switch_mprintf("%s%s", SOFIA_SIP_HEADER_PREFIX"sip_h_", un->un_name))) {
						switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, tmp_name, un->un_value);
						free(tmp_name);
					}
				}
			} else if (!strncasecmp(un->un_name, "History-Info", 12)) {
				if (first_history_info) {
					/* If the header exists first time, make sure to remove old info and re-set the variable */
					switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_history_info", un->un_value);
					first_history_info = 0;
				} else {
					/* Append the History-Info into one long string */
					const char *history_var = switch_event_get_header(event, "sip_history_info")switch_event_get_header_idx(event, "sip_history_info", -1);
					if (!zstr(history_var)_zstr(history_var)) {
						char *tmp_str;
						if ((tmp_str = switch_mprintf("%s, %s", history_var, un->un_value))) {
							switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_history_info", tmp_str);
							free(tmp_str);
						} else {
							switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_history_info", un->un_value);
						}
					} else {
						switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_history_info", un->un_value);
					}
				}
			} else if (!strcasecmp(un->un_name, "Geolocation")) {
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_geolocation", un->un_value);
			} else if (!strcasecmp(un->un_name, "Geolocation-Error")) {
				switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "sip_geolocation_error", un->un_value);
			} else if (!strncasecmp(un->un_name, "X-", 2) || !strncasecmp(un->un_name, "P-", 2) || !strcasecmp(un->un_name, "User-to-User")) {
				if (!zstr(un->un_value)_zstr(un->un_value)) {
					char new_name[512] = "";
					int reps = 0;
					for (;;) {
						char postfix[25] = "";
						if (reps > 0) {
							switch_snprintf(postfix, sizeof(postfix), "-%d", reps);
						}
						reps++;
						switch_snprintf(new_name, sizeof(new_name), "%s%s%s", SOFIA_SIP_HEADER_PREFIX"sip_h_", un->un_name, postfix);

						if (switch_event_get_header(event, new_name)switch_event_get_header_idx(event, new_name, -1)) {
							continue;
						}

						switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, new_name, un->un_value);
						break;
					}
				}
			}
		}

		if (msg) {
			switch_event_add_body(event, "%s", msg);
		}

		if (channel) {
			switch_channel_event_set_data(channel, event);
		}


		if (sofia_test_pflag(profile, PFLAG_FIRE_MESSAGE_EVENTS)((profile)->pflags[PFLAG_FIRE_MESSAGE_EVENTS] ? 1 : 0)) {
			if (switch_event_dup(&event_dup, event) == SWITCH_STATUS_SUCCESS) {
				event_dup->event_id = SWITCH_EVENT_RECV_MESSAGE;
				event_dup->flags |= EF_UNIQ_HEADERS;
				switch_event_add_header_string(event_dup, SWITCH_STACK_BOTTOM, "Event-Name", switch_event_name(event_dup->event_id));
				switch_event_fire(&event_dup)switch_event_fire_detailed("sofia_presence.c", (const char * )
(const char *)__func__, 4994, &event_dup, ((void*)0));
			}
		}

		if (session) {
			if (switch_event_dup(&event_dup, event) == SWITCH_STATUS_SUCCESS) {
				switch_core_session_queue_event(session, &event_dup);
			}
		}


	} else {
		abort();
	}

	if (sofia_test_pflag(profile, PFLAG_IN_DIALOG_CHAT)((profile)->pflags[PFLAG_IN_DIALOG_CHAT] ? 1 : 0) && (tech_pvt = (private_object_t *) switch_core_hash_find_locked(profile->chat_hash, hash_key, profile->flag_mutex))) {
		switch_core_session_queue_event(tech_pvt->session, &event);
	} else {
		switch_core_chat_send(proto, event);
		switch_event_destroy(&event);
	}

	switch_safe_free(to_addr)if (to_addr) {free(to_addr);to_addr=((void*)0);};
	switch_safe_free(from_addr)if (from_addr) {free(from_addr);from_addr=((void*)0);};

	if (full_from) {
		su_free(nua_handle_get_home(nh), full_from);
	}
}
}

end:

if (sofia_test_pflag(profile, PFLAG_MESSAGES_RESPOND_200_OK)((profile)->pflags[PFLAG_MESSAGES_RESPOND_200_OK] ? 1 : 0)) {
nua_respond(nh, SIP_200_OK200, sip_200_OK, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
} else {
nua_respond(nh, SIP_202_ACCEPTED202, sip_202_Accepted, NUTAG_WITH_THIS_MSG(de->data->e_msg)nutag_with, tag_ptr_v(de->data->e_msg), TAG_END()(tag_type_t)0, (tag_value_t)0);
}

5033}

5035void sofia_presence_set_chat_hash(private_object_t *tech_pvt, sip_t const *sip)
5036{
char hash_key[256] = "";
char buf[512];
su_home_t *home = NULL((void*)0);

if (!tech_pvt || tech_pvt->hash_key || !sip || !sip->sip_from || !sip->sip_from->a_url->url_user || !sip->sip_from->a_url->url_host) {
return;
}

if (sofia_reg_find_reg_url(tech_pvt->profile, sip->sip_from->a_url->url_user, sip->sip_from->a_url->url_host, buf, sizeof(buf))) {
home = su_home_new(sizeof(*home));
switch_assert(home != NULL)((home != ((void*)0)) ? (void) (0) : __assert_fail ("home != ((void*)0)"
, "sofia_presence.c", 5047, __extension__ __PRETTY_FUNCTION__
));
tech_pvt->chat_from = sip_header_as_string(home, (const sip_header_t *) sip->sip_to);
tech_pvt->chat_to = switch_core_session_strdup(tech_pvt->session, buf)switch_core_perform_session_strdup(tech_pvt->session, buf,
 "sofia_presence.c", (const char *)__func__, 5049);
sofia_presence_set_hash_key(hash_key, sizeof(hash_key), sip);
su_home_unref(home);
home = NULL((void*)0);
} else {
return;
}

switch_mutex_lock(tech_pvt->profile->flag_mutex);
tech_pvt->hash_key = switch_core_session_strdup(tech_pvt->session, hash_key)switch_core_perform_session_strdup(tech_pvt->session, hash_key
, "sofia_presence.c", (const char *)__func__, 5058);
switch_core_hash_insert(tech_pvt->profile->chat_hash, tech_pvt->hash_key, tech_pvt)switch_core_hash_insert_destructor(tech_pvt->profile->chat_hash
, tech_pvt->hash_key, tech_pvt, ((void*)0));
switch_mutex_unlock(tech_pvt->profile->flag_mutex);
5061}


5064void sofia_presence_check_subscriptions(sofia_profile_t *profile, time_t now)
5065{
char *sql;

if (now) {
struct pres_sql_cb cb = {profile, 0};

if (profile->pres_type != PRES_TYPE_FULL) {
	if (mod_sofia_globals.debug_presence > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 5073, ((void*)0), SWITCH_LOG_WARNING, "check_subs: %s is passive, skipping\n", (char *) profile->name);
	}
	return;
}

sql = switch_mprintf("update sip_subscriptions set version=version+1 where "
					 "((expires > 0 and expires <= %ld)) and profile_name='%q' and hostname='%q'",
					 (long) now, profile->name, mod_sofia_globals.hostname);

sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

sql = switch_mprintf("select full_to, full_from, contact, -1, call_id, event, network_ip, network_port, "
					 "NULL as ct, NULL as pt "
					 " from sip_subscriptions where ((expires > 0 and expires <= %ld)) and profile_name='%q' and hostname='%q'",
					 (long) now, profile->name, mod_sofia_globals.hostname);

sofia_glue_execute_sql_callback(profile, profile->dbh_mutex, sql, sofia_presence_send_sql, &cb);
switch_safe_free(sql)if (sql) {free(sql);sql=((void*)0);};

if (cb.ttl) {
	sql = switch_mprintf("delete from sip_subscriptions where ((expires > 0 and expires <= %ld)) "
						 "and profile_name='%q' and hostname='%q'",
						 (long) now, profile->name, mod_sofia_globals.hostname);

	if (mod_sofia_globals.debug_presence > 0 || mod_sofia_globals.debug_sla > 0) {
		switch_log_printf(SWITCH_CHANNEL_LOGSWITCH_CHANNEL_ID_LOG, "sofia_presence.c", (const char *)__func__
, 5099, ((void*)0), SWITCH_LOG_ERROR,
						  "sub del sql: %s\n", sql);
	}

	sofia_glue_execute_sql_now(profile, &sql, SWITCH_TRUE);
}
}



5109}


5112/* 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 noet:
*/