/*

* 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 DM specific client api.

*

*/

#include <s32mem.h>

#include <SyncMLClientDM.h>

#include <nsmldebug.h>

#include "NSmlClientAPIUtils.h"

#include "nsmlsosserverdefs.h"

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

//

// RSyncMLDevManJob

//

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

// RSyncMLDevManJob::RSyncMLDevManJob()

// Constructor.

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

//

EXPORT_C RSyncMLDevManJob::RSyncMLDevManJob()

	: RSyncMLJobBase()

	{

	}

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

// RSyncMLDevManJob::CreateL()

// Creates DM job.

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

//

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

	{

	_DBG_FILE("RSyncMLDevManJob::CreateL() ECmdDevManJobCreate: begin");

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

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDevManNotSupportedL();

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

	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, ECmdDevManJobCreate, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

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

	}

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

// RSyncMLDevManJob::CreateL()

// Creates DM job, transport override.

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

//

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

	{

	_DBG_FILE("RSyncMLDevManJob::CreateL() ECmdDevManJobCreateForTransport: begin");

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

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDevManNotSupportedL();

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

	CleanupStack::PushL( data );

	// add profile id 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, ECmdDevManJobCreateForTransport, args ) );

	data->SetProfile( aProfileId );

	data->SetIdentifier( jobId() );

	iData = data;

	CleanupStack::Pop(); // data

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

	}

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

// RSyncMLDevManJob::OpenL().

// Opens given job. If not found, leaves with KErrNotFound.

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

//

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

	{

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

	CClientSessionData::PanicIfAlreadyCreated( iData );

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

	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

	GetJobL( dataSize(), EFalse );

	CleanupStack::Pop(); // this

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

	}

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

// RSyncMLDevManJob::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 RSyncMLDevManJob::StopL()

	{

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

	TInt jobId = Identifier();

	TIpcArgs args( jobId );

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

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

	}

//

// RSyncMLDevManProfile

//

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

// RSyncMLDevManProfile::RSyncMLDevManProfile()

// Constructor.

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

//

EXPORT_C RSyncMLDevManProfile::RSyncMLDevManProfile()

	: RSyncMLProfileBase()

	{

	}

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

// RSyncMLDevManProfile::OpenL()

// Opens given profile in read-only mode.

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

//

EXPORT_C void RSyncMLDevManProfile::OpenL( RSyncMLSession& aSession, TSmlProfileId aProfileId )

	{

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

	OpenL( aSession, aProfileId, ESmlOpenRead );

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

	}

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

// RSyncMLDevManProfile::OpenL()

// Opens given profile.

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

//

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

	{

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

	CClientSessionData::PanicIfAlreadyCreated( iData );

	CDevManProfileSessionData* data = CDevManProfileSessionData::NewLC();

	TPckgBuf<TInt> dataSize;

	TIpcArgs args( &dataSize, aProfileId, aOpenMode );

	// open the sub-session

	User::LeaveIfError( CreateSubSession( aSession, ECmdProfileOpenDM, 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("RSyncMLDevManProfile::OpenL(): end");

	}

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

// RSyncMLDevManProfile::CreateL()

// Creates new DM profile.

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

//

EXPORT_C void RSyncMLDevManProfile::CreateL( RSyncMLSession& aSession )

	{

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

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

	CClientSessionData::PanicIfAlreadyCreated( iData );

	NSmlClientAPIFeatureHandler::LeaveIfDevManNotSupportedL();

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

	// create sub-session and new profile

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

	iData = data;

	CleanupStack::Pop(); // data

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

	}

//

// RSyncMLDevMan ( Not supported )

//

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

// RSyncMLDevMan::RSyncMLDevMan()

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

//

EXPORT_C RSyncMLDevMan::RSyncMLDevMan()

	{

	}

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

// RSyncMLDevMan::OpenL()

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

//

EXPORT_C void RSyncMLDevMan::OpenL( RSyncMLSession& )

	{

	User::Leave( KErrNotSupported );

	}

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

// RSyncMLDevMan::ClearRootAclL()

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

//

EXPORT_C void RSyncMLDevMan::ClearRootAclL()

	{

	User::Leave( KErrNotSupported );

	}

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

// RSyncMLDevMan::SetUserInteractionNotifierTimeoutL()

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

//

EXPORT_C void RSyncMLDevMan::SetUserInteractionNotifierTimeoutL( TUint /*aSeconds*/ )

	{

	User::Leave( KErrNotSupported );

	}

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

// RSyncMLDevMan::UserInteractionNotifierTimeout()

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

//

EXPORT_C TUint RSyncMLDevMan::UserInteractionNotifierTimeout() const

	{

	return 0;

	}

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

// RSyncMLDevMan::Close()

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

//

EXPORT_C void RSyncMLDevMan::Close()

	{

	}