server/tests/api/video-transcoder.js

   1 /* eslint-disable no-unused-expressions */
   2
   3 'use strict'
   4
   5 const chai = require('chai')
   6 const each = require('async/each')
   7 const expect = chai.expect
   8 const series = require('async/series')
   9 const webtorrent = new (require('webtorrent'))()
  10
  11 const loginUtils = require('../utils/login')
  12 const serversUtils = require('../utils/servers')
  13 const videosUtils = require('../utils/videos')
  14
  15 describe('Test video transcoding', function () {
  16   let servers = []
  17
  18   before(function (done) {
  19     this.timeout(30000)
  20
  21     series([
  22       // Run servers
  23       function (next) {
  24         serversUtils.flushAndRunMultipleServers(2, function (serversRun) {
  25           servers = serversRun
  26           next()
  27         })
  28       },
  29       // Get the access tokens
  30       function (next) {
  31         each(servers, function (server, callbackEach) {
  32           loginUtils.loginAndGetAccessToken(server, function (err, accessToken) {
  33             if (err) return callbackEach(err)
  34
  35             server.accessToken = accessToken
  36             callbackEach()
  37           })
  38         }, next)
  39       }
  40     ], done)
  41   })
  42
  43   it('Should not transcode video on server 1', function (done) {
  44     this.timeout(60000)
  45
  46     const videoAttributes = {
  47       name: 'my super name for pod 1',
  48       description: 'my super description for pod 1',
  49       fixture: 'video_short.webm'
  50     }
  51     videosUtils.uploadVideo(servers[0].url, servers[0].accessToken, videoAttributes, function (err) {
  52       if (err) throw err
  53
  54       setTimeout(function () {
  55         videosUtils.getVideosList(servers[0].url, function (err, res) {
  56           if (err) throw err
  57
  58           const video = res.body.data[0]
  59           const magnetUri = video.files[0].magnetUri
  60           expect(magnetUri).to.match(/\.webm/)
  61
  62           webtorrent.add(magnetUri, function (torrent) {
  63             expect(torrent.files).to.exist
  64             expect(torrent.files.length).to.equal(1)
  65             expect(torrent.files[0].path).match(/\.webm$/)
  66
  67             done()
  68           })
  69         })
  70       }, 30000)
  71     })
  72   })
  73
  74   it('Should transcode video on server 2', function (done) {
  75     this.timeout(60000)
  76
  77     const videoAttributes = {
  78       name: 'my super name for pod 2',
  79       description: 'my super description for pod 2',
  80       fixture: 'video_short.webm'
  81     }
  82     videosUtils.uploadVideo(servers[1].url, servers[1].accessToken, videoAttributes, function (err) {
  83       if (err) throw err
  84
  85       setTimeout(function () {
  86         videosUtils.getVideosList(servers[1].url, function (err, res) {
  87           if (err) throw err
  88
  89           const video = res.body.data[0]
  90           const magnetUri = video.files[0].magnetUri
  91           expect(magnetUri).to.match(/\.mp4/)
  92
  93           webtorrent.add(magnetUri, function (torrent) {
  94             expect(torrent.files).to.exist
  95             expect(torrent.files.length).to.equal(1)
  96             expect(torrent.files[0].path).match(/\.mp4$/)
  97
  98             done()
  99           })
 100         })
 101       }, 30000)
 102     })
 103   })
 104
 105   after(function (done) {
 106     servers.forEach(function (server) {
 107       process.kill(-server.app.pid)
 108     })
 109
 110     // Keep the logs if the test failed
 111     if (this.ok) {
 112       serversUtils.flushTests(done)
 113     } else {
 114       done()
 115     }
 116   })
 117 })