web-agent-presets.e2e.ts 38 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829
  1. import { randomUUID } from 'node:crypto'
  2. import { mkdir, mkdtemp, readFile, stat, writeFile } from 'node:fs/promises'
  3. import { tmpdir } from 'node:os'
  4. import { fileURLToPath } from 'node:url'
  5. import { dirname, join } from 'node:path'
  6. import { Context } from '@deepseek-ai/cordis'
  7. import { boot, healProfilesModuleFallback, loadOverlayPatches } from '@deepseek-ai/dsh-app-boot'
  8. import { provideCmdline } from '@deepseek-ai/dsh-cmdline'
  9. import { SessionId } from '@deepseek-ai/dsh-session'
  10. import type { Agent } from '@deepseek-ai/dsh-agent'
  11. import type { PatchOptions } from '@deepseek-ai/cordis-plugin-include'
  12. import { afterAll, beforeAll, describe, expect, it } from 'vitest'
  13. import { settingsNamespace } from '@deepseek-ai/dsh-settings'
  14. import { resolveSessionPreset, SETTINGS_NAMESPACE } from '@deepseek-ai/dsh-agent-presets'
  15. import { applyChildComposition, childSessionMeta } from '@deepseek-ai/dsh-subagent'
  16. import { CallId } from '@deepseek-ai/dsh-llm'
  17. import type {} from '@deepseek-ai/dsh-compaction-basic'
  18. import type {} from '@deepseek-ai/dsh-skill'
  19. import type {} from '@deepseek-ai/dsh-tools'
  20. // Type-only: resolves `ctx.get('sessionProjections')` and `ctx.get('tokenMeter')`.
  21. import type {} from '@deepseek-ai/dsh-session-projection'
  22. import type {} from '@deepseek-ai/dsh-token-meter'
  23. const CONFIG_DIR = fileURLToPath(new URL('../config/', import.meta.url))
  24. const REPO_ROOT = fileURLToPath(new URL('../../..', import.meta.url))
  25. /** The shipped Web surface: the dsh-base and dsh-web-app bundle patches over an empty preset root. */
  26. const BASE_PATCH = join(REPO_ROOT, 'packages/bundle/base/cordis.patch.yml')
  27. const WEB_PATCH = join(REPO_ROOT, 'packages/bundle/web-app/cordis.patch.yml')
  28. /** The installation anchor whose dependency surface the preset module fallback mirrors. */
  29. const INSTALL_ANCHOR = join(REPO_ROOT, 'apps/cli/package.json')
  30. const EXAMPLES_INSTALL_ANCHOR = join(REPO_ROOT, 'examples/package.json')
  31. const MINIMAL_PROMPT = 'You are a helpful software engineer assistant.'
  32. const MINIMAL_BASH_DESCRIPTION = `Run commands in a bash shell
  33. * When invoking this tool, the contents of the "command" parameter does NOT need to be XML-escaped.
  34. * You don't have access to the internet via this tool.
  35. * You do have access to a mirror of common linux and python packages via apt and pip.
  36. * State is persistent across command calls and discussions with the user.
  37. * To inspect a particular line range of a file, e.g. lines 10-25, try 'sed -n 10,25p /path/to/the/file'.
  38. * Please avoid commands that may produce a very large amount of output.
  39. * Please run long lived commands in the background, e.g. 'sleep 10 &' or start a server in the background.`
  40. /**
  41. * Boot the shipped Web composition, minus the rows that would bind a port,
  42. * touch the network, or write outside the test. Everything that decides an
  43. * agent's capabilities is the real thing, including both shipped presets.
  44. */
  45. async function bootWeb(
  46. settingsFile: string,
  47. extra: PatchOptions[] = [],
  48. extraInstallAnchor?: string,
  49. ): Promise<Context> {
  50. const storageRoot = join(dirname(settingsFile), 'storages')
  51. const patches: PatchOptions[] = [
  52. ...loadOverlayPatches('dsh-test', BASE_PATCH),
  53. ...loadOverlayPatches('dsh-test', WEB_PATCH),
  54. // The settings row defaults to `$DSH_HOME/settings.yaml`. Left alone it
  55. // reads the developer's own document — and since the default preset is a
  56. // setting, a stored `agent-presets.default` would decide this file's
  57. // outcome. Point it at a temp file for the same reason the roster below
  58. // names only the shipped root.
  59. { id: 'settings', config: { path: settingsFile, watch: false } },
  60. // storage-json's root is anchored to the real $DSH_HOME. Unpinned, this
  61. // file writes the developer's own `~/.dsh/storages/` — and then reads it
  62. // back on the next run, so a stored document from any other build decides
  63. // this test's boot. Same reason the settings row above is pinned.
  64. { id: 'storage-json', config: { root: storageRoot } },
  65. // Host rows with side effects outside this process: a bound port, a served
  66. // asset tree, a telemetry exporter. `api-gateway` and `directory-picker`
  67. // stay ENABLED on purpose — the api-proxy is the host row that injects
  68. // `subagents`, `workspace`, and the rest of the agent plane, so disabling
  69. // it would hide exactly the breakage this file exists to catch: a service
  70. // moved into the presets that a host row still waits for. The boot audit
  71. // is that assertion.
  72. { id: 'webserver', disabled: true },
  73. // The web bundle's runtime row injects `webServer`, so it cannot
  74. // activate without the bound port disabled above. It owns dist serving
  75. // and the URL prompt line — surface glue, not anything that decides an
  76. // agent's capabilities, which is all this file asserts.
  77. { id: 'web-runtime', disabled: true },
  78. { id: 'session-telemetry-otel', disabled: true },
  79. // A deployment-level skill on the host registry's GLOBAL layer — the same
  80. // registration shape a repository plugin's skill root uses. The layered
  81. // skills test below proves it reaches preset-composed agents.
  82. { id: 'skill-badge', disabled: false },
  83. { id: 'modules', disabled: true },
  84. { id: 'connection', disabled: true },
  85. // The always-on reload chain waits for the browser roster and bound port
  86. // disabled above.
  87. { id: 'client-hmr', disabled: true },
  88. // The shipped `-auto` chooser resolves its interaction from a running
  89. // host and so waits for the webserver disabled above; the browse variant
  90. // supplies `directoryPicker` without one.
  91. { id: 'directory-picker', disabled: true },
  92. { insert: [
  93. { id: 'directory-picker-browse', name: '@deepseek-ai/dsh-host-directory-picker-browse' },
  94. { id: 'ui-directory-picker-browse', name: '@deepseek-ai/dsh-client-ui-directory-picker-browse' },
  95. ] },
  96. // The roster AppCLIEntry would patch in; only the shipped root, so a
  97. // developer's own `~/.dsh/.preset` cannot change this test's outcome.
  98. // `default` here is the COMPOSITION default — the base layer the settings
  99. // document overrides.
  100. {
  101. id: 'agent-presets',
  102. config: {
  103. default: 'standard',
  104. roots: [{ path: join(CONFIG_DIR, 'agent-presets'), trust: 'system' }],
  105. includeUserRoot: false,
  106. },
  107. },
  108. ...extra,
  109. ]
  110. // The surface is patch layers over an empty preset root, so the root sits
  111. // outside this workspace and bare plugin names cannot resolve by Node's
  112. // upward walk. The flat fallback the preset boot maintains is what makes
  113. // them resolvable — the same mechanism, not a test-only shim.
  114. const home = dirname(settingsFile)
  115. healProfilesModuleFallback(INSTALL_ANCHOR, home)
  116. if (extraInstallAnchor !== undefined) healProfilesModuleFallback(extraInstallAnchor, home)
  117. const profileDir = join(home, 'profiles', 'spec')
  118. await mkdir(profileDir, { recursive: true })
  119. const rootConfig = join(profileDir, 'cordis.yml')
  120. await writeFile(rootConfig, '[]\n')
  121. return await boot('dsh-test', rootConfig, patches, (bootCtx) => {
  122. provideCmdline(bootCtx, { args: [], exit: () => {} })
  123. })
  124. }
  125. const toolNames = (ctx: Context, agent?: Agent): string[] =>
  126. ctx.tools.schemas(agent).map(schema => schema.name).sort()
  127. function enablePresetTool(composition: string, id: string): string {
  128. const row = ` - id: ${id}\n`
  129. const start = composition.indexOf(row)
  130. if (start < 0) throw new Error(`missing preset row ${id}`)
  131. const end = composition.indexOf('\n - id:', start + row.length)
  132. const disabled = composition.indexOf(' disabled: true\n', start)
  133. if (disabled < 0 || (end >= 0 && disabled > end)) {
  134. throw new Error(`preset row ${id} is not disabled`)
  135. }
  136. return composition.slice(0, disabled) + composition.slice(disabled + ' disabled: true\n'.length)
  137. }
  138. let ctx: Context
  139. beforeAll(async () => {
  140. const settingsFile = join(await mkdtemp(join(tmpdir(), 'dsh-web-presets-')), 'settings.yaml')
  141. await writeFile(settingsFile, '{}\n')
  142. ctx = await bootWeb(settingsFile)
  143. }, 120_000)
  144. describe('the shipped Web composition', () => {
  145. it('leaves the global tool layer empty', () => {
  146. // Every model-facing tool belongs to a preset, `ask_user_question`
  147. // included: a tool in the global layer reaches EVERY agent regardless of
  148. // which preset composed it, so a two-tool benchmark surface would really
  149. // present three. A regression here means an agent-plane row came back to
  150. // the host composition.
  151. expect(toolNames(ctx)).toEqual([])
  152. })
  153. it('keeps the token meter and its context-meter projections on the host plane', async () => {
  154. // Read before any preset in this file mounts, which is what makes this an
  155. // ownership assertion rather than a mount-order coincidence: a preset-side
  156. // meter sits behind an `isolate` realm and is invisible to `ctx.get`.
  157. //
  158. // The projection registry is process-wide rather than scope-layered, so a
  159. // preset-side meter would also make the browser's context meter appear for
  160. // a `minimal` session the moment some OTHER session mounted a preset that
  161. // carries one, and vanish entirely in a process that only ever ran
  162. // `minimal`. Host ownership is what makes the meter a per-session fact.
  163. expect(ctx.get('tokenMeter')).toBeDefined()
  164. const projections = ctx.get('sessionProjections')
  165. if (projections === undefined) throw new Error('the Web composition must compose a projection registry')
  166. const handle = await ctx.agents.create({
  167. sessionId: SessionId('preset-minimal-meter'),
  168. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  169. })
  170. try {
  171. // A subset assertion: `tasks`, `goal`, and the rest register into the
  172. // same process-wide table, and this is about the meter's three units.
  173. expect(Object.keys(projections.snapshot(handle.agent.session).values))
  174. .toEqual(expect.arrayContaining(['contextBreakdown', 'contextPressure', 'tokenUsage']))
  175. } finally {
  176. await handle.dispose()
  177. }
  178. })
  179. it('supplies both shipped presets, and only those, from the system root', async () => {
  180. const listed = await ctx.agentPresets.list()
  181. expect(listed.map(preset => preset.id).sort()).toEqual(['code', 'cordis', 'minimal', 'standard'])
  182. expect(listed.every(preset => preset.trust === 'system')).toBe(true)
  183. expect(ctx.agentPresets.defaultId).toBe('standard')
  184. })
  185. it('composes the full agent from `standard`', async () => {
  186. const handle = await ctx.agents.create({
  187. sessionId: SessionId('preset-standard'),
  188. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  189. })
  190. try {
  191. // The EXACT catalog, not a spot-check: an omission is this design's
  192. // quietest failure mode, because a row that registers into the wrong
  193. // layer mounts cleanly and simply contributes nothing. `glob`/`grep` are
  194. // excluded for the reason the TUI composition e2e excludes them — they
  195. // depend on ripgrep being present on the machine.
  196. expect(toolNames(ctx, handle.agent).filter(name => name !== 'glob' && name !== 'grep')).toEqual([
  197. 'ask_user_question', 'bash', 'create_goal', 'edit', 'exit_plan_mode',
  198. 'get_goal', 'interrupt_agent', 'job_kill', 'job_list', 'job_output', 'list_agents', 'ralph', 'read', 'read_image', 'send_message', 'skill',
  199. 'subagent', 'subagent_fork', 'todo_write', 'update_goal', 'web_search',
  200. 'workflow', 'write',
  201. ])
  202. } finally {
  203. await handle.dispose()
  204. }
  205. })
  206. it('composes the exact RL prompt and two tools from `minimal`', async () => {
  207. const handle = await ctx.agents.create({
  208. sessionId: SessionId('preset-minimal'),
  209. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  210. })
  211. try {
  212. const assembly = await ctx.systemPrompt.assemble({ scope: handle.agent })
  213. expect(assembly.sections).toEqual([
  214. { name: 'deployment:persona', text: MINIMAL_PROMPT },
  215. ])
  216. expect(assembly.tools.map(tool => tool.name)).toEqual(['bash', 'str_replace_editor'])
  217. expect(assembly.tools.find(tool => tool.name === 'bash')?.description).toBe(MINIMAL_BASH_DESCRIPTION)
  218. expect(JSON.stringify(assembly.tools.find(tool => tool.name === 'str_replace_editor')?.parameters))
  219. .toContain('Absolute path')
  220. expect(ctx.agentPresets.serviceFor(handle.agent, 'compaction')).toBeUndefined()
  221. expect(handle.agent.ctx.get('compaction')).toBeUndefined()
  222. } finally {
  223. await handle.dispose()
  224. }
  225. })
  226. it('keeps two differently composed sessions independent', async () => {
  227. const full = await ctx.agents.create({
  228. sessionId: SessionId('preset-both-full'),
  229. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  230. })
  231. const minimal = await ctx.agents.create({
  232. sessionId: SessionId('preset-both-minimal'),
  233. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  234. })
  235. try {
  236. expect(toolNames(ctx, minimal.agent)).toEqual(['bash', 'str_replace_editor'])
  237. expect(toolNames(ctx, full.agent).length).toBeGreaterThan(10)
  238. await minimal.dispose()
  239. // Tearing the minimal session down leaves the full one whole.
  240. expect(toolNames(ctx, full.agent).length).toBeGreaterThan(10)
  241. expect(toolNames(ctx)).toEqual([])
  242. } finally {
  243. await full.dispose()
  244. }
  245. })
  246. it('composes the cordis agent with its own toolset', async () => {
  247. const handle = await ctx.agents.create({
  248. sessionId: SessionId('preset-cordis'),
  249. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'cordis').then(() => undefined),
  250. })
  251. try {
  252. const tools = toolNames(ctx, handle.agent)
  253. // The self-referential toolset is what distinguishes this preset.
  254. expect(tools).toEqual(expect.arrayContaining([
  255. 'cordis_inspect_list', 'cordis_inspect_query', 'cordis_inspect_self',
  256. 'cordis_define', 'cordis_run', 'cordis_stop', 'cordis_undefine',
  257. ]))
  258. // And it keeps the standard agent's own tools rather than replacing them.
  259. expect(tools).toEqual(expect.arrayContaining(['bash', 'read', 'edit', 'skill']))
  260. expect(tools).not.toContain('str_replace_editor')
  261. // The preset's own authoring skill registers into ITS layer of the host
  262. // registry: the cordis agent's view carries it, the global view does not.
  263. const scoped = (await ctx.skills.list({ scope: handle.agent })).map(skill => skill.name)
  264. expect(scoped).toContain('editing-cordis-compositions')
  265. expect((await ctx.skills.list()).map(skill => skill.name)).not.toContain('editing-cordis-compositions')
  266. } finally {
  267. await handle.dispose()
  268. }
  269. })
  270. it('presents `code` as Code Mode without disturbing a native session beside it', async () => {
  271. const coded = await ctx.agents.create({
  272. sessionId: SessionId('preset-code'),
  273. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'code').then(() => undefined),
  274. })
  275. const native = await ctx.agents.create({
  276. sessionId: SessionId('preset-code-native'),
  277. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  278. })
  279. try {
  280. // One tool reaches the MODEL: the transport. The registry's catalog for
  281. // this agent is unchanged — a code mode collapses the presentation, not
  282. // the capabilities — so the assembly is what carries the claim.
  283. const assembly = await ctx.systemPrompt.assemble({ scope: coded.agent })
  284. expect(assembly.tools.map(tool => tool.name)).toEqual(['run_code'])
  285. expect(toolNames(ctx, coded.agent)).not.toContain('str_replace_editor')
  286. const sdk = assembly.sections.find(section => section.name === 'tools:sdk')?.text ?? ''
  287. expect(sdk).not.toContain('str_replace_editor')
  288. expect(sdk).toContain('web_search')
  289. // The presentation is this agent's alone: the deployment default is
  290. // native, and the session composed from `standard` still sees it.
  291. const nativeAssembly = await ctx.systemPrompt.assemble({ scope: native.agent })
  292. expect(nativeAssembly.tools.map(tool => tool.name)).toContain('bash')
  293. expect(nativeAssembly.tools.map(tool => tool.name)).not.toContain('run_code')
  294. expect(nativeAssembly.sections.some(section => section.name === 'tools:sdk')).toBe(false)
  295. } finally {
  296. await native.dispose()
  297. await coded.dispose()
  298. }
  299. })
  300. it('keeps the self-referential toolset out of every other preset', async () => {
  301. const handle = await ctx.agents.create({
  302. sessionId: SessionId('preset-no-cordis'),
  303. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  304. })
  305. try {
  306. // Editing the live runtime is opt-in per session, not ambient.
  307. expect(toolNames(ctx, handle.agent)).not.toContain('cordis_define')
  308. } finally {
  309. await handle.dispose()
  310. }
  311. })
  312. it('ships the composition-authoring skill inside the preset directory', async () => {
  313. // The preset's skill root is derived from its own `baseUrl`, so the skill
  314. // travels with the directory wherever the preset is installed.
  315. const skill = join(
  316. CONFIG_DIR, 'agent-presets', 'cordis', 'skills', 'editing-cordis-compositions', 'SKILL.md',
  317. )
  318. expect((await readFile(skill, 'utf8')).startsWith('---\nname: editing-cordis-compositions')).toBe(true)
  319. })
  320. it('merges the global skill layer into a preset agent\'s catalog, keeping local discovery preset-side', async () => {
  321. const proj = await mkdtemp(join(tmpdir(), 'dsh-preset-skill-proj-'))
  322. await mkdir(join(proj, '.dsh', 'skills', 'project-proof'), { recursive: true })
  323. await writeFile(join(proj, '.dsh', 'skills', 'project-proof', 'SKILL.md'), [
  324. '---',
  325. 'name: project-proof',
  326. 'description: Proves the preset layer discovers project skills beside global ones.',
  327. '---',
  328. '',
  329. 'Project proof body.',
  330. '',
  331. ].join('\n'))
  332. const handle = await ctx.agents.create({
  333. // Unique per run: the composition persists into the ambient DSH home,
  334. // and a fixed id would collide with a log an earlier run left there.
  335. sessionId: SessionId(`preset-skills-standard-${randomUUID()}`),
  336. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  337. })
  338. try {
  339. // The host (global) view carries the deployment-level provider alone:
  340. // local discovery moved behind the presets with `skill-filesystem`.
  341. expect((await ctx.skills.list({ cwd: proj })).map(skill => skill.name)).toEqual(['dsh-badge'])
  342. // The standard agent's view merges the global layer with its preset's
  343. // own local discovery over the session cwd.
  344. const scoped = (await ctx.skills.list({ cwd: proj, scope: handle.agent })).map(skill => skill.name)
  345. expect(scoped).toContain('dsh-badge')
  346. expect(scoped).toContain('project-proof')
  347. // The preset's own loader tool resolves the global-layer skill.
  348. const loaded = await ctx.tools.execute({
  349. callId: CallId('preset-skills-load'),
  350. name: 'skill',
  351. arguments: { name: 'dsh-badge' },
  352. signal: new AbortController().signal,
  353. agent: handle.agent,
  354. })
  355. expect(loaded.isError).toBe(false)
  356. expect(JSON.stringify(loaded.content)).toContain('powered by dsh')
  357. } finally {
  358. await handle.dispose()
  359. }
  360. })
  361. it('shows a minimal agent the global layer but no loader tool', async () => {
  362. const handle = await ctx.agents.create({
  363. sessionId: SessionId(`preset-skills-minimal-${randomUUID()}`),
  364. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  365. })
  366. try {
  367. // Layer visibility is the registry's; whether an agent can USE skills
  368. // stays the preset's choice — minimal mounts no `tool-skill`, so its
  369. // tool table has no loader even though the global layer is readable.
  370. expect((await ctx.skills.list({ scope: handle.agent })).map(skill => skill.name)).toContain('dsh-badge')
  371. expect(toolNames(ctx, handle.agent)).toEqual(['bash', 'str_replace_editor'])
  372. } finally {
  373. await handle.dispose()
  374. }
  375. })
  376. it('never rewrites the preset file it composed from', async () => {
  377. // The Loader persists a tree whose plugin self-disposed, and tearing an
  378. // agent down disposes its whole subtree. Inherited, that rewrote the
  379. // shipped composition — truncating it to `[]` the first time a session
  380. // ended — so `PresetTree` refuses to write at all.
  381. const path = join(CONFIG_DIR, 'agent-presets', 'standard', 'agent.cordis.yml')
  382. const before = await readFile(path, 'utf8')
  383. const handle = await ctx.agents.create({
  384. sessionId: SessionId('preset-readonly'),
  385. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  386. })
  387. await handle.dispose()
  388. // Slack, not a race the number has to win. The write is driven by the
  389. // Loader's fiber-unload listener, which fires as the subtree's fibers
  390. // settle rather than when `dispose()` resolves, and the Loader exposes no
  391. // flush to await. A regression writes synchronously inside that listener,
  392. // so any wait past settlement fails; a longer one only slows the test.
  393. await new Promise(resolve => setTimeout(resolve, 50))
  394. expect(await readFile(path, 'utf8')).toBe(before)
  395. })
  396. })
  397. describe('product subagent rows in user presets', () => {
  398. let productCtx: Context
  399. const ids = ['products-none', 'products-codex', 'products-claude', 'products-both'] as const
  400. beforeAll(async () => {
  401. const root = await mkdtemp(join(tmpdir(), 'dsh-product-presets-'))
  402. const userRoot = join(root, 'presets')
  403. const settingsFile = join(root, 'settings.yaml')
  404. const standard = await readFile(join(CONFIG_DIR, 'agent-presets', 'standard', 'agent.cordis.yml'), 'utf8')
  405. await writeFile(settingsFile, '{}\n')
  406. for (const id of ids) {
  407. let composition = standard
  408. if (id === 'products-codex' || id === 'products-both') {
  409. composition = enablePresetTool(composition, 'tool-subagent-codex')
  410. }
  411. if (id === 'products-claude' || id === 'products-both') {
  412. composition = enablePresetTool(composition, 'tool-subagent-claude-code')
  413. }
  414. const directory = join(userRoot, id)
  415. await mkdir(directory, { recursive: true })
  416. await writeFile(join(directory, 'agent.cordis.yml'), composition)
  417. }
  418. productCtx = await bootWeb(settingsFile, [
  419. { insert: [
  420. { id: 'subagent-codex', name: '@deepseek-ai/dsh-subagent-codex' },
  421. { id: 'subagent-claude-code', name: '@deepseek-ai/dsh-subagent-claude-code' },
  422. ] },
  423. {
  424. id: 'agent-presets',
  425. config: {
  426. default: 'standard',
  427. roots: [
  428. { path: join(CONFIG_DIR, 'agent-presets'), trust: 'system' },
  429. { path: userRoot, trust: 'user' },
  430. ],
  431. includeUserRoot: false,
  432. },
  433. },
  434. ], EXAMPLES_INSTALL_ANCHOR)
  435. }, 120_000)
  436. afterAll(async () => {
  437. await productCtx.fiber.dispose()
  438. })
  439. it('composes none, either product, or both without changing the shared host registry', async () => {
  440. const expected = new Map<string, string[]>([
  441. ['products-none', []],
  442. ['products-codex', ['subagent_codex']],
  443. ['products-claude', ['subagent_claude_code']],
  444. ['products-both', ['subagent_claude_code', 'subagent_codex']],
  445. ])
  446. expect(productCtx.subagents.list()).toEqual(expect.arrayContaining([
  447. 'spawn', 'fork', 'codex', 'claude-code',
  448. ]))
  449. for (const [id, productTools] of expected) {
  450. const handle = await productCtx.agents.create({
  451. sessionId: SessionId(`preset-${id}`),
  452. setup: agentCtx => productCtx.agentPresets.mount(agentCtx, id).then(() => undefined),
  453. })
  454. try {
  455. const tools = toolNames(productCtx, handle.agent)
  456. expect(tools.filter(name => name === 'subagent_codex' || name === 'subagent_claude_code'))
  457. .toEqual(productTools)
  458. } finally {
  459. await handle.dispose()
  460. }
  461. }
  462. })
  463. it('applies a product-row edit only to later sessions on the preset', async () => {
  464. const preset = await productCtx.agentPresets.resolve('products-none')
  465. const original = await readFile(preset.path, 'utf8')
  466. const existing = await productCtx.agents.create({
  467. sessionId: SessionId('preset-product-generation-existing'),
  468. setup: agentCtx => productCtx.agentPresets.mount(agentCtx, 'products-none').then(() => undefined),
  469. })
  470. try {
  471. expect(toolNames(productCtx, existing.agent)).not.toContain('subagent_codex')
  472. await writeFile(preset.path, enablePresetTool(original, 'tool-subagent-codex'))
  473. const later = await productCtx.agents.create({
  474. sessionId: SessionId('preset-product-generation-later'),
  475. setup: agentCtx => productCtx.agentPresets.mount(agentCtx, 'products-none').then(() => undefined),
  476. })
  477. try {
  478. expect(toolNames(productCtx, existing.agent)).not.toContain('subagent_codex')
  479. expect(toolNames(productCtx, later.agent)).toContain('subagent_codex')
  480. } finally {
  481. await later.dispose()
  482. }
  483. } finally {
  484. await existing.dispose()
  485. await writeFile(preset.path, original)
  486. }
  487. })
  488. })
  489. describe('a switch survives the session', () => {
  490. it('records the choice so the log states what the agent runs', async () => {
  491. const handle = await ctx.agents.create({
  492. sessionId: SessionId('preset-switch-logged'),
  493. meta: { agentPreset: 'standard' },
  494. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  495. })
  496. try {
  497. // The api-proxy's select does exactly this pair while the session is blank.
  498. await ctx.agentPresets.recompose(handle.agent.ctx, 'minimal')
  499. handle.agent.session.append('agent-preset/selected', { agentPreset: 'minimal' })
  500. // The header keeps the creation fact; the log carries what it runs.
  501. expect(handle.agent.session.header.agentPreset).toBe('standard')
  502. expect(resolveSessionPreset(handle.agent.session)).toBe('minimal')
  503. } finally {
  504. await handle.dispose()
  505. }
  506. })
  507. it('rebuilds a switched session from the log, not the creation header', () => {
  508. // The exact shape a resume reads back from disk: the header says standard,
  509. // the log records the switch the user made while the session was blank.
  510. const rebuilt = resolveSessionPreset({
  511. header: { version: 0, id: SessionId('x'), createdAt: 0, agentPreset: 'standard' },
  512. events: [
  513. { type: 'agent-preset/selected', seq: 1, time: 0, data: { agentPreset: 'minimal' } },
  514. { type: 'turn/start', seq: 2, time: 0, data: { turn: 0, trigger: { kind: 'message', source: { kind: 'user' } } } },
  515. ] as never,
  516. })
  517. // Reading the header alone would compose the creation-time preset over a
  518. // history another one produced — the replay the blank-only lock prevents.
  519. expect(rebuilt).toBe('minimal')
  520. })
  521. })
  522. describe('a forked session', () => {
  523. it('inherits the composition its seeded history was produced under', async () => {
  524. const parent = await ctx.agents.create({
  525. sessionId: SessionId('preset-fork-parent'),
  526. meta: { agentPreset: 'minimal' },
  527. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  528. })
  529. const inherited = resolveSessionPreset(parent.agent.session)
  530. const child = await ctx.agents.create({
  531. sessionId: SessionId('preset-fork-child'),
  532. meta: {
  533. parentSession: SessionId('preset-fork-parent'),
  534. seedLength: 0,
  535. ...inherited === undefined ? {} : { agentPreset: inherited },
  536. },
  537. setup: agentCtx => ctx.agentPresets.mount(agentCtx, inherited).then(() => undefined),
  538. })
  539. try {
  540. // Composing nothing would leave the child empty: this layer moved every
  541. // model-facing row out of the host plane, so there is nothing to inherit
  542. // for free any more.
  543. expect(toolNames(ctx, child.agent)).toEqual(toolNames(ctx, parent.agent))
  544. expect(toolNames(ctx, child.agent).length).toBeGreaterThan(0)
  545. } finally {
  546. await child.dispose()
  547. await parent.dispose()
  548. }
  549. })
  550. })
  551. describe('a delegated child', () => {
  552. it('runs on the composition its parent runs on', async () => {
  553. const parent = await ctx.agents.create({
  554. sessionId: SessionId('preset-child-parent'),
  555. meta: { agentPreset: 'standard' },
  556. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  557. })
  558. // Exactly what an in-process subagent driver's creation window does.
  559. const child = await parent.agent.ctx.agents.create({
  560. sessionId: SessionId('preset-child'),
  561. meta: childSessionMeta(parent.agent, 1, 0),
  562. setup: (agentCtx) => {
  563. applyChildComposition(agentCtx, parent.agent, {})
  564. },
  565. })
  566. try {
  567. expect(toolNames(ctx, child.agent)).toEqual(toolNames(ctx, parent.agent))
  568. // The shipped `standard` preset is the whole coding agent; an empty
  569. // child here is the defect, and equality alone would not catch it.
  570. expect(toolNames(ctx, child.agent)).toContain('bash')
  571. expect(child.agent.session.header.agentPreset).toBe('standard')
  572. } finally {
  573. await child.dispose()
  574. await parent.dispose()
  575. }
  576. })
  577. it('follows a parent that switched preset while blank', async () => {
  578. const parent = await ctx.agents.create({
  579. sessionId: SessionId('preset-child-switch-parent'),
  580. meta: { agentPreset: 'standard' },
  581. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'standard').then(() => undefined),
  582. })
  583. await ctx.agentPresets.recompose(parent.agent.ctx, 'minimal')
  584. const child = await parent.agent.ctx.agents.create({
  585. sessionId: SessionId('preset-child-switch'),
  586. meta: childSessionMeta(parent.agent, 1, 0),
  587. setup: (agentCtx) => {
  588. applyChildComposition(agentCtx, parent.agent, {})
  589. },
  590. })
  591. try {
  592. // The live scope chain is the authority, not the parent's creation
  593. // header — which still names `standard`.
  594. expect(toolNames(ctx, child.agent)).toEqual(toolNames(ctx, parent.agent))
  595. expect(child.agent.session.header.agentPreset).toBe('minimal')
  596. } finally {
  597. await child.dispose()
  598. await parent.dispose()
  599. }
  600. })
  601. })
  602. describe('a launcher that configures no writable root', () => {
  603. // The claim this default exists for, asserted through the real shipped
  604. // bundles rather than a hand-built context: `apps/cli` patches in only the
  605. // system root, and a person's own presets are found anyway because the
  606. // roster derives `<dshHome>/.agent-presets` itself. `$DSH_HOME` is pointed
  607. // at a temp home BEFORE boot — the derived root is resolved when the plugin
  608. // is constructed, and an unpinned run would read the developer's own.
  609. let derivedCtx: Context
  610. let previousHome: string | undefined
  611. beforeAll(async () => {
  612. const home = await mkdtemp(join(tmpdir(), 'dsh-preset-derived-'))
  613. previousHome = process.env.DSH_HOME
  614. process.env.DSH_HOME = home
  615. await mkdir(join(home, '.agent-presets', 'derived-mine'), { recursive: true })
  616. await writeFile(
  617. join(home, '.agent-presets', 'derived-mine', 'agent.cordis.yml'),
  618. '- id: tool-todo\n name: \'@deepseek-ai/dsh-tool-todo\'\n config:\n allowParallelInProgress: true\n',
  619. )
  620. const settingsFile = join(await mkdtemp(join(tmpdir(), 'dsh-preset-derived-settings-')), 'settings.yaml')
  621. await writeFile(settingsFile, '{}\n')
  622. // Only the shipped root, exactly what `composeProfile` supplies; the
  623. // writable one is the roster's own default rather than this patch's job.
  624. derivedCtx = await bootWeb(settingsFile, [{
  625. id: 'agent-presets',
  626. config: {
  627. default: 'standard',
  628. roots: [{ path: join(CONFIG_DIR, 'agent-presets'), trust: 'system' }],
  629. includeUserRoot: true,
  630. },
  631. }])
  632. }, 120_000)
  633. afterAll(async () => {
  634. if (previousHome === undefined) delete process.env.DSH_HOME
  635. else process.env.DSH_HOME = previousHome
  636. await derivedCtx.fiber.dispose()
  637. })
  638. it('discovers and mounts a preset the person authored under the harness home', async () => {
  639. const listed = await derivedCtx.agentPresets.list()
  640. const mine = listed.find(preset => preset.id === 'derived-mine')
  641. expect(mine).toMatchObject({ trust: 'user' })
  642. // Omitted rather than undefined: a healthy row carries no `broken` key.
  643. expect(mine?.broken).toBeUndefined()
  644. expect(derivedCtx.agentPresets.authorable).toBe(true)
  645. const handle = await derivedCtx.agents.create({
  646. sessionId: SessionId('preset-derived-root'),
  647. setup: agentCtx => derivedCtx.agentPresets.mount(agentCtx, 'derived-mine').then(() => undefined),
  648. })
  649. try {
  650. expect(toolNames(derivedCtx, handle.agent)).toContain('todo_write')
  651. } finally {
  652. await handle.dispose()
  653. }
  654. })
  655. })
  656. describe('authoring a preset on the shipped composition', () => {
  657. let authorCtx: Context
  658. let userRoot: string
  659. beforeAll(async () => {
  660. userRoot = join(await mkdtemp(join(tmpdir(), 'dsh-preset-authoring-')), 'profiles')
  661. const settingsFile = join(await mkdtemp(join(tmpdir(), 'dsh-preset-authoring-settings-')), 'settings.yaml')
  662. await writeFile(settingsFile, '{}\n')
  663. authorCtx = await bootWeb(settingsFile, [{
  664. id: 'agent-presets',
  665. config: {
  666. default: 'standard',
  667. roots: [
  668. { path: join(CONFIG_DIR, 'agent-presets'), trust: 'system' },
  669. // The root does not exist yet: a deployment whose user has authored
  670. // nothing is the normal first-run state.
  671. { path: userRoot, trust: 'user' },
  672. ],
  673. includeUserRoot: false,
  674. },
  675. }])
  676. })
  677. it('refuses to copy over or delete a shipped preset', async () => {
  678. await expect(authorCtx.agentPresets.copy('minimal', 'standard')).rejects.toThrow(/already exists/)
  679. await expect(authorCtx.agentPresets.remove('standard')).rejects.toThrow(/ships with the deployment/)
  680. })
  681. it.each(['../escape', 'a/b', '/abs', 'Upper'])('refuses the uncontainable id %j', async (id) => {
  682. // The id becomes a directory name under the user root, so containment is
  683. // checked on the id rather than on the joined path afterwards.
  684. await expect(authorCtx.agentPresets.copy('minimal', id)).rejects.toThrow()
  685. })
  686. it('copies a shipped preset a session then really composes from', async () => {
  687. await authorCtx.agentPresets.copy('minimal', 'my-agent', '我的模式')
  688. // Round-trips through the roster as a `user` row carrying the given name
  689. // and the source's description, over the source's own composition text.
  690. const preset = await authorCtx.agentPresets.resolve('my-agent')
  691. const source = await authorCtx.agentPresets.resolve('minimal')
  692. expect(preset.trust).toBe('user')
  693. expect(preset.name).toBe('我的模式')
  694. expect(preset.description).toBe(source.description)
  695. expect(await authorCtx.agentPresets.read('my-agent')).toBe(await authorCtx.agentPresets.read('minimal'))
  696. // Owner-only, in an owner-only directory: a composition is executable
  697. // configuration on a machine that may have other users.
  698. expect((await stat(preset.path)).mode & 0o777).toBe(0o600)
  699. const handle = await authorCtx.agents.create({
  700. sessionId: SessionId('preset-authored'),
  701. setup: agentCtx => authorCtx.agentPresets.mount(agentCtx, 'my-agent').then(() => undefined),
  702. })
  703. try {
  704. // The same tools the shipped `minimal` composes, from a directory copied
  705. // through the service into a root outside the installed harness.
  706. expect(toolNames(authorCtx, handle.agent)).toEqual(['bash', 'str_replace_editor'])
  707. } finally {
  708. await handle.dispose()
  709. }
  710. })
  711. it('deletes what it copied', async () => {
  712. await authorCtx.agentPresets.copy('minimal', 'doomed')
  713. await authorCtx.agentPresets.remove('doomed')
  714. expect((await authorCtx.agentPresets.list()).map(preset => preset.id)).not.toContain('doomed')
  715. })
  716. })
  717. /**
  718. * Which preset an unnamed session gets is a user setting layered over the
  719. * composition's own default. The package suite proves the layering against a
  720. * hand-built context; this proves it through the shipped `cordis.yml` — that
  721. * the roster and the settings provider are actually wired to each other, and
  722. * that the id the setting names is the one a session composes from.
  723. */
  724. describe('the default preset as a user setting', () => {
  725. it('composes an unnamed session from the stored default, not the composed one', async () => {
  726. expect(ctx.agentPresets.defaultId).toBe('standard')
  727. await ctx.settings.update(settingsNamespace(SETTINGS_NAMESPACE), { default: 'minimal' })
  728. try {
  729. expect(ctx.agentPresets.defaultId).toBe('minimal')
  730. const handle = await ctx.agents.create({
  731. sessionId: SessionId('preset-user-default'),
  732. setup: agentCtx => ctx.agentPresets.mount(agentCtx).then(() => undefined),
  733. })
  734. try {
  735. // `mount()` with no id resolves the effective default. Two tools, not
  736. // `standard`'s catalog: the setting decided the composition.
  737. expect(toolNames(ctx, handle.agent)).toEqual(['bash', 'str_replace_editor'])
  738. } finally {
  739. await handle.dispose()
  740. }
  741. } finally {
  742. // The context is shared with the rest of the file. `replace({})` drops
  743. // the user section wholesale so the field re-inherits the composition
  744. // base; `update` merges, and would leave the override standing.
  745. await ctx.settings.replace(settingsNamespace(SETTINGS_NAMESPACE), {})
  746. }
  747. expect(ctx.agentPresets.defaultId).toBe('standard')
  748. })
  749. })
  750. describe('a session keeps the preset it was created with', () => {
  751. it('refuses to adopt a live session under a different preset', async () => {
  752. const handle = await ctx.agents.create({
  753. sessionId: SessionId('preset-locked'),
  754. meta: { agentPreset: 'minimal' },
  755. setup: agentCtx => ctx.agentPresets.mount(agentCtx, 'minimal').then(() => undefined),
  756. })
  757. try {
  758. // The api-proxy guard reads exactly this: the header records what the
  759. // session runs, so naming anything else is a caller error rather than a
  760. // switch. Its history was produced under `minimal`'s two tools.
  761. expect(handle.agent.session.header.agentPreset).toBe('minimal')
  762. } finally {
  763. await handle.dispose()
  764. }
  765. })
  766. })