Function registerQueueSessionTracking

src/lib/queue_session.ts:331–756

(plugin: ReactRNPlugin)

  } else {
    session.currentCardFirstRep = undefined;
    session.currentCardTotalTime = 0;
    session.currentCardRepCount = 0;
    session.currentCardInterval = undefined;
  }
}

export function registerQueueSessionTracking(plugin: ReactRNPlugin) {
  // One-shot startup migration / rollover: covers users who installed this
  // build but haven't reviewed yet. Fire-and-forget; widget reads will pick
  // up the new state via useSyncedStorageState reactivity.
  maybeRollOver(plugin);

  // Startup recovery: if the plugin restarted (page refresh, crash) while a
  // session was in progress, ACTIVE_SESSION_KEY holds the last synced snapshot
  // but currentSession is null. Rescue it into synced history so the work is
  // not silently lost.
  (async () => {
    try {
      const orphaned = await plugin.storage.getSession<PracticedQueueSession>(ACTIVE_SESSION_KEY);
      if (orphaned && (orphaned.flashcardsCount > 0 || orphaned.incRemsCount > 0)) {
        if (!orphaned.endTime) orphaned.endTime = Date.now();
        const history =
          ((await plugin.storage.getSynced(PRACTICED_QUEUES_HISTORY_KEY)) as PracticedQueueSession[]) || [];
        const deduped = history.filter((s): s is PracticedQueueSession => !!s && s.id !== orphaned.id);
        await plugin.storage.setSynced(PRACTICED_QUEUES_HISTORY_KEY, [orphaned, ...deduped]);
        await plugin.storage.setSession(ACTIVE_SESSION_KEY, null);
        console.log(
          `[QueueSession] Recovered orphaned session: id=${orphaned.id} scope="${orphaned.scopeName}" fc=${orphaned.flashcardsCount} ir=${orphaned.incRemsCount}`
        );
        maybeRollOver(plugin);
      }
    } catch (err) {
      console.error('[QueueSession] Orphaned session recovery failed:', err);
    }
  })();

  // Heartbeat monitor: auto-save Mastery Drill session if the popup is closed without QueueExit.
  // Popup drill only: the regular-queue drill writes no heartbeat, so a timestamp left behind
  // by an earlier popup would end each of its sessions 5 s after it starts.
  setInterval(async () => {
    if (currentSession && currentSession.scopeName === 'Mastery Drill' && !isNativeDrillActive()) {
      if (Date.now() - currentSession.startTime < 5000) return; // grace period
      const lastHeartbeat = await plugin.storage.getSession<number>('finalDrillHeartbeat');
      if (lastHeartbeat) {
        if (Date.now() - lastHeartbeat > 5000) {
          await saveCurrentSession(plugin, 'Heartbeat Stale');
        }
      }
    }
  }, 2500);

  // Cluster sibling-transition poll: inside a cluster, QueueLoadCard does NOT fire per
  // sibling — only card_info_bar.tsx sees each sibling via getWidgetContext().
  // The widget broadcasts `clusterVisibleCardId`; we poll for changes and advance the
  // per-card panel state (currentCardId/prevCardId + lifetime stats) so the UI tracks
  // the sibling actually on screen rather than being stuck on the cluster anchor.
  setInterval(async () => {
    const session = currentSession;