${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..7804450 --- /dev/null +++ b/extensions/jaskiringg/confluence-ai/src/lib/confluence.js @@ -0,0 +1,209 @@ +const fs = require("fs"); +const path = require("path"); + +const DEMO_PAGE_ID = "demo-page"; +const DEMO_SPACE_ID = "demo-space"; + +function loadDemoAdf() { + const p = path.join(__dirname, "../../fixtures/demo-page.adf.json"); + return JSON.parse(fs.readFileSync(p, "utf8")); +} + +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); +} + +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; +} + +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 (!confluenceConfigured(env) || String(pageId).startsWith("demo")) { + 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 cfFetch( + 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 (!confluenceConfigured(env) || String(pageId).startsWith("demo")) { + return { + id: DEMO_PAGE_ID, + title, + version: { number: (versionNumber || 1) + 1, message }, + demo: true, + adf, + }; + } + return cfFetch(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 (!confluenceConfigured(env) || 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 cfFetch( + 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, + })); +} + +async function searchUsers(env, query) { + if (!confluenceConfigured(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())); + } + const data = await cfFetch( + env, + `/wiki/rest/api/search/user?cql=${encodeURIComponent(`user.fullname~"${query}"`)}&limit=10` + ); + return (data.results || []).map((r) => ({ + accountId: r.user?.accountId, + displayName: r.user?.displayName, + email: r.user?.email, + })); +} + +const PROPERTY_KEY = "superdocs-review"; + +async function getReviewState(env, pageId, memory) { + if (memory.has(pageId)) return memory.get(pageId); + if (!confluenceConfigured(env) || pageId === DEMO_PAGE_ID) { + return { status: "draft" }; + } + try { + const data = await cfFetch( + 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 (!confluenceConfigured(env) || pageId === DEMO_PAGE_ID) return value; + try { + await cfFetch( + env, + `/wiki/rest/api/content/${encodeURIComponent(pageId)}/property/${PROPERTY_KEY}`, + { method: "PUT", body: { key: PROPERTY_KEY, value } } + ); + } catch { + await cfFetch( + 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 ? " · demo page (sidecar)" : ""} + {" · "} + 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. +
+