1 #include "auto_qmail.h"

     2 #include "qmail.h"

     3 #include "received.h"

     4 #include "sig.h"

     5 #include "substdio.h"

     6 #include "readwrite.h"

     7 #include "exit.h"

     8 #include "now.h"

     9 #include "fmt.h"

    10 #include "env.h"

    11 

    12 void resources() { _exit(111); }

    13 

    14 int safewrite(fd,buf,len) int fd; char *buf; int len;

    15 {

    16   int r;

    17   r = write(fd,buf,len);

    18   if (r <= 0) _exit(0);

    19   return r;

    20 }

    21 int saferead(fd,buf,len) int fd; char *buf; int len;

    22 {

    23   int r;

    24   r = read(fd,buf,len);

    25   if (r <= 0) _exit(0);

    26   return r;

    27 }

    28 

    29 char ssinbuf[512];

    30 substdio ssin = SUBSTDIO_FDBUF(saferead,0,ssinbuf,sizeof ssinbuf);

    31 char ssoutbuf[256];

    32 substdio ssout = SUBSTDIO_FDBUF(safewrite,1,ssoutbuf,sizeof ssoutbuf);

    33 

    34 unsigned long bytesleft = 100;

    35 

    36 void getbyte(ch)

    37 char *ch;

    38 {

    39   if (!bytesleft--) _exit(100);

    40   substdio_get(&ssin,ch,1);

    41 }

    42 

    43 unsigned long getlen()

    44 {

    45   unsigned long len = 0;

    46   char ch;

    47 

    48   for (;;) {

    49     getbyte(&ch);

    50     if (ch == ':') return len;

    51     if (len > 200000000) resources();

    52     len = 10 * len + (ch - '0');

    53   }

    54 }

    55 

    56 void getcomma()

    57 {

    58   char ch;

    59   getbyte(&ch);

    60   if (ch != ',') _exit(100);

    61 }

    62 

    63 struct qmail qq;

    64 

    65 void identify()

    66 {

    67   char *remotehost;

    68   char *remoteinfo;

    69   char *remoteip;

    70   char *local;

    71 

    72   remotehost = env_get("TCPREMOTEHOST");

    73   if (!remotehost) remotehost = "unknown";

    74   remoteinfo = env_get("TCPREMOTEINFO");

    75   remoteip = env_get("TCPREMOTEIP");

    76   if (!remoteip) remoteip = "unknown";

    77   local = env_get("TCPLOCALHOST");

    78   if (!local) local = env_get("TCPLOCALIP");

    79   if (!local) local = "unknown";

    80  

    81   received(&qq,"QMQP",local,remoteip,remotehost,remoteinfo,(char *) 0);

    82 }

    83 

    84 char buf[1000];

    85 char strnum[FMT_ULONG];

    86 

    87 int getbuf()

    88 {

    89   unsigned long len;

    90   int i;

    91 

    92   len = getlen();

    93   if (len >= 1000) {

    94     for (i = 0;i < len;++i) getbyte(buf);

    95     getcomma();

    96     buf[0] = 0;

    97     return 0;

    98   }

    99 

   100   for (i = 0;i < len;++i) getbyte(buf + i);

   101   getcomma();

   102   buf[len] = 0;

   103   return byte_chr(buf,len,'\0') == len;

   104 }

   105 

   106 int flagok = 1;

   107 

   108 main()

   109 {

   110   char *result;

   111   unsigned long qp;

   112   unsigned long len;

   113   char ch;

   114 

   115   sig_pipeignore();

   116   sig_alarmcatch(resources);

   117   alarm(3600);

   118 

   119   bytesleft = getlen();

   120 

   121   len = getlen();

   122 

   123   if (chdir(auto_qmail) == -1) resources();

   124   if (qmail_open(&qq) == -1) resources();

   125   qp = qmail_qp(&qq);

   126   identify();

   127 

   128   while (len > 0) { /* XXX: could speed this up */

   129     getbyte(&ch);

   130     --len;

   131     qmail_put(&qq,&ch,1);

   132   }

   133   getcomma();

   134 

   135   if (getbuf())

   136     qmail_from(&qq,buf);

   137   else {

   138     qmail_from(&qq,"");

   139     qmail_fail(&qq);

   140     flagok = 0;

   141   }

   142 

   143   while (bytesleft)

   144     if (getbuf())

   145       qmail_to(&qq,buf);

   146     else {

   147       qmail_fail(&qq);

   148       flagok = 0;

   149     }

   150 

   151   bytesleft = 1;

   152   getcomma();

   153 

   154   result = qmail_close(&qq);

   155 

   156   if (!*result) {

   157     len = fmt_str(buf,"Kok ");

   158     len += fmt_ulong(buf + len,(unsigned long) now());

   159     len += fmt_str(buf + len," qp ");

   160     len += fmt_ulong(buf + len,qp);

   161     buf[len] = 0;

   162     result = buf;

   163   }

   164 

   165   if (!flagok)

   166     result = "Dsorry, I can't accept addresses like that (#5.1.3)";

   167 

   168   substdio_put(&ssout,strnum,fmt_ulong(strnum,(unsigned long) str_len(result)));

   169   substdio_puts(&ssout,":");

   170   substdio_puts(&ssout,result);

   171   substdio_puts(&ssout,",");

   172   substdio_flush(&ssout);

   173   _exit(0);

   174 }