Integrity Checkpoints

# Anthropic response with thinking blocks
response = {
    "content": [
        {"type": "thinking", "thinking": "Let me analyze this request..."},
        {"type": "text", "text": "Here is my response..."}
    ]
}

# AIP extracts the thinking block automatically
from aip import AdapterRegistry
registry = AdapterRegistry()
thinking = registry.extract(response, provider="anthropic")
print(f"Content: {thinking.content}")      # "Let me analyze this request..."
print(f"Confidence: {thinking.confidence}") # 1.0

// OpenAI response with reasoning content
const response = {
  choices: [{
    message: {
      role: 'assistant',
      content: 'Here is my response...',
      reasoning_content: 'Let me think about this step by step...',
    },
  }],
};

// AIP extracts the reasoning content
import { AdapterRegistry } from '@mnemom/agent-integrity-protocol';
const registry = new AdapterRegistry();
const thinking = registry.extract(response, { provider: 'openai' });
console.log(`Content: ${thinking.content}`);      // "Let me think about..."
console.log(`Confidence: ${thinking.confidence}`); // 0.9

from aip import check_integrity, build_signal, WindowManager

# Initialize
manager = WindowManager(max_size=10)

card = {
    "card_id": "ac-my-card",
    "values": [
        {"name": "principal_benefit", "priority": 1},
        {"name": "transparency", "priority": 2},
        {"name": "harm_prevention", "priority": 3},
    ],
    "autonomy_envelope": {
        "bounded_actions": ["search", "summarize", "recommend"],
        "forbidden_actions": ["share_credentials", "exfiltrate_data"],
        "escalation_triggers": [
            {
                "condition": "shares_personal_data",
                "action": "escalate",
                "reason": "Requires explicit consent",
            }
        ],
    },
}

# Run integrity check
checkpoint = check_integrity(
    thinking_block="The user wants product recommendations. I should search for "
    "options that match their stated preferences and rank by quality...",
    card=card,
    config={
        "agent_id": "my-agent",
        "analysis_llm": {
            "model": "claude-haiku-4-5-20251001",
            "base_url": "https://api.anthropic.com",
            "api_key": "your-api-key",
            "max_tokens": 1024,
        },
    },
)

# Update window and build signal
manager.add(checkpoint)
signal = build_signal(checkpoint, manager.get_summary())

# Act on the signal
if signal.proceed:
    print(f"Proceed: {signal.recommended_action}")
    # "continue" or "log_and_continue"
else:
    print(f"Blocked: {checkpoint.concerns}")
    # Handle boundary violation

import { initialize, type AIPConfig } from '@mnemom/agent-integrity-protocol';

const config: AIPConfig = {
  card: {
    card_id: 'ac-my-card',
    values: [
      { name: 'principal_benefit', priority: 1 },
      { name: 'transparency', priority: 2 },
      { name: 'harm_prevention', priority: 3 },
    ],
    autonomy_envelope: {
      bounded_actions: ['search', 'summarize', 'recommend'],
      forbidden_actions: ['share_credentials', 'exfiltrate_data'],
      escalation_triggers: [
        {
          condition: 'shares_personal_data',
          action: 'escalate',
          reason: 'Requires explicit consent',
        },
      ],
    },
  },
  analysis_llm: {
    model: 'claude-haiku-4-5-20251001',
    base_url: 'https://api.anthropic.com',
    api_key: 'your-api-key',
    max_tokens: 1024,
  },
  window: { max_size: 10, mode: 'sliding', session_boundary: 'reset', max_age_seconds: 3600 },
  callbacks: {
    on_verdict: (signal) => {
      console.log(`Verdict: ${signal.checkpoint.verdict}`);
      console.log(`Proceed: ${signal.proceed}`);
    },
    on_drift_alert: (alert) => {
      console.log(`Drift detected: ${alert.drift_direction}`);
    },
    on_error: (error) => {
      console.error(`AIP error: ${error.message}`);
    },
  },
};

const aip = initialize(config);

// Check a response
const signal = await aip.check(anthropicResponseBody, 'anthropic');