/*

* Copyright (c) 2004 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:  Symbian OS Server source.

*

*/

#include "nsmlsosserver.h"

#include "nsmldshostclient.h"

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

// CNSmlDataProvider::CNSmlDataProvider( const TInt aId )

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

//

CNSmlDataProvider::CNSmlDataProvider( const TInt aId, CNSmlSOSSession& aSession ) 

: iId(aId), iDataPtr(NULL, 0, 0), iSession(aSession) 

    {    

    }

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

// CNSmlDataProvider::~CNSmlDataProvider()

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

//

CNSmlDataProvider::~CNSmlDataProvider()

    {

    delete iBuffer;

    }

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

// void CNSmlDataProvider::FetchDataL()

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

//

void CNSmlDataProvider::FetchDataL()

    {

    RArray<TInt> idArray;

    RArray<TInt> resultArray;

    CleanupClosePushL(resultArray);

    CleanupClosePushL(idArray);

    idArray.AppendL(iId);

    iSession.HostClient().CreateDataProvidersL( idArray, resultArray );

    TInt res = resultArray[0];

    User::LeaveIfError( res );

    CleanupStack::PopAndDestroy(&idArray);

    CleanupStack::PopAndDestroy(&resultArray);

	TInt err = KErrNone;

	TNSmlDPInformation* dpInfo = iSession.HostClient().DataProviderInformationL( iId, err );

    User::LeaveIfError( err );

    HBufC* defds = iSession.HostClient().DefaultStoreL( iId, err );

    User::LeaveIfError( err );

    CDesCArray* dsArray = new (ELeave) CDesCArrayFlat(1);

    CleanupStack::PushL(dsArray);

    iSession.HostClient().ListStoresL( dsArray, iId, err );

    User::LeaveIfError( err );

    TInt mimeCount = dpInfo->iMimeTypes->Count();

    TInt mimelen = 0;

    TInt mverlen = 0;

    for (TInt mime = 0; mime < mimeCount; ++mime )

    	{

    	mimelen += ( *dpInfo->iMimeTypes )[ mime ].Size(); // mime type text length

    	mimelen += KSizeofTInt32; // mime type length value

    	mverlen += ( *dpInfo->iMimeVersions )[ mime ].Size(); // mime version text length

    	mverlen += KSizeofTInt32; // mime version length value

    	}

    TInt dnamlen = dpInfo->iDisplayName->Size();

    TInt defdslen = defds->Size();

    CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );

	CleanupStack::PushL( buffer );

	RBufWriteStream stream( *buffer );  

    CleanupClosePushL(stream); 

    stream.WriteInt32L( dpInfo->iVersion.iMajor );    // Version major

    stream.WriteInt32L( dpInfo->iVersion.iMinor );    // Version minor

    stream.WriteInt32L( dpInfo->iVersion.iBuild );    // Version build

    stream.WriteInt8L( (TInt8)dpInfo->iProtocolVer ); // Req protocol version

    // display name

    stream.WriteInt32L( dnamlen );

    stream << dpInfo->iDisplayName->Des();

	// mime type count

    stream.WriteInt32L( mimeCount );

    // mime types

    for ( TInt type = 0; type < mimeCount; ++type )

    	{

        stream.WriteInt32L( ( *dpInfo->iMimeTypes )[ type ].Size() );

        stream << ( *dpInfo->iMimeTypes )[ type ];

    	}

    // mime versions

    for ( TInt ver = 0; ver < mimeCount; ++ver )

    	{

        stream.WriteInt32L( ( *dpInfo->iMimeVersions )[ ver ].Size() );

        stream << ( *dpInfo->iMimeVersions )[ ver ];

    	}

    TInt count = dsArray->Count() + 1; // default ds + others.

    stream.WriteInt8L( count ); // Amount of datastores.

    // default datastore

    stream.WriteInt32L( defdslen );   

    stream << defds->Des();

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

        {

            stream.WriteInt32L( dsArray->operator[](i).Size() ); 

            stream << dsArray->operator[](i);

        }

    // Allow multible datastores

    stream.WriteInt8L( iSession.HostClient().SupportsOperationL( KUidSmlSupportMultipleStores, iId, err ) ); 

    User::LeaveIfError( err );

    stream.CommitL();

    CleanupStack::PopAndDestroy(&stream);

    delete iBuffer;

	iBuffer = buffer;

	CleanupStack::Pop( buffer );    

    CleanupStack::PopAndDestroy(dsArray);

    delete defds;

    delete dpInfo->iDisplayName;

    delete dpInfo->iMimeTypes;

    delete dpInfo->iMimeVersions;

    delete dpInfo;

    }

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

// TInt CNSmlDataProvider::DataSize()

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

//

TInt CNSmlDataProvider::DataSize()

    {

    return iBuffer->Size();

    }

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

// const TPtr8& CNSmlDataProvider::ReadData()

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

//

const TPtr8& CNSmlDataProvider::ReadData()

    {

    if ( iBuffer )

        {

        iDataPtr.Set( iBuffer->Ptr(0) );    

        }    

    return iDataPtr;

    }