aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rwxr-xr-xapps/Makefile2
-rwxr-xr-xapps/app_voicemail2.c2303
2 files changed, 2304 insertions, 1 deletions
diff --git a/apps/Makefile b/apps/Makefile
index 6e9dafb8f..274f0355c 100755
--- a/apps/Makefile
+++ b/apps/Makefile
@@ -20,7 +20,7 @@ APPS=app_dial.so app_playback.so app_voicemail.so app_directory.so app_intercom.
app_setcidname.so app_lookupcidname.so app_substring.so app_macro.so \
app_authenticate.so app_softhangup.so app_lookupblacklist.so \
app_waitforring.so app_privacy.so app_db.so app_chanisavail.so \
- app_enumlookup.so
+ app_enumlookup.so app_voicemail2.so
#APPS+=app_sql_postgres.so
#APPS+=app_sql_odbc.so
diff --git a/apps/app_voicemail2.c b/apps/app_voicemail2.c
new file mode 100755
index 000000000..0b8348430
--- /dev/null
+++ b/apps/app_voicemail2.c
@@ -0,0 +1,2303 @@
+/*
+ * Asterisk -- A telephony toolkit for Linux.
+ *
+ * Voicemail System (did you ever think it could be so easy?)
+ *
+ * Copyright (C) 1999, Mark Spencer
+ *
+ * Mark Spencer <markster@linux-support.net>
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License
+ */
+
+#include <asterisk/lock.h>
+#include <asterisk/file.h>
+#include <asterisk/logger.h>
+#include <asterisk/channel.h>
+#include <asterisk/pbx.h>
+#include <asterisk/options.h>
+#include <asterisk/config.h>
+#include <asterisk/say.h>
+#include <asterisk/module.h>
+#include <asterisk/adsi.h>
+#include <asterisk/app.h>
+#include <asterisk/manager.h>
+#include <asterisk/dsp.h>
+#include <stdlib.h>
+#include <errno.h>
+#include <unistd.h>
+#include <string.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <sys/time.h>
+#include <sys/stat.h>
+#include <time.h>
+
+#include <pthread.h>
+#include "../asterisk.h"
+#include "../astconf.h"
+
+#define COMMAND_TIMEOUT 5000
+
+#define VOICEMAIL_CONFIG "voicemail.conf"
+#define ASTERISK_USERNAME "asterisk"
+
+#define SENDMAIL "/usr/sbin/sendmail -t"
+
+#define INTRO "vm-intro"
+
+#define MAXMSG 100
+
+#define MAX_OTHER_FORMATS 10
+
+#define VM_SPOOL_DIR AST_SPOOL_DIR "/vm"
+
+#define BASEMAXINLINE 256
+
+#define BASELINELEN 72
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+
+#define BASEMAXINLINE 256
+#define BASELINELEN 72
+#define eol "\r\n"
+
+static int iocp;
+static int iolen;
+static int linelength;
+static int ateof;
+static unsigned char iobuf[BASEMAXINLINE];
+
+static char *tdesc = "Comedian Mail (Voicemail System)";
+
+static char *adapp = "CoMa";
+
+static char *adsec = "_AST";
+
+static char *addesc = "Comedian Mail";
+
+static int adver = 1;
+
+static char *synopsis_vm =
+"Leave a voicemail message";
+
+static char *descrip_vm =
+" VoiceMail([s|u|b]extension): Leaves voicemail for a given extension (must\n"
+"be configured in voicemail.conf). If the extension is preceeded by an 's'"
+"then instructions for leaving the message will be skipped. If the extension\n"
+"is preceeded by 'u' then the \"unavailable\" message will be played (that is, \n"
+"/var/lib/asterisk/sounds/vm/<exten>/unavail) if it exists. If the extension\n"
+"is preceeded by a 'b' then the the busy message will be played (that is,\n"
+"busy instead of unavail). At most one of 's', 'u', or 'b' may be specified.\n"
+"Returns -1 on error or mailbox not found, or if the user hangs up. \n"
+"Otherwise, it returns 0. \n";
+
+static char *synopsis_vmain =
+"Enter voicemail system";
+
+static char *descrip_vmain =
+" VoiceMailMain(): Enters the main voicemail system for the checking of\n"
+"voicemail. The mailbox can be passed as the option, which will stop the\n"
+"voicemail system from prompting the user for the mailbox. If the mailbox\n"
+"is preceded by 's' then the password check will be skipped. Returns -1 if\n"
+"the user hangs up or 0 otherwise.\n";
+
+/* Leave a message */
+static char *app = "VoiceMail2";
+
+/* Check mail, control, etc */
+static char *app2 = "VoiceMailMain2";
+
+STANDARD_LOCAL_USER;
+
+LOCAL_USER_DECL;
+
+static int make_dir(char *dest, int len, char *ext, char *mailbox)
+{
+ return snprintf(dest, len, "%s/%s/%s/%s", (char *)ast_config_AST_SPOOL_DIR,"vm", ext, mailbox);
+}
+
+static int make_file(char *dest, int len, char *dir, int num)
+{
+ return snprintf(dest, len, "%s/msg%04d", dir, num);
+}
+
+static int vm_change_password(char *username, char *password, char *newpassword)
+{
+ /* There's probably a better way of doing this. */
+ /* That's why I've put the password change in a separate function. */
+
+ FILE *configin;
+ FILE *configout;
+ char inbuf[256];
+ char orig[256];
+ char tmpin[AST_CONFIG_MAX_PATH];
+ char tmpout[AST_CONFIG_MAX_PATH];
+ char *user, *pass, *rest, *trim;
+ snprintf((char *)tmpin, sizeof(tmpin)-1, "%s/voicemail.conf",(char *)ast_config_AST_CONFIG_DIR);
+ snprintf((char *)tmpout, sizeof(tmpout)-1, "%s/voicemail.conf.new",(char *)ast_config_AST_CONFIG_DIR);
+ configin = fopen((char *)tmpin,"r");
+ configout = fopen((char *)tmpout,"w+");
+
+ while (!feof(configin)) {
+ /* Read in the line */
+ fgets(inbuf, sizeof(inbuf), configin);
+ if (!feof(configin)) {
+ /* Make a backup of it */
+ memcpy(orig, inbuf, sizeof(orig));
+ /* Strip trailing \n and comment */
+ inbuf[strlen(inbuf) - 1] = '\0';
+ user = strchr(inbuf, ';');
+ if (user)
+ *user = '\0';
+ user=inbuf;
+ while(*user < 33)
+ user++;
+ pass = strchr(user, '=');
+ if (pass > user) {
+ trim = pass - 1;
+ while(*trim && *trim < 33) {
+ *trim = '\0';
+ trim--;
+ }
+ }
+ if (pass) {
+ *pass = '\0';
+ pass++;
+ if (*pass == '>')
+ pass++;
+ while(*pass && *pass < 33)
+ pass++;
+ }
+ if (pass) {
+ rest = strchr(pass,',');
+ if (rest) {
+ *rest = '\0';
+ rest++;
+ }
+ } else
+ rest = NULL;
+ if (user && pass && *user && *pass && !strcmp(user, username) && !strcmp(pass, password)) {
+ /* This is the line */
+ if (rest) {
+ fprintf(configout, "%s => %s,%s\n", username,newpassword,rest);
+ } else {
+ fprintf(configout, "%s => %s\n", username,newpassword);
+ }
+ } else {
+ /* Put it back like it was */
+ fprintf(configout, orig);
+ }
+ }
+ }
+ fclose(configin);
+ fclose(configout);
+
+ unlink((char *)tmpin);
+ rename((char *)tmpout,(char *)tmpin);
+ return(1);
+}
+
+static int
+inbuf(FILE *fi)
+{
+ int l;
+
+ if(ateof)
+ return 0;
+
+ if ( (l = fread(iobuf,1,BASEMAXINLINE,fi)) <= 0) {
+ if(ferror(fi))
+ return -1;
+
+ ateof = 1;
+ return 0;
+ }
+
+ iolen= l;
+ iocp= 0;
+
+ return 1;
+}
+
+static int
+inchar(FILE *fi)
+{
+ if(iocp>=iolen)
+ if(!inbuf(fi))
+ return EOF;
+
+ return iobuf[iocp++];
+}
+
+static int
+ochar(int c, FILE *so)
+{
+ if(linelength>=BASELINELEN) {
+ if(fputs(eol,so)==EOF)
+ return -1;
+
+ linelength= 0;
+ }
+
+ if(putc(((unsigned char)c),so)==EOF)
+ return -1;
+
+ linelength++;
+
+ return 1;
+}
+
+static int base_encode(char *filename, FILE *so)
+{
+ unsigned char dtable[BASEMAXINLINE];
+ int i,hiteof= 0;
+ FILE *fi;
+
+ linelength = 0;
+ iocp = BASEMAXINLINE;
+ iolen = 0;
+ ateof = 0;
+
+ if ( !(fi = fopen(filename, "rb"))) {
+ ast_log(LOG_WARNING, "Failed to open log file: %s: %s\n", filename, strerror(errno));
+ return -1;
+ }
+
+ for(i= 0;i<9;i++){
+ dtable[i]= 'A'+i;
+ dtable[i+9]= 'J'+i;
+ dtable[26+i]= 'a'+i;
+ dtable[26+i+9]= 'j'+i;
+ }
+ for(i= 0;i<8;i++){
+ dtable[i+18]= 'S'+i;
+ dtable[26+i+18]= 's'+i;
+ }
+ for(i= 0;i<10;i++){
+ dtable[52+i]= '0'+i;
+ }
+ dtable[62]= '+';
+ dtable[63]= '/';
+
+ while(!hiteof){
+ unsigned char igroup[3],ogroup[4];
+ int c,n;
+
+ igroup[0]= igroup[1]= igroup[2]= 0;
+
+ for(n= 0;n<3;n++){
+ if ( (c = inchar(fi)) == EOF) {
+ hiteof= 1;
+ break;
+ }
+
+ igroup[n]= (unsigned char)c;
+ }
+
+ if(n> 0){
+ ogroup[0]= dtable[igroup[0]>>2];
+ ogroup[1]= dtable[((igroup[0]&3)<<4)|(igroup[1]>>4)];
+ ogroup[2]= dtable[((igroup[1]&0xF)<<2)|(igroup[2]>>6)];
+ ogroup[3]= dtable[igroup[2]&0x3F];
+
+ if(n<3) {
+ ogroup[3]= '=';
+
+ if(n<2)
+ ogroup[2]= '=';
+ }
+
+ for(i= 0;i<4;i++)
+ ochar(ogroup[i], so);
+ }
+ }
+
+ if(fputs(eol,so)==EOF)
+ return 0;
+
+ fclose(fi);
+
+ return 1;
+}
+
+static int sendmail(char *srcemail, char *email, char *name, int msgnum, char *mailbox, char *callerid, char *attach, char *format, long duration)
+{
+ FILE *p;
+ char date[256];
+ char host[256];
+ char who[256];
+ char bound[256];
+ char fname[256];
+ char dur[256];
+ time_t t;
+ struct tm tm;
+ char *astattach;
+ struct ast_config *cfg;
+ p = popen(SENDMAIL, "w");
+ cfg = ast_load(VOICEMAIL_CONFIG);
+ if (!(astattach = ast_variable_retrieve(cfg, "general", "attach")))
+ astattach = "yes";
+ if (p) {
+ gethostname(host, sizeof(host));
+ if (strchr(srcemail, '@'))
+ strncpy(who, srcemail, sizeof(who)-1);
+ else {
+ snprintf(who, sizeof(who), "%s@%s", srcemail, host);
+ }
+ snprintf(dur, sizeof(dur), "%ld:%02ld", duration / 60, duration % 60);
+ time(&t);
+ localtime_r(&t,&tm);
+ strftime(date, sizeof(date), "%a, %d %b %Y %H:%M:%S %z", &tm);
+ fprintf(p, "Date: %s\n", date);
+ fprintf(p, "From: Asterisk PBX <%s>\n", who);
+ fprintf(p, "To: %s <%s>\n", name, email);
+ fprintf(p, "Subject: [PBX]: New message %d in mailbox %s\n", msgnum, mailbox);
+ fprintf(p, "Message-ID: <Asterisk-%d-%s-%d@%s>\n", msgnum, mailbox, getpid(), host);
+ fprintf(p, "MIME-Version: 1.0\n");
+ if (ast_true(astattach)) {
+ // Something unique.
+ snprintf(bound, sizeof(bound), "Boundary=%d%s%d", msgnum, mailbox, getpid());
+
+ fprintf(p, "Content-Type: MULTIPART/MIXED; BOUNDARY=\"%s\"\n\n\n", bound);
+
+ fprintf(p, "--%s\n", bound);
+ }
+ fprintf(p, "Content-Type: TEXT/PLAIN; charset=US-ASCII\n\n");
+ strftime(date, sizeof(date), "%A, %B %d, %Y at %r", &tm);
+ fprintf(p, "Dear %s:\n\n\tJust wanted to let you know you were just left a %s long message (number %d)\n"
+
+ "in mailbox %s from %s, on %s so you might\n"
+ "want to check it when you get a chance. Thanks!\n\n\t\t\t\t--Asterisk\n\n", name,
+ dur, msgnum, mailbox, (callerid ? callerid : "an unknown caller"), date);
+ if (ast_true(astattach)) {
+ fprintf(p, "--%s\n", bound);
+ fprintf(p, "Content-Type: audio/x-wav; name=\"msg%04d.%s\"\n", msgnum, format);
+ fprintf(p, "Content-Transfer-Encoding: BASE64\n");
+ fprintf(p, "Content-Description: Voicemail sound attachment.\n");
+ fprintf(p, "Content-Disposition: attachment; filename=\"msg%04d.%s\"\n\n", msgnum, format);
+
+ snprintf(fname, sizeof(fname), "%s.%s", attach, format);
+ base_encode(fname, p);
+ fprintf(p, "\n\n--%s--\n.\n", bound);
+ }
+ pclose(p);
+ } else {
+ ast_log(LOG_WARNING, "Unable to launch '%s'\n", SENDMAIL);
+ return -1;
+ }
+ return 0;
+}
+
+static int sendpage(char *srcemail, char *pager, int msgnum, char *mailbox, char *callerid, long duration)
+{
+ FILE *p;
+ char date[256];
+ char host[256];
+ char who[256];
+ char dur[256];
+ time_t t;
+ struct tm tm;
+ struct ast_config *cfg;
+ p = popen(SENDMAIL, "w");
+ cfg = ast_load(VOICEMAIL_CONFIG);
+
+ if (p) {
+ gethostname(host, sizeof(host));
+ if (strchr(srcemail, '@'))
+ strncpy(who, srcemail, sizeof(who)-1);
+ else {
+ snprintf(who, sizeof(who), "%s@%s", srcemail, host);
+ }
+ snprintf(dur, sizeof(dur), "%ld:%02ld", duration / 60, duration % 60);
+ time(&t);
+ localtime_r(&t,&tm);
+ strftime(date, sizeof(date), "%a, %d %b %Y %H:%M:%S %z", &tm);
+ fprintf(p, "Date: %s\n", date);
+ fprintf(p, "From: Asterisk PBX <%s>\n", who);
+ fprintf(p, "To: %s\n", pager);
+ fprintf(p, "Subject: New VM\n\n");
+ strftime(date, sizeof(date), "%A, %B %d, %Y at %r", &tm);
+ fprintf(p, "New %s long msg in box %s\n"
+ "from %s, on %s", dur, mailbox, (callerid ? callerid : "unknown"), date);
+ pclose(p);
+ } else {
+ ast_log(LOG_WARNING, "Unable to launch '%s'\n", SENDMAIL);
+ return -1;
+ }
+ return 0;
+}
+
+static int get_date(char *s, int len)
+{
+ struct tm tm;
+ time_t t;
+ t = time(0);
+ localtime_r(&t,&tm);
+ return strftime(s, len, "%a %b %e %r %Z %Y", &tm);
+}
+
+static int invent_message(struct ast_channel *chan, char *ext, int busy, char *ecodes)
+{
+ int res;
+ char fn[256];
+ snprintf(fn, sizeof(fn), "vm/%s/greet", ext);
+ if (ast_fileexists(fn, NULL, NULL) > 0) {
+ res = ast_streamfile(chan, fn, chan->language);
+ if (res)
+ return -1;
+ res = ast_waitstream(chan, ecodes);
+ if (res)
+ return res;
+ } else {
+ res = ast_streamfile(chan, "vm-theperson", chan->language);
+ if (res)
+ return -1;
+ res = ast_waitstream(chan, ecodes);
+ if (res)
+ return res;
+ res = ast_say_digit_str(chan, ext, ecodes, chan->language);
+ if (res)
+ return res;
+ }
+ if (busy)
+ res = ast_streamfile(chan, "vm-isonphone", chan->language);
+ else
+ res = ast_streamfile(chan, "vm-isunavail", chan->language);
+ if (res)
+ return -1;
+ res = ast_waitstream(chan, ecodes);
+ return res;
+}
+
+static int leave_voicemail(struct ast_channel *chan, char *ext, int silent, int busy, int unavail)
+{
+ struct ast_config *cfg;
+ char *copy, *name, *passwd, *email, *pager, *fmt, *fmts;
+ char comment[256];
+ struct ast_filestream *writer=NULL, *others[MAX_OTHER_FORMATS];
+ char *sfmt[MAX_OTHER_FORMATS];
+ char txtfile[256];
+ FILE *txt;
+ int res = -1, fmtcnt=0, x;
+ int msgnum;
+ int outmsg=0;
+ int wavother=0;
+ int maxmessage=0;
+ struct ast_frame *f;
+ char date[256];
+ char dir[256];
+ char fn[256];
+ char prefile[256]="";
+ char *astemail;
+ char *ecodes = "#";
+ char *s;
+ time_t start;
+ time_t end;
+ struct ast_dsp *sildet; /* silence detector dsp */
+ int totalsilence = 0;
+ int dspsilence = 0;
+ int silence = 0; /* amount of silence to allow */
+ int gotsilence = 0; /* did we timeout for silence? */
+ char *silencestr;
+ char *thresholdstr;
+ int rfmt;
+ int threshold = 128;
+
+ cfg = ast_load(VOICEMAIL_CONFIG);
+ if (!cfg) {
+ ast_log(LOG_WARNING, "No such configuration file %s\n", VOICEMAIL_CONFIG);
+ return -1;
+ }
+ if ((silencestr = ast_variable_retrieve(cfg, "general", "maxsilence"))) {
+ silence = atoi(silencestr);
+ if (silence > 0)
+ silence *= 1000;
+ }
+ if ((thresholdstr = ast_variable_retrieve(cfg, "general", "silencethreshold")))
+ threshold = atoi(thresholdstr);
+
+ if (!(astemail = ast_variable_retrieve(cfg, "general", "serveremail")))
+ astemail = ASTERISK_USERNAME;
+ if ((s = ast_variable_retrieve(cfg, "general", "maxmessage"))) {
+ if (sscanf(s, "%d", &x) == 1) {
+ maxmessage = x;
+ } else {
+ ast_log(LOG_WARNING, "Invalid max message time length\n");
+ }
+ }
+ if ((copy = ast_variable_retrieve(cfg, NULL, ext))) {
+ char *stringp=NULL;
+ /* Setup pre-file if appropriate */
+ if (busy)
+ snprintf(prefile, sizeof(prefile), "vm/%s/busy", ext);
+ else if (unavail)
+ snprintf(prefile, sizeof(prefile), "vm/%s/unavail", ext);
+ /* Make sure they have an entry in the config */
+ copy = strdup(copy);
+ stringp=copy;
+ passwd = strsep(&stringp, ",");
+ name = strsep(&stringp, ",");
+ email = strsep(&stringp, ",");
+ pager = strsep(&stringp, ",");
+ make_dir(dir, sizeof(dir), ext, "");
+ /* It's easier just to try to make it than to check for its existence */
+ if (mkdir(dir, 0700) && (errno != EEXIST))
+ ast_log(LOG_WARNING, "mkdir '%s' failed: %s\n", dir, strerror(errno));
+ make_dir(dir, sizeof(dir), ext, "INBOX");
+ if (mkdir(dir, 0700) && (errno != EEXIST))
+ ast_log(LOG_WARNING, "mkdir '%s' failed: %s\n", dir, strerror(errno));
+ if (ast_exists_extension(chan, strlen(chan->macrocontext) ? chan->macrocontext : chan->context, "o", 1, chan->callerid))
+ ecodes = "#0";
+ /* Play the beginning intro if desired */
+ if (strlen(prefile)) {
+ if (ast_fileexists(prefile, NULL, NULL) > 0) {
+ if (ast_streamfile(chan, prefile, chan->language) > -1)
+ silent = ast_waitstream(chan, "#0");
+ } else {
+ ast_log(LOG_DEBUG, "%s doesn't exist, doing what we can\n", prefile);
+ silent = invent_message(chan, ext, busy, ecodes);
+ }
+ if (silent < 0) {
+ ast_log(LOG_DEBUG, "Hang up during prefile playback\n");
+ free(copy);
+ return -1;
+ }
+ }
+ /* If they hit "#" we should still play the beep sound */
+ if (silent == '#') {
+ if (!ast_streamfile(chan, "beep", chan->language) < 0)
+ silent = 1;
+ if (ast_waitstream(chan, "") <0) {
+ ast_log(LOG_DEBUG, "Hangup during beep\n");
+ free(copy);
+ return -1;
+ }
+ } else if (silent == '0') {
+ strncpy(chan->exten, "o", sizeof(chan->exten) - 1);
+ if (strlen(chan->macrocontext))
+ strncpy(chan->context, chan->macrocontext, sizeof(chan->context) - 1);
+ chan->priority = 0;
+ free(copy);
+ return 0;
+ }
+ /* Stream an info message */
+ if (silent || !ast_streamfile(chan, INTRO, chan->language)) {
+ /* Wait for the message to finish */
+ if (silent || !ast_waitstream(chan, "")) {
+ if (!ast_streamfile(chan, "beep", chan->language) < 0)
+ silent = 1;
+ if (ast_waitstream(chan, "") <0) {
+ ast_log(LOG_DEBUG, "Hangup during beep\n");
+ free(copy);
+ return -1;
+ }
+ fmt = ast_variable_retrieve(cfg, "general", "format");
+ if (fmt) {
+ char *stringp=NULL;
+ fmts = strdup(fmt);
+ stringp=fmts;
+ fmt = strsep(&stringp, "|");
+ msgnum = 0;
+ do {
+ make_file(fn, sizeof(fn), dir, msgnum);
+ snprintf(comment, sizeof(comment), "Voicemail from %s to %s (%s) on %s\n",
+ (chan->callerid ? chan->callerid : "Unknown"),
+ name, ext, chan->name);
+ if (ast_fileexists(fn, NULL, chan->language) > 0) {
+ msgnum++;
+ continue;
+ }
+ writer = ast_writefile(fn, fmt, comment, O_EXCL, 1 /* check for other formats */, 0700);
+ if (!writer)
+ break;
+ msgnum++;
+ } while(!writer && (msgnum < MAXMSG));
+ if (writer) {
+ char *stringp=NULL;
+ /* Store information */
+ snprintf(txtfile, sizeof(txtfile), "%s.txt", fn);
+ txt = fopen(txtfile, "w+");
+ if (txt) {
+ get_date(date, sizeof(date));
+ time(&start);
+ fprintf(txt,
+";\n"
+"; Message Information file\n"
+";\n"
+"[message]\n"
+"origmailbox=%s\n"
+"context=%s\n"
+"exten=%s\n"
+"priority=%d\n"
+"callerchan=%s\n"
+"callerid=%s\n"
+"origdate=%s\n"
+"origtime=%ld\n",
+ ext,
+ chan->context,
+ chan->exten,
+ chan->priority,
+ chan->name,
+ chan->callerid ? chan->callerid : "Unknown",
+ date, time(NULL));
+ fclose(txt);
+ } else
+ ast_log(LOG_WARNING, "Error opening text file for output\n");
+
+ /* We need to reset these values */
+ free(fmts);
+ fmt = ast_variable_retrieve(cfg, "general", "format");
+ fmts = strdup(fmt);
+ stringp=fmts;
+ strsep(&stringp, "|");
+ while((fmt = strsep(&stringp, "|"))) {
+ if (fmtcnt > MAX_OTHER_FORMATS - 1) {
+ ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app_voicemail.c\n");
+ break;
+ }
+ sfmt[fmtcnt++] = strdup(fmt);
+ }
+ for (x=0;x<fmtcnt;x++) {
+ others[x] = ast_writefile(fn, sfmt[x], comment, 0, 0, 0700);
+ if (!others[x]) {
+ /* Ick, the other format didn't work, but be sure not
+ to leak memory here */
+ int y;
+ for(y=x+1;y < fmtcnt;y++)
+ free(sfmt[y]);
+ break;
+ }
+ if(!strcasecmp(sfmt[x], "wav"))
+ wavother++;
+ free(sfmt[x]);
+ }
+
+ sildet = ast_dsp_new(); //Create the silence detector
+ if (silence > 0) {
+ rfmt = chan->readformat;
+ res = ast_set_read_format(chan, AST_FORMAT_SLINEAR);
+ if (res < 0) {
+ ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n");
+ return -1;
+ }
+ if (!sildet) {
+ ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
+ return -1;
+ }
+ ast_dsp_set_threshold(sildet, 50);
+ }
+
+ if (x == fmtcnt) {
+ /* Loop forever, writing the packets we read to the writer(s), until
+ we read a # or get a hangup */
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Recording to %s\n", fn);
+ f = NULL;
+ for(;;) {
+ res = ast_waitfor(chan, 2000);
+ if (!res) {
+ ast_log(LOG_DEBUG, "One waitfor failed, trying another\n");
+ /* Try one more time in case of masq */
+ res = ast_waitfor(chan, 2000);
+ if (!res) {
+ ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name);
+ res = -1;
+ }
+ }
+
+ if (res < 0) {
+ f = NULL;
+ break;
+ }
+
+ f = ast_read(chan);
+ if (!f)
+ break;
+ if (f->frametype == AST_FRAME_VOICE) {
+ /* Write the primary format */
+ res = ast_writestream(writer, f);
+ if (res) {
+ ast_log(LOG_WARNING, "Error writing primary frame\n");
+ break;
+ }
+ /* And each of the others */
+ for (x=0;x<fmtcnt;x++) {
+ res |= ast_writestream(others[x], f);
+ }
+ /* Exit on any error */
+ if (res) {
+ ast_log(LOG_WARNING, "Error writing frame\n");
+ ast_frfree(f);
+ break;
+ }
+ /* Silence Detection */
+ if (silence > 0) {
+ dspsilence = 0;
+ ast_dsp_silence(sildet, f, &dspsilence);
+ if (dspsilence) {
+ totalsilence = dspsilence;
+ } else {
+ totalsilence = 0;
+ }
+ if (totalsilence > silence) {
+ /* Ended happily with silence */
+ outmsg=2;
+ ast_frfree(f);
+ gotsilence = 1;
+ res = 0;
+ break;
+ }
+ }
+
+ } else if (f->frametype == AST_FRAME_DTMF) {
+ if (f->subclass == '#') {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
+ outmsg=2;
+ ast_frfree(f);
+ res = 0;
+ break;
+ }
+ }
+ ast_frfree(f);
+ time(&end);
+ if (maxmessage && (end - start > maxmessage)) {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Message is too long, ending it now...\n");
+ outmsg = 2;
+ res = 0;
+ break;
+ }
+ }
+ if (!f) {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
+ res = -1;
+ outmsg=1;
+ }
+ if (gotsilence) {
+ ast_stream_rewind(writer, silence-1000);
+ ast_truncstream(writer);
+
+ /* And each of the others */
+ for (x=0;x<fmtcnt;x++) {
+ ast_stream_rewind(others[x], silence-1000);
+ ast_truncstream(others[x]);
+ }
+ }
+ } else {
+ ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", fn, sfmt[x]);
+ free(sfmt[x]);
+ }
+
+ ast_closestream(writer);
+ for (x=0;x<fmtcnt;x++) {
+ if (!others[x])
+ break;
+ ast_closestream(others[x]);
+ }
+ if (outmsg) {
+ if (outmsg > 1) {
+ /* Let them know it worked */
+ ast_streamfile(chan, "vm-msgsaved", chan->language);
+ ast_waitstream(chan, "");
+ }
+ txt = fopen(txtfile, "a");
+ if (txt) {
+ time(&end);
+ fprintf(txt, "duration=%ld\n", end-start);
+ fclose(txt);
+ }
+ /* Send e-mail if applicable */
+ if (email)
+ sendmail(astemail, email, name, msgnum, ext, chan->callerid, fn, wavother ? "wav" : fmts, end - start);
+ if (pager)
+ sendpage(astemail, pager, msgnum, ext, chan->callerid, end - start);
+ }
+ } else {
+ if (msgnum < MAXMSG)
+ ast_log(LOG_WARNING, "Error writing to mailbox %s\n", ext);
+ else
+ ast_log(LOG_WARNING, "Too many messages in mailbox %s\n", ext);
+ }
+ free(fmts);
+ } else
+ ast_log(LOG_WARNING, "No format to save messages in \n");
+ }
+ } else
+ ast_log(LOG_WARNING, "Unable to playback instructions\n");
+
+ free(copy);
+ } else
+ ast_log(LOG_WARNING, "No entry in voicemail config file for '%s'\n", ext);
+ ast_destroy(cfg);
+ /* Leave voicemail for someone */
+ manager_event(EVENT_FLAG_CALL, "MessageWaiting", "Mailbox: %s\r\nWaiting: %d\r\n", ext, ast_app_has_voicemail(ext));
+ return res;
+}
+
+static char *mbox(int id)
+{
+ switch(id) {
+ case 0:
+ return "INBOX";
+ case 1:
+ return "Old";
+ case 2:
+ return "Work";
+ case 3:
+ return "Family";
+ case 4:
+ return "Friends";
+ case 5:
+ return "Cust1";
+ case 6:
+ return "Cust2";
+ case 7:
+ return "Cust3";
+ case 8:
+ return "Cust4";
+ case 9:
+ return "Cust5";
+ default:
+ return "Unknown";
+ }
+}
+
+static int count_messages(char *dir)
+{
+ int x;
+ char fn[256];
+ for (x=0;x<MAXMSG;x++) {
+ make_file(fn, sizeof(fn), dir, x);
+ if (ast_fileexists(fn, NULL, NULL) < 1)
+ break;
+ }
+ return x;
+}
+
+static int play_and_wait(struct ast_channel *chan, char *fn)
+{
+ int d;
+ d = ast_streamfile(chan, fn, chan->language);
+ if (d)
+ return d;
+ d = ast_waitstream(chan, AST_DIGIT_ANY);
+ return d;
+}
+
+static int say_and_wait(struct ast_channel *chan, int num)
+{
+ int d;
+ d = ast_say_number(chan, num, AST_DIGIT_ANY, chan->language);
+ return d;
+}
+
+static int copy(char *infile, char *outfile)
+{
+ int ifd;
+ int ofd;
+ int res;
+ int len;
+ char buf[4096];
+ if ((ifd = open(infile, O_RDONLY)) < 0) {
+ ast_log(LOG_WARNING, "Unable to open %s in read-only mode\n", infile);
+ return -1;
+ }
+ if ((ofd = open(outfile, O_WRONLY | O_TRUNC | O_CREAT, 0600)) < 0) {
+ ast_log(LOG_WARNING, "Unable to open %s in write-only mode\n", outfile);
+ close(ifd);
+ return -1;
+ }
+ do {
+ len = read(ifd, buf, sizeof(buf));
+ if (len < 0) {
+ ast_log(LOG_WARNING, "Read failed on %s: %s\n", infile, strerror(errno));
+ close(ifd);
+ close(ofd);
+ unlink(outfile);
+ }
+ if (len) {
+ res = write(ofd, buf, len);
+ if (res != len) {
+ ast_log(LOG_WARNING, "Write failed on %s (%d of %d): %s\n", outfile, res, len, strerror(errno));
+ close(ifd);
+ close(ofd);
+ unlink(outfile);
+ }
+ }
+ } while(len);
+ close(ifd);
+ close(ofd);
+ return 0;
+}
+
+static int save_to_folder(char *dir, int msg, char *username, int box)
+{
+ char sfn[256];
+ char dfn[256];
+ char ddir[256];
+ char txt[256];
+ char ntxt[256];
+ char *dbox = mbox(box);
+ int x;
+ make_file(sfn, sizeof(sfn), dir, msg);
+ make_dir(ddir, sizeof(ddir), username, dbox);
+ mkdir(ddir, 0700);
+ for (x=0;x<MAXMSG;x++) {
+ make_file(dfn, sizeof(dfn), ddir, x);
+ if (ast_fileexists(dfn, NULL, NULL) < 0)
+ break;
+ }
+ if (x >= MAXMSG)
+ return -1;
+ ast_filecopy(sfn, dfn, NULL);
+ if (strcmp(sfn, dfn)) {
+ snprintf(txt, sizeof(txt), "%s.txt", sfn);
+ snprintf(ntxt, sizeof(ntxt), "%s.txt", dfn);
+ copy(txt, ntxt);
+ }
+ return 0;
+}
+
+static int adsi_logo(unsigned char *buf)
+{
+ int bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 1, ADSI_JUST_CENT, 0, "Comedian Mail", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 2, ADSI_JUST_CENT, 0, "(C)2002 LSS, Inc.", "");
+ return bytes;
+}
+
+static int adsi_load_vmail(struct ast_channel *chan, int *useadsi)
+{
+ char buf[256];
+ int bytes=0;
+ int x;
+ char num[5];
+
+ *useadsi = 0;
+ bytes += adsi_data_mode(buf + bytes);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+
+ bytes = 0;
+ bytes += adsi_logo(buf);
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Downloading Scripts", "");
+#ifdef DISPLAY
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, " .", "");
+#endif
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_data_mode(buf + bytes);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+
+ if (adsi_begin_download(chan, addesc, adapp, adsec, adver)) {
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Load Cancelled.", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_CENT, 0, "ADSI Unavailable", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_voice_mode(buf + bytes, 0);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+ return 0;
+ }
+
+#ifdef DISPLAY
+ /* Add a dot */
+ bytes = 0;
+ bytes += adsi_logo(buf);
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Downloading Scripts", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, " ..", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+#endif
+ bytes = 0;
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 0, "Listen", "Listen", "1", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 1, "Folder", "Folder", "2", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 2, "Advanced", "Advnced", "3", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 3, "Options", "Options", "4", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 4, "Help", "Help", "*", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 5, "Exit", "Exit", "#", 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD);
+
+#ifdef DISPLAY
+ /* Add another dot */
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, " ...", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+#endif
+
+ bytes = 0;
+ /* These buttons we load but don't use yet */
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 6, "Previous", "Prev", "4", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 8, "Repeat", "Repeat", "5", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 7, "Delete", "Delete", "7", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 9, "Next", "Next", "6", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 10, "Save", "Save", "9", 1);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 11, "Undelete", "Restore", "7", 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD);
+
+#ifdef DISPLAY
+ /* Add another dot */
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, " ....", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+#endif
+
+ bytes = 0;
+ for (x=0;x<5;x++) {
+ snprintf(num, sizeof(num), "%d", x);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 12 + x, mbox(x), mbox(x), num, 1);
+ }
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 12 + 5, "Cancel", "Cancel", "#", 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD);
+
+#ifdef DISPLAY
+ /* Add another dot */
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, " .....", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+#endif
+
+ if (adsi_end_download(chan)) {
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Download Unsuccessful.", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_CENT, 0, "ADSI Unavailable", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_voice_mode(buf + bytes, 0);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+ return 0;
+ }
+ bytes = 0;
+ bytes += adsi_download_disconnect(buf + bytes);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD);
+
+ ast_log(LOG_DEBUG, "Done downloading scripts...\n");
+
+#ifdef DISPLAY
+ /* Add last dot */
+ bytes = 0;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_CENT, 0, " ......", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+#endif
+ ast_log(LOG_DEBUG, "Restarting session...\n");
+
+ bytes = 0;
+ /* Load the session now */
+ if (adsi_load_session(chan, adapp, adver, 1) == 1) {
+ *useadsi = 1;
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Scripts Loaded!", "");
+ } else
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, "Load Failed!", "");
+
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+ return 0;
+}
+
+static void adsi_begin(struct ast_channel *chan, int *useadsi)
+{
+ int x;
+ if (!adsi_available(chan))
+ return;
+ x = adsi_load_session(chan, adapp, adver, 1);
+ if (x < 0)
+ return;
+ if (!x) {
+ if (adsi_load_vmail(chan, useadsi)) {
+ ast_log(LOG_WARNING, "Unable to upload voicemail scripts\n");
+ return;
+ }
+ } else
+ *useadsi = 1;
+}
+
+static void adsi_login(struct ast_channel *chan)
+{
+ char buf[256];
+ int bytes=0;
+ unsigned char keys[8];
+ int x;
+ if (!adsi_available(chan))
+ return;
+
+ for (x=0;x<8;x++)
+ keys[x] = 0;
+ /* Set one key for next */
+ keys[3] = ADSI_KEY_APPS + 3;
+
+ bytes += adsi_logo(buf + bytes);
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_CENT, 0, " ", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_CENT, 0, " ", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_input_format(buf + bytes, 1, ADSI_DIR_FROM_LEFT, 0, "Mailbox: ******", "");
+ bytes += adsi_input_control(buf + bytes, ADSI_COMM_PAGE, 4, 1, 1, ADSI_JUST_LEFT);
+ bytes += adsi_load_soft_key(buf + bytes, ADSI_KEY_APPS + 3, "Enter", "Enter", "#", 1);
+ bytes += adsi_set_keys(buf + bytes, keys);
+ bytes += adsi_voice_mode(buf + bytes, 0);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_password(struct ast_channel *chan)
+{
+ char buf[256];
+ int bytes=0;
+ unsigned char keys[8];
+ int x;
+ if (!adsi_available(chan))
+ return;
+
+ for (x=0;x<8;x++)
+ keys[x] = 0;
+ /* Set one key for next */
+ keys[3] = ADSI_KEY_APPS + 3;
+
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_input_format(buf + bytes, 1, ADSI_DIR_FROM_LEFT, 0, "Password: ******", "");
+ bytes += adsi_input_control(buf + bytes, ADSI_COMM_PAGE, 4, 0, 1, ADSI_JUST_LEFT);
+ bytes += adsi_set_keys(buf + bytes, keys);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_folders(struct ast_channel *chan, int start, char *label)
+{
+ char buf[256];
+ int bytes=0;
+ unsigned char keys[8];
+ int x,y;
+
+ if (!adsi_available(chan))
+ return;
+
+ for (x=0;x<5;x++) {
+ y = ADSI_KEY_APPS + 12 + start + x;
+ if (y > ADSI_KEY_APPS + 12 + 4)
+ y = 0;
+ keys[x] = ADSI_KEY_SKT | y;
+ }
+ keys[5] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 17);
+ keys[6] = 0;
+ keys[7] = 0;
+
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 1, ADSI_JUST_CENT, 0, label, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 2, ADSI_JUST_CENT, 0, " ", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_set_keys(buf + bytes, keys);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_message(struct ast_channel *chan, char *folder, int msg, int last, int deleted, char *fn)
+{
+ int bytes=0;
+ char buf[256], buf1[256], buf2[256];
+ char fn2[256];
+ char cid[256]="";
+ char *val;
+ char *name, *num;
+ char datetime[21]="";
+ FILE *f;
+
+ unsigned char keys[8];
+
+ int x;
+
+ if (!adsi_available(chan))
+ return;
+
+ /* Retrieve important info */
+ snprintf(fn2, sizeof(fn2), "%s.txt", fn);
+ f = fopen(fn2, "r");
+ if (f) {
+ while(!feof(f)) {
+ fgets(buf, sizeof(buf), f);
+ if (!feof(f)) {
+ char *stringp=NULL;
+ stringp=buf;
+ strsep(&stringp, "=");
+ val = strsep(&stringp, "=");
+ if (val && strlen(val)) {
+ if (!strcmp(buf, "callerid"))
+ strncpy(cid, val, sizeof(cid) - 1);
+ if (!strcmp(buf, "origdate"))
+ strncpy(datetime, val, sizeof(datetime) - 1);
+ }
+ }
+ }
+ fclose(f);
+ }
+ /* New meaning for keys */
+ for (x=0;x<5;x++)
+ keys[x] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 6 + x);
+ keys[6] = 0x0;
+ keys[7] = 0x0;
+
+ if (!msg) {
+ /* No prev key, provide "Folder" instead */
+ keys[0] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 1);
+ }
+ if (msg >= last) {
+ /* If last message ... */
+ if (msg) {
+ /* but not only message, provide "Folder" instead */
+ keys[3] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 1);
+ } else {
+ /* Otherwise if only message, leave blank */
+ keys[3] = 1;
+ }
+ }
+
+ if (strlen(cid)) {
+ ast_callerid_parse(cid, &name, &num);
+ if (!name)
+ name = num;
+ } else
+ name = "Unknown Caller";
+
+ /* If deleted, show "undeleted" */
+ if (deleted)
+ keys[1] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 11);
+
+ /* Except "Exit" */
+ keys[5] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 5);
+ snprintf(buf1, sizeof(buf1), "%s%s", folder,
+ strcasecmp(folder, "INBOX") ? " Messages" : "");
+ snprintf(buf2, sizeof(buf2), "Message %d of %d", msg + 1, last + 1);
+
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 1, ADSI_JUST_LEFT, 0, buf1, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 2, ADSI_JUST_LEFT, 0, buf2, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_LEFT, 0, name, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_LEFT, 0, datetime, "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_set_keys(buf + bytes, keys);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_delete(struct ast_channel *chan, int msg, int last, int deleted)
+{
+ int bytes=0;
+ char buf[256];
+ unsigned char keys[8];
+
+ int x;
+
+ if (!adsi_available(chan))
+ return;
+
+ /* New meaning for keys */
+ for (x=0;x<5;x++)
+ keys[x] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 6 + x);
+
+ keys[6] = 0x0;
+ keys[7] = 0x0;
+
+ if (!msg) {
+ /* No prev key, provide "Folder" instead */
+ keys[0] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 1);
+ }
+ if (msg >= last) {
+ /* If last message ... */
+ if (msg) {
+ /* but not only message, provide "Folder" instead */
+ keys[3] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 1);
+ } else {
+ /* Otherwise if only message, leave blank */
+ keys[3] = 1;
+ }
+ }
+
+ /* If deleted, show "undeleted" */
+ if (deleted)
+ keys[1] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 11);
+
+ /* Except "Exit" */
+ keys[5] = ADSI_KEY_SKT | (ADSI_KEY_APPS + 5);
+ bytes += adsi_set_keys(buf + bytes, keys);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_status(struct ast_channel *chan, int new, int old, int lastmsg)
+{
+ char buf[256], buf1[256], buf2[256];
+ int bytes=0;
+ unsigned char keys[8];
+ int x;
+
+ char *newm = (new == 1) ? "message" : "messages";
+ char *oldm = (old == 1) ? "message" : "messages";
+ if (!adsi_available(chan))
+ return;
+ if (new) {
+ snprintf(buf1, sizeof(buf1), "You have %d new", new);
+ if (old) {
+ strcat(buf1, " and");
+ snprintf(buf2, sizeof(buf2), "%d old %s.", old, oldm);
+ } else {
+ snprintf(buf2, sizeof(buf2), "%s.", newm);
+ }
+ } else if (old) {
+ snprintf(buf1, sizeof(buf1), "You have %d old", old);
+ snprintf(buf2, sizeof(buf2), "%s.", oldm);
+ } else {
+ strcpy(buf1, "You have no messages.");
+ strcpy(buf2, " ");
+ }
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 1, ADSI_JUST_LEFT, 0, buf1, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 2, ADSI_JUST_LEFT, 0, buf2, "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+
+ for (x=0;x<6;x++)
+ keys[x] = ADSI_KEY_SKT | (ADSI_KEY_APPS + x);
+ keys[6] = 0;
+ keys[7] = 0;
+
+ /* Don't let them listen if there are none */
+ if (lastmsg < 0)
+ keys[0] = 1;
+ bytes += adsi_set_keys(buf + bytes, keys);
+
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_status2(struct ast_channel *chan, char *folder, int messages)
+{
+ char buf[256], buf1[256], buf2[256];
+ int bytes=0;
+ unsigned char keys[8];
+ int x;
+
+ char *mess = (messages == 1) ? "message" : "messages";
+
+ if (!adsi_available(chan))
+ return;
+
+ /* Original command keys */
+ for (x=0;x<6;x++)
+ keys[x] = ADSI_KEY_SKT | (ADSI_KEY_APPS + x);
+
+ keys[6] = 0;
+ keys[7] = 0;
+
+ if (messages < 1)
+ keys[0] = 0;
+
+ snprintf(buf1, sizeof(buf1), "%s%s has", folder,
+ strcasecmp(folder, "INBOX") ? " folder" : "");
+
+ if (messages)
+ snprintf(buf2, sizeof(buf2), "%d %s.", messages, mess);
+ else
+ strcpy(buf2, "no messages.");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 1, ADSI_JUST_LEFT, 0, buf1, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 2, ADSI_JUST_LEFT, 0, buf2, "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_LEFT, 0, "", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ bytes += adsi_set_keys(buf + bytes, keys);
+
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+
+}
+
+static void adsi_clear(struct ast_channel *chan)
+{
+ char buf[256];
+ int bytes=0;
+ if (!adsi_available(chan))
+ return;
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static void adsi_goodbye(struct ast_channel *chan)
+{
+ char buf[256];
+ int bytes=0;
+
+ if (!adsi_available(chan))
+ return;
+ bytes += adsi_logo(buf + bytes);
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 3, ADSI_JUST_LEFT, 0, " ", "");
+ bytes += adsi_display(buf + bytes, ADSI_COMM_PAGE, 4, ADSI_JUST_CENT, 0, "Goodbye", "");
+ bytes += adsi_set_line(buf + bytes, ADSI_COMM_PAGE, 1);
+ adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY);
+}
+
+static int get_folder(struct ast_channel *chan, int start)
+{
+ int x;
+ int d;
+ char fn[256];
+ d = play_and_wait(chan, "vm-press");
+ if (d)
+ return d;
+ for (x = start; x< 5; x++) {
+ if ((d = ast_say_number(chan, x, AST_DIGIT_ANY, chan->language)))
+ return d;
+ d = play_and_wait(chan, "vm-for");
+ if (d)
+ return d;
+ snprintf(fn, sizeof(fn), "vm-%s", mbox(x));
+ d = play_and_wait(chan, fn);
+ if (d)
+ return d;
+ d = play_and_wait(chan, "vm-messages");
+ if (d)
+ return d;
+ d = ast_waitfordigit(chan, 500);
+ if (d)
+ return d;
+ }
+ d = play_and_wait(chan, "vm-tocancel");
+ if (d)
+ return d;
+ d = ast_waitfordigit(chan, 4000);
+ return d;
+}
+
+static int
+forward_message(struct ast_channel *chan, struct ast_config *cfg, char *dir, int curmsg, char* myusername)
+{
+ char username[70];
+ char sys[256];
+ char todir[256];
+ int todircount=0;
+ long duration;
+ struct ast_config *mif;
+ char miffile[256];
+ char *copy, *name, *passwd, *email, *pager;
+ char *mycopy, *myname, *mypasswd, *myemail, *mypager;
+ char *astemail;
+ char fn[256];
+ char callerid[512];
+
+ while(1) {
+ ast_streamfile(chan, "vm-extension", chan->language);
+
+ if (ast_readstring(chan, username, sizeof(username) - 1, 2000, 10000, "#") < 0)
+ return 0;
+ if (ast_variable_retrieve(cfg, NULL, username)) {
+ printf("Got %d\n", atoi(username));
+ /* if (play_and_wait(chan, "vm-savedto"))
+ break;
+ */
+
+ snprintf(todir, sizeof(todir), "%s/%s/%s/INBOX", (char *)ast_config_AST_SPOOL_DIR,"vm", username);
+ snprintf(sys, sizeof(sys), "mkdir -p %s\n", todir);
+ puts(sys);
+ system(sys);
+
+ todircount = count_messages(todir);
+
+ snprintf(sys, sizeof(sys), "cp %s/msg%04d.gsm %s/msg%04d.gsm\n", dir, curmsg, todir, todircount);
+ puts(sys);
+ system(sys);
+
+ /* TODO: use config to determine what other formats to copy the message in */
+ snprintf(sys, sizeof(sys), "cp %s/msg%04d.wav %s/msg%04d.wav\n", dir, curmsg, todir, todircount);
+ puts(sys);
+ system(sys);
+
+ /* copy the message information file too */
+ snprintf(sys, sizeof(sys), "cp %s/msg%04d.txt %s/msg%04d.txt\n", dir, curmsg, todir, todircount);
+ puts(sys);
+ system(sys);
+
+ snprintf(fn, sizeof(fn), "%s/msg%04d", todir,todircount);
+
+ /* load the information on the source message so we can send an e-mail like a new message */
+ snprintf(miffile, sizeof(miffile), "%s/msg%04d.txt", dir, curmsg);
+ if ((mif=ast_load(miffile))) {
+
+ /* send an e-mail like it was a new message if appropriate */
+ if ((copy = ast_variable_retrieve(cfg, NULL, username))) {
+ char *stringp=NULL;
+ /* Make sure they have an entry in the config */
+ copy = strdup(copy);
+ stringp=copy;
+ passwd = strsep(&stringp, ",");
+ name = strsep(&stringp, ",");
+ email = strsep(&stringp, ",");
+ pager = strsep(&stringp, ",");
+ }
+
+ if ((mycopy = ast_variable_retrieve(cfg, NULL, myusername))) {
+ char *mystringp=NULL;
+ /* Make sure they have an entry in the config */
+ mycopy = strdup(mycopy);
+ mystringp=mycopy;
+ mypasswd = strsep(&mystringp, ",");
+ myname = strsep(&mystringp, ",");
+ myemail = strsep(&mystringp, ",");
+ mypager = strsep(&mystringp, ",");
+ }
+
+ /* set the outbound email from address */
+ if (!(astemail = ast_variable_retrieve(cfg, "general", "serveremail")))
+ astemail = ASTERISK_USERNAME;
+
+ /* set callerid and duration variables */
+ snprintf(callerid, sizeof(callerid), "FWD from: %s from %s", myname, ast_variable_retrieve(mif, NULL, "callerid"));
+ duration = atol(ast_variable_retrieve(mif, NULL, "duration"));
+
+ if (email)
+ sendmail(astemail, email, name, todircount, username, callerid, fn, "wav", atol(ast_variable_retrieve(mif, NULL, "duration")));
+
+ if (pager)
+ sendpage(astemail, pager, todircount, username, callerid, duration);
+
+ free(copy); /* no leaks here */
+ free(mycopy); /* or here */
+ ast_destroy(mif); /* or here */
+ }
+
+ /* give confirmatopm that the message was saved */
+ if (play_and_wait(chan, "vm-message")) break;
+ if (play_and_wait(chan, "vm-saved")) break;
+
+ break;
+ } else {
+ if ( play_and_wait(chan, "pbx-invalid"))
+ break;
+ }
+ }
+ return 0;
+}
+
+#define WAITCMD(a) do { \
+ d = (a); \
+ if (d < 0) \
+ goto out; \
+ if (d) \
+ goto cmd; \
+} while(0)
+
+#define WAITFILE2(file) do { \
+ if (ast_streamfile(chan, file, chan->language)) \
+ ast_log(LOG_WARNING, "Unable to play message %s\n", file); \
+ d = ast_waitstream(chan, AST_DIGIT_ANY); \
+ if (d < 0) { \
+ goto out; \
+ }\
+} while(0)
+
+#define WAITFILE(file) do { \
+ if (ast_streamfile(chan, file, chan->language)) \
+ ast_log(LOG_WARNING, "Unable to play message %s\n", file); \
+ if ((s = ast_variable_retrieve(cfg, "general", "skipms"))) { \
+ if (sscanf(s, "%d", &x) == 1) \
+ ms = x; \
+ } \
+ d = ast_waitstream_fr(chan, AST_DIGIT_ANY, "#", "*",ms); \
+ if (!d) { \
+ repeats = 0; \
+ goto instructions; \
+ } else if (d < 0) { \
+ goto out; \
+ } else goto cmd;\
+} while(0)
+
+#define PLAYMSG(a) do { \
+ starting = 0; \
+ make_file(fn, sizeof(fn), curdir, a); \
+ adsi_message(chan, curbox, a, lastmsg, deleted[a], fn); \
+ if (!a) \
+ WAITFILE2("vm-first"); \
+ else if (a == lastmsg) \
+ WAITFILE2("vm-last"); \
+ WAITFILE2("vm-message"); \
+ if (a && (a != lastmsg)) { \
+ d = ast_say_number(chan, a + 1, AST_DIGIT_ANY, chan->language); \
+ if (d < 0) goto out; \
+ if (d) goto cmd; \
+ } \
+ make_file(fn, sizeof(fn), curdir, a); \
+ heard[a] = 1; \
+ WAITFILE(fn); \
+} while(0)
+
+#define CLOSE_MAILBOX do { \
+ if (lastmsg > -1) { \
+ /* Get the deleted messages fixed */ \
+ curmsg = -1; \
+ for (x=0;x<=lastmsg;x++) { \
+ if (!deleted[x] && (strcasecmp(curbox, "INBOX") || !heard[x])) { \
+ /* Save this message. It's not in INBOX or hasn't been heard */ \
+ curmsg++; \
+ make_file(fn, sizeof(fn), curdir, x); \
+ make_file(fn2, sizeof(fn2), curdir, curmsg); \
+ if (strcmp(fn, fn2)) { \
+ snprintf(txt, sizeof(txt), "%s.txt", fn); \
+ snprintf(ntxt, sizeof(ntxt), "%s.txt", fn2); \
+ ast_filerename(fn, fn2, NULL); \
+ rename(txt, ntxt); \
+ } \
+ } else if (!strcasecmp(curbox, "INBOX") && heard[x] && !deleted[x]) { \
+ /* Move to old folder before deleting */ \
+ save_to_folder(curdir, x, username, 1); \
+ } \
+ } \
+ for (x = curmsg + 1; x<=lastmsg; x++) { \
+ make_file(fn, sizeof(fn), curdir, x); \
+ snprintf(txt, sizeof(txt), "%s.txt", fn); \
+ ast_filedelete(fn, NULL); \
+ unlink(txt); \
+ } \
+ } \
+ memset(deleted, 0, sizeof(deleted)); \
+ memset(heard, 0, sizeof(heard)); \
+} while(0)
+
+#define OPEN_MAILBOX(a) do { \
+ strcpy(curbox, mbox(a)); \
+ make_dir(curdir, sizeof(curdir), username, curbox); \
+ lastmsg = count_messages(curdir) - 1; \
+ snprintf(vmbox, sizeof(vmbox), "vm-%s", curbox); \
+} while (0)
+
+static int play_and_record(struct ast_channel *chan, char *playfile, char *recordfile, int maxtime)
+{
+ char d, *fmt, *fmts;
+ char comment[256];
+ int x, fmtcnt=1, res=-1,outmsg=0, wavother=0;
+ struct ast_frame *f;
+ struct ast_config *cfg;
+ struct ast_filestream *others[MAX_OTHER_FORMATS];
+ char *sfmt[MAX_OTHER_FORMATS];
+ char *stringp=NULL;
+ time_t start, end;
+
+
+ ast_log(LOG_DEBUG,"play_and_record: %s, %s\n", playfile, recordfile);
+ snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile, recordfile, chan->name);
+
+ d = play_and_wait(chan, playfile);
+ if (d < 0)
+ return -1;
+ ast_streamfile(chan, "beep",chan->language);
+ ast_waitstream(chan,"");
+ cfg = ast_load(VOICEMAIL_CONFIG);
+
+ fmt = ast_variable_retrieve(cfg, "general", "format");
+ ast_log(LOG_DEBUG,"Recording Formats: fmt=%s\n", fmt);
+
+ fmts = strdup(fmt);
+
+ ast_destroy(cfg);
+
+ stringp=fmts;
+ strsep(&stringp, "|");
+ ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
+ sfmt[0] = strdup(fmts);
+
+ while((fmt = strsep(&stringp, "|"))) {
+ if (fmtcnt > MAX_OTHER_FORMATS - 1) {
+ ast_log(LOG_WARNING, "Please increase MAX_OTHER_FORMATS in app_voicemail.c\n");
+ break;
+ }
+ sfmt[fmtcnt++] = strdup(fmt);
+ }
+
+ if (maxtime)
+ time(&start);
+ for (x=0;x<fmtcnt;x++) {
+ others[x] = ast_writefile(recordfile, sfmt[x], comment, O_TRUNC, 0, 0700);
+ ast_verbose( VERBOSE_PREFIX_3 "x=%i, open writing: %s format: %s\n", x, recordfile, sfmt[x]);
+
+ if (!others[x]) {
+ /* Ick, the other format didn't work, but be sure not
+ to leak memory here */
+ int y;
+ for(y=x+1;y < fmtcnt;y++)
+ free(sfmt[y]);
+ break;
+ }
+ if(!strcasecmp(sfmt[x], "wav"))
+ wavother++;
+ free(sfmt[x]);
+ }
+ if (x == fmtcnt) {
+ /* Loop forever, writing the packets we read to the writer(s), until
+ we read a # or get a hangup */
+ f = NULL;
+ for(;;) {
+ res = ast_waitfor(chan, 2000);
+ if (!res) {
+ ast_log(LOG_DEBUG, "One waitfor failed, trying another\n");
+ /* Try one more time in case of masq */
+ res = ast_waitfor(chan, 2000);
+ if (!res) {
+ ast_log(LOG_WARNING, "No audio available on %s??\n", chan->name);
+ res = -1;
+ }
+ }
+
+ if (res < 0) {
+ f = NULL;
+ break;
+ }
+
+ f = ast_read(chan);
+ if (!f)
+ break;
+ if (f->frametype == AST_FRAME_VOICE) {
+ /* write each format */
+ for (x=0;x<fmtcnt;x++) {
+ res = ast_writestream(others[x], f);
+ }
+ /* Exit on any error */
+ if (res) {
+ ast_log(LOG_WARNING, "Error writing frame\n");
+ ast_frfree(f);
+ break;
+ }
+ } else if (f->frametype == AST_FRAME_DTMF) {
+ if (f->subclass == '#') {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
+ outmsg=2;
+ break;
+ }
+ }
+ if (maxtime) {
+ time(&end);
+ if (maxtime < (end - start)) {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Took too long, cutting it short...\n");
+ outmsg=2;
+ break;
+ }
+ }
+ ast_frfree(f);
+ }
+ if (!f) {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
+ res = -1;
+ outmsg=1;
+ }
+ } else {
+ ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", recordfile, sfmt[x]);
+ free(sfmt[x]);
+ }
+
+ for (x=0;x<fmtcnt;x++) {
+ if (!others[x])
+ break;
+ ast_closestream(others[x]);
+ }
+ if (outmsg) {
+ if (outmsg > 1) {
+ /* Let them know it worked */
+ ast_streamfile(chan, "vm-msgsaved", chan->language);
+ ast_waitstream(chan, "");
+ }
+ }
+
+
+ return 0;
+}
+
+
+
+
+static int vm_execmain(struct ast_channel *chan, void *data)
+{
+ /* XXX This is, admittedly, some pretty horrendus code. For some
+ reason it just seemed a lot easier to do with GOTO's. I feel
+ like I'm back in my GWBASIC days. XXX */
+ int res=-1;
+ int valid = 0;
+ int prefix = 0;
+ char d;
+ struct localuser *u;
+ char username[80] ="";
+ char prefixstr[80] ="";
+ char empty[80] = "";
+ char password[80] = "", *copy;
+ char newpassword[80] = "";
+ char newpassword2[80] = "";
+ char curbox[80] = "";
+ char curdir[256] = "";
+ char vmbox[256] = "";
+ char fn[256] = "";
+ char fn2[256] = "";
+ char prefile[256]="";
+ int x;
+ char ntxt[256] = "";
+ char txt[256] = "";
+ int deleted[MAXMSG] = { 0, };
+ int heard[MAXMSG] = { 0, };
+ int newmessages;
+ int oldmessages;
+ int repeats = 0;
+ int curmsg = 0;
+ int lastmsg = 0;
+ int starting = 1;
+ int box;
+ int useadsi = 0;
+ int skipuser = 0;
+ char *s;
+ int ms = 3000;
+ int maxgreet = 0;
+ char tmp[256], *ext;
+ struct ast_config *cfg;
+
+ LOCAL_USER_ADD(u);
+ cfg = ast_load(VOICEMAIL_CONFIG);
+ if (!cfg) {
+ ast_log(LOG_WARNING, "No voicemail configuration\n");
+ goto out;
+ }
+ if ((s = ast_variable_retrieve(cfg, "general", "maxgreet"))) {
+ if (sscanf(s, "%d", &x) == 1) {
+ maxgreet = x;
+ } else {
+ ast_log(LOG_WARNING, "Invalid max message greeting length\n");
+ }
+ }
+ if (chan->_state != AST_STATE_UP)
+ ast_answer(chan);
+
+ if (strlen(data)) {
+ strncpy(tmp, data, sizeof(tmp) - 1);
+ ext = tmp;
+
+ switch (*ext) {
+ case 's':
+ /* We should skip the user's password */
+ valid++;
+ ext++;
+ break;
+ case 'p':
+ /* We should prefix the mailbox with the supplied data */
+ prefix++;
+ ext++;
+ break;
+ }
+
+
+ if (prefix)
+ strncpy(prefixstr, ext, sizeof(prefixstr) - 1);
+ else
+ strncpy(username, ext, sizeof(username) - 1);
+ /* make sure username passed as an option is valid */
+ if (ast_variable_retrieve(cfg, NULL, username))
+ skipuser++;
+ else
+ valid = 0;
+
+ }
+
+ /* If ADSI is supported, setup login screen */
+ adsi_begin(chan, &useadsi);
+ if (!skipuser && useadsi)
+ adsi_login(chan);
+ if (!skipuser && ast_streamfile(chan, "vm-login", chan->language)) {
+ ast_log(LOG_WARNING, "Couldn't stream login file\n");
+ goto out;
+ }
+
+ /* Authenticate them and get their mailbox/password */
+
+ while (!valid) {
+ /* Prompt for, and read in the username */
+ if (!skipuser && ast_readstring(chan, username, sizeof(username) - 1, 2000, 10000, "#") < 0) {
+ ast_log(LOG_WARNING, "Couldn't read username\n");
+ goto out;
+ }
+ if (!strlen(username)) {
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "Username not entered\n");
+ res = 0;
+ goto out;
+ }
+ if (useadsi)
+ adsi_password(chan);
+ if (ast_streamfile(chan, "vm-password", chan->language)) {
+ ast_log(LOG_WARNING, "Unable to stream password file\n");
+ goto out;
+ }
+ if (ast_readstring(chan, password, sizeof(password) - 1, 2000, 10000, "#") < 0) {
+ ast_log(LOG_WARNING, "Unable to read password\n");
+ goto out;
+ }
+ if (prefix) {
+ char fullusername[80] = "";
+ strncpy(fullusername, prefixstr, sizeof(fullusername) - 1);
+ strncat(fullusername, username, sizeof(fullusername) - 1);
+ strncpy(username, fullusername, sizeof(username) - 1);
+ }
+ copy = ast_variable_retrieve(cfg, NULL, username);
+ if (copy) {
+ char *stringp=NULL;
+ copy = strdup(copy);
+ stringp=copy;
+ strsep(&stringp, ",");
+ if (!strcmp(password,copy))
+ valid++;
+ else {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Incorrect password '%s' for user '%s'\n", password, username);
+ if (prefix)
+ strncpy(username, empty, sizeof(username) -1);
+ }
+ free(copy);
+ } else {
+ skipuser = 0;
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "No such user '%s' in config file\n", username);
+ }
+ if (!valid) {
+ if (useadsi)
+ adsi_login(chan);
+ if (ast_streamfile(chan, "vm-incorrect", chan->language))
+ break;
+#if 0
+ if (ast_waitstream(chan, ""))
+ break;
+#endif
+ }
+ }
+
+ if (valid) {
+ snprintf(curdir, sizeof(curdir), "%s/%s/%s", (char *)ast_config_AST_SPOOL_DIR,"vm", username);
+ mkdir(curdir, 0700);
+ OPEN_MAILBOX(1);
+ oldmessages = lastmsg + 1;
+ /* Start in INBOX */
+ OPEN_MAILBOX(0);
+ newmessages = lastmsg + 1;
+
+
+ /* Select proper mailbox FIRST!! */
+ if (!newmessages && oldmessages) {
+ /* If we only have old messages start here */
+ OPEN_MAILBOX(1);
+ }
+
+ if (useadsi)
+ adsi_status(chan, newmessages, oldmessages, lastmsg);
+
+ WAITCMD(play_and_wait(chan, "vm-youhave"));
+ if (newmessages) {
+ WAITCMD(say_and_wait(chan, newmessages));
+ WAITCMD(play_and_wait(chan, "vm-INBOX"));
+
+ if (oldmessages)
+ WAITCMD(play_and_wait(chan, "vm-and"));
+ else {
+ if (newmessages == 1)
+ WAITCMD(play_and_wait(chan, "vm-message"));
+ else
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ }
+
+ }
+ if (oldmessages) {
+ WAITCMD(say_and_wait(chan, oldmessages));
+ WAITCMD(play_and_wait(chan, "vm-Old"));
+ if (oldmessages == 1)
+ WAITCMD(play_and_wait(chan, "vm-message"));
+ else
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ }
+ if (!oldmessages && !newmessages) {
+ WAITCMD(play_and_wait(chan, "vm-no"));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ }
+ repeats = 0;
+ starting = 1;
+instructions:
+ if (starting) {
+ if (lastmsg > -1) {
+ WAITCMD(play_and_wait(chan, "vm-onefor"));
+ WAITCMD(play_and_wait(chan, vmbox));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ }
+ WAITCMD(play_and_wait(chan, "vm-opts"));
+ } else {
+ if (curmsg)
+ WAITCMD(play_and_wait(chan, "vm-prev"));
+ WAITCMD(play_and_wait(chan, "vm-repeat"));
+ if (curmsg != lastmsg)
+ WAITCMD(play_and_wait(chan, "vm-next"));
+ if (!deleted[curmsg])
+ WAITCMD(play_and_wait(chan, "vm-delete"));
+ else
+ WAITCMD(play_and_wait(chan, "vm-undelete"));
+ WAITCMD(play_and_wait(chan, "vm-toforward"));
+ WAITCMD(play_and_wait(chan, "vm-savemessage"));
+ }
+ WAITCMD(play_and_wait(chan, "vm-helpexit"));
+ d = ast_waitfordigit(chan, 6000);
+ if (d < 0)
+ goto out;
+ if (!d) {
+ repeats++;
+ if (repeats > 2) {
+ play_and_wait(chan, "vm-goodbye");
+ goto out;
+ }
+ goto instructions;
+ }
+cmd:
+ switch(d) {
+ case '2':
+ if (useadsi)
+ adsi_folders(chan, 0, "Change to folder...");
+ box = play_and_wait(chan, "vm-changeto");
+ if (box < 0)
+ goto out;
+ while((box < '0') || (box > '9')) {
+ box = get_folder(chan, 0);
+ if (box < 0)
+ goto out;
+ if (box == '#')
+ goto instructions;
+ }
+ box = box - '0';
+ CLOSE_MAILBOX;
+ OPEN_MAILBOX(box);
+ if (useadsi)
+ adsi_status2(chan, curbox, lastmsg + 1);
+ WAITCMD(play_and_wait(chan, vmbox));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ starting = 1;
+ goto instructions;
+ case '4':
+ if (curmsg) {
+ curmsg--;
+ PLAYMSG(curmsg);
+ } else {
+ WAITCMD(play_and_wait(chan, "vm-nomore"));
+ goto instructions;
+ }
+ case '1':
+ curmsg = 0;
+ /* Fall through */
+ case '5':
+ if (lastmsg > -1) {
+ PLAYMSG(curmsg);
+ } else {
+ WAITCMD(play_and_wait(chan, "vm-youhave"));
+ WAITCMD(play_and_wait(chan, "vm-no"));
+ snprintf(fn, sizeof(fn), "vm-%s", curbox);
+ WAITCMD(play_and_wait(chan, fn));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ goto instructions;
+ }
+ case '6':
+ if (curmsg < lastmsg) {
+ curmsg++;
+ PLAYMSG(curmsg);
+ } else {
+ WAITCMD(play_and_wait(chan, "vm-nomore"));
+ goto instructions;
+ }
+ case '7':
+ deleted[curmsg] = !deleted[curmsg];
+ if (useadsi)
+ adsi_delete(chan, curmsg, lastmsg, deleted[curmsg]);
+ if (deleted[curmsg])
+ WAITCMD(play_and_wait(chan, "vm-deleted"));
+ else
+ WAITCMD(play_and_wait(chan, "vm-undeleted"));
+ goto instructions;
+ case '8':
+ if(lastmsg > -1)
+ if(forward_message(chan, cfg, curdir, curmsg, username) < 0)
+ goto out;
+ goto instructions;
+ case '9':
+ if (useadsi)
+ adsi_folders(chan, 1, "Save to folder...");
+ box = play_and_wait(chan, "vm-savefolder");
+ if (box < 0)
+ goto out;
+ while((box < '1') || (box > '9')) {
+ box = get_folder(chan, 1);
+ if (box < 0)
+ goto out;
+ if (box == '#')
+ goto instructions;
+ }
+ box = box - '0';
+ if (option_debug)
+ ast_log(LOG_DEBUG, "Save to folder: %s (%d)\n", mbox(box), box);
+ if (save_to_folder(curdir, curmsg, username, box))
+ goto out;
+ deleted[curmsg]=1;
+ make_file(fn, sizeof(fn), curdir, curmsg);
+ if (useadsi)
+ adsi_message(chan, curbox, curmsg, lastmsg, deleted[curmsg], fn);
+ WAITCMD(play_and_wait(chan, "vm-message"));
+ WAITCMD(say_and_wait(chan, curmsg + 1) );
+ WAITCMD(play_and_wait(chan, "vm-savedto"));
+ snprintf(fn, sizeof(fn), "vm-%s", mbox(box));
+ WAITCMD(play_and_wait(chan, fn));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ goto instructions;
+ case '*':
+ if (!starting) {
+ WAITCMD(play_and_wait(chan, "vm-onefor"));
+ WAITCMD(play_and_wait(chan, vmbox));
+ WAITCMD(play_and_wait(chan, "vm-messages"));
+ WAITCMD(play_and_wait(chan, "vm-opts"));
+ }
+ goto instructions;
+ case '#':
+ ast_stopstream(chan);
+ adsi_goodbye(chan);
+ play_and_wait(chan, "vm-goodbye");
+ res = 0;
+ goto out2;
+
+ case '0':
+ goto vm_options;
+
+ default:
+ goto instructions;
+ }
+ }
+out:
+ adsi_goodbye(chan);
+out2:
+ CLOSE_MAILBOX;
+ ast_stopstream(chan);
+ if (cfg)
+ ast_destroy(cfg);
+ if (useadsi)
+ adsi_unload_session(chan);
+ if (valid) {
+ manager_event(EVENT_FLAG_CALL, "MessageWaiting", "Mailbox: %s\r\nWaiting: %d\r\n", username, ast_app_has_voicemail(username));
+ }
+ LOCAL_USER_REMOVE(u);
+ return res;
+
+vm_options:
+ d = play_and_wait(chan,"vm-options");
+ if (!d)
+ d = ast_waitfordigit(chan,6000);
+ if (d < 0)
+ goto out;
+ switch (d) {
+
+ case '1':
+ snprintf(prefile,sizeof(prefile),"vm/%s/unavail",username);
+ play_and_record(chan,"vm-rec-unv",prefile, maxgreet);
+ break;
+ case '2':
+ snprintf(prefile,sizeof(prefile),"vm/%s/busy",username);
+ play_and_record(chan,"vm-rec-busy",prefile, maxgreet);
+ break;
+ case '3':
+ snprintf(prefile,sizeof(prefile),"vm/%s/greet",username);
+ play_and_record(chan,"vm-rec-name",prefile, maxgreet);
+ break;
+ case '4':
+ newpassword[1] = '\0';
+ newpassword[0] = play_and_wait(chan,"vm-newpassword");
+ if (ast_readstring(chan,newpassword + strlen(newpassword),sizeof(newpassword)-1,2000,10000,"#") < 0) {
+ play_and_wait(chan, "vm-sorry");
+ ast_log(LOG_NOTICE,"Unable to read new password\n");
+ goto vm_options;
+ }
+ newpassword2[1] = '\0';
+ newpassword2[0] = play_and_wait(chan,"vm-reenterpassword");
+
+ if (ast_readstring(chan,newpassword2 + strlen(newpassword2),sizeof(newpassword2)-1,2000,10000,"#") < 0) {
+ play_and_wait(chan, "vm-sorry");
+ ast_log(LOG_NOTICE,"Unable to read re-entered password\n");
+ goto vm_options;
+ }
+ if (strcmp(newpassword, newpassword2)) {
+ ast_log(LOG_NOTICE,"Password mismatch for user %s (%s != %s)\n", username, newpassword, newpassword2);
+ play_and_wait(chan, "vm-mismatch");
+ goto vm_options;
+ }
+ if (vm_change_password(username,password,newpassword) < 0)
+ {
+ ast_log(LOG_DEBUG,"Failed to set new password of user %s\n",username);
+ } else
+ ast_log(LOG_DEBUG,"User %s set password to %s of length %i\n",username,newpassword,strlen(newpassword));
+ play_and_wait(chan,"vm-passchanged");
+ break;
+ case '*':
+ goto instructions;
+
+ default:
+ goto vm_options;
+ }
+ goto vm_options;
+}
+
+static int vm_exec(struct ast_channel *chan, void *data)
+{
+ int res=0, silent=0, busy=0, unavail=0;
+ struct localuser *u;
+ char tmp[256], *ext;
+
+ LOCAL_USER_ADD(u);
+ if (chan->_state != AST_STATE_UP)
+ ast_answer(chan);
+ if (data)
+ strncpy(tmp, data, sizeof(tmp) - 1);
+ else {
+ res = ast_app_getdata(chan, "vm-whichbox", tmp, sizeof(tmp) - 1, 0);
+ if (res < 0)
+ return res;
+ if (!strlen(tmp))
+ return 0;
+ }
+ ext = tmp;
+ if (*ext == 's') {
+ silent++;
+ ext++;
+ } else if (*ext == 'b') {
+ busy++;
+ ext++;
+ } else if (*ext == 'u') {
+ unavail++;
+ ext++;
+ }
+ res = leave_voicemail(chan, ext, silent, busy, unavail);
+ LOCAL_USER_REMOVE(u);
+ return res;
+}
+
+int unload_module(void)
+{
+ int res;
+ STANDARD_HANGUP_LOCALUSERS;
+ res = ast_unregister_application(app);
+ res |= ast_unregister_application(app2);
+ return res;
+}
+
+int load_module(void)
+{
+ int res;
+ res = ast_register_application(app, vm_exec, synopsis_vm, descrip_vm);
+ if (!res)
+ res = ast_register_application(app2, vm_execmain, synopsis_vmain, descrip_vmain);
+ return res;
+}
+
+char *description(void)
+{
+ return tdesc;
+}
+
+int usecount(void)
+{
+ int res;
+ STANDARD_USECOUNT(res);
+ return res;
+}
+
+char *key()
+{
+ return ASTERISK_GPL_KEY;
+}
generated by cgit v1.2.3 (git 2.25.1) at 2024-05-23 07:04:26 +0000