sl@0: // Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include "LOGCHNGE.H"
sl@0: #include <logwraplimits.h>
sl@0: #include <logcntdef.h>
sl@0: #include "LOGQUERY.H"
sl@0: #include "logservpanic.h"
sl@0: #include "LogServRecentList.h"
sl@0: #include "LogServCacheConfig.h"
sl@0: #include "LogServRecentListManager.h"
sl@0: #include "LogServDatabaseTransactionInterface.h"
sl@0: #include "LogServDatabaseChangeInterface.h"
sl@0: #include "LOGDUP.H"
sl@0: #include "LogServCacheStrings.h"
sl@0: #include "LogServSqlStrings.h"
sl@0: 
sl@0: //**********************************
sl@0: // CLogChangeEvent
sl@0: //**********************************
sl@0: 
sl@0: CLogChangeEvent::CLogChangeEvent(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)
sl@0: : CLogActive(aPriority), iDatabase(aDatabase)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: CLogChangeEvent::~CLogChangeEvent()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	//
sl@0: 	delete iEvent;
sl@0: 	delete iDuplicate;
sl@0: 	delete iDuplicateFilter;
sl@0: 	}
sl@0: 
sl@0: void CLogChangeEvent::ConstructL()
sl@0: 	{
sl@0: 	iEvent = CLogEvent::NewL();
sl@0: 	iDuplicate = CLogDuplicate::NewL(iDatabase, Priority());
sl@0: 	iDuplicateFilter = CLogFilter::NewL();
sl@0: 	}
sl@0: 
sl@0: CLogChangeEvent* CLogChangeEvent::NewL(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)
sl@0: 	{
sl@0: 	CLogChangeEvent* self = new(ELeave)CLogChangeEvent(aDatabase, aPriority);
sl@0: 	CleanupStack::PushL(self);
sl@0: 	self->ConstructL();
sl@0: 	CleanupStack::Pop();
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: void CLogChangeEvent::StartL(const CLogEvent& aEvent, const CLogServRecentList* aRecentList, TRequestStatus& aStatus, const RMessage2& aMessage)
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(iState == ELogNone, Panic(ELogBadState2));
sl@0: 	__ASSERT_DEBUG(!IsActive(), Panic(ELogAlreadyActive3));
sl@0: 
sl@0: 	iMessage = &aMessage;
sl@0: 	iEvent->CopyL(aEvent);
sl@0: 	iState = ELogChangeEvent;
sl@0: 	iRecentList = aRecentList; // Need to use this! (5yrs later - okay then :-)
sl@0: 	iOldRecentList = KLogNullRecentList;
sl@0: 
sl@0: 	Queue(aStatus);
sl@0: 	TRequestStatus* status = &iStatus;
sl@0: 	User::RequestComplete(status, KErrNone);
sl@0: 	SetActive();
sl@0: 	}
sl@0: 
sl@0: void CLogChangeEvent::DoRunL()
sl@0: 	{
sl@0: 	__ASSERT_DEBUG(iState != ELogNone, Panic(ELogBadState3));
sl@0: 
sl@0: 	switch (iState)
sl@0: 		{
sl@0: 		case ELogChangeEvent:
sl@0: 			DoChangeEventL();
sl@0:             ResetDuplicatesL();
sl@0:             UpdateDuplicateEventsL();
sl@0: 			break;
sl@0: 		case ELogPurgeRecent:
sl@0: 			{
sl@0:             RArray<TLogId> logIds;
sl@0:             ::LogGetRecentEventsLC(iDatabase, iRecentList->Id(), iDatabase.DTICacheConfig().Config().iMaxRecentLogSize, logIds); 
sl@0:             ::LogPurgeRecentEventsL(iDatabase, logIds);
sl@0:             CleanupStack::PopAndDestroy(&logIds);
sl@0: 			}
sl@0:             break;
sl@0:  		default:
sl@0:  			__ASSERT_DEBUG(ETrue, Panic(ELogBadState4));
sl@0:  			break;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CLogChangeEvent::DoComplete(TInt& aStatus)
sl@0: 	{
sl@0: 	if (iDatabase.DTIInTransaction())
sl@0: 		{
sl@0: 		if (aStatus == KErrNone)
sl@0: 			aStatus = iDatabase.DTICommitAndEnd();
sl@0: 
sl@0: 		if (aStatus < KErrNone)
sl@0: 			iDatabase.DTIRollBack();
sl@0: 		}
sl@0: 
sl@0: 	iState = ELogNone;
sl@0: 	}
sl@0: 
sl@0: void CLogChangeEvent::ResetDuplicatesL()
sl@0:     {
sl@0:     // Was it in a recent list? Is it now changing lists?
sl@0:     if (iOldRecentList > 0 && (!iRecentList || iOldRecentList != iRecentList->Id()))
sl@0:         {
sl@0:         ::LogResetDuplicatesL(iDatabase, iEvent->Id());
sl@0:         }
sl@0:     }
sl@0: 
sl@0: void CLogChangeEvent::UpdateDuplicateEventsL()
sl@0:     {
sl@0:     // Detect duplicate events if we've added an event to a recent list
sl@0:     if (iOldRecentList > 0 && iRecentList && iOldRecentList != iRecentList->Id())
sl@0:         {
sl@0:         iRecentList->GetFilter(*iEvent, *iDuplicateFilter);
sl@0:         // If we get here we have added an event to a recent list, which may need to be purged
sl@0:         iState = ELogPurgeRecent;
sl@0:         // Passing -1 into this will ensure that events are updated so the most recent duplicate is first
sl@0:         if (!iDuplicate->StartL(-1, iRecentList->Id(), *iDuplicateFilter, iStatus))
sl@0:             {
sl@0:             // Complete ourselves
sl@0:             TRequestStatus* status = &iStatus;
sl@0:             User::RequestComplete(status, KErrNone);
sl@0:             }
sl@0:         SetActive();
sl@0:         }
sl@0:     }
sl@0: 
sl@0: void CLogChangeEvent::DoChangeEventL()
sl@0:     {
sl@0:     RLogEventDbTable tbl;
sl@0:     tbl.OpenLC(iDatabase.DTIDatabase());
sl@0:     User::LeaveIfError(tbl.SetIndex(KLogNameEventIdx1));
sl@0:     if(!tbl.SeekL(TDbSeekKey((TInt)iEvent->Id())))
sl@0:         {
sl@0:         User::Leave(KErrNotFound);
sl@0:         }
sl@0:     User::LeaveIfError(iDatabase.DTIBegin());
sl@0:     tbl.GetL();
sl@0:     iOldRecentList = tbl.ColInt8(RLogEventDbTable::iRecentColNo);
sl@0:     DoChangeL(tbl, iDatabase.DTICacheStrings().GetIdL(iEvent->Direction()), iDatabase.DTICacheStrings().GetIdL(iEvent->Status()));
sl@0:     CleanupStack::PopAndDestroy();//tbl
sl@0:     }
sl@0: 
sl@0: void CLogChangeEvent::DoChangeL(RLogEventDbTable& aTbl, TLogStringId aDirectionId, TLogStringId aStatusId)
sl@0: 	{
sl@0: 	if(!iDatabase.DTIIsAllowed(EWriteOp, *iMessage, iEvent->EventType())) 
sl@0: 		{
sl@0: 		User::Leave(KErrPermissionDenied);
sl@0: 		}
sl@0: 	
sl@0: 	aTbl.UpdateL();
sl@0: 
sl@0: 	if (iEvent->RemoteParty().Length() > 0)
sl@0: 		aTbl.SetColL(RLogEventDbTable::iRemotePartyColNo, iEvent->RemoteParty());
sl@0: 	else
sl@0: 		aTbl.SetColNullL(RLogEventDbTable::iRemotePartyColNo);
sl@0: 
sl@0: 	if (iEvent->Direction().Length() > 0)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iDirectionColNo, (TUint32)aDirectionId);
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iDirectionColNo);
sl@0: 
sl@0: 	aTbl.SetColL(RLogEventDbTable::iTimeColNo, iEvent->Time());
sl@0: 	aTbl.SetColL(RLogEventDbTable::iDurationTypeColNo, (TInt32)iEvent->DurationType());
sl@0: 
sl@0: 	if (iEvent->DurationType() != KLogNullDurationType)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iDurationColNo, iEvent->Duration());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iDurationColNo);
sl@0: 
sl@0: 	if (iEvent->Status().Length() > 0)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iStatusColNo, (TUint32)aStatusId);
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iStatusColNo);
sl@0: 
sl@0: 	if (iEvent->Subject().Length() > 0)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iSubjectColNo, iEvent->Subject());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iSubjectColNo);
sl@0: 
sl@0: 	if (iEvent->Number().Length() > 0)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iNumberColNo, iEvent->Number());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iNumberColNo);
sl@0: 
sl@0: 	if (iEvent->Contact() != KLogNullContactId)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iContactColNo, iEvent->Contact());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iContactColNo);
sl@0: 
sl@0: 	if (iEvent->Link() != KLogNullLink)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iLinkColNo, iEvent->Link());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iLinkColNo);
sl@0: 
sl@0: 	if (iEvent->Data().Length() > 0)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iDataColNo, iEvent->Data());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iDataColNo);
sl@0: 
sl@0: 	// Set the flags
sl@0: 	TInt bit = KLogFlagsCount;
sl@0: 	while(bit--)
sl@0: 		{
sl@0:         aTbl.SetColL(RLogEventDbTable::iFlagColNo[bit], (TUint32)((iEvent->Flags() & 0x1 << bit) ? 1 : 0));
sl@0: 		}
sl@0: 
sl@0: 	// Set the recent list
sl@0: 	if (iOldRecentList > 0)
sl@0: 		{
sl@0: 		// Removing an event from all recent lists?
sl@0: 		if (!iRecentList)
sl@0: 			{
sl@0: 			aTbl.SetColNullL(RLogEventDbTable::iRecentColNo);
sl@0: 			aTbl.SetColNullL(RLogEventDbTable::iDuplicateColNo);
sl@0: 			}
sl@0: 		// Changing list?
sl@0: 		else if (iOldRecentList != iRecentList->Id())
sl@0: 			{
sl@0: 			__ASSERT_DEBUG(iRecentList->Id() != KLogNullRecentList, Panic(ELogNullRecentList));
sl@0: 			aTbl.SetColL(RLogEventDbTable::iRecentColNo, (TInt32)iRecentList->Id());
sl@0: 
sl@0: 			// This is set to -1 to prevent it temporarily appearing in a recent or duplicate view
sl@0: 			// It gets updated properly later when detecting duplicates
sl@0: 			aTbl.SetColL(RLogEventDbTable::iDuplicateColNo, -1);
sl@0: 			}
sl@0: 		}
sl@0: 
sl@0: #ifdef SYMBIAN_ENABLE_EVENTLOGGER_DUALSIM	
sl@0: 	if(iEvent->SimId() != KLogNullSimId)
sl@0: 	    aTbl.SetColL(RLogEventDbTable::iSimIdColNo, iEvent->SimId());
sl@0: 	else
sl@0: 	    aTbl.SetColNullL(RLogEventDbTable::iSimIdColNo);
sl@0: #endif	
sl@0: 	
sl@0: 	aTbl.PutL();
sl@0: 
sl@0: 	iDatabase.DTIChangeInterface().DCISubmitChangedEventContextL(ELogChangeTypeEventChanged, iEvent->Id());
sl@0: 	}
sl@0: 
sl@0: //**********************************
sl@0: // CLogChangeConfig
sl@0: //**********************************
sl@0: 
sl@0: CLogChangeConfig::CLogChangeConfig(MLogServDatabaseTransactionInterface& aDatabase, const CLogServRecentListManager& aRecentSetup, TInt aPriority)
sl@0: : CLogActive(aPriority), iDatabase(aDatabase), iRecentSetup(aRecentSetup)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: CLogChangeConfig::~CLogChangeConfig()
sl@0: 	{
sl@0: 	Cancel();
sl@0: 	}
sl@0: 
sl@0: CLogChangeConfig* CLogChangeConfig::NewL(MLogServDatabaseTransactionInterface& aDatabase, const CLogServRecentListManager& aRecentSetup, TInt aPriority)
sl@0: 	{
sl@0: 	CLogChangeConfig* self = new(ELeave) CLogChangeConfig(aDatabase, aRecentSetup, aPriority);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: void CLogChangeConfig::StartL(const TLogConfig& aConfig, TRequestStatus& aStatus)
sl@0: 	{
sl@0: 	__ASSERT_ALWAYS(iState == ELogNone, Panic(ELogBadState5));
sl@0: 	__ASSERT_DEBUG(!IsActive(), Panic(ELogAlreadyActive4));
sl@0: 
sl@0: 	iState = ELogChange;
sl@0: 	iConfig = &aConfig;
sl@0: 
sl@0: 	Queue(aStatus);
sl@0: 	TRequestStatus* status = &iStatus;
sl@0: 	User::RequestComplete(status, KErrNone);
sl@0: 	SetActive();
sl@0: 	}
sl@0: 
sl@0: void CLogChangeConfig::DoRunL()
sl@0: 	{
sl@0: 	switch (iState)
sl@0: 		{
sl@0: 		case ELogChange:
sl@0: 			{
sl@0: 			// Start a transaction
sl@0: 			User::LeaveIfError(iDatabase.DTIBegin());
sl@0: 			// Change the config, using the existing transaction
sl@0: 			iDatabase.DTICacheConfig().UpdateL(*iConfig);
sl@0: 			//Purge old events
sl@0:             RLogEventDbTable tbl;
sl@0:             tbl.OpenLC(iDatabase.DTIDatabase());
sl@0:             ::LogPurgeMainL(iDatabase, tbl, iConfig->iMaxLogSize, 0);
sl@0:             CleanupStack::PopAndDestroy(&tbl);
sl@0:             iRecent = 0;
sl@0:             //
sl@0: 			iState = ELogPurgeRecent;
sl@0: 			TRequestStatus* status = &iStatus;
sl@0: 			User::RequestComplete(status, KErrNone);
sl@0: 			SetActive();
sl@0: 			break;
sl@0: 			}
sl@0: 		case ELogPurgeRecent:
sl@0: 			{
sl@0: 			// Are there any more recent lists to check
sl@0: 			if(iRecent >= iRecentSetup.Count())
sl@0: 			    {
sl@0: 				break;
sl@0: 			    }
sl@0:             RArray<TLogId> logIds;
sl@0:             ::LogGetRecentEventsLC(iDatabase, iRecentSetup.List(iRecent).Id(), iConfig->iMaxRecentLogSize, logIds); 
sl@0:             ::LogPurgeRecentEventsL(iDatabase, logIds);
sl@0:             CleanupStack::PopAndDestroy(&logIds);
sl@0:             // Purge next recent list?
sl@0:             if (++iRecent < iRecentSetup.Count())
sl@0:                 {
sl@0:                 iState = ELogPurgeRecent;
sl@0:                 TRequestStatus* status = &iStatus;
sl@0:                 User::RequestComplete(status, KErrNone);
sl@0:                 SetActive();
sl@0:                 }
sl@0:             break;
sl@0: 			}
sl@0: 		default:
sl@0: 			__ASSERT_DEBUG(ETrue, Panic(ELogBadState6));
sl@0: 			break;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CLogChangeConfig::DoComplete(TInt& aStatus)
sl@0: 	{
sl@0: 	// Try and commit the transaction
sl@0: 	if (iDatabase.DTIInTransaction())
sl@0: 		{
sl@0: 		if	(aStatus == KErrNone)
sl@0: 			aStatus = iDatabase.DTICommitAndEnd();
sl@0: 
sl@0: 		if	(aStatus < KErrNone)
sl@0: 			{
sl@0: 			iDatabase.DTICacheConfig().Rollback();
sl@0: 			iDatabase.DTIRollBack();
sl@0: 			}
sl@0: 		else
sl@0: 		    {
sl@0: 		    iDatabase.DTICacheConfig().Commit();
sl@0: 		    }
sl@0: 		}
sl@0:     __ASSERT_DEBUG(!iDatabase.DTICacheConfig().InTransaction(), Panic(ELogChangeConfigLogicError));
sl@0: 	iState = ELogNone;
sl@0: 	}