${html}`;
+ else if (mark.type === "link" && mark.attrs?.href) {
+ html = `${html}`;
+ }
+ }
+ return html;
+}
+
+function inlineHtml(node) {
+ if (!node) return "";
+ if (node.type === "text") return marksWrap(node.text || "", node.marks);
+ if (node.type === "hardBreak") return "${inlineHtml(node)}
`; + } + if (node.type === "blockquote") { + const inner = (node.content || []).map((c, i) => blockToHtml(c, `${path}/${i}`)).join(""); + return `${inner}`; + } + if (node.type === "bulletList" || node.type === "orderedList") { + const tag = node.type === "bulletList" ? "ul" : "ol"; + const items = (node.content || []) + .map((li) => `
North region freeze is 01:00-05:00 IST on release nights.
", + approved: true, + }, + { + operation: "delete", + chunk_id: table.attrs.localId, + approved: true, + }, + ]); + const texts = JSON.stringify(next); + assert.match(texts, /01:00-05:00/); + assert.equal(next.content.some((n) => n.type === "table"), true); + assert.equal(next.content.some((n) => n.type === "codeBlock"), true); + }); + + it("html fragment becomes heading + paragraph", () => { + const frag = htmlFragmentToAdf("Not stated in source.
"); + assert.equal(frag[0].type, "heading"); + assert.equal(frag[1].type, "paragraph"); + }); +}); + +describe("superdocs pending parse", () => { + it("parses twice when payload is a JSON string", () => { + const inner = [{ change_id: "ch_1", operation: "edit", chunk_id: "a", old_html: "x
", new_html: "y
" }]; + const wrapped = JSON.stringify(JSON.stringify(inner)); + const once = parseTwice(JSON.parse(wrapped)); + assert.equal(Array.isArray(once), true); + const pending = normalizePendingChanges(JSON.stringify(inner)); + assert.equal(pending[0].change_id, "ch_1"); + }); +}); diff --git a/extensions/jaskiringg/confluence-ai/src/lib/confluence.js b/extensions/jaskiringg/confluence-ai/src/lib/confluence.js new file mode 100644 index 0000000..1954e1d --- /dev/null +++ b/extensions/jaskiringg/confluence-ai/src/lib/confluence.js @@ -0,0 +1,345 @@ +const DEMO_PAGE_ID = "demo-page"; +const DEMO_SPACE_ID = "demo-space"; + +const DEMO_ADF = { + type: "doc", + version: 1, + content: [ + { + type: "heading", + attrs: { level: 1 }, + content: [{ type: "text", text: "IT Change Policy — North Region" }], + }, + { + type: "paragraph", + content: [ + { + type: "text", + text: "All production changes require a CAB ticket before cutover. Emergency changes still need a follow-up ticket within 24 hours.", + }, + ], + }, + { + type: "heading", + attrs: { level: 2 }, + content: [{ type: "text", text: "Freeze windows" }], + }, + { + type: "paragraph", + content: [ + { + type: "text", + text: "North region freeze is 02:00-06:00 IST on release nights. No master-data edits during freeze.", + }, + ], + }, + { + type: "table", + attrs: { isNumberColumnEnabled: false, layout: "default" }, + content: [ + { + type: "tableRow", + content: [ + { + type: "tableHeader", + attrs: {}, + content: [{ type: "paragraph", content: [{ type: "text", text: "System" }] }], + }, + { + type: "tableHeader", + attrs: {}, + content: [{ type: "paragraph", content: [{ type: "text", text: "Owner" }] }], + }, + ], + }, + { + type: "tableRow", + content: [ + { + type: "tableCell", + attrs: {}, + content: [{ type: "paragraph", content: [{ type: "text", text: "Order API" }] }], + }, + { + type: "tableCell", + attrs: {}, + content: [{ type: "paragraph", content: [{ type: "text", text: "Platform" }] }], + }, + ], + }, + ], + }, + { + type: "heading", + attrs: { level: 2 }, + content: [{ type: "text", text: "Rollback" }], + }, + { + type: "paragraph", + content: [ + { + type: "text", + text: "If error rate exceeds 2% after cutover, roll back within 15 minutes and page the on-call.", + }, + ], + }, + { + type: "codeBlock", + attrs: { language: "bash" }, + content: [{ type: "text", text: "kubectl rollout undo deploy/order-api" }], + }, + ], +}; + +function loadDemoAdf() { + return JSON.parse(JSON.stringify(DEMO_ADF)); +} + +function authHeader(email, token) { + return `Basic ${Buffer.from(`${email}:${token}`).toString("base64")}`; +} + +function confluenceConfigured(env) { + return !!(env.CONFLUENCE_BASE_URL && env.CONFLUENCE_EMAIL && env.CONFLUENCE_API_TOKEN); +} + +function liveConfluence(env, id) { + if (id && String(id).startsWith("demo")) return false; + return !!(env.useForgeApi || confluenceConfigured(env)); +} + +async function forgeFetch(pathname, { method = "GET", body } = {}) { + const { asApp, assumeTrustedRoute } = require("@forge/api"); + const res = await asApp().requestConfluence(assumeTrustedRoute(pathname), { + method, + headers: { + Accept: "application/json", + ...(body ? { "Content-Type": "application/json" } : {}), + }, + body: body ? JSON.stringify(body) : undefined, + }); + const text = await res.text(); + const data = text ? JSON.parse(text) : null; + if (!res.ok) { + throw new Error(`Confluence ${res.status}: ${text.slice(0, 500)}`); + } + return data; +} + +async function cfFetch(env, pathname, { method = "GET", body } = {}) { + const url = `${env.CONFLUENCE_BASE_URL.replace(/\/$/, "")}${pathname}`; + const res = await fetch(url, { + method, + headers: { + Authorization: authHeader(env.CONFLUENCE_EMAIL, env.CONFLUENCE_API_TOKEN), + Accept: "application/json", + ...(body ? { "Content-Type": "application/json" } : {}), + }, + body: body ? JSON.stringify(body) : undefined, + }); + const text = await res.text(); + const data = text ? JSON.parse(text) : null; + if (!res.ok) { + throw new Error(`Confluence ${res.status}: ${text.slice(0, 500)}`); + } + return data; +} + +async function productFetch(env, pathname, opts) { + if (env.useForgeApi) return forgeFetch(pathname, opts); + return cfFetch(env, pathname, opts); +} + +function parseAdfFromPage(page) { + const value = + page?.body?.atlas_doc_format?.value || + page?.body?.value || + null; + if (!value) throw new Error("Page has no atlas_doc_format body"); + return typeof value === "string" ? JSON.parse(value) : value; +} + +const DEMO_TITLES = { + [DEMO_PAGE_ID]: "IT Change Policy — North Region", + "demo-page-2": "Go-live checklist (draft)", + "demo-page-3": "SIT notes — week 12", +}; + +async function getPage(env, pageId) { + if (!liveConfluence(env, pageId)) { + const adf = loadDemoAdf(); + if (pageId === "demo-page-2") { + adf.content[0] = { + type: "heading", + attrs: { level: 1 }, + content: [{ type: "text", text: "Go-live checklist (draft)" }], + }; + } + if (pageId === "demo-page-3") { + adf.content[0] = { + type: "heading", + attrs: { level: 1 }, + content: [{ type: "text", text: "SIT notes — week 12" }], + }; + } + return { + id: String(pageId), + title: DEMO_TITLES[pageId] || "Demo page", + status: "current", + spaceId: DEMO_SPACE_ID, + version: { number: 1 }, + adf, + demo: true, + }; + } + const page = await productFetch( + env, + `/wiki/api/v2/pages/${encodeURIComponent(pageId)}?body-format=atlas_doc_format` + ); + return { + id: String(page.id), + title: page.title, + status: page.status, + spaceId: String(page.spaceId), + version: page.version, + adf: parseAdfFromPage(page), + demo: false, + }; +} + +async function updatePage(env, { pageId, title, adf, versionNumber, message }) { + if (!liveConfluence(env, pageId)) { + return { + id: DEMO_PAGE_ID, + title, + version: { number: (versionNumber || 1) + 1, message }, + demo: true, + adf, + }; + } + return productFetch(env, `/wiki/api/v2/pages/${encodeURIComponent(pageId)}`, { + method: "PUT", + body: { + id: String(pageId), + status: "current", + title, + body: { + representation: "atlas_doc_format", + value: JSON.stringify(adf), + }, + version: { + number: versionNumber + 1, + message: message || "SuperDocs AI edit (approved batch)", + }, + }, + }); +} + +async function listSpacePages(env, spaceId) { + if (!liveConfluence(env, spaceId) || spaceId === DEMO_SPACE_ID) { + return [ + { id: DEMO_PAGE_ID, title: "IT Change Policy — North Region", status: "current" }, + { id: "demo-page-2", title: "Go-live checklist (draft)", status: "current" }, + { id: "demo-page-3", title: "SIT notes — week 12", status: "current" }, + ]; + } + const data = await productFetch( + env, + `/wiki/api/v2/spaces/${encodeURIComponent(spaceId)}/pages?limit=50&status=current` + ); + return (data.results || []).map((p) => ({ + id: String(p.id), + title: p.title, + status: p.status, + })); +} + +function mapUser(u) { + if (!u) return null; + return { + accountId: u.accountId, + displayName: u.displayName || u.publicName || u.email, + email: u.email, + }; +} + +async function searchUsers(env, query) { + if (!liveConfluence(env)) { + return [ + { accountId: "demo-approver", displayName: "Priya Sharma (demo)", email: "priya@example.com" }, + { accountId: "demo-author", displayName: "Jaskirat Singh (demo)", email: "singhjass6404@gmail.com" }, + ].filter((u) => !query || u.displayName.toLowerCase().includes(query.toLowerCase())); + } + try { + const q = String(query || "").trim(); + if (!q) { + const me = await productFetch(env, "/wiki/rest/api/user/current"); + const mapped = mapUser(me); + return mapped ? [mapped] : []; + } + const data = await productFetch( + env, + `/wiki/rest/api/user/search?query=${encodeURIComponent(q)}&limit=10` + ); + const rows = Array.isArray(data) ? data : data.results || []; + return rows.map(mapUser).filter(Boolean); + } catch { + return [ + { + accountId: "current-user", + displayName: "Jaskirat Singh", + email: env.CONFLUENCE_EMAIL || "singhjass6404@gmail.com", + }, + ]; + } +} + +const PROPERTY_KEY = "superdocs-review"; + +async function getReviewState(env, pageId, memory) { + if (memory.has(pageId)) return memory.get(pageId); + if (!liveConfluence(env, pageId) || pageId === DEMO_PAGE_ID) { + return { status: "draft" }; + } + try { + const data = await productFetch( + env, + `/wiki/rest/api/content/${encodeURIComponent(pageId)}/property/${PROPERTY_KEY}` + ); + return data.value || { status: "draft" }; + } catch { + return { status: "draft" }; + } +} + +async function setReviewState(env, pageId, value, memory) { + memory.set(pageId, value); + if (!liveConfluence(env, pageId) || pageId === DEMO_PAGE_ID) return value; + try { + await productFetch( + env, + `/wiki/rest/api/content/${encodeURIComponent(pageId)}/property/${PROPERTY_KEY}`, + { method: "PUT", body: { key: PROPERTY_KEY, value } } + ); + } catch { + await productFetch( + env, + `/wiki/rest/api/content/${encodeURIComponent(pageId)}/property`, + { method: "POST", body: { key: PROPERTY_KEY, value } } + ); + } + return value; +} + +module.exports = { + DEMO_PAGE_ID, + DEMO_SPACE_ID, + confluenceConfigured, + getPage, + updatePage, + listSpacePages, + searchUsers, + getReviewState, + setReviewState, + loadDemoAdf, +}; diff --git a/extensions/jaskiringg/confluence-ai/src/lib/superdocs.js b/extensions/jaskiringg/confluence-ai/src/lib/superdocs.js new file mode 100644 index 0000000..597badd --- /dev/null +++ b/extensions/jaskiringg/confluence-ai/src/lib/superdocs.js @@ -0,0 +1,158 @@ +const DEFAULT_BASE = process.env.SUPERDOCS_API_BASE || "https://api.superdocs.app"; + +function parseJsonLenient(text) { + if (text == null) return null; + if (typeof text !== "string") return text; + const cleaned = text.replace(/[\u0000-\u0008\u000B\u000C\u000E-\u001F]/g, " "); + try { + return JSON.parse(cleaned); + } catch (err) { + const once = cleaned.replace(/,\s*([}\]])/g, "$1"); + return JSON.parse(once); + } +} + +function parseTwice(value) { + let v = value; + if (typeof v === "string") v = parseJsonLenient(v); + if (typeof v === "string") v = parseJsonLenient(v); + return v; +} + +function normalizePendingChanges(raw) { + let v = parseTwice(raw); + if (!v) return []; + if (!Array.isArray(v) && v.changes) v = parseTwice(v.changes); + if (!Array.isArray(v)) return []; + return v.map((item) => { + const c = typeof item === "string" ? parseTwice(item) : item; + return c && typeof c === "object" ? c : null; + }).filter(Boolean); +} + +async function sdFetch(path, { method = "GET", body, apiKey, base = DEFAULT_BASE } = {}) { + if (!apiKey) throw new Error("SUPERDOCS_API_KEY is missing"); + const res = await fetch(`${base}${path}`, { + method, + headers: { + Authorization: `Bearer ${apiKey}`, + ...(body ? { "Content-Type": "application/json" } : {}), + }, + body: body ? JSON.stringify(body) : undefined, + }); + const text = await res.text(); + const data = text ? parseJsonLenient(text) : null; + if (!res.ok) { + const msg = data?.detail || data?.error || data?.message || text.slice(0, 400); + const err = new Error(`SuperDocs ${res.status}: ${typeof msg === "string" ? msg : JSON.stringify(msg)}`); + err.status = res.status; + err.body = data; + throw err; + } + return data; +} + +async function startHitlEdit({ apiKey, sessionId, documentHtml, message, modelTier = "core" }) { + return sdFetch("/v1/chat/async", { + method: "POST", + apiKey, + body: { + message, + session_id: sessionId, + document_html: documentHtml, + approval_mode: "ask_every_time", + model_tier: modelTier, + }, + }); +} + +async function getJob({ apiKey, jobId }) { + const job = await sdFetch(`/v1/jobs/${jobId}`, { apiKey }); + const pending = normalizePendingChanges(job?.metadata?.pending_changes); + return { ...job, pending_changes: pending }; +} + +async function approveChanges({ apiKey, sessionId, jobId, decisions }) { + const changes = decisions.map((d) => ({ + change_id: d.change_id, + approved: !!d.approved, + ...(d.feedback ? { feedback: d.feedback } : {}), + })); + return sdFetch(`/v1/chat/${encodeURIComponent(sessionId)}/approve`, { + method: "POST", + apiKey, + body: { + job_id: jobId, + approved: true, + changes, + }, + }); +} + +async function continueJob({ apiKey, sessionId, jobId, shouldContinue }) { + return sdFetch(`/v1/chat/${encodeURIComponent(sessionId)}/continue`, { + method: "POST", + apiKey, + body: { job_id: jobId, continue: !!shouldContinue }, + }); +} + +async function exportPdf({ apiKey, sessionId, html, filename = "confluence-export" }) { + const res = await fetch(`${DEFAULT_BASE}/v1/documents/export`, { + method: "POST", + headers: { + Authorization: `Bearer ${apiKey}`, + "Content-Type": "application/json", + }, + body: JSON.stringify({ + session_id: html ? undefined : sessionId, + html: html || undefined, + format: "pdf", + options: { filename, paper_size: "A4", margins: "normal" }, + }), + }); + if (!res.ok) { + const text = await res.text(); + throw new Error(`Export failed ${res.status}: ${text.slice(0, 400)}`); + } + const buf = Buffer.from(await res.arrayBuffer()); + return { + filename: `${filename}.pdf`, + contentType: res.headers.get("content-type") || "application/pdf", + base64: buf.toString("base64"), + bytes: buf.length, + }; +} + +const HOUSE_STRUCTURE_PROMPT = `Normalise this Confluence page to the house structure below. +Keep every fact that is already in the page. Do not invent owners, dates, metrics, or systems. +Do not rewrite or remove blocks marked as preserved (tables, code, macros). +Use these headings, in this order, and move existing sentences under the right heading: + +#{err || "Loading page…"}
+ v{ctx.page.version} + {ctx.page.demo ? " · not writing to Confluence yet" : " · writes back to the wiki page"} + {" · "} + review: {ctx.review?.status || "draft"} + {!ctx.hasSuperDocsKey ? " · missing SUPERDOCS_API_KEY" : ""} +
++ House structure is applied one page at a time. Nothing is bulk-overwritten. + Open a page, review diffs, then move to the next. +
+