engine_handle.h

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
#pragma once
 
#include <entropic/config/bundled_models.h>
#include <entropic/core/compactor_registry.h>
#include <entropic/core/constitutional_validator.h>
#include <entropic/core/engine.h>
#include <entropic/core/hook_registry.h>
#include <entropic/core/identity_manager.h>
#include <entropic/inference/orchestrator.h>
#include <entropic/mcp/mcp_authorization.h>
#include <entropic/mcp/external_bridge.h>
#include <entropic/mcp/server_manager.h>
#include <entropic/mcp/tool_executor.h>
#include <entropic/storage/audit_logger.h>
#include <entropic/types/session_logger.h>
#include <entropic/storage/backend.h>
#include <entropic/types/config.h>
#include <entropic/types/error.h>
#include <entropic/types/logging.h>
 
#include <atomic>
#include <memory>
#include <mutex>
#include <string>
 
// Forward declarations for Phase 1+ subsystems.
// Headers included as each phase wires them.
namespace entropic {
class ModelOrchestrator;
class ServerManager;
class ToolExecutor;
class IdentityManager;
class MCPAuthorizationManager;
class AgentEngine;
class SqliteStorageBackend;
class AuditLogger;
class ConstitutionalValidator;
class CompactorRegistry;
struct ParsedConfig;
class BundledModels;
struct InterfaceContext;  // gh#58 follow-up (v2.2.6): per-handle iface ctx
} // namespace entropic
 
struct entropic_engine {
    // ── Phase 0: Lifecycle ──────────────────────────────────
    entropic::HookRegistry hook_registry;     
    std::mutex api_mutex;                     
    std::string last_error;                   
    std::atomic<bool> configured{false};      
    std::atomic<bool> running{false};         
    int log_id = 0;
 
    // ── Phase 1: Configuration ────────────────────────────────
    entropic::ParsedConfig config;                    
    entropic::config::BundledModels bundled_models;   
 
    // ── Phase 2: Inference ─────────────────────────────────────
    std::unique_ptr<entropic::ModelOrchestrator> orchestrator; 
    entropic::InferenceInterface inference_iface;              
    entropic::InterfaceContext* inference_iface_ctx = nullptr;
 
    // ── Phase 3: MCP + Identity + Authorization ──────────────
    std::unique_ptr<entropic::ServerManager> server_manager;           
    std::unique_ptr<entropic::ToolExecutor> tool_executor;             
    std::unique_ptr<entropic::IdentityManager> identity_manager;       
    std::unique_ptr<entropic::MCPAuthorizationManager> mcp_auth;       
 
    // ── Phase 4: Engine Loop + Storage + Audit ─────────────────
    std::unique_ptr<entropic::AgentEngine> engine;                     
    std::unique_ptr<entropic::SqliteStorageBackend> storage;           
    std::unique_ptr<entropic::AuditLogger> audit_logger;               
    std::unique_ptr<entropic::SessionLogger> session_logger;           
 
    // ── Phase 5: Constitutional + Compaction ────────────────────
    std::unique_ptr<entropic::ConstitutionalValidator> validator;       
    std::unique_ptr<entropic::CompactorRegistry> compactor_registry;   
 
    // ── Phase 6: Tier metadata (v2.0.4) ───────────────────────
    std::unordered_map<std::string, std::vector<std::string>> tier_allowed_tools;
    std::unordered_map<std::string, std::vector<std::string>> tier_validation_rules;
 
    // ── Phase 7: External MCP bridge (v2.0.8) ──────────────────
    std::unique_ptr<entropic::ExternalBridge> external_bridge;   
 
    // ── Stream observer (v2.0.10) ────────────────────────────
    void (*stream_observer)(const char*, size_t, void*) = nullptr;
    void* stream_observer_data = nullptr;                        
 
    // ── State-change observer (P1-5 follow-up, 2.0.6-rc16.2) ─
    void (*state_observer)(int, void*) = nullptr;
    void* state_observer_data = nullptr;
 
    // ── Mid-gen queue observer (gh#40, v2.1.10) ───────────────
    void (*queue_observer)(const char*, size_t, void*) = nullptr;
    void* queue_observer_data = nullptr;
 
    // ── Critique start/end callbacks (gh#50, v2.1.12) ─────────
    void (*critique_start_cb)(void*) = nullptr;
    void (*critique_end_cb)(void*) = nullptr;
    void* critique_cb_data = nullptr;
};
 
namespace entropic {
 
class HandleApiLock {
public:
    explicit HandleApiLock(entropic_handle_t h)
        : lock_(h->api_mutex), log_scope_(h->log_id) {}
    HandleApiLock(const HandleApiLock&) = delete;
    HandleApiLock& operator=(const HandleApiLock&) = delete;
private:
    // Order matters: api_mutex acquired first, log_scope second.
    // Destruction reverses (scope first, mutex second) — fine.
    std::lock_guard<std::mutex> lock_;
    entropic::log::HandleLogScope log_scope_;
};
 
}  // namespace entropic