Gemini API の Recitation block が発火する条件と、応答が消えないためのプロンプト・ポストプロセス設計

function buildParaphrasePrompt(sourceText: string, task: string): string {
  return [
    "あなたは情報を再構成するライターです。以下の【原文】を参照しますが、",
    "重要な制約を守ってください:",
    "",
    "- 原文の文章を 10 単語以上連続してそのまま使用しないこと",
    "- 各文を必ず言い換える（語順を入れ替える・別の表現に置き換える）",
    "- 固有名詞・数値・日付以外は逐語複製しない",
    "- 引用が必要な箇所は「原文の要点として」「○○氏は△△と述べた」のような",
    "  間接話法で記述する",
    "",
    `タスク: ${task}`,
    "",
    "【原文】",
    sourceText,
  ].join("\n");
}

async function safeGeminiCall(
  client: GoogleGenerativeAI,
  modelId: string,
  sourceText: string,
  task: string
): Promise<string> {
  const model = client.getGenerativeModel({ model: modelId });
 
  // Step 1: 通常プロンプト
  const initial = await model.generateContent(`${task}\n\n${sourceText}`);
  let det = detectRecitation(initial.response);
  if (!det.isRecitation && det.partial) return det.partial;
 
  // Step 2: 言い換え強制プロンプト
  const paraphrasePrompt = buildParaphrasePrompt(sourceText, task);
  const second = await model.generateContent(paraphrasePrompt);
  det = detectRecitation(second.response);
  if (!det.isRecitation && det.partial) return det.partial;
 
  // Step 3: チャンク分割
  return chunkAndAggregate(model, sourceText, task);
}
 
async function chunkAndAggregate(
  model: any,
  source: string,
  task: string
): Promise<string> {
  const chunks = splitIntoChunks(source, 3000);
  const summaries: string[] = [];
  for (const chunk of chunks) {
    const prompt = buildParaphrasePrompt(chunk, "この断片の主旨を3点で抽出");
    const r = await model.generateContent(prompt);
    const d = detectRecitation(r.response);
    if (d.partial) summaries.push(d.partial);
  }
  const integration = buildParaphrasePrompt(summaries.join("\n---\n"), task);
  const final = await model.generateContent(integration);
  return detectRecitation(final.response).partial;
}
 
function splitIntoChunks(text: string, size: number): string[] {
  const chunks: string[] = [];
  for (let i = 0; i < text.length; i += size) {
    chunks.push(text.slice(i, i + size));
  }
  return chunks;
}

interface SanitizationResult {
  sanitized: string;
  flags: string[];
}
 
function sanitizeSource(source: string): SanitizationResult {
  const flags: string[] = [];
  let s = source;
 
  // 1. 引用ブロック（"〜"、「〜」、`> 〜`）が長いと発火しやすい
  // 30 単語以上の引用ブロックは中略にする
  s = s.replace(/[「『"][^」』"]{60,}[」』"]/g, (match) => {
    flags.push("long-quote-truncated");
    return match.slice(0, 30) + "…[中略]…" + match.slice(-30);
  });
 
  // 2. 連続する数値・日付の羅列は要約しない（そのまま渡してOK）
  // 3. URL は引用判定を誘発しやすいので、ドメイン名だけ残す
  s = s.replace(/https?:\/\/([\w.-]+)[^\s]*/g, (_match, host) => `[${host}]`);
 
  return { sanitized: s, flags };
}

const MODEL_FALLBACK_CHAIN = [
  "gemini-3-2-pro",
  "gemini-2-5-pro",
  "gemini-2-5-flash",
] as const;
 
async function modelFallback(
  client: GoogleGenerativeAI,
  sourceText: string,
  task: string
): Promise<string> {
  for (const modelId of MODEL_FALLBACK_CHAIN) {
    try {
      const result = await safeGeminiCall(client, modelId, sourceText, task);
      if (result) return result;
    } catch (err) {
      // 次のモデルで試す
    }
  }
  throw new Error("all models blocked by recitation");
}