Pine/deepseek-harness
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases 1 Wiki Activity

Merge branch 'codex/simp-hide-concrete-agent-loop' into codex/simp-hide-subagent-internals

Browse Source
This commit is contained in:
Tianyi Cui
2026-07-15 23:37:12 +08:00
parent 9bba95ff7c 8d4c1e2a58
commit e1160cda8c
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/tasks/tool-tasks/tests/tool-tasks.spec.ts
+8 -7
View File
@@ -5,6 +5,7 @@ import SystemPrompt from '@deepseek-ai/dsh-system-prompt'
import ToolRegistry from '@deepseek-ai/dsh-tools' import ToolRegistry from '@deepseek-ai/dsh-tools'
import AgentRegistry from '@deepseek-ai/dsh-agent' import AgentRegistry from '@deepseek-ai/dsh-agent'
import type { Agent } from '@deepseek-ai/dsh-agent' import type { Agent } from '@deepseek-ai/dsh-agent'
import { SessionId } from '@deepseek-ai/dsh-session'
import TaskService from '@deepseek-ai/dsh-tasks' import TaskService from '@deepseek-ai/dsh-tasks'
import type { TaskHooks, TaskOutcome, TaskSnapshot, TaskStart } from '@deepseek-ai/dsh-tasks' import type { TaskHooks, TaskOutcome, TaskSnapshot, TaskStart } from '@deepseek-ai/dsh-tasks'
import * as ToolTasks from '@deepseek-ai/dsh-tool-tasks' import * as ToolTasks from '@deepseek-ai/dsh-tool-tasks'
@@ -23,17 +24,17 @@ async function setup(config: ToolTasks.Config = {}) {
} }
/** /**
* A fake agent whose session token is `sessionId`, registered in `ctx.agents`. * A fake agent with the shared agent/session identity, registered in
* The agent id is deliberately different so session authorization and exact * `ctx.agents` with a dedicated lifecycle scope.
* lifecycle ownership cannot be confused in tests.
*/ */
function fakeAgent(ctx: Context, sessionId: string, inject: (...args: unknown[]) => void = () => {}): Agent { function fakeAgent(ctx: Context, sessionId: string, inject: (...args: unknown[]) => void = () => {}): Agent {
const scopeFiber = ctx.plugin(() => {}) const scopeFiber = ctx.plugin(() => {})
const id = SessionId(sessionId)
const agent = { const agent = {
id: `agent-${sessionId}`, id,
ctx: scopeFiber.ctx, ctx: scopeFiber.ctx,
inject, inject,
session: { header: { version: 0, id: sessionId, createdAt: 0 } }, session: { id, header: { version: 0, id, createdAt: 0 } },
} as unknown as Agent } as unknown as Agent
agentRegistryDisposers.set(agent, ctx.agents.register(agent)) agentRegistryDisposers.set(agent, ctx.agents.register(agent))
return agent return agent
@@ -276,7 +277,7 @@ describe('completion notices', () => {
await tick() await tick()
// Disposed owner: inject throws the disposed message — contained. // Disposed owner: inject throws the disposed message — contained.
const inject = vi.fn(() => { throw new Error('agent "agent-sess-1" is disposed') }) const inject = vi.fn(() => { throw new Error('agent "sess-1" is disposed') })
const owner = fakeAgent(ctx, 'sess-1', inject) const owner = fakeAgent(ctx, 'sess-1', inject)
const p = producer({ owner }) const p = producer({ owner })
ctx.tasks.start(p.spec) ctx.tasks.start(p.spec)
@@ -287,7 +288,7 @@ describe('completion notices', () => {
it('does not route an old owner completion notice to a same-session replacement', async () => { it('does not route an old owner completion notice to a same-session replacement', async () => {
const { ctx } = await setup() const { ctx } = await setup()
const oldInject = vi.fn(() => { throw new Error('agent "agent-shared" is disposed') }) const oldInject = vi.fn(() => { throw new Error('agent "shared" is disposed') })
const oldOwner = fakeAgent(ctx, 'shared', oldInject) const oldOwner = fakeAgent(ctx, 'shared', oldInject)
const p = producer({ owner: oldOwner }) const p = producer({ owner: oldOwner })
ctx.tasks.start(p.spec) ctx.tasks.start(p.spec)