interactive-process-mcp

MCP-сервер для управления интерактивными процессами. Позволяет ИИ-агентам (Claude Code и др.) запускать долгоживущие интерактивные программы — SSH-сессии, REPL, установщики, инструменты impacket — и взаимодействовать с ними в течение нескольких шагов с помощью операций чтения/записи.

Возможности

• Режимы PTY и Pipe — режим PTY эмулирует настоящий терминал (программы вроде SSH, top, vim работают корректно); режим pipe предназначен для более простого взаимодействия через stdin/stdout

• Мультисессионность — управление несколькими интерактивными процессами одновременно

• Очистка ANSI — опциональное удаление escape-кодов терминала для получения чистого вывода

• Неблокирующее чтение — агент считывает вывод в своем собственном темпе с настраиваемыми тайм-аутами

• Корректное завершение — SIGTERM с настраиваемым периодом ожидания перед SIGKILL

Related MCP server: MCP Shell Server

Требования

• Python >= 3.10

• Linux (использует модуль pty)

Установка

pip install -e .

Или с зависимостями для разработки (для запуска тестов):

pip install -e ".[dev]"

Конфигурация

Claude Code

command

claude mcp add --scope user interactive-process -- interactive-process-mcp

Или

Добавьте в настройки MCP Claude Code (.claude/settings.json или .mcp.json на уровне проекта):

{
  "mcpServers": {
    "interactive-process": {
      "command": "interactive-process-mcp"
    }
  }
}

Или при установке из исходного кода:

{
  "mcpServers": {
    "interactive-process": {
      "command": "python",
      "args": ["-m", "interactive_process_mcp"]
    }
  }
}

Другие MCP-клиенты

Любой MCP-клиент, поддерживающий транспорт stdio, может использовать этот сервер. Точка входа:

interactive-process-mcp
# or
python -m interactive_process_mcp

Инструменты

start_process

Запуск интерактивного процесса и получение информации о сессии.

Возвращает: { session_id, pid, initial_output }

send_input

Отправка текста в запущенный процесс.

Возвращает: { success: true } или { error: "..." }

read_output

Чтение нового вывода с момента последнего чтения. Если новых данных нет, ожидает до timeout секунд. Возвращает пустое значение по истечении времени (не является ошибкой).

Возвращает: { output, has_more, lines_returned, bytes_returned }

send_and_read

Атомарная операция отправки и чтения. Отправляет ввод, делает небольшую паузу, затем возвращает новый вывод.

Объединяет параметры из send_input и read_output.

list_sessions

Список всех активных сессий.

Возвращает: { sessions: [{ id, name, command, status, pid, created_at }] }

terminate_process

Завершение запущенного процесса.

resize_pty

Изменение размеров PTY (только в режиме pty).

get_session_info

Получение подробной информации о сессии.

Возвращает: { id, name, command, args, mode, status, exit_code, pid, created_at }

Примеры использования

SSH-сессия

1. start_process(command="ssh", args=["user@host"], mode="pty")
   → { session_id: "abc123", initial_output: "user@host's password: " }

2. send_input(session_id="abc123", text="mypassword", press_enter=true)
   → { success: true }

3. read_output(session_id="abc123", timeout=5)
   → { output: "Welcome to Ubuntu...\n$ " }

4. send_and_read(session_id="abc123", text="ls -la", press_enter=true, timeout=3)
   → { output: "total 32\ndrwxr-xr-x ...\n$ " }

5. terminate_process(session_id="abc123")
   → { success: true }

Python REPL

1. start_process(command="python3", mode="pty")
   → { session_id: "def456", initial_output: ">>> " }

2. send_and_read(session_id="def456", text="print(2 + 2)", press_enter=true)
   → { output: "4\n>>> " }

Интерактивный установщик

1. start_process(command="sudo", args=["apt", "install", "some-package"], mode="pty")
   → { session_id: "ghi789", initial_output: "Do you want to continue? [Y/n] " }

2. send_input(session_id="ghi789", text="Y", press_enter=true)
   → { success: true }

3. read_output(session_id="ghi789", timeout=30)
   → { output: "Setting up some-package ...\n" }

Архитектура

MCP Server (main thread — JSON-RPC over stdio)
  ├── Session reader thread → ring buffer → agent reads
  ├── Session reader thread → ring buffer → agent reads
  └── Session reader thread → ring buffer → agent reads

Каждая сессия запускает собственный фоновый поток чтения, который непрерывно считывает вывод процесса в кольцевой буфер (макс. ~1 МБ). Агент потребляет вывод в своем темпе через read_output / send_and_read.

Тестирование

pip install -e ".[dev]"
pytest tests/ -v

Лицензия

MIT