feat(connectors): final audit — add verified scoping filters (grain team/type, granola+greenhouse createdBefore, gitlab milestone, rootly service/team/env), fix incident.io paused category + rootly severity-slug copy

Author: waleedlatif1

apps/sim/connectors/gitlab/gitlab.ts

@@ -366,6 +366,16 @@ export const gitlabConnector: ConnectorConfig = {
       description:
         'Only sync issues with all of these labels (comma-separated). Applies only when syncing issues.',
     },
+    {
+      id: 'issueMilestone',
+      title: 'Issue Milestone',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      placeholder: 'e.g. v1.0 (milestone title)',
+      description:
+        'Only sync issues assigned to this milestone (exact title). Applies only when syncing issues.',
+    },
     {
       id: 'maxItems',
       title: 'Max Items',
@@ -465,6 +475,9 @@ export const gitlabConnector: ConnectorConfig = {
       const issueLabels =
         typeof sourceConfig.issueLabels === 'string' ? sourceConfig.issueLabels.trim() : ''
       if (issueLabels) params.set('labels', issueLabels)
+      const issueMilestone =
+        typeof sourceConfig.issueMilestone === 'string' ? sourceConfig.issueMilestone.trim() : ''
+      if (issueMilestone) params.set('milestone', issueMilestone)
 
       const url = `${apiBase}/projects/${encodedProject}/issues?${params.toString()}`
       logger.info('Listing GitLab issues', {

apps/sim/connectors/grain/grain.ts

@@ -117,6 +117,8 @@ function isParticipantScope(value: unknown): value is ParticipantScope {
  * - `after_datetime` — derived from `lookbackDays`; recordings on/after the window start
  * - `participant_scope` — `internal` or `external`
  * - `title_search` — substring match against recording titles
+ * - `team` — recordings belonging to the given team UUID
+ * - `meeting_type` — recordings classified as the given meeting type UUID
  */
 function buildRecordingFilter(
   sourceConfig: Record<string, unknown>
@@ -136,6 +138,13 @@ function buildRecordingFilter(
     typeof sourceConfig.titleSearch === 'string' ? sourceConfig.titleSearch.trim() : ''
   if (titleSearch) filter.title_search = titleSearch
 
+  const team = typeof sourceConfig.teamId === 'string' ? sourceConfig.teamId.trim() : ''
+  if (team) filter.team = team
+
+  const meetingType =
+    typeof sourceConfig.meetingTypeId === 'string' ? sourceConfig.meetingTypeId.trim() : ''
+  if (meetingType) filter.meeting_type = meetingType
+
   return Object.keys(filter).length > 0 ? filter : undefined
 }
 
@@ -363,6 +372,26 @@ export const grainConnector: ConnectorConfig = {
       placeholder: 'e.g. weekly standup',
       description: 'Only sync recordings whose title matches this text. Leave blank to sync all.',
     },
+    {
+      id: 'teamId',
+      title: 'Team ID',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      placeholder: 'e.g. a1b2c3d4-e5f6-7890-abcd-ef1234567890',
+      description:
+        'Only sync recordings belonging to this team (Grain team UUID). Leave blank to sync all teams.',
+    },
+    {
+      id: 'meetingTypeId',
+      title: 'Meeting Type ID',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      placeholder: 'e.g. a1b2c3d4-e5f6-7890-abcd-ef1234567890',
+      description:
+        'Only sync recordings of this meeting type (Grain meeting type UUID). Leave blank to sync all types.',
+    },
   ],
 
   listDocuments: async (

apps/sim/connectors/granola/granola.ts

@@ -125,12 +125,12 @@ function parseFolderId(sourceConfig: Record<string, unknown>): string | undefine
 }
 
 /**
- * Parses the optional `createdAfter` date filter from source config. Returns a
- * normalized ISO 8601 string when the value is a valid date; otherwise returns
- * undefined so the request is not scoped to an invalid date.
+ * Parses an optional ISO 8601 date filter from a named source-config field.
+ * Returns a normalized ISO 8601 string when the value is a valid date; otherwise
+ * returns undefined so the request is not scoped to an invalid date.
  */
-function parseCreatedAfter(sourceConfig: Record<string, unknown>): string | undefined {
-  const raw = sourceConfig.createdAfter
+function parseDateFilter(sourceConfig: Record<string, unknown>, key: string): string | undefined {
+  const raw = sourceConfig[key]
   if (typeof raw !== 'string') return undefined
   const trimmed = raw.trim()
   if (!trimmed) return undefined
@@ -262,6 +262,16 @@ export const granolaConnector: ConnectorConfig = {
       description:
         'Only sync notes created on or after this date (ISO 8601). Leave blank to sync notes regardless of creation date.',
     },
+    {
+      id: 'createdBefore',
+      title: 'Created Before',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      placeholder: 'e.g. 2025-12-31 or 2025-12-31T23:59:59Z',
+      description:
+        'Only sync notes created on or before this date (ISO 8601). Leave blank to sync notes regardless of creation date.',
+    },
   ],
 
   listDocuments: async (
@@ -273,20 +283,23 @@ export const granolaConnector: ConnectorConfig = {
   ): Promise<ExternalDocumentList> => {
     const maxNotes = parseMaxNotes(sourceConfig)
     const folderId = parseFolderId(sourceConfig)
-    const createdAfter = parseCreatedAfter(sourceConfig)
+    const createdAfter = parseDateFilter(sourceConfig, 'createdAfter')
+    const createdBefore = parseDateFilter(sourceConfig, 'createdBefore')
 
     const url = new URL(`${GRANOLA_API_BASE}/notes`)
     url.searchParams.set('page_size', String(PAGE_SIZE))
     if (cursor) url.searchParams.set('cursor', cursor)
     if (lastSyncAt) url.searchParams.set('updated_after', lastSyncAt.toISOString())
     if (folderId) url.searchParams.set('folder_id', folderId)
     if (createdAfter) url.searchParams.set('created_after', createdAfter)
+    if (createdBefore) url.searchParams.set('created_before', createdBefore)
 
     logger.info('Listing Granola notes', {
       hasCursor: Boolean(cursor),
       incremental: Boolean(lastSyncAt),
       scopedToFolder: Boolean(folderId),
       scopedByCreatedAfter: Boolean(createdAfter),
+      scopedByCreatedBefore: Boolean(createdBefore),
     })
 
     const response = await fetchWithRetry(url.toString(), {
@@ -432,6 +445,19 @@ export const granolaConnector: ConnectorConfig = {
       }
     }
 
+    const createdBefore = sourceConfig.createdBefore
+    if (
+      typeof createdBefore === 'string' &&
+      createdBefore.trim() &&
+      Number.isNaN(new Date(createdBefore.trim()).getTime())
+    ) {
+      return {
+        valid: false,
+        error:
+          'Created Before must be a valid date (ISO 8601, e.g. 2025-12-31 or 2025-12-31T23:59:59Z)',
+      }
+    }
+
     try {
       const url = new URL(`${GRANOLA_API_BASE}/notes`)
       url.searchParams.set('page_size', '1')

apps/sim/connectors/greenhouse/greenhouse.ts

@@ -527,6 +527,16 @@ export const greenhouseConnector: ConnectorConfig = {
       description:
         'Sync only candidates created at or after this ISO 8601 timestamp. Leave empty to sync candidates regardless of creation date.',
     },
+    {
+      id: 'createdBefore',
+      title: 'Created Before',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      placeholder: 'e.g. 2024-12-31T23:59:59Z',
+      description:
+        'Sync only candidates created before this ISO 8601 timestamp. Combine with Created After to backfill a bounded date range.',
+    },
   ],
 
   listDocuments: async (
@@ -543,6 +553,8 @@ export const greenhouseConnector: ConnectorConfig = {
     const jobId = typeof sourceConfig.jobId === 'string' ? sourceConfig.jobId.trim() : ''
     const createdAfter =
       typeof sourceConfig.createdAfter === 'string' ? sourceConfig.createdAfter.trim() : ''
+    const createdBefore =
+      typeof sourceConfig.createdBefore === 'string' ? sourceConfig.createdBefore.trim() : ''
 
     const queryParams = new URLSearchParams({
       per_page: String(CANDIDATES_PER_PAGE),
@@ -551,6 +563,7 @@ export const greenhouseConnector: ConnectorConfig = {
     if (updatedAfter) queryParams.set('updated_after', updatedAfter)
     if (jobId) queryParams.set('job_id', jobId)
     if (createdAfter) queryParams.set('created_after', createdAfter)
+    if (createdBefore) queryParams.set('created_before', createdBefore)
 
     const url = `${GREENHOUSE_API_BASE}/candidates?${queryParams.toString()}`
 

apps/sim/connectors/incidentio/incidentio.ts

@@ -378,6 +378,7 @@ export const incidentioConnector: ConnectorConfig = {
       options: [
         { label: 'All', id: '' },
         { label: 'Live (active)', id: 'live' },
+        { label: 'Paused', id: 'paused' },
         { label: 'Closed', id: 'closed' },
         { label: 'Triage', id: 'triage' },
         { label: 'Learning (post-incident)', id: 'learning' },

apps/sim/connectors/rootly/rootly.ts

@@ -3,7 +3,7 @@ import { getErrorMessage, toError } from '@sim/utils/errors'
 import { RootlyIcon } from '@/components/icons'
 import { fetchWithRetry, VALIDATE_RETRY_OPTIONS } from '@/lib/knowledge/documents/utils'
 import type { ConnectorConfig, ExternalDocument, ExternalDocumentList } from '@/connectors/types'
-import { joinTagArray, parseTagDate } from '@/connectors/utils'
+import { joinTagArray, parseMultiValue, parseTagDate } from '@/connectors/utils'
 
 const logger = createLogger('RootlyConnector')
 
@@ -17,8 +17,9 @@ const MAX_TIMELINE_EVENTS = 200
  * JSON:API relationships to embed inline within each incident's `attributes`.
  * Rootly omits these unless requested via `include`, so both the list (stub) and
  * detail requests pass them to ensure tag metadata is identical on either path.
- * Scoped to exactly the relationships this connector reads (services, teams,
- * environments) to avoid fetching unused relationship payloads on every incident.
+ * Scoped to exactly the relationships this connector reads — `environments`,
+ * `services`, and `groups` (Rootly's API token for teams) — to avoid fetching
+ * unused relationship payloads on every incident.
  */
 const INCIDENT_INCLUDE = 'environments,services,groups'
 
@@ -388,9 +389,39 @@ export const rootlyConnector: ConnectorConfig = {
       type: 'short-input',
       required: false,
       mode: 'advanced',
-      placeholder: 'e.g. SEV0 (default: all)',
+      placeholder: 'e.g. sev0 (default: all)',
       description:
-        'Only sync incidents with this severity name. Leave blank to sync all severities.',
+        'Only sync incidents with this severity slug (e.g. sev0, sev1). Leave blank to sync all severities.',
+    },
+    {
+      id: 'services',
+      title: 'Filter by Services',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      multi: true,
+      placeholder: 'Service slugs (comma-separated, default: all)',
+      description: 'Only sync incidents affecting these service slugs.',
+    },
+    {
+      id: 'teams',
+      title: 'Filter by Teams',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      multi: true,
+      placeholder: 'Team slugs (comma-separated, default: all)',
+      description: 'Only sync incidents owned by these team slugs.',
+    },
+    {
+      id: 'environments',
+      title: 'Filter by Environments',
+      type: 'short-input',
+      required: false,
+      mode: 'advanced',
+      multi: true,
+      placeholder: 'Environment slugs (comma-separated, default: all)',
+      description: 'Only sync incidents in these environment slugs.',
     },
     {
       id: 'maxIncidents',
@@ -411,6 +442,9 @@ export const rootlyConnector: ConnectorConfig = {
     const maxIncidents = parseMaxIncidents(sourceConfig)
     const status = typeof sourceConfig.status === 'string' ? sourceConfig.status.trim() : ''
     const severity = typeof sourceConfig.severity === 'string' ? sourceConfig.severity.trim() : ''
+    const services = parseMultiValue(sourceConfig.services)
+    const teams = parseMultiValue(sourceConfig.teams)
+    const environments = parseMultiValue(sourceConfig.environments)
     const pageNumber = cursor ? Number(cursor) : 1
     const startPage = Number.isFinite(pageNumber) && pageNumber > 0 ? pageNumber : 1
 
@@ -420,6 +454,9 @@ export const rootlyConnector: ConnectorConfig = {
     queryParams.set('include', INCIDENT_INCLUDE)
     if (status) queryParams.set('filter[status]', status)
     if (severity) queryParams.set('filter[severity]', severity)
+    if (services.length > 0) queryParams.set('filter[services]', services.join(','))
+    if (teams.length > 0) queryParams.set('filter[teams]', teams.join(','))
+    if (environments.length > 0) queryParams.set('filter[environments]', environments.join(','))
 
     if (lastSyncAt) {
       queryParams.set('filter[updated_at][gt]', lastSyncAt.toISOString())