Add remaining read-only implementation to respect caches

astro-panda · Apr 7, 2023 · 6c41fd1 · 6c41fd1
1 parent 7e8db88
commit 6c41fd1
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 4 deletions.
diff --git a/src/DefaultCachedRepository.cs b/src/DefaultCachedRepository.cs
@@ -17,6 +17,7 @@ public class DefaultCachedRepository<TEntity, TContext> : RepositoryBase<TEntity
     public DefaultCachedRepository(TContext dbFactory) : base(dbFactory)
     {
     }
+
 
     public override async Task<IEnumerable<TEntity>> GetAllAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
     {
@@ -34,6 +35,22 @@ public override async Task<IEnumerable<TEntity>> GetAllAsync(CancellationToken c
         return cachedEntities;
     }
 
+    public override async Task<TEntity> GetAsync(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
+    {
+        if (cachedEntities.Any() == false)
+            await RefreshCache(cancellationToken);
+
+        return cachedEntities.FirstOrDefault(predicate.Compile());
+    }
+
+    public override async Task<bool> Exists(Expression<Func<TEntity, bool>> predicate, CancellationToken cancellationToken = default)
+    {
+        if (cachedEntities.Any() == false)
+            await RefreshCache(cancellationToken);
+
+        return cachedEntities.Any(predicate.Compile());
+    }
+
     public async Task RefreshCache(CancellationToken cancellationToken = default)
     {
         cachedEntities = await base.GetAllAsync(cancellationToken);

diff --git a/src/Interfaces/IReadOnlyRepository.cs b/src/Interfaces/IReadOnlyRepository.cs
@@ -15,27 +15,31 @@ namespace BasicRepos
     public interface IReadOnlyRepository<T> where T : class
     {
         /// <summary>
-        /// Allows for the internal entities to be queried with any type specifications
+        /// Allows for the internal entities to be queried with any type specifications.
+        /// Bypasses entity caches
         /// </summary>
         /// <returns>A facade for the internal <see cref="DbSet{TEntity}"/></returns>
         IQueryable<T> Query();
 
         /// <summary>
-        /// Allows for the internal entities to be queried with any type specifications
+        /// Allows for the internal entities to be queried with any type specifications.
+        /// Bypasses entity caches
         /// </summary>
         /// <returns>A facade for the internal <see cref="DbSet{TEntity}"/></returns>
         IQueryable<T> Query(Expression<Func<T, bool>> predicate);
 
         /// <summary>
-        /// Allows for the internal entities to be queried with any type specifications
+        /// Allows for the internal entities to be queried with any type specifications.
+        /// Bypasses entity caches.
         /// </summary>
         /// <returns>A facade for the internal <see cref="DbSet{TEntity}"/></returns>
         IQueryable<K> Query<K>() where K : T;
 
         /// <summary>
         /// Allows for the internal entities to be queried without any type specifications
+        /// Bypasses entity caches
         /// </summary>
-        /// <returns>A facade for the internal <see cref="DbSet{TEntity}"/></returns>
+        /// <returns>A façade for the internal <see cref="DbSet{TEntity}"/></returns>
         IQueryable RawQuery();
 
         /// <summary>