/*

* 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:    ICE Communication tests

*

*/

#ifndef NATCOMTEST_H

#define NATCOMTEST_H

#include <e32base.h>

#include "natfwconnectivityapidefs.h"

#include "mnatfwconnectivityobserver.h"

#include "natcomteststate.h"

class CNATFWConnectivityApi;

class MNatComTestObserver;

class CNATFWCredentials;

class CNATFWCandidatePair;

class CNATFWCandidate;

class CConsoleBase;

class CMccMediaStream;

class CMccLink;

class CMccSession;

class MNATFWSocketMediaConnWrapper;

class TInetAddr;

class CDesC8Array;

enum TComTestType

    {

    EIceComTest = 0,

    EStunComTest,

    ETurnComTest

    };

class CNatComTest :

    public CActive,

    public MNATFWConnectivityObserver

    {

public:

    static CNatComTest* NewL( const TDesC8& aDomain, TUint32 aIapId,

        MNatComTestObserver& aObserver );

    static CNatComTest* NewLC( const TDesC8& aDomain, TUint32 aIapId,

        MNatComTestObserver& aObserver );

    virtual ~CNatComTest();

    TInt StartComTest( TUint aProtocol, TComTestType aTestType,

        TBool aUseRtcp );

    TInt OnlyFetchCandidates( TUint aProtocol );

    TInt StartUsingIce( TUint aProtocol,

        TNATFWIceRole aRole, TBool aUseRtcp = EFalse );

    TInt StoreLocalCondidates( TUint aProtocol, TBool aUseRtcp = EFalse );

    TInt StoreLocalCandidate( TUint aProtocol,

            TComTestType aTestType, TBool aUseRtcp );

    void StopL();

protected:

    TInt Start( TUint aProtocol, TNATFWIceRole aRole );

// from CActive

    void RunL();

    void DoCancel();

// from base class MNATFWConnectivityObserver

    void EventOccured( TUint aSessionId, TUint aStreamId,

        TNATFWConnectivityEvent aEvent, TInt aError, TAny* aEventData );

private:

    CNatComTest( TUint32 aIapId, MNatComTestObserver& aObserver );

    void ConstructL( const TDesC8& aDomain );

    void ActiveRequestCompleted( TInt aError );

    const TInetAddr RemoteCandidateAddrByStreamIdL( TUint aStreamId );

    void GetCandidatesAssosiatedToL( TInt aStreamCollectionId,

        TInt aComponentId, const RPointerArray<CNATFWCandidate>& aSource,

        RPointerArray<CNATFWCandidate>& aTarget );

    void GetCandidatesAssosiatedToL( TInt aMediaComponentId,

        const RPointerArray<CNATFWCandidate>& aSource,

        RPointerArray<CNATFWCandidate>& aTarget );

    const CNATFWCandidate& IceLocalCandidateByStreamIdL( TUint aStreamId );

    const CNATFWCandidate& LocalCandidateByStreamIdL( TUint aStreamId );

    void SetToCandidatesL( TUint aSessionId, TInt aStreamId, 

        RPointerArray<CNATFWCandidate>& aTarget );

    void SetTeardownSequence( TInt aTestType, TBool aUseRtcp );

    void CreateSession();

    void LoadPlugin();

    void CreateRtpStream();

    void CreateRtcpStream();

    void SetIdentification();

    void FetchRtpCandidates();

    void FetchRtcpCandidates();

    void FetchRtpCandidate();

    void FetchRtcpCandidate();

    void SetOperationMode();

    void PerformConnectivityChecks();

    void CreateRtpWrapper();

    void CreateRtcpWrapper();

    void PrepareMccLink();

    void PrepareMccLinkWithRtcp();

    void SetWrapperIncomingAddr();

    void SetReceivingState( MNATFWSocketMediaConnWrapper& aWrapper,

        TUint aStreamId, TNATFWStreamingState aStreamingState );

    void SetSendingState( MNATFWSocketMediaConnWrapper& aWrapper,

        TUint aStreamId, TNATFWStreamingState aStreamingState,

        TInt aTestType, TBool aRtcp );

    void CreateMediaUpStream();

    void CreateMediaDownStream();

    void StartMediaUpStream();

    void StartMediaDownStream();

    TInt SetSendingStatus( TUint aStreamId,

        TNATFWStreamingState aState, const TInetAddr& aDestAddr );

    TInt SetReceivingStatus( TUint aStreamId, TNATFWStreamingState aState );

    void TeardownL();

private: // data

    TUint32 iIapId;

    MNatComTestObserver& iObserver;

    TUint iProtocol;

    CNATFWConnectivityApi* iNat;

    HBufC8* iDomain;

    TUint iSessionId;

    TUint iRtpStreamId;

    TUint iRtcpStreamId;

    RPointerArray<CNATFWCandidate> iLocalCandidates;

    RPointerArray<CNATFWCandidatePair> iCandidatePairs;

    TNATFWIceRole iMode;

    CConsoleBase* iConsole;

    TBool iOnlyCandidates;

    CMccSession* iSession;

    TInt32 iLinkId;

    TInt32 iUpStreamId;

    TInt32 iDownStreamId;

    TNatComState iState;

    TNatComTestState iStateSequence;

    TNatComTestState iTeardownSequence;

    MNATFWSocketMediaConnWrapper* iRtpMediaWrapper;

    MNATFWSocketMediaConnWrapper* iRtcpMediaWrapper;

    RArray<TInt> iStreamIds;

    CDesC8Array* iPlugins;

    };

#endif // NATCOMTEST_H