FBI FRATER / Mbed 2 deprecated InetTest

Library for Bert van Dam's book "ARM MICROCONTROLLERS" For all chapters with internet.

Dependencies:   mbed

NetServices/services/email/smtp/SMTPClient.cpp@0:4edb816d21e1, 2015-10-16 (annotated)

Committer:
ICTFBI
Date:
Fri Oct 16 14:28:26 2015 +0000
Revision:
0:4edb816d21e1
Pre-update 16-10-15

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ICTFBI 0:4edb816d21e1 1
ICTFBI 0:4edb816d21e1 2 /*
ICTFBI 0:4edb816d21e1 3 Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com) y Segundo Equipo
ICTFBI 0:4edb816d21e1 4
ICTFBI 0:4edb816d21e1 5 Permission is hereby granted, free of charge, to any person obtaining a copy
ICTFBI 0:4edb816d21e1 6 of this software and associated documentation files (the "Software"), to deal
ICTFBI 0:4edb816d21e1 7 in the Software without restriction, including without limitation the rights
ICTFBI 0:4edb816d21e1 8 to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
ICTFBI 0:4edb816d21e1 9 copies of the Software, and to permit persons to whom the Software is
ICTFBI 0:4edb816d21e1 10 furnished to do so, subject to the following conditions:
ICTFBI 0:4edb816d21e1 11
ICTFBI 0:4edb816d21e1 12 The above copyright notice and this permission notice shall be included in
ICTFBI 0:4edb816d21e1 13 all copies or substantial portions of the Software.
ICTFBI 0:4edb816d21e1 14
ICTFBI 0:4edb816d21e1 15 THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
ICTFBI 0:4edb816d21e1 16 IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
ICTFBI 0:4edb816d21e1 17 FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
ICTFBI 0:4edb816d21e1 18 AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
ICTFBI 0:4edb816d21e1 19 LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
ICTFBI 0:4edb816d21e1 20 OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
ICTFBI 0:4edb816d21e1 21 THE SOFTWARE.
ICTFBI 0:4edb816d21e1 22 */
ICTFBI 0:4edb816d21e1 23 #include "core/netservice.h"
ICTFBI 0:4edb816d21e1 24 #include "SMTPClient.h"
ICTFBI 0:4edb816d21e1 25 #include "../util/base64.h"
ICTFBI 0:4edb816d21e1 26
ICTFBI 0:4edb816d21e1 27 #define __DEBUG
ICTFBI 0:4edb816d21e1 28 #include "dbg/dbg.h"
ICTFBI 0:4edb816d21e1 29
ICTFBI 0:4edb816d21e1 30 #define CHUNK_SIZE 256 //512
ICTFBI 0:4edb816d21e1 31 #define BUF_SIZE (CHUNK_SIZE + 1)
ICTFBI 0:4edb816d21e1 32
ICTFBI 0:4edb816d21e1 33 #define SMTP_REQUEST_TIMEOUT 15000
ICTFBI 0:4edb816d21e1 34 #define SMTP_PORT 25
ICTFBI 0:4edb816d21e1 35
ICTFBI 0:4edb816d21e1 36 SMTPClient::SMTPClient() : NetService(false) /*Not owned by the pool*/,
ICTFBI 0:4edb816d21e1 37 m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL),
ICTFBI 0:4edb816d21e1 38 m_watchdog(), m_timeout(SMTP_REQUEST_TIMEOUT), m_pDnsReq(NULL), m_server(),
ICTFBI 0:4edb816d21e1 39 m_closed(true), m_state(SMTP_CLOSED), m_pMessage(NULL),
ICTFBI 0:4edb816d21e1 40 m_posInMsg(0), m_blockingResult(SMTP_PROCESSING),
ICTFBI 0:4edb816d21e1 41 m_username(""), m_password(""), m_auth(SMTP_AUTH_NONE),
ICTFBI 0:4edb816d21e1 42 m_heloDomain("localhost") {
ICTFBI 0:4edb816d21e1 43 DBG("New SMTPClient %p\n", this);
ICTFBI 0:4edb816d21e1 44 }
ICTFBI 0:4edb816d21e1 45
ICTFBI 0:4edb816d21e1 46 SMTPClient::SMTPClient(const Host& host, const char* heloDomain, const char* user, const char* password, SMTPAuth auth) : NetService(false),
ICTFBI 0:4edb816d21e1 47 m_pCbItem(NULL), m_pCbMeth(NULL), m_pCb(NULL),
ICTFBI 0:4edb816d21e1 48 m_watchdog(), m_timeout(SMTP_REQUEST_TIMEOUT), m_pDnsReq(NULL), m_server(host),
ICTFBI 0:4edb816d21e1 49 m_closed(true), m_state(SMTP_CLOSED), m_pMessage(NULL),
ICTFBI 0:4edb816d21e1 50 m_posInMsg(0), m_blockingResult(SMTP_PROCESSING),
ICTFBI 0:4edb816d21e1 51 m_username(string(user)), m_password(string(password)), m_auth(auth),
ICTFBI 0:4edb816d21e1 52 m_heloDomain(heloDomain) {
ICTFBI 0:4edb816d21e1 53 DBG("New SMTPClient %p\n", this);
ICTFBI 0:4edb816d21e1 54 }
ICTFBI 0:4edb816d21e1 55
ICTFBI 0:4edb816d21e1 56 SMTPClient::~SMTPClient() {
ICTFBI 0:4edb816d21e1 57 close();
ICTFBI 0:4edb816d21e1 58 }
ICTFBI 0:4edb816d21e1 59
ICTFBI 0:4edb816d21e1 60 void SMTPClient::setAuth(const char* user, const char* password) { // Plain authentication
ICTFBI 0:4edb816d21e1 61 m_username = string(user);
ICTFBI 0:4edb816d21e1 62 m_password = string(password);
ICTFBI 0:4edb816d21e1 63 m_auth = SMTP_AUTH_PLAIN;
ICTFBI 0:4edb816d21e1 64 }
ICTFBI 0:4edb816d21e1 65
ICTFBI 0:4edb816d21e1 66 void SMTPClient::clearAuth() { // Clear authentication
ICTFBI 0:4edb816d21e1 67 m_username = "";
ICTFBI 0:4edb816d21e1 68 m_password = "";
ICTFBI 0:4edb816d21e1 69 m_auth = SMTP_AUTH_NONE;
ICTFBI 0:4edb816d21e1 70 }
ICTFBI 0:4edb816d21e1 71
ICTFBI 0:4edb816d21e1 72 string SMTPClient::encodePlainAuth() {
ICTFBI 0:4edb816d21e1 73 string decStr = m_username;
ICTFBI 0:4edb816d21e1 74 decStr += '\0';
ICTFBI 0:4edb816d21e1 75 decStr += m_username;
ICTFBI 0:4edb816d21e1 76 decStr += '\0';
ICTFBI 0:4edb816d21e1 77 decStr += m_password;
ICTFBI 0:4edb816d21e1 78
ICTFBI 0:4edb816d21e1 79 string auth = "AUTH PLAIN ";
ICTFBI 0:4edb816d21e1 80 return auth.append(Base64::encode(decStr));
ICTFBI 0:4edb816d21e1 81 }
ICTFBI 0:4edb816d21e1 82
ICTFBI 0:4edb816d21e1 83 void SMTPClient::setHeloDomain(const char* heloDomain) {
ICTFBI 0:4edb816d21e1 84 m_heloDomain = string(heloDomain);
ICTFBI 0:4edb816d21e1 85 }
ICTFBI 0:4edb816d21e1 86
ICTFBI 0:4edb816d21e1 87 SMTPResult SMTPClient::send(EmailMessage* pMessage) { //Blocking
ICTFBI 0:4edb816d21e1 88 doSend(pMessage);
ICTFBI 0:4edb816d21e1 89 return blockingProcess();
ICTFBI 0:4edb816d21e1 90 }
ICTFBI 0:4edb816d21e1 91
ICTFBI 0:4edb816d21e1 92 SMTPResult SMTPClient::send(EmailMessage* pMessage, void (*pMethod)(SMTPResult)) { //Non blocking
ICTFBI 0:4edb816d21e1 93 setOnResult(pMethod);
ICTFBI 0:4edb816d21e1 94 doSend(pMessage);
ICTFBI 0:4edb816d21e1 95 return SMTP_PROCESSING;
ICTFBI 0:4edb816d21e1 96 }
ICTFBI 0:4edb816d21e1 97
ICTFBI 0:4edb816d21e1 98 void SMTPClient::doSend(EmailMessage* pMessage) {
ICTFBI 0:4edb816d21e1 99 setup(pMessage);
ICTFBI 0:4edb816d21e1 100 }
ICTFBI 0:4edb816d21e1 101
ICTFBI 0:4edb816d21e1 102 void SMTPClient::setOnResult( void (*pMethod)(SMTPResult) ) {
ICTFBI 0:4edb816d21e1 103 m_pCb = pMethod;
ICTFBI 0:4edb816d21e1 104 m_pCbItem = NULL;
ICTFBI 0:4edb816d21e1 105 m_pCbMeth = NULL;
ICTFBI 0:4edb816d21e1 106 }
ICTFBI 0:4edb816d21e1 107
ICTFBI 0:4edb816d21e1 108 void SMTPClient::setTimeout(int ms) {
ICTFBI 0:4edb816d21e1 109 m_timeout = ms;
ICTFBI 0:4edb816d21e1 110 }
ICTFBI 0:4edb816d21e1 111
ICTFBI 0:4edb816d21e1 112 void SMTPClient::poll() { //Called by NetServices
ICTFBI 0:4edb816d21e1 113 if ( (!m_closed) && (m_watchdog.read_ms() >= m_timeout) ) {
ICTFBI 0:4edb816d21e1 114 onTimeout();
ICTFBI 0:4edb816d21e1 115 }
ICTFBI 0:4edb816d21e1 116 }
ICTFBI 0:4edb816d21e1 117
ICTFBI 0:4edb816d21e1 118 void SMTPClient::resetTimeout() {
ICTFBI 0:4edb816d21e1 119 m_watchdog.reset();
ICTFBI 0:4edb816d21e1 120 m_watchdog.start();
ICTFBI 0:4edb816d21e1 121 }
ICTFBI 0:4edb816d21e1 122
ICTFBI 0:4edb816d21e1 123 void SMTPClient::init() { //Create and setup socket if needed
ICTFBI 0:4edb816d21e1 124 close(); //Remove previous elements
ICTFBI 0:4edb816d21e1 125 if (!m_closed) //Already opened
ICTFBI 0:4edb816d21e1 126 return;
ICTFBI 0:4edb816d21e1 127 m_state = SMTP_HELLO;
ICTFBI 0:4edb816d21e1 128 m_pTCPSocket = new TCPSocket;
ICTFBI 0:4edb816d21e1 129 m_pTCPSocket->setOnEvent(this, &SMTPClient::onTCPSocketEvent);
ICTFBI 0:4edb816d21e1 130 m_closed = false;
ICTFBI 0:4edb816d21e1 131 m_posInMsg = 0;
ICTFBI 0:4edb816d21e1 132 m_posInCRLF = 2;
ICTFBI 0:4edb816d21e1 133 m_response = "";
ICTFBI 0:4edb816d21e1 134 }
ICTFBI 0:4edb816d21e1 135
ICTFBI 0:4edb816d21e1 136 void SMTPClient::close() {
ICTFBI 0:4edb816d21e1 137 if (m_closed)
ICTFBI 0:4edb816d21e1 138 return;
ICTFBI 0:4edb816d21e1 139 m_state = SMTP_CLOSED;
ICTFBI 0:4edb816d21e1 140 m_closed = true; //Prevent recursive calling or calling on an object being destructed by someone else
ICTFBI 0:4edb816d21e1 141 m_watchdog.stop(); //Stop timeout
ICTFBI 0:4edb816d21e1 142 m_watchdog.reset();
ICTFBI 0:4edb816d21e1 143 m_pTCPSocket->resetOnEvent();
ICTFBI 0:4edb816d21e1 144 m_pTCPSocket->close();
ICTFBI 0:4edb816d21e1 145 delete m_pTCPSocket;
ICTFBI 0:4edb816d21e1 146 m_pTCPSocket = NULL;
ICTFBI 0:4edb816d21e1 147 if ( m_pDnsReq ) {
ICTFBI 0:4edb816d21e1 148 m_pDnsReq->close();
ICTFBI 0:4edb816d21e1 149 delete m_pDnsReq;
ICTFBI 0:4edb816d21e1 150 m_pDnsReq = NULL;
ICTFBI 0:4edb816d21e1 151 }
ICTFBI 0:4edb816d21e1 152 }
ICTFBI 0:4edb816d21e1 153
ICTFBI 0:4edb816d21e1 154 void SMTPClient::setServer(const Host& host) { //Setup request, make DNS Req if necessary
ICTFBI 0:4edb816d21e1 155 m_server = host;
ICTFBI 0:4edb816d21e1 156 }
ICTFBI 0:4edb816d21e1 157
ICTFBI 0:4edb816d21e1 158 void SMTPClient::setup(EmailMessage* pMessage) { //Setup request, make DNS Req if necessary
ICTFBI 0:4edb816d21e1 159
ICTFBI 0:4edb816d21e1 160 init(); //Initialize client in known state, create socket
ICTFBI 0:4edb816d21e1 161 m_pMessage = pMessage;
ICTFBI 0:4edb816d21e1 162 resetTimeout();
ICTFBI 0:4edb816d21e1 163
ICTFBI 0:4edb816d21e1 164 m_To = m_pMessage->m_lTo.begin(); // Point to first to recipient in TO list
ICTFBI 0:4edb816d21e1 165
ICTFBI 0:4edb816d21e1 166 //If port set to zero then use default port
ICTFBI 0:4edb816d21e1 167 if (!m_server.getPort()) {
ICTFBI 0:4edb816d21e1 168 m_server.setPort(SMTP_PORT);
ICTFBI 0:4edb816d21e1 169 DBG("Using default port %d\n", SMTP_PORT);
ICTFBI 0:4edb816d21e1 170 }
ICTFBI 0:4edb816d21e1 171
ICTFBI 0:4edb816d21e1 172 if (m_server.getIp().isNull()) {
ICTFBI 0:4edb816d21e1 173 //DNS query required
ICTFBI 0:4edb816d21e1 174 m_pDnsReq = new DNSRequest();
ICTFBI 0:4edb816d21e1 175 DBG("DNSRequest %p\r\n", m_pDnsReq);
ICTFBI 0:4edb816d21e1 176 m_pDnsReq->setOnReply(this, &SMTPClient::onDNSReply);
ICTFBI 0:4edb816d21e1 177 m_pDnsReq->resolve(&m_server);
ICTFBI 0:4edb816d21e1 178 return;
ICTFBI 0:4edb816d21e1 179 } else
ICTFBI 0:4edb816d21e1 180 connect();
ICTFBI 0:4edb816d21e1 181
ICTFBI 0:4edb816d21e1 182 }
ICTFBI 0:4edb816d21e1 183
ICTFBI 0:4edb816d21e1 184 void SMTPClient::connect() { //Start Connection
ICTFBI 0:4edb816d21e1 185 resetTimeout();
ICTFBI 0:4edb816d21e1 186 DBG("Connecting...\n");
ICTFBI 0:4edb816d21e1 187 m_pTCPSocket->connect(m_server);
ICTFBI 0:4edb816d21e1 188 }
ICTFBI 0:4edb816d21e1 189
ICTFBI 0:4edb816d21e1 190 void SMTPClient::onTCPSocketEvent(TCPSocketEvent e) {
ICTFBI 0:4edb816d21e1 191
ICTFBI 0:4edb816d21e1 192 DBG("Event %d in SMTPClient::onTCPSocketEvent()\n", e);
ICTFBI 0:4edb816d21e1 193
ICTFBI 0:4edb816d21e1 194 if (m_closed) {
ICTFBI 0:4edb816d21e1 195 DBG("WARN: Discarded\n");
ICTFBI 0:4edb816d21e1 196 return;
ICTFBI 0:4edb816d21e1 197 }
ICTFBI 0:4edb816d21e1 198
ICTFBI 0:4edb816d21e1 199 switch (e) {
ICTFBI 0:4edb816d21e1 200 case TCPSOCKET_READABLE:
ICTFBI 0:4edb816d21e1 201 resetTimeout();
ICTFBI 0:4edb816d21e1 202 process(false);
ICTFBI 0:4edb816d21e1 203 break;
ICTFBI 0:4edb816d21e1 204 case TCPSOCKET_WRITEABLE:
ICTFBI 0:4edb816d21e1 205 resetTimeout();
ICTFBI 0:4edb816d21e1 206 process(true);
ICTFBI 0:4edb816d21e1 207 break;
ICTFBI 0:4edb816d21e1 208 case TCPSOCKET_CONTIMEOUT:
ICTFBI 0:4edb816d21e1 209 case TCPSOCKET_CONRST:
ICTFBI 0:4edb816d21e1 210 case TCPSOCKET_CONABRT:
ICTFBI 0:4edb816d21e1 211 case TCPSOCKET_ERROR:
ICTFBI 0:4edb816d21e1 212 DBG("Connection error in SMTP Client.\n");
ICTFBI 0:4edb816d21e1 213 close();
ICTFBI 0:4edb816d21e1 214 onResult(SMTP_DISC);
ICTFBI 0:4edb816d21e1 215 break;
ICTFBI 0:4edb816d21e1 216 case TCPSOCKET_DISCONNECTED:
ICTFBI 0:4edb816d21e1 217 if (m_state != SMTP_BYE) {
ICTFBI 0:4edb816d21e1 218 DBG("Connection error in SMTP Client.\n");
ICTFBI 0:4edb816d21e1 219 close();
ICTFBI 0:4edb816d21e1 220 onResult(SMTP_DISC);
ICTFBI 0:4edb816d21e1 221 }
ICTFBI 0:4edb816d21e1 222 break;
ICTFBI 0:4edb816d21e1 223 }
ICTFBI 0:4edb816d21e1 224 }
ICTFBI 0:4edb816d21e1 225
ICTFBI 0:4edb816d21e1 226 void SMTPClient::onDNSReply(DNSReply r) {
ICTFBI 0:4edb816d21e1 227 if (m_closed) {
ICTFBI 0:4edb816d21e1 228 DBG("WARN: Discarded\n");
ICTFBI 0:4edb816d21e1 229 return;
ICTFBI 0:4edb816d21e1 230 }
ICTFBI 0:4edb816d21e1 231
ICTFBI 0:4edb816d21e1 232 if ( r != DNS_FOUND ) {
ICTFBI 0:4edb816d21e1 233 DBG("Could not resolve hostname.\n");
ICTFBI 0:4edb816d21e1 234 close();
ICTFBI 0:4edb816d21e1 235 onResult(SMTP_DNS);
ICTFBI 0:4edb816d21e1 236 return;
ICTFBI 0:4edb816d21e1 237 }
ICTFBI 0:4edb816d21e1 238
ICTFBI 0:4edb816d21e1 239 DBG("DNS Resolved to %d.%d.%d.%d\n", m_server.getIp()[0], m_server.getIp()[1], m_server.getIp()[2], m_server.getIp()[3]);
ICTFBI 0:4edb816d21e1 240 //If no error, m_server has been updated by m_pDnsReq so we're set to go !
ICTFBI 0:4edb816d21e1 241 m_pDnsReq->close();
ICTFBI 0:4edb816d21e1 242 delete m_pDnsReq;
ICTFBI 0:4edb816d21e1 243 m_pDnsReq = NULL;
ICTFBI 0:4edb816d21e1 244 connect();
ICTFBI 0:4edb816d21e1 245 }
ICTFBI 0:4edb816d21e1 246
ICTFBI 0:4edb816d21e1 247 void SMTPClient::onResult(SMTPResult r) { //Called when exchange completed or on failure
ICTFBI 0:4edb816d21e1 248 if (m_pCbItem && m_pCbMeth)
ICTFBI 0:4edb816d21e1 249 (m_pCbItem->*m_pCbMeth)(r);
ICTFBI 0:4edb816d21e1 250 else if (m_pCb)
ICTFBI 0:4edb816d21e1 251 m_pCb(r);
ICTFBI 0:4edb816d21e1 252 m_blockingResult = r; //Blocking mode
ICTFBI 0:4edb816d21e1 253 }
ICTFBI 0:4edb816d21e1 254
ICTFBI 0:4edb816d21e1 255 void SMTPClient::onTimeout() { //Connection has timed out
ICTFBI 0:4edb816d21e1 256 DBG("Timed out.\n");
ICTFBI 0:4edb816d21e1 257 close();
ICTFBI 0:4edb816d21e1 258 onResult(SMTP_TIMEOUT);
ICTFBI 0:4edb816d21e1 259 }
ICTFBI 0:4edb816d21e1 260
ICTFBI 0:4edb816d21e1 261 SMTPResult SMTPClient::blockingProcess() { //Called in blocking mode, calls Net::poll() until return code is available
ICTFBI 0:4edb816d21e1 262 //Disable callbacks
ICTFBI 0:4edb816d21e1 263 m_pCb = NULL;
ICTFBI 0:4edb816d21e1 264 m_pCbItem = NULL;
ICTFBI 0:4edb816d21e1 265 m_pCbMeth = NULL;
ICTFBI 0:4edb816d21e1 266 m_blockingResult = SMTP_PROCESSING;
ICTFBI 0:4edb816d21e1 267 do {
ICTFBI 0:4edb816d21e1 268 Net::poll();
ICTFBI 0:4edb816d21e1 269 } while (m_blockingResult == SMTP_PROCESSING);
ICTFBI 0:4edb816d21e1 270 Net::poll(); //Necessary for cleanup
ICTFBI 0:4edb816d21e1 271 return m_blockingResult;
ICTFBI 0:4edb816d21e1 272 }
ICTFBI 0:4edb816d21e1 273
ICTFBI 0:4edb816d21e1 274 int SMTPClient::rc(char* buf) { //Parse return code
ICTFBI 0:4edb816d21e1 275 int rc;
ICTFBI 0:4edb816d21e1 276 int len = sscanf(buf, "%d %*[^\r\n]\r\n", &rc);
ICTFBI 0:4edb816d21e1 277 if (len != 1)
ICTFBI 0:4edb816d21e1 278 return -1;
ICTFBI 0:4edb816d21e1 279 return rc;
ICTFBI 0:4edb816d21e1 280 }
ICTFBI 0:4edb816d21e1 281
ICTFBI 0:4edb816d21e1 282 bool SMTPClient::okPostAuthentication(int code) {
ICTFBI 0:4edb816d21e1 283 return (code == 250) || (code == 235);
ICTFBI 0:4edb816d21e1 284 }
ICTFBI 0:4edb816d21e1 285
ICTFBI 0:4edb816d21e1 286 void SMTPClient::process(bool writeable) { //Main state-machine
ICTFBI 0:4edb816d21e1 287
ICTFBI 0:4edb816d21e1 288 DBG("In state %d, writeable %d\n", m_state, writeable);
ICTFBI 0:4edb816d21e1 289
ICTFBI 0:4edb816d21e1 290 // If writeable but nothing to write then return
ICTFBI 0:4edb816d21e1 291 if (writeable && (m_state != SMTP_BODYMORE))
ICTFBI 0:4edb816d21e1 292 return;
ICTFBI 0:4edb816d21e1 293
ICTFBI 0:4edb816d21e1 294 // If not writeable then read
ICTFBI 0:4edb816d21e1 295 char buf[BUF_SIZE] = {0};
ICTFBI 0:4edb816d21e1 296 int responseCode = -1;
ICTFBI 0:4edb816d21e1 297 if (!writeable) {
ICTFBI 0:4edb816d21e1 298 bool firstBuf = true;
ICTFBI 0:4edb816d21e1 299 int read;
ICTFBI 0:4edb816d21e1 300 do { // read until nothing left but only process the response from first buffer
ICTFBI 0:4edb816d21e1 301 read = m_pTCPSocket->recv(buf, BUF_SIZE - 1);
ICTFBI 0:4edb816d21e1 302 if (firstBuf) {
ICTFBI 0:4edb816d21e1 303 m_response = string(buf);
ICTFBI 0:4edb816d21e1 304 responseCode = rc(buf);
ICTFBI 0:4edb816d21e1 305 firstBuf = false;
ICTFBI 0:4edb816d21e1 306 DBG("Response %d %d | %s", read, responseCode, buf);
ICTFBI 0:4edb816d21e1 307 }
ICTFBI 0:4edb816d21e1 308 } while (read > 0);
ICTFBI 0:4edb816d21e1 309 }
ICTFBI 0:4edb816d21e1 310
ICTFBI 0:4edb816d21e1 311 switch (m_state) {
ICTFBI 0:4edb816d21e1 312 case SMTP_HELLO:
ICTFBI 0:4edb816d21e1 313 if ( responseCode != 220 ) {
ICTFBI 0:4edb816d21e1 314 close();
ICTFBI 0:4edb816d21e1 315 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 316 return;
ICTFBI 0:4edb816d21e1 317 }
ICTFBI 0:4edb816d21e1 318 char* helloCommand;
ICTFBI 0:4edb816d21e1 319 if (m_auth == SMTP_AUTH_NONE) {
ICTFBI 0:4edb816d21e1 320 helloCommand = "HELO";
ICTFBI 0:4edb816d21e1 321 m_state = SMTP_FROM;
ICTFBI 0:4edb816d21e1 322 } else {
ICTFBI 0:4edb816d21e1 323 helloCommand = "EHLO";
ICTFBI 0:4edb816d21e1 324 m_state = SMTP_AUTH;
ICTFBI 0:4edb816d21e1 325 }
ICTFBI 0:4edb816d21e1 326 snprintf(buf, BUF_SIZE, "%s %s\r\n", helloCommand, m_heloDomain.c_str());
ICTFBI 0:4edb816d21e1 327 break;
ICTFBI 0:4edb816d21e1 328 case SMTP_AUTH:
ICTFBI 0:4edb816d21e1 329 if ( responseCode != 250 ) {
ICTFBI 0:4edb816d21e1 330 close();
ICTFBI 0:4edb816d21e1 331 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 332 return;
ICTFBI 0:4edb816d21e1 333 }
ICTFBI 0:4edb816d21e1 334 snprintf(buf, BUF_SIZE, "%s\r\n", encodePlainAuth().c_str());
ICTFBI 0:4edb816d21e1 335 m_state = SMTP_FROM;
ICTFBI 0:4edb816d21e1 336 break;
ICTFBI 0:4edb816d21e1 337 case SMTP_FROM:
ICTFBI 0:4edb816d21e1 338 if (!okPostAuthentication(responseCode)) {
ICTFBI 0:4edb816d21e1 339 close();
ICTFBI 0:4edb816d21e1 340 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 341 return;
ICTFBI 0:4edb816d21e1 342 }
ICTFBI 0:4edb816d21e1 343 snprintf(buf, BUF_SIZE, "MAIL FROM:<%s>\r\n", m_pMessage->m_from.c_str());
ICTFBI 0:4edb816d21e1 344 m_state = SMTP_TO;
ICTFBI 0:4edb816d21e1 345 break;
ICTFBI 0:4edb816d21e1 346 case SMTP_TO:
ICTFBI 0:4edb816d21e1 347 if ( responseCode != 250 ) {
ICTFBI 0:4edb816d21e1 348 close();
ICTFBI 0:4edb816d21e1 349 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 350 return;
ICTFBI 0:4edb816d21e1 351 }
ICTFBI 0:4edb816d21e1 352 snprintf(buf, BUF_SIZE, "RCPT TO:<%s>\r\n", (m_To++)->c_str());
ICTFBI 0:4edb816d21e1 353 if (m_To == m_pMessage->m_lTo.end())
ICTFBI 0:4edb816d21e1 354 m_state = SMTP_DATA;
ICTFBI 0:4edb816d21e1 355 break;
ICTFBI 0:4edb816d21e1 356 case SMTP_DATA:
ICTFBI 0:4edb816d21e1 357 if ( responseCode != 250 ) {
ICTFBI 0:4edb816d21e1 358 close();
ICTFBI 0:4edb816d21e1 359 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 360 return;
ICTFBI 0:4edb816d21e1 361 }
ICTFBI 0:4edb816d21e1 362 snprintf(buf, BUF_SIZE, "DATA\r\n");
ICTFBI 0:4edb816d21e1 363 m_state = SMTP_BODY;
ICTFBI 0:4edb816d21e1 364 break;
ICTFBI 0:4edb816d21e1 365 case SMTP_BODY:
ICTFBI 0:4edb816d21e1 366 if ( responseCode != 354 ) {
ICTFBI 0:4edb816d21e1 367 close();
ICTFBI 0:4edb816d21e1 368 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 369 return;
ICTFBI 0:4edb816d21e1 370 }
ICTFBI 0:4edb816d21e1 371 m_state = SMTP_BODYMORE;
ICTFBI 0:4edb816d21e1 372 buf[0] = '\0'; // clear buffer before carrying on into next state
ICTFBI 0:4edb816d21e1 373 case SMTP_BODYMORE:
ICTFBI 0:4edb816d21e1 374 if (strlen(buf) > 0) { // sending interrupted by a server response
ICTFBI 0:4edb816d21e1 375 close();
ICTFBI 0:4edb816d21e1 376 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 377 return;
ICTFBI 0:4edb816d21e1 378 }
ICTFBI 0:4edb816d21e1 379
ICTFBI 0:4edb816d21e1 380 if ( m_posInMsg < m_pMessage->m_content.length() ) { // if still something to send
ICTFBI 0:4edb816d21e1 381 int sendLen = 0;
ICTFBI 0:4edb816d21e1 382 while (sendLen < BUF_SIZE - 1) { // - 1 to allow room for extra dot or CR or LF
ICTFBI 0:4edb816d21e1 383 char c = m_pMessage->m_content.at(m_posInMsg++);
ICTFBI 0:4edb816d21e1 384 switch (c) { // thanks ExtraDotOutputStream.java (with extra check for naked CR)
ICTFBI 0:4edb816d21e1 385 case '.':
ICTFBI 0:4edb816d21e1 386 if (m_posInCRLF == 2) // add extra dot
ICTFBI 0:4edb816d21e1 387 buf[sendLen++] = '.';
ICTFBI 0:4edb816d21e1 388 m_posInCRLF = 0;
ICTFBI 0:4edb816d21e1 389 break;
ICTFBI 0:4edb816d21e1 390 case '\r':
ICTFBI 0:4edb816d21e1 391 if (m_posInCRLF == 1) // two CR in a row, so insert an LF first
ICTFBI 0:4edb816d21e1 392 buf[sendLen++] = '\n';
ICTFBI 0:4edb816d21e1 393 m_posInCRLF = 1;
ICTFBI 0:4edb816d21e1 394 break;
ICTFBI 0:4edb816d21e1 395 case '\n':
ICTFBI 0:4edb816d21e1 396 if (m_posInCRLF != 1) // convert naked LF to CRLF
ICTFBI 0:4edb816d21e1 397 buf[sendLen++] = '\r';
ICTFBI 0:4edb816d21e1 398 m_posInCRLF = 2;
ICTFBI 0:4edb816d21e1 399 break;
ICTFBI 0:4edb816d21e1 400 default:
ICTFBI 0:4edb816d21e1 401 if (m_posInCRLF == 1) { // convert naked CR to CRLF
ICTFBI 0:4edb816d21e1 402 buf[sendLen++] = '\n';
ICTFBI 0:4edb816d21e1 403 m_posInCRLF = 2;
ICTFBI 0:4edb816d21e1 404 } else
ICTFBI 0:4edb816d21e1 405 m_posInCRLF = 0; // we're no longer at the start of a line
ICTFBI 0:4edb816d21e1 406 break;
ICTFBI 0:4edb816d21e1 407 }
ICTFBI 0:4edb816d21e1 408 buf[sendLen++] = c;
ICTFBI 0:4edb816d21e1 409 if ( m_posInMsg == m_pMessage->m_content.length() )
ICTFBI 0:4edb816d21e1 410 break;
ICTFBI 0:4edb816d21e1 411 }
ICTFBI 0:4edb816d21e1 412 m_pTCPSocket->send( buf, sendLen );
ICTFBI 0:4edb816d21e1 413 DBG("Sending %d bytes of processed message content\n", sendLen);
ICTFBI 0:4edb816d21e1 414 } else {
ICTFBI 0:4edb816d21e1 415 if (m_posInCRLF == 0)
ICTFBI 0:4edb816d21e1 416 snprintf(buf, BUF_SIZE, "\r\n.\r\n");
ICTFBI 0:4edb816d21e1 417 else if (m_posInCRLF == 1)
ICTFBI 0:4edb816d21e1 418 snprintf(buf, BUF_SIZE, "\n.\r\n");
ICTFBI 0:4edb816d21e1 419 else
ICTFBI 0:4edb816d21e1 420 snprintf(buf, BUF_SIZE, ".\r\n");
ICTFBI 0:4edb816d21e1 421 m_state = SMTP_EOF;
ICTFBI 0:4edb816d21e1 422 }
ICTFBI 0:4edb816d21e1 423 break;
ICTFBI 0:4edb816d21e1 424 case SMTP_EOF:
ICTFBI 0:4edb816d21e1 425 if ( responseCode != 250 ) {
ICTFBI 0:4edb816d21e1 426 close();
ICTFBI 0:4edb816d21e1 427 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 428 return;
ICTFBI 0:4edb816d21e1 429 }
ICTFBI 0:4edb816d21e1 430 snprintf(buf, BUF_SIZE, "QUIT\r\n");
ICTFBI 0:4edb816d21e1 431 m_state = SMTP_BYE;
ICTFBI 0:4edb816d21e1 432 break;
ICTFBI 0:4edb816d21e1 433 case SMTP_BYE:
ICTFBI 0:4edb816d21e1 434 if ( responseCode != 221 ) {
ICTFBI 0:4edb816d21e1 435 close();
ICTFBI 0:4edb816d21e1 436 onResult(SMTP_PRTCL);
ICTFBI 0:4edb816d21e1 437 return;
ICTFBI 0:4edb816d21e1 438 }
ICTFBI 0:4edb816d21e1 439 close();
ICTFBI 0:4edb816d21e1 440 onResult(SMTP_OK);
ICTFBI 0:4edb816d21e1 441 return;
ICTFBI 0:4edb816d21e1 442 }
ICTFBI 0:4edb816d21e1 443
ICTFBI 0:4edb816d21e1 444 if ( m_state != SMTP_BODYMORE ) {
ICTFBI 0:4edb816d21e1 445 DBG("Sending | %s", buf);
ICTFBI 0:4edb816d21e1 446 m_pTCPSocket->send( buf, strlen(buf) );
ICTFBI 0:4edb816d21e1 447 }
ICTFBI 0:4edb816d21e1 448
ICTFBI 0:4edb816d21e1 449 }
ICTFBI 0:4edb816d21e1 450
ICTFBI 0:4edb816d21e1 451 string& SMTPClient::getLastResponse() { // Return last response set on result
ICTFBI 0:4edb816d21e1 452 return m_response;
ICTFBI 0:4edb816d21e1 453 }