primus.chat package

Shared chat session operations for CLI and MCP tools.

class primus.chat.ChatMessageActionService(client: Any)

Bases: object

Create or reuse nonblocking human actions without changing Procedure state.

__init__(client: Any)

create_or_get(action: Mapping[str, Any], *, procedure_id: str, session_id: str | None = None) → dict[str, Any]

publish_update(update: Mapping[str, Any], *, procedure_id: str, session_id: str | None = None) → dict[str, Any]: Create one idempotent milestone notification using ChatMessage.

resolve_first_valid_response(message_id: str, *, account_id: str, procedure_id: str) → dict[str, Any] | None: Validate and atomically claim the oldest valid child RESPONSE.

Submodules