Add TagType CRUD

Core.Inventory.Provider/Contracts/ITagOverrideProvider.cs

@@ -0,0 +1,59 @@
+using Core.Adapters.Lib;
+using Core.Blueprint.Mongo;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+
+namespace Core.Inventory.Provider.Contracts
+{
+    public interface ITagOverrideProvider
+    {
+        /// <summary>
+        /// Creates a new TagOverride.
+        /// </summary>
+        /// <param name="entity">The TagOverride to be created.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagOverrideAdapter> CreateTagOverride(TagOverrideRequest newTagOverride, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets an TagOverride by identifier.
+        /// </summary>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagOverrideAdapter> GetTagOverrideById(string _id, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the TagOverrides.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagOverrideAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagOverrideAdapter>> GetAllTagOverrides(CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the TagOverrides by TagOverrides identifier list.
+        /// </summary>
+        /// <param name="TagOverrides">The list of TagOverrides identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagOverrideAdapter>> GetAllTagOverridesByList(string[] tagOverrides, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Changes the status of the TagOverride.
+        /// </summary>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <param name="newStatus">The new status of the TagOverride.</param>
+        /// <returns>The <see cref="TagOverrideAdapter"/> updated entity.</returns>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagOverrideAdapter> ChangeTagOverrideStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Updates a TagOverride by id.
+        /// </summary>
+        /// <param name="entity">The TagOverride to be updated.</param>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagOverrideAdapter> UpdateTagOverride(TagOverrideAdapter entity, CancellationToken cancellationToken);
+    }
+}

Core.Inventory.Provider/Providers/Inventory/TagOverrideProvider.cs

@@ -0,0 +1,149 @@
+using Core.Adapters.Lib;
+using Core.Blueprint.Mongo;
+using Core.Blueprint.Redis;
+using Core.Blueprint.Redis.Helpers;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+using Core.Inventory.Provider.Contracts;
+using Mapster;
+using Microsoft.Extensions.Options;
+using MongoDB.Driver;
+
+namespace Core.Inventory.Provider.Providers.Inventory
+{
+    /// <summary>
+    /// Handles all services and business rules related to <see cref="TagOverrideAdapter"/>.
+    /// </summary>
+    public class TagOverrideProvider : ITagOverrideProvider
+    {
+        private readonly CollectionRepository<TagOverrideAdapter> repository;
+        private readonly CacheSettings cacheSettings;
+        private readonly IRedisCacheProvider cacheProvider;
+
+        public TagOverrideProvider(CollectionRepository<TagOverrideAdapter> repository,
+            IRedisCacheProvider cacheProvider,
+            IOptions<CacheSettings> cacheSettings)
+        {
+            this.repository = repository;
+            this.repository.CollectionInitialization();
+            this.cacheSettings = cacheSettings.Value;
+            this.cacheProvider = cacheProvider;
+        }
+
+        /// <summary>
+        /// Creates a new TagOverride.
+        /// </summary>
+        /// <param name="entity">The TagOverride to be created.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagOverrideAdapter> CreateTagOverride(TagOverrideRequest newTagOverride, CancellationToken cancellationToken)
+        {
+            var tagOverrideCollection = newTagOverride.Adapt<TagOverrideAdapter>();
+
+            await repository.InsertOneAsync(tagOverrideCollection);
+
+            return tagOverrideCollection;
+        }
+
+        /// <summary>
+        /// Gets an TagOverride by identifier.
+        /// </summary>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>0
+        public async ValueTask<TagOverrideAdapter> GetTagOverrideById(string _id, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagOverrideById", _id);
+            var cachedData = await cacheProvider.GetAsync<TagOverrideAdapter>(cacheKey);
+
+            if (cachedData is not null) { return cachedData; }
+
+            var TagOverride = await repository.FindByIdAsync(_id);
+
+            await cacheProvider.SetAsync(cacheKey, TagOverride);
+
+            return TagOverride;
+        }
+
+        /// <summary>
+        /// Gets all the TagOverrides.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagOverrideAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagOverrideAdapter>> GetAllTagOverrides(CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagOverrides");
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagOverrideAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var TagOverrides = await repository.AsQueryable();
+
+            await cacheProvider.SetAsync(cacheKey, TagOverrides);
+
+            return TagOverrides;
+        }
+
+        /// <summary>
+        /// Gets all the TagOverrides by TagOverrides identifier list.
+        /// </summary>
+        /// <param name="TagOverrides">The list of TagOverrides identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagOverrideAdapter>> GetAllTagOverridesByList(string[] tagOverrides, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllTagOverridesByList", tagOverrides);
+
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagOverrideAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var builder = Builders<TagOverrideAdapter>.Filter;
+            var filters = new List<FilterDefinition<TagOverrideAdapter>>();
+
+            if (tagOverrides != null || !tagOverrides.Any())
+            {
+                filters.Add(builder.In(x => x._Id, tagOverrides));
+            }
+
+            var finalFilter = filters.Any() ? builder.And(filters) : builder.Empty;
+
+            var TagOverridesList = await repository.FilterByMongoFilterAsync(finalFilter);
+
+            await cacheProvider.SetAsync(cacheKey, TagOverridesList);
+
+            return TagOverridesList;
+        }
+
+
+        /// <summary>
+        /// Changes the status of the TagOverride.
+        /// </summary>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <param name="newStatus">The new status of the TagOverride.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagOverrideAdapter> ChangeTagOverrideStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken)
+        {
+            var entity = await repository.FindByIdAsync(id);
+            entity.Status = newStatus;
+
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Updates a TagOverride by id.
+        /// </summary>
+        /// <param name="entity">The TagOverride to be updated.</param>
+        /// <param name="id">The TagOverride identifier.</param>
+        /// <returns>A <see cref="{Task{TagOverrideAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagOverrideAdapter> UpdateTagOverride(TagOverrideAdapter entity, CancellationToken cancellationToken)
+        {
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+    }
+}

Core.Inventory.Provider/ServiceCollectionExtensions.cs

@@ -24,6 +24,9 @@ namespace Core.Inventory.Provider
             services.AddScoped<ITagProvider, TagProvider>();
             services.AddScoped<CollectionRepository<TagAdapter>>();
 
+            services.AddScoped<ITagOverrideProvider, TagOverrideProvider>();
+            services.AddScoped<CollectionRepository<TagOverrideAdapter>>();
+
             services.AddScoped<IProductProvider, ProductProvider>();
             services.AddScoped<CollectionRepository<ProductAdapter>>();