m/umami
1
0
Fork 0
mirror of https://github.com/kremalicious/umami.git synced 2025-02-14 21:10:34 +01:00
Code Issues Packages Projects Releases Wiki Activity

roll back check/update

Browse Source
This commit is contained in:
Brian Cao 2022-08-21 23:47:11 -07:00
parent 207c1224ed
commit 0066e8dbcb
2 changed files with 0 additions and 104 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
scripts/check-db.js
View File

@ -65,9 +65,6 @@ async function checkMigrations() {
console.log(output); console.log(output);
var x = await prisma.$queryRaw`select * from _prisma_migrations`;
console.log(x);
const missingMigrations = output.includes('have not yet been applied'); const missingMigrations = output.includes('have not yet been applied');
const missingInitialMigration = const missingInitialMigration =
output.includes('01_init') && !output.includes('The last common migration is: 01_init'); output.includes('01_init') && !output.includes('The last common migration is: 01_init');

101
scripts/update-db.js
View File

@ -1,101 +0,0 @@
require('dotenv').config();
const { PrismaClient } = require('@prisma/client');
const chalk = require('chalk');
const spawn = require('cross-spawn');
const { execSync } = require('child_process');
const prisma = new PrismaClient();
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.');
}
}
async function checkConnection() {
try {
await prisma.$connect();
success('Database connection successful.');
} catch (e) {
throw new Error('Unable to connect to the database.');
}
}
async function checkTables() {
try {
await prisma.account.findFirst();
success('Database tables found.');
} catch (e) {
error('Database tables not found.');
console.log('Adding tables...');
console.log(execSync('prisma migrate deploy').toString());
}
}
async function run(cmd, args) {
const buffer = [];
const proc = spawn(cmd, args);
return new Promise((resolve, reject) => {
proc.stdout.on('data', data => buffer.push(data));
proc.on('error', () => {
reject(new Error('Failed to run Prisma.'));
});
proc.on('exit', () => resolve(buffer.join('')));
});
}
async function checkMigrations() {
const output = await run('prisma', ['migrate', 'status']);
console.log(output);
const missingMigrations = output.includes('have not yet been applied');
const missingInitialMigration =
output.includes('01_init') && !output.includes('The last common migration is: 01_init');
const notManaged = output.includes('The current database is not managed');
if (notManaged || missingMigrations) {
console.log('Running update...');
if (missingInitialMigration) {
console.log(execSync('prisma migrate resolve --applied "01_init"').toString());
}
console.log(execSync('prisma migrate deploy').toString());
}
success('Database is up to date.');
}
(async () => {
let err = false;
for (let fn of [checkEnv, checkConnection, checkTables, checkMigrations]) {
try {
await fn();
} catch (e) {
console.log(chalk.red(`✗ ${e.message}`));
err = true;
} finally {
await prisma.$disconnect();
if (err) {
process.exit(1);
}
}
}
})();