diff options
Diffstat (limited to '1.4.23-rc4/res/res_adsi.c')
-rw-r--r-- | 1.4.23-rc4/res/res_adsi.c | 1132 |
1 files changed, 0 insertions, 1132 deletions
diff --git a/1.4.23-rc4/res/res_adsi.c b/1.4.23-rc4/res/res_adsi.c deleted file mode 100644 index 38648a8d4..000000000 --- a/1.4.23-rc4/res/res_adsi.c +++ /dev/null @@ -1,1132 +0,0 @@ -/* - * Asterisk -- An open source telephony toolkit. - * - * Copyright (C) 1999 - 2005, Digium, Inc. - * - * Mark Spencer <markster@digium.com> - * - * Includes code and algorithms from the Zapata library. - * - * 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 ADSI support - * - * \author Mark Spencer <markster@digium.com> - * - * \note this module is required by app_voicemail and app_getcpeid - * \todo Move app_getcpeid into this module - * \todo Create a core layer so that app_voicemail does not require - * res_adsi to load - */ - -#include "asterisk.h" - -ASTERISK_FILE_VERSION(__FILE__, "$Revision$") - -#include <time.h> -#include <string.h> -#include <stdio.h> -#include <stdlib.h> -#include <unistd.h> -#include <math.h> -#include <errno.h> - -#include "asterisk/ulaw.h" -#include "asterisk/alaw.h" -#include "asterisk/callerid.h" -#include "asterisk/logger.h" -#include "asterisk/fskmodem.h" -#include "asterisk/channel.h" -#include "asterisk/adsi.h" -#include "asterisk/module.h" -#include "asterisk/config.h" -#include "asterisk/file.h" - -#define DEFAULT_ADSI_MAX_RETRIES 3 - -#define ADSI_MAX_INTRO 20 -#define ADSI_MAX_SPEED_DIAL 6 - -#define ADSI_FLAG_DATAMODE (1 << 8) - -static int maxretries = DEFAULT_ADSI_MAX_RETRIES; - -/* Asterisk ADSI button definitions */ -#define ADSI_SPEED_DIAL 10 /* 10-15 are reserved for speed dial */ - -static char intro[ADSI_MAX_INTRO][20]; -static int aligns[ADSI_MAX_INTRO]; - -static char speeddial[ADSI_MAX_SPEED_DIAL][3][20]; - -static int alignment = 0; - -static int adsi_generate(unsigned char *buf, int msgtype, unsigned char *msg, int msglen, int msgnum, int last, int codec) -{ - int sum; - int x; - int bytes=0; - /* Initial carrier (imaginary) */ - float cr = 1.0; - float ci = 0.0; - float scont = 0.0; - - if (msglen > 255) - msglen = 255; - - /* If first message, Send 150ms of MARK's */ - if (msgnum == 1) { - for (x=0;x<150;x++) /* was 150 */ - PUT_CLID_MARKMS; - } - /* Put message type */ - PUT_CLID(msgtype); - sum = msgtype; - - /* Put message length (plus one for the message number) */ - PUT_CLID(msglen + 1); - sum += msglen + 1; - - /* Put message number */ - PUT_CLID(msgnum); - sum += msgnum; - - /* Put actual message */ - for (x=0;x<msglen;x++) { - PUT_CLID(msg[x]); - sum += msg[x]; - } - - /* Put 2's compliment of sum */ - PUT_CLID(256-(sum & 0xff)); - -#if 0 - if (last) { - /* Put trailing marks */ - for (x=0;x<50;x++) - PUT_CLID_MARKMS; - } -#endif - return bytes; - -} - -static int adsi_careful_send(struct ast_channel *chan, unsigned char *buf, int len, int *remainder) -{ - /* Sends carefully on a full duplex channel by using reading for - timing */ - struct ast_frame *inf, outf; - int amt; - - /* Zero out our outgoing frame */ - memset(&outf, 0, sizeof(outf)); - - if (remainder && *remainder) { - amt = len; - - /* Send remainder if provided */ - if (amt > *remainder) - amt = *remainder; - else - *remainder = *remainder - amt; - outf.frametype = AST_FRAME_VOICE; - outf.subclass = AST_FORMAT_ULAW; - outf.data = buf; - outf.datalen = amt; - outf.samples = amt; - if (ast_write(chan, &outf)) { - ast_log(LOG_WARNING, "Failed to carefully write frame\n"); - return -1; - } - /* Update pointers and lengths */ - buf += amt; - len -= amt; - } - - while(len) { - amt = len; - /* If we don't get anything at all back in a second, forget - about it */ - if (ast_waitfor(chan, 1000) < 1) - return -1; - inf = ast_read(chan); - /* Detect hangup */ - if (!inf) - return -1; - if (inf->frametype == AST_FRAME_VOICE) { - /* Read a voice frame */ - if (inf->subclass != AST_FORMAT_ULAW) { - ast_log(LOG_WARNING, "Channel not in ulaw?\n"); - ast_frfree(inf); - return -1; - } - /* Send no more than they sent us */ - if (amt > inf->datalen) - amt = inf->datalen; - else if (remainder) - *remainder = inf->datalen - amt; - outf.frametype = AST_FRAME_VOICE; - outf.subclass = AST_FORMAT_ULAW; - outf.data = buf; - outf.datalen = amt; - outf.samples = amt; - if (ast_write(chan, &outf)) { - ast_log(LOG_WARNING, "Failed to carefully write frame\n"); - ast_frfree(inf); - return -1; - } - /* Update pointers and lengths */ - buf += amt; - len -= amt; - } - ast_frfree(inf); - } - return 0; -} - -static int __adsi_transmit_messages(struct ast_channel *chan, unsigned char **msg, int *msglen, int *msgtype) -{ - /* msglen must be no more than 256 bits, each */ - unsigned char buf[24000 * 5]; - int pos = 0, res; - int x; - int start=0; - int retries = 0; - - char ack[3]; - - /* Wait up to 500 ms for initial ACK */ - int waittime; - struct ast_frame *f; - int rem = 0; - int def; - - if (chan->adsicpe == AST_ADSI_UNAVAILABLE) { - /* Don't bother if we know they don't support ADSI */ - errno = ENOSYS; - return -1; - } - - while(retries < maxretries) { - if (!(chan->adsicpe & ADSI_FLAG_DATAMODE)) { - /* Generate CAS (no SAS) */ - ast_gen_cas(buf, 0, 680, AST_FORMAT_ULAW); - - /* Send CAS */ - if (adsi_careful_send(chan, buf, 680, NULL)) { - ast_log(LOG_WARNING, "Unable to send CAS\n"); - } - /* Wait For DTMF result */ - waittime = 500; - for(;;) { - if (((res = ast_waitfor(chan, waittime)) < 1)) { - /* Didn't get back DTMF A in time */ - ast_log(LOG_DEBUG, "No ADSI CPE detected (%d)\n", res); - if (!chan->adsicpe) - chan->adsicpe = AST_ADSI_UNAVAILABLE; - errno = ENOSYS; - return -1; - } - waittime = res; - f = ast_read(chan); - if (!f) { - ast_log(LOG_DEBUG, "Hangup in ADSI\n"); - return -1; - } - if (f->frametype == AST_FRAME_DTMF) { - if (f->subclass == 'A') { - /* Okay, this is an ADSI CPE. Note this for future reference, too */ - if (!chan->adsicpe) - chan->adsicpe = AST_ADSI_AVAILABLE; - break; - } else { - if (f->subclass == 'D') { - ast_log(LOG_DEBUG, "Off-hook capable CPE only, not ADSI\n"); - } else - ast_log(LOG_WARNING, "Unknown ADSI response '%c'\n", f->subclass); - if (!chan->adsicpe) - chan->adsicpe = AST_ADSI_UNAVAILABLE; - errno = ENOSYS; - ast_frfree(f); - return -1; - } - } - ast_frfree(f); - } - - ast_log(LOG_DEBUG, "ADSI Compatible CPE Detected\n"); - } else - ast_log(LOG_DEBUG, "Already in data mode\n"); - - x = 0; - pos = 0; -#if 1 - def= ast_channel_defer_dtmf(chan); -#endif - while((x < 6) && msg[x]) { - res = adsi_generate(buf + pos, msgtype[x], msg[x], msglen[x], x+1 - start, (x == 5) || !msg[x+1], AST_FORMAT_ULAW); - if (res < 0) { - ast_log(LOG_WARNING, "Failed to generate ADSI message %d on channel %s\n", x + 1, chan->name); - return -1; - } - ast_log(LOG_DEBUG, "Message %d, of %d input bytes, %d output bytes\n", - x + 1, msglen[x], res); - pos += res; - x++; - } - - - rem = 0; - res = adsi_careful_send(chan, buf, pos, &rem); - if (!def) - ast_channel_undefer_dtmf(chan); - if (res) - return -1; - - ast_log(LOG_DEBUG, "Sent total spill of %d bytes\n", pos); - - memset(ack, 0, sizeof(ack)); - /* Get real result */ - res = ast_readstring(chan, ack, 2, 1000, 1000, ""); - /* Check for hangup */ - if (res < 0) - return -1; - if (ack[0] == 'D') { - ast_log(LOG_DEBUG, "Acked up to message %d\n", atoi(ack + 1)); - start += atoi(ack + 1); - if (start >= x) - break; - else { - retries++; - ast_log(LOG_DEBUG, "Retransmitting (%d), from %d\n", retries, start + 1); - } - } else { - retries++; - ast_log(LOG_WARNING, "Unexpected response to ack: %s (retry %d)\n", ack, retries); - } - } - if (retries >= maxretries) { - ast_log(LOG_WARNING, "Maximum ADSI Retries (%d) exceeded\n", maxretries); - errno = ETIMEDOUT; - return -1; - } - return 0; - -} - -int ast_adsi_begin_download(struct ast_channel *chan, char *service, unsigned char *fdn, unsigned char *sec, int version) -{ - int bytes; - unsigned char buf[256]; - char ack[2]; - bytes = 0; - /* Setup the resident soft key stuff, a piece at a time */ - /* Upload what scripts we can for voicemail ahead of time */ - bytes += ast_adsi_download_connect(buf + bytes, service, fdn, sec, version); - if (ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DOWNLOAD, 0)) - return -1; - if (ast_readstring(chan, ack, 1, 10000, 10000, "")) - return -1; - if (ack[0] == 'B') - return 0; - ast_log(LOG_DEBUG, "Download was denied by CPE\n"); - return -1; -} - -int ast_adsi_end_download(struct ast_channel *chan) -{ - int bytes; - unsigned char buf[256]; - bytes = 0; - /* Setup the resident soft key stuff, a piece at a time */ - /* Upload what scripts we can for voicemail ahead of time */ - bytes += ast_adsi_download_disconnect(buf + bytes); - if (ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DOWNLOAD, 0)) - return -1; - return 0; -} - -int ast_adsi_transmit_message_full(struct ast_channel *chan, unsigned char *msg, int msglen, int msgtype, int dowait) -{ - unsigned char *msgs[5] = { NULL, NULL, NULL, NULL, NULL }; - int msglens[5]; - int msgtypes[5]; - int newdatamode; - int res; - int x; - int writeformat, readformat; - int waitforswitch = 0; - - writeformat = chan->writeformat; - readformat = chan->readformat; - - newdatamode = chan->adsicpe & ADSI_FLAG_DATAMODE; - - for (x=0;x<msglen;x+=(msg[x+1]+2)) { - if (msg[x] == ADSI_SWITCH_TO_DATA) { - ast_log(LOG_DEBUG, "Switch to data is sent!\n"); - waitforswitch++; - newdatamode = ADSI_FLAG_DATAMODE; - } - - if (msg[x] == ADSI_SWITCH_TO_VOICE) { - ast_log(LOG_DEBUG, "Switch to voice is sent!\n"); - waitforswitch++; - newdatamode = 0; - } - } - msgs[0] = msg; - - msglens[0] = msglen; - msgtypes[0] = msgtype; - - if (msglen > 253) { - ast_log(LOG_WARNING, "Can't send ADSI message of %d bytes, too large\n", msglen); - return -1; - } - - ast_stopstream(chan); - - if (ast_set_write_format(chan, AST_FORMAT_ULAW)) { - ast_log(LOG_WARNING, "Unable to set write format to ULAW\n"); - return -1; - } - - if (ast_set_read_format(chan, AST_FORMAT_ULAW)) { - ast_log(LOG_WARNING, "Unable to set read format to ULAW\n"); - if (writeformat) { - if (ast_set_write_format(chan, writeformat)) - ast_log(LOG_WARNING, "Unable to restore write format to %d\n", writeformat); - } - return -1; - } - res = __adsi_transmit_messages(chan, msgs, msglens, msgtypes); - - if (dowait) { - ast_log(LOG_DEBUG, "Wait for switch is '%d'\n", waitforswitch); - while(waitforswitch-- && ((res = ast_waitfordigit(chan, 1000)) > 0)) { res = 0; ast_log(LOG_DEBUG, "Waiting for 'B'...\n"); } - } - - if (!res) - chan->adsicpe = (chan->adsicpe & ~ADSI_FLAG_DATAMODE) | newdatamode; - - if (writeformat) - ast_set_write_format(chan, writeformat); - if (readformat) - ast_set_read_format(chan, readformat); - - if (!res) - res = ast_safe_sleep(chan, 100 ); - return res; -} - -int ast_adsi_transmit_message(struct ast_channel *chan, unsigned char *msg, int msglen, int msgtype) -{ - return ast_adsi_transmit_message_full(chan, msg, msglen, msgtype, 1); -} - -static inline int ccopy(unsigned char *dst, const unsigned char *src, int max) -{ - int x=0; - /* Carefully copy the requested data */ - while ((x < max) && src[x] && (src[x] != 0xff)) { - dst[x] = src[x]; - x++; - } - return x; -} - -int ast_adsi_load_soft_key(unsigned char *buf, int key, const char *llabel, const char *slabel, const char *ret, int data) -{ - int bytes=0; - - /* Abort if invalid key specified */ - if ((key < 2) || (key > 33)) - return -1; - buf[bytes++] = ADSI_LOAD_SOFTKEY; - /* Reserve for length */ - bytes++; - /* Which key */ - buf[bytes++] = key; - - /* Carefully copy long label */ - bytes += ccopy(buf + bytes, (const unsigned char *)llabel, 18); - - /* Place delimiter */ - buf[bytes++] = 0xff; - - /* Short label */ - bytes += ccopy(buf + bytes, (const unsigned char *)slabel, 7); - - - /* If specified, copy return string */ - if (ret) { - /* Place delimiter */ - buf[bytes++] = 0xff; - if (data) - buf[bytes++] = ADSI_SWITCH_TO_DATA2; - /* Carefully copy return string */ - bytes += ccopy(buf + bytes, (const unsigned char *)ret, 20); - - } - /* Replace parameter length */ - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_connect_session(unsigned char *buf, unsigned char *fdn, int ver) -{ - int bytes=0; - int x; - - /* Message type */ - buf[bytes++] = ADSI_CONNECT_SESSION; - - /* Reserve space for length */ - bytes++; - - if (fdn) { - for (x=0;x<4;x++) - buf[bytes++] = fdn[x]; - if (ver > -1) - buf[bytes++] = ver & 0xff; - } - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_download_connect(unsigned char *buf, char *service, unsigned char *fdn, unsigned char *sec, int ver) -{ - int bytes=0; - int x; - - /* Message type */ - buf[bytes++] = ADSI_DOWNLOAD_CONNECT; - - /* Reserve space for length */ - bytes++; - - /* Primary column */ - bytes+= ccopy(buf + bytes, (unsigned char *)service, 18); - - /* Delimiter */ - buf[bytes++] = 0xff; - - for (x=0;x<4;x++) { - buf[bytes++] = fdn[x]; - } - for (x=0;x<4;x++) - buf[bytes++] = sec[x]; - buf[bytes++] = ver & 0xff; - - buf[1] = bytes - 2; - - return bytes; - -} - -int ast_adsi_disconnect_session(unsigned char *buf) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_DISC_SESSION; - - /* Reserve space for length */ - bytes++; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_query_cpeid(unsigned char *buf) -{ - int bytes = 0; - buf[bytes++] = ADSI_QUERY_CPEID; - /* Reserve space for length */ - bytes++; - buf[1] = bytes - 2; - return bytes; -} - -int ast_adsi_query_cpeinfo(unsigned char *buf) -{ - int bytes = 0; - buf[bytes++] = ADSI_QUERY_CONFIG; - /* Reserve space for length */ - bytes++; - buf[1] = bytes - 2; - return bytes; -} - -int ast_adsi_read_encoded_dtmf(struct ast_channel *chan, unsigned char *buf, int maxlen) -{ - int bytes = 0; - int res; - unsigned char current = 0; - int gotstar = 0; - int pos = 0; - memset(buf, 0, sizeof(buf)); - while(bytes <= maxlen) { - /* Wait up to a second for a digit */ - res = ast_waitfordigit(chan, 1000); - if (!res) - break; - if (res == '*') { - gotstar = 1; - continue; - } - /* Ignore anything other than a digit */ - if ((res < '0') || (res > '9')) - continue; - res -= '0'; - if (gotstar) - res += 9; - if (pos) { - pos = 0; - buf[bytes++] = (res << 4) | current; - } else { - pos = 1; - current = res; - } - gotstar = 0; - } - return bytes; -} - -int ast_adsi_get_cpeid(struct ast_channel *chan, unsigned char *cpeid, int voice) -{ - unsigned char buf[256]; - int bytes = 0; - int res; - bytes += ast_adsi_data_mode(buf); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - - bytes = 0; - bytes += ast_adsi_query_cpeid(buf); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - - /* Get response */ - memset(buf, 0, sizeof(buf)); - res = ast_adsi_read_encoded_dtmf(chan, cpeid, 4); - if (res != 4) { - ast_log(LOG_WARNING, "Got %d bytes back of encoded DTMF, expecting 4\n", res); - res = 0; - } else { - res = 1; - } - - if (voice) { - bytes = 0; - bytes += ast_adsi_voice_mode(buf, 0); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - /* Ignore the resulting DTMF B announcing it's in voice mode */ - ast_waitfordigit(chan, 1000); - } - return res; -} - -int ast_adsi_get_cpeinfo(struct ast_channel *chan, int *width, int *height, int *buttons, int voice) -{ - unsigned char buf[256]; - int bytes = 0; - int res; - bytes += ast_adsi_data_mode(buf); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - - bytes = 0; - bytes += ast_adsi_query_cpeinfo(buf); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - - /* Get width */ - memset(buf, 0, sizeof(buf)); - res = ast_readstring(chan, (char *)buf, 2, 1000, 500, ""); - if (res < 0) - return res; - if (strlen((char *)buf) != 2) { - ast_log(LOG_WARNING, "Got %d bytes of width, expecting 2\n", res); - res = 0; - } else { - res = 1; - } - if (width) - *width = atoi((char *)buf); - /* Get height */ - memset(buf, 0, sizeof(buf)); - if (res) { - res = ast_readstring(chan, (char *)buf, 2, 1000, 500, ""); - if (res < 0) - return res; - if (strlen((char *)buf) != 2) { - ast_log(LOG_WARNING, "Got %d bytes of height, expecting 2\n", res); - res = 0; - } else { - res = 1; - } - if (height) - *height= atoi((char *)buf); - } - /* Get buttons */ - memset(buf, 0, sizeof(buf)); - if (res) { - res = ast_readstring(chan, (char *)buf, 1, 1000, 500, ""); - if (res < 0) - return res; - if (strlen((char *)buf) != 1) { - ast_log(LOG_WARNING, "Got %d bytes of buttons, expecting 1\n", res); - res = 0; - } else { - res = 1; - } - if (buttons) - *buttons = atoi((char *)buf); - } - if (voice) { - bytes = 0; - bytes += ast_adsi_voice_mode(buf, 0); - ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - /* Ignore the resulting DTMF B announcing it's in voice mode */ - ast_waitfordigit(chan, 1000); - } - return res; -} - -int ast_adsi_data_mode(unsigned char *buf) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_SWITCH_TO_DATA; - - /* Reserve space for length */ - bytes++; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_clear_soft_keys(unsigned char *buf) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_CLEAR_SOFTKEY; - - /* Reserve space for length */ - bytes++; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_clear_screen(unsigned char *buf) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_CLEAR_SCREEN; - - /* Reserve space for length */ - bytes++; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_voice_mode(unsigned char *buf, int when) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_SWITCH_TO_VOICE; - - /* Reserve space for length */ - bytes++; - - buf[bytes++] = when & 0x7f; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_available(struct ast_channel *chan) -{ - int cpe = chan->adsicpe & 0xff; - if ((cpe == AST_ADSI_AVAILABLE) || - (cpe == AST_ADSI_UNKNOWN)) - return 1; - return 0; -} - -int ast_adsi_download_disconnect(unsigned char *buf) -{ - int bytes=0; - - /* Message type */ - buf[bytes++] = ADSI_DOWNLOAD_DISC; - - /* Reserve space for length */ - bytes++; - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_display(unsigned char *buf, int page, int line, int just, int wrap, - char *col1, char *col2) -{ - int bytes=0; - - /* Sanity check line number */ - - if (page) { - if (line > 4) return -1; - } else { - if (line > 33) return -1; - } - - if (line < 1) - return -1; - /* Parameter type */ - buf[bytes++] = ADSI_LOAD_VIRTUAL_DISP; - - /* Reserve space for size */ - bytes++; - - /* Page and wrap indicator */ - buf[bytes++] = ((page & 0x1) << 7) | ((wrap & 0x1) << 6) | (line & 0x3f); - - /* Justification */ - buf[bytes++] = (just & 0x3) << 5; - - /* Omit highlight mode definition */ - buf[bytes++] = 0xff; - - /* Primary column */ - bytes+= ccopy(buf + bytes, (unsigned char *)col1, 20); - - /* Delimiter */ - buf[bytes++] = 0xff; - - /* Secondary column */ - bytes += ccopy(buf + bytes, (unsigned char *)col2, 20); - - /* Update length */ - buf[1] = bytes - 2; - - return bytes; - -} - -int ast_adsi_input_control(unsigned char *buf, int page, int line, int display, int format, int just) -{ - int bytes=0; - - if (page) { - if (line > 4) return -1; - } else { - if (line > 33) return -1; - } - - if (line < 1) - return -1; - - buf[bytes++] = ADSI_INPUT_CONTROL; - bytes++; - buf[bytes++] = ((page & 1) << 7) | (line & 0x3f); - buf[bytes++] = ((display & 1) << 7) | ((just & 0x3) << 4) | (format & 0x7); - - buf[1] = bytes - 2; - return bytes; - -} - -int ast_adsi_input_format(unsigned char *buf, int num, int dir, int wrap, char *format1, char *format2) -{ - int bytes = 0; - - if (!strlen((char *)format1)) - return -1; - - buf[bytes++] = ADSI_INPUT_FORMAT; - bytes++; - buf[bytes++] = ((dir & 1) << 7) | ((wrap & 1) << 6) | (num & 0x7); - bytes += ccopy(buf + bytes, (unsigned char *)format1, 20); - buf[bytes++] = 0xff; - if (format2 && strlen((char *)format2)) { - bytes += ccopy(buf + bytes, (unsigned char *)format2, 20); - } - buf[1] = bytes - 2; - return bytes; -} - -int ast_adsi_set_keys(unsigned char *buf, unsigned char *keys) -{ - int bytes=0; - int x; - /* Message type */ - buf[bytes++] = ADSI_INIT_SOFTKEY_LINE; - /* Space for size */ - bytes++; - /* Key definitions */ - for (x=0;x<6;x++) - buf[bytes++] = (keys[x] & 0x3f) ? keys[x] : (keys[x] | 0x1); - buf[1] = bytes - 2; - return bytes; -} - -int ast_adsi_set_line(unsigned char *buf, int page, int line) -{ - int bytes=0; - - /* Sanity check line number */ - - if (page) { - if (line > 4) return -1; - } else { - if (line > 33) return -1; - } - - if (line < 1) - return -1; - /* Parameter type */ - buf[bytes++] = ADSI_LINE_CONTROL; - - /* Reserve space for size */ - bytes++; - - /* Page and line */ - buf[bytes++] = ((page & 0x1) << 7) | (line & 0x3f); - - buf[1] = bytes - 2; - return bytes; - -}; - -static int total = 0; -static int speeds = 0; - -int ast_adsi_channel_restore(struct ast_channel *chan) -{ - unsigned char dsp[256]; - int bytes; - int x; - unsigned char keyd[6]; - - memset(dsp, 0, sizeof(dsp)); - - /* Start with initial display setup */ - bytes = 0; - bytes += ast_adsi_set_line(dsp + bytes, ADSI_INFO_PAGE, 1); - - /* Prepare key setup messages */ - - if (speeds) { - memset(keyd, 0, sizeof(keyd)); - for (x=0;x<speeds;x++) { - keyd[x] = ADSI_SPEED_DIAL + x; - } - bytes += ast_adsi_set_keys(dsp + bytes, keyd); - } - ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0); - return 0; - -} - -int ast_adsi_print(struct ast_channel *chan, char **lines, int *aligns, int voice) -{ - unsigned char buf[4096]; - int bytes=0; - int res; - int x; - for(x=0;lines[x];x++) - bytes += ast_adsi_display(buf + bytes, ADSI_INFO_PAGE, x+1, aligns[x], 0, lines[x], ""); - bytes += ast_adsi_set_line(buf + bytes, ADSI_INFO_PAGE, 1); - if (voice) { - bytes += ast_adsi_voice_mode(buf + bytes, 0); - } - res = ast_adsi_transmit_message_full(chan, buf, bytes, ADSI_MSG_DISPLAY, 0); - if (voice) { - /* Ignore the resulting DTMF B announcing it's in voice mode */ - ast_waitfordigit(chan, 1000); - } - return res; -} - -int ast_adsi_load_session(struct ast_channel *chan, unsigned char *app, int ver, int data) -{ - unsigned char dsp[256]; - int bytes; - int res; - char resp[2]; - - memset(dsp, 0, sizeof(dsp)); - - /* Connect to session */ - bytes = 0; - bytes += ast_adsi_connect_session(dsp + bytes, app, ver); - - if (data) - bytes += ast_adsi_data_mode(dsp + bytes); - - /* Prepare key setup messages */ - if (ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0)) - return -1; - if (app) { - res = ast_readstring(chan, resp, 1, 1200, 1200, ""); - if (res < 0) - return -1; - if (res) { - ast_log(LOG_DEBUG, "No response from CPE about version. Assuming not there.\n"); - return 0; - } - if (!strcmp(resp, "B")) { - ast_log(LOG_DEBUG, "CPE has script '%s' version %d already loaded\n", app, ver); - return 1; - } else if (!strcmp(resp, "A")) { - ast_log(LOG_DEBUG, "CPE hasn't script '%s' version %d already loaded\n", app, ver); - } else { - ast_log(LOG_WARNING, "Unexpected CPE response to script query: %s\n", resp); - } - } else - return 1; - return 0; - -} - -int ast_adsi_unload_session(struct ast_channel *chan) -{ - unsigned char dsp[256]; - int bytes; - - memset(dsp, 0, sizeof(dsp)); - - /* Connect to session */ - bytes = 0; - bytes += ast_adsi_disconnect_session(dsp + bytes); - bytes += ast_adsi_voice_mode(dsp + bytes, 0); - - /* Prepare key setup messages */ - if (ast_adsi_transmit_message_full(chan, dsp, bytes, ADSI_MSG_DISPLAY, 0)) - return -1; - return 0; -} - -static int str2align(char *s) -{ - if (!strncasecmp(s, "l", 1)) - return ADSI_JUST_LEFT; - else if (!strncasecmp(s, "r", 1)) - return ADSI_JUST_RIGHT; - else if (!strncasecmp(s, "i", 1)) - return ADSI_JUST_IND; - else - return ADSI_JUST_CENT; -} - -static void init_state(void) -{ - int x; - - for (x=0;x<ADSI_MAX_INTRO;x++) - aligns[x] = ADSI_JUST_CENT; - ast_copy_string(intro[0], "Welcome to the", sizeof(intro[0])); - ast_copy_string(intro[1], "Asterisk", sizeof(intro[1])); - ast_copy_string(intro[2], "Open Source PBX", sizeof(intro[2])); - total = 3; - speeds = 0; - for (x=3;x<ADSI_MAX_INTRO;x++) - intro[x][0] = '\0'; - memset(speeddial, 0, sizeof(speeddial)); - alignment = ADSI_JUST_CENT; -} - -static void adsi_load(void) -{ - int x; - struct ast_config *conf; - struct ast_variable *v; - char *name, *sname; - init_state(); - conf = ast_config_load("adsi.conf"); - if (conf) { - x=0; - for (v = ast_variable_browse(conf, "intro"); v; v = v->next) { - if (!strcasecmp(v->name, "alignment")) - alignment = str2align(v->value); - else if (!strcasecmp(v->name, "greeting")) { - if (x < ADSI_MAX_INTRO) { - aligns[x] = alignment; - ast_copy_string(intro[x], v->value, sizeof(intro[x])); - x++; - } - } else if (!strcasecmp(v->name, "maxretries")) { - if (atoi(v->value) > 0) - maxretries = atoi(v->value); - } - } - if (x) - total = x; - x = 0; - for (v = ast_variable_browse(conf, "speeddial"); v; v = v->next) { - char *stringp = v->value; - name = strsep(&stringp, ","); - sname = strsep(&stringp, ","); - if (!sname) - sname = name; - if (x < ADSI_MAX_SPEED_DIAL) { - ast_copy_string(speeddial[x][0], v->name, sizeof(speeddial[x][0])); - ast_copy_string(speeddial[x][1], name, 18); - ast_copy_string(speeddial[x][2], sname, 7); - x++; - } - } - if (x) - speeds = x; - ast_config_destroy(conf); - } -} - -static int reload(void) -{ - adsi_load(); - return 0; -} - -static int load_module(void) -{ - adsi_load(); - return 0; -} - -static int unload_module(void) -{ - /* Can't unload this once we're loaded */ - return -1; -} - -AST_MODULE_INFO(ASTERISK_GPL_KEY, AST_MODFLAG_GLOBAL_SYMBOLS, "ADSI Resource", - .load = load_module, - .unload = unload_module, - .reload = reload, - ); |