summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authordrebs <drebs@leap.se>2012-11-28 20:05:27 -0200
committerdrebs <drebs@leap.se>2012-11-28 20:05:27 -0200
commitea2f5e31c5754b71b2cb5aea9d9b36f4d2b2ac31 (patch)
treef7e064dfa81f7b9379372614255ce9b30fccbe71
parent564b82fa30ebcd8a0abfea54e00506dd77446a54 (diff)
add u1db openstack backend base files
-rw-r--r--src/leap/soledad/README6
-rw-r--r--src/leap/soledad/__init__.py164
2 files changed, 170 insertions, 0 deletions
diff --git a/src/leap/soledad/README b/src/leap/soledad/README
new file mode 100644
index 00000000..91263d50
--- /dev/null
+++ b/src/leap/soledad/README
@@ -0,0 +1,6 @@
+Soledad -- Synchronization Of Locally Encrypted Data Among Devices
+==================================================================
+
+This code is based on:
+
+* u1db 0.14
diff --git a/src/leap/soledad/__init__.py b/src/leap/soledad/__init__.py
new file mode 100644
index 00000000..b4284c84
--- /dev/null
+++ b/src/leap/soledad/__init__.py
@@ -0,0 +1,164 @@
+# License?
+
+"""A U1DB implementation that uses OpenStack Swift as its persistence layer."""
+
+import errno
+import os
+try:
+ import simplejson as json
+except ImportError:
+ import json # noqa
+import sys
+import time
+import uuid
+
+from u1db.backends import CommonBackend, CommonSyncTarget
+from u1db import (
+ Document,
+ errors,
+ query_parser,
+ vectorclock,
+ )
+
+
+class OpenStackDatabase(CommonBackend):
+ """A U1DB implementation that uses OpenStack as its persistence layer."""
+
+ def __init__(self, sqlite_file, document_factory=None):
+ """Create a new OpenStack data container."""
+ raise NotImplementedError(self.__init__)
+
+ def set_document_factory(self, factory):
+ self._factory = factory
+
+ def get_sync_target(self):
+ return OpenStackSyncTarget(self)
+
+ @classmethod
+ def open_database(cls, sqlite_file, create, backend_cls=None,
+ document_factory=None):
+ raise NotImplementedError(open_database)
+
+ @staticmethod
+ def delete_database(sqlite_file):
+ raise NotImplementedError(delete_database)
+
+
+ def close(self):
+ raise NotImplementedError(self.close)
+
+ def _is_initialized(self, c):
+ raise NotImplementedError(self._is_initialized)
+
+ def _initialize(self, c):
+ raise NotImplementedError(self._initialize)
+
+ def _ensure_schema(self):
+ raise NotImplementedError(self._ensure_schema)
+
+ def _set_replica_uid(self, replica_uid):
+ """Force the replica_uid to be set."""
+ raise NotImplementedError(self._set_replica_uid)
+
+ def _set_replica_uid_in_transaction(self, replica_uid):
+ """Set the replica_uid. A transaction should already be held."""
+ raise NotImplementedError(self._set_replica_uid_in_transaction)
+
+ def _get_replica_uid(self):
+ raise NotImplementedError(self._get_replica_uid)
+
+ _replica_uid = property(_get_replica_uid)
+
+ def _get_generation(self):
+ raise NotImplementedError(self._get_generation)
+
+ def _get_generation_info(self):
+ raise NotImplementedError(self._get_generation_info)
+
+ def _get_trans_id_for_gen(self, generation):
+ raise NotImplementedError(self._get_trans_id_for_gen)
+
+ def _get_transaction_log(self):
+ raise NotImplementedError(self._get_transaction_log)
+
+ def _get_doc(self, doc_id, check_for_conflicts=False):
+ """Get just the document content, without fancy handling."""
+ raise NotImplementedError(self._get_doc)
+
+ def _has_conflicts(self, doc_id):
+ raise NotImplementedError(self._has_conflicts)
+
+ def get_doc(self, doc_id, include_deleted=False):
+ raise NotImplementedError(self.get_doc)
+
+ def get_all_docs(self, include_deleted=False):
+ """Get all documents from the database."""
+ raise NotImplementedError(self.get_all_docs)
+
+ def put_doc(self, doc):
+ raise NotImplementedError(self.put_doc)
+
+ def whats_changed(self, old_generation=0):
+ raise NotImplementedError(self.whats_changed)
+
+ def delete_doc(self, doc):
+ raise NotImplementedError(self.delete_doc)
+
+ def _get_conflicts(self, doc_id):
+ return []
+
+ def get_doc_conflicts(self, doc_id):
+ return []
+
+ def _get_replica_gen_and_trans_id(self, other_replica_uid):
+ raise NotImplementedError(self._get_replica_gen_and_trans_id)
+
+ def _set_replica_gen_and_trans_id(self, other_replica_uid,
+ other_generation, other_transaction_id):
+ raise NotImplementedError(self._set_replica_gen_and_trans_id)
+
+ def _do_set_replica_gen_and_trans_id(self, other_replica_uid,
+ other_generation,
+ other_transaction_id):
+ raise NotImplementedError(self._do_set_replica_gen_and_trans_id)
+
+ def _put_doc_if_newer(self, doc, save_conflict, replica_uid=None,
+ replica_gen=None, replica_trans_id=None):
+ raise NotImplementedError(self._put_doc_if_newer)
+
+ def resolve_doc(self, doc, conflicted_doc_revs):
+ raise NotImplementedError(self.resolve_doc)
+
+ def list_indexes(self):
+ return []
+
+ def get_from_index(self, index_name, *key_values):
+ return []
+
+ def get_range_from_index(self, index_name, start_value=None,
+ end_value=None):
+ return []
+
+ def get_index_keys(self, index_name):
+ return []
+
+ def delete_index(self, index_name):
+ return False
+
+class LeapDocument(Document):
+
+ def get_content_encrypted(self):
+ raise NotImplementedError(self.get_content_encrypted)
+
+ def set_content_encrypted(self):
+ raise NotImplementedError(self.set_content_encrypted)
+
+
+class OpenStackSyncTarget(CommonSyncTarget):
+
+ def get_sync_info(self, source_replica_uid):
+ raise NotImplementedError(self.get_sync_info)
+
+ def record_sync_info(self, source_replica_uid, source_replica_generation,
+ source_replica_transaction_id):
+ raise NotImplementedError(self.record_sync_info)