Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- var getReceiver = function () {
- var receiver = new Writable({objectMode: true});
- receiver._write = function (file, enc, done) {
- file.fd = directory + file.fd;
- var fileStream = fs.createWriteStream(file.fd);
- fileStream.on('error', function (err) {
- done(err);
- }).once('finish', function () {
- done();
- });
- var fileLength = 0;
- file.on('data', function (chunk) {
- fileLength = fileLength + chunk.length;
- if (fileLength > maxFileSize) {
- var err = new Error('upload exceeds maxFileSize.');
- file.unpipe();
- fs.unlink(file.fd, function (fsErr) {
- if (fsErr && (typeof fsErr !== 'object' || fsErr.code !== 'ENOENT')) {
- return done([err].concat([fsErr]));
- }
- });
- return done(err);
- }
- });
- file.pipe(fileStream);
- };
- return receiver;
- };
- req.file('file').upload(getReceiver(), function (err, uploadedFiles) {
- if (err) {
- return res.badRequest(err);
- }
- // Do stuff
- }
- });
- });
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement