blob: 68374f6f57917edc374687818de0e74e8244206e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
|
/* eslint-disable no-console */
import 'dotenv/config';
import { execSync } from 'node:child_process';
import { PrismaPg } from '@prisma/adapter-pg';
import chalk from 'chalk';
import semver from 'semver';
import { PrismaClient } from '../generated/prisma/client.js';
const MIN_VERSION = '9.4.0';
if (process.env.SKIP_DB_CHECK) {
console.log('Skipping database check.');
process.exit(0);
}
const url = new URL(process.env.DATABASE_URL);
const adapter = new PrismaPg(
{ connectionString: url.toString() },
{ schema: url.searchParams.get('schema') },
);
const prisma = new PrismaClient({ adapter });
function success(msg) {
console.log(chalk.greenBright(`✓ ${msg}`));
}
function error(msg) {
console.log(chalk.redBright(`✗ ${msg}`));
}
async function checkEnv() {
if (!process.env.DATABASE_URL) {
throw new Error('DATABASE_URL is not defined.');
} else {
success('DATABASE_URL is defined.');
}
if (process.env.REDIS_URL) {
success('REDIS_URL is defined.');
}
}
async function checkConnection() {
try {
await prisma.$connect();
success('Database connection successful.');
} catch (e) {
throw new Error('Unable to connect to the database: ' + e.message);
}
}
async function checkDatabaseVersion() {
const query = await prisma.$queryRaw`select version() as version`;
const version = semver.valid(semver.coerce(query[0].version));
if (semver.lt(version, MIN_VERSION)) {
throw new Error(
`Database version is not compatible. Please upgrade to ${MIN_VERSION} or greater.`,
);
}
success('Database version check successful.');
}
async function applyMigration() {
if (!process.env.SKIP_DB_MIGRATION) {
console.log(execSync('prisma migrate deploy').toString());
success('Database is up to date.');
}
}
(async () => {
let err = false;
for (const fn of [checkEnv, checkConnection, checkDatabaseVersion, applyMigration]) {
try {
await fn();
} catch (e) {
error(e.message);
err = true;
} finally {
if (err) {
process.exit(1);
}
}
}
})();
|