/*
* Copyright (c) 2007 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:   
*
*/




#include "natfwcallbackinfo.h"
#include "natfwclientlogs.h"
#include "mnatfwregistrationcontroller.h"

#ifdef _DEBUG
_LIT16( KPanicArgument, "invalid argument" );
#endif

// ---------------------------------------------------------------------------
// CNatFwCallbackInfo::CNatFwCallbackInfo
// ---------------------------------------------------------------------------
//
CNatFwCallbackInfo::CNatFwCallbackInfo(
    MNATFWRegistrationController& aController,
    CNatFwCallbackInfo::TFunction aFunction, TUint aSessionId,
    TUint aStreamId, TInt aErrorCode, TAny* aEventData ) :
    iLink(),
    iController( aController ),
    iFunction( aFunction ),
    iSessionId( aSessionId ),
    iStreamId( aStreamId ),
    iErrorCode( aErrorCode ),
    iEventData( aEventData )
    {

    }


// ----------------------------------------------------------------------------
// CNatFwCallbackInfo::Validate
// ----------------------------------------------------------------------------
//
TBool CNatFwCallbackInfo::Validate() const
    {
    __NATFWCLIENT( "CNatFwCallbackInfo::Validate()" )

    switch ( iFunction )
        {
        case ECreatedSession:
        case ELocalCandidateFound:
        case ECandidatePairFound:
            return iSessionId;

        case EFetchingEnd:
        case EActiveReceiving:
        case EDeactiveReceiving:
        case EActiveSending:
        case EDeactiveSending:
        case ECompletedConnChecks:
            return iSessionId && iStreamId;

        case EError:
            return iSessionId && iStreamId && ( iErrorCode != KErrNone );

        default:
            return EFalse;
        }
    }


// ---------------------------------------------------------------------------
// CNatFwCallbackInfo::Execute
// ---------------------------------------------------------------------------
//
void CNatFwCallbackInfo::Execute() const
    {
    __NATFWCLIENT_INT1( "CNatFwCallbackInfo::Execute() in - Function:",
        iFunction )
    __ASSERT_DEBUG( Validate(),
        User::Panic( KPanicArgument, KErrArgument ) );

    switch ( iFunction )
        {
        case ECreatedSession:
            PassEvent( MNATFWConnectivityObserver::ESessionCreated );
            break;

        case EFetchingEnd:
            PassEvent( MNATFWConnectivityObserver::EFetchingCompleted );
            break;

        case EActiveReceiving:
            PassEvent( MNATFWConnectivityObserver::EReceivingActivated );
            break;

        case EDeactiveReceiving:
            PassEvent( MNATFWConnectivityObserver::EReceivingDeactivated );
            break;

        case EActiveSending:
            PassEvent( MNATFWConnectivityObserver::ESendingActivated );
            break;

        case EDeactiveSending:
            PassEvent( MNATFWConnectivityObserver::ESendingDeactivated );
            break;

        case ECompletedConnChecks:
            PassEvent( MNATFWConnectivityObserver::EConnChecksCompleted );
            break;

        case ELocalCandidateFound:
            PassEvent( MNATFWConnectivityObserver::ELocalCandidateFound );
            break;

        case ECandidatePairFound:
            PassEvent( MNATFWConnectivityObserver::ECandidatePairFound );
            break;

        case EError:
            PassEvent( MNATFWConnectivityObserver::EGeneralError );
            break;

        default:
            ASSERT( EFalse );
        }

    __NATFWCLIENT( "CNatFwCallbackInfo::Execute() out" )
    }


// ---------------------------------------------------------------------------
// CNatFwCallbackInfo::PassEvent
// ---------------------------------------------------------------------------
//
void CNatFwCallbackInfo::PassEvent(
    MNATFWConnectivityObserver::TNATFWConnectivityEvent aEvent ) const
    {
    RArray<TNATFWEventRegistration> registry = iController.Registry();
    for ( TInt i(0); i < registry.Count(); ++i )
        {
        if ( registry[i].Events() & aEvent )
            {
            // Observer registered for this event
            registry[i].Observer().EventOccured( iSessionId, iStreamId,
                aEvent, iErrorCode, iEventData );
            }
        }
    }