storage services

src/Core/Services/LiteDbStorageService.cs

@@ -0,0 +1,56 @@
+using Bit.Core.Abstractions;
+using LiteDB;
+using Newtonsoft.Json;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace Bit.Core.Services
+{
+    public class LiteDbStorageService : IStorageService
+    {
+        private LiteCollection<JsonItem> _collection;
+
+        public LiteDbStorageService(string dbPath)
+        {
+            var db = new LiteDatabase($"filename={dbPath}");
+            _collection = db.GetCollection<JsonItem>("json_items");
+        }
+
+        public Task<T> GetAsync<T>(string key)
+        {
+            var item = _collection.Find(i => i.Id == key).FirstOrDefault();
+            if(item == null)
+            {
+                return Task.FromResult(default(T));
+            }
+            return Task.FromResult(JsonConvert.DeserializeObject<T>(item.Value));
+        }
+
+        public Task SaveAsync<T>(string key, T obj)
+        {
+            var data = JsonConvert.SerializeObject(obj);
+            _collection.Upsert(new JsonItem(key, data));
+            return Task.FromResult(0);
+        }
+
+        public Task RemoveAsync(string key)
+        {
+            _collection.Delete(i => i.Id == key);
+            return Task.FromResult(0);
+        }
+
+        private class JsonItem
+        {
+            public JsonItem() { }
+
+            public JsonItem(string key, string value)
+            {
+                Id = key;
+                Value = value;
+            }
+
+            public string Id { get; set; }
+            public string Value { get; set; }
+        }
+    }
+}