TpdsUpdateHandler.coffee 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. updateMerger = require('./UpdateMerger')
  2. logger = require('logger-sharelatex')
  3. projectLocator = require('../Project/ProjectLocator')
  4. projectCreationHandler = require('../Project/ProjectCreationHandler')
  5. projectDeleter = require('../Project/ProjectDeleter')
  6. ProjectRootDocManager = require "../Project/ProjectRootDocManager"
  7. FileTypeManager = require('../Uploads/FileTypeManager')
  8. commitMessage = "Before update from Dropbox"
  9. module.exports =
  10. newUpdate: (user_id, projectName, path, updateRequest, source, callback)->
  11. getOrCreateProject = (cb)=>
  12. projectLocator.findUsersProjectByName user_id, projectName, (err, project)=>
  13. logger.log user_id:user_id, filePath:path, projectName:projectName, "handling new update from tpds"
  14. if !project?
  15. projectCreationHandler.createBlankProject user_id, projectName, (err, project)=>
  16. # have a crack at setting the root doc after a while, on creation we won't have it yet, but should have
  17. # been sent it it within 30 seconds
  18. setTimeout (-> ProjectRootDocManager.setRootDocAutomatically project._id ), @_rootDocTimeoutLength
  19. cb err, project
  20. else
  21. cb err, project
  22. getOrCreateProject (err, project)->
  23. return callback(err) if err?
  24. FileTypeManager.shouldIgnore path, (err, shouldIgnore)->
  25. if shouldIgnore
  26. return callback()
  27. updateMerger.mergeUpdate user_id, project._id, path, updateRequest, source, callback
  28. deleteUpdate: (user_id, projectName, path, source, callback)->
  29. logger.log user_id:user_id, filePath:path, "handling delete update from tpds"
  30. projectLocator.findUsersProjectByName user_id, projectName, (err, project)->
  31. if !project?
  32. logger.log user_id:user_id, filePath:path, projectName:projectName, "project not found from tpds update, ignoring folder or project"
  33. return callback()
  34. if path == "/"
  35. logger.log user_id:user_id, filePath:path, projectName:projectName, project_id:project._id, "project found for delete update, path is root so marking project as deleted"
  36. return projectDeleter.markAsDeletedByExternalSource project._id, callback
  37. else
  38. updateMerger.deleteUpdate project._id, path, source, (err)->
  39. callback(err)
  40. _rootDocTimeoutLength : 30 * 1000