| -rw-r--r-- | noncore/unsupported/mail2/libmail/smtphandler.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/noncore/unsupported/mail2/libmail/smtphandler.cpp b/noncore/unsupported/mail2/libmail/smtphandler.cpp index 1bbad8b..d0a505d 100644 --- a/noncore/unsupported/mail2/libmail/smtphandler.cpp +++ b/noncore/unsupported/mail2/libmail/smtphandler.cpp @@ -1,172 +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"); + 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"); + 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; } |