CmsKit: Rating app service and repository implementations

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Ratings/IRatingRepository.cs

@@ -1,10 +1,18 @@
 using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using JetBrains.Annotations;
 using Volo.Abp.Domain.Repositories;
 
 namespace Volo.CmsKit.Ratings
 {
     public interface IRatingRepository : IBasicRepository<Rating, Guid>
     {
-        
+        Task<List<Rating>> GetListAsync(
+            [NotNull] string entityType,
+            [NotNull] string entityId,
+            CancellationToken cancellationToken = default
+        );
     }
 }

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Ratings/Rating.cs

@@ -37,9 +37,21 @@ namespace Volo.CmsKit.Ratings
         {
             EntityType = Check.NotNullOrWhiteSpace(entityType, nameof(entityType), RatingConsts.MaxEntityTypeLength);
             EntityId = Check.NotNullOrWhiteSpace(entityId, nameof(entityId), RatingConsts.MaxEntityIdLength);
-            StarCount = starCount;
+            SetStarCount(starCount);
             CreatorId = creatorId;
             TenantId = tenantId;
         }
+
+        public virtual void SetStarCount(short starCount)
+        {
+            if(starCount <= 5 && starCount > 0)
+            {
+                StarCount = starCount;
+            }
+            else
+            {
+                throw new ArgumentOutOfRangeException("Choosen star must between 1 and 5");
+            }
+        }
     }
 }

modules/cms-kit/src/Volo.CmsKit.EntityFrameworkCore/Volo/CmsKit/Ratings/EfCoreRatingRepository.cs

@@ -1,4 +1,11 @@
 using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Linq.Dynamic.Core;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.EntityFrameworkCore;
+using Volo.Abp;
 using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
 using Volo.Abp.EntityFrameworkCore;
 using Volo.CmsKit.EntityFrameworkCore;
@@ -10,5 +17,16 @@ namespace Volo.CmsKit.Ratings
         public EfCoreRatingRepository(IDbContextProvider<ICmsKitDbContext> dbContextProvider) : base(dbContextProvider)
         {
         }
+
+        public async Task<List<Rating>> GetListAsync(string entityType, string entityId, CancellationToken cancellationToken = default)
+        {
+            Check.NotNullOrWhiteSpace(entityType, nameof(entityType));
+            Check.NotNullOrWhiteSpace(entityId, nameof(entityId));
+
+            var query = DbSet.Where(r => r.EntityType == entityType && r.EntityId == entityId);
+            var ratings = await query.ToListAsync(GetCancellationToken(cancellationToken));
+
+            return ratings;
+        }
     }
 }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/CmsKitMongoDbContext.cs

@@ -2,6 +2,7 @@
 using Volo.Abp.Data;
 using Volo.Abp.MongoDB;
 using Volo.CmsKit.Comments;
+using Volo.CmsKit.Ratings;
 using Volo.CmsKit.Reactions;
 using Volo.CmsKit.Users;
 
@@ -16,6 +17,8 @@ namespace Volo.CmsKit.MongoDB
 
         public IMongoCollection<CmsUser> CmsUsers => Collection<CmsUser>();
 
+        public IMongoCollection<Rating> Ratings => Collection<Rating>();
+
         protected override void CreateModel(IMongoModelBuilder modelBuilder)
         {
             base.CreateModel(modelBuilder);

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/CmsKitMongoDbContextExtensions.cs

@@ -2,6 +2,7 @@
 using Volo.Abp;
 using Volo.Abp.MongoDB;
 using Volo.CmsKit.Comments;
+using Volo.CmsKit.Ratings;
 using Volo.CmsKit.Reactions;
 using Volo.CmsKit.Users;
 
@@ -35,6 +36,11 @@ namespace Volo.CmsKit.MongoDB
             {
                 x.CollectionName = CmsKitDbProperties.DbTablePrefix + "Comments";
             });
+            
+            builder.Entity<Rating>(x =>
+            {
+                x.CollectionName = CmsKitDbProperties.DbTablePrefix + "Ratings";
+            });
         }
     }
 }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/CmsKitMongoDbModule.cs

@@ -4,8 +4,10 @@ using Volo.Abp.MongoDB;
 using Volo.Abp.Users.MongoDB;
 using Volo.CmsKit.Comments;
 using Volo.CmsKit.MongoDB.Comments;
+using Volo.CmsKit.MongoDB.Ratings;
 using Volo.CmsKit.MongoDB.Reactions;
 using Volo.CmsKit.MongoDB.Users;
+using Volo.CmsKit.Ratings;
 using Volo.CmsKit.Reactions;
 using Volo.CmsKit.Users;
 
@@ -25,6 +27,7 @@ namespace Volo.CmsKit.MongoDB
                 options.AddRepository<CmsUser, MongoCmsUserRepository>();
                 options.AddRepository<UserReaction, MongoUserReactionRepository>();
                 options.AddRepository<Comment, MongoCommentRepository>();
+                options.AddRepository<Rating, MongoRatingRepository>();
             });
         }
     }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/ICmsKitMongoDbContext.cs

@@ -2,6 +2,7 @@
 using Volo.Abp.Data;
 using Volo.Abp.MongoDB;
 using Volo.CmsKit.Comments;
+using Volo.CmsKit.Ratings;
 using Volo.CmsKit.Reactions;
 using Volo.CmsKit.Users;
 
@@ -15,5 +16,7 @@ namespace Volo.CmsKit.MongoDB
         IMongoCollection<Comment> Comments { get; }
 
         IMongoCollection<CmsUser> CmsUsers { get; }
+        
+        IMongoCollection<Rating> Ratings { get; }
     }
 }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/Ratings/MongoRatingRepository.cs

@@ -0,0 +1,31 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using MongoDB.Driver;
+using MongoDB.Driver.Linq;
+using Volo.Abp;
+using Volo.Abp.Domain.Repositories.MongoDB;
+using Volo.Abp.MongoDB;
+using Volo.CmsKit.Ratings;
+
+namespace Volo.CmsKit.MongoDB.Ratings
+{
+    public class MongoRatingRepository : MongoDbRepository<ICmsKitMongoDbContext, Rating, Guid>, IRatingRepository
+    {
+        public MongoRatingRepository(IMongoDbContextProvider<ICmsKitMongoDbContext> dbContextProvider) : base(dbContextProvider)
+        {
+        }
+
+        public async Task<List<Rating>> GetListAsync(string entityType, string entityId, CancellationToken cancellationToken = default)
+        {
+            Check.NotNullOrWhiteSpace(entityType, nameof(entityType));
+            Check.NotNullOrWhiteSpace(entityId, nameof(entityId));
+
+            var query = GetMongoQueryable().Where(r => r.EntityType == entityType && r.EntityId == entityId);
+            var ratings = await query.ToListAsync(GetCancellationToken(cancellationToken));
+
+            return ratings;
+        }
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Public.Application.Contracts/Volo.CmsKit.Public.Application.Contracts.csproj

@@ -1,15 +1,15 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <Import Project="..\..\..\..\common.props" />
-  <Import Project="..\..\..\..\configureawait.props" />
-
-  <PropertyGroup>
-    <TargetFramework>netstandard2.0</TargetFramework>
-    <RootNamespace />
-  </PropertyGroup>
-
-  <ItemGroup>
-    <ProjectReference Include="..\Volo.CmsKit.Common.Application.Contracts\Volo.CmsKit.Common.Application.Contracts.csproj" />
-  </ItemGroup>
-
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Import Project="..\..\..\..\common.props" />
+  <Import Project="..\..\..\..\configureawait.props" />
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+    <RootNamespace />
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Volo.CmsKit.Common.Application.Contracts\Volo.CmsKit.Common.Application.Contracts.csproj" />
+  </ItemGroup>
+
+</Project>

modules/cms-kit/src/Volo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Ratings/CreateRatingInput.cs

@@ -0,0 +1,10 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace Volo.CmsKit.Public.Ratings
+{
+    public class CreateRatingInput
+    {
+        [Required]
+        public short StarCount { get; set; }
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Ratings/IRatingPublicAppService.cs

@@ -0,0 +1,18 @@
+using System;
+using System.Threading.Tasks;
+using Volo.Abp.Application.Dtos;
+using Volo.Abp.Application.Services;
+
+namespace Volo.CmsKit.Public.Ratings
+{
+    public interface IRatingPublicAppService : IApplicationService
+    {
+        Task<ListResultDto<RatingDto>> GetListAsync(string entityType, string entityId);
+
+        Task<RatingDto> CreateAsync(string entityType, string entityId, CreateRatingInput input);
+
+        Task<RatingDto> UpdateAsync(Guid id, UpdateRatingInput input);
+
+        Task DeleteAsync(Guid id);
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Ratings/RatingDto.cs

@@ -0,0 +1,19 @@
+using System;
+
+namespace Volo.CmsKit.Public.Ratings
+{
+    public class RatingDto
+    {
+        public Guid Id { get; set; }
+
+        public string EntityType { get; set; }
+
+        public string EntityId { get; set; }
+        
+        public short StarCount { get; set; }
+        
+        public Guid CreatorId { get; set; }
+
+        public DateTime CreationTime { get; set; }
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Public.Application.Contracts/Volo/CmsKit/Public/Ratings/UpdateRatingInput.cs

@@ -0,0 +1,10 @@
+using System.ComponentModel.DataAnnotations;
+
+namespace Volo.CmsKit.Public.Ratings
+{
+    public class UpdateRatingInput
+    {
+        [Required]
+        public short StarCount { get; set; }
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Public.Application/Volo.CmsKit.Public.Application.csproj

@@ -1,16 +1,16 @@
-<Project Sdk="Microsoft.NET.Sdk">
-
-  <Import Project="..\..\..\..\common.props" />
-  <Import Project="..\..\..\..\configureawait.props" />
-
-  <PropertyGroup>
-    <TargetFramework>netstandard2.0</TargetFramework>
-    <RootNamespace />
-  </PropertyGroup>
-
-  <ItemGroup>
-    <ProjectReference Include="..\Volo.CmsKit.Common.Application\Volo.CmsKit.Common.Application.csproj" />
-    <ProjectReference Include="..\Volo.CmsKit.Public.Application.Contracts\Volo.CmsKit.Public.Application.Contracts.csproj" />
-  </ItemGroup>
-
-</Project>
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Import Project="..\..\..\..\common.props" />
+  <Import Project="..\..\..\..\configureawait.props" />
+
+  <PropertyGroup>
+    <TargetFramework>netstandard2.0</TargetFramework>
+    <RootNamespace />
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Volo.CmsKit.Common.Application\Volo.CmsKit.Common.Application.csproj" />
+    <ProjectReference Include="..\Volo.CmsKit.Public.Application.Contracts\Volo.CmsKit.Public.Application.Contracts.csproj" />
+  </ItemGroup>
+
+</Project>

modules/cms-kit/src/Volo.CmsKit.Public.Application/Volo/CmsKit/Public/Ratings/RatingPublicAppService.cs

@@ -0,0 +1,82 @@
+using System;
+using System.Collections.Generic;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Authorization;
+using Volo.Abp.Application.Dtos;
+using Volo.Abp.Application.Services;
+using Volo.Abp.Authorization;
+using Volo.Abp.Users;
+using Volo.CmsKit.Ratings;
+using Volo.CmsKit.Users;
+
+namespace Volo.CmsKit.Public.Ratings
+{
+    public class RatingPublicAppService : ApplicationService, IRatingPublicAppService
+    {
+        protected IRatingRepository RatingRepository { get; }
+        public ICmsUserLookupService CmsUserLookupService { get; }
+
+        public RatingPublicAppService(IRatingRepository ratingRepository, ICmsUserLookupService cmsUserLookupService)
+        {
+            RatingRepository = ratingRepository;
+            CmsUserLookupService = cmsUserLookupService;
+        }
+
+        public virtual async Task<ListResultDto<RatingDto>> GetListAsync(string entityType, string entityId)
+        {
+            var ratings = await RatingRepository.GetListAsync(entityType, entityId);
+            var ratingDto = ObjectMapper.Map<List<Rating>, List<RatingDto>>(ratings);
+
+            return new ListResultDto<RatingDto>(ratingDto);
+        }
+
+        [Authorize]
+        public virtual async Task<RatingDto> CreateAsync(string entityType, string entityId, CreateRatingInput input)
+        {
+            var user = await CmsUserLookupService.GetByIdAsync(CurrentUser.GetId());
+
+            var rating = await RatingRepository.InsertAsync(
+                new Rating(
+                    GuidGenerator.Create(),
+                    entityType,
+                    entityId,
+                    input.StarCount,
+                    user.Id,
+                    CurrentTenant.Id
+                )
+            );
+
+            return ObjectMapper.Map<Rating, RatingDto>(rating);
+        }
+
+        [Authorize]
+        public virtual async Task<RatingDto> UpdateAsync(Guid id, UpdateRatingInput input)
+        {
+            var rating = await RatingRepository.GetAsync(id);
+
+            if (rating.CreatorId != CurrentUser.GetId())
+            {
+                throw new AbpAuthorizationException();
+            }
+            
+            rating.SetStarCount(input.StarCount);
+
+            var updatedRating = await RatingRepository.UpdateAsync(rating);
+
+            return ObjectMapper.Map<Rating, RatingDto>(updatedRating);
+        }
+
+        [Authorize]
+        public virtual async Task DeleteAsync(Guid id)
+        {
+            var rating = await RatingRepository.GetAsync(id);
+
+            if (rating.CreatorId != CurrentUser.GetId())
+            {
+                throw new AbpAuthorizationException();
+            }
+
+            await RatingRepository.DeleteAsync(id);
+        }
+    }
+}