// 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:
// @file atsmsstorewrite.cpp
// This contains CAtSmsStoreWrite which is used to write sms message
// 

//system include 
#include <ctsy/ltsy/cctsydispatchercallback.h>

//user include
#include "atsmsstorewrite.h"
#include "mslogger.h"
#include "atmanager.h"
#include "commengine.h"
#include "smsatutil.h"

//constant defination
_LIT8(KCMGWResponseString,"+CMGW:");
_LIT8(KSmsWriteLengthCommand,"AT+CMGW = %d\r");
_LIT8(KDefaultSCA,"00");
_LIT8(KSmsEnterPduResponse,">");
const TInt KLtsyOnePause = 100000;   //0.1s

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::CAtSmsStoreWrite
// other items were commented in a header
// ---------------------------------------------------------------------------
CAtSmsStoreWrite::CAtSmsStoreWrite(CGlobalPhonemanager& aGloblePhone, 
                                   CCtsyDispatcherCallback& aCtsyDispatcherCallback)
                                   :CAtCommandBase(aGloblePhone,aCtsyDispatcherCallback)
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::CAtSmsStoreWrite called"));
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::~CAtSmsStoreWrite
// other items were commented in a header
// ---------------------------------------------------------------------------
CAtSmsStoreWrite::~CAtSmsStoreWrite()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::~CAtSmsStoreWrite called"));
	delete iCallbackTimer;
	iCallbackTimer = NULL;
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::NewLC
// other items were commented in a header
// ---------------------------------------------------------------------------
CAtSmsStoreWrite* CAtSmsStoreWrite::NewLC(CGlobalPhonemanager& aGloblePhone, 
                                          CCtsyDispatcherCallback& aCtsyDispatcherCallback)
	{
	CAtSmsStoreWrite* self = new (ELeave)CAtSmsStoreWrite(aGloblePhone, 
                                                          aCtsyDispatcherCallback);
	CleanupStack::PushL(self);
	self->ConstructL();
	return self;
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::NewL
// other items were commented in a header
// ---------------------------------------------------------------------------
CAtSmsStoreWrite* CAtSmsStoreWrite::NewL(CGlobalPhonemanager& aGloblePhone, 
                                         CCtsyDispatcherCallback& aCtsyDispatcherCallback)
	{
	CAtSmsStoreWrite* self=CAtSmsStoreWrite::NewLC(aGloblePhone, 
                                                   aCtsyDispatcherCallback);
	CleanupStack::Pop(self);
	return self;
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::ConstructL
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::ConstructL()
	{
	CAtCommandBase::ConstructL();
	//Create Timer
	iCallbackTimer = CCallbackTimer::NewL(*this);
	//set writing timeout
	iWriteTimeOut = KLtsyDefaultWriteTimeOut;
	AddExpectStringL(KSmsEnterPduResponse);
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::SeGsmSmsEntry
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::SeGsmSmsEntry(RMobileSmsStore::TMobileGsmSmsEntryV1 aMobileGsmEntry)
	{
	iMobileGsmEntry = aMobileGsmEntry;
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::StartRequest
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::StartRequest()
	{
	ExecuteCommand();
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::ExecuteCommand
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::ExecuteCommand()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::ExecuteCommand callded"));
	WriteMessage();
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::WriteMessage
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::WriteMessage()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::WriteMessage callded"));
	iTxBuffer.Zero();
	
	RMobilePhone::TMobileAddress  msgSca = iMobileGsmEntry.iServiceCentre;
	if( msgSca.iTelNumber.Length()!=0 )
		{
		//Here is a SCA
		TInt ret = SmsAtUtil::AppendAddressToAscii(iMsgDataAscii,msgSca);
		if( ret!=KErrNone )
			{
			BeginTimer();
			iCallbackVal = ret;
			return;
			}
		}
	else 
		{
		//Here is no SCA,usign default SCA
		iMsgDataAscii.Append(KDefaultSCA);
		}
	
	const TInt msgDataAsciiLen(iMsgDataAscii.Length());
	// Convert PDU to ASCII
	SmsAtUtil::AppendDataToAscii(iMsgDataAscii,iMobileGsmEntry.iMsgData);
	iState = ESetPDULengthComplete;
	StartWritingPduLength();	
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::StartWritingPduLength
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::StartWritingPduLength()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::StartWritingPduLength called"));
	TInt pduLen = iMobileGsmEntry.iMsgData.Length();
	iTxBuffer.Zero();
	iTxBuffer.Format(KSmsWriteLengthCommand,pduLen);
	ClearBuffer();
	iPhoneGlobals.iAtManager->SetSolicitedAtCommand(this);
	iPhoneGlobals.iCommEngine->CommWrite(iTxBuffer);	
	StartTimer(iWriteTimeOut);
	}


// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::StartWritingPdu
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::StartWritingPdu()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::StartWritingPdu called"));
	iTxBuffer.Zero();
	iTxBuffer.Append(iMsgDataAscii);
	iTxBuffer.Append(KLtsyCtrlZChar);
	ClearBuffer();
	iPhoneGlobals.iAtManager->SetSolicitedAtCommand(this);
	iPhoneGlobals.iCommEngine->CommWrite(iTxBuffer);	
	StartTimer(iWriteTimeOut);
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::EventSignal
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::EventSignal(TAtEventSource aEventSource, TInt aStatus)
	{
	LOGTEXT3(_L8("CAtSmsStoreWrite::EventSignal aStatus=%D iSource=%D"),aStatus,aEventSource);
		
	if(aStatus == KErrNone)
		{
		if((aEventSource == EWriteCompletion))
			{
			LOGTEXT(_L8("CAtSmsStoreWrite::EventSignal,EWriteCompletion!"));
			return;
			}
		else
			{
			if( iState == ESetPDULengthComplete )
				{
	            if(iError==KErrNone)
	            	{
			    	iState = EWritePDUComplete;
			    	Complete();
			    	StartWritingPdu();
			    	return;     
	            	}
				}
			}
		aStatus = iError;
		}
	Complete();
	iPhoneGlobals.iEventSignalActive = EFalse;
	iCtsyDispatcherCallback.CallbackPhonebookSmsStoreWriteEntryComp(aStatus,iLocation,EFalse);
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::ParseResponseL
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::ParseResponseL(const TDesC8& /*aResponseBuf*/)
	{
    LOGTEXT(_L8("CAtSmsStoreWrite::ParseResponseL called!"));
    if(iState == ESetPDULengthComplete) 
	    {
   	    if(CurrentLine().MatchF(KSmsEnterPduResponse) != KErrNotFound)
	    	{
	    	iError = KErrNone;
	    	}
	    else
	    	{
	    	iError = KErrNotFound;
	    	}
	    }
    else
    	{
	    iError = KErrNone;	
	    TPtrC8 responseBuf;
	    responseBuf.Set(Buffer());
		TInt pos = responseBuf.FindF(KCMGWResponseString);
		if (pos == KErrNotFound)
			{
			LOGTEXT(_L8("CAtSmsStoreWrite::ParseResponseL\tError - Cannot find '+CMGW:' string"));
			iError = KErrNotFound;
			return;
			}
		pos += KCMGWResponseString().Length();
		//skip a "space" start
		while(!(TChar(responseBuf[pos]).IsDigit()))
			{
			++pos;
			}
		// Place the message reference number into buffer 
		//(ie: everything after +CMGW: string)
		TInt refPos = responseBuf.Length()-pos;
		responseBuf.Set(responseBuf.Right(refPos));
		
		
		TLex8 lex(responseBuf);
		TUint16 val;
		TInt ret = lex.Val(val,EDecimal);
		if(ret != KErrNone)
			{
			iError = ret;
			return;
			}
		iLocation = val;
		LOGTEXT2(_L8("CAtSmsStoreWrite::ParseResponseL write index =%d"),iLocation);
    	}
	}


// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::BeginTimer
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::BeginTimer()
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::BeginTimer() called"));	
	
    if (iCallbackTimer->IsActive())
    	{
    	iCallbackTimer->Cancel();
    	}
	iCallbackTimer->After(KLtsyOnePause);	
	}

// ---------------------------------------------------------------------------
// CAtSmsStoreWrite::TimerRun
// other items were commented in a header
// ---------------------------------------------------------------------------
void CAtSmsStoreWrite::TimerRun(TInt aError)
	{
	LOGTEXT(_L8("CAtSmsStoreWrite::TimerRun() called"));
	if(aError == KErrNone)
		{
		Complete();
		iPhoneGlobals.iEventSignalActive = EFalse;
		iCtsyDispatcherCallback.CallbackPhonebookSmsStoreWriteEntryComp(
				                iCallbackVal,iLocation,EFalse);
		
		}
	}

//End of file