Function startOpencodeSession

packages/ai-opencode/src/process/server.ts:113–270

(
  options: StartOpencodeSessionOptions,
)

 * flattened transcript.
 */
export async function startOpencodeSession(
  options: StartOpencodeSessionOptions,
): Promise<OpencodeSessionHandle> {
  const { directory } = options
  // Spread into a `query` object only when set; omitting lets opencode use the
  // server's launch cwd (correct for every provider — see `directory` docs).
  const dirQuery = directory !== undefined ? { directory } : {}

  let client: OpencodeClient
  let ownedServer: { close: () => void } | undefined

  if (options.baseUrl !== undefined) {
    client = createOpencodeClient({
      baseUrl: options.baseUrl,
      ...(options.headers !== undefined && { headers: options.headers }),
      ...(directory !== undefined && { directory }),
    })
  } else {
    const config = buildConfig(options)
    const result = await createOpencode({
      ...(options.hostname !== undefined && { hostname: options.hostname }),
      ...(options.port !== undefined && { port: options.port }),
      ...(Object.keys(config).length > 0 && { config }),
    })
    client = result.client
    ownedServer = result.server
  }

  // Mutated from several closures (the subscription loop, dispose, teardown);
  // a holder object keeps reads typed as `boolean` rather than being
  // flow-narrowed to a literal across those boundaries.
  const lifecycle = { disposed: false }

  const teardown = async (): Promise<void> => {
    if (lifecycle.disposed) return
    lifecycle.disposed = true
    ownedServer?.close()
    await Promise.resolve()
  }

  try {
    // Resolve the session before subscribing so the event filter has an id.
    let sessionId: string | undefined
    let resumed = false
    if (options.resumeSessionId !== undefined) {
      const existing = await client.session.get({
        path: { id: options.resumeSessionId },
        query: dirQuery,
      })
      if (existing.data) {
        sessionId = options.resumeSessionId
        resumed = true
      }
    }
    if (sessionId === undefined) {
      const created = await client.session.create({
        query: dirQuery,
        body: {},