fix(plane): honor connector caps and preserve inbox timestamp order

Author: waleedlatif1

apps/sim/connectors/plane/plane.ts

@@ -111,7 +111,7 @@ export const planeConnector: ConnectorConfig = {
     }
     const response = await requestPlane(token, config, resourcePath(config), {
       cursor,
-      per_page: PAGE_SIZE,
+      per_page: Math.min(PAGE_SIZE, remaining),
       fields: config.contentType === 'pages' ? PAGE_FIELDS : WORK_ITEM_FIELDS,
       ...(config.contentType === 'work_items'
         ? { expand: 'state,assignees,labels', order_by: 'created_at' }

apps/sim/lib/desktop/application/executor.integration.ts

@@ -31,6 +31,7 @@ import {
 import { createDeferred } from '@sim/testing/helpers/deferred'
 import { featureFlagsMock, featureFlagsMockFns } from '@sim/testing/mocks/feature-flags.mock'
 import { generateId } from '@sim/utils/id'
+import { compareStrings } from '@sim/utils/string'
 import { eq, inArray, sql } from 'drizzle-orm'
 import { closeRedisConnection, getRedisClient } from '@/lib/core/config/redis'
 import type { DbTransaction } from '@/lib/db/types'
@@ -865,7 +866,7 @@ describe.runIf(Boolean(redisUrl))('desktop background executor protocol', () =>
       ])
     })
 
-    it('lists pending calls in persistence order even when their doorbell was never heard', async () => {
+    it('preserves sub-millisecond persistence order even when the doorbell was never heard', async () => {
       const desktop = await signedInDesktop()
       const run = await boundRun(desktop)
       const first = await pendingCall(run.runId, 'browser_navigate', { url: 'https://sim.ai' })
@@ -874,13 +875,23 @@ describe.runIf(Boolean(redisUrl))('desktop background executor protocol', () =>
         path: 'user-local/Project--mount-1',
         pattern: 'TODO',
       })
+      const persisted = [first, second, vfs].sort(compareStrings).reverse()
+      const createdAt = new Date(Date.now() - 1000).toISOString()
+      for (const [index, toolCallId] of persisted.entries()) {
+        await db
+          .update(copilotAsyncToolCalls)
+          .set({
+            createdAt: sql`${createdAt}::timestamp + ${index} * interval '100 microseconds'`,
+          })
+          .where(eq(copilotAsyncToolCalls.toolCallId, toolCallId))
+      }
       await pendingCall(run.runId, 'run_workflow', {})
       /** Rung while no stream was open: nobody heard it. */
       ringDesktopInbox(desktop.deviceId, 'call')
 
       expect(
         (await inbox(desktop)).items.map((item) => item.kind === 'call' && item.toolCallId)
-      ).toEqual([first, second, vfs])
+      ).toEqual(persisted)
     })
 
     it('counts the device online after a pull or a stream open, and keeps it online when the stream closes', async () => {

apps/sim/lib/desktop/executor/repository.ts

@@ -189,28 +189,25 @@ export async function listDesktopInboxRows(identity: Omit<DesktopDeviceIdentity,
       )
       .orderBy(asc(copilotAsyncToolCalls.createdAt), asc(copilotAsyncToolCalls.toolCallId))
       .limit(INBOX_ROW_LIMIT)
-  const [waiting, cancelled] = await Promise.all([
-    rowsWhere(
-      and(
-        eq(copilotAsyncToolCalls.status, ASYNC_TOOL_STATUS.pending),
-        isNull(copilotAsyncToolCalls.executionOwnerToken),
-        or(sql`${copilotAsyncToolCalls.pickupDeadlineAt} > clock_timestamp()`, awaitingPermission),
-        inArray(copilotRuns.status, LIVE_RUN_STATUSES),
-        isNull(copilotRuns.toolAdmissionClosedAt)
-      )
-    ),
-    rowsWhere(
-      and(
-        isNotNull(copilotAsyncToolCalls.executionOwnerToken),
-        isNull(copilotAsyncToolCalls.executionSettledAt),
-        ne(copilotAsyncToolCalls.status, ASYNC_TOOL_STATUS.running)
-      )
-    ),
-  ])
-  return [...waiting, ...cancelled].sort(
-    (a, b) =>
-      a.createdAt.getTime() - b.createdAt.getTime() || a.toolCallId.localeCompare(b.toolCallId)
+  return rowsWhere(
+    and(
+      eq(copilotAsyncToolCalls.status, ASYNC_TOOL_STATUS.pending),
+      isNull(copilotAsyncToolCalls.executionOwnerToken),
+      or(sql`${copilotAsyncToolCalls.pickupDeadlineAt} > clock_timestamp()`, awaitingPermission),
+      inArray(copilotRuns.status, LIVE_RUN_STATUSES),
+      isNull(copilotRuns.toolAdmissionClosedAt)
+    )
   )
+    .unionAll(
+      rowsWhere(
+        and(
+          isNotNull(copilotAsyncToolCalls.executionOwnerToken),
+          isNull(copilotAsyncToolCalls.executionSettledAt),
+          ne(copilotAsyncToolCalls.status, ASYNC_TOOL_STATUS.running)
+        )
+      )
+    )
+    .orderBy(asc(copilotAsyncToolCalls.createdAt), asc(copilotAsyncToolCalls.toolCallId))
 }
 
 export type DesktopInboxRow = Awaited<ReturnType<typeof listDesktopInboxRows>>[number]

apps/sim/scripts/test-plane-e2e.ts

@@ -600,7 +600,14 @@ try {
         (await planeConnector.validateConfig(apiKey, { ...config, maxDocuments: true })).valid,
         false
       )
-      const capped = await planeConnector.listDocuments(apiKey, { ...config, maxDocuments: 1 })
+      const cappedContext: Record<string, unknown> = { totalDocsFetched: 0 }
+      const capped = await planeConnector.listDocuments(
+        apiKey,
+        { ...config, maxDocuments: 1 },
+        undefined,
+        cappedContext
+      )
+      assert.equal(cappedContext.listingCapped, true)
       assert.equal(capped.documents.length, 1)
       assert.equal(capped.hasMore, false)
       assert.equal(capped.reconciliationSafe, false)

apps/sim/tools/plane/coverage.json

@@ -779,7 +779,7 @@
       "checked": 102,
       "failures": 0
     },
-    "liveVerification": "Disposable-project HTTP checks exercise v2 and v1 compatibility on Plane Cloud. A real signed webhook delivery exercises registration, signature verification, filtering and cleanup. Community Edition is source-audited; no separate self-hosted server was live-tested.",
+    "liveVerification": "The recorded Plane Cloud validation covers v2 and v1 compatibility and a real signed webhook delivery. These Cloud checks precede the connector cap fix and have not been rerun for this follow-up. Official Community Edition v1.4.2 was also tested over real HTTP with production Sim actions and the knowledge connector, reverse-proxy paths, signed attachment storage, and actual Celery webhook deliveries through the production signature and event handler.",
     "liveResponses": {
       "checked": 145,
       "failures": 0
@@ -791,10 +791,25 @@
       "successfulV2Operations": 67,
       "successfulV1CompatibilityVariants": 56,
       "verifiedSignedDeliveries": 1
+    },
+    "communityChecks": {
+      "release": "v1.4.2",
+      "reference": "https://github.com/makeplane/plane/releases/tag/v1.4.2",
+      "passed": 21,
+      "failed": 0,
+      "skipped": 1,
+      "requests": 76,
+      "successfulV1Operations": 51,
+      "additionalReverseProxyChecksPassed": 8,
+      "verifiedSignedDeliveries": 63,
+      "webhookProcessingErrors": 0,
+      "cleanupVerified": true,
+      "boundary": "Production action transport and knowledge connector over real provider HTTP; actual provider webhook deliveries through the production handler. Full Sim route/workflow execution is covered separately by synthetic HTTP and database integration checks."
     }
   },
   "documentedLimitations": [
     "API availability depends on the Plane edition and version. Community Edition compatibility uses v1.",
+    "Community Edition v1.4.2 does not expose the public project pages API or the v2 webhook management API. Work-item knowledge sync and manual webhook subscriptions were verified against the real Community server.",
     "Signed object-storage transfers are performed with the returned upload URL and form fields; asset initialization and confirmation are exposed as Plane actions.",
     "Expanded v2 objects without a published nested schema are preserved as JSON rather than assigning guessed fields.",
     "The knowledge connector uses v1 to access description content, which v2 work-item reads omit. Offset listings disable automatic deletion reconciliation.",