Files
WeHub Mirror 6bf8bebf51
CI / Test and Build (push) Failing after 1s
CI / Migrate Dev DB (push) Has been skipped
CI / Migrate DB (push) Has been skipped
CodeQL / Analyze actions (push) Has been cancelled
CodeQL / Analyze javascript-typescript (push) Has been cancelled
CI / Detect Version (push) Has been cancelled
CI / Detect Desktop Changes (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/cron.Dockerfile, ubuntu-latest, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build AMD64 (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build AMD64 (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build AMD64 (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/cron.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/db.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/pii.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-4vcpu-ubuntu-2404-arm, ./docker/realtime.Dockerfile, ubuntu-24.04-arm, ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build ARM64 (GHCR Only) (blacksmith-8vcpu-ubuntu-2404-arm, ./docker/app.Dockerfile, linux-arm64-8-core, ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Check Docs Changes (push) Has been cancelled
Publish CLI Package / publish-npm (push) Has been cancelled
Publish Python SDK / publish-pypi (push) Has been cancelled
CI / Deploy Trigger.dev (Dev) (push) Has been cancelled
Helm Chart / Lint, test, and validate chart (push) Has been cancelled
Helm Chart / Chart version bumped (push) Has been cancelled
Publish TypeScript SDK / publish-npm (push) Has been cancelled
CI / Build Dev ECR (blacksmith-8vcpu-ubuntu-2404, ./docker/app.Dockerfile, ECR_APP, linux-x64-8-core) (push) Has been cancelled
CI / Promote Images (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/cron) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/migrations) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/pii) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/realtime) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-2vcpu-ubuntu-2404, ./docker/db.Dockerfile, ECR_MIGRATIONS, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/pii.Dockerfile, ECR_PII, ubuntu-latest) (push) Has been cancelled
CI / Build Dev ECR (blacksmith-4vcpu-ubuntu-2404, ./docker/realtime.Dockerfile, ECR_REALTIME, ubuntu-latest) (push) Has been cancelled
CI / Create GHCR Manifests (ghcr.io/simstudioai/simstudio) (push) Has been cancelled
CI / Process Docs (push) Has been cancelled
CI / Create GitHub Release (push) Has been cancelled
CI / Check Desktop Signing Secrets (push) Has been cancelled
CI / Desktop Release (push) Has been cancelled
CI / Create Desktop Prerelease (push) Has been cancelled
CI / Desktop Prerelease Build (push) Has been cancelled
CI / Publish Desktop Prerelease (push) Has been cancelled
CI / Prune Desktop Prereleases (push) Has been cancelled
Helm Chart / Install on kind and run helm test (push) Has been cancelled
WeHub snapshot of cb28d14c6f2c081de7a0d8729a8c816c9adef67a
2026-08-10 11:17:50 +08:00

169 lines
6.6 KiB
TypeScript

import { createLogger } from '@sim/logger'
import { drizzle } from 'drizzle-orm/postgres-js'
import postgres from 'postgres'
import { resolveDbUrl } from './connection-url'
import * as schema from './schema'
import { instrumentPoolClient } from './tx-tripwire'
const logger = createLogger('Db')
/**
* Per-role pool profiles. Starting numbers — validate against real per-role
* process counts (PgBouncer transaction mode, max_connections=200).
*/
export const DB_POOL_PROFILES = {
web: { primaryMax: 10, replicaMax: 4, appName: 'sim-app' },
// 5, not 3 — one run can need 3+ simultaneous connections (parallel queries +
// overlapping logging writes); 3 risks intra-run deadlock.
trigger: { primaryMax: 5, replicaMax: 2, appName: 'sim-trigger' },
realtime: { primaryMax: 5, replicaMax: 3, appName: 'sim-realtime' },
// Sub-process pools, selected per call-site via dbFor() — never via SIM_DB_ROLE.
cleanup: { primaryMax: 5, replicaMax: 2, appName: 'sim-cleanup' },
exec: { primaryMax: 10, replicaMax: 4, appName: 'sim-exec' },
} as const
/** Roles a whole process runs as (via SIM_DB_ROLE). */
const PROCESS_ROLES = ['web', 'trigger', 'realtime'] as const
type ProcessDbRole = (typeof PROCESS_ROLES)[number]
type SubProcessDbRole = Exclude<keyof typeof DB_POOL_PROFILES, ProcessDbRole>
const roleEnv = process.env.SIM_DB_ROLE?.trim()
if (roleEnv && !PROCESS_ROLES.includes(roleEnv as ProcessDbRole)) {
throw new Error(
`Invalid SIM_DB_ROLE '${roleEnv}' — expected one of ${PROCESS_ROLES.join(', ')} (or unset for web)`
)
}
const role = (roleEnv as ProcessDbRole) || 'web'
const profile = DB_POOL_PROFILES[role]
const connectionString = resolveDbUrl('DATABASE_URL', role)
if (!connectionString) {
throw new Error('Missing DATABASE_URL environment variable')
}
/**
* `fetch_types: false` skips postgres.js's `pg_catalog.pg_type` roundtrip, which it
* otherwise runs on every new connection before that connection's first query.
*
* That roundtrip populates the array type map, which postgres.js uses in BOTH
* directions, for every array type — not just `text[]`. Disabling it has two
* consequences on every client built from these options (the primary, the replica,
* and every `dbFor()` sub-pool):
*
* 1. Reads: a raw `db.execute` projecting an array column yields the wire form
* `'{a,b}'`, not `['a','b']`. Drizzle-typed selects and `.returning()` are
* unaffected — `PgArray.mapFromDriverValue` parses the wire form itself.
* 2. Writes: a JS array bound as a SINGLE parameter fails at execution with
* `22P02 Array value must start with "{"` — there is no serializer to build the
* literal, and neither `prepare: false` nor `sql.array()` avoids it. Drizzle-typed
* column writes ARE safe (`PgArray.mapToDriverValue` stringifies first), as are
* `inArray`/`${jsArray}` in a drizzle `sql` template (both expand to scalar binds).
* Raw binds are NOT: never write `sql.param(someArray)`. Pass an expanded list
* (`IN ${ids}`) or an explicit `ARRAY[${sql.join(...)}]::text[]` of scalars.
*
* Scalar types — including `jsonb`, pgvector, enums and ranges — are unaffected.
*
* Note postgres.js's OWN `sql` tag has the opposite semantics: it binds `${array}`
* as one array parameter. `packages/db/scripts/migrate.ts` deliberately omits
* `fetch_types` for that reason; see the note there before sharing these options.
*
* Pinned by apps/sim/lib/execution/payloads/prune-metadata-sql.test.ts, which renders
* the real statements and asserts no bind parameter is an array.
*/
const poolOptions = {
prepare: false,
fetch_types: false,
idle_timeout: 20,
connect_timeout: 30,
onnotice: () => {},
connection: { application_name: process.env.DB_APP_NAME ?? profile.appName },
}
const postgresClient = instrumentPoolClient(
postgres(connectionString, { ...poolOptions, max: profile.primaryMax }),
'db'
)
export const db = drizzle(postgresClient, { schema })
/**
* Opt-in read-replica client for reads that tolerate bounded staleness and have
* no read-your-writes dependency (logs, exports, dashboard aggregations). Never
* for auth, workflow state, or billing enforcement. Falls back to the primary
* when `DATABASE_REPLICA_URL` is unset, so call sites never branch.
*/
const replicaUrl = resolveDbUrl('DATABASE_REPLICA_URL', role)
if (replicaUrl && !/^postgres(ql)?:\/\//.test(replicaUrl)) {
throw new Error(
'DATABASE_REPLICA_URL is set but is not a postgres:// DSN — fix the URL or unset the variable'
)
}
export const dbReplica: typeof db = replicaUrl
? drizzle(
instrumentPoolClient(
postgres(replicaUrl, { ...poolOptions, max: profile.replicaMax }),
'dbReplica'
),
{
schema,
}
)
: db
const subPoolClients = new Map<SubProcessDbRole, typeof db>()
/** Which env var the process connection came from — named in dbFor fallback logs. */
const processUrlEnvVar = process.env[`DATABASE_URL_${role.toUpperCase()}`]
? `DATABASE_URL_${role.toUpperCase()}`
: 'DATABASE_URL'
/**
* Per-workload drizzle client with its own pool, built lazily on first call and
* cached per role. Unlike the process-wide `db` (selected by `SIM_DB_ROLE`),
* these are selected per call-site so a workload running inside an existing
* process — cleanup jobs in the trigger worker, inline execution log writes in
* the web server — gets its own connection budget and PgBouncer pool.
*
* Resolves `DATABASE_URL_<ROLE>` with fallback to the URL the process itself
* resolved (`DATABASE_URL_<PROCESSROLE>`, then base `DATABASE_URL`), so an
* unset sub-pool URL changes nothing about where this process's traffic lands.
* Always uses the role profile's `appName` — the `DB_APP_NAME` override applies
* only to the process-wide clients.
*/
export function dbFor(role: SubProcessDbRole): typeof db {
const existing = subPoolClients.get(role)
if (existing) return existing
const keyedEnvVar = `DATABASE_URL_${role.toUpperCase()}`
const keyedUrl = process.env[keyedEnvVar]
const url = keyedUrl ?? connectionString
if (!url) {
throw new Error('Missing DATABASE_URL environment variable')
}
if (keyedUrl) {
logger.info(`'${role}' pool using dedicated ${keyedEnvVar}`)
} else {
logger.info(
`${keyedEnvVar} not set — '${role}' pool falling back to the process connection (${processUrlEnvVar})`
)
}
const subProfile = DB_POOL_PROFILES[role]
const client = drizzle(
instrumentPoolClient(
postgres(url, {
...poolOptions,
max: subProfile.primaryMax,
connection: { application_name: subProfile.appName },
}),
role
),
{ schema }
)
subPoolClients.set(role, client)
return client
}