Start a proof-of-concept FUSE interface to old snapshots.

[cumulus.git] / python / cumulus / store / file.py

diff --git a/python/cumulus/store/file.py b/python/cumulus/store/file.py
new file mode 100644 (file)
index 0000000..6034835
--- /dev/null
+++ b/python/cumulus/store/file.py
@@ -0,0 +1,37 @@
+import os, sys, tempfile
+
+import cumulus.store
+
+type_patterns = cumulus.store.type_patterns
+
+class FileStore(cumulus.store.Store):
+    def __init__(self, prefix):
+        while prefix.endswith("/") and prefix != "/": prefix = prefix[:-1]
+        self.prefix = prefix
+
+    def _get_path(self, type, name):
+        return "%s/%s" % (self.prefix, name)
+
+    def list(self, type):
+        files = os.listdir(self.prefix)
+        return (f for f in files if type_patterns[type].match(f))
+
+    def get(self, type, name):
+        k = self._get_path(type, name)
+        return open(k, 'rb')
+
+    def put(self, type, name, fp):
+        k = self._get_path(type, name)
+        out = open(k, 'wb')
+        buf = fp.read(4096)
+        while len(buf) > 0:
+            out.write(buf)
+            buf = fp.read(4096)
+
+    def delete(self, type, name):
+        k = self._get_path(type, name)
+        os.unlink(k)
+
+    def stat(self, type, name):
+        stat = os.stat(self._get_path(type, name))
+        return {'size': stat.st_size}