pbx/pbx_realtime.c

   1 /*
   2  * Asterisk -- An open source telephony toolkit.
   3  *
   4  * Copyright (C) 1999 - 2005, Digium, Inc.
   5  *
   6  * Mark Spencer <markster@digium.com>
   7  *
   8  * See http://www.asterisk.org for more information about
   9  * the Asterisk project. Please do not directly contact
  10  * any of the maintainers of this project for assistance;
  11  * the project provides a web site, mailing lists and IRC
  12  * channels for your use.
  13  *
  14  * This program is free software, distributed under the terms of
  15  * the GNU General Public License Version 2. See the LICENSE file
  16  * at the top of the source tree.
  17  */
  18
  19 /*! \file
  20  *
  21  * \brief Realtime PBX Module
  22  *
  23  * \arg See also: \ref AstARA
  24  */
  25
  26 #include <stdlib.h>
  27 #include <stdio.h>
  28 #include <unistd.h>
  29 #include <string.h>
  30 #include <errno.h>
  31
  32 #include "asterisk.h"
  33
  34 ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
  35
  36 #include "asterisk/file.h"
  37 #include "asterisk/logger.h"
  38 #include "asterisk/channel.h"
  39 #include "asterisk/config.h"
  40 #include "asterisk/options.h"
  41 #include "asterisk/pbx.h"
  42 #include "asterisk/module.h"
  43 #include "asterisk/frame.h"
  44 #include "asterisk/term.h"
  45 #include "asterisk/manager.h"
  46 #include "asterisk/file.h"
  47 #include "asterisk/cli.h"
  48 #include "asterisk/lock.h"
  49 #include "asterisk/md5.h"
  50 #include "asterisk/linkedlists.h"
  51 #include "asterisk/chanvars.h"
  52 #include "asterisk/sched.h"
  53 #include "asterisk/io.h"
  54 #include "asterisk/utils.h"
  55 #include "asterisk/crypto.h"
  56 #include "asterisk/astdb.h"
  57
  58 #define MODE_MATCH              0
  59 #define MODE_MATCHMORE  1
  60 #define MODE_CANMATCH   2
  61
  62 #define EXT_DATA_SIZE 256
  63
  64
  65 /* Realtime switch looks up extensions in the supplied realtime table.
  66
  67         [context@][realtimetable][/options]
  68
  69         If the realtimetable is omitted it is assumed to be "extensions".  If no context is
  70         specified the context is assumed to be whatever is the container.
  71
  72         The realtime table should have entries for context,exten,priority,app,args
  73
  74         The realtime table currently does not support callerid fields.
  75
  76 */
  77
  78
  79 #define REALTIME_COMMON(mode) \
  80         char *buf; \
  81         char *opts; \
  82         const char *cxt; \
  83         char *table; \
  84         int res=-1; \
  85         struct ast_variable *var=NULL; \
  86         buf = ast_strdupa(data); \
  87         if (buf) { \
  88                 opts = strchr(buf, '/'); \
  89                 if (opts) { \
  90                         *opts='\0'; \
  91                         opts++; \
  92                 } else \
  93                         opts=""; \
  94                 table = strchr(buf, '@'); \
  95                 if (table) { \
  96                         *table = '\0'; \
  97                         table++;\
  98                         cxt = buf; \
  99                 } else cxt = NULL; \
 100                 if (ast_strlen_zero(cxt)) \
 101                         cxt = context;\
 102                 if (ast_strlen_zero(table)) \
 103                         table = "extensions"; \
 104                 var = realtime_switch_common(table, cxt, exten, priority, mode); \
 105         } else \
 106                 res = -1;
 107
 108 static struct ast_variable *realtime_switch_common(const char *table, const char *context, const char *exten, int priority, int mode)
 109 {
 110         struct ast_variable *var;
 111         struct ast_config *cfg;
 112         char pri[20];
 113         char *ematch;
 114         char rexten[AST_MAX_EXTENSION + 20]="";
 115         int match;
 116         snprintf(pri, sizeof(pri), "%d", priority);
 117         switch(mode) {
 118         case MODE_MATCHMORE:
 119                 ematch = "exten LIKE";
 120                 snprintf(rexten, sizeof(rexten), "%s_%%", exten);
 121                 break;
 122         case MODE_CANMATCH:
 123                 ematch = "exten LIKE";
 124                 snprintf(rexten, sizeof(rexten), "%s%%", exten);
 125                 break;
 126         case MODE_MATCH:
 127         default:
 128                 ematch = "exten";
 129                 strncpy(rexten, exten, sizeof(rexten) - 1);
 130         }
 131         var = ast_load_realtime(table, ematch, rexten, "context", context, "priority", pri, NULL);
 132         if (!var) {
 133                 cfg = ast_load_realtime_multientry(table, "exten LIKE", "\\_%", "context", context, "priority", pri, NULL);
 134                 if (cfg) {
 135                         char *cat = ast_category_browse(cfg, NULL);
 136
 137                         while(cat) {
 138                                 switch(mode) {
 139                                 case MODE_MATCHMORE:
 140                                         match = ast_extension_close(cat, exten, 1);
 141                                         break;
 142                                 case MODE_CANMATCH:
 143                                         match = ast_extension_close(cat, exten, 0);
 144                                         break;
 145                                 case MODE_MATCH:
 146                                 default:
 147                                         match = ast_extension_match(cat, exten);
 148                                 }
 149                                 if (match) {
 150                                         var = ast_category_detach_variables(ast_category_get(cfg, cat));
 151                                         break;
 152                                 }
 153                                 cat = ast_category_browse(cfg, cat);
 154                         }
 155                         ast_config_destroy(cfg);
 156                 }
 157         }
 158         return var;
 159 }
 160
 161 static int realtime_exists(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 162 {
 163         REALTIME_COMMON(MODE_MATCH);
 164         if (var) ast_variables_destroy(var);
 165         if (var)
 166                 res = 1;
 167         return res > 0 ? res : 0;
 168 }
 169
 170 static int realtime_canmatch(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 171 {
 172         REALTIME_COMMON(MODE_CANMATCH);
 173         if (var) ast_variables_destroy(var);
 174         if (var)
 175                 res = 1;
 176         return res > 0 ? res : 0;
 177 }
 178
 179 static int realtime_exec(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 180 {
 181         char app[256];
 182         char appdata[512]="";
 183         char *tmp="";
 184         char tmp1[80];
 185         char tmp2[80];
 186         char tmp3[EXT_DATA_SIZE];
 187         struct ast_app *a;
 188         struct ast_variable *v;
 189         REALTIME_COMMON(MODE_MATCH);
 190         if (var) {
 191                 v = var;
 192                 while(v) {
 193                         if (!strcasecmp(v->name, "app"))
 194                                 strncpy(app, v->value, sizeof(app) -1 );
 195                         else if (!strcasecmp(v->name, "appdata"))
 196                                 tmp = ast_strdupa(v->value);
 197                         v = v->next;
 198                 }
 199                 ast_variables_destroy(var);
 200                 if (!ast_strlen_zero(app)) {
 201                         a = pbx_findapp(app);
 202                         if (a) {
 203                                 if(!ast_strlen_zero(tmp))
 204                                    pbx_substitute_variables_helper(chan, tmp, appdata, sizeof(appdata) - 1);
 205                 if (option_verbose > 2)
 206                                         ast_verbose( VERBOSE_PREFIX_3 "Executing %s(\"%s\", \"%s\")\n",
 207                                                                  term_color(tmp1, app, COLOR_BRCYAN, 0, sizeof(tmp1)),
 208                                                                  term_color(tmp2, chan->name, COLOR_BRMAGENTA, 0, sizeof(tmp2)),
 209                                                                  term_color(tmp3, (!ast_strlen_zero(appdata) ? (char *)appdata : ""), COLOR_BRMAGENTA, 0, sizeof(tmp3)));
 210                 manager_event(EVENT_FLAG_CALL, "Newexten",
 211                                                           "Channel: %s\r\n"
 212                                                           "Context: %s\r\n"
 213                                                           "Extension: %s\r\n"
 214                                                           "Priority: %d\r\n"
 215                                                           "Application: %s\r\n"
 216                                                           "AppData: %s\r\n"
 217                                                           "Uniqueid: %s\r\n",
 218                                                           chan->name, chan->context, chan->exten, chan->priority, app, appdata ? appdata : "(NULL)", chan->uniqueid);
 219
 220                                 res = pbx_exec(chan, a, appdata);
 221                         } else
 222                                 ast_log(LOG_NOTICE, "No such application '%s' for extension '%s' in context '%s'\n", app, exten, context);
 223                 }
 224         }
 225         return res;
 226 }
 227
 228 static int realtime_matchmore(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 229 {
 230         REALTIME_COMMON(MODE_MATCHMORE);
 231         if (var)
 232                 ast_variables_destroy(var);
 233         if (var)
 234                 res = 1;
 235         return res > 0 ? res : 0;
 236 }
 237
 238 static struct ast_switch realtime_switch =
 239 {
 240         name:                   "Realtime",
 241         description:                    "Realtime Dialplan Switch",
 242         exists:                 realtime_exists,
 243         canmatch:               realtime_canmatch,
 244         exec:                   realtime_exec,
 245         matchmore:              realtime_matchmore,
 246 };
 247
 248 static const char *description(void)
 249 {
 250         return "Realtime Switch";
 251 }
 252
 253 static const char *key(void)
 254 {
 255         return ASTERISK_GPL_KEY;
 256 }
 257
 258 static int unload_module(void *mod)
 259 {
 260         ast_unregister_switch(&realtime_switch);
 261         return 0;
 262 }
 263
 264 static int load_module(void *mod)
 265 {
 266         ast_register_switch(&realtime_switch);
 267         return 0;
 268 }
 269
 270 STD_MOD(MOD_1 | NO_USECOUNT | NO_UNLOAD, NULL, NULL, NULL);