Version 0.3.0 from FTP

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

1 files changed, 104 insertions, 0 deletions

diff --git a/app.c b/app.c
index 2d2af6de9..482c2ee3a 100755
--- a/app.c
+++ b/app.c
@@ -19,9 +19,15 @@
 #include <signal.h>
 #include <errno.h>
 #include <unistd.h>
+#include <dirent.h>
 #include <asterisk/channel.h>
 #include <asterisk/file.h>
 #include <asterisk/app.h>
+#include <asterisk/dsp.h>
+#include <asterisk/logger.h>
+#include <asterisk/options.h>
+#include "asterisk.h"
+#include "astconf.h"
 
 /* set timeout to 0 for "standard" timeouts. Set timeout to -1 for 
    "ludicrous time" (essentially never times out) */
@@ -41,3 +47,101 @@ int ast_app_getdata(struct ast_channel *c, char *prompt, char *s, int maxlen, in
 	return res;
 }
 
+int ast_app_getvoice(struct ast_channel *c, char *dest, char *dstfmt, char *prompt, int silence, int maxsec)
+{
+	int res;
+	struct ast_filestream *writer;
+	int rfmt;
+	int totalms, total;
+	
+	struct ast_frame *f;
+	struct ast_dsp *sildet;
+	/* Play prompt if requested */
+	if (prompt) {
+		res = ast_streamfile(c, prompt, c->language);
+		if (res < 0)
+			return res;
+		res = ast_waitstream(c,"");
+		if (res < 0)
+			return res;
+	}
+	rfmt = c->readformat;
+	res = ast_set_read_format(c, AST_FORMAT_SLINEAR);
+	if (res < 0) {
+		ast_log(LOG_WARNING, "Unable to set to linear mode, giving up\n");
+		return -1;
+	}
+	sildet = ast_dsp_new();
+	if (!sildet) {
+		ast_log(LOG_WARNING, "Unable to create silence detector :(\n");
+		return -1;
+	}
+	writer = ast_writefile(dest, dstfmt, "Voice file", 0, 0, 0666);
+	if (!writer) {
+		ast_log(LOG_WARNING, "Unable to open file '%s' in format '%s' for writing\n", dest, dstfmt);
+		ast_dsp_free(sildet);
+		return -1;
+	}
+	for(;;) {
+		if ((res = ast_waitfor(c, 2000)) < 0) {
+			ast_log(LOG_NOTICE, "Waitfor failed while recording file '%s' format '%s'\n", dest, dstfmt);
+			break;
+		}
+		if (res) {
+			f = ast_read(c);
+			if (!f) {
+				ast_log(LOG_NOTICE, "Hungup while recording file '%s' format '%s'\n", dest, dstfmt);
+				break;
+			}
+			if ((f->frametype == AST_FRAME_DTMF) && (f->subclass == '#')) {
+				/* Ended happily with DTMF */
+				ast_frfree(f);
+				break;
+			} else if (f->frametype == AST_FRAME_VOICE) {
+				ast_dsp_silence(sildet, f, &total); 
+				if (total > silence) {
+					/* Ended happily with silence */
+					ast_frfree(f);
+					break;
+				}
+				totalms += f->samples / 8;
+				if (totalms > maxsec * 1000) {
+					/* Ended happily with too much stuff */
+					ast_log(LOG_NOTICE, "Constraining voice on '%s' to %d seconds\n", c->name, maxsec);
+					ast_frfree(f);
+					break;
+				}
+			}
+			ast_frfree(f);
+		}
+	}
+	res = ast_set_read_format(c, rfmt);
+	if (res)
+		ast_log(LOG_WARNING, "Unable to restore read format on '%s'\n", c->name);
+	ast_dsp_free(sildet);
+	ast_closestream(writer);
+	return 0;
+}
+
+int ast_app_has_voicemail(char *mailbox)
+{
+	DIR *dir;
+	struct dirent *de;
+	char fn[256];
+
+	/* If no mailbox, return immediately */
+	if (!strlen(mailbox))
+		return 0;
+	snprintf(fn, sizeof(fn), "%s/vm/%s/INBOX", (char *)ast_config_AST_SPOOL_DIR, mailbox);
+	dir = opendir(fn);
+	if (!dir)
+		return 0;
+	while ((de = readdir(dir))) {
+		if (!strncasecmp(de->d_name, "msg", 3))
+			break;
+	}
+	closedir(dir);
+	if (de)
+		return 1;
+	return 0;
+}