rootandClaude Fable 5.1
304feea141
- root deno.json workspace (nodeModulesDir auto), npm versions registered once in imports, deno.lock; remove pnpm-lock/pnpm-workspace/root package.json; members keep minimal package.json (name/type/exports) - tasks: dev, typecheck (tsc 7.0.2 per member + deno check), lint/fmt (biome, useImportExtensions), test (vitest via deno), check:tokens, build (web + deno compile), ci, db:migrate/reset, gen:types - tsconfig base moved to config/ (no root tsconfig.json); deno types -> types/deno.d.ts; web drops baseUrl - server: Deno.serve entry with graceful shutdown, --role migrate|preflight|probe, WEB_ROOT static SPA hosting; drop @hono/node-server, tsx, esbuild build.mjs - logger: redact child() bindings and serialize err by message/stack; sync stdout destination; tests - relative imports get explicit extensions (sites/mp-sync paths left for follow-up) - crash-recovery tests spawn `deno run -A`; tasks tests use unique per-file schemas - single-container Dockerfile + entrypoint (migrate -> preflight -> api+worker watchdog), docker-compose.yml - docs: README, runbook, ADR-001 superseded, plan §1 validation row Co-Authored-By: Claude Fable 5.1 <[email protected]>
27 lines
1.1 KiB
TypeScript
27 lines
1.1 KiB
TypeScript
import { Kysely, PostgresDialect } from "kysely";
|
|
import pg from "pg";
|
|
import type { DB } from "./types.ts";
|
|
|
|
// int8 → number(大小/序号都在 2^53 内;超出即报错而不是静默丢精度)
|
|
pg.types.setTypeParser(pg.types.builtins.INT8, (v: string) => {
|
|
const n = Number(v);
|
|
if (!Number.isSafeInteger(n)) throw new RangeError(`int8 超出安全整数范围: ${v}`);
|
|
return n;
|
|
});
|
|
// date → 原样 'YYYY-MM-DD' 字符串,避免按本地时区转成 Date 造成日期漂移
|
|
pg.types.setTypeParser(pg.types.builtins.DATE, (v: string) => v);
|
|
|
|
export interface CreateDbOptions {
|
|
/** 默认读 process.env.DATABASE_URL */
|
|
connectionString?: string;
|
|
max?: number;
|
|
}
|
|
|
|
/** 创建带连接池的 Kysely 实例;调用方负责在退出时 db.destroy() */
|
|
export function createDb(opts: CreateDbOptions = {}): Kysely<DB> {
|
|
const connectionString = opts.connectionString ?? process.env.DATABASE_URL;
|
|
if (!connectionString) throw new Error("DATABASE_URL 未设置");
|
|
const pool = new pg.Pool({ connectionString, max: opts.max ?? 10 });
|
|
return new Kysely<DB>({ dialect: new PostgresDialect({ pool }) });
|
|
}
|