mirror of
https://github.com/asterisk/asterisk.git
synced 2025-10-25 22:18:07 +00:00
d185405755
(closes issue #13002) Reported by: caio1982 Patches: janitor_arraylen5.diff uploaded by caio1982 (license 22) git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@129045 65c4cc65-6c06-0410-ace0-fbb531ad65f3
1579 lines
46 KiB
C
1579 lines
46 KiB
C
/*
|
|
* Asterisk -- An open source telephony toolkit.
|
|
*
|
|
* Copyright (C) 1999 - 2005, Digium, Inc.
|
|
*
|
|
* Mark Spencer <markster@digium.com>
|
|
*
|
|
* 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 <markster@digium.com>
|
|
*
|
|
* \ingroup applications
|
|
*/
|
|
|
|
/*** MODULEINFO
|
|
<depend>res_adsi</depend>
|
|
***/
|
|
|
|
#include "asterisk.h"
|
|
|
|
ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
|
|
|
|
#include <netinet/in.h>
|
|
#include <ctype.h>
|
|
|
|
#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";
|
|
|
|
static char *synopsis = "Load Asterisk ADSI Scripts into phone";
|
|
|
|
/* #define DUMP_MESSAGES */
|
|
|
|
static char *descrip =
|
|
" ADSIProg(script): This application programs an ADSI Phone with the given\n"
|
|
"script. If nothing is specified, the default script (asterisk.adsi) is used.\n";
|
|
|
|
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, "%o", (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, "%x", (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, "%d", (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 <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];
|
|
}
|
|
|
|
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 : "<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;
|
|
}
|
|
|
|
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 subscript[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(subscript, tok, sizeof(subscript) - 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, subscript, 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 subscript[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) < 0)) {
|
|
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(subscript, tok, sizeof(subscript) - 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, subscript, 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 : "<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] = 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 : "<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] = 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)) {
|
|
fgets(buf, sizeof(buf), f);
|
|
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(app, adsi_exec, synopsis, descrip))
|
|
return AST_MODULE_LOAD_FAILURE;
|
|
return AST_MODULE_LOAD_SUCCESS;
|
|
}
|
|
|
|
AST_MODULE_INFO_STANDARD(ASTERISK_GPL_KEY, "Asterisk ADSI Programming Application");
|