diff --git a/services/filestore/app/coffee/FSPersistorManager.coffee b/services/filestore/app/coffee/FSPersistorManager.coffee index 2ade1f3a5b..d1b72806cf 100644 --- a/services/filestore/app/coffee/FSPersistorManager.coffee +++ b/services/filestore/app/coffee/FSPersistorManager.coffee @@ -3,6 +3,7 @@ fs = require("fs") LocalFileWriter = require("./LocalFileWriter") Errors = require('./Errors') rimraf = require("rimraf") +_ = require "underscore" filterName = (key) -> return key.replace /\//g, "_" @@ -29,9 +30,7 @@ module.exports = # opts may be {start: Number, end: Number} getFileStream: (location, name, opts, _callback = (err, res)->) -> - callback = (args...) -> - _callback(args...) - _callback = () -> + callback = _.once _callback filteredName = filterName name logger.log location:location, name:filteredName, "getting file" sourceStream = fs.createReadStream "#{location}/#{filteredName}", opts diff --git a/services/filestore/app/coffee/FileHandler.coffee b/services/filestore/app/coffee/FileHandler.coffee index a0e80dde71..917df653db 100644 --- a/services/filestore/app/coffee/FileHandler.coffee +++ b/services/filestore/app/coffee/FileHandler.coffee @@ -63,7 +63,7 @@ module.exports = PersistorManager.getFileStream bucket, convertedKey, callback _convertFile: (bucket, originalKey, opts, callback)-> - @_writeS3FileToDisk bucket, originalKey, (err, originalFsPath)-> + @_writeS3FileToDisk bucket, originalKey, opts, (err, originalFsPath)-> if err? return callback(err) done = (err, destPath)->