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

// INCLUDES
#include <e32base.h>
#include <f32file.h> 

#include "MSRPCommon.h"
#include "MMSRPMessageHandler.h"
#include "MMSRPIncomingMessage.h"
#include "MMSRPOutgoingMessage.h"
#include "MMSRPWriterObserver.h"
#include "CMSRPMessageChunkState.h"

// Forward declarations
class MMSRPMessageHandler;
class MMSRPIncomingMessage;
class MMSRPOutgoingMessage;
class MMSRPWriterObserver;
class MMSRPMessageObserver;
class CMSRPMessage;
class CMSRPResponse;
class CMSRPReport;
class CMSRPMessageBase;
class RStringF;

// Constants
const TInt KMaxBufferSize = 2500;
const TInt KSmallBuffer = 1024;
const TInt KMaxChunkReadSize =  65000;
// Class declaration

/* MSRP Message handler
 * 
 */

class CMSRPMessageHandler : public CBase, public MMSRPMessageHandler, 
                            public MMSRPIncomingMessage, public MMSRPOutgoingMessage, 
                            public MMSRPWriterObserver
    {
public:
    
    enum TMSRPMessageState
        {
        EIdle,
        EInProgress,
        EChunkSent,
        EMessageSent,
        EWaitingForResponse,
        EWaitingForReport,        
        EMessageDone
        };
        
    /* Two-Phased constructor
     * 
     */
    static CMSRPMessageHandler* NewL( MMSRPMessageObserver* aMessageObserver, 
            const TDesC8& aMessage );
    
    static CMSRPMessageHandler* NewLC( MMSRPMessageObserver* aMessageObserver, 
            const TDesC8& aMessage );
    
    static CMSRPMessageHandler* NewL( TMSRPMessageType aMessageType );
    
    static CMSRPMessageHandler* NewLC( TMSRPMessageType aMessageType );
    
    /**
     * Destructor.
     */
    ~CMSRPMessageHandler();

	static TInt LinkOffset();		
	TSglQueLink iLink;	
    
public: // From base classes
    
    // From MMSRPWriterObserver
	TWriteStatus GetSendBufferL( TPtrC8& aData, TBool aInterrupt ); 
    
    MMSRPWriterObserver::TMsgStatus WriteDoneL( TInt aStatus );
    
    // From MMSRPMessageHandler
    void AddHeaderL( TMsrpHeaderType aHeaderType, TPtrC8& aHeaderValue, 
            TPtrC8& aHeaderTypeAndValue );
    
    void AddContentL( TPtrC8& aContent );
    
    void SetTransactionId( TPtrC8& aTransactionId );
    
    void SetStatusOfResponseL( TPtrC8& aStatusCode, TPtrC8& aStatusMessage );
    
    void EndOfMessageL( TMsrpMsgEndStatus aStatus );
    
    // From MMSRPIncomingMessage
    TMSRPMessageType MessageType( );
       
    CMSRPMessage* GetIncomingMessage( );
    
    TBool SendResponseL( MMSRPMessageObserver* aMessageObserver,
								MMSRPConnection& aConnection, TUint aResponseCode );
    
    TDesC8& TransactionId( );
        
    CMSRPResponse* GetIncomingResponse( );
        
    // From MMSRPOutgoingMessage
    void SendMessageL( MMSRPConnection& aConnection );
        
    TBool IsOwnerOfResponse( MMSRPIncomingMessage& aIncomingMessage );
    
    TBool ConsumeResponseL( MMSRPIncomingMessage& aIncomingMessage );

    TBool IsMessageComplete();
    
    TBool GetSendResultL( TUint &aErrorCode, HBufC8* &aMessageId );
    
    void SendFileL( MMSRPConnection& aConnection );
        
    void ConsumeFileResponseL( MMSRPIncomingMessage& aIncomingMessage );
       


    TBool IsInFile();
       
    void ReceiveFileL( );
       
    TBool FileTransferComplete( );
       
    void WritetoFileL(CMSRPMessageHandler *aIncomingMsgHandler );
       
    void UpdateResponseStateL(CMSRPMessageHandler *incomingMsgHandler);
       
    TBool IfResponseReqL();
private:
    // Constructor
    CMSRPMessageHandler( MMSRPMessageObserver* aMessageObserver );
    
    CMSRPMessageHandler( );
    
    void ConstructL( const TDesC8& aMessage );
    
    void ConstructL( TMSRPMessageType aMessageType );
    
    // Member Functions
    void CreateByteRangeHeaderL();
    
    void CreateTransactionId();
    
    void WriteInitialLineToBufferL();
    
    void WriteHeadersToBufferL();
    
    void WriteContentToBuffer();
    
    void WriteFileContentToBufferL();
    
    void WriteEndLineToBuffer(TMsrpMsgEndStatus = EMessageEnd );
    
    TInt ExtractByteRangeParams( TDesC8& aHeaderValue, TInt& aStartPos, 
            TInt& aEndPos, TInt& aTotal );
    
    RStringF GetStatusStringL( TUint aStatusCode );
    
    TUint CheckValidityOfMessage( TMSRPMessageType aMessageType, 
            CMSRPMessageBase* aMessage );
    
    TInt FillFileBufferL();
         
    void SendFileChunkL( MMSRPConnection& aConnection );
       
        

    void SendFileStateL( TInt aBytes );
        
    void ReceiveFileStateL( TInt aBytes );
        
    void WriteChunkToFileL(const TDesC8& aFileChunk ,TDesC8& aTransactionId);  
private:
    
    // Server interface
    MMSRPMessageObserver* iMSRPMessageObserver;
    
    // Transaction Id
    TBuf8< KMaxLengthOfTransactionIdString > iTransactionId;
            
    // MSRP Message
    CMSRPMessage* iMessage;

    // MSRP response;
    CMSRPResponse* iResponse;
    
    TBool iResponseNeeded;
    
    RBuf8 iBuffer;
    
    TPtrC8 iContentPtr;
    
    TBool iWriteDone;    
    
    TMSRPMessageType iActiveMsgType;
    
    TMSRPMessageState iState;
    
    TMsrpMsgEndStatus iMsgEndStatus;        
    
    /* For File Use Case */
    TBool isFile; 
    RFile iFile;
    RFs iFs;
    TInt iFileSize;
    
    TBool iInterrupt;
    HBufC8* iFileBuffer;
    TBool iFileTransferComplete;
    RPointerArray <CMSRPMessageChunkState> iChunkList;       
    TInt iBufPosInFile; //file buffer start pos in file
    TInt iEndPosInBuffer;    
    TInt iStartPosInBuffer;
    TInt iFileBytesSent;

    TBool iProgress;
    TInt iNotifiedBytes;
    TInt iPendingBytes;
    };

#endif /* CMSRPMESSAGEHANDLER_H_ */