From d623e7c0b71f9268b125c918b7ac2895c6962689 Mon Sep 17 00:00:00 2001 From: Maksym Sadovnychyy Date: Thu, 14 Nov 2024 13:47:20 +0100 Subject: [PATCH] (refactor): code review --- src/MaksIT.Core.Dapr/DaprService.cs | 8 ++++++-- .../Extensions/ServiceCollectionExtensions.cs | 7 ++++++- src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj | 2 +- 3 files changed, 13 insertions(+), 4 deletions(-) diff --git a/src/MaksIT.Core.Dapr/DaprService.cs b/src/MaksIT.Core.Dapr/DaprService.cs index 0f78b82..f0e0e79 100644 --- a/src/MaksIT.Core.Dapr/DaprService.cs +++ b/src/MaksIT.Core.Dapr/DaprService.cs @@ -5,14 +5,18 @@ using Dapr.Client; using MaksIT.Results; namespace MaksIT.Core.Dapr; -public interface IDaprService { + +public interface IDaprPublisherService { Task PublishEventAsync(string pubSubName, string topicName, string payload); +} + +public interface IDaprStateStoreService { Task SaveStateAsync(string storeName, string key, T value); Task> GetStateAsync(string storeName, string key); Task DeleteStateAsync(string storeName, string key); } -public class DaprService : IDaprService { +public class DaprService : IDaprPublisherService, IDaprStateStoreService { private const string _errorMessage = "MaksIT.Core.Dapr - Data provider error"; private readonly DaprClient _client; diff --git a/src/MaksIT.Core.Dapr/Extensions/ServiceCollectionExtensions.cs b/src/MaksIT.Core.Dapr/Extensions/ServiceCollectionExtensions.cs index e5cbafd..f943d40 100644 --- a/src/MaksIT.Core.Dapr/Extensions/ServiceCollectionExtensions.cs +++ b/src/MaksIT.Core.Dapr/Extensions/ServiceCollectionExtensions.cs @@ -4,6 +4,11 @@ namespace MaksIT.Core.Dapr.Extensions; public static class ServiceCollectionExtensions { public static void RegisterPublisher(this IServiceCollection services) { services.AddDaprClient(); - services.AddSingleton(); + services.AddSingleton(); + } + + public static void RegisterStateStore(this IServiceCollection services) { + services.AddDaprClient(); + services.AddSingleton(); } } \ No newline at end of file diff --git a/src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj b/src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj index 3133595..c49722c 100644 --- a/src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj +++ b/src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj @@ -7,7 +7,7 @@ MaksIT.Core.Dapr - 1.0.1 + 1.0.2 Maksym Sadovnychyy MAKS-IT MaksIT.Core.Dapr