refactor: introduce IStorageAccess interface and update DataStore to …

…use FileAccess methods
ttu · Dec 14, 2024 · cfa1b55 · cfa1b55
1 parent 6bd9766
commit cfa1b55
Show file tree

Hide file tree

Showing 2 changed files with 27 additions and 7 deletions.
diff --git a/JsonFlatFileDataStore/DataStore.cs b/JsonFlatFileDataStore/DataStore.cs
@@ -15,6 +15,7 @@ namespace JsonFlatFileDataStore
 {
     public class DataStore : IDataStore
     {
+        private readonly IStorageAccess _fileAccess = new FileAccess();
         private readonly string _filePath;
         private readonly string _keyProperty;
         private readonly bool _reloadBeforeGetCollection;
@@ -86,7 +87,7 @@ public DataStore(string path, bool useLowerCamelCase = true, string keyProperty
                             _jsonData = JObject.Parse(jsonText);
                         }
 
-                        return FileAccess.WriteJsonToFile(_filePath, _encryptJson, jsonText);
+                        return _fileAccess.WriteJson(_filePath, _encryptJson, jsonText);
                     },
                     GetJsonTextFromFile);
             });
@@ -114,7 +115,7 @@ public void UpdateAll(string jsonData)
                 _jsonData = JObject.Parse(jsonData);
             }
 
-            FileAccess.WriteJsonToFile(_filePath, _encryptJson, jsonData);
+            _fileAccess.WriteJson(_filePath, _encryptJson, jsonData);
         }
 
         public void Reload()
@@ -432,7 +433,7 @@ private dynamic SingleDynamicItemReadConverter(JToken e)
             }
         }
 
-        private string GetJsonTextFromFile() => FileAccess.ReadJsonFromFile(_filePath, _encryptJson, _decryptJson);
+        private string GetJsonTextFromFile() => _fileAccess.ReadJson(_filePath, _encryptJson, _decryptJson);
 
         private JObject GetJsonObjectFromFile() => JObject.Parse(GetJsonTextFromFile());
 

diff --git a/JsonFlatFileDataStore/FileAccess.cs b/JsonFlatFileDataStore/FileAccess.cs
@@ -4,9 +4,15 @@
 
 namespace JsonFlatFileDataStore
 {
-    internal static class FileAccess
+    public interface IStorageAccess
     {
-        internal static string ReadJsonFromFile(string path, Func<string, string> encryptJson, Func<string, string> decryptJson)
+        string ReadJson(string path, Func<string, string> encryptJson, Func<string, string> decryptJson);
+        bool WriteJson(string path, Func<string, string> encryptJson, string content);
+    }
+
+    internal class FileAccess : IStorageAccess
+    {
+        public string ReadJson(string path, Func<string, string> encryptJson, Func<string, string> decryptJson)
         {
             Stopwatch sw = null;
             var json = "{}";
@@ -36,7 +42,7 @@ internal static string ReadJsonFromFile(string path, Func<string, string> encryp
             return decryptJson(json);
         }
 
-        internal static bool WriteJsonToFile(string path, Func<string, string> encryptJson, string content)
+        public bool WriteJson(string path, Func<string, string> encryptJson, string content)
         {
             Stopwatch sw = null;
 
@@ -61,4 +67,17 @@ internal static bool WriteJsonToFile(string path, Func<string, string> encryptJs
             }
         }
     }
-}
+
+    internal class LocalStorageAccess : IStorageAccess
+    {
+        private string _content = string.Empty;
+
+        public string ReadJson(string path, Func<string, string> encryptJson, Func<string, string> decryptJson) => _content;
+
+        public bool WriteJson(string path, Func<string, string> encryptJson, string content)
+        {
+            _content = content;
+            return true;
+        }
+    }
+}