2 * C Client for the DX Spider cluster program
4 * Eventually this program will be a complete replacement
5 * for the perl version.
7 * This program provides the glue necessary to talk between
8 * an input (eg from telnet or ax25) and the perl DXSpider
11 * Currently, this program connects STDIN/STDOUT to the
12 * message system used by cluster.pl
14 * Copyright (c) 2000 Dirk Koopman G1TLH
21 #include <sys/types.h>
27 #include <sys/socket.h>
28 #include <netinet/in.h>
44 #define MAXPATHLEN 256
53 int cnum; /* the connection number */
54 int sort; /* the type of connection either text or msg */
55 cmsg_t *in; /* current input message being built up */
56 cmsg_t *out; /* current output message being sent */
57 cmsg_t *obuf; /* current output being buffered */
58 reft *inq; /* input queue */
59 reft *outq; /* output queue */
60 sel_t *sp; /* my select fcb address */
61 struct termios t; /* any termios associated with this cnum */
62 char echo; /* echo characters back to this cnum */
63 char t_set; /* the termios structure is valid */
64 char buffer_it; /* buffer outgoing packets for paclen */
74 char *node_addr = "localhost"; /* the node tcp address, can be overridden by DXSPIDER_HOST */
75 int node_port = 27754; /* the tcp port of the node at the above address can be overidden by DXSPIDER_PORT*/
76 char *call; /* the caller's callsign */
77 char *connsort; /* the type of connection */
78 fcb_t *in; /* the fcb of 'stdin' that I shall use */
79 fcb_t *node; /* the fcb of the msg system */
80 char nl = '\n'; /* line end character */
81 char ending = 0; /* set this to end the program */
82 char send_Z = 1; /* set a Z record to the node on termination */
83 char echo = 1; /* echo characters on stdout from stdin */
84 char int_tabs = 0; /* interpret tabs -> spaces */
85 char *root = "/spider"; /* root of data tree, can be overridden by DXSPIDER_ROOT */
86 int timeout = 60; /* default timeout for logins and things */
87 int paclen = 128; /* default buffer size for outgoing packets */
88 int tabsize = 8; /* default tabsize for text messages */
90 myregex_t iscallreg[] = { /* regexes to determine whether this is a reasonable callsign */
92 "^[A-Z]+[0-9]+[A-Z]+", 0
95 "^[0-9]+[A-Z]+[0-9]+[A-Z]+", 0
105 * utility routines - various
108 void die(char *s, ...)
114 vsnprintf(buf, sizeof(buf)-1, s, ap);
116 fprintf(stderr,"%s\n", buf);
120 char *strupper(char *s)
122 char *d = malloc(strlen(s)+1);
126 die("out of room in strupper");
127 while (*p++ = toupper(*s++)) ;
131 char *strlower(char *s)
133 char *d = malloc(strlen(s)+1);
137 die("out of room in strlower");
138 while (*p++ = tolower(*s++)) ;
142 int eq(char *a, char *b)
144 return (strcmp(a, b) == 0);
147 int xopen(char *dir, char *name, int mode)
149 char fn[MAXPATHLEN+1];
150 snprintf(fn, MAXPATHLEN, "%s/%s/%s", root, dir, name);
151 return open(fn, mode);
154 int iscallsign(char *s)
157 for (rp = iscallreg; rp->in; ++rp) {
158 if (regexec(rp->regex, s, 0, 0, 0) == 0)
165 * higher level send and receive routines
168 fcb_t *fcb_new(int cnum, int sort)
170 fcb_t *f = malloc(sizeof(fcb_t));
172 die("no room in fcb_new");
173 memset (f, 0, sizeof(fcb_t));
176 f->inq = chain_new();
177 f->outq = chain_new();
181 void flush_text(fcb_t *f)
184 cmsg_send(f->outq, f->obuf, 0);
185 f->sp->flags |= SEL_OUTPUT;
190 void send_text(fcb_t *f, char *s, int l)
195 if (f->buffer_it && f->obuf) {
198 f->obuf = mp = cmsg_new(paclen+1, f->sort, f);
201 for (p = s; p < s+l; ) {
202 if (mp->inp >= mp->data + paclen) {
204 f->obuf = mp = cmsg_new(paclen+1, f->sort, f);
208 if (mp->inp >= mp->data + paclen) {
210 f->obuf = mp = cmsg_new(paclen+1, f->sort, f);
217 void send_msg(fcb_t *f, char let, char *s, int l)
221 int myl = strlen(call)+2+l;
223 mp = cmsg_new(myl+4+1, f->sort, f);
225 memcpy(mp->inp, &ln, 4);
228 strcpy(mp->inp, call);
229 mp->inp += strlen(call);
232 memcpy(mp->inp, s, l);
236 cmsg_send(f->outq, mp, 0);
237 f->sp->flags |= SEL_OUTPUT;
241 * the callback (called by sel_run) that handles all the inputs and outputs
244 int fcb_handler(sel_t *sp, int in, int out, int err)
251 char *p, buf[MAXBUFL];
254 /* read what we have into a buffer */
255 r = read(f->cnum, buf, MAXBUFL);
275 dbgdump(DBUF, "in ->", buf, r);
277 /* create a new message buffer if required */
279 f->in = cmsg_new(MAXBUFL+1, f->sort, f);
286 omp = cmsg_new(3*r+1, f->sort, f);
287 while (r > 0 && p < &buf[r]) {
289 /* echo processing */
294 strcpy(omp->inp, "\b \b");
295 omp->inp += strlen(omp->inp);
302 /* character processing */
306 memset(mp->inp, ' ', tabsize);
315 if (mp->inp > mp->data)
320 if (nl == '\n' && *p == '\r') { /* ignore \r in telnet mode (ugh) */
322 } else if (*p == nl) {
323 if (mp->inp == mp->data)
325 *mp->inp = 0; /* zero terminate it, but don't include it in the length */
326 dbgdump(DMSG, "QUEUE TEXT", mp->data, mp->inp-mp->data);
327 cmsg_send(f->inq, mp, 0);
328 f->in = mp = cmsg_new(MAXBUFL+1, f->sort, f);
331 if (mp->inp < &mp->data[MAXBUFL-8])
340 /* queue any echo text */
342 dbgdump(DMSG, "QUEUE ECHO TEXT", omp->data, omp->inp - omp->data);
343 cmsg_send(f->outq, omp, 0);
344 f->sp->flags |= SEL_OUTPUT;
351 while (r > 0 && p < &buf[r]) {
353 /* build up the size into the likely message length (yes I know it's a short) */
361 mp->size = (mp->size << 8) | (*p++ & 0xff);
362 if (mp->size > MAXBUFL)
363 die("Message size too big from node (%d > %d)", mp->size, MAXBUFL);
367 if (mp->inp - mp->data < mp->size) {
370 if (mp->inp - mp->data >= mp->size) {
371 /* kick it upstairs */
372 dbgdump(DMSG, "QUEUE MSG", mp->data, mp->inp - mp->data);
373 cmsg_send(f->inq, mp, 0);
374 mp = f->in = cmsg_new(MAXBUFL+1, f->sort, f);
381 die("invalid sort (%d) in input handler", f->sort);
391 mp = f->out = cmsg_next(f->outq);
393 sp->flags &= ~SEL_OUTPUT;
398 l = mp->size - (mp->inp - mp->data);
401 dbgdump(DBUF, "<-out", mp->inp, l);
403 r = write(f->cnum, mp->inp, l);
420 die("got negative length in handler on node");
421 if (mp->inp - mp->data >= mp->size) {
422 cmsg_callback(mp, 0);
431 * things to do with initialisation
434 void initargs(int argc, char *argv[])
438 while ((c = getopt(argc, argv, "h:p:x:")) > 0) {
444 paclen = atoi(optarg);
447 if (paclen > MAXPACLEN)
451 node_port = atoi(optarg);
455 dbgset(atoi(optarg));
465 die("usage: client [-x n|-h<host>|-p<port>|-l<paclen>] <call>|login [local|telnet|ax25]");
469 call = strupper(argv[optind]);
473 die("Must have at least a callsign (for now)");
476 connsort = strlower(argv[optind]);
477 if (eq(connsort, "telnet") || eq(connsort, "local")) {
480 } else if (eq(connsort, "ax25")) {
484 die("2nd argument must be \"telnet\" or \"ax25\" or \"local\"");
493 void connect_to_node()
495 struct hostent *hp, *gethostbyname();
496 struct sockaddr_in server;
500 if ((hp = gethostbyname(node_addr)) == 0)
501 die("Unknown host tcp host %s for printer", node_addr);
503 memset(&server, 0, sizeof server);
504 server.sin_family = AF_INET;
505 memcpy(&server.sin_addr, hp->h_addr, hp->h_length);
506 server.sin_port = htons(node_port);
508 nodef = socket(AF_INET, SOCK_STREAM, 0);
510 die("Can't open socket to %s port %d (%d)", node_addr, node_port, errno);
512 if (connect(nodef, (struct sockaddr *) &server, sizeof server) < 0) {
513 die("Error on connect to %s port %d (%d)", node_addr, node_port, errno);
515 node = fcb_new(nodef, MSG);
516 node->sp = sel_open(nodef, node, "Msg System", fcb_handler, MSG, SEL_INPUT);
521 * things to do with going away
524 void term_timeout(int i)
526 /* none of this is going to be reused so don't bother cleaning up properly */
528 tcsetattr(0, TCSANOW, &in->t);
535 void terminate(int i)
537 if (node && send_Z && call) {
538 send_msg(node, 'Z', "", 0);
541 signal(SIGALRM, term_timeout);
544 while ((in && !is_chain_empty(in->outq)) ||
545 (node && !is_chain_empty(node->outq))) {
549 tcsetattr(0, TCSADRAIN, &in->t);
555 void login_timeout(int i)
557 write(0, "Timed Out", 10);
559 sel_run(); /* force a coordination */
561 tcsetattr(0, TCSANOW, &in->t);
566 * things to do with ongoing processing of inputs
571 cmsg_t *mp = cmsg_next(in->inq);
573 dbg(DMSG, "MSG size: %d", mp->size);
575 if (mp->size > 0 && mp->inp > mp->data) {
576 send_msg(node, 'I', mp->data, mp->size);
578 cmsg_callback(mp, 0);
584 cmsg_t *mp = cmsg_next(node->inq);
586 dbg(DMSG, "MSG size: %d", mp->size);
588 if (mp->size > 0 && mp->inp > mp->data) {
589 char *p = strchr(mp->data, '|');
592 switch (mp->data[0]) {
603 in->buffer_it = *p - '0';
607 int l = mp->inp - (unsigned char *) p;
615 cmsg_callback(mp, 0);
622 * the program itself....
625 main(int argc, char *argv[])
627 /* set up environment */
629 char *p = getenv("DXSPIDER_ROOT");
632 p = getenv("DXSPIDER_HOST");
635 p = getenv("DXSPIDER_PORT");
638 p = getenv("DXSPIDER_PACLEN");
643 if (paclen > MAXPACLEN)
648 /* get program arguments, initialise stuff */
649 initargs(argc, argv);
650 sel_init(10, 0, 10000);
653 signal(SIGHUP, SIG_IGN);
654 signal(SIGINT, terminate);
655 signal(SIGQUIT, terminate);
656 signal(SIGTERM, terminate);
658 signal(SIGPWR, terminate);
661 /* compile regexes for iscallsign */
664 for (rp = iscallreg; rp->in; ++rp) {
666 int r = regcomp(®, rp->in, REG_EXTENDED|REG_ICASE|REG_NOSUB);
668 die("regcomp returned %d for '%s'", r, rp->in);
669 rp->regex = malloc(sizeof(regex_t));
671 die("out of room - compiling regexes");
676 /* is this a login? */
677 if (eq(call, "LOGIN")) {
678 char buf[MAXPACLEN+1];
680 int f = xopen("data", "issue", 0);
682 while ((r = read(f, buf, paclen)) > 0) {
685 for (p = buf; p < &buf[r]; ++p) {
694 signal(SIGALRM, login_timeout);
696 write(0, "login: ", 7);
697 r = read(0, buf, 20);
699 die("No login or error (%d)", errno);
700 signal(SIGALRM, SIG_IGN);
703 if (buf[r-1] == ' ' || buf[r-1] == '\r' || buf[r-1] == '\n')
709 call = strupper(buf);
710 if (!iscallsign(call)) {
711 die("Sorry, %s isn't a valid callsign", buf);
715 /* connect up stdin */
716 in = fcb_new(0, TEXT);
717 in->sp = sel_open(0, in, "STDIN", fcb_handler, TEXT, SEL_INPUT);
718 if (tcgetattr(0, &in->t) < 0) {
722 struct termios t = in->t;
723 t.c_lflag &= ~(ECHO|ECHONL|ICANON);
724 if (tcsetattr(0, TCSANOW, &t) < 0)
725 die("tcsetattr (%d)", errno);
731 /* connect up node */
734 /* tell the cluster who I am */
735 send_msg(node, 'A', connsort, strlen(connsort));
737 /* main processing loop */