sync fixes

2 files changed, 48 insertions, 75 deletions

diff --git a/korganizer/mainwindow.cpp b/korganizer/mainwindow.cpp
index b7176a1..5aa75f5 100644
--- a/korganizer/mainwindow.cpp
+++ b/korganizer/mainwindow.cpp
@@ -1282,8 +1282,16 @@ void MainWindow::aboutKnownBugs()
 QString MainWindow::defaultFileName()
 {
     return locateLocal( "data", "korganizer/mycalendar.ics" );
 }
+QString MainWindow::syncFileName()
+{
+#ifdef _WIN32_
+    return  locateLocal( "tmp", "synccalendar.ics" );
+#else
+    return QString( "/tmp/kopitempfile.ics" );
+#endif
+}
 
 void MainWindow::processIncidenceSelection( Incidence *incidence )
 {
     if ( !incidence ) {
@@ -1923,22 +1931,20 @@ void MainWindow::enableQuick()
     if ( ! ok ) {
         KMessageBox::information( this, i18n("No valid port"));
         return;
     }
-    qDebug("port %d ", port);
+    //qDebug("port %d ", port);
     mServerSocket = new KServerSocket ( passWordPiSync, port ,1 );
     mServerSocket->setFileName( defaultFileName() );
-    qDebug("connected ");
+    //qDebug("connected ");
     if ( !mServerSocket->ok() ) {
         qWarning("Failed to bind to port %d", port);
         delete mServerSocket;
         mServerSocket = 0;
         return;
     }
-     connect( mServerSocket, SIGNAL ( saveFile() ), this, SLOT  ( save() ) );
+    connect( mServerSocket, SIGNAL ( saveFile() ), this, SLOT  ( save() ) );
     connect( mServerSocket, SIGNAL ( file_received( bool ) ), this, SLOT  ( getFile( bool ) ) );
-    // connect( mServerSocket, SIGNAL ( sendFile(QSocket*) ), this, SLOT  ( sendFile(QSocket*) ) );
-    //connect( mServerSocket, SIGNAL ( getFile(QSocket*) ), this, SLOT  ( getFile(QSocket*) ) );
 }
 
 void MainWindow::getFile( bool success )
 {
@@ -1961,94 +1967,62 @@ void MainWindow::syncPi()
 }
 
 void MainWindow::performQuickQuick()
 {
-    // setCaption( i18n("") );
-   
     bool ok;
     Q_UINT16 port = KOPrefs::instance()->mActiveSyncPort.toUInt(&ok);
     if ( ! ok ) {
         setCaption( i18n("Sorry, no valid port.Syncing cancelled.") );
         return;
     }
-     KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, KOPrefs::instance()->mActiveSyncIP, this );
-    connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, bool )), this, SLOT(deleteCommandSocket(KCommandSocket*,bool)) );
+    KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, KOPrefs::instance()->mActiveSyncIP, this );
+    connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) );
     setCaption( i18n("Sending request for remote file ...") );
-    QString fileName;
-#ifdef _WIN32_
-    fileName = defaultFileName() +"sync";
-#else
-    fileName = "/tmp/kopitempfile.ics";
-#endif
-    commandSocket->readFile(  fileName );
+    commandSocket->readFile(  syncFileName() );
 }
-void MainWindow::deleteCommandSocket(KCommandSocket*s, bool success)
+void MainWindow::deleteCommandSocket(KCommandSocket*s, int state)
 {
-    if ( ! success ) {
-        setCaption( i18n("ERROR:Receiving remote file failed.") );
+    qDebug("MainWindow::deleteCommandSocket %d", state);
+    
+    //enum { success, errorW, errorR, quiet };
+    if ( state == KCommandSocket::errorR ) {
+        setCaption( i18n("ERROR: Receiving remote file failed.") );
         delete s;
-        // pending : send stop
+        KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, KOPrefs::instance()->mActiveSyncPort.toUInt(), KOPrefs::instance()->mActiveSyncIP, this );
+        connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
+        commandSocket->sendStop();
         return;
-
-    }
-    QTimer::singleShot( 1, this , SLOT ( readFileFromSocket()));
-    qDebug("MainWindow::deleteCommandSocket ");
-    delete s;
-}
-void MainWindow::deleteCommandSocketFinish(KCommandSocket* s, bool success )
-{
-    if ( ! success ) {
+        
+    } else  if ( state == KCommandSocket::errorW ) {
         setCaption( i18n("ERROR:Writing back file failed.") );
-    } else {
-        qDebug("Syncing succesful! ");
+
+    } else  if ( state == KCommandSocket::successR ) {
+        QTimer::singleShot( 1, this , SLOT ( readFileFromSocket()));
+
+    } else  if ( state == KCommandSocket::successW ) {
         setCaption( i18n("Pi-Sync succesful!") );
     }
-    qDebug("MainWindow::deleteCommandSocketFinish ");
+
     delete s;
 }
+
 void MainWindow::readFileFromSocket()
 {
-    // mTimerCommandSocket->stop();
-    setCaption( i18n("Receiving remote file ...") );
-    qDebug("MainWindow::readFileFromSocket() ");
-    QString fileName;
-#ifdef _WIN32_
-    fileName = defaultFileName() +"sync";
-#else
-    fileName = "/tmp/kopitempfile.ics";
-#endif
-   
-    setCaption( i18n("Remote file saved to temp file.") );
-    //mCommandSocket = 0;
-    mCurrentSyncProfile = 2 ; // last file
-    mView->setSyncDevice(KOPrefs::instance()->mSyncProfileNames[mCurrentSyncProfile] );
-    mView->setSyncName( KOPrefs::instance()->mLocalMachineName );
-    KConfig config ( locateLocal( "config","ksyncprofilesrc"  ) );
-    KSyncProfile* temp = new KSyncProfile ();
-    temp->setName(KOPrefs::instance()->mSyncProfileNames[mCurrentSyncProfile]);
-    temp->readConfig(&config);
-    KOPrefs::instance()->mAskForPreferences = temp->getAskForPreferences();
-    KOPrefs::instance()->mSyncAlgoPrefs = temp->getSyncPrefs();
-    KOPrefs::instance()->mWriteBackFile = temp->getWriteBackFile();
-    KOPrefs::instance()->mWriteBackExistingOnly = temp->getWriteBackExisting();
-    KOPrefs::instance()->mWriteBackInFuture = 0;
-    if ( temp->getWriteBackFuture() )
-        KOPrefs::instance()->mWriteBackInFuture =  temp->getWriteBackFutureWeeks( );
-    KOPrefs::instance()->mShowSyncSummary = temp->getShowSummaryAfterSync();
-    delete temp;
+    QString fileName = syncFileName();
     setCaption( i18n("Remote file saved to temp file.") );
     if ( ! syncWithFile( fileName , true ) ) {
         setCaption( i18n("Syncing failed.") );
         qDebug("Syncing failed ");
         return;
     }
-
     KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, KOPrefs::instance()->mActiveSyncPort.toUInt(), KOPrefs::instance()->mActiveSyncIP, this );
-    connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, bool )), this, SLOT(deleteCommandSocketFinish(KCommandSocket*,bool)) );
+    connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
     if ( KOPrefs::instance()->mWriteBackFile ) 
         commandSocket->writeFile(  fileName );
-    else
+    else {
         commandSocket->sendStop();
+        setCaption( i18n("Pi-Sync succesful!") );
+    }
 }
 
 void MainWindow::syncLocalFile()
 {
@@ -2502,9 +2476,9 @@ KCommandSocket::KCommandSocket (  QString password, Q_UINT16 port, QString host,
     mSocket = 0;
     mPort = port;
     mHost = host;
 
-    mRetVal = false;
+    mRetVal = quiet;
     mTimerSocket = new QTimer ( this );
     connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket()  ) );
 }
 void KCommandSocket::readFile( QString fn )
@@ -2537,9 +2511,9 @@ void KCommandSocket::writeFile( QString fileName  )
 void KCommandSocket::writeFileToSocket()
 {
     QFile file2( mFileName );
     if (!file2.open( IO_ReadOnly ) ) {
-        mRetVal= false;
+        mRetVal= errorW;
         mSocket->close();
         if ( mSocket->state() == QSocket::Idle )
             QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
         return ;
@@ -2551,9 +2525,9 @@ void KCommandSocket::writeFileToSocket()
     os2 << "PUT " << mPassWord << "\r\n";;
     while ( ! ts2.atEnd() ) {
         os2 << ts2.readLine() << "\n";
     }
-    mRetVal= true;
+    mRetVal= successW;
     file2.close();
     mSocket->close();
     if ( mSocket->state() == QSocket::Idle )
         QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
@@ -2567,9 +2541,8 @@ void KCommandSocket::sendStop()
     mSocket->connectToHost( mHost, mPort ); 
     QTextStream os2( mSocket );
     os2.setCodec( QTextCodec::codecForName("utf8") );
     os2 << "STOP\r\n";
-    mRetVal= true;
     mSocket->close();
     if ( mSocket->state() == QSocket::Idle )
         QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
 }
@@ -2603,9 +2576,9 @@ void KCommandSocket::readFileFromSocket()
     QString fileName = mFileName;
     QFile file ( fileName );
     if (!file.open( IO_WriteOnly ) ) {
         mFileString = "";
-        mRetVal = false;
+        mRetVal = errorR;
         qDebug("Error open temp calender file for writing: %s",fileName.latin1() );
         deleteSocket();
         return ;
                     
@@ -2615,9 +2588,9 @@ void KCommandSocket::readFileFromSocket()
     ts.setCodec( QTextCodec::codecForName("utf8") );
     ts << mFileString;
     file.close();  
     mFileString = "";
-    mRetVal = true;
+    mRetVal = successR;
     mSocket->close();
     // if state is not idle, deleteSocket(); is called via 
     //  connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
     if ( mSocket->state() == QSocket::Idle )
@@ -2628,9 +2601,9 @@ void KCommandSocket::deleteSocket()
 {
     if ( mTimerSocket->isActive () ) {
       mTimerSocket->stop();
       KMessageBox::information( 0, i18n("ERROR:\nConnection to remote host timed out!\nDid you forgot to enable\nsyncing on remote host? "));
-      mRetVal = false;
+      mRetVal = errorR;
     }
     //qDebug("KCommandSocket::deleteSocket() %d", mRetVal ); 
     if ( mSocket)
         delete mSocket;
diff --git a/korganizer/mainwindow.h b/korganizer/mainwindow.h
index 90b3a88..4da371e 100644
--- a/korganizer/mainwindow.h
+++ b/korganizer/mainwindow.h
@@ -60,18 +60,18 @@ private slots:
 
 class KCommandSocket : public QObject
 {
     Q_OBJECT
-
 public:
+    enum state { successR, errorR, successW, errorW, quiet };
     KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent=0, const char * name=0 );
     void readFile( QString );
     void writeFile( QString );
     void sendStop();
     
    
 signals:
-    void commandFinished( KCommandSocket*, bool );
+    void commandFinished( KCommandSocket*, int );
 private slots:
     void startReadFileFromSocket();
     void readFileFromSocket();
     void deleteSocket();
@@ -82,9 +82,9 @@ private slots:
     Q_UINT16 mPort;
     QString mHost;
     QString mFileName;
     QTimer* mTimerSocket;
-    bool mRetVal;
+    int mRetVal;
     QTime mTime;
     QString mFileString;
     bool mFirst;
 };
@@ -105,8 +105,9 @@ class MainWindow : public QMainWindow
     virtual void showMaximized (); 
      void configureAgenda( int );
     void recieve( const QCString& msg, const QByteArray& data );
     static  QString defaultFileName();
+    static  QString syncFileName();
     static QString resourcePath();
     protected slots:  
     void setCaptionToDates();
     int ringSync();
@@ -163,10 +164,9 @@ class MainWindow : public QMainWindow
   private slots:
     QSocket* piSocket;
     QString  piFileString;
     QTime piTime;
-    void deleteCommandSocket(KCommandSocket* s, bool success);
-    void deleteCommandSocketFinish(KCommandSocket* s, bool success);
+    void deleteCommandSocket(KCommandSocket* s, int state );
     void fillSyncMenu();
     void getFile( bool );
     void readFileFromSocket();
   private: