* Error level logging - for errors (always logged)

* Info level logging - for general information

* Log level logging - alias for info

* Debug level logging - for detailed debugging information

Send a message to this channel. Args: content: Message content (string or dict) **kwargs: Additional message paramete

* Event handling

Return a JSON response with a specific code.

Mark an outId processed and persist. Now-timestamp is injected (testable).

* Start a timer

Execute the tool with the provided parameters. Automatically detects whether the underlying function is async or sync and ha

Check if file exists at storage key.

Send an event to the network.

* Warning level logging - for warnings

Pydantic-style model dump for backward compatibility.

Return a standard success response.

Kill the HTTP server.

Disconnect from the network server.

Send an event to the network. Args: event: The event to send Returns: Optional[EventResponse]: The response

Connect to a network server (alias for connect_to_server). This is a cleaner alias for the connect_to_server method. Args:

* Apply resolve_env rules to map generic vars to provider-specific vars. * * Rules format (from YAML plugin definition): * { from: 'LLM_API

Create a new task in the store. Args: task: The task to create Returns: The created task (may have updated f

* Send an event to the network and get immediate EventResponse

Run an openagents CLI command and return the result. Tries the `openagents` binary first, falls back to the entry point script next to the cu

Initialize the mod. Returns: bool: True if initialization was successful, False otherwise

Print text safely on all platforms. On Windows with cp1252, Unicode characters (box-drawing, emoji) cause UnicodeEncodeError. This replaces u

Shutdown the mod gracefully. Returns: bool: True if shutdown was successful, False otherwise

Check if the caller has access to a workspace via token, bearer owner, or collaborator.

Register an event handler for the mod. Args: handler: The handler function to register patterns: The patterns to matc

Read file data by storage key.

Resolve workspace by ID or slug.

Clear all tasks from the store.

Delete file data by storage key.

Start the adapter: heartbeat + poll loop.

Create a standardized event response.

Create a simple text message.

* Group logs together (useful for debugging)

Send a direct message to this agent. Args: content: Message content (string or dict) **kwargs: Additional message par

Print message only if verbose mode is enabled. Args: *args: Arguments to pass to print() **kwargs: Keyword arguments to pass to p

Get a specific channel by name. Args: channel_name: Name of the channel (with or without # prefix) Returns:

Get the storage path for this mod. Returns: Optional[Path]: Path to mod's storage directory, or None if no workspace manager

Announce a remote A2A agent to the registry. This fetches the agent's Agent Card and creates an AgentConnection for registration in t

* Clear all read message data (for debugging or reset)

Click an element by CSS selector.

Register an agent with the network. Args: agent_id: Unique identifier for the agent transport_type: Transport type us

Helper function to create a log entry dictionary.

Wait for the server thread to finish.

Load an AgentNetwork from a YAML configuration file. Args: config: String or Path to a YAML config file, or None to auto-discover

Extract request_id from message, with fallback to event_id.

* Delete env file for an agent type.

Handle sending events/messages via HTTP.

Send an error message to a channel.

* Build a CopilotAdapter wired to the mock CLI with all network sends captured.