streaming-test.js
1.83 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
var assert = require('assert'),
fs = require('fs'),
path = require('path'),
request = require('request'),
vows = require('vows'),
union = require('../');
vows.describe('union/streaming').addBatch({
'When using `union`': {
'a simple union server': {
topic: function () {
var self = this;
union.createServer({
buffer: false,
before: [
function (req, res, next) {
var chunks = '';
req.on('data', function (chunk) {
chunks += chunk;
});
req.on('end', function () {
self.callback(null, chunks);
});
}
]
}).listen(9000, function () {
request.post('http://localhost:9000').write('hello world');
});
},
'should receive complete POST data': function (chunks) {
assert.equal(chunks, 'hello world');
}
},
"a simple pipe to a file": {
topic: function () {
var self = this;
union.createServer({
before: [
function (req, res, next) {
var filename = path.join(__dirname, 'fixtures', 'pipe-write-test.txt'),
writeStream = fs.createWriteStream(filename);
req.pipe(writeStream);
writeStream.on('close', function () {
res.writeHead(200);
fs.createReadStream(filename).pipe(res);
});
}
]
}).listen(9044, function () {
request({
method: 'POST',
uri: 'http://localhost:9044',
body: 'hello world'
}, self.callback);
});
},
'should receive complete POST data': function (err, res, body) {
assert.equal(body, 'hello world');
}
}
}
}).export(module);