+ await servers[0].servers.waitUntilLog('Run hook filter:api.search.video-playlists.local.list.params', 1)
+ await servers[0].servers.waitUntilLog('Run hook filter:api.search.video-playlists.local.list.result', 1)
+ await servers[0].servers.waitUntilLog('Run hook filter:api.search.video-playlists.index.list.params', 1)
+ await servers[0].servers.waitUntilLog('Run hook filter:api.search.video-playlists.index.list.result', 1)
+ })
+ })
+
+ describe('Upload/import/live attributes filters', function () {
+
+ before(async function () {
+ await servers[0].config.enableLive({ transcoding: false, allowReplay: false })
+ await servers[0].config.enableImports()
+ await servers[0].config.disableTranscoding()
+ })
+
+ it('Should run filter:api.video.upload.video-attribute.result', async function () {
+ for (const mode of [ 'legacy' as 'legacy', 'resumable' as 'resumable' ]) {
+ const { id } = await servers[0].videos.upload({ attributes: { name: 'video', description: 'upload' }, mode })
+
+ const video = await servers[0].videos.get({ id })
+ expect(video.description).to.equal('upload - filter:api.video.upload.video-attribute.result')
+ }
+ })
+
+ it('Should run filter:api.video.import-url.video-attribute.result', async function () {
+ const attributes = {
+ name: 'video',
+ description: 'import url',
+ channelId: servers[0].store.channel.id,
+ targetUrl: FIXTURE_URLS.goodVideo,
+ privacy: VideoPrivacy.PUBLIC
+ }
+ const { video: { id } } = await servers[0].imports.importVideo({ attributes })
+
+ const video = await servers[0].videos.get({ id })
+ expect(video.description).to.equal('import url - filter:api.video.import-url.video-attribute.result')
+ })
+
+ it('Should run filter:api.video.import-torrent.video-attribute.result', async function () {
+ const attributes = {
+ name: 'video',
+ description: 'import torrent',
+ channelId: servers[0].store.channel.id,
+ magnetUri: FIXTURE_URLS.magnet,
+ privacy: VideoPrivacy.PUBLIC
+ }
+ const { video: { id } } = await servers[0].imports.importVideo({ attributes })
+
+ const video = await servers[0].videos.get({ id })
+ expect(video.description).to.equal('import torrent - filter:api.video.import-torrent.video-attribute.result')
+ })
+
+ it('Should run filter:api.video.live.video-attribute.result', async function () {
+ const fields = {
+ name: 'live',
+ description: 'live',
+ channelId: servers[0].store.channel.id,
+ privacy: VideoPrivacy.PUBLIC
+ }
+ const { id } = await servers[0].live.create({ fields })
+
+ const video = await servers[0].videos.get({ id })
+ expect(video.description).to.equal('live - filter:api.video.live.video-attribute.result')
+ })
+ })
+
+ describe('Stats filters', function () {
+
+ it('Should run filter:api.server.stats.get.result', async function () {
+ const data = await servers[0].stats.get()
+
+ expect((data as any).customStats).to.equal(14)
+ })
+
+ })
+
+ describe('Job queue filters', function () {
+ let videoUUID: string
+
+ before(async function () {
+ this.timeout(120_000)
+
+ await servers[0].config.enableMinimumTranscoding()
+ const { uuid } = await servers[0].videos.quickUpload({ name: 'studio' })
+
+ const video = await servers[0].videos.get({ id: uuid })
+ expect(video.duration).at.least(2)
+ videoUUID = video.uuid
+
+ await waitJobs(servers)
+
+ await servers[0].config.enableStudio()
+ })
+
+ it('Should run filter:job-queue.process.params', async function () {
+ this.timeout(120_000)
+
+ await servers[0].videoStudio.createEditionTasks({
+ videoId: videoUUID,
+ tasks: [
+ {
+ name: 'add-intro',
+ options: {
+ file: 'video_very_short_240p.mp4'
+ }
+ }
+ ]
+ })
+
+ await waitJobs(servers)
+
+ await servers[0].servers.waitUntilLog('Run hook filter:job-queue.process.params', 1, false)
+
+ const video = await servers[0].videos.get({ id: videoUUID })
+ expect(video.duration).at.most(2)
+ })
+
+ it('Should run filter:job-queue.process.result', async function () {
+ await servers[0].servers.waitUntilLog('Run hook filter:job-queue.process.result', 1, false)
+ })
+ })
+
+ describe('Transcoding filters', async function () {
+
+ it('Should run filter:transcoding.auto.resolutions-to-transcode.result', async function () {
+ const { uuid } = await servers[0].videos.quickUpload({ name: 'transcode-filter' })
+
+ await waitJobs(servers)
+
+ const video = await servers[0].videos.get({ id: uuid })
+ expect(video.files).to.have.lengthOf(2)
+ expect(video.files.find(f => f.resolution.id === 100 as any)).to.exist
+ })
+ })
+
+ describe('Video channel filters', async function () {
+
+ it('Should run filter:api.video-channels.list.params', async function () {
+ const { data } = await servers[0].channels.list({ start: 0, count: 0 })
+
+ // plugin do +1 to the count parameter
+ expect(data).to.have.lengthOf(1)
+ })
+
+ it('Should run filter:api.video-channels.list.result', async function () {
+ const { total } = await servers[0].channels.list({ start: 0, count: 1 })
+
+ // plugin do +1 to the total parameter
+ expect(total).to.equal(4)
+ })
+
+ it('Should run filter:api.video-channel.get.result', async function () {
+ const channel = await servers[0].channels.get({ channelName: 'root_channel' })
+ expect(channel.displayName).to.equal('Main root channel <3')