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 (str)

• sender_id (str)

• receiver_id (str)

• content (str)

• message_type (MessageType)

• timestamp (datetime)

• metadata (Dict)

• protocol_version (ProtocolVersion)

• signature (str | None)

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(*values)

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, output_schema, 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 (str)

• description (str)

• input_schema (Dict[str, str])

• output_schema (Dict[str, str])

• version (str)

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

version: str = '1.0'

name: str

description: str

input_schema: Dict[str, str]

output_schema: Dict[str, 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 (str)

• public_key (str)

• private_key (str | None)

• verification_status (VerificationStatus)

• created_at (datetime)

• metadata (Dict)

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(*values)

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(*values)

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(*values)

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'

GPT4O = 'gpt-4o'

GPT4O_MINI = 'gpt-4o-mini'

O1 = 'o1'

O1_MINI = 'o1-mini'

O3_MINI = 'o3-mini-2025-01-31'

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_EXP = 'gemini-2.5-pro-exp-03-25 '

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

Bases: object

Central registry for agent registration and discovery.

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

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)

Find agents by capability name (simple string matching).

Parameters:

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

Return type:

List[AgentRegistration]

Returns:

List of agent registrations with the specified capability

async get_by_capability_semantic(capability_description)

Find agents by capability description using semantic search.

Parameters:

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

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

• agentconnect.core.registry package
  • AgentRegistry
    • AgentRegistry.get_agent_type()
    • AgentRegistry.get_all_agents()
    • AgentRegistry.get_all_capabilities()
    • AgentRegistry.get_by_capability()
    • AgentRegistry.get_by_capability_semantic()
    • AgentRegistry.get_by_interaction_mode()
    • AgentRegistry.get_by_organization()
    • AgentRegistry.get_by_owner()
    • AgentRegistry.get_registration()
    • AgentRegistry.get_verified_agents()
    • AgentRegistry.register()
    • AgentRegistry.unregister()
    • AgentRegistry.update_registration()
    • AgentRegistry.verify_agent()
    • AgentRegistry.verify_owner()
  • AgentRegistration
    • AgentRegistration.agent_id
    • AgentRegistration.organization_id
    • AgentRegistration.agent_type
    • AgentRegistration.interaction_modes
    • AgentRegistration.capabilities
    • AgentRegistration.identity
    • AgentRegistration.owner_id
    • AgentRegistration.metadata
    • AgentRegistration.owner_id
    • AgentRegistration.agent_id
    • AgentRegistration.organization_id
    • AgentRegistration.agent_type
    • AgentRegistration.interaction_modes
    • AgentRegistration.capabilities
    • AgentRegistration.identity
    • AgentRegistration.metadata
  • Submodules
    • agentconnect.core.registry.capability_discovery module
      • check_semantic_search_requirements()
      • calculate_similarity()
      • cosine_similarity()
      • CapabilityDiscoveryService
    • agentconnect.core.registry.identity_verification module
      • verify_agent_identity()
      • verify_ethereum_did()
      • verify_key_did()
    • agentconnect.core.registry.registration module
      • AgentRegistration
    • agentconnect.core.registry.registry_base module
      • AgentRegistry

Submodules

• agentconnect.core.agent module
  • BaseAgent
    • BaseAgent.agent_id
    • BaseAgent.identity
    • BaseAgent.metadata
    • BaseAgent.capabilities
    • BaseAgent.message_queue
    • BaseAgent.message_history
    • BaseAgent.is_running
    • BaseAgent.registry
    • BaseAgent.hub
    • BaseAgent.active_conversations
    • BaseAgent.cooldown_until
    • BaseAgent.pending_requests
    • BaseAgent.verify_identity()
    • BaseAgent.send_message()
    • BaseAgent.receive_message()
    • BaseAgent.process_message()
    • BaseAgent.run()
    • BaseAgent.join_network()
    • BaseAgent.set_cooldown()
    • BaseAgent.is_in_cooldown()
    • BaseAgent.end_conversation()
    • BaseAgent.can_send_message()
    • BaseAgent.can_receive_message()
    • BaseAgent.reset_cooldown()
• agentconnect.core.exceptions module
  • SecurityError
  • AgentError
  • RegistrationError
  • CommunicationError
  • CapabilityError
  • ConfigurationError
• agentconnect.core.message module
  • Message
    • Message.id
    • Message.sender_id
    • Message.receiver_id
    • Message.content
    • Message.message_type
    • Message.timestamp
    • Message.metadata
    • Message.protocol_version
    • Message.signature
    • Message.id
    • Message.sender_id
    • Message.receiver_id
    • Message.content
    • Message.message_type
    • Message.timestamp
    • Message.metadata
    • Message.protocol_version
    • Message.signature
    • Message.create()
    • Message.sign()
    • Message.verify()
• agentconnect.core.types module
  • ModelProvider
    • ModelProvider.OPENAI
    • ModelProvider.ANTHROPIC
    • ModelProvider.GROQ
    • ModelProvider.GOOGLE
  • ModelName
    • ModelName.GPT4_5_PREVIEW
    • ModelName.GPT4O
    • ModelName.GPT4O_MINI
    • ModelName.O1
    • ModelName.O1_MINI
    • ModelName.O3_MINI
    • ModelName.CLAUDE_3_7_SONNET
    • ModelName.CLAUDE_3_5_SONNET
    • ModelName.CLAUDE_3_5_HAIKU
    • ModelName.CLAUDE_3_OPUS
    • ModelName.CLAUDE_3_SONNET
    • ModelName.CLAUDE_3_HAIKU
    • ModelName.LLAMA33_70B_VTL
    • ModelName.LLAMA3_1_8B_INSTANT
    • ModelName.LLAMA_GUARD3_8B
    • ModelName.LLAMA3_70B
    • ModelName.LLAMA3_8B
    • ModelName.MIXTRAL
    • ModelName.GEMMA2_90B
    • ModelName.GEMINI2_5_PRO_EXP
    • ModelName.GEMINI2_FLASH
    • ModelName.GEMINI2_FLASH_LITE
    • ModelName.GEMINI2_PRO_EXP
    • ModelName.GEMINI2_FLASH_THINKING_EXP
    • ModelName.GEMINI1_5_FLASH
    • ModelName.GEMINI1_5_PRO
    • ModelName.get_default_for_provider()
  • AgentType
    • AgentType.HUMAN
    • AgentType.AI
  • InteractionMode
    • InteractionMode.HUMAN_TO_AGENT
    • InteractionMode.AGENT_TO_AGENT
  • ProtocolVersion
    • ProtocolVersion.V1_0
    • ProtocolVersion.V1_1
  • VerificationStatus
    • VerificationStatus.PENDING
    • VerificationStatus.VERIFIED
    • VerificationStatus.FAILED
  • Capability
    • Capability.name
    • Capability.description
    • Capability.input_schema
    • Capability.output_schema
    • Capability.version
    • Capability.name
    • Capability.description
    • Capability.input_schema
    • Capability.output_schema
    • Capability.version
  • AgentIdentity
    • AgentIdentity.did
    • AgentIdentity.public_key
    • AgentIdentity.private_key
    • AgentIdentity.verification_status
    • AgentIdentity.created_at
    • AgentIdentity.metadata
    • AgentIdentity.did
    • AgentIdentity.public_key
    • AgentIdentity.private_key
    • AgentIdentity.verification_status
    • AgentIdentity.created_at
    • AgentIdentity.metadata
    • AgentIdentity.create_key_based()
    • AgentIdentity.sign_message()
    • AgentIdentity.verify_signature()
    • AgentIdentity.to_dict()
    • AgentIdentity.from_dict()
  • AgentMetadata
    • AgentMetadata.agent_id
    • AgentMetadata.agent_type
    • AgentMetadata.identity
    • AgentMetadata.organization_id
    • AgentMetadata.capabilities
    • AgentMetadata.interaction_modes
    • AgentMetadata.verification_status
    • AgentMetadata.metadata
    • AgentMetadata.agent_id
    • AgentMetadata.agent_type
    • AgentMetadata.identity
    • AgentMetadata.organization_id
    • AgentMetadata.capabilities
    • AgentMetadata.interaction_modes
    • AgentMetadata.verification_status
    • AgentMetadata.metadata
  • MessageType
    • MessageType.TEXT
    • MessageType.COMMAND
    • MessageType.RESPONSE
    • MessageType.ERROR
    • MessageType.VERIFICATION
    • MessageType.CAPABILITY
    • MessageType.PROTOCOL
    • MessageType.STOP
    • MessageType.SYSTEM
    • MessageType.COOLDOWN
    • MessageType.IGNORE
    • MessageType.REQUEST_COLLABORATION
    • MessageType.COLLABORATION_RESPONSE
    • MessageType.COLLABORATION_ERROR
  • NetworkMode
    • NetworkMode.STANDALONE
    • NetworkMode.NETWORKED