fix(kb): poll for connector documents after initial sync without requiring refresh

Add time-bounded polling for newly created connectors awaiting their
first sync. Previously, documents only appeared after a manual page
refresh because the frontend stopped polling before the sync started.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: waleedlatif1

apps/sim/app/workspace/[workspaceId]/knowledge/[id]/base.tsx

@@ -62,7 +62,7 @@ import {
   type TagDefinition,
   useKnowledgeBaseTagDefinitions,
 } from '@/hooks/kb/use-knowledge-base-tag-definitions'
-import { useConnectorList } from '@/hooks/queries/kb/connectors'
+import { isConnectorSyncingOrPending, useConnectorList } from '@/hooks/queries/kb/connectors'
 import type { DocumentTagFilter } from '@/hooks/queries/kb/knowledge'
 import {
   useBulkDocumentOperation,
@@ -272,7 +272,7 @@ export function KnowledgeBase({
   } = useKnowledgeBase(id)
 
   const { data: connectors = [], isLoading: isLoadingConnectors } = useConnectorList(id)
-  const hasSyncingConnectors = connectors.some((c) => c.status === 'syncing')
+  const hasSyncingConnectors = connectors.some(isConnectorSyncingOrPending)
   const hasSyncingConnectorsRef = useRef(hasSyncingConnectors)
   hasSyncingConnectorsRef.current = hasSyncingConnectors
 

apps/sim/hooks/queries/kb/connectors.ts

@@ -88,6 +88,21 @@ async function fetchConnectorDetail(
   return result.data
 }
 
+/** Stop polling for initial sync after 2 minutes */
+const PENDING_SYNC_WINDOW_MS = 2 * 60 * 1000
+
+/**
+ * Checks if a connector is syncing or awaiting its first sync within the allowed window
+ */
+export function isConnectorSyncingOrPending(connector: ConnectorData): boolean {
+  if (connector.status === 'syncing') return true
+  return (
+    connector.status === 'active' &&
+    !connector.lastSyncAt &&
+    Date.now() - new Date(connector.createdAt).getTime() < PENDING_SYNC_WINDOW_MS
+  )
+}
+
 export function useConnectorList(knowledgeBaseId?: string) {
   return useQuery({
     queryKey: connectorKeys.list(knowledgeBaseId),
@@ -97,8 +112,8 @@ export function useConnectorList(knowledgeBaseId?: string) {
     placeholderData: keepPreviousData,
     refetchInterval: (query) => {
       const connectors = query.state.data
-      const hasSyncing = connectors?.some((c) => c.status === 'syncing')
-      return hasSyncing ? 3000 : false
+      if (!connectors?.length) return false
+      return connectors.some(isConnectorSyncingOrPending) ? 3000 : false
     },
   })
 }