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 }