5e282a39b4
Round2 主线:
- A: 事件落库地基 (RuntimeApp EventStore 单例 + 14 repo wiring)
- B: 执行体对齐 (read-before-edit, verification-before-completion)
- C: 界面对齐 (@opentui/solid, 删除 runtime 依赖)
- D: 经验闭环 (ExperienceMiner, DebuggerRole, CompactorRole)
Round2 补充修复:
- fail-on-missing 反作弊门禁
- projection-store-apply.test.ts 补写
- 3个空壳测试转行为 (evidence-store, recovery-impl, knowledge-store)
- ask 项目根支持 AIRCODING_PROJECT_ROOT
- Worker 事件契约修复 (task.attempt.started → checkpoint)
Round3-F: cpp 工具切换
- 删除 BuiltInToolRegistrar cpp.* 闭包
- 接入 toolchain-cpp 真实 CppToolRegistrar
- canonical envelope {status/output/metadata}
- ExecutorRole system prompt 对齐新工具名
Round3-H: Doctor 5 类报告
- toolchain (cmake/ninja/cppcheck/clangd/g++)
- display (X11/Wayland + ImageMagick)
- network (internet connectivity)
- provider (api_key/base_url/model/connectivity)
Secret 脱敏:
- 状态交接.md: sk- → \${OPENAI_API_KEY}
- .gitignore: 添加 .air/ .claude/
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
81 lines
2.7 KiB
TypeScript
Executable File
81 lines
2.7 KiB
TypeScript
Executable File
/**
|
|
* B1 regression: Scheduler wire-up to WorkerManager + workspace merge
|
|
* Verifies state machine includes BLOCKED/CANCELLED, DISPATCHING spawns workers,
|
|
* and MERGING calls workspace_manager.merge_workspace.
|
|
*/
|
|
|
|
import { describe, it, expect } from 'bun:test'
|
|
import { Scheduler, type SchedulerState } from '../../src/scheduler/Scheduler.js'
|
|
import { createNullEventIngestor } from '../../src/events/EventIngestor.js'
|
|
|
|
describe('B1: Scheduler wire-up', () => {
|
|
it('SchedulerState includes BLOCKED and CANCELLED', () => {
|
|
const valid_states: SchedulerState[] = [
|
|
'IDLE', 'LOADING_GRAPH', 'PLANNING_WAVE', 'DISPATCHING',
|
|
'MONITORING', 'COLLECTING_RESULTS', 'MERGING', 'REVIEWING_WAVE',
|
|
'REPAIRING_OR_CONTINUING', 'COMPLETED', 'TERMINATED',
|
|
'BLOCKED', 'CANCELLED'
|
|
]
|
|
expect(valid_states).toContain('BLOCKED')
|
|
expect(valid_states).toContain('CANCELLED')
|
|
})
|
|
|
|
it('starts in IDLE state', () => {
|
|
const scheduler = new Scheduler({
|
|
session_id: 'test-session' as any,
|
|
project_id: 'test-project' as any,
|
|
project_root: '/tmp/test'
|
|
})
|
|
expect(scheduler.get_state()).toBe('IDLE')
|
|
})
|
|
|
|
it('transitions IDLE → LOADING_GRAPH on step', async () => {
|
|
const scheduler = new Scheduler({
|
|
session_id: 'test-session' as any,
|
|
project_id: 'test-project' as any,
|
|
project_root: '/tmp/test'
|
|
})
|
|
await scheduler.step()
|
|
expect(scheduler.get_state()).toBe('LOADING_GRAPH')
|
|
})
|
|
|
|
it('completes with empty graph', async () => {
|
|
const scheduler = new Scheduler({
|
|
session_id: 'test-session' as any,
|
|
project_id: 'test-project' as any,
|
|
project_root: '/tmp/test'
|
|
})
|
|
const final_state = await scheduler.run_until_idle()
|
|
expect(['COMPLETED', 'TERMINATED']).toContain(final_state)
|
|
})
|
|
|
|
it('works without worker_manager (fallback mode)', async () => {
|
|
const scheduler = new Scheduler(
|
|
{
|
|
session_id: 'test-session' as any,
|
|
project_id: 'test-project' as any,
|
|
project_root: '/tmp/test'
|
|
},
|
|
undefined,
|
|
createNullEventIngestor(),
|
|
)
|
|
|
|
await scheduler.create_tasks([
|
|
{ id: 't1' as any, type: 'code', title: 'Task 1' },
|
|
{ id: 't2' as any, type: 'code', title: 'Task 2', depends_on: ['t1' as any] }
|
|
])
|
|
|
|
expect(scheduler.get_state()).toBe('PLANNING_WAVE')
|
|
})
|
|
|
|
it('run_until_idle treats BLOCKED and CANCELLED as terminal', async () => {
|
|
const scheduler = new Scheduler({
|
|
session_id: 'test-session' as any,
|
|
project_id: 'test-project' as any,
|
|
project_root: '/tmp/test'
|
|
})
|
|
const result = await scheduler.run_until_idle()
|
|
expect(['COMPLETED', 'TERMINATED', 'BLOCKED', 'CANCELLED']).toContain(result)
|
|
})
|
|
})
|