/*

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

*

*/

#include <f32file.h>

#include <s32mem.h>

#include <nsmldebug.h>

#include <nsmldmauthinfo.h>

#include <NSmlPrivateAPI.h>

#include "NSmlClientAPIDefs.h"

#include "nsmlsosserverdefs.h"

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

// Launches the server.

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

//

TInt LaunchServer()

	{	

	DBG_BEGIN();

	_DBG_FILE("RNSmlPrivateAPI LaunchServer(): begin");

	TInt res = KErrNone;

	// DLL launch

	RProcess server;

	res = server.Create(KServerExeName, KNullDesC);

	// Loading failed.

	if ( res != KErrNone )

		{

		return res;

		}

	TRequestStatus status;

	server.Rendezvous(status);

	if (status != KRequestPending)

		{

		server.Kill(0);		// abort startup

		server.Close();

		return KErrGeneral;   // status can be KErrNone: don't return status.Int()

		}

	else

		{

		server.Resume();	// logon OK - start the server

		}

	User::WaitForRequest(status);

	server.Close();

	_DBG_FILE("RNSmlPrivateAPI LaunchServer(): end");

	return status.Int();

	}

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

// RNSmlPrivateAPI::RNSmlPrivateAPI()

// Constructor

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

//

EXPORT_C RNSmlPrivateAPI::RNSmlPrivateAPI()

	{

	}

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

// RNSmlPrivateAPI::OpenL()

// Creates connection to server

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

//

EXPORT_C void RNSmlPrivateAPI::OpenL()

	{

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

	TVersion version(KNSmlSOSServerVersionMajor, KNSmlSOSServerVersionMinor, 0);

	TInt res = CreateSession( KSOSServerName, version, KDefaultMessageSlots );

	if ( res != KErrNone )

		{

		res = LaunchServer();

		}

	User::LeaveIfError( res );

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

	}

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

// RNSmlPrivateAPI::SendL( const TDesC8& aData, TSmlUsageType aType, 

// TSmlProtocolVersion aVersion )

// Passes message to server

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

//

EXPORT_C void RNSmlPrivateAPI::SendL(

    const TDesC8& aData, 

    TSmlUsageType aType, 

    TSmlProtocolVersion aVersion, 

    TUid aTransportId )

	{

	_DBG_FILE("RNSmlPrivateAPI::SendL(): begin");

	TIpcArgs args( &aData, aType, aVersion, aTransportId.iUid );    

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

    _DBG_FILE("RNSmlPrivateAPI::SendL(): end");

	}

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

// RNSmlPrivateAPI::Close()

// Passes message to server

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

//		

EXPORT_C void RNSmlPrivateAPI::Close()

	{

	_DBG_FILE("RNSmlPrivateAPI::Close(): begin");

	// close session	

	RSessionBase::Close();

	_DBG_FILE("RNSmlPrivateAPI::Close(): end");

	}

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

// RNSmlPrivateAPI::SetDMAuthInfoL( const CNSmlDMAuthInfo& aAuthInfo )

// Sends DM auhentication info to be saved

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

//	

EXPORT_C void RNSmlPrivateAPI::SetDMAuthInfoL( const CNSmlDMAuthInfo& aAuthInfo )

	{

	CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );

	CleanupStack::PushL( buffer );

	RBufWriteStream stream( *buffer );	

	CleanupClosePushL( stream );

	aAuthInfo.ExternalizeL( stream );

	TPtr8 pBuffer(0, NULL, 0);

	pBuffer.Set( buffer->Ptr(0) );

	CleanupStack::PopAndDestroy(); // stream

	TIpcArgs args(aAuthInfo.iProfileId, &pBuffer);

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

	CleanupStack::PopAndDestroy(); // buffer

	}

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

// RNSmlPrivateAPI::GetDMAuthInfoL( CNSmlDMAuthInfo& aAuthInfo )

// Retrieves DM auhentication info from settings

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

//	

EXPORT_C void RNSmlPrivateAPI::GetDMAuthInfoL( CNSmlDMAuthInfo& aAuthInfo )

	{

	TPckgBuf<TInt> buf;

	TIpcArgs args(aAuthInfo.iProfileId, &buf);

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

	CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );

	CleanupStack::PushL( buffer );

	buffer->ResizeL( buf() );

	TPtr8 pBuffer(0, NULL, 0);

	pBuffer.Set( buffer->Ptr(0) );

	TIpcArgs argsGet( &pBuffer );

	User::LeaveIfError( SendReceive( ECmdGetDMAuthInfo, argsGet) );

	RDesReadStream stream;

	stream.Open( pBuffer );

	CleanupClosePushL( stream );

	aAuthInfo.InternalizeL( stream );

	CleanupStack::PopAndDestroy(2); // stream, buffer	

	}

// FOTA

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

// RNSmlPrivateAPI::AddDMGenericAlertRequestL()

// Adds a Generic Alert to DM Agent if it is found in the 

// server.

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

//	

EXPORT_C TInt RNSmlPrivateAPI::AddDMGenericAlertRequestL( const TDesC8& aMgmtUri, const TDesC8& aMetaType, const TDesC8& aMetaFormat, TInt aFinalResult, const TDesC8& aCorrelator ) const

	{

	TInt err = KErrNone;

	// create buffer

	CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );

	CleanupStack::PushL( buffer );

	// open stream to buffer

	RBufWriteStream stream( *buffer );	

	CleanupClosePushL( stream );

    // externalize data to stream

	stream.WriteInt32L( aMgmtUri.Length() );

	stream.WriteL( aMgmtUri );

	stream.WriteInt32L( aMetaType.Length() );

	stream.WriteL( aMetaType );

	stream.WriteInt32L( aMetaFormat.Length() );

	stream.WriteL( aMetaFormat );

	stream.WriteInt32L( aCorrelator.Length() );

	stream.WriteL( aCorrelator );

	stream.WriteInt32L( aFinalResult );

	// get modifiable pointer to buffer

	TPtr8 bufPtr( buffer->Ptr(0) );

	CleanupStack::PopAndDestroy( &stream );

	// send the data to sos server

	TIpcArgs args( &bufPtr );

	err = SendReceive( ECmdAddDMGenericAlert, args );

	CleanupStack::PopAndDestroy( buffer );

	return err;

	}

// FOTA end

// SCOMO

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

// RNSmlPrivateAPI::AddDMGenericAlertRequestL()

// Adds a Generic Alert to DM Agent if it is found in the 

// server.

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

//	

EXPORT_C TInt RNSmlPrivateAPI::AddDMGenericAlertRequestL( const TDesC8& aCorrelator, RArray<CNSmlDMAlertItem>& aItemList ) const

	{

	TInt err = KErrNone;

	// create buffer

	CBufFlat* buffer = CBufFlat::NewL( KDefaultNSmlBufferGranularity );

	CleanupStack::PushL( buffer );

	// open stream to buffer

	RBufWriteStream stream( *buffer );	

	CleanupClosePushL( stream );

    // externalize data to stream

	stream.WriteInt32L( aCorrelator.Length() );

	stream.WriteL( aCorrelator );

	TInt count = aItemList.Count();

	stream.WriteInt32L( count );

	if(count > 0)

	{		

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

		{

			stream.WriteInt32L( (aItemList[i].iSource)->Length() );

			stream.WriteL( (aItemList[i].iSource)->Des() );

			stream.WriteInt32L( (aItemList[i].iTarget)->Length() );

			stream.WriteL( aItemList[i].iTarget->Des() );

			stream.WriteInt32L( (aItemList[i].iMetaType)->Length() );

			stream.WriteL( aItemList[i].iMetaType->Des() );

			stream.WriteInt32L( (aItemList[i].iMetaFormat)->Length()  );

			stream.WriteL( aItemList[i].iMetaFormat->Des());

			stream.WriteInt32L( (aItemList[i].iMetaMark)->Length() );

			stream.WriteL( aItemList[i].iMetaMark->Des() );

			stream.WriteInt32L( (aItemList[i].iData)->Length() );

			stream.WriteL( aItemList[i].iData->Des() );

		}		

	}

	// get modifiable pointer to buffer

	TPtr8 bufPtr( buffer->Ptr(0) );

	CleanupStack::PopAndDestroy( &stream );

	// send the data to sos server

	TIpcArgs args( &bufPtr );

	err = SendReceive( ECmdAddGenericAlert, args );

	CleanupStack::PopAndDestroy( buffer );

	return err;

	}

// SCOMO

//End of File