/*
* Copyright (c) 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:  
*
*/


#include <s32mem.h>
#include <liwcommon.h>
#include "cpclientactivenotifier.h"
#include "ccontentmap.h"
#include "cpdebug.h"
#include "cpglobals.h"
#include "cpserverdef.h"
#include "cdatasourceinterface.h"

using namespace LIW;

// ======== MEMBER FUNCTIONS ========

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
CCPActiveNotifier* CCPActiveNotifier::NewL( RCPServerClient& aServerClient )
    {
    CCPActiveNotifier* self = new( ELeave ) 
            CCPActiveNotifier ( aServerClient );
    CleanupStack::PushL( self );
    self->ConstructL( );
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// destructor
// ---------------------------------------------------------------------------
CCPActiveNotifier::~CCPActiveNotifier()
    {
    CP_DEBUG( _L8("CCPActiveNotifier::CCPActiveNotifier()" ) );
    Cancel( );
    iObservers.Close( );
    delete iObserverBuf;
    delete iSizeDes;
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::RegisterL( MLiwNotifyCallback* aObserver, 
		TInt32 aTransactionId, CCPLiwMap* aMap )
    {
    CP_DEBUG( _L8("CCPActiveNotifier::RegisterL()" ) );
    TIpcArgs args;
    
   	if(iObservers.Find( aTransactionId ))
   		{
   		User::Leave( KErrInUse );
   		}
    
   	iObservers.InsertL( aTransactionId, aObserver );
	delete iObserverBuf;
	iObserverBuf = NULL;
 	iObserverBuf = aMap->PackForServerLC( );
   	CleanupStack::Pop( iObserverBuf );
   	args.Set( KDescriptorPosition, &*iObserverBuf );
	args.Set( KTransactionPosition, aTransactionId );
    
    if ( !IsActive( ) )
        {
        iSizeDes = new (ELeave) TPckgBuf<TInt>( );
        args.Set( KReturnPosition, iSizeDes );
        iServerClient.RegisterObserverL( iStatus, args );
        SetActive( );
        }
    else
        {
        iServerClient.AddObserver( args );
        }
    }


// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::UnregisterL()
    {
    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterL()" ) );
    if ( !IsActive( ) )
        {
        User::Leave( KErrNotFound );
        }
    else
        {
        Cancel( );
        delete iSizeDes;
        iSizeDes = NULL;
        }
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
TBool CCPActiveNotifier::UnregisterL( TInt32 aTransactionId )
    {
    TBool last(EFalse);
    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterL()" ) );

    MLiwNotifyCallback** observer = iObservers.Find(aTransactionId);
    if (observer)
        {
        CLiwGenericParamList* changeInfoList = 
                 CLiwGenericParamList::NewL( );
        CleanupStack::PushL( changeInfoList );
        CLiwGenericParamList* inParamList = CLiwGenericParamList::NewL( );
        CleanupStack::PushL( inParamList );
        
        changeInfoList->AppendL(TLiwGenericParam(EGenericParamError,
                TLiwVariant(CDataSourceInterface::ErrCodeConversion(KErrNone))));
        changeInfoList->AppendL(TLiwGenericParam(KErrorCode, TLiwVariant(
                CDataSourceInterface::ErrCodeConversion(KErrNone))));
        
		(*observer)->HandleNotifyL( aTransactionId, KLiwEventCanceled, *changeInfoList,
            *inParamList );     
        
        CleanupStack::PopAndDestroy( inParamList );
        CleanupStack::PopAndDestroy( changeInfoList );
        }
    else
        {
        User::Leave(KErrNotFound);
        }
    
    TIpcArgs args;
	args.Set( KTransactionPosition, aTransactionId );
    iServerClient.RemoveObserver( args );

    iObservers.Remove( aTransactionId );
        
	if( !iObservers.Count() )
		{
		UnregisterL();
		last = ETrue;
		}
	return last;
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::UnregisterAllL(  )
    {
    CP_DEBUG( _L8("CCPActiveNotifier::UnregisterAllL()" ) );
    if (!iObservers.Count())
    	{
    	User::Leave( KErrNotFound );
    	}
    THashMapIter<TInt32, MLiwNotifyCallback*> iter( iObservers );
    const TInt32* transaction = iter.NextKey();
    while( transaction )
        {
        UnregisterL( *transaction );
        transaction = iter.NextKey( );
        }    
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::RunL()
    {
    CP_DEBUG( _L8("CCPActiveNotifier::RunL()" ) );
    CLiwGenericParamList* eventParamList = CLiwGenericParamList::NewL();
    CleanupStack::PushL(eventParamList);

    TInt error = iStatus.Int();
    if (KErrNone == error)
        {
        RBuf8 outbuf;
        outbuf.CleanupClosePushL();
        outbuf.CreateL((*iSizeDes)());
        error = iServerClient.GetChangeInfoData(outbuf);
        RDesReadStream stream(outbuf);
        CleanupClosePushL(stream);
        eventParamList->InternalizeL(stream);
        CleanupStack::PopAndDestroy(&stream);
        delete iSizeDes;
        iSizeDes = NULL;
        CleanupStack::PopAndDestroy(&outbuf);
        }
    RegisterAgainL();

    NotifyObserversL(error, eventParamList);
    CleanupStack::PopAndDestroy(eventParamList);
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::NotifyObserversL( TInt aErrorCode, 
		CLiwGenericParamList* aEventParamList  )
	{
    TInt event( KLiwEventInProgress );
    if ( aErrorCode == KErrCancel )
        {
        event = KLiwEventCanceled;
        }
    else if ( aErrorCode != KErrNone )
        {
        event = KLiwEventStopped;
        }	
 
    for ( TInt i = 0; i<aEventParamList->Count(); i++ )
    	{
    	TLiwGenericParam param;
    	param.PushL();
    	TLiwVariant mapsV;
    	mapsV.PushL();
    	aEventParamList->AtL( i, param );
    	mapsV = param.Value();
    	CLiwDefaultList* listOfMatchingMaps = CLiwDefaultList::NewLC( );
    	if (mapsV.Get( *listOfMatchingMaps ))
    		{
    		TLiwVariant transV;
    		transV.PushL();
    		TInt transIndex (listOfMatchingMaps->Count()-1);
    		listOfMatchingMaps->AtL(transIndex ,transV);
    		TInt32 transactionId ( KErrNotFound );
    		transV.Get( transactionId );
    		MLiwNotifyCallback** observer = iObservers.Find( transactionId );
    		
    		if ( observer )
    			{
    			listOfMatchingMaps->Remove( transIndex );
    			CLiwGenericParamList* changeInfoList = 
											CLiwGenericParamList::NewL( );
    			CleanupStack::PushL( changeInfoList );
    		    CLiwGenericParamList* inParamList = CLiwGenericParamList::NewL( );
    		    CleanupStack::PushL( inParamList );
    			
    			changeInfoList->AppendL( TLiwGenericParam( KChangeInfo,
    							TLiwVariant( listOfMatchingMaps ) ) );
    			
    			changeInfoList->AppendL( TLiwGenericParam( EGenericParamError,
    			    TLiwVariant( CDataSourceInterface::ErrCodeConversion( aErrorCode ) ) ) );
    			changeInfoList->AppendL( TLiwGenericParam( KErrorCode,
    			    TLiwVariant( CDataSourceInterface::ErrCodeConversion( aErrorCode ) ) ) );
    			(*observer)->HandleNotifyL( transactionId, event, *changeInfoList,
    			        *inParamList );
    			
    		    CleanupStack::PopAndDestroy( inParamList );
    		    CleanupStack::PopAndDestroy( changeInfoList );
    			}//if

    		CleanupStack::PopAndDestroy( &transV );
    		}//if
    	CleanupStack::PopAndDestroy( listOfMatchingMaps );
    	CleanupStack::PopAndDestroy( &mapsV );
    	CleanupStack::PopAndDestroy( &param );
    	}//for
	}


// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::DoCancel()
    {
    CP_DEBUG( _L8("CCPActiveNotifier::DoCancel()" ) );
    iServerClient.UnregisterObserver( );
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
TInt CCPActiveNotifier::RunError( TInt /*aError*/)
    {
    TRAP_IGNORE( RegisterAgainL( ) );
    return KErrNone;
    }
// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
CCPActiveNotifier::CCPActiveNotifier( RCPServerClient& aServerClient ) :
    CActive(EPriorityStandard)
    {
    iServerClient = aServerClient;
    CActiveScheduler::Add( this );
    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::ConstructL()
    {

    }

// ----------------------------------------------------------------------------
//
// ----------------------------------------------------------------------------
//
void CCPActiveNotifier::RegisterAgainL()
    {
    CP_DEBUG( _L8("CCPActiveNotifier::RegisterAgainL()" ) );

    if (!IsActive())
        {
        TIpcArgs args;
        args.Set(KTransactionPosition, KErrAlreadyExists);
        if (iSizeDes)
            {
            delete iSizeDes;
            iSizeDes = NULL;
            }
        iSizeDes = new (ELeave) TPckgBuf<TInt> ();
        args.Set(KReturnPosition, iSizeDes);
        iServerClient.RegisterObserverL(iStatus, args);
        SetActive();
        }
    }