/*

* Copyright (c) 2005 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:  Admin Sub-session class of the Storage Server

*

*/

// INCLUDE FILES

#include    <e32std.h>

#include	"CPEngAdminSubSession.h"

#include	"PEngStorageServerCommon.h"

#include	"CPEngStorageFolder.h"

#include	"CPEngSessionSlotState.h"

#include	"CPEngSessionSlotEvent.h"

#include	"PEngPresenceEngineConsts2.h"

#include	"MPEngStorageServer.h"

#include	"RPEngMessage.h"

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

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

// CPEngAdminSubSession::CPEngAdminSubSession

// C++ default constructor can NOT contain any code, that might leave.

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

//

CPEngAdminSubSession::CPEngAdminSubSession(

    MPEngStorageServer& aServer,

    TInt32 aSessionId )

        : iSessionId( aSessionId ),

        iServer( aServer )

    {

    }

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

// CPEngAdminSubSession::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CPEngAdminSubSession::ConstructL(

    const RPEngMessage& aMessage )

    {

    iStorageFolder = iServer.StorageFolderL( aMessage );

    }

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

// CPEngAdminSubSession::NewL

// Two-phased constructor.

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

//

CPEngAdminSubSession* CPEngAdminSubSession::NewL(

    MPEngStorageServer& aServer,

    const RPEngMessage& aMessage,

    TInt32 aSessionId )

    {

    CPEngAdminSubSession* self = NewLC( aServer, aMessage, aSessionId );

    CleanupStack::Pop(); // self

    return self;

    }

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

// CPEngAdminSubSession::NewLC

// Two-phased constructor.

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

//

CPEngAdminSubSession* CPEngAdminSubSession::NewLC(

    MPEngStorageServer& aServer,

    const RPEngMessage& aMessage,

    TInt32 aSessionId )

    {

    CPEngAdminSubSession* self = new( ELeave ) CPEngAdminSubSession(

        aServer,

        aSessionId );

    CleanupClosePushL( *self );

    self->ConstructL( aMessage );

    return self;

    }

// Destructor

CPEngAdminSubSession::~CPEngAdminSubSession()

    {

    // decrease count of the storage Folder

    TRAP_IGNORE( NotifySessionSlotCloseL() );

    if ( iStorageFolder )

        {

        // notify globally

        iStorageFolder->CancelSubSessionRequests( iSessionId, iHandle );

        iStorageFolder->Close();

        }

    }

// =============================================================================

// =============== Functions from base class ===================================

// =============================================================================

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

// CPEngAdminSubSession::DispatchMessageL()

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

//

TBool CPEngAdminSubSession::DispatchMessageL(

    const RPEngMessage& aMessage,

    TInt aRequest )

    {

    TBool completeMessage( ETrue );

    switch ( aRequest )

        {

            // ================ Admin  sub client requests ========================

            /*********************************************************************/

            /* Admin sub session requests                                        */

            /*********************************************************************/

            // Notify new global event

        case EAdminSubSessNotifyNewEvent:

            {

            NotifyGlobalEventL( aMessage );

            break;

            }

        // Check if passed App Id is registered for passed Session Slot

        case EAdminSubSessCheckAppIdRegistration:

            {

            CheckAppIdRegistrationL( aMessage );

            break;

            }

        case EAdminSubSessNotifyError:

            {

            NotifyError( aMessage );

            break;

            }

        default:

            {

            PanicClient( aMessage, ESSBadRequest );

            break;

            }

        }

    // check if message can be completed

    completeMessage &= aMessage.MessageValid();

    return completeMessage;

    }

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

// CPEngAdminSubSession::SetSubSesionHandle()

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

//

void CPEngAdminSubSession::SetSubSesionHandle(

    TInt aHandle )

    {

    iHandle = aHandle;

    }

// =============================================================================

// =============== Private Functions from base class ===========================

// =============================================================================

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

// CPEngAdminSubSession::PanicClient()

// Panic client

// (other items were commented in a header).

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

//

void CPEngAdminSubSession::PanicClient(

    const RPEngMessage& aMessage,

    const TInt aPanic ) const

    {

    aMessage.Panic( KStorageSessionName, aPanic );

    }

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

// CPEngAdminSubSession::NotifyGlobalEventL()

// Notify about new global event

// (other items were commented in a header).

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

//

void CPEngAdminSubSession::NotifyGlobalEventL(

    const RPEngMessage& aMessage )

    {

    // Try to unpack the event

    CPEngSessionSlotEvent* newEvent = CPEngSessionSlotEvent::NewLC();

    HBufC8* evetBuff = aMessage.ReadOneDescriptor8LC( KMessageSlot0 );

    newEvent->UnpackEventL( *evetBuff );

    // update state

    iStorageFolder->SessionSlotState().UpdateAndCommitStateL( *newEvent );

    iStorageFolder->CommiteStateUpdate();

    iServer.NotifyGlobalEvent( *evetBuff );

    CleanupStack::PopAndDestroy( 2 );

    }

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

// CPEngAdminSubSession::CheckAppIdRegistrationL()

// Notify Error to listeners

// (other items were commented in a header).

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

//

void CPEngAdminSubSession::NotifyError(

    const RPEngMessage& aMessage )

    {

    iServer.NotifyError( aMessage.Int0() );

    }

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

// CPEngAdminSubSession::CheckAppIdRegistrationL()

// Check application registration

// (other items were commented in a header).

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

//

void CPEngAdminSubSession::CheckAppIdRegistrationL(

    const RPEngMessage& aMessage )

    {

    HBufC* appId = aMessage.ReadOneDescriptor16LC( KMessageSlot0 );

    iStorageFolder->SessionSlotState().ApplicationRegisteredL( *appId );

    CleanupStack::PopAndDestroy(); // appId

    }

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

// CPEngAdminSubSession::NotifySessionSlotCloseL()

// Notify Global Session slot close

// (other items were commented in a header).

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

//

void CPEngAdminSubSession::NotifySessionSlotCloseL()

    {

    // Construct new Session slot event

    if ( !iStorageFolder )

        {

        return;

        }

    iStorageFolder->SessionSlotState().SetSessionSlotStateClosed();

    iStorageFolder->CommiteStateUpdate();

    CPEngSessionSlotEvent* newEvent = CPEngSessionSlotEvent::NewLC();

    newEvent->SetSessionSlotId(

        &( iStorageFolder->SessionSlotState().SessionSlotId() ),

        EFalse );

    HBufC8* eventBuff = newEvent->PackEventLC();

    iServer.NotifyGlobalEvent( *eventBuff );

    CleanupStack::PopAndDestroy( 2 ); // eventBuff, newEvent

    }

//  End of File