pbx/pbx_realtime.c

   1 /*
   2  * Realtime PBX Module
   3  *
   4  * Copyright (C) 2004, Digium Inc.
   5  *
   6  * Written by Mark Spencer <markster@digium.com>
   7  *
   8  * This program is Free Software distributed under the terms of
   9  * of the GNU General Public License.
  10  */
  11
  12 #include <asterisk/file.h>
  13 #include <asterisk/logger.h>
  14 #include <asterisk/channel.h>
  15 #include <asterisk/config.h>
  16 #include <asterisk/options.h>
  17 #include <asterisk/pbx.h>
  18 #include <asterisk/module.h>
  19 #include <asterisk/frame.h>
  20 #include <asterisk/file.h>
  21 #include <asterisk/cli.h>
  22 #include <asterisk/lock.h>
  23 #include <asterisk/md5.h>
  24 #include <asterisk/linkedlists.h>
  25 #include <asterisk/chanvars.h>
  26 #include <asterisk/sched.h>
  27 #include <asterisk/io.h>
  28 #include <asterisk/utils.h>
  29 #include <asterisk/crypto.h>
  30 #include <asterisk/astdb.h>
  31
  32 #include <stdlib.h>
  33 #include <unistd.h>
  34 #include <string.h>
  35 #include <errno.h>
  36
  37 static char *tdesc = "Realtime Switch";
  38
  39 /* Realtime switch looks up extensions in the supplied realtime table.
  40
  41         [context@][realtimetable][/options]
  42
  43         If the realtimetable is omitted it is assumed to be "extensions".  If no context is
  44         specified the context is assumed to be whatever is the container.
  45
  46         The realtime table should have entries for context,exten,priority,app,args
  47
  48         The realtime table currently does not support patterns or callerid fields.
  49
  50 */
  51
  52
  53 #define REALTIME_COMMON(mode) \
  54         char *buf; \
  55         char *opts; \
  56         const char *cxt; \
  57         char *table; \
  58         int res=-1; \
  59         struct ast_variable *var=NULL; \
  60         buf = ast_strdupa(data); \
  61         if (buf) { \
  62                 opts = strchr(buf, '/'); \
  63                 if (opts) { \
  64                         *opts='\0'; \
  65                         opts++; \
  66                 } else \
  67                         opts=""; \
  68                 table = strchr(buf, '@'); \
  69                 if (table) { \
  70                         *table = '\0'; \
  71                         table++;\
  72                         cxt = buf; \
  73                 } else cxt = NULL; \
  74                 if (!cxt || ast_strlen_zero(cxt)) \
  75                         cxt = context;\
  76                 if (!table || ast_strlen_zero(table)) \
  77                         table = "extensions"; \
  78                 var = realtime_switch_common(table, cxt, exten, priority, mode); \
  79         } else \
  80                 res = -1;
  81
  82 static struct ast_variable *realtime_switch_common(const char *table, const char *context, const char *exten, int priority)
  83 {
  84         struct ast_variable *var;
  85         char pri[20];
  86         snprintf(pri, sizeof(pri), "%d", priority);
  87         printf("%s/%s/%s/%s exists\n", table, context, exten, pri);
  88         var = ast_load_realtime(table, "context", context, "exten", exten, "priority", pri, NULL);
  89         return var;
  90 }
  91
  92 static int realtime_exists(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
  93 {
  94         REALTIME_COMMON;
  95         if (var) ast_destroy_realtime(var);
  96         if (var)
  97                 res = 1;
  98         return res > 0 ? res : 0;
  99 }
 100
 101 static int realtime_canmatch(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 102 {
 103         REALTIME_COMMON;
 104         if (var) ast_destroy_realtime(var);
 105         if (var)
 106                 res = 1;
 107         return res > 0 ? res : 0;
 108 }
 109
 110 static int realtime_exec(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, int newstack, const char *data)
 111 {
 112         char app[256];
 113         char *appdata="";
 114         struct ast_app *a;
 115         struct ast_variable *v;
 116         REALTIME_COMMON;
 117         if (var) {
 118                 v = var;
 119                 while(v) {
 120                         if (!strcasecmp(v->name, "app"))
 121                                 strncpy(app, v->value, sizeof(app) -1 );
 122                         else if (!strcasecmp(v->name, "appdata"))
 123                                 appdata = ast_strdupa(v->value);
 124                         v = v->next;
 125                 }
 126                 ast_destroy_realtime(var);
 127                 if (!ast_strlen_zero(app)) {
 128                         a = pbx_findapp(app);
 129                         if (a) {
 130                                 res = pbx_exec(chan, a, appdata, newstack);
 131                         } else
 132                                 ast_log(LOG_NOTICE, "No such application '%s' for extension '%s' in context '%s'\n", app, exten, context);
 133                 }
 134         }
 135         return res;
 136 }
 137
 138 static int realtime_matchmore(struct ast_channel *chan, const char *context, const char *exten, int priority, const char *callerid, const char *data)
 139 {
 140         REALTIME_COMMON;
 141         if (var) ast_destroy_realtime(var);
 142         return res > 0 ? res : 0;
 143 }
 144
 145 static struct ast_switch realtime_switch =
 146 {
 147         name:                   "Realtime",
 148         description:                    "Realtime Dialplan Switch",
 149         exists:                 realtime_exists,
 150         canmatch:               realtime_canmatch,
 151         exec:                   realtime_exec,
 152         matchmore:              realtime_matchmore,
 153 };
 154
 155 char *description(void)
 156 {
 157         return tdesc;
 158 }
 159
 160 int usecount(void)
 161 {
 162         return 1;
 163 }
 164
 165 char *key()
 166 {
 167         return ASTERISK_GPL_KEY;
 168 }
 169
 170 int unload_module(void)
 171 {
 172         ast_unregister_switch(&realtime_switch);
 173         return 0;
 174 }
 175
 176 int load_module(void)
 177 {
 178         ast_register_switch(&realtime_switch);
 179         return 0;
 180 }
 181