fix(db): honor DATABASE_URL schema for pg Pool and PrismaPg

node-postgres ignores Prisma's ?schema= query param, so connections
defaulted to public. Parse the schema from the URL, set search_path on
the pool, and pass schema to PrismaPg (see prisma/prisma#28611).

Made-with: Cursor

.env.example

@@ -9,5 +9,5 @@ DATABASE_URL="postgresql://kord:password@localhost:5432/kord_db?schema=public"
 # Logging (log4js — file only under LOG_DIR, no console appender)
 # Levels: trace, debug, info, warn, error, fatal
 LOG_LEVEL=info
-# Daily log files; keep 7 rotated days (see logger.ts)
+# Daily log files; keep 7 rotated days (see logger.ts). Directory is created at startup if missing.
 LOG_DIR=logs

src/database/index.ts

@@ -1,11 +1,36 @@
+import type { PoolConfig } from 'pg';
 import { Pool } from 'pg';
 import { PrismaPg } from '@prisma/adapter-pg';
 import { PrismaClient } from '@prisma/client';
+import { env } from '../config/env';
 import { logger } from '../utils/logger';
 
-// Prisma 7 requires a driver adapter for direct database connections.
+/**
-const pool = new Pool({ connectionString: process.env.DATABASE_URL });
+ * `?schema=` in DATABASE_URL is a Prisma URL extension. node-postgres does not apply it,
-const adapter = new PrismaPg(pool);
+ * so connections default to `search_path=public`. PrismaPg also needs an explicit schema
+ * option in some setups (see prisma/prisma#28611).
+ */
+function createPgPoolConfig(connectionString: string): { poolConfig: PoolConfig; prismaSchema?: string } {
+  if (!connectionString) {
+    return { poolConfig: { connectionString: '' } };
+  }
+  try {
+    const url = new URL(connectionString);
+    const schema = url.searchParams.get('schema')?.trim();
+    const poolConfig: PoolConfig = { connectionString };
+    if (schema) {
+      const escaped = schema.replace(/"/g, '""');
+      poolConfig.options = `-c search_path="${escaped}"`;
+    }
+    return { poolConfig, prismaSchema: schema || undefined };
+  } catch {
+    return { poolConfig: { connectionString } };
+  }
+}
+
+const { poolConfig, prismaSchema } = createPgPoolConfig(env.DATABASE_URL);
+const pool = new Pool(poolConfig);
+const adapter = prismaSchema ? new PrismaPg(pool, { schema: prismaSchema }) : new PrismaPg(pool);
 
 export const prisma = new PrismaClient({
   adapter,

src/utils/logger.ts

@@ -14,10 +14,20 @@ function resolveLogLevel(): LogLevel {
   return (LOG_LEVELS as readonly string[]).includes(raw) ? (raw as LogLevel) : 'info';
 }
 
-const logDir = resolve(process.env.LOG_DIR || 'logs');
+function ensureLogDir(dir: string): void {
+  try {
+    mkdirSync(dir, { recursive: true });
+  } catch (err) {
+    const msg = err instanceof Error ? err.message : String(err);
+    process.stderr.write(`[kord] Failed to create LOG_DIR "${dir}": ${msg}\n`);
+    throw err;
+  }
+}
+
+const logDir = resolve((process.env.LOG_DIR || 'logs').trim());
 const level = resolveLogLevel();
 
-mkdirSync(logDir, { recursive: true });
+ensureLogDir(logDir);
 
 log4js.configure({
   appenders: {