diff --git a/DI/XDIHelperExtension.cs b/DI/XDIHelperExtension.cs
index b4885d8..8bb6868 100644
--- a/DI/XDIHelperExtension.cs
+++ b/DI/XDIHelperExtension.cs
@@ -78,8 +78,8 @@ namespace xTagService.DI
             var pushHelper = new XPushServiceHelper();
 
             //
-            pushHelper.AddHub<XTagDtoHub>("stringDto");
-            pushHelper.AddHub<XTagEntityHub>("stringEntity");
+            pushHelper.AddHub<XTagDtoHub>("tagDto");
+            pushHelper.AddHub<XTagEntityHub>("tagEntity");
 
             //
             app.UseXPushService(pushHelper);
diff --git a/Interfaces/IXBaseProvidedHasTag.cs b/Interfaces/IXBaseProvidedHasTag.cs
new file mode 100644
index 0000000..192df76
--- /dev/null
+++ b/Interfaces/IXBaseProvidedHasTag.cs
@@ -0,0 +1,12 @@
+using xModels.Base;
+using xPushService.Base;
+using xPushService.Interfaces;
+
+namespace xTagService.Interfaces
+{
+    public interface IXBaseProvidedHasTag<TEntity, TDto, TKey, THub> : IXBaseProvided<TEntity, TDto, TKey, THub>, IXTagProvided<TEntity, TDto, TKey, THub>
+    where TEntity : XBaseEntity<TKey>
+    where TDto : XBaseEntityDto<TKey>
+    where THub : XBaseDtoHub<TEntity, TDto, TKey>
+    { }
+}
\ No newline at end of file
diff --git a/Interfaces/IXTagProvided.cs b/Interfaces/IXTagProvided.cs
new file mode 100644
index 0000000..40320e6
--- /dev/null
+++ b/Interfaces/IXTagProvided.cs
@@ -0,0 +1,114 @@
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using xIdentityModels.Models;
+using xModels.Base;
+using xPushService.Base;
+
+namespace xTagService.Interfaces
+{
+    /// <summary>
+    /// a Tag Provided Service is a Model Provider Service which
+    /// can Contains Tags ... 
+    /// </summary>
+    public interface IXTagProvided<TEntity, TDto, TKey, THub>
+    where TEntity : XBaseEntity<TKey>
+    where TDto : XBaseEntityDto<TKey>
+    where THub : XBaseDtoHub<TEntity, TDto, TKey>
+    {
+        /// <summary>
+        /// Attach Tag to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task AttachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Detach Tag of Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task DetachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Attach Tags to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task AttachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Detach Tags of Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task DetachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Detach all Attached Tags of Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task DetachTags(
+            TKey id,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Get Specified Item Tags ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<string>> GetTags(
+            TKey id,
+            CancellationToken cancellationToken = default
+        );        
+    }
+}
\ No newline at end of file
diff --git a/Interfaces/IXTagProvidedController.cs b/Interfaces/IXTagProvidedController.cs
new file mode 100644
index 0000000..765bfb2
--- /dev/null
+++ b/Interfaces/IXTagProvidedController.cs
@@ -0,0 +1,83 @@
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.Mvc;
+using xModels.Base;
+using xPushService.Base;
+
+namespace xTagService.Interfaces
+{
+    public interface IXTagProvidedController<TEntity, TDto, TKey, THub>
+    where TEntity : XBaseEntity<TKey>
+    where TDto : XBaseEntityDto<TKey>
+    where THub : XBaseDtoHub<TEntity, TDto, TKey>
+    {
+        /// <summary>
+        /// Attach Tag to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        [HttpPost("{id}/tags/attach")]
+        Task<ActionResult> AttachTag(
+            [FromRoute] TKey id,
+            [FromBody] XBaseValueContainer<string> tag,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Detach Tag of Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        [HttpPost("{id}/tags/detach")]
+        Task<ActionResult> DetachTag(
+            [FromRoute] TKey id,
+            [FromBody] XBaseValueContainer<string> tag,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Attach Tags to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        [HttpPost("{id}/tags/attachs")]
+        Task<ActionResult> AttachTags(
+            [FromRoute] TKey id,
+            [FromBody] XBaseRangeRequest<string> tags,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Detach Tags of Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        [HttpPost("{id}/tags/detachs")]
+        Task<ActionResult> DetachTags(
+            [FromRoute] TKey id,
+            [FromBody] XBaseRangeRequest<string> tags = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Get Specified Item Tags ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        [HttpGet("{id}/tags")]
+        Task<ActionResult<IEnumerable<string>>> GetTags(
+            [FromRoute] TKey id,
+            CancellationToken cancellationToken = default
+        );
+    }
+}
\ No newline at end of file
diff --git a/Providers/XBaseProvidedHasTag.cs b/Providers/XBaseProvidedHasTag.cs
new file mode 100644
index 0000000..25d6f91
--- /dev/null
+++ b/Providers/XBaseProvidedHasTag.cs
@@ -0,0 +1,723 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using xCommons.Extensions;
+using xIdentityModels.Models;
+using xModels.Base;
+using xPushService.Base;
+using xPushService.Interfaces;
+using xTagService.Interfaces;
+using xIdentityModels.Extensions;
+using System.Threading;
+using xExceptions.Constants;
+using System.Linq.Expressions;
+using Microsoft.EntityFrameworkCore.Query;
+using xModels.Dtos;
+
+namespace xTagService.Providers
+{
+    public abstract class XBaseProvidedHasTag<TEntity, TDto, TKey, THub> : IXBaseProvidedHasTag<TEntity, TDto, TKey, THub>
+    where TEntity : XBaseEntity<TKey>
+    where TDto : XBaseEntityDto<TKey>
+    where THub : XBaseDtoHub<TEntity, TDto, TKey>
+    {
+        private readonly string[] permittedRoles;
+        private readonly IXBaseTagProvider<TKey> tagProvider;
+        private readonly IXBaseDtoProvider<TEntity, TDto, TKey, THub> provider;
+
+        protected XBaseProvidedHasTag(
+            IXBaseTagProvider<TKey> tagProvider,
+            IXBaseDtoProvider<TEntity, TDto, TKey, THub> provider,
+            string[] permittedRoles = null
+        )
+        {
+            this.provider = provider;
+            this.tagProvider = tagProvider;
+            this.permittedRoles = permittedRoles;
+        }
+
+        /// <summary>
+        /// Check an Items is Owned for User or not ...
+        /// </summary>
+        /// <param name="item"></param>
+        /// <param name="userInfo"></param>
+        /// <returns></returns>
+        public abstract bool IsOwned(
+            TDto item,
+            XUserClaimsInfoDto userInfo
+        );
+        public abstract bool IsOwned(
+            TEntity item,
+            XUserClaimsInfoDto userInfo
+        );
+
+        /// <summary>
+        /// Check User Has Permission for Manipulate Data or not ...
+        /// </summary>
+        /// <param name="userInfo"></param>
+        /// <returns></returns>
+        public bool HasPermision(
+            XUserClaimsInfoDto userInfo
+        )
+        {
+            //
+            var result =
+                !userInfo.IsNullOrDefault() &&
+                userInfo.HasAccess(permittedRoles);
+
+            //
+            return result;
+        }
+
+        //
+        #region Tag ...
+        /// <summary>
+        /// Attach Tag to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task AttachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tag.IsNullOrEmpty() &&
+                !userInfo.IsNullOrDefault();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.AddReference(
+                    tag: tag,
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Detach Tag fro Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tag.IsNullOrEmpty() &&
+                !userInfo.IsNullOrDefault();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.RemoveReference(
+                    tag: tag,
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Attach Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task AttachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tags.IsNull() &&
+                tags.HasChild();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            // Loop through Tags ...
+            foreach (var tag in tags)
+            {
+                //
+                // Check Cancellation Token ...
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    break;
+                }
+
+                //
+                await AttachTag(
+                    id: id,
+                    tag: tag,
+                    userInfo: userInfo,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+        }
+
+        /// <summary>
+        /// Detach Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tags.IsNull() &&
+                tags.HasChild();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            // Loop through Tags ...
+            foreach (var tag in tags)
+            {
+                //
+                // Check Cancellation Token ...
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    break;
+                }
+
+                //
+                await DetachTag(
+                    id: id,
+                    tag: tag,
+                    userInfo: userInfo,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+        }
+
+        /// <summary>
+        /// Detach all Attached Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTags(
+            TKey id,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.RemoveReferences(
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Get Specified Model's Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<string>> GetTags(
+            TKey id,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid = !id.IsNull();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            isValid = await provider.IsExistsAsync(
+                id: id,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            if (!isValid)
+            {
+                XException.NotFound.Throw();
+            }
+
+            //
+            var result = (await tagProvider.GetAllReferences(
+                providedForId: id,
+                cancellationToken: cancellationToken
+            ))
+            .Select(x => x.Tag)
+            .Distinct()
+            .ToList();
+
+            //
+            return result;
+        }
+        #endregion
+
+        //
+        #region Provided ...
+        /// <summary>
+        /// Get Specified Item by ID ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<TDto> Get(
+            TKey id,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Get All Exists Items ...
+        /// </summary>
+        /// <param name="orderBuilder"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<TDto>> GetAll(
+            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBuilder = null,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.GetAllAsync(
+                ignoreSoftDeleteds: true,
+                orderBuilder: orderBuilder,
+                includeBuilder: includeBuilder,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// find an item by providing a Conditional Expression ...
+        /// </summary>
+        /// <param name="predicate"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<TDto> FindOne(
+            Expression<Func<TEntity, bool>> predicate,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.FindOneAsync(
+                predicate: predicate,
+                ignoreSoftDeleteds: true,
+                includeBuilder: includeBuilder,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// find a collection of Items by proving a Conditional Expression ...
+        /// </summary>
+        /// <param name="predicate"></param>
+        /// <param name="orderBuilder"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<TDto>> FindMany(
+            Expression<Func<TEntity, bool>> predicate,
+            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBuilder = null,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.FindManyAsync(
+                predicate: predicate,
+                ignoreSoftDeleteds: true,
+                orderBuilder: orderBuilder,
+                includeBuilder: includeBuilder,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// retrieve Items based on XQuery Pagination structure ...
+        /// </summary>
+        /// <param name="query"></param>
+        /// <param name="predicate"></param>
+        /// <param name="orderBuilder"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XQueryResult<TDto>> Query(
+            XQuery query,
+            Expression<Func<TEntity, bool>> predicate = null,
+            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBuilder = null,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.QueryAsync(
+                query: query,
+                predicate: predicate,
+                ignoreSoftDeleteds: true,
+                orderBuilder: orderBuilder,
+                includeBuilder: includeBuilder,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// retrieve Owned Items based on XQuery Pagination structure ...
+        /// if supported ...
+        /// </summary>
+        /// <param name="query"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="predicate"></param>
+        /// <param name="orderBuilder"></param>
+        /// <param name="includeBuilder"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XQueryResult<TDto>> QueryOwned(
+            XQuery query,
+            XUserClaimsInfoDto userInfo = null,
+            Expression<Func<TEntity, bool>> predicate = null,
+            Func<IQueryable<TEntity>, IOrderedQueryable<TEntity>> orderBuilder = null,
+            Func<IQueryable<TEntity>, IIncludableQueryable<TEntity, object>> includeBuilder = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            Expression<Func<TEntity, bool>> predicateor = null;
+            if (!predicate.IsNull())
+            {
+                //
+                var predicateFnc = predicate.Compile();
+                predicateor = x =>
+                    predicateFnc(x) &&
+                    IsOwned(x, userInfo);
+            }
+            else
+            {
+                predicateor = x => IsOwned(x, userInfo);
+            }
+
+            //
+            var result = await provider.QueryAsync(
+                query: query,
+                predicate: predicateor,
+                ignoreSoftDeleteds: true,
+                orderBuilder: orderBuilder,
+                includeBuilder: includeBuilder,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Add an item values ...
+        /// </summary>
+        /// <param name="item"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<TDto> Add(
+            TDto item,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.AddAsync(
+                item: item,
+                saveChanges: true,
+                connectionId: connectionId,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Update an item values ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="item"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<TDto> Update(
+            TKey id,
+            TDto item,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Check Permission ...
+            var hasPermission =
+                IsOwned(item, userInfo) ||
+                HasPermision(userInfo);
+            if (!hasPermission)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            var result = await provider.UpdateAsync(
+                id: id,
+                item: item,
+                saveChanges: true,
+                connectionId: connectionId,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// remove an Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<TDto> Remove(
+            TKey id,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Check Permission ...
+            var item = await Get(
+                id: id,
+                cancellationToken: cancellationToken
+            );
+            var hasPermission =
+                IsOwned(item, userInfo) ||
+                HasPermision(userInfo);
+            if (!hasPermission)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            var result = await provider.RemoveAsync(
+                id: id,
+                saveChanges: true,
+                softDelete: false,
+                connectionId: connectionId,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// count all exists Items ...
+        /// </summary>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<int> Count(
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.CountAsync(
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Check an Item exists or not ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<bool> IsExists(
+            TKey id,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var result = await provider.IsExistsAsync(
+                id: id,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+        #endregion
+    }
+}
\ No newline at end of file
diff --git a/Providers/XBaseTagProvided.cs b/Providers/XBaseTagProvided.cs
new file mode 100644
index 0000000..a0b7137
--- /dev/null
+++ b/Providers/XBaseTagProvided.cs
@@ -0,0 +1,384 @@
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using xCommons.Extensions;
+using xIdentityModels.Models;
+using xModels.Base;
+using xPushService.Base;
+using xPushService.Interfaces;
+using xTagService.Interfaces;
+using xIdentityModels.Extensions;
+using xExceptions.Constants;
+using System.Linq;
+
+namespace xTagService.Providers
+{
+    public abstract class XBaseTagProvided<TEntity, TDto, TKey, THub> : IXTagProvided<TEntity, TDto, TKey, THub>
+    where TEntity : XBaseEntity<TKey>
+    where TDto : XBaseEntityDto<TKey>
+    where THub : XBaseDtoHub<TEntity, TDto, TKey>
+    {
+        private readonly string[] permittedRoles;
+        private readonly IXBaseTagProvider<TKey> tagProvider;
+        private readonly IXBaseDtoProvider<TEntity, TDto, TKey, THub> provider;
+
+        protected XBaseTagProvided(
+            IXBaseTagProvider<TKey> tagProvider,
+            IXBaseDtoProvider<TEntity, TDto, TKey, THub> provider,
+            string[] permittedRoles = null
+        )
+        {
+            this.provider = provider;
+            this.tagProvider = tagProvider;
+            this.permittedRoles = permittedRoles;
+        }
+
+        /// <summary>
+        /// Check an Items is Owned for User or not ...
+        /// </summary>
+        /// <param name="item"></param>
+        /// <param name="userInfo"></param>
+        /// <returns></returns>
+        public abstract bool IsOwned(
+            TDto item,
+            XUserClaimsInfoDto userInfo
+        );
+        public abstract bool IsOwned(
+            TEntity item,
+            XUserClaimsInfoDto userInfo
+        );
+
+        /// <summary>
+        /// Check User Has Permission for Manipulate Data or not ...
+        /// </summary>
+        /// <param name="userInfo"></param>
+        /// <returns></returns>
+        public bool HasPermision(
+            XUserClaimsInfoDto userInfo
+        )
+        {
+            //
+            var result =
+                !userInfo.IsNullOrDefault() &&
+                userInfo.HasAccess(permittedRoles);
+
+            //
+            return result;
+        }
+
+        //
+        #region Actions ...
+        /// <summary>
+        /// Attach Tag to Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task AttachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tag.IsNullOrEmpty() &&
+                !userInfo.IsNullOrDefault();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.AddReference(
+                    tag: tag,
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Detach Tag fro Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tag"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTag(
+            TKey id,
+            string tag,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tag.IsNullOrEmpty() &&
+                !userInfo.IsNullOrDefault();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.RemoveReference(
+                    tag: tag,
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Attach Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task AttachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tags.IsNull() &&
+                tags.HasChild();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            // Loop through Tags ...
+            foreach (var tag in tags)
+            {
+                //
+                // Check Cancellation Token ...
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    break;
+                }
+
+                //
+                await AttachTag(
+                    id: id,
+                    tag: tag,
+                    userInfo: userInfo,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+        }
+
+        /// <summary>
+        /// Detach Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="tags"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTags(
+            TKey id,
+            IEnumerable<string> tags,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull() &&
+                !tags.IsNull() &&
+                tags.HasChild();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            // Loop through Tags ...
+            foreach (var tag in tags)
+            {
+                //
+                // Check Cancellation Token ...
+                if (cancellationToken.IsCancellationRequested)
+                {
+                    break;
+                }
+
+                //
+                await DetachTag(
+                    id: id,
+                    tag: tag,
+                    userInfo: userInfo,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+        }
+
+        /// <summary>
+        /// Detach all Attached Tags for Specified Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="userInfo"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task DetachTags(
+            TKey id,
+            XUserClaimsInfoDto userInfo = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid =
+                !id.IsNull();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = await provider.GetAsync(
+                id: id,
+                includeBuilder: null,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            isValid =
+                !item.IsNullOrDefault() &&
+                (IsOwned(item, userInfo) ||
+                HasPermision(userInfo));
+            if (!isValid)
+            {
+                XException.NotAllowed.Throw();
+            }
+
+            //
+            try
+            {
+                //
+                await tagProvider.RemoveReferences(
+                    providedForId: id,
+                    connectionId: connectionId,
+                    cancellationToken: cancellationToken
+                );
+            }
+            catch { }
+        }
+
+        /// <summary>
+        /// Get Specified Model's Item ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<string>> GetTags(
+            TKey id,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Validate ...
+            var isValid = !id.IsNull();
+            if (!isValid)
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            isValid = await provider.IsExistsAsync(
+                id: id,
+                ignoreSoftDeleteds: true,
+                cancellationToken: cancellationToken
+            );
+            if (!isValid)
+            {
+                XException.NotFound.Throw();
+            }
+
+            //
+            var result = (await tagProvider.GetAllReferences(
+                providedForId: id,
+                cancellationToken: cancellationToken
+            ))
+            .Select(x => x.Tag)
+            .Distinct()
+            .ToList();
+
+            //
+            return result;
+        }
+        #endregion
+    }
+}
\ No newline at end of file
diff --git a/Providers/Entities/XTagSeederBase.cs b/Providers/XTagSeederBase.cs
similarity index 93%
rename from Providers/Entities/XTagSeederBase.cs
rename to Providers/XTagSeederBase.cs
index 1daf6e2..9bef85f 100644
--- a/Providers/Entities/XTagSeederBase.cs
+++ b/Providers/XTagSeederBase.cs
@@ -4,7 +4,7 @@ using xDataService.Providers;
 using xTagService.Interfaces;
 using xTagService.Models.Entities;
 
-namespace xTagService.Providers.Entities
+namespace xTagService.Providers
 {
     public abstract class XTagSeederBase : XBaseDbSeeder<XTag, int>, IXTagSeeder
     {