Implemented Stotage.FileSystem

andrey-serdyuk · andrey-serdyuk · commit 971f07aa7fd5 · 2025-12-31T21:05:23.000+02:00
diff --git a/Directory.Build.props b/Directory.Build.props
@@ -4,7 +4,7 @@
 		<ImplicitUsings>enable</ImplicitUsings>
 		<Nullable>enable</Nullable>
 		<IsPackable>true</IsPackable>
-		<Version>2.3.31</Version>
+		<Version>2.3.34</Version>
 		<Authors>Andrey Serdyuk</Authors>
 		<Company>TaskHub</Company>
 		<Title>TaskHub.Shared - Reusable Primitives for .NET Microservices</Title>
diff --git a/README.md b/README.md
@@ -2,7 +2,6 @@
 [![GitHub stars](https://img.shields.io/github/stars/TaskHub-Server/TaskHub.Shared?style=social)](https://github.com/TaskHub-Server/TaskHub.Shared/stargazers)
 [![Sponsor](https://img.shields.io/badge/Sponsor-💖-pink?style=flat-square)](https://github.com/sponsors/andrey-serdyuk)
 
-
 TaskHub.Shared is a set of small, independent modules that act as the shared foundation for microservices. 
 It provides shared primitives, abstractions, contracts, and infrastructure adapters designed around Domain-Driven Design (DDD) and Clean Architecture principles.
 
@@ -42,6 +41,13 @@ TaskHub.Shared contains the fundamental components and patterns used across all
 - **TaskHub.Shared.GeoCoding.Abstractions** — Abstractions for geocoding providers.
 - **TaskHub.Shared.GeoCoding.Nominatim** — Implementation of the geocoding service using the Nominatim API.
 
+## Networking
+- **TaskHub.Shared.Networking.Abstractions** — Abstractions for HTTP client configurations, including interfaces for defining client settings and policies.
+- **TaskHub.Shared.Networking.Implementation** — Configuration, refactoring and registering of HTTP clients with Polly-based resilience policies (retry, circuit breaker, timeout).
+
+## Refactoring
+- **TaskHub.Shared.Refactoring.Abstractions** — Abstractions for service refactoring.
+- **TaskHub.Shared.Refactoring.Implementation** — Implementations for service refactoring and dynamic dependency resolution.
 
 ## Observability
 
@@ -55,17 +61,9 @@ TaskHub.Shared contains the fundamental components and patterns used across all
 ### OpenTelemetry
 - **TaskHub.Observability.OpenTelemetry** — Preconfigured OpenTelemetry setup (resource, exporters, processors) for metrics, traces, and logs (Tempo, Prometheus, Loki).
 
-
-## Refactoring
-- **TaskHub.Shared.Refactoring.Abstractions** — Abstractions for service refactoring.
-- **TaskHub.Shared.Refactoring.Implementation** — Implementations for service refactoring and dynamic dependency resolution.
-
 ## Swagger / OpenAPI
 - **TaskHub.Shared.Swagger** — Common Swagger / OpenAPI configuration for ASP.NET Core services (conventions, filters, defaults).
 
-## Networking
-- **TaskHub.Shared.Networking** — Resiliency policies (retry, circuit breaker, timeout) for HTTP clients.
-
 ## Bootstrapping
 - **TaskHub.Shared.Bootstraper.Basic** — Basic service bootstrapping (dependency injection, configuration, logging).
 - **TaskHub.Shared.Bootstraper.Full** — Comprehensive service bootstrapping (all features, advanced configuration, etc.).
diff --git a/Shared.slnx b/Shared.slnx
@@ -35,8 +35,8 @@
     <Project Path="TaskHub.Shared.GeoCoding.Nominatim/TaskHub.Shared.GeoCoding.Nominatim.csproj" />
   </Folder>
   <Folder Name="/Networking/">
-    <Project Path="TaskHub.Shared.Networking.Abstractions/TaskHub.Shared.Networking.Abstractions.csproj" Id="9058871d-aadf-4e9b-b1ce-545eda04f71e" />
-    <Project Path="TaskHub.Shared.Networking.Implementation/TaskHub.Shared.Networking.Implementation.csproj" Id="98f34111-49e6-4178-9919-91ff62eb402e" />
+    <Project Path="TaskHub.Shared.Networking.Abstractions/TaskHub.Shared.Networking.Abstractions.csproj" />
+    <Project Path="TaskHub.Shared.Networking.Implementation/TaskHub.Shared.Networking.Implementation.csproj" />
   </Folder>
   <Folder Name="/Observability/" />
   <Folder Name="/Observability/Logger/">
@@ -56,8 +56,8 @@
     <Project Path="TaskHub.Shared.Persistence.Repository/TaskHub.Shared.Persistence.Repository.csproj" />
   </Folder>
   <Folder Name="/Storage/">
-    <Project Path="TaskHub.Shared.Storage.Abstractions/TaskHub.Shared.Storage.Abstractions.csproj" Id="a379fdb7-5b5c-422a-97fa-e3a7a9be834a" />
-    <Project Path="TaskHub.Shared.Storage.FileSystem/TaskHub.Shared.Storage.FileSystem.csproj" Id="49adf94c-7d33-4873-a8d6-0b806a8a2ff1" />
+    <Project Path="TaskHub.Shared.Storage.Abstractions/TaskHub.Shared.Storage.Abstractions.csproj" />
+    <Project Path="TaskHub.Shared.Storage.FileSystem/TaskHub.Shared.Storage.FileSystem.csproj" />
   </Folder>
   <Folder Name="/Tools/">
     <Project Path="TaskHub.Shared.RateLimiter/TaskHub.Shared.RateLimiter.csproj" />
diff --git a/TaskHub.Observability.Logger/TaskHub.Observability.Logger.csproj b/TaskHub.Observability.Logger/TaskHub.Observability.Logger.csproj
@@ -12,7 +12,7 @@
 	<ItemGroup>
 		<PackageReference Include="Serilog.AspNetCore" Version="10.0.0" />
 		<PackageReference Include="Serilog.Settings.Configuration" Version="10.0.0" />
-		<PackageReference Include="Serilog.Sinks.Grafana.Loki" Version="8.3.1" />
+		<PackageReference Include="Serilog.Sinks.Grafana.Loki" Version="8.3.2" />
 	</ItemGroup>
 
 	<ItemGroup>
diff --git a/TaskHub.Shared.Networking.Abstractions/TaskHub.Shared.Networking.Abstractions.csproj b/TaskHub.Shared.Networking.Abstractions/TaskHub.Shared.Networking.Abstractions.csproj
@@ -1,2 +1,5 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
+	<PropertyGroup>
+		<Description>Abstractions for HTTP client configurations, including interfaces for defining client settings and policies.</Description>
+	</PropertyGroup>
 </Project>
diff --git a/TaskHub.Shared.Networking.Implementation/TaskHub.Shared.Networking.Implementation.csproj b/TaskHub.Shared.Networking.Implementation/TaskHub.Shared.Networking.Implementation.csproj
@@ -1,4 +1,7 @@
 ﻿<Project Sdk="Microsoft.NET.Sdk">
+	<PropertyGroup>
+		<Description>Configuration, refactoring and registering of HTTP clients with Polly-based resilience policies (retry, circuit breaker, timeout).</Description>
+	</PropertyGroup>
 	<ItemGroup>
 		<PackageReference Include="Microsoft.AspNetCore.Http" Version="2.3.0" />
 		<PackageReference Include="Microsoft.Extensions.Http" Version="10.0.1" />
diff --git a/TaskHub.Shared.Storage.Abstractions/Exceptions/StorageException.cs b/TaskHub.Shared.Storage.Abstractions/Exceptions/StorageException.cs
@@ -0,0 +1,7 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Exceptions;
+
+public sealed class StorageException : Exception
+{
+    public StorageException(string message) : base(message) { }
+    public StorageException(string message, Exception innerException) : base(message, innerException) { }
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Generator/IStorageKeyGenerator.cs b/TaskHub.Shared.Storage.Abstractions/Generator/IStorageKeyGenerator.cs
@@ -0,0 +1,9 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+using TaskHub.Shared.Storage.Abstractions.Requests;
+
+namespace TaskHub.Shared.Storage.Abstractions.Generator;
+
+public interface IStorageKeyGenerator
+{
+    string Generate(StorageObjectId id, StoreObjectRequest request);
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Models/StorageAccess.cs b/TaskHub.Shared.Storage.Abstractions/Models/StorageAccess.cs
@@ -0,0 +1,7 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Models;
+
+public enum StorageAccess
+{
+    Private = 0,
+    Public = 1
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Models/StorageMetadata.cs b/TaskHub.Shared.Storage.Abstractions/Models/StorageMetadata.cs
@@ -0,0 +1,6 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Models;
+
+public class StorageMetadata
+{
+    public string Pathway { get; set; } = string.Empty;
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Models/StorageObject.cs b/TaskHub.Shared.Storage.Abstractions/Models/StorageObject.cs
@@ -0,0 +1,12 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Models;
+
+public sealed record StorageObject(
+    StorageObjectId Id,
+    string Key,
+    StorageObjectType Type,
+    StorageAccess Access,
+    long Size,
+    string ContentType,
+    Uri? PublicUrl,
+    StorageMetadata Metadata
+);
diff --git a/TaskHub.Shared.Storage.Abstractions/Models/StorageObjectId.cs b/TaskHub.Shared.Storage.Abstractions/Models/StorageObjectId.cs
@@ -0,0 +1,7 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Models;
+
+public sealed record StorageObjectId(Guid Value)
+{
+    public StorageObjectId() : this(Guid.NewGuid()) { }
+    public override string ToString() => Value.ToString();
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Models/StorageObjectType.cs b/TaskHub.Shared.Storage.Abstractions/Models/StorageObjectType.cs
@@ -0,0 +1,8 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Models;
+
+public enum StorageObjectType
+{
+    Image,
+    Video,
+    File
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Provider/IStorageProvider.cs b/TaskHub.Shared.Storage.Abstractions/Provider/IStorageProvider.cs
@@ -0,0 +1,10 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+using TaskHub.Shared.Storage.Abstractions.Requests;
+
+namespace TaskHub.Shared.Storage.Abstractions.Provider;
+
+public interface IStorageProvider
+{
+    Task<StorageObject> StoreAsync(StorageObjectId id, string key, Stream content, StoreObjectRequest request, CancellationToken ct);
+    Task DeleteAsync(StorageObjectId id, string key, CancellationToken ct);
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Requests/DeleteObjectRequest.cs b/TaskHub.Shared.Storage.Abstractions/Requests/DeleteObjectRequest.cs
@@ -0,0 +1,5 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Requests;
+
+public sealed class DeleteObjectRequest
+{
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Requests/StoreObjectRequest.cs b/TaskHub.Shared.Storage.Abstractions/Requests/StoreObjectRequest.cs
@@ -0,0 +1,13 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+
+namespace TaskHub.Shared.Storage.Abstractions.Requests;
+
+public sealed record StoreObjectRequest(
+    Stream Content,
+    string FolderName,
+    string FileName,
+    string ContentType,
+    StorageObjectType Type,
+    StorageAccess Access,
+    StorageMetadata? Metadata = null
+);
diff --git a/TaskHub.Shared.Storage.Abstractions/Resolver/IStorageUrlResolver.cs b/TaskHub.Shared.Storage.Abstractions/Resolver/IStorageUrlResolver.cs
@@ -0,0 +1,8 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+
+namespace TaskHub.Shared.Storage.Abstractions.Resolver;
+
+public interface IStorageUrlResolver
+{
+    Uri? ResolvePublicUrl(StorageObject obj);
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Results/DeleteObjectResult.cs b/TaskHub.Shared.Storage.Abstractions/Results/DeleteObjectResult.cs
@@ -0,0 +1,5 @@
+﻿namespace TaskHub.Shared.Storage.Abstractions.Results;
+
+public sealed class DeleteObjectResult
+{
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/Results/StoreObjectResult.cs b/TaskHub.Shared.Storage.Abstractions/Results/StoreObjectResult.cs
@@ -0,0 +1,7 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+
+namespace TaskHub.Shared.Storage.Abstractions.Results;
+
+public sealed record StoreObjectResult(
+    StorageObject Object
+);
diff --git a/TaskHub.Shared.Storage.Abstractions/Service/IStorageService.cs b/TaskHub.Shared.Storage.Abstractions/Service/IStorageService.cs
@@ -0,0 +1,12 @@
+﻿using TaskHub.Shared.Response;
+using TaskHub.Shared.Storage.Abstractions.Models;
+using TaskHub.Shared.Storage.Abstractions.Requests;
+using TaskHub.Shared.Storage.Abstractions.Results;
+
+namespace TaskHub.Shared.Storage.Abstractions.Service;
+
+public interface IStorageService
+{
+    Task<StoreObjectResult> StoreAsync(StoreObjectRequest request, CancellationToken ct);
+    Task<Result> DeleteAsync(StorageObjectId objectId, CancellationToken ct);
+}
diff --git a/TaskHub.Shared.Storage.Abstractions/TaskHub.Shared.Storage.Abstractions.csproj b/TaskHub.Shared.Storage.Abstractions/TaskHub.Shared.Storage.Abstractions.csproj
@@ -6,4 +6,8 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
+  <ItemGroup>
+    <ProjectReference Include="..\TaskHub.Shared.Response\TaskHub.Shared.Response.csproj" />
+  </ItemGroup>
+
 </Project>
diff --git a/TaskHub.Shared.Storage.FileSystem/Bootstrap/FileSystemBoostrap.cs b/TaskHub.Shared.Storage.FileSystem/Bootstrap/FileSystemBoostrap.cs
@@ -0,0 +1,25 @@
+﻿using Microsoft.Extensions.DependencyInjection;
+using TaskHub.Shared.Storage.Abstractions.Generator;
+using TaskHub.Shared.Storage.Abstractions.Provider;
+using TaskHub.Shared.Storage.Abstractions.Resolver;
+using TaskHub.Shared.Storage.Abstractions.Service;
+using TaskHub.Shared.Storage.FileSystem.Generator;
+using TaskHub.Shared.Storage.FileSystem.Provider;
+using TaskHub.Shared.Storage.FileSystem.Resolver;
+using TaskHub.Shared.Storage.FileSystem.Service;
+
+namespace TaskHub.Shared.Storage.FileSystem.Bootstrap;
+
+public static class FileSystemBoostrap
+{
+    extension(IServiceCollection services)
+    {
+        public void AddFileSystemStorage()
+        {
+            services.AddSingleton<IStorageUrlResolver, StorageUrlResolver>();
+            services.AddSingleton<IStorageKeyGenerator, StorageKeyGenerator>();
+            services.AddSingleton<IStorageProvider, StorageProvider>();
+            services.AddSingleton<IStorageService, StorageService>();
+        }
+    }
+}
diff --git a/TaskHub.Shared.Storage.FileSystem/Generator/StorageKeyGenerator.cs b/TaskHub.Shared.Storage.FileSystem/Generator/StorageKeyGenerator.cs
@@ -0,0 +1,47 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Generator;
+using TaskHub.Shared.Storage.Abstractions.Models;
+using TaskHub.Shared.Storage.Abstractions.Requests;
+
+namespace TaskHub.Shared.Storage.FileSystem.Generator;
+
+public sealed class StorageKeyGenerator : IStorageKeyGenerator
+{
+    public string Generate(StorageObjectId id, StoreObjectRequest request)
+    {
+        ArgumentNullException.ThrowIfNull(request);
+
+        var ext = GetSafeExtension(request);
+        var typeFolder = request.Type switch
+        {
+            StorageObjectType.Image => "images",
+            StorageObjectType.Video => "videos",
+            StorageObjectType.File => "files",
+            _ => "other"
+        };
+
+        var now = DateTime.UtcNow;
+        return Path.Combine(request.FolderName ?? string.Empty, $"{id}{ext}");
+    }
+
+    private static string GetSafeExtension(StoreObjectRequest request)
+    {
+        if (string.IsNullOrWhiteSpace(request.FileName))
+        {
+            return string.Empty;
+        }
+
+        var ext = Path.GetExtension(request.FileName);
+
+        if (string.IsNullOrWhiteSpace(ext))
+        {
+            return string.Empty;
+        }
+
+        if (ext.Length > 10)
+        {
+            return string.Empty;
+        }
+
+        return ext.ToLowerInvariant();
+    }
+}
diff --git a/TaskHub.Shared.Storage.FileSystem/Options/StorageOptions.cs b/TaskHub.Shared.Storage.FileSystem/Options/StorageOptions.cs
@@ -0,0 +1,7 @@
+﻿namespace TaskHub.Shared.Storage.FileSystem.Options;
+
+public sealed class StorageOptions
+{
+    public required string RootPath { get; init; }
+    public required string BaseUrl { get; init; }
+}
diff --git a/TaskHub.Shared.Storage.FileSystem/Provider/StorageProvider.cs b/TaskHub.Shared.Storage.FileSystem/Provider/StorageProvider.cs
@@ -0,0 +1,69 @@
+﻿using TaskHub.Shared.Storage.Abstractions.Models;
+using TaskHub.Shared.Storage.Abstractions.Provider;
+using TaskHub.Shared.Storage.Abstractions.Requests;
+using TaskHub.Shared.Storage.FileSystem.Options;
+
+namespace TaskHub.Shared.Storage.FileSystem.Provider;
+
+public sealed class StorageProvider(StorageOptions options) : IStorageProvider
+{
+    private readonly string _rootPath = options.RootPath;
+
+    public async Task<StorageObject> StoreAsync(StorageObjectId id, string key, Stream content, StoreObjectRequest request, CancellationToken ct)
+    {
+        ArgumentNullException.ThrowIfNull(content);
+        ArgumentException.ThrowIfNullOrWhiteSpace(key);
+
+        var relativePath = NormalizeKey(key);
+        var fullPath = Path.Combine(_rootPath, relativePath);
+        var directory = Path.GetDirectoryName(fullPath);
+        
+        if (!string.IsNullOrWhiteSpace(directory))
+        {
+            Directory.CreateDirectory(directory);
+        }
+
+        await using var fs = new FileStream(fullPath, FileMode.Create, FileAccess.Write, FileShare.None, bufferSize: 81920, useAsync: true);
+        await content.CopyToAsync(fs, ct);
+
+        var fileInfo = new FileInfo(fullPath);
+
+        return new StorageObject(
+            Id: id,
+            Key: relativePath,
+            Type: request.Type,
+            Access: request.Access,
+            Size: fileInfo.Length,
+            ContentType: request.ContentType,
+            PublicUrl: null,
+            Metadata: request.Metadata ?? new StorageMetadata()
+        );
+    }
+
+    public Task DeleteAsync(StorageObjectId id, string key, CancellationToken ct)
+    {
+        ArgumentException.ThrowIfNullOrWhiteSpace(key);
+
+        var relativePath = NormalizeKey(key);
+        var fullPath = Path.Combine(_rootPath, relativePath);
+
+        if (File.Exists(fullPath))
+        {
+            File.Delete(fullPath);
+        }
+
+        return Task.CompletedTask;
+    }
+
+    private static string NormalizeKey(string key)
+    {
+        key = key.Replace('\\', '/').TrimStart('/');
+
+        if (key.Contains("..", StringComparison.Ordinal))
+        {
+            throw new InvalidOperationException("Invalid storage key");
+        }
+
+        return key;
+    }
+}
diff --git a/TaskHub.Shared.Storage.FileSystem/Resolver/StorageUrlResolver.cs b/TaskHub.Shared.Storage.FileSystem/Resolver/StorageUrlResolver.cs
diff --git a/TaskHub.Shared.Storage.FileSystem/Service/StorageService.cs b/TaskHub.Shared.Storage.FileSystem/Service/StorageService.cs
diff --git a/TaskHub.Shared.Storage.FileSystem/TaskHub.Shared.Storage.FileSystem.csproj b/TaskHub.Shared.Storage.FileSystem/TaskHub.Shared.Storage.FileSystem.csproj
diff --git a/TaskHub.Shared.Versioning/TaskHub.Shared.Versioning.csproj b/TaskHub.Shared.Versioning/TaskHub.Shared.Versioning.csproj
