// 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 FILES

#include "EPos_CPosFileHandler.h"

// ================= MEMBER FUNCTIONS =======================

// C++ default constructor can NOT contain any code, that

// might leave.

//

CPosFileHandler::CPosFileHandler()

    {

    }

// EPOC default constructor can leave.

void CPosFileHandler::ConstructL(const TDesC& aFileName)

    {

    iFileName = aFileName.AllocL();

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

    User::LeaveIfError(iFile.Open(iFsSession, aFileName,

        EFileShareReadersOnly));

    iStream.Attach(iFile);

    }

// Two-phased constructor.

CPosFileHandler* CPosFileHandler::NewL(const TDesC& aFileName)

    {

    CPosFileHandler* self = new (ELeave) CPosFileHandler;

    CleanupStack::PushL(self);

    self->ConstructL(aFileName);

    CleanupStack::Pop(self);

    return self;

    }

// Destructor

CPosFileHandler::~CPosFileHandler()

    {

    iStream.Close();

    iFile.Close();

    iFsSession.Close();

    delete iFileName;

    }

// ----------------------------------------------------------------------------

// CPosFileHandler::Read

//

// (other items were commented in a header).

// ----------------------------------------------------------------------------

//

TInt CPosFileHandler::Read(TDes8& aDes)

    {

    const TChar c(0x000A) ;

    TRAPD(err, (iStream.ReadL(aDes, c)));

    if (err == KErrEof)

        {

        TInt err2 = ReadFromStart();

        if (err2 != KErrNone)

            {

            err = err2;

            }

        }

    return err;

    }

// ----------------------------------------------------------------------------

// CPosFileHandler::ReadL

//

// (other items were commented in a header).

// ----------------------------------------------------------------------------

//

void CPosFileHandler::ReadL(CDesC8Array& aArray)

    {

    TInt err = KErrNone;

    TBuf8<KMaxSentenceLength> dataInfo;

    const TChar endoflinechar(';');

	TStreamPos offset;

    while (err != KErrEof)

        {

		//Store the current offset in the stream

        offset = iStream.Source()->TellL(MStreamBuf::ERead);

        TRAP(err, (iStream.ReadL(dataInfo, endoflinechar)));

		if(err == KErrEof)

        	{

        	//End of File has been reached without finding an endoflinechar, so attempt to

        	// extract the remaining data of the file

        	TInt length = iStream.Source()->SizeL();

        	TInt readLength = length - (offset.Offset());

        	//Reset the stream back to the end of the previous successful data extraction 

        	iStream.Source()->SeekL(MStreamBuf::ERead, offset);

        	//Read the remaining data from the stream

        	TRAP(err, (iStream.ReadL(dataInfo, readLength)));

        	if(err == KErrNone)

        		{

        		//Managed to read the remaining data.  Ensure the error is EOF to exit the loop 

        		err = KErrEof;

        		}

        	}

        if (err != KErrNone && err != KErrEof)

            {

            User::Leave(err);

            }

        dataInfo.Trim();

        if ((err == KErrNone || err == KErrEof) && dataInfo.Length() > 0)

            {

            aArray.AppendL(dataInfo);

            }

        }

    if (aArray.Count() != KNoOfSimulatedDataItems)

        {

        User::Leave(KErrCorrupt);

        }

    }

// ----------------------------------------------------------------------------

// CPosFileHandler::ReadFromStart

//

// (other items were commented in a header).

// ----------------------------------------------------------------------------

//

TInt CPosFileHandler::ReadFromStart()

    {

    // Close stream and file and open them again.

    iStream.Close();

    iFile.Close();

    TInt err = iFile.Open(iFsSession, *iFileName, EFileShareReadersOnly);

    iStream.Attach(iFile);

    return err;

    }

//  End of File