// Copyright (c) 2003-2009 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:

//

#include "LOGMAIN.H"

#include "LOGREC.H"

#include "LOGCOMP.H"

#include "logservpanic.h"

#include "LOGQUERY.H"

#include "LogServDatabaseTransactionInterface.h"

#include "LogServCacheConfig.h"

#include "LogCliServShared.h"

#include "LogServDatabaseChangeInterface.h"

#include "LogServSqlStrings.h"

CLogMaintenance::CLogMaintenance(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

: CLogActive(aPriority), iDatabase(aDatabase)

	{

	}

CLogMaintenance::~CLogMaintenance()

	{

	Cancel();

	delete iRecover;

	delete iCompact;

	}

void CLogMaintenance::ConstructL()

	{

	iRecover = new(ELeave)CLogRecover(iDatabase, Priority());

	iCompact = new(ELeave)CLogCompact(iDatabase, Priority());

	}

CLogMaintenance* CLogMaintenance::NewL(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

	{

	CLogMaintenance* self = new(ELeave)CLogMaintenance(aDatabase, aPriority);

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop();

	return self;

	}

void CLogMaintenance::Start(TBool aPurge, TRequestStatus& aStatus)

	{

	iState = ELogRecover;

	iPurge = aPurge;

	Queue(aStatus);

	TRequestStatus* status = &iStatus;

	User::RequestComplete(status, KErrNone);

	SetActive();

	}

TBool CLogMaintenance::DoNextL()

	{

	switch(iState)

		{

		// Recover the database

		case ELogRecover:

			if (iRecover->Start(iStatus))

				{

				iState = ELogGetConfig;

				return ETrue;

				}

			// Fall Through

		// Get the log configuration

		case ELogGetConfig:

			if (iPurge)

				{

				iConfig = iDatabase.DTICacheConfig().Config();				

				TRequestStatus* status = &iStatus;

				User::RequestComplete(status, KErrNone);

				iState = iConfig.iMaxEventAge == 0 ? ELogCompact : ELogPurgeMainAge;

				return ETrue;

				}

			// Fall through

		// Purge old events from the log

		case ELogPurgeMainAge:

			if (iPurge)

				{

				// Get the max age

				TTime date;

				date.UniversalTime();

				date -= TTimeIntervalSeconds(iConfig.iMaxEventAge);

				ClearLogL(date, iStatus);

				iState = ELogCompact;

				return ETrue;

				}

		// Compact the database

		case ELogCompact:

			iCompact->Start(iStatus);

			iState = ELogComplete;

			return ETrue;

		case ELogComplete:

			break;

		default:

			__ASSERT_DEBUG(EFalse, Panic(ELogNoSuchState7));

		};

	return EFalse;

	}

void CLogMaintenance::DoRunL()

	{

	if (DoNextL())

		SetActive();

	}

void CLogMaintenance::DoCancel()

	{

	iRecover->Cancel();

	iCompact->Cancel();

	CLogActive::DoCancel();

	}

void CLogMaintenance::DoComplete(TInt& aStatus)

	{

	// Ignore all errors

	aStatus = KErrNone;

	}

// aDate is expected to be UTC  

void CLogMaintenance::ClearLogL(const TTime& aDate, TRequestStatus& aStatus)

	{

	TBuf<KLogMaxDateLength> date;

	aDate.FormatL(date, LogUtils::DateFormatForLocale());

    // Get list of events to purge

    TheSql.Format(KLogSqlSelectOldestString, &date);

    RLogDbView view;

    view.PrepareLC(iDatabase.DTIDatabase(), TheSql);

	if(view.FirstL())

		{

        static TDbColNo idColNo = 0;

        if(idColNo == 0)

            {

            CDbColSet* cs = view.ColSetL();

            idColNo = cs->ColNo(KLogFieldIdString);

            delete cs;

            }

        iDatabase.DTIBeginWithRollBackProtectionLC();

		do

			{

			view.GetL();

			const TLogId id = view.ColInt32(idColNo);

			view.DeleteL();

			iDatabase.DTIChangeInterface().DCISubmitChangedEventContextL(ELogChangeTypeEventDeleted, id);

			}

		while(view.NextL());

		// Commit changes

		iDatabase.DTICommitAndCancelRollbackProtectionL();

		}

	CleanupStack::PopAndDestroy(&view);

	// Complete the request

	TRequestStatus* status = &aStatus;

	User::RequestComplete(status, KErrNone);

	}