/** @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:  Message handler
 *
 */

// INCLUDE FILES
#include "upnpmessagehandler.h"
#define KLogFile _L("UpnpMessageHandler.txt")
#include "upnpcustomlog.h"

const TVersion KServerSupportedVersion( KMessageHandlerMajorVersionNumber,
    KMessageHandlerMinorVersionNumber, KMessageHandlerBuildVersionNumber );

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

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::CUpnpMessageHandler
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CUpnpMessageHandler::CUpnpMessageHandler()
    {
    LOG_FUNC_NAME;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::~CUpnpMessageHandler
// Destructor.
// -----------------------------------------------------------------------------
//
CUpnpMessageHandler::~CUpnpMessageHandler()
    {
    LOG_FUNC_NAME;
    iObservers.Close();
    delete iEngine;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::NewLC
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CUpnpSymbianServerBase* CUpnpMessageHandler::NewLC()
    {
    LOG_FUNC_NAME;
    CUpnpMessageHandler* messageHandler = new (ELeave) CUpnpMessageHandler();
    CleanupStack::PushL( messageHandler );
    messageHandler->ConstructL() ;
    return messageHandler;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::ConstructL()
    {
    LOG_FUNC_NAME;
    BaseConstructL();
    iEngine = CUpnpMessageHandlerEngine::NewL( *this );
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::ServerName
// Return name of the server
// -----------------------------------------------------------------------------
//
const TDesC& CUpnpMessageHandler::ServerName() const
    {
    return KMessageHandlerName;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::NewSessionL
// Create new session.
// -----------------------------------------------------------------------------
//
CSession2* CUpnpMessageHandler::NewSessionL( const RMessage2& /*aMsg*/) const
    {
    LOG_FUNC_NAME;
    return CUpnpMessageHandlerSession::NewL(
        *const_cast<CUpnpMessageHandler*> ( this ), *iEngine );
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::SupportedVersion
// Gets server supported version.
// -----------------------------------------------------------------------------
//
TVersion CUpnpMessageHandler::SupportedVersion() const
    {
    return KServerSupportedVersion;
    }

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

// -----------------------------------------------------------------------------
// E32Main entry point.
// Returns: KErrNone
// -----------------------------------------------------------------------------
//
TInt E32Main()
    {
    return CUpnpMessageHandler::StartServer( KMessageHandlerThreadName,
        CUpnpMessageHandler::NewLC );
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::DeviceListUpdateL
// Update device list.
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::DeviceListUpdateL()
    {
    LOG_FUNC_NAME;
    // Inform every Observer (every session) that the device list has changed
    for ( TInt i(0); i < iObservers.Count(); i++ )
        {
        iObservers[i]->DeviceListChangeL();
        }
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::AddObserverL
// Add observer.
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::AddObserverL( MMessageHandlerObserver* aObserver )
    {
    LOG_FUNC_NAME;
    iObservers.InsertL( aObserver, iObservers.Count() );
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::RemoveObserver
// Remove observer.
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::RemoveObserver( MMessageHandlerObserver* aObserver )
    {
    LOG_FUNC_NAME;
    LOGS1( "CUpnpMessageHandler::RemoveObserver - Count: %d", iObservers.Count());

    for ( TInt i(0); i < iObservers.Count(); i++ )
        {
        if ( iObservers[i] == aObserver )
            {
            LOGS1( "CUpnpMessageHandler::RemoveObserver - Removed osb: %d",i);
            iObservers.Remove( i );
            iObservers.Compress();
            }
        }
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::RunError
// RunError is called when RunL leaves.
// -----------------------------------------------------------------------------
//
TInt CUpnpMessageHandler::RunError( TInt aError )
    {
    LOG_FUNC_NAME;
    iStartingError = aError;
    return CUpnpSymbianServerBase::RunError( aError );
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::IsSsdpStarted
// Set function for iSsdpStarted
// -----------------------------------------------------------------------------
//     
TBool CUpnpMessageHandler::IsSsdpStarted()
    {
    return iSsdpStarted;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::GetError
// -----------------------------------------------------------------------------
//
TInt CUpnpMessageHandler::StartingError()
    {
    return iStartingError;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::SetStarted
// Set function for iSsdpStarted
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::SetSsdpStarted( TBool aStarted )
    {
    iSsdpStarted = aStarted;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::Sessions
// Returns client sessions
// -----------------------------------------------------------------------------
//
TDblQueIter< CSession2 >& CUpnpMessageHandler::Sessions()
    {
    return iSessionIter;
    }

// -----------------------------------------------------------------------------
// CUpnpMessageHandler::IPListChange
// Notify all observers
// -----------------------------------------------------------------------------
//
void CUpnpMessageHandler::IPListChange()
    {
#ifdef RD_UPNP_REMOTE_ACCESS
    for(TInt i(0); i < iObservers.Count(); i++)
        {
        iObservers[i]->IPListChange();
        }
#endif    
    }

// End of File