1 files changed, 110 insertions, 0 deletions

diff --git a/noncore/unsupported/mail2/libmail/imapbase.cpp b/noncore/unsupported/mail2/libmail/imapbase.cpp
new file mode 100644
index 0000000..9a2ba47
--- a/dev/null
+++ b/noncore/unsupported/mail2/libmail/imapbase.cpp
@@ -0,0 +1,110 @@
+#include <qsocket.h>
+#include <qtimer.h>
+
+#include "imapbase.h"
+
+IMAPBase::IMAPBase(const Account &account)
+        : QObject(), _account(account)
+{
+        _connected = false;
+        _writingAllowed = false;
+        _socket = new QSocket(this);
+
+        connect(_socket, SIGNAL(readyRead()), SLOT(slotDataAvailiable()));
+        connect(_socket, SIGNAL(hostFound()), SLOT(slotHostFound()));
+        connect(_socket, SIGNAL(connected()), SLOT(slotConnected()));
+        connect(_socket, SIGNAL(connectionClosed()), SLOT(slotDisconnected()));
+        connect(_socket, SIGNAL(error(int)), SLOT(slotError(int)));
+
+        QTimer *commandTimer = new QTimer(this);
+        commandTimer->start(200);
+        connect(commandTimer, SIGNAL(timeout()), SLOT(writeCommands()));
+}
+
+void IMAPBase::sendCommand(const QString &command)
+{
+        if (!_connected) makeConnect();
+        _commandQueue.append(command);
+}
+
+void IMAPBase::disconnect()
+{
+        _connected = false;
+        delete _socket;
+        emit disconnected();
+}
+
+void IMAPBase::makeConnect()
+{
+        emit lookingUpHost();
+        if (_socket == NULL) _socket = new QSocket(this);
+
+        Q_UINT16 port = _account.imapPort().toUInt();
+        _socket->connectToHost(_account.imapServer(), port);
+}
+
+void IMAPBase::writeCommands()
+{
+        if (!_connected) return;
+        if (_commandQueue.isEmpty()) return;
+        if (!_writingAllowed) return;
+
+        QStringList::Iterator it;
+        for (it = _commandQueue.begin(); it != _commandQueue.end(); it++) {
+                if (!(*it).isEmpty() && _writingAllowed) {
+#ifndef QT_NO_DEBUG
+                        qDebug("IMAP > " + (*it).stripWhiteSpace());
+#endif
+                        _socket->writeBlock((*it).latin1(), (*it).length());
+                        _writingAllowed = false;
+                        _commandQueue.remove(it);
+                        break;
+                }
+        }
+}
+
+void IMAPBase::slotError(int err)
+{
+        if (err == QSocket::ErrConnectionRefused) {
+                emit error(IMAPErrConnectionRefused);
+        } else if (err == QSocket::ErrHostNotFound) {
+                emit error(IMAPErrHostNotFound);
+        } else if (err == QSocket::ErrSocketRead) {
+                emit error(IMAPErrSocketRead);
+        } else {
+                emit error(IMAPErrUnknownError);
+        }
+}
+
+void IMAPBase::slotHostFound()
+{
+        emit hostFound();
+}
+
+void IMAPBase::slotConnected()
+{
+        _connected = true;
+        emit connected();
+}
+
+void IMAPBase::slotDisconnected()
+{
+        _connected = false;
+        emit disconnected();
+}
+
+void IMAPBase::slotDataAvailiable()
+{
+        while (_socket->canReadLine()) {
+                _data += _socket->readLine();
+                if (_socket->atEnd()) {
+#ifndef QT_NO_DEBUG
+                        qDebug("IMAP < " + _data.stripWhiteSpace());
+#endif
+                        emit dataReceived(_data);
+                        _writingAllowed = true;
+                        _data = QString(0);
+                }
+        }
+}
+