Function _build_trajectory_from_events

src/agent/opencode_agent/runner.py:423–564

Convert OpenCode events into the shared SDK-style trajectory shape. Text/tool parts are merged by part id, turns are split on OpenCode step-finish boundaries, and the canonical answer is scoped to the final assistant message instead of concatenating all intermediate narration.

(
    events: list[dict[str, Any]],
    plain_lines: list[str],
    *,
    duration_ms: float | None = None,
    stderr: str = "",
)

def _build_trajectory_from_events(
    events: list[dict[str, Any]],
    plain_lines: list[str],
    *,
    duration_ms: float | None = None,
    stderr: str = "",
) -> tuple[str, OpenCodeTrajectory]:
    """Convert OpenCode events into the shared SDK-style trajectory shape.

    Text/tool parts are merged by part id, turns are split on OpenCode
    step-finish boundaries, and the canonical answer is scoped to the final
    assistant message instead of concatenating all intermediate narration.
    """
    text_by_part: OrderedDict[str, str] = OrderedDict()
    msg_by_part: dict[str, str] = {}
    tool_calls: OrderedDict[str, ToolCall] = OrderedDict()

    steps: list[dict[str, Any]] = []
    pending_text: list[str] = []
    pending_tools: list[str] = []

    def _close_step(input_tokens: int, output_tokens: int) -> None:
        if not (pending_text or pending_tools or input_tokens or output_tokens):
            return
        steps.append(
            {
                "text_ids": list(pending_text),
                "tool_ids": list(pending_tools),
                "input_tokens": input_tokens,
                "output_tokens": output_tokens,
            }
        )
        pending_text.clear()
        pending_tools.clear()

    for index, event in enumerate(events):
        part = _candidate_part(event)
        if part is None:
            part = event

        part_type = str(part.get("type") or part.get("kind") or "").lower()
        part_id = str(
            part.get("id")
            or part.get("partID")
            or part.get("messageID")
            or f"event_{index}"
        )

        if _is_step_finish(event, part, part_type):
            step_in, step_out = _usage_from_events([event])
            _close_step(step_in, step_out)
            continue

        text_value = part.get("text") or part.get("content")
        if isinstance(text_value, str) and _is_answer_text(part_type, part):
            text_by_part[part_id] = _merge_text(
                text_by_part.get(part_id, ""), text_value
            )