/*

* 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:    Implements My Videos Client API.*

*/

// INCLUDE FILES

#include <e32svr.h>

#include <s32mem.h> 

#include "IptvClientServerCommon.h"

#include "IptvDebug.h"

#include "CIptvMyVideosClient.h"

#include "MIptvMyVideosClientObserver.h"

#include "IptvServer.pan"

#include "CIptvMyVideosFolder.h"

#include "CIptvMyVideosGlobalFileId.h"

#include "CIptvMyVideosVideoBriefDetails.h"

#include "CIptvMyVideosVideoFullDetails.h"

#include "CIptvMyVideosContentUpdateObserver.h"

#include "CIptvMyVideosTotalVideoLengthObserver.h"

#include "CIptvMyVideosCopyOrMoveObserver.h"

// CONSTANTS

const TInt KIptvMaxFileSizeInKiloBytes = 4194303; // (TUint32) ((KMaxTUint32 - 1) / 1024)

const TInt KTUint32SizeInBytes         = 4;

const TInt KTUint16SizeInBytes         = 2;

_LIT(KIptvInvalidFileNameChars, "\"<>/|'?*");

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

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

// CIptvMyVideosClient::CIptvMyVideosClient

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

//

CIptvMyVideosClient::CIptvMyVideosClient( 

    MIptvMyVideosClientObserver& aClientObserver ) 

  : CActive( EPriorityStandard ),

    iClientObserver( aClientObserver ),

    iMsgPtr( NULL, 0 )

    {

    CActiveScheduler::Add( this );

    }

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

// CIptvMyVideosClient::ConstructL

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

//

void CIptvMyVideosClient::ConstructL( TBool aSkipMaintenance )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::ConstructL -- Enter");

    User::LeaveIfError(iSession.Connect());

    // Create observers for "content updated", "get total video length" and "copy/move complete"

    // messages from server. These messages stay pending until server has completed operation.

    //

    iContentUpdateObserver    = CIptvMyVideosContentUpdateObserver::NewL(iClientObserver, iSession);

    iTotalVideoLengthObserver = CIptvMyVideosTotalVideoLengthObserver::NewL(iClientObserver, iSession);

    iCopyOrMoveObserver       = CIptvMyVideosCopyOrMoveObserver::NewL(iClientObserver, iSession);

    // If client does not need maintenance scan, send the information about

    // need for maintenance to server. If this message is not sent, server

    // assumes that maintenance is needed and performs it after a short while.

    //

    if ( aSkipMaintenance )

        {

        TRequestStatus status;

        delete iMsg;

        iMsg = NULL;

        iMsg = HBufC8::NewL(KTUint32SizeInBytes);

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

        RDesWriteStream stream;

        stream.Open(iMsgPtr);

        CleanupClosePushL(stream);

        stream.WriteUint32L(static_cast<TUint32>(aSkipMaintenance));

        CleanupStack::PopAndDestroy(&stream);

        iSession.SendRequest(EIptvEngineMyVideosPassMaintenanceInfoReq, iMsgPtr, status);

        User::WaitForRequest(status);

        }

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::ConstructL -- Exit");

    }

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

// CIptvMyVideosClient::NewL

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

//

EXPORT_C CIptvMyVideosClient* CIptvMyVideosClient::NewL(

        MIptvMyVideosClientObserver& aClientObserver,

        TBool aMaintenance /*= EFalse*/ )

    {

	CIptvMyVideosClient* self = CIptvMyVideosClient::NewLC(

	        aClientObserver,

	        aMaintenance );

	CleanupStack::Pop(self);

	return self;

    }

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

// CIptvMyVideosClient::NewLC

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

//

EXPORT_C CIptvMyVideosClient* CIptvMyVideosClient::NewLC(

        MIptvMyVideosClientObserver& aClientObserver,

        TBool aMaintenance /*= EFalse*/ )

    {

	CIptvMyVideosClient* self = new (ELeave) CIptvMyVideosClient(aClientObserver);

	CleanupStack::PushL(self);

	self->ConstructL(aMaintenance);

	return self;

    }

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

// CIptvMyVideosClient::~CIptvMyVideosClient

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

//

CIptvMyVideosClient::~CIptvMyVideosClient()

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::~CIptvMyVideosClient -- Enter");

    // Cancel own requests, there shouldn't be any though.

    Cancel(); 

    // Cancel the content update and total video length requests.

    // The cancellation is done with the help of server side.

    if (!IsActive())

        {

        if (!iSession.IsNull())

            {

            TRequestStatus status;

            iSession.SendRequest(EIptvEngineMyVideosCancelReq, status);

            User::WaitForRequest(status);

            }

        }

    delete iContentUpdateObserver;

    delete iTotalVideoLengthObserver;

    delete iCopyOrMoveObserver;

    delete iMsg;

    iSession.Close();

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::~CIptvMyVideosClient -- Exit");    

    }

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

// CIptvMyVideosClient::GetFolderListL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetFolderListL( 

        CIptvMyVideosGlobalFolderId& aParentFolderId,

        TUint32 aFrom,

        TUint32 aAmount,

        TUint32& aTotalAmount,

        RPointerArray<CIptvMyVideosFolder>& aFolderList )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetFolderListL");

    TInt error = KErrServerBusy;

    if ( ! IsActive() )

        {

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosGetFolderListSizeReq,

                                     aParentFolderId,

                                     aFrom,

                                     aAmount ) ) )

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( EIptvEngineMyVideosGetFolderListDataReq ) ) )

                {

                error = HandleMyVideosGetFolderListDataReqL( aTotalAmount, aFolderList );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetParentFolderL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetParentFolderL(

        CIptvMyVideosGlobalFolderId& aFolderId,

        CIptvMyVideosGlobalFolderId& aParentFolder )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetParentFolderL");

    TInt error = KErrServerBusy;

    if ( aFolderId.iDrive == 0 && aFolderId.iFolderId == 0 )

        {

        return KErrArgument;

        }

    if ( ! IsActive() )

        {

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosGetParentFolderSizeReq, aFolderId ) ) )

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( EIptvEngineMyVideosGetParentFolderDataReq ) ) )

                {

                error = HandleMyVideosGetParentFolderDataReqL( aParentFolder );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetFolderNameL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetFolderNameL(

        CIptvMyVideosGlobalFolderId& aFolderId,

        TDes& aName )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetParentFolderL");

    TInt error = KErrServerBusy;

    if ( ! IsActive() )

        {

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosGetFolderNameSizeReq, aFolderId ) ) )

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( EIptvEngineMyVideosGetFolderNameDataReq ) ) )

                {

                error = HandleMyVideosGetFolderNameDataReqL( aName );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::DeleteFolderReqL

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

//

EXPORT_C TInt CIptvMyVideosClient::DeleteFolderReqL(CIptvMyVideosGlobalFolderId& aFolderId)

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::DeleteFolderReqL");

    TInt error = KErrServerBusy;

    if (aFolderId.iDrive == 0 && aFolderId.iFolderId == 0)

        {

        return KErrArgument;

        }  

    if (!IsActive())

        {

        if (iMsg)

            {

            delete iMsg;

            iMsg = NULL;

            }

        TUint32 dataSize = aFolderId.CountExternalizeSize();

        iMsg = HBufC8::NewL(dataSize);

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

        RDesWriteStream stream;

        stream.Open(iMsgPtr);

        CleanupClosePushL( stream );

        aFolderId.ExternalizeL(stream);

        CleanupStack::PopAndDestroy( &stream );

        iSession.SendRequest(EIptvEngineMyVideosDeleteFolderRequestReq, iMsgPtr, iStatus);

        iActiveRequest = EIptvEngineMyVideosDeleteFolderRequestReq;

        SetActive();

        error = KErrNone;

        }

    return error;

    }

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

// CIptvMyVideosClient::DeleteFolderL

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

//

EXPORT_C TInt CIptvMyVideosClient::DeleteFolderL( CIptvMyVideosGlobalFolderId& aFolderId )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::DeleteFolderL");

    TInt error = KErrServerBusy;

    if ( aFolderId.iDrive == 0 && aFolderId.iFolderId == 0 )

        {

        return KErrArgument;

        }  

    if ( ! IsActive() )

        {

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosDeleteFolderReq, aFolderId ) ) )

            {

            error = HandleMyVideosReqL(); // No return data.

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetVideoListL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetVideoListL(

        CIptvMyVideosGlobalFolderId& aParentFolderId,

        TUint32 aFrom,

        TUint32 aAmount,

        TUint32& aTotalAmount,

        RPointerArray<CIptvMyVideosVideoBriefDetails>& aVideoList )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetVideoListL");

    TInt error = KErrServerBusy;

    if ( ! IsActive() )

        {

        if ( KErrNone == 

             ( error = SendRequestL( EIptvEngineMyVideosGetVideoListSizeReq,

                                     aParentFolderId,

                                     aFrom,

                                     aAmount ) ) )

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( EIptvEngineMyVideosGetVideoListDataReq ) ) )

                {

                error = HandleMyVideosGetVideoListDataReqL( aTotalAmount, aVideoList );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetVideoDetailsL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetVideoDetailsL(

        CIptvMyVideosGlobalFileId& aFileId,

        CIptvMyVideosVideoFullDetails& aFullDetails )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetVideoDetailsL");

    TInt error = KErrServerBusy;

    if ( ! IsActive() )

        {        

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosGetVideoDetailsSizeReq, aFileId ) ) )

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( EIptvEngineMyVideosGetVideoDetailsDataReq ) ) )

                {

                error = HandleMyVideosGetVideoDetailsDataReqL( aFullDetails );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetVideoDetailsForPathL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetVideoDetailsForPathL(

        const TDesC& aLocalPath,

        CIptvMyVideosVideoFullDetails& aFullDetails )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetVideoDetailsForPathL");

    TInt error = KErrServerBusy;

    if ( aLocalPath.Length() == 0 || aLocalPath.Length() > KIptvMaxPath )

        {

        return KErrArgument;

        }

    if ( ! IsActive() )

        {

        RDesWriteStream writeStream;

        CleanupClosePushL( writeStream );

        TRequestStatus status;

        TUint32 length = aLocalPath.Length();

        // Request for the video details.

        delete iMsg;

        iMsg = NULL;

        iMsg = HBufC8::NewL( KTUint16SizeInBytes + ( length * 2 ) );

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

        writeStream.Open( iMsgPtr );

        CIptvUtil::WriteDesToStreamL( aLocalPath, writeStream );

        CleanupStack::PopAndDestroy( &writeStream );

        iSession.SendRequest( EIptvEngineMyVideosGetVideoDetailsForPathSizeReq, iMsgPtr, status );

        User::WaitForRequest( status );

        error = status.Int();

        // If operation went ok, get the reply data.

        if ( error == KErrNone )    

            {

            if ( KErrNone ==

                 ( error = HandleMyVideosSizeReqL( 

                               EIptvEngineMyVideosGetVideoDetailsForPathDataReq ) ) )

                {

                error = HandleMyVideosGetVideoDetailsDataReqL( aFullDetails );

                }

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::GetTotalVideoLengthRequestL

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

//

EXPORT_C TInt CIptvMyVideosClient::GetTotalVideoLengthRequestL()

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::GetTotalVideoLengthRequestL");

    if (iTotalVideoLengthObserver && (! iTotalVideoLengthObserver->IsActive()))

        {

        iTotalVideoLengthObserver->SetActiveL();

        return KErrNone;

        }

    else

        {

        return KErrServerBusy;

        }

    }

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

// CIptvMyVideosClient::SetVideoDetailsL

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

//

EXPORT_C TInt CIptvMyVideosClient::SetVideoDetailsL( 

        CIptvMyVideosVideoFullDetails& aVideoFullDetails )

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::SetVideoDetailsL()");

    TInt error = KErrServerBusy;

    if ( ! IsActive() )

        {

        if ( KErrNone ==

             ( error = SendRequestL( EIptvEngineMyVideosSetVideoDetailsReq,

                                     aVideoFullDetails ) ) )

            {

            error = HandleMyVideosReqL(); // No return data.

            }

        }

    return error;

    }

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

// CIptvMyVideosClient::DeleteVideoReqL()

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

//

EXPORT_C TInt CIptvMyVideosClient::DeleteVideoReqL(CIptvMyVideosGlobalFileId& aFileId)

    {

    IPTVLOGSTRING_LOW_LEVEL("My Videos Mgr ## CIptvMyVideosClient::DeleteVideoReqL");

    TInt error = KErrServerBusy;

    if (!IsActive())

        {

        if (iMsg)

            {

            delete iMsg;

            iMsg = NULL;

            }

        TUint32 dataSize = aFileId.CountExternalizeSize();

        iMsg = HBufC8::NewL(dataSize);

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

        RDesWriteStream stream;

        stream.Open(iMsgPtr);

        CleanupClosePushL( stream );

        aFileId.ExternalizeL(stream);

        CleanupStack::PopAndDestroy( &stream );

        iSession.SendRequest(EIptvEngineMyVideosDeleteVideoRequestReq, iMsgPtr, iStatus);

        iActiveRequest = EIptvEngineMyVideosDeleteVideoRequestReq;

        SetActive();

        error = KErrNone;

        }

    return error;    

    }

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

// CIptvMyVideosClient::DeleteVideoL

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

//