Mirrors/unleash.unleash
1
0
Fork 0
mirror of https://github.com/Unleash/unleash.git synced 2025-01-11 00:08:30 +01:00
Code Issues Projects Releases Wiki Activity

fix: migrate only users without any role

Browse Source
This commit is contained in:
Ivar Conradi Østhus 2021-04-28 12:56:19 +02:00
parent 6c57aeb232
commit 65fad95c6f
No known key found for this signature in database
GPG Key ID: 31AC596886B0BD09
1 changed files with 20 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
src/migrations/20210428062103-user-permission-to-rbac.js
View File

@ -2,8 +2,8 @@
const async = require('async'); const async = require('async');
function resolveRoleName(permissions = []) { function resolveRoleName(permissions) {
if (permissions.length === 0) { if (!permissions || permissions.length === 0) {
return 'Viewer'; return 'Viewer';
} }
if (permissions.includes('ADMIN')) { if (permissions.includes('ADMIN')) {
@ -13,24 +13,27 @@ function resolveRoleName(permissions = []) {
} }
exports.up = function(db, cb) { exports.up = function(db, cb) {
db.runSql(`SELECT id, permissions from users;`, (err, results) => { db.runSql(
if (results.rowCount > 0) { `SELECT id, permissions from users WHERE id NOT IN (select user_id from role_user);`,
const users = results.rows; (err, results) => {
const insertRootRole = users.map(u => { if (results.rowCount > 0) {
const roleName = resolveRoleName(u.permissions); const users = results.rows;
return db.runSql.bind( const insertRootRole = users.map(u => {
db, const roleName = resolveRoleName(u.permissions);
`INSERT INTO role_user (role_id, user_id) return db.runSql.bind(
db,
`INSERT INTO role_user (role_id, user_id)
SELECT id, '${u.id}' SELECT id, '${u.id}'
FROM roles FROM roles
WHERE name = '${roleName}' AND type = 'root';`, WHERE name = '${roleName}' AND type = 'root';`,
); );
}); });
async.series(insertRootRole, cb); async.series(insertRootRole, cb);
} else { } else {
cb(); cb();
} }
}); },
);
}; };
exports.down = function(db, cb) { exports.down = function(db, cb) {