/*

* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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 "config.h"

#include <../bidi.h>

#include "FileStreamSymbian.h"

#include "PlatformString.h"

#include "StaticObjectsContainer.h"

namespace WebCore {

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

// FileStreamOutput

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

FileStreamOutput::FileStreamOutput(const String& path) : m_isOpened(false)

{

    if (m_stream.Replace(StaticObjectsContainer::instance()->fsSession(), path.des(), EFileWrite | EFileStream | EFileShareAny) == KErrNone)

        m_isOpened = true;

}

FileStreamOutput::~FileStreamOutput()

{

    m_stream.Close();

}

StreamOutput& FileStreamOutput::operator<<(char ch)

{

    m_stream.WriteInt8L(ch);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(unsigned char ch)

{

    m_stream.WriteUint8L(ch);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(short sh)

{

    m_stream.WriteInt16L(sh);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(unsigned short ush)

{

    m_stream.WriteUint16L(ush);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(int i)

{

    m_stream.WriteInt32L(i);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(unsigned int ui)

{

    m_stream.WriteUint32L(ui);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(const String& str)

{

    // we only write unicode data into the string

    int len = str.length();

    const UChar* chs = str.characters();

    m_stream.WriteInt32L(len);

    m_stream.WriteL((const TUint8*)(chs), len<<1);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(const Streamable& o)

{

    o.write(*this);

    return *this;

}

StreamOutput& FileStreamOutput::operator<<(const StreamEndOfLine&)

{

    return *this;

}

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

// FileStreamInput

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

FileStreamInput::FileStreamInput(const String& path) : m_isOpened(false)

{

    if (m_stream.Open(StaticObjectsContainer::instance()->fsSession(), path.des(), EFileShareReadersOnly | EFileRead | EFileStream) == KErrNone)

        m_isOpened = true;

}

FileStreamInput::~FileStreamInput()

{

    m_stream.Close();

}

StreamInput& FileStreamInput::operator>>(char& ch)

{

    ch = m_stream.ReadInt8L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(unsigned char& uch)

{

    uch = m_stream.ReadUint8L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(short& sh)

{

    sh = m_stream.ReadInt16L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(unsigned short& ush)

{

    ush = m_stream.ReadUint16L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(int& i)

{

    i = m_stream.ReadInt32L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(unsigned int& ui)

{

    ui = m_stream.ReadUint32L();

    return *this;

}

StreamInput& FileStreamInput::operator>>(String& str)

{

    int len = m_stream.ReadInt32L();

    UChar* data = new UChar[len];

    m_stream.ReadL(data, len);

    str.insert(data, len, 0);

    delete data;

    return *this;

}

StreamInput& FileStreamInput::operator>>(Streamable& o)

{

    o.read(*this);

    return *this;

}

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

// TextFileStreamOutput

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

TextFileStreamOutput::TextFileStreamOutput(const String& path) : m_isOpened(false)

{

    if (m_stream.Replace(StaticObjectsContainer::instance()->fsSession(), path.des(), EFileWrite | EFileStream | EFileShareAny) == KErrNone)

        m_isOpened = true;

}

TextFileStreamOutput::~TextFileStreamOutput()

{

    m_stream.Close();

}

StreamOutput& TextFileStreamOutput::operator<<(char ch)

{

    m_data.append(String::number(ch));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(unsigned char ch)

{

    m_data.append(String::number(ch));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(short sh)

{

    m_data.append(String::number(sh));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(unsigned short ush)

{

    m_data.append(String::number(ush));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(int i)

{

    m_data.append(String::number(i));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(unsigned int ui)

{

    m_data.append(String::number(ui));

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(const String& str)

{

    m_data.append(str);    

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(const Streamable& o)

{

    o.write(*this);

    return *this;

}

StreamOutput& TextFileStreamOutput::operator<<(const StreamEndOfLine&)

{

    String str("\n");

    int len = str.length();

    const UChar* chs = str.characters();

    m_stream.WriteL((const TUint8*)(chs), len<<1);

    return *this;

}

}