-
Notifications
You must be signed in to change notification settings - Fork 70
/
migration.js
81 lines (73 loc) · 2.15 KB
/
migration.js
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
const dotenvExt = require('dotenv-extended');
const fs = require('fs');
const path = require('path');
let isLocal = false;
dotenvExt.load({
path: path.join(process.env.INIT_CWD ?? '.', '.env'),
defaults: path.join(process.env.INIT_CWD ?? '.', '.env.defaults'),
errorOnMissing: false,
includeProcessEnv: true,
});
const type = 'WORKFLOW';
try {
if (fs.existsSync('.infolder')) {
isLocal = true;
}
} catch (err) {
console.info('\n');
}
if (isLocal) {
console.info(`Skipping migrations`);
} else if (
!(process.env[`${type}_MIGRATION`] || process.env.SOURCELOOP_MIGRATION)
) {
console.warn(
`${type}_MIGRATION or SOURCELOOP_MIGRATION variables not found in the environment, skipping automigration.`,
);
} else {
const DBMigrate = require('db-migrate');
dotenvExt.load({
schema: path.join('.', 'migrations', '.env.schema'),
path: path.join(process.env.INIT_CWD, '.env'),
errorOnMissing: true,
includeProcessEnv: true,
});
const dbmigrate = DBMigrate.getInstance(true);
dbmigrate.up();
}
if (
process.env.SOURCELOOP_MIGRATION_COPY ||
process.env[`${type}_MIGRATION_COPY`]
) {
copyFolderRecursiveSync(path.join('.', 'migrations'), process.env.INIT_CWD);
}
function copyFileSync(source, target) {
let targetFile = target;
// If target is a directory, a new file with the same name will be created
if (fs.existsSync(target)) {
if (fs.lstatSync(target).isDirectory()) {
targetFile = path.join(target, path.basename(source));
}
}
fs.writeFileSync(targetFile, fs.readFileSync(source));
}
function copyFolderRecursiveSync(source, target) {
let files = [];
// Check if folder needs to be created or integrated
const targetFolder = path.join(target, path.basename(source));
if (!fs.existsSync(targetFolder)) {
fs.mkdirSync(targetFolder);
}
// Copy
if (fs.lstatSync(source).isDirectory()) {
files = fs.readdirSync(source);
files.forEach(function (file) {
const curSource = path.join(source, file);
if (fs.lstatSync(curSource).isDirectory()) {
copyFolderRecursiveSync(curSource, targetFolder);
} else {
copyFileSync(curSource, targetFolder);
}
});
}
}