/* * Asterisk -- An open source telephony toolkit. * * Copyright (C) 1999 - 2005, Digium, Inc. * * Mark Spencer * * See http://www.asterisk.org for more information about * the Asterisk project. Please do not directly contact * any of the maintainers of this project for assistance; * the project provides a web site, mailing lists and IRC * channels for your use. * * This program is free software, distributed under the terms of * the GNU General Public License Version 2. See the LICENSE file * at the top of the source tree. */ /*! \file * * \brief Program Asterisk ADSI Scripts into phone * * \author Mark Spencer * * \ingroup applications */ /*** MODULEINFO res_adsi ***/ #include "asterisk.h" ASTERISK_FILE_VERSION(__FILE__, "$Revision$") #include #include #include "asterisk/paths.h" /* use ast_config_AST_CONFIG_DIR */ #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" static char *app = "ADSIProg"; /*** DOCUMENTATION Load Asterisk ADSI Scripts into phone adsi script to use. If not given uses the default script asterisk.adsi This application programs an ADSI Phone with the given script

GetCPEID adsi.conf

***/ /* #define DUMP_MESSAGES */ struct adsi_event { int id; char *name; }; static struct adsi_event events[] = { { 1, "CALLERID" }, { 2, "VMWI" }, { 3, "NEARANSWER" }, { 4, "FARANSWER" }, { 5, "ENDOFRING" }, { 6, "IDLE" }, { 7, "OFFHOOK" }, { 8, "CIDCW" }, { 9, "BUSY" }, { 10, "FARRING" }, { 11, "DIALTONE" }, { 12, "RECALL" }, { 13, "MESSAGE" }, { 14, "REORDER" }, { 15, "DISTINCTIVERING" }, { 16, "RING" }, { 17, "REMINDERRING" }, { 18, "SPECIALRING" }, { 19, "CODEDRING" }, { 20, "TIMER" }, { 21, "INUSE" }, { 22, "EVENT22" }, { 23, "EVENT23" }, { 24, "CPEID" }, }; static struct adsi_event justify[] = { { 0, "CENTER" }, { 1, "RIGHT" }, { 2, "LEFT" }, { 3, "INDENT" }, }; #define STATE_NORMAL 0 #define STATE_INKEY 1 #define STATE_INSUB 2 #define STATE_INIF 3 #define MAX_RET_CODE 20 #define MAX_SUB_LEN 255 #define MAX_MAIN_LEN 1600 #define ARG_STRING (1 << 0) #define ARG_NUMBER (1 << 1) struct adsi_soft_key { char vname[40]; /* Which "variable" is associated with it */ int retstrlen; /* Length of return string */ int initlen; /* initial length */ int id; int defined; char retstr[80]; /* Return string data */ }; struct adsi_subscript { char vname[40]; int id; int defined; int datalen; int inscount; int ifinscount; char *ifdata; char data[2048]; }; struct adsi_state { char vname[40]; int id; }; struct adsi_flag { char vname[40]; int id; }; struct adsi_display { char vname[40]; int id; char data[70]; int datalen; }; struct adsi_script { int state; int numkeys; int numsubs; int numstates; int numdisplays; int numflags; struct adsi_soft_key *key; struct adsi_subscript *sub; /* Pre-defined displays */ struct adsi_display displays[63]; /* ADSI States 1 (initial) - 254 */ struct adsi_state states[256]; /* Keys 2-63 */ struct adsi_soft_key keys[62]; /* Subscripts 0 (main) to 127 */ struct adsi_subscript subs[128]; /* Flags 1-7 */ struct adsi_flag flags[7]; /* Stuff from adsi script */ unsigned char sec[5]; char desc[19]; unsigned char fdn[5]; int ver; }; static int process_token(void *out, char *src, int maxlen, int argtype) { 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", (int *)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; } static char *get_token(char **buf, char *script, int lineno) { 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; } static char *validdtmf = "123456789*0#ABCD"; static int send_dtmf(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int goto_line(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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 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; } static int goto_line_rel(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int send_delay(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int set_state(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int cleartimer(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static struct adsi_flag *getflagbyname(struct adsi_script *state, char *name, char *script, int lineno, int create) { 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]; } static int setflag(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int clearflag(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int starttimer(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int geteventbyname(char *name) { int x; for (x = 0; x < ARRAY_LEN(events); x++) { if (!strcasecmp(events[x].name, name)) return events[x].id; } return 0; } static int getjustifybyname(char *name) { int x; for (x = 0; x < ARRAY_LEN(justify); x++) { if (!strcasecmp(justify[x].name, name)) return justify[x].id; } return -1; } static struct adsi_soft_key *getkeybyname(struct adsi_script *state, char *name, char *script, int lineno) { 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]; } static struct adsi_subscript *getsubbyname(struct adsi_script *state, char *name, char *script, int lineno) { 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, script); 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]; } static struct adsi_state *getstatebyname(struct adsi_script *state, char *name, char *script, int lineno, int create) { int x; for (x = 0; x 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]; } static struct adsi_display *getdisplaybyname(struct adsi_script *state, char *name, char *script, int lineno, int create) { 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]; } static int showkeys(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int showdisplay(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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 : "", 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 : "", 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; } static int cleardisplay(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int digitdirect(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int clearcbone(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int digitcollect(char *buf, char *name, int id, char *args, struct adsi_script *istate, char *script, int lineno) { 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; } static int subscript(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int onevent(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno) { 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 = ""; 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; } struct adsi_key_cmd { char *name; int id; int (*add_args)(char *buf, char *name, int id, char *args, struct adsi_script *state, char *script, int lineno); }; static struct adsi_key_cmd kcmds[] = { { "SENDDTMF", 0, send_dtmf }, /* Encoded DTMF would go here */ { "ONHOOK", 0x81 }, { "OFFHOOK", 0x82 }, { "FLASH", 0x83 }, { "WAITDIALTONE", 0x84 }, /* Send line number */ { "BLANK", 0x86 }, { "SENDCHARS", 0x87 }, { "CLEARCHARS", 0x88 }, { "BACKSPACE", 0x89 }, /* Tab column */ { "GOTOLINE", 0x8b, goto_line }, { "GOTOLINEREL", 0x8c, goto_line_rel }, { "PAGEUP", 0x8d }, { "PAGEDOWN", 0x8e }, /* Extended DTMF */ { "DELAY", 0x90, send_delay }, { "DIALPULSEONE", 0x91 }, { "DATAMODE", 0x92 }, { "VOICEMODE", 0x93 }, /* Display call buffer 'n' */ /* Clear call buffer 'n' */ { "CLEARCB1", 0x95, clearcbone }, { "DIGITCOLLECT", 0x96, digitcollect }, { "DIGITDIRECT", 0x96, digitdirect }, { "CLEAR", 0x97 }, { "SHOWDISPLAY", 0x98, showdisplay }, { "CLEARDISPLAY", 0x98, cleardisplay }, { "SHOWKEYS", 0x99, showkeys }, { "SETSTATE", 0x9a, set_state }, { "TIMERSTART", 0x9b, starttimer }, { "TIMERCLEAR", 0x9b, cleartimer }, { "SETFLAG", 0x9c, setflag }, { "CLEARFLAG", 0x9c, clearflag }, { "GOTO", 0x9d, subscript }, { "EVENT22", 0x9e }, { "EVENT23", 0x9f }, { "EXIT", 0xa0 }, }; static struct adsi_key_cmd opcmds[] = { /* 1 - Branch on event -- handled specially */ { "SHOWKEYS", 2, showkeys }, /* Display Control */ { "SHOWDISPLAY", 3, showdisplay }, { "CLEARDISPLAY", 3, cleardisplay }, { "CLEAR", 5 }, { "SETSTATE", 6, set_state }, { "TIMERSTART", 7, starttimer }, { "TIMERCLEAR", 7, cleartimer }, { "ONEVENT", 8, onevent }, /* 9 - Subroutine label, treated specially */ { "SETFLAG", 10, setflag }, { "CLEARFLAG", 10, clearflag }, { "DELAY", 11, send_delay }, { "EXIT", 12 }, }; static int process_returncode(struct adsi_soft_key *key, char *code, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int process_opcode(struct adsi_subscript *sub, char *code, char *args, struct adsi_script *state, char *script, int lineno) { 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; } static int adsi_process(struct adsi_script *state, char *buf, char *script, int lineno) { 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 : "", 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] = 128; /* 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] = 130; /* 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 : "", 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] = 129; 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; } static struct adsi_script *compile_script(char *script) { 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; } #ifdef DUMP_MESSAGES static void dump_message(char *type, char *vname, unsigned char *buf, int buflen) { int x; printf("%s %s: [ ", type, vname); for (x = 0; x < buflen; x++) printf("%02x ", buf[x]); printf("]\n"); } #endif static int adsi_prog(struct ast_channel *chan, char *script) { 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", chan->name); 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", chan->name); ast_free(scr); return -1; } ast_free(scr); ast_adsi_unload_session(chan); return 0; } static int adsi_exec(struct ast_channel *chan, void *data) { 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; } static int unload_module(void) { return ast_unregister_application(app); } static int load_module(void) { if (ast_register_application_xml(app, adsi_exec)) return AST_MODULE_LOAD_FAILURE; return AST_MODULE_LOAD_SUCCESS; } AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Asterisk ADSI Programming Application");