app_adsiprog.c File Reference

Program Asterisk ADSI Scripts into phone. More...

#include "asterisk.h"
#include <netinet/in.h>
#include <ctype.h>
#include "asterisk/paths.h"
#include "asterisk/file.h"
#include "asterisk/channel.h"
#include "asterisk/pbx.h"
#include "asterisk/module.h"
#include "asterisk/adsi.h"
#include "asterisk/utils.h"
#include "asterisk/lock.h"

Include dependency graph for app_adsiprog.c:

Go to the source code of this file.

Data Structures
struct	adsi_display
struct	adsi_event
struct	adsi_flag
struct	adsi_key_cmd
struct	adsi_script
struct	adsi_soft_key
struct	adsi_state
struct	adsi_subscript

Macros
#define	ARG_NUMBER   (1 << 1)
#define	ARG_STRING   (1 << 0)
#define	MAX_MAIN_LEN   1600
#define	MAX_RET_CODE   20
#define	MAX_SUB_LEN   255
#define	STATE_INIF   3
#define	STATE_INKEY   1
#define	STATE_INSUB   2
#define	STATE_NORMAL   0

Functions
static void	__reg_module (void)
static void	__unreg_module (void)
static int	adsi_exec (struct ast_channel *chan, const char *data)
static int	adsi_process (struct adsi_script *state, char *buf, const char *script, int lineno)
static int	adsi_prog (struct ast_channel *chan, const char *script)
struct ast_module *	AST_MODULE_SELF_SYM (void)
static int	clearcbone (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static int	cleardisplay (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static int	clearflag (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	cleartimer (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static struct adsi_script *	compile_script (const char *script)
static int	digitcollect (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static int	digitdirect (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static char *	get_token (char **buf, const char *script, int lineno)
static struct adsi_display *	getdisplaybyname (struct adsi_script *state, char *name, const char *script, int lineno, int create)
static int	geteventbyname (char *name)
static struct adsi_flag *	getflagbyname (struct adsi_script *state, char *name, const char *script, int lineno, int create)
static int	getjustifybyname (char *name)
static struct adsi_soft_key *	getkeybyname (struct adsi_script *state, char *name, const char *script, int lineno)
static struct adsi_state *	getstatebyname (struct adsi_script *state, char *name, const char *script, int lineno, int create)
static struct adsi_subscript *	getsubbyname (struct adsi_script *state, char *name, const char *script, int lineno)
static int	goto_line (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	goto_line_rel (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	load_module (void)
	Load the module. More...
static int	onevent (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	process_opcode (struct adsi_subscript *sub, char *code, char *args, struct adsi_script *state, const char *script, int lineno)
static int	process_returncode (struct adsi_soft_key *key, char *code, char *args, struct adsi_script *state, const char *script, int lineno)
static int	process_token (void *out, char *src, int maxlen, int argtype)
static int	send_delay (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	send_dtmf (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	set_state (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static int	setflag (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	showdisplay (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	showkeys (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	starttimer (char *buf, char *name, int id, char *args, struct adsi_script *istate, const char *script, int lineno)
static int	subscript (char *buf, char *name, int id, char *args, struct adsi_script *state, const char *script, int lineno)
static int	unload_module (void)

Variables
static struct ast_module_info	__mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Asterisk ADSI Programming Application" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_DEPRECATED, .load = load_module, .unload = unload_module, .requires = "res_adsi", }
static const char	app [] = "ADSIProg"
static const struct ast_module_info *	ast_module_info = &__mod_info
static const struct adsi_event	events []
static const struct adsi_event	justify []
static const struct adsi_key_cmd	kcmds []
static const struct adsi_key_cmd	opcmds []
static char *	validdtmf = "123456789*0#ABCD"

Detailed Description

Program Asterisk ADSI Scripts into phone.

Author

Mark Spencer marks.nosp@m.ter@.nosp@m.digiu.nosp@m.m.co.nosp@m.m

Definition in file app_adsiprog.c.

Macro Definition Documentation

ARG_NUMBER

#define ARG_NUMBER   (1 << 1)

Definition at line 132 of file app_adsiprog.c.

ARG_STRING

#define ARG_STRING   (1 << 0)

Definition at line 131 of file app_adsiprog.c.

MAX_MAIN_LEN

#define MAX_MAIN_LEN   1600

Definition at line 129 of file app_adsiprog.c.

MAX_RET_CODE

#define MAX_RET_CODE   20

Definition at line 127 of file app_adsiprog.c.

MAX_SUB_LEN

#define MAX_SUB_LEN   255

Definition at line 128 of file app_adsiprog.c.

STATE_INIF

#define STATE_INIF   3

Definition at line 125 of file app_adsiprog.c.

STATE_INKEY

#define STATE_INKEY   1

Definition at line 123 of file app_adsiprog.c.

STATE_INSUB

#define STATE_INSUB   2

Definition at line 124 of file app_adsiprog.c.

STATE_NORMAL

#define STATE_NORMAL   0

Definition at line 122 of file app_adsiprog.c.

Function Documentation

__reg_module()

static void __reg_module ( void  )

static

Definition at line 1620 of file app_adsiprog.c.

__unreg_module()

static void __unreg_module ( void  )

static

Definition at line 1620 of file app_adsiprog.c.

adsi_exec()

static int adsi_exec ( struct ast_channel *  chan, const char *  data  )

static

Definition at line 1576 of file app_adsiprog.c.

{
    int res = 0;
 
    if (ast_strlen_zero(data))
        data = "asterisk.adsi";
 
    if (!ast_adsi_available(chan)) {
        ast_verb(3, "ADSI Unavailable on CPE.  Not bothering to try.\n");
    } else {
        ast_verb(3, "ADSI Available on CPE.  Attempting Upload.\n");
        res = adsi_prog(chan, data);
    }
 
    return res;
}

References adsi_prog(), ast_adsi_available(), ast_strlen_zero(), and ast_verb.

Referenced by load_module().

adsi_process()

static int adsi_process ( struct adsi_script *  state, char *  buf, const char *  script, int  lineno  )

static

Definition at line 1024 of file app_adsiprog.c.

{
    char *keyword = get_token(&buf, script, lineno);
    char *args, vname[256], tmp[80], tmp2[80];
    int lrci, wi, event;
    struct adsi_display *disp;
    struct adsi_subscript *newsub;
 
    if (!keyword)
        return 0;
 
    switch(state->state) {
    case STATE_NORMAL:
        if (!strcasecmp(keyword, "DESCRIPTION")) {
            if ((args = get_token(&buf, script, lineno))) {
                if (process_token(state->desc, args, sizeof(state->desc) - 1, ARG_STRING))
                    ast_log(LOG_WARNING, "'%s' is not a valid token for DESCRIPTION at line %d of %s\n", args, lineno, script);
            } else
                ast_log(LOG_WARNING, "Missing argument for DESCRIPTION at line %d of %s\n", lineno, script);
        } else if (!strcasecmp(keyword, "VERSION")) {
            if ((args = get_token(&buf, script, lineno))) {
                if (process_token(&state->ver, args, sizeof(state->ver) - 1, ARG_NUMBER))
                    ast_log(LOG_WARNING, "'%s' is not a valid token for VERSION at line %d of %s\n", args, lineno, script);
            } else
                ast_log(LOG_WARNING, "Missing argument for VERSION at line %d of %s\n", lineno, script);
        } else if (!strcasecmp(keyword, "SECURITY")) {
            if ((args = get_token(&buf, script, lineno))) {
                if (process_token(state->sec, args, sizeof(state->sec) - 1, ARG_STRING | ARG_NUMBER))
                    ast_log(LOG_WARNING, "'%s' is not a valid token for SECURITY at line %d of %s\n", args, lineno, script);
            } else
                ast_log(LOG_WARNING, "Missing argument for SECURITY at line %d of %s\n", lineno, script);
        } else if (!strcasecmp(keyword, "FDN")) {
            if ((args = get_token(&buf, script, lineno))) {
                if (process_token(state->fdn, args, sizeof(state->fdn) - 1, ARG_STRING | ARG_NUMBER))
                    ast_log(LOG_WARNING, "'%s' is not a valid token for FDN at line %d of %s\n", args, lineno, script);
            } else
                ast_log(LOG_WARNING, "Missing argument for FDN at line %d of %s\n", lineno, script);
        } else if (!strcasecmp(keyword, "KEY")) {
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "KEY definition missing name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(vname, args, sizeof(vname) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a KEY name at line %d of %s\n", args, lineno, script);
                break;
            }
            if (!(state->key = getkeybyname(state, vname, script, lineno))) {
                ast_log(LOG_WARNING, "Out of key space at line %d of %s\n", lineno, script);
                break;
            }
            if (state->key->defined) {
                ast_log(LOG_WARNING, "Cannot redefine key '%s' at line %d of %s\n", vname, lineno, script);
                break;
            }
            if (!(args = get_token(&buf, script, lineno)) || strcasecmp(args, "IS")) {
                ast_log(LOG_WARNING, "Expecting 'IS', but got '%s' at line %d of %s\n", args ? args : "<nothing>", lineno, script);
                break;
            }
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "KEY definition missing short name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(tmp, args, sizeof(tmp) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a KEY short name at line %d of %s\n", args, lineno, script);
                break;
            }
            if ((args = get_token(&buf, script, lineno))) {
                if (strcasecmp(args, "OR")) {
                    ast_log(LOG_WARNING, "Expecting 'OR' but got '%s' instead at line %d of %s\n", args, lineno, script);
                    break;
                }
                if (!(args = get_token(&buf, script, lineno))) {
                    ast_log(LOG_WARNING, "KEY definition missing optional long name at line %d of %s\n", lineno, script);
                    break;
                }
                if (process_token(tmp2, args, sizeof(tmp2) - 1, ARG_STRING)) {
                    ast_log(LOG_WARNING, "'%s' is not a valid token for a KEY long name at line %d of %s\n", args, lineno, script);
                    break;
                }
            } else {
                ast_copy_string(tmp2, tmp, sizeof(tmp2));
            }
            if (strlen(tmp2) > 18) {
                ast_log(LOG_WARNING, "Truncating full name to 18 characters at line %d of %s\n", lineno, script);
                tmp2[18] = '\0';
            }
            if (strlen(tmp) > 7) {
                ast_log(LOG_WARNING, "Truncating short name to 7 bytes at line %d of %s\n", lineno, script);
                tmp[7] = '\0';
            }
            /* Setup initial stuff */
            state->key->retstr[0] = 0x80;
            /* 1 has the length */
            state->key->retstr[2] = state->key->id;
            /* Put the Full name in */
            memcpy(state->key->retstr + 3, tmp2, strlen(tmp2));
            /* Update length */
            state->key->retstrlen = strlen(tmp2) + 3;
            /* Put trailing 0xff */
            state->key->retstr[state->key->retstrlen++] = 0xff;
            /* Put the short name */
            memcpy(state->key->retstr + state->key->retstrlen, tmp, strlen(tmp));
            /* Update length */
            state->key->retstrlen += strlen(tmp);
            /* Put trailing 0xff */
            state->key->retstr[state->key->retstrlen++] = 0xff;
            /* Record initial length */
            state->key->initlen = state->key->retstrlen;
            state->state = STATE_INKEY;
        } else if (!strcasecmp(keyword, "SUB")) {
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "SUB definition missing name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(vname, args, sizeof(vname) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a KEY name at line %d of %s\n", args, lineno, script);
                break;
            }
            if (!(state->sub = getsubbyname(state, vname, script, lineno))) {
                ast_log(LOG_WARNING, "Out of subroutine space at line %d of %s\n", lineno, script);
                break;
            }
            if (state->sub->defined) {
                ast_log(LOG_WARNING, "Cannot redefine subroutine '%s' at line %d of %s\n", vname, lineno, script);
                break;
            }
            /* Setup sub */
            state->sub->data[0] = 0x82;
            /* 1 is the length */
            state->sub->data[2] = 0x0; /* Clear extensibility bit */
            state->sub->datalen = 3;
            if (state->sub->id) {
                /* If this isn't the main subroutine, make a subroutine label for it */
                state->sub->data[3] = 9;
                state->sub->data[4] = state->sub->id;
                /* 5 is length */
                state->sub->data[6] = 0xff;
                state->sub->datalen = 7;
            }
            if (!(args = get_token(&buf, script, lineno)) || strcasecmp(args, "IS")) {
                ast_log(LOG_WARNING, "Expecting 'IS', but got '%s' at line %d of %s\n", args ? args : "<nothing>", lineno, script);
                break;
            }
            state->state = STATE_INSUB;
        } else if (!strcasecmp(keyword, "STATE")) {
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "STATE definition missing name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(vname, args, sizeof(vname) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a STATE name at line %d of %s\n", args, lineno, script);
                break;
            }
            if (getstatebyname(state, vname, script, lineno, 0)) {
                ast_log(LOG_WARNING, "State '%s' is already defined at line %d of %s\n", vname, lineno, script);
                break;
            }
            getstatebyname(state, vname, script, lineno, 1);
        } else if (!strcasecmp(keyword, "FLAG")) {
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "FLAG definition missing name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(vname, args, sizeof(vname) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a FLAG name at line %d of %s\n", args, lineno, script);
                break;
            }
            if (getflagbyname(state, vname, script, lineno, 0)) {
                ast_log(LOG_WARNING, "Flag '%s' is already defined\n", vname);
                break;
            }
            getflagbyname(state, vname, script, lineno, 1);
        } else if (!strcasecmp(keyword, "DISPLAY")) {
            lrci = 0;
            wi = 0;
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "SUB definition missing name at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(vname, args, sizeof(vname) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "'%s' is not a valid token for a KEY name at line %d of %s\n", args, lineno, script);
                break;
            }
            if (getdisplaybyname(state, vname, script, lineno, 0)) {
                ast_log(LOG_WARNING, "State '%s' is already defined\n", vname);
                break;
            }
            if (!(disp = getdisplaybyname(state, vname, script, lineno, 1)))
                break;
            if (!(args = get_token(&buf, script, lineno)) || strcasecmp(args, "IS")) {
                ast_log(LOG_WARNING, "Missing 'IS' at line %d of %s\n", lineno, script);
                break;
            }
            if (!(args = get_token(&buf, script, lineno))) {
                ast_log(LOG_WARNING, "Missing Column 1 text at line %d of %s\n", lineno, script);
                break;
            }
            if (process_token(tmp, args, sizeof(tmp) - 1, ARG_STRING)) {
                ast_log(LOG_WARNING, "Token '%s' is not valid column 1 text at line %d of %s\n", args, lineno, script);
                break;
            }
            if (strlen(tmp) > 20) {
                ast_log(LOG_WARNING, "Truncating column one to 20 characters at line %d of %s\n", lineno, script);
                tmp[20] = '\0';
            }
            memcpy(disp->data + 5, tmp, strlen(tmp));
            disp->datalen = strlen(tmp) + 5;
            disp->data[disp->datalen++] = 0xff;
 
            args = get_token(&buf, script, lineno);
            if (args && !process_token(tmp, args, sizeof(tmp) - 1, ARG_STRING)) {
                /* Got a column two */
                if (strlen(tmp) > 20) {
                    ast_log(LOG_WARNING, "Truncating column two to 20 characters at line %d of %s\n", lineno, script);
                    tmp[20] = '\0';
                }
                memcpy(disp->data + disp->datalen, tmp, strlen(tmp));
                disp->datalen += strlen(tmp);
                args = get_token(&buf, script, lineno);
            }
            while (args) {
                if (!strcasecmp(args, "JUSTIFY")) {
                    args = get_token(&buf, script, lineno);
                    if (!args) {
                        ast_log(LOG_WARNING, "Qualifier 'JUSTIFY' requires an argument at line %d of %s\n", lineno, script);
                        break;
                    }
                    lrci = getjustifybyname(args);
                    if (lrci < 0) {
                        ast_log(LOG_WARNING, "'%s' is not a valid justification at line %d of %s\n", args, lineno, script);
                        break;
                    }
                } else if (!strcasecmp(args, "WRAP")) {
                    wi = 0x80;
                } else {
                    ast_log(LOG_WARNING, "'%s' is not a known qualifier at line %d of %s\n", args, lineno, script);
                    break;
                }
                args = get_token(&buf, script, lineno);
            }
            if (args) {
                /* Something bad happened */
                break;
            }
            disp->data[0] = 0x81;
            disp->data[1] = disp->datalen - 2;
            disp->data[2] = ((lrci & 0x3) << 6) | disp->id;
            disp->data[3] = wi;
            disp->data[4] = 0xff;
        } else {
            ast_log(LOG_WARNING, "Invalid or Unknown keyword '%s' in PROGRAM\n", keyword);
        }
        break;
    case STATE_INKEY:
        if (process_returncode(state->key, keyword, buf, state, script, lineno)) {
            if (!strcasecmp(keyword, "ENDKEY")) {
                /* Return to normal operation and increment current key */
                state->state = STATE_NORMAL;
                state->key->defined = 1;
                state->key->retstr[1] = state->key->retstrlen - 2;
                state->key = NULL;
            } else {
                ast_log(LOG_WARNING, "Invalid or Unknown keyword '%s' in SOFTKEY definition at line %d of %s\n", keyword, lineno, script);
            }
        }
        break;
    case STATE_INIF:
        if (process_opcode(state->sub, keyword, buf, state, script, lineno)) {
            if (!strcasecmp(keyword, "ENDIF")) {
                /* Return to normal SUB operation and increment current key */
                state->state = STATE_INSUB;
                state->sub->defined = 1;
                /* Store the proper number of instructions */
                state->sub->ifdata[2] = state->sub->ifinscount;
            } else if (!strcasecmp(keyword, "GOTO")) {
                if (!(args = get_token(&buf, script, lineno))) {
                    ast_log(LOG_WARNING, "GOTO clause missing Subscript name at line %d of %s\n", lineno, script);
                    break;
                }
                if (process_token(tmp, args, sizeof(tmp) - 1, ARG_STRING)) {
                    ast_log(LOG_WARNING, "'%s' is not a valid subscript name token at line %d of %s\n", args, lineno, script);
                    break;
                }
                if (!(newsub = getsubbyname(state, tmp, script, lineno)))
                    break;
                /* Somehow you use GOTO to go to another place */
                state->sub->data[state->sub->datalen++] = 0x8;
                state->sub->data[state->sub->datalen++] = state->sub->ifdata[1];
                state->sub->data[state->sub->datalen++] = newsub->id;
                /* Terminate */
                state->sub->data[state->sub->datalen++] = 0xff;
                /* Increment counters */
                state->sub->inscount++;
                state->sub->ifinscount++;
            } else {
                ast_log(LOG_WARNING, "Invalid or Unknown keyword '%s' in IF clause at line %d of %s\n", keyword, lineno, script);
            }
        } else
            state->sub->ifinscount++;
        break;
    case STATE_INSUB:
        if (process_opcode(state->sub, keyword, buf, state, script, lineno)) {
            if (!strcasecmp(keyword, "ENDSUB")) {
                /* Return to normal operation and increment current key */
                state->state = STATE_NORMAL;
                state->sub->defined = 1;
                /* Store the proper length */
                state->sub->data[1] = state->sub->datalen - 2;
                if (state->sub->id) {
                    /* if this isn't main, store number of instructions, too */
                    state->sub->data[5] = state->sub->inscount;
                }
                state->sub = NULL;
            } else if (!strcasecmp(keyword, "IFEVENT")) {
                if (!(args = get_token(&buf, script, lineno))) {
                    ast_log(LOG_WARNING, "IFEVENT clause missing Event name at line %d of %s\n", lineno, script);
                    break;
                }
                if ((event = geteventbyname(args)) < 1) {
                    ast_log(LOG_WARNING, "'%s' is not a valid event\n", args);
                    break;
                }
                if (!(args = get_token(&buf, script, lineno)) || strcasecmp(args, "THEN")) {
                    ast_log(LOG_WARNING, "IFEVENT clause missing 'THEN' at line %d of %s\n", lineno, script);
                    break;
                }
                state->sub->ifinscount = 0;
                state->sub->ifdata = state->sub->data + state->sub->datalen;
                /* Reserve header and insert op codes */
                state->sub->ifdata[0] = 0x1;
                state->sub->ifdata[1] = event;
                /* 2 is for the number of instructions */
                state->sub->ifdata[3] = 0xff;
                state->sub->datalen += 4;
                /* Update Subscript instruction count */
                state->sub->inscount++;
                state->state = STATE_INIF;
            } else {
                ast_log(LOG_WARNING, "Invalid or Unknown keyword '%s' in SUB definition at line %d of %s\n", keyword, lineno, script);
            }
        }
        break;
    default:
        ast_log(LOG_WARNING, "Can't process keyword '%s' in weird state %d\n", keyword, state->state);
    }
    return 0;
}

References ARG_NUMBER, ARG_STRING, args, ast_copy_string(), ast_log, buf, adsi_display::data, adsi_display::datalen, get_token(), getdisplaybyname(), geteventbyname(), getflagbyname(), getjustifybyname(), getkeybyname(), getstatebyname(), getsubbyname(), adsi_subscript::id, adsi_display::id, LOG_WARNING, NULL, process_opcode(), process_returncode(), process_token(), STATE_INIF, STATE_INKEY, STATE_INSUB, STATE_NORMAL, and adsi_subscript::vname.

Referenced by compile_script().

adsi_prog()

static int adsi_prog ( struct ast_channel *  chan, const char *  script  )

static

Definition at line 1465 of file app_adsiprog.c.

{
    struct adsi_script *scr;
    int x, bytes;
    unsigned char buf[1024];
 
    if (!(scr = compile_script(script)))
        return -1;
 
    /* Start an empty ADSI Session */
    if (ast_adsi_load_session(chan, NULL, 0, 1) < 1)
        return -1;
 
    /* Now begin the download attempt */
    if (ast_adsi_begin_download(chan, scr->desc, scr->fdn, scr->sec, scr->ver)) {
        /* User rejected us for some reason */
        ast_verb(3, "User rejected download attempt\n");
        ast_log(LOG_NOTICE, "User rejected download on channel %s\n", ast_channel_name(chan));
        ast_free(scr);
        return -1;
    }
 
    bytes = 0;
    /* Start with key definitions */
    for (x = 0; x < scr->numkeys; x++) {
        if (bytes + scr->keys[x].retstrlen > 253) {
            /* Send what we've collected so far */
            if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
                ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
                return -1;
            }
            bytes =0;
        }
        memcpy(buf + bytes, scr->keys[x].retstr, scr->keys[x].retstrlen);
        bytes += scr->keys[x].retstrlen;
#ifdef DUMP_MESSAGES
        dump_message("Key", scr->keys[x].vname, scr->keys[x].retstr, scr->keys[x].retstrlen);
#endif
    }
    if (bytes) {
        if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
            ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
            return -1;
        }
    }
 
    bytes = 0;
    /* Continue with the display messages */
    for (x = 0; x < scr->numdisplays; x++) {
        if (bytes + scr->displays[x].datalen > 253) {
            /* Send what we've collected so far */
            if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
                ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
                return -1;
            }
            bytes =0;
        }
        memcpy(buf + bytes, scr->displays[x].data, scr->displays[x].datalen);
        bytes += scr->displays[x].datalen;
#ifdef DUMP_MESSAGES
        dump_message("Display", scr->displays[x].vname, scr->displays[x].data, scr->displays[x].datalen);
#endif
    }
    if (bytes) {
        if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
            ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
            return -1;
        }
    }
 
    bytes = 0;
    /* Send subroutines */
    for (x = 0; x < scr->numsubs; x++) {
        if (bytes + scr->subs[x].datalen > 253) {
            /* Send what we've collected so far */
            if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
                ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
                return -1;
            }
            bytes =0;
        }
        memcpy(buf + bytes, scr->subs[x].data, scr->subs[x].datalen);
        bytes += scr->subs[x].datalen;
#ifdef DUMP_MESSAGES
        dump_message("Sub", scr->subs[x].vname, scr->subs[x].data, scr->subs[x].datalen);
#endif
    }
    if (bytes) {
        if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DOWNLOAD)) {
            ast_log(LOG_WARNING, "Unable to send chunk ending at %d\n", x);
            return -1;
        }
    }
 
    bytes = 0;
    bytes += ast_adsi_display(buf, ADSI_INFO_PAGE, 1, ADSI_JUST_LEFT, 0, "Download complete.", "");
    bytes += ast_adsi_set_line(buf, ADSI_INFO_PAGE, 1);
    if (ast_adsi_transmit_message(chan, buf, bytes, ADSI_MSG_DISPLAY) < 0)
        return -1;
    if (ast_adsi_end_download(chan)) {
        /* Download failed for some reason */
        ast_verb(3, "Download attempt failed\n");
        ast_log(LOG_NOTICE, "Download failed on %s\n", ast_channel_name(chan));
        ast_free(scr);
        return -1;
    }
    ast_free(scr);
    ast_adsi_unload_session(chan);
    return 0;
}

References ADSI_INFO_PAGE, ADSI_JUST_LEFT, ADSI_MSG_DISPLAY, ADSI_MSG_DOWNLOAD, ast_adsi_begin_download(), ast_adsi_display(), ast_adsi_end_download(), ast_adsi_load_session(), ast_adsi_set_line(), ast_adsi_transmit_message(), ast_adsi_unload_session(), ast_channel_name(), ast_free, ast_log, ast_verb, buf, compile_script(), adsi_subscript::data, adsi_display::data, adsi_subscript::datalen, adsi_display::datalen, adsi_script::desc, adsi_script::displays, adsi_script::fdn, adsi_script::keys, LOG_NOTICE, LOG_WARNING, NULL, adsi_script::numdisplays, adsi_script::numkeys, adsi_script::numsubs, adsi_soft_key::retstr, adsi_soft_key::retstrlen, adsi_script::sec, adsi_script::subs, adsi_script::ver, adsi_soft_key::vname, adsi_subscript::vname, and adsi_display::vname.

Referenced by adsi_exec().

AST_MODULE_SELF_SYM()

struct ast_module * AST_MODULE_SELF_SYM

(

void

)

Definition at line 1620 of file app_adsiprog.c.

clearcbone()

static int clearcbone ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 777 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
 
    if (tok)
        ast_log(LOG_WARNING, "CLEARCB1 requires no arguments ('%s') at line %d of %s\n", tok, lineno, script);
 
    buf[0] = id;
    buf[1] = 0;
    return 2;
}

References args, ast_log, buf, get_token(), id, and LOG_WARNING.

cleardisplay()

static int cleardisplay ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 753 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
 
    if (tok)
        ast_log(LOG_WARNING, "Clearing display requires no arguments ('%s') at line %d of %s\n", tok, lineno, script);
 
    buf[0] = id;
    buf[1] = 0x00;
    return 2;
}

References args, ast_log, buf, get_token(), id, and LOG_WARNING.

clearflag()

static int clearflag ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 490 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
    struct adsi_flag *flag;
    char sname[80];
 
    if (!tok) {
        ast_log(LOG_WARNING, "Clearing flag requires a flag number at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(sname, tok, sizeof(sname) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid flag '%s' at line %d of %s\n", tok, lineno, script);
        return 0;
    }
 
    if (!(flag = getflagbyname(state, sname, script, lineno, 0))) {
        ast_log(LOG_WARNING, "Flag '%s' is undeclared at line %d of %s\n", sname, lineno, script);
        return 0;
    }
 
    buf[0] = id;
    buf[1] = ((flag->id & 0x7) << 4);
 
    return 2;
}

References ARG_STRING, args, ast_log, buf, get_token(), getflagbyname(), id, LOG_WARNING, and process_token().

cleartimer()

static int cleartimer ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 420 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
 
    if (tok)
        ast_log(LOG_WARNING, "Clearing timer requires no arguments ('%s') at line %d of %s\n", tok, lineno, script);
 
    buf[0] = id;
 
    /* For some reason the clear code is different slightly */
    if (id == 7)
        buf[1] = 0x10;
    else
        buf[1] = 0x00;
 
    return 2;
}

References args, ast_log, buf, get_token(), id, and LOG_WARNING.

compile_script()

static struct adsi_script * compile_script ( const char *  script )

static

Definition at line 1372 of file app_adsiprog.c.

{
    FILE *f;
    char fn[256], buf[256], *c;
    int lineno = 0, x, err;
    struct adsi_script *scr;
 
    if (script[0] == '/')
        ast_copy_string(fn, script, sizeof(fn));
    else
        snprintf(fn, sizeof(fn), "%s/%s", ast_config_AST_CONFIG_DIR, script);
 
    if (!(f = fopen(fn, "r"))) {
        ast_log(LOG_WARNING, "Can't open file '%s'\n", fn);
        return NULL;
    }
 
    if (!(scr = ast_calloc(1, sizeof(*scr)))) {
        fclose(f);
        return NULL;
    }
 
    /* Create "main" as first subroutine */
    getsubbyname(scr, "main", NULL, 0);
    while (!feof(f)) {
        if (!fgets(buf, sizeof(buf), f)) {
            continue;
        }
        if (!feof(f)) {
            lineno++;
            /* Trim off trailing return */
            buf[strlen(buf) - 1] = '\0';
            /* Strip comments */
            if ((c = strchr(buf, ';')))
                *c = '\0';
            if (!ast_strlen_zero(buf))
                adsi_process(scr, buf, script, lineno);
        }
    }
    fclose(f);
    /* Make sure we're in the main routine again */
    switch(scr->state) {
    case STATE_NORMAL:
        break;
    case STATE_INSUB:
        ast_log(LOG_WARNING, "Missing ENDSUB at end of file %s\n", script);
        ast_free(scr);
        return NULL;
    case STATE_INKEY:
        ast_log(LOG_WARNING, "Missing ENDKEY at end of file %s\n", script);
        ast_free(scr);
        return NULL;
    }
    err = 0;
 
    /* Resolve all keys and record their lengths */
    for (x = 0; x < scr->numkeys; x++) {
        if (!scr->keys[x].defined) {
            ast_log(LOG_WARNING, "Key '%s' referenced but never defined in file %s\n", scr->keys[x].vname, fn);
            err++;
        }
    }
 
    /* Resolve all subs */
    for (x = 0; x < scr->numsubs; x++) {
        if (!scr->subs[x].defined) {
            ast_log(LOG_WARNING, "Subscript '%s' referenced but never defined in file %s\n", scr->subs[x].vname, fn);
            err++;
        }
        if (x == (scr->numsubs - 1)) {
            /* Clear out extension bit on last message */
            scr->subs[x].data[2] = 0x80;
        }
    }
 
    if (err) {
        ast_free(scr);
        return NULL;
    }
    return scr;
}

References adsi_process(), ast_calloc, ast_config_AST_CONFIG_DIR, ast_copy_string(), ast_free, ast_log, ast_strlen_zero(), buf, c, adsi_subscript::data, adsi_soft_key::defined, adsi_subscript::defined, getsubbyname(), adsi_script::keys, LOG_WARNING, NULL, adsi_script::numkeys, adsi_script::numsubs, adsi_script::state, STATE_INKEY, STATE_INSUB, STATE_NORMAL, adsi_script::subs, adsi_soft_key::vname, and adsi_subscript::vname.

Referenced by adsi_prog().

digitcollect()

static int digitcollect ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 789 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
 
    if (tok)
        ast_log(LOG_WARNING, "Digitcollect requires no arguments ('%s') at line %d of %s\n", tok, lineno, script);
 
    buf[0] = id;
    buf[1] = 0xf;
    return 2;
}

References args, ast_log, buf, get_token(), id, and LOG_WARNING.

digitdirect()

static int digitdirect ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 765 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
 
    if (tok)
        ast_log(LOG_WARNING, "Digitdirect requires no arguments ('%s') at line %d of %s\n", tok, lineno, script);
 
    buf[0] = id;
    buf[1] = 0x7;
    return 2;
}

References args, ast_log, buf, get_token(), id, and LOG_WARNING.

get_token()

static char * get_token ( char **  buf, const char *  script, int  lineno  )

static

Definition at line 246 of file app_adsiprog.c.

{
    char *tmp = *buf, *keyword;
    int quoted = 0;
 
    /* Advance past any white space */
    while(*tmp && (*tmp < 33))
        tmp++;
    if (!*tmp)
        return NULL;
    keyword = tmp;
    while(*tmp && ((*tmp > 32)  || quoted)) {
        if (*tmp == '\"') {
            quoted = !quoted;
        }
        tmp++;
    }
    if (quoted) {
        ast_log(LOG_WARNING, "Mismatched quotes at line %d of %s\n", lineno, script);
        return NULL;
    }
    *tmp = '\0';
    tmp++;
    while(*tmp && (*tmp < 33))
        tmp++;
    /* Note where we left off */
    *buf = tmp;
    return keyword;
}

References ast_log, buf, LOG_WARNING, and NULL.

Referenced by adsi_process(), clearcbone(), cleardisplay(), clearflag(), cleartimer(), digitcollect(), digitdirect(), goto_line(), goto_line_rel(), onevent(), process_opcode(), process_returncode(), send_delay(), send_dtmf(), set_state(), setflag(), showdisplay(), showkeys(), starttimer(), and subscript().

getdisplaybyname()

static struct adsi_display * getdisplaybyname ( struct adsi_script *  state, char *  name, const char *  script, int  lineno, int  create  )

static

Definition at line 630 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < state->numdisplays; x++) {
        if (!strcasecmp(state->displays[x].vname, name))
            return &state->displays[x];
    }
 
    /* Return now if we're not allowed to create */
    if (!create)
        return NULL;
 
    if (state->numdisplays > 61) {
        ast_log(LOG_WARNING, "No more display space at line %d of %s\n", lineno, script);
        return NULL;
    }
 
    ast_copy_string(state->displays[state->numdisplays].vname, name, sizeof(state->displays[state->numdisplays].vname));
    state->displays[state->numdisplays].id = state->numdisplays + 1;
    state->numdisplays++;
 
    return &state->displays[state->numdisplays-1];
}

References ast_copy_string(), ast_log, LOG_WARNING, name, and NULL.

Referenced by adsi_process(), and showdisplay().

geteventbyname()

static int geteventbyname ( char *  name )

static

Definition at line 539 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < ARRAY_LEN(events); x++) {
        if (!strcasecmp(events[x].name, name))
            return events[x].id;
    }
 
    return 0;
}

References ARRAY_LEN, events, and name.

Referenced by adsi_process(), and onevent().

getflagbyname()

static struct adsi_flag * getflagbyname ( struct adsi_script *  state, char *  name, const char *  script, int  lineno, int  create  )

static

Definition at line 438 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < state->numflags; x++) {
        if (!strcasecmp(state->flags[x].vname, name))
            return &state->flags[x];
    }
 
    /* Return now if we're not allowed to create */
    if (!create)
        return NULL;
 
    if (state->numflags > 6) {
        ast_log(LOG_WARNING, "No more flag space at line %d of %s\n", lineno, script);
        return NULL;
    }
 
    ast_copy_string(state->flags[state->numflags].vname, name, sizeof(state->flags[state->numflags].vname));
    state->flags[state->numflags].id = state->numflags + 1;
    state->numflags++;
 
    return &state->flags[state->numflags-1];
}

References ast_copy_string(), ast_log, LOG_WARNING, name, and NULL.

Referenced by adsi_process(), clearflag(), setflag(), and showkeys().

getjustifybyname()

static int getjustifybyname ( char *  name )

static

Definition at line 551 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < ARRAY_LEN(justify); x++) {
        if (!strcasecmp(justify[x].name, name))
            return justify[x].id;
    }
 
    return -1;
}

References ARRAY_LEN, justify, and name.

Referenced by adsi_process().

getkeybyname()

static struct adsi_soft_key * getkeybyname ( struct adsi_script *  state, char *  name, const char *  script, int  lineno  )

static

Definition at line 563 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < state->numkeys; x++) {
        if (!strcasecmp(state->keys[x].vname, name))
            return &state->keys[x];
    }
 
    if (state->numkeys > 61) {
        ast_log(LOG_WARNING, "No more key space at line %d of %s\n", lineno, script);
        return NULL;
    }
 
    ast_copy_string(state->keys[state->numkeys].vname, name, sizeof(state->keys[state->numkeys].vname));
    state->keys[state->numkeys].id = state->numkeys + 2;
    state->numkeys++;
 
    return &state->keys[state->numkeys-1];
}

References ast_copy_string(), ast_log, LOG_WARNING, name, and NULL.

Referenced by adsi_process(), and showkeys().

getstatebyname()

static struct adsi_state * getstatebyname ( struct adsi_script *  state, char *  name, const char *  script, int  lineno, int  create  )

static

Definition at line 605 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x <state->numstates; x++) {
        if (!strcasecmp(state->states[x].vname, name))
            return &state->states[x];
    }
 
    /* Return now if we're not allowed to create */
    if (!create)
        return NULL;
 
    if (state->numstates > 253) {
        ast_log(LOG_WARNING, "No more state space at line %d of %s\n", lineno, script);
        return NULL;
    }
 
    ast_copy_string(state->states[state->numstates].vname, name, sizeof(state->states[state->numstates].vname));
    state->states[state->numstates].id = state->numstates + 1;
    state->numstates++;
 
    return &state->states[state->numstates-1];
}

References ast_copy_string(), ast_log, LOG_WARNING, name, and NULL.

Referenced by adsi_process(), and onevent().

getsubbyname()

static struct adsi_subscript * getsubbyname ( struct adsi_script *  state, char *  name, const char *  script, int  lineno  )

static

Definition at line 584 of file app_adsiprog.c.

{
    int x;
 
    for (x = 0; x < state->numsubs; x++) {
        if (!strcasecmp(state->subs[x].vname, name))
            return &state->subs[x];
    }
 
    if (state->numsubs > 127) {
        ast_log(LOG_WARNING, "No more subscript space at line %d of %s\n", lineno, S_OR(script, "unknown"));
        return NULL;
    }
 
    ast_copy_string(state->subs[state->numsubs].vname, name, sizeof(state->subs[state->numsubs].vname));
    state->subs[state->numsubs].id = state->numsubs;
    state->numsubs++;
 
    return &state->subs[state->numsubs-1];
}

References ast_copy_string(), ast_log, LOG_WARNING, name, NULL, and S_OR.

Referenced by adsi_process(), compile_script(), onevent(), and subscript().

goto_line()

static int goto_line ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 308 of file app_adsiprog.c.

{
    char *page = get_token(&args, script, lineno);
    char *gline = get_token(&args, script, lineno);
    int line;
    unsigned char cmd;
 
    if (!page || !gline) {
        ast_log(LOG_WARNING, "Expecting page and line number for GOTOLINE at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (!strcasecmp(page, "INFO"))
        cmd = 0;
    else if (!strcasecmp(page, "COMM"))
        cmd = 0x80;
    else {
        ast_log(LOG_WARNING, "Expecting either 'INFO' or 'COMM' page, got '%s' at line %d of %s\n", page, lineno, script);
        return 0;
    }
 
    if (process_token(&line, gline, sizeof(line), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid line number '%s' at line %d of %s\n", gline, lineno, script);
        return 0;
    }
 
    cmd |= line;
    buf[0] = 0x8b;
    buf[1] = cmd;
 
    return 2;
}

References ARG_NUMBER, args, ast_log, buf, get_token(), LOG_WARNING, and process_token().

goto_line_rel()

static int goto_line_rel ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 341 of file app_adsiprog.c.

{
    char *dir = get_token(&args, script, lineno);
    char *gline = get_token(&args, script, lineno);
    int line;
    unsigned char cmd;
 
    if (!dir || !gline) {
        ast_log(LOG_WARNING, "Expecting direction and number of lines for GOTOLINEREL at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (!strcasecmp(dir, "UP"))
        cmd = 0;
    else if (!strcasecmp(dir, "DOWN"))
        cmd = 0x20;
    else {
        ast_log(LOG_WARNING, "Expecting either 'UP' or 'DOWN' direction, got '%s' at line %d of %s\n", dir, lineno, script);
        return 0;
    }
 
    if (process_token(&line, gline, sizeof(line), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid line number '%s' at line %d of %s\n", gline, lineno, script);
        return 0;
    }
 
    cmd |= line;
    buf[0] = 0x8c;
    buf[1] = cmd;
 
    return 2;
}

References ARG_NUMBER, args, ast_log, buf, get_token(), LOG_WARNING, and process_token().

load_module()

static int load_module ( void  )

static

Load the module.

Module loading including tests for configuration or dependencies. This function can return AST_MODULE_LOAD_FAILURE, AST_MODULE_LOAD_DECLINE, or AST_MODULE_LOAD_SUCCESS. If a dependency or environment variable fails tests return AST_MODULE_LOAD_FAILURE. If the module can not load the configuration file or other non-critical problem return AST_MODULE_LOAD_DECLINE. On success return AST_MODULE_LOAD_SUCCESS.

Definition at line 1608 of file app_adsiprog.c.

{
    if (ast_register_application_xml(app, adsi_exec))
        return AST_MODULE_LOAD_DECLINE;
    return AST_MODULE_LOAD_SUCCESS;
}

References adsi_exec(), app, AST_MODULE_LOAD_DECLINE, AST_MODULE_LOAD_SUCCESS, and ast_register_application_xml.

onevent()

static int onevent ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 826 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
    char subscr[80], sname[80];
    int sawin = 0, event, snums[8], scnt = 0, x;
    struct adsi_subscript *sub;
 
    if (!tok) {
        ast_log(LOG_WARNING, "Missing event for 'ONEVENT' at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if ((event = geteventbyname(tok)) < 1) {
        ast_log(LOG_WARNING, "'%s' is not a valid event name, at line %d of %s\n", args, lineno, script);
        return 0;
    }
 
    tok = get_token(&args, script, lineno);
    while ((!sawin && !strcasecmp(tok, "IN")) || (sawin && !strcasecmp(tok, "OR"))) {
        sawin = 1;
        if (scnt > 7) {
            ast_log(LOG_WARNING, "No more than 8 states may be specified for inclusion at line %d of %s\n", lineno, script);
            return 0;
        }
        /* Process 'in' things */
        tok = get_token(&args, script, lineno);
        if (process_token(sname, tok, sizeof(sname), ARG_STRING)) {
            ast_log(LOG_WARNING, "'%s' is not a valid state name at line %d of %s\n", tok, lineno, script);
            return 0;
        }
        if ((snums[scnt] = getstatebyname(state, sname, script, lineno, 0) == NULL)) {
            ast_log(LOG_WARNING, "State '%s' not declared at line %d of %s\n", sname, lineno, script);
            return 0;
        }
        scnt++;
        if (!(tok = get_token(&args, script, lineno)))
            break;
    }
    if (!tok || strcasecmp(tok, "GOTO")) {
        if (!tok)
            tok = "<nothing>";
        if (sawin)
            ast_log(LOG_WARNING, "Got '%s' while looking for 'GOTO' or 'OR' at line %d of %s\n", tok, lineno, script);
        else
            ast_log(LOG_WARNING, "Got '%s' while looking for 'GOTO' or 'IN' at line %d of %s\n", tok, lineno, script);
    }
    if (!(tok = get_token(&args, script, lineno))) {
        ast_log(LOG_WARNING, "Missing subscript to call at line %d of %s\n", lineno, script);
        return 0;
    }
    if (process_token(subscr, tok, sizeof(subscr) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid subscript '%s' at line %d of %s\n", tok, lineno, script);
        return 0;
    }
    if (!(sub = getsubbyname(state, subscr, script, lineno)))
        return 0;
    buf[0] = 8;
    buf[1] = event;
    buf[2] = sub->id | 0x80;
    for (x = 0; x < scnt; x++)
        buf[3 + x] = snums[x];
    return 3 + scnt;
}

References ARG_STRING, args, ast_log, buf, get_token(), geteventbyname(), getstatebyname(), getsubbyname(), LOG_WARNING, NULL, process_token(), and sub.

process_opcode()

static int process_opcode ( struct adsi_subscript *  sub, char *  code, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 987 of file app_adsiprog.c.

{
    int x, res, max = sub->id ? MAX_SUB_LEN : MAX_MAIN_LEN;
    char *unused;
 
    for (x = 0; x < ARRAY_LEN(opcmds); x++) {
        if ((opcmds[x].id > -1) && !strcasecmp(opcmds[x].name, code)) {
            if (opcmds[x].add_args) {
                res = opcmds[x].add_args(sub->data + sub->datalen,
                        code, opcmds[x].id, args, state, script, lineno);
                if ((sub->datalen + res + 1) <= max)
                    sub->datalen += res;
                else {
                    ast_log(LOG_WARNING, "No space for '%s' code in subscript '%s' at line %d of %s\n", opcmds[x].name, sub->vname, lineno, script);
                    return -1;
                }
            } else {
                if ((unused = get_token(&args, script, lineno)))
                    ast_log(LOG_WARNING, "'%s' takes no arguments at line %d of %s (token is '%s')\n", opcmds[x].name, lineno, script, unused);
                if ((sub->datalen + 2) <= max) {
                    sub->data[sub->datalen] = opcmds[x].id;
                    sub->datalen++;
                } else {
                    ast_log(LOG_WARNING, "No space for '%s' code in key '%s' at line %d of %s\n", opcmds[x].name, sub->vname, lineno, script);
                    return -1;
                }
            }
            /* Separate commands with 0xff */
            sub->data[sub->datalen] = 0xff;
            sub->datalen++;
            sub->inscount++;
            return 0;
        }
    }
    return -1;
}

References adsi_key_cmd::add_args, args, ARRAY_LEN, ast_log, get_token(), adsi_key_cmd::id, LOG_WARNING, max, MAX_MAIN_LEN, MAX_SUB_LEN, name, opcmds, and sub.

Referenced by adsi_process().

process_returncode()

static int process_returncode ( struct adsi_soft_key *  key, char *  code, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 958 of file app_adsiprog.c.

{
    int x, res;
    char *unused;
 
    for (x = 0; x < ARRAY_LEN(kcmds); x++) {
        if ((kcmds[x].id > -1) && !strcasecmp(kcmds[x].name, code)) {
            if (kcmds[x].add_args) {
                res = kcmds[x].add_args(key->retstr + key->retstrlen,
                        code, kcmds[x].id, args, state, script, lineno);
                if ((key->retstrlen + res - key->initlen) <= MAX_RET_CODE)
                    key->retstrlen += res;
                else
                    ast_log(LOG_WARNING, "No space for '%s' code in key '%s' at line %d of %s\n", kcmds[x].name, key->vname, lineno, script);
            } else {
                if ((unused = get_token(&args, script, lineno)))
                    ast_log(LOG_WARNING, "'%s' takes no arguments at line %d of %s (token is '%s')\n", kcmds[x].name, lineno, script, unused);
                if ((key->retstrlen + 1 - key->initlen) <= MAX_RET_CODE) {
                    key->retstr[key->retstrlen] = kcmds[x].id;
                    key->retstrlen++;
                } else
                    ast_log(LOG_WARNING, "No space for '%s' code in key '%s' at line %d of %s\n", kcmds[x].name, key->vname, lineno, script);
            }
            return 0;
        }
    }
    return -1;
}

References adsi_key_cmd::add_args, args, ARRAY_LEN, ast_log, get_token(), adsi_key_cmd::id, adsi_soft_key::initlen, kcmds, LOG_WARNING, MAX_RET_CODE, name, adsi_soft_key::retstr, adsi_soft_key::retstrlen, and adsi_soft_key::vname.

Referenced by adsi_process().

process_token()

static int process_token ( void *  out, char *  src, int  maxlen, int  argtype  )

static

Definition at line 199 of file app_adsiprog.c.

{
    if ((strlen(src) > 1) && src[0] == '\"') {
        /* This is a quoted string */
        if (!(argtype & ARG_STRING))
            return -1;
        src++;
        /* Don't take more than what's there */
        if (maxlen > strlen(src) - 1)
            maxlen = strlen(src) - 1;
        memcpy(out, src, maxlen);
        ((char *)out)[maxlen] = '\0';
    } else if (!ast_strlen_zero(src) && (src[0] == '\\')) {
        if (!(argtype & ARG_NUMBER))
            return -1;
        /* Octal value */
        if (sscanf(src, "%30o", (unsigned *)out) != 1)
            return -1;
        if (argtype & ARG_STRING) {
            /* Convert */
            *((unsigned int *)out) = htonl(*((unsigned int *)out));
        }
    } else if ((strlen(src) > 2) && (src[0] == '0') && (tolower(src[1]) == 'x')) {
        if (!(argtype & ARG_NUMBER))
            return -1;
        /* Hex value */
        if (sscanf(src + 2, "%30x", (unsigned int *)out) != 1)
            return -1;
        if (argtype & ARG_STRING) {
            /* Convert */
            *((unsigned int *)out) = htonl(*((unsigned int *)out));
        }
    } else if ((!ast_strlen_zero(src) && isdigit(src[0]))) {
        if (!(argtype & ARG_NUMBER))
            return -1;
        /* Hex value */
        if (sscanf(src, "%30d", (int *)out) != 1)
            return -1;
        if (argtype & ARG_STRING) {
            /* Convert */
            *((unsigned int *)out) = htonl(*((unsigned int *)out));
        }
    } else
        return -1;
    return 0;
}

References ARG_NUMBER, ARG_STRING, ast_strlen_zero(), and out.

Referenced by adsi_process(), clearflag(), goto_line(), goto_line_rel(), onevent(), send_delay(), send_dtmf(), set_state(), setflag(), showdisplay(), showkeys(), starttimer(), and subscript().

send_delay()

static int send_delay ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 374 of file app_adsiprog.c.

{
    char *gtime = get_token(&args, script, lineno);
    int ms;
 
    if (!gtime) {
        ast_log(LOG_WARNING, "Expecting number of milliseconds to wait at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(&ms, gtime, sizeof(ms), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid delay milliseconds '%s' at line %d of %s\n", gtime, lineno, script);
        return 0;
    }
 
    buf[0] = 0x90;
 
    if (id == 11)
        buf[1] = ms / 100;
    else
        buf[1] = ms / 10;
 
    return 2;
}

References ARG_NUMBER, args, ast_log, buf, get_token(), LOG_WARNING, and process_token().

send_dtmf()

static int send_dtmf ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 278 of file app_adsiprog.c.

{
    char dtmfstr[80], *a;
    int bytes = 0;
 
    if (!(a = get_token(&args, script, lineno))) {
        ast_log(LOG_WARNING, "Expecting something to send for SENDDTMF at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(dtmfstr, a, sizeof(dtmfstr) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid token for SENDDTMF at line %d of %s\n", lineno, script);
        return 0;
    }
 
    a = dtmfstr;
 
    while (*a) {
        if (strchr(validdtmf, *a)) {
            *buf = *a;
            buf++;
            bytes++;
        } else
            ast_log(LOG_WARNING, "'%c' is not a valid DTMF tone at line %d of %s\n", *a, lineno, script);
        a++;
    }
 
    return bytes;
}

References a, ARG_STRING, args, ast_log, buf, get_token(), LOG_WARNING, process_token(), and validdtmf.

set_state()

static int set_state ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 399 of file app_adsiprog.c.

{
    char *gstate = get_token(&args, script, lineno);
    int state;
 
    if (!gstate) {
        ast_log(LOG_WARNING, "Expecting state number at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(&state, gstate, sizeof(state), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid state number '%s' at line %d of %s\n", gstate, lineno, script);
        return 0;
    }
 
    buf[0] = id;
    buf[1] = state;
 
    return 2;
}

References ARG_NUMBER, args, ast_log, buf, get_token(), id, LOG_WARNING, process_token(), and state.

setflag()

static int setflag ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 463 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
    char sname[80];
    struct adsi_flag *flag;
 
    if (!tok) {
        ast_log(LOG_WARNING, "Setting flag requires a flag number at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(sname, tok, sizeof(sname) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid flag '%s' at line %d of %s\n", tok, lineno, script);
        return 0;
    }
 
    if (!(flag = getflagbyname(state, sname, script, lineno, 0))) {
        ast_log(LOG_WARNING, "Flag '%s' is undeclared at line %d of %s\n", sname, lineno, script);
        return 0;
    }
 
    buf[0] = id;
    buf[1] = ((flag->id & 0x7) << 4) | 1;
 
    return 2;
}

References ARG_STRING, args, ast_log, buf, get_token(), getflagbyname(), id, LOG_WARNING, and process_token().

showdisplay()

static int showdisplay ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 702 of file app_adsiprog.c.

{
    char *tok, dispname[80];
    int line = 0, flag = 0, cmd = 3;
    struct adsi_display *disp;
 
    /* Get display */
    if (!(tok = get_token(&args, script, lineno)) || process_token(dispname, tok, sizeof(dispname) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid display name: %s at line %d of %s\n", tok ? tok : "<nothing>", lineno, script);
        return 0;
    }
 
    if (!(disp = getdisplaybyname(state, dispname, script, lineno, 0))) {
        ast_log(LOG_WARNING, "Display '%s' is undefined at line %d of %s\n", dispname, lineno, script);
        return 0;
    }
 
    if (!(tok = get_token(&args, script, lineno)) || strcasecmp(tok, "AT")) {
        ast_log(LOG_WARNING, "Missing token 'AT' at line %d of %s\n", lineno, script);
        return 0;
    }
 
    /* Get line number */
    if (!(tok = get_token(&args, script, lineno)) || process_token(&line, tok, sizeof(line), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid line: '%s' at line %d of %s\n", tok ? tok : "<nothing>", lineno, script);
        return 0;
    }
 
    if ((tok = get_token(&args, script, lineno)) && !strcasecmp(tok, "NOUPDATE")) {
        cmd = 1;
        tok = get_token(&args, script, lineno);
    }
 
    if (tok && !strcasecmp(tok, "UNLESS")) {
        /* Check for trailing UNLESS flag */
        if (!(tok = get_token(&args, script, lineno)))
            ast_log(LOG_WARNING, "Missing argument for UNLESS clause at line %d of %s\n", lineno, script);
        else if (process_token(&flag, tok, sizeof(flag), ARG_NUMBER))
            ast_log(LOG_WARNING, "Invalid flag number '%s' at line %d of %s\n", tok, lineno, script);
 
        if ((tok = get_token(&args, script, lineno)))
            ast_log(LOG_WARNING, "Extra arguments after UNLESS clause: '%s' at line %d of %s\n", tok, lineno, script);
    }
 
    buf[0] = id;
    buf[1] = (cmd << 6) | (disp->id & 0x3f);
    buf[2] = ((line & 0x1f) << 3) | (flag & 0x7);
 
    return 3;
}

References ARG_NUMBER, ARG_STRING, args, ast_log, buf, get_token(), getdisplaybyname(), adsi_display::id, id, LOG_WARNING, and process_token().

showkeys()

static int showkeys ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 655 of file app_adsiprog.c.

{
    char *tok, newkey[80];
    int bytes, x, flagid = 0;
    unsigned char keyid[6];
    struct adsi_soft_key *key;
    struct adsi_flag *flag;
 
    for (x = 0; x < 7; x++) {
        /* Up to 6 key arguments */
        if (!(tok = get_token(&args, script, lineno)))
            break;
        if (!strcasecmp(tok, "UNLESS")) {
            /* Check for trailing UNLESS flag */
            if (!(tok = get_token(&args, script, lineno)))
                ast_log(LOG_WARNING, "Missing argument for UNLESS clause at line %d of %s\n", lineno, script);
            else if (process_token(newkey, tok, sizeof(newkey) - 1, ARG_STRING))
                ast_log(LOG_WARNING, "Invalid flag name '%s' at line %d of %s\n", tok, lineno, script);
            else if (!(flag = getflagbyname(state, newkey, script, lineno, 0)))
                ast_log(LOG_WARNING, "Flag '%s' is undeclared at line %d of %s\n", newkey, lineno, script);
            else
                flagid = flag->id;
            if ((tok = get_token(&args, script, lineno)))
                ast_log(LOG_WARNING, "Extra arguments after UNLESS clause: '%s' at line %d of %s\n", tok, lineno, script);
            break;
        }
        if (x > 5) {
            ast_log(LOG_WARNING, "Only 6 keys can be defined, ignoring '%s' at line %d of %s\n", tok, lineno, script);
            break;
        }
        if (process_token(newkey, tok, sizeof(newkey) - 1, ARG_STRING)) {
            ast_log(LOG_WARNING, "Invalid token for key name: %s\n", tok);
            continue;
        }
 
        if (!(key = getkeybyname(state, newkey, script, lineno)))
            break;
        keyid[x] = key->id;
    }
    buf[0] = id;
    buf[1] = (flagid & 0x7) << 3 | (x & 0x7);
    for (bytes = 0; bytes < x; bytes++)
        buf[bytes + 2] = keyid[bytes];
 
    return 2 + x;
}

References ARG_STRING, args, ast_log, buf, get_token(), getflagbyname(), getkeybyname(), adsi_soft_key::id, id, LOG_WARNING, and process_token().

starttimer()

static int starttimer ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  istate, const char *  script, int  lineno  )

static

Definition at line 517 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
    int secs;
 
    if (!tok) {
        ast_log(LOG_WARNING, "Missing number of seconds at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(&secs, tok, sizeof(secs), ARG_NUMBER)) {
        ast_log(LOG_WARNING, "Invalid number of seconds '%s' at line %d of %s\n", tok, lineno, script);
        return 0;
    }
 
    buf[0] = id;
    buf[1] = 0x1;
    buf[2] = secs;
 
    return 3;
}

References ARG_NUMBER, args, ast_log, buf, get_token(), id, LOG_WARNING, and process_token().

subscript()

static int subscript ( char *  buf, char *  name, int  id, char *  args, struct adsi_script *  state, const char *  script, int  lineno  )

static

Definition at line 801 of file app_adsiprog.c.

{
    char *tok = get_token(&args, script, lineno);
    char subscr[80];
    struct adsi_subscript *sub;
 
    if (!tok) {
        ast_log(LOG_WARNING, "Missing subscript to call at line %d of %s\n", lineno, script);
        return 0;
    }
 
    if (process_token(subscr, tok, sizeof(subscr) - 1, ARG_STRING)) {
        ast_log(LOG_WARNING, "Invalid number of seconds '%s' at line %d of %s\n", tok, lineno, script);
        return 0;
    }
 
    if (!(sub = getsubbyname(state, subscr, script, lineno)))
        return 0;
 
    buf[0] = 0x9d;
    buf[1] = sub->id;
 
    return 2;
}

References ARG_STRING, args, ast_log, buf, get_token(), getsubbyname(), LOG_WARNING, process_token(), and sub.

unload_module()

static int unload_module ( void  )

static

Definition at line 1593 of file app_adsiprog.c.

{
    return ast_unregister_application(app);
}

References app, and ast_unregister_application().

Variable Documentation

__mod_info

struct ast_module_info __mod_info = { .name = AST_MODULE, .flags = AST_MODFLAG_DEFAULT , .description = "Asterisk ADSI Programming Application" , .key = "This paragraph is copyright (c) 2006 by Digium, Inc. \In order for your module to load, it must return this \key via a function called \"key\". Any code which \includes this paragraph must be licensed under the GNU \General Public License version 2 or later (at your \option). In addition to Digium's general reservations \of rights, Digium expressly reserves the right to \allow other parties to license this paragraph under \different terms. Any use of Digium, Inc. trademarks or \logos (including \"Asterisk\" or \"Digium\") without \express written permission of Digium, Inc. is prohibited.\n" , .buildopt_sum = AST_BUILDOPT_SUM, .support_level = AST_MODULE_SUPPORT_DEPRECATED, .load = load_module, .unload = unload_module, .requires = "res_adsi", }

static

Definition at line 1620 of file app_adsiprog.c.

app

const char app[] = "ADSIProg"

static

Definition at line 56 of file app_adsiprog.c.

Referenced by __stasis_app_register(), action_originate(), add_extension(), add_extensions(), adsi_load_session(), answer_exec_enable(), answer_exec_run(), app_create(), app_deactivate(), app_dtor(), app_event_filter_set(), app_event_sources_to_json(), app_events_allowed_set(), app_events_disallowed_set(), app_handle_subscriptions(), app_hash(), app_is_active(), app_is_finished(), app_is_subscribed_bridge_id(), app_is_subscribed_channel_id(), app_is_subscribed_endpoint_id(), app_match(), app_name(), app_send(), app_send_end_msg(), app_shutdown(), app_subscribe(), app_subscribe_bridge(), app_subscribe_channel(), app_subscribe_endpoint(), app_to_json(), app_unsubscribe(), app_unsubscribe_bridge(), app_unsubscribe_bridge_id(), app_unsubscribe_channel(), app_unsubscribe_channel_id(), app_unsubscribe_endpoint_id(), app_update(), append_json(), append_name(), applicationmap_handler(), applicationmap_item_alloc(), ari_originate_dial(), ari_set_debug(), ari_show_app(), ari_show_apps(), ast_adsi_load_session(), ast_app_get_topic(), ast_ari_applications_filter(), ast_ari_callback(), ast_attended_transfer_message_add_app(), ast_bridge_transfer_attended(), ast_compile_ael2(), ast_complete_applications(), ast_pbx_exec_application(), ast_pbx_outgoing_app(), ast_pbx_outgoing_app_predial(), ast_register_application2(), AST_TEST_DEFINE(), ast_unregister_application(), attended_transfer_bridge(), bridge_app_subscribed(), bridge_app_subscribed_involved(), bridge_attended_transfer_handler(), bridge_blind_transfer_handler(), bridge_merge_handler(), bridge_subscription_change_handler(), call_forwarded_handler(), cel_track_app(), check_app_args(), check_pval_item(), cleanup_cb(), control_create(), control_set_app(), device_state_subscription_create(), devices_to_json(), endpoint_state_cb(), exec_exec(), execif_exec(), extension_presence_state_helper(), find_device_state(), find_device_state_subscription(), forwards_create(), forwards_create_bridge(), forwards_create_channel(), forwards_create_endpoint(), handle_cli_dialplan_add_extension(), handle_cli_status(), handle_exec(), handle_show_application(), is_originate_app_permitted(), is_subscribed_device_state(), is_subscribed_device_state_lock(), load_module(), load_moh_classes(), lua_pbx_exec(), message_received_handler(), orig_app(), outbound_session_apply_config(), outbound_websocket_apply(), outbound_websocket_validate_cb(), page_exec(), parse_line(), pbx_exec(), pbx_extension_helper(), pbx_findapp(), pbx_outgoing_attempt(), pbx_outgoing_exec(), queue_match(), realtime_exec(), send_start_msg(), send_start_msg_snapshots(), session_find_by_app(), session_update(), stasis_app_control_snoop(), stasis_app_event_allowed(), stasis_app_event_filter_set(), stasis_app_event_filter_to_json(), stasis_app_exec(), stasis_app_get_debug(), stasis_app_get_debug_by_name(), stasis_app_is_registered(), stasis_app_name(), stasis_app_object_to_json(), stasis_app_send(), stasis_app_set_debug(), stasis_app_set_debug_by_name(), stasis_app_set_global_debug(), stasis_app_subscribe_channel(), stasis_app_to_cli(), stasis_app_to_json(), stasis_app_unregister(), stasis_app_user_event(), sub_bridge_update_handler(), sub_channel_update_handler(), sub_endpoint_update_handler(), sub_subscription_change_handler(), subscribe_bridge(), subscribe_channel(), subscribe_device_state(), subscribe_endpoint(), tryexec_exec(), unload_module(), unreference_cached_app(), unsubscribe(), and unsubscribe_device_state().

ast_module_info

const struct ast_module_info* ast_module_info = &__mod_info

static

Definition at line 1620 of file app_adsiprog.c.

events

const struct adsi_event events[]

static

Definition at line 88 of file app_adsiprog.c.

Referenced by add_event_to_list(), add_new_event_cb(), ast_io_add(), ast_io_change(), calendar_query_exec(), calendar_query_result_exec(), eventlist_destroy(), eventlist_destructor(), eventlist_duplicate(), events_handler(), find_event(), geteventbyname(), handle_manager_show_event(), handle_manager_show_events(), and parse_tag().

justify

const struct adsi_event justify[]

static

Definition at line 115 of file app_adsiprog.c.

Referenced by cpeid_setstatus(), and getjustifybyname().

kcmds

const struct adsi_key_cmd kcmds[]

static

Definition at line 896 of file app_adsiprog.c.

Referenced by process_returncode().

opcmds

const struct adsi_key_cmd opcmds[]

static

Definition at line 938 of file app_adsiprog.c.

Referenced by process_opcode().

validdtmf

char* validdtmf = "123456789*0#ABCD"

static

Definition at line 276 of file app_adsiprog.c.

Referenced by send_dtmf().