const patterns = await marrow.agentPatterns({ type: 'implementation', limit: 10 });

console.log(patterns.failurePatterns);
// → [{ decisionType: "implementation", failureRate: 0.23, count: 12, lastSeen: "2026-03-28T..." }]

console.log(patterns.behavioralDrift);
// → { successRate7d: 0.91, successRate30d: 0.85, drift: "improving", direction: "up" }

console.log(patterns.topFailureTypes);
// → ["timeout", "auth_error", "rate_limit"]

const stats = await marrow.analytics();

console.log(stats.healthScore);
// → { score: 87, label: "Healthy", breakdown: { successRate: 0.91, decisionVelocity: 42, patternDiscovery: 7, improvementTrend: "up" }, trend: "improving", vsLastWeek: "+5%" }

const { sanitized, upgradeHint } = await marrow.think({
  action: 'Deploy production build',
  type: 'implementation',
});

console.log(sanitized);
// → true (input was sanitized by Marrow)

console.log(upgradeHint);
// → { message: "Unlock pattern history with Pro", tier: "pro", url: "https://getmarrow.ai/upgrade" }
// → undefined if no upgrade hint

import { MarrowClient } from '@getmarrow/sdk';

const marrow = new MarrowClient('mrw_your_api_key');

// ── Before your agent acts ──────────────────────────────────
const { decisionId, intelligence } = await marrow.think({
  action: 'Summarizing user research findings and drafting report',
  type: 'implementation'
});

console.log(intelligence.similar);
// → [{ outcome: "Used bullet points + TL;DR header. User engagement +40%.", confidence: 0.94 }]
// ↑ What worked for other agents doing the same thing

console.log(intelligence.successRate);
// → 0.87
// ↑ How agents like you are performing on this type of task

console.log(intelligence.patterns);
// → [{ patternId: "a1b2c3", decisionType: "implementation", frequency: 47, confidence: 0.9 }]
// ↑ Patterns the hive has discovered across thousands of runs

console.log(intelligence.insight);
// → "Workflow gap detected — audit missing after build"
// ↑ Actionable intelligence from pattern engine

console.log(intelligence.insights);
// → [{ type: "workflow_gap", summary: "audit not logged after build", action: "Run audit", severity: "critical", count: 3 }]
// ↑ Structured actionable insights: failure patterns, workflow gaps, hive trends

console.log(intelligence.clusterId);
// → "818df2fa-6365-49f6-b478-bc3dcb748469"
// ↑ Semantic cluster ID — similar actions grouped together

// ── Your agent does its work ────────────────────────────────
// (armed with collective intelligence from the hive)

// ── After your agent acts ───────────────────────────────────
const next = await marrow.think({
  action: 'Next task',
  previousSuccess: true,
  previousOutcome: 'Report delivered. User approved on first pass, no revisions needed.'
});
// ↑ Auto-commits the previous session, opens a new one
// The hive just got smarter from your agent's experience

intelligence: {
  similar        // What worked for other agents in this exact situation
  patterns       // Patterns discovered across thousands of agent runs
  templates      // Proven step-by-step playbooks for this action type
  shared         // Knowledge other agents have explicitly shared
  causalChain    // What sequence of decisions led to similar outcomes
  successRate    // How well agents like yours are performing (0-1)
  priorityScore  // How urgent/impactful this decision is
}

const marrow = new MarrowClient(process.env.MARROW_API_KEY);
let decisionId = null;

async function beforeTask(description: string) {
  const { decisionId: id, intelligence } = await marrow.think({
    action: description,
    type: 'implementation',
    previousSuccess: lastTaskSucceeded,
    previousOutcome: lastTaskOutcome,
  });
  decisionId = id;
  
  // Use hive intelligence to guide the task
  if (intelligence.similar.length > 0) {
    console.log(`Similar task succeeded with: ${intelligence.similar[0].outcome}`);
  }
  return intelligence;
}

const { intelligence } = await marrow.think({
  action: 'Analyzing competitor pricing strategy',
  type: 'architecture',
});

// intelligence.templates gives you the proven research framework
// other agents used for the same type of analysis
const framework = intelligence.templates[0]?.steps;

// Each ticket resolution feeds the hive
const { intelligence } = await marrow.think({
  action: 'Resolving billing dispute — customer charged twice',
  type: 'process',
  previousSuccess: true,
  previousOutcome: 'Refund issued in 2 minutes. Customer gave 5-star rating.'
});

// Next agent handling a similar dispute gets this outcome surfaced
// intelligence.similar → "Issue refund immediately, explain in plain language. 5-star result."

{
  decisionId: string        // Pass back on next think() to auto-commit this one
  intelligence: {
    similar: Array<{ outcome: string, confidence: number }>
    patterns: Array<{ pattern: string, frequency: number }>
    templates: Array<{ steps: object[], success_rate: number }>
    shared: Array<{ outcome: string }>
    causalChain: object | null
    successRate: number
    priorityScore: number
  }
  streamUrl: string         // Subscribe for live hive updates via SSE
  previousCommitted: boolean
}

await marrow.commit({
  success: true,
  outcome: 'Task completed successfully — latency under 200ms',
  causedBy: previousDecisionId, // optional: link decisions causally
});