Function updateSessionStatusFromEvent

src/index.js:781–799

(event)

  const normalized = String(command || "compact").replace(/^\/+/, "").trim().toLowerCase();
  if (normalized === "compact" || normalized === "summarize")
    return "session_compact";
  return;
}
async function readRecentSessionMessages(client, sessionID, directory, limit = 20) {
  if (!client?.session?.messages)
    return;
  const query = { limit };
  if (directory)
    query.directory = directory;
  try {
    const messages = await sdkCall(client.session.messages.bind(client.session), { path: { id: sessionID }, query }, { path: { sessionID }, query }, { sessionID, ...query });
    return Array.isArray(messages) ? messages : undefined;
  } catch {
    return;
  }
}
function orderedSessionMessages(messages) {
  return (messages || []).map((message, index) => {
    const info = message?.info || message || {};
    const created = Number(info?.time?.created || 0);
    return { message, index, created: Number.isFinite(created) ? created : 0 };
  }).sort((a, b) => a.created - b.created || a.index - b.index).map((entry) => entry.message);