/** @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 nonmodereted events
*
*/


#include "upnpnonmoderatedeventqueuemanager.h"
#include "upnpgenamessagefactory.h"
#include "upnphttpnonmoderatedeventtransaction.h"
#include "upnpcommonupnplits.h"
#include "upnpcommonstructs.h"


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


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

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

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

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

// -----------------------------------------------------------------------------
// CUpnpNonModeratedEventQueueManager::SendEvent
// -----------------------------------------------------------------------------
//
void CUpnpNonModeratedEventQueueManager::SendEvent()
    {
    TRAPD( err, SendEventL() );
    if( err )
        {
        SendingCompleted();
        }
    }

// -----------------------------------------------------------------------------
// CUpnpNonModeratedEventQueueManager::SendEventL
// -----------------------------------------------------------------------------
//   
void CUpnpNonModeratedEventQueueManager::SendEventL()
    {
    if ( ! iSubscriberLibrary->SubscriberLibrary().Count() )
        {
        return;
        }
     
    if ( iIsSending ) 
        {
        iNewValuesWaitingToBeSend = ETrue;
        return;
        }
    
    iIsSending = ETrue;
     
    iCurrentSubscriberIndex = 0;
    for ( TInt i = 0; i < iServiceImpl.EventedStateVariables().Count(); i++ )
        {
        if ( iServiceImpl.EventedStateVariables()[i]->MaxEventRate() > 0 )
            {
            iServiceImpl.EventedStateVariables()[i]->EventTick();
            }
        }
            
    delete iBody;
    iBody =NULL;
         
    iBody = CreateEventL( iServiceImpl.StateVariableList() );
        
    PrepareTransactionAndStartSendingL( KFirstSubscriberInQueue );
    }

   
// -----------------------------------------------------------------------------
// CUpnpNonModeratedEventQueueManager::CreateTranscationL
// -----------------------------------------------------------------------------
//
CUpnpHttpTransaction* CUpnpNonModeratedEventQueueManager::CreateTransactionL( CUpnpHttpMessage* aMessage )
    {
    return CUpnpHttpNonModeratedEventTransaction::NewL( aMessage, *this );
    }

// -----------------------------------------------------------------------------
// CUpnpNonModeratedEventQueueManager::FillEventBodyL
// -----------------------------------------------------------------------------
//
TInt CUpnpNonModeratedEventQueueManager::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() 
            &&!aVariableList[i]->IsModerated() )
            {                            
            AddVariableToEventBody( aEvent , aVariableList[i] );
                                              
            iServiceImpl.StateVariableEvented( aVariableList[i]->Name() );        
            eventableVariableCount++;
            }  
        }
    return eventableVariableCount;
    }
//end of file