author | zautrix <zautrix> | 2004-10-26 22:56:24 (UTC) |
---|---|---|
committer | zautrix <zautrix> | 2004-10-26 22:56:24 (UTC) |
commit | 00d623c9391a9bdaeb142f443f1dd09861317608 (patch) (unidiff) | |
tree | 941b77a6da7a5db84ed9f4c00ab18918231cb643 /libkdepim/ksyncmanager.cpp | |
parent | 6385f303bef3cbcd19d097a7b05c30e144d5dd6e (diff) | |
download | kdepimpi-00d623c9391a9bdaeb142f443f1dd09861317608.zip kdepimpi-00d623c9391a9bdaeb142f443f1dd09861317608.tar.gz kdepimpi-00d623c9391a9bdaeb142f443f1dd09861317608.tar.bz2 |
added external time for pisync - kdesync
-rw-r--r-- | libkdepim/ksyncmanager.cpp | 16 |
1 files changed, 14 insertions, 2 deletions
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp index feb184b..e09050e 100644 --- a/libkdepim/ksyncmanager.cpp +++ b/libkdepim/ksyncmanager.cpp | |||
@@ -34,48 +34,51 @@ | |||
34 | #include "kpimprefs.h" | 34 | #include "kpimprefs.h" |
35 | #include <kmessagebox.h> | 35 | #include <kmessagebox.h> |
36 | 36 | ||
37 | #include <qdir.h> | 37 | #include <qdir.h> |
38 | #include <qprogressbar.h> | 38 | #include <qprogressbar.h> |
39 | #include <qpopupmenu.h> | 39 | #include <qpopupmenu.h> |
40 | #include <qpushbutton.h> | 40 | #include <qpushbutton.h> |
41 | #include <qradiobutton.h> | 41 | #include <qradiobutton.h> |
42 | #include <qbuttongroup.h> | 42 | #include <qbuttongroup.h> |
43 | #include <qtimer.h> | 43 | #include <qtimer.h> |
44 | #include <qmessagebox.h> | 44 | #include <qmessagebox.h> |
45 | #include <qapplication.h> | 45 | #include <qapplication.h> |
46 | #include <qlineedit.h> | 46 | #include <qlineedit.h> |
47 | #include <qdialog.h> | 47 | #include <qdialog.h> |
48 | #include <qlayout.h> | 48 | #include <qlayout.h> |
49 | #include <qtextcodec.h> | 49 | #include <qtextcodec.h> |
50 | #include <qlabel.h> | 50 | #include <qlabel.h> |
51 | #include <qcheckbox.h> | 51 | #include <qcheckbox.h> |
52 | 52 | ||
53 | #include <klocale.h> | 53 | #include <klocale.h> |
54 | #include <kglobal.h> | 54 | #include <kglobal.h> |
55 | #include <kconfig.h> | 55 | #include <kconfig.h> |
56 | #include <kfiledialog.h> | 56 | #include <kfiledialog.h> |
57 | 57 | ||
58 | QDateTime KSyncManager::mRequestedSyncEvent; | ||
59 | |||
60 | |||
58 | KSyncManager::KSyncManager(QWidget* parent, KSyncInterface* implementation, TargetApp ta, KPimPrefs* prefs, QPopupMenu* syncmenu) | 61 | KSyncManager::KSyncManager(QWidget* parent, KSyncInterface* implementation, TargetApp ta, KPimPrefs* prefs, QPopupMenu* syncmenu) |
59 | : QObject(), mParent(parent), mImplementation(implementation), mTargetApp(ta), mPrefs(prefs ),mSyncMenu(syncmenu) | 62 | : QObject(), mParent(parent), mImplementation(implementation), mTargetApp(ta), mPrefs(prefs ),mSyncMenu(syncmenu) |
60 | { | 63 | { |
61 | mServerSocket = 0; | 64 | mServerSocket = 0; |
62 | bar = new QProgressBar ( 1, 0 ); | 65 | bar = new QProgressBar ( 1, 0 ); |
63 | bar->setCaption (""); | 66 | bar->setCaption (""); |
64 | 67 | ||
65 | int w = 300; | 68 | int w = 300; |
66 | if ( QApplication::desktop()->width() < 320 ) | 69 | if ( QApplication::desktop()->width() < 320 ) |
67 | w = 220; | 70 | w = 220; |
68 | int h = bar->sizeHint().height() ; | 71 | int h = bar->sizeHint().height() ; |
69 | int dw = QApplication::desktop()->width(); | 72 | int dw = QApplication::desktop()->width(); |
70 | int dh = QApplication::desktop()->height(); | 73 | int dh = QApplication::desktop()->height(); |
71 | bar->setGeometry( (dw-w)/2, (dh - h )/2 ,w,h ); | 74 | bar->setGeometry( (dw-w)/2, (dh - h )/2 ,w,h ); |
72 | if ( mPrefs->mPassiveSyncAutoStart ) | 75 | if ( mPrefs->mPassiveSyncAutoStart ) |
73 | enableQuick( false ); | 76 | enableQuick( false ); |
74 | 77 | ||
75 | } | 78 | } |
76 | 79 | ||
77 | KSyncManager::~KSyncManager() | 80 | KSyncManager::~KSyncManager() |
78 | { | 81 | { |
79 | delete bar; | 82 | delete bar; |
80 | } | 83 | } |
81 | 84 | ||
@@ -1090,51 +1093,58 @@ void KServerSocket::newConnection ( int socket ) | |||
1090 | 1093 | ||
1091 | void KServerSocket::discardClient() | 1094 | void KServerSocket::discardClient() |
1092 | { | 1095 | { |
1093 | //qDebug(" KServerSocket::discardClient()"); | 1096 | //qDebug(" KServerSocket::discardClient()"); |
1094 | if ( mSocket ) { | 1097 | if ( mSocket ) { |
1095 | delete mSocket; | 1098 | delete mSocket; |
1096 | mSocket = 0; | 1099 | mSocket = 0; |
1097 | } | 1100 | } |
1098 | //emit endConnect(); | 1101 | //emit endConnect(); |
1099 | } | 1102 | } |
1100 | void KServerSocket::readClient() | 1103 | void KServerSocket::readClient() |
1101 | { | 1104 | { |
1102 | if ( blockRC ) | 1105 | if ( blockRC ) |
1103 | return; | 1106 | return; |
1104 | if ( mSocket == 0 ) { | 1107 | if ( mSocket == 0 ) { |
1105 | qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 "); | 1108 | qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 "); |
1106 | return; | 1109 | return; |
1107 | } | 1110 | } |
1108 | //qDebug("KServerSocket::readClient()"); | 1111 | //qDebug("KServerSocket::readClient()"); |
1109 | if ( mSocket->canReadLine() ) { | 1112 | if ( mSocket->canReadLine() ) { |
1110 | QString line = mSocket->readLine(); | 1113 | QString line = mSocket->readLine(); |
1111 | //qDebug("KServerSocket readline: %s ", line.latin1()); | 1114 | //qDebug("KServerSocket readline: %s ", line.latin1()); |
1112 | QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line ); | 1115 | QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line ); |
1113 | if ( tokens[0] == "GET" ) { | 1116 | if ( tokens[0] == "GET" ) { |
1114 | if ( tokens[1] == mPassWord ) | 1117 | if ( tokens[1] == mPassWord ) { |
1115 | //emit sendFile( mSocket ); | 1118 | //emit sendFile( mSocket ); |
1119 | bool ok = false; | ||
1120 | QDateTime dt = KGlobal::locale()->readDateTime( tokens[2], KLocale::ISODate, &ok); | ||
1121 | if ( ok ) | ||
1122 | KSyncManager::mRequestedSyncEvent = dt; | ||
1123 | else | ||
1124 | KSyncManager::mRequestedSyncEvent = QDateTime(); | ||
1116 | send_file(); | 1125 | send_file(); |
1126 | } | ||
1117 | else { | 1127 | else { |
1118 | KMessageBox::error( 0, i18n("Got send file request\nwith invalid password")); | 1128 | KMessageBox::error( 0, i18n("Got send file request\nwith invalid password")); |
1119 | //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); | 1129 | //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); |
1120 | } | 1130 | } |
1121 | } | 1131 | } |
1122 | if ( tokens[0] == "PUT" ) { | 1132 | if ( tokens[0] == "PUT" ) { |
1123 | if ( tokens[1] == mPassWord ) { | 1133 | if ( tokens[1] == mPassWord ) { |
1124 | //emit getFile( mSocket ); | 1134 | //emit getFile( mSocket ); |
1125 | blockRC = true; | 1135 | blockRC = true; |
1126 | get_file(); | 1136 | get_file(); |
1127 | } | 1137 | } |
1128 | else { | 1138 | else { |
1129 | KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password")); | 1139 | KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password")); |
1130 | //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); | 1140 | //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); |
1131 | } | 1141 | } |
1132 | } | 1142 | } |
1133 | if ( tokens[0] == "STOP" ) { | 1143 | if ( tokens[0] == "STOP" ) { |
1134 | //emit endConnect(); | 1144 | //emit endConnect(); |
1135 | end_connect(); | 1145 | end_connect(); |
1136 | } | 1146 | } |
1137 | } | 1147 | } |
1138 | } | 1148 | } |
1139 | void KServerSocket::end_connect() | 1149 | void KServerSocket::end_connect() |
1140 | { | 1150 | { |
@@ -1246,49 +1256,51 @@ void KServerSocket::readBackFileFromSocket() | |||
1246 | KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) | 1256 | KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) |
1247 | { | 1257 | { |
1248 | mPassWord = password; | 1258 | mPassWord = password; |
1249 | mSocket = 0; | 1259 | mSocket = 0; |
1250 | mPort = port; | 1260 | mPort = port; |
1251 | mHost = host; | 1261 | mHost = host; |
1252 | 1262 | ||
1253 | mRetVal = quiet; | 1263 | mRetVal = quiet; |
1254 | mTimerSocket = new QTimer ( this ); | 1264 | mTimerSocket = new QTimer ( this ); |
1255 | connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) ); | 1265 | connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) ); |
1256 | } | 1266 | } |
1257 | void KCommandSocket::readFile( QString fn ) | 1267 | void KCommandSocket::readFile( QString fn ) |
1258 | { | 1268 | { |
1259 | if ( !mSocket ) { | 1269 | if ( !mSocket ) { |
1260 | mSocket = new QSocket( this ); | 1270 | mSocket = new QSocket( this ); |
1261 | connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); | 1271 | connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); |
1262 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); | 1272 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); |
1263 | } | 1273 | } |
1264 | mFileString = ""; | 1274 | mFileString = ""; |
1265 | mFileName = fn; | 1275 | mFileName = fn; |
1266 | mFirst = true; | 1276 | mFirst = true; |
1267 | mSocket->connectToHost( mHost, mPort ); | 1277 | mSocket->connectToHost( mHost, mPort ); |
1268 | QTextStream os( mSocket ); | 1278 | QTextStream os( mSocket ); |
1269 | os.setEncoding( QTextStream::Latin1 ); | 1279 | os.setEncoding( QTextStream::Latin1 ); |
1270 | os << "GET " << mPassWord << "\r\n"; | 1280 | |
1281 | QString curDt = KGlobal::locale()->formatDateTime(QDateTime::currentDateTime().addSecs(-1),true, true,KLocale::ISODate ); | ||
1282 | os << "GET " << mPassWord << curDt <<"\r\n"; | ||
1271 | mTimerSocket->start( 20000 ); | 1283 | mTimerSocket->start( 20000 ); |
1272 | } | 1284 | } |
1273 | 1285 | ||
1274 | void KCommandSocket::writeFile( QString fileName ) | 1286 | void KCommandSocket::writeFile( QString fileName ) |
1275 | { | 1287 | { |
1276 | if ( !mSocket ) { | 1288 | if ( !mSocket ) { |
1277 | mSocket = new QSocket( this ); | 1289 | mSocket = new QSocket( this ); |
1278 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); | 1290 | connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); |
1279 | connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); | 1291 | connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); |
1280 | } | 1292 | } |
1281 | mFileName = fileName ; | 1293 | mFileName = fileName ; |
1282 | mSocket->connectToHost( mHost, mPort ); | 1294 | mSocket->connectToHost( mHost, mPort ); |
1283 | } | 1295 | } |
1284 | void KCommandSocket::writeFileToSocket() | 1296 | void KCommandSocket::writeFileToSocket() |
1285 | { | 1297 | { |
1286 | QFile file2( mFileName ); | 1298 | QFile file2( mFileName ); |
1287 | if (!file2.open( IO_ReadOnly ) ) { | 1299 | if (!file2.open( IO_ReadOnly ) ) { |
1288 | mRetVal= errorW; | 1300 | mRetVal= errorW; |
1289 | mSocket->close(); | 1301 | mSocket->close(); |
1290 | if ( mSocket->state() == QSocket::Idle ) | 1302 | if ( mSocket->state() == QSocket::Idle ) |
1291 | QTimer::singleShot( 10, this , SLOT ( deleteSocket())); | 1303 | QTimer::singleShot( 10, this , SLOT ( deleteSocket())); |
1292 | return ; | 1304 | return ; |
1293 | } | 1305 | } |
1294 | QTextStream ts2( &file2 ); | 1306 | QTextStream ts2( &file2 ); |