/*

* Copyright (c) 2002 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: AlwaysOnline server command operation

*

*/

// INCLUDE FILES

#include "HandleServerCommandOperation.h"

#include "AlwaysOnlineManagerLogging.h"

// CONSTANTS

_LIT8( KAOCmdStart, "AOCmdStart:" );

_LIT8( KAOCmdEnd, ":AOCmdEnd" );

_LIT8( KColon, ":" );

// FORWARD DECLARATIONS

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

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

// CAOServerCommandHandler::CAOServerCommandHandler

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CAOServerCommandHandler::CAOServerCommandHandler( 

    CMsvSession& aMsvSession,

    TInt aPriority,

    TRequestStatus& aObserverRequestStatus,

    CAlwaysOnlineEComInterface& aPlugin,

    TManagerServerCommands aCommand )

    : 

    CMsvOperation(aMsvSession, aPriority, aObserverRequestStatus),

    iPlugin( aPlugin ),

    iCommand( aCommand )    

    {

    }

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

// CAOServerCommandHandler::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CAOServerCommandHandler::ConstructL( const TDes8& aParameter)

    {

    CActiveScheduler::Add(this);

    // Copy the contents from the passed parameter into member variable,

    // so that the contents of the parameter remains in safe memory area.

    iParameterBuf = aParameter.AllocL();

    StartOperationL();

    KAOMANAGER_LOGGER_WRITE("CAOServerCommandHandler::ConstructL() Operation Started");

    }

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

// CAOServerCommandHandler::StartOperationL

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

//

void CAOServerCommandHandler::StartOperationL()

    {

    KAOMANAGER_LOGGER_WRITE_FORMAT("CAOServerCommandHandler::StartOperationL() Creating async call for HandleServerCommand(). TManagerServerCommand: %d", iCommand);

    SetActive();

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrNone);

    }

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

// CAOServerCommandHandler::NewL

// Two-phased constructor.

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

//

CAOServerCommandHandler* CAOServerCommandHandler::NewL( 

    CMsvSession& aMsvSession,

    TRequestStatus& aObserverRequestStatus,

    TManagerServerCommands aCommand,

    TDes8& aParameter,

    CAlwaysOnlineEComInterface& aPlugin)

    {

    CAOServerCommandHandler* self = new( ELeave ) CAOServerCommandHandler( 

        aMsvSession, 

        CActive::EPriorityIdle,

        aObserverRequestStatus,

        aPlugin,

        aCommand );

    KAOMANAGER_LOGGER_WRITE_FORMAT("CAOServerCommandHandler created to address 0x%x", self);

    CleanupStack::PushL( self );

    self->ConstructL( aParameter );

    CleanupStack::Pop( self );

    return self;

    }

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

// ~CAOServerCommandHandler

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

//

CAOServerCommandHandler::~CAOServerCommandHandler()

    {

    Cancel();

    delete iParameterBuf;

    }

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

// CAOServerCommandHandler::ProgressL

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

//

const TDesC8& CAOServerCommandHandler::ProgressL()

    {

    return iProgress;

    }

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

// CAOServerCommandHandler::FinalProgress

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

//

const TDesC8& CAOServerCommandHandler::FinalProgress()

    {

    return iFinalProgress;

    }

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

// CAOServerCommandHandler::DoCancel

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

void CAOServerCommandHandler::DoCancel()

    {

    KAOMANAGER_LOGGER_WRITE("CAOServerCommandHandler::DoCancel() Operation Cancelled");

    TRequestStatus* status = &iObserverRequestStatus;

    User::RequestComplete( status, KErrCancel );

    }

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

// CAOServerCommandHandler::RunL

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

void CAOServerCommandHandler::RunL()

    {    

    KAOMANAGER_LOGGER_WRITE("CAOServerCommandHandler::RunL() Command Issued!");

    TAny* response = iPlugin.HandleServerCommandL( iCommand, iParameterBuf );

    TRequestStatus* status = &iObserverRequestStatus;

    User::RequestComplete( status, KErrNone );

    SetFinalProgressFromResult( response );

    }

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

// CAOServerCommandHandler::RunError()

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

//

TInt CAOServerCommandHandler::RunError( TInt aError )

    {

    // A leave occurred in plugin command handler. Complete watcher

    // with error.

    TRequestStatus* status = &iObserverRequestStatus;

    User::RequestComplete( status, aError );

    return KErrNone;

    }

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

// CAOServerCommandHandler::SetFinalProgressFromResult()

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

//  

void CAOServerCommandHandler::SetFinalProgressFromResult( TAny* aResponse )

    {

    iFinalProgress.Zero();

    iFinalProgress.Append( KAOCmdStart );

    iFinalProgress.AppendNum( iPlugin.InstanceUid().iUid );

    iFinalProgress.Append( KColon );

    iFinalProgress.AppendNum( iCommand );

    iFinalProgress.Append( KColon );

    // aResponse should be handled based on command.

    HandleResponse( aResponse );

    iFinalProgress.Append( KAOCmdEnd );

    }

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

// CAOServerCommandHandler::HandleResponse()

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

//  

void CAOServerCommandHandler::HandleResponse( TAny* aResponse )

    {

    switch ( iCommand )

        {

        case EAOManagerSuicideQuery:

            // aResponse should contain either 0 or 1.

            iFinalProgress.AppendNum( reinterpret_cast<TBool>( aResponse ) );

            KAOMANAGER_LOGGER_WRITE_FORMAT("CAOServerCommandHandler::HandleResponse() EAOManagerSuicideQuery, aResponse %d", aResponse);

            break;

        default:

            // Other commands doesn't respond anything useful.

            iFinalProgress.AppendNum( reinterpret_cast<TInt>( aResponse ) );

            KAOMANAGER_LOGGER_WRITE_FORMAT("CAOServerCommandHandler::HandleResponse() default, aResponse %d", aResponse);

            break;

        }

    }

//  End of File