Function bucketSession

src/lib/queue_aggregates.ts:91–111

(
  aggregates: DailyAggregate[],
  session: PracticedQueueSession,
  aggregatedIdsSet?: Set<string>
)

 * insert — pass it across many calls to avoid recomputing from scratch.
 */
export function bucketSession(
  aggregates: DailyAggregate[],
  session: PracticedQueueSession,
  aggregatedIdsSet?: Set<string>
): boolean {
  if (!session || !session.id) return false;
  if (aggregatedIdsSet?.has(session.id)) return false;
  const date = getLocalDateKey(session.startTime);
  const kbId = session.kbId || UNKNOWN_KB_ID;
  const bucket = findOrCreateBucket(aggregates, date, kbId);
  if (bucket.ids.includes(session.id)) return false;
  bucket.totalTime += session.totalTime || 0;
  bucket.cardsCount += session.flashcardsCount || 0;
  bucket.cardsTime += session.flashcardsTime || 0;
  bucket.incRemsCount += session.incRemsCount || 0;
  bucket.incRemsTime += session.incRemsTime || 0;
  bucket.forgotCount += session.againCount || 0;
  bucket.ids.push(session.id);
  if (aggregatedIdsSet) aggregatedIdsSet.add(session.id);
  return true;
}

/**
 * Move sessions older than the raw-window into daily aggregates. Idempotent: