--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/predictivesearch/PcsServerClientAPI/src/CPsPropertyHandler.cpp	Wed Sep 01 12:29:52 2010 +0100
@@ -0,0 +1,150 @@
+/*
+* Copyright (c) 2007 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:  This is the client side internal file to handle
+*               property used in Publish and Subscribe framework.
+*
+*/
+
+//SYSTEM INCLUDES
+#include <CPsRequestHandler.h>
+#include <MPsResultsObserver.h>
+
+// USER INCLUDES
+#include "CPsPropertyHandler.h"
+#include "CPcsDebug.h"
+
+
+// ========================= MEMBER FUNCTIONS ==================================
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::NewL()
+// Two-phased constructor.
+// -----------------------------------------------------------------------------
+ CPsPropertyHandler* CPsPropertyHandler::NewL( CPSRequestHandler* aRequestHandler )
+{
+    PRINT ( _L("Enter CPsPropertyHandler::NewL") );
+    
+    CPsPropertyHandler* self = new ( ELeave ) CPsPropertyHandler(aRequestHandler);
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    CleanupStack::Pop( self );
+    
+    PRINT ( _L("End CPsPropertyHandler::NewL") );
+    
+    return( self ) ;
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::ConstructL()
+// Symbian 2nd phase constructor can leave.
+// -----------------------------------------------------------------------------
+void CPsPropertyHandler::ConstructL()
+{
+    PRINT ( _L("Enter CPsPropertyHandler::ConstructL") );
+    
+    TInt err = iCacheStatusProperty.Attach( KPcsInternalUidCacheStatus, EPsKeyCacheStatus );
+    User::LeaveIfError(err);
+    
+    // Attach the cache error property
+    err = iCacheErrorProperty.Attach( KPcsInternalUidCacheStatus, EPsKeyCacheError );
+    User::LeaveIfError(err);
+    
+    iCacheStatusProperty.Subscribe(iStatus);
+    
+    SetActive();
+    
+    PRINT ( _L("End CPsPropertyHandler::ConstructL") );
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::CPsPropertyHandler()
+// C++ default constructor can NOT contain any code, that might leave.
+// -----------------------------------------------------------------------------
+CPsPropertyHandler::CPsPropertyHandler( CPSRequestHandler* aRequestHandler )
+: CActive( EPriorityStandard ), 
+  iRequestHandler(aRequestHandler)
+{
+    PRINT ( _L("Enter CPsPropertyHandler::CPsPropertyHandler") );
+    
+    CActiveScheduler::Add( this );
+    
+    PRINT ( _L("End CPsPropertyHandler::CPsPropertyHandler") );
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::~CPsPropertyHandler()
+// Destructor.
+// -----------------------------------------------------------------------------
+CPsPropertyHandler::~CPsPropertyHandler()
+{
+    PRINT ( _L("Enter CPsPropertyHandler::~CPsPropertyHandler") );
+
+    Cancel(); // Causes call to DoCancel()
+    
+    iCacheStatusProperty.Close();
+    iCacheErrorProperty.Close();
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::RunL()
+// Invoked to handle responses from the server.
+// -----------------------------------------------------------------------------
+void CPsPropertyHandler::RunL()
+{
+    iCacheStatusProperty.Subscribe(iStatus);
+    SetActive();
+    
+    //Get the value
+    TCachingStatus status; 
+    TInt statusValue;
+    iCacheStatusProperty.Get(statusValue);
+    status = (TCachingStatus)statusValue;
+    
+    TInt cacheError;
+    iCacheErrorProperty.Get(cacheError);
+    
+    if ( (status == ECachingComplete) || (status == ECachingCompleteWithErrors) )
+    {
+        iRequestHandler->NotifyCachingStatus( status, cacheError );
+    }
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::DoCancel()
+// Cancels any outstanding operation.
+// -----------------------------------------------------------------------------
+void CPsPropertyHandler::DoCancel()
+{
+	iCacheStatusProperty.Cancel();
+}
+
+// -----------------------------------------------------------------------------
+// CPsPropertyHandler::GetCachingStatusL()
+// Returns the caching status fr synchronous request
+// -----------------------------------------------------------------------------
+TInt CPsPropertyHandler::GetCachingStatusL(TCachingStatus& aStatus)
+{
+	TInt status;
+	//Get the status from the property
+	iCacheStatusProperty.Get(status);
+	
+	aStatus = (TCachingStatus)status;
+	
+	TInt cacheError;
+	iCacheErrorProperty.Get(cacheError);
+	
+	return cacheError;
+}
+
+//END OF FILE