last ...

Configurations/Entities/XAiConversationEntityConfiguration.cs

@@ -1,9 +1,9 @@
 using System;
+using xAiModels.Constants;
+using xDataService.Providers;
+using xAiModels.Models.Entities;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
-using xAiModels.Constants;
-using xAiModels.Models.Entities;
-using xDataService.Providers;
 
 namespace xAiModels.Configurations.Entities
 {

Configurations/Entities/XAiMessageEntityConfiguration.cs

@@ -1,9 +1,9 @@
 using System;
+using xAiModels.Constants;
+using xDataService.Providers;
+using xAiModels.Models.Entities;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
-using xAiModels.Constants;
-using xAiModels.Models.Entities;
-using xDataService.Providers;
 
 namespace xAiModels.Configurations.Entities
 {

Configurations/Entities/XAiProjectEntityConfiguration.cs

@@ -1,9 +1,9 @@
 using System;
+using xAiModels.Constants;
+using xDataService.Providers;
+using xAiModels.Models.Entities;
 using Microsoft.EntityFrameworkCore;
 using Microsoft.EntityFrameworkCore.Metadata.Builders;
-using xAiModels.Constants;
-using xAiModels.Models.Entities;
-using xDataService.Providers;
 
 namespace xAiModels.Configurations.Entities
 {

Configurations/XAiApiConfiguration.cs

@@ -1,5 +1,5 @@
-using xAiModels.Constants;
 using xAiModels.Models;
+using xAiModels.Constants;
 
 namespace xAiModels.Configurations
 {

Constants/XAiDataProviderConstants.cs

@@ -0,0 +1,46 @@
+using xExceptions.Attributes;
+
+namespace xAiModels.Constants
+{
+    public struct XAiDataProviderConstants
+    {
+        public const string XDefaultAiProjectSuffix = "DefAiPrj";
+        public const string XDefaultAiConversationSuffix = "DefAiCnv";
+    }
+
+    public enum XAiDataProviderHubActions
+    {
+        //
+        // Project ...
+        [StringValue("ProjectCreated")]
+        ProjectCreated,
+
+        [StringValue("ProjectUpdated")]
+        ProjectUpdated,
+
+        [StringValue("ProjectRemoved")]
+        ProjectRemoved,
+
+        //
+        // Conversation ...
+        [StringValue("ConversationCreated")]
+        ConversationCreated,
+
+        [StringValue("ConversationUpdated")]
+        ConversationUpdated,
+
+        [StringValue("ConversationRemoved")]
+        ConversationRemoved,
+
+        //
+        // Message ...
+        [StringValue("MessageCreated")]
+        MessageCreated,
+
+        [StringValue("MessageUpdated")]
+        MessageUpdated,
+
+        [StringValue("MessageRemoved")]
+        MessageRemoved,
+    }
+}

Constants/XAiModelProviderType.cs

@@ -6,6 +6,7 @@ namespace xAiModels.Constants
     public enum XAiModelProviderType
     {
         None,
+        OpenAI,
         Ollama,
         DeepSeek,
         HuggingFace        

DI/XDIHelperExtension.cs

@@ -1,25 +1,25 @@
 using System;
-using Microsoft.AspNetCore.Builder;
-using Microsoft.Extensions.DependencyInjection;
-using xAiModels.Providers.Dtos;
-using xAiModels.Providers.Entities;
-using xCommons.Extensions;
-using xDataService.Constants;
 using xDataService.Db;
-using xDataService.Models;
-using xExceptions.Constants;
-using xPushService.Helpers;
 using xPushService.DI;
 using xDataService.DI;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Helpers;
 using xCommons.Helpers;
-using xAiModels.Interfaces.Entities;
-using xAiModels.Interfaces;
+using xAiModels.Helpers;
+using xDataService.Models;
 using xAiModels.Providers;
 using xAiModels.Constants;
-using xAiModels.Interfaces.Enrichers;
+using xCommons.Extensions;
+using xPushService.Helpers;
+using xAiModels.Interfaces;
+using xExceptions.Constants;
+using xDataService.Constants;
+using xAiModels.Providers.Dtos;
+using xAiModels.Interfaces.Dtos;
+using Microsoft.AspNetCore.Builder;
+using xAiModels.Providers.Entities;
+using xAiModels.Interfaces.Entities;
 using xAiModels.Providers.Enrichers;
+using xAiModels.Interfaces.Enrichers;
+using Microsoft.Extensions.DependencyInjection;
 
 namespace xAiModels.DI
 {
@@ -495,6 +495,12 @@ namespace xAiModels.DI
             #endregion
             #endregion
 
+            //
+            // Data Provider ...
+            services.Add(
+                new ServiceDescriptor(typeof(IXAiDataProvider), typeof(XAiDataProvider), lifeTime)
+            );
+
             //
             Log("Service Regitration Succeed ...");
         }

Extensions/ChatResponseExtensions.cs

@@ -1,5 +1,5 @@
-using Microsoft.Extensions.AI;
 using xCommons.Extensions;
+using Microsoft.Extensions.AI;
 
 namespace xAiModels.Extensions
 {

Extensions/ChatRoleExtensions.cs

@@ -1,6 +1,6 @@
-using Microsoft.Extensions.AI;
 using xAiModels.Constants;
 using xCommons.Extensions;
+using Microsoft.Extensions.AI;
 
 namespace xAiModels.Extensions
 {

Extensions/XAiApiConfigurationExtensions.cs

@@ -1,7 +1,7 @@
 using System.Linq;
-using xAiModels.Configurations;
 using xAiModels.Models;
 using xCommons.Extensions;
+using xAiModels.Configurations;
 
 namespace xAiModels.Extensions
 {

Extensions/XAiModelsExtensions.cs

@@ -0,0 +1,466 @@
+using System;
+using System.Linq;
+using xAiModels.Models;
+using xModels.Extensions;
+using xCommons.Extensions;
+using xAiModels.Constants;
+using xAiModels.Models.Dtos;
+using xExceptions.Constants;
+using Microsoft.Extensions.AI;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
+
+namespace xAiModels.Extensions
+{
+    /// <summary>
+    /// Extensions Methods for XAiModels ...
+    /// </summary>
+    public static class XAiModelsExtensions
+    {
+        /// <summary>
+        /// Validate a Project for Add Or Update ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValidForAddOrUpdate(this XAiProject source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                !source.Prompt.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+        public static bool IsValidForAddOrUpdate(this XAiProjectDto source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                !source.Prompt.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate a Conversation for Add Or Update ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValidForAddOrUpdate(this XAiConversation source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                !source.ProjectId.IsNull() &&
+                !source.ProjectId.IsDefaultGuid();
+
+            //
+            return result;
+        }
+        public static bool IsValidForAddOrUpdate(this XAiConversationDto source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                !source.ProjectId.IsNull() &&
+                !source.ProjectId.IsDefaultGuid();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate a Message for Add Or Update ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValidForAddOrUpdate(this XAiMessage source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                source.Role.IsValid() &&
+                !source.ConversationId.IsNull() &&
+                !source.ConversationId.IsDefaultGuid() &&
+                !source.Content.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+        public static bool IsValidForAddOrUpdate(this XAiMessageDto source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.OwnerId.IsNullOrEmpty() &&
+                source.Role.IsValid() &&
+                !source.ConversationId.IsNull() &&
+                !source.ConversationId.IsDefaultGuid() &&
+                !source.Content.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate a Model Descriptor ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValid(this XAiModelDescriptor source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.Name.IsNullOrEmpty() &&
+                !source.Url.IsNullOrEmpty() &&
+                source.Url.IsValidUrl() &&
+                !source.LLM.IsNullOrEmpty() &&
+                source.Provider != Constants.XAiModelProviderType.None;
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate Specified Param ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValid(this XAiPromptParam source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.Name.IsNullOrEmpty() &&
+                !source.Param.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate Specified Prompt ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValid(this XAiPromptDescriptor source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.Name.IsNullOrEmpty() &&
+                !source.Template.IsNullOrEmpty();
+            if (!result)
+            {
+                return result;
+            }
+
+            //
+            if (source.Params.HasChild())
+            {
+                result =
+                    result &&
+                    source.Params.All(x => x.IsValid());
+            }
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate a Request for Retrieve Response in Controllers ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValid(this XAiResponseRequest source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                !source.Prompt.IsNullOrEmpty();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Validate a File Extraction Result ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static bool IsValid(this XFileExtractionResult source)
+        {
+            //
+            var result =
+                !source.IsNullOrDefault() &&
+                (
+                    source.Images.HasChild() ||
+                    !source.Text.IsNullOrEmpty() ||
+                    !source.AudioTranscript.IsNullOrEmpty()
+                );
+            return result;
+        }
+
+        /// <summary>
+        /// Converts a File Extraction Result to AI Contents ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <returns></returns>
+        public static IList<AIContent> ToAIContents(this XFileExtractionResult source)
+        {
+            //
+            var result = new List<AIContent>();
+
+            //
+            if (source.IsValid())
+            {
+                //
+                // Main Text ...
+                if (!source.Text.IsNullOrEmpty())
+                {
+                    result.Add(new TextContent(source.Text));
+                }
+
+                //
+                // Images ...
+                if (source.Images.HasChild())
+                {
+                    //
+                    foreach (var img in source.Images)
+                    {
+                        result.Add(new DataContent(img.Bytes, img.MimeType));
+                    }
+                }
+
+                //
+                // Transcripted Audio ...
+                if (!source.AudioTranscript.IsNullOrEmpty())
+                {
+                    result.Add(new TextContent($"[Audio Transcript]\n{source.AudioTranscript}"));
+                }
+            }
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Check a Collection Contains Default Project for Specified Owner or not ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="ownerId"></param>
+        /// <returns></returns>
+        public static bool HasDefaultProject(
+            this IEnumerable<XAiProjectDto> source,
+            string ownerId
+        )
+        {
+            //
+            // Validate Args ...
+            if (source.HasChild() ||
+                ownerId.IsNullOrEmpty())
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = source
+                .FirstOrDefault(x =>
+                    x.Title
+                        .ToNormalString()
+                        .Contains(ownerId.ToNormalString()) &&
+                    x.Title
+                        .ToNormalString()
+                        .Contains(XAiModelsConstants.DefaultXAiProjectDescriptionResourceID.ToNormalString())
+            );
+
+            //
+            var result = !item.IsNullOrDefault();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Check a Collection Contains Default Conversation for Specified Project or not ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="ownerId"></param>
+        /// <param name="projectId"></param>
+        /// <returns></returns>
+        public static bool HasDefaultConversation(
+            this IEnumerable<XAiConversationDto> source,
+            string ownerId,
+            Guid projectId
+        )
+        {
+            //
+            // Validate Args ...
+            if (source.HasChild() ||
+                projectId.IsDefaultGuid())
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = source
+                .FirstOrDefault(x =>
+                    x.Title
+                        .ToNormalString()
+                        .Contains(ownerId.ToNormalString()) &&
+                    x.Title
+                        .ToNormalString()
+                        .Contains(projectId.ToString().ToNormalString()) &&
+                    x.Title
+                        .ToNormalString()
+                        .Contains(XAiModelsConstants.DefaultXAiConversationTitleResourceID)
+            );
+
+            //
+            var result = !item.IsNullOrDefault();
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Retrieve Default Project Id from a Collection ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="ownerId"></param>
+        /// <returns></returns>
+        public static Guid GetDafualtProject(
+            this IEnumerable<XAiProjectDto> source,
+            string ownerId
+        )
+        {
+            //
+            // Validate Args ...
+            if (!source.HasChild() ||
+                ownerId.IsNullOrEmpty())
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = source
+                .FirstOrDefault(x =>
+                    x.Title
+                        .ToNormalString()
+                        .Contains(ownerId.ToNormalString()) &&
+                    x.Title
+                        .ToNormalString()
+                        .Contains(XAiModelsConstants.XAiProjectTitleIdentifier.ToNormalString())
+            );
+            if (item.IsNullOrDefault())
+            {
+                XException.NotFound.Throw();
+            }
+
+            //
+            return item.Id;
+        }
+
+        /// <summary>
+        /// Get Default Conversation Id from a Collection Contains ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="ownerId"></param>
+        /// <param name="projectId"></param>
+        /// <returns></returns>
+        public static Guid GetDefaultConversation(
+            this IEnumerable<XAiConversationDto> source,
+            string ownerId,
+            Guid projectId
+        )
+        {
+            //
+            // Validate Args ...
+            if (!source.HasChild() ||
+                ownerId.IsNullOrEmpty() ||
+                projectId.IsDefaultGuid())
+            {
+                XException.InvalidArgs.Throw();
+            }
+
+            //
+            var item = source
+                .FirstOrDefault(x =>
+                    x.Title
+                        .ToNormalString()
+                        .Contains(ownerId.ToNormalString()) &&
+                    x.Title
+                        .ToNormalString()
+                        .Contains(XAiModelsConstants.XAiConversationTitleIdentifier.ToNormalString())
+            );
+            if (item.IsNullOrDefault())
+            {
+                XException.NotFound.Throw();
+            }
+
+            //
+            var result = item.Id;
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Converts a Message Dto to ChatMessage ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="additionalContents"></param>
+        /// <returns></returns>
+        public static ChatMessage ToChatMessages(
+            this XAiMessageDto source,
+             IList<AIContent> additionalContents = null
+        )
+        {
+            //
+            ChatMessage result = null;
+
+            //
+            if (!source.IsNullOrDefault())
+            {
+                //
+                var contents = new List<AIContent>
+                {
+                    //
+                    // Add Source Content ...
+                    new TextContent(source.Content)
+                };
+
+                //
+                // Add Additional Content ...
+                if (additionalContents.HasChild())
+                {
+                    contents.AddRange(additionalContents);
+                }
+
+                //
+                result = new ChatMessage
+                {
+                    Contents = contents,
+                    AuthorName =
+                    source.Role == XAiChatRole.User &&
+                    !source.Owner.IsNullOrDefault()
+                        ? source.Owner.GetFullname()
+                        : string.Empty,
+                    Role = source.Role.ToChatRole(),
+                    MessageId = source.Id.ToString(),
+                };
+            }
+
+            //
+            return result;
+        }
+    }
+}

Helpers/XAiModelsHelper.cs

@@ -1,12 +1,12 @@
 using System;
 using GraphQL.Types;
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
-using xAiModels.Providers.Entities;
-using xAiModels.Providers.GraphQL;
 using xDataService.Db;
 using xDataService.Models;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Providers.GraphQL;
+using xAiModels.Providers.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Helpers
 {

Interfaces/Dtos/IXAiConversationDtoHub.cs

@@ -1,7 +1,7 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Dtos/IXAiConversationRepositoryService.cs

@@ -1,10 +1,68 @@
 using System;
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
+using System.Threading.Tasks;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Dtos
 {
     public interface IXAiConversationRepositoryService : IXBaseRepositoryService<XAiConversation, XAiConversationDto, Guid>
-    { }
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> Enrich(
+            XAiConversation source,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> Enrich(
+            XAiConversationDto source,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversation> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversationDto> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+        #endregion                
+    }
 }

Interfaces/Dtos/IXAiConversationServiceProvider.cs

@@ -1,8 +1,8 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
-using xAiModels.Providers.Dtos;
 using xPushService.Interfaces;
+using xAiModels.Providers.Dtos;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Dtos/IXAiMessageDtoHub.cs

@@ -1,7 +1,7 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Dtos/IXAiMessageRepositoryService.cs

@@ -1,10 +1,60 @@
 using System;
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
+using System.Threading.Tasks;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Dtos
 {
     public interface IXAiMessageRepositoryService : IXBaseRepositoryService<XAiMessage, XAiMessageDto, Guid>
-    { }
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> Enrich(
+            XAiMessage source,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> Enrich(
+            XAiMessageDto source,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessage> sources,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessageDto> sources,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
+    }
 }

Interfaces/Dtos/IXAiMessageServiceProvider.cs

@@ -1,8 +1,8 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
-using xAiModels.Providers.Dtos;
 using xPushService.Interfaces;
+using xAiModels.Providers.Dtos;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Dtos/IXAiProjectDtoHub.cs

@@ -1,7 +1,7 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Dtos/IXAiProjectRepositoryService.cs

@@ -1,10 +1,76 @@
 using System;
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
+using System.Threading.Tasks;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Dtos
 {
     public interface IXAiProjectRepositoryService : IXBaseRepositoryService<XAiProject, XAiProjectDto, Guid>
-    { }
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> Enrich(
+            XAiProject source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> Enrich(
+            XAiProjectDto source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProject> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProjectDto> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+        #endregion        
+    }
 }

Interfaces/Dtos/IXAiProjectServiceProvider.cs

@@ -1,8 +1,8 @@
 using System;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
-using xAiModels.Providers.Dtos;
 using xPushService.Interfaces;
+using xAiModels.Providers.Dtos;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Dtos
 {

Interfaces/Enrichers/IXAiConversationEnricher.cs

@@ -1,11 +1,69 @@
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xDataService.Interfaces;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Enrichers
 {
     /// <summary>
     /// Ai Conversation Enricher ...
     /// </summary>
-    public interface IXAiConversationEnricher : IXBaseEnricher<XAiConversationDto, XAiConversationDto>
-    { }
+    public interface IXAiConversationEnricher
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> Enrich(
+            XAiConversation source,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> Enrich(
+            XAiConversationDto source,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversation> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversationDto> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+        #endregion                
+    }
 }

Interfaces/Enrichers/IXAiMessageEnricher.cs

@@ -1,8 +1,58 @@
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xDataService.Interfaces;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Enrichers
 {
-    public interface IXAiMessageEnricher : IXBaseEnricher<XAiMessageDto, XAiMessageDto>
-    { }
+    public interface IXAiMessageEnricher
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> Enrich(
+            XAiMessage source,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> Enrich(
+            XAiMessageDto source,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessage> sources,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessageDto> sources,
+            CancellationToken cancellationToken = default
+        );
+        #endregion        
+    }
 }

Interfaces/Enrichers/IXAiProjectEnricher.cs

@@ -1,8 +1,74 @@
+using System.Threading;
 using xAiModels.Models.Dtos;
-using xDataService.Interfaces;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 
 namespace xAiModels.Interfaces.Enrichers
 {
-    public interface IXAiProjectEnricher : IXBaseEnricher<XAiProjectDto, XAiProjectDto>
-    { }
+    public interface IXAiProjectEnricher
+    {
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> Enrich(
+            XAiProject source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> Enrich(
+            XAiProjectDto source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProject> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProjectDto> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+        #endregion        
+    }
 }

Interfaces/Entities/IXAiConversationEntityHub.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationGraphQLTypeHelper.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationKeyGenerator.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationRepository.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationRepositoryEvents.cs

@@ -1,5 +1,5 @@
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationRepositoryProvider.cs

@@ -1,7 +1,7 @@
 using System;
+using xPushService.Interfaces;
 using xAiModels.Models.Entities;
 using xAiModels.Providers.Entities;
-using xPushService.Interfaces;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiConversationSeeder.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiDocumentEntityHub.cs

@@ -0,0 +1,12 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+
+namespace xAiModels.Interfaces.Entities
+{
+    public interface IXAiDocumentEntityHub
+    {
+        
+    }
+}

Interfaces/Entities/IXAiMessageEntityHub.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageGraphQLTypeHelper.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageKeyGenerator.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageRepository.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageRepositoryEvents.cs

@@ -1,5 +1,5 @@
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageRepositoryProvider.cs

@@ -1,7 +1,7 @@
 using System;
+using xPushService.Interfaces;
 using xAiModels.Models.Entities;
 using xAiModels.Providers.Entities;
-using xPushService.Interfaces;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiMessageSeeder.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectEntityHub.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xPushService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectGraphQLTypeHelper.cs

@@ -1,9 +1,6 @@
 using System;
-using System.Collections.Generic;
-using System.Linq;
-using System.Threading.Tasks;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectKeyGenerator.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectRepository.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectRepositoryEvents.cs

@@ -1,5 +1,5 @@
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectRepositoryProvider.cs

@@ -1,7 +1,7 @@
 using System;
+using xPushService.Interfaces;
 using xAiModels.Models.Entities;
 using xAiModels.Providers.Entities;
-using xPushService.Interfaces;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/Entities/IXAiProjectSeeder.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.Interfaces;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Interfaces.Entities
 {

Interfaces/IXAiConversationTitleResourceProvider.cs

@@ -2,6 +2,6 @@ using xStringService.Interfaces;
 
 namespace xAiModels.Interfaces
 {
-    public interface IXAiConversationTitleResourceProvider : IXItemResourceProvider
+    public interface IXAiConversationTitleResourceProvider : IXOwnedItemResourceProvider
     { }
 }

Interfaces/IXAiDataProvider.cs

@@ -1,3 +1,10 @@
+using System;
+using xModels.Dtos;
+using System.Threading;
+using xAiModels.Models.Dtos;
+using System.Threading.Tasks;
+using System.Collections.Generic;
+
 namespace xAiModels.Interfaces
 {
     /// <summary>
@@ -5,6 +12,291 @@ namespace xAiModels.Interfaces
     /// </summary>
     public interface IXAiDataProvider
     {
-        
+        //
+        #region Getters ...
+        /// <summary>
+        /// Retrieve Specified Project ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> GetProject(
+            Guid id,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Retrieve Specified Conversation ...
+        /// </summary>
+        /// <param name="id"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> GetConversation(
+            Guid id,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
+
+        //
+        #region Loaders ...
+        /// <summary>
+        /// Load Projects List of Specified Owner ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> LoadProjects(
+            string ownerId,
+            string connectionId = null,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Load List of Conversations for Specified Project ... 
+        /// </summary>
+        /// <param name="projectId"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> LoadConversations(
+            Guid projectId,
+            bool fillMessages = false,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Load Messages of Specified Conversation ...
+        /// </summary>
+        /// <param name="conversationId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> LoadMessages(
+            Guid conversationId,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
+
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> Enrich(
+            XAiProjectDto source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProjectDto> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> Enrich(
+            XAiConversationDto source,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversationDto> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> Enrich(
+            XAiMessageDto source,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessageDto> sources,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
+
+        //
+        #region Defaults ...
+        /// <summary>
+        /// Retrieve Default Project of Specified Owner ...
+        /// Create it if not Handled ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> GetDefaultProject(
+            string ownerId,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Retrieve Default Conversation of Specified Owner ...
+        /// Create it if not Handled ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="projectId"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> GetDefaultConversation(
+            string ownerId,
+            Guid projectId,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
+
+        //
+        #region Creator/Adders ...
+        /// <summary>
+        /// Create Project ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="item"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiProjectDto> CreateProject(
+            string ownerId,
+            XAiProjectDto item = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Create Conversation ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="projectId"></param>
+        /// <param name="item"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiConversationDto> CreateConversation(
+            string ownerId,
+            Guid projectId,
+            XAiConversationDto item = null,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Add Message ...
+        /// </summary>
+        /// <param name="conversationId"></param>
+        /// <param name="item"></param>
+        /// <param name="connectionId"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XAiMessageDto> AddMessage(
+            Guid conversationId,
+            XAiMessageDto item,
+            string connectionId = null,
+            CancellationToken cancellationToken = default
+        );
+        #endregion    
+
+        //
+        #region Query ...
+        /// <summary>
+        /// Query Projects ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="query"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XQueryResult<XAiProjectDto>> QueryProjects(
+            string ownerId,
+            XQuery query,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Query Conversations ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="projectId"></param>
+        /// <param name="query"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XQueryResult<XAiConversationDto>> QueryConversations(
+            string ownerId,
+            Guid projectId,
+            XQuery query,
+            CancellationToken cancellationToken = default
+        );
+
+        /// <summary>
+        /// Query Messages ...
+        /// </summary>
+        /// <param name="ownerId"></param>
+        /// <param name="conversationId"></param>
+        /// <param name="query"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        Task<XQueryResult<XAiMessageDto>> QueryMessages(
+            string ownerId,
+            Guid conversationId,
+            XQuery query,
+            CancellationToken cancellationToken = default
+        );
+        #endregion
     }
 }

Interfaces/IXAiProjectDescriptionResourceProvider.cs

@@ -2,6 +2,6 @@ using xStringService.Interfaces;
 
 namespace xAiModels.Interfaces
 {
-    public interface IXAiProjectDescriptionResourceProvider : IXItemResourceProvider
+    public interface IXAiProjectDescriptionResourceProvider : IXOwnedItemResourceProvider
     { }
 }

Interfaces/IXAiProjectTitleResourceProvider.cs

@@ -2,6 +2,6 @@ using xStringService.Interfaces;
 
 namespace xAiModels.Interfaces
 {
-    public interface IXAiProjectTitleResourceProvider : IXItemResourceProvider
+    public interface IXAiProjectTitleResourceProvider : IXOwnedItemResourceProvider
     { }
 }

Models/Dtos/XAiConversationDto.cs

@@ -1,6 +1,7 @@
 using System;
 using xModels.Base;
 using xModels.Dtos;
+using System.Collections.Generic;
 
 namespace xAiModels.Models.Dtos
 {
@@ -40,6 +41,11 @@ namespace xAiModels.Models.Dtos
         /// </summary>
         public DateTime UpdatedAt { get; set; }
 
+        /// <summary>
+        /// Conversation Messages ...
+        /// </summary>
+        public virtual IEnumerable<XAiMessageDto> Messages { get; set; } = [];
+
         /// <summary>
         /// Project ID ...
         /// </summary>

Models/Dtos/XAiMessageDto.cs

@@ -1,10 +1,10 @@
 using System;
-using System.Collections.Generic;
-using System.ComponentModel.DataAnnotations.Schema;
-using xAiModels.Constants;
-using xCommons.Extensions;
 using xModels.Base;
 using xModels.Dtos;
+using xAiModels.Constants;
+using xCommons.Extensions;
+using System.Collections.Generic;
+using System.ComponentModel.DataAnnotations.Schema;
 
 namespace xAiModels.Models.Dtos
 {
@@ -65,7 +65,7 @@ namespace xAiModels.Models.Dtos
         /// <summary>
         /// Meta Data of MEssage in Json ... 
         /// </summary>
-        public string MeatDatas
+        public string MetaDatas
         {
             //
             get => _metadata;

Models/Dtos/XAiProjectDto.cs

@@ -1,7 +1,7 @@
 using System;
-using System.Collections.Generic;
 using xModels.Base;
 using xModels.Dtos;
+using System.Collections.Generic;
 
 namespace xAiModels.Models.Dtos
 {

Models/Entities/XAiConversation.cs

@@ -1,6 +1,6 @@
 using System;
-using System.ComponentModel.DataAnnotations;
 using xModels.Base;
+using System.ComponentModel.DataAnnotations;
 
 namespace xAiModels.Models.Entities
 {

Models/Entities/XAiDocument.cs

@@ -0,0 +1,61 @@
+using System;
+using System.ComponentModel.DataAnnotations;
+using xModels.Base;
+
+namespace xAiModels.Models.Entities
+{
+    /// <summary>
+    /// Represents an embedd document in the AI system.
+    /// </summary>
+    public class XAiDocument : XBaseGuidIDEntity
+    {
+        /// <summary>
+        /// User Identifier ...
+        /// </summary>
+        /// <value></value>
+        [Required]
+        [StringLength(255)]
+        public string OwnerId { get; set; }
+
+        /// <summary>
+        /// Title of Document ...
+        /// </summary>
+        [StringLength(255)]
+        public string Title { get; set; }
+
+        /// <summary>
+        /// Content of Document ...
+        /// </summary>
+        public string Content { get; set; }
+
+        /// <summary>
+        /// Hash of the Document Content ...
+        /// </summary>
+        public string ContentHash { get; set; } = string.Empty;
+
+        /// <summary>
+        /// Embedding Model Identifier ...
+        /// </summary>
+        public string EmbeddingModel { get; set; } = string.Empty;
+
+        /// <summary>
+        /// Dimensions of the Embedding ...
+        /// </summary>
+        public int Dimensions { get; set; }
+
+        /// <summary>
+        /// Vector representation of the Document ...
+        /// </summary>
+        public byte[] Vector { get; set; } = [];
+
+        /// <summary>
+        /// Created Time ...
+        /// </summary>
+        public DateTime CreatedOn { get; set; }
+
+        /// <summary>
+        /// Updated Time ...
+        /// </summary>
+        public DateTime UpdatedAt { get; set; }
+    }
+}

Models/Entities/XAiMessage.cs

@@ -1,10 +1,10 @@
 using System;
+using xModels.Base;
+using xAiModels.Constants;
+using xCommons.Extensions;
 using System.Collections.Generic;
 using System.ComponentModel.DataAnnotations;
 using System.ComponentModel.DataAnnotations.Schema;
-using xAiModels.Constants;
-using xCommons.Extensions;
-using xModels.Base;
 
 namespace xAiModels.Models.Entities
 {
@@ -61,7 +61,7 @@ namespace xAiModels.Models.Entities
         /// <summary>
         /// Meta Data of MEssage in Json ... 
         /// </summary>
-        public string MeatDatas
+        public string MetaDatas
         {
             //
             get => _metadata;

Models/Entities/XAiProject.cs

@@ -1,6 +1,6 @@
 using System;
-using System.ComponentModel.DataAnnotations;
 using xModels.Base;
+using System.ComponentModel.DataAnnotations;
 
 namespace xAiModels.Models.Entities
 {

Models/XAiPromptDescriptor.cs

@@ -0,0 +1,49 @@
+namespace xAiModels.Models
+{
+    /// <summary>
+    /// Describe Specified Prompt ...
+    /// </summary>
+    public class XAiPromptDescriptor
+    {
+        /// <summary>
+        /// Prompt Name ...
+        /// </summary>
+        public string Name { get; set; }
+
+        /// <summary>
+        /// Prompt Template ... 
+        /// </summary>
+        public string Template { get; set; }
+
+        /// <summary>
+        /// Prompt Description ...
+        /// </summary>
+        public string Description { get; set; }
+
+        /// <summary>
+        /// Prompt Template Params ...
+        /// </summary>
+        public XAiPromptParam[] Params { get; set; } = [];
+    }
+
+    /// <summary>
+    /// Specified a Prompt Param ...
+    /// </summary>
+    public class XAiPromptParam
+    {
+        /// <summary>
+        /// Param Name ...
+        /// </summary>
+        public string Name { get; set; }
+
+        /// <summary>
+        /// Param Identifier ...
+        /// </summary>
+        public string Param { get; set; }
+
+        /// <summary>
+        /// Parma Description ...
+        /// </summary>
+        public string Description { get; set; }
+    }
+}

Models/XAiResonseMessage.cs

@@ -0,0 +1,16 @@
+using System;
+using xModels.Base;
+using xAiModels.Constants;
+
+namespace xAiModels.Models
+{
+    public class XAiResonseMessage : XBaseDto
+    {
+        public long Sequence { get; set; }
+        public Guid RespondTo { get; set; }
+        public string OwnerId { get; set; }
+        public string Content { get; set; }
+        public XAiChatRole Role { get; set; }
+        public DateTime RespondedOn { get; set; }
+    }
+}

Models/XAiResponseRequest.cs

@@ -0,0 +1,25 @@
+using System;
+
+namespace xAiModels.Models
+{
+    /// <summary>
+    /// /Request for a Response in Controllers ...
+    /// </summary>
+    public class XAiResponseRequest
+    {
+        /// <summary>
+        /// Prompt Text ...
+        /// </summary>
+        public string Prompt { get; set; }
+
+        /// <summary>
+        /// Specified Project Id ...
+        /// </summary>
+        public Guid ProjectId { get; set; }
+
+        /// <summary>
+        /// Specified Conversation Id ...
+        /// </summary>
+        public Guid ConversationId { get; set; }
+    }
+}

Models/XFileExtractionResult.cs

@@ -0,0 +1,71 @@
+using System.Collections.Generic;
+
+namespace xAiModels.Models
+{
+    /// <summary>
+    /// Holds File Extraction Result ...
+    /// </summary>    
+    public class XFileExtractionResult
+    {
+        /// <summary>
+        /// Extracted String Content ...
+        /// </summary>
+        public string Text { get; set; } = string.Empty;
+
+        /// <summary>
+        /// Extracted Images for Vision Model ...
+        /// </summary>
+        public IList<XExtractedImage> Images { get; set; } = [];
+
+        /// <summary>
+        /// Extracted Content from Audio File ...
+        /// </summary>
+        public string AudioTranscript { get; set; } = string.Empty;
+
+        /// <summary>
+        /// Main File Name ...
+        /// </summary>
+        public string FileName { get; set; }
+
+        /// <summary>
+        /// Main File MIME Type ...
+        /// </summary>
+        public string MimeType { get; set; }
+
+        /// <summary>
+        /// Specified Fallback done using Images or not ...
+        /// </summary>
+        public bool UsedImageFallback { get; set; } = false;
+
+        /// <summary>
+        /// Error Message ...
+        /// </summary>
+        public string ErrorMessage { get; set; }
+    }
+
+    /// <summary>
+    /// Extracted Image ...
+    /// </summary>
+    public class XExtractedImage
+    {
+        /// <summary>
+        /// Content as Byte ...
+        /// </summary>
+        public byte[] Bytes { get; set; }
+
+        /// <summary>
+        /// MIME Type of Image ...
+        /// </summary>
+        public string MimeType { get; set; } = "image/png";
+
+        /// <summary>
+        /// for PDF Files ...
+        /// </summary>
+        public int? PageNumber { get; set; }
+
+        /// <summary>
+        /// Describe Image ...
+        /// </summary>
+        public string Description { get; set; }
+    }
+}

Providers/Dtos/XAiConversationDtoHub.cs

@@ -1,9 +1,9 @@
 using System;
-using Microsoft.Extensions.Logging;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Base;
+using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using Microsoft.Extensions.Logging;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Dtos/XAiConversationRepositoryService.cs

@@ -1,485 +1,207 @@
 using System;
-using System.Collections.Generic;
 using System.Linq;
-using System.Linq.Expressions;
-using System.Runtime.CompilerServices;
-using System.Threading;
-using System.Threading.Tasks;
-using AutoMapper;
-using Microsoft.EntityFrameworkCore.Query;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Interfaces.Enrichers;
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
-using xCommons.Extensions;
-using xDataService.Providers;
 using xModels.Dtos;
+using System.Threading;
+using xCommons.Extensions;
+using xAiModels.Interfaces;
+using xAiModels.Models.Dtos;
+using System.Threading.Tasks;
+using xDataService.Providers;
+using xAiModels.Configurations;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
+using xIdentityService.Interfaces;
+using xIdentityService.Extensions;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Dtos
 {
     public class XAiConversationRepositoryService : XBaseRepositoryService<XAiConversation, XAiConversationDto, Guid>, IXAiConversationRepositoryService
     {
-        private readonly IXAiConversationEnricher enricher;
+        private readonly IXIdentityProvider identityProvider;
+        private readonly IXAiConversationRepository repository;
+        private readonly IXAiProjectTitleResourceProvider projectTitleResourceProvider;
+        private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
+        private readonly IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider;
 
         public XAiConversationRepositoryService(
-            IXAiConversationEnricher enricher,
+            IXIdentityProvider identityProvider,
             IXAiConversationRepository repository,
-            IEnumerable<Profile> mapperProfiles = null
+            IXAiProjectTitleResourceProvider projectTitleResourceProvider,
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider,
+            IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider
         ) : base(
             repository,
-            mapperProfiles
+            mapperProfiles:
+            [
+                new XAiModelMappersProfile()
+            ]
         )
         {
-            this.enricher = enricher;
+            this.repository = repository;
+            this.identityProvider = identityProvider;
+            this.projectTitleResourceProvider = projectTitleResourceProvider;
+            this.conversationTitleResourceProvider = conversationTitleResourceProvider;
+            this.projectDescriptionResourceProvider = projectDescriptionResourceProvider;
         }
 
         //
-        #region Actions ...
-        //
-        #region Add ...
+        #region Enrichers ...
         /// <summary>
-        /// add a new Dto ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="item"></param>
-        /// <param name="saveChanges"></param>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public override async Task<XAiConversationDto> AddAsync(
-            XAiConversationDto item,
-            bool saveChanges = true,
+        public virtual async Task<XAiConversationDto> Enrich(
+            XAiConversation source,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            var result = await base.AddAsync(
-                item: item,
-                saveChanges: saveChanges,
+            // Mapping Default ...
+            var result = Mapper.Map<XAiConversationDto>(source);
+            result = await Enrich(
+                source: result,
+                fillMessages: fillMessages,
                 cancellationToken: cancellationToken
             );
 
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
             //
             return result;
         }
 
         /// <summary>
-        /// add or update a Dto (add if not exists/update if exists) ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="item"></param>
-        /// <param name="saveChanges"></param>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public override async Task<XAiConversationDto> AddOrUpdateAsync(
-            XAiConversationDto item,
-            bool saveChanges = true,
+        public virtual async Task<XAiConversationDto> Enrich(
+            XAiConversationDto source,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            var result = await base.AddAsync(
-                item: item,
-                saveChanges: saveChanges,
-                cancellationToken: cancellationToken
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
+            // Handdle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
             {
                 //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
+            }
+
+            //
+            // Handle Title Resource ...
+            XResourceDto titleResource = null;
+            if (!source.Title.IsNullOrEmpty())
+            {
+                //
+                titleResource = await conversationTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
                     cancellationToken: cancellationToken
                 );
             }
 
+            //
+            // Handle Project Info ...
+            XResourceDto projectTitleResource = null;
+            XResourceDto projectDescriptionResource = null;
+            if (!source.ProjectId.IsDefaultGuid())
+            {
+                //
+                projectTitleResource = await projectTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ProjectId,
+                    cancellationToken: cancellationToken
+                );
+
+                //
+                projectDescriptionResource = await projectDescriptionResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ProjectId,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = Mapper.Map<XAiConversationDto>(source, options =>
+            {
+                //
+                options.Items[nameof(source.Owner)] = owner;
+                options.Items[nameof(source.TitleResource)] = titleResource;
+                options.Items[nameof(source.ProjectTitleResource)] = projectTitleResource;
+                options.Items[nameof(source.ProjectDescriptionResource)] = projectDescriptionResource;
+            });
+
             //
             return result;
         }
-        #endregion
 
-        //
-        #region Update ...
         /// <summary>
-        /// Update an Dto values ...
+        /// Enrich Specified Items ...
         /// </summary>
-        /// <param name="id"></param>
-        /// <param name="item"></param>
-        /// <param name="saveChanges"></param>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public override async Task<XAiConversationDto> UpdateAsync(
-            Guid id,
-            XAiConversationDto item,
-            bool saveChanges = true,
+        public virtual async Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversation> sources,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            var result = await base.UpdateAsync(
-                id: id,
-                item: item,
-                saveChanges: saveChanges,
-                cancellationToken: cancellationToken
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    fillMessages: fillMessages,
                     cancellationToken: cancellationToken
-                );
-            }
+                ));
 
             //
+            var result = await Task.WhenAll(tasks);
             return result;
         }
-        #endregion
 
-        //
-        #region Remove ...
         /// <summary>
-        /// remove an Dto by it's Id ...
+        /// Enrich Specified Items ...
         /// </summary>
-        /// <param name="id"></param>
-        /// <param name="softDelete"></param>
-        /// <param name="saveChanges"></param>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public override async Task<XAiConversationDto> RemoveAsync(
-            Guid id,
-            bool softDelete = true,
-            bool saveChanges = true,
+        public virtual async Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversationDto> sources,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            var result = await base.RemoveAsync(
-                id: id,
-                softDelete: softDelete,
-                saveChanges: saveChanges,
-                cancellationToken: cancellationToken
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    fillMessages: fillMessages,
                     cancellationToken: cancellationToken
-                );
-            }
+                ));
 
             //
+            var result = await Task.WhenAll(tasks);
             return result;
         }
-
-        /// <summary>
-        /// remove an Dto ...
-        /// </summary>
-        /// <param name="item"></param>
-        /// <param name="softDelete"></param>
-        /// <param name="saveChanges"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<XAiConversationDto> RemoveAsync(
-            XAiConversationDto item,
-            bool softDelete = true,
-            bool saveChanges = true,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.RemoveAsync(
-                item: item,
-                softDelete: softDelete,
-                saveChanges: saveChanges,
-                cancellationToken: cancellationToken
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-        #endregion
-
-        //
-        #region Retrieve ...
-        /// <summary>
-        /// retrieve an Dto by it's Id ...
-        /// </summary>
-        /// <param name="id"></param>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<XAiConversationDto> GetAsync(
-            Guid id,
-            bool ignoreSoftDeleteds = true,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.GetAsync(
-                id: id,
-                includeBuilder: includeBuilder,
-                cancellationToken: cancellationToken,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// retrieve all exists Dtos ...
-        /// </summary>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="orderBuilder"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<IEnumerable<XAiConversationDto>> GetAllAsync(
-            bool ignoreSoftDeleteds = true,
-            Func<IQueryable<XAiConversation>, IOrderedQueryable<XAiConversation>> orderBuilder = null,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.GetAllAsync(
-                orderBuilder: orderBuilder,
-                includeBuilder: includeBuilder,
-                cancellationToken: cancellationToken,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichRangeAsync(
-                    sources: result,
-                    destinations: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// retrieve all exists Dtos
-        /// as Async Enumerable ...
-        /// </summary>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="orderBuilder"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async IAsyncEnumerable<XAiConversationDto> GetAllAsAsyncEnumerable(
-            bool ignoreSoftDeleteds = true,
-            Func<IQueryable<XAiConversation>, IOrderedQueryable<XAiConversation>> orderBuilder = null,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            [EnumeratorCancellation] CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var enumerable = base.GetAllAsAsyncEnumerable(
-                orderBuilder: orderBuilder,
-                includeBuilder: includeBuilder,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-            await foreach (var dto in enumerable)
-            {
-                //
-                if (cancellationToken.IsCancellationRequested)
-                {
-                    yield break;
-                }
-
-                //
-                await enricher.EnrichAsync(
-                    source: dto,
-                    destination: dto,
-                    cancellationToken: cancellationToken
-                );
-                yield return dto;
-            }
-        }
-
-        /// <summary>
-        /// find an Dto by providing a Conditional Expression ...
-        /// </summary>
-        /// <param name="predicate"></param>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<XAiConversationDto> FindOneAsync(
-            Expression<Func<XAiConversation, bool>> predicate,
-            bool ignoreSoftDeleteds = true,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.FindOneAsync(
-                predicate: predicate,
-                includeBuilder: includeBuilder,
-                cancellationToken: cancellationToken,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichAsync(
-                    source: result,
-                    destination: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// find a collection of Dtos by proving a Conditional Expression ...
-        /// </summary>
-        /// <param name="predicate"></param>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="orderBuilder"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<IEnumerable<XAiConversationDto>> FindManyAsync(
-            Expression<Func<XAiConversation, bool>> predicate,
-            bool ignoreSoftDeleteds = true,
-            Func<IQueryable<XAiConversation>, IOrderedQueryable<XAiConversation>> orderBuilder = null,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.FindManyAsync(
-                predicate: predicate,
-                orderBuilder: orderBuilder,
-                includeBuilder: includeBuilder,
-                cancellationToken: cancellationToken,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichRangeAsync(
-                    sources: result,
-                    destinations: result,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// retrieve Dtos based on XQuery Pagination structure ...
-        /// </summary>
-        /// <param name="query"></param>
-        /// <param name="ignoreSoftDeleteds"></param>
-        /// <param name="predicate"></param>
-        /// <param name="orderBuilder"></param>
-        /// <param name="includeBuilder"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public override async Task<XQueryResult<XAiConversationDto>> QueryAsync(
-            XQuery query,
-            bool ignoreSoftDeleteds = true,
-            Expression<Func<XAiConversation, bool>> predicate = null,
-            Func<IQueryable<XAiConversation>, IOrderedQueryable<XAiConversation>> orderBuilder = null,
-            Func<IQueryable<XAiConversation>, IIncludableQueryable<XAiConversation, object>> includeBuilder = null,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            var result = await base.QueryAsync(
-                query: query,
-                predicate: predicate,
-                orderBuilder: orderBuilder,
-                includeBuilder: includeBuilder,
-                cancellationToken: cancellationToken,
-                ignoreSoftDeleteds: ignoreSoftDeleteds
-            );
-
-            //
-            // Do Enrichment if result Exists ...
-            if (!result.IsNullOrDefault())
-            {
-                //
-                await enricher.EnrichRangeAsync(
-                    sources: result.Items,
-                    destinations: result.Items,
-                    cancellationToken: cancellationToken
-                );
-            }
-
-            //
-            return result;
-        }
-        #endregion
-        #endregion
+        #endregion                
     }
 }

Providers/Dtos/XAiConversationServiceProvider.cs

@@ -1,11 +1,11 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Dtos;
+using xPushService.Base;
 using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Dtos/XAiMessageDtoHub.cs

@@ -1,9 +1,9 @@
 using System;
-using Microsoft.Extensions.Logging;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Base;
+using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using Microsoft.Extensions.Logging;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Dtos/XAiMessageRepositoryService.cs

@@ -1,23 +1,165 @@
 using System;
-using System.Collections.Generic;
-using AutoMapper;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Interfaces.Entities;
+using System.Linq;
+using xModels.Dtos;
+using System.Threading;
+using xCommons.Extensions;
+using xAiModels.Interfaces;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
+using System.Threading.Tasks;
 using xDataService.Providers;
+using xAiModels.Configurations;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
+using xIdentityService.Interfaces;
+using xIdentityService.Extensions;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Dtos
 {
     public class XAiMessageRepositoryService : XBaseRepositoryService<XAiMessage, XAiMessageDto, Guid>, IXAiMessageRepositoryService
     {
+        private readonly IXIdentityProvider identityProvider;
+        private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
+
         public XAiMessageRepositoryService(
             IXAiMessageRepository repository,
-            IEnumerable<Profile> mapperProfiles = null
+            IXIdentityProvider identityProvider,
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider
         ) : base(
             repository,
-            mapperProfiles
+            mapperProfiles:
+            [
+                new XAiModelMappersProfile()
+            ]
         )
-        { }
+        {
+            this.identityProvider = identityProvider;
+            this.conversationTitleResourceProvider = conversationTitleResourceProvider;
+        }
+
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XAiMessageDto> Enrich(
+            XAiMessage source,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Mapping Default ...
+            var result = Mapper.Map<XAiMessageDto>(source);
+            result = await Enrich(
+                source: result,
+                cancellationToken: cancellationToken
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XAiMessageDto> Enrich(
+            XAiMessageDto source,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Handdle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
+            {
+                //
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
+            }
+
+            //
+            // Hanlde Conversation Title ...
+            string conversationTitle = string.Empty;
+            XResourceDto conversationTitleResource = null;
+            if (!source.ConversationId.IsDefaultGuid())
+            {
+                //
+                conversationTitleResource = await conversationTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ConversationId,
+                    cancellationToken: cancellationToken
+                );
+                if (!conversationTitleResource.IsNullOrDefault())
+                {
+                    conversationTitle = conversationTitleResource.Resource;
+                }
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = Mapper.Map<XAiMessageDto>(source, options =>
+            {
+                //
+                options.Items[nameof(source.Owner)] = owner;
+                options.Items[nameof(source.ConversationTitle)] = conversationTitle;
+                options.Items[nameof(source.ConversationTitleResouce)] = conversationTitleResource;
+            });
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessage> sources,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(x, cancellationToken));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessageDto> sources,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(x, cancellationToken));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+        #endregion
     }
 }

Providers/Dtos/XAiMessageServiceProvider.cs

@@ -1,11 +1,11 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Dtos;
+using xPushService.Base;
 using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Dtos/XAiProjectDtoHub.cs

@@ -1,9 +1,9 @@
 using System;
-using Microsoft.Extensions.Logging;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
 using xPushService.Base;
+using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using Microsoft.Extensions.Logging;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Dtos/XAiProjectRepositoryService.cs

@@ -1,23 +1,322 @@
 using System;
-using System.Collections.Generic;
-using AutoMapper;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Interfaces.Entities;
+using System.Linq;
+using xModels.Dtos;
+using System.Threading;
+using xCommons.Extensions;
+using xAiModels.Interfaces;
 using xAiModels.Models.Dtos;
-using xAiModels.Models.Entities;
+using System.Threading.Tasks;
 using xDataService.Providers;
+using xAiModels.Configurations;
+using xAiModels.Interfaces.Dtos;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
+using xIdentityService.Interfaces;
+using xIdentityService.Extensions;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Dtos
 {
     public class XAiProjectRepositoryService : XBaseRepositoryService<XAiProject, XAiProjectDto, Guid>, IXAiProjectRepositoryService
     {
+        private readonly IXIdentityProvider identityProvider;
+        private readonly IXAiMessageRepository messageRepository;
+        private readonly IXAiConversationRepository conversationRepository;
+        private readonly IXAiProjectTitleResourceProvider projectTitleResourceProvider;
+        private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
+        private readonly IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider;
+
         public XAiProjectRepositoryService(
             IXAiProjectRepository repository,
-            IEnumerable<Profile> mapperProfiles = null
+            IXIdentityProvider identityProvider,
+            IXAiMessageRepository messageRepository,
+            IXAiConversationRepository conversationRepository,
+            IXAiProjectTitleResourceProvider projectTitleResourceProvider,
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider,
+            IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider
         ) : base(
             repository,
-            mapperProfiles
+            mapperProfiles:
+            [
+                new XAiModelMappersProfile()
+            ]
         )
-        { }
+        {
+            //
+            this.identityProvider = identityProvider;
+            this.messageRepository = messageRepository;
+            this.conversationRepository = conversationRepository;
+            this.projectTitleResourceProvider = projectTitleResourceProvider;
+            this.conversationTitleResourceProvider = conversationTitleResourceProvider;
+            this.projectDescriptionResourceProvider = projectDescriptionResourceProvider;
+        }
+
+        //
+        #region Enrichers ...
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XAiProjectDto> Enrich(
+            XAiProject source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Mapping Default ...
+            var result = Mapper.Map<XAiProjectDto>(source);
+            result = await Enrich(
+                source: result,
+                fillConversations: fillConversations,
+                cancellationToken: cancellationToken,
+                fillConversationMessages: fillConversationMessages                
+            );
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XAiProjectDto> Enrich(
+            XAiProjectDto source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Handle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
+            {
+                //
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
+            }
+
+            //
+            // Handle Title ...            
+            XResourceDto titleResource = null;
+            if (!source.Title.IsNullOrEmpty())
+            {
+                //
+                titleResource = await projectTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Handle Description ...
+            XResourceDto descriptionResource = null;
+            if (!source.Description.IsNullOrEmpty())
+            {
+                //
+                descriptionResource = await projectDescriptionResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Handle Conversations ...
+            IEnumerable<XAiConversationDto> conversations = [];
+            if (fillConversations)
+            {
+                //
+                // Reading Entities ...
+                var entitiies = await conversationRepository.FindManyAsync(
+                    includeBuilder: null,
+                    ignoreSoftDeleteds: true,
+                    cancellationToken: cancellationToken,
+                    predicate: x => x.ProjectId == source.Id,
+                    orderBuilder: x => x.OrderBy(y => y.CreatedOn)
+                );
+
+                //
+                // Converts to Dto Enumerable ...
+                conversations = entitiies
+                    .MapConvert<XAiConversationDto, XAiConversation>();
+
+                //
+                // Handle Conversation Enrichment ...
+                foreach (var conversation in conversations)
+                {
+                    //
+                    // Handle Owner ...
+                    if (!conversation.OwnerId.IsNullOrEmpty())
+                    {
+                        conversation.Owner = owner;
+                    }
+
+                    //
+                    // Handle Title Resource ...
+                    if (!conversation.Title.IsNullOrEmpty())
+                    {
+                        //
+                        conversation.TitleResource = await conversationTitleResourceProvider.GetResource(
+                            owner: source.OwnerId,
+                            identifier: conversation.Id,
+                            cancellationToken: cancellationToken
+                        );
+                    }
+
+                    //
+                    // Handle Project Info ...
+                    if (!conversation.ProjectId.IsDefaultGuid())
+                    {
+                        conversation.ProjectTitle = source.Title;
+                        conversation.ProjectTitleResource = titleResource;
+                        conversation.ProjectDescription = source.Description;
+                        conversation.ProjectDescriptionResource = descriptionResource;
+                    }
+                }
+
+                //
+                // Handle Fill Messages ...
+                if (fillConversationMessages)
+                {
+                    //
+                    foreach (var conversation in conversations)
+                    {
+                        //
+                        IEnumerable<XAiMessageDto> messages = [];
+
+                        //
+                        // Retrieve Message Entities ...
+                        var messageEntities = await messageRepository.FindManyAsync(
+                            includeBuilder: null,
+                            ignoreSoftDeleteds: true,
+                            cancellationToken: cancellationToken,
+                            orderBuilder: x => x.OrderBy(y => y.CreatedOn),
+                            predicate: x => x.ConversationId == conversation.Id
+                        );
+                        if (messageEntities.HasChild())
+                        {
+                            //
+                            // Converts to Message ...
+                            messages = messageEntities
+                                .MapConvert<XAiMessageDto, XAiMessage>();
+
+                            //
+                            // Ennrich Messages ...
+                            foreach (var message in messages)
+                            {
+                                //
+                                // Handle Owner ...
+                                if (!message.OwnerId.IsNullOrEmpty())
+                                {
+                                    message.Owner = owner;
+                                }
+
+                                //
+                                // Handle Conversation ...
+                                if (!message.ConversationId.IsDefaultGuid())
+                                {
+                                    message.ConversationTitle = conversation.Title;
+                                    message.ConversationTitleResouce = conversation.TitleResource;
+                                }
+                            }
+                        }
+
+                        //
+                        conversation.Messages = [.. messages];
+                    }
+                }
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = Mapper.Map<XAiProjectDto>(source, options =>
+            {
+                //
+                options.Items[nameof(source.Owner)] = owner;
+                options.Items[nameof(source.Conversations)] = conversations;
+                options.Items[nameof(source.TitleResource)] = titleResource;
+                options.Items[nameof(source.DescriptionResource)] = descriptionResource;
+            });
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProject> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    cancellationToken: cancellationToken,
+                    fillConversations: fillConversations,
+                    fillConversationMessages: fillConversationMessages
+                ));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProjectDto> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    cancellationToken: cancellationToken,
+                    fillConversations: fillConversations,
+                    fillConversationMessages: fillConversationMessages
+                ));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+        #endregion        
     }
 }

Providers/Dtos/XAiProjectServiceProvider.cs

@@ -1,11 +1,11 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Dtos;
+using xPushService.Base;
 using xAiModels.Models.Dtos;
+using xAiModels.Interfaces.Dtos;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
 
 namespace xAiModels.Providers.Dtos
 {

Providers/Enrichers/XAiConversationEnricher.cs

@@ -1,153 +1,64 @@
-using System;
-using System.Collections.Generic;
+using System.Linq;
+using xModels.Dtos;
 using System.Threading;
-using System.Threading.Tasks;
-using xAiModels.Interfaces;
-using xAiModels.Interfaces.Dtos;
-using xAiModels.Interfaces.Enrichers;
-using xAiModels.Models.Dtos;
 using xCommons.Extensions;
+using xAiModels.Interfaces;
+using xAiModels.Models.Dtos;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 using xIdentityService.Interfaces;
 using xIdentityService.Extensions;
-using xModels.Dtos;
-using System.Linq;
+using xAiModels.Interfaces.Entities;
+using xAiModels.Interfaces.Enrichers;
 
 namespace xAiModels.Providers.Enrichers
 {
     public class XAiConversationEnricher : IXAiConversationEnricher
     {
         private readonly IXIdentityProvider identityProvider;
-        private readonly IXAiProjectRepositoryService projectRepositoryService;
+        private readonly IXAiConversationRepository repository;
+        private readonly IXAiProjectTitleResourceProvider projectTitleResourceProvider;
         private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
+        private readonly IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider;
 
         public XAiConversationEnricher(
             IXIdentityProvider identityProvider,
-            IXAiProjectRepositoryService projectRepositoryService,
-            IXAiConversationTitleResourceProvider conversationTitleResourceProvider
+            IXAiConversationRepository repository,
+            IXAiProjectTitleResourceProvider projectTitleResourceProvider,
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider,
+            IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider
         )
         {
+            //
+            this.repository = repository;
             this.identityProvider = identityProvider;
-            this.projectRepositoryService = projectRepositoryService;
+            this.projectTitleResourceProvider = projectTitleResourceProvider;
             this.conversationTitleResourceProvider = conversationTitleResourceProvider;
-        }
-
-        /// <summary>
-        /// Converts a Signle Entity to Dto ...
-        /// </summary>
-        /// <param name="source"></param>
-        /// <param name="destination"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public async Task EnrichAsync(
-            XAiConversationDto source,
-            XAiConversationDto destination,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            // Run independent async operations concurrently
-            var ownerTask = ResolveOwnerAsync(source.OwnerId, cancellationToken);
-            var projectTask = ResolveProjectAsync(source.ProjectId, cancellationToken);
-            var titleLocalesTask = ResolveTitleLocalesAsync(source.Title, cancellationToken);
-
-            //
-            // wait until All Tasks Resolved ... 
-            await Task.WhenAll(ownerTask, titleLocalesTask, projectTask);
-
-            //
-            // Attached Resolved Info to Destination ...
-            destination.Owner = ownerTask.Result;
-            destination.TitleResource = titleLocalesTask.Result;
-            var project = projectTask.Result;
-            if (!project.IsNullOrDefault())
-            {
-                destination.ProjectTitle = project.Title;
-                destination.ProjectDescription = project.Description;
-                destination.ProjectTitleResource = project.TitleResource;
-                destination.ProjectDescriptionResource = project.DescriptionResource;
-            }
-        }
-
-        /// <summary>
-        /// Converts a Collection of Entities to Dtos ...
-        /// </summary>
-        /// <param name="sources"></param>
-        /// <param name="destinations"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        public async Task EnrichRangeAsync(
-            IEnumerable<XAiConversationDto> sources,
-            IEnumerable<XAiConversationDto> destinations,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            // Make Tasks Ready ...
-            var tasks = sources.Zip(destinations, (src, dst) =>
-                EnrichAsync(src, dst, cancellationToken)
-            );
-
-            //
-            await Task.WhenAll(tasks);
+            this.projectDescriptionResourceProvider = projectDescriptionResourceProvider;
         }
 
         //
-        #region Private ...
+        #region Enrichers ...
         /// <summary>
-        /// Reading Owner User Info ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="ownerId"></param>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<XPersonDto> ResolveOwnerAsync(
-            string ownerId,
+        public virtual async Task<XAiConversationDto> Enrich(
+            XAiConversation source,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            XPersonDto result = null;
-
-            //
-            // Validate ...
-            if (ownerId.IsNullOrEmpty())
-            {
-                return result;
-            }
-
-            //
-            // Try to Retrieve User Info ...
-            var device = identityProvider.GetDevice();
-            var userInfo = await identityProvider.GetUserInfo(
-                device: device,
-                userSelectByParam: ownerId
-            );
-            result = userInfo.ToXPersonDto();
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// Reading Title Locales ...
-        /// </summary>
-        /// <param name="title"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        private async Task<XResourceDto> ResolveTitleLocalesAsync(
-            string title,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            XResourceDto result = null;
-            if (title.IsNullOrEmpty())
-            {
-                return result;
-            }
-
-            //
-            result = await conversationTitleResourceProvider.GetResource(
-                identifier: title,
+            // Mapping Default ...
+            var result = source.MapConvert<XAiConversationDto, XAiConversation>();
+            result = await Enrich(
+                source: result,
+                fillMessages: fillMessages,
                 cancellationToken: cancellationToken
             );
 
@@ -156,34 +67,132 @@ namespace xAiModels.Providers.Enrichers
         }
 
         /// <summary>
-        /// Retrieve Project ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="projectId"></param>
+        /// <param name="source"></param>
+        /// <param name="fillMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<XAiProjectDto> ResolveProjectAsync(
-            Guid projectId,
+        public virtual async Task<XAiConversationDto> Enrich(
+            XAiConversationDto source,
+            bool fillMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            XAiProjectDto result = null;
-            if (projectId.IsNull() || projectId.IsDefaultGuid())
+            // Handdle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
             {
-                return result;
+                //
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
             }
 
             //
-            result = await projectRepositoryService.GetAsync(
-                id: projectId,
-                includeBuilder: null,
-                ignoreSoftDeleteds: true,
-                cancellationToken: cancellationToken
-            );
+            // Handle Title Resource ...
+            XResourceDto titleResource = null;
+            if (!source.Title.IsNullOrEmpty())
+            {
+                //
+                titleResource = await conversationTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Handle Project Info ...
+            XResourceDto projectTitleResource = null;
+            XResourceDto projectDescriptionResource = null;
+            if (!source.ProjectId.IsDefaultGuid())
+            {
+                //
+                projectTitleResource = await projectTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ProjectId,
+                    cancellationToken: cancellationToken
+                );
+
+                //
+                projectDescriptionResource = await projectDescriptionResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ProjectId,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = source.MapConvert<XAiConversationDto, XAiConversationDto>();
+            result.Owner = owner;
+            result.TitleResource = titleResource;
+            result.ProjectTitleResource = projectTitleResource;
+            result.ProjectTitle = projectTitleResource.Resource;
+            result.ProjectDescriptionResource = projectDescriptionResource;
+            result.ProjectDescription = projectDescriptionResource.Resource;
 
             //
             return result;
         }
-        #endregion
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversation> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    fillMessages: fillMessages,
+                    cancellationToken: cancellationToken
+                ));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiConversationDto>> EnrichRange(
+            IEnumerable<XAiConversationDto> sources,
+            bool fillMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    fillMessages: fillMessages,
+                    cancellationToken: cancellationToken
+                ));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+        #endregion                
     }
 }

Providers/Enrichers/XAiMessageEnricher.cs

@@ -1,143 +1,151 @@
-using System;
-using System.Collections.Generic;
+using System.Linq;
+using xModels.Dtos;
 using System.Threading;
-using System.Threading.Tasks;
-using xAiModels.Interfaces.Enrichers;
-using xAiModels.Models.Dtos;
 using xCommons.Extensions;
+using xAiModels.Interfaces;
+using xAiModels.Models.Dtos;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 using xIdentityService.Interfaces;
 using xIdentityService.Extensions;
-using xModels.Dtos;
-using System.Linq;
-using xAiModels.Interfaces.Dtos;
+using xAiModels.Interfaces.Enrichers;
 
 namespace xAiModels.Providers.Enrichers
 {
     public class XAiMessageEnricher : IXAiMessageEnricher
     {
         private readonly IXIdentityProvider identityProvider;
-        private readonly IXAiConversationRepositoryService conversationRepositoryService;
+        private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
 
         public XAiMessageEnricher(
             IXIdentityProvider identityProvider,
-            IXAiConversationRepositoryService conversationRepositoryService
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider
         )
         {
             this.identityProvider = identityProvider;
-            this.conversationRepositoryService = conversationRepositoryService;
-        }
-
-        public async Task EnrichAsync(
-            XAiMessageDto source,
-            XAiMessageDto destination,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            // Run independent async operations concurrently
-            var ownerTask = ResolveOwnerAsync(source.OwnerId, cancellationToken);
-            var conversationTask = ResolveConversationAsync(source.ConversationId, cancellationToken);
-            //
-            // wait until All Tasks Resolved ... 
-            await Task.WhenAll(ownerTask, conversationTask);
-
-            //
-            // Attached Resolved Info to Destination ...
-            destination.Owner = ownerTask.Result;
-            if (!conversationTask.Result.IsNullOrDefault())
-            {
-                //
-                destination.ConversationTitle = conversationTask.Result.Title;
-                destination.ConversationTitleResouce = conversationTask.Result.TitleResource;
-            }
-        }
-
-        public async Task EnrichRangeAsync(
-            IEnumerable<XAiMessageDto> sources,
-            IEnumerable<XAiMessageDto> destinations,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            // Make Tasks Ready ...
-            var tasks = sources.Zip(destinations, (src, dst) =>
-                EnrichAsync(src, dst, cancellationToken)
-            );
-
-            //
-            await Task.WhenAll(tasks);
+            this.conversationTitleResourceProvider = conversationTitleResourceProvider;
         }
 
         //
-        #region Private ...
+        #region Enrichers ...
         /// <summary>
-        /// Reading Owner User Info ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="ownerId"></param>
+        /// <param name="source"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<XPersonDto> ResolveOwnerAsync(
-            string ownerId,
+        public virtual async Task<XAiMessageDto> Enrich(
+            XAiMessage source,
             CancellationToken cancellationToken = default
         )
         {
             //
-            XPersonDto result = null;
-
-            //
-            // Validate ...
-            if (ownerId.IsNullOrEmpty())
-            {
-                return result;
-            }
-
-            //
-            // Try to Retrieve User Info ...
-            var device = identityProvider.GetDevice();
-            var userInfo = await identityProvider.GetUserInfo(
-                device: device,
-                userSelectByParam: ownerId
-            );
-            result = userInfo.ToXPersonDto();
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// Reading Conversation ...
-        /// </summary>
-        /// <param name="conversationId"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        private async Task<XAiConversationDto> ResolveConversationAsync(
-            Guid conversationId,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            XAiConversationDto result = null;
-
-            //
-            // Validate ...
-            if (conversationId.IsNull() ||
-                conversationId.IsDefaultGuid()
-            )
-            {
-                return result;
-            }
-
-            //
-            result = await conversationRepositoryService.GetAsync(
-                id: conversationId,
-                includeBuilder: null,
-                ignoreSoftDeleteds: true,
+            // Mapping Default ...
+            var result = source.MapConvert<XAiMessageDto, XAiMessage>();
+            result = await Enrich(
+                source: result,
                 cancellationToken: cancellationToken
             );
 
             //
             return result;
         }
-        #endregion
+
+        /// <summary>
+        /// Enrich Specified Item ...
+        /// </summary>
+        /// <param name="source"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<XAiMessageDto> Enrich(
+            XAiMessageDto source,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            // Handdle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
+            {
+                //
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
+            }
+
+            //
+            // Hanlde Conversation Title ...
+            string conversationTitle = string.Empty;
+            XResourceDto conversationTitleResource = null;
+            if (!source.ConversationId.IsDefaultGuid())
+            {
+                //
+                conversationTitleResource = await conversationTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.ConversationId,
+                    cancellationToken: cancellationToken
+                );
+                if (!conversationTitleResource.IsNullOrDefault())
+                {
+                    conversationTitle = conversationTitleResource.Resource;
+                }
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = source.MapConvert<XAiMessageDto, XAiMessageDto>();
+            result.Owner = owner;
+            result.ConversationTitle = conversationTitle;
+            result.ConversationTitleResouce = conversationTitleResource;
+
+            //
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessage> sources,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(x, cancellationToken));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiMessageDto>> EnrichRange(
+            IEnumerable<XAiMessageDto> sources,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(x, cancellationToken));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+        #endregion        
     }
 }

Providers/Enrichers/XAiProjectEnricher.cs

@@ -1,118 +1,71 @@
-using System;
-using System.Collections.Generic;
 using System.Linq;
+using xModels.Dtos;
 using System.Threading;
-using System.Threading.Tasks;
-using xAiModels.Interfaces.Enrichers;
-using xAiModels.Models.Dtos;
 using xCommons.Extensions;
+using xAiModels.Interfaces;
+using xAiModels.Models.Dtos;
+using System.Threading.Tasks;
+using xAiModels.Models.Entities;
+using System.Collections.Generic;
 using xIdentityService.Interfaces;
 using xIdentityService.Extensions;
-using xModels.Dtos;
-using xAiModels.Interfaces;
-using xAiModels.Interfaces.Dtos;
+using xAiModels.Interfaces.Entities;
+using xAiModels.Interfaces.Enrichers;
 
 namespace xAiModels.Providers.Enrichers
 {
     public class XAiProjectEnricher : IXAiProjectEnricher
     {
         private readonly IXIdentityProvider identityProvider;
+        private readonly IXAiMessageRepository messageRepository;
+        private readonly IXAiConversationRepository conversationRepository;
         private readonly IXAiProjectTitleResourceProvider projectTitleResourceProvider;
-        private readonly IXAiConversationRepositoryService conversationRepositoryService;
+        private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
         private readonly IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider;
 
         public XAiProjectEnricher(
             IXIdentityProvider identityProvider,
+            IXAiMessageRepository messageRepository,
+            IXAiConversationRepository conversationRepository,
             IXAiProjectTitleResourceProvider projectTitleResourceProvider,
-            IXAiConversationRepositoryService conversationRepositoryService,
+            IXAiConversationTitleResourceProvider conversationTitleResourceProvider,
             IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider
         )
         {
+            //
             this.identityProvider = identityProvider;
+            this.messageRepository = messageRepository;
+            this.conversationRepository = conversationRepository;
             this.projectTitleResourceProvider = projectTitleResourceProvider;
-            this.conversationRepositoryService = conversationRepositoryService;
+            this.conversationTitleResourceProvider = conversationTitleResourceProvider;
             this.projectDescriptionResourceProvider = projectDescriptionResourceProvider;
         }
 
-        public Task EnrichAsync(
-            XAiProjectDto source,
-            XAiProjectDto destination,
-            CancellationToken cancellationToken = default
-        )
-        {
-            throw new NotImplementedException();
-        }
-
-        public Task EnrichRangeAsync(
-            IEnumerable<XAiProjectDto> sources,
-            IEnumerable<XAiProjectDto> destinations,
-            CancellationToken cancellationToken = default
-        )
-        {
-            throw new NotImplementedException();
-        }
-
         //
-        #region Private ...
+        #region Enrichers ...
         /// <summary>
-        /// Reading Owner User Info ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="ownerId"></param>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<XPersonDto> ResolveOwnerAsync(
-            string ownerId,
+        public virtual async Task<XAiProjectDto> Enrich(
+            XAiProject source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            XPersonDto result = null;
-
-            //
-            // Validate ...
-            if (ownerId.IsNullOrEmpty())
-            {
-                return result;
-            }
-
-            //
-            // Try to Retrieve User Info ...
-            var device = identityProvider.GetDevice();
-            var userInfo = await identityProvider.GetUserInfo(
-                device: device,
-                userSelectByParam: ownerId
-            );
-            result = userInfo.ToXPersonDto();
-
-            //
-            return result;
-        }
-
-        /// <summary>
-        /// Retrieve Title Resource ...
-        /// </summary>
-        /// <param name="identifier"></param>
-        /// <param name="cancellationToken"></param>
-        /// <returns></returns>
-        private async Task<XResourceDto> ResolveTitleAsync(
-            string identifier,
-            CancellationToken cancellationToken = default
-        )
-        {
-            //
-            XResourceDto result = null;
-
-            //
-            // Validate ...
-            if (identifier.IsNullOrEmpty())
-            {
-                return result;
-            }
-
-            //
-            result = await projectTitleResourceProvider.GetResource(
-                identifier: identifier,
-                cancellationToken: cancellationToken
+            // Mapping Default ...
+            var result = source.MapConvert<XAiProjectDto, XAiProject>();
+            result = await Enrich(
+                source: result,
+                fillConversations: fillConversations,
+                cancellationToken: cancellationToken,
+                fillConversationMessages: fillConversationMessages
             );
 
             //
@@ -120,72 +73,237 @@ namespace xAiModels.Providers.Enrichers
         }
 
         /// <summary>
-        /// Retrieve Description Resource ...
+        /// Enrich Specified Item ...
         /// </summary>
-        /// <param name="identifier"></param>
+        /// <param name="source"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<XResourceDto> ResolveDescriptionAsync(
-            string identifier,
+        public virtual async Task<XAiProjectDto> Enrich(
+            XAiProjectDto source,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            XResourceDto result = null;
-
-            //
-            // Validate ...
-            if (identifier.IsNullOrEmpty())
+            // Handle Owner ...
+            XPersonDto owner = null;
+            if (!source.OwnerId.IsNullOrEmpty())
             {
-                return result;
+                //
+                // Try to Retrieve User Info ...
+                var device = identityProvider.GetDevice();
+                var userInfo = await identityProvider.GetUserInfo(
+                    device: device,
+                    userSelectByParam: source.OwnerId
+                );
+                owner = userInfo.ToXPersonDto();
             }
 
             //
-            result = await projectDescriptionResourceProvider.GetResource(
-                identifier: identifier,
-                cancellationToken: cancellationToken
-            );
+            // Handle Title ...            
+            XResourceDto titleResource = null;
+            if (!source.Title.IsNullOrEmpty())
+            {
+                //
+                titleResource = await projectTitleResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Handle Description ...
+            XResourceDto descriptionResource = null;
+            if (!source.Description.IsNullOrEmpty())
+            {
+                //
+                descriptionResource = await projectDescriptionResourceProvider.GetResource(
+                    owner: source.OwnerId,
+                    identifier: source.Id,
+                    cancellationToken: cancellationToken
+                );
+            }
+
+            //
+            // Handle Conversations ...
+            IEnumerable<XAiConversationDto> conversations = [];
+            if (fillConversations)
+            {
+                //
+                // Reading Entities ...
+                var entitiies = await conversationRepository.FindManyAsync(
+                    includeBuilder: null,
+                    ignoreSoftDeleteds: true,
+                    cancellationToken: cancellationToken,
+                    predicate: x => x.ProjectId == source.Id,
+                    orderBuilder: x => x.OrderBy(y => y.CreatedOn)
+                );
+
+                //
+                // Converts to Dto Enumerable ...
+                conversations = entitiies
+                    .MapConvert<XAiConversationDto, XAiConversation>();
+
+                //
+                // Handle Conversation Enrichment ...
+                foreach (var conversation in conversations)
+                {
+                    //
+                    // Handle Owner ...
+                    if (!conversation.OwnerId.IsNullOrEmpty())
+                    {
+                        conversation.Owner = owner;
+                    }
+
+                    //
+                    // Handle Title Resource ...
+                    if (!conversation.Title.IsNullOrEmpty())
+                    {
+                        //
+                        conversation.TitleResource = await conversationTitleResourceProvider.GetResource(
+                            owner: source.OwnerId,
+                            identifier: conversation.Id,
+                            cancellationToken: cancellationToken
+                        );
+                    }
+
+                    //
+                    // Handle Project Info ...
+                    if (!conversation.ProjectId.IsDefaultGuid())
+                    {
+                        conversation.ProjectTitle = source.Title;
+                        conversation.ProjectTitleResource = titleResource;
+                        conversation.ProjectDescription = source.Description;
+                        conversation.ProjectDescriptionResource = descriptionResource;
+                    }
+                }
+
+                //
+                // Handle Fill Messages ...
+                if (fillConversationMessages)
+                {
+                    //
+                    foreach (var conversation in conversations)
+                    {
+                        //
+                        IEnumerable<XAiMessageDto> messages = [];
+
+                        //
+                        // Retrieve Message Entities ...
+                        var messageEntities = await messageRepository.FindManyAsync(
+                            includeBuilder: null,
+                            ignoreSoftDeleteds: true,
+                            cancellationToken: cancellationToken,
+                            orderBuilder: x => x.OrderBy(y => y.CreatedOn),
+                            predicate: x => x.ConversationId == conversation.Id
+                        );
+                        if (messageEntities.HasChild())
+                        {
+                            //
+                            // Converts to Message ...
+                            messages = messageEntities
+                                .MapConvert<XAiMessageDto, XAiMessage>();
+
+                            //
+                            // Ennrich Messages ...
+                            foreach (var message in messages)
+                            {
+                                //
+                                // Handle Owner ...
+                                if (!message.OwnerId.IsNullOrEmpty())
+                                {
+                                    message.Owner = owner;
+                                }
+
+                                //
+                                // Handle Conversation ...
+                                if (!message.ConversationId.IsDefaultGuid())
+                                {
+                                    message.ConversationTitle = conversation.Title;
+                                    message.ConversationTitleResouce = conversation.TitleResource;
+                                }
+                            }
+                        }
+
+                        //
+                        conversation.Messages = [.. messages];
+                    }
+                }
+            }
+
+            //
+            // Attach Extracted Items ...
+            var result = source.MapConvert<XAiProjectDto, XAiProjectDto>();
+            result.Owner = owner;
+            result.TitleResource = titleResource;
+            result.Conversations = [.. conversations];
+            result.DescriptionResource = descriptionResource;
 
             //
             return result;
         }
 
         /// <summary>
-        /// Retrieve Project Conversations ...
+        /// Enrich Specified Items ...
         /// </summary>
-        /// <param name="projectId"></param>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        private async Task<List<XAiConversationDto>> ResolveConversationsAsync(
-            Guid projectId,
+        public virtual async Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProject> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
             CancellationToken cancellationToken = default
         )
         {
             //
-            List<XAiConversationDto> result = [];
-
-            //
-            // Validate ...
-            if (projectId.IsNull() ||
-                projectId.IsDefaultGuid()
-            )
-            {
-                return result;
-            }
-
-            //
-            var items = await conversationRepositoryService.FindManyAsync(
-                orderBuilder: null,
-                includeBuilder: null,
-                ignoreSoftDeleteds: true,
-                predicate: x => x.Id == projectId,
-                cancellationToken: cancellationToken
-            );
-            result = [.. items];
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    cancellationToken: cancellationToken,
+                    fillConversations: fillConversations,
+                    fillConversationMessages: fillConversationMessages
+                ));
 
             //
+            var result = await Task.WhenAll(tasks);
             return result;
         }
-        #endregion
+
+        /// <summary>
+        /// Enrich Specified Items ...
+        /// </summary>
+        /// <param name="sources"></param>
+        /// <param name="fillConversations"></param>
+        /// <param name="fillConversationMessages"></param>
+        /// <param name="cancellationToken"></param>
+        /// <returns></returns>
+        public virtual async Task<IEnumerable<XAiProjectDto>> EnrichRange(
+            IEnumerable<XAiProjectDto> sources,
+            bool fillConversations = false,
+            bool fillConversationMessages = false,
+            CancellationToken cancellationToken = default
+        )
+        {
+            //
+            var tasks = sources
+                .Select(x => Enrich(
+                    source: x,
+                    cancellationToken: cancellationToken,
+                    fillConversations: fillConversations,
+                    fillConversationMessages: fillConversationMessages
+                ));
+
+            //
+            var result = await Task.WhenAll(tasks);
+            return result;
+        }
+        #endregion        
     }
 }

Providers/Entities/XAiConversationEFRepository.cs

@@ -1,10 +1,10 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Db;
+using xDataService.Providers;
+using xDataService.Interfaces;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Db;
-using xDataService.Interfaces;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationEntityHub.cs

@@ -1,8 +1,8 @@
 using System;
+using xPushService.Base;
+using xAiModels.Models.Entities;
 using Microsoft.Extensions.Logging;
 using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
-using xPushService.Base;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationInMemoryRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationKeyGenerator.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationMongoRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationRepositoryEvents.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationRepositoryProvider.cs

@@ -1,10 +1,10 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Entities;
+using xPushService.Base;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiConversationSeederBase.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageEFRepository.cs

@@ -1,10 +1,10 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Db;
+using xDataService.Providers;
+using xDataService.Interfaces;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Db;
-using xDataService.Interfaces;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageEntityHub.cs

@@ -1,8 +1,8 @@
 using System;
+using xPushService.Base;
+using xAiModels.Models.Entities;
 using Microsoft.Extensions.Logging;
 using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
-using xPushService.Base;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageInMemoryRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageKeyGenerator.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageMongoRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageRepositoryEvents.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageRepositoryProvider.cs

@@ -1,10 +1,10 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Entities;
+using xPushService.Base;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiMessageSeederBase.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectEFRepository.cs

@@ -1,10 +1,10 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Db;
+using xDataService.Providers;
+using xDataService.Interfaces;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Db;
-using xDataService.Interfaces;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectEntityHub.cs

@@ -1,8 +1,8 @@
 using System;
+using xPushService.Base;
+using xAiModels.Models.Entities;
 using Microsoft.Extensions.Logging;
 using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
-using xPushService.Base;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectInMemoryRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectKeyGenerator.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectMongoRepository.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectRepositoryEvents.cs

@@ -1,6 +1,6 @@
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.Providers;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectRepositoryProvider.cs

@@ -1,10 +1,10 @@
 using System;
-using Microsoft.AspNetCore.SignalR;
-using xAiModels.Interfaces.Entities;
+using xPushService.Base;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
 using xIdentityService.Interfaces;
-using xPushService.Base;
+using Microsoft.AspNetCore.SignalR;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/Entities/XAiProjectSeederBase.cs

@@ -1,8 +1,8 @@
 using System;
-using xAiModels.Interfaces.Entities;
+using xDataService.Providers;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.Providers;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.Entities
 {

Providers/GraphQL/XAiConversationGraphQLTypeHelper.cs

@@ -1,8 +1,8 @@
 using System;
 using xAiModels.Constants;
-using xAiModels.Interfaces.Entities;
-using xAiModels.Models.Entities;
 using xDataService.GraphQL;
+using xAiModels.Models.Entities;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.GraphQL
 {

Providers/GraphQL/XAiConversationGraphQuery.cs

@@ -1,9 +1,9 @@
 using System;
 using GraphQL.Types;
-using xAiModels.Interfaces.Entities;
+using xDataService.GraphQL;
 using xAiModels.Models.Entities;
 using xDataService.Configuration;
-using xDataService.GraphQL;
+using xAiModels.Interfaces.Entities;
 
 namespace xAiModels.Providers.GraphQL
 {

Providers/GraphQL/XAiConversationGraphType.cs

@@ -1,6 +1,6 @@
 using System;
-using xAiModels.Models.Entities;
 using xDataService.GraphQL;
+using xAiModels.Models.Entities;
 
 namespace xAiModels.Providers.GraphQL
 {