/*

* 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 CMSRPMSGPARSER_H_

#define CMSRPMSGPARSER_H_

#ifdef UT_TEST

#include "../../tsrc/conn_parser/inc/CMSRPMessageHandler.h"

#else

#include "CMSRPMessageHandler.h"

#endif

#include "MMSRPParserObserver.h"

#include "MSRPBuffer.h"

#define MSRP_COLON ':'

#define MSRP_SPACE ' '

#define MSRP_CARRIAGE '\r'

#define MSRP_TERMINATE  '#'

#define MSRP_CONTINUE  '+'

#define MSRP_END  '$'

#define KMSRPIDLenMax 32

#define KMSRPIDLenMin 4

#define KMSRPEndTokenMax KMSRPIDLenMax+8+2 //init-crlf

class CMSRPMsgParser: public CBase

    {

    friend class CMSRPParser;    

    public:

        enum TParseState 

            {

            EIdle = 0,

            ETitleLine,

            EToPath,

            EFromPath,

            //EMandatoryHeader,

            EOptionalHeaders,

            EBody,

            EExtraCRLF,        

            EEndofEndLine

            };

        enum TMatchType

            {

            ENoMatch,

            EFullMatch,        

            EPartialMatch   

            };

        static CMSRPMsgParser* NewL(MMSRPParserObserver& aConnection);

        virtual ~CMSRPMsgParser();

        TBool ParseL();

    private:

        CMSRPMsgParser(MMSRPParserObserver& aConnection);

        void ConstructL();

        TBool HandleFullMatchL(TPtrC8& aToken, TInt aMatchPos, TBool aCopyToLocal = FALSE);

        TBool HandlePartialMatchL(TPtrC8& aToken, TInt aCurBufMatchPos);

        TBool HandleNoMatchL(TPtrC8& aToken, TInt aCurBufMatchPos);

        void HandleStateL(const TDesC8& aString, TInt aMatchPos);

        void HandleTitleLineL(const TDesC8& aString, TInt aMatchPos);

        void HandleHeaderL(const TDesC8& aString, TInt aMatchPos);

        void HandleOptionalHeaderL(const TDesC8& aString, TInt aMatchPos);

        void HandleBodyL(const TDesC8& aString, TInt aMatchPos);

        void HandleXtraCrlfL(const TDesC8& aString, TInt aMatchPos);

        void HandleEndofEndLineL(const TDesC8& aString, TInt aMatchPos);

        TMatchType FindToken(const TDesC8& aString, const TDesC8& aToken, TInt& aMatchPos);

        /**

        * Check if this chunk belongs to one of messages received 

        * earlier. If so, the messages are combined to one

        * entity

        */

        void CheckMessageChunkL( );

    private:

        MMSRPParserObserver& iConnection;

        RPointerArray<RMsrpBuf> iParseBuffers;

        TParseState iState;

        RMsrpBuf* iLocalBuf;//keep it above pool

        CMSRPMessageHandler* iMessage;

        CMSRPBufPool iBufPool;

        HBufC8* iEndToken;

        // byte-range header included indicator

        TBool iByteRangeHeaderFound;

        // pool of incoming message chunks. This array contains unfinished 

        // message chunks which are waiting for the next chunk to arrive

        RPointerArray< CMSRPMessageHandler > iIncomingMessageChunks;

    };

#endif /* CMSRPMSGPARSER_H_ */