--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/presencefwsimpleadpt/inc/simplepluginpublisher.h	Tue Feb 02 01:05:17 2010 +0200
@@ -0,0 +1,450 @@
+/*
+* Copyright (c) 2006 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:    Simple Protocol implementation for Presence Framework
+*
+*/
+
+
+
+
+#ifndef CSIMPLEPLUGINPUBLISHER_H
+#define CSIMPLEPLUGINPUBLISHER_H
+
+#include <e32std.h>
+
+#include <ximpbase.h>
+#include <protocolpresencepublishing.h>
+
+#include <msimplepublishobserver.h>
+#include <msimplewatcherobserver.h>
+
+#include "simpleplugincommon.h"
+#include "msimplepluginconnectionobs.h"
+#include "msimplepluginsettings.h"
+
+class TXIMPRequestId;
+class MXIMPIdentity;
+class MXIMPProtocolConnectionHost;
+
+class MPersonPresenceInfo;
+class MServicePresenceInfo;
+class MDevicePresenceInfo;
+
+class MSimplePublisher;
+class MSimpleDocument;
+class MSimpleWinfo;
+class MSimpleWatcher;
+class MSimpleElement;
+
+
+/**
+ * CSimplePluginWatcherInfo
+ *
+ * watcher info.
+ *
+ * @lib ?library
+ * @since s60 v5.0
+ */
+NONSHARABLE_CLASS( CSimplePluginWatcherInfo ): public CBase
+    {
+public:
+
+    /**
+     * Constructor.
+     * @param aId watcher id
+     * @param aSipId watcher SIP identity
+     */
+    static CSimplePluginWatcherInfo* NewL(
+        const TDesC8& aId,
+        const TDesC& aSipId );
+
+    virtual ~CSimplePluginWatcherInfo();
+            
+    /**
+     * Destructor
+     */
+    void Destroy();
+    
+    /** 
+     * Match to given info
+     * @param aId watcher id
+     * @param aSipId watcher SIP identity     
+     * @return ETrue if current entity matches to the parameters
+     */
+    TBool Match( const TDesC8& aId,
+        const TDesC& aSipId ); 
+        
+    TPtrC SipId();    
+    
+    inline static TInt LinkOffset(); 
+    
+private:
+
+    CSimplePluginWatcherInfo( );
+
+    /** 
+     * Constructor
+     * @param aId watcher id
+     * @param aSipId watcher SIP identity     
+     */
+    void ConstructL( 
+        const TDesC8& aId,
+        const TDesC& aSipId ); 
+   
+public: // data        
+
+    TDblQueLink iLink;
+    
+private: // data
+    
+    HBufC8* iId;
+    HBufC* iSipId;
+
+    };
+
+/**
+ * CSimplePluginPublisher
+ *
+ * publisher.
+ *
+ * @lib ?library
+ * @since s60 v5.0
+ */
+NONSHARABLE_CLASS( CSimplePluginPublisher ): public CActive,
+    public MSimplePublishObserver,
+    public MSimpleWatcherObserver,
+    public MProtocolPresencePublishing
+    {
+public:
+
+    /**
+     * Current operation
+     */
+    enum TPluginPublishOperation
+        {
+        ENoOperation,
+        EPublishOwn,
+        ESubscribeOwn,
+        EUnsubscribeOwn,
+        ESubscribeWinfo,
+        EUnsubscribeWinfo
+        };
+
+    /**
+     * Constructor.
+     * @param aConnSetts current settings
+     * @param aObs callback for complete requests
+     * @param aConn Simple Engine connection
+     */
+    static CSimplePluginPublisher* NewL(
+        MSimplePluginSettings& aConnSetts,
+        MSimplePluginConnectionObs& aObs,
+        MSimpleConnection& aConn );
+
+    virtual ~CSimplePluginPublisher();
+
+    /**
+     * WinfoTerminatedL
+     *
+     * SIMPLE Winfo watcher sunscription is terminated
+     * @param aReason reason code
+     */
+     void WinfoTerminatedL( TInt aReason );
+
+     /**
+      * WINFO received from SIMPLE
+      * @param aWinfo WINFO
+      */
+     void WinfoNotificationL( MSimpleWinfo& aWinfo );
+
+private:
+
+    CSimplePluginPublisher(
+        MSimplePluginSettings& aConnSetts,    
+        MSimplePluginConnectionObs& aObs,
+        MSimpleConnection& aConn );
+
+    void ConstructL( );
+
+
+public:
+
+// from base class MSimplePublishObserver
+
+    /**
+     * Defined in a base class
+     */
+    void PublishReqCompleteL( TInt aOpid, TInt aStatus);
+
+    /**
+     * Defined in a base class
+     */
+    void PublishTerminatedL( TInt aOpid );
+
+// from base class MSimpleWatcherObserver
+
+    /**
+     * Defined in a base class
+     */
+    void WatcherReqCompleteL( TInt aOpId, TInt aStatus );
+
+    /**
+     * Defined in a base class
+     */
+    void WatcherNotificationL( MSimpleDocument& aDocument );
+
+    /**
+     * Defined in a base class
+     */
+    void WatcherListNotificationL( MSimplePresenceList& aList );
+
+    /**
+     * Defined in a base class
+     */
+    void WatcherTerminatedL(
+        TInt aOpId, TInt aReason );
+
+
+// from base class MXIMPBase
+public:
+
+    /**
+     * Defined in a base class
+     */
+    TAny* GetInterface(
+        TInt32 aInterfaceId,
+        TIfGetOps aOps );
+
+    /**
+     * Defined in a base class
+     */
+    const TAny* GetInterface(
+        TInt32 aInterfaceId,
+        TIfGetOps aOps ) const;
+
+    /**
+     * Defined in a base class
+     */
+    TInt32 GetInterfaceId() const;
+
+
+// from base class MProtocolPresencePublishing
+public:
+
+    /**
+     * Defined in a base class
+     */
+    void DoPublishOwnPresenceL(
+        const MPresenceInfo& aOwnPresence,
+        TXIMPRequestId aReqId );
+
+    /**
+     * Defined in a base class
+     */
+    void DoSubscribeOwnPresenceL(
+        const MPresenceInfoFilter& aPif,
+        TXIMPRequestId aReqId );
+
+    /**
+     * Defined in a base class
+     */
+    void DoUpdateOwnPresenceSubscriptionPifL(
+        const MPresenceInfoFilter& aPif,
+        TXIMPRequestId aReqId );
+
+    /**
+     * Defined in a base class
+     */
+    void DoUnsubscribeOwnPresenceL(
+        TXIMPRequestId aReqId );
+
+    /**
+     * Defined in a base class
+     */
+    void DoSubscribePresenceWatcherListL(
+        TXIMPRequestId aReqId );
+
+    /**
+     * Defined in a base class
+     */
+    void DoUnsubscribePresenceWatcherListL(
+        TXIMPRequestId aReqId );
+
+
+protected:
+
+// from base class CActive
+
+    /**
+     * Defined in a base class
+     */
+    void RunL();
+
+    /**
+     * Defined in a base class
+     */
+    TInt RunError( TInt aError );
+
+    /**
+     * Defined in a base class
+     */
+    void DoCancel();
+
+private:
+
+
+    /**
+     * Calls MXIMPProtocolConnectionHost callback
+     * @param aStatus error status
+     */
+    void CompletePrFwReq( TInt aStatus );
+
+    /**
+     * Initialize a document
+     */
+    void InitializeSimpleDocumentL( );
+
+    /**
+     * Add person information to the document.
+     * @param aPersInfo personal information
+     */
+    void AddSimpleDocumentPersL(
+        const MPersonPresenceInfo* aInfo );
+
+    void AddSimpleDocumentServiceL(
+        const MServicePresenceInfo& aInfo );
+
+    void AddSimpleDocumentDeviceL(
+        const MDevicePresenceInfo& aInfo );
+
+    /**
+     * Make a publish request
+     */
+    void MakePublishReqL();
+
+    /**
+     * Start XDM initialization
+     */
+    void StartXdmOperationL( TXIMPRequestId aReqId );
+    
+    /**
+     * Start XDM initialization. StartXdmOperationL calls this.
+     */
+    void DoStartXdmOperationL( TXIMPRequestId aReqId );    
+    
+    /**
+     * Delete watcher information
+     */
+    void DeleteWatchers();  
+    
+    void AddWatcherIfNotExistsL( const TDesC8& aId, const TDesC& aSipId );
+        
+    void RemoveWatcherIfExistsL( const TDesC8& aId, const TDesC& aSipId ); 
+    
+    CDesCArrayFlat* MakeCurrentWatcherListLC();  
+    
+    
+    /**
+     * Update private data member of active watchers list
+     * @param aElems SIMPLE elements [IN]
+     */
+    void UpdateActiveWatchersListL( 
+        RPointerArray<MSimpleElement>& aElems );     
+
+
+private: // Data
+
+    /**
+     * PrFw Plugin connection observer
+     */
+    MSimplePluginConnectionObs& iConnObs;
+    
+    /**
+     * Current settings
+     */
+    MSimplePluginSettings& iConnSets;
+
+    /**
+     * SIMPLE engine connection
+     */
+    MSimpleConnection& iConnection;
+
+    /**
+     * SIMPLE engine publisher
+     * Own.
+     */
+    MSimplePublisher* iPublisher;
+
+    /**
+     * SIMPLE engine watcher
+     * Own.
+     */
+    MSimpleWatcher* iWatcher;
+
+    /**
+     * PrFW request id
+     */
+    TXIMPRequestId iPrFwId;
+
+    /**
+     * Simple Engine request id
+     */
+    TInt iSimpleId;
+
+    /**
+     * Subscribed winfo
+     */
+    TBool iSubscribed;
+
+    /**
+     * Subscribed own data
+     */
+    TBool iSubscribedOwn;
+
+    /**
+     * Published own data
+     */
+    TBool iPublished;
+
+    /**
+     * Current operation
+     */
+    TPluginPublishOperation iOperation;
+
+    /**
+     * Simple publish document
+     * Own.
+     */
+    MSimpleDocument* iDocument;
+
+    /**
+     * XDM Utils
+     * Not own.
+     */
+    CSimplePluginXdmUtils* iXdmUtils;
+    
+    /**
+     * WINFO watchers
+     * Own.
+     */
+    TDblQue<CSimplePluginWatcherInfo> iWatcherList;
+
+    };
+    
+    TInt CSimplePluginWatcherInfo::LinkOffset()
+        {
+        return _FOFF(CSimplePluginWatcherInfo, iLink);
+        }     
+
+#endif // CSimplePluginPublisher_H