summaryrefslogtreecommitdiffabout
path: root/korganizer
authorzautrix <zautrix>2004-10-07 07:28:54 (UTC)
committer zautrix <zautrix>2004-10-07 07:28:54 (UTC)
commit77280f6a176a15b60004f312e6cacdfbbd3909c1 (patch) (side-by-side diff)
treee074d4abedc2f4cc575e5655575e038b9d460106 /korganizer
parentf1eb5b74c962909851607c4b4cb05ee18a347d37 (diff)
downloadkdepimpi-77280f6a176a15b60004f312e6cacdfbbd3909c1.zip
kdepimpi-77280f6a176a15b60004f312e6cacdfbbd3909c1.tar.gz
kdepimpi-77280f6a176a15b60004f312e6cacdfbbd3909c1.tar.bz2
sync changes
Diffstat (limited to 'korganizer') (more/less context) (ignore whitespace changes)
-rw-r--r--korganizer/koprefs.cpp2
-rw-r--r--korganizer/koprefs.h3
-rw-r--r--korganizer/mainwindow.cpp321
-rw-r--r--korganizer/mainwindow.h70
4 files changed, 2 insertions, 394 deletions
diff --git a/korganizer/koprefs.cpp b/korganizer/koprefs.cpp
index 84e3d00..1210094 100644
--- a/korganizer/koprefs.cpp
+++ b/korganizer/koprefs.cpp
@@ -192,8 +192,6 @@ KOPrefs::KOPrefs() :
// addItemBool("WriteBackExistingOnly",&mWriteBackExistingOnly,false);
// addItemBool("AskForPreferences",&mAskForPreferences,true);
// addItemBool("ShowSyncSummary",&mShowSyncSummary,true);
- addItemString("PassiveSyncPort",&mPassiveSyncPort,"9197" );
- addItemString("PassiveSyncPw",&mPassiveSyncPw,"abc" );
addItemString("ActiveSyncPort",&mActiveSyncPort,"9197" );
addItemString("ActiveSyncIP",&mActiveSyncIP,"192.168.0.40" );
addItemBool("ShowSyncEvents",&mShowSyncEvents,false);
diff --git a/korganizer/koprefs.h b/korganizer/koprefs.h
index d9ac851..ff09e19 100644
--- a/korganizer/koprefs.h
+++ b/korganizer/koprefs.h
@@ -278,8 +278,7 @@ class KOPrefs : public KPimPrefs
int mAlarmSuspendCount;
int mAlarmBeepInterval;
- QString mPassiveSyncPort;
- QString mPassiveSyncPw;
+
QString mActiveSyncPort;
QString mActiveSyncIP;
diff --git a/korganizer/mainwindow.cpp b/korganizer/mainwindow.cpp
index 9104347..e3324ee 100644
--- a/korganizer/mainwindow.cpp
+++ b/korganizer/mainwindow.cpp
@@ -130,7 +130,6 @@ MainWindow::MainWindow( QWidget *parent, const char *name, QString msg) :
#ifdef DESKTOP_VERSION
setFont( QFont("Arial"), 14 );
#endif
- mSyncActionDialog = 0;
mServerSocket = 0;
mClosed = false;
//QString confFile = KStandardDirs::appDir() + "config/korganizerrc";
@@ -2347,323 +2346,3 @@ void MainWindow::printCal()
mView->print();//mCp->showDialog();
}
-
-
-KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name )
-{
- mPassWord = pw;
- mSocket = 0;
- mSyncActionDialog = 0;
- blockRC = false;
-};
-
-void KServerSocket::newConnection ( int socket )
-{
- // qDebug("KServerSocket:New connection %d ", socket);
- if ( mSocket ) {
- qDebug("KServerSocket::newConnection Socket deleted! ");
- delete mSocket;
- mSocket = 0;
- }
- mSocket = new QSocket( this );
- connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) );
- connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) );
- mSocket->setSocket( socket );
-}
-
-void KServerSocket::discardClient()
-{
- //qDebug(" KServerSocket::discardClient()");
- if ( mSocket ) {
- delete mSocket;
- mSocket = 0;
- }
- //emit endConnect();
-}
-void KServerSocket::readClient()
-{
- if ( blockRC )
- return;
- if ( mSocket == 0 ) {
- qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 ");
- return;
- }
- qDebug("KServerSocket readClient()");
- if ( mSocket->canReadLine() ) {
- QString line = mSocket->readLine();
- qDebug("KServerSocket readline: %s ", line.latin1());
- QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line );
- if ( tokens[0] == "GET" ) {
- if ( tokens[1] == mPassWord )
- //emit sendFile( mSocket );
- send_file();
- else {
- KMessageBox::information( 0, i18n("ERROR:\nGot send file request\nwith invalid password"));
- qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() );
- }
- }
- if ( tokens[0] == "PUT" ) {
- if ( tokens[1] == mPassWord ) {
- //emit getFile( mSocket );
- blockRC = true;
- get_file();
- }
- else {
- KMessageBox::information( 0, i18n("ERROR:\nGot receive file request\nwith invalid password"));
- qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() );
- }
- }
- if ( tokens[0] == "STOP" ) {
- //emit endConnect();
- end_connect();
- }
- }
-}
-void KServerSocket::end_connect()
-{
- delete mSyncActionDialog;
- mSyncActionDialog = 0;
-}
-void KServerSocket::send_file()
-{
- //qDebug("MainWindow::sendFile(QSocket* s) ");
- if ( mSyncActionDialog )
- delete mSyncActionDialog;
- mSyncActionDialog = new QDialog ( 0, "input-dialog", true );
- mSyncActionDialog->setCaption(i18n("Received sync request"));
- QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog );
- QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog );
- lay->addWidget( label);
- lay->setMargin(7);
- lay->setSpacing(7);
- mSyncActionDialog->setFixedSize( 230, 120);
- mSyncActionDialog->show();
- qDebug("KSS::saving ... ");
- emit saveFile();
- qApp->processEvents();
- QString fileName = mFileName;
- QFile file( fileName );
- if (!file.open( IO_ReadOnly ) ) {
- delete mSyncActionDialog;
- mSyncActionDialog = 0;
- qDebug("KSS::error open file ");
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( discardClient()));
- return ;
-
- }
- mSyncActionDialog->setCaption( i18n("Sending file...") );
- QTextStream ts( &file );
- ts.setCodec( QTextCodec::codecForName("utf8") );
- QTextStream os( mSocket );
- os.setCodec( QTextCodec::codecForName("utf8") );
- //os.setEncoding( QTextStream::UnicodeUTF8 );
- while ( ! ts.atEnd() ) {
- os << ts.readLine() << "\n";
- }
- //os << ts.read();
- file.close();
- mSyncActionDialog->setCaption( i18n("Waiting for synced file...") );
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( discardClient()));
-}
-void KServerSocket::get_file()
-{
- mSyncActionDialog->setCaption( i18n("Receiving synced file...") );
-
- piTime.start();
- piFileString = "";
- QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) ));
-}
-
-
-void KServerSocket::readBackFileFromSocket()
-{
- //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ());
- while ( mSocket->canReadLine () ) {
- piTime.restart();
- QString line = mSocket->readLine ();
- piFileString += line;
- //qDebug("readline: %s ", line.latin1());
- mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) );
-
- }
- if ( piTime.elapsed () < 3000 ) {
- // wait for more
- //qDebug("waitformore ");
- QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) ));
- return;
- }
- QString fileName = mFileName;
- QFile file ( fileName );
- if (!file.open( IO_WriteOnly ) ) {
- delete mSyncActionDialog;
- mSyncActionDialog = 0;
- qDebug("error open cal file ");
- piFileString = "";
- emit file_received( false );
- blockRC = false;
- return ;
-
- }
-
- // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
- QTextStream ts ( &file );
- ts.setCodec( QTextCodec::codecForName("utf8") );
- mSyncActionDialog->setCaption( i18n("Writing file to disk...") );
- ts << piFileString;
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( discardClient()));
- file.close();
- delete mSyncActionDialog;
- mSyncActionDialog = 0;
- piFileString = "";
- blockRC = false;
- emit file_received( true );
-
-}
-
-KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name )
-{
- mPassWord = password;
- mSocket = 0;
- mPort = port;
- mHost = host;
-
- mRetVal = quiet;
- mTimerSocket = new QTimer ( this );
- connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) );
-}
-void KCommandSocket::readFile( QString fn )
-{
- if ( !mSocket ) {
- mSocket = new QSocket( this );
- connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) );
- connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
- }
- mFileString = "";
- mFileName = fn;
- mFirst = true;
- mSocket->connectToHost( mHost, mPort );
- QTextStream os( mSocket );
- os.setEncoding( QTextStream::UnicodeUTF8 );
- os << "GET " << mPassWord << "\r\n";
- mTimerSocket->start( 10000 );
-}
-
-void KCommandSocket::writeFile( QString fileName )
-{
- if ( !mSocket ) {
- mSocket = new QSocket( this );
- connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
- connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) );
- }
- mFileName = fileName ;
- mSocket->connectToHost( mHost, mPort );
-}
-void KCommandSocket::writeFileToSocket()
-{
- QFile file2( mFileName );
- if (!file2.open( IO_ReadOnly ) ) {
- mRetVal= errorW;
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
- return ;
- }
- QTextStream ts2( &file2 );
- ts2.setCodec( QTextCodec::codecForName("utf8") );
- QTextStream os2( mSocket );
- os2.setCodec( QTextCodec::codecForName("utf8") );
- os2 << "PUT " << mPassWord << "\r\n";;
- while ( ! ts2.atEnd() ) {
- os2 << ts2.readLine() << "\n";
- }
- mRetVal= successW;
- file2.close();
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
-}
-void KCommandSocket::sendStop()
-{
- if ( !mSocket ) {
- mSocket = new QSocket( this );
- connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
- }
- mSocket->connectToHost( mHost, mPort );
- QTextStream os2( mSocket );
- os2.setCodec( QTextCodec::codecForName("utf8") );
- os2 << "STOP\r\n";
- mSocket->close();
- if ( mSocket->state() == QSocket::Idle )
- QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
-}
-
-void KCommandSocket::startReadFileFromSocket()
-{
- if ( ! mFirst )
- return;
- mFirst = false;
- mTimerSocket->stop();
- mFileString = "";
- mTime.start();
- QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) ));
-
-}
-void KCommandSocket::readFileFromSocket()
-{
- //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ());
- while ( mSocket->canReadLine () ) {
- mTime.restart();
- QString line = mSocket->readLine ();
- mFileString += line;
- //qDebug("readline: %s ", line.latin1());
- }
- if ( mTime.elapsed () < 3000 ) {
- // wait for more
- //qDebug("waitformore ");
- QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) ));
- return;
- }
- QString fileName = mFileName;
- QFile file ( fileName );
- if (!file.open( IO_WriteOnly ) ) {
- mFileString = "";
- mRetVal = errorR;
- qDebug("Error open temp calender file for writing: %s",fileName.latin1() );
- deleteSocket();
- return ;
-
- }
- // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
- QTextStream ts ( &file );
- ts.setCodec( QTextCodec::codecForName("utf8") );
- ts << mFileString;
- file.close();
- mFileString = "";
- 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 )
- deleteSocket();
-}
-
-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 = errorR;
- }
- //qDebug("KCommandSocket::deleteSocket() %d", mRetVal );
- if ( mSocket)
- delete mSocket;
- mSocket = 0;
- emit commandFinished( this, mRetVal );
-}
-
diff --git a/korganizer/mainwindow.h b/korganizer/mainwindow.h
index 4f89e03..0da0be0 100644
--- a/korganizer/mainwindow.h
+++ b/korganizer/mainwindow.h
@@ -5,12 +5,12 @@
#include <qtimer.h>
#include <qdict.h>
#include <qfile.h>
-#include <qsocket.h>
#include <qtextstream.h>
#include <qregexp.h>
#include <libkcal/incidence.h>
#include "simplealarmclient.h"
+#include <ksyncmanager.h>
class QAction;
class CalendarView;
@@ -21,74 +21,7 @@ class KSyncProfile;
#define QPEMenuBar QMenuBar
#endif
class QPEToolBar;
-#include <qserversocket.h>
-#include <qsocket.h>
-#include <qnetworkprotocol.h>
-class KServerSocket : public QServerSocket
-{
- Q_OBJECT
-
-public:
- KServerSocket ( QString password, Q_UINT16 port, int backlog = 0, QObject * parent=0, const char * name=0 );
-
- void newConnection ( int socket ) ;
- void setFileName( QString fn ) {mFileName = fn;};
-
-signals:
- //void sendFile(QSocket*);
- //void getFile(QSocket*);
- void file_received( bool );
- //void file_sent();
- void saveFile();
- void endConnect();
-private slots:
- void discardClient();
- void readClient();
- void readBackFileFromSocket();
- private :
- bool blockRC;
- void send_file();
- void get_file();
- void end_connect();
- QDialog* mSyncActionDialog;
- QSocket* mSocket;
- QString mPassWord;
- QString mFileName;
- QTime piTime;
- QString piFileString;
-};
-
-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*, int );
-private slots:
- void startReadFileFromSocket();
- void readFileFromSocket();
- void deleteSocket();
- void writeFileToSocket();
- private :
- QSocket* mSocket;
- QString mPassWord;
- Q_UINT16 mPort;
- QString mHost;
- QString mFileName;
- QTimer* mTimerSocket;
- int mRetVal;
- QTime mTime;
- QString mFileString;
- bool mFirst;
-};
namespace KCal {
class CalendarLocal;
@@ -209,7 +142,6 @@ class MainWindow : public QMainWindow
bool mBlockSaveFlag;
bool mCalendarModifiedFlag;
QPixmap loadPixmap( QString );
- QDialog * mSyncActionDialog;
};