122716Sdist /* 234921Sbostic * Copyright (c) 1983 Eric P. Allman 362532Sbostic * Copyright (c) 1988, 1993 462532Sbostic * The Regents of the University of California. All rights reserved. 533731Sbostic * 642831Sbostic * %sccs.include.redist.c% 733731Sbostic */ 822716Sdist 933731Sbostic # include "sendmail.h" 1022716Sdist 1133731Sbostic #ifndef lint 1233731Sbostic #ifdef SMTP 13*68559Seric static char sccsid[] = "@(#)usersmtp.c 8.39 (Berkeley) 03/21/95 (with SMTP)"; 1433731Sbostic #else 15*68559Seric static char sccsid[] = "@(#)usersmtp.c 8.39 (Berkeley) 03/21/95 (without SMTP)"; 1633731Sbostic #endif 1733731Sbostic #endif /* not lint */ 1833731Sbostic 194684Seric # include <sysexits.h> 2021065Seric # include <errno.h> 214684Seric 2233731Sbostic # ifdef SMTP 234684Seric 244684Seric /* 259391Seric ** USERSMTP -- run SMTP protocol from the user end. 269391Seric ** 279391Seric ** This protocol is described in RFC821. 289391Seric */ 299391Seric 309391Seric #define REPLYTYPE(r) ((r) / 100) /* first digit of reply code */ 319391Seric #define REPLYCLASS(r) (((r) / 10) % 10) /* second digit of reply code */ 329391Seric #define SMTPCLOSING 421 /* "Service Shutting Down" */ 339391Seric 3414900Seric char SmtpMsgBuffer[MAXLINE]; /* buffer for commands */ 3510054Seric char SmtpReplyBuffer[MAXLINE]; /* buffer for replies */ 3621065Seric char SmtpError[MAXLINE] = ""; /* save failure error messages */ 3710054Seric int SmtpPid; /* pid of mailer */ 3864071Seric bool SmtpNeedIntro; /* need "while talking" in transcript */ 3958671Seric 4058671Seric #ifdef __STDC__ 4158671Seric extern smtpmessage(char *f, MAILER *m, MCI *mci, ...); 4258671Seric #endif 439391Seric /* 444865Seric ** SMTPINIT -- initialize SMTP. 454684Seric ** 464865Seric ** Opens the connection and sends the initial protocol. 474684Seric ** 484684Seric ** Parameters: 494865Seric ** m -- mailer to create connection to. 504865Seric ** pvp -- pointer to parameter vector to pass to 514865Seric ** the mailer. 524684Seric ** 534684Seric ** Returns: 5454967Seric ** none. 554684Seric ** 564684Seric ** Side Effects: 574865Seric ** creates connection and sends initial protocol. 584684Seric */ 594684Seric 6054967Seric smtpinit(m, mci, e) 614865Seric struct mailer *m; 6254967Seric register MCI *mci; 6353751Seric ENVELOPE *e; 644684Seric { 654865Seric register int r; 6658957Seric register char *p; 6760210Seric extern void esmtp_check(); 6859285Seric extern void helo_options(); 694684Seric 7063753Seric if (tTd(18, 1)) 7157379Seric { 7257379Seric printf("smtpinit "); 7364731Seric mci_dump(mci, FALSE); 7457379Seric } 7557379Seric 764865Seric /* 774865Seric ** Open the connection to the mailer. 784865Seric */ 794684Seric 8021065Seric SmtpError[0] = '\0'; 8157379Seric CurHostName = mci->mci_host; /* XXX UGLY XXX */ 8268100Seric if (CurHostName == NULL) 8368100Seric CurHostName = MyHostName; 8464071Seric SmtpNeedIntro = TRUE; 8554967Seric switch (mci->mci_state) 866051Seric { 8754967Seric case MCIS_ACTIVE: 8854967Seric /* need to clear old information */ 8954967Seric smtprset(m, mci, e); 9057734Seric /* fall through */ 9115139Seric 9254967Seric case MCIS_OPEN: 9354967Seric return; 9454967Seric 9554967Seric case MCIS_ERROR: 9654967Seric case MCIS_SSD: 9754967Seric /* shouldn't happen */ 9854967Seric smtpquit(m, mci, e); 9957734Seric /* fall through */ 10054967Seric 10154967Seric case MCIS_CLOSED: 10258151Seric syserr("451 smtpinit: state CLOSED"); 10354967Seric return; 10454967Seric 10554967Seric case MCIS_OPENING: 10654967Seric break; 1076051Seric } 1084796Seric 10954967Seric mci->mci_state = MCIS_OPENING; 11054967Seric 1114865Seric /* 1124865Seric ** Get the greeting message. 11314913Seric ** This should appear spontaneously. Give it five minutes to 11414886Seric ** happen. 1154865Seric */ 1164797Seric 11761093Seric SmtpPhase = mci->mci_phase = "client greeting"; 11853751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 11960210Seric r = reply(m, mci, e, TimeOuts.to_initial, esmtp_check); 12064750Seric if (r < 0 || REPLYTYPE(r) == 4) 12152104Seric goto tempfail1; 12264750Seric if (REPLYTYPE(r) != 2) 12364750Seric goto unavailable; 1244684Seric 1254865Seric /* 1264976Seric ** Send the HELO command. 1277963Seric ** My mother taught me to always introduce myself. 1284976Seric */ 1294976Seric 13059285Seric if (bitnset(M_ESMTP, m->m_flags)) 13159285Seric mci->mci_flags |= MCIF_ESMTP; 13259285Seric 13359285Seric tryhelo: 13459285Seric if (bitset(MCIF_ESMTP, mci->mci_flags)) 13559285Seric { 13659285Seric smtpmessage("EHLO %s", m, mci, MyHostName); 13761093Seric SmtpPhase = mci->mci_phase = "client EHLO"; 13859285Seric } 13959285Seric else 14059285Seric { 14159285Seric smtpmessage("HELO %s", m, mci, MyHostName); 14261093Seric SmtpPhase = mci->mci_phase = "client HELO"; 14359285Seric } 14453751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 14559285Seric r = reply(m, mci, e, TimeOuts.to_helo, helo_options); 1468005Seric if (r < 0) 14752104Seric goto tempfail1; 1488005Seric else if (REPLYTYPE(r) == 5) 14959285Seric { 15059285Seric if (bitset(MCIF_ESMTP, mci->mci_flags)) 15159285Seric { 15259285Seric /* try old SMTP instead */ 15359285Seric mci->mci_flags &= ~MCIF_ESMTP; 15459285Seric goto tryhelo; 15559285Seric } 15614913Seric goto unavailable; 15759285Seric } 1587963Seric else if (REPLYTYPE(r) != 2) 15952104Seric goto tempfail1; 1604976Seric 1614976Seric /* 16258957Seric ** Check to see if we actually ended up talking to ourself. 16358957Seric ** This means we didn't know about an alias or MX, or we managed 16458957Seric ** to connect to an echo server. 16558957Seric */ 16658957Seric 16759026Seric p = strchr(&SmtpReplyBuffer[4], ' '); 16858957Seric if (p != NULL) 16961707Seric *p = '\0'; 17067472Seric if (!bitnset(M_NOLOOPCHECK, m->m_flags) && 17167472Seric strcasecmp(&SmtpReplyBuffer[4], MyHostName) == 0) 17258957Seric { 17358957Seric syserr("553 %s config error: mail loops back to myself", 17458957Seric MyHostName); 17558957Seric mci->mci_exitstat = EX_CONFIG; 17658957Seric mci->mci_errno = 0; 17758957Seric smtpquit(m, mci, e); 17858957Seric return; 17958957Seric } 18058957Seric 18158957Seric /* 1829315Seric ** If this is expected to be another sendmail, send some internal 1839315Seric ** commands. 1849315Seric */ 1859315Seric 18610688Seric if (bitnset(M_INTERNAL, m->m_flags)) 1879315Seric { 1889315Seric /* tell it to be verbose */ 18953751Seric smtpmessage("VERB", m, mci); 19059285Seric r = reply(m, mci, e, TimeOuts.to_miscshort, NULL); 1919315Seric if (r < 0) 19252104Seric goto tempfail2; 1939315Seric } 1949315Seric 19565057Seric if (mci->mci_state != MCIS_CLOSED) 19665057Seric { 19765057Seric mci->mci_state = MCIS_OPEN; 19865057Seric return; 19965057Seric } 20053751Seric 20165057Seric /* got a 421 error code during startup */ 20265057Seric 20353751Seric tempfail1: 20453751Seric tempfail2: 20553751Seric mci->mci_exitstat = EX_TEMPFAIL; 20657379Seric if (mci->mci_errno == 0) 20757379Seric mci->mci_errno = errno; 20857379Seric if (mci->mci_state != MCIS_CLOSED) 20957379Seric smtpquit(m, mci, e); 21054967Seric return; 21153751Seric 21253751Seric unavailable: 21353751Seric mci->mci_exitstat = EX_UNAVAILABLE; 21453751Seric mci->mci_errno = errno; 21553751Seric smtpquit(m, mci, e); 21654967Seric return; 21753751Seric } 21859285Seric /* 21960210Seric ** ESMTP_CHECK -- check to see if this implementation likes ESMTP protocol 22060210Seric ** 22160210Seric ** Parameters: 22260210Seric ** line -- the response line. 22367893Seric ** firstline -- set if this is the first line of the reply. 22460210Seric ** m -- the mailer. 22560210Seric ** mci -- the mailer connection info. 22660210Seric ** e -- the envelope. 22760210Seric ** 22860210Seric ** Returns: 22960210Seric ** none. 23060210Seric */ 23160210Seric 23260210Seric void 23367893Seric esmtp_check(line, firstline, m, mci, e) 23460210Seric char *line; 23567893Seric bool firstline; 23660210Seric MAILER *m; 23760210Seric register MCI *mci; 23860210Seric ENVELOPE *e; 23960210Seric { 240*68559Seric register char *l; 241*68559Seric 242*68559Seric for (l = line; (l = strchr(++l, 'E')) != NULL; ) 24367893Seric { 244*68559Seric if (strncmp(l, "ESMTP ", 6) == 0) 24567893Seric { 24667893Seric mci->mci_flags |= MCIF_ESMTP; 24767893Seric break; 24867893Seric } 24967893Seric } 250*68559Seric for (l = line; (l = strchr(++l, '8')) != NULL; ) 251*68559Seric { 252*68559Seric if (strncmp(l, "8BIT OK", 7) == 0) 253*68559Seric { 254*68559Seric mci->mci_flags |= MCIF_8BITOK; 255*68559Seric break; 256*68559Seric } 257*68559Seric } 25860210Seric } 25960210Seric /* 26059285Seric ** HELO_OPTIONS -- process the options on a HELO line. 26159285Seric ** 26259285Seric ** Parameters: 26359285Seric ** line -- the response line. 26467893Seric ** firstline -- set if this is the first line of the reply. 26559285Seric ** m -- the mailer. 26659285Seric ** mci -- the mailer connection info. 26759285Seric ** e -- the envelope. 26859285Seric ** 26959285Seric ** Returns: 27059285Seric ** none. 27159285Seric */ 27253751Seric 27359285Seric void 27467893Seric helo_options(line, firstline, m, mci, e) 27559285Seric char *line; 27667893Seric bool firstline; 27759285Seric MAILER *m; 27859285Seric register MCI *mci; 27959285Seric ENVELOPE *e; 28059285Seric { 28159285Seric register char *p; 28259285Seric 28367971Seric if (firstline) 28467893Seric return; 28567893Seric 28659285Seric if (strlen(line) < 5) 28759285Seric return; 28859285Seric line += 4; 28959285Seric p = strchr(line, ' '); 29059285Seric if (p != NULL) 29159285Seric *p++ = '\0'; 29259285Seric if (strcasecmp(line, "size") == 0) 29359285Seric { 29459285Seric mci->mci_flags |= MCIF_SIZE; 29559285Seric if (p != NULL) 29659285Seric mci->mci_maxsize = atol(p); 29759285Seric } 29859285Seric else if (strcasecmp(line, "8bitmime") == 0) 29965870Seric { 30059285Seric mci->mci_flags |= MCIF_8BITMIME; 30165870Seric mci->mci_flags &= ~MCIF_7BIT; 30265870Seric } 30359285Seric else if (strcasecmp(line, "expn") == 0) 30459285Seric mci->mci_flags |= MCIF_EXPN; 305*68559Seric else if (strcasecmp(line, "x-dsn-3") == 0) 30667880Seric mci->mci_flags |= MCIF_DSN; 30759285Seric } 30859285Seric /* 30959285Seric ** SMTPMAILFROM -- send MAIL command 31059285Seric ** 31159285Seric ** Parameters: 31259285Seric ** m -- the mailer. 31359285Seric ** mci -- the mailer connection structure. 31459285Seric ** e -- the envelope (including the sender to specify). 31559285Seric */ 31659285Seric 31753751Seric smtpmailfrom(m, mci, e) 31853751Seric struct mailer *m; 31954967Seric MCI *mci; 32053751Seric ENVELOPE *e; 32153751Seric { 32253751Seric int r; 32365494Seric char *bufp; 32467887Seric char *bodytype; 32568528Seric char buf[MAXNAME + 1]; 32659285Seric char optbuf[MAXLINE]; 32753751Seric 32863753Seric if (tTd(18, 2)) 32957943Seric printf("smtpmailfrom: CurHost=%s\n", CurHostName); 33057943Seric 33159285Seric /* set up appropriate options to include */ 33264254Seric if (bitset(MCIF_SIZE, mci->mci_flags) && e->e_msgsize > 0) 33359285Seric sprintf(optbuf, " SIZE=%ld", e->e_msgsize); 33459285Seric else 33559285Seric strcpy(optbuf, ""); 33659285Seric 33767887Seric bodytype = e->e_bodytype; 33867887Seric if (bitset(MCIF_8BITMIME, mci->mci_flags)) 33967417Seric { 34067887Seric if (bodytype == NULL && 34167887Seric bitset(MM_MIME8BIT, MimeMode) && 34267887Seric bitset(EF_HAS8BIT, e->e_flags) && 34367887Seric !bitnset(M_8BITS, m->m_flags)) 34467887Seric bodytype = "8BITMIME"; 34567887Seric if (bodytype != NULL) 34667417Seric { 34767417Seric strcat(optbuf, " BODY="); 34867887Seric strcat(optbuf, bodytype); 34967417Seric } 35067417Seric } 35167995Seric else if (bitnset(M_8BITS, m->m_flags) || 35267995Seric !bitset(EF_HAS8BIT, e->e_flags) || 35367995Seric (e->e_bodytype != NULL && 35467995Seric strcasecmp(e->e_bodytype, "7bit") == 0)) 35567887Seric { 35667887Seric /* just pass it through */ 35767887Seric } 35867887Seric else if (bitset(MM_CVTMIME, MimeMode) && 35967995Seric (e->e_bodytype != NULL || !bitset(MM_PASS8BIT, MimeMode))) 36067887Seric { 36167887Seric /* must convert from 8bit MIME format to 7bit encoded */ 36267887Seric mci->mci_flags |= MCIF_CVT8TO7; 36367887Seric } 36467887Seric else if (!bitset(MM_PASS8BIT, MimeMode)) 36567887Seric { 36667887Seric /* cannot just send a 8-bit version */ 36767887Seric usrerr("%s does not support 8BITMIME", mci->mci_host); 36867887Seric return EX_DATAERR; 36967887Seric } 37067417Seric 37167963Seric if (bitset(MCIF_DSN, mci->mci_flags)) 37267880Seric { 37367963Seric if (e->e_envid != NULL) 37467963Seric { 37567963Seric strcat(optbuf, " ENVID="); 37667963Seric strcat(optbuf, e->e_envid); 37767963Seric } 378*68559Seric 379*68559Seric /* RET= parameter */ 380*68559Seric if (bitset(EF_RET_PARAM, e->e_flags)) 381*68559Seric { 382*68559Seric strcat(optbuf, " RET="); 383*68559Seric if (bitset(EF_NO_BODY_RETN, e->e_flags)) 384*68559Seric strcat(optbuf, "HDRS"); 385*68559Seric else 386*68559Seric strcat(optbuf, "FULL"); 387*68559Seric } 38867880Seric } 38967880Seric 3909315Seric /* 3914865Seric ** Send the MAIL command. 3924865Seric ** Designates the sender. 3934865Seric */ 3944796Seric 39553751Seric mci->mci_state = MCIS_ACTIVE; 39653751Seric 39759540Seric if (bitset(EF_RESPONSE, e->e_flags) && 39859540Seric !bitnset(M_NO_NULL_FROM, m->m_flags)) 39958680Seric (void) strcpy(buf, ""); 40058680Seric else 40168529Seric expand("\201g", buf, sizeof buf, e); 40265494Seric if (buf[0] == '<') 40365494Seric { 40465494Seric /* strip off <angle brackets> (put back on below) */ 40565494Seric bufp = &buf[strlen(buf) - 1]; 40665494Seric if (*bufp == '>') 40765494Seric *bufp = '\0'; 40865494Seric bufp = &buf[1]; 40965494Seric } 41065494Seric else 41165494Seric bufp = buf; 41267472Seric if (bitnset(M_LOCALMAILER, e->e_from.q_mailer->m_flags) || 41310688Seric !bitnset(M_FROMPATH, m->m_flags)) 4148436Seric { 41565494Seric smtpmessage("MAIL From:<%s>%s", m, mci, bufp, optbuf); 4168436Seric } 4178436Seric else 4188436Seric { 41959285Seric smtpmessage("MAIL From:<@%s%c%s>%s", m, mci, MyHostName, 42065494Seric *bufp == '@' ? ',' : ':', bufp, optbuf); 4218436Seric } 42261093Seric SmtpPhase = mci->mci_phase = "client MAIL"; 42353751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 42459285Seric r = reply(m, mci, e, TimeOuts.to_mail, NULL); 4258005Seric if (r < 0 || REPLYTYPE(r) == 4) 42653751Seric { 42753751Seric mci->mci_exitstat = EX_TEMPFAIL; 42853751Seric mci->mci_errno = errno; 42953751Seric smtpquit(m, mci, e); 43053751Seric return EX_TEMPFAIL; 43153751Seric } 4327963Seric else if (r == 250) 43353751Seric { 43453751Seric return EX_OK; 43553751Seric } 43668075Seric else if (r == 501 || r == 553) 43768075Seric { 43868075Seric /* syntax error in arguments */ 43968075Seric smtpquit(m, mci, e); 44068075Seric return EX_DATAERR; 44168075Seric } 4427963Seric else if (r == 552) 44353751Seric { 44453751Seric /* signal service unavailable */ 44553751Seric smtpquit(m, mci, e); 44653751Seric return EX_UNAVAILABLE; 44753751Seric } 44814913Seric 44958008Seric #ifdef LOG 45058020Seric if (LogLevel > 1) 45158008Seric { 45267860Seric syslog(LOG_CRIT, "%s: %s: SMTP MAIL protocol error: %s", 45367860Seric e->e_id, mci->mci_host, SmtpReplyBuffer); 45458008Seric } 45558008Seric #endif 45658008Seric 45714913Seric /* protocol error -- close up */ 45853751Seric smtpquit(m, mci, e); 45953751Seric return EX_PROTOCOL; 4604684Seric } 4614684Seric /* 4624976Seric ** SMTPRCPT -- designate recipient. 4634797Seric ** 4644797Seric ** Parameters: 4654865Seric ** to -- address of recipient. 46610175Seric ** m -- the mailer we are sending to. 46757379Seric ** mci -- the connection info for this transaction. 46857379Seric ** e -- the envelope for this transaction. 4694797Seric ** 4704797Seric ** Returns: 4714865Seric ** exit status corresponding to recipient status. 4724797Seric ** 4734797Seric ** Side Effects: 4744865Seric ** Sends the mail via SMTP. 4754797Seric */ 4764797Seric 47753751Seric smtprcpt(to, m, mci, e) 4784865Seric ADDRESS *to; 47910175Seric register MAILER *m; 48054967Seric MCI *mci; 48153751Seric ENVELOPE *e; 4824797Seric { 4834797Seric register int r; 48467880Seric char optbuf[MAXLINE]; 4854797Seric 48667880Seric strcpy(optbuf, ""); 48767880Seric if (bitset(MCIF_DSN, mci->mci_flags)) 48867880Seric { 48967963Seric bool firstone = TRUE; 49067963Seric 49167987Seric /* NOTIFY= parameter */ 49267880Seric strcat(optbuf, " NOTIFY="); 49367987Seric if (bitset(QPINGONSUCCESS, to->q_flags)) 49467880Seric { 49567987Seric strcat(optbuf, "SUCCESS"); 49667963Seric firstone = FALSE; 49767880Seric } 49867987Seric if (bitset(QPINGONFAILURE, to->q_flags)) 49967880Seric { 50067971Seric if (!firstone) 50167963Seric strcat(optbuf, ","); 50267987Seric strcat(optbuf, "FAILURE"); 50367963Seric firstone = FALSE; 50467880Seric } 50567963Seric if (bitset(QPINGONDELAY, to->q_flags)) 50667880Seric { 50767971Seric if (!firstone) 50867963Seric strcat(optbuf, ","); 50967963Seric strcat(optbuf, "DELAY"); 51067963Seric firstone = FALSE; 51167963Seric } 51267963Seric if (firstone) 51367963Seric strcat(optbuf, "NEVER"); 51467963Seric 51567987Seric /* ORCPT= parameter */ 51667987Seric if (to->q_orcpt != NULL) 51767987Seric { 51867987Seric strcat(optbuf, " ORCPT="); 51967987Seric strcat(optbuf, to->q_orcpt); 52067987Seric } 52167880Seric } 5224865Seric 52367880Seric smtpmessage("RCPT To:<%s>%s", m, mci, to->q_user, optbuf); 52467880Seric 52561093Seric SmtpPhase = mci->mci_phase = "client RCPT"; 52653751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 52759285Seric r = reply(m, mci, e, TimeOuts.to_rcpt, NULL); 52867880Seric setstatus(to, SmtpReplyBuffer); 5298005Seric if (r < 0 || REPLYTYPE(r) == 4) 5304865Seric return (EX_TEMPFAIL); 5317963Seric else if (REPLYTYPE(r) == 2) 5327963Seric return (EX_OK); 5337964Seric else if (r == 550 || r == 551 || r == 553) 5347964Seric return (EX_NOUSER); 5357964Seric else if (r == 552 || r == 554) 5367964Seric return (EX_UNAVAILABLE); 53758008Seric 53858008Seric #ifdef LOG 53958020Seric if (LogLevel > 1) 54058008Seric { 54167860Seric syslog(LOG_CRIT, "%s: %s: SMTP RCPT protocol error: %s", 54267860Seric e->e_id, mci->mci_host, SmtpReplyBuffer); 54358008Seric } 54458008Seric #endif 54558008Seric 5467964Seric return (EX_PROTOCOL); 5474797Seric } 5484797Seric /* 54910175Seric ** SMTPDATA -- send the data and clean up the transaction. 5504684Seric ** 5514684Seric ** Parameters: 5524865Seric ** m -- mailer being sent to. 5536980Seric ** e -- the envelope for this message. 5544684Seric ** 5554684Seric ** Returns: 5564976Seric ** exit status corresponding to DATA command. 5574684Seric ** 5584684Seric ** Side Effects: 5594865Seric ** none. 5604684Seric */ 5614684Seric 56263753Seric static jmp_buf CtxDataTimeout; 56368433Seric static void datatimeout(); 56463753Seric 56553740Seric smtpdata(m, mci, e) 5664865Seric struct mailer *m; 56754967Seric register MCI *mci; 5686980Seric register ENVELOPE *e; 5694684Seric { 5704684Seric register int r; 57163753Seric register EVENT *ev; 57263753Seric time_t timeout; 5734684Seric 5744797Seric /* 5754797Seric ** Send the data. 57610175Seric ** First send the command and check that it is ok. 57710175Seric ** Then send the data. 57810175Seric ** Follow it up with a dot to terminate. 57910175Seric ** Finally get the results of the transaction. 5804797Seric */ 5814797Seric 58210175Seric /* send the command and check ok to proceed */ 58353751Seric smtpmessage("DATA", m, mci); 58461093Seric SmtpPhase = mci->mci_phase = "client DATA 354"; 58553751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 58659285Seric r = reply(m, mci, e, TimeOuts.to_datainit, NULL); 5878005Seric if (r < 0 || REPLYTYPE(r) == 4) 58857990Seric { 58957990Seric smtpquit(m, mci, e); 5904797Seric return (EX_TEMPFAIL); 59157990Seric } 5927963Seric else if (r == 554) 59357990Seric { 59457990Seric smtprset(m, mci, e); 5957963Seric return (EX_UNAVAILABLE); 59657990Seric } 5977963Seric else if (r != 354) 59857990Seric { 59958008Seric #ifdef LOG 60058020Seric if (LogLevel > 1) 60158008Seric { 60267860Seric syslog(LOG_CRIT, "%s: %s: SMTP DATA-1 protocol error: %s", 60367860Seric e->e_id, mci->mci_host, SmtpReplyBuffer); 60458008Seric } 60558008Seric #endif 60657990Seric smtprset(m, mci, e); 6077964Seric return (EX_PROTOCOL); 60857990Seric } 60910175Seric 61063757Seric /* 61163757Seric ** Set timeout around data writes. Make it at least large 61263757Seric ** enough for DNS timeouts on all recipients plus some fudge 61363757Seric ** factor. The main thing is that it should not be infinite. 61463757Seric */ 61563757Seric 61663753Seric if (setjmp(CtxDataTimeout) != 0) 61763753Seric { 61863753Seric mci->mci_errno = errno; 61963753Seric mci->mci_exitstat = EX_TEMPFAIL; 62063753Seric mci->mci_state = MCIS_ERROR; 62163753Seric syserr("451 timeout writing message to %s", mci->mci_host); 62263753Seric smtpquit(m, mci, e); 62363753Seric return EX_TEMPFAIL; 62463753Seric } 62563753Seric 62663787Seric timeout = e->e_msgsize / 16; 62763787Seric if (timeout < (time_t) 60) 62863787Seric timeout = (time_t) 60; 62963787Seric timeout += e->e_nrcpts * 90; 63063753Seric ev = setevent(timeout, datatimeout, 0); 63163753Seric 63267546Seric /* 63367546Seric ** Output the actual message. 63467546Seric */ 63567546Seric 63668228Seric (*e->e_puthdr)(mci, e->e_header, e); 63768228Seric (*e->e_putbody)(mci, e, NULL); 63810175Seric 63967546Seric /* 64067546Seric ** Cleanup after sending message. 64167546Seric */ 64267546Seric 64363753Seric clrevent(ev); 64463753Seric 64564718Seric if (ferror(mci->mci_out)) 64664718Seric { 64764718Seric /* error during processing -- don't send the dot */ 64864718Seric mci->mci_errno = EIO; 64964718Seric mci->mci_exitstat = EX_IOERR; 65064718Seric mci->mci_state = MCIS_ERROR; 65164718Seric smtpquit(m, mci, e); 65264718Seric return EX_IOERR; 65364718Seric } 65464718Seric 65510175Seric /* terminate the message */ 65653740Seric fprintf(mci->mci_out, ".%s", m->m_eol); 65763753Seric if (TrafficLogFile != NULL) 65863753Seric fprintf(TrafficLogFile, "%05d >>> .\n", getpid()); 65958120Seric if (Verbose) 66058151Seric nmessage(">>> ."); 66110175Seric 66210175Seric /* check for the results of the transaction */ 66361093Seric SmtpPhase = mci->mci_phase = "client DATA 250"; 66453751Seric setproctitle("%s %s: %s", e->e_id, CurHostName, mci->mci_phase); 66559285Seric r = reply(m, mci, e, TimeOuts.to_datafinal, NULL); 66653751Seric if (r < 0) 66757990Seric { 66857990Seric smtpquit(m, mci, e); 6694797Seric return (EX_TEMPFAIL); 67057990Seric } 67153751Seric mci->mci_state = MCIS_OPEN; 67258917Seric e->e_statmsg = newstr(&SmtpReplyBuffer[4]); 67353751Seric if (REPLYTYPE(r) == 4) 67453751Seric return (EX_TEMPFAIL); 6757963Seric else if (r == 250) 6767963Seric return (EX_OK); 6777963Seric else if (r == 552 || r == 554) 6787963Seric return (EX_UNAVAILABLE); 67958008Seric #ifdef LOG 68058020Seric if (LogLevel > 1) 68158008Seric { 68267860Seric syslog(LOG_CRIT, "%s: %s: SMTP DATA-2 protocol error: %s", 68367860Seric e->e_id, mci->mci_host, SmtpReplyBuffer); 68458008Seric } 68558008Seric #endif 6867964Seric return (EX_PROTOCOL); 6874684Seric } 68863753Seric 68963753Seric 69068433Seric static void 69163753Seric datatimeout() 69263753Seric { 69363753Seric longjmp(CtxDataTimeout, 1); 69463753Seric } 6954684Seric /* 6964865Seric ** SMTPQUIT -- close the SMTP connection. 6974865Seric ** 6984865Seric ** Parameters: 69915535Seric ** m -- a pointer to the mailer. 7004865Seric ** 7014865Seric ** Returns: 7024865Seric ** none. 7034865Seric ** 7044865Seric ** Side Effects: 7054865Seric ** sends the final protocol and closes the connection. 7064865Seric */ 7074865Seric 70853751Seric smtpquit(m, mci, e) 70953751Seric register MAILER *m; 71054967Seric register MCI *mci; 71153751Seric ENVELOPE *e; 7124865Seric { 71364822Seric bool oldSuprErrs = SuprErrs; 7144865Seric 71564822Seric /* 71664822Seric ** Suppress errors here -- we may be processing a different 71764822Seric ** job when we do the quit connection, and we don't want the 71864822Seric ** new job to be penalized for something that isn't it's 71964822Seric ** problem. 72064822Seric */ 72164822Seric 72264822Seric SuprErrs = TRUE; 72364822Seric 72454967Seric /* send the quit message if we haven't gotten I/O error */ 72553751Seric if (mci->mci_state != MCIS_ERROR) 7269391Seric { 72761093Seric SmtpPhase = "client QUIT"; 72853751Seric smtpmessage("QUIT", m, mci); 72959285Seric (void) reply(m, mci, e, TimeOuts.to_quit, NULL); 73064822Seric SuprErrs = oldSuprErrs; 73153740Seric if (mci->mci_state == MCIS_CLOSED) 73264822Seric { 73364822Seric SuprErrs = oldSuprErrs; 73410159Seric return; 73564822Seric } 7369391Seric } 7379391Seric 73852676Seric /* now actually close the connection and pick up the zombie */ 73965194Seric (void) endmailer(mci, e, NULL); 74064822Seric 74164822Seric SuprErrs = oldSuprErrs; 7424865Seric } 7434865Seric /* 74454967Seric ** SMTPRSET -- send a RSET (reset) command 74554967Seric */ 74654967Seric 74754967Seric smtprset(m, mci, e) 74854967Seric register MAILER *m; 74954967Seric register MCI *mci; 75054967Seric ENVELOPE *e; 75154967Seric { 75254967Seric int r; 75354967Seric 75461093Seric SmtpPhase = "client RSET"; 75554967Seric smtpmessage("RSET", m, mci); 75659285Seric r = reply(m, mci, e, TimeOuts.to_rset, NULL); 75757734Seric if (r < 0) 75857734Seric mci->mci_state = MCIS_ERROR; 75954967Seric else if (REPLYTYPE(r) == 2) 76057734Seric { 76157734Seric mci->mci_state = MCIS_OPEN; 76257734Seric return; 76357734Seric } 76457734Seric smtpquit(m, mci, e); 76554967Seric } 76654967Seric /* 76758867Seric ** SMTPPROBE -- check the connection state 76854967Seric */ 76954967Seric 77058867Seric smtpprobe(mci) 77154967Seric register MCI *mci; 77254967Seric { 77354967Seric int r; 77454967Seric MAILER *m = mci->mci_mailer; 77554967Seric extern ENVELOPE BlankEnvelope; 77654967Seric ENVELOPE *e = &BlankEnvelope; 77754967Seric 77861093Seric SmtpPhase = "client probe"; 77958867Seric smtpmessage("RSET", m, mci); 78059285Seric r = reply(m, mci, e, TimeOuts.to_miscshort, NULL); 78158061Seric if (r < 0 || REPLYTYPE(r) != 2) 78254967Seric smtpquit(m, mci, e); 78354967Seric return r; 78454967Seric } 78554967Seric /* 7864684Seric ** REPLY -- read arpanet reply 7874684Seric ** 7884684Seric ** Parameters: 78910175Seric ** m -- the mailer we are reading the reply from. 79057379Seric ** mci -- the mailer connection info structure. 79157379Seric ** e -- the current envelope. 79257379Seric ** timeout -- the timeout for reads. 79359285Seric ** pfunc -- processing function for second and subsequent 79459285Seric ** lines of response -- if null, no special 79559285Seric ** processing is done. 7964684Seric ** 7974684Seric ** Returns: 7984684Seric ** reply code it reads. 7994684Seric ** 8004684Seric ** Side Effects: 8014684Seric ** flushes the mail file. 8024684Seric */ 8034684Seric 80459285Seric reply(m, mci, e, timeout, pfunc) 80553751Seric MAILER *m; 80654967Seric MCI *mci; 80753751Seric ENVELOPE *e; 80859285Seric time_t timeout; 80959285Seric void (*pfunc)(); 8104684Seric { 81159014Seric register char *bufp; 81259014Seric register int r; 81359285Seric bool firstline = TRUE; 81458957Seric char junkbuf[MAXLINE]; 81558957Seric 81657379Seric if (mci->mci_out != NULL) 81757379Seric (void) fflush(mci->mci_out); 8184684Seric 8197677Seric if (tTd(18, 1)) 8204796Seric printf("reply\n"); 8214796Seric 8227356Seric /* 8237356Seric ** Read the input line, being careful not to hang. 8247356Seric */ 8257356Seric 82659014Seric for (bufp = SmtpReplyBuffer;; bufp = junkbuf) 8274684Seric { 8287356Seric register char *p; 82953751Seric extern time_t curtime(); 8304684Seric 8317685Seric /* actually do the read */ 83253751Seric if (e->e_xfp != NULL) 83353751Seric (void) fflush(e->e_xfp); /* for debugging */ 8347356Seric 83510054Seric /* if we are in the process of closing just give the code */ 83653740Seric if (mci->mci_state == MCIS_CLOSED) 83710054Seric return (SMTPCLOSING); 83810054Seric 83958680Seric if (mci->mci_out != NULL) 84058680Seric fflush(mci->mci_out); 84158680Seric 84210054Seric /* get the line from the other side */ 84361093Seric p = sfgets(bufp, MAXLINE, mci->mci_in, timeout, SmtpPhase); 84453751Seric mci->mci_lastuse = curtime(); 84553751Seric 84610054Seric if (p == NULL) 84710131Seric { 84863753Seric bool oldholderrs; 84910148Seric extern char MsgBuf[]; /* err.c */ 85010148Seric 85121065Seric /* if the remote end closed early, fake an error */ 85221065Seric if (errno == 0) 85321065Seric # ifdef ECONNRESET 85421065Seric errno = ECONNRESET; 85556795Seric # else /* ECONNRESET */ 85621065Seric errno = EPIPE; 85756795Seric # endif /* ECONNRESET */ 85821065Seric 85957379Seric mci->mci_errno = errno; 86057642Seric mci->mci_exitstat = EX_TEMPFAIL; 86163753Seric oldholderrs = HoldErrs; 86263753Seric HoldErrs = TRUE; 86363753Seric usrerr("451 reply: read error from %s", mci->mci_host); 86463753Seric 86510420Seric /* if debugging, pause so we can see state */ 86610420Seric if (tTd(18, 100)) 86710420Seric pause(); 86854967Seric mci->mci_state = MCIS_ERROR; 86953751Seric smtpquit(m, mci, e); 87063753Seric #ifdef XDEBUG 87163753Seric { 87263753Seric char wbuf[MAXLINE]; 87364082Seric char *p = wbuf; 87464082Seric if (e->e_to != NULL) 87564082Seric { 87664082Seric sprintf(p, "%s... ", e->e_to); 87764082Seric p += strlen(p); 87864082Seric } 87964082Seric sprintf(p, "reply(%s) during %s", 88064082Seric mci->mci_host, SmtpPhase); 88163753Seric checkfd012(wbuf); 88263753Seric } 88363753Seric #endif 88463753Seric HoldErrs = oldholderrs; 88510054Seric return (-1); 88610131Seric } 88758957Seric fixcrlf(bufp, TRUE); 88810054Seric 88963753Seric /* EHLO failure is not a real error */ 89063753Seric if (e->e_xfp != NULL && (bufp[0] == '4' || 89163753Seric (bufp[0] == '5' && strncmp(SmtpMsgBuffer, "EHLO", 4) != 0))) 89214900Seric { 89314900Seric /* serious error -- log the previous command */ 89464071Seric if (SmtpNeedIntro) 89564071Seric { 89664071Seric /* inform user who we are chatting with */ 89764071Seric fprintf(CurEnv->e_xfp, 89864071Seric "... while talking to %s:\n", 89964071Seric CurHostName); 90064071Seric SmtpNeedIntro = FALSE; 90164071Seric } 90259014Seric if (SmtpMsgBuffer[0] != '\0') 90359014Seric fprintf(e->e_xfp, ">>> %s\n", SmtpMsgBuffer); 90459014Seric SmtpMsgBuffer[0] = '\0'; 90514900Seric 90614900Seric /* now log the message as from the other side */ 90758957Seric fprintf(e->e_xfp, "<<< %s\n", bufp); 90814900Seric } 90914900Seric 91014900Seric /* display the input for verbose mode */ 91158120Seric if (Verbose) 91259956Seric nmessage("050 %s", bufp); 9137356Seric 91459285Seric /* process the line */ 91567893Seric if (pfunc != NULL) 91667893Seric (*pfunc)(bufp, firstline, m, mci, e); 91759285Seric 91859285Seric firstline = FALSE; 91959285Seric 9207356Seric /* if continuation is required, we can go on */ 92159014Seric if (bufp[3] == '-') 9224684Seric continue; 9237356Seric 92459014Seric /* ignore improperly formated input */ 92559014Seric if (!(isascii(bufp[0]) && isdigit(bufp[0]))) 92659014Seric continue; 92759014Seric 9287356Seric /* decode the reply code */ 92959014Seric r = atoi(bufp); 9307356Seric 9317356Seric /* extra semantics: 0xx codes are "informational" */ 93259014Seric if (r >= 100) 93359014Seric break; 93459014Seric } 9357356Seric 93659014Seric /* 93759014Seric ** Now look at SmtpReplyBuffer -- only care about the first 93859014Seric ** line of the response from here on out. 93959014Seric */ 94058061Seric 94159014Seric /* save temporary failure messages for posterity */ 94259014Seric if (SmtpReplyBuffer[0] == '4' && SmtpError[0] == '\0') 94359014Seric (void) strcpy(SmtpError, SmtpReplyBuffer); 9449391Seric 94559014Seric /* reply code 421 is "Service Shutting Down" */ 94659014Seric if (r == SMTPCLOSING && mci->mci_state != MCIS_SSD) 94759014Seric { 94859014Seric /* send the quit protocol */ 94959014Seric mci->mci_state = MCIS_SSD; 95059014Seric smtpquit(m, mci, e); 9514684Seric } 95259014Seric 95359014Seric return (r); 9544684Seric } 9554796Seric /* 9564865Seric ** SMTPMESSAGE -- send message to server 9574796Seric ** 9584796Seric ** Parameters: 9594796Seric ** f -- format 96010175Seric ** m -- the mailer to control formatting. 9614796Seric ** a, b, c -- parameters 9624796Seric ** 9634796Seric ** Returns: 9644796Seric ** none. 9654796Seric ** 9664796Seric ** Side Effects: 96753740Seric ** writes message to mci->mci_out. 9684796Seric */ 9694796Seric 9704865Seric /*VARARGS1*/ 97157642Seric #ifdef __STDC__ 97257642Seric smtpmessage(char *f, MAILER *m, MCI *mci, ...) 97357642Seric #else 97457642Seric smtpmessage(f, m, mci, va_alist) 9754796Seric char *f; 97610175Seric MAILER *m; 97754967Seric MCI *mci; 97857642Seric va_dcl 97957642Seric #endif 9804796Seric { 98156852Seric VA_LOCAL_DECL 98256852Seric 98357135Seric VA_START(mci); 98456852Seric (void) vsprintf(SmtpMsgBuffer, f, ap); 98556852Seric VA_END; 98658680Seric 98758120Seric if (tTd(18, 1) || Verbose) 98858151Seric nmessage(">>> %s", SmtpMsgBuffer); 98963753Seric if (TrafficLogFile != NULL) 99063753Seric fprintf(TrafficLogFile, "%05d >>> %s\n", getpid(), SmtpMsgBuffer); 99153740Seric if (mci->mci_out != NULL) 99258680Seric { 99353740Seric fprintf(mci->mci_out, "%s%s", SmtpMsgBuffer, 99454967Seric m == NULL ? "\r\n" : m->m_eol); 99558680Seric } 99659149Seric else if (tTd(18, 1)) 99758725Seric { 99859149Seric printf("smtpmessage: NULL mci_out\n"); 99958725Seric } 10004796Seric } 10015182Seric 100256795Seric # endif /* SMTP */ 1003