GASのdoPostで
外部サービスのWebhookを受け取る方法

// 外部サービスからのPOSTリクエストは doPost(e) が受け取る
function doPost(e) {
  // ボディは文字列。JSONで届く場合はパースする
  const raw = e && e.postData ? e.postData.contents : "";
  console.log("受信ボディ: " + raw);

  // 応答は必ず ContentService で返す（返さないとエラー扱いになる）
  return ContentService
    .createTextOutput(JSON.stringify({ ok: true }))
    .setMimeType(ContentService.MimeType.JSON);
}

function doPost(e) {
  const body = parseBody_(e);
  const sheet = SpreadsheetApp.getActive().getSheetByName("Webhookログ");

  sheet.appendRow([
    new Date(),
    body.event || "",          // イベント種別
    body.id || "",             // 送信元のイベントID
    JSON.stringify(body),      // 生データも残しておく
  ]);

  return jsonResponse_({ ok: true });
}

// JSONでもフォーム形式でも受けられるようにする
function parseBody_(e) {
  if (!e) return {};

  const type = e.postData ? e.postData.type : "";
  if (type && type.indexOf("application/json") === 0) {
    try {
      return JSON.parse(e.postData.contents);
    } catch (err) {
      console.error("JSONパース失敗: " + err);
      return {};
    }
  }

  // application/x-www-form-urlencoded は e.parameter に入る
  return e.parameter || {};
}

function jsonResponse_(obj) {
  return ContentService
    .createTextOutput(JSON.stringify(obj))
    .setMimeType(ContentService.MimeType.JSON);
}

// 例: https://script.google.com/.../exec?token=xxxxx を送信元に登録しておく
function doPost(e) {
  const expected = PropertiesService.getScriptProperties().getProperty("WEBHOOK_TOKEN");
  const given = e && e.parameter ? e.parameter.token : "";

  if (!expected || given !== expected) {
    console.warn("不正なリクエストを拒否しました");
    return jsonResponse_({ ok: false, error: "unauthorized" });
  }

  // ここから通常の処理
  const body = parseBody_(e);
  handleWebhook_(body);
  return jsonResponse_({ ok: true });
}

function handleWebhook_(body) {
  const eventId = body.id || Utilities.base64Encode(
    Utilities.computeDigest(
      Utilities.DigestAlgorithm.SHA_256,
      JSON.stringify(body),
      Utilities.Charset.UTF_8
    )
  );

  const lock = LockService.getScriptLock();
  if (!lock.tryLock(10000)) {
    console.warn("ロック取得に失敗。処理をスキップします");
    return;
  }

  try {
    const cache = CacheService.getScriptCache();
    if (cache.get(eventId)) {
      console.log("処理済みイベントのためスキップ: " + eventId);
      return;
    }

    SpreadsheetApp.getActive()
      .getSheetByName("Webhookログ")
      .appendRow([new Date(), eventId, JSON.stringify(body), ""]);

    cache.put(eventId, "done", 21600); // 6時間は再送を無視する
  } finally {
    lock.releaseLock();
  }
}

// 受信済みで未分類の行を、時間主導トリガーからまとめてAI処理する
function classifyPendingRows() {
  const sheet = SpreadsheetApp.getActive().getSheetByName("Webhookログ");
  const values = sheet.getDataRange().getValues();

  for (let i = 1; i < values.length; i++) {
    const bodyJson = values[i][2];
    const classified = values[i][3];
    if (!bodyJson || classified) continue; // 未受信 or 分類済みは飛ばす

    const result = classifyWithClaude_(bodyJson);
    sheet.getRange(i + 1, 4).setValue(result.category + " / " + result.summary);
  }
}

function classifyWithClaude_(bodyJson) {
  const apiKey = PropertiesService.getScriptProperties().getProperty("ANTHROPIC_API_KEY");

  const payload = {
    model: "claude-opus-5",
    max_tokens: 1024,
    system: "あなたは問い合わせ内容を分類する担当です。必ず指定のJSON形式だけを返します。",
    messages: [
      {
        role: "user",
        content: "次のWebhookデータを分類してください。\n" + bodyJson,
      },
    ],
    output_config: {
      format: {
        type: "json_schema",
        schema: {
          type: "object",
          properties: {
            category: { type: "string", enum: ["申込", "問い合わせ", "解約", "その他"] },
            summary: { type: "string" },
          },
          required: ["category", "summary"],
          additionalProperties: false,
        },
      },
    },
  };

  const res = UrlFetchApp.fetch("https://api.anthropic.com/v1/messages", {
    method: "post",
    contentType: "application/json",
    headers: {
      "x-api-key": apiKey,
      "anthropic-version": "2023-06-01",
    },
    payload: JSON.stringify(payload),
    muteHttpExceptions: true,
  });

  if (res.getResponseCode() !== 200) {
    console.error("Claude APIエラー: " + res.getContentText());
    return { category: "その他", summary: "分類に失敗しました" };
  }

  const json = JSON.parse(res.getContentText());
  return JSON.parse(json.content[0].text);
}

function createClassifyTrigger() {
  ScriptApp.newTrigger("classifyPendingRows")
    .timeBased()
    .everyMinutes(10)
    .create();
}