Sat Aug 6 00:39:20 2011

Asterisk developer's documentation


app_directory.c

Go to the documentation of this file.
00001 /*
00002  * Asterisk -- An open source telephony toolkit.
00003  *
00004  * Copyright (C) 1999 - 2005, Digium, Inc.
00005  *
00006  * Mark Spencer <markster@digium.com>
00007  *
00008  * See http://www.asterisk.org for more information about
00009  * the Asterisk project. Please do not directly contact
00010  * any of the maintainers of this project for assistance;
00011  * the project provides a web site, mailing lists and IRC
00012  * channels for your use.
00013  *
00014  * This program is free software, distributed under the terms of
00015  * the GNU General Public License Version 2. See the LICENSE file
00016  * at the top of the source tree.
00017  */
00018 
00019 /*! \file
00020  *
00021  * \brief Provide a directory of extensions
00022  *
00023  * \author Mark Spencer <markster@digium.com>
00024  * 
00025  * \ingroup applications
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 /* For simplicity, I'm keeping the format compatible with the voicemail config,
00083    but i'm open to suggestions for isolating it */
00084 
00085 #define VOICEMAIL_CONFIG "voicemail.conf"
00086 
00087 /* How many digits to read in */
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 /* play name of mailbox owner.
00276  * returns:  -1 for bad or missing extension
00277  *           '1' for selected entry from directory
00278  *           '*' for skipped entry from directory
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    /* Check for the VoiceMail2 greeting first */
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       /* no file, check for an old-style Voicemail greeting */
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       /* If Option 'e' was specified, also read the extension number with the name */
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) /* User hungup, so jump out now */
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          /* return 1 to indicate goto has been performed */
00337          return '1';
00338          }
00339       }
00340       if (res == '1') { /* Name selected */
00341          if (fromappvm) {
00342             /* We still want to set the exten though */
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 == '*') /* Skip to next match in list */
00356          break;
00357       if (res == '#')
00358          break;
00359 
00360       /* Not '1', or '*', so decrement number of tries */
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    /* Load flat file config. */
00379    cfg = ast_config_load(VOICEMAIL_CONFIG);
00380 
00381    if (!cfg) {
00382       /* Loading config failed. */
00383       ast_log(LOG_WARNING, "Loading config failed.\n");
00384       return NULL;
00385    }
00386 
00387    /* Get realtime entries, categorized by their mailbox number
00388       and present in the requested context */
00389    rtdata = ast_load_realtime_multientry("voicemail", "mailbox LIKE", "%", "context", context, NULL);
00390 
00391    /* if there are no results, just return the entries from the config file */
00392    if (!rtdata)
00393       return cfg;
00394 
00395    /* Does the context exist within the config file? If not, make one */
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    /* Read in the first three digits..  "digit" is the first digit, already read */
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       /* Search for all names which start with those digits */
00475       v = ast_variable_browse(cfg, context);
00476       while(v && !res) {
00477          /* Find all candidate extensions */
00478          while(v) {
00479             /* Find a candidate extension */
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                   /* Grab the last name */
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                         /* Match! */
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             /* We have a match -- play a greeting if they have it */
00509             res = play_mailbox_owner(chan, context, dialcontext, v->name, name, readext, fromappvm);
00510             switch (res) {
00511                case -1:
00512                   /* user pressed '1' but extension does not exist, or
00513                    * user hungup
00514                    */
00515                   lastuserchoice = 0;
00516                   break;
00517                case '1':
00518                   /* user pressed '1' and extensions exists;
00519                      play_mailbox_owner will already have done
00520                      a goto() on the channel
00521                    */
00522                   lastuserchoice = res;
00523                   break;
00524                case '*':
00525                   /* user pressed '*' to skip something found */
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          /* Search users.conf for all names which start with those digits */
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             /* Find all candidate extensions */
00548             if ((pos = ast_variable_retrieve(ucfg, cat, "fullname"))) {
00549                ast_copy_string(name, pos, sizeof(name));
00550                /* Grab the last name */
00551                if (last && strrchr(pos,' '))
00552                   pos = strrchr(pos, ' ') + 1;
00553                conv = convert(pos);
00554                if (conv) {
00555                   if (!strcmp(conv, ext)) {
00556                      /* Match! */
00557                      found++;
00558                      /* We have a match -- play a greeting if they have it */
00559                      res = play_mailbox_owner(chan, context, dialcontext, cat, name, readext, fromappvm);
00560                      switch (res) {
00561                      case -1:
00562                         /* user pressed '1' but extension does not exist, or
00563                          * user hungup
00564                          */
00565                         lastuserchoice = 0;
00566                         breakout = 1;
00567                         break;
00568                      case '1':
00569                         /* user pressed '1' and extensions exists;
00570                            play_mailbox_owner will already have done
00571                            a goto() on the channel
00572                          */
00573                         lastuserchoice = res;
00574                         breakout = 1;
00575                         break;
00576                      case '*':
00577                         /* user pressed '*' to skip something found */
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    /* the above prompts probably should be modified to include 0 for dialing operator
00662       and # for exiting (continues in dialplan) */
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");

Generated on Sat Aug 6 00:39:20 2011 for Asterisk - the Open Source PBX by  doxygen 1.4.7