Function startTokensPerSecondInterval

core/http/static/chat.js:544–637

()

// Start a single global interval that updates tokens/second for the active chat
function startTokensPerSecondInterval() {
  // Stop any existing interval first
  stopTokensPerSecondInterval();
  
  // Get the current active chat ID to track
  const chatStore = Alpine.store("chat");
  if (!chatStore) {
    return;
  }
  
  const activeChat = chatStore.activeChat();
  if (!activeChat) {
    return;
  }
  
  // Check if active chat has an active request
  // We can start the interval if we have at least a controller (reader will be set when streaming starts)
  const request = activeRequests.get(activeChat.id);
  if (!request) {
    // No active request for this chat
    return;
  }
  
  if (!request.controller) {
    // No controller yet, don't start interval
    return;
  }
  
  // Store which chat this interval is for
  tokensPerSecondIntervalChatId = activeChat.id;
  
  // Start a single interval that always checks the current active chat
  // Use a function that always gets fresh state, no closures
  tokensPerSecondInterval = setInterval(() => {
    // Always get fresh references - no closures
    const currentChatStore = Alpine.store("chat");
    if (!currentChatStore) {
      stopTokensPerSecondInterval();
      return;
    }
    
    const currentActiveChat = currentChatStore.activeChat();
    const tokensPerSecondDisplay = document.getElementById('tokens-per-second');
    
    if (!tokensPerSecondDisplay) {
      stopTokensPerSecondInterval();
      return;
    }
    
    // CRITICAL: Check if the active chat has changed
    if (!currentActiveChat || currentActiveChat.id !== tokensPerSecondIntervalChatId) {
      // Active chat changed, stop this interval immediately and hide badge
      const maxBadge = document.getElementById('max-tokens-per-second-badge');
      if (maxBadge) {
        maxBadge.style.display = 'none';
      }
      stopTokensPerSecondInterval();
      return;