** **
\*****************************************************************************/
-#include <stdio.h>
-#include <string.h>
-#include <stdlib.h>
-#include <unistd.h>
-#include <poll.h>
#include "main.h"
-#include "linux/isdnif.h"
extern char **environ;
-/* create caller id from digits by comparing with national and international
- * prefixes.
- */
-char *nationalize_callerinfo(char *string, int *ntype)
-{
- if (!strncmp(options.international, string, strlen(options.international)))
- {
- *ntype = INFO_NTYPE_INTERNATIONAL;
- return(string+strlen(options.international));
- }
- if (!strncmp(options.national, string, strlen(options.national)))
- {
- *ntype = INFO_NTYPE_NATIONAL;
- return(string+strlen(options.national));
- }
- *ntype = INFO_NTYPE_SUBSCRIBER;
- return(string);
-}
-
-/* create number (including access codes) from caller id
- * prefixes.
- */
-char *numberrize_callerinfo(char *string, int ntype)
-{
- static char result[256];
-
- switch(ntype)
- {
- case INFO_NTYPE_INTERNATIONAL:
- UCPY(result, options.international);
- SCAT(result, string);
- return(result);
- break;
-
- case INFO_NTYPE_NATIONAL:
- UCPY(result, options.national);
- SCAT(result, string);
- return(result);
- break;
-
- default:
- return(string);
- }
-}
-
-
/*
* process init 'internal' / 'external' / 'remote' / 'vbox-record' / 'partyline'...
*/
-void EndpointAppPBX::_action_init_call(char *remote)
+int EndpointAppPBX::_action_init_call(char *remote)
{
class Join *join;
struct port_list *portlist = ea_endpoint->ep_portlist;
struct admin_list *admin;
/* a created call, this should never happen */
- if (ea_endpoint->ep_join_id)
- {
+ if (ea_endpoint->ep_join_id) {
if (options.deb & DEBUG_EPOINT)
PERROR("EPOINT(%d): We already have a call instance, this should never happen!\n", ea_endpoint->ep_serial);
- return;
+ return(0);
}
/* create join */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial);
- if (remote)
- {
+ if (remote) {
admin = admin_first;
- while(admin)
- {
+ while(admin) {
if (admin->remote_name[0] && !strcmp(admin->remote_name, remote))
break;
admin = admin->next;
}
- if (!admin)
- {
+ if (!admin) {
/* resource not available */
trace_header("ACTION remote (not available)", DIRECTION_NONE);
add_trace("application", NULL, "%s", remote);
end_trace();
- message_disconnect_port(portlist, CAUSE_RESSOURCEUNAVAIL, LOCATION_PRIVATE_LOCAL, "");
+ message_disconnect_port(portlist, CAUSE_OUTOFORDER, LOCATION_PRIVATE_LOCAL, "");
new_state(EPOINT_STATE_OUT_DISCONNECT);
- set_tone(portlist,"cause_22");
- return;
+ set_tone(portlist,"cause_1b");
+ return(0);
}
join = new JoinRemote(ea_endpoint->ep_serial, remote, admin->sock);
}
if (!join)
FATAL("No memoy for Join instance.\n");
ea_endpoint->ep_join_id = join->j_serial;
+ return(1);
}
void EndpointAppPBX::action_init_call(void)
{
}
void EndpointAppPBX::action_init_remote(void)
{
- struct route_param *rparam;
- struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
- struct capa_info capainfo;
- struct caller_info callerinfo;
- struct redir_info redirinfo;
- struct dialing_info dialinginfo;
- char remote[32];
-
- if (!(rparam = routeparam(e_action, PARAM_APPLICATION)))
- {
- trace_header("ACTION remote (no application given)", DIRECTION_NONE);
- end_trace();
- new_state(EPOINT_STATE_OUT_DISCONNECT);
- message_disconnect_port(portlist, CAUSE_SERVICEUNAVAIL, LOCATION_PRIVATE_LOCAL, "");
- set_tone(portlist, "cause_3f");
- return;
- }
- SCPY(remote, rparam->string_value);
- _action_init_call(remote);
-
- /* create bearer/caller/dialinginfo */
- memcpy(&capainfo, &e_capainfo, sizeof(capainfo));
- memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo));
- memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
- memset(&dialinginfo, 0, sizeof(dialinginfo));
-
- /* send setup to remote */
- trace_header("ACTION remote (setup)", DIRECTION_NONE);
- add_trace("number", NULL, dialinginfo.id);
- add_trace("remote", NULL, remote);
- end_trace();
- message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_SETUP);
- memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info));
- memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info));
- memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info));
- memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
- message_put(message);
}
/*
struct redir_info redirinfo;
struct dialing_info dialinginfo;
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct extension ext;
struct route_param *rparam;
dialinginfo.ntype = rparam->integer_value;
/* process service */
- if ((rparam = routeparam(e_action, PARAM_CAPA)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAPA))) {
capainfo.bearer_capa = rparam->integer_value;
if (capainfo.bearer_capa != INFO_BC_SPEECH
- && capainfo.bearer_capa != INFO_BC_AUDIO)
- {
+ && capainfo.bearer_capa != INFO_BC_AUDIO) {
capainfo.bearer_mode = INFO_BMODE_PACKET;
}
capainfo.bearer_info1 = INFO_INFO1_NONE;
}
- if ((rparam = routeparam(e_action, PARAM_BMODE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_BMODE))) {
capainfo.bearer_mode = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_INFO1)))
- {
+ if ((rparam = routeparam(e_action, PARAM_INFO1))) {
capainfo.bearer_info1 = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_HLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_HLC))) {
capainfo.hlc = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_EXTHLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTHLC))) {
capainfo.exthlc = rparam->integer_value;
}
/* process presentation */
- if ((rparam = routeparam(e_action, PARAM_PRESENT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PRESENT))) {
callerinfo.present = (rparam->integer_value)?INFO_PRESENT_ALLOWED:INFO_PRESENT_RESTRICTED;
}
/* check if extension exists AND only if not multiple extensions */
- if (!read_extension(&ext, dialinginfo.id) && !strchr(dialinginfo.id,','))
- {
+ if (!strchr(dialinginfo.id,',') && !read_extension(&ext, dialinginfo.id)) {
trace_header("ACTION extension (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, dialinginfo.id);
end_trace();
return;
}
/* check if internal calls are denied */
- if (e_ext.rights < 1)
- {
+ if (e_ext.rights < 1) {
trace_header("ACTION extension (dialing to extension denied)", DIRECTION_NONE);
add_trace("extension", NULL, dialinginfo.id);
end_trace();
struct dialing_info dialinginfo;
char *p;
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct route_param *rparam;
/* special processing of delete characters '*' and '#' */
- if (e_ext.delete_ext)
- {
+ if (e_ext.delete_ext) {
/* dialing a # causes a clearing of complete number */
- if (strchr(e_extdialing, '#'))
- {
+ if (strchr(e_extdialing, '#')) {
e_extdialing[0] = '\0';
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): '#' detected: terminal '%s' selected caller id '%s' and continues dialing: '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_callerinfo.id, e_extdialing);
}
/* eliminate digits before '*', which is a delete digit
*/
- if (strchr(e_extdialing, '*'))
- {
+ if (strchr(e_extdialing, '*')) {
/* remove digits */
- while((p=strchr(e_extdialing, '*')))
- {
- if (p > e_extdialing) /* only if there is a digit in front */
- {
+ while((p=strchr(e_extdialing, '*'))) {
+ if (p > e_extdialing) { /* only if there is a digit in front */
UCPY(p-1, p);
p--;
}
if ((rparam = routeparam(e_action, PARAM_PREFIX)))
SPRINT(dialinginfo.id, "%s%s", rparam->string_value, e_extdialing);
+ /* process keypad */
+ if ((rparam = routeparam(e_action, PARAM_KEYPAD))) {
+ SCPY(dialinginfo.keypad, dialinginfo.id);
+ dialinginfo.id[0] = '\0';
+ }
+
/* process number complete */
if ((rparam = routeparam(e_action, PARAM_COMPLETE)))
if ((rparam = routeparam(e_action, PARAM_PREFIX)))
dialinginfo.ntype = rparam->integer_value;
/* process service */
- if ((rparam = routeparam(e_action, PARAM_CAPA)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAPA))) {
capainfo.bearer_capa = rparam->integer_value;
if (capainfo.bearer_capa != INFO_BC_SPEECH
- && capainfo.bearer_capa != INFO_BC_AUDIO)
- {
+ && capainfo.bearer_capa != INFO_BC_AUDIO) {
capainfo.bearer_mode = INFO_BMODE_PACKET;
}
capainfo.bearer_info1 = INFO_INFO1_NONE;
}
- if ((rparam = routeparam(e_action, PARAM_BMODE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_BMODE))) {
capainfo.bearer_mode = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_INFO1)))
- {
+ if ((rparam = routeparam(e_action, PARAM_INFO1))) {
capainfo.bearer_info1 = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_HLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_HLC))) {
capainfo.hlc = rparam->integer_value;
}
- if ((rparam = routeparam(e_action, PARAM_EXTHLC)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTHLC))) {
capainfo.exthlc = rparam->integer_value;
}
/* process callerid */
- if ((rparam = routeparam(e_action, PARAM_CALLERID)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERID))) {
SCPY(callerinfo.id, rparam->string_value);
}
- if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE))) {
callerinfo.ntype = rparam->integer_value;
}
/* process presentation */
- if ((rparam = routeparam(e_action, PARAM_PRESENT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PRESENT))) {
callerinfo.present = (rparam->integer_value)?INFO_PRESENT_ALLOWED:INFO_PRESENT_RESTRICTED;
}
SCPY(dialinginfo.interfaces, rparam->string_value);
/* check if local calls are denied */
- if (e_ext.rights < 2)
- {
+ if (e_ext.rights < 2) {
trace_header("ACTION extern (calling denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
if (!strncmp(dialinginfo.id, options.national, strlen(options.national))
|| dialinginfo.ntype == INFO_NTYPE_NATIONAL
- || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL)
- {
+ || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL) {
/* check if national calls are denied */
- if (e_ext.rights < 3)
- {
+ if (e_ext.rights < 3) {
trace_header("ACTION extern (national calls denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
}
if (!strncmp(dialinginfo.id, options.international, strlen(options.international))
- || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL)
- {
+ || dialinginfo.ntype == INFO_NTYPE_INTERNATIONAL) {
/* check if international calls are denied */
- if (e_ext.rights < 4)
- {
+ if (e_ext.rights < 4) {
trace_header("ACTION extern (international calls denied)", DIRECTION_NONE);
end_trace();
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_REJECTED, 0, 0);
void EndpointAppPBX::action_dialing_remote(void)
{
- struct message *message;
- struct dialing_info dialinginfo;
-// struct route_param *rparam;
+ struct route_param *rparam;
+ struct port_list *portlist = ea_endpoint->ep_portlist;
+ struct lcr_msg *message;
+ struct capa_info capainfo;
+ struct caller_info callerinfo;
+ struct redir_info redirinfo;
+ struct dialing_info dialinginfo;
+ char context[128] = "";
+ char remote[32];
- /* create bearer/caller/dialinginfo */
- memset(&dialinginfo, 0, sizeof(dialinginfo));
+ if (!ea_endpoint->ep_join_id) {
+ /* no join yet, sending setup */
+ if (!(rparam = routeparam(e_action, PARAM_APPLICATION))) {
+ trace_header("ACTION remote (no application given)", DIRECTION_NONE);
+ end_trace();
+ new_state(EPOINT_STATE_OUT_DISCONNECT);
+ message_disconnect_port(portlist, CAUSE_SERVICEUNAVAIL, LOCATION_PRIVATE_LOCAL, "");
+ set_tone(portlist, "cause_3f");
+ return;
+ }
+ SCPY(remote, rparam->string_value);
+ if (!_action_init_call(remote))
+ return;
- if (dialinginfo.id[0])
- {
- /* add or update outgoing call */
- trace_header("ACTION remote (dialing)", DIRECTION_NONE);
+ /* create bearer/caller/dialinginfo */
+ memcpy(&capainfo, &e_capainfo, sizeof(capainfo));
+ memcpy(&callerinfo, &e_callerinfo, sizeof(callerinfo));
+ memcpy(&redirinfo, &e_redirinfo, sizeof(redirinfo));
+ memset(&dialinginfo, 0, sizeof(dialinginfo));
+
+ if ((rparam = routeparam(e_action, PARAM_CONTEXT))) {
+ SCPY(context, rparam->string_value);
+ }
+ if ((rparam = routeparam(e_action, PARAM_EXTEN))) {
+ SCPY(dialinginfo.id, rparam->string_value);
+ dialinginfo.ntype = INFO_NTYPE_UNKNOWN;
+ } else {
+ SCPY(dialinginfo.id, e_extdialing);
+ }
+ e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id);
+ /* send setup to remote */
+ trace_header("ACTION remote (setup)", DIRECTION_NONE);
add_trace("number", NULL, dialinginfo.id);
+ add_trace("remote", NULL, remote);
+ if (context[0])
+ add_trace("context", NULL, context);
end_trace();
- message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_INFORMATION);
- memcpy(&message->param.information, &dialinginfo, sizeof(struct dialing_info));
+ message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_SETUP);
+ memcpy(&message->param.setup.dialinginfo, &dialinginfo, sizeof(struct dialing_info));
+ memcpy(&message->param.setup.redirinfo, &redirinfo, sizeof(struct redir_info));
+ memcpy(&message->param.setup.callerinfo, &callerinfo, sizeof(struct caller_info));
+ memcpy(&message->param.setup.capainfo, &capainfo, sizeof(struct capa_info));
+ SCPY(message->param.setup.context, context);
message_put(message);
+ } else {
+ /* send overlap digits */
+ trace_header("ACTION remote (dialing)", DIRECTION_NONE);
+ add_trace("number", NULL, e_extdialing);
+ end_trace();
+ if (e_extdialing[0]) {
+ message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_join_id, EPOINT_TO_JOIN, MESSAGE_INFORMATION);
+ memcpy(&message->param.information, &e_dialinginfo, sizeof(struct dialing_info));
+ SCPY(message->param.information.id, e_extdialing);
+ e_extdialing = e_dialinginfo.id + strlen(e_dialinginfo.id);
+ message_put(message);
+ }
}
}
{
struct dialing_info dialinginfo;
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct extension ext;
struct route_param *rparam;
portlist = ea_endpoint->ep_portlist;
/* check for given extension */
- if (!(rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_EXTENSION))) {
trace_header("ACTION vbox-record (no extension given by parameter)", DIRECTION_NONE);
end_trace();
}
/* check if extension exists */
- if (!read_extension(&ext, rparam->string_value))
- {
+ if (!read_extension(&ext, rparam->string_value)) {
trace_header("ACTION vbox-record (given extension does not exists)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", rparam->string_value);
end_trace();
}
/* check if internal calls are denied */
- if (e_ext.rights < 1)
- {
+ if (e_ext.rights < 1) {
trace_header("ACTION vbox-record (internal calls are denied)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
/* append special announcement (if given) */
if ((rparam = routeparam(e_action, PARAM_ANNOUNCEMENT)))
- if (rparam->string_value[0])
- {
+ if (rparam->string_value[0]) {
SCAT(dialinginfo.id, ",");
SCAT(dialinginfo.id, rparam->string_value);
}
class Join *join;
class JoinPBX *joinpbx;
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct route_param *rparam;
int partyline, jingle = 0;
struct join_relation *relation;
portlist = ea_endpoint->ep_portlist;
/* check for given extension */
- if (!(rparam = routeparam(e_action, PARAM_ROOM)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_ROOM))) {
trace_header("ACTION partyline (no room parameter)", DIRECTION_NONE);
end_trace();
noroom:
set_tone(portlist, "cause_3f");
return;
}
- if (rparam->integer_value <= 0)
- {
+ if (rparam->integer_value <= 0) {
trace_header("ACTION partyline (illegal room parameter)", DIRECTION_NONE);
add_trace("room", NULL, "%d", rparam->integer_value);
end_trace();
/* don't create join if partyline exists */
join = join_first;
- while(join)
- {
- if (join->j_type == JOIN_TYPE_PBX)
- {
+ while(join) {
+ if (join->j_type == JOIN_TYPE_PBX) {
joinpbx = (class JoinPBX *)join;
if (joinpbx->j_partyline == partyline)
break;
}
join = join->next;
}
- if (!join)
- {
+ if (!join) {
/* create join */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): Creating new join instance.\n", ea_endpoint->ep_serial);
if (!(join = new JoinPBX(ea_endpoint)))
FATAL("No memory for join object\n");
- } else
- {
+ } else {
//NOTE: joinpbx must be set here
/* add relation to existing join */
if (!(relation=joinpbx->add_relation()))
FATAL("No memory for join relation\n");
relation->type = RELATION_TYPE_SETUP;
- relation->channel_state = CHANNEL_STATE_CONNECT;
+ relation->channel_state = 1;
relation->rx_state = NOTIFY_STATE_ACTIVE;
relation->tx_state = NOTIFY_STATE_ACTIVE;
relation->epoint_id = ea_endpoint->ep_serial;
void EndpointAppPBX::action_dialing_login(void)
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
char *extension;
struct route_param *rparam;
/* extension parameter */
- if ((rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if ((rparam = routeparam(e_action, PARAM_EXTENSION))) {
/* extension is given by parameter */
extension = rparam->string_value;
if (extension[0] == '\0')
return;
- if (!read_extension(&e_ext, extension))
- {
+ if (!read_extension(&e_ext, extension)) {
trace_header("ACTION login (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", extension);
end_trace();
set_tone(portlist, "cause_86");
return;
}
- } else
- {
+ } else {
/* extension must be given by dialstring */
extension = e_extdialing;
if (extension[0] == '\0')
return;
- if (!read_extension(&e_ext, extension))
- {
+ if (!read_extension(&e_ext, extension)) {
trace_header("ACTION login (extension incomplete or does not exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", extension);
end_trace();
message->param.connectinfo.present = INFO_PRESENT_RESTRICTED;
else message->param.connectinfo.present = e_ext.callerid_present;
/* handle restricted caller ids */
- apply_callerid_restriction(e_ext.anon_ignore, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name);
+ apply_callerid_restriction(&e_ext, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name);
/* display callerid if desired for extension */
SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name));
message->param.connectinfo.ntype = e_ext.callerid_type;
e_connectedmode = 1;
e_dtmf = 1;
- if (!(rparam = routeparam(e_action, PARAM_NOPASSWORD)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_NOPASSWORD))) {
/* make call state to enter password */
trace_header("ACTION login (ask for password)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_ext.number);
/* do dialing */
process_dialing();
- } else
- {
+ } else {
/* make call state */
new_state(EPOINT_STATE_IN_OVERLAP);
e_ruleset = ruleset_main;
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- if (!e_ext.change_callerid)
- {
+ if (!e_ext.change_callerid) {
/* service not available */
trace_header("ACTION change-callerid (denied for this caller)", DIRECTION_NONE);
end_trace();
char old_id[64] = "", new_id[64] = "";
int old_type=0, new_type=0, old_present=0, new_present=0;
- if ((rparam = routeparam(e_action, PARAM_CALLERID)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CALLERID))) {
/* the caller ID is given by parameter */
callerid = rparam->string_value;
- } else
- {
+ } else {
/* caller ID is dialed */
- if (!strchr(e_extdialing, '#'))
- {
+ if (!strchr(e_extdialing, '#')) {
/* no complete ID yet */
return;
}
/* given callerid type */
if ((rparam = routeparam(e_action, PARAM_CALLERIDTYPE)))
- switch(rparam->integer_value)
- {
+ switch(rparam->integer_value) {
case INFO_NTYPE_SUBSCRIBER:
SPRINT(buffer, "s%s", callerid);
callerid = buffer;
/* caller id complete, dialing with new caller id */
/* write new parameters */
- if (read_extension(&e_ext, e_ext.number))
- {
+ if (read_extension(&e_ext, e_ext.number)) {
old_present = (!next)?e_ext.callerid_present:e_ext.id_next_call_present;
old_type = (!next)?e_ext.callerid_type:e_ext.id_next_call_type;
SCPY(old_id, (!next)?e_ext.callerid:e_ext.id_next_call);
- if (callerid[0] == '\0')
- {
+ if (callerid[0] == '\0') {
/* no caller id */
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_RESTRICTED;
- } else
- {
+ } else {
/* new caller id */
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_ALLOWED;
if ((rparam = routeparam(e_action, PARAM_PRESENT))) if (rparam->integer_value == 0)
(!next)?e_ext.callerid_present:e_ext.id_next_call_present = INFO_PRESENT_RESTRICTED;
- if (e_ext.callerid_type == INFO_NTYPE_UNKNOWN) /* if callerid is unknown, the given id is not nationalized */
- {
+ if (e_ext.callerid_type == INFO_NTYPE_UNKNOWN) /* if callerid is unknown, the given id is not nationalized */ {
SCPY((!next)?e_ext.callerid:e_ext.id_next_call, callerid);
(!next)?e_ext.callerid_type:e_ext.id_next_call_type = INFO_NTYPE_UNKNOWN;
- } else
- {
- SCPY((!next)?e_ext.callerid:e_ext.id_next_call, nationalize_callerinfo(callerid,&((!next)?e_ext.callerid_type:e_ext.id_next_call_type)));
+ } else {
+ SCPY((!next)?e_ext.callerid:e_ext.id_next_call, nationalize_callerinfo(callerid,&((!next)?e_ext.callerid_type:e_ext.id_next_call_type), options.national, options.international));
}
if (!next) e_ext.id_next_call_type = -1;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): nationalized callerid: '%s' type=%d\n", ea_endpoint->ep_serial, (!next)?e_ext.callerid:e_ext.id_next_call, (!next)?e_ext.callerid_type:e_ext.id_next_call_type);
trace_header("ACTION change-callerid (only next call)", DIRECTION_NONE);
else
trace_header("ACTION change-callerid (all future calls)", DIRECTION_NONE);
- add_trace("old", "caller id", "%s", numberrize_callerinfo(old_id, old_type));
+ add_trace("old", "caller id", "%s", numberrize_callerinfo(old_id, old_type, options.national, options.international));
add_trace("old", "present", "%s", (old_present==INFO_PRESENT_RESTRICTED)?"restricted":"allowed");
- add_trace("new", "caller id", "%s", numberrize_callerinfo(new_id, new_type));
+ add_trace("new", "caller id", "%s", numberrize_callerinfo(new_id, new_type, options.national, options.international));
add_trace("new", "present", "%s", (new_present==INFO_PRESENT_RESTRICTED)?"restricted":"allowed");
end_trace();
message_disconnect_port(portlist, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, "");
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- if (!e_ext.change_forward)
- {
+ if (!e_ext.change_forward) {
trace_header("ACTION change-forward (denied for this caller)", DIRECTION_NONE);
end_trace();
/* service not available */
if ((rparam = routeparam(e_action, PARAM_DIVERSION)))
diversion = rparam->integer_value;
- if ((rparam = routeparam(e_action, PARAM_DEST)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DEST))) {
/* if destination is given */
dest = rparam->string_value;
- } else
- {
+ } else {
if (!strchr(e_extdialing, '#'))
return;
*strchr(e_extdialing, '#') = '\0';
}
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: storing forwarding to '%s'.\n", ea_endpoint->ep_serial, e_ext.number, dest);
- if (read_extension(&e_ext, e_ext.number))
- {
- switch(diversion)
- {
+ if (read_extension(&e_ext, e_ext.number)) {
+ switch(diversion) {
case INFO_DIVERSION_CFU:
trace_header("ACTION change-forward (new CFU=unconditional)", DIRECTION_NONE);
add_trace("destin'", NULL, "%s", dest);
struct port_list *portlist = ea_endpoint->ep_portlist;
e_select = 0;
- if (!e_ext.last_out[0])
- {
+ if (!e_ext.last_out[0]) {
trace_header("ACTION redial/reply (no last number stored)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
*/
void EndpointAppPBX::_action_redial_reply(int in)
{
- struct message *message;
+ struct lcr_msg *message;
char *last;
struct route_param *rparam;
goto nodisplay;
/* scroll menu */
- if (e_extdialing[0]=='*' || e_extdialing[0]=='1')
- {
+ if (e_extdialing[0]=='*' || e_extdialing[0]=='1') {
/* find prev entry */
e_select--;
if (e_select < 0)
e_select = 0;
}
- if (e_extdialing[0]=='#' || e_extdialing[0]=='3')
- {
+ if (e_extdialing[0]=='#' || e_extdialing[0]=='3') {
/* find next entry */
e_select++;
- if (e_select >= MAX_REMEMBER)
+ if (e_select >= MAX_REMEMBER) {
e_select--;
- else if (in)
+ } else if (in) {
if (e_ext.last_in[e_select][0] == '\0')
e_select--;
- else
+ } else
if (e_ext.last_out[e_select][0] == '\0')
e_select--;
}
last = (in)?e_ext.last_in[e_select]:e_ext.last_out[e_select];
- if (e_extdialing[0]=='0' || e_extdialing[0]=='2')
- {
+ if (e_extdialing[0]=='0' || e_extdialing[0]=='2') {
nodisplay:
if (in)
trace_header("ACTION reply (dialing)", DIRECTION_NONE);
void EndpointAppPBX::action_dialing_powerdial(void)
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct route_param *rparam;
/* power dialing only possible if we have a last dialed number */
- if (!e_ext.last_out[0])
- {
+ if (!e_ext.last_out[0]) {
trace_header("ACTION powerdial (no last number stored)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
}
/* limit */
- if ((rparam = routeparam(e_action, PARAM_LIMIT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_LIMIT))) {
e_powerlimit = rparam->integer_value;
- } else
- {
+ } else {
e_powerlimit = 0;
}
/* delay */
- if ((rparam = routeparam(e_action, PARAM_DELAY)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DELAY))) {
e_powerdelay = rparam->integer_value;
- } else
- {
+ } else {
/* delay incomplete */
if (!strchr(e_extdialing, '#'))
return;
portlist = ea_endpoint->ep_portlist;
/* check given extension */
- if (!(rparam = routeparam(e_action, PARAM_EXTENSION)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_EXTENSION))) {
noextension:
trace_header("ACTION callback (no extension defined)", DIRECTION_NONE);
end_trace();
/* read callback extension */
memset(&cbext, 0, sizeof(cbext));
- if (!read_extension(&cbext, e_cbcaller))
- {
+ if (!read_extension(&cbext, e_cbcaller)) {
trace_header("ACTION callback (extension doesn't exist)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
}
/* if password is not given */
- if (cbext.password[0] == '\0')
- {
+ if (cbext.password[0] == '\0') {
trace_header("ACTION callback (no password set)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
/* callback only possible if callerid exists OR it is given */
if ((rparam = routeparam(e_action, PARAM_CALLTO)))
SCPY(e_cbto, rparam->string_value);
- if (e_cbto[0])
- {
+ if (e_cbto[0]) {
trace_header("ACTION callback (alternative caller id)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
add_trace("callerid", NULL, "%s", e_cbto);
e_callerinfo.ntype = INFO_NTYPE_UNKNOWN;
e_callerinfo.present = INFO_PRESENT_ALLOWED;
}
- if (e_callerinfo.id[0]=='\0' || e_callerinfo.present==INFO_PRESENT_NOTAVAIL)
- {
+ if (e_callerinfo.id[0]=='\0' || e_callerinfo.present==INFO_PRESENT_NOTAVAIL) {
trace_header("ACTION callback (no caller ID available)", DIRECTION_NONE);
add_trace("extension", NULL, "%s", e_cbcaller);
end_trace();
portlist = ea_endpoint->ep_portlist;
/* abbrev dialing is only possible if we have a caller defined */
- if (!e_ext.number[0])
- {
+ if (!e_ext.number[0]) {
trace_header("ACTION abbreviation (only for extension)", DIRECTION_NONE);
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
phone = NULL;
name = NULL;
result = parse_phonebook(e_ext.number, &abbrev, &phone, &name);
- if (result == 0)
- {
+ if (result == 0) {
trace_header("ACTION abbreviation (not found)", DIRECTION_NONE);
add_trace("abbrev", NULL, "%s", abbrev);
end_trace();
set_tone(portlist, "cause_01");
return;
}
- if (result == -1) /* may match if more digits are dialed */
- {
+ if (result == -1) { /* may match if more digits are dialed */
return;
}
unsigned int cause;
char causestr[16];
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
class Port *port;
char testcode[32] = "";
struct route_param *rparam;
SCPY(testcode, rparam->string_value);
SCAT(testcode, e_extdialing);
- switch(testcode[0])
- {
+ switch(testcode[0]) {
case '1':
trace_header("ACTION test", DIRECTION_NONE);
add_trace("test", NULL, "proceeding");
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_CONNECT);
memcpy(&message->param.connectinfo, &e_connectinfo, sizeof(struct connect_info));
/* handle restricted caller ids */
- apply_callerid_restriction(e_ext.anon_ignore, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name);
+ apply_callerid_restriction(&e_ext, message->param.connectinfo.id, &message->param.connectinfo.ntype, &message->param.connectinfo.present, &message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name);
/* display callerid if desired for extension */
SCPY(message->param.connectinfo.display, apply_callerid_display(message->param.connectinfo.id, message->param.connectinfo.itype, message->param.connectinfo.ntype, message->param.connectinfo.present, message->param.connectinfo.screen, message->param.connectinfo.extension, message->param.connectinfo.name));
message_put(message);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
port = find_port_id(portlist->port_id);
- if (port)
- {
+ if (port) {
port->set_echotest(1);
}
break;
struct port_list *portlist = ea_endpoint->ep_portlist;
/* check given sample */
- if (!(rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_SAMPLE))) {
trace_header("ACTION play (no sample given)", DIRECTION_NONE);
end_trace();
}
/* if sample is given */
- if (rparam->string_value[0] == '\0')
- {
+ if (rparam->string_value[0] == '\0') {
trace_header("ACTION play (no sample given)", DIRECTION_NONE);
end_trace();
goto disconnect;
void EndpointAppPBX::action_dialing_calculator(void)
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
double value1, value2, v, sign1;
- int komma1, komma2, k, state, mode, first;
+ int komma1, komma2, k, state, mode = 0, first;
char *p;
portlist = ea_endpoint->ep_portlist;
/* remove error message */
- if (!strncmp(e_extdialing, "Error", 5))
- {
+ if (!strncmp(e_extdialing, "Error", 5)) {
UCPY(e_extdialing, e_extdialing+5);
}
- if (!strncmp(e_extdialing, "inf", 3))
- {
+ if (!strncmp(e_extdialing, "inf", 3)) {
UCPY(e_extdialing, e_extdialing+3);
}
- if (!strncmp(e_extdialing, "-inf", 4))
- {
+ if (!strncmp(e_extdialing, "-inf", 4)) {
UCPY(e_extdialing, e_extdialing+4);
}
if (!p)
return;
first = 1;
- while(*p)
- {
- if (*p>='0' && *p<='9')
- {
+ while(*p) {
+ if (*p>='0' && *p<='9') {
#if 0
- if (first)
- {
+ if (first) {
UCPY(p, p+1);
continue;
}
- if ((p[-1]<'0' || p[-1]>'0') && p[-1]!='.')
- {
+ if ((p[-1]<'0' || p[-1]>'0') && p[-1]!='.') {
p--;
UCPY(p, p+1);
continue;
}
#endif
- switch(state)
- {
+ switch(state) {
case 0: /* first number */
- if (!komma1)
- {
+ if (!komma1) {
value1 = value1*10 + (*p-'0');
- } else
- {
+ } else {
k = komma1++;
v = *p-'0';
while(k--)
}
break;
case 1: /* second number */
- if (!komma2)
- {
+ if (!komma2) {
value2 = value2*10 + (*p-'0');
- } else
- {
+ } else {
k = komma2++;
v = *p-'0';
while(k--)
break;
}
} else
- switch(*p)
- {
+ switch(*p) {
case '*':
- if (first)
- {
+ if (first) {
UCPY(e_extdialing, "Error");
goto done;
}
/* if there is a multiplication, we change to / */
- if (p[-1] == '*')
- {
+ if (p[-1] == '*') {
mode = 1;
p[-1] = '/';
UCPY(p, p+1);
break;
}
/* if there is a division, we change to + */
- if (p[-1] == '/')
- {
+ if (p[-1] == '/') {
mode = 2;
p[-1] = '+';
UCPY(p, p+1);
break;
}
/* if there is a addition, we change to - */
- if (p[-1] == '+')
- {
+ if (p[-1] == '+') {
mode = 3;
p[-1] = '-';
UCPY(p, p+1);
break;
}
/* if there is a substraction and a comma, we change to * */
- if (p[-1]=='-' && komma1)
- {
+ if (p[-1]=='-' && komma1) {
mode = 0;
p[-1] = '*';
UCPY(p, p+1);
break;
}
/* if there is a substraction and no comma and the first or second value, we change to , */
- if (p[-1]=='-')
- {
+ if (p[-1]=='-') {
p[-1] = '.';
UCPY(p, p+1);
p--;
break;
}
/* if there is a komma and we are at the first value, we change to * */
- if (p[-1]=='.' && state==0)
- {
+ if (p[-1]=='.' && state==0) {
mode = 0;
p[-1] = '*';
UCPY(p, p+1);
break;
}
/* if there is a komma and we are at the second value, we display error */
- if (komma2 && state==1)
- {
+ if (komma2 && state==1) {
UCPY(e_extdialing, "Error");
goto done;
}
/* if we are at state 1, we write a comma */
- if (state == 1)
- {
+ if (state == 1) {
*p = '.';
komma2 = 1;
break;
case '#':
/* if just a number is displayed, the input is cleared */
- if (state==0)
- {
+ if (state==0) {
*e_extdialing = '\0';
break;
}
/* calculate the result */
- switch(mode)
- {
+ switch(mode) {
case 0: /* multiply */
UNPRINT(e_extdialing, sizeof(e_dialinginfo.id)-strlen(e_dialinginfo.id), "%.8f", sign1*value1*value2);
break;
break;
}
e_dialinginfo.id[sizeof(e_dialinginfo.id)-1] = '\0';
- if (strchr(e_extdialing, '.')) /* remove zeroes */
- {
+ if (strchr(e_extdialing, '.')) { /* remove zeroes */
while (e_extdialing[strlen(e_extdialing)-1] == '0')
e_extdialing[strlen(e_extdialing)-1] = '\0';
if (e_extdialing[strlen(e_extdialing)-1] == '.')
break;
case '-':
- if (first)
- {
+ if (first) {
sign1=-1;
break;
}
struct route_param *rparam;
/* check given ruleset */
- if (!(rparam = routeparam(e_action, PARAM_RULESET)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_RULESET))) {
no_ruleset:
trace_header("ACTION goto/menu (no ruleset given)", DIRECTION_NONE);
end_trace();
if (rparam->string_value[0] == '\0')
goto no_ruleset;
e_ruleset = getrulesetbyname(rparam->string_value);
- if (!e_ruleset)
- {
+ if (!e_ruleset) {
trace_header("ACTION goto/menu (ruleset not found)", DIRECTION_NONE);
add_trace("ruleset", NULL, "%s", rparam->string_value);
end_trace();
}
/* if the 'menu' was selected, we will flush all digits */
- if (mode)
- {
+ if (mode) {
e_dialinginfo.id[0] = 0;
e_extdialing = e_dialinginfo.id;
- } else
- {
+ } else {
/* remove digits that are required to match the rule */
- if ((rparam = routeparam(e_action, PARAM_STRIP)))
- {
+ if ((rparam = routeparam(e_action, PARAM_STRIP))) {
if (e_extdialing)
SCPY(e_dialinginfo.id, e_extdialing);
e_extdialing = e_dialinginfo.id;
/* play sample */
trace_header("ACTION goto/menu (change to)", DIRECTION_NONE);
add_trace("ruleset", NULL, "%s", e_ruleset->name);
- if (e_dialinginfo.id[0])
+ if (e_dialinginfo.id[0]) {
add_trace("dialing", NULL, "%s", e_dialinginfo.id);
- if ((rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ }
+ if ((rparam = routeparam(e_action, PARAM_SAMPLE))) {
add_trace("sample", NULL, "%s", rparam->string_value);
+ end_trace();
set_tone(ea_endpoint->ep_portlist, rparam->string_value);
+ } else {
+ end_trace();
}
- end_trace();
/* do dialing with new ruleset */
e_action = NULL;
{
struct route_param *rparam;
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
int cause = CAUSE_NORMAL; /* normal call clearing */
int location = LOCATION_PRIVATE_LOCAL;
char cause_string[256] = "", display[84] = "";
/* check cause parameter */
- if ((rparam = routeparam(e_action, PARAM_CAUSE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CAUSE))) {
cause = rparam->integer_value;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'cause' is given: %d\n", ea_endpoint->ep_serial, cause);
}
- if ((rparam = routeparam(e_action, PARAM_LOCATION)))
- {
+ if ((rparam = routeparam(e_action, PARAM_LOCATION))) {
location = rparam->integer_value;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'location' is given: %d\n", ea_endpoint->ep_serial, location);
}
SPRINT(cause_string, "cause_%02x", cause);
/* check sample parameter */
- if ((rparam = routeparam(e_action, PARAM_SAMPLE)))
- {
+ if ((rparam = routeparam(e_action, PARAM_SAMPLE))) {
SCPY(cause_string, rparam->string_value);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'sample' is given: %s\n", ea_endpoint->ep_serial, cause_string);
}
/* check display */
- if ((rparam = routeparam(e_action, PARAM_DISPLAY)))
- {
+ if ((rparam = routeparam(e_action, PARAM_DISPLAY))) {
SCPY(display, rparam->string_value);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): 'display' is given: %s\n", ea_endpoint->ep_serial, display);
}
end_trace();
new_state(EPOINT_STATE_OUT_DISCONNECT);
set_tone(portlist, cause_string);
- if (!(rparam = routeparam(e_action, PARAM_CONNECT)))
- {
+ if (!(rparam = routeparam(e_action, PARAM_CONNECT))) {
message_disconnect_port(portlist, cause, location, display);
- } else
- {
+ } else {
message = message_create(ea_endpoint->ep_serial, ea_endpoint->ep_portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
SCPY(message->param.notifyinfo.display, display);
message_put(message);
struct numbering *numbering = numbering_int;
char dialing[sizeof(e_dialinginfo.id)];
int i;
- struct message *message;
+ struct lcr_msg *message;
struct route_param *rparam;
/* in case we have no menu (this should never happen) */
return;
/* scroll menu */
- if (strchr(e_dialinginfo.id,'*'))
- {
+ if (strchr(e_dialinginfo.id,'*')) {
e_menu--;
e_dialinginfo.id[0] = '\0';
}
- if (strchr(e_dialinginfo.id,'#'))
- {
+ if (strchr(e_dialinginfo.id,'#')) {
e_menu++;
e_dialinginfo.id[0] = '\0';
}
/* get position in menu */
- if (e_menu < 0)
- {
+ if (e_menu < 0) {
/* get last menu position */
e_menu = 0;
- while(numbering->next)
- {
+ while(numbering->next) {
e_menu++;
numbering = numbering->next;
}
- } else
- {
+ } else {
/* get menu position */
i = 0;
- while(i < e_menu)
- {
+ while(i < e_menu) {
numbering = numbering->next;
- if (!numbering)
- {
+ if (!numbering) {
e_menu = 0;
numbering = numbering_int;
break;
}
/* if we dial something else we need to add the prefix and change the action */
- if (e_dialinginfo.id[0])
- {
+ if (e_dialinginfo.id[0]) {
e_action = NUMB_ACTION_NONE;
SCPY(dialing, numbering->prefix);
//we ignore the first digit after selecting
{
}
+/*
+ * process init 'execute'
+ */
+void EndpointAppPBX::action_init_execute(void)
+{
+ struct route_param *rparam;
+ int executeon = INFO_ON_HANGUP; /* Use Hangup as a default for compatibility */
+
+ /* Get the execute on parameter */
+ if ((rparam = routeparam(e_action, PARAM_ON)))
+ executeon = rparam->integer_value;
+
+ /* Execute this action if init was specified */
+ if (executeon == INFO_ON_INIT) {
+ trace_header("ACTION execute ON init", DIRECTION_NONE);
+ end_trace();
+ action_execute();
+ }
+}
/*
* process hangup 'execute'
- */
+ */
void EndpointAppPBX::action_hangup_execute(void)
{
struct route_param *rparam;
- char *command = "", isdn_port[10];
- char *argv[7+1]; /* check also number of args below */
+ int executeon = INFO_ON_HANGUP; /* Use Hangup as a default for compatibility */
+
+ /* Get the execute on parameter */
+ if ((rparam = routeparam(e_action, PARAM_ON)))
+ executeon = rparam->integer_value;
+
+ /* Execute this action if init was specified */
+ if (executeon == INFO_ON_HANGUP) {
+ trace_header("ACTION execute ON hangup", DIRECTION_NONE);
+ end_trace();
+ action_execute();
+ }
+}
+
+/*
+ * process 'execute' from action_init_execute or action_hangup_execute
+ */
+void EndpointAppPBX::action_execute(void)
+{
+ struct route_param *rparam;
+ pid_t pid;
+ pid_t pid2;
+ int iWaitStatus;
+ char *command = (char *)"";
+ char isdn_port[10];
+ char *argv[11]; /* check also number of args below */
int i = 0;
/* get script / command */
if ((rparam = routeparam(e_action, PARAM_EXECUTE)))
command = rparam->string_value;
- if (command[0] == '\0')
- {
+ if (command[0] == '\0') {
trace_header("ACTION execute (no parameter given)", DIRECTION_NONE);
end_trace();
return;
}
- trace_header("ACTION execute", DIRECTION_NONE);
- add_trace("command", NULL, "%s", command);
- end_trace();
-
- argv[0] = command;
- while(strchr(argv[0], '/'))
- argv[0] = strchr(argv[0], '/')+1;
- if ((rparam = routeparam(e_action, PARAM_PARAM)))
- {
- argv[1] = rparam->string_value;
- i++;
- }
- argv[1+i] = e_extdialing;
- argv[2+i] = numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype);
- argv[3+i] = e_callerinfo.extension;
- argv[4+i] = e_callerinfo.name;
+ argv[i++] = (char *)"/bin/sh";
+ argv[i++] = (char *)"-c";
+ argv[i++] = command;
+ argv[i++] = command;
+ if ((rparam = routeparam(e_action, PARAM_PARAM))) {
+ argv[i++] = rparam->string_value;
+ }
+ argv[i++] = e_extdialing;
+ argv[i++] = (char *)numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international);
+ argv[i++] = e_callerinfo.extension;
+ argv[i++] = e_callerinfo.name;
SPRINT(isdn_port, "%d", e_callerinfo.isdn_port);
- argv[5+i] = isdn_port;
- argv[6+i] = NULL; /* check also number of args above */
- execve("/bin/sh", argv, environ);
+ argv[i++] = isdn_port;
+ argv[i++] = NULL; /* check also number of args above */
+ switch (pid = fork ()) {
+ case -1:
+ trace_header("ACTION execute (fork failed)", DIRECTION_NONE);
+ end_trace();
+ break;
+ case 0:
+ /* To be shure there are no zombies created double fork */
+ if ((pid2 = fork()) == 0) {
+ execve("/bin/sh", argv, environ);
+ }
+ else {
+ /* Exit immediately and release the waiting parent. The subprocess falls to init because the parent died */
+ exit(0);
+ }
+ break;
+ default:
+ trace_header("ACTION execute", DIRECTION_NONE);
+ add_trace("command", NULL, "%s", command);
+ end_trace();
+
+ /* Wait for the pid. The forked process will exit immediately so there is no problem waiting. */
+ waitpid(pid, &iWaitStatus, 0);
+ break;
+ }
}
void EndpointAppPBX::action_hangup_file(void)
{
struct route_param *rparam;
- char *file, *content, *mode;
+ const char *file, *content, *mode;
FILE *fp;
/* get file / content */
mode = "a";
else
mode = "w";
- if (file[0] == '\0')
- {
+ if (file[0] == '\0') {
trace_header("ACTION file (no filename given)", DIRECTION_NONE);
end_trace();
return;
}
- if (!(fp = fopen(file, mode)))
- {
+ if (!(fp = fopen(file, mode))) {
trace_header("ACTION file (failed to open)", DIRECTION_NONE);
add_trace("file", "name", "%s", file);
add_trace("file", "mode", "%s", (mode[0]=='w')?"write":"append");
struct port_list *portlist = ea_endpoint->ep_portlist;
/* prompt for password */
- if (e_extdialing[0] == '\0')
- {
+ if (e_extdialing[0] == '\0') {
/* give password tone */
set_tone(portlist, "password");
} else // ELSE!!
- if (e_extdialing[1] == '\0')
- {
+ if (e_extdialing[1] == '\0') {
/* give password tone */
set_tone(portlist, "dialing");
}
return; /* more digits needed */
/* check the password */
- if (e_ext.password[0]=='\0' || (strlen(e_ext.password)==strlen(e_extdialing) && !!strcmp(e_ext.password,e_extdialing)))
- {
+ if (e_ext.password[0]=='\0' || (strlen(e_ext.password)==strlen(e_extdialing) && !!strcmp(e_ext.password,e_extdialing))) {
trace_header("ACTION password_write (wrong password)", DIRECTION_NONE);
add_trace("dialed", NULL, "%s", e_extdialing);
end_trace();
/* write caller id if ACTION_PASSWORD_WRITE was selected */
if (e_action)
- if (e_action->index == ACTION_PASSWORD_WRITE)
- {
+ if (e_action->index == ACTION_PASSWORD_WRITE) {
append_callbackauth(e_ext.number, &e_callbackinfo);
trace_header("ACTION password_write (written)", DIRECTION_NONE);
add_trace("dialed", NULL, "%s", e_extdialing);
void EndpointAppPBX::process_dialing(void)
{
struct port_list *portlist = ea_endpoint->ep_portlist;
- struct message *message;
+ struct lcr_msg *message;
struct route_param *rparam;
//#warning Due to HANG-BUG somewhere here, I added some HANG-BUG-DEBUGGING output that cannot be disabled. after bug has been found, this will be removed.
//PDEBUG(~0, "HANG-BUG-DEBUGGING: entered porcess_dialing\n");
portlist = ea_endpoint->ep_portlist;
/* check if we have a port instance linked to our epoint */
- if (!portlist)
- {
+ if (!portlist) {
portlist_error:
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): note: dialing call requires exactly one port object to process dialing. this case could happen due to a parked call. we end dialing here.\n", ea_endpoint->ep_serial, e_ext.number);
e_action_timeout = 0;
e_match_timeout = 0;
return;
}
- if (portlist->next)
- {
+ if (portlist->next) {
goto portlist_error;
}
/* check nesting levels */
- if (++e_rule_nesting > RULE_NESTING)
- {
+ if (++e_rule_nesting > RULE_NESTING) {
trace_header("ACTION (nesting too deep)", DIRECTION_NONE);
add_trace("max-levels", NULL, "%d", RULE_NESTING);
end_trace();
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before action-timeout processing\n");
/* process timeout */
- if (e_action_timeout)
- {
+ if (e_action && e_action_timeout) { /* e_action may be NULL, but e_action_timeout may still be set and must be ignored */
e_action_timeout = 0;
- if (e_state == EPOINT_STATE_CONNECT)
- {
+ if (e_state == EPOINT_STATE_CONNECT) {
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action timed out, but we already have connected, so we stop timer and continue.\n", ea_endpoint->ep_serial);
goto end;
}
if (e_action->index == ACTION_DISCONNECT
- || e_state == EPOINT_STATE_OUT_DISCONNECT)
- {
+ || e_state == EPOINT_STATE_OUT_DISCONNECT) {
/* release after disconnect */
release(RELEASE_ALL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL);
goto end;
}
release(RELEASE_JOIN, LOCATION_PRIVATE_LOCAL, CAUSE_NORMAL, 0, 0);
e_action = e_action->next;
- if (!e_action)
- {
+ if (!e_action) {
/* nothing more, so we release */
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action timed out, and we have no next action, so we disconnect.\n", ea_endpoint->ep_serial);
new_state(EPOINT_STATE_OUT_DISCONNECT);
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before setup/overlap state checking\n");
if (e_state!=EPOINT_STATE_IN_SETUP
- && e_state!=EPOINT_STATE_IN_OVERLAP)
- {
- PDEBUG(DEBUG_EPOINT, "EPOINT(%d): we are not in incomming setup/overlap state, so we ignore init/dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
+ && e_state!=EPOINT_STATE_IN_OVERLAP) {
+ PDEBUG(DEBUG_EPOINT, "EPOINT(%d): we are not in incoming setup/overlap state, so we ignore init/dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
e_match_timeout = 0;
goto end;
}
/* check if we do menu selection */
if (e_action==NUMB_ACTION_NONE && (e_dialinginfo.id[0]=='*' || e_dialinginfo.id[0]=='#'))
/* do menu selection */
- if (e_ext.display_menu)
- {
- if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* only if the dialing terminal is an isdn telephone connected to an internal port */
- {
+ if (e_ext.display_menu) {
+ if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) { /* only if the dialing terminal is an isdn telephone connected to an internal port */
e_dialinginfo.id[0] = '\0';
e_action = NUMB_ACTION_MENU;
e_menu = 0;
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_DISCONNECT);
message->param.disconnectinfo.cause = CAUSE_INVALID;
message->param.disconnectinfo.location = LOCATION_PRIVATE_LOCAL;
- } else
- {
+ } else {
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
SCPY(message->param.notifyinfo.display,get_isdn_cause(LOCATION_PRIVATE_LOCAL, epoint->e_ext.display_cause, param->disconnectinfo.location, param->disconnectinfo.cause));
}
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before e_action==NULL\n");
/* if no action yet, we will call try to find a matching rule */
- if (!e_action)
- {
+ if (!e_action) {
/* be sure that all selectors are initialized */
e_select = 0;
/* check for external call */
- if (!strncmp(e_dialinginfo.id, "extern:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "extern:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_external;
goto process_action;
}
/* check for internal call */
- if (!strncmp(e_dialinginfo.id, "intern:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "intern:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_internal;
goto process_action;
}
/* check for chan call */
- if (!strncmp(e_dialinginfo.id, "remote:", 7))
- {
+ if (!strncmp(e_dialinginfo.id, "remote:", 7)) {
e_extdialing = e_dialinginfo.id+7;
e_action = &action_remote;
goto process_action;
}
/* check for vbox call */
- if (!strncmp(e_dialinginfo.id, "vbox:", 5))
- {
+ if (!strncmp(e_dialinginfo.id, "vbox:", 5)) {
e_extdialing = e_dialinginfo.id+5;
e_action = &action_vbox;
goto process_action;
}
- if (e_match_timeout && now_d>=e_match_timeout)
- {
+ if (e_match_timeout && now_d>=e_match_timeout) {
/* return timeout rule */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' dialing: '%s', timeout in ruleset '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_dialinginfo.id, e_ruleset->name);
e_match_timeout = 0;
add_trace("action", NULL, "%s", action_defs[e_action->index].name);
add_trace("line", NULL, "%d", e_action->line);
end_trace();
- } else
- {
+ } else {
//PDEBUG(~0, "HANG-BUG-DEBUGGING: before routing\n");
/* check for matching rule */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' dialing: '%s', checking matching rule of ruleset '%s'\n", ea_endpoint->ep_serial, e_ext.number, e_dialinginfo.id, e_ruleset->name);
- if (e_ruleset)
- {
+ if (e_ruleset) {
e_action = route(e_ruleset);
- if (e_action)
- {
+ if (e_action) {
trace_header("ACTION (match)", DIRECTION_NONE);
add_trace("action", NULL, "%s", action_defs[e_action->index].name);
add_trace("line", NULL, "%d", e_action->line);
end_trace();
}
- } else
- {
+ } else {
e_action = &action_disconnect;
- if (e_action)
- {
+ if (e_action) {
trace_header("ACTION (no main ruleset, disconnecting)", DIRECTION_NONE);
end_trace();
}
}
//PDEBUG(~0, "HANG-BUG-DEBUGGING: after routing\n");
}
- if (!e_action)
- {
+ if (!e_action) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): no rule within the current ruleset matches yet.\n", ea_endpoint->ep_serial, e_ext.number);
goto display;
}
/* set timeout */
e_action_timeout = 0;
- if (e_action->timeout)
- {
+ if (e_action->timeout) {
e_action_timeout = now_d + e_action->timeout;
PDEBUG(DEBUG_ROUTE|DEBUG_EPOINT, "EPOINT(%d): action has a timeout of %d secods.\n", ea_endpoint->ep_serial, e_action->timeout);
}
process_action:
/* check param proceeding / alerting / connect */
- if ((rparam = routeparam(e_action, PARAM_CONNECT)))
- {
+ if ((rparam = routeparam(e_action, PARAM_CONNECT))) {
/* NOTE: we may not change our state to connect, because dialing will then not possible */
e_dtmf = 1;
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message_put(message);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
} else
- if ((rparam = routeparam(e_action, PARAM_ALERTING)))
- {
+ if ((rparam = routeparam(e_action, PARAM_ALERTING))) {
/* NOTE: we may not change our state to alerting, because dialing will then not possible */
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_ALERTING);
message_put(message);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
} else
- if ((rparam = routeparam(e_action, PARAM_PROCEEDING)))
- {
+ if ((rparam = routeparam(e_action, PARAM_PROCEEDING))) {
/* NOTE: we may not change our state to proceeding, because dialing will then not possible */
memset(&e_connectinfo, 0, sizeof(e_connectinfo));
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_PROCEEDING);
logmessage(message->type, &message->param, portlist->port_id, DIRECTION_OUT);
}
- if (action_defs[e_action->index].init_func)
- {
+ if (action_defs[e_action->index].init_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a init function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].init_func))();
}
if (e_state!=EPOINT_STATE_IN_SETUP
- && e_state!=EPOINT_STATE_IN_OVERLAP)
- {
- PDEBUG(DEBUG_EPOINT, "EPOINT(%d): AFTER init process: we are not in incomming setup/overlap state anymore, so we ignore further dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
+ && e_state!=EPOINT_STATE_IN_OVERLAP) {
+ PDEBUG(DEBUG_EPOINT, "EPOINT(%d): AFTER init process: we are not in incoming setup/overlap state anymore, so we ignore further dialing process.\n", ea_endpoint->ep_serial, e_rule_nesting);
goto display_action;
}
}
/* show what we are doing */
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s' action: %s (dialing '%s')\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name, e_extdialing);
/* go to action's dialing function */
- if (action_defs[e_action->index].dialing_func)
- {
+ if (action_defs[e_action->index].dialing_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a dialing function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].dialing_func))();
}
/* display selected dialing action if enabled and still in setup state */
display_action:
- if (e_action)
- {
+ if (e_action) {
if (e_action->index==ACTION_MENU
|| e_action->index==ACTION_REDIAL
|| e_action->index==ACTION_REPLY
if (!e_ext.display_dialing)
goto end;
if (e_state==EPOINT_STATE_IN_OVERLAP || e_state==EPOINT_STATE_IN_PROCEEDING || e_state==EPOINT_STATE_IN_ALERTING || e_state==EPOINT_STATE_CONNECT/* || e_state==EPOINT_STATE_IN_DISCONNECT || e_state==EPOINT_STATE_OUT_DISCONNECT*/)
- if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) /* only if the dialing terminal is an isdn telephone connected to an internal port */
- {
+ if (portlist->port_type==PORT_TYPE_DSS1_NT_IN || portlist->port_type==PORT_TYPE_DSS1_NT_OUT) { /* only if the dialing terminal is an isdn telephone connected to an internal port */
message = message_create(ea_endpoint->ep_serial, portlist->port_id, EPOINT_TO_PORT, MESSAGE_NOTIFY);
- if (!e_action)
- {
+ if (!e_action) {
SPRINT(message->param.notifyinfo.display, "> %s", e_dialinginfo.id);
- } else
- {
+ } else {
SPRINT(message->param.notifyinfo.display, "%s%s%s", action_defs[e_action->index].name, (e_extdialing[0])?" ":"", e_extdialing);
}
int writeext = 0, i;
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal '%s'\n", ea_endpoint->ep_serial, e_ext.number);
- if (e_ext.number[0])
- {
+ if (e_ext.number[0]) {
if (read_extension(&e_ext, e_ext.number))
writeext = 0x10;
- if (!e_start)
- {
+ if (!e_start) {
time(&e_start);
e_stop = 0;
} else
if (!e_stop)
time(&e_stop);
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): writing connect from %s to %s into logfile of %s\n", ea_endpoint->ep_serial, e_callerinfo.id, e_dialinginfo.id, e_ext.number);
- switch(e_dialinginfo.itype)
- {
+ switch(e_dialinginfo.itype) {
case INFO_ITYPE_CHAN:
SPRINT(dialingtext, "chan:%s", e_dialinginfo.id);
break;
}
if (e_callerinfo.id[0])
- SPRINT(callertext, "%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype));
+ SPRINT(callertext, "%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international));
else
SPRINT(callertext, "unknown");
/* allpy restriction */
write_log(e_ext.number, callertext, dialingtext, e_start, e_stop, 0, cause, location);
/* store last received call for reply-list */
- if (e_origin == 1) // outgoing to phone is incomming for user
+ if (e_origin == 1) // outgoing to phone is incoming for user
if (e_callerinfo.id[0] || e_callerinfo.extension[0])
- if (e_ext.anon_ignore || e_callerinfo.present!=INFO_PRESENT_RESTRICTED)
- {
+ if (e_ext.anon_ignore || e_callerinfo.present!=INFO_PRESENT_RESTRICTED) {
if (e_callerinfo.extension[0])
SPRINT(callertext, "intern:%s", e_callerinfo.extension);
else
- SPRINT(callertext, "extern:%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype));
- if (!!strcmp(callertext, e_ext.last_in[0]))
- {
+ SPRINT(callertext, "extern:%s", numberrize_callerinfo(e_callerinfo.id, e_callerinfo.ntype, options.national, options.international));
+ if (!!strcmp(callertext, e_ext.last_in[0])) {
i = MAX_REMEMBER-1;
- while(i)
- {
+ while(i) {
UCPY(e_ext.last_in[i], e_ext.last_in[i-1]);
i--;
}
}
/* store last made call for reply-list */
- if (e_origin == 0) // incomming from phone is outgoing for user
- if (e_dialinginfo.id[0])
- {
- if (!!strcmp(e_dialinginfo.id, e_ext.last_out[0]))
- {
+ if (e_origin == 0) // incoming from phone is outgoing for user
+ if (e_dialinginfo.id[0]) {
+ if (!!strcmp(e_dialinginfo.id, e_ext.last_out[0])) {
i = MAX_REMEMBER-1;
- while(i)
- {
+ while(i) {
UCPY(e_ext.last_out[i], e_ext.last_out[i-1]);
i--;
}
if (writeext == 0x11)
write_extension(&e_ext, e_ext.number);
- if (e_action)
- {
- if (action_defs[e_action->index].hangup_func)
- {
+ if (e_action) {
+ if (action_defs[e_action->index].hangup_func) {
PDEBUG(DEBUG_EPOINT, "EPOINT(%d): terminal %s: current action '%s' has a hangup function, so we call it...\n", ea_endpoint->ep_serial, e_ext.number, action_defs[e_action->index].name);
(this->*(action_defs[e_action->index].hangup_func))();
}
projects / lcr.git / blobdiff