OutputFileFinder.coffee 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  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. if !incomingResources[file]
  18. outputFiles.push {
  19. path: file
  20. type: file.match(/\.([^\.]+)$/)?[1]
  21. }
  22. callback null, outputFiles
  23. _getAllFiles: (directory, _callback = (error, fileList) ->) ->
  24. callback = (error, fileList) ->
  25. _callback(error, fileList)
  26. _callback = () ->
  27. args = [directory, "-name", ".cache", "-prune", "-o", "-type", "f", "-print"]
  28. logger.log args: args, "running find command"
  29. proc = spawn("find", args)
  30. stdout = ""
  31. proc.stdout.on "data", (chunk) ->
  32. stdout += chunk.toString()
  33. proc.on "error", callback
  34. proc.on "close", (code) ->
  35. if code != 0
  36. logger.warn {directory, code}, "find returned error, directory likely doesn't exist"
  37. return callback null, []
  38. fileList = stdout.trim().split("\n")
  39. fileList = fileList.map (file) ->
  40. # Strip leading directory
  41. path = Path.relative(directory, file)
  42. return callback null, fileList