debug: enhance publish pipeline logging

Log live Hocuspocus document state, XmlFragment content,
full JSON structure, CSS loading, and meta to diagnose
incomplete published articles.

Made-with: Cursor

backend/src/publisher/index.ts

@@ -60,24 +60,30 @@ function extractFromYDoc(ydoc: Y.Doc): {
     frontmatter[key] = value;
   });
 
-  // Debug: list all shared types in the Y.Doc
   const sharedTypes: string[] = [];
   ydoc.share.forEach((_value, key) => sharedTypes.push(key));
   console.log("[publish] Y.Doc shared types:", sharedTypes);
   console.log("[publish] frontmatter:", JSON.stringify(frontmatter));
 
-  // Check the XmlFragment directly
   const fragment = ydoc.getXmlFragment("default");
   console.log("[publish] XmlFragment 'default' length:", fragment.length);
+  if (fragment.length > 0) {
+    console.log("[publish] XmlFragment first child tag:", fragment.toArray()[0]?.constructor?.name);
+  }
 
-  // Convert Y.XmlFragment -> ProseMirror JSON using TipTap extensions
   const extensions = getServerExtensions();
   const json = TiptapTransformer
     .extensions(extensions)
     .fromYdoc(ydoc, "default");
 
   console.log("[publish] TiptapTransformer result type:", json?.type);
-  console.log("[publish] TiptapTransformer content count:", Array.isArray((json as any)?.content) ? (json as any).content.length : "N/A");
+  const contentArr = (json as any)?.content;
+  console.log("[publish] TiptapTransformer content count:", Array.isArray(contentArr) ? contentArr.length : "N/A");
+  if (Array.isArray(contentArr) && contentArr.length > 0) {
+    const types = contentArr.slice(0, 10).map((n: any) => n.type);
+    console.log("[publish] First 10 node types:", types);
+  }
+  console.log("[publish] Full JSON (truncated):", JSON.stringify(json).slice(0, 2000));
 
   if (json && typeof json === "object" && json.type === "doc") {
     return { json, frontmatter };
@@ -126,11 +132,12 @@ export async function publishDocument(docName: string, token?: string): Promise<
     date: (frontmatter.date as string) || new Date().toISOString(),
   };
 
-  // Load CSS
   const css = loadCSS();
+  console.log("[publish] CSS tokens length:", css.tokens.length, "article length:", css.article.length);
+  console.log("[publish] Meta:", JSON.stringify(meta));
 
-  // Generate HTML
   const html = renderArticleHTML(json, meta, css.tokens, css.article);
+  console.log("[publish] Generated HTML length:", html.length);
 
   // Generate PDF + thumbnail
   let pdf: Buffer | null = null;

backend/src/server.ts

@@ -181,13 +181,19 @@ app.post("/api/publish", async (req, res) => {
   }
 
   try {
-    // Flush live Hocuspocus document to disk so the publisher can read it
     const conn = await hocuspocus.openDirectConnection(DEFAULT_DOC_NAME);
     if (conn.document) {
-      writeFileSync(
-        docPath(DEFAULT_DOC_NAME),
-        Buffer.from(Y.encodeStateAsUpdate(conn.document)),
-      );
+      const liveTypes: string[] = [];
+      conn.document.share.forEach((_v, k) => liveTypes.push(k));
+      console.log("[publish] Live Hocuspocus doc shared types:", liveTypes);
+      const liveFragment = conn.document.getXmlFragment("default");
+      console.log("[publish] Live XmlFragment length:", liveFragment.length);
+
+      const update = Y.encodeStateAsUpdate(conn.document);
+      console.log("[publish] Encoded state size:", update.byteLength, "bytes");
+      writeFileSync(docPath(DEFAULT_DOC_NAME), Buffer.from(update));
+    } else {
+      console.warn("[publish] openDirectConnection returned no document");
     }
     await conn.disconnect();