Function sessionStatusType

src/index.js:828–860

(client, sessionID, directory, options = {})

  const completed = Number(info?.time?.completed || 0);
  const created = Number(info?.time?.created || 0);
  if (!Number.isFinite(completed) || completed <= 0)
    return "incomplete";
  const startedAt = Number(active?.startedAt || 0);
  if (startedAt > 0 && completed < startedAt && (!Number.isFinite(created) || created < startedAt))
    return "incomplete";
  const relevant = ordered.filter((message) => {
    const candidate = message?.info || message || {};
    if (candidate.role !== "assistant")
      return false;
    if (startedAt <= 0)
      return true;
    const candidateCreated = Number(candidate?.time?.created || 0);
    const candidateCompleted = Number(candidate?.time?.completed || 0);
    return candidateCreated >= startedAt || candidateCompleted >= startedAt;
  });
  return relevant.some(assistantMessageHasMeaningfulActivity) ? "completed" : "empty";
}
async function resolveCompactionModel(directory, client, sessionID, preferredModel) {
  const preferred = normalizedModelRef(preferredModel);
  if (preferred)
    return preferred;
  const cached = normalizedModelRef(getSessionExecutionContext(sessionID)?.model);
  if (cached)
    return cached;
  const captured = await captureSessionExecutionContext(client, sessionID);
  const capturedModel = normalizedModelRef(captured?.model);
  if (capturedModel)
    return capturedModel;
  const messages = await readRecentSessionMessages(client, sessionID, directory);
  for (const message of orderedSessionMessages(messages).reverse()) {
    const info = message?.info || message;
    const model = normalizedModelRef(info?.model) || normalizedModelRef(info);
    if (!model)
      continue;
    const previous = getSessionExecutionContext(sessionID) || {};
    setSessionExecutionContext(sessionID, { ...previous, model });