123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306 |
- /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
- import { expect } from 'chai'
- import {
- checkCommentMention,
- CheckerBaseParams,
- checkNewCommentOnMyVideo,
- MockSmtpServer,
- prepareNotificationsTest
- } from '@server/tests/shared'
- import { UserNotification } from '@shared/models'
- import { cleanupTests, PeerTubeServer, waitJobs } from '@shared/server-commands'
- describe('Test comments notifications', function () {
- let servers: PeerTubeServer[] = []
- let userToken: string
- let userNotifications: UserNotification[] = []
- let emails: object[] = []
- const commentText = '**hello** <a href="https://joinpeertube.org">world</a>, <h1>what do you think about peertube?</h1>'
- const expectedHtml = '<strong style="-ms-text-size-adjust: 100%; -webkit-text-size-adjust: 100%;">hello</strong> ' +
- '<a href="https://joinpeertube.org" target="_blank" rel="noopener noreferrer" style="-ms-text-size-adjust: 100%; ' +
- '-webkit-text-size-adjust: 100%; text-decoration: none; color: #f2690d;">world</a>, </p>what do you think about peertube?'
- before(async function () {
- this.timeout(120000)
- const res = await prepareNotificationsTest(2)
- emails = res.emails
- userToken = res.userAccessToken
- servers = res.servers
- userNotifications = res.userNotifications
- })
- describe('Comment on my video notifications', function () {
- let baseParams: CheckerBaseParams
- before(() => {
- baseParams = {
- server: servers[0],
- emails,
- socketNotifications: userNotifications,
- token: userToken
- }
- })
- it('Should not send a new comment notification after a comment on another video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- const created = await servers[0].comments.createThread({ videoId: uuid, text: 'comment' })
- const commentId = created.id
- await waitJobs(servers)
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId: commentId, commentId, checkType: 'absence' })
- })
- it('Should not send a new comment notification if I comment my own video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- const created = await servers[0].comments.createThread({ token: userToken, videoId: uuid, text: 'comment' })
- const commentId = created.id
- await waitJobs(servers)
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId: commentId, commentId, checkType: 'absence' })
- })
- it('Should not send a new comment notification if the account is muted', async function () {
- this.timeout(30000)
- await servers[0].blocklist.addToMyBlocklist({ token: userToken, account: 'root' })
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- const created = await servers[0].comments.createThread({ videoId: uuid, text: 'comment' })
- const commentId = created.id
- await waitJobs(servers)
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId: commentId, commentId, checkType: 'absence' })
- await servers[0].blocklist.removeFromMyBlocklist({ token: userToken, account: 'root' })
- })
- it('Should send a new comment notification after a local comment on my video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- const created = await servers[0].comments.createThread({ videoId: uuid, text: 'comment' })
- const commentId = created.id
- await waitJobs(servers)
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId: commentId, commentId, checkType: 'presence' })
- })
- it('Should send a new comment notification after a remote comment on my video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- await waitJobs(servers)
- await servers[1].comments.createThread({ videoId: uuid, text: 'comment' })
- await waitJobs(servers)
- const { data } = await servers[0].comments.listThreads({ videoId: uuid })
- expect(data).to.have.lengthOf(1)
- const commentId = data[0].id
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId: commentId, commentId, checkType: 'presence' })
- })
- it('Should send a new comment notification after a local reply on my video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- const { id: threadId } = await servers[0].comments.createThread({ videoId: uuid, text: 'comment' })
- const { id: commentId } = await servers[0].comments.addReply({ videoId: uuid, toCommentId: threadId, text: 'reply' })
- await waitJobs(servers)
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId, commentId, checkType: 'presence' })
- })
- it('Should send a new comment notification after a remote reply on my video', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- await waitJobs(servers)
- {
- const created = await servers[1].comments.createThread({ videoId: uuid, text: 'comment' })
- const threadId = created.id
- await servers[1].comments.addReply({ videoId: uuid, toCommentId: threadId, text: 'reply' })
- }
- await waitJobs(servers)
- const { data } = await servers[0].comments.listThreads({ videoId: uuid })
- expect(data).to.have.lengthOf(1)
- const threadId = data[0].id
- const tree = await servers[0].comments.getThread({ videoId: uuid, threadId })
- expect(tree.children).to.have.lengthOf(1)
- const commentId = tree.children[0].comment.id
- await checkNewCommentOnMyVideo({ ...baseParams, shortUUID, threadId, commentId, checkType: 'presence' })
- })
- it('Should convert markdown in comment to html', async function () {
- this.timeout(30000)
- const { uuid } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'cool video' } })
- await servers[0].comments.createThread({ videoId: uuid, text: commentText })
- await waitJobs(servers)
- const latestEmail = emails[emails.length - 1]
- expect(latestEmail['html']).to.contain(expectedHtml)
- })
- })
- describe('Mention notifications', function () {
- let baseParams: CheckerBaseParams
- const byAccountDisplayName = 'super root name'
- before(async () => {
- baseParams = {
- server: servers[0],
- emails,
- socketNotifications: userNotifications,
- token: userToken
- }
- await servers[0].users.updateMe({ displayName: 'super root name' })
- await servers[1].users.updateMe({ displayName: 'super root 2 name' })
- })
- it('Should not send a new mention comment notification if I mention the video owner', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ token: userToken, attributes: { name: 'super video' } })
- const { id: commentId } = await servers[0].comments.createThread({ videoId: uuid, text: '@user_1 hello' })
- await waitJobs(servers)
- await checkCommentMention({ ...baseParams, shortUUID, threadId: commentId, commentId, byAccountDisplayName, checkType: 'absence' })
- })
- it('Should not send a new mention comment notification if I mention myself', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- const { id: commentId } = await servers[0].comments.createThread({ token: userToken, videoId: uuid, text: '@user_1 hello' })
- await waitJobs(servers)
- await checkCommentMention({ ...baseParams, shortUUID, threadId: commentId, commentId, byAccountDisplayName, checkType: 'absence' })
- })
- it('Should not send a new mention notification if the account is muted', async function () {
- this.timeout(30000)
- await servers[0].blocklist.addToMyBlocklist({ token: userToken, account: 'root' })
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- const { id: commentId } = await servers[0].comments.createThread({ videoId: uuid, text: '@user_1 hello' })
- await waitJobs(servers)
- await checkCommentMention({ ...baseParams, shortUUID, threadId: commentId, commentId, byAccountDisplayName, checkType: 'absence' })
- await servers[0].blocklist.removeFromMyBlocklist({ token: userToken, account: 'root' })
- })
- it('Should not send a new mention notification if the remote account mention a local account', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- await waitJobs(servers)
- const { id: threadId } = await servers[1].comments.createThread({ videoId: uuid, text: '@user_1 hello' })
- await waitJobs(servers)
- const byAccountDisplayName = 'super root 2 name'
- await checkCommentMention({ ...baseParams, shortUUID, threadId, commentId: threadId, byAccountDisplayName, checkType: 'absence' })
- })
- it('Should send a new mention notification after local comments', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- const { id: threadId } = await servers[0].comments.createThread({ videoId: uuid, text: '@user_1 hellotext: 1' })
- await waitJobs(servers)
- await checkCommentMention({ ...baseParams, shortUUID, threadId, commentId: threadId, byAccountDisplayName, checkType: 'presence' })
- const { id: commentId } = await servers[0].comments.addReply({ videoId: uuid, toCommentId: threadId, text: 'hello 2 @user_1' })
- await waitJobs(servers)
- await checkCommentMention({ ...baseParams, shortUUID, commentId, threadId, byAccountDisplayName, checkType: 'presence' })
- })
- it('Should send a new mention notification after remote comments', async function () {
- this.timeout(30000)
- const { uuid, shortUUID } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- await waitJobs(servers)
- const text1 = `hello @user_1@${servers[0].host} 1`
- const { id: server2ThreadId } = await servers[1].comments.createThread({ videoId: uuid, text: text1 })
- await waitJobs(servers)
- const { data } = await servers[0].comments.listThreads({ videoId: uuid })
- expect(data).to.have.lengthOf(1)
- const byAccountDisplayName = 'super root 2 name'
- const threadId = data[0].id
- await checkCommentMention({ ...baseParams, shortUUID, commentId: threadId, threadId, byAccountDisplayName, checkType: 'presence' })
- const text2 = `@user_1@${servers[0].host} hello 2 @root@${servers[0].host}`
- await servers[1].comments.addReply({ videoId: uuid, toCommentId: server2ThreadId, text: text2 })
- await waitJobs(servers)
- const tree = await servers[0].comments.getThread({ videoId: uuid, threadId })
- expect(tree.children).to.have.lengthOf(1)
- const commentId = tree.children[0].comment.id
- await checkCommentMention({ ...baseParams, shortUUID, commentId, threadId, byAccountDisplayName, checkType: 'presence' })
- })
- it('Should convert markdown in comment to html', async function () {
- this.timeout(30000)
- const { uuid } = await servers[0].videos.upload({ attributes: { name: 'super video' } })
- const { id: threadId } = await servers[0].comments.createThread({ videoId: uuid, text: '@user_1 hello 1' })
- await servers[0].comments.addReply({ videoId: uuid, toCommentId: threadId, text: '@user_1 ' + commentText })
- await waitJobs(servers)
- const latestEmail = emails[emails.length - 1]
- expect(latestEmail['html']).to.contain(expectedHtml)
- })
- })
- after(async function () {
- MockSmtpServer.Instance.kill()
- await cleanupTests(servers)
- })
- })
|