made the communications between clients and server completely ascii (no

[spider.git] / src / client.c

diff --git a/src/client.c b/src/client.c
index 8c52d53ffa921839d491a76ed137c0aeccfef971..1f899c58dcf29ea589f4ce42526fbab8959693cc 100644 (file)
--- a/src/client.c
+++ b/src/client.c
@@ -237,24 +237,35 @@ void send_text(fcb_t *f, char *s, int l)
                flush_text(f);
 }
 
-void send_msg(fcb_t *f, char let, char *s, int l)
+void send_msg(fcb_t *f, char let, unsigned char *s, int l)
 {
        cmsg_t *mp;
        int ln;
        int myl = strlen(call)+2+l;
 
        mp = cmsg_new(myl+4+1, f->sort, f);
-       ln = htonl(myl);
-       memcpy(mp->inp, &ln, 4);
-       mp->inp += 4;
        *mp->inp++ = let;
        strcpy(mp->inp, call);
        mp->inp += strlen(call);
        *mp->inp++ = '|';
        if (l > 0) {
-               memcpy(mp->inp, s, l);
-               mp->inp += l;
-       }
+               unsigned char *p;
+               for (p = s; p < s+l; ++p) {
+                       if (mp->inp >= mp->data + (myl - 4)) {
+                               int off = mp->inp - mp->data;
+                               myl += 256;
+                               mp = realloc(mp, myl);
+                               mp->inp = mp->data + off;
+                       }
+                       
+                       if (*p < 0x20 || *p > 0x7e || *p == '%') {
+                               sprintf(mp->inp, "%%%02X", *p & 0xff);
+                               mp->inp += strlen(mp->inp);
+                       } else 
+                               *mp->inp++ = *p;
+               }
+       } 
+       *mp->inp++ = '\n';
        *mp->inp = 0;
        cmsg_send(f->outq, mp, 0);
        f->sp->flags |= SEL_OUTPUT;
@@ -268,6 +279,7 @@ int fcb_handler(sel_t *sp, int in, int out, int err)
 {
        fcb_t *f = sp->fcb;
        cmsg_t *mp, *omp;
+       unsigned char c;
        
        /* input modes */
        if (in) {
@@ -283,14 +295,14 @@ int fcb_handler(sel_t *sp, int in, int out, int err)
                        case EAGAIN:
                                goto lout;
                        default:
-                               if (f->sort == MSG)
-                                       send_Z = 0;
+/*                             if (f->sort == MSG)
+                               send_Z = 0; */
                                ending++;
                                return 0;
                        }
                } else if (r == 0) {
-                       if (f->sort == MSG)
-                               send_Z = 0;
+/*                     if (f->sort == MSG)
+                       send_Z = 0; */
                        ending++;
                        return 0;
                }
@@ -372,30 +384,60 @@ int fcb_handler(sel_t *sp, int in, int out, int err)
                case MSG:
                        p = buf;
                        while (r > 0 && p < &buf[r]) {
+                               unsigned char ch = *p++;
+                               
+                               if (mp->inp >= mp->data + (MAXBUFL-1)) {
+                                       mp->state = 0;
+                                       mp->inp = mp->data;
+                                       dbg(DMSG, "Message longer than %d received", MAXBUFL);
+                               }
 
-                               /* build up the size into the likely message length (yes I know it's a short) */
                                switch (mp->state) {
-                               case 0:
-                               case 1:
-                                       mp->state++;
-                                       break;
-                               case 2:
-                               case 3:
-                                       mp->size = (mp->size << 8) | (*p++ & 0xff);
-                                       if (mp->size > MAXBUFL)
-                                               die("Message size too big from node (%d > %d)", mp->size, MAXBUFL);
-                                       mp->state++;
-                                       break;
-                               default:
-                                       if (mp->inp - mp->data < mp->size) {
-                                               *mp->inp++ = *p++;
-                                       } 
-                                       if (mp->inp - mp->data >= mp->size) {
+                               case 0: 
+                                       if (ch == '%') {
+                                               c = 0;
+                                               mp->state = 1;
+                                       } else if (ch == '\n') {
                                                /* kick it upstairs */
+                                               *mp->inp = 0;
                                                dbgdump(DMSG, "QUEUE MSG", mp->data, mp->inp - mp->data);
                                                cmsg_send(f->inq, mp, 0);
                                                mp = f->in = cmsg_new(MAXBUFL+1, f->sort, f);
+                                       } else if (ch < 0x20 || ch > 0x7e) {
+                                               dbg(DMSG, "Illegal character (0x%02X) received", *p);
+                                               mp->inp = mp->data;
+                                       } else {
+                                               *mp->inp++ = ch;
+                                       }
+                                       break;
+
+                               case 1:
+                                       mp->state = 2;
+                                       if (ch >= '0' && ch <= '9') 
+                                               c = (ch - '0') << 4;
+                                       else if (ch >= 'A' && ch <= 'F')
+                                               c = (ch - 'A' + 10) << 4;
+                                       else if (ch >= 'a' && ch <= 'a')
+                                               c = (ch - 'a' + 10) << 4;
+                                       else {
+                                               dbg(DMSG, "Illegal hex char (%c) received in state %d", ch, mp->state);
+                                               mp->inp = mp->data;
+                                               mp->state = 0;
                                        }
+                                       break;
+                                       
+                               case 2:
+                                       if (ch >= '0' && ch <= '9') 
+                                               *mp->inp++ = c | (ch - '0');
+                                       else if (ch >= 'A' && ch <= 'F')
+                                               *mp->inp++ = c | (ch - 'A' + 10);
+                                       else if (ch >= 'a' && ch <= 'a')
+                                               *mp->inp++ = c | (ch - 'a' + 10);
+                                       else {
+                                               dbg(DMSG, "Illegal hex char (%c) received in state %d", ch, mp->state);
+                                               mp->inp = mp->data;
+                                       }
+                                       mp->state = 0;
                                }
                        }
                        break;
@@ -431,8 +473,8 @@ lout:;
                                case EAGAIN:
                                        goto lend;
                                default:
-                                       if (f->sort == MSG)
-                                               send_Z = 0;
+/*                                     if (f->sort == MSG)
+                                       send_Z = 0; */
                                        ending++;
                                        return;
                                }
@@ -555,6 +597,7 @@ void term_timeout(int i)
        if (in && in->t_set)
                tcsetattr(0, TCSANOW, &in->t);
        if (node) {
+               shutdown(node->cnum, 3);
                close(node->cnum);
        }
        exit(i);
@@ -563,7 +606,7 @@ void term_timeout(int i)
 void terminate(int i)
 {
        if (node && send_Z && call) {
-               send_msg(node, 'Z', "", 0);
+               send_msg(node, 'Z', "bye", 3);
        }
        
        signal(SIGALRM, term_timeout);
@@ -575,8 +618,10 @@ void terminate(int i)
        }
        if (in && in->t_set)
                tcsetattr(0, TCSADRAIN, &in->t);
-       if (node) 
+       if (node) {
+               shutdown(node->cnum, 3);
                close(node->cnum);
+       }
        exit(i);
 }