implement file upload via plugin

server/index.js

@@ -2,6 +2,7 @@ const express = require("express");
 const path = require("path");
 const config = require("./config");
 const { setupWebSocket } = require("./ws");
+const { installPluginInAllVaults } = require("./install-plugin");
 
 const ANSI_RED = "\x1b[31m";
 const ANSI_YELLOW = "\x1b[33m";
@@ -73,10 +74,12 @@ app.use(express.static(path.join(__dirname, "..", "dist")));
 
 app.use(express.static(config.obsidianAssetsPath));
 
-const server = app.listen(config.port, () => {
+const server = app.listen(config.port, async () => {
   console.log(`[ignis] Server running on http://localhost:${config.port}`);
   console.log(`[ignis] Vault root: ${config.vaultRoot}`);
   console.log(`[ignis] Vaults: ${Object.keys(config.vaults).join(", ")}`);
+
+  await installPluginInAllVaults(config.vaultRoot);
 });
 
 setupWebSocket(server);

server/install-plugin.js

@@ -0,0 +1,65 @@
+const fs = require("fs");
+const path = require("path");
+
+async function installPluginInVault(vaultPath) {
+  const obsidianDir = path.join(vaultPath, ".obsidian");
+  const pluginDir = path.join(obsidianDir, "plugins", "ignis-bridge");
+
+  if (!(await fs.promises.stat(obsidianDir).catch(() => null))) {
+    return false;
+  }
+
+  if (!(await fs.promises.stat(pluginDir).catch(() => null))) {
+    await fs.promises.mkdir(pluginDir, { recursive: true });
+
+    const pluginSrcDir = path.join(__dirname, "..", "plugin");
+    await fs.promises.copyFile(
+      path.join(pluginSrcDir, "manifest.json"),
+      path.join(pluginDir, "manifest.json"),
+    );
+    await fs.promises.copyFile(
+      path.join(pluginSrcDir, "main.js"),
+      path.join(pluginDir, "main.js"),
+    );
+  }
+
+  const pluginsConfig = path.join(obsidianDir, "community-plugins.json");
+  let plugins = [];
+
+  if (await fs.promises.stat(pluginsConfig).catch(() => null)) {
+    try {
+      plugins = JSON.parse(await fs.promises.readFile(pluginsConfig, "utf8"));
+    } catch (e) {
+      plugins = [];
+    }
+  }
+
+  if (!plugins.includes("ignis-bridge")) {
+    plugins.push("ignis-bridge");
+    await fs.promises.writeFile(pluginsConfig, JSON.stringify(plugins));
+    return true;
+  }
+
+  return false;
+}
+
+async function installPluginInAllVaults(vaultRoot) {
+  if (!(await fs.promises.stat(vaultRoot).catch(() => null))) {
+    return;
+  }
+
+  const entries = await fs.promises.readdir(vaultRoot, { withFileTypes: true });
+
+  for (const entry of entries) {
+    if (entry.isDirectory()) {
+      const vaultPath = path.join(vaultRoot, entry.name);
+      const installed = await installPluginInVault(vaultPath);
+
+      if (installed) {
+        console.log(`[ignis] Installed plugin in vault: ${entry.name}`);
+      }
+    }
+  }
+}
+
+module.exports = { installPluginInVault, installPluginInAllVaults };

server/routes/vault.js

@@ -52,6 +52,31 @@ router.post("/create", async (req, res) => {
       recursive: false,
     });
 
+    // Install ignis-bridge plugin
+    const pluginDir = path.join(
+      vaultPath,
+      ".obsidian",
+      "plugins",
+      "ignis-bridge",
+    );
+    await fs.promises.mkdir(pluginDir, { recursive: true });
+
+    const pluginSrcDir = path.join(__dirname, "..", "..", "plugin");
+    await fs.promises.copyFile(
+      path.join(pluginSrcDir, "manifest.json"),
+      path.join(pluginDir, "manifest.json"),
+    );
+    await fs.promises.copyFile(
+      path.join(pluginSrcDir, "main.js"),
+      path.join(pluginDir, "main.js"),
+    );
+
+    // Enable the plugin
+    await fs.promises.writeFile(
+      path.join(vaultPath, ".obsidian", "community-plugins.json"),
+      JSON.stringify(["ignis-bridge"]),
+    );
+
     config.refreshVaults();
 
     res.json({ ok: true, id: name, path: vaultPath });