diff -r 000000000000 -r 2e3d3ce01487 tzservices/tzserver/swiobserverplugin/source/tzswiobserverplugin.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/tzservices/tzserver/swiobserverplugin/source/tzswiobserverplugin.cpp	Tue Feb 02 10:12:00 2010 +0200
@@ -0,0 +1,239 @@
+// Copyright (c) 2008-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 "tzswiobserverplugin.h"
+
+using namespace Swi;
+
+_LIT(KFilterTzPrivate,  "!:\\private\\1020383E");
+_LIT(KFilterResourceTimezonelocalization,  "!:\\resource\\timezonelocalization");
+
+#ifdef _DEBUG
+//Logging data
+_LIT(KTzDebugLogFile, "c:\\TzSwiObserver.log");
+_LIT(KTzLogDir, "c:\\logs\\Tz");
+_LIT(KTzLogFile, "c:\\logs\\Tz\\TzSwiObserver.log");
+_LIT8(KTzCRLF, "\r\n");
+_LIT8(KTzAdded, "Added ");
+_LIT8(KTzDeleted, "Deleted ");
+#endif
+
+CTzSwiObserverPlugin* CTzSwiObserverPlugin::NewL()
+	{
+	CTzSwiObserverPlugin* self = new(ELeave) CTzSwiObserverPlugin();
+	return self;
+	}
+
+CTzSwiObserverPlugin::~CTzSwiObserverPlugin()
+	{
+	//Should close the RTz
+	iTz.Close();
+#if defined(_DEBUG)
+	delete iFileWriteStream;
+#endif
+	}
+
+CTzSwiObserverPlugin::CTzSwiObserverPlugin()
+	: CSwiObserverPlugin(), iTzConnected(EFalse)
+	{
+	}
+
+/**
+This function is called when the SWI Observer processor starts processing
+an observation log file.
+
+@param aFs File server session handle.
+*/
+void CTzSwiObserverPlugin::StartL(RFs& aFs)
+	{
+	iFs = &aFs;
+	
+#if defined(_DEBUG)
+	TUint fileAtt;
+	if (aFs.Att(KTzLogDir, fileAtt) == KErrNone)
+		{
+		iFileWriteStream = new(ELeave) RFileWriteStream;
+		if (iFileWriteStream)
+			{
+			if (iFileWriteStream->Replace(aFs, KTzDebugLogFile, EFileShareAny | EFileWrite | EFileStreamText ) != KErrNone)
+				{
+				delete iFileWriteStream;
+				iFileWriteStream = NULL;
+				}
+			}
+		}
+	
+#endif
+	}
+ 	
+/**
+Signals TZ Server that a new installation log is about to be processed.
+	
+@param aHeader Object containing all observation data related with a specific package.
+@param aStatus The request status object.
+ */ 		
+void CTzSwiObserverPlugin::NextObservedHeaderL(const CObservationHeader& /*aHeader*/, TRequestStatus& aStatus)
+	{
+	TRequestStatus* status = &aStatus;
+	User::RequestComplete(status, KErrNone);
+	}
+ 
+/**
+This function is called for each actual observation data (i.e. adding/deleting file).
+	
+@param aData   		Object for a single observation data.
+@param aFilterIndex The index of the filter which matches with that notification.
+@param aStatus 		The request status object.
+ */
+#if defined(_DEBUG)
+void CTzSwiObserverPlugin::NextObservedDataL(const CObservationData& aData, TInt aFilterIndex, TRequestStatus& aStatus)
+#else
+void CTzSwiObserverPlugin::NextObservedDataL(const CObservationData& /*aData*/, TInt aFilterIndex, TRequestStatus& aStatus)
+#endif
+	{
+	RTz::TSWIObserverFilterIndex idx = static_cast<RTz::TSWIObserverFilterIndex>(aFilterIndex);
+	
+	switch(idx)
+		{
+		case RTz::EFilterTzPrivate:
+		case RTz::EFilterResourceTimezonelocalization:
+			{
+			GetTzClientL().SwiObsFileChangedL(idx);
+			}
+			
+			break;
+		default:
+			// Do nothing
+			break;
+		}
+	
+#if defined(_DEBUG)
+	if (iFileWriteStream)
+		{
+		if (aData.iFileFlag & Swi::EFileAdded)
+			{
+			iFileWriteStream->WriteL(KTzAdded());
+			}
+		else if (aData.iFileFlag & Swi::EFileDeleted)
+			{
+			iFileWriteStream->WriteL(KTzDeleted());
+			}
+		TBuf8<256> fileBuf;
+		fileBuf.Copy(aData.iFileName->Des());
+		iFileWriteStream->WriteL(fileBuf);
+		iFileWriteStream->WriteL(KTzCRLF());
+		}
+#endif
+	
+	TRequestStatus* status = &aStatus;
+	User::RequestComplete(status, KErrNone);
+	}
+	
+/**
+This function is called when the SWI Observer processor is finished with
+the observation log file.
+	
+@param aStatus The request status object.
+ */	
+void CTzSwiObserverPlugin::FinalizeL(TRequestStatus& aStatus)
+ 	{
+ 	GetTzClientL().SwiObsEndL();
+ 	
+#if defined(_DEBUG)
+ 	if (iFileWriteStream)
+ 		{
+ 		iFileWriteStream->Close();
+ 		User::LeaveIfError(iFs->Rename(KTzDebugLogFile, KTzLogFile));
+ 		}
+#endif
+ 		
+ 	TRequestStatus* status = &aStatus;
+	User::RequestComplete(status, KErrNone);
+  	}
+ 
+/**
+Returns a list of filters which representing in what folders the tz observer
+plugin is interested. 
+
+The tz observer plugin needs to know any change in the \private\1020383E and \resource\timezonelocalization
+directories of the system drive. 
+
+@return A list of filters showing the interest of this plugin.
+ */ 
+CObservationFilter* CTzSwiObserverPlugin::GetFilterL() const
+ 	{
+ 	CObservationFilter* filterList = CObservationFilter::NewLC();
+ 	AddFilterL(*filterList, KFilterTzPrivate);
+ 	AddFilterL(*filterList, KFilterResourceTimezonelocalization);
+ 	CleanupStack::Pop(filterList);
+ 	return filterList;
+ 	}
+
+/**
+	Inserts a new filter into the filter list.
+	Sets the first character of the new filter as the current system drive.
+	
+	@param aFilterList A filter list object.
+	@param aFilter	   A filter data which will be inserted.
+ */
+void CTzSwiObserverPlugin::AddFilterL(CObservationFilter& aFilterList, const TDesC& aFilter) const
+	{
+	HBufC* filterData = aFilter.AllocLC();
+	TPtr ptr(filterData->Des());
+	ptr[0] = iFs->GetSystemDriveChar();
+	aFilterList.AddFilterL(filterData);
+	CleanupStack::Pop(filterData);
+	}
+	
+void CTzSwiObserverPlugin::RunL()
+	{
+	// Do Nothing
+	}
+		
+TInt CTzSwiObserverPlugin::RunError(TInt /*aError*/)
+	{
+	return KErrNone;
+	}
+
+void CTzSwiObserverPlugin::DoCancel()
+	{
+	}
+
+static const TUint KTzSwiObserverImplementationId = 0x1028649F;
+
+static const TImplementationProxy ImplementationTable[] = 
+	{
+	IMPLEMENTATION_PROXY_ENTRY(KTzSwiObserverImplementationId, CTzSwiObserverPlugin::NewL)
+	};
+
+RTz& CTzSwiObserverPlugin::GetTzClientL()
+	{
+	if (!iTzConnected)
+		{
+		User::LeaveIfError(iTz.Connect());
+		iTzConnected = ETrue;
+		iTz.SwiObsBeginL();
+		}
+	return iTz;
+	}
+
+/**
+Standard ECOM factory
+*/	
+EXPORT_C const TImplementationProxy* ImplementationGroupProxy(TInt& aTableCount)
+	{
+	aTableCount = sizeof(ImplementationTable) / sizeof(TImplementationProxy);
+	return ImplementationTable;
+	}