--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/locationdataharvester/mylocationsengine/src/contactsubscriber.cpp Wed Jun 23 18:07:15 2010 +0300
@@ -0,0 +1,156 @@
+/*
+ * Copyright (c) 2010 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: Subscribe source implementation for getting contact status
+ * notification from publisher.
+ *
+ */
+#include "contactsubscriber.h"
+#include "mylocationlogger.h"
+#include <locationservicedefines.h>
+
+const TUid KContactPropertyCat={0x20022EF9};
+enum TMyPropertyKeys {EMyPropertyInteger=0x1, EMyPropertyType=0x2};
+const TInt KBufferSize=16;
+
+// -----------------------------------------------------------------------------
+// CContactSubscriber::NewL()
+// -----------------------------------------------------------------------------
+//
+CContactSubscriber* CContactSubscriber::NewL(MNotifyChange* aNotifyChange)
+{
+ CContactSubscriber* self = CContactSubscriber::NewLC(aNotifyChange);
+ CleanupStack::Pop(self);
+ return self;
+}
+
+// -----------------------------------------------------------------------------
+// CContactSubscriber::NewLC()
+// -----------------------------------------------------------------------------
+//
+CContactSubscriber* CContactSubscriber::NewLC(
+ MNotifyChange* aNotifyChange)
+{
+ CContactSubscriber* self = new (ELeave) CContactSubscriber(
+ aNotifyChange);
+ CleanupStack::PushL(self);
+ self->ConstructL();
+ return self;
+}
+
+// -----------------------------------------------------------------------------
+// CContactSubscriber::ConstructL()
+// Symbian 2nd phase constructor can leave.
+// -----------------------------------------------------------------------------
+//
+void CContactSubscriber::ConstructL()
+{
+ __TRACE_CALLSTACK;
+ CActiveScheduler::Add(this);
+ TInt ret = iProperty.Attach(KContactPropertyCat, EMyPropertyInteger);
+ if (KErrNone == ret)
+ {
+ SubscribeChangeNotiFication();
+ }
+}
+
+
+// -----------------------------------------------------------------------------
+// CContactSubscriber::SubscribeChangeNotiFication()
+// start subscribe for contact entry
+// -----------------------------------------------------------------------------
+//
+void CContactSubscriber::SubscribeChangeNotiFication()
+{
+ __TRACE_CALLSTACK;
+ if (IsActive())
+ {
+ Cancel();
+ }
+ // resubscribe before processing new value to prevent missing updates
+ iProperty.Subscribe(iStatus);
+ SetActive();
+}
+
+// -----------------------------------------------------------------------------
+// CContactSubscriber::CContactSubscriber()
+// Default constructor .
+// -----------------------------------------------------------------------------
+//
+CContactSubscriber::CContactSubscriber(MNotifyChange* aNotifyChange) :
+ CActive(EPriorityStandard),
+ iNotifyChange(*aNotifyChange)
+
+{
+}
+// -----------------------------------------------------------------------------
+// CContactSubscriber::~CContactSubscriber()
+// default destuctor.
+// -----------------------------------------------------------------------------
+//
+CContactSubscriber::~CContactSubscriber()
+{
+ __TRACE_CALLSTACK;
+ Cancel();
+ iProperty.Close();
+
+}
+// -----------------------------------------------------------------------------
+// CContactSubscriber::RunL()
+// Assyncronous request handler , on completion of notification
+// -----------------------------------------------------------------------------
+//
+void CContactSubscriber::RunL()
+{
+ __TRACE_CALLSTACK;
+ SubscribeChangeNotiFication();
+ // property updated, get new value
+ TBuf8 <KBufferSize> value;
+ TPtrC8 id;
+ TPtrC8 sourceType;
+ TPtrC8 addressCount;
+
+ if ( KErrNone == iProperty.Get( value ) )
+ {
+ TInt pos = value.Locate(TChar('-'));
+ id.Set( value.Left(pos) );
+
+ TPtrC8 ptr = value.Right(3);
+ sourceType.Set(ptr.Left(1));
+ addressCount.Set(ptr.Right(1));
+
+ TInt appId = -1, addressType = -1, addressTypeCount = -1;
+ TLex8 lex(id);
+ lex.Val(appId);
+
+ TLex8 lex1(sourceType);
+ lex1.Val( addressType );
+
+ TLex8 lex2(addressCount);
+ lex2.Val(addressTypeCount);
+
+ iNotifyChange.GetChangeNotificationL( appId, addressType,addressTypeCount );
+ }
+}
+// -----------------------------------------------------------------------------
+// CContactSubscriber::DoCancel()
+// Handels the error condition on assynchronous request
+// -----------------------------------------------------------------------------
+//
+void CContactSubscriber::DoCancel()
+{
+ iProperty.Cancel();
+}
+
+//End of file
+