OutputFileFinder.coffee 1.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657
  1. async = require "async"
  2. fs = require "fs"
  3. Path = require "path"
  4. spawn = require("child_process").spawn
  5. logger = require "logger-sharelatex"
  6. module.exports = OutputFileFinder =
  7. findOutputFiles: (resources, directory, callback = (error, outputFiles) ->) ->
  8. incomingResources = {}
  9. for resource in resources
  10. incomingResources[resource.path] = true
  11. logger.log directory: directory, "getting output files"
  12. OutputFileFinder._getAllFiles directory, (error, allFiles = []) ->
  13. return callback(error) if error?
  14. jobs = []
  15. outputFiles = []
  16. for file in allFiles
  17. do (file) ->
  18. jobs.push (callback) ->
  19. if incomingResources[file]
  20. return callback()
  21. else
  22. outputFiles.push {
  23. path: file
  24. type: file.match(/\.([^\.]+)$/)?[1]
  25. }
  26. callback()
  27. async.series jobs, (error) ->
  28. return callback(error) if error?
  29. callback null, outputFiles
  30. _getAllFiles: (directory, _callback = (error, fileList) ->) ->
  31. callback = (error, fileList) ->
  32. _callback(error, fileList)
  33. _callback = () ->
  34. args = [directory, "-name", ".cache", "-prune", "-o", "-type", "f", "-print"]
  35. logger.log args: args, "running find command"
  36. proc = spawn("find", args)
  37. stdout = ""
  38. proc.stdout.on "data", (chunk) ->
  39. stdout += chunk.toString()
  40. proc.on "error", callback
  41. proc.on "close", (code) ->
  42. if code != 0
  43. logger.warn {directory, code}, "find returned error, directory likely doesn't exist"
  44. return callback null, []
  45. fileList = stdout.trim().split("\n")
  46. fileList = fileList.map (file) ->
  47. # Strip leading directory
  48. path = Path.relative(directory, file)
  49. return callback null, fileList