Version 0.1.0 from FTP

git-svn-id: http://svn.digium.com/svn/asterisk/trunk@66 f38db490-d61c-443f-a65b-d21fe96a405b

1 files changed, 595 insertions, 0 deletions

diff --git a/apps/app_voicemail.c b/apps/app_voicemail.c
new file mode 100755
index 000000000..d32a0ef9d
--- /dev/null
+++ b/apps/app_voicemail.c
@@ -0,0 +1,595 @@
+/*
+ * Asterisk -- A telephony toolkit for Linux.
+ *
+ * Voicemail System (did you ever think it could be so easy?)
+ * 
+ * Copyright (C) 1999, Adtran Inc. and Linux Support Services, LLC
+ *
+ * Mark Spencer <markster@linux-support.net>
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License
+ */
+
+#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 <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"
+
+#define COMMAND_TIMEOUT 5000
+
+#define VOICEMAIL_CONFIG "voicemail.conf"
+#define ASTERISK_USERNAME "asterisk"
+
+/*
+#define HOSTNAME_OVERRIDE "linux-support.net"
+*/
+
+#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"
+
+
+static char *tdesc = "Comedian Mail (Voicemail System)";
+
+/* Leave a message */
+static char *app = "VoiceMail";
+
+/* Check mail, control, etc */
+static char *app2 = "VoiceMailMain";
+
+STANDARD_LOCAL_USER;
+
+LOCAL_USER_DECL;
+
+static char *get_dir(char *ext, char *mailbox)
+{
+	char *tmp = malloc(strlen(ext) + strlen(VM_SPOOL_DIR) + 3 + strlen(mailbox));
+	sprintf(tmp, "%s/%s/%s", VM_SPOOL_DIR, ext, mailbox);
+	return tmp;
+}
+static char *get_fn(char *dir, int num)
+{
+	char *tmp = malloc(strlen(dir) + 10);
+	sprintf(tmp, "%s/msg%04d", dir, num);
+	return tmp;
+}
+
+static int announce_message(struct ast_channel *chan, char *dir, int msgcnt)
+{
+	char *fn;
+	int res;
+	res = ast_streamfile(chan, "vm-message");
+	if (!res) {
+		res = ast_waitstream(chan, AST_DIGIT_ANY);
+		if (!res) {
+			res = ast_say_number(chan, msgcnt+1);
+			if (!res) {
+				fn = get_fn(dir, msgcnt);
+				if (fn) {
+					res = ast_streamfile(chan, fn);
+					free(fn);
+				}
+			}
+		}
+	}
+	if (res < 0)
+		ast_log(LOG_WARNING, "Unable to announce message\n");
+	return res;
+}
+static int sendmail(char *email, char *name, int msgnum, char *mailbox)
+{
+	FILE *p;
+	char date[256];
+	char host[256];
+	time_t t;
+	struct tm *tm;
+	p = popen(SENDMAIL, "w");
+	if (p) {
+		gethostname(host, sizeof(host));
+		time(&t);
+		tm = localtime(&t);
+		strftime(date, sizeof(date), "%a, %d %b %Y %H:%M:%S %z", tm);
+		fprintf(p, "Date: %s\n", date);
+		fprintf(p, "Message-ID: <Asterisk-%d-%s-%d@%s>\n", msgnum, mailbox, getpid(), host);
+		fprintf(p, "From: Asterisk PBX <%s@%s>\n", ASTERISK_USERNAME,
+#ifdef HOSTNAME_OVERRIDE
+				HOSTNAME_OVERRIDE
+#else
+				host
+#endif
+				);
+		fprintf(p, "To: %s <%s>\n", name, email);
+		fprintf(p, "Subject: [PBX]: New message %d in mailbox %s\n\n", msgnum, mailbox);
+		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 message (number %d)\n"
+		           "in mailbox %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", name, msgnum, mailbox, date);
+		fprintf(p, ".\n");
+		pclose(p);
+	} else {
+		ast_log(LOG_WARNING, "Unable to launch '%s'\n", SENDMAIL);
+		return -1;
+	}
+	return 0;
+}
+
+static int leave_voicemail(struct ast_channel *chan, char *ext, int silent)
+{
+	struct ast_config *cfg;
+	char *copy, *name, *passwd, *email, *dir, *fmt, *fmts, *fn=NULL;
+	char comment[256];
+	struct ast_filestream *writer, *others[MAX_OTHER_FORMATS];
+	char *sfmt[MAX_OTHER_FORMATS];
+	int res = -1, fmtcnt=0, x;
+	int msgnum;
+	int outmsg=0;
+	struct ast_frame *f;
+	
+	cfg = ast_load(VOICEMAIL_CONFIG);
+	if (!cfg) {
+		ast_log(LOG_WARNING, "No such configuration file %s\n", VOICEMAIL_CONFIG);
+		return -1;
+	}
+	if ((copy = ast_variable_retrieve(cfg, chan->context, ext))) {
+		/* Make sure they have an entry in the config */
+		copy = strdup(copy);
+		passwd = strtok(copy, ",");
+		name = strtok(NULL, ",");
+		email = strtok(NULL, ",");
+		dir = get_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));
+		dir = get_dir(ext, "INBOX");
+		if (mkdir(dir, 0700) && (errno != EEXIST))
+			ast_log(LOG_WARNING, "mkdir '%s' failed: %s\n", dir, strerror(errno));
+		/* Stream an info message */
+		if (silent || !ast_streamfile(chan, INTRO)) {
+			/* Wait for the message to finish */
+			if (silent || !ast_waitstream(chan, "")) {
+				fmt = ast_variable_retrieve(cfg, "general", "format");
+				if (fmt) {
+					fmts = strdup(fmt);
+					fmt = strtok(fmts, "|");
+					msgnum = 0;
+					do {
+						if (fn)
+							free(fn);
+						fn = get_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);
+						writer = ast_writefile(fn, fmt, comment, O_EXCL, 1 /* check for other formats */, 0700);
+						if (!writer && (errno != EEXIST))
+							break;
+						msgnum++;
+					} while(!writer && (msgnum < MAXMSG));
+					if (writer) {
+						/* We need to reset these values */
+						free(fmts);
+						fmt = ast_variable_retrieve(cfg, "general", "format");
+						fmts = strdup(fmt);
+						strtok(fmts, "|");
+						while((fmt = strtok(NULL, "|"))) {
+							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;
+							}
+							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 */
+							if (option_verbose > 2) 
+								ast_verbose( VERBOSE_PREFIX_3 "Recording to %s\n", fn);
+							while((f = ast_read(chan))) {
+								if (f->frametype == AST_FRAME_VOICE) {
+									/* Write the primary format */
+									res = ast_writestream(writer, f);
+									/* And each of the others */
+									for (x=0;x<fmtcnt;x++)
+										res |= ast_writestream(others[x], f);
+									ast_frfree(f);
+									/* Exit on any error */
+									if (res) {
+										ast_log(LOG_WARNING, "Error writing frame\n");
+										break;
+									}
+								}
+								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 (!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", 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");
+								ast_waitstream(chan, "");
+							}
+							/* Send e-mail if applicable */
+							if (email) 
+								sendmail(email, name, msgnum, ext);
+						}
+					} 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);
+					}
+					if (fn)
+						free(fn);
+					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(dir);
+		free(copy);
+	} else
+		ast_log(LOG_WARNING, "No entry in voicemail config file for '%s'\n", ext);
+	ast_destroy(cfg);
+	/* Leave voicemail for someone */
+	return res;
+}
+
+static int vm_execmain(struct ast_channel *chan, void *data)
+{
+	/* XXX This is, admittedly, some pretty horrendus code XXX */
+	int res=-1;
+	int valid = 0;
+	int curmsg = 0;
+	int maxmsg = 0;
+	int x;
+	char *fn, *nfn;
+	char d;
+	struct localuser *u;
+	char username[80];
+	char password[80], *copy;
+	int deleted[MAXMSG];
+	struct ast_config *cfg;
+	int state;
+	char *dir=NULL;
+	
+	LOCAL_USER_ADD(u);
+	cfg = ast_load(VOICEMAIL_CONFIG);
+	if (!cfg) {
+		ast_log(LOG_WARNING, "No voicemail configuration\n");
+		goto out;
+	}
+	if (ast_streamfile(chan, "vm-login"))
+		goto out;
+	do {
+		/* Prompt for, and read in the username */
+		if (ast_readstring(chan, username, sizeof(username), 2000, 5000, "#"))
+			goto out;
+		if (ast_streamfile(chan, "vm-password"))
+			goto out;
+		if (ast_readstring(chan, password, sizeof(password), 2000, 5000, "#"))
+			goto out;
+		copy = ast_variable_retrieve(cfg, chan->context, username);
+		if (copy) {
+			copy = strdup(copy);
+			strtok(copy, ",");
+			if (!strcmp(password,copy))
+				valid++;
+			else if (option_verbose > 2)
+				ast_verbose( VERBOSE_PREFIX_3 "Incorrect password '%s' for user '%s'\n", password, username);
+			free(copy);
+		} else if (option_verbose > 2)
+			ast_verbose( VERBOSE_PREFIX_3 "No such user '%s' in config file\n", username);
+		if (!valid) {
+			if (ast_streamfile(chan, "vm-incorrect"))
+				break;
+			if (ast_waitstream(chan, ""))
+				break;
+		}
+	} while (!valid);
+	if (valid) {
+		dir = get_dir(username, "INBOX");
+		if (!dir) 
+			goto out;
+
+		deleted[0] = 0;
+		/* Find out how many messages are there, mark all as
+		   not deleted. */
+		do {
+			fn = get_fn(dir, maxmsg);
+			if ((res = ast_fileexists(fn, NULL))>0) {
+				maxmsg++;
+				deleted[maxmsg] = 0;
+			}
+			free(fn);
+		} while(res > 0);
+		if (ast_streamfile(chan, "vm-youhave"))
+			goto out;
+		if ((d=ast_waitstream(chan, AST_DIGIT_ANY)) < 0)
+			goto out;
+		ast_stopstream(chan);
+		if (!d) {
+			/* If they haven't interrupted us, play the message count */
+			if (maxmsg > 0) {
+				if ((d = ast_say_number(chan, maxmsg)) < 0)
+					goto out;
+			} else {
+				if (ast_streamfile(chan, "vm-no"))
+					goto out;
+				if ((d=ast_waitstream(chan, AST_DIGIT_ANY)) < 0)
+					goto out;
+				ast_stopstream(chan);
+			}
+			if (!d) {
+				/* And if they still haven't, give them the last word */
+				if (ast_streamfile(chan, ((maxmsg == 1) ? "vm-message" : "vm-messages")))
+					goto out;
+				if (ast_waitstream(chan, AST_DIGIT_ANY) < 0)
+					goto out;
+				ast_stopstream(chan);
+			}
+		}
+		res = -1;
+				
+#define STATE_STARTING 1
+#define STATE_MESSAGE 2
+#define STATE_MESSAGE_PLAYING 3
+		state = STATE_STARTING;
+		ast_log(LOG_EVENT, "User '%s' logged in on channel '%s' with %d message(s).\n", username, chan->name, maxmsg);
+		if (option_verbose > 2)
+			ast_verbose( VERBOSE_PREFIX_3 "User '%s' logged in on channel %s with %d messages\n", username, chan->name, maxmsg);
+		if (!ast_streamfile(chan, "vm-instructions")) {
+			for(;;) {
+				if (chan->stream || (chan->trans && chan->trans->stream)) {
+					d = ast_waitstream(chan, AST_DIGIT_ANY);
+					ast_stopstream(chan);
+					if (!d && (state == STATE_MESSAGE_PLAYING)) {
+						state  = STATE_MESSAGE;
+						/* If it runs out playing a message, then give directions */
+						if (!(d = ast_streamfile(chan, "vm-msginstruct")))
+							d = ast_waitstream(chan, AST_DIGIT_ANY);
+						ast_stopstream(chan);
+					}
+					if (!d)
+						d = ast_waitfordigit(chan, COMMAND_TIMEOUT);
+				} else
+					d = ast_waitfordigit(chan, COMMAND_TIMEOUT);
+				if (d < 0)
+					goto out;
+restart:
+				if (!d || (d == '*')) {
+					/* If they don't say anything, play back a message.  We'll decide which one is
+					   best based up on where they are.  Ditto if they press the '*' key. */
+					switch(state) {
+					case STATE_STARTING:
+						if (ast_streamfile(chan, "vm-instructions"))
+							goto out;
+						break;
+					case STATE_MESSAGE:
+					case STATE_MESSAGE_PLAYING:
+						if (ast_streamfile(chan, "vm-msginstruct"))
+							goto out;
+						break;
+					default:
+						ast_log(LOG_WARNING, "What do I do when they timeout/* in state %d?\n", state);
+					}
+				} else {
+					/* XXX Should we be command-compatible with Meridian mail?  Their system seems
+					       very confusing, but also widely used XXX */
+					/* They've entered (or started to enter) a command */
+					switch(d) {
+					case '0':
+						if (curmsg < maxmsg) {
+							deleted[curmsg] = !deleted[curmsg];
+							if (deleted[curmsg]) {
+								if (ast_streamfile(chan, "vm-deleted"))
+									goto out;
+							} else {
+								if (ast_streamfile(chan, "vm-undeleted"))
+									goto out;
+							}
+						} else {
+							if (ast_streamfile(chan, "vm-nomore"))
+								goto out;
+						}
+						break;
+					case '1':
+						curmsg = 0;
+						if (maxmsg > 0) {
+							/* Yuck */
+							if ((d = announce_message(chan, dir, curmsg)) > 0)
+								goto restart;
+							else if (d < 0)
+								goto out;
+						} else {
+							if (ast_streamfile(chan, "vm-nomore"))
+								goto out;
+						}
+						state = STATE_MESSAGE_PLAYING;
+						break;
+					case '4':
+						if (curmsg > 0)
+							curmsg--;
+						/* Yuck */
+						if ((d = announce_message(chan, dir, curmsg)) > 0)
+							goto restart;
+						else if (d < 0)
+							goto out;
+						state = STATE_MESSAGE_PLAYING;
+						break;
+					case '5':
+						if ((d = announce_message(chan, dir, curmsg)) > 0)
+							goto restart;
+						else if (d < 0)
+							goto out;
+						state = STATE_MESSAGE_PLAYING;
+						break;
+					case '6':
+						if (curmsg < maxmsg - 1) {
+							curmsg++;
+							if ((d = announce_message(chan, dir, curmsg)) > 0)
+								goto restart;
+							else if (d < 0)
+								goto out;
+						} else {
+							if (ast_streamfile(chan, "vm-nomore"))
+								goto out;
+						}
+						state = STATE_MESSAGE_PLAYING;
+						break;
+					/* XXX Message compose? It's easy!  Just read their # and, assuming it's in the config, 
+					       call the routine as if it were called from the PBX proper XXX */
+					case '#':
+						if (ast_streamfile(chan, "vm-goodbye"))
+							goto out;
+						if (ast_waitstream(chan, ""))
+							goto out;
+						res = 0;
+						goto out;
+						break;
+					default:
+						/* Double yuck */
+						d = '*';
+						goto restart;
+					}
+				}
+			}
+		}
+	}
+	
+out:
+	ast_stopstream(chan);
+	if (maxmsg) {
+		/* Get the deleted messages fixed */
+		curmsg = -1;
+		for (x=0;x<maxmsg;x++) {
+			if (!deleted[x]) {
+				curmsg++;
+				fn = get_fn(dir, x);
+				nfn = get_fn(dir, curmsg);
+				if (strcmp(fn, nfn))
+					ast_filerename(fn, nfn, NULL);
+				free(fn);
+				free(nfn);
+			}
+		}
+		for (x = curmsg + 1; x<maxmsg; x++) {
+			fn = get_fn(dir, x);
+			if (fn) {
+				ast_filedelete(fn, NULL);
+				free(fn);
+			}
+		}
+	}
+	if (dir)
+		free(dir);
+	if (cfg)
+		ast_destroy(cfg);
+	LOCAL_USER_REMOVE(u);
+	return res;
+}
+
+static int vm_exec(struct ast_channel *chan, void *data)
+{
+	int res=0, silent=0;
+	struct localuser *u;
+	char *ext = (char *)data;
+	
+	if (!data) {
+		ast_log(LOG_WARNING, "vm requires an argument (extension)\n");
+		return -1;
+	}
+	LOCAL_USER_ADD(u);
+	if (*ext == 's') {
+		silent++;
+		ext++;
+	}
+	res = leave_voicemail(chan, ext, silent);
+	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);
+	if (!res)
+		res = ast_register_application(app2, vm_execmain);
+	return res;
+}
+
+char *description(void)
+{
+	return tdesc;
+}
+
+int usecount(void)
+{
+	int res;
+	STANDARD_USECOUNT(res);
+	return res;
+}