Function createMcpServer

lib/reactotron-mcp/src/mcp-server.ts:22–167

(
  reactotronServer: ReactotronServer,
  redactionConfig?: Partial<McpRedactionServerConfig>
)

}

export function createMcpServer(
  reactotronServer: ReactotronServer,
  redactionConfig?: Partial<McpRedactionServerConfig>
): ReactotronMcpServer {
  let serverRedactionConfig: McpRedactionServerConfig = {
    ...DEFAULT_SERVER_CONFIG,
    ...redactionConfig,
    defaults: { ...DEFAULT_SERVER_CONFIG.defaults, ...redactionConfig?.defaults },
  }
  let httpServer: HttpServer | null = null
  let started = false
  let listenPort: number | null = null

  // Command buffer — collects recent commands for resource reads
  const commandBuffer: Command[] = []
  const BUFFER_SIZE = 500
  let commandListener: ((command: Command) => void) | null = null

  function startBuffering() {
    commandListener = (command: Command) => {
      commandBuffer.push(command)
      if (commandBuffer.length > BUFFER_SIZE) {
        commandBuffer.shift()
      }
    }
    reactotronServer.on("command", commandListener as any)
  }

  function stopBuffering() {
    if (commandListener) {
      reactotronServer.off("command", commandListener as any)
      commandListener = null
    }
    commandBuffer.length = 0
  }

  /** Create a fresh McpServer instance with all resources/tools registered */
  function createMcp(): McpServer {
    const mcp = new McpServer(
      { name: "reactotron", version: "0.1.0" },
      { capabilities: { resources: {}, tools: {} } }
    )
    registerResources(mcp, reactotronServer, commandBuffer, serverRedactionConfig)
    registerTools(mcp, reactotronServer, commandBuffer, serverRedactionConfig)
    return mcp
  }

  return {
    get started() { return started },
    get port() { return listenPort },
    get redactionConfig() { return serverRedactionConfig },

    updateRedactionConfig(config: Partial<McpRedactionServerConfig>) {
      serverRedactionConfig = {
        ...serverRedactionConfig,
        ...config,
        defaults: config.defaults
          ? { ...serverRedactionConfig.defaults, ...config.defaults }