qmail/qmail-qread.c

#include <sys/types.h>
#include <sys/stat.h>
#include "stralloc.h"
#include "substdio.h"
#include "subfd.h"
#include "fmt.h"
#include "str.h"
#include "getln.h"
#include "fmtqfn.h"
#include "readsubdir.h"
#include "auto_qmail.h"
#include "open.h"
#include "datetime.h"
#include "date822fmt.h"
#include "readwrite.h"
#include "error.h"
#include "exit.h"

readsubdir rs;

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

void warn(s1,s2) char *s1; char *s2;
{
 char *x;
 x = error_str(errno);
 substdio_puts(subfdout,s1);
 substdio_puts(subfdout,s2);
 substdio_puts(subfdout,": ");
 substdio_puts(subfdout,x);
 substdio_puts(subfdout,"\n");
}

void die_nomem() { substdio_puts(subfdout,"fatal: out of memory\n"); die(111); }
void die_chdir() { warn("fatal: unable to chdir",""); die(111); }
void die_opendir(fn) char *fn; { warn("fatal: unable to opendir ",fn); die(111); }

void err(id) unsigned long id;
{
 char foo[FMT_ULONG];
 foo[fmt_ulong(foo,id)] = 0;
 warn("warning: trouble with #",foo);
}

char fnmess[FMTQFN];
char fninfo[FMTQFN];
char fnlocal[FMTQFN];
char fnremote[FMTQFN];
char fnbounce[FMTQFN];

char inbuf[1024];
stralloc sender = {0};

unsigned long id;
datetime_sec qtime;
int flagbounce;
unsigned long size;

unsigned int fmtstats(s)
char *s;
{
 struct datetime dt;
 unsigned int len;
 unsigned int i;

 len = 0;
 datetime_tai(&dt,qtime);
 i = date822fmt(s,&dt) - 7/*XXX*/; len += i; if (s) s += i;
 i = fmt_str(s," GMT  #"); len += i; if (s) s += i;
 i = fmt_ulong(s,id); len += i; if (s) s += i;
 i = fmt_str(s,"  "); len += i; if (s) s += i;
 i = fmt_ulong(s,size); len += i; if (s) s += i;
 i = fmt_str(s,"  <"); len += i; if (s) s += i;
 i = fmt_str(s,sender.s + 1); len += i; if (s) s += i;
 i = fmt_str(s,"> "); len += i; if (s) s += i;
 if (flagbounce)
  {
   i = fmt_str(s," bouncing"); len += i; if (s) s += i;
  }

 return len;
}

stralloc stats = {0};

void out(s,n) char *s; unsigned int n;
{
 while (n > 0)
  {
   substdio_put(subfdout,((*s >= 32) && (*s <= 126)) ? s : "_",1);
   --n;
   ++s;
  }
}
void outs(s) char *s; { out(s,str_len(s)); }
void outok(s) char *s; { substdio_puts(subfdout,s); }

void putstats()
{
 if (!stralloc_ready(&stats,fmtstats(FMT_LEN))) die_nomem();
 stats.len = fmtstats(stats.s);
 out(stats.s,stats.len);
 outok("\n");
}

stralloc line = {0};

void main()
{
 int channel;
 int match;
 struct stat st;
 int fd;
 substdio ss;
 int x;

 if (chdir(auto_qmail) == -1) die_chdir();
 if (chdir("queue") == -1) die_chdir();
 readsubdir_init(&rs,"info",die_opendir);

 while (x = readsubdir_next(&rs,&id))
   if (x > 0)
    {
     fmtqfn(fnmess,"mess/",id,1);
     fmtqfn(fninfo,"info/",id,1);
     fmtqfn(fnlocal,"local/",id,1);
     fmtqfn(fnremote,"remote/",id,1);
     fmtqfn(fnbounce,"bounce/",id,0);

     if (stat(fnmess,&st) == -1) { err(id); continue; }
     size = st.st_size;
     flagbounce = !stat(fnbounce,&st);

     fd = open_read(fninfo);
     if (fd == -1) { err(id); continue; }
     substdio_fdbuf(&ss,read,fd,inbuf,sizeof(inbuf));
     if (getln(&ss,&sender,&match,0) == -1) die_nomem();
     if (fstat(fd,&st) == -1) { close(fd); err(id); continue; }
     close(fd);
     qtime = st.st_mtime;

     putstats();

     for (channel = 0;channel < 2;++channel)
      {
       fd = open_read(channel ? fnremote : fnlocal);
       if (fd == -1)
	{
	 if (errno != error_noent)
	   err(id);
	}
       else
        {
         for (;;)
	  {
	   if (getln(&ss,&line,&match,0) == -1) die_nomem();
	   if (!match) break;
	   switch(line.s[0])
	    {
	     case 'D':
	       outok("  done");
	     case 'T':
	       outok(channel ? "\tremote\t" : "\tlocal\t");
	       outs(line.s + 1);
	       outok("\n");
	       break;
	    }
	  }
         close(fd);
        }
      }
    }

 die(0);
}