/*
* Copyright (c) 2004-2009 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: 
* sisregistry - restricted client registry session interface implementation
*
*/


/**
 @file 
 @released
 @internalTechnology
*/

#include <s32mem.h>
#include "sisregistrywritablesession.h"
#include "sisregistryobject.h"
#include "sisregistryclientserver.h"
#include "application.h"
#include "siscontroller.h"
#include "sisinfo.h"
#include "sisuid.h"
#include "cleanuputils.h"
#include "arrayutils.h"
#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
#include "swtypereginfo.h"
#endif

using namespace Swi;

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
EXPORT_C void RSisRegistryWritableSession::CreateTransactionL()
	{
	User::LeaveIfError(SendReceive(ECreateTransaction));
	}

EXPORT_C void RSisRegistryWritableSession::CommitTransactionL()
	{
	User::LeaveIfError(SendReceive(ECommitTransaction));
	}

EXPORT_C void RSisRegistryWritableSession::RollbackTransactionL()
	{
	User::LeaveIfError(SendReceive(ERollbackTransaction));
	}
#endif

void RSisRegistryWritableSession::AddEntryImplL(TInt aMessage,
												const CApplication& aApplication,
												const TDesC8& aController, 
												TInt64 aTransactionID,
												TIpcArgs& aIpcArgs)
	{
	CBufFlat* tempBuffer = CBufFlat::NewL(KDefaultBufferSize);
	CleanupStack::PushL(tempBuffer);
	
	CSisRegistryObject* object = CSisRegistryObject::NewLC();
	object->ProcessApplicationL(aApplication, aController);
	
	RBufWriteStream stream(*tempBuffer);
 	CleanupClosePushL(stream);
 	
	object->ExternalizeL(stream);
	
	CleanupStack::PopAndDestroy(2, object); // stream
	
	// Now, create an HBufC8 from the stream buf's length, and copy 
	// the stream buffer into this descriptor
	HBufC8* buffer = HBufC8::NewLC(tempBuffer->Size());
	TPtr8 ptr(buffer->Des());
	tempBuffer->Read(0, ptr, tempBuffer->Size());
	
	TPckgC<TInt64> transactionID(aTransactionID);
	
	aIpcArgs.Set(0, &ptr);
	aIpcArgs.Set(1, &transactionID);
	aIpcArgs.Set(2, &aController);
	
	User::LeaveIfError(SendReceive(aMessage, aIpcArgs));
	
	CleanupStack::PopAndDestroy(2, tempBuffer); // buffer
	}

EXPORT_C void RSisRegistryWritableSession::AddEntryL(const CApplication& aApplication,
													 const TDesC8& aController, 
													 TInt64 aTransactionID)
	{
	TIpcArgs ipcArgs;
	AddEntryImplL(EAddEntry, aApplication, aController, aTransactionID, ipcArgs);
	}

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
EXPORT_C void RSisRegistryWritableSession::AddEntryL(const CApplication& aApplication,
													 const TDesC8& aController,
													 const RPointerArray<CSoftwareTypeRegInfo>& aSwTypeRegInfoArray,
													 TInt64 aTransactionID)
	{
	RBuf8 serializedArray;
	serializedArray.CleanupClosePushL();
	SoftwareTypeRegInfoUtils::SerializeArrayL(aSwTypeRegInfoArray, serializedArray);
	TIpcArgs ipcArgs;
	ipcArgs.Set(3, &serializedArray);

	AddEntryImplL(EAddSoftwareTypeEntry, aApplication, aController, aTransactionID, ipcArgs);

	CleanupStack::PopAndDestroy(&serializedArray);
	}
#endif

void RSisRegistryWritableSession::UpdateEntryImplL(TInt aMessage,
												   const CApplication& aApplication, 
												   const TDesC8& aController, 
												   TInt64 aTransactionID,
												   TIpcArgs& aIpcArgs)
	{
	CSisRegistryObject* object;
	
	// create a buffer for the final extenalisation
	CBufFlat* tempBuffer = CBufFlat::NewL(KDefaultBufferSize);
	CleanupStack::PushL(tempBuffer);
	
	// check whether it is full or partial upgrade
	if (aApplication.IsPartialUpgrade())
		{
		TUid uid = aApplication.ControllerL().Info().Uid().Uid();
		TPckg<TUid> packageUid(uid);
		// request the copy of the object across IPC
		HBufC8* buffer = SendReceiveBufferLC(EGetEntry, packageUid);

		// create a stream based on the buffer
		RDesReadStream stream(*buffer);
		CleanupClosePushL(stream);
		
		// reassemble the object from the stream
		object = CSisRegistryObject::NewLC(stream);
		CleanupStack::Pop(object);
		
		CleanupStack::PopAndDestroy(2, buffer); // buffer, stream
		CleanupStack::PushL(object);
		// update the entry using the application stuff
		object->UpgradeApplicationL(aApplication, aController);
		}
	else
		{
		// create a new object
		object = CSisRegistryObject::NewLC();
		object->ProcessApplicationL(aApplication, aController);
		}

	// create a stream to extenalise to
	RBufWriteStream stream(*tempBuffer);
 	CleanupClosePushL(stream);

	object->ExternalizeL(stream);
	
	CleanupStack::PopAndDestroy(2, object); // stream
	
	// create an HBufC8 from the stream buf's length, and copy 
	// the stream buffer into this descriptor
	HBufC8* buffer = HBufC8::NewLC(tempBuffer->Size());
	TPtr8 ptr(buffer->Des());
	tempBuffer->Read(0, ptr, tempBuffer->Size());
	
	// pass the transasction Id
	TPckgC<TInt64> transactionID(aTransactionID);
	
	aIpcArgs.Set(0, &ptr);
	aIpcArgs.Set(1, &transactionID);
	aIpcArgs.Set(2, &aController);
	
	User::LeaveIfError(SendReceive(aMessage, aIpcArgs));

	CleanupStack::PopAndDestroy(2, tempBuffer); // buffer 
	}

EXPORT_C void RSisRegistryWritableSession::UpdateEntryL(const CApplication& aApplication, 
														const TDesC8& aController, 
														TInt64 aTransactionID)
	{
	TIpcArgs ipcArgs;
	UpdateEntryImplL(EUpdateEntry, aApplication, aController, aTransactionID, ipcArgs);
	}

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
EXPORT_C void RSisRegistryWritableSession::UpdateEntryL(const CApplication& aApplication, 
														const TDesC8& aController,
														const RPointerArray<CSoftwareTypeRegInfo>& aSwTypeRegInfoArray,
														TInt64 aTransactionID)
	{
	RBuf8 serializedArray;
	serializedArray.CleanupClosePushL();
	SoftwareTypeRegInfoUtils::SerializeArrayL(aSwTypeRegInfoArray, serializedArray);
	TIpcArgs ipcArgs;
	ipcArgs.Set(3, &serializedArray);
	
	UpdateEntryImplL(EUpdateSoftwareTypeEntry, aApplication, aController, aTransactionID, ipcArgs);
	
	CleanupStack::PopAndDestroy(&serializedArray);
	}
#endif

EXPORT_C void RSisRegistryWritableSession::DeleteEntryL(const CSisRegistryPackage& aPackage, TInt64 aTransactionID)
	{
	TPckgC<TUid> packageUid(aPackage.Uid());
	TPckgC<TInt64> transactionID(aTransactionID);

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
	TPckgC<TInt> packageIndex(aPackage.Index());
	User::LeaveIfError(SendReceive(EDeleteEntry, TIpcArgs(&packageUid, &packageIndex, &transactionID)));
#else
	User::LeaveIfError(SendReceive(EDeleteEntry, TIpcArgs(&packageUid, &aPackage.Name(), &aPackage.Vendor(), &transactionID)));
#endif
	}

EXPORT_C void RSisRegistryWritableSession::AddDriveL(const TInt aDrive)
	{
	TPckgC<TInt> packageDrive(aDrive);
	User::LeaveIfError(SendReceive(EAddDrive, TIpcArgs(&packageDrive)));	
	}

#ifndef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
EXPORT_C void RSisRegistryWritableSession::RemoveDriveL(const TInt aDrive)
	{
	TPckgC<TInt> packageDrive(aDrive);
	User::LeaveIfError(SendReceive(ERemoveDrive, TIpcArgs(&packageDrive)));	
	}

EXPORT_C void RSisRegistryWritableSession::RegenerateCacheL()
	{
	User::LeaveIfError(SendReceive(ERegenerateCache));
	}
#endif

/**
* Returns ETrue if any ROM stub in the filesystem has the package uid specified
* in aPackageId 
* With the addition of SA upgrades to ROM, a package may be both in ROM, upgraded 
* on another drive and this method can be used to check for the presence 
* of an upgraded ROM package.
*
*
* @param aPackageId		Package Id to be searched in the ROM stub files.
*
* @return ETrue if it can find the aPackageId or aFileName in any of the ROM stub SIS.
*         EFalse otherwise
*/

EXPORT_C TBool RSisRegistryWritableSession::PackageExistsInRomL(const TUid& aPackageId)
	{
	TPckgBuf<TBool> present;	
	TPckgC<TUid> tuid(aPackageId);
	TInt returnCode = SendReceive(EPackageExistsInRom, TIpcArgs(&tuid, &present));
	User::LeaveIfError(returnCode);
		
	return present();
	}


/**
* Gets all the eclipsable file's entries from the ROM stub file of a ROM based package.
*
* @param aUid		Package UId to identify the right stub file.
*
* @param aFiles		A pointer array of file names to be populated.
*
*/
EXPORT_C void RSisRegistryWritableSession::GetFilesForRomApplicationL(const TUid& aUid, RPointerArray<HBufC>& aFiles)
	{
	TInt startingFile = 0;
	TPckgBuf<TInt> filesCount;
	TPckgC<TInt> pckgStartingFile(startingFile);
	TStubExtractionMode operationMode = EGetCount;
	
	// Get the total file count.	
	TPckgC<TUid> packageUid(aUid);
	TPckgC<TStubExtractionMode> packageMode(operationMode);
	
	TInt result = SendReceive(EStubFileEntries, TIpcArgs(&packageUid, &packageMode, &filesCount));
	User::LeaveIfError(result);	
	
	TInt totalFilesCount = filesCount();
	operationMode = EGetFiles;	
	
	do
		{	
		HBufC8* buffer = HBufC8::NewLC(KDefaultBufferSize);
	
		TPtr8 pOutput(buffer->Des());
		
		// Fetch the files.	
		TInt result=SendReceive(EStubFileEntries, TIpcArgs(&packageUid, &packageMode, &pckgStartingFile, &pOutput));
		User::LeaveIfError(result);
		
		// create a stream based on the buffer
		RDesReadStream stream(*buffer);
		CleanupClosePushL(stream);
		
		// reassemble the array from the stream
		InternalizePointerArrayL(aFiles, stream);
		
		CleanupStack::PopAndDestroy(2, buffer); // buffer, stream
		startingFile = aFiles.Count();	
		} while (startingFile < totalFilesCount);	
	}

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
EXPORT_C void RSisRegistryWritableSession::ActivateComponentL(TComponentId aComponentId)
	{
	SetComponentStateL(aComponentId, Usif::EActivated);
	}

EXPORT_C void RSisRegistryWritableSession::DeactivateComponentL(TComponentId aComponentId)
	{
	SetComponentStateL(aComponentId, Usif::EDeactivated);
	}

void RSisRegistryWritableSession::SetComponentStateL(TComponentId aComponentId, TScomoState aState)
	{
	TPckgC<TComponentId> packageComponentId(aComponentId);
	TPckgC<TScomoState> packageState(aState);	
	TInt returnCode = SendReceive(ESetComponentState, TIpcArgs(&packageComponentId, &packageState));
	User::LeaveIfError(returnCode);
	}
#endif