fix: use DATABASE_SCHEMA as single source of truth for DBOS schema name

The MCP listRuns/getRun/getTrace tools were resolving the DBOS schema
via getSchemaName(getAppName()), which reads package.json from cwd and
falls back to "crayon_dbos". On cloud machines the MCP server's cwd
often lacks the right package.json, causing queries against the wrong
schema and returning empty results.

Now all paths (runtime, CLI, MCP tools) read DATABASE_SCHEMA from .env
via getDbosSchema(). Removed the redundant getSchemaName() helper and
made DBOSConfig.appName required.

Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>

Author: cevian

packages/core/src/__tests__/dbos.test.ts

@@ -13,14 +13,15 @@ vi.mock("@dbos-inc/dbos-sdk", () => ({
 describe("DBOS integration", () => {
   beforeEach(() => {
     vi.clearAllMocks();
+    process.env.DATABASE_SCHEMA = "test";
   });
 
   describe("initializeDBOS()", () => {
     it("configures and launches DBOS with database URL", async () => {
       const { DBOS } = await import("@dbos-inc/dbos-sdk");
       const { initializeDBOS } = await import("../dbos.js");
 
-      await initializeDBOS({ databaseUrl: "postgres://localhost/test" });
+      await initializeDBOS({ databaseUrl: "postgres://localhost/test", appName: "test" });
 
       expect(DBOS.setConfig).toHaveBeenCalledWith(
         expect.objectContaining({

packages/core/src/__tests__/factory.test.ts

@@ -25,6 +25,7 @@ vi.mock("@dbos-inc/dbos-sdk", () => ({
 describe("createCrayon()", () => {
   beforeEach(() => {
     vi.clearAllMocks();
+    process.env.DATABASE_SCHEMA = "test";
     // Clear globalThis singleton so each test gets a fresh createCrayon()
     delete (globalThis as Record<symbol, unknown>)[Symbol.for("crayon.crayonInstance")];
     // Clear workflow cache so Workflow.create() re-registers

packages/core/src/__tests__/integration.e2e.test.ts

@@ -9,7 +9,7 @@ import { createCrayon, Workflow, Node, type Crayon } from "../index.js";
 
 const DATABASE_URL = process.env.DATABASE_URL;
 
-// Schema used by tests (must match default from getSchemaName())
+// Schema used by tests (must match DATABASE_SCHEMA env or getDbosSchema())
 const TEST_SCHEMA = "crayon_dbos";
 
 async function resetDatabase(): Promise<void> {
@@ -99,6 +99,7 @@ describe.skipIf(!DATABASE_URL)("crayon e2e", () => {
   let crayon: Crayon;
 
   beforeAll(async () => {
+    process.env.DATABASE_SCHEMA = "crayon";
     // Drop DBOS schema for clean test state
     await resetDatabase();
 

packages/core/src/__tests__/integration.test.ts

@@ -86,6 +86,7 @@ describe.skipIf(!DATABASE_URL)("crayon integration", () => {
   let crayon: Crayon;
 
   beforeAll(async () => {
+    process.env.DATABASE_SCHEMA = "integration_test";
     await resetDatabase();
 
     crayon = await createCrayon({

packages/core/src/cli/__tests__/runs.test.ts

@@ -44,6 +44,7 @@ describe.skipIf(!DATABASE_URL)("runs", () => {
   let crayon: Crayon;
 
   beforeAll(async () => {
+    process.env.DATABASE_SCHEMA = TEST_APP_NAME;
     await resetDatabase();
 
     crayon = await createCrayon({

packages/core/src/cli/app.ts

@@ -59,3 +59,10 @@ export function getAppSchema(projectRoot?: string): string {
     );
   }
 }
+
+/**
+ * Get the DBOS system schema name (e.g. "my_app_dbos") from DATABASE_SCHEMA.
+ */
+export function getDbosSchema(projectRoot?: string): string {
+  return `${getAppSchema(projectRoot)}_dbos`;
+}

packages/core/src/cli/runs.ts

@@ -1,7 +1,6 @@
 // packages/cli/src/runs.ts
 import pg from "pg";
-import { getSchemaName } from "../index.js";
-import { getAppName } from "./app.js";
+import { getDbosSchema } from "./app.js";
 
 export interface WorkflowRun {
   workflow_uuid: string;
@@ -27,7 +26,7 @@ export async function listRuns(
   options: ListRunsOptions = {}
 ): Promise<WorkflowRun[]> {
   const { limit = 20, workflowName, schema: schemaOverride } = options;
-  const schema = schemaOverride ?? getSchemaName(getAppName());
+  const schema = schemaOverride ?? getDbosSchema();
   const client = new pg.Client({ connectionString: databaseUrl });
 
   await client.connect();
@@ -69,7 +68,7 @@ export async function getRun(
   runId: string,
   schemaOverride?: string
 ): Promise<GetRunResult> {
-  const schema = schemaOverride ?? getSchemaName(getAppName());
+  const schema = schemaOverride ?? getDbosSchema();
   const client = new pg.Client({ connectionString: databaseUrl });
 
   await client.connect();

packages/core/src/cli/trace.ts

@@ -1,8 +1,7 @@
 // packages/cli/src/trace.ts
 import pg from "pg";
 import pc from "picocolors";
-import { getSchemaName } from "../index.js";
-import { getAppName } from "./app.js";
+import { getDbosSchema } from "./app.js";
 import { getRun, type WorkflowRun } from "./runs.js";
 
 export interface WorkflowTrace extends WorkflowRun {
@@ -56,7 +55,7 @@ async function getTraceData(
   workflowUuid: string,
   schemaOverride?: string
 ): Promise<TraceResult> {
-  const schema = schemaOverride ?? getSchemaName(getAppName());
+  const schema = schemaOverride ?? getDbosSchema();
   const client = new pg.Client({ connectionString: databaseUrl });
 
   await client.connect();

packages/core/src/dbos.ts

@@ -1,26 +1,20 @@
 // packages/core/src/dbos.ts
 import { DBOS } from "@dbos-inc/dbos-sdk";
+import { getDbosSchema } from "./cli/app.js";
 
 export interface DBOSConfig {
   databaseUrl: string;
-  appName?: string;
-}
-
-/** Get the schema name for a given app */
-export function getSchemaName(appName?: string): string {
-  const name = appName ?? "crayon";
-  // Convert to valid schema name: lowercase, replace non-alphanumeric with underscore
-  return `${name.toLowerCase().replace(/[^a-z0-9]/g, "_")}_dbos`;
+  appName: string;
 }
 
 /**
  * Initialize DBOS with the given configuration
  */
 export async function initializeDBOS(config: DBOSConfig): Promise<void> {
   DBOS.setConfig({
-    name: config.appName ?? "crayon",
+    name: config.appName,
     systemDatabaseUrl: config.databaseUrl,
-    systemDatabaseSchemaName: getSchemaName(config.appName),
+    systemDatabaseSchemaName: getDbosSchema(),
     logLevel: process.env.LOG_LEVEL ?? "info",
   });
   await DBOS.launch();

packages/core/src/index.ts

@@ -4,7 +4,6 @@ export const VERSION = "0.1.0";
 
 // Factory
 export { createCrayon } from "./factory.js";
-export { getSchemaName } from "./dbos.js";
 
 // Discovery (CLI / non-bundled environments)
 export { discover } from "./discover.js";