Cordis 在做什么：从 DeepSeek Harness 看

export async function boot(
  binName: string,
  absoluteConfigPath: string,
  // ...
): Promise {
  const ctx = new Context()
  // ...
  ctx.provide('dshHomePath', dshHomePath)
  await ctx.plugin(Loader)
  // ...
  await mountRootInclude(ctx, absoluteConfigPath, patches, bareModuleBaseUrl)
  await ctx.get('loader')?.await()
  if (ctx.get('loader') === undefined) return ctx
  await assertEntriesActivated(ctx, binName)
  return ctx
}

ctx.reflect.provide('loader', this, this[Service.check])

plugin(plugin: Plugin, config?: any, getOuterStack = buildOuterStack()) {
  const callback = this.resolve(plugin)   // 函数 / 类 / { apply } 对象统一成一个回调
  if (!callback) throw new Error('invalid plugin, ...')
  this.ctx.fiber.assertActive()

  let runtime = this._internal.get(callback)   // 同一插件的登记处，注意 fibers 是列表
  if (!runtime) {
    // ...
    runtime = { name, callback, fibers: new DisposableList(), Config: plugin.Config }
    this._internal.set(callback, runtime)
  }

  const fiber = new Fiber(this.ctx, config, Inject.resolve(plugin.inject), runtime, getOuterStack)

constructor(
  public parent: Context,
  config: any,
  public inject: Dict,
  public runtime: Plugin.Runtime | null,
  // ...
) {
  this._config = config
  // ...
  this.ctx = this.context = parent.extend({ fiber: this })   // 派生子 ctx

  this._runner = {
    epoch: INACTIVE,
    execute: function () {
      if (isConstructor(runtime.callback)) {
        const instance = new runtime.callback(this.ctx, this.config)   // ← 实现类对象在启动时才 new
        // ...
      } else {
        return runtime.callback(this.ctx, this.config)
      }
    },
    collect,
  }

  this.dispose = parent.fiber.effect(() => {   // 把自己登记为父 fiber 的 effect → 级联卸载
    const remove = runtime.fibers.push(this)
    // ...
  })

constructor(protected ctx: Context, name: string) {
  // ...
  self.ctx.reflect.provide(name, self, this[symbols.check])
  return self
}

declare module '@deepseek-ai/cordis' {
  interface Context {
    shell: ShellExecutor
  }
}

export abstract class ShellExecutor extends Service {
  constructor(ctx: Context) {
    super(ctx, 'shell')
  }

  abstract resolve(request: ShellExecRequest): ShellExecSpec
  abstract run(spec: ShellExecSpec): Promise
  abstract start(spec: ShellExecSpec): ShellProcess
}

/**
 * Local bash executor over `ctx.subprocess`. ... a
 * still-running background process stays managed (killed and joined at
 * composition teardown) even across an executor reload.
 */
export class LocalBashExecutor extends ShellExecutor {
  static inject = ['subprocess']

  static Config: z = z.object({
    cwd: z.string(),
    timeoutMs: z.number().default(120_000),
    maxTimeoutMs: z.number().default(600_000),
    maxOutputBytes: z.number().default(64_000),
    // ...
  })
  // ...
  constructor(ctx: Context, config: Config) {
    super(ctx)

export const name = 'web-search-exa'

/** The web seam this provider registers into. */
export const inject = ['web']

/** Register the Exa search provider with `ctx.web`. */
export function apply(ctx: Context, config: Config): void {
  ctx.web.registerSearchProvider(new ExaSearchProvider({
    apiKey: config.apiKey ?? launchEnvironmentOf(ctx).get('EXA_API_KEY')?.value ?? '',
    // ...
  }))
}

/** Concrete agent factory and driver service. */
export class AgentLoop extends Service implements AgentFactory {
  static inject = ['agents', 'sessions', 'llm', 'tools', 'systemPrompt']

export function apply(ctx: Context, config: Config): void {
  // ...
  ctx.plugin(Timer)
  ctx.plugin(LlmRuntime)
  ctx.plugin(SessionStore)
  ctx.plugin(SystemPrompt, { /* ... */ })
  ctx.plugin(ToolRuntime, config.tools ?? {})
  // ...
  ctx.plugin(AgentLoop, { agents: config.agents ?? [], /* ... */ })
}

ctx.web.registerSearchProvider(new ExaSearchProvider({ /* ... */ }))

/**
 * ...
 * if its id is already registered for search. Returns a disposer; disposed
 * with the calling fiber.
 */
registerSearchProvider(provider: WebSearchProvider): () => void {
  return this.registerProvider(this.searchProviders, provider)
}

private registerProvider
(store: Map, provider: P): () => void {
  if (store.has(provider.id)) {
    throw new WebError(`a web provider with id "${provider.id}" is already registered`, 'WEB_DUPLICATE_PROVIDER')
  }
  const dispose = this.ctx.effect(function* () {
    store.set(provider.id, provider)
    yield () => store.delete(provider.id)
  }, 'web.registerProvider()')
  // ...
}

const effect: Effect = runner.execute.call(this)   // 调生成器函数，拿到迭代器
// ...（略：回调直接返回函数 / Promise / async 迭代器的分支）
} else if (Symbol.iterator in effect) {
  const iter = effect[Symbol.iterator]()
  while (true) {
    const result = iter.next()       // 当场驱动到底
    safeCollect(result.value)        // 每 yield 一条撤销，当场收走
    if (result.done) return
  }
}

export function apply(ctx: Context, config: Config): void {
  ctx.web.registerSearchProvider(new ExaSearchProvider({ /* ... */ }))
}

public readonly _disposables = new DisposableList()   // 每个实例的处置列表

// Fiber.effect 内：
removeWrapper = this._disposables.push(wrapper)                    // 「登记」= push 进列表

await Promise.all(this._disposables.clear().map(async (dispose) => {

// announcing so a throwing `session/created` listener rolls the attach back
// (the generator effect disposes already-yielded disposers on a throw)
// instead of leaking the store entry and its publication hooks.
this.ctx.effect(function* (this: SessionStore) {
  yield this.enter(session)   // 第一步：入库，立刻交出「移除它」的撤销
  this.announce(session)      // 第二步：广播——监听器可能抛错
}.bind(this), 'sessions.create()')

provide(name: string, value?: any, check?: () => boolean) {
  return this.ctx.fiber.effect(() => {
    // ...（略：把 name 声明为 service 的簿记）
    this.ctx.root[symbols.isolate][name] ??= Symbol(name)
    const key = this.ctx[symbols.isolate][name]
    const impl: Impl = { name, value, fiber: this.ctx.fiber, check }
    if (this.store[key]) {
      throw new Error(`service "${name}" has been registered at <${this.store[key].fiber.name}>`)
    }
    this.store[key] = impl
    this.ctx.fiber.store![name] = impl
    if (this.ctx.fiber.state === FiberState.ACTIVE) {
      this.notify([name])
    }
    return async () => {
      delete this.store[key]
      const fibers = this.notify([name])
      await Promise.allSettled(fibers.map(fiber => fiber.await()))
      // ensure self access before dependencies cleanup
      delete this.ctx.fiber.store![name]
    }
  }, `ctx.provide(${JSON.stringify(name)})`)
}

import { Context } from '@deepseek-ai/cordis'
import { LocalBashExecutor } from '@deepseek-ai/dsh-bash-local'

export class SandboxBashExecutor extends LocalBashExecutor {
  static override inject = ['subprocess', 'sandbox', 'sandboxPolicy']

  constructor(ctx: Context, config: Config) {
    super(ctx, config)
    this.mode = ctx.sandboxPolicy.defaultMode   // inject 声明过的服务，直接用
  }

  override resolve(request: ShellExecRequest): ShellExecSpec { /* ... */ }
  override async run(spec: ShellExecSpec): Promise { /* ... */ }
  override start(spec: ShellExecSpec): ShellProcess { /* ... */ }
  // ...（沙箱业务逻辑，Cordis 不关心）
}

export default SandboxBashExecutor

- id: bash-sandbox
  name: '@deepseek-ai/dsh-bash-sandbox'
  disabled: !!js process.platform === 'win32'
  config:
    timeoutMs: 60000

- id: settings
  name: '@deepseek-ai/dsh-settings-file'

- id: llm-deepseek
  name: '@deepseek-ai/dsh-llm-deepseek'
  config:
    thinking: enabled
    reasoningEffort: max
    models:
      - id: deepseek-v4-pro
        contextWindow: 128000

- id: agent-spine
  name: '@deepseek-ai/dsh-agent-spine-demo'

- id: hmr
  name: '@deepseek-ai/cordis-plugin-hmr'
  config:
    root: ['.']

# The shared module-reload HMR row stays off; the launcher's watch-only
# fallback still keeps the user patch layers live until the run exits.
- id: hmr
  disabled: true

- id: persona
  name: '@deepseek-ai/dsh-persona'
  config:
    text: You are a helpful software engineer assistant.
    complete: true

- id: persistent-shell
  name: cordis:group
  group: true
  isolate:
    terminals: true
  config:
    - id: pty
      name: '@deepseek-ai/dsh-terminal'

- id: tool-bash
  name: '@deepseek-ai/dsh-tool-bash'
  disabled: !!js process.platform === 'win32'

- id: tool-pwsh
  name: '@deepseek-ai/dsh-tool-pwsh'
  disabled: !!js process.platform !== 'win32'

- id: tool-presentation
  name: '@deepseek-ai/dsh-agent-tool-presentation'
  config:
    mode: code

- id: tool-cordis
  name: '@deepseek-ai/dsh-tool-cordis'

- id: skill-filesystem
  name: '@deepseek-ai/dsh-skill-filesystem'