/*
* Asterisk -- A telephony toolkit for Linux.
*
- * Channel Management
+ * Convenient Application Routines
*
- * Copyright (C) 1999, Mark Spencer
+ * Copyright (C) 1999-2004, Digium, Inc.
*
- * Mark Spencer <markster@linux-support.net>
+ * Mark Spencer <markster@digium.com>
*
* This program is free software, distributed under the terms of
* the GNU General Public License
#include "asterisk.h"
#include "astconf.h"
+#define MAX_OTHER_FORMATS 10
+
/* set timeout to 0 for "standard" timeouts. Set timeout to -1 for
"ludicrous time" (essentially never times out) */
int ast_app_getdata(struct ast_channel *c, char *prompt, char *s, int maxlen, int timeout)
return res;
}
+
+int ast_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);
+ ast_stopstream(chan);
+ return d;
+}
+
+static int global_silence_threshold = 128;
+static int global_maxsilence = 0;
+
+int ast_play_and_record(struct ast_channel *chan, char *playfile, char *recordfile, int maxtime, char *fmt, int *duration, int silencethreshold, int maxsilence)
+{
+ char d, *fmts;
+ char comment[256];
+ int x, fmtcnt=1, res=-1,outmsg=0;
+ struct ast_frame *f;
+ struct ast_filestream *others[MAX_OTHER_FORMATS];
+ char *sfmt[MAX_OTHER_FORMATS];
+ char *stringp=NULL;
+ time_t start, end;
+ struct ast_dsp *sildet; /* silence detector dsp */
+ int totalsilence = 0;
+ int dspsilence = 0;
+ int gotsilence = 0; /* did we timeout for silence? */
+ int rfmt=0;
+
+ if (silencethreshold < 0)
+ silencethreshold = global_silence_threshold;
+
+ if (maxsilence < 0)
+ maxsilence = global_maxsilence;
+
+ /* barf if no pointer passed to store duration in */
+ if (duration == NULL) {
+ ast_log(LOG_WARNING, "Error play_and_record called without duration pointer\n");
+ return -1;
+ }
+
+ ast_log(LOG_DEBUG,"play_and_record: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
+ snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
+
+ if (playfile) {
+ d = ast_play_and_wait(chan, playfile);
+ if (d > -1)
+ d = ast_streamfile(chan, "beep",chan->language);
+ if (!d)
+ d = ast_waitstream(chan,"");
+ if (d < 0)
+ return -1;
+ }
+
+ fmts = ast_strdupa(fmt);
+
+ stringp=fmts;
+ strsep(&stringp, "|");
+ ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
+ sfmt[0] = ast_strdupa(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++] = ast_strdupa(fmt);
+ }
+
+ time(&start);
+ end=start; /* pre-initialize end to be same as start in case we never get into loop */
+ 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, %p\n", x, recordfile, sfmt[x], others[x]);
+
+ if (!others[x]) {
+ break;
+ }
+ }
+
+ sildet = ast_dsp_new(); /* Create the silence detector */
+ if (!sildet) {
+ ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
+ return -1;
+ }
+ ast_dsp_set_threshold(sildet, silencethreshold);
+
+ if (maxsilence > 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 (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);
+ }
+
+ /* Silence Detection */
+ if (maxsilence > 0) {
+ dspsilence = 0;
+ ast_dsp_silence(sildet, f, &dspsilence);
+ if (dspsilence)
+ totalsilence = dspsilence;
+ else
+ totalsilence = 0;
+
+ if (totalsilence > maxsilence) {
+ /* Ended happily with silence */
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
+ ast_frfree(f);
+ gotsilence = 1;
+ outmsg=2;
+ break;
+ }
+ }
+ /* Exit on any error */
+ if (res) {
+ ast_log(LOG_WARNING, "Error writing frame\n");
+ ast_frfree(f);
+ break;
+ }
+ } else if (f->frametype == AST_FRAME_VIDEO) {
+ /* Write only once */
+ ast_writestream(others[0], f);
+ } 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);
+ res = '#';
+ outmsg = 2;
+ ast_frfree(f);
+ break;
+ }
+ }
+ if (f->subclass == '0') {
+ /* Check for a '0' during message recording also, in case caller wants operator */
+ if (option_verbose > 2)
+ ast_verbose(VERBOSE_PREFIX_3 "User cancelled by pressing %c\n", f->subclass);
+ res = '0';
+ outmsg = 0;
+ ast_frfree(f);
+ 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;
+ res = 't';
+ ast_frfree(f);
+ break;
+ }
+ }
+ ast_frfree(f);
+ }
+ if (end == start) time(&end);
+ 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]);
+ }
+
+ *duration = end - start;
+
+ for (x=0;x<fmtcnt;x++) {
+ if (!others[x])
+ break;
+ if (totalsilence)
+ ast_stream_rewind(others[x], totalsilence-200);
+ else
+ ast_stream_rewind(others[x], 200);
+ ast_truncstream(others[x]);
+ ast_closestream(others[x]);
+ }
+ if (rfmt) {
+ if (ast_set_read_format(chan, rfmt)) {
+ ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
+ }
+ }
+ if (outmsg) {
+ if (outmsg > 1) {
+ /* Let them know recording is stopped */
+ ast_streamfile(chan, "auth-thankyou", chan->language);
+ ast_waitstream(chan, "");
+ }
+ }
+
+ return res;
+}
+
+int ast_play_and_prepend(struct ast_channel *chan, char *playfile, char *recordfile, int maxtime, char *fmt, int *duration, int beep, int silencethreshold, int maxsilence)
+{
+ char d = 0, *fmts;
+ char comment[256];
+ int x, fmtcnt=1, res=-1,outmsg=0;
+ struct ast_frame *f;
+ struct ast_filestream *others[MAX_OTHER_FORMATS];
+ struct ast_filestream *realfiles[MAX_OTHER_FORMATS];
+ char *sfmt[MAX_OTHER_FORMATS];
+ char *stringp=NULL;
+ time_t start, end;
+ struct ast_dsp *sildet; /* silence detector dsp */
+ int totalsilence = 0;
+ int dspsilence = 0;
+ int gotsilence = 0; /* did we timeout for silence? */
+ int rfmt=0;
+ char prependfile[80];
+
+ if (silencethreshold < 0)
+ silencethreshold = global_silence_threshold;
+
+ if (maxsilence < 0)
+ maxsilence = global_maxsilence;
+
+ /* barf if no pointer passed to store duration in */
+ if (duration == NULL) {
+ ast_log(LOG_WARNING, "Error play_and_prepend called without duration pointer\n");
+ return -1;
+ }
+
+ ast_log(LOG_DEBUG,"play_and_prepend: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
+ snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
+
+ if (playfile || beep) {
+ if (!beep)
+ d = ast_play_and_wait(chan, playfile);
+ if (d > -1)
+ d = ast_streamfile(chan, "beep",chan->language);
+ if (!d)
+ d = ast_waitstream(chan,"");
+ if (d < 0)
+ return -1;
+ }
+ strncpy(prependfile, recordfile, sizeof(prependfile) -1);
+ strncat(prependfile, "-prepend", sizeof(prependfile) - strlen(prependfile) - 1);
+
+ fmts = ast_strdupa(fmt);
+
+ stringp=fmts;
+ strsep(&stringp, "|");
+ ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
+ sfmt[0] = ast_strdupa(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++] = ast_strdupa(fmt);
+ }
+
+ time(&start);
+ end=start; /* pre-initialize end to be same as start in case we never get into loop */
+ for (x=0;x<fmtcnt;x++) {
+ others[x] = ast_writefile(prependfile, sfmt[x], comment, O_TRUNC, 0, 0700);
+ ast_verbose( VERBOSE_PREFIX_3 "x=%i, open writing: %s format: %s, %p\n", x, prependfile, sfmt[x], others[x]);
+ if (!others[x]) {
+ break;
+ }
+ }
+
+ sildet = ast_dsp_new(); /* Create the silence detector */
+ if (!sildet) {
+ ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
+ return -1;
+ }
+ ast_dsp_set_threshold(sildet, silencethreshold);
+
+ if (maxsilence > 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 (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++) {
+ if (!others[x])
+ break;
+ res = ast_writestream(others[x], f);
+ }
+
+ /* Silence Detection */
+ if (maxsilence > 0) {
+ dspsilence = 0;
+ ast_dsp_silence(sildet, f, &dspsilence);
+ if (dspsilence)
+ totalsilence = dspsilence;
+ else
+ totalsilence = 0;
+
+ if (totalsilence > maxsilence) {
+ /* Ended happily with silence */
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
+ ast_frfree(f);
+ gotsilence = 1;
+ outmsg=2;
+ break;
+ }
+ }
+ /* Exit on any error */
+ if (res) {
+ ast_log(LOG_WARNING, "Error writing frame\n");
+ ast_frfree(f);
+ break;
+ }
+ } else if (f->frametype == AST_FRAME_VIDEO) {
+ /* Write only once */
+ ast_writestream(others[0], f);
+ } else if (f->frametype == AST_FRAME_DTMF) {
+ /* stop recording with any digit */
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
+ res = 't';
+ outmsg = 2;
+ ast_frfree(f);
+ 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");
+ res = 't';
+ outmsg=2;
+ ast_frfree(f);
+ break;
+ }
+ }
+ ast_frfree(f);
+ }
+ if (end == start) time(&end);
+ if (!f) {
+ if (option_verbose > 2)
+ ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
+ res = -1;
+ outmsg=1;
+#if 0
+ /* delete all the prepend files */
+ for (x=0;x<fmtcnt;x++) {
+ if (!others[x])
+ break;
+ ast_closestream(others[x]);
+ ast_filedelete(prependfile, sfmt[x]);
+ }
+#endif
+ }
+ } else {
+ ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", prependfile, sfmt[x]);
+ }
+ *duration = end - start;
+#if 0
+ if (outmsg > 1) {
+#else
+ if (outmsg) {
+#endif
+ struct ast_frame *fr;
+ for (x=0;x<fmtcnt;x++) {
+ snprintf(comment, sizeof(comment), "Opening the real file %s.%s\n", recordfile, sfmt[x]);
+ realfiles[x] = ast_readfile(recordfile, sfmt[x], comment, O_RDONLY, 0, 0);
+ if (!others[x] || !realfiles[x])
+ break;
+ if (totalsilence)
+ ast_stream_rewind(others[x], totalsilence-200);
+ else
+ ast_stream_rewind(others[x], 200);
+ ast_truncstream(others[x]);
+ /* add the original file too */
+ while ((fr = ast_readframe(realfiles[x]))) {
+ ast_writestream(others[x],fr);
+ }
+ ast_closestream(others[x]);
+ ast_closestream(realfiles[x]);
+ ast_filerename(prependfile, recordfile, sfmt[x]);
+#if 0
+ ast_verbose("Recording Format: sfmts=%s, prependfile %s, recordfile %s\n", sfmt[x],prependfile,recordfile);
+#endif
+ ast_filedelete(prependfile, sfmt[x]);
+ }
+ }
+ if (rfmt) {
+ if (ast_set_read_format(chan, rfmt)) {
+ ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
+ }
+ }
+ if (outmsg) {
+ if (outmsg > 1) {
+ /* Let them know it worked */
+ ast_streamfile(chan, "auth-thankyou", chan->language);
+ ast_waitstream(chan, "");
+ }
+ }
+ return res;
+}
+
*
* Voicemail System (did you ever think it could be so easy?)
*
- * Copyright (C) 2003, Digium Inc.
+ * Copyright (C) 2003-2004, Digium Inc.
*
* Mark Spencer <markster@digium.com>
*
#define INTRO "vm-intro"
#define MAXMSG 100
-#define MAX_OTHER_FORMATS 10
#define VM_SPOOL_DIR AST_SPOOL_DIR "/vm"
return res;
}
-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);
- ast_stopstream(chan);
- return d;
-}
-
-static int play_and_prepend(struct ast_channel *chan, char *playfile, char *recordfile, int maxtime, char *fmt, int *duration, int beep)
-{
- char d = 0, *fmts;
- char comment[256];
- int x, fmtcnt=1, res=-1,outmsg=0;
- struct ast_frame *f;
- struct ast_filestream *others[MAX_OTHER_FORMATS];
- struct ast_filestream *realfiles[MAX_OTHER_FORMATS];
- char *sfmt[MAX_OTHER_FORMATS];
- char *stringp=NULL;
- time_t start, end;
- struct ast_dsp *sildet; /* silence detector dsp */
- int totalsilence = 0;
- int dspsilence = 0;
- int gotsilence = 0; /* did we timeout for silence? */
- int rfmt=0;
- char prependfile[80];
-
- /* barf if no pointer passed to store duration in */
- if (duration == NULL) {
- ast_log(LOG_WARNING, "Error play_and_prepend called without duration pointer\n");
- return -1;
- }
-
- ast_log(LOG_DEBUG,"play_and_prepend: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
- snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
-
- if (playfile || beep) {
- if (!beep)
- d = play_and_wait(chan, playfile);
- if (d > -1)
- d = ast_streamfile(chan, "beep",chan->language);
- if (!d)
- d = ast_waitstream(chan,"");
- if (d < 0)
- return -1;
- }
- strncpy(prependfile, recordfile, sizeof(prependfile) -1);
- strncat(prependfile, "-prepend", sizeof(prependfile) - strlen(prependfile) - 1);
-
- fmts = ast_strdupa(fmt);
-
- stringp=fmts;
- strsep(&stringp, "|");
- ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
- sfmt[0] = ast_strdupa(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++] = ast_strdupa(fmt);
- }
-
- time(&start);
- end=start; /* pre-initialize end to be same as start in case we never get into loop */
- for (x=0;x<fmtcnt;x++) {
- others[x] = ast_writefile(prependfile, sfmt[x], comment, O_TRUNC, 0, 0700);
- ast_verbose( VERBOSE_PREFIX_3 "x=%i, open writing: %s format: %s, %p\n", x, prependfile, sfmt[x], others[x]);
- if (!others[x]) {
- break;
- }
- }
-
- sildet = ast_dsp_new(); /* Create the silence detector */
- if (!sildet) {
- ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
- return -1;
- }
- ast_dsp_set_threshold(sildet, silencethreshold);
-
- if (maxsilence > 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 (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++) {
- if (!others[x])
- break;
- res = ast_writestream(others[x], f);
- }
-
- /* Silence Detection */
- if (maxsilence > 0) {
- dspsilence = 0;
- ast_dsp_silence(sildet, f, &dspsilence);
- if (dspsilence)
- totalsilence = dspsilence;
- else
- totalsilence = 0;
-
- if (totalsilence > maxsilence) {
- /* Ended happily with silence */
- if (option_verbose > 2)
- ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
- ast_frfree(f);
- gotsilence = 1;
- outmsg=2;
- break;
- }
- }
- /* Exit on any error */
- if (res) {
- ast_log(LOG_WARNING, "Error writing frame\n");
- ast_frfree(f);
- break;
- }
- } else if (f->frametype == AST_FRAME_VIDEO) {
- /* Write only once */
- ast_writestream(others[0], f);
- } else if (f->frametype == AST_FRAME_DTMF) {
- /* stop recording with any digit */
- if (option_verbose > 2)
- ast_verbose( VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass);
- res = 't';
- outmsg = 2;
- ast_frfree(f);
- 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");
- res = 't';
- outmsg=2;
- ast_frfree(f);
- break;
- }
- }
- ast_frfree(f);
- }
- if (end == start) time(&end);
- if (!f) {
- if (option_verbose > 2)
- ast_verbose( VERBOSE_PREFIX_3 "User hung up\n");
- res = -1;
- outmsg=1;
-#if 0
- /* delete all the prepend files */
- for (x=0;x<fmtcnt;x++) {
- if (!others[x])
- break;
- ast_closestream(others[x]);
- ast_filedelete(prependfile, sfmt[x]);
- }
-#endif
- }
- } else {
- ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", prependfile, sfmt[x]);
- }
- *duration = end - start;
-#if 0
- if (outmsg > 1) {
-#else
- if (outmsg) {
-#endif
- struct ast_frame *fr;
- for (x=0;x<fmtcnt;x++) {
- snprintf(comment, sizeof(comment), "Opening the real file %s.%s\n", recordfile, sfmt[x]);
- realfiles[x] = ast_readfile(recordfile, sfmt[x], comment, O_RDONLY, 0, 0);
- if (!others[x] || !realfiles[x])
- break;
- if (totalsilence)
- ast_stream_rewind(others[x], totalsilence-200);
- else
- ast_stream_rewind(others[x], 200);
- ast_truncstream(others[x]);
- /* add the original file too */
- while ((fr = ast_readframe(realfiles[x]))) {
- ast_writestream(others[x],fr);
- }
- ast_closestream(others[x]);
- ast_closestream(realfiles[x]);
- ast_filerename(prependfile, recordfile, sfmt[x]);
-#if 0
- ast_verbose("Recording Format: sfmts=%s, prependfile %s, recordfile %s\n", sfmt[x],prependfile,recordfile);
-#endif
- ast_filedelete(prependfile, sfmt[x]);
- }
- }
- if (rfmt) {
- if (ast_set_read_format(chan, rfmt)) {
- ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
- }
- }
- if (outmsg) {
- if (outmsg > 1) {
- /* Let them know it worked */
- ast_streamfile(chan, "auth-thankyou", chan->language);
- ast_waitstream(chan, "");
- }
- }
- return res;
-}
-
-static int play_and_record(struct ast_channel *chan, char *playfile, char *recordfile, int maxtime, char *fmt, int *duration)
-{
- char d, *fmts;
- char comment[256];
- int x, fmtcnt=1, res=-1,outmsg=0;
- struct ast_frame *f;
- struct ast_filestream *others[MAX_OTHER_FORMATS];
- char *sfmt[MAX_OTHER_FORMATS];
- char *stringp=NULL;
- time_t start, end;
- struct ast_dsp *sildet; /* silence detector dsp */
- int totalsilence = 0;
- int dspsilence = 0;
- int gotsilence = 0; /* did we timeout for silence? */
- int rfmt=0;
-
- /* barf if no pointer passed to store duration in */
- if (duration == NULL) {
- ast_log(LOG_WARNING, "Error play_and_record called without duration pointer\n");
- return -1;
- }
-
- ast_log(LOG_DEBUG,"play_and_record: %s, %s, '%s'\n", playfile ? playfile : "<None>", recordfile, fmt);
- snprintf(comment,sizeof(comment),"Playing %s, Recording to: %s on %s\n", playfile ? playfile : "<None>", recordfile, chan->name);
-
- if (playfile) {
- d = play_and_wait(chan, playfile);
- if (d > -1)
- d = ast_streamfile(chan, "beep",chan->language);
- if (!d)
- d = ast_waitstream(chan,"");
- if (d < 0)
- return -1;
- }
-
- fmts = ast_strdupa(fmt);
-
- stringp=fmts;
- strsep(&stringp, "|");
- ast_log(LOG_DEBUG,"Recording Formats: sfmts=%s\n", fmts);
- sfmt[0] = ast_strdupa(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++] = ast_strdupa(fmt);
- }
-
- time(&start);
- end=start; /* pre-initialize end to be same as start in case we never get into loop */
- 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, %p\n", x, recordfile, sfmt[x], others[x]);
-
- if (!others[x]) {
- break;
- }
- }
-
- sildet = ast_dsp_new(); /* Create the silence detector */
- if (!sildet) {
- ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
- return -1;
- }
- ast_dsp_set_threshold(sildet, silencethreshold);
-
- if (maxsilence > 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 (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);
- }
-
- /* Silence Detection */
- if (maxsilence > 0) {
- dspsilence = 0;
- ast_dsp_silence(sildet, f, &dspsilence);
- if (dspsilence)
- totalsilence = dspsilence;
- else
- totalsilence = 0;
-
- if (totalsilence > maxsilence) {
- /* Ended happily with silence */
- if (option_verbose > 2)
- ast_verbose( VERBOSE_PREFIX_3 "Recording automatically stopped after a silence of %d seconds\n", totalsilence/1000);
- ast_frfree(f);
- gotsilence = 1;
- outmsg=2;
- break;
- }
- }
- /* Exit on any error */
- if (res) {
- ast_log(LOG_WARNING, "Error writing frame\n");
- ast_frfree(f);
- break;
- }
- } else if (f->frametype == AST_FRAME_VIDEO) {
- /* Write only once */
- ast_writestream(others[0], f);
- } 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);
- res = '#';
- outmsg = 2;
- ast_frfree(f);
- break;
- }
- }
- if (f->subclass == '0') {
- /* Check for a '0' during message recording also, in case caller wants operator */
- if (option_verbose > 2)
- ast_verbose(VERBOSE_PREFIX_3 "User cancelled by pressing %c\n", f->subclass);
- res = '0';
- outmsg = 0;
- ast_frfree(f);
- 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;
- res = 't';
- ast_frfree(f);
- break;
- }
- }
- ast_frfree(f);
- }
- if (end == start) time(&end);
- 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]);
- }
-
- *duration = end - start;
-
- for (x=0;x<fmtcnt;x++) {
- if (!others[x])
- break;
- if (totalsilence)
- ast_stream_rewind(others[x], totalsilence-200);
- else
- ast_stream_rewind(others[x], 200);
- ast_truncstream(others[x]);
- ast_closestream(others[x]);
- }
- if (rfmt) {
- if (ast_set_read_format(chan, rfmt)) {
- ast_log(LOG_WARNING, "Unable to restore format %s to channel '%s'\n", ast_getformatname(rfmt), chan->name);
- }
- }
- if (outmsg) {
- if (outmsg > 1) {
- /* Let them know recording is stopped */
- ast_streamfile(chan, "auth-thankyou", chan->language);
- ast_waitstream(chan, "");
- }
- }
-
- return res;
-}
-
static void free_user(struct ast_vm_user *vmu)
{
if (vmu->alloced)
int x;
int d;
char fn[256];
- d = play_and_wait(chan, "vm-press"); /* "Press" */
+ d = ast_play_and_wait(chan, "vm-press"); /* "Press" */
if (d)
return d;
for (x = start; x< 5; x++) { /* For all folders */
if ((d = ast_say_number(chan, x, AST_DIGIT_ANY, chan->language, (char *) NULL)))
return d;
- d = play_and_wait(chan, "vm-for"); /* "for" */
+ d = ast_play_and_wait(chan, "vm-for"); /* "for" */
if (d)
return d;
if (!strcasecmp(chan->language, "es") || !strcasecmp(chan->language, "fr") || !strcasecmp(chan->language, "pt")) { /* Spanish, French or Portuguese syntax */
- d = play_and_wait(chan, "vm-messages"); /* "messages */
+ d = ast_play_and_wait(chan, "vm-messages"); /* "messages */
if (d)
return d;
snprintf(fn, sizeof(fn), "vm-%s", mbox(x)); /* Folder name */
- d = play_and_wait(chan, fn);
+ d = ast_play_and_wait(chan, fn);
if (d)
return d;
} else { /* Default English */
snprintf(fn, sizeof(fn), "vm-%s", mbox(x)); /* Folder name */
- d = play_and_wait(chan, fn);
+ d = ast_play_and_wait(chan, fn);
if (d)
return d;
- d = play_and_wait(chan, "vm-messages"); /* "messages */
+ d = ast_play_and_wait(chan, "vm-messages"); /* "messages */
if (d)
return d;
}
if (d)
return d;
}
- d = play_and_wait(chan, "vm-tocancel"); /* "or pound to cancel" */
+ d = ast_play_and_wait(chan, "vm-tocancel"); /* "or pound to cancel" */
if (d)
return d;
d = ast_waitfordigit(chan, 4000);
static int get_folder2(struct ast_channel *chan, char *fn, int start)
{
int res = 0;
- res = play_and_wait(chan, fn); /* Folder name */
+ res = ast_play_and_wait(chan, fn); /* Folder name */
while (((res < '0') || (res > '9')) &&
(res != '#') && (res >= 0)) {
res = get_folder(chan, 0);
{
char file[200];
snprintf(file, sizeof(file), "%s/msg%04d", curdir, curmsg);
- cmd = play_and_prepend(chan, NULL, file, 0, vmfmts, &duration, 1);
+ cmd = ast_play_and_prepend(chan, NULL, file, 0, vmfmts, &duration, 1, silencethreshold, maxsilence);
break;
}
case '2':
cmd = '*';
break;
default:
- cmd = play_and_wait(chan,"vm-forwardoptions");
+ cmd = ast_play_and_wait(chan,"vm-forwardoptions");
/* "Press 1 to prepend a message or 2 to forward the message without prepending" */
if (!cmd)
- cmd = play_and_wait(chan,"vm-starmain");
+ cmd = ast_play_and_wait(chan,"vm-starmain");
/* "press star to return to the main menu" */
if (!cmd)
cmd = ast_waitfordigit(chan,6000);
if (valid_extensions)
break;
/* "I am sorry, that's not a valid extension. Please try again." */
- res = play_and_wait(chan, "pbx-invalid");
+ res = ast_play_and_wait(chan, "pbx-invalid");
}
/* check if we're clear to proceed */
if (!extensions || !valid_extensions)
cmd = vm_forwardoptions(chan, sender, dir, curmsg, vmfmts, context);
if (!cmd) {
while(!res && vmtmp) {
- /* if (play_and_wait(chan, "vm-savedto"))
+ /* if (ast_play_and_wait(chan, "vm-savedto"))
break;
*/
snprintf(todir, sizeof(todir), "%s/voicemail/%s/%s/INBOX", (char *)ast_config_AST_SPOOL_DIR, vmtmp->context, vmtmp->mailbox);
/* give confirmation that the message was saved */
/* commented out since we can't forward batches yet
if (saved_messages == 1)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, "vm-saved"); */
+ res = ast_play_and_wait(chan, "vm-saved"); */
if (!res)
- res = play_and_wait(chan, "vm-msgsaved");
+ res = ast_play_and_wait(chan, "vm-msgsaved");
}
}
}
{
/* Introduce messages they have */
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
res = say_and_wait(chan, vms->newmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
else if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res && vms->oldmessages) {
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
}
{
/* Introduce messages they have */
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "digits/1F");
+ res = ast_play_and_wait(chan, "digits/1F");
else
res = say_and_wait(chan, vms->newmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
else if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res && vms->oldmessages) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "digits/1F");
+ res = ast_play_and_wait(chan, "digits/1F");
else
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
}
/* Introduce messages they have */
int res;
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-youhaveno");
+ res = ast_play_and_wait(chan, "vm-youhaveno");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
} else {
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
}
if (!res) {
if (vms->newmessages) {
if (!res) {
if ((vms->newmessages == 1)) {
- res = play_and_wait(chan, "digits/1M");
+ res = ast_play_and_wait(chan, "digits/1M");
if (!res)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
if (!res)
- res = play_and_wait(chan, "vm-INBOXs");
+ res = ast_play_and_wait(chan, "vm-INBOXs");
} else {
res = say_and_wait(chan, vms->newmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
}
}
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
}
if (vms->oldmessages) {
if (!res) {
if (vms->oldmessages == 1) {
- res = play_and_wait(chan, "digits/1M");
+ res = ast_play_and_wait(chan, "digits/1M");
if (!res)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
if (!res)
- res = play_and_wait(chan, "vm-Olds");
+ res = ast_play_and_wait(chan, "vm-Olds");
} else {
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
}
}
}
{
/* Introduce messages they have */
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
res = say_and_wait(chan, vms->newmessages, chan->language);
if (!res)
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
else if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
if (!res)
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
}
{
/* Introduce messages they have */
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
res = say_and_wait(chan, vms->newmessages, chan->language);
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-INBOXs");
+ res = ast_play_and_wait(chan, "vm-INBOXs");
else
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
}
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
else if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-Olds");
+ res = ast_play_and_wait(chan, "vm-Olds");
else
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
}
if (!res) {
if (vms->oldmessages == 1)
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
else
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
}
{
/* Introduce messages they have */
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
res = ast_say_number(chan, vms->newmessages, AST_DIGIT_ANY, chan->language, "f");
if (!res) {
if ((vms->newmessages == 1)) {
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
if (!res)
- res = play_and_wait(chan, "vm-INBOXs");
+ res = ast_play_and_wait(chan, "vm-INBOXs");
} else {
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, "vm-INBOX");
+ res = ast_play_and_wait(chan, "vm-INBOX");
}
}
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
}
if (!res && vms->oldmessages) {
res = ast_say_number(chan, vms->oldmessages, AST_DIGIT_ANY, chan->language, "f");
if (!res) {
if (vms->oldmessages == 1) {
- res = play_and_wait(chan, "vm-message");
+ res = ast_play_and_wait(chan, "vm-message");
if (!res)
- res = play_and_wait(chan, "vm-Olds");
+ res = ast_play_and_wait(chan, "vm-Olds");
} else {
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, "vm-Old");
+ res = ast_play_and_wait(chan, "vm-Old");
}
}
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
}
static int vm_intro_cz(struct ast_channel *chan,struct vm_state *vms)
{
int res;
- res = play_and_wait(chan, "vm-youhave");
+ res = ast_play_and_wait(chan, "vm-youhave");
if (!res) {
if (vms->newmessages) {
if (vms->newmessages == 1) {
- res = play_and_wait(chan, "digits/jednu");
+ res = ast_play_and_wait(chan, "digits/jednu");
} else {
res = say_and_wait(chan, vms->newmessages, chan->language);
}
if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-novou");
+ res = ast_play_and_wait(chan, "vm-novou");
if ((vms->newmessages) > 1 && (vms->newmessages < 5))
- res = play_and_wait(chan, "vm-nove");
+ res = ast_play_and_wait(chan, "vm-nove");
if (vms->newmessages > 4)
- res = play_and_wait(chan, "vm-novych");
+ res = ast_play_and_wait(chan, "vm-novych");
}
if (vms->oldmessages && !res)
- res = play_and_wait(chan, "vm-and");
+ res = ast_play_and_wait(chan, "vm-and");
else if (!res) {
if ((vms->newmessages == 1))
- res = play_and_wait(chan, "vm-zpravu");
+ res = ast_play_and_wait(chan, "vm-zpravu");
if ((vms->newmessages) > 1 && (vms->newmessages < 5))
- res = play_and_wait(chan, "vm-zpravy");
+ res = ast_play_and_wait(chan, "vm-zpravy");
if (vms->newmessages > 4)
- res = play_and_wait(chan, "vm-zprav");
+ res = ast_play_and_wait(chan, "vm-zprav");
}
}
if (!res && vms->oldmessages) {
res = say_and_wait(chan, vms->oldmessages, chan->language);
if (!res) {
if ((vms->oldmessages == 1))
- res = play_and_wait(chan, "vm-starou");
+ res = ast_play_and_wait(chan, "vm-starou");
if ((vms->oldmessages) > 1 && (vms->oldmessages < 5))
- res = play_and_wait(chan, "vm-stare");
+ res = ast_play_and_wait(chan, "vm-stare");
if (vms->oldmessages > 4)
- res = play_and_wait(chan, "vm-starych");
+ res = ast_play_and_wait(chan, "vm-starych");
}
if (!res) {
if ((vms->oldmessages == 1))
- res = play_and_wait(chan, "vm-zpravu");
+ res = ast_play_and_wait(chan, "vm-zpravu");
if ((vms->oldmessages) > 1 && (vms->oldmessages < 5))
- res = play_and_wait(chan, "vm-zpravy");
+ res = ast_play_and_wait(chan, "vm-zpravy");
if (vms->oldmessages > 4)
- res = play_and_wait(chan, "vm-zprav");
+ res = ast_play_and_wait(chan, "vm-zprav");
}
}
if (!res) {
if (!vms->oldmessages && !vms->newmessages) {
- res = play_and_wait(chan, "vm-no");
+ res = ast_play_and_wait(chan, "vm-no");
if (!res)
- res = play_and_wait(chan, "vm-zpravy");
+ res = ast_play_and_wait(chan, "vm-zpravy");
}
}
}
while(!res) {
if (vms->starting) {
if (vms->lastmsg > -1) {
- res = play_and_wait(chan, "vm-onefor");
+ res = ast_play_and_wait(chan, "vm-onefor");
if (!strcasecmp(chan->language, "es") || !strcasecmp(chan->language, "fr") || !strcasecmp(chan->language, "pt")) { /* Spanish, French & Portuguese Syntax */
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
if (!res)
- res = play_and_wait(chan, vms->vmbox);
+ res = ast_play_and_wait(chan, vms->vmbox);
} else { /* Default English syntax */
if (!res)
- res = play_and_wait(chan, vms->vmbox);
+ res = ast_play_and_wait(chan, vms->vmbox);
if (!res)
- res = play_and_wait(chan, "vm-messages");
+ res = ast_play_and_wait(chan, "vm-messages");
}
}
if (!res)
- res = play_and_wait(chan, "vm-opts");
+ res = ast_play_and_wait(chan, "vm-opts");
} else {
if (vms->curmsg)
- res = play_and_wait(chan, "vm-prev");
+ res = ast_play_and_wait(chan, "vm-prev");
if (!res && !skipadvanced)
- res = play_and_wait(chan, "vm-advopts");
+ res = ast_play_and_wait(chan, "vm-advopts");
if (!res)
- res = play_and_wait(chan, "vm-repeat");
+ res = ast_play_and_wait(chan, "vm-repeat");
if (!res && (vms->curmsg != vms->lastmsg))
- res = play_and_wait(chan, "vm-next");
+ res = ast_play_and_wait(chan, "vm-next");
if (!res) {
if (!vms->deleted[vms->curmsg])
- res = play_and_wait(chan, "vm-delete");
+ res = ast_play_and_wait(chan, "vm-delete");
else
- res = play_and_wait(chan, "vm-undelete");
+ res = ast_play_and_wait(chan, "vm-undelete");
if (!res)
- res = play_and_wait(chan, "vm-toforward");
+ res = ast_play_and_wait(chan, "vm-toforward");
if (!res)
- res = play_and_wait(chan, "vm-savemessage");
+ res = ast_play_and_wait(chan, "vm-savemessage");
}
}
if (!res)
- res = play_and_wait(chan, "vm-helpexit");
+ res = ast_play_and_wait(chan, "vm-helpexit");
if (!res)
res = ast_waitfordigit(chan, 6000);
if (!res) {
break;
case '4':
if (vmu->password[0] == '-') {
- cmd = play_and_wait(chan, "vm-no");
+ cmd = ast_play_and_wait(chan, "vm-no");
break;
}
newpassword[1] = '\0';
- newpassword[0] = cmd = play_and_wait(chan,"vm-newpassword");
+ newpassword[0] = cmd = ast_play_and_wait(chan,"vm-newpassword");
if (cmd < 0)
break;
if ((cmd = ast_readstring(chan,newpassword + strlen(newpassword),sizeof(newpassword)-1,2000,10000,"#")) < 0) {
break;
}
newpassword2[1] = '\0';
- newpassword2[0] = cmd = play_and_wait(chan,"vm-reenterpassword");
+ newpassword2[0] = cmd = ast_play_and_wait(chan,"vm-reenterpassword");
if (cmd < 0)
break;
}
if (strcmp(newpassword, newpassword2)) {
ast_log(LOG_NOTICE,"Password mismatch for user %s (%s != %s)\n", vms->username, newpassword, newpassword2);
- cmd = play_and_wait(chan, "vm-mismatch");
+ cmd = ast_play_and_wait(chan, "vm-mismatch");
break;
}
if(ast_strlen_zero(ext_pass_cmd))
else
vm_change_password_shell(vmu,newpassword);
ast_log(LOG_DEBUG,"User %s set password to %s of length %i\n",vms->username,newpassword,(int)strlen(newpassword));
- cmd = play_and_wait(chan,"vm-passchanged");
+ cmd = ast_play_and_wait(chan,"vm-passchanged");
break;
case '*':
cmd = 't';
break;
default:
- cmd = play_and_wait(chan,"vm-options");
+ cmd = ast_play_and_wait(chan,"vm-options");
if (!cmd)
cmd = ast_waitfordigit(chan,6000);
if (!cmd)
if (vms->lastmsg > -1) {
cmd = play_message(chan, vmu, vms);
} else {
- cmd = play_and_wait(chan, "vm-youhave");
+ cmd = ast_play_and_wait(chan, "vm-youhave");
if (!cmd)
- cmd = play_and_wait(chan, "vm-no");
+ cmd = ast_play_and_wait(chan, "vm-no");
if (!cmd) {
snprintf(vms->fn, sizeof(vms->fn), "vm-%s", vms->curbox);
- cmd = play_and_wait(chan, vms->fn);
+ cmd = ast_play_and_wait(chan, vms->fn);
}
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
}
return cmd;
}
if (vms->lastmsg > -1) {
cmd = play_message(chan, vmu, vms);
} else {
- cmd = play_and_wait(chan, "vm-youhaveno");
+ cmd = ast_play_and_wait(chan, "vm-youhaveno");
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
if (!cmd) {
snprintf(vms->fn, sizeof(vms->fn), "vm-%s", vms->curbox);
- cmd = play_and_wait(chan, vms->fn);
+ cmd = ast_play_and_wait(chan, vms->fn);
}
}
return cmd;
if (vms->lastmsg > -1) {
cmd = play_message(chan, vmu, vms);
} else {
- cmd = play_and_wait(chan, "vm-no");
+ cmd = ast_play_and_wait(chan, "vm-no");
if (!cmd) {
snprintf(vms->fn, sizeof(vms->fn), "vm-%s", vms->curbox);
- cmd = play_and_wait(chan, vms->fn);
+ cmd = ast_play_and_wait(chan, vms->fn);
}
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
}
return cmd;
}
}
if (!valid && (logretries >= maxlogins)) {
ast_stopstream(chan);
- res = play_and_wait(chan, "vm-goodbye");
+ res = ast_play_and_wait(chan, "vm-goodbye");
if (res > 0)
res = 0;
}
adsi_status2(chan, &vms);
if (!strcasecmp(chan->language, "es") || !strcasecmp(chan->language, "pt")) { /* SPANISH or PORTUGUESE */
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
if (!cmd)
- cmd = play_and_wait(chan, vms.vmbox);
+ cmd = ast_play_and_wait(chan, vms.vmbox);
} else { /* Default to English syntax */
if (!cmd)
- cmd = play_and_wait(chan, vms.vmbox);
+ cmd = ast_play_and_wait(chan, vms.vmbox);
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
}
vms.starting = 1;
break;
if(vms.lastmsg > -1)
cmd = advanced_options(chan, vmu, &vms, vms.curmsg, 1);
else
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
cmd = 't';
break;
case '2': /* Callback */
}
}
else
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
cmd = 't';
break;
case '3': /* Envelope */
if(vms.lastmsg > -1)
cmd = advanced_options(chan, vmu, &vms, vms.curmsg, 3);
else
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
cmd = 't';
break;
case '4': /* Dialout */
}
}
else
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
cmd = 't';
break;
if(vmu->svmail)
cmd = forward_message(chan, context, vms.curdir, vms.curmsg, vmu, vmfmts,1);
else
- cmd = play_and_wait(chan,"vm-sorry");
+ cmd = ast_play_and_wait(chan,"vm-sorry");
cmd='t';
break;
default:
cmd = 0;
if (!vms.starting) {
- cmd = play_and_wait(chan, "vm-toreply");
+ cmd = ast_play_and_wait(chan, "vm-toreply");
}
if (!ast_strlen_zero(vmu->callback) && !vms.starting && !cmd) {
- cmd = play_and_wait(chan, "vm-tocallback");
+ cmd = ast_play_and_wait(chan, "vm-tocallback");
}
if (!cmd && !vms.starting) {
- cmd = play_and_wait(chan, "vm-tohearenv");
+ cmd = ast_play_and_wait(chan, "vm-tohearenv");
}
if (!ast_strlen_zero(vmu->dialout) && !cmd) {
- cmd = play_and_wait(chan, "vm-tomakecall");
+ cmd = ast_play_and_wait(chan, "vm-tomakecall");
}
if(vmu->svmail&&!cmd)
- cmd=play_and_wait(chan, "vm-leavemsg");
+ cmd=ast_play_and_wait(chan, "vm-leavemsg");
if (!cmd)
- cmd = play_and_wait(chan, "vm-starmain");
+ cmd = ast_play_and_wait(chan, "vm-starmain");
if (!cmd)
cmd = ast_waitfordigit(chan,6000);
if (!cmd)
vms.curmsg--;
cmd = play_message(chan, vmu, &vms);
} else {
- cmd = play_and_wait(chan, "vm-nomore");
+ cmd = ast_play_and_wait(chan, "vm-nomore");
}
break;
case '6':
vms.curmsg++;
cmd = play_message(chan, vmu, &vms);
} else {
- cmd = play_and_wait(chan, "vm-nomore");
+ cmd = ast_play_and_wait(chan, "vm-nomore");
}
break;
case '7':
if (useadsi)
adsi_delete(chan, &vms);
if (vms.deleted[vms.curmsg])
- cmd = play_and_wait(chan, "vm-deleted");
+ cmd = ast_play_and_wait(chan, "vm-deleted");
else
- cmd = play_and_wait(chan, "vm-undeleted");
+ cmd = ast_play_and_wait(chan, "vm-undeleted");
if (skipaftercmd) {
if (vms.curmsg < vms.lastmsg) {
vms.curmsg++;
cmd = play_message(chan, vmu, &vms);
} else {
- cmd = play_and_wait(chan, "vm-nomore");
+ cmd = ast_play_and_wait(chan, "vm-nomore");
}
}
break;
if(vms.lastmsg > -1)
cmd = forward_message(chan, context, vms.curdir, vms.curmsg, vmu, vmfmts,0);
else
- cmd = play_and_wait(chan, "vm-nomore");
+ cmd = ast_play_and_wait(chan, "vm-nomore");
break;
case '9':
if (useadsi)
if (useadsi)
adsi_message(chan, &vms);
if (!cmd)
- cmd = play_and_wait(chan, "vm-message");
+ cmd = ast_play_and_wait(chan, "vm-message");
if (!cmd)
cmd = say_and_wait(chan, vms.curmsg + 1, chan->language);
if (!cmd)
- cmd = play_and_wait(chan, "vm-savedto");
+ cmd = ast_play_and_wait(chan, "vm-savedto");
if (!strcasecmp(chan->language, "es") || !strcasecmp(chan->language, "pt")) { /* SPANISH or PORTUGUESE */
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
if (!cmd) {
snprintf(vms.fn, sizeof(vms.fn), "vm-%s", mbox(box));
- cmd = play_and_wait(chan, vms.fn);
+ cmd = ast_play_and_wait(chan, vms.fn);
}
} else { /* Default to English */
if (!cmd) {
snprintf(vms.fn, sizeof(vms.fn), "vm-%s", mbox(box));
- cmd = play_and_wait(chan, vms.fn);
+ cmd = ast_play_and_wait(chan, vms.fn);
}
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
}
if (skipaftercmd) {
if (vms.curmsg < vms.lastmsg) {
vms.curmsg++;
cmd = play_message(chan, vmu, &vms);
} else {
- cmd = play_and_wait(chan, "vm-nomore");
+ cmd = ast_play_and_wait(chan, "vm-nomore");
}
}
break;
case '*':
if (!vms.starting) {
- cmd = play_and_wait(chan, "vm-onefor");
+ cmd = ast_play_and_wait(chan, "vm-onefor");
if (!strcasecmp(chan->language, "es") || !strcasecmp(chan->language, "pt")) { /* Spanish or Portuguese syntax */
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
if (!cmd)
- cmd = play_and_wait(chan, vms.vmbox);
+ cmd = ast_play_and_wait(chan, vms.vmbox);
} else {
if (!cmd)
- cmd = play_and_wait(chan, vms.vmbox);
+ cmd = ast_play_and_wait(chan, vms.vmbox);
if (!cmd)
- cmd = play_and_wait(chan, "vm-messages");
+ cmd = ast_play_and_wait(chan, "vm-messages");
}
if (!cmd)
- cmd = play_and_wait(chan, "vm-opts");
+ cmd = ast_play_and_wait(chan, "vm-opts");
if (!cmd)
cmd = vm_instructions(chan, &vms, 1);
} else
adsi_goodbye(chan);
if(valid) {
if (silentexit)
- res = play_and_wait(chan, "vm-dialout");
+ res = ast_play_and_wait(chan, "vm-dialout");
else
- res = play_and_wait(chan, "vm-goodbye");
+ res = ast_play_and_wait(chan, "vm-goodbye");
if (res > 0)
res = 0;
}
ast_verbose( VERBOSE_PREFIX_3 "Destination number will be entered manually\n");
while (retries < 3 && cmd != 't') {
destination[1] = '\0';
- destination[0] = cmd = play_and_wait(chan,"vm-enter-num-to-call");
+ destination[0] = cmd = ast_play_and_wait(chan,"vm-enter-num-to-call");
if (!cmd)
- destination[0] = cmd = play_and_wait(chan, "vm-then-pound");
+ destination[0] = cmd = ast_play_and_wait(chan, "vm-then-pound");
if (!cmd)
- destination[0] = cmd = play_and_wait(chan, "vm-star-cancel");
+ destination[0] = cmd = ast_play_and_wait(chan, "vm-star-cancel");
if (!cmd) {
cmd = ast_waitfordigit(chan, 6000);
if (cmd)
return 9;
} else {
ast_verbose( VERBOSE_PREFIX_3 "Caller can not specify callback number - no dialout context available\n");
- res = play_and_wait(chan, "vm-sorry");
+ res = ast_play_and_wait(chan, "vm-sorry");
}
return res;
case '*':
case '9':
case '0':
- res = play_and_wait(chan, "vm-sorry");
+ res = ast_play_and_wait(chan, "vm-sorry");
retries++;
break;
default:
if (num) {
ast_verbose( VERBOSE_PREFIX_3 "Confirm CID number '%s' is number to use for callback\n", num);
- res = play_and_wait(chan, "vm-num-i-have");
+ res = ast_play_and_wait(chan, "vm-num-i-have");
if (!res)
res = play_message_callerid(chan, vms, num, vmu->context, 1);
if (!res)
- res = play_and_wait(chan, "vm-tocallnum");
+ res = ast_play_and_wait(chan, "vm-tocallnum");
/* Only prompt for a caller-specified number if there is a dialout context specified */
if (!ast_strlen_zero(vmu->dialout)) {
if (!res)
- res = play_and_wait(chan, "vm-calldiffnum");
+ res = ast_play_and_wait(chan, "vm-calldiffnum");
}
} else {
- res = play_and_wait(chan, "vm-nonumber");
+ res = ast_play_and_wait(chan, "vm-nonumber");
if (!ast_strlen_zero(vmu->dialout)) {
if (!res)
- res = play_and_wait(chan, "vm-toenternumber");
+ res = ast_play_and_wait(chan, "vm-toenternumber");
}
}
if (!res)
- res = play_and_wait(chan, "vm-star-cancel");
+ res = ast_play_and_wait(chan, "vm-star-cancel");
if (!res)
res = ast_waitfordigit(chan, 6000);
if (!res)
if (!num) {
ast_verbose(VERBOSE_PREFIX_3 "No CID number available, no reply sent\n");
if (!res)
- res = play_and_wait(chan, "vm-nonumber");
+ res = ast_play_and_wait(chan, "vm-nonumber");
return res;
} else {
if (find_user(NULL, vmu->context, num)) {
else {
ast_verbose( VERBOSE_PREFIX_3 "No mailbox number '%s' in context '%s', no reply sent\n", num, vmu->context);
/* Sender has no mailbox, can't reply */
- play_and_wait(chan, "vm-nobox");
+ ast_play_and_wait(chan, "vm-nobox");
res = 't';
return res;
}
else
ast_verbose(VERBOSE_PREFIX_3 "Recording the message\n");
if (recorded && outsidecaller) {
- cmd = play_and_wait(chan, INTRO);
- cmd = play_and_wait(chan, "beep");
+ cmd = ast_play_and_wait(chan, INTRO);
+ cmd = ast_play_and_wait(chan, "beep");
}
recorded = 1;
/* After an attempt has been made to record message, we have to take care of INTRO and beep for incoming messages, but not for greetings */
- cmd = play_and_record(chan, playfile, recordfile, maxtime, fmt, duration);
+ cmd = ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, silencethreshold, maxsilence);
if (cmd == -1)
/* User has hung up, no options to give */
return res;
if (cmd == '0') {
/* Erase the message if 0 pushed during playback */
- play_and_wait(chan, "vm-deleted");
+ ast_play_and_wait(chan, "vm-deleted");
vm_delete(recordfile);
} else if (cmd == '*') {
break;
else if (vmu->review && (*duration < 5)) {
/* Message is too short */
ast_verbose(VERBOSE_PREFIX_3 "Message too short\n");
- cmd = play_and_wait(chan, "vm-tooshort");
+ cmd = ast_play_and_wait(chan, "vm-tooshort");
cmd = vm_delete(recordfile);
break;
}
/* Message is all silence */
ast_verbose(VERBOSE_PREFIX_3 "Nothing recorded\n");
cmd = vm_delete(recordfile);
- cmd = play_and_wait(chan, "vm-nothingrecorded");
+ cmd = ast_play_and_wait(chan, "vm-nothingrecorded");
if (!cmd)
- cmd = play_and_wait(chan, "vm-speakup");
+ cmd = ast_play_and_wait(chan, "vm-speakup");
break;
}
#endif
case '9':
case '*':
case '#':
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
break;
#if 0
/* XXX Commented out for the moment because of the dangers of deleting
a message while recording (can put the message numbers out of sync) */
case '*':
/* Cancel recording, delete message, offer to take another message*/
- cmd = play_and_wait(chan, "vm-deleted");
+ cmd = ast_play_and_wait(chan, "vm-deleted");
cmd = vm_delete(recordfile);
if (outsidecaller) {
res = vm_exec(chan, NULL);
case '0':
if (outsidecaller && vmu->operator) {
if (message_exists)
- play_and_wait(chan, "vm-msgsaved");
+ ast_play_and_wait(chan, "vm-msgsaved");
return cmd;
} else
- cmd = play_and_wait(chan, "vm-sorry");
+ cmd = ast_play_and_wait(chan, "vm-sorry");
break;
default:
/* If the caller is an ouside caller, and the review option is enabled,
if (outsidecaller && !vmu->review)
return cmd;
if (message_exists) {
- cmd = play_and_wait(chan, "vm-review");
+ cmd = ast_play_and_wait(chan, "vm-review");
}
else {
- cmd = play_and_wait(chan, "vm-torerecord");
+ cmd = ast_play_and_wait(chan, "vm-torerecord");
if (!cmd)
cmd = ast_waitfordigit(chan, 600);
}
if (!cmd && outsidecaller && vmu->operator) {
- cmd = play_and_wait(chan, "vm-reachoper");
+ cmd = ast_play_and_wait(chan, "vm-reachoper");
if (!cmd)
cmd = ast_waitfordigit(chan, 600);
}
#if 0
if (!cmd)
- cmd = play_and_wait(chan, "vm-tocancelmsg");
+ cmd = ast_play_and_wait(chan, "vm-tocancelmsg");
#endif
if (!cmd)
cmd = ast_waitfordigit(chan, 6000);
}
}
if (outsidecaller)
- play_and_wait(chan, "vm-goodbye");
+ ast_play_and_wait(chan, "vm-goodbye");
if (cmd == 't')
cmd = 0;
return cmd;
projects / thirdparty / asterisk.git / commitdiff
