.claude/settings.local.json

@@ -0,0 +1,50 @@
+{
+  "permissions": {
+    "allow": [
+      "Bash(dotnet clean:*)",
+      "Bash(dotnet run)",
+      "Bash(dotnet add:*)",
+      "Bash(timeout 5 dotnet run:*)",
+      "Bash(dotnet remove:*)",
+      "Bash(netstat:*)",
+      "Bash(findstr:*)",
+      "Bash(cat:*)",
+      "Bash(taskkill:*)",
+      "WebSearch",
+      "Bash(dotnet tool install:*)",
+      "Bash(protogen:*)",
+      "Bash(timeout 15 dotnet run:*)",
+      "Bash(where:*)",
+      "Bash(timeout 30 dotnet run:*)",
+      "Bash(timeout 60 dotnet run:*)",
+      "Bash(timeout 120 dotnet run:*)",
+      "Bash(git add:*)",
+      "Bash(curl:*)",
+      "Bash(timeout 3 cmd:*)",
+      "Bash(timeout:*)",
+      "Bash(tasklist:*)",
+      "Bash(dotnet build:*)",
+      "Bash(dotnet --list-sdks:*)",
+      "Bash(dotnet sln:*)",
+      "Bash(pkill:*)",
+      "Bash(python3:*)",
+      "Bash(grpcurl:*)",
+      "Bash(lsof:*)",
+      "Bash(xargs kill -9)",
+      "Bash(dotnet run:*)",
+      "Bash(find:*)",
+      "Bash(dotnet pack:*)",
+      "Bash(unzip:*)",
+      "WebFetch(domain:andrewlock.net)",
+      "WebFetch(domain:github.com)",
+      "WebFetch(domain:stackoverflow.com)",
+      "WebFetch(domain:www.kenmuse.com)",
+      "WebFetch(domain:blog.rsuter.com)",
+      "WebFetch(domain:natemcmaster.com)",
+      "WebFetch(domain:www.nuget.org)",
+      "Bash(mkdir:*)"
+    ],
+    "deny": [],
+    "ask": []
+  }
+}

.editorconfig

@@ -1,96 +0,0 @@
-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

@@ -1,6 +1,6 @@
 # CLAUDE.md
 
-This file provides guidance to AI agents when working with code in this repository.
+This file provides guidance to Claude Code (claude.ai/code) when working with code in this repository.
 
 ## Project Overview
 

README.md

@@ -4,15 +4,6 @@
 
 Our implementation of query and command responsibility segregation (CQRS).
 
-## Where This Fits
-
-This is a backend framework of the [Svrnty Agent System](../README.md).
-
-**Layer**: Framework
-**Depends on**: Nothing (standalone .NET framework)
-**Depended on by**: a-gent-app (backend services), flutter_cqrs_datasource (client)
-**Git**: [git.openharbor.io/svrnty/dotnet-cqrs](https://git.openharbor.io/svrnty/dotnet-cqrs)
-
 ## Getting Started
 
 > Install nuget package to your awesome project.

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;
 

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;

Svrnty.CQRS.Abstractions/IQueryHandler.cs

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

Svrnty.CQRS.Abstractions/Security/AuthorizationResult.cs

@@ -1,4 +1,4 @@
-namespace Svrnty.CQRS.Abstractions.Security;
+namespace Svrnty.CQRS.Abstractions.Security;
 
 public enum AuthorizationResult
 {

Svrnty.CQRS.Abstractions/Security/ICommandAuthorizationService.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Threading;
 using System.Threading.Tasks;
 

Svrnty.CQRS.Abstractions/Security/IQueryAuthorizationService.cs

@@ -1,4 +1,4 @@
-using System;
+using System;
 using System.Threading;
 using System.Threading.Tasks;
 

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;
 

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;
 

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;

Svrnty.CQRS.DynamicQuery.Abstractions/IDynamicQueryInterceptorProvider.cs

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

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;
 

Svrnty.CQRS.DynamicQuery.MinimalApi/EndpointRouteBuilderExtensions.cs

@@ -7,7 +7,6 @@ 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;
@@ -15,6 +14,7 @@ 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;
 

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,10 +1,10 @@
+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;
 

Svrnty.CQRS.DynamicQuery/DynamicQueryHandlerBase.cs

@@ -1,14 +1,11 @@
-using System;
+using System;
 using System.Collections.Generic;
-using System.Diagnostics.CodeAnalysis;
-using System.Globalization;
 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;
 
@@ -19,10 +16,7 @@ public abstract class DynamicQueryHandlerBase<TSource, TDestination>
     private readonly IQueryHandlerAsync _queryHandlerAsync;
     private readonly IEnumerable<IQueryableProvider<TSource>> _queryableProviders;
     private readonly IEnumerable<IAlterQueryableService<TSource, TDestination>> _alterQueryableServices;
-
-    private readonly IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>>
-        _dynamicQueryInterceptorProviders;
-
+    private readonly IEnumerable<IDynamicQueryInterceptorProvider<TSource, TDestination>> _dynamicQueryInterceptorProviders;
     private readonly IServiceProvider _serviceProvider;
 
     public DynamicQueryHandlerBase(IQueryHandlerAsync queryHandlerAsync, 
@@ -38,8 +32,7 @@ public abstract class DynamicQueryHandlerBase<TSource, TDestination>
         _serviceProvider = serviceProvider;
     }
 
-    protected virtual Task<IQueryable<TSource>> GetQueryableAsync(IDynamicQuery query,
-        CancellationToken cancellationToken = default)
+    protected virtual Task<IQueryable<TSource>> GetQueryableAsync(IDynamicQuery query, CancellationToken cancellationToken = default)
     {
         if (_queryableProviders.Any())
         {
@@ -63,8 +56,7 @@ public abstract class DynamicQueryHandlerBase<TSource, TDestination>
             yield return _serviceProvider.GetService(type) as IQueryInterceptor;
     }
 
-    protected async Task<IQueryExecutionResult<TDestination>> ProcessQueryAsync(IDynamicQuery query,
-        CancellationToken cancellationToken = default)
+    protected async Task<IQueryExecutionResult<TDestination>> ProcessQueryAsync(IDynamicQuery query, CancellationToken cancellationToken = default)
     {
         var source = await GetQueryableAsync(query, cancellationToken);
         source = await AlterSourceAsync(source, query, cancellationToken);
@@ -75,13 +67,11 @@ public abstract class DynamicQueryHandlerBase<TSource, TDestination>
             _queryHandlerAsync.AddInterceptor(interceptor);
 
         var criteria = CreateCriteriaFromQuery(query);
-        var result =
-            await _queryHandlerAsync.ExecuteAsync<TSource, TDestination>(source, criteria, options, cancellationToken);
+        var result = await _queryHandlerAsync.ExecuteAsync<TSource, TDestination>(source, criteria, options, cancellationToken);
         return result;
     }
 
-    protected virtual async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query,
-        CancellationToken cancellationToken)
+    protected virtual async Task<IQueryable<TSource>> AlterSourceAsync(IQueryable<TSource> source, IDynamicQuery query, CancellationToken cancellationToken)
     {
         foreach (var t in _alterQueryableServices)
             source = await t.AlterQueryableAsync(source, query, cancellationToken);
@@ -91,94 +81,16 @@ public abstract class DynamicQueryHandlerBase<TSource, TDestination>
 
     protected virtual IQueryCriteria CreateCriteriaFromQuery(IDynamicQuery query)
     {
-        var filters = query?.GetFilters() ?? new List<IFilter>();
-        ConvertFilterValuesToPropertyTypes(filters);
         var criteria = new QueryCriteria
         {
             Page = query?.GetPage(),
             PageSize = query?.GetPageSize(),
-            Filters = filters,
+            Filters = query?.GetFilters() ?? new List<IFilter>(),
             Sorts = query?.GetSorts() ?? new List<ISort>(),
             Groups = query?.GetGroups() ?? new List<IGroup>(),
             Aggregates = query?.GetAggregates() ?? new List<IAggregate>()
         };
         return criteria;
     }
-
-    /// <summary>
-    /// Converts string filter values to the correct CLR type based on TSource property types.
-    /// This handles the case where transport layers (e.g. gRPC) pass all values as strings,
-    /// but PoweredSoft.DynamicLinq needs the actual type to build LINQ expressions.
-    /// </summary>
-    [UnconditionalSuppressMessage("ReflectionAnalysis", "IL2087",
-        Justification = "TSource properties are preserved by EF Core and DynamicLinq usage")]
-    private static void ConvertFilterValuesToPropertyTypes(List<IFilter> filters)
-    {
-        for (var i = filters.Count - 1; i >= 0; i--)
-        {
-            var filter = filters[i];
-            if (filter is SimpleFilter simpleFilter)
-            {
-                if (simpleFilter.Value == null)
-                {
-                    filters.RemoveAt(i);
-                    continue;
-                }
-
-                if (simpleFilter.Value is string strValue && !string.IsNullOrEmpty(strValue))
-                {
-                    var propertyType = ResolvePropertyType(typeof(TSource), simpleFilter.Path);
-                    if (propertyType == null)
-                        continue;
-
-                    var targetType = Nullable.GetUnderlyingType(propertyType) ?? propertyType;
-
-                    if (targetType == typeof(DateTime))
-                    {
-                        if (DateTime.TryParse(strValue, CultureInfo.InvariantCulture, DateTimeStyles.AdjustToUniversal,
-                                out var dt))
-                        {
-                            simpleFilter.Value = DateTime.SpecifyKind(dt, DateTimeKind.Utc);
-                        }
-                    }
-                    else if (targetType == typeof(DateTimeOffset))
-                    {
-                        if (DateTimeOffset.TryParse(strValue, CultureInfo.InvariantCulture, DateTimeStyles.None,
-                                out var dto))
-                        {
-                            simpleFilter.Value = dto;
-                        }
-                    }
-                }
-            }
-            else if (filter is CompositeFilter compositeFilter && compositeFilter.Filters != null)
-            {
-                ConvertFilterValuesToPropertyTypes(compositeFilter.Filters);
-            }
-        }
-
-        [UnconditionalSuppressMessage("ReflectionAnalysis", "IL2070",
-            Justification = "Property types are preserved by EF Core and DynamicLinq usage")]
-        [UnconditionalSuppressMessage("ReflectionAnalysis", "IL2075",
-            Justification = "Nested property type resolution is inherently dynamic")]
-        static Type? ResolvePropertyType(
-            [DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.PublicProperties)] Type type, string? path)
-        {
-            if (string.IsNullOrEmpty(path))
-                return null;
-
-            var currentType = type;
-            foreach (var part in path.Split('.'))
-            {
-                var property = currentType.GetProperty(part,
-                    BindingFlags.Public | BindingFlags.Instance | BindingFlags.IgnoreCase);
-                if (property == null)
-                    return null;
-                currentType = property.PropertyType;
-            }
-
-            return currentType;
-        }
-    }
 }
 

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

Svrnty.CQRS.Grpc.Generators/GenerateProtoFileTask.cs

@@ -1,256 +0,0 @@
-#pragma warning disable RS1035 // Do not use APIs banned for analyzers - This is an MSBuild task, not an analyzer
-
-using System;
-using System.Collections.Generic;
-using System.IO;
-using System.Linq;
-using Microsoft.Build.Framework;
-using Microsoft.Build.Utilities;
-using Microsoft.CodeAnalysis;
-using Microsoft.CodeAnalysis.CSharp;
-
-namespace Svrnty.CQRS.Grpc.Generators;
-
-/// <summary>
-/// MSBuild task that generates .proto files by creating its own Roslyn compilation.
-/// This runs BEFORE CoreCompile to solve the source generator timing issue.
-/// </summary>
-public class GenerateProtoFileTask : Task
-{
-    /// <summary>
-    /// The project directory
-    /// </summary>
-    [Required]
-    public string ProjectDirectory { get; set; } = string.Empty;
-
-    /// <summary>
-    /// The output directory where the proto file should be written (typically Protos/)
-    /// </summary>
-    [Required]
-    public string OutputDirectory { get; set; } = string.Empty;
-
-    /// <summary>
-    /// The name of the proto file to generate (typically cqrs_services.proto)
-    /// </summary>
-    [Required]
-    public string ProtoFileName { get; set; } = string.Empty;
-
-    /// <summary>
-    /// The C# source files to compile (from @(Compile) ItemGroup)
-    /// </summary>
-    [Required]
-    public ITaskItem[] SourceFiles { get; set; } = Array.Empty<ITaskItem>();
-
-    /// <summary>
-    /// The assembly references (from @(ReferencePath) ItemGroup)
-    /// </summary>
-    [Required]
-    public ITaskItem[] References { get; set; } = Array.Empty<ITaskItem>();
-
-    /// <summary>
-    /// The root namespace of the project
-    /// </summary>
-    public string RootNamespace { get; set; } = string.Empty;
-
-    /// <summary>
-    /// The assembly name of the project
-    /// </summary>
-    public string AssemblyName { get; set; } = string.Empty;
-
-    public override bool Execute()
-    {
-        try
-        {
-            Log.LogMessage(MessageImportance.High,
-                "Svrnty.CQRS.Grpc: Generating proto file via MSBuild task...");
-
-            // Determine the namespace for the proto file
-            var projectNamespace = !string.IsNullOrEmpty(RootNamespace) ? RootNamespace
-                : !string.IsNullOrEmpty(AssemblyName) ? AssemblyName
-                : "Generated";
-            var grpcNamespace = $"{projectNamespace}.Grpc";
-            var packageName = "cqrs";
-
-            // Create the compilation
-            var compilation = CreateCompilation();
-            if (compilation == null)
-            {
-                Log.LogWarning("Svrnty.CQRS.Grpc: Could not create compilation. Writing placeholder proto file.");
-                WritePlaceholderProto(grpcNamespace);
-                return true;
-            }
-
-            // Check for compilation errors that would prevent proper analysis
-            var diagnostics = compilation.GetDiagnostics()
-                .Where(d => d.Severity == DiagnosticSeverity.Error)
-                .ToList();
-
-            if (diagnostics.Count > 0)
-            {
-                Log.LogMessage(MessageImportance.Normal,
-                    $"Svrnty.CQRS.Grpc: Compilation has {diagnostics.Count} errors. Attempting to generate proto anyway...");
-
-                // Log first few errors for debugging
-                foreach (var diag in diagnostics.Take(5))
-                {
-                    Log.LogMessage(MessageImportance.Low, $"  {diag.GetMessage()}");
-                }
-            }
-
-            // Use the ProtoFileGenerator to generate content
-            var generator = new ProtoFileGenerator(compilation);
-            var protoContent = generator.Generate(packageName, grpcNamespace);
-
-            // Check if we got meaningful content
-            if (string.IsNullOrWhiteSpace(protoContent) || !protoContent.Contains("rpc "))
-            {
-                Log.LogMessage(MessageImportance.High,
-                    "Svrnty.CQRS.Grpc: No commands/queries/notifications found. Writing minimal proto file.");
-                WritePlaceholderProto(grpcNamespace);
-                return true;
-            }
-
-            // Ensure output directory exists
-            var fullOutputPath = Path.IsPathRooted(OutputDirectory)
-                ? OutputDirectory
-                : Path.Combine(ProjectDirectory, OutputDirectory);
-            Directory.CreateDirectory(fullOutputPath);
-
-            // Write the proto file
-            var protoFilePath = Path.Combine(fullOutputPath, ProtoFileName);
-            File.WriteAllText(protoFilePath, protoContent);
-
-            Log.LogMessage(MessageImportance.High,
-                $"Svrnty.CQRS.Grpc: Successfully generated proto file at {protoFilePath}");
-
-            return true;
-        }
-        catch (Exception ex)
-        {
-            Log.LogErrorFromException(ex, true);
-            return false;
-        }
-    }
-
-    private CSharpCompilation? CreateCompilation()
-    {
-        try
-        {
-            // Parse all source files into syntax trees
-            var syntaxTrees = new List<SyntaxTree>();
-            foreach (var sourceFile in SourceFiles)
-            {
-                var filePath = sourceFile.ItemSpec;
-                if (!Path.IsPathRooted(filePath))
-                {
-                    filePath = Path.Combine(ProjectDirectory, filePath);
-                }
-
-                if (!File.Exists(filePath))
-                {
-                    Log.LogMessage(MessageImportance.Low, $"Source file not found: {filePath}");
-                    continue;
-                }
-
-                try
-                {
-                    var sourceText = File.ReadAllText(filePath);
-                    var syntaxTree = CSharpSyntaxTree.ParseText(
-                        sourceText,
-                        CSharpParseOptions.Default.WithLanguageVersion(LanguageVersion.Latest),
-                        path: filePath);
-                    syntaxTrees.Add(syntaxTree);
-                }
-                catch (Exception ex)
-                {
-                    Log.LogMessage(MessageImportance.Low, $"Failed to parse {filePath}: {ex.Message}");
-                }
-            }
-
-            if (syntaxTrees.Count == 0)
-            {
-                Log.LogWarning("Svrnty.CQRS.Grpc: No source files could be parsed.");
-                return null;
-            }
-
-            Log.LogMessage(MessageImportance.Normal,
-                $"Svrnty.CQRS.Grpc: Parsed {syntaxTrees.Count} source files");
-
-            // Create metadata references from the References
-            var metadataReferences = new List<MetadataReference>();
-            foreach (var reference in References)
-            {
-                var refPath = reference.ItemSpec;
-                if (!File.Exists(refPath))
-                {
-                    Log.LogMessage(MessageImportance.Low, $"Reference not found: {refPath}");
-                    continue;
-                }
-
-                try
-                {
-                    var metadataRef = MetadataReference.CreateFromFile(refPath);
-                    metadataReferences.Add(metadataRef);
-                }
-                catch (Exception ex)
-                {
-                    Log.LogMessage(MessageImportance.Low, $"Failed to load reference {refPath}: {ex.Message}");
-                }
-            }
-
-            Log.LogMessage(MessageImportance.Normal,
-                $"Svrnty.CQRS.Grpc: Loaded {metadataReferences.Count} references");
-
-            // Create the compilation
-            var compilationOptions = new CSharpCompilationOptions(OutputKind.DynamicallyLinkedLibrary)
-                .WithNullableContextOptions(NullableContextOptions.Enable);
-
-            var assemblyName = !string.IsNullOrEmpty(AssemblyName) ? AssemblyName : "TempCompilation";
-            var compilation = CSharpCompilation.Create(
-                assemblyName,
-                syntaxTrees,
-                metadataReferences,
-                compilationOptions);
-
-            return compilation;
-        }
-        catch (Exception ex)
-        {
-            Log.LogMessage(MessageImportance.High,
-                $"Svrnty.CQRS.Grpc: Failed to create compilation: {ex.Message}");
-            return null;
-        }
-    }
-
-    private void WritePlaceholderProto(string grpcNamespace)
-    {
-        var placeholderProto = $@"syntax = ""proto3"";
-
-option csharp_namespace = ""{grpcNamespace}"";
-
-package cqrs;
-
-// Placeholder proto file - will be regenerated when commands/queries are available
-// Using namespace: {grpcNamespace}
-
-// Empty service definitions so Grpc.Tools generates base classes
-service CommandService {{
-}}
-
-service QueryService {{
-}}
-
-service DynamicQueryService {{
-}}
-";
-        var fullOutputPath = Path.IsPathRooted(OutputDirectory)
-            ? OutputDirectory
-            : Path.Combine(ProjectDirectory, OutputDirectory);
-        Directory.CreateDirectory(fullOutputPath);
-        var protoFilePath = Path.Combine(fullOutputPath, ProtoFileName);
-        File.WriteAllText(protoFilePath, placeholderProto);
-
-        Log.LogMessage(MessageImportance.High,
-            $"Svrnty.CQRS.Grpc: Wrote placeholder proto file at {protoFilePath}");
-    }
-}

Svrnty.CQRS.Grpc.Generators/GrpcGenerator.cs

@@ -1,16 +1,16 @@
-using System.Collections.Generic;
-using System.Linq;
-using System.Text;
 using Microsoft.CodeAnalysis;
 using Microsoft.CodeAnalysis.CSharp.Syntax;
 using Svrnty.CQRS.Grpc.Generators.Helpers;
 using Svrnty.CQRS.Grpc.Generators.Models;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
 
-namespace Svrnty.CQRS.Grpc.Generators;
-
-[Generator]
-public class GrpcGenerator : IIncrementalGenerator
+namespace Svrnty.CQRS.Grpc.Generators
 {
+    [Generator]
+    public class GrpcGenerator : IIncrementalGenerator
+    {
         public void Initialize(IncrementalGeneratorInitializationContext context)
         {
             // Find all types that might be commands or queries from source
@@ -2291,7 +2291,6 @@ public class GrpcGenerator : IIncrementalGenerator
             sb.AppendLine("using Google.Protobuf.WellKnownTypes;");
             sb.AppendLine($"using {rootNamespace}.Grpc;");
             sb.AppendLine("using Svrnty.CQRS.Abstractions;");
-        sb.AppendLine("using Svrnty.CQRS.Abstractions.Security;");
             sb.AppendLine();
 
             sb.AppendLine($"namespace {rootNamespace}.Grpc.Services");
@@ -2322,17 +2321,6 @@ public class GrpcGenerator : IIncrementalGenerator
                 sb.AppendLine("            using var scope = _scopeFactory.CreateScope();");
                 sb.AppendLine("            var serviceProvider = scope.ServiceProvider;");
                 sb.AppendLine();
-            sb.AppendLine("            // Authorization check");
-            sb.AppendLine($"            var authorizationService = serviceProvider.GetService<ICommandAuthorizationService>();");
-            sb.AppendLine("            if (authorizationService != null)");
-            sb.AppendLine("            {");
-            sb.AppendLine($"                var authResult = await authorizationService.IsAllowedAsync(typeof({command.FullyQualifiedName}), context.CancellationToken);");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Unauthorized)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.Unauthenticated, \"Unauthorized\"));");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Forbidden)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.PermissionDenied, \"Forbidden\"));");
-            sb.AppendLine("            }");
-            sb.AppendLine();
                 sb.AppendLine($"            var command = new {command.FullyQualifiedName}");
                 sb.AppendLine("            {");
                 foreach (var prop in command.Properties)
@@ -2437,7 +2425,6 @@ public class GrpcGenerator : IIncrementalGenerator
             sb.AppendLine("using Microsoft.Extensions.DependencyInjection;");
             sb.AppendLine($"using {rootNamespace}.Grpc;");
             sb.AppendLine("using Svrnty.CQRS.Abstractions;");
-        sb.AppendLine("using Svrnty.CQRS.Abstractions.Security;");
             sb.AppendLine();
 
             sb.AppendLine($"namespace {rootNamespace}.Grpc.Services");
@@ -2468,17 +2455,6 @@ public class GrpcGenerator : IIncrementalGenerator
                 sb.AppendLine("            using var scope = _scopeFactory.CreateScope();");
                 sb.AppendLine("            var serviceProvider = scope.ServiceProvider;");
                 sb.AppendLine();
-            sb.AppendLine("            // Authorization check");
-            sb.AppendLine($"            var authorizationService = serviceProvider.GetService<IQueryAuthorizationService>();");
-            sb.AppendLine("            if (authorizationService != null)");
-            sb.AppendLine("            {");
-            sb.AppendLine($"                var authResult = await authorizationService.IsAllowedAsync(typeof({query.FullyQualifiedName}), context.CancellationToken);");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Unauthorized)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.Unauthenticated, \"Unauthorized\"));");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Forbidden)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.PermissionDenied, \"Forbidden\"));");
-            sb.AppendLine("            }");
-            sb.AppendLine();
                 sb.AppendLine($"            var handler = serviceProvider.GetRequiredService<{query.HandlerInterfaceName}>();");
                 sb.AppendLine($"            var query = new {query.FullyQualifiedName}");
                 sb.AppendLine("            {");
@@ -2760,7 +2736,6 @@ public class GrpcGenerator : IIncrementalGenerator
             sb.AppendLine("using Microsoft.Extensions.DependencyInjection;");
             sb.AppendLine($"using {rootNamespace}.Grpc;");
             sb.AppendLine("using Svrnty.CQRS.Abstractions;");
-        sb.AppendLine("using Svrnty.CQRS.Abstractions.Security;");
             sb.AppendLine("using Svrnty.CQRS.DynamicQuery.Abstractions;");
             sb.AppendLine("using PoweredSoft.DynamicQuery.Core;");
             sb.AppendLine();
@@ -2793,17 +2768,6 @@ public class GrpcGenerator : IIncrementalGenerator
                 sb.AppendLine("            using var scope = _scopeFactory.CreateScope();");
                 sb.AppendLine("            var serviceProvider = scope.ServiceProvider;");
                 sb.AppendLine();
-            sb.AppendLine("            // Authorization check");
-            sb.AppendLine($"            var authorizationService = serviceProvider.GetService<IQueryAuthorizationService>();");
-            sb.AppendLine("            if (authorizationService != null)");
-            sb.AppendLine("            {");
-            sb.AppendLine($"                var authResult = await authorizationService.IsAllowedAsync(typeof({dynamicQuery.QueryInterfaceName}), context.CancellationToken);");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Unauthorized)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.Unauthenticated, \"Unauthorized\"));");
-            sb.AppendLine("                if (authResult == AuthorizationResult.Forbidden)");
-            sb.AppendLine("                    throw new RpcException(new global::Grpc.Core.Status(global::Grpc.Core.StatusCode.PermissionDenied, \"Forbidden\"));");
-            sb.AppendLine("            }");
-            sb.AppendLine();
 
                 // Build the dynamic query object
                 if (dynamicQuery.HasParams)
@@ -2864,8 +2828,7 @@ public class GrpcGenerator : IIncrementalGenerator
             sb.AppendLine("                {");
             sb.AppendLine("                    Path = protoFilter.Path,");
             sb.AppendLine("                    Type = ((PoweredSoft.DynamicQuery.Core.FilterType)protoFilter.Type).ToString(),");
-        sb.AppendLine("                    Value = protoFilter.Value,");
-        sb.AppendLine("                    And = true");
+            sb.AppendLine("                    Value = protoFilter.Value");
             sb.AppendLine("                };");
             sb.AppendLine();
             sb.AppendLine("                // Handle nested AND filters");
@@ -2895,8 +2858,7 @@ public class GrpcGenerator : IIncrementalGenerator
             sb.AppendLine("                {");
             sb.AppendLine("                    Path = pf.Path,");
             sb.AppendLine("                    Type = ((PoweredSoft.DynamicQuery.Core.FilterType)pf.Type).ToString(),");
-        sb.AppendLine("                    Value = pf.Value,");
-        sb.AppendLine("                    And = true");
+            sb.AppendLine("                    Value = pf.Value");
             sb.AppendLine("                };");
             sb.AppendLine("                if (pf.And != null && pf.And.Count > 0)");
             sb.AppendLine("                {");
@@ -3358,4 +3320,5 @@ public class GrpcGenerator : IIncrementalGenerator
             return string.Join("", parts.Select(p =>
                 p.Length > 0 ? char.ToUpperInvariant(p[0]) + p.Substring(1).ToLowerInvariant() : ""));
         }
+    }
 }

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

@@ -1,9 +1,9 @@
 using System.Collections.Generic;
 
-namespace Svrnty.CQRS.Grpc.Generators.Helpers;
-
-internal static class ProtoTypeMapper
+namespace Svrnty.CQRS.Grpc.Generators.Helpers
 {
+    internal static class ProtoTypeMapper
+    {
         private static readonly Dictionary<string, string> TypeMap = new Dictionary<string, string>
         {
             // Primitives
@@ -98,4 +98,5 @@ internal static class ProtoTypeMapper
 
             return csharpType.Replace("?", "");
         }
+    }
 }

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

@@ -1,10 +1,10 @@
 using System.Collections.Generic;
 using Microsoft.CodeAnalysis;
 
-namespace Svrnty.CQRS.Grpc.Generators.Models;
-
-public class CommandInfo
+namespace Svrnty.CQRS.Grpc.Generators.Models
 {
+    public class CommandInfo
+    {
         public string Name { get; set; }
         public string FullyQualifiedName { get; set; }
         public string Namespace { get; set; }
@@ -26,10 +26,10 @@ public class CommandInfo
             ResultProperties = new List<PropertyInfo>();
             IsResultPrimitiveType = false;
         }
-}
+    }
 
-public class PropertyInfo
-{
+    public class PropertyInfo
+    {
         public string Name { get; set; }
         public string Type { get; set; }
         public string FullyQualifiedType { get; set; }
@@ -79,4 +79,5 @@ public class PropertyInfo
             IsElementComplexType = false;
             IsElementGuid = false;
         }
+    }
 }

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

@@ -1,7 +1,7 @@
-namespace Svrnty.CQRS.Grpc.Generators.Models;
-
-public class DynamicQueryInfo
+namespace Svrnty.CQRS.Grpc.Generators.Models
 {
+    public class DynamicQueryInfo
+    {
         public string Name { get; set; }
         public string SourceType { get; set; }
         public string SourceTypeFullyQualified { get; set; }
@@ -24,4 +24,5 @@ public class DynamicQueryInfo
             QueryInterfaceName = string.Empty;
             HasParams = false;
         }
+    }
 }

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

@@ -1,12 +1,12 @@
 using System.Collections.Generic;
 
-namespace Svrnty.CQRS.Grpc.Generators.Models;
-
-/// <summary>
-/// Represents a discovered streaming notification type for proto/gRPC generation.
-/// </summary>
-public class NotificationInfo
+namespace Svrnty.CQRS.Grpc.Generators.Models
 {
+    /// <summary>
+    /// Represents a discovered streaming notification type for proto/gRPC generation.
+    /// </summary>
+    public class NotificationInfo
+    {
         /// <summary>
         /// The notification type name (e.g., "InventoryChangeNotification").
         /// </summary>
@@ -46,4 +46,5 @@ public class NotificationInfo
             SubscriptionKeyInfo = new PropertyInfo();
             Properties = new List<PropertyInfo>();
         }
+    }
 }

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

@@ -1,9 +1,9 @@
 using System.Collections.Generic;
 
-namespace Svrnty.CQRS.Grpc.Generators.Models;
-
-public class QueryInfo
+namespace Svrnty.CQRS.Grpc.Generators.Models
 {
+    public class QueryInfo
+    {
         public string Name { get; set; }
         public string FullyQualifiedName { get; set; }
         public string Namespace { get; set; }
@@ -26,4 +26,5 @@ public class QueryInfo
             ResultProperties = new List<PropertyInfo>();
             IsResultPrimitiveType = false;
         }
+    }
 }

Svrnty.CQRS.Grpc.Generators/ProtoFileGenerator.cs

@@ -413,21 +413,17 @@ internal class ProtoFileGenerator
 
     private void GenerateComplexTypeMessage(INamedTypeSymbol? type)
     {
-        if (type == null)
-            return;
-
-        var messageName = ProtoFileTypeMapper.GetProtoMessageName(type);
-        if (_generatedMessages.Contains(messageName))
+        if (type == null || _generatedMessages.Contains(type.Name))
             return;
 
         // Don't generate messages for system types or primitives
         if (type.ContainingNamespace?.ToString().StartsWith("System") == true)
             return;
 
-        _generatedMessages.Add(messageName);
+        _generatedMessages.Add(type.Name);
 
-        _messagesBuilder.AppendLine($"// {messageName} entity");
-        _messagesBuilder.AppendLine($"message {messageName} {{");
+        _messagesBuilder.AppendLine($"// {type.Name} entity");
+        _messagesBuilder.AppendLine($"message {type.Name} {{");
 
         // Collect nested complex types to generate after closing this message
         var nestedComplexTypes = new List<INamedTypeSymbol>();

Svrnty.CQRS.Grpc.Generators/ProtoFileSourceGenerator.cs

@@ -0,0 +1,124 @@
+using System;
+using System.Collections.Immutable;
+using System.Linq;
+using Microsoft.CodeAnalysis;
+using Microsoft.CodeAnalysis.CSharp.Syntax;
+
+namespace Svrnty.CQRS.Grpc.Generators;
+
+/// <summary>
+/// Incremental source generator that generates .proto files from C# commands and queries
+/// </summary>
+[Generator]
+public class ProtoFileSourceGenerator : IIncrementalGenerator
+{
+    public void Initialize(IncrementalGeneratorInitializationContext context)
+    {
+        // Register a post-initialization output to generate the proto file
+        context.RegisterPostInitializationOutput(ctx =>
+        {
+            // Generate a placeholder - the actual proto will be generated in the source output
+        });
+
+        // Collect type declarations to trigger generation
+        // We use any type declaration as a trigger since ProtoFileGenerator scans all assemblies
+        var typeDeclarations = context.SyntaxProvider
+            .CreateSyntaxProvider(
+                predicate: static (s, _) => s is TypeDeclarationSyntax,
+                transform: static (ctx, _) => GetTypeSymbol(ctx))
+            .Where(static m => m is not null)
+            .Collect();
+
+        // Combine with compilation to have access to it
+        var compilationAndTypes = context.CompilationProvider.Combine(typeDeclarations);
+
+        // Generate proto file when commands/queries change
+        context.RegisterSourceOutput(compilationAndTypes, (spc, source) =>
+        {
+            var (compilation, types) = source;
+
+            // Note: We no longer bail out early since ProtoFileGenerator now scans all referenced assemblies
+            // The types from source are just a trigger - the generator will find types from all assemblies
+
+            try
+            {
+                // Get the root namespace from the compilation - this matches what GrpcGenerator does
+                var rootNamespace = compilation.AssemblyName ?? "Generated";
+                var packageName = "cqrs";
+                var csharpNamespace = $"{rootNamespace}.Grpc";
+
+                // Generate the proto file content
+                var generator = new ProtoFileGenerator(compilation);
+                var protoContent = generator.Generate(packageName, csharpNamespace);
+
+                // Output as an embedded resource that can be extracted
+                var protoFileName = "cqrs_services.proto";
+
+                // Generate a C# class that contains the proto content
+                // This allows build tools to extract it if needed
+                var csContent = $$"""
+                // <auto-generated />
+                #nullable enable
+
+                namespace Svrnty.CQRS.Grpc.Generated
+                {
+                    /// <summary>
+                    /// Contains the auto-generated Protocol Buffer definition
+                    /// </summary>
+                    internal static class GeneratedProtoFile
+                    {
+                        public const string FileName = "{{protoFileName}}";
+
+                        public const string Content = @"{{protoContent.Replace("\"", "\"\"")}}";
+                    }
+                }
+                """;
+
+                spc.AddSource("GeneratedProtoFile.g.cs", csContent);
+
+                // Report that we generated the proto content
+                var descriptor = new DiagnosticDescriptor(
+                    "CQRSGRPC002",
+                    "Proto file generated",
+                    "Generated proto file content in GeneratedProtoFile class",
+                    "Svrnty.CQRS.Grpc",
+                    DiagnosticSeverity.Info,
+                    isEnabledByDefault: true);
+
+                spc.ReportDiagnostic(Diagnostic.Create(descriptor, Location.None));
+            }
+            catch (Exception ex)
+            {
+                // Report diagnostic if generation fails
+                var descriptor = new DiagnosticDescriptor(
+                    "CQRSGRPC001",
+                    "Proto file generation failed",
+                    "Failed to generate proto file: {0}",
+                    "Svrnty.CQRS.Grpc",
+                    DiagnosticSeverity.Warning,
+                    isEnabledByDefault: true);
+
+                spc.ReportDiagnostic(Diagnostic.Create(descriptor, Location.None, ex.Message));
+            }
+        });
+    }
+
+    private static INamedTypeSymbol? GetTypeSymbol(GeneratorSyntaxContext context)
+    {
+        var typeDecl = (TypeDeclarationSyntax)context.Node;
+        var symbol = context.SemanticModel.GetDeclaredSymbol(typeDecl) as INamedTypeSymbol;
+
+        // Skip if it has GrpcIgnore attribute
+        if (symbol?.GetAttributes().Any(a => a.AttributeClass?.Name == "GrpcIgnoreAttribute") == true)
+            return null;
+
+        return symbol;
+    }
+
+    private static string? GetBuildProperty(SourceProductionContext context, string propertyName)
+    {
+        // Try to get build properties from the compilation options
+        // This is a simplified approach - in practice, you might need analyzer config
+        return null; // Will use defaults
+    }
+}

Svrnty.CQRS.Grpc.Generators/ProtoTypeMapper.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Linq;
 using Microsoft.CodeAnalysis;
 
 namespace Svrnty.CQRS.Grpc.Generators;
@@ -152,27 +151,13 @@ internal static class ProtoFileTypeMapper
         // Complex types (classes/records) become message types
         if (typeSymbol.TypeKind == TypeKind.Class || typeSymbol.TypeKind == TypeKind.Struct)
         {
-            return GetProtoMessageName(typeSymbol); // Reference the message type by name (handles generics)
+            return typeName; // Reference the message type by name
         }
 
         // Fallback
         return "string"; // Default to string for unknown types
     }
 
-    /// <summary>
-    /// Gets the proto message name for a type, handling generic types by qualifying
-    /// with type arguments. e.g. Translation&lt;FaqTranslationQueryItem&gt; becomes TranslationOfFaqTranslationQueryItem.
-    /// </summary>
-    public static string GetProtoMessageName(ITypeSymbol typeSymbol)
-    {
-        if (typeSymbol is INamedTypeSymbol namedType && namedType.IsGenericType && namedType.TypeArguments.Length > 0)
-        {
-            var typeArgs = string.Join("And", namedType.TypeArguments.Select(t => GetProtoMessageName(t)));
-            return $"{namedType.Name}Of{typeArgs}";
-        }
-        return typeSymbol.Name;
-    }
-
     /// <summary>
     /// Converts C# PascalCase property name to proto snake_case field name.
     /// Uses simple conversion: add underscore before each uppercase letter (except first).

Svrnty.CQRS.Grpc.Generators/WriteProtoFileTask.cs

@@ -0,0 +1,150 @@
+#pragma warning disable RS1035 // Do not use APIs banned for analyzers - This is an MSBuild task, not an analyzer
+
+using System;
+using System.IO;
+using System.Linq;
+using System.Text.RegularExpressions;
+using Microsoft.Build.Framework;
+using Microsoft.Build.Utilities;
+
+namespace Svrnty.CQRS.Grpc.Generators;
+
+/// <summary>
+/// MSBuild task that extracts the auto-generated proto file content from the source generator
+/// output and writes it to disk so Grpc.Tools can process it
+/// </summary>
+public class WriteProtoFileTask : Task
+{
+    /// <summary>
+    /// The project directory where we should look for generated files
+    /// </summary>
+    [Required]
+    public string ProjectDirectory { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The intermediate output path (typically obj/Debug/net10.0)
+    /// </summary>
+    [Required]
+    public string IntermediateOutputPath { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The output directory where the proto file should be written (typically Protos/)
+    /// </summary>
+    [Required]
+    public string OutputDirectory { get; set; } = string.Empty;
+
+    /// <summary>
+    /// The name of the proto file to generate (typically cqrs_services.proto)
+    /// </summary>
+    [Required]
+    public string ProtoFileName { get; set; } = string.Empty;
+
+    public override bool Execute()
+    {
+        try
+        {
+            Log.LogMessage(MessageImportance.High,
+                "Svrnty.CQRS.Grpc: Extracting auto-generated proto file...");
+
+            // Look for the generated C# file containing the proto content
+            // Source generators output to obj/Generated, not IntermediateOutputPath/Generated
+            var generatedFilePath = Path.Combine(
+                ProjectDirectory,
+                "obj",
+                "Generated",
+                "Svrnty.CQRS.Grpc.Generators",
+                "Svrnty.CQRS.Grpc.Generators.ProtoFileSourceGenerator",
+                "GeneratedProtoFile.g.cs"
+            );
+
+            if (!File.Exists(generatedFilePath))
+            {
+                Log.LogWarning(
+                    $"Generated proto file not found at {generatedFilePath}. " +
+                    "The proto file may not have been generated yet. This is normal on first build.");
+
+                // Write a minimal placeholder proto file so Grpc.Tools doesn't fail
+                // The real content will be generated on the next build
+                var placeholderProto = @"syntax = ""proto3"";
+
+option csharp_namespace = ""Generated.Grpc"";
+
+package cqrs;
+
+// Placeholder proto file - will be regenerated on next build
+";
+                var placeholderOutputPath = Path.Combine(ProjectDirectory, OutputDirectory);
+                Directory.CreateDirectory(placeholderOutputPath);
+                var placeholderProtoFilePath = Path.Combine(placeholderOutputPath, ProtoFileName);
+                File.WriteAllText(placeholderProtoFilePath, placeholderProto);
+
+                Log.LogMessage(MessageImportance.High,
+                    $"Svrnty.CQRS.Grpc: Wrote placeholder proto file at {placeholderProtoFilePath}. " +
+                    "Run build again to generate the actual proto content.");
+
+                return true;
+            }
+
+            // Read the generated C# file
+            var csContent = File.ReadAllText(generatedFilePath);
+
+            // Extract the proto content using a more robust approach
+            // Looking for: public const string Content = @"...";
+            var startMarker = "public const string Content = @\"";
+            var startIndex = csContent.IndexOf(startMarker);
+
+            if (startIndex < 0)
+            {
+                Log.LogError($"Could not find Content property in {generatedFilePath}");
+                return false;
+            }
+
+            startIndex += startMarker.Length;
+
+            // Find the closing "; - We need the LAST occurrence because the content contains escaped quotes
+            // The pattern is: Content = @"...content...";
+            // where content has "" for literal quotes
+            var endMarker = "\";";
+
+            // Find where the next field starts or class ends to limit our search
+            var nextFieldOrEnd = csContent.IndexOf("\n    }", startIndex); // End of class
+            if (nextFieldOrEnd < 0)
+            {
+                nextFieldOrEnd = csContent.Length;
+            }
+
+            var endIndex = csContent.LastIndexOf(endMarker, nextFieldOrEnd, nextFieldOrEnd - startIndex);
+
+            if (endIndex < 0 || endIndex < startIndex)
+            {
+                Log.LogError($"Could not find end of Content property in {generatedFilePath}");
+                return false;
+            }
+
+            // Extract and unescape doubled quotes
+            var protoContent = csContent.Substring(startIndex, endIndex - startIndex);
+            protoContent = protoContent.Replace("\"\"", "\"");
+
+            Log.LogMessage(MessageImportance.High,
+                $"Extracted proto content length: {protoContent.Length} characters");
+
+            // Ensure output directory exists
+            var fullOutputPath = Path.Combine(ProjectDirectory, OutputDirectory);
+            Directory.CreateDirectory(fullOutputPath);
+
+            // Write the proto file
+            var protoFilePath = Path.Combine(fullOutputPath, ProtoFileName);
+            File.WriteAllText(protoFilePath, protoContent);
+
+            Log.LogMessage(MessageImportance.High,
+                $"Svrnty.CQRS.Grpc: Successfully generated proto file at {protoFilePath}");
+
+            return true;
+        }
+        catch (Exception ex)
+        {
+            Log.LogErrorFromException(ex, true);
+            return false;
+        }
+    }
+}

Svrnty.CQRS.Grpc.Generators/build/Svrnty.CQRS.Grpc.Generators.targets

@@ -9,48 +9,29 @@
   <!-- Determine the assembly path (different for NuGet package vs project reference) -->
   <PropertyGroup>
     <_GeneratorsAssemblyPath Condition="Exists('$(MSBuildThisFileDirectory)\..\analyzers\dotnet\cs\Svrnty.CQRS.Grpc.Generators.dll')">$(MSBuildThisFileDirectory)\..\analyzers\dotnet\cs\Svrnty.CQRS.Grpc.Generators.dll</_GeneratorsAssemblyPath>
-    <_GeneratorsAssemblyPath Condition="'$(_GeneratorsAssemblyPath)' == '' AND Exists('$(MSBuildThisFileDirectory)Svrnty.CQRS.Grpc.Generators.dll')">$(MSBuildThisFileDirectory)Svrnty.CQRS.Grpc.Generators.dll</_GeneratorsAssemblyPath>
     <_GeneratorsAssemblyPath Condition="'$(_GeneratorsAssemblyPath)' == '' AND Exists('$(MSBuildThisFileDirectory)\..\bin\Debug\netstandard2.0\Svrnty.CQRS.Grpc.Generators.dll')">$(MSBuildThisFileDirectory)\..\bin\Debug\netstandard2.0\Svrnty.CQRS.Grpc.Generators.dll</_GeneratorsAssemblyPath>
     <_GeneratorsAssemblyPath Condition="'$(_GeneratorsAssemblyPath)' == '' AND Exists('$(MSBuildThisFileDirectory)\..\bin\Release\netstandard2.0\Svrnty.CQRS.Grpc.Generators.dll')">$(MSBuildThisFileDirectory)\..\bin\Release\netstandard2.0\Svrnty.CQRS.Grpc.Generators.dll</_GeneratorsAssemblyPath>
   </PropertyGroup>
 
-  <!-- Load the GenerateProtoFileTask from the generator assembly -->
-  <UsingTask TaskName="Svrnty.CQRS.Grpc.Generators.GenerateProtoFileTask"
+  <!-- Load the WriteProtoFileTask from the generator assembly -->
+  <UsingTask TaskName="Svrnty.CQRS.Grpc.Generators.WriteProtoFileTask"
              AssemblyFile="$(_GeneratorsAssemblyPath)"
              Condition="'$(_GeneratorsAssemblyPath)' != ''" />
 
-  <!-- This target ensures the Protos directory exists -->
-  <Target Name="EnsureProtosDirectory" BeforeTargets="SvrntyGenerateProtoFile">
+  <!-- This target ensures the Protos directory exists before the generator runs -->
+  <Target Name="EnsureProtosDirectory" BeforeTargets="CoreCompile">
     <MakeDir Directories="$(ProtoOutputDirectory)" Condition="!Exists('$(ProtoOutputDirectory)')" />
   </Target>
 
-  <!--
-    Generate the proto file BEFORE Grpc.Tools processes protos and BEFORE CoreCompile.
-    This runs AFTER ResolveAssemblyReferences so we have access to @(ReferencePath).
+  <!-- Extract the proto file from the source generator output BEFORE Grpc.Tools processes protos -->
+  <!-- Runs before CoreCompile, after source generators have been executed -->
+  <Target Name="SvrntyExtractProtoFile" BeforeTargets="CoreCompile" AfterTargets="ResolveProjectReferences" DependsOnTargets="EnsureProtosDirectory" Condition="'$(GenerateProtoFile)' == 'true'">
+    <Message Text="Svrnty.CQRS.Grpc: Extracting auto-generated proto file to $(ProtoOutputDirectory)\$(GeneratedProtoFileName)" Importance="high" />
 
-    Key timing:
-    - AfterTargets="ResolveAssemblyReferences" ensures we have all references resolved
-    - BeforeTargets="_gRPC_GetProtoc;CoreCompile" ensures proto is generated before:
-      1. Grpc.Tools compiles the proto into C# (_gRPC_GetProtoc is Grpc.Tools' entry point)
-      2. CoreCompile compiles the project
-  -->
-  <Target Name="SvrntyGenerateProtoFile"
-          BeforeTargets="_gRPC_GetProtoc;CoreCompile"
-          AfterTargets="ResolveAssemblyReferences"
-          DependsOnTargets="EnsureProtosDirectory"
-          Condition="'$(GenerateProtoFile)' == 'true' AND '$(_GeneratorsAssemblyPath)' != ''">
-
-    <Message Text="Svrnty.CQRS.Grpc: Generating proto file from $(MSBuildProjectName)..." Importance="high" />
-    <Message Text="Svrnty.CQRS.Grpc: Source files count: @(Compile->Count())" Importance="normal" />
-    <Message Text="Svrnty.CQRS.Grpc: References count: @(ReferencePath->Count())" Importance="normal" />
-
-    <GenerateProtoFileTask
+    <WriteProtoFileTask
       ProjectDirectory="$(MSBuildProjectDirectory)"
+      IntermediateOutputPath="$(IntermediateOutputPath)"
       OutputDirectory="$(ProtoOutputDirectory)"
-      ProtoFileName="$(GeneratedProtoFileName)"
-      SourceFiles="@(Compile)"
-      References="@(ReferencePath)"
-      RootNamespace="$(RootNamespace)"
-      AssemblyName="$(AssemblyName)" />
+      ProtoFileName="$(GeneratedProtoFileName)" />
   </Target>
 </Project>

Svrnty.CQRS.Grpc/CqrsBuilderExtensions.cs

@@ -33,7 +33,6 @@ public static class CqrsBuilderExtensions
         {
             Console.WriteLine("Warning: AddGrpcFromConfiguration not found. gRPC services were not registered.");
             Console.WriteLine("Make sure your project has source generators enabled and references Svrnty.CQRS.Grpc.Generators.");
-            DiagnoseGeneratedCode();
         }
 
         // Register mapping callback for automatic endpoint mapping
@@ -50,59 +49,6 @@ public static class CqrsBuilderExtensions
         return builder;
     }
 
-    private static void DiagnoseGeneratedCode()
-    {
-        var entryAsm = Assembly.GetEntryAssembly();
-        if (entryAsm == null)
-        {
-            Console.WriteLine("Diagnostic: Entry assembly is null");
-            return;
-        }
-
-        Console.WriteLine($"Diagnostic: Entry assembly = {entryAsm.GetName().Name}");
-
-        try
-        {
-            var allTypes = entryAsm.GetTypes();
-            Console.WriteLine($"Diagnostic: Total types in entry assembly = {allTypes.Length}");
-
-            var grpcTypes = allTypes
-                .Where(t => t.FullName?.Contains("Grpc") == true)
-                .ToList();
-
-            if (grpcTypes.Any())
-            {
-                Console.WriteLine("Diagnostic: Found Grpc-related types:");
-                foreach (var t in grpcTypes)
-                {
-                    Console.WriteLine($"  - {t.FullName} (IsClass={t.IsClass}, IsSealed={t.IsSealed}, IsPublic={t.IsPublic})");
-
-                    // Check for our target method
-                    var method = t.GetMethod("AddGrpcFromConfiguration", BindingFlags.Static | BindingFlags.Public);
-                    if (method != null)
-                        Console.WriteLine($"    -> HAS AddGrpcFromConfiguration method!");
-                }
-            }
-            else
-            {
-                Console.WriteLine("Diagnostic: No Grpc-related types found. Source generator did NOT run.");
-            }
-        }
-        catch (ReflectionTypeLoadException ex)
-        {
-            Console.WriteLine($"Diagnostic: ReflectionTypeLoadException - {ex.Message}");
-            foreach (var le in ex.LoaderExceptions)
-            {
-                if (le != null)
-                    Console.WriteLine($"  LoaderException: {le.Message}");
-            }
-        }
-        catch (Exception ex)
-        {
-            Console.WriteLine($"Diagnostic: Exception - {ex.GetType().Name}: {ex.Message}");
-        }
-    }
-
     private static MethodInfo? FindExtensionMethod(string methodName, Type parameterType)
     {
         // Search through all loaded assemblies for the extension method

Svrnty.CQRS.MinimalApi/EndpointRouteBuilderExtensions.cs

@@ -83,7 +83,8 @@ public static class EndpointRouteBuilderExtensions
         .Produces(200, queryMeta.QueryResultType)
         .Produces(400)
         .Produces(401)
-        .Produces(403);
+        .Produces(403)
+        .WithAllowAnonymousIfAttributePresent(queryMeta.QueryType);
     }
 
     private static void MapQueryGet(
@@ -146,7 +147,8 @@ public static class EndpointRouteBuilderExtensions
         .Produces(200, queryMeta.QueryResultType)
         .Produces(400)
         .Produces(401)
-        .Produces(403);
+        .Produces(403)
+        .WithAllowAnonymousIfAttributePresent(queryMeta.QueryType);
     }
 
     public static IEndpointRouteBuilder MapSvrntyCommands(this IEndpointRouteBuilder endpoints, string routePrefix = "api/command")
@@ -213,7 +215,8 @@ public static class EndpointRouteBuilderExtensions
         .Produces(200)
         .Produces(400)
         .Produces(401)
-        .Produces(403);
+        .Produces(403)
+        .WithAllowAnonymousIfAttributePresent(commandMeta.CommandType);
     }
 
     private static void MapCommandWithResult(
@@ -260,6 +263,17 @@ public static class EndpointRouteBuilderExtensions
         .Produces(200, commandMeta.CommandResultType)
         .Produces(400)
         .Produces(401)
-        .Produces(403);
+        .Produces(403)
+        .WithAllowAnonymousIfAttributePresent(commandMeta.CommandType);
+    }
+
+    private static RouteHandlerBuilder WithAllowAnonymousIfAttributePresent(this RouteHandlerBuilder builder, Type type)
+    {
+        var allowAnonymousAttribute = type.GetCustomAttribute<Microsoft.AspNetCore.Authorization.AllowAnonymousAttribute>();
+        if (allowAnonymousAttribute != null)
+        {
+            builder.AllowAnonymous();
+        }
+        return builder;
     }
 }

Svrnty.CQRS.MinimalApi/WebApplicationExtensions.cs

@@ -2,7 +2,7 @@ using Microsoft.AspNetCore.Builder;
 using Microsoft.Extensions.DependencyInjection;
 using Svrnty.CQRS.Configuration;
 
-namespace Svrnty.CQRS;
+namespace Svrnty.CQRS.MinimalApi;
 
 public static class WebApplicationExtensions
 {

Svrnty.CQRS/Configuration/CqrsBuilder.cs

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

@@ -26,10 +26,6 @@
     <None Include="..\README.md" Pack="true" PackagePath="" CopyToOutputDirectory="Always" />
   </ItemGroup>
 
-  <ItemGroup>
-    <FrameworkReference Include="Microsoft.AspNetCore.App" />
-  </ItemGroup>
-
   <ItemGroup>
     <ProjectReference Include="..\Svrnty.CQRS.Abstractions\Svrnty.CQRS.Abstractions.csproj" />
   </ItemGroup>

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.CQRS.MinimalApi;
 using Svrnty.Sample;
+using Svrnty.CQRS.MinimalApi;
+using Svrnty.CQRS.DynamicQuery;
+using Svrnty.CQRS.Abstractions;
 
 var builder = WebApplication.CreateBuilder(args);
 

Svrnty.Sample/SimpleAsyncQueryableService.cs

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