summaryrefslogtreecommitdiff
path: root/openstack.py
diff options
context:
space:
mode:
authordrebs <drebs@leap.se>2012-12-05 17:04:46 -0200
committerdrebs <drebs@leap.se>2012-12-05 17:04:46 -0200
commit29390a6317f172a75346ce3a25a03bc915e1a502 (patch)
treecef6ead0a43181f04c0968afa0c318ceff3661e9 /openstack.py
parentc596c469502004432783a210938c8c8ce5ae75a8 (diff)
OpenStack backend initialization.
Diffstat (limited to 'openstack.py')
-rw-r--r--openstack.py27
1 files changed, 23 insertions, 4 deletions
diff --git a/openstack.py b/openstack.py
index af04465d..07ed071d 100644
--- a/openstack.py
+++ b/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()