1 files changed, 46 insertions, 0 deletions

diff --git a/src/internal-server/start/migrate.js b/src/internal-server/start/migrate.js
new file mode 100644
index 000000000..c27e07bc5
--- /dev/null
+++ b/src/internal-server/start/migrate.js
@@ -0,0 +1,46 @@
+const { ferdiVersion } = require('../../environment');
+
+/**
+ * Migrate server database to work with current Ferdi version
+ */
+const Database = use('Database');
+const User = use('App/Models/User');
+
+const migrateLog = (text) => {
+  console.log('\x1b[36m%s\x1b[0m', 'Ferdi Migration:', '\x1b[0m', text);
+};
+
+module.exports = async () => {
+  migrateLog('🧙‍  Running database migration wizard');
+
+  // Make sure user table exists
+  await Database.raw('CREATE TABLE IF NOT EXISTS `users` (`id` integer not null primary key autoincrement, `settings` text, `created_at` datetime, `updated_at` datetime);');
+
+  const user = await User.find(1);
+  let settings;
+  if (!user) {
+    migrateLog('🎩  Migrating from old Ferdi version as user doesn\'t exist');
+
+    // Create new user
+    await Database.raw('INSERT INTO  "users" ("id") VALUES (\'1\');');
+  } else {
+    settings = typeof user.settings === 'string' ? JSON.parse(user.settings) : user.settings;
+  }
+
+  if (!settings || !settings.db_version || settings.db_version !== ferdiVersion) {
+    const srcVersion = settings && settings.db_version ? settings.db_version : '5.4.0-beta.2';
+    migrateLog(`🔮  Migrating table from ${srcVersion} to ${ferdiVersion}`);
+
+    // Migrate database to current Ferdi version
+    // Currently no migrations
+
+    // Update version number in database
+    if (!settings) settings = {};
+    settings.db_version = ferdiVersion;
+    const newUser = await User.find(1); // Fetch user again as we might have only just created it
+    newUser.settings = JSON.stringify(settings);
+    await newUser.save();
+  } else {
+    migrateLog('🔧  Nothing to migrate, already on the newest version');
+  }
+};