switch_core_db_t *db;
char *errmsg;
char *to = switch_event_get_header(event, "to");
+ char *f_host = NULL;
+ if (to) {
+ if ((f_host = strchr(to, '@'))) {
+ f_host++;
+ }
+ }
- if (to && (sql = switch_mprintf("select * from subscriptions where sub_to='%q'", to))) {
- if (!(db = switch_core_db_open_file(profile->dbname))) {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Opening DB %s\n", profile->dbname);
- return;
+ if (f_host && (profile = switch_core_hash_find(globals.profile_hash, f_host))) {
+ if (to && (sql = switch_mprintf("select * from subscriptions where sub_to='%q'", to))) {
+ if (!(db = switch_core_db_open_file(profile->dbname))) {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Error Opening DB %s\n", profile->dbname);
+ return;
+ }
+ switch_mutex_lock(profile->mutex);
+ switch_core_db_exec(db, sql, sin_callback, profile, &errmsg);
+ switch_mutex_unlock(profile->mutex);
+ switch_core_db_close(db);
+ switch_safe_free(sql);
}
- switch_mutex_lock(profile->mutex);
- switch_core_db_exec(db, sql, sin_callback, profile, &errmsg);
- switch_mutex_unlock(profile->mutex);
- switch_core_db_close(db);
- switch_safe_free(sql);
}
}
return;
*host++ = '\0';
}
if (user && host &&
- (sql = switch_mprintf("select user,host,'Registered','unknown','' from sip_registrations where user='%q' and host='%q'", user, host))) {
+ (sql = switch_mprintf("select user,host,status,rpid,'' from sip_registrations where user='%q' and host='%q'", user, host))) {
switch_mutex_lock(profile->ireg_mutex);
switch_core_db_exec(db, sql, resub_callback, profile, &errmsg);
switch_mutex_unlock(profile->ireg_mutex);