/*

* 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:  Class that provides handling of vpbk local store

*

*/

// INCLUDE FILES

#include <AknUtils.h> 

#include "cvimpststoragevpbklocalstore.h"

#include "cvimpststoragevpbkstorehandler.h"

#include <MVPbkContactView.h>

#include <CVPbkContactIdConverter.h>

#include "mvimpststorageserviceview.h"

#include "tvimpstconsts.h"

#include <CVPbkContactLinkArray.h>

#include <MVPbkContactLink.h>

#include "cvimpststoragecontact.h"

#include "vimpststorageutils.h"

#include <f32file.h>

#include <sysutil.h>

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

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

// CVIMPSTStorageVPbkLocalStore::

//      CVIMPSTStorageVPbkLocalStore

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

//

CVIMPSTStorageVPbkLocalStore:: CVIMPSTStorageVPbkLocalStore( MVIMPSTStorageServiceCacheWriter& aServiceCacheWriter ):

	CActive( CActive::EPriorityIdle ),

    iServiceCacheWriter( aServiceCacheWriter ),

    iFetchStep( EFetchingUnknown )

    { 

    CActiveScheduler::Add( this );

    }

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

// CVIMPSTStorageVPbkLocalStore::NewL

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

//

CVIMPSTStorageVPbkLocalStore* CVIMPSTStorageVPbkLocalStore::NewL( const TDesC& aContactDb,

    															 const TDesC& aServiceName,

    															 MVIMPSTStorageServiceCacheWriter& aServiceCacheWriter )

    {

    CVIMPSTStorageVPbkLocalStore* self = NewLC( aContactDb,  

    										   aServiceName,

											  aServiceCacheWriter);

    CleanupStack::Pop( self );

    return self;

    }

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

// CVIMPSTStorageVPbkLocalStore::NewLC

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

//

CVIMPSTStorageVPbkLocalStore* 

    CVIMPSTStorageVPbkLocalStore::NewLC( const TDesC& aContactDb, 

    									const TDesC& aServiceName,

    									MVIMPSTStorageServiceCacheWriter& aServiceCacheWriter  )

    {

    CVIMPSTStorageVPbkLocalStore* self =

        new (ELeave) CVIMPSTStorageVPbkLocalStore(aServiceCacheWriter);

    CleanupStack::PushL( self );

    self->ConstructL( aContactDb, aServiceName );

    return self;

    }

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

// CVIMPSTStorageVPbkLocalStore::ConstructL

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

//

void CVIMPSTStorageVPbkLocalStore::ConstructL( const TDesC& aContactDb, const TDesC& aServiceName )

    {

    iVPbkStoreHandler = CVIMPSTStorageVPbkStoreHandler::NewL( aContactDb ,aServiceName, *this,ETrue );

     //construct the persistent store name

    iLocalDBName = HBufC::NewL( aServiceName.Length()+ KStorageExtn().Length());

    TPtr iLocalDBNamePtr = iLocalDBName->Des();

    iLocalDBNamePtr.Append(aServiceName);

    _LIT(KSpecialChar ,"/\\:*?<>\"");

    AknTextUtils :: StripCharacters(iLocalDBNamePtr,KSpecialChar); 

    iLocalDBNamePtr.Append(KStorageExtn());    

    MVPbkContactStore* defaultStore = iVPbkStoreHandler->GetDefaultStoreL( aContactDb );

    User::LeaveIfNull(defaultStore);  

    iIdConverter = CVPbkContactIdConverter::NewL(*defaultStore);

    User::LeaveIfError( iFs.Connect() );

    // Open existing or create new database.

	if ( DbExists() )

		{

        OpenDbL();

		}

	else

		{

        DoFreespaceLevelCheckL( KEmptyDbSize );

        CreateDbL();

		}

    OpenTableL();

    iColset = iDb.ColSetL( KContactTable );    

    }

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

// CVIMPSTStorageVPbkLocalStore::

//      ~CVIMPSTStorageVPbkLocalStore

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

//

CVIMPSTStorageVPbkLocalStore::~CVIMPSTStorageVPbkLocalStore()

    {

    iRetrivedContactArray.ResetAndDestroy();

    TRAP_IGNORE( ResetAndDestroyLocalArrayL() );

    CloseTable();

    delete iColset;

    CloseDb();

    iFs.Close();    

    delete iLocalDBName;

    delete iIdConverter;	        

    delete iInviteId;

    delete iVPbkStoreHandler;

    }

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

// CVIMPSTStorageVPbkLocalStore::

//      ResetAndDestroyLocalArrayL

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

//

void CVIMPSTStorageVPbkLocalStore::ResetAndDestroyLocalArrayL()

    {

    TInt count = iFetchContactsToBeAdded.Count();

   	while( count )

	   	{

	   	TVIMPSTContactInfo contactInf = iFetchContactsToBeAdded[ count-1 ];

	   	iFetchContactsToBeAdded.Remove( count-1 );

		delete contactInf.iUserId;

		contactInf.iUserId = NULL;	

		delete contactInf.iDisplayName;

		contactInf.iDisplayName = NULL;				         

         // not exist need to add 

        iFetchContactsToBeAdded.Compress();	

        count = iFetchContactsToBeAdded.Count();

	   	}

	iFetchContactsToBeAdded.Reset();

    }

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

// CVIMPSTStorageVPbkLocalStore::LocalStore

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

//

TBool CVIMPSTStorageVPbkLocalStore::LocalStore() const 

	{

	return ETrue;

	}

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

// CVIMPSTStorageVPbkLocalStore::HandleVPbkStoreEventL

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

//

void CVIMPSTStorageVPbkLocalStore::HandleVPbkStoreEventL(TVIMPSTVPbkStoreEvent aVPbkStoreEvent) 

	{

	switch( aVPbkStoreEvent.iEventType )

	    {

	    case EVPbkContactReadCompleted:

	    	{

	    	iServiceCacheWriter.NotifyServiceViewL(TVIMPSTEnums::EStorageContactReadComplete);

	    	if( iFetchStep == EFetchingCalled )

		    	{

		    	IssueRequest();		

		    	}

	    	iFetchStep = EContactReadComplete;

		  	break;

	    	}

	    case EVPbkContactReading:

		    {

		    // a contact entry has been created in virtual database store

			// create the cache contact

			TInt32 linkId = iIdConverter->LinkToIdentifier(*aVPbkStoreEvent.iContactLink );

			TDbColNo colNo = iColset->ColNo( KContactId );

		    if ( SeekRowL( colNo, linkId ) )

				{

				/*

					*	This is local store, that is phone book and service tab shares only one cdb file.

					* 	in that case, if somebody edits the cdb file from contacts tab, then also we get the 

					* 	callback, then checking for entry in db table makes sens.. 

				*/

				/*

				 * 	in case when the user adds a contact from the service tab, then it first tries to add it in the

				 *	cdb file, after that we get this callback, then , there is no way that it will be present in the

				 *	db table, in that case, we will not add it in the cache - which is wrong.. 

				 *	so we need to make a differentiation, on how the contact was added.. whether from cotnacts tab

				 *	or from the service tab. --- to solve this issue.. we can store the userid in memberVariable.. 

				 *	before making a add request to the VPBK (cdb file).. then in this function, we check if

				 *	the contactid is same as the member variable.  aVPbkStoreEvent contains the userid that was added.

				 *	then if it matches, then we know that it was added from our service tab.. and then we can add it in our DB.

				 */

				// contatc found in local database ,add to storage

				iServiceCacheWriter.AddContactToCacheL (*aVPbkStoreEvent.iContactLink , 

										 aVPbkStoreEvent.iUserId ,

										 aVPbkStoreEvent.iDisplayName,

										 aVPbkStoreEvent.iAvatarContent,

										 TVIMPSTEnums::EStorageContactReading );

				}

		    break;	

		    }

		case EVPbkContactFetching:

	   	case EVPbkContactAdded:

			{

			// a contact entry has been created in virtual database store

			// create the cache contact

			TInt32 linkId = iIdConverter->LinkToIdentifier(*aVPbkStoreEvent.iContactLink );

			TDbColNo colNo = iColset->ColNo( KContactId );

			if( iFetchStep  == EFetchingOn )

		         {

		         WriteToStoreDbL( linkId );

		         iServiceCacheWriter.AddContactToCacheL (*aVPbkStoreEvent.iContactLink , 

		                 aVPbkStoreEvent.iUserId ,

		                 aVPbkStoreEvent.iDisplayName ,

		                 aVPbkStoreEvent.iAvatarContent,

		                 TVIMPSTEnums::EStorageContactFetching );

		      	IssueRequest();		

				}

			else if ( SeekRowL( colNo, linkId ) )

				{

				/*

					*	This is local store, that is phone book and service tab shares only one cdb file.

					* 	in that case, if somebody edits the cdb file from contacts tab, then also we get the 

					* 	callback, then checking for entry in db table makes sens.. 

				*/

				/*

				 * 	in case when the user adds a contact from the service tab, then it first tries to add it in the

				 *	cdb file, after that we get this callback, then , there is no way that it will be present in the

				 *	db table, in that case, we will not add it in the cache - which is wrong.. 

				 *	so we need to make a differentiation, on how the contact was added.. whether from cotnacts tab

				 *	or from the service tab. --- to solve this issue.. we can store the userid in memberVariable.. 

				 *	before making a add request to the VPBK (cdb file).. then in this function, we check if

				 *	the contactid is same as the member variable.  aVPbkStoreEvent contains the userid that was added.

				 *	then if it matches, then we know that it was added from our service tab.. and then we can add it in our DB.

				 */

				// contatc found in local database ,add to storage

				iServiceCacheWriter.AddContactToCacheL (*aVPbkStoreEvent.iContactLink , 

										 aVPbkStoreEvent.iUserId ,

										 aVPbkStoreEvent.iDisplayName,

										 aVPbkStoreEvent.iAvatarContent,

										 TVIMPSTEnums::EStorageEventContactAddition  );

				}

			else if(  iInviteId )

			    {

			    if( IsSameContactIdL( *iInviteId, aVPbkStoreEvent.iUserId ) )

			        {

			        WriteToStoreDbL( linkId );

			        iServiceCacheWriter.AddContactToCacheL (*aVPbkStoreEvent.iContactLink , 

			                aVPbkStoreEvent.iUserId ,

			                aVPbkStoreEvent.iDisplayName,

			                aVPbkStoreEvent.iAvatarContent,

			                TVIMPSTEnums::EStorageEventContactAddition );

			        delete iInviteId;

			        iInviteId = NULL;

			        }

			    }

			break;	

			}

	   	case EVPbkContactSynchronizing:

	   	    {

	   	    // a contact entry has been created in virtual database store

	   	    // create the cache contact

	   	    TInt32 linkId = iIdConverter->LinkToIdentifier(*aVPbkStoreEvent.iContactLink );

	   	    TDbColNo colNo = iColset->ColNo( KContactId );

	   	    if ( SeekRowL( colNo, linkId ) )

	   	        {

	   	        /*

	   	         *   This is local store, that is phone book and service tab shares only one cdb file.

	   	         *   in that case, if somebody edits the cdb file from contacts tab, then also we get the 

	   	         *   callback, then checking for entry in db table makes sens.. 

	   	         */

	   	        /*

	   	         *  in case when the user adds a contact from the service tab, then it first tries to add it in the

	   	         *  cdb file, after that we get this callback, then , there is no way that it will be present in the

	   	         *  db table, in that case, we will not add it in the cache - which is wrong.. 

	   	         *  so we need to make a differentiation, on how the contact was added.. whether from cotnacts tab

	   	         *  or from the service tab. --- to solve this issue.. we can store the userid in memberVariable.. 

	   	         *  before making a add request to the VPBK (cdb file).. then in this function, we check if

	   	         *  the contactid is same as the member variable.  aVPbkStoreEvent contains the userid that was added.

	   	         *  then if it matches, then we know that it was added from our service tab.. and then we can add it in our DB.

	   	         */

	   	        // contatc found in local database ,add to storage

	   	        iServiceCacheWriter.AddContactToCacheL (*aVPbkStoreEvent.iContactLink , 

	   	                aVPbkStoreEvent.iUserId ,

	   	                aVPbkStoreEvent.iDisplayName,

	   	                aVPbkStoreEvent.iAvatarContent,

	   	                TVIMPSTEnums::EStorageContactFetching  );

	   	        }

	   	   if(iFetchStep == EFetchingOn)          

               {

               IssueRequest();

               }

	   	    break;

	   	    }

		case EVPbkContactDeleted:

		    {

		    TInt32 linkId = iIdConverter->LinkToIdentifier(*aVPbkStoreEvent.iContactLink );

		    // a contact entry has been deleted from virtual database store

		    TDbColNo colNo = iColset->ColNo( KContactId );

		    if ( SeekRowL( colNo, linkId ) )

		        { 

		        // contatc found in local database ,delete from local database 

		        DeleteContactFromInternalStoreL( linkId );

		         // delete from cache contact

		    	iServiceCacheWriter.RemoveContactFromCacheL(*aVPbkStoreEvent.iContactLink, 

		    												TVIMPSTEnums::EStorageEventDeleteFromPbk );

		        }

		    break;	 

		    }

		case EVPbkContactChanged:

		    {

		    TInt32 linkId = iIdConverter->LinkToIdentifier(*aVPbkStoreEvent.iContactLink );

		    TDbColNo colNo = iColset->ColNo( KContactId );

		    if ( SeekRowL( colNo, linkId ) )

		       {

		       // found in the list update it

		       iServiceCacheWriter.UpdateCacheContactL(*aVPbkStoreEvent.iContactLink , 

					    						 	 aVPbkStoreEvent.iUserId ,

					    							 aVPbkStoreEvent.iDisplayName,

					    							 aVPbkStoreEvent.iAvatarContent );

		       }

		    break;	

		    }

	    case EVPbkContactRetriving:

		    {

		    // in case of local we allow all 

			CVIMPSTStorageContact* retrivedContact = CVIMPSTStorageContact::NewL( aVPbkStoreEvent.iUserId ,

											    								  aVPbkStoreEvent.iDisplayName,

											    								  *aVPbkStoreEvent.iContactLink,

											    								  aVPbkStoreEvent.iAvatarContent);

			iRetrivedContactArray.Append( retrivedContact ); // takes the ownership of retrivedContact

			// keep the backup of retrieved contacts

			// user can add later once it sent to server

			break;	

		    }

		case EVPbkUnknownChanges:

		    {

		    DeleteAllContactFromInternalStoreL();

		     // unknow mean all contact deleted from store

		    iServiceCacheWriter.RemoveAllCacheContactsL();

		    break;	

		    }

	    default:

		 	break;

	    }

	}

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

// CVIMPSTStorageVPbkLocalStore::IssueRequest

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

//

void CVIMPSTStorageVPbkLocalStore::IssueRequest()

    {

    if( !IsActive() )

	    {

	    TRequestStatus* status = &iStatus;

	    User::RequestComplete( status, KErrNone );

	    SetActive();

	    }

    }

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

// CVIMPSTStorageVPbkLocalStore::RunL

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

//

void CVIMPSTStorageVPbkLocalStore::RunL()

    {

    TInt count = iFetchContactsToBeAdded.Count();

    if( !count )

        {

        iFetchStep = EContactReadComplete;

        iServiceCacheWriter.NotifyServiceViewL( TVIMPSTEnums::EStorageContactFetchComplete );

	    }

    else

        {

        iFetchStep  = EFetchingOn;

        TVIMPSTContactInfo contactInfoToAdd = iFetchContactsToBeAdded[0];

        MVIMPSTStorageContact* exist = iServiceCacheWriter.FindCacheContactByUserId( *contactInfoToAdd.iUserId );

        if( exist )

	        {

	        // contact is already exist ,send the notification about this

	        iServiceCacheWriter.NotifyServiceViewL(TVIMPSTEnums::EStorageContactFetchExistInStore, exist );

	        // process next

	        IssueRequest();

	        }

	    else

		    {

		     // pass the display NAme in place of NULL

        	iVPbkStoreHandler->CreateVPbkContactL( *contactInfoToAdd.iUserId, *contactInfoToAdd.iDisplayName ); // process always 0th item

            }

        iFetchContactsToBeAdded.Remove( 0 );

        delete contactInfoToAdd.iUserId;

        contactInfoToAdd.iUserId = NULL;

        delete contactInfoToAdd.iDisplayName;

        contactInfoToAdd.iDisplayName = NULL ;

        iFetchContactsToBeAdded.Compress();

        }

    }

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

// CVIMPSTStorageVPbkLocalStore::DoCancel

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

//

void CVIMPSTStorageVPbkLocalStore::DoCancel()

    {

    }

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

// CVIMPSTStorageVPbkLocalStore::RunError

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

//

TInt CVIMPSTStorageVPbkLocalStore::RunError( TInt aError )

    { 

    return aError;

    }

//////////////////////////////////////////////////////////

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

// CVIMPSTStorageVPbkLocalStore::CreateVPbkContactL

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

// 

TInt CVIMPSTStorageVPbkLocalStore::CreateVPbkContactL(const TDesC& aUserId, 

        										   	  const TDesC& aDisplayName ,

        										   	  TBool aInvitationAutoAccept /* = EFalse */ )   

	{

	TInt error = KErrGeneral;

	if( aInvitationAutoAccept)

	    {

	    delete iInviteId;

	    iInviteId = NULL;