'use strict';

var async = require('async');

var ADMIN_GROUP_ID = 'admin'; // see constants.js

exports.up = function(db, callback) {
	async.series([
		db.runSql.bind(db, 'START TRANSACTION;'),
		db.runSql.bind(db, 'INSERT INTO userGroups (id, name) VALUES (?, ?)', [ ADMIN_GROUP_ID, 'admin' ]),
		function migrateAdminFlag(done) {
			db.all('SELECT * FROM users WHERE admin=1', function (error, results) {
				if (error) return done(error);

				async.eachSeries(results, function (r, next) {
					db.runSql('INSERT INTO groupMembers (groupId, userId) VALUES (?, ?)', [ ADMIN_GROUP_ID, r.id ], next);
				}, done);
			});
		},
		db.runSql.bind(db, 'ALTER TABLE users DROP COLUMN admin'),
		db.runSql.bind(db, 'COMMIT')
	], callback);
};

exports.down = function(db, callback) {
    callback();
};