fix(connectors): keep confluence CQL page size constant; unify monday API version

The CQL search endpoint paginates by opaque cursor, and Atlassian does not
document that a cursor issued against one limit survives a request asking
for a different one. Narrowing limit to the remaining budget was the same
pattern reverted on airtable, asana, and ashby. The page size is now
constant and the cap is applied by trimming the returned page, which keeps
the cap exact without varying the request.

Monday OAuth getUserInfo hardcoded API-Version 2024-10 while every other
monday surface reads MONDAY_API_VERSION, defeating the single-source pin.

Author: waleedlatif1

apps/sim/connectors/confluence/confluence.ts

@@ -708,12 +708,18 @@ async function listDocumentsViaCql(
   }
 
   const fetchedSoFar = (syncContext?.totalDocsFetched as number) ?? 0
-  const remaining = maxPages > 0 ? maxPages - fetchedSoFar : CQL_PAGE_SIZE
-  const limit = Math.max(Math.min(CQL_PAGE_SIZE, remaining), 1)
+  const remaining = maxPages > 0 ? maxPages - fetchedSoFar : Number.POSITIVE_INFINITY
 
+  /**
+   * The page size stays constant for every request of a run. This endpoint
+   * paginates by opaque cursor, and Atlassian does not document that a cursor
+   * issued against one `limit` stays valid when the following request asks for a
+   * different one, so narrowing `limit` to the remaining budget risks skipping or
+   * repeating results. The cap is applied by trimming the returned page instead.
+   */
   const queryParams = new URLSearchParams()
   queryParams.append('cql', cql)
-  queryParams.append('limit', String(limit))
+  queryParams.append('limit', String(CQL_PAGE_SIZE))
   queryParams.append('expand', 'version,metadata.labels')
   /**
    * `/wiki/rest/api/content/search` paginates by opaque cursor only — it has no
@@ -724,7 +730,10 @@ async function listDocumentsViaCql(
 
   const url = `https://api.atlassian.com/ex/confluence/${cloudId}/wiki/rest/api/content/search?${queryParams.toString()}`
 
-  logger.info(`Searching Confluence via CQL: ${cql}`, { limit, hasCursor: Boolean(cursor) })
+  logger.info(`Searching Confluence via CQL: ${cql}`, {
+    limit: CQL_PAGE_SIZE,
+    hasCursor: Boolean(cursor),
+  })
 
   const response = await fetchWithRetry(url, {
     method: 'GET',
@@ -746,16 +755,30 @@ async function listDocumentsViaCql(
   const data = await response.json()
   const results = data.results || []
 
-  const documents: ExternalDocument[] = (results as Record<string, unknown>[])
+  const allDocuments: ExternalDocument[] = (results as Record<string, unknown>[])
     .filter(isCurrentContent)
     .map((item) => cqlResultToStub(item, domain))
 
+  /**
+   * Trim to the remaining budget. Trimming stops the walk (`hitLimit` below is
+   * then true), so the discarded tail is never skipped over — the run simply
+   * ends here.
+   */
+  const documents =
+    allDocuments.length > remaining ? allDocuments.slice(0, remaining) : allDocuments
+  const trimmedByCap = documents.length < allDocuments.length
+
   const nextCursor = extractCursor((data._links as Record<string, unknown> | undefined)?.next)
 
   const totalFetched = fetchedSoFar + documents.length
   if (syncContext) syncContext.totalDocsFetched = totalFetched
   const hitLimit = maxPages > 0 && totalFetched >= maxPages
-  if (hitLimit && nextCursor && syncContext) syncContext.listingCapped = true
+  /**
+   * Both truncation shapes count: pages this run trimmed off, and a page left
+   * unread behind a live cursor. A cap that lands exactly on source exhaustion
+   * is a complete listing and must still reconcile deletions.
+   */
+  if (hitLimit && (trimmedByCap || nextCursor) && syncContext) syncContext.listingCapped = true
 
   const hasMore = !hitLimit && Boolean(nextCursor)
 

apps/sim/lib/auth/connectors/providers.ts

@@ -17,6 +17,7 @@ import { getDocusignOAuthUrl } from '@/lib/oauth/docusign'
 import { getMicrosoftUserInfoFromIdToken } from '@/lib/oauth/microsoft'
 import { SALESFORCE_LOGIN_HOSTS } from '@/lib/oauth/salesforce'
 import { getCanonicalScopesForProvider } from '@/lib/oauth/utils'
+import { MONDAY_API_URL, MONDAY_API_VERSION } from '@/tools/monday/utils'
 import { REDDIT_USER_AGENT } from '@/tools/reddit/constants'
 import { deriveZohoDeskBaseFromApiDomain } from '@/tools/zoho_desk/host-allowlist'
 
@@ -1532,11 +1533,11 @@ export function buildConnectorProviders(): GenericOAuthConfig[] {
       redirectURI: `${getBaseUrl()}/api/auth/oauth2/callback/monday`,
       getUserInfo: async (tokens) => {
         try {
-          const response = await fetch('https://api.monday.com/v2', {
+          const response = await fetch(MONDAY_API_URL, {
             method: 'POST',
             headers: {
               'Content-Type': 'application/json',
-              'API-Version': '2024-10',
+              'API-Version': MONDAY_API_VERSION,
               Authorization: tokens.accessToken ?? '',
             },
             body: JSON.stringify({ query: '{ me { id name email } }' }),