verdaccio/test/functional/incomplete.js

var assert = require('assert')

module.exports = function() {
  var server = process.server
  var express = process.express

  describe('Incomplete', function() {
    var on_tarball

    before(function() {
      express.get('/testexp-incomplete', function(_, res) {
        res.send({
          "name": "testexp-incomplete",
          "versions": {
            "0.1.0": {
              "name": "testexp_tags",
              "version": "0.1.0",
              "dist": {
                "shasum": "fake",
                "tarball": "http://localhost:55550/testexp-incomplete/-/content-length.tar.gz"
              }
            },
            "0.1.1": {
              "name": "testexp_tags",
              "version": "0.1.1",
              "dist": {
                "shasum": "fake",
                "tarball": "http://localhost:55550/testexp-incomplete/-/chunked.tar.gz"
              }
            }
          }
        })
      })
    })

    ;['content-length', 'chunked'].forEach(function(type) {
      it('should not store tarballs / ' + type, function(_cb) {
        var called
        express.get('/testexp-incomplete/-/'+type+'.tar.gz', function(_, res) {
          if (called) return res.socket.destroy()
          called = true
          if (type !== 'chunked') res.header('content-length', 1e6)
          res.write('test test test\n')
          setTimeout(function() {
            res.socket.write('200\nsss\n')
            res.socket.destroy()
            cb()
          }, 10)
        })

        server.request({uri:'/testexp-incomplete/-/'+type+'.tar.gz'}, function(err, res, body) {
          if (type !== 'chunked') assert.equal(res.headers['content-length'], 1e6)
          assert(body.match(/test test test/))
        })

        function cb() {
          server.request({uri:'/testexp-incomplete/-/'+type+'.tar.gz'}, function(err, res, body) {
            assert.equal(body.error, 'internal server error')
            _cb()
          })
        }
      })
    })
  })
}