chiark - git - mdw - qmail/blob - maildirwatch.c

   1 #include "getln.h"
   2 #include "substdio.h"
   3 #include "subfd.h"
   4 #include "prioq.h"
   5 #include "stralloc.h"
   6 #include "str.h"
   7 #include "exit.h"
   8 #include "hfield.h"
   9 #include "readwrite.h"
  10 #include "open.h"
  11 #include "headerbody.h"
  12 #include "maildir.h"
  13
  14 #define FATAL "maildirwatch: fatal: "
  15
  16 void die_nomem() { strerr_die2x(111,FATAL,"out of memory"); }
  17
  18 stralloc recipient = {0};
  19 stralloc sender = {0};
  20 stralloc fromline = {0};
  21 stralloc text = {0};
  22
  23 void addtext(s,n) char *s; int n;
  24 {
  25  if (!stralloc_catb(&text,s,n)) die_nomem();
  26  if (text.len > 158) text.len = 158;
  27 }
  28 void dobody(h) stralloc *h; { addtext(h->s,h->len); }
  29 void doheader(h) stralloc *h;
  30 {
  31  int i;
  32  switch(hfield_known(h->s,h->len))
  33   {
  34    case H_SUBJECT:
  35      i = hfield_skipname(h->s,h->len);
  36      addtext(h->s + i,h->len - i);
  37      break;
  38    case H_DELIVEREDTO:
  39      i = hfield_skipname(h->s,h->len);
  40      if (i < h->len)
  41        if (!stralloc_copyb(&recipient,h->s + i,h->len - i - 1)) die_nomem();
  42      break;
  43    case H_RETURNPATH:
  44      i = hfield_skipname(h->s,h->len);
  45      if (i < h->len)
  46        if (!stralloc_copyb(&sender,h->s + i,h->len - i - 1)) die_nomem();
  47      break;
  48    case H_FROM:
  49      if (!stralloc_copyb(&fromline,h->s,h->len - 1)) die_nomem();
  50      break;
  51   }
  52 }
  53 void finishheader() { ; }
  54
  55 stralloc filenames = {0};
  56 prioq pq = {0};
  57
  58 char inbuf[SUBSTDIO_INSIZE];
  59 substdio ssin;
  60
  61 void main()
  62 {
  63  struct prioq_elt pe;
  64  int fd;
  65  int i;
  66
  67  if (maildir_chdir() == -1)
  68    strerr_die1(111,FATAL,&maildir_chdir_err);
  69
  70  for (;;)
  71   {
  72    maildir_clean(&filenames);
  73    if (maildir_scan(&pq,&filenames,1,0) == -1)
  74      strerr_die1(111,FATAL,&maildir_scan_err);
  75
  76    substdio_putsflush(subfdout,"\033[;H\033[;J");
  77
  78    while (prioq_min(&pq,&pe))
  79     {
  80      prioq_delmin(&pq);
  81
  82      fd = open_read(filenames.s + pe.id);
  83      if (fd == -1) continue;
  84      substdio_fdbuf(&ssin,read,fd,inbuf,sizeof(inbuf));
  85
  86      if (!stralloc_copys(&sender,"?")) die_nomem();
  87      if (!stralloc_copys(&recipient,"?")) die_nomem();
  88      if (!stralloc_copys(&fromline,"")) die_nomem();
  89      if (!stralloc_copys(&text,"")) die_nomem();
  90      if (headerbody(&ssin,doheader,finishheader,dobody) == -1)
  91        strerr_die2x(111,FATAL,"trouble reading new message");
  92
  93      for (i = 0;i < fromline.len;++i)
  94        if ((fromline.s[i] < 32) || (fromline.s[i] > 126))
  95          fromline.s[i] = '/';
  96      for (i = 0;i < sender.len;++i)
  97        if ((sender.s[i] < 32) || (sender.s[i] > 126))
  98          sender.s[i] = '?';
  99      for (i = 0;i < recipient.len;++i)
 100        if ((recipient.s[i] < 32) || (recipient.s[i] > 126))
 101          recipient.s[i] = '?';
 102      for (i = 0;i < text.len;++i)
 103        if ((text.s[i] < 32) || (text.s[i] > 126))
 104          text.s[i] = '/';
 105      substdio_puts(subfdout,"FROM ");
 106      substdio_put(subfdout,sender.s,sender.len);
 107      substdio_puts(subfdout," TO <");
 108      substdio_put(subfdout,recipient.s,recipient.len);
 109      substdio_puts(subfdout,">\n");
 110      if (fromline.len)
 111       {
 112        substdio_puts(subfdout,"\033[1m");
 113        substdio_put(subfdout,fromline.s,fromline.len);
 114        substdio_puts(subfdout,"\033[0m\n");
 115       }
 116      substdio_put(subfdout,text.s,text.len);
 117      substdio_puts(subfdout,"\n\n");
 118
 119      close(fd);
 120     }
 121
 122    substdio_flush(subfdout);
 123    sleep(30);
 124   }
 125 }