Class AcpServer

packages/acp-adapter/src/server.ts:130–925

 * push `session/update` chunks back to the client.
 */
export class AcpServer implements Agent {
  private negotiated: AcpVersionSpec | undefined;
  private clientCapabilities: ClientCapabilities | undefined;
  private readonly sessions = new Map<string, AcpSession>();
  private readonly agentInfo: Implementation | undefined;
  private readonly terminalAuthEnv: Readonly<Record<string, string>> | undefined;
  private readonly terminalAuthLegacyCommand: string | undefined;
  private readonly resolveSlashCommands: (
    session: Session,
  ) => Promise<ResolvedSlashCommands>;
  /**
   * Lazily-built inner {@link Kaos} (a {@link LocalKaos}) used as the
   * delegate target for every {@link AcpKaos} this server hands out.
   * One per server (not per session) so we don't re-probe the
   * environment for every `session/new` call.
   */
  private innerKaos: Kaos | undefined = undefined;

  constructor(
    private readonly harness: KimiHarness,
    private readonly conn?: AgentSideConnection | undefined,
    opts?: {
      agentInfo?: Implementation;
      /**
       * Env vars to advertise in `authMethods[0].env` so the `kimi login`
       * subprocess the client spawns (via `terminal-auth`) lands its
       * token under the same data root the ACP server uses. Intended for
       * sandboxed test setups (e.g. `{ KIMI_CODE_HOME: '/tmp/...' }`);
       * leave undefined in production so the advertised env stays empty.
       */
      terminalAuthEnv?: Readonly<Record<string, string>>;
      /**
       * Absolute binary path advertised in `_meta['terminal-auth'].command`
       * for clients that don't yet honor the first-class
       * `AuthMethodTerminal` (Zed without `AcpBetaFeatureFlag`, JetBrains
       * plugin). Clients on this legacy path spawn `<command> login`
       * directly. Defaults to undefined (the `_meta` fallback is omitted).
       */
      terminalAuthLegacyCommand?: string;
      /**
       * Slash commands to advertise in the one-shot
       * `available_commands_update` pushed immediately after each
       * `session/new`, `session/load`, and `session/resume`. Accepts
       * either a static array, or a resolver called once per session
       * (with the just-created `Session`) so per-session sources like
       * `session.listSkills()` can be merged in. When omitted, the
       * adapter falls back to an empty list.
       *
       * Returning a {@link SlashCommandsSnapshot} (`{ commands, skillCommandMap }`)
       * additionally lets {@link AcpSession.prompt} intercept
       * `/skill:<name> ...` inputs at the adapter boundary and route
       * them to {@link Session.activateSkill} instead of forwarding the
       * raw slash text — matching the TUI's slash-command behavior so
       * skill activations don't fall back to model-driven Bash
       * exploration of `~/.kimi-code/skills/`.
       */
      slashCommands?: SlashCommandsResolver;
    },