support reset?

Author: jmd

src/DotJEM.Json.Index2.Management/IJsonIndexManager.cs

@@ -32,7 +32,8 @@ public class JsonIndexManager : IJsonIndexManager
     private readonly IJsonDocumentSource jsonDocumentSource;
     private readonly IJsonIndexSnapshotManager snapshots;
     private readonly IJsonIndexWriter writer;
-    
+    private readonly IJsonIndex index;
+
     private readonly IInfoStream<JsonIndexManager> infoStream = new InfoStream<JsonIndexManager>();
     private readonly DocumentChangesStream changesStream = new();
 
@@ -44,11 +45,12 @@ public JsonIndexManager(
         IJsonDocumentSource jsonDocumentSource,
         IJsonIndexSnapshotManager snapshots,
         //TODO: Allow multiple indexes and something that can shard
-        IJsonIndexWriter writer)
+        IJsonIndex index)
     {
         this.jsonDocumentSource = jsonDocumentSource;
         this.snapshots = snapshots;
-        this.writer = writer;
+        this.index = index;
+        this.writer = new JsonIndexWriter(index);
 
         Tracker = new IngestProgressTracker();
         jsonDocumentSource.DocumentChanges.ForEachAsync(CaptureChange);
@@ -105,6 +107,7 @@ public Task UpdateGenerationAsync(string area, long generation)
 
     public async Task ResetIndexAsync()
     {
+        index.Storage.Delete();
         await jsonDocumentSource.ResetAsync().ConfigureAwait(false);
     }
 

src/Stress/StressTester/Adapter/IJsonStorageAreaObserver.cs

@@ -69,7 +69,6 @@ public void UpdateGeneration(string area, long value)
     public async Task ResetAsync()
     {
         UpdateGeneration(AreaName, initialGeneration);
-        
     }
 
     public void RunUpdateCheck()

src/Stress/StressTester/Program.cs

@@ -69,7 +69,7 @@
 IJsonIndexManager jsonIndexManager = new JsonIndexManager(
     new JsonStorageDocumentSource(new JsonStorageAreaObserverFactory(storage, scheduler,areas)),
     new JsonIndexSnapshotManager(index, new ZipSnapshotStrategy(".\\app_data\\snapshots"), scheduler, "10s"),
-    new JsonIndexWriter(index)
+    index
 );
 
 Task run = Task.WhenAll(