diff --git a/services/filestore/app/coffee/FSPersistorManager.coffee b/services/filestore/app/coffee/FSPersistorManager.coffee index 8eae61f651..61e497a4fb 100644 --- a/services/filestore/app/coffee/FSPersistorManager.coffee +++ b/services/filestore/app/coffee/FSPersistorManager.coffee @@ -44,10 +44,10 @@ module.exports = # opts may be {start: Number, end: Number} getFileStream: (location, name, opts, callback = (err, res)->) -> filteredName = filterName name - logger.log location:location, name:filteredName, "getting file" + logger.log location:location, filteredName:filteredName, "getting file" fs.open "#{location}/#{filteredName}", 'r', (err, fd) -> if err? - logger.err err:err, location:location, name:name, "Error reading from file" + logger.err err:err, location:location, filteredName:name, "Error reading from file" if err.code == 'ENOENT' return callback new Errors.NotFoundError(err.message), null else @@ -87,10 +87,10 @@ module.exports = deleteFile: (location, name, callback)-> filteredName = filterName name - logger.log location:location, name:filteredName, "delete file" + logger.log location:location, filteredName:filteredName, "delete file" fs.unlink "#{location}/#{filteredName}", (err) -> if err? - logger.err err:err, location:location, name:filteredName, "Error on delete." + logger.err err:err, location:location, filteredName:filteredName, "Error on delete." callback err else callback() @@ -99,24 +99,24 @@ module.exports = filteredName = filterName name.replace(/\/$/,'') rimraf "#{location}/#{filteredName}", (err) -> if err? - logger.err err:err, location:location, name:filteredName, "Error on rimraf rmdir." + logger.err err:err, location:location, filteredName:filteredName, "Error on rimraf rmdir." callback err else callback() checkIfFileExists:(location, name, callback = (err,exists)->)-> filteredName = filterName name - logger.log location:location, name:filteredName, "checking if file exists" + logger.log location:location, filteredName:filteredName, "checking if file exists" fs.exists "#{location}/#{filteredName}", (exists) -> - logger.log location:location, name:filteredName, exists:exists, "checked if file exists" + logger.log location:location, filteredName:filteredName, exists:exists, "checked if file exists" callback null, exists directorySize:(location, name, callback)-> filteredName = filterName name.replace(/\/$/,'') - logger.log location:location, name:filteredName, "get project size in file system" + logger.log location:location, filteredName:filteredName, "get project size in file system" fs.readdir "#{location}/#{filteredName}", (err, files) -> if err? - logger.err err:err, location:location, name:filteredName, "something went wrong listing prefix in aws" + logger.err err:err, location:location, filteredName:filteredName, "something went wrong listing prefix in aws" return callback(err) totalSize = 0 _.each files, (entry)->