00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022
00023
00024
00025
00026
00027
00028 #include "asterisk.h"
00029
00030 ASTERISK_FILE_VERSION(__FILE__, "$Revision: 263769 $")
00031
00032 #include <string.h>
00033 #include <ctype.h>
00034 #include <stdlib.h>
00035 #include <stdio.h>
00036
00037 #include "asterisk/lock.h"
00038 #include "asterisk/file.h"
00039 #include "asterisk/logger.h"
00040 #include "asterisk/channel.h"
00041 #include "asterisk/pbx.h"
00042 #include "asterisk/module.h"
00043 #include "asterisk/config.h"
00044 #include "asterisk/say.h"
00045 #include "asterisk/utils.h"
00046 #include "asterisk/app.h"
00047
00048 #ifdef ODBC_STORAGE
00049 #include <errno.h>
00050 #include <sys/mman.h>
00051 #include "asterisk/res_odbc.h"
00052
00053 static char odbc_database[80] = "asterisk";
00054 static char odbc_table[80] = "voicemessages";
00055 static char vmfmts[80] = "wav";
00056 #endif
00057
00058 static char *app = "Directory";
00059
00060 static char *synopsis = "Provide directory of voicemail extensions";
00061 static char *descrip =
00062 " Directory(vm-context[|dial-context[|options]]): This application will present\n"
00063 "the calling channel with a directory of extensions from which they can search\n"
00064 "by name. The list of names and corresponding extensions is retrieved from the\n"
00065 "voicemail configuration file, voicemail.conf.\n"
00066 " This application will immediately exit if one of the following DTMF digits are\n"
00067 "received and the extension to jump to exists:\n"
00068 " 0 - Jump to the 'o' extension, if it exists.\n"
00069 " * - Jump to the 'a' extension, if it exists.\n\n"
00070 " Parameters:\n"
00071 " vm-context - This is the context within voicemail.conf to use for the\n"
00072 " Directory.\n"
00073 " dial-context - This is the dialplan context to use when looking for an\n"
00074 " extension that the user has selected, or when jumping to the\n"
00075 " 'o' or 'a' extension.\n\n"
00076 " Options:\n"
00077 " e - In addition to the name, also read the extension number to the\n"
00078 " caller before presenting dialing options.\n"
00079 " f - Allow the caller to enter the first name of a user in the directory\n"
00080 " instead of using the last name.\n";
00081
00082
00083
00084
00085 #define VOICEMAIL_CONFIG "voicemail.conf"
00086
00087
00088 #define NUMDIGITS 3
00089
00090
00091 #ifdef ODBC_STORAGE
00092 struct generic_prepare_struct {
00093 const char *sql;
00094 const char *param;
00095 };
00096
00097 static SQLHSTMT generic_prepare(struct odbc_obj *obj, void *data)
00098 {
00099 struct generic_prepare_struct *gps = data;
00100 SQLHSTMT stmt;
00101 int res;
00102
00103 res = SQLAllocHandle(SQL_HANDLE_STMT, obj->con, &stmt);
00104 if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
00105 ast_log(LOG_WARNING, "SQL Alloc Handle failed!\n");
00106 return NULL;
00107 }
00108
00109 res = SQLPrepare(stmt, (unsigned char *)gps->sql, SQL_NTS);
00110 if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
00111 ast_log(LOG_WARNING, "SQL Prepare failed![%s]\n", (char *)gps->sql);
00112 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00113 return NULL;
00114 }
00115
00116 if (!ast_strlen_zero(gps->param))
00117 SQLBindParameter(stmt, 1, SQL_PARAM_INPUT, SQL_C_CHAR, SQL_CHAR, strlen(gps->param), 0, (void *)gps->param, 0, NULL);
00118
00119 return stmt;
00120 }
00121
00122 static void retrieve_file(char *dir)
00123 {
00124 int x = 0;
00125 int res;
00126 int fd=-1;
00127 size_t fdlen = 0;
00128 void *fdm = MAP_FAILED;
00129 SQLHSTMT stmt;
00130 char sql[256];
00131 char fmt[80]="", empty[10] = "";
00132 char *c;
00133 SQLLEN colsize;
00134 char full_fn[256];
00135 struct odbc_obj *obj;
00136 struct generic_prepare_struct gps = { .sql = sql, .param = dir };
00137
00138 obj = ast_odbc_request_obj(odbc_database, 1);
00139 if (obj) {
00140 do {
00141 ast_copy_string(fmt, vmfmts, sizeof(fmt));
00142 c = strchr(fmt, '|');
00143 if (c)
00144 *c = '\0';
00145 if (!strcasecmp(fmt, "wav49"))
00146 strcpy(fmt, "WAV");
00147 snprintf(full_fn, sizeof(full_fn), "%s.%s", dir, fmt);
00148 snprintf(sql, sizeof(sql), "SELECT recording FROM %s WHERE dir=? AND msgnum=-1", odbc_table);
00149 stmt = ast_odbc_prepare_and_execute(obj, generic_prepare, &gps);
00150
00151 if (!stmt) {
00152 ast_log(LOG_WARNING, "SQL Execute error!\n[%s]\n\n", sql);
00153 break;
00154 }
00155 res = SQLFetch(stmt);
00156 if (res == SQL_NO_DATA) {
00157 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00158 break;
00159 } else if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
00160 ast_log(LOG_WARNING, "SQL Fetch error!\n[%s]\n\n", sql);
00161 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00162 break;
00163 }
00164 fd = open(full_fn, O_RDWR | O_CREAT | O_TRUNC, 0770);
00165 if (fd < 0) {
00166 ast_log(LOG_WARNING, "Failed to write '%s': %s\n", full_fn, strerror(errno));
00167 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00168 break;
00169 }
00170
00171 res = SQLGetData(stmt, 1, SQL_BINARY, empty, 0, &colsize);
00172 fdlen = colsize;
00173 if (fd > -1) {
00174 char tmp[1]="";
00175 lseek(fd, fdlen - 1, SEEK_SET);
00176 if (write(fd, tmp, 1) != 1) {
00177 close(fd);
00178 fd = -1;
00179 break;
00180 }
00181 if (fd > -1)
00182 fdm = mmap(NULL, fdlen, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);
00183 }
00184 if (fdm != MAP_FAILED) {
00185 memset(fdm, 0, fdlen);
00186 res = SQLGetData(stmt, x + 1, SQL_BINARY, fdm, fdlen, &colsize);
00187 if ((res != SQL_SUCCESS) && (res != SQL_SUCCESS_WITH_INFO)) {
00188 ast_log(LOG_WARNING, "SQL Get Data error!\n[%s]\n\n", sql);
00189 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00190 break;
00191 }
00192 }
00193 SQLFreeHandle(SQL_HANDLE_STMT, stmt);
00194 } while (0);
00195 ast_odbc_release_obj(obj);
00196 } else
00197 ast_log(LOG_WARNING, "Failed to obtain database object for '%s'!\n", odbc_database);
00198 if (fdm != MAP_FAILED)
00199 munmap(fdm, fdlen);
00200 if (fd > -1)
00201 close(fd);
00202 return;
00203 }
00204 #endif
00205
00206 static char *convert(const char *lastname)
00207 {
00208 char *tmp;
00209 int lcount = 0;
00210 tmp = ast_malloc(NUMDIGITS + 1);
00211 if (tmp) {
00212 while((*lastname > 32) && lcount < NUMDIGITS) {
00213 switch(toupper(*lastname)) {
00214 case '1':
00215 tmp[lcount++] = '1';
00216 break;
00217 case '2':
00218 case 'A':
00219 case 'B':
00220 case 'C':
00221 tmp[lcount++] = '2';
00222 break;
00223 case '3':
00224 case 'D':
00225 case 'E':
00226 case 'F':
00227 tmp[lcount++] = '3';
00228 break;
00229 case '4':
00230 case 'G':
00231 case 'H':
00232 case 'I':
00233 tmp[lcount++] = '4';
00234 break;
00235 case '5':
00236 case 'J':
00237 case 'K':
00238 case 'L':
00239 tmp[lcount++] = '5';
00240 break;
00241 case '6':
00242 case 'M':
00243 case 'N':
00244 case 'O':
00245 tmp[lcount++] = '6';
00246 break;
00247 case '7':
00248 case 'P':
00249 case 'Q':
00250 case 'R':
00251 case 'S':
00252 tmp[lcount++] = '7';
00253 break;
00254 case '8':
00255 case 'T':
00256 case 'U':
00257 case 'V':
00258 tmp[lcount++] = '8';
00259 break;
00260 case '9':
00261 case 'W':
00262 case 'X':
00263 case 'Y':
00264 case 'Z':
00265 tmp[lcount++] = '9';
00266 break;
00267 }
00268 lastname++;
00269 }
00270 tmp[lcount] = '\0';
00271 }
00272 return tmp;
00273 }
00274
00275
00276
00277
00278
00279
00280 static int play_mailbox_owner(struct ast_channel *chan, char *context,
00281 char *dialcontext, char *ext, char *name, int readext,
00282 int fromappvm)
00283 {
00284 int res = 0;
00285 int loop;
00286 char fn[256];
00287
00288
00289 snprintf(fn, sizeof(fn), "%s/voicemail/%s/%s/greet",
00290 ast_config_AST_SPOOL_DIR, context, ext);
00291 #ifdef ODBC_STORAGE
00292 retrieve_file(fn);
00293 #endif
00294
00295 if (ast_fileexists(fn, NULL, chan->language) <= 0) {
00296
00297 snprintf(fn, sizeof(fn), "%s/vm/%s/greet",
00298 ast_config_AST_SPOOL_DIR, ext);
00299 }
00300 #ifdef ODBC_STORAGE
00301 retrieve_file(fn);
00302 #endif
00303
00304 if (ast_fileexists(fn, NULL, chan->language) > 0) {
00305 res = ast_stream_and_wait(chan, fn, chan->language, AST_DIGIT_ANY);
00306 ast_stopstream(chan);
00307
00308 if (readext) {
00309 ast_stream_and_wait(chan, "vm-extension", chan->language, AST_DIGIT_ANY);
00310 res = ast_say_character_str(chan, ext, AST_DIGIT_ANY, chan->language);
00311 }
00312 } else {
00313 res = ast_say_character_str(chan, S_OR(name, ext), AST_DIGIT_ANY, chan->language);
00314 if (!ast_strlen_zero(name) && readext) {
00315 ast_stream_and_wait(chan, "vm-extension", chan->language, AST_DIGIT_ANY);
00316 res = ast_say_character_str(chan, ext, AST_DIGIT_ANY, chan->language);
00317 }
00318 }
00319 #ifdef ODBC_STORAGE
00320 ast_filedelete(fn, NULL);
00321 #endif
00322
00323 for (loop = 3 ; loop > 0; loop--) {
00324 if (!res)
00325 res = ast_stream_and_wait(chan, "dir-instr", chan->language, AST_DIGIT_ANY);
00326 if (!res)
00327 res = ast_waitfordigit(chan, 3000);
00328 ast_stopstream(chan);
00329
00330 if (res < 0)
00331 break;
00332 if (res == '0') {
00333 if (!ast_goto_if_exists(chan, dialcontext, "o", 1) ||
00334 (!ast_strlen_zero(chan->macrocontext) &&
00335 !ast_goto_if_exists(chan, chan->macrocontext, "o", 1))) {
00336
00337 return '1';
00338 }
00339 }
00340 if (res == '1') {
00341 if (fromappvm) {
00342
00343 ast_copy_string(chan->exten, ext, sizeof(chan->exten));
00344 } else {
00345 if (ast_goto_if_exists(chan, dialcontext, ext, 1)) {
00346 ast_log(LOG_WARNING,
00347 "Can't find extension '%s' in context '%s'. "
00348 "Did you pass the wrong context to Directory?\n",
00349 ext, dialcontext);
00350 res = -1;
00351 }
00352 }
00353 break;
00354 }
00355 if (res == '*')
00356 break;
00357 if (res == '#')
00358 break;
00359
00360
00361 res = 0;
00362 }
00363
00364 return(res);
00365 }
00366
00367 static struct ast_config *realtime_directory(char *context)
00368 {
00369 struct ast_config *cfg;
00370 struct ast_config *rtdata;
00371 struct ast_category *cat;
00372 struct ast_variable *var;
00373 char *mailbox;
00374 const char *fullname;
00375 const char *hidefromdir;
00376 char tmp[100];
00377
00378
00379 cfg = ast_config_load(VOICEMAIL_CONFIG);
00380
00381 if (!cfg) {
00382
00383 ast_log(LOG_WARNING, "Loading config failed.\n");
00384 return NULL;
00385 }
00386
00387
00388
00389 rtdata = ast_load_realtime_multientry("voicemail", "mailbox LIKE", "%", "context", context, NULL);
00390
00391
00392 if (!rtdata)
00393 return cfg;
00394
00395
00396 cat = ast_category_get(cfg, context);
00397 if (!cat) {
00398 cat = ast_category_new(context);
00399 if (!cat) {
00400 ast_log(LOG_WARNING, "Out of memory\n");
00401 ast_config_destroy(cfg);
00402 if (rtdata) {
00403 ast_config_destroy(rtdata);
00404 }
00405 return NULL;
00406 }
00407 ast_category_append(cfg, cat);
00408 }
00409
00410 mailbox = NULL;
00411 while ( (mailbox = ast_category_browse(rtdata, mailbox)) ) {
00412 fullname = ast_variable_retrieve(rtdata, mailbox, "fullname");
00413 hidefromdir = ast_variable_retrieve(rtdata, mailbox, "hidefromdir");
00414 snprintf(tmp, sizeof(tmp), "no-password,%s,hidefromdir=%s",
00415 fullname ? fullname : "",
00416 hidefromdir ? hidefromdir : "no");
00417 var = ast_variable_new(mailbox, tmp);
00418 if (var)
00419 ast_variable_append(cat, var);
00420 else
00421 ast_log(LOG_WARNING, "Out of memory adding mailbox '%s'\n", mailbox);
00422 }
00423 ast_config_destroy(rtdata);
00424
00425 return cfg;
00426 }
00427
00428 static int do_directory(struct ast_channel *chan, struct ast_config *cfg, struct ast_config *ucfg, char *context, char *dialcontext, char digit, int last, int readext, int fromappvm)
00429 {
00430
00431 char ext[NUMDIGITS + 1], *cat;
00432 char name[80] = "";
00433 struct ast_variable *v;
00434 int res;
00435 int found=0;
00436 int lastuserchoice = 0;
00437 char *start, *conv, *stringp = NULL;
00438 const char *pos;
00439 int breakout = 0;
00440
00441 if (ast_strlen_zero(context)) {
00442 ast_log(LOG_WARNING,
00443 "Directory must be called with an argument "
00444 "(context in which to interpret extensions)\n");
00445 return -1;
00446 }
00447 if (digit == '0') {
00448 if (!ast_goto_if_exists(chan, dialcontext, "o", 1) ||
00449 (!ast_strlen_zero(chan->macrocontext) &&
00450 !ast_goto_if_exists(chan, chan->macrocontext, "o", 1))) {
00451 return 0;
00452 } else {
00453 ast_log(LOG_WARNING, "Can't find extension 'o' in current context. "
00454 "Not Exiting the Directory!\n");
00455 res = 0;
00456 }
00457 }
00458 if (digit == '*') {
00459 if (!ast_goto_if_exists(chan, dialcontext, "a", 1) ||
00460 (!ast_strlen_zero(chan->macrocontext) &&
00461 !ast_goto_if_exists(chan, chan->macrocontext, "a", 1))) {
00462 return 0;
00463 } else {
00464 ast_log(LOG_WARNING, "Can't find extension 'a' in current context. "
00465 "Not Exiting the Directory!\n");
00466 res = 0;
00467 }
00468 }
00469 memset(ext, 0, sizeof(ext));
00470 ext[0] = digit;
00471 res = 0;
00472 if (ast_readstring(chan, ext + 1, NUMDIGITS - 1, 3000, 3000, "#") < 0) res = -1;
00473 if (!res) {
00474
00475 v = ast_variable_browse(cfg, context);
00476 while(v && !res) {
00477
00478 while(v) {
00479
00480 start = strdup(v->value);
00481 if (start && !strcasestr(start, "hidefromdir=yes")) {
00482 stringp=start;
00483 strsep(&stringp, ",");
00484 pos = strsep(&stringp, ",");
00485 if (pos) {
00486 ast_copy_string(name, pos, sizeof(name));
00487
00488 if (last && strrchr(pos,' '))
00489 pos = strrchr(pos, ' ') + 1;
00490 conv = convert(pos);
00491 if (conv) {
00492 if (!strncmp(conv, ext, strlen(ext))) {
00493
00494 found++;
00495 free(conv);
00496 free(start);
00497 break;
00498 }
00499 free(conv);
00500 }
00501 }
00502 free(start);
00503 }
00504 v = v->next;
00505 }
00506
00507 if (v) {
00508
00509 res = play_mailbox_owner(chan, context, dialcontext, v->name, name, readext, fromappvm);
00510 switch (res) {
00511 case -1:
00512
00513
00514
00515 lastuserchoice = 0;
00516 break;
00517 case '1':
00518
00519
00520
00521
00522 lastuserchoice = res;
00523 break;
00524 case '*':
00525
00526 lastuserchoice = res;
00527 res = 0;
00528 break;
00529 case '#':
00530 lastuserchoice = res;
00531 return 0;
00532 default:
00533 break;
00534 }
00535 v = v->next;
00536 }
00537 }
00538
00539 if (!res && ucfg) {
00540
00541 for (cat = ast_category_browse(ucfg, NULL); cat && !res ; cat = ast_category_browse(ucfg, cat)) {
00542 if (!strcasecmp(cat, "general"))
00543 continue;
00544 if (!ast_true(ast_config_option(ucfg, cat, "hasdirectory")))
00545 continue;
00546
00547
00548 if ((pos = ast_variable_retrieve(ucfg, cat, "fullname"))) {
00549 ast_copy_string(name, pos, sizeof(name));
00550
00551 if (last && strrchr(pos,' '))
00552 pos = strrchr(pos, ' ') + 1;
00553 conv = convert(pos);
00554 if (conv) {
00555 if (!strcmp(conv, ext)) {
00556
00557 found++;
00558
00559 res = play_mailbox_owner(chan, context, dialcontext, cat, name, readext, fromappvm);
00560 switch (res) {
00561 case -1:
00562
00563
00564
00565 lastuserchoice = 0;
00566 breakout = 1;
00567 break;
00568 case '1':
00569
00570
00571
00572
00573 lastuserchoice = res;
00574 breakout = 1;
00575 break;
00576 case '*':
00577
00578 lastuserchoice = res;
00579 breakout = 0;
00580 res = 0;
00581 break;
00582 default:
00583 breakout = 1;
00584 break;
00585 }
00586 free(conv);
00587 if (breakout)
00588 break;
00589 }
00590 else
00591 free(conv);
00592 }
00593 }
00594 }
00595 }
00596
00597 if (lastuserchoice != '1') {
00598 res = ast_streamfile(chan, found ? "dir-nomore" : "dir-nomatch", chan->language);
00599 if (!res)
00600 res = 1;
00601 return res;
00602 }
00603 return 0;
00604 }
00605 return res;
00606 }
00607
00608 static int directory_exec(struct ast_channel *chan, void *data)
00609 {
00610 int res = 0;
00611 struct ast_module_user *u;
00612 struct ast_config *cfg, *ucfg;
00613 int last = 1;
00614 int readext = 0;
00615 int fromappvm = 0;
00616 const char *dirintro;
00617 char *parse;
00618 AST_DECLARE_APP_ARGS(args,
00619 AST_APP_ARG(vmcontext);
00620 AST_APP_ARG(dialcontext);
00621 AST_APP_ARG(options);
00622 );
00623
00624 if (ast_strlen_zero(data)) {
00625 ast_log(LOG_WARNING, "Directory requires an argument (context[,dialcontext])\n");
00626 return -1;
00627 }
00628
00629 u = ast_module_user_add(chan);
00630
00631 parse = ast_strdupa(data);
00632
00633 AST_STANDARD_APP_ARGS(args, parse);
00634
00635 if (args.options) {
00636 if (strchr(args.options, 'f'))
00637 last = 0;
00638 if (strchr(args.options, 'e'))
00639 readext = 1;
00640 if (strchr(args.options, 'v'))
00641 fromappvm = 1;
00642 }
00643
00644 if (ast_strlen_zero(args.dialcontext))
00645 args.dialcontext = args.vmcontext;
00646
00647 cfg = realtime_directory(args.vmcontext);
00648 if (!cfg) {
00649 ast_log(LOG_ERROR, "Unable to read the configuration data!\n");
00650 ast_module_user_remove(u);
00651 return -1;
00652 }
00653
00654 ucfg = ast_config_load("users.conf");
00655
00656 dirintro = ast_variable_retrieve(cfg, args.vmcontext, "directoryintro");
00657 if (ast_strlen_zero(dirintro))
00658 dirintro = ast_variable_retrieve(cfg, "general", "directoryintro");
00659 if (ast_strlen_zero(dirintro))
00660 dirintro = last ? "dir-intro" : "dir-intro-fn";
00661
00662
00663
00664 if (chan->_state != AST_STATE_UP)
00665 res = ast_answer(chan);
00666
00667 for (;;) {
00668 if (!res)
00669 res = ast_stream_and_wait(chan, dirintro, chan->language, AST_DIGIT_ANY);
00670 ast_stopstream(chan);
00671 if (!res)
00672 res = ast_waitfordigit(chan, 5000);
00673 if (res > 0) {
00674 res = do_directory(chan, cfg, ucfg, args.vmcontext, args.dialcontext, res, last, readext, fromappvm);
00675 if (res > 0) {
00676 res = ast_waitstream(chan, AST_DIGIT_ANY);
00677 ast_stopstream(chan);
00678 if (res >= 0)
00679 continue;
00680 }
00681 }
00682 break;
00683 }
00684 if (ucfg)
00685 ast_config_destroy(ucfg);
00686 ast_config_destroy(cfg);
00687 ast_module_user_remove(u);
00688 return res;
00689 }
00690
00691 static int unload_module(void)
00692 {
00693 int res;
00694 res = ast_unregister_application(app);
00695 return res;
00696 }
00697
00698 static int load_module(void)
00699 {
00700 #ifdef ODBC_STORAGE
00701 struct ast_config *cfg = ast_config_load(VOICEMAIL_CONFIG);
00702 const char *tmp;
00703
00704 if (cfg) {
00705 if ((tmp = ast_variable_retrieve(cfg, "general", "odbcstorage"))) {
00706 ast_copy_string(odbc_database, tmp, sizeof(odbc_database));
00707 }
00708 if ((tmp = ast_variable_retrieve(cfg, "general", "odbctable"))) {
00709 ast_copy_string(odbc_table, tmp, sizeof(odbc_table));
00710 }
00711 if ((tmp = ast_variable_retrieve(cfg, "general", "format"))) {
00712 ast_copy_string(vmfmts, tmp, sizeof(vmfmts));
00713 }
00714 ast_config_destroy(cfg);
00715 } else
00716 ast_log(LOG_WARNING, "Unable to load " VOICEMAIL_CONFIG " - ODBC defaults will be used\n");
00717 #endif
00718
00719 return ast_register_application(app, directory_exec, synopsis, descrip);
00720 }
00721
00722 AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Extension Directory");