mirror of
https://github.com/overleaf/overleaf.git
synced 2024-11-29 19:03:39 -05:00
4cc888ce2f
Add endpoints to chat for deleting expired project chat data GitOrigin-RevId: e4eb7c7a79472bb116b2095a76c870e204590288
67 lines
2.2 KiB
JavaScript
67 lines
2.2 KiB
JavaScript
const { ObjectId } = require('../../../app/js/mongodb')
|
|
const { expect } = require('chai')
|
|
|
|
const ChatClient = require('./helpers/ChatClient')
|
|
const ChatApp = require('./helpers/ChatApp')
|
|
|
|
const db = ChatApp.db
|
|
|
|
async function getMessage(messageId) {
|
|
return await db.messages.findOne({
|
|
_id: ObjectId(messageId),
|
|
})
|
|
}
|
|
|
|
describe('Destroying a project', async function () {
|
|
const projectId = ObjectId().toString()
|
|
const userId = ObjectId().toString()
|
|
before(async function () {
|
|
await ChatApp.ensureRunning()
|
|
})
|
|
|
|
describe('with a project that has threads and messages', async function () {
|
|
const threadId = ObjectId().toString()
|
|
before(async function () {
|
|
const { response } = await ChatClient.sendMessage(
|
|
projectId,
|
|
threadId,
|
|
userId,
|
|
'destroyed thread message'
|
|
)
|
|
expect(response.statusCode).to.equal(201)
|
|
this.threadMessageId = response.body.id
|
|
const { response: response2 } = await ChatClient.sendGlobalMessage(
|
|
projectId,
|
|
userId,
|
|
'destroyed global message'
|
|
)
|
|
expect(response2.statusCode).to.equal(201)
|
|
this.globalThreadMessageId = response2.body.id
|
|
|
|
const threadRooms = await db.rooms
|
|
.find({ project_id: ObjectId(projectId) })
|
|
.toArray()
|
|
expect(threadRooms.length).to.equal(2)
|
|
const threadMessage = await getMessage(this.threadMessageId)
|
|
expect(threadMessage).to.exist
|
|
const globalThreadMessage = await getMessage(this.globalThreadMessageId)
|
|
expect(globalThreadMessage).to.exist
|
|
|
|
const { response: responseDestroy } = await ChatClient.destroyProject(
|
|
projectId
|
|
)
|
|
expect(responseDestroy.statusCode).to.equal(204)
|
|
})
|
|
|
|
it('should remove the messages and threads from the database', async function () {
|
|
const threadRooms = await db.rooms
|
|
.find({ project_id: ObjectId(projectId) })
|
|
.toArray()
|
|
expect(threadRooms.length).to.equal(0)
|
|
const threadMessage = await getMessage(this.threadMessageId)
|
|
expect(threadMessage).to.be.null
|
|
const globalThreadMessage = await getMessage(this.globalThreadMessageId)
|
|
expect(globalThreadMessage).to.be.null
|
|
})
|
|
})
|
|
})
|