aboutsummaryrefslogblamecommitdiffhomepage
path: root/tests/api/singlePod.js
blob: 7621d766cbf43ee9586db708420b920019a3152b (plain) (tree)
1
2
3
4
5
6
7
8
9


               
                              

                            
                        
 
                                                                   

                          
                                

                                             




                            
                         
 








                                                    
            




                                                                


                                                  

                                                    
 

                                           
 

              



                                                   
                                                                                               





                                                          

                                                    
 

                                           
 




                                                                  
 
                            
 



                                                                     
 
                
          
        

      
                                                   

                                                        
 

                                           
 




                                                                  
 

              


                                                    

                                                           
 

                                           
 

              

      
                                                   

                                                       
 

                                                                               
 

                                          
          
        


                                                  

                                                    
 

                                           
 

              







                                         
                              





              
;(function () {
  'use strict'

  var async = require('async')
  var chai = require('chai')
  var expect = chai.expect
  var fs = require('fs')

  var webtorrent = require(__dirname + '/../../lib/webTorrentNode')
  webtorrent.silent = true

  var utils = require('./utils')

  describe('Test a single pod', function () {
    var app = null
    var url = ''
    var video_id = -1

    before(function (done) {
      this.timeout(20000)

      async.series([
        function (next) {
          utils.flushTests(next)
        },
        function (next) {
          utils.runServer(1, function (app1, url1) {
            app = app1
            url = url1
            next()
          })
        },
        function (next) {
          webtorrent.create({ host: 'client', port: '1' }, next)
        }
      ], done)
    })

    it('Should not have videos', function (done) {
      utils.getVideosList(url, function (err, res) {
        if (err) throw err

        expect(res.body).to.be.an('array')
        expect(res.body.length).to.equal(0)

        done()
      })
    })

    it('Should upload the video', function (done) {
      this.timeout(5000)
      utils.uploadVideo(url, 'my super name', 'my super description', 'video_short.webm', done)
    })

    it('Should seed the uploaded video', function (done) {
      // Yes, this could be long
      this.timeout(60000)

      utils.getVideosList(url, function (err, res) {
        if (err) throw err

        expect(res.body).to.be.an('array')
        expect(res.body.length).to.equal(1)

        var video = res.body[0]
        expect(video.name).to.equal('my super name')
        expect(video.description).to.equal('my super description')
        expect(video.podUrl).to.equal('http://localhost:9001')
        expect(video.magnetUri).to.exist

        video_id = video._id

        webtorrent.add(video.magnetUri, function (torrent) {
          expect(torrent.files).to.exist
          expect(torrent.files.length).to.equal(1)
          expect(torrent.files[0].path).to.exist.and.to.not.equal('')

          done()
        })
      })
    })

    it('Should search the video', function (done) {
      utils.searchVideo(url, 'my', function (err, res) {
        if (err) throw err

        expect(res.body).to.be.an('array')
        expect(res.body.length).to.equal(1)

        var video = res.body[0]
        expect(video.name).to.equal('my super name')
        expect(video.description).to.equal('my super description')
        expect(video.podUrl).to.equal('http://localhost:9001')
        expect(video.magnetUri).to.exist

        done()
      })
    })

    it('Should not find a search', function (done) {
      utils.searchVideo(url, 'hello', function (err, res) {
        if (err) throw err

        expect(res.body).to.be.an('array')
        expect(res.body.length).to.equal(0)

        done()
      })
    })

    it('Should remove the video', function (done) {
      utils.removeVideo(url, video_id, function (err) {
        if (err) throw err

        fs.readdir(__dirname + '/../../test1/uploads/', function (err, files) {
          if (err) throw err

          expect(files.length).to.equal(0)
          done()
        })
      })
    })

    it('Should not have videos', function (done) {
      utils.getVideosList(url, function (err, res) {
        if (err) throw err

        expect(res.body).to.be.an('array')
        expect(res.body.length).to.equal(0)

        done()
      })
    })

    after(function (done) {
      process.kill(-app.pid)
      process.kill(-webtorrent.app.pid)

      // Keep the logs if the test failed
      if (this.ok) {
        utils.flushTests(done)
      } else {
        done()
      }
    })
  })
})()