summaryrefslogtreecommitdiffabout
Unidiff
Diffstat (more/less context) (ignore whitespace changes)
-rw-r--r--korganizer/calendarview.cpp11
-rw-r--r--libkdepim/ksyncmanager.cpp48
-rw-r--r--libkdepim/ksyncmanager.h2
3 files changed, 50 insertions, 11 deletions
diff --git a/korganizer/calendarview.cpp b/korganizer/calendarview.cpp
index e45240a..6128137 100644
--- a/korganizer/calendarview.cpp
+++ b/korganizer/calendarview.cpp
@@ -1308,521 +1308,524 @@ void CalendarView::addAlarm(const QDateTime &qdt, const QString &noti )
1308 mRecheckAlarmTimer->start( maxSec * 1000 ); 1308 mRecheckAlarmTimer->start( maxSec * 1000 );
1309 // qDebug("recheck Alarm timer started with secs: %d next alarm in sec:%d", maxSec,sec ); 1309 // qDebug("recheck Alarm timer started with secs: %d next alarm in sec:%d", maxSec,sec );
1310 return; 1310 return;
1311 } else { 1311 } else {
1312 mRecheckAlarmTimer->stop(); 1312 mRecheckAlarmTimer->stop();
1313 } 1313 }
1314 //qDebug("Alarm timer started with secs: %d ", sec); 1314 //qDebug("Alarm timer started with secs: %d ", sec);
1315 mAlarmTimer->start( sec * 1000 , true ); 1315 mAlarmTimer->start( sec * 1000 , true );
1316 1316
1317} 1317}
1318// called by mRecheckAlarmTimer to get next alarm 1318// called by mRecheckAlarmTimer to get next alarm
1319// we need this, because a QTimer has only a max range of 25 days 1319// we need this, because a QTimer has only a max range of 25 days
1320void CalendarView::recheckTimerAlarm() 1320void CalendarView::recheckTimerAlarm()
1321{ 1321{
1322 mAlarmTimer->stop(); 1322 mAlarmTimer->stop();
1323 mRecheckAlarmTimer->stop(); 1323 mRecheckAlarmTimer->stop();
1324 mCalendar->checkAlarmForIncidence( 0, true ); 1324 mCalendar->checkAlarmForIncidence( 0, true );
1325} 1325}
1326#ifndef DESKTOP_VERSION 1326#ifndef DESKTOP_VERSION
1327void CalendarView::removeAlarm(const QDateTime &qdt, const QString &noti ) 1327void CalendarView::removeAlarm(const QDateTime &qdt, const QString &noti )
1328#else 1328#else
1329void CalendarView::removeAlarm(const QDateTime &, const QString & ) 1329void CalendarView::removeAlarm(const QDateTime &, const QString & )
1330#endif 1330#endif
1331{ 1331{
1332 //qDebug("-----removeAlarm %s %s ", qdt.toString().latin1() , noti.latin1() ); 1332 //qDebug("-----removeAlarm %s %s ", qdt.toString().latin1() , noti.latin1() );
1333 if ( ! KOPrefs::instance()->mUseInternalAlarmNotification ) { 1333 if ( ! KOPrefs::instance()->mUseInternalAlarmNotification ) {
1334#ifndef DESKTOP_VERSION 1334#ifndef DESKTOP_VERSION
1335 AlarmServer::deleteAlarm (qdt ,"koalarm" ,noti.utf8() ); 1335 AlarmServer::deleteAlarm (qdt ,"koalarm" ,noti.utf8() );
1336#endif 1336#endif
1337 return; 1337 return;
1338 } 1338 }
1339 mAlarmTimer->stop(); 1339 mAlarmTimer->stop();
1340} 1340}
1341void CalendarView::selectWeekNum ( int num ) 1341void CalendarView::selectWeekNum ( int num )
1342{ 1342{
1343 dateNavigator()->blockSignals( true ); 1343 dateNavigator()->blockSignals( true );
1344 dateNavigator()->selectWeek( num ); 1344 dateNavigator()->selectWeek( num );
1345 dateNavigator()->blockSignals( false ); 1345 dateNavigator()->blockSignals( false );
1346 mViewManager->showWeekView(); 1346 mViewManager->showWeekView();
1347} 1347}
1348KOViewManager *CalendarView::viewManager() 1348KOViewManager *CalendarView::viewManager()
1349{ 1349{
1350 return mViewManager; 1350 return mViewManager;
1351} 1351}
1352 1352
1353KODialogManager *CalendarView::dialogManager() 1353KODialogManager *CalendarView::dialogManager()
1354{ 1354{
1355 return mDialogManager; 1355 return mDialogManager;
1356} 1356}
1357 1357
1358QDate CalendarView::startDate() 1358QDate CalendarView::startDate()
1359{ 1359{
1360 DateList dates = mNavigator->selectedDates(); 1360 DateList dates = mNavigator->selectedDates();
1361 1361
1362 return dates.first(); 1362 return dates.first();
1363} 1363}
1364 1364
1365QDate CalendarView::endDate() 1365QDate CalendarView::endDate()
1366{ 1366{
1367 DateList dates = mNavigator->selectedDates(); 1367 DateList dates = mNavigator->selectedDates();
1368 1368
1369 return dates.last(); 1369 return dates.last();
1370} 1370}
1371 1371
1372 1372
1373void CalendarView::createPrinter() 1373void CalendarView::createPrinter()
1374{ 1374{
1375#ifndef KORG_NOPRINTER 1375#ifndef KORG_NOPRINTER
1376 if (!mCalPrinter) { 1376 if (!mCalPrinter) {
1377 mCalPrinter = new CalPrinter(this, mCalendar); 1377 mCalPrinter = new CalPrinter(this, mCalendar);
1378 connect(this, SIGNAL(configChanged()), mCalPrinter, SLOT(updateConfig())); 1378 connect(this, SIGNAL(configChanged()), mCalPrinter, SLOT(updateConfig()));
1379 } 1379 }
1380#endif 1380#endif
1381} 1381}
1382 1382
1383 1383
1384//KOPrefs::instance()->mWriteBackFile 1384//KOPrefs::instance()->mWriteBackFile
1385//KOPrefs::instance()->mWriteBackExistingOnly 1385//KOPrefs::instance()->mWriteBackExistingOnly
1386 1386
1387// 0 syncPrefsGroup->addRadio(i18n("Take local entry on conflict")); 1387// 0 syncPrefsGroup->addRadio(i18n("Take local entry on conflict"));
1388// 1 syncPrefsGroup->addRadio(i18n("Take remote entry on conflict")); 1388// 1 syncPrefsGroup->addRadio(i18n("Take remote entry on conflict"));
1389// 2 syncPrefsGroup->addRadio(i18n("Take newest entry on conflict")); 1389// 2 syncPrefsGroup->addRadio(i18n("Take newest entry on conflict"));
1390// 3 syncPrefsGroup->addRadio(i18n("Ask for every entry on conflict")); 1390// 3 syncPrefsGroup->addRadio(i18n("Ask for every entry on conflict"));
1391// 4 syncPrefsGroup->addRadio(i18n("Force take local entry always")); 1391// 4 syncPrefsGroup->addRadio(i18n("Force take local entry always"));
1392// 5 syncPrefsGroup->addRadio(i18n("Force take remote entry always")); 1392// 5 syncPrefsGroup->addRadio(i18n("Force take remote entry always"));
1393 1393
1394int CalendarView::takeEvent( Incidence* local, Incidence* remote, int mode , bool full ) 1394int CalendarView::takeEvent( Incidence* local, Incidence* remote, int mode , bool full )
1395{ 1395{
1396 1396
1397 // 0 equal 1397 // 0 equal
1398 // 1 take local 1398 // 1 take local
1399 // 2 take remote 1399 // 2 take remote
1400 // 3 cancel 1400 // 3 cancel
1401 QDateTime lastSync = mLastCalendarSync; 1401 QDateTime lastSync = mLastCalendarSync;
1402 QDateTime localMod = local->lastModified(); 1402 QDateTime localMod = local->lastModified();
1403 QDateTime remoteMod = remote->lastModified(); 1403 QDateTime remoteMod = remote->lastModified();
1404 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) { 1404 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) {
1405 bool remCh, locCh; 1405 bool remCh, locCh;
1406 remCh = ( remote->getCsum(mCurrentSyncDevice) != local->getCsum(mCurrentSyncDevice) ); 1406 remCh = ( remote->getCsum(mCurrentSyncDevice) != local->getCsum(mCurrentSyncDevice) );
1407 //if ( remCh ) 1407 //if ( remCh )
1408 //qDebug("loc %s rem %s", local->getCsum(mCurrentSyncDevice).latin1(), remote->getCsum(mCurrentSyncDevice).latin1() ); 1408 //qDebug("loc %s rem %s", local->getCsum(mCurrentSyncDevice).latin1(), remote->getCsum(mCurrentSyncDevice).latin1() );
1409 locCh = ( localMod > mLastCalendarSync ); 1409 locCh = ( localMod > mLastCalendarSync );
1410 if ( !remCh && ! locCh ) { 1410 if ( !remCh && ! locCh ) {
1411 //qDebug("both not changed "); 1411 //qDebug("both not changed ");
1412 lastSync = localMod.addDays(1); 1412 lastSync = localMod.addDays(1);
1413 if ( mode <= SYNC_PREF_ASK ) 1413 if ( mode <= SYNC_PREF_ASK )
1414 return 0; 1414 return 0;
1415 } else { 1415 } else {
1416 if ( locCh ) { 1416 if ( locCh ) {
1417 //qDebug("loc changed %d %s %s", local->revision() , localMod.toString().latin1(), mLastCalendarSync.toString().latin1()); 1417 //qDebug("loc changed %d %s %s", local->revision() , localMod.toString().latin1(), mLastCalendarSync.toString().latin1());
1418 lastSync = localMod.addDays( -1 ); 1418 lastSync = localMod.addDays( -1 );
1419 if ( !remCh ) 1419 if ( !remCh )
1420 remoteMod = ( lastSync.addDays( -1 ) ); 1420 remoteMod = ( lastSync.addDays( -1 ) );
1421 } else { 1421 } else {
1422 //qDebug(" not loc changed "); 1422 //qDebug(" not loc changed ");
1423 lastSync = localMod.addDays( 1 ); 1423 lastSync = localMod.addDays( 1 );
1424 if ( remCh ) 1424 if ( remCh )
1425 remoteMod =( lastSync.addDays( 1 ) ); 1425 remoteMod =( lastSync.addDays( 1 ) );
1426 1426
1427 } 1427 }
1428 } 1428 }
1429 full = true; 1429 full = true;
1430 if ( mode < SYNC_PREF_ASK ) 1430 if ( mode < SYNC_PREF_ASK )
1431 mode = SYNC_PREF_ASK; 1431 mode = SYNC_PREF_ASK;
1432 } else { 1432 } else {
1433 if ( localMod == remoteMod ) 1433 if ( localMod == remoteMod )
1434 // if ( local->revision() == remote->revision() ) 1434 // if ( local->revision() == remote->revision() )
1435 return 0; 1435 return 0;
1436 1436
1437 } 1437 }
1438 // qDebug(" %d %d conflict on %s %s ", mode, full, local->summary().latin1(), remote->summary().latin1() ); 1438 // qDebug(" %d %d conflict on %s %s ", mode, full, local->summary().latin1(), remote->summary().latin1() );
1439 1439
1440 //qDebug("%s %d %s %d", localMod.toString().latin1() , local->revision(), remoteMod.toString().latin1(), remote->revision()); 1440 //qDebug("%s %d %s %d", localMod.toString().latin1() , local->revision(), remoteMod.toString().latin1(), remote->revision());
1441 //qDebug("%d %d %d %d ", localMod.time().second(), localMod.time().msec(), remoteMod.time().second(), remoteMod.time().msec() ); 1441 //qDebug("%d %d %d %d ", localMod.time().second(), localMod.time().msec(), remoteMod.time().second(), remoteMod.time().msec() );
1442 //full = true; //debug only 1442 //full = true; //debug only
1443 if ( full ) { 1443 if ( full ) {
1444 bool equ = false; 1444 bool equ = false;
1445 if ( local->typeID() == eventID ) { 1445 if ( local->typeID() == eventID ) {
1446 equ = (*((Event*) local) == *((Event*) remote)); 1446 equ = (*((Event*) local) == *((Event*) remote));
1447 } 1447 }
1448 else if ( local->typeID() == todoID ) 1448 else if ( local->typeID() == todoID )
1449 equ = (*((Todo*) local) == (*(Todo*) remote)); 1449 equ = (*((Todo*) local) == (*(Todo*) remote));
1450 else if ( local->typeID() == journalID ) 1450 else if ( local->typeID() == journalID )
1451 equ = (*((Journal*) local) == *((Journal*) remote)); 1451 equ = (*((Journal*) local) == *((Journal*) remote));
1452 if ( equ ) { 1452 if ( equ ) {
1453 //qDebug("equal "); 1453 //qDebug("equal ");
1454 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) { 1454 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) {
1455 local->setCsum( mCurrentSyncDevice, remote->getCsum(mCurrentSyncDevice) ); 1455 local->setCsum( mCurrentSyncDevice, remote->getCsum(mCurrentSyncDevice) );
1456 } 1456 }
1457 if ( mode < SYNC_PREF_FORCE_LOCAL ) 1457 if ( mode < SYNC_PREF_FORCE_LOCAL )
1458 return 0; 1458 return 0;
1459 1459
1460 }//else //debug only 1460 }//else //debug only
1461 //qDebug("not equal %s %s ", local->summary().latin1(), remote->summary().latin1()); 1461 //qDebug("not equal %s %s ", local->summary().latin1(), remote->summary().latin1());
1462 } 1462 }
1463 int result; 1463 int result;
1464 bool localIsNew; 1464 bool localIsNew;
1465 //qDebug("%s -- %s mLastCalendarSync %s lastsync %s --- local %s remote %s ",local->summary().latin1(), remote->summary().latin1(),mLastCalendarSync.toString().latin1() ,lastSync.toString().latin1() , localMod.toString().latin1() , remoteMod.toString().latin1() ); 1465 //qDebug("%s -- %s mLastCalendarSync %s lastsync %s --- local %s remote %s ",local->summary().latin1(), remote->summary().latin1(),mLastCalendarSync.toString().latin1() ,lastSync.toString().latin1() , localMod.toString().latin1() , remoteMod.toString().latin1() );
1466 1466
1467 1467
1468 // ************************************************ 1468 // ************************************************
1469 // ************************************************ 1469 // ************************************************
1470 // ************************************************ 1470 // ************************************************
1471 // We may have that lastSync > remoteMod AND lastSync > localMod 1471 // We may have that lastSync > remoteMod AND lastSync > localMod
1472 // BUT remoteMod != localMod 1472 // BUT remoteMod != localMod
1473 1473
1474 1474
1475 if ( full && mode < SYNC_PREF_NEWEST ) 1475 if ( full && mode < SYNC_PREF_NEWEST )
1476 mode = SYNC_PREF_ASK; 1476 mode = SYNC_PREF_ASK;
1477 1477
1478 switch( mode ) { 1478 switch( mode ) {
1479 case SYNC_PREF_LOCAL: 1479 case SYNC_PREF_LOCAL:
1480 if ( lastSync > remoteMod ) 1480 if ( lastSync > remoteMod )
1481 return 1; 1481 return 1;
1482 if ( lastSync > localMod ) 1482 if ( lastSync > localMod )
1483 return 2; 1483 return 2;
1484 return 1; 1484 return 1;
1485 break; 1485 break;
1486 case SYNC_PREF_REMOTE: 1486 case SYNC_PREF_REMOTE:
1487 if ( lastSync > localMod ) 1487 if ( lastSync > localMod )
1488 return 2; 1488 return 2;
1489 if ( lastSync > remoteMod ) 1489 if ( lastSync > remoteMod )
1490 return 1; 1490 return 1;
1491 return 2; 1491 return 2;
1492 break; 1492 break;
1493 case SYNC_PREF_NEWEST: 1493 case SYNC_PREF_NEWEST:
1494 if ( localMod >= remoteMod ) 1494 if ( localMod >= remoteMod )
1495 return 1; 1495 return 1;
1496 else 1496 else
1497 return 2; 1497 return 2;
1498 break; 1498 break;
1499 case SYNC_PREF_ASK: 1499 case SYNC_PREF_ASK:
1500 qDebug("lsy %s --- lo %s --- re %s ", lastSync.toString().latin1(), localMod.toString().latin1(), remoteMod.toString().latin1() ); 1500 //qDebug("lsy %s --- lo %s --- re %s ", lastSync.toString().latin1(), localMod.toString().latin1(), remoteMod.toString().latin1() );
1501 if ( lastSync > remoteMod && lastSync > localMod) 1501 if ( lastSync > remoteMod && lastSync > localMod)
1502 return 0; 1502 return 0;
1503 if ( lastSync > remoteMod ) 1503 if ( lastSync > remoteMod )
1504 return 1; 1504 return 1;
1505 if ( lastSync > localMod ) 1505 if ( lastSync > localMod )
1506 return 2; 1506 return 2;
1507 qDebug("lsy %s --- lo %s --- re %s ", lastSync.toString().latin1(), localMod.toString().latin1(), remoteMod.toString().latin1() ); 1507 //qDebug("lsy %s --- lo %s --- re %s ", lastSync.toString().latin1(), localMod.toString().latin1(), remoteMod.toString().latin1() );
1508 localIsNew = localMod >= remoteMod; 1508 localIsNew = localMod >= remoteMod;
1509 if ( localIsNew ) 1509 if ( localIsNew )
1510 getEventViewerDialog()->setColorMode( 1 ); 1510 getEventViewerDialog()->setColorMode( 1 );
1511 else 1511 else
1512 getEventViewerDialog()->setColorMode( 2 ); 1512 getEventViewerDialog()->setColorMode( 2 );
1513 getEventViewerDialog()->setIncidence(local); 1513 getEventViewerDialog()->setIncidence(local);
1514 if ( localIsNew ) 1514 if ( localIsNew )
1515 getEventViewerDialog()->setColorMode( 2 ); 1515 getEventViewerDialog()->setColorMode( 2 );
1516 else 1516 else
1517 getEventViewerDialog()->setColorMode( 1 ); 1517 getEventViewerDialog()->setColorMode( 1 );
1518 getEventViewerDialog()->addIncidence(remote); 1518 getEventViewerDialog()->addIncidence(remote);
1519 getEventViewerDialog()->setColorMode( 0 ); 1519 getEventViewerDialog()->setColorMode( 0 );
1520 //qDebug("local %d remote %d ",local->relatedTo(),remote->relatedTo() ); 1520 //qDebug("local %d remote %d ",local->relatedTo(),remote->relatedTo() );
1521 getEventViewerDialog()->setCaption( mCurrentSyncDevice +i18n(" : Conflict! Please choose entry!")); 1521 getEventViewerDialog()->setCaption( mCurrentSyncDevice +i18n(" : Conflict! Please choose entry!"));
1522 getEventViewerDialog()->showMe(); 1522 getEventViewerDialog()->showMe();
1523 result = getEventViewerDialog()->executeS( localIsNew ); 1523 result = getEventViewerDialog()->executeS( localIsNew );
1524 return result; 1524 return result;
1525 1525
1526 break; 1526 break;
1527 case SYNC_PREF_FORCE_LOCAL: 1527 case SYNC_PREF_FORCE_LOCAL:
1528 return 1; 1528 return 1;
1529 break; 1529 break;
1530 case SYNC_PREF_FORCE_REMOTE: 1530 case SYNC_PREF_FORCE_REMOTE:
1531 return 2; 1531 return 2;
1532 break; 1532 break;
1533 1533
1534 default: 1534 default:
1535 // SYNC_PREF_TAKE_BOTH not implemented 1535 // SYNC_PREF_TAKE_BOTH not implemented
1536 break; 1536 break;
1537 } 1537 }
1538 return 0; 1538 return 0;
1539} 1539}
1540Event* CalendarView::getLastSyncEvent() 1540Event* CalendarView::getLastSyncEvent()
1541{ 1541{
1542 Event* lse; 1542 Event* lse;
1543 //qDebug("CurrentSyncDevice %s ",mCurrentSyncDevice .latin1() ); 1543 //qDebug("CurrentSyncDevice %s ",mCurrentSyncDevice .latin1() );
1544 mCalendar->setSyncEventsEnabled();
1544 lse = mCalendar->event( "last-syncEvent-"+mCurrentSyncDevice ); 1545 lse = mCalendar->event( "last-syncEvent-"+mCurrentSyncDevice );
1545 if (!lse) { 1546 if (!lse) {
1547 qDebug("KO: New last Syncevent created for local: %s",mCurrentSyncDevice.latin1() );
1546 lse = new Event(); 1548 lse = new Event();
1547 lse->setUid( "last-syncEvent-"+mCurrentSyncDevice ); 1549 lse->setUid( "last-syncEvent-"+mCurrentSyncDevice );
1548 QString sum = ""; 1550 QString sum = "";
1549 if ( mSyncManager->mExternSyncProfiles.contains( mCurrentSyncDevice ) ) 1551 if ( mSyncManager->mExternSyncProfiles.contains( mCurrentSyncDevice ) )
1550 sum = "E: "; 1552 sum = "E: ";
1551 lse->setSummary(sum+mCurrentSyncDevice + i18n(" - sync event")); 1553 lse->setSummary(sum+mCurrentSyncDevice + i18n(" - sync event"));
1552 lse->setDtStart( mLastCalendarSync ); 1554 lse->setDtStart( mLastCalendarSync );
1553 lse->setDtEnd( mLastCalendarSync.addSecs( 7200 ) ); 1555 lse->setDtEnd( mLastCalendarSync.addSecs( 7200 ) );
1554 lse->setCategories( i18n("SyncEvent") ); 1556 lse->setCategories( i18n("SyncEvent") );
1555 lse->setReadOnly( true ); 1557 lse->setReadOnly( true );
1556 lse->setCalID( 1 ); 1558 lse->setCalID( 1 );
1557 mCalendar->addEvent( lse ); 1559 mCalendar->addEvent( lse );
1558 } 1560 } else
1561 qDebug("KO: Last Syncevent on local found");
1559 1562
1560 return lse; 1563 return lse;
1561 1564
1562} 1565}
1563 1566
1564// we check, if the to delete event has a id for a profile 1567// we check, if the to delete event has a id for a profile
1565// if yes, we set this id in the profile to delete 1568// if yes, we set this id in the profile to delete
1566void CalendarView::checkExternSyncEvent( QPtrList<Event> lastSync , Incidence* toDelete ) 1569void CalendarView::checkExternSyncEvent( QPtrList<Event> lastSync , Incidence* toDelete )
1567{ 1570{
1568 if ( lastSync.count() == 0 ) { 1571 if ( lastSync.count() == 0 ) {
1569 //qDebug(" lastSync.count() == 0"); 1572 //qDebug(" lastSync.count() == 0");
1570 return; 1573 return;
1571 } 1574 }
1572 if ( toDelete->typeID() == journalID ) 1575 if ( toDelete->typeID() == journalID )
1573 return; 1576 return;
1574 1577
1575 Event* eve = lastSync.first(); 1578 Event* eve = lastSync.first();
1576 1579
1577 while ( eve ) { 1580 while ( eve ) {
1578 QString id = toDelete->getID( eve->uid().mid( 15 ) ); // this is the sync profile name 1581 QString id = toDelete->getID( eve->uid().mid( 15 ) ); // this is the sync profile name
1579 if ( !id.isEmpty() ) { 1582 if ( !id.isEmpty() ) {
1580 QString des = eve->description(); 1583 QString des = eve->description();
1581 QString pref = "e"; 1584 QString pref = "e";
1582 if ( toDelete->typeID() == todoID ) 1585 if ( toDelete->typeID() == todoID )
1583 pref = "t"; 1586 pref = "t";
1584 des += pref+ id + ","; 1587 des += pref+ id + ",";
1585 eve->setReadOnly( false ); 1588 eve->setReadOnly( false );
1586 eve->setDescription( des ); 1589 eve->setDescription( des );
1587 //qDebug("setdes %s ", des.latin1()); 1590 //qDebug("setdes %s ", des.latin1());
1588 eve->setReadOnly( true ); 1591 eve->setReadOnly( true );
1589 } 1592 }
1590 eve = lastSync.next(); 1593 eve = lastSync.next();
1591 } 1594 }
1592 1595
1593} 1596}
1594void CalendarView::checkExternalId( Incidence * inc ) 1597void CalendarView::checkExternalId( Incidence * inc )
1595{ 1598{
1596 QPtrList<Event> lastSync = mCalendar->getExternLastSyncEvents() ; 1599 QPtrList<Event> lastSync = mCalendar->getExternLastSyncEvents() ;
1597 checkExternSyncEvent( lastSync, inc ); 1600 checkExternSyncEvent( lastSync, inc );
1598 1601
1599} 1602}
1600bool CalendarView::synchronizeCalendar( Calendar* local, Calendar* remote, int mode ) 1603bool CalendarView::synchronizeCalendar( Calendar* local, Calendar* remote, int mode )
1601{ 1604{
1602 bool syncOK = true; 1605 bool syncOK = true;
1603 int addedEvent = 0; 1606 int addedEvent = 0;
1604 int addedEventR = 0; 1607 int addedEventR = 0;
1605 int deletedEventR = 0; 1608 int deletedEventR = 0;
1606 int deletedEventL = 0; 1609 int deletedEventL = 0;
1607 int changedLocal = 0; 1610 int changedLocal = 0;
1608 int changedRemote = 0; 1611 int changedRemote = 0;
1609 int filteredIN = 0; 1612 int filteredIN = 0;
1610 int filteredOUT = 0; 1613 int filteredOUT = 0;
1611 //QPtrList<Event> el = local->rawEvents(); 1614 //QPtrList<Event> el = local->rawEvents();
1612 Event* eventR; 1615 Event* eventR;
1613 QString uid; 1616 QString uid;
1614 int take; 1617 int take;
1615 Event* eventRSync; 1618 Event* eventRSync;
1616 Event* eventLSync; 1619 Event* eventLSync;
1617 clearAllViews(); 1620 clearAllViews();
1618 QPtrList<Event> eventRSyncSharp = remote->getExternLastSyncEvents(); 1621 QPtrList<Event> eventRSyncSharp = remote->getExternLastSyncEvents();
1619 QPtrList<Event> eventLSyncSharp = local->getExternLastSyncEvents(); 1622 QPtrList<Event> eventLSyncSharp = local->getExternLastSyncEvents();
1620 bool fullDateRange = false; 1623 bool fullDateRange = false;
1621 local->resetTempSyncStat(); 1624 local->resetTempSyncStat();
1622 mLastCalendarSync = QDateTime::currentDateTime(); 1625 mLastCalendarSync = QDateTime::currentDateTime();
1623 if ( mSyncManager->syncWithDesktop() ) { 1626 if ( mSyncManager->syncWithDesktop() ) {
1624 remote->resetPilotStat(1); 1627 remote->resetPilotStat(1);
1625 if ( KSyncManager::mRequestedSyncEvent.isValid() ) { 1628 if ( KSyncManager::mRequestedSyncEvent.isValid() ) {
1626 mLastCalendarSync = KSyncManager::mRequestedSyncEvent; 1629 mLastCalendarSync = KSyncManager::mRequestedSyncEvent;
1627 qDebug("KO: using extern time for calendar sync: %s ", mLastCalendarSync.toString().latin1() ); 1630 qDebug("KO: using extern time for calendar sync: %s ", mLastCalendarSync.toString().latin1() );
1628 } else { 1631 } else {
1629 qDebug("KSyncManager::mRequestedSyncEvent has invalid datatime "); 1632 qDebug("KSyncManager::mRequestedSyncEvent has invalid datatime ");
1630 } 1633 }
1631 } 1634 }
1632 QDateTime modifiedCalendar = mLastCalendarSync; 1635 QDateTime modifiedCalendar = mLastCalendarSync;
1633 eventLSync = getLastSyncEvent(); 1636 eventLSync = getLastSyncEvent();
1634 eventR = remote->event("last-syncEvent-"+mCurrentSyncName ); 1637 eventR = remote->event("last-syncEvent-"+mCurrentSyncName );
1635 if ( eventR ) { 1638 if ( eventR ) {
1636 qDebug("last-syncEvent on remote found "); 1639 qDebug("KO: Last-syncEvent on remote found ");
1637 eventRSync = (Event*) eventR->clone(); 1640 eventRSync = (Event*) eventR->clone();
1638 remote->deleteEvent(eventR ); 1641 remote->deleteEvent(eventR );
1639 1642
1640 } else { 1643 } else {
1641 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL || mSyncManager->syncWithDesktop()) { 1644 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL || mSyncManager->syncWithDesktop()) {
1642 eventRSync = (Event*)eventLSync->clone(); 1645 eventRSync = (Event*)eventLSync->clone();
1643 } else { 1646 } else {
1644 fullDateRange = true; 1647 fullDateRange = true;
1645 eventRSync = new Event(); 1648 eventRSync = new Event();
1646 eventRSync->setSummary(mCurrentSyncName + i18n(" - sync event")); 1649 eventRSync->setSummary(mCurrentSyncName + i18n(" - sync event"));
1647 eventRSync->setUid("last-syncEvent-"+mCurrentSyncName ); 1650 eventRSync->setUid("last-syncEvent-"+mCurrentSyncName );
1648 eventRSync->setDtStart( mLastCalendarSync ); 1651 eventRSync->setDtStart( mLastCalendarSync );
1649 eventRSync->setDtEnd( mLastCalendarSync.addSecs( 7200 ) ); 1652 eventRSync->setDtEnd( mLastCalendarSync.addSecs( 7200 ) );
1650 eventRSync->setCategories( i18n("SyncEvent") ); 1653 eventRSync->setCategories( i18n("SyncEvent") );
1651 } 1654 }
1652 } 1655 }
1653 if ( eventLSync->dtStart() == mLastCalendarSync ) 1656 if ( eventLSync->dtStart() == mLastCalendarSync )
1654 fullDateRange = true; 1657 fullDateRange = true;
1655 1658
1656 if ( ! fullDateRange ) { 1659 if ( ! fullDateRange ) {
1657 if ( eventLSync->dtStart() != eventRSync->dtStart() ) { 1660 if ( eventLSync->dtStart() != eventRSync->dtStart() ) {
1658 1661
1659 qDebug("KO: Sync: Set fulldate to true! Local: %s --- Remote: %s" ,eventLSync->dtStart().toString().latin1(), eventRSync->dtStart().toString().latin1() ); 1662 qDebug("KO: Sync: Set fulldate to true! Local: %s --- Remote: %s" ,eventLSync->dtStart().toString().latin1(), eventRSync->dtStart().toString().latin1() );
1660 //qDebug("%d %d %d %d ", eventLSync->dtStart().time().second(), eventLSync->dtStart().time().msec() , eventRSync->dtStart().time().second(), eventRSync->dtStart().time().msec()); 1663 //qDebug("%d %d %d %d ", eventLSync->dtStart().time().second(), eventLSync->dtStart().time().msec() , eventRSync->dtStart().time().second(), eventRSync->dtStart().time().msec());
1661 fullDateRange = true; 1664 fullDateRange = true;
1662 } 1665 }
1663 } 1666 }
1664 if ( mSyncManager->syncWithDesktop() ) { 1667 if ( mSyncManager->syncWithDesktop() ) {
1665 fullDateRange = ( eventLSync->dtStart() <= mLastCalendarSync && eventLSync->dtStart().addSecs(1) >= mLastCalendarSync ); 1668 fullDateRange = ( eventLSync->dtStart() <= mLastCalendarSync && eventLSync->dtStart().addSecs(1) >= mLastCalendarSync );
1666 } 1669 }
1667 if ( fullDateRange ) 1670 if ( fullDateRange )
1668 mLastCalendarSync = QDateTime::currentDateTime().addDays( -100*365); 1671 mLastCalendarSync = QDateTime::currentDateTime().addDays( -100*365);
1669 else 1672 else
1670 mLastCalendarSync = eventLSync->dtStart(); 1673 mLastCalendarSync = eventLSync->dtStart();
1671 // for resyncing if own file has changed 1674 // for resyncing if own file has changed
1672 if ( mCurrentSyncDevice == "deleteaftersync" ) { 1675 if ( mCurrentSyncDevice == "deleteaftersync" ) {
1673 mLastCalendarSync = loadedFileVersion; 1676 mLastCalendarSync = loadedFileVersion;
1674 //qDebug("setting mLastCalendarSync "); 1677 //qDebug("setting mLastCalendarSync ");
1675 } 1678 }
1676 //qDebug("*************************** "); 1679 //qDebug("*************************** ");
1677 qDebug("KO: mLastCalendarSync %s .Full: %d",mLastCalendarSync.toString().latin1(), fullDateRange); 1680 qDebug("KO: mLastCalendarSync %s .Full: %d",mLastCalendarSync.toString().latin1(), fullDateRange);
1678 QPtrList<Incidence> er = remote->rawIncidences(); 1681 QPtrList<Incidence> er = remote->rawIncidences();
1679 Incidence* inR = er.first(); 1682 Incidence* inR = er.first();
1680 Incidence* inL; 1683 Incidence* inL;
1681 QProgressBar bar( er.count(),0 ); 1684 QProgressBar bar( er.count(),0 );
1682 bar.setCaption (i18n("Syncing - close to abort!") ); 1685 bar.setCaption (i18n("Syncing - close to abort!") );
1683 1686
1684 // ************** setting up filter ************* 1687 // ************** setting up filter *************
1685 CalFilter *filterIN = 0; 1688 CalFilter *filterIN = 0;
1686 CalFilter *filterOUT = 0; 1689 CalFilter *filterOUT = 0;
1687 CalFilter *filter = mFilters.first(); 1690 CalFilter *filter = mFilters.first();
1688 while(filter) { 1691 while(filter) {
1689 if ( filter->name() == mSyncManager->mFilterInCal ) 1692 if ( filter->name() == mSyncManager->mFilterInCal )
1690 filterIN = filter; 1693 filterIN = filter;
1691 if ( filter->name() == mSyncManager->mFilterOutCal ) 1694 if ( filter->name() == mSyncManager->mFilterOutCal )
1692 filterOUT = filter; 1695 filterOUT = filter;
1693 filter = mFilters.next(); 1696 filter = mFilters.next();
1694 } 1697 }
1695 int w = 300; 1698 int w = 300;
1696 if ( QApplication::desktop()->width() < 320 ) 1699 if ( QApplication::desktop()->width() < 320 )
1697 w = 220; 1700 w = 220;
1698 int h = bar.sizeHint().height() ; 1701 int h = bar.sizeHint().height() ;
1699 int dw = QApplication::desktop()->width(); 1702 int dw = QApplication::desktop()->width();
1700 int dh = QApplication::desktop()->height(); 1703 int dh = QApplication::desktop()->height();
1701 bar.setGeometry( (dw-w)/2, (dh - h )/2 ,w,h ); 1704 bar.setGeometry( (dw-w)/2, (dh - h )/2 ,w,h );
1702 bar.show(); 1705 bar.show();
1703 int modulo = (er.count()/10)+1; 1706 int modulo = (er.count()/10)+1;
1704 int incCounter = 0; 1707 int incCounter = 0;
1705 while ( inR ) { 1708 while ( inR ) {
1706 if ( ! bar.isVisible() ) 1709 if ( ! bar.isVisible() )
1707 return false; 1710 return false;
1708 if ( incCounter % modulo == 0 ) 1711 if ( incCounter % modulo == 0 )
1709 bar.setProgress( incCounter ); 1712 bar.setProgress( incCounter );
1710 ++incCounter; 1713 ++incCounter;
1711 uid = inR->uid(); 1714 uid = inR->uid();
1712 bool skipIncidence = false; 1715 bool skipIncidence = false;
1713 if ( uid.left(15) == QString("last-syncEvent-") ) 1716 if ( uid.left(15) == QString("last-syncEvent-") )
1714 skipIncidence = true; 1717 skipIncidence = true;
1715 QString idS; 1718 QString idS;
1716 qApp->processEvents(); 1719 qApp->processEvents();
1717 if ( !skipIncidence ) { 1720 if ( !skipIncidence ) {
1718 inL = local->incidenceForUid( uid , false ); 1721 inL = local->incidenceForUid( uid , false );
1719 if ( inL ) { // maybe conflict - same uid in both calendars 1722 if ( inL ) { // maybe conflict - same uid in both calendars
1720 if ( (take = takeEvent( inL, inR, mode, fullDateRange )) > 0 ) { 1723 if ( (take = takeEvent( inL, inR, mode, fullDateRange )) > 0 ) {
1721 //qDebug("take %d %s ", take, inL->summary().latin1()); 1724 //qDebug("take %d %s ", take, inL->summary().latin1());
1722 if ( take == 3 ) 1725 if ( take == 3 )
1723 return false; 1726 return false;
1724 if ( take == 1 ) {// take local ********************** 1727 if ( take == 1 ) {// take local **********************
1725 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) 1728 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL )
1726 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) ); 1729 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) );
1727 else 1730 else
1728 idS = inR->IDStr(); 1731 idS = inR->IDStr();
1729 int calID = inR->calID(); 1732 int calID = inR->calID();
1730 remote->deleteIncidence( inR ); 1733 remote->deleteIncidence( inR );
1731 inR = inL->clone(); 1734 inR = inL->clone();
1732 inR->setCalID( calID ); 1735 inR->setCalID( calID );
1733 inR->setTempSyncStat( SYNC_TEMPSTATE_INITIAL ); 1736 inR->setTempSyncStat( SYNC_TEMPSTATE_INITIAL );
1734 if ( mGlobalSyncMode != SYNC_MODE_EXTERNAL ) 1737 if ( mGlobalSyncMode != SYNC_MODE_EXTERNAL )
1735 inR->setIDStr( idS ); 1738 inR->setIDStr( idS );
1736 remote->addIncidence( inR ); 1739 remote->addIncidence( inR );
1737 if ( mSyncManager->syncWithDesktop() ) 1740 if ( mSyncManager->syncWithDesktop() )
1738 inR->setPilotId( 2 ); 1741 inR->setPilotId( 2 );
1739 ++changedRemote; 1742 ++changedRemote;
1740 } else {// take remote ********************** 1743 } else {// take remote **********************
1741 if ( !inL->isReadOnly() ) { 1744 if ( !inL->isReadOnly() ) {
1742 idS = inL->IDStr(); 1745 idS = inL->IDStr();
1743 int pid = inL->pilotId(); 1746 int pid = inL->pilotId();
1744 int calID = inL->calID(); 1747 int calID = inL->calID();
1745 local->deleteIncidence( inL ); 1748 local->deleteIncidence( inL );
1746 inL = inR->clone(); 1749 inL = inR->clone();
1747 inL->setCalID( calID ); 1750 inL->setCalID( calID );
1748 if ( mSyncManager->syncWithDesktop() ) 1751 if ( mSyncManager->syncWithDesktop() )
1749 inL->setPilotId( pid ); 1752 inL->setPilotId( pid );
1750 inL->setIDStr( idS ); 1753 inL->setIDStr( idS );
1751 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) { 1754 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) {
1752 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) ); 1755 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) );
1753 inL->setID( mCurrentSyncDevice, inR->getID(mCurrentSyncDevice) ); 1756 inL->setID( mCurrentSyncDevice, inR->getID(mCurrentSyncDevice) );
1754 } 1757 }
1755 local->addIncidence( inL ); 1758 local->addIncidence( inL );
1756 ++changedLocal; 1759 ++changedLocal;
1757 } 1760 }
1758 } 1761 }
1759 } 1762 }
1760 } else { // no conflict ********** add or delete remote 1763 } else { // no conflict ********** add or delete remote
1761 if ( !filterIN || filterIN->filterCalendarItem( inR ) ){ 1764 if ( !filterIN || filterIN->filterCalendarItem( inR ) ){
1762 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) { 1765 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL ) {
1763 QString des = eventLSync->description(); 1766 QString des = eventLSync->description();
1764 QString pref = "e"; 1767 QString pref = "e";
1765 if ( inR->typeID() == todoID ) 1768 if ( inR->typeID() == todoID )
1766 pref = "t"; 1769 pref = "t";
1767 if ( des.find(pref+ inR->getID(mCurrentSyncDevice) +"," ) >= 0 && mode != 5) { // delete it 1770 if ( des.find(pref+ inR->getID(mCurrentSyncDevice) +"," ) >= 0 && mode != 5) { // delete it
1768 inR->setTempSyncStat( SYNC_TEMPSTATE_DELETE ); 1771 inR->setTempSyncStat( SYNC_TEMPSTATE_DELETE );
1769 //remote->deleteIncidence( inR ); 1772 //remote->deleteIncidence( inR );
1770 ++deletedEventR; 1773 ++deletedEventR;
1771 } else { 1774 } else {
1772 inR->setLastModified( modifiedCalendar ); 1775 inR->setLastModified( modifiedCalendar );
1773 inL = inR->clone(); 1776 inL = inR->clone();
1774 inL->setIDStr( ":" ); 1777 inL->setIDStr( ":" );
1775 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) ); 1778 inL->setCsum( mCurrentSyncDevice, inR->getCsum(mCurrentSyncDevice) );
1776 inL->setID( mCurrentSyncDevice, inR->getID(mCurrentSyncDevice) ); 1779 inL->setID( mCurrentSyncDevice, inR->getID(mCurrentSyncDevice) );
1777 1780
1778 inL->setCalID( 0 );// add to default cal 1781 inL->setCalID( 0 );// add to default cal
1779 local->addIncidence( inL ); 1782 local->addIncidence( inL );
1780 ++addedEvent; 1783 ++addedEvent;
1781 1784
1782 } 1785 }
1783 } else { 1786 } else {
1784 if ( inR->lastModified() > mLastCalendarSync || mode == 5 ) { 1787 if ( inR->lastModified() > mLastCalendarSync || mode == 5 ) {
1785 inR->setLastModified( modifiedCalendar ); 1788 inR->setLastModified( modifiedCalendar );
1786 inL = inR->clone(); 1789 inL = inR->clone();
1787 inL->setIDStr( ":" ); 1790 inL->setIDStr( ":" );
1788 inL->setCalID( 0 );// add to default cal 1791 inL->setCalID( 0 );// add to default cal
1789 local->addIncidence( inL ); 1792 local->addIncidence( inL );
1790 ++addedEvent; 1793 ++addedEvent;
1791 1794
1792 } else { 1795 } else {
1793 checkExternSyncEvent(eventRSyncSharp, inR); 1796 checkExternSyncEvent(eventRSyncSharp, inR);
1794 remote->deleteIncidence( inR ); 1797 remote->deleteIncidence( inR );
1795 ++deletedEventR; 1798 ++deletedEventR;
1796 } 1799 }
1797 } 1800 }
1798 } else { 1801 } else {
1799 ++filteredIN; 1802 ++filteredIN;
1800 } 1803 }
1801 } 1804 }
1802 } 1805 }
1803 inR = er.next(); 1806 inR = er.next();
1804 } 1807 }
1805 QPtrList<Incidence> el = local->rawIncidences(); 1808 QPtrList<Incidence> el = local->rawIncidences();
1806 inL = el.first(); 1809 inL = el.first();
1807 modulo = (el.count()/10)+1; 1810 modulo = (el.count()/10)+1;
1808 bar.setCaption (i18n("Add / remove events") ); 1811 bar.setCaption (i18n("Add / remove events") );
1809 bar.setTotalSteps ( el.count() ) ; 1812 bar.setTotalSteps ( el.count() ) ;
1810 bar.show(); 1813 bar.show();
1811 incCounter = 0; 1814 incCounter = 0;
1812 1815
1813 while ( inL ) { 1816 while ( inL ) {
1814 1817
1815 qApp->processEvents(); 1818 qApp->processEvents();
1816 if ( ! bar.isVisible() ) 1819 if ( ! bar.isVisible() )
1817 return false; 1820 return false;
1818 if ( incCounter % modulo == 0 ) 1821 if ( incCounter % modulo == 0 )
1819 bar.setProgress( incCounter ); 1822 bar.setProgress( incCounter );
1820 ++incCounter; 1823 ++incCounter;
1821 uid = inL->uid(); 1824 uid = inL->uid();
1822 bool skipIncidence = false; 1825 bool skipIncidence = false;
1823 if ( uid.left(15) == QString("last-syncEvent-") ) 1826 if ( uid.left(15) == QString("last-syncEvent-") )
1824 skipIncidence = true; 1827 skipIncidence = true;
1825 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL && inL->typeID() == journalID ) 1828 if ( mGlobalSyncMode == SYNC_MODE_EXTERNAL && inL->typeID() == journalID )
1826 skipIncidence = true; 1829 skipIncidence = true;
1827 if ( !skipIncidence ) { 1830 if ( !skipIncidence ) {
1828 inR = remote->incidenceForUid( uid , true ); 1831 inR = remote->incidenceForUid( uid , true );
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp
index e1b15d2..8bf0d27 100644
--- a/libkdepim/ksyncmanager.cpp
+++ b/libkdepim/ksyncmanager.cpp
@@ -971,803 +971,837 @@ void KSyncManager::syncKDE()
971 } 971 }
972 } 972 }
973 if ( syncWithFile( fileName,true ) ) { 973 if ( syncWithFile( fileName,true ) ) {
974 if ( mWriteBackFile ) { 974 if ( mWriteBackFile ) {
975 command += " --read"; 975 command += " --read";
976 system ( command.latin1()); 976 system ( command.latin1());
977 } 977 }
978 } 978 }
979 979
980 } 980 }
981 break; 981 break;
982 case (KOPI): 982 case (KOPI):
983 { 983 {
984#ifdef DESKTOP_VERSION 984#ifdef DESKTOP_VERSION
985 QString command = "kdecaldump33"; 985 QString command = "kdecaldump33";
986 QString commandfile = "kdecaldump33"; 986 QString commandfile = "kdecaldump33";
987 QString commandpath = qApp->applicationDirPath () + "/"; 987 QString commandpath = qApp->applicationDirPath () + "/";
988#else 988#else
989 QString command = "kdecaldump33"; 989 QString command = "kdecaldump33";
990 QString commandfile = "kdecaldump33"; 990 QString commandfile = "kdecaldump33";
991 QString commandpath = QDir::homeDirPath ()+"/"; 991 QString commandpath = QDir::homeDirPath ()+"/";
992#endif 992#endif
993 if ( ! QFile::exists ( commandpath+commandfile ) ) 993 if ( ! QFile::exists ( commandpath+commandfile ) )
994 command = commandfile; 994 command = commandfile;
995 else 995 else
996 command = commandpath+commandfile; 996 command = commandpath+commandfile;
997 997
998 QString fileName = QDir::homeDirPath ()+"/.kdecalendardump.ics"; 998 QString fileName = QDir::homeDirPath ()+"/.kdecalendardump.ics";
999 int result = system ( command.latin1()); 999 int result = system ( command.latin1());
1000 qDebug("Cal dump 33 command call result result: %d ", result); 1000 qDebug("Cal dump 33 command call result result: %d ", result);
1001 if ( result != 0 ) { 1001 if ( result != 0 ) {
1002 qDebug("Calling CAL dump version 33 failed. Trying 34... "); 1002 qDebug("Calling CAL dump version 33 failed. Trying 34... ");
1003 commandfile = "kdecaldump34"; 1003 commandfile = "kdecaldump34";
1004 if ( ! QFile::exists ( commandpath+commandfile ) ) 1004 if ( ! QFile::exists ( commandpath+commandfile ) )
1005 command = commandfile; 1005 command = commandfile;
1006 else 1006 else
1007 command = commandpath+commandfile; 1007 command = commandpath+commandfile;
1008 result = system ( command.latin1()); 1008 result = system ( command.latin1());
1009 qDebug("Cal dump 34 command call result result: %d ", result); 1009 qDebug("Cal dump 34 command call result result: %d ", result);
1010 if ( result != 0 ) { 1010 if ( result != 0 ) {
1011 KMessageBox::error( 0, i18n("Error accessing KDE calendar data.\nMake sure the file\n%1kdecaldump3x\nexists ( x = 3 or 4 ).\nSupported KDE versions are 3.3 and 3.4.\nUsed version should be auto detected.\n").arg( commandpath )); 1011 KMessageBox::error( 0, i18n("Error accessing KDE calendar data.\nMake sure the file\n%1kdecaldump3x\nexists ( x = 3 or 4 ).\nSupported KDE versions are 3.3 and 3.4.\nUsed version should be auto detected.\n").arg( commandpath ));
1012 return; 1012 return;
1013 } 1013 }
1014 } 1014 }
1015 if ( syncWithFile( fileName,true ) ) { 1015 if ( syncWithFile( fileName,true ) ) {
1016 if ( mWriteBackFile ) { 1016 if ( mWriteBackFile ) {
1017 command += " --read"; 1017 command += " --read";
1018 system ( command.latin1()); 1018 system ( command.latin1());
1019 } 1019 }
1020 } 1020 }
1021 1021
1022 } 1022 }
1023 break; 1023 break;
1024 case (PWMPI): 1024 case (PWMPI):
1025 1025
1026 break; 1026 break;
1027 default: 1027 default:
1028 qDebug("KSM::slotSyncMenu: invalid apptype selected"); 1028 qDebug("KSM::slotSyncMenu: invalid apptype selected");
1029 break; 1029 break;
1030 1030
1031 } 1031 }
1032} 1032}
1033 1033
1034void KSyncManager::syncSharp() 1034void KSyncManager::syncSharp()
1035{ 1035{
1036 1036
1037 if ( ! syncExternalApplication("sharp") ) 1037 if ( ! syncExternalApplication("sharp") )
1038 qDebug("KSM::ERROR sync sharp "); 1038 qDebug("KSM::ERROR sync sharp ");
1039} 1039}
1040 1040
1041bool KSyncManager::syncExternalApplication(QString resource) 1041bool KSyncManager::syncExternalApplication(QString resource)
1042{ 1042{
1043 1043
1044 emit save(); 1044 emit save();
1045 1045
1046 if ( mAskForPreferences ) 1046 if ( mAskForPreferences )
1047 if ( !edit_sync_options()) { 1047 if ( !edit_sync_options()) {
1048 mParent->topLevelWidget()->setCaption( i18n("Syncing aborted. Nothing synced.") ); 1048 mParent->topLevelWidget()->setCaption( i18n("Syncing aborted. Nothing synced.") );
1049 return false; 1049 return false;
1050 } 1050 }
1051 1051
1052 qDebug("KSM::Sync extern %s", resource.latin1()); 1052 qDebug("KSM::Sync extern %s", resource.latin1());
1053 1053
1054 bool syncOK = mImplementation->syncExternal(this, resource); 1054 bool syncOK = mImplementation->syncExternal(this, resource);
1055 1055
1056 return syncOK; 1056 return syncOK;
1057 1057
1058} 1058}
1059 1059
1060void KSyncManager::syncPhone() 1060void KSyncManager::syncPhone()
1061{ 1061{
1062 1062
1063 syncExternalApplication("phone"); 1063 syncExternalApplication("phone");
1064 1064
1065} 1065}
1066 1066
1067void KSyncManager::showProgressBar(int percentage, QString caption, int total) 1067void KSyncManager::showProgressBar(int percentage, QString caption, int total)
1068{ 1068{
1069 if (!bar->isVisible()) 1069 if (!bar->isVisible())
1070 { 1070 {
1071 int w = 300; 1071 int w = 300;
1072 if ( QApplication::desktop()->width() < 320 ) 1072 if ( QApplication::desktop()->width() < 320 )
1073 w = 220; 1073 w = 220;
1074 int h = bar->sizeHint().height() ; 1074 int h = bar->sizeHint().height() ;
1075 int dw = QApplication::desktop()->width(); 1075 int dw = QApplication::desktop()->width();
1076 int dh = QApplication::desktop()->height(); 1076 int dh = QApplication::desktop()->height();
1077 bar->setGeometry( (dw-w)/2, (dh - h )/2 ,w,h ); 1077 bar->setGeometry( (dw-w)/2, (dh - h )/2 ,w,h );
1078 bar->setCaption (caption); 1078 bar->setCaption (caption);
1079 bar->setTotalSteps ( total ) ; 1079 bar->setTotalSteps ( total ) ;
1080 bar->show(); 1080 bar->show();
1081 } 1081 }
1082 bar->raise(); 1082 bar->raise();
1083 bar->setProgress( percentage ); 1083 bar->setProgress( percentage );
1084 qApp->processEvents(); 1084 qApp->processEvents();
1085} 1085}
1086 1086
1087void KSyncManager::hideProgressBar() 1087void KSyncManager::hideProgressBar()
1088{ 1088{
1089 bar->hide(); 1089 bar->hide();
1090 qApp->processEvents(); 1090 qApp->processEvents();
1091} 1091}
1092 1092
1093bool KSyncManager::isProgressBarCanceled() 1093bool KSyncManager::isProgressBarCanceled()
1094{ 1094{
1095 return !bar->isVisible(); 1095 return !bar->isVisible();
1096} 1096}
1097 1097
1098QString KSyncManager::syncFileName() 1098QString KSyncManager::syncFileName()
1099{ 1099{
1100 1100
1101 QString fn = "tempfile"; 1101 QString fn = "tempfile";
1102 switch(mTargetApp) 1102 switch(mTargetApp)
1103 { 1103 {
1104 case (KAPI): 1104 case (KAPI):
1105 fn = "tempsyncab.vcf"; 1105 fn = "tempsyncab.vcf";
1106 break; 1106 break;
1107 case (KOPI): 1107 case (KOPI):
1108 fn = "tempsynccal.ics"; 1108 fn = "tempsynccal.ics";
1109 break; 1109 break;
1110 case (PWMPI): 1110 case (PWMPI):
1111 fn = "tempsyncpw.pwm"; 1111 fn = "tempsyncpw.pwm";
1112 break; 1112 break;
1113 default: 1113 default:
1114 break; 1114 break;
1115 } 1115 }
1116#ifdef DESKTOP_VERSION 1116#ifdef DESKTOP_VERSION
1117 return locateLocal( "tmp", fn ); 1117 return locateLocal( "tmp", fn );
1118#else 1118#else
1119 return (QString( "/tmp/" )+ fn ); 1119 return (QString( "/tmp/" )+ fn );
1120#endif 1120#endif
1121} 1121}
1122 1122
1123void KSyncManager::syncPi() 1123void KSyncManager::syncPi()
1124{ 1124{
1125 mIsKapiFile = true; 1125 mIsKapiFile = true;
1126 mPisyncFinished = false; 1126 mPisyncFinished = false;
1127 qApp->processEvents(); 1127 qApp->processEvents();
1128 if ( mAskForPreferences ) 1128 if ( mAskForPreferences )
1129 if ( !edit_pisync_options()) { 1129 if ( !edit_pisync_options()) {
1130 mParent->topLevelWidget()->setCaption( i18n("Syncing aborted. Nothing synced.") ); 1130 mParent->topLevelWidget()->setCaption( i18n("Syncing aborted. Nothing synced.") );
1131 mPisyncFinished = true; 1131 mPisyncFinished = true;
1132 return; 1132 return;
1133 } 1133 }
1134 bool ok; 1134 bool ok;
1135 Q_UINT16 port = mActiveSyncPort.toUInt(&ok); 1135 Q_UINT16 port = mActiveSyncPort.toUInt(&ok);
1136 if ( ! ok ) { 1136 if ( ! ok ) {
1137 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") ); 1137 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") );
1138 mPisyncFinished = true; 1138 mPisyncFinished = true;
1139 return; 1139 return;
1140 } 1140 }
1141 mCurrentResourceLocal = ""; 1141 mCurrentResourceLocal = "";
1142 mCurrentResourceRemote = ""; 1142 mCurrentResourceRemote = "";
1143 if ( mSpecificResources.count() ) { 1143 if ( mSpecificResources.count() ) {
1144 int lastSyncRes = mSpecificResources.count()/2; 1144 int lastSyncRes = mSpecificResources.count()/2;
1145 int ccc = mSpecificResources.count()-1; 1145 int ccc = mSpecificResources.count()-1;
1146 while ( lastSyncRes > 0 && ccc > 0 && mSpecificResources[ ccc ].isEmpty() ) { 1146 while ( lastSyncRes > 0 && ccc > 0 && mSpecificResources[ ccc ].isEmpty() ) {
1147 --ccc; 1147 --ccc;
1148 --lastSyncRes; 1148 --lastSyncRes;
1149 //qDebug ( "KSM: sync pi %d",ccc ); 1149 //qDebug ( "KSM: sync pi %d",ccc );
1150 } 1150 }
1151 int startLocal = 0; 1151 int startLocal = 0;
1152 int startRemote = mSpecificResources.count()/2; 1152 int startRemote = mSpecificResources.count()/2;
1153 emit multiResourceSyncStart( true ); 1153 emit multiResourceSyncStart( true );
1154 while ( startLocal < mSpecificResources.count()/2 ) { 1154 while ( startLocal < mSpecificResources.count()/2 ) {
1155 if ( startLocal+1 >= lastSyncRes ) 1155 if ( startLocal+1 >= lastSyncRes )
1156 emit multiResourceSyncStart( false ); 1156 emit multiResourceSyncStart( false );
1157 mPisyncFinished = false; 1157 mPisyncFinished = false;
1158 mCurrentResourceLocal = mSpecificResources[ startLocal ]; 1158 mCurrentResourceLocal = mSpecificResources[ startLocal ];
1159 mCurrentResourceRemote = mSpecificResources[ startRemote ]; 1159 mCurrentResourceRemote = mSpecificResources[ startRemote ];
1160 //qDebug ( "KSM: AAASyncing resources: Local: %s --- Remote: %s ",mCurrentResourceLocal.latin1(), mCurrentResourceRemote.latin1() ); 1160 //qDebug ( "KSM: AAASyncing resources: Local: %s --- Remote: %s ",mCurrentResourceLocal.latin1(), mCurrentResourceRemote.latin1() );
1161 if ( !mCurrentResourceRemote.isEmpty() ) { 1161 if ( !mCurrentResourceRemote.isEmpty() ) {
1162 qDebug ( "KSM: Syncing resources: Local: %s --- Remote: %s ",mCurrentResourceLocal.latin1(), mCurrentResourceRemote.latin1() ); 1162 qDebug ( "KSM: Syncing resources: Local: %s --- Remote: %s ",mCurrentResourceLocal.latin1(), mCurrentResourceRemote.latin1() );
1163
1163 KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote, mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() ); 1164 KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote, mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() );
1164 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) ); 1165 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) );
1165 commandSocket->readFile( syncFileName() ); 1166 commandSocket->readFile( syncFileName() );
1167 mParent->topLevelWidget()->setCaption( i18n("Syncing %1 <-> %2").arg( mCurrentResourceLocal ).arg( mCurrentResourceRemote ) );
1166 while ( !mPisyncFinished ) { 1168 while ( !mPisyncFinished ) {
1167 //qDebug("waiting "); 1169 //qDebug("waiting ");
1168 qApp->processEvents(); 1170 qApp->processEvents();
1169 } 1171 }
1172 if ( startLocal+1 < mSpecificResources.count()/2 ) {
1173 mParent->topLevelWidget()->setCaption( i18n("Waiting 2 secs before syncing next resource...") );
1174 QTime timer;
1175 timer.start();
1176 while ( timer.elapsed () < 2000 ) {
1177 qApp->processEvents();
1178 }
1179 }
1170 } 1180 }
1171 ++startRemote; 1181 ++startRemote;
1172 ++startLocal; 1182 ++startLocal;
1183
1173 } 1184 }
1174 mPisyncFinished = true; 1185 mPisyncFinished = true;
1175 } else { 1186 } else {
1176 KCommandSocket* commandSocket = new KCommandSocket( "", mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() ); 1187 KCommandSocket* commandSocket = new KCommandSocket( "", mPassWordPiSync, port, mActiveSyncIP, this, mParent->topLevelWidget() );
1177 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) ); 1188 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) );
1178 commandSocket->readFile( syncFileName() ); 1189 commandSocket->readFile( syncFileName() );
1179 } 1190 }
1180} 1191}
1181 1192
1182void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state) 1193void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state)
1183{ 1194{
1184 //enum { success, errorW, errorR, quiet }; 1195 //enum { success, errorW, errorR, quiet };
1185 1196
1186 1197
1187 1198
1188 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ||state == KCommandSocket::errorPW || 1199 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ||state == KCommandSocket::errorPW ||
1189 state == KCommandSocket::errorCA ||state == KCommandSocket::errorFI ||state == KCommandSocket::errorUN||state == KCommandSocket::errorED ) { 1200 state == KCommandSocket::errorCA ||state == KCommandSocket::errorFI ||state == KCommandSocket::errorUN||state == KCommandSocket::errorED ) {
1190 if ( state == KCommandSocket::errorPW ) 1201 if ( state == KCommandSocket::errorPW )
1191 mParent->topLevelWidget()->setCaption( i18n("Wrong password: Receiving remote file failed.") ); 1202 mParent->topLevelWidget()->setCaption( i18n("Wrong password: Receiving remote file failed.") );
1192 else if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ) 1203 else if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO )
1193 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") ); 1204 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") );
1194 else if ( state == KCommandSocket::errorCA ) 1205 else if ( state == KCommandSocket::errorCA )
1195 mParent->topLevelWidget()->setCaption( i18n("Sync cancelled from remote.") ); 1206 mParent->topLevelWidget()->setCaption( i18n("Sync cancelled from remote.") );
1196 else if ( state == KCommandSocket::errorFI ) 1207 else if ( state == KCommandSocket::errorFI )
1197 mParent->topLevelWidget()->setCaption( i18n("File error on remote.") ); 1208 mParent->topLevelWidget()->setCaption( i18n("File error on remote.") );
1198 else if ( state == KCommandSocket::errorED ) 1209 else if ( state == KCommandSocket::errorED )
1199 mParent->topLevelWidget()->setCaption( i18n("Please close error dialog on remote.") ); 1210 mParent->topLevelWidget()->setCaption( i18n("Please close error dialog on remote.") );
1200 else if ( state == KCommandSocket::errorUN ) 1211 else if ( state == KCommandSocket::errorUN )
1201 mParent->topLevelWidget()->setCaption( i18n("Unknown error on remote.") ); 1212 mParent->topLevelWidget()->setCaption( i18n("Unknown error on remote.") );
1202 delete s; 1213 delete s;
1203 if ( state == KCommandSocket::errorR ) { 1214 if ( state == KCommandSocket::errorR ) {
1204 KCommandSocket* commandSocket = new KCommandSocket( "",mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget()); 1215 KCommandSocket* commandSocket = new KCommandSocket( "",mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget());
1205 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); 1216 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
1206 commandSocket->sendStop(); 1217 commandSocket->sendStop();
1207 } 1218 }
1208 mPisyncFinished = true; 1219 mPisyncFinished = true;
1209 return; 1220 return;
1210 1221
1211 } else if ( state == KCommandSocket::errorW ) { 1222 } else if ( state == KCommandSocket::errorW ) {
1212 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") ); 1223 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") );
1213 mPisyncFinished = true; 1224 mPisyncFinished = true;
1214 1225
1215 } else if ( state == KCommandSocket::successR ) { 1226 } else if ( state == KCommandSocket::successR ) {
1216 QTimer::singleShot( 1, this , SLOT ( readFileFromSocket())); 1227 QTimer::singleShot( 1, this , SLOT ( readFileFromSocket()));
1217 1228
1218 } else if ( state == KCommandSocket::successW ) { 1229 } else if ( state == KCommandSocket::successW ) {
1219 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync successful!") ); 1230 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync successful!") );
1220 mPisyncFinished = true; 1231 mPisyncFinished = true;
1221 } else if ( state == KCommandSocket::quiet ){ 1232 } else if ( state == KCommandSocket::quiet ){
1222 qDebug("KSS: quiet "); 1233 qDebug("KSS: quiet ");
1223 mPisyncFinished = true; 1234 mPisyncFinished = true;
1224 } else { 1235 } else {
1225 qDebug("KSS: Error: unknown state: %d ", state); 1236 qDebug("KSS: Error: unknown state: %d ", state);
1226 mPisyncFinished = true; 1237 mPisyncFinished = true;
1227 } 1238 }
1228 1239
1229 delete s; 1240 delete s;
1230} 1241}
1231 1242
1232void KSyncManager::readFileFromSocket() 1243void KSyncManager::readFileFromSocket()
1233{ 1244{
1234 QString fileName = syncFileName(); 1245 QString fileName = syncFileName();
1235 bool syncOK = true; 1246 bool syncOK = true;
1236 mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") ); 1247 mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") );
1237 if ( ! syncWithFile( fileName , true ) ) { 1248 if ( ! syncWithFile( fileName , true ) ) {
1238 mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") ); 1249 mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") );
1239 syncOK = false; 1250 syncOK = false;
1240 } 1251 }
1241 KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote,mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget() ); 1252 KCommandSocket* commandSocket = new KCommandSocket( mCurrentResourceRemote,mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this, mParent->topLevelWidget() );
1242 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); 1253 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
1243 if ( mWriteBackFile && syncOK ) { 1254 if ( mWriteBackFile && syncOK ) {
1244 mParent->topLevelWidget()->setCaption( i18n("Sending back file ...") ); 1255 mParent->topLevelWidget()->setCaption( i18n("Sending back file ...") );
1245 commandSocket->writeFile( fileName ); 1256 commandSocket->writeFile( fileName );
1246 } 1257 }
1247 else { 1258 else {
1248 commandSocket->sendStop(); 1259 commandSocket->sendStop();
1249 if ( syncOK ) 1260 if ( syncOK )
1250 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") ); 1261 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") );
1251 mPisyncFinished = true; 1262 mPisyncFinished = true;
1252 } 1263 }
1253} 1264}
1254 1265
1255KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ) 1266KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name )
1256{ 1267{
1268 mPendingConnect = 0;
1257 mPassWord = pw; 1269 mPassWord = pw;
1258 mSocket = 0; 1270 mSocket = 0;
1259 mSyncActionDialog = 0; 1271 mSyncActionDialog = 0;
1260 blockRC = false; 1272 blockRC = false;
1261 mErrorMessage = 0; 1273 mErrorMessage = 0;
1262} 1274}
1263 1275void KServerSocket::waitForSocketFinish()
1276{
1277 if ( mSocket ) {
1278 qDebug("KSS:: waiting for finish operation");
1279 QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish()));
1280 return;
1281 }
1282 mSocket = new QSocket( this );
1283 connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) );
1284 connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) );
1285 mSocket->setSocket( mPendingConnect );
1286 mPendingConnect = 0;
1287}
1264void KServerSocket::newConnection ( int socket ) 1288void KServerSocket::newConnection ( int socket )
1265{ 1289{
1266 // qDebug("KServerSocket:New connection %d ", socket); 1290 // qDebug("KServerSocket:New connection %d ", socket);
1291 if ( mPendingConnect ) {
1292 qDebug("KSS::Error : new Connection");
1293 return;
1294 }
1267 if ( mSocket ) { 1295 if ( mSocket ) {
1296 mPendingConnect = socket;
1297 QTimer::singleShot( 250, this , SLOT ( waitForSocketFinish()));
1298 return;
1268 qDebug("KSS::newConnection Socket deleted! "); 1299 qDebug("KSS::newConnection Socket deleted! ");
1269 delete mSocket; 1300 delete mSocket;
1270 mSocket = 0; 1301 mSocket = 0;
1271 } 1302 }
1303 mPendingConnect = 0;
1272 mSocket = new QSocket( this ); 1304 mSocket = new QSocket( this );
1273 connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); 1305 connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) );
1274 connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); 1306 connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) );
1275 mSocket->setSocket( socket ); 1307 mSocket->setSocket( socket );
1276} 1308}
1277 1309
1278void KServerSocket::discardClient() 1310void KServerSocket::discardClient()
1279{ 1311{
1280 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1312 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1281} 1313}
1282void KServerSocket::deleteSocket() 1314void KServerSocket::deleteSocket()
1283{ 1315{
1284 qDebug("KSS::deleteSocket"); 1316 qDebug("KSS::deleteSocket");
1285 if ( mSocket ) { 1317 if ( mSocket ) {
1286 delete mSocket; 1318 delete mSocket;
1287 mSocket = 0; 1319 mSocket = 0;
1288 } 1320 }
1289 if ( mErrorMessage ) 1321 if ( mErrorMessage )
1290 QTimer::singleShot( 10, this , SLOT ( displayErrorMessage())); 1322 QTimer::singleShot( 10, this , SLOT ( displayErrorMessage()));
1291} 1323}
1292void KServerSocket::readClient() 1324void KServerSocket::readClient()
1293{ 1325{
1294 if ( blockRC ) 1326 if ( blockRC )
1295 return; 1327 return;
1296 if ( mSocket == 0 ) { 1328 if ( mSocket == 0 ) {
1297 qDebug("ERROR::KSS::readClient(): mSocket == 0 "); 1329 qDebug("ERROR::KSS::readClient(): mSocket == 0 ");
1298 return; 1330 return;
1299 } 1331 }
1300 if ( mErrorMessage ) { 1332 if ( mErrorMessage ) {
1301 mErrorMessage = 999; 1333 mErrorMessage = 999;
1302 error_connect("ERROR_ED\r\n\r\n"); 1334 error_connect("ERROR_ED\r\n\r\n");
1303 return; 1335 return;
1304 } 1336 }
1305 mResource = ""; 1337 mResource = "";
1306 mErrorMessage = 0; 1338 mErrorMessage = 0;
1307 //qDebug("KServerSocket::readClient()"); 1339 //qDebug("KServerSocket::readClient()");
1308 if ( mSocket->canReadLine() ) { 1340 if ( mSocket->canReadLine() ) {
1309 QString line = mSocket->readLine(); 1341 QString line = mSocket->readLine();
1310 //qDebug("KServerSocket readline: %s ", line.latin1()); 1342 //qDebug("KServerSocket readline: %s ", line.latin1());
1311 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line ); 1343 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line );
1312 if ( tokens[0] == "GET" ) { 1344 if ( tokens[0] == "GET" ) {
1313 if ( tokens[1] == mPassWord ) { 1345 if ( tokens[1] == mPassWord ) {
1314 //emit sendFile( mSocket ); 1346 //emit sendFile( mSocket );
1315 bool ok = false; 1347 bool ok = false;
1316 QDateTime dt = KGlobal::locale()->readDateTime( tokens[2], KLocale::ISODate, &ok); 1348 QDateTime dt = KGlobal::locale()->readDateTime( tokens[2], KLocale::ISODate, &ok);
1317 if ( ok ) { 1349 if ( ok ) {
1318 KSyncManager::mRequestedSyncEvent = dt; 1350 KSyncManager::mRequestedSyncEvent = dt;
1319 } 1351 }
1320 else 1352 else
1321 KSyncManager::mRequestedSyncEvent = QDateTime(); 1353 KSyncManager::mRequestedSyncEvent = QDateTime();
1322 mResource =tokens[3]; 1354 mResource =tokens[3];
1323 send_file(); 1355 send_file();
1324 } 1356 }
1325 else { 1357 else {
1326 mErrorMessage = 1; 1358 mErrorMessage = 1;
1327 error_connect("ERROR_PW\r\n\r\n"); 1359 error_connect("ERROR_PW\r\n\r\n");
1328 } 1360 }
1329 } 1361 }
1330 if ( tokens[0] == "PUT" ) { 1362 if ( tokens[0] == "PUT" ) {
1331 if ( tokens[1] == mPassWord ) { 1363 if ( tokens[1] == mPassWord ) {
1332 //emit getFile( mSocket ); 1364 //emit getFile( mSocket );
1333 blockRC = true; 1365 blockRC = true;
1334 mResource =tokens[2]; 1366 mResource =tokens[2];
1335 get_file(); 1367 get_file();
1336 } 1368 }
1337 else { 1369 else {
1338 mErrorMessage = 2; 1370 mErrorMessage = 2;
1339 error_connect("ERROR_PW\r\n\r\n"); 1371 error_connect("ERROR_PW\r\n\r\n");
1340 end_connect(); 1372 end_connect();
1341 } 1373 }
1342 } 1374 }
1343 if ( tokens[0] == "STOP" ) { 1375 if ( tokens[0] == "STOP" ) {
1344 //emit endConnect(); 1376 //emit endConnect();
1345 end_connect(); 1377 end_connect();
1346 } 1378 }
1347 } 1379 }
1348} 1380}
1349void KServerSocket::displayErrorMessage() 1381void KServerSocket::displayErrorMessage()
1350{ 1382{
1351 if ( mErrorMessage == 1 ) { 1383 if ( mErrorMessage == 1 ) {
1352 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password"), i18n("Pi-Sync Error")); 1384 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password"), i18n("Pi-Sync Error"));
1353 mErrorMessage = 0; 1385 mErrorMessage = 0;
1354 } 1386 }
1355 else if ( mErrorMessage == 2 ) { 1387 else if ( mErrorMessage == 2 ) {
1356 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password"), i18n("Pi-Sync Error")); 1388 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password"), i18n("Pi-Sync Error"));
1357 mErrorMessage = 0; 1389 mErrorMessage = 0;
1358 } 1390 }
1359} 1391}
1360void KServerSocket::error_connect( QString errmess ) 1392void KServerSocket::error_connect( QString errmess )
1361{ 1393{
1362 QTextStream os( mSocket ); 1394 QTextStream os( mSocket );
1363 os.setEncoding( QTextStream::Latin1 ); 1395 os.setEncoding( QTextStream::Latin1 );
1364 os << errmess ; 1396 os << errmess ;
1365 mSocket->close(); 1397 mSocket->close();
1366 if ( mSocket->state() == QSocket::Idle ) { 1398 if ( mSocket->state() == QSocket::Idle ) {
1367 QTimer::singleShot( 0, this , SLOT ( discardClient())); 1399 QTimer::singleShot( 0, this , SLOT ( discardClient()));
1368 } 1400 }
1369} 1401}
1370void KServerSocket::end_connect() 1402void KServerSocket::end_connect()
1371{ 1403{
1372 delete mSyncActionDialog; 1404 delete mSyncActionDialog;
1373 mSyncActionDialog = 0; 1405 mSyncActionDialog = 0;
1374} 1406}
1375void KServerSocket::send_file() 1407void KServerSocket::send_file()
1376{ 1408{
1377 //qDebug("MainWindow::sendFile(QSocket* s) "); 1409 //qDebug("MainWindow::sendFile(QSocket* s) ");
1378 if ( mSyncActionDialog ) 1410 if ( mSyncActionDialog )
1379 delete mSyncActionDialog; 1411 delete mSyncActionDialog;
1380 mSyncActionDialog = new QDialog ( 0, "input-dialog", true ); 1412 mSyncActionDialog = new QDialog ( 0, "input-dialog", true );
1381 mSyncActionDialog->setCaption(i18n("Received sync request")); 1413 mSyncActionDialog->setCaption(i18n("Received sync request"));
1382 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog ); 1414 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog );
1383 label->setAlignment ( Qt::AlignHCenter ); 1415 label->setAlignment ( Qt::AlignHCenter );
1384 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog ); 1416 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog );
1385 lay->addWidget( label); 1417 lay->addWidget( label);
1386 lay->setMargin(7); 1418 lay->setMargin(7);
1387 lay->setSpacing(7); 1419 lay->setSpacing(7);
1388 if ( KSyncManager::mRequestedSyncEvent.isValid() ) { 1420 if ( KSyncManager::mRequestedSyncEvent.isValid() ) {
1389 int secs = QDateTime::currentDateTime().secsTo( KSyncManager::mRequestedSyncEvent ); 1421 int secs = QDateTime::currentDateTime().secsTo( KSyncManager::mRequestedSyncEvent );
1390 //secs = 333; 1422 //secs = 333;
1391 if ( secs < 0 ) 1423 if ( secs < 0 )
1392 secs = secs * (-1); 1424 secs = secs * (-1);
1393 if ( secs > 30 ) 1425 if ( secs > 30 )
1394 //if ( true ) 1426 //if ( true )
1395 { 1427 {
1396 QString warning = i18n("Clock skew of\nsyncing devices\nis %1 seconds!").arg( secs ); 1428 QString warning = i18n("Clock skew of\nsyncing devices\nis %1 seconds!").arg( secs );
1397 QLabel* label = new QLabel( warning, mSyncActionDialog ); 1429 QLabel* label = new QLabel( warning, mSyncActionDialog );
1398 label->setAlignment ( Qt::AlignHCenter ); 1430 label->setAlignment ( Qt::AlignHCenter );
1399 lay->addWidget( label); 1431 lay->addWidget( label);
1400 if ( secs > 180 ) 1432 if ( secs > 180 )
1401 { 1433 {
1402 if ( secs > 300 ) { 1434 if ( secs > 300 ) {
1403 if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(0, i18n("The clocks of the syncing\ndevices have a difference\nof more than 5 minutes.\nPlease adjust your clocks.\nYou may get wrong syncing results!\nPlease confirm synchronization!"), i18n("High clock skew!"),i18n("Synchronize!"))) { 1435 if ( KMessageBox::Cancel == KMessageBox::warningContinueCancel(0, i18n("The clocks of the syncing\ndevices have a difference\nof more than 5 minutes.\nPlease adjust your clocks.\nYou may get wrong syncing results!\nPlease confirm synchronization!"), i18n("High clock skew!"),i18n("Synchronize!"))) {
1404 qDebug("KSS::Sync cancelled ,cs"); 1436 qDebug("KSS::Sync cancelled ,cs");
1405 mErrorMessage = 0; 1437 mErrorMessage = 0;
1406 end_connect(); 1438 end_connect();
1407 error_connect("ERROR_CA\r\n\r\n"); 1439 error_connect("ERROR_CA\r\n\r\n");
1408 return ; 1440 return ;
1409 } 1441 }
1410 } 1442 }
1411 QFont f = label->font(); 1443 QFont f = label->font();
1412 f.setPointSize ( f.pointSize() *2 ); 1444 f.setPointSize ( f.pointSize() *2 );
1413 f. setBold (true ); 1445 f. setBold (true );
1414 QLabel* label = new QLabel( warning, mSyncActionDialog ); 1446 QLabel* label = new QLabel( warning, mSyncActionDialog );
1415 label->setFont( f ); 1447 label->setFont( f );
1416 warning = i18n("ADJUST\nYOUR\nCLOCKS!"); 1448 warning = i18n("ADJUST\nYOUR\nCLOCKS!");
1417 label->setText( warning ); 1449 label->setText( warning );
1418 label->setAlignment ( Qt::AlignHCenter ); 1450 label->setAlignment ( Qt::AlignHCenter );
1419 lay->addWidget( label); 1451 lay->addWidget( label);
1420 mSyncActionDialog->setFixedSize( 230, 300); 1452 mSyncActionDialog->setFixedSize( 230, 300);
1421 } else { 1453 } else {
1422 mSyncActionDialog->setFixedSize( 230, 200); 1454 mSyncActionDialog->setFixedSize( 230, 200);
1423 } 1455 }
1424 } else { 1456 } else {
1425 mSyncActionDialog->setFixedSize( 230, 120); 1457 mSyncActionDialog->setFixedSize( 230, 120);
1426 } 1458 }
1427 } else 1459 } else
1428 mSyncActionDialog->setFixedSize( 230, 120); 1460 mSyncActionDialog->setFixedSize( 230, 120);
1429 mSyncActionDialog->show(); 1461 mSyncActionDialog->show();
1430 mSyncActionDialog->raise(); 1462 mSyncActionDialog->raise();
1431 emit request_file(mResource); 1463 emit request_file(mResource);
1432 emit request_file(); 1464 emit request_file();
1433 qApp->processEvents(); 1465 qApp->processEvents();
1434 QString fileName = mFileName; 1466 QString fileName = mFileName;
1435 QFile file( fileName ); 1467 QFile file( fileName );
1436 if (!file.open( IO_ReadOnly ) ) { 1468 if (!file.open( IO_ReadOnly ) ) {
1437 mErrorMessage = 0; 1469 mErrorMessage = 0;
1438 end_connect(); 1470 end_connect();
1439 error_connect("ERROR_FI\r\n\r\n"); 1471 error_connect("ERROR_FI\r\n\r\n");
1440 return ; 1472 return ;
1441 } 1473 }
1442 mSyncActionDialog->setCaption( i18n("Sending file...") ); 1474 mSyncActionDialog->setCaption( i18n("Sending file...") );
1443 QTextStream ts( &file ); 1475 QTextStream ts( &file );
1444 ts.setEncoding( QTextStream::Latin1 ); 1476 ts.setEncoding( QTextStream::Latin1 );
1445 1477
1446 QTextStream os( mSocket ); 1478 QTextStream os( mSocket );
1447 os.setEncoding( QTextStream::Latin1 ); 1479 os.setEncoding( QTextStream::Latin1 );
1448 while ( ! ts.atEnd() ) { 1480 while ( ! ts.atEnd() ) {
1449 os << ts.readLine() << "\r\n"; 1481 os << ts.readLine() << "\r\n";
1450 } 1482 }
1451 os << "\r\n"; 1483 os << "\r\n";
1452 //os << ts.read(); 1484 //os << ts.read();
1453 file.close(); 1485 file.close();
1454 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") ); 1486 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") );
1455 mSocket->close(); 1487 mSocket->close();
1456 if ( mSocket->state() == QSocket::Idle ) 1488 if ( mSocket->state() == QSocket::Idle )
1457 QTimer::singleShot( 10, this , SLOT ( discardClient())); 1489 QTimer::singleShot( 10, this , SLOT ( discardClient()));
1458} 1490}
1459void KServerSocket::get_file() 1491void KServerSocket::get_file()
1460{ 1492{
1461 mSyncActionDialog->setCaption( i18n("Receiving synced file...") ); 1493 mSyncActionDialog->setCaption( i18n("Receiving synced file...") );
1462 1494
1463 piTime.start(); 1495 piTime.start();
1464 piFileString = ""; 1496 piFileString = "";
1465 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) )); 1497 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) ));
1466} 1498}
1467 1499
1468 1500
1469void KServerSocket::readBackFileFromSocket() 1501void KServerSocket::readBackFileFromSocket()
1470{ 1502{
1471 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ()); 1503 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ());
1472 while ( mSocket->canReadLine () ) { 1504 while ( mSocket->canReadLine () ) {
1473 piTime.restart(); 1505 piTime.restart();
1474 QString line = mSocket->readLine (); 1506 QString line = mSocket->readLine ();
1475 piFileString += line; 1507 piFileString += line;
1476 //qDebug("readline: %s ", line.latin1()); 1508 //qDebug("readline: %s ", line.latin1());
1477 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) ); 1509 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) );
1478 1510
1479 } 1511 }
1480 if ( piTime.elapsed () < 3000 ) { 1512 if ( piTime.elapsed () < 3000 ) {
1481 // wait for more 1513 // wait for more
1482 //qDebug("waitformore "); 1514 //qDebug("waitformore ");
1483 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) )); 1515 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) ));
1484 return; 1516 return;
1485 } 1517 }
1486 QString fileName = mFileName; 1518 QString fileName = mFileName;
1487 QFile file ( fileName ); 1519 QFile file ( fileName );
1488 if (!file.open( IO_WriteOnly ) ) { 1520 if (!file.open( IO_WriteOnly ) ) {
1489 delete mSyncActionDialog; 1521 delete mSyncActionDialog;
1490 mSyncActionDialog = 0; 1522 mSyncActionDialog = 0;
1491 qDebug("KSS:Error open read back file "); 1523 qDebug("KSS:Error open read back file ");
1492 piFileString = ""; 1524 piFileString = "";
1493 emit file_received( false, mResource); 1525 emit file_received( false, mResource);
1494 emit file_received( false); 1526 emit file_received( false);
1495 blockRC = false; 1527 blockRC = false;
1496 return ; 1528 return ;
1497 1529
1498 } 1530 }
1499 1531
1500 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 1532 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
1501 QTextStream ts ( &file ); 1533 QTextStream ts ( &file );
1502 ts.setEncoding( QTextStream::Latin1 ); 1534 ts.setEncoding( QTextStream::Latin1 );
1503 mSyncActionDialog->setCaption( i18n("Writing file to disk...") ); 1535 mSyncActionDialog->setCaption( i18n("Writing file to disk...") );
1504 ts << piFileString; 1536 ts << piFileString;
1505 mSocket->close(); 1537 mSocket->close();
1506 if ( mSocket->state() == QSocket::Idle ) 1538 if ( mSocket->state() == QSocket::Idle )
1507 QTimer::singleShot( 10, this , SLOT ( discardClient())); 1539 QTimer::singleShot( 10, this , SLOT ( discardClient()));
1508 file.close(); 1540 file.close();
1509 piFileString = ""; 1541 piFileString = "";
1510 emit file_received( true, mResource ); 1542 emit file_received( true, mResource );
1511 emit file_received( true); 1543 emit file_received( true);
1512 delete mSyncActionDialog; 1544 delete mSyncActionDialog;
1513 mSyncActionDialog = 0; 1545 mSyncActionDialog = 0;
1514 blockRC = false; 1546 blockRC = false;
1515 1547
1516} 1548}
1517 1549
1518KCommandSocket::KCommandSocket ( QString remres, QString password, Q_UINT16 port, QString host, QObject * parent, QWidget * cap, const char * name ): QObject( parent, name ) 1550KCommandSocket::KCommandSocket ( QString remres, QString password, Q_UINT16 port, QString host, QObject * parent, QWidget * cap, const char * name ): QObject( parent, name )
1519{ 1551{
1520 mRemoteResource = remres; 1552 mRemoteResource = remres;
1521 if ( mRemoteResource.isEmpty() ) 1553 if ( mRemoteResource.isEmpty() )
1522 mRemoteResource = "ALL"; 1554 mRemoteResource = "ALL";
1523 else 1555 else
1524 mRemoteResource.replace (QRegExp (" "),"_" ); 1556 mRemoteResource.replace (QRegExp (" "),"_" );
1525 mPassWord = password; 1557 mPassWord = password;
1526 mSocket = 0; 1558 mSocket = 0;
1527 mFirst = false; 1559 mFirst = false;
1528 mFirstLine = true; 1560 mFirstLine = true;
1529 mPort = port; 1561 mPort = port;
1530 mHost = host; 1562 mHost = host;
1531 tlw = cap; 1563 tlw = cap;
1532 mRetVal = quiet; 1564 mRetVal = quiet;
1533 mTimerSocket = new QTimer ( this ); 1565 mTimerSocket = new QTimer ( this );
1534 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( updateConnectDialog() ) ); 1566 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( updateConnectDialog() ) );
1535 mConnectProgress.setCaption( i18n("Pi-Sync") ); 1567 mConnectProgress.setCaption( i18n("Pi-Sync") );
1536 connect( &mConnectProgress, SIGNAL ( cancelled () ), this, SLOT ( deleteSocket() ) ); 1568 connect( &mConnectProgress, SIGNAL ( cancelled () ), this, SLOT ( deleteSocket() ) );
1537 mConnectCount = -1; 1569 mConnectCount = -1;
1538} 1570}
1539void KCommandSocket::sendFileRequest() 1571void KCommandSocket::sendFileRequest()
1540{ 1572{
1541 if ( tlw ) 1573 if ( tlw )
1542 tlw->setCaption( i18n("Connected! Sending request for remote file ...") ); 1574 tlw->setCaption( i18n("Connected! Sending request for remote file ...") );
1543 mConnectProgress.hide(); 1575 mConnectProgress.hide();
1544 mConnectCount = 300;mConnectMax = 300; 1576 mConnectCount = 300;mConnectMax = 300;
1545 mConnectProgress.setCaption( i18n("Pi-Sync: Connected!") ); 1577 mConnectProgress.setCaption( i18n("Pi-Sync: Connected!") );
1578 mConnectProgress.setLabelText( i18n("Waiting for remote file...") );
1546 mTimerSocket->start( 100, true ); 1579 mTimerSocket->start( 100, true );
1547 QTextStream os( mSocket ); 1580 QTextStream os( mSocket );
1548 os.setEncoding( QTextStream::Latin1 ); 1581 os.setEncoding( QTextStream::Latin1 );
1549 1582
1550 QString curDt = " " +KGlobal::locale()->formatDateTime(QDateTime::currentDateTime().addSecs(-1),true, true,KLocale::ISODate ); 1583 QString curDt = " " +KGlobal::locale()->formatDateTime(QDateTime::currentDateTime().addSecs(-1),true, true,KLocale::ISODate );
1551 os << "GET " << mPassWord << curDt << " " << mRemoteResource << "\r\n\r\n"; 1584 os << "GET " << mPassWord << curDt << " " << mRemoteResource << "\r\n\r\n";
1552} 1585}
1553 1586
1554void KCommandSocket::readFile( QString fn ) 1587void KCommandSocket::readFile( QString fn )
1555{ 1588{
1556 if ( !mSocket ) { 1589 if ( !mSocket ) {
1557 mSocket = new QSocket( this ); 1590 mSocket = new QSocket( this );
1591 qDebug("KCS: read file - new socket");
1558 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); 1592 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) );
1559 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1593 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1560 connect( mSocket, SIGNAL(connected ()), this, SLOT(sendFileRequest() )); 1594 connect( mSocket, SIGNAL(connected ()), this, SLOT(sendFileRequest() ));
1561 } 1595 }
1562 mFileString = ""; 1596 mFileString = "";
1563 mFileName = fn; 1597 mFileName = fn;
1564 mFirst = true; 1598 mFirst = true;
1565 if ( tlw ) 1599 if ( tlw )
1566 tlw->setCaption( i18n("Trying to connect to remote...") ); 1600 tlw->setCaption( i18n("Trying to connect to remote...") );
1567 mConnectCount = 30;mConnectMax = 30; 1601 mConnectCount = 30;mConnectMax = 30;
1568 mTimerSocket->start( 1000, true ); 1602 mTimerSocket->start( 1000, true );
1569 mSocket->connectToHost( mHost, mPort ); 1603 mSocket->connectToHost( mHost, mPort );
1570 qDebug("KSS: Waiting for connection"); 1604 qDebug("KCS: Waiting for connection");
1571} 1605}
1572void KCommandSocket::updateConnectDialog() 1606void KCommandSocket::updateConnectDialog()
1573{ 1607{
1574 1608
1575 if ( mConnectCount == mConnectMax ) { 1609 if ( mConnectCount == mConnectMax ) {
1576 //qDebug("MAXX %d", mConnectMax); 1610 qDebug("MAXX %d", mConnectMax);
1577 mConnectProgress.setTotalSteps ( 30 ); 1611 mConnectProgress.setTotalSteps ( 30 );
1578 mConnectProgress.show(); 1612 mConnectProgress.show();
1579 mConnectProgress.setLabelText( i18n("Trying to connect to remote...") ); 1613 mConnectProgress.setLabelText( i18n("Trying to connect to remote...") );
1580 } 1614 }
1581 //qDebug("updateConnectDialog() %d", mConnectCount); 1615 qDebug("updateConnectDialog() %d", mConnectCount);
1582 mConnectProgress.raise(); 1616 mConnectProgress.raise();
1583 mConnectProgress.setProgress( (mConnectMax - mConnectCount)%30 ); 1617 mConnectProgress.setProgress( (mConnectMax - mConnectCount)%30 );
1584 --mConnectCount; 1618 --mConnectCount;
1585 if ( mConnectCount > 0 ) 1619 if ( mConnectCount > 0 )
1586 mTimerSocket->start( 1000, true ); 1620 mTimerSocket->start( 1000, true );
1587 else 1621 else
1588 deleteSocket(); 1622 deleteSocket();
1589 1623
1590} 1624}
1591void KCommandSocket::writeFile( QString fileName ) 1625void KCommandSocket::writeFile( QString fileName )
1592{ 1626{
1593 if ( !mSocket ) { 1627 if ( !mSocket ) {
1594 mSocket = new QSocket( this ); 1628 mSocket = new QSocket( this );
1595 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1629 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1596 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); 1630 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) );
1597 } 1631 }
1598 mFileName = fileName ; 1632 mFileName = fileName ;
1599 mConnectCount = 30;mConnectMax = 30; 1633 mConnectCount = 30;mConnectMax = 30;
1600 mTimerSocket->start( 1000, true ); 1634 mTimerSocket->start( 1000, true );
1601 mSocket->connectToHost( mHost, mPort ); 1635 mSocket->connectToHost( mHost, mPort );
1602} 1636}
1603void KCommandSocket::writeFileToSocket() 1637void KCommandSocket::writeFileToSocket()
1604{ 1638{
1605 mTimerSocket->stop(); 1639 mTimerSocket->stop();
1606 QFile file2( mFileName ); 1640 QFile file2( mFileName );
1607 if (!file2.open( IO_ReadOnly ) ) { 1641 if (!file2.open( IO_ReadOnly ) ) {
1608 mConnectProgress.hide(); 1642 mConnectProgress.hide();
1609 mConnectCount = -1; 1643 mConnectCount = -1;
1610 mRetVal= errorW; 1644 mRetVal= errorW;
1611 mSocket->close(); 1645 mSocket->close();
1612 if ( mSocket->state() == QSocket::Idle ) 1646 if ( mSocket->state() == QSocket::Idle )
1613 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1647 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1614 return ; 1648 return ;
1615 } 1649 }
1616 mConnectProgress.setTotalSteps ( file2.size() ); 1650 mConnectProgress.setTotalSteps ( file2.size() );
1617 mConnectProgress.show(); 1651 mConnectProgress.show();
1618 int count = 0; 1652 int count = 0;
1619 mConnectProgress.setLabelText( i18n("Sending back synced file...") ); 1653 mConnectProgress.setLabelText( i18n("Sending back synced file...") );
1620 mConnectProgress.setProgress( count ); 1654 mConnectProgress.setProgress( count );
1621 mConnectProgress.blockSignals( true ); 1655 mConnectProgress.blockSignals( true );
1622 QTextStream ts2( &file2 ); 1656 QTextStream ts2( &file2 );
1623 ts2.setEncoding( QTextStream::Latin1 ); 1657 ts2.setEncoding( QTextStream::Latin1 );
1624 QTextStream os2( mSocket ); 1658 QTextStream os2( mSocket );
1625 os2.setEncoding( QTextStream::Latin1 ); 1659 os2.setEncoding( QTextStream::Latin1 );
1626 os2 << "PUT " << mPassWord << " " << mRemoteResource << "\r\n\r\n";; 1660 os2 << "PUT " << mPassWord << " " << mRemoteResource << "\r\n\r\n";;
1627 int byteCount = 0; 1661 int byteCount = 0;
1628 int byteMax = file2.size()/53; 1662 int byteMax = file2.size()/53;
1629 while ( ! ts2.atEnd() ) { 1663 while ( ! ts2.atEnd() ) {
1630 qApp->processEvents(); 1664 qApp->processEvents();
1631 if ( byteCount > byteMax ) { 1665 if ( byteCount > byteMax ) {
1632 byteCount = 0; 1666 byteCount = 0;
1633 mConnectProgress.setProgress( count ); 1667 mConnectProgress.setProgress( count );
1634 } 1668 }
1635 QString temp = ts2.readLine(); 1669 QString temp = ts2.readLine();
1636 count += temp.length(); 1670 count += temp.length();
1637 byteCount += temp.length(); 1671 byteCount += temp.length();
1638 os2 << temp << "\r\n"; 1672 os2 << temp << "\r\n";
1639 } 1673 }
1640 file2.close(); 1674 file2.close();
1641 mConnectProgress.hide(); 1675 mConnectProgress.hide();
1642 mConnectCount = -1; 1676 mConnectCount = -1;
1643 os2 << "\r\n"; 1677 os2 << "\r\n";
1644 mRetVal= successW; 1678 mRetVal= successW;
1645 mSocket->close(); 1679 mSocket->close();
1646 if ( mSocket->state() == QSocket::Idle ) 1680 if ( mSocket->state() == QSocket::Idle )
1647 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1681 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1648 mConnectProgress.blockSignals( false ); 1682 mConnectProgress.blockSignals( false );
1649} 1683}
1650void KCommandSocket::sendStop() 1684void KCommandSocket::sendStop()
1651{ 1685{
1652 if ( !mSocket ) { 1686 if ( !mSocket ) {
1653 mSocket = new QSocket( this ); 1687 mSocket = new QSocket( this );
1654 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1688 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1655 } 1689 }
1656 mSocket->connectToHost( mHost, mPort ); 1690 mSocket->connectToHost( mHost, mPort );
1657 QTextStream os2( mSocket ); 1691 QTextStream os2( mSocket );
1658 os2.setEncoding( QTextStream::Latin1 ); 1692 os2.setEncoding( QTextStream::Latin1 );
1659 os2 << "STOP\r\n\r\n"; 1693 os2 << "STOP\r\n\r\n";
1660 mSocket->close(); 1694 mSocket->close();
1661 if ( mSocket->state() == QSocket::Idle ) 1695 if ( mSocket->state() == QSocket::Idle )
1662 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1696 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1663} 1697}
1664 1698
1665void KCommandSocket::startReadFileFromSocket() 1699void KCommandSocket::startReadFileFromSocket()
1666{ 1700{
1667 if ( ! mFirst ) 1701 if ( ! mFirst )
1668 return; 1702 return;
1669 mConnectProgress.setLabelText( i18n("Receiving file from remote...") ); 1703 mConnectProgress.setLabelText( i18n("Receiving file from remote...") );
1670 mFirst = false; 1704 mFirst = false;
1671 mFileString = ""; 1705 mFileString = "";
1672 mTime.start(); 1706 mTime.start();
1673 mFirstLine = true; 1707 mFirstLine = true;
1674 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) )); 1708 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) ));
1675 1709
1676} 1710}
1677void KCommandSocket::readFileFromSocket() 1711void KCommandSocket::readFileFromSocket()
1678{ 1712{
1679 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ()); 1713 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ());
1680 while ( mSocket->canReadLine () ) { 1714 while ( mSocket->canReadLine () ) {
1681 mTime.restart(); 1715 mTime.restart();
1682 QString line = mSocket->readLine (); 1716 QString line = mSocket->readLine ();
1683 if ( mFirstLine ) { 1717 if ( mFirstLine ) {
1684 mFirstLine = false; 1718 mFirstLine = false;
1685 if ( line.left( 6 ) == "ERROR_" ) { 1719 if ( line.left( 6 ) == "ERROR_" ) {
1686 mTimerSocket->stop(); 1720 mTimerSocket->stop();
1687 mConnectCount = -1; 1721 mConnectCount = -1;
1688 if ( line.left( 8 ) == "ERROR_PW" ) { 1722 if ( line.left( 8 ) == "ERROR_PW" ) {
1689 mRetVal = errorPW; 1723 mRetVal = errorPW;
1690 deleteSocket(); 1724 deleteSocket();
1691 return ; 1725 return ;
1692 } 1726 }
1693 if ( line.left( 8 ) == "ERROR_CA" ) { 1727 if ( line.left( 8 ) == "ERROR_CA" ) {
1694 mRetVal = errorCA; 1728 mRetVal = errorCA;
1695 deleteSocket(); 1729 deleteSocket();
1696 return ; 1730 return ;
1697 } 1731 }
1698 if ( line.left( 8 ) == "ERROR_FI" ) { 1732 if ( line.left( 8 ) == "ERROR_FI" ) {
1699 mRetVal = errorFI; 1733 mRetVal = errorFI;
1700 deleteSocket(); 1734 deleteSocket();
1701 return ; 1735 return ;
1702 } 1736 }
1703 if ( line.left( 8 ) == "ERROR_ED" ) { 1737 if ( line.left( 8 ) == "ERROR_ED" ) {
1704 mRetVal = errorED; 1738 mRetVal = errorED;
1705 deleteSocket(); 1739 deleteSocket();
1706 return ; 1740 return ;
1707 } 1741 }
1708 mRetVal = errorUN; 1742 mRetVal = errorUN;
1709 deleteSocket(); 1743 deleteSocket();
1710 return ; 1744 return ;
1711 } 1745 }
1712 } 1746 }
1713 mFileString += line; 1747 mFileString += line;
1714 //qDebug("readline: %s ", line.latin1()); 1748 //qDebug("readline: %s ", line.latin1());
1715 } 1749 }
1716 if ( mTime.elapsed () < 3000 ) { 1750 if ( mTime.elapsed () < 3000 ) {
1717 // wait for more 1751 // wait for more
1718 //qDebug("waitformore "); 1752 //qDebug("waitformore ");
1719 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) )); 1753 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) ));
1720 return; 1754 return;
1721 } 1755 }
1722 mTimerSocket->stop(); 1756 mTimerSocket->stop();
1723 mConnectCount = -1; 1757 mConnectCount = -1;
1724 mConnectProgress.hide(); 1758 mConnectProgress.hide();
1725 QString fileName = mFileName; 1759 QString fileName = mFileName;
1726 QFile file ( fileName ); 1760 QFile file ( fileName );
1727 if (!file.open( IO_WriteOnly ) ) { 1761 if (!file.open( IO_WriteOnly ) ) {
1728 mFileString = ""; 1762 mFileString = "";
1729 mRetVal = errorR; 1763 mRetVal = errorR;
1730 qDebug("KSS:Error open temp sync file for writing: %s",fileName.latin1() ); 1764 qDebug("KSS:Error open temp sync file for writing: %s",fileName.latin1() );
1731 deleteSocket(); 1765 deleteSocket();
1732 return ; 1766 return ;
1733 1767
1734 } 1768 }
1735 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 1769 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
1736 QTextStream ts ( &file ); 1770 QTextStream ts ( &file );
1737 ts.setEncoding( QTextStream::Latin1 ); 1771 ts.setEncoding( QTextStream::Latin1 );
1738 ts << mFileString; 1772 ts << mFileString;
1739 file.close(); 1773 file.close();
1740 mFileString = ""; 1774 mFileString = "";
1741 mRetVal = successR; 1775 mRetVal = successR;
1742 mSocket->close(); 1776 mSocket->close();
1743 // if state is not idle, deleteSocket(); is called via 1777 // if state is not idle, deleteSocket(); is called via
1744 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1778 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1745 if ( mSocket->state() == QSocket::Idle ) 1779 if ( mSocket->state() == QSocket::Idle )
1746 deleteSocket(); 1780 deleteSocket();
1747} 1781}
1748 1782
1749void KCommandSocket::deleteSocket() 1783void KCommandSocket::deleteSocket()
1750{ 1784{
1751 //qDebug("KCommandSocket::deleteSocket() "); 1785 //qDebug("KCommandSocket::deleteSocket() ");
1752 mConnectProgress.hide(); 1786 mConnectProgress.hide();
1753 1787
1754 if ( mConnectCount >= 0 ) { 1788 if ( mConnectCount >= 0 ) {
1755 mTimerSocket->stop(); 1789 mTimerSocket->stop();
1756 mRetVal = errorTO; 1790 mRetVal = errorTO;
1757 qDebug("KCS::Connection to remote host timed out"); 1791 qDebug("KCS::Connection to remote host timed out");
1758 if ( mSocket ) { 1792 if ( mSocket ) {
1759 mSocket->close(); 1793 mSocket->close();
1760 //if ( mSocket->state() == QSocket::Idle ) 1794 //if ( mSocket->state() == QSocket::Idle )
1761 // deleteSocket(); 1795 // deleteSocket();
1762 delete mSocket; 1796 delete mSocket;
1763 mSocket = 0; 1797 mSocket = 0;
1764 } 1798 }
1765 if ( mConnectCount == 0 ) 1799 if ( mConnectCount == 0 )
1766 KMessageBox::error( 0, i18n("Connection to remote\nhost timed out!\nDid you forgot to enable\nsyncing on remote host?")); 1800 KMessageBox::error( 0, i18n("Connection to remote\nhost timed out!\nDid you forgot to enable\nsyncing on remote host?"));
1767 else if ( tlw ) 1801 else if ( tlw )
1768 tlw->setCaption( i18n("Connection to remote host cancelled!") ); 1802 tlw->setCaption( i18n("Connection to remote host cancelled!") );
1769 emit commandFinished( this, mRetVal ); 1803 emit commandFinished( this, mRetVal );
1770 return; 1804 return;
1771 } 1805 }
1772 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal ); 1806 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal );
1773 if ( mSocket) 1807 if ( mSocket)
diff --git a/libkdepim/ksyncmanager.h b/libkdepim/ksyncmanager.h
index 53c611d..604adb8 100644
--- a/libkdepim/ksyncmanager.h
+++ b/libkdepim/ksyncmanager.h
@@ -1,247 +1,249 @@
1/* 1/*
2 This file is part of KDE-Pim/Pi. 2 This file is part of KDE-Pim/Pi.
3 Copyright (c) 2004 Ulf Schenk 3 Copyright (c) 2004 Ulf Schenk
4 4
5 This library is free software; you can redistribute it and/or 5 This library is free software; you can redistribute it and/or
6 modify it under the terms of the GNU Library General Public 6 modify it under the terms of the GNU Library General Public
7 License as published by the Free Software Foundation; either 7 License as published by the Free Software Foundation; either
8 version 2 of the License, or (at your option) any later version. 8 version 2 of the License, or (at your option) any later version.
9 9
10 This library is distributed in the hope that it will be useful, 10 This library is distributed in the hope that it will be useful,
11 but WITHOUT ANY WARRANTY; without even the implied warranty of 11 but WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU 12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Library General Public License for more details. 13 Library General Public License for more details.
14 14
15 You should have received a copy of the GNU Library General Public License 15 You should have received a copy of the GNU Library General Public License
16 along with this library; see the file COPYING.LIB. If not, write to 16 along with this library; see the file COPYING.LIB. If not, write to
17 the Free Software Foundation, Inc., 59 Temple Place - Suite 330, 17 the Free Software Foundation, Inc., 59 Temple Place - Suite 330,
18 Boston, MA 02111-1307, USA. 18 Boston, MA 02111-1307, USA.
19 19
20 $Id$ 20 $Id$
21*/ 21*/
22#ifndef _KSYNCMANAGER_H 22#ifndef _KSYNCMANAGER_H
23#define _KSYNCMANAGER_H 23#define _KSYNCMANAGER_H
24 24
25#include <qobject.h> 25#include <qobject.h>
26#include <qstring.h> 26#include <qstring.h>
27#include <qsocket.h> 27#include <qsocket.h>
28#include <qdatetime.h> 28#include <qdatetime.h>
29#include <qserversocket.h> 29#include <qserversocket.h>
30#include <qtextstream.h> 30#include <qtextstream.h>
31#include <qregexp.h> 31#include <qregexp.h>
32#include <qprogressdialog.h> 32#include <qprogressdialog.h>
33#include <kdialog.h> 33#include <kdialog.h>
34 34
35class QPopupMenu; 35class QPopupMenu;
36class KSyncProfile; 36class KSyncProfile;
37class KPimPrefs; 37class KPimPrefs;
38class QWidget; 38class QWidget;
39class KSyncManager; 39class KSyncManager;
40class KSyncInterface; 40class KSyncInterface;
41class QProgressBar; 41class QProgressBar;
42 42
43 43
44class KServerSocket : public QServerSocket 44class KServerSocket : public QServerSocket
45{ 45{
46 Q_OBJECT 46 Q_OBJECT
47 47
48 public: 48 public:
49 KServerSocket ( QString password, Q_UINT16 port, int backlog = 0, QObject * parent=0, const char * name=0 ); 49 KServerSocket ( QString password, Q_UINT16 port, int backlog = 0, QObject * parent=0, const char * name=0 );
50 50
51 void newConnection ( int socket ) ; 51 void newConnection ( int socket ) ;
52 void setFileName( QString fn ) {mFileName = fn;}; 52 void setFileName( QString fn ) {mFileName = fn;};
53 signals: 53 signals:
54 void file_received( bool ); 54 void file_received( bool );
55 void request_file(); 55 void request_file();
56 void file_received( bool, const QString &); 56 void file_received( bool, const QString &);
57 void request_file(const QString &); 57 void request_file(const QString &);
58 void saveFile(); 58 void saveFile();
59 void endConnect(); 59 void endConnect();
60 private slots: 60 private slots:
61 void waitForSocketFinish();
61 void discardClient(); 62 void discardClient();
62 void deleteSocket(); 63 void deleteSocket();
63 void readClient(); 64 void readClient();
64 void displayErrorMessage(); 65 void displayErrorMessage();
65 void readBackFileFromSocket(); 66 void readBackFileFromSocket();
66 private : 67 private :
68 int mPendingConnect;
67 QString mResource; 69 QString mResource;
68 int mErrorMessage; 70 int mErrorMessage;
69 bool blockRC; 71 bool blockRC;
70 void send_file(); 72 void send_file();
71 void get_file(); 73 void get_file();
72 void end_connect(); 74 void end_connect();
73 void error_connect( QString ); 75 void error_connect( QString );
74 QDialog* mSyncActionDialog; 76 QDialog* mSyncActionDialog;
75 QSocket* mSocket; 77 QSocket* mSocket;
76 QString mPassWord; 78 QString mPassWord;
77 QString mFileName; 79 QString mFileName;
78 QTime piTime; 80 QTime piTime;
79 QString piFileString; 81 QString piFileString;
80}; 82};
81 83
82class KCommandSocket : public QObject 84class KCommandSocket : public QObject
83{ 85{
84 Q_OBJECT 86 Q_OBJECT
85 public: 87 public:
86 enum state { successR, errorR, successW, errorW, errorTO, errorPW, errorCA, errorFI, errorUN, errorED,quiet }; 88 enum state { successR, errorR, successW, errorW, errorTO, errorPW, errorCA, errorFI, errorUN, errorED,quiet };
87 KCommandSocket (QString remoteResource, QString password, Q_UINT16 port, QString host, QObject * parent=0, QWidget* cap = 0, const char * name=0 ); 89 KCommandSocket (QString remoteResource, QString password, Q_UINT16 port, QString host, QObject * parent=0, QWidget* cap = 0, const char * name=0 );
88 void readFile( QString ); 90 void readFile( QString );
89 void writeFile( QString ); 91 void writeFile( QString );
90 void sendStop(); 92 void sendStop();
91 93
92 private slots : 94 private slots :
93 void sendFileRequest(); 95 void sendFileRequest();
94 void updateConnectDialog(); 96 void updateConnectDialog();
95 97
96 signals: 98 signals:
97 void commandFinished( KCommandSocket*, int ); 99 void commandFinished( KCommandSocket*, int );
98 private slots: 100 private slots:
99 void startReadFileFromSocket(); 101 void startReadFileFromSocket();
100 void readFileFromSocket(); 102 void readFileFromSocket();
101 void deleteSocket(); 103 void deleteSocket();
102 void writeFileToSocket(); 104 void writeFileToSocket();
103 private : 105 private :
104 QString mRemoteResource; 106 QString mRemoteResource;
105 int mConnectCount; 107 int mConnectCount;
106 int mConnectMax; 108 int mConnectMax;
107 KProgressDialog mConnectProgress; 109 KProgressDialog mConnectProgress;
108 QWidget* tlw; 110 QWidget* tlw;
109 QSocket* mSocket; 111 QSocket* mSocket;
110 QString mPassWord; 112 QString mPassWord;
111 Q_UINT16 mPort; 113 Q_UINT16 mPort;
112 QString mHost; 114 QString mHost;
113 QString mFileName; 115 QString mFileName;
114 QTimer* mTimerSocket; 116 QTimer* mTimerSocket;
115 int mRetVal; 117 int mRetVal;
116 QTime mTime; 118 QTime mTime;
117 QString mFileString; 119 QString mFileString;
118 bool mFirst; 120 bool mFirst;
119 bool mFirstLine; 121 bool mFirstLine;
120}; 122};
121 123
122 124
123class KSyncManager : public QObject 125class KSyncManager : public QObject
124{ 126{
125 Q_OBJECT 127 Q_OBJECT
126 128
127 public: 129 public:
128 enum TargetApp { 130 enum TargetApp {
129 KOPI = 0, 131 KOPI = 0,
130 KAPI = 1, 132 KAPI = 1,
131 PWMPI = 2 }; 133 PWMPI = 2 };
132 134
133 KSyncManager(QWidget* parent, KSyncInterface* implementation, TargetApp ta, KPimPrefs* prefs, QPopupMenu* syncmenu); 135 KSyncManager(QWidget* parent, KSyncInterface* implementation, TargetApp ta, KPimPrefs* prefs, QPopupMenu* syncmenu);
134 ~KSyncManager() ; 136 ~KSyncManager() ;
135 137
136 void multiSync( bool askforPrefs ); 138 void multiSync( bool askforPrefs );
137 bool blockSave() { return mBlockSaveFlag; } 139 bool blockSave() { return mBlockSaveFlag; }
138 void setBlockSave(bool sa) { mBlockSaveFlag = sa; } 140 void setBlockSave(bool sa) { mBlockSaveFlag = sa; }
139 void setDefaultFileName( QString s) ; 141 void setDefaultFileName( QString s) ;
140 QString defaultFileName() { return mDefFileName ;} 142 QString defaultFileName() { return mDefFileName ;}
141 QString syncFileName(); 143 QString syncFileName();
142 void enableQuick( bool ask = true); 144 void enableQuick( bool ask = true);
143 145
144 bool syncWithDesktop () { return mSyncWithDesktop;} 146 bool syncWithDesktop () { return mSyncWithDesktop;}
145 QString getCurrentSyncDevice() { return mCurrentSyncDevice; } 147 QString getCurrentSyncDevice() { return mCurrentSyncDevice; }
146 QString getCurrentSyncName() { return mCurrentSyncName; } 148 QString getCurrentSyncName() { return mCurrentSyncName; }
147 149
148 void showProgressBar(int percentage, QString caption = QString::null, int total=100); 150 void showProgressBar(int percentage, QString caption = QString::null, int total=100);
149 void hideProgressBar(); 151 void hideProgressBar();
150 bool isProgressBarCanceled(); 152 bool isProgressBarCanceled();
151 153
152 // sync stuff 154 // sync stuff
153 QString mLocalMachineName; 155 QString mLocalMachineName;
154 QStringList mExternSyncProfiles; 156 QStringList mExternSyncProfiles;
155 QStringList mSyncProfileNames; 157 QStringList mSyncProfileNames;
156 bool mAskForPreferences; 158 bool mAskForPreferences;
157 bool mShowSyncSummary; 159 bool mShowSyncSummary;
158 bool mIsKapiFile; 160 bool mIsKapiFile;
159 bool mWriteBackExistingOnly; 161 bool mWriteBackExistingOnly;
160 int mSyncAlgoPrefs; 162 int mSyncAlgoPrefs;
161 bool mWriteBackFile; 163 bool mWriteBackFile;
162 int mWriteBackInFuture; 164 int mWriteBackInFuture;
163 int mWriteBackInPast; 165 int mWriteBackInPast;
164 QString mPhoneDevice; 166 QString mPhoneDevice;
165 QString mPhoneConnection; 167 QString mPhoneConnection;
166 QString mPhoneModel; 168 QString mPhoneModel;
167 QString mPassWordPiSync; 169 QString mPassWordPiSync;
168 QString mActiveSyncPort; 170 QString mActiveSyncPort;
169 QString mActiveSyncIP ; 171 QString mActiveSyncIP ;
170 QString mFilterInCal; 172 QString mFilterInCal;
171 QString mFilterOutCal; 173 QString mFilterOutCal;
172 QString mFilterInAB; 174 QString mFilterInAB;
173 QString mFilterOutAB; 175 QString mFilterOutAB;
174 static QDateTime mRequestedSyncEvent; 176 static QDateTime mRequestedSyncEvent;
175 177
176 signals: 178 signals:
177 void save(); 179 void save();
178 void request_file(); 180 void request_file();
179 void getFile( bool ); 181 void getFile( bool );
180 void getFile( bool, const QString &); 182 void getFile( bool, const QString &);
181 void request_file(const QString &); 183 void request_file(const QString &);
182 void multiResourceSyncStart( bool ); 184 void multiResourceSyncStart( bool );
183 185
184 public slots: 186 public slots:
185 void slotSyncMenu( int ); 187 void slotSyncMenu( int );
186 void slotClearMenu( int action ); 188 void slotClearMenu( int action );
187 void deleteCommandSocket(KCommandSocket*s, int state); 189 void deleteCommandSocket(KCommandSocket*s, int state);
188 void readFileFromSocket(); 190 void readFileFromSocket();
189 void fillSyncMenu(); 191 void fillSyncMenu();
190 192
191 private: 193 private:
192 void syncPi(); 194 void syncPi();
193 KServerSocket * mServerSocket; 195 KServerSocket * mServerSocket;
194 KPimPrefs* mPrefs; 196 KPimPrefs* mPrefs;
195 QString mDefFileName; 197 QString mDefFileName;
196 QString mCurrentSyncDevice; 198 QString mCurrentSyncDevice;
197 QString mCurrentSyncName; 199 QString mCurrentSyncName;
198 void quickSyncLocalFile(); 200 void quickSyncLocalFile();
199 bool syncWithFile( QString fn , bool quick ); 201 bool syncWithFile( QString fn , bool quick );
200 void syncLocalFile(); 202 void syncLocalFile();
201 void syncPhone(); 203 void syncPhone();
202 void syncSharp(); 204 void syncSharp();
203 void syncKDE(); 205 void syncKDE();
204 bool syncExternalApplication(QString); 206 bool syncExternalApplication(QString);
205 int mCurrentSyncProfile ; 207 int mCurrentSyncProfile ;
206 void syncRemote( KSyncProfile* prof, bool ask = true); 208 void syncRemote( KSyncProfile* prof, bool ask = true);
207 bool edit_sync_options(); 209 bool edit_sync_options();
208 bool edit_pisync_options(); 210 bool edit_pisync_options();
209 int ringSync(); 211 int ringSync();
210 QString getPassword( ); 212 QString getPassword( );
211 bool mPisyncFinished; 213 bool mPisyncFinished;
212 QStringList mSpecificResources; 214 QStringList mSpecificResources;
213 QString mCurrentResourceLocal; 215 QString mCurrentResourceLocal;
214 QString mCurrentResourceRemote; 216 QString mCurrentResourceRemote;
215 bool mBlockSaveFlag; 217 bool mBlockSaveFlag;
216 QWidget* mParent; 218 QWidget* mParent;
217 KSyncInterface* mImplementation; 219 KSyncInterface* mImplementation;
218 TargetApp mTargetApp; 220 TargetApp mTargetApp;
219 QPopupMenu* mSyncMenu; 221 QPopupMenu* mSyncMenu;
220 QProgressBar* bar; 222 QProgressBar* bar;
221 bool mSyncWithDesktop; 223 bool mSyncWithDesktop;
222 224
223private slots: 225private slots:
224 void displayErrorPort(); 226 void displayErrorPort();
225 void confSync(); 227 void confSync();
226 228
227 229
228}; 230};
229 231
230 232
231class KSyncInterface 233class KSyncInterface
232{ 234{
233 public : 235 public :
234 virtual void removeSyncInfo( QString syncProfile) = 0; 236 virtual void removeSyncInfo( QString syncProfile) = 0;
235 virtual bool sync(KSyncManager* manager, QString filename, int mode, QString resource) = 0; 237 virtual bool sync(KSyncManager* manager, QString filename, int mode, QString resource) = 0;
236 virtual bool syncExternal(KSyncManager* manager, QString resource) 238 virtual bool syncExternal(KSyncManager* manager, QString resource)
237 { 239 {
238 // empty implementation, because some syncable applications do not 240 // empty implementation, because some syncable applications do not
239 // have an external(sharpdtm) syncmode, like pwmanager. 241 // have an external(sharpdtm) syncmode, like pwmanager.
240 return false; 242 return false;
241 } 243 }
242 244
243 245
244}; 246};
245 247
246 248
247#endif 249#endif