Publish an event on comment creation for the CMS Kit

resolves #5463
abpframework · Oct 26, 2020 · 99dbc8d · 99dbc8d
1 parent 4e792e2
commit 99dbc8d
Show file tree

Hide file tree

Showing 4 changed files with 31 additions and 1 deletion.
diff --git a/.../Volo.CmsKit.Public.Application.Contracts/Volo.CmsKit.Public.Application.Contracts.csproj b/.../Volo.CmsKit.Public.Application.Contracts/Volo.CmsKit.Public.Application.Contracts.csproj
@@ -10,6 +10,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\Volo.CmsKit.Common.Application.Contracts\Volo.CmsKit.Common.Application.Contracts.csproj" />
+    <ProjectReference Include="..\..\..\..\framework\src\Volo.Abp.EventBus\Volo.Abp.EventBus.csproj" />
   </ItemGroup>
 
 </Project>
diff --git a/...Public.Application.Contracts/Volo/CmsKit/Public/CmsKitPublicApplicationContractsModule.cs b/...Public.Application.Contracts/Volo/CmsKit/Public/CmsKitPublicApplicationContractsModule.cs
@@ -1,9 +1,11 @@
 using Volo.Abp.Modularity;
+using Volo.Abp.EventBus;
 
 namespace Volo.CmsKit.Public
 {
     [DependsOn(
-        typeof(CmsKitCommonApplicationContractsModule)
+        typeof(CmsKitCommonApplicationContractsModule),
+        typeof(AbpEventBusModule)
         )]
     public class CmsKitPublicApplicationContractsModule : AbpModule
     {

diff --git a/...lo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Comments/CreatedCommentEvent.cs b/...lo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Comments/CreatedCommentEvent.cs
@@ -0,0 +1,11 @@
+using System;
+using Volo.Abp.EventBus;
+
+namespace Volo.CmsKit.Public.Comments
+{
+    [EventName("Volo.CmsKit.Comments.Created")]
+    public class CreatedCommentEvent
+    {
+        public Guid Id { get; set; }
+    }
+}
diff --git a/...src/Volo.CmsKit.Public.Application/Volo/CmsKit/Public/Comments/CommentPublicAppService.cs b/...src/Volo.CmsKit.Public.Application/Volo/CmsKit/Public/Comments/CommentPublicAppService.cs
@@ -7,6 +7,8 @@
 using Volo.Abp;
 using Volo.Abp.Application.Dtos;
 using Volo.Abp.Application.Services;
+using Volo.Abp.EventBus.Distributed;
+using Volo.Abp.Uow;
 using Volo.Abp.Users;
 using Volo.CmsKit.Comments;
 using Volo.CmsKit.Users;
@@ -18,15 +20,21 @@ public class CommentPublicAppService : ApplicationService, ICommentPublicAppServ
         protected CmsKitOptions CmsKitOptions { get; }
         protected ICommentRepository CommentRepository { get; }
         protected ICmsUserLookupService CmsUserLookupService { get; }
+        public IDistributedEventBus DistributedEventBus { get; }
+        public IUnitOfWorkManager UnitOfWorkManager { get; }
 
         public CommentPublicAppService(
             ICommentRepository commentRepository,
             ICmsUserLookupService cmsUserLookupService,
+            IDistributedEventBus distributedEventBus,
+            IUnitOfWorkManager unitOfWorkManager,
             IOptions<CmsKitOptions> cmsKitOptions)
         {
             CmsKitOptions = cmsKitOptions.Value;
             CommentRepository = commentRepository;
             CmsUserLookupService = cmsUserLookupService;
+            DistributedEventBus = distributedEventBus;
+            UnitOfWorkManager = unitOfWorkManager;
         }
 
         public virtual async Task<ListResultDto<CommentWithDetailsDto>> GetListAsync(string entityType, string entityId)
@@ -56,6 +64,14 @@ public virtual async Task<CommentDto> CreateAsync(string entityType, string enti
                 )
             );
 
+
+            await UnitOfWorkManager.Current.SaveChangesAsync();
+
+            await DistributedEventBus.PublishAsync(new CreatedCommentEvent
+            {
+                Id = comment.Id
+            });
+
             return ObjectMapper.Map<Comment, CommentDto>(comment);
         }