/** @file
* Copyright (c) 2008-2008 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:  Implements algoritms for initial events
*
*/


#include "upnpinitialeventqueuemanager.h"
#include "upnpgenamessagefactory.h"
#include "upnphttpinitialeventtransaction.h"
#include "upnpcommonupnplits.h"
#include "upnpcommonstructs.h"


#define KLogFile _L("UPnPStack.txt")
#include "upnpcustomlog.h"


// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::CUpnpInitialEventQueueManager
// -----------------------------------------------------------------------------
//
CUpnpInitialEventQueueManager::CUpnpInitialEventQueueManager( 
                                            CUpnpServiceImplementation& aServiceImpl,
                                            CUpnpEventController& aEventController,
                                            CUpnpSubscriberLibrary* aSubscriberLibrary
                                                             )
    :CUpnpEventQueueManagerBase( aServiceImpl, aEventController, aSubscriberLibrary )
    {
    // No implementation required
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::~CUpnpInitialEventQueueManager
// -----------------------------------------------------------------------------
//
CUpnpInitialEventQueueManager::~CUpnpInitialEventQueueManager()
    {
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::NewLC
// -----------------------------------------------------------------------------
//
CUpnpInitialEventQueueManager* CUpnpInitialEventQueueManager::NewLC( 
                                           CUpnpServiceImplementation& aServiceImpl,
                                           CUpnpEventController& aEventController,
                                           CUpnpSubscriberLibrary* aSubscriberLibrary 
                                                                    )
    {
    CUpnpInitialEventQueueManager* self = 
        new (ELeave) CUpnpInitialEventQueueManager( aServiceImpl, 
                                                    aEventController, 
                                                    aSubscriberLibrary );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }
    
// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::NewL
// -----------------------------------------------------------------------------
//    
CUpnpInitialEventQueueManager* CUpnpInitialEventQueueManager::NewL( 
                                          CUpnpServiceImplementation& aServiceImpl,
                                          CUpnpEventController& aEventController,
                                          CUpnpSubscriberLibrary* aSubscriberLibrary 
                                                                   )
    {
    CUpnpInitialEventQueueManager* self= CUpnpInitialEventQueueManager::NewLC( 
                                                            aServiceImpl, 
                                                            aEventController, 
                                                            aSubscriberLibrary 
                                                                              );
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::ConstructL
// -----------------------------------------------------------------------------
//
void CUpnpInitialEventQueueManager::ConstructL()
    {
    BaseConstructL();
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::SendEvent
// -----------------------------------------------------------------------------
//
void CUpnpInitialEventQueueManager::SendEvent()
    {
    TRAP_IGNORE( SendEventL() );
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::SendEventL
// -----------------------------------------------------------------------------
//   
void CUpnpInitialEventQueueManager::SendEventL()
    {
    // Initial event is sent to subscriber which is last on the list
    // it has been just added into it
    //
    TInt lastSubscriberIndex( iSubscriberLibrary->SubscriberLibrary().Count() - 1 );
    
    if ( iBody )
        {
        delete iBody;
        iBody =NULL;
        }
         
    iBody = CreateEventL( iServiceImpl.StateVariableList() );
    
    PrepareTransactionAndStartSendingL( lastSubscriberIndex );   
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::CreateTransactionL
// -----------------------------------------------------------------------------
//
CUpnpHttpTransaction* CUpnpInitialEventQueueManager::CreateTransactionL( CUpnpHttpMessage* aMessage )
    {
    return CUpnpHttpInitialEventTransaction::NewL( aMessage );
    }

// -----------------------------------------------------------------------------
// CUpnpInitialEventQueueManager::FillEventBody
// -----------------------------------------------------------------------------
//
TInt CUpnpInitialEventQueueManager::FillEventBodyL( TDes8& aEvent, 
                                              const RPointerArray<CUpnpStateVariable>& aVariableList 
                                                   )
    {
    TInt eventableVariableCount(0);        
    for ( TInt i = 0; i < aVariableList.Count(); i++ )
        {
        if (   aVariableList[i]->Eventable().CompareF( KYes() ) == 0 
            && aVariableList[i]->ReadyForEventing() )
            {                            
            AddVariableToEventBody( aEvent , aVariableList[i] );
        
            eventableVariableCount++;
            }  
        }
    return eventableVariableCount;
    }
//end if file