TpdsController.coffee 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. tpdsUpdateHandler = require('./TpdsUpdateHandler')
  2. UpdateMerger = require "./UpdateMerger"
  3. logger = require('logger-sharelatex')
  4. Path = require('path')
  5. metrics = require("metrics-sharelatex")
  6. module.exports =
  7. # mergeUpdate and deleteUpdate are used by Dropbox, where the project is only passed as the name, as the
  8. # first part of the file path. They have to check the project exists, find it, and create it if not.
  9. # They also ignore 'noisy' files like .DS_Store, .gitignore, etc.
  10. mergeUpdate: (req, res)->
  11. metrics.inc("tpds.merge-update")
  12. {filePath, user_id, projectName} = parseParams(req)
  13. source = req.headers["x-sl-update-source"] or "unknown"
  14. logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], projectName:projectName, source: source, "reciving update request from tpds"
  15. tpdsUpdateHandler.newUpdate user_id, projectName, filePath, req, source, (err)->
  16. logger.log user_id:user_id, filePath:filePath, fullPath:req.params[0], "sending response that tpdsUpdate has been completed"
  17. if err?
  18. logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
  19. res.sendStatus(500)
  20. else
  21. logger.log user_id:user_id, filePath:filePath, projectName:projectName, "telling tpds update has been processed"
  22. res.sendStatus 200
  23. deleteUpdate: (req, res)->
  24. metrics.inc("tpds.delete-update")
  25. {filePath, user_id, projectName} = parseParams(req)
  26. source = req.headers["x-sl-update-source"] or "unknown"
  27. logger.log user_id:user_id, filePath:filePath, projectName:projectName, fullPath:req.params[0], source: source, "reciving delete request from tpds"
  28. tpdsUpdateHandler.deleteUpdate user_id, projectName, filePath, source, (err)->
  29. if err?
  30. logger.err err:err, user_id:user_id, filePath:filePath, "error reciving update from tpds"
  31. res.sendStatus(500)
  32. else
  33. logger.log user_id:user_id, filePath:filePath, projectName:projectName, "telling tpds delete has been processed"
  34. res.sendStatus 200
  35. # updateProjectContents and deleteProjectContents are used by GitHub. The project_id is known so we
  36. # can skip right ahead to creating/updating/deleting the file. These methods will not ignore noisy
  37. # files like .DS_Store, .gitignore, etc because people are generally more explicit with the files they
  38. # want in git.
  39. updateProjectContents: (req, res, next = (error) ->) ->
  40. {project_id} = req.params
  41. path = "/" + req.params[0] # UpdateMerger expects leading slash
  42. source = req.headers["x-sl-update-source"] or "unknown"
  43. logger.log project_id: project_id, path: path, source: source, "received project contents update"
  44. UpdateMerger.mergeUpdate null, project_id, path, req, source, (error) ->
  45. return next(error) if error?
  46. res.sendStatus(200)
  47. deleteProjectContents: (req, res, next = (error) ->) ->
  48. {project_id} = req.params
  49. path = "/" + req.params[0] # UpdateMerger expects leading slash
  50. source = req.headers["x-sl-update-source"] or "unknown"
  51. logger.log project_id: project_id, path: path, source: source, "received project contents delete request"
  52. UpdateMerger.deleteUpdate null, project_id, path, source, (error) ->
  53. return next(error) if error?
  54. res.sendStatus(200)
  55. parseParams: parseParams = (req)->
  56. path = req.params[0]
  57. user_id = req.params.user_id
  58. path = Path.join("/",path)
  59. if path.substring(1).indexOf('/') == -1
  60. filePath = "/"
  61. projectName = path.substring(1)
  62. else
  63. filePath = path.substring(path.indexOf("/",1))
  64. projectName = path.substring(0, path.indexOf("/",1))
  65. projectName = projectName.replace("/","")
  66. return filePath:filePath, user_id:user_id, projectName:projectName