Skip to content

Commit 9576acf

Browse files
committed
Fixed an issue where cached paged queries were note being removed properly.
1 parent 48b0065 commit 9576acf

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

src/Exceptionless.Core/Repositories/Base/RepositoryOwnedByOrganization.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,7 @@ private Task OnDocumentsAdded(object sender, DocumentsEventArgs<T> documents) {
5353
protected virtual async Task InvalidateCachedQueriesAsync(IReadOnlyCollection<T> documents, ICommandOptions options = null) {
5454
var organizations = documents.Select(d => d.OrganizationId).Distinct().Where(id => !String.IsNullOrEmpty(id));
5555
foreach (string organizationId in organizations)
56-
await Cache.RemoveByPrefixAsync($"paged:Organization:{organizationId}:").AnyContext();
56+
await Cache.RemoveByPrefixAsync($"paged:Organization:{organizationId}").AnyContext();
5757
}
5858
}
5959
}

src/Exceptionless.Core/Repositories/UserRepository.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -89,7 +89,7 @@ private Task OnDocumentsAdded(object sender, DocumentsEventArgs<User> documents)
8989
protected virtual async Task InvalidateCachedQueriesAsync(IReadOnlyCollection<User> documents, ICommandOptions options = null) {
9090
var organizations = documents.SelectMany(d => d.OrganizationIds).Distinct().Where(id => !String.IsNullOrEmpty(id));
9191
foreach (string organizationId in organizations)
92-
await Cache.RemoveByPrefixAsync($"paged:Organization:{organizationId}:").AnyContext();
92+
await Cache.RemoveByPrefixAsync($"paged:Organization:{organizationId}").AnyContext();
9393
}
9494
}
9595
}

src/Exceptionless.Core/Repositories/WebHookRepository.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ await Cache.RemoveAllAsync(documents.Select(d => d.Value)
4949
}
5050

5151
protected override async Task InvalidateCachedQueriesAsync(IReadOnlyCollection<WebHook> documents, ICommandOptions options = null) {
52-
var keysToRemove = documents.Select(d => $"paged:Organization:{d.OrganizationId}:Project:{d.ProjectId}:").Distinct();
52+
var keysToRemove = documents.Select(d => $"paged:Organization:{d.OrganizationId}:Project:{d.ProjectId}").Distinct();
5353
foreach (string key in keysToRemove)
5454
await Cache.RemoveByPrefixAsync(key).AnyContext();
5555

0 commit comments

Comments
 (0)