CmsKit - Implementation of EntityTag Domain logic

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Tags/EntityTag.cs

@@ -16,7 +16,7 @@ namespace Volo.CmsKit.Tags
         {
         }
 
-        public EntityTag(Guid tagId, string entityId, Guid? tenantId = null)
+        internal EntityTag(Guid tagId, string entityId, Guid? tenantId = null)
         {
             TagId = tagId;
             EntityId = entityId;
@@ -27,6 +27,5 @@ namespace Volo.CmsKit.Tags
         {
             return new object[] { TagId, EntityId };
         }
-
     }
 }

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Tags/EntityTagManager.cs

@@ -0,0 +1,52 @@
+using JetBrains.Annotations;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Services;
+using Volo.CmsKit.Tags;
+
+namespace Volo.CmsKit.Tags
+{
+    public class EntityTagManager : DomainService, IEntityTagManager
+    {
+        protected readonly IEntityTagRepository _entityTagRepository;
+        protected readonly ITagDefinitionStore _tagDefinitionStore;
+
+        public EntityTagManager(
+            IEntityTagRepository entityTagRepository,
+            ITagDefinitionStore tagDefinitionStore)
+        {
+            _entityTagRepository = entityTagRepository;
+            _tagDefinitionStore = tagDefinitionStore;
+        }
+
+        public async Task<EntityTag> AddTagToEntityAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityType,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId = null,
+            CancellationToken cancellationToken = default)
+        {
+            if (!await _tagDefinitionStore.IsDefinedAsync(entityType))
+            {
+                throw new EntityNotTaggableException(entityType);
+            }
+
+            var entityTag = new EntityTag(tagId, entityId, tenantId);
+
+            return await _entityTagRepository.InsertAsync(entityTag, cancellationToken: cancellationToken);
+        }
+
+        public async Task RemoveTagFromEntityAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityType,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId = null,
+            CancellationToken cancellationToken = default)
+        {
+            var entityTag = await _entityTagRepository.FindAsync(tagId, entityId, tenantId, cancellationToken);
+
+            await _entityTagRepository.DeleteAsync(entityTag);
+        }
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Tags/IEntityTagManager.cs

@@ -0,0 +1,24 @@
+using JetBrains.Annotations;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Volo.CmsKit.Tags
+{
+    public interface IEntityTagManager
+    {
+        Task<EntityTag> AddTagToEntityAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityType,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId = null,
+            CancellationToken cancellationToken = default);
+
+        Task RemoveTagFromEntityAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityType,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId = null,
+            CancellationToken cancellationToken = default);
+    }
+}

modules/cms-kit/src/Volo.CmsKit.Domain/Volo/CmsKit/Tags/IEntityTagRepository.cs

@@ -1,9 +1,17 @@
-using Volo.Abp.Domain.Repositories;
+using JetBrains.Annotations;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories;
 
 namespace Volo.CmsKit.Tags
 {
     public interface IEntityTagRepository : IBasicRepository<EntityTag>
     {
-        
+        Task<EntityTag> FindAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId,
+            CancellationToken cancellationToken = default);
     }
 }

modules/cms-kit/src/Volo.CmsKit.EntityFrameworkCore/Volo/CmsKit/Tags/EfCoreEntityTagRepository.cs

@@ -1,4 +1,8 @@
-using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
+using JetBrains.Annotations;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories.EntityFrameworkCore;
 using Volo.Abp.EntityFrameworkCore;
 using Volo.CmsKit.EntityFrameworkCore;
 
@@ -9,5 +13,18 @@ namespace Volo.CmsKit.Tags
         public EfCoreEntityTagRepository(IDbContextProvider<ICmsKitDbContext> dbContextProvider) : base(dbContextProvider)
         {
         }
+
+        public Task<EntityTag> FindAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId,
+            CancellationToken cancellationToken = default)
+        {
+            return base.FindAsync(x =>
+                        x.TagId == tagId &&
+                        x.EntityId == entityId &&
+                        x.TenantId == tenantId,
+                    cancellationToken: cancellationToken);
+        }
     }
 }

modules/cms-kit/src/Volo.CmsKit.MongoDB/Volo/CmsKit/MongoDB/Tags/MongoEntityTagRepository.cs

@@ -1,4 +1,8 @@
-using Volo.Abp.Domain.Repositories.MongoDB;
+using JetBrains.Annotations;
+using System;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Domain.Repositories.MongoDB;
 using Volo.Abp.MongoDB;
 using Volo.CmsKit.Tags;
 
@@ -9,5 +13,18 @@ namespace Volo.CmsKit.MongoDB.Tags
         public MongoEntityTagRepository(IMongoDbContextProvider<ICmsKitMongoDbContext> dbContextProvider) : base(dbContextProvider)
         {
         }
+
+        public Task<EntityTag> FindAsync(
+            [NotNull] Guid tagId,
+            [NotNull] string entityId,
+            [CanBeNull] Guid? tenantId,
+            CancellationToken cancellationToken = default)
+        {
+            return base.FindAsync(x =>
+                        x.TagId == tagId &&
+                        x.EntityId == entityId &&
+                        x.TenantId == tenantId,
+                    cancellationToken: cancellationToken);
+        }
     }
 }