changing who and latestChangeBy field from ldapUid to user mongo ID, …

…migration script included relates #429

scripts/migration/migrateEditLogWho.js

@@ -0,0 +1,76 @@
+const models = require('../../server/lib/model')
+const {EditLog} = require('../../server/lib/edit-logs')
+const async = require('async')
+const _ = require('lodash')
+
+console.log('starting migration')
+models.connect()
+
+async.waterfall([
+	next => {
+		// get mongoid ldapuid index
+		models.People.aggregate([{$match:{ldapUid:{$ne:null}}},{$project:{_id:1, ldapUid:1}}]).then(data => {
+			console.log(data.length)
+			return next(null, data)
+	})
+	},
+	(data,next) => {
+		// update edtilogs
+		async.parallelLimit(
+			data.map(e => (nextParallel) => EditLog.updateMany(
+				{who:e.ldapUid},
+				{who:e._id},
+				(error,cursor) => nextParallel(null, cursor.modifiedCount))),
+			100,
+			(err, counts) => {
+				console.log(`wrote ${_.sum(counts)} modifications on editLogs`)
+				return next(null, data)
+			})
+	},
+	(data,next) => {
+		// update edtilogs
+		async.parallelLimit(
+			data.map(e => (nextParallel) => models.People.updateMany(
+				{latestChangeBy:e.ldapUid},
+				{latestChangeBy:e._id},
+				(error,cursor) => nextParallel(null, cursor.modifiedCount))),
+			100,
+			(err, counts) => {
+				console.log(`wrote ${_.sum(counts)} modifications on People`)
+				return next(null, data)
+			})
+	},
+	(data,next) => {
+		// update edtilogs
+		async.parallelLimit(
+			data.map(e => (nextParallel) => models.Organization.updateMany(
+				{latestChangeBy:e.ldapUid},
+				{latestChangeBy:e._id},
+				(error,cursor) => nextParallel(null, cursor.modifiedCount))),
+			100,
+			(err, counts) => {
+				console.log(`wrote ${_.sum(counts)} modifications on People`)
+				return next(null, data)
+			})
+	},
+	(data,next) => {
+		// update edtilogs
+		async.parallelLimit(
+			data.map(e => (nextParallel) => models.Activity.updateMany(
+				{latestChangeBy:e.ldapUid},
+				{latestChangeBy:e._id},
+				(error,cursor) => nextParallel(null, cursor.modifiedCount))),
+			100,
+			(err, counts) => {
+				console.log(`wrote ${_.sum(counts)} modifications on Activity`)
+				return next(null)
+			})
+	}
+],error => {
+	if (error){
+		console.log(error)
+		process.exit(1);
+	}
+	process.exit(0);
+})
+

server/lib/rest-utils.js

@@ -225,7 +225,7 @@ const replaceModel = (Model, save, getPermissions) => {
 		}
 
 		// Delete
-		doc.latestChangeBy = req.session.login // sign for EditLogs
+		doc.latestChangeBy = req.userId // sign for EditLogs
 		debug('Save', Model.modelName, doc)
 		return save(doc, perms)
 	}))
@@ -234,7 +234,7 @@ const replaceModel = (Model, save, getPermissions) => {
 const createModel = (Model, save, getPermissions) => (req, res) => Promise.resolve()
 	.then(() => new Model(removeEmptyFields(req.body)))
 	.then(doc => getPermissions(req, doc).then(perms => {
-		doc.latestChangeBy = req.session.login // sign for EditLogs
+		doc.latestChangeBy = req.userId // sign for EditLogs
 		return save(doc, perms)
 	}))
 	.then(saved => {
@@ -270,7 +270,7 @@ const deleteModel = (Model, getPermissions) => {
 			if (hasRelations)
 				return Promise.reject(ClientError({ status: 403, message: 'Target still has relations' }))
 
-			doc.latestChangeBy = req.session.login
+			doc.latestChangeBy = req.userId
 			return doc.remove()
 		})
 		.then(() => {