Add MongoDB and PostgreSQL support to StandaloneStack driver detection

Author: hotlong

examples/app-crm/e2e/_acceptance.ts

@@ -63,5 +63,56 @@ export function runDriverAcceptance(opts: { label: string; baseURL?: string }) {
 
       await ctx.dispose();
     });
+
+    test('analytics aggregate returns measure values per dimension', async () => {
+      // Regression guard for a 3-layer bug where:
+      //   1. engine.aggregate() called driver.find() instead of driver.aggregate(),
+      //      so groupBy / aggregations were silently ignored.
+      //   2. resolveMeasure() did not accept `${field}_${type}` aliases (e.g.
+      //      'amount_sum' for measure 'amount' of type 'sum'), so the measure
+      //      was dropped from the SELECT.
+      // Without this test the failure mode is silent (200 OK, rows present,
+      // but every row is missing the measure value), and dashboard charts
+      // render empty axes with no bars.
+      const ctx = await request.newContext({ baseURL: BASE_URL });
+
+      const grouped = await ctx.post('/api/v1/analytics/query', {
+        data: {
+          cube: 'opportunity',
+          measures: ['amount_sum'],
+          dimensions: ['stage'],
+        },
+      });
+      expect(grouped.ok()).toBe(true);
+      const groupedBody = await grouped.json();
+      const groupedRows: Array<Record<string, unknown>> =
+        groupedBody?.data?.rows ?? groupedBody?.rows ?? [];
+      expect(groupedRows.length).toBeGreaterThan(0);
+      for (const row of groupedRows) {
+        expect(row).toHaveProperty('stage');
+        expect(typeof row.amount_sum).toBe('number');
+        expect(row.amount_sum as number).toBeGreaterThan(0);
+      }
+
+      const total = await ctx.post('/api/v1/analytics/query', {
+        data: {
+          cube: 'opportunity',
+          measures: ['amount_sum'],
+        },
+      });
+      expect(total.ok()).toBe(true);
+      const totalBody = await total.json();
+      const totalRows: Array<Record<string, unknown>> =
+        totalBody?.data?.rows ?? totalBody?.rows ?? [];
+      expect(totalRows).toHaveLength(1);
+      expect(typeof totalRows[0].amount_sum).toBe('number');
+      const groupedSum = groupedRows.reduce(
+        (acc, r) => acc + ((r.amount_sum as number) || 0),
+        0,
+      );
+      expect(totalRows[0].amount_sum).toBe(groupedSum);
+
+      await ctx.dispose();
+    });
   });
 }

examples/app-crm/package.json

@@ -23,7 +23,9 @@
     "@objectstack/spec": "workspace:*",
     "@objectstack/runtime": "workspace:*",
     "@objectstack/service-analytics": "workspace:*",
-    "@objectstack/service-automation": "workspace:*"
+    "@objectstack/service-automation": "workspace:*",
+    "@objectstack/driver-mongodb": "workspace:*",
+    "pg": "^8.13.1"
   },
   "devDependencies": {
     "@objectstack/cli": "workspace:*",

packages/runtime/package.json

@@ -28,6 +28,7 @@
   },
   "devDependencies": {
     "@objectstack/driver-memory": "workspace:*",
+    "@objectstack/driver-mongodb": "workspace:*",
     "@objectstack/driver-sql": "workspace:*",
     "@objectstack/driver-turso": "workspace:*",
     "@objectstack/metadata": "workspace:*",

packages/runtime/src/standalone-stack.ts

@@ -8,10 +8,16 @@
  * artifact is available. No authentication, no Studio data, no control
  * plane — REST routes are served unauthenticated.
  *
- * Auto-detects the appropriate driver from the database URL:
+ * Auto-detects the appropriate driver from the database URL scheme:
  *   - `memory://*`              → InMemoryDriver
  *   - `libsql://`, `https://`   → TursoDriver
- *   - `file:` / anything else   → SqlDriver (better-sqlite3)
+ *   - `postgres[ql]://`, `pg://` → SqlDriver (pg)
+ *   - `mongodb[+srv]://`        → MongoDBDriver (peer-dep `@objectstack/driver-mongodb`)
+ *   - `file:` / no scheme       → SqlDriver (better-sqlite3)
+ *
+ * Unknown URL schemes throw — we never silently fall back to sqlite, since
+ * that historically created bogus directories on disk (e.g. `mongodb:/`)
+ * when an unsupported URL was treated as a file path.
  */
 
 import { resolve as resolvePath } from 'node:path';
@@ -22,7 +28,7 @@ import { z } from 'zod';
 export const StandaloneStackConfigSchema = z.object({
     databaseUrl: z.string().optional(),
     databaseAuthToken: z.string().optional(),
-    databaseDriver: z.enum(['sqlite', 'turso', 'memory', 'postgres']).optional(),
+    databaseDriver: z.enum(['sqlite', 'turso', 'memory', 'postgres', 'mongodb']).optional(),
     projectId: z.string().optional(),
     artifactPath: z.string().optional(),
 });
@@ -34,6 +40,22 @@ export interface StandaloneStackResult {
     api: { enableProjectScoping: false; projectResolution: 'none' };
 }
 
+type ResolvedDriverKind = 'memory' | 'turso' | 'postgres' | 'mongodb' | 'sqlite';
+
+function detectDriverFromUrl(dbUrl: string): ResolvedDriverKind {
+    if (/^memory:\/\//i.test(dbUrl)) return 'memory';
+    if (/^(libsql|https?):\/\//i.test(dbUrl)) return 'turso';
+    if (/^(postgres(ql)?|pg):\/\//i.test(dbUrl)) return 'postgres';
+    if (/^mongodb(\+srv)?:\/\//i.test(dbUrl)) return 'mongodb';
+    if (/^file:/i.test(dbUrl)) return 'sqlite';
+    // Bare path without a scheme — treat as a sqlite file path.
+    if (!/^[a-z][a-z0-9+.-]*:\/\//i.test(dbUrl)) return 'sqlite';
+    throw new Error(
+        `[StandaloneStack] Unsupported database URL scheme: ${dbUrl}. ` +
+        `Supported schemes: memory://, libsql://, https://, postgres://, pg://, mongodb://, mongodb+srv://, file:`
+    );
+}
+
 export async function createStandaloneStack(config?: StandaloneStackConfig): Promise<StandaloneStackResult> {
     const cfg = StandaloneStackConfigSchema.parse(config ?? {});
 
@@ -55,22 +77,51 @@ export async function createStandaloneStack(config?: StandaloneStackConfig): Pro
     const dbAuthToken = cfg.databaseAuthToken
         ?? process.env.OS_DATABASE_AUTH_TOKEN?.trim()
         ?? process.env.TURSO_AUTH_TOKEN?.trim();
-    const dbDriver = cfg.databaseDriver
-        ?? process.env.OS_DATABASE_DRIVER?.trim()
-        ?? (/^(libsql|https?):\/\//i.test(dbUrl) ? 'turso' : 'sqlite');
+    const explicitDriver = cfg.databaseDriver
+        ?? (process.env.OS_DATABASE_DRIVER?.trim() as ResolvedDriverKind | undefined);
+    const dbDriver: ResolvedDriverKind = explicitDriver ?? detectDriverFromUrl(dbUrl);
 
     let driverPlugin: any;
-    if (dbDriver === 'memory' || dbUrl.startsWith('memory://')) {
+    if (dbDriver === 'memory') {
         const { InMemoryDriver } = await import('@objectstack/driver-memory');
         driverPlugin = new DriverPlugin(new InMemoryDriver());
-    } else if (dbDriver === 'turso' || /^(libsql|https?):\/\//i.test(dbUrl)) {
+    } else if (dbDriver === 'turso') {
         const { TursoDriver } = await import('@objectstack/driver-turso');
         driverPlugin = new DriverPlugin(
             new TursoDriver({ url: dbUrl, authToken: dbAuthToken }) as any,
         );
+    } else if (dbDriver === 'postgres') {
+        const { SqlDriver } = await import('@objectstack/driver-sql');
+        driverPlugin = new DriverPlugin(
+            new SqlDriver({
+                client: 'pg',
+                connection: dbUrl,
+                pool: { min: 0, max: 5 },
+            }) as any,
+        );
+    } else if (dbDriver === 'mongodb') {
+        // MongoDB driver is an optional peer dependency. Importing it lazily
+        // avoids forcing every standalone consumer to install the mongo SDK.
+        let MongoDBDriver: any;
+        try {
+            ({ MongoDBDriver } = await import('@objectstack/driver-mongodb' as any));
+        } catch (err: any) {
+            throw new Error(
+                `[StandaloneStack] mongodb URL detected but @objectstack/driver-mongodb is not installed. ` +
+                `Add it as a dependency or pass an explicit driverPlugin. (${err?.message ?? err})`
+            );
+        }
+        driverPlugin = new DriverPlugin(new MongoDBDriver({ url: dbUrl }) as any);
     } else {
+        // sqlite
         const { SqlDriver } = await import('@objectstack/driver-sql');
         const filename = dbUrl.replace(/^file:(\/\/)?/, '');
+        if (!filename || /^[a-z][a-z0-9+.-]*:\/\//i.test(filename)) {
+            throw new Error(
+                `[StandaloneStack] sqlite driver was selected but the URL does not look like a file path: "${dbUrl}". ` +
+                `Use file:/path/to/db.sqlite, or set OS_DATABASE_DRIVER explicitly.`
+            );
+        }
         mkdirSync(resolvePath(filename, '..'), { recursive: true });
         driverPlugin = new DriverPlugin(
             new SqlDriver({