/*

* Copyright (c) 2008-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: 

* sts.h

*

*/

/**

 @file

 @publishedAll

 @released

*/

#include <usif/sts/sts.h>

#include "stscommon.h"

#include <e32cmn.h>

#include <e32uid.h>

using namespace Usif;

void RStsSession::ConnectL()

	{

	__ASSERT_DEBUG(iHandle == NULL, User::Invariant());

	TInt err = RScsClientBase::Connect(KStsServerName, TVersion(KStsVerMajor,

			KStsVerMinor, KStsVerBuild), KStsServerImgName, TUidType(

			KExecutableImageUid, KNullUid, TUid::Uid(KUidStsServer)));

	User::LeaveIfError(err);

	}

EXPORT_C RStsSession::RStsSession()

: RScsClientBase()

	{

	// empty

	}

EXPORT_C void RStsSession::Close()

	{

	RScsClientBase::Close();

	}

EXPORT_C TStsTransactionId RStsSession::CreateTransactionL()

	{

	// It is possible to create several transactions on the same session, assuming that they are all sequential

	if (iHandle == NULL)

		ConnectL();

	TStsTransactionId trID;

	TPckg<TStsTransactionId> idPkg(trID);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KIdIPCSlot, &idPkg);

	User::LeaveIfError(CallSessionFunction(ECreateTransaction, ipcArgs));

	return trID;

	}

EXPORT_C void RStsSession::OpenTransactionL(TStsTransactionId aTransactionID)

	{

	if (iHandle == NULL)

		ConnectL();

	TPckgC<TStsTransactionId> idPkg(aTransactionID);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KIdIPCSlot, &idPkg);

	User::LeaveIfError(CallSessionFunction(EOpenTransaction, ipcArgs));

	}

EXPORT_C void RStsSession::RegisterNewL(const TDesC& aFileName)

	{

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	User::LeaveIfError(CallSessionFunction(ERegisterNew, ipcArgs));

	}

EXPORT_C void RStsSession::CreateNewL(const TDesC& aFileName, RFile &aFile, TUint aCreateMode)

	{

	__ASSERT_DEBUG(((KFilePathIPCSlot!=KFileHandleIPCSlot) &&

					(KFilePathIPCSlot!=KFileModeIPCSlot)   &&

					(KFileModeIPCSlot!=KFileHandleIPCSlot)), User::Invariant());

	TPckgBuf<TInt> fileHandlePkg;

	TPckgC<TUint> pkgFileMode(aCreateMode);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	ipcArgs.Set(KFileHandleIPCSlot, &fileHandlePkg);

	ipcArgs.Set(KFileModeIPCSlot, &pkgFileMode);

	TInt fileServerHandle = User::LeaveIfError(CallSessionFunction(ECreateNew, ipcArgs));

	User::LeaveIfError(aFile.AdoptFromServer(fileServerHandle, fileHandlePkg()));

	}

EXPORT_C void RStsSession::RemoveL(const TDesC& aFileName)

	{

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	User::LeaveIfError(CallSessionFunction(ERemove, ipcArgs));

	}

EXPORT_C void RStsSession::RegisterTemporaryL(const TDesC& aFileName)

	{

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	User::LeaveIfError(CallSessionFunction(ERegisterTemporary, ipcArgs));

	}

EXPORT_C void RStsSession::CreateTemporaryL(const TDesC& aFileName, RFile &aFile, TUint aCreateMode)

	{

	__ASSERT_DEBUG(((KFilePathIPCSlot!=KFileHandleIPCSlot) &&

					(KFilePathIPCSlot!=KFileModeIPCSlot)   &&

					(KFileModeIPCSlot!=KFileHandleIPCSlot)), User::Invariant());

	TPckgBuf<TInt> fileHandlePkg;

	TPckgC<TUint> pkgFileMode(aCreateMode);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	ipcArgs.Set(KFileHandleIPCSlot, &fileHandlePkg);

	ipcArgs.Set(KFileModeIPCSlot, &pkgFileMode);

	TInt fileServerHandle = User::LeaveIfError(CallSessionFunction(ECreateTemporary, ipcArgs));

	User::LeaveIfError(aFile.AdoptFromServer(fileServerHandle, fileHandlePkg()));

	}

EXPORT_C void RStsSession::OverwriteL(const TDesC& aFileName, RFile &aFile, TUint aCreateMode)

	{

	__ASSERT_DEBUG(((KFilePathIPCSlot!=KFileHandleIPCSlot) &&

					(KFilePathIPCSlot!=KFileModeIPCSlot)   &&

					(KFileModeIPCSlot!=KFileHandleIPCSlot)), User::Invariant());

	TPckgBuf<TInt> fileHandlePkg;

	TPckgC<TUint> pkgFileMode(aCreateMode);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KFilePathIPCSlot, &aFileName);

	ipcArgs.Set(KFileHandleIPCSlot, &fileHandlePkg);

	ipcArgs.Set(KFileModeIPCSlot, &pkgFileMode);

	TInt fileServerHandle = User::LeaveIfError(CallSessionFunction(EOverwrite, ipcArgs));

	User::LeaveIfError(aFile.AdoptFromServer(fileServerHandle, fileHandlePkg()));

	}

EXPORT_C void RStsSession::CommitL()

	{

	User::LeaveIfError(CallSessionFunction(ECommit));

	Close();

	}

EXPORT_C void RStsSession::RollBackL()

	{

	User::LeaveIfError(CallSessionFunction(ERollBack));

	Close();

	}

EXPORT_C TStsTransactionId RStsSession::TransactionIdL()

	{

	TStsTransactionId id;

	TPckg<TStsTransactionId> idPkg(id);

	TIpcArgs ipcArgs;

	ipcArgs.Set(KIdIPCSlot, &idPkg);

	User::LeaveIfError(CallSessionFunction(EGetId, ipcArgs));

	return id;

	}