1 #include <sys/types.h>

     2 #include <sys/stat.h>

     3 #include "stralloc.h"

     4 #include "substdio.h"

     5 #include "subfd.h"

     6 #include "fmt.h"

     7 #include "str.h"

     8 #include "getln.h"

     9 #include "fmtqfn.h"

    10 #include "readsubdir.h"

    11 #include "auto_qmail.h"

    12 #include "open.h"

    13 #include "datetime.h"

    14 #include "date822fmt.h"

    15 #include "readwrite.h"

    16 #include "error.h"

    17 #include "exit.h"

    18 

    19 readsubdir rs;

    20 

    21 void die(n) int n; { substdio_flush(subfdout); _exit(n); }

    22 

    23 void warn(s1,s2) char *s1; char *s2;

    24 {

    25  char *x;

    26  x = error_str(errno);

    27  substdio_puts(subfdout,s1);

    28  substdio_puts(subfdout,s2);

    29  substdio_puts(subfdout,": ");

    30  substdio_puts(subfdout,x);

    31  substdio_puts(subfdout,"\n");

    32 }

    33 

    34 void die_nomem() { substdio_puts(subfdout,"fatal: out of memory\n"); die(111); }

    35 void die_chdir() { warn("fatal: unable to chdir",""); die(111); }

    36 void die_opendir(fn) char *fn; { warn("fatal: unable to opendir ",fn); die(111); }

    37 

    38 void err(id) unsigned long id;

    39 {

    40  char foo[FMT_ULONG];

    41  foo[fmt_ulong(foo,id)] = 0;

    42  warn("warning: trouble with #",foo);

    43 }

    44 

    45 char fnmess[FMTQFN];

    46 char fninfo[FMTQFN];

    47 char fnlocal[FMTQFN];

    48 char fnremote[FMTQFN];

    49 char fnbounce[FMTQFN];

    50 

    51 char inbuf[1024];

    52 stralloc sender = {0};

    53 

    54 unsigned long id;

    55 datetime_sec qtime;

    56 int flagbounce;

    57 unsigned long size;

    58 

    59 unsigned int fmtstats(s)

    60 char *s;

    61 {

    62  struct datetime dt;

    63  unsigned int len;

    64  unsigned int i;

    65 

    66  len = 0;

    67  datetime_tai(&dt,qtime);

    68  i = date822fmt(s,&dt) - 7/*XXX*/; len += i; if (s) s += i;

    69  i = fmt_str(s," GMT  #"); len += i; if (s) s += i;

    70  i = fmt_ulong(s,id); len += i; if (s) s += i;

    71  i = fmt_str(s,"  "); len += i; if (s) s += i;

    72  i = fmt_ulong(s,size); len += i; if (s) s += i;

    73  i = fmt_str(s,"  <"); len += i; if (s) s += i;

    74  i = fmt_str(s,sender.s + 1); len += i; if (s) s += i;

    75  i = fmt_str(s,"> "); len += i; if (s) s += i;

    76  if (flagbounce)

    77   {

    78    i = fmt_str(s," bouncing"); len += i; if (s) s += i;

    79   }

    80 

    81  return len;

    82 }

    83 

    84 stralloc stats = {0};

    85 

    86 void out(s,n) char *s; unsigned int n;

    87 {

    88  while (n > 0)

    89   {

    90    substdio_put(subfdout,((*s >= 32) && (*s <= 126)) ? s : "_",1);

    91    --n;

    92    ++s;

    93   }

    94 }

    95 void outs(s) char *s; { out(s,str_len(s)); }

    96 void outok(s) char *s; { substdio_puts(subfdout,s); }

    97 

    98 void putstats()

    99 {

   100  if (!stralloc_ready(&stats,fmtstats(FMT_LEN))) die_nomem();

   101  stats.len = fmtstats(stats.s);

   102  out(stats.s,stats.len);

   103  outok("\n");

   104 }

   105 

   106 stralloc line = {0};

   107 

   108 void main()

   109 {

   110  int channel;

   111  int match;

   112  struct stat st;

   113  int fd;

   114  substdio ss;

   115  int x;

   116 

   117  if (chdir(auto_qmail) == -1) die_chdir();

   118  if (chdir("queue") == -1) die_chdir();

   119  readsubdir_init(&rs,"info",die_opendir);

   120 

   121  while (x = readsubdir_next(&rs,&id))

   122    if (x > 0)

   123     {

   124      fmtqfn(fnmess,"mess/",id,1);

   125      fmtqfn(fninfo,"info/",id,1);

   126      fmtqfn(fnlocal,"local/",id,1);

   127      fmtqfn(fnremote,"remote/",id,1);

   128      fmtqfn(fnbounce,"bounce/",id,0);

   129 

   130      if (stat(fnmess,&st) == -1) { err(id); continue; }

   131      size = st.st_size;

   132      flagbounce = !stat(fnbounce,&st);

   133 

   134      fd = open_read(fninfo);

   135      if (fd == -1) { err(id); continue; }

   136      substdio_fdbuf(&ss,read,fd,inbuf,sizeof(inbuf));

   137      if (getln(&ss,&sender,&match,0) == -1) die_nomem();

   138      if (fstat(fd,&st) == -1) { close(fd); err(id); continue; }

   139      close(fd);

   140      qtime = st.st_mtime;

   141 

   142      putstats();

   143 

   144      for (channel = 0;channel < 2;++channel)

   145       {

   146        fd = open_read(channel ? fnremote : fnlocal);

   147        if (fd == -1)

   148 	{

   149 	 if (errno != error_noent)

   150 	   err(id);

   151 	}

   152        else

   153         {

   154          for (;;)

   155 	  {

   156 	   if (getln(&ss,&line,&match,0) == -1) die_nomem();

   157 	   if (!match) break;

   158 	   switch(line.s[0])

   159 	    {

   160 	     case 'D':

   161 	       outok("  done");

   162 	     case 'T':

   163 	       outok(channel ? "\tremote\t" : "\tlocal\t");

   164 	       outs(line.s + 1);

   165 	       outok("\n");

   166 	       break;

   167 	    }

   168 	  }

   169          close(fd);

   170         }

   171       }

   172     }

   173 

   174  die(0);

   175 }