/** @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 dispatcher
*
*/


// INCLUDE FILES
#include <e32svr.h>
#include "upnpdispatcher.pan"
#include "upnpdispatcher.h"
#include "upnpdiscoveryobserver.h"
#include "upnpdispatcherengine.h"
#include "upnpstring.h"
#include "upnpsettings.h"
#include "upnpcustomlog.h"

#ifdef _DEBUG
#define KLogFile _L("UPnPStack.txt")
#endif

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

// -----------------------------------------------------------------------------
// CUpnpDispatcher::CUpnpDispatcher
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
//
CUpnpDispatcher::CUpnpDispatcher( MUpnpDiscoveryObserver* aParent)
    : iParent( aParent )
{
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CUpnpDispatcher::ConstructL( )
    {
    //  LOGSH(iHandle, "Dispatcher::ConstructL");

    iEngine = CUpnpDispatcherEngine::NewL( *this );
    iUpdateId = 0;

    iEngine->UpdateDevicesL(iUpdateId);
    }

// -----------------------------------------------------------------------------
// CUpnpDispatcher::NewL
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
EXPORT_C CUpnpDispatcher* CUpnpDispatcher::NewL( MUpnpDiscoveryObserver* aParent )
{
    CUpnpDispatcher* self = NewLC( aParent );
    CleanupStack::Pop( self );
    return( self );
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::NewLC
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
EXPORT_C CUpnpDispatcher* CUpnpDispatcher::NewLC( MUpnpDiscoveryObserver* aParent )
{
    CUpnpDispatcher* self = new (ELeave) CUpnpDispatcher( aParent );
    CleanupStack::PushL( self );
    self->ConstructL();

    if( aParent )
        {
        self->StartHttpServerL( EFalse , KRandomPort );
        }
    return self;
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::~CUpnpDispatcher
// Destructor.
// -----------------------------------------------------------------------------
//
EXPORT_C CUpnpDispatcher::~CUpnpDispatcher()
{
    delete iEngine;
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::DeviceListReceivedL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
void CUpnpDispatcher::DeviceListReceivedL(TInt aUpdateId)
{
    //LOGSH( iHandle, "Dispatcher DeviceListReceived");
    UpdateDevicesL(aUpdateId);
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::AddCustomer
// Adds a customer to this Dispatcher.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::AddCustomer( const MUpnpDispatcherCustomer& aCustomer )
{
    //LOGSH( iHandle, "Dispatcher AddCustomer");
    TRAP_IGNORE(AddCustomerL(aCustomer, ETrue ));
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::RemoveCustomer
// Removes a customer from Dispatcher.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::RemoveCustomer( const MUpnpDispatcherCustomer& aCustomer )
{
    RemoveCustomer(aCustomer, ETrue);
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::AddCustomer
// Adds a customer to this Dispatcher.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::AddCustomerL( const MUpnpDispatcherCustomer& aCustomer, TBool aIsCP)
{
    //LOGSH( iHandle, "Dispatcher AddCustomer");
    iEngine->AddCustomer( aCustomer );
    if (aIsCP)
        {
        iEngine->AddControlPointClientL( );
        }
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::RemoveCustomer
// Removes a customer from Dispatcher.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::RemoveCustomer( const MUpnpDispatcherCustomer& aCustomer,
                                               TBool aIsCP)
{
    LOGS1("CUpnpDispatcher::RemoveCustomer 0x%x", &aCustomer);
    iEngine->RemoveCustomer( aCustomer );
    if ( aIsCP )
        {
        TRAP_IGNORE(iEngine->RemoveControlPointClientL( ));
        }
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::SendMessageL
// Sends a message using Engine's HTTP server,
// if device is local (third param), used local sending feature, type of message has to be EAction
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::SendMessageL( CUpnpHttpMessage* aMessage,
                                             MUpnpDispatcherCustomer& aCustomer ,
                                             TBool /*aIsLocal*/ )
{
    //LOGSH( iHandle, "Dispatcher SendMessageL");

    TPtrC8 path(0,0);
    if (iParent != NULL)
        {
        path.Set(iParent->Path());
        }


    HBufC8* wholePath = HBufC8::NewLC( path.Length()
                                       + 1
                                       + aCustomer.Path().Length() );
    TPtr8 ptr = wholePath->Des();
    ptr.Append( path );
    ptr.Append( UpnpString::KSlash() );
    ptr.Append( aCustomer.Path() );

    if ( aMessage )
    {
        aMessage->SetSenderPathL( *wholePath );
        iEngine->SendMessageL( aMessage );
    }

    CleanupStack::PopAndDestroy(wholePath);
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::UpdateDevicesL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::UpdateDevicesL( TInt aNewId )
    {

    //LOGSH( iHandle, "Dispatcher UpdateDevicesL");
    if ( iUpdateId != aNewId )
        {
        // Go through the new devices and add them inform
        // the Control Point of the new devices?
        const RPointerArray<CUpnpDevice>& newDevices = iEngine->NewDevices();
        for ( TInt i = 0; i < newDevices.Count(); i++ )
            {
            CUpnpDevice* dev = newDevices[i];

            if ( iParent != NULL )
                {

                if ( dev->Alive() )
                    {
                    iParent->DeviceFoundL( *dev );
                    }
                else
                    {
                    iParent->DeviceLostL( *dev );
                    }
                }

            }
        iEngine->RemoveDevices();

        iUpdateId = aNewId;
        }
    }

// -----------------------------------------------------------------------------
// CUpnpDispatcher::AddLocalDeviceL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::AddLocalDeviceL( const TDesC8& aUuid,
                                                const TDesC8& aDeviceType,
                                                const TDesC8& aDescriptionPath,
                                                const CDesC8Array& aServices,
                                                const TBool aIsRootDevice )
{
    //LOGSH( iHandle, "Dispatcher AddLocalDeviceL");
    iEngine->AddLocalDeviceL( aUuid, aDeviceType, aDescriptionPath, aServices, aIsRootDevice );
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::RemoveLocalDeviceL
// -----------------------------------------------------------------------------
//
void CUpnpDispatcher::RemoveLocalDeviceL( const TDesC8& aUuid, TBool aSilent )
{
    //LOGSH( iHandle, "Dispatcher RemoveLocalDeviceL");
    iEngine->RemoveLocalDeviceL( aUuid, aSilent );
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::SearchL
// Sends a SSDP search with given string.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::SearchL( const TDesC8& aSearchString )
{
    iEngine->SsdpSearchL( aSearchString );
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::StopFilteringL
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::StopFilteringL( const TDesC8& aUuids )
{
    iEngine->SsdpStopFilteringL( aUuids );
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::SearchL
//
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::SearchL( const TDesC16& aSearchString )
{
    //LOGSH( iHandle, "Dispatcher SearchL");
    HBufC8* buf = UpnpString::FromUnicodeL( aSearchString );
    SearchL( *buf );
    delete buf;
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::HttpServerAddressL
// Returns the HTTP servers IP address.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C TInetAddr CUpnpDispatcher::HttpServerAddress()
    {
    return iEngine->HttpServerAddress();
    }

// -----------------------------------------------------------------------------
// CUpnpDispatcher::MacAddressL
// Returns the MAC address of HTTP server.
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
const HBufC8* CUpnpDispatcher::MacAddressL()
{
    //LOGSH( iHandle, "Dispatcher MacAddressL");
    return iEngine->MacAddressL();
}

// -----------------------------------------------------------------------------
// CUpnpDispatcher::SetTransactionCreator
// -----------------------------------------------------------------------------
//
void CUpnpDispatcher::SetTransactionCreator( 
          MUpnpHttpServerTransactionCreator* aTransactionCreator )
    {
    iEngine->SetTransactionCreator( aTransactionCreator );
    }

// -----------------------------------------------------------------------------
// CUpnpDispatcher::StartHttpServerL
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::StartHttpServerL( TBool aRegister , const TInt aPort )
    {
    iEngine->StartHttpServerL( aRegister , aPort );
    }

// -----------------------------------------------------------------------------
// CUpnpDispatcher::StopHttpServerL
// (other items were commented in a header).
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpDispatcher::StopHttpServer()
    {
    iEngine->StopHttpServer();
    }

EXPORT_C void CUpnpDispatcher::StartIPFilteringL( )
    {
    #ifdef RD_UPNP_REMOTE_ACCESS
    iEngine->HttpServer()->StartIPFilteringL();
    #endif
    }

EXPORT_C void CUpnpDispatcher::StopIPFiltering( )
    {
    #ifdef RD_UPNP_REMOTE_ACCESS
    iEngine->HttpServer()->StopIPFiltering( );
    #endif
    }

// End of File