BackFillDocNameForDeletedDocsTests.mjs 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. import { exec } from 'child_process'
  2. import { promisify } from 'util'
  3. import { expect } from 'chai'
  4. import logger from '@overleaf/logger'
  5. import { db, ObjectId } from '../../../app/src/infrastructure/mongodb.js'
  6. import UserHelper from './helpers/User.js'
  7. const User = UserHelper.promises
  8. async function getDeletedDocs(projectId) {
  9. return (await db.projects.findOne({ _id: projectId })).deletedDocs
  10. }
  11. async function setDeletedDocs(projectId, deletedDocs) {
  12. await db.projects.updateOne({ _id: projectId }, { $set: { deletedDocs } })
  13. }
  14. describe('BackFillDocNameForDeletedDocs', function () {
  15. let user, projectId1, projectId2, docId1, docId2, docId3
  16. beforeEach('create projects', async function () {
  17. user = new User()
  18. await user.login()
  19. projectId1 = new ObjectId(await user.createProject('project1'))
  20. projectId2 = new ObjectId(await user.createProject('project2'))
  21. })
  22. beforeEach('create docs', async function () {
  23. docId1 = new ObjectId(
  24. await user.createDocInProject(projectId1, null, 'doc1.tex')
  25. )
  26. docId2 = new ObjectId(
  27. await user.createDocInProject(projectId1, null, 'doc2.tex')
  28. )
  29. docId3 = new ObjectId(
  30. await user.createDocInProject(projectId2, null, 'doc3.tex')
  31. )
  32. })
  33. beforeEach('deleted docs', async function () {
  34. await user.deleteItemInProject(projectId1, 'doc', docId1)
  35. await user.deleteItemInProject(projectId1, 'doc', docId2)
  36. await user.deleteItemInProject(projectId2, 'doc', docId3)
  37. })
  38. beforeEach('insert doc stubs into docs collection', async function () {
  39. await db.docs.insertMany([
  40. { _id: docId1, deleted: true },
  41. { _id: docId2, deleted: true },
  42. { _id: docId3, deleted: true },
  43. ])
  44. })
  45. let deletedDocs1, deletedDocs2
  46. let deletedAt1, deletedAt2, deletedAt3
  47. beforeEach('set deletedDocs details', async function () {
  48. deletedAt1 = new Date()
  49. deletedAt2 = new Date()
  50. deletedAt3 = new Date()
  51. deletedDocs1 = [
  52. { _id: docId1, name: 'doc1.tex', deletedAt: deletedAt1 },
  53. { _id: docId2, name: 'doc2.tex', deletedAt: deletedAt2 },
  54. ]
  55. deletedDocs2 = [{ _id: docId3, name: 'doc3.tex', deletedAt: deletedAt3 }]
  56. await setDeletedDocs(projectId1, deletedDocs1)
  57. await setDeletedDocs(projectId2, deletedDocs2)
  58. })
  59. async function runScript(args = []) {
  60. let result
  61. try {
  62. result = await promisify(exec)(
  63. ['LET_USER_DOUBLE_CHECK_INPUTS_FOR=1']
  64. .concat(['node', 'scripts/back_fill_doc_name_for_deleted_docs.mjs'])
  65. .concat(args)
  66. .join(' ')
  67. )
  68. } catch (error) {
  69. // dump details like exit code, stdErr and stdOut
  70. logger.error({ error }, 'script failed')
  71. throw error
  72. }
  73. const { stderr: stdErr } = result
  74. expect(stdErr).to.include(`Completed batch ending ${projectId2}`)
  75. }
  76. function checkDocsBackFilled() {
  77. it('should back fill names and deletedAt dates into docs', async function () {
  78. const docs = await db.docs.find({}).toArray()
  79. expect(docs).to.deep.equal([
  80. { _id: docId1, deleted: true, name: 'doc1.tex', deletedAt: deletedAt1 },
  81. { _id: docId2, deleted: true, name: 'doc2.tex', deletedAt: deletedAt2 },
  82. { _id: docId3, deleted: true, name: 'doc3.tex', deletedAt: deletedAt3 },
  83. ])
  84. })
  85. }
  86. describe('back fill only', function () {
  87. beforeEach('run script', runScript)
  88. checkDocsBackFilled()
  89. it('should leave the deletedDocs as is', async function () {
  90. expect(await getDeletedDocs(projectId1)).to.deep.equal(deletedDocs1)
  91. expect(await getDeletedDocs(projectId2)).to.deep.equal(deletedDocs2)
  92. })
  93. })
  94. describe('back fill and cleanup', function () {
  95. beforeEach('run script with cleanup flag', async function () {
  96. await runScript(['--perform-cleanup'])
  97. })
  98. checkDocsBackFilled()
  99. it('should cleanup the deletedDocs', async function () {
  100. expect(await getDeletedDocs(projectId1)).to.deep.equal([])
  101. expect(await getDeletedDocs(projectId2)).to.deep.equal([])
  102. })
  103. })
  104. })