/*

* Copyright (c) 2004-2005 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: 

*

*/

// INCLUDE FILES

#include <e32base.h>

#include <s32mem.h>

#include "IptvDebug.h"

#include "MIptvVodContentClientObserver.h"

#include "IptvClientServerCommon.h"

#include "CIptvVodContentUpdateObserver.h"

#include "RIptvClientSession.h"

// CONSTANTS

const TUint32 KIptvVodObserverData = 0;

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

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

// CIptvVodContentUpdateObserver::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CIptvVodContentUpdateObserver::ConstructL()

    {    

    SendObserverRequestL();

    SetActive();

    }

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

// CIptvVodContentUpdateObserver::NewL

// Two-phased constructor.

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

//

EXPORT_C CIptvVodContentUpdateObserver* CIptvVodContentUpdateObserver::NewL(MIptvVodContentClientObserver& aObserver, 

    RIptvClientSession& aSession,

    TIptvServiceId aServiceId)

    {

    CIptvVodContentUpdateObserver* self = new(ELeave) CIptvVodContentUpdateObserver(aObserver, aSession, aServiceId);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// CIptvVodContentUpdateObserver::~CIptvVodContentUpdateObserver

// Destructor

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

//

CIptvVodContentUpdateObserver::~CIptvVodContentUpdateObserver()

    {

    delete iObserverMsg;

    Cancel();        

    }

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

// CIptvVodContentUpdateObserver::CIptvVodContentUpdateObserver

// C++ default constructor

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

//

CIptvVodContentUpdateObserver::CIptvVodContentUpdateObserver(MIptvVodContentClientObserver& aObserver, 

    RIptvClientSession& aSession, 

    TIptvServiceId aServiceId) : 

    CActive( EPriorityStandard ),

    iObserver( aObserver ),

    iSession( aSession ),

    iObserverMsg( NULL ),

    iObserverMsgPtr( (unsigned char*)0, 0 ),

    iServiceId( aServiceId )

    {

    CActiveScheduler::Add(this);

    }

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

// CIptvVodContentUpdateObserver::DoCancel

// 

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

//

void CIptvVodContentUpdateObserver::DoCancel()

    {

    }

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

// CIptvVodContentUpdateObserver::RunL

// 

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

//

void CIptvVodContentUpdateObserver::RunL()

    {

    IPTVLOGSTRING_LOW_LEVEL("CIptvVodContentUpdateObserver::RunL");

    RDesReadStream stream;

    stream.Open(iObserverMsgPtr);

    CleanupClosePushL( stream );    

    TUint32 msg = stream.ReadUint32L();

    TInt info = stream.ReadInt32L();

    CleanupStack::PopAndDestroy( &stream );

    TRAP_IGNORE( iObserver.HandleEpgManagerMsgL( msg, info, iServiceId ) );

    SendObserverRequestL();

    SetActive();

    }

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

// CIptvVodContentClient::SendObserverRequestL

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

void CIptvVodContentUpdateObserver::SendObserverRequestL()

    {

    IPTVLOGSTRING_LOW_LEVEL("CIptvVodContentUpdateObserver::SendObserverRequestL");

    delete iObserverMsg;

    iObserverMsg = NULL;

    iObserverMsg = HBufC8::NewL(KIptvVodObserverRequestSize);

    iObserverMsgPtr.Set(iObserverMsg->Des());

    RDesWriteStream stream;

    stream.Open(iObserverMsgPtr);

    CleanupClosePushL( stream );

    stream.WriteUint32L(KIptvVodObserverData);

    CleanupStack::PopAndDestroy( &stream );

    iSession.SendRequest(EIptvEngineVodContentObserver, iObserverMsgPtr, iStatus);

    }