* RFC 2822 - Internet Message Format
* RFC 2920 - SMTP Service Extension for Command Pipelining
*
- * Copyright (c) 1998-2012 by the citadel.org team
+ * Copyright (c) 1998-2015 by the citadel.org team
*
- * This program is open source software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License version 3.
- *
- *
+ * This program is open source software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 3.
*
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
- * GNU General Public License for more details.
- *
- *
- *
- *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+ * GNU General Public License for more details.
*/
#include "sysdep.h"
#define SMTP_IS_STATE(WHICH_STATE) (ChrPtr(Msg->IO.IOBuf)[0] == WHICH_STATE)
#define SMTP_DBG_SEND() \
- EVS_syslog(LOG_DEBUG, "> %s\n", ChrPtr(Msg->IO.SendBuf.Buf))
+ syslog(LOG_DEBUG, "> %s\n", ChrPtr(Msg->IO.SendBuf.Buf))
#define SMTP_DBG_READ() \
- EVS_syslog(LOG_DEBUG, "< %s\n", ChrPtr(Msg->IO.IOBuf))
+ syslog(LOG_DEBUG, "< %s\n", ChrPtr(Msg->IO.IOBuf))
+/*
+ * if a Read handler wants to skip to a specific part use this macro.
+ * the -1 is here since the auto-forward following has to be taken into account.
+ */
+#define READ_NEXT_STATE(state) Msg->State = state - 1
/*****************************************************************************/
/* SMTP CLIENT STATE CALLBACKS */
eNextState SMTPC_send_EHLO(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
/* At this point we know we are talking to a real SMTP server */
/* Do a EHLO command. If it fails, try the HELO command. */
- StrBufPrintf(Msg->IO.SendBuf.Buf,
- "EHLO %s\r\n", config.c_fqdn);
+ StrBufPrintf(Msg->IO.SendBuf.Buf, "EHLO %s\r\n", CtdlGetConfigStr("c_fqdn"));
SMTP_DBG_SEND();
return eReadMessage;
eNextState SMTPC_read_EHLO_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
SMTP_DBG_READ();
if (SMTP_IS_STATE('2')) {
- Msg->State ++;
+ READ_NEXT_STATE(eSMTPAuth);
if ((Msg->pCurrRelay == NULL) ||
(Msg->pCurrRelay->User == NULL))
- Msg->State ++; /* Skip auth... */
+ READ_NEXT_STATE(eFROM); /* Skip auth... */
+ if (Msg->pCurrRelay != NULL)
+ {
+ if (strstr(ChrPtr(Msg->IO.IOBuf), "LOGIN") != NULL)
+ Msg->SendLogin = 1;
+ else if ((Msg->MultiLineBuf != NULL) &&
+ strstr(ChrPtr(Msg->MultiLineBuf), "LOGIN") != NULL)
+ {
+ Msg->SendLogin = 1;
+ }
+ }
}
/* else we fall back to 'helo' */
return eSendReply;
eNextState STMPC_send_HELO(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
- StrBufPrintf(Msg->IO.SendBuf.Buf,
- "HELO %s\r\n", config.c_fqdn);
+ StrBufPrintf(Msg->IO.SendBuf.Buf, "HELO %s\r\n", CtdlGetConfigStr("c_fqdn"));
SMTP_DBG_SEND();
return eReadMessage;
eNextState SMTPC_read_HELO_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
SMTP_DBG_READ();
if (!SMTP_IS_STATE('2'))
else
SMTP_VERROR(5);
}
+ if (Msg->pCurrRelay != NULL)
+ {
+ if (strstr(ChrPtr(Msg->IO.IOBuf), "LOGIN") != NULL)
+ Msg->SendLogin = 1;
+ }
if ((Msg->pCurrRelay == NULL) ||
(Msg->pCurrRelay->User == NULL))
- Msg->State ++; /* Skip auth... */
+ READ_NEXT_STATE(eFROM); /* Skip auth... */
return eSendReply;
}
eNextState SMTPC_send_auth(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
char buf[SIZ];
char encoded[1024];
if ((Msg->pCurrRelay == NULL) ||
(Msg->pCurrRelay->User == NULL))
- Msg->State ++; /* Skip auth, shouldn't even come here!... */
+ READ_NEXT_STATE(eFROM); /* Skip auth, shouldn't even come here!... */
else {
/* Do an AUTH command if necessary */
- sprintf(buf, "%s%c%s%c%s",
- Msg->pCurrRelay->User, '\0',
- Msg->pCurrRelay->User, '\0',
- Msg->pCurrRelay->Pass);
-
- CtdlEncodeBase64(encoded, buf,
- strlen(Msg->pCurrRelay->User) * 2 +
- strlen(Msg->pCurrRelay->Pass) + 2, 0);
+ if (Msg->SendLogin)
+ {
+ StrBufPlain(Msg->IO.SendBuf.Buf,
+ HKEY("AUTH LOGIN\r\n"));
+ }
+ else
+ {
+ sprintf(buf, "%s%c%s%c%s",
+ Msg->pCurrRelay->User, '\0',
+ Msg->pCurrRelay->User, '\0',
+ Msg->pCurrRelay->Pass);
+
+ size_t len = CtdlEncodeBase64(encoded, buf,
+ strlen(Msg->pCurrRelay->User) * 2 +
+ strlen(Msg->pCurrRelay->Pass) + 2, 0);
+
+ if (buf[len - 1] == '\n') {
+ buf[len - 1] = '\0';
+ }
- StrBufPrintf(Msg->IO.SendBuf.Buf,
- "AUTH PLAIN %s\r\n", encoded);
+ StrBufPrintf(Msg->IO.SendBuf.Buf,
+ "AUTH PLAIN %s\r\n",
+ encoded);
+ }
}
SMTP_DBG_SEND();
return eReadMessage;
}
+
eNextState SMTPC_read_auth_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
+ /* Do an AUTH command if necessary */
+
+ SMTP_DBG_READ();
+
+ if (Msg->SendLogin)
+ {
+ if (!SMTP_IS_STATE('3'))
+ SMTP_VERROR(5);
+ }
+ else
+ {
+ if (!SMTP_IS_STATE('2')) {
+ if (SMTP_IS_STATE('4'))
+ SMTP_VERROR(4);
+ else
+ SMTP_VERROR(5);
+ }
+ READ_NEXT_STATE(eFROM);
+ }
+ return eSendReply;
+}
+
+
+eNextState SMTPC_send_authplain_1(SmtpOutMsg *Msg)
+{
+ char buf[SIZ];
+ char encoded[1024];
+ long encodedlen;
+
+ sprintf(buf, "%s",
+ Msg->pCurrRelay->User);
+
+ encodedlen = CtdlEncodeBase64(
+ encoded,
+ Msg->pCurrRelay->User,
+ strlen(Msg->pCurrRelay->User),
+ 0);
+ if (encoded[encodedlen - 1] == '\n') {
+ encodedlen --;
+ encoded[encodedlen] = '\0';
+ }
+
+ StrBufPlain(Msg->IO.SendBuf.Buf,
+ encoded,
+ encodedlen);
+
+ StrBufAppendBufPlain(Msg->IO.SendBuf.Buf,
+ HKEY("\r\n"), 0);
+
+ SMTP_DBG_SEND();
+
+ return eReadMessage;
+}
+eNextState SMTPC_read_auth_plain_reply_1(SmtpOutMsg *Msg)
+{
+ /* Do an AUTH command if necessary */
+
+ SMTP_DBG_READ();
+
+ if (!SMTP_IS_STATE('3'))
+ SMTP_VERROR(5);
+ return eSendReply;
+}
+
+
+eNextState SMTPC_send_authplain_2(SmtpOutMsg *Msg)
+{
+ char buf[SIZ];
+ char encoded[1024];
+ long encodedlen;
+
+ sprintf(buf, "%s",
+ Msg->pCurrRelay->Pass);
+
+ encodedlen = CtdlEncodeBase64(
+ encoded,
+ Msg->pCurrRelay->Pass,
+ strlen(Msg->pCurrRelay->Pass),
+ 0);
+
+ if (encoded[encodedlen - 1] == '\n') {
+ encodedlen --;
+ encoded[encodedlen] = '\0';
+ }
+
+ StrBufPlain(Msg->IO.SendBuf.Buf,
+ encoded,
+ encodedlen);
+
+ StrBufAppendBufPlain(Msg->IO.SendBuf.Buf,
+ HKEY("\r\n"), 0);
+
+ SMTP_DBG_SEND();
+
+ return eReadMessage;
+}
+eNextState SMTPC_read_auth_plain_reply_2(SmtpOutMsg *Msg)
+{
/* Do an AUTH command if necessary */
SMTP_DBG_READ();
eNextState SMTPC_send_FROM(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
/* previous command succeeded, now try the MAIL FROM: command */
StrBufPrintf(Msg->IO.SendBuf.Buf,
"MAIL FROM:<%s>\r\n",
eNextState SMTPC_read_FROM_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
SMTP_DBG_READ();
if (!SMTP_IS_STATE('2')) {
eNextState SMTPC_send_RCPT(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
/* MAIL succeeded, now try the RCPT To: command */
StrBufPrintf(Msg->IO.SendBuf.Buf,
"RCPT TO:<%s@%s>\r\n",
eNextState SMTPC_read_RCPT_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
SMTP_DBG_READ();
if (!SMTP_IS_STATE('2')) {
eNextState SMTPC_send_DATAcmd(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
/* RCPT succeeded, now try the DATA command */
StrBufPlain(Msg->IO.SendBuf.Buf,
HKEY("DATA\r\n"));
Buf = Msg->IO.SendBuf.Buf;
Msg->IO.SendBuf.Buf = Msg->msgtext;
Msg->msgtext = Buf;
+ /*
+ * sending the message itself doesn't use this state machine.
+ * so we have to operate it here by ourselves.
+ */
Msg->State ++;
return eSendMore;
eNextState SMTPC_send_QUIT(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
StrBufPlain(Msg->IO.SendBuf.Buf,
HKEY("QUIT\r\n"));
eNextState SMTPC_read_QUIT_reply(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
SMTP_DBG_READ();
- EVS_syslog(LOG_DEBUG,
+ syslog(LOG_DEBUG,
"delivery to <%s> @ <%s> (%s) succeeded\n",
Msg->user,
Msg->node,
SMTPC_read_EHLO_reply,
SMTPC_read_HELO_reply,
SMTPC_read_auth_reply,
+ SMTPC_read_auth_plain_reply_1,
+ SMTPC_read_auth_plain_reply_2,
SMTPC_read_FROM_reply,
SMTPC_read_RCPT_reply,
SMTPC_read_DATAcmd_reply,
SMTPC_send_EHLO,
STMPC_send_HELO,
SMTPC_send_auth,
+ SMTPC_send_authplain_1,
+ SMTPC_send_authplain_2,
SMTPC_send_FROM,
SMTPC_send_RCPT,
SMTPC_send_DATAcmd,
30., /* EHLO */
30., /* HELO */
30., /* Auth */
+ 30., /* Auth */
+ 30., /* Auth */
30., /* From */
90., /* RCPT */
30., /* DATA */
30., /* EHLO */
30., /* HELO */
30., /* Auth */
+ 30., /* Auth */
+ 30., /* Auth */
30., /* From */
30., /* RCPT */
30., /* DATA */
{HKEY("Connection broken during SMTP EHLO")},
{HKEY("Connection broken during SMTP HELO")},
{HKEY("Connection broken during SMTP AUTH")},
+ {HKEY("Connection broken during SMTP AUTH PLAIN I")},
+ {HKEY("Connection broken during SMTP AUTH PLAIN II")},
{HKEY("Connection broken during SMTP MAIL FROM")},
{HKEY("Connection broken during SMTP RCPT")},
{HKEY("Connection broken during SMTP DATA")},
int smtp_resolve_recipients(SmtpOutMsg *Msg)
{
- AsyncIO *IO = &Msg->IO;
const char *ptr;
char buf[1024];
int scan_done;
int lp, rp;
int i;
- EVNCS_syslog(LOG_DEBUG, "%s\n", __FUNCTION__);
+ syslog(LOG_DEBUG, "%s\n", __FUNCTION__);
if ((Msg==NULL) ||
(Msg->MyQEntry == NULL) ||
Msg->node,
Msg->name);
- EVNCS_syslog(LOG_DEBUG,
+ syslog(LOG_DEBUG,
"Attempting delivery to <%s> @ <%s> (%s)\n",
Msg->user,
Msg->node,