diff --git a/Core.Blueprint.DAL.Mongo/Service/MongoSampleService.cs b/Core.Blueprint.DAL.Mongo/Service/MongoSampleService.cs index 27089cb..9a0164f 100644 --- a/Core.Blueprint.DAL.Mongo/Service/MongoSampleService.cs +++ b/Core.Blueprint.DAL.Mongo/Service/MongoSampleService.cs @@ -29,6 +29,8 @@ namespace Core.Blueprint.DAL.Mongo.Service await this.repository.InsertOneAsync(sampleCollection); + await ResetCollectionCache(); + return sampleCollection; } @@ -65,15 +67,33 @@ namespace Core.Blueprint.DAL.Mongo.Service public async ValueTask UpdateSample(string _id, SampleCollection entity, CancellationToken cancellationToken) { await this.repository.ReplaceOneAsync(entity); + + await ResetCollectionCache(); return entity; } + public async ValueTask DeleteSample(string _id, CancellationToken cancellationToken) { var entity = await this.repository.DeleteOneAsync(doc => doc._Id == _id); + + await ResetCollectionCache(); return entity; + } + + /// + /// Temporary method to "reset" collections cache + /// + /// + private async Task ResetCollectionCache() + { + //TODO: remoge this mehtod when necessary. + var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllSamples"); + + await cacheProvider.SetAsync(cacheKey, Enumerable.Empty(), null); } + } }