/* * FreeSWITCH Modular Media Switching Software Library / Soft-Switch Application * Copyright (C) 2005-2014, Anthony Minessale II * * 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 * Portions created by the Initial Developer are Copyright (C) * the Initial Developer. All Rights Reserved. * * Contributor(s): * * Anthony Minessale II * Michael Jerris * Johny Kadarisman * Paul Tinsley * Marcel Barbulescu * Bret McDanel * Cesar Cepeda * Massimo Cetra * Rupa Schomaker * Joseph Sullivan * Raymond Chandler * Seven Du * Garmt Boekholt * * mod_commands.c -- Misc. Command Module * */ #include #include SWITCH_MODULE_LOAD_FUNCTION(mod_commands_load); SWITCH_MODULE_SHUTDOWN_FUNCTION(mod_commands_shutdown); SWITCH_MODULE_DEFINITION(mod_commands, mod_commands_load, mod_commands_shutdown, NULL); static switch_mutex_t *reload_mutex = NULL; struct cb_helper { uint32_t row_process; switch_stream_handle_t *stream; }; struct stream_format { char *http; /* http cmd (from xmlrpc) */ char *query; /* http query (cmd args) */ switch_bool_t api; /* flag: define content type for http reply e.g. text/html or text/xml */ switch_bool_t html; /* flag: format as html */ char *nl; /* newline to use: html "
\n" or just "\n" */ }; typedef struct stream_format stream_format; static int url_callback(void *pArg, int argc, char **argv, char **columnNames) { struct cb_helper *cb = (struct cb_helper *) pArg; cb->row_process++; if (!zstr(argv[0])) { cb->stream->write_function(cb->stream, "%s,", argv[0]); } return 0; } static switch_status_t select_url(const char *user, const char *domain, const char *concat, const char *exclude_contact, switch_stream_handle_t *stream) { struct cb_helper cb; char *sql, *errmsg = NULL; switch_core_flag_t cflags = switch_core_flags(); switch_cache_db_handle_t *db = NULL; if (!(cflags & SCF_USE_SQL)) { stream->write_function(stream, "-ERR SQL disabled, no data available!\n"); return SWITCH_STATUS_SUCCESS; } if (switch_core_db_handle(&db) != SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "%s", "-ERR Database error!\n"); return SWITCH_STATUS_SUCCESS; } cb.row_process = 0; cb.stream = stream; if (exclude_contact) { sql = switch_mprintf("select url, '%q' " "from registrations where reg_user='%q' and realm='%q' " "and url not like '%%%q%%'", (concat != NULL) ? concat : "", user, domain, exclude_contact); } else { sql = switch_mprintf("select url, '%q' " "from registrations where reg_user='%q' and realm='%q'", (concat != NULL) ? concat : "", user, domain); } switch_assert(sql); switch_cache_db_execute_sql_callback(db, sql, url_callback, &cb, &errmsg); if (errmsg) { stream->write_function(stream, "-ERR SQL error [%s]\n", errmsg); free(errmsg); errmsg = NULL; } switch_safe_free(sql); switch_cache_db_release_db_handle(&db); return SWITCH_STATUS_SUCCESS; } static stream_format set_format(stream_format *format, switch_stream_handle_t *stream) { format->nl = "\n"; if (stream->param_event && (format->http = switch_event_get_header(stream->param_event, "HTTP-URI"))) { format->query = switch_event_get_header(stream->param_event, "HTTP-QUERY"); if (switch_event_get_header(stream->param_event, "HTTP-API")) { format->api = SWITCH_TRUE; } if (!strncasecmp(format->http, "/webapi/", 8)) { format->nl = "
\n"; format->html = SWITCH_TRUE; } } return *format; } #define SAY_STRING_SYNTAX "[.] [.] [] " SWITCH_STANDARD_API(say_string_function) { char *argv[6] = { 0 }; int argc; char *lbuf = NULL, *string = NULL; int err = 1, par = 0; char *p, *ext = "wav"; char *tosay = NULL; int strip = 0; if (cmd) { lbuf = strdup(cmd); } if (lbuf && (argc = switch_separate_string(lbuf, ' ', argv, (sizeof(argv) / sizeof(argv[0])))) && (argc == 5 || argc == 6)) { if ((p = strchr(argv[0], '.'))) { *p++ = '\0'; ext = p; par++; } if (!par && (p = strchr(argv[1], '.'))) { *p++ = '\0'; ext = p; } tosay = (argc == 5) ? argv[4] : argv[5]; if (*tosay == '~') { tosay++; strip++; } switch_ivr_say_string(session, argv[1], ext, tosay, argv[0], argv[2], argv[3], (argc == 6) ? argv[4] : NULL , &string); if (string) { stream->write_function(stream, "%s", strip ? string + 14 : string); free(string); err = 0; } } if (err) { stream->write_function(stream, "-ERR Usage: %s\n", SAY_STRING_SYNTAX); } free(lbuf); return SWITCH_STATUS_SUCCESS; } struct user_struct { char *dname; char *gname; char *effective_caller_id_name; char *effective_caller_id_number; char *callgroup; switch_xml_t x_user_tag; switch_stream_handle_t *stream; char *search_context; char *context; switch_xml_t x_domain_tag; }; static void dump_user(struct user_struct *us) { switch_xml_t x_vars, x_var, ux, x_user_tag, x_domain_tag; switch_status_t status; switch_stream_handle_t apistream = { 0 }, *stream; char *user_context = NULL, *search_context = NULL, *context = NULL; char *effective_caller_id_name = NULL; char *effective_caller_id_number = NULL; char *dname = NULL, *gname = NULL, *callgroup = NULL; char *utype = NULL, *uname = NULL; char *apip = NULL; x_user_tag = us->x_user_tag; x_domain_tag = us->x_domain_tag; effective_caller_id_name = us->effective_caller_id_name; effective_caller_id_number = us->effective_caller_id_number; callgroup = us->callgroup; dname = us->dname; gname = us->gname; stream = us->stream; context = us->context; search_context = us->search_context; if (!x_user_tag) { return; } utype = (char *)switch_xml_attr_soft(us->x_user_tag, "type"); uname = (char *)switch_xml_attr_soft(us->x_user_tag, "id"); if (!strcasecmp(utype, "pointer")) { if (switch_xml_locate_user_in_domain(uname, x_domain_tag, &ux, NULL) == SWITCH_STATUS_SUCCESS) { x_user_tag = ux; } } user_context = (char *)context; if ((x_vars = switch_xml_child(x_user_tag, "variables"))) { for (x_var = switch_xml_child(x_vars, "variable"); x_var; x_var = x_var->next) { const char *key = switch_xml_attr_soft(x_var, "name"); const char *val = switch_xml_attr_soft(x_var, "value"); if (!strcasecmp(key, "user_context")) { user_context = (char*) val; } else if (!strcasecmp(key, "effective_caller_id_name")) { effective_caller_id_name = (char*) val; } else if (!strcasecmp(key, "effective_caller_id_number")) { effective_caller_id_number = (char*) val; } else if (!strcasecmp(key, "callgroup")) { callgroup = (char*) val; } else { continue; } } } if (search_context) { if (zstr(user_context) || strcasecmp(search_context, user_context)) { return; } } if(zstr(dname)) { apip = switch_mprintf("*/%s",switch_xml_attr_soft(x_user_tag, "id")); } else { apip = switch_mprintf("*/%s@%s",switch_xml_attr_soft(x_user_tag, "id"), dname); } SWITCH_STANDARD_STREAM(apistream); if ((status = switch_api_execute("sofia_contact", apip, NULL, &apistream)) != SWITCH_STATUS_SUCCESS) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_DEBUG, "sofia_contact '%s' failed. status: %d \n", apip, status ); goto end; } stream->write_function(stream, "%s|%s|%s|%s|%s|%s|%s|%s\n", switch_xml_attr_soft(x_user_tag, "id"), user_context, dname, gname, apistream.data, callgroup, effective_caller_id_name, effective_caller_id_number); end: switch_safe_free(apistream.data); switch_safe_free(apip); return; } char *find_channel_brackets(char *data, char start, char end, char **front, int *local_clobber) { char *p; char *last_end = NULL; *front = NULL; p = data; while ((p = switch_strchr_strict(p, start, " "))) { char *next_end = switch_find_end_paren(p, start, end); if (!next_end) { break; } if (!*front) { *front = p; } *p = '['; last_end = next_end; *last_end = ']'; p = last_end + 1; } if (!last_end) { if (local_clobber) { *local_clobber = 0; } return data; } *last_end = '\0'; if (local_clobber) { /* Would be nice to use switch_true to account for other valid boolean representations, but this is better than nothing: */ *local_clobber = strstr(data, "local_var_clobber=true") != NULL; } return last_end + 1; } char *find_channel_delim(char *p, const char **out) { *out = ""; for (; *p; p++) { if (*p == ',') { *out = ","; break; } if (*p == '|') { *out = "|"; break; } if (!strncmp(p, SWITCH_ENT_ORIGINATE_DELIM, strlen(SWITCH_ENT_ORIGINATE_DELIM))) { *out = SWITCH_ENT_ORIGINATE_DELIM; break; } } return p; } /* Read <..> and {..}, and inserts [..] before every leg dial string. */ void output_flattened_dial_string(char *data, switch_stream_handle_t *stream) { char *p; char *vars_start_ent; char *vars_start_all; char *vars_start_leg; int local_clobber_ent; int local_clobber_all; const char *delim; char *leg_dial_string; /* -3 because ":_:" is the longest delimiter, of length 3. */ p = find_channel_delim(end_of_p(data) - 3, &delim); *p = '\0'; p = data; p = find_channel_brackets(p, '<', '>', &vars_start_ent, &local_clobber_ent); p = find_channel_brackets(p, '{', '}', &vars_start_all, &local_clobber_all); while (*p) { p = find_channel_brackets(p, '[', ']', &vars_start_leg, NULL); if (vars_start_leg) { if (vars_start_ent && !local_clobber_ent) { stream->write_function(stream, "%s]", vars_start_ent); } if (vars_start_all && !local_clobber_all) { stream->write_function(stream, "%s]", vars_start_all); } stream->write_function(stream, "%s]", vars_start_leg); } while (*p == ' ') p++; if (*p) { if (vars_start_all && (!vars_start_leg || local_clobber_all)) { stream->write_function(stream, "%s]", vars_start_all); } if (vars_start_ent && (!vars_start_leg || local_clobber_ent)) { stream->write_function(stream, "%s]", vars_start_ent); } leg_dial_string = p; p = find_channel_delim(p, &delim); if (*p) { *p = '\0'; p += strlen(delim); if (!strcmp(delim, SWITCH_ENT_ORIGINATE_DELIM)) { p = find_channel_brackets(p, '{', '}', &vars_start_all, &local_clobber_all); } } stream->write_function(stream, "%s%s", leg_dial_string, delim); } } } #define LIST_USERS_SYNTAX "[group ] [domain ] [user ] [context ]" SWITCH_STANDARD_API(list_users_function) { int argc; char *pdata = NULL, *argv[9]; int32_t arg = 0; switch_xml_t xml_root, x_domains, x_domain_tag; switch_xml_t gts, gt, uts, ut; char *_user = NULL, *_search_context = NULL, *_group = NULL, *section = "directory"; char *tag_name = NULL, *key_name = NULL, *key_value = NULL; char *_domain = NULL; if (!zstr(cmd) && (pdata = strdup(cmd))) { argc = switch_separate_string(pdata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc >= 9) { stream->write_function(stream, "-USAGE: %s\n", LIST_USERS_SYNTAX); goto done; } for (arg = 0; arg < argc; arg++) { if (!strcasecmp(argv[arg], "user")) { _user = argv[arg + 1]; } if (!strcasecmp(argv[arg], "context")) { _search_context = argv[arg + 1]; } if (!strcasecmp(argv[arg], "domain")) { _domain = argv[arg + 1]; } if (!strcasecmp(argv[arg], "group")) { _group = argv[arg + 1]; } } } if (_domain) { tag_name = "domain"; key_name = "name"; key_value = _domain; } stream->write_function(stream, "userid|context|domain|group|contact|callgroup|effective_caller_id_name|effective_caller_id_number\n"); if (switch_xml_locate(section, tag_name, key_name, key_value, &xml_root, &x_domains, NULL, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) { struct user_struct us = { 0 }; for (x_domain_tag = _domain ? x_domains : switch_xml_child(x_domains, "domain"); x_domain_tag; x_domain_tag = x_domain_tag->next) { switch_xml_t x_vars, x_var; us.dname = (char*)switch_xml_attr_soft(x_domain_tag, "name"); if (_domain && strcasecmp(_domain, us.dname)) { continue; } if ((x_vars = switch_xml_child(x_domain_tag, "variables"))) { if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "user_context", NULL))) { us.context = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "callgroup", NULL))) { us.callgroup = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "effective_caller_id_name", NULL))) { us.effective_caller_id_name = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "effective_caller_id_number", NULL))) { us.effective_caller_id_number = (char*)switch_xml_attr_soft(x_var, "value"); } } if ((gts = switch_xml_child(x_domain_tag, "groups"))) { for (gt = switch_xml_child(gts, "group"); gt; gt = gt->next) { us.gname = (char*)switch_xml_attr_soft(gt, "name"); if (_group && strcasecmp(_group, us.gname)) { continue; } if ((x_vars = switch_xml_child(gt, "variables"))) { if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "user_context", NULL))) { us.context = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "callgroup", NULL))) { us.callgroup = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "effective_caller_id_name", NULL))) { us.effective_caller_id_name = (char*)switch_xml_attr_soft(x_var, "value"); } if ((x_var = switch_xml_find_child_multi(x_vars, "variable", "name", "effective_caller_id_number", NULL))) { us.effective_caller_id_number = (char*)switch_xml_attr_soft(x_var, "value"); } } for (uts = switch_xml_child(gt, "users"); uts; uts = uts->next) { for (ut = switch_xml_child(uts, "user"); ut; ut = ut->next) { if (_user && strcasecmp(_user, switch_xml_attr_soft(ut, "id"))) { continue; } us.x_user_tag = ut; us.x_domain_tag = x_domain_tag; us.stream = stream; us.search_context = _search_context; dump_user(&us); } } } } else { for (uts = switch_xml_child(x_domain_tag, "users"); uts; uts = uts->next) { for (ut = switch_xml_child(uts, "user"); ut; ut = ut->next) { if (_user && strcasecmp(_user, switch_xml_attr_soft(ut, "id"))) { continue; } us.x_user_tag = ut; us.x_domain_tag = x_domain_tag; us.stream = stream; us.search_context = _search_context; dump_user(&us); } } } } switch_xml_free(xml_root); } stream->write_function(stream, "\n+OK\n"); done: switch_safe_free(pdata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(reg_url_function) { char *data; char *user = NULL; char *domain = NULL, *dup_domain = NULL; char *concat = NULL; const char *exclude_contact = NULL; char *reply = "error/facility_not_subscribed"; switch_stream_handle_t mystream = { 0 }; if (!cmd) { stream->write_function(stream, "%s", ""); return SWITCH_STATUS_SUCCESS; } if (session) { switch_channel_t *channel = switch_core_session_get_channel(session); exclude_contact = switch_channel_get_variable(channel, "sip_exclude_contact"); } data = strdup(cmd); switch_assert(data); user = data; if ((domain = strchr(user, '@'))) { *domain++ = '\0'; if ((concat = strchr(domain, '/'))) { *concat++ = '\0'; } } else { if ((concat = strchr(user, '/'))) { *concat++ = '\0'; } } if (zstr(domain)) { dup_domain = switch_core_get_domain(SWITCH_TRUE); domain = dup_domain; } SWITCH_STANDARD_STREAM(mystream); switch_assert(mystream.data); select_url(user, domain, concat, exclude_contact, &mystream); reply = mystream.data; if (zstr(reply)) { reply = "error/user_not_registered"; } else if (end_of(reply) == ',') { end_of(reply) = '\0'; } stream->write_function(stream, "%s", reply); reply = NULL; switch_safe_free(mystream.data); switch_safe_free(data); switch_safe_free(dup_domain); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(banner_function) { stream->write_function(stream, "%s", switch_core_banner()); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(hostname_api_function) { stream->write_function(stream, "%s", switch_core_get_hostname()); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(switchname_api_function) { stream->write_function(stream, "%s", switch_core_get_switchname()); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(gethost_api_function) { struct sockaddr_in sa; struct hostent *he; const char *ip; char buf[50] = ""; if (!zstr(cmd)) { he = gethostbyname(cmd); if (he) { memcpy(&sa.sin_addr, he->h_addr, sizeof(struct in_addr)); ip = switch_inet_ntop(AF_INET, &sa.sin_addr, buf, sizeof(buf)); stream->write_function(stream, "%s", ip); return SWITCH_STATUS_SUCCESS; } } stream->write_function(stream, "-ERR"); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(shutdown_function) { switch_session_ctl_t command = SCSC_SHUTDOWN; int arg = 0; stream->write_function(stream, "+OK\n"); switch_core_session_ctl(command, &arg); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(version_function) { int argc; char *mydata = NULL, *argv[2]; if (zstr(cmd)) { stream->write_function(stream, "FreeSWITCH Version %s (%s)\n", switch_version_full(), switch_version_revision_human()); goto end; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc > 0 && switch_stristr("short", argv[0])) { stream->write_function(stream, "%s.%s.%s\n", switch_version_major(),switch_version_minor(),switch_version_micro()); } else { stream->write_function(stream, "FreeSWITCH Version %s (%s)\n", switch_version_full(), switch_version_full_human()); } switch_safe_free(mydata); end: return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(db_cache_function) { int argc; char *mydata = NULL, *argv[2]; if (zstr(cmd)) { goto error; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 1) { goto error; } if (argv[0] && switch_stristr("status", argv[0])) { switch_cache_db_status(stream); goto ok; } else { goto error; } error: stream->write_function(stream, "%s", "parameter missing\n"); ok: switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(host_lookup_function) { char host[256] = ""; if (zstr(cmd)) { stream->write_function(stream, "%s", "parameter missing\n"); } else { if (switch_resolve_host(cmd, host, sizeof(host)) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "%s", host); } else { stream->write_function(stream, "%s", "!err!"); } } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(nat_map_function) { int argc; char *mydata = NULL, *argv[5]; switch_nat_ip_proto_t proto = SWITCH_NAT_UDP; switch_port_t external_port = 0; char *tmp = NULL; switch_bool_t sticky = SWITCH_FALSE; switch_bool_t mapping = SWITCH_TRUE; if (!cmd) { goto usage; } if (!switch_nat_is_initialized()) { switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "nat_map API called while NAT not initialized\n"); goto error; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 1) { goto usage; } if (argv[0] && switch_stristr("status", argv[0])) { tmp = switch_nat_status(); stream->write_function(stream, tmp); switch_safe_free(tmp); goto ok; } else if (argv[0] && switch_stristr("republish", argv[0])) { switch_nat_republish(); stream->write_function(stream, "true"); goto ok; } else if (argv[0] && switch_stristr("reinit", argv[0])) { switch_nat_reinit(); tmp = switch_nat_status(); stream->write_function(stream, tmp); switch_safe_free(tmp); goto ok; } if (argc < 2) { goto usage; } if (argv[0] && switch_stristr("mapping", argv[0])) { if (argv[1] && switch_stristr("enable", argv[1])) { mapping = SWITCH_TRUE; } else if (argv[1] && switch_stristr("disable", argv[1])) { mapping = SWITCH_FALSE; } switch_nat_set_mapping(mapping); tmp = switch_nat_status(); stream->write_function(stream, tmp); switch_safe_free(tmp); goto ok; } if (argc < 3) { goto error; } if (argv[2] && switch_stristr("tcp", argv[2])) { proto = SWITCH_NAT_TCP; } else if (argv[2] && switch_stristr("udp", argv[2])) { proto = SWITCH_NAT_UDP; } if (argv[3] && switch_stristr("sticky", argv[3])) { sticky = SWITCH_TRUE; } if (argv[0] && switch_stristr("add", argv[0])) { if (switch_nat_add_mapping((switch_port_t) atoi(argv[1]), proto, &external_port, sticky) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "true"); /* still return true */ goto ok; } } else if (argv[0] && switch_stristr("del", argv[0])) { if (switch_nat_del_mapping((switch_port_t) atoi(argv[1]), proto) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "true"); goto ok; } } error: stream->write_function(stream, "false"); goto ok; usage: stream->write_function(stream, "USAGE: nat_map [status|reinit|republish] | [add|del] [tcp|udp] [sticky] | [mapping] "); ok: switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(time_test_function) { switch_time_t now, then; int x; long mss; uint32_t total = 0; int diff; int max = 10, a = 0; char *p; if (zstr(cmd)) { stream->write_function(stream, "parameter missing\n"); return SWITCH_STATUS_SUCCESS; } mss = atol(cmd); if (mss > 1000000) { mss = 1000000; } if ((p = strchr(cmd, ' '))) { if ((a = atoi(p + 1)) > 0) { max = a; if (max > 100) { max = 100; } } } for (x = 1; x <= max; x++) { then = switch_time_ref(); switch_yield(mss); now = switch_time_ref(); diff = (int) (now - then); stream->write_function(stream, "test %d sleep %ld %d\n", x, mss, diff); total += diff; } stream->write_function(stream, "avg %d\n", total / (x > 1 ? x - 1 : 1)); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(msleep_function) { if (cmd) { long ms = atol(cmd); switch_yield(ms * 1000); } stream->write_function(stream, "+OK"); return SWITCH_STATUS_SUCCESS; } #define TIMER_TEST_SYNTAX "<10|20|40|60|120> [<1..200>] []" SWITCH_STANDARD_API(timer_test_function) { switch_time_t now, then, start, end; int x; int mss = 20; uint32_t total = 0; int diff; int max = 50; switch_timer_t timer = { 0 }; int argc = 0; char *argv[5] = { 0 }; const char *timer_name = "soft"; switch_memory_pool_t *pool; char *mycmd = NULL; switch_core_new_memory_pool(&pool); if (zstr(cmd)) { mycmd = ""; } else { mycmd = switch_core_strdup(pool, cmd); } argc = switch_split(mycmd, ' ', argv); if (argc > 0) { mss = atoi(argv[0]); } if (argc > 1) { int tmp = atoi(argv[1]); if (tmp > 0 && tmp <= 400) { max = tmp; } } if (argc > 2) { timer_name = argv[2]; } if (mss != 10 && mss != 20 && mss != 30 && mss != 32 && mss != 40 && mss != 60 && mss != 120) { stream->write_function(stream, "parameter missing: %s\n", TIMER_TEST_SYNTAX); goto end; } if (switch_core_timer_init(&timer, timer_name, mss, 1, pool) != SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "Timer Error!\n"); goto end; } switch_core_timer_next(&timer); /* Step timer once before testing results below, to get first timestamp as accurate as possible */ start = then = switch_time_ref(); for (x = 1; x <= max; x++) { switch_core_timer_next(&timer); now = switch_time_ref(); diff = (int) (now - then); total += diff; then = now; switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_CONSOLE, "Timer Test: %d sleep %d %d\n", x, mss, diff); } end = then; switch_yield(250000); stream->write_function(stream, "Avg: %0.3fms Total Time: %0.3fms\n", (float) ((float) (total / (x - 1)) / 1000), (float) ((float) (end - start) / 1000)); end: switch_core_destroy_memory_pool(&pool); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(group_call_function) { char *domain, *dup_domain = NULL; char *group_name = NULL; char *flags; int ok = 0; switch_channel_t *channel = NULL; char *fp = NULL; const char *call_delim = ","; if (zstr(cmd)) { goto end; } if (session) { channel = switch_core_session_get_channel(session); } group_name = strdup(cmd); switch_assert(group_name); if ((flags = strchr(group_name, '+'))) { *flags++ = '\0'; for (fp = flags; fp && *fp; fp++) { switch (*fp) { case 'F': call_delim = "|"; break; case 'A': call_delim = ","; break; case 'E': call_delim = SWITCH_ENT_ORIGINATE_DELIM; break; default: break; } } } domain = strchr(group_name, '@'); if (domain) { *domain++ = '\0'; } else { if ((dup_domain = switch_core_get_domain(SWITCH_TRUE))) { domain = dup_domain; } } if (!zstr(domain)) { switch_xml_t xml, x_domain, x_group; switch_event_t *params; switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "group", group_name); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "domain", domain); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "action", "group_call"); if (switch_xml_locate_group(group_name, domain, &xml, &x_domain, &x_group, params) == SWITCH_STATUS_SUCCESS) { switch_xml_t x_user, x_users, x_param, x_params, my_x_user; if ((x_users = switch_xml_child(x_group, "users"))) { for (x_user = switch_xml_child(x_users, "user"); x_user; x_user = x_user->next) { const char *id = switch_xml_attr_soft(x_user, "id"); const char *x_user_type = switch_xml_attr_soft(x_user, "type"); const char *dest = NULL; char *d_dest = NULL; switch_xml_t xml_for_pointer = NULL, x_domain_for_pointer = NULL, x_group_for_pointer = NULL, x_user_for_pointer = NULL; my_x_user = x_user; if (!strcmp(x_user_type, "pointer")) { if (switch_xml_locate_user("id", id, domain, NULL, &xml_for_pointer, &x_domain_for_pointer, &x_user_for_pointer, &x_group_for_pointer, params) != SWITCH_STATUS_SUCCESS) { switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_WARNING, "Can't find user [%s@%s]\n", id, domain); goto done_x_user; } my_x_user = x_user_for_pointer; } if ((x_params = switch_xml_child(x_domain, "params"))) { for (x_param = switch_xml_child(x_params, "param"); x_param; x_param = x_param->next) { const char *var = switch_xml_attr(x_param, "name"); const char *val = switch_xml_attr(x_param, "value"); if (!strcasecmp(var, "group-dial-string")) { dest = val; break; } if (!strcasecmp(var, "dial-string")) { dest = val; } } } if ((x_params = switch_xml_child(x_group, "params"))) { for (x_param = switch_xml_child(x_params, "param"); x_param; x_param = x_param->next) { const char *var = switch_xml_attr(x_param, "name"); const char *val = switch_xml_attr(x_param, "value"); if (!strcasecmp(var, "group-dial-string")) { dest = val; break; } if (!strcasecmp(var, "dial-string")) { dest = val; } } } if ((x_params = switch_xml_child(my_x_user, "params"))) { for (x_param = switch_xml_child(x_params, "param"); x_param; x_param = x_param->next) { const char *var = switch_xml_attr(x_param, "name"); const char *val = switch_xml_attr(x_param, "value"); if (!strcasecmp(var, "group-dial-string")) { dest = val; break; } if (!strcasecmp(var, "dial-string")) { dest = val; } } } if (dest) { if (channel) { switch_channel_set_variable(channel, "dialed_group", group_name); switch_channel_set_variable(channel, "dialed_user", id); switch_channel_set_variable(channel, "dialed_domain", domain); d_dest = switch_channel_expand_variables(channel, dest); } else { switch_event_del_header(params, "dialed_user"); switch_event_del_header(params, "dialed_group"); switch_event_del_header(params, "dialed_domain"); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "dialed_user", id); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "dialed_group", group_name); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "dialed_domain", domain); d_dest = switch_event_expand_headers(params, dest); } } else { d_dest = switch_mprintf("user/%s@%s", id, domain); } if (d_dest) { switch_stream_handle_t dstream = { 0 }; SWITCH_STANDARD_STREAM(dstream); dstream.write_function(&dstream, "%s", d_dest); if (d_dest != dest) { free(d_dest); } if (dstream.data) { if (++ok > 1) { stream->write_function(stream, "%s", call_delim); } output_flattened_dial_string((char*)dstream.data, stream); free(dstream.data); } } done_x_user: if (xml_for_pointer) { switch_xml_free(xml_for_pointer); xml_for_pointer = NULL; } } } } switch_xml_free(xml); switch_event_destroy(¶ms); } end: switch_safe_free(group_name); switch_safe_free(dup_domain); if (!ok) { stream->write_function(stream, "error/NO_ROUTE_DESTINATION"); } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(in_group_function) { switch_xml_t x_domain, xml = NULL, x_group; int argc; char *mydata = NULL, *argv[2], *user, *domain, *dup_domain = NULL; char delim = ','; switch_event_t *params = NULL; const char *rval = "false"; char *group; if (zstr(cmd) || !(mydata = strdup(cmd))) { goto end; } if ((argc = switch_separate_string(mydata, delim, argv, (sizeof(argv) / sizeof(argv[0])))) < 2) { goto end; } user = argv[0]; group = argv[1]; if ((domain = strchr(user, '@'))) { *domain++ = '\0'; } else { if ((dup_domain = switch_core_get_domain(SWITCH_TRUE))) { domain = dup_domain; } } switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "user", user); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "domain", domain); if (switch_xml_locate_group(group, domain, &xml, &x_domain, &x_group, params) == SWITCH_STATUS_SUCCESS) { switch_xml_t x_users; if ((x_users = switch_xml_child(x_group, "users"))) { if (switch_xml_find_child(x_users, "user", "id", user)) { rval = "true"; } } } end: stream->write_function(stream, "%s", rval); switch_xml_free(xml); switch_safe_free(mydata); switch_safe_free(dup_domain); switch_event_destroy(¶ms); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(domain_data_function) { switch_xml_t x_domain = NULL, xml_root = NULL, x_param, x_params; int argc; char *mydata = NULL, *argv[3], *key = NULL, *type = NULL, *domain, *dup_domain = NULL; char delim = ' '; const char *container = "params", *elem = "param"; const char *result = NULL; switch_event_t *params = NULL; if (zstr(cmd) || !(mydata = strdup(cmd))) { goto end; } if ((argc = switch_separate_string(mydata, delim, argv, (sizeof(argv) / sizeof(argv[0])))) < 3) { goto end; } domain = argv[0]; type = argv[1]; key = argv[2]; if (!domain) { if ((dup_domain = switch_core_get_domain(SWITCH_TRUE))) { domain = dup_domain; } else { domain = "cluecon.com"; } } switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "domain", domain); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "type", type); if (key && type && switch_xml_locate_domain(domain, params, &xml_root, &x_domain) == SWITCH_STATUS_SUCCESS) { if (!strcmp(type, "attr")) { const char *attr = switch_xml_attr_soft(x_domain, key); result = attr; goto end; } if (!strcmp(type, "var")) { container = "variables"; elem = "variable"; } if ((x_params = switch_xml_child(x_domain, container))) { for (x_param = switch_xml_child(x_params, elem); x_param; x_param = x_param->next) { const char *var = switch_xml_attr(x_param, "name"); const char *val = switch_xml_attr(x_param, "value"); if (var && val && !strcasecmp(var, key)) { result = val; } } } } end: if (result) { stream->write_function(stream, "%s", result); } switch_safe_free(mydata); switch_safe_free(dup_domain); switch_event_destroy(¶ms); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(user_data_function) { switch_xml_t x_user = NULL, x_param, x_params; int argc; char *mydata = NULL, *argv[3], *key = NULL, *type = NULL, *user, *domain, *dup_domain = NULL; char delim = ' '; const char *container = "params", *elem = "param"; const char *result = NULL; switch_event_t *params = NULL; if (zstr(cmd) || !(mydata = strdup(cmd))) { goto end; } if ((argc = switch_separate_string(mydata, delim, argv, (sizeof(argv) / sizeof(argv[0])))) < 3) { goto end; } user = argv[0]; type = argv[1]; key = argv[2]; if ((domain = strchr(user, '@'))) { *domain++ = '\0'; } else { if ((dup_domain = switch_core_get_domain(SWITCH_TRUE))) { domain = dup_domain; } else { domain = "cluecon.com"; } } switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "user", user); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "domain", domain); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "type", type); if (key && type && switch_xml_locate_user_merged("id:number-alias", user, domain, NULL, &x_user, params) == SWITCH_STATUS_SUCCESS) { if (!strcmp(type, "attr")) { const char *attr = switch_xml_attr_soft(x_user, key); result = attr; goto end; } if (!strcmp(type, "var")) { container = "variables"; elem = "variable"; } if ((x_params = switch_xml_child(x_user, container))) { for (x_param = switch_xml_child(x_params, elem); x_param; x_param = x_param->next) { const char *var = switch_xml_attr(x_param, "name"); const char *val = switch_xml_attr(x_param, "value"); if (var && val && !strcasecmp(var, key)) { result = val; } } } } end: if (result) { stream->write_function(stream, "%s", result); } switch_xml_free(x_user); switch_safe_free(mydata); switch_safe_free(dup_domain); switch_event_destroy(¶ms); return SWITCH_STATUS_SUCCESS; } static switch_status_t _find_user(const char *cmd, switch_core_session_t *session, switch_stream_handle_t *stream, switch_bool_t tf) { switch_xml_t x_user = NULL; int argc; char *mydata = NULL, *argv[3]; char *key, *user, *domain; char *xmlstr; char delim = ' '; const char *err = NULL; stream_format format = { 0 }; set_format(&format, stream); if (!tf && format.api) { stream->write_function(stream, "Content-Type: text/xml\r\n\r\n"); format.html = SWITCH_FALSE; } if (!cmd) { err = "bad args"; goto end; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, delim, argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 3) { err = "bad args"; goto end; } key = argv[0]; user = argv[1]; domain = argv[2]; if (!(key && user && domain)) { err = "bad args"; goto end; } if (switch_xml_locate_user_merged(key, user, domain, NULL, &x_user, NULL) != SWITCH_STATUS_SUCCESS) { err = "can't find user"; goto end; } end: if (session || tf) { stream->write_function(stream, err ? "false" : "true"); } else { if (err) { if (format.api) { stream->write_function(stream, "%s\n", err); } else { stream->write_function(stream, "-ERR %s\n", err); } } if (x_user) { /* print header if request to show xml on webpage */ if (format.html) { xmlstr = switch_xml_tohtml(x_user, SWITCH_TRUE); } else { xmlstr = switch_xml_toxml(x_user, SWITCH_FALSE); } switch_assert(xmlstr); stream->write_function(stream, "%s%s%s", format.html?"
":"", xmlstr, format.html?"
":""); switch_safe_free(xmlstr); } } switch_xml_free(x_user); switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(md5_function) { char digest[SWITCH_MD5_DIGEST_STRING_SIZE] = { 0 }; if (zstr(cmd)) { stream->write_function(stream, "%s", "!err!"); } else { switch_md5_string(digest, (void *) cmd, strlen(cmd)); stream->write_function(stream, "%s", digest); } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(url_decode_function) { char *reply = ""; char *data = NULL; if (!zstr(cmd)) { data = strdup(cmd); switch_url_decode(data); reply = data; } stream->write_function(stream, "%s", reply); switch_safe_free(data); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(echo_function) { stream->write_function(stream, "%s", cmd); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(stun_function) { char *stun_ip = NULL; char *src_ip = NULL; switch_port_t stun_port = (switch_port_t) SWITCH_STUN_DEFAULT_PORT; char *p; char ip_buf[256] = ""; char *ip = NULL; switch_port_t port = 0; switch_memory_pool_t *pool = NULL; char *error = ""; char *argv[3] = { 0 }; char *mycmd = NULL; ip = ip_buf; if (zstr(cmd)) { stream->write_function(stream, "%s", "-STUN Failed! NO STUN SERVER\n"); return SWITCH_STATUS_SUCCESS; } mycmd = strdup(cmd); switch_split(mycmd, ' ', argv); stun_ip = argv[0]; switch_assert(stun_ip); src_ip = argv[1]; if ((p = strchr(stun_ip, ':'))) { int iport; *p++ = '\0'; iport = atoi(p); if (iport > 0 && iport < 0xFFFF) { stun_port = (switch_port_t) iport; } } else { p = stun_ip; } if (!zstr(src_ip) && (p = strchr(src_ip, ':'))) { int iport; *p++ = '\0'; iport = atoi(p); if (iport > 0 && iport < 0xFFFF) { port = (switch_port_t) iport; } } else if (!zstr(src_ip)) { ip = src_ip; } if ( !zstr(src_ip) ) { switch_copy_string(ip_buf, src_ip, sizeof(ip_buf)); } else { switch_find_local_ip(ip_buf, sizeof(ip_buf), NULL, AF_INET); } switch_core_new_memory_pool(&pool); if (zstr(stun_ip)) { stream->write_function(stream, "%s", "-STUN Failed! NO STUN SERVER\n"); } else { if ((switch_stun_lookup(&ip, &port, stun_ip, stun_port, &error, pool)) == SWITCH_STATUS_SUCCESS && ip && port) { stream->write_function(stream, "%s:%u\n", ip, port); } else { stream->write_function(stream, "-STUN Failed! [%s]\n", error); } } switch_core_destroy_memory_pool(&pool); switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(expand_function) { char *expanded; char *dup; char *arg = NULL; char *mycmd; switch_status_t status; const char *p; switch_core_session_t *xsession; char uuid[80] = ""; if (zstr(cmd)) { stream->write_function(stream, "-ERR No input\n"); return SWITCH_STATUS_SUCCESS; } dup = strdup(cmd); mycmd = dup; if (!strncasecmp(mycmd, "uuid:", 5)) { p = cmd + 5; if ((mycmd = strchr(p, ' ')) && *mycmd++) { switch_copy_string(uuid, p, mycmd - p); } } if (zstr(mycmd)) { stream->write_function(stream, "-ERR No input\n"); switch_safe_free(dup); return SWITCH_STATUS_SUCCESS; } if (*uuid) { if ((xsession = switch_core_session_locate(uuid))) { switch_channel_event_set_data(switch_core_session_get_channel(xsession), stream->param_event); switch_core_session_rwunlock(xsession); } } if (mycmd && (arg = strchr(mycmd, ' '))) { *arg++ = '\0'; } expanded = arg ? switch_event_expand_headers(stream->param_event, arg) : arg; if ((status = switch_api_execute(mycmd, expanded, session, stream)) != SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "-ERR Cannot execute command\n"); } if (expanded != arg) { free(expanded); expanded = NULL; } free(dup); dup = NULL; return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(console_complete_function) { const char *p, *cursor = NULL; int c; if (zstr(cmd)) { cmd = " "; } if ((p = strstr(cmd, "c="))) { p += 2; c = atoi(p); if ((p = strchr(p, ';'))) { cmd = p + 1; cursor = cmd + c; } } switch_console_complete(cmd, cursor, NULL, stream, NULL); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(console_complete_xml_function) { const char *p, *cursor = NULL; int c; switch_xml_t xml = switch_xml_new("complete"); char *sxml; if (zstr(cmd)) { cmd = " "; } if ((p = strstr(cmd, "c="))) { p += 2; c = atoi(p); if ((p = strchr(p, ';'))) { cmd = p + 1; cursor = cmd + c; } } switch_console_complete(cmd, cursor, NULL, NULL, xml); sxml = switch_xml_toxml(xml, SWITCH_TRUE); stream->write_function(stream, "%s", sxml); free(sxml); switch_xml_free(xml); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(eval_function) { char *expanded; switch_event_t *event; char uuid[80] = ""; const char *p, *input = cmd; if (zstr(cmd)) { stream->write_function(stream, "%s", ""); return SWITCH_STATUS_SUCCESS; } if (!strncasecmp(cmd, "uuid:", 5)) { p = cmd + 5; if ((input = strchr(p, ' ')) && *input++) { switch_copy_string(uuid, p, input - p); } } if (zstr(input)) { stream->write_function(stream, "%s", ""); return SWITCH_STATUS_SUCCESS; } switch_event_create(&event, SWITCH_EVENT_CHANNEL_DATA); if (*uuid) { if ((session = switch_core_session_locate(uuid))) { switch_channel_event_set_data(switch_core_session_get_channel(session), event); switch_core_session_rwunlock(session); } } expanded = switch_event_expand_headers(event, input); stream->write_function(stream, "%s", expanded); if (expanded != input) { free(expanded); } switch_event_destroy(&event); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(module_exists_function) { if (!zstr(cmd)) { if (switch_loadable_module_exists(cmd) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "true"); } else { stream->write_function(stream, "false"); } } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(domain_exists_function) { switch_xml_t root = NULL, domain = NULL; if (!zstr(cmd)) { if (switch_xml_locate_domain(cmd, NULL, &root, &domain) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "true"); switch_xml_free(root); } else { stream->write_function(stream, "false"); } } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(url_encode_function) { char *reply = ""; char *data = NULL; int len = 0; if (!zstr(cmd)) { len = (int)(strlen(cmd) * 3) + 1; switch_zmalloc(data, len); switch_url_encode(cmd, data, len); reply = data; } stream->write_function(stream, "%s", reply); switch_safe_free(data); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(toupper_function) { char *reply = ""; char *data = NULL; if (!zstr(cmd)) { int i; data = strdup(cmd); for(i = 0; i < strlen(data); i++) { data[i] = toupper(data[i]); } reply = data; } stream->write_function(stream, "%s", reply); switch_safe_free(data); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(tolower_function) { char *reply = ""; char *data = NULL; if (!zstr(cmd)) { int i; data = strdup(cmd); for(i = 0; i < strlen(data); i++) { data[i] = tolower(data[i]); } reply = data; } stream->write_function(stream, "%s", reply); switch_safe_free(data); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(user_exists_function) { return _find_user(cmd, session, stream, SWITCH_TRUE); } SWITCH_STANDARD_API(find_user_function) { return _find_user(cmd, session, stream, SWITCH_FALSE); } SWITCH_STANDARD_API(xml_locate_function) { switch_xml_t xml = NULL, obj = NULL; int argc; char *mydata = NULL, *argv[4] = { 0 } ; char *section, *tag, *tag_attr_name, *tag_attr_val; switch_event_t *params = NULL; char *xmlstr; char delim = ' '; const char *err = NULL; stream_format format = { 0 }; set_format(&format, stream); if (format.api) { stream->write_function(stream, "Content-Type: text/xml\r\n\r\n"); cmd = format.query; delim = '/'; } if (!cmd) { err = "bad args"; goto end; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, delim, argv, (sizeof(argv) / sizeof(argv[0]))); if (argc == 1 && argv[0] && !strcasecmp(argv[0], "root")) { const char *error; xml = switch_xml_open_root(0, &error); obj = xml; goto end; } if (argc != 1 && argc != 4) { err = "bad args"; goto end; } section = argv[0]; tag = argv[1]; tag_attr_name = argv[2]; tag_attr_val = argv[3]; switch_event_create(¶ms, SWITCH_EVENT_REQUEST_PARAMS); switch_assert(params); switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "section", section); if (tag) { switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "tag", tag); } if (tag_attr_name) { switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "tag_attr_name", tag_attr_name); } if (tag_attr_val) { switch_event_add_header_string(params, SWITCH_STACK_BOTTOM, "tag_attr_val", tag_attr_val); } if (switch_xml_locate(section, tag, tag_attr_name, tag_attr_val, &xml, &obj, params, SWITCH_FALSE) != SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "can't find anything\n"); goto end; } end: if (err) { stream->write_function(stream, "-ERR %s\n", err); } if (obj) { xmlstr = switch_xml_toxml(obj, SWITCH_FALSE); switch_assert(xmlstr); stream->write_function(stream, "%s", xmlstr); free(xmlstr); } switch_xml_free(xml); switch_event_destroy(¶ms); free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(reload_acl_function) { const char *err; if (cmd && !strcasecmp(cmd, "reloadxml")) { stream->write_function(stream, "This option is deprecated, we now always reloadxml.\n"); } if (switch_xml_reload(&err) == SWITCH_STATUS_SUCCESS) { switch_load_network_lists(SWITCH_TRUE); stream->write_function(stream, "+OK acl reloaded\n"); } else { stream->write_function(stream, "-ERR [%s]\n", err); } return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(acl_function) { int argc; char *mydata = NULL, *argv[3]; if (!cmd) { goto error; } mydata = strdup(cmd); switch_assert(mydata); argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 2) { goto error; } if (switch_check_network_list_ip(argv[0], argv[1])) { stream->write_function(stream, "true"); goto ok; } error: stream->write_function(stream, "false"); ok: switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(replace_function) { char delim = '|'; char *mydata = NULL, *argv[3], *d, *replace; int argc = 0; if (!cmd) { goto error; } mydata = strdup(cmd); d = mydata; if (*d == 'm' && *(d + 1) == ':' && *(d + 2)) { char t = *(d + 2); switch (t) { case '|': case '~': case '/': d += 3; delim = t; break; default: break; } } argc = switch_separate_string(d, delim, argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 3) { goto error; } replace = switch_string_replace(argv[0], argv[1], argv[2]); stream->write_function(stream, "%s", replace); free(replace); goto ok; error: stream->write_function(stream, "-ERR"); ok: switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(regex_function) { switch_regex_t *re = NULL; int ovector[30]; int argc; char *mydata = NULL, *argv[4]; size_t len = 0; char *substituted = NULL; int proceed = 0; char *d; char delim = '|'; if (!cmd) { goto error; } mydata = strdup(cmd); switch_assert(mydata); d = mydata; if (*d == 'm' && *(d + 1) == ':' && *(d + 2)) { char t = *(d + 2); switch (t) { case '|': case '~': case '/': d += 3; delim = t; break; default: break; } } argc = switch_separate_string(d, delim, argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 2) { goto error; } proceed = switch_regex_perform(argv[0], argv[1], &re, ovector, sizeof(ovector) / sizeof(ovector[0])); if (argc > 2) { char *flags = ""; if (argc > 3) { flags = argv[3]; } if (proceed) { len = (strlen(argv[0]) + strlen(argv[2]) + 10) * proceed; substituted = malloc(len); switch_assert(substituted); memset(substituted, 0, len); switch_replace_char(argv[2], '%', '$', SWITCH_FALSE); switch_perform_substitution(re, proceed, argv[2], argv[0], substituted, len, ovector); stream->write_function(stream, "%s", substituted); free(substituted); } else { if (strchr(flags, 'n')) { stream->write_function(stream, "%s", ""); } else if (strchr(flags, 'b')) { stream->write_function(stream, "%s", "false"); } else { stream->write_function(stream, "%s", argv[0]); } } } else { stream->write_function(stream, proceed ? "true" : "false"); } goto ok; error: stream->write_function(stream, "-ERR"); ok: switch_regex_safe_free(re); switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } typedef enum { O_NONE, O_EQ, O_NE, O_GT, O_GE, O_LT, O_LE } o_t; SWITCH_STANDARD_API(cond_function) { int argc; char *mydata = NULL, *argv[3]; char *expr; char *a, *b; double a_f = 0.0, b_f = 0.0; int a_is_quoted = 0, b_is_quoted = 0; o_t o = O_NONE; int is_true = 0; if (!cmd) { goto error; } mydata = strdup(cmd); switch_assert(mydata); a = mydata; if (*a == '\'') { a_is_quoted = 1; for (expr = ++a; *expr; expr++) { if (*expr == '\\') { if (*(expr + 1) == '\\' || *(expr + 1) == '\'') { expr++; } } else if (*expr == '\'') { break; } } if (!*expr) { goto error; } *expr++ = '\0'; if (!switch_isspace(*expr)) { goto error; } } else { if ((expr = strchr(a, ' '))) { *expr++ = '\0'; } else { goto error; } } while (switch_isspace(*expr)) expr++; switch(*expr) { case '!': case '<': case '>': case '=': goto operator; default: goto error; } operator: switch (*expr) { case '!': *expr++ = '\0'; if (*expr == '=') { o = O_NE; *expr++ = '\0'; } break; case '>': *expr++ = '\0'; if (*expr == '=') { o = O_GE; *expr++ = '\0'; } else { o = O_GT; } break; case '<': *expr++ = '\0'; if (*expr == '=') { o = O_LE; *expr++ = '\0'; } else { o = O_LT; } break; case '=': *expr++ = '\0'; if (*expr == '=') { o = O_EQ; *expr++ = '\0'; } break; default: goto error; } if (o) { char *s_a = NULL, *s_b = NULL; int a_is_num, b_is_num; expr++; while (switch_isspace(*expr)) expr++; b = expr; if (*b == '\'') { b_is_quoted = 1; for (expr = ++b; *expr; expr++) { if (*expr == '\\') { if (*(expr + 1) == '\\' || *(expr + 1) == '\'') { expr++; } } else if (*expr == '\'') { break; } } if (!*expr) { goto error; } *expr++ = '\0'; if (!switch_isspace(*expr)) { goto error; } } else { if ((expr = strchr(b, ' '))) { *expr++ = '\0'; } else { goto error; } } while (switch_isspace(*expr)) expr++; if (*expr != '?') { goto error; } *expr = ':'; argc = switch_separate_string(expr, ':', argv, (sizeof(argv) / sizeof(argv[0]))); if (!(argc >= 2 && argc <= 3)) { goto error; } s_a = a; s_b = b; a_is_num = (switch_is_number(s_a) && !a_is_quoted); b_is_num = (switch_is_number(s_b) && !b_is_quoted); a_f = a_is_num ? atof(s_a) : (float) strlen(s_a); b_f = b_is_num ? atof(s_b) : (float) strlen(s_b); switch (o) { case O_EQ: if (!a_is_num && !b_is_num) { is_true = !strcmp(s_a, s_b); } else { is_true = a_f == b_f; } break; case O_NE: if (!a_is_num && !b_is_num) { is_true = strcmp(s_a, s_b); } else { is_true = a_f != b_f; } break; case O_GT: is_true = a_f > b_f; break; case O_GE: is_true = a_f >= b_f; break; case O_LT: is_true = a_f < b_f; break; case O_LE: is_true = a_f <= b_f; break; default: break; } if ((argc == 2 && !is_true)) { stream->write_function(stream, ""); } else { stream->write_function(stream, "%s", is_true ? argv[1] : argv[2]); } goto end; } error: stream->write_function(stream, "-ERR"); end: switch_safe_free(mydata); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(lan_addr_function) { stream->write_function(stream, "%s", switch_is_lan_addr(cmd) ? "true" : "false"); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(status_function) { switch_core_time_duration_t duration = { 0 }; int sps = 0, last_sps = 0, max_sps = 0, max_sps_fivemin = 0; int sessions_peak = 0, sessions_peak_fivemin = 0; /* Max Concurrent Sessions buffers */ switch_bool_t html = SWITCH_FALSE; /* shortcut to format.html */ char * nl = "\n"; /* shortcut to format.nl */ stream_format format = { 0 }; switch_size_t cur = 0, max = 0; set_format(&format, stream); if (format.api) { format.html = SWITCH_TRUE; format.nl = "
\n"; } if (format.html) { /* set flag to allow refresh of webpage if web request contained kv-pair refresh=xx */ switch_event_add_header_string(stream->param_event, SWITCH_STACK_BOTTOM, "HTTP-REFRESH", "true"); if (format.api) { /* "Overwrite" default "api" Content-Type: text/plain */ stream->write_function(stream, "Content-Type: text/html\r\n\r\n"); } } html = format.html; nl = format.nl; if (html) { /* don't bother cli with heading and timestamp */ stream->write_function(stream, "%sFreeSWITCH Status%s", "

", "

\n"); stream->write_function(stream, "%s%s", switch_event_get_header(stream->param_event,"Event-Date-Local"), nl); } switch_core_measure_time(switch_core_uptime(), &duration); stream->write_function(stream, "UP %u year%s, %u day%s, %u hour%s, %u minute%s, %u second%s, %u millisecond%s, %u microsecond%s%s", duration.yr, duration.yr == 1 ? "" : "s", duration.day, duration.day == 1 ? "" : "s", duration.hr, duration.hr == 1 ? "" : "s", duration.min, duration.min == 1 ? "" : "s", duration.sec, duration.sec == 1 ? "" : "s", duration.ms , duration.ms == 1 ? "" : "s", duration.mms, duration.mms == 1 ? "" : "s", nl); stream->write_function(stream, "FreeSWITCH (Version %s) is %s%s", switch_version_full_human(), switch_core_ready() ? "ready" : "not ready", nl); stream->write_function(stream, "%" SWITCH_SIZE_T_FMT " session(s) since startup%s", switch_core_session_id() - 1, nl); switch_core_session_ctl(SCSC_SESSIONS_PEAK, &sessions_peak); switch_core_session_ctl(SCSC_SESSIONS_PEAK_FIVEMIN, &sessions_peak_fivemin); stream->write_function(stream, "%d session(s) - peak %d, last 5min %d %s", switch_core_session_count(), sessions_peak, sessions_peak_fivemin, nl); switch_core_session_ctl(SCSC_LAST_SPS, &last_sps); switch_core_session_ctl(SCSC_SPS, &sps); switch_core_session_ctl(SCSC_SPS_PEAK, &max_sps); switch_core_session_ctl(SCSC_SPS_PEAK_FIVEMIN, &max_sps_fivemin); stream->write_function(stream, "%d session(s) per Sec out of max %d, peak %d, last 5min %d %s", last_sps, sps, max_sps, max_sps_fivemin, nl); stream->write_function(stream, "%d session(s) max%s", switch_core_session_limit(0), nl); stream->write_function(stream, "min idle cpu %0.2f/%0.2f%s", switch_core_min_idle_cpu(-1.0), switch_core_idle_cpu(), nl); if (switch_core_get_stacksizes(&cur, &max) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "Current Stack Size/Max %ldK/%ldK\n", cur / 1024, max / 1024); } return SWITCH_STATUS_SUCCESS; } #define UPTIME_SYNTAX "[us|ms|s|m|h|d|microseconds|milliseconds|seconds|minutes|hours|days]" SWITCH_STANDARD_API(uptime_function) { switch_time_t scale; if (zstr(cmd)) { /* default to seconds */ scale = 1000000; } else if (!strcasecmp(cmd, "microseconds") || !strcasecmp(cmd, "us")) { scale = 1; } else if (!strcasecmp(cmd, "milliseconds") || !strcasecmp(cmd, "ms")) { scale = 1000; } else if (!strcasecmp(cmd, "seconds") || !strcasecmp(cmd, "s")) { scale = 1000000; } else if (!strcasecmp(cmd, "minutes") || !strcasecmp(cmd, "m")) { scale = 60000000; } else if (!strcasecmp(cmd, "hours") || !strcasecmp(cmd, "h")) { scale = 3600000000; } else if (!strcasecmp(cmd, "days") || !strcasecmp(cmd, "d")) { scale = 86400000000; } else { stream->write_function(stream, "-USAGE: %s\n", UPTIME_SYNTAX); return SWITCH_STATUS_SUCCESS; } stream->write_function(stream, "%u\n", switch_core_uptime() / scale); return SWITCH_STATUS_SUCCESS; } #define CTL_SYNTAX "[recover|send_sighup|hupall|pause [inbound|outbound]|resume [inbound|outbound]|shutdown [cancel|elegant|asap|now|restart]|sps|sps_peak_reset|sync_clock|sync_clock_when_idle|reclaim_mem|max_sessions|min_dtmf_duration [num]|max_dtmf_duration [num]|default_dtmf_duration [num]|min_idle_cpu|loglevel [level]|debug_level [level]]" SWITCH_STANDARD_API(ctl_function) { int argc; char *mydata, *argv[6]; int32_t arg = 0; if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", CTL_SYNTAX); return SWITCH_STATUS_SUCCESS; } if ((mydata = strdup(cmd))) { argc = switch_separate_string(mydata, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (!strcasecmp(argv[0], "hupall")) { arg = 1; switch_core_session_ctl(SCSC_HUPALL, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "recover")) { int r = switch_core_session_ctl(SCSC_RECOVER, argv[1]); if (r < 0){ stream->write_function(stream, "+OK flushed\n"); } else { stream->write_function(stream, "+OK %d session(s) recovered in total\n", r); } } else if (!strcasecmp(argv[0], "flush_db_handles")) { switch_core_session_ctl(SCSC_FLUSH_DB_HANDLES, NULL); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "pause")) { switch_session_ctl_t command = SCSC_PAUSE_ALL; arg = 1; if (argv[1]) { if (!strcasecmp(argv[1], "inbound")) { command = SCSC_PAUSE_INBOUND; } else if (!strcasecmp(argv[1], "outbound")) { command = SCSC_PAUSE_OUTBOUND; } } switch_core_session_ctl(command, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "send_sighup")) { arg = 1; switch_core_session_ctl(SCSC_SEND_SIGHUP, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "resume")) { switch_session_ctl_t command = SCSC_PAUSE_ALL; arg = 0; if (argv[1]) { if (!strcasecmp(argv[1], "inbound")) { command = SCSC_PAUSE_INBOUND; } else if (!strcasecmp(argv[1], "outbound")) { command = SCSC_PAUSE_OUTBOUND; } } switch_core_session_ctl(command, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "calibrate_clock")) { switch_core_session_ctl(SCSC_CALIBRATE_CLOCK, NULL); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "crash")) { switch_core_session_ctl(SCSC_CRASH, NULL); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "verbose_events")) { arg = -1; if (argv[1]) { arg = switch_true(argv[1]); } switch_core_session_ctl(SCSC_VERBOSE_EVENTS, &arg); stream->write_function(stream, "+OK verbose_events is %s \n", arg ? "on" : "off"); } else if (!strcasecmp(argv[0], "api_expansion")) { arg = -1; if (argv[1]) { arg = switch_true(argv[1]); } switch_core_session_ctl(SCSC_API_EXPANSION, &arg); stream->write_function(stream, "+OK api_expansion is %s \n", arg ? "on" : "off"); } else if (!strcasecmp(argv[0], "threaded_system_exec")) { arg = -1; if (argv[1]) { arg = switch_true(argv[1]); } switch_core_session_ctl(SCSC_THREADED_SYSTEM_EXEC, &arg); stream->write_function(stream, "+OK threaded_system_exec is %s \n", arg ? "true" : "false"); } else if (!strcasecmp(argv[0], "save_history")) { switch_core_session_ctl(SCSC_SAVE_HISTORY, NULL); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "pause_check")) { switch_session_ctl_t command = SCSC_PAUSE_CHECK; if (argv[1]) { if (!strcasecmp(argv[1], "inbound")) { command = SCSC_PAUSE_INBOUND_CHECK; } else if (!strcasecmp(argv[1], "outbound")) { command = SCSC_PAUSE_OUTBOUND_CHECK; } } switch_core_session_ctl(command, &arg); stream->write_function(stream, arg ? "true" : "false"); } else if (!strcasecmp(argv[0], "ready_check")) { switch_core_session_ctl(SCSC_READY_CHECK, &arg); stream->write_function(stream, arg ? "true" : "false"); } else if (!strcasecmp(argv[0], "shutdown_check")) { switch_core_session_ctl(SCSC_SHUTDOWN_CHECK, &arg); stream->write_function(stream, arg ? "true" : "false"); } else if (!strcasecmp(argv[0], "shutdown")) { switch_session_ctl_t command = SCSC_SHUTDOWN; int x = 0; arg = 0; for (x = 1; x < 5; x++) { if (argv[x]) { if (!strcasecmp(argv[x], "cancel")) { arg = 0; command = SCSC_CANCEL_SHUTDOWN; break; } else if (!strcasecmp(argv[x], "elegant")) { command = SCSC_SHUTDOWN_ELEGANT; } else if (!strcasecmp(argv[x], "now")) { command = SCSC_SHUTDOWN_NOW; } else if (!strcasecmp(argv[x], "asap")) { command = SCSC_SHUTDOWN_ASAP; } else if (!strcasecmp(argv[x], "reincarnate") && (x+1 < argc) && argv[x+1] && !strcasecmp(argv[x+1], "now")) { ++x; command = SCSC_REINCARNATE_NOW; } else if (!strcasecmp(argv[x], "restart")) { arg = 1; } } else { break; } } switch_core_session_ctl(command, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "debug_pool")) { switch_core_session_debug_pool(stream); } else if (!strcasecmp(argv[0], "debug_sql")) { int x = 0; switch_core_session_ctl(SCSC_DEBUG_SQL, &x); stream->write_function(stream, "+OK SQL DEBUG [%s]\n", x ? "on" : "off"); } else if (!strcasecmp(argv[0], "sql")) { if (argv[1]) { int x = 0; if (!strcasecmp(argv[1], "start")) { x = 1; } switch_core_session_ctl(SCSC_SQL, &x); stream->write_function(stream, "+OK\n"); } } else if (!strcasecmp(argv[0], "reclaim_mem")) { switch_core_session_ctl(SCSC_RECLAIM, &arg); stream->write_function(stream, "+OK\n"); } else if (!strcasecmp(argv[0], "max_sessions")) { if (argc > 1) { arg = atoi(argv[1]); } switch_core_session_ctl(SCSC_MAX_SESSIONS, &arg); stream->write_function(stream, "+OK max sessions: %d\n", arg); } else if (!strcasecmp(argv[0], "min_idle_cpu")) { double d = -1; if (argc > 1) { d = atof(argv[1]); } switch_core_session_ctl(SCSC_MIN_IDLE_CPU, &d); if (d) { stream->write_function(stream, "+OK min idle cpu: %0.2f%\n", d); } else { stream->write_function(stream, "+OK min idle cpu: DISABLED\n", d); } } else if (!strcasecmp(argv[0], "max_dtmf_duration")) { if (argc > 1) { arg = atoi(argv[1]); } switch_core_session_ctl(SCSC_MAX_DTMF_DURATION, &arg); stream->write_function(stream, "+OK max dtmf duration: %d\n", arg); } else if (!strcasecmp(argv[0], "min_dtmf_duration")) { if (argc > 1) { arg = atoi(argv[1]); } switch_core_session_ctl(SCSC_MIN_DTMF_DURATION, &arg); stream->write_function(stream, "+OK min dtmf duration: %d\n", arg); } else if (!strcasecmp(argv[0], "default_dtmf_duration")) { if (argc > 1) { arg = atoi(argv[1]); } switch_core_session_ctl(SCSC_DEFAULT_DTMF_DURATION, &arg); stream->write_function(stream, "+OK default dtmf duration: %d\n", arg); } else if (!strcasecmp(argv[0], "loglevel")) { if (argc > 1) { if (*argv[1] > 47 && *argv[1] < 58) { arg = atoi(argv[1]); } else { arg = switch_log_str2level(argv[1]); } } else { arg = -1; } if (arg == SWITCH_LOG_INVALID) { stream->write_function(stream, "-ERR syntax error, log level not set!\n"); } else { switch_core_session_ctl(SCSC_LOGLEVEL, &arg); stream->write_function(stream, "+OK log level: %s [%d]\n", switch_log_level2str(arg), arg); } } else if (!strcasecmp(argv[0], "debug_level")) { if (argc > 1) { arg = atoi(argv[1]); } else { arg = -1; } switch_core_session_ctl(SCSC_DEBUG_LEVEL, &arg); stream->write_function(stream, "+OK DEBUG level: %d\n", arg); } else if (!strcasecmp(argv[0], "sps_peak_reset")) { arg = -1; switch_core_session_ctl(SCSC_SPS_PEAK, &arg); stream->write_function(stream, "+OK max sessions per second counter reset\n"); } else if (!strcasecmp(argv[0], "last_sps")) { switch_core_session_ctl(SCSC_LAST_SPS, &arg); stream->write_function(stream, "+OK last sessions per second: %d\n", arg); } else if (!strcasecmp(argv[0], "sps")) { if (argc > 1) { arg = atoi(argv[1]); } else { arg = 0; } switch_core_session_ctl(SCSC_SPS, &arg); stream->write_function(stream, "+OK sessions per second: %d\n", arg); } else if (!strcasecmp(argv[0], "sync_clock")) { arg = 0; switch_core_session_ctl(SCSC_SYNC_CLOCK, &arg); stream->write_function(stream, "+OK clock synchronized\n"); } else if (!strcasecmp(argv[0], "sync_clock_when_idle")) { arg = 0; switch_core_session_ctl(SCSC_SYNC_CLOCK_WHEN_IDLE, &arg); if (arg) { stream->write_function(stream, "+OK clock synchronized\n"); } else { stream->write_function(stream, "+OK clock will synchronize when there are no more calls\n"); } } else { stream->write_function(stream, "-ERR Invalid command\nUSAGE: fsctl %s\n", CTL_SYNTAX); goto end; } end: free(mydata); } else { stream->write_function(stream, "-ERR Memory error\n"); } return SWITCH_STATUS_SUCCESS; } #define LOAD_SYNTAX "" SWITCH_STANDARD_API(load_function) { const char *err; if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", LOAD_SYNTAX); return SWITCH_STATUS_SUCCESS; } switch_mutex_lock(reload_mutex); if (switch_xml_reload(&err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK Reloading XML\n"); } if (switch_loadable_module_load_module((char *) SWITCH_GLOBAL_dirs.mod_dir, (char *) cmd, SWITCH_TRUE, &err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR [%s]\n", err); } switch_mutex_unlock(reload_mutex); return SWITCH_STATUS_SUCCESS; } #define UNLOAD_SYNTAX "[-f] " SWITCH_STANDARD_API(unload_function) { const char *err; switch_bool_t force = SWITCH_FALSE; const char *p = cmd; if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", UNLOAD_SYNTAX); return SWITCH_STATUS_SUCCESS; } if (*p == '-') { p++; while (p && *p) { switch (*p) { case ' ': cmd = p + 1; goto end; case 'f': force = SWITCH_TRUE; break; default: break; } p++; } } end: if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", UNLOAD_SYNTAX); return SWITCH_STATUS_SUCCESS; } switch_mutex_lock(reload_mutex); if (switch_loadable_module_unload_module((char *) SWITCH_GLOBAL_dirs.mod_dir, (char *) cmd, force, &err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR [%s]\n", err); } switch_mutex_unlock(reload_mutex); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(reload_function) { const char *err; switch_bool_t force = SWITCH_FALSE; const char *p = cmd; if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", UNLOAD_SYNTAX); return SWITCH_STATUS_SUCCESS; } if (*p == '-') { p++; while (p && *p) { switch (*p) { case ' ': cmd = p + 1; goto end; case 'f': force = SWITCH_TRUE; break; default: break; } p++; } } end: if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", UNLOAD_SYNTAX); return SWITCH_STATUS_SUCCESS; } switch_mutex_lock(reload_mutex); if (switch_xml_reload(&err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK Reloading XML\n"); } if (switch_loadable_module_unload_module((char *) SWITCH_GLOBAL_dirs.mod_dir, (char *) cmd, force, &err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK module unloaded\n"); } else { stream->write_function(stream, "-ERR unloading module [%s]\n", err); } if (switch_loadable_module_load_module((char *) SWITCH_GLOBAL_dirs.mod_dir, (char *) cmd, SWITCH_TRUE, &err) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK module loaded\n"); } else { stream->write_function(stream, "-ERR loading module [%s]\n", err); } switch_mutex_unlock(reload_mutex); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(reload_xml_function) { const char *err = ""; switch_xml_reload(&err); stream->write_function(stream, "+OK [%s]\n", err); return SWITCH_STATUS_SUCCESS; } #define KILL_SYNTAX " [cause]" SWITCH_STANDARD_API(kill_function) { char *mycmd = NULL, *kcause = NULL; switch_call_cause_t cause = SWITCH_CAUSE_NORMAL_CLEARING; if (zstr(cmd) || !(mycmd = strdup(cmd))) { stream->write_function(stream, "-USAGE: %s\n", KILL_SYNTAX); return SWITCH_STATUS_SUCCESS; } if ((kcause = strchr(mycmd, ' '))) { *kcause++ = '\0'; if (!zstr(kcause)) { cause = switch_channel_str2cause(kcause); } } if (switch_ivr_kill_uuid(mycmd, cause) != SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "-ERR No such channel!\n"); } else { stream->write_function(stream, "+OK\n"); } switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } #define OUTGOING_ANSWER_SYNTAX "" SWITCH_STANDARD_API(outgoing_answer_function) { switch_core_session_t *outgoing_session = NULL; char *mycmd = NULL; if (zstr(cmd) || !(mycmd = strdup(cmd))) { stream->write_function(stream, "-USAGE: %s\n", OUTGOING_ANSWER_SYNTAX); return SWITCH_STATUS_SUCCESS; } if (zstr(mycmd) || !(outgoing_session = switch_core_session_locate(mycmd))) { stream->write_function(stream, "-ERR No such channel!\n"); } else { switch_channel_t *channel = switch_core_session_get_channel(outgoing_session); if (switch_channel_direction(channel) == SWITCH_CALL_DIRECTION_OUTBOUND) { switch_channel_mark_answered(channel); stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR Not an outbound channel!\n"); } switch_core_session_rwunlock(outgoing_session); } switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } #define PREPROCESS_SYNTAX "<>" SWITCH_STANDARD_API(preprocess_function) { switch_core_session_t *ksession = NULL; char *mycmd = NULL, *argv[3] = { 0 }; int argc = 0; if (zstr(cmd) || !(mycmd = strdup(cmd))) { goto usage; } argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 2) { goto usage; } if (!(ksession = switch_core_session_locate(argv[0]))) { stream->write_function(stream, "-ERR No such channel!\n"); goto done; } else { switch_ivr_preprocess_session(ksession, (char *) argv[1]); switch_core_session_rwunlock(ksession); stream->write_function(stream, "+OK\n"); goto done; } usage: stream->write_function(stream, "-USAGE: %s\n", PREPROCESS_SYNTAX); done: switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } #define PARK_SYNTAX "" SWITCH_STANDARD_API(park_function) { switch_core_session_t *ksession = NULL; if (!cmd) { stream->write_function(stream, "-USAGE: %s\n", PARK_SYNTAX); } else if ((ksession = switch_core_session_locate(cmd))) { switch_ivr_park_session(ksession); switch_core_session_rwunlock(ksession); stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR No such channel!\n"); } return SWITCH_STATUS_SUCCESS; } #define TRANSFER_SYNTAX " [-bleg|-both] [] []" SWITCH_STANDARD_API(transfer_function) { switch_core_session_t *tsession = NULL, *other_session = NULL; char *mycmd = NULL, *argv[5] = { 0 }; int argc = 0; char *tuuid, *dest, *dp, *context, *arg = NULL; if (zstr(cmd) || !(mycmd = strdup(cmd))) { stream->write_function(stream, "-USAGE: %s\n", TRANSFER_SYNTAX); return SWITCH_STATUS_SUCCESS; } argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc < 2 || argc > 5) { stream->write_function(stream, "-USAGE: %s\n", TRANSFER_SYNTAX); goto done; } tuuid = argv[0]; dest = argv[1]; dp = argv[2]; context = argv[3]; if (zstr(tuuid) || !(tsession = switch_core_session_locate(tuuid))) { stream->write_function(stream, "-ERR No such channel!\n"); goto done; } if (*dest == '-') { arg = dest; dest = argv[2]; dp = argv[3]; context = argv[4]; } if (arg) { switch_channel_t *channel = switch_core_session_get_channel(tsession); const char *uuid = switch_channel_get_variable(channel, SWITCH_BRIDGE_VARIABLE); arg++; if (!strcasecmp(arg, "bleg")) { if (uuid && (other_session = switch_core_session_locate(uuid))) { switch_core_session_t *tmp = tsession; tsession = other_session; other_session = NULL; if (switch_true(switch_channel_get_variable(channel, "recording_follow_transfer"))) { switch_core_media_bug_transfer_recordings(tmp, tsession); } switch_core_session_rwunlock(tmp); } } else if (!strcasecmp(arg, "both")) { if (uuid && (other_session = switch_core_session_locate(uuid))) { switch_channel_t *other_channel = switch_core_session_get_channel(other_session); switch_channel_set_flag(other_channel, CF_REDIRECT); switch_channel_set_flag(channel, CF_REDIRECT); switch_ivr_session_transfer(other_session, dest, dp, context); switch_core_session_rwunlock(other_session); } } } if (switch_ivr_session_transfer(tsession, dest, dp, context) == SWITCH_STATUS_SUCCESS) { stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR\n"); } switch_core_session_rwunlock(tsession); done: switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } #define DUAL_TRANSFER_SYNTAX " [/][/] [/][/]" SWITCH_STANDARD_API(dual_transfer_function) { switch_core_session_t *tsession = NULL, *other_session = NULL; char *mycmd = NULL, *argv[5] = { 0 }; int argc = 0; char *tuuid, *dest1, *dest2, *dp1 = NULL, *dp2 = NULL, *context1 = NULL, *context2 = NULL; if (zstr(cmd) || !(mycmd = strdup(cmd))) { stream->write_function(stream, "-USAGE: %s\n", DUAL_TRANSFER_SYNTAX); return SWITCH_STATUS_SUCCESS; } argc = switch_separate_string(mycmd, ' ', argv, (sizeof(argv) / sizeof(argv[0]))); if (argc != 3) { stream->write_function(stream, "-USAGE: %s\n", DUAL_TRANSFER_SYNTAX); goto done; } tuuid = argv[0]; dest1 = argv[1]; dest2= argv[2]; if ((dp1 = strstr(dest1, "/inline")) && *(dp1 + 7) == '\0') { *dp1++ = '\0'; } else { if ((dp1 = strchr(dest1, '/'))) { *dp1++ = '\0'; if ((context1 = strchr(dp1, '/'))) { *context1++ = '\0'; } } } if ((dp2 = strstr(dest2, "/inline")) && *(dp2 + 7) == '\0') { *dp2++ = '\0'; } else { if ((dp2 = strchr(dest2, '/'))) { *dp2++ = '\0'; if ((context2 = strchr(dp2, '/'))) { *context2++ = '\0'; } } } if (zstr(tuuid) || !(tsession = switch_core_session_locate(tuuid))) { stream->write_function(stream, "-ERR No such channel!\n"); goto done; } if (switch_core_session_get_partner(tsession, &other_session) == SWITCH_STATUS_SUCCESS) { switch_ivr_session_transfer(other_session, dest2, dp2, context2); switch_core_session_rwunlock(other_session); } switch_ivr_session_transfer(tsession, dest1, dp1, context1); stream->write_function(stream, "+OK\n"); switch_core_session_rwunlock(tsession); done: switch_safe_free(mycmd); return SWITCH_STATUS_SUCCESS; } #define TONE_DETECT_SYNTAX " [ ]" SWITCH_STANDARD_API(tone_detect_session_function) { char *argv[8] = { 0 }; int argc; char *mydata = NULL; time_t to = 0; switch_core_session_t *rsession; int hits = 1; if (!cmd) { stream->write_function(stream, "-USAGE: %s\n", TONE_DETECT_SYNTAX); return SWITCH_STATUS_SUCCESS; } mydata = strdup(cmd); switch_assert(mydata != NULL); if ((argc = switch_separate_string(mydata, ' ', argv, sizeof(argv) / sizeof(argv[0]))) < 3 || !argv[0]) { switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "-ERR INVALID ARGS!\n"); return SWITCH_STATUS_SUCCESS; } if (!(rsession = switch_core_session_locate(argv[0]))) { stream->write_function(stream, "-ERR Cannot locate session!\n"); return SWITCH_STATUS_SUCCESS; } if (argv[4]) { uint32_t mto; if (*argv[4] == '+') { if ((mto = atoi(argv[4] + 1)) > 0) { to = switch_epoch_time_now(NULL) + mto; } else { switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "INVALID Timeout!\n"); goto done; } } else { if ((to = atoi(argv[4])) < switch_epoch_time_now(NULL)) { switch_log_printf(SWITCH_CHANNEL_SESSION_LOG(session), SWITCH_LOG_ERROR, "INVALID Timeout!\n"); to = 0; goto done; } } } if (argv[7]) { hits = atoi(argv[7]); if (hits < 0) { hits = 1; } } switch_ivr_tone_detect_session(rsession, argv[1], argv[2], argv[3], to, hits, argv[5], argv[6], NULL); stream->write_function(stream, "+OK Enabling tone detection '%s' '%s' '%s'\n", argv[1], argv[2], argv[3]); done: free(mydata); switch_core_session_rwunlock(rsession); return SWITCH_STATUS_SUCCESS; } SWITCH_STANDARD_API(uuid_function) { char uuid_str[SWITCH_UUID_FORMATTED_LENGTH + 1]; switch_uuid_str(uuid_str, sizeof(uuid_str)); stream->write_function(stream, "%s", uuid_str); return SWITCH_STATUS_SUCCESS; } #define UUID_CHAT_SYNTAX " " SWITCH_STANDARD_API(uuid_chat) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *text = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((text = strchr(uuid, ' '))) { *text++ = '\0'; } } if (zstr(uuid) || zstr(text)) { stream->write_function(stream, "-USAGE: %s\n", UUID_CHAT_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_event_t *event; if (switch_event_create(&event, SWITCH_EVENT_COMMAND) == SWITCH_STATUS_SUCCESS) { switch_event_add_body(event, "%s", text); if (switch_core_session_receive_event(tsession, &event) != SWITCH_STATUS_SUCCESS) { switch_event_destroy(&event); stream->write_function(stream, "-ERR Send failed\n"); } else { stream->write_function(stream, "+OK\n"); } } switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define UUID_CAPTURE_TEXT_SYNTAX " " SWITCH_STANDARD_API(uuid_capture_text) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *onoff = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((onoff = strchr(uuid, ' '))) { *onoff++ = '\0'; } } if (zstr(uuid) || zstr(onoff)) { stream->write_function(stream, "-USAGE: %s\n", UUID_CAPTURE_TEXT_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_ivr_capture_text(tsession, switch_true(onoff)); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define UUID_SEND_TEXT_SYNTAX " " SWITCH_STANDARD_API(uuid_send_text) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *text = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((text = strchr(uuid, ' '))) { *text++ = '\0'; } } if (zstr(uuid) || zstr(text)) { stream->write_function(stream, "-USAGE: %s\n", UUID_SEND_TEXT_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_core_session_print(tsession, text); switch_core_session_print(tsession, "\r\n"); switch_core_session_rwunlock(tsession); stream->write_function(stream, "+OK\n"); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define UUID_DROP_DTMF_SYNTAX " [on | off ] [ mask_digits | mask_file ]" SWITCH_STANDARD_API(uuid_drop_dtmf) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *action = NULL, *mask_action = NULL, *mask_arg = NULL; char *argv[5] = { 0 }; char *dup; int argc = 0; if (zstr(cmd)) { stream->write_function(stream, "-USAGE: %s\n", UUID_DROP_DTMF_SYNTAX); return SWITCH_STATUS_SUCCESS; } dup = strdup(cmd); argc = switch_split(dup, ' ', argv); if ( argc < 4 ) { stream->write_function(stream, "-USAGE: %s\n", UUID_DROP_DTMF_SYNTAX); goto end; } if (argv[0]) { uuid = argv[0]; } if (argv[1]) { action = argv[1]; } if (argv[2]) { mask_action = argv[2]; } if (argv[3]) { mask_arg = argv[3]; } if (zstr(uuid)) { stream->write_function(stream, "-USAGE: %s\n", UUID_DROP_DTMF_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_channel_t *channel = switch_core_session_get_channel(tsession); int is_on = 0; const char *file, *digits; switch_channel_set_variable(channel, "drop_dtmf_masking_digits", NULL); switch_channel_set_variable(channel, "drop_dtmf_masking_file", NULL); if (!zstr(mask_action) && !zstr(mask_arg)) { if (!strcasecmp(mask_action, "mask_digits")) { switch_channel_set_variable(channel, "drop_dtmf_masking_digits", mask_arg); } else if (!strcasecmp(mask_action, "mask_file")) { switch_channel_set_variable(channel, "drop_dtmf_masking_file", mask_arg); } else { stream->write_function(stream, "-USAGE: %s\n", UUID_DROP_DTMF_SYNTAX); goto end; } } if (!zstr(action)) { if (!strcasecmp(action, "on")) { switch_channel_set_flag(channel, CF_DROP_DTMF); switch_channel_set_variable(channel, "drop_dtmf", "true"); } else { switch_channel_clear_flag(channel, CF_DROP_DTMF); switch_channel_set_variable(channel, "drop_dtmf", "false"); } } is_on = switch_channel_test_flag(channel, CF_DROP_DTMF); file = switch_channel_get_variable_dup(channel, "drop_dtmf_masking_file", SWITCH_FALSE, -1); digits = switch_channel_get_variable_dup(channel, "drop_dtmf_masking_digits", SWITCH_FALSE, -1); stream->write_function(stream, "+OK %s is %s DTMF. mask_file: %s mask_digits: %s\n", uuid, is_on ? "dropping" : "not dropping", file ? file : "NONE", digits ? digits : "NONE"); switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } end: switch_safe_free(dup); return SWITCH_STATUS_SUCCESS; } #define UUID_DEFLECT_SYNTAX " " SWITCH_STANDARD_API(uuid_deflect) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *text = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((text = strchr(uuid, ' '))) { *text++ = '\0'; } } if (zstr(uuid) || zstr(text)) { stream->write_function(stream, "-USAGE: %s\n", UUID_DEFLECT_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_core_session_message_t msg = { 0 }; /* Tell the channel to deflect the call */ msg.from = __FILE__; msg.string_arg = text; msg.message_id = SWITCH_MESSAGE_INDICATE_DEFLECT; switch_core_session_receive_message(tsession, &msg); stream->write_function(stream, "+OK:%s\n", msg.string_reply); switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define UUID_REDIRECT_SYNTAX " " SWITCH_STANDARD_API(uuid_redirect) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *text = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((text = strchr(uuid, ' '))) { *text++ = '\0'; } } if (zstr(uuid) || zstr(text)) { stream->write_function(stream, "-USAGE: %s\n", UUID_REDIRECT_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_core_session_message_t msg = { 0 }; /* Tell the channel to redirect the call */ msg.from = __FILE__; msg.string_arg = text; msg.message_id = SWITCH_MESSAGE_INDICATE_REDIRECT; msg.numeric_arg = 1; switch_core_session_receive_message(tsession, &msg); stream->write_function(stream, "+OK:%s\n", msg.string_reply); switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define UUID_MEDIA_STATS_SYNTAX "" SWITCH_STANDARD_API(uuid_set_media_stats) { switch_core_session_t *tsession = NULL; const char *uuid = cmd; if (zstr(uuid)) { stream->write_function(stream, "-USAGE: %s\n", UUID_MEDIA_STATS_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_core_media_set_stats(tsession); stream->write_function(stream, "+OK:\n"); switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } return SWITCH_STATUS_SUCCESS; } #define add_stat(_i, _s) cJSON_AddItemToObject(jstats, _s, cJSON_CreateNumber(((double)_i))) static void jsonify_stats(cJSON *json, const char *name, switch_rtp_stats_t *stats) { cJSON *jstats = cJSON_CreateObject(); cJSON_AddItemToObject(json, name, jstats); stats->inbound.std_deviation = sqrt(stats->inbound.variance); add_stat(stats->inbound.raw_bytes, "in_raw_bytes"); add_stat(stats->inbound.media_bytes, "in_media_bytes"); add_stat(stats->inbound.packet_count, "in_packet_count"); add_stat(stats->inbound.media_packet_count, "in_media_packet_count"); add_stat(stats->inbound.skip_packet_count, "in_skip_packet_count"); add_stat(stats->inbound.jb_packet_count, "in_jitter_packet_count"); add_stat(stats->inbound.dtmf_packet_count, "in_dtmf_packet_count"); add_stat(stats->inbound.cng_packet_count, "in_cng_packet_count"); add_stat(stats->inbound.flush_packet_count, "in_flush_packet_count"); add_stat(stats->inbound.largest_jb_size, "in_largest_jb_size"); add_stat (stats->inbound.min_variance, "in_jitter_min_variance"); add_stat (stats->inbound.max_variance, "in_jitter_max_variance"); add_stat (stats->inbound.lossrate, "in_jitter_loss_rate"); add_stat (stats->inbound.burstrate, "in_jitter_burst_rate"); add_stat (stats->inbound.mean_interval, "in_mean_interval"); add_stat(stats->inbound.flaws, "in_flaw_total"); add_stat (stats->inbound.R, "in_quality_percentage"); add_stat (stats->inbound.mos, "in_mos"); add_stat(stats->outbound.raw_bytes, "out_raw_bytes"); add_stat(stats->outbound.media_bytes, "out_media_bytes"); add_stat(stats->outbound.packet_count, "out_packet_count"); add_stat(stats->outbound.media_packet_count, "out_media_packet_count"); add_stat(stats->outbound.skip_packet_count, "out_skip_packet_count"); add_stat(stats->outbound.dtmf_packet_count, "out_dtmf_packet_count"); add_stat(stats->outbound.cng_packet_count, "out_cng_packet_count"); add_stat(stats->rtcp.packet_count, "rtcp_packet_count"); add_stat(stats->rtcp.octet_count, "rtcp_octet_count"); } static switch_bool_t true_enough(cJSON *json) { if (json && (json->type == cJSON_True || json->valueint || json->valuedouble || json->valuestring)) { return SWITCH_TRUE; } return SWITCH_FALSE; } SWITCH_STANDARD_JSON_API(json_stats_function) { cJSON *reply, *data = cJSON_GetObjectItem(json, "data"); switch_status_t status = SWITCH_STATUS_FALSE; const char *uuid = cJSON_GetObjectCstr(data, "uuid"); cJSON *cdata = cJSON_GetObjectItem(data, "channelData"); switch_core_session_t *tsession; reply = cJSON_CreateObject(); *json_reply = reply; if (zstr(uuid)) { cJSON_AddItemToObject(reply, "response", cJSON_CreateString("INVALID INPUT")); goto end; } if ((tsession = switch_core_session_locate(uuid))) { cJSON *jevent; switch_rtp_stats_t *audio_stats = NULL, *video_stats = NULL; switch_core_media_set_stats(tsession); audio_stats = switch_core_media_get_stats(tsession, SWITCH_MEDIA_TYPE_AUDIO, switch_core_session_get_pool(tsession)); video_stats = switch_core_media_get_stats(tsession, SWITCH_MEDIA_TYPE_VIDEO, switch_core_session_get_pool(tsession)); if (audio_stats) { jsonify_stats(reply, "audio", audio_stats); } if (video_stats) { jsonify_stats(reply, "video", video_stats); } if (true_enough(cdata) && switch_ivr_generate_json_cdr(tsession, &jevent, SWITCH_FALSE) == SWITCH_STATUS_SUCCESS) { cJSON_AddItemToObject(reply, "channelData", jevent); } switch_core_session_rwunlock(tsession); status = SWITCH_STATUS_SUCCESS; } else { cJSON_AddItemToObject(reply, "response", cJSON_CreateString("Session does not exist")); goto end; } end: return status; } #define UUID_RECOVERY_REFRESH_SYNTAX " " SWITCH_STANDARD_API(uuid_recovery_refresh) { switch_core_session_t *tsession = NULL; char *uuid = NULL, *text = NULL; if (!zstr(cmd) && (uuid = strdup(cmd))) { if ((text = strchr(uuid, ' '))) { *text++ = '\0'; } } if (zstr(uuid) || zstr(text)) { stream->write_function(stream, "-USAGE: %s\n", UUID_RECOVERY_REFRESH_SYNTAX); } else { if ((tsession = switch_core_session_locate(uuid))) { switch_core_session_message_t msg = { 0 }; /* Tell the channel to recovery_refresh the call */ msg.from = __FILE__; msg.string_arg = text; msg.message_id = SWITCH_MESSAGE_INDICATE_RECOVERY_REFRESH; switch_core_session_receive_message(tsession, &msg); stream->write_function(stream, "+OK:%s\n", msg.string_reply); switch_core_session_rwunlock(tsession); } else { stream->write_function(stream, "-ERR No such channel %s!\n", uuid); } } switch_safe_free(uuid); return SWITCH_STATUS_SUCCESS; } #define SCHED_TRANSFER_SYNTAX "[+]