emailjs/smtp/client.js

var smtp 		= require('./smtp');
var smtpError 	= require('./error');
var message		= require('./message');
var address		= require('./address');

var Client = function(server)
{
	this.smtp			= new smtp.SMTP(server);

	//this.smtp.debug(1);

	this.queue			= [];
	this.timer			= null;
	this.sending		= false;
};

Client.prototype = 
{
	_poll: function()
	{
		var self = this;

		clearTimeout(self.timer);

		if(self.queue.length)
		{
			if(self.smtp.state() == smtp.state.NOTCONNECTED)
				self._connect(self.queue[0]);

			else if(self.smtp.state() == smtp.state.CONNECTED && !self.sending)
				self._sendmail(self.queue.shift());
		}
		// wait around 1 seconds in case something does come in, otherwise close out SMTP connection
		else
			self.timer = setTimeout(function() { self.smtp.quit(); }, 1000);
	},

	_connect: function(stack)
	{
		var self = this,

		connect = function(err)
		{
			if(!err)
			{
				var login = function(err)
				{
					if(!err)
						self._poll();

					else
						stack.callback(err, stack.message);
				};

				if(!self.smtp.authorized())
					self.smtp.login(login);

				else
					self._poll();
			}
			else
				stack.callback(err, stack.message);
		};

		self.smtp.connect(connect);
	},

	send: function(msg, callback)
	{
		var self = this;

		if(!(msg instanceof message.Message) && msg.from && msg.to && msg.text)
			msg = message.create(msg);

		if(msg instanceof message.Message && msg.valid())
		{
			var stack = 
			{
				message:		msg,
				to:			address.parse(msg.header["to"]),
				from:			address.parse(msg.header["from"])[0].address,
				callback:	callback || function() {}
			};

			if(msg.header["cc"])
				stack.to = stack.to.concat(address.parse(msg.header["cc"]));

			if(msg.header["bcc"])
				stack.to = stack.to.concat(address.parse(msg.header["bcc"]));

			self.queue.push(stack);
			self._poll();
		}
		else
			callback({code:-1, message:"message is not a valid Message instance"}, msg);
	},

	_sendsmtp: function(stack, next)
	{
		var self	= this;
		var check= function(err)
		{
			if(!err && next)
			{
				next.apply(self, [stack]);
			}
			else
			{
				// if we snag on SMTP commands, call done, passing the error
				// but first reset SMTP state so queue can continue polling
				self.smtp.rset(function()
				{
					self._senddone(stack, err);
				});
			}
		};

		return check;
	},

	_sendmail: function(stack)
	{
		var self = this;
		self.sending = true;
		self.smtp.mail(self._sendsmtp(stack, self._sendrcpt), '<' + stack.from + '>');
	},

	_sendrcpt: function(stack)
	{
		var self = this, to = stack.to.shift().address;
		self.smtp.rcpt(self._sendsmtp(stack, stack.to.length ? self._sendrcpt : self._senddata), '<'+ to +'>');
	},

	_senddata: function(stack)
	{
		var self = this;
		self.smtp.data(self._sendsmtp(stack, self._sendmessage));
	},

	_sendmessage: function(stack)
	{
		var self = this, stream = stack.message.stream();

		stream.on('data', function(data) { self.smtp.message(data); });
		stream.on('end', function() { self.smtp.data_end(self._sendsmtp(stack, self._senddone)); });
		stream.on('error', self._sendsmtp(stack));
	},

	_senddone: function(stack, err)
	{
		var self = this;

		self.sending = false;
		stack.callback(err, stack.message);
		self._poll();
	}
};

exports.Client = Client;

exports.connect = function(server)
{
	return new Client(server);
}