diff -r 000000000000 -r e6b17d312c8b imservices/instantmessagingcache/imcacheclient/src/cimcacheclient.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/imservices/instantmessagingcache/imcacheclient/src/cimcacheclient.cpp	Thu Dec 17 08:54:49 2009 +0200
@@ -0,0 +1,373 @@
+/*
+* Copyright (c) 2008 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:  client class implementation to connect to server
+*
+*/
+
+
+
+//  INCLUDE FILES
+#include "cimcacheclient.h"
+
+#include "imcacheprocessstarter.h"
+#include <imcachedefs.h>
+#include "mimcacheclient.h"
+// logs
+#include "imcachedebugtrace.h"
+#include "cimcacheeventhandler.h"
+
+#include "cimcacheaccesseventhandler.h"
+
+// ==============================================================
+// ======================== CLIENT ==============================
+// ==============================================================
+
+// Destructor
+CIMCacheClient::~CIMCacheClient()
+	{
+	TRACE( T_LIT("CIMCacheClient::~CIMCacheClient() begin") );
+	if( iUpdateObserver )
+		{
+		delete iUpdateObserver;
+		}
+	
+	if( iAccessObserver )
+		{
+		delete iAccessObserver;
+		}
+    if( iChatBuffer )
+        {
+        delete iChatBuffer;
+        }
+    //finally close the session.
+    RSessionBase::Close();
+	#if _BullseyeCoverage
+	cov_write();
+	#endif
+	TRACE( T_LIT("CIMCacheClient::~CIMCacheClient() end") );
+	}
+// -----------------------------------------------------------------------------
+// CIMCacheClient::CIMCacheClient()
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CIMCacheClient::CIMCacheClient( )
+	{
+    TRACE( T_LIT("CIMCacheClient::CIMCacheClient()") );
+    }
+
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::Connect()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheClient::Connect()
+    {
+    TRACE( T_LIT("CIMCacheClient::Connect() begin") );
+    TFileName fullExePath;
+    IMCacheProcessStarter::FullExePathForClientLocation( EIMCacheServerExe,
+                                                 fullExePath );
+
+	TRACE( T_LIT("CIMCacheClient::Connect() end") );
+    return IMCacheProcessStarter::ConnectToServer( fullExePath,
+                                            KNullDesC,
+                                            *this,
+                                            KIMCacheServerName,
+                                            TVersion( KIMCacheVersionMajor,
+                                                      KIMCacheVersionMinor,
+                                                      KIMCacheVersionBuild ),
+                                            KIMCacheMsgSlotCount );
+    
+    }
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::RegisterObserverL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::RegisterUpdateObserverL( MIMCacheEventHandler& aObserver )
+	{
+	TRACE( T_LIT("CIMCacheClient::RegisterUpdateObserverL() begin") );
+
+	CIMCacheEventHandler* tempObserver = CIMCacheEventHandler::NewL(  *this , aObserver );
+
+	if( iUpdateObserver )
+		{
+		delete iUpdateObserver;
+		iUpdateObserver = NULL;
+		}
+
+	iUpdateObserver = tempObserver;
+	TRACE( T_LIT("CIMCacheClient::RegisterUpdateObserverL() end") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::UnRegisterUpdateObserver()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::UnRegisterUpdateObserver( MIMCacheEventHandler& /*aObserver*/)
+	{
+	TRACE( T_LIT("CIMCacheClient::UnRegisterUpdateObserver() begin") );
+	
+	iUpdateObserver->UnRegisterObserver();
+
+    TRACE( T_LIT("CIMCacheClient::UnRegisterUpdateObserver() end") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::RegisterAccessObserverL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::RegisterAccessObserverL( MIMCacheEventHandler& aObserver )
+	{
+	TRACE( T_LIT("CIMCacheClient::RegisterUpdateObserverL() begin") );
+
+	CIMCacheAccessEventHandler* tempObserver = CIMCacheAccessEventHandler::NewL(  *this , aObserver );
+
+	if( iAccessObserver )
+		{
+		delete iAccessObserver;
+		iAccessObserver = NULL;
+		}
+
+	iAccessObserver = tempObserver;
+	TRACE( T_LIT("CIMCacheClient::RegisterUpdateObserverL() end") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::UnRegisterAccessObserver()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::UnRegisterAccessObserver( MIMCacheEventHandler& /*aObserver*/)
+	{
+	TRACE( T_LIT("CIMCacheClient::UnRegisterUpdateObserver() begin") );
+	
+	iAccessObserver->UnRegisterObserver();
+
+    TRACE( T_LIT("CIMCacheClient::UnRegisterUpdateObserver() end") );
+	}
+// -----------------------------------------------------------------------------
+// CIMCacheClient::RegisterObserverToServerL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::RegisterObserverToServerL( TRequestStatus& aStatus , EIMCacheOperations aRight)
+	{
+	TRACE( T_LIT("CIMCacheClient::RegisterObserverToServerL() begin") );
+	TIpcArgs args;
+	SendReceive( aRight, args, aStatus );
+	TRACE( T_LIT("CIMCacheClient::RegisterObserverToServerL() end") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::UnRegisterObserverToServerL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::UnRegisterObserverToServerL( TRequestStatus& aStatus, EIMCacheOperations aRight)
+	{
+	TRACE( T_LIT("CIMCacheClient::UnRegisterObserverToServerL() begin") );
+	TIpcArgs args;
+	TInt err = SendReceive( aRight, args );
+	User::LeaveIfError( err );
+	TRACE( T_LIT("CIMCacheClient::UnRegisterObserverToServerL() end") );
+	}
+// -----------------------------------------------------------------------------
+// CIMCacheClient::CancelRequestL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::CancelRequestL( TRequestStatus& aStatus, EIMCacheOperations aRight)
+    {
+    TRACE( T_LIT("CIMCacheClient::CancelRequestL() begin") );
+    TIpcArgs args;
+    TInt err = SendReceive( aRight, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::CancelRequestL() end") );
+    }
+// -----------------------------------------------------------------------------
+// CIMCacheClient::StartTransactionL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::StartTransactionL( EIMCacheOperations aOperationType,
+									   TInt aServiceId ,
+									   const TDesC& aText
+									   )
+	{
+	TRACE( T_LIT("CIMCacheClient::StartTransactionL() begin") );
+	TIpcArgs args = CreateArgumentsL( aServiceId, aText );
+ 	TInt err = SendReceive( aOperationType, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::StartTransactionL() end") );
+	}
+
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::StartTransactionL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::StartTransactionL(EIMCacheOperations aOperationType,
+										const TDesC& aText
+									   )
+	{
+	TRACE( T_LIT("CIMCacheClient::StartTransactionL() begin") );
+	TIpcArgs args;
+    args.Set( 0,  &aText );
+   	TInt err = SendReceive( aOperationType, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::StartTransactionL() end") );
+	}
+// -----------------------------------------------------------------------------
+// CIMCacheClient::StartTransactionL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheClient::StartTransactionL(	EIMCacheOperations aOperationType,
+										TInt aServiceId,
+										const TDesC& aText1 ,
+										const TDesC& aText2 
+									   	)
+	{
+	TRACE( T_LIT("CIMCacheClient::StartTransactionL() begin") );
+	TIpcArgs args = CreateArgumentsL(aServiceId, aText1, aText2 );
+ 	TInt err = SendReceive( aOperationType, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::StartTransactionL() end") );
+	}
+	
+// -----------------------------------------------------------------------------
+// CIMCacheClient::StopTransactionL()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheClient::StartTransactionL(EIMCacheOperations aOperationType )
+	{
+	TRACE( T_LIT("CIMCacheClient::StopTransactionL() begin") );
+	TRACE( T_LIT(" aOperationType = %d  "),aOperationType );
+	TInt err = SendReceive( aOperationType );
+    TRACE( T_LIT("CIMCacheClient::StopTransactionL() end") );
+	return err;
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::CreateArgumentsL()
+// -----------------------------------------------------------------------------
+//
+TIpcArgs CIMCacheClient::CreateArgumentsL( TInt aServiceId ,
+									   const TDesC& aText  )
+	{
+	TRACE( T_LIT("CIMCacheClient::CreateArgumentsL() begin") );
+	// set the arguments for the message
+	TIpcArgs args;
+    args.Set( 0,  aServiceId );
+    args.Set( 1,  &aText );
+    TRACE( T_LIT("CIMCacheClient::CreateArgumentsL() end") );
+    return args;
+	}
+
+ // -----------------------------------------------------------------------------
+// CIMCacheClient::CreateArgumentsL()
+// -----------------------------------------------------------------------------
+//
+TIpcArgs CIMCacheClient::CreateArgumentsL(TInt aServiceId, 
+										const TDesC& aText1  ,
+									   const TDesC& aText2  )
+	{
+	TRACE( T_LIT("CIMCacheClient::CreateArgumentsL() begin") );
+	// set the arguments for the message
+	TIpcArgs args(aServiceId);
+    args.Set( 1,  &aText1 );
+    args.Set( 2,  &aText2 );
+    TRACE( T_LIT("CIMCacheClient::CreateArgumentsL() end") );
+    return args;
+	}
+
+
+// -----------------------------------------------------------------------------
+// CIMCacheClient::GetInformationL()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheClient::GetInformationL(EIMCacheOperations aOperationType, TInt aServiceId,const TDesC& aBuddyId )
+	{
+	TRACE( T_LIT("CIMCacheClient::GetInformationL start") );
+	TInt returnValue = 0;
+	TIpcArgs args(aServiceId);
+	args.Set( 1,  &aBuddyId );
+    TPckg<TInt> pack( returnValue );
+    args.Set(2, &pack );
+    TInt err = SendReceive( aOperationType, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::GetInformationL() end") );
+	return returnValue;
+	}
+
+ // -----------------------------------------------------------------------------
+// CIMCacheClient::GetCountL()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheClient::GetInformationL(EIMCacheOperations aOperationType, TInt aServiceId )
+	{
+	TRACE( T_LIT("CIMCacheClient::GetInformationL") );
+	TInt returnValue = 0;
+	TIpcArgs args(aServiceId);
+        
+    TPckg<TInt> pack( returnValue );
+    args.Set(1, &pack );
+    TInt err = SendReceive( aOperationType, args );
+    User::LeaveIfError( err );
+    TRACE( T_LIT("CIMCacheClient::GetInformationL() end") );
+	return returnValue;
+	}	
+// -----------------------------------------------------------------------------
+// CIMCacheClient::GetContactBufferL()
+// -----------------------------------------------------------------------------
+//
+TPtr8 CIMCacheClient::GetBufferedDataL(EIMCacheOperations aOperationType )
+    {
+    TRACE( T_LIT("CIMCacheClient::GetContactBufferL() begin") );
+    
+    if(!iChatBuffer)//if not allocated allocate.
+        {
+        iChatBuffer = HBufC8::NewL(KMaxSize);
+        }
+    TPtr8 chatBufferPtr = iChatBuffer->Des();
+    TIpcArgs msgArgs;
+    msgArgs.Set( 0, &chatBufferPtr );
+    
+    TInt err = SendReceive( aOperationType, msgArgs );
+    User::LeaveIfError( err );
+  
+    TRACE( T_LIT("CIMCacheClient::GetContactBufferL() end") );
+    
+    return iChatBuffer->Des();
+    }
+    
+// -----------------------------------------------------------------------------
+// CIMCacheClient::GetChatListL()
+// -----------------------------------------------------------------------------    
+TPtr8 CIMCacheClient::GetChatListL( const TInt& aServiceId /*= -1*/ )
+    {
+    
+    if(!iChatBuffer)//if not allocated allocate.
+        {
+        iChatBuffer = HBufC8::NewL(KMaxSize);
+        }
+    TPtr8 ptr = iChatBuffer->Des();
+     
+    TIpcArgs msgArgs( aServiceId );//at 0.
+    msgArgs.Set( 1, &ptr  );
+    
+    TInt err = SendReceive( EIMCacheGetChatList, msgArgs );
+    User::LeaveIfError( err );
+  
+  	return iChatBuffer->Des();
+    }
+    
+// end of file
+