/*
* Copyright (c) 2004-2009 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of the License "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 "daemon.h"
#include "drivewatcher.h"
#include "log.h"
#include "securitypolicy.h"

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
#include <e32property.h>
#include <connect/sbdefs.h>
#include <usif/sts/sts.h>
#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS
#include "stsrecovery.h"
#endif //SYMBIAN_ENABLE_SPLIT_HEADERS
#include "swiobserverclient.h"
#else
#include "sisregistrysession.h"
#endif


namespace Swi
{
// CDaemon

/*static*/ CDaemon* CDaemon::NewL(MDaemonBehaviour& aBehaviour)
	{
	CDaemon* self=NewLC(aBehaviour);
	CleanupStack::Pop(self);
	return self;
	}

/*static*/ CDaemon* CDaemon::NewLC(MDaemonBehaviour& aBehaviour)
	{
	CDaemon* self=new(ELeave) CDaemon(aBehaviour);
	CleanupStack::PushL(self);
	self->ConstructL();
	return self;
	}
	
CDaemon::~CDaemon()
	{
	iPolicyLockFile.Close();
	iWatchers.ResetAndDestroy();
	iFs.Close();
	}

CDaemon::CDaemon(MDaemonBehaviour& aBehaviour)
	: iBehaviour(aBehaviour)
	{
	}

void CDaemon::ConstructL()
	{
	User::LeaveIfError(iFs.Connect());
	LockSensitiveFiles();
	StartRecoveryL();
	iBehaviour.StartupL();
	StartWatchersL();
	}

void CDaemon::StartWatchersL()
	{
	RFs fs;
	User::LeaveIfError(fs.Connect());
	CleanupClosePushL(fs);
	
	User::LeaveIfError(fs.ShareProtected());
	
	TDriveList driveList;
	
	User::LeaveIfError(fs.DriveList(driveList));

	for (TInt drive=0; drive < KMaxDrives; ++drive)
		{
		if (driveList[drive] == 0)
			{
			continue;
			}
		TDriveInfo info;
		
		// Ignore errors since the next drive might work
		if (KErrNone != fs.Drive(info, drive))
			{
			DEBUG_PRINTF2(_L8("SWI Daemon - Not watching drive '%d', could not retrieve drive info."),
				drive); 
			continue;
			}

		if (info.iDriveAtt & KDriveAttRemovable)
			{
			DEBUG_PRINTF2(_L8("SWI Daemon - Watching removable drive '%d'"), drive);
			CDriveWatcher* driveWatcher=CDriveWatcher::NewLC(iFs, drive, iBehaviour);
			User::LeaveIfError(iWatchers.Append(driveWatcher));
			CleanupStack::Pop(driveWatcher);
			}
		}
	CleanupStack::PopAndDestroy(&fs);
	} // StartWatchersL()

void CDaemon::LockSensitiveFiles()
	{
	TInt error = iPolicyLockFile.Open(iFs, KSwisPolicyFile, EFileShareReadersOnly | EFileRead);
	if (error != KErrNone)
		{
		DEBUG_PRINTF2(_L8("SWI Daemon - Could not open SWI policy file with error %d!"), error);
		}	
	}

#ifdef SYMBIAN_UNIVERSAL_INSTALL_FRAMEWORK
void CDaemon::StartRecoveryL()
	{
	DEBUG_PRINTF(_L("CDaemon::StartRecoveryL()"));

	// Check to see if a backup is in progress...
	TInt backup = 0;
	User::LeaveIfError(RProperty::Get(KUidSystemCategory,conn::KUidBackupRestoreKey,backup));
	
	if(backup == conn::EBURUnset || (backup == (conn::EBURNormal | conn::ENoBackup))) //no backup or restore is in progress
		{
		//no recovery attempt is made during backup/restore as recovery may seriously affect the file system, which might impact backup/restore
		//recovery will be made at next bootup
		Usif::RStsRecoverySession stsRecoverySession;
		// A recovery failure should not affect Daemon start up.
		TRAPD(err, stsRecoverySession.RollbackAllPendingL());
		if(err != KErrNone)
			{
			DEBUG_PRINTF2(_L("CDaemon::StartRecoveryL() - STS server failed to recover transactions. Error code: %d"), err);
			}
		//Start SWI Observer so that it can process the log files left from the previous session.
		RSwiObserverSession swiObserver;
		swiObserver.ProcessLogsL(iFs); 
		swiObserver.Close();
		}
	}
#else
void CDaemon::StartRecoveryL()
	{
	DEBUG_PRINTF(_L8("SWI Daemon - Check to see if a recovery is needed"));
	RSisRegistrySession registrySession;
	User::LeaveIfError(registrySession.Connect());
	CleanupClosePushL(registrySession);
	
	// A recovery failure should not affect SWI Daemon start up.
	TRAP_IGNORE(registrySession.RecoverL());
	
	CleanupStack::PopAndDestroy(&registrySession);
	DEBUG_PRINTF(_L8("SWI Daemon - Recovery check finished"));
	}
#endif

} // namespace Swi