diff options
Diffstat (limited to 'kbugbuster/backend/smtp.cpp')
| -rw-r--r-- | kbugbuster/backend/smtp.cpp | 181 |
1 files changed, 181 insertions, 0 deletions
diff --git a/kbugbuster/backend/smtp.cpp b/kbugbuster/backend/smtp.cpp new file mode 100644 index 00000000..d54cafab --- /dev/null +++ b/kbugbuster/backend/smtp.cpp @@ -0,0 +1,181 @@ +/**************************************************************************** +** +** This file is a modified version of part of an example program for Qt. +** This file may be used, distributed and modified without limitation. +** +** Don Sanders <sanders@kde.org> +** +*****************************************************************************/ + +#include "smtp.h" + +#include <qtextstream.h> +#include <qsocket.h> +#include <qtimer.h> +#include <kapplication.h> +#include <kmessagebox.h> +#include <klocale.h> + +Smtp::Smtp( const QString &from, const QStringList &to, + const QString &aMessage, + const QString &server, + unsigned short int port ) +{ + skipReadResponse = false; + mSocket = new QSocket( this ); + connect ( mSocket, SIGNAL( readyRead() ), + this, SLOT( readyRead() ) ); + connect ( mSocket, SIGNAL( connected() ), + this, SLOT( connected() ) ); + connect ( mSocket, SIGNAL( error(int) ), + this, SLOT( socketError(int) ) ); + + message = aMessage; + + this->from = from; + rcpt = to; + state = smtpInit; + command = ""; + + emit status( i18n( "Connecting to %1" ).arg( server ) ); + + mSocket->connectToHost( server, port ); + t = new QTextStream( mSocket ); + t->setEncoding(QTextStream::Latin1); +} + + +Smtp::~Smtp() +{ + if (t) + delete t; + if (mSocket) + delete mSocket; +} + + +void Smtp::send( const QString &from, const QStringList &to, + const QString &aMessage ) +{ + skipReadResponse = true; + message = aMessage; + this->from = from; + rcpt = to; + + state = smtpMail; + command = ""; + readyRead(); +} + + +void Smtp::quit() +{ + skipReadResponse = true; + state = smtpQuit; + command = ""; + readyRead(); +} + + +void Smtp::connected() +{ + emit status( i18n( "Connected to %1" ).arg( mSocket->peerName() ) ); +} + +void Smtp::socketError(int errorCode) +{ + command = "CONNECT"; + switch ( errorCode ) { + case QSocket::ErrConnectionRefused: + responseLine = i18n( "Connection refused." ); + break; + case QSocket::ErrHostNotFound: + responseLine = i18n( "Host Not Found." ); + break; + case QSocket::ErrSocketRead: + responseLine = i18n( "Error reading socket." ); + break; + default: + responseLine = i18n( "Internal error, unrecognized error." ); + } + QTimer::singleShot( 0, this, SLOT(emitError()) ); +} + +void Smtp::emitError() { + error( command, responseLine ); +} + +void Smtp::readyRead() +{ + if (!skipReadResponse) { + // SMTP is line-oriented + if ( !mSocket->canReadLine() ) + return; + + do { + responseLine = mSocket->readLine(); + response += responseLine; + } while( mSocket->canReadLine() && responseLine[3] != ' ' ); + } + skipReadResponse = false; + + if ( state == smtpInit && responseLine[0] == '2' ) { + // banner was okay, let's go on + command = "HELO there"; + *t << "HELO there\r\n"; + state = smtpMail; + } else if ( state == smtpMail && responseLine[0] == '2' ) { + // HELO response was okay (well, it has to be) + command = "MAIL"; + *t << "MAIL FROM: <" << from << ">\r\n"; + state = smtpRcpt; + } else if ( state == smtpRcpt && responseLine[0] == '2' && (rcpt.begin() != rcpt.end())) { + command = "RCPT"; + *t << "RCPT TO: <" << *(rcpt.begin()) << ">\r\n"; + rcpt.remove( rcpt.begin() ); + if (rcpt.begin() == rcpt.end()) + state = smtpData; + } else if ( state == smtpData && responseLine[0] == '2' ) { + command = "DATA"; + *t << "DATA\r\n"; + state = smtpBody; + } else if ( state == smtpBody && responseLine[0] == '3' ) { + command = "DATA"; + QString seperator = ""; + if (message[message.length() - 1] != '\n') + seperator = "\r\n"; + *t << message << seperator << ".\r\n"; + state = smtpSuccess; + } else if ( state == smtpSuccess && responseLine[0] == '2' ) { + QTimer::singleShot( 0, this, SIGNAL(success()) ); + } else if ( state == smtpQuit && responseLine[0] == '2' ) { + command = "QUIT"; + *t << "QUIT\r\n"; + // here, we just close. + state = smtpClose; + emit status( i18n( "Message sent" ) ); + } else if ( state == smtpClose ) { + // we ignore it + } else { // error occurred + QTimer::singleShot( 0, this, SLOT(emitError()) ); + state = smtpClose; + } + + response = ""; + + if ( state == smtpClose ) { + delete t; + t = 0; + delete mSocket; + mSocket = 0; + QTimer::singleShot( 0, this, SLOT(deleteMe()) ); + } +} + + +void Smtp::deleteMe() +{ + delete this; +} + +#include "smtp.moc" |