/*

* 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 <e32def.h>

#include "DataDealer.h"

#include "BreathSaver.h"

CBreathSaver* CBreathSaver::NewL()

    {

    CBreathSaver* self = new (ELeave) CBreathSaver();

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

CBreathSaver::~CBreathSaver()

    {

    // Free DataDealer

	if (iDataDealer)

		{

		delete iDataDealer;

		iDataDealer = 0;

		}

    // Close handle to File server session

    iRFsession.Close();

    }

/**

 * Start function for data dealer

 * @param aKey			Data dealer key

 * @return				TInt. Error code.

 */

TInt CBreathSaver::StartDealer(const TUint aKey)

	{

	TInt error = KErrNone;

    // return error if DataDealer is already started

    if (iDealerStarted != EFalse)

        {

        error = KErrLocked;

        }

    else

    	{

    	// iDataDealer is deleted in End-function or in destructor and

    	// Start cannot be called again before End is called first

        TRAP (error, iDataDealer = CDataDealer::NewL(ETrue, aKey));

        // NewL failed

        if (error == KErrNone)

            {

            // DataDealer is started

        	iDealerStarted = ETrue;

        	}        

    	}

	return error;

	}

/**

 * Start function for file saving. This function replaces the file if it already exists

 * @param aFileName		File name

 * @return				TInt. Error code.

 */

TInt CBreathSaver::StartFile(const TDesC &aFileName)

    {

    TInt error = KErrNone;

    // Check that start is not called when somebody else have already called start

    // but not end

    if (iFileStarted != EFalse)

        {

        error = KErrLocked;

        }

    else

    	{

    	error = iFile.Replace(iRFsession,aFileName,EFileWrite|EFileStream);

        // Check that file replase was successful

        if (error == KErrNone)

            {

            // All must be fine so lets start file

            iFileStarted = ETrue;

            }

    	}

    return error;

    }

/**

 * Appends Buffer into a started file.

 * @param aBuffer		Buffer to be appened.

 * @return				TInt. Error code.

 */

TInt CBreathSaver::Append(TDes8 &aBuffer)

    {

	// If nothing is started then nothing should be appended

    if (iFileStarted == EFalse && iDealerStarted == EFalse)

        {

        return KErrNotFound;

        }

    TInt error = KErrNone;

    // Check if file is started

    if (iFileStarted)

        {

        // Add more to existing file

        error = iFile.Write(aBuffer);

		if (error != KErrNone)

			{

			return error;

			}

        }

    // Check if DataDealer is started

    if (iDealerStarted)

		{

		// ProduceDataL waits until consumer has devoured all the previously

		// produced data

		TRAP (error, iDataDealer->ProduceDataL(aBuffer));

		if (error != KErrNone)

			{

			return error;

			}

		}

    // more types can be added here

    return error;

    }

/**

 * Ends function for file saving.

 * @return				TInt. Error code.

 */

TInt CBreathSaver::End()

    {

    TInt error = KErrNone;

	// If nothing is started then nothing should be ended

    if (iFileStarted == EFalse && iDealerStarted == EFalse)

        {

        error = KErrNotFound;

        }

    else

    	{

        // Check if file is started

        if (iFileStarted)

            {

            // Flush and close file

            error = iFile.Flush();

            iFile.Close();

            // Now new file can be started

    		iFileStarted = EFalse;

            }

        // Check if DataDealer is started

    	if (iDealerStarted)

    		{

            // free DataDealer, new dealer is born(captured?) in start function

    		delete iDataDealer;

    		iDataDealer = 0;

            // Now new data dealer can be started

    		iDealerStarted = EFalse;

    		}

    	}

    return error;

    }

CBreathSaver::CBreathSaver()

    {

    iFileStarted = EFalse;

	iDealerStarted = EFalse;

	iDataDealer = 0;

    }

void CBreathSaver::ConstructL()

    {

    // Open file server session

    // Session is closed in destructor

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

    }