Compare commits

...
25 Commits
Author SHA1 Message Date
saherelm 26df2c7ebc last ... 2026-10-02 22:12:26 +03:30
saherelm 755eafa7d2 Add Support for Attaching Additional Contents to Specified Prompt Message when Converting to Chat Message, Specified For File Support ... 2026-09-30 23:12:39 +03:30
saherelm 47b2cbc0d2 last ... 2026-09-30 15:27:26 +03:30
saherelm f48b9257a3 last ... 2026-09-29 17:41:17 +03:30
saherelm 5d3601ba44 last ... 2026-09-28 22:36:16 +03:30
saherelm 33922537d5 last ... 2026-09-28 18:00:00 +03:30
saherelm 8e23a09f7b apply some changes on default ai resource titles ... 2026-09-28 17:49:50 +03:30
saherelm 2aa0607e85 last ... 2026-09-28 16:34:36 +03:30
saherelm a4dee3b5a4 last ... 2026-09-27 22:00:56 +03:30
saherelm 9f27b7825e last ... 2026-09-27 16:08:32 +03:30
saherelm eb27e9ce1f last ... 2026-09-25 19:48:23 +03:30
saherelm 490058d1a8 last ... 2026-09-19 17:03:16 +03:30
saherelm f9b5f1f6aa last ... 2026-09-06 08:46:01 +03:30
saherelm a9b75b3c33 apply sorting ... 2026-09-06 00:18:24 +03:30
saherelm 88607a9e4d sorting ... 2026-09-03 23:58:37 +03:30
saherelm 7ef56fbc1e kast ... 2026-09-03 10:38:06 +03:30
saherelm 7f47c449e7 cleanup nuget source ... 2026-08-15 17:23:35 +03:30
saherelm 89b848709f apply fix on Models Enrichments ... 2026-08-15 14:42:21 +03:30
saherelm 54883b760b last ... 2026-08-15 10:48:55 +03:30
saherelm 337899ba85 last ... 2026-08-14 21:33:20 +03:30
saherelm 73fb9a01b8 last ... 2026-08-14 00:01:17 +03:30
saherelm 842feac905 last works ... 2026-08-09 17:10:47 +03:30
saherelm 831c7004a8 last works on Models ... 2026-08-08 18:07:28 +03:30
saherelm 8e1566310c last ... 2026-08-08 11:34:16 +03:30
saherelm 000408ae3f fix usage of Enrichers and Dto Structures ... 2026-08-08 09:42:28 +03:30
117 changed files with 4941 additions and 820 deletions
@@ -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
{
@@ -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
{
@@ -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
{
+1 -1
View File
@@ -1,5 +1,5 @@
using xAiModels.Constants;
using xAiModels.Models;
using xAiModels.Constants;
namespace xAiModels.Configurations
{
+46
View File
@@ -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,
}
}
+1
View File
@@ -6,6 +6,7 @@ namespace xAiModels.Constants
public enum XAiModelProviderType
{
None,
OpenAI,
Ollama,
DeepSeek,
HuggingFace
+2
View File
@@ -49,5 +49,7 @@ namespace xAiModels.Constants
public const string DefaultXAiProjectTitleResourceID = "XAiPrjT";
public const string DefaultXAiConversationTitleResourceID = "XAiCnvT";
public const string DefaultXAiProjectDescriptionResourceID = "XAiPrjD";
//
}
}
+32 -14
View File
@@ -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
{
@@ -431,6 +431,12 @@ namespace xAiModels.DI
services.Add(
new ServiceDescriptor(typeof(IXAiMessageRepositoryProvider), typeof(XAiMessageRepositoryProvider), lifeTime)
);
//
// Enrichers ...
services.Add(
new ServiceDescriptor(typeof(IXAiMessageEnricher), typeof(XAiMessageEnricher), lifeTime)
);
#endregion
//
@@ -454,6 +460,12 @@ namespace xAiModels.DI
services.Add(
new ServiceDescriptor(typeof(IXAiProjectDescriptionResourceProvider), typeof(XAiProjectDescriptionResourceProvider), lifeTime)
);
//
// Enrichers ...
services.Add(
new ServiceDescriptor(typeof(IXAiProjectEnricher), typeof(XAiProjectEnricher), lifeTime)
);
#endregion
//
@@ -483,6 +495,12 @@ namespace xAiModels.DI
#endregion
#endregion
//
// Data Provider ...
services.Add(
new ServiceDescriptor(typeof(IXAiDataProvider), typeof(XAiDataProvider), lifeTime)
);
//
Log("Service Regitration Succeed ...");
}
+1 -1
View File
@@ -1,5 +1,5 @@
using Microsoft.Extensions.AI;
using xCommons.Extensions;
using Microsoft.Extensions.AI;
namespace xAiModels.Extensions
{
+1 -1
View File
@@ -1,6 +1,6 @@
using Microsoft.Extensions.AI;
using xAiModels.Constants;
using xCommons.Extensions;
using Microsoft.Extensions.AI;
namespace xAiModels.Extensions
{
+1 -1
View File
@@ -1,7 +1,7 @@
using System.Linq;
using xAiModels.Configurations;
using xAiModels.Models;
using xCommons.Extensions;
using xAiModels.Configurations;
namespace xAiModels.Extensions
{
+466
View File
@@ -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;
}
}
}
+4 -4
View File
@@ -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
{
+1 -1
View File
@@ -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
{
@@ -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
}
}
@@ -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
{
+1 -1
View File
@@ -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
{
@@ -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
}
}
@@ -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
{
+1 -1
View File
@@ -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
{
@@ -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
}
}
@@ -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
{
@@ -1,22 +1,69 @@
using System.Collections.Generic;
using System.Threading;
using System.Threading.Tasks;
using xAiModels.Models.Dtos;
using System.Threading.Tasks;
using xAiModels.Models.Entities;
using System.Collections.Generic;
namespace xAiModels.Interfaces.Enrichers
{
/// <summary>
/// Ai Conversation Enricher ...
/// </summary>
public interface IXAiConversationEnricher
{
Task EnrichAsync(
XAiConversationDto source,
XAiConversationDto destination,
//
#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
);
Task<IEnumerable<XAiConversationDto>> EnrichRangeAsync(
IEnumerable<XAiConversationDto> sources,
IEnumerable<XAiConversationDto> destinations,
/// <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
}
}
@@ -0,0 +1,58 @@
using System.Threading;
using xAiModels.Models.Dtos;
using System.Threading.Tasks;
using xAiModels.Models.Entities;
using System.Collections.Generic;
namespace xAiModels.Interfaces.Enrichers
{
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
}
}
@@ -0,0 +1,74 @@
using System.Threading;
using xAiModels.Models.Dtos;
using System.Threading.Tasks;
using xAiModels.Models.Entities;
using System.Collections.Generic;
namespace xAiModels.Interfaces.Enrichers
{
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
}
}
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,5 +1,5 @@
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,7 +1,7 @@
using System;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
using xAiModels.Providers.Entities;
using xPushService.Interfaces;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -0,0 +1,12 @@
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
namespace xAiModels.Interfaces.Entities
{
public interface IXAiDocumentEntityHub
{
}
}
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,5 +1,5 @@
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,7 +1,7 @@
using System;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
using xAiModels.Providers.Entities;
using xPushService.Interfaces;
namespace xAiModels.Interfaces.Entities
{
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -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
{
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,5 +1,5 @@
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -1,7 +1,7 @@
using System;
using xPushService.Interfaces;
using xAiModels.Models.Entities;
using xAiModels.Providers.Entities;
using xPushService.Interfaces;
namespace xAiModels.Interfaces.Entities
{
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using xAiModels.Models.Entities;
using xDataService.Interfaces;
using xAiModels.Models.Entities;
namespace xAiModels.Interfaces.Entities
{
@@ -2,6 +2,6 @@ using xStringService.Interfaces;
namespace xAiModels.Interfaces
{
public interface IXAiConversationTitleResourceProvider : IXItemResourceProvider
public interface IXAiConversationTitleResourceProvider : IXOwnedItemResourceProvider
{ }
}
+293 -1
View File
@@ -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
}
}
@@ -2,6 +2,6 @@ using xStringService.Interfaces;
namespace xAiModels.Interfaces
{
public interface IXAiProjectDescriptionResourceProvider : IXItemResourceProvider
public interface IXAiProjectDescriptionResourceProvider : IXOwnedItemResourceProvider
{ }
}
@@ -2,6 +2,6 @@ using xStringService.Interfaces;
namespace xAiModels.Interfaces
{
public interface IXAiProjectTitleResourceProvider : IXItemResourceProvider
public interface IXAiProjectTitleResourceProvider : IXOwnedItemResourceProvider
{ }
}
+9 -3
View File
@@ -1,6 +1,7 @@
using System;
using xModels.Base;
using xModels.Dtos;
using System.Collections.Generic;
namespace xAiModels.Models.Dtos
{
@@ -28,7 +29,7 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// All Exists Title Locale Resources ...
/// </summary>
public virtual XLocaleResourceDto[] TitleLocales { get; set; }
public virtual XResourceDto TitleResource { get; set; }
/// <summary>
/// Created Time ...
@@ -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>
@@ -58,11 +64,11 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// Project Title Locale Resources ...
/// </summary>
public virtual XLocaleResourceDto[] ProjectTitleLocales { get; set; }
public virtual XResourceDto ProjectTitleResource { get; set; }
/// <summary>
/// Project Description Locale Resources ...
/// </summary>
public virtual XLocaleResourceDto[] ProjectDescriptionLocales { get; set; }
public virtual XResourceDto ProjectDescriptionResource { get; set; }
}
}
+8 -5
View File
@@ -1,9 +1,10 @@
using System;
using System.Collections.Generic;
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
{
@@ -48,7 +49,8 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// Conversation Info ...
/// </summary>
public virtual XAiConversationDto Conversation { get; set; } = null;
public virtual string ConversationTitle { get; set; } = null;
public virtual XResourceDto ConversationTitleResouce { get; set; } = null;
//
#region Meta Data Property ...
@@ -57,12 +59,13 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// Meta Data of Message ...
/// </summary>
[NotMapped]
public IDictionary<string, object> Metadata { get; private set; } = null;
/// <summary>
/// Meta Data of MEssage in Json ...
/// </summary>
public string MeatDatas
public string MetaDatas
{
//
get => _metadata;
+3 -3
View File
@@ -1,7 +1,7 @@
using System;
using System.Collections.Generic;
using xModels.Base;
using xModels.Dtos;
using System.Collections.Generic;
namespace xAiModels.Models.Dtos
{
@@ -29,7 +29,7 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// All Exists Title Locale Resources ...
/// </summary>
public virtual XLocaleResourceDto[] TitleLocales { get; set; }
public virtual XResourceDto TitleResource { get; set; }
/// <summary>
/// Description of Project ...
@@ -39,7 +39,7 @@ namespace xAiModels.Models.Dtos
/// <summary>
/// All Exists Description Locale Resources ...
/// </summary>
public virtual XLocaleResourceDto[] DescriptionLocales { get; set; }
public virtual XResourceDto DescriptionResource { get; set; }
/// <summary>
/// a Prompt for Project Start ...
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using System.ComponentModel.DataAnnotations;
using xModels.Base;
using System.ComponentModel.DataAnnotations;
namespace xAiModels.Models.Entities
{
+61
View File
@@ -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; }
}
}
+4 -4
View File
@@ -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;
+1 -1
View File
@@ -1,6 +1,6 @@
using System;
using System.ComponentModel.DataAnnotations;
using xModels.Base;
using System.ComponentModel.DataAnnotations;
namespace xAiModels.Models.Entities
{
+49
View File
@@ -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; }
}
}
+16
View File
@@ -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; }
}
}
+25
View File
@@ -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; }
}
}
+71
View File
@@ -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; }
}
}
+4 -4
View File
@@ -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
{
+127 -405
View File
@@ -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
}
}
@@ -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
{
+4 -4
View File
@@ -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
{
+150 -8
View File
@@ -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
}
}
+3 -3
View File
@@ -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
{
+4 -4
View File
@@ -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
{
+307 -8
View File
@@ -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
}
}
+3 -3
View File
@@ -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
{
+161 -157
View File
@@ -1,194 +1,198 @@
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 xAiModels.Models.Entities;
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.TitleLocales = titleLocalesTask.Result;
var project = projectTask.Result;
if (!project.IsNullOrDefault())
{
destination.ProjectTitle = project.Title;
destination.ProjectDescription = project.Description;
destination.ProjectTitleLocales = project.TitleLocales;
destination.ProjectDescriptionLocales = project.DescriptionLocales;
}
}
/// <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<IEnumerable<XAiConversationDto>> 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);
//
return destinations;
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<XLocaleResourceDto[]> ResolveTitleLocalesAsync(
string title,
CancellationToken cancellationToken = default
)
{
//
XLocaleResourceDto[] result = [];
if (title.IsNullOrEmpty())
{
return result;
}
//
var locales = await conversationTitleResourceProvider.GetLocales(
identifier: title,
cancellationToken: cancellationToken
);
result = [.. locales];
//
return result;
}
/// <summary>
/// Retrieve Project ...
/// </summary>
/// <param name="projectId"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
private async Task<XAiProjectDto> ResolveProjectAsync(
Guid projectId,
CancellationToken cancellationToken = default
)
{
//
XAiProjectDto result = null;
if (projectId.IsNull() || projectId.IsDefaultGuid())
{
return result;
}
//
result = await projectRepositoryService.GetAsync(
id: projectId,
includeBuilder: null,
ignoreSoftDeleteds: true,
// Mapping Default ...
var result = source.MapConvert<XAiConversationDto, XAiConversation>();
result = await Enrich(
source: result,
fillMessages: fillMessages,
cancellationToken: cancellationToken
);
//
return result;
}
#endregion
/// <summary>
/// Enrich Specified Item ...
/// </summary>
/// <param name="source"></param>
/// <param name="fillMessages"></param>
/// <param name="cancellationToken"></param>
/// <returns></returns>
public virtual async Task<XAiConversationDto> Enrich(
XAiConversationDto source,
bool fillMessages = false,
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();
}
//
// 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;
}
/// <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
}
}
+151
View File
@@ -0,0 +1,151 @@
using System.Linq;
using xModels.Dtos;
using System.Threading;
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 xAiModels.Interfaces.Enrichers;
namespace xAiModels.Providers.Enrichers
{
public class XAiMessageEnricher : IXAiMessageEnricher
{
private readonly IXIdentityProvider identityProvider;
private readonly IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
public XAiMessageEnricher(
IXIdentityProvider identityProvider,
IXAiConversationTitleResourceProvider conversationTitleResourceProvider
)
{
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 = source.MapConvert<XAiMessageDto, XAiMessage>();
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 = 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
}
}
+309
View File
@@ -0,0 +1,309 @@
using System.Linq;
using xModels.Dtos;
using System.Threading;
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 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 IXAiConversationTitleResourceProvider conversationTitleResourceProvider;
private readonly IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider;
public XAiProjectEnricher(
IXIdentityProvider identityProvider,
IXAiMessageRepository messageRepository,
IXAiConversationRepository conversationRepository,
IXAiProjectTitleResourceProvider projectTitleResourceProvider,
IXAiConversationTitleResourceProvider conversationTitleResourceProvider,
IXAiProjectDescriptionResourceProvider projectDescriptionResourceProvider
)
{
//
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 = source.MapConvert<XAiProjectDto, XAiProject>();
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 = source.MapConvert<XAiProjectDto, XAiProjectDto>();
result.Owner = owner;
result.TitleResource = titleResource;
result.Conversations = [.. conversations];
result.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
}
}
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
+4 -4
View File
@@ -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
{
+2 -2
View File
@@ -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
{
@@ -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
{
+2 -2
View File
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
+2 -2
View File
@@ -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
{
+4 -4
View File
@@ -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
{
+2 -2
View File
@@ -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
{
@@ -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
{
+2 -2
View File
@@ -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
{
@@ -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
{
@@ -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
{
@@ -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
{
+2 -2
View File
@@ -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
{
@@ -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
{
@@ -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
{

Some files were not shown because too many files have changed in this diff Show More