Author: brian
Date: Mon Dec 15 13:16:34 2008
New Revision: 10776
Log:
FSSCRIPTS-8 Thanks John
Added:
freeswitch/trunk/scripts/s25vmail/
freeswitch/trunk/scripts/s25vmail/README
freeswitch/trunk/scripts/s25vmail/s25vmail.js
freeswitch/trunk/scripts/s25vmail/s25vmail_mwi.c
Added: freeswitch/trunk/scripts/s25vmail/README
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/s25vmail/README Mon Dec 15 13:16:34 2008
@@ -0,0 +1,42 @@
+This directory contains software used for interfacing the
+FreeSWITCH voicemail application with the AT&T (aka Lucent
+aka Avaya) System 25 PBX. It's possible that System 75
+and Definity PBXs may also work.
+
+s25vmail.js goes into the FreeSWITCH scripts directory.
+s25vmail_mwi.c should be compiled and the resulting binary
+put into the FreeSWITCH bin directory. Modify the FreeSWITCH
+rc.d script to also start / stop s25vmail_mwi.
+
+Configuration fragments look something like:
+
+ conf/openzap.conf:
+
+ [span zt]
+ ; A204DX
+ name => OpenZAP
+ dtmf_hangup = ##99
+
+ number => 551
+ fxo-channel => 49
+
+ number => 552
+ fxo-channel => 50
+
+ number => 553
+ fxo-channel => 51
+
+ number => 554
+ fxo-channel => 52
+
+ conf/dialplan/default.xml
+
+ <extension name="system25_vmail">
+ <condition field="destination_number" expression="^(55[1-4])$">
+ <action application="javascript" data="s25vmail.js"/>
+ </condition>
+ </extension>
+
+Tested using FreeSWITCH SVN 10428 running on FreeBSD 6.3
+with a Sangoma A200DX Analog Series w/ Echo Cancellation
+ports card containing 2 FXO modules.
Added: freeswitch/trunk/scripts/s25vmail/s25vmail.js
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/s25vmail/s25vmail.js Mon Dec 15 13:16:34 2008
@@ -0,0 +1,193 @@
+/*
+ * File: s25vmail.js
+ * Purpose: Invoke voicemail based on AT&T System 25 PBX voicemail mode codes
+ * Machine: OS:
+ * Author: John Wehle Date: June 24, 2008
+ *
+ * Copyright (c) 2008 Feith Systems and Software, Inc.
+ * All Rights Reserved
+ *
+ * The message waiting indicator is handled by a separate program.
+ */
+
+
+var id_digits_required = 3;
+
+var digitTimeOut = 3000;
+var interDigitTimeOut = 1000;
+var absoluteTimeOut = 10000;
+
+
+var dtmf_digits = "";
+
+function on_dtmf (session, type, obj, arg)
+ {
+
+ if (type == "dtmf") {
+ dtmf_digits += obj.digit;
+ }
+
+ return true;
+ }
+
+
+function prompt_for_id ()
+ {
+ var id;
+ var index;
+ var repeat;
+
+ dtmf_digits = "";
+ id = "";
+ repeat = 0;
+
+ while (session.ready () && repeat < 3) {
+ session.flushDigits ();
+
+ /* play phrase - if digit keyed while playing callback will catch them*/
+ session.sayPhrase ("voicemail_enter_id", "#", "", on_dtmf, "");
+
+ if (! session.ready ())
+ return "";
+
+ id = dtmf_digits;
+
+ if (id.indexOf ('#') == -1) {
+ dtmf_digits = session.getDigits (5, '#', digitTimeOut,
+ interDigitTimeOut, absoluteTimeOut);
+ id += dtmf_digits;
+ id += '#';
+ }
+
+ /* a valid id must meet the minimum length requirements */
+ if ((index = id.indexOf ('#')) >= id_digits_required) {
+ id = id.substring (0,index);
+ break;
+ }
+
+ dtmf_digits = "";
+ id = "";
+ repeat++;
+ }
+
+ return id;
+ }
+
+
+var start = "";
+var mode = "";
+var from = "";
+var to = "";
+
+var domain = session.getVariable ("domain");
+
+session.answer ();
+
+start = session.getDigits (1, '', digitTimeOut,
+ interDigitTimeOut, absoluteTimeOut);
+
+if (start != "#") {
+ console_log ("err", "Invalid VMAIL start code from PBX\n");
+ exit();
+ }
+
+mode = session.getDigits (5, '#', digitTimeOut,
+ interDigitTimeOut, absoluteTimeOut);
+
+from = session.getDigits (5, '#', digitTimeOut,
+ interDigitTimeOut, absoluteTimeOut);
+
+to = session.getDigits (5, '#', digitTimeOut,
+ interDigitTimeOut, absoluteTimeOut);
+
+session.execute("sleep", "1000");
+
+// Verify that the proper parameters are present
+switch (mode) {
+
+ // Direct Inside Access
+ case "00":
+ if (isNaN (parseInt (from, 10))) {
+ console_log ("err", "Invalid VMAIL calling PDC from PBX\n");
+ break;
+ }
+
+ session.setVariable ("voicemail_authorized", "false");
+ session.execute ("voicemail", "check default " + domain + " " + from);
+ break;
+
+ // Direct Dial Access
+ case "01":
+ from = prompt_for_id ();
+
+ if (! session.ready ()) {
+ session.hangup();
+ exit();
+ }
+
+ if (isNaN (parseInt (from, 10))) {
+ console_log ("err", "Invalid VMAIL mailbox from caller\n");
+ break;
+ }
+
+ session.setVariable ("voicemail_authorized", "false");
+ session.execute ("voicemail", "check default " + domain + " " + from);
+ break;
+
+ // Coverage - caller is inside
+ case "02":
+ if (isNaN (parseInt (from, 10)) || isNaN (parseInt (to, 10))) {
+ console_log ("err", "Invalid VMAIL calling or called PDC from PBX\n");
+ break;
+ }
+
+ session.setVariable ("effective_caller_id_name", "inside caller");
+ session.setVariable ("effective_caller_id_number", from);
+
+ session.execute ("voicemail", "default " + domain + " " + to);
+ break;
+
+ // Coverage - caller is dial
+ case "03":
+ if (isNaN (parseInt (to, 10))) {
+ console_log ("err", "Invalid VMAIL called PDC from PBX\n");
+ break;
+ }
+
+ session.setVariable ("effective_caller_id_name", "outside caller");
+ session.setVariable ("effective_caller_id_number", "Unknown");
+
+ session.execute ("voicemail", "default " + domain + " " + to);
+ break;
+
+ // Coverage - not yet defined
+ case "04":
+ break;
+
+ // Leave Word Calling
+ case "05":
+ if (isNaN (parseInt (from, 10)) || isNaN (parseInt (to, 10))) {
+ console_log ("err", "Invalid VMAIL calling or called PDC from PBX\n");
+ break;
+ }
+ break;
+
+ // Refresh MW lamps
+ case "06":
+ break;
+
+ // Voice Port failed to answer
+ case "08":
+ if (isNaN (parseInt (to, 10))) {
+ console_log ("err", "Invalid VMAIL PDC from PBX\n");
+ break;
+ }
+ break;
+
+ // Unknown
+ default:
+ console_log ("err", "Invalid VMAIL mode code from PBX\n");
+ break;
+ }
+
+exit();
Added: freeswitch/trunk/scripts/s25vmail/s25vmail_mwi.c
==============================================================================
--- (empty file)
+++ freeswitch/trunk/scripts/s25vmail/s25vmail_mwi.c Mon Dec 15 13:16:34 2008
@@ -0,0 +1,953 @@
+/*
+ * File: s25vmail_mwi.c
+ * Purpose: Send AT&T System 25 PBX MWI DTMF based on MWI events
+ * Machine: OS:
+ * Author: John Wehle Date: July 24, 2008
+ *
+ * Copyright (c) 2008 Feith Systems and Software, Inc.
+ * All Rights Reserved
+ *
+ * Tested using a Zyxel U90e configured using:
+ *
+ * at OK at&f OK at&d3&y2q2 OK ats0=0s2=255s15.7=0s18=4s35.1=0 OK
+ * ats38.3=1s42.3=1s42.6=1 OK atl0 OK at&w OK at&v
+ *
+ * though just about any modem should work. Preferred settings are
+ *
+ * DTR OFF causes hangup and reset from profile 0
+ * RTS / CTS flow control
+ * allow abort during modem handshake
+ * auto answer off
+ * ring message off
+ */
+
+
+#include <ctype.h>
+#include <errno.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <memory.h>
+#include <stdarg.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <signal.h>
+#include <termios.h>
+
+#include <netdb.h>
+#include <netinet/in.h>
+#include <arpa/inet.h>
+#include <sys/socket.h>
+#include <sys/param.h>
+#include <unistd.h>
+
+
+#define LOGFILE "/var/log/s25vmail_mwi.log"
+
+
+static const char *MyName = "s25vmail_mwi";
+
+static int daimon = 0;
+static int error_msg_throttle = 0;
+static volatile int shutdown_server = 0;
+
+
+static void
+debugmsg (const char *fmt, ...)
+ {
+ char message[256];
+ va_list args;
+
+ if (daimon)
+ return;
+
+ va_start (args, fmt);
+ vsprintf (message, fmt, args);
+ va_end (args);
+
+ fprintf (stderr, "%s: %s", MyName, message);
+ if ( !strchr (message, '\n'))
+ fprintf (stderr, "\n");
+ fflush (stderr);
+ }
+
+
+static void
+errmsg (const char *fmt, ...)
+ {
+ char time_stamp[256];
+ struct tm *tmp;
+ time_t now;
+ va_list args;
+
+ if (! daimon) {
+ fprintf (stderr, "%s: ", MyName);
+
+ va_start (args, fmt);
+ vfprintf (stderr, fmt, args);
+ va_end (args);
+
+ if (! strchr (fmt, '\n'))
+ fputc ('\n', stderr);
+
+ fflush (stderr);
+ return;
+ }
+
+ if (error_msg_throttle)
+ return;
+
+ time (&now);
+
+ if ( !(tmp = localtime (&now)) ) {
+ fprintf (stderr, "%s: errmsg -- localtime failed.\n", MyName);
+ perror (MyName);
+ fflush (stderr);
+ return;
+ }
+
+ strftime (time_stamp, sizeof (time_stamp), "%b %d %H:%M:%S", tmp);
+ fprintf (stderr, "%s %s[%d]: ", time_stamp, MyName, (int)getpid ());
+
+ va_start (args, fmt);
+ vfprintf (stderr, fmt, args);
+ va_end (args);
+
+ if (! strchr (fmt, '\n'))
+ fputc ('\n', stderr);
+
+ fflush (stderr);
+ }
+
+
+static void
+catch_signal ()
+ {
+
+ shutdown_server = 1;
+ }
+
+
+static void
+daemonize()
+ {
+
+#ifdef SIGTSTP
+ (void)signal(SIGTSTP, SIG_IGN);
+#endif
+#ifdef SIGTTIN
+ (void)signal(SIGTTIN, SIG_IGN);
+#endif
+#ifdef SIGTTOU
+ (void)signal(SIGTTOU, SIG_IGN);
+#endif
+
+ switch (fork ()) {
+ case 0:
+ break;
+
+ case -1:
+ fprintf (stderr, "%s: daemonize -- fork failed.", MyName);
+ perror (MyName);
+ exit (1);
+ /* NOTREACHED */
+ break;
+
+ default:
+ exit (0);
+ /* NOTREACHED */
+ break;
+ }
+
+ setsid();
+
+ close (0);
+ close (1);
+ close (2);
+
+ (void)open ("/dev/null", O_RDWR);
+ (void)open ("/dev/null", O_RDWR);
+ (void)open (LOGFILE, O_WRONLY | O_APPEND | O_CREAT, 0644);
+
+ daimon = 1;
+ }
+
+
+static void
+install_signal_handlers ()
+ {
+ struct sigaction act;
+
+ memset (&act, '\0', sizeof (act));
+
+ act.sa_handler = catch_signal;
+ sigemptyset (&act.sa_mask);
+ act.sa_flags = 0;
+
+ if (signal (SIGHUP, SIG_IGN) != SIG_IGN)
+ sigaction (SIGHUP, &act, NULL);
+ if (signal (SIGINT, SIG_IGN) != SIG_IGN)
+ sigaction (SIGINT, &act, NULL);
+ (void)sigaction (SIGTERM, &act, NULL);
+ }
+
+
+static int
+connect_to_service (const char *hostname, const char *port)
+ {
+ int sock;
+ struct hostent *hp;
+ struct in_addr address;
+ struct servent *servp;
+ struct sockaddr_in sin;
+
+ if ((sock = socket (AF_INET, SOCK_STREAM, IPPROTO_TCP)) == -1) {
+ char *errstr = strerror (errno);
+
+ errmsg ("socket failed\n");
+ errmsg (errstr);
+ return -1;
+ }
+
+ memset (&sin, 0, sizeof (sin));
+
+ if (isalpha (hostname[0])) {
+ if ( !(hp = gethostbyname (hostname))) {
+ char *errstr = strerror (errno);
+
+ errmsg ("gethostbyname failed\n");
+ errmsg (errstr);
+ close (sock);
+ return -1;
+ }
+ if (hp->h_addrtype != AF_INET) {
+ errmsg ("gethostbyname returned unsupported family\n");
+ close (sock);
+ return -1;
+ }
+ memcpy (&sin.sin_addr, hp->h_addr, sizeof(sin.sin_addr));
+ }
+ else {
+ address.s_addr = inet_addr (hostname);
+
+ if ((long)address.s_addr == -1) {
+ char *errstr = strerror (errno);
+
+ errmsg ("inet_addr failed\n");
+ errmsg (errstr);
+ close (sock);
+ return -1;
+ }
+ sin.sin_addr.s_addr = address.s_addr;
+ }
+
+ if (isalpha (*port)) {
+ if ( !(servp = getservbyname(port, "tcp"))) {
+ char *errstr = strerror (errno);
+
+ errmsg ("getservbyname failed\n");
+ errmsg (errstr);
+ close (sock);
+ return -1;
+ }
+ sin.sin_port = servp->s_port;
+ }
+ else
+ sin.sin_port = htons ((unsigned short)atoi (port));
+
+ sin.sin_family = AF_INET;
+
+ if (connect (sock, (struct sockaddr *)&sin, sizeof(sin)) == -1) {
+ char *errstr = strerror (errno);
+
+ errmsg ("connect failed\n");
+ errmsg (errstr);
+ close (sock);
+ return -1;
+ }
+
+ debugmsg ("Connected to service\n");
+
+ return sock;
+ }
+
+
+static ssize_t
+read_line (int fd, char *buf, size_t buf_len)
+ {
+ size_t l;
+ ssize_t nbytes_read;
+
+ l = 0;
+
+ for ( ; ; ) {
+ nbytes_read = read (fd, &buf[l], 1);
+
+ if (nbytes_read < 0) {
+ char *errstr = strerror (errno);
+
+ errmsg ("read failed in middle of line\n");
+ errmsg (errstr);
+ return -1;
+ }
+
+ if (nbytes_read == 0) {
+ if (l)
+ errmsg ("EOF in middle of line\n");
+ return l ? -1 : 0;
+ }
+
+ if (buf[l] == '\n') {
+ while (l && buf[l - 1] == '\r')
+ l--;
+ buf[l++] = '\0';
+ break;
+ }
+
+ l++;
+
+ if (l == buf_len) {
+ errmsg ("line too long\n");
+ return -1;
+ }
+ }
+
+ return l;
+ }
+
+
+static int
+read_trailing_newline(int fd)
+ {
+ char c;
+ ssize_t nbytes_read;
+
+ nbytes_read = read (fd, &c, 1);
+
+ if (nbytes_read < 0) {
+ char *errstr = strerror (errno);
+
+ errmsg ("read failed in trailing newline\n");
+ errmsg (errstr);
+ return -1;
+ }
+
+ if (nbytes_read == 0) {
+ errmsg ("EOF in trailing newline\n");
+ return -1;
+ }
+
+ if (c != '\n') {
+ errmsg ("missing trailing newline\n");
+ return -1;
+ }
+
+ return 0;
+ }
+
+
+static char *
+retrieve_message (int fd)
+ {
+ char cl_buf[64];
+ char ct_buf[64];
+ char *h;
+ char *m;
+ ssize_t cl;
+ ssize_t nbytes_read;
+ size_t l;
+ size_t nbytes_to_read;
+
+ if (shutdown_server)
+ return NULL;
+
+ /*
+ * Read / parse Content-Length and Content-Type.
+ */
+
+ nbytes_read = read_line (fd, cl_buf, sizeof (cl_buf));
+
+ if (nbytes_read < 0) {
+ errmsg ("read_line failed\n");
+ return NULL;
+ }
+
+ if (nbytes_read == 0) {
+
+ /*
+ * EOF
+ */
+
+ return NULL;
+ }
+
+ nbytes_read = read_line (fd, ct_buf, sizeof (ct_buf));
+
+ if (nbytes_read < 0) {
+ errmsg ("read_line failed\n");
+ return NULL;
+ }
+
+ if (nbytes_read == 0) {
+ errmsg ("EOF in middle of headers\n");
+ return NULL;
+ }
+
+ h = "Content-Length: ";
+ l = strlen (h);
+
+ if (strncmp (cl_buf, h, l) != 0) {
+
+ /*
+ * If the message header doesn't being with Content-Length,
+ * then it needs to be a Content-Type we understand.
+ */
+
+ h = "Content-Type: ";
+ l = strlen (h);
+
+ if (strncmp (cl_buf, h, l) != 0) {
+ errmsg ("missing Content-Type\n");
+ return NULL;
+ }
+
+ if (strcmp (&cl_buf[l], "auth/request") != 0
+ && strcmp (&cl_buf[l], "command/reply") != 0) {
+ errmsg ("Unsupported Content-Type\n");
+ return NULL;
+ }
+
+ if (ct_buf[0])
+ if (read_trailing_newline (fd) < 0) {
+ return NULL;
+ }
+
+ m = malloc (strlen (cl_buf) + 1 + strlen (ct_buf) + 1 + 1);
+
+ if (! m) {
+ char *errstr = strerror (errno);
+
+ errmsg ("malloc failed\n");
+ errmsg (errstr);
+ return NULL;
+ }
+
+ sprintf (m, "%s\n%s\n", cl_buf, ct_buf);
+
+ return m;
+ }
+
+ cl = atoi (&cl_buf[l]);
+
+ if (cl <= 0) {
+ errmsg ("Content-Length must be greater than zero\n");
+ return NULL;
+ }
+
+ h = "Content-Type: ";
+ l = strlen (h);
+
+ if (strncmp (ct_buf, h, l) != 0) {
+ errmsg ("missing Content-Type\n");
+ return NULL;
+ }
+
+ if (strcmp (&ct_buf[l], "text/event-plain") != 0) {
+ errmsg ("Unsupported Content-Type\n");
+ return NULL;
+ }
+
+ if (read_trailing_newline (fd) < 0) {
+ return NULL;
+ }
+
+ /*
+ * Read the event.
+ */
+
+ m = malloc (cl);
+
+ if (! m) {
+ char *errstr = strerror (errno);
+
+ errmsg ("malloc failed\n");
+ errmsg (errstr);
+ return NULL;
+ }
+
+ for (nbytes_to_read = cl; nbytes_to_read; nbytes_to_read -= nbytes_read) {
+ nbytes_read = read (fd, m + (cl - nbytes_to_read), nbytes_to_read);
+
+ if (nbytes_read < 0) {
+ char *errstr = strerror (errno);
+
+ errmsg ("read failed in middle of message\n");
+ errmsg (errstr);
+ free (m);
+ return NULL;
+ }
+
+ if (nbytes_read == 0) {
+ errmsg ("EOF in middle of message\n");
+ free (m);
+ return NULL;
+ }
+ }
+
+ if (m[cl - 2] != '\n' || m[cl - 1] != '\n') {
+ errmsg ("Message is missing trailing newlines\n");
+ free (m);
+ return NULL;
+ }
+
+ return m;
+ }
+
+
+static int
+send_password (int fd, const char *passwd)
+ {
+ char *h;
+ char *last;
+ char *m;
+ char *p;
+ int l;
+ size_t ml;
+
+ m = retrieve_message (fd);
+ if (! m)
+ return -1;
+
+ p = strtok_r (m, "\n", &last);
+
+ h = "Content-Type: auth/request";
+
+ if (strcmp (p, h) != 0) {
+ errmsg ("Content-Type wasn't auth/request\n");
+ free (m);
+ return -1;
+ }
+
+ free (m);
+
+ l = snprintf (NULL, 0, "auth %s\n\n", passwd);
+ if (l <= 0) {
+ errmsg ("snprintf failed\n");
+ return -1;
+ }
+ l++;
+
+ m = malloc (l);
+ if (! m) {
+ char *errstr = strerror (errno);
+
+ errmsg ("malloc failed\n");
+ errmsg (errstr);
+ return -1;
+ }
+
+ ml = snprintf (m, l, "auth %s\n\n", passwd);
+ if ((ml + 1) != l) {
+ errmsg ("snprintf failed\n");
+ free (m);
+ return -1;
+ }
+
+ if (write (fd, m, ml) != ml) {
+ char *errstr = strerror (errno);
+
+ errmsg ("write failed\n");
+ errmsg (errstr);
+ free (m);
+ return -1;
+ }
+
+ m = retrieve_message (fd);
+ if (! m )
+ return -1;
+
+ p = strtok_r (m, "\n", &last);
+
+ h = "Content-Type: command/reply";
+
+ if (! p || strcmp (p, h) != 0) {
+ errmsg ("Content-Type wasn't command/reply\n");
+ free (m);
+ return -1;
+ }
+
+ p = strtok_r (NULL, "\n", &last);
+
+ h = "Reply-Text: +OK accepted";
+
+ if (! p || strcmp (p, h) != 0) {
+ errmsg ("auth wasn't accepted\n");
+ free (m);
+ return -1;
+ }
+
+ free (m);
+
+ debugmsg ("Logged into service\n");
+
+ return 0;
+ }
+
+
+static int
+enable_mwi_event (int fd)
+ {
+ char *h;
+ char *last;
+ char *m;
+ char *p;
+ size_t ml;
+
+ m = "event plain MESSAGE_WAITING\n\n";
+ ml = strlen (m);
+
+ if (write (fd, m, ml) != ml) {
+ char *errstr = strerror (errno);
+
+ errmsg ("write failed\n");
+ errmsg (errstr);
+ return -1;
+ }
+
+ m = retrieve_message (fd);
+ if (! m )
+ return -1;
+
+ p = strtok_r (m, "\n", &last);
+
+ h = "Content-Type: command/reply";
+
+ if (! p || strcmp (p, h) != 0) {
+ errmsg ("Content-Type wasn't command/reply\n");
+ free (m);
+ return -1;
+ }
+
+ p = strtok_r (NULL, "\n", &last);
+
+ h = "Reply-Text: +OK event listener enabled plain";
+
+ if (! p || strcmp (p, h) != 0) {
+ errmsg ("event wasn't enabled\n");
+ free (m);
+ return -1;
+ }
+
+ free (m);
+
+ debugmsg ("Enabled message waiting event\n");
+
+ return 0;
+ }
+
+
+static int
+process_mwi_event (char *m, const char *device)
+ {
+ char cbuf[64];
+ char rbuf[64];
+ char *h;
+ char *last;
+ char *ma;
+ char *mw;
+ char *p;
+ int fd;
+ int mwi_off;
+ int mwi_on;
+ int r;
+ int w;
+ size_t l;
+ ssize_t ml;
+ ssize_t nbytes_read;
+ struct termios tio;
+
+ debugmsg ("Processing MWI event\n");
+
+ ma = NULL;
+ mw = NULL;
+
+ p = m;
+
+ while ( (p = strtok_r (p, "\n", &last)) ) {
+ h = "MWI-Messages-Waiting: ";
+ l = strlen (h);
+
+ if (strncmp (p, h, l) == 0)
+ mw = p + l;
+
+ h = "MWI-Message-Account: ";
+ l = strlen (h);
+
+ if (strncmp (p, h, l) == 0)
+ ma = p + l;
+
+ p = NULL;
+ }
+
+ if (! (ma && mw) ) {
+ errmsg ("message account or message waiting missing\n");
+ return -1;
+ }
+
+ p = strchr (ma, '\n');
+ if (p)
+ *p = '\n';
+
+ p = strchr (mw, '\n');
+ if (p)
+ *p = '\n';
+
+ /*
+ * The account is considered to be a System 25 extension if
+ * it's of the form:
+ *
+ * numeric_string@host
+ */
+
+ p = strchr (ma, '%');
+ if (! p)
+ p = strchr (ma, '@');
+
+ if (! p || (strncmp (p, "%40", 3) != 0 && strncmp (p, "@", 1) != 0)) {
+ debugmsg (" %s is not a System 25 extension\n", ma);
+ return 0;
+ }
+
+ *p = '\0';
+
+ for (p = ma; *p; p++)
+ if (! isdigit (*p)) {
+ debugmsg (" %s is not a System 25 extension\n", ma);
+ return 0;
+ }
+
+ mwi_off = strcasecmp (mw, "no") == 0;
+ mwi_on = strcasecmp (mw, "yes") == 0;
+
+ if (mwi_off == mwi_on) {
+ errmsg ("Unsupported Messages-Waiting\n");
+ return 0;
+ }
+
+ for (r = 0; r < 3; r++) {
+ if ((fd = open (device, O_RDWR)) < 0) {
+ char *errstr = strerror (errno);
+
+ errmsg ("open failed for device node <%s>.\n", device);
+ errmsg (errstr);
+ return -1;
+ }
+
+ cfmakeraw (&tio);
+
+ tio.c_cflag = CS8 | CREAD | HUPCL | CCTS_OFLOW | CRTS_IFLOW;
+
+ tio.c_cc[VMIN] = 0;
+ tio.c_cc[VTIME] = 50;
+
+ cfsetispeed (&tio, B9600);
+ cfsetospeed (&tio, B9600);
+
+ if (tcsetattr (fd, TCSAFLUSH, &tio) < 0) {
+ char *errstr = strerror (errno);
+
+ errmsg ("tcsetattr failed\n");
+ errmsg (errstr);
+ close (fd);
+ return -1;
+ }
+
+ m = "AT";
+ ml = strlen (m);
+
+ if (write (fd, m, ml) != ml
+ || write (fd, "\r\n", 2) != 2) {
+ char *errstr = strerror (errno);
+
+ errmsg ("write failed\n");
+ errmsg (errstr);
+ close (fd);
+ return -1;
+ }
+
+ for (w = 0; w < 2; w++) {
+ nbytes_read = read_line (fd, rbuf, sizeof (rbuf));
+ if (nbytes_read > 0 && (rbuf[0] == '\0' || strcmp (rbuf, m) == 0))
+ continue;
+ break;
+ }
+
+ if (nbytes_read < 0) {
+ errmsg ("read_line failed\n");
+ close (fd);
+ return -1;
+ }
+
+ if (nbytes_read == 0
+ || strcmp (rbuf, "OK") != 0) {
+ errmsg ("modem failed to wake up\n");
+ close (fd);
+ continue;
+ }
+
+ m = cbuf;
+ ml = snprintf (cbuf, sizeof (cbuf),
+ "ATDT%s%s", (mwi_on ? "#90" : "#91"), ma);
+ if (ml <= 0 || ml >= sizeof (cbuf)) {
+ errmsg ("snprintf failed.\n");
+ close (fd);
+ return -1;
+ }
+
+ if (write (fd, m, ml) != ml
+ || write (fd, "\r\n", 2) != 2) {
+ char *errstr = strerror (errno);
+
+ errmsg ("write failed\n");
+ errmsg (errstr);
+ close (fd);
+ return -1;
+ }
+
+ sleep (5);
+
+ if (write (fd, "\r\n", 2) != 2) {
+ char *errstr = strerror (errno);
+
+ errmsg ("write failed\n");
+ errmsg (errstr);
+ close (fd);
+ return -1;
+ }
+
+ for (w = 0; w < 2; w++) {
+ nbytes_read = read_line (fd, rbuf, sizeof (rbuf));
+ if (nbytes_read > 0 && (rbuf[0] == '\0' || strcmp (rbuf, m) == 0))
+ continue;
+ break;
+ }
+
+ if (nbytes_read < 0) {
+ errmsg ("read_line failed\n");
+ close (fd);
+ return -1;
+ }
+
+ if (nbytes_read > 0 && strcmp (rbuf, "NO DIALTONE") == 0) {
+ errmsg ("modem failed to detect dialtone\n");
+ close (fd);
+ return -1;
+ }
+
+ if (nbytes_read == 0
+ || strcmp (rbuf, "NO CARRIER") != 0) {
+ errmsg ("modem failed to update MWI\n");
+ close (fd);
+ continue;
+ }
+
+ close (fd);
+
+ debugmsg (" message waiting indicator updated for %s\n", ma);
+ return 0;
+ }
+
+ errmsg (" failed to update message waiting indicator for %s\n", ma);
+
+ return -1;
+ }
+
+
+int
+main (int argc, char **argv)
+ {
+ const char *device = "/dev/cuad0";
+ const char *machine = "localhost";
+ const char *port = "8021";
+ const char *passwd = "ClueCon";
+ char *m;
+ int c;
+ int debug;
+ int fd;
+ struct stat statbuf;
+
+ debug = 0;
+
+ while ((c = getopt (argc, argv, "dm:p:w:")) != -1)
+ switch (c) {
+ case 'd':
+ debug = 1;
+ break;
+
+ case 'm':
+ machine = optarg;
+ break;
+
+ case 'p':
+ port = optarg;
+ break;
+
+ case 'w':
+ passwd = optarg;
+ break;
+
+ case 'l':
+ device = optarg;
+ break;
+
+ default:
+ fprintf (stderr,
+ "Usage: %s [-d] [-m machine] [-p port] [-w passwd] [-l device]\n",
+ MyName);
+ exit(1);
+ /* NOTREACHED */
+ break;
+ }
+
+ if (stat (device, &statbuf) < 0 || ! S_ISCHR (statbuf.st_mode)) {
+ fprintf (stderr, "%s: stat failed for path <%s>\n", MyName, device);
+ fprintf (stderr, "%s: or the path isn't a character special file.\n",
+ MyName);
+ perror (MyName);
+ exit (1);
+ }
+
+ install_signal_handlers ();
+
+ if (! debug)
+ daemonize ();
+
+ while (! shutdown_server) {
+ sleep (5);
+
+ fd = connect_to_service (machine, port);
+ if (fd < 0) {
+ error_msg_throttle = 1;
+ continue;
+ }
+
+ if (send_password (fd, passwd) < 0
+ || enable_mwi_event (fd) < 0) {
+ error_msg_throttle = 1;
+ close (fd);
+ continue;
+ }
+
+ error_msg_throttle = 0;
+
+ while (m = retrieve_message (fd)) {
+ process_mwi_event (m, device);
+ free (m);
+ }
+
+ close (fd);
+ }
+
+ exit (0);
+ }