夜間バッチの完了を待つポーリングを畳む — Apps Script の doPost を Gemini の合図受けにする設計

const WEBHOOK_TOKEN = 'REPLACE_WITH_LONG_RANDOM_TOKEN';
 
function doPost(e) {
  // 1) 推測困難トークンで一次選別（ヘッダーは読めないのでクエリで受ける）
  if (!e || !e.parameter || e.parameter.t !== WEBHOOK_TOKEN) {
    return json_({ ok: false }, 200); // 攻撃者に情報を与えないため常に200
  }
 
  // 2) 本文からオペレーション名だけを取り出す（中身は信頼しない）
  let opName = '';
  try {
    const body = JSON.parse(e.postData.contents || '{}');
    opName = String(body.name || body.operation || '').trim();
  } catch (err) {
    return json_({ ok: false }, 200);
  }
  if (!opName) return json_({ ok: false }, 200);
 
  // 3) 耐久キューへ投入して即返す（重い確認・適用は後段トリガーへ）
  enqueue_(opName);
  return json_({ ok: true }, 200);
}
 
function json_(obj, code) {
  return ContentService
    .createTextOutput(JSON.stringify(obj))
    .setMimeType(ContentService.MimeType.JSON);
}
 
function enqueue_(opName) {
  const lock = LockService.getScriptLock();
  lock.waitLock(5000);
  try {
    const props = PropertiesService.getScriptProperties();
    const q = JSON.parse(props.getProperty('inbound_q') || '[]');
    if (q.indexOf(opName) === -1) q.push(opName);
    props.setProperty('inbound_q', JSON.stringify(q));
  } finally {
    lock.releaseLock();
  }
}

function drainInbound() {
  const props = PropertiesService.getScriptProperties();
  const lock = LockService.getScriptLock();
  lock.waitLock(5000);
  let q;
  try {
    q = JSON.parse(props.getProperty('inbound_q') || '[]');
    props.setProperty('inbound_q', '[]'); // 取り出して空にする
  } finally {
    lock.releaseLock();
  }
 
  const requeue = [];
  for (const opName of q) {
    const res = UrlFetchApp.fetch(
      'https://generativelanguage.googleapis.com/v1beta/' + opName,
      { headers: { 'x-goog-api-key': getApiKey_() }, muteHttpExceptions: true }
    );
    if (res.getResponseCode() !== 200) { requeue.push(opName); continue; }
    const op = JSON.parse(res.getContentText());
    if (!op.done) { requeue.push(opName); continue; } // まだなら戻す
    applyOnce_(opName, op); // 完了を確認できたものだけ適用
  }
  if (requeue.length) enqueueMany_(requeue);
}

function applyOnce_(opName, op) {
  const applied = PropertiesService.getScriptProperties();
  const key = 'applied:' + opName;         // オペレーション名を冪等キーに
  const lock = LockService.getScriptLock();
  lock.waitLock(10000);
  try {
    if (applied.getProperty(key)) return;  // 既に適用済みなら何もしない
    applyResult_(opName, op);              // 実際の書き戻し（副作用）
    applied.setProperty(key, String(Date.now()));
  } finally {
    lock.releaseLock();
  }
}

// 例：6時間に1回だけ実行
function reconcileInflight() {
  const props = PropertiesService.getScriptProperties();
  const inflight = JSON.parse(props.getProperty('inflight_ops') || '[]');
  const still = [];
  for (const opName of inflight) {
    const res = UrlFetchApp.fetch(
      'https://generativelanguage.googleapis.com/v1beta/' + opName,
      { headers: { 'x-goog-api-key': getApiKey_() }, muteHttpExceptions: true }
    );
    const op = JSON.parse(res.getContentText());
    if (op.done) applyOnce_(opName, op);
    else still.push(opName);
  }
  props.setProperty('inflight_ops', JSON.stringify(still));
}