fix(connectors): grain cache filter window across pages, greenhouse guard NaN page, rootly skip empty incidents

Author: waleedlatif1

apps/sim/connectors/grain/grain.ts

@@ -376,7 +376,9 @@ export const grainConnector: ConnectorConfig = {
     const body: Record<string, unknown> = { include: RECORDING_INCLUDE }
     if (cursor) body.cursor = cursor
 
-    const filter = buildRecordingFilter(sourceConfig)
+    const cachedFilter = syncContext?.grainFilter as Record<string, unknown> | undefined | null
+    const filter = cachedFilter !== undefined ? cachedFilter : buildRecordingFilter(sourceConfig)
+    if (syncContext && cachedFilter === undefined) syncContext.grainFilter = filter ?? null
     if (filter) body.filter = filter
 
     logger.info('Listing Grain recordings', {

apps/sim/connectors/greenhouse/greenhouse.ts

@@ -537,7 +537,8 @@ export const greenhouseConnector: ConnectorConfig = {
     lastSyncAt?: Date
   ): Promise<ExternalDocumentList> => {
     const maxCandidates = sourceConfig.maxCandidates ? Number(sourceConfig.maxCandidates) : 0
-    const page = cursor ? Number(cursor) : 1
+    const parsedPage = cursor ? Number(cursor) : 1
+    const page = Number.isFinite(parsedPage) && parsedPage > 0 ? Math.floor(parsedPage) : 1
     const updatedAfter = computeUpdatedAfter(lastSyncAt)
     const jobId = typeof sourceConfig.jobId === 'string' ? sourceConfig.jobId.trim() : ''
     const createdAfter =

apps/sim/connectors/rootly/rootly.ts

@@ -509,6 +509,10 @@ export const rootlyConnector: ConnectorConfig = {
 
       const events = await fetchTimelineEvents(accessToken, id)
       const content = formatIncidentContent(attrs, events)
+      if (!content.trim()) {
+        logger.info('Skipping Rootly incident with no indexable content', { externalId: id })
+        return null
+      }
       const metadata = buildMetadata(attrs)
 
       return {