Merge remote-tracking branch 'origin/development' into feature/create-Product-and-ProductTag-CRUD(DAL)

- fix: adapters package updated
- fix: status property renamed

Core.Inventory.DAL.API/Controllers/FurnitureBaseController.cs

@@ -40,12 +40,12 @@ namespace Core.Inventory.DAL.API.Controllers
         /// Gets a furniture base record by ID.
         /// </summary>
         [HttpGet]
-        [Route("{id}")]
+        [Route("{mongoId}")]
         [ProducesResponseType(typeof(FurnitureBase), StatusCodes.Status200OK)]
         [ProducesResponseType(StatusCodes.Status404NotFound)]
-        public async Task<IActionResult> GetByIdAsync([FromRoute] string id, CancellationToken cancellationToken)
+        public async Task<IActionResult> GetByIdAsync([FromRoute] string mongoId, CancellationToken cancellationToken)
         {
-            var result = await service.GetByIdAsync(id, cancellationToken);
+            var result = await service.GetByIdAsync(mongoId, cancellationToken);
             return result is not null ? Ok(result) : NotFound("Entity not found");
         }
 
@@ -80,11 +80,11 @@ namespace Core.Inventory.DAL.API.Controllers
         /// Changes the status of a furniture base record.
         /// </summary>
         [HttpPatch]
-        [Route("{id}/{newStatus}/ChangeStatus")]
+        [Route("{mongoId}/{newStatus}/ChangeStatus")]
         [ProducesResponseType(typeof(FurnitureBase), StatusCodes.Status200OK)]
-        public async Task<IActionResult> ChangeStatusAsync([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
+        public async Task<IActionResult> ChangeStatusAsync([FromRoute] string mongoId, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
         {
-            var result = await service.ChangeStatusAsync(id, newStatus, cancellationToken);
+            var result = await service.ChangeStatusAsync(mongoId, newStatus, cancellationToken);
             return Ok(result);
         }
     }

Core.Inventory.DAL.API/Controllers/FurnitureVariantController.cs

@@ -25,12 +25,25 @@ namespace Core.Inventory.DAL.API.Controllers
     [AllowAnonymous]
     public class FurnitureVariantController(IFurnitureVariantProvider service) : ControllerBase
     {
+
         /// <summary>
         /// Gets all furniture variant records.
         /// </summary>
         [HttpGet]
         [ProducesResponseType(typeof(IEnumerable<FurnitureVariant>), StatusCodes.Status200OK)]
-        public async Task<IActionResult> GetAllVariantsByModelIdAsync([FromRoute] string modelId, CancellationToken cancellationToken)
+        public async Task<IActionResult> GetAllAsync(CancellationToken cancellationToken)
+        {
+            var result = await service.GetAllAsync(cancellationToken);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Gets all furniture variant records by ModelId.
+        /// </summary>
+        [HttpGet]
+        [Route("ByModel/{modelId}")]
+        [ProducesResponseType(typeof(IEnumerable<FurnitureVariant>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllVariantsByModelIdAsync(string modelId, CancellationToken cancellationToken)
         {
             var result = await service.GetAllByModelIdAsync(modelId, cancellationToken).ConfigureAwait(false);
 
@@ -46,15 +59,38 @@ namespace Core.Inventory.DAL.API.Controllers
         /// Gets a furniture variant record by ID.
         /// </summary>
         [HttpGet]
-        [Route("{id}")]
+        [Route("{mongoId}")]
         [ProducesResponseType(typeof(FurnitureVariant), StatusCodes.Status200OK)]
         [ProducesResponseType(StatusCodes.Status404NotFound)]
-        public async Task<IActionResult> GetByIdAsync([FromRoute] string id, CancellationToken cancellationToken)
+        public async Task<IActionResult> GetByIdAsync([FromRoute] string mongoId, CancellationToken cancellationToken)
         {
-            var result = await service.GetByIdAsync(id, cancellationToken);
+            var result = await service.GetByIdAsync(mongoId, cancellationToken);
             return result is not null ? Ok(result) : NotFound("Entity not found");
         }
 
+        /// <summary>
+        /// Gets multiple furniture variants by their identifiers.
+        /// </summary>
+        /// <param name="request">List of variant IDs.</param>
+        /// <param name="cancellationToken">Cancellation token.</param>
+        /// <returns>A list of <see cref="FurnitureVariant"/>.</returns>
+        [HttpPost("ByIds")]
+        [ProducesResponseType(typeof(IEnumerable<FurnitureVariant>), StatusCodes.Status200OK)]
+        [ProducesResponseType(StatusCodes.Status204NoContent)]
+        [ProducesResponseType(StatusCodes.Status400BadRequest)]
+        public async Task<IActionResult> GetVariantsByIdsAsync([FromBody] string[] ids, CancellationToken cancellationToken)
+        {
+            if (ids is null || ids.Length == 0)
+                return BadRequest("At least one variant ID must be provided.");
+
+            var result = await service.GetAllByIdsAsync(ids, cancellationToken);
+
+            if (result is null || !result.Any())
+                return NoContent();
+
+            return Ok(result);
+        }
+
         /// <summary>
         /// Creates a new furniture variant.
         /// </summary>
@@ -86,11 +122,11 @@ namespace Core.Inventory.DAL.API.Controllers
         /// Changes the status of a furniture variant record.
         /// </summary>
         [HttpPatch]
-        [Route("{id}/{newStatus}/ChangeStatus")]
+        [Route("{mongoId}/{newStatus}/ChangeStatus")]
         [ProducesResponseType(typeof(FurnitureVariant), StatusCodes.Status200OK)]
-        public async Task<IActionResult> ChangeStatusAsync([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
+        public async Task<IActionResult> ChangeStatusAsync([FromRoute] string mongoId, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
         {
-            var result = await service.ChangeStatusAsync(id, newStatus, cancellationToken);
+            var result = await service.ChangeStatusAsync(mongoId, newStatus, cancellationToken);
             return Ok(result);
         }
     }

Core.Inventory.DAL.API/Controllers/ProductController.cs

@@ -0,0 +1,231 @@
+using Asp.Versioning;
+using Core.Adapters.Lib.Inventory;
+using Core.Blueprint.Logging;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+using Core.Inventory.Provider.Contracts;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Core.Inventory.DAL.API.Controllers
+{
+    /// <summary>
+    /// Handles all requests for Product operations.
+    /// </summary>
+    [ApiVersion(MimeTypes.ApplicationVersion)]
+    [Route("api/v{api-version:apiVersion}/[controller]")]
+    [Produces(MimeTypes.ApplicationJson)]
+    [Consumes(MimeTypes.ApplicationJson)]
+    [ApiController]
+    [AllowAnonymous]
+    public class ProductController(IProductProvider service) : ControllerBase
+    {
+        /// <summary>
+        /// Gets all the Products.
+        /// </summary>
+        /// <returns>The <see cref="IEnumerable{ProductAdapter}"/> found entities.</returns>
+        /// <response code="200">The products found.</response>
+        /// <response code="404">The products not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<ProductAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllProductsAsync(CancellationToken cancellationToken)
+        {
+            var result = await service.GetAllProducts(cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Gets all the Products by Product identifiers.
+        /// </summary>
+        /// <param name="products">The list of Product identifiers.</param>
+        /// <returns>The <see cref="IEnumerable{ProductAdapter}"/> found entities.</returns>
+        /// <response code="200">The Products found.</response>
+        /// <response code="404">The Products not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [Route("GetProductList")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<ProductAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllProductsByList([FromBody] string[] products, CancellationToken cancellationToken)
+        {
+            if (products == null || !products.Any())
+            {
+                return BadRequest("Product identifiers are required.");
+            }
+
+            var result = await service.GetAllProductsByList(products, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Gets the Product by identifier.
+        /// </summary>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>The <see cref="ProductAdapter"/> found entity.</returns>
+        /// <response code="200">The Product found.</response>
+        /// <response code="404">The Product not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetProductByIdAsync([FromRoute] string id, CancellationToken cancellationToken)
+        {
+            var result = await service.GetProductById(id, cancellationToken).ConfigureAwait(false);
+
+            if (result == null)
+            {
+                return NotFound("Entity not found");
+            }
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Creates a new Product.
+        /// </summary>
+        /// <param name="newProduct">The Product to be added.</param>
+        /// <returns>The <see cref="ProductAdapter"/> created entity.</returns>
+        /// <response code="201">The Product created.</response>
+        /// <response code="422">The Product could not be created.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status201Created)]
+        public async Task<IActionResult> CreateProductAsync([FromBody] ProductRequest newProduct, CancellationToken cancellationToken)
+        {
+            var result = await service.CreateProduct(newProduct, cancellationToken).ConfigureAwait(false);
+            return Created("CreatedWithIdAsync", result);
+        }
+
+        /// <summary>
+        /// Updates a full Product by identifier.
+        /// </summary>
+        /// <param name="entity">The Product to update.</param>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
+        /// <response code="200">The Product updated.</response>
+        /// <response code="404">The Product not found.</response>
+        /// <response code="422">The Product could not be updated.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPut]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> UpdateProductAsync([FromRoute] string id, ProductAdapter entity, CancellationToken cancellationToken)
+        {
+            if (id != entity.Id?.ToString())
+            {
+                return BadRequest("Product ID mismatch");
+            }
+
+            var result = await service.UpdateProduct(entity, cancellationToken).ConfigureAwait(false);
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Changes the status of the Product.
+        /// </summary>
+        /// <param name="id">The Product identifier.</param>
+        /// <param name="newStatus">The new status of the Product.</param>
+        /// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
+        /// <response code="200">The Product updates.</response>
+        /// <response code="404">The Product not found.</response>
+        /// <response code="422">The Product could not be deleted.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPatch]
+        [Route("{id}/{newStatus}/ChangeStatus")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> ChangeProductStatus([FromRoute] string id, [FromRoute] ProductStatus newStatus, CancellationToken cancellationToken)
+        {
+            var result = await service.ChangeProductStatus(id, newStatus, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Adds a tag to the product.
+        /// </summary>
+        /// <param name="productId">The Product identifier.</param>
+        /// <param name="tagId">The Tag identifier to add.</param>
+        /// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
+        /// <response code="200">The tag added to product.</response>
+        /// <response code="404">The Product not found.</response>
+        /// <response code="422">The tag could not be added.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [Route("{productId}/tags/{tagId}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> AddTagToProduct([FromRoute] string productId, [FromRoute] string tagId, CancellationToken cancellationToken)
+        {
+            var result = await service.AddTagToProduct(productId, tagId, cancellationToken).ConfigureAwait(false);
+            
+            if (result == null)
+            {
+                return NotFound("Product not found");
+            }
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Removes a tag from the product.
+        /// </summary>
+        /// <param name="productId">The Product identifier.</param>
+        /// <param name="tagId">The Tag identifier to remove.</param>
+        /// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
+        /// <response code="200">The tag removed from product.</response>
+        /// <response code="404">The Product not found.</response>
+        /// <response code="422">The tag could not be removed.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpDelete]
+        [Route("{productId}/tags/{tagId}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(ProductAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> RemoveTagFromProduct([FromRoute] string productId, [FromRoute] string tagId, CancellationToken cancellationToken)
+        {
+            var result = await service.RemoveTagFromProduct(productId, tagId, cancellationToken).ConfigureAwait(false);
+            
+            if (result == null)
+            {
+                return NotFound("Product not found");
+            }
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Deletes a Product by its MongoDB identifier.
+        /// </summary>
+        /// <param name="id">The Product MongoDB identifier.</param>
+        /// <returns>The result of the delete operation.</returns>
+        /// <response code="200">The Product deleted successfully.</response>
+        /// <response code="404">The Product not found.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpDelete]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(bool), StatusCodes.Status200OK)]
+        public async Task<IActionResult> DeleteProduct([FromRoute] string id, CancellationToken cancellationToken)
+        {
+            var result = await service.DeleteProduct(id, cancellationToken).ConfigureAwait(false);
+            
+            if (!result)
+            {
+                return NotFound("Product not found");
+            }
+
+            return Ok(result);
+        }
+    }
+} 

Core.Inventory.DAL.API/Controllers/TagController.cs

@@ -0,0 +1,190 @@
+using Asp.Versioning;
+using Core.Adapters.Lib;
+using Core.Blueprint.Logging;
+using Core.Blueprint.Mongo;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+using Core.Inventory.Provider.Contracts;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Core.Inventory.DAL.API.Controllers
+{
+    /// <summary>
+    /// Handles all requests for Tag authentication.
+    /// </summary>
+    [ApiVersion(MimeTypes.ApplicationVersion)]
+    [Route("api/v{api-version:apiVersion}/[controller]")]
+    [Produces(MimeTypes.ApplicationJson)]
+    [Consumes(MimeTypes.ApplicationJson)]
+    [ApiController]
+    [AllowAnonymous]
+    public class TagController(ITagProvider service) : ControllerBase
+    {
+        /// <summary>
+        /// Gets all the Tags.
+        /// </summary>
+        /// <returns>The <see cref="IEnumerable{TagAdapter}"/> found entities.</returns>
+        /// <response code="200">The Tags found.</response>
+        /// <response code="404">The Tags not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<TagAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllTagsAsync(CancellationToken cancellationToken)
+        {
+            var result = await service.GetAllTags(cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Gets all the Tags by Tag identifiers.
+        /// </summary>
+        /// <param name="Tags">The list of Tag identifiers.</param>
+        /// <returns>The <see cref="IEnumerable{TagAdapter}"/> found entities.</returns>
+        /// <response code="200">The Tags found.</response>
+        /// <response code="404">The Tags not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [Route("GetTagList")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<TagAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllTagsByList([FromBody] string[] tags, CancellationToken cancellationToken)
+        {
+            if (tags == null || !tags.Any())
+            {
+                return BadRequest("Tag identifiers are required.");
+            }
+
+            var result = await service.GetAllTagsByList(tags, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+
+        /// <summary>
+        /// Gets the Tag by identifier.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>The <see cref="TagAdapter"/> found entity.</returns>
+        /// <response code="200">The Tag found.</response>
+        /// <response code="404">The Tag not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetTagByIdAsync([FromRoute] string id, CancellationToken cancellationToken)
+        {
+            var result = await service.GetTagById(id, cancellationToken).ConfigureAwait(false);
+
+            if (result == null)
+            {
+                return NotFound("Entity not found");
+            }
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Creates a new Tag.
+        /// </summary>
+        /// <param name="newTag">The Tag to be added.</param>
+        /// <returns>The <see cref="TagAdapter"/> created entity.</returns>
+        /// <response code="201">The Tag created.</response>
+        /// <response code="422">The Tag could not be created.</response>
+        /// <response code="500">The service internal e|ror.</response>
+        [HttpPost]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status201Created)]
+        public async Task<IActionResult> CreateTagAsync([FromBody] TagRequest newTag, CancellationToken cancellationToken)
+        {
+            var result = await service.CreateTag(newTag, cancellationToken).ConfigureAwait(false);
+            return Created("CreatedWithIdAsync", result);
+        }
+
+        /// <summary>
+        /// Updates a full Tag by identifier.
+        /// </summary>
+        /// <param name="entity">The Tag to update.</param>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>The <see cref="TagAdapter"/> updated entity.</returns>
+        /// <response code="200">The Tag updated.</response>
+        /// <response code="404">The Tag not found.</response>
+        /// <response code="422">The Tag could not be updated.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPut]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> UpdateTagAsync([FromRoute] string id, TagAdapter entity, CancellationToken cancellationToken)
+        {
+            if (id != entity.Id?.ToString())
+            {
+                return BadRequest("Tag ID mismatch");
+            }
+
+            var result = await service.UpdateTag(entity, cancellationToken).ConfigureAwait(false);
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Changes the status of the Tag.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <param name="newStatus">The new status of the Tag.</param>
+        /// <returns>The <see cref="TagAdapter"/> updated entity.</returns>
+        /// <response code="200">The Tag updates.</response>
+        /// <response code="404">The Tag not found.</response>
+        /// <response code="422">The Tag could not be deleted.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPatch]
+        [Route("{id}/{newStatus}/ChangeStatus")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> ChangeTagStatus([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
+        {
+            var result = await service.ChangeTagStatus(id, newStatus, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Adds a parentTag to the tag.
+        /// </summary>
+        /// <param name="tagId">The tag identifier.</param>
+        /// <param name="parentTagId">The parentTag identifier to add.</param>
+        /// <returns>The updated <see cref="TagAdapter"/> entity.</returns>
+        /// <response code="200">The tag with the updated parentTags.</response>
+        /// <response code="404">The tag or parentTag not found.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [Route("{tagId}/ParentTags/{parentTagId}/Add")]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> AddParentTagAsync([FromRoute] string tagId, [FromRoute] string parentTagId, CancellationToken cancellationToken)
+        {
+            var result = await service.AddParentTag(tagId, parentTagId, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Remove a parentTag to the tag.
+        /// </summary>
+        /// <param name="tagId">The tag identifier.</param>
+        /// <param name="parentTagId">The parentTag identifier to remove.</param>
+        /// <returns>The updated <see cref="TagAdapter"/> entity.</returns>
+        /// <response code="200">The tag with the updated parentTags.</response>
+        /// <response code="404">The tag or parentTag not found.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpDelete]
+        [Route("{tagId}/ParentTags/{parentTagId}/Remove")]
+        [ProducesResponseType(typeof(TagAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> RemoveParentTagAsync([FromRoute] string tagId, [FromRoute] string parentTagId, CancellationToken cancellationToken)
+        {
+            var result = await service.RemoveParentTag(tagId, parentTagId, cancellationToken).ConfigureAwait(false); ;
+            return Ok(result);
+        }
+    }
+}

Core.Inventory.DAL.API/Controllers/TagTypeController.cs

@@ -0,0 +1,154 @@
+using Asp.Versioning;
+using Core.Adapters.Lib;
+using Core.Blueprint.Logging;
+using Core.Blueprint.Mongo;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+using Core.Inventory.Provider.Contracts;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Core.Inventory.DAL.API.Controllers
+{
+    /// <summary>
+    /// Handles all requests for TagType authentication.
+    /// </summary>
+    [ApiVersion(MimeTypes.ApplicationVersion)]
+    [Route("api/v{api-version:apiVersion}/[controller]")]
+    [Produces(MimeTypes.ApplicationJson)]
+    [Consumes(MimeTypes.ApplicationJson)]
+    [ApiController]
+    [AllowAnonymous]
+    public class TagTypeController(ITagTypeProvider service) : ControllerBase
+    {
+        /// <summary>
+        /// Gets all the TagTypes.
+        /// </summary>
+        /// <returns>The <see cref="IEnumerable{TagTypeAdapter}"/> found entities.</returns>
+        /// <response code="200">The tagTypes found.</response>
+        /// <response code="404">The tagTypes not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<TagTypeAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllTagTypesAsync(CancellationToken cancellationToken)
+        {
+            var result = await service.GetAllTagTypes(cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Gets all the TagTypes by TagType identifiers.
+        /// </summary>
+        /// <param name="TagTypes">The list of TagType identifiers.</param>
+        /// <returns>The <see cref="IEnumerable{TagTypeAdapter}"/> found entities.</returns>
+        /// <response code="200">The TagTypes found.</response>
+        /// <response code="404">The TagTypes not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPost]
+        [Route("GetTagTypeList")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(IEnumerable<TagTypeAdapter>), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetAllTagTypesByList([FromBody] string[] tagTypes, CancellationToken cancellationToken)
+        {
+            if (tagTypes == null || !tagTypes.Any())
+            {
+                return BadRequest("TagType identifiers are required.");
+            }
+
+            var result = await service.GetAllTagTypesByList(tagTypes, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+
+
+        /// <summary>
+        /// Gets the TagType by identifier.
+        /// </summary>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>The <see cref="TagTypeAdapter"/> found entity.</returns>
+        /// <response code="200">The TagType found.</response>
+        /// <response code="404">The TagType not found error.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpGet]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagTypeAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> GetTagTypeByIdAsync([FromRoute] string id, CancellationToken cancellationToken)
+        {
+            var result = await service.GetTagTypeById(id, cancellationToken).ConfigureAwait(false);
+
+            if (result == null)
+            {
+                return NotFound("Entity not found");
+            }
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Creates a new TagType.
+        /// </summary>
+        /// <param name="newTagType">The TagType to be added.</param>
+        /// <returns>The <see cref="TagTypeAdapter"/> created entity.</returns>
+        /// <response code="201">The TagType created.</response>
+        /// <response code="422">The TagType could not be created.</response>
+        /// <response code="500">The service internal e|ror.</response>
+        [HttpPost]
+        [ProducesResponseType(typeof(TagTypeAdapter), StatusCodes.Status201Created)]
+        public async Task<IActionResult> CreateTagTypeAsync([FromBody] TagTypeRequest newTagType, CancellationToken cancellationToken)
+        {
+            var result = await service.CreateTagType(newTagType, cancellationToken).ConfigureAwait(false);
+            return Created("CreatedWithIdAsync", result);
+        }
+
+        /// <summary>
+        /// Updates a full TagType by identifier.
+        /// </summary>
+        /// <param name="entity">The TagType to update.</param>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>The <see cref="TagTypeAdapter"/> updated entity.</returns>
+        /// <response code="200">The TagType updated.</response>
+        /// <response code="404">The TagType not found.</response>
+        /// <response code="422">The TagType could not be updated.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPut]
+        [Route("{id}")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagTypeAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> UpdateTagTypeAsync([FromRoute] string id, TagTypeAdapter entity, CancellationToken cancellationToken)
+        {
+            if (id != entity.Id?.ToString())
+            {
+                return BadRequest("TagType ID mismatch");
+            }
+
+            var result = await service.UpdateTagType(entity, cancellationToken).ConfigureAwait(false);
+
+            return Ok(result);
+        }
+
+        /// <summary>
+        /// Changes the status of the TagType.
+        /// </summary>
+        /// <param name="id">The TagType identifier.</param>
+        /// <param name="newStatus">The new status of the TagType.</param>
+        /// <returns>The <see cref="TagTypeAdapter"/> updated entity.</returns>
+        /// <response code="200">The TagType updates.</response>
+        /// <response code="404">The TagType not found.</response>
+        /// <response code="422">The TagType could not be deleted.</response>
+        /// <response code="500">The service internal error.</response>
+        [HttpPatch]
+        [Route("{id}/{newStatus}/ChangeStatus")]
+        [Consumes(MimeTypes.ApplicationJson)]
+        [Produces(MimeTypes.ApplicationJson)]
+        [ProducesResponseType(typeof(TagTypeAdapter), StatusCodes.Status200OK)]
+        public async Task<IActionResult> ChangeTagTypeStatus([FromRoute] string id, [FromRoute] StatusEnum newStatus, CancellationToken cancellationToken)
+        {
+            var result = await service.ChangeTagTypeStatus(id, newStatus, cancellationToken).ConfigureAwait(false);
+            return Ok(result);
+        }
+    }
+}

Core.Inventory.DAL.API/appsettings.Development.json

@@ -12,7 +12,7 @@
   },
   "MongoDb": {
     "DatabaseName": "Inventory",
-    "LocalAudience": ""
+    "LocalAudience": "InventotyDev"
   },
   "DetailedErrors": true,
   "UseRedisCache": true,

Core.Inventory.DAL.API/appsettings.Local.json

@@ -12,7 +12,7 @@
   },
   "MongoDb": {
     "DatabaseName": "Inventory",
-    "LocalAudience": ""
+    "LocalAudience": "InventotyLocal"
   },
   "DetailedErrors": true,
   "UseRedisCache": true,

Core.Inventory.Domain/Contexts/Inventory/Request/InventoryItemRequestBase.cs

@@ -37,7 +37,7 @@ namespace Core.Inventory.Domain.Contexts.Inventory.Request
         [BsonElement("currency")]
         [BsonRepresentation(BsonType.String)]
         [JsonPropertyName("currency")]
-        public string Currency { get; set; } = "MXN";
+        public string Currency { get; set; } = "USD";
 
         /// <summary>
         /// Gets or sets the category identifier the item belongs to.
@@ -45,7 +45,7 @@ namespace Core.Inventory.Domain.Contexts.Inventory.Request
         [BsonElement("categoryId")]
         [BsonRepresentation(BsonType.String)]
         [JsonPropertyName("categoryId")]
-        public Guid CategoryId { get; set; }
+        public string CategoryId { get; set; } = string.Empty;
 
         /// <summary>
         /// Gets or sets the provider or vendor identifier of the item.
@@ -53,7 +53,7 @@ namespace Core.Inventory.Domain.Contexts.Inventory.Request
         [BsonElement("providerId")]
         [BsonRepresentation(BsonType.String)]
         [JsonPropertyName("providerId")]
-        public Guid ProviderId { get; set; }
+        public string ProviderId { get; set; } = string.Empty;
 
         /// <summary>
         /// Gets or sets additional customizable attributes.
@@ -61,6 +61,6 @@ namespace Core.Inventory.Domain.Contexts.Inventory.Request
         /// </summary>
         [BsonElement("attributes")]
         [JsonPropertyName("attributes")]
-        public Dictionary<string, object> Attributes { get; set; } = [];
+        public Dictionary<string, string> Attributes { get; set; } = [];
     }
 }

Core.Inventory.Domain/Contexts/Inventory/Request/ProductRequest.cs

@@ -0,0 +1,52 @@
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization.Attributes;
+using System.Text.Json.Serialization;
+
+namespace Core.Inventory.Domain.Contexts.Inventory.Request
+{
+    /// <summary>
+    /// Data transfer object (DTO) for adding product.
+    /// </summary>
+    public class ProductRequest
+    {
+        /// <summary>
+        /// Gets or sets the tenantId of the product.
+        /// </summary>
+        [BsonElement("tenantId")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("tenantId")]
+        public string TenantId { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the name of the product.
+        /// </summary>
+        [BsonElement("productName")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("productName")]
+        public string ProductName { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the description of the product.
+        /// </summary>
+        [BsonElement("description")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("description")]
+        public string Description { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the productStatus of the product.
+        /// </summary>
+        [BsonElement("productStatus")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("productStatus")]
+        public string ProductStatus { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the list of Tag Ids associated with this product.
+        /// </summary>
+        [BsonElement("tagIds")]
+        [BsonRepresentation(BsonType.ObjectId)]
+        [JsonPropertyName("tagIds")]
+        public List<string> TagIds { get; set; } = new List<string>();
+    }
+} 

Core.Inventory.Domain/Contexts/Inventory/Request/TagRequest.cs

@@ -0,0 +1,67 @@
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization.Attributes;
+using System.Text.Json.Serialization;
+
+namespace Core.Inventory.Domain.Contexts.Inventory.Request
+{
+    /// <summary>
+    /// Data transfer object (DTO) for adding Tag.
+    /// </summary>
+    public class TagRequest
+    {
+        /// <summary>
+        /// Gets or sets the tenantId of the Tag.
+        /// </summary>
+        [BsonElement("tenantId")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("tenantId")]
+        public string TenantId { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the name of the Tag.
+        /// </summary>
+        [BsonElement("tagName")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("tagName")]
+        public string TagName { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the typeId of the Tag.
+        /// </summary>
+        [BsonElement("typeId")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("typeId")]
+        public string TypeId { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the parentTagId of the Tag.
+        /// </summary>
+        [BsonElement("parentTagId")]
+        [JsonPropertyName("parentTagId")]
+        public string[] ParentTagId { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the slug of the Tag.
+        /// </summary>
+        [BsonElement("slug")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("slug")]
+        public string Slug { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the displayOrder of the Tag.
+        /// </summary>
+        [BsonElement("displayOrder")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("displayOrder")]
+        public int DisplayOrder { get; set; }
+
+        /// <summary>
+        /// Gets or sets the icon of the Tag.
+        /// </summary>
+        [BsonElement("icon")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("icon")]
+        public string Icon { get; set; } = null!;
+    }
+}

Core.Inventory.Domain/Contexts/Inventory/Request/TagTypeRequest.cs

@@ -0,0 +1,44 @@
+using MongoDB.Bson;
+using MongoDB.Bson.Serialization.Attributes;
+using System.Text.Json.Serialization;
+
+namespace Core.Inventory.Domain.Contexts.Inventory.Request
+{
+    /// <summary>
+    /// Data transfer object (DTO) for adding tagType.
+    /// </summary>
+    public class TagTypeRequest
+    {
+        /// <summary>
+        /// Gets or sets the tenantId of the tagType.
+        /// </summary>
+        [BsonElement("tenantId")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("tenantId")]
+        public string TenantId { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the typeName of the tagType.
+        /// </summary>
+        [BsonElement("typeName")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("typeName")]
+        public string TypeName { get; set; } = null!;
+
+        /// <summary>
+        /// Gets or sets the level of the tagType.
+        /// </summary>
+        [BsonElement("level")]
+        [BsonRepresentation(BsonType.Int32)]
+        [JsonPropertyName("level")]
+        public int Level { get; set; }
+
+        /// <summary>
+        /// Gets or sets the parentTypeId of the tagType.
+        /// </summary>
+        [BsonElement("parentTypeId")]
+        [BsonRepresentation(BsonType.String)]
+        [JsonPropertyName("parentTypeId")]
+        public string ParentTypeId { get; set; } = null!;
+    }
+}

Core.Inventory.Provider/Contracts/IFurnitureBaseProvider.cs

@@ -25,10 +25,10 @@ namespace Core.Inventory.Provider.Contracts
         /// <summary>
         /// Gets a furniture base entity by its ID.
         /// </summary>
-        /// <param name="id">The unique identifier (_id) of the furniture base.</param>
+        /// <param name="_id">The unique identifier (_id) of the furniture base.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The corresponding <see cref="FurnitureBase"/>.</returns>
-        ValueTask<FurnitureBase> GetByIdAsync(string id, CancellationToken cancellationToken);
+        ValueTask<FurnitureBase> GetByIdAsync(string _id, CancellationToken cancellationToken);
 
         /// <summary>
         /// Retrieves all furniture base entries.
@@ -49,10 +49,10 @@ namespace Core.Inventory.Provider.Contracts
         /// <summary>
         /// Changes the status of a furniture base entity.
         /// </summary>
-        /// <param name="id">The entity identifier.</param>
+        /// <param name="_id">The entity identifier.</param>
         /// <param name="newStatus">The new status to apply.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The updated <see cref="FurnitureBase"/>.</returns>
-        ValueTask<FurnitureBase> ChangeStatusAsync(string id, StatusEnum newStatus, CancellationToken cancellationToken);
+        ValueTask<FurnitureBase> ChangeStatusAsync(string _id, StatusEnum newStatus, CancellationToken cancellationToken);
     }
 }

Core.Inventory.Provider/Contracts/IFurnitureVariantProvider.cs

@@ -25,10 +25,18 @@ namespace Core.Inventory.Provider.Contracts
         /// <summary>
         /// Gets a furniture variant entity by its ID.
         /// </summary>
-        /// <param name="id">The unique identifier (_id) of the furniture variant.</param>
+        /// <param name="_id">The unique identifier (_id) of the furniture variant.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The corresponding <see cref="FurnitureVariant"/>.</returns>
-        ValueTask<FurnitureVariant> GetByIdAsync(string id, CancellationToken cancellationToken);
+        ValueTask<FurnitureVariant> GetByIdAsync(string _id, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Retrieves all furniture variants by a list of variant IDs.
+        /// </summary>
+        /// <param name="ids">Array of variant IDs.</param>
+        /// <param name="cancellationToken">Cancellation token.</param>
+        /// <returns>A list of <see cref="FurnitureVariant"/> matching the specified IDs.</returns>
+        ValueTask<IEnumerable<FurnitureVariant>> GetAllByIdsAsync(string[] ids, CancellationToken cancellationToken);
 
         /// <summary>
         /// Retrieves all furniture variants associated with a base model.
@@ -50,10 +58,17 @@ namespace Core.Inventory.Provider.Contracts
         /// <summary>
         /// Changes the status of a furniture variant entity.
         /// </summary>
-        /// <param name="id">The entity identifier.</param>
+        /// <param name="_id">The entity identifier.</param>
         /// <param name="newStatus">The new status to apply.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The updated <see cref="FurnitureVariant"/>.</returns>
-        ValueTask<FurnitureVariant> ChangeStatusAsync(string id, StatusEnum newStatus, CancellationToken cancellationToken);
+        ValueTask<FurnitureVariant> ChangeStatusAsync(string _id, StatusEnum newStatus, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Retrieves all furniture variant entities.
+        /// </summary>
+        /// <param name="cancellationToken">Cancellation token.</param>
+        /// <returns>A list of all <see cref="FurnitureVariant"/> entities.</returns>
+        ValueTask<IEnumerable<FurnitureVariant>> GetAllAsync(CancellationToken cancellationToken);
     }
 }

Core.Inventory.Provider/Contracts/IProductProvider.cs

@@ -0,0 +1,85 @@
+using Core.Adapters.Lib.Inventory;
+using Core.Blueprint.Mongo;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+
+namespace Core.Inventory.Provider.Contracts
+{
+    public interface IProductProvider
+    {
+        /// <summary>
+        /// Creates a new Product.
+        /// </summary>
+        /// <param name="entity">The Product to be created.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> CreateProduct(ProductRequest newProduct, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets a Product by identifier.
+        /// </summary>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> GetProductById(string _id, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the products.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerable{ProductAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<ProductAdapter>> GetAllProducts(CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the products by products identifier list.
+        /// </summary>
+        /// <param name="products">The list of products identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<ProductAdapter>> GetAllProductsByList(string[] products, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Changes the status of the product.
+        /// </summary>
+        /// <param name="id">The product identifier.</param>
+        /// <param name="newStatus">The new status of the product.</param>
+        /// <returns>The <see cref="ProductAdapter"/> updated entity.</returns>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> ChangeProductStatus(string id, ProductStatus newStatus, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Updates a Product by id.
+        /// </summary>
+        /// <param name="entity">The Product to be updated.</param>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> UpdateProduct(ProductAdapter entity, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Adds a tag to the product.
+        /// </summary>
+        /// <param name="productId">The ID of the product.</param>
+        /// <param name="tagId">The ID of the tag to add.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> AddTagToProduct(string productId, string tagId, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Removes a tag from the product.
+        /// </summary>
+        /// <param name="productId">The ID of the product.</param>
+        /// <param name="tagId">The ID of the tag to remove.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<ProductAdapter> RemoveTagFromProduct(string productId, string tagId, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Deletes a Product by its MongoDB identifier.
+        /// </summary>
+        /// <param name="productId">The Product MongoDB identifier.</param>
+        /// <returns>A <see cref="{Task{bool}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<bool> DeleteProduct(string productId, CancellationToken cancellationToken);
+    }
+} 

Core.Inventory.Provider/Contracts/ITagProvider.cs

@@ -0,0 +1,75 @@
+using Core.Adapters.Lib;
+using Core.Blueprint.Mongo;
+using Core.Inventory.Domain.Contexts.Inventory.Request;
+
+namespace Core.Inventory.Provider.Contracts
+{
+    public interface ITagProvider
+    {
+        /// <summary>
+        /// Creates a new Tag.
+        /// </summary>
+        /// <param name="entity">The Tag to be created.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagAdapter> CreateTag(TagRequest newTag, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets an Tag by identifier.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagAdapter> GetTagById(string _id, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the Tags.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagAdapter>> GetAllTags(CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the Tags by Tags identifier list.
+        /// </summary>
+        /// <param name="Tags">The list of Tags identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagAdapter>> GetAllTagsByList(string[] Tags, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Changes the status of the Tag.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <param name="newStatus">The new status of the Tag.</param>
+        /// <returns>The <see cref="TagAdapter"/> updated entity.</returns>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagAdapter> ChangeTagStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Updates a Tag by id.
+        /// </summary>
+        /// <param name="entity">The Tag to be updated.</param>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagAdapter> UpdateTag(TagAdapter entity, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Adds a parentTag to the tag.
+        /// </summary>
+        /// <param name="tagId">The identifier of the tag to whom the parentTag will be added.</param>
+        /// <param name="parentTagId">The identifier of the parentTag to add.</param>
+        /// <returns>A <see cref="Task{TagAdapter}"/> representing the asynchronous operation, with the updated tag object.</returns>
+        ValueTask<TagAdapter> AddParentTag(string tagId, string parentTagId, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Removes a parentTag from the tag.
+        /// </summary>
+        /// <param name="tagId">The identifier of the tag to whom the parentTag will be added.</param>
+        /// <param name="parentTagId">The identifier of the parentTag to add.</param>
+        /// <returns>A <see cref="Task{TagAdapter}"/> representing the asynchronous operation, with the updated tag object.</returns>
+        ValueTask<TagAdapter> RemoveParentTag(string tagId, string parentTagId, CancellationToken cancellationToken);
+    }
+}

Core.Inventory.Provider/Contracts/ITagTypeProvider.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 ITagTypeProvider
+    {
+        /// <summary>
+        /// Creates a new TagType.
+        /// </summary>
+        /// <param name="entity">The TagType to be created.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagTypeAdapter> CreateTagType(TagTypeRequest newTagType, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets an TagType by identifier.
+        /// </summary>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagTypeAdapter> GetTagTypeById(string _id, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the tagTypes.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagTypeAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypes(CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Gets all the tagTypes by tagTypes identifier list.
+        /// </summary>
+        /// <param name="tagTypes">The list of tagTypes identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypesByList(string[] TagTypes, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Changes the status of the tagType.
+        /// </summary>
+        /// <param name="id">The tagType identifier.</param>
+        /// <param name="newStatus">The new status of the tagType.</param>
+        /// <returns>The <see cref="TagTypeAdapter"/> updated entity.</returns>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagTypeAdapter> ChangeTagTypeStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken);
+
+        /// <summary>
+        /// Updates a TagType by id.
+        /// </summary>
+        /// <param name="entity">The TagType to be updated.</param>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        ValueTask<TagTypeAdapter> UpdateTagType(TagTypeAdapter entity, CancellationToken cancellationToken);
+    }
+}

Core.Inventory.Provider/Core.Inventory.Provider.csproj

@@ -7,9 +7,9 @@
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Adapters.Lib" Version="1.0.3" />
+    <PackageReference Include="Adapters.Lib" Version="1.0.13" />
     <PackageReference Include="Core.Blueprint.Mongo" Version="1.0.0" />
-    <PackageReference Include="Core.Blueprint.Redis" Version="1.0.1" />
+    <PackageReference Include="Core.Blueprint.Redis" Version="1.0.2" />
     <PackageReference Include="Mapster" Version="7.4.0" />
   </ItemGroup>
 

Core.Inventory.Provider/Providers/Inventory/FurnitureBaseProvider.cs

@@ -22,6 +22,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
         private readonly CollectionRepository<FurnitureBase> repository;
         private readonly IRedisCacheProvider cacheProvider;
         private readonly CacheSettings cacheSettings;
+        private const string getAllCache = "GetAllFurnitureBases";
 
         public FurnitureBaseProvider(
             CollectionRepository<FurnitureBase> repository,
@@ -38,15 +39,16 @@ namespace Core.Inventory.Provider.Providers.Inventory
         /// <summary>
         /// Changes the status of a FurnitureBase entity.
         /// </summary>
-        /// <param name="id">The furniture base identifier.</param>
+        /// <param name="mongoId">The furniture base identifier.</param>
         /// <param name="newStatus">The new status to apply.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The updated <see cref="FurnitureBase"/>.</returns>
-        public async ValueTask<FurnitureBase> ChangeStatusAsync(string id, StatusEnum newStatus, CancellationToken cancellationToken)
+        public async ValueTask<FurnitureBase> ChangeStatusAsync(string mongoId, StatusEnum newStatus, CancellationToken cancellationToken)
         {
-            var entity = await repository.FindByIdAsync(id);
+            var entity = await repository.FindByIdAsync(mongoId);
             entity.Status = newStatus;
             await repository.ReplaceOneAsync(entity);
+            await ResetCollectionCache();
             return entity;
         }
 
@@ -60,6 +62,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
         {
             var furnitureCollection = newFurniture.Adapt<FurnitureBase>();
             await repository.InsertOneAsync(furnitureCollection);
+            await ResetCollectionCache();
             return furnitureCollection;
         }
 
@@ -70,7 +73,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
         /// <returns>A list of <see cref="FurnitureBase"/>.</returns>
         public async ValueTask<IEnumerable<FurnitureBase>> GetAllAsync(CancellationToken cancellationToken)
         {
-            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetAllAsync));
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, getAllCache);
             var cachedData = await cacheProvider.GetAsync<IEnumerable<FurnitureBase>>(cacheKey) ?? [];
 
             if (cachedData.Any()) return cachedData;
@@ -83,17 +86,17 @@ namespace Core.Inventory.Provider.Providers.Inventory
         /// <summary>
         /// Gets a FurnitureBase entity by its ID.
         /// </summary>
-        /// <param name="id">The furniture base identifier.</param>
+        /// <param name="mongoId">The furniture base identifier.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The corresponding <see cref="FurnitureBase"/>.</returns>
-        public async ValueTask<FurnitureBase> GetByIdAsync(string id, CancellationToken cancellationToken)
+        public async ValueTask<FurnitureBase> GetByIdAsync(string mongoId, CancellationToken cancellationToken)
         {
-            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetByIdAsync), id);
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetByIdAsync), mongoId);
             var cached = await cacheProvider.GetAsync<FurnitureBase>(cacheKey);
 
             if (cached is not null) return cached;
 
-            var result = await repository.FindByIdAsync(id);
+            var result = await repository.FindByIdAsync(mongoId);
             await cacheProvider.SetAsync(cacheKey, result);
             return result;
         }
@@ -108,7 +111,20 @@ namespace Core.Inventory.Provider.Providers.Inventory
         public async ValueTask<FurnitureBase> UpdateAsync(string id, FurnitureBase entity, CancellationToken cancellationToken)
         {
             await repository.ReplaceOneAsync(entity);
+            await ResetCollectionCache();
             return entity;
         }
+
+        /// <summary>
+        /// Temporary method to "reset" collections cache
+        /// </summary>
+        /// <returns></returns>
+        private async Task ResetCollectionCache()
+        {
+            //TODO: remove this method when necessary.
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, getAllCache);
+
+            await cacheProvider.SetAsync(cacheKey, Enumerable.Empty<FurnitureBase>(), null);
+        }
     }
 }

Core.Inventory.Provider/Providers/Inventory/FurnitureVariantProvider.cs

@@ -11,6 +11,7 @@ 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
 {
@@ -22,6 +23,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
         private readonly CollectionRepository<FurnitureVariant> repository;
         private readonly IRedisCacheProvider cacheProvider;
         private readonly CacheSettings cacheSettings;
+        private const string getAllVariantsCache = "GetAllFurnitureVariants";
 
         public FurnitureVariantProvider(
             CollectionRepository<FurnitureVariant> repository,
@@ -38,15 +40,16 @@ namespace Core.Inventory.Provider.Providers.Inventory
         /// <summary>
         /// Changes the status of a FurnitureVariant entity.
         /// </summary>
-        /// <param name="id">The furniture variant identifier.</param>
+        /// <param name="mongoId">The furniture variant identifier.</param>
         /// <param name="newStatus">The new status to apply.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The updated <see cref="FurnitureVariant"/>.</returns>
-        public async ValueTask<FurnitureVariant> ChangeStatusAsync(string id, StatusEnum newStatus, CancellationToken cancellationToken)
+        public async ValueTask<FurnitureVariant> ChangeStatusAsync(string mongoId, StatusEnum newStatus, CancellationToken cancellationToken)
         {
-            var entity = await repository.FindByIdAsync(id);
+            var entity = await repository.FindByIdAsync(mongoId);
             entity.Status = newStatus;
             await repository.ReplaceOneAsync(entity);
+            await ResetCollectionCache();
             return entity;
         }
 
@@ -60,6 +63,7 @@ namespace Core.Inventory.Provider.Providers.Inventory
         {
             var variantCollection = newVariant.Adapt<FurnitureVariant>();
             await repository.InsertOneAsync(variantCollection);
+            await ResetCollectionCache();
             return variantCollection;
         }
 
@@ -70,34 +74,62 @@ namespace Core.Inventory.Provider.Providers.Inventory
         /// <returns>A list of <see cref="FurnitureVariant"/>.</returns>
         public async ValueTask<IEnumerable<FurnitureVariant>> GetAllByModelIdAsync(string modelId, CancellationToken cancellationToken)
         {
-            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetAllByModelIdAsync));
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetAllByModelIdAsync), modelId);
+
             var cachedData = await cacheProvider.GetAsync<IEnumerable<FurnitureVariant>>(cacheKey);
+            if (cachedData is not null && cachedData.Any())
+                return cachedData;
 
-            if (cachedData.Any()) return cachedData;
+            var filter = Builders<FurnitureVariant>.Filter.Eq(x => x.ModelId, modelId);
+            var variants = await repository.FilterByMongoFilterAsync(filter);
 
-            var data = await repository.AsQueryable();
-            await cacheProvider.SetAsync(cacheKey, data);
-            return data;
+            if (variants is not null && variants.Any())
+                await cacheProvider.SetAsync(cacheKey, variants);
+
+            return variants ?? [];
         }
 
         /// <summary>
         /// Gets a FurnitureVariant entity by its ID.
         /// </summary>
-        /// <param name="id">The furniture variant identifier.</param>
+        /// <param name="mongoId">The furniture variant identifier.</param>
         /// <param name="cancellationToken">Cancellation token.</param>
         /// <returns>The corresponding <see cref="FurnitureVariant"/>.</returns>
-        public async ValueTask<FurnitureVariant> GetByIdAsync(string id, CancellationToken cancellationToken)
+        public async ValueTask<FurnitureVariant> GetByIdAsync(string mongoId, CancellationToken cancellationToken)
         {
-            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetByIdAsync), id);
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetByIdAsync), mongoId);
             var cached = await cacheProvider.GetAsync<FurnitureVariant>(cacheKey);
 
             if (cached is not null) return cached;
 
-            var result = await repository.FindByIdAsync(id);
+            var result = await repository.FindByIdAsync(mongoId);
             await cacheProvider.SetAsync(cacheKey, result);
             return result;
         }
 
+        /// <summary>
+        /// Retrieves all furniture variants by a list of variant IDs.
+        /// </summary>
+        /// <param name="ids">Array of variant IDs.</param>
+        /// <param name="cancellationToken">Cancellation token.</param>
+        /// <returns>A list of <see cref="FurnitureVariant"/> matching the specified IDs.</returns>
+        public async ValueTask<IEnumerable<FurnitureVariant>> GetAllByIdsAsync(string[] ids, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, nameof(GetAllByIdsAsync), ids);
+
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<FurnitureVariant>>(cacheKey);
+            if (cachedData is not null && cachedData.Any())
+                return cachedData;
+
+            var filter = Builders<FurnitureVariant>.Filter.In(x => x.Id, ids);
+            var variants = await repository.FilterByMongoFilterAsync(filter);
+
+            if (variants is not null && variants.Any())
+                await cacheProvider.SetAsync(cacheKey, variants);
+
+            return variants ?? [];
+        }
+
         /// <summary>
         /// Updates a FurnitureVariant entity by ID.
         /// </summary>
@@ -108,7 +140,37 @@ namespace Core.Inventory.Provider.Providers.Inventory
         public async ValueTask<FurnitureVariant> UpdateAsync(string id, FurnitureVariant entity, CancellationToken cancellationToken)
         {
             await repository.ReplaceOneAsync(entity);
+            await ResetCollectionCache();
             return entity;
         }
+
+        /// <summary>
+        /// Retrieves all FurnitureVariant entries.
+        /// </summary>
+        /// <param name="cancellationToken">Cancellation token.</param>
+        /// <returns>A list of <see cref="FurnitureVariant"/>.</returns>
+        public async ValueTask<IEnumerable<FurnitureVariant>> GetAllAsync(CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, getAllVariantsCache);
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<FurnitureVariant>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var data = await repository.AsQueryable();
+            await cacheProvider.SetAsync(cacheKey, data);
+            return data;
+        }
+
+        /// <summary>
+        /// Temporary method to "reset" collections cache
+        /// </summary>
+        /// <returns></returns>
+        private async Task ResetCollectionCache()
+        {
+            //TODO: remove this method when necessary.
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, getAllVariantsCache);
+
+            await cacheProvider.SetAsync(cacheKey, Enumerable.Empty<FurnitureVariant>(), null);
+        }
     }
 }

Core.Inventory.Provider/Providers/Inventory/ProductProvider.cs

@@ -0,0 +1,213 @@
+using Core.Adapters.Lib.Inventory;
+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;
+using MongoDB.Bson;
+
+namespace Core.Inventory.Provider.Providers.Inventory
+{
+    /// <summary>
+    /// Handles all services and business rules related to <see cref="ProductAdapter"/>.
+    /// </summary>
+    public class ProductProvider : IProductProvider
+    {
+        private readonly CollectionRepository<ProductAdapter> repository;
+        private readonly CacheSettings cacheSettings;
+        private readonly IRedisCacheProvider cacheProvider;
+
+        public ProductProvider(CollectionRepository<ProductAdapter> repository,
+            IRedisCacheProvider cacheProvider,
+            IOptions<CacheSettings> cacheSettings)
+        {
+            this.repository = repository;
+            this.repository.CollectionInitialization();
+            this.cacheSettings = cacheSettings.Value;
+            this.cacheProvider = cacheProvider;
+        }
+
+        /// <summary>
+        /// Creates a new Product.
+        /// </summary>
+        /// <param name="entity">The Product to be created.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> CreateProduct(ProductRequest newProduct, CancellationToken cancellationToken)
+        {
+            var productCollection = newProduct.Adapt<ProductAdapter>();
+
+            await repository.InsertOneAsync(productCollection);
+
+            return productCollection;
+        }
+
+        /// <summary>
+        /// Gets a Product by identifier.
+        /// </summary>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> GetProductById(string _id, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetProductById", _id);
+            var cachedData = await cacheProvider.GetAsync<ProductAdapter>(cacheKey);
+
+            if (cachedData is not null) { return cachedData; }
+
+            var product = await repository.FindByIdAsync(_id);
+
+            await cacheProvider.SetAsync(cacheKey, product);
+
+            return product;
+        }
+
+        /// <summary>
+        /// Gets all the Products.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerable{ProductAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<ProductAdapter>> GetAllProducts(CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetProducts");
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<ProductAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var products = await repository.AsQueryable();
+
+            await cacheProvider.SetAsync(cacheKey, products);
+
+            return products;
+        }
+
+        /// <summary>
+        /// Gets all the Products by Products identifier list.
+        /// </summary>
+        /// <param name="products">The list of Products identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<ProductAdapter>> GetAllProductsByList(string[] products, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllProductsByList", products);
+
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<ProductAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var builder = Builders<ProductAdapter>.Filter;
+            var filters = new List<FilterDefinition<ProductAdapter>>();
+
+            if (products != null || !products.Any())
+            {
+                filters.Add(builder.In(x => x._Id, products));
+            }
+
+            var finalFilter = filters.Count != 0 ? builder.And(filters) : builder.Empty;
+
+            var productsList = await repository.FilterByMongoFilterAsync(finalFilter);
+
+            await cacheProvider.SetAsync(cacheKey, productsList);
+
+            return productsList;
+        }
+
+        /// <summary>
+        /// Changes the status of the Product.
+        /// </summary>
+        /// <param name="id">The Product identifier.</param>
+        /// <param name="newStatus">The new status of the Product.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> ChangeProductStatus(string id, ProductStatus newStatus, CancellationToken cancellationToken)
+        {
+            var entity = await repository.FindByIdAsync(id);
+            entity.ProductStatus = newStatus;
+
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Updates a Product by id.
+        /// </summary>
+        /// <param name="entity">The Product to be updated.</param>
+        /// <param name="id">The Product identifier.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> UpdateProduct(ProductAdapter entity, CancellationToken cancellationToken)
+        {
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Adds a tag to the product.
+        /// </summary>
+        /// <param name="productId">The ID of the product.</param>
+        /// <param name="tagId">The ID of the tag to add.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> AddTagToProduct(string productId, string tagId, CancellationToken cancellationToken)
+        {
+            var product = await repository.FindByIdAsync(productId);
+            
+            if (product != null)
+            {
+                var objectId = ObjectId.Parse(tagId);
+                if (!product.TagIds.Contains(objectId))
+                {
+                    product.TagIds.Add(objectId);
+                    await repository.ReplaceOneAsync(product);
+                }
+            }
+
+            return product;
+        }
+
+        /// <summary>
+        /// Removes a tag from the product.
+        /// </summary>
+        /// <param name="productId">The ID of the product.</param>
+        /// <param name="tagId">The ID of the tag to remove.</param>
+        /// <returns>A <see cref="{Task{ProductAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<ProductAdapter> RemoveTagFromProduct(string productId, string tagId, CancellationToken cancellationToken)
+        {
+            var product = await repository.FindByIdAsync(productId);
+
+            if (product != null)
+            {
+                var objectId = ObjectId.Parse(tagId);
+                product.TagIds.Remove(objectId);
+                await repository.ReplaceOneAsync(product);
+            }
+
+            return product;
+        }
+
+        /// <summary>
+        /// Deletes a Product by its MongoDB identifier.
+        /// </summary>
+        /// <param name="productId">The Product MongoDB identifier.</param>
+        /// <returns>A <see cref="{Task{bool}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<bool> DeleteProduct(string productId, CancellationToken cancellationToken)
+        {
+            try
+            {
+                await repository.DeleteByIdAsync(productId);
+                return true;
+            }
+            catch (Exception)
+            {
+                throw;
+            }
+        }
+    }
+}

Core.Inventory.Provider/Providers/Inventory/TagProvider.cs

@@ -0,0 +1,192 @@
+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="TagAdapter"/>.
+    /// </summary>
+    public class TagProvider : ITagProvider
+    {
+        private readonly CollectionRepository<TagAdapter> repository;
+        private readonly CacheSettings cacheSettings;
+        private readonly IRedisCacheProvider cacheProvider;
+
+        public TagProvider(CollectionRepository<TagAdapter> repository,
+            IRedisCacheProvider cacheProvider,
+            IOptions<CacheSettings> cacheSettings)
+        {
+            this.repository = repository;
+            this.repository.CollectionInitialization();
+            this.cacheSettings = cacheSettings.Value;
+            this.cacheProvider = cacheProvider;
+        }
+
+        /// <summary>
+        /// Creates a new Tag.
+        /// </summary>
+        /// <param name="entity">The Tag to be created.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagAdapter> CreateTag(TagRequest newTag, CancellationToken cancellationToken)
+        {
+            var tagCollection = newTag.Adapt<TagAdapter>();
+
+            await repository.InsertOneAsync(tagCollection);
+
+            return tagCollection;
+        }
+
+        /// <summary>
+        /// Gets an Tag by identifier.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>0
+        public async ValueTask<TagAdapter> GetTagById(string _id, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagById", _id);
+            var cachedData = await cacheProvider.GetAsync<TagAdapter>(cacheKey);
+
+            if (cachedData is not null) { return cachedData; }
+
+            var tag = await repository.FindByIdAsync(_id);
+
+            await cacheProvider.SetAsync(cacheKey, tag);
+
+            return tag;
+        }
+
+        /// <summary>
+        /// Gets all the Tags.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagAdapter>> GetAllTags(CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTags");
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var tags = await repository.AsQueryable();
+
+            await cacheProvider.SetAsync(cacheKey, tags);
+
+            return tags;
+        }
+
+        /// <summary>
+        /// Gets all the Tags by Tags identifier list.
+        /// </summary>
+        /// <param name="Tags">The list of Tags identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagAdapter>> GetAllTagsByList(string[] tags, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllTagsByList", tags);
+
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var builder = Builders<TagAdapter>.Filter;
+            var filters = new List<FilterDefinition<TagAdapter>>();
+
+            if (tags != null || !tags.Any())
+            {
+                filters.Add(builder.In(x => x._Id, tags));
+            }
+
+            var finalFilter = filters.Any() ? builder.And(filters) : builder.Empty;
+
+            var TagsList = await repository.FilterByMongoFilterAsync(finalFilter);
+
+            await cacheProvider.SetAsync(cacheKey, TagsList);
+
+            return TagsList;
+        }
+
+
+        /// <summary>
+        /// Changes the status of the Tag.
+        /// </summary>
+        /// <param name="id">The Tag identifier.</param>
+        /// <param name="newStatus">The new status of the Tag.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagAdapter> ChangeTagStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken)
+        {
+            var entity = await repository.FindByIdAsync(id);
+            entity.Status = newStatus;
+
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Updates a Tag by id.
+        /// </summary>
+        /// <param name="entity">The Tag to be updated.</param>
+        /// <param name="id">The Tag identifier.</param>
+        /// <returns>A <see cref="{Task{TagAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagAdapter> UpdateTag(TagAdapter entity, CancellationToken cancellationToken)
+        {
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Adds a parentTag to the tag.
+        /// </summary>
+        /// <param name="tagId">The identifier of the tag to whom the parentTag will be added.</param>
+        /// <param name="parentTagId">The identifier of the parentTag to add.</param>
+        /// <returns>A <see cref="Task{TagAdapter}"/> representing the asynchronous operation, with the updated tag object.</returns>
+        public async ValueTask<TagAdapter> AddParentTag(string tagId, string parentTagId, CancellationToken cancellationToken)
+        {
+            var tag = await repository.FindOneAsync(
+                u => u._Id == tagId &&
+                u.Status == StatusEnum.Active);
+
+            var updatedParentTags = tag.ParentTagId.Append(parentTagId).Distinct().ToArray();
+            tag.ParentTagId = updatedParentTags;
+
+            await repository.ReplaceOneAsync(tag);
+
+            return tag;
+        }
+
+        /// <summary>
+        /// Remove a parentTag to the tag.
+        /// </summary>
+        /// <param name="tagId">The identifier of the tag to whom the parentTag will be removed.</param>
+        /// <param name="parentTagId">The identifier of the parentTag to add.</param>
+        /// <returns>A <see cref="Task{TagAdapter}"/> representing the asynchronous operation, with the updated tag object.</returns>
+        public async ValueTask<TagAdapter> RemoveParentTag(string tagId, string parentTagId, CancellationToken cancellationToken)
+        {
+            var tag = await repository.FindOneAsync(
+                u => u._Id == tagId &&
+                u.Status == StatusEnum.Active);
+
+            var updatedParentTags = tag.ParentTagId
+                    ?.Where(c => c != parentTagId)
+                    .ToArray();
+
+            tag.ParentTagId = updatedParentTags;
+
+            await repository.ReplaceOneAsync(tag);
+
+            return tag;
+        }
+    }
+}

Core.Inventory.Provider/Providers/Inventory/TagTypeProvider.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="TagTypeAdapter"/>.
+    /// </summary>
+    public class TagTypeProvider : ITagTypeProvider
+    {
+        private readonly CollectionRepository<TagTypeAdapter> repository;
+        private readonly CacheSettings cacheSettings;
+        private readonly IRedisCacheProvider cacheProvider;
+
+        public TagTypeProvider(CollectionRepository<TagTypeAdapter> repository,
+            IRedisCacheProvider cacheProvider,
+            IOptions<CacheSettings> cacheSettings)
+        {
+            this.repository = repository;
+            this.repository.CollectionInitialization();
+            this.cacheSettings = cacheSettings.Value;
+            this.cacheProvider = cacheProvider;
+        }
+
+        /// <summary>
+        /// Creates a new TagType.
+        /// </summary>
+        /// <param name="entity">The TagType to be created.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagTypeAdapter> CreateTagType(TagTypeRequest newTagType, CancellationToken cancellationToken)
+        {
+            var tagTypeCollection = newTagType.Adapt<TagTypeAdapter>();
+
+            await repository.InsertOneAsync(tagTypeCollection);
+
+            return tagTypeCollection;
+        }
+
+        /// <summary>
+        /// Gets an TagType by identifier.
+        /// </summary>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>0
+        public async ValueTask<TagTypeAdapter> GetTagTypeById(string _id, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagTypeById", _id);
+            var cachedData = await cacheProvider.GetAsync<TagTypeAdapter>(cacheKey);
+
+            if (cachedData is not null) { return cachedData; }
+
+            var tagType = await repository.FindByIdAsync(_id);
+
+            await cacheProvider.SetAsync(cacheKey, tagType);
+
+            return tagType;
+        }
+
+        /// <summary>
+        /// Gets all the TagTypes.
+        /// </summary>
+        /// <returns>A <see cref="{Task{IEnumerbale{TagTypeAdapter}}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypes(CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetTagTypes");
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagTypeAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var tagTypes = await repository.AsQueryable();
+
+            await cacheProvider.SetAsync(cacheKey, tagTypes);
+
+            return tagTypes;
+        }
+
+        /// <summary>
+        /// Gets all the TagTypes by TagTypes identifier list.
+        /// </summary>
+        /// <param name="TagTypes">The list of TagTypes identifiers.</param>
+        /// <returns>A <see cref="Task{IEnumerable{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<IEnumerable<TagTypeAdapter>> GetAllTagTypesByList(string[] tagTypes, CancellationToken cancellationToken)
+        {
+            var cacheKey = CacheKeyHelper.GenerateCacheKey(this, "GetAllTagTypesByList", tagTypes);
+
+            var cachedData = await cacheProvider.GetAsync<IEnumerable<TagTypeAdapter>>(cacheKey) ?? [];
+
+            if (cachedData.Any()) return cachedData;
+
+            var builder = Builders<TagTypeAdapter>.Filter;
+            var filters = new List<FilterDefinition<TagTypeAdapter>>();
+
+            if (tagTypes != null || !tagTypes.Any())
+            {
+                filters.Add(builder.In(x => x._Id, tagTypes));
+            }
+
+            var finalFilter = filters.Any() ? builder.And(filters) : builder.Empty;
+
+            var tagTypesList = await repository.FilterByMongoFilterAsync(finalFilter);
+
+            await cacheProvider.SetAsync(cacheKey, tagTypesList);
+
+            return tagTypesList;
+        }
+
+
+        /// <summary>
+        /// Changes the status of the TagType.
+        /// </summary>
+        /// <param name="id">The TagType identifier.</param>
+        /// <param name="newStatus">The new status of the TagType.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagTypeAdapter> ChangeTagTypeStatus(string id, StatusEnum newStatus, CancellationToken cancellationToken)
+        {
+            var entity = await repository.FindByIdAsync(id);
+            entity.Status = newStatus;
+
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+
+        /// <summary>
+        /// Updates a TagType by id.
+        /// </summary>
+        /// <param name="entity">The TagType to be updated.</param>
+        /// <param name="id">The TagType identifier.</param>
+        /// <returns>A <see cref="{Task{TagTypeAdapter}}"/> representing
+        /// the asynchronous execution of the service.</returns>
+        public async ValueTask<TagTypeAdapter> UpdateTagType(TagTypeAdapter entity, CancellationToken cancellationToken)
+        {
+            await repository.ReplaceOneAsync(entity);
+
+            return entity;
+        }
+    }
+}

Core.Inventory.Provider/ServiceCollectionExtensions.cs

@@ -1,4 +1,5 @@
-using Core.Adapters.Lib;
+using Core.Adapters.Lib.Inventory;
+using Core.Adapters.Lib;
 using Core.Blueprint.Mongo;
 using Core.Inventory.Provider.Contracts;
 using Core.Inventory.Provider.Providers.Inventory;
@@ -17,6 +18,15 @@ namespace Core.Inventory.Provider
             services.AddScoped<IFurnitureVariantProvider, FurnitureVariantProvider>();
             services.AddScoped<CollectionRepository<FurnitureVariant>>();
 
+            services.AddScoped<ITagTypeProvider, TagTypeProvider>();
+            services.AddScoped<CollectionRepository<TagTypeAdapter>>();
+
+            services.AddScoped<ITagProvider, TagProvider>();
+            services.AddScoped<CollectionRepository<TagAdapter>>();
+
+            services.AddScoped<IProductProvider, ProductProvider>();
+            services.AddScoped<CollectionRepository<ProductAdapter>>();
+
             return services;
 
         }