/*
* Copyright (c) 2005-2006 Nokia Corporation and/or its subsidiary(-ies). 
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description:  Watches changes of the PC-Suite data sync state
*
*/


#include "nssvasdatasyncwatcher.h"
#include "rubydebug.h"

// Destructors cannot be pure virtual
MNssDataSyncWatcher::~MNssDataSyncWatcher() 
    {
    // empty
    }



///////////////////////////////////
// CNssDataSyncWatcherFactory::ConstructDataSyncWatcherL
//
// Constructs and returns the data sync watcher according to what's
// available in the system. I.e RProperty based watcher or
// shared data client based watcher
// @param aHost Observer to be notified about data sync state changes
//
// @return Constructed and already started watcher
///////////////////////////////////
MNssDataSyncWatcher* CNssDataSyncWatcherFactory::ConstructDataSyncWatcherL( 
                                        MNssDataSyncStateObserver& aHost )
    {
    RUBY_DEBUG_BLOCKL( "ConstructDataSyncWatcherL" );
    MNssDataSyncWatcher* watcher = CNssDataSyncPropertyWatcher::NewL( aHost );
    return watcher;
    }

///////////////////////////////////
// CNssDataSyncPropertyWatcher::NewL
//
// Two phased construction
///////////////////////////////////
CNssDataSyncPropertyWatcher* CNssDataSyncPropertyWatcher::NewL( MNssDataSyncStateObserver& aHost )
    {
    CNssDataSyncPropertyWatcher* self = new (ELeave) CNssDataSyncPropertyWatcher( aHost );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }
    
///////////////////////////////////
// CNssDataSyncPropertyWatcher::CNssDataSyncPropertyWatcher
//
// Constructor
///////////////////////////////////
CNssDataSyncPropertyWatcher::CNssDataSyncPropertyWatcher( MNssDataSyncStateObserver& aHost ) :
    CActive( EPriorityStandard ),
    iHost( &aHost ),
    iDataSyncStatus( EDataSyncNotRunning )
    {
    // Nothing
    }
    
///////////////////////////////////
// CNssDataSyncPropertyWatcher::ConstructL
//
// Second-pase constructor
///////////////////////////////////
void CNssDataSyncPropertyWatcher::ConstructL() 
    {
    RUBY_DEBUG_BLOCK( "CNssDataSyncPropertyWatcher::ConstructL" );
    User::LeaveIfError( iProperty.Attach( KPSUidDataSynchronizationInternalKeys, KDataSyncStatus ) );
    CActiveScheduler::Add( this );
    // initial subscription and process current property value
    RunL();
    }
    
///////////////////////////////////
// CNssDataSyncPropertyWatcher::~CNssDataSyncPropertyWatcher
//
// Destructor
///////////////////////////////////
CNssDataSyncPropertyWatcher::~CNssDataSyncPropertyWatcher()
    {
    if( IsAdded() ) 
        {
        Deque();
        }
    iProperty.Close();
    }
    
///////////////////////////////////
// CNssDataSyncPropertyWatcher::DoCancel
//
// Cancel listening now
///////////////////////////////////
void CNssDataSyncPropertyWatcher::DoCancel() 
    {
    iProperty.Cancel();
    }


///////////////////////////////////
// CNssDataSyncPropertyWatcher::runL
//
// Is called, when property changed
///////////////////////////////////
void CNssDataSyncPropertyWatcher::RunL()
    {
    RUBY_DEBUG_BLOCK( "CNssDataSyncPropertyWatcher::RunL" );
    if( iStatus != KErrNone ) 
        {
        // At least report the error
        RUBY_ERROR1( "CNssDataSyncPropertyWatcher::RunL iStatus is [%d]", iStatus.Int() );
        }
        
    // resubscribe before processing new value to prevent missing updates
    // even if some error happened
    iProperty.Subscribe( iStatus );
    SetActive();
    // property updated, get new value
    TInt dataSyncStatus;
    if ( iProperty.Get( dataSyncStatus) == KErrNotFound )
        {
        // not defined is the same as sync is not running
        dataSyncStatus = EDataSyncNotRunning;
        }
    iDataSyncStatus = static_cast<TDataSyncStatus>( dataSyncStatus );
    iHost->DataSyncStateChanged( InProgress() );

    }
    
///////////////////////////////////
// CNssDataSyncPropertyWatcher::InProgress
//
// Tells if data sync is active right now
///////////////////////////////////
TBool CNssDataSyncPropertyWatcher::InProgress()
	{
	// There can be several different "running" statuses, but only one "not running"
    // So check for not running
	return iDataSyncStatus != EDataSyncNotRunning;
	}

//  End of File