verdaccio/test/functional/incomplete.js

var assert = require('assert')
  , ex = module.exports

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()
					})
				}
			})
		})
	})
}