1 files changed, 375 insertions, 0 deletions

diff --git a/noncore/unsupported/mailit/popclient.cpp b/noncore/unsupported/mailit/popclient.cpp
new file mode 100644
index 0000000..a406af2
--- a/dev/null
+++ b/noncore/unsupported/mailit/popclient.cpp
@@ -0,0 +1,375 @@
+/**********************************************************************
+** Copyright (C) 2001 Trolltech AS.  All rights reserved.
+**
+** This file is part of Qt Palmtop Environment.
+**
+** This file may be distributed and/or modified under the terms of the
+** GNU General Public License version 2 as published by the Free Software
+** Foundation and appearing in the file LICENSE.GPL included in the
+** packaging of this file.
+**
+** This file is provided AS IS with NO WARRANTY OF ANY KIND, INCLUDING THE
+** WARRANTY OF DESIGN, MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE.
+**
+** See http://www.trolltech.com/gpl/ for GPL licensing information.
+**
+** Contact info@trolltech.com if any conditions of this licensing are
+** not clear to you.
+**
+**********************************************************************/
+#include "popclient.h"
+#include "emailhandler.h"
+//#define APOP_TEST
+
+extern "C" {
+#include "md5.h"
+}
+
+#include <qcstring.h>
+
+PopClient::PopClient()
+{
+  socket = new QSocket(this, "popClient");
+  connect(socket, SIGNAL(error(int)), this, SLOT(errorHandling(int)));
+  connect(socket, SIGNAL(connected()), this, SLOT(connectionEstablished()));
+  connect(socket, SIGNAL(readyRead()), this, SLOT(incomingData()));
+  
+  stream = new QTextStream(socket);
+  
+  receiving = FALSE;
+  synchronize = FALSE;
+  lastSync = 0;
+  headerLimit = 0;
+  preview = FALSE;
+}
+
+PopClient::~PopClient()
+{
+  delete socket;
+  delete stream;
+}
+
+void PopClient::newConnection(QString target, int port)
+{
+  if (receiving) {
+    qWarning("socket in use, connection refused");
+    return;
+  }
+  
+  status = Init;
+  
+  socket->connectToHost(target, port);
+  receiving = TRUE;
+  selected = FALSE;
+    
+  emit updateStatus("DNS lookup");
+}
+
+void PopClient::setAccount(QString popUser, QString popPasswd)
+{
+  popUserName = popUser;
+  popPassword = popPasswd;
+}             
+
+void PopClient::setSynchronize(int lastCount)
+{
+  synchronize = TRUE;
+  lastSync = lastCount;
+}
+
+void PopClient::removeSynchronize()
+{
+  synchronize = FALSE;
+  lastSync = 0;
+}
+
+void PopClient::headersOnly(bool headers, int limit)
+{
+  preview = headers;
+  headerLimit = limit;
+}
+
+void PopClient::setSelectedMails(MailList *list)
+{
+  selected = TRUE;
+  mailList = list;
+}
+
+void PopClient::connectionEstablished()
+{
+  emit updateStatus("Connection established");
+}
+
+void PopClient::errorHandling(int status)
+{
+  emit updateStatus("Error Occured");
+  emit errorOccurred(status);
+  socket->close();
+  receiving = FALSE;
+}
+
+void PopClient::incomingData()
+{
+  QString response, temp, temp2, timeStamp;
+  QString md5Source;
+  int start, end;
+//  char *md5Digest;
+  char md5Digest[16];
+//  if ( !socket->canReadLine() )
+//    return;
+  
+  response = socket->readLine();
+  qDebug(response +" %d", status);
+  
+  switch(status) {
+    //logging in
+    case Init:  {
+#ifdef APOP_TEST
+       start = response.find('<',0);
+       end = response.find('>', start);
+       if( start >= 0 && end > start )
+       {
+          timeStamp = response.mid( start , end - start + 1);
+          md5Source = timeStamp + popPassword;
+          qDebug( md5Source);
+//           for( int i = 0; i < md5Source.length(); i++) {
+//              buff[i] = (QChar)md5Source[i];
+//           }
+          
+          md5_buffer( (char const *)md5Source, md5Source.length(),&md5Digest[0]);
+//          md5_buffer(char const *buffer, unsigned int len, char *digest);
+ 
+//           MD5_Init( &ctx);
+//           MD5_Update( &ctx, buff, sizeof( buff) );
+//           MD5_Final( md5Digest, &ctx);
+//          MD5( buff, md5Source.length(), md5Digest);
+
+           for(int j =0;j < MD5_DIGEST_LENGTH ;j++)
+           {
+              printf("%x", md5Digest[j]);
+           }
+           printf("\n");          
+//          qDebug(md5Digest);
+          *stream << "APOP " <<  popUserName << " " << md5Digest << "\r\n";
+          //    qDebug("%s", stream);
+          status = Stat;
+       }
+       else
+#endif
+       {
+          timeStamp = "";
+          *stream << "USER " << popUserName << "\r\n";
+          status = Pass;
+       }
+          
+          break;
+        }
+    //password shhh. don't tell anyone (implement APOP...)
+    case Pass:  {
+          *stream << "PASS " << popPassword << "\r\n";
+          status = Stat;
+          break;
+        }
+    //ask for number of messages
+    case Stat:  {
+          if (response[0] == '+') {
+            *stream << "STAT" << "\r\n";
+            status = Mcnt;
+          } else errorHandling(ErrLoginFailed);
+            break;
+          }
+    //get count of messages, eg "+OK 4 900.." -> int 4
+    case Mcnt:  {
+          if (response[0] == '+') {
+            temp = response.replace(0, 4, "");
+            int x = temp.find(" ", 0);
+            temp.truncate((uint) x);
+            newMessages = temp.toInt();
+            messageCount = 1;
+            status = List;
+              
+            if (synchronize) {
+              //messages deleted from server, reload all
+              if (newMessages < lastSync)
+                lastSync = 0;
+                messageCount = lastSync + 1;
+              }
+              
+              if (selected) {
+                int *ptr = mailList->first();
+                if (ptr != 0) {
+                  newMessages++;  //to ensure no early jumpout
+                  messageCount = *(mailList->first());
+                } else newMessages = 0;
+              }
+            } else errorHandling(ErrUnknownResponse);
+          }
+    //Read message number x, count upwards to messageCount
+    case List:  {
+          if (messageCount <= newMessages) {
+            *stream << "LIST " << messageCount << "\r\n";
+            status = Size;
+            temp2.setNum(newMessages - lastSync);
+            temp.setNum(messageCount - lastSync);
+            if (!selected) {
+              emit updateStatus("Retrieving " + temp + "/" + temp2);
+            } else {
+              //completing a previously closed transfer
+              if ( (messageCount - lastSync) <= 0) {
+                temp.setNum(messageCount);
+                emit updateStatus("Previous message " + temp);
+              } else {
+                emit updateStatus("Completing message " + temp);
+              }
+            }
+            break;
+          } else {
+            emit updateStatus("No new Messages");
+            status = Quit;
+          }
+        } 
+    //get size of message, eg "500 characters in message.." -> int 500
+    case Size:  {
+          if (status != Quit) { //because of idiotic switch
+            if (response[0] == '+') {
+              temp = response.replace(0, 4, "");
+              int x = temp.find(" ", 0);
+              temp = temp.right(temp.length() - ((uint) x + 1) );
+              mailSize = temp.toInt();
+              emit currentMailSize(mailSize);
+              
+              status = Retr;
+            } else {
+              qWarning(response);
+              errorHandling(ErrUnknownResponse);
+            }
+          }
+        } 
+    //Read message number x, count upwards to messageCount
+    case Retr:  {
+          if (status != Quit) {
+            if (!preview || mailSize <= headerLimit) {
+              *stream << "RETR " << messageCount << "\r\n";
+            } else {        //only header
+              *stream << "TOP " << messageCount << " 0\r\n";
+            }
+            messageCount++;
+            status = Ignore;
+            break;
+          }         } 
+    case Ignore:  {
+          if (status != Quit) { //because of idiotic switch
+            if (response[0] == '+') {
+              message = "";
+              status = Read;
+              if (!socket->canReadLine()) //sync. problems
+                break;
+              response = socket->readLine();
+            } else errorHandling(ErrUnknownResponse);
+          }
+        }
+    //add all incoming lines to body.  When size is reached, send
+    //message, and go back to read new message
+    case Read:  {
+          if (status != Quit) { //because of idiotic switch
+            message += response;
+            while ( socket->canReadLine() ) {
+              response = socket->readLine();
+              message += response;
+            }
+            emit downloadedSize(message.length());
+            int x = message.find("\r\n.\r\n",-5);
+            if (x == -1) {
+              break;
+            } else {  //message reach entire size
+              //complete mail downloaded
+              if ( (!preview ) || ((preview) && (mailSize <= headerLimit)) ){
+                emit newMessage(message, messageCount-1, mailSize, TRUE);
+              } else {  //incomplete mail downloaded
+                emit newMessage(message, messageCount-1, mailSize, FALSE);
+              }
+              if (messageCount > newMessages) //that was the last message
+                status = Quit;
+              else {        //ask for new message
+                if (selected) {   //grab next from queue
+                  int *ptr = mailList->next();
+                  if (ptr != 0) {
+                    messageCount = *ptr;
+                    *stream << "LIST " << messageCount << "\r\n";
+                    status = Size;
+                    //completing a previously closed transfer
+                    if ( (messageCount - lastSync) <= 0) {
+                      temp.setNum(messageCount);
+                      emit updateStatus("Previous message " + temp);
+                    } else {
+                      temp.setNum(messageCount - lastSync);
+                      emit updateStatus("Completing message " + temp);
+                    }
+                    break;
+                  } else {
+                    newMessages--;
+                    status = Quit;
+                  }
+                } else {
+                  *stream << "LIST " << messageCount << "\r\n";
+                  status = Size;
+                  temp2.setNum(newMessages - lastSync);
+                  temp.setNum(messageCount - lastSync);
+                  emit updateStatus("Retrieving " + temp + "/" + temp2);
+                  
+                  break;
+                }
+              }
+            }
+            if (status != Quit)
+              break;
+          }
+        }
+    case Quit:  {
+          *stream << "Quit\r\n";
+          status = Done;
+          int newM = newMessages - lastSync;
+          if (newM > 0) {
+            temp.setNum(newM);
+            emit updateStatus(temp + " new messages");
+          } else {
+            emit updateStatus("No new messages");
+          }
+          
+          socket->close();
+          receiving = FALSE;
+          emit mailTransfered(newM);
+          break;
+        }
+  }
+
+}
+
+// if( bAPOPAuthentication )
+//  {
+//    if( m_strTimeStamp.IsEmpty() )
+//    {
+//      SetLastError("Apop error!");
+//      return false;
+//    }
+//    strMD5Source = m_strTimeStamp+pszPassword;
+//    strMD5Dst = MD5_GetMD5( (BYTE*)(const char*)strMD5Source , strMD5Source.GetLength() );
+//    sprintf(msg , "apop %s %s\r\n" , pszUser , strMD5Dst);
+//    ret = send(m_sPop3Socket , msg , strlen(msg) , NULL);
+//    if(ret == SOCKET_ERROR)
+//    {
+//      SetLastError("Socket error!");
+//      m_bSocketOK = false;
+//      m_bConnected = false;
+//      return false;
+//    }
+//    if( !GetSocketResult(&strResult , COMMAND_END_FLAG) )
+//      return false;
+//    if( 0 == strResult.Find('-' , 0) )
+//    {
+//      SetLastError("Username or Password error!");
+//      return false;
+//    }
+//    m_bConnected = true;
+
+//  }