zoriya/Kyoo
1
0
Fork 0
mirror of https://github.com/zoriya/Kyoo.git synced 2025-12-06 06:36:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add a trace for api migrations

Browse Source
This commit is contained in:
Zoe Roux
2025-11-24 17:31:46 +01:00
parent 3a0cbf786d
commit d822463fe0
1 changed files with 18 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

34
api/src/db/index.ts
View File

@@ -7,6 +7,7 @@ import { drizzle } from "drizzle-orm/node-postgres";
import { migrate as migrateDb } from "drizzle-orm/node-postgres/migrator";
import type { PoolConfig } from "pg";
import * as schema from "./schema";
import { record } from "@elysiajs/opentelemetry";
const config: PoolConfig = {
connectionString: process.env.POSTGRES_URL,
@@ -112,7 +113,6 @@ const postgresConfig = await parseSslConfig();
// use this when using drizzle-kit since it can't parse await statements
// const postgresConfig = config;
console.log("Connecting to postgres with config", postgresConfig);
export const db = drizzle({
schema,
connection: postgresConfig,
@@ -123,22 +123,24 @@ instrumentDrizzleClient(db, {
});
export const migrate = async () => {
try {
await db.execute(
sql.raw(`
create extension if not exists pg_trgm;
set pg_trgm.word_similarity_threshold = 0.4;
alter database "${postgresConfig.database}" set pg_trgm.word_similarity_threshold = 0.4;
`),
);
} catch (err: any) {
console.error("Error while updating pg_trgm", err.message);
}
await migrateDb(db, {
migrationsSchema: "kyoo",
migrationsFolder: "./drizzle",
return record("migrate", async () => {
try {
await db.execute(
sql.raw(`
create extension if not exists pg_trgm;
set pg_trgm.word_similarity_threshold = 0.4;
alter database "${postgresConfig.database}" set pg_trgm.word_similarity_threshold = 0.4;
`),
);
} catch (err: any) {
console.error("Error while updating pg_trgm", err.message);
}
await migrateDb(db, {
migrationsSchema: "kyoo",
migrationsFolder: "./drizzle",
});
console.log(`Database ${postgresConfig.database} migrated!`);
});
console.log(`Database ${postgresConfig.database} migrated!`);
};
export type Transaction =