/** @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:  CUpnpHttpServerRuntime is a single runtime.
*
*/

#include "upnphttpserverruntime.h"
#include "upnpconnectionmanagerproxy.h"
#include "upnphttpserver.h"
#include "upnpsettings.h"

static const TUint KSocketServerConnectionSlots = 60;

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::CUpnpHttpServerRuntime
// -----------------------------------------------------------------------------
//
CUpnpHttpServerRuntime::CUpnpHttpServerRuntime( TUint /*aUnusedIapId*/,
                                                MUpnpHttpServerObserver& aObserver ):
    iObserver( aObserver )                                               
    {
    // No implementation required
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::~CUpnpHttpServerRuntime
// -----------------------------------------------------------------------------
//
CUpnpHttpServerRuntime::~CUpnpHttpServerRuntime()
    {
    delete iHttpServer;
    CloseSocketServer();
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::NewLC
// -----------------------------------------------------------------------------
//
CUpnpHttpServerRuntime* CUpnpHttpServerRuntime::NewLC( 
    TUint aUnusedIapId, MUpnpHttpServerObserver& aObserver )
    {
    CUpnpHttpServerRuntime* self = new (ELeave) CUpnpHttpServerRuntime( aUnusedIapId, aObserver );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::NewL
// -----------------------------------------------------------------------------
//
CUpnpHttpServerRuntime* CUpnpHttpServerRuntime::NewL( 
    TUint aUnusedIapId, MUpnpHttpServerObserver& aObserver )
    {
    CUpnpHttpServerRuntime* self = CUpnpHttpServerRuntime::NewLC( aUnusedIapId, aObserver );
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::ConstructL
// -----------------------------------------------------------------------------
//
void CUpnpHttpServerRuntime::ConstructL()
    {    
    // connecting to needed servers
    OpenSocketServerL();
    GetIapAndStartServerL();
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::GetIapAndStartServer
// -----------------------------------------------------------------------------
//    
void CUpnpHttpServerRuntime::GetIapAndStartServerL()
    {       
    // Gets IAP
    CUpnpConnectionManagerProxy *proxy = CUpnpConnectionManagerProxy::NewLC( iSocketServ );
    User::LeaveIfError( proxy->EnsureStart() );
    TInt iap = proxy->ActiveIap();    
    
    TInt bufferSize = CUpnpSettings::GetFileBufferSizeL();
    // creating Http server
    iHttpServer = CUpnpHttpServer::NewL( &iObserver, &iSocketServ, iap );
    iHttpServer->SetFileReadBufferSize( bufferSize );
    iHttpServer->SetFileWriteBufferSize( bufferSize );
    
    CleanupStack::PopAndDestroy( proxy );
    }
    
// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::SetCreator
// -----------------------------------------------------------------------------
//
EXPORT_C void CUpnpHttpServerRuntime::SetCreator( MUpnpHttpServerTransactionCreator& aCreator )
    {
    iTransactionCreator = &aCreator;
    iHttpServer->SetTransactionCreator( &aCreator );
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::HttpServer
// -----------------------------------------------------------------------------
//
CUpnpHttpServer& CUpnpHttpServerRuntime::HttpServer()
    {
    return *iHttpServer; 
    }

// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::DeleteServer
// -----------------------------------------------------------------------------
//
void CUpnpHttpServerRuntime::DeleteServer()
    {
    if ( iHttpServer )
        {
        // server should be stopped to notify failed transfers
        iHttpServer->Stop();
        delete iHttpServer;
        iHttpServer = NULL;   
        CloseSocketServer();
        }    
    }
    
// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::StartServerL
// -----------------------------------------------------------------------------
//
void CUpnpHttpServerRuntime::StartServerL(  const TInt aPort )
    {
    OpenSocketServerL();  
    if ( !iHttpServer )
        {
        GetIapAndStartServerL();
        }
    iHttpServer->SetTransactionCreator( iTransactionCreator );  
    iHttpServer->StartL( aPort );
    }
    
// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::OpenSocketServerL
// -----------------------------------------------------------------------------
//
void CUpnpHttpServerRuntime::OpenSocketServerL()
    {
    if ( !iIsSocketOpened )
        {
        User::LeaveIfError( iSocketServ.Connect( KSocketServerConnectionSlots ) );
        iIsSocketOpened = ETrue;
        }
    }
    
// -----------------------------------------------------------------------------
// CUpnpHttpServerRuntime::CloseSocketServer
// -----------------------------------------------------------------------------
//
void CUpnpHttpServerRuntime::CloseSocketServer()
    {
    iSocketServ.Close();
    iIsSocketOpened = EFalse;
    }