diff -r 000000000000 -r e6b17d312c8b imservices/instantmessagingcache/imcacheclient/src/cimcacheaccessor.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/imservices/instantmessagingcache/imcacheclient/src/cimcacheaccessor.cpp	Thu Dec 17 08:54:49 2009 +0200
@@ -0,0 +1,248 @@
+/*
+* 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:  access right class implemetation
+*
+*/
+
+
+//  INCLUDE FILES
+#include "cimcacheaccessor.h"
+#include <imcachedefs.h>
+#include <s32mem.h>
+// logs
+#include "imcachedebugtrace.h"
+
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::NewL()
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+//
+CIMCacheAccessor* CIMCacheAccessor::NewL(TInt aServiceId,
+											const TDesC& aSenderId  )
+    {
+    TRACE( T_LIT("CIMCacheAccessor::NewL begin") );
+    CIMCacheAccessor* self = new ( ELeave ) CIMCacheAccessor( aServiceId ) ;
+    CleanupStack::PushL( self );
+    self->ConstructL( aSenderId );
+    CleanupStack::Pop( self );  //self
+    TRACE( T_LIT("CIMCacheAccessor::NewL end") );
+    return self;
+    }
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::ConstructL()
+// Symbian OS default constructor can leave.
+// -----------------------------------------------------------------------------
+//
+void CIMCacheAccessor::ConstructL( const TDesC& aSenderId  )
+    {
+    TRACE( T_LIT("CIMCacheAccessor::ConstructL begin") );
+    iUserId = aSenderId.AllocL();
+    User::LeaveIfError( iClient.Connect() );
+    iClient.StartTransactionL( EIMCacheInitAccess,
+    							iServiceId,
+    						    *iUserId
+								 );
+								 
+    TRACE( T_LIT("CIMCacheAccessor::ConstructL end") );
+    }
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::~CIMCacheAccessor()
+// Destructor
+// -----------------------------------------------------------------------------
+//
+CIMCacheAccessor::~CIMCacheAccessor()
+    {
+    TRACE( T_LIT("CIMCacheAccessor::~CIMCacheAccessor begin") );
+    delete iUserId;
+    //do not close the client session here. since there is also updater class which is closing the session
+    //moved this part of code which is common to both udpater and Accessor i.e, client ~CIMCacheClient()
+    //iClient.Close();    
+    TRACE( T_LIT("CIMCacheAccessor::~CIMCacheAccessor end") );
+    }
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::CIMCacheAccessor()
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+CIMCacheAccessor::CIMCacheAccessor(TInt aServiceId )
+	:iServiceId( aServiceId )
+	{
+	TRACE( T_LIT("CIMCacheAccessor::CIMCacheAccessor ") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::ServiceId()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheAccessor::ServiceId() const 
+	{
+	return iServiceId;	
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheAccess::RegisterObserverL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheAccessor::RegisterObserverL( MIMCacheEventHandler& aObserver  )
+	{
+	TRACE( T_LIT("CIMCacheAccess::RegisterObserverL begin") );
+	// update case ETrue says CV is active
+	// cch need not to register
+	iClient.RegisterAccessObserverL( aObserver  );
+	TRACE( T_LIT("CIMCacheAccess::RegisterObserverL end") );
+	}
+
+// -----------------------------------------------------------------------------
+// CIMCacheAccess::UnRegisterObserverL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheAccessor::UnRegisterObserver( MIMCacheEventHandler& aObserver )
+	{
+	TRACE( T_LIT("CIMCacheAccess::UnRegisterObserverL begin") );
+	iClient.UnRegisterAccessObserver( aObserver );
+	TRACE( T_LIT("CIMCacheAccess::UnRegisterObserverL end") );
+	}
+// -----------------------------------------------------------------------------
+// CIMCacheAccess::GetUnreadMessageCountL()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheAccessor::GetUnreadMessageCountL(const TDesC& aBuddyId)
+	{
+	TRACE( T_LIT("CIMCacheAccess::GetUnreadMessageCount") );
+	if( !aBuddyId.Length() )
+		{
+		User::Leave( KErrArgument )	;
+		}
+	return iClient.GetInformationL(EIMCacheGetUnreadCount, iServiceId,aBuddyId );
+	}
+//-----------------------------------------------------------------------------
+// CIMCacheAccessor::IsConversationExistL
+// ( Other items commented in header )
+//-----------------------------------------------------------------------------    
+TBool CIMCacheAccessor::IsConversationExistL( const TDesC& aBuddyId ) 
+	{
+	TRACE( T_LIT("CIMCacheAccess::IsConversationExistL Start ") );
+	if( !aBuddyId.Length() )
+		{
+		User::Leave( KErrArgument )	;
+		}
+	TBool ret = iClient.GetInformationL(EIMCacheIsConversationExist,iServiceId, aBuddyId );
+	TRACE( T_LIT("CIMCacheAccess::IsConversationExistL End ") );
+	return ret;  
+  	}
+  
+  // -----------------------------------------------------------------------------
+// CIMCacheAccess::GetAllUnreadMessageCountL()
+// -----------------------------------------------------------------------------
+//
+TInt CIMCacheAccessor::GetAllUnreadMessageCountL()
+	{
+	TRACE( T_LIT("CIMCacheAccess::GetAllUnreadMessageCountL") );
+	return iClient.GetInformationL( EIMCacheGetAllUnreadCount,iServiceId );
+	}	
+
+	
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::CloseConversationL()
+// -----------------------------------------------------------------------------
+//
+void CIMCacheAccessor::CloseConversationL( const TDesC& aBuddyId )
+    {
+    TRACE( T_LIT("CIMCacheAccessor::CloseConversationL begin") ); 
+    if( !aBuddyId.Length() )
+		{
+		User::Leave( KErrArgument )	;
+		}
+    iClient.StartTransactionL( EIMCacheCloseConversation,
+    						   iServiceId, 
+                               aBuddyId                               
+                                );
+    TRACE( T_LIT("CIMCacheAccessor::CloseConversationL end") );
+    }
+ 
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::GetChatListL()
+// -----------------------------------------------------------------------------
+//
+RArray<SIMCacheChatItem> CIMCacheAccessor::GetChatListL( const TInt aServiceId  )
+    {
+    TRACE( T_LIT("CIMCacheUpdater::GetChatListL") );    
+    RArray<SIMCacheChatItem> chatListArray;//array to hold chat item
+    TBool more = EFalse;
+    TPtr8 bufferPtr =  iClient.GetChatListL( aServiceId );
+    InternalizeChatListL( chatListArray, bufferPtr, more );
+    
+    while( more)
+        {
+        bufferPtr = iClient.GetBufferedDataL( EIMCacheGetBufferedPackets );
+        InternalizeChatListL( chatListArray, bufferPtr, more );
+        }
+    return chatListArray;
+    }
+    
+// -----------------------------------------------------------------------------
+// CIMCacheAccessor::InternalizeChatListL
+// -----------------------------------------------------------------------------
+//
+void CIMCacheAccessor::InternalizeChatListL(RArray<SIMCacheChatItem>& aChatArray, TPtr8 aChatListBuffer ,TBool& aMore )
+    {
+    TRACE( T_LIT("CIMCacheAccessor::InternalizeChatListL() begin") );   
+    
+    RDesReadStream readAllStream ;
+    RDesReadStream readStream ;    
+    
+    readAllStream.Open( aChatListBuffer );
+    CleanupClosePushL(readAllStream);
+    
+    TInt messageCount = readAllStream.ReadInt16L();
+    
+    for( TInt i=0; i< messageCount; i++)
+        {
+        SIMCacheChatItem chatItem =
+          {
+          0,
+          };
+                
+        TInt size = readAllStream.ReadInt16L() ;
+        HBufC8* mBuffer  = HBufC8::NewLC( size );
+        TPtr8 mBufferPtr = mBuffer->Des();
+                
+        readAllStream.ReadL( mBufferPtr , size );
+        
+        readStream.Open( *mBuffer );        
+        CleanupClosePushL(readStream) ;
+        
+        chatItem.iServiceId  = static_cast<TInt>( readStream.ReadInt16L() );
+        
+        TInt textSize = readStream.ReadInt16L();
+        HBufC* buddyId = HBufC::NewLC( textSize );
+        TPtr buddyIdPtr = buddyId->Des(); 
+        readStream.ReadL( buddyIdPtr , textSize);
+        
+        chatItem.iBuddyId = buddyId;
+        CleanupStack::Pop(buddyId); // ownership to structure variable
+        aChatArray.Insert(chatItem, 0);
+        CleanupStack::PopAndDestroy(2);//close read stream, delete mBuffer.      
+                   
+        }
+
+    aMore = static_cast<TBool>( readAllStream.ReadInt16L() );
+    CleanupStack::PopAndDestroy();//readAllStream.    
+    TRACE( T_LIT("CIMCacheAccessor::InternalizeChatListL() End") );
+    }
+ 
+//  END OF FILE
+
+