Function evaluateQueries

packages/lang-core/src/runtime/queryManager.ts:319–394

(queryNodes: QueryNode[])

  // ── Query evaluation ─────────────────────────────────────────────────────

  function evaluateQueries(queryNodes: QueryNode[]) {
    if (disposed) return;

    const activeIds = new Set(queryNodes.map((n) => n.statementId));

    // Clean up removed queries
    for (const [sid, q] of queries) {
      if (!activeIds.has(sid)) {
        if (q.timer) clearInterval(q.timer);
        queries.delete(sid);
        // Clean up cache entries that are no longer referenced
        cleanupCacheEntry(q.cacheKey);
        if (q.prevCacheKey) cleanupCacheEntry(q.prevCacheKey);
      }
    }

    // Process active queries
    for (const node of queryNodes) {
      if (!node.complete) continue;

      const cacheKey = buildCacheKey(node.toolName, node.args, node.deps);
      const existing = queries.get(node.statementId);

      if (existing) {
        // Track previous cache key for fallback display
        if (existing.cacheKey !== cacheKey) {
          existing.prevCacheKey = existing.cacheKey;
        }
        existing.toolName = node.toolName;
        existing.args = node.args;
        existing.defaults = node.defaults;
        existing.cacheKey = cacheKey;
      } else {
        queries.set(node.statementId, {
          toolName: node.toolName,
          args: node.args,
          defaults: node.defaults,
          cacheKey,
          loading: false,
          everFetched: false,
          refreshInterval: 0,
          needsRefetch: false,
        });
      }

      const q = queries.get(node.statementId)!;

      // Fire fetch if no settled data and not already in-flight
      const entry = cache.get(cacheKey);
      const hasSettledData = entry && entry.data !== undefined && !entry.inFlight;
      if (toolProvider && !hasSettledData && !entry?.inFlight) {
        executeFetch(cacheKey, node.statementId);
      }

      // Configure auto-refresh timer
      const newInterval = node.refreshInterval ?? 0;
      if (newInterval !== q.refreshInterval) {
        if (q.timer) {