// 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:
//

#ifndef __INETURILISTSERVER_H__
#define __INETURILISTSERVER_H__

#include <e32base.h>
#include <e32std.h>
#include <e32cmn.h>
#include <ineturilistdef.h>
#include <tldlistdef.h>
#include "StreamObjContainer.h"
#include "urilistwritestream.h"

const TInt KIpcDataSize = 2 * 1024;

// ----------------------------------------------------
const TUint KInetUriListServerMajorVersion = 0;
const TUint KInetUriListServerMinorVersion = 1;
const TUint KInetUriListServerBuildVersion = 1;

_LIT( KInetUriListServerName,"!InetUriListServer" );

// Structures
struct TRendezvous
	{
	TThreadId iId;
	TRequestStatus* iStatus;
	};

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


class CUriListInterface;
class CUriQueryFilter;
	
class CInetUriListServerSession : public CSession2
	{
public:
	static CInetUriListServerSession* NewL ();
	~CInetUriListServerSession ();
	
		
private:
	// From CSession2
	void ServiceL ( const RMessage2& aMessage );
	
	void ServiceError (const RMessage2 &aMessage, TInt aError);
	
	CInetUriListServerSession ();	
	
	void DispatchMessageL ( const RMessage2& aMessage );
	CBufFlat* ReadMessageLC ( TInt aParam, const RMessage2& aMessage );
	CUriListStream* GetListStreamL ( CUriQueryFilter* aQueryFilter );
	
private:
	TInt AddUriL ( const RMessage2& aMessage );
	TInt RemoveUriL ( const RMessage2& aMessage );
	TInt UpdateUriL ( const RMessage2& aMessage );
	
	TInt UriCountL ( const RMessage2& aMessage );
	
	TInt GetListTypeL ( const RMessage2& aMessage );

	TInt QueryWithUriL ( const RMessage2& aMessage );
	TInt QueryL ( const RMessage2& aMessage );
	TInt QueryTldInfoL ( const RMessage2& aMessage );
	TInt GetHostTypeL ( const RMessage2& aMessage );
	TInt PolicyDataLengthL ( const RMessage2& aMessage );
	TInt ReadQueryResultsL ( const RMessage2& aMessage );
	TInt CloseSrvStream ( const RMessage2& aMessage );

private:
	InetUriList::TServiceType iServiceType;	
	
	RStreamObjContainer < CUriListStream > iUriListStreams;
	};

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

class CInetUriListServer : public CPolicyServer
	{
public:

	enum TFunctionCode
		{
		EListType,
		EUriCount,
		EQuery,
		EQueryWithUri,
		EReadQueryResults,
		ECloseSrvStream,
		EAddUri,
		ERemoveUri,
		EUpdateUri,
		EQueryTldInfo,
		ETldListType,
		EPolicyLength,
		ENotSupported		
		};	
		
	static CInetUriListServer* NewL ();
	
	~CInetUriListServer ();
	
	void IncSessionCount () const;
	void DecSessionCount () const;
	
	void Error ( TInt aError );	
	
	inline CUriListInterface* UriListInterface () const;
private:
	virtual CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage ) const;
	
	CInetUriListServer ();
	void ConstructL ();
	
	
private:
	mutable TInt iSessionCount;
	mutable CUriListInterface* iUriListInterface;
	};

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

class CInetUriListSrvScheduler : public CActiveScheduler
	{
public:
	~CInetUriListSrvScheduler();
	static CInetUriListSrvScheduler* NewL();

private:
	CInetUriListSrvScheduler();
	
	// from CActiveScheduler
	virtual void Error(TInt aError) const;

private:
	CInetUriListServer* iInetUriListSrv;
	};
	
// ----------------------------------------------------------------------------------

#endif // __INETURILISTSERVER_H__