lint

Author: waleedlatif1

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
     },
   })
 }

apps/sim/lib/knowledge/documents/document-processor.ts

@@ -761,7 +761,7 @@ async function parseDataURI(fileUrl: string, filename: string, mimeType: string)
 
   const extension = filename.includes('.')
     ? filename.split('.').pop()!.toLowerCase()
-    : getExtensionFromMimeType(mimeType) ?? 'txt'
+    : (getExtensionFromMimeType(mimeType) ?? 'txt')
   const buffer = Buffer.from(base64Data, 'base64')
   const result = await parseBuffer(buffer, extension)
   return result.content
@@ -774,9 +774,7 @@ async function parseHttpFile(
 ): Promise<{ content: string; metadata?: FileParseMetadata }> {
   const buffer = await downloadFileWithTimeout(fileUrl)
 
-  let extension = filename.includes('.')
-    ? filename.split('.').pop()?.toLowerCase()
-    : undefined
+  let extension = filename.includes('.') ? filename.split('.').pop()?.toLowerCase() : undefined
   if (!extension && mimeType) {
     extension = getExtensionFromMimeType(mimeType) ?? undefined
   }