fix(granola): correct array output schemas, listing-truncation signal, and docs

Findings from validation passes over the tools, trigger, and connector.

Tools — array outputs were declared as `type: 'json'` with `properties`, which
describes an object, not an array. Agents and the output picker therefore saw
`notes.title` instead of `notes[i].title`. All 15 array outputs (including the
pre-existing three tools) now use `type: 'array'` with `items`, matching the
2000+ other tool files. The audit event `data` field stays `json`; it is
genuinely free-form per the spec.

Connector — `hasMore` was ANDed with the cursor, so a `hasMore: true` response
with no cursor was reported as a complete listing. The sync engine treats
exactly that shape as truncated and sets `listingTruncated` to block deletion
reconciliation; masking it meant a partial first page could be taken for the
whole corpus and reconciliation would hard-delete every note past it. Granola
would have to violate its own contract to emit that shape, but the engine
already handles it and the connector was hiding the signal. Also aligns
mimeType with the `.txt`/text-plain bytes the engine actually writes (it was
the only connector of 101 claiming text/markdown).

Trigger — the setup instructions named a Granola settings path that does not
exist; the help center says Settings > Connectors > API keys in the desktop app.

Both list parsers now split commas inside array entries, so an array-wrapped
free-text value cannot be sent as one malformed identifier.

Block — `id`, `events`, and `hasMore` are produced by several operations but
their descriptions named only one, unlike `folders` which already documented
both meanings.

Adds connector tests pinning all four listingCapped quadrants and the
truncation signal, and tool tests for the list parser and the PATCH body's
per-field "omit means unchanged" semantics.

Author: waleedlatif1

apps/docs/content/docs/en/integrations/granola.mdx

@@ -51,7 +51,7 @@ Lists meeting notes from Granola with optional date filters and pagination.
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `notes` | json | List of meeting notes |
+| `notes` | array | List of meeting notes |
 |   ↳ `id` | string | Note ID |
 |   ↳ `title` | string | Note title |
 |   ↳ `ownerName` | string | Note owner name |
@@ -86,19 +86,19 @@ Retrieves a specific meeting note from Granola by ID, including summary, attende
 | `webUrl` | string | URL to view the note in Granola |
 | `summaryText` | string | Plain text summary of the meeting |
 | `summaryMarkdown` | string | Markdown-formatted summary of the meeting |
-| `attendees` | json | Meeting attendees |
+| `attendees` | array | Meeting attendees |
 |   ↳ `name` | string | Attendee name |
 |   ↳ `email` | string | Attendee email |
-| `folders` | json | Folders the note belongs to |
+| `folders` | array | Folders the note belongs to |
 |   ↳ `id` | string | Folder ID |
 |   ↳ `name` | string | Folder name |
 | `calendarEventTitle` | string | Calendar event title |
 | `calendarOrganiser` | string | Calendar event organiser email |
 | `calendarEventId` | string | Calendar event ID |
 | `scheduledStartTime` | string | Scheduled start time |
 | `scheduledEndTime` | string | Scheduled end time |
-| `invitees` | json | Calendar event invitee emails |
-| `transcript` | json | Meeting transcript entries \(only if requested\) |
+| `invitees` | array | Calendar event invitee emails |
+| `transcript` | array | Meeting transcript entries \(only if requested\) |
 |   ↳ `speaker` | string | Speaker source \(microphone or speaker\) |
 |   ↳ `speakerAttribution` | string | Who spoke relative to the note owner: "me" for the note-taker, "them" for other participants. Null when attribution is unknown. |
 |   ↳ `speakerLabel` | string | Diarization label for the speaker \(e.g., Speaker A\) |
@@ -124,7 +124,7 @@ Retrieves a meeting transcript from Granola one page at a time, including when G
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `transcript` | json | Transcript items for this page |
+| `transcript` | array | Transcript items for this page |
 |   ↳ `speaker` | string | Audio source of the speaker \(microphone or speaker\) |
 |   ↳ `speakerAttribution` | string | Who spoke relative to the note owner: "me" for the note-taker, "them" for other participants. Null when attribution is unknown. |
 |   ↳ `speakerLabel` | string | Anonymous diarization label for the speaker \(e.g., Speaker A\) |
@@ -151,7 +151,7 @@ Lists folders from Granola, sorted alphabetically, with pagination.
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `folders` | json | List of folders |
+| `folders` | array | List of folders |
 |   ↳ `id` | string | Folder ID |
 |   ↳ `name` | string | Folder name |
 |   ↳ `parentFolderId` | string | Parent folder ID, or null for top-level folders |
@@ -177,7 +177,7 @@ Lists workspace audit events from Granola, with optional action and date filters
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `events` | json | List of audit events |
+| `events` | array | List of audit events |
 |   ↳ `id` | string | Audit event ID |
 |   ↳ `action` | string | The recorded action \(e.g., workspace.member_added\). Treat as an open set — actions are added over time. |
 |   ↳ `occurredAt` | string | When the action happened |
@@ -213,9 +213,9 @@ Registers an HTTPS URL in Granola to receive note event deliveries. The signing
 | `id` | string | Webhook endpoint ID |
 | `url` | string | The HTTPS URL deliveries are sent to |
 | `urlRedacted` | boolean | Whether the returned URL was reduced to its origin because the caller is not the endpoint creator |
-| `events` | json | Event names this endpoint is subscribed to |
-| `folderIds` | json | Folder IDs delivery is restricted to, or an empty array when unrestricted |
-| `scopes` | json | Which notes this endpoint receives events for |
+| `events` | array | Event names this endpoint is subscribed to |
+| `folderIds` | array | Folder IDs delivery is restricted to, or an empty array when unrestricted |
+| `scopes` | array | Which notes this endpoint receives events for |
 | `createdByName` | string | Name of the user who created the endpoint |
 | `createdByEmail` | string | Email of the user who created the endpoint |
 | `enabled` | boolean | Whether deliveries are active |
@@ -236,13 +236,13 @@ Lists the Granola webhook endpoints the API key can manage. A personal key sees
 
 | Parameter | Type | Description |
 | --------- | ---- | ----------- |
-| `webhookEndpoints` | json | List of webhook endpoints |
+| `webhookEndpoints` | array | List of webhook endpoints |
 |   ↳ `id` | string | Webhook endpoint ID |
 |   ↳ `url` | string | The HTTPS URL deliveries are sent to, reduced to its origin when urlRedacted is true |
 |   ↳ `urlRedacted` | boolean | Whether the URL was reduced to its origin because the caller is not the endpoint creator |
-|   ↳ `events` | json | Event names this endpoint is subscribed to |
-|   ↳ `folderIds` | json | Folder IDs delivery is restricted to, or an empty array when unrestricted |
-|   ↳ `scopes` | json | Which notes this endpoint receives events for |
+|   ↳ `events` | array | Event names this endpoint is subscribed to |
+|   ↳ `folderIds` | array | Folder IDs delivery is restricted to, or an empty array when unrestricted |
+|   ↳ `scopes` | array | Which notes this endpoint receives events for |
 |   ↳ `createdByName` | string | Name of the user who created the endpoint |
 |   ↳ `createdByEmail` | string | Email of the user who created the endpoint |
 |   ↳ `enabled` | boolean | Whether deliveries are active |
@@ -271,9 +271,9 @@ Updates a Granola webhook endpoint. Each supplied field replaces its current val
 | `id` | string | Webhook endpoint ID |
 | `url` | string | The HTTPS URL deliveries are sent to |
 | `urlRedacted` | boolean | Whether the returned URL was reduced to its origin because the caller is not the endpoint creator |
-| `events` | json | Event names this endpoint is subscribed to |
-| `folderIds` | json | Folder IDs delivery is restricted to, or an empty array when unrestricted |
-| `scopes` | json | Which notes this endpoint receives events for |
+| `events` | array | Event names this endpoint is subscribed to |
+| `folderIds` | array | Folder IDs delivery is restricted to, or an empty array when unrestricted |
+| `scopes` | array | Which notes this endpoint receives events for |
 | `createdByName` | string | Name of the user who created the endpoint |
 | `createdByEmail` | string | Email of the user who created the endpoint |
 | `enabled` | boolean | Whether deliveries are active |

apps/sim/blocks/blocks/granola.ts

@@ -361,9 +361,17 @@ export const GranolaBlock: BlockConfig = {
       type: 'json',
       description: 'List of meeting notes (id, title, ownerName, ownerEmail, createdAt, updatedAt)',
     },
-    hasMore: { type: 'boolean', description: 'Whether more notes are available' },
+    hasMore: {
+      type: 'boolean',
+      description:
+        'Whether another page is available, for whichever listing ran — notes, folders, audit events, or transcript items',
+    },
     cursor: { type: 'string', description: 'Pagination cursor for next page' },
-    id: { type: 'string', description: 'Note ID' },
+    id: {
+      type: 'string',
+      description:
+        'Note ID for Get Note, or the webhook endpoint ID for the create, update, and delete webhook endpoint operations',
+    },
     title: { type: 'string', description: 'Note title' },
     ownerName: { type: 'string', description: 'Note owner name' },
     ownerEmail: { type: 'string', description: 'Note owner email' },
@@ -392,7 +400,7 @@ export const GranolaBlock: BlockConfig = {
     events: {
       type: 'json',
       description:
-        'Audit events (id, action, occurredAt, collectedAt, actorType, actorId, actorEmail, data, ipAddress, userAgent, clientVersion)',
+        'Audit events (id, action, occurredAt, collectedAt, actorType, actorId, actorEmail, data, ipAddress, userAgent, clientVersion) for List Audit Events, or the subscribed webhook event names for the create and update webhook endpoint operations',
     },
     webhookEndpoints: {
       type: 'json',

apps/sim/connectors/granola/granola.test.ts

@@ -0,0 +1,180 @@
+/**
+ * Pins the listing-completeness signals the sync engine relies on to decide whether it may
+ * hard-delete stored documents. `listingCapped` and a truthful `hasMore` are the only things
+ * standing between a partial listing and reconciliation purging the rest of the knowledge base,
+ * so each quadrant is asserted explicitly.
+ *
+ * @vitest-environment node
+ */
+import { beforeEach, describe, expect, it, vi } from 'vitest'
+
+const { mockFetchWithRetry } = vi.hoisted(() => ({ mockFetchWithRetry: vi.fn() }))
+
+vi.mock('@/lib/knowledge/documents/utils', () => ({
+  fetchWithRetry: mockFetchWithRetry,
+  VALIDATE_RETRY_OPTIONS: {},
+}))
+vi.mock('@/components/icons', () => ({ GranolaIcon: () => null }))
+
+import { granolaConnector } from '@/connectors/granola/granola'
+
+function note(id: string) {
+  return {
+    id,
+    object: 'note',
+    title: `Note ${id}`,
+    owner: { name: 'Oat Benson', email: 'oat@granola.ai' },
+    created_at: '2026-01-27T15:30:00Z',
+    updated_at: '2026-01-27T16:45:00Z',
+  }
+}
+
+/** Queue a single Granola list-notes response. */
+function mockListResponse(body: unknown, status = 200) {
+  mockFetchWithRetry.mockResolvedValue({
+    ok: status >= 200 && status < 300,
+    status,
+    json: async () => body,
+    text: async () => JSON.stringify(body),
+  } as unknown as Response)
+}
+
+const list = (sourceConfig: Record<string, unknown>, syncContext: Record<string, unknown>) =>
+  granolaConnector.listDocuments('tok', sourceConfig, undefined, syncContext, undefined)
+
+describe('granola connector listing completeness', () => {
+  beforeEach(() => {
+    mockFetchWithRetry.mockReset()
+  })
+
+  it("passes Granola's hasMore through with the cursor on a normal page", async () => {
+    mockListResponse({ notes: [note('not_1')], hasMore: true, cursor: 'cur_2' })
+
+    const syncContext: Record<string, unknown> = {}
+    const page = await list({}, syncContext)
+
+    expect(page.hasMore).toBe(true)
+    expect(page.nextCursor).toBe('cur_2')
+    expect(syncContext.listingCapped).toBeUndefined()
+  })
+
+  it('surfaces hasMore=true with no cursor so the engine can mark the listing truncated', async () => {
+    /**
+     * The engine sets `listingTruncated` (which blocks deletion reconciliation outright) only when
+     * a connector reports this shape. Collapsing it to hasMore=false would present a partial page
+     * as the complete corpus.
+     */
+    mockListResponse({ notes: [note('not_1')], hasMore: true, cursor: null })
+
+    const page = await list({}, {})
+
+    expect(page.hasMore).toBe(true)
+    expect(page.nextCursor).toBeUndefined()
+  })
+
+  it('reports a complete listing when the source is exhausted', async () => {
+    mockListResponse({ notes: [note('not_1'), note('not_2')], hasMore: false, cursor: null })
+
+    const syncContext: Record<string, unknown> = {}
+    const page = await list({}, syncContext)
+
+    expect(page.hasMore).toBe(false)
+    expect(page.nextCursor).toBeUndefined()
+    expect(syncContext.listingCapped).toBeUndefined()
+    expect(page.documents).toHaveLength(2)
+  })
+
+  it('never caps when no maxNotes is configured', async () => {
+    mockListResponse({ notes: [note('not_1'), note('not_2')], hasMore: true, cursor: 'cur_2' })
+
+    const syncContext: Record<string, unknown> = {}
+    await list({ maxNotes: '' }, syncContext)
+
+    expect(syncContext.listingCapped).toBeUndefined()
+  })
+
+  it('caps and flags when maxNotes slices a page, hiding notes that still exist', async () => {
+    mockListResponse({
+      notes: [note('not_1'), note('not_2'), note('not_3')],
+      hasMore: false,
+      cursor: null,
+    })
+
+    const syncContext: Record<string, unknown> = {}
+    const page = await list({ maxNotes: '2' }, syncContext)
+
+    expect(page.documents).toHaveLength(2)
+    expect(syncContext.listingCapped).toBe(true)
+    expect(page.hasMore).toBe(false)
+  })
+
+  it('caps and flags when maxNotes lands on a page boundary but more pages exist', async () => {
+    mockListResponse({ notes: [note('not_1'), note('not_2')], hasMore: true, cursor: 'cur_2' })
+
+    const syncContext: Record<string, unknown> = {}
+    const page = await list({ maxNotes: '2' }, syncContext)
+
+    expect(page.documents).toHaveLength(2)
+    expect(syncContext.listingCapped).toBe(true)
+    expect(page.hasMore).toBe(false)
+  })
+
+  it('does NOT flag when the cap lands exactly on the last note and the source is exhausted', async () => {
+    /**
+     * Flagging here would block deletion reconciliation on every ordinary sync, stranding notes
+     * deleted in Granola in the knowledge base indefinitely.
+     */
+    mockListResponse({ notes: [note('not_1'), note('not_2')], hasMore: false, cursor: null })
+
+    const syncContext: Record<string, unknown> = {}
+    const page = await list({ maxNotes: '2' }, syncContext)
+
+    expect(page.documents).toHaveLength(2)
+    expect(syncContext.listingCapped).toBeUndefined()
+  })
+
+  it('carries the cap across pages via totalDocsFetched', async () => {
+    mockListResponse({ notes: [note('not_3'), note('not_4')], hasMore: true, cursor: 'cur_3' })
+
+    const syncContext: Record<string, unknown> = { totalDocsFetched: 1 }
+    const page = await list({ maxNotes: '2' }, syncContext)
+
+    expect(page.documents).toHaveLength(1)
+    expect(syncContext.totalDocsFetched).toBe(2)
+    expect(syncContext.listingCapped).toBe(true)
+  })
+})
+
+describe('granola connector request shaping', () => {
+  beforeEach(() => {
+    mockFetchWithRetry.mockReset()
+  })
+
+  it('requests the maximum page size and applies only valid scope filters', async () => {
+    mockListResponse({ notes: [], hasMore: false, cursor: null })
+
+    await granolaConnector.listDocuments(
+      'tok',
+      { folderId: 'not-a-folder-id', createdAfter: '2025-01-01' },
+      undefined,
+      {},
+      new Date('2026-01-01T00:00:00Z')
+    )
+
+    const url = new URL(mockFetchWithRetry.mock.calls[0][0] as string)
+    expect(url.searchParams.get('page_size')).toBe('30')
+    expect(url.searchParams.get('created_after')).toBe('2025-01-01T00:00:00.000Z')
+    expect(url.searchParams.get('updated_after')).toBe('2026-01-01T00:00:00.000Z')
+    /* A malformed folder id must not be sent — it would scope the sync to nothing. */
+    expect(url.searchParams.get('folder_id')).toBeNull()
+  })
+
+  it('stores content as plain text, matching the bytes the sync engine writes', async () => {
+    mockListResponse({ notes: [note('not_1')], hasMore: false, cursor: null })
+
+    const page = await list({}, {})
+
+    expect(page.documents[0].mimeType).toBe('text/plain')
+    expect(page.documents[0].contentDeferred).toBe(true)
+  })
+})

apps/sim/connectors/granola/granola.ts

@@ -196,7 +196,7 @@ function noteSummaryToStub(note: GranolaNoteSummary): ExternalDocument {
     title: note.title?.trim() || 'Untitled Note',
     content: '',
     contentDeferred: true,
-    mimeType: 'text/markdown',
+    mimeType: 'text/plain',
     contentHash: buildContentHash(note.id, note.updated_at),
     metadata: {
       title: note.title?.trim() || undefined,
@@ -274,7 +274,15 @@ export const granolaConnector: ConnectorConfig = {
     const totalFetched = prevFetched + documents.length
     if (syncContext) syncContext.totalDocsFetched = totalFetched
 
-    const sourceHasMore = Boolean(data.hasMore) && Boolean(nextCursor)
+    /**
+     * Report Granola's own `hasMore` verbatim rather than ANDing the cursor into
+     * it. The sync engine treats `hasMore: true` with no cursor as a truncated
+     * listing and sets `listingTruncated`, which blocks deletion reconciliation
+     * outright. Collapsing that shape to `hasMore: false` here would hide the
+     * signal and present a partial page as the complete corpus, letting
+     * reconciliation hard-delete every note past it.
+     */
+    const sourceHasMore = Boolean(data.hasMore)
     const hitLimit = maxNotes > 0 && totalFetched >= maxNotes
 
     /**
@@ -337,7 +345,7 @@ export const granolaConnector: ConnectorConfig = {
         title: note.title?.trim() || 'Untitled Note',
         content,
         contentDeferred: false,
-        mimeType: 'text/markdown',
+        mimeType: 'text/plain',
         sourceUrl: note.web_url?.trim() || undefined,
         contentHash: buildContentHash(note.id, note.updated_at),
         metadata: {

apps/sim/lib/webhooks/providers/granola.ts

@@ -70,7 +70,15 @@ function verifyGranolaSignature(
  * Trigger fields are free text, so both forms are accepted.
  */
 function parseList(value: unknown): string[] {
-  if (Array.isArray(value)) return value.map((entry) => String(entry).trim()).filter(Boolean)
+  const split = (entry: unknown) =>
+    String(entry)
+      .split(',')
+      .map((part) => part.trim())
+      .filter(Boolean)
+
+  /* Trigger config can arrive array-wrapped rather than split, so an entry may still
+     hold a comma-separated list; split inside entries as well as across them. */
+  if (Array.isArray(value)) return value.flatMap(split)
   if (typeof value !== 'string') return []
 
   const trimmed = value.trim()
@@ -80,17 +88,14 @@ function parseList(value: unknown): string[] {
     try {
       const parsed: unknown = JSON.parse(trimmed)
       if (Array.isArray(parsed)) {
-        return parsed.map((entry) => String(entry).trim()).filter(Boolean)
+        return parsed.flatMap(split)
       }
     } catch {
       /* Fall through to comma-separated parsing. */
     }
   }
 
-  return trimmed
-    .split(',')
-    .map((entry) => entry.trim())
-    .filter(Boolean)
+  return split(trimmed)
 }
 
 /** Turn a Granola API failure into a message worth showing on the deploy dialog. */