From 785e49c56253b9c602a92b60b3995c7822492cb3 Mon Sep 17 00:00:00 2001
From: Waleed Latif <walif6@gmail.com>
Date: Mon, 14 Sep 2026 16:40:54 -0700
Subject: [PATCH] fix(confluence): drop scripts, styles, and unresolved Jira
 placeholders from indexed page text

---
 .../connectors/confluence/confluence.test.ts  | 165 +++++++++++++++---
 apps/sim/connectors/confluence/confluence.ts  |  66 +++++--
 .../connectors/sync-content-pass.test.ts      |   6 +-
 3 files changed, 194 insertions(+), 43 deletions(-)

diff --git a/apps/sim/connectors/confluence/confluence.test.ts b/apps/sim/connectors/confluence/confluence.test.ts
index f4c3601b9a9..894292d982a 100644
--- a/apps/sim/connectors/confluence/confluence.test.ts
+++ b/apps/sim/connectors/confluence/confluence.test.ts
@@ -10,15 +10,14 @@ import {
   buildLastModifiedClause,
   confluenceConnector,
   confluenceStorageToPlainText,
+  confluenceViewToPlainText,
   DYNAMIC_CONTENT_SKIP_REASON,
   escapeCql,
   extractConfluenceStorageText,
   isCurrentContent,
-  preserveConfluenceCallouts,
   readIncludedLabels,
 } from '@/connectors/confluence/confluence'
 import { extractCursor } from '@/connectors/confluence/cursor'
-import { htmlToPlainText } from '@/connectors/utils'
 
 describe('Confluence service-account scopes', () => {
   it('requests metadata and role reads needed for complete mirrored ACLs', () => {
@@ -216,14 +215,14 @@ describe('readIncludedLabels', () => {
   })
 })
 
-describe('preserveConfluenceCallouts', () => {
+describe('confluenceViewToPlainText', () => {
   it.concurrent('handles empty content', () => {
-    expect(preserveConfluenceCallouts('')).toBe('')
+    expect(confluenceViewToPlainText('')).toBe('')
   })
 
   it.concurrent('leaves content with no macros unchanged', () => {
     const html = '<p>Just a normal paragraph.</p>'
-    expect(preserveConfluenceCallouts(html)).toContain('Just a normal paragraph.')
+    expect(confluenceViewToPlainText(html)).toContain('Just a normal paragraph.')
   })
 
   it.concurrent('labels a built-in warning macro and keeps its body', () => {
@@ -232,7 +231,7 @@ describe('preserveConfluenceCallouts', () => {
       '<span class="aui-icon aui-icon-small aui-iconfont-warning confluence-information-macro-icon"></span>' +
       '<div class="confluence-information-macro-body"><p>Do NOT use this form for GitLab access.</p></div>' +
       '</div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).toContain('[WARNING]')
     expect(result).toContain('Do NOT use this form for GitLab access.')
   })
@@ -242,7 +241,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="confluence-information-macro confluence-information-macro-information">' +
       '<div class="confluence-information-macro-body"><p>Heads up.</p></div>' +
       '</div>'
-    expect(preserveConfluenceCallouts(html)).toContain('[INFO] Heads up.')
+    expect(confluenceViewToPlainText(html)).toContain('[INFO] Heads up.')
   })
 
   it.concurrent('labels a built-in note macro', () => {
@@ -250,7 +249,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="confluence-information-macro confluence-information-macro-note">' +
       '<div class="confluence-information-macro-body"><p>See also.</p></div>' +
       '</div>'
-    expect(preserveConfluenceCallouts(html)).toContain('[NOTE] See also.')
+    expect(confluenceViewToPlainText(html)).toContain('[NOTE] See also.')
   })
 
   it.concurrent('labels a built-in tip macro', () => {
@@ -258,7 +257,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="confluence-information-macro confluence-information-macro-tip">' +
       '<div class="confluence-information-macro-body"><p>Pro tip.</p></div>' +
       '</div>'
-    expect(preserveConfluenceCallouts(html)).toContain('[TIP] Pro tip.')
+    expect(confluenceViewToPlainText(html)).toContain('[TIP] Pro tip.')
   })
 
   it.concurrent('labels a generic custom-colored Panel macro using its header title', () => {
@@ -267,7 +266,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="panelHeader" style="background-color: #ffebe6;"><b>Do NOT use this form for:</b></div>' +
       '<div class="panelContent"><p>GitLab access requests go to the private channel instead.</p></div>' +
       '</div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).toContain('[CALLOUT: Do NOT use this form for:]')
     expect(result).toContain('GitLab access requests go to the private channel instead.')
   })
@@ -276,7 +275,7 @@ describe('preserveConfluenceCallouts', () => {
     const html =
       '<div class="panel"><div class="panelHeader"><b>Warning:</b></div>' +
       '<div class="panelContent"><p>See replacement form.</p></div></div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).toContain('[CALLOUT: Warning:] See replacement form.')
   })
 
@@ -286,7 +285,7 @@ describe('preserveConfluenceCallouts', () => {
       const html =
         '<div class="panel"><div class="panelHeader"><b>Warning:</b> <span>Do not use</span></div>' +
         '<div class="panelContent"><p>See replacement form.</p></div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).toContain('[CALLOUT: Warning: Do not use]')
     }
   )
@@ -294,13 +293,13 @@ describe('preserveConfluenceCallouts', () => {
   it.concurrent('falls back to a bare CALLOUT label when a Panel macro has no header text', () => {
     const html =
       '<div class="panel"><div class="panelContent"><p>Untitled panel body.</p></div></div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).toContain('[CALLOUT]')
     expect(result).toContain('Untitled panel body.')
   })
 
   it.concurrent(
-    'keeps the exclusion marker attached to its content through htmlToPlainText, even across surrounding whitespace collapse',
+    'keeps the exclusion marker attached to its content across surrounding whitespace collapse',
     () => {
       const html =
         '<p>Intro paragraph.</p>\n\n' +
@@ -309,7 +308,7 @@ describe('preserveConfluenceCallouts', () => {
         '<ul><li>GitLab</li></ul></div>' +
         '</div>\n\n' +
         '<p>Trailing paragraph.</p>'
-      const plainText = htmlToPlainText(preserveConfluenceCallouts(html))
+      const plainText = confluenceViewToPlainText(html)
       expect(plainText).toContain('[WARNING] Do NOT use this form for: GitLab')
       expect(plainText).toContain('Intro paragraph.')
       expect(plainText).toContain('Trailing paragraph.')
@@ -325,7 +324,7 @@ describe('preserveConfluenceCallouts', () => {
         '<p>Do NOT use this form for:</p>' +
         '<ul><li>GitLab</li><li>ServiceNow</li></ul>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).not.toContain('for:GitLab')
       expect(result).not.toContain('GitLabServiceNow')
       expect(result).toContain('Do NOT use this form for: GitLab ServiceNow')
@@ -339,7 +338,7 @@ describe('preserveConfluenceCallouts', () => {
         '<div class="panel"><div class="panelContent">' +
         '<p>First sentence.</p><p>Second sentence.</p>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).toContain('First sentence. Second sentence.')
       expect(result).not.toContain('sentence.Second')
     }
@@ -355,7 +354,7 @@ describe('preserveConfluenceCallouts', () => {
         '<ul><li>Nested item A</li><li>Nested item B</li></ul>' +
         '</li><li>Outer item two</li></ul>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       // Each nested <li>'s text must appear exactly once, not duplicated by the
       // outer <li> also being matched and its .text() recursing into it.
       const occurrences = (result.match(/Nested item A/g) ?? []).length
@@ -370,7 +369,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="panel"><div class="panelContent">' +
       '<table><tr><td>Cell text<blockquote><p>quoted text</p></blockquote>after quote</td></tr></table>' +
       '</div></div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).not.toContain('quotedtext')
     expect(result).not.toContain('textafter')
     expect(result).toContain('Cell text quoted text after quote')
@@ -383,7 +382,7 @@ describe('preserveConfluenceCallouts', () => {
         '<div class="panel"><div class="panelContent">' +
         '<p>This is un<b>believe</b>able.</p>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).not.toContain('un believe able')
       expect(result).toContain('This is unbelieveable.')
     }
@@ -394,7 +393,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="confluence-information-macro confluence-information-macro-warning">' +
       '<div class="confluence-information-macro-body"><p>Do not proceed<b>!</b></p></div>' +
       '</div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).not.toContain('proceed !')
     expect(result).toContain('[WARNING] Do not proceed!')
   })
@@ -404,7 +403,7 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="panel"><div class="panelContent">' +
       '<p>Do <b>NOT</b> use this form.</p>' +
       '</div></div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).toContain('Do NOT use this form.')
   })
 
@@ -416,7 +415,7 @@ describe('preserveConfluenceCallouts', () => {
         '<div class="panel"><div class="panelHeader"><b>Inner</b></div>' +
         '<div class="panelContent"><p>inner body</p></div></div>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).toContain('[CALLOUT: Outer]')
       expect(result).toContain('[CALLOUT: Inner] inner body')
     }
@@ -430,7 +429,7 @@ describe('preserveConfluenceCallouts', () => {
         '<div class="confluence-information-macro confluence-information-macro-warning">' +
         '<div class="confluence-information-macro-body"><p>Do not use this.</p></div></div>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       expect(result).toContain('[WARNING] Do not use this.')
     }
   )
@@ -443,7 +442,7 @@ describe('preserveConfluenceCallouts', () => {
         '<div class="panel"><div class="panelHeader"><b>Inner title</b></div>' +
         '<div class="panelContent"><p>inner body</p></div></div>' +
         '</div></div>'
-      const result = preserveConfluenceCallouts(html)
+      const result = confluenceViewToPlainText(html)
       // The outer panel has no header of its own — it must fall back to a
       // bare [CALLOUT], not steal "Inner title" from the nested panel.
       expect(result).toContain('[CALLOUT] [CALLOUT: Inner title] inner body')
@@ -455,10 +454,98 @@ describe('preserveConfluenceCallouts', () => {
       '<div class="confluence-information-macro confluence-information-macro-warning">' +
       '<div class="confluence-information-macro-body"><p>Do NOT use this form for:<br>GitLab</p></div>' +
       '</div>'
-    const result = preserveConfluenceCallouts(html)
+    const result = confluenceViewToPlainText(html)
     expect(result).not.toContain('for:GitLab')
     expect(result).toContain('[WARNING] Do NOT use this form for: GitLab')
   })
+
+  it.concurrent('drops app macro bootstrap scripts, inline styles, and chart data', () => {
+    const html =
+      '<p><style>[data-colorid=yr9gnc4vid]{color:#333333}</style>' +
+      '<span data-colorid="yr9gnc4vid">Colored text</span></p>' +
+      '<style type="text/css">/*<![CDATA[*/ div.rbtoc1748352890217 {padding: 0px;} /*]]>*/</style>' +
+      '<div class="ap-container" id="ap-lucidchart"><div class="ap-content"></div>' +
+      '<script class="ap-iframe-body-script">//<![CDATA[\n(function(){ var data = {"addon_key":"lucidchart-app"}; AP._createContainer(data); }());\n//]]></script></div>' +
+      '<script class="chart-render-data" type="application/json">{"pluginKey": "confluence.extra.chart"}</script>' +
+      '<p>After</p>'
+    expect(confluenceViewToPlainText(html)).toBe('Colored text After')
+  })
+
+  it.concurrent('keeps the word break a dropped script or style occupied', () => {
+    expect(confluenceViewToPlainText('<p>Before<style>.a{}</style>After</p>')).toBe('Before After')
+  })
+
+  it.concurrent('treats a page holding only an app macro as having no text', () => {
+    const html =
+      '<div class="ap-container"><div class="ap-content"></div>' +
+      '<script class="ap-iframe-body-script">(function(){ var data = {"addon_key":"drawio"}; }());</script></div>'
+    expect(confluenceViewToPlainText(html)).toBe('')
+  })
+
+  it.concurrent('reduces an unresolved Jira issue macro to its issue key', () => {
+    const html =
+      '<p>Tracked in ' +
+      '<span class="confluence-jim-macro jira-issue" data-jira-key="ENG-101">' +
+      '<a href="https://example.atlassian.net/browse/ENG-101" class="jira-issue-key">' +
+      '<span class="aui-icon aui-icon-wait issue-placeholder"></span>ENG-101</a> - ' +
+      '<span class="summary">Getting issue details...</span> ' +
+      '<span class="aui-lozenge aui-lozenge-subtle aui-lozenge-default issue-placeholder">STATUS</span>' +
+      '</span> and ' +
+      '<span class="confluence-jim-macro jira-issue conf-macro output-block">' +
+      '<a href="https://example.atlassian.net/browse/ENG-102" class="jira-issue-key">' +
+      '<span class="aui-icon aui-icon-wait issue-placeholder"> </span>ENG-102</a> - ' +
+      '<span class="summary">이슈 세부사항 가져오는 중...</span> ' +
+      '<span class="aui-lozenge aui-lozenge-subtle aui-lozenge-default issue-placeholder">상태</span>' +
+      '</span>.</p>'
+    expect(confluenceViewToPlainText(html)).toBe('Tracked in ENG-101 and ENG-102 .')
+  })
+
+  it.concurrent('falls back to the data attribute when the issue key link has no text', () => {
+    const html =
+      '<span class="confluence-jim-macro jira-issue" data-jira-key="ENG-103">' +
+      '<span class="summary">Getting issue details...</span>' +
+      '<span class="aui-lozenge issue-placeholder">STATUS</span></span>'
+    expect(confluenceViewToPlainText(html)).toBe('ENG-103')
+  })
+
+  it.concurrent('keeps the summary and status of a Jira issue macro Confluence resolved', () => {
+    const html =
+      '<span class="confluence-jim-macro jira-issue resolved" data-jira-key="OPS-201">' +
+      '<a href="https://example.atlassian.net/browse/OPS-201" class="jira-issue-key">' +
+      '<img class="icon" src="https://example.atlassian.net/avatar.png" />OPS-201</a> - ' +
+      '<span class="summary">Rotate the signing key</span> ' +
+      '<span class="aui-lozenge aui-lozenge-success jira-macro-single-issue-export-pdf">Done</span>' +
+      '</span>'
+    expect(confluenceViewToPlainText(html)).toBe('OPS-201 - Rotate the signing key Done')
+  })
+
+  it.concurrent('keeps the block break of a Jira issue macro inside a callout', () => {
+    const html =
+      '<div class="confluence-information-macro confluence-information-macro-warning">' +
+      '<div class="confluence-information-macro-body">Blocked by' +
+      '<div class="confluence-jim-macro jira-issue" data-jira-key="ENG-104">' +
+      '<a class="jira-issue-key"><span class="aui-icon issue-placeholder"></span>ENG-104</a> - ' +
+      '<span class="summary">Getting issue details...</span>' +
+      '<span class="aui-lozenge issue-placeholder">STATUS</span></div>' +
+      'until release</div></div>'
+    expect(confluenceViewToPlainText(html)).toBe('[WARNING] Blocked by ENG-104 until release')
+  })
+
+  it.concurrent('drops only the placeholder shell of a Jira issues table', () => {
+    const html =
+      '<p>Release notes</p>' +
+      '<div class="confluence-jim-macro refresh-module-id jira-table placeholder conf-macro output-block">' +
+      '<div class="jira-issues"><table class="aui"><tbody><tr></tr>' +
+      '<tr><th>type</th><th>key</th><th>summary</th></tr></tbody></table></div>' +
+      '<div class="refresh-issues-bottom"><span class="aui-icon aui-icon-wait">Loading...</span></div></div>' +
+      '<div class="confluence-jim-macro jira-table"><table class="aui"><tbody>' +
+      '<tr><th>key</th><th>summary</th></tr><tr><td>ENG-104</td><td>Update the runbook</td></tr>' +
+      '</tbody></table></div>' +
+      '<div class="confluence-jim-macro jira-table"><div class="aui-message">No issues found</div></div>'
+    expect(confluenceViewToPlainText(html)).toBe(
+      'Release notes key summary ENG-104 Update the runbook No issues found'
+    )
+  })
 })
 
 describe('confluence incremental CQL listing', () => {
@@ -1055,7 +1142,29 @@ describe('Confluence permission-scoped content', () => {
     )
 
     expect(document?.content).toContain('CONFIDENTIAL SALARY DATA')
-    expect(document?.contentHash).toBe('confluence:view-callouts:shared-page:1')
+    expect(document?.contentHash).toBe('confluence:view-text-v2:shared-page:1')
+  })
+
+  it('reports the content type of the endpoint that answered and omits unknown metadata', async () => {
+    vi.mocked(fetch).mockResolvedValueOnce(new Response('', { status: 404 }))
+
+    const document = await confluenceConnector.getDocument('token', config, 'shared-page', {
+      cloudId: 'cloud-1',
+    })
+
+    expect(vi.mocked(fetch).mock.calls.map(([input]) => new URL(String(input)).pathname)).toEqual([
+      '/ex/confluence/cloud-1/wiki/api/v2/pages/shared-page',
+      '/ex/confluence/cloud-1/wiki/api/v2/blogposts/shared-page',
+    ])
+    expect(document?.metadata).toEqual({
+      spaceId: 'space-1',
+      contentType: 'blogpost',
+      status: 'current',
+      version: 1,
+      labels: [],
+      lastModified: '',
+    })
+    expect(document?.metadata).not.toHaveProperty('spaceKey')
   })
 
   it('rejects a missing storage body without falling back to rendered content', async () => {
@@ -1118,7 +1227,7 @@ describe('Confluence permission-scoped content', () => {
       const expectedHash =
         'mirrorsSourceAcls' in mode || 'perMemberListing' in mode
           ? 'confluence:storage-local-body-v2:shared-page:1'
-          : 'confluence:view-callouts:shared-page:1'
+          : 'confluence:view-text-v2:shared-page:1'
 
       expect(v2.documents[0].contentHash).toBe(expectedHash)
       expect(cql.documents[0].contentHash).toBe(expectedHash)
diff --git a/apps/sim/connectors/confluence/confluence.ts b/apps/sim/connectors/confluence/confluence.ts
index 263d50c7db0..f0da25bdb44 100644
--- a/apps/sim/connectors/confluence/confluence.ts
+++ b/apps/sim/connectors/confluence/confluence.ts
@@ -1,5 +1,6 @@
 import { createLogger } from '@sim/logger'
 import { getErrorMessage } from '@sim/utils/errors'
+import { filterUndefined } from '@sim/utils/object'
 import * as cheerio from 'cheerio'
 import {
   AtlassianSiteNotAccessibleError,
@@ -172,9 +173,37 @@ function extractBlockJoinedText($: cheerio.CheerioAPI, $el: cheerio.Cheerio<any>
   return parts.join(' ').trim()
 }
 
-/** Matches either flavor of panel/macro this function rewrites. */
+/** Matches either flavor of panel/macro {@link rewriteConfluenceCallouts} rewrites. */
 const MACRO_SELECTOR = 'div.confluence-information-macro, div.panel'
 
+/**
+ * Rendered-page elements whose text is never page prose. App macros render as a
+ * bootstrap `<script>` carrying their JSON config, colored text and the table of
+ * contents emit inline `<style>` rules, and charts embed their data as a script.
+ */
+const VIEW_NOISE_SELECTOR = 'script, style'
+
+/**
+ * Jira macros render as placeholders the browser fills in. A single issue renders
+ * its key, then a localized "Getting issue details..." summary and "STATUS"
+ * lozenge, both marked `issue-placeholder`; the key is the only real content, and
+ * a macro Confluence did resolve carries no placeholder and keeps its summary and
+ * status. An issues table renders as a `placeholder` shell holding only column
+ * headers, a loading spinner, and its refresh settings.
+ */
+function collapseJiraIssuePlaceholders($: cheerio.CheerioAPI): void {
+  $('.jira-issue')
+    .filter((_, el) => $(el).find('.issue-placeholder').length > 0)
+    .each((_, el) => {
+      const $macro = $(el)
+      const key =
+        $macro.find('.jira-issue-key').first().text().trim() || $macro.attr('data-jira-key') || ''
+      $macro.text(key)
+    })
+
+  $('.jira-table.placeholder').remove()
+}
+
 /**
  * Confluence's rendered `view` HTML wraps Info/Note/Warning/Tip macros in
  * `confluence-information-macro confluence-information-macro-{type}` divs, and
@@ -197,11 +226,7 @@ const MACRO_SELECTOR = 'div.confluence-information-macro, div.panel'
  * bracketed `<p>` by the time its parent's body/header text is read — at which
  * point it correctly reads as plain text carrying its own label.
  */
-export function preserveConfluenceCallouts(html: string): string {
-  if (!html) return html
-
-  const $ = cheerio.load(html)
-
+function rewriteConfluenceCallouts($: cheerio.CheerioAPI): void {
   let progressed = true
   while (progressed) {
     progressed = false
@@ -228,8 +253,21 @@ export function preserveConfluenceCallouts(html: string): string {
       progressed = true
     })
   }
+}
 
-  return $.html()
+/**
+ * Plain text of a rendered `view` body: drops non-prose elements, reduces
+ * unresolved Jira placeholders to their issue keys, and labels callouts before
+ * the tags are stripped.
+ */
+export function confluenceViewToPlainText(html: string): string {
+  if (!html) return ''
+
+  const $ = cheerio.load(html)
+  $(VIEW_NOISE_SELECTOR).replaceWith(' ')
+  collapseJiraIssuePlaceholders($)
+  rewriteConfluenceCallouts($)
+  return htmlToPlainText($.html())
 }
 
 const STORAGE_MACRO_SELECTOR = 'ac\\:structured-macro, ac\\:macro'
@@ -416,7 +454,7 @@ export function readIncludedLabels(page: Record<string, unknown>): string[] {
  * is unchanged. Search must replace rendered inclusions with authored content;
  * ordinary knowledge bases retain their existing rendered representation.
  */
-const CONTENT_REPRESENTATION = 'view-callouts'
+const CONTENT_REPRESENTATION = 'view-text-v2'
 const SCOPED_CONTENT_REPRESENTATION = 'storage-local-body-v2'
 
 /**
@@ -464,7 +502,8 @@ function pageToStub(
     mimeType: 'text/plain',
     sourceUrl: options.sourceUrl,
     contentHash: `confluence:${representation}:${page.id}:${versionKey}`,
-    metadata: {
+    /** Hydration merges over the listing stub, so an absent key must not erase a listed value. */
+    metadata: filterUndefined({
       spaceId: options.spaceId,
       spaceKey: options.spaceKey,
       contentType: options.contentType,
@@ -472,7 +511,7 @@ function pageToStub(
       version: versionNumber,
       labels: options.labels ?? [],
       lastModified,
-    },
+    }),
   }
 }
 
@@ -767,7 +806,8 @@ export const confluenceConnector: ConnectorConfig = {
     const scopedContent = usesPermissionScopedContent(syncContext)
     const bodyFormat = scopedContent ? 'storage' : 'view'
     let page: Record<string, unknown> | null = null
-    for (const endpoint of ['pages', 'blogposts']) {
+    let contentType: 'page' | 'blogpost' = 'page'
+    for (const endpoint of ['pages', 'blogposts'] as const) {
       const url = `https://api.atlassian.com/ex/confluence/${cloudId}/wiki/api/v2/${endpoint}/${encodeURIComponent(externalId)}?body-format=${bodyFormat}&include-labels=true`
       const response = await fetchWithRetry(url, {
         method: 'GET',
@@ -779,6 +819,7 @@ export const confluenceConnector: ConnectorConfig = {
 
       if (response.ok) {
         page = await response.json()
+        contentType = endpoint === 'pages' ? 'page' : 'blogpost'
         break
       }
       if (response.status === 401) throw await createRetryableHttpError(response)
@@ -795,13 +836,14 @@ export const confluenceConnector: ConnectorConfig = {
     }
     const rawContent = representation.value
     const scoped = scopedContent ? extractConfluenceStorageText(rawContent) : null
-    const plainText = scoped ? scoped.text : htmlToPlainText(preserveConfluenceCallouts(rawContent))
+    const plainText = scoped ? scoped.text : confluenceViewToPlainText(rawContent)
 
     const links = page._links as Record<string, unknown> | undefined
     const stub = pageToStub(
       page,
       {
         spaceId: page.spaceId,
+        contentType,
         labels: readIncludedLabels(page),
         sourceUrl: links?.webui ? `https://${domain}/wiki${links.webui}` : undefined,
       },
diff --git a/apps/sim/lib/knowledge/connectors/sync-content-pass.test.ts b/apps/sim/lib/knowledge/connectors/sync-content-pass.test.ts
index de2d738b106..d4638298b69 100644
--- a/apps/sim/lib/knowledge/connectors/sync-content-pass.test.ts
+++ b/apps/sim/lib/knowledge/connectors/sync-content-pass.test.ts
@@ -421,7 +421,7 @@ describe('content pass checkpoint intent', () => {
       const { pass, result, hydrate, listDocuments } = await runPass({
         existing: {
           ...EXISTING,
-          contentHash: 'confluence:view-callouts:page:3',
+          contentHash: 'confluence:view-text-v2:page:3',
           storageKey: 'kb/old.txt',
           sourceSeenAt: new Date(checkpoint.startedAt),
         },
@@ -473,7 +473,7 @@ describe('content pass checkpoint intent', () => {
       const { pass, hydrate, listDocuments } = await runPass({
         existing: {
           ...EXISTING,
-          contentHash: 'confluence:view-callouts:page:3',
+          contentHash: 'confluence:view-text-v2:page:3',
           storageKey: 'kb/old.txt',
           sourceSeenAt: new Date(checkpoint.startedAt),
         },
@@ -645,7 +645,7 @@ describe('Confluence empty content through the shared content pass', () => {
     expect(dbChainMockFns.values).toHaveBeenCalledWith([
       expect.objectContaining({
         externalId: 'page',
-        contentHash: 'confluence:view-callouts:page:3',
+        contentHash: 'confluence:view-text-v2:page:3',
         storageKey: null,
         processingError: 'Document contains no extractable text',
       }),