/** @file
* Copyright (c) 2005-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:  Media Server event handler
*
*/


// INCLUDE FILES
#include "upnpmediaservereventhandler.h"
#include "upnpmediaserversession.h"
#include "upnpfiletransfereventlist.h"
#include "upnpfiletransferevent.h"
#include "upnpmediaserver.pan"
#include <s32mem.h>

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CUpnpMediaServerEventHandler* CUpnpMediaServerEventHandler::NewL(CUpnpMediaServer* aServer)
    {
    CUpnpMediaServerEventHandler* self = CUpnpMediaServerEventHandler::NewLC(aServer); 
    CleanupStack::Pop( self ) ;
    return self ;
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::NewLC
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CUpnpMediaServerEventHandler* CUpnpMediaServerEventHandler::NewLC(CUpnpMediaServer* aServer)
    {
    CUpnpMediaServerEventHandler* self = new (ELeave) CUpnpMediaServerEventHandler(aServer);
    CleanupStack::PushL( self );
    self->ConstructL() ;
    return self ;
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::EventMediaServerSubscribeEventsL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::EventMediaServerSubscribeEvents( const RMessage2& aMessage )
    {    
    iMediaServer->SubscribeEvents(this);
    aMessage.Complete( KErrNone );
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::EventMediaServerUnsubscribeEventsL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::EventMediaServerUnsubscribeEvents( const RMessage2& aMessage )
    {        
    if ( iListenRequestPending )
        {
        iCurrentMessage.Complete( KErrNone );
        }
    iMediaServer->UnsubscribeEvents(this);    
    aMessage.Complete( KErrNone );
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::EventMediaServerServerListenTransferEventL
// Serves event listening request
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::EventMediaServerServerListenTransferEventL( const RMessage2& aMessage )
    {    
    iCurrentMessage = aMessage;
    
    if ( iFileTransferEventList->GetPointerArray().Count() > 0 )
        {   
        ListenTransferEventCompleteL();
        }
    else
        {
        iListenRequestPending = ETrue;
        }    
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::EventMediaServerGetTransferEventBodyL
// Sends event list body to client
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::EventMediaServerGetTransferEventBodyL( const RMessage2& aMessage )
    {
    aMessage.WriteL(0, *iResponseBuffer);
    aMessage.Complete( KErrNone );
    delete iResponseBuffer;
    iResponseBuffer = NULL;
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::CUpnpMediaServerEventHandler
// Constructor.
// -----------------------------------------------------------------------------
//
CUpnpMediaServerEventHandler::CUpnpMediaServerEventHandler(CUpnpMediaServer* aServer)
    :iMediaServer(aServer), iRespLengthPkg(iRespLength)
    {
    }


// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::~CUpnpMediaServerEventHandler()
// Destructor.
// -----------------------------------------------------------------------------
//
CUpnpMediaServerEventHandler::~CUpnpMediaServerEventHandler()
    {
    if(iMediaServer)
        {        
        iMediaServer->UnsubscribeEvents(this);
        }
    delete iResponseBuffer;
    delete iFileTransferEventList;
    }


// -----------------------------------------------------------------------------
// CUpnpMediaServerSession::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::ConstructL()
    {
    iFileTransferEventList = CUpnpFileTransferEventList::NewL();
	}

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::FileTransferEvent
// File transfer event callback method.(from MUpnpContentDirectoryObserver)
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::FileTransferEvent( CUpnpFileTransferEvent *aEvent )
    {
    TRAP_IGNORE( ServeEventL( aEvent ) );
    }


// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::ServeEventL
// Serves incoming transfer event
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::ServeEventL(CUpnpFileTransferEvent *aEvent) 
    {
    iFileTransferEventList->GetPointerArray().AppendL( aEvent->CloneL() );
    if (iListenRequestPending)
        {
        ListenTransferEventCompleteL();
        }
    }

// -----------------------------------------------------------------------------
// CUpnpMediaServerEventHandler::ListenTransferEventCompleteL
// Serialize events queue and sends buffer length to client
// -----------------------------------------------------------------------------
//
void CUpnpMediaServerEventHandler::ListenTransferEventCompleteL()
    {
    iResponseBuffer = iFileTransferEventList->ToDes8L(); 
    iFileTransferEventList->GetPointerArray().ResetAndDestroy();
    iRespLength = iResponseBuffer->Des().Size();
    iCurrentMessage.WriteL(0, iRespLengthPkg);
    iCurrentMessage.Complete( KErrNone );
    iListenRequestPending = EFalse;
    }