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

// INCLUDES

// CLASS HEADER
#include "CMSRPParser.h"
#include "MSRPCommon.h"

// -----------------------------------------------------------------------------
// CMSRPParser::NewL
// Static constructor
// -----------------------------------------------------------------------------
//
/*static*/MMSRPParser* CMSRPParser::NewL(MMSRPParserObserver& aConnection)
    {
    MSRPLOG( "CMSRPParser::NewL enter" )
    CMSRPParser* self = new (ELeave) CMSRPParser(aConnection);
    CleanupStack::PushL(self);
    self->ConstructL(aConnection);
    CleanupStack::Pop(self);
    MSRPLOG( "CMSRPParser::NewL exit" )
    return self;
    }

// -----------------------------------------------------------------------------
// CMSRPParser::CMSRPParser
// Constructor
// -----------------------------------------------------------------------------
//
CMSRPParser::CMSRPParser(MMSRPParserObserver& aConnection)        
    : CActive(CActive::EPriorityStandard), iConnection( aConnection )
    {  
    CActiveScheduler::Add(this);
    }

// -----------------------------------------------------------------------------
// CMSRPParser::~CMSRPParser
// Destructor
// -----------------------------------------------------------------------------
//
CMSRPParser::~CMSRPParser()
    {
    MSRPLOG( "CMSRPParser::~CMSRPParser enter" )
    Cancel();    
    delete iParser;
    MSRPLOG( "CMSRPParser::~CMSRPParser exit" )
    }

// -----------------------------------------------------------------------------
// CMSRPParser::ConstructL
// 2nd phase constructor
// -----------------------------------------------------------------------------
//
void CMSRPParser::ConstructL(MMSRPParserObserver& aConnection)
    {
    //iState = EIdle;
    iParser = CMSRPMsgParser::NewL(aConnection);
    }

// -----------------------------------------------------------------------------
// CMSRPParser::DoCancel
// Cancels outstanding request.
// -----------------------------------------------------------------------------
//
void CMSRPParser::DoCancel()
    {
    MSRPLOG( "CMSRPParser::DoCancel enter" )
    //TRequestStatus* status = &iStatus;
    //User::RequestComplete( status, KErrCancel );
    MSRPLOG( "CMSRPParser::DoCancel exit" )
    }

// -----------------------------------------------------------------------------
// CMSRPParser::Parse
// -----------------------------------------------------------------------------
//
void CMSRPParser::ParseL(RMsrpBuf& aBuf)
    { 
    MSRPLOG( "CMSRPParser::ParseL enter" )
    
    if(!IsActive())
        {
        TRequestStatus* status = &iStatus;
        SetActive();
        User::RequestComplete( status, KErrNone );
        }
    
    //collate with last element in array, else claim ownership
    if(iParser->iParseBuffers.Count())
        {
        if(iParser->iParseBuffers[iParser->iParseBuffers.Count()-1]->Collate(aBuf))
            return;
        }
        
    RMsrpBuf* buf = new (ELeave) RMsrpBuf(aBuf);
    CleanupDeletePushL(buf);
    iParser->iParseBuffers.AppendL(buf);
    CleanupStack::Pop( );
    MSRPLOG( "CMSRPParser::ParseL exit" )
    }

// -----------------------------------------------------------------------------
// CMSRPParser::CancelReceiving
// -----------------------------------------------------------------------------
//
/*void CMSRPParser::CancelReceiving()
    {
    Cancel();
    }*/


// -----------------------------------------------------------------------------
// CMSRPParser::RunL
// -----------------------------------------------------------------------------
//
void CMSRPParser::RunL()
    {     
    MSRPLOG( "CMSRPParser::RunL enter" )
          
    TBool reschedule = iParser->ParseL();
    
    //count could be > 0 but data could be insufficient to parse
    if(reschedule && iParser->iParseBuffers.Count())
       {
       TRequestStatus* status = &iStatus;
       SetActive();
       User::RequestComplete( status, KErrNone );
       }
    MSRPLOG( "CMSRPParser::RunL exit" )
    }

// -----------------------------------------------------------------------------
// CMSRPParser::RunError
// -----------------------------------------------------------------------------
//
TInt CMSRPParser::RunError(TInt /*aError*/)
    {
    MSRPLOG( "CMSRPParser::RunError enter" )    
    //aError = KErrNone;
    //ParseError//non leaving introduce
    TRAPD(err,iConnection.ParseStatusL(NULL, KErrCorrupt));
    MSRPLOG( "CMSRPParser::RunError exit" )
    return err;
    }
    

// End of File