/*

* Copyright (c) 2002-2008 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:  CCFContextManager class implementation.

*

*/

#include <cfcontextdataobject.h>

#include "CFContextManager.h"

#include "CFContextQueryImpl.h"

#include "CFContextObjectImpl.h"

#include "cfcontextsubscriptionlistener.h"

#include "CFContextSubscriptionImpl.h"

#include "CFCacheElement.h"

#include "cfutils.h"

#include "cftrace.h"

#include "CFContextDataProxy.h"

#include "cfcommon.h"

// Public Constructors and destructors

CCFContextManager* CCFContextManager::NewL(

	MCFSecurityChecker& aSecurityChecker )

    {

    FUNC_LOG;

    CCFContextManager* self = CCFContextManager::NewLC( aSecurityChecker );

    CleanupStack::Pop(self);

    return self;

    }

CCFContextManager* CCFContextManager::NewLC(

	MCFSecurityChecker& aSecurityChecker )

    {

    FUNC_LOG;

    CCFContextManager* self

    	= new (ELeave) CCFContextManager( aSecurityChecker );

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

    }

CCFContextManager::~CCFContextManager()

    {

    FUNC_LOG;

    iCleanupCacheElements.Close();

    iContextCache.ResetAndDestroy();

    iContextCache.Close();

    delete iPreviousContext;

    delete iCacheOrder;

    delete iCacheSearchKey;

    iSubscriptions.ResetAndDestroy();

    }

CCFContextManager::CCFContextManager( MCFSecurityChecker& aSecurityChecker )

    {

    FUNC_LOG;

    iSecurityChecker = &aSecurityChecker;

    }

void CCFContextManager::ConstructL()

    {

    FUNC_LOG;

    iCacheOrder = new (ELeave) TLinearOrder<CCFCacheElement>

        (CCFCacheElement::CompareByTypeAndSource);

    iCacheSearchKey = CCFCacheElement::NewL();

    iPreviousContext = CCFContextObject::NewL();

    }

// METHODS

//-----------------------------------------------------------------------------

// CCFContextManager::PublishContextL

//-----------------------------------------------------------------------------

//

void CCFContextManager::PublishContextL( CCFContextObject &aContext,

    RThread& aClientThread )

    {

    FUNC_LOG;

    ValidatePublishContextL( aContext, aClientThread );

    DoPublishContextL( aContext );

    }

//-----------------------------------------------------------------------------

// CCFContextManager::PublishContextL

//-----------------------------------------------------------------------------

//

void CCFContextManager::PublishContextL( CCFContextObject &aContext,

    RThread& aClientThread,

    CCFContextDataObject& aData )

    {

    FUNC_LOG;

    ValidatePublishContextL( aContext, aClientThread );

    DoPublishContextL( aContext, &aData );

    }

//-----------------------------------------------------------------------------

// CCFContextManager::RequestContextL

//-----------------------------------------------------------------------------

//

void CCFContextManager::RequestContextL( RContextObjectArray& aResultBuffer,

    CCFContextQuery& aContextQuery,

    RThread& aClientThread )

    {

    FUNC_LOG;

    // Accessing the context cache for the latest context values is enough

    DoRequestContextL( aResultBuffer, aContextQuery, &aClientThread );

    }

//-----------------------------------------------------------------------------

// CCFContextManager::RequestContextL

//-----------------------------------------------------------------------------

//

CCFContextObject* CCFContextManager::RequestContextL( const TDesC& aContextType,

    const TDesC& aContextSource,

    RThread& aClientThread )

    {

    FUNC_LOG;

    // check the cache

    iCacheSearchKey->Context().SetTypeL( aContextType );

    iCacheSearchKey->Context().SetSourceL( aContextSource );

    TInt index = KErrNone;

    if( iContextCache.FindInOrder( iCacheSearchKey, index,

        *iCacheOrder ) == KErrNone )

        {

        // index points to the matching object

        if( index >= 0 && index < iContextCache.Count() )

            {

            User::LeaveIfError( DoReadSecurityCheck(

                *iContextCache[index],

                aClientThread ) );

            return &iContextCache[index]->Context();

            }

        else

            {

            return NULL;

            }

        }

    else    // == KErrNotFound

        {   // index points to "the place to be"

        return NULL;

        }

    }

//-----------------------------------------------------------------------------

// CCFContextManager::SubscriptionAddedL

//-----------------------------------------------------------------------------

//

void CCFContextManager::SubscriptionAddedL(

    CCFContextSubscriptionImpl& aSubscription,

    RThread& aClientThread )

    {

    FUNC_LOG;

    TInt count = iContextCache.Count();

    CCFCacheElement* element = NULL;

    for( TInt i = 0; i < count; i++ )

        {

        element = iContextCache[i];

        if( aSubscription.Matches( element->Context().Type(),

            element->Context().Source() ) )

            {

            TInt err = DoReadSecurityCheck( *element, aClientThread );

            if (err == KErrNone)

            	{

            	element->AddSubscriptionL( aSubscription );

            	}

            else

            	{

            	aSubscription.SubscriptionListener().HandleContextSubscriptionError( err,

            		element->Context().Source(),

            		element->Context().Type() );

            	}

            }

        }

    }

//-----------------------------------------------------------------------------

// CCFContextManager::SubscriptionRemoved

//-----------------------------------------------------------------------------

//

TBool CCFContextManager::SubscriptionRemoved(

    CCFContextSubscriptionImpl& aSubscription)

    {

    FUNC_LOG;

    TBool cleanupElement( EFalse );

    for( TInt i = 0; i < iContextCache.Count(); i++ )

        {

        TInt j = iContextCache[ i ]->Subscriptions().Count() - 1;

        for( ; j >= 0; j-- )

            {

            if( &aSubscription == iContextCache[ i ]->Subscriptions()[ j ] )

                {

                CCFCacheElement* cacheElement = iContextCache[ i ];

                if ( iPublishingForCacheElement

                    && ( iPublishingForCacheElement == cacheElement ) )

                    {

                    cleanupElement = ETrue;

                    cacheElement->NullifySubscription( j );

                    TInt err = iCleanupCacheElements.InsertInAddressOrder(

                            cacheElement );

                    if ( err == KErrAlreadyExists )

                        {

                        err = KErrNone;

                        }

                    ERROR( err, "CCFContextManager::SubscriptionRemoved - Adding cache element to cleanup array failed!" );

                    }

                else

                    {

                    cacheElement->RemoveSubscription( j );

                    }

                }

            }

        }

    return cleanupElement;

    }

//----------------------------------------------------------------------------

// CCFContextManager::DefineContextL

//----------------------------------------------------------------------------

//

void CCFContextManager::DefineContextL( const TDesC& aContextSource,

    const TDesC& aContextType,

    const TSecurityPolicy& aReadSecurityPolicy,

    const TSecurityPolicy& aWriteSecurityPolicy )

    {

    FUNC_LOG;

    RThread thread;

    CleanupClosePushL( thread );

    DefineContextL( aContextSource, aContextType, aReadSecurityPolicy,

    		aWriteSecurityPolicy, NULL, thread.SecureId() );

    CleanupStack::PopAndDestroy( );

    }

//----------------------------------------------------------------------------

// CCFContextManager::DefineContextL

//----------------------------------------------------------------------------

//

void CCFContextManager::DefineContextL( const TDesC& aContextSource,

    const TDesC& aContextType,

    const TSecurityPolicy& aReadSecurityPolicy,

    const TSecurityPolicy& aWriteSecurityPolicy,

    MCFContextSource* aContextPublisher,

    const TUid& aPublisherUid )

    {

    FUNC_LOG;

    // Prepare and find context

    iCacheSearchKey->Context().SetSourceL( aContextSource );

    iCacheSearchKey->Context().SetTypeL( aContextType );

    iCacheSearchKey->Context().SetValueL( KNullDesC );

    iCacheSearchKey->SetReadSecurityPolicy( aReadSecurityPolicy );

    iCacheSearchKey->SetWriteSecurityPolicy( aWriteSecurityPolicy );

    iCacheSearchKey->SetContextPublisher( aContextPublisher, aPublisherUid );

    TInt index = KErrNone;

    TInt searchError = iContextCache.FindInOrder( iCacheSearchKey,

        index,

        *iCacheOrder );

    if ( searchError != KErrNone )

        {

        // New context type

        User::LeaveIfError(

            iContextCache.Insert( iCacheSearchKey, index ) );

        CacheElementAddedL( *iCacheSearchKey );

        iCacheSearchKey = NULL;

        iCacheSearchKey = CCFCacheElement::NewL();

        // Signalling new context type

        iPreviousContext->SetSourceL( KNullDesC );

        iPreviousContext->SetTypeL( KNullDesC );

        INFO_2( "New context defined: [%S: %S]",

            &aContextSource,

            &aContextType );

        }

    else

        {

        TInt err = KErrNone;

        CCFCacheElement* cacheElement = iContextCache[index];

        if( cacheElement->PublisherUid() == aPublisherUid )

            {

            if( RedefineAllowed( *cacheElement, aContextPublisher, aPublisherUid ) )

                {

                cacheElement->SetContextPublisher( aContextPublisher,

                    aPublisherUid );

                INFO_3( "Context [%S: %S] redefined by client [%x]",

                    &aContextSource, &aContextType, aPublisherUid.iUid );

                }

            else

                {

                err = KErrAlreadyExists;

                }

            }

        else

            {

            err = KErrAlreadyExists;

            }

        ERROR_2( err, "Context already defined: [%S: %S]",

            &aContextSource,

            &aContextType );

        User::LeaveIfError( err );

        }

    }

//-----------------------------------------------------------------------------

// CCFContextManager::GetReadSecurityPolicyL

//-----------------------------------------------------------------------------

//

void CCFContextManager::GetReadSecurityPolicyL( const TDesC& aContextSource,

            const TDesC& aContextType,

			TSecurityPolicy& aPolicy )

	{

	FUNC_LOG;

    TInt count = iContextCache.Count();

    CCFCacheElement* cacheElement = NULL;

    for( TInt i = 0; i < count; i++ )

        {

        cacheElement = iContextCache[ i ];

        if( cacheElement->Context().Source().Compare( aContextSource ) == 0

        	&& cacheElement->Context().Type().Compare( aContextType ) == 0 )

        	{

			aPolicy = cacheElement->GetReadSecurityPolicy();

			return;

        	}

        }

	ERROR_2( KErrNotFound, "Security Policy for [%S: %S] not found!",

		&aContextSource, &aContextType );

	User::Leave( KErrNotFound );

	}

//-----------------------------------------------------------------------------

// CCFContextManager::GetWriteSecurityPolicyL

//-----------------------------------------------------------------------------

//

void CCFContextManager::GetWriteSecurityPolicyL( const TDesC& aContextSource,

            const TDesC& aContextType,

			TSecurityPolicy& aPolicy )

	{

	FUNC_LOG;

    TInt count = iContextCache.Count();

    CCFCacheElement* cacheElement = NULL;

    for( TInt i = 0; i < count; i++ )

        {

        cacheElement = iContextCache[ i ];

        if( cacheElement->Context().Source().Compare( aContextSource ) == 0

        	&& cacheElement->Context().Type().Compare( aContextType ) == 0 )

        	{

			aPolicy = cacheElement->GetWriteSecurityPolicy();

			return;

        	}

        }

	ERROR_2( KErrNotFound, "Security Policy for [%S: %S] not found!",

		&aContextSource, &aContextType );

	User::Leave( KErrNotFound );

	}

//-----------------------------------------------------------------------------

// CCFContextManager::DeregisterPublisher

//-----------------------------------------------------------------------------

//

void CCFContextManager::DeregisterPublisher( MCFContextSource& aPublisher )

	{

    FUNC_LOG;

    for( TInt i = 0; i < iContextCache.Count() ; i++ )

        {

        CCFCacheElement* cacheElement = iContextCache[ i ];

        if( cacheElement->ContextPublisher() == &aPublisher )

        	{

			cacheElement->SetContextPublisher( NULL );

        	}

        }

	}