ENG-1000 Sync nodes causing jank (#515)

* move from async to backend for queries

* merge conflict fix

Author: sid597

apps/roam/src/components/DiscourseContextOverlay.tsx

@@ -39,8 +39,7 @@ const getOverlayInfo = async (tag: string): Promise<DiscourseData> => {
         nodes,
         relations,
       }),
-      // @ts-ignore - backend to be added to roamjs-components
-      window.roamAlphaAPI.data.async.q(
+      window.roamAlphaAPI.data.backend.q(
         `[:find ?a :where [?b :node/title "${normalizePageTitle(tag)}"] [?a :block/refs ?b]]`,
       ),
     ]);

apps/roam/src/utils/getAllDiscourseNodesSince.ts

@@ -90,10 +90,8 @@ export const getAllDiscourseNodesSince = async (
     [(> ?nodeEditTime ?since)]
 ]`;
 
-  //@ts-ignore - backend to be added to roamjs-components
-  const allNodes = (await window.roamAlphaAPI.data.async.q(
-    query,
-    sinceMs,
+  const allNodes = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(query, sinceMs),
   )) as unknown as RoamDiscourseNodeData[];
 
   const discourseNodes = getDiscourseNodes();

apps/roam/src/utils/hyde.ts

@@ -348,57 +348,61 @@ export const findSimilarNodesUsingHyde = async ({
 };
 
 export const getAllPageByUidAsync = async (): Promise<[string, string][]> => {
-  // @ts-ignore - backend to be added to roamjs-components
-  const pages = (await window.roamAlphaAPI.data.async.q(
-    "[:find ?pageName ?pageUid :where [?e :node/title ?pageName] [?e :block/uid ?pageUid]]",
+  const pages = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(
+      "[:find ?pageName ?pageUid :where [?e :node/title ?pageName] [?e :block/uid ?pageUid]]",
+    ),
   )) as [string, string][];
   return pages;
 };
 
-const extractPagesFromChildBlock = async (
+export const extractPagesFromChildBlock = async (
   tag: string,
 ): Promise<{ uid: string; text: string }[]> => {
-  // @ts-ignore - backend to be added to roamjs-components
-  const results = (await window.roamAlphaAPI.data.async.q(
-    `[:find ?uid ?title
+  const results = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(
+      `[:find ?uid ?title
       :where [?b :node/title "${normalizePageTitle(tag)}"]
         [?a :block/refs ?b]
         [?p :block/children ?a]
         [?p :block/refs ?rf]
         [?rf :block/uid ?uid]
         [?rf :node/title ?title]]]`,
+    ),
   )) as Array<[string, string]>;
   return results.map(([uid, title]) => ({ uid, text: title }));
 };
 
-const extractPagesFromParentBlock = async (
+export const extractPagesFromParentBlock = async (
   tag: string,
 ): Promise<{ uid: string; text: string }[]> => {
-  // @ts-ignore - backend to be added to roamjs-components
-  const results = (await window.roamAlphaAPI.data.async.q(
-    `[:find ?uid ?title
+  const results = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(
+      `[:find ?uid ?title
       :where [?b :node/title "${normalizePageTitle(tag)}"]
         [?a :block/refs ?b]
         [?p :block/parents ?a]
         [?p :block/refs ?rf]
         [?rf :block/uid ?uid]
         [?rf :node/title ?title]]]`,
+    ),
   )) as Array<[string, string]>;
   return results.map(([uid, title]) => ({ uid, text: title }));
 };
 
-const getAllReferencesOnPage = async (
+export const getAllReferencesOnPage = async (
   pageTitle: string,
 ): Promise<{ uid: string; text: string }[]> => {
-  // @ts-ignore - backend to be added to roamjs-components
-  const referencedPages = (await window.roamAlphaAPI.data.async.q(
-    `[:find ?uid ?text
+  const referencedPages = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(
+      `[:find ?uid ?text
       :where
         [?page :node/title "${normalizePageTitle(pageTitle)}"]
         [?b :block/page ?page]
         [?b :block/refs ?refPage]
         [?refPage :block/uid ?uid]
         [?refPage :node/title ?text]]`,
+    ),
   )) as Array<[string, string]>;
   return referencedPages.map(([uid, text]) => ({ uid, text }));
 };

apps/roam/src/utils/syncDgNodesToSupabase.ts

@@ -18,7 +18,6 @@ import {
 } from "./conceptConversion";
 import { fetchEmbeddingsForNodes } from "./upsertNodesAsContentWithEmbeddings";
 import { convertRoamNodeToLocalContent } from "./upsertNodesAsContentWithEmbeddings";
-import { getRoamUrl } from "roamjs-components/dom";
 import { render as renderToast } from "roamjs-components/components/Toast";
 import { createClient, type DGSupabaseClient } from "@repo/database/lib/client";
 import type { Json, CompositeTypes, Enums } from "@repo/database/dbTypes";
@@ -178,9 +177,9 @@ const upsertNodeSchemaToContent = async ({
 
   ]
   `;
-  const result = (await window.roamAlphaAPI.data.async.q(
-    query,
-    nodeTypesUids,
+
+  const result = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(query, nodeTypesUids),
   )) as unknown as RoamDiscourseNodeData[];
 
   const contentData: LocalContentDataInput[] = convertRoamNodeToLocalContent({
@@ -329,8 +328,9 @@ const getAllUsers = async (): Promise<AccountLocalInput[]> => {
     [?user-eid :user/uid ?author_local_id]
     [(get-else $ ?user-eid :user/display-name "") ?author_name]
 ]`;
-  //@ts-ignore - backend to be added to roamjs-components
-  const result = (await window.roamAlphaAPI.data.async.q(query)) as unknown as {
+  const result = (await Promise.resolve(
+    window.roamAlphaAPI.data.backend.q(query),
+  )) as unknown as {
     author_local_id: string;
     name: string;
   }[];