Diffstat (limited to 'kmicromail/libmailwrapper/smtpwrapper.cpp') (more/less context) (ignore whitespace changes)
| -rw-r--r-- | kmicromail/libmailwrapper/smtpwrapper.cpp | 458 |
1 files changed, 458 insertions, 0 deletions
diff --git a/kmicromail/libmailwrapper/smtpwrapper.cpp b/kmicromail/libmailwrapper/smtpwrapper.cpp new file mode 100644 index 0000000..04a21ea --- a/dev/null +++ b/kmicromail/libmailwrapper/smtpwrapper.cpp @@ -0,0 +1,458 @@ +#include "smtpwrapper.h" +#include "mailwrapper.h" +#include "abstractmail.h" +#include "logindialog.h" +#include "mailtypes.h" +#include "sendmailprogress.h" + +//#include <opie2/odebug.h> +//#include <qt.h> +#include <qapplication.h> +#include <qmessagebox.h> +#include <stdlib.h> +#include <qpe/config.h> +#include <qpe/qcopenvelope_qws.h> + +#include <libetpan/libetpan.h> + + +using namespace Opie::Core; +progressMailSend*SMTPwrapper::sendProgress = 0; + +SMTPwrapper::SMTPwrapper(SMTPaccount * aSmtp ) + : Generatemail() +{ + m_SmtpAccount = aSmtp; + Config cfg( "mail" ); + cfg.setGroup( "Status" ); + m_queuedMail = cfg.readNumEntry( "outgoing", 0 ); + emit queuedMails( m_queuedMail ); + connect( this, SIGNAL( queuedMails(int) ), this, SLOT( emitQCop(int) ) ); + m_smtp = 0; +} + +SMTPwrapper::~SMTPwrapper() +{ + disc_server(); +} + +void SMTPwrapper::emitQCop( int queued ) { + QCopEnvelope env( "QPE/Pim", "outgoingMails(int)" ); + env << queued; +} + +QString SMTPwrapper::mailsmtpError( int errnum ) { + switch ( errnum ) { + case MAILSMTP_NO_ERROR: + return tr( "No error" ); + case MAILSMTP_ERROR_UNEXPECTED_CODE: + return tr( "Unexpected error code" ); + case MAILSMTP_ERROR_SERVICE_NOT_AVAILABLE: + return tr( "Service not available" ); + case MAILSMTP_ERROR_STREAM: + return tr( "Stream error" ); + case MAILSMTP_ERROR_HOSTNAME: + return tr( "gethostname() failed" ); + case MAILSMTP_ERROR_NOT_IMPLEMENTED: + return tr( "Not implemented" ); + case MAILSMTP_ERROR_ACTION_NOT_TAKEN: + return tr( "Error, action not taken" ); + case MAILSMTP_ERROR_EXCEED_STORAGE_ALLOCATION: + return tr( "Data exceeds storage allocation" ); + case MAILSMTP_ERROR_IN_PROCESSING: + return tr( "Error in processing" ); + case MAILSMTP_ERROR_STARTTLS_NOT_SUPPORTED: + return tr( "Starttls not supported" ); + // case MAILSMTP_ERROR_INSUFFISANT_SYSTEM_STORAGE: + // return tr( "Insufficient system storage" ); + case MAILSMTP_ERROR_MAILBOX_UNAVAILABLE: + return tr( "Mailbox unavailable" ); + case MAILSMTP_ERROR_MAILBOX_NAME_NOT_ALLOWED: + return tr( "Mailbox name not allowed" ); + case MAILSMTP_ERROR_BAD_SEQUENCE_OF_COMMAND: + return tr( "Bad command sequence" ); + case MAILSMTP_ERROR_USER_NOT_LOCAL: + return tr( "User not local" ); + case MAILSMTP_ERROR_TRANSACTION_FAILED: + return tr( "Transaction failed" ); + case MAILSMTP_ERROR_MEMORY: + return tr( "Memory error" ); + case MAILSMTP_ERROR_CONNECTION_REFUSED: + return tr( "Connection refused" ); + default: + return tr( "Unknown error code" ); + } +} + + +void SMTPwrapper::progress( size_t current, size_t maximum ) { + if (SMTPwrapper::sendProgress) { + SMTPwrapper::sendProgress->setSingleMail(current, maximum ); + qApp->processEvents(); + } +} + +void SMTPwrapper::storeMail(const char*mail, size_t length, const QString&box) { + if (!mail) + return; + QString localfolders = AbstractMail::defaultLocalfolder(); + AbstractMail*wrap = AbstractMail::getWrapper(localfolders); + wrap->createMbox(box); + wrap->storeMessage(mail,length,box); + delete wrap; +} + +void SMTPwrapper::smtpSend( mailmime *mail,bool later) { + clist *rcpts = 0; + char *from, *data; + size_t size; + + from = data = 0; + + mailmessage * msg = 0; + msg = mime_message_init(mail); + mime_message_set_tmpdir(msg,getenv( "HOME" )); + int r = mailmessage_fetch(msg,&data,&size); + mime_message_detach_mime(msg); + mailmessage_free(msg); + if (r != MAIL_NO_ERROR || !data) { + if (data) + free(data); + ; // odebug << "Error fetching mime..." << oendl; + return; + } + msg = 0; + if (later) { + storeMail(data,size,"Outgoing"); + if (data) + free( data ); + Config cfg( "mail" ); + cfg.setGroup( "Status" ); + cfg.writeEntry( "outgoing", ++m_queuedMail ); + emit queuedMails( m_queuedMail ); + return; + } + from = getFrom( mail ); + rcpts = createRcptList( mail->mm_data.mm_message.mm_fields ); + smtpSend(from,rcpts,data,size); + if (data) { + free(data); + } + if (from) { + free(from); + } + if (rcpts) + smtp_address_list_free( rcpts ); +} + +void SMTPwrapper::storeFailedMail(const char*data,unsigned int size, const char*failuremessage) +{ + if (data) { + storeMail(data,size,"Sendfailed"); + } + if (failuremessage) { + QMessageBox::critical(0,tr("Error sending mail"), + tr("<center>%1</center>").arg(failuremessage)); + } +} + +int SMTPwrapper::start_smtp_tls() +{ + if (!m_smtp) { + return MAILSMTP_ERROR_IN_PROCESSING; + } + int err = mailesmtp_starttls(m_smtp); + if (err != MAILSMTP_NO_ERROR) return err; + mailstream_low * low; + mailstream_low * new_low; + low = mailstream_get_low(m_smtp->stream); + if (!low) { + return MAILSMTP_ERROR_IN_PROCESSING; + } + int fd = mailstream_low_get_fd(low); + if (fd > -1 && (new_low = mailstream_low_ssl_open(fd))!=0) { + mailstream_low_free(low); + mailstream_set_low(m_smtp->stream, new_low); + } else { + return MAILSMTP_ERROR_IN_PROCESSING; + } + return err; +} + +void SMTPwrapper::connect_server() +{ + const char *server, *user, *pass; + bool ssl; + uint16_t port; + ssl = false; + bool try_tls = true; + bool force_tls=false; + server = user = pass = 0; + QString failuretext = ""; + + if (m_smtp || !m_SmtpAccount) { + return; + } + server = m_SmtpAccount->getServer().latin1(); + if ( m_SmtpAccount->ConnectionType() == 2 ) { + ssl = true; + try_tls = false; + } else if (m_SmtpAccount->ConnectionType() == 1) { + force_tls = true; + } + int result = 1; + port = m_SmtpAccount->getPort().toUInt(); + + m_smtp = mailsmtp_new( 20, &progress ); + if ( m_smtp == NULL ) { + /* no failure message cause this happens when problems with memory - than we + we can not display any messagebox */ + return; + } + + int err = MAILSMTP_NO_ERROR; + ; // odebug << "Servername " << server << " at port " << port << "" << oendl; + if ( ssl ) { + ; // odebug << "SSL session" << oendl; + err = mailsmtp_ssl_connect( m_smtp, server, port ); + } else { + ; // odebug << "No SSL session" << oendl; + err = mailsmtp_socket_connect( m_smtp, server, port ); + } + if ( err != MAILSMTP_NO_ERROR ) { + ; // odebug << "Error init connection" << oendl; + failuretext = tr("Error init SMTP connection: %1").arg(mailsmtpError(err)); + result = 0; + } + + /* switch to tls after init 'cause there it will send the ehlo */ + if (result) { + err = mailsmtp_init( m_smtp ); + if (err != MAILSMTP_NO_ERROR) { + result = 0; + failuretext = tr("Error init SMTP connection: %1").arg(mailsmtpError(err)); + } + } + + if (try_tls) { + err = start_smtp_tls(); + if (err != MAILSMTP_NO_ERROR) { + try_tls = false; + } else { + err = mailesmtp_ehlo(m_smtp); + } + } + + if (!try_tls && force_tls) { + result = 0; + failuretext = tr("Error init SMTP tls: %1").arg(mailsmtpError(err)); + } + + if (result==1 && m_SmtpAccount->getLogin() ) { + ; // odebug << "smtp with auth" << oendl; + if ( m_SmtpAccount->getUser().isEmpty() || m_SmtpAccount->getPassword().isEmpty() ) { + // get'em + LoginDialog login( m_SmtpAccount->getUser(), + m_SmtpAccount->getPassword(), NULL, 0, true ); + login.show(); + if ( QDialog::Accepted == login.exec() ) { + // ok + user = login.getUser().latin1(); + pass = login.getPassword().latin1(); + } else { + result = 0; + failuretext=tr("Login aborted - storing mail to localfolder"); + } + } else { + user = m_SmtpAccount->getUser().latin1(); + pass = m_SmtpAccount->getPassword().latin1(); + } + ; // odebug << "session->auth: " << m_smtp->auth << "" << oendl; + if (result) { + err = mailsmtp_auth( m_smtp, (char*)user, (char*)pass ); + if ( err == MAILSMTP_NO_ERROR ) { + ; // odebug << "auth ok" << oendl; + } else { + failuretext = tr("Authentification failed"); + result = 0; + } + } + } +} + +void SMTPwrapper::disc_server() +{ + if (m_smtp) { + mailsmtp_quit( m_smtp ); + mailsmtp_free( m_smtp ); + m_smtp = 0; + } +} + +int SMTPwrapper::smtpSend(char*from,clist*rcpts,const char*data,size_t size ) +{ + int err,result; + QString failuretext = ""; + + connect_server(); + + result = 1; + if (m_smtp) { + err = mailsmtp_send( m_smtp, from, rcpts, data, size ); + if ( err != MAILSMTP_NO_ERROR ) { + failuretext=tr("Error sending mail: %1").arg(mailsmtpError(err)); + result = 0; + } + } else { + result = 0; + } + + if (!result) { + storeFailedMail(data,size,failuretext); + } else { + ; // odebug << "Mail sent." << oendl; + storeMail(data,size,"Sent"); + } + return result; +} + +void SMTPwrapper::sendMail(const Opie::Core::OSmartPointer<Mail>&mail,bool later ) +{ + mailmime * mimeMail; + + mimeMail = createMimeMail(mail ); + if ( mimeMail == NULL ) { + ; // odebug << "sendMail: error creating mime mail" << oendl; + } else { + sendProgress = new progressMailSend(); + sendProgress->show(); + sendProgress->setMaxMails(1); + smtpSend( mimeMail,later); + ; // odebug << "Clean up done" << oendl; + sendProgress->hide(); + delete sendProgress; + sendProgress = 0; + mailmime_free( mimeMail ); + } +} + +int SMTPwrapper::sendQueuedMail(AbstractMail*wrap,const RecMailP&which) { + size_t curTok = 0; + mailimf_fields *fields = 0; + mailimf_field*ffrom = 0; + clist *rcpts = 0; + char*from = 0; + int res = 0; + + encodedString * data = wrap->fetchRawBody(which); + if (!data) + return 0; + int err = mailimf_fields_parse( data->Content(), data->Length(), &curTok, &fields ); + if (err != MAILIMF_NO_ERROR) { + delete data; + delete wrap; + return 0; + } + + rcpts = createRcptList( fields ); + ffrom = getField(fields, MAILIMF_FIELD_FROM ); + from = getFrom(ffrom); + + if (rcpts && from) { + res = smtpSend(from,rcpts,data->Content(),data->Length()); + } + if (fields) { + mailimf_fields_free(fields); + fields = 0; + } + if (data) { + delete data; + } + if (from) { + free(from); + } + if (rcpts) { + smtp_address_list_free( rcpts ); + } + return res; +} + +/* this is a special fun */ +bool SMTPwrapper::flushOutbox() { + bool returnValue = true; + + ; // odebug << "Sending the queue" << oendl; + if (!m_SmtpAccount) { + ; // odebug << "No smtp account given" << oendl; + return false; + } + + bool reset_user_value = false; + QString localfolders = AbstractMail::defaultLocalfolder(); + AbstractMail*wrap = AbstractMail::getWrapper(localfolders); + if (!wrap) { + ; // odebug << "memory error" << oendl; + return false; + } + QString oldPw, oldUser; + QValueList<RecMailP> mailsToSend; + QValueList<RecMailP> mailsToRemove; + QString mbox("Outgoing"); + wrap->listMessages(mbox,mailsToSend); + if (mailsToSend.count()==0) { + delete wrap; + ; // odebug << "No mails to send" << oendl; + return false; + } + + oldPw = m_SmtpAccount->getPassword(); + oldUser = m_SmtpAccount->getUser(); + if (m_SmtpAccount->getLogin() && (m_SmtpAccount->getUser().isEmpty() || m_SmtpAccount->getPassword().isEmpty()) ) { + // get'em + QString user,pass; + LoginDialog login( m_SmtpAccount->getUser(), m_SmtpAccount->getPassword(), NULL, 0, true ); + login.show(); + if ( QDialog::Accepted == login.exec() ) { + // ok + user = login.getUser().latin1(); + pass = login.getPassword().latin1(); + reset_user_value = true; + m_SmtpAccount->setUser(user); + m_SmtpAccount->setPassword(pass); + } else { + return true; + } + } + + + sendProgress = new progressMailSend(); + sendProgress->show(); + sendProgress->setMaxMails(mailsToSend.count()); + + while (mailsToSend.count()>0) { + if (sendQueuedMail(wrap, (*mailsToSend.begin()))==0) { + QMessageBox::critical(0,tr("Error sending mail"), + tr("Error sending queued mail - breaking")); + returnValue = false; + break; + } + mailsToRemove.append((*mailsToSend.begin())); + mailsToSend.remove(mailsToSend.begin()); + sendProgress->setCurrentMails(mailsToRemove.count()); + } + if (reset_user_value) { + m_SmtpAccount->setUser(oldUser); + m_SmtpAccount->setPassword(oldPw); + } + Config cfg( "mail" ); + cfg.setGroup( "Status" ); + m_queuedMail = 0; + cfg.writeEntry( "outgoing", m_queuedMail ); + emit queuedMails( m_queuedMail ); + sendProgress->hide(); + delete sendProgress; + sendProgress = 0; + wrap->deleteMails(mbox,mailsToRemove); + delete wrap; + return returnValue; +} |