wine/dlls/inetcomm/smtptransport.c
2012-08-13 16:28:47 +02:00

1051 lines
31 KiB
C

/*
* SMTP Transport
*
* Copyright 2006 Robert Shearman for CodeWeavers
* Copyright 2008 Hans Leidekker for CodeWeavers
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* This library 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, write to the Free Software
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301, USA
*
*/
#define COBJMACROS
#include <stdarg.h>
#include <stdio.h>
#include "windef.h"
#include "winbase.h"
#include "winnt.h"
#include "winuser.h"
#include "objbase.h"
#include "mimeole.h"
#include "wine/debug.h"
#include "inetcomm_private.h"
WINE_DEFAULT_DEBUG_CHANNEL(inetcomm);
typedef struct
{
InternetTransport InetTransport;
ULONG refs;
BOOL fESMTP;
SMTPMESSAGE pending_message;
INETADDR *addrlist;
ULONG ulCurrentAddressIndex;
} SMTPTransport;
static HRESULT SMTPTransport_ParseResponse(SMTPTransport *This, char *pszResponse, SMTPRESPONSE *pResponse)
{
HRESULT hrServerError;
TRACE("response: %s\n", debugstr_a(pszResponse));
if (!isdigit(*pszResponse))
return IXP_E_SMTP_RESPONSE_ERROR;
pResponse->pTransport = (ISMTPTransport *)&This->InetTransport.u.vtblSMTP2;
pResponse->rIxpResult.pszResponse = pszResponse;
pResponse->rIxpResult.dwSocketError = 0;
pResponse->rIxpResult.uiServerError = strtol(pszResponse, &pszResponse, 10);
if (*pszResponse == '-')
{
pResponse->fDone = FALSE;
pszResponse++;
}
else
pResponse->fDone = TRUE;
switch (pResponse->rIxpResult.uiServerError)
{
case 211: hrServerError = IXP_E_SMTP_211_SYSTEM_STATUS; break;
case 214: hrServerError = IXP_E_SMTP_214_HELP_MESSAGE; break;
case 220: hrServerError = IXP_E_SMTP_220_READY; break;
case 221: hrServerError = IXP_E_SMTP_221_CLOSING; break;
case 245: hrServerError = IXP_E_SMTP_245_AUTH_SUCCESS; break;
case 250: hrServerError = IXP_E_SMTP_250_MAIL_ACTION_OKAY; break;
case 251: hrServerError = IXP_E_SMTP_251_FORWARDING_MAIL; break;
case 334: hrServerError = IXP_E_SMTP_334_AUTH_READY_RESPONSE; break;
case 354: hrServerError = IXP_E_SMTP_354_START_MAIL_INPUT; break;
case 421: hrServerError = IXP_E_SMTP_421_NOT_AVAILABLE; break;
case 450: hrServerError = IXP_E_SMTP_450_MAILBOX_BUSY; break;
case 451: hrServerError = IXP_E_SMTP_451_ERROR_PROCESSING; break;
case 452: hrServerError = IXP_E_SMTP_452_NO_SYSTEM_STORAGE; break;
case 454: hrServerError = IXP_E_SMTP_454_STARTTLS_FAILED; break;
case 500: hrServerError = IXP_E_SMTP_500_SYNTAX_ERROR; break;
case 501: hrServerError = IXP_E_SMTP_501_PARAM_SYNTAX; break;
case 502: hrServerError = IXP_E_SMTP_502_COMMAND_NOTIMPL; break;
case 503: hrServerError = IXP_E_SMTP_503_COMMAND_SEQ; break;
case 504: hrServerError = IXP_E_SMTP_504_COMMAND_PARAM_NOTIMPL; break;
case 530: hrServerError = IXP_E_SMTP_530_STARTTLS_REQUIRED; break;
case 550: hrServerError = IXP_E_SMTP_550_MAILBOX_NOT_FOUND; break;
case 551: hrServerError = IXP_E_SMTP_551_USER_NOT_LOCAL; break;
case 552: hrServerError = IXP_E_SMTP_552_STORAGE_OVERFLOW; break;
case 553: hrServerError = IXP_E_SMTP_553_MAILBOX_NAME_SYNTAX; break;
case 554: hrServerError = IXP_E_SMTP_554_TRANSACT_FAILED; break;
default:
hrServerError = IXP_E_SMTP_RESPONSE_ERROR;
break;
}
pResponse->rIxpResult.hrResult = hrServerError;
pResponse->rIxpResult.hrServerError = hrServerError;
if (This->InetTransport.pCallback && This->InetTransport.fCommandLogging)
{
ITransportCallback_OnCommand(This->InetTransport.pCallback, CMD_RESP,
pResponse->rIxpResult.pszResponse, hrServerError,
(IInternetTransport *)&This->InetTransport.u.vtbl);
}
return S_OK;
}
static void SMTPTransport_CallbackDoNothing(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
TRACE("\n");
}
static void SMTPTransport_CallbackReadResponseDoNothing(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackDoNothing);
}
static void SMTPTransport_CallbackProcessDATAResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
response.command = SMTP_DATA;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
}
static void SMTPTransport_CallbackReadDATAResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackProcessDATAResponse);
}
static void SMTPTransport_CallbackProcessMAILResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
response.command = SMTP_MAIL;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
}
static void SMTPTransport_CallbackReadMAILResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackProcessMAILResponse);
}
static void SMTPTransport_CallbackProcessRCPTResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
TRACE("\n");
HeapFree(GetProcessHeap(), 0, This->addrlist);
This->addrlist = NULL;
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
response.command = SMTP_RCPT;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
}
static void SMTPTransport_CallbackReadRCPTResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackProcessRCPTResponse);
}
static void SMTPTransport_CallbackProcessHelloResp(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
response.command = This->fESMTP ? SMTP_EHLO : SMTP_HELO;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
if (!response.fDone)
{
InternetTransport_ReadLine(&This->InetTransport,
SMTPTransport_CallbackProcessHelloResp);
return;
}
/* FIXME: try to authorize */
/* always changed to this status, even if authorization not support on server */
InternetTransport_ChangeStatus(&This->InetTransport, IXP_AUTHORIZED);
InternetTransport_ChangeStatus(&This->InetTransport, IXP_CONNECTED);
memset(&response, 0, sizeof(response));
response.command = SMTP_CONNECTED;
response.fDone = TRUE;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
}
static void SMTPTransport_CallbackRecvHelloResp(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackProcessHelloResp);
}
static void SMTPTransport_CallbackSendHello(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
const char *pszHello;
char *pszCommand;
const char szHostName[] = "localhost"; /* FIXME */
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
response.command = SMTP_BANNER;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
TRACE("(%s)\n", pBuffer);
This->fESMTP = strstr(response.rIxpResult.pszResponse, "ESMTP") &&
This->InetTransport.ServerInfo.dwFlags & (ISF_SSLONSAMEPORT|ISF_QUERYDSNSUPPORT|ISF_QUERYAUTHSUPPORT);
if (This->fESMTP)
pszHello = "EHLO ";
else
pszHello = "HELO ";
pszCommand = HeapAlloc(GetProcessHeap(), 0, strlen(pszHello) + strlen(szHostName) + 2);
strcpy(pszCommand, pszHello);
strcat(pszCommand, szHostName);
pszCommand[strlen(pszCommand)+1] = '\0';
pszCommand[strlen(pszCommand)] = '\n';
InternetTransport_DoCommand(&This->InetTransport, pszCommand,
SMTPTransport_CallbackRecvHelloResp);
HeapFree(GetProcessHeap(), 0, pszCommand);
}
static void SMTPTransport_CallbackDisconnect(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response;
HRESULT hr;
TRACE("\n");
if (pBuffer)
{
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
}
InternetTransport_DropConnection(&This->InetTransport);
}
static void SMTPTransport_CallbackMessageProcessResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response = { 0 };
HRESULT hr;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
response.command = SMTP_SEND_MESSAGE;
response.rIxpResult.hrResult = S_OK;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
}
static void SMTPTransport_CallbackMessageReadResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackMessageProcessResponse);
}
static void SMTPTransport_CallbackMessageSendDOT(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
IStream_Release(This->pending_message.pstmMsg);
InternetTransport_DoCommand(&This->InetTransport, "\n.\n",
SMTPTransport_CallbackMessageReadResponse);
}
static void SMTPTransport_CallbackMessageSendDataStream(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response;
HRESULT hr;
char *pszBuffer;
ULONG cbSize;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
pszBuffer = HeapAlloc(GetProcessHeap(), 0, This->pending_message.cbSize);
hr = IStream_Read(This->pending_message.pstmMsg, pszBuffer, This->pending_message.cbSize, NULL);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
cbSize = This->pending_message.cbSize;
/* FIXME: map "\n.\n" to "\n..\n", reallocate memory, update cbSize */
/* FIXME: properly stream the message rather than writing it all at once */
hr = InternetTransport_Write(&This->InetTransport, pszBuffer, cbSize,
SMTPTransport_CallbackMessageSendDOT);
HeapFree(GetProcessHeap(), 0, pszBuffer);
}
static void SMTPTransport_CallbackMessageReadDataResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackMessageSendDataStream);
}
static void SMTPTransport_CallbackMessageSendTo(IInternetTransport *iface, char *pBuffer, int cbBuffer);
static void SMTPTransport_CallbackMessageReadToResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackMessageSendTo);
}
static void SMTPTransport_CallbackMessageSendTo(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
SMTPRESPONSE response;
HRESULT hr;
TRACE("\n");
hr = SMTPTransport_ParseResponse(This, pBuffer, &response);
if (FAILED(hr))
{
/* FIXME: handle error */
return;
}
if (FAILED(response.rIxpResult.hrServerError))
{
ERR("server error: %s\n", debugstr_a(pBuffer));
/* FIXME: handle error */
return;
}
for (; This->ulCurrentAddressIndex < This->pending_message.rAddressList.cAddress; This->ulCurrentAddressIndex++)
{
TRACE("address[%d]: %s\n", This->ulCurrentAddressIndex,
This->pending_message.rAddressList.prgAddress[This->ulCurrentAddressIndex].szEmail);
if ((This->pending_message.rAddressList.prgAddress[This->ulCurrentAddressIndex].addrtype & ADDR_TOFROM_MASK) == ADDR_TO)
{
const char szCommandFormat[] = "RCPT TO: <%s>\n";
char *szCommand;
int len = sizeof(szCommandFormat) - 2 /* "%s" */ +
strlen(This->pending_message.rAddressList.prgAddress[This->ulCurrentAddressIndex].szEmail);
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return;
sprintf(szCommand, szCommandFormat,
This->pending_message.rAddressList.prgAddress[This->ulCurrentAddressIndex].szEmail);
This->ulCurrentAddressIndex++;
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackMessageReadToResponse);
HeapFree(GetProcessHeap(), 0, szCommand);
return;
}
}
hr = InternetTransport_DoCommand(&This->InetTransport, "DATA\n",
SMTPTransport_CallbackMessageReadDataResponse);
}
static void SMTPTransport_CallbackMessageReadFromResponse(IInternetTransport *iface, char *pBuffer, int cbBuffer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("\n");
InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackMessageSendTo);
}
static HRESULT WINAPI SMTPTransport_QueryInterface(ISMTPTransport2 *iface, REFIID riid, void **ppv)
{
TRACE("(%s, %p)\n", debugstr_guid(riid), ppv);
if (IsEqualIID(riid, &IID_IUnknown) ||
IsEqualIID(riid, &IID_IInternetTransport) ||
IsEqualIID(riid, &IID_ISMTPTransport) ||
IsEqualIID(riid, &IID_ISMTPTransport2))
{
*ppv = iface;
ISMTPTransport2_AddRef(iface);
return S_OK;
}
*ppv = NULL;
FIXME("no interface for %s\n", debugstr_guid(riid));
return E_NOINTERFACE;
}
static ULONG WINAPI SMTPTransport_AddRef(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
return InterlockedIncrement((LONG *)&This->refs);
}
static ULONG WINAPI SMTPTransport_Release(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
ULONG refs = InterlockedDecrement((LONG *)&This->refs);
if (!refs)
{
TRACE("destroying %p\n", This);
if (This->InetTransport.Status != IXP_DISCONNECTED)
InternetTransport_DropConnection(&This->InetTransport);
if (This->InetTransport.pCallback) ITransportCallback_Release(This->InetTransport.pCallback);
HeapFree(GetProcessHeap(), 0, This->addrlist);
HeapFree(GetProcessHeap(), 0, This);
}
return refs;
}
static HRESULT WINAPI SMTPTransport_GetServerInfo(ISMTPTransport2 *iface,
LPINETSERVER pInetServer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("(%p)\n", pInetServer);
return InternetTransport_GetServerInfo(&This->InetTransport, pInetServer);
}
static IXPTYPE WINAPI SMTPTransport_GetIXPType(ISMTPTransport2 *iface)
{
TRACE("()\n");
return IXP_SMTP;
}
static HRESULT WINAPI SMTPTransport_IsState(ISMTPTransport2 *iface,
IXPISSTATE isstate)
{
FIXME("(%d): stub\n", isstate);
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_InetServerFromAccount(
ISMTPTransport2 *iface, IImnAccount *pAccount, LPINETSERVER pInetServer)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("(%p, %p)\n", pAccount, pInetServer);
return InternetTransport_InetServerFromAccount(&This->InetTransport, pAccount, pInetServer);
}
static HRESULT WINAPI SMTPTransport_Connect(ISMTPTransport2 *iface,
LPINETSERVER pInetServer, boolean fAuthenticate, boolean fCommandLogging)
{
SMTPTransport *This = (SMTPTransport *)iface;
HRESULT hr;
TRACE("(%p, %s, %s)\n", pInetServer, fAuthenticate ? "TRUE" : "FALSE", fCommandLogging ? "TRUE" : "FALSE");
hr = InternetTransport_Connect(&This->InetTransport, pInetServer, fAuthenticate, fCommandLogging);
if (FAILED(hr))
return hr;
/* this starts the state machine, which continues in SMTPTransport_CallbackSendHELO */
return InternetTransport_ReadLine(&This->InetTransport, SMTPTransport_CallbackSendHello);
}
static HRESULT WINAPI SMTPTransport_HandsOffCallback(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
return InternetTransport_HandsOffCallback(&This->InetTransport);
}
static HRESULT WINAPI SMTPTransport_Disconnect(ISMTPTransport2 *iface)
{
TRACE("()\n");
return ISMTPTransport2_CommandQUIT(iface);
}
static HRESULT WINAPI SMTPTransport_DropConnection(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
return InternetTransport_DropConnection(&This->InetTransport);
}
static HRESULT WINAPI SMTPTransport_GetStatus(ISMTPTransport2 *iface,
IXPSTATUS *pCurrentStatus)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
return InternetTransport_GetStatus(&This->InetTransport, pCurrentStatus);
}
static HRESULT WINAPI SMTPTransport_InitNew(ISMTPTransport2 *iface,
LPSTR pszLogFilePath, ISMTPCallback *pCallback)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("(%s, %p)\n", debugstr_a(pszLogFilePath), pCallback);
if (!pCallback)
return E_INVALIDARG;
if (pszLogFilePath)
FIXME("not using log file of %s, use Wine debug logging instead\n",
debugstr_a(pszLogFilePath));
ISMTPCallback_AddRef(pCallback);
This->InetTransport.pCallback = (ITransportCallback *)pCallback;
This->InetTransport.fInitialised = TRUE;
return S_OK;
}
static HRESULT WINAPI SMTPTransport_SendMessage(ISMTPTransport2 *iface,
LPSMTPMESSAGE pMessage)
{
SMTPTransport *This = (SMTPTransport *)iface;
ULONG i, size;
LPSTR pszFromAddress = NULL;
const char szCommandFormat[] = "MAIL FROM: <%s>\n";
char *szCommand;
int len;
HRESULT hr;
TRACE("(%p)\n", pMessage);
This->pending_message = *pMessage;
IStream_AddRef(pMessage->pstmMsg);
size = pMessage->rAddressList.cAddress * sizeof(INETADDR);
This->addrlist = HeapAlloc(GetProcessHeap(), 0, size);
if (!This->addrlist)
return E_OUTOFMEMORY;
memcpy(This->addrlist, pMessage->rAddressList.prgAddress, size);
This->pending_message.rAddressList.prgAddress = This->addrlist;
This->ulCurrentAddressIndex = 0;
for (i = 0; i < pMessage->rAddressList.cAddress; i++)
{
if ((pMessage->rAddressList.prgAddress[i].addrtype & ADDR_TOFROM_MASK) == ADDR_FROM)
{
TRACE("address[%d]: ADDR_FROM, %s\n", i,
pMessage->rAddressList.prgAddress[i].szEmail);
pszFromAddress = pMessage->rAddressList.prgAddress[i].szEmail;
}
else if ((pMessage->rAddressList.prgAddress[i].addrtype & ADDR_TOFROM_MASK) == ADDR_TO)
{
TRACE("address[%d]: ADDR_TO, %s\n", i,
pMessage->rAddressList.prgAddress[i].szEmail);
}
}
if (!pszFromAddress)
{
SMTPRESPONSE response;
memset(&response, 0, sizeof(response));
response.command = SMTP_SEND_MESSAGE;
response.fDone = TRUE;
response.pTransport = (ISMTPTransport *)&This->InetTransport.u.vtblSMTP2;
response.rIxpResult.hrResult = IXP_E_SMTP_NO_SENDER;
ISMTPCallback_OnResponse((ISMTPCallback *)This->InetTransport.pCallback, &response);
return S_OK;
}
len = sizeof(szCommandFormat) - 2 /* "%s" */ + strlen(pszFromAddress);
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, pszFromAddress);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackMessageReadFromResponse);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandMAIL(ISMTPTransport2 *iface, LPSTR pszEmailFrom)
{
SMTPTransport *This = (SMTPTransport *)iface;
const char szCommandFormat[] = "MAIL FROM: <%s>\n";
char *szCommand;
int len;
HRESULT hr;
TRACE("(%s)\n", debugstr_a(pszEmailFrom));
if (!pszEmailFrom)
return E_INVALIDARG;
len = sizeof(szCommandFormat) - 2 /* "%s" */ + strlen(pszEmailFrom);
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, pszEmailFrom);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackReadMAILResponse);
HeapFree(GetProcessHeap(), 0, szCommand);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandRCPT(ISMTPTransport2 *iface, LPSTR pszEmailTo)
{
SMTPTransport *This = (SMTPTransport *)iface;
const char szCommandFormat[] = "RCPT TO: <%s>\n";
char *szCommand;
int len;
HRESULT hr;
TRACE("(%s)\n", debugstr_a(pszEmailTo));
if (!pszEmailTo)
return E_INVALIDARG;
len = sizeof(szCommandFormat) - 2 /* "%s" */ + strlen(pszEmailTo);
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, pszEmailTo);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackReadRCPTResponse);
HeapFree(GetProcessHeap(), 0, szCommand);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandEHLO(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
const char szCommandFormat[] = "EHLO %s\n";
const char szHostname[] = "localhost"; /* FIXME */
char *szCommand;
int len = sizeof(szCommandFormat) - 2 /* "%s" */ + sizeof(szHostname);
HRESULT hr;
TRACE("\n");
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, szHostname);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackReadResponseDoNothing);
HeapFree(GetProcessHeap(), 0, szCommand);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandHELO(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
const char szCommandFormat[] = "HELO %s\n";
const char szHostname[] = "localhost"; /* FIXME */
char *szCommand;
int len = sizeof(szCommandFormat) - 2 /* "%s" */ + sizeof(szHostname);
HRESULT hr;
TRACE("()\n");
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, szHostname);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackReadResponseDoNothing);
HeapFree(GetProcessHeap(), 0, szCommand);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandAUTH(ISMTPTransport2 *iface,
LPSTR pszAuthType)
{
SMTPTransport *This = (SMTPTransport *)iface;
const char szCommandFormat[] = "AUTH %s\n";
char *szCommand;
int len;
HRESULT hr;
TRACE("(%s)\n", debugstr_a(pszAuthType));
if (!pszAuthType)
return E_INVALIDARG;
len = sizeof(szCommandFormat) - 2 /* "%s" */ + strlen(pszAuthType);
szCommand = HeapAlloc(GetProcessHeap(), 0, len);
if (!szCommand)
return E_OUTOFMEMORY;
sprintf(szCommand, szCommandFormat, pszAuthType);
hr = InternetTransport_DoCommand(&This->InetTransport, szCommand,
SMTPTransport_CallbackReadResponseDoNothing);
HeapFree(GetProcessHeap(), 0, szCommand);
return hr;
}
static HRESULT WINAPI SMTPTransport_CommandQUIT(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
InternetTransport_ChangeStatus(&This->InetTransport, IXP_DISCONNECTING);
return InternetTransport_DoCommand(&This->InetTransport, "QUIT\n",
SMTPTransport_CallbackDisconnect);
}
static HRESULT WINAPI SMTPTransport_CommandRSET(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
return InternetTransport_DoCommand(&This->InetTransport, "RSET\n",
SMTPTransport_CallbackReadResponseDoNothing);
}
static HRESULT WINAPI SMTPTransport_CommandDATA(ISMTPTransport2 *iface)
{
SMTPTransport *This = (SMTPTransport *)iface;
TRACE("()\n");
return InternetTransport_DoCommand(&This->InetTransport, "DATA\n",
SMTPTransport_CallbackReadDATAResponse);
}
static HRESULT WINAPI SMTPTransport_CommandDOT(ISMTPTransport2 *iface)
{
FIXME("()\n");
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_SendDataStream(ISMTPTransport2 *iface,
IStream *pStream, ULONG cbSize)
{
FIXME("(%p, %d)\n", pStream, cbSize);
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_SetWindow(ISMTPTransport2 *iface)
{
FIXME("()\n");
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_ResetWindow(ISMTPTransport2 *iface)
{
FIXME("()\n");
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_SendMessage2(ISMTPTransport2 *iface, LPSMTPMESSAGE2 pMessage)
{
FIXME("(%p)\n", pMessage);
return E_NOTIMPL;
}
static HRESULT WINAPI SMTPTransport_CommandRCPT2(ISMTPTransport2 *iface, LPSTR pszEmailTo,
INETADDRTYPE atDSN)
{
FIXME("(%s, %u)\n", pszEmailTo, atDSN);
return E_NOTIMPL;
}
static const ISMTPTransport2Vtbl SMTPTransport2Vtbl =
{
SMTPTransport_QueryInterface,
SMTPTransport_AddRef,
SMTPTransport_Release,
SMTPTransport_GetServerInfo,
SMTPTransport_GetIXPType,
SMTPTransport_IsState,
SMTPTransport_InetServerFromAccount,
SMTPTransport_Connect,
SMTPTransport_HandsOffCallback,
SMTPTransport_Disconnect,
SMTPTransport_DropConnection,
SMTPTransport_GetStatus,
SMTPTransport_InitNew,
SMTPTransport_SendMessage,
SMTPTransport_CommandMAIL,
SMTPTransport_CommandRCPT,
SMTPTransport_CommandEHLO,
SMTPTransport_CommandHELO,
SMTPTransport_CommandAUTH,
SMTPTransport_CommandQUIT,
SMTPTransport_CommandRSET,
SMTPTransport_CommandDATA,
SMTPTransport_CommandDOT,
SMTPTransport_SendDataStream,
SMTPTransport_SetWindow,
SMTPTransport_ResetWindow,
SMTPTransport_SendMessage2,
SMTPTransport_CommandRCPT2
};
HRESULT WINAPI CreateSMTPTransport(ISMTPTransport **ppTransport)
{
HRESULT hr;
SMTPTransport *This = HeapAlloc(GetProcessHeap(), 0, sizeof(*This));
if (!This)
return E_OUTOFMEMORY;
This->InetTransport.u.vtblSMTP2 = &SMTPTransport2Vtbl;
This->refs = 0;
This->fESMTP = FALSE;
hr = InternetTransport_Init(&This->InetTransport);
if (FAILED(hr))
{
HeapFree(GetProcessHeap(), 0, This);
return hr;
}
*ppTransport = (ISMTPTransport *)&This->InetTransport.u.vtblSMTP2;
ISMTPTransport_AddRef(*ppTransport);
return S_OK;
}
static HRESULT WINAPI SMTPTransportCF_QueryInterface(LPCLASSFACTORY iface,
REFIID riid, LPVOID *ppv)
{
*ppv = NULL;
if (IsEqualIID(riid, &IID_IUnknown) || IsEqualIID(riid, &IID_IClassFactory))
{
*ppv = iface;
IClassFactory_AddRef(iface);
return S_OK;
}
return E_NOINTERFACE;
}
static ULONG WINAPI SMTPTransportCF_AddRef(LPCLASSFACTORY iface)
{
return 2; /* non-heap based object */
}
static ULONG WINAPI SMTPTransportCF_Release(LPCLASSFACTORY iface)
{
return 1; /* non-heap based object */
}
static HRESULT WINAPI SMTPTransportCF_CreateInstance(LPCLASSFACTORY iface,
LPUNKNOWN pUnk, REFIID riid, LPVOID *ppv)
{
HRESULT hr;
ISMTPTransport *pSmtpTransport;
TRACE("(%p, %s, %p)\n", pUnk, debugstr_guid(riid), ppv);
*ppv = NULL;
if (pUnk)
return CLASS_E_NOAGGREGATION;
hr = CreateSMTPTransport(&pSmtpTransport);
if (FAILED(hr))
return hr;
hr = ISMTPTransport_QueryInterface(pSmtpTransport, riid, ppv);
ISMTPTransport_Release(pSmtpTransport);
return hr;
}
static HRESULT WINAPI SMTPTransportCF_LockServer(LPCLASSFACTORY iface, BOOL fLock)
{
FIXME("(%d)\n",fLock);
return S_OK;
}
static const IClassFactoryVtbl SMTPTransportCFVtbl =
{
SMTPTransportCF_QueryInterface,
SMTPTransportCF_AddRef,
SMTPTransportCF_Release,
SMTPTransportCF_CreateInstance,
SMTPTransportCF_LockServer
};
static const IClassFactoryVtbl *SMTPTransportCF = &SMTPTransportCFVtbl;
HRESULT SMTPTransportCF_Create(REFIID riid, LPVOID *ppv)
{
return IClassFactory_QueryInterface((IClassFactory *)&SMTPTransportCF, riid, ppv);
}