// Copyright (c) 2002-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 "LOGDUP.H"

#include "LOGFILTQ.H"

#include "LOGQUERY.H"

#include "logservpanic.h"

#include "LogServDatabaseTransactionInterface.h"

#include "LogServResourceInterpreter.h"

#include "LogServDatabaseChangeInterface.h"

#include "LogServSqlStrings.h"

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

    CLogActive(aPriority), 

    iDatabase(aDatabase)

	{

	}

CLogDuplicate::~CLogDuplicate()

	{

	Cancel();

	delete iFilterList;

	}

void CLogDuplicate::ConstructL()

	{

	iFilterList = new(ELeave) CLogFilterList;

	}

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

	{

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

	CleanupStack::PushL(self);

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

TBool CLogDuplicate::StartL(TLogId aId, TLogRecentList aRecentList, const CLogFilter& aFilter, TRequestStatus& aStatus)

	{

	if (aRecentList == KLogNullRecentList)

		return EFalse;

	iId = aId;

	iRecentList = aRecentList;

	iFilterList->Reset();

	iFilterList->AppendL(&aFilter);

	Queue(aStatus);

    TRequestStatus* status = &iStatus;

    User::RequestComplete(status, KErrNone);

	SetActive();

	return ETrue;

	}

void CLogDuplicate::DoRunL()

	{

    RLogDynBuf expr;

    TLogFilterExprBuilder exprBuilder(iDatabase);

    exprBuilder.BuildExprLC(expr, *iFilterList, KLogAnd);

    TheSql.Format(KLogSqlSelectDuplicateString, iRecentList, &expr.DesC(), iId);

    CleanupStack::PopAndDestroy(&expr);

    RLogDbView view;

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

    if(view.FirstL())

        {

        // Begin a transaction

        TBool inTransaction = iDatabase.DTIInTransaction();

        if(!inTransaction)

            {

            iDatabase.DTIBeginWithRollBackProtectionLC();

            }

        // Get column ids

        static TDbColNo idColNo = 0;

        static TDbColNo duplicateColNo = 0;

        if(idColNo == 0)

            {

            CDbColSet* cs = view.ColSetL();

            idColNo = cs->ColNo(KLogFieldIdString);

            duplicateColNo = cs->ColNo(KLogFieldEventDuplicateString);

            delete cs;

            }

        // Iterate through the events

        do

            {

            // Get current event id

            view.GetL();

            const TLogId id = view.ColInt32(idColNo);

            // Set the latest recent?

            if(iId < 0)

                {

                iId = id;

                }

            // Make the change

            view.UpdateL();

            iId == id ? view.SetColNullL(duplicateColNo) : view.SetColL(duplicateColNo, iId); 

            view.PutL();

            // This is a "hidden" change. It may affect the contents of a view, but the actual event hasn't changed

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

            }

        while(view.NextL());

        // Commit changes

        if(!inTransaction)

            {

            iDatabase.DTICommitAndCancelRollbackProtectionL();

            }

        }

    CleanupStack::PopAndDestroy(&view);

	}

void CLogDuplicate::DoComplete(TInt& aStatus)

	{

	// Ignoring all errors because if an error occurs whilst detecting duplicate events 

	// it should not stop us actually adding the event to the log

	aStatus = KErrNone;

	}