// 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:

//

#include <e32std.h>

#include <e32base.h>

#include <msventry.h>

#include <smutset.h>

#include <gsmubuf.h>

#include <smsulog.h>

#include <biodb.h>

#include <smuthdr.h>

#include "SMSRecipientSend.h"

#include "SMSSSEND.H"

#include "SMSSPAN.H"

#include <smsulog.h>

#include <logwraplimits.h>

CSmsRecipientSend::~CSmsRecipientSend()

	{

	delete iLogger;

	if (iSocket.SubSessionHandle())

		{

		iSocket.Close();

		}

	if (iSession.Handle())

		{

		iSession.Close();

		}

	}

void CSmsRecipientSend::Start(TRequestStatus& aStatus, const TMsvEntry& aEntry, CSmsHeader& aHeader, CSmsNumber& aRecipient)

	{

	__ASSERT_DEBUG(iState==ESmsRecipientSendWaiting,Panic(KSmssPanicUnexpectedState));

	Queue(aStatus);

	iEntry		= aEntry;

	iHeader		= &aHeader;

	iRecipient	= &aRecipient;

	TRAPD(err, StartL());

	if (err)

		Complete(err);

	}

CSmsRecipientSend::CSmsRecipientSend(TSmsProgress& aProgress, RFs& aFs, CMsvServerEntry& aServerEntry)

:	CSmssActive(aFs, aServerEntry, KSmsSessionPriority),

	iProgress(aProgress),

	iState(ESmsRecipientSendWaiting)

	{

	CActiveScheduler::Add(this);

	}

void CSmsRecipientSend::ConstructL()

	{

	iLogger = CSmsEventLogger::NewL(iFs);

	}

void CSmsRecipientSend::DoRunL()		

	{

	switch (iState)

		{

		case ESmsRecipientSendGetLogEvent:

			{

			if (iLogger->iStatus == KErrNone)

				{

				//no log error

				ChangeLogEvent();

				}

			else 

				{

				//Log error has occured

				if (-(iLogger->iStatus.Int()) == KErrNotFound)

					{

					AddLogEvent();

					}

				else

					{

					SendMessageL();

					}

				}

			break;

			}

		case ESmsRecipientSendAddLogEvent:

			{

			TLogId logId = KLogNullId;

			if (iLogger->iStatus == KErrNone)

				{

				//No log error has occured

				logId = iLogger->Event().Id();

				}

			iHeader->Message().SetLogServerId(logId);

			iRecipient->SetLogId(logId);

			//do not break here...

			}

		case ESmsRecipientSendChangeLogEvent:

			{

			SendMessageL();

			break;

			}

		case ESmsRecipientSendSendingMessage:

			{

			iState = ESmsRecipientSendWaiting;

			break;

			}

		case ESmsRecipientSendWaiting:

		default:

			Panic(KSmssPanicUnexpectedState);

		}

	}

void CSmsRecipientSend::DoComplete(TInt& aStatus)

	{

	//Set the state to waiting

	iState		= ESmsRecipientSendWaiting;

	iHeader		= NULL;

	iRecipient	= NULL;

	iEntry		= TMsvEntry();

	iProgress.iError = aStatus;

	aStatus = KErrNone;

	SMSSLOG(FLogFormat(_L8("CSmsRecipientSend completed with %d"), iProgress.iError));

	}

void CSmsRecipientSend::GetDefaultSendBearerL(TInt aBioType, TBioMsgIdType aBearer, TBioMsgId& rBioMsgId) const

	{

	CBIODatabase* bdb = CBIODatabase::NewL(iFs);

	CleanupStack::PushL(bdb);

	TInt index = 0;

	TUid uid;

	uid.iUid = aBioType;

	bdb->GetBioIndexWithMsgIDL(uid, index); //leaves with KErrNotFound if aBioType does not exist in bdb

	const CArrayFix<TBioMsgId>* bioIDs = bdb->BIOEntryLC(index);

	const TInt count = bioIDs->Count();

	TBool found = EFalse;

	for (TInt i = 0; !found && i < count; i++) //order important

		{

		rBioMsgId = bioIDs->At(i);

		found = (rBioMsgId.iType == aBearer && AcceptBioMsgId(rBioMsgId));

		}

	CleanupStack::PopAndDestroy(2); //bdb, bioIDs

	if (!found)

		User::Leave(KErrNotFound);

	}

TInt CSmsRecipientSend::AcceptBioType(TInt aBioType, TBioMsgIdType aBearer) const

	{

	TBioMsgId bioMsgId;

	TRAPD(err, GetDefaultSendBearerL(aBioType, aBearer, bioMsgId));

	return err;

	}

void CSmsRecipientSend::GetLogEvent()

	{

	TLogId id = iRecipient->LogId();

	iHeader->Message().SetLogServerId(id);

	iLogger->GetEvent(iStatus, id);

	SetActive();

	iState = ESmsRecipientSendGetLogEvent;

	}

void CSmsRecipientSend::AddLogEvent()

	{

	TInt logStatus = R_LOG_DEL_NONE;

	iHeader->Message().SetLogServerId(KLogNullId);

	TLogSmsPduData data;

	// Initialise the data members

	data.iType		= 0;

	data.iTotal		= 0;

	data.iSent		= 0;

	data.iDelivered	= 0;

	data.iFailed	= 0;

	data.iReceived	= 0;

	iLogger->AddEvent(iStatus, iHeader->Message(), data, &logStatus);

	SetActive();

	iState = ESmsRecipientSendAddLogEvent;

	}

void CSmsRecipientSend::ChangeLogEvent()

	{

	TInt logStatus = R_LOG_DEL_NONE;

	TLogSmsPduData data;

	data.iType		= 0;

	data.iTotal		= 0;

	data.iSent		= 0;

	data.iDelivered	= 0;

	data.iFailed	= 0;

	data.iReceived	= 0;

	iLogger->ChangeEvent(iStatus, iHeader->Message(), data, &logStatus);

	SetActive();

	iState = ESmsRecipientSendChangeLogEvent;

	}

void CSmsRecipientSend::DoSmssCancel()

	{

	switch (iState)

		{

		case ESmsRecipientSendGetLogEvent:

		case ESmsRecipientSendAddLogEvent:

		case ESmsRecipientSendChangeLogEvent:

			SMSSLOG(FLogFormat(_L8("CSmsRecipientSend::DoSmssCancel() cancelling logging for msg %d"), iEntry.Id()));

			iLogger->Cancel();

			break;

		case ESmsRecipientSendSendingMessage:

			DoCancelSendingMessage();

			break;

		default:

			break;

		}

	}