822received.c

Go to the documentation of this file.

#include <sys/types.h>
#include <time.h>
#include "buffer.h"
#include "logmsg.h"
#include "getln.h"
#include "mess822.h"
#include "exit.h"
#include "leapsecs.h"
#include "caltime.h"
#include "tai.h"
#include "case.h"
 
#define WHO "822received"
 
static void nomem()
{
  logmsg(WHO,111,FATAL,"out of memory");
}
 
mess822_time t;
struct tai sec;
unsigned char secpack[TAI_PACK];
time_t secunix;
 
stralloc tokens = {0};
 
stralloc line = {0};
 
static void doit()
{
  int i;
  int j;
  int state;
  char ch;
  char *x;
 
  for (i = 0; i < line.len; ++i)
    if (line.s[i] == 0)
      line.s[i] = '\n';
  if (!stralloc_0(&line)) nomem();
 
  t.known = 0;
  if (!mess822_token(&tokens,line.s)) nomem();
  if (!mess822_when(&t,line.s)) nomem();
  --line.len;
 
  if (!t.known)
    buffer_puts(buffer_1,"\t\t\t");
  else {
    caltime_tai(&t.ct,&sec);
    tai_pack((char *)secpack,&sec);
    secunix = secpack[0] - 64;
    secunix = (secunix << 8) + secpack[1];
    secunix = (secunix << 8) + secpack[2];
    secunix = (secunix << 8) + secpack[3];
    secunix = (secunix << 8) + secpack[4];
    secunix = (secunix << 8) + secpack[5];
    secunix = (secunix << 8) + secpack[6];
    secunix = (secunix << 8) + secpack[7];
    secunix -= 10;
    buffer_put(buffer_1,ctime(&secunix),24);
  }
  buffer_puts(buffer_1," ");
 
  state = 1;
  /* 1: start; 2: middle; 3: immediately after space; 4: after semicolon */
 
  for (j = i = 0; j < tokens.len; ++j)
    if (!tokens.s[j]) {
      x = tokens.s + i;
      if (*x == '(') {
#ifdef notdef
        if (state == 3)
          buffer_puts(buffer_1,"\n\t\t\t   ");
#endif
          buffer_puts(buffer_1,"(");
          while ((ch = tokens.s[++i])) {
            if (ch == '\n') ch = 0;
              buffer_put(buffer_1,&ch,1);
         }
         buffer_puts(buffer_1,")");
        if (state & 1) state = 2;
      }
      else if (*x == '|') {
        if (state == 3)
          if (!case_diffs(x,"|from")
            ||!case_diffs(x,"|by")
            ||!case_diffs(x,"|for")
            ||!case_diffs(x,"|id")
          )
      buffer_puts(buffer_1,"\n\t\t\t ");
      while ((ch = tokens.s[++i])) {
        if (ch == '\n') ch = 0;
          buffer_put(buffer_1,&ch,1);
      }
        if (state & 1) state = 2;
      }
      else if (*x == ';') {
        if ((state == 2) || (state == 3))
          buffer_puts(buffer_1,"\n\t\t\t ");
        state = 4;
        buffer_puts(buffer_1,";");
        if (state & 1) state = 2;
      }
      else if ((*x == ' ') || (*x == '\t')) {
        if ((state != 1) && (state != 3))
           buffer_puts(buffer_1," ");
        if (state == 2) state = 3;
      }
      else {
        buffer_put(buffer_1,tokens.s + i,1);
        if (state & 1) state = 2;
      }
      i = j + 1;
    }
 
  buffer_puts(buffer_1,"\n");
}
 
stralloc received = {0};
 
mess822_header h = MESS822_HEADER;
mess822_action a[] = {
  { "received:", 0, 0, &received, 0, 0, 0 }
, { 0, 0, 0, 0, 0, 0, 0 }
} ;
 
int main(int argc,char **argv)
{
  int i;
  int j;
  int match;
 
  if (leapsecs_init() == -1)
    logmsg(WHO,111,FATAL,"unable to init leapsecs: ");
 
  if (!mess822_begin(&h,a)) nomem();
  for (;;) {
    if (getln(buffer_0,&line,&match,'\n') == -1)
      logmsg(WHO,111,FATAL,"unable to read input: ");
    if (!mess822_ok(&line)) break;
    if (!mess822_line(&h,&line)) nomem();
    if (!match) break;
  }
  if (!mess822_end(&h)) nomem();
 
  i = 0;
  j = received.len;
  for (;;) {
    if (!j || (received.s[j - 1] == '\n')) {
      if (i >= j) {
        if (!stralloc_copyb(&line,received.s + j,i - j)) nomem();
        doit();
      }
      if (!j) break;
      i = j - 1;
    }
    --j;
  }
 
  buffer_flush(buffer_1);
  _exit(0);
}