InactiveProjectManager.coffee 2.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859
  1. async = require("async")
  2. _ = require("underscore")
  3. logger = require("logger-sharelatex")
  4. DocstoreManager = require("../Docstore/DocstoreManager")
  5. ProjectGetter = require("../Project/ProjectGetter")
  6. ProjectUpdateHandler = require("../Project/ProjectUpdateHandler")
  7. Project = require("../../models/Project").Project
  8. MILISECONDS_IN_DAY = 86400000
  9. module.exports = InactiveProjectManager =
  10. reactivateProjectIfRequired: (project_id, callback)->
  11. ProjectGetter.getProject project_id, {active:true}, (err, project)->
  12. if err?
  13. logger.err err:err, project_id:project_id, "error getting project"
  14. return callback(err)
  15. logger.log project_id:project_id, active:project.active, "seeing if need to reactivate project"
  16. if project.active
  17. return callback()
  18. DocstoreManager.unarchiveProject project_id, (err)->
  19. if err?
  20. logger.err err:err, project_id:project_id, "error reactivating project in docstore"
  21. return callback(err)
  22. ProjectUpdateHandler.markAsActive project_id, callback
  23. deactivateOldProjects: (limit = 10, daysOld = 360, callback)->
  24. oldProjectDate = new Date() - (MILISECONDS_IN_DAY * daysOld)
  25. logger.log oldProjectDate:oldProjectDate, limit:limit, daysOld:daysOld, "starting process of deactivating old projects"
  26. Project.find()
  27. .where("lastOpened").lt(oldProjectDate)
  28. .where("active").equals(true)
  29. .select("_id")
  30. .limit(limit)
  31. .exec (err, projects)->
  32. if err?
  33. logger.err err:err, "could not get projects for deactivating"
  34. jobs = _.map projects, (project)->
  35. return (cb)->
  36. InactiveProjectManager.deactivateProject project._id, cb
  37. logger.log numberOfProjects:projects?.length, "deactivating projects"
  38. async.series jobs, (err)->
  39. if err?
  40. logger.err err:err, "error deactivating projects"
  41. callback err, projects
  42. deactivateProject: (project_id, callback)->
  43. logger.log project_id:project_id, "deactivating inactive project"
  44. jobs = [
  45. (cb)-> DocstoreManager.archiveProject project_id, cb
  46. (cb)-> ProjectUpdateHandler.markAsInactive project_id, cb
  47. ]
  48. async.series jobs, (err)->
  49. if err?
  50. logger.err err:err, project_id:project_id, "error deactivating project"
  51. callback(err)