2011-12-02 51 views
3

我最近将环境升级到Node v0.6.3,并且一些文件上传功能在工作停止前正常工作。我一个上传文件的形式向以下页面:快速/连接窗体事件监听器没有触发

var fs = require('fs'), 
    client = require('../app'), 
    exec = require('child_process').exec, 
    socket = require('../socket') 

var supported = [ 'image/jpeg', 
        'image/pjpeg', 
        'image/bmp', 
        'image/gif', 
        'image/tiff', 
        'image/png'] 

var maxSize = 204800; 

module.exports = function(req, res) { 
    console.log(JSON.stringify(req.form)); 
    var tmpPath = ''; 
    req.form.on('fileBegin', function(err, fileInfo) { 
    console.log('upload file begin') 
    if (fileInfo.path) {tmpPath = fileInfo.path}; 
    socket.emit('attachment_upload_started', req.query.user, {friend: req.query.friend}, []); 
    }); 

    req.form.on('progress', function(bytesReceived, bytesExpected) { 
    var percent = (bytesReceived/bytesExpected * 100) | 0; 
    socket.emit('attachment_progress', req.query.user, {progress: percent, friend: req.query.friend}, []);  
     var child = exec('file --mime-type ' + tmpPath, function (err, stdout, stderr) { 
      var mimetype = stdout.substring(stdout.lastIndexOf(':') + 2, stdout.lastIndexOf('\n')); 
      if (!err && mimetype && supported.indexOf(mimetype)==-1 && mimetype!='Can\'t read SAT') { 
      socket.emit('attachment_error', req.query.user, {type: 'format', friend: req.query.friend}, []); 
      req.connection.destroy(); 
      req.connection.resume = function(){}; 
      console.log(mimetype) 
      console.log(err); 
      } 

      if (bytesExpected > maxSize) { 
      socket.emit('attachment_error', req.query.user, {type: 'size', friend: req.query.friend}, []); 
      req.connection.destroy(); 
      req.connection.resume = function(){} 
      } 
     }); 
     }); 

    req.form.complete(function(err, fields, files){ 
    console.log('form complete'); 
    if (!err) { 
     if (supported.indexOf(files.upload.mime)==-1) { 
     console.log(files.upload.mime); 
     socket.emit('attachment_error', req.query.user, {type: 'format', friend: req.query.friend}, []); 
     } 
     else { 
     socket.emit('attachment_complete', req.query.user, {friend: req.query.friend, file: files.upload}, []); 
     } 
    } 
    else { 
     console.log('err'); 
    } 
    res.redirect('/iattachment?user='+req.query.user+'&friend='+req.query.friend); 
    }); 
} 

的文件确实是让我的/ tmp目录,但没有req.form.complete内的代码,或req.form.on ('progress'),req.form.on('fileBegin')监听器被执行。任何帮助,将不胜感激!

回答

3

你在使用express.bodyParser吗?

问题是,连接,表示基于的模块,现在包括强大的2.0版本,但没有人打扰更改文档或示例。 (其实,现在就让我这样做吧。)

如果您已经在使用bodyParser,临时文件已经被创建,并且由于请求已经被处理并且流全部被读取,您的代码并不真正在做任何东西,并等待输入。

检查“req.body”,它应该包含所有文件信息。否则,请尝试删除express.bodyParser。

+0

是的,我正在使用bodyParser。删除它似乎已经完成了这个伎俩,但破坏了其他一些功能。谢谢你的帮助。 –

0

您需要bodyParser来解析POST数据。

尝试寻找在这个http://senchalabs.github.com/connect/middleware-bodyParser.html

删除express.bodyParser.parse [ '的multipart/form-data的'];

我还没有能够得到这个工作在我的目的呢。我试图直接使用强大的,所以我可以发送进度条。但根本没有任何东西被触发。