apps/app_osplookup.c

   1 /*
   2  * Asterisk -- A telephony toolkit for Linux.
   3  *
   4  * Time of day - Report the time of day
   5  *
   6  * Copyright (C) 1999, Mark Spencer
   7  *
   8  * Mark Spencer <markster@linux-support.net>
   9  *
  10  * This program is free software, distributed under the terms of
  11  * the GNU General Public License
  12  */
  13
  14 #include <asterisk/lock.h>
  15 #include <asterisk/file.h>
  16 #include <asterisk/logger.h>
  17 #include <asterisk/channel.h>
  18 #include <asterisk/pbx.h>
  19 #include <asterisk/options.h>
  20 #include <asterisk/config.h>
  21 #include <asterisk/module.h>
  22 #include <asterisk/utils.h>
  23 #include <asterisk/causes.h>
  24 #include <asterisk/astosp.h>
  25 #include <stdlib.h>
  26 #include <unistd.h>
  27 #include <string.h>
  28 #include <stdlib.h>
  29 #include <ctype.h>
  30
  31 static char *tdesc = "OSP Lookup";
  32
  33 static char *app = "OSPLookup";
  34 static char *app2 = "OSPNext";
  35 static char *app3 = "OSPFinish";
  36
  37 static char *synopsis = "Lookup number in OSP";
  38 static char *synopsis2 = "Lookup next OSP entry";
  39 static char *synopsis3 = "Record OSP entry";
  40
  41 static char *descrip =
  42 "  OSPLookup(exten[|provider[|options]]):  Looks up an extension via OSP and sets\n"
  43 "the variables, where 'n' is the number of the result beginning with 1:\n"
  44 " ${OSPTECH}:   The technology to use for the call\n"
  45 " ${OSPDEST}:   The destination to use for the call\n"
  46 " ${OSPTOKEN}:  The actual OSP token as a string\n"
  47 " ${OSPHANDLE}: The OSP Handle for anything remaining\n"
  48 " ${OSPRESULTS}: The number of OSP results total remaining\n"
  49 "\n"
  50 "If the lookup was *not* successful and there exists a priority n + 101,\n"
  51 "then that priority will be taken next.\n" ;
  52
  53 static char *descrip2 =
  54 "  OSPNext:  Looks up the next OSP Destination for ${OSPHANDLE}\n"
  55 "See OSPLookup for more information\n"
  56 "\n"
  57 "If the lookup was *not* successful and there exists a priority n + 101,\n"
  58 "then that priority will be taken next.\n" ;
  59
  60 static char *descrip3 =
  61 "  OSPFinish(status):  Records call state for ${OSPHANDLE}, according to\n"
  62 "status, which should be one of BUSY, CONGESTION, ANSWER, NOANSWER, or NOCHANAVAIL\n"
  63 "or coincidentally, just what the Dial application stores in its ${DIALSTATUS}\n"
  64 "\n"
  65 "If the finishing was *not* successful and there exists a priority n + 101,\n"
  66 "then that priority will be taken next.\n" ;
  67
  68 STANDARD_LOCAL_USER;
  69
  70 LOCAL_USER_DECL;
  71
  72 static int str2cause(char *cause)
  73 {
  74         if (!strcasecmp(cause, "BUSY"))
  75                 return AST_CAUSE_BUSY;
  76         if (!strcasecmp(cause, "CONGESTION"))
  77                 return AST_CAUSE_CONGESTION;
  78         if (!strcasecmp(cause, "ANSWER"))
  79                 return AST_CAUSE_NORMAL;
  80         if (!strcasecmp(cause, "CANCEL"))
  81                 return AST_CAUSE_NORMAL;
  82         if (!strcasecmp(cause, "NOANSWER"))
  83                 return AST_CAUSE_NOANSWER;
  84         if (!strcasecmp(cause, "NOCHANAVAIL"))
  85                 return AST_CAUSE_CONGESTION;
  86         ast_log(LOG_WARNING, "Unknown cause '%s', using NORMAL\n", cause);
  87         return AST_CAUSE_NORMAL;
  88 }
  89
  90 static int osplookup_exec(struct ast_channel *chan, void *data)
  91 {
  92         int res=0;
  93         struct localuser *u;
  94         char *temp;
  95         char *provider, *opts=NULL;
  96         struct ast_osp_result result;
  97         if (!data || ast_strlen_zero(data) || !(temp = ast_strdupa(data))) {
  98                 ast_log(LOG_WARNING, "OSPLookup requires an argument (extension)\n");
  99                 return -1;
 100         }
 101         provider = strchr(temp, '|');
 102         if (provider) {
 103                 *provider = '\0';
 104                 provider++;
 105                 opts = strchr(provider, '|');
 106                 if (opts) {
 107                         *opts = '\0';
 108                         opts++;
 109                 }
 110         }
 111         LOCAL_USER_ADD(u);
 112         ast_log(LOG_DEBUG, "Whoo hoo, looking up OSP on '%s' via '%s'\n", temp, provider ? provider : "<default>");
 113         if ((res = ast_osp_lookup(chan, provider, temp, chan->callerid, &result)) > 0) {
 114                 char tmp[80];
 115                 snprintf(tmp, sizeof(tmp), "%d", result.handle);
 116                 pbx_builtin_setvar_helper(chan, "OSPHANDLE", tmp);
 117                 pbx_builtin_setvar_helper(chan, "OSPTECH", result.tech);
 118                 pbx_builtin_setvar_helper(chan, "OSPDEST", result.dest);
 119                 pbx_builtin_setvar_helper(chan, "OSPTOKEN", result.token);
 120                 snprintf(tmp, sizeof(tmp), "%d", result.numresults);
 121                 pbx_builtin_setvar_helper(chan, "OSPRESULTS", tmp);
 122         } else {
 123                 if (!res)
 124                         ast_log(LOG_NOTICE, "OSP Lookup failed for '%s' (provider '%s')\n", temp, provider ? provider : "<default>");
 125                 else
 126                         ast_log(LOG_DEBUG, "Got hangup on '%s' while doing OSP Lookup for '%s' (provider '%s')!\n", chan->name, temp, provider ? provider : "<default>" );
 127         }
 128         if (!res) {
 129                 /* Look for a "busy" place */
 130                 if (ast_exists_extension(chan, chan->context, chan->exten, chan->priority + 101, chan->callerid))
 131                         chan->priority += 100;
 132         } else if (res > 0)
 133                 res = 0;
 134         LOCAL_USER_REMOVE(u);
 135         return res;
 136 }
 137
 138 static int ospnext_exec(struct ast_channel *chan, void *data)
 139 {
 140         int res=0;
 141         struct localuser *u;
 142         char *temp;
 143         int cause;
 144         struct ast_osp_result result;
 145         if (!data || ast_strlen_zero(data)) {
 146                 ast_log(LOG_WARNING, "OSPNext should have an argument (cause)\n");
 147         }
 148         LOCAL_USER_ADD(u);
 149         cause = str2cause((char *)data);
 150         temp = pbx_builtin_getvar_helper(chan, "OSPHANDLE");
 151         result.handle = -1;
 152         if (temp && strlen(temp) && (sscanf(temp, "%i", &result.handle) == 1) && (result.handle > -1)) {
 153                 if ((res = ast_osp_next(&result, cause)) > 0) {
 154                         char tmp[80];
 155                         snprintf(tmp, sizeof(tmp), "%d", result.handle);
 156                         pbx_builtin_setvar_helper(chan, "OSPHANDLE", tmp);
 157                         pbx_builtin_setvar_helper(chan, "OSPTECH", result.tech);
 158                         pbx_builtin_setvar_helper(chan, "OSPDEST", result.dest);
 159                         pbx_builtin_setvar_helper(chan, "OSPTOKEN", result.token);
 160                         snprintf(tmp, sizeof(tmp), "%d", result.numresults);
 161                         pbx_builtin_setvar_helper(chan, "OSPRESULTS", tmp);
 162                 }
 163         } else {
 164                 if (!res) {
 165                         if (result.handle < 0)
 166                                 ast_log(LOG_NOTICE, "OSP Lookup Next failed for handle '%d'\n", result.handle);
 167                         else
 168                                 ast_log(LOG_DEBUG, "No OSP handle specified\n");
 169                 } else
 170                         ast_log(LOG_DEBUG, "Got hangup on '%s' while doing OSP Next!\n", chan->name);
 171         }
 172         if (!res) {
 173                 /* Look for a "busy" place */
 174                 if (ast_exists_extension(chan, chan->context, chan->exten, chan->priority + 101, chan->callerid))
 175                         chan->priority += 100;
 176         } else if (res > 0)
 177                 res = 0;
 178         LOCAL_USER_REMOVE(u);
 179         return res;
 180 }
 181
 182 static int ospfinished_exec(struct ast_channel *chan, void *data)
 183 {
 184         int res=0;
 185         struct localuser *u;
 186         char *temp;
 187         int cause;
 188         time_t start=0, duration=0;
 189         struct ast_osp_result result;
 190         if (!data || ast_strlen_zero(data)) {
 191                 ast_log(LOG_WARNING, "OSPFinish should have an argument (cause)\n");
 192         }
 193         if (chan->cdr) {
 194                 start = chan->cdr->answer.tv_sec;
 195                 if (start)
 196                         duration = time(NULL) - start;
 197                 else
 198                         duration = 0;
 199         } else
 200                 ast_log(LOG_WARNING, "OSPFinish called on channel '%s' with no CDR!\n", chan->name);
 201         LOCAL_USER_ADD(u);
 202         cause = str2cause((char *)data);
 203         temp = pbx_builtin_getvar_helper(chan, "OSPHANDLE");
 204         result.handle = -1;
 205         if (temp && strlen(temp) && (sscanf(temp, "%i", &result.handle) == 1) && (result.handle > -1)) {
 206                 if (!ast_osp_terminate(result.handle, cause, start, duration)) {
 207                         pbx_builtin_setvar_helper(chan, "OSPHANDLE", "");
 208                         res = 1;
 209                 }
 210         } else {
 211                 if (!res) {
 212                         if (result.handle > -1)
 213                                 ast_log(LOG_NOTICE, "OSP Finish failed for handle '%d'\n", result.handle);
 214                         else
 215                                 ast_log(LOG_DEBUG, "No OSP handle specified\n");
 216                 } else
 217                         ast_log(LOG_DEBUG, "Got hangup on '%s' while doing OSP Terminate!\n", chan->name);
 218         }
 219         if (!res) {
 220                 /* Look for a "busy" place */
 221                 if (ast_exists_extension(chan, chan->context, chan->exten, chan->priority + 101, chan->callerid))
 222                         chan->priority += 100;
 223         } else if (res > 0)
 224                 res = 0;
 225         LOCAL_USER_REMOVE(u);
 226         return res;
 227 }
 228
 229
 230 int unload_module(void)
 231 {
 232         int res;
 233         STANDARD_HANGUP_LOCALUSERS;
 234         res = ast_unregister_application(app3);
 235         res |= ast_unregister_application(app2);
 236         res |= ast_unregister_application(app);
 237         return res;
 238 }
 239
 240 int load_module(void)
 241 {
 242         int res;
 243         res = ast_register_application(app, osplookup_exec, synopsis, descrip);
 244         if (res)
 245                 return(res);
 246         res = ast_register_application(app2, ospnext_exec, synopsis2, descrip2);
 247         if (res)
 248                 return(res);
 249         res = ast_register_application(app3, ospfinished_exec, synopsis3, descrip3);
 250         if (res)
 251                 return(res);
 252         return(0);
 253 }
 254
 255 int reload(void)
 256 {
 257         return 0;
 258 }
 259
 260
 261 char *description(void)
 262 {
 263         return tdesc;
 264 }
 265
 266 int usecount(void)
 267 {
 268         int res;
 269         STANDARD_USECOUNT(res);
 270         return res;
 271 }
 272
 273 char *key()
 274 {
 275         return ASTERISK_GPL_KEY;
 276 }
 277