/* eslint-disable @typescript-eslint/no-unused-expressions,@typescript-eslint/require-await */ import * as chai from 'chai' import 'mocha' import { VideoDetails, VideoImport, VideoPrivacy, VideoCaption } from '../../../../shared/models/videos' import { cleanupTests, doubleFollow, flushAndRunMultipleServers, getMyUserInformation, getMyVideos, getVideo, getVideosList, listVideoCaptions, testCaptionFile, immutableAssign, ServerInfo, setAccessTokensToServers } from '../../../../shared/extra-utils' import { waitJobs } from '../../../../shared/extra-utils/server/jobs' import { getMagnetURI, getMyVideoImports, getYoutubeVideoUrl, importVideo } from '../../../../shared/extra-utils/videos/video-imports' const expect = chai.expect describe('Test video imports', function () { let servers: ServerInfo[] = [] let channelIdServer1: number let channelIdServer2: number async function checkVideosServer1 (url: string, idHttp: string, idMagnet: string, idTorrent: string) { const resHttp = await getVideo(url, idHttp) const videoHttp: VideoDetails = resHttp.body expect(videoHttp.name).to.equal('small video - youtube') expect(videoHttp.category.label).to.equal('News & Politics') expect(videoHttp.licence.label).to.equal('Attribution') expect(videoHttp.language.label).to.equal('Unknown') expect(videoHttp.nsfw).to.be.false expect(videoHttp.description).to.equal('this is a super description') expect(videoHttp.tags).to.deep.equal([ 'tag1', 'tag2' ]) expect(videoHttp.files).to.have.lengthOf(1) const originallyPublishedAt = new Date(videoHttp.originallyPublishedAt) expect(originallyPublishedAt.getDate()).to.equal(14) expect(originallyPublishedAt.getMonth()).to.equal(0) expect(originallyPublishedAt.getFullYear()).to.equal(2019) const resMagnet = await getVideo(url, idMagnet) const videoMagnet: VideoDetails = resMagnet.body const resTorrent = await getVideo(url, idTorrent) const videoTorrent: VideoDetails = resTorrent.body for (const video of [ videoMagnet, videoTorrent ]) { expect(video.category.label).to.equal('Misc') expect(video.licence.label).to.equal('Unknown') expect(video.language.label).to.equal('Unknown') expect(video.nsfw).to.be.false expect(video.description).to.equal('this is a super torrent description') expect(video.tags).to.deep.equal([ 'tag_torrent1', 'tag_torrent2' ]) expect(video.files).to.have.lengthOf(1) } expect(videoTorrent.name).to.contain('你好 世界 720p.mp4') expect(videoMagnet.name).to.contain('super peertube2 video') } async function checkVideoServer2 (url: string, id: number | string) { const res = await getVideo(url, id) const video = res.body expect(video.name).to.equal('my super name') expect(video.category.label).to.equal('Entertainment') expect(video.licence.label).to.equal('Public Domain Dedication') expect(video.language.label).to.equal('English') expect(video.nsfw).to.be.false expect(video.description).to.equal('my super description') expect(video.tags).to.deep.equal([ 'supertag1', 'supertag2' ]) expect(video.files).to.have.lengthOf(1) } before(async function () { this.timeout(30000) // Run servers servers = await flushAndRunMultipleServers(2) await setAccessTokensToServers(servers) { const res = await getMyUserInformation(servers[0].url, servers[0].accessToken) channelIdServer1 = res.body.videoChannels[0].id } { const res = await getMyUserInformation(servers[1].url, servers[1].accessToken) channelIdServer2 = res.body.videoChannels[0].id } await doubleFollow(servers[0], servers[1]) }) it('Should import videos on server 1', async function () { this.timeout(60000) const baseAttributes = { channelId: channelIdServer1, privacy: VideoPrivacy.PUBLIC } { const attributes = immutableAssign(baseAttributes, { targetUrl: getYoutubeVideoUrl() }) const res = await importVideo(servers[0].url, servers[0].accessToken, attributes) expect(res.body.video.name).to.equal('small video - youtube') const resCaptions = await listVideoCaptions(servers[0].url, res.body.video.id) const videoCaptions: VideoCaption[] = resCaptions.body expect(videoCaptions).to.have.lengthOf(2) const enCaption = videoCaptions.filter(caption => caption.language.label === 'en')[0] expect(enCaption).to.not(undefined) expect(enCaption.language.label).to.equal('en') expect(enCaption.captionPath).to.equal(`/static/video-captions/${res.body.video.uuid}-en.vtt`) await testCaptionFile(servers[0].url, enCaption.captionPath, `WEBVTT 1 00:00:01.600 --> 00:00:04.200 English (US) 2 00:00:05.900 --> 00:00:07.999 This is a subtitle in American English 3 00:00:10.000 --> 00:00:14.000 Adding subtitles is very easy to do`) const frCaption = videoCaptions.filter(caption => caption.language.label === 'fr')[0] expect(frCaption).to.not(undefined) expect(frCaption.language.label).to.equal('fr') expect(frCaption.captionPath).to.equal(`/static/video-captions/${res.body.video.uuid}-en.vtt`) await testCaptionFile(servers[0].url, frCaption.captionPath, `WEBVTT 1 00:00:01,600 --> 00:00:04.200 Français (FR) 2 00:00:05,900 --> 00:00:07.999 C'est un sous-titre français 3 00:00:10,000 --> 00:00:14.000 Ajouter un sous-titre est vraiment facile`) } { const attributes = immutableAssign(baseAttributes, { magnetUri: getMagnetURI(), description: 'this is a super torrent description', tags: [ 'tag_torrent1', 'tag_torrent2' ] }) const res = await importVideo(servers[0].url, servers[0].accessToken, attributes) expect(res.body.video.name).to.equal('super peertube2 video') } { const attributes = immutableAssign(baseAttributes, { torrentfile: 'video-720p.torrent', description: 'this is a super torrent description', tags: [ 'tag_torrent1', 'tag_torrent2' ] }) const res = await importVideo(servers[0].url, servers[0].accessToken, attributes) expect(res.body.video.name).to.equal('你好 世界 720p.mp4') } }) it('Should list the videos to import in my videos on server 1', async function () { const res = await getMyVideos(servers[0].url, servers[0].accessToken, 0, 5, 'createdAt') expect(res.body.total).to.equal(3) const videos = res.body.data expect(videos).to.have.lengthOf(3) expect(videos[0].name).to.equal('small video - youtube') expect(videos[1].name).to.equal('super peertube2 video') expect(videos[2].name).to.equal('你好 世界 720p.mp4') }) it('Should list the videos to import in my imports on server 1', async function () { const res = await getMyVideoImports(servers[0].url, servers[0].accessToken, '-createdAt') expect(res.body.total).to.equal(3) const videoImports: VideoImport[] = res.body.data expect(videoImports).to.have.lengthOf(3) expect(videoImports[2].targetUrl).to.equal(getYoutubeVideoUrl()) expect(videoImports[2].magnetUri).to.be.null expect(videoImports[2].torrentName).to.be.null expect(videoImports[2].video.name).to.equal('small video - youtube') expect(videoImports[1].targetUrl).to.be.null expect(videoImports[1].magnetUri).to.equal(getMagnetURI()) expect(videoImports[1].torrentName).to.be.null expect(videoImports[1].video.name).to.equal('super peertube2 video') expect(videoImports[0].targetUrl).to.be.null expect(videoImports[0].magnetUri).to.be.null expect(videoImports[0].torrentName).to.equal('video-720p.torrent') expect(videoImports[0].video.name).to.equal('你好 世界 720p.mp4') }) it('Should have the video listed on the two instances', async function () { this.timeout(120000) await waitJobs(servers) for (const server of servers) { const res = await getVideosList(server.url) expect(res.body.total).to.equal(3) expect(res.body.data).to.have.lengthOf(3) const [ videoHttp, videoMagnet, videoTorrent ] = res.body.data await checkVideosServer1(server.url, videoHttp.uuid, videoMagnet.uuid, videoTorrent.uuid) } }) it('Should import a video on server 2 with some fields', async function () { this.timeout(60000) const attributes = { targetUrl: getYoutubeVideoUrl(), channelId: channelIdServer2, privacy: VideoPrivacy.PUBLIC, category: 10, licence: 7, language: 'en', name: 'my super name', description: 'my super description', tags: [ 'supertag1', 'supertag2' ] } const res = await importVideo(servers[1].url, servers[1].accessToken, attributes) expect(res.body.video.name).to.equal('my super name') }) it('Should have the videos listed on the two instances', async function () { this.timeout(120000) await waitJobs(servers) for (const server of servers) { const res = await getVideosList(server.url) expect(res.body.total).to.equal(4) expect(res.body.data).to.have.lengthOf(4) await checkVideoServer2(server.url, res.body.data[0].uuid) const [ , videoHttp, videoMagnet, videoTorrent ] = res.body.data await checkVideosServer1(server.url, videoHttp.uuid, videoMagnet.uuid, videoTorrent.uuid) } }) it('Should import a video that will be transcoded', async function () { this.timeout(120000) const attributes = { name: 'transcoded video', magnetUri: getMagnetURI(), channelId: channelIdServer2, privacy: VideoPrivacy.PUBLIC } const res = await importVideo(servers[1].url, servers[1].accessToken, attributes) const videoUUID = res.body.video.uuid await waitJobs(servers) for (const server of servers) { const res = await getVideo(server.url, videoUUID) const video: VideoDetails = res.body expect(video.name).to.equal('transcoded video') expect(video.files).to.have.lengthOf(4) } }) after(async function () { await cleanupTests(servers) }) })