計算文件哈希並保存文件

Question

用戶將文件上傳到我的快速應用程序。我需要計算上傳文件的哈希值，然後使用計算出的哈希值作爲文件名將文件寫入磁盤。我嘗試使用下面的代碼來做到這一點：

function storeFileStream(file, next) { 
    createFileHash(file, function(err, hash) { 
     if (err) { 
      return next(err); 
     } 

     var fileName = path.join(config.storagePath, hash), 
      stream = fs.createWriteStream(fileName); 

     stream.on('error', function(err) { 
      return next(err); 
     }); 
     stream.on('finish', function() { 
      return next(); 
     }); 

     file.pipe(stream); 
    }); 
} 

function createFileHash(file, next) { 
    var hash = crypto.createHash('sha1'); 
    hash.setEncoding('hex'); 

    file.on('error', function(err) { 
     return next(err); 
    }); 
    file.on('end', function(data) { 
     hash.end(); 
     return next(null, hash.read()); 
    }); 

    file.pipe(hash); 
} 

的問題是，在我calc下文件哈希所著的文件大小爲0。什麼是不解決這個任務的最佳方法是什麼？

更新 根據@poke建議我嘗試複製我的流。現在我的代碼是：

function storeFileStream(file, next) { 
    var s1 = new pass; 
    var s2 = new pass; 
    file.pipe(s1); 
    file.pipe(s2);   

    createFileHash(s1, function(err, hash) { 
     if (err) { 
      return next(err); 
     } 

     var fileName = path.join(config.storagePath, hash), 
      stream = fs.createWriteStream(fileName); 

     stream.on('error', function(err) { 
      return next(err); 
     }); 
     stream.on('finish', function() { 
      return next(); 
     }); 

     s2.pipe(stream); 
    }); 
} 

function createFileHash(file, next) { 
    var hash = crypto.createHash('sha1'); 
    hash.setEncoding('hex'); 

    file.on('error', function(err) { 
     return next(err); 
    }); 
    file.on('end', function(data) { 
     hash.end(); 
     return next(null, hash.read()); 
    }); 

    file.pipe(hash); 
} 

這段代碼的問題是，事件end和finish不emited。如果我評論file.pipe(s2);事件被證實，但我再次得到我的起源問題。

Answer 1

此代碼解決這個問題：

var s1 = new passThrough, 
    s2 = new passThrough; 

file.on('data', function(data) { 
    s1.write(data); 
    s2.write(data); 
}); 
file.on('end', function() { 
    s1.end(); 
    s2.end(); 
}); 

Answer 2

您可以使用async模塊（未測試，但應工作）：

async.waterfall([ 
    function(done) { 
     var hash = crypto.createHash('sha1'); 
     hash.setEncoding('hex'); 

     file.on('error', function(err) { 
      done(err); 
     }); 
     file.on('end', function(data) { 
      done(null, hash.read); 
     }); 

     file.pipe(hash); 

    }, 
    function(hash, done) { 
     var fileName = path.join(config.storagePath, hash), 
      stream = fs.createWriteStream(fileName); 

     stream.on('error', function(err) { 
      done(err); 
     }); 
     stream.on('finish', function() { 
      done(null); 
     }); 

     file.pipe(stream); 
    } 
], function (err) { 
    console.log("Everything is done!"); 
});