Tianyi Cui
a2d0f7f411
Apply the accepted pre-release package, service, type, directory, and role renames as one repository-wide change.
116 lines
4.0 KiB
TypeScript
116 lines
4.0 KiB
TypeScript
/** The `bash` settings section layered over the executor's composition entry. */
|
|
|
|
import { describe, expect, it } from 'vitest'
|
|
import { Context } from '@deepseek-ai/cordis'
|
|
import type { Fiber } from '@deepseek-ai/cordis'
|
|
import { SettingsProvider } from '@deepseek-ai/dsh-settings'
|
|
import type { SettingsNamespace } from '@deepseek-ai/dsh-settings'
|
|
import LocalSubprocessRuntime from '@deepseek-ai/dsh-subprocess-local'
|
|
import { SHELL_SETTINGS_NAMESPACE } from '@deepseek-ai/dsh-shell'
|
|
import { LocalBashExecutor } from '@deepseek-ai/dsh-bash-local'
|
|
|
|
/** The smallest real provider: one in-memory document, always writable. */
|
|
class MemorySettings extends SettingsProvider {
|
|
doc: Record<string, unknown> = {}
|
|
|
|
get writable(): boolean {
|
|
return true
|
|
}
|
|
|
|
protected load(): Promise<Record<string, unknown>> {
|
|
return Promise.resolve(structuredClone(this.doc))
|
|
}
|
|
|
|
protected persist(ns: SettingsNamespace, section: Record<string, unknown>): Promise<void> {
|
|
this.doc = { ...this.doc, [ns]: structuredClone(section) }
|
|
return Promise.resolve()
|
|
}
|
|
}
|
|
|
|
async function boot(config: ConstructorParameters<typeof LocalBashExecutor>[1] = {}): Promise<{
|
|
ctx: Context
|
|
settingsFiber: Fiber
|
|
executorFiber: Fiber
|
|
bash: LocalBashExecutor
|
|
}> {
|
|
const ctx = new Context()
|
|
await ctx.plugin(LocalSubprocessRuntime)
|
|
const settingsFiber = ctx.plugin(MemorySettings)
|
|
await settingsFiber.await()
|
|
const executorFiber = ctx.plugin(LocalBashExecutor, { timeoutMs: 60_000, ...config })
|
|
await executorFiber.await()
|
|
return { ctx, settingsFiber, executorFiber, bash: ctx.shell as LocalBashExecutor }
|
|
}
|
|
|
|
describe('bash settings section', () => {
|
|
it('resolves the user layer over the composition entry', async () => {
|
|
const bench = await boot()
|
|
expect(bench.bash.config.timeoutMs).toBe(60_000)
|
|
|
|
await bench.ctx.settings.update(SHELL_SETTINGS_NAMESPACE, { timeoutMs: 5_000 })
|
|
|
|
expect(bench.bash.config.timeoutMs).toBe(5_000)
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
|
|
it('refuses a stored value the constructor would have rejected', async () => {
|
|
const bench = await boot()
|
|
|
|
await expect(bench.ctx.settings.update(SHELL_SETTINGS_NAMESPACE, { timeoutMs: 0 }))
|
|
.rejects.toThrow(/positive finite/)
|
|
|
|
expect(bench.bash.config.timeoutMs).toBe(60_000)
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
|
|
it('refuses a grace period longer than a timer can carry', async () => {
|
|
const bench = await boot()
|
|
|
|
await expect(bench.ctx.settings.update(SHELL_SETTINGS_NAMESPACE, { graceMs: Number.MAX_SAFE_INTEGER }))
|
|
.rejects.toThrow(/graceMs must be no greater than/)
|
|
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
|
|
it('serves the stored section to every later read', async () => {
|
|
const bench = await boot()
|
|
await bench.ctx.settings.update(SHELL_SETTINGS_NAMESPACE, { maxOutputBytes: 1_024, cwd: '/tmp' })
|
|
|
|
const spec = bench.bash.resolve({ command: 'true' })
|
|
|
|
expect(spec.stdoutMaxBytes).toBe(1_024)
|
|
expect(spec.workdir).toBe('/tmp')
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
|
|
it('falls back to the composition entry when the settings provider detaches', async () => {
|
|
const bench = await boot()
|
|
await bench.ctx.settings.update(SHELL_SETTINGS_NAMESPACE, { timeoutMs: 5_000 })
|
|
expect(bench.bash.config.timeoutMs).toBe(5_000)
|
|
|
|
await bench.settingsFiber.dispose()
|
|
|
|
expect(bench.bash.config.timeoutMs).toBe(60_000)
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
|
|
it('keeps the composition entry when no settings provider is mounted', async () => {
|
|
const ctx = new Context()
|
|
await ctx.plugin(LocalSubprocessRuntime)
|
|
await ctx.plugin(LocalBashExecutor, { timeoutMs: 1_234 })
|
|
|
|
expect((ctx.shell as LocalBashExecutor).config.timeoutMs).toBe(1_234)
|
|
await ctx.fiber.dispose()
|
|
})
|
|
|
|
it('releases the namespace when the executor unloads', async () => {
|
|
const bench = await boot()
|
|
expect(bench.ctx.settings.describe().map(row => String(row.ns))).toContain('shell')
|
|
|
|
await bench.executorFiber.dispose()
|
|
|
|
expect(bench.ctx.settings.describe().map(row => String(row.ns))).not.toContain('shell')
|
|
await bench.ctx.fiber.dispose()
|
|
})
|
|
})
|