/*

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

*

*/

#include <liwservicehandler.h>

#include "hnqueryresultcollector.h"

#include "hnmdquery.h"

#include "hnmdqueries.h"

#include "hnconvutils.h"

#include "hnservicehandler.h"

#include "hnmdservice.h"

#include "hnmdservicecommand.h"

using namespace LIW;

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

//

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

//

CHnQueryResultCollector* CHnQueryResultCollector::NewL(

		const CHnMdQueries& aQueries , const CLiwGenericParamList& aParams )

	{

	CHnQueryResultCollector* self = NewLC( aQueries , aParams );

	CleanupStack::Pop( self );

	return self;

	}

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

//

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

//

CHnQueryResultCollector* CHnQueryResultCollector::NewLC(

		const CHnMdQueries& aQueries , const CLiwGenericParamList& aParams )

	{

	CHnQueryResultCollector* self =

	new ( ELeave ) CHnQueryResultCollector( aQueries , aParams );

	CleanupStack::PushL( self );

	self->ConstructL();

	return self;

	}

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

//

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

//

CHnQueryResultCollector::CHnQueryResultCollector(

		const CHnMdQueries& aQueries ,

		const CLiwGenericParamList& aParams) : CActive ( EPriorityStandard ),

                                        	   iQueries( aQueries ),

                                        	   iParams( aParams )

	{

	}

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

//

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

//

CHnQueryResultCollector::~CHnQueryResultCollector()

	{

	Cancel();

	delete iResults;

	delete iCurrentQueryResults;

	delete iSh;

	}

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

//

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

//

void CHnQueryResultCollector::ConstructL()

	{

	iResults = CLiwGenericParamList::NewL();

	iCurrentQueryResults = CLiwGenericParamList::NewL();

	CActiveScheduler::Add( this );

	}

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

//

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

//

void CHnQueryResultCollector::StartAsynchL(

        MHnQueryResultCollectorNotification* aNotification )

    {

    __ASSERT_DEBUG( aNotification , User::Panic( KMatrixPanic , 0) );

    iNotification = aNotification;

    ResetL();

    if( iQueryIterator < iQueries.Count())

        {

        ExecQueryAsynchL();

        }

    else

        {

        iNotification->ResultsCollectedL( iResults );

        }

    }

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

//

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

//

void CHnQueryResultCollector::ResetL()

    {

    iQueryIterator = 0;

    iCurrentQueryResults->Reset();

    }

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

//

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

//

void CHnQueryResultCollector::DoCancel()

    {

    iCurrentQueryResults->Reset();

    delete iSh;

    iSh = NULL;

    }

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

//

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

//

TBool CHnQueryResultCollector::NextQuery()

    {

    iQueryIterator++;

    return iQueryIterator < iQueries.Count();

    }

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

//

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

//

void CHnQueryResultCollector::HandleQueryResultsL()

    {

    HBufC8* name8 = HnConvUtils::StrToStr8FastLC(

            iQueries.Query( iQueryIterator ).NameSpace() );

    CLiwDefaultMap* map = CLiwDefaultMap::NewL();

    map->PushL();

    TLiwGenericParam param;

    param.PushL();

    for (TInt i = 0; i < iCurrentQueryResults->Count(); i++)

        {

        iCurrentQueryResults->AtL(i, param);

        map->InsertL( param.Name(), param.Value() );

        param.Reset();

        }

    param.SetNameAndValueL( *name8, TLiwVariant( map) );

    iResults->AppendL(param);

    CleanupStack::PopAndDestroy( &param);

    CleanupStack::PopAndDestroy( map);

    CleanupStack::PopAndDestroy(name8);

    }

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

//

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

//

void CHnQueryResultCollector::RunL()

    {

    if ( !iStatus.Int() )

        {

        HandleQueryResultsL();

        }

    if( NextQuery() )

        {

        ExecQueryAsynchL();

        }

    else

        {

        iNotification->ResultsCollectedL( iResults );

        }

    }

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

//

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

//

void CHnQueryResultCollector::ExecQueryAsynchL()

    {

    __ASSERT_DEBUG( iQueryIterator < iQueries.Count() ,

                    User::Panic( KMatrixPanic , 0) );

    //cancel any running evaulations

    Cancel();

    ExecQueryL( iQueries.Query( iQueryIterator ) );

    SetActive();

    }

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

//

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

//

void CHnQueryResultCollector::ExecQueryL( CHnMdQuery& aQuery )

    {

    CLiwGenericParamList* constructor

        = aQuery.GetService().EvaluateConstructorL( iParams );

    CleanupStack::PushL( constructor );

    CLiwGenericParamList* command

        = aQuery.GetService().EvaluateCommandL( iParams );

    CleanupStack::PushL( command );

    delete iSh;

    iSh = NULL;

    iSh = CHnServiceHandler::NewL(

            aQuery.GetService().GetServiceName(),

            aQuery.GetService().GetInterfaceName(),

            aQuery.GetService().GetCommand().GetCommandName(),

            aQuery.GetService().GetCommand().GetCommandMode(),

            constructor,

            command );

    CleanupStack::Pop( command );

    CleanupStack::Pop( constructor );

    iSh->ExecuteL( *iCurrentQueryResults, iStatus );

    }

// End of file