AmpereMeter - Example self-announcing webserver which controls …

Users » dirkx » Code » AmpereMeter

Dirk-Willem van Gulik (NXP/mbed) / Mbed 2 deprecated AmpereMeter

Example self-announcing webserver which controls a servo through a smallHTML userinterface.

services/email/smtp/SMTPClient.cpp@0:a259777c45a3, 2010-08-14 (annotated)

Committer:: dirkx
Date:: Sat Aug 14 15:56:01 2010 +0000
Revision:: 0:a259777c45a3

Who changed what in which revision?

User	Revision	Line number	New contents of line
dirkx	0:a259777c45a3	1
dirkx	0:a259777c45a3	2	/*
dirkx	0:a259777c45a3	3	Copyright (c) 2010 Donatien Garnier (donatiengar [at] gmail [dot] com)
dirkx	0:a259777c45a3	4
dirkx	0:a259777c45a3	5	Permission is hereby granted, free of charge, to any person obtaining a copy
dirkx	0:a259777c45a3	6	of this software and associated documentation files (the "Software"), to deal
dirkx	0:a259777c45a3	7	in the Software without restriction, including without limitation the rights
dirkx	0:a259777c45a3	8	to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
dirkx	0:a259777c45a3	9	copies of the Software, and to permit persons to whom the Software is
dirkx	0:a259777c45a3	10	furnished to do so, subject to the following conditions:
dirkx	0:a259777c45a3	11
dirkx	0:a259777c45a3	12	The above copyright notice and this permission notice shall be included in
dirkx	0:a259777c45a3	13	all copies or substantial portions of the Software.
dirkx	0:a259777c45a3	14
dirkx	0:a259777c45a3	15	THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
dirkx	0:a259777c45a3	16	IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
dirkx	0:a259777c45a3	17	FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
dirkx	0:a259777c45a3	18	AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
dirkx	0:a259777c45a3	19	LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
dirkx	0:a259777c45a3	20	OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
dirkx	0:a259777c45a3	21	THE SOFTWARE.
dirkx	0:a259777c45a3	22	*/
dirkx	0:a259777c45a3	23
dirkx	0:a259777c45a3	24	#include "SMTPClient.h"
dirkx	0:a259777c45a3	25
dirkx	0:a259777c45a3	26	#if 0
dirkx	0:a259777c45a3	27
dirkx	0:a259777c45a3	28	#include <stdio.h>
dirkx	0:a259777c45a3	29
dirkx	0:a259777c45a3	30	#define __DEBUG
dirkx	0:a259777c45a3	31	#include "dbg.h"
dirkx	0:a259777c45a3	32
dirkx	0:a259777c45a3	33	#define BUF_SIZE 128
dirkx	0:a259777c45a3	34	#define CHUNK_SIZE 512
dirkx	0:a259777c45a3	35
dirkx	0:a259777c45a3	36	SMTPClient::SMTPClient() : m_pMessage(NULL), m_nextState(SMTP_HELLO),
dirkx	0:a259777c45a3	37	m_pCbItem(NULL), m_pCbMeth(NULL), m_watchdog(), m_timeout(0), m_posInMsg(0), m_closed(true), m_host()
dirkx	0:a259777c45a3	38	{
dirkx	0:a259777c45a3	39	setTimeout(SMTP_REQUEST_TIMEOUT);
dirkx	0:a259777c45a3	40	}
dirkx	0:a259777c45a3	41
dirkx	0:a259777c45a3	42	SMTPClient::~SMTPClient()
dirkx	0:a259777c45a3	43	{
dirkx	0:a259777c45a3	44	close();
dirkx	0:a259777c45a3	45	}
dirkx	0:a259777c45a3	46
dirkx	0:a259777c45a3	47	void SMTPClient::setHost(const Host& host)
dirkx	0:a259777c45a3	48	{
dirkx	0:a259777c45a3	49	m_host = host;
dirkx	0:a259777c45a3	50	}
dirkx	0:a259777c45a3	51
dirkx	0:a259777c45a3	52	void SMTPClient::send(EmailMessage* pMessage)
dirkx	0:a259777c45a3	53	{
dirkx	0:a259777c45a3	54	init();
dirkx	0:a259777c45a3	55	m_posInMsg = 0;
dirkx	0:a259777c45a3	56	m_nextState = SMTP_HELLO;
dirkx	0:a259777c45a3	57	if( !m_pTCPSocket->connect(m_host) )
dirkx	0:a259777c45a3	58	{
dirkx	0:a259777c45a3	59	close();
dirkx	0:a259777c45a3	60	onResult(SMTP_DISC);
dirkx	0:a259777c45a3	61	}
dirkx	0:a259777c45a3	62	}
dirkx	0:a259777c45a3	63
dirkx	0:a259777c45a3	64	void SMTPClient::init() //Create and setup socket if needed
dirkx	0:a259777c45a3	65	{
dirkx	0:a259777c45a3	66	close(); //Remove previous elements
dirkx	0:a259777c45a3	67	if(!m_closed) //Already opened
dirkx	0:a259777c45a3	68	return;
dirkx	0:a259777c45a3	69	m_nextState = SMTP_HELLO;
dirkx	0:a259777c45a3	70	m_pTCPSocket = new TCPSocket;
dirkx	0:a259777c45a3	71	m_pTCPSocket->setOnEvent(this, &SMTPClient::onTCPSocketEvent);
dirkx	0:a259777c45a3	72	m_closed = false;
dirkx	0:a259777c45a3	73	}
dirkx	0:a259777c45a3	74
dirkx	0:a259777c45a3	75	void SMTPClient::close()
dirkx	0:a259777c45a3	76	{
dirkx	0:a259777c45a3	77	if(m_closed)
dirkx	0:a259777c45a3	78	return;
dirkx	0:a259777c45a3	79	m_closed = true; //Prevent recursive calling or calling on an object being destructed by someone else
dirkx	0:a259777c45a3	80	m_watchdog.detach();
dirkx	0:a259777c45a3	81	m_pTCPSocket->resetOnEvent();
dirkx	0:a259777c45a3	82	m_pTCPSocket->close();
dirkx	0:a259777c45a3	83	delete m_pTCPSocket;
dirkx	0:a259777c45a3	84	m_pTCPSocket = NULL;
dirkx	0:a259777c45a3	85	}
dirkx	0:a259777c45a3	86
dirkx	0:a259777c45a3	87	int SMTPClient::rc(char* buf) //Parse return code
dirkx	0:a259777c45a3	88	{
dirkx	0:a259777c45a3	89	int rc;
dirkx	0:a259777c45a3	90	int len = sscanf(buf, "%d %*[^\r\n]\r\n", &rc);
dirkx	0:a259777c45a3	91	if(len != 1)
dirkx	0:a259777c45a3	92	return -1;
dirkx	0:a259777c45a3	93	return rc;
dirkx	0:a259777c45a3	94	}
dirkx	0:a259777c45a3	95
dirkx	0:a259777c45a3	96	#define MIN(a,b) ((a)<(b))?(a):(b)
dirkx	0:a259777c45a3	97	void SMTPClient::process(bool moreData) //Main state-machine
dirkx	0:a259777c45a3	98	{
dirkx	0:a259777c45a3	99	char buf[BUF_SIZE] = {0};
dirkx	0:a259777c45a3	100	if(moreData)
dirkx	0:a259777c45a3	101	{
dirkx	0:a259777c45a3	102	if( m_nextState != SMTP_BODYMORE )
dirkx	0:a259777c45a3	103	{
dirkx	0:a259777c45a3	104	return;
dirkx	0:a259777c45a3	105	}
dirkx	0:a259777c45a3	106	}
dirkx	0:a259777c45a3	107	if(!moreData) //Receive next frame
dirkx	0:a259777c45a3	108	{
dirkx	0:a259777c45a3	109	m_pTCPSocket->recv(buf, BUF_SIZE - 1);
dirkx	0:a259777c45a3	110	}
dirkx	0:a259777c45a3	111
dirkx	0:a259777c45a3	112	IpAddr myIp(0,0,0,0);
dirkx	0:a259777c45a3	113	string to;
dirkx	0:a259777c45a3	114	int sendLen;
dirkx	0:a259777c45a3	115
dirkx	0:a259777c45a3	116	DBG("In state %d", m_nextState);
dirkx	0:a259777c45a3	117
dirkx	0:a259777c45a3	118	switch(m_nextState)
dirkx	0:a259777c45a3	119	{
dirkx	0:a259777c45a3	120	case SMTP_HELLO:
dirkx	0:a259777c45a3	121	if( rc(buf) != 220 )
dirkx	0:a259777c45a3	122	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	123	myIp = Net::getDefaultIf()->getIp();
dirkx	0:a259777c45a3	124	sprintf(buf, "HELO %d.%d.%d.%d\r\n", myIp[0], myIp[1], myIp[2], myIp[3]);
dirkx	0:a259777c45a3	125	m_nextState = SMTP_FROM;
dirkx	0:a259777c45a3	126	break;
dirkx	0:a259777c45a3	127	case SMTP_FROM:
dirkx	0:a259777c45a3	128	if( rc(buf) != 250 )
dirkx	0:a259777c45a3	129	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	130	sprintf(buf, "MAIL FROM:<%s>\r\n", m_pMessage->m_from.c_str());
dirkx	0:a259777c45a3	131	break;
dirkx	0:a259777c45a3	132	case SMTP_TO:
dirkx	0:a259777c45a3	133	if( rc(buf) != 250 )
dirkx	0:a259777c45a3	134	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	135	to = m_pMessage->m_lTo.front();
dirkx	0:a259777c45a3	136	sprintf(buf, "RCPT TO:<%s>\r\n", to.c_str());
dirkx	0:a259777c45a3	137	m_pMessage->m_lTo.pop();
dirkx	0:a259777c45a3	138	if(m_pMessage->m_lTo.empty())
dirkx	0:a259777c45a3	139	{
dirkx	0:a259777c45a3	140	m_nextState = SMTP_DATA;
dirkx	0:a259777c45a3	141	}
dirkx	0:a259777c45a3	142	break;
dirkx	0:a259777c45a3	143	case SMTP_DATA:
dirkx	0:a259777c45a3	144	if( rc(buf) != 250 )
dirkx	0:a259777c45a3	145	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	146	sprintf(buf, "DATA\r\n");
dirkx	0:a259777c45a3	147	break;
dirkx	0:a259777c45a3	148	case SMTP_BODY:
dirkx	0:a259777c45a3	149	if( rc(buf) != 354 )
dirkx	0:a259777c45a3	150	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	151	m_nextState = SMTP_BODYMORE;
dirkx	0:a259777c45a3	152	case SMTP_BODYMORE:
dirkx	0:a259777c45a3	153	sendLen = 0;
dirkx	0:a259777c45a3	154	if( m_posInMsg < m_pMessage->m_content.length() )
dirkx	0:a259777c45a3	155	{
dirkx	0:a259777c45a3	156	sendLen = MIN( (m_pMessage->m_content.length() - m_posInMsg), CHUNK_SIZE );
dirkx	0:a259777c45a3	157	m_pTCPSocket->send( m_pMessage->m_content.c_str() + m_posInMsg, sendLen );
dirkx	0:a259777c45a3	158	m_posInMsg += sendLen;
dirkx	0:a259777c45a3	159	}
dirkx	0:a259777c45a3	160	if( m_posInMsg == m_pMessage->m_content.length() )
dirkx	0:a259777c45a3	161	{
dirkx	0:a259777c45a3	162	sprintf(buf, "\r\n.\r\n"); //EOF
dirkx	0:a259777c45a3	163	m_nextState = SMTP_EOF;
dirkx	0:a259777c45a3	164	}
dirkx	0:a259777c45a3	165	break;
dirkx	0:a259777c45a3	166	case SMTP_EOF:
dirkx	0:a259777c45a3	167	if( rc(buf) != 250 )
dirkx	0:a259777c45a3	168	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	169	sprintf(buf, "QUIT\r\n");
dirkx	0:a259777c45a3	170	m_nextState = SMTP_BYE;
dirkx	0:a259777c45a3	171	break;
dirkx	0:a259777c45a3	172	case SMTP_BYE:
dirkx	0:a259777c45a3	173	if( rc(buf) != 221 )
dirkx	0:a259777c45a3	174	{ close(); onResult(SMTP_PRTCL); return; }
dirkx	0:a259777c45a3	175	close();
dirkx	0:a259777c45a3	176	onResult(SMTP_OK);
dirkx	0:a259777c45a3	177	break;
dirkx	0:a259777c45a3	178	}
dirkx	0:a259777c45a3	179
dirkx	0:a259777c45a3	180	if( m_nextState != SMTP_BODYMORE )
dirkx	0:a259777c45a3	181	{
dirkx	0:a259777c45a3	182	m_pTCPSocket->send( buf, strlen(buf) );
dirkx	0:a259777c45a3	183	}
dirkx	0:a259777c45a3	184	}
dirkx	0:a259777c45a3	185
dirkx	0:a259777c45a3	186	void SMTPClient::setTimeout(int ms)
dirkx	0:a259777c45a3	187	{
dirkx	0:a259777c45a3	188	m_timeout = 1000*ms;
dirkx	0:a259777c45a3	189	resetTimeout();
dirkx	0:a259777c45a3	190	}
dirkx	0:a259777c45a3	191
dirkx	0:a259777c45a3	192	void SMTPClient::resetTimeout()
dirkx	0:a259777c45a3	193	{
dirkx	0:a259777c45a3	194	m_watchdog.detach();
dirkx	0:a259777c45a3	195	m_watchdog.attach_us<SMTPClient>(this, &SMTPClient::onTimeout, m_timeout);
dirkx	0:a259777c45a3	196	}
dirkx	0:a259777c45a3	197
dirkx	0:a259777c45a3	198	void SMTPClient::onTimeout() //Connection has timed out
dirkx	0:a259777c45a3	199	{
dirkx	0:a259777c45a3	200	close();
dirkx	0:a259777c45a3	201	onResult(SMTP_TIMEOUT);
dirkx	0:a259777c45a3	202	}
dirkx	0:a259777c45a3	203
dirkx	0:a259777c45a3	204	void SMTPClient::onTCPSocketEvent(TCPSocketEvent e)
dirkx	0:a259777c45a3	205	{
dirkx	0:a259777c45a3	206	switch(e)
dirkx	0:a259777c45a3	207	{
dirkx	0:a259777c45a3	208	case TCPSOCKET_READABLE:
dirkx	0:a259777c45a3	209	resetTimeout();
dirkx	0:a259777c45a3	210	process(false);
dirkx	0:a259777c45a3	211	break;
dirkx	0:a259777c45a3	212	case TCPSOCKET_WRITEABLE:
dirkx	0:a259777c45a3	213	resetTimeout();
dirkx	0:a259777c45a3	214	process(true);
dirkx	0:a259777c45a3	215	break;
dirkx	0:a259777c45a3	216	case TCPSOCKET_CONTIMEOUT:
dirkx	0:a259777c45a3	217	case TCPSOCKET_CONRST:
dirkx	0:a259777c45a3	218	case TCPSOCKET_CONABRT:
dirkx	0:a259777c45a3	219	case TCPSOCKET_ERROR:
dirkx	0:a259777c45a3	220	onResult(SMTP_DISC);
dirkx	0:a259777c45a3	221	DBG("\r\nConnection error in SMTP Client.\r\n");
dirkx	0:a259777c45a3	222	close();
dirkx	0:a259777c45a3	223	break;
dirkx	0:a259777c45a3	224	case TCPSOCKET_DISCONNECTED:
dirkx	0:a259777c45a3	225	if(m_nextState != SMTP_BYE)
dirkx	0:a259777c45a3	226	{
dirkx	0:a259777c45a3	227	onResult(SMTP_DISC);
dirkx	0:a259777c45a3	228	DBG("\r\nConnection error in SMTP Client.\r\n");
dirkx	0:a259777c45a3	229	close();
dirkx	0:a259777c45a3	230	}
dirkx	0:a259777c45a3	231	break;
dirkx	0:a259777c45a3	232	}
dirkx	0:a259777c45a3	233	}
dirkx	0:a259777c45a3	234
dirkx	0:a259777c45a3	235	void SMTPClient::onResult(SMTPResult r) //Must be called by impl when the request completes
dirkx	0:a259777c45a3	236	{
dirkx	0:a259777c45a3	237	if(m_pCbItem && m_pCbMeth)
dirkx	0:a259777c45a3	238	(m_pCbItem->*m_pCbMeth)(r);
dirkx	0:a259777c45a3	239	}
dirkx	0:a259777c45a3	240
dirkx	0:a259777c45a3	241	#endif

Repository toolbox

Export to desktop IDE

Build repository

Repository details

Type:	Program
Mbed OS support:	Mbed 2 deprecated
Created:	14 Aug 2010
Imports:	49
Forks:	0
Commits:	1
Dependents:	0
Dependencies:	2
Followers:	1

services/email/smtp/SMTPClient.cpp@0:a259777c45a3, 2010-08-14 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Important Information for this Arm website

Access Warning