/*
* 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 CMSRPSESSIONIMPLEMENTATION_H_
#define CMSRPSESSIONIMPLEMENTATION_H_

// INCLUDES
#include "MsrpCommon.h"

// Forward declarations.
class CMSRP;
class MMSRPSessionObserver;
class CUri8;
class RMSRPSession;
class CMSRPConnectionListener;
class CMSRPIncomingListener;
class CMSRPSendResultListener;
class CMSRPMessage;
class RMSRP;
class CMSRPSessionParams;


class CMSRPSessionImplementation : public CBase
    {
public:       
    static CMSRPSessionImplementation* NewL( RMSRP& aRMSRP,
                                             MMSRPSessionObserver& aObserver,
                                             const TUint aIapId );
    
    static CMSRPSessionImplementation* NewLC( RMSRP& aRMSRP,
                                              MMSRPSessionObserver& aObserver,
                                              const TUint aIapId );
    
    ~CMSRPSessionImplementation();
    
public:
    
    TDesC8& LocalMSRPPath();
    
    void SetSessionParams( CMSRPSessionParams& aSessionParams );
    
    void ConnectL( const TDesC8& aRemoteMsrpPath );
    
    void ListenL( const TDesC8& aRemoteMsrpPath );
        
    HBufC8* SendBufferL( const TDesC8& aMessage, const TDesC8& aMimeType );
        
    void CancelSendingL( TDesC8& aMessageId );
    
        
    void ConnectionEstablishedL( TInt aStatus );
    
    void HandleIncomingMessageL( const TDesC8& aIncomingMessage,
                                 TInt aStatus );
    void ReceiveProgress(TInt aBytesReceived, TInt aTotalBytes);
    
    void SendProgress(TInt aBytesSent, TInt aTotalBytes);
    
    void SendStatusL( TInt aStatus, const TDesC8& aMessageid );
	
    void HandleConnectionErrors( TInt aErrorStatus );
    
	void SendFileL( const TFileName& aFileName,const TDesC8& aMimeType );
	 
	void NotifyProgress(TBool aFlag);

	void ReceiveFileL(const TFileName& aFileName,const TInt aFileSize, const TDesC8& aMimeType);

private:
    
    CMSRPMessage* CreateMsrpMessageL( const TDesC8& aMessage, const TDesC8& aToPath, 
                                      const TDesC8& aFromPath, const TDesC8& aMimeType );
    
    void SendMessageL( CMSRPMessage* aMessage );
    
    void GetRemotePathComponentsL( TPtrC8& aRemoteHost, TUint& aRemotePort, TPtrC8& aRemoteSessionID );
    
    CMSRPMessage* SetFileParamsL(const TFileName& aFileName,const TDesC8& aToPath,
                                                               const TDesC8& aFromPath, 
                                                               const TDesC8& aMimeType );
private:
    
    CMSRPSessionImplementation( RMSRP& aRMSRP,
                                MMSRPSessionObserver& aObserver );
    
    void ConstructL( const TUint aIapId );
        
private:
    
    RMSRP& iRMSRP;
    
    MMSRPSessionObserver& iSessionObserver;
    
    RMSRPSession* iMSRPSession;
    
    RBuf8 iLocalMsrpPath;
    
    RBuf8 iRemoteMsrpPath;
    
    TReportStatus iSuccessReport;
    
    TReportStatus iFailureReport;
            
    TBuf8< KMaxLengthOfIncomingMessageExt > iExtMessageBuffer;
    
    CMSRPConnectionListener* iConnectionListener;
    
    CMSRPIncomingListener* iIncomingListener;
    
    CMSRPSendResultListener* iSendResultListener;
    
    RPointerArray< CMSRPMessage > iSentMessages;
    
    TBool iProgress;
    
    TBool  isSendFile;
    TBool  isReceiveFile;
    };

#endif /* CMSRPSESSIONIMPLEMENTATION_H_ */