mirror of
https://github.com/overleaf/overleaf.git
synced 2024-09-16 02:52:31 -04:00
4b9aa97ea1
Migrations: tag migrations with relevant environment GitOrigin-RevId: ad6c3bea19d3c21a1fdae58e09c861a3173c792b
42 lines
1.1 KiB
JavaScript
42 lines
1.1 KiB
JavaScript
/* eslint-disable no-unused-vars */
|
|
|
|
exports.tags = ['server-ce', 'server-pro', 'saas']
|
|
|
|
async function removeDuplicates(collection, field) {
|
|
const duplicates = await collection.aggregate(
|
|
[
|
|
{
|
|
$group: {
|
|
_id: { projectId: `$deleterData.${field}` },
|
|
dups: { $addToSet: '$_id' },
|
|
count: { $sum: 1 },
|
|
},
|
|
},
|
|
{ $match: { count: { $gt: 1 } } },
|
|
],
|
|
{ allowDiskUse: true }
|
|
)
|
|
let duplicate
|
|
while ((duplicate = await duplicates.next())) {
|
|
// find duplicate items, ignore the most recent and delete the rest
|
|
const items = await collection
|
|
.find(
|
|
{ _id: { $in: duplicate.dups } },
|
|
{ projection: { _id: 1 }, sort: { 'deleterData.deletedAt': -1 } }
|
|
)
|
|
.toArray()
|
|
items.pop()
|
|
const ids = items.map(item => item._id)
|
|
await collection.deleteMany({ _id: { $in: ids } })
|
|
}
|
|
}
|
|
|
|
exports.migrate = async client => {
|
|
const { db } = client
|
|
await removeDuplicates(db.deletedProjects, 'deletedProjectId')
|
|
await removeDuplicates(db.deletedUsers, 'deletedUserId')
|
|
}
|
|
|
|
exports.rollback = async client => {
|
|
// can't really do anything here
|
|
}
|