ENG-1285 Base user affordance to trigger node sharing (#698)

* eng-1285 base user affordance and base publish

Author: maparent

apps/obsidian/src/utils/publishNode.ts

@@ -0,0 +1,46 @@
+import type { FrontMatterCache, TFile } from "obsidian";
+import type { default as DiscourseGraphPlugin } from "~/index";
+import { getLoggedInClient, getSupabaseContext } from "./supabaseContext";
+
+export const publishNode = async ({
+  plugin,
+  file,
+  frontmatter,
+}: {
+  plugin: DiscourseGraphPlugin;
+  file: TFile;
+  frontmatter: FrontMatterCache;
+}): Promise<void> => {
+  const nodeId = frontmatter.nodeInstanceId as string | undefined;
+  if (!nodeId) throw new Error("Please sync the node first");
+  const client = await getLoggedInClient(plugin);
+  if (!client) throw new Error("Cannot get client");
+  const context = await getSupabaseContext(plugin);
+  if (!context) throw new Error("Cannot get context");
+  const spaceId = context.spaceId;
+  const myGroupResponse = await client
+    .from("group_membership")
+    .select("group_id");
+  if (myGroupResponse.error) throw myGroupResponse.error;
+  const myGroup = myGroupResponse.data[0]?.group_id;
+  if (!myGroup) throw new Error("Cannot get group");
+  const existingPublish =
+    (frontmatter.publishedToGroups as undefined | string[]) || [];
+  if (existingPublish.includes(myGroup)) return; // already published
+  const publishResponse = await client.from("ResourceAccess").insert({
+    /* eslint-disable @typescript-eslint/naming-convention */
+    account_uid: myGroup,
+    source_local_id: nodeId,
+    space_id: spaceId,
+    /* eslint-enable @typescript-eslint/naming-convention */
+  });
+  if (publishResponse.error && publishResponse.error.code !== "23505")
+    // 23505 is duplicate key, which counts as a success.
+    throw publishResponse.error;
+  await plugin.app.fileManager.processFrontMatter(
+    file,
+    (fm: Record<string, unknown>) => {
+      fm.publishedToGroups = [...existingPublish, myGroup];
+    },
+  );
+};

apps/obsidian/src/utils/registerCommands.ts

@@ -1,4 +1,4 @@
-import { Editor } from "obsidian";
+import { Editor, MarkdownView, Notice } from "obsidian";
 import type DiscourseGraphPlugin from "~/index";
 import { NodeTypeModal } from "~/components/NodeTypeModal";
 import ModifyNodeModal from "~/components/ModifyNodeModal";
@@ -7,7 +7,7 @@ import { createDiscourseNode } from "./createNode";
 import { VIEW_TYPE_MARKDOWN, VIEW_TYPE_TLDRAW_DG_PREVIEW } from "~/constants";
 import { createCanvas } from "~/components/canvas/utils/tldraw";
 import { createOrUpdateDiscourseEmbedding } from "./syncDgNodesToSupabase";
-import { Notice } from "obsidian";
+import { publishNode } from "./publishNode";
 
 export const registerCommands = (plugin: DiscourseGraphPlugin) => {
   plugin.addCommand({
@@ -156,4 +156,43 @@ export const registerCommands = (plugin: DiscourseGraphPlugin) => {
       return true;
     },
   });
+  plugin.addCommand({
+    id: "publish-discourse-node",
+    name: "Publish current node to lab space",
+    checkCallback: (checking: boolean) => {
+      if (!plugin.settings.syncModeEnabled) {
+        new Notice("Sync mode is not enabled", 3000);
+        return false;
+      }
+      const activeView = plugin.app.workspace.getActiveViewOfType(MarkdownView);
+      if (!activeView || !activeView.file) {
+        return false;
+      }
+      const file = activeView.file;
+      const cache = plugin.app.metadataCache.getFileCache(file);
+      const frontmatter = cache?.frontmatter || {};
+      if (!frontmatter.nodeTypeId) {
+        return false;
+      }
+      if (!checking) {
+        if (!frontmatter.nodeInstanceId) {
+          new Notice("Please sync the node first");
+          return true;
+        }
+        // TODO (in follow-up PRs):
+        // Maybe sync the node now if unsynced
+        // Ensure that the node schema is synced to the database, and shared
+        // sync the assets to the database
+        publishNode({ plugin, file, frontmatter })
+          .then(() => {
+            new Notice("Published");
+          })
+          .catch((error: Error) => {
+            new Notice(error.message);
+            console.error(error);
+          });
+      }
+      return true;
+    },
+  });
 };