server/tests/api/notifications/admin-notifications.ts

   1 /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
   2
   3 import 'mocha'
   4 import { expect } from 'chai'
   5 import { MockJoinPeerTubeVersions } from '@shared/extra-utils/mock-servers/joinpeertube-versions'
   6 import { PluginType } from '@shared/models'
   7 import { cleanupTests, installPlugin, setPluginLatestVersion, setPluginVersion, wait } from '../../../../shared/extra-utils'
   8 import { ServerInfo } from '../../../../shared/extra-utils/index'
   9 import { MockSmtpServer } from '../../../../shared/extra-utils/miscs/email'
  10 import {
  11   CheckerBaseParams,
  12   checkNewPeerTubeVersion,
  13   checkNewPluginVersion,
  14   prepareNotificationsTest
  15 } from '../../../../shared/extra-utils/users/user-notifications'
  16 import { UserNotification, UserNotificationType } from '../../../../shared/models/users'
  17
  18 describe('Test admin notifications', function () {
  19   let server: ServerInfo
  20   let userNotifications: UserNotification[] = []
  21   let adminNotifications: UserNotification[] = []
  22   let emails: object[] = []
  23   let baseParams: CheckerBaseParams
  24   let joinPeerTubeServer: MockJoinPeerTubeVersions
  25
  26   before(async function () {
  27     this.timeout(120000)
  28
  29     joinPeerTubeServer = new MockJoinPeerTubeVersions()
  30     const port = await joinPeerTubeServer.initialize()
  31
  32     const config = {
  33       peertube: {
  34         check_latest_version: {
  35           enabled: true,
  36           url: `http://localhost:${port}/versions.json`
  37         }
  38       },
  39       plugins: {
  40         index: {
  41           enabled: true,
  42           check_latest_versions_interval: '5 seconds'
  43         }
  44       }
  45     }
  46
  47     const res = await prepareNotificationsTest(1, config)
  48     emails = res.emails
  49     server = res.servers[0]
  50
  51     userNotifications = res.userNotifications
  52     adminNotifications = res.adminNotifications
  53
  54     baseParams = {
  55       server: server,
  56       emails,
  57       socketNotifications: adminNotifications,
  58       token: server.accessToken
  59     }
  60
  61     await installPlugin({
  62       url: server.url,
  63       accessToken: server.accessToken,
  64       npmName: 'peertube-plugin-hello-world'
  65     })
  66
  67     await installPlugin({
  68       url: server.url,
  69       accessToken: server.accessToken,
  70       npmName: 'peertube-theme-background-red'
  71     })
  72   })
  73
  74   describe('Latest PeerTube version notification', function () {
  75
  76     it('Should not send a notification to admins if there is not a new version', async function () {
  77       this.timeout(30000)
  78
  79       joinPeerTubeServer.setLatestVersion('1.4.2')
  80
  81       await wait(3000)
  82       await checkNewPeerTubeVersion(baseParams, '1.4.2', 'absence')
  83     })
  84
  85     it('Should send a notification to admins on new plugin version', async function () {
  86       this.timeout(30000)
  87
  88       joinPeerTubeServer.setLatestVersion('15.4.2')
  89
  90       await wait(3000)
  91       await checkNewPeerTubeVersion(baseParams, '15.4.2', 'presence')
  92     })
  93
  94     it('Should not send the same notification to admins', async function () {
  95       this.timeout(30000)
  96
  97       await wait(3000)
  98       expect(adminNotifications.filter(n => n.type === UserNotificationType.NEW_PEERTUBE_VERSION)).to.have.lengthOf(1)
  99     })
 100
 101     it('Should not have sent a notification to users', async function () {
 102       this.timeout(30000)
 103
 104       expect(userNotifications.filter(n => n.type === UserNotificationType.NEW_PEERTUBE_VERSION)).to.have.lengthOf(0)
 105     })
 106
 107     it('Should send a new notification after a new release', async function () {
 108       this.timeout(30000)
 109
 110       joinPeerTubeServer.setLatestVersion('15.4.3')
 111
 112       await wait(3000)
 113       await checkNewPeerTubeVersion(baseParams, '15.4.3', 'presence')
 114       expect(adminNotifications.filter(n => n.type === UserNotificationType.NEW_PEERTUBE_VERSION)).to.have.lengthOf(2)
 115     })
 116   })
 117
 118   describe('Latest plugin version notification', function () {
 119
 120     it('Should not send a notification to admins if there is no new plugin version', async function () {
 121       this.timeout(30000)
 122
 123       await wait(6000)
 124       await checkNewPluginVersion(baseParams, PluginType.PLUGIN, 'hello-world', 'absence')
 125     })
 126
 127     it('Should send a notification to admins on new plugin version', async function () {
 128       this.timeout(30000)
 129
 130       await setPluginVersion(server.internalServerNumber, 'hello-world', '0.0.1')
 131       await setPluginLatestVersion(server.internalServerNumber, 'hello-world', '0.0.1')
 132       await wait(6000)
 133
 134       await checkNewPluginVersion(baseParams, PluginType.PLUGIN, 'hello-world', 'presence')
 135     })
 136
 137     it('Should not send the same notification to admins', async function () {
 138       this.timeout(30000)
 139
 140       await wait(6000)
 141
 142       expect(adminNotifications.filter(n => n.type === UserNotificationType.NEW_PLUGIN_VERSION)).to.have.lengthOf(1)
 143     })
 144
 145     it('Should not have sent a notification to users', async function () {
 146       expect(userNotifications.filter(n => n.type === UserNotificationType.NEW_PLUGIN_VERSION)).to.have.lengthOf(0)
 147     })
 148
 149     it('Should send a new notification after a new plugin release', async function () {
 150       this.timeout(30000)
 151
 152       await setPluginVersion(server.internalServerNumber, 'hello-world', '0.0.1')
 153       await setPluginLatestVersion(server.internalServerNumber, 'hello-world', '0.0.1')
 154       await wait(6000)
 155
 156       expect(adminNotifications.filter(n => n.type === UserNotificationType.NEW_PEERTUBE_VERSION)).to.have.lengthOf(2)
 157     })
 158   })
 159
 160   after(async function () {
 161     MockSmtpServer.Instance.kill()
 162
 163     await cleanupTests([ server ])
 164   })
 165 })