/*
* Copyright (c) 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 <s32mem.h>
#include "tsserializeddataprovider.h"
#include "tsmodel.h"
// -----------------------------------------------------------------------------
/**
 * Leaving constructor. 
 * @param observer - data observer
 */
CTsSerializedDataProvider* CTsSerializedDataProvider::NewL(MTsDataObserver &observer)
{
    return new (ELeave) CTsSerializedDataProvider(observer);
    
}

// -----------------------------------------------------------------------------
/**
 * Constructor
 * @param observer - data observer
 */
CTsSerializedDataProvider::CTsSerializedDataProvider(MTsDataObserver& observer)
:
    mObserver(observer)
{}

// -----------------------------------------------------------------------------
/**
 * Destructor
 */
CTsSerializedDataProvider::~CTsSerializedDataProvider()
{
    mData.Close();
}

// -----------------------------------------------------------------------------
/**
 * Interface implementation.
 * @see MTsDataProvider::Data()
 */
const TDesC8& CTsSerializedDataProvider::Data() const
{
    return mData;
}

// -----------------------------------------------------------------------------
/**
 * Interface implementation.
 * @see MTsModelObserver::dataChanged(MTsModel &)
 */
void CTsSerializedDataProvider::dataChanged(MTsModel &model)
{
    serializeModel(model);
}

// -----------------------------------------------------------------------------
/**
 * Interface implementation.
 * @see MTsModelObserver::dataChanged(TTsModelItem &)
 */
void CTsSerializedDataProvider::dataChanged(const TTsModelItem &/*item*/)
{
    //No implementation required now. 
}

// -----------------------------------------------------------------------------
/**
 * Serialize source model into internal data storage
 * @param src - model
 */
void CTsSerializedDataProvider::serializeModel(const MTsModel &src)
{
    TRAPD(errNo, serializeModelL(src));
    if(KErrNone == errNo ) {
        mObserver.DataChanged();
    }
}

// -----------------------------------------------------------------------------
/**
 * Serialize source model into internal data storage. Function can leave.
 * @param src - source model
 */
void CTsSerializedDataProvider::serializeModelL(const MTsModel &src)
{
    const TInt KExpandSize = 256;
    CBufFlat* buf = CBufFlat::NewL(KExpandSize);
    CleanupStack::PushL(buf);
    RBufWriteStream stream(*buf); 
    CleanupClosePushL(stream);
    
    serializeModelL(stream, src);
    
    CleanupStack::PopAndDestroy(&stream);
    mData.Close();
    mData.CreateL(buf->Size());
    buf->Read(0, mData, buf->Size());
    CleanupStack::PopAndDestroy(buf);
}

// -----------------------------------------------------------------------------
/**
 * Serialize source model into destination stream. Function can leave.
 * @param dst - destination stream
 * @param src - source model
 */
void CTsSerializedDataProvider::serializeModelL(RWriteStream& dst, const MTsModel &src)
{
    dst.WriteInt32L(src.count());
    for (TInt iter(0); iter < src.count(); ++iter) {
        dst << src.itemL(iter);
    }
}