aboutsummaryrefslogtreecommitdiffhomepage
path: root/tests/api/friendsAdvanced.js
diff options
context:
space:
mode:
authorChocobozzz <florian.bigard@gmail.com>2016-01-30 17:05:22 +0100
committerChocobozzz <florian.bigard@gmail.com>2016-01-30 17:05:22 +0100
commitcda021079ff455cc0fd0eb95a5395fa808ab63d1 (patch)
tree056716de7460462b74b861051a5e9da6e2633fce /tests/api/friendsAdvanced.js
parent86435b9baedfe300a28ea4545511c1b50d4119f6 (diff)
downloadPeerTube-cda021079ff455cc0fd0eb95a5395fa808ab63d1.tar.gz
PeerTube-cda021079ff455cc0fd0eb95a5395fa808ab63d1.tar.zst
PeerTube-cda021079ff455cc0fd0eb95a5395fa808ab63d1.zip
New directory organization
Diffstat (limited to 'tests/api/friendsAdvanced.js')
-rw-r--r--tests/api/friendsAdvanced.js252
1 files changed, 252 insertions, 0 deletions
diff --git a/tests/api/friendsAdvanced.js b/tests/api/friendsAdvanced.js
new file mode 100644
index 000000000..61483bee6
--- /dev/null
+++ b/tests/api/friendsAdvanced.js
@@ -0,0 +1,252 @@
1;(function () {
2 'use strict'
3
4 var async = require('async')
5 var chai = require('chai')
6 var expect = chai.expect
7
8 var utils = require('./utils')
9
10 describe('Test advanced friends', function () {
11 var apps = []
12 var urls = []
13
14 function makeFriends (pod_number, callback) {
15 return utils.makeFriends(urls[pod_number - 1], callback)
16 }
17
18 function quitFriends (pod_number, callback) {
19 return utils.quitFriends(urls[pod_number - 1], callback)
20 }
21
22 function getFriendsList (pod_number, end) {
23 return utils.getFriendsList(urls[pod_number - 1], end)
24 }
25
26 function uploadVideo (pod_number, callback) {
27 var name = 'my super video'
28 var description = 'my super description'
29 var fixture = 'video_short.webm'
30
31 return utils.uploadVideo(urls[pod_number - 1], name, description, fixture, callback)
32 }
33
34 function getVideos (pod_number, callback) {
35 return utils.getVideosList(urls[pod_number - 1], callback)
36 }
37
38 // ---------------------------------------------------------------
39
40 before(function (done) {
41 this.timeout(30000)
42 utils.flushAndRunMultipleServers(6, function (apps_run, urls_run) {
43 apps = apps_run
44 urls = urls_run
45 done()
46 })
47 })
48
49 it('Should make friends with two pod each in a different group', function (done) {
50 this.timeout(20000)
51
52 async.series([
53 // Pod 3 makes friend with the first one
54 function (next) {
55 makeFriends(3, next)
56 },
57 // Pod 4 makes friend with the second one
58 function (next) {
59 makeFriends(4, next)
60 },
61 // Now if the fifth wants to make friends with the third et the first
62 function (next) {
63 makeFriends(5, next)
64 },
65 function (next) {
66 setTimeout(next, 11000)
67 }],
68 function (err) {
69 if (err) throw err
70
71 // It should have 0 friends
72 getFriendsList(5, function (err, res) {
73 if (err) throw err
74
75 expect(res.body.length).to.equal(0)
76
77 done()
78 })
79 }
80 )
81 })
82
83 it('Should quit all friends', function (done) {
84 this.timeout(10000)
85
86 async.series([
87 function (next) {
88 quitFriends(1, next)
89 },
90 function (next) {
91 quitFriends(2, next)
92 }],
93 function (err) {
94 if (err) throw err
95
96 async.each([ 1, 2, 3, 4, 5, 6 ], function (i, callback) {
97 getFriendsList(i, function (err, res) {
98 if (err) throw err
99
100 expect(res.body.length).to.equal(0)
101
102 callback()
103 })
104 }, done)
105 }
106 )
107 })
108
109 it('Should make friends with the pods 1, 2, 3', function (done) {
110 this.timeout(150000)
111
112 async.series([
113 // Pods 1, 2, 3 and 4 become friends
114 function (next) {
115 makeFriends(2, next)
116 },
117 function (next) {
118 makeFriends(1, next)
119 },
120 function (next) {
121 makeFriends(4, next)
122 },
123 // Kill pod 4
124 function (next) {
125 apps[3].kill()
126 next()
127 },
128 // Expulse pod 4 from pod 1 and 2
129 function (next) {
130 uploadVideo(1, next)
131 },
132 function (next) {
133 uploadVideo(2, next)
134 },
135 function (next) {
136 setTimeout(next, 11000)
137 },
138 function (next) {
139 uploadVideo(1, next)
140 },
141 function (next) {
142 uploadVideo(2, next)
143 },
144 function (next) {
145 setTimeout(next, 20000)
146 },
147 // Rerun server 4
148 function (next) {
149 utils.runServer(4, function (app, url) {
150 apps[3] = app
151 next()
152 })
153 },
154 function (next) {
155 getFriendsList(4, function (err, res) {
156 if (err) throw err
157
158 // Pod 4 didn't know pod 1 and 2 removed it
159 expect(res.body.length).to.equal(3)
160
161 next()
162 })
163 },
164 // Pod 6 ask pod 1, 2 and 3
165 function (next) {
166 makeFriends(6, next)
167 }],
168 function (err) {
169 if (err) throw err
170
171 getFriendsList(6, function (err, res) {
172 if (err) throw err
173
174 // Pod 4 should not be our friend
175 var result = res.body
176 expect(result.length).to.equal(3)
177 for (var pod of result) {
178 expect(pod.url).not.equal(urls[3])
179 }
180
181 done()
182 })
183 }
184 )
185 })
186
187 it('Should pod 1 quit friends', function (done) {
188 this.timeout(25000)
189
190 async.series([
191 // Upload a video on server 3 for aditionnal tests
192 function (next) {
193 uploadVideo(3, next)
194 },
195 function (next) {
196 setTimeout(next, 15000)
197 },
198 function (next) {
199 quitFriends(1, next)
200 },
201 // Remove pod 1 from pod 2
202 function (next) {
203 getVideos(1, function (err, res) {
204 if (err) throw err
205 expect(res.body).to.be.an('array')
206 expect(res.body.length).to.equal(2)
207
208 next()
209 })
210 }],
211 function (err) {
212 if (err) throw err
213
214 getVideos(2, function (err, res) {
215 if (err) throw err
216 expect(res.body).to.be.an('array')
217 expect(res.body.length).to.equal(3)
218 done()
219 })
220 }
221 )
222 })
223
224 it('Should make friends between pod 1 and 2 and exchange their videos', function (done) {
225 this.timeout(20000)
226 makeFriends(1, function () {
227 setTimeout(function () {
228 getVideos(1, function (err, res) {
229 if (err) throw err
230
231 expect(res.body).to.be.an('array')
232 expect(res.body.length).to.equal(5)
233
234 done()
235 })
236 }, 5000)
237 })
238 })
239
240 after(function (done) {
241 apps.forEach(function (app) {
242 process.kill(-app.pid)
243 })
244
245 if (this.ok) {
246 utils.flushTests(done)
247 } else {
248 done()
249 }
250 })
251 })
252})()