MAKS-IT/maksit-dapr
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

(refactor): code review

Browse Source
This commit is contained in:
Maksym Sadovnychyy 2024-11-14 13:47:20 +01:00
parent c1204b67b2
commit d623e7c0b7
3 changed files with 13 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/MaksIT.Core.Dapr/DaprService.cs
View File

@ -5,14 +5,18 @@ using Dapr.Client;
using MaksIT.Results; using MaksIT.Results;
namespace MaksIT.Core.Dapr; namespace MaksIT.Core.Dapr;
public interface IDaprService {
public interface IDaprPublisherService {
Task<Result> PublishEventAsync(string pubSubName, string topicName, string payload); Task<Result> PublishEventAsync(string pubSubName, string topicName, string payload);
}
public interface IDaprStateStoreService {
Task<Result> SaveStateAsync<T>(string storeName, string key, T value); Task<Result> SaveStateAsync<T>(string storeName, string key, T value);
Task<Result<T?>> GetStateAsync<T>(string storeName, string key); Task<Result<T?>> GetStateAsync<T>(string storeName, string key);
Task<Result> DeleteStateAsync(string storeName, string key); Task<Result> 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 const string _errorMessage = "MaksIT.Core.Dapr - Data provider error";
private readonly DaprClient _client; private readonly DaprClient _client;

7
src/MaksIT.Core.Dapr/Extensions/ServiceCollectionExtensions.cs
View File

@ -4,6 +4,11 @@ namespace MaksIT.Core.Dapr.Extensions;
public static class ServiceCollectionExtensions { public static class ServiceCollectionExtensions {
public static void RegisterPublisher(this IServiceCollection services) { public static void RegisterPublisher(this IServiceCollection services) {
services.AddDaprClient(); services.AddDaprClient();
services.AddSingleton<IDaprService, DaprService>(); services.AddSingleton<IDaprPublisherService, DaprService>();
}
public static void RegisterStateStore(this IServiceCollection services) {
services.AddDaprClient();
services.AddSingleton<IDaprStateStoreService, DaprService>();
} }
} }

2
src/MaksIT.Core.Dapr/MaksIT.Core.Dapr.csproj
View File

@ -7,7 +7,7 @@
<!-- NuGet package metadata --> <!-- NuGet package metadata -->
<PackageId>MaksIT.Core.Dapr</PackageId> <PackageId>MaksIT.Core.Dapr</PackageId>
<Version>1.0.1</Version> <Version>1.0.2</Version>
<Authors>Maksym Sadovnychyy</Authors> <Authors>Maksym Sadovnychyy</Authors>
<Company>MAKS-IT</Company> <Company>MAKS-IT</Company>
<Product>MaksIT.Core.Dapr</Product> <Product>MaksIT.Core.Dapr</Product>