SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Remove CachingBookmarkStore class and its references (#5354)

Browse source 
The class CachingBookmarkStore was removed from the project as it is no longer being used. The reference to this class in CachingWorkflowRuntimeFeature.cs was also eliminated as part of this change.
This commit is contained in:
Sipke Schoorstra 2024-05-08 20:07:44 +02:00 committed by GitHub
parent 6a0f74e06c
commit 7f65b0018a
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 1 additions and 67 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/modules/Elsa.Workflows.Runtime/Features/CachingWorkflowRuntimeFeature.cs
View file

@ -23,8 +23,6 @@ public class CachingWorkflowRuntimeFeature : FeatureBase
public override void Apply()
{
// Decorators.
Services
.Decorate<ITriggerStore, CachingTriggerStore>()
.Decorate<IBookmarkStore, CachingBookmarkStore>();
Services.Decorate<ITriggerStore, CachingTriggerStore>();
}
}

64
src/modules/Elsa.Workflows.Runtime/Stores/CachingBookmarkStore.cs
View file

@ -1,64 +0,0 @@
using Elsa.Caching;
using Elsa.Workflows.Contracts;
using Elsa.Workflows.Runtime.Contracts;
using Elsa.Workflows.Runtime.Entities;
using Elsa.Workflows.Runtime.Filters;
using Microsoft.Extensions.Caching.Memory;
namespace Elsa.Workflows.Runtime.Stores;
/// <summary>
/// A decorator for <see cref="IBookmarkStore"/> that caches bookmark records.
/// </summary>
public class CachingBookmarkStore(IBookmarkStore decoratedStore, ICacheManager cacheManager, IHasher hasher) : IBookmarkStore
{
private static readonly string CacheInvalidationTokenKey = typeof(CachingBookmarkStore).FullName!;
/// <inheritdoc />
public async ValueTask SaveAsync(StoredBookmark record, CancellationToken cancellationToken = default)
{
await cacheManager.TriggerTokenAsync(CacheInvalidationTokenKey, cancellationToken);
await decoratedStore.SaveAsync(record, cancellationToken);
}
/// <inheritdoc />
public async ValueTask SaveManyAsync(IEnumerable<StoredBookmark> records, CancellationToken cancellationToken)
{
await cacheManager.TriggerTokenAsync(CacheInvalidationTokenKey, cancellationToken);
await decoratedStore.SaveManyAsync(records, cancellationToken);
}
/// <inheritdoc />
public async ValueTask<StoredBookmark?> FindAsync(BookmarkFilter filter, CancellationToken cancellationToken = default)
{
var cacheKey = hasher.Hash(filter);
return (await GetOrCreateAsync(cacheKey, async () => await decoratedStore.FindAsync(filter, cancellationToken)))!;
}
/// <inheritdoc />
public async ValueTask<IEnumerable<StoredBookmark>> FindManyAsync(BookmarkFilter filter, CancellationToken cancellationToken = default)
{
var cacheKey = hasher.Hash(filter);
return (await GetOrCreateAsync(cacheKey, async () => await decoratedStore.FindManyAsync(filter, cancellationToken)))!;
}
/// <inheritdoc />
public async ValueTask<long> DeleteAsync(BookmarkFilter filter, CancellationToken cancellationToken = default)
{
await cacheManager.TriggerTokenAsync(CacheInvalidationTokenKey, cancellationToken);
return await decoratedStore.DeleteAsync(filter, cancellationToken);
}
private async ValueTask<T?> GetOrCreateAsync<T>(string key, Func<Task<T?>> factory)
{
var cacheEntry = await cacheManager.GetOrCreateAsync(key, async entry =>
{
var invalidationRequestToken = cacheManager.GetToken(CacheInvalidationTokenKey);
entry.AddExpirationToken(invalidationRequestToken);
entry.SetAbsoluteExpiration(cacheManager.CachingOptions.Value.CacheDuration);
return await factory();
});
return cacheEntry!;
}
}