#include "auto_qmail.h"

#include "qmail.h"

#include "received.h"

#include "sig.h"

#include "substdio.h"

#include "readwrite.h"

#include "exit.h"

#include "now.h"

#include "fmt.h"

#include "env.h"

void resources() { _exit(111); }

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

{

  int r;

  r = write(fd,buf,len);

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

  return r;

}

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

{

  int r;

  r = read(fd,buf,len);

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

  return r;

}

char ssinbuf[512];

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

char ssoutbuf[256];

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

unsigned long bytesleft = 100;

void getbyte(ch)

char *ch;

{

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

  substdio_get(&ssin,ch,1);

}

unsigned long getlen()

{

  unsigned long len = 0;

  char ch;

  for (;;) {

    getbyte(&ch);

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

    if (len > 200000000) resources();

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

  }

}

void getcomma()

{

  char ch;

  getbyte(&ch);

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

}

struct qmail qq;

void identify()

{

  char *remotehost;

  char *remoteinfo;

  char *remoteip;

  char *local;

  remotehost = env_get("TCPREMOTEHOST");

  if (!remotehost) remotehost = "unknown";

  remoteinfo = env_get("TCPREMOTEINFO");

  remoteip = env_get("TCPREMOTEIP");

  if (!remoteip) remoteip = "unknown";

  local = env_get("TCPLOCALHOST");

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

  if (!local) local = "unknown";

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

}

char buf[1000];

char strnum[FMT_ULONG];

int getbuf()

{

  unsigned long len;

  int i;

  len = getlen();

  if (len >= 1000) {

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

    getcomma();

    buf[0] = 0;

    return 0;

  }

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

  getcomma();

  buf[len] = 0;

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

}

int flagok = 1;

main()

{

  char *result;

  unsigned long qp;

  unsigned long len;

  char ch;

  sig_pipeignore();

  sig_alarmcatch(resources);

  alarm(3600);

  bytesleft = getlen();

  len = getlen();

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

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

  qp = qmail_qp(&qq);

  identify();

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

    getbyte(&ch);

    --len;

    qmail_put(&qq,&ch,1);

  }

  getcomma();

  if (getbuf())

    qmail_from(&qq,buf);

  else {

    qmail_from(&qq,"");

    qmail_fail(&qq);

    flagok = 0;

  }

  while (bytesleft)

    if (getbuf())

      qmail_to(&qq,buf);

    else {

      qmail_fail(&qq);

      flagok = 0;

    }

  bytesleft = 1;

  getcomma();

  result = qmail_close(&qq);

  if (!*result) {

    len = fmt_str(buf,"Kok ");

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

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

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

    buf[len] = 0;

    result = buf;

  }

  if (!flagok)

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

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

  substdio_puts(&ssout,":");

  substdio_puts(&ssout,result);

  substdio_puts(&ssout,",");

  substdio_flush(&ssout);

  _exit(0);

}