for gehirn

app-chunking-uploader.js

var http          = require("http");
var util          = require("util");
var fs            = require('fs');
var StreamChunker = require('streamchunker');

var server = http.createServer(function(req, res) {
	var name = req.url.replace('/', 'recv.');
	var file = fs.createWriteStream(name);
	
	var streamChunker = new StreamChunker({
		chunkSize: 1024 * 1024 * 4
	});
	
	var chunkCount = 0;
	
	streamChunker.on('chunk', function(chunk) {
		var chunkName = [name, chunkCount.toString(10)].join('.');
		var chunkFile = fs.createWriteStream(chunkName);
		
		chunk.on('data', function(buffer) {
			chunkFile.write(buffer);
		});
		chunk.on('end', function() {
			++chunkCount;
			chunkFile.end();
		});
	});
	
	req.on('data', function(buffer) {
		file.write(buffer);
	});
	
	req.on('end', function() {
		file.end();
		
		console.log('file:', name);
		
		res.writeHead(200, {'Content-type': 'text/plain'});
		res.end();
	});
	
	req.pipe(streamChunker);
});

server.listen(1421);