/*
 * rbsmtp.c  V0.8.01
 *
 * process incoming batched SMTP (Simple Mail Transfer Protocol) files
 *
 * (c) 1992-94 Stefan Becker
 *
 */

#include "uuxqt.h"

extern struct TagItem MailTags[];
static const char RCPTTOCmd[]="RCPT TO:";

/* Get user name from SMTP command line */
static char *GetUserName(char **line, BOOL terminate)
{
 char *bra,*ket;

 /* Find opening and closing braket */
 if ((bra=strchr(*line,'<')) && (ket=strchr(bra+1,'>'))) {
  /* Set string terminator */
  if (terminate) *ket='\0';

  /* Position read pointer after address */
  *line=ket+1;

  /* Return pointer to user name */
  return(bra+1);
 }
 return(NULL);
}

int ReceiveBSMTPFile(char *bsmtpfile, char *bsmtpbuf)
{
 char *mp=bsmtpbuf;
 char *mailfrom=NULL;
 char *rcptto=NULL;
 char *nextaddress;
 ULONG recipients;
 int rc=RETURN_OK;

 /* Filter CRs? */
 if (FilterCR) {
  char *rp=bsmtpbuf,*wp=bsmtpbuf;
  char c;

  /* Scan buffer */
  while (c=*rp++)
   /* CR found? */
   if (c!='\r') *wp++=c; /* No, copy character */

  /* Add string terminator */
  *wp='\0';
 }

 /* Process batch */
 while ((rc!=RETURN_FAIL) && mp && *mp) {
  char *endl;

  /* Set string terminator at end of command line */
  if (endl=strchr(mp,'\n')) *endl++='\0';

  /* Interpret SMTP command */
  if (strnicmp(mp,"MAIL FROM:",10)==0) {
   /* "MAIL FROM: <user>" - Recipient */
   /* Get user name */
   mp+=10;
   mailfrom=GetUserName(&mp,TRUE);

   /* Reset recipient data */
   rcptto=NULL;
   recipients=0;

  } else if (strnicmp(mp,RCPTTOCmd,8)==0) {
   /* "RCPT TO: <user>" - Recipient */
   char *tmp;

   /* Check user name */
   mp+=8;
   if (tmp=GetUserName(&mp,(rcptto == NULL) ? TRUE : FALSE)) {
    /* Valid recipient address */
    recipients++;

    /* First recipient? Yes, save pointers */
    if (rcptto==NULL) {
     rcptto=tmp;
     nextaddress=mp;
    }
   }

  } else if (strnicmp(mp,"DATA",4)==0) {
   /* "DATA" - Mail data. Check if mail data follows and    */
   /* search end of mail data  (a line with only "." on it) */
   if ((mp=endl) && (endl=strstr(endl,"\n.\n"))) {

    /* Check if From/To lines are set */
    if (mailfrom && rcptto) {

     /* Append string terminator */
     *endl='\0';
     endl+=3; /* Move end pointer behind '\n' */

     /* Process RFC Header */
     if (ScanRFCMessage(mp,MailTags,TRUE)) {

      /* Handle lines with a "." at the beginning */
      {
       char *lp=(char *) MailTags[MSGTAGS_TEXT].ti_Data;

       while (lp=strstr(lp,"\n.")) {
        /* Skip '\n' */
        lp++;

        /* Copy rest of message, removes first '.' on a line */
        memmove(lp,lp+1,endl-lp);
       }
      }

      /* Loop through all recipients */
      while (recipients-->0) {
       /* Process RFC Mail */
       if (ProcessRFCMail(rcptto))
        /* All OK */
        MailGood();

       else {
        /* Error */
        int tmprc;

        /* Log error */
        if ((tmprc=LogUMSError("BSMTP",bsmtpfile,"mail from",mailfrom,
                               mp-bsmtpbuf))==RETURN_FAIL) {
         rc=RETURN_FAIL;
         break; /* Real error, break loop */
        }

        /* Set error level */
        if (tmprc>rc) rc=tmprc;

        /* Count bad mail */
        MailBad();
       }

       /* Get next recipient */
       if (recipients>0)
        while (TRUE) {
         /* Goto begin of next line */
         nextaddress+=strlen(nextaddress)+1;

         /* "RCPT TO:" command? */
         if (strnicmp(nextaddress,RCPTTOCmd,8)==0) {
          /* Get user name */
          nextaddress+=8;
          if (rcptto=GetUserName(&nextaddress,TRUE))
           break; /* Valid address */
         }
        }
      }

      /* Corrupt RFC header */
     } else
      rc=RETURN_WARN;

    } else {
     ErrLog("(BSMTP) Missing 'MAIL FROM:' or 'RCPT TO:' line!\n");
     rc=RETURN_WARN;
    }

   } else {
    ErrLog("corrupted BSMTP file '%s' (offset: %d)!\n",bsmtpfile,
           mp-bsmtpbuf);
    rc=RETURN_WARN;
    break;
   }

   /* Reset user name pointer */
   mailfrom=NULL;

  } else if (strnicmp(mp,"QUIT",4)==0)
   /* "QUIT" - End of BSMTP file reached */
   break;

  /* Set pointer to next line */
  mp=endl;
 }
 return(rc);
}