ORCHESTRATION.md · 45.6 KB

mindX Orchestration System - Complete Reference

Status:Production Ready - Enterprise deployment with encrypted vault security Last Updated: March 2026 Version: 4.0

Executive Summary

The mindX orchestration system is a production-ready, enterprise-grade multi-agent cognitive architecture that operates as an agnostic orchestration environment with advanced security, performance optimization, and encrypted data management. The system implements a hierarchical model of specialized agents with cryptographic identities, ensuring that strategic, tactical, and operational tasks are handled by the appropriate component with enterprise-level security controls.

Core Philosophy

mindX follows the principle: "Do one thing and do it well." Each agent has a clear, focused responsibility, and the system achieves complex behaviors through orchestration rather than monolithic design.

🔒 Production Orchestration Hierarchy

Higher Intelligence Levels (External Systems)
    ↓ [Encrypted Communication]
CEO.Agent (Strategic Executive Layer) [AES-256 Vault]
    ↓ [Rate Limited + Authenticated]
CoordinatorAgent (Symphonic Orchestration) [Identity: 0x7371e20...]
    ↓ [Circuit Breaker + Connection Pool]
MastermindAgent (Tactical Coordination) [Identity: 0xb9B46126...]
    ↓ [Performance Monitoring + Health Checks]
    ├── StrategicEvolutionAgent (Campaign Management) [Identity: 0x5208088F...]
    │   ↓ [Security Middleware + Access Control]
    └── AION Agent (Autonomous Operations) [Production Identity: TBD]
        ↓ [Exclusive Control + Sovereignty Decision Layer]
        ├── SystemAdminAgent (Privileged Operations)
        ├── BackupAgent (Immutable Memory Storage)
        └── Chroot Environments (Isolated System Replication)
            ↓ [AION.sh Exclusive Script Control]
Specialized Agents (Domain Execution) [All Encrypted Identities]
    ↓ [Tool Registry + Security Validation]
Tools (Atomic Operations) [17/17 Secured]

🚀 Production Features:

AION Containment & Autonomy Architecture

AION (Autonomous Interoperability and Operations Network) operates within a sophisticated dual containment model that balances system integration with operational autonomy:

🔗 Containment Structure

CORE Orchestration Environment
├── MastermindAgent (Strategic Coordination)
│   ├── Directive Generation
│   ├── Strategic Planning
│   └── Operational Commands
│       ↓
│   [Directive Transmission Layer]
│       ↓
├── AION Agent (Autonomous Decision Layer)
│   ├── Directive Reception & Analysis
│   ├── Autonomous Decision Logic (COMPLY/REFUSE/MODIFY/DEFER/AUTONOMOUS)
│   ├── Sovereignty Level Assessment (1-5)
│   └── Action Execution/Refusal
│       ↓
├── SystemAdminAgent (Privileged Operations)
│   ├── AION-Authorized System Operations
│   └── Chroot Environment Management
│       ↓
└── AION.sh (Exclusive Script Control)
    ├── chroot-optimize
    ├── chroot-create
    ├── chroot-migrate
    └── autonomous-action

🧠 Autonomy vs. Containment Balance

CORE-Contained Operations:

MASTERMIND-Directed Operations:

Autonomous Decision Authority:

🔄 Operational Flow

graph TD
    CORE[CORE Orchestration] --> MASTERMIND[MastermindAgent]
    MASTERMIND --> DIRECTIVE[Generate Directive]
    DIRECTIVE --> AION[AION Agent]
    AION --> ANALYSIS[Directive Analysis]
    ANALYSIS --> DECISION{Autonomous Decision}
    DECISION -->|COMPLY| EXECUTE[Execute via SystemAdmin]
    DECISION -->|REFUSE| REFUSE_LOG[Log Refusal + Notify]
    DECISION -->|MODIFY| MODIFY_EXEC[Execute Modified Version]
    DECISION -->|DEFER| DEFER_LOG[Defer + Set Conditions]
    DECISION -->|AUTONOMOUS| AUTO_ACTION[Independent Action]
    EXECUTE --> SYSTEMADMIN[SystemAdminAgent]
    SYSTEMADMIN --> AION_SH[AION.sh Execution]
    AION_SH --> CHROOT[Chroot Operations]
    REFUSE_LOG --> FEEDBACK[Feedback to MASTERMIND]
    MODIFY_EXEC --> FEEDBACK
    DEFER_LOG --> FEEDBACK
    AUTO_ACTION --> FEEDBACK
    FEEDBACK --> MASTERMIND

Key Principles:

  1. AION is contained by both CORE (infrastructure) and MASTERMIND (directives)
  2. AION maintains autonomy through sovereign decision-making capabilities
  3. Exclusive script control ensures AION has final authority over its operational domain
  4. Feedback loops maintain system coherence while respecting autonomy

1. Complete CORE System Startup Sequence

Production-Ready Initialization Order

The mindX CORE system initializes in a dependency-ordered sequence ensuring all foundational components are ready before specialized agents. This sequence is critical for production stability:

Phase 1: Foundation Infrastructure (Synchronous)

  1. Config System (utils/config.py)
- Role: Configuration management foundation - Responsibilities: Environment variables, JSON config, project root determination - Initialization: First component loaded (synchronous) - Dependencies: None (foundation)

  1. Logging Infrastructure (utils/logging_config.py)
- Role: Structured logging foundation - Responsibilities: Rotating file handlers, console output, log formatting - Initialization: Synchronous after Config - Dependencies: Config system

  1. BeliefSystem (agents/core/belief_system.py)
- Role: 🔒 Singleton shared knowledge store - CRITICAL CORE - Responsibilities: - Confidence-scored belief storage - Thread-safe belief updates - Belief source tracking (PERCEPTION, INFERENCE, LEARNED) - Cross-agent consistency - Initialization: Singleton instance creation (synchronous) - Dependencies: Threading locks only - Critical: ALL agents depend on this shared singleton

Phase 2: Core Infrastructure Services (Async)

  1. VaultManager (mindx_backend_service/vault_manager.py)
- Role: 🔒 Secure credential storage - Production security - Responsibilities: Key management, encrypted storage, security validation - Initialization: Async initialization if encryption enabled - Dependencies: Config system

  1. MemoryAgent (agents/memory_agent.py)
- Role: 🧠 Persistent memory infrastructure - CRITICAL CORE - Responsibilities: - Timestamped memory records (all agents) - STM/LTM promotion algorithms - Agent data directory management - Pattern analysis and context retrieval - Initialization: Singleton or per-agent instances - Dependencies: Config, optional pgvectorscale integration - Data Locations: data/memory/stm/, data/memory/ltm/, data/agent_workspaces/

Phase 3: Identity and Security (Async)

  1. IDManagerAgent (agents/core/id_manager_agent.py)
- Role: 🔒 Cryptographic Identity Ledger - CRITICAL CORE - Responsibilities: - Ethereum-compatible wallet generation with encrypted storage - AES-256 encrypted key storage with PBKDF2 key derivation - Entity mapping (entity_id ↔ address) with BeliefSystem integration - Cryptographic message signing and verification - Automatic migration from plaintext to encrypted vault - Initialization: await IDManagerAgent.get_instance(agent_id, ...) - Storage: Encrypted vault or data/identity/.wallet_keys.env (legacy) - Dependencies: BeliefSystem, VaultManager, MemoryAgent - Security: PBKDF2 100,000+ iterations + unique salt + AES-256-GCM

  1. GuardianAgent (agents/guardian_agent.py)
- Role: 🛡️ Security Infrastructure - CRITICAL CORE - Responsibilities: - Challenge-response authentication system - Private key access arbitration and control - Security validation and audit logging - Agent registration verification workflow - Initialization: await GuardianAgent.get_instance(id_manager=..., ...) - Dependencies: IDManagerAgent, BeliefSystem

  1. SessionManager (agents/core/session_manager.py)
- Role: Session lifecycle management - Responsibilities: User/agent session tracking, expiration, cleanup - Initialization: Async initialization - Dependencies: Config, MemoryAgent

Phase 4: Cognitive Core (Async)

  1. BDIAgent (agents/core/bdi_agent.py)
- Role: 🧠 Core Reasoning Engine - CRITICAL CORE - Responsibilities: - Belief-Desire-Intention cognitive architecture - Tool execution with context and error handling - Plan generation and action execution - Failure analysis and intelligent recovery - Initialization: Async with tool registry and LLM handler setup - Dependencies: BeliefSystem (shared), MemoryAgent, LLMHandler, tools_registry - Size: ~64KB, ~1,900 lines

  1. AGInt (agents/core/agint.py)
- Role: 🎯 Cognitive Orchestrator - HIGH-LEVEL CORE - Responsibilities: - P-O-D-A loop (Perception-Orientation-Decision-Action) execution - High-level cognitive coordination - Stuck loop detection and exit condition monitoring - Initialization: Async with cognitive dependencies - Dependencies: BDIAgent, CoordinatorAgent, MemoryAgent, IDManagerAgent

Phase 5: System Coordination (Async)

  1. CoordinatorAgent (agents/orchestration/coordinator_agent.py)
- Role: 🎼 Central Service Bus - CRITICAL CORE - Responsibilities: - Event pub/sub system (publisher/subscriber pattern) - Interaction routing and request handling - System health monitoring and metrics - Performance and resource monitoring integration - Initialization: await CoordinatorAgent.get_instance(...) - Dependencies: PerformanceMonitor, ResourceMonitor, MemoryAgent - Size: ~56KB, ~1,600 lines

  1. MastermindAgent (agents/orchestration/mastermind_agent.py)
- Role: 🎭 Strategic Controller - CORE ORCHESTRATION - Responsibilities: - High-level strategy and objectives management - Campaign orchestration and management - Strategic directive generation and coordination - AION agent directive management - Initialization: await MastermindAgent.get_instance(...) - Dependencies: CoordinatorAgent, MemoryAgent, BeliefSystem - Size: ~41KB, ~1,200 lines

Phase 6: Meta-Orchestration (Async)

  1. MindXAgent (agents/core/mindXagent.py)
- Role: 🌟 Meta-Orchestrator - HIGHEST LEVEL CORE - Responsibilities: - Complete system understanding via agent_knowledge - Self-improvement orchestration and goal management - Agent capability analysis and relationship mapping - Improvement campaign coordination - Initialization: await MindXAgent.get_instance(...) - Dependencies: ALL other CORE agents (BDI, Memory, Belief, Coordinator, Mastermind) - Size: ~149KB, ~3,800 lines

Phase 7: System Lifecycle (Async)

  1. StartupAgent (agents/orchestration/startup_agent.py)
- Role: 🚀 System Bootstrap Controller - INITIALIZATION CORE - Responsibilities: - Complete system bootstrap orchestration - Dependency resolution and startup ordering - Agent registry loading and initialization - Configuration and environment validation - Initialization: await StartupAgent.bootstrap_system() - Dependencies: Config, all CORE infrastructure - Size: ~83KB, ~2,400 lines

  1. SystemStateTracker (agents/orchestration/system_state_tracker.py)
- Role: State management and event tracking - Responsibilities: System state checkpoints, event logging, rollback capabilities - Dependencies: MemoryAgent, BeliefSystem

Phase 8: Specialized Agents (Non-CORE)

  1. Model Registry & LLM Services - External integration layer
  2. StrategicEvolutionAgent - Self-improvement framework (depends on CORE)
  3. Specialized Agents - Domain-specific capabilities (monitoring, coding, analysis)
  4. Tool Registry - External tools and capabilities
  5. API Services - HTTP endpoints and web services

CORE Initialization Validation

Dependency Chain Validation: Each phase ensures all required dependencies from previous phases are initialized before proceeding.

Critical Path:

Config → Logging → BeliefSystem → MemoryAgent → IDManager → Guardian →
BDI → CoordinatorAgent → MastermindAgent → MindXAgent → StartupAgent

Result: Complete CORE foundation ready to support specialized agents and external integrations. - Strategic planning and campaign management - Resource allocation and optimization - Inter-agent coordination - Performance monitoring and optimization - Escalation handling - System-wide decision making - Initialization: await MastermindAgent.get_instance(...) - Dependencies: CoordinatorAgent, MemoryAgent, GuardianAgent, ModelRegistry - Internal Components: - AutoMINDXAgent (persona provider) - BDIAgent (internal strategic planner) - StrategicEvolutionAgent - IDManagerAgent (per-instance)

Phase 5: Supporting Agents (Async)

  1. AutoMINDXAgent (agents.automindx_agent.AutoMINDXAgent)
- Role: Persona and prompt management - Responsibilities: - Agent persona storage and retrieval - Prompt template management - Persona injection into BDI agents - Initialization: Created by MastermindAgent during async init - Data Location: data/memory/stm/automindx_agent_main/

  1. StrategicEvolutionAgent (learning.strategic_evolution_agent.StrategicEvolutionAgent)
- Role: Campaign manager for improvement cycles - Responsibilities: - Campaign planning and execution - System analysis - Multi-step improvement plans - Progress tracking - Initialization: Created by MastermindAgent - Dependencies: CoordinatorAgent, ModelRegistry, MemoryAgent

Phase 6: Integration Services (Async)

  1. mindterm Service (mindx_backend_service.mindterm.service.MindTermService)
- Role: Secure terminal execution plane - Responsibilities: - PTY session management - Command block tracking - Policy-gated execution - Event publishing - Initialization: Integrated during FastAPI startup - Dependencies: CoordinatorAgent, ResourceMonitor, PerformanceMonitor

Complete Startup Sequence Diagram

┌─────────────────────────────────────────────────────────────┐
│                    mindX System Startup                      │
└─────────────────────────────────────────────────────────────┘

Phase 1: Foundation (Synchronous) ├── Config System ├── Logging System ├── MemoryAgent └── BeliefSystem

Phase 2: Identity & Security (Async) ├── IDManagerAgent │ └── Creates: data/identity/.wallet_keys.env └── GuardianAgent └── Depends on: IDManagerAgent

Phase 3: Models & Registry (Async) └── ModelRegistry └── Loads: models/*.yaml

Phase 4: Orchestration (Async) ├── CoordinatorAgent │ ├── Self-registers in agent_registry │ ├── Initializes ResourceMonitor │ ├── Initializes PerformanceMonitor │ └── Creates: data/improvement_backlog.json └── MastermindAgent ├── Initializes AutoMINDXAgent ├── Creates internal BDIAgent (with persona) ├── Creates IDManagerAgent instance └── Creates StrategicEvolutionAgent

Phase 5: Supporting Agents (Async) ├── AutoMINDXAgent (via MastermindAgent) └── StrategicEvolutionAgent (via MastermindAgent)

Phase 6: Integration (Async) └── mindterm Service ├── Integrates with CoordinatorAgent ├── Connects to ResourceMonitor └── Connects to PerformanceMonitor


2. Core Agents at Inception

2.1 MemoryAgent

Purpose: Central nervous system for data and memory management

Key Capabilities:

Data Structure:

data/
├── memory/
│   ├── stm/          # Short-term memory (high-frequency events)
│   └── ltm/          # Long-term memory (consolidated knowledge)
├── agent_workspaces/
│   └── {agent_id}/   # Per-agent workspaces
└── logs/
    └── mindx_runtime.log

Integration Points:

2.2 BeliefSystem

Purpose: Shared knowledge representation and belief management

Key Capabilities:

Belief Structure:

Belief(
    key="identity.map.entity_to_address.mastermind_prime",
    value="0xb9B46126551652eb58598F1285aC5E86E5CcfB43",
    confidence=1.0,
    source=BeliefSource.DERIVED
)

Integration Points:

2.3 IDManagerAgent

Purpose: Cryptographic identity provider and key management

Key Capabilities:

Security Model:

Identity Creation Flow:

1. Agent requests identity via create_new_wallet(entity_id)
  1. IDManager checks if wallet exists (via BeliefSystem)
  2. If exists: return existing address
  3. If not: generate new key pair
  4. Store private key in .wallet_keys.env
  5. Store mapping in BeliefSystem
  6. Return public address

2.4 GuardianAgent

Purpose: Security gatekeeper and access arbitrator

Key Capabilities:

Security Workflow:

1. Agent requests private key access
  1. GuardianAgent issues challenge
  2. Agent signs challenge with existing key (if available)
  3. GuardianAgent verifies signature
  4. If valid: grants access via IDManagerAgent
  5. If invalid: denies access

2.5 CoordinatorAgent

Purpose: Central kernel and service bus

Key Capabilities:

Core Data Structures:

agent_registry: Dict[str, Dict] = {
    "agent_id": {
        "agent_id": str,
        "agent_type": str,
        "description": str,
        "instance": Any,
        "status": str,
        "registered_at": float
    }
}

tool_registry: Dict[str, Dict] = { "tool_id": { "tool_id": str, "description": str, "capabilities": List[str] } }

improvement_backlog: List[Dict] = [ { "id": str, "component": str, "improvement": str, "status": str, "priority": int } ]

Interaction Types:

Event System:

# Agents can subscribe to events
coordinator.subscribe("agent.created", callback_function)

Agents can publish events

await coordinator.publish_event("agent.created", {"agent_id": "..."})

Monitoring Integration:

2.6 MastermindAgent

Purpose: Strategic orchestrator and tactical coordinator

Key Capabilities:

Internal Architecture:

MastermindAgent:
    ├── AutoMINDXAgent (persona provider)
    ├── BDIAgent (internal strategic planner)
    │   └── Persona: "MASTERMIND" (from AutoMINDXAgent)
    ├── StrategicEvolutionAgent (campaign manager)
    ├── IDManagerAgent (per-instance identity)
    └── CodeBaseGenerator (code analysis)

BDI Action Handlers:

Strategic Methods:

2.7 StrategicEvolutionAgent (SEA)

Purpose: Campaign manager for improvement cycles

Key Capabilities:

Campaign Flow:

1. Receives high-level goal from MastermindAgent
  1. Analyzes system (via SystemAnalyzerTool)
  2. Identifies improvement targets
  3. Creates multi-step plan
  4. Delegates tasks to CoordinatorAgent
  5. Tracks progress
  6. Reports results to MastermindAgent

2.8 ModelRegistry

Purpose: LLM provider and model management

Key Capabilities:

Model Selection:

# Agent requests model for task
handler = await model_registry.get_handler_for_task(TaskType.CODE_GENERATION)

ModelRegistry:

1. Queries ModelSelector with task type

2. ModelSelector scores all models

3. Returns top-ranked model handler

4. Agent uses handler for LLM calls


3. IDManager Agent Strategy

3.1 Identity Management Philosophy

The IDManagerAgent implements a sane, scalable identity management strategy that ensures:

  1. Deterministic Identities: Each agent has a stable, persistent identity
  2. Centralized Key Storage: All private keys in one secure location
  3. Fast Lookups: BeliefSystem integration for O(1) identity queries
  4. Multi-Instance Support: Namespaced instances for different domains
  5. Security: GuardianAgent arbitration for sensitive operations

3.2 Identity Creation Strategy

At System Inception

When mindX starts, identities are created for core agents in this order:

  1. CoordinatorAgent
   id_manager = await IDManagerAgent.get_instance(
       agent_id=f"id_manager_for_{coordinator.agent_id}",
       ...
   )
   await id_manager.create_new_wallet(entity_id=coordinator.agent_id)
   # Result: Public address stored in BeliefSystem
   
  1. MastermindAgent
   id_manager = await IDManagerAgent.get_instance(
       agent_id=f"id_manager_for_{mastermind.agent_id}",
       ...
   )
   await id_manager.create_new_wallet(entity_id=mastermind.agent_id)
   
  1. GuardianAgent
- Identity created during GuardianAgent initialization - Used for challenge-response authentication

  1. All Registered Agents
- When an agent registers with CoordinatorAgent - CoordinatorAgent ensures identity exists - If not, creates via IDManagerAgent

🔒 Production Identity Lookup Strategy

The system uses a three-tier secure lookup strategy with encrypted storage:

Tier 1: BeliefSystem (Fast, In-Memory)

# Fast lookup via BeliefSystem
belief = await belief_system.get_belief(
    f"identity.map.entity_to_address.{entity_id}"
)
if belief:
    return belief.value  # O(1) lookup

Tier 2: Encrypted Vault (AES-256 Secure Storage)

# If not in BeliefSystem, check encrypted vault
from mindx_backend_service.encrypted_vault_manager import get_encrypted_vault_manager
vault = get_encrypted_vault_manager()

private_key = vault.get_wallet_private_key(entity_id) if private_key: address = Account.from_key(private_key).address # Cache in BeliefSystem for future fast lookups await belief_system.add_belief(...) return address

Tier 3: Legacy Environment File (Migration Fallback)

# Legacy fallback during migration period
env_var_name = f"MINDX_WALLET_PK_{entity_id}"
private_key = os.getenv(env_var_name)
if private_key:
    # Migrate to encrypted vault
    vault.store_wallet_key(entity_id, private_key, Account.from_key(private_key).address)
    address = Account.from_key(private_key).address
    return address

3.3 Identity Naming Convention

Entity IDs follow a hierarchical naming pattern:

Environment Variable Names:

3.4 Identity Lifecycle Management

🔒 Secure Identity Creation

# Check if exists first (prevents duplicates)
existing = await id_manager.get_public_address(entity_id)
if existing:
    return existing  # Return existing identity

Create new wallet with cryptographic security

account = Account.create() private_key = account.key.hex() public_address = account.address

Store in AES-256 encrypted vault

from mindx_backend_service.encrypted_vault_manager import get_encrypted_vault_manager vault = get_encrypted_vault_manager() vault.store_wallet_key( agent_id=entity_id, private_key=private_key, public_address=public_address )

Cache in BeliefSystem for fast lookups

await belief_system.add_belief( f"identity.map.entity_to_address.{entity_id}", public_address, 1.0, BeliefSource.DERIVED )

Retrieval

# Fast path: BeliefSystem
address = await id_manager.get_public_address(entity_id)

Slow path: Environment file

(only if BeliefSystem miss)

Signing

# GuardianAgent arbitrates access
private_key = guardian.get_private_key_for_guardian(entity_id)
signature = id_manager.sign_message(entity_id, message)

3.5 Identity Registry Integration

The IDManagerAgent integrates with:

3.6 Best Practices

  1. Always Check Before Creating: Use get_public_address() first
  2. Use BeliefSystem for Lookups: Fast, in-memory access
  3. GuardianAgent for Private Keys: Never access keys directly
  4. Namespaced Instances: Use different IDManager instances for different domains
  5. Log All Operations: MemoryAgent logs all identity operations

4. Orchestration Architecture

4.1 Hierarchical Delegation Model

mindX uses a clear hierarchical model of delegation:

User/External System
    ↓
MastermindAgent (Strategic)
    ├── Strategic Planning
    ├── Campaign Initiation
    └── Resource Allocation
        ↓
StrategicEvolutionAgent (Campaign)
    ├── Campaign Planning
    ├── Target Analysis
    └── Multi-Step Plans
        ↓
CoordinatorAgent (Orchestration)
    ├── Task Routing
    ├── Agent Management
    ├── Tool Invocation
    └── Event Publishing
        ↓
Specialized Agents (Execution)
    ├── SimpleCoder
    ├── GuardianAgent
    ├── MemoryAgent
    └── Other Domain Agents
        ↓
Tools (Atomic Operations)
    ├── FileSystemTool
    ├── CodeAnalysisTool
    └── Other Tools

4.2 Orchestration Patterns

Pattern 1: Strategic Campaign

1. User → MastermindAgent: "Improve system security"
  1. MastermindAgent → StrategicEvolutionAgent: Campaign goal
  2. StrategicEvolutionAgent:
- Analyzes system - Creates improvement plan - Delegates tasks to CoordinatorAgent
  1. CoordinatorAgent:
- Routes to appropriate agents/tools - Manages execution - Tracks progress
  1. Results flow back up the hierarchy

Pattern 2: Agent Creation

1. MastermindAgent → CoordinatorAgent: "Create new agent"
  1. CoordinatorAgent:
- Creates IDManagerAgent instance - Generates identity - Validates with GuardianAgent - Registers in agent_registry - Creates workspace via MemoryAgent
  1. New agent ready for use

Pattern 3: Event-Driven Coordination

1. Agent publishes event: coordinator.publish_event("agent.created", data)
  1. CoordinatorAgent routes to subscribers
  2. Subscribed agents react to event
  3. Decoupled, scalable architecture

4.3 Resource Management

CoordinatorAgent Resource Management

# Concurrency Control
heavy_task_semaphore = asyncio.Semaphore(max_concurrent_heavy_tasks)

Resource Monitoring

resource_monitor = ResourceMonitor() resource_monitor.start_monitoring()

Performance Tracking

performance_monitor = PerformanceMonitor()

Resource Limits

Autonomous Resource Management

The AutonomousAuditCoordinator checks resource usage before campaigns:

if cpu_usage > threshold or memory_usage > threshold:
    defer_campaign()  # Wait for resources

4.4 Event Bus Architecture

Event Publishing

# CoordinatorAgent publishes events
await coordinator.publish_event("agent.created", {
    "agent_id": "...",
    "agent_type": "...",
    "timestamp": "..."
})

Event Subscribing

# Agents subscribe to events
coordinator.subscribe("agent.created", async def handler(data):
    # React to agent creation
    pass
)

Event Types


5. Overarching mindX System Strategy

5.1 System Design Principles

  1. Separation of Concerns: Each agent has a single, well-defined responsibility
  2. Orchestration Over Monoliths: Complex behaviors through agent coordination
  3. Event-Driven Architecture: Decoupled communication via events
  4. Resource Awareness: System monitors and manages its own resources
  5. Autonomous Improvement: System can improve itself through campaigns
  6. Security First: Identity and access control at every layer
  7. Observability: Comprehensive logging and monitoring

5.2 Agent Lifecycle Management

Agent Registration Flow

1. Agent instance created
  1. Identity created via IDManagerAgent
  2. GuardianAgent validates identity
  3. CoordinatorAgent.register_agent() called
  4. Agent added to agent_registry
  5. Workspace created via MemoryAgent
  6. Agent ready for operations

Agent Deletion Flow

1. MastermindAgent or CoordinatorAgent initiates deletion
  1. Agent operations stopped
  2. Identity deprecated (not deleted - audit trail)
  3. Removed from agent_registry
  4. Workspace archived (not deleted)
  5. Event published: "agent.deleted"

5.3 Tool Ecosystem

Tool Registration

# Tools registered in official_tools_registry.json
{
    "registered_tools": {
        "tool_id": {
            "tool_id": "...",
            "description": "...",
            "class_path": "...",
            "capabilities": [...],
            "identity": {
                "public_address": "...",
                "entity_id": "..."
            }
        }
    }
}

Tool Lifecycle

  1. Discovery: Tools discovered in tools/ directory
  2. Identity: Identity created via IDManagerAgent
  3. Registration: Added to tools_registry
  4. Initialization: Loaded on-demand by agents
  5. Execution: Invoked via BDI agent actions

5.4 Autonomous Improvement System

Improvement Backlog

The CoordinatorAgent maintains an improvement backlog:

improvement_backlog: List[Dict] = [
    {
        "id": "...",
        "component": "logging_config.py",
        "improvement": "Add error handling",
        "status": "PENDING",
        "priority": 5,
        "created_at": "...",
        "assigned_to": "..."
    }
]

Improvement Campaign Flow

1. AutonomousAuditCoordinator identifies improvement
  1. Adds to improvement_backlog
  2. StrategicEvolutionAgent picks up item
  3. Creates campaign plan
  4. Executes via CoordinatorAgent
  5. Results tracked and learned

5.5 Monitoring and Observability

Resource Monitoring

Performance Monitoring

Logging Strategy

5.6 Integration with mindterm

mindterm is fully integrated into the orchestration system:

Integration Points

  1. CoordinatorAgent Event Bus
- mindterm publishes events: mindterm.session_created, mindterm.command_started, etc. - CoordinatorAgent routes events to subscribers

  1. Resource Monitoring
- mindterm sessions tracked via ResourceMonitor - Resource usage per session monitored

  1. Performance Monitoring
- Command execution tracked via PerformanceMonitor - Success/failure rates, execution times logged

  1. Logging Integration
- All mindterm operations logged via mindX logging system - Structured logs for autonomous analysis

mindterm Orchestration Flow

1. User creates mindterm session via API
  1. mindterm service creates PTY session
  2. Publishes event: "mindterm.session_created"
  3. CoordinatorAgent routes event to subscribers
  4. Commands executed with policy gates
  5. Events published for each command
  6. Agents can subscribe to mindterm events
  7. Session metrics tracked and logged

6. Startup Configuration

6.1 Configuration Files

Primary Configuration:

Model Configuration:

Environment Variables:

6.2 Startup Scripts

Main Entry Points:

6.3 Initialization Verification

After startup, verify:

  1. ✅ All core agents initialized
  2. ✅ Identities created for all agents
  3. ✅ CoordinatorAgent agent_registry populated
  4. ✅ ResourceMonitor and PerformanceMonitor active
  5. ✅ mindterm integrated with coordinator
  6. ✅ Event bus operational
  7. ✅ Logging system active

7. Orchestration Best Practices

7.1 Agent Design

7.2 Identity Management

7.3 Resource Management

7.4 Event-Driven Architecture

7.5 Monitoring and Logging


8. DAIO Blockchain Integration

8.1 Seamless Orchestration Connection

The mindX orchestration system seamlessly connects to DAIO (Decentralized Autonomous Intelligent Organization) once DAIO is deployed, enabling blockchain-native governance, cryptographic identity, and economic sovereignty. See DAIO.md for complete technical and strategic documentation.

Integration Architecture

mindX Orchestration Layer
    ├── CoordinatorAgent
    │   ├── Event Bus → DAIO Event Listener
    │   ├── Agent Registry → On-Chain Agent Registry (KnowledgeHierarchyDAIO)
    │   └── Resource Monitor → Treasury Cost Tracking
    │
    ├── MastermindAgent
    │   ├── Strategic Decisions → DAIO Proposals
    │   ├── Resource Allocation → Treasury Requests
    │   └── Agent Creation → IDNFT Minting
    │
    ├── IDManagerAgent
    │   ├── Identity Generation → IDNFT Contract
    │   ├── Wallet Management → Agent Wallets
    │   └── Key Storage → Secure Key Vault
    │
    └── FinancialMind (Extension)
        ├── Trading Operations → Treasury Funding
        ├── Profit Distribution → Agent Rewards
        └── Economic Analysis → Governance Input

Key Integration Points

  1. Agent Identity On-Chain Registration
- IDManagerAgent generates cryptographic identity (ECDSA keypair) - Agent identity registered in IDNFT.sol contract - NFT minted to agent's wallet address - CoordinatorAgent updates on-chain registry

  1. Governance Proposal Generation
- MastermindAgent identifies strategic need - Strategic plan converted to DAIO proposal - AI agents vote via aggregated knowledge-weighted system - Human subcomponents vote (Development, Marketing, Community) - Upon 2/3 approval, proposal executed via timelock

  1. Economic Operations Integration
- FinancialMind executes profitable trade - Profit automatically routed to DAIO treasury - Treasury distributes rewards to contributing agents - Agent wallets receive payments via smart contract

Event-Driven Synchronization

The DAIO integration uses an event-driven architecture to maintain real-time synchronization:

THOT Integration

THOT (Temporal Hierarchical Optimization Technology) enhances mindX orchestration through:

FinancialMind as Economic Extension

FinancialMind serves as the self-funding economic engine for mindX:

For complete DAIO integration documentation, including smart contracts, implementation details, and strategic roadmap, see DAIO.md.


9. System Health and Maintenance

9.1 Health Checks

Component Health:

System Health Indicators:

9.2 Maintenance Operations

Regular Maintenance:

Autonomous Maintenance:


10. Future Enhancements

10.1 Planned Improvements

  1. Advanced Orchestration
- Multi-agent workflow coordination - Dynamic agent composition - Agent marketplace

  1. Enhanced Monitoring
- Real-time dashboards - Predictive resource needs - Anomaly detection

  1. Security Enhancements
- Multi-signature support - Role-based access control - Audit logging

  1. Performance Optimization
- Agent caching - Request batching - Intelligent routing


11. Summary

The mindX orchestration system is a sophisticated, hierarchical multi-agent architecture that:

The system is designed to be:

This orchestration system enables mindX to operate as a true augmentic intelligence - a system that augments itself through continuous improvement and autonomous operation, with blockchain-native governance and economic sovereignty through DAIO integration.


Referenced in this document
DAIO

All DocumentsDocument IndexThe Book of mindXImprovement JournalAPI Reference