/*

* Copyright (c) 2004 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 DS specific client api.

*

*/

#include <s32mem.h>

#include <SyncMLClientDS.h>

#include <nsmldebug.h>

#include "NSmlClientAPIUtils.h"

#include "nsmlsosserverdefs.h"

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

//

// RSyncMLDataSyncJob

//

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

// RSyncMLDataSyncJob::RSyncMLDataSyncJob()

// Constructor.

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

//

EXPORT_C RSyncMLDataSyncJob::RSyncMLDataSyncJob()

	: RSyncMLJobBase()

	{

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForProfile: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add profile id to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->WriteIntegersToBufferL();

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForProfile, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, transport override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlConnectionId aTransportId )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTransport: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aTransportId );

	data->WriteIntegersToBufferL();

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTransport, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, sync type override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlSyncType aSyncType )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForProfileST: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aSyncType );

	data->WriteIntegersToBufferL();

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForProfileST, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, transport + sync type override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlConnectionId aTransportId, TSmlSyncType aSyncType )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTransportST: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aTransportId );

	data->AddParamL( aSyncType );

	data->WriteIntegersToBufferL();

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTransportST, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, tasks override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, const RArray<TSmlTaskId>& aTasks )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTasks: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->WriteIntegersToBufferL( &aTasks );

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTasks, args ) );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this );  // if leave occures, Close is called by cleanup

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	data->SetTasksL( aTasks );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, transport + tasks override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlConnectionId aTransportId, const RArray<TSmlTaskId>& aTasks )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTransportAndTasks: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aTransportId );

	data->WriteIntegersToBufferL( &aTasks );

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTransportAndTasks, args ) );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this );  // if leave occures, Close is called by cleanup

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	data->SetTasksL( aTasks );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, sync type + tasks override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlSyncType aSyncType, const RArray<TSmlTaskId>& aTasks )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTasksST: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aSyncType );

	data->WriteIntegersToBufferL( &aTasks );

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTasksST, args ) );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this );  // if leave occures, Close is called by cleanup

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	data->SetTasksL( aTasks );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::CreateL()

// Creates DS job, transport + sync type + tasks override.

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

//

EXPORT_C void RSyncMLDataSyncJob::CreateL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlConnectionId aTransportId, TSmlSyncType aSyncType, const RArray<TSmlTaskId>& aTasks )

	{

	_DBG_FILE("RSyncMLDataSyncJob::CreateL() ECmdDataSyncJobCreateForTransportAndTasksST: begin");

	// check that job is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// add ids to parameters and write the buffer

	data->AddParamL( aProfileId );

	data->AddParamL( aTransportId );

	data->AddParamL( aSyncType );

	data->WriteIntegersToBufferL( &aTasks );

	TPtr8 dataPtr = data->DataBufferPtr();

	TPckgBuf<TInt> jobId;

	TIpcArgs args( &jobId, &dataPtr );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdDataSyncJobCreateForTransportAndTasksST, args ) );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this );  // if leave occures, Close is called by cleanup

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	data->SetTasksL( aTasks );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncJob::CreateL(): end");

	}

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

// RSyncMLDataSyncJob::OpenL()

// Opens a job currently in servers job queue. If not found, leaves with 

// KErrNotFound.

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

//

EXPORT_C void RSyncMLDataSyncJob::OpenL( RSyncMLSession& aSession, TSmlJobId aJobId )

	{

	_DBG_FILE("RSyncMLDataSyncJob::OpenL(): begin");

	CClientSessionData::PanicIfAlreadyCreated( iData );

	CDataSyncJobSessionData* data = new (ELeave) CDataSyncJobSessionData();

	CleanupStack::PushL( data );

	// open the sub-session and get size of data to be received

	TPckgBuf<TInt> dataSize;

	TIpcArgs args( &dataSize, aJobId );

	User::LeaveIfError( CreateSubSession( aSession, ECmdJobOpen, args ) );

	data->SetIdentifier( aJobId );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this ); // if leave occures, Close is called by cleanup

	// get the data: the profile id and list of task ids

	GetJobL( dataSize(), EFalse );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncJob::OpenL(): end");

	}

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

// RSyncMLDataSyncJob::StopL()

// If this job has started to execute in server, it is stopped and an 

// event is emitted. If the job is still in job queue, it is merely 

// removed from the queue. If not found, leaves with KErrNotFound.

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

//

EXPORT_C void RSyncMLDataSyncJob::StopL()

	{

	_DBG_FILE("RSyncMLDataSyncJob::StopL(): begin");

	TInt jobId = Identifier();

	TIpcArgs args( jobId );

	User::LeaveIfError( SendReceive( ECmdJobStop, args ) );

	_DBG_FILE("RSyncMLDataSyncJob::StopL(): end");

	}

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

// RSyncMLDataSyncJob::TaskIDs()

// Returns the task id associated with this job (if given in CreateL).

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

//

EXPORT_C const RArray<TSmlTaskId>& RSyncMLDataSyncJob::TaskIDs() const

	{

	return static_cast<CDataSyncJobSessionData*>(iData)->TaskIds();

	}

//

// RSyncMLDataSyncProfile

//

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

// RSyncMLDataSyncProfile::RSyncMLDataSyncProfile()

// Constructor.

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

//

EXPORT_C RSyncMLDataSyncProfile::RSyncMLDataSyncProfile()

	: RSyncMLProfileBase()

	{

	}

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

// RSyncMLDataSyncProfile::CreateL()

// Opens a sub-session to server and creates a new profile 

// to server side.

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

//

EXPORT_C void RSyncMLDataSyncProfile::CreateL( RSyncMLSession& aSession )

	{

	_DBG_FILE("RSyncMLDataSyncProfile::CreateL(): begin");

	// check that profile is not yet open and ds sync is supported

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDataSyncNotSupportedL();

	CDataSyncProfileSessionData* data = CDataSyncProfileSessionData::NewLC( ETrue );

	// create sub-session and new profile

	User::LeaveIfError( CreateSubSession( aSession, ECmdProfileCreateDS ) );

	iData = data;

	CleanupStack::Pop(); // data

	_DBG_FILE("RSyncMLDataSyncProfile::CreateL(): end");

	}

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

// RSyncMLDataSyncProfile::OpenL()

// Opens a sub-session to server to an existing profile and 

// gets the profile's data to iData.

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

//

EXPORT_C void RSyncMLDataSyncProfile::OpenL( RSyncMLSession& aSession, TSmlProfileId aProfileId, TSmlOpenMode aOpenMode )

	{

	_DBG_FILE("RSyncMLDataSyncProfile::OpenL(): begin");

	CClientSessionData::PanicIfAlreadyCreated( iData );

	CDataSyncProfileSessionData* data = CDataSyncProfileSessionData::NewLC();

	TPckgBuf<TInt> dataSize;

	TIpcArgs args( &dataSize, aProfileId, aOpenMode );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdProfileOpenDS, args ) );

	data->SetIdentifier( aProfileId );

	data->SetOpenMode( (TSmlOpenMode)aOpenMode );

	iData = data;

	CleanupStack::Pop(); // data

	CleanupClosePushL( *this ); // if leave occures, Close is called by cleanup

	// dataSize contains now the size of the data buffer that is received next -> get data

	GetProfileL( dataSize() );

	CleanupStack::Pop(); // this

	_DBG_FILE("RSyncMLDataSyncProfile::OpenL(): end");

	}

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

// RSyncMLDataSyncProfile::SetCreatorId()

// Sets creator id.

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

//

EXPORT_C void RSyncMLDataSyncProfile::SetCreatorId( TSmlCreatorId aCreatorId )

	{

	RSyncMLProfileBase::SetCreatorId( aCreatorId );

	}

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

// RSyncMLDataSyncProfile::SetDisplayNameL()

// Sets display name for this profile.

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

//

EXPORT_C void RSyncMLDataSyncProfile::SetDisplayNameL( const TDesC& aDisplayName )

	{

	RSyncMLProfileBase::SetDisplayNameL( aDisplayName );

	}

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

// RSyncMLDataSyncProfile::SetUserNameL()

// Sets user name.

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

//

EXPORT_C void RSyncMLDataSyncProfile::SetUserNameL( const TDesC8& aUserName )

	{

	RSyncMLProfileBase::SetUserNameL( aUserName );

	}

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