reintroduce chunk store interfaces

src/BeeNet.Util/Hashing/Pipeline/ChunkStoreWriterPipelineStage.cs

@@ -21,7 +21,7 @@
 namespace Etherna.BeeNet.Hashing.Pipeline
 {
     internal sealed class ChunkStoreWriterPipelineStage(
-        ChunkStoreBase chunkStore,
+        IChunkStore chunkStore,
         IPostageStamper postageStamper,
         IHasherPipelineStage? nextStage)
         : IHasherPipelineStage

src/BeeNet.Util/Hashing/Pipeline/HasherPipelineBuilder.cs

@@ -40,7 +40,7 @@ public static IHasherPipeline BuildNewHasherPipeline(
                 chunkConcurrency);
 
         public static IHasherPipeline BuildNewHasherPipeline(
-            ChunkStoreBase chunkStore,
+            IChunkStore chunkStore,
             IPostageStamper postageStamper,
             RedundancyLevel redundancyLevel,
             bool isEncrypted,

src/BeeNet.Util/Manifest/ReferencedMantarayManifest.cs

@@ -21,7 +21,7 @@
 namespace Etherna.BeeNet.Manifest
 {
     public class ReferencedMantarayManifest(
-        ReadOnlyChunkStoreBase chunkStore,
+        IReadOnlyChunkStore chunkStore,
         SwarmHash rootHash,
         bool useChunksCache = true)
         : IReadOnlyMantarayManifest

src/BeeNet.Util/Manifest/ReferencedMantarayNode.cs

@@ -26,7 +26,7 @@ namespace Etherna.BeeNet.Manifest
     public class ReferencedMantarayNode : IReadOnlyMantarayNode
     {
         // Fields.
-        private readonly ReadOnlyChunkStoreBase chunkStore;
+        private readonly IReadOnlyChunkStore chunkStore;
         private readonly bool useChunksCache;
 
         private SwarmHash? _entryHash;
@@ -36,7 +36,7 @@ public class ReferencedMantarayNode : IReadOnlyMantarayNode
 
         // Constructor.
         public ReferencedMantarayNode(
-            ReadOnlyChunkStoreBase chunkStore,
+            IReadOnlyChunkStore chunkStore,
             SwarmHash chunkHash,
             Dictionary<string, string>? metadata,
             NodeType nodeTypeFlags,

src/BeeNet.Util/Services/ChunkService.cs

@@ -37,7 +37,7 @@ public async Task<UploadEvaluationResult> EvaluateDirectoryUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null, 
-            ChunkStoreBase? chunkStore = null)
+            IChunkStore? chunkStore = null)
         {
             // Checks.
             if (indexFilename?.Contains(SwarmAddress.Separator, StringComparison.InvariantCulture) == true)
@@ -146,7 +146,7 @@ public async Task<UploadEvaluationResult> EvaluateSingleFileUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null, 
-            ChunkStoreBase? chunkStore = null)
+            IChunkStore? chunkStore = null)
         {
             using var stream = new MemoryStream(data);
             return await EvaluateSingleFileUploadAsync(
@@ -170,7 +170,7 @@ public async Task<UploadEvaluationResult> EvaluateSingleFileUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null, 
-            ChunkStoreBase? chunkStore = null)
+            IChunkStore? chunkStore = null)
         {
             chunkStore ??= new FakeChunkStore();
 
@@ -240,7 +240,7 @@ public string[] GetAllChunkFilesInDirectory(string chunkStoreDirectory) =>
 
         public async Task<IReadOnlyDictionary<string, string>> GetFileMetadataFromChunksAsync(
             SwarmAddress address,
-            ReadOnlyChunkStoreBase chunkStore)
+            IReadOnlyChunkStore chunkStore)
         {
             var rootManifest = new ReferencedMantarayManifest(
                 chunkStore,

src/BeeNet.Util/Services/IChunkService.cs

@@ -46,7 +46,7 @@ Task<UploadEvaluationResult> EvaluateDirectoryUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null,
-            ChunkStoreBase? chunkStore = null);
+            IChunkStore? chunkStore = null);
 
         /// <summary>
         /// Evaluate the result uploading a single file
@@ -70,7 +70,7 @@ Task<UploadEvaluationResult> EvaluateSingleFileUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null,
-            ChunkStoreBase? chunkStore = null);
+            IChunkStore? chunkStore = null);
 
         /// <summary>
         /// Evaluate the result uploading a single file
@@ -94,7 +94,7 @@ Task<UploadEvaluationResult> EvaluateSingleFileUploadAsync(
             RedundancyLevel redundancyLevel = RedundancyLevel.None,
             IPostageStampIssuer? postageStampIssuer = null,
             int? chunkCuncorrency = null,
-            ChunkStoreBase? chunkStore = null);
+            IChunkStore? chunkStore = null);
 
         /// <summary>
         /// Get list of all chunk files in directory
@@ -112,7 +112,7 @@ string[] GetAllChunkFilesInDirectory(
         /// <returns>Resource metadata</returns>
         Task<IReadOnlyDictionary<string, string>> GetFileMetadataFromChunksAsync(
             SwarmAddress address,
-            ReadOnlyChunkStoreBase chunkStore);
+            IReadOnlyChunkStore chunkStore);
 
         /// <summary>
         /// Get resource stream from a directory of chunks and the resource address

src/BeeNet.Util/Stores/ChunkJoiner.cs

@@ -21,7 +21,7 @@
 namespace Etherna.BeeNet.Stores
 {
     public class ChunkJoiner(
-        ReadOnlyChunkStoreBase chunkStore)
+        IReadOnlyChunkStore chunkStore)
     {
         // Methods.
         /// <summary>

src/BeeNet.Util/Stores/ChunkStoreBase.cs

@@ -21,7 +21,7 @@ namespace Etherna.BeeNet.Stores
 {
     public abstract class ChunkStoreBase(
         IDictionary<SwarmHash, SwarmChunk>? chunksCache = null)
-        : ReadOnlyChunkStoreBase(chunksCache)
+        : ReadOnlyChunkStoreBase(chunksCache), IChunkStore
     {
         /// <summary>
         /// Add a chunk in the store

src/BeeNet.Util/Stores/IChunkStore.cs

@@ -0,0 +1,26 @@
+// Copyright 2021-present Etherna SA
+// This file is part of Bee.Net.
+// 
+// Bee.Net is free software: you can redistribute it and/or modify it under the terms of the
+// GNU Lesser General Public License as published by the Free Software Foundation,
+// either version 3 of the License, or (at your option) any later version.
+// 
+// Bee.Net is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+// without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+// See the GNU Lesser General Public License for more details.
+// 
+// You should have received a copy of the GNU Lesser General Public License along with Bee.Net.
+// If not, see <https://www.gnu.org/licenses/>.
+
+using Etherna.BeeNet.Models;
+using System.Threading.Tasks;
+
+namespace Etherna.BeeNet.Stores
+{
+    public interface IChunkStore : IReadOnlyChunkStore
+    {
+        Task<bool> AddAsync(
+            SwarmChunk chunk,
+            bool bypassCacheWriting);
+    }
+}

src/BeeNet.Util/Stores/IReadOnlyChunkStore.cs

@@ -0,0 +1,32 @@
+// Copyright 2021-present Etherna SA
+// This file is part of Bee.Net.
+// 
+// Bee.Net is free software: you can redistribute it and/or modify it under the terms of the
+// GNU Lesser General Public License as published by the Free Software Foundation,
+// either version 3 of the License, or (at your option) any later version.
+// 
+// Bee.Net is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
+// without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
+// See the GNU Lesser General Public License for more details.
+// 
+// You should have received a copy of the GNU Lesser General Public License along with Bee.Net.
+// If not, see <https://www.gnu.org/licenses/>.
+
+using Etherna.BeeNet.Models;
+using System.Threading.Tasks;
+
+namespace Etherna.BeeNet.Stores
+{
+    public interface IReadOnlyChunkStore
+    {
+        Task<SwarmChunk> GetAsync(
+            SwarmHash hash,
+            bool bypassCacheReading,
+            bool bypassCacheWriting);
+
+        Task<SwarmChunk?> TryGetAsync(
+            SwarmHash hash,
+            bool bypassCacheReading,
+            bool bypassCacheWriting);
+    }
+}

src/BeeNet.Util/Stores/ReadOnlyChunkStoreBase.cs

@@ -21,6 +21,7 @@ namespace Etherna.BeeNet.Stores
 {
     public abstract class ReadOnlyChunkStoreBase(
         IDictionary<SwarmHash, SwarmChunk>? chunksCache = null)
+        : IReadOnlyChunkStore
     {
         // Fields.
         protected readonly IDictionary<SwarmHash, SwarmChunk> ChunksCache =
@@ -34,15 +35,15 @@ public async Task<SwarmChunk> GetAsync(
         {
             if (!bypassCacheReading && ChunksCache.TryGetValue(hash, out var chunk))
                 return chunk;
-            
+
             chunk = await LoadChunkAsync(hash).ConfigureAwait(false);
-            
+
             if (!bypassCacheWriting)
                 ChunksCache[hash] = chunk;
 
             return chunk;
         }
-        
+
         public async Task<SwarmChunk?> TryGetAsync(
             SwarmHash hash,
             bool bypassCacheReading,
@@ -57,7 +58,7 @@ public async Task<SwarmChunk> GetAsync(
                 return null;
             }
         }
-        
+
         // Protected methods.
         protected abstract Task<SwarmChunk> LoadChunkAsync(SwarmHash hash);
     }