.claude/.harness-version

@@ -0,0 +1 @@
+1.0.0

.claude/rules/commands-queries.md

@@ -0,0 +1,100 @@
+---
+paths:
+  - "*Command*.cs"
+  - "*Query*.cs"
+  - "*Handler*.cs"
+  - "**/Program.cs"
+  - "**/ServiceCollectionExtensions.cs"
+---
+
+# Commands & Queries
+
+## Commands Are Domain Actions, Not CRUD
+
+Commands express **user intent**. Name them as the business action being performed.
+
+- `PlaceOrderCommand` not `CreateOrderCommand`
+- `ApproveExpenseCommand` not `UpdateExpenseCommand`
+- `DeactivateAccountCommand` not `DeleteAccountCommand`
+
+One CRUD "Update" often becomes multiple distinct commands, each with its own validation and side effects.
+
+## File Structure
+
+Command, handler, and validator live in the **same file**, organized by feature:
+
+```csharp
+// File: Features/Orders/PlaceOrderCommand.cs
+public record PlaceOrderCommand
+{
+    public string CustomerId { get; set; } = string.Empty;
+    public List<OrderItem> Items { get; set; } = [];
+}
+
+public class PlaceOrderCommandValidator : AbstractValidator<PlaceOrderCommand>
+{
+    public PlaceOrderCommandValidator()
+    {
+        RuleFor(x => x.CustomerId).NotEmpty();
+        RuleFor(x => x.Items).NotEmpty();
+    }
+}
+
+public class PlaceOrderCommandHandler : ICommandHandler<PlaceOrderCommand, int>
+{
+    public Task<int> HandleAsync(PlaceOrderCommand command, CancellationToken cancellationToken = default)
+    {
+        // implementation
+    }
+}
+```
+
+## Handler Interfaces
+
+```csharp
+// Command with no result
+ICommandHandler<TCommand>
+    Task HandleAsync(TCommand command, CancellationToken cancellationToken = default)
+
+// Command with result
+ICommandHandler<TCommand, TResult>
+    Task<TResult> HandleAsync(TCommand command, CancellationToken cancellationToken = default)
+
+// Query (always returns result) — only for single-entity lookups or non-queryable data
+IQueryHandler<TQuery, TResult>
+    Task<TResult> HandleAsync(TQuery query, CancellationToken cancellationToken = default)
+```
+
+## Registration
+
+```csharp
+// Command without result
+services.AddCommand<DeactivateAccountCommand, DeactivateAccountCommandHandler>();
+
+// Command with result
+services.AddCommand<PlaceOrderCommand, int, PlaceOrderCommandHandler>();
+
+// Command with result + validator (from Svrnty.CQRS.FluentValidation)
+services.AddCommand<PlaceOrderCommand, int, PlaceOrderCommandHandler, PlaceOrderCommandValidator>();
+
+// Regular query — ONLY for single-entity lookups or non-queryable results
+services.AddQuery<FetchOrderByIdQuery, Order, FetchOrderByIdQueryHandler>();
+```
+
+## When to Use Regular IQueryHandler vs Dynamic Query
+
+**Use `IQueryHandler`** (rare):
+- Single entity by ID: `FetchOrderByIdQuery`
+- Non-entity results: `GetDashboardStatsQuery`
+- Complex aggregation not expressible as IQueryable
+
+**Use Dynamic Query** (default — see dynamic-query.md rule):
+- Any list/collection query
+- Anything that needs pagination, filtering, or sorting
+
+## Rules
+
+- Always use `CancellationToken` — never omit it
+- Commands/queries are `record` types with `{ get; set; }` properties
+- Default string properties to `string.Empty`, collections to `[]`
+- Naming: endpoint name is auto-derived by stripping `Command`/`Query` suffix and converting to lowerCamelCase

.claude/rules/dynamic-query.md

@@ -0,0 +1,97 @@
+---
+paths:
+  - "*QueryableProvider*.cs"
+  - "*AlterQueryable*.cs"
+  - "*DynamicQuery*.cs"
+  - "*Interceptor*.cs"
+---
+
+# Dynamic Queries — The Default Query Pattern
+
+**99% of queries should be dynamic queries.** They provide pagination, filtering, sorting, grouping, and aggregation for free.
+
+## The Standard Pattern: IQueryableProviderOverride
+
+```csharp
+// File: Features/Orders/OrderQueryableProvider.cs
+public class OrderQueryableProvider : IQueryableProviderOverride<Order>
+{
+    private readonly AppDbContext _db;
+    public OrderQueryableProvider(AppDbContext db) => _db = db;
+
+    public Task<IQueryable<Order>> GetQueryableAsync(object query, CancellationToken ct = default)
+        => Task.FromResult(_db.Orders.AsQueryable());
+}
+```
+
+Registration — one line:
+```csharp
+builder.Services.AddDynamicQueryWithProvider<Order, OrderQueryableProvider>();
+```
+
+This automatically creates endpoints with full filtering, sorting, and pagination support.
+
+## Required Dependencies
+
+These must be registered before `AddSvrntyCqrs`:
+```csharp
+builder.Services.AddTransient<IAsyncQueryableService, SimpleAsyncQueryableService>();
+builder.Services.AddTransient<IQueryHandlerAsync, QueryHandlerAsync>();
+```
+
+## Alter Queryable Services (Security Filters, Tenant Isolation)
+
+Use `IAlterQueryableService` to modify the queryable before execution — for security filters, tenant isolation, default ordering, etc.
+
+```csharp
+public class OrderTenantFilter : IAlterQueryableService<Order, Order>
+{
+    private readonly ITenantContext _tenant;
+    public OrderTenantFilter(ITenantContext tenant) => _tenant = tenant;
+
+    public Task<IQueryable<Order>> AlterQueryableAsync(
+        IQueryable<Order> query,
+        IDynamicQuery dynamicQuery,
+        CancellationToken ct = default)
+    {
+        return Task.FromResult(query.Where(o => o.TenantId == _tenant.Id));
+    }
+}
+```
+
+Registration:
+```csharp
+builder.Services.AddAlterQueryable<Order, Order, OrderTenantFilter>();
+```
+
+## Interceptors
+
+Up to 5 interceptors per query type. These modify the PoweredSoft DynamicQuery criteria at query build time.
+
+```csharp
+builder.Services.AddDynamicQueryInterceptor<Order, Order, OrderInterceptor>();
+```
+
+## Source to Destination Mapping
+
+When the entity type differs from the DTO:
+```csharp
+// Provider returns the source entity queryable
+public class OrderQueryableProvider : IQueryableProviderOverride<Order> { ... }
+
+// Registration maps source -> destination
+builder.Services.AddDynamicQueryWithProvider<Order, OrderDto, OrderQueryableProvider>();
+```
+
+## Key Interfaces
+
+```csharp
+IQueryableProvider<TSource>
+    Task<IQueryable<TSource>> GetQueryableAsync(object query, CancellationToken ct)
+
+IQueryableProviderOverride<TSource> : IQueryableProvider<TSource>
+    // Marker interface — same method, signals override registration
+
+IAlterQueryableService<TSource, TDestination>
+    Task<IQueryable<TSource>> AlterQueryableAsync(IQueryable<TSource> query, IDynamicQuery dynamicQuery, CancellationToken ct)
+```

.claude/rules/grpc.md

@@ -0,0 +1,109 @@
+---
+paths:
+  - "**/*.proto"
+  - "**/Protos/**"
+  - "*Grpc*"
+---
+
+# gRPC Integration
+
+## Proto File Conventions
+
+Proto files live in `Protos/` directory. The source generator (`Svrnty.CQRS.Grpc.Generators`) auto-generates service implementations at compile time.
+
+### Service Structure
+```protobuf
+service CommandService {
+  rpc PlaceOrder (PlaceOrderCommandRequest) returns (PlaceOrderCommandResponse);
+}
+
+service QueryService {
+  rpc FetchUserById (FetchUserByIdQueryRequest) returns (FetchUserByIdQueryResponse);
+}
+
+service DynamicQueryService {
+  rpc QueryOrders (DynamicQueryOrdersRequest) returns (DynamicQueryOrdersResponse);
+}
+```
+
+### Naming Rules
+- RPC method name: command/query name without the `Command`/`Query` suffix
+- Request message: `{Name}CommandRequest` or `{Name}QueryRequest`
+- Response message: `{Name}CommandResponse` or `{Name}QueryResponse`
+- Dynamic query request: `DynamicQuery{PluralEntity}Request`
+- Dynamic query response: `DynamicQuery{PluralEntity}Response`
+- Fields use `snake_case` (proto convention), mapped case-insensitively to C# `PascalCase` properties
+
+### Field Mapping
+C# property names must match proto field names (case-insensitive):
+
+| C# Property   | Proto Field     |
+|---------------|-----------------|
+| `UserId`      | `user_id`       |
+| `Name`        | `name`          |
+| `EmailAddress`| `email_address` |
+| `OrderItems`  | `order_items`   |
+
+### Type Mapping
+| C#          | Proto        |
+|-------------|-------------|
+| `int`       | `int32`     |
+| `long`      | `int64`     |
+| `string`    | `string`    |
+| `bool`      | `bool`      |
+| `double`    | `double`    |
+| `float`     | `float`     |
+| `List<T>`   | `repeated T`|
+| complex type| `message`   |
+
+### Dynamic Query Messages (standard, reuse across entities)
+```protobuf
+message DynamicQueryFilter {
+  string path = 1;
+  int32 type = 2;       // PoweredSoft.DynamicQuery.Core.FilterType
+  string value = 3;
+  repeated DynamicQueryFilter and = 4;
+  repeated DynamicQueryFilter or = 5;
+}
+
+message DynamicQuerySort {
+  string path = 1;
+  bool ascending = 2;
+}
+
+message DynamicQueryGroup {
+  string path = 1;
+}
+
+message DynamicQueryAggregate {
+  string path = 1;
+  int32 type = 2;       // PoweredSoft.DynamicQuery.Core.AggregateType
+}
+```
+
+## Source Generator Behavior
+
+The generator in `Svrnty.CQRS.Grpc.Generators` auto-creates:
+- `CommandServiceImpl` — implements `CommandService.CommandServiceBase`
+- `QueryServiceImpl` — implements `QueryService.QueryServiceBase`
+- `DynamicQueryServiceImpl` — implements `DynamicQueryService.DynamicQueryServiceBase`
+- `GrpcServiceRegistration` — auto-registration code
+
+Generated implementations handle:
+1. Request-to-POCO property mapping
+2. Validator invocation (if registered) with Google Rich Error Model errors
+3. Handler invocation with proper `CancellationToken`
+4. DI scope management via `IServiceScopeFactory`
+
+## Validation in gRPC
+
+Validation errors return `google.rpc.Status` with `BadRequest` detail containing `FieldViolations`. This is automatic — do not manually validate in handlers.
+
+## Registration
+
+```csharp
+builder.Services.AddSvrntyCqrs(cqrs =>
+{
+    cqrs.AddGrpc(grpc => grpc.EnableReflection()); // reflection for grpcurl/grpcui
+});
+```

.claude/rules/validation.md

@@ -0,0 +1,60 @@
+---
+paths:
+  - "*Validator*.cs"
+  - "*Validation*"
+---
+
+# FluentValidation Integration
+
+## Validator Pattern
+
+Validators live in the **same file** as their command/query, named `{CommandName}Validator`:
+
+```csharp
+public class PlaceOrderCommandValidator : AbstractValidator<PlaceOrderCommand>
+{
+    public PlaceOrderCommandValidator()
+    {
+        RuleFor(x => x.CustomerId)
+            .NotEmpty()
+            .WithMessage("Customer is required");
+
+        RuleFor(x => x.Items)
+            .NotEmpty()
+            .WithMessage("At least one item is required");
+    }
+}
+```
+
+## Registration
+
+Validators are registered alongside their handler using the FluentValidation overloads:
+
+```csharp
+// Command without result + validator
+services.AddCommand<DeactivateAccountCommand, DeactivateAccountCommandHandler, DeactivateAccountCommandValidator>();
+
+// Command with result + validator
+services.AddCommand<PlaceOrderCommand, int, PlaceOrderCommandHandler, PlaceOrderCommandValidator>();
+
+// Query + validator
+services.AddQuery<FetchOrderByIdQuery, Order, FetchOrderByIdQueryHandler, FetchOrderByIdQueryValidator>();
+```
+
+These come from `Svrnty.CQRS.FluentValidation.ServiceCollectionExtensions` — they call the base `AddCommand`/`AddQuery` then register `IValidator<T>`.
+
+## Error Formats by Protocol
+
+The framework handles validation execution automatically. Errors are returned as:
+
+- **HTTP (Minimal API)**: RFC 7807 Problem Details — `400 Bad Request` with structured error body
+- **gRPC**: Google Rich Error Model — `google.rpc.Status` with `BadRequest` detail containing `FieldViolations`
+
+You do NOT need to manually invoke validation in handlers. The endpoint layer (Minimal API or gRPC source-generated service) handles it.
+
+## Rules
+
+- Inherit from `AbstractValidator<T>`, not `IValidator<T>` directly
+- Define all rules in the constructor
+- Always include `.WithMessage()` for user-facing error messages
+- Validator constructor can inject services for async/database validation

.claude/settings.json

@@ -0,0 +1,79 @@
+{
+  "permissions": {
+    "allow": [
+      "Bash(dotnet build:*)",
+      "Bash(dotnet clean:*)",
+      "Bash(dotnet restore:*)",
+      "Bash(dotnet run:*)",
+      "Bash(dotnet test:*)",
+      "Bash(dotnet format:*)",
+      "Bash(dotnet add:*)",
+      "Bash(dotnet remove:*)",
+      "Bash(dotnet sln:*)",
+      "Bash(dotnet --list-sdks:*)",
+      "Bash(dotnet tool install:*)",
+      "Bash(dotnet ef:*)",
+      "Bash(grpcurl:*)",
+      "Bash(protogen:*)",
+      "Bash(mkdir:*)",
+      "Bash(ls:*)",
+      "Bash(git status:*)",
+      "Bash(git log:*)",
+      "Bash(git diff:*)",
+      "Bash(git branch:*)",
+      "Bash(git stash:*)",
+      "Bash(git add:*)",
+      "Bash(git checkout:*)",
+      "WebSearch",
+      "WebFetch(domain:learn.microsoft.com)",
+      "WebFetch(domain:github.com)",
+      "WebFetch(domain:www.nuget.org)",
+      "WebFetch(domain:stackoverflow.com)"
+    ],
+    "ask": [
+      "Bash(dotnet publish:*)",
+      "Bash(dotnet pack:*)",
+      "Bash(git push:*)",
+      "Bash(git commit:*)"
+    ]
+  },
+  "hooks": {
+    "PostToolUse": [
+      {
+        "matcher": "Edit|Write",
+        "hooks": [
+          {
+            "type": "command",
+            "command": "bash -c 'INPUT=$(cat); FILE=$(echo \"$INPUT\" | jq -r \".tool_input.file_path // empty\"); if [[ -n \"$FILE\" && \"$FILE\" == *.cs ]]; then dotnet format --include \"$FILE\" --no-restore --diagnostics IDE0005 IDE0055 IDE0161 2>/dev/null || true; fi'",
+            "timeout": 15,
+            "statusMessage": "Formatting..."
+          }
+        ]
+      },
+      {
+        "matcher": "Edit|Write",
+        "hooks": [
+          {
+            "type": "command",
+            "command": "bash -c 'INPUT=$(cat); FILE=$(echo \"$INPUT\" | jq -r \".tool_input.file_path // empty\"); if [[ -n \"$FILE\" && \"$FILE\" == *.proto ]]; then dotnet build --no-restore 2>&1 | grep -E \"(error|warning)\" | head -10; fi'",
+            "timeout": 30,
+            "statusMessage": "Validating proto..."
+          }
+        ]
+      }
+    ],
+    "Stop": [
+      {
+        "matcher": "",
+        "hooks": [
+          {
+            "type": "command",
+            "command": "bash -c 'BUILD=$(dotnet build --no-restore 2>&1); if echo \"$BUILD\" | grep -q \"Build FAILED\"; then echo \"BUILD FAILED — errors below:\" >&2; echo \"$BUILD\" | grep -E \"error CS\" >&2; exit 2; fi'",
+            "timeout": 60,
+            "statusMessage": "Verifying build..."
+          }
+        ]
+      }
+    ]
+  }
+}

.claude/skills/add-command/SKILL.md

@@ -0,0 +1,103 @@
+---
+name: add-command
+description: Scaffold a new CQRS command with handler, validator, and DI registration. Use when the user wants to add a new command to a project.
+argument-hint: <description of the command in natural language>
+---
+
+# Add Command
+
+Scaffold a new command based on: $ARGUMENTS
+
+## Instructions
+
+### 1. Determine the command name
+
+The name must express **domain intent**, not CRUD. If the user's description sounds like CRUD, translate it:
+- "create a user" → `RegisterUserCommand`
+- "update the order status" → contextual: `ShipOrderCommand`, `CancelOrderCommand`, `ApproveOrderCommand`
+- "delete an account" → `DeactivateAccountCommand` or `CloseAccountCommand`
+
+Ask the user to clarify if the intent is ambiguous (e.g., "update order" could mean many things).
+
+### 2. Determine the feature folder
+
+Place the file in the appropriate feature folder: `Features/{DomainArea}/`
+If the folder doesn't exist, create it. If the project doesn't use `Features/` yet, check the existing structure and follow the same pattern.
+
+### 3. Create the file
+
+Create a single file `Features/{DomainArea}/{CommandName}Command.cs` containing all three classes:
+
+```csharp
+using FluentValidation;
+using Svrnty.CQRS.Abstractions;
+
+namespace {ProjectNamespace}.Features.{DomainArea};
+
+// 1. Command POCO — record type, properties with defaults
+public record {CommandName}Command
+{
+    // Properties based on user description
+    // Strings default to string.Empty, collections to []
+}
+
+// 2. Validator — rules in constructor, always include .WithMessage()
+public class {CommandName}CommandValidator : AbstractValidator<{CommandName}Command>
+{
+    public {CommandName}CommandValidator()
+    {
+        // Validation rules based on command properties
+    }
+}
+
+// 3. Handler — always async with CancellationToken
+public class {CommandName}CommandHandler : ICommandHandler<{CommandName}Command, {ResultType}>
+{
+    public Task<{ResultType}> HandleAsync({CommandName}Command command, CancellationToken cancellationToken = default)
+    {
+        throw new NotImplementedException();
+    }
+}
+```
+
+If the command has **no return value**, use `ICommandHandler<{CommandName}Command>` (single generic param) with `Task HandleAsync(...)`.
+
+### 4. Register in DI
+
+Find the project's service registration (typically `Program.cs` or a dedicated registration method) and add:
+
+```csharp
+// With validator (preferred)
+builder.Services.AddCommand<{CommandName}Command, {ResultType}, {CommandName}CommandHandler, {CommandName}CommandValidator>();
+
+// Without validator
+builder.Services.AddCommand<{CommandName}Command, {ResultType}, {CommandName}CommandHandler>();
+
+// No return value + validator
+builder.Services.AddCommand<{CommandName}Command, {CommandName}CommandHandler, {CommandName}CommandValidator>();
+```
+
+Ensure the `using Svrnty.CQRS.FluentValidation;` namespace is imported if using the validator overload.
+
+### 5. Proto message (if project uses gRPC)
+
+If the project has a `Protos/` directory, add the corresponding proto message:
+
+```protobuf
+// In the CommandService definition
+rpc {CommandName} ({CommandName}CommandRequest) returns ({CommandName}CommandResponse);
+
+// Request message
+message {CommandName}CommandRequest {
+  // fields matching command properties, snake_case, numbered sequentially
+}
+
+// Response message
+message {CommandName}CommandResponse {
+  {result_type} result = 1;  // omit if command has no return value
+}
+```
+
+### 6. Summary
+
+After creating everything, list what was created and where.

.claude/skills/add-dynamic-query/SKILL.md

@@ -0,0 +1,125 @@
+---
+name: add-dynamic-query
+description: Scaffold a dynamic query with IQueryableProviderOverride for automatic pagination, filtering, and sorting. This is the DEFAULT choice for any list/collection query.
+argument-hint: <entity name and optional description>
+---
+
+# Add Dynamic Query
+
+Scaffold a dynamic query based on: $ARGUMENTS
+
+**This is the default query pattern.** It gives pagination, filtering, sorting, grouping, and aggregation for free.
+
+## Instructions
+
+### 1. Identify the entity
+
+Determine the source entity type from the user's description. If the project uses a DAL with EF Core, the entity should already exist in the DbContext.
+
+### 2. Determine the feature folder
+
+Place the file in: `Features/{DomainArea}/`
+
+### 3. Create the queryable provider
+
+Create `Features/{DomainArea}/{Entity}QueryableProvider.cs`:
+
+```csharp
+using Svrnty.CQRS.DynamicQuery.Abstractions;
+
+namespace {ProjectNamespace}.Features.{DomainArea};
+
+public class {Entity}QueryableProvider : IQueryableProviderOverride<{Entity}>
+{
+    private readonly {DbContextType} _db;
+    public {Entity}QueryableProvider({DbContextType} db) => _db = db;
+
+    public Task<IQueryable<{Entity}>> GetQueryableAsync(object query, CancellationToken cancellationToken = default)
+        => Task.FromResult(_db.{EntityPlural}.AsQueryable());
+}
+```
+
+If the entity needs a DTO projection (different shape for the API), note this for the registration step.
+
+### 4. Create alter queryable service (if needed)
+
+If the entity needs security filtering, tenant isolation, or default ordering, create `Features/{DomainArea}/{Entity}AlterQueryable.cs`:
+
+```csharp
+using Svrnty.CQRS.DynamicQuery.Abstractions;
+
+namespace {ProjectNamespace}.Features.{DomainArea};
+
+public class {Entity}AlterQueryable : IAlterQueryableService<{Entity}, {EntityOrDto}>
+{
+    public Task<IQueryable<{Entity}>> AlterQueryableAsync(
+        IQueryable<{Entity}> query,
+        IDynamicQuery dynamicQuery,
+        CancellationToken cancellationToken = default)
+    {
+        // Add default ordering, security filters, etc.
+        return Task.FromResult(query.OrderByDescending(x => x.CreatedAt));
+    }
+}
+```
+
+### 5. Register in DI
+
+Find the project's service registration and add:
+
+```csharp
+// Basic — entity returned as-is
+builder.Services.AddDynamicQueryWithProvider<{Entity}, {Entity}QueryableProvider>();
+
+// With DTO projection — entity mapped to DTO
+builder.Services.AddDynamicQueryWithProvider<{Entity}, {EntityDto}, {Entity}QueryableProvider>();
+
+// With alter service (add after provider registration)
+builder.Services.AddAlterQueryable<{Entity}, {EntityOrDto}, {Entity}AlterQueryable>();
+```
+
+### 6. Ensure dynamic query dependencies are registered
+
+Check that these are registered (typically once per project, before `AddSvrntyCqrs`):
+
+```csharp
+builder.Services.AddTransient<IAsyncQueryableService, SimpleAsyncQueryableService>();
+builder.Services.AddTransient<IQueryHandlerAsync, QueryHandlerAsync>();
+```
+
+If they're already present, don't add duplicates.
+
+### 7. Proto message (if project uses gRPC)
+
+```protobuf
+// In the DynamicQueryService definition
+rpc Query{EntityPlural} (DynamicQuery{EntityPlural}Request) returns (DynamicQuery{EntityPlural}Response);
+
+// Entity message (if not already defined)
+message {Entity} {
+  // fields matching entity properties
+}
+
+// Request — uses standard dynamic query fields
+message DynamicQuery{EntityPlural}Request {
+  int32 page = 1;
+  int32 page_size = 2;
+  repeated DynamicQueryFilter filters = 3;
+  repeated DynamicQuerySort sorts = 4;
+  repeated DynamicQueryGroup groups = 5;
+  repeated DynamicQueryAggregate aggregates = 6;
+}
+
+// Response
+message DynamicQuery{EntityPlural}Response {
+  repeated {Entity} data = 1;
+  int64 total_records = 2;
+  int32 number_of_pages = 3;
+}
+```
+
+The standard `DynamicQueryFilter`, `DynamicQuerySort`, `DynamicQueryGroup`, and `DynamicQueryAggregate` messages should already be defined — reuse them.
+
+### 8. Summary
+
+After creating everything, list what was created and where.

.claude/skills/add-query/SKILL.md

@@ -0,0 +1,86 @@
+---
+name: add-query
+description: Scaffold a new regular CQRS query with handler and DI registration. Use ONLY for single-entity lookups or non-queryable results. For list/collection queries, use /add-dynamic-query instead.
+argument-hint: <description of the query in natural language>
+---
+
+# Add Query
+
+Scaffold a new regular query based on: $ARGUMENTS
+
+## Important: Is This the Right Skill?
+
+**This skill is for the rare case.** Most queries should be dynamic queries (`/add-dynamic-query`).
+
+Only use this for:
+- Single entity by ID (e.g., `FetchOrderByIdQuery`)
+- Non-entity results (e.g., `GetDashboardStatsQuery`, `CheckAvailabilityQuery`)
+- Complex aggregation not expressible as IQueryable
+
+If the user is asking for a list/collection query with filtering, sorting, or pagination → suggest `/add-dynamic-query` instead.
+
+## Instructions
+
+### 1. Determine the query name
+
+Use descriptive, domain-oriented names:
+- `FetchOrderByIdQuery` — fetching a single entity
+- `GetSystemHealthQuery` — non-entity result
+- `CheckInventoryAvailabilityQuery` — domain-specific check
+
+### 2. Determine the feature folder
+
+Place the file in: `Features/{DomainArea}/`
+
+### 3. Create the file
+
+Create `Features/{DomainArea}/{QueryName}Query.cs`:
+
+```csharp
+using Svrnty.CQRS.Abstractions;
+
+namespace {ProjectNamespace}.Features.{DomainArea};
+
+// 1. Query POCO
+public record {QueryName}Query
+{
+    // Parameters — e.g., Id for lookups
+}
+
+// 2. Handler
+public class {QueryName}QueryHandler : IQueryHandler<{QueryName}Query, {ResultType}>
+{
+    public Task<{ResultType}> HandleAsync({QueryName}Query query, CancellationToken cancellationToken = default)
+    {
+        throw new NotImplementedException();
+    }
+}
+```
+
+### 4. Register in DI
+
+```csharp
+builder.Services.AddQuery<{QueryName}Query, {ResultType}, {QueryName}QueryHandler>();
+
+// With validator (if needed)
+builder.Services.AddQuery<{QueryName}Query, {ResultType}, {QueryName}QueryHandler, {QueryName}QueryValidator>();
+```
+
+### 5. Proto message (if project uses gRPC)
+
+```protobuf
+// In the QueryService definition
+rpc {QueryName} ({QueryName}QueryRequest) returns ({QueryName}QueryResponse);
+
+message {QueryName}QueryRequest {
+  // fields matching query properties
+}
+
+message {QueryName}QueryResponse {
+  {ResultMessage} result = 1;
+}
+```
+
+### 6. Summary
+
+After creating everything, list what was created and where.

.editorconfig

@@ -0,0 +1,96 @@
+root = true
+
+[*]
+indent_style = space
+indent_size = 4
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true
+
+[*.{csproj,props,targets,xml}]
+indent_size = 2
+
+[*.{json,yml,yaml}]
+indent_size = 2
+
+[*.proto]
+indent_size = 2
+
+[*.cs]
+# Namespace
+csharp_style_namespace_declarations = file_scoped:warning
+
+# Braces — Allman style
+csharp_new_line_before_open_brace = all
+
+# Usings
+dotnet_sort_system_directives_first = true
+csharp_using_directive_placement = outside_namespace:warning
+
+# var preferences — use var when type is apparent
+csharp_style_var_for_built_in_types = true:suggestion
+csharp_style_var_when_type_is_apparent = true:suggestion
+csharp_style_var_elsewhere = true:suggestion
+
+# Expression bodies — prefer for simple members
+csharp_style_expression_bodied_methods = when_on_single_line:suggestion
+csharp_style_expression_bodied_constructors = false:suggestion
+csharp_style_expression_bodied_operators = when_on_single_line:suggestion
+csharp_style_expression_bodied_properties = true:suggestion
+csharp_style_expression_bodied_accessors = true:suggestion
+csharp_style_expression_bodied_lambdas = true:suggestion
+
+# Pattern matching
+csharp_style_pattern_matching_over_is_with_cast_check = true:suggestion
+csharp_style_pattern_matching_over_as_with_null_check = true:suggestion
+
+# Null checking
+csharp_style_throw_expression = true:suggestion
+csharp_style_conditional_delegate_call = true:suggestion
+
+# Modifier preferences — exclude interface members (netstandard2.1 compat)
+dotnet_style_require_accessibility_modifiers = for_non_interface_members:warning
+
+# Field naming — _camelCase for private fields
+dotnet_naming_rule.private_fields_should_be_camel_case.severity = warning
+dotnet_naming_rule.private_fields_should_be_camel_case.symbols = private_fields
+dotnet_naming_rule.private_fields_should_be_camel_case.style = camel_case_underscore
+
+dotnet_naming_symbols.private_fields.applicable_kinds = field
+dotnet_naming_symbols.private_fields.applicable_accessibilities = private, protected, private_protected
+dotnet_naming_symbols.private_fields.required_modifiers =
+
+dotnet_naming_style.camel_case_underscore.required_prefix = _
+dotnet_naming_style.camel_case_underscore.capitalization = camel_case
+
+# Constants — PascalCase
+dotnet_naming_rule.constants_should_be_pascal_case.severity = suggestion
+dotnet_naming_rule.constants_should_be_pascal_case.symbols = constants
+dotnet_naming_rule.constants_should_be_pascal_case.style = pascal_case
+
+dotnet_naming_symbols.constants.applicable_kinds = field
+dotnet_naming_symbols.constants.required_modifiers = const
+
+dotnet_naming_style.pascal_case.capitalization = pascal_case
+
+# Interfaces — I prefix
+dotnet_naming_rule.interfaces_should_begin_with_i.severity = warning
+dotnet_naming_rule.interfaces_should_begin_with_i.symbols = interfaces
+dotnet_naming_rule.interfaces_should_begin_with_i.style = begins_with_i
+
+dotnet_naming_symbols.interfaces.applicable_kinds = interface
+
+dotnet_naming_style.begins_with_i.required_prefix = I
+dotnet_naming_style.begins_with_i.capitalization = pascal_case
+
+# Async methods — Async suffix
+dotnet_naming_rule.async_methods_should_end_with_async.severity = suggestion
+dotnet_naming_rule.async_methods_should_end_with_async.symbols = async_methods
+dotnet_naming_rule.async_methods_should_end_with_async.style = ends_with_async
+
+dotnet_naming_symbols.async_methods.applicable_kinds = method
+dotnet_naming_symbols.async_methods.required_modifiers = async
+
+dotnet_naming_style.ends_with_async.required_suffix = Async
+dotnet_naming_style.ends_with_async.capitalization = pascal_case

CLAUDE.md

@@ -2,6 +2,9 @@
 
 This file provides guidance to AI agents when working with code in this repository.
 
+For domain-specific patterns (commands, queries, validation, gRPC, dynamic queries), see `.claude/rules/`.
+For scaffolding commands, see `.claude/skills/` (`/add-command`, `/add-query`, `/add-dynamic-query`).
+
 ## Project Overview
 
 This is Svrnty.CQRS, a modern implementation of Command Query Responsibility Segregation (CQRS) for .NET 10. It was forked from PoweredSoft.CQRS and provides:
@@ -11,11 +14,10 @@ This is Svrnty.CQRS, a modern implementation of Command Query Responsibility Seg
 - Automatic gRPC endpoint generation with source generators and Google Rich Error Model validation
 - Dynamic query capabilities (filtering, sorting, grouping, aggregation)
 - FluentValidation support with RFC 7807 Problem Details (HTTP) and Google Rich Error Model (gRPC)
-- AOT (Ahead-of-Time) compilation compatibility for core packages (where dependencies allow)
 
 ## Solution Structure
 
-The solution contains 11 projects organized by responsibility (10 packages + 1 sample project):
+The solution contains projects organized by responsibility:
 
 **Abstractions (interfaces and contracts only):**
 - `Svrnty.CQRS.Abstractions` - Core interfaces (ICommandHandler, IQueryHandler, discovery contracts)
@@ -24,81 +26,42 @@ The solution contains 11 projects organized by responsibility (10 packages + 1 s
 
 **Implementation:**
 - `Svrnty.CQRS` - Core discovery and registration logic
-- `Svrnty.CQRS.MinimalApi` - Minimal API endpoint mapping for commands/queries (recommended for HTTP)
+- `Svrnty.CQRS.MinimalApi` - Minimal API endpoint mapping for commands/queries
 - `Svrnty.CQRS.DynamicQuery` - PoweredSoft.DynamicQuery integration for advanced filtering
 - `Svrnty.CQRS.DynamicQuery.MinimalApi` - Minimal API endpoint mapping for dynamic queries
 - `Svrnty.CQRS.FluentValidation` - Validation integration helpers
 - `Svrnty.CQRS.Grpc` - gRPC service implementation support
 - `Svrnty.CQRS.Grpc.Generators` - Source generator for .proto files and gRPC service implementations
 
-**Sample Projects:**
+**Sample:**
-- `Svrnty.Sample` - Comprehensive demo project showcasing both HTTP and gRPC endpoints
+- `Svrnty.Sample` - Demo project showcasing both HTTP and gRPC endpoints
 
-**Key Design Principle:** Abstractions projects contain ONLY interfaces/attributes with minimal dependencies. Implementation projects depend on abstractions. This allows consumers to reference abstractions without pulling in heavy implementation dependencies.
+**Key Design Principle:** Abstractions projects contain ONLY interfaces/attributes with minimal dependencies. Implementation projects depend on abstractions.
 
 ## Build Commands
 
 ```bash
-# Restore dependencies
+dotnet restore            # Restore dependencies
-dotnet restore
+dotnet build              # Build entire solution
-
+dotnet build -c Release   # Build in Release mode
-# Build entire solution
+dotnet pack -c Release -o ./artifacts -p:Version=1.0.0  # Create NuGet packages
-dotnet build
-
-# Build in Release mode
-dotnet build -c Release
-
-# Create NuGet packages (with version)
-dotnet pack -c Release -o ./artifacts -p:Version=1.0.0
-
-# Build specific project
-dotnet build Svrnty.CQRS/Svrnty.CQRS.csproj
 ```
 
 ## Testing
 
-This repository does not currently contain test projects. When adding tests:
+No test projects currently exist. When adding tests:
-- Place them in a `tests/` directory or alongside source projects
+- Place them in a `tests/` directory
 - Name them with `.Tests` suffix (e.g., `Svrnty.CQRS.Tests`)
 
 ## Architecture
 
-### Core CQRS Pattern
-
-The framework uses handler interfaces that follow this pattern:
-
-```csharp
-// Command with no result
-ICommandHandler<TCommand>
-  Task HandleAsync(TCommand command, CancellationToken cancellationToken = default)
-
-// Command with result
-ICommandHandler<TCommand, TResult>
-  Task<TResult> HandleAsync(TCommand command, CancellationToken cancellationToken = default)
-
-// Query (always returns result)
-IQueryHandler<TQuery, TResult>
-  Task<TResult> HandleAsync(TQuery query, CancellationToken cancellationToken = default)
-```
-
 ### Metadata-Driven Discovery
 
 The framework uses a **metadata pattern** for runtime discovery:
 
-1. When you register a handler using `services.AddCommand<TCommand, THandler>()`, it:
+1. `services.AddCommand<TCommand, THandler>()` registers the handler in DI and creates `ICommandMeta` metadata as a singleton
-   - Registers the handler in DI as `ICommandHandler<TCommand, THandler>`
+2. Discovery services (`ICommandDiscovery`, `IQueryDiscovery`) query all registered metadata from DI
-   - Creates metadata (`ICommandMeta`) describing the command type, handler type, and result type
+3. Endpoint mapping (HTTP and gRPC) uses discovery to dynamically generate endpoints at startup
-   - Stores metadata as singleton in DI
-
-2. Discovery services (`ICommandDiscovery`, `IQueryDiscovery`) implemented in `Svrnty.CQRS`:
-   - Query all registered metadata from DI container
-   - Provide lookup methods: `GetCommand(string name)`, `GetCommands()`, etc.
-
-3. Endpoint mapping (HTTP and gRPC) uses discovery to:
-   - Enumerate all registered commands/queries
-   - Dynamically generate endpoints at application startup
-   - Apply naming conventions (convert to lowerCamelCase)
-   - Generate gRPC service implementations via source generators
 
 **Key Files:**
 - `Svrnty.CQRS.Abstractions/Discovery/` - Metadata interfaces
@@ -107,307 +70,77 @@ The framework uses a **metadata pattern** for runtime discovery:
 - `Svrnty.CQRS.DynamicQuery.MinimalApi/EndpointRouteBuilderExtensions.cs` - Dynamic query endpoint generation
 - `Svrnty.CQRS.Grpc.Generators/` - gRPC service generation via source generators
 
-### Integration Options
+### Integration
 
-There are two primary integration options for exposing commands and queries:
+Commands and queries can be exposed via HTTP (Minimal API), gRPC, or both simultaneously. The fluent configuration API handles all wiring:
-
-#### Option 1: gRPC (Recommended for performance-critical scenarios)
-
-The **Svrnty.CQRS.Grpc** package with **Svrnty.CQRS.Grpc.Generators** source generator provides high-performance gRPC endpoints:
-
-**Registration:**
-```csharp
-var builder = WebApplication.CreateBuilder(args);
-
-// Register CQRS services
-builder.Services.AddSvrntyCQRS();
-builder.Services.AddDefaultCommandDiscovery();
-builder.Services.AddDefaultQueryDiscovery();
-
-// Add your commands and queries
-builder.Services.AddCommand<AddUserCommand, int, AddUserCommandHandler>();
-builder.Services.AddCommand<RemoveUserCommand, RemoveUserCommandHandler>();
-
-// Add gRPC support
-builder.Services.AddGrpc();
-
-var app = builder.Build();
-
-// Map auto-generated gRPC service implementations
-app.MapGrpcService<CommandServiceImpl>();
-app.MapGrpcService<QueryServiceImpl>();
-
-// Enable gRPC reflection for tools like grpcurl
-app.MapGrpcReflectionService();
-
-app.Run();
-```
-
-**How It Works:**
-1. Define `.proto` files in `Protos/` directory with your commands/queries as messages
-2. Source generator automatically creates `CommandServiceImpl` and `QueryServiceImpl` implementations
-3. Property names in C# commands must match proto field names (case-insensitive)
-4. FluentValidation is automatically integrated with **Google Rich Error Model** for structured validation errors
-5. Validation errors return `google.rpc.Status` with `BadRequest` containing `FieldViolations`
-
-**Features:**
-- High-performance binary protocol
-- Automatic service implementation generation at compile time
-- Google Rich Error Model for structured validation errors
-- Full FluentValidation integration
-- gRPC reflection support for development tools
-- Suitable for microservices, internal APIs, and low-latency scenarios
-
-**Key Files:**
-- `Svrnty.CQRS.Grpc/` - Runtime support for gRPC services
-- `Svrnty.CQRS.Grpc.Generators/` - Source generator for service implementations
-
-#### Option 2: HTTP via Minimal API (Recommended for web/browser scenarios)
-
-The **Svrnty.CQRS.MinimalApi** package provides HTTP endpoints for CQRS commands and queries:
-
-**Registration:**
-```csharp
-var builder = WebApplication.CreateBuilder(args);
-
-// Register CQRS services
-builder.Services.AddSvrntyCQRS();
-builder.Services.AddDefaultCommandDiscovery();
-builder.Services.AddDefaultQueryDiscovery();
-
-// Add your commands and queries
-builder.Services.AddCommand<CreatePersonCommand, CreatePersonCommandHandler>();
-builder.Services.AddQuery<PersonQuery, IQueryable<Person>, PersonQueryHandler>();
-
-// Add Swagger (optional)
-builder.Services.AddEndpointsApiExplorer();
-builder.Services.AddSwaggerGen();
-
-var app = builder.Build();
-
-// Map endpoints (this creates routes automatically)
-app.MapSvrntyCommands();   // Maps all commands to POST /api/command/{name}
-app.MapSvrntyQueries();    // Maps all queries to POST/GET /api/query/{name}
-
-app.Run();
-```
-
-**How It Works:**
-1. Extension methods iterate through `ICommandDiscovery` and `IQueryDiscovery`
-2. For each command/query, creates Minimal API endpoints using `MapPost()`/`MapGet()`
-3. Applies naming conventions (lowerCamelCase)
-4. Respects `[CommandControllerIgnore]` and `[QueryControllerIgnore]` attributes
-5. Integrates with `ICommandAuthorizationService` and `IQueryAuthorizationService`
-6. Supports OpenAPI/Swagger documentation
-
-**Features:**
-- Queries support both POST (with JSON body) and GET (with query string parameters)
-- Commands only support POST with JSON body
-- Authorization via authorization services (returns 401/403 status codes)
-- Customizable route prefixes: `MapSvrntyCommands("my-prefix")`
-- Automatic OpenAPI tags: "Commands" and "Queries"
-- RFC 7807 Problem Details for validation errors
-- Full Swagger/OpenAPI support
-
-**Key Files:**
-- `Svrnty.CQRS.MinimalApi/EndpointRouteBuilderExtensions.cs` - Main implementation
-
-#### Option 3: Both gRPC and HTTP (Dual Protocol Support)
-
-You can enable both protocols simultaneously, allowing clients to choose their preferred protocol:
 
 ```csharp
-var builder = WebApplication.CreateBuilder(args);
+builder.Services.AddSvrntyCqrs(cqrs =>
+{
+    cqrs.AddGrpc(grpc => grpc.EnableReflection());
+    cqrs.AddMinimalApi();
+});
 
-// Register CQRS services
+app.UseSvrntyCqrs(); // Maps all endpoints
-builder.Services.AddSvrntyCQRS();
-builder.Services.AddDefaultCommandDiscovery();
-builder.Services.AddDefaultQueryDiscovery();
-
-// Add commands and queries
-AddCommands(builder.Services);
-AddQueries(builder.Services);
-
-// Add both gRPC and HTTP support
-builder.Services.AddGrpc();
-builder.Services.AddEndpointsApiExplorer();
-builder.Services.AddSwaggerGen();
-
-var app = builder.Build();
-
-// Map both gRPC and HTTP endpoints
-app.MapGrpcService<CommandServiceImpl>();
-app.MapGrpcService<QueryServiceImpl>();
-app.MapGrpcReflectionService();
-
-app.MapSvrntyCommands();
-app.MapSvrntyQueries();
-
-app.Run();
 ```
 
-**Benefits:**
+See `Svrnty.Sample/Program.cs` for a complete working example.
-- Single codebase supports multiple protocols
-- gRPC for high-performance, low-latency scenarios (microservices, internal APIs)
-- HTTP for web browsers, legacy clients, and public APIs
-- Same commands, queries, and validation logic for both protocols
-- Swagger UI available for HTTP endpoints, gRPC reflection for gRPC clients
-
-### Dynamic Query System
-
-Dynamic queries provide OData-like filtering capabilities:
-
-**Core Components:**
-- `IDynamicQuery<TSource, TDestination>` - Interface with GetFilters(), GetSorts(), GetGroups(), GetAggregates()
-- `IQueryableProvider<TSource>` - Provides base IQueryable to query against
-- `IAlterQueryableService<TSource, TDestination>` - Middleware to modify queries (e.g., security filters)
-- `DynamicQueryHandler<TSource, TDestination>` - Executes queries using PoweredSoft.DynamicQuery
-
-**Request Flow:**
-1. HTTP request with filters/sorts/aggregates
-2. Minimal API endpoint receives request
-3. DynamicQueryHandler gets base queryable from IQueryableProvider
-4. Applies alterations from all registered IAlterQueryableService instances
-5. Builds PoweredSoft query criteria
-6. Executes and returns IQueryExecutionResult
-
-**Registration Example:**
-```csharp
-// Register dynamic query
-services.AddDynamicQuery<Person, PersonDto>()
-    .AddDynamicQueryWithProvider<Person, PersonQueryableProvider>()
-    .AddAlterQueryable<Person, PersonDto, SecurityFilter>();
-
-// Map dynamic query endpoints
-app.MapSvrntyDynamicQueries();  // Creates POST/GET /api/query/{queryName} endpoints
-```
-
-**Key Files:**
-- `Svrnty.CQRS.DynamicQuery/DynamicQueryHandler.cs` - Query execution logic
-- `Svrnty.CQRS.DynamicQuery.MinimalApi/EndpointRouteBuilderExtensions.cs` - HTTP endpoint mapping
 
 ## Package Configuration
 
-All projects target .NET 10.0 and use C# 14, sharing common configuration:
+- **Target Framework**: `net10.0` (except DynamicQuery.Abstractions: `netstandard2.1;net10.0`)
-
-- **Target Framework**: `net10.0` (except DynamicQuery.Abstractions which multi-targets `netstandard2.1;net10.0`)
 - **Language Version**: C# 14
-- **IsAotCompatible**: Currently set but not enforced (many dependencies are not AOT-compatible yet)
-- **Symbols**: Portable debug symbols with source, published as `.snupkg`
-- **NuGet metadata**: Icon, README, license (MIT), and repository URL included in packages
 - **Authors**: David Lebee, Mathias Beaulieu-Duncan
 - **Repository**: https://git.openharbor.io/svrnty/dotnet-cqrs
 
-### Package Dependencies
+### Key Dependencies
 
-**Core Dependencies:**
 - **Microsoft.Extensions.DependencyInjection.Abstractions**: 10.0.0
 - **FluentValidation**: 11.11.0
 - **PoweredSoft.DynamicQuery**: 3.0.1
-- **Pluralize.NET**: 1.0.2
+- **Grpc.AspNetCore**: 2.68.0+
-
+- **Grpc.StatusProto**: 2.71.0+ (Rich Error Model)
-**gRPC Dependencies (for Svrnty.CQRS.Grpc):**
+- **Microsoft.CodeAnalysis.CSharp**: 5.0.0-2.final (source generators, targets netstandard2.0)
-- **Grpc.AspNetCore**: 2.68.0 or later
-- **Grpc.AspNetCore.Server.Reflection**: 2.71.0 or later (optional, for reflection)
-- **Grpc.StatusProto**: 2.71.0 or later (for Rich Error Model validation)
-- **Grpc.Tools**: 2.76.0 or later (for .proto compilation)
-
-**Source Generator Dependencies (for Svrnty.CQRS.Grpc.Generators):**
-- **Microsoft.CodeAnalysis.CSharp**: 5.0.0-2.final
-- **Microsoft.CodeAnalysis.Analyzers**: 3.11.0
-- **Microsoft.Build.Utilities.Core**: 17.0.0
-- Targets: netstandard2.0 (for Roslyn compatibility)
 
 ## Publishing
 
-NuGet packages are published automatically via GitHub Actions when a release is created:
+NuGet packages publish automatically via GitHub Actions (`.github/workflows/publish-nugets.yml`) when a release is created. Tag becomes the version.
 
-**Workflow:** `.github/workflows/publish-nugets.yml`
-1. Triggered on release publication
-2. Extracts version from release tag
-3. Runs `dotnet pack -c Release -p:Version={tag}`
-4. Pushes to NuGet.org using `NUGET_API_KEY` secret
-
-**Manual publish:**
 ```bash
-# Create packages with specific version
+# Manual publish
 dotnet pack -c Release -o ./artifacts -p:Version=1.2.3
-
-# Push to NuGet
 dotnet nuget push ./artifacts/*.nupkg --source https://api.nuget.org/v3/index.json --api-key YOUR_KEY
 ```
 
 ## Development Workflow
 
-**Adding a New Command/Query Handler:**
+**Adding a New Feature to the Framework:**
-
-1. Create command/query POCO in consumer project
-2. Implement handler: `ICommandHandler<TCommand, TResult>`
-3. Register in DI: `services.AddCommand<CreatePersonCommand, CreatePersonCommandHandler>()`
-4. (Optional) Add validator: `services.AddTransient<IValidator<CreatePersonCommand>, Validator>()`
-5. Controller endpoint is automatically generated
-
-**Adding a New Feature to Framework:**
 
 1. Add interface to appropriate Abstractions project
 2. Implement in corresponding implementation project
 3. Update ServiceCollectionExtensions with registration method
-4. Ensure all projects maintain AOT compatibility (unless AspNetCore-specific)
+4. When extending discovery, create corresponding metadata classes (implement ICommandMeta/IQueryMeta)
 5. Update package version and release notes
 
-**Naming Conventions:**
-
-- Commands/Queries: Use `[CommandName]` or `[QueryName]` attribute for custom names
-- Default naming: Strips "Command"/"Query" suffix, converts to lowerCamelCase
-- Example: `CreatePersonCommand` -> `createPerson` endpoint
-
 ## C# 14 Language Features
 
-The project now uses C# 14, which introduces several new features. Be aware of these breaking changes:
+The project uses C# 14. Be aware of these reserved keywords:
-
+- **`field`**: Contextual keyword in property accessors for implicit backing fields
-**Potential Breaking Changes:**
+- **`extension`**: Reserved for extension containers; use `@extension` for identifiers
-- **`field` keyword**: New contextual keyword in property accessors for implicit backing fields
-- **`extension` keyword**: Reserved for extension containers; use `@extension` for identifiers
-- **`partial` return type**: Cannot use `partial` as return type without escaping
-- **Span<T> overload resolution**: New implicit conversions may select different overloads
-- **`scoped` as lambda modifier**: Always treated as modifier in lambda parameters
-
-**New Features Available:**
-- Extension members (static extension members and extension properties)
-- Implicit span conversions
-- Unbound generic types with `nameof`
-- Lambda parameter modifiers without type specification
-- Partial instance constructors and events
-- Null-conditional assignment (`?.=` and `?[]=`)
-
-The codebase currently compiles without warnings on C# 14.
 
 ## Important Implementation Notes
 
-1. **AOT Compatibility**: Currently not enforced. The `IsAotCompatible` property is set on some projects but many dependencies (including FluentValidation, PoweredSoft.DynamicQuery) are not AOT-compatible. Future work may address this.
+1. **Async Everywhere**: All handlers are async. Always support CancellationToken.
-
+2. **Generic Type Safety**: Framework relies heavily on generics. Maintain strong typing.
-2. **Async Everywhere**: All handlers are async. Always support CancellationToken.
+3. **Endpoint Mapping Timing**: Discovery services must be registered before calling `UseSvrntyCqrs()`.
-
+4. **AOT Compatibility**: `IsAotCompatible` is set but not enforced — many dependencies are not AOT-compatible.
-3. **Generic Type Safety**: Framework relies heavily on generics for compile-time safety. When adding features, maintain strong typing.
-
-4. **Metadata Pattern**: When extending discovery, always create corresponding metadata classes (implement ICommandMeta/IQueryMeta).
-
-5. **Endpoint Mapping Timing**: Endpoints are mapped at application startup. Discovery services must be registered before calling `MapSvrntyCommands()`/`MapSvrntyQueries()` or mapping gRPC services.
-
-6. **FluentValidation Integration**:
-   - For HTTP: Validation happens automatically in the Minimal API pipeline. Errors return RFC 7807 Problem Details.
-   - For gRPC: Validation happens automatically via source-generated services. Errors return Google Rich Error Model with structured FieldViolations.
-   - The framework REGISTERS validators in DI; actual validation execution is handled by the endpoint implementations.
-
-7. **DynamicQuery Interceptors**: Support up to 5 interceptors per query type. Interceptors modify PoweredSoft DynamicQuery behavior.
 
 ## Common Code Locations
 
 - Handler interfaces: `Svrnty.CQRS.Abstractions/ICommandHandler.cs`, `IQueryHandler.cs`
-- Discovery implementations: `Svrnty.CQRS/Discovery/`
+- Discovery: `Svrnty.CQRS/Discovery/`
 - Service registration: `*/ServiceCollectionExtensions.cs` in each project
-- HTTP endpoint mapping: `Svrnty.CQRS.MinimalApi/EndpointRouteBuilderExtensions.cs`
+- HTTP endpoints: `Svrnty.CQRS.MinimalApi/EndpointRouteBuilderExtensions.cs`
-- Dynamic query logic: `Svrnty.CQRS.DynamicQuery/DynamicQueryHandler.cs`
+- Dynamic queries: `Svrnty.CQRS.DynamicQuery/DynamicQueryHandler.cs`
-- Dynamic query endpoints: `Svrnty.CQRS.DynamicQuery.MinimalApi/EndpointRouteBuilderExtensions.cs`
+- gRPC generators: `Svrnty.CQRS.Grpc.Generators/`
-- gRPC support: `Svrnty.CQRS.Grpc/` runtime, `Svrnty.CQRS.Grpc.Generators/` source generators
+- Sample: `Svrnty.Sample/`
-- Sample application: `Svrnty.Sample/` - demonstrates both HTTP and gRPC integration

Svrnty.CQRS.Abstractions/Attributes/CommandNameAttribute.cs

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

Svrnty.CQRS.Abstractions/Attributes/QueryNameAttribute.cs

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

Svrnty.CQRS.Abstractions/Discovery/CommandMeta.cs

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

Svrnty.CQRS.Abstractions/Discovery/ICommandMeta.cs

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

Svrnty.CQRS.Abstractions/Discovery/IQueryDiscovery.cs

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

Svrnty.CQRS.Abstractions/Discovery/IQueryMeta.cs

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

Svrnty.CQRS.Abstractions/Discovery/QueryMeta.cs

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

Svrnty.CQRS.Abstractions/ICommandHandler.cs

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

Svrnty.CQRS.Abstractions/IQueryHandler.cs

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

Svrnty.CQRS.Abstractions/Security/AuthorizationResult.cs

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

Svrnty.CQRS.Abstractions/Security/ICommandAuthorizationService.cs

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

Svrnty.CQRS.Abstractions/Security/IQueryAuthorizationService.cs

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

Svrnty.CQRS.Abstractions/ServiceCollectionExtensions.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/DynamicQueryInterceptorProvider.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/IAlterQueryableService.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/IDynamicQuery.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/IDynamicQueryInterceptorProvider.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/IDynamicQueryParams.cs

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

Svrnty.CQRS.DynamicQuery.Abstractions/IQueryableProvider.cs

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

Svrnty.CQRS.DynamicQuery.MinimalApi/EndpointRouteBuilderExtensions.cs

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

Svrnty.CQRS.DynamicQuery/Discover/DynamicQueryMeta.cs

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

Svrnty.CQRS.DynamicQuery/DynamicQuery.cs

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

Svrnty.CQRS.DynamicQuery/DynamicQueryAggregate.cs

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

Svrnty.CQRS.DynamicQuery/DynamicQueryHandler.cs

@@ -1,23 +1,23 @@
-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;
+using PoweredSoft.DynamicQuery.Core;
+using Svrnty.CQRS.DynamicQuery.Abstractions;
 
 namespace Svrnty.CQRS.DynamicQuery;
 
 public class DynamicQueryHandler<TSource, TDestination>
-    : DynamicQueryHandlerBase<TSource, TDestination>, 
+    : DynamicQueryHandlerBase<TSource, TDestination>,
     Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination>, IQueryExecutionResult<TDestination>>
     where TSource : class
     where TDestination : class
 {
-    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, 
+    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync,
         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)
     {
     }
@@ -29,7 +29,7 @@ public class DynamicQueryHandler<TSource, TDestination>
 }
 
 public class DynamicQueryHandler<TSource, TDestination, TParams>
-    : DynamicQueryHandlerBase<TSource, TDestination>, 
+    : DynamicQueryHandlerBase<TSource, TDestination>,
     Svrnty.CQRS.Abstractions.IQueryHandler<IDynamicQuery<TSource, TDestination, TParams>, IQueryExecutionResult<TDestination>>
     where TSource : class
     where TDestination : class
@@ -37,10 +37,10 @@ public class DynamicQueryHandler<TSource, TDestination, TParams>
 {
     private readonly IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams;
 
-    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync, 
+    public DynamicQueryHandler(IQueryHandlerAsync queryHandlerAsync,
         IEnumerable<IQueryableProvider<TSource>> queryableProviders,
         IEnumerable<IAlterQueryableService<TSource, TDestination>> alterQueryableServices,
-        IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams, 
+        IEnumerable<IAlterQueryableService<TSource, TDestination, TParams>> alterQueryableServicesWithParams,
         IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> dynamicQueryInterceptorProviders,
         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)
     {
-        source =  await base.AlterSourceAsync(source, query, cancellationToken);
+        source = await base.AlterSourceAsync(source, query, cancellationToken);
 
         if (query is IDynamicQueryParams<TParams> withParams)
         {

Svrnty.CQRS.DynamicQuery/DynamicQueryHandlerBase.cs

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

Svrnty.CQRS.DynamicQuery/ServiceCollectionExtensions.cs

@@ -1,4 +1,4 @@
-using System.Diagnostics.CodeAnalysis;
+using System.Diagnostics.CodeAnalysis;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.DependencyInjection.Extensions;
 using PoweredSoft.Data.Core;
@@ -91,10 +91,10 @@ public static class ServiceCollectionExtensions
         where TParams : class
         => 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.
         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 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>

Svrnty.CQRS.FluentValidation/ServiceCollectionExtensions.cs

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

Svrnty.CQRS.Grpc.Generators/Helpers/ProtoTypeMapper.cs

@@ -1,102 +1,101 @@
 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("?", "");
     }
 }

Svrnty.CQRS.Grpc.Generators/Models/CommandInfo.cs

@@ -1,83 +1,82 @@
 using System.Collections.Generic;
 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;
-        }
     }
 }

Svrnty.CQRS.Grpc.Generators/Models/DynamicQueryInfo.cs

@@ -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;
     }
 }

Svrnty.CQRS.Grpc.Generators/Models/NotificationInfo.cs

@@ -1,50 +1,49 @@
 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>
-    /// Represents a discovered streaming notification type for proto/gRPC generation.
+    /// The notification type name (e.g., "InventoryChangeNotification").
     /// </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>();
-        }
     }
 }

Svrnty.CQRS.Grpc.Generators/Models/QueryInfo.cs

@@ -1,30 +1,29 @@
 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;
     }
 }

Svrnty.CQRS/Configuration/CqrsBuilder.cs

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

Svrnty.CQRS/Discovery/CommandDiscovery.cs

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

Svrnty.CQRS/Discovery/QueryDiscovery.cs

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

Svrnty.Sample/Program.cs

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

Svrnty.Sample/SimpleAsyncQueryableService.cs

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