// Copyright (c) 1998-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 "IMSKSCR.H"
#include "IMSK.H"
#include "IMCVTEXT.H"


_LIT8(K_IM_SCRIPT_WAIT_STRING, "** Read cancelled");

CImTextServerScript::CImTextServerScript() : CActive(EPriorityStandard)
	{
	}

CImTextServerScript *CImTextServerScript::NewL(TInt aPortNum)
	{
	CImTextServerScript* self =new(ELeave)CImTextServerScript();
	CleanupStack::PushL(self);
	self->ConstructL(aPortNum);
	CleanupStack::Pop();
	return self;
	}
//
// 2nd phase of construction
//
void CImTextServerScript::ConstructL(TInt aPortNum)
	{
	CActiveScheduler::Add(this);
	User::LeaveIfError(iFs.Connect());

	TBuf<35> scriptFile; 
	scriptFile.Format(TRefByValue<const TDesC>_L("c:\\Logs\\email\\imsk%d.scr"),aPortNum);
	User::LeaveIfError(iFile.Open(iFs,scriptFile,EFileShareAny));

#ifndef _UNICODE
	iScriptFileText.Set(iFile);
#endif

	}

CImTextServerScript::~CImTextServerScript()
	{
	iFile.Close();
	iFs.Close();
	}

void CImTextServerScript::RetrieveResponse(TDes8& theBuffer, TRequestStatus& aStatus)
	{
	iReportStatus = &aStatus;
    TInt fileReadErr = KErrNone;

#ifndef _UNICODE
	fileReadErr = iScriptFileText.Read(iData);
#else
    //  _UNICODE read one line ASCII data
    fileReadErr = ReadLine();
#endif

	iNextFileSeg.Copy(iData);

	if( fileReadErr == KErrNone)
		{
		theBuffer.Append(iNextFileSeg);
		}
	else if(fileReadErr == KErrTooBig)
		{
		for(;;)
			{
			// read response from file
#ifndef _UNICODE
			fileReadErr = iScriptFileText.Read(iData);
#else
            //  _UNICODE read one line ASCII data
            fileReadErr = ReadLine();
#endif
			iNextFileSeg.Copy(iData);
			TInt crLfPos = iNextFileSeg.Find(KImcvCRLF);
			if(crLfPos == KErrNotFound)
				{
				theBuffer.Append(iNextFileSeg);
				break;
				}
			else
				{
				theBuffer.Append(iNextFileSeg.Left(crLfPos));
				}
			}
		}

	iStatus = KRequestPending;
	aStatus = KRequestPending;
	SetActive();

	if ((theBuffer.CompareF(K_IM_SCRIPT_WAIT_STRING) != 0)
		&& (fileReadErr != KErrEof))
		{
		theBuffer.Append(KImcvCRLF);
		TRequestStatus* status = &iStatus;
		User::RequestComplete(status, KErrNone);
		}
	}

//
//  ReadLine() read ASCII into TBuf8 thingy if unicode build.
//
#ifdef _UNICODE
TInt CImTextServerScript::ReadLine()
    {
    TInt err = KErrNone;

    //  Read into the buffer
    TBuf8<256> buffer;              // Max read of the Read() function..    
    iData.Zero();

    //  Get the current file position
    TInt filePos = 0;
    iFile.Seek(ESeekCurrent, filePos);

    //  Read the buffer
    err = iFile.Read(buffer);
    
    //end of file?
    TInt s = buffer.Length();
    if( s == 0)
        {
        err = KErrEof;
        }

    if(err == KErrNone)
        {
        //  Copy to the lfcr and then set the file pointer
        //  to the point after that...
        TInt pos = buffer.Find(KImcvCRLF);
        if( pos != -1)
            {
            iData.Justify(buffer, pos, ELeft, ' ');
            filePos += (pos+2);

            //  Set the file pointer back to after the lfcr..
            iFile.Seek(ESeekStart, filePos);                
            }
        //  Else fill the whole buffer 256 chars..
        else
            {
            iData.Copy(buffer);
            }
        }
    return err;
    }
#endif

void CImTextServerScript::RunL()
	{
	User::RequestComplete(iReportStatus, KErrNone);
	}

void CImTextServerScript::DoCancel()
	{
	if (IsActive())
		{
		if (iStatus == KRequestPending)
			{
			TRequestStatus* status = &iStatus;
			User::RequestComplete(status, KErrNone);
			}
		User::RequestComplete(iReportStatus, KErrNone);
		}
	}