// Copyright (c) 2006-2009 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:
//

/**
 @file
 @internalTechnology
 @prototype
*/


#ifndef SYMBIAN_AGENTSCPR_H
#define SYMBIAN_AGENTSCPR_H

#include <comms-infras/corescpr.h>
#include <comms-infras/nifprvar.h>
#include <comms-infras/ss_metaconnprov.h>
#include <comms-infras/agentmessages.h>
#include <cdblen.h>
#include <nifman.h>

#include <comms-infras/nifprvar_internal.h>
#include <nifman_internal.h>



class CAgentAdapter;
class CAgentNotificationHandler;

namespace AgentSCprStates
{
    class TSendBindTo;
    class TJoinAgent;
    class TStartAgent;
    class TStopAgent;
    class TSendAuthenticate;
    class TAwaitingAuthenticateComplete;
    class TSendAuthenticateComplete;
    class TNotifyAgent;
    class TProcessDataClientGoneDown;
    class TNoTagOrProviderStopped;
    class TNoTagOrProviderStarted;
    class TSendDataClientGoneDown;
    class TSendError;
    class TSendDataClientStarted;
    class TAwaitingDataClientStop;
} // AgentSCprStates


class CAgentSubConnectionProvider : public CCoreSubConnectionProvider
	{
	friend class CAgentNotificationHandler;
	friend class AgentSCprStates::TSendBindTo;
	friend class AgentSCprStates::TJoinAgent;
	friend class AgentSCprStates::TStartAgent;
	friend class AgentSCprStates::TStopAgent;
	friend class AgentSCprStates::TSendAuthenticate;
	friend class AgentSCprStates::TAwaitingAuthenticateComplete;
	friend class AgentSCprStates::TSendAuthenticateComplete;
	friend class AgentSCprStates::TNotifyAgent;
	friend class AgentSCprStates::TProcessDataClientGoneDown;
	friend class AgentSCprStates::TNoTagOrProviderStopped;
	friend class AgentSCprStates::TNoTagOrProviderStarted;
	friend class AgentSCprStates::TSendDataClientGoneDown;
	friend class AgentSCprStates::TSendError;
    friend class AgentSCprStates::TSendDataClientStarted;
    friend class AgentSCprStates::TAwaitingDataClientStop;
	friend class CAgentAdapter;

public:
    IMPORT_C static CAgentSubConnectionProvider* NewL(ESock::CSubConnectionProviderFactoryBase& aFactory);
    IMPORT_C ~CAgentSubConnectionProvider();
    void StartAgentL();
    void StopAgent(TInt aReason);

protected:
	IMPORT_C CAgentSubConnectionProvider(ESock::CSubConnectionProviderFactoryBase& aFactory,
	    const MeshMachine::TNodeActivityMap& aActivityMap);
	IMPORT_C void CleanupProvisioningInfo ();

   	// Messages::ANode Interface
	IMPORT_C virtual void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage);

    IMPORT_C const CAgentProvisionInfo* AgentProvisionInfo () const;

    IMPORT_C void ConnectAgent (TAgentConnectType aConnectType);
    IMPORT_C TInt NotificationToAgent (TFlowToAgentEventType aEvent, TAny* aInfo);

private:
    // Methods that are called from the CAgentAdapter
    void ServiceStarted();
    void ConnectionUpL();
    void ConnectionDownL();
    void AuthenticateCompleteL(TInt aStatus);
    void PromptForReconnectComplete(TInt aStatus);
    void ProgressL(TInt aStage);
    void Error (const Elements::TStateChange& aProgress);
    void NetworkAdaptorEvent(TNetworkAdaptorEventType aEventType, TUint aEvent, const TDesC8& aEventData, TAny* aSource=NULL);
    TInt NotificationFromAgent(TAgentToFlowEventType aEvent, TAny* aInfo=NULL);

private:
    void NotificationFromFlow(TFlowToAgentEventType aEvent);
    void ProvisionAgentInfoL();
    TInt PostMessageToFlow(const Messages::TRuntimeCtxId& aSender, const Messages::TSignatureBase& aMessage);
    inline void SetActivityIdForAdapter(TUint aActivityId);
    void CancelStartOrSendStopToSelf(TInt aError);


private:
    TBool iScprOwnedNotificationHandler;
    TBool iAuthenticateInProgress;
    TBool iStopRequested;		// ETrue means an agent stop has been requested - not that the SCPr has received a TCFDataClient::TStop
    TInt iStoppingReason;

    Elements::TStateChange iLastProgress;
    TBuf<KCommsDbSvrMaxUserIdPassLength> iUsername;
    TBuf<KCommsDbSvrMaxUserIdPassLength> iPassword;
    TUint iActivityIdForAdapter;
    };


inline void CAgentSubConnectionProvider::SetActivityIdForAdapter(TUint aActivityId)
	{
	iActivityIdForAdapter = aActivityId;
	}


#endif
// SYMBIAN_AGENTSCPR_H