From 6f1089db78f14b52b869f5aaa979e52ff5e4c2d7 Mon Sep 17 00:00:00 2001
From: Aleksi Lindeman <aleksi_888@hotmail.com>
Date: Thu, 1 Feb 2018 21:15:13 +0100
Subject: Sync time with ntp server, starting with basic operations

---
 include/Database.hpp | 21 ++++++++++++++++++---
 1 file changed, 18 insertions(+), 3 deletions(-)

(limited to 'include/Database.hpp')

diff --git a/include/Database.hpp b/include/Database.hpp
index 0b324e8..20d7513 100644
--- a/include/Database.hpp
+++ b/include/Database.hpp
@@ -5,13 +5,24 @@
 #include "DataView.hpp"
 #include <opendht/dhtrunner.h>
 #include <vector>
+#include <ntp/NtpClient.hpp>
 
 namespace odhtdb
 {
-    struct StagedObject
+    class Group;
+
+    struct StagedCreateObject
+    {
+        Key key;
+        Group *primaryAdminGroup;
+        u64 timestamp; // In microseconds
+    };
+
+    struct StagedAddObject
     {
         Key key;
         DataView data;
+        u64 timestamp; // In microseconds
     };
 
     class Database
@@ -20,12 +31,16 @@ namespace odhtdb
         Database(const char *bootstrapNodeAddr, u16 port);
         ~Database();
 
+        void create(const Key &key, Group *primaryAdminGroup);
         void add(const Key &key, DataView data);
         void commit();
     private:
-        void commitStagedObject(const StagedObject &stagedObject);
+        void commitStagedCreateObject(const StagedCreateObject &stagedObject);
+        void commitStagedAddObject(const StagedAddObject &stagedObject);
+        ntp::NtpTimestamp getSyncedTimestampUtc() const;
     private:
         dht::DhtRunner node;
-        std::vector<StagedObject> stagedObjects;
+        std::vector<StagedCreateObject> stagedCreateObjects;
+        std::vector<StagedAddObject> stagedAddObjects;
     };
 }
\ No newline at end of file
-- 
cgit v1.2.3