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

/**
 @file
 @internalAll 
*/

#if !defined (__SMSPSTOR_H__)
#define __SMSPSTOR_H__

#include "gsmustor.h"
#include <logwrap.h>

/**
 *  @internalComponent
 */
_LIT(KReassemblyStoreName,"smsreast.dat");	//reassembly store name
const TInt KReassemblyStoreUidValue=0x1000089e;
const TUid KReassemblyStoreUid={KReassemblyStoreUidValue};  //  Used for second uid of SAR stores

/**
 *  @internalComponent
 */
_LIT(KSegmentationStoreName,"smssegst.dat");	//segmentation store name
const TInt KSegmentationStoreUidValue=0x1000089f;
const TUid KSegmentationStoreUid={KSegmentationStoreUidValue};  //  Used for second uid of SAR stores
const TInt KDefaultMaxmumNumberOfMessagesInSegmentationStore = 1000; //<Maximum number of messages in segmentation store

class CSmsMessage;
class TSmsAddr;
class TGsmSms;

//  TSAREntry fields for the reassembly store

//  Reference - concatenation reference
//  Total - total number of PDUs in SMS message
//  Count - number of PDUs received
//  Data1 - DCS bits7to4 and min and max IEI
//  Data2 - log server id
//  Data3 - SMS PDU type
//  Data4 - Storage
//  Description1 - first 32 characters from buffer
//  Description2 - original address
//  Time - time on SMS message

/**
 *  @internalComponent
 */
class CSmsReassemblyStore : public CSARStore
	{
public:
	static CSmsReassemblyStore* NewL(RFs& aFs);
	~CSmsReassemblyStore();

	void MatchPDUToExistingMessage(const CSmsMessage& aSmsMessage, TInt& aIndex);
	void UpdateExistingMessageL(const CSmsMessage& aSmsMessage,
								const TGsmSms& aGsmSms, TInt aIndex,
								TBool& aComplete,
								TBool& aDuplicateMsgRef,
								TBool& aDuplicateSlot);
	
	void NewMessagePDUL(TInt& aIndex,CSmsMessage& aSmsMessage,const TGsmSms& aGsmSms);
	void GetMessageL(TInt aIndex,CSmsMessage& aSmsMessage);
	TBool FindMessageL(const CSmsMessage& aSmsMessage, TBool aPassed, TInt& aIndex);
	void  SetPassedToClientL(TInt aIndex, TBool aPassed);
	TBool PassedToClient(TInt aIndex) const;
	void UpdateLogServerIdL(TInt aIndex, TLogId aLogServerId);
	void OpenStoreL();

private:
	void InternalizeEntryL(const TStreamId& aStreamId,CSmsMessage& aSmsMessage,CArrayFix<TInt>& aIndexArray,CArrayFix<TGsmSms>& aSmsArray);
	void ExternalizeEntryL(TStreamId& aStreamId,const CSmsMessage& aSmsMessage,const CArrayFix<TInt>& aIndexArray,const CArrayFix<TGsmSms>& aSmsArray);

	static void PopulateEntry(TSmsReassemblyEntry& aEntry,const CSmsMessage& aSmsMessage,TInt aNumSmss);
	void CreateEntryL(CSmsMessage& aSmsMessage,const CArrayFix<TInt>& aIndexArray,const CArrayFix<TGsmSms>& aSmsArray);

private:
	CSmsReassemblyStore(RFs& aFs);
	void ConstructL();

	TTime iLastReceivedTime;
	TTime iLastRealTime;
	TFileName iFullPathBuf;
	};

//  TSAREntry fields for the segmentation store

//  Reference - concatenation reference
//  Total - total number of PDUs in SMS message
//  Count - number of PDUs sent
//  Data1 - total PDUs delivered<<16 and failed
//  Data2 - log server id
//  Data3 - validity period
//  Data4 - type and min and max message reference
//  Description1 - first 32 characters from buffer
//  Description2 - original address
//  Time - time on SMS message


/**
 *  @internalComponent
 */

class CSmsSegmentationStore : public CSARStore
	{
public:
	enum
		{
		ENullStatus=0x100,
		EStatusComplete=0x00
		};

	/**
	 *  @internalComponent
	 */
	class TSmsSegmentationStoreRefStatus
		{
		public:
			inline TSmsSegmentationStoreRefStatus(TInt aRef=0, TInt aStatus=ENullStatus);
			static TInt Compare(const TSmsSegmentationStoreRefStatus& aLeft, const TSmsSegmentationStoreRefStatus& aRight);
			void InternalizeL(RReadStream& aStream);
			void ExternalizeL(RWriteStream& aStream) const;
			inline TInt Reference() const;
			inline TInt Status() const;
			inline void SetStatus(TInt aStatus);

		private:

			TInt iReference;	//< Message reference number
			TInt iStatus;		//< Status for this message reference
		};

	/**
	 *  @internalComponent
	 */
	class RSmsSegmentationStoreRefStatusArray : public RArray<TSmsSegmentationStoreRefStatus>
		{
		public:
			inline RSmsSegmentationStoreRefStatusArray();
			void InsertL(const TSmsSegmentationStoreRefStatus& aRefStatus);
			TInt Find(const TSmsSegmentationStoreRefStatus& aRefStatus) const;
			void CopyL(const RSmsSegmentationStoreRefStatusArray& aOther);
			void ResetAllStatus(TInt aStatus=ENullStatus);

			void InternalizeL(RReadStream& aStream);
			void ExternalizeL(RWriteStream& aStream) const;
		};

public:
	static CSmsSegmentationStore* NewL(RFs& aFs);
	~CSmsSegmentationStore();

	TInt Next8BitReferenceL();
	TInt Next16BitReferenceL();

	void AddSubmitL(const TSmsAddr& aSmsAddr,CSmsMessage& aSubmit);
	TBool AddCommandL(const TSmsAddr& aSmsAddr,const CSmsMessage& aCommand, RSmsSegmentationStoreRefStatusArray& aRefStatus);
	TBool AddReferenceL(const CSmsMessage& aSmsMessage,TInt aReference);
	TBool AddReferenceStatusPairL(const CSmsMessage& aSmsMessage,TInt aReference, TUint aSegmentSequenceNumber);
	TBool AddStatusReportL(TInt& aIndex,TBool& aComplete,const CSmsMessage& aStatusReport);
	void GetMessageL(TInt aIndex,TSmsAddr& aSmsAddr,CSmsMessage& aSmsMessage, RSmsSegmentationStoreRefStatusArray& aRefStatus);

	inline static TBool IsPermanentStatus(TInt aStatus);
	TBool HasEntryWithLogIdL(TLogId,TInt&,TInt&);
	void OpenStoreL();

private:
	void InternalizeConcatenationReferencesL(const TStreamId& aStreamId,TInt& aReference8bit,TInt& aReference16bit);
	void ExternalizeConcatenationReferencesL(TStreamId& aStreamId,TInt aReference8bit,TInt aReference16bit);

	void InternalizeEntryL(const TStreamId& aStreamId,TSmsAddr& aSmsAddr,CSmsMessage& aSmsMessage, RSmsSegmentationStoreRefStatusArray& aRefStatus);
	void ExternalizeEntryL(TStreamId& aStreamId,const TSmsAddr& aSmsAddr,const CSmsMessage& aSmsMessage, const RSmsSegmentationStoreRefStatusArray& aRefStatus);

	static void PopulateEntry(TSmsSegmentationEntry& aEntry,/*const TSmsAddr& aSmsAddr,*/const CSmsMessage& aSmsMessage, const RSmsSegmentationStoreRefStatusArray& aRefStatus);

	static TBool StatusArrayComplete(const RSmsSegmentationStoreRefStatusArray& aRefStatus, TSAREntry& aEntry);

	CSmsSegmentationStore(RFs& aFs);
	void ConstructL();
private:
	TFileName iFullPathBuf;
	};

#include "smspstor.inl"

#endif // !defined __SMSPSTOR_H__