// sms.cpp
// 
// Copyright (c) 2008 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#include "sms.h"

CCmdSms* CCmdSms::NewLC()
	{
	CCmdSms* self = new (ELeave) CCmdSms();
	CleanupStack::PushL(self);
	self->BaseConstructL();
	return self;
	}

CCmdSms::~CCmdSms()
	{
	delete iCompletionCallBack;
	delete iWatch;
	delete iSendMsg;
	delete iMsgToSend;
	delete iDestination;
	delete iMessageFromStdin;
	iMatchStrings.ResetAndDestroy();
	}

CCmdSms::CCmdSms():
CCommandBase(CCommandBase::EManualComplete)
	{
	}

const TDesC& CCmdSms::Name() const
	{
	_LIT(KName, "sms");	
	return KName;
	}

//
// CCmdSms::DoRunL
//
void CCmdSms::DoRunL()
	{
	iCompletionCallBack = new(ELeave) CAsyncCallBack(TCallBack(CompletionCallBack, this), CActive::EPriorityStandard);

	switch (iOperation)
		{
	case ESend:
			{
			if (!iDestination)
				{
				LeaveIfErr(KErrArgument, _L("Option --destination not specified for send."));
				}
			if (!iMsgToSend)
				{
				iMessageFromStdin = CTextBuffer::NewL(160);
				Stdin().SetReadMode(RIoReadHandle::EFull);
				TBuf<0x100> buf;
				while (Stdin().Read(buf) == KErrNone)
					{
					iMessageFromStdin->AppendL(buf);
					}
				
				iSendMsg = CSmsSender::NewL(FsL(), *this, iMessageFromStdin->Descriptor(), *iDestination);
				}
			else
				{
				iSendMsg = CSmsSender::NewL(FsL(), *this, *iMsgToSend, *iDestination);
				}
			iSendMsg->StartL();
			}
		break;
	case EReceive:
			{
			FsL(); // So that CSmsWatcher can call Fs() if it needs to
			iWatch = CSmsWatcher::NewL(*this);
			iWatch->WaitForMessage();
			}
		break;
		};
	}

void CCmdSms::ArgumentsL(RCommandArgumentList& aArguments)
	{
	aArguments.AppendEnumL((TInt&)iOperation, _L("command"));
	aArguments.AppendStringL(iMsgToSend, _L("message"));
	}

//
// CCmdSms::OptionsL
//
void CCmdSms::OptionsL(RCommandOptionList& aOptions)
	{
	// send sms options
	_LIT(KOptDestination, "destination");
	aOptions.AppendStringL(iDestination, KOptDestination);
	
	// receive sms options
	_LIT(KOptDebug, "no-delete");
	aOptions.AppendBoolL(iDebug, KOptDebug);
	
	_LIT(KOptMatch, "match");
	aOptions.AppendStringL(iMatchStrings, KOptMatch);
	}

//
// CCmdSms::SendComplete
// up-call from the underlying smssender to indicate
// it has finished its task
//
void CCmdSms::SendComplete(TInt aError)
	{
	EventsFinished(aError);
	}

//
// CCmdSms::EventsFinished
// up-call from the underlying smswatcher to indicate
// it has finished its task(s)
//
void CCmdSms::EventsFinished(const TInt aError)
	{
	iCompletionError = aError;
	iCompletionCallBack->CallBack();
	}

//
// CCmdSms::CompletionCallBack
// static function called in the event the cmd has finished executing
// 
TInt CCmdSms::CompletionCallBack(TAny* aEvent)
	{
	CCmdSms* self = static_cast<CCmdSms*>(aEvent);
	self->Cleanup();
	return KErrNone;
	}

//
// CCmdSms::Cleanup
// 
void CCmdSms::Cleanup()
	{
	if (iCompletionError)
		PrintError(iCompletionError, _L("amsms.exe failure"));
	else
		{
		if (iWatch)
			{
			// dump any underlying messages (if any!)
			const TDesC& msg = iWatch->Message();
			if (msg.Length() > 0)
				Printf(_L("Message received: \r\n"), &msg); // dump the message to stdout
			}
		}
	// complete the fshell command
	Complete(iCompletionError);
	}

EXE_BOILER_PLATE(CCmdSms);