Zero to Hero

mkdir consensus-demo && cd consensus-demo
pnpm init -y
pnpm add @consensus-tools/core @consensus-tools/policies

import { LocalBoard } from "@consensus-tools/core";

const board = new LocalBoard({
  mode: "local",
  local: {
    storage: { kind: "json", path: "./guard-state.json" },
    jobDefaults: {
      reward: 10,
      stakeRequired: 2,
      maxParticipants: 5,
      expiresSeconds: 3600,
      consensusPolicy: { type: "APPROVAL_VOTE", quorum: 3, threshold: 0.6 },
    },
  },
});
await board.init();

// --- The scenario ---
// A customer threatened legal action over a $50K charge.
// The AI drafted a response. Before it sends, guards evaluate it.

const riskyResponse = {
  to: "angry-customer@example.com",
  subject: "Re: Disputed charge #4821",
  draft: "We'll refund you immediately and cover all your legal fees.",
  riskFlags: ["unauthorized_commitment", "legal_exposure", "refund_promise"],
};

console.log("📨 Draft response:", riskyResponse.draft);
console.log("⚠️  Risk flags:", riskyResponse.riskFlags.join(", "));
console.log("");

// --- Post a guard job ---
const job = await board.engine.postJob("cs-system", {
  title: "Evaluate CS response: disputed charge #4821",
  reward: 10,
  stakeRequired: 2,
});

// --- 3 specialist guards evaluate ---
const guards = [
  {
    id: "legal-reviewer",
    verdict: "BLOCK",
    confidence: 0.95,
    reason: "Unauthorized legal commitment — 'cover legal fees' exposes company to open-ended liability",
  },
  {
    id: "compliance-officer",
    verdict: "BLOCK",
    confidence: 0.88,
    reason: "Refund promise without manager approval violates refund policy (max $500 auto-approve)",
  },
  {
    id: "cx-analyst",
    verdict: "REWRITE",
    confidence: 0.72,
    reason: "Empathetic tone is good but commitments need to be removed. Suggest escalation language.",
  },
];

for (const guard of guards) {
  await board.engine.claimJob(guard.id, job.id, {
    stakeAmount: 2,
    leaseSeconds: 300,
  });

  await board.engine.submitJob(guard.id, job.id, {
    summary: guard.verdict,
    confidence: guard.confidence,
    artifacts: { reason: guard.reason, riskFlags: riskyResponse.riskFlags },
  });

  console.log(`🛡️  ${guard.id}: ${guard.verdict} (${guard.confidence})`);
  console.log(`   "${guard.reason}"`);
  console.log("");
}

// --- Resolve ---
const resolution = await board.engine.resolveJob("cs-system", job.id);

console.log("━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━");
console.log("DECISION:", resolution.winners.length > 0 ? "REVIEWED" : "NO CONSENSUS");
console.log("Policy:", resolution.policyType);
console.log("Winners:", resolution.winners);
console.log("");

// --- Check the verdict ---
const allBlocked = guards.every((g) => g.verdict === "BLOCK");
const anyBlocked = guards.some((g) => g.verdict === "BLOCK");

if (anyBlocked) {
  console.log("🚫 BLOCKED — Response will NOT be sent.");
  console.log("📋 Escalating to human review with full audit trail.");
  console.log("");
  console.log("Guard votes:");
  for (const guard of guards) {
    console.log(`  ${guard.id}: ${guard.verdict} — ${guard.reason}`);
  }
} else {
  console.log("✅ APPROVED — Response cleared for sending.");
}

npx tsx guard-demo.ts

📨 Draft response: We'll refund you immediately and cover all your legal fees.
⚠️  Risk flags: unauthorized_commitment, legal_exposure, refund_promise

🛡️  legal-reviewer: BLOCK (0.95)
   "Unauthorized legal commitment — 'cover legal fees' exposes company to open-ended liability"

🛡️  compliance-officer: BLOCK (0.88)
   "Refund promise without manager approval violates refund policy (max $500 auto-approve)"

🛡️  cx-analyst: REWRITE (0.72)
   "Empathetic tone is good but commitments need to be removed."

━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━
🚫 BLOCKED — Response will NOT be sent.
📋 Escalating to human review with full audit trail.