/*
* Copyright (c) 2002-2007 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:  RCntParserServer implementation.
*
*/


// needed for client interface
#include "clientserver.h"
#include "cntparserserver.h"
#include "cntparserclient.h"

#include "debug.h"

const TUint KDefaultMessageSlots=4;


//------------------------------------------------------------
// RCntParserServer::RCntParserServer()
//------------------------------------------------------------
EXPORT_C RCntParserServer::RCntParserServer():iConnected(ECntParserNotConnected)
	{
	}
//------------------------------------------------------------
// RCntParserServer::Connect()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::Connect()
	{
	LOGGER_ENTERFN( "RCntParserServer::Connect()" );

	TInt r = KErrNone;

	if( iConnected == ECntParserNotConnected )
		{
		r = CreateSession( KCntParserName, Version(), KDefaultMessageSlots );
		if(r==KErrNone) 
			{
			iConnected=ECntParserConnected;	
			}
		else
			{
			RProcess p;
			TInt err = p.Create(KTxtServer, KNullDesC);
	   		if ( err != KErrNone )
           		{
           		// Loading failed.
           		return err;
           		}
			TRequestStatus status;
			p.Rendezvous( status );
			if( status != KRequestPending )
				{
				p.Kill(0);		// abort startup
				p.Close();
				return KErrGeneral;   // status can be KErrNone: don't return status.Int()
				}
			else
				{
				p.Resume();	// logon OK - start the server
				}
			
			User::WaitForRequest( status );

			if( status != KErrNone )
				{
				p.Close();
				return status.Int();
				}

			r = CreateSession( KCntParserName, Version() );
			if( r == KErrNone )
				{
				iConnected = ECntParserConnected;	
				}
			p.Close();
			}
		}
	else
		{
		r = KErrCouldNotConnect;
		}
	LOGGER_WRITE_1( "RCntParserServer::Connect() : return %d", r );
	return r; 
	}
//------------------------------------------------------------
// RCntParserServer::Disconnect()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::Disconnect()
	{
	LOGGER_ENTERFN( "RCntParserServer::Disconnect()" );

	TInt res = KErrNone;
	if(iConnected==ECntParserConnected)
		{
		res = SendReceive( ECntParserServerDisconnect, TIpcArgs(NULL) );
		if( res == KErrNone )
			{
			iConnected = ECntParserNotConnected;
			RSessionBase::Close();
			}
		}
	else
		{
		res = KErrCouldNotDisconnect;
		}
	LOGGER_WRITE_1( "RCntParserServer::CreateIrMCL2PhoneBook() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::Version(void) const
//------------------------------------------------------------
EXPORT_C TVersion RCntParserServer::Version(void) const
	{
	return(TVersion(KCntParserMajorVersionNumber,KCntParserMinorVersionNumber,KCntParserBuildVersionNumber));
	}
//------------------------------------------------------------
// RCntParserServer::CreateIrMCL2PhoneBook(TInt aMaxNumberOfContacts, TBool aForced)
//------------------------------------------------------------
EXPORT_C int RCntParserServer::CreateIrMCL2PhoneBook(TInt aMaxNumberOfContacts, TBool aForced)
	{
	LOGGER_ENTERFN( "RCntParserServer::CreateIrMCL2PhoneBook()" );
    TInt res(KErrNone);
	if( iConnected == ECntParserConnected )
		{
		res = SendReceive(ECntParserServerCreateIrMCL2,TIpcArgs(aMaxNumberOfContacts,aForced));
		}
	else
		{
		res = KErrNotReady;
		}
	LOGGER_WRITE_1( "RCntParserServer::CreateIrMCL2PhoneBook() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::ContactsParsed()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::ContactsParsed()
	{
	LOGGER_ENTERFN( "RCntParserServer::ContactsParsed()" );

	TInt res=KErrNone;
	if( iConnected == ECntParserConnected )
		{
		TPckgBuf<TInt> pckg;
		res = SendReceive(ECntParserServerCntParsed,TIpcArgs(&pckg));
		if( res == KErrNone )
            {
            res = pckg();
            }
		}
	else
		{
		res = KErrNotReady;
		}
	LOGGER_WRITE_1( "RCntParserServer::ContactsParsed() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::TotalNumberOfContacts()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::TotalNumberOfContacts()
	{
	LOGGER_ENTERFN( "RCntParserServer::TotalNumberOfContacts()" );

	TInt res = KErrNone;
	if( iConnected == ECntParserConnected )
		{
		TPckgBuf<TInt> pckg;
		res = SendReceive(ECntParserServerTotalNumOfContacts,TIpcArgs(&pckg));
		if( res == KErrNone)
            {
            res = pckg();
            }
		}
	else
		{
		res = KErrNotReady;
		}
	LOGGER_WRITE_1( "RCntParserServer::TotalNumberOfContacts() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::Cancel()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::Cancel()
	{
	LOGGER_ENTERFN( "RCntParserServer::Cancel()" );

	TInt res = KErrNone;
	if( iConnected == ECntParserConnected )
		{
		res = SendReceive(ECntParserServerCancel,TIpcArgs(NULL));
		}
	else
		{
		res = KErrCancel;
		}
	LOGGER_WRITE_1( "RCntParserServer::Cancel() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::CancelAll()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::CancelAll()
	{
	LOGGER_ENTERFN( "RCntParserServer::CancelAll()" );

	TInt res = KErrNone;
	if(iConnected==ECntParserConnected)
		{
		res = SendReceive(ECntParserServerCancelAll,TIpcArgs(NULL));
		}
	else
		{
		res = KErrCancel;
		}
    LOGGER_WRITE_1( "RCntParserServer::CancelAll() : return %d", res );
	return res;
	}
//------------------------------------------------------------
// RCntParserServer::ContactsSaved()
//------------------------------------------------------------
EXPORT_C TInt RCntParserServer::ContactsSaved()
	{
	LOGGER_ENTERFN( "RCntParserServer::ContactsSaved()" );

	TInt res = KErrNone;
	if( iConnected == ECntParserConnected )
		{
		TPckgBuf<TInt> pckg;
		SendReceive(ECntParserServerCntSaved,TIpcArgs(&pckg));
		res = pckg();
		}
	else
		{
		res = KErrNotReady;
		}
    LOGGER_WRITE_1( "RCntParserServer::ContactsSaved() : return %d", res );
	return res;
	}