qmail 1.03 import

1 files changed, 175 insertions, 0 deletions

diff --git a/qmail-qread.c b/qmail-qread.c
new file mode 100644
index 0000000..8ec0fbd
--- /dev/null
+++ b/qmail-qread.c
@@ -0,0 +1,175 @@
+#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);
+}