// Copyright (c) 2006-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:
// Definition of assistance data channel component.
// 
//

/**
 @file
 @internalTechnology
 @released
*/

#ifndef AGPSCHANNEL_H_
#define AGPSCHANNEL_H_

#include <e32hashtab.h>
#include "lbscommoninternaldatatypes.h"
#include "lbsnetinternalapi.h"
#include "lbsassistancedatacacheapi.h"

#include "lbsagpsngmsgs.h"

//
// Asssitance Data Channel
//

/** Observer for the A-GPS interface
*/
class MAgpsObserver
	{
public:
	virtual void OnAssistanceDataRequest(TLbsAsistanceDataGroupInt aDataItemMask) = 0;
	virtual void OnSelfLocationRequest(const TLbsNetSessionIdInt& aSessionId, const TLbsNetPosRequestOptionsAssistanceInt& aOptions) = 0;
	virtual void OnSelfLocationCancel(const TLbsNetSessionIdInt& aSessionId, TInt aReason) = 0;
	virtual void OnSystemStatusAdvice(TBool aTracking) = 0;
	};

/** 
Buffers incoming assistance data msgs.
Used when a channel is busy.
*/
class RAssistanceDataMsgBuffer
	{
public:
	RAssistanceDataMsgBuffer();
	void OpenL();
	void Close();
	
	void Write(const TLbsNetAssistanceDataResponseMsg& aMsg);
	void Read(TLbsNetAssistanceDataResponseMsg& aMsg);
	TBool IsEmpty() const;
	
private:

private:
	class TBufferItem
		{
	public:
		TBufferItem();
		
		TBool iValid;
		TInt  iReason;
		};
	RArray<TBufferItem> iBuffer;
	TBool				iEmpty;
	TBufferItem iErrGeneric;
	};
	
/** Communicates with the AGPS manager over an internal API 
*/
class CAgpsChannel : public CActive, private MLbsNetChannelObserver
	{
public:
	static CAgpsChannel* NewL(MAgpsObserver& aObserver);
	~CAgpsChannel();
	
    void SendAssistanceDataResponse(TInt aError, 
    								TLbsAsistanceDataGroupInt aMask, 
    								const RLbsAssistanceDataBuilderSet& aData);
    void SendSessionComplete(TInt aReason, const TLbsNetSessionIdInt& aSessionId);

private:
	CAgpsChannel(MAgpsObserver& aObserver);
	void ConstructL();
	
	// from MLbsNetChannelObserver
	void ProcessNetChannelMessage(RLbsNetChannel::TLbsNetChannelId aChannelId, const TLbsNetInternalMsgBase& aMessage);
	
	// from CActive
	void RunL();
	void DoCancel();
	TInt RunError(TInt aError);

	// Helpers	
	void SetAssistanceDataCacheL(const RLbsAssistanceDataBuilderSet& aData);
	
private:
	TLbsNetSessionCompleteAgpsMsg iSessionCompleteMsgBuffer;
	TBool					      iSessionCompleteMsgValid;
	RAssistanceDataMsgBuffer      iAssistanceDataMsgBuffer;
	
	MAgpsObserver& 		 iObserver;
	RAssistanceDataCache iAssistanceDataCache;
	RLbsNetChannel 		 iAGPSChannel;
	};

#endif // AGPSCHANNEL_H_