Function flushPending

src/core/embedding-tracker.ts:85–109

()

  };

  const flushPending = async (): Promise<void> => {
    if (closed || isProcessing) return;
    if (pendingFiles.size === 0) return;

    isProcessing = true;
    const batch = Array.from(pendingFiles).slice(0, maxFilesPerTick);
    for (const file of batch) pendingFiles.delete(file);

    try {
      const [fileEmbeds, identifierEmbeds] = await Promise.all([
        refreshFileSearchEmbeddings({ rootDir: options.rootDir, relativePaths: batch }),
        refreshIdentifierEmbeddings({ rootDir: options.rootDir, relativePaths: batch }),
      ]);
      if (fileEmbeds > 0 || identifierEmbeds > 0) {
        console.error(
          `Embedding tracker refreshed ${batch.length} file(s) | file-vectors=${fileEmbeds}, identifier-vectors=${identifierEmbeds}`,
        );
      }
    } catch (error) {
      console.error("Embedding tracker refresh failed:", error);
    } finally {
      isProcessing = false;
      if (pendingFiles.size > 0) schedule(100);
    }
  };

  try {
    watcher = watch(options.rootDir, { recursive: true }, (_eventType, fileName) => {