Durable mcp

mcp-studio/package.json

@@ -5,7 +5,7 @@
   "private": true,
   "type": "module",
   "scripts": {
-    "dev": "bun run --hot server/main.ts",
+    "dev": "PORT=8002 bun run --hot server/main.ts",
     "configure": "deco configure",
     "gen": "deco gen --output=shared/deco.gen.ts",
     "check": "tsc --noEmit",
@@ -14,40 +14,40 @@
     "publish": "cat app.json | deco registry publish -w /shared/deco -y"
   },
   "dependencies": {
-    "@decocms/bindings": "1.0.1-alpha.26",
-    "@decocms/runtime": "1.0.0-alpha.31",
+    "@ai-sdk/mcp": "^1.0.1",
+    "@decocms/bindings": "file:../../mesh/packages/bindings",
+    "@decocms/runtime": "file:../../mesh/packages/runtime",
+    "@jitl/quickjs-wasmfile-release-sync": "^0.31.0",
+    "@modelcontextprotocol/sdk": "^1.25.1",
     "@radix-ui/react-collapsible": "^1.1.12",
     "@radix-ui/react-popover": "^1.1.15",
     "@radix-ui/react-slot": "^1.2.3",
     "@tailwindcss/vite": "^4.0.6",
     "@tanstack/react-query": "^5.66.5",
     "@tanstack/react-router": "^1.121.2",
     "@tanstack/react-router-devtools": "^1.121.2",
+    "@types/prettier": "^3.0.0",
     "class-variance-authority": "^0.7.1",
     "clsx": "^2.1.1",
     "lucide-react": "^0.554.0",
     "next-themes": "^0.4.6",
+    "prettier": "^3.7.3",
+    "quickjs-emscripten": "^0.31.0",
+    "quickjs-emscripten-core": "^0.31.0",
     "react": "^19.0.0",
     "react-dom": "^19.0.0",
     "sonner": "^2.0.7",
+    "sucrase": "^3.35.0",
     "tailwind-merge": "^3.0.2",
     "tailwindcss": "^4.0.6",
     "tailwindcss-animate": "^1.0.7",
     "zod": "^3.24.3"
   },
   "devDependencies": {
-    "@decocms/vite-plugin": "1.0.0-alpha.1",
-    "@modelcontextprotocol/sdk": "1.20.2",
-    "@types/mime-db": "^1.43.6",
-    "@types/react": "^19.0.8",
-    "@types/react-dom": "^19.0.3",
-    "@vitejs/plugin-react": "^5.1.1",
-    "concurrently": "^9.2.0",
     "deco-cli": "^0.28.0",
-    "typescript": "^5.7.2",
-    "vite": "7.2.0"
+    "typescript": "^5.7.2"
   },
   "engines": {
     "node": ">=22.0.0"
   }
-}
+}

mcp-studio/server/db/index.ts

@@ -0,0 +1,60 @@
+import { runSQL } from "./postgres.ts";
+import { postgresQueries } from "./schemas/workflow.ts";
+import type { Env } from "../types/env.ts";
+
+/**
+ * Collection queries for database table creation.
+ *
+ * Note: Only 'agents' and 'workflows' are true collections with MCP tools.
+ * 'workflow_execution', 'workflow_execution_step_result', and 'workflow_event'
+ * are internal engine tables managed by direct database functions.
+ */
+const collectionsQueries = {
+  workflow_collections: {
+    idempotent: postgresQueries.workflowCollectionTableIdempotentQuery,
+    indexes: postgresQueries.workflowCollectionTableIndexesQuery,
+  },
+  workflows: {
+    idempotent: postgresQueries.workflowTableIdempotentQuery,
+    indexes: postgresQueries.workflowTableIndexesQuery,
+  },
+  // Internal engine tables (not collections, no MCP tools)
+  workflow_executions: {
+    idempotent: postgresQueries.workflowExecutionTableIdempotentQuery,
+    indexes: postgresQueries.workflowExecutionTableIndexesQuery,
+  },
+  execution_step_results: {
+    idempotent: postgresQueries.executionStepResultsTableIdempotentQuery,
+    indexes: postgresQueries.executionStepResultsTableIndexesQuery,
+  },
+  workflow_events: {
+    idempotent: postgresQueries.workflowEventsTableIdempotentQuery,
+    indexes: postgresQueries.workflowEventsTableIndexesQuery,
+  },
+};
+
+async function ensureCollections(env: Env) {
+  for (const collection of Object.values(collectionsQueries)) {
+    try {
+      await runSQL(env, collection.idempotent);
+    } catch (error) {
+      console.error(
+        `Error ensuring collection ${collection.idempotent}`,
+        error,
+      );
+      throw error;
+    }
+  }
+}
+
+async function ensureIndexes(env: Env) {
+  for (const collection of Object.values(collectionsQueries)) {
+    try {
+      await runSQL(env, collection.indexes);
+    } catch (error) {
+      console.error(`Error ensuring indexes ${collection.indexes}`, error);
+    }
+  }
+}
+
+export { collectionsQueries, ensureCollections, ensureIndexes };

mcp-studio/server/db/postgres.ts

@@ -0,0 +1,26 @@
+/**
+ * PostgreSQL Database Module
+ *
+ * Generic SQL runner using the DATABASE binding.
+ */
+
+import type { Env } from "../types/env.ts";
+
+/**
+ * Run a SQL query using the DATABASE binding
+ * @param env - The environment containing the DATABASE binding
+ * @param sql - SQL query with ? placeholders
+ * @param params - Parameters to substitute for ? placeholders
+ * @returns The query results as an array of rows
+ */
+export async function runSQL<T = unknown>(
+  env: Env,
+  sql: string,
+  params: unknown[] = [],
+): Promise<T[]> {
+  const response = await env.DATABASE.DATABASES_RUN_SQL({
+    sql,
+    params,
+  });
+  return (response.result[0]?.results ?? []) as T[];
+}