(bugfix): get dapr stete empty result should be not found error
This commit is contained in:
parent
d623e7c0b7
commit
7ab3e848ba
@ -11,7 +11,7 @@ public interface IDaprPublisherService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public interface IDaprStateStoreService {
|
public interface IDaprStateStoreService {
|
||||||
Task<Result> SaveStateAsync<T>(string storeName, string key, T value);
|
Task<Result> SetStateAsync<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);
|
||||||
}
|
}
|
||||||
@ -56,7 +56,7 @@ public class DaprService : IDaprPublisherService, IDaprStateStoreService {
|
|||||||
/// <param name="key"></param>
|
/// <param name="key"></param>
|
||||||
/// <param name="value"></param>
|
/// <param name="value"></param>
|
||||||
/// <returns></returns>
|
/// <returns></returns>
|
||||||
public async Task<Result> SaveStateAsync<T>(string storeName, string key, T value) {
|
public async Task<Result> SetStateAsync<T>(string storeName, string key, T value) {
|
||||||
try {
|
try {
|
||||||
await _client.SaveStateAsync(storeName, key, value);
|
await _client.SaveStateAsync(storeName, key, value);
|
||||||
return Result.Ok();
|
return Result.Ok();
|
||||||
@ -77,6 +77,9 @@ public class DaprService : IDaprPublisherService, IDaprStateStoreService {
|
|||||||
public async Task<Result<T?>> GetStateAsync<T>(string storeName, string key) {
|
public async Task<Result<T?>> GetStateAsync<T>(string storeName, string key) {
|
||||||
try {
|
try {
|
||||||
var state = await _client.GetStateAsync<T?>(storeName, key);
|
var state = await _client.GetStateAsync<T?>(storeName, key);
|
||||||
|
if (state == null)
|
||||||
|
return Result<T?>.NotFound(default, $"State from the store {storeName} with the {key} not found.");
|
||||||
|
|
||||||
return Result<T?>.Ok(state);
|
return Result<T?>.Ok(state);
|
||||||
}
|
}
|
||||||
catch (Exception ex) {
|
catch (Exception ex) {
|
||||||
|
|||||||
@ -7,7 +7,7 @@
|
|||||||
|
|
||||||
<!-- NuGet package metadata -->
|
<!-- NuGet package metadata -->
|
||||||
<PackageId>MaksIT.Core.Dapr</PackageId>
|
<PackageId>MaksIT.Core.Dapr</PackageId>
|
||||||
<Version>1.0.2</Version>
|
<Version>1.0.3</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>
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user