cat on a spaceship

2025-11-01 22:38:46 -04:00
parent 747fa227a1
commit f6dccf46d7
89 changed files with 2663 additions and 581 deletions
@@ -0,0 +1,32 @@
+using System;
+using Pluralize.NET;
+using Svrnty.CQRS.Abstractions.Discovery;
+
+namespace Svrnty.CQRS.DynamicQuery.Discover;
+
+public class DynamicQueryMeta : QueryMeta
+{
+    public DynamicQueryMeta(Type queryType, Type serviceType, Type queryResultType) : base(queryType, serviceType, queryResultType)
+    {
+
+    }
+
+    public Type SourceType => QueryType.GetGenericArguments()[0];
+    public Type DestinationType => QueryType.GetGenericArguments()[1];
+    public override string Category => "DynamicQuery";
+    public override string Name
+    {
+        get
+        {
+            if (OverridableName != null)
+                return OverridableName;
+
+            var pluralizer = new Pluralizer();
+            return pluralizer.Pluralize(DestinationType.Name);
+        }
+    }
+
+    public Type ParamsType { get; internal set; }
+    public string OverridableName { get; internal set; }
+}
+
@@ -0,0 +1,67 @@
+using Svrnty.CQRS.DynamicQuery.Abstractions;
+using PoweredSoft.DynamicQuery.Core;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+
+namespace Svrnty.CQRS.DynamicQuery;
+
+public class DynamicQueryHandler<TSource, TDestination>
+    : DynamicQueryHandlerBase<TSource, TDestination>, 
+    Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination>, IQueryExecutionResult<TDestination>>
+    where TSource : class
+    where TDestination : class
+{
+    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, 
+        IEnumerable<IQueryableProvider<TSource>> queryableProviders,
+        IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices, 
+        IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders, 
+        IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider)
+    {
+    }
+
+    public Task<IQueryExecutionResult<TDestination>> HandleAsync(IDynamicQuery<TSource, TDestination> query, CancellationToken cancellationToken = default)
+    {
+        return ProcessQueryAsync(query, cancellationToken);
+    }
+}
+
+public class DynamicQueryHandler<TSource, TDestination, TParams>
+    : DynamicQueryHandlerBase<TSource, TDestination>, 
+    Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>
+    where TSource : class
+    where TDestination : class
+    where TParams : class
+{
+    private readonly IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams;
+
+    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, 
+        IEnumerable<IQueryableProvider<TSource>> queryableProviders,
+        IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices,
+        IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams, 
+        IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders,
+        IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider)
+    {
+        this.alterQueryableServicesWithParams = alterQueryableServicesWithParams;
+    }
+
+    protected override async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query, CancellationToken cancellationToken)
+    {
+        source =  await base.AlterSourceAsync(source, query, cancellationToken);
+
+        if (query is IDynamicQueryParams<TParams> withParams)
+        {
+            foreach (var it in alterQueryableServicesWithParams)
+                source = await it.AlterQueryableAsync(source, withParams, cancellationToken);
+        }
+
+        return source;
+    }
+
+    public Task<IQueryExecutionResult<TDestination>> HandleAsync(IDynamicQuery<TSource, TDestination, TParams> query, CancellationToken cancellationToken = default)
+    {
+        return this.ProcessQueryAsync(query, cancellationToken);
+    }
+}
@@ -0,0 +1,92 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using Svrnty.CQRS.DynamicQuery.Abstractions;
+using PoweredSoft.DynamicQuery;
+using PoweredSoft.DynamicQuery.Core;
+
+namespace Svrnty.CQRS.DynamicQuery;
+
+public abstract class DynamicQueryHandlerBase<TSource, TDestination>
+    where TSource : class
+    where TDestination : class
+{
+    private readonly IQueryHandlerAsync _queryHandlerAsync;
+    private readonly IEnumerable<IQueryableProvider<TSource>> _queryableProviders;
+    private readonly IEnumerable<IAlterQueryableService<TSource, TDestination>> _alterQueryableServices;
+    private readonly IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> _dynamicQueryInterceptorProviders;
+    private readonly IServiceProvider _serviceProvider;
+
+    public DynamicQueryHandlerBase(IQueryHandlerAsync queryHandlerAsync, 
+        IEnumerable<IQueryableProvider<TSource>> queryableProviders,
+        IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices,
+        IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders,
+        IServiceProvider serviceProvider)
+    {
+        _queryHandlerAsync = queryHandlerAsync;
+        _queryableProviders = queryableProviders;
+        _alterQueryableServices = alterQueryableServices;
+        _dynamicQueryInterceptorProviders = dynamicQueryInterceptorProviders;
+        _serviceProvider = serviceProvider;
+    }
+
+    protected virtual Task<IQueryable<TSource>> GetQueryableAsync(IDynamicQuery query, CancellationToken cancellationToken = default)
+    {
+        if (_queryableProviders.Any())
+            return _queryableProviders.ElementAt(0).GetQueryableAsync(query, cancellationToken);
+
+        throw new Exception($"You must provide a QueryableProvider<TSource> for {typeof(TSource).Name}");
+    }
+
+    public virtual IQueryExecutionOptions GetQueryExecutionOptions(IQueryable<TSource> source, IDynamicQuery query)
+    {
+        return new QueryExecutionOptions();
+    }
+
+    public virtual IEnumerable<IQueryInterceptor> GetInterceptors()
+    {
+        var types = _dynamicQueryInterceptorProviders.SelectMany(t => t.GetInterceptorsTypes()).Distinct();
+        foreach (var type in types)
+            yield return _serviceProvider.GetService(type) as IQueryInterceptor;
+    }
+
+    protected async Task<IQueryExecutionResult<TDestination>> ProcessQueryAsync(IDynamicQuery query, CancellationToken cancellationToken = default)
+    {
+        var source = await GetQueryableAsync(query, cancellationToken);
+        source = await AlterSourceAsync(source, query, cancellationToken);
+        var options = GetQueryExecutionOptions(source, query);
+        var interceptors = GetInterceptors();
+
+        foreach (var interceptor in interceptors)
+            _queryHandlerAsync.AddInterceptor(interceptor);
+
+        var criteria = CreateCriteriaFromQuery(query);
+        var result = await _queryHandlerAsync.ExecuteAsync<TSource, TDestination>(source, criteria, options, cancellationToken);
+        return result;
+    }
+
+    protected virtual async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query, CancellationToken cancellationToken)
+    {
+        foreach (var t in _alterQueryableServices)
+            source = await t.AlterQueryableAsync(source, query, cancellationToken);
+
+        return source;
+    }
+
+    protected virtual IQueryCriteria CreateCriteriaFromQuery(IDynamicQuery query)
+    {
+        var criteria = new QueryCriteria
+        {
+            Page = query?.GetPage(),
+            PageSize = query?.GetPageSize(),
+            Filters = query?.GetFilters() ?? new List<IFilter>(),
+            Sorts = query?.GetSorts() ?? new List<ISort>(),
+            Groups = query?.GetGroups() ?? new List<IGroup>(),
+            Aggregates = query?.GetAggregates() ?? new List<IAggregate>()
+        };
+        return criteria;
+    }
+}
+
@@ -0,0 +1,176 @@
+using System.Diagnostics.CodeAnalysis;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using Svrnty.CQRS.Abstractions;
+using Svrnty.CQRS.Abstractions.Discovery;
+using Svrnty.CQRS.DynamicQuery.Abstractions;
+using Svrnty.CQRS.DynamicQuery.Discover;
+using PoweredSoft.DynamicQuery.Core;
+
+namespace Svrnty.CQRS.DynamicQuery;
+
+public static class ServiceCollectionExtensions
+{
+    public static IServiceCollection AddDynamicQuery<TSourceAndDestination>(this IServiceCollection services, string name = null)
+        where TSourceAndDestination : class
+        => AddDynamicQuery<TSourceAndDestination, TSourceAndDestination>(services, name: name);
+
+    public static IServiceCollection AddDynamicQuery<TSource, TDestination>(this IServiceCollection services, string name = null)
+        where TSource : class
+        where TDestination : class
+    {
+        // add query handler.
+        services.AddTransient<IQueryHandler<IDynamicQuery<TSource, TDestination>, IQueryExecutionResult<TDestination>>, DynamicQueryHandler<TSource, TDestination>>();
+
+        // add for discovery purposes.
+        var queryType = typeof(IDynamicQuery<TSource, TDestination>);
+        var resultType = typeof(IQueryExecutionResult<TDestination>);
+        var serviceType = typeof(DynamicQueryHandler<TSource, TDestination>);
+        var queryMeta = new DynamicQueryMeta(queryType, serviceType, resultType)
+        {
+            OverridableName = name
+        };
+
+        services.AddSingleton<IQueryMeta>(queryMeta);
+
+        return services;
+    }
+
+    public static IServiceCollection AddDynamicQueryWithProvider<TSource, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TQueryableProvider>(this IServiceCollection services, string name = null)
+        where TQueryableProvider : class, IQueryableProvider<TSource>
+        where TSource : class
+    {
+        services.AddTransient<IQueryableProvider<TSource>, TQueryableProvider>()
+            .AddDynamicQuery<TSource>(name: name);
+        return services;
+    }
+
+    public static IServiceCollection AddDynamicQueryWithParamsAndProvider<TSource, TParams, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TQueryableProvider>(this IServiceCollection services, string name = null)
+        where TQueryableProvider : class, IQueryableProvider<TSource>
+        where TParams : class
+        where TSource : class
+    {
+        services.AddTransient<IQueryableProvider<TSource>, TQueryableProvider>()
+            .AddDynamicQueryWithParams<TSource, TParams>(name: name);
+        return services;
+    }
+
+    public static IServiceCollection AddDynamicQueryWithParams<TSourceAndDestination, TParams>(this IServiceCollection services, string name = null)
+        where TSourceAndDestination : class
+        where TParams : class
+        => AddDynamicQueryWithParams<TSourceAndDestination, TSourceAndDestination, TParams>(services, name: name);
+
+        public static IServiceCollection AddDynamicQueryWithParams<TSource, TDestination, TParams>(this IServiceCollection services, string name = null)
+        where TSource : class
+        where TDestination : class
+        where TParams : class
+    {
+        // add query handler.
+        services.AddTransient<IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>, DynamicQueryHandler<TSource, TDestination, TParams>>();
+
+        // add for discovery purposes.
+        var queryType = typeof(IDynamicQuery<TSource, TDestination, TParams>);
+        var resultType = typeof(IQueryExecutionResult<TDestination>);
+        var serviceType = typeof(DynamicQueryHandler<TSource, TDestination>);
+        var queryMeta = new DynamicQueryMeta(queryType, serviceType, resultType)
+        {
+
+            // params type.
+            ParamsType = typeof(TParams),
+            OverridableName = name
+        };
+
+        services.AddSingleton<IQueryMeta>(queryMeta);
+
+        return services;
+    }
+
+    public static IServiceCollection AddAlterQueryable<TSourceAndDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService>(this IServiceCollection services)
+        where TService : class, IAlterQueryableService<TSourceAndDestination, TSourceAndDestination>
+    {
+        return services.AddTransient<IAlterQueryableService<TSourceAndDestination, TSourceAndDestination>, TService>();
+    }
+
+    public static IServiceCollection AddAlterQueryable<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService>(this IServiceCollection services)
+        where TService : class, IAlterQueryableService<TSource, TDestination>
+    {
+        return services.AddTransient<IAlterQueryableService<TSource, TDestination>, TService>();
+    }
+
+    public static IServiceCollection AddAlterQueryableWithParams<TSourceAndTDestination, TParams, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService>
+        (this IServiceCollection services)
+        where TParams : class
+        where TService : class, IAlterQueryableService<TSourceAndTDestination, TSourceAndTDestination, TParams>
+    {
+        return services.AddTransient<IAlterQueryableService< TSourceAndTDestination, TSourceAndTDestination, TParams>, TService>();
+    }
+
+    public static IServiceCollection AddAlterQueryableWithParams<TSource, TDestination, TParams, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService>
+        (this IServiceCollection services)
+        where TParams : class
+        where TService : class, IAlterQueryableService<TSource, TDestination, TParams>
+    {
+        return services.AddTransient<IAlterQueryableService<TSource, TDestination, TParams>, TService>();
+    }
+
+    public static IServiceCollection AddDynamicQueryInterceptor<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TInterceptor>(this IServiceCollection services)
+        where TInterceptor : class, IQueryInterceptor
+    {
+        services.TryAddTransient<TInterceptor>();
+        return services.AddSingleton<IDynamicQueryInterceptorProvider<TSource, TDestination>>(
+            new DynamicQueryInterceptorProvider<TSource, TDestination>(typeof(TInterceptor)));
+    }
+
+    public static IServiceCollection AddDynamicQueryInterceptors<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T1, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T2>(this IServiceCollection services)
+        where T1 : class, IQueryInterceptor
+        where T2 : class, IQueryInterceptor
+    {
+        services.TryAddTransient<T1>();
+        services.TryAddTransient<T2>();
+        return services.AddSingleton<IDynamicQueryInterceptorProvider<TSource, TDestination>>(
+            new DynamicQueryInterceptorProvider<TSource, TDestination>(typeof(T1), typeof(T2)));
+    }
+
+    public static IServiceCollection AddDynamicQueryInterceptors<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T1, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T2, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T3>(this IServiceCollection services)
+        where T1 : class, IQueryInterceptor
+        where T2 : class, IQueryInterceptor
+        where T3 : class, IQueryInterceptor
+    {
+        services.TryAddTransient<T1>();
+        services.TryAddTransient<T2>();
+        services.TryAddTransient<T3>();
+        return services.AddSingleton<IDynamicQueryInterceptorProvider<TSource, TDestination>>(
+            new DynamicQueryInterceptorProvider<TSource, TDestination>(typeof(T1), typeof(T2), typeof(T3)));
+    }
+
+    public static IServiceCollection AddDynamicQueryInterceptors<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T1, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T2, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T3, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T4>(this IServiceCollection services)
+        where T1 : class, IQueryInterceptor
+        where T2 : class, IQueryInterceptor
+        where T3 : class, IQueryInterceptor
+        where T4 : class, IQueryInterceptor
+    {
+        services.TryAddTransient<T1>();
+        services.TryAddTransient<T2>();
+        services.TryAddTransient<T3>();
+        services.TryAddTransient<T4>();
+        return services.AddSingleton<IDynamicQueryInterceptorProvider<TSource, TDestination>>(
+            new DynamicQueryInterceptorProvider<TSource, TDestination>(typeof(T1), typeof(T2), typeof(T3), typeof(T4)));
+    }
+
+    public static IServiceCollection AddDynamicQueryInterceptors<TSource, TDestination, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T1, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T2, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T3, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T4, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] T5>(this IServiceCollection services)
+        where T1 : class, IQueryInterceptor
+        where T2 : class, IQueryInterceptor
+        where T3 : class, IQueryInterceptor
+        where T4 : class, IQueryInterceptor
+        where T5 : class, IQueryInterceptor
+    {
+        services.TryAddTransient<T1>();
+        services.TryAddTransient<T2>();
+        services.TryAddTransient<T3>();
+        services.TryAddTransient<T4>();
+        services.TryAddTransient<T5>();
+        return services.AddSingleton<IDynamicQueryInterceptorProvider<TSource, TDestination>>(
+            new DynamicQueryInterceptorProvider<TSource, TDestination>(typeof(T1), typeof(T2), typeof(T3), typeof(T4), typeof(T5)));
+    }
+}
+
@@ -0,0 +1,35 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <TargetFramework>net10.0</TargetFramework>
+    <IsAotCompatible>true</IsAotCompatible>
+    <LangVersion>14</LangVersion>
+    <Company>Svrnty</Company>
+    <PackageIcon>icon.png</PackageIcon>
+    <PackageReadmeFile>README.md</PackageReadmeFile>
+    <RepositoryUrl>https://github.com/svrnty/dotnet-cqrs</RepositoryUrl>
+    <RepositoryType>git</RepositoryType>
+    <PublishRepositoryUrl>true</PublishRepositoryUrl>
+    <PackageLicenseExpression>MIT</PackageLicenseExpression>
+
+    <DebugType>portable</DebugType>
+    <DebugSymbols>true</DebugSymbols>
+    <IncludeSymbols>true</IncludeSymbols>
+    <IncludeSource>true</IncludeSource>
+    <SymbolPackageFormat>snupkg</SymbolPackageFormat>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <None Include="..\icon.png" Pack="true" PackagePath="" CopyToOutputDirectory="Always" />
+    <None Include="..\README.md" Pack="true" PackagePath="" CopyToOutputDirectory="Always" />
+  </ItemGroup>
+  
+  <ItemGroup>
+    <PackageReference Include="Pluralize.NET" Version="1.0.2" />
+    <PackageReference Include="PoweredSoft.DynamicQuery" Version="3.0.1" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\Svrnty.CQRS.DynamicQuery.Abstractions\Svrnty.CQRS.DynamicQuery.Abstractions.csproj" />
+    <ProjectReference Include="..\Svrnty.CQRS\Svrnty.CQRS.csproj" />
+  </ItemGroup>
+</Project>