From 7f2eef29708380844922f34f59ba4e9beefbf7c3 Mon Sep 17 00:00:00 2001
From: conber <conber>
Date: Sat, 15 Jun 2002 09:46:14 +0000
Subject: initial checkin

---
(limited to 'noncore/unsupported/mail2/libmail/smtphandler.cpp')

diff --git a/noncore/unsupported/mail2/libmail/smtphandler.cpp b/noncore/unsupported/mail2/libmail/smtphandler.cpp
new file mode 100644
index 0000000..1bbad8b
--- a/dev/null
+++ b/noncore/unsupported/mail2/libmail/smtphandler.cpp
@@ -0,0 +1,172 @@
+#warning "TODO: XXX This class needs to be rewritten. XXX"
+
+#include <qsocket.h>
+#include <qtimer.h>
+#include <qfile.h>
+#include <qdatetime.h>
+#include <qdir.h>
+#include <qregexp.h>
+
+#include <qpe/mimetype.h>
+#include <qpe/config.h>
+
+#include <stdlib.h>
+
+#include "smtphandler.h"
+#include "miscfunctions.h"
+
+SmtpHandler::SmtpHandler(const QString &header, const QString &message, Account &account, const QString &to) 
+	: QObject(), _header(header), _message(message), _account(account), _to(to)
+{
+	_header.replace(QRegExp("\\n"), "\r\n");
+	_message.replace(QRegExp("\\n"), "\r\n");
+	_message.replace(QRegExp("\\r\\n\\.\\r\\n"), "\r\n..\r\n");
+
+//	_state = account.esmtpAuth() ? Ehlo : Helo;
+	_state = Helo;
+
+	_socket = new QSocket(this);
+	connect(_socket, SIGNAL(hostFound()), this, SLOT(hostFound()));
+	connect(_socket, SIGNAL(connected()), this, SLOT(connected()));
+	connect(_socket, SIGNAL(readyRead()), this, SLOT(readyRead()));
+	connect(_socket, SIGNAL(error(int)), this, SLOT(errorHandling(int)));
+
+	_socket->connectToHost(account.smtpServer(), account.smtpPort().toUInt());
+	emit status(tr("Looking up host..."));
+}
+
+void SmtpHandler::errorHandling(int err)
+{
+	if (err == QSocket::ErrConnectionRefused) {
+		emit error(tr("The server refused the connection."));
+	} else if (err == QSocket::ErrHostNotFound) {
+		emit error(tr("Host lookup failed."));
+	} else if (err == QSocket::ErrSocketRead) {
+		emit error(tr("The read from the socket failed for an unknown reason."));
+	} else {
+		emit error(tr("The sending failed for an unknown reason."));
+	}
+	stop();
+}
+
+void SmtpHandler::hostFound()
+{
+	emit status(tr("Host found."));
+}
+
+void SmtpHandler::connected()
+{
+	emit status(tr("Connected to %1").arg(_socket->peerName()));
+}
+
+void SmtpHandler::readyRead()
+{
+	if (!_socket->canReadLine()) return;
+	if (_state == Close) stop();
+
+	QString response = _socket->readLine();
+	QString temp = response;
+	temp.truncate(3);
+	int responseCode = temp.toInt();
+
+#ifndef QT_NO_DEBUG
+	qDebug(tr("SMTP > %3").arg(response.stripWhiteSpace()));
+#endif
+
+	response.replace(0, 4, "");
+	response.stripWhiteSpace();
+
+	if (_state == Ehlo && responseCode == 220) {
+		QString hostname = getenv("HOSTNAME");
+		if (hostname.stripWhiteSpace().isEmpty())
+			hostname = "opiemail";
+
+		emit status(tr("SMTP> EHLO *"));
+		sendToSocket(QString("EHLO %1\r\n").arg(hostname));
+		_state = Auth;
+	} else if (_state == Auth && responseCode == 250) {
+		QStringList capabilities;
+		while (_socket->canReadLine()) {
+			QString line = _socket->readLine().stripWhiteSpace();
+			capabilities.append(line);
+		}
+		
+		// FIXME: Dirty, quick hack!
+		if (!capabilities.grep(QRegExp("^250-AUTH=LOGIN.*CRAM-MD5.*$")).isEmpty()) {
+//			emit errorOccourred(ErrAuthNotSupported);
+			_state = Mail;
+		} else {
+			emit status(tr("SMTP> AUTH CRAM-MD5"));
+			sendToSocket("AUTH CRAM-MD5\r\n");
+			_state = ReadAuth;
+		}
+	} else if (_state == ReadAuth && responseCode == 334) {
+		QString msgId = MiscFunctions::decodeBase64(response);
+	
+		QString authString;
+		authString = _account.user() + " " + 
+			MiscFunctions::smtpAuthCramMd5(msgId, _account.pass());
+		authString = MiscFunctions::encodeBase64(authString);
+
+		emit status(tr("SMTP> Authenticating"));
+		sendToSocket(authString + "\r\n");
+
+		_state = Mail;
+	} else if (_state == Helo && responseCode == 220) {
+		QString hostname = getenv("HOSTNAME");
+		if (hostname.stripWhiteSpace().isEmpty())
+			hostname = "opiemail";
+
+		emit status(tr("SMTP> HELO *"));
+		sendToSocket(QString("HELO %1\r\n").arg(hostname));
+		_state = Mail;
+	} else if (_state == Mail && responseCode == 250) {
+		emit status(tr("SMTP> MAIL FROM: *"));
+		sendToSocket("MAIL FROM: " + _account.email() + "\r\n");
+		_state = Rcpt;
+	} else if (_state == Rcpt && responseCode == 250) {
+		emit status(tr("SMTP> RCPT TO: *"));
+		sendToSocket("RCPT TO: " + _to + "\r\n");
+		_state = Data;
+	} else if (_state == Data && responseCode == 250) {
+		emit status(tr("SMTP> DATA"));
+		sendToSocket("DATA\r\n");
+		_state = Body;
+	} else if (_state == Body && responseCode == 354) {
+		emit status(tr("SMTP> Sending data..."));
+		sendToSocket(_header + "\r\n" + _message + "\r\n.\r\n", false);
+		_state = Quit;
+	} else if (_state == Quit) {
+		emit status(tr("SMTP> QUIT (Done)"));
+		sendToSocket("QUIT\r\n");
+		_state = Close;
+	} else if (_state == Close) {
+
+	} else {
+		emit error(tr("The server returned an error. This is the message:<br>%1").arg(response));
+		stop();
+	}
+}
+
+void SmtpHandler::sendToSocket(const QString &text, bool log)
+{
+	_socket->writeBlock(text.latin1(), text.length());
+
+	if (log) {
+#ifndef QT_NO_DEBUG
+		qDebug(tr("SMTP < %3").arg(text.stripWhiteSpace()));
+#endif
+	}
+}
+
+void SmtpHandler::stop()
+{
+	emit finished();
+	QTimer::singleShot(0, this, SLOT(deleteMe()));
+}
+
+void SmtpHandler::deleteMe()
+{
+	delete this;
+}
+
--
cgit v0.9.0.2