/*

* Copyright (c) 2000 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:   Implementation of Application Management Components

*

*/

#include <e32svr.h>

#include "ApplicationManagementClientServer.h"

#include "ApplicationManagementClient.h"

#include "ApplicationManagementRfs.h"

#include "debug.h"

#include <apacmdln.h>

#include <apgtask.h>

#include <apgcli.h>

#include <badesca.h>

using namespace NApplicationManagement;

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

// Server startup code

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

static TInt StartAMServerL()

	{

	RDEBUG("RApplicationManagement: Starting server...");

	TInt err = KErrNone;

	const TUid nameUid = TUid::Uid(KUikonUidPluginInterfaceNotifiers);

	const TUid appServerUid = TUid::Uid(KAppMgmtServerUid );

	RApaLsSession apa;

    err = apa.Connect();

    User::LeaveIfError(err);

    CleanupClosePushL(apa);

    // Get application information

    TApaAppInfo info;

    for(TInt i = 20; ((err = apa.GetAppInfo(info, 

	    appServerUid)) == RApaLsSession::EAppListInvalid) && i > 0; i--)

        {

        User::After(500000);

        }

    User::LeaveIfError(err);

	TRequestStatus aRequestStatusForRendezvous;

    // Start aplication server

    CApaCommandLine* cmdLine = CApaCommandLine::NewLC();

    cmdLine->SetExecutableNameL(info.iFullName);

    cmdLine->SetServerRequiredL(nameUid.iUid );

    cmdLine->SetCommandL(EApaCommandBackground);

    TThreadId   srvid;

    err = apa.StartApp(*cmdLine, srvid, &aRequestStatusForRendezvous);

    User::LeaveIfError(err);

	User::WaitForRequest(aRequestStatusForRendezvous);

	CleanupStack::PopAndDestroy(2, &apa);	// cmdLine and apa 

	return KErrNone;

	}

EXPORT_C RAppMgmtRfs::RAppMgmtRfs()

    {

    }

EXPORT_C TInt RAppMgmtRfs::Connect()

	{

	TInt retry=2;

	TVersion ver( KAMVerMajor, KAMVerMinor, KAMVerBuild );

	for (;;)

		{

		TInt r;

		const TUid nameUid = TUid::Uid(KUikonUidPluginInterfaceNotifiers);

		const TUid appServerUid = TUid::Uid(KAppMgmtServerUid );

		_LIT(KServerNameFormat, "%08x_%08x_AppServer");

		TFullName serverName;

		serverName.Format(KServerNameFormat, 

		nameUid, appServerUid);

        TRAP(r, ConnectExistingByNameL(serverName) );

        if(r)

            {

            r = CreateSession (serverName, ver);

            }    

		if (r!=KErrNotFound && r!=KErrServerTerminated)

			return r;

		if (--retry==0)

			return r;

		TRAP_IGNORE(r=StartAMServerL());

		if (r!=KErrNone && r!=KErrAlreadyExists)

			{

			return r;

			}

		}

	}

EXPORT_C void RAppMgmtRfs::Close()

	{

	REikAppServiceBase::Close();  //basecall

	}

// New methods

EXPORT_C void RAppMgmtRfs::PerformRfsL() const

	{

	User::LeaveIfError( SendReceive( EPerformRfs, TIpcArgs() ) );	

	}

TUid RAppMgmtRfs::ServiceUid() const

	{

	return TUid::Uid( KAMServiceUid);

	}

EXPORT_C RApplicationManagement::RApplicationManagement()

    {

    }

// This is the standard retry pattern for server connection

EXPORT_C TInt RApplicationManagement::Connect( )

	{

	TInt retry=2;

	TVersion ver( KAMVerMajor, KAMVerMinor, KAMVerBuild );

	for (;;)

		{

		TInt r;

		const TUid nameUid = TUid::Uid(KUikonUidPluginInterfaceNotifiers);

		const TUid appServerUid = TUid::Uid(KAppMgmtServerUid );

		_LIT(KServerNameFormat, "%08x_%08x_AppServer");

		TFullName serverName;

		serverName.Format(KServerNameFormat, 

		nameUid, appServerUid);

        TRAP(r, ConnectExistingByNameL(serverName) );

        if(r)

            {

            r = CreateSession (serverName, ver);

            }    

		if (r!=KErrNotFound && r!=KErrServerTerminated)

			return r;

		if (--retry==0)

			return r;

		TRAP_IGNORE(r=StartAMServerL())

		if (r!=KErrNone && r!=KErrAlreadyExists)

			{

			return r;

			}

		}

	}

EXPORT_C TInt RApplicationManagement::Connect( const TCertInfo &aCertInfo )

	{

	TInt r( Connect() );

	if ( r == KErrNone || r == KErrAlreadyExists )

		{

		TPckg<TCertInfo> pkg( aCertInfo );

		r = SendReceive( EAddTrust, TIpcArgs( &pkg ) );

		}

	return r;

	}

EXPORT_C void RApplicationManagement::Close()

	{

	REikAppServiceBase::Close();

	}

EXPORT_C TUint32 RApplicationManagement::DeliverL( const TDCUserId &aUserId ) const

	{

	TDeploymentComponent aInfo( KNullDesC8(), KNullDesC8(), KNullDesC8(), EDCSNone );

	TDeploymentComponentIPC pkg( aInfo, KNullDesC8(), aUserId );

	TPckg<TDeploymentComponentIPC> pinfo(pkg);

	TUint32 id = 0;

	TPckg< TUint32 > pid( id );

	const TDesC8& empty = KNullDesC8();

	TInt err( SendReceive( EDeplCompDeliverStartOperation2, TIpcArgs( &pinfo, &empty, &pid) ) );	

	if ( err == KErrNone )

		{

		RDEBUG_2( "ApplicationManagementServer: DeliverL start SUCCESS id: %d", id );

		//TPckg<TDeploymentComponent> pinfo2(aInfo);

		err = SendReceive( EDeplCompDeliverCompleteOperation, TIpcArgs( &pid, &empty, &empty ));

		if ( err == KErrNone )

			{	

			RDEBUG_2( "ApplicationManagementServer: DeliverL complete SUCCESS id: %d", id );

			err = id;

			}

		else

			{

			RDEBUG_2( "ApplicationManagementServer: DeliverL failed2... %d", err);

			}

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: DeliverL failed1... %d", err);

		}

	User::LeaveIfError( err );

	return err;

	}

EXPORT_C TInt RApplicationManagement::DeploymentComponent( 

	TUint32 aInternalId, TDeploymentComponent &aReturnValue ) const

	{

	TPckg<TDeploymentComponent> pinfo(aReturnValue);

	TPckg< TUint32 > pid( aInternalId );

	TInt err( SendReceive( EDeplCompGetOperation, TIpcArgs( &pid, &pinfo) ) );	

	if ( err == KErrNone )

		{

		RDEBUG_2( "RApplicationManagement: DeploymentComponent start SUCCESS id: %d", aInternalId );

		}

	else

		{

		RDEBUG_2("RApplicationManagement: DeploymentComponent failed... %d", err);

		}

	return err;

	}

EXPORT_C void RApplicationManagement::DeploymentComponentUserIdL( 

	TUint32 aInternalId, TDCUserId &aResponse ) const

	{

	TPckgC< TUint32 > pid( aInternalId );

	TInt err( SendReceive( EDeplCompGetUserIdOperation, TIpcArgs( &pid, &aResponse) ) );	

	if ( err == KErrNone )

		{

		RDEBUG_2( "RApplicationManagement: DeploymentComponentUserIdL SUCCESS id: %d", aInternalId );

		}

	else

		{

		RDEBUG_2( "RApplicationManagement: DeploymentComponentUserIdL failed... %d", err);

		}

	User::LeaveIfError( err );

	}

/**

* @param aInternalId Id of the component to be found

* @param aBuffer a buffer to store results

* @return KErrNone Symbian error code

*/

EXPORT_C void RApplicationManagement::DeploymentComponentDataL( 

	TUint32 aInternalId, TDeplCompAttrType aDataType, CBufBase &aBuffer ) const

	{

	//aBuffer.ResizeL(

	TPckg< TUint32 > pid( aInternalId );

	TPckg< TDeplCompAttrType > pdt( aDataType );

	TInt length( 0 );

	TPckg< TInt > plen( length );

	aBuffer.Reset();

	TInt err( KErrNone) ;

	if ( aDataType == EDCInstallOptions 

		|| aDataType == EDCMetaData 

		|| aDataType ==	EDCData

		|| aDataType ==	EDCDataMime

		|| aDataType ==	EDCMetaDataMime

	 	|| aDataType == EDCDownloadURI )

		{

		err = SendReceive( EDeplCompGetDataLengthOperation, TIpcArgs( &pid, &pdt, &plen) ) ;

		if ( err == KErrNone )

			{

			}

		else

			{

			RDEBUG_2( "RApplicationManagement: DeploymentComponentDataL EDeplCompGetDataLengthOperation ERROR failed to get length... %d", err );

			}

		}

	else if ( aDataType == EDCStatus)

		{

		length = 0; // to make sure we don't fetch it twice

		TPckgBuf<TInt> ptr;

		err = SendReceive( EDeplCompGetDataOperation, TIpcArgs( &pid, &pdt, &ptr ) );

		if ( err == KErrNone )

			{	

			TBuf8<10> b;

			b.AppendNum( ptr() );

			aBuffer.InsertL( 0, b );

			RDEBUG( "RApplicationManagement: DeploymentComponentDataL EDCDownloadStatus SUCCESS!" );

			}

		else

			{

			RDEBUG_2( "RApplicationManagement: DeploymentComponentDataL EDCDownloadStatus ERROR failed... %d", err );

			}

		}

	else if ( aDataType == EDCConRef )

		{

		length = 0; // to make sure we don't fetch it twice

		TPckgBuf<TInt> ptr;

		err = SendReceive( EDeplCompGetDataOperation, TIpcArgs( &pid, &pdt, &ptr ) );

		if ( err == KErrNone )

			{	

			aBuffer.InsertL( 0, ptr );

			RDEBUG( "RApplicationManagement: DeploymentComponentDataL EDCConRef SUCCESS!" );

			}

		else

			{

			RDEBUG_2( "RApplicationManagement: DeploymentComponentDataL EDCConRefERROR failed... %d" , err );

			}

		}

	else

		{

		User::Leave( KErrArgument );

		}

	if ( length > 0 )

		{

		HBufC8 *buf = HBufC8::NewLC( length );

		TPtr8 ptr( buf->Des() );

		err = SendReceive( EDeplCompGetDataOperation, TIpcArgs( &pid, &pdt, &ptr ) );

		if ( err == KErrNone )

			{	

			aBuffer.InsertL( 0, ptr );

			RDEBUG( "RApplicationManagement: DeploymentComponentDataL EDeplCompGetDataOperation SUCCESS!" );

			}

		else

			{

			RDEBUG_2( "RApplicationManagement: DeploymentComponentDataL EDeplCompGetDataOperationERROR failed... %d", err );

			}

		CleanupStack::PopAndDestroy( buf );

		}

	else

		{

		RDEBUG( "RApplicationManagement: DeploymentComponentDataL:  Length is zero" );

		}

	User::LeaveIfError( err );

	}

EXPORT_C TInt RApplicationManagement::DeploymentComponentIdsL(

			RElementIdArray &aArray, const TDeploymentComponentState aState	) const

	{

	RDEBUG_2( "RApplicationManagement: DeploymentComponentIds aState=%d!", aState );

	TInt count = 0;

	TPckg<TInt> cnt(count);

	TPckg<TDeploymentComponentState> pk(aState);

	TInt err( SendReceive( EDeplCompCountOperation, TIpcArgs( &cnt, &pk ) ) );

	RDEBUG_2( "RApplicationManagement: DeploymentComponentIds : Count is %d", count );

	if ( err == KErrNone )

		{

		if ( count > 0 )

			{

			aArray.Reset();

			for ( TInt i( 0 ); i != count; ++i )

				{

				aArray.AppendL( 0 );

				}

			TPtr8 p( reinterpret_cast< TUint8* >( &aArray[0] ), 0, count * sizeof( TUint32 ) );

			err = SendReceive( EDeplCompIdsOperation, TIpcArgs( &p, &pk ) ) ;	

			if ( err == KErrNone )

				{	

				RDEBUG( "RApplicationManagement: DeploymentComponentIds SUCCESS!" );

				}

			else

				{

				RDEBUG_2( "RApplicationManagement: DeploymentComponentIds failed... %d", err );

				}

			}

		}

	else

		{

		RDEBUG_2( "RApplicationManagement: DeploymentComponentIds failed to get count... %d", err);

		}

	return err;

	}

/**

* InstallL Installs given deployment component.

* @param aDeploymentComponent The deployment component to be installed

* @param aTargetState Will the installed component be actibve or inactive (default active)

* @return KErrNone Symbian error code

*/

EXPORT_C void RApplicationManagement::InstallL( TUint32 aInternalId, 

	TDeploymentComponentState aTargetState  ) const

	{

	TPckg<TUint32> id(aInternalId);

	if ( aTargetState != EDCSActive && aTargetState != EDCSInactive )

		{

		// install only to either of above states

		User::Leave( KErrArgument );

		}

	TPckg<TDeploymentComponentState> pk( aTargetState );

	TInt err( SendReceive( EInstallOperation, TIpcArgs( &id, &pk ) ) );	

	if ( err == KErrNone )

		{

		RDEBUG( "RApplicationManagement: InstallL SUCCESS!" );

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: InstallL failed... %d", err);

		if( err == KErrNotFound )

			{

			err = KErrArgument ; // indicates that data was not filled...

			}

		}

	User::LeaveIfError( err ) ;

	}

EXPORT_C void RApplicationManagement::UpdateDeploymentComponentDataL( 

		TUint32 aInternalId, TDeplCompAttrType aItem, const TDesC8 &aItemData, const TDesC8 &aDataMime  ) const

	{

	TDeplCompDataIPC ipc ;

	ipc.iDataMime = aDataMime;

	ipc.iInternalId = aInternalId ;

	ipc.iAttrType = aItem ;

	TPckg<TDeplCompDataIPC> pipc( ipc );

	TInt err( SendReceive( EDeplCompUpdateDataOperation, TIpcArgs( &pipc, &aItemData ) ) );	

	if ( err == KErrNone )

		{

		RDEBUG( "RApplicationManagement: UpdateDeploymentComponentDataL SUCCESS!" );

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: UpdateDeploymentComponentDataL failed... %d", err);

		}

	User::LeaveIfError( err );

	}

EXPORT_C void RApplicationManagement::UpdateDeploymentComponentStreamedDataL( 

		TUint32 aInternalId, TDeplCompAttrType aItem, const TDesC8 &aDataMime  ) const

	{

	TDeplCompDataIPC ipc ;

	ipc.iDataMime = aDataMime;

	ipc.iInternalId = aInternalId ;

	ipc.iAttrType = aItem ;

	TPckg<TDeplCompDataIPC> pipc( ipc );

	TInt err( SendReceive( EDeplCompUpdateStreamedDataOperation, TIpcArgs( &pipc ) ) );	

	if ( err == KErrNone )

		{

		RDEBUG( "RApplicationManagement: UpdateDeploymentComponentStreamedDataL SUCCESS!" );

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: UpdateDeploymentComponentStreamedDataL failed... %d", err);

		}

	User::LeaveIfError( err );

	}

EXPORT_C void RApplicationManagement::UpdateDeploymentComponentL( 

			TUint32 aInternalId, TDeplCompAttrType aItem, const TDesC8 &aItemData ) const

	{

	TPckg<TUint32> id(aInternalId);

	TPckg<TDeplCompAttrType> itemid(aItem);

	TInt err( SendReceive( EDeplCompAttrUpdateOperation, TIpcArgs( &id, &itemid, &aItemData ) ) );	

	if ( err == KErrNone )

		{

		RDEBUG( "RApplicationManagement: UpdateDeploymentComponentL SUCCESS!" );

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: UpdateDeploymentComponentL failed... %d", err);

		}

	User::LeaveIfError( err );

	}

/**

* RemoveL Removes given deployment component.

* @param aInternalId Id of the component to be removed

* @return KErrNone Symbian error code

*/

EXPORT_C void RApplicationManagement::RemoveL( TUint32 aInternalId ) const

	{

	TPckg< TUint32 > id( aInternalId );

	RDEBUG_2( "RApplicationManagement: RemoveL %d!" , aInternalId );

	TInt err( SendReceive( EDeplCompRemoveOperation, TIpcArgs( &id ) ) );	

	if ( err == KErrNone )

		{

		RDEBUG( "RApplicationManagement: RemoveL SUCCESS!" );

		}

	else if ( err == KErrNotFound )

		{

		RDEBUG( "RApplicationManagement: RemoveL WARNING Component already missing!" );

		}

	else

		{

		RDEBUG_2("ApplicationManagementServer: RemoveL failed... %d", err);

		User::LeaveIfError( err );

		}

	}

/**

		* StartDownloadL Starts download of deployment component.

		* @param aInternalId The id of the component to be downloaded

	    * @return