// 取得全域靜態資料，用來跨執行保存狀態，它是我們的筆記本
const sd = $getWorkflowStaticData('global');
// 第一次跑還沒有 buffers，先開一個空物件
if (!sd.buffers) sd.buffers = {};

// 這次 webhook 進來的原始內容
const body = $json.body || {};
const events = body.events || [];

// 一則一則檢查 LINE 丟進來的事件
for (const ev of events) {
  if (ev.type !== 'message') continue;                     // 不是訊息（例如加入好友）就跳過
  if (!ev.message || ev.message.type !== 'text') continue; // 不是純文字（貼圖、圖片）也跳過

  const src = ev.source || {};
  let key, to;
  // 依訊息來源決定「置物櫃編號」：群組 / 多人聊天室 / 一對一 各有不同
  if (src.groupId) { key = 'G:' + src.groupId; to = src.groupId; }
  else if (src.roomId) { key = 'R:' + src.roomId; to = src.roomId; }
  else { key = 'U:' + src.userId; to = src.userId; }

  // 這個人/群組第一次講話 → 發一個新的空籃子給他
  if (!sd.buffers[key]) sd.buffers[key] = { items: [], lastTs: 0, to };
  // 把訊息丟進籃子，順便記下它進來的時間
  sd.buffers[key].items.push({ text: ev.message.text, ts: ev.timestamp || Date.now() });
  // 更新「最後講話時間」，這是後面判斷你講完沒的關鍵
  sd.buffers[key].lastTs = Date.now();
}

// 這步只負責囤貨，回傳什麼其實不重要，給自己看日誌用的
return [{ json: { ok: true, keys: Object.keys(sd.buffers) } }];

const SILENCE_MS = 8000;                    // 停 8 秒沒新訊息才回（耐心長度）
const sd = $getWorkflowStaticData('global'); // 再次打開同一本筆記本
if (!sd.buffers) sd.buffers = {};

const now = Date.now(); // 現在的時刻
const out = [];         // 準備放「真的可以回」的人

// 翻每一個人的筆記本，逐一判斷
for (const key of Object.keys(sd.buffers)) {
  const buf = sd.buffers[key];
  if (!buf.items || buf.items.length === 0) continue; // 籃子是空的，沒啥好回
  if (now - buf.lastTs < SILENCE_MS) continue;        // 距上次講話不到 8 秒 → 還在講，跳過

  // 通過考驗 → 把籃子裡的訊息組成一段逐字稿，前面加時間方便 AI 理解先後順序
  const transcript = buf.items.map((m) => {
    const d = new Date(m.ts);
    const hh = String(d.getHours()).padStart(2, '0');
    const mm = String(d.getMinutes()).padStart(2, '0');
    return '[' + hh + ':' + mm + '] ' + m.text;
  }).join('\n');

  out.push({
    json: {
      key,                     // 誰講的
      to: buf.to,              // 要回給誰
      count: buf.items.length, // 這次合併了幾則
      transcript,              // 合併後的內容
    },
  });

  buf.items = []; // 清空籃子，避免等等 AI 回完又被重複處理
}

// 有人達標就往下送；都沒人就回一個空殼，讓後面的 AI 節點不會被觸發
return out.length ? out : [{ json: { key: '', to: '', transcript: '', count: 0, empty: true } }];