diff options
author | Chocobozzz <me@florianbigard.com> | 2023-05-23 10:49:45 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2023-05-23 10:49:45 +0200 |
commit | f89189907bbdff6c4bc6d3460ed9ef4c49515f17 (patch) | |
tree | c55e50e3fc02ae9b3f2d1d19d95160af98cc7d7c /server/tests/api/object-storage/video-imports.ts | |
parent | 41cde76bbf5ac16a90b5f158672523069db74009 (diff) | |
download | PeerTube-f89189907bbdff6c4bc6d3460ed9ef4c49515f17.tar.gz PeerTube-f89189907bbdff6c4bc6d3460ed9ef4c49515f17.tar.zst PeerTube-f89189907bbdff6c4bc6d3460ed9ef4c49515f17.zip |
Prevent object storage mock conflicts
When running tests in parallel
Diffstat (limited to 'server/tests/api/object-storage/video-imports.ts')
-rw-r--r-- | server/tests/api/object-storage/video-imports.ts | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/server/tests/api/object-storage/video-imports.ts b/server/tests/api/object-storage/video-imports.ts index d5fd91b6a..57150e5a6 100644 --- a/server/tests/api/object-storage/video-imports.ts +++ b/server/tests/api/object-storage/video-imports.ts | |||
@@ -32,13 +32,14 @@ describe('Object storage for video import', function () { | |||
32 | if (areMockObjectStorageTestsDisabled()) return | 32 | if (areMockObjectStorageTestsDisabled()) return |
33 | 33 | ||
34 | let server: PeerTubeServer | 34 | let server: PeerTubeServer |
35 | const objectStorage = new ObjectStorageCommand() | ||
35 | 36 | ||
36 | before(async function () { | 37 | before(async function () { |
37 | this.timeout(120000) | 38 | this.timeout(120000) |
38 | 39 | ||
39 | await ObjectStorageCommand.prepareDefaultMockBuckets() | 40 | await objectStorage.prepareDefaultMockBuckets() |
40 | 41 | ||
41 | server = await createSingleServer(1, ObjectStorageCommand.getDefaultMockConfig()) | 42 | server = await createSingleServer(1, objectStorage.getDefaultMockConfig()) |
42 | 43 | ||
43 | await setAccessTokensToServers([ server ]) | 44 | await setAccessTokensToServers([ server ]) |
44 | await setDefaultVideoChannel([ server ]) | 45 | await setDefaultVideoChannel([ server ]) |
@@ -64,7 +65,7 @@ describe('Object storage for video import', function () { | |||
64 | expect(video.streamingPlaylists).to.have.lengthOf(0) | 65 | expect(video.streamingPlaylists).to.have.lengthOf(0) |
65 | 66 | ||
66 | const fileUrl = video.files[0].fileUrl | 67 | const fileUrl = video.files[0].fileUrl |
67 | expectStartWith(fileUrl, ObjectStorageCommand.getMockWebTorrentBaseUrl()) | 68 | expectStartWith(fileUrl, objectStorage.getMockWebVideosBaseUrl()) |
68 | 69 | ||
69 | await makeRawRequest({ url: fileUrl, expectedStatus: HttpStatusCode.OK_200 }) | 70 | await makeRawRequest({ url: fileUrl, expectedStatus: HttpStatusCode.OK_200 }) |
70 | }) | 71 | }) |
@@ -89,13 +90,13 @@ describe('Object storage for video import', function () { | |||
89 | expect(video.streamingPlaylists[0].files).to.have.lengthOf(5) | 90 | expect(video.streamingPlaylists[0].files).to.have.lengthOf(5) |
90 | 91 | ||
91 | for (const file of video.files) { | 92 | for (const file of video.files) { |
92 | expectStartWith(file.fileUrl, ObjectStorageCommand.getMockWebTorrentBaseUrl()) | 93 | expectStartWith(file.fileUrl, objectStorage.getMockWebVideosBaseUrl()) |
93 | 94 | ||
94 | await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 }) | 95 | await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 }) |
95 | } | 96 | } |
96 | 97 | ||
97 | for (const file of video.streamingPlaylists[0].files) { | 98 | for (const file of video.streamingPlaylists[0].files) { |
98 | expectStartWith(file.fileUrl, ObjectStorageCommand.getMockPlaylistBaseUrl()) | 99 | expectStartWith(file.fileUrl, objectStorage.getMockPlaylistBaseUrl()) |
99 | 100 | ||
100 | await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 }) | 101 | await makeRawRequest({ url: file.fileUrl, expectedStatus: HttpStatusCode.OK_200 }) |
101 | } | 102 | } |
@@ -103,6 +104,8 @@ describe('Object storage for video import', function () { | |||
103 | }) | 104 | }) |
104 | 105 | ||
105 | after(async function () { | 106 | after(async function () { |
107 | await objectStorage.cleanupMock() | ||
108 | |||
106 | await cleanupTests([ server ]) | 109 | await cleanupTests([ server ]) |
107 | }) | 110 | }) |
108 | }) | 111 | }) |