Jev で監査証跡を構築：すべての判断を記録・再生・説明できる形に

import logging
import os

import requests

logger = logging.getLogger("decisions")

def decide_with_chat_model(customer_id: str, case: dict) -> str:
    resp = requests.post(
        "https://api.openai.com/v1/chat/completions",
        headers={"Authorization": f"Bearer {os.environ['OPENAI_API_KEY']}"},
        json={
            "model": "gpt-4o-mini",
            "messages": [{
                "role": "user",
                "content": f"ポリシー v3 で裁定し、判断と根拠を返してください。\nCase: {case}",
            }],
        },
        timeout=30,
    )
    decision_text = resp.json()["choices"][0]["message"]["content"]

    # 監査ログが得るのは段落。しきい値設定もリプレイも説明もできず、
    # 再読できるだけ。この呼び出しはどのプロンプトバージョンで作られたか？
    # 「おそらく承認」は信頼度 0.8 のことだったのか？ログには答えられない。
    logger.info("decision for %s: %s", customer_id, decision_text)
    return decision_text

import hashlib
import json

import requests

JEV_ENDPOINT = "https://api.typesafe.ai/v1/jev/evaluate"
AUTO_EXECUTE_CONFIDENCE = 0.85  # ゲート超過 かつ 可逆性 <= 2 -> 自動実行
HUMAN_CONFIDENCE = 0.60         # 未満、または可逆性 4 -> 人手

QUESTIONS = {
    "decision": {
        "type": "choice",
        "instructions": "公開ポリシーに基づきケースを裁定する",
        "criteria": {
            "approve": "ポリシー条件をすべて満たす",
            "refer": "明示されたエッジケースに該当",
            "deny": "ハード条件を満たさない——該当条件を明示",
        },
    },
    "reversibility": {
        "type": "score",
        "instructions": "誤りだった場合の取下げコスト？1 = 簡単、4 = 人への不可逆的な害",
    },
    "needs_human_review": {
        "type": "noul",
        "instructions": "発効前に人間の確認が必要か？",
    },
}

def decide_and_record(subject_ref: str, state: dict) -> dict:
    payload = {"state": state, "questions": QUESTIONS}
    resp = requests.post(JEV_ENDPOINT, json=payload, timeout=5)
    resp.raise_for_status()
    data = resp.json()

    decision = data["decision"]
    reversibility = data["reversibility"]["answer"]
    if data["needs_human_review"]["answer"] or reversibility == 4:
        lane = "human_decision"
    elif decision["confidence"] >= AUTO_EXECUTE_CONFIDENCE and reversibility <= 2:
        lane = "auto_executed"
    else:
        lane = "review_queue"

    # レコードが監査証跡：契約・回答・ゲート——1 行の固定長レコードで、
    # 任意の将来スキーマバージョンでリプレイ可能。
    return {
        "subject_ref": subject_ref,
        "decision": decision["answer"],
        "confidence": decision["confidence"],
        "reversibility": reversibility,
        "lane": lane,
        "logic": {
            "schema_version": "audit-contract@1.3.0",
            "questions_hash": hashlib.sha256(
                json.dumps(payload["questions"], sort_keys=True).encode()
            ).hexdigest()[:16],
            "model_version": "jev-1.13",
        },
        "human_intervention_path": (
            "available_on_request"
            if lane == "auto_executed"
            else "mandatory_before_effect"
        ),
    }

import { z } from "zod";
import OpenAI from "openai";

const Decision = z.object({ decision: z.enum(["approve", "refer", "deny"]) });
const openai = new OpenAI();

export async function decideCase(caseData: unknown) {
  const resp = await openai.chat.completions.create({
    model: "gpt-4o-mini",
    response_format: { type: "json_object" },
    messages: [
      { role: "user", content: `ポリシー v3 で裁定: ${JSON.stringify(caseData)}` },
    ],
  });
  const { decision } = Decision.parse(
    JSON.parse(resp.choices[0].message.content!),
  );

  // 形状は保証されるが、証拠はそうではない。信頼度なし・スキーマバージョンなし・
  // 分布なし——6 か月後の監査が得られるのは「何」だけで、「なぜ」と
  // 「どのくらい正しかったか」は永遠に得られない。
  return { decision, auditRecord: { decision } };
}

const JEV_ENDPOINT = "https://api.typesafe.ai/v1/jev/evaluate";
const AUTO_EXECUTE_CONFIDENCE = 0.85; // ゲート超過 かつ 可逆性 <= 2
const HUMAN_CONFIDENCE = 0.6; // 未満、または可逆性 4 -> 人手

type Lane = "auto_executed" | "review_queue" | "human_decision";

const QUESTIONS = {
  decision: {
    type: "choice",
    instructions: "公開ポリシーに基づきケースを裁定する",
    criteria: {
      approve: "ポリシー条件をすべて満たす",
      refer: "エッジケースに該当——理由を付してキューへ",
      deny: "ハード条件を満たさない——該当条件を明示",
    },
  },
  reversibility: {
    type: "score",
    instructions: "誤りだった場合の取下げコスト？1 = 簡単、4 = 不可逆的な害",
  },
  needs_human_review: {
    type: "noul",
    instructions: "発効前に人間の確認が必要か？",
  },
} as const;

export async function decideAndRecord(subjectRef: string, state: object) {
  const resp = await fetch(JEV_ENDPOINT, {
    method: "POST",
    headers: { "Content-Type": "application/json" },
    body: JSON.stringify({ state, questions: QUESTIONS }),
  });
  if (!resp.ok) throw new Error("Jev evaluate failed");
  const data = await resp.json();

  const { answer, confidence } = data.decision as {
    answer: string;
    confidence: number;
  };
  const reversibility = data.reversibility.answer as number;
  const lane: Lane =
    data.needs_human_review.answer || reversibility === 4
      ? "human_decision"
      : confidence >= AUTO_EXECUTE_CONFIDENCE && reversibility <= 2
        ? "auto_executed"
        : "review_queue";

  return {
    subject_ref: subjectRef,
    decision: answer,
    confidence,
    reversibility,
    lane,
    logic: { schema_version: "audit-contract@1.3.0", model_version: "jev-1.13" },
    human_intervention_path:
      lane === "auto_executed" ? "available_on_request" : "mandatory_before_effect",
  };
}
// 第 22 条レコード = このオブジェクト。リプレイ = 保存 state を新しい
// スキーマバージョンで再送し、レーンを差分。