// 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:
// imapserver.cpp
// 
//
 
#include "imapspoofserver.h"

//
// CImapSpoofServer
//

const TInt KImapPortNumber = 143;

CImapSpoofServer::CImapSpoofServer() : CActive(EPriorityStandard)
	{
	iServerStatus=EIdle;
	}

EXPORT_C CImapSpoofServer* CImapSpoofServer::NewL(MImapTestEventHandler* aOwner,const TDesC& aScriptFile)
	{
	CImapSpoofServer* self = NewLC(aOwner,aScriptFile);
	CleanupStack::Pop(self);
	return self;
	}

EXPORT_C CImapSpoofServer* CImapSpoofServer::NewLC(MImapTestEventHandler* aOwner,const TDesC& aScriptFile)
	{
	CImapSpoofServer* self = new(ELeave) CImapSpoofServer;
	CleanupStack::PushL(self);
	self->ConstructL(aOwner,aScriptFile);
	return self;
	}
	
CImapSpoofServer::~CImapSpoofServer()
	{
	Cancel();	
	iListeningSocket.Close();
	iServiceSocket.Close();
	iSocketServer.Close();
	delete iScriptFileProcessor;
	}

EXPORT_C TInt CImapSpoofServer::RunError(TInt aError)
	{
	iOwner->HandleEvent(aError);
	return KErrNone;
	}

void CImapSpoofServer::ConstructL(MImapTestEventHandler* aOwner,const TDesC& aScriptFile)
	{
	CActiveScheduler::Add(this); 
	iOwner=aOwner;
	//connect to the socket server
	User::LeaveIfError(iSocketServer.Connect());
	//create the script file processor
	iScriptFileProcessor = CScriptFileProcessor::NewL(aScriptFile);	
	}

void CImapSpoofServer::DoCancel()
	{
	iListeningSocket.CancelAccept();
	}
	
void CImapSpoofServer::StartL()
	{
	iServerStatus = EWriting;
	//set up the listening socket
	User::LeaveIfError(iListeningSocket.Open(iSocketServer, KAfInet, KSockStream, KProtocolInetTcp));
	//bind the listener to any address from port 143
	TSockAddr address;
	address.SetPort(KImapPortNumber);
	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 CImapSpoofServer::IssueWrite()
	{			
    iBuffer.Zero();
  	iBuffer.Append(iNextLine);
	iBuffer.Append(_L("\r\n"));
	iServiceSocket.Write(iBuffer, iStatus);
	SetActive();
	}

void CImapSpoofServer::IssueRead()
	{
    iBuffer.Zero();
  	iServiceSocket.RecvOneOrMore(iBuffer, 0, iStatus,iReadLength);
  	SetActive();
	}
 
void CImapSpoofServer::RunL()
	{	
	
	CScriptFileProcessor::TDataDirection direction;

	if (iStatus == KErrNone)
		{		
		iBuffer.TrimAll();
		if(iServerStatus==EReading)
			{
			if(iNextLine!=iBuffer)
				{
				iOwner->HandleEvent(KErrCorrupt);		
				}		
			}
		//read next line of script file
		//if weve reached the end of the file then inform the owning object
		TInt err = iScriptFileProcessor->ReadLine(iNextLine);
		
		if(err==KErrEof)
			{
			iOwner->HandleEvent(KErrEof);	
			}
		else if(err==KErrNone)
			{
			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();
    			}    	
			}
		else
			{
			iOwner->HandleEvent(err);	
			}
		}	
	else
		{
		iOwner->HandleEvent(iStatus.Int());		
		}
		
	}