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

//

#include <e32base.h>

#include <s32buf.h>

#include "urilistwritestream.h"

#include "ineturiimpl.h"

#include "ineturiproperties.h"

#include "urilist.h"

#include "ineturilistserver.h"

#include "uriqueryfilter.h"

/**

Stanadard factory construction method

*/

CUriListStream* CUriListStream::NewL ( CUriQueryFilter* aQueryFilter )

	{

	CUriListStream* self = new (ELeave) CUriListStream;

	CleanupStack::PushL ( self );

	self->ConstructL (aQueryFilter);

	CleanupStack::Pop ();

	return self;

	}

CUriListStream::CUriListStream ()

	{

	}

CUriListStream::~CUriListStream ()

	{

	iWriteStream.Close ();

	delete iInetUri;

	// Delete the buffer

	delete iIpcBuffer;

	delete iQueryFilter;	

	}

void CUriListStream::ConstructL ( CUriQueryFilter* aQueryFilter )

	{

	iIpcBuffer = CBufFlat::NewL ( KIpcDataSize );	

	iIpcBuffer->ExpandL ( 0, KIpcDataSize );		

	iWriteStream.Open ( *iIpcBuffer );	// Open the stream

	iInetUri = CInetUriImpl::NewL ();

	iQueryFilter = aQueryFilter;						

	}

/**

Writes the URI list to the IPC data stream. The results could contain multiple 

data records. The stream position will be set to the beginning before the write 

operation. It returns the total number of records returned via the data stream.

*/

TInt CUriListStream::WriteUriListL ( TPtrC8& aData )

	{

	ResetL ();

	MDBTransaction& dbTrans = iQueryFilter->DBTransaction();

	TInt totalRecords = 0;

	TBool dirty = iInetUri->IsDirty ();

	while ( !dirty || dbTrans.Next() ) 

		{

		if ( iQueryFilter->MatchRecordL () )

			{

			PopulateDataFieldsL ();

			if ( PendingWriteStreamSizeL () >= iInetUri->Size() )

				{

				iInetUri->PackL ( iWriteStream );

				iInetUri->Clear ();

				dirty = ETrue;

				++totalRecords; // Increment the total no. of records

				}

			else

				{

				break;				

				}			

			}

		}

	// Write to the buffer.

	aData.Set ( iIpcBuffer->Ptr(0) );

	// return with total no. of records

	return totalRecords;	

	}

/**

Resets the write stream position to the begining.

*/

void CUriListStream::ResetL ()

	{

	MStreamBuf* srcStream = iWriteStream.Sink ();

	srcStream->SeekL ( MStreamBuf::EWrite, EStreamBeginning, 0 );

	}

/**

Returns the number of bytes remaining in the stream for the write operation. 

*/

TInt CUriListStream::PendingWriteStreamSizeL ()

	{

	MStreamBuf* srcStream = iWriteStream.Sink ();	

	TStreamPos streamPos = srcStream->TellL ( MStreamBuf::EWrite );

	return KIpcDataSize - streamPos.Offset();

	}

/**

Reads the data from the storage and populates the CInetUriImpl object. Later this

data will be packed and send it via IPC data buffer

*/

void CUriListStream::PopulateDataFieldsL ()

	{

	MDBTransaction& dbTrans = iQueryFilter->DBTransaction();

	iInetUri->SetUriId ( dbTrans.ColumnIntL ( URILIST::EId ) );

	CUri8* uri = CreateUriL ();

	iInetUri->SetUri ( *uri );

	// Populate the properties

	CInetUriProperties& properties = iInetUri->Properties ();

	properties.SetPropId ( dbTrans.ColumnIntL ( URILIST::EPropId - 1 ) );

	properties.SetServiceType ( static_cast <InetUriList::TServiceType> ( dbTrans.ColumnIntL ( URILIST::EServiceType - 1 ) ) );

	properties.SetListType ( static_cast <InetUriList::TListType> ( dbTrans.ColumnIntL ( URILIST::EListType - 1 ) ) );

	properties.SetFavouriteNameL ( dbTrans.ColumnTextL ( URILIST::EFavouriteName - 1 ) );

	properties.SetPermission ( static_cast <InetUriList::TPermission> ( dbTrans.ColumnIntL ( URILIST::EPermission - 1 ) ) );

	}

/**

Creates a new URI object by setting the individual components. The individual componentes are 

read from the storage.

*/

CUri8* CUriListStream::CreateUriL ()

	{

	MDBTransaction& dbTrans = iQueryFilter->DBTransaction();

	CUri8* uri = CUri8::NewL ();

	CleanupStack::PushL ( uri );

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EScheme ), EUriScheme );	

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EHost ), EUriHost );	

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EPort ), EUriPort );	

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EUserInfo ), EUriUserinfo );	

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EPath ), EUriPath );			

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EQuery ), EUriQuery );	

	SetUriComponentL ( *uri, dbTrans.ColumnTextL ( URILIST::EFragments ), EUriFragment );	

	CleanupStack::Pop (); // uri

	return uri;

	}

/**

Sets the URI component.

*/

void CUriListStream::SetUriComponentL ( CUri8& aUri, const TDesC8& aUriComponent, TUriComponent aComponent )

	{

	aUri.SetComponentL ( aUriComponent, aComponent );

	}