Apply dotnet format with new editorconfig rules

Automated formatting: BOM removal, using sort order, final newlines,
whitespace normalization across all projects.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
This commit is contained in:
Mathias Beaulieu-Duncan 2026-03-12 03:30:50 -04:00
parent a4525bad6a
commit fdee02c960
38 changed files with 3392 additions and 3397 deletions

View File

@ -1,4 +1,4 @@
using System; using System;
namespace Svrnty.CQRS.Abstractions.Attributes; namespace Svrnty.CQRS.Abstractions.Attributes;

View File

@ -1,4 +1,4 @@
using System; using System;
namespace Svrnty.CQRS.Abstractions.Attributes; namespace Svrnty.CQRS.Abstractions.Attributes;

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Reflection; using System.Reflection;
using Svrnty.CQRS.Abstractions.Attributes; using Svrnty.CQRS.Abstractions.Attributes;

View File

@ -1,4 +1,4 @@
using System; using System;
namespace Svrnty.CQRS.Abstractions.Discovery; namespace Svrnty.CQRS.Abstractions.Discovery;

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.Abstractions.Discovery; namespace Svrnty.CQRS.Abstractions.Discovery;

View File

@ -1,4 +1,4 @@
using System; using System;
namespace Svrnty.CQRS.Abstractions.Discovery; namespace Svrnty.CQRS.Abstractions.Discovery;
@ -10,4 +10,4 @@ public interface IQueryMeta
Type QueryResultType { get; } Type QueryResultType { get; }
string Category { get; } string Category { get; }
string LowerCamelCaseName { get; } string LowerCamelCaseName { get; }
} }

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Reflection; using System.Reflection;
using Svrnty.CQRS.Abstractions.Attributes; using Svrnty.CQRS.Abstractions.Attributes;

View File

@ -1,4 +1,4 @@
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace Svrnty.CQRS.Abstractions; namespace Svrnty.CQRS.Abstractions;
@ -13,4 +13,4 @@ public interface ICommandHandler<in TCommand, TCommandResult>
where TCommand : class where TCommand : class
{ {
Task<TCommandResult> HandleAsync(TCommand command, CancellationToken cancellationToken = default); Task<TCommandResult> HandleAsync(TCommand command, CancellationToken cancellationToken = default);
} }

View File

@ -1,4 +1,4 @@
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
namespace Svrnty.CQRS.Abstractions; namespace Svrnty.CQRS.Abstractions;
@ -7,4 +7,4 @@ public interface IQueryHandler<in TQuery, TQueryResult>
where TQuery : class where TQuery : class
{ {
Task<TQueryResult> HandleAsync(TQuery query, CancellationToken cancellationToken = default); Task<TQueryResult> HandleAsync(TQuery query, CancellationToken cancellationToken = default);
} }

View File

@ -1,8 +1,8 @@
namespace Svrnty.CQRS.Abstractions.Security; namespace Svrnty.CQRS.Abstractions.Security;
public enum AuthorizationResult public enum AuthorizationResult
{ {
Unauthorized, Unauthorized,
Forbidden, Forbidden,
Allowed Allowed
} }

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -7,4 +7,4 @@ namespace Svrnty.CQRS.Abstractions.Security;
public interface ICommandAuthorizationService public interface ICommandAuthorizationService
{ {
Task<AuthorizationResult> IsAllowedAsync(Type commandType, CancellationToken cancellationToken = default); Task<AuthorizationResult> IsAllowedAsync(Type commandType, CancellationToken cancellationToken = default);
} }

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -7,4 +7,4 @@ namespace Svrnty.CQRS.Abstractions.Security;
public interface IQueryAuthorizationService public interface IQueryAuthorizationService
{ {
Task<AuthorizationResult> IsAllowedAsync(Type queryType, CancellationToken cancellationToken = default); Task<AuthorizationResult> IsAllowedAsync(Type queryType, CancellationToken cancellationToken = default);
} }

View File

@ -1,4 +1,4 @@
using System.Diagnostics.CodeAnalysis; using System.Diagnostics.CodeAnalysis;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Svrnty.CQRS.Abstractions.Discovery; using Svrnty.CQRS.Abstractions.Discovery;
@ -47,4 +47,4 @@ public static class ServiceCollectionExtensions
return services; return services;
} }
} }

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.DynamicQuery.Abstractions; namespace Svrnty.CQRS.DynamicQuery.Abstractions;

View File

@ -1,4 +1,4 @@
using System.Linq; using System.Linq;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -13,4 +13,4 @@ public interface IAlterQueryableService<TSource, TDestination, in TParams>
where TParams : class where TParams : class
{ {
Task<IQueryable<TSource>> AlterQueryableAsync(IQueryable<TSource> query, IDynamicQueryParams<TParams> dynamicQuery, CancellationToken cancellationToken = default); Task<IQueryable<TSource>> AlterQueryableAsync(IQueryable<TSource> query, IDynamicQueryParams<TParams> dynamicQuery, CancellationToken cancellationToken = default);
} }

View File

@ -1,4 +1,4 @@
using System.Collections.Generic; using System.Collections.Generic;
using PoweredSoft.DynamicQuery.Core; using PoweredSoft.DynamicQuery.Core;
namespace Svrnty.CQRS.DynamicQuery.Abstractions; namespace Svrnty.CQRS.DynamicQuery.Abstractions;
@ -15,7 +15,7 @@ public interface IDynamicQuery<TSource, TDestination, out TParams> : IDynamicQue
where TDestination : class where TDestination : class
where TParams : class where TParams : class
{ {
} }
public interface IDynamicQuery public interface IDynamicQuery
@ -26,4 +26,4 @@ public interface IDynamicQuery
List<IAggregate> GetAggregates(); List<IAggregate> GetAggregates();
int? GetPage(); int? GetPage();
int? GetPageSize(); int? GetPageSize();
} }

View File

@ -1,9 +1,9 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.DynamicQuery.Abstractions; namespace Svrnty.CQRS.DynamicQuery.Abstractions;
public interface IDynamicQueryInterceptorProvider<TSource, TDestination> public interface IDynamicQueryInterceptorProvider<TSource, TDestination>
{ {
IEnumerable<Type> GetInterceptorsTypes(); IEnumerable<Type> GetInterceptorsTypes();
} }

View File

@ -1,4 +1,4 @@
namespace Svrnty.CQRS.DynamicQuery.Abstractions; namespace Svrnty.CQRS.DynamicQuery.Abstractions;
public interface IDynamicQueryParams<out TParams> public interface IDynamicQueryParams<out TParams>
where TParams : class where TParams : class

View File

@ -1,4 +1,4 @@
using System.Linq; using System.Linq;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
@ -7,4 +7,4 @@ namespace Svrnty.CQRS.DynamicQuery.Abstractions;
public interface IQueryableProvider<TSource> public interface IQueryableProvider<TSource>
{ {
Task<IQueryable<TSource>> GetQueryableAsync(object query, CancellationToken cancellationToken = default); Task<IQueryable<TSource>> GetQueryableAsync(object query, CancellationToken cancellationToken = default);
} }

View File

@ -7,6 +7,7 @@ using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http; using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Routing; using Microsoft.AspNetCore.Routing;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using PoweredSoft.DynamicQuery.Core;
using Svrnty.CQRS.Abstractions; using Svrnty.CQRS.Abstractions;
using Svrnty.CQRS.Abstractions.Attributes; using Svrnty.CQRS.Abstractions.Attributes;
using Svrnty.CQRS.Abstractions.Discovery; using Svrnty.CQRS.Abstractions.Discovery;
@ -14,7 +15,6 @@ using Svrnty.CQRS.Abstractions.Security;
using Svrnty.CQRS.DynamicQuery; using Svrnty.CQRS.DynamicQuery;
using Svrnty.CQRS.DynamicQuery.Abstractions; using Svrnty.CQRS.DynamicQuery.Abstractions;
using Svrnty.CQRS.DynamicQuery.Discover; using Svrnty.CQRS.DynamicQuery.Discover;
using PoweredSoft.DynamicQuery.Core;
namespace Svrnty.CQRS.DynamicQuery.MinimalApi; namespace Svrnty.CQRS.DynamicQuery.MinimalApi;

View File

@ -1,4 +1,4 @@
using System; using System;
using Pluralize.NET; using Pluralize.NET;
using Svrnty.CQRS.Abstractions.Discovery; using Svrnty.CQRS.Abstractions.Discovery;
@ -7,7 +7,7 @@ namespace Svrnty.CQRS.DynamicQuery.Discover;
public class DynamicQueryMeta(Type queryType, Type serviceType, Type queryResultType) public class DynamicQueryMeta(Type queryType, Type serviceType, Type queryResultType)
: QueryMeta(queryType, serviceType, queryResultType) : QueryMeta(queryType, serviceType, queryResultType)
{ {
public Type SourceType => QueryType.GetGenericArguments()[0]; public Type SourceType => QueryType.GetGenericArguments()[0];
public Type DestinationType => QueryType.GetGenericArguments()[1]; public Type DestinationType => QueryType.GetGenericArguments()[1];
public override string Category => "DynamicQuery"; public override string Category => "DynamicQuery";
public override string Name public override string Name

View File

@ -1,8 +1,8 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Svrnty.CQRS.DynamicQuery.Abstractions;
using PoweredSoft.DynamicQuery; using PoweredSoft.DynamicQuery;
using PoweredSoft.DynamicQuery.Core; using PoweredSoft.DynamicQuery.Core;
using Svrnty.CQRS.DynamicQuery.Abstractions;
namespace Svrnty.CQRS.DynamicQuery; namespace Svrnty.CQRS.DynamicQuery;

View File

@ -1,6 +1,6 @@
using System;
using PoweredSoft.DynamicQuery; using PoweredSoft.DynamicQuery;
using PoweredSoft.DynamicQuery.Core; using PoweredSoft.DynamicQuery.Core;
using System;
namespace Svrnty.CQRS.DynamicQuery; namespace Svrnty.CQRS.DynamicQuery;

View File

@ -1,23 +1,23 @@
using Svrnty.CQRS.DynamicQuery.Abstractions;
using PoweredSoft.DynamicQuery.Core;
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using PoweredSoft.DynamicQuery.Core;
using Svrnty.CQRS.DynamicQuery.Abstractions;
namespace Svrnty.CQRS.DynamicQuery; namespace Svrnty.CQRS.DynamicQuery;
public class DynamicQueryHandler<TSource, TDestination> public class DynamicQueryHandler<TSource, TDestination>
: DynamicQueryHandlerBase<TSource, TDestination>, : DynamicQueryHandlerBase<TSource, TDestination>,
Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination>, IQueryExecutionResult<TDestination>> Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination>, IQueryExecutionResult<TDestination>>
where TSource : class where TSource : class
where TDestination : class where TDestination : class
{ {
public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync,
IEnumerable<IQueryableProvider<TSource>> queryableProviders, IEnumerable<IQueryableProvider<TSource>> queryableProviders,
IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices, IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices,
IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders, IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders,
IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider) IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider)
{ {
} }
@ -29,7 +29,7 @@ public class DynamicQueryHandler<TSource, TDestination>
} }
public class DynamicQueryHandler<TSource, TDestination, TParams> public class DynamicQueryHandler<TSource, TDestination, TParams>
: DynamicQueryHandlerBase<TSource, TDestination>, : DynamicQueryHandlerBase<TSource, TDestination>,
Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>> Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>
where TSource : class where TSource : class
where TDestination : class where TDestination : class
@ -37,10 +37,10 @@ public class DynamicQueryHandler<TSource, TDestination, TParams>
{ {
private readonly IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams; private readonly IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams;
public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync,
IEnumerable<IQueryableProvider<TSource>> queryableProviders, IEnumerable<IQueryableProvider<TSource>> queryableProviders,
IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices, IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices,
IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams, IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams,
IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders, IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders,
IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider) IServiceProvider serviceProvider) : base(queryHandlerAsync, queryableProviders, alterQueryableServices, dynamicQueryInterceptorProviders, serviceProvider)
{ {
@ -49,7 +49,7 @@ public class DynamicQueryHandler<TSource, TDestination, TParams>
protected override async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query, CancellationToken cancellationToken) protected override async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query, CancellationToken cancellationToken)
{ {
source = await base.AlterSourceAsync(source, query, cancellationToken); source = await base.AlterSourceAsync(source, query, cancellationToken);
if (query is IDynamicQueryParams<TParams> withParams) if (query is IDynamicQueryParams<TParams> withParams)
{ {

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Diagnostics.CodeAnalysis; using System.Diagnostics.CodeAnalysis;
using System.Globalization; using System.Globalization;
@ -6,9 +6,9 @@ using System.Linq;
using System.Reflection; using System.Reflection;
using System.Threading; using System.Threading;
using System.Threading.Tasks; using System.Threading.Tasks;
using Svrnty.CQRS.DynamicQuery.Abstractions;
using PoweredSoft.DynamicQuery; using PoweredSoft.DynamicQuery;
using PoweredSoft.DynamicQuery.Core; using PoweredSoft.DynamicQuery.Core;
using Svrnty.CQRS.DynamicQuery.Abstractions;
namespace Svrnty.CQRS.DynamicQuery; namespace Svrnty.CQRS.DynamicQuery;

View File

@ -1,4 +1,4 @@
using System.Diagnostics.CodeAnalysis; using System.Diagnostics.CodeAnalysis;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection.Extensions; using Microsoft.Extensions.DependencyInjection.Extensions;
using PoweredSoft.Data.Core; using PoweredSoft.Data.Core;
@ -91,10 +91,10 @@ public static class ServiceCollectionExtensions
where TParams : class where TParams : class
=> AddDynamicQueryWithParams<TSourceAndDestination, TSourceAndDestination, TParams>(services, name: name); => AddDynamicQueryWithParams<TSourceAndDestination, TSourceAndDestination, TParams>(services, name: name);
public static IServiceCollection AddDynamicQueryWithParams<TSource, TDestination, TParams>(this IServiceCollection services, string name = null) public static IServiceCollection AddDynamicQueryWithParams<TSource, TDestination, TParams>(this IServiceCollection services, string name = null)
where TSource : class where TSource : class
where TDestination : class where TDestination : class
where TParams : class where TParams : class
{ {
// add query handler. // add query handler.
services.AddTransient<IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>, DynamicQueryHandler<TSource, TDestination, TParams>>(); services.AddTransient<IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>, DynamicQueryHandler<TSource, TDestination, TParams>>();
@ -133,7 +133,7 @@ public static class ServiceCollectionExtensions
where TParams : class where TParams : class
where TService : class, IAlterQueryableService<TSourceAndTDestination, TSourceAndTDestination, TParams> where TService : class, IAlterQueryableService<TSourceAndTDestination, TSourceAndTDestination, TParams>
{ {
return services.AddTransient<IAlterQueryableService< TSourceAndTDestination, TSourceAndTDestination, TParams>, TService>(); return services.AddTransient<IAlterQueryableService<TSourceAndTDestination, TSourceAndTDestination, TParams>, TService>();
} }
public static IServiceCollection AddAlterQueryableWithParams<TSource, TDestination, TParams, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService> public static IServiceCollection AddAlterQueryableWithParams<TSource, TDestination, TParams, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TService>

View File

@ -1,4 +1,4 @@
using System.Diagnostics.CodeAnalysis; using System.Diagnostics.CodeAnalysis;
using FluentValidation; using FluentValidation;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Svrnty.CQRS.Abstractions; using Svrnty.CQRS.Abstractions;
@ -39,7 +39,7 @@ public static class ServiceCollectionExtensions
{ {
services.AddQuery<TQuery, TQueryResult, TQueryHandler>() services.AddQuery<TQuery, TQueryResult, TQueryHandler>()
.AddFluentValidator<TQuery, TValidator>(); .AddFluentValidator<TQuery, TValidator>();
return services; return services;
} }
} }

File diff suppressed because it is too large Load Diff

View File

@ -1,102 +1,101 @@
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.Grpc.Generators.Helpers namespace Svrnty.CQRS.Grpc.Generators.Helpers;
internal static class ProtoTypeMapper
{ {
internal static class ProtoTypeMapper private static readonly Dictionary<string, string> TypeMap = new Dictionary<string, string>
{ {
private static readonly Dictionary<string, string> TypeMap = new Dictionary<string, string> // Primitives
{ "System.String", "string" },
{ "System.Boolean", "bool" },
{ "System.Int32", "int32" },
{ "System.Int64", "int64" },
{ "System.UInt32", "uint32" },
{ "System.UInt64", "uint64" },
{ "System.Single", "float" },
{ "System.Double", "double" },
{ "System.Byte", "uint32" },
{ "System.SByte", "int32" },
{ "System.Int16", "int32" },
{ "System.UInt16", "uint32" },
{ "System.Decimal", "string" }, // Decimal as string to preserve precision
{ "System.DateTime", "int64" }, // Unix timestamp
{ "System.DateTimeOffset", "int64" }, // Unix timestamp
{ "System.Guid", "string" },
{ "System.TimeSpan", "int64" }, // Ticks
// Nullable variants
{ "System.Boolean?", "bool" },
{ "System.Int32?", "int32" },
{ "System.Int64?", "int64" },
{ "System.UInt32?", "uint32" },
{ "System.UInt64?", "uint64" },
{ "System.Single?", "float" },
{ "System.Double?", "double" },
{ "System.Byte?", "uint32" },
{ "System.SByte?", "int32" },
{ "System.Int16?", "int32" },
{ "System.UInt16?", "uint32" },
{ "System.Decimal?", "string" },
{ "System.DateTime?", "int64" },
{ "System.DateTimeOffset?", "int64" },
{ "System.Guid?", "string" },
{ "System.TimeSpan?", "int64" },
};
public static string MapToProtoType(string csharpType, out bool isRepeated, out bool isOptional)
{
isRepeated = false;
isOptional = false;
// Handle byte[] as bytes proto type (NOT repeated uint32)
if (csharpType == "System.Byte[]" || csharpType == "byte[]" || csharpType == "Byte[]")
{ {
// Primitives return "bytes";
{ "System.String", "string" },
{ "System.Boolean", "bool" },
{ "System.Int32", "int32" },
{ "System.Int64", "int64" },
{ "System.UInt32", "uint32" },
{ "System.UInt64", "uint64" },
{ "System.Single", "float" },
{ "System.Double", "double" },
{ "System.Byte", "uint32" },
{ "System.SByte", "int32" },
{ "System.Int16", "int32" },
{ "System.UInt16", "uint32" },
{ "System.Decimal", "string" }, // Decimal as string to preserve precision
{ "System.DateTime", "int64" }, // Unix timestamp
{ "System.DateTimeOffset", "int64" }, // Unix timestamp
{ "System.Guid", "string" },
{ "System.TimeSpan", "int64" }, // Ticks
// Nullable variants
{ "System.Boolean?", "bool" },
{ "System.Int32?", "int32" },
{ "System.Int64?", "int64" },
{ "System.UInt32?", "uint32" },
{ "System.UInt64?", "uint64" },
{ "System.Single?", "float" },
{ "System.Double?", "double" },
{ "System.Byte?", "uint32" },
{ "System.SByte?", "int32" },
{ "System.Int16?", "int32" },
{ "System.UInt16?", "uint32" },
{ "System.Decimal?", "string" },
{ "System.DateTime?", "int64" },
{ "System.DateTimeOffset?", "int64" },
{ "System.Guid?", "string" },
{ "System.TimeSpan?", "int64" },
};
public static string MapToProtoType(string csharpType, out bool isRepeated, out bool isOptional)
{
isRepeated = false;
isOptional = false;
// Handle byte[] as bytes proto type (NOT repeated uint32)
if (csharpType == "System.Byte[]" || csharpType == "byte[]" || csharpType == "Byte[]")
{
return "bytes";
}
// Handle arrays
if (csharpType.EndsWith("[]"))
{
isRepeated = true;
var elementType = csharpType.Substring(0, csharpType.Length - 2);
return MapToProtoType(elementType, out _, out _);
}
// Handle generic collections
if (csharpType.StartsWith("System.Collections.Generic.List<") ||
csharpType.StartsWith("System.Collections.Generic.IList<") ||
csharpType.StartsWith("System.Collections.Generic.IEnumerable<") ||
csharpType.StartsWith("System.Collections.Generic.ICollection<"))
{
isRepeated = true;
var startIndex = csharpType.IndexOf('<') + 1;
var endIndex = csharpType.LastIndexOf('>');
var elementType = csharpType.Substring(startIndex, endIndex - startIndex);
return MapToProtoType(elementType, out _, out _);
}
// Handle nullable value types
if (csharpType.EndsWith("?"))
{
isOptional = true;
}
// Check if it's a known primitive type
if (TypeMap.TryGetValue(csharpType, out var protoType))
{
return protoType;
}
// For unknown types, assume it's a custom message type
// Extract just the type name without namespace
var lastDot = csharpType.LastIndexOf('.');
if (lastDot >= 0)
{
return csharpType.Substring(lastDot + 1).Replace("?", "");
}
return csharpType.Replace("?", "");
} }
// Handle arrays
if (csharpType.EndsWith("[]"))
{
isRepeated = true;
var elementType = csharpType.Substring(0, csharpType.Length - 2);
return MapToProtoType(elementType, out _, out _);
}
// Handle generic collections
if (csharpType.StartsWith("System.Collections.Generic.List<") ||
csharpType.StartsWith("System.Collections.Generic.IList<") ||
csharpType.StartsWith("System.Collections.Generic.IEnumerable<") ||
csharpType.StartsWith("System.Collections.Generic.ICollection<"))
{
isRepeated = true;
var startIndex = csharpType.IndexOf('<') + 1;
var endIndex = csharpType.LastIndexOf('>');
var elementType = csharpType.Substring(startIndex, endIndex - startIndex);
return MapToProtoType(elementType, out _, out _);
}
// Handle nullable value types
if (csharpType.EndsWith("?"))
{
isOptional = true;
}
// Check if it's a known primitive type
if (TypeMap.TryGetValue(csharpType, out var protoType))
{
return protoType;
}
// For unknown types, assume it's a custom message type
// Extract just the type name without namespace
var lastDot = csharpType.LastIndexOf('.');
if (lastDot >= 0)
{
return csharpType.Substring(lastDot + 1).Replace("?", "");
}
return csharpType.Replace("?", "");
} }
} }

View File

@ -1,83 +1,82 @@
using System.Collections.Generic; using System.Collections.Generic;
using Microsoft.CodeAnalysis; using Microsoft.CodeAnalysis;
namespace Svrnty.CQRS.Grpc.Generators.Models namespace Svrnty.CQRS.Grpc.Generators.Models;
public class CommandInfo
{ {
public class CommandInfo public string Name { get; set; }
public string FullyQualifiedName { get; set; }
public string Namespace { get; set; }
public List<PropertyInfo> Properties { get; set; }
public string? ResultType { get; set; }
public string? ResultFullyQualifiedName { get; set; }
public bool HasResult => ResultType != null;
public string HandlerInterfaceName { get; set; }
public List<PropertyInfo> ResultProperties { get; set; }
public bool IsResultPrimitiveType { get; set; }
public CommandInfo()
{ {
public string Name { get; set; } Name = string.Empty;
public string FullyQualifiedName { get; set; } FullyQualifiedName = string.Empty;
public string Namespace { get; set; } Namespace = string.Empty;
public List<PropertyInfo> Properties { get; set; } Properties = new List<PropertyInfo>();
public string? ResultType { get; set; } HandlerInterfaceName = string.Empty;
public string? ResultFullyQualifiedName { get; set; } ResultProperties = new List<PropertyInfo>();
public bool HasResult => ResultType != null; IsResultPrimitiveType = false;
public string HandlerInterfaceName { get; set; } }
public List<PropertyInfo> ResultProperties { get; set; } }
public bool IsResultPrimitiveType { get; set; }
public class PropertyInfo
public CommandInfo() {
{ public string Name { get; set; }
Name = string.Empty; public string Type { get; set; }
FullyQualifiedName = string.Empty; public string FullyQualifiedType { get; set; }
Namespace = string.Empty; public string ProtoType { get; set; }
Properties = new List<PropertyInfo>(); public int FieldNumber { get; set; }
HandlerInterfaceName = string.Empty; public bool IsComplexType { get; set; }
ResultProperties = new List<PropertyInfo>(); public List<PropertyInfo> NestedProperties { get; set; }
IsResultPrimitiveType = false;
} // Type conversion metadata
} public bool IsEnum { get; set; }
public bool IsList { get; set; }
public class PropertyInfo public bool IsNullable { get; set; }
{ public bool IsDecimal { get; set; }
public string Name { get; set; } public bool IsDateTime { get; set; }
public string Type { get; set; } public bool IsDateTimeOffset { get; set; }
public string FullyQualifiedType { get; set; } public bool IsGuid { get; set; }
public string ProtoType { get; set; } public bool IsJsonElement { get; set; }
public int FieldNumber { get; set; } public bool IsBinaryType { get; set; } // Stream, byte[], MemoryStream
public bool IsComplexType { get; set; } public bool IsStream { get; set; } // Specifically Stream types (not byte[])
public List<PropertyInfo> NestedProperties { get; set; } public bool IsReadOnly { get; set; } // Read-only/computed properties should be skipped
public bool IsValueTypeCollection { get; set; } // Value types that implement IList<T> (like NpgsqlPolygon)
// Type conversion metadata public string? ElementType { get; set; }
public bool IsEnum { get; set; } public bool IsElementComplexType { get; set; }
public bool IsList { get; set; } public bool IsElementGuid { get; set; }
public bool IsNullable { get; set; } public List<PropertyInfo>? ElementNestedProperties { get; set; }
public bool IsDecimal { get; set; }
public bool IsDateTime { get; set; } public PropertyInfo()
public bool IsDateTimeOffset { get; set; } {
public bool IsGuid { get; set; } Name = string.Empty;
public bool IsJsonElement { get; set; } Type = string.Empty;
public bool IsBinaryType { get; set; } // Stream, byte[], MemoryStream FullyQualifiedType = string.Empty;
public bool IsStream { get; set; } // Specifically Stream types (not byte[]) ProtoType = string.Empty;
public bool IsReadOnly { get; set; } // Read-only/computed properties should be skipped IsComplexType = false;
public bool IsValueTypeCollection { get; set; } // Value types that implement IList<T> (like NpgsqlPolygon) NestedProperties = new List<PropertyInfo>();
public string? ElementType { get; set; } IsEnum = false;
public bool IsElementComplexType { get; set; } IsList = false;
public bool IsElementGuid { get; set; } IsNullable = false;
public List<PropertyInfo>? ElementNestedProperties { get; set; } IsDecimal = false;
IsDateTime = false;
public PropertyInfo() IsDateTimeOffset = false;
{ IsGuid = false;
Name = string.Empty; IsJsonElement = false;
Type = string.Empty; IsBinaryType = false;
FullyQualifiedType = string.Empty; IsStream = false;
ProtoType = string.Empty; IsReadOnly = false;
IsComplexType = false; IsValueTypeCollection = false;
NestedProperties = new List<PropertyInfo>(); IsElementComplexType = false;
IsEnum = false; IsElementGuid = false;
IsList = false;
IsNullable = false;
IsDecimal = false;
IsDateTime = false;
IsDateTimeOffset = false;
IsGuid = false;
IsJsonElement = false;
IsBinaryType = false;
IsStream = false;
IsReadOnly = false;
IsValueTypeCollection = false;
IsElementComplexType = false;
IsElementGuid = false;
}
} }
} }

View File

@ -1,28 +1,27 @@
namespace Svrnty.CQRS.Grpc.Generators.Models namespace Svrnty.CQRS.Grpc.Generators.Models;
{
public class DynamicQueryInfo
{
public string Name { get; set; }
public string SourceType { get; set; }
public string SourceTypeFullyQualified { get; set; }
public string DestinationType { get; set; }
public string DestinationTypeFullyQualified { get; set; }
public string? ParamsType { get; set; }
public string? ParamsTypeFullyQualified { get; set; }
public string HandlerInterfaceName { get; set; }
public string QueryInterfaceName { get; set; }
public bool HasParams { get; set; }
public DynamicQueryInfo() public class DynamicQueryInfo
{ {
Name = string.Empty; public string Name { get; set; }
SourceType = string.Empty; public string SourceType { get; set; }
SourceTypeFullyQualified = string.Empty; public string SourceTypeFullyQualified { get; set; }
DestinationType = string.Empty; public string DestinationType { get; set; }
DestinationTypeFullyQualified = string.Empty; public string DestinationTypeFullyQualified { get; set; }
HandlerInterfaceName = string.Empty; public string? ParamsType { get; set; }
QueryInterfaceName = string.Empty; public string? ParamsTypeFullyQualified { get; set; }
HasParams = false; public string HandlerInterfaceName { get; set; }
} public string QueryInterfaceName { get; set; }
public bool HasParams { get; set; }
public DynamicQueryInfo()
{
Name = string.Empty;
SourceType = string.Empty;
SourceTypeFullyQualified = string.Empty;
DestinationType = string.Empty;
DestinationTypeFullyQualified = string.Empty;
HandlerInterfaceName = string.Empty;
QueryInterfaceName = string.Empty;
HasParams = false;
} }
} }

View File

@ -1,50 +1,49 @@
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.Grpc.Generators.Models namespace Svrnty.CQRS.Grpc.Generators.Models;
/// <summary>
/// Represents a discovered streaming notification type for proto/gRPC generation.
/// </summary>
public class NotificationInfo
{ {
/// <summary> /// <summary>
/// Represents a discovered streaming notification type for proto/gRPC generation. /// The notification type name (e.g., "InventoryChangeNotification").
/// </summary> /// </summary>
public class NotificationInfo public string Name { get; set; }
/// <summary>
/// The fully qualified type name including namespace.
/// </summary>
public string FullyQualifiedName { get; set; }
/// <summary>
/// The namespace of the notification type.
/// </summary>
public string Namespace { get; set; }
/// <summary>
/// The property name used as the subscription key (from [StreamingNotification] attribute).
/// </summary>
public string SubscriptionKeyProperty { get; set; }
/// <summary>
/// The subscription key property info.
/// </summary>
public PropertyInfo SubscriptionKeyInfo { get; set; }
/// <summary>
/// All properties of the notification type.
/// </summary>
public List<PropertyInfo> Properties { get; set; }
public NotificationInfo()
{ {
/// <summary> Name = string.Empty;
/// The notification type name (e.g., "InventoryChangeNotification"). FullyQualifiedName = string.Empty;
/// </summary> Namespace = string.Empty;
public string Name { get; set; } SubscriptionKeyProperty = string.Empty;
SubscriptionKeyInfo = new PropertyInfo();
/// <summary> Properties = new List<PropertyInfo>();
/// The fully qualified type name including namespace.
/// </summary>
public string FullyQualifiedName { get; set; }
/// <summary>
/// The namespace of the notification type.
/// </summary>
public string Namespace { get; set; }
/// <summary>
/// The property name used as the subscription key (from [StreamingNotification] attribute).
/// </summary>
public string SubscriptionKeyProperty { get; set; }
/// <summary>
/// The subscription key property info.
/// </summary>
public PropertyInfo SubscriptionKeyInfo { get; set; }
/// <summary>
/// All properties of the notification type.
/// </summary>
public List<PropertyInfo> Properties { get; set; }
public NotificationInfo()
{
Name = string.Empty;
FullyQualifiedName = string.Empty;
Namespace = string.Empty;
SubscriptionKeyProperty = string.Empty;
SubscriptionKeyInfo = new PropertyInfo();
Properties = new List<PropertyInfo>();
}
} }
} }

View File

@ -1,30 +1,29 @@
using System.Collections.Generic; using System.Collections.Generic;
namespace Svrnty.CQRS.Grpc.Generators.Models namespace Svrnty.CQRS.Grpc.Generators.Models;
{
public class QueryInfo
{
public string Name { get; set; }
public string FullyQualifiedName { get; set; }
public string Namespace { get; set; }
public List<PropertyInfo> Properties { get; set; }
public string ResultType { get; set; }
public string ResultFullyQualifiedName { get; set; }
public string HandlerInterfaceName { get; set; }
public List<PropertyInfo> ResultProperties { get; set; }
public bool IsResultPrimitiveType { get; set; }
public QueryInfo() public class QueryInfo
{ {
Name = string.Empty; public string Name { get; set; }
FullyQualifiedName = string.Empty; public string FullyQualifiedName { get; set; }
Namespace = string.Empty; public string Namespace { get; set; }
Properties = new List<PropertyInfo>(); public List<PropertyInfo> Properties { get; set; }
ResultType = string.Empty; public string ResultType { get; set; }
ResultFullyQualifiedName = string.Empty; public string ResultFullyQualifiedName { get; set; }
HandlerInterfaceName = string.Empty; public string HandlerInterfaceName { get; set; }
ResultProperties = new List<PropertyInfo>(); public List<PropertyInfo> ResultProperties { get; set; }
IsResultPrimitiveType = false; public bool IsResultPrimitiveType { get; set; }
}
public QueryInfo()
{
Name = string.Empty;
FullyQualifiedName = string.Empty;
Namespace = string.Empty;
Properties = new List<PropertyInfo>();
ResultType = string.Empty;
ResultFullyQualifiedName = string.Empty;
HandlerInterfaceName = string.Empty;
ResultProperties = new List<PropertyInfo>();
IsResultPrimitiveType = false;
} }
} }

View File

@ -1,3 +1,4 @@
using System.Diagnostics.CodeAnalysis;
using Microsoft.Extensions.DependencyInjection; using Microsoft.Extensions.DependencyInjection;
using Svrnty.CQRS.Abstractions; using Svrnty.CQRS.Abstractions;
using Svrnty.CQRS.Discovery; using Svrnty.CQRS.Discovery;
@ -43,7 +44,7 @@ public class CqrsBuilder
/// <summary> /// <summary>
/// Adds a command handler to the CQRS pipeline /// Adds a command handler to the CQRS pipeline
/// </summary> /// </summary>
public CqrsBuilder AddCommand<TCommand, TCommandHandler>() public CqrsBuilder AddCommand<TCommand, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TCommandHandler>()
where TCommand : class where TCommand : class
where TCommandHandler : class, ICommandHandler<TCommand> where TCommandHandler : class, ICommandHandler<TCommand>
{ {
@ -54,7 +55,7 @@ public class CqrsBuilder
/// <summary> /// <summary>
/// Adds a command handler with result to the CQRS pipeline /// Adds a command handler with result to the CQRS pipeline
/// </summary> /// </summary>
public CqrsBuilder AddCommand<TCommand, TResult, TCommandHandler>() public CqrsBuilder AddCommand<TCommand, TResult, [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicConstructors)] TCommandHandler>()
where TCommand : class where TCommand : class
where TCommandHandler : class, ICommandHandler<TCommand, TResult> where TCommandHandler : class, ICommandHandler<TCommand, TResult>
{ {

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Svrnty.CQRS.Abstractions.Discovery; using Svrnty.CQRS.Abstractions.Discovery;

View File

@ -1,4 +1,4 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq; using System.Linq;
using Svrnty.CQRS.Abstractions.Discovery; using Svrnty.CQRS.Abstractions.Discovery;

View File

@ -1,11 +1,11 @@
using Microsoft.AspNetCore.Server.Kestrel.Core; using Microsoft.AspNetCore.Server.Kestrel.Core;
using Svrnty.CQRS; using Svrnty.CQRS;
using Svrnty.CQRS.Abstractions;
using Svrnty.CQRS.DynamicQuery;
using Svrnty.CQRS.FluentValidation; using Svrnty.CQRS.FluentValidation;
using Svrnty.CQRS.Grpc; using Svrnty.CQRS.Grpc;
using Svrnty.Sample;
using Svrnty.CQRS.MinimalApi; using Svrnty.CQRS.MinimalApi;
using Svrnty.CQRS.DynamicQuery; using Svrnty.Sample;
using Svrnty.CQRS.Abstractions;
var builder = WebApplication.CreateBuilder(args); var builder = WebApplication.CreateBuilder(args);

View File

@ -1,5 +1,5 @@
using PoweredSoft.Data.Core;
using System.Linq.Expressions; using System.Linq.Expressions;
using PoweredSoft.Data.Core;
namespace Svrnty.Sample; namespace Svrnty.Sample;