/*
* 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 the License "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: 
* Server-side classes which are required to implement a streaming reference agent server.
*
*/


/**
 @file
 @internalComponent
 @released
*/

#ifndef SRASERVER_H
#define SRASERVER_H


#include <e32base.h>
#include "sracommon.h"

using namespace StreamAccess;

// forward declarations
class CSraServer;
class CSraSession;
class CSraRightsObject;
class CSraProcessor;

class CShutdownTimer : public CTimer
/**
	An instance of this class is constructed with a delay period.
	If the object runs to completion, i.e. if it is not cancelled, then it stops
	the active scheduler, which has the effect of terminating the server.
 */
	{
public:
	static CShutdownTimer* NewL(TInt aDelay);
	void Restart();

private:
	CShutdownTimer(TInt aDelay);

	// implement CTimer
	virtual void RunL();

private:
	TInt iDelay;			///< Timer delay in microseconds.
	};


class CSraSession : public CSession2
/**
 	Represents a session for a client thread on the server-side of the reference agent.
 	A client thread can have multiple concurrent sessions with the reference agent server.
 */
	{
	friend class CSraProcessor;
public:
	static CSraSession* NewL();
	~CSraSession();
	void CreateL();
	
	// implement CSession2
	virtual void ServiceL(const RMessage2& aMessage);
	// override CSession2
	virtual void ServiceError(const RMessage2& aMessage, TInt aError);
	
private:
	CSraSession();
	CSraServer* GetServerHandle();
	
	void GetAttributeL(const RMessage2& aMessage);
	void GetStringAttributeSizeL(const RMessage2& aMessage);
	void GetStringAttributeDataL(const RMessage2& aMessage);
	void GetPostDeliveryRightsL(const RMessage2& aMessage);
	void SetKeyStreamSinkL(const RMessage2& aMessage);
	void SetSdpMediaFieldL(const RMessage2& aMessage);
	void SetSdpDocumentL(const RMessage2& aMessage);
	
	void FindAndLoadRightsObjectL(const TDesC8& aCid);
	void VerifyRoL();
	void StartProcessorL();
	
private:
	CSraProcessor* iProcessor;
	CKeyStreamSink* iKeyStreamSink;
	CSraRightsObject* iRo;
#ifdef INTERNALLY_ENABLE_UPWARD_DEPENDENCY
	CSdpMediaField* iSdp;
	CSdpDocument* iSdpDoc;
#endif
	/**
	 A handle to a mutex which is used to signal the client that the key has been implemented. 
	 Not necessary in real-life agents and is present here only for testing.
	 */
	RMutex iMutex;
	};
	
	
class CSraServer : public CPolicyServer
/**
	The reference agent server object allocates sessions.	
	It also uses a shutdown timer to stop the server when 
	there have been no open sessions for a set period.
 */
	{
	friend class CSraSession;
public:
	static CSraServer* NewLC();
	~CSraServer();
	
private:
	CSraServer();
	void ConstructL();
	void AddSession();
	void RemoveSession();
	// implement CServer2
	virtual CSession2* NewSessionL(const TVersion& aVersion, const RMessage2& aMessage) const;

private:
	CShutdownTimer* iShutdownTimer;
	const TVersion iVersion;
	/** Number of open sessions.  Used to start and cancel the shutdown timer. */
	TInt iSessionCount;
	/** File server handle. */
	RFs iFs;
	};


/**
	The server is panicked with this category when it detects an invalid state.
 */
_LIT(KSraServerPanicCat, "SRA-Server");

/** The mime type of the post-acquisition rights object file. */
_LIT8(KPostAcquisitionRoMimeType,"application/x-sra.drm.postacqrights");

/** The mime type of the post-acquisition rights object file. */
_LIT8(KPostAcquisitionContentMimeType,"application/x-sra.drm.postacqcontent");

/** The content Id of the post-acquisition rights object file. */
_LIT8(KPostAcquisitionCid,"SamplePostAcquisitionCid");

/** The private folder of the Streaming Reference Agent. */
_LIT(KSraPrivateFolder,"!:\\private\\10285a1c\\");

/** 
 	Mutex name used to synchronize the reference agent with the test harness.
 	@see CSraSession::iMutex
 */
_LIT(KSraMutexName, "MutexBtwTestHarnessAndRefAgent");

#endif