mirror of
https://github.com/agent0ai/agent-zero.git
synced 2026-05-31 21:39:24 +00:00
8c5cf1f69f
Introduce the builtin `_a0_connector` plugin that lets the host-side A0 CLI connect to Agent Zero over authenticated HTTP and `/ws`. This adds connector capability discovery, chat/context lifecycle endpoints, log streaming, and the remote text editing, code execution, and file tree bridge used by the CLI workflow.
32 lines
1.1 KiB
Python
32 lines
1.1 KiB
Python
"""POST /api/plugins/_a0_connector/v1/log_tail."""
|
|
from __future__ import annotations
|
|
|
|
from helpers.api import Request, Response
|
|
import plugins._a0_connector.api.v1.base as connector_base
|
|
|
|
|
|
class LogTail(connector_base.ProtectedConnectorApiHandler):
|
|
async def process(self, input: dict, request: Request) -> dict | Response:
|
|
from plugins._a0_connector.helpers.event_bridge import (
|
|
get_context_log_entries,
|
|
)
|
|
|
|
context_id = str(input.get("context_id", "")).strip()
|
|
if not context_id:
|
|
return Response(
|
|
response='{"error": "context_id is required"}',
|
|
status=400,
|
|
mimetype="application/json",
|
|
)
|
|
|
|
after = int(input.get("after", 0) or 0)
|
|
limit = min(int(input.get("limit", 50) or 50), 250)
|
|
|
|
events, last_sequence = get_context_log_entries(context_id, after=after)
|
|
limited_events = events[:limit]
|
|
return {
|
|
"context_id": context_id,
|
|
"events": limited_events,
|
|
"last_sequence": last_sequence,
|
|
"has_more": len(events) > len(limited_events),
|
|
}
|