// smsevent.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 "smsevent.h"
#include "sms.h"

_LIT(KInternationlDialDirectIndicator,	"+");

//
// CSmsEventBase
//
CSmsEventBase::CSmsEventBase(CCmdSms& aObserver):
CActive(CActive::EPriorityStandard), iObserver(aObserver)
	{
	CActiveScheduler::Add(this);
	}

//
// CSmsEventDial
//
CSmsEventDial* CSmsEventDial::NewL(CCmdSms& aObserver, RCall::TTelNumberC& aTelNumber)
	{
	CSmsEventDial* self = new (ELeave) CSmsEventDial(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL(aTelNumber);
	CleanupStack::Pop(self);
	return self;
	}

CSmsEventDial::CSmsEventDial(CCmdSms& aObserver):
CSmsEventBase(aObserver), iState(ESmsEventNetworkIdle)
	{
	}

CSmsEventDial::~CSmsEventDial()
	{
	Cancel();
	iTimeout.Cancel();
	iTimeout.Close();
	if (iCall.SubSessionHandle() > 0)
		iCall.Close(); // should also force a hangup on the call object if it's active
	if (iLine.SubSessionHandle() > 0)
		iLine.Close();
	if (iPhone.SubSessionHandle() > 0)
		iPhone.Close();
	if (iTelServer.Handle() > 0)
		iTelServer.Close();
	}

void CSmsEventDial::ConstructL(RCall::TTelNumberC& aTelNumber)
	{
	// timeout timer 
	iTimeout.CreateLocal();
	
	// capture the number to dial
	iNumber.iTypeOfNumber = RMobilePhone::ENationalNumber;
	iNumber.iNumberPlan = RMobilePhone::EIsdnNumberPlan;
	iNumber.iTelNumber.Copy(aTelNumber);
	
	// check if there's a '+' at the front of the number
	if (aTelNumber.MatchC(KInternationlDialDirectIndicator) == 0)
		iNumber.iTypeOfNumber = RMobilePhone::EInternationalNumber;
	
	// connect to ETel. Note we're assuming the TSY has been loaded already
	RTelServer::TPhoneInfo phoneInfo;
	User::LeaveIfError(iTelServer.Connect());
	User::LeaveIfError(iTelServer.GetPhoneInfo(0, phoneInfo));
	
	// open the first phone object
	User::LeaveIfError(iPhone.Open(iTelServer, phoneInfo.iName));
	
	// find the voice line & open it
	TInt lines = 0;
	RPhone::TLineInfo lineInfo;
	User::LeaveIfError(iPhone.EnumerateLines(lines));
	if (lines <= 0)
		User::Leave(KErrNotSupported);
	for (TInt ii = 0 ; ii < lines ; ii++)
		{
		User::LeaveIfError(iPhone.GetLineInfo(ii, lineInfo));
		if (lineInfo.iLineCapsFlags & RLine::KCapsVoice)
			{
			// found our voice line
			if (lineInfo.iStatus > RCall::EStatusIdle)
				User::Leave(KErrInUse);
			User::LeaveIfError(iLine.Open(iPhone, lineInfo.iName));
			break;
			}
		}
	if (iLine.SubSessionHandle() <= 0)
		User::Leave(KErrNotFound);
	
	// create a voice call (note it's not currently active)
	User::LeaveIfError(iCall.OpenNewCall(iLine, iCallName));
	}

//
// CSmsEventDial::StartL
// start the dial-out procedure, beginning
// with a check of the network, line/call status
//
void CSmsEventDial::StartL()
	{
	User::LeaveIfError(iLine.GetMobileLineStatus(iCallStatus));
	if (iCallStatus > RMobileCall::EStatusIdle)
		User::Leave(KErrInUse);
	
	// some product tsy implementations can't handle a dial request immediately following receiving an sms. so we wait a little bit..5 seconds in fact
	iTimeout.After(iStatus, 5000000);
	SetActive();
	iState = ESmsEventDial;
	}

void CSmsEventDial::RunL()
	{
	User::LeaveIfError(iStatus.Int()); // process the error elsewhere
	switch (iState)
		{
		case ESmsEventDial:
			{
			// dial the number
			iCall.Dial(iStatus, iNumber.iTelNumber);
			SetActive();
			iState = ESmsEventStatusChange;
			}
		break;
				
		case ESmsEventWatchStatus:
		case ESmsEventStatusChange:
			{
			User::LeaveIfError(iCall.GetMobileCallStatus(iCallStatus));
			if (iCallStatus > RMobileCall::EStatusIdle)
				{
				// keep the call going until it drops
				iCall.NotifyMobileCallStatusChange(iStatus, iCallStatus);
				SetActive();
				iState = ESmsEventWatchStatus;
				return;
				}
			}
		break;
		
		default:
		break;
		};
	}

//
// CSmsEventDial::RunError
// inform the observer we hit a prob. with execution of the dial state machine
//
TInt CSmsEventDial::RunError(TInt /*aError*/)
	{
	//TODO iObserver.EventComplete(aError); 
	return KErrNone;
	}

void CSmsEventDial::DoCancel()
	{
	switch (iState)
		{
		case ESmsEventDial:
			iTimeout.Cancel();
		break;
		
		case ESmsEventStatusChange:
			iCall.DialCancel();
		break;
		
		case ESmsEventWatchStatus:
			iCall.NotifyStatusChangeCancel();			
		break;
		
		default:
		break;
		};
	}

CSmsShellCommand* CSmsShellCommand::NewL(CCmdSms& aObserver, const TDesC& aCommandText, const TDesC& aSenderAddress)
	{
	CSmsShellCommand* self = new(ELeave) CSmsShellCommand(aObserver);
	CleanupStack::PushL(self);
	self->ConstructL(aCommandText, aSenderAddress);
	CleanupStack::Pop(self);
	return self;
	}

CSmsShellCommand::CSmsShellCommand(CCmdSms& aObserver)
	: CSmsEventBase(aObserver)
	{
	}

void CSmsShellCommand::ConstructL(const TDesC& aCommandText, const TDesC& aSenderAddress)
	{
	iSmsSender.CreateL(aSenderAddress);
	// Set up environment for script
	iScriptEnv = CEnvironment::NewL(iObserver.Env());
	_LIT(KSmsSenderEnvironmentVariable, "SMS_SENDER");
	iScriptEnv->SetL(KSmsSenderEnvironmentVariable, iSmsSender);

	const TDesC* scriptName = NULL;
	_LIT(KFshellName, "C:\\shared\\fshellscript%d.script");
	_LIT(KPerlName, "C:\\shared\\perlscript%d.pl");
	if (aCommandText.MatchF(_L("#!fshell*")) == 0)
		{
		iExeName = _L("fshell.exe");
		scriptName = &KFshellName;
		}
	else if (aCommandText.MatchF(_L("#!perl*")) == 0)
		{
		iExeName = _L("perl.exe");
		scriptName = &KPerlName;
		}
	else
		{
		User::Leave(KErrArgument);
		}	
	
	RBuf8 buf;
	CleanupClosePushL(buf);
	buf.CreateL(aCommandText.Length());
	buf.Copy(aCommandText);

	RFile scriptFile;
	CleanupClosePushL(scriptFile);
	TInt nonce = 0;
	iObserver.Fs().MkDirAll(*scriptName);
	TInt err = KErrNone;
	do {
		iScriptFile.Format(*scriptName, nonce);
		nonce++;
		err = scriptFile.Create(iObserver.Fs(), iScriptFile, EFileShareAny|EFileWrite);
		} while (err == KErrAlreadyExists);
	User::LeaveIfError(scriptFile.Write(buf));
	CleanupStack::PopAndDestroy(2, &buf);
	}

void CSmsShellCommand::StartL()
	{
	iProcess.CreateL(iExeName, iScriptFile, iObserver.IoSession(), iObserver.Stdin(), iObserver.Stdout(), iObserver.Stderr(), *iScriptEnv);
	iProcess.Run(iStatus);
	SetActive();
	}

void CSmsShellCommand::DoCancel()
	{
	iProcess.Process().LogonCancel(iStatus);
	}

CSmsShellCommand::~CSmsShellCommand()
	{
	Cancel();
	iProcess.Close();
	if (!iObserver.Debug())
		{
		iObserver.Fs().Delete(iScriptFile);
		}
	delete iScriptEnv;
	iSmsSender.Close();
	}

void CSmsShellCommand::RunL()
	{
	TExitType exitType = iProcess.Process().ExitType();
	TInt exitReason = iProcess.Process().ExitReason();
	TBool ok = exitType == EExitKill && exitReason == 0;
	if (ok)
		{
		iObserver.Printf(_L("Script from %S completed ok.\r\n"), &iSmsSender);
		}
	else
		{
		TInt err = exitReason;
		if (err >= 0) err = KErrGeneral;
		switch (iProcess.Process().ExitType())
			{
			case EExitKill:
				iObserver.PrintError(err, _L("Script %S failed, returned %d"), &iScriptFile, exitReason);
				break;
			case EExitTerminate:
				iObserver.PrintError(err, _L("Script %S terminated with %d"), &iScriptFile, exitReason);
				break;
			case EExitPanic:
				{
				TExitCategoryName cat = iProcess.Process().ExitCategory();
				iObserver.PrintError(err, _L("Script %S panicked with %S %d"), &iScriptFile, &cat, exitReason);
				break;
				}
			default:
				break;
			}
		}
	delete this;
	}