/*
* Copyright (c)  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:  Service Provider Settings API
*
*/


#include <e32property.h>
#include "spnotifychange.h"
#include "spdefaultvalues.h"
#include "mspnotifychangeobserver.h"
#include "spsapilogger.h" // For logging
#include "spsbufferedpublisher.h"

// ---------------------------------------------------------------------------
// Constructor
// ---------------------------------------------------------------------------
//
CSPNotifyChange::CSPNotifyChange( MSPNotifyChangeObserver& aObserver )
    : CActive( CActive::EPriorityStandard ),
      iObserver( aObserver )
    {
    XSPSLOGSTRING( "CSPNotifyChange::CSPNotifyChange() - IN" );
    
    CActiveScheduler::Add(this);
    
    XSPSLOGSTRING( "CSPNotifyChange::CSPNotifyChange() - OUT" );
    }

// ---------------------------------------------------------------------------
// ConstructL
// ---------------------------------------------------------------------------
//
void CSPNotifyChange::ConstructL()
    {
    XSPSLOGSTRING( "CSPNotifyChange::ConstructL() - IN" );
    
    iData = CSpsBufferedPublisher::NewL( KUidSystemCategory, KSPNotifyChangeKey );
    
    User::LeaveIfError( iProperty.Attach( KUidSystemCategory, KSPNotifyChangeKey ) );
    
    XSPSLOGSTRING( "CSPNotifyChange::ConstructL() - OUT" );
    }

// ---------------------------------------------------------------------------
// NewL
// ---------------------------------------------------------------------------
//
EXPORT_C CSPNotifyChange* CSPNotifyChange::NewL( MSPNotifyChangeObserver& aObserver )
    {
    XSPSLOGSTRING( "CSPNotifyChange::NewL() - IN" );
    
    CSPNotifyChange* self = new (ELeave) CSPNotifyChange( aObserver );

    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    
    XSPSLOGSTRING( "CSPNotifyChange::NewL() - OUT" );

    return self;
    }

// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
EXPORT_C CSPNotifyChange::~CSPNotifyChange()
    {
    XSPSLOGSTRING( "CSPNotifyChange::~CSPNotifyChange() - IN" );
    delete iData;
    Cancel();
	iIdArray.Reset();   
    iIdArray.Close();
    iProperty.Close();
    
    XSPSLOGSTRING( "CSPNotifyChange::~CSPNotifyChange() - OUT" );
    }

// ---------------------------------------------------------------------------
// From class CActive.
// ---------------------------------------------------------------------------
//
void CSPNotifyChange::DoCancel()
    {
    XSPSLOGSTRING( "CSPNotifyChange::DoCancel() - IN" );
    iData->Stop();
    iProperty.Cancel();
    
    XSPSLOGSTRING( "CSPNotifyChange::DoCancel() - OUT" );
    }

// ---------------------------------------------------------------------------
// From class CActive.
// Handle registration event
// ---------------------------------------------------------------------------
//
void CSPNotifyChange::RunL()
    {
    XSPSLOGSTRING( "CSPNotifyChange::RunL() - IN" );
    
    User::LeaveIfError( iStatus.Int() );
    Subscribe();
    RArray<TUint32> array;
    iData->GetL( array );
    
    TInt count = iIdArray.Count();
    while( array.Count() )
        {
        for( TInt i = 0; i < count; i++ )
            {
            if( array[0] == iIdArray[i] )
                {
                iObserver.HandleNotifyChange( array[0] );
                break;
                }
            }
        if( count == 0 )
            {
            XSPSLOGSTRING2( 
                "CSPNotifyChange::RunL() - HandleNotifyChange(%i)", array[0] );
            iObserver.HandleNotifyChange( array[0] );
            }
        
        array.Remove(0);
        }

    array.Close();

	XSPSLOGSTRING( "CSPNotifyChange::RunL() - OUT" );
    }

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
TInt CSPNotifyChange::RunError( TInt aError )
	{
	XSPSLOGSTRING( "CSPNotifyChange::RunError() - IN" );
	
	iObserver.HandleError( aError );
    
	Subscribe();
    
	XSPSLOGSTRING( "CSPNotifyChange::RunError() - OUT" );
	
	return KErrNone;
	}
	
// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
EXPORT_C void CSPNotifyChange::NotifyChangeL( const RIdArray& aIdArray )
	{
	XSPSLOGSTRING( "CSPNotifyChange::NotifyChangeL() - IN" );
	
	iIdArray.Reset();
	
	TInt count = aIdArray.Count();
	
	for( TInt i = 0; i < count; i++)
		{
		User::LeaveIfError( iIdArray.Append( aIdArray[i] ) );
		}
		
	Subscribe();
		
	XSPSLOGSTRING( "CSPNotifyChange::NotifyChangeL() - OUT" );
	}

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
EXPORT_C void CSPNotifyChange::NotifyChangeCancel()
	{
	XSPSLOGSTRING( "CSPNotifyChange::NotifyChangeCancel() - IN" );
	
	Cancel();
	
	XSPSLOGSTRING( "CSPNotifyChange::NotifyChangeCancel() - OUT" );
	}

// ---------------------------------------------------------------------------
// 
// ---------------------------------------------------------------------------
//
void CSPNotifyChange::Subscribe()
    {
    if( !IsActive() )
        {
        iData->Start();
        iProperty.Subscribe( iStatus );
        SetActive();
        }
    }