agentconnect.communication.protocols package

Communication protocols that enable diverse agent interactions.

This module provides protocol implementations that standardize different types of agent communication patterns. These protocols support peer-to-peer messaging, capability discovery, and collaborative task execution between independent agents.

The protocols ensure message format consistency while allowing agents to maintain their individual autonomy and decision-making processes.

class BaseProtocol

Bases: ABC

Foundation for all agent communication protocols.

This abstract class defines the common interface and baseline functionality for all communication protocols, ensuring consistent message handling across different interaction patterns. It provides the foundation for both basic agent-to-agent messaging and more complex collaboration patterns based on capability discovery.

The protocol system enables standardized communication without requiring central control of agent behavior - it simply ensures messages are properly formatted, signed, and validated.

abstractmethod async format_message(sender_id, receiver_id, content, sender_identity, message_type=MessageType.TEXT, metadata=None)

Format a message according to protocol specifications.

Parameters:

  • sender_id (str) – ID of the sending agent

  • receiver_id (str) – ID of the receiving agent

  • content (str) – Message content

  • sender_identity (AgentIdentity) – Identity of the sending agent

  • message_type (MessageType) – Type of message being sent

  • metadata (Optional[Dict]) – Additional metadata for the message

Return type:

Message

Returns:

A properly formatted Message object

abstractmethod async validate_message(message)

Validate message format and contents.

Parameters:

message (Message) – The message to validate

Return type:

bool

Returns:

True if the message is valid, False otherwise

class SimpleAgentProtocol

Bases: BaseProtocol

Protocol that ensures secure peer-to-peer agent communication.

This protocol handles message formatting, cryptographic verification, and validation for direct communication between agents. It ensures that messages are properly signed and can be verified by the receiving agent, maintaining security in peer-to-peer interactions.

async format_message(sender_id, receiver_id, content, sender_identity, message_type=MessageType.TEXT, metadata=None)

Format a message with proper protocol metadata

Return type:

Message

Parameters:
async validate_message(message)

Validate message against protocol requirements

Return type:

bool

Parameters:

message (Message)

class CollaborationProtocol

Bases: BaseProtocol

Protocol that enables peer-to-peer agent collaboration and capability sharing.

This protocol facilitates dynamic discovery and utilization of capabilities across a network of independent agents. It allows agents to:

  1. Discover what other agents can do through capability queries

  2. Request help from agents with relevant capabilities

  3. Share results after task completion

Agents maintain their independence - each agent decides whether to accept collaboration requests based on its own criteria. The protocol simply standardizes the communication pattern without imposing central control.

async format_message(sender_id, receiver_id, content, sender_identity, message_type=MessageType.TEXT, metadata=None)

Format a message according to the collaboration protocol.

Return type:

Message

Parameters:
async validate_message(message)

Validate message against protocol requirements.

Return type:

bool

Parameters:

message (Message)

Submodules