Added scripted channels to receive and handle voicemail.
Fixed a problem compiling zapchan with very new versions of gcc. git-svn-id: http://voip.null.ro/svn/yate@230 acf43c95-373e-0410-b603-e72c3f656dc1
This commit is contained in:
paulc
parent
bf463060a5
commit
082ded0419
|
|
@ -590,7 +590,7 @@ PriSpan::PriSpan(struct pri *_pri, int span, int first, int chans, int dchan, in
|
|||
m_restart(0), m_chans(0), m_ok(false)
|
||||
{
|
||||
Debug(DebugAll,"PriSpan::PriSpan(%p,%d,%d,%d) [%p]",_pri,span,chans,fd,this);
|
||||
ZapChan **ch = new (ZapChan *)[chans];
|
||||
ZapChan **ch = new ZapChan* [chans];
|
||||
for (int i = 1; i <= chans; i++)
|
||||
ch[i-1] = (i == dchan) ? 0 : new ZapChan(this,i,s_buflen);
|
||||
m_chans = ch;
|
||||
|
|
|
|||
|
|
@ -0,0 +1,186 @@
|
|||
#!/usr/bin/php -q
|
||||
<?
|
||||
/* Simple voicemail recorder for the Yate PHP interface
|
||||
|
||||
To use it you must re-route calls to offline or non-responding numbers to:
|
||||
external/nodata/leavemail.php
|
||||
*/
|
||||
require_once("libyate.php");
|
||||
|
||||
/* Always the first action to do */
|
||||
Yate::Init();
|
||||
|
||||
/* Install handler for the wave end notify messages */
|
||||
Yate::Install("chan.notify");
|
||||
|
||||
$ourcallid = "leavemail/" . uniqid(rand(),1);
|
||||
$partycallid = "";
|
||||
$state = "call";
|
||||
$base = "/var/spool/voicemail";
|
||||
$user = "";
|
||||
$file = "";
|
||||
|
||||
/* Check if the user exists and prepare a filename if so */
|
||||
function checkUser($called,$caller)
|
||||
{
|
||||
global $base;
|
||||
global $user;
|
||||
global $file;
|
||||
|
||||
$user = "$base/$called";
|
||||
if (!is_dir($user))
|
||||
return false;
|
||||
$t = strftime("%Y.%m.%d-%H.%M.%S");
|
||||
$file = "vm-$t-$caller.slin";
|
||||
return true;
|
||||
}
|
||||
|
||||
/* Perform machine status transitions */
|
||||
function setState($newstate)
|
||||
{
|
||||
global $ourcallid;
|
||||
global $state;
|
||||
global $base;
|
||||
global $user;
|
||||
global $file;
|
||||
|
||||
// are we exiting?
|
||||
if ($state == "")
|
||||
return;
|
||||
|
||||
Yate::Output("setState('$newstate') state: $state");
|
||||
|
||||
if ($newstate == $state)
|
||||
return;
|
||||
|
||||
switch ($newstate) {
|
||||
case "novmail":
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/$base/novmail.slin";
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "greeting":
|
||||
$m = new Yate("chan.attach");
|
||||
if (is_file("$user/greeting.slin"))
|
||||
$m->params["source"] = "wave/play/$user/greeting.slin";
|
||||
else
|
||||
$m->params["source"] = "wave/play/$base/greeting.slin";
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "beep":
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/$base/beep.slin";
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "record":
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/-";
|
||||
$m->params["consumer"] = "wave/record/$user/$file";
|
||||
$m->params["maxlen"] = 160000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "goodbye":
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "tone/congestion";
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 32000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
}
|
||||
$state = $newstate;
|
||||
}
|
||||
|
||||
/* Handle EOF of wave files */
|
||||
function gotNotify()
|
||||
{
|
||||
global $state;
|
||||
|
||||
Yate::Output("gotNotify() state: $state");
|
||||
|
||||
switch ($state) {
|
||||
case "goodbye":
|
||||
setState("");
|
||||
break;
|
||||
case "greeting":
|
||||
setState("beep");
|
||||
break;
|
||||
case "beep":
|
||||
setState("record");
|
||||
break;
|
||||
default:
|
||||
setState("goodbye");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
/* The main loop. We pick events and handle them */
|
||||
while ($state != "") {
|
||||
$ev=Yate::GetEvent();
|
||||
/* If Yate disconnected us then exit cleanly */
|
||||
if ($ev == "EOF")
|
||||
break;
|
||||
/* No need to handle empty events in this application */
|
||||
if ($ev == "")
|
||||
continue;
|
||||
/* If we reached here we should have a valid object */
|
||||
switch ($ev->type) {
|
||||
case "incoming":
|
||||
switch ($ev->name) {
|
||||
case "call.execute":
|
||||
$partycallid = $ev->params["id"];
|
||||
$ev->params["targetid"] = $ourcallid;
|
||||
$ev->handled = true;
|
||||
/* We must ACK this message before dispatching a call.answered */
|
||||
$ev->Acknowledge();
|
||||
|
||||
/* Check if the mailbox exists, answer only if that's the case */
|
||||
if (checkUser($ev->params["called"],$ev->params["caller"])) {
|
||||
$m = new Yate("call.answered");
|
||||
$m->params["id"] = $ourcallid;
|
||||
$m->params["targetid"] = $partycallid;
|
||||
$m->Dispatch();
|
||||
setState("greeting");
|
||||
}
|
||||
else
|
||||
/* Play a message and exit - don't answer the call */
|
||||
setState("novmail");
|
||||
|
||||
// we already ACKed this message
|
||||
$ev = "";
|
||||
break;
|
||||
|
||||
case "chan.notify":
|
||||
if ($ev->params["targetid"] == $ourcallid) {
|
||||
gotNotify();
|
||||
$ev->handled = true;
|
||||
}
|
||||
break;
|
||||
}
|
||||
/* This is extremely important.
|
||||
We MUST let messages return, handled or not */
|
||||
if ($ev != "")
|
||||
$ev->Acknowledge();
|
||||
break;
|
||||
case "answer":
|
||||
Yate::Output("PHP Answered: " . $ev->name . " id: " . $ev->id);
|
||||
break;
|
||||
case "installed":
|
||||
Yate::Output("PHP Installed: " . $ev->name);
|
||||
break;
|
||||
case "uninstalled":
|
||||
Yate::Output("PHP Uninstalled: " . $ev->name);
|
||||
break;
|
||||
default:
|
||||
Yate::Output("PHP Event: " . $ev->type);
|
||||
}
|
||||
}
|
||||
|
||||
Yate::Output("PHP: bye!");
|
||||
|
||||
/* vi: set ts=8 sw=4 sts=4 noet: */
|
||||
?>
|
||||
|
|
@ -0,0 +1,400 @@
|
|||
#!/usr/bin/php -q
|
||||
<?
|
||||
/* Simple voicemail manipulation for the Yate PHP interface
|
||||
To use add in regexroute.conf
|
||||
|
||||
^NNN$=external/nodata/voicemail.php
|
||||
|
||||
where NNN is the number you want to assign to handle voicemail
|
||||
*/
|
||||
require_once("libyate.php");
|
||||
|
||||
/* Always the first action to do */
|
||||
Yate::Init();
|
||||
|
||||
/* Install handlers for the wave end and dtmf notify messages */
|
||||
Yate::Install("chan.dtmf",10);
|
||||
Yate::Install("chan.notify");
|
||||
|
||||
$ourcallid = "voicemail/" . uniqid(rand(),1);
|
||||
$partycallid = "";
|
||||
$state = "call";
|
||||
$base = "/var/spool/voicemail";
|
||||
$dir = "";
|
||||
$mailbox = "";
|
||||
$collect_user = "";
|
||||
$collect_pass = "";
|
||||
$files = array();
|
||||
$current = 0;
|
||||
|
||||
/* Ask the user to enter number */
|
||||
function promptUser()
|
||||
{
|
||||
global $collect_user;
|
||||
global $base;
|
||||
$collect_user = "";
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/$base/usernumber.slin";
|
||||
$m->Dispatch();
|
||||
}
|
||||
|
||||
/* Ask for the password */
|
||||
function promptPass()
|
||||
{
|
||||
global $collect_pass;
|
||||
global $base;
|
||||
$collect_pass = "";
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/$base/password.slin";
|
||||
$m->Dispatch();
|
||||
}
|
||||
|
||||
/* Perform machine status transitions */
|
||||
function setState($newstate)
|
||||
{
|
||||
global $ourcallid;
|
||||
global $partycallid;
|
||||
global $state;
|
||||
global $mailbox;
|
||||
global $base;
|
||||
global $dir;
|
||||
global $files;
|
||||
global $current;
|
||||
|
||||
// are we exiting?
|
||||
if ($state == "")
|
||||
return;
|
||||
|
||||
Yate::Output("setState('$newstate') state: $state");
|
||||
|
||||
// always obey a return to prompt
|
||||
switch ($newstate) {
|
||||
case "prompt":
|
||||
$state = $newstate;
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/$base/menu.slin";
|
||||
$m->Dispatch();
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 320000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
return;
|
||||
case "listen":
|
||||
$state = $newstate;
|
||||
$m = new Yate("chan.attach");
|
||||
$f = $dir . "/" . $files[$current];
|
||||
if (is_file("$f"))
|
||||
$m->params["source"] = "wave/play/$f";
|
||||
else
|
||||
$m->params["source"] = "wave/play/$base/deleted.slin";
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 100000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
return;
|
||||
}
|
||||
|
||||
if ($newstate == $state)
|
||||
return;
|
||||
|
||||
switch ($newstate) {
|
||||
case "user":
|
||||
promptUser();
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 160000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "pass":
|
||||
promptPass();
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 160000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "record":
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "wave/play/-";
|
||||
$m->params["consumer"] = "wave/record/$ir/greeting.slin";
|
||||
$m->params["maxlen"] = 80000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "play":
|
||||
$m = new Yate("chan.attach");
|
||||
if (is_file("$dir/greeting.slin"))
|
||||
$m->params["source"] = "wave/play/$dir/greeting.slin";
|
||||
else
|
||||
$m->params["source"] = "wave/play/$base/nogreeting.slin";
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 100000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
case "goodbye":
|
||||
$mailbox = "";
|
||||
$m = new Yate("chan.attach");
|
||||
$m->params["source"] = "tone/congestion";
|
||||
$m->params["consumer"] = "wave/record/-";
|
||||
$m->params["maxlen"] = 32000;
|
||||
$m->params["notify"] = $ourcallid;
|
||||
$m->Dispatch();
|
||||
break;
|
||||
}
|
||||
$state = $newstate;
|
||||
}
|
||||
|
||||
/* Check if the maibox exists, create if not, scan voicemail files */
|
||||
function initUser()
|
||||
{
|
||||
global $base;
|
||||
global $dir;
|
||||
global $mailbox;
|
||||
global $files;
|
||||
$dir = "$base/$mailbox";
|
||||
if (!is_dir($dir))
|
||||
mkdir($dir,0755);
|
||||
if ($d = @opendir($dir)) {
|
||||
while (($f = readdir($d)) !== false) {
|
||||
if (substr($f,0,3) == "vm-") {
|
||||
Yate::Output("found file '$f'");
|
||||
$files[] = $f;
|
||||
}
|
||||
}
|
||||
closedir($d);
|
||||
}
|
||||
Yate::Output("found " . count($files) . " file entries");
|
||||
setState("prompt");
|
||||
}
|
||||
|
||||
/* Transition to password entering state if user is not empty else exit */
|
||||
function checkUser()
|
||||
{
|
||||
global $collect_user;
|
||||
if ($collect_user == "")
|
||||
setState("goodbye");
|
||||
else
|
||||
setState("pass");
|
||||
}
|
||||
|
||||
/* Transition to authentication state if password is not empty else exit */
|
||||
function checkPass()
|
||||
{
|
||||
global $collect_user;
|
||||
global $collect_pass;
|
||||
if ($collect_pass == "")
|
||||
setState("goodbye");
|
||||
else {
|
||||
setState("auth");
|
||||
$m = new Yate("user.auth");
|
||||
$m->params["username"] = $collect_user;
|
||||
$m->Dispatch();
|
||||
}
|
||||
}
|
||||
|
||||
/* Check the system known password agains the user enterd one */
|
||||
function checkAuth($pass)
|
||||
{
|
||||
global $collect_user;
|
||||
global $collect_pass;
|
||||
global $mailbox;
|
||||
// Yate::Output("checking passwd if '$collect_pass' == '$pass'");
|
||||
if ($collect_pass == $pass) {
|
||||
$mailbox = $collect_user;
|
||||
initUser();
|
||||
}
|
||||
else
|
||||
setState("goodbye");
|
||||
$collect_pass = "";
|
||||
}
|
||||
|
||||
/* Handle EOF of wave files */
|
||||
function gotNotify()
|
||||
{
|
||||
global $ourcallid;
|
||||
global $partycallid;
|
||||
global $state;
|
||||
|
||||
Yate::Output("gotNotify() state: $state");
|
||||
|
||||
switch ($state) {
|
||||
case "goodbye":
|
||||
setState("");
|
||||
break;
|
||||
case "record":
|
||||
case "play":
|
||||
case "listen":
|
||||
setState("prompt");
|
||||
break;
|
||||
case "user":
|
||||
checkUser();
|
||||
break;
|
||||
case "pass":
|
||||
checkPass();
|
||||
break;
|
||||
default:
|
||||
setState("goodbye");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
/* Play the n-th voicemail file */
|
||||
function listenTo($n)
|
||||
{
|
||||
global $files;
|
||||
global $current;
|
||||
if (($n < 0) || ($n >= count($files)))
|
||||
return;
|
||||
$current = $n;
|
||||
setState("listen");
|
||||
}
|
||||
|
||||
/* Handle DTMFs after successfully logging in */
|
||||
function navigate($text)
|
||||
{
|
||||
global $state;
|
||||
global $current;
|
||||
switch ($text) {
|
||||
case "0":
|
||||
listenTo(0);
|
||||
break;
|
||||
case "7":
|
||||
listenTo($current-1);
|
||||
break;
|
||||
case "8":
|
||||
listenTo($current);
|
||||
break;
|
||||
case "9":
|
||||
listenTo($current+1);
|
||||
break;
|
||||
case "1":
|
||||
setState("record");
|
||||
break;
|
||||
case "2":
|
||||
setState("play");
|
||||
break;
|
||||
case "3":
|
||||
setState("");
|
||||
break;
|
||||
case "*":
|
||||
setState("prompt");
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
/* Handle all DTMFs here */
|
||||
function gotDTMF($text)
|
||||
{
|
||||
global $state;
|
||||
global $mailbox;
|
||||
global $collect_user;
|
||||
global $collect_pass;
|
||||
|
||||
Yate::Output("gotDTMF('$text') state: $state");
|
||||
|
||||
switch ($state) {
|
||||
case "user":
|
||||
if ($text == "*") {
|
||||
promptUser();
|
||||
return;
|
||||
}
|
||||
if ($text == "#")
|
||||
checkUser();
|
||||
else
|
||||
$collect_user .= $text;
|
||||
return;
|
||||
case "pass":
|
||||
if ($text == "*") {
|
||||
promptPass();
|
||||
return;
|
||||
}
|
||||
if ($text == "#")
|
||||
checkPass();
|
||||
else
|
||||
$collect_pass .= $text;
|
||||
return;
|
||||
}
|
||||
if ($mailbox == "")
|
||||
return;
|
||||
|
||||
navigate($text);
|
||||
}
|
||||
|
||||
/* The main loop. We pick events and handle them */
|
||||
while ($state != "") {
|
||||
$ev=Yate::GetEvent();
|
||||
/* If Yate disconnected us then exit cleanly */
|
||||
if ($ev == "EOF")
|
||||
break;
|
||||
/* No need to handle empty events in this application */
|
||||
if ($ev == "")
|
||||
continue;
|
||||
/* If we reached here we should have a valid object */
|
||||
switch ($ev->type) {
|
||||
case "incoming":
|
||||
switch ($ev->name) {
|
||||
case "call.execute":
|
||||
$mailbox = $ev->params["user"];
|
||||
$partycallid = $ev->params["id"];
|
||||
$ev->params["targetid"] = $ourcallid;
|
||||
$ev->handled = true;
|
||||
/* We must ACK this message before dispatching a call.answered */
|
||||
$ev->Acknowledge();
|
||||
/* Prevent a warning if trying to ACK this message again */
|
||||
$ev = "";
|
||||
|
||||
/* Signal we are answering the call */
|
||||
$m = new Yate("call.answered");
|
||||
$m->params["id"] = $ourcallid;
|
||||
$m->params["targetid"] = $partycallid;
|
||||
$m->Dispatch();
|
||||
|
||||
/* If the user is unknown we need to identify and authenticate */
|
||||
if ($mailbox == "")
|
||||
setState("user");
|
||||
else
|
||||
initUser();
|
||||
break;
|
||||
|
||||
case "chan.notify":
|
||||
if ($ev->params["targetid"] == $ourcallid) {
|
||||
gotNotify();
|
||||
$ev->handled = true;
|
||||
}
|
||||
break;
|
||||
|
||||
case "chan.dtmf":
|
||||
if ($ev->params["targetid"] == $ourcallid ) {
|
||||
gotDTMF($ev->params["text"]);
|
||||
$ev->handled = true;
|
||||
}
|
||||
break;
|
||||
}
|
||||
/* This is extremely important.
|
||||
We MUST let messages return, handled or not */
|
||||
if ($ev != "")
|
||||
$ev->Acknowledge();
|
||||
break;
|
||||
case "answer":
|
||||
Yate::Output("PHP Answered: " . $ev->name . " id: " . $ev->id);
|
||||
if ($ev->name == "user.auth")
|
||||
checkAuth($ev->retval);
|
||||
break;
|
||||
case "installed":
|
||||
Yate::Output("PHP Installed: " . $ev->name);
|
||||
break;
|
||||
case "uninstalled":
|
||||
Yate::Output("PHP Uninstalled: " . $ev->name);
|
||||
break;
|
||||
default:
|
||||
Yate::Output("PHP Event: " . $ev->type);
|
||||
}
|
||||
}
|
||||
|
||||
Yate::Output("PHP: bye!");
|
||||
|
||||
/* vi: set ts=8 sw=4 sts=4 noet: */
|
||||
?>
|
||||
Loading…
Reference in New Issue