cleanup old connection before creating new tunnel — prevent duplicate integrations

Made-with: Cursor

Author: f

src/tunnel.js

@@ -1,15 +1,55 @@
 import { PokeTunnel, getToken } from "poke";
+import { readFileSync, writeFileSync, mkdirSync } from "node:fs";
+import { join } from "node:path";
+import { homedir } from "node:os";
+
+const CONFIG_DIR = process.env.XDG_CONFIG_HOME || join(homedir(), ".config");
+const STATE_PATH = join(CONFIG_DIR, "poke-gate", "state.json");
+
+function loadState() {
+  try {
+    return JSON.parse(readFileSync(STATE_PATH, "utf-8"));
+  } catch {
+    return {};
+  }
+}
+
+function saveState(state) {
+  mkdirSync(join(CONFIG_DIR, "poke-gate"), { recursive: true });
+  writeFileSync(STATE_PATH, JSON.stringify(state, null, 2));
+}
+
+async function cleanupOldConnection(apiKey) {
+  const state = loadState();
+  if (!state.connectionId) return;
+
+  const token = getToken() || apiKey;
+  const base = process.env.POKE_API ?? "https://poke.com/api/v1";
+
+  try {
+    await fetch(`${base}/mcp/connections/${state.connectionId}`, {
+      method: "DELETE",
+      headers: { Authorization: `Bearer ${token}` },
+    });
+  } catch {}
+}
 
 export async function startTunnel({ apiKey, mcpUrl, onEvent }) {
+  await cleanupOldConnection(apiKey);
+
   const token = getToken();
 
   const tunnel = new PokeTunnel({
     url: mcpUrl,
     name: "poke-gate",
     token: token || apiKey,
+    cleanupOnStop: false,
   });
 
-  tunnel.on("connected", (info) => onEvent("connected", info));
+  tunnel.on("connected", (info) => {
+    saveState({ connectionId: info.connectionId });
+    onEvent("connected", info);
+  });
   tunnel.on("disconnected", () => onEvent("disconnected"));
   tunnel.on("error", (err) => onEvent("error", err.message));
   tunnel.on("toolsSynced", ({ toolCount }) => onEvent("tools-synced", toolCount));