1 #include "stralloc.h"

     2 #include "substdio.h"

     3 #include "qmail.h"

     4 #include "now.h"

     5 #include "str.h"

     6 #include "fmt.h"

     7 #include "env.h"

     8 #include "sig.h"

     9 #include "rcpthosts.h"

    10 #include "auto_qmail.h"

    11 #include "readwrite.h"

    12 #include "control.h"

    13 #include "received.h"

    14 

    15 void badproto() { _exit(100); }

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

    17 

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

    19 {

    20   int r;

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

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

    23   return r;

    24 }

    25 

    26 char ssoutbuf[256];

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

    28 

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

    30 {

    31   int r;

    32   substdio_flush(&ssout);

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

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

    35   return r;

    36 }

    37 

    38 char ssinbuf[512];

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

    40 

    41 unsigned long getlen()

    42 {

    43   unsigned long len = 0;

    44   char ch;

    45   for (;;) {

    46     substdio_get(&ssin,&ch,1);

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

    48     if (len > 200000000) resources();

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

    50   }

    51 }

    52 

    53 void getcomma()

    54 {

    55   char ch;

    56   substdio_get(&ssin,&ch,1);

    57   if (ch != ',') badproto();

    58 }

    59 

    60 unsigned int databytes = 0;

    61 unsigned int bytestooverflow = 0;

    62 struct qmail qq;

    63 

    64 char buf[1000];

    65 char buf2[100];

    66 

    67 char *remotehost;

    68 char *remoteinfo;

    69 char *remoteip;

    70 char *local;

    71 

    72 stralloc failure = {0};

    73 

    74 char *relayclient;

    75 int relayclientlen;

    76 

    77 main()

    78 {

    79   char ch;

    80   int i;

    81   unsigned long biglen;

    82   unsigned long len;

    83   int flagdos;

    84   int flagsenderok;

    85   int flagbother;

    86   unsigned long qp;

    87   char *result;

    88   char *x;

    89   unsigned long u;

    90  

    91   sig_pipeignore();

    92   sig_alarmcatch(resources);

    93   alarm(3600);

    94  

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

    96  

    97   if (control_init() == -1) resources();

    98   if (rcpthosts_init() == -1) resources();

    99   relayclient = env_get("RELAYCLIENT");

   100   relayclientlen = relayclient ? str_len(relayclient) : 0;

   101  

   102   if (control_readint(&databytes,"control/databytes") == -1) resources();

   103   x = env_get("DATABYTES");

   104   if (x) { scan_ulong(x,&u); databytes = u; }

   105   if (!(databytes + 1)) --databytes;

   106  

   107   remotehost = env_get("TCPREMOTEHOST");

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

   109   remoteinfo = env_get("TCPREMOTEINFO");

   110   remoteip = env_get("TCPREMOTEIP");

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

   112   local = env_get("TCPLOCALHOST");

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

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

   115  

   116   for (;;) {

   117     if (!stralloc_copys(&failure,"")) resources();

   118     flagsenderok = 1;

   119  

   120     len = getlen();

   121     if (len == 0) badproto();

   122  

   123     if (databytes) bytestooverflow = databytes + 1;

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

   125     qp = qmail_qp(&qq);

   126  

   127     substdio_get(&ssin,&ch,1);

   128     --len;

   129     if (ch == 10) flagdos = 0;

   130     else if (ch == 13) flagdos = 1;

   131     else badproto();

   132  

   133     received(&qq,"QMTP",local,remoteip,remotehost,remoteinfo,(char *) 0);

   134  

   135     /* XXX: check for loops? only if len is big? */

   136  

   137     if (flagdos)

   138       while (len > 0) {

   139         substdio_get(&ssin,&ch,1);

   140         --len;

   141         while ((ch == 13) && len) {

   142           substdio_get(&ssin,&ch,1);

   143           --len;

   144           if (ch == 10) break;

   145           if (bytestooverflow) if (!--bytestooverflow) qmail_fail(&qq);

   146           qmail_put(&qq,"\015",1);

   147         }

   148         if (bytestooverflow) if (!--bytestooverflow) qmail_fail(&qq);

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

   150       }

   151     else {

   152       if (databytes)

   153         if (len > databytes) {

   154           bytestooverflow = 0;

   155           qmail_fail(&qq);

   156         }

   157       while (len > 0) { /* XXX: could speed this up, obviously */

   158         substdio_get(&ssin,&ch,1);

   159         --len;

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

   161       }

   162     }

   163     getcomma();

   164  

   165     len = getlen();

   166  

   167     if (len >= 1000) {

   168       buf[0] = 0;

   169       flagsenderok = 0;

   170       for (i = 0;i < len;++i)

   171         substdio_get(&ssin,&ch,1);

   172     }

   173     else {

   174       for (i = 0;i < len;++i) {

   175         substdio_get(&ssin,buf + i,1);

   176         if (!buf[i]) flagsenderok = 0;

   177       }

   178       buf[len] = 0;

   179     }

   180     getcomma();

   181  

   182     flagbother = 0;

   183     qmail_from(&qq,buf);

   184     if (!flagsenderok) qmail_fail(&qq);

   185  

   186     biglen = getlen();

   187     while (biglen > 0) {

   188       if (!stralloc_append(&failure,"")) resources();

   189  

   190       len = 0;

   191       for (;;) {

   192         if (!biglen) badproto();

   193         substdio_get(&ssin,&ch,1);

   194         --biglen;

   195         if (ch == ':') break;

   196         if (len > 200000000) resources();

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

   198       }

   199       if (len >= biglen) badproto();

   200       if (len + relayclientlen >= 1000) {

   201         failure.s[failure.len - 1] = 'L';

   202         for (i = 0;i < len;++i)

   203           substdio_get(&ssin,&ch,1);

   204       }

   205       else {

   206         for (i = 0;i < len;++i) {

   207           substdio_get(&ssin,buf + i,1);

   208           if (!buf[i]) failure.s[failure.len - 1] = 'N';

   209         }

   210         buf[len] = 0;

   211  

   212         if (relayclient)

   213           str_copy(buf + len,relayclient);

   214         else

   215           switch(rcpthosts(buf,len)) {

   216             case -1: resources();

   217             case 0: failure.s[failure.len - 1] = 'D';

   218           }

   219  

   220         if (!failure.s[failure.len - 1]) {

   221           qmail_to(&qq,buf);

   222           flagbother = 1;

   223         }

   224       }

   225       getcomma();

   226       biglen -= (len + 1);

   227     }

   228     getcomma();

   229  

   230     if (!flagbother) qmail_fail(&qq);

   231     result = qmail_close(&qq);

   232     if (!flagsenderok) result = "Dunacceptable sender (#5.1.7)";

   233     if (databytes) if (!bytestooverflow) result = "Dsorry, that message size exceeds my databytes limit (#5.3.4)";

   234  

   235     if (*result)

   236       len = str_len(result);

   237     else {

   238       /* success! */

   239       len = 0;

   240       len += fmt_str(buf2 + len,"Kok ");

   241       len += fmt_ulong(buf2 + len,(unsigned long) now());

   242       len += fmt_str(buf2 + len," qp ");

   243       len += fmt_ulong(buf2 + len,qp);

   244       buf2[len] = 0;

   245       result = buf2;

   246     }

   247       

   248     len = fmt_ulong(buf,len);

   249     buf[len++] = ':';

   250     len += fmt_str(buf + len,result);

   251     buf[len++] = ',';

   252  

   253     for (i = 0;i < failure.len;++i)

   254       switch(failure.s[i]) {

   255         case 0:

   256           substdio_put(&ssout,buf,len);

   257           break;

   258         case 'D':

   259           substdio_puts(&ssout,"66:Dsorry, that domain isn't in my list of allowed rcpthosts (#5.7.1),");

   260           break;

   261         default:

   262           substdio_puts(&ssout,"46:Dsorry, I can't handle that recipient (#5.1.3),");

   263           break;

   264       }

   265  

   266     /* ssout will be flushed when we read from the network again */

   267   }

   268 }