From 3f20028bac1ad7d651b6b666e4ceee8f73ed5f8c Mon Sep 17 00:00:00 2001
From: Matthias Beyer <mail@beyermatthias.de>
Date: Wed, 13 Jan 2016 22:04:06 +0100
Subject: [PATCH] Add interface impl for FSStore

---
 libimagstore/src/fsstore.rs | 78 +++++++++++++++++++++++++++++++++++++
 libimagstore/src/lib.rs     |  1 +
 2 files changed, 79 insertions(+)
 create mode 100644 libimagstore/src/fsstore.rs

diff --git a/libimagstore/src/fsstore.rs b/libimagstore/src/fsstore.rs
new file mode 100644
index 00000000..e2c9798a
--- /dev/null
+++ b/libimagstore/src/fsstore.rs
@@ -0,0 +1,78 @@
+use std::collections::HashMap;
+use std::fs::File;
+use std::ops::Drop;
+use std::path::PathBuf;
+use std::result::Result as RResult;
+use std::sync::Arc;
+use std::sync::RwLock;
+
+pub use store::Store;
+pub use store::Result;
+pub use entry::Entry;
+pub use error::StoreError;
+
+pub struct FSStore {
+    location: PathBuf,
+
+    /**
+     * Internal Path->File cache map
+     *
+     * Caches the files, so they remain flock()ed
+     *
+     * Could be optimized for a threadsafe HashMap
+     */
+    cache: Arc<RwLock<HashMap<PathBuf, File>>>,
+}
+
+impl FSStore {
+
+    pub fn new(location: PathBuf) -> FSStore {
+        FSStore {
+            location: location,
+            cache: Arc::new(RwLock::new(HashMap::new())),
+        }
+    }
+}
+
+impl Store for FSStore {
+
+    fn location(&self) -> &PathBuf {
+        &self.location
+    }
+
+    fn create(&self, entry: Entry) -> Result<()> {
+        unimplemented!()
+    }
+
+    fn read(&self, path: PathBuf) -> Result<Arc<RwLock<Entry>>> {
+        unimplemented!()
+    }
+
+    fn update(&self, entry: Arc<RwLock<Entry>>) -> Result<()> {
+        unimplemented!()
+    }
+
+    fn delete(&self, path: PathBuf) -> Result<()> {
+        unimplemented!()
+    }
+
+}
+
+impl Drop for FSStore {
+
+    /**
+     * Unlock all files on drop
+     *
+     * TODO: Error message when file cannot be unlocked?
+     */
+    fn drop(&mut self) {
+        use std::ops::DerefMut;
+        use fs2::FileExt;
+
+        let cache = self.cache.clone();
+        cache.write().unwrap().deref_mut().iter().map(|(_, f)| f.unlock());
+    }
+
+}
+
+
diff --git a/libimagstore/src/lib.rs b/libimagstore/src/lib.rs
index 12c0e09d..eaba6a32 100644
--- a/libimagstore/src/lib.rs
+++ b/libimagstore/src/lib.rs
@@ -4,6 +4,7 @@ extern crate toml;
 pub mod content;
 pub mod entry;
 pub mod error;
+pub mod fsstore;
 pub mod header;
 pub mod store;