/*
* Copyright (c) 2005-2009 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:  Implementation of object, relation and event query
*
*/


#include "mdequeryimpl.h"

#include "mdesessionimpl.h"
#include "mdeasynchronousfindao.h"
#include "mdeobject.h"
#include "mderelation.h"
#include "mdeevent.h"



CMdEObjectQueryImpl* CMdEObjectQueryImpl::NewL( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, CMdEObjectDef& aObjectDef,
		RPointerArray<CMdEObjectDef>* aObjectDefs, RMdEEngineSession& aSession )
	{
	CMdEObjectQueryImpl* self = CMdEObjectQueryImpl::NewLC( aSessionImpl, aNamespaceDef, 
			aObjectDef, aObjectDefs, aSession );
    CleanupStack::Pop( self );
    return self;
	}

CMdEObjectQueryImpl* CMdEObjectQueryImpl::NewLC( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, CMdEObjectDef& aObjectDef,
		RPointerArray<CMdEObjectDef>* aObjectDefs, RMdEEngineSession& aSession  )
	{
	CMdEObjectQueryImpl* self = new ( ELeave ) CMdEObjectQueryImpl( aSessionImpl, aNamespaceDef, 
			aObjectDef, aObjectDefs );
    CleanupStack::PushL( self );
    self->ConstructL( aSessionImpl, aSession );
    return self;
	}

CMdEObjectQueryImpl::CMdEObjectQueryImpl( 
		CMdESessionImpl& aSessionImpl, CMdENamespaceDef& aNamespaceDef, 
		CMdEObjectDef& aObjectDef, RPointerArray<CMdEObjectDef>* aObjectDefs )
    : CMdEObjectQuery( aSessionImpl, aNamespaceDef, aObjectDef, aObjectDefs )
    {
    }


void CMdEObjectQueryImpl::ConstructL( CMdESessionImpl& aSessionImpl,
    RMdEEngineSession& aSession )
    {
    ObjectQueryConstructL();
    iAsyncFind = CMdEAsynchronousFindAO::NewL( *this, aSessionImpl, aSession );
    }


CMdEObjectQueryImpl::~CMdEObjectQueryImpl()
    {
    if( iAsyncFind )
    	{    	
    	iAsyncFind->Cancel();
    	
    	delete iAsyncFind;
    	}
    }


void CMdEObjectQueryImpl::DoFindL( TUint aMaxCount, TUint aNotifyCount )
    {
    iAsyncFind->DoFindL( aMaxCount, aNotifyCount );
    SetState( EStateSearching );
    }


void CMdEObjectQueryImpl::DoCancel()
    {
    // Stop searching.
    iAsyncFind->Cancel();
    SetState( EStateError );
    }


void CMdEObjectQueryImpl::DoNotifyResultsL( RPointerArray<CMdEInstanceItem>& aResultList )
    {
    NotifyNewResultsL( aResultList );
    }


void CMdEObjectQueryImpl::DoNotifyResultsL( RArray<TItemId>& aResultIdList )
    {
    NotifyNewResultsL( aResultIdList );
    }

void CMdEObjectQueryImpl::DoNotifyResultsL( CDesCArray& aResults )
	{
	NotifyNewResultsL( aResults );
	}

void CMdEObjectQueryImpl::DoNotifyResults( TInt aResultCount )
    {
    NotifyNewResults( aResultCount );
    }

void CMdEObjectQueryImpl::DoNotifyCompleted( TInt aError )
    {
    SetState( aError ? EStateError : EStateCompleted );
    NotifyCompleted( aError );
    }


CMdERelationQueryImpl* CMdERelationQueryImpl::NewL( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, RMdEEngineSession& aSession )
	{
	CMdERelationQueryImpl* self = CMdERelationQueryImpl::NewLC( aSessionImpl,
			aNamespaceDef, aSession );
    CleanupStack::Pop( self );
    return self;
	}

CMdERelationQueryImpl* CMdERelationQueryImpl::NewLC( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, RMdEEngineSession& aSession )
	{
	CMdERelationQueryImpl* self = new ( ELeave ) CMdERelationQueryImpl( aSessionImpl, aNamespaceDef );
    CleanupStack::PushL( self );
    self->ConstructL( aSessionImpl, aSession );
    return self;
	}

CMdERelationQueryImpl::CMdERelationQueryImpl( CMdESessionImpl& aSessionImpl, CMdENamespaceDef& aNamespaceDef )
    : CMdERelationQuery( aSessionImpl, aNamespaceDef )
    {
    }


void CMdERelationQueryImpl::ConstructL( CMdESessionImpl& aSessionImpl,
    RMdEEngineSession& aSession )
    {
    RelationQueryConstructL();
    iAsyncFind = CMdEAsynchronousFindAO::NewL( *this, aSessionImpl, aSession );
    }


CMdERelationQueryImpl::~CMdERelationQueryImpl()
    {
	delete iAsyncFind;
    }


void CMdERelationQueryImpl::DoFindL( TUint aMaxCount, TUint aNotifyCount )
    {
    iAsyncFind->DoFindL( aMaxCount, aNotifyCount );
    SetState( EStateSearching );
    }

    
void CMdERelationQueryImpl::DoCancel()
    {
    // Stop searching.
    iAsyncFind->Cancel();
    SetState( EStateError );
    }

void CMdERelationQueryImpl::DoNotifyResultsL( RPointerArray<CMdEInstanceItem>& aResultList )
    {
    NotifyNewResultsL( aResultList );
    }

void CMdERelationQueryImpl::DoNotifyResultsL( RArray<TItemId>& aResultIdList )
    {
    NotifyNewResultsL( aResultIdList );
    }

void CMdERelationQueryImpl::DoNotifyResults( TUint32 aResultCount )
    {
    NotifyNewResults( aResultCount );
    }

void CMdERelationQueryImpl::DoNotifyCompleted( TInt aError )
    {
    SetState( aError ? EStateError : EStateCompleted );
    NotifyCompleted( aError );
    }


CMdEEventQueryImpl::CMdEEventQueryImpl( CMdESessionImpl& aSessionImpl, CMdENamespaceDef& aNamespaceDef )
    : CMdEEventQuery( aSessionImpl, aNamespaceDef )
    {
    }


CMdEEventQueryImpl* CMdEEventQueryImpl::NewL( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, RMdEEngineSession& aSession )
	{
	CMdEEventQueryImpl* self = CMdEEventQueryImpl::NewLC( aSessionImpl,
			aNamespaceDef, aSession );
    CleanupStack::Pop( self );
    return self;
	}

CMdEEventQueryImpl* CMdEEventQueryImpl::NewLC( CMdESessionImpl& aSessionImpl,
		CMdENamespaceDef& aNamespaceDef, RMdEEngineSession& aSession )
	{
	CMdEEventQueryImpl* self = new ( ELeave ) CMdEEventQueryImpl( aSessionImpl, aNamespaceDef );
    CleanupStack::PushL( self );
    self->ConstructL( aSessionImpl, aSession );
    return self;
	}

void CMdEEventQueryImpl::ConstructL( CMdESessionImpl& aSessionImpl,
    RMdEEngineSession& aSession )
    {
    EventQueryConstructL();
    iAsyncFind = CMdEAsynchronousFindAO::NewL( *this, aSessionImpl, aSession );
    }


CMdEEventQueryImpl::~CMdEEventQueryImpl()
    {
	delete iAsyncFind;
    }


void CMdEEventQueryImpl::DoFindL( TUint aMaxCount, TUint aNotifyCount )
    {
    iAsyncFind->DoFindL( aMaxCount, aNotifyCount );
    SetState( EStateSearching );
    }


void CMdEEventQueryImpl::DoCancel()
    {
    // Stop searching.
    iAsyncFind->Cancel();
    SetState( EStateError );
    }

void CMdEEventQueryImpl::DoNotifyResultsL( RPointerArray<CMdEInstanceItem>& aResultList )
    {
    NotifyNewResultsL( aResultList );
    }

void CMdEEventQueryImpl::DoNotifyResultsL( RArray<TItemId>& aResultIdList )
    {
    NotifyNewResultsL( aResultIdList );
    }

void CMdEEventQueryImpl::DoNotifyResults( TUint32 aResultCount )
    {
    NotifyNewResults( aResultCount );
    }

void CMdEEventQueryImpl::DoNotifyCompleted( TInt aError )
    {
    SetState( aError ? EStateError : EStateCompleted );
    NotifyCompleted( aError );
    }