/*

* 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:  RSconSyncSession implementation

*

*/

#include "sconsyncclient.h"

#include <SmlDataProvider.h>

#include <s32mem.h>

#include "sconsyncclientserver.h"

#include "debug.h"

const TInt KSConSyncChunkSize = 0xFFFF; // 65535 bytes;

const TInt KSConSyncChunkMaxSize = 0x400000; // 4194304 bytes

EXPORT_C RSconSyncSession::RSconSyncSession()

    {

    TRACE_FUNC;

    }

EXPORT_C RSconSyncSession::~RSconSyncSession()

    {

    TRACE_FUNC;

    }

EXPORT_C TInt RSconSyncSession::Connect()

    {

    TRACE_FUNC_ENTRY;

    TInt retryCount = 2;

    TInt error = KErrNone;

    while(retryCount)

        {

        error = CreateSession(KSconSyncServerName, TVersion(1,0,0));

        if ( error != KErrNotFound && error != KErrServerTerminated )

            {

            break;

            }

        error = StartServer();

        if( error != KErrNone && error != KErrAlreadyExists )

            {

            break;

            }

        --retryCount;

        }

    if ( error == KErrNone )

        {

        error = CreateAndSendChunkHandle();

        if ( error != KErrNone )

            {

            LOGGER_WRITE("CreateAndSendChunkHandle failed, close session");

            Close();

            }

        }

    TRACE_FUNC_EXIT;

    return error;

    }

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

// RSconSyncSession::Close()

// Closes the server connection

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

//

EXPORT_C void RSconSyncSession::Close()

    {

    TRACE_FUNC_ENTRY;

    iChunk.Close();

    RSessionBase::Close();

    TRACE_FUNC_EXIT

    }

EXPORT_C void RSconSyncSession::ListAllImplementationsL( RSconDataProviderInfoArray& aInfoArray )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EListImplementations, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::ListAllImplementationsL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    // copy data from the chunk

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    TInt count( readStream.ReadUint16L() );

    LOGGER_WRITE_1("count: %d", count);

    for ( TInt i=0; i<count; i++ )

        {

        LOGGER_WRITE_1("Import[%d]", i);

        CSconDataproviderInfo *dpInfo = CSconDataproviderInfo::NewL();

        CleanupStack::PushL( dpInfo );

        dpInfo->InternalizeL( readStream );

        aInfoArray.AppendL( dpInfo );

        CleanupStack::Pop( dpInfo );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::OpenDataStoreL( const TSmlDataProviderId aProviderId, const TDesC& aStoreName, TInt aContextId )

    {

    TRACE_FUNC_ENTRY;

    User::LeaveIfError( iChunk.Adjust( 

            sizeof(TInt32)

            + sizeof(TInt32)

            + aStoreName.Size()

            + sizeof(TInt) ));

    RMemWriteStream writeBuf( iChunk.Base(), iChunk.Size() );

    writeBuf.WriteInt32L( aProviderId );

    writeBuf.WriteInt32L( aStoreName.Length() );

    writeBuf.WriteL( aStoreName );

    writeBuf.WriteInt32L( aContextId );

    writeBuf.CommitL();

    writeBuf.Close();

    TIpcArgs args;

    TInt ret = SendReceive ( EOpenStore, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::OpenDataStoreL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::OpenItemL( TSmlDbItemUid aUid, TBool& aFieldChange,

        TSmlDbItemUid& aParent, TDes8& aMimeType, TDes8& aMimeVer, CBufFlat& aItemData )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args( aUid );

    TInt ret = SendReceive ( EOpenItem, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::OpenItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    // copy data from the chunk

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    TInt32 length ( 0 );

    aItemData.Reset();

    length = readStream.ReadInt32L();

    HBufC8* data = HBufC8::NewLC( length );

    TPtr8 dataPtr = data->Des();

    readStream.ReadL( dataPtr, length );

    aItemData.ExpandL( 0, length );

    aItemData.Write ( 0, dataPtr );

    CleanupStack::PopAndDestroy( data );

    aFieldChange = readStream.ReadInt8L();

    aParent = readStream.ReadInt32L();

    length = readStream.ReadInt32L();

    readStream.ReadL( aMimeType, length );

    length = readStream.ReadInt32L();

    readStream.ReadL( aMimeVer, length );

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::CreateItemL(TSmlDbItemUid& aUid/*, TInt aSize*/,

        TSmlDbItemUid aParent, const TDesC8& aMimeType, const TDesC8& aMimeVer,

        const TDesC8& aData)

    {

    TRACE_FUNC_ENTRY;

    User::LeaveIfError( iChunk.Adjust( 

        sizeof(TInt32)

        + sizeof(TInt32)

        + aMimeType.Length()

        + sizeof(TInt32)

        + aMimeVer.Length()

        + sizeof(TInt32)

        + aData.Length() ));

    RMemWriteStream writeBuf( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( writeBuf );

    writeBuf.WriteInt32L( aParent );

    writeBuf.WriteInt32L( aMimeType.Length() );

    writeBuf.WriteL( aMimeType );

    writeBuf.WriteInt32L( aMimeVer.Length() );

    writeBuf.WriteL( aMimeVer );

    writeBuf.WriteInt32L( aData.Length() );

    writeBuf.WriteL( aData );

    writeBuf.CommitL();

    CleanupStack::PopAndDestroy( &writeBuf );

    TPckg<TSmlDbItemUid> pckg(aUid);

    iArgs = TIpcArgs( &pckg );

    TInt ret = SendReceive ( ECreateItem, iArgs );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::CreateItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    LOGGER_WRITE_1("aUid: %d", aUid);

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::CreateItemL(TPckg<TSmlDbItemUid>& aUidPckg,

        TSmlDbItemUid aParent, const TDesC8& aMimeType, const TDesC8& aMimeVer,

        const TDesC8& aData, TRequestStatus& aStatus)

    {

    TRACE_FUNC_ENTRY;

    User::LeaveIfError( iChunk.Adjust( 

        sizeof(TInt32)

        + sizeof(TInt32)

        + aMimeType.Length()

        + sizeof(TInt32)

        + aMimeVer.Length()

        + sizeof(TInt32)

        + aData.Length() ));

    RMemWriteStream writeBuf( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( writeBuf );

    writeBuf.WriteInt32L( aParent );

    writeBuf.WriteInt32L( aMimeType.Length() );

    writeBuf.WriteL( aMimeType );

    writeBuf.WriteInt32L( aMimeVer.Length() );

    writeBuf.WriteL( aMimeVer );

    writeBuf.WriteInt32L( aData.Length() );

    writeBuf.WriteL( aData );

    writeBuf.CommitL();

    CleanupStack::PopAndDestroy( &writeBuf );

    iArgs = TIpcArgs( &aUidPckg );

    SendReceive( ECreateItem, iArgs, aStatus );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::ReplaceItemL(TSmlDbItemUid aUid,

        TSmlDbItemUid aParent, TBool aFieldChange, const TDesC8& aData)

    {

    TRACE_FUNC_ENTRY;

    User::LeaveIfError( iChunk.Adjust( 

        sizeof(TInt32)

        + sizeof(TInt32)

        + sizeof(TInt8)

        + sizeof(TInt32)

        + aData.Length() ));

    RMemWriteStream writeBuf( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( writeBuf );

    writeBuf.WriteInt32L( aUid );

    writeBuf.WriteInt32L( aParent );

    writeBuf.WriteInt8L( aFieldChange );

    writeBuf.WriteInt32L( aData.Length() );

    writeBuf.WriteL( aData );

    writeBuf.CommitL();

    CleanupStack::PopAndDestroy( &writeBuf );

    TIpcArgs args;

    TInt ret = SendReceive( EReplaceItem, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::ReplaceItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::ReplaceItemL(TSmlDbItemUid aUid,

        TSmlDbItemUid aParent, TBool aFieldChange, const TDesC8& aData,

        TRequestStatus& aStatus)

    {

    TRACE_FUNC_ENTRY;

    User::LeaveIfError( iChunk.Adjust( 

        sizeof(TInt32)

        + sizeof(TInt32)

        + sizeof(TInt8)

        + sizeof(TInt32)

        + aData.Length() ));

    RMemWriteStream writeBuf( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( writeBuf );

    writeBuf.WriteInt32L( aUid );

    writeBuf.WriteInt32L( aParent );

    writeBuf.WriteInt8L( aFieldChange );

    writeBuf.WriteInt32L( aData.Length() );

    writeBuf.WriteL( aData );

    writeBuf.CommitL();

    CleanupStack::PopAndDestroy( &writeBuf );

    TIpcArgs args;

    SendReceive( EReplaceItem, args, aStatus );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::MoveItemL( TSmlDbItemUid aUid, TSmlDbItemUid aNewParent )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args(aUid, aNewParent);

    TInt ret = SendReceive ( EMoveItem, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::MoveItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::DeleteItemL( TSmlDbItemUid aUid )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args( aUid );

    TInt ret = SendReceive ( EDeleteItem, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::DeleteItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::SoftDeleteItemL( TSmlDbItemUid aUid )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args( aUid );

    TInt ret = SendReceive ( ESoftDeleteItem, args );

    if ( ret != KErrNone) 

        {

        LOGGER_WRITE_1( "RSconSyncSession::SoftDeleteItemL() :\

         Send Receive failed with code %d", ret );

        User::Leave( ret );

        };

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::DeleteAllItems( TRequestStatus& aStatus )

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    SendReceive( EDeleteAllItems, args, aStatus );

    TRACE_FUNC_EXIT;

    }

EXPORT_C TBool RSconSyncSession::HasSyncHistoryL() const

    {

    TRACE_FUNC;

    TBool history(EFalse);

    TPckg<TBool> pck(history);

    TIpcArgs args(&pck);

    TInt ret = SendReceive ( EHasHistory, args );

    User::LeaveIfError( ret );

    TRACE_FUNC_EXIT;

    return history;

    }

EXPORT_C void RSconSyncSession::AddedItemsL( RArray<TSmlDbItemUid>& aItems) const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EAddedItems, args );

    User::LeaveIfError( ret );

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    aItems.Reset();

    TInt itemCount = readStream.ReadInt32L();

    for (TInt i=0; i<itemCount; i++)

        {

        aItems.AppendL( readStream.ReadInt32L() );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::DeletedItemsL( RArray<TSmlDbItemUid>& aItems) const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EDeletedItems, args );

    User::LeaveIfError( ret );

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    aItems.Reset();

    TInt itemCount = readStream.ReadInt32L();

    for (TInt i=0; i<itemCount; i++)

        {

        aItems.AppendL( readStream.ReadInt32L() );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::SoftDeletedItemsL( RArray<TSmlDbItemUid>& aItems) const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( ESoftDeletedItems, args );

    User::LeaveIfError( ret );

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    aItems.Reset();

    TInt itemCount = readStream.ReadInt32L();

    for (TInt i=0; i<itemCount; i++)

        {

        aItems.AppendL( readStream.ReadInt32L() );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::ModifiedItemsL( RArray<TSmlDbItemUid>& aItems) const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EModifiedItems, args );

    User::LeaveIfError( ret );

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    aItems.Reset();

    TInt itemCount = readStream.ReadInt32L();

    for (TInt i=0; i<itemCount; i++)

        {

        aItems.AppendL( readStream.ReadInt32L() );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::MovedItemsL( RArray<TSmlDbItemUid>& aItems) const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EMovedItems, args );

    User::LeaveIfError( ret );

    RMemReadStream readStream( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( readStream );

    aItems.Reset();

    TInt itemCount = readStream.ReadInt32L();

    for (TInt i=0; i<itemCount; i++)

        {

        aItems.AppendL( readStream.ReadInt32L() );

        }

    CleanupStack::PopAndDestroy( &readStream );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::CloseDataStore() const

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    SendReceive ( ECloseStore, args );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::ResetChangeInfoL()

    {

    TRACE_FUNC_ENTRY;

    TIpcArgs args;

    TInt ret = SendReceive ( EResetChangeInfo, args );

    User::LeaveIfError( ret );

    TRACE_FUNC_EXIT;

    }

EXPORT_C void RSconSyncSession::CommitChangeInfoL(const RArray<TSmlDbItemUid>& aItems )

    {

    TRACE_FUNC_ENTRY;

    RMemWriteStream stream ( iChunk.Base(), iChunk.Size() );

    CleanupClosePushL( stream );

    LOGGER_WRITE_1("items count: %d", aItems.Count());

    stream.WriteInt32L( aItems.Count() );

    for (TInt i=0; i < aItems.Count(); i++ )