diff --git a/GFramework.Core.Tests/Command/CommandExecutorTests.cs b/GFramework.Core.Tests/Command/CommandExecutorTests.cs index 21c6bc27..aad98ca3 100644 --- a/GFramework.Core.Tests/Command/CommandExecutorTests.cs +++ b/GFramework.Core.Tests/Command/CommandExecutorTests.cs @@ -126,6 +126,7 @@ public class CommandExecutorTests { Assert.That(result, Is.EqualTo(123)); Assert.That(runtime.LastRequest, Is.TypeOf()); + Assert.That(command.ObservedContext, Is.SameAs(expectedContext)); }); } diff --git a/GFramework.Core.Tests/Command/RecordingCqrsRuntime.cs b/GFramework.Core.Tests/Command/RecordingCqrsRuntime.cs index d85df9a0..5dd07317 100644 --- a/GFramework.Core.Tests/Command/RecordingCqrsRuntime.cs +++ b/GFramework.Core.Tests/Command/RecordingCqrsRuntime.cs @@ -1,6 +1,8 @@ // Copyright (c) 2025-2026 GeWuYou // SPDX-License-Identifier: Apache-2.0 +using GFramework.Core.Abstractions.Rule; +using GFramework.Core.Cqrs; using GFramework.Cqrs.Abstractions.Cqrs; namespace GFramework.Core.Tests.Command; @@ -25,7 +27,7 @@ internal sealed class RecordingCqrsRuntime(Func? responseFacto public object? LastRequest { get; private set; } /// - public ValueTask SendAsync( + public async ValueTask SendAsync( ICqrsContext context, IRequest request, CancellationToken cancellationToken = default) @@ -38,11 +40,34 @@ internal sealed class RecordingCqrsRuntime(Func? responseFacto object? response = request switch { + LegacyCommandDispatchRequest legacyCommandDispatchRequest => ExecuteLegacyCommand(context, legacyCommandDispatchRequest), + LegacyCommandResultDispatchRequest legacyCommandResultDispatchRequest => ExecuteContextAwareRequest( + context, + legacyCommandResultDispatchRequest.Target, + legacyCommandResultDispatchRequest.Execute), + LegacyQueryDispatchRequest legacyQueryDispatchRequest => ExecuteContextAwareRequest( + context, + legacyQueryDispatchRequest.Target, + legacyQueryDispatchRequest.Execute), + LegacyAsyncCommandDispatchRequest legacyAsyncCommandDispatchRequest => await ExecuteLegacyAsyncCommandAsync( + context, + legacyAsyncCommandDispatchRequest, + cancellationToken).ConfigureAwait(false), + LegacyAsyncCommandResultDispatchRequest legacyAsyncCommandResultDispatchRequest => await ExecuteContextAwareRequestAsync( + context, + legacyAsyncCommandResultDispatchRequest.Target, + legacyAsyncCommandResultDispatchRequest.ExecuteAsync, + cancellationToken).ConfigureAwait(false), + LegacyAsyncQueryDispatchRequest legacyAsyncQueryDispatchRequest => await ExecuteContextAwareRequestAsync( + context, + legacyAsyncQueryDispatchRequest.Target, + legacyAsyncQueryDispatchRequest.ExecuteAsync, + cancellationToken).ConfigureAwait(false), IRequest => Unit.Value, _ => _responseFactory(request) }; - return ValueTask.FromResult((TResponse)response!); + return ConvertResponse(request, response); } /// @@ -63,4 +88,120 @@ internal sealed class RecordingCqrsRuntime(Func? responseFacto { throw new NotSupportedException(); } + + /// + /// 将测试替身工厂返回的装箱结果显式还原为目标类型,并在类型不匹配时给出可诊断异常。 + /// + /// 当前请求声明的响应类型。 + /// 触发响应工厂的请求实例。 + /// 响应工厂返回的装箱结果。 + /// 还原后的目标类型响应。 + /// + /// 响应工厂返回 或错误类型,导致无法还原为 。 + /// + private static TResponse ConvertResponse(IRequest request, object? response) + { + if (response is TResponse typedResponse) + { + return typedResponse; + } + + if (response is null && !typeof(TResponse).IsValueType) + { + return (TResponse)response!; + } + + string actualType = response?.GetType().FullName ?? "null"; + throw new InvalidOperationException( + $"RecordingCqrsRuntime 无法将响应类型从 '{actualType}' 转换为 '{typeof(TResponse).FullName}'。" + + $" 请求类型:'{request.GetType().FullName}'。"); + } + + /// + /// 按 bridge handler 语义为 legacy 无返回值命令注入上下文并执行。 + /// + /// 当前运行时接收到的架构上下文。 + /// 待执行的 legacy 命令桥接请求。 + /// 桥接后的 响应。 + private static Unit ExecuteLegacyCommand( + ICqrsContext context, + LegacyCommandDispatchRequest request) + { + PrepareTarget(context, request.Command); + request.Command.Execute(); + return Unit.Value; + } + + /// + /// 按 bridge handler 语义为 legacy 异步无返回值命令注入上下文并执行。 + /// + /// 当前运行时接收到的架构上下文。 + /// 待执行的 legacy 异步命令桥接请求。 + /// 调用方传入的取消令牌。 + /// 表示 bridge 执行完成的异步结果。 + private static async Task ExecuteLegacyAsyncCommandAsync( + ICqrsContext context, + LegacyAsyncCommandDispatchRequest request, + CancellationToken cancellationToken) + { + PrepareTarget(context, request.Command); + await request.Command.ExecuteAsync().WaitAsync(cancellationToken).ConfigureAwait(false); + return Unit.Value; + } + + /// + /// 按 bridge handler 语义为带返回值 legacy 请求注入上下文并执行同步委托。 + /// + /// 当前运行时接收到的架构上下文。 + /// 需要接收上下文注入的 legacy 目标对象。 + /// 实际执行 legacy 目标逻辑的同步委托。 + /// 同步执行结果。 + private static object? ExecuteContextAwareRequest( + ICqrsContext context, + object target, + Func execute) + { + PrepareTarget(context, target); + return execute(); + } + + /// + /// 按 bridge handler 语义为带返回值 legacy 请求注入上下文并执行异步委托。 + /// + /// 当前运行时接收到的架构上下文。 + /// 需要接收上下文注入的 legacy 目标对象。 + /// 实际执行 legacy 目标逻辑的异步委托。 + /// 调用方传入的取消令牌。 + /// 异步执行结果。 + private static async Task ExecuteContextAwareRequestAsync( + ICqrsContext context, + object target, + Func> executeAsync, + CancellationToken cancellationToken) + { + PrepareTarget(context, target); + return await executeAsync().WaitAsync(cancellationToken).ConfigureAwait(false); + } + + /// + /// 模拟 legacy bridge handler 的上下文注入语义,使测试替身与生产桥接行为保持一致。 + /// + /// 当前运行时接收到的架构上下文。 + /// 即将执行的 legacy 目标对象。 + private static void PrepareTarget(ICqrsContext context, object target) + { + ArgumentNullException.ThrowIfNull(context); + ArgumentNullException.ThrowIfNull(target); + + if (context is not GFramework.Core.Abstractions.Architectures.IArchitectureContext architectureContext) + { + throw new InvalidOperationException( + $"RecordingCqrsRuntime 期望收到 IArchitectureContext,但实际为 '{context.GetType().FullName}'。"); + } + + if (target is IContextAware contextAware) + { + contextAware.SetContext(architectureContext); + } + } } diff --git a/GFramework.Core.Tests/Query/AsyncQueryExecutorTests.cs b/GFramework.Core.Tests/Query/AsyncQueryExecutorTests.cs index 8ac9f002..7781bc73 100644 --- a/GFramework.Core.Tests/Query/AsyncQueryExecutorTests.cs +++ b/GFramework.Core.Tests/Query/AsyncQueryExecutorTests.cs @@ -159,6 +159,7 @@ public class AsyncQueryExecutorTests { Assert.That(result, Is.EqualTo(64)); Assert.That(runtime.LastRequest, Is.TypeOf()); + Assert.That(query.ObservedContext, Is.SameAs(expectedContext)); }); } 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 b46e19bb..477ec8f7 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-096` +- 恢复点编号:`CQRS-REWRITE-RP-097` - 当前阶段:`Phase 8` - 当前 PR 锚点:`PR #334` - 当前结论: @@ -31,8 +31,9 @@ CQRS 迁移与收敛。 - `RP-093` 已把 `GFramework.Core` 的 legacy `SendCommand` / `SendQuery` 兼容入口收敛到底层统一 `GFramework.Cqrs` runtime,同时补充 `Mediator` 未吸收能力差距复核 - `RP-094` 已按 `PR #334` latest-head review 收口 legacy bridge 的测试注册方式、模块运行时依赖契约、异步取消语义、XML 文档缺口与兼容文档回退边界 - `RP-095` 已继续收口 `PR #334` 剩余 review:把 legacy 同步 bridge 的阻塞等待统一切到线程池隔离 helper、补齐 `ArchitectureContext` / executor 共享 dispatch helper、修正 bridge fixture 的并行与容器释放约束,并为 runtime bridge 与 async void command cancellation 增补回归测试 - - 当前 `RP-096` 已再次使用 `$gframework-pr-review` 复核 `PR #334` latest-head review,确认仍显示为 open 的 AI threads 在本地代码中已无新增仍成立的运行时 / 测试 / 文档缺陷,剩余差异主要是 GitHub thread 未 resolve 的状态滞后 -- `ai-plan` active 入口现以 `RP-096` 为最新恢复锚点;`PR #334`、`PR #331`、`PR #326`、`PR #323`、`PR #307` 与其他更早阶段细节均以下方归档或说明为准 + - `RP-096` 已再次使用 `$gframework-pr-review` 复核 `PR #334` latest-head review,确认仍显示为 open 的 AI threads 在本地代码中已无新增仍成立的运行时 / 测试 / 文档缺陷,剩余差异主要是 GitHub thread 未 resolve 的状态滞后 + - 当前 `RP-097` 已继续收口 `PR #334` latest-head nitpick:为 `AsyncQueryExecutorTests` / `CommandExecutorTests` 补齐可观察的上下文保留断言,并让 `RecordingCqrsRuntime` 在测试替身返回错误响应类型时抛出带请求/类型信息的诊断异常 +- `ai-plan` active 入口现以 `RP-097` 为最新恢复锚点;`PR #334`、`PR #331`、`PR #326`、`PR #323`、`PR #307` 与其他更早阶段细节均以下方归档或说明为准 ## 当前活跃事实 @@ -62,6 +63,8 @@ CQRS 迁移与收敛。 - 远端 `CTRF` 最新汇总为 `2311/2311` passed(run `#1079`, 2026-05-07) - `MegaLinter` 当前只暴露 `dotnet-format` 的 `Restore operation failed` 环境噪音,尚未提供本地仍成立的文件级格式诊断 - `PR #334` 当前 latest-head open AI feedback 经过本轮本地复核与修复后,应主要剩余待 GitHub 重新索引的状态差异或已实质关闭但未 resolve 的 thread +- `GFramework.Core.Tests` 中 legacy bridge 的“保留上下文”回归现在同时断言 bridge request 类型与目标对象执行期观察到的 `IArchitectureContext` +- `RecordingCqrsRuntime` 对非 `Unit` 响应已显式校验返回值类型;若测试工厂返回了 `null` 或错误装箱类型,异常会直接指出 request 类型与期望/实际响应类型 ## 当前风险 @@ -97,6 +100,14 @@ CQRS 迁移与收敛。 - 备注:确认当前分支对应 `PR #334`;`CodeRabbit` latest review 已 `APPROVED`,但 latest-head 仍显示 `10` 个 open thread、`Greptile` 仍显示 `3` 个 open thread;本地逐项复核后未发现新的仍成立缺陷,最新 CI 测试汇总为 `2311/2311` passed,`MegaLinter` 仅剩 `dotnet-format` restore 环境噪音 - `dotnet build GFramework.Core/GFramework.Core.csproj -c Release` - 结果:通过,`0 warning / 0 error` +- `dotnet build GFramework.Core.Tests/GFramework.Core.Tests.csproj -c Release` + - 结果:通过,`0 warning / 0 error` +- `dotnet test GFramework.Core.Tests/GFramework.Core.Tests.csproj -c Release --filter "FullyQualifiedName~CommandExecutorTests|FullyQualifiedName~AsyncQueryExecutorTests"` + - 结果:通过,`19/19` passed +- `python3 scripts/license-header.py --check` + - 结果:通过 +- `git diff --check` + - 结果:通过 - `python3 .agents/skills/gframework-pr-review/scripts/fetch_current_pr_review.py --format json --json-output ` - 结果:通过 - 备注:确认当前分支对应 `PR #331`,本轮 latest-head open AI feedback 已收敛到 `dotnet pack --no-build`、共享包校验脚本跨平台兼容性与 active 文档 PR 锚点同步 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 f083ca9b..4244a7eb 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,26 @@ ## 2026-05-07 +### 阶段:PR #334 nitpick 测试收尾(CQRS-REWRITE-RP-097) + +- 继续处理 `PR #334` latest-head review 中仍值得本地吸收的轻量 nitpick,范围限定在 legacy bridge 测试可观察性与测试替身诊断质量: + - `AsyncQueryExecutorTests.SendAsync_Should_Bridge_Through_Runtime_And_Preserve_Context` 标题声明“保留上下文”,但此前只断言了返回值与 bridge request 类型 + - `CommandExecutorTests.Send_WithResult_Should_Bridge_Through_Runtime_And_Preserve_Context` 同样缺少可观察的上下文注入断言 + - `RecordingCqrsRuntime` 直接强转响应对象,若测试工厂回错类型,失败信息不够聚焦 +- 本轮主线程决策: + - 为两个 “Preserve_Context” 用例补齐 `ObservedContext` 与 `expectedContext` 的同一实例断言,使测试标题、注释与断言对象保持一致 + - 让 `RecordingCqrsRuntime` 通过私有 helper 显式执行响应类型还原;当工厂返回 `null` 或错误装箱类型时,抛出包含 request 类型与期望/实际响应类型的 `InvalidOperationException` + - 同步刷新 `cqrs-rewrite` active tracking,把本轮 nitpick 收敛与验证结果记录为新的恢复锚点 `RP-097` +- 本轮权威验证: + - `dotnet build GFramework.Core.Tests/GFramework.Core.Tests.csproj -c Release` + - 结果:通过,`0 warning / 0 error` + - `dotnet test GFramework.Core.Tests/GFramework.Core.Tests.csproj -c Release --filter "FullyQualifiedName~CommandExecutorTests|FullyQualifiedName~AsyncQueryExecutorTests"` + - 结果:通过,`19/19` passed + - `python3 scripts/license-header.py --check` + - 结果:通过 + - `git diff --check` + - 结果:通过 + ### 阶段:PR #334 latest-head review 复核(CQRS-REWRITE-RP-096) - 再次使用 `$gframework-pr-review` 抓取 `feat/cqrs-optimization` 对应的 `PR #334` latest-head review,并读取 `/tmp/current-pr-review.json` 中的 `review_agents`、`latest_commit_review`、`megalinter_report` 与 `test_reports`