ertad-family/liquid

Однократная настройка для API. Обнаруживает API по url, использует LLM для сопоставления его ответов с вашей target_model и сохраняет переиспользуемый адаптер; возвращает adapter_id, который затем передаёте в liquid_fetch / liquid_query / liquid_estimate. Побочные эффекты: выполняет исходящие HTTP(S)-запросы к url, вызывает настроенную LLM (требуется API-ключ) и сохраняет адаптер вместе с учётными данными в ~/.liquid. Идемпотентен: повторное подключение с теми же url и target_model использует существующий адаптер, а не создаёт дубликат. Используйте один раз на каждый API. Для быстрого просмотра без сохранения используйте liquid_discover; для чтения данных из уже подключённого API — liquid_fetch.

Проверяет структуру API: имя сервиса, метод обнаружения, тип аутентификации и список эндпоинтов — без создания или сохранения адаптера. Побочные эффекты: выполняет исходящие HTTP(S)-запросы к url для разведки и может вызывать настроенную LLM для API, которые не публикуют машиночитаемую спецификацию (эвристика REST). Только чтение: ничего не сохраняется. Используйте это, чтобы предварительно изучить незнакомое API; когда будете готовы реально читать данные, вызывайте liquid_connect — он обнаруживает, и отображает, и сохраняет переиспользуемый адаптер.

Предварительная оценка для fetch — прогнозируемое количество элементов, байт, токенов, кредитов и задержка, каждый параметр с указанием уверенности и источника — без выполнения каких-либо HTTP-вызовов или вызовов LLM. Только чтение и бесплатно. Возвращает {estimate: {...}}. Проверьте это перед потенциально большим liquid_fetch, чтобы решить, стоит ли сначала сузить выборку с помощью liquid_query (фильтр/агрегация). Требуется adapter_id от liquid_connect.

Извлекает записи через подключенный адаптер, сопоставленные с target_model, который вы задали при подключении — детерминированно, без вызова LLM. Побочные эффекты: отправляет исходящий HTTP(S)-запрос только на чтение к подключенному API, используя сохраненные учетные данные; подчиняется лимитам частоты запросов этого API (Liquid заранее применяет троттлинг и возвращает ошибки 429 с подсказками для повторной попытки). Возвращает {records, data: [до 100 сопоставленных записей], _meta}. Требуется adapter_id из liquid_connect. Используйте это для получения полных записей; для фильтрации/агрегации на стороне сервера и получения меньшего ответа используйте вместо этого liquid_query; чтобы оценить размер выгрузки до её выполнения, сначала вызовите liquid_estimate.

Перечислить адаптеры, уже подключенные на этой машине (читать из ~/.liquid) — только чтение, без сетевых вызовов, без LLM. Каждая запись содержит adapter_id, название сервиса, source url и пути эндпоинтов. Вызывайте это, чтобы найти adapter_id для liquid_fetch / liquid_query / liquid_estimate, или чтобы проверить, подключено ли уже API, перед вызовом liquid_connect.

Выполняет поиск или агрегацию на стороне сервера через адаптер и возвращает только ответ, без полного набора данных — детерминированно, без вызова LLM, только чтение. Два режима: через group_by/agg для агрегации (количество, суммы и т.д.) или через where/fields/limit для фильтрации и проекции. Побочные эффекты: исходящий HTTP(S) запрос на чтение к подключённому API, с ограничением частоты, как у liquid_fetch. Возвращает результаты поиска {records, data, _meta} или агрегацию {result, _meta}. Используйте этот инструмент вместо liquid_fetch, когда нужно только отфильтрованное подмножество, количество или сводка — он возвращает гораздо меньше токенов.

Узнай, что произошло в мире с момента последней проверки: опрашивай endpoint на предмет событий, произошедших после cursor - новые строки в БД, опубликованные сообщения и т.д. Возвращает пакет событий (каждое с modality, payload и cursor) плюс next_cursor, чтобы продолжить с него. Это читающая сторона чувств агента - вызывай его повторно, передавая последний next_cursor, чтобы оставаться в курсе изменений, не пересматривая старые события. Ограничен max_events / max_seconds, поэтому всегда возвращает результат быстро. Где liquid_fetch - однократное получение текущего состояния, liquid_sense воспринимает, что изменилось с последней проверки. Требует adapter_id от liquid_connect. Поддерживают только endpoints, способные к восприятию (таблицы SQL, каналы Redis, WebSocket, потоки SSE/NDJSON, уведомления MCP, MQTT, Modbus, OPC UA, BACnet, ADB logcat); остальные возвращают ошибку. Только для чтения - он воспринимает, он ничего не меняет.