feat(Immortal) Disabling SQL

2022-03-30 21:28:08 -04:00
parent 4d27140e36
commit 363d6835b8
21 changed files with 427 additions and 132 deletions
@@ -0,0 +1,84 @@
+
+
+using System.Net.Http.Json;
+using Contexts;
+using Microsoft.EntityFrameworkCore;
+using Model.Work.Tasks;
+
+namespace Services.Work;
+
+public class AgileService : IAgileService {
+    private readonly HttpClient httpClient;
+
+    private bool isLoaded;
+
+    public AgileService(HttpClient httpClient) {
+        this.httpClient = httpClient;
+    }
+
+
+#if NO_SQL
+    public List<SprintModel> SprintModels { get; set; }
+    public List<TaskModel> TaskModels { get; set; }
+#else
+
+    private DatabaseContext Database { get; set; }
+    public DbSet<SprintModel> SprintModels => Database.SprintModels;
+    public DbSet<TaskModel> TaskModels => Database.TaskModels;
+#endif
+
+
+    public void Subscribe(Action action) {
+        _onChange += action;
+    }
+
+    public void Unsubscribe(Action action) {
+        _onChange -= action;
+    }
+
+    public bool IsLoaded() {
+        return isLoaded;
+    }
+
+#if NO_SQL
+    public async Task Load() {
+        if (isLoaded) {
+            return;
+        }
+
+        SprintModels = (await httpClient.GetFromJsonAsync<SprintModel[]>("generated/SprintModels.json")).ToList();
+        TaskModels =(await httpClient.GetFromJsonAsync<TaskModel[]>("generated/TaskModels.json")).ToList();
+
+        isLoaded = true;
+
+        NotifyDataChanged();
+    }
+#else
+    public async Task Load(DatabaseContext database) {
+        Database = database;
+
+        if (isLoaded) {
+            return;
+        }
+
+        Database.SprintModels.AddRange(await httpClient.GetFromJsonAsync<SprintModel[]>("generated/SprintModels.json"));
+        Database.TaskModels.AddRange(await httpClient.GetFromJsonAsync<TaskModel[]>("generated/TaskModels.json"));
+
+        Database.SaveChanges();
+
+        isLoaded = true;
+
+        NotifyDataChanged();
+    }
+#endif
+
+    public void Update() {
+        NotifyDataChanged();
+    }
+
+    private event Action _onChange;
+
+    private void NotifyDataChanged() {
+        _onChange?.Invoke();
+    }
+}
@@ -0,0 +1,96 @@
+
+
+using System.Net.Http.Json;
+using Model.Work.Git;
+
+#if NO_SQL
+
+#else
+using Contexts;
+using Microsoft.EntityFrameworkCore;
+#endif
+
+namespace Services.Work;
+
+public class GitService : IGitService {
+    private readonly HttpClient httpClient;
+
+    private bool isLoaded;
+
+    public GitService(HttpClient httpClient) {
+        this.httpClient = httpClient;
+    }
+
+#if NO_SQL
+    public List<ChangeModel> ChangeModels { get; set; }
+    public List<PatchModel> PatchModels { get; set; }
+#else
+    public DbSet<ChangeModel> ChangeModels => Database.ChangeModels;
+    public DbSet<PatchModel> PatchModels => Database.PatchModels;
+    public DatabaseContext Database { get; set; }
+#endif
+
+
+
+    public void Subscribe(Action action) {
+        _onChange += action;
+    }
+
+    public void Unsubscribe(Action action) {
+        _onChange -= action;
+    }
+
+    public bool IsLoaded() {
+        return isLoaded;
+    }
+
+    
+#if NO_SQL
+
+    public async Task Load() {
+
+        if (isLoaded) {
+            return;
+        }
+        
+        ChangeModels =  (await httpClient.GetFromJsonAsync<ChangeModel[]>("generated/ChangeModels.json")).ToList();
+        PatchModels = (await httpClient.GetFromJsonAsync<PatchModel[]>("generated/PatchModels.json")).ToList();
+
+
+        isLoaded = true;
+
+        NotifyDataChanged();
+    }
+
+#else
+
+    public async Task Load(DatabaseContext database) {
+        Database = database;
+
+        if (isLoaded) {
+            return;
+        }
+        
+        Database.ChangeModels.AddRange(await httpClient.GetFromJsonAsync<ChangeModel[]>("generated/ChangeModels.json"));
+        Database.PatchModels.AddRange(await httpClient.GetFromJsonAsync<PatchModel[]>("generated/PatchModels.json"));
+        Database.SaveChanges();
+
+
+        isLoaded = true;
+
+        NotifyDataChanged();
+    }
+
+#endif
+
+    
+    public void Update() {
+        NotifyDataChanged();
+    }
+
+    private event Action _onChange;
+
+    private void NotifyDataChanged() {
+        _onChange?.Invoke();
+    }
+}