From cfc2ff5886ef1ca32895023c48d66f36c88f027e Mon Sep 17 00:00:00 2001
From: CodeSteak <codesteak@shellf.art>
Date: Mon, 6 May 2019 09:34:12 +0200
Subject: [PATCH] flush on change metadata

---
 server/texture-sync-server/src/persistency/mod.rs | 2 +-
 server/texture-sync-server/src/server_state.rs    | 6 ++++++
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/server/texture-sync-server/src/persistency/mod.rs b/server/texture-sync-server/src/persistency/mod.rs
index 052aa07..1026531 100644
--- a/server/texture-sync-server/src/persistency/mod.rs
+++ b/server/texture-sync-server/src/persistency/mod.rs
@@ -165,7 +165,7 @@ impl DataStore {
         file.write_all(data)
     }
 
-    fn flush_metadata(&self) -> io::Result<()> {
+    pub fn flush_metadata(&self) -> io::Result<()> {
         let f = metadata_file::MetadataFile::from_iterator(self.textures.iter());
 
         f.store(self.index_file_path().as_path())
diff --git a/server/texture-sync-server/src/server_state.rs b/server/texture-sync-server/src/server_state.rs
index 4da94c1..f899934 100644
--- a/server/texture-sync-server/src/server_state.rs
+++ b/server/texture-sync-server/src/server_state.rs
@@ -102,6 +102,8 @@ impl ProtocolHandler for ServerState {
                     ));
                 }
 
+                data_store.flush_metadata()?;
+
                 Ok(ReplaceTextureStatus::Ok)
             }
             (Some(delete), None) => {
@@ -111,6 +113,8 @@ impl ProtocolHandler for ServerState {
                     ));
                 }
 
+                data_store.flush_metadata()?;
+
                 Ok(ReplaceTextureStatus::Ok)
             }
             (None, Some(insert)) => {
@@ -125,6 +129,8 @@ impl ProtocolHandler for ServerState {
                     ));
                 }
 
+                data_store.flush_metadata()?;
+
                 Ok(ReplaceTextureStatus::Ok)
             }
             (None, None) => Ok(ReplaceTextureStatus::Ok),