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

//

#ifdef _DEBUG

#undef _MSG_NO_LOGGING

#endif

#include "smssactive.h"

#include <gsmubuf.h>

#include <msvstd.h>

#include <smutset.h>

#include <msventry.h>

#include <smuthdr.h>

#include "SMSSPAN.H"

#ifndef _MSG_NO_LOGGING

	#include <flogger.h>

	_LIT(KSmssLogFile, "Smss.txt");

	_LIT(KSmssLogDir, "Sms");

	const TInt KSmssLogMaxLength = KLogBufferSize - 22;

	/**

	Names for Multimode ETel sub-sessions

	*/

	_LIT(KETelMeSmsStore,"S13");

	_LIT(KETelIccSmsStore,"S14");

	_LIT(KETelCombinedSmsStore,"S15");

#endif

CSmssActive::CSmssActive(RFs& aFs, CMsvServerEntry& aServerEntry, TInt aPriority)

: CActive(aPriority), iFs(aFs), iServerEntry(aServerEntry)

	{

	}

CSmssActive::~CSmssActive()

	{

#ifndef _MSG_NO_LOGGING

	delete iLastLogFile;

	if (iFlogger.LogValid())

		iFlogger.CloseLog();

	iFlogger.Close();

#endif

	}

void CSmssActive::RequestComplete(TRequestStatus* aStatus, TInt aError, TBool aSetActive)

	{

	User::RequestComplete(aStatus, aError);

	if (aSetActive)

		{

		SetActive();

		}

	}

void CSmssActive::Queue(TRequestStatus& aStatus)

//

// call this last when an asynch operation has been requested

//

	{

	__ASSERT_DEBUG(iReport==NULL, Panic(KSmssPanicAlreadyActive));

	aStatus=KRequestPending;

	iReport=&aStatus;

	}

void CSmssActive::DoCancel()

//

// must be called at end of derived classes DoCancel()

//

	{

	DoSmssCancel();

	TInt result=KErrCancel;

	Complete(result);	// can be done safely as asynch reporting

	}

TInt CSmssActive::RunError(TInt aError)

	{

	Complete(aError);

	return KErrNone;

	}

void CSmssActive::RunL()

	{

	User::LeaveIfError(iStatus.Int()); //This will be traped by RunError().

	DoRunL();

	if (!IsActive())

		Complete(iStatus.Int());

	}

TInt CSmssActive::Complete(TInt aStatus)

	{

	if (iReport)

		{

		const TBool isCancelling = (aStatus == KErrCancel);

		DoComplete(aStatus);

		if (!IsActive() || isCancelling)

			{

			User::RequestComplete(iReport, aStatus);

			iReport = NULL;

			}

		}

	return aStatus;

	}

TBool CSmssActive::CanSendMessage(const TMsvEntry& aEntry) const

	{

	TBool retVal = ETrue;

	switch (aEntry.SendingState())

		{

		case KMsvSendStateSuspended:

		case KMsvSendStateSent:

		case KMsvSendStateNotApplicable:

			retVal = EFalse;

			break;

		default:

			break;

		}

	return retVal;

	}

TBool CSmssActive::CanSendMessageToRecipient(const TMsvEntry& aEntry, const CSmsNumber& aRcpt) const

	{

	return (aRcpt.Status() != CMsvRecipient::ESentSuccessfully) && CanSendMessage(aEntry);

	}

#ifndef _MSG_NO_LOGGING

TInt CSmssActive::FLogMessage(const TMsvEntry& aEntry, const CSmsMessage& aSmsMessage, TBioMsgIdType aBearer, const TDesC& aFile)

	{

	TRAPD(err, DoFLogMessageL(aEntry, aSmsMessage, aBearer, aFile));

	return err;

	}

void CSmssActive::DoFLogMessageL(const TMsvEntry& aEntry, const CSmsMessage& aSmsMessage, TBioMsgIdType aBearer, const TDesC& aFile)

	{

	if (!IsLogging(aFile))

		return;

	TBuf8<32> temp;

	TBuf16<32> temp1;

	TPtrC temp2;

	switch (aSmsMessage.Type())

		{

		case CSmsPDU::ESmsSubmit:

			temp = _L8("[Submit%d]");

			break;

		case CSmsPDU::ESmsDeliver:

			temp = _L8("[Deliver%d]");

			break;

		default:

			temp = _L8("[Message%d]");

			break;

		}

	FLogFormat(aFile, temp, aEntry.Id());

	TInt length = aSmsMessage.Buffer().Length();

	HBufC* hBuf = HBufC::NewLC(32 + length);

	TPtr buf(hBuf->Des());

	aSmsMessage.Buffer().Extract(buf, 0, length);

	buf.Insert(0, _L("Message= "));

	FLog(aFile, buf, EFalse);

	CleanupStack::PopAndDestroy(hBuf);

	hBuf = NULL;

	temp2.Set(aSmsMessage.ToFromAddress());

	FLogFormat(aFile, _L("Recipients= %S"), &temp2);

	temp2.Set(aSmsMessage.ServiceCenterAddress());

	FLogFormat(aFile, _L("SC= %S"), &temp2);

	FLogFormat(aFile, _L("BioUid= %d"), aEntry.iBioType);

	const CSmsPDU& pdu = aSmsMessage.SmsPDU();

	if (pdu.DataCodingSchemePresent())

		{

		temp.Zero();

		temp.Append(_L8("Encoding= "));

		switch (pdu.Alphabet())

			{

			case TSmsDataCodingScheme::ESmsAlphabet7Bit:

				temp.Append(_L8("7"));

				break;

			case TSmsDataCodingScheme::ESmsAlphabet8Bit:

				temp.Append(_L8("8"));

				break;

			case TSmsDataCodingScheme::ESmsAlphabetUCS2:

				temp.Append(_L8("16"));

				break;

			default:

				temp.Append(_L8("Unsupported"));

				break;

			}

		FLogFormat(aFile, temp);

		}

	if (aSmsMessage.Type() == CSmsPDU::ESmsSubmit)

		{

		temp.Zero();

		temp.Append(_L8("DeliveryReport= "));

		const CSmsSubmit& submit = (CSmsSubmit&) pdu;

		if (submit.StatusReportRequest())

			{

			temp.Append(_L8("YES"));

			}

		else

			{

			temp.Append(_L8("NO"));

			}

		FLogFormat(aFile, temp);

		}

	temp.Zero();

	temp.Append(_L("Bearer= "));

	switch (aBearer)

		{

		case EBioMsgIdNbs:

			temp.Append(_L("NBS"));

			break;

		case EBioMsgIdWap:

			temp.Append(_L("WAP"));

			break;

		case EBioMsgIdWapSecure:

			temp.Append(_L("WAPSE"));

			break;

		default:

			temp.Append(_L("UnSup"));

			break;

		}

	FLogFormat(aFile, temp);

	temp1.Zero();

	temp1.Append(_L("Storage= "));

	switch (aSmsMessage.Storage())

		{

		case CSmsMessage::ESmsSIMStorage:

			temp1.Append(KETelIccSmsStore);

			break;

		case CSmsMessage::ESmsPhoneStorage:

			temp1.Append(KETelMeSmsStore);

			break;

		case CSmsMessage::ESmsCombinedStorage:

			temp1.Append(KETelCombinedSmsStore);

			break;

		case CSmsMessage::ESmsNoStorage:

		default:

			temp1.Append(_L("NONE"));

		};

	FLogFormat(aFile, temp1);

	FLogFormat(aFile, KNullDesC);

	}

void CSmssActive::FLog(const TDesC& aFile, const TDesC& aInputLine, TBool aIgnoreLineBreaks)

	{

	if (!IsLogging(aFile))

		return;

	TPtrC str(aInputLine);

	TInt length = str.Length();

	if (aIgnoreLineBreaks)

		{

		//Ignore trailing spaces

		while (length--)

			{

			const TChar ch(str[length]);

			if (!ch.IsSpace())

				{

				break;

				}

			}

		length++;

		str.Set(aInputLine.Left(length));

		//Break the message up and print only 255 chars at a time

		TInt start = 0;

		while (start < length)

			{

			TPtrC buf(str.Mid(start, Min(KSmssLogMaxLength, length - start)));

			iFlogger.Write(buf);

			start += KSmssLogMaxLength;

			}

		}

	else

		{

		//Log each line in aInputLine individually

		while (length > 0)

			{

			TInt find = str.Locate('\n');

			if (find == KErrNotFound)

				{

				FLog(aFile, str, ETrue);

				break;

				}

			else

				{

				if (find == 0)

					FLog(aFile, KNullDesC, ETrue);

				else

					FLog(aFile, str.Left(find), ETrue);

				if (find < length - 1)

					str.Set(str.Mid(find + 1));

				else

					break;

				}

			length = str.Length();

			}

		}

	}

void CSmssActive::FLog(const TDesC& aInputLine, TBool aIgnoreLineBreaks)

	{

	FLog(KSmssLogFile, aInputLine, aIgnoreLineBreaks);

	}

void CSmssActive::FLogFormat(const TDesC& aFile, TRefByValue<const TDesC> aFormat, ...)

	{

	VA_LIST list;

	VA_START(list, aFormat);

	FLogFormat(aFile, aFormat, list);

	}

void CSmssActive::FLogFormat(const TDesC& aFile, TRefByValue<const TDesC> aFormat, VA_LIST& aList)

	{

	if (!IsLogging(aFile))

		return;

	iFlogger.WriteFormat(aFormat, aList);

	}

void CSmssActive::FLogFormat(TRefByValue<const TDesC> aFormat, ...)

	{

	VA_LIST list;

	VA_START(list, aFormat);

	FLogFormat(KSmssLogFile, aFormat, list);

	}

void CSmssActive::FLogFormat(const TDesC& aFile, TRefByValue<const TDesC8> aFormat, ...)

	{

	VA_LIST list;

	VA_START(list, aFormat);

	FLogFormat(aFile, aFormat, list);

	}

void CSmssActive::FLogFormat(const TDesC& aFile, TRefByValue<const TDesC8> aFormat, VA_LIST& aList)

	{

	if (!IsLogging(aFile))

		return;

	iFlogger.WriteFormat(aFormat, aList);

	}

void CSmssActive::FLogFormat(TRefByValue<const TDesC8> aFormat, ...)

	{

	VA_LIST list;

	VA_START(list, aFormat);

	FLogFormat(KSmssLogFile, aFormat, list);

	}

TBool CSmssActive::IsLogging(const TDesC& aFile)

	{

	return (ConstructFlogger(aFile) == KErrNone);

	}

TInt CSmssActive::ConstructFlogger(const TDesC& aFile)

	{

	TRAPD(err, DoConstructFloggerL(aFile));

	return err;

	}

void CSmssActive::DoConstructFloggerL(const TDesC& aFile)

	{

	if (iFlogger.Handle() == NULL)

		User::LeaveIfError(iFlogger.Connect());

	if (iLastLogFile == NULL || *iLastLogFile != aFile)

		{

		if (iFlogger.LogValid())

			iFlogger.CloseLog();

		delete iLastLogFile;

		iLastLogFile = NULL;

		iLastLogFile = aFile.AllocL();

		iFlogger.CreateLog(KSmssLogDir, aFile, EFileLoggingModeAppend);

		}

	if (!iFlogger.LogValid())

		User::Leave(KErrNotFound);

	}

#endif

void CSmssActive::ChangeEntryL(const TMsvEntry& aNewEntry)

 	{

 	__ASSERT_DEBUG(iServerEntry.Entry().Id() == aNewEntry.Id(), Panic(ESmssEntryNotSet));

 	if (!(aNewEntry == iServerEntry.Entry()))

 		User::LeaveIfError(iServerEntry.ChangeEntry(aNewEntry));

 	}

void CSmssActive::StoreHeaderL(const CSmsHeader& aNewHeader)

	{

 	CMsvStore* msvStore = iServerEntry.EditStoreL();

 	CleanupStack::PushL(msvStore);

 	aNewHeader.StoreL(*msvStore);

 	msvStore->CommitL();

 	CleanupStack::PopAndDestroy(msvStore);

 	}