retronetworking
/
capi4yaps
mirror of https://github.com/MelwareDE/capi4yaps.git
13
0
Fork 0
Code Issues Projects Releases Wiki Activity
capi4yaps/tap.c

726 lines
14 KiB
C
Raw Permalink Blame History

/* -*- mode: c; mode: fold -*- */
# include "config.h"
# include <stdio.h>
# include <stdlib.h>
# include <ctype.h>
# include <string.h>
# include "pager.h"
/*{{{ definitions & typedefs */
# define DEF_SERVICE_TYPE "PG"
# define DEF_TERMINAL_TYPE '1'
# define CHKTYPE(sss,ccc) ((((sss)[0] & 0xff) << 16) | (((sss)[1] & 0xff) << 8) | ((ccc) & 0xff))
# define CHKSTYPE(cc1,cc2,cc3) ((((cc1) & 0xff) << 16) | (((cc2) & 0xff) << 8) | ((cc3) & 0xff))
typedef enum {
None,
PG1
} Type;
typedef struct _rmsg {
string_t *str;
int rnr;
struct _rmsg *next;
} rmsg;
typedef struct {
# ifndef NDEBUG
# define MAGIC MKMAGIC ('t', 'a', 'p', '\0')
long magic;
# endif /* NDEBUG */
void *sp; /* the serial connection */
void *ctab; /* the conversion table */
void (*logger) (char, char *, ...);
string_t
*callid; /* caller id */
Type typ; /* the connection type */
Bool pre16; /* if p.version before 1.6 is used */
/* timing and retry values */
int t1, t2, t3, t4, t5;
int n1, n2, n3;
int licnt, locnt;
rmsg *r, *prv; /* response message(s) on callback */
} tap;
/*}}}*/
/*{{{ convert */
static int
field_convert (tap *t, string_t *ptr, string_t *cf)
{
int n;
int ch;
cf -> str = NULL;
cf -> size = ptr -> len + 32;
if (! (cf -> str = malloc (cf -> size + 2)))
return ERR_FATAL;
for (n = 0, cf -> len = 0; n < ptr -> len; ++n) {
if (cf -> len + 2 >= cf -> size)
if (! sexpand (cf, cf -> size + 32))
return ERR_FATAL;
ch = cv_conv (t -> ctab, ptr -> str[n]);
if (ch != -1)
switch ((char_t) ch) {
case '\x0d': case '\x0a': case '\x1b':
case '\x02': case '\x03': case '\x1f':
case '\x17': case '\x04': case '\x1a':
if (! t -> pre16) {
cf -> str[cf -> len++] = '\x1a';
cf -> str[cf -> len++] = (char_t) (ch + 0x40);
}
break;
default:
cf -> str[cf -> len++] = (char_t) ch;
break;
}
}
if (cf -> str) {
cf -> str[cf -> len] = '\0';
return NO_ERR;
}
return ERR_FATAL;
}
static char chkstr[] = "0123456789:;<=>?";
static string_t **
convert_tap (tap *t, string_t **field)
{
string_t **ret;
int fcnt;
string_t *cf;
char_t *ptr;
int cnt, siz;
char_t tmp[260];
Bool needchk;
unsigned long chk;
int fld, off, len;
int n, m;
ret = NULL;
for (fcnt = 0; field[fcnt]; ++fcnt)
;
if (cf = (string_t *) malloc ((fcnt + 1) * sizeof (string_t))) {
for (fld = 0; fld < fcnt; ++fld)
if (field_convert (t, field[fld], & cf[fld]) != NO_ERR) {
while (--fld >= 0)
free (cf[fld].str);
free (cf);
break;
}
if (fld < fcnt)
return NULL;
cnt = 0;
siz = 0;
n = 0;
needchk = False;
for (fld = 0, off = 0; fld < fcnt; ) {
ptr = cf[fld].str + off;
len = cf[fld].len - off;
do {
if (! n)
tmp[n++] = '\x02';
if (len) {
tmp[n++] = *ptr++;
--len;
++off;
}
if (! len) {
off = 0;
++fld;
tmp[n++] = '\r';
if (fld == fcnt) {
tmp[n++] = '\x03';
needchk = True;
} else if (n >= 230) {
tmp[n++] = '\x17';
needchk = True;
}
} else if (n >= 250) {
tmp[n++] = '\x1f';
needchk = True;
}
if (needchk) {
needchk = False;
for (m = 0, chk = 0; m < n; ++m)
chk += tmp[m] & 0xff;
tmp[n++] = chkstr[(chk >> 8) & 0xf];
tmp[n++] = chkstr[(chk >> 4) & 0xf];
tmp[n++] = chkstr[chk & 0xf];
tmp[n++] = '\r';
tmp[n] = '\0';
if (cnt >= siz) {
siz += 4;
if (! (ret = (string_t **) Realloc (ret, (siz + 1) * sizeof (string_t *))))
return NULL;
}
if (! (ret[cnt] = snew (tmp, n))) {
while (--cnt >= 0)
sfree (ret[cnt]);
free (ret);
return NULL;
}
++cnt;
ret[cnt] = NULL;
n = 0;
}
} while (len);
}
for (fld = 0; fld < fcnt; ++fld)
free (cf[fld].str);
free (cf);
}
return ret;
}
/*}}}*/
/*{{{ callback interface for receiving response numbers */
static void
getresponse (void *sp, string_t *s, char_t ch, void *data)
{
tap *t = (tap *) data;
rmsg *r;
if (t && (! t -> pre16) && s && (s -> len > 0))
if (sisdigit (s, 0)) {
if (r = (rmsg *) malloc (sizeof (rmsg)))
if (r -> str = snew (s -> str, s -> len + 2)) {
r -> rnr = stoi (r -> str);
r -> next = NULL;
if (t -> prv)
t -> prv -> next = r;
else
t -> r = r;
t -> prv = r;
} else
free (r);
} else if ((! siscntrl (s, 0)) && (r = t -> prv) && scatc (r -> str, "\n")) {
if (sisspace (s, 0))
sdel (s, 0, 1);
scat (r -> str, s);
}
}
static void
free_resp (tap *t)
{
rmsg *tmp;
if (t) {
while (t -> r) {
tmp = t -> r;
t -> r = t -> r -> next;
sfree (tmp -> str);
free (tmp);
}
t -> prv = NULL;
}
}
static void
setcb (tap *t)
{
if (! t -> pre16) {
free_resp (t);
tty_suspend_callback (t -> sp, False);
}
}
static void
clrcb (tap *t)
{
if (! t -> pre16) {
tty_suspend_callback (t -> sp, True);
free_resp (t);
}
}
/*}}}*/
/*{{{ response handling */
static int
show_response (tap *t)
{
rmsg *r;
int nr, typ;
char *line, *ptr;
for (r = t -> r, nr = -1; r; r = r -> next) {
nr = r -> rnr;
if (line = sextract (r -> str)) {
for (ptr = line; isdigit (*ptr); ++ptr)
;
while (isspace (*ptr))
++ptr;
} else
ptr = "(none)";
switch (nr) {
case 110:
V (1, ("TAP Version: %s\n", ptr));
break;
case 111:
V (1, ("processing input\n"));
break;
case 112:
V (1, ("maximum pages entered\n"));
break;
case 113:
V (1, ("maximum time reached\n"));
break;
case 114:
V (1, ("Welcome: %s\n", ptr));
break;
case 115:
V (1, ("Byebye: %s\n", ptr));
break;
case 211:
V (1, ("Page(s) sent successful\n"));
break;
case 212:
V (1, ("Long message truncated and sent\n"));
break;
case 213:
V (1, ("Message accepted - held for deferred delivery\n"));
break;
case 214:
V (1, ("%d character maximum, message has been truncated and sent\n", atoi (ptr)));
break;
case 501:
V (1, ("Timeout during input\n"));
break;
case 502:
V (1, ("Unexpected character received before transaction\n"));
break;
case 503:
V (1, ("Excessive attempts to send/re-send a transaction with checksum errors\n"));
break;
case 504:
V (1, ("Message have to be empty for tone-only pager\n"));
break;
case 505:
V (1, ("Message must not contain characters for a numeric pager\n"));
break;
case 506:
V (1, ("Excessive invalid pages received\n"));
break;
case 507:
V (1, ("Invalid logon attempt: Incorrectly formed logon sequence\n"));
break;
case 508:
V (1, ("Invalid Logon attempt: Service type and category given is not supported\n"));
break;
case 509:
V (1, ("Invalid Logon attempt: Invalid password supplied\n"));
break;
case 510:
V (1, ("Illegal Pager ID\n"));
break;
case 511:
V (1, ("Invalid Pager ID\n"));
break;
case 512:
V (1, ("Temporarily cannot deliver to Pager ID\n"));
break;
case 513:
V (1, ("Long message rejected for exceeding maximum character length\n"));
break;
case 514:
V (1, ("Checksum error\n"));
break;
case 515:
V (1, ("Message format error\n"));
break;
case 516:
V (1, ("Message quota temporarily exceeded\n"));
break;
case 517:
V (1, ("%d character maximum, message rejected\n", atoi (ptr)));
break;
default:
typ = nr / 100;
switch (typ) {
default:
V (1, ("Response"));
break;
case 1:
V (1, ("Informal"));
break;
case 2:
V (1, ("Success"));
break;
case 5:
V (1, ("Fail"));
break;
}
V (1, (" %03d: %s\n", r -> rnr, ptr));
break;
}
if (line)
free (line);
}
return nr;
}
/*}}}*/
/*{{{ login/logout */
int
tap_login (void *tp, char *stype, char ttype, char *passwd, string_t *callid)
{
tap *t = (tap *) tp;
int n, ep;
char *cbuf;
int clen;
int err;
MCHK (t);
if ((! t) || (! t -> sp))
return ERR_ABORT;
if (! stype)
stype = DEF_SERVICE_TYPE;
else if (strlen (stype) != 2) {
V (1, ("Invalid service type %s\n", stype));
return ERR_ABORT;
}
if (! ttype)
ttype = DEF_TERMINAL_TYPE;
switch (CHKTYPE (stype, ttype)) {
case CHKSTYPE ('P', 'G', '1'):
t -> typ = PG1;
break;
}
if (t -> typ == None) {
V (1, ("Invalid service/terminal type combination\n"));
return ERR_ABORT;
}
t -> callid = sfree (t -> callid);
if (callid && (! (t -> callid = snew (callid -> str, callid -> len))))
return ERR_ABORT;
for (n = 0; n < t -> n1; ++n)
if (tty_send (t -> sp, "\r", 1) != 1)
V (1, ("Unable to send initial CR\n"));
else if (tty_expect (t -> sp, t -> t1, "ID=", 3, NULL) == 1) {
V (1, ("Send initial CR\n"));
break;
}
if (n == t -> n1) {
V (1, ("Didn't got initial response\n"));
return ERR_ABORT;
}
if (cbuf = malloc ((passwd ? strlen (passwd) : 0) + strlen (stype) + 16)) {
if (passwd)
sprintf (cbuf, "\x1b%s%c%s\r", stype, ttype, passwd);
else
sprintf (cbuf, "\x1b%s%c\r", stype, ttype);
clen = strlen (cbuf);
} else {
V (1, ("Out of memory!\n"));
return ERR_ABORT;
}
err = NO_ERR;
for (n = 0; n < t -> licnt; ++n)
if (tty_send (t -> sp, cbuf, clen) != clen)
V (1, ("Unable to send Logon request\n"));
else {
setcb (t);
ep = tty_expect (t -> sp, t -> t3, "\x06\r", 2, "ID=", 3, "\x15\r", 2, "\x1b\x04\r", 3, NULL);
if ((! t -> pre16) && t -> r)
show_response (t);
if (ep == 1) {
V (1, ("Login request accepted\n"));
break;
} else if (ep == 2)
V (1, ("Oops, got ID= again\n"));
else if (ep == 3)
V (1, ("Login request not accepted\n"));
else if (ep == 4) {
V (1, ("Logout forced\n"));
n = t -> licnt;
err = ERR_ABORT;
break;
}
}
free (cbuf);
clrcb (t);
if (n == t -> licnt) {
V (1, ("Could not login\n"));
return (err == NO_ERR) ? ERR_FATAL : err;
}
if (tty_expect (t -> sp, t -> t3, "\x1b[p\r", 4, NULL) != 1) {
V (1, ("Didn't got Go Ahead message\n"));
return ERR_FATAL;
} else
V (1, ("Successful login\n"));
return NO_ERR;
}
int
tap_logout (void *tp)
{
tap *t = (tap *) tp;
int err;
int n, ep;
MCHK (t);
if ((! t) || (! t -> sp))
return ERR_FATAL;
err = NO_ERR;
for (n = 0; n < t -> locnt; ++n)
if (tty_send (t -> sp, "\x04\r", 2) != 2)
V (1, ("Unable to send logout request\n"));
else {
setcb (t);
ep = tty_expect (t -> sp, t -> t3, "\x1b\x04\r", 3, "\x1e\r", 2, NULL);
if ((! t -> pre16) && t -> r)
show_response (t);
if (ep == 1) {
V (1, ("Message sending completed\n"));
break;
} else if (ep == 2) {
V (1, ("Message sending failed (%d)\n", ep));
err = ERR_FATAL;
n = t -> locnt;
break;
}
}
clrcb (t);
if (n == t -> locnt) {
if (err == NO_ERR)
err = ERR_FAIL;
V (1, ("Unable to logout\n"));
return err;
} else
V (1, ("Logout successful\n"));
return NO_ERR;
}
/*}}}*/
/*{{{ transmit */
int
tap_transmit (void *tp, string_t **field, Bool last)
{
tap *t = (tap *) tp;
int err;
string_t **snd;
char *ptr;
int len;
int n, m, ep;
MCHK (t);
if ((! t) || (! t -> sp))
return ERR_FATAL;
switch (t -> typ) {
default:
case None:
V (1, ("Invalid service/terminal type\n"));
return ERR_FAIL;
case PG1:
for (n = 0; field[n]; ++n)
;
if (n != 2) {
V (1, ("PG1 service/terminal type needs exactly two fields\n"));
return ERR_FAIL;
}
break;
}
err = ERR_FATAL;
if (snd = convert_tap (t, field)) {
err = NO_ERR;
for (m = 0; snd[m]; ++m) {
ptr = (char *) snd[m] -> str;
len = snd[m] -> len;
for (n = 0; n < t -> n2; ++n)
if (tty_send (t -> sp, ptr, len) != len)
V (1, ("Unable to transmit part\n"));
else {
setcb (t);
ep = tty_expect (t -> sp, t -> t3, "\x06\r", 2, "\x15\r", 2, "\x1e\r", 2, "\x1b\x04\r", 3, NULL);
if ((! t -> pre16) && t -> r)
show_response (t);
if (ep == 1) {
V (1, ("Transmited part\n"));
break;
} else if (ep == 2)
V (1, ("Can't transmit part\n"));
else if (ep == 3) {
V (1, ("Can't transmit this message\n"));
err = ERR_FAIL;
n = t -> n2;
break;
} else if (ep == 4) {
V (1, ("Logout forced\n"));
err = ERR_ABORT;
n = t -> n2;
break;
}
}
sfree (snd[m]);
clrcb (t);
if (n == t -> n2) {
V (1, ("Unable to send part %d\n", m));
for (n = m + 1; snd[n]; ++n)
sfree (snd[n]);
break;
}
}
if (! snd[m])
V (1, ("Sent message\n"));
else if (err == NO_ERR)
err = ERR_FAIL;
free (snd);
} else
V (1, ("Unable to convert message\n"));
return err;
}
/*}}}*/
/*{{{ configuration */
void
tap_config (void *tp, void (*logger) (char, char *, ...), Bool pre16)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
t -> logger = logger;
if (t -> pre16 = pre16)
tty_suspend_callback (t -> sp, True);
}
}
void
tap_timeouts (void *tp, int t1, int t2, int t3, int t4, int t5)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
if (t1 != -1)
t -> t1 = t1;
if (t2 != -1)
t -> t2 = t2;
if (t3 != -1)
t -> t3 = t3;
if (t4 != -1)
t -> t4 = t4;
if (t5 != -1)
t -> t5 = t5;
}
}
void
tap_retries (void *tp, int n1, int n2, int n3, int licnt, int locnt)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
if (n1 != -1)
t -> n1 = n1;
if (n2 != -1)
t -> n2 = n2;
if (n3 != -1)
t -> n3 = n3;
if (licnt != -1)
t -> licnt = licnt;
if (locnt != -1)
t -> locnt = locnt;
}
}
void
tap_set_convtable (void *tp, void *ctab)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
if (t -> ctab)
cv_free (t -> ctab);
t -> ctab = ctab;
}
}
static void
new_convtab (tap *t)
{
int n;
if (t -> ctab = cv_new ())
for (n = 128; n < 256; ++n)
cv_invalid (t -> ctab, (char_t) n);
}
void
tap_add_convtable (void *tp, void *ctab)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
if (! t -> ctab)
new_convtab (t);
if (t -> ctab)
cv_merge (t -> ctab, ctab, True);
}
}
/*}}}*/
/*{{{ new/free/etc */
void *
tap_new (void *sp)
{
tap *t;
if (t = (tap *) malloc (sizeof (tap))) {
# ifndef NDEBUG
t -> magic = MAGIC;
# endif /* NDEBUG */
t -> sp = sp;
new_convtab (t);
t -> logger = NULL;
t -> callid = NULL;
t -> typ = None;
t -> pre16 = False;
t -> t1 = 2;
t -> t2 = 1;
t -> t3 = 10;
t -> t4 = 4;
t -> t5 = 8;
t -> n1 = 3;
t -> n2 = 3;
t -> n3 = 3;
t -> licnt = 3;
t -> locnt = 3;
t -> r = NULL;
t -> prv = NULL;
tty_set_line_callback (t -> sp, getresponse, "\r", (void *) t);
tty_suspend_callback (t -> sp, True);
}
return (void *) t;
}
void *
tap_free (void *tp)
{
tap *t = (tap *) tp;
MCHK (t);
if (t) {
if (t -> ctab)
cv_free (t -> ctab);
if (t -> sp)
tty_set_line_callback (t -> sp, NULL, NULL, NULL);
if (t -> callid)
sfree (t -> callid);
if (t -> r)
free_resp (t);
free (t);
}
return NULL;
}
int
tap_preinit (void)
{
return 0;
}
void
tap_postdeinit (void)
{
}
/*}}}*/
Reference in New Issue View Git Blame Copy Permalink