CmsKit - Add Existence check for blog

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Blogs/BlogPostManager.cs

@@ -3,6 +3,7 @@ using System.Collections.Generic;
 using System.Linq;
 using System.Text;
 using System.Threading.Tasks;
+using Volo.Abp.Domain.Entities;
 using Volo.Abp.Domain.Services;
 
 namespace Volo.CmsKit.Blogs
@@ -48,7 +49,8 @@ namespace Volo.CmsKit.Blogs
 
         private async Task CheckBlogExistenceAsync(Guid blogId)
         {
-            await blogRepository.GetAsync(blogId);
+            if (!await blogRepository.ExistsAsync(blogId))
+                throw new EntityNotFoundException(typeof(Blog), blogId);
         }
     }
 }

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Blogs/IBlogRepository.cs

@@ -5,5 +5,6 @@ namespace Volo.CmsKit.Blogs
 {
     public interface IBlogRepository : IBasicRepository<Blog, Guid>
     {
+        Task<bool> ExistsAsync(Guid blogId);
     }
 }

modules/cms-kit/src/Volo.CmsKit.EntityFrameworkCore/Volo/CmsKit/Blogs/EfCoreBlogRepository.cs

@@ -1,4 +1,6 @@
-using System;
+using Microsoft.EntityFrameworkCore;
+using System;
+using System.Threading.Tasks;
 using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
 using Volo.Abp.EntityFrameworkCore;
 using Volo.CmsKit.EntityFrameworkCore;
@@ -10,5 +12,10 @@ namespace Volo.CmsKit.Blogs
         public EfCoreBlogRepository(IDbContextProvider<ICmsKitDbContext> dbContextProvider) : base(dbContextProvider)
         {
         }
+
+        public async Task<bool> ExistsAsync(Guid blogId)
+        {
+            return await (await GetQueryableAsync()).AnyAsync(x => x.Id == blogId);
+        }
     }
 }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/Blogs/MongoBlogRepository.cs

@@ -1,4 +1,5 @@
-using System;
+using MongoDB.Driver.Core.Operations;
+using System;
 using Volo.Abp.Domain.Repositories.MongoDB;
 using Volo.Abp.MongoDB;
 using Volo.CmsKit.Blogs;
@@ -10,5 +11,12 @@ namespace Volo.CmsKit.MongoDB.Blogs
         public MongoBlogRepository(IMongoDbContextProvider<ICmsKitMongoDbContext> dbContextProvider) : base(dbContextProvider)
         {
         }
+
+        public async Task<bool> ExistsAsync(Guid blogId)
+        {
+            return await AsyncExecuter.AnyAsync(
+                            await GetQueryableAsync(),
+                            x => x.Id == blogId);
+        }
     }
 }