From 52b9ddd4a7e32c00c7a791c2c00a262cda7042b5 Mon Sep 17 00:00:00 2001 From: gewuyou <95328647+GeWuYou@users.noreply.github.com> Date: Wed, 29 Apr 2026 18:00:07 +0800 Subject: [PATCH] =?UTF-8?q?test(cqrs):=20=E8=A1=A5=E5=85=85=E4=B8=8A?= =?UTF-8?q?=E4=B8=8B=E6=96=87=E5=89=8D=E7=BD=AE=E6=9D=A1=E4=BB=B6=E5=A4=B1?= =?UTF-8?q?=E8=B4=A5=E5=9B=9E=E5=BD=92?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 新增 dispatcher 上下文校验测试，锁定非 IArchitectureContext 上下文的 request、notification 与 stream 失败语义 - 通过公开 runtime 工厂与最小容器 mock 覆盖调用前校验路径，不改 runtime 实现 - 更新 cqrs-rewrite 跟踪与 trace，记录 RP-060 的验证结论 --- .../CqrsDispatcherContextValidationTests.cs | 165 ++++++++++++++++++ .../todos/cqrs-rewrite-migration-tracking.md | 12 +- .../traces/cqrs-rewrite-migration-trace.md | 17 ++ 3 files changed, 192 insertions(+), 2 deletions(-) create mode 100644 GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs diff --git a/GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs b/GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs new file mode 100644 index 00000000..bf1998a9 --- /dev/null +++ b/GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs @@ -0,0 +1,165 @@ +using System.Collections.Generic; +using System.Runtime.CompilerServices; +using GFramework.Core.Abstractions.Ioc; +using GFramework.Core.Abstractions.Logging; +using GFramework.Cqrs.Abstractions.Cqrs; +using GFramework.Cqrs.Cqrs; +using GFramework.Cqrs.Tests.Logging; + +namespace GFramework.Cqrs.Tests.Cqrs; + +/// +/// 验证默认 dispatcher 在上下文注入前置条件不满足时的失败语义。 +/// +[TestFixture] +internal sealed class CqrsDispatcherContextValidationTests +{ + /// + /// 验证当 request handler 需要上下文注入、但当前 CQRS 上下文不实现 时， + /// dispatcher 会在调用前显式失败。 + /// + [Test] + public void SendAsync_Should_Throw_When_Context_Does_Not_Implement_IArchitectureContext() + { + var runtime = CreateRuntime( + container => + { + container + .Setup(currentContainer => currentContainer.Get(typeof(IRequestHandler))) + .Returns(new ContextAwareRequestHandler()); + container + .Setup(currentContainer => currentContainer.GetAll(typeof(IPipelineBehavior))) + .Returns(Array.Empty()); + }); + + Assert.That( + async () => await runtime.SendAsync(new FakeCqrsContext(), new ContextAwareRequest()).ConfigureAwait(false), + Throws.InvalidOperationException.With.Message.Contains("does not implement IArchitectureContext")); + } + + /// + /// 验证当 notification handler 需要上下文注入、但当前 CQRS 上下文不实现 时， + /// dispatcher 会在发布前显式失败。 + /// + [Test] + public void PublishAsync_Should_Throw_When_Context_Does_Not_Implement_IArchitectureContext() + { + var runtime = CreateRuntime( + container => + { + container + .Setup(currentContainer => currentContainer.GetAll(typeof(INotificationHandler))) + .Returns([new ContextAwareNotificationHandler()]); + }); + + Assert.That( + async () => await runtime.PublishAsync(new FakeCqrsContext(), new ContextAwareNotification()).ConfigureAwait(false), + Throws.InvalidOperationException.With.Message.Contains("does not implement IArchitectureContext")); + } + + /// + /// 验证当 stream handler 需要上下文注入、但当前 CQRS 上下文不实现 时， + /// dispatcher 会在建流前显式失败。 + /// + [Test] + public void CreateStream_Should_Throw_When_Context_Does_Not_Implement_IArchitectureContext() + { + var runtime = CreateRuntime( + container => + { + container + .Setup(currentContainer => currentContainer.Get(typeof(IStreamRequestHandler))) + .Returns(new ContextAwareStreamHandler()); + }); + + Assert.That( + () => runtime.CreateStream(new FakeCqrsContext(), new ContextAwareStreamRequest()), + Throws.InvalidOperationException.With.Message.Contains("does not implement IArchitectureContext")); + } + + /// + /// 创建一个只满足当前测试最小依赖面的 dispatcher runtime。 + /// + /// 对容器 mock 的额外配置。 + /// 默认 CQRS runtime。 + private static GFramework.Cqrs.Abstractions.Cqrs.ICqrsRuntime CreateRuntime( + Action> configureContainer) + { + var container = new Mock(MockBehavior.Strict); + var logger = new TestLogger("CqrsDispatcherContextValidationTests", LogLevel.Debug); + + configureContainer(container); + return CqrsRuntimeFactory.CreateRuntime(container.Object, logger); + } + + /// + /// 为失败语义测试提供最小 CQRS 上下文标记，但故意不实现架构上下文能力。 + /// + private sealed class FakeCqrsContext : ICqrsContext + { + } + + /// + /// 为 request 上下文校验提供最小测试请求。 + /// + private sealed record ContextAwareRequest : IRequest; + + /// + /// 为 notification 上下文校验提供最小测试通知。 + /// + private sealed record ContextAwareNotification : INotification; + + /// + /// 为 stream 上下文校验提供最小测试请求。 + /// + private sealed record ContextAwareStreamRequest : IStreamRequest; + + /// + /// 为 request 上下文校验提供需要注入架构上下文的最小 handler。 + /// + private sealed class ContextAwareRequestHandler : CqrsContextAwareHandlerBase, IRequestHandler + { + /// + /// 返回固定结果；当前测试只关心调用前的上下文校验。 + /// + public ValueTask Handle(ContextAwareRequest request, CancellationToken cancellationToken) + { + return ValueTask.FromResult(1); + } + } + + /// + /// 为 notification 上下文校验提供需要注入架构上下文的最小 handler。 + /// + private sealed class ContextAwareNotificationHandler + : CqrsContextAwareHandlerBase, + INotificationHandler + { + /// + /// 返回已完成任务；当前测试只关心调用前的上下文校验。 + /// + public ValueTask Handle(ContextAwareNotification notification, CancellationToken cancellationToken) + { + return ValueTask.CompletedTask; + } + } + + /// + /// 为 stream 上下文校验提供需要注入架构上下文的最小 handler。 + /// + private sealed class ContextAwareStreamHandler + : CqrsContextAwareHandlerBase, + IStreamRequestHandler + { + /// + /// 返回一个最小流；当前测试只关心建流前的上下文校验。 + /// + public async IAsyncEnumerable Handle( + ContextAwareStreamRequest request, + [EnumeratorCancellation] CancellationToken cancellationToken) + { + yield return 1; + await ValueTask.CompletedTask.ConfigureAwait(false); + } + } +} diff --git a/ai-plan/public/cqrs-rewrite/todos/cqrs-rewrite-migration-tracking.md b/ai-plan/public/cqrs-rewrite/todos/cqrs-rewrite-migration-tracking.md index fec9f710..da5f6f2e 100644 --- a/ai-plan/public/cqrs-rewrite/todos/cqrs-rewrite-migration-tracking.md +++ b/ai-plan/public/cqrs-rewrite/todos/cqrs-rewrite-migration-tracking.md @@ -7,7 +7,7 @@ CQRS 迁移与收敛。 ## 当前恢复点 -- 恢复点编号：`CQRS-REWRITE-RP-059` +- 恢复点编号：`CQRS-REWRITE-RP-060` - 当前阶段：`Phase 8` - 当前焦点： - 当前功能历史已归档，active 跟踪仅保留 `Phase 8` 主线的恢复入口 @@ -19,6 +19,7 @@ CQRS 迁移与收敛。 - 已补充 dispatcher pipeline executor 缓存与双行为顺序回归，锁定缓存复用后仍保持现有行为执行顺序 - 已补充 cached request pipeline executor 的上下文刷新回归，锁定 executor 复用时仍会为当次 handler / singleton behavior 重新注入当前 `ArchitectureContext` - 已补充 cached notification / stream dispatch binding 的上下文刷新回归，锁定 binding 复用时仍会为当次 handler 重新注入当前 `ArchitectureContext` + - 已补充非 `IArchitectureContext` 的 dispatcher 失败语义回归，锁定 context-aware request / notification / stream handler 在注入前置条件不满足时会显式抛出异常 - 已完成 generated registry 激活路径收敛：`CqrsHandlerRegistrar` 现优先复用缓存工厂委托，避免重复 `ConstructorInfo.Invoke` - 已补充私有无参构造 generated registry 的回归测试，确保兼容现有生成器产物 - 已修正 pointer / function pointer 泛型合同的错误覆盖：生成器不再为这两类类型发射 precise runtime type 重建代码 @@ -101,6 +102,10 @@ CQRS 迁移与收敛。 - `GFramework.Cqrs.Tests` 已新增 `DispatcherNotificationContextRefresh*` 与 `DispatcherStreamContextRefresh*` 测试替身，分别记录 notification handler 与 stream handler 在重复分发时观察到的实例身份与 `ArchitectureContext` - `CqrsDispatcherCacheTests` 现明确断言：同一个 cached notification / stream dispatch binding 在重复分发时会继续命中同一 binding，但不会跨分发保留旧上下文 - 本轮定向测试未暴露新的 runtime 缺口，因此没有改动 `GFramework.Cqrs/Internal/CqrsDispatcher.cs` +- `2026-04-29` 已完成一轮 dispatcher 上下文前置条件失败语义回归： + - `GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs` 已通过公开工厂 `CqrsRuntimeFactory.CreateRuntime(...)` 锁定默认 dispatcher 的失败语义 + - 当 context-aware request / notification / stream handler 遇到仅实现 `ICqrsContext`、但未实现 `IArchitectureContext` 的上下文时，dispatcher 会在调用前显式抛出 `InvalidOperationException` + - 本轮只补测试，不改 runtime 实现与文档口径 - `2026-04-29` 已接受一轮 delegated 叶子级 fallback 合同测试： - `GFramework.Cqrs.Tests/Cqrs/CqrsReflectionFallbackAttributeTests.cs` 已锁定空 marker、字符串 fallback 名称去空/去重/排序、直接 `Type` fallback 去空/去重/排序与空参数数组防御语义 - 当前 runtime 读取程序集级 fallback 元数据时所依赖的 attribute 归一化合同，现已有独立叶子级测试文件覆盖 @@ -140,6 +145,9 @@ CQRS 迁移与收敛。 - `dotnet test GFramework.Cqrs.Tests/GFramework.Cqrs.Tests.csproj -c Release --filter "FullyQualifiedName~GFramework.Cqrs.Tests.Cqrs.CqrsDispatcherCacheTests"` - 结果：通过 - 备注：`7/7` 测试通过；本轮新增 cached notification / stream binding 上下文刷新回归，确认 binding 复用时仍按当次分发重新注入上下文 +- `dotnet test GFramework.Cqrs.Tests/GFramework.Cqrs.Tests.csproj -c Release --filter "FullyQualifiedName~GFramework.Cqrs.Tests.Cqrs.CqrsDispatcherContextValidationTests"` + - 结果：通过 + - 备注：`3/3` 测试通过；本轮锁定默认 dispatcher 对非 `IArchitectureContext` 上下文的 request / notification / stream 失败语义，且未引入新增 warning - `dotnet test GFramework.Cqrs.Tests/GFramework.Cqrs.Tests.csproj -c Release --no-restore -p:RestoreFallbackFolders= -m:1 -nodeReuse:false` - 结果：通过 - 备注：`63/63` 测试通过；当前沙箱限制了 MSBuild named pipe，验证需在提权环境下运行 @@ -209,6 +217,6 @@ CQRS 迁移与收敛。 ## 下一步 -1. 继续 `Phase 8` 主线，优先再找一个收益明确且写集独立的 generator 或 registrar/dispatcher 热点；当前工作区若提交主线程 notification / stream 回归批次，相对 `origin/main` 的累计 diff 将达到 `29 files`，仍低于本轮 `gframework-batch-boot 50` 的主要 stop condition +1. 继续 `Phase 8` 主线，优先再找一个收益明确且写集独立的 generator 或 registrar/dispatcher 热点；当前工作区若提交 dispatcher 上下文前置条件回归批次，相对 `origin/main` 的累计 diff 将达到 `31 files`，仍低于本轮 `gframework-batch-boot 50` 的主要 stop condition 2. 若继续文档主线，优先再扫教程入口页与 API 参考中的 CQRS 采用说明，确认是否还有旧 Command / Query 迁移口径残留 3. 若后续再出现新的 PR review 或 review thread 变化，再重新执行 `$gframework-pr-review` 作为独立验证步骤 diff --git a/ai-plan/public/cqrs-rewrite/traces/cqrs-rewrite-migration-trace.md b/ai-plan/public/cqrs-rewrite/traces/cqrs-rewrite-migration-trace.md index 41a14f44..1e376e35 100644 --- a/ai-plan/public/cqrs-rewrite/traces/cqrs-rewrite-migration-trace.md +++ b/ai-plan/public/cqrs-rewrite/traces/cqrs-rewrite-migration-trace.md @@ -2,6 +2,23 @@ ## 2026-04-29 +### 阶段：dispatcher 上下文前置条件失败语义回归（CQRS-REWRITE-RP-060） + +- 延续 `gframework-batch-boot 50` 的 `Phase 8` 主线，本轮选择一个新的单文件测试切片：锁定默认 dispatcher 对“仅实现 `ICqrsContext`、但未实现 `IArchitectureContext` 的上下文”会如何失败 +- 主线程先复核当前公开契约与实现后确认： + - `GFramework.Cqrs.Abstractions.Cqrs.ICqrsRuntime` 的 XML 文档已经把这类失败语义写成公开契约 + - `CqrsDispatcher.PrepareHandler(...)` 当前正是唯一的上下文前置条件检查点，因此本轮最稳妥的切片仍是测试补强，而不是继续改 runtime +- 已完成的测试补强： + - 新增 `GFramework.Cqrs.Tests/Cqrs/CqrsDispatcherContextValidationTests.cs` + - 通过 `CqrsRuntimeFactory.CreateRuntime(...)` + `Mock` 构造最小 runtime，分别锁定 request、notification、stream 三条路径的失败语义 + - 三个测试都只在需要上下文注入的 handler 已解析出来时触发，避免把“找不到 handler”与“上下文不满足注入前置条件”混淆成同一种异常 +- 定向验证已通过： + - `dotnet test GFramework.Cqrs.Tests/GFramework.Cqrs.Tests.csproj -c Release --filter "FullyQualifiedName~GFramework.Cqrs.Tests.Cqrs.CqrsDispatcherContextValidationTests"` + - `3/3` passed +- 结果： + - 本轮只补测试，不改 `GFramework.Cqrs/Internal/CqrsDispatcher.cs` + - 若连同当前工作区一起计算，当前分支相对 `origin/main` 的累计 diff 将达到 `31 files` + ### 阶段：notification / stream binding 上下文刷新回归（CQRS-REWRITE-RP-059） - 延续 `gframework-batch-boot 50` 的 `Phase 8` 主线，本轮继续沿着上一批 dispatcher cached executor 上下文回归往外扩一圈，但只覆盖 notification / stream 两条非 request 路径