// Copyright (c) 2005-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 "cspoofserver.h"

const TInt KListeningSocketQueueSize = 1;

CSpoofServer::CSpoofServer(MImapTestEventHandler& aObserver) 

: CActive(EPriorityStandard), iObserver(aObserver)

	{

	iServerStatus=EIdle;

	CActiveScheduler::Add(this); 

	}

EXPORT_C CSpoofServer* CSpoofServer::NewL(MImapTestEventHandler& aObserver,const TDesC& aScriptFile)

	{

	CSpoofServer* self = NewLC(aObserver,aScriptFile);

	CleanupStack::Pop(self);

	return self;

	}

EXPORT_C CSpoofServer* CSpoofServer::NewLC(MImapTestEventHandler& aObserver,const TDesC& aScriptFile)

	{

	CSpoofServer* self = new(ELeave) CSpoofServer(aObserver);

	CleanupStack::PushL(self);

	self->ConstructL(aScriptFile);

	return self;

	}

CSpoofServer::~CSpoofServer()

	{

	Cancel();	

	iListeningSocket.Close();

	iServiceSocket.Close();

	iSocketServer.Close();

	delete iScriptFileProcessor;

	}

EXPORT_C TInt CSpoofServer::RunError(TInt aError)

	{

	iObserver.TestComplete(aError);

	return KErrNone;

	}

void CSpoofServer::ConstructL(const TDesC& aScriptFile)

	{

	//connect to the socket server

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

	//create the script file processor

	iScriptFileProcessor = CScriptFileProcessor::NewL(aScriptFile);	

	}

void CSpoofServer::DoCancel()

	{

	iListeningSocket.CancelAll();

	}

EXPORT_C void CSpoofServer::StartL(const TInt aPortNumber)

	{

	iServerStatus = EWriting;

	//set up the listening socket

	User::LeaveIfError(iListeningSocket.Open(iSocketServer, KAfInet, KSockStream, KProtocolInetTcp));

	//bind the listener

	TSockAddr address;

	address.SetPort(aPortNumber);

	iListeningSocket.Bind(address);

	//listen for incomming connections

	iListeningSocket.Listen(KListeningSocketQueueSize);

	//accept incomming connections and use iServiceSocket to communicate with it.

	User::LeaveIfError(iServiceSocket.Open(iSocketServer));

	iListeningSocket.Accept(iServiceSocket,iStatus);

	SetActive();	

	}

void CSpoofServer::IssueWrite()

	{			

    iBuffer.Zero();

  	iBuffer.Append(iNextLine);

  	_LIT(KEndOfLine,"\r\n");

  	iBuffer.Append(KEndOfLine);

	iServiceSocket.Write(iBuffer, iStatus);

	SetActive();

	}

void CSpoofServer::IssueRead()

	{

    iBuffer.Zero();

  	iServiceSocket.RecvOneOrMore(iBuffer, 0, iStatus,iReadLength);

  	SetActive();

	}

void CSpoofServer::RunL()

	{

	User::LeaveIfError(iStatus.Int());	

	CScriptFileProcessor::TDataDirection direction;

	iBuffer.TrimAll();

	if(iServerStatus==EReading)

		{

		if(iNextLine!=iBuffer)

			{

			User::Leave(KErrCorrupt);		

			}		

		}

	//read next line of script file and get its direction

	User::LeaveIfError(iScriptFileProcessor->ReadLine(iNextLine));

	direction=iScriptFileProcessor->DataDirection();

    //if we are sending then write the line, else read 

    if(direction==CScriptFileProcessor::EFromServer)

    	{

    	iServerStatus=EWriting;	

    	IssueWrite();

    	}

    else if(direction==CScriptFileProcessor::EFromClient)

    	{

    	iServerStatus=EReading;

    	IssueRead();

    	}    	

	}