summaryrefslogtreecommitdiffabout
path: root/libkdepim/ksyncmanager.cpp
Unidiff
Diffstat (limited to 'libkdepim/ksyncmanager.cpp') (more/less context) (ignore whitespace changes)
-rw-r--r--libkdepim/ksyncmanager.cpp24
1 files changed, 10 insertions, 14 deletions
diff --git a/libkdepim/ksyncmanager.cpp b/libkdepim/ksyncmanager.cpp
index 80fb147..df53235 100644
--- a/libkdepim/ksyncmanager.cpp
+++ b/libkdepim/ksyncmanager.cpp
@@ -385,830 +385,826 @@ void KSyncManager::multiSync( bool askforPrefs )
385 if ( QMessageBox::information( mParent, i18n("KDE-Pim Sync"), 385 if ( QMessageBox::information( mParent, i18n("KDE-Pim Sync"),
386 question, 386 question,
387 i18n("Yes"), i18n("No"), 387 i18n("Yes"), i18n("No"),
388 0, 0 ) != 0 ) { 388 0, 0 ) != 0 ) {
389 setBlockSave(false); 389 setBlockSave(false);
390 mParent->topLevelWidget()->setCaption(i18n("Aborted! Nothing synced!")); 390 mParent->topLevelWidget()->setCaption(i18n("Aborted! Nothing synced!"));
391 return; 391 return;
392 } 392 }
393 mCurrentSyncDevice = i18n("Multiple profiles") ; 393 mCurrentSyncDevice = i18n("Multiple profiles") ;
394 mSyncAlgoPrefs = mPrefs->mRingSyncAlgoPrefs; 394 mSyncAlgoPrefs = mPrefs->mRingSyncAlgoPrefs;
395 if ( askforPrefs ) { 395 if ( askforPrefs ) {
396 edit_sync_options(); 396 edit_sync_options();
397 mPrefs->mRingSyncAlgoPrefs = mSyncAlgoPrefs; 397 mPrefs->mRingSyncAlgoPrefs = mSyncAlgoPrefs;
398 } 398 }
399 mParent->topLevelWidget()->setCaption(i18n("Multiple sync started.") ); 399 mParent->topLevelWidget()->setCaption(i18n("Multiple sync started.") );
400 qApp->processEvents(); 400 qApp->processEvents();
401 int num = ringSync() ; 401 int num = ringSync() ;
402 if ( num > 1 ) 402 if ( num > 1 )
403 ringSync(); 403 ringSync();
404 setBlockSave(false); 404 setBlockSave(false);
405 if ( num ) 405 if ( num )
406 emit save(); 406 emit save();
407 if ( num ) 407 if ( num )
408 mParent->topLevelWidget()->setCaption(i18n("%1 profiles synced. Multiple sync complete!").arg(num) ); 408 mParent->topLevelWidget()->setCaption(i18n("%1 profiles synced. Multiple sync complete!").arg(num) );
409 else 409 else
410 mParent->topLevelWidget()->setCaption(i18n("Nothing synced! No profiles defined for multisync!")); 410 mParent->topLevelWidget()->setCaption(i18n("Nothing synced! No profiles defined for multisync!"));
411 return; 411 return;
412} 412}
413 413
414int KSyncManager::ringSync() 414int KSyncManager::ringSync()
415{ 415{
416 int syncedProfiles = 0; 416 int syncedProfiles = 0;
417 unsigned int i; 417 unsigned int i;
418 QTime timer; 418 QTime timer;
419 KConfig config ( locateLocal( "config","ksyncprofilesrc" ) ); 419 KConfig config ( locateLocal( "config","ksyncprofilesrc" ) );
420 QStringList syncProfileNames = mSyncProfileNames; 420 QStringList syncProfileNames = mSyncProfileNames;
421 KSyncProfile* temp = new KSyncProfile (); 421 KSyncProfile* temp = new KSyncProfile ();
422 mAskForPreferences = false; 422 mAskForPreferences = false;
423 for ( i = 0; i < syncProfileNames.count(); ++i ) { 423 for ( i = 0; i < syncProfileNames.count(); ++i ) {
424 mCurrentSyncProfile = i; 424 mCurrentSyncProfile = i;
425 temp->setName(syncProfileNames[mCurrentSyncProfile]); 425 temp->setName(syncProfileNames[mCurrentSyncProfile]);
426 temp->readConfig(&config); 426 temp->readConfig(&config);
427 427
428 bool includeInRingSync; 428 bool includeInRingSync;
429 switch(mTargetApp) 429 switch(mTargetApp)
430 { 430 {
431 case (KAPI): 431 case (KAPI):
432 includeInRingSync = temp->getIncludeInRingSyncAB(); 432 includeInRingSync = temp->getIncludeInRingSyncAB();
433 break; 433 break;
434 case (KOPI): 434 case (KOPI):
435 includeInRingSync = temp->getIncludeInRingSync(); 435 includeInRingSync = temp->getIncludeInRingSync();
436 break; 436 break;
437 case (PWMPI): 437 case (PWMPI):
438 includeInRingSync = temp->getIncludeInRingSyncPWM(); 438 includeInRingSync = temp->getIncludeInRingSyncPWM();
439 break; 439 break;
440 default: 440 default:
441 qDebug("KSyncManager::ringSync: invalid apptype selected"); 441 qDebug("KSyncManager::ringSync: invalid apptype selected");
442 break; 442 break;
443 443
444 } 444 }
445 445
446 446
447 if ( includeInRingSync && ( i < 1 || i > 2 )) { 447 if ( includeInRingSync && ( i < 1 || i > 2 )) {
448 mParent->topLevelWidget()->setCaption(i18n("Profile ")+syncProfileNames[mCurrentSyncProfile]+ i18n(" is synced ... ")); 448 mParent->topLevelWidget()->setCaption(i18n("Profile ")+syncProfileNames[mCurrentSyncProfile]+ i18n(" is synced ... "));
449 ++syncedProfiles; 449 ++syncedProfiles;
450 // mAskForPreferences = temp->getAskForPreferences(); 450 // mAskForPreferences = temp->getAskForPreferences();
451 mWriteBackFile = temp->getWriteBackFile(); 451 mWriteBackFile = temp->getWriteBackFile();
452 mWriteBackExistingOnly = temp->getWriteBackExisting(); 452 mWriteBackExistingOnly = temp->getWriteBackExisting();
453 mWriteBackInFuture = 0; 453 mWriteBackInFuture = 0;
454 if ( temp->getWriteBackFuture() ) 454 if ( temp->getWriteBackFuture() )
455 mWriteBackInFuture = temp->getWriteBackFutureWeeks( ); 455 mWriteBackInFuture = temp->getWriteBackFutureWeeks( );
456 mShowSyncSummary = false; 456 mShowSyncSummary = false;
457 mCurrentSyncDevice = syncProfileNames[i] ; 457 mCurrentSyncDevice = syncProfileNames[i] ;
458 mCurrentSyncName = mLocalMachineName; 458 mCurrentSyncName = mLocalMachineName;
459 if ( i == 0 ) { 459 if ( i == 0 ) {
460 syncSharp(); 460 syncSharp();
461 } else { 461 } else {
462 if ( temp->getIsLocalFileSync() ) { 462 if ( temp->getIsLocalFileSync() ) {
463 switch(mTargetApp) 463 switch(mTargetApp)
464 { 464 {
465 case (KAPI): 465 case (KAPI):
466 if ( syncWithFile( temp->getRemoteFileNameAB( ), false ) ) 466 if ( syncWithFile( temp->getRemoteFileNameAB( ), false ) )
467 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileNameAB(); 467 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileNameAB();
468 break; 468 break;
469 case (KOPI): 469 case (KOPI):
470 if ( syncWithFile( temp->getRemoteFileName( ), false ) ) 470 if ( syncWithFile( temp->getRemoteFileName( ), false ) )
471 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileName(); 471 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileName();
472 break; 472 break;
473 case (PWMPI): 473 case (PWMPI):
474 if ( syncWithFile( temp->getRemoteFileNamePWM( ), false ) ) 474 if ( syncWithFile( temp->getRemoteFileNamePWM( ), false ) )
475 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileNamePWM(); 475 mPrefs->mLastSyncedLocalFile = temp->getRemoteFileNamePWM();
476 break; 476 break;
477 default: 477 default:
478 qDebug("KSyncManager::slotSyncMenu: invalid apptype selected"); 478 qDebug("KSyncManager::slotSyncMenu: invalid apptype selected");
479 break; 479 break;
480 } 480 }
481 } else { 481 } else {
482 if ( temp->getIsPhoneSync() ) { 482 if ( temp->getIsPhoneSync() ) {
483 mPhoneDevice = temp->getPhoneDevice( ) ; 483 mPhoneDevice = temp->getPhoneDevice( ) ;
484 mPhoneConnection = temp->getPhoneConnection( ); 484 mPhoneConnection = temp->getPhoneConnection( );
485 mPhoneModel = temp->getPhoneModel( ); 485 mPhoneModel = temp->getPhoneModel( );
486 syncPhone(); 486 syncPhone();
487 } else if ( temp->getIsPiSync() ) { 487 } else if ( temp->getIsPiSync() ) {
488 if ( mTargetApp == KAPI ) { 488 if ( mTargetApp == KAPI ) {
489 mPassWordPiSync = temp->getRemotePwAB(); 489 mPassWordPiSync = temp->getRemotePwAB();
490 mActiveSyncPort = temp->getRemotePortAB(); 490 mActiveSyncPort = temp->getRemotePortAB();
491 mActiveSyncIP = temp->getRemoteIPAB(); 491 mActiveSyncIP = temp->getRemoteIPAB();
492 } else if ( mTargetApp == KOPI ) { 492 } else if ( mTargetApp == KOPI ) {
493 mPassWordPiSync = temp->getRemotePw(); 493 mPassWordPiSync = temp->getRemotePw();
494 mActiveSyncPort = temp->getRemotePort(); 494 mActiveSyncPort = temp->getRemotePort();
495 mActiveSyncIP = temp->getRemoteIP(); 495 mActiveSyncIP = temp->getRemoteIP();
496 } else { 496 } else {
497 mPassWordPiSync = temp->getRemotePwPWM(); 497 mPassWordPiSync = temp->getRemotePwPWM();
498 mActiveSyncPort = temp->getRemotePortPWM(); 498 mActiveSyncPort = temp->getRemotePortPWM();
499 mActiveSyncIP = temp->getRemoteIPPWM(); 499 mActiveSyncIP = temp->getRemoteIPPWM();
500 } 500 }
501 syncPi(); 501 syncPi();
502 } else 502 } else
503 syncRemote( temp, false ); 503 syncRemote( temp, false );
504 504
505 } 505 }
506 } 506 }
507 timer.start(); 507 timer.start();
508 mParent->topLevelWidget()->setCaption(i18n("Multiple sync in progress ... please wait!") ); 508 mParent->topLevelWidget()->setCaption(i18n("Multiple sync in progress ... please wait!") );
509 while ( timer.elapsed () < 2000 ) { 509 while ( timer.elapsed () < 2000 ) {
510 qApp->processEvents(); 510 qApp->processEvents();
511#ifndef _WIN32_ 511#ifndef _WIN32_
512 sleep (1); 512 sleep (1);
513#endif 513#endif
514 } 514 }
515 515
516 } 516 }
517 517
518 } 518 }
519 delete temp; 519 delete temp;
520 return syncedProfiles; 520 return syncedProfiles;
521} 521}
522 522
523void KSyncManager::syncRemote( KSyncProfile* prof, bool ask) 523void KSyncManager::syncRemote( KSyncProfile* prof, bool ask)
524{ 524{
525 QString question; 525 QString question;
526 if ( ask ) { 526 if ( ask ) {
527 question = i18n("Do you really want\nto remote sync\nwith profile \n")+ prof->getName()+" ?\n"; 527 question = i18n("Do you really want\nto remote sync\nwith profile \n")+ prof->getName()+" ?\n";
528 if ( QMessageBox::information( mParent, i18n("Sync"), 528 if ( QMessageBox::information( mParent, i18n("Sync"),
529 question, 529 question,
530 i18n("Yes"), i18n("No"), 530 i18n("Yes"), i18n("No"),
531 0, 0 ) != 0 ) 531 0, 0 ) != 0 )
532 return; 532 return;
533 } 533 }
534 534
535 QString preCommand; 535 QString preCommand;
536 QString localTempFile; 536 QString localTempFile;
537 QString postCommand; 537 QString postCommand;
538 538
539 switch(mTargetApp) 539 switch(mTargetApp)
540 { 540 {
541 case (KAPI): 541 case (KAPI):
542 preCommand = prof->getPreSyncCommandAB(); 542 preCommand = prof->getPreSyncCommandAB();
543 postCommand = prof->getPostSyncCommandAB(); 543 postCommand = prof->getPostSyncCommandAB();
544 localTempFile = prof->getLocalTempFileAB(); 544 localTempFile = prof->getLocalTempFileAB();
545 break; 545 break;
546 case (KOPI): 546 case (KOPI):
547 preCommand = prof->getPreSyncCommand(); 547 preCommand = prof->getPreSyncCommand();
548 postCommand = prof->getPostSyncCommand(); 548 postCommand = prof->getPostSyncCommand();
549 localTempFile = prof->getLocalTempFile(); 549 localTempFile = prof->getLocalTempFile();
550 break; 550 break;
551 case (PWMPI): 551 case (PWMPI):
552 preCommand = prof->getPreSyncCommandPWM(); 552 preCommand = prof->getPreSyncCommandPWM();
553 postCommand = prof->getPostSyncCommandPWM(); 553 postCommand = prof->getPostSyncCommandPWM();
554 localTempFile = prof->getLocalTempFilePWM(); 554 localTempFile = prof->getLocalTempFilePWM();
555 break; 555 break;
556 default: 556 default:
557 qDebug("KSyncManager::syncRemote: invalid apptype selected"); 557 qDebug("KSyncManager::syncRemote: invalid apptype selected");
558 break; 558 break;
559 } 559 }
560 560
561 561
562 int fi; 562 int fi;
563 if ( (fi = preCommand.find("$PWD$")) > 0 ) { 563 if ( (fi = preCommand.find("$PWD$")) > 0 ) {
564 QString pwd = getPassword(); 564 QString pwd = getPassword();
565 preCommand = preCommand.left( fi )+ pwd + preCommand.mid( fi+5 ); 565 preCommand = preCommand.left( fi )+ pwd + preCommand.mid( fi+5 );
566 566
567 } 567 }
568 int maxlen = 30; 568 int maxlen = 30;
569 if ( QApplication::desktop()->width() > 320 ) 569 if ( QApplication::desktop()->width() > 320 )
570 maxlen += 25; 570 maxlen += 25;
571 mParent->topLevelWidget()->setCaption ( i18n( "Copy remote file to local machine..." ) ); 571 mParent->topLevelWidget()->setCaption ( i18n( "Copy remote file to local machine..." ) );
572 int fileSize = 0; 572 int fileSize = 0;
573 int result = system ( preCommand ); 573 int result = system ( preCommand );
574 // 0 : okay 574 // 0 : okay
575 // 256: no such file or dir 575 // 256: no such file or dir
576 // 576 //
577 qDebug("KO: Remote copy result(0 = okay): %d ",result ); 577 qDebug("Sync: Remote copy result(0 = okay): %d ",result );
578 if ( result != 0 ) { 578 if ( result != 0 ) {
579 unsigned int len = maxlen; 579 unsigned int len = maxlen;
580 while ( len < preCommand.length() ) { 580 while ( len < preCommand.length() ) {
581 preCommand.insert( len , "\n" ); 581 preCommand.insert( len , "\n" );
582 len += maxlen +2; 582 len += maxlen +2;
583 } 583 }
584 question = i18n("Sorry, the copy command failed!\nCommand was:\n%1\n \nTry command on console to get more\ndetailed info about the reason.\n").arg (preCommand) ; 584 question = i18n("Sorry, the copy command failed!\nCommand was:\n%1\n \nTry command on console to get more\ndetailed info about the reason.\n").arg (preCommand) ;
585 QMessageBox::information( mParent, i18n("Sync - ERROR"), 585 QMessageBox::information( mParent, i18n("Sync - ERROR"),
586 question, 586 question,
587 i18n("Okay!")) ; 587 i18n("Okay!")) ;
588 mParent->topLevelWidget()->setCaption ("KDE-Pim"); 588 mParent->topLevelWidget()->setCaption ("KDE-Pim");
589 return; 589 return;
590 } 590 }
591 mParent->topLevelWidget()->setCaption ( i18n( "Copying succeed." ) ); 591 mParent->topLevelWidget()->setCaption ( i18n( "Copying succeed." ) );
592 //qDebug(" file **%s** ",prof->getLocalTempFile().latin1() ); 592 //qDebug(" file **%s** ",prof->getLocalTempFile().latin1() );
593 593
594 if ( syncWithFile( localTempFile, true ) ) { 594 if ( syncWithFile( localTempFile, true ) ) {
595 595
596 if ( mWriteBackFile ) { 596 if ( mWriteBackFile ) {
597 int fi; 597 int fi;
598 if ( (fi = postCommand.find("$PWD$")) > 0 ) { 598 if ( (fi = postCommand.find("$PWD$")) > 0 ) {
599 QString pwd = getPassword(); 599 QString pwd = getPassword();
600 postCommand = postCommand.left( fi )+ pwd + postCommand.mid( fi+5 ); 600 postCommand = postCommand.left( fi )+ pwd + postCommand.mid( fi+5 );
601 601
602 } 602 }
603 mParent->topLevelWidget()->setCaption ( i18n( "Writing back file ..." ) ); 603 mParent->topLevelWidget()->setCaption ( i18n( "Writing back file ..." ) );
604 result = system ( postCommand ); 604 result = system ( postCommand );
605 qDebug("Writing back file result: %d ", result); 605 qDebug("Sync:Writing back file result: %d ", result);
606 if ( result != 0 ) { 606 if ( result != 0 ) {
607 mParent->topLevelWidget()->setCaption ( i18n( "Writing back file result: " )+QString::number( result ) ); 607 mParent->topLevelWidget()->setCaption ( i18n( "Writing back file result: " )+QString::number( result ) );
608 return; 608 return;
609 } else { 609 } else {
610 mParent->topLevelWidget()->setCaption ( i18n( "Syncronization sucessfully completed" ) ); 610 mParent->topLevelWidget()->setCaption ( i18n( "Syncronization sucessfully completed" ) );
611 } 611 }
612 } 612 }
613 } 613 }
614 return; 614 return;
615} 615}
616void KSyncManager::edit_pisync_options() 616void KSyncManager::edit_pisync_options()
617{ 617{
618 QDialog dia( mParent, "dia", true ); 618 QDialog dia( mParent, "dia", true );
619 dia.setCaption( i18n("Pi-Sync options for device: " ) +mCurrentSyncDevice ); 619 dia.setCaption( i18n("Pi-Sync options for device: " ) +mCurrentSyncDevice );
620 QVBoxLayout lay ( &dia ); 620 QVBoxLayout lay ( &dia );
621 lay.setSpacing( 5 ); 621 lay.setSpacing( 5 );
622 lay.setMargin( 3 ); 622 lay.setMargin( 3 );
623 QLabel lab1 ( i18n("Password for remote access:"), &dia); 623 QLabel lab1 ( i18n("Password for remote access:"), &dia);
624 lay.addWidget( &lab1 ); 624 lay.addWidget( &lab1 );
625 QLineEdit le1 (&dia ); 625 QLineEdit le1 (&dia );
626 lay.addWidget( &le1 ); 626 lay.addWidget( &le1 );
627 QLabel lab2 ( i18n("Remote IP address:"), &dia); 627 QLabel lab2 ( i18n("Remote IP address:"), &dia);
628 lay.addWidget( &lab2 ); 628 lay.addWidget( &lab2 );
629 QLineEdit le2 (&dia ); 629 QLineEdit le2 (&dia );
630 lay.addWidget( &le2 ); 630 lay.addWidget( &le2 );
631 QLabel lab3 ( i18n("Remote port number:"), &dia); 631 QLabel lab3 ( i18n("Remote port number:"), &dia);
632 lay.addWidget( &lab3 ); 632 lay.addWidget( &lab3 );
633 QLineEdit le3 (&dia ); 633 QLineEdit le3 (&dia );
634 lay.addWidget( &le3 ); 634 lay.addWidget( &le3 );
635 QPushButton pb ( "OK", &dia); 635 QPushButton pb ( "OK", &dia);
636 lay.addWidget( &pb ); 636 lay.addWidget( &pb );
637 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) ); 637 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) );
638 le1.setText( mPassWordPiSync ); 638 le1.setText( mPassWordPiSync );
639 le2.setText( mActiveSyncIP ); 639 le2.setText( mActiveSyncIP );
640 le3.setText( mActiveSyncPort ); 640 le3.setText( mActiveSyncPort );
641 if ( dia.exec() ) { 641 if ( dia.exec() ) {
642 mPassWordPiSync = le1.text(); 642 mPassWordPiSync = le1.text();
643 mActiveSyncPort = le3.text(); 643 mActiveSyncPort = le3.text();
644 mActiveSyncIP = le2.text(); 644 mActiveSyncIP = le2.text();
645 } 645 }
646 646
647} 647}
648void KSyncManager::edit_sync_options() 648void KSyncManager::edit_sync_options()
649{ 649{
650 650
651 QDialog dia( mParent, "dia", true ); 651 QDialog dia( mParent, "dia", true );
652 dia.setCaption( i18n("Device: " ) +mCurrentSyncDevice ); 652 dia.setCaption( i18n("Device: " ) +mCurrentSyncDevice );
653 QButtonGroup gr ( 1, Qt::Horizontal, i18n("Sync preferences"), &dia); 653 QButtonGroup gr ( 1, Qt::Horizontal, i18n("Sync preferences"), &dia);
654 QVBoxLayout lay ( &dia ); 654 QVBoxLayout lay ( &dia );
655 lay.setSpacing( 2 ); 655 lay.setSpacing( 2 );
656 lay.setMargin( 3 ); 656 lay.setMargin( 3 );
657 lay.addWidget(&gr); 657 lay.addWidget(&gr);
658 QRadioButton loc ( i18n("Take local entry on conflict"), &gr ); 658 QRadioButton loc ( i18n("Take local entry on conflict"), &gr );
659 QRadioButton rem ( i18n("Take remote entry on conflict"), &gr ); 659 QRadioButton rem ( i18n("Take remote entry on conflict"), &gr );
660 QRadioButton newest( i18n("Take newest entry on conflict"), &gr ); 660 QRadioButton newest( i18n("Take newest entry on conflict"), &gr );
661 QRadioButton ask( i18n("Ask for every entry on conflict"), &gr ); 661 QRadioButton ask( i18n("Ask for every entry on conflict"), &gr );
662 QRadioButton f_loc( i18n("Force: Take local entry always"), &gr ); 662 QRadioButton f_loc( i18n("Force: Take local entry always"), &gr );
663 QRadioButton f_rem( i18n("Force: Take remote entry always"), &gr ); 663 QRadioButton f_rem( i18n("Force: Take remote entry always"), &gr );
664 //QRadioButton both( i18n("Take both on conflict"), &gr ); 664 //QRadioButton both( i18n("Take both on conflict"), &gr );
665 QPushButton pb ( "OK", &dia); 665 QPushButton pb ( "OK", &dia);
666 lay.addWidget( &pb ); 666 lay.addWidget( &pb );
667 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) ); 667 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) );
668 switch ( mSyncAlgoPrefs ) { 668 switch ( mSyncAlgoPrefs ) {
669 case 0: 669 case 0:
670 loc.setChecked( true); 670 loc.setChecked( true);
671 break; 671 break;
672 case 1: 672 case 1:
673 rem.setChecked( true ); 673 rem.setChecked( true );
674 break; 674 break;
675 case 2: 675 case 2:
676 newest.setChecked( true); 676 newest.setChecked( true);
677 break; 677 break;
678 case 3: 678 case 3:
679 ask.setChecked( true); 679 ask.setChecked( true);
680 break; 680 break;
681 case 4: 681 case 4:
682 f_loc.setChecked( true); 682 f_loc.setChecked( true);
683 break; 683 break;
684 case 5: 684 case 5:
685 f_rem.setChecked( true); 685 f_rem.setChecked( true);
686 break; 686 break;
687 case 6: 687 case 6:
688 // both.setChecked( true); 688 // both.setChecked( true);
689 break; 689 break;
690 default: 690 default:
691 break; 691 break;
692 } 692 }
693 if ( dia.exec() ) { 693 if ( dia.exec() ) {
694 mSyncAlgoPrefs = rem.isChecked()*1+newest.isChecked()*2+ ask.isChecked()*3+ f_loc.isChecked()*4+ f_rem.isChecked()*5;//+ both.isChecked()*6 ; 694 mSyncAlgoPrefs = rem.isChecked()*1+newest.isChecked()*2+ ask.isChecked()*3+ f_loc.isChecked()*4+ f_rem.isChecked()*5;//+ both.isChecked()*6 ;
695 } 695 }
696 696
697 697
698} 698}
699 699
700QString KSyncManager::getPassword( ) 700QString KSyncManager::getPassword( )
701{ 701{
702 QString retfile = ""; 702 QString retfile = "";
703 QDialog dia ( mParent, "input-dialog", true ); 703 QDialog dia ( mParent, "input-dialog", true );
704 QLineEdit lab ( &dia ); 704 QLineEdit lab ( &dia );
705 lab.setEchoMode( QLineEdit::Password ); 705 lab.setEchoMode( QLineEdit::Password );
706 QVBoxLayout lay( &dia ); 706 QVBoxLayout lay( &dia );
707 lay.setMargin(7); 707 lay.setMargin(7);
708 lay.setSpacing(7); 708 lay.setSpacing(7);
709 lay.addWidget( &lab); 709 lay.addWidget( &lab);
710 dia.setFixedSize( 230,50 ); 710 dia.setFixedSize( 230,50 );
711 dia.setCaption( i18n("Enter password") ); 711 dia.setCaption( i18n("Enter password") );
712 QPushButton pb ( "OK", &dia); 712 QPushButton pb ( "OK", &dia);
713 lay.addWidget( &pb ); 713 lay.addWidget( &pb );
714 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) ); 714 connect(&pb, SIGNAL( clicked() ), &dia, SLOT ( accept() ) );
715 dia.show(); 715 dia.show();
716 int res = dia.exec(); 716 int res = dia.exec();
717 if ( res ) 717 if ( res )
718 retfile = lab.text(); 718 retfile = lab.text();
719 dia.hide(); 719 dia.hide();
720 qApp->processEvents(); 720 qApp->processEvents();
721 return retfile; 721 return retfile;
722 722
723} 723}
724 724
725 725
726void KSyncManager::confSync() 726void KSyncManager::confSync()
727{ 727{
728 static KSyncPrefsDialog* sp = 0; 728 static KSyncPrefsDialog* sp = 0;
729 if ( ! sp ) { 729 if ( ! sp ) {
730 sp = new KSyncPrefsDialog( mParent, "syncprefs", true ); 730 sp = new KSyncPrefsDialog( mParent, "syncprefs", true );
731 } 731 }
732 sp->usrReadConfig(); 732 sp->usrReadConfig();
733#ifndef DESKTOP_VERSION 733#ifndef DESKTOP_VERSION
734 sp->showMaximized(); 734 sp->showMaximized();
735#else 735#else
736 sp->show(); 736 sp->show();
737#endif 737#endif
738 sp->exec(); 738 sp->exec();
739 mSyncProfileNames = sp->getSyncProfileNames(); 739 mSyncProfileNames = sp->getSyncProfileNames();
740 mLocalMachineName = sp->getLocalMachineName (); 740 mLocalMachineName = sp->getLocalMachineName ();
741 QTimer::singleShot ( 1, this, SLOT ( fillSyncMenu() ) ); 741 QTimer::singleShot ( 1, this, SLOT ( fillSyncMenu() ) );
742} 742}
743 743
744void KSyncManager::syncSharp() 744void KSyncManager::syncSharp()
745{ 745{
746 746
747 if ( ! syncExternalApplication("sharp") ) 747 if ( ! syncExternalApplication("sharp") )
748 qDebug("ERROR sync sharp ");; 748 qDebug("ERROR sync sharp ");
749} 749}
750 750
751bool KSyncManager::syncExternalApplication(QString resource) 751bool KSyncManager::syncExternalApplication(QString resource)
752{ 752{
753 753
754 emit save(); 754 emit save();
755 755
756 if ( mAskForPreferences ) 756 if ( mAskForPreferences )
757 edit_sync_options(); 757 edit_sync_options();
758 758
759 qDebug("sync %s", resource.latin1()); 759 qDebug("Sync extern %s", resource.latin1());
760 760
761 bool syncOK = mImplementation->syncExternal(this, resource); 761 bool syncOK = mImplementation->syncExternal(this, resource);
762 762
763 return syncOK; 763 return syncOK;
764 764
765} 765}
766 766
767void KSyncManager::syncPhone() 767void KSyncManager::syncPhone()
768{ 768{
769 769
770 syncExternalApplication("phone"); 770 syncExternalApplication("phone");
771 771
772} 772}
773 773
774void KSyncManager::showProgressBar(int percentage, QString caption, int total) 774void KSyncManager::showProgressBar(int percentage, QString caption, int total)
775{ 775{
776 if (!bar->isVisible()) 776 if (!bar->isVisible())
777 { 777 {
778 bar->setCaption (caption); 778 bar->setCaption (caption);
779 bar->setTotalSteps ( total ) ; 779 bar->setTotalSteps ( total ) ;
780 780
781 bar->show(); 781 bar->show();
782 } 782 }
783 783
784 bar->setProgress( percentage ); 784 bar->setProgress( percentage );
785} 785}
786 786
787void KSyncManager::hideProgressBar() 787void KSyncManager::hideProgressBar()
788{ 788{
789 bar->hide(); 789 bar->hide();
790} 790}
791 791
792bool KSyncManager::isProgressBarCanceled() 792bool KSyncManager::isProgressBarCanceled()
793{ 793{
794 return !bar->isVisible(); 794 return !bar->isVisible();
795} 795}
796 796
797QString KSyncManager::syncFileName() 797QString KSyncManager::syncFileName()
798{ 798{
799 799
800 QString fn = "tempfile"; 800 QString fn = "tempfile";
801 switch(mTargetApp) 801 switch(mTargetApp)
802 { 802 {
803 case (KAPI): 803 case (KAPI):
804 fn = "tempsyncab.vcf"; 804 fn = "tempsyncab.vcf";
805 break; 805 break;
806 case (KOPI): 806 case (KOPI):
807 fn = "tempsynccal.ics"; 807 fn = "tempsynccal.ics";
808 break; 808 break;
809 case (PWMPI): 809 case (PWMPI):
810 fn = "tempsyncpw.pwm"; 810 fn = "tempsyncpw.pwm";
811 break; 811 break;
812 default: 812 default:
813 break; 813 break;
814 } 814 }
815#ifdef _WIN32_ 815#ifdef _WIN32_
816 return locateLocal( "tmp", fn ); 816 return locateLocal( "tmp", fn );
817#else 817#else
818 return (QString( "/tmp/" )+ fn ); 818 return (QString( "/tmp/" )+ fn );
819#endif 819#endif
820} 820}
821 821
822void KSyncManager::syncPi() 822void KSyncManager::syncPi()
823{ 823{
824 qApp->processEvents(); 824 qApp->processEvents();
825 if ( mAskForPreferences ) 825 if ( mAskForPreferences )
826 edit_pisync_options(); 826 edit_pisync_options();
827 bool ok; 827 bool ok;
828 Q_UINT16 port = mActiveSyncPort.toUInt(&ok); 828 Q_UINT16 port = mActiveSyncPort.toUInt(&ok);
829 if ( ! ok ) { 829 if ( ! ok ) {
830 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") ); 830 mParent->topLevelWidget()->setCaption( i18n("Sorry, no valid port.Syncing cancelled.") );
831 return; 831 return;
832 } 832 }
833 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, mActiveSyncIP, this ); 833 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, port, mActiveSyncIP, this );
834 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) ); 834 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int )), this, SLOT(deleteCommandSocket(KCommandSocket*, int)) );
835 mParent->topLevelWidget()->setCaption( i18n("Sending request for remote file ...") ); 835 mParent->topLevelWidget()->setCaption( i18n("Sending request for remote file ...") );
836 commandSocket->readFile( syncFileName() ); 836 commandSocket->readFile( syncFileName() );
837} 837}
838 838
839void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state) 839void KSyncManager::deleteCommandSocket(KCommandSocket*s, int state)
840{ 840{
841 qDebug("MainWindow::deleteCommandSocket %d", state);
842
843 //enum { success, errorW, errorR, quiet }; 841 //enum { success, errorW, errorR, quiet };
844 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ) { 842 if ( state == KCommandSocket::errorR ||state == KCommandSocket::errorTO ) {
845 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") ); 843 mParent->topLevelWidget()->setCaption( i18n("ERROR: Receiving remote file failed.") );
846 delete s; 844 delete s;
847 if ( state == KCommandSocket::errorR ) { 845 if ( state == KCommandSocket::errorR ) {
848 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this ); 846 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this );
849 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); 847 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
850 commandSocket->sendStop(); 848 commandSocket->sendStop();
851 } 849 }
852 return; 850 return;
853 851
854 } else if ( state == KCommandSocket::errorW ) { 852 } else if ( state == KCommandSocket::errorW ) {
855 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") ); 853 mParent->topLevelWidget()->setCaption( i18n("ERROR:Writing back file failed.") );
856 854
857 } else if ( state == KCommandSocket::successR ) { 855 } else if ( state == KCommandSocket::successR ) {
858 QTimer::singleShot( 1, this , SLOT ( readFileFromSocket())); 856 QTimer::singleShot( 1, this , SLOT ( readFileFromSocket()));
859 857
860 } else if ( state == KCommandSocket::successW ) { 858 } else if ( state == KCommandSocket::successW ) {
861 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") ); 859 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") );
862 } 860 }
863 861
864 delete s; 862 delete s;
865} 863}
866 864
867void KSyncManager::readFileFromSocket() 865void KSyncManager::readFileFromSocket()
868{ 866{
869 QString fileName = syncFileName(); 867 QString fileName = syncFileName();
870 mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") ); 868 mParent->topLevelWidget()->setCaption( i18n("Remote file saved to temp file.") );
871 if ( ! syncWithFile( fileName , true ) ) { 869 if ( ! syncWithFile( fileName , true ) ) {
872 mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") ); 870 mParent->topLevelWidget()->setCaption( i18n("Syncing failed.") );
873 qDebug("Syncing failed ");
874 return; 871 return;
875 } 872 }
876 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this ); 873 KCommandSocket* commandSocket = new KCommandSocket( mPassWordPiSync, mActiveSyncPort.toUInt(), mActiveSyncIP, this );
877 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) ); 874 connect( commandSocket, SIGNAL(commandFinished( KCommandSocket*, int)), this, SLOT(deleteCommandSocket(KCommandSocket*, int )) );
878 if ( mWriteBackFile ) 875 if ( mWriteBackFile )
879 commandSocket->writeFile( fileName ); 876 commandSocket->writeFile( fileName );
880 else { 877 else {
881 commandSocket->sendStop(); 878 commandSocket->sendStop();
882 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") ); 879 mParent->topLevelWidget()->setCaption( i18n("Pi-Sync succesful!") );
883 } 880 }
884} 881}
885 882
886KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name ) 883KServerSocket:: KServerSocket ( QString pw, Q_UINT16 port, int backlog, QObject * parent, const char * name ) : QServerSocket( port, backlog, parent, name )
887{ 884{
888 mPassWord = pw; 885 mPassWord = pw;
889 mSocket = 0; 886 mSocket = 0;
890 mSyncActionDialog = 0; 887 mSyncActionDialog = 0;
891 blockRC = false; 888 blockRC = false;
892}; 889};
893 890
894void KServerSocket::newConnection ( int socket ) 891void KServerSocket::newConnection ( int socket )
895{ 892{
896 // qDebug("KServerSocket:New connection %d ", socket); 893 // qDebug("KServerSocket:New connection %d ", socket);
897 if ( mSocket ) { 894 if ( mSocket ) {
898 qDebug("KServerSocket::newConnection Socket deleted! "); 895 qDebug("KServerSocket::newConnection Socket deleted! ");
899 delete mSocket; 896 delete mSocket;
900 mSocket = 0; 897 mSocket = 0;
901 } 898 }
902 mSocket = new QSocket( this ); 899 mSocket = new QSocket( this );
903 connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) ); 900 connect( mSocket , SIGNAL(readyRead()), this, SLOT(readClient()) );
904 connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) ); 901 connect( mSocket , SIGNAL(delayedCloseFinished()), this, SLOT(discardClient()) );
905 mSocket->setSocket( socket ); 902 mSocket->setSocket( socket );
906} 903}
907 904
908void KServerSocket::discardClient() 905void KServerSocket::discardClient()
909{ 906{
910 //qDebug(" KServerSocket::discardClient()"); 907 //qDebug(" KServerSocket::discardClient()");
911 if ( mSocket ) { 908 if ( mSocket ) {
912 delete mSocket; 909 delete mSocket;
913 mSocket = 0; 910 mSocket = 0;
914 } 911 }
915 //emit endConnect(); 912 //emit endConnect();
916} 913}
917void KServerSocket::readClient() 914void KServerSocket::readClient()
918{ 915{
919 if ( blockRC ) 916 if ( blockRC )
920 return; 917 return;
921 if ( mSocket == 0 ) { 918 if ( mSocket == 0 ) {
922 qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 "); 919 qDebug("ERROR::KServerSocket::readClient(): mSocket == 0 ");
923 return; 920 return;
924 } 921 }
925 qDebug("KServerSocket readClient()"); 922 //qDebug("KServerSocket::readClient()");
926 if ( mSocket->canReadLine() ) { 923 if ( mSocket->canReadLine() ) {
927 QString line = mSocket->readLine(); 924 QString line = mSocket->readLine();
928 qDebug("KServerSocket readline: %s ", line.latin1()); 925 //qDebug("KServerSocket readline: %s ", line.latin1());
929 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line ); 926 QStringList tokens = QStringList::split( QRegExp("[ \r\n][ \r\n]*"), line );
930 if ( tokens[0] == "GET" ) { 927 if ( tokens[0] == "GET" ) {
931 if ( tokens[1] == mPassWord ) 928 if ( tokens[1] == mPassWord )
932 //emit sendFile( mSocket ); 929 //emit sendFile( mSocket );
933 send_file(); 930 send_file();
934 else { 931 else {
935 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password")); 932 KMessageBox::error( 0, i18n("Got send file request\nwith invalid password"));
936 qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); 933 //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() );
937 } 934 }
938 } 935 }
939 if ( tokens[0] == "PUT" ) { 936 if ( tokens[0] == "PUT" ) {
940 if ( tokens[1] == mPassWord ) { 937 if ( tokens[1] == mPassWord ) {
941 //emit getFile( mSocket ); 938 //emit getFile( mSocket );
942 blockRC = true; 939 blockRC = true;
943 get_file(); 940 get_file();
944 } 941 }
945 else { 942 else {
946 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password")); 943 KMessageBox::error( 0, i18n("Got receive file request\nwith invalid password"));
947 qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() ); 944 //qDebug("password %s, invalid password %s ",mPassWord.latin1(), tokens[1].latin1() );
948 } 945 }
949 } 946 }
950 if ( tokens[0] == "STOP" ) { 947 if ( tokens[0] == "STOP" ) {
951 //emit endConnect(); 948 //emit endConnect();
952 end_connect(); 949 end_connect();
953 } 950 }
954 } 951 }
955} 952}
956void KServerSocket::end_connect() 953void KServerSocket::end_connect()
957{ 954{
958 delete mSyncActionDialog; 955 delete mSyncActionDialog;
959 mSyncActionDialog = 0; 956 mSyncActionDialog = 0;
960} 957}
961void KServerSocket::send_file() 958void KServerSocket::send_file()
962{ 959{
963 //qDebug("MainWindow::sendFile(QSocket* s) "); 960 //qDebug("MainWindow::sendFile(QSocket* s) ");
964 if ( mSyncActionDialog ) 961 if ( mSyncActionDialog )
965 delete mSyncActionDialog; 962 delete mSyncActionDialog;
966 mSyncActionDialog = new QDialog ( 0, "input-dialog", true ); 963 mSyncActionDialog = new QDialog ( 0, "input-dialog", true );
967 mSyncActionDialog->setCaption(i18n("Received sync request")); 964 mSyncActionDialog->setCaption(i18n("Received sync request"));
968 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog ); 965 QLabel* label = new QLabel( i18n("Synchronizing from remote ...\n\nDo not use this application!\n\nIf syncing fails\nyou can close this dialog."), mSyncActionDialog );
969 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog ); 966 QVBoxLayout* lay = new QVBoxLayout( mSyncActionDialog );
970 lay->addWidget( label); 967 lay->addWidget( label);
971 lay->setMargin(7); 968 lay->setMargin(7);
972 lay->setSpacing(7); 969 lay->setSpacing(7);
973 mSyncActionDialog->setFixedSize( 230, 120); 970 mSyncActionDialog->setFixedSize( 230, 120);
974 mSyncActionDialog->show(); 971 mSyncActionDialog->show();
975 mSyncActionDialog->raise(); 972 mSyncActionDialog->raise();
976 qDebug("KSS::saving ... ");
977 emit request_file(); 973 emit request_file();
978 qApp->processEvents(); 974 qApp->processEvents();
979 QString fileName = mFileName; 975 QString fileName = mFileName;
980 QFile file( fileName ); 976 QFile file( fileName );
981 if (!file.open( IO_ReadOnly ) ) { 977 if (!file.open( IO_ReadOnly ) ) {
982 delete mSyncActionDialog; 978 delete mSyncActionDialog;
983 mSyncActionDialog = 0; 979 mSyncActionDialog = 0;
984 qDebug("KSS::error open file "); 980 qDebug("KSS::error open file ");
985 mSocket->close(); 981 mSocket->close();
986 if ( mSocket->state() == QSocket::Idle ) 982 if ( mSocket->state() == QSocket::Idle )
987 QTimer::singleShot( 10, this , SLOT ( discardClient())); 983 QTimer::singleShot( 10, this , SLOT ( discardClient()));
988 return ; 984 return ;
989 985
990 } 986 }
991 mSyncActionDialog->setCaption( i18n("Sending file...") ); 987 mSyncActionDialog->setCaption( i18n("Sending file...") );
992 QTextStream ts( &file ); 988 QTextStream ts( &file );
993 ts.setEncoding( QTextStream::Latin1 ); 989 ts.setEncoding( QTextStream::Latin1 );
994 990
995 QTextStream os( mSocket ); 991 QTextStream os( mSocket );
996 os.setEncoding( QTextStream::Latin1 ); 992 os.setEncoding( QTextStream::Latin1 );
997 while ( ! ts.atEnd() ) { 993 while ( ! ts.atEnd() ) {
998 os << ts.readLine() << "\n"; 994 os << ts.readLine() << "\n";
999 } 995 }
1000 //os << ts.read(); 996 //os << ts.read();
1001 file.close(); 997 file.close();
1002 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") ); 998 mSyncActionDialog->setCaption( i18n("Waiting for synced file...") );
1003 mSocket->close(); 999 mSocket->close();
1004 if ( mSocket->state() == QSocket::Idle ) 1000 if ( mSocket->state() == QSocket::Idle )
1005 QTimer::singleShot( 10, this , SLOT ( discardClient())); 1001 QTimer::singleShot( 10, this , SLOT ( discardClient()));
1006} 1002}
1007void KServerSocket::get_file() 1003void KServerSocket::get_file()
1008{ 1004{
1009 mSyncActionDialog->setCaption( i18n("Receiving synced file...") ); 1005 mSyncActionDialog->setCaption( i18n("Receiving synced file...") );
1010 1006
1011 piTime.start(); 1007 piTime.start();
1012 piFileString = ""; 1008 piFileString = "";
1013 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) )); 1009 QTimer::singleShot( 1, this , SLOT (readBackFileFromSocket( ) ));
1014} 1010}
1015 1011
1016 1012
1017void KServerSocket::readBackFileFromSocket() 1013void KServerSocket::readBackFileFromSocket()
1018{ 1014{
1019 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ()); 1015 //qDebug("readBackFileFromSocket() %d ", piTime.elapsed ());
1020 while ( mSocket->canReadLine () ) { 1016 while ( mSocket->canReadLine () ) {
1021 piTime.restart(); 1017 piTime.restart();
1022 QString line = mSocket->readLine (); 1018 QString line = mSocket->readLine ();
1023 piFileString += line; 1019 piFileString += line;
1024 //qDebug("readline: %s ", line.latin1()); 1020 //qDebug("readline: %s ", line.latin1());
1025 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) ); 1021 mSyncActionDialog->setCaption( i18n("Received %1 bytes").arg( piFileString.length() ) );
1026 1022
1027 } 1023 }
1028 if ( piTime.elapsed () < 3000 ) { 1024 if ( piTime.elapsed () < 3000 ) {
1029 // wait for more 1025 // wait for more
1030 //qDebug("waitformore "); 1026 //qDebug("waitformore ");
1031 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) )); 1027 QTimer::singleShot( 100, this , SLOT (readBackFileFromSocket( ) ));
1032 return; 1028 return;
1033 } 1029 }
1034 QString fileName = mFileName; 1030 QString fileName = mFileName;
1035 QFile file ( fileName ); 1031 QFile file ( fileName );
1036 if (!file.open( IO_WriteOnly ) ) { 1032 if (!file.open( IO_WriteOnly ) ) {
1037 delete mSyncActionDialog; 1033 delete mSyncActionDialog;
1038 mSyncActionDialog = 0; 1034 mSyncActionDialog = 0;
1039 qDebug("error open cal file "); 1035 qDebug("KSS:Error open read back file ");
1040 piFileString = ""; 1036 piFileString = "";
1041 emit file_received( false ); 1037 emit file_received( false );
1042 blockRC = false; 1038 blockRC = false;
1043 return ; 1039 return ;
1044 1040
1045 } 1041 }
1046 1042
1047 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 1043 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
1048 QTextStream ts ( &file ); 1044 QTextStream ts ( &file );
1049 ts.setEncoding( QTextStream::Latin1 ); 1045 ts.setEncoding( QTextStream::Latin1 );
1050 mSyncActionDialog->setCaption( i18n("Writing file to disk...") ); 1046 mSyncActionDialog->setCaption( i18n("Writing file to disk...") );
1051 ts << piFileString; 1047 ts << piFileString;
1052 mSocket->close(); 1048 mSocket->close();
1053 if ( mSocket->state() == QSocket::Idle ) 1049 if ( mSocket->state() == QSocket::Idle )
1054 QTimer::singleShot( 10, this , SLOT ( discardClient())); 1050 QTimer::singleShot( 10, this , SLOT ( discardClient()));
1055 file.close(); 1051 file.close();
1056 delete mSyncActionDialog; 1052 delete mSyncActionDialog;
1057 mSyncActionDialog = 0; 1053 mSyncActionDialog = 0;
1058 piFileString = ""; 1054 piFileString = "";
1059 blockRC = false; 1055 blockRC = false;
1060 emit file_received( true ); 1056 emit file_received( true );
1061 1057
1062} 1058}
1063 1059
1064KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name ) 1060KCommandSocket::KCommandSocket ( QString password, Q_UINT16 port, QString host, QObject * parent, const char * name ): QObject( parent, name )
1065{ 1061{
1066 mPassWord = password; 1062 mPassWord = password;
1067 mSocket = 0; 1063 mSocket = 0;
1068 mPort = port; 1064 mPort = port;
1069 mHost = host; 1065 mHost = host;
1070 1066
1071 mRetVal = quiet; 1067 mRetVal = quiet;
1072 mTimerSocket = new QTimer ( this ); 1068 mTimerSocket = new QTimer ( this );
1073 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) ); 1069 connect( mTimerSocket, SIGNAL ( timeout () ), this, SLOT ( deleteSocket() ) );
1074} 1070}
1075void KCommandSocket::readFile( QString fn ) 1071void KCommandSocket::readFile( QString fn )
1076{ 1072{
1077 if ( !mSocket ) { 1073 if ( !mSocket ) {
1078 mSocket = new QSocket( this ); 1074 mSocket = new QSocket( this );
1079 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) ); 1075 connect( mSocket, SIGNAL(readyRead()), this, SLOT(startReadFileFromSocket()) );
1080 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1076 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1081 } 1077 }
1082 mFileString = ""; 1078 mFileString = "";
1083 mFileName = fn; 1079 mFileName = fn;
1084 mFirst = true; 1080 mFirst = true;
1085 mSocket->connectToHost( mHost, mPort ); 1081 mSocket->connectToHost( mHost, mPort );
1086 QTextStream os( mSocket ); 1082 QTextStream os( mSocket );
1087 os.setEncoding( QTextStream::Latin1 ); 1083 os.setEncoding( QTextStream::Latin1 );
1088 os << "GET " << mPassWord << "\r\n"; 1084 os << "GET " << mPassWord << "\r\n";
1089 mTimerSocket->start( 10000 ); 1085 mTimerSocket->start( 10000 );
1090} 1086}
1091 1087
1092void KCommandSocket::writeFile( QString fileName ) 1088void KCommandSocket::writeFile( QString fileName )
1093{ 1089{
1094 if ( !mSocket ) { 1090 if ( !mSocket ) {
1095 mSocket = new QSocket( this ); 1091 mSocket = new QSocket( this );
1096 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1092 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1097 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) ); 1093 connect( mSocket, SIGNAL(connected ()), this, SLOT(writeFileToSocket()) );
1098 } 1094 }
1099 mFileName = fileName ; 1095 mFileName = fileName ;
1100 mSocket->connectToHost( mHost, mPort ); 1096 mSocket->connectToHost( mHost, mPort );
1101} 1097}
1102void KCommandSocket::writeFileToSocket() 1098void KCommandSocket::writeFileToSocket()
1103{ 1099{
1104 QFile file2( mFileName ); 1100 QFile file2( mFileName );
1105 if (!file2.open( IO_ReadOnly ) ) { 1101 if (!file2.open( IO_ReadOnly ) ) {
1106 mRetVal= errorW; 1102 mRetVal= errorW;
1107 mSocket->close(); 1103 mSocket->close();
1108 if ( mSocket->state() == QSocket::Idle ) 1104 if ( mSocket->state() == QSocket::Idle )
1109 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1105 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1110 return ; 1106 return ;
1111 } 1107 }
1112 QTextStream ts2( &file2 ); 1108 QTextStream ts2( &file2 );
1113 ts2.setEncoding( QTextStream::Latin1 ); 1109 ts2.setEncoding( QTextStream::Latin1 );
1114 QTextStream os2( mSocket ); 1110 QTextStream os2( mSocket );
1115 os2.setEncoding( QTextStream::Latin1 ); 1111 os2.setEncoding( QTextStream::Latin1 );
1116 os2 << "PUT " << mPassWord << "\r\n";; 1112 os2 << "PUT " << mPassWord << "\r\n";;
1117 while ( ! ts2.atEnd() ) { 1113 while ( ! ts2.atEnd() ) {
1118 os2 << ts2.readLine() << "\n"; 1114 os2 << ts2.readLine() << "\n";
1119 } 1115 }
1120 mRetVal= successW; 1116 mRetVal= successW;
1121 file2.close(); 1117 file2.close();
1122 mSocket->close(); 1118 mSocket->close();
1123 if ( mSocket->state() == QSocket::Idle ) 1119 if ( mSocket->state() == QSocket::Idle )
1124 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1120 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1125} 1121}
1126void KCommandSocket::sendStop() 1122void KCommandSocket::sendStop()
1127{ 1123{
1128 if ( !mSocket ) { 1124 if ( !mSocket ) {
1129 mSocket = new QSocket( this ); 1125 mSocket = new QSocket( this );
1130 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1126 connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1131 } 1127 }
1132 mSocket->connectToHost( mHost, mPort ); 1128 mSocket->connectToHost( mHost, mPort );
1133 QTextStream os2( mSocket ); 1129 QTextStream os2( mSocket );
1134 os2.setEncoding( QTextStream::Latin1 ); 1130 os2.setEncoding( QTextStream::Latin1 );
1135 os2 << "STOP\r\n"; 1131 os2 << "STOP\r\n";
1136 mSocket->close(); 1132 mSocket->close();
1137 if ( mSocket->state() == QSocket::Idle ) 1133 if ( mSocket->state() == QSocket::Idle )
1138 QTimer::singleShot( 10, this , SLOT ( deleteSocket())); 1134 QTimer::singleShot( 10, this , SLOT ( deleteSocket()));
1139} 1135}
1140 1136
1141void KCommandSocket::startReadFileFromSocket() 1137void KCommandSocket::startReadFileFromSocket()
1142{ 1138{
1143 if ( ! mFirst ) 1139 if ( ! mFirst )
1144 return; 1140 return;
1145 mFirst = false; 1141 mFirst = false;
1146 mTimerSocket->stop(); 1142 mTimerSocket->stop();
1147 mFileString = ""; 1143 mFileString = "";
1148 mTime.start(); 1144 mTime.start();
1149 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) )); 1145 QTimer::singleShot( 1, this , SLOT (readFileFromSocket( ) ));
1150 1146
1151} 1147}
1152void KCommandSocket::readFileFromSocket() 1148void KCommandSocket::readFileFromSocket()
1153{ 1149{
1154 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ()); 1150 //qDebug("readBackFileFromSocket() %d ", mTime.elapsed ());
1155 while ( mSocket->canReadLine () ) { 1151 while ( mSocket->canReadLine () ) {
1156 mTime.restart(); 1152 mTime.restart();
1157 QString line = mSocket->readLine (); 1153 QString line = mSocket->readLine ();
1158 mFileString += line; 1154 mFileString += line;
1159 //qDebug("readline: %s ", line.latin1()); 1155 //qDebug("readline: %s ", line.latin1());
1160 } 1156 }
1161 if ( mTime.elapsed () < 3000 ) { 1157 if ( mTime.elapsed () < 3000 ) {
1162 // wait for more 1158 // wait for more
1163 //qDebug("waitformore "); 1159 //qDebug("waitformore ");
1164 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) )); 1160 QTimer::singleShot( 100, this , SLOT (readFileFromSocket( ) ));
1165 return; 1161 return;
1166 } 1162 }
1167 QString fileName = mFileName; 1163 QString fileName = mFileName;
1168 QFile file ( fileName ); 1164 QFile file ( fileName );
1169 if (!file.open( IO_WriteOnly ) ) { 1165 if (!file.open( IO_WriteOnly ) ) {
1170 mFileString = ""; 1166 mFileString = "";
1171 mRetVal = errorR; 1167 mRetVal = errorR;
1172 qDebug("Error open temp calender file for writing: %s",fileName.latin1() ); 1168 qDebug("KSS:Error open temp sync file for writing: %s",fileName.latin1() );
1173 deleteSocket(); 1169 deleteSocket();
1174 return ; 1170 return ;
1175 1171
1176 } 1172 }
1177 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1)); 1173 // mView->setLoadedFileVersion(QDateTime::currentDateTime().addSecs( -1));
1178 QTextStream ts ( &file ); 1174 QTextStream ts ( &file );
1179 ts.setEncoding( QTextStream::Latin1 ); 1175 ts.setEncoding( QTextStream::Latin1 );
1180 ts << mFileString; 1176 ts << mFileString;
1181 file.close(); 1177 file.close();
1182 mFileString = ""; 1178 mFileString = "";
1183 mRetVal = successR; 1179 mRetVal = successR;
1184 mSocket->close(); 1180 mSocket->close();
1185 // if state is not idle, deleteSocket(); is called via 1181 // if state is not idle, deleteSocket(); is called via
1186 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) ); 1182 // connect( mSocket, SIGNAL(delayedCloseFinished ()), this, SLOT(deleteSocket()) );
1187 if ( mSocket->state() == QSocket::Idle ) 1183 if ( mSocket->state() == QSocket::Idle )
1188 deleteSocket(); 1184 deleteSocket();
1189} 1185}
1190 1186
1191void KCommandSocket::deleteSocket() 1187void KCommandSocket::deleteSocket()
1192{ 1188{
1193 //qDebug("KCommandSocket::deleteSocket() "); 1189 //qDebug("KCommandSocket::deleteSocket() ");
1194 if ( mTimerSocket->isActive () ) { 1190 if ( mTimerSocket->isActive () ) {
1195 mTimerSocket->stop(); 1191 mTimerSocket->stop();
1196 mRetVal = errorTO; 1192 mRetVal = errorTO;
1197 qDebug("Connection to remote host timed out"); 1193 qDebug("Connection to remote host timed out");
1198 if ( mSocket ) { 1194 if ( mSocket ) {
1199 mSocket->close(); 1195 mSocket->close();
1200 //if ( mSocket->state() == QSocket::Idle ) 1196 //if ( mSocket->state() == QSocket::Idle )
1201 // deleteSocket(); 1197 // deleteSocket();
1202 delete mSocket; 1198 delete mSocket;
1203 mSocket = 0; 1199 mSocket = 0;
1204 } 1200 }
1205 KMessageBox::error( 0, i18n("Connection to remote\nhost timed out!\nDid you forgot to enable\nsyncing on remote host? ")); 1201 KMessageBox::error( 0, i18n("Connection to remote\nhost timed out!\nDid you forgot to enable\nsyncing on remote host? "));
1206 emit commandFinished( this, mRetVal ); 1202 emit commandFinished( this, mRetVal );
1207 return; 1203 return;
1208 } 1204 }
1209 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal ); 1205 //qDebug("KCommandSocket::deleteSocket() %d", mRetVal );
1210 if ( mSocket) 1206 if ( mSocket)
1211 delete mSocket; 1207 delete mSocket;
1212 mSocket = 0; 1208 mSocket = 0;
1213 emit commandFinished( this, mRetVal ); 1209 emit commandFinished( this, mRetVal );
1214} 1210}