/*
* Copyright (c) 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 <lbsposition.h>
#include "clbsareapositionersubsession.h"
#include "lbslocmonitorserverdata.h"
#include "clbslocmonitorutils.h"
#include "lbsdevloggermacros.h"


//-------------------------------------------------------------------------------
// Methods called by the Server Framework for subsession creation and destruction
// ------------------------------------------------------------------------------

//
// Called by the Server Framework when the subsession is
// closed by the client or otherwise destroyed (i.e. if the
// owning session is closed).
// 
void CLbsAreaPositionerSubsession::VirtualRelease()
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::VirtualRelease()");
	delete this;
	}

// Called by the server framework after creating this object
// in CSubSessionBase::GetImplL
void CLbsAreaPositionerSubsession::CreateSubSessionL(const RMessage2& aMessage, const CSecureServerBase* aServer)
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::CreateSubSessionL()");
	iLocMonitorServer = reinterpret_cast<const CLbsLocMonitorServer*>(aServer);
	
	// set ourselves as an observer of server destruction
	CLbsLocMonitorServer* server = const_cast<CLbsLocMonitorServer*>(iLocMonitorServer);
	server->SetLocMonServerDestructObserverL(*this);
	
	iSubsessionId.iSessionPtr = static_cast<CLbsLocMonitorSession*>(aMessage.Session());
	
	TInt subsessionId;
	TPckg<TInt> subsessionIdBuf(subsessionId);
	User::LeaveIfError(aMessage.Read(3, subsessionIdBuf));
	
	iSubsessionId.iSubsessionId = subsessionId;
	}

// Called by the Server Framework on sub-session closure
void CLbsAreaPositionerSubsession::CloseSubSession()
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::CloseSubSession()");
	
	// The server should not have been destroyed at this point
	__ASSERT_DEBUG(iLocMonitorServer, User::Invariant());
	// Release anything allocated in CreateSubSessionL.
    // remove ourselves as an observer of server destruction
    CLbsLocMonitorServer* server = const_cast<CLbsLocMonitorServer*>(iLocMonitorServer);    
    server->UnsetLocMonServerDestructObserver(*this); 
	}	


void CLbsAreaPositionerSubsession::DispatchL(const RMessage2& aMessage)
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::DispatchL()");
	switch(aMessage.Function())
		{
		case ESetLastKnownPosition:
			SetLastKnownPositionL(aMessage);
			break;
		case EGetLastKnownPosition:
		case EGetLastKnownPositionArea:
			GetPositionL(aMessage);
			break;
		case ECancelGetLastKnownPosition:
		case ECancelGetLastKnownPositionArea:
			CancelGetPositionL(aMessage);
			break;
		default:
			__ASSERT_DEBUG(EFalse, User::Invariant());
			break;
		}
	}
	
void CLbsAreaPositionerSubsession::DispatchError(const RMessage2& /*aMessage*/, TInt /*aError*/)
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::DispatchError()");
	// errors from DispatchL end up in here
	}

// -----------------------------------------------------------------------------
// Construction/Destruction methods not directly called by the Server framework
//------------------------------------------------------------------------------

CLbsAreaPositionerSubsession::CLbsAreaPositionerSubsession()
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::CLbsAreaPositionerSubsession()");
	}

CLbsAreaPositionerSubsession::~CLbsAreaPositionerSubsession()
	{
	LBSLOG(ELogP1,"->CLbsAreaPositionerSubsession::~CLbsAreaPositionerSubsession");		

	if(iLocMonitorServer)
	    {
        // Tell the DB reader that this subsession is being deleted
        // so that if there are any outanding requests from this session
        // they are terminated with KErrServerTerminated.
        iLocMonitorServer->ReadRequestHandler().ClientTerminated(iSubsessionId);
        // remove ourselves as an observer of server destruction
        CLbsLocMonitorServer* server = const_cast<CLbsLocMonitorServer*>(iLocMonitorServer);    
        server->UnsetLocMonServerDestructObserver(*this);        
	    }
	
	LBSLOG(ELogP1,"<-CLbsAreaPositionerSubsession::~CLbsAreaPositionerSubsession");
	}

CLbsAreaPositionerSubsession* CLbsAreaPositionerSubsession::NewL()
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::NewL()");
	CLbsAreaPositionerSubsession* self = new (ELeave) CLbsAreaPositionerSubsession;
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}

void CLbsAreaPositionerSubsession::ConstructL()
	{
	LBSLOG(ELogP1,"CLbsAreaPositionerSubsession::ConstructL()");
	// Nothing to do
	}

void CLbsAreaPositionerSubsession::LocMonServerDestructed()
    {
    iLocMonitorServer = NULL;
    }


//-------------------------------------------------------------------------
// 							Action methods
// (These method just relay the client request to a database writer or 
//  reader where requests of the same type are either serialized or  
// 	merged into a single call to the database)
//-------------------------------------------------------------------------

/*
Called when a a client (e.g. Location Server) has a position that wants to
add to the database.
*/
void CLbsAreaPositionerSubsession::SetLastKnownPositionL(const RMessage2& aMessage)
	{
	LBSLOG(ELogP1,"->CLbsAreaPositionerSubsession::SetLastKnownPositionL");

	// Read the position
	TPosition position;
	TPckg<TPosition> positionPkg(position);
	aMessage.ReadL(0, positionPkg, 0);
	
	// Complete the call 
	aMessage.Complete(KErrNone);
	
	// Pass the message on to the database writer
	iLocMonitorServer->ReadRequestHandler().StoreLastKnownPosition(position);

	LBSLOG(ELogP1,"<-CLbsAreaPositionerSubsession::SetLastKnownPositionL");
	}

void CLbsAreaPositionerSubsession::GetPositionL(const RMessage2& aMessage)
	{
	LBSLOG(ELogP1,"->CLbsAreaPositionerSubsession::GetPositionL");		
	
	iLocMonitorServer->ReadRequestHandler().PositionRequestL(aMessage);
	
	LBSLOG(ELogP1,"<-CLbsAreaPositionerSubsession::GetPositionL");	
	}
	

void CLbsAreaPositionerSubsession::CancelGetPositionL(const RMessage2& aMessage)
	{
	LBSLOG(ELogP1,"->CLbsAreaPositionerSubsession::CancelGetPositionL");		

	iLocMonitorServer->ReadRequestHandler().CancelPositionRequestL(aMessage);

	LBSLOG(ELogP1,"<-CLbsAreaPositionerSubsession::CancelGetPositionL");	
	}