/*
* Copyright (c) 2006-2009 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: conntest application
*
*/

/**
@file alractiveobject.cpp
ALR application active object.
*/

// INCLUDE FILES
#include <e32cons.h>
#include <comms-infras/mobilitymessagesecom.h>
#include <mobilitymessages.h>
#include "alractiveobject.h"
#include "uinotify.h"

using namespace ESock;

const TInt KCommsMobilityMaxMsgLength = 256;  //Max mobility message size is much less than that

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

// -----------------------------------------------------------------------------
// CALRActiveObject::NewL
// -----------------------------------------------------------------------------
//
CALRActiveObject* CALRActiveObject::NewL(
            MUINotify& aConsole, 
            MMobilityProtocolResp* aApplication)
    {
    CALRActiveObject* self =
        new ( ELeave ) CALRActiveObject(aConsole, aApplication);
    CleanupStack::PushL( self );
    self->ConstructL(aConsole);
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::ConstructL
// -----------------------------------------------------------------------------
//
void CALRActiveObject::ConstructL(MUINotify& /*aConsole*/)
    {
    iResponseBuf.CreateL( KCommsMobilityMaxMsgLength );
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::CALRActiveObject
// -----------------------------------------------------------------------------
//
CALRActiveObject::CALRActiveObject(MUINotify& aConsole, MMobilityProtocolResp* aApplication ) 
    : CActive( CActive::EPriorityStandard ),
    iConsole(aConsole), iApplication(aApplication)
    {
    CActiveScheduler::Add( this );
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::~CALRActiveObject
// -----------------------------------------------------------------------------
//
CALRActiveObject::~CALRActiveObject()
    {
    Cancel();
	iExtApi.Close();
	iResponseBuf.Close();
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::OpenL
// -----------------------------------------------------------------------------
//
void CALRActiveObject::OpenL( RCommsSubSession& aExtensionProvider )
    {
    User::LeaveIfError( iExtApi.Open( aExtensionProvider ) );
    
    //iConsole.PrintNotify(_L("\r\nRegister for mobility notification "));

    iExtApi.RegisterForMobilityNotification( iResponseBuf, iStatus );
    
    //iConsole.PrintNotify(_L("\r\nRegistration successful "));

    SetActive();
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::MigrateToPreferredCarrier
// -----------------------------------------------------------------------------
//
void CALRActiveObject::MigrateToPreferredCarrier()
	{
	iExtApi.MigrateToPreferredCarrier();
	}

// -----------------------------------------------------------------------------
// CALRActiveObject::IgnorePreferredCarrier
// -----------------------------------------------------------------------------
//
void CALRActiveObject::IgnorePreferredCarrier()
	{
    iExtApi.IgnorePreferredCarrier();
	}

// -----------------------------------------------------------------------------
// CALRActiveObject::NewCarrierAccepted
// -----------------------------------------------------------------------------
//
void CALRActiveObject::NewCarrierAccepted()
	{
    iExtApi.NewCarrierAccepted();
	}

// -----------------------------------------------------------------------------
// CALRActiveObject::NewCarrierRejected
// -----------------------------------------------------------------------------
//
void CALRActiveObject::NewCarrierRejected()
	{
    iExtApi.NewCarrierRejected();
	}

// -----------------------------------------------------------------------------
// CALRActiveObject::RunL
// -----------------------------------------------------------------------------
//
void CALRActiveObject::RunL()
    {
    if( iStatus != KErrNone )
        { 
      //  iConsole.Printf(_L("\niStatus: %i\n"), iStatus.Int() );
        iApplication->Error( iStatus.Int() );
//          virtual void Error(TInt aError) = 0;

        return;
        }

	//iConsole.PrintNotify(_L("\r\nReceived notification"));
    CCommsApiExtensionMsg* msg = CCommsApiExtensionMsg::NewL( iResponseBuf );

    //check types
    STypeId preferredCarrierAvailableTID  = STypeId::CreateSTypeId( ESock::KMobilityMessagesImplementationUid, ESock::EPreferredCarrierAvailable );
    STypeId newCarrierActiveTID = STypeId::CreateSTypeId( ESock::KMobilityMessagesImplementationUid, ESock::ENewCarrierActive );
    
    if (msg->IsTypeOf(preferredCarrierAvailableTID))
        {
        CPreferredCarrierAvailable& pca = reinterpret_cast<CPreferredCarrierAvailable&>( *msg );
        iApplication->PreferredCarrierAvailable( pca.OldAPInfo(),
                                                pca.NewAPInfo(),
                                                pca.IsUpgrade(),
                                                pca.IsSeamless() );         
//        virtual void PreferredCarrierAvailable(TAccessPointInfo aOldAP, TAccessPointInfo aNewAP, TBool aIsUpgrade, TBool aIsSeamless) = 0;

        //MigrateToPreferredCarrier();
        }
    else if (msg->IsTypeOf(newCarrierActiveTID))
        {
        CNewCarrierActive& nca = reinterpret_cast<CNewCarrierActive&>( *msg );
        iApplication->NewCarrierActive( nca.NewAPInfo(), nca.IsSeamless() );
//        virtual void NewCarrierActive(TAccessPointInfo aNewAP, TBool aIsSeamless) = 0;
      	//NewCarrierAccepted();
        }
  
    delete msg;

    iExtApi.RegisterForMobilityNotification( iResponseBuf, iStatus );

    SetActive();
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::DoCancel
// -----------------------------------------------------------------------------
//
void CALRActiveObject::DoCancel()
    {
    iExtApi.CancelMobilityNotification();
    }

// -----------------------------------------------------------------------------
// CALRActiveObject::RunError
// -----------------------------------------------------------------------------
//
TInt CALRActiveObject::RunError(TInt aError)
    {
    //The notification has not been sent to the client because of KErrNoMemory
    //We may need to provide an inplace construction for the messages to exclude this possibility.
    return aError;
    }

//  End of File