BackFillDocNameForDeletedDocsTests.js 3.9 KB

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