diff options
Diffstat (limited to '1.4.23-rc4/main/app.c')
| -rw-r--r-- | 1.4.23-rc4/main/app.c | 1452 |
1 files changed, 0 insertions, 1452 deletions
diff --git a/1.4.23-rc4/main/app.c b/1.4.23-rc4/main/app.c deleted file mode 100644 index bcecff568..000000000 --- a/1.4.23-rc4/main/app.c +++ /dev/null @@ -1,1452 +0,0 @@ -/* - * Asterisk -- An open source telephony toolkit. - * - * Copyright (C) 1999 - 2005, Digium, Inc. - * - * Mark Spencer <markster@digium.com> - * - * See http://www.asterisk.org for more information about - * the Asterisk project. Please do not directly contact - * any of the maintainers of this project for assistance; - * the project provides a web site, mailing lists and IRC - * channels for your use. - * - * This program is free software, distributed under the terms of - * the GNU General Public License Version 2. See the LICENSE file - * at the top of the source tree. - */ - -/*! \file - * - * \brief Convenient Application Routines - * - * \author Mark Spencer <markster@digium.com> - */ - -#include "asterisk.h" - -ASTERISK_FILE_VERSION(__FILE__, "$Revision$") - -#include <stdio.h> -#include <stdlib.h> -#include <string.h> -#include <sys/time.h> -#include <signal.h> -#include <errno.h> -#include <unistd.h> -#include <dirent.h> -#include <sys/types.h> -#include <sys/stat.h> -#include <regex.h> - -#include "asterisk/channel.h" -#include "asterisk/pbx.h" -#include "asterisk/file.h" -#include "asterisk/app.h" -#include "asterisk/dsp.h" -#include "asterisk/logger.h" -#include "asterisk/options.h" -#include "asterisk/utils.h" -#include "asterisk/lock.h" -#include "asterisk/indications.h" -#include "asterisk/linkedlists.h" - -#define MAX_OTHER_FORMATS 10 - -static AST_LIST_HEAD_STATIC(groups, ast_group_info); - -/* ! -This function presents a dialtone and reads an extension into 'collect' -which must be a pointer to a **pre-initialized** array of char having a -size of 'size' suitable for writing to. It will collect no more than the smaller -of 'maxlen' or 'size' minus the original strlen() of collect digits. -\return 0 if extension does not exist, 1 if extension exists -*/ -int ast_app_dtget(struct ast_channel *chan, const char *context, char *collect, size_t size, int maxlen, int timeout) -{ - struct tone_zone_sound *ts; - int res=0, x=0; - - if (maxlen > size) - maxlen = size; - - if (!timeout && chan->pbx) - timeout = chan->pbx->dtimeout; - else if (!timeout) - timeout = 5; - - ts = ast_get_indication_tone(chan->zone,"dial"); - if (ts && ts->data[0]) - res = ast_playtones_start(chan, 0, ts->data, 0); - else - ast_log(LOG_NOTICE,"Huh....? no dial for indications?\n"); - - for (x = strlen(collect); x < maxlen; ) { - res = ast_waitfordigit(chan, timeout); - if (!ast_ignore_pattern(context, collect)) - ast_playtones_stop(chan); - if (res < 1) - break; - if (res == '#') - break; - collect[x++] = res; - if (!ast_matchmore_extension(chan, context, collect, 1, chan->cid.cid_num)) - break; - } - if (res >= 0) - res = ast_exists_extension(chan, context, collect, 1, chan->cid.cid_num) ? 1 : 0; - return res; -} - -/*! \param c The channel to read from - * \param prompt The file to stream to the channel - * \param s The string to read in to. Must be at least the size of your length - * \param maxlen How many digits to read (maximum) - * \param timeout 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) -{ - int res,to,fto; - /* XXX Merge with full version? XXX */ - if (maxlen) - s[0] = '\0'; - if (prompt) { - res = ast_streamfile(c, prompt, c->language); - if (res < 0) - return res; - } - fto = c->pbx ? c->pbx->rtimeout * 1000 : 6000; - to = c->pbx ? c->pbx->dtimeout * 1000 : 2000; - - if (timeout > 0) - fto = to = timeout; - if (timeout < 0) - fto = to = 1000000000; - res = ast_readstring(c, s, maxlen, to, fto, "#"); - return res; -} - - -int ast_app_getdata_full(struct ast_channel *c, char *prompt, char *s, int maxlen, int timeout, int audiofd, int ctrlfd) -{ - int res, to, fto; - if (prompt) { - res = ast_streamfile(c, prompt, c->language); - if (res < 0) - return res; - } - fto = 6000; - to = 2000; - if (timeout > 0) - fto = to = timeout; - if (timeout < 0) - fto = to = 1000000000; - res = ast_readstring_full(c, s, maxlen, to, fto, "#", audiofd, ctrlfd); - return res; -} - -static int (*ast_has_voicemail_func)(const char *mailbox, const char *folder) = NULL; -static int (*ast_inboxcount_func)(const char *mailbox, int *newmsgs, int *oldmsgs) = NULL; -static int (*ast_messagecount_func)(const char *context, const char *mailbox, const char *folder) = NULL; - -void ast_install_vm_functions(int (*has_voicemail_func)(const char *mailbox, const char *folder), - int (*inboxcount_func)(const char *mailbox, int *newmsgs, int *oldmsgs), - int (*messagecount_func)(const char *context, const char *mailbox, const char *folder)) -{ - ast_has_voicemail_func = has_voicemail_func; - ast_inboxcount_func = inboxcount_func; - ast_messagecount_func = messagecount_func; -} - -void ast_uninstall_vm_functions(void) -{ - ast_has_voicemail_func = NULL; - ast_inboxcount_func = NULL; - ast_messagecount_func = NULL; -} - -int ast_app_has_voicemail(const char *mailbox, const char *folder) -{ - static int warned = 0; - if (ast_has_voicemail_func) - return ast_has_voicemail_func(mailbox, folder); - - if ((option_verbose > 2) && !warned) { - ast_verbose(VERBOSE_PREFIX_3 "Message check requested for mailbox %s/folder %s but voicemail not loaded.\n", mailbox, folder ? folder : "INBOX"); - warned++; - } - return 0; -} - - -int ast_app_inboxcount(const char *mailbox, int *newmsgs, int *oldmsgs) -{ - static int warned = 0; - if (newmsgs) - *newmsgs = 0; - if (oldmsgs) - *oldmsgs = 0; - if (ast_inboxcount_func) - return ast_inboxcount_func(mailbox, newmsgs, oldmsgs); - - if (!warned && (option_verbose > 2)) { - warned++; - ast_verbose(VERBOSE_PREFIX_3 "Message count requested for mailbox %s but voicemail not loaded.\n", mailbox); - } - - return 0; -} - -int ast_app_messagecount(const char *context, const char *mailbox, const char *folder) -{ - static int warned = 0; - if (ast_messagecount_func) - return ast_messagecount_func(context, mailbox, folder); - - if (!warned && (option_verbose > 2)) { - warned++; - ast_verbose(VERBOSE_PREFIX_3 "Message count requested for mailbox %s@%s/%s but voicemail not loaded.\n", mailbox, context, folder); - } - - return 0; -} - -int ast_dtmf_stream(struct ast_channel *chan, struct ast_channel *peer, const char *digits, int between) -{ - const char *ptr; - int res = 0; - struct ast_silence_generator *silgen = NULL; - - if (!between) - between = 100; - - if (peer) - res = ast_autoservice_start(peer); - - if (!res) - res = ast_waitfor(chan, 100); - - /* ast_waitfor will return the number of remaining ms on success */ - if (res < 0) { - if (peer) { - ast_autoservice_stop(peer); - } - return res; - } - - if (ast_opt_transmit_silence) { - silgen = ast_channel_start_silence_generator(chan); - } - - for (ptr = digits; *ptr; ptr++) { - if (*ptr == 'w') { - /* 'w' -- wait half a second */ - if ((res = ast_safe_sleep(chan, 500))) - break; - } else if (strchr("0123456789*#abcdfABCDF", *ptr)) { - /* Character represents valid DTMF */ - if (*ptr == 'f' || *ptr == 'F') { - /* ignore return values if not supported by channel */ - ast_indicate(chan, AST_CONTROL_FLASH); - } else - ast_senddigit(chan, *ptr); - /* pause between digits */ - if ((res = ast_safe_sleep(chan, between))) - break; - } else - ast_log(LOG_WARNING, "Illegal DTMF character '%c' in string. (0-9*#aAbBcCdD allowed)\n",*ptr); - } - - if (peer) { - /* Stop autoservice on the peer channel, but don't overwrite any error condition - that has occurred previously while acting on the primary channel */ - if (ast_autoservice_stop(peer) && !res) - res = -1; - } - - if (silgen) { - ast_channel_stop_silence_generator(chan, silgen); - } - - return res; -} - -struct linear_state { - int fd; - int autoclose; - int allowoverride; - int origwfmt; -}; - -static void linear_release(struct ast_channel *chan, void *params) -{ - struct linear_state *ls = params; - if (ls->origwfmt && ast_set_write_format(chan, ls->origwfmt)) { - ast_log(LOG_WARNING, "Unable to restore channel '%s' to format '%d'\n", chan->name, ls->origwfmt); - } - if (ls->autoclose) - close(ls->fd); - free(params); -} - -static int linear_generator(struct ast_channel *chan, void *data, int len, int samples) -{ - struct ast_frame f; - short buf[2048 + AST_FRIENDLY_OFFSET / 2]; - struct linear_state *ls = data; - int res; - len = samples * 2; - if (len > sizeof(buf) - AST_FRIENDLY_OFFSET) { - ast_log(LOG_WARNING, "Can't generate %d bytes of data!\n" ,len); - len = sizeof(buf) - AST_FRIENDLY_OFFSET; - } - memset(&f, 0, sizeof(f)); - res = read(ls->fd, buf + AST_FRIENDLY_OFFSET/2, len); - if (res > 0) { - f.frametype = AST_FRAME_VOICE; - f.subclass = AST_FORMAT_SLINEAR; - f.data = buf + AST_FRIENDLY_OFFSET/2; - f.datalen = res; - f.samples = res / 2; - f.offset = AST_FRIENDLY_OFFSET; - ast_write(chan, &f); - if (res == len) - return 0; - } - return -1; -} - -static void *linear_alloc(struct ast_channel *chan, void *params) -{ - struct linear_state *ls; - /* In this case, params is already malloc'd */ - if (params) { - ls = params; - if (ls->allowoverride) - ast_set_flag(chan, AST_FLAG_WRITE_INT); - else - ast_clear_flag(chan, AST_FLAG_WRITE_INT); - ls->origwfmt = chan->writeformat; - if (ast_set_write_format(chan, AST_FORMAT_SLINEAR)) { - ast_log(LOG_WARNING, "Unable to set '%s' to linear format (write)\n", chan->name); - free(ls); - ls = params = NULL; - } - } - return params; -} - -static struct ast_generator linearstream = -{ - alloc: linear_alloc, - release: linear_release, - generate: linear_generator, -}; - -int ast_linear_stream(struct ast_channel *chan, const char *filename, int fd, int allowoverride) -{ - struct linear_state *lin; - char tmpf[256]; - int res = -1; - int autoclose = 0; - if (fd < 0) { - if (ast_strlen_zero(filename)) - return -1; - autoclose = 1; - if (filename[0] == '/') - ast_copy_string(tmpf, filename, sizeof(tmpf)); - else - snprintf(tmpf, sizeof(tmpf), "%s/%s/%s", (char *)ast_config_AST_DATA_DIR, "sounds", filename); - fd = open(tmpf, O_RDONLY); - if (fd < 0){ - ast_log(LOG_WARNING, "Unable to open file '%s': %s\n", tmpf, strerror(errno)); - return -1; - } - } - if ((lin = ast_calloc(1, sizeof(*lin)))) { - lin->fd = fd; - lin->allowoverride = allowoverride; - lin->autoclose = autoclose; - res = ast_activate_generator(chan, &linearstream, lin); - } - return res; -} - -int ast_control_streamfile(struct ast_channel *chan, const char *file, - const char *fwd, const char *rev, - const char *stop, const char *pause, - const char *restart, int skipms) -{ - char *breaks = NULL; - char *end = NULL; - int blen = 2; - int res; - long pause_restart_point = 0; - - if (stop) - blen += strlen(stop); - if (pause) - blen += strlen(pause); - if (restart) - blen += strlen(restart); - - if (blen > 2) { - breaks = alloca(blen + 1); - breaks[0] = '\0'; - if (stop) - strcat(breaks, stop); - if (pause) - strcat(breaks, pause); - if (restart) - strcat(breaks, restart); - } - if (chan->_state != AST_STATE_UP) - res = ast_answer(chan); - - if (file) { - if ((end = strchr(file,':'))) { - if (!strcasecmp(end, ":end")) { - *end = '\0'; - end++; - } - } - } - - for (;;) { - ast_stopstream(chan); - res = ast_streamfile(chan, file, chan->language); - if (!res) { - if (pause_restart_point) { - ast_seekstream(chan->stream, pause_restart_point, SEEK_SET); - pause_restart_point = 0; - } - else if (end) { - ast_seekstream(chan->stream, 0, SEEK_END); - end = NULL; - }; - res = ast_waitstream_fr(chan, breaks, fwd, rev, skipms); - } - - if (res < 1) - break; - - /* We go at next loop if we got the restart char */ - if (restart && strchr(restart, res)) { - if (option_debug) - ast_log(LOG_DEBUG, "we'll restart the stream here at next loop\n"); - pause_restart_point = 0; - continue; - } - - if (pause && strchr(pause, res)) { - pause_restart_point = ast_tellstream(chan->stream); - for (;;) { - ast_stopstream(chan); - res = ast_waitfordigit(chan, 1000); - if (!res) - continue; - else if (res == -1 || strchr(pause, res) || (stop && strchr(stop, res))) - break; - } - if (res == *pause) { - res = 0; - continue; - } - } - - if (res == -1) - break; - - /* if we get one of our stop chars, return it to the calling function */ - if (stop && strchr(stop, res)) - break; - } - - /* If we are returning a digit cast it as char */ - if (res > 0 || chan->stream) - res = (char)res; - - ast_stopstream(chan); - - return res; -} - -int ast_play_and_wait(struct ast_channel *chan, const 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; - -/*! Optionally play a sound file or a beep, then record audio and video from the channel. - * @param chan Channel to playback to/record from. - * @param playfile Filename of sound to play before recording begins. - * @param recordfile Filename to record to. - * @param maxtime Maximum length of recording (in milliseconds). - * @param fmt Format(s) to record message in. Multiple formats may be specified by separating them with a '|'. - * @param duration Where to store actual length of the recorded message (in milliseconds). - * @param beep Whether to play a beep before starting to record. - * @param silencethreshold - * @param maxsilence Length of silence that will end a recording (in milliseconds). - * @param path Optional filesystem path to unlock. - * @param prepend If true, prepend the recorded audio to an existing file. - * @param acceptdtmf DTMF digits that will end the recording. - * @param canceldtmf DTMF digits that will cancel the recording. - */ - -static int __ast_play_and_record(struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, int beep, int silencethreshold, int maxsilence, const char *path, int prepend, const char *acceptdtmf, const char *canceldtmf) -{ - int d = 0; - char *fmts; - char comment[256]; - int x, fmtcnt = 1, res = -1, outmsg = 0; - struct ast_filestream *others[MAX_OTHER_FORMATS]; - char *sfmt[MAX_OTHER_FORMATS]; - char *stringp = NULL; - time_t start, end; - struct ast_dsp *sildet = NULL; /* silence detector dsp */ - int totalsilence = 0; - int rfmt = 0; - struct ast_silence_generator *silgen = NULL; - 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_record called without duration pointer\n"); - return -1; - } - - if (option_debug) - 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 || beep) { - if (!beep) - d = ast_play_and_wait(chan, playfile); - if (d > -1) - d = ast_stream_and_wait(chan, "beep", chan->language, ""); - if (d < 0) - return -1; - } - - if (prepend) { - ast_copy_string(prependfile, recordfile, sizeof(prependfile)); - strncat(prependfile, "-prepend", sizeof(prependfile) - strlen(prependfile) - 1); - } - - fmts = ast_strdupa(fmt); - - stringp = fmts; - strsep(&stringp, "|"); - if (option_debug) - 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.c\n"); - break; - } - sfmt[fmtcnt++] = ast_strdupa(fmt); - } - - end = start = time(NULL); /* 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(prepend ? prependfile : recordfile, sfmt[x], comment, O_TRUNC, 0, 0777); - if (option_verbose > 2) - ast_verbose(VERBOSE_PREFIX_3 "x=%d, open writing: %s format: %s, %p\n", x, prepend ? prependfile : recordfile, sfmt[x], others[x]); - - if (!others[x]) - break; - } - - if (path) - ast_unlock_path(path); - - if (maxsilence > 0) { - 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); - 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"); - ast_dsp_free(sildet); - return -1; - } - } - - if (!prepend) { - /* Request a video update */ - ast_indicate(chan, AST_CONTROL_VIDUPDATE); - - if (ast_opt_transmit_silence) - silgen = ast_channel_start_silence_generator(chan); - } - - if (x == fmtcnt) { - /* Loop forever, writing the packets we read to the writer(s), until - we read a digit or get a hangup */ - struct ast_frame *f; - for (;;) { - res = ast_waitfor(chan, 2000); - if (!res) { - if (option_debug) - 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 (prepend && !others[x]) - break; - res = ast_writestream(others[x], f); - } - - /* Silence Detection */ - if (maxsilence > 0) { - int 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); - res = 'S'; - outmsg = 2; - break; - } - } - /* Exit on any error */ - if (res) { - ast_log(LOG_WARNING, "Error writing frame\n"); - break; - } - } else if (f->frametype == AST_FRAME_VIDEO) { - /* Write only once */ - ast_writestream(others[0], f); - } else if (f->frametype == AST_FRAME_DTMF) { - if (prepend) { - /* 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; - break; - } - if (strchr(acceptdtmf, f->subclass)) { - if (option_verbose > 2) - ast_verbose(VERBOSE_PREFIX_3 "User ended message by pressing %c\n", f->subclass); - res = f->subclass; - outmsg = 2; - break; - } - if (strchr(canceldtmf, f->subclass)) { - if (option_verbose > 2) - ast_verbose(VERBOSE_PREFIX_3 "User cancelled message by pressing %c\n", f->subclass); - res = f->subclass; - outmsg = 0; - break; - } - } - if (maxtime) { - end = time(NULL); - if (maxtime < (end - start)) { - if (option_verbose > 2) - ast_verbose(VERBOSE_PREFIX_3 "Took too long, cutting it short...\n"); - res = 't'; - outmsg = 2; - break; - } - } - ast_frfree(f); - } - if (!f) { - if (option_verbose > 2) - ast_verbose(VERBOSE_PREFIX_3 "User hung up\n"); - res = -1; - outmsg = 1; - } else { - ast_frfree(f); - } - } else { - ast_log(LOG_WARNING, "Error creating writestream '%s', format '%s'\n", recordfile, sfmt[x]); - } - - if (!prepend) { - if (silgen) - ast_channel_stop_silence_generator(chan, silgen); - } - - /*!\note - * Instead of asking how much time passed (end - start), calculate the number - * of seconds of audio which actually went into the file. This fixes a - * problem where audio is stopped up on the network and never gets to us. - * - * Note that we still want to use the number of seconds passed for the max - * message, otherwise we could get a situation where this stream is never - * closed (which would create a resource leak). - */ - *duration = others[0] ? ast_tellstream(others[0]) / 8000 : 0; - - if (!prepend) { - for (x = 0; x < fmtcnt; x++) { - if (!others[x]) - break; - /*!\note - * If we ended with silence, trim all but the first 200ms of silence - * off the recording. However, if we ended with '#', we don't want - * to trim ANY part of the recording. - */ - if (res > 0 && totalsilence) - ast_stream_rewind(others[x], totalsilence - 200); - ast_truncstream(others[x]); - ast_closestream(others[x]); - } - } - - if (prepend && outmsg) { - struct ast_filestream *realfiles[MAX_OTHER_FORMATS]; - 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; - /*!\note Same logic as above. */ - if (totalsilence) - ast_stream_rewind(others[x], totalsilence - 200); - ast_truncstream(others[x]); - /* add the original file too */ - while ((fr = ast_readframe(realfiles[x]))) { - ast_writestream(others[x], fr); - ast_frfree(fr); - } - ast_closestream(others[x]); - ast_closestream(realfiles[x]); - ast_filerename(prependfile, recordfile, sfmt[x]); - if (option_verbose > 3) - ast_verbose(VERBOSE_PREFIX_4 "Recording Format: sfmts=%s, prependfile %s, recordfile %s\n", sfmt[x], prependfile, recordfile); - ast_filedelete(prependfile, sfmt[x]); - } - } - if (rfmt && 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 == 2) { - ast_stream_and_wait(chan, "auth-thankyou", chan->language, ""); - } - if (sildet) - ast_dsp_free(sildet); - return res; -} - -static char default_acceptdtmf[] = "#"; -static char default_canceldtmf[] = ""; - -int ast_play_and_record_full(struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, int silencethreshold, int maxsilence, const char *path, const char *acceptdtmf, const char *canceldtmf) -{ - return __ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, 0, silencethreshold, maxsilence, path, 0, S_OR(acceptdtmf, default_acceptdtmf), S_OR(canceldtmf, default_canceldtmf)); -} - -int ast_play_and_record(struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, int silencethreshold, int maxsilence, const char *path) -{ - return __ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, 0, silencethreshold, maxsilence, path, 0, default_acceptdtmf, default_canceldtmf); -} - -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) -{ - return __ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, beep, silencethreshold, maxsilence, NULL, 1, default_acceptdtmf, default_canceldtmf); -} - -/* Channel group core functions */ - -int ast_app_group_split_group(const char *data, char *group, int group_max, char *category, int category_max) -{ - int res=0; - char tmp[256]; - char *grp=NULL, *cat=NULL; - - if (!ast_strlen_zero(data)) { - ast_copy_string(tmp, data, sizeof(tmp)); - grp = tmp; - cat = strchr(tmp, '@'); - if (cat) { - *cat = '\0'; - cat++; - } - } - - if (!ast_strlen_zero(grp)) - ast_copy_string(group, grp, group_max); - else - *group = '\0'; - - if (!ast_strlen_zero(cat)) - ast_copy_string(category, cat, category_max); - - return res; -} - -int ast_app_group_set_channel(struct ast_channel *chan, const char *data) -{ - int res = 0; - char group[80] = "", category[80] = ""; - struct ast_group_info *gi = NULL; - size_t len = 0; - - if (ast_app_group_split_group(data, group, sizeof(group), category, sizeof(category))) - return -1; - - /* Calculate memory we will need if this is new */ - len = sizeof(*gi) + strlen(group) + 1; - if (!ast_strlen_zero(category)) - len += strlen(category) + 1; - - AST_LIST_LOCK(&groups); - AST_LIST_TRAVERSE_SAFE_BEGIN(&groups, gi, list) { - if ((gi->chan == chan) && ((ast_strlen_zero(category) && ast_strlen_zero(gi->category)) || (!ast_strlen_zero(gi->category) && !strcasecmp(gi->category, category)))) { - AST_LIST_REMOVE_CURRENT(&groups, list); - free(gi); - break; - } - } - AST_LIST_TRAVERSE_SAFE_END - - if (ast_strlen_zero(group)) { - /* Enable unsetting the group */ - } else if ((gi = calloc(1, len))) { - gi->chan = chan; - gi->group = (char *) gi + sizeof(*gi); - strcpy(gi->group, group); - if (!ast_strlen_zero(category)) { - gi->category = (char *) gi + sizeof(*gi) + strlen(group) + 1; - strcpy(gi->category, category); - } - AST_LIST_INSERT_TAIL(&groups, gi, list); - } else { - res = -1; - } - - AST_LIST_UNLOCK(&groups); - - return res; -} - -int ast_app_group_get_count(const char *group, const char *category) -{ - struct ast_group_info *gi = NULL; - int count = 0; - - if (ast_strlen_zero(group)) - return 0; - - AST_LIST_LOCK(&groups); - AST_LIST_TRAVERSE(&groups, gi, list) { - if (!strcasecmp(gi->group, group) && (ast_strlen_zero(category) || (!ast_strlen_zero(gi->category) && !strcasecmp(gi->category, category)))) - count++; - } - AST_LIST_UNLOCK(&groups); - - return count; -} - -int ast_app_group_match_get_count(const char *groupmatch, const char *category) -{ - struct ast_group_info *gi = NULL; - regex_t regexbuf; - int count = 0; - - if (ast_strlen_zero(groupmatch)) - return 0; - - /* if regex compilation fails, return zero matches */ - if (regcomp(®exbuf, groupmatch, REG_EXTENDED | REG_NOSUB)) - return 0; - - AST_LIST_LOCK(&groups); - AST_LIST_TRAVERSE(&groups, gi, list) { - if (!regexec(®exbuf, gi->group, 0, NULL, 0) && (ast_strlen_zero(category) || (!ast_strlen_zero(gi->category) && !strcasecmp(gi->category, category)))) - count++; - } - AST_LIST_UNLOCK(&groups); - - regfree(®exbuf); - - return count; -} - -int ast_app_group_update(struct ast_channel *old, struct ast_channel *new) -{ - struct ast_group_info *gi = NULL; - - AST_LIST_LOCK(&groups); - AST_LIST_TRAVERSE_SAFE_BEGIN(&groups, gi, list) { - if (gi->chan == old) { - gi->chan = new; - } else if (gi->chan == new) { - AST_LIST_REMOVE_CURRENT(&groups, list); - free(gi); - } - } - AST_LIST_TRAVERSE_SAFE_END - AST_LIST_UNLOCK(&groups); - - return 0; -} - -int ast_app_group_discard(struct ast_channel *chan) -{ - struct ast_group_info *gi = NULL; - - AST_LIST_LOCK(&groups); - AST_LIST_TRAVERSE_SAFE_BEGIN(&groups, gi, list) { - if (gi->chan == chan) { - AST_LIST_REMOVE_CURRENT(&groups, list); - free(gi); - } - } - AST_LIST_TRAVERSE_SAFE_END - AST_LIST_UNLOCK(&groups); - - return 0; -} - -int ast_app_group_list_lock(void) -{ - return AST_LIST_LOCK(&groups); -} - -struct ast_group_info *ast_app_group_list_head(void) -{ - return AST_LIST_FIRST(&groups); -} - -int ast_app_group_list_unlock(void) -{ - return AST_LIST_UNLOCK(&groups); -} - -unsigned int ast_app_separate_args(char *buf, char delim, char **array, int arraylen) -{ - int argc; - char *scan, *wasdelim = NULL; - int paren = 0, quote = 0; - - if (!buf || !array || !arraylen) - return 0; - - memset(array, 0, arraylen * sizeof(*array)); - - scan = buf; - - for (argc = 0; *scan && (argc < arraylen - 1); argc++) { - array[argc] = scan; - for (; *scan; scan++) { - if (*scan == '(') - paren++; - else if (*scan == ')') { - if (paren) - paren--; - } else if (*scan == '"' && delim != '"') { - quote = quote ? 0 : 1; - /* Remove quote character from argument */ - memmove(scan, scan + 1, strlen(scan)); - scan--; - } else if (*scan == '\\') { - /* Literal character, don't parse */ - memmove(scan, scan + 1, strlen(scan)); - } else if ((*scan == delim) && !paren && !quote) { - wasdelim = scan; - *scan++ = '\0'; - break; - } - } - } - - /* If the last character in the original string was the delimiter, then - * there is one additional argument. */ - if (*scan || (scan > buf && (scan - 1) == wasdelim)) { - array[argc++] = scan; - } - - return argc; -} - -enum AST_LOCK_RESULT ast_lock_path(const char *path) -{ - char *s; - char *fs; - int res; - int fd; - int lp = strlen(path); - time_t start; - - if (!(s = alloca(lp + 10)) || !(fs = alloca(lp + 20))) { - ast_log(LOG_WARNING, "Out of memory!\n"); - return AST_LOCK_FAILURE; - } - - snprintf(fs, strlen(path) + 19, "%s/.lock-%08lx", path, ast_random()); - fd = open(fs, O_WRONLY | O_CREAT | O_EXCL, 0600); - if (fd < 0) { - ast_log(LOG_ERROR, "Unable to create lock file '%s': %s\n", path, strerror(errno)); - return AST_LOCK_PATH_NOT_FOUND; - } - close(fd); - - snprintf(s, strlen(path) + 9, "%s/.lock", path); - start = time(NULL); - while (((res = link(fs, s)) < 0) && (errno == EEXIST) && (time(NULL) - start < 5)) - usleep(1); - - unlink(fs); - - if (res) { - ast_log(LOG_WARNING, "Failed to lock path '%s': %s\n", path, strerror(errno)); - return AST_LOCK_TIMEOUT; - } else { - if (option_debug) - ast_log(LOG_DEBUG, "Locked path '%s'\n", path); - return AST_LOCK_SUCCESS; - } -} - -int ast_unlock_path(const char *path) -{ - char *s; - int res; - - if (!(s = alloca(strlen(path) + 10))) { - ast_log(LOG_WARNING, "Out of memory!\n"); - return -1; - } - - snprintf(s, strlen(path) + 9, "%s/%s", path, ".lock"); - - if ((res = unlink(s))) - ast_log(LOG_ERROR, "Could not unlock path '%s': %s\n", path, strerror(errno)); - else { - if (option_debug) - ast_log(LOG_DEBUG, "Unlocked path '%s'\n", path); - } - - return res; -} - -int ast_record_review(struct ast_channel *chan, const char *playfile, const char *recordfile, int maxtime, const char *fmt, int *duration, const char *path) -{ - int silencethreshold = 128; - int maxsilence=0; - int res = 0; - int cmd = 0; - int max_attempts = 3; - int attempts = 0; - int recorded = 0; - int message_exists = 0; - /* Note that urgent and private are for flagging messages as such in the future */ - - /* barf if no pointer passed to store duration in */ - if (duration == NULL) { - ast_log(LOG_WARNING, "Error ast_record_review called without duration pointer\n"); - return -1; - } - - cmd = '3'; /* Want to start by recording */ - - while ((cmd >= 0) && (cmd != 't')) { - switch (cmd) { - case '1': - if (!message_exists) { - /* In this case, 1 is to record a message */ - cmd = '3'; - break; - } else { - ast_stream_and_wait(chan, "vm-msgsaved", chan->language, ""); - cmd = 't'; - return res; - } - case '2': - /* Review */ - ast_verbose(VERBOSE_PREFIX_3 "Reviewing the recording\n"); - cmd = ast_stream_and_wait(chan, recordfile, chan->language, AST_DIGIT_ANY); - break; - case '3': - message_exists = 0; - /* Record */ - if (recorded == 1) - ast_verbose(VERBOSE_PREFIX_3 "Re-recording\n"); - else - ast_verbose(VERBOSE_PREFIX_3 "Recording\n"); - recorded = 1; - cmd = ast_play_and_record(chan, playfile, recordfile, maxtime, fmt, duration, silencethreshold, maxsilence, path); - if (cmd == -1) { - /* User has hung up, no options to give */ - return cmd; - } - if (cmd == '0') { - break; - } else if (cmd == '*') { - break; - } - else { - /* If all is well, a message exists */ - message_exists = 1; - cmd = 0; - } - break; - case '4': - case '5': - case '6': - case '7': - case '8': - case '9': - case '*': - case '#': - cmd = ast_play_and_wait(chan, "vm-sorry"); - break; - default: - if (message_exists) { - cmd = ast_play_and_wait(chan, "vm-review"); - } - else { - cmd = ast_play_and_wait(chan, "vm-torerecord"); - if (!cmd) - cmd = ast_waitfordigit(chan, 600); - } - - if (!cmd) - cmd = ast_waitfordigit(chan, 6000); - if (!cmd) { - attempts++; - } - if (attempts > max_attempts) { - cmd = 't'; - } - } - } - if (cmd == 't') - cmd = 0; - return cmd; -} - -#define RES_UPONE (1 << 16) -#define RES_EXIT (1 << 17) -#define RES_REPEAT (1 << 18) -#define RES_RESTART ((1 << 19) | RES_REPEAT) - -static int ast_ivr_menu_run_internal(struct ast_channel *chan, struct ast_ivr_menu *menu, void *cbdata); - -static int ivr_dispatch(struct ast_channel *chan, struct ast_ivr_option *option, char *exten, void *cbdata) -{ - int res; - int (*ivr_func)(struct ast_channel *, void *); - char *c; - char *n; - - switch(option->action) { - case AST_ACTION_UPONE: - return RES_UPONE; - case AST_ACTION_EXIT: - return RES_EXIT | (((unsigned long)(option->adata)) & 0xffff); - case AST_ACTION_REPEAT: - return RES_REPEAT | (((unsigned long)(option->adata)) & 0xffff); - case AST_ACTION_RESTART: - return RES_RESTART ; - case AST_ACTION_NOOP: - return 0; - case AST_ACTION_BACKGROUND: - res = ast_stream_and_wait(chan, (char *)option->adata, chan->language, AST_DIGIT_ANY); - if (res < 0) { - ast_log(LOG_NOTICE, "Unable to find file '%s'!\n", (char *)option->adata); - res = 0; - } - return res; - case AST_ACTION_PLAYBACK: - res = ast_stream_and_wait(chan, (char *)option->adata, chan->language, ""); - if (res < 0) { - ast_log(LOG_NOTICE, "Unable to find file '%s'!\n", (char *)option->adata); - res = 0; - } - return res; - case AST_ACTION_MENU: - res = ast_ivr_menu_run_internal(chan, (struct ast_ivr_menu *)option->adata, cbdata); - /* Do not pass entry errors back up, treaat ast though ti was an "UPONE" */ - if (res == -2) - res = 0; - return res; - case AST_ACTION_WAITOPTION: - res = ast_waitfordigit(chan, 1000 * (chan->pbx ? chan->pbx->rtimeout : 10)); - if (!res) - return 't'; - return res; - case AST_ACTION_CALLBACK: - ivr_func = option->adata; - res = ivr_func(chan, cbdata); - return res; - case AST_ACTION_TRANSFER: - res = ast_parseable_goto(chan, option->adata); - return 0; - case AST_ACTION_PLAYLIST: - case AST_ACTION_BACKLIST: - res = 0; - c = ast_strdupa(option->adata); - while ((n = strsep(&c, ";"))) { - if ((res = ast_stream_and_wait(chan, n, chan->language, - (option->action == AST_ACTION_BACKLIST) ? AST_DIGIT_ANY : ""))) - break; - } - ast_stopstream(chan); - return res; - default: - ast_log(LOG_NOTICE, "Unknown dispatch function %d, ignoring!\n", option->action); - return 0; - }; - return -1; -} - -static int option_exists(struct ast_ivr_menu *menu, char *option) -{ - int x; - for (x = 0; menu->options[x].option; x++) - if (!strcasecmp(menu->options[x].option, option)) - return x; - return -1; -} - -static int option_matchmore(struct ast_ivr_menu *menu, char *option) -{ - int x; - for (x = 0; menu->options[x].option; x++) - if ((!strncasecmp(menu->options[x].option, option, strlen(option))) && - (menu->options[x].option[strlen(option)])) - return x; - return -1; -} - -static int read_newoption(struct ast_channel *chan, struct ast_ivr_menu *menu, char *exten, int maxexten) -{ - int res=0; - int ms; - while (option_matchmore(menu, exten)) { - ms = chan->pbx ? chan->pbx->dtimeout : 5000; - if (strlen(exten) >= maxexten - 1) - break; - res = ast_waitfordigit(chan, ms); - if (res < 1) - break; - exten[strlen(exten) + 1] = '\0'; - exten[strlen(exten)] = res; - } - return res > 0 ? 0 : res; -} - -static int ast_ivr_menu_run_internal(struct ast_channel *chan, struct ast_ivr_menu *menu, void *cbdata) -{ - /* Execute an IVR menu structure */ - int res=0; - int pos = 0; - int retries = 0; - char exten[AST_MAX_EXTENSION] = "s"; - if (option_exists(menu, "s") < 0) { - strcpy(exten, "g"); - if (option_exists(menu, "g") < 0) { - ast_log(LOG_WARNING, "No 's' nor 'g' extension in menu '%s'!\n", menu->title); - return -1; - } - } - while(!res) { - while(menu->options[pos].option) { - if (!strcasecmp(menu->options[pos].option, exten)) { - res = ivr_dispatch(chan, menu->options + pos, exten, cbdata); - if (option_debug) - ast_log(LOG_DEBUG, "IVR Dispatch of '%s' (pos %d) yields %d\n", exten, pos, res); - if (res < 0) - break; - else if (res & RES_UPONE) - return 0; - else if (res & RES_EXIT) - return res; - else if (res & RES_REPEAT) { - int maxretries = res & 0xffff; - if ((res & RES_RESTART) == RES_RESTART) { - retries = 0; - } else - retries++; - if (!maxretries) - maxretries = 3; - if ((maxretries > 0) && (retries >= maxretries)) { - if (option_debug) - ast_log(LOG_DEBUG, "Max retries %d exceeded\n", maxretries); - return -2; - } else { - if (option_exists(menu, "g") > -1) - strcpy(exten, "g"); - else if (option_exists(menu, "s") > -1) - strcpy(exten, "s"); - } - pos = 0; - continue; - } else if (res && strchr(AST_DIGIT_ANY, res)) { - if (option_debug) - ast_log(LOG_DEBUG, "Got start of extension, %c\n", res); - exten[1] = '\0'; - exten[0] = res; - if ((res = read_newoption(chan, menu, exten, sizeof(exten)))) - break; - if (option_exists(menu, exten) < 0) { - if (option_exists(menu, "i")) { - if (option_debug) - ast_log(LOG_DEBUG, "Invalid extension entered, going to 'i'!\n"); - strcpy(exten, "i"); - pos = 0; - continue; - } else { - if (option_debug) - ast_log(LOG_DEBUG, "Aborting on invalid entry, with no 'i' option!\n"); - res = -2; - break; - } - } else { - if (option_debug) - ast_log(LOG_DEBUG, "New existing extension: %s\n", exten); - pos = 0; - continue; - } - } - } - pos++; - } - if (option_debug) - ast_log(LOG_DEBUG, "Stopping option '%s', res is %d\n", exten, res); - pos = 0; - if (!strcasecmp(exten, "s")) - strcpy(exten, "g"); - else - break; - } - return res; -} - -int ast_ivr_menu_run(struct ast_channel *chan, struct ast_ivr_menu *menu, void *cbdata) -{ - int res = ast_ivr_menu_run_internal(chan, menu, cbdata); - /* Hide internal coding */ - return res > 0 ? 0 : res; -} - -char *ast_read_textfile(const char *filename) -{ - int fd; - char *output = NULL; - struct stat filesize; - int count = 0; - int res; - if (stat(filename, &filesize) == -1) { - ast_log(LOG_WARNING, "Error can't stat %s\n", filename); - return NULL; - } - count = filesize.st_size + 1; - fd = open(filename, O_RDONLY); - if (fd < 0) { - ast_log(LOG_WARNING, "Cannot open file '%s' for reading: %s\n", filename, strerror(errno)); - return NULL; - } - if ((output = ast_malloc(count))) { - res = read(fd, output, count - 1); - if (res == count - 1) { - output[res] = '\0'; - } else { - ast_log(LOG_WARNING, "Short read of %s (%d of %d): %s\n", filename, res, count - 1, strerror(errno)); - free(output); - output = NULL; - } - } - close(fd); - return output; -} - -void ast_app_options2str(const struct ast_app_option *options, struct ast_flags *flags, char *buf, size_t len) -{ - unsigned int i, found = 0; - - for (i = 32; i < 128 && found < len;i++) { - if (ast_test_flag(flags, options[i].flag)) { - buf[found++] = i; - } - } - buf[found] = '\0'; -} - -int ast_app_parse_options(const struct ast_app_option *options, struct ast_flags *flags, char **args, char *optstr) -{ - char *s; - int curarg; - unsigned int argloc; - char *arg; - int res = 0; - - ast_clear_flag(flags, AST_FLAGS_ALL); - - if (!optstr) - return 0; - - s = optstr; - while (*s) { - curarg = *s++ & 0x7f; /* the array (in app.h) has 128 entries */ - argloc = options[curarg].arg_index; - if (*s == '(') { - /* Has argument */ - arg = ++s; - if ((s = strchr(s, ')'))) { - if (argloc) - args[argloc - 1] = arg; - *s++ = '\0'; - } else { - ast_log(LOG_WARNING, "Missing closing parenthesis for argument '%c' in string '%s'\n", curarg, arg); - res = -1; - break; - } - } else if (argloc) { - args[argloc - 1] = ""; - } - ast_set_flag(flags, options[curarg].flag); - } - - return res; -} - |