feat: copy new schema version to .history

Refs: #23

PR-URL: #25

lib/schema-db.js

@@ -3,7 +3,7 @@
 const path = require('path');
 const fs = require('fs').promises;
 
-const { isUpperCamel } = require('./utils.js');
+const { isUpperCamel, cpdir } = require('./utils.js');
 const { Schema } = require('./schema.js');
 
 class DatabaseSchema {
@@ -119,11 +119,17 @@ class DatabaseSchema {
     const folder = path.basename(ps.path);
     const date = folder.substring(0, folder.lastIndexOf('v') - 1);
     console.log(`Previous schema: v${ps.database.version} (${date})`);
+    if (ps.database.version >= version) {
+      console.log('You have latest schema version. Migration is not needed.');
+      return;
+    }
     const newFolder = path.join(this.path, `.history/${date}-v${version}`);
     const mig = path.join(this.path, `.migration/${date}-v${version}`);
     const migUp = mig + '-up.sql';
     const migDn = mig + '-dn.sql';
     console.log(`Save history: ${newFolder}`);
+    await fs.mkdir(newFolder);
+    await cpdir(this.path, newFolder);
     console.log(`Migration up: ${migUp}`);
     console.log(`Migration down: ${migDn}`);
   }

lib/utils.js

@@ -1,5 +1,8 @@
 'use strict';
 
+const path = require('path');
+const fs = require('fs').promises;
+
 const escapeIdentifier = name => `"${name}"`;
 
 const escapeKey = (key, escapeIdentifier) =>
@@ -30,6 +33,16 @@ const joinIterable = (val, sep) => {
   return res;
 };
 
+const cpdir = async (from, to) => {
+  const files = await fs.readdir(from, { withFileTypes: true });
+  for (const file of files) {
+    if (file.isDirectory()) continue;
+    const fromPath = path.join(from, file.name);
+    const toPath = path.join(to, file.name);
+    await fs.copyFile(fromPath, toPath);
+  }
+};
+
 const toLowerCamel = s => s.charAt(0).toLowerCase() + s.slice(1);
 const toUpperCamel = s => s.charAt(0).toUpperCase() + s.slice(1);
 const isUpperCamel = s => !!s && s[0] === s[0].toUpperCase();
@@ -39,6 +52,7 @@ module.exports = {
   escapeKey,
   mapJoinIterable,
   joinIterable,
+  cpdir,
   toLowerCamel,
   toUpperCamel,
   isUpperCamel,

test/schema/.history/2020-09-11-v3/.database.js

@@ -0,0 +1,25 @@
+({
+  name: 'example',
+  description: 'Example database schema',
+  version: 3,
+  driver: 'pg',
+
+  authors: [
+    { name: 'Timur Shemsedinov', email: '[email protected]' },
+  ],
+
+  extensions: [
+    'hstore',
+    'postgis',
+    'postgis_topology',
+    'pg_trgm',
+  ],
+
+  connection: {
+    host: '127.0.0.1',
+    port: 5432,
+    database: 'application',
+    user: 'postgres',
+    password: 'postgres',
+  },
+});

test/schema/.history/2020-09-11-v3/.eslintrc.json

@@ -0,0 +1,5 @@
+{
+  "parserOptions": {
+    "sourceType": "module"
+  }
+}

test/schema/.history/2020-09-11-v3/City.js

@@ -0,0 +1,4 @@
+({
+  country: 'Country',
+  name: { type: 'string', unique: true },
+});

test/schema/.history/2020-09-11-v3/Country.js

@@ -0,0 +1,4 @@
+({
+  planet: 'Planet',
+  name: { type: 'string', unique: true },
+});

test/schema/.history/2020-09-11-v3/District.js

@@ -0,0 +1,4 @@
+({
+  city: 'City',
+  name: { type: 'string', unique: true },
+});

test/schema/.history/2020-09-11-v3/Planet.js

@@ -0,0 +1,3 @@
+({
+  name: { type: 'string', unique: true },
+});