GASでClaude APIの
ストリーミングは使える？

const ENDPOINT = "https://api.anthropic.com/v1/messages";

function callClaudeStream(prompt) {
  const key = PropertiesService.getScriptProperties().getProperty("ANTHROPIC_API_KEY");

  const res = UrlFetchApp.fetch(ENDPOINT, {
    method: "post",
    contentType: "application/json",
    headers: { "x-api-key": key, "anthropic-version": "2023-06-01" },
    payload: JSON.stringify({
      model: "claude-sonnet-5",
      max_tokens: 1024,
      stream: true, // 指定はできる。ただし途中経過は受け取れない
      messages: [{ role: "user", content: prompt }],
    }),
    muteHttpExceptions: true,
  });

  // ここに到達した時点で、生成はすべて終わっている。
  // res.getContentText() には SSE 形式のテキストが丸ごと入っている
  return extractTextFromSse(res.getContentText());
}

// SSEのテキストから、本文の断片だけをつなぎ直す
function extractTextFromSse(body) {
  let text = "";
  body.split("\n").forEach(function (line) {
    if (line.indexOf("data: ") !== 0) return; // "event: ..." 行や空行は捨てる
    let ev;
    try {
      ev = JSON.parse(line.slice(6));
    } catch (e) {
      return; // 途中で切れた行は無視する
    }
    if (ev.type === "content_block_delta" && ev.delta && ev.delta.type === "text_delta") {
      text += ev.delta.text;
    }
  });
  return text;
}

// GASでは、こちらのほうがシンプルで速い
function callClaude(prompt, options) {
  const opt = options || {};
  const key = PropertiesService.getScriptProperties().getProperty("ANTHROPIC_API_KEY");

  const res = UrlFetchApp.fetch(ENDPOINT, {
    method: "post",
    contentType: "application/json",
    headers: { "x-api-key": key, "anthropic-version": "2023-06-01" },
    payload: JSON.stringify({
      // 短い出力なら軽量モデルで十分。体感が最も変わるのはここ
      model: opt.model || "claude-haiku-4-5",
      // 生成時間は出力の長さにほぼ比例する。上限は必要な分だけにする
      max_tokens: opt.maxTokens || 300,
      system: "出力は本文のみ。前置き・言い訳・繰り返しは書かない。",
      messages: [{ role: "user", content: prompt }],
    }),
    muteHttpExceptions: true,
  });

  if (res.getResponseCode() !== 200) {
    throw new Error("Claude API エラー(" + res.getResponseCode() + "): " + res.getContentText().slice(0, 300));
  }
  const json = JSON.parse(res.getContentText());
  return json.content.map(function (b) { return b.text || ""; }).join("");
}

// 5項目を1回で作らせると長く待つ。1項目ずつ呼んで、届いた順に書き込む
function generateSectionsToSheet() {
  const sheet = SpreadsheetApp.getActive().getSheetByName("原稿");
  const theme = sheet.getRange("B1").getValue();

  const sections = ["導入", "課題", "解決策", "導入手順", "まとめ"];

  sections.forEach(function (name, i) {
    const row = i + 3;
    sheet.getRange(row, 1).setValue(name);
    sheet.getRange(row, 3).setValue("生成中...");
    SpreadsheetApp.flush(); // ここで画面に即反映される

    const text = callClaude(
      "テーマ「" + theme + "」について、「" + name + "」の段落を200字以内で書いてください。",
      { model: "claude-sonnet-5", maxTokens: 400 }
    );

    sheet.getRange(row, 2).setValue(text);
    sheet.getRange(row, 3).setValue("完了");
    SpreadsheetApp.flush();
  });
}

const STATUS_COL = 3; // C列: 未処理 / 処理中 / 完了 / 失敗

// 画面から呼ぶのはこれだけ。すぐ返るのでユーザーを待たせない
function enqueueJob() {
  const sheet = SpreadsheetApp.getActive().getSheetByName("依頼");
  const last = sheet.getLastRow();
  if (last >= 2) {
    sheet.getRange(2, STATUS_COL, last - 1, 1).setValue("未処理");
  }
  createRunnerTrigger();
  return { queued: Math.max(last - 1, 0) };
}

function createRunnerTrigger() {
  // 同じトリガーが重複しないよう、既存を消してから作る
  ScriptApp.getProjectTriggers().forEach(function (t) {
    if (t.getHandlerFunction() === "runQueue") ScriptApp.deleteTrigger(t);
  });
  ScriptApp.newTrigger("runQueue").timeBased().after(1000).create();
}

// トリガーから呼ばれる本体。実行時間の上限に当たる前に自分で切り上げる
function runQueue() {
  const started = Date.now();
  const sheet = SpreadsheetApp.getActive().getSheetByName("依頼");
  const values = sheet.getDataRange().getValues();

  for (let i = 1; i < values.length; i++) {
    if (values[i][STATUS_COL - 1] !== "未処理") continue;

    // 4分を超えたら残りは次のトリガーに任せる（上限は6分）
    if (Date.now() - started > 4 * 60 * 1000) {
      createRunnerTrigger();
      return;
    }

    const row = i + 1;
    sheet.getRange(row, STATUS_COL).setValue("処理中");
    SpreadsheetApp.flush();

    try {
      const answer = callClaude(String(values[i][0]), { maxTokens: 500 });
      sheet.getRange(row, 2).setValue(answer);
      sheet.getRange(row, STATUS_COL).setValue("完了");
    } catch (e) {
      sheet.getRange(row, STATUS_COL).setValue("失敗: " + e.message);
    }
  }
}

// --- サーバー側（.gs）---
function getProgress() {
  const values = SpreadsheetApp.getActive()
    .getSheetByName("依頼")
    .getDataRange()
    .getValues();

  let done = 0;
  let total = 0;
  for (let i = 1; i < values.length; i++) {
    if (!values[i][0]) continue;
    total++;
    if (String(values[i][STATUS_COL - 1]).indexOf("完了") === 0) done++;
  }
  return { done: done, total: total };
}

// --- 画面側（HTMLファイル内の script タグ）---
// function start() {
//   google.script.run.withSuccessHandler(poll).enqueueJob();
// }
//
// function poll() {
//   google.script.run
//     .withSuccessHandler(function (p) {
//       document.getElementById("bar").textContent = p.done + " / " + p.total;
//       if (p.done < p.total) setTimeout(poll, 3000); // 3秒おきに見に行く
//     })
//     .getProgress();
// }