FOGProject/fog-too

var async = require('async');

var chalk = require('chalk');
var CLI = require('clui');
var Spinner = CLI.Spinner;

var config = require('../lib/config');
var header = require('../lib/header');

var inquire = require('./lib/inquire');
var migrations = require('./lib/migration');

var welcome = 'Welcome to the FOG schema migrator.\nYou will be guided through migrating your current database schema.'
var COMPLETED = false;
var revision;

header.print(welcome);

async.waterfall([
    function(next) {
        header.printSection("Database backup");
        inquire.getBackupInfo(function(answers) {
            if(!answers.backup && !answers.confirmBackup)
                return next('No backup');

            next();
        });
    },
    function(next) {
      header.printSection("Migration");
      var status = new Spinner('Calculating deltas...');
      var pendingText = "Deltas calculated";
      status.start();
      var didMigrate = false;
      migrations.auto(config.preferences.connections.main, function(upgrade, fromRev, toRev, description) {
        didMigrate = true;
        status.stop();
        console.log(pendingText);
        pendingText = "Revision " + fromRev + " -> " + toRev + "\t ";
        pendingText += chalk.cyan(((upgrade) ? "APPLYING: " : "REVERSING: ") + description);
        status = new Spinner(pendingText);
        status.start();
      }, function(err) {
        status.stop();
        console.log(pendingText);
        if (err) return next(err);

        if(didMigrate) {
          console.log("Migration complete");
        } else {
          console.log("No migration needed");
        }
        next();
      });
    }
], function (err, result) {
    if(err) console.log(chalk.bgRed(err));
    COMPLETED = true;
    process.exit();
});



(function wait () {
   if (!COMPLETED) setTimeout(wait, 1000);
})();