--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/activityfw/activitydatabase/hsactivitydbserver/inc/activitystorage.h	Fri May 14 16:10:06 2010 +0300
@@ -0,0 +1,196 @@
+/*
+* Copyright (c) 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:
+*
+*/
+#ifndef ACTIVITYSTORAGE_H
+#define ACTIVITYSTORAGE_H
+
+#define __E32SVR_H__
+
+#include <e32std.h>
+#include <e32base.h>
+#include <d32dbms.h>    // RDbStoreDatabase
+#include <s32file.h>    // CFileStore & CPermanentFileStore
+
+/**
+ *  CActivityStorage
+ * 
+ */
+class CActivityStorage : public CBase
+    {
+public:
+    /**
+     * Destructor.
+     */
+    ~CActivityStorage();
+
+    /**
+     * Two-phased constructor.
+     * @param session - initialized session to file system
+     */
+    static CActivityStorage* NewL(RFs& session);
+
+    /**
+     * Register new activity
+     * @param appId - application id
+     * @param actId - activity id
+     * @param data - activity data
+     */
+    void AddActivityL(TInt appId,const TDesC8& actId, const TDesC8& data);
+
+    /**
+     * Update activity
+     * @param appId - application id
+     * @param actId - activity id
+     * @param data - activity data
+     */
+    void UpdateActivityL(TInt appId,const TDesC8& actId, const TDesC8& data);
+
+    /**
+     * Delete activity
+     * @param appId - application id
+     * @param actId - activity id
+     */
+    void DeleteActivityL(TInt appId,const TDesC8& actId);
+
+    /**
+     * Delete activity
+     * @param appId - application id
+     */
+    void DeleteActivitiesL(TInt appId);
+
+    /**
+     * Serialize all activity into the buffer
+     * @param dst - destination buffer
+     */
+    void ActivitiesL(RBuf8 &dst);
+
+    /**
+     * Serialize application activity into the buffer
+     * @param dst - destination buffer
+     * @param appId - application id
+     */
+    void ActivitiesL(RBuf8 &dst, TInt appId);
+
+private:
+    /**
+     * Constructor for performing 1st stage construction
+     * @param session - initialized session to file system
+     */
+    CActivityStorage(RFs& session);
+
+    /**
+     * EPOC default constructor for performing 2nd stage construction
+     */
+    void ConstructL();
+
+    /**
+     * Create database and its structure
+     * @param databaseFile - database file path
+     */
+    void CreateDbL(const TDesC& databaseFile);
+
+    /**
+     * Open database
+     * @param databaseFile - database file path
+     */
+    void OpenDbL(const TDesC& databaseFile);
+
+    /**
+     * Create database structure
+     */
+    void CreateTableL();
+
+    /**
+     * Serialize activity into buffer
+     * @param dst - destination buffer
+     */
+    void GetActivitiesL(const TDesC& dst);
+
+    /**
+     * Format query to select activity row
+     * @param appId - application id
+     * @param actId - activity id
+     * @return formated sql query
+     */
+    HBufC* SelectRowLC(TInt appId, const TDesC8& actId) const;
+    
+    /**
+     * Format query to select activities for application
+     * @param appId - application id
+     * @return formated sql query
+     */
+    HBufC* SelectRowsLC(TInt appId) const;
+
+    /**
+     * Format query to delete activity
+     * @param appId - application id
+     * @param actId - activity id
+     * @return formated sql query
+     */
+    HBufC* DeleteRowLC(TInt appId, const TDesC8& actId) const;
+    
+    /**
+     * Format query to delete activities for application
+     * @param appId - application id
+     * @return formated sql query
+     */
+    HBufC* DeleteRowsLC(TInt appId) const;
+
+    /**
+     * Format sql query
+     * @format - sql format string
+     * @param appId - application id
+     * @param actId - activity id
+     * @return formated sql query
+     */
+    HBufC* BuildQueryLC(const TDesC& format, TInt appId, const TDesC8& actId) const;
+
+    /**
+     * Count require buffer size to serialize activity query result
+     * @param data - sql query result
+     * @return reuired buffer size to seriazlie activity
+     */
+    TInt DataSizeL(RDbRowSet& data)const;
+
+    /**
+     * Serialize activity query result to preallocated buffer
+     * @param dst - preallocated buffer
+     * @param view - sql query result
+     */
+    void ExternalizeL(TDes8& dst, RDbRowSet& view)const;
+
+    /**
+     * Execute sql query and result serialize into buffer
+     * @param dst - destination result buffer
+     * @param query - sql activity query 
+     */
+    void ActivitiesL(RBuf8& dst, const TDesC& query);
+
+    /**
+     * Get activity for update
+     * @param query - destination query result
+     * @param appId - application id
+     * @param actId - activity id
+     */
+    void GetActivityForUpdateL(RDbView& query, TInt appId, const TDesC8& actId);
+
+private:
+    RFs& mFsSession;
+    RDbStoreDatabase mActDb;/* For database operations                 */
+    CFileStore* mFileStore;  /* For creating and opening database files */
+};
+
+#endif // ACTIVITYSTORAGE_H