// Copyright (c) 1997-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:

//

/**

 @file

*/

#include <comms-infras/mobilitymessages_internal.h>

#include <comms-infras/es_mobility_apiext.h>

#include <comms-infras/mobilitymessagesecom.h>

#include <comms-infras/mobilitymessages.h>

using namespace ESock;

/**

Default empty constructor, and is present only to support virtual

function table export.

@publishedPartner

@released

*/

EXPORT_C RCommsMobilityApiExt::RCommsMobilityApiExt()

	{

	}

/**

Closes the extension after it has been used. It is not possible to use 

an extension after it has been closed.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::Close()

	{

	RCommsApiExtensionBase::Close();

	}

/**

This API is used to register (subscribe) for Mobility notifications from the Implementation. 

@param aResponseEventBuf	Will be filled with a corresponding response message before aStatus is completed.

@param aReqStatus 			Returns the result code after the asynchronous call completes.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::RegisterForMobilityNotification(TDes8& aResponseEventBuf, TRequestStatus& aStatus)

	{

	TMobilitySubscriptionMsg msg;

	SendRequest(msg, aResponseEventBuf, aStatus);

	}

/**

Cancels previously requested subscription for Mobility notifications.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::CancelMobilityNotification()

	{

	TMobilitySubscriptionCancelMsg msg;	

	SendMessage(msg);

	}

/**

Instructs the Implementation that it should migrate the Client to the newly 

available preferred carrier (or, in case of the current carrier becoming unavailable, 

to the less preferred but available carrier).

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::MigrateToPreferredCarrier()

	{

	TMigrateToPreferredCarrier msg;

	SendMessage(msg);

	}

/**

Instructs the Implementation that it should not migrate the Client to the newly 

available preferred carrier and that the Client wishes to continue using the current carrier.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::IgnorePreferredCarrier()

	{

	TIgnorePreferredCarrier msg;

	SendMessage(msg);

	}

/**

Instructs the Implementation that the Client wishes to use the new carrier it has been migrated to.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::NewCarrierAccepted()

	{

	TNewCarrierAccepted msg;

	SendMessage(msg);

	}

/**

Instructs the Implementation that the Client wishes to reject the new carrier it has been 

migrated to and be offered another preferred carrier unless nothing else is available. 

In case nothing else is available the request completes with an error.

@publishedPartner

@released

*/

EXPORT_C void RCommsMobilityApiExt::NewCarrierRejected()

	{

	TNewCarrierRejected msg;

	SendMessage(msg);

	}

void CActiveCommsMobilityApiExt::DoCancel()

    {

    iExtApi.CancelMobilityNotification();

    iProtocol.Error(KErrCancel);

    }

void CActiveCommsMobilityApiExt::RunL()

    {

    if(iStatus.Int() == KErrNone)

        {

        CCommsApiExtRespMsg* msg = CCommsApiExtRespMsg::NewL(iResponseBuf);

        // Re-register for the next message.

        iExtApi.RegisterForMobilityNotification(iResponseBuf,iStatus);

        SetActive();

        //check types

        STypeId preferredCarrierAvailableTid = STypeId::CreateSTypeId(KMobilityMessagesImplementationUid,EPreferredCarrierAvailable);

        STypeId newCarrierActiveTid = STypeId::CreateSTypeId(KMobilityMessagesImplementationUid,ENewCarrierActive);

        if (msg->IsTypeOf(preferredCarrierAvailableTid))

           {

           CPreferredCarrierAvailable& pca = reinterpret_cast<CPreferredCarrierAvailable&>(*msg);

           iProtocol.PreferredCarrierAvailable(pca.OldAPInfo(),pca.NewAPInfo(),pca.IsUpgrade(),pca.IsSeamless());

           }

        else if (msg->IsTypeOf(newCarrierActiveTid))

           {

           CNewCarrierActive& nca = reinterpret_cast<CNewCarrierActive&>(*msg);

           iProtocol.NewCarrierActive(nca.NewAPInfo(),nca.IsSeamless());

           }

        delete msg;

        }

	else

		{

        iProtocol.Error(iStatus.Int());

		}

    }

TInt CActiveCommsMobilityApiExt::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;

    }

/**

This call is used to construct the Mobility extension, initialised with the MMobilityProtocolResp 

implementation provided as a parameter. MMobilityProtocolResp implementation is used when a Mobility 

notification arrives to the Client and is being dispatched on one of the call back APIs of MMobilityProtocolResp.

@param aExtensionProvider	The corresponding RCommsSubSession under which the extension is to be opened

							(in case of Mobility this is the RConnection or RCommsManager instance).

@param aProtocol			Handles the response communication between the implementation and the client.

@publishedPartner

@released

*/

EXPORT_C CActiveCommsMobilityApiExt* CActiveCommsMobilityApiExt::NewL(RCommsSubSession& aExtensionProvider,MMobilityProtocolResp& aProtocol)

    {

    CActiveCommsMobilityApiExt* self = new (ELeave) CActiveCommsMobilityApiExt(aProtocol);

    CleanupStack::PushL(self);

    self->ConstructL(aExtensionProvider);

    CleanupStack::Pop(self);

    return self;

    }

/**

Cancels the outstanding notification request and deletes the Mobility extension.

@publishedPartner

@released

*/

EXPORT_C CActiveCommsMobilityApiExt::~CActiveCommsMobilityApiExt()

	{

	Cancel();

	iExtApi.Close();

	iResponseBuf.Close();

	}

void CActiveCommsMobilityApiExt::ConstructL(RCommsSubSession& aExtensionProvider)

    {

    User::LeaveIfError(iExtApi.Open(aExtensionProvider));

    iResponseBuf.CreateL(KMaxExtApiIpcMsgLength);

    iExtApi.RegisterForMobilityNotification(iResponseBuf,iStatus);

    SetActive();

    }

CActiveCommsMobilityApiExt::CActiveCommsMobilityApiExt(MMobilityProtocolResp& aProtocol)

:   CActive(CActive::EPriorityUserInput),

    iProtocol(aProtocol)

	{

	CActiveScheduler::Add(this);

	}

/**

Instructs the Implementation that it should migrate the Client to the newly 

available preferred carrier (or, in case of the current carrier becoming 

unavailable, to the less preferred but available carrier).

@publishedPartner

@released

*/

EXPORT_C void CActiveCommsMobilityApiExt::MigrateToPreferredCarrier()

	{

	iExtApi.MigrateToPreferredCarrier();

	}

/**

Instructs the Implementation that it should not migrate the Client to the 

newly available preferred carrier and that the Client wishes to continue using 

the current carrier.

@publishedPartner

@released

*/

EXPORT_C void CActiveCommsMobilityApiExt::IgnorePreferredCarrier()

	{

    iExtApi.IgnorePreferredCarrier();

	}

/**

Instructs the Implementation that the Client wishes to use the new carrier it has been migrated to.

@publishedPartner

@released

*/

EXPORT_C void CActiveCommsMobilityApiExt::NewCarrierAccepted()

	{

    iExtApi.NewCarrierAccepted();

	}

/**

Instruct the Implementation that the Client wishes to reject the new carrier 

it has been migrated to be offered another preferred carrier unless nothing else is available. 

In case nothing else is available the request completes with an error.

@publishedPartner

@released

*/

EXPORT_C void CActiveCommsMobilityApiExt::NewCarrierRejected()

	{

    iExtApi.NewCarrierRejected();

	}