ProjectGetter.test.mjs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461
  1. import { vi, expect } from 'vitest'
  2. import sinon from 'sinon'
  3. import mongodb from 'mongodb-legacy'
  4. const modulePath = '../../../../app/src/Features/Project/ProjectGetter.mjs'
  5. const { ObjectId } = mongodb
  6. describe('ProjectGetter', function () {
  7. beforeEach(async function (ctx) {
  8. ctx.project = { _id: new ObjectId() }
  9. ctx.projectIdStr = ctx.project._id.toString()
  10. ctx.deletedProject = { deleterData: { wombat: 'potato' } }
  11. ctx.userId = new ObjectId()
  12. ctx.DeletedProject = {
  13. find: sinon.stub().returns({
  14. exec: sinon.stub().resolves([ctx.deletedProject]),
  15. }),
  16. }
  17. ctx.Project = {
  18. find: sinon.stub().returns({
  19. exec: sinon.stub().resolves(),
  20. }),
  21. findOne: sinon.stub().returns({
  22. exec: sinon.stub().resolves(ctx.project),
  23. }),
  24. }
  25. ctx.CollaboratorsGetter = {
  26. promises: {
  27. getProjectsUserIsMemberOf: sinon.stub().resolves({
  28. readAndWrite: [],
  29. readOnly: [],
  30. tokenReadAndWrite: [],
  31. tokenReadOnly: [],
  32. }),
  33. },
  34. }
  35. ctx.LockManager = {
  36. promises: {
  37. runWithLock: sinon
  38. .stub()
  39. .callsFake((namespace, id, runner) => runner()),
  40. },
  41. }
  42. ctx.db = {
  43. projects: {
  44. findOne: sinon.stub().resolves(ctx.project),
  45. },
  46. users: {},
  47. }
  48. ctx.ProjectEntityMongoUpdateHandler = {
  49. lockKey: sinon.stub().returnsArg(0),
  50. }
  51. vi.doMock('../../../../app/src/infrastructure/mongodb', () => ({
  52. db: ctx.db,
  53. ObjectId,
  54. }))
  55. vi.doMock('../../../../app/src/models/Project', () => ({
  56. Project: ctx.Project,
  57. }))
  58. vi.doMock('../../../../app/src/models/DeletedProject', () => ({
  59. DeletedProject: ctx.DeletedProject,
  60. }))
  61. vi.doMock(
  62. '../../../../app/src/Features/Collaborators/CollaboratorsGetter',
  63. () => ({
  64. default: ctx.CollaboratorsGetter,
  65. })
  66. )
  67. vi.doMock('../../../../app/src/infrastructure/LockManager', () => ({
  68. default: ctx.LockManager,
  69. }))
  70. vi.doMock(
  71. '../../../../app/src/Features/Project/ProjectEntityMongoUpdateHandler',
  72. () => ({
  73. default: ctx.ProjectEntityMongoUpdateHandler,
  74. })
  75. )
  76. ctx.ProjectGetter = (await import(modulePath)).default
  77. })
  78. describe('getProjectWithoutDocLines', function () {
  79. beforeEach(function (ctx) {
  80. ctx.ProjectGetter.promises.getProject = sinon.stub().resolves()
  81. })
  82. describe('passing an id', function () {
  83. beforeEach(async function (ctx) {
  84. await ctx.ProjectGetter.promises.getProjectWithoutDocLines(
  85. ctx.project._id
  86. )
  87. })
  88. it('should call find with the project id', function (ctx) {
  89. ctx.ProjectGetter.promises.getProject
  90. .calledWith(ctx.project._id)
  91. .should.equal(true)
  92. })
  93. it('should exclude the doc lines', function (ctx) {
  94. const excludes = {
  95. 'rootFolder.docs.lines': 0,
  96. 'rootFolder.folders.docs.lines': 0,
  97. 'rootFolder.folders.folders.docs.lines': 0,
  98. 'rootFolder.folders.folders.folders.docs.lines': 0,
  99. 'rootFolder.folders.folders.folders.folders.docs.lines': 0,
  100. 'rootFolder.folders.folders.folders.folders.folders.docs.lines': 0,
  101. 'rootFolder.folders.folders.folders.folders.folders.folders.docs.lines': 0,
  102. 'rootFolder.folders.folders.folders.folders.folders.folders.folders.docs.lines': 0,
  103. }
  104. ctx.ProjectGetter.promises.getProject
  105. .calledWith(ctx.project._id, excludes)
  106. .should.equal(true)
  107. })
  108. })
  109. })
  110. describe('getProjectWithOnlyFolders', function () {
  111. beforeEach(function (ctx) {
  112. ctx.ProjectGetter.promises.getProject = sinon.stub().resolves()
  113. })
  114. describe('passing an id', function () {
  115. beforeEach(async function (ctx) {
  116. await ctx.ProjectGetter.promises.getProjectWithOnlyFolders(
  117. ctx.project._id
  118. )
  119. })
  120. it('should call find with the project id', function (ctx) {
  121. ctx.ProjectGetter.promises.getProject
  122. .calledWith(ctx.project._id)
  123. .should.equal(true)
  124. })
  125. it('should exclude the docs and files lines', function (ctx) {
  126. const excludes = {
  127. 'rootFolder.docs': 0,
  128. 'rootFolder.fileRefs': 0,
  129. 'rootFolder.folders.docs': 0,
  130. 'rootFolder.folders.fileRefs': 0,
  131. 'rootFolder.folders.folders.docs': 0,
  132. 'rootFolder.folders.folders.fileRefs': 0,
  133. 'rootFolder.folders.folders.folders.docs': 0,
  134. 'rootFolder.folders.folders.folders.fileRefs': 0,
  135. 'rootFolder.folders.folders.folders.folders.docs': 0,
  136. 'rootFolder.folders.folders.folders.folders.fileRefs': 0,
  137. 'rootFolder.folders.folders.folders.folders.folders.docs': 0,
  138. 'rootFolder.folders.folders.folders.folders.folders.fileRefs': 0,
  139. 'rootFolder.folders.folders.folders.folders.folders.folders.docs': 0,
  140. 'rootFolder.folders.folders.folders.folders.folders.folders.fileRefs': 0,
  141. 'rootFolder.folders.folders.folders.folders.folders.folders.folders.docs': 0,
  142. 'rootFolder.folders.folders.folders.folders.folders.folders.folders.fileRefs': 0,
  143. }
  144. ctx.ProjectGetter.promises.getProject
  145. .calledWith(ctx.project._id, excludes)
  146. .should.equal(true)
  147. })
  148. })
  149. })
  150. describe('getProject', function () {
  151. describe('without projection', function () {
  152. describe('with project id', function () {
  153. beforeEach(async function (ctx) {
  154. await ctx.ProjectGetter.promises.getProject(ctx.projectIdStr)
  155. })
  156. it('should call findOne with the project id', function (ctx) {
  157. expect(ctx.db.projects.findOne.callCount).to.equal(1)
  158. expect(
  159. ctx.db.projects.findOne.lastCall.args[0]._id.toString()
  160. ).to.equal(ctx.projectIdStr)
  161. })
  162. })
  163. describe('without project id', function () {
  164. it('should be rejected', function (ctx) {
  165. expect(
  166. ctx.ProjectGetter.promises.getProject(null)
  167. ).to.be.rejectedWith('no project id provided')
  168. expect(ctx.db.projects.findOne.callCount).to.equal(0)
  169. })
  170. })
  171. })
  172. describe('with projection', function () {
  173. beforeEach(function (ctx) {
  174. ctx.projection = { _id: 1 }
  175. })
  176. describe('with project id', function () {
  177. beforeEach(async function (ctx) {
  178. await ctx.ProjectGetter.promises.getProject(
  179. ctx.projectIdStr,
  180. ctx.projection
  181. )
  182. })
  183. it('should call findOne with the project id', function (ctx) {
  184. expect(ctx.db.projects.findOne.callCount).to.equal(1)
  185. expect(
  186. ctx.db.projects.findOne.lastCall.args[0]._id.toString()
  187. ).to.equal(ctx.projectIdStr)
  188. expect(ctx.db.projects.findOne.lastCall.args[1]).to.deep.equal({
  189. projection: ctx.projection,
  190. })
  191. })
  192. })
  193. describe('without project id', function () {
  194. it('should be rejected', function (ctx) {
  195. expect(
  196. ctx.ProjectGetter.promises.getProject(null)
  197. ).to.be.rejectedWith('no project id provided')
  198. expect(ctx.db.projects.findOne.callCount).to.equal(0)
  199. })
  200. })
  201. })
  202. })
  203. describe('getProjectWithoutLock', function () {
  204. describe('without projection', function () {
  205. describe('with project id', function () {
  206. beforeEach(async function (ctx) {
  207. await ctx.ProjectGetter.promises.getProjectWithoutLock(
  208. ctx.projectIdStr
  209. )
  210. })
  211. it('should call findOne with the project id', function (ctx) {
  212. expect(ctx.db.projects.findOne.callCount).to.equal(1)
  213. expect(
  214. ctx.db.projects.findOne.lastCall.args[0]._id.toString()
  215. ).to.equal(ctx.projectIdStr)
  216. })
  217. })
  218. describe('without project id', function () {
  219. it('should be rejected', function (ctx) {
  220. expect(
  221. ctx.ProjectGetter.promises.getProjectWithoutLock(null)
  222. ).to.be.rejectedWith('no project id provided')
  223. expect(ctx.db.projects.findOne.callCount).to.equal(0)
  224. })
  225. })
  226. })
  227. describe('with projection', function () {
  228. beforeEach(function (ctx) {
  229. ctx.projection = { _id: 1 }
  230. })
  231. describe('with project id', function () {
  232. beforeEach(async function (ctx) {
  233. await ctx.ProjectGetter.promises.getProjectWithoutLock(
  234. ctx.project._id,
  235. ctx.projection
  236. )
  237. })
  238. it('should call findOne with the project id', function (ctx) {
  239. expect(ctx.db.projects.findOne.callCount).to.equal(1)
  240. expect(
  241. ctx.db.projects.findOne.lastCall.args[0]._id.toString()
  242. ).to.equal(ctx.projectIdStr)
  243. expect(ctx.db.projects.findOne.lastCall.args[1]).to.deep.equal({
  244. projection: ctx.projection,
  245. })
  246. })
  247. })
  248. describe('without project id', function () {
  249. it('should be rejected', function (ctx) {
  250. expect(
  251. ctx.ProjectGetter.promises.getProjectWithoutLock(null)
  252. ).to.be.rejectedWith('no project id provided')
  253. expect(ctx.db.projects.findOne.callCount).to.equal(0)
  254. })
  255. })
  256. })
  257. })
  258. describe('findAllUsersProjects', function () {
  259. beforeEach(function (ctx) {
  260. ctx.fields = { mock: 'fields' }
  261. ctx.projectOwned = { _id: 'mock-owned-projects' }
  262. ctx.projectRW = { _id: 'mock-rw-projects' }
  263. ctx.projectReview = { _id: 'mock-review-projects' }
  264. ctx.projectRO = { _id: 'mock-ro-projects' }
  265. ctx.projectTokenRW = { _id: 'mock-token-rw-projects' }
  266. ctx.projectTokenRO = { _id: 'mock-token-ro-projects' }
  267. ctx.Project.find
  268. .withArgs({ owner_ref: ctx.userId }, ctx.fields)
  269. .returns({ exec: sinon.stub().resolves([ctx.projectOwned]) })
  270. })
  271. it('should return a promise with all the projects', async function (ctx) {
  272. ctx.CollaboratorsGetter.promises.getProjectsUserIsMemberOf.resolves({
  273. readAndWrite: [ctx.projectRW],
  274. readOnly: [ctx.projectRO],
  275. tokenReadAndWrite: [ctx.projectTokenRW],
  276. tokenReadOnly: [ctx.projectTokenRO],
  277. review: [ctx.projectReview],
  278. })
  279. const projects = await ctx.ProjectGetter.promises.findAllUsersProjects(
  280. ctx.userId,
  281. ctx.fields
  282. )
  283. expect(projects).to.deep.equal({
  284. owned: [ctx.projectOwned],
  285. readAndWrite: [ctx.projectRW],
  286. readOnly: [ctx.projectRO],
  287. tokenReadAndWrite: [ctx.projectTokenRW],
  288. tokenReadOnly: [ctx.projectTokenRO],
  289. review: [ctx.projectReview],
  290. })
  291. })
  292. it('should remove duplicate projects', async function (ctx) {
  293. ctx.CollaboratorsGetter.promises.getProjectsUserIsMemberOf.resolves({
  294. readAndWrite: [ctx.projectRW, ctx.projectOwned],
  295. readOnly: [ctx.projectRO, ctx.projectRW],
  296. tokenReadAndWrite: [ctx.projectTokenRW, ctx.projectRO],
  297. tokenReadOnly: [ctx.projectTokenRW, ctx.projectTokenRO, ctx.projectRO],
  298. review: [ctx.projectReview],
  299. })
  300. const projects = await ctx.ProjectGetter.promises.findAllUsersProjects(
  301. ctx.userId,
  302. ctx.fields
  303. )
  304. expect(projects).to.deep.equal({
  305. owned: [ctx.projectOwned],
  306. readAndWrite: [ctx.projectRW],
  307. readOnly: [ctx.projectRO],
  308. tokenReadAndWrite: [ctx.projectTokenRW],
  309. tokenReadOnly: [ctx.projectTokenRO],
  310. review: [ctx.projectReview],
  311. })
  312. })
  313. })
  314. describe('getProjectIdByReadAndWriteToken', function () {
  315. describe('when project find returns project', function () {
  316. beforeEach(async function (ctx) {
  317. ctx.projectIdFound =
  318. await ctx.ProjectGetter.promises.getProjectIdByReadAndWriteToken(
  319. 'token'
  320. )
  321. })
  322. it('should find project with token', function (ctx) {
  323. ctx.Project.findOne
  324. .calledWithMatch({ 'tokens.readAndWrite': 'token' })
  325. .should.equal(true)
  326. })
  327. it('should return the project id', function (ctx) {
  328. expect(ctx.projectIdFound).to.equal(ctx.project._id)
  329. })
  330. })
  331. describe('when project not found', function () {
  332. it('should return undefined', async function (ctx) {
  333. ctx.Project.findOne.returns({ exec: sinon.stub().resolves(null) })
  334. const projectId =
  335. await ctx.ProjectGetter.promises.getProjectIdByReadAndWriteToken(
  336. 'token'
  337. )
  338. expect(projectId).to.equal(undefined)
  339. })
  340. })
  341. describe('when project find returns error', function () {
  342. beforeEach(async function (ctx) {
  343. ctx.Project.findOne.returns({ exec: sinon.stub().rejects() })
  344. })
  345. it('should be rejected', function (ctx) {
  346. expect(
  347. ctx.ProjectGetter.promises.getProjectIdByReadAndWriteToken('token')
  348. ).to.be.rejected
  349. })
  350. })
  351. })
  352. describe('findUsersProjectsByName', function () {
  353. it('should perform a case-insensitive search', async function (ctx) {
  354. ctx.project1 = { _id: 1, name: 'find me!' }
  355. ctx.project2 = { _id: 2, name: 'not me!' }
  356. ctx.project3 = { _id: 3, name: 'FIND ME!' }
  357. ctx.project4 = { _id: 4, name: 'Find Me!' }
  358. ctx.Project.find.withArgs({ owner_ref: ctx.userId }).returns({
  359. exec: sinon
  360. .stub()
  361. .resolves([ctx.project1, ctx.project2, ctx.project3, ctx.project4]),
  362. })
  363. const projects = await ctx.ProjectGetter.promises.findUsersProjectsByName(
  364. ctx.userId,
  365. ctx.project1.name
  366. )
  367. const projectNames = projects.map(project => project.name)
  368. expect(projectNames).to.have.members([
  369. ctx.project1.name,
  370. ctx.project3.name,
  371. ctx.project4.name,
  372. ])
  373. })
  374. it('should search collaborations as well', async function (ctx) {
  375. ctx.project1 = { _id: 1, name: 'find me!' }
  376. ctx.project2 = { _id: 2, name: 'FIND ME!' }
  377. ctx.project3 = { _id: 3, name: 'Find Me!' }
  378. ctx.project4 = { _id: 4, name: 'find ME!' }
  379. ctx.project5 = { _id: 5, name: 'FIND me!' }
  380. ctx.Project.find
  381. .withArgs({ owner_ref: ctx.userId })
  382. .returns({ exec: sinon.stub().resolves([ctx.project1]) })
  383. ctx.CollaboratorsGetter.promises.getProjectsUserIsMemberOf.resolves({
  384. readAndWrite: [ctx.project2],
  385. readOnly: [ctx.project3],
  386. tokenReadAndWrite: [ctx.project4],
  387. tokenReadOnly: [ctx.project5],
  388. })
  389. const projects = await ctx.ProjectGetter.promises.findUsersProjectsByName(
  390. ctx.userId,
  391. ctx.project1.name
  392. )
  393. expect(projects.map(project => project.name)).to.have.members([
  394. ctx.project1.name,
  395. ctx.project2.name,
  396. ])
  397. })
  398. })
  399. describe('getUsersDeletedProjects', function () {
  400. it('should look up the deleted projects by deletedProjectOwnerId', async function (ctx) {
  401. await ctx.ProjectGetter.promises.getUsersDeletedProjects('giraffe')
  402. sinon.assert.calledWith(ctx.DeletedProject.find, {
  403. 'deleterData.deletedProjectOwnerId': 'giraffe',
  404. })
  405. })
  406. it('should pass the found projects to the callback', async function (ctx) {
  407. const docs =
  408. await ctx.ProjectGetter.promises.getUsersDeletedProjects('giraffe')
  409. expect(docs).to.deep.equal([ctx.deletedProject])
  410. })
  411. })
  412. })