123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165 |
- /* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */
- import { expect } from 'chai'
- import { expectNotStartWith, expectStartWith, FIXTURE_URLS, MockProxy } from '@server/tests/shared'
- import { areMockObjectStorageTestsDisabled } from '@shared/core-utils'
- import { HttpStatusCode, VideoPrivacy } from '@shared/models'
- import {
- cleanupTests,
- createMultipleServers,
- doubleFollow,
- ObjectStorageCommand,
- PeerTubeServer,
- setAccessTokensToServers,
- setDefaultVideoChannel,
- waitJobs
- } from '@shared/server-commands'
- describe('Test proxy', function () {
- let servers: PeerTubeServer[] = []
- let proxy: MockProxy
- const goodEnv = { HTTP_PROXY: '' }
- const badEnv = { HTTP_PROXY: 'http://localhost:9000' }
- before(async function () {
- this.timeout(120000)
- proxy = new MockProxy()
- const proxyPort = await proxy.initialize()
- servers = await createMultipleServers(2)
- goodEnv.HTTP_PROXY = 'http://localhost:' + proxyPort
- await setAccessTokensToServers(servers)
- await setDefaultVideoChannel(servers)
- await doubleFollow(servers[0], servers[1])
- })
- describe('Federation', function () {
- it('Should succeed federation with the appropriate proxy config', async function () {
- this.timeout(40000)
- await servers[0].kill()
- await servers[0].run({}, { env: goodEnv })
- await servers[0].videos.quickUpload({ name: 'video 1' })
- await waitJobs(servers)
- for (const server of servers) {
- const { total, data } = await server.videos.list()
- expect(total).to.equal(1)
- expect(data).to.have.lengthOf(1)
- }
- })
- it('Should fail federation with a wrong proxy config', async function () {
- this.timeout(40000)
- await servers[0].kill()
- await servers[0].run({}, { env: badEnv })
- await servers[0].videos.quickUpload({ name: 'video 2' })
- await waitJobs(servers)
- {
- const { total, data } = await servers[0].videos.list()
- expect(total).to.equal(2)
- expect(data).to.have.lengthOf(2)
- }
- {
- const { total, data } = await servers[1].videos.list()
- expect(total).to.equal(1)
- expect(data).to.have.lengthOf(1)
- }
- })
- })
- describe('Videos import', async function () {
- function quickImport (expectedStatus: HttpStatusCode = HttpStatusCode.OK_200) {
- return servers[0].imports.importVideo({
- attributes: {
- name: 'video import',
- channelId: servers[0].store.channel.id,
- privacy: VideoPrivacy.PUBLIC,
- targetUrl: FIXTURE_URLS.peertube_long
- },
- expectedStatus
- })
- }
- it('Should succeed import with the appropriate proxy config', async function () {
- this.timeout(120000)
- await servers[0].kill()
- await servers[0].run({}, { env: goodEnv })
- await quickImport()
- await waitJobs(servers)
- const { total, data } = await servers[0].videos.list()
- expect(total).to.equal(3)
- expect(data).to.have.lengthOf(3)
- })
- it('Should fail import with a wrong proxy config', async function () {
- this.timeout(120000)
- await servers[0].kill()
- await servers[0].run({}, { env: badEnv })
- await quickImport(HttpStatusCode.BAD_REQUEST_400)
- })
- })
- describe('Object storage', function () {
- if (areMockObjectStorageTestsDisabled()) return
- before(async function () {
- this.timeout(30000)
- await ObjectStorageCommand.prepareDefaultMockBuckets()
- })
- it('Should succeed to upload to object storage with the appropriate proxy config', async function () {
- this.timeout(120000)
- await servers[0].kill()
- await servers[0].run(ObjectStorageCommand.getDefaultMockConfig(), { env: goodEnv })
- const { uuid } = await servers[0].videos.quickUpload({ name: 'video' })
- await waitJobs(servers)
- const video = await servers[0].videos.get({ id: uuid })
- expectStartWith(video.files[0].fileUrl, ObjectStorageCommand.getMockWebTorrentBaseUrl())
- })
- it('Should fail to upload to object storage with a wrong proxy config', async function () {
- this.timeout(120000)
- await servers[0].kill()
- await servers[0].run(ObjectStorageCommand.getDefaultMockConfig(), { env: badEnv })
- const { uuid } = await servers[0].videos.quickUpload({ name: 'video' })
- await waitJobs(servers)
- const video = await servers[0].videos.get({ id: uuid })
- expectNotStartWith(video.files[0].fileUrl, ObjectStorageCommand.getMockWebTorrentBaseUrl())
- })
- })
- after(async function () {
- await proxy.terminate()
- await cleanupTests(servers)
- })
- })
|