/*
* Copyright (c) 2006-2006 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:  Defines a session with the preset server
*
*/


#include <pscommon.h>
#include <s32mem.h>

#include "psdebug.h"
#include "psserver.h"
#include "pssession.h"

// ======== LOCAL FUNCTIONS ========

// ======== MEMBER FUNCTIONS ========

// ---------------------------------------------------------------------------
// Two-phased constructor.
// ---------------------------------------------------------------------------
//
CPSSession* CPSSession::NewL( CPSServer& aServer )
    {
    CPSSession* self = new ( ELeave ) CPSSession( aServer );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop( self );
    return self;
    }

// ---------------------------------------------------------------------------
// Constructor.
// ---------------------------------------------------------------------------
//
CPSSession::CPSSession( CPSServer& aServer )
    : CSession2(), iPresetServer( aServer )
    {
    }

// ---------------------------------------------------------------------------
// Second-phase constructor.
// ---------------------------------------------------------------------------
//
void CPSSession::ConstructL()
    {
    iPresetServer.IncrementSessionCount();
    }
    
// ---------------------------------------------------------------------------
// Destructor.
// ---------------------------------------------------------------------------
//
CPSSession::~CPSSession()
    {
    iPresetServer.DecrementSessionCount();
    }

// ---------------------------------------------------------------------------
// From class CSession2
// Invoked when a service request is made.
// ---------------------------------------------------------------------------
//
void CPSSession::ServiceL( const RMessage2& aMessage )
    {
    PSDEBUG2( "CPSSession::ServiceL >> OpCode = %d", static_cast<TInt>( aMessage.Function() ) );

    TBool messageHandled = ETrue;

    TRAPD( err, messageHandled = DoServiceL( aMessage ) )
    
    if ( messageHandled && !aMessage.IsNull() )
        {
        PSDEBUG2( "\tMessage was handled >> err = %d", err );
        aMessage.Complete( err );
        }

    PSDEBUG( "CPSSession::ServiceL <<" );
    }

// ---------------------------------------------------------------------------
// Service request implementation.
// ---------------------------------------------------------------------------
//
TBool CPSSession::DoServiceL( const RMessage2& aMessage )
    {
    TPSOpCode opCode = static_cast<TPSOpCode>( aMessage.Function() );
    TBool messageHandled = ETrue;

    switch ( opCode )
        {
        case EPSOpCreatePreset:
            CreatePresetL( aMessage );
        break;
        case EPSOpDeletePreset:
            DeletePresetL( aMessage );
        break;
        case EPSOpStartTransaction:
            StartTransactionL( aMessage );
        break;
        case EPSOpCommitTransaction:
            CommitTransactionL( aMessage );
        break;
        case EPSOpRollbackTransaction:
            RollbackTransaction( aMessage );
        break;
        case EPSOpMovePreset:
            MovePresetL( aMessage );
        break;
        case EPSOpNotify:
            NotifyPresetChangeL( aMessage );
            messageHandled = EFalse;
        break;
        case EPSOpCancelNotify:
            CancelNotifyPresetChange( aMessage );
        break;
        case EPSOpSetPresetName:
            SetPresetNameL( aMessage );
        break;
        case EPSOpSetPresetIndex:
            SetPresetIndexL( aMessage );
        break;
        case EPSOpSetPresetData:
            SetPresetDataL( aMessage );
        break;
        case EPSOpGetPresetName:
            GetPresetNameL( aMessage );
        break;
        case EPSOpGetPresetNameLength:
            GetPresetNameLengthL( aMessage );
        break;
        case EPSOpGetPresetIndex:
            GetPresetIndexL( aMessage );
        break;
        case EPSOpGetPresetDataHandler:
            GetPresetDataHandlerL( aMessage );
        break;
        case EPSOpGetPresetData:
            GetPresetDataL( aMessage );
        break;
        case EPSOpGetPresetDataLength:
            GetPresetDataLengthL( aMessage );
        break;
        case EPSOpGetPresets:
            GetPresetsL( aMessage );
        break;
        case EPSOpGetPresetsLength:
            GetPresetsLengthL( aMessage );
        break;
        default:
            iPresetServer.PanicClient( KErrArgument );
        break;
        }

    return messageHandled;
    }

// ---------------------------------------------------------------------------
// From class CSession2
// Invoked when a session is disconnected.
// ---------------------------------------------------------------------------
//
void CPSSession::Disconnect(const RMessage2 &aMessage)
    {
    iPresetServer.SessionDisconnected( aMessage );
    
    CSession2::Disconnect( aMessage );
    }

// ---------------------------------------------------------------------------
// Handles a create preset message.
// ---------------------------------------------------------------------------
//
void CPSSession::CreatePresetL( const RMessage2& aMessage )
    {
    TInt id = iPresetServer.Database().CreatePresetL( aMessage.Int0(), TUid::Uid( aMessage.Int1() ) );
    TPckgBuf<TInt> idBuf( id );
    aMessage.WriteL( 2, idBuf );
    }

// ---------------------------------------------------------------------------
// Handles a delete preset message.
// ---------------------------------------------------------------------------
//
void CPSSession::DeletePresetL( const RMessage2& aMessage )
    {
    iPresetServer.Database().DeletePresetL( aMessage.Int0() );
    }

// ---------------------------------------------------------------------------
// Handles a start transaction message.
// ---------------------------------------------------------------------------
//
void CPSSession::StartTransactionL( const RMessage2& aMessage )
    {
    iPresetServer.AppendPendingPresetL( aMessage.Int0() );
    }

// ---------------------------------------------------------------------------
// Handles a commit transaction message.
// ---------------------------------------------------------------------------
//
void CPSSession::CommitTransactionL( const RMessage2& aMessage )
    {
    iPresetServer.CommitPendingPresetL( aMessage.Int0() );
    }

// ---------------------------------------------------------------------------
// Handles a rollback transaction message.
// ---------------------------------------------------------------------------
//
void CPSSession::RollbackTransaction( const RMessage2& aMessage )
    {
    iPresetServer.RemovePendingPreset( aMessage.Int0() );
    }

// ---------------------------------------------------------------------------
// Handles a move preset message.
// ---------------------------------------------------------------------------
//
void CPSSession::MovePresetL( const RMessage2& aMessage )
    {
    iPresetServer.Database().MovePresetL( aMessage.Int0(), aMessage.Int1() );
    }

// ---------------------------------------------------------------------------
// Handles a notify preset change message.
// ---------------------------------------------------------------------------
//
void CPSSession::NotifyPresetChangeL( const RMessage2& aMessage )
    {
    iPresetServer.AppendPresetObserverL( aMessage );
    }

// ---------------------------------------------------------------------------
// Handles a cancel notify preset change message.
// ---------------------------------------------------------------------------
//
void CPSSession::CancelNotifyPresetChange( const RMessage2& aMessage )
    {
    iPresetServer.RemovePresetObserver( aMessage );
    }

// ---------------------------------------------------------------------------
// Handles a set preset name message.
// ---------------------------------------------------------------------------
//
void CPSSession::SetPresetNameL( const RMessage2& aMessage )
    {
    HBufC* name = HBufC::NewLC( aMessage.GetDesLengthL( 1 ) );
    TPtr namePtr( name->Des() );
    aMessage.ReadL( 1, namePtr );
    iPresetServer.SetPendingPresetNameL( aMessage.Int0(), namePtr );
    CleanupStack::PopAndDestroy( name );
    }

// ---------------------------------------------------------------------------
// Handles a set preset index message.
// ---------------------------------------------------------------------------
//
void CPSSession::SetPresetIndexL( const RMessage2& aMessage )
    {
    iPresetServer.SetPendingPresetIndexL( aMessage.Int0(), aMessage.Int1() );
    }

// ---------------------------------------------------------------------------
// Handles a set preset data message.
// ---------------------------------------------------------------------------
//
void CPSSession::SetPresetDataL( const RMessage2& aMessage )
    {
    HBufC8* data = HBufC8::NewLC( aMessage.GetDesLengthL( 1 ) );
    TPtr8 dataPtr( data->Des() );
    aMessage.ReadL( 1, dataPtr );
    iPresetServer.SetPendingPresetDataL( aMessage.Int0(), dataPtr );
    CleanupStack::PopAndDestroy( data );
    }

// ---------------------------------------------------------------------------
// Handles a get preset name message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetNameL( const RMessage2& aMessage )
    {
    HBufC* name = iPresetServer.Database().PresetNameL( aMessage.Int0() );
    CleanupStack::PushL( name );
    aMessage.WriteL( 1, *name );
    CleanupStack::PopAndDestroy( name );
    }

// ---------------------------------------------------------------------------
// Handles a get preset name length message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetNameLengthL( const RMessage2& aMessage )
    {
    TInt length = iPresetServer.Database().PresetNameLengthL( aMessage.Int0() );
    TPckgBuf<TInt> pckg( length );
    aMessage.WriteL( 1, pckg );
    }

// ---------------------------------------------------------------------------
// Handles a get preset index message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetIndexL( const RMessage2& aMessage )
    {
    TPckgBuf<TInt> pckg( iPresetServer.Database().PresetIndexL( aMessage.Int0() ) );
    aMessage.WriteL( 1, pckg );
    }

// ---------------------------------------------------------------------------
// Handles a get preset data handler message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetDataHandlerL( const RMessage2& aMessage )
    {
    TPckgBuf<TInt> pckg( iPresetServer.Database().PresetDataHandlerL( aMessage.Int0() ).iUid );
    aMessage.WriteL( 1, pckg );
    }

// ---------------------------------------------------------------------------
// Handles a get preset data message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetDataL( const RMessage2& aMessage )
    {
    HBufC8* data = iPresetServer.Database().PresetDataL( aMessage.Int0() );
    CleanupStack::PushL( data );
    aMessage.WriteL( 1, *data );
    CleanupStack::PopAndDestroy( data );
    }

// ---------------------------------------------------------------------------
// Handles a get preset data length message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetDataLengthL( const RMessage2& aMessage )
    {
    TInt length = iPresetServer.Database().PresetDataLengthL( aMessage.Int0() );
    TPckgBuf<TInt> pckg( length );
    aMessage.WriteL( 1, pckg );
    }

// ---------------------------------------------------------------------------
// Handles a get presets message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetsL( const RMessage2& aMessage )
    {
    RArray<TInt> presets;
    CleanupClosePushL( presets );
    
    iPresetServer.Database().GetPresetListL( presets, TUid::Uid( aMessage.Int0() ) );

    TInt count = presets.Count();

    HBufC8* buf = HBufC8::NewLC( (presets.Count() + 1) * KDefaultRealWidth );
    TPtr8 ptr( buf->Des() );
    
    RDesWriteStream stream( ptr );
    CleanupClosePushL( stream );

    stream << TCardinality( count );
    
    for ( TInt i = 0; i < count; i++ )
        {
        stream.WriteInt32L( presets[i] );
        }
    
    stream.CommitL();

    aMessage.WriteL( 1, *buf );
    
    CleanupStack::PopAndDestroy( 3, &presets );
    }

// ---------------------------------------------------------------------------
// Handles a get presets length message.
// ---------------------------------------------------------------------------
//
void CPSSession::GetPresetsLengthL( const RMessage2& aMessage )
    {
    RArray<TInt> presets;
    CleanupClosePushL( presets );
    
    iPresetServer.Database().GetPresetListL( presets, TUid::Uid( aMessage.Int0() ) );

    aMessage.WriteL( 1, TPckgC<TInt>( (presets.Count() + 1) * KDefaultRealWidth ) );
    
    CleanupStack::PopAndDestroy( &presets );
    }

// ======== GLOBAL FUNCTIONS ========