/*
* Copyright (c) 2002 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:  Sub-client to managed particular session slot
*
*/


// INCLUDE FILES
#include "RPEngStorageSubFolderClient.h"

#include "RPEngStorageClient.h"
#include "TPEngStorageServerMessages.h"

#include "PresenceDebugPrint.h"

// PEC Engine internal constants
#include "PEngInternalGlobalConsts.h"

// MACROS
#define RETURN_IF_NOT_CONNECTED()\
    if(!iConnected)\
        {\
        return KErrDisconnected;\
        }

#define SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType )\
    TIpcArgs messArgs;\
    messArgs.Set( KMessageSlot0, &aStoreId );\
    messArgs.Set( KMessageSlot1, aStoreType );

// ============================ MEMBER FUNCTIONS ===============================
// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::RPEngStorageSubFolderClient
// C++ default constructor can NOT contain any code, that might leave.
// -----------------------------------------------------------------------------
//
RPEngStorageSubFolderClient::RPEngStorageSubFolderClient( )
    {
    }

// Destructor
RPEngStorageSubFolderClient::~RPEngStorageSubFolderClient()
    {
    }

// =============================================================================
// ============================ Close/Connect FUNCTIONS ========================
// =============================================================================

// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::Connect()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::Connect(
    RPEngStorageClient& aStorageMainClient,
    const TDesC8& aSessionName )
    {
    PENG_DP_TXT( "RPEngStorageSubFolderClient::Connect()" );

    TIpcArgs messArguments;
    messArguments.Set( KMessageSlot0, &aSessionName );

    TInt err( RSubSessionBase::CreateSubSession(
                  aStorageMainClient,
                  EMainSessCreateFolderSubSession,
                  messArguments ) );

    iConnected = ( err == KErrNone ? ETrue : EFalse );
    return err;
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::Close()
// -----------------------------------------------------------------------------
//
void RPEngStorageSubFolderClient::Close()
    {
    PENG_DP_TXT( "RPEngStorageSubFolderClient::Close()" );


    CloseSubSession( EMainSessCloseSubSession );
    iConnected = EFalse;
    }


// =============================================================================
// ======================= Storage FUNCTIONS ===================================
// =============================================================================

// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::Store()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::Store(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType,
    const TDesC8& aData )
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    messArgs.Set( KMessageSlot2, &aData );
    return SendReceive( EFolderSubSessWriteEntry, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::Retrieve()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::Retrieve(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType,
    TDes8& aData )
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    messArgs.Set( KMessageSlot2, &aData );
    return SendReceive( EFolderSubSessReadEntry, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::Delete()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::Delete(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType )
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    return SendReceive( EFolderSubSessRemoveEntry, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::StoreEntryLocked()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::StoreEntryLocked(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType,
    TPengStorageLockPriority aPriority ) const
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    messArgs.Set( KMessageSlot2, aPriority );
    return SendReceive( EFolderSubSessIsEntryLocked, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::LockStoreEntry()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::LockStoreEntry(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType,
    TPengStorageLockPriority aPriority,
    TBool aCreateEntry ) const
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    // priority and Create flag will be transported as one TInt value
    TInt value( aPriority );
    value |= ( aCreateEntry  ? KLockEntryCreateMask : 0 );
    messArgs.Set( KMessageSlot2,  value );

    return SendReceive( EFolderSubSessLockEntry, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::UnlockStoreEntry()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::UnlockStoreEntry(
    const TDesC& aStoreId,
    TPEngStorageType aStoreType ) const
    {
    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aStoreId, aStoreType );
    return SendReceive( EFolderSubSessUnlockEntry, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::BufferServerSideNotifications()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::BufferServerSideNotifications(
    TInt aCount )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, aCount );
    return SendReceive( EFolderSubSessSuspendNotification, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::ReleaseServerSideBuffering()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::ReleaseServerSideBuffering(
    TInt aCount )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, aCount );
    return SendReceive( EFolderSubSessResumeNotification, messArgs );
    }


// =============================================================================
// ======================= NOTIFY FUNCTIONS ====================================
// =============================================================================


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::StartListeningSIdsChanges()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::StartListeningSIdsChanges(
    const TDesC& aEngagedSIds )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, &aEngagedSIds );
    return SendReceive( EFolderSubSessListenSIDsChanges, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::UpdateListenSIdsChangesScout()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::UpdateListenSIdsChangesScout(
    const TDesC& aEngagedSIds )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );
    messArgs.Set( KMessageSlot1, &aEngagedSIds );
    return SendReceive( EFolderSubSessUpdateListenSIDsScout, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::ReloadSIdsChangesScout()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::ReloadListenSIdsChangesScout(
    TRequestStatus& aStatus )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );
    SendReceive( EFolderSubSessReloadAsynchronousScout, messArgs, aStatus );
    return KErrNone;
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::FetchChangedSIdsIndexes()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::FetchChangedSIdsIndexes(
    TDes& aChangedIds )
    {
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( KMessageSlot0, EFolderSubSessListenSIDsChanges );
    messArgs.Set( KMessageSlot1, &aChangedIds );
    return SendReceive( EFolderSubSessFetchChangedSIDsIndexes, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::StopListeningSIdsChanges()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::StopListeningSIdsChanges()
    {
    // add Start listen ID to the message container,
    // this request is sort of cancel of request
    RETURN_IF_NOT_CONNECTED();
    TIpcArgs messArgs;
    messArgs.Set( 0, EFolderSubSessListenSIDsChanges );
    return SendReceive( EFolderSubSessCancelRequest, messArgs );
    }


// -----------------------------------------------------------------------------
// RPEngStorageSubFolderClient::NotifyChangedSIDsBlind()
// -----------------------------------------------------------------------------
//
TInt RPEngStorageSubFolderClient::NotifyChangedSIdBlind(
    const TDesC& aPackedChangedSId,
    TPEngStorageType aStoreType )
    {
    PENG_DP( D_PENG_LIT( "RPEngStorageSubFolderClient::NotifyChangedSIdBlind: %S" ),
             &aPackedChangedSId );

    RETURN_IF_NOT_CONNECTED();

    SET_MESSAGE_ARGUMENTS( aPackedChangedSId, aStoreType );

    return SendReceive( EFolderSubSessNotifyChangedSIDs, messArgs );
    }

//  End of File