#!/usr/bin/perl
#
# Web based Voicemail for Asterisk
#
# Copyright (C) 2002, Linux Support Services, Inc.
#
# Distributed under the terms of the GNU General Public License
#
# Written by Mark Spencer <markster@linux-support.net>
#
# (icky, I know....  if you know better perl please help!)
#
#
# Synchronization added by GDS Partners (www.gdspartners.com)
#			 Stojan Sljivic (stojan.sljivic@gdspartners.com)
#
use CGI qw/:standard/;
use Carp::Heavy;
use CGI::Carp qw(fatalsToBrowser);
use DBI;
use Fcntl qw ( O_WRONLY O_CREAT O_EXCL );
use Time::HiRes qw ( usleep );

$context=""; # Define here your by default context (so you dont need to put voicemail@context in the login)

@validfolders = ( "INBOX", "Old", "Work", "Family", "Friends", "Cust1", "Cust2", "Cust3", "Cust4", "Cust5" );

%formats = (
	"wav" => {
		name => "Uncompressed WAV",
		mime => "audio/x-wav",
		pref => 1
	},
	"WAV" => {
		name => "GSM Compressed WAV",
		mime => "audio/x-wav",
		pref => 2
	},
	"gsm" => {
		name => "Raw GSM Audio",
		mime => "audio/x-gsm",
		pref => 3
	}
);

$astpath = "/_asterisk";

$stdcontainerstart = "
 \n";
$footer = "
The Asterisk Open Source PBX Copyright 2004-2008, Digium, Inc.";
$stdcontainerend = "
 $footer

\n";

sub lock_path($) {

	my($path) = @_;
	my $rand;
	my $rfile;
	my $start;
	my $res;
	
	$rand = rand 99999999;	
	$rfile = "$path/.lock-$rand";
	
	sysopen(RFILE, $rfile, O_WRONLY | O_CREAT | O_EXCL, 0666) or return -1;
	close(RFILE);
	
	$res = link($rfile, "$path/.lock");
	$start = time;
	if ($res == 0) {
	while (($res == 0) && (time - $start <= 5)) {
		$res = link($rfile, "$path/.lock");
		usleep(1);
	}
	}
	unlink($rfile);
	
	if ($res == 0) {
		return -1;
	} else {
		return 0;
	}
}

sub unlock_path($) {

	my($path) = @_;
	
	unlink("$path/.lock");
}

sub untaint($) {

	my($data) = @_;
	
	if ($data =~ /^([-\@\w.]+)$/) {
		$data = $1;
	} else {
		die "Security violation.";
	}
	
	return $data;
}

sub login_screen($) {
	print header;
	my ($message) = @_;
	print <<_EOH;

Asterisk Web-Voicemail

$stdcontainerstart

 Comedian Mail Login
 $message
 Mailbox: 
 Password: 

$stdcontainerend
\n
_EOH

}

sub check_login($$)
{
	local ($filename, $startcat) = @_;
	local ($mbox, $context) = split(/\@/, param('mailbox'));
	local $pass = param('password');
	local $category = $startcat;
	local @fields;
	local $tmp;
	local (*VMAIL);
	if (!$category) {
		$category = "general";
	}
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	if (!$filename) {
		$filename = "/etc/asterisk/voicemail.conf";
	}
#	print header;
#	print "Including 
$filename
 while in 
$category
...\n";
	open(VMAIL, "<$filename") || die("Bleh, no $filename");
	while(<VMAIL>) {
		chomp;
		if (/include\s\"([^\"]+)\"$/) {
			($tmp, $category) = &check_login("/etc/asterisk/$1", $category);
			if (length($tmp)) {
#				print "Got '$tmp'\n";
				return ($tmp, $category);
			}
		} elsif (/\[(.*)\]/) {
			$category = $1;
		} elsif ($category eq "general") {
			if (/([^\s]+)\s*\=\s*(.*)/) {
				if ($1 eq "dbname") {
					$dbname = $2;
				} elsif ($1 eq "dbpass") {
					$dbpass = $2;
				} elsif ($1 eq "dbhost") {
					$dbhost = $2;
				} elsif ($1 eq "dbuser") {
					$dbuser = $2;
				}
			}
			if ($dbname and $dbpass and $dbhost and $dbuser) {

				# db variables are present.  Use db for authentication.
				my $dbh = DBI->connect("DBI:mysql:$dbname:$dbhost",$dbuser,$dbpass);
				my $sth = $dbh->prepare(qq{select fullname,context from voicemail where mailbox='$mbox' and password='$pass' and context='$context'});
				$sth->execute();
				if (($fullname, $category) = $sth->fetchrow_array()) {
					return ($fullname ? $fullname : "Extension $mbox in $context",$category);
				}
			}
		} elsif (($category ne "general") && ($category ne "zonemessages")) { 
			if (/([^\s]+)\s*\=\>?\s*(.*)/) {
				@fields = split(/\,\s*/, $2);
#				print "<p>Mailbox is $1\n";
				if (($mbox eq $1) && (($pass eq $fields[0]) || ("-${pass}" eq $fields[0])) && ($context eq $category)) {
					return ($fields[1] ? $fields[1] : "Extension $mbox in $context", $category);
				}
			}
		}
	}
	close(VMAIL);
	return check_login_users();
}

sub check_login_users {
	my ($mbox, $context) = split(/\@/, param('mailbox'));
	my $pass = param('password');
	my ($found, $fullname) = (0, "");
	open VMAIL, "</etc/asterisk/users.conf";
	while (<VMAIL>) {
		chomp;
		if (m/\[(.*)\]/) {
			if ($1 eq $mbox) {
				$found = 1;
			} elsif ($found == 2) {
				close VMAIL;
				return (($fullname ? $fullname : "Extension $mbox in $context"), $context);
			} else {
				$found = 0;
			}
		} elsif ($found) {
			my ($var, $value) = split /\s*=\s*/, $_, 2;
			if ($var eq 'vmsecret' and $value eq $pass) {
				$found = 2;
			} elsif ($var eq 'fullname') {
				$fullname = $value;
				if ($found == 2) {
					close VMAIL;
					return ($fullname, $context);
				}
			}
		}
	}
	close VMAIL;
	return ("", "");
}

sub validmailbox($$$$)
{
	local ($context, $mbox, $filename, $startcat) = @_;
	local $category = $startcat;
	local @fields;
	local (*VMAIL);
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	if (!$filename) {
		$filename = "/etc/asterisk/voicemail.conf";
	}
	if (!$category) {
		$category = "general";
	}
	open(VMAIL, "<$filename") || die("Bleh, no $filename");
	while (<VMAIL>) {
		chomp;
		if (/include\s\"([^\"]+)\"$/) {
			($tmp, $category) = &validmailbox($mbox, $context, "/etc/asterisk/$1");
			if ($tmp) {
				return ($tmp, $category);
			}
		} elsif (/\[(.*)\]/) {
			$category = $1;
		} elsif ($category eq "general") {
			if (/([^\s]+)\s*\=\s*(.*)/) {
				if ($1 eq "dbname") {
					$dbname = $2;
				} elsif ($1 eq "dbpass") {
					$dbpass = $2;
				} elsif ($1 eq "dbhost") {
					$dbhost = $2;
				} elsif ($1 eq "dbuser") {
					$dbuser = $2;
				}
			}
			if ($dbname and $dbpass and $dbhost and $dbuser) {

				# db variables are present.  Use db for authentication.
				my $dbh = DBI->connect("DBI:mysql:$dbname:$dbhost",$dbuser,$dbpass);
				my $sth = $dbh->prepare(qq{select fullname,context from voicemail where mailbox='$mbox' and password='$pass' and context='$context'});
				$sth->execute();
				if (($fullname, $context) = $sth->fetchrow_array()) {
					return ($fullname ? $fullname : "unknown", $category);
				}
			}
		} elsif (($category ne "general") && ($category ne "zonemessages") && ($category eq $context)) {
			if (/([^\s]+)\s*\=\>?\s*(.*)/) {
				@fields = split(/\,\s*/, $2);
				if (($mbox eq $1) && ($context eq $category)) {
					return ($fields[2] ? $fields[2] : "unknown", $category);
				}
			}
		}
	}
	return ("", $category);
}

sub mailbox_options()
{
	local($context, $current, $filename, $category) = @_;
	local (*VMAIL);
	local $tmp2;
	local $tmp;
	if (!$filename) {
		$filename = "/etc/asterisk/voicemail.conf";
	}
	if (!$category) {
		$category = "general";
	}
#	print header;
#	print "Including 
$filename
 while in 
$category
...\n";
	open(VMAIL, "<$filename") || die("Bleh, no voicemail.conf");
	while(<VMAIL>) {
		chomp;
		s/\;.*$//;
		if (/include\s\"([^\"]+)\"$/) {
			($tmp2, $category) = &mailbox_options($context, $current, "/etc/asterisk/$1", $category);
#			print "Got '$tmp2'...\n";
			$tmp .= $tmp2;
		} elsif (/\[(.*)\]/) {
			$category = $1;
		} elsif ($category eq "general") {
			if (/([^\s]+)\s*\=\s*(.*)/) {
				if ($1 eq "dbname") {
					$dbname = $2;
				} elsif ($1 eq "dbpass") {
					$dbpass = $2;
				} elsif ($1 eq "dbhost") {
					$dbhost = $2;
				} elsif ($1 eq "dbuser") {
					$dbuser = $2;
				}
			}
			if ($dbname and $dbpass and $dbhost and $dbuser) {

				# db variables are present.  Use db for authentication.
				my $dbh = DBI->connect("DBI:mysql:$dbname:$dbhost",$dbuser,$dbpass);
				my $sth = $dbh->prepare(qq{select mailbox,fullname,context from voicemail where context='$context' order by mailbox});
				$sth->execute();
				while (($mailbox, $fullname, $category) = $sth->fetchrow_array()) {
					$text = $mailbox;
					if ($fullname) {
						$text .= " (".$fullname.")";
					}
					if ($mailbox eq $current) {
						$tmp .= "<OPTION SELECTED>$text</OPTION>\n";
					} else {
						$tmp .= "<OPTION>$text</OPTION>\n";
					}
				}
				return ($tmp, $category);
			}
		} elsif (($category ne "general") && ($category ne "zonemessages")) {
			if (/([^\s]+)\s*\=\>?\s*(.*)/) {
				@fields = split(/\,\s*/, $2);
				$text = "$1";
				if ($fields[1]) {
					$text .= " ($fields[1])";
				}
				if ($1 eq $current) {
					$tmp .= "<OPTION SELECTED>$text</OPTION>\n";
				} else {
					$tmp .= "<OPTION>$text</OPTION>\n";
				}
				
			}
		}
	}
	close(VMAIL);
	return ($tmp, $category);
}

sub mailbox_list()
{
	local ($name, $context, $current) = @_;
	local $tmp;
	local $text;
	local $tmp;
	local $opts;
	if (!$context) {
		$context = "default";
	}
	$tmp = "\n";
	($opts) = &mailbox_options($context, $current);
	$tmp .= $opts;
	$tmp .= "\n";
	
}

sub msgcount() 
{
	my ($context, $mailbox, $folder) = @_;
	my $path = "/var/spool/asterisk/voicemail/$context/$mailbox/$folder";
	if (opendir(DIR, $path)) {
		my @msgs = grep(/^msg....\.txt$/, readdir(DIR));
		closedir(DIR);
		return sprintf "%d", $#msgs + 1;
	}
	return "0";
}

sub msgcountstr()
{
	my ($context, $mailbox, $folder) = @_;
	my $count = &msgcount($context, $mailbox, $folder);
	if ($count > 1) {
		"$count messages";
	} elsif ($count > 0) {
		"$count message";
	} else {
		"no messages";
	}
}
sub messages()
{
	my ($context, $mailbox, $folder) = @_;
	my $path = "/var/spool/asterisk/voicemail/$context/$mailbox/$folder";
	if (opendir(DIR, $path)) {
		my @msgs = sort grep(/^msg....\.txt$/, readdir(DIR));
		closedir(DIR);
		return map { s/^msg(....)\.txt$/$1/; $_ } @msgs;
	}
	return ();
}

sub getcookie()
{
	my ($var) = @_;
	return cookie($var);
}

sub makecookie()
{
	my ($format) = @_;
	cookie(-name => "format", -value =>["$format"], -expires=>"+1y");
}

sub getfields()
{
	my ($context, $mailbox, $folder, $msg) = @_;
	my $fields;
	if (open(MSG, "</var/spool/asterisk/voicemail/$context/$mailbox/$folder/msg${msg}.txt")) {
		while(<MSG>) {
			s/\#.*$//g;
			if (/^(\w+)\s*\=\s*(.*)$/) {
				$fields->{$1} = $2;
			}
		}
		close(MSG);
		$fields->{'msgid'} = $msg;
	} else { print "
Unable to open '$msg' in '$mailbox', '$folder'\n"; }
	$fields;
}

sub message_prefs()
{
	my ($nextaction, $msgid) = @_;
	my $folder = param('folder');
	my $mbox = param('mailbox');
	my $context = param('context');
	my $passwd = param('password');
	my $format = param('format');
	if (!$format) {
		$format = &getcookie('format');
	}
	print header;
	print <<_EOH;

Asterisk Web-Voicemail: Preferences

$stdcontainerstart

 Web Voicemail Preferences
 Preferred Audio Format: 
_EOH

foreach $fmt (sort { $formats{$a}->{'pref'} <=> $formats{$b}->{'pref'} } keys %formats) {
	my $clicked = "checked" if $fmt eq $format;
	print "    $formats{$fmt}->{name}
\n";
}

print <<_EOH;

$stdcontainerend
\n
_EOH

}

sub message_play()
{
	my ($message, $msgid) = @_;
	my $folder = param('folder');
	my ($mbox, $context) = split(/\@/, param('mailbox'));
	my $passwd = param('password');
	my $format = param('format');
	
	my $fields;
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	
	my $folders = &folder_list('newfolder', $context, $mbox, $folder);
	my $mailboxes = &mailbox_list('forwardto', $context, $mbox);
	if (!$format) {
		$format = &getcookie('format');
	}
	if (!$format) {
		&message_prefs("play", $msgid);
	} else {
		print header(-cookie => &makecookie($format));
		$fields = &getfields($context, $mbox, $folder, $msgid);
		if (!$fields) {
			print "<BR>Bah!\n";
			return;
		}
		my $duration = $fields->{'duration'};
		if ($duration) {
			$duration = sprintf "%d:%02d", $duration/60, $duration % 60; 
		} else {
			$duration = "<i>Unknown</i>";
		}
		print <<_EOH;
	
Asterisk Web-Voicemail: $folder Message $msgid

$stdcontainerstart

 $folder Message $msgid
_EOH

		print <<_EOH;
 
	 $folder $msgid
	 Message: $msgid
\n
	 Mailbox: $mbox\@$context
\n
	 Folder: $folder
\n
	 From: $fields->{callerid}
\n
	 Duration: $duration
\n
	 Original Date: $fields->{origdate}
\n
	 Original Mailbox: $fields->{origmailbox}
\n
	 Caller Channel: $fields->{callerchan}
\n
	 	 
	 
	 "> 
	$mailboxes 
	">
	$folders 

$stdcontainerend
\n
_EOH
	}
}

sub message_audio()
{
	my ($forcedownload) = @_;
	my $folder = &untaint(param('folder'));
	my $msgid = &untaint(param('msgid'));
	my $mailbox = &untaint(param('mailbox'));
	my $context = &untaint(param('context'));
	my $format = param('format');
	if (!$format) {
		$format = &getcookie('format');
	}
	&untaint($format);

	my $path = "/var/spool/asterisk/voicemail/$context/$mailbox/$folder/msg${msgid}.$format";

	$msgid =~ /^\d\d\d\d$/ || die("Msgid Liar ($msgid)!");
	grep(/^${format}$/, keys %formats) || die("Format Liar ($format)!");

	# Mailbox and folder are already verified
	if (open(AUDIO, "<$path")) {
		$size = -s $path;
		$|=1;
		if ($forcedownload) {
			print header(-type=>$formats{$format}->{'mime'}, -Content_length => $size, -attachment => "msg${msgid}.$format");
		} else {		
			print header(-type=>$formats{$format}->{'mime'}, -Content_length => $size);
		}
		
		while(($amt = sysread(AUDIO, $data, 4096)) > 0) {
			syswrite(STDOUT, $data, $amt);
		}
		close(AUDIO);
	} else {
		die("Hrm, can't seem to open $path\n");
	}
}

sub message_index() 
{
	my ($folder, $message) = @_;
	my ($mbox, $context) = split(/\@/, param('mailbox'));
	my $passwd = param('password');
	my $message2;
	my $msgcount;	
	my $hasmsg;
	my ($newmessages, $oldmessages);
	my $format = param('format');
	if (!$format) {
		$format = &getcookie('format');
	}
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	if ($folder) {
		$msgcount = &msgcountstr($context, $mbox, $folder);
		$message2 = "   Folder '$folder' has " . &msgcountstr($context, $mbox, $folder);
	} else {
		$newmessages = &msgcount($context, $mbox, "INBOX");
		$oldmessages = &msgcount($context, $mbox, "Old");
		if (($newmessages > 0) || ($oldmessages < 1)) {
			$folder = "INBOX";
		} else {
			$folder = "Old";
		}
		$message2 = "You have";
		if ($newmessages > 0) {
			$message2 .= " $newmessages NEW";
			if ($oldmessages > 0) {
				$message2 .= "and $oldmessages OLD";
				if ($oldmessages != 1) {
					$message2 .= " messages.";
				} else {
					$message2 .= "message.";
				}
			} else {
				if ($newmessages != 1) {
					$message2 .= " messages.";
				} else {
					$message2 .= " message.";
				}
			}
		} else {
			if ($oldmessages > 0) {
				$message2 .= " $oldmessages OLD";
				if ($oldmessages != 1) {
					$message2 .= " messages.";
				} else {
					$message2 .= " message.";
				}
			} else {
				$message2 .= " no messages.";
			}
		}
	}
	
	my $folders = &folder_list('newfolder', $context, $mbox, $folder);
	my $cfolders = &folder_list('changefolder', $context, $mbox, $folder);
	my $mailboxes = &mailbox_list('forwardto', $context, $mbox);
	print header(-cookie => &makecookie($format));
	print <<_EOH;

Asterisk Web-Voicemail: $mbox\@$context $folder

$stdcontainerstart

 $message
 $folder Messages ">$cfolders
 $message2

_EOH

print "  Msg  From  Duration  Date  
\n";
print " 

\n";
foreach $msg (&messages($context, $mbox, $folder)) {

	$fields = &getfields($context, $mbox, $folder, $msg);
	$duration = $fields->{'duration'};
	if ($duration) {
		$duration = sprintf "%d:%02d", $duration / 60, $duration % 60;
	} else {
		$duration = "<i>Unknown</i>";
	}
	$hasmsg++;
	print "<tr><td><input type=checkbox name=\"msgselect\" value=\"$msg\">&nbsp;<b>$msg</b></td><td>$fields->{'callerid'}</td><td>$duration</td><td>$fields->{'origdate'}</td><td><input name='play$msg' alt=\"Play message $msg\" border=0 type=image align=left src=\"$astpath/play.gif\"></td></tr>\n";

}
if (!$hasmsg) {
	print " <P>No messages<P>
";
}

print <<_EOH;

 	 
_EOH

if ($hasmsg) {
print <<_EOH;
	 
	">
	$folders 
	">
	$mailboxes
_EOH
}

print <<_EOH;

$stdcontainerend
\n
_EOH
}

sub validfolder()
{
	my ($folder) = @_;
	return grep(/^$folder$/, @validfolders);
}

sub folder_list()
{
	my ($name, $context, $mbox, $selected) = @_;
	my $f;
	my $count;
	my $tmp = "\n";
	foreach $f (@validfolders) {
		$count =  &msgcount($context, $mbox, $f);
		if ($f eq $selected) {
			$tmp .= "$f ($count)\n";
		} else {
			$tmp .= "$f ($count)\n";
		}
	}
	$tmp .= "";
}

sub message_rename()
{
	my ($context, $mbox, $oldfolder, $old, $newfolder, $new) = @_;
	my ($oldfile, $newfile);
	return if ($old eq $new) && ($oldfolder eq $newfolder);

	if ($context =~ /^(\w+)$/) {
		$context = $1;
	} else {
		die("Invalid Context<BR>\n");
	}
	
	if ($mbox =~ /^(\w+)$/) {
		$mbox = $1;
	} else {
		die ("Invalid mailbox<BR>\n");
	}
	
	if ($oldfolder =~ /^(\w+)$/) {
		$oldfolder = $1;
	} else {
		die("Invalid old folder<BR>\n");
	}
	
	if ($newfolder =~ /^(\w+)$/) {
		$newfolder = $1;
	} else {
		die("Invalid new folder ($newfolder)<BR>\n");
	}
	
	if ($old =~ /^(\d\d\d\d)$/) {
		$old = $1;
	} else {
		die("Invalid old Message<BR>\n");
	}
	
	if ($new =~ /^(\d\d\d\d)$/) {
		$new = $1;
	} else {
		die("Invalid old Message<BR>\n");
	}
	
	my $path = "/var/spool/asterisk/voicemail/$context/$mbox/$newfolder";
	$path =~ /^(.*)$/;
	$path = $1;
	mkdir $path, 0770;
	$path = "/var/spool/asterisk/voicemail/$context/$mbox/$oldfolder";
	opendir(DIR, $path) || die("Unable to open directory\n");
	my @files = grep /^msg${old}\.\w+$/, readdir(DIR);
	closedir(DIR);
	foreach $oldfile (@files) {
		my $tmp = $oldfile;
		if ($tmp =~ /^(msg${old}.\w+)$/) {
			$tmp = $1;
			$oldfile = $path . "/$tmp";
			$tmp =~ s/msg${old}/msg${new}/;
			$newfile = "/var/spool/asterisk/voicemail/$context/$mbox/$newfolder/$tmp";
#			print "Renaming $oldfile to $newfile
\n";
			rename($oldfile, $newfile);
		}
	}
}

sub file_copy()
{
	my ($orig, $new) = @_;
	my $res;
	my $data;
	$orig =~ /^(.*)$/;
	$orig = $1;
	$new =~ /^(.*)$/;
	$new = $1;
	open(IN, "<$orig") || die("Unable to open '$orig'\n");
	open(OUT, ">$new") || DIE("Unable to open '$new'\n");
	while(($res = sysread(IN, $data, 4096)) > 0) {
		syswrite(OUT, $data, $res);
	}
	close(OUT);
	close(IN);
}

sub message_copy()
{
	my ($context, $mbox, $newmbox, $oldfolder, $old, $new) = @_;
	my ($oldfile, $newfile);
	return if ($mbox eq $newmbox);
	
	if ($mbox =~ /^(\w+)$/) {
		$mbox = $1;
	} else {
		die ("Invalid mailbox<BR>\n");
	}

	if ($newmbox =~ /^(\w+)$/) {
		$newmbox = $1;
	} else {
		die ("Invalid new mailbox<BR>\n");
	}
	
	if ($oldfolder =~ /^(\w+)$/) {
		$oldfolder = $1;
	} else {
		die("Invalid old folder<BR>\n");
	}
	
	if ($old =~ /^(\d\d\d\d)$/) {
		$old = $1;
	} else {
		die("Invalid old Message<BR>\n");
	}
	
	if ($new =~ /^(\d\d\d\d)$/) {
		$new = $1;
	} else {
		die("Invalid old Message<BR>\n");
	}
	
	my $path = "/var/spool/asterisk/voicemail/$context/$newmbox";
	$path =~ /^(.*)$/;
	$path = $1;
	mkdir $path, 0770;
	$path = "/var/spool/asterisk/voicemail/$context/$newmbox/INBOX";
	$path =~ /^(.*)$/;
	$path = $1;
	mkdir $path, 0770;
	$path = "/var/spool/asterisk/voicemail/$context/$mbox/$oldfolder";
	opendir(DIR, $path) || die("Unable to open directory\n");
	my @files = grep /^msg${old}\.\w+$/, readdir(DIR);
	closedir(DIR);
	foreach $oldfile (@files) {
		my $tmp = $oldfile;
		if ($tmp =~ /^(msg${old}.\w+)$/) {
			$tmp = $1;
			$oldfile = $path . "/$tmp";
			$tmp =~ s/msg${old}/msg${new}/;
			$newfile = "/var/spool/asterisk/voicemail/$context/$newmbox/INBOX/$tmp";
#			print "Copying $oldfile to $newfile
\n";
			&file_copy($oldfile, $newfile);
		}
	}
}

sub message_delete()
{
	my ($context, $mbox, $folder, $msg) = @_;
	if ($mbox =~ /^(\w+)$/) {
		$mbox = $1;
	} else {
		die ("Invalid mailbox
\n");
	}
	if ($context =~ /^(\w+)$/) {
		$context = $1;
	} else {
		die ("Invalid context
\n");
	}
	if ($folder =~ /^(\w+)$/) {
		$folder = $1;
	} else {
		die("Invalid folder
\n");
	}
	if ($msg =~ /^(\d\d\d\d)$/) {
		$msg = $1;
	} else {
		die("Invalid Message
\n");
	}
	my $path = "/var/spool/asterisk/voicemail/$context/$mbox/$folder";
	opendir(DIR, $path) || die("Unable to open directory\n");
	my @files = grep /^msg${msg}\.\w+$/, readdir(DIR);
	closedir(DIR);
	foreach $oldfile (@files) {
		if ($oldfile =~ /^(msg${msg}.\w+)$/) {
			$oldfile = $path . "/$1";
#			print "Deleting $oldfile
\n";
			unlink($oldfile);
		}
	}
}

sub message_forward()
{
	my ($toindex, @msgs) = @_;
	my $folder = param('folder');
	my ($mbox, $context) = split(/\@/, param('mailbox'));
	my $newmbox = param('forwardto');
	my $msg;
	my $msgcount;
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	$newmbox =~ s/(\w+)(\s+.*)?$/$1/;
	if (!&validmailbox($context, $newmbox)) {
		die("Bah! Not a valid mailbox '$newmbox'\n");
		return "";
	}
	
	my $txt;
	$context = &untaint($context);
	$newmbox = &untaint($newmbox);
	my $path = "/var/spool/asterisk/voicemail/$context/$newmbox/INBOX";
	if ($msgs[0]) {
		if (&lock_path($path) == 0) {
			$msgcount = &msgcount($context, $newmbox, "INBOX");
			
			if ($newmbox ne $mbox) {
	#			print header;
				foreach $msg (@msgs) {
	#				print "Forwarding $msg from $mbox to $newmbox<BR>\n";
					&message_copy($context, $mbox, $newmbox, $folder, $msg, sprintf "%04d", $msgcount);
					$msgcount++;
				}
				$txt = "Forwarded messages " . join(', ', @msgs) . "to $newmbox";
			} else {
				$txt = "Can't forward messages to yourself!\n";
			}
			&unlock_path($path); 
		} else {
			$txt = "Cannot forward messages: Unable to lock path.\n";
		}
	} else {
		$txt = "Please Select Message(s) for this action.\n";
	}
	if ($toindex) {
		&message_index($folder, $txt);
	} else {
		&message_play($txt, $msgs[0]);
	}
}

sub message_delete_or_move()
{
	my ($toindex, $del, @msgs) = @_;
	my $txt;
	my $path;
	my ($y, $x);
	my $folder = param('folder');
	my $newfolder = param('newfolder') unless $del;
	$newfolder =~ s/^(\w+)\s+.*$/$1/;
	my ($mbox, $context) = split(/\@/, param('mailbox'));
	if (!$context) {
		$context = param('context');
	}
	if (!$context) {
		$context = "default";
	}
	my $passwd = param('password');
	$context = &untaint($context);
	$mbox = &untaint($mbox);
	$folder = &untaint($folder);
	$path = "/var/spool/asterisk/voicemail/$context/$mbox/$folder";
	if ($msgs[0]) {
		if (&lock_path($path) == 0) {
			my $msgcount = &msgcount($context, $mbox, $folder);
			my $omsgcount = &msgcount($context, $mbox, $newfolder) if $newfolder;
		#	print header;
			if ($newfolder ne $folder) {
				$y = 0;
				for ($x=0;$x<$msgcount;$x++) {
					my $msg = sprintf "%04d", $x;
					my $newmsg = sprintf "%04d", $y;
					if (grep(/^$msg$/, @msgs)) {
						if ($newfolder) {
							&message_rename($context, $mbox, $folder, $msg, $newfolder, sprintf "%04d", $omsgcount);
							$omsgcount++;
						} else {
							&message_delete($context, $mbox, $folder, $msg);
						}
					} else {
						&message_rename($context, $mbox, $folder, $msg, $folder, $newmsg);
						$y++;
					}
				}
				if ($del) {
					$txt = "Deleted messages "  . join (', ', @msgs);
				} else {
					$txt = "Moved messages "  . join (', ', @msgs) . " to $newfolder";
				}
			} else {
				$txt = "Can't move a message to the same folder they're in already";
			}
			&unlock_path($path);
		} else {
			$txt = "Cannot move/delete messages: Unable to lock path.\n";
		}
	} else {
		$txt = "Please Select Message(s) for this action.\n";
	}
	# Not as many messages now
	$msgcount--;
	if ($toindex || ($msgs[0] >= $msgcount)) {
		&message_index($folder, $txt);	
	} else {
		&message_play($txt, $msgs[0]);
	}
}

if (param()) {
	my $folder = param('folder');
	my $changefolder = param('changefolder');
	$changefolder =~ s/(\w+)\s+.*$/$1/;
	
	my $newfolder = param('newfolder');
	$newfolder =~ s/^(\w+)\s+.*$/$1/;
	if ($newfolder && !&validfolder($newfolder)) {
		print header;
		die("Bah! new folder '$newfolder' isn't a folder.");
	}
	$action = param('action');
	$msgid = param('msgid');
	if (!$action) {
		my ($tmp) = grep /^play\d\d\d\d\.x$/, param;
		if ($tmp =~ /^play(\d\d\d\d)/) {
			$msgid = $1;
			$action = "play";
		} else {
			print header;
			print "No message?<BR>\n";
			return;
		}
	}
	@msgs = param('msgselect');
	@msgs = ($msgid) unless @msgs;
	{
		($mailbox) = &check_login();
		if (length($mailbox)) {
			if ($action eq 'login') {
				&message_index($folder, "Welcome, $mailbox");
			} elsif (($action eq 'refresh') || ($action eq 'index')) {
				&message_index($folder, "Welcome, $mailbox");
			} elsif ($action eq 'change to ->') {
				if (&validfolder($changefolder)) {
					$folder = $changefolder;
					&message_index($folder, "Welcome, $mailbox");
				} else {
					die("Bah!  Not a valid change to folder '$changefolder'\n");
				}
			} elsif ($action eq 'play') {
				&message_play("$mailbox $folder $msgid", $msgid);
			} elsif ($action eq 'preferences') {
				&message_prefs("refresh", $msgid);
			} elsif ($action eq 'download') {
				&message_audio(1);
			} elsif ($action eq 'play ') {
				&message_audio(0);
			} elsif ($action eq 'audio') {
				&message_audio(0);
			} elsif ($action eq 'delete') {
				&message_delete_or_move(1, 1, @msgs);
			} elsif ($action eq 'delete ') {
				&message_delete_or_move(0, 1, @msgs);
			} elsif ($action eq 'forward to ->') {
				&message_forward(1, @msgs);
			} elsif ($action eq 'forward to -> ') {
				&message_forward(0, @msgs);
			} elsif ($action eq 'save to ->') {
				&message_delete_or_move(1, 0, @msgs);
			} elsif ($action eq 'save to -> ') {
				&message_delete_or_move(0, 0, @msgs);
			} elsif ($action eq 'logout') {
				&login_screen("Logged out!\n");
			}
		} else {
			sleep(1);
			&login_screen("Login Incorrect!\n");
		}
	}
} else {
	&login_screen("\ ");
}
