From 2d4119c40e2484a4e8a3ab251bbf98e1463ec57d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Gerg=C5=91=20Jedlicska?= Date: Fri, 19 Nov 2021 12:57:00 +0100 Subject: [PATCH] refactor(server migration): code cleanup --- .../migrations/20211119105730_de_duplicate_users.js | 13 ++++--------- 1 file changed, 4 insertions(+), 9 deletions(-) diff --git a/packages/server/modules/core/migrations/20211119105730_de_duplicate_users.js b/packages/server/modules/core/migrations/20211119105730_de_duplicate_users.js index 45dc43919..023e278ea 100644 --- a/packages/server/modules/core/migrations/20211119105730_de_duplicate_users.js +++ b/packages/server/modules/core/migrations/20211119105730_de_duplicate_users.js @@ -26,15 +26,10 @@ exports.up = async ( knex ) => { [ 'stream_activity' , 'userId' ], ] - const migrateColumnValue = async( tableName, columnName, oldUser, newUser ) => { - try { - const query = knex( tableName ).where( { [columnName]: oldUser.id } ).update( { [columnName]: newUser.id } ) - console.log( `${query}` ) - await query - } catch ( err ) { - console.log( err ) - } - } + const migrateColumnValue = async( tableName, columnName, oldUser, newUser ) => + await knex( tableName ) + .where( { [columnName]: oldUser.id } ) + .update( { [columnName]: newUser.id } ) const serverAclMigration = async ( { lowerUser, upperUser } ) => { const oldAcl = await knex( 'server_acl' ).where( { userId: upperUser.id } ).first()