server/tests/external-plugins/akismet.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import { expect } from 'chai'
   4 import { HttpStatusCode } from '@shared/models'
   5 import {
   6   cleanupTests,
   7   createMultipleServers,
   8   doubleFollow,
   9   PeerTubeServer,
  10   setAccessTokensToServers,
  11   waitJobs
  12 } from '@shared/server-commands'
  13
  14 describe('Official plugin Akismet', function () {
  15   let servers: PeerTubeServer[]
  16   let videoUUID: string
  17
  18   before(async function () {
  19     this.timeout(30000)
  20
  21     servers = await createMultipleServers(2)
  22     await setAccessTokensToServers(servers)
  23
  24     await servers[0].plugins.install({ npmName: 'peertube-plugin-akismet' })
  25
  26     if (!process.env.AKISMET_KEY) throw new Error('Missing AKISMET_KEY from env')
  27
  28     await servers[0].plugins.updateSettings({
  29       npmName: 'peertube-plugin-akismet',
  30       settings: {
  31         'akismet-api-key': process.env.AKISMET_KEY
  32       }
  33     })
  34
  35     await doubleFollow(servers[0], servers[1])
  36   })
  37
  38   describe('Local threads/replies', function () {
  39
  40     before(async function () {
  41       const { uuid } = await servers[0].videos.quickUpload({ name: 'video 1' })
  42       videoUUID = uuid
  43     })
  44
  45     it('Should not detect a thread as spam', async function () {
  46       await servers[0].comments.createThread({ videoId: videoUUID, text: 'comment' })
  47     })
  48
  49     it('Should not detect a reply as spam', async function () {
  50       await servers[0].comments.addReplyToLastThread({ text: 'reply' })
  51     })
  52
  53     it('Should detect a thread as spam', async function () {
  54       await servers[0].comments.createThread({
  55         videoId: videoUUID,
  56         text: 'akismet-guaranteed-spam',
  57         expectedStatus: HttpStatusCode.FORBIDDEN_403
  58       })
  59     })
  60
  61     it('Should detect a thread as spam', async function () {
  62       await servers[0].comments.createThread({ videoId: videoUUID, text: 'comment' })
  63       await servers[0].comments.addReplyToLastThread({ text: 'akismet-guaranteed-spam', expectedStatus: HttpStatusCode.FORBIDDEN_403 })
  64     })
  65   })
  66
  67   describe('Remote threads/replies', function () {
  68
  69     before(async function () {
  70       this.timeout(60000)
  71
  72       const { uuid } = await servers[0].videos.quickUpload({ name: 'video 1' })
  73       videoUUID = uuid
  74     })
  75
  76     it('Should not detect a thread as spam', async function () {
  77       this.timeout(30000)
  78
  79       await servers[1].comments.createThread({ videoId: videoUUID, text: 'remote comment 1' })
  80       await waitJobs(servers)
  81
  82       const { data } = await servers[0].comments.listThreads({ videoId: videoUUID })
  83       expect(data).to.have.lengthOf(1)
  84     })
  85
  86     it('Should not detect a reply as spam', async function () {
  87       this.timeout(30000)
  88
  89       await servers[1].comments.addReplyToLastThread({ text: 'I agree with you' })
  90       await waitJobs(servers)
  91
  92       const { data } = await servers[0].comments.listThreads({ videoId: videoUUID })
  93       expect(data).to.have.lengthOf(1)
  94
  95       const tree = await servers[0].comments.getThread({ videoId: videoUUID, threadId: data[0].id })
  96       expect(tree.children).to.have.lengthOf(1)
  97     })
  98
  99     it('Should detect a thread as spam', async function () {
 100       this.timeout(30000)
 101
 102       await servers[1].comments.createThread({ videoId: videoUUID, text: 'akismet-guaranteed-spam' })
 103       await waitJobs(servers)
 104
 105       const { data } = await servers[0].comments.listThreads({ videoId: videoUUID })
 106       expect(data).to.have.lengthOf(1)
 107     })
 108
 109     it('Should detect a thread as spam', async function () {
 110       this.timeout(30000)
 111
 112       await servers[1].comments.createThread({ videoId: videoUUID, text: 'remote comment 2' })
 113       await servers[1].comments.addReplyToLastThread({ text: 'akismet-guaranteed-spam' })
 114       await waitJobs(servers)
 115
 116       const { data } = await servers[0].comments.listThreads({ videoId: videoUUID })
 117       expect(data).to.have.lengthOf(2)
 118
 119       for (const thread of data) {
 120         const tree = await servers[0].comments.getThread({ videoId: videoUUID, threadId: thread.id })
 121         if (tree.comment.text === 'remote comment 1') continue
 122
 123         expect(tree.children).to.have.lengthOf(0)
 124       }
 125     })
 126   })
 127
 128   after(async function () {
 129     await cleanupTests(servers)
 130   })
 131 })