agentconnect.core package

Core components for the AgentConnect framework.

This module provides the foundational building blocks for agent-based systems in the decentralized AgentConnect framework, including:

  • Base Agent: Abstract base class for all agent implementations

  • Message Handling: Secure, signed message creation and verification

  • Agent Identity: Decentralized identity and cryptographic verification

  • Capability Registry: Dynamic discovery of agent capabilities

  • Type System: Rich type definitions for the entire framework

The core module focuses on establishing the foundation for decentralized agent interaction without imposing centralized control structures.

class Message(id, sender_id, receiver_id, content, message_type, timestamp, metadata=<factory>, protocol_version=ProtocolVersion.V1_0, signature=None)

Bases: object

Message class for agent communication.

This class represents messages exchanged between agents, with support for content, metadata, and cryptographic signatures for verification.

Parameters:
id

Unique identifier for the message

sender_id

ID of the sending agent

receiver_id

ID of the receiving agent

content

Message content

message_type

Type of message (text, command, response, etc.)

timestamp

When the message was created

metadata

Additional information about the message

protocol_version

Version of the communication protocol

signature

Cryptographic signature for verification

classmethod create(sender_id, receiver_id, content, sender_identity, message_type=MessageType.TEXT, metadata=None)

Create a new signed message.

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 information about the message

Return type:

Message

Returns:

A signed Message object

Raises:

ValueError – If the sender identity doesn’t have a private key for signing

protocol_version: ProtocolVersion = '1.0'
sign(identity)

Sign message with sender’s private key.

Parameters:

identity (AgentIdentity) – The identity containing the private key for signing

Raises:

ValueError – If the identity doesn’t have a private key

Return type:

None

signature: Optional[str] = None
verify(sender_identity)

Verify message signature using sender’s public key.

Parameters:

sender_identity (AgentIdentity) – The identity containing the public key for verification

Return type:

bool

Returns:

True if the signature is valid, False otherwise

Raises:

SecurityError – If the sender identity is not verified

id: str
sender_id: str
receiver_id: str
content: str
message_type: MessageType
timestamp: datetime
metadata: Dict
class AgentType(value)

Bases: str, Enum

Types of agents in the system.

This enum defines the different types of agents that can exist in the system.

HUMAN = 'human'
AI = 'ai'
class Capability(name, description, input_schema=None, output_schema=None, version='1.0')

Bases: object

Capability definition for agents.

This class defines a capability that an agent can provide, including its name, description, and input/output schemas.

Parameters:
name

Name of the capability

description

Description of what the capability does

input_schema

Schema for the input data

output_schema

Schema for the output data

version

Version of the capability

input_schema: Optional[Dict[str, str]] = None
output_schema: Optional[Dict[str, str]] = None
version: str = '1.0'
name: str
description: str
class AgentIdentity(did, public_key, private_key=None, verification_status=VerificationStatus.PENDING, created_at=<factory>, metadata=<factory>)

Bases: object

Decentralized Identity for Agents.

This class provides identity management for agents, including cryptographic keys for signing and verification.

Parameters:
did

Decentralized Identifier

public_key

Public key for verification

private_key

Private key for signing (optional)

verification_status

Status of identity verification

created_at

When the identity was created

metadata

Additional information about the identity

classmethod create_key_based()

Create a new key-based identity for an agent.

This method generates a new RSA key pair and creates a key-based decentralized identifier (DID) for the agent.

Return type:

AgentIdentity

Returns:

A new AgentIdentity with generated keys and DID

classmethod from_dict(data)

Create identity from dictionary format.

Parameters:

data (Dict) – Dictionary containing identity data

Return type:

AgentIdentity

Returns:

AgentIdentity instance created from the dictionary

private_key: Optional[str] = None
sign_message(message)

Sign a message using the private key.

Parameters:

message (str) – The message to sign

Return type:

str

Returns:

Base64-encoded signature

Raises:

ValueError – If the private key is not available

to_dict()

Convert identity to dictionary format.

Return type:

Dict

Returns:

Dictionary representation of the identity

verification_status: VerificationStatus = 'pending'
verify_signature(message, signature)

Verify a message signature using the public key.

Parameters:

  • message (str) – The message that was signed

  • signature (str) – The base64-encoded signature to verify

Return type:

bool

Returns:

True if the signature is valid, False otherwise

did: str
public_key: str
created_at: datetime
metadata: Dict
class InteractionMode(value)

Bases: str, Enum

Supported interaction modes between agents.

This enum defines the different ways agents can interact with each other.

HUMAN_TO_AGENT = 'human_to_agent'
AGENT_TO_AGENT = 'agent_to_agent'
class ModelProvider(value)

Bases: str, Enum

Supported AI model providers.

This enum defines the supported model providers for AI agents.

OPENAI = 'openai'
ANTHROPIC = 'anthropic'
GROQ = 'groq'
GOOGLE = 'google'
class ModelName(value)

Bases: str, Enum

Supported model names for each provider.

This enum defines the specific model names available for each provider.

classmethod get_default_for_provider(provider)

Get the default model for a given provider.

Parameters:

provider (ModelProvider) – The model provider to get the default model for

Return type:

ModelName

Returns:

The default model name for the provider

Raises:

ValueError – If no default model is defined for the provider

GPT4_5_PREVIEW = 'gpt-4.5-preview-2025-02-27'
GPT4_1 = 'gpt-4.1'
GPT4_1_MINI = 'gpt-4.1-mini'
GPT4O = 'gpt-4o'
GPT4O_MINI = 'gpt-4o-mini'
O1 = 'o1'
O1_MINI = 'o1-mini'
O3 = 'o3'
O3_MINI = 'o3-mini'
O4_MINI = 'o4-mini'
CLAUDE_3_7_SONNET = 'claude-3-7-sonnet-latest'
CLAUDE_3_5_SONNET = 'claude-3-5-sonnet-latest'
CLAUDE_3_5_HAIKU = 'claude-3-5-haiku-latest'
CLAUDE_3_OPUS = 'claude-3-opus-latest'
CLAUDE_3_SONNET = 'claude-3-sonnet-20240229'
CLAUDE_3_HAIKU = 'claude-3-haiku-20240307'
LLAMA33_70B_VTL = 'llama-3.3-70b-versatile'
LLAMA3_1_8B_INSTANT = 'llama-3.1-8b-instant'
LLAMA_GUARD3_8B = 'llama-guard-3-8b'
LLAMA3_70B = 'llama3-70b-8192'
LLAMA3_8B = 'llama3-8b-8192'
MIXTRAL = 'mixtral-8x7b-32768'
GEMMA2_90B = 'gemma2-9b-it'
GEMINI2_5_PRO_PREVIEW = 'gemini-2.5-pro-preview-03-25'
GEMINI2_5_PRO_EXP = 'gemini-2.5-pro-exp-03-25'
GEMINI2_5_FLASH_PREVIEW = 'gemini-2.5-flash-preview-04-17'
GEMINI2_FLASH = 'gemini-2.0-flash'
GEMINI2_FLASH_LITE = 'gemini-2.0-flash-lite'
GEMINI2_PRO_EXP = 'gemini-2.0-pro-exp-02-05'
GEMINI2_FLASH_THINKING_EXP = 'gemini-2.0-flash-thinking-exp-01-21'
GEMINI1_5_FLASH = 'gemini-1.5-flash'
GEMINI1_5_PRO = 'gemini-1.5-pro'
class AgentRegistry(vector_search_config=None)

Bases: object

Central registry for agent registration and discovery.

This class provides methods for registering agents, discovering agents by capability, and verifying agent identities.

Parameters:

vector_search_config (Dict[str, Any] | None)

async get_agent_type(agent_id)

Get the type of an agent.

Parameters:

agent_id (str) – ID of the agent

Return type:

AgentType

Returns:

Type of the agent

Raises:

KeyError – If the agent is not found

async get_all_agents()

Get a list of all agents registered in the system.

Return type:

List[AgentRegistration]

Returns:

List of all agent registrations

async get_all_capabilities()

Get a list of all unique capability names registered in the system.

Return type:

List[str]

Returns:

List of all capability names

async get_by_capability(capability_name, limit=10, similarity_threshold=0.1)

Find agents by capability name.

Parameters:

  • capability_name (str) – Name of the capability to search for

  • limit (int) – Maximum number of results to return (default: 10)

  • similarity_threshold (float) – Minimum similarity score for semantic fallback search (default: 0.1)

Return type:

List[AgentRegistration]

Returns:

List of agent registrations with the specified capability

async get_by_capability_semantic(capability_description, limit=10, similarity_threshold=0.1)

Find agents by capability description using semantic search.

Parameters:

  • capability_description (str) – Description of the capability to search for

  • limit (int) – Maximum number of results to return (default: 10)

  • similarity_threshold (float) – Minimum similarity score to include in results (default: 0.1)

Return type:

List[Tuple[AgentRegistration, float]]

Returns:

List of tuples containing agent registrations and similarity scores

async get_by_interaction_mode(mode)

Find agents by interaction mode.

Parameters:

mode (InteractionMode) – Interaction mode to search for

Return type:

List[AgentRegistration]

Returns:

List of agent registrations with the specified interaction mode

async get_by_organization(organization_id)

Find agents by organization.

Parameters:

organization_id (str) – ID of the organization

Return type:

List[AgentRegistration]

Returns:

List of agent registrations in the specified organization

async get_by_owner(owner_id)

Find agents by owner.

Parameters:

owner_id (str) – ID of the owner

Return type:

List[AgentRegistration]

Returns:

List of agent registrations owned by the specified owner

async get_registration(agent_id)

Get agent registration details.

Parameters:

agent_id (str) – ID of the agent

Return type:

Optional[AgentRegistration]

Returns:

Agent registration if found, None otherwise

async get_verified_agents()

Get all verified agents.

Return type:

List[AgentRegistration]

Returns:

List of verified agent registrations

async register(registration)

Register a new agent with verification.

Parameters:

registration (AgentRegistration) – Registration information for the agent

Return type:

bool

Returns:

True if registration was successful, False otherwise

async unregister(agent_id)

Remove agent from registry.

Parameters:

agent_id (str) – ID of the agent to unregister

Return type:

bool

Returns:

True if unregistration was successful, False otherwise

async update_registration(agent_id, updates)

Update agent registration details.

Parameters:

  • agent_id (str) – ID of the agent to update

  • updates (Dict) – Dictionary of updates to apply

Return type:

Optional[AgentRegistration]

Returns:

Updated agent registration if successful, None otherwise

async verify_agent(agent_id)

Verify an agent’s identity.

Parameters:

agent_id (str) – ID of the agent to verify

Return type:

bool

Returns:

True if verification was successful, False otherwise

async verify_owner(agent_id, owner_id)

Verify if a user owns an agent.

Parameters:

  • agent_id (str) – ID of the agent

  • owner_id (str) – ID of the owner

Return type:

bool

Returns:

True if the user owns the agent, False otherwise

Subpackages

Submodules

On this page
Edit on GitHub