mirror of
https://github.com/asterisk/asterisk.git
synced 2025-10-31 02:37:10 +00:00
Version 0.1.0 from FTP
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@66 65c4cc65-6c06-0410-ace0-fbb531ad65f3
This commit is contained in:
Mark Spencer
71
apps/app_playback.c
Executable file
71
apps/app_playback.c
Executable file
@@ -0,0 +1,71 @@
|
||||
/*
|
||||
* Asterisk -- A telephony toolkit for Linux.
|
||||
*
|
||||
* Trivial application to playback a sound file
|
||||
*
|
||||
* 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/module.h>
|
||||
#include <asterisk/translate.h>
|
||||
#include <string.h>
|
||||
#include <stdlib.h>
|
||||
#include <pthread.h>
|
||||
|
||||
static char *tdesc = "Trivial Playback Application";
|
||||
|
||||
static char *app = "Playback";
|
||||
|
||||
STANDARD_LOCAL_USER;
|
||||
|
||||
LOCAL_USER_DECL;
|
||||
|
||||
static int playback_exec(struct ast_channel *chan, void *data)
|
||||
{
|
||||
int res;
|
||||
struct localuser *u;
|
||||
if (!data) {
|
||||
ast_log(LOG_WARNING, "Playback requires an argument (filename)\n");
|
||||
return -1;
|
||||
}
|
||||
LOCAL_USER_ADD(u);
|
||||
ast_stopstream(chan);
|
||||
res = ast_streamfile(chan, (char *)data);
|
||||
if (!res)
|
||||
res = ast_waitstream(chan, "");
|
||||
ast_stopstream(chan);
|
||||
LOCAL_USER_REMOVE(u);
|
||||
return res;
|
||||
}
|
||||
|
||||
int unload_module(void)
|
||||
{
|
||||
STANDARD_HANGUP_LOCALUSERS;
|
||||
return ast_unregister_application(app);
|
||||
}
|
||||
|
||||
int load_module(void)
|
||||
{
|
||||
return ast_register_application(app, playback_exec);
|
||||
}
|
||||
|
||||
char *description(void)
|
||||
{
|
||||
return tdesc;
|
||||
}
|
||||
|
||||
int usecount(void)
|
||||
{
|
||||
int res;
|
||||
STANDARD_USECOUNT(res);
|
||||
return res;
|
||||
}
|
||||
595
apps/app_voicemail.c
Executable file
595
apps/app_voicemail.c
Executable file
@@ -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;
|
||||
}
|
||||
Reference in New Issue
Block a user