diff options
Diffstat (limited to 'server/tests/api/moderation/blocklist-notification.ts')
-rw-r--r-- | server/tests/api/moderation/blocklist-notification.ts | 231 |
1 files changed, 0 insertions, 231 deletions
diff --git a/server/tests/api/moderation/blocklist-notification.ts b/server/tests/api/moderation/blocklist-notification.ts deleted file mode 100644 index 9c2863a58..000000000 --- a/server/tests/api/moderation/blocklist-notification.ts +++ /dev/null | |||
@@ -1,231 +0,0 @@ | |||
1 | /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */ | ||
2 | |||
3 | import { expect } from 'chai' | ||
4 | import { UserNotificationType } from '@shared/models' | ||
5 | import { | ||
6 | cleanupTests, | ||
7 | createMultipleServers, | ||
8 | doubleFollow, | ||
9 | PeerTubeServer, | ||
10 | setAccessTokensToServers, | ||
11 | waitJobs | ||
12 | } from '@shared/server-commands' | ||
13 | |||
14 | async function checkNotifications (server: PeerTubeServer, token: string, expected: UserNotificationType[]) { | ||
15 | const { data } = await server.notifications.list({ token, start: 0, count: 10, unread: true }) | ||
16 | expect(data).to.have.lengthOf(expected.length) | ||
17 | |||
18 | for (const type of expected) { | ||
19 | expect(data.find(n => n.type === type)).to.exist | ||
20 | } | ||
21 | } | ||
22 | |||
23 | describe('Test blocklist notifications', function () { | ||
24 | let servers: PeerTubeServer[] | ||
25 | let videoUUID: string | ||
26 | |||
27 | let userToken1: string | ||
28 | let userToken2: string | ||
29 | let remoteUserToken: string | ||
30 | |||
31 | async function resetState () { | ||
32 | try { | ||
33 | await servers[1].subscriptions.remove({ token: remoteUserToken, uri: 'user1_channel@' + servers[0].host }) | ||
34 | await servers[1].subscriptions.remove({ token: remoteUserToken, uri: 'user2_channel@' + servers[0].host }) | ||
35 | } catch {} | ||
36 | |||
37 | await waitJobs(servers) | ||
38 | |||
39 | await servers[0].notifications.markAsReadAll({ token: userToken1 }) | ||
40 | await servers[0].notifications.markAsReadAll({ token: userToken2 }) | ||
41 | |||
42 | { | ||
43 | const { uuid } = await servers[0].videos.upload({ token: userToken1, attributes: { name: 'video' } }) | ||
44 | videoUUID = uuid | ||
45 | |||
46 | await waitJobs(servers) | ||
47 | } | ||
48 | |||
49 | { | ||
50 | await servers[1].comments.createThread({ | ||
51 | token: remoteUserToken, | ||
52 | videoId: videoUUID, | ||
53 | text: '@user2@' + servers[0].host + ' hello' | ||
54 | }) | ||
55 | } | ||
56 | |||
57 | { | ||
58 | |||
59 | await servers[1].subscriptions.add({ token: remoteUserToken, targetUri: 'user1_channel@' + servers[0].host }) | ||
60 | await servers[1].subscriptions.add({ token: remoteUserToken, targetUri: 'user2_channel@' + servers[0].host }) | ||
61 | } | ||
62 | |||
63 | await waitJobs(servers) | ||
64 | } | ||
65 | |||
66 | before(async function () { | ||
67 | this.timeout(60000) | ||
68 | |||
69 | servers = await createMultipleServers(2) | ||
70 | await setAccessTokensToServers(servers) | ||
71 | |||
72 | { | ||
73 | const user = { username: 'user1', password: 'password' } | ||
74 | await servers[0].users.create({ | ||
75 | username: user.username, | ||
76 | password: user.password, | ||
77 | videoQuota: -1, | ||
78 | videoQuotaDaily: -1 | ||
79 | }) | ||
80 | |||
81 | userToken1 = await servers[0].login.getAccessToken(user) | ||
82 | await servers[0].videos.upload({ token: userToken1, attributes: { name: 'video user 1' } }) | ||
83 | } | ||
84 | |||
85 | { | ||
86 | const user = { username: 'user2', password: 'password' } | ||
87 | await servers[0].users.create({ username: user.username, password: user.password }) | ||
88 | |||
89 | userToken2 = await servers[0].login.getAccessToken(user) | ||
90 | } | ||
91 | |||
92 | { | ||
93 | const user = { username: 'user3', password: 'password' } | ||
94 | await servers[1].users.create({ username: user.username, password: user.password }) | ||
95 | |||
96 | remoteUserToken = await servers[1].login.getAccessToken(user) | ||
97 | } | ||
98 | |||
99 | await doubleFollow(servers[0], servers[1]) | ||
100 | }) | ||
101 | |||
102 | describe('User blocks another user', function () { | ||
103 | |||
104 | before(async function () { | ||
105 | this.timeout(30000) | ||
106 | |||
107 | await resetState() | ||
108 | }) | ||
109 | |||
110 | it('Should have appropriate notifications', async function () { | ||
111 | const notifs = [ UserNotificationType.NEW_COMMENT_ON_MY_VIDEO, UserNotificationType.NEW_FOLLOW ] | ||
112 | await checkNotifications(servers[0], userToken1, notifs) | ||
113 | }) | ||
114 | |||
115 | it('Should block an account', async function () { | ||
116 | await servers[0].blocklist.addToMyBlocklist({ token: userToken1, account: 'user3@' + servers[1].host }) | ||
117 | await waitJobs(servers) | ||
118 | }) | ||
119 | |||
120 | it('Should not have notifications from this account', async function () { | ||
121 | await checkNotifications(servers[0], userToken1, []) | ||
122 | }) | ||
123 | |||
124 | it('Should have notifications of this account on user 2', async function () { | ||
125 | const notifs = [ UserNotificationType.COMMENT_MENTION, UserNotificationType.NEW_FOLLOW ] | ||
126 | |||
127 | await checkNotifications(servers[0], userToken2, notifs) | ||
128 | |||
129 | await servers[0].blocklist.removeFromMyBlocklist({ token: userToken1, account: 'user3@' + servers[1].host }) | ||
130 | }) | ||
131 | }) | ||
132 | |||
133 | describe('User blocks another server', function () { | ||
134 | |||
135 | before(async function () { | ||
136 | this.timeout(30000) | ||
137 | |||
138 | await resetState() | ||
139 | }) | ||
140 | |||
141 | it('Should have appropriate notifications', async function () { | ||
142 | const notifs = [ UserNotificationType.NEW_COMMENT_ON_MY_VIDEO, UserNotificationType.NEW_FOLLOW ] | ||
143 | await checkNotifications(servers[0], userToken1, notifs) | ||
144 | }) | ||
145 | |||
146 | it('Should block an account', async function () { | ||
147 | await servers[0].blocklist.addToMyBlocklist({ token: userToken1, server: servers[1].host }) | ||
148 | await waitJobs(servers) | ||
149 | }) | ||
150 | |||
151 | it('Should not have notifications from this account', async function () { | ||
152 | await checkNotifications(servers[0], userToken1, []) | ||
153 | }) | ||
154 | |||
155 | it('Should have notifications of this account on user 2', async function () { | ||
156 | const notifs = [ UserNotificationType.COMMENT_MENTION, UserNotificationType.NEW_FOLLOW ] | ||
157 | |||
158 | await checkNotifications(servers[0], userToken2, notifs) | ||
159 | |||
160 | await servers[0].blocklist.removeFromMyBlocklist({ token: userToken1, server: servers[1].host }) | ||
161 | }) | ||
162 | }) | ||
163 | |||
164 | describe('Server blocks a user', function () { | ||
165 | |||
166 | before(async function () { | ||
167 | this.timeout(30000) | ||
168 | |||
169 | await resetState() | ||
170 | }) | ||
171 | |||
172 | it('Should have appropriate notifications', async function () { | ||
173 | { | ||
174 | const notifs = [ UserNotificationType.NEW_COMMENT_ON_MY_VIDEO, UserNotificationType.NEW_FOLLOW ] | ||
175 | await checkNotifications(servers[0], userToken1, notifs) | ||
176 | } | ||
177 | |||
178 | { | ||
179 | const notifs = [ UserNotificationType.COMMENT_MENTION, UserNotificationType.NEW_FOLLOW ] | ||
180 | await checkNotifications(servers[0], userToken2, notifs) | ||
181 | } | ||
182 | }) | ||
183 | |||
184 | it('Should block an account', async function () { | ||
185 | await servers[0].blocklist.addToServerBlocklist({ account: 'user3@' + servers[1].host }) | ||
186 | await waitJobs(servers) | ||
187 | }) | ||
188 | |||
189 | it('Should not have notifications from this account', async function () { | ||
190 | await checkNotifications(servers[0], userToken1, []) | ||
191 | await checkNotifications(servers[0], userToken2, []) | ||
192 | |||
193 | await servers[0].blocklist.removeFromServerBlocklist({ account: 'user3@' + servers[1].host }) | ||
194 | }) | ||
195 | }) | ||
196 | |||
197 | describe('Server blocks a server', function () { | ||
198 | |||
199 | before(async function () { | ||
200 | this.timeout(30000) | ||
201 | |||
202 | await resetState() | ||
203 | }) | ||
204 | |||
205 | it('Should have appropriate notifications', async function () { | ||
206 | { | ||
207 | const notifs = [ UserNotificationType.NEW_COMMENT_ON_MY_VIDEO, UserNotificationType.NEW_FOLLOW ] | ||
208 | await checkNotifications(servers[0], userToken1, notifs) | ||
209 | } | ||
210 | |||
211 | { | ||
212 | const notifs = [ UserNotificationType.COMMENT_MENTION, UserNotificationType.NEW_FOLLOW ] | ||
213 | await checkNotifications(servers[0], userToken2, notifs) | ||
214 | } | ||
215 | }) | ||
216 | |||
217 | it('Should block an account', async function () { | ||
218 | await servers[0].blocklist.addToServerBlocklist({ server: servers[1].host }) | ||
219 | await waitJobs(servers) | ||
220 | }) | ||
221 | |||
222 | it('Should not have notifications from this account', async function () { | ||
223 | await checkNotifications(servers[0], userToken1, []) | ||
224 | await checkNotifications(servers[0], userToken2, []) | ||
225 | }) | ||
226 | }) | ||
227 | |||
228 | after(async function () { | ||
229 | await cleanupTests(servers) | ||
230 | }) | ||
231 | }) | ||