/*

* 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 completion of copy or move requests.*

*/

// INCLUDE FILES

#include "IptvClientServerCommon.h"

#include "RIptvClientSession.h"

#include "CIptvMyVideosCopyOrMoveObserver.h"

#include "MIptvMyVideosClientObserver.h"

#include "CIptvMyVideosGlobalFileId.h"

#include "CIptvMyVideosGlobalFolderId.h"

// CONSTANTS

const TInt KTUint32SizeInBytes = 4;

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

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

// CIptvMyVideosCopyOrMoveObserver::CIptvMyVideosCopyOrMoveObserver()

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

//

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

 :  CActive(EPriorityStandard),

    iClientObserver(aClientObserver),

    iSession(aSession),

    iMsgPtr((unsigned char*)0, 0)

    {

    CActiveScheduler::Add(this);

    }

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

// CIptvMyVideosCopyOrMoveObserver::NewL()

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

//

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

    {

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

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

    }

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

// CIptvMyVideosCopyOrMoveObserver::ConstructL()

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

//

void CIptvMyVideosCopyOrMoveObserver::ConstructL()

    {

    }

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

// CIptvMyVideosCopyOrMoveObserver::~CIptvMyVideosCopyOrMoveObserver()

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

//

CIptvMyVideosCopyOrMoveObserver::~CIptvMyVideosCopyOrMoveObserver()

    {

    Cancel();

    delete iMsg;

    }

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

// CIptvMyVideosCopyOrMoveObserver::SetActiveL()

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

//

void CIptvMyVideosCopyOrMoveObserver::SetActiveL(TUint16 aCommand, CIptvMyVideosGlobalFileId& aSourceFileId, CIptvMyVideosGlobalFolderId& aTargetFolderId)

    {

    if (! IsActive())

        {

        TInt dataSize = 0;

        delete iMsg;

        iMsg = NULL;

        dataSize  = KTUint32SizeInBytes; // aCommand

        dataSize += aSourceFileId.CountExternalizeSize();

        dataSize += aTargetFolderId.CountExternalizeSize();

        iMsg = HBufC8::NewL(dataSize > (KTUint32SizeInBytes * 2) ? dataSize : (KTUint32SizeInBytes * 2)); // Return values need 8 bytes.

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

        RDesWriteStream stream;

        stream.Open(iMsgPtr);

        CleanupClosePushL( stream );

        aSourceFileId.ExternalizeL(stream);

        aTargetFolderId.ExternalizeL(stream);

        CleanupStack::PopAndDestroy( &stream );

        iSession.SendRequest(aCommand, iMsgPtr, iStatus);

        CActive::SetActive();        

        }

    }

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

// CIptvMyVideosCopyOrMoveObserver::SetActiveL()

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

//

void CIptvMyVideosCopyOrMoveObserver::SetActiveL(TUint16 aCommand, CIptvMyVideosGlobalFolderId& aSourceFolderId, CIptvMyVideosGlobalFolderId& aTargetFolderId)

    {

    if (! IsActive())

        {

        TInt dataSize = 0;

        delete iMsg;

        iMsg = NULL;

        dataSize  = KTUint32SizeInBytes; // aCommand

        dataSize += aSourceFolderId.CountExternalizeSize();

        dataSize += aTargetFolderId.CountExternalizeSize();

        iMsg = HBufC8::NewL(dataSize > (KTUint32SizeInBytes * 2) ? dataSize : (KTUint32SizeInBytes * 2)); // Return values need 8 bytes.

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

        RDesWriteStream stream;

        stream.Open(iMsgPtr);

        CleanupClosePushL( stream );

        aSourceFolderId.ExternalizeL(stream);

        aTargetFolderId.ExternalizeL(stream);

        CleanupStack::PopAndDestroy( &stream );

        iSession.SendRequest(aCommand, iMsgPtr, iStatus);

        CActive::SetActive();        

        }

    }

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

// CIptvMyVideosCopyOrMoveObserver::RunL()

// Server has finished the copy or move request.

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

//

void CIptvMyVideosCopyOrMoveObserver::RunL()

    {

    TInt operationStatus = KErrGeneral;

    TInt failed          = 0;

    if (iStatus.Int() == KErrNone)

        {

        if (iMsg)

            {

            RDesReadStream stream;

            CleanupClosePushL( stream );

            stream.Open(iMsgPtr);

            operationStatus = stream.ReadUint32L();

            failed          = stream.ReadUint32L();

            CleanupStack::PopAndDestroy( &stream );

            }

        }

    delete iMsg;

    iMsg = NULL;

    // Call obsever, except in the case when server was cancelled.

    // This situation happens during shutdown so client is no more.    

    if (iStatus.Int() != KErrCancel)

        {

        iClientObserver.CopyOrMoveResponse(iStatus.Int(), operationStatus, failed);

        }

    }

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

// CIptvMyVideosCopyOrMoveObserver::DoCancel()

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

//

void CIptvMyVideosCopyOrMoveObserver::DoCancel()

    {

    }

// End of file.