From 1815c078a9bb4c016b354429f7618da664344236 Mon Sep 17 00:00:00 2001
From: drebs <drebs@leap.se>
Date: Wed, 5 Dec 2012 17:04:46 -0200
Subject: OpenStack backend initialization.

---
 src/leap/soledad/openstack.py | 27 +++++++++++++++++++++++----
 1 file changed, 23 insertions(+), 4 deletions(-)

(limited to 'src')

diff --git a/src/leap/soledad/openstack.py b/src/leap/soledad/openstack.py
index af04465d..07ed071d 100644
--- a/src/leap/soledad/openstack.py
+++ b/src/leap/soledad/openstack.py
@@ -18,6 +18,7 @@ class OpenStackDatabase(CommonBackend):
         self._connection = swiftclient.Connection(self._auth_url, self._user,
                                                   self._auth_key)
         self._get_auth()
+        self._ensure_u1db_data()
 
     #-------------------------------------------------------------------------
     # implemented methods from Database
@@ -185,11 +186,29 @@ class OpenStackDatabase(CommonBackend):
     # OpenStack specific methods
     #-------------------------------------------------------------------------
 
-    def _is_initialized(self, c):
-        raise NotImplementedError(self._is_initialized)
+    def _ensure_u1db_data(self):
+        """
+        Guarantee that u1db data exists in store.
+        """
+        if self._is_initialized():
+            return
+        self._initialize()
 
-    def _initialize(self, c):
-        raise NotImplementedError(self._initialize)
+    def _is_initialized(self):
+        """
+        Verify if u1db data exists in store.
+        """
+        if not self._get_doc('u1db_data'):
+            return False
+        return True
+
+    def _initialize(self):
+        """
+        Create u1db data object in store.
+        """
+        content = { 'transaction_log' = [],
+                    'sync_log' = [] }
+        doc = self.create_doc('u1db_data', content)
 
     def _get_auth(self):
         self._url, self._auth_token = self._connection.get_auth()
-- 
cgit v1.2.3