/*

* Copyright (c) 2006 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of the License "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:    Observer for completed total video length requests.*

*/

// INCLUDE FILES

#include <s32mem.h>

#include "IptvClientServerCommon.h"

#include "RIptvClientSession.h"

#include "CIptvMyVideosTotalVideoLengthObserver.h"

#include "MIptvMyVideosClientObserver.h"

// CONSTANTS

const TInt KTUint32SizeInBytes = 4;

// ============================ MEMBER FUNCTIONS ===============================

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::CIptvMyVideosTotalVideoLengthObserver()

// ---------------------------------------------------------

//

CIptvMyVideosTotalVideoLengthObserver::CIptvMyVideosTotalVideoLengthObserver(MIptvMyVideosClientObserver& aClientObserver, RIptvClientSession& aSession) 

 :  CActive(EPriorityStandard),

    iClientObserver(aClientObserver),

    iSession(aSession),

    iMsgPtr((unsigned char*)0, 0)

    {

    CActiveScheduler::Add(this);

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::NewL()

// ---------------------------------------------------------

//

CIptvMyVideosTotalVideoLengthObserver* CIptvMyVideosTotalVideoLengthObserver::NewL(MIptvMyVideosClientObserver& aClientObserver, RIptvClientSession& aSession)

    {

	CIptvMyVideosTotalVideoLengthObserver* self = new (ELeave) CIptvMyVideosTotalVideoLengthObserver(aClientObserver, aSession);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::ConstructL()

// ---------------------------------------------------------

//

void CIptvMyVideosTotalVideoLengthObserver::ConstructL()

    {

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::~CIptvMyVideosTotalVideoLengthObserver()

// ---------------------------------------------------------

//

CIptvMyVideosTotalVideoLengthObserver::~CIptvMyVideosTotalVideoLengthObserver()

    {

    if ( IsActive() )

        {

        Cancel();

        }

    delete iMsg;

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::SetActiveL()

// ---------------------------------------------------------

//

void CIptvMyVideosTotalVideoLengthObserver::SetActiveL()

    {

    if (! IsActive())

        {

        delete iMsg;

        iMsg = NULL;

        iMsg = HBufC8::NewL(2 * KTUint32SizeInBytes);

        iMsgPtr.Set(iMsg->Des());

        iSession.SendRequest(EIptvEngineMyVideosGetTotalVideoLenghtRequestReq, iMsgPtr, iStatus);

        SetActive();        

        }

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::RunL()

// ---------------------------------------------------------

//

void CIptvMyVideosTotalVideoLengthObserver::RunL()

    {

    if (iStatus.Int() == KErrNone)

        {

        TIptvPlayTime  playTime = 0;

        TIptvFileSize  fileSize = 0;

        if (iMsg)

            {

            RDesReadStream stream;

            stream.Open(iMsgPtr);

            CleanupClosePushL( stream );

            playTime = stream.ReadUint32L();

            fileSize = stream.ReadUint32L();

            CleanupStack::PopAndDestroy( &stream );

            }

        iClientObserver.TotalVideoLenghtResponse(playTime, fileSize);

        }

    // Inform client about errors too, otherwise it might stay waiting for ever.

    else

        {

        iClientObserver.TotalVideoLenghtResponse(0, 0);

        }

    delete iMsg;

    iMsg = NULL;

    }

// ---------------------------------------------------------

// CIptvMyVideosTotalVideoLengthObserver::DoCancel()

// ---------------------------------------------------------

//

void CIptvMyVideosTotalVideoLengthObserver::DoCancel()

    {

    iClientObserver.TotalVideoLenghtResponse(0, 0);

    }

// End of file.