/*

* Copyright (c) 2009-2010 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:

* MSRP Implementation

*

*/

#ifndef TSTATES_H_

#define TSTATES_H_

#include "MSRPServerCommon.h"

class TStateBase;

class CMSRPServerSubSession;

class CMSRPMessageHandler;

enum TStates

{

    EIdle,

    EConnecting,    

    EWaitForClient,    

    EActive,

	EError

};

class TStateBase

{ 

public:

    virtual TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext)=0;

    virtual TStateBase* HandleStateErrorL(CMSRPServerSubSession *aContext);

    virtual TStateBase * processIncommingMessageL(CMSRPServerSubSession *aContext, CMSRPMessageHandler* incommingMsg = NULL);

    TStateBase * processPendingMessageQL( CMSRPServerSubSession *aContext );

    TStateBase * processCompletedMessageL( CMSRPServerSubSession *aContext );

    TStateBase * processCompletedIncomingMessageL( CMSRPServerSubSession *aContext );

    TStateBase * processReceiveReportL( CMSRPServerSubSession *aContext );

    TStateBase * processSendReportL( CMSRPServerSubSession *aContext );

    virtual TStateBase * handlesResponseL(CMSRPServerSubSession *aContext,

                    CMSRPMessageHandler *incommingMsgHandler);

    virtual TStateBase* handleRequestsL(CMSRPServerSubSession *aContext,

                    CMSRPMessageHandler *incommingMsgHandler);

    TStateBase* handleClientListnerCancelL(CMSRPServerSubSession * aContext, 

                                        TMSRPFSMEvent aEvent);

    TStateBase* HandleClientCancelSendingL(CMSRPServerSubSession * aContext ); 

    TStateBase* handleConnectionStateChangedL(CMSRPServerSubSession *aContext);

    TStateBase* handleQueuesL(CMSRPServerSubSession *aContext);

	TStateBase* handleConnectionErrorsL(CMSRPServerSubSession *aContext);

    virtual TStates identity()=0;

    TStateBase* handleInCommingMessagesL(CMSRPServerSubSession *aContext);

    TStateBase* handleCancelFileSendingL(CMSRPServerSubSession *aContext);

    TStateBase* MessageSendCompleteL(CMSRPServerSubSession *aContext); 

};

class TStateIdle : public TStateBase

{

public:

    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);

    TStates identity();

private:    

    TStateBase* handleLocalMSRPPathRequestL( CMSRPServerSubSession *aContext);

    TStateBase* handleConnectRequestL(CMSRPServerSubSession *aContext);

    TStateBase* handleListenRequestL(CMSRPServerSubSession *aContext);

    TBool initializeConnectionL(CMSRPServerSubSession *aContext);    

};

class TStateConnecting : public TStateBase

{

public:

    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);

    TStates identity();    

};

class TStateWaitForClient : public TStateBase

{

public:

    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);

    TStates identity();

};

class TStateActive : public TStateBase

{

public:

    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);

    TStates identity();

private:

    TStateBase* handleSendDataL( CMSRPServerSubSession* aContext );

    TStateBase* handleResponseSentL( CMSRPServerSubSession* aContext);

    TStateBase* handleReportSentL( CMSRPServerSubSession* aContext);

};

class TStateError : public TStateBase

{

public:

    TStateBase* EventL(TMSRPFSMEvent aEvent, CMSRPServerSubSession *aContext);

    TStates identity();    

};

#endif /* TSTATES_HPP_ */