Asterisk
/
asterisk
mirror of https://github.com/asterisk/asterisk
1
0
Fork 0
Code Issues Releases Wiki Activity

Merged revisions 193870 via svnmerge from

Browse Source 
https://origsvn.digium.com/svn/asterisk/trunk

........
  r193870 | tilghman | 2009-05-12 12:29:33 -0500 (Tue, 12 May 2009) | 2 lines
  
  Convert a THREADSTORAGE object into a simple malloc'd object (as suggested by Russell on -dev)
........


git-svn-id: https://origsvn.digium.com/svn/asterisk/branches/1.6.0@193871 65c4cc65-6c06-0410-ace0-fbb531ad65f3
1.6.0
Tilghman Lesher 16 years ago
parent 0569b32ac0
commit b9d140e943
1 changed files with 369 additions and 346 deletions
Show Stats Download Patch File Download Diff File

715
apps/app_voicemail.c
Unescape View File

@ -227,8 +227,6 @@ static AST_LIST_HEAD_STATIC(vmstates, vmstate);
#define ERROR_MAILBOX_FULL -200 #define ERROR_MAILBOX_FULL -200
AST_THREADSTORAGE(voicemail_extension_list);
enum { enum {
NEW_FOLDER, NEW_FOLDER,
OLD_FOLDER, OLD_FOLDER,
@ -4255,424 +4253,449 @@ static int has_voicemail(const char *mailbox, const char *folder)
} }
} }
struct leave_vm_options { struct leave_vm_options {
unsigned int flags; unsigned int flags;
signed char record_gain; signed char record_gain;
char *exitcontext; char *exitcontext;
}; };
static int leave_voicemail(struct ast_channel *chan, char *ext, struct leave_vm_options *options) static int leave_voicemail(struct ast_channel *chan, char *ext, struct leave_vm_options *options)
{ {
#ifdef IMAP_STORAGE #ifdef IMAP_STORAGE
int newmsgs, oldmsgs; int newmsgs, oldmsgs;
#endif #endif
char txtfile[PATH_MAX], tmptxtfile[PATH_MAX]; char txtfile[PATH_MAX], tmptxtfile[PATH_MAX];
struct vm_state *vms = NULL; struct vm_state *vms = NULL;
char callerid[256]; char callerid[256];
FILE *txt; FILE *txt;
char date[256]; char date[256];
int txtdes; int txtdes;
int res = 0; int res = 0;
int msgnum; int msgnum;
int duration = 0; int duration = 0;
int ausemacro = 0; int ausemacro = 0;
int ousemacro = 0; int ousemacro = 0;
int ouseexten = 0; int ouseexten = 0;
int rtmsgid = 0; int rtmsgid = 0;
char tmpid[16]; char tmpid[16];
char tmpdur[16]; char tmpdur[16];
char priority[16]; char priority[16];
char origtime[16]; char origtime[16];
char dir[PATH_MAX], tmpdir[PATH_MAX]; char dir[PATH_MAX], tmpdir[PATH_MAX];
char fn[PATH_MAX]; char fn[PATH_MAX];
char prefile[PATH_MAX] = ""; char prefile[PATH_MAX] = "";
char tempfile[PATH_MAX] = ""; char tempfile[PATH_MAX] = "";
char ext_context[256] = ""; char ext_context[256] = "";
char fmt[80]; char fmt[80];
char *context; char *context;
char ecodes[17] = "#"; char ecodes[17] = "#";
char *tmpptr; char *tmpptr;
struct ast_str *tmp = ast_str_thread_get(&voicemail_extension_list, 16); struct ast_str *tmp = ast_str_create(16);
struct ast_vm_user *vmu; struct ast_vm_user *vmu;
struct ast_vm_user svm; struct ast_vm_user svm;
const char *category = NULL, *code, *alldtmf = "0123456789ABCD*#"; const char *category = NULL, *code, *alldtmf = "0123456789ABCD*#";
ast_str_set(&tmp, 0, "%s", ext);
ext = ast_str_buffer(tmp);
if ((context = strchr(ext, '@'))) {
*context++ = '\0';
tmpptr = strchr(context, '&');
} else {
tmpptr = strchr(ext, '&');
}
if (tmpptr) ast_str_set(&tmp, 0, "%s", ext);
*tmpptr++ = '\0'; ext = ast_str_buffer(tmp);
if ((context = strchr(ext, '@'))) {
*context++ = '\0';
tmpptr = strchr(context, '&');
} else {
tmpptr = strchr(ext, '&');
}
category = pbx_builtin_getvar_helper(chan, "VM_CATEGORY"); if (tmpptr) {
*tmpptr++ = '\0';
}
ast_debug(3, "Before find_user\n"); category = pbx_builtin_getvar_helper(chan, "VM_CATEGORY");
if (!(vmu = find_user(&svm, context, ext))) {
ast_log(LOG_WARNING, "No entry in voicemail config file for '%s'\n", ext);
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
return res;
}
/* Setup pre-file if appropriate */
if (strcmp(vmu->context, "default"))
snprintf(ext_context, sizeof(ext_context), "%s@%s", ext, vmu->context);
else
ast_copy_string(ext_context, vmu->mailbox, sizeof(ext_context));
if (ast_test_flag(options, OPT_BUSY_GREETING)) {
snprintf(prefile, sizeof(prefile), "%s%s/%s/busy", VM_SPOOL_DIR, vmu->context, ext);
} else if (ast_test_flag(options, OPT_UNAVAIL_GREETING)) {
snprintf(prefile, sizeof(prefile), "%s%s/%s/unavail", VM_SPOOL_DIR, vmu->context, ext);
}
snprintf(tempfile, sizeof(tempfile), "%s%s/%s/temp", VM_SPOOL_DIR, vmu->context, ext);
if ((res = create_dirpath(tmpdir, sizeof(tmpdir), vmu->context, ext, "tmp"))) {
ast_log(LOG_WARNING, "Failed to make directory (%s)\n", tempfile);
return -1;
}
RETRIEVE(tempfile, -1, vmu->mailbox, vmu->context);
if (ast_fileexists(tempfile, NULL, NULL) > 0)
ast_copy_string(prefile, tempfile, sizeof(prefile));
DISPOSE(tempfile, -1);
/* It's easier just to try to make it than to check for its existence */
create_dirpath(dir, sizeof(dir), vmu->context, ext, "INBOX");
/* Check current or macro-calling context for special extensions */ ast_debug(3, "Before find_user\n");
if (ast_test_flag(vmu, VM_OPERATOR)) { if (!(vmu = find_user(&svm, context, ext))) {
if (!ast_strlen_zero(vmu->exit)) { ast_log(LOG_WARNING, "No entry in voicemail config file for '%s'\n", ext);
if (ast_exists_extension(chan, vmu->exit, "o", 1, chan->cid.cid_num)) { pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1); ast_free(tmp);
ouseexten = 1; return res;
} }
} else if (ast_exists_extension(chan, chan->context, "o", 1, chan->cid.cid_num)) { /* Setup pre-file if appropriate */
if (strcmp(vmu->context, "default")) {
snprintf(ext_context, sizeof(ext_context), "%s@%s", ext, vmu->context);
} else {
ast_copy_string(ext_context, vmu->mailbox, sizeof(ext_context));
}
if (ast_test_flag(options, OPT_BUSY_GREETING)) {
snprintf(prefile, sizeof(prefile), "%s%s/%s/busy", VM_SPOOL_DIR, vmu->context, ext);
} else if (ast_test_flag(options, OPT_UNAVAIL_GREETING)) {
snprintf(prefile, sizeof(prefile), "%s%s/%s/unavail", VM_SPOOL_DIR, vmu->context, ext);
}
snprintf(tempfile, sizeof(tempfile), "%s%s/%s/temp", VM_SPOOL_DIR, vmu->context, ext);
if ((res = create_dirpath(tmpdir, sizeof(tmpdir), vmu->context, ext, "tmp"))) {
ast_log(LOG_WARNING, "Failed to make directory (%s)\n", tempfile);
ast_free(tmp);
return -1;
}
RETRIEVE(tempfile, -1, vmu->mailbox, vmu->context);
if (ast_fileexists(tempfile, NULL, NULL) > 0) {
ast_copy_string(prefile, tempfile, sizeof(prefile));
}
DISPOSE(tempfile, -1);
/* It's easier just to try to make it than to check for its existence */
create_dirpath(dir, sizeof(dir), vmu->context, ext, "INBOX");
/* Check current or macro-calling context for special extensions */
if (ast_test_flag(vmu, VM_OPERATOR)) {
if (!ast_strlen_zero(vmu->exit)) {
if (ast_exists_extension(chan, vmu->exit, "o", 1, chan->cid.cid_num)) {
strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1); strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1);
ouseexten = 1; ouseexten = 1;
} else if (!ast_strlen_zero(chan->macrocontext) && ast_exists_extension(chan, chan->macrocontext, "o", 1, chan->cid.cid_num)) {
strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1);
ousemacro = 1;
} }
} else if (ast_exists_extension(chan, chan->context, "o", 1, chan->cid.cid_num)) {
strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1);
ouseexten = 1;
} else if (!ast_strlen_zero(chan->macrocontext) && ast_exists_extension(chan, chan->macrocontext, "o", 1, chan->cid.cid_num)) {
strncat(ecodes, "0", sizeof(ecodes) - strlen(ecodes) - 1);
ousemacro = 1;
} }
}
if (!ast_strlen_zero(vmu->exit)) { if (!ast_strlen_zero(vmu->exit)) {
if (ast_exists_extension(chan, vmu->exit, "a", 1, chan->cid.cid_num)) if (ast_exists_extension(chan, vmu->exit, "a", 1, chan->cid.cid_num)) {
strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1);
} else if (ast_exists_extension(chan, chan->context, "a", 1, chan->cid.cid_num))
strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1);
else if (!ast_strlen_zero(chan->macrocontext) && ast_exists_extension(chan, chan->macrocontext, "a", 1, chan->cid.cid_num)) {
strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1); strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1);
ausemacro = 1;
} }
} else if (ast_exists_extension(chan, chan->context, "a", 1, chan->cid.cid_num)) {
strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1);
} else if (!ast_strlen_zero(chan->macrocontext) && ast_exists_extension(chan, chan->macrocontext, "a", 1, chan->cid.cid_num)) {
strncat(ecodes, "*", sizeof(ecodes) - strlen(ecodes) - 1);
ausemacro = 1;
}
if (ast_test_flag(options, OPT_DTMFEXIT)) { if (ast_test_flag(options, OPT_DTMFEXIT)) {
for (code = alldtmf; *code; code++) { for (code = alldtmf; *code; code++) {
char e[2] = ""; char e[2] = "";
e[0] = *code; e[0] = *code;
if (strchr(ecodes, e[0]) == NULL && ast_canmatch_extension(chan, chan->context, e, 1, chan->cid.cid_num)) if (strchr(ecodes, e[0]) == NULL && ast_canmatch_extension(chan, chan->context, e, 1, chan->cid.cid_num)) {
strncat(ecodes, e, sizeof(ecodes) - strlen(ecodes) - 1); strncat(ecodes, e, sizeof(ecodes) - strlen(ecodes) - 1);
} }
} }
}
/* Play the beginning intro if desired */ /* Play the beginning intro if desired */
if (!ast_strlen_zero(prefile)) { if (!ast_strlen_zero(prefile)) {
res = play_greeting(chan, vmu, prefile, ecodes); res = play_greeting(chan, vmu, prefile, ecodes);
if (res == -2) { if (res == -2) {
/* The file did not exist */ /* The file did not exist */
ast_debug(1, "%s doesn't exist, doing what we can\n", prefile); ast_debug(1, "%s doesn't exist, doing what we can\n", prefile);
res = invent_message(chan, vmu, ext, ast_test_flag(options, OPT_BUSY_GREETING), ecodes); res = invent_message(chan, vmu, ext, ast_test_flag(options, OPT_BUSY_GREETING), ecodes);
} }
if (res < 0) { if (res < 0) {
ast_debug(1, "Hang up during prefile playback\n"); ast_debug(1, "Hang up during prefile playback\n");
free_user(vmu); free_user(vmu);
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED"); pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
return -1; ast_free(tmp);
} return -1;
} }
}
if (res == '#') {
/* On a '#' we skip the instructions */
ast_set_flag(options, OPT_SILENT);
res = 0;
}
if (!res && !ast_test_flag(options, OPT_SILENT)) {
res = ast_stream_and_wait(chan, INTRO, ecodes);
if (res == '#') { if (res == '#') {
/* On a '#' we skip the instructions */
ast_set_flag(options, OPT_SILENT); ast_set_flag(options, OPT_SILENT);
res = 0; res = 0;
} }
if (!res && !ast_test_flag(options, OPT_SILENT)) { }
res = ast_stream_and_wait(chan, INTRO, ecodes); if (res > 0) {
if (res == '#') { ast_stopstream(chan);
ast_set_flag(options, OPT_SILENT); }
res = 0; /* Check for a '*' here in case the caller wants to escape from voicemail to something
} * other than the operator -- an automated attendant or mailbox login for example */
if (res == '*') {
chan->exten[0] = 'a';
chan->exten[1] = '\0';
if (!ast_strlen_zero(vmu->exit)) {
ast_copy_string(chan->context, vmu->exit, sizeof(chan->context));
} else if (ausemacro && !ast_strlen_zero(chan->macrocontext)) {
ast_copy_string(chan->context, chan->macrocontext, sizeof(chan->context));
} }
if (res > 0) chan->priority = 0;
ast_stopstream(chan); free_user(vmu);
/* Check for a '*' here in case the caller wants to escape from voicemail to something pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT");
other than the operator -- an automated attendant or mailbox login for example */ ast_free(tmp);
if (res == '*') { return 0;
chan->exten[0] = 'a'; }
/* Check for a '0' here */
if (ast_test_flag(vmu, VM_OPERATOR) && res == '0') {
transfer:
if (ouseexten || ousemacro) {
chan->exten[0] = 'o';
chan->exten[1] = '\0'; chan->exten[1] = '\0';
if (!ast_strlen_zero(vmu->exit)) { if (!ast_strlen_zero(vmu->exit)) {
ast_copy_string(chan->context, vmu->exit, sizeof(chan->context)); ast_copy_string(chan->context, vmu->exit, sizeof(chan->context));
} else if (ausemacro && !ast_strlen_zero(chan->macrocontext)) { } else if (ousemacro && !ast_strlen_zero(chan->macrocontext)) {
ast_copy_string(chan->context, chan->macrocontext, sizeof(chan->context)); ast_copy_string(chan->context, chan->macrocontext, sizeof(chan->context));
} }
ast_play_and_wait(chan, "transfer");
chan->priority = 0; chan->priority = 0;
free_user(vmu); free_user(vmu);
pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT"); pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT");
return 0;
} }
ast_free(tmp);
return 0;
}
/* Check for a '0' here */ /* Allow all other digits to exit Voicemail and return to the dialplan */
if (ast_test_flag(vmu, VM_OPERATOR) && res == '0') { if (ast_test_flag(options, OPT_DTMFEXIT) && res > 0) {
transfer: if (!ast_strlen_zero(options->exitcontext)) {
if (ouseexten || ousemacro) { ast_copy_string(chan->context, options->exitcontext, sizeof(chan->context));
chan->exten[0] = 'o';
chan->exten[1] = '\0';
if (!ast_strlen_zero(vmu->exit)) {
ast_copy_string(chan->context, vmu->exit, sizeof(chan->context));
} else if (ousemacro && !ast_strlen_zero(chan->macrocontext)) {
ast_copy_string(chan->context, chan->macrocontext, sizeof(chan->context));
}
ast_play_and_wait(chan, "transfer");
chan->priority = 0;
free_user(vmu);
pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT");
}
return 0;
} }
free_user(vmu);
pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT");
return res;
}
/* Allow all other digits to exit Voicemail and return to the dialplan */ if (res < 0) {
if (ast_test_flag(options, OPT_DTMFEXIT) && res > 0) { free_user(vmu);
if (!ast_strlen_zero(options->exitcontext)) pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
ast_copy_string(chan->context, options->exitcontext, sizeof(chan->context)); ast_free(tmp);
free_user(vmu); return -1;
pbx_builtin_setvar_helper(chan, "VMSTATUS", "USEREXIT"); }
return res; /* The meat of recording the message... All the announcements and beeps have been played*/
} ast_copy_string(fmt, vmfmts, sizeof(fmt));
if (!ast_strlen_zero(fmt)) {
msgnum = 0;
#ifdef IMAP_STORAGE
/* Is ext a mailbox? */
/* must open stream for this user to get info! */
res = inboxcount(ext_context, &newmsgs, &oldmsgs);
if (res < 0) { if (res < 0) {
free_user(vmu); ast_log(LOG_NOTICE, "Can not leave voicemail, unable to count messages\n");
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED"); ast_free(tmp);
return -1; return -1;
} }
/* The meat of recording the message... All the announcements and beeps have been played*/ if (!(vms = get_vm_state_by_mailbox(ext, 0))) {
ast_copy_string(fmt, vmfmts, sizeof(fmt));
if (!ast_strlen_zero(fmt)) {
msgnum = 0;
#ifdef IMAP_STORAGE
/* Is ext a mailbox? */
/* must open stream for this user to get info! */
res = inboxcount(ext_context, &newmsgs, &oldmsgs);
if (res < 0) {
ast_log(LOG_NOTICE, "Can not leave voicemail, unable to count messages\n");
return -1;
}
if (!(vms = get_vm_state_by_mailbox(ext, 0))) {
/* It is possible under certain circumstances that inboxcount did not /* It is possible under certain circumstances that inboxcount did not
* create a vm_state when it was needed. This is a catchall which will * create a vm_state when it was needed. This is a catchall which will
* rarely be used. * rarely be used.
*/ */
if (!(vms = create_vm_state_from_user(vmu))) { if (!(vms = create_vm_state_from_user(vmu))) {
ast_log(LOG_ERROR, "Couldn't allocate necessary space\n"); ast_log(LOG_ERROR, "Couldn't allocate necessary space\n");
return -1; ast_free(tmp);
}
}
vms->newmessages++;
/* here is a big difference! We add one to it later */
msgnum = newmsgs + oldmsgs;
ast_debug(3, "Messagecount set to %d\n", msgnum);
snprintf(fn, sizeof(fn), "%s/imap/msg%s%04d", VM_SPOOL_DIR, vmu->mailbox, msgnum);
/* set variable for compatibility */
pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", "IMAP_STORAGE");
/* Check if mailbox is full */
check_quota(vms, imapfolder);
if (vms->quota_limit && vms->quota_usage >= vms->quota_limit) {
ast_debug(1, "*** QUOTA EXCEEDED!! %u >= %u\n", vms->quota_usage, vms->quota_limit);
ast_play_and_wait(chan, "vm-mailboxfull");
return -1;
}
/* Check if we have exceeded maxmsg */
if (msgnum >= vmu->maxmsg) {
ast_log(LOG_WARNING, "Unable to leave message since we will exceed the maximum number of messages allowed (%u > %u)\n", msgnum, vmu->maxmsg);
ast_play_and_wait(chan, "vm-mailboxfull");
return -1; return -1;
} }
}
vms->newmessages++;
/* here is a big difference! We add one to it later */
msgnum = newmsgs + oldmsgs;
ast_debug(3, "Messagecount set to %d\n", msgnum);
snprintf(fn, sizeof(fn), "%s/imap/msg%s%04d", VM_SPOOL_DIR, vmu->mailbox, msgnum);
/* set variable for compatibility */
pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", "IMAP_STORAGE");
/* Check if mailbox is full */
check_quota(vms, imapfolder);
if (vms->quota_limit && vms->quota_usage >= vms->quota_limit) {
ast_debug(1, "*** QUOTA EXCEEDED!! %u >= %u\n", vms->quota_usage, vms->quota_limit);
ast_play_and_wait(chan, "vm-mailboxfull");
ast_free(tmp);
return -1;
}
/* Check if we have exceeded maxmsg */
if (msgnum >= vmu->maxmsg) {
ast_log(LOG_WARNING, "Unable to leave message since we will exceed the maximum number of messages allowed (%u > %u)\n", msgnum, vmu->maxmsg);
ast_play_and_wait(chan, "vm-mailboxfull");
ast_free(tmp);
return -1;
}
#else #else
if (count_messages(vmu, dir) >= vmu->maxmsg) { if (count_messages(vmu, dir) >= vmu->maxmsg) {
res = ast_streamfile(chan, "vm-mailboxfull", chan->language); res = ast_streamfile(chan, "vm-mailboxfull", chan->language);
if (!res) if (!res) {
res = ast_waitstream(chan, ""); res = ast_waitstream(chan, "");
ast_log(LOG_WARNING, "No more messages possible\n");
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
goto leave_vm_out;
} }
ast_log(LOG_WARNING, "No more messages possible\n");
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
goto leave_vm_out;
}
#endif #endif
snprintf(tmptxtfile, sizeof(tmptxtfile), "%s/XXXXXX", tmpdir); snprintf(tmptxtfile, sizeof(tmptxtfile), "%s/XXXXXX", tmpdir);
txtdes = mkstemp(tmptxtfile); txtdes = mkstemp(tmptxtfile);
chmod(tmptxtfile, VOICEMAIL_FILE_MODE & ~my_umask); chmod(tmptxtfile, VOICEMAIL_FILE_MODE & ~my_umask);
if (txtdes < 0) { if (txtdes < 0) {
res = ast_streamfile(chan, "vm-mailboxfull", chan->language); res = ast_streamfile(chan, "vm-mailboxfull", chan->language);
if (!res) if (!res) {
res = ast_waitstream(chan, ""); res = ast_waitstream(chan, "");
ast_log(LOG_ERROR, "Unable to create message file: %s\n", strerror(errno));
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
goto leave_vm_out;
}
/* Now play the beep once we have the message number for our next message. */
if (res >= 0) {
/* Unless we're *really* silent, try to send the beep */
res = ast_stream_and_wait(chan, "beep", "");
} }
ast_log(LOG_ERROR, "Unable to create message file: %s\n", strerror(errno));
/* Store information in real-time storage */ pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
if (ast_check_realtime("voicemail_data")) { goto leave_vm_out;
snprintf(priority, sizeof(priority), "%d", chan->priority); }
snprintf(origtime, sizeof(origtime), "%ld", (long)time(NULL));
get_date(date, sizeof(date)); /* Now play the beep once we have the message number for our next message. */
rtmsgid = ast_store_realtime("voicemail_data", "origmailbox", ext, "context", chan->context, "macrocontext", chan->macrocontext, "exten", chan->exten, "priority", priority, "callerchan", chan->name, "callerid", ast_callerid_merge(callerid, sizeof(callerid), chan->cid.cid_name, chan->cid.cid_num, "Unknown"), "origdate", date, "origtime", origtime, "category", category ? category : "", NULL); if (res >= 0) {
} /* Unless we're *really* silent, try to send the beep */
res = ast_stream_and_wait(chan, "beep", "");
/* Store information */ }
txt = fdopen(txtdes, "w+");
if (txt) { /* Store information in real-time storage */
get_date(date, sizeof(date)); if (ast_check_realtime("voicemail_data")) {
fprintf(txt, snprintf(priority, sizeof(priority), "%d", chan->priority);
";\n" snprintf(origtime, sizeof(origtime), "%ld", (long)time(NULL));
"; Message Information file\n" get_date(date, sizeof(date));
";\n" rtmsgid = ast_store_realtime("voicemail_data", "origmailbox", ext, "context", chan->context, "macrocontext", chan->macrocontext, "exten", chan->exten, "priority", priority, "callerchan", chan->name, "callerid", ast_callerid_merge(callerid, sizeof(callerid), chan->cid.cid_name, chan->cid.cid_num, "Unknown"), "origdate", date, "origtime", origtime, "category", category ? category : "", NULL);
"[message]\n" }
"origmailbox=%s\n"
"context=%s\n" /* Store information */
"macrocontext=%s\n" txt = fdopen(txtdes, "w+");
"exten=%s\n" if (txt) {
"priority=%d\n" get_date(date, sizeof(date));
"callerchan=%s\n" fprintf(txt,
"callerid=%s\n" ";\n"
"origdate=%s\n" "; Message Information file\n"
"origtime=%ld\n" ";\n"
"category=%s\n", "[message]\n"
ext, "origmailbox=%s\n"
chan->context, "context=%s\n"
chan->macrocontext, "macrocontext=%s\n"
chan->exten, "exten=%s\n"
chan->priority, "priority=%d\n"
chan->name, "callerchan=%s\n"
ast_callerid_merge(callerid, sizeof(callerid), S_OR(chan->cid.cid_name, NULL), S_OR(chan->cid.cid_num, NULL), "Unknown"), "callerid=%s\n"
date, (long)time(NULL), "origdate=%s\n"
category ? category : ""); "origtime=%ld\n"
} else "category=%s\n",
ast_log(LOG_WARNING, "Error opening text file for output\n"); ext,
res = play_record_review(chan, NULL, tmptxtfile, vmu->maxsecs, fmt, 1, vmu, &duration, NULL, options->record_gain, vms); chan->context,
chan->macrocontext,
if (txt) { chan->exten,
if (duration < vmminsecs) { chan->priority,
fclose(txt); chan->name,
ast_verb(3, "Recording was %d seconds long but needs to be at least %d - abandoning\n", duration, vmminsecs); ast_callerid_merge(callerid, sizeof(callerid), S_OR(chan->cid.cid_name, NULL), S_OR(chan->cid.cid_num, NULL), "Unknown"),
date, (long)time(NULL),
category ? category : "");
} else {
ast_log(LOG_WARNING, "Error opening text file for output\n");
}
res = play_record_review(chan, NULL, tmptxtfile, vmu->maxsecs, fmt, 1, vmu, &duration, NULL, options->record_gain, vms);
if (txt) {
if (duration < vmminsecs) {
fclose(txt);
ast_verb(3, "Recording was %d seconds long but needs to be at least %d - abandoning\n", duration, vmminsecs);
ast_filedelete(tmptxtfile, NULL);
unlink(tmptxtfile);
if (ast_check_realtime("voicemail_data")) {
snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid);
ast_destroy_realtime("voicemail_data", "id", tmpid, NULL);
}
} else {
fprintf(txt, "duration=%d\n", duration);
fclose(txt);
if (vm_lock_path(dir)) {
ast_log(LOG_ERROR, "Couldn't lock directory %s. Voicemail will be lost.\n", dir);
/* Delete files */
ast_filedelete(tmptxtfile, NULL); ast_filedelete(tmptxtfile, NULL);
unlink(tmptxtfile); unlink(tmptxtfile);
} else if (ast_fileexists(tmptxtfile, NULL, NULL) <= 0) {
ast_debug(1, "The recorded media file is gone, so we should remove the .txt file too!\n");
unlink(tmptxtfile);
ast_unlock_path(dir);
if (ast_check_realtime("voicemail_data")) { if (ast_check_realtime("voicemail_data")) {
snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid); snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid);
ast_destroy_realtime("voicemail_data", "id", tmpid, NULL); ast_destroy_realtime("voicemail_data", "id", tmpid, NULL);
} }
} else { } else {
fprintf(txt, "duration=%d\n", duration);
fclose(txt);
if (vm_lock_path(dir)) {
ast_log(LOG_ERROR, "Couldn't lock directory %s. Voicemail will be lost.\n", dir);
/* Delete files */
ast_filedelete(tmptxtfile, NULL);
unlink(tmptxtfile);
} else if (ast_fileexists(tmptxtfile, NULL, NULL) <= 0) {
ast_debug(1, "The recorded media file is gone, so we should remove the .txt file too!\n");
unlink(tmptxtfile);
ast_unlock_path(dir);
if (ast_check_realtime("voicemail_data")) {
snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid);
ast_destroy_realtime("voicemail_data", "id", tmpid, NULL);
}
} else {
#ifndef IMAP_STORAGE #ifndef IMAP_STORAGE
msgnum = last_message_index(vmu, dir) + 1; msgnum = last_message_index(vmu, dir) + 1;
#endif #endif
make_file(fn, sizeof(fn), dir, msgnum); make_file(fn, sizeof(fn), dir, msgnum);
/* assign a variable with the name of the voicemail file */ /* assign a variable with the name of the voicemail file */
#ifndef IMAP_STORAGE #ifndef IMAP_STORAGE
pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", fn); pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", fn);
#else #else
pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", "IMAP_STORAGE"); pbx_builtin_setvar_helper(chan, "VM_MESSAGEFILE", "IMAP_STORAGE");
#endif #endif
snprintf(txtfile, sizeof(txtfile), "%s.txt", fn); snprintf(txtfile, sizeof(txtfile), "%s.txt", fn);
ast_filerename(tmptxtfile, fn, NULL); ast_filerename(tmptxtfile, fn, NULL);
rename(tmptxtfile, txtfile); rename(tmptxtfile, txtfile);
/* Properly set permissions on voicemail text descriptor file. /* Properly set permissions on voicemail text descriptor file.
Unfortunately mkstemp() makes this file 0600 on most unix systems. */ Unfortunately mkstemp() makes this file 0600 on most unix systems. */
if (chmod(txtfile, VOICEMAIL_FILE_MODE) < 0) if (chmod(txtfile, VOICEMAIL_FILE_MODE) < 0) {
ast_log(LOG_ERROR, "Couldn't set permissions on voicemail text file %s: %s", txtfile, strerror(errno)); ast_log(LOG_ERROR, "Couldn't set permissions on voicemail text file %s: %s", txtfile, strerror(errno));
}
ast_unlock_path(dir); ast_unlock_path(dir);
if (ast_check_realtime("voicemail_data")) { if (ast_check_realtime("voicemail_data")) {
snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid); snprintf(tmpid, sizeof(tmpid), "%d", rtmsgid);
snprintf(tmpdur, sizeof(tmpdur), "%d", duration); snprintf(tmpdur, sizeof(tmpdur), "%d", duration);
ast_update_realtime("voicemail_data", "id", tmpid, "filename", fn, "duration", tmpdur, NULL); ast_update_realtime("voicemail_data", "id", tmpid, "filename", fn, "duration", tmpdur, NULL);
} }
/* We must store the file first, before copying the message, because /* We must store the file first, before copying the message, because
* ODBC storage does the entire copy with SQL. * ODBC storage does the entire copy with SQL.
*/ */
if (ast_fileexists(fn, NULL, NULL) > 0) { if (ast_fileexists(fn, NULL, NULL) > 0) {
STORE(dir, vmu->mailbox, vmu->context, msgnum, chan, vmu, fmt, duration, vms); STORE(dir, vmu->mailbox, vmu->context, msgnum, chan, vmu, fmt, duration, vms);
} }
/* Are there to be more recipients of this message? */ /* Are there to be more recipients of this message? */
while (tmpptr) { while (tmpptr) {
struct ast_vm_user recipu, *recip; struct ast_vm_user recipu, *recip;
char *exten, *context; char *exten, *context;
exten = strsep(&tmpptr, "&"); exten = strsep(&tmpptr, "&");
context = strchr(exten, '@'); context = strchr(exten, '@');
if (context) { if (context) {
*context = '\0'; *context = '\0';
context++; context++;
}
if ((recip = find_user(&recipu, context, exten))) {
copy_message(chan, vmu, 0, msgnum, duration, recip, fmt, dir);
free_user(recip);
}
} }
/* Notification and disposal needs to happen after the copy, though. */ if ((recip = find_user(&recipu, context, exten))) {
if (ast_fileexists(fn, NULL, NULL)) { copy_message(chan, vmu, 0, msgnum, duration, recip, fmt, dir);
free_user(recip);
}
}
/* Notification and disposal needs to happen after the copy, though. */
if (ast_fileexists(fn, NULL, NULL)) {
#ifdef IMAP_STORAGE #ifdef IMAP_STORAGE
notify_new_message(chan, vmu, vms, msgnum, duration, fmt, S_OR(chan->cid.cid_num, NULL), S_OR(chan->cid.cid_name, NULL)); notify_new_message(chan, vmu, vms, msgnum, duration, fmt, S_OR(chan->cid.cid_num, NULL), S_OR(chan->cid.cid_name, NULL));
#else #else
notify_new_message(chan, vmu, NULL, msgnum, duration, fmt, S_OR(chan->cid.cid_num, NULL), S_OR(chan->cid.cid_name, NULL)); notify_new_message(chan, vmu, NULL, msgnum, duration, fmt, S_OR(chan->cid.cid_num, NULL), S_OR(chan->cid.cid_name, NULL));
#endif #endif
DISPOSE(dir, msgnum); DISPOSE(dir, msgnum);
}
} }
} }
} }
if (res == '0') { }
goto transfer; if (res == '0') {
} else if (res > 0) goto transfer;
res = 0; } else if (res > 0) {
res = 0;
}
if (duration < vmminsecs) if (duration < vmminsecs) {
/* XXX We should really give a prompt too short/option start again, with leave_vm_out called only after a timeout XXX */ /* XXX We should really give a prompt too short/option start again, with leave_vm_out called only after a timeout XXX */
pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED"); pbx_builtin_setvar_helper(chan, "VMSTATUS", "FAILED");
else } else {
pbx_builtin_setvar_helper(chan, "VMSTATUS", "SUCCESS"); pbx_builtin_setvar_helper(chan, "VMSTATUS", "SUCCESS");
} else }
ast_log(LOG_WARNING, "No format for saving voicemail?\n"); } else {
leave_vm_out: ast_log(LOG_WARNING, "No format for saving voicemail?\n");
free_user(vmu);
return res;
} }
leave_vm_out:
free_user(vmu);
ast_free(tmp);
return res;
}
#ifndef IMAP_STORAGE #ifndef IMAP_STORAGE
static int resequence_mailbox(struct ast_vm_user *vmu, char *dir) static int resequence_mailbox(struct ast_vm_user *vmu, char *dir)

Write Preview
Loading…
Cancel
Save