EditorController.coffee 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218
  1. logger = require('logger-sharelatex')
  2. Metrics = require('metrics-sharelatex')
  3. sanitize = require('sanitizer')
  4. ProjectEntityHandler = require('../Project/ProjectEntityHandler')
  5. ProjectOptionsHandler = require('../Project/ProjectOptionsHandler')
  6. ProjectDetailsHandler = require('../Project/ProjectDetailsHandler')
  7. ProjectDeleter = require("../Project/ProjectDeleter")
  8. DocumentUpdaterHandler = require('../DocumentUpdater/DocumentUpdaterHandler')
  9. EditorRealTimeController = require("./EditorRealTimeController")
  10. async = require('async')
  11. LockManager = require("../../infrastructure/LockManager")
  12. _ = require('underscore')
  13. module.exports = EditorController =
  14. setDoc: (project_id, doc_id, user_id, docLines, source, callback = (err)->)->
  15. DocumentUpdaterHandler.setDocument project_id, doc_id, user_id, docLines, source, (err)=>
  16. logger.log project_id:project_id, doc_id:doc_id, "notifying users that the document has been updated"
  17. DocumentUpdaterHandler.flushDocToMongo project_id, doc_id, callback
  18. addDoc: (project_id, folder_id, docName, docLines, source, callback = (error, doc)->)->
  19. LockManager.getLock project_id, (err)->
  20. if err?
  21. logger.err err:err, project_id:project_id, source:source, "could not get lock to addDoc"
  22. return callback(err)
  23. EditorController.addDocWithoutLock project_id, folder_id, docName, docLines, source, (error, doc)->
  24. LockManager.releaseLock project_id, ->
  25. callback(error, doc)
  26. addDocWithoutLock: (project_id, folder_id, docName, docLines, source, callback = (error, doc)->)->
  27. docName = docName.trim()
  28. logger.log {project_id, folder_id, docName, source}, "sending new doc to project"
  29. Metrics.inc "editor.add-doc"
  30. ProjectEntityHandler.addDoc project_id, folder_id, docName, docLines, (err, doc, folder_id)=>
  31. if err?
  32. logger.err err:err, project_id:project_id, docName:docName, "error adding doc without lock"
  33. return callback(err)
  34. EditorRealTimeController.emitToRoom(project_id, 'reciveNewDoc', folder_id, doc, source)
  35. callback(err, doc)
  36. addFile: (project_id, folder_id, fileName, path, source, callback = (error, file)->)->
  37. LockManager.getLock project_id, (err)->
  38. if err?
  39. logger.err err:err, project_id:project_id, source:source, "could not get lock to addFile"
  40. return callback(err)
  41. EditorController.addFileWithoutLock project_id, folder_id, fileName, path, source, (error, file)->
  42. LockManager.releaseLock project_id, ->
  43. callback(error, file)
  44. addFileWithoutLock: (project_id, folder_id, fileName, path, source, callback = (error, file)->)->
  45. fileName = fileName.trim()
  46. logger.log {project_id, folder_id, fileName, path}, "sending new file to project"
  47. Metrics.inc "editor.add-file"
  48. ProjectEntityHandler.addFile project_id, folder_id, fileName, path, (err, fileRef, folder_id)=>
  49. if err?
  50. logger.err err:err, project_id:project_id, folder_id:folder_id, fileName:fileName, "error adding file without lock"
  51. return callback(err)
  52. EditorRealTimeController.emitToRoom(project_id, 'reciveNewFile', folder_id, fileRef, source)
  53. callback(err, fileRef)
  54. replaceFile: (project_id, file_id, fsPath, source, callback = (error) ->)->
  55. ProjectEntityHandler.replaceFile project_id, file_id, fsPath, callback
  56. addFolder : (project_id, folder_id, folderName, source, callback = (error, folder)->)->
  57. LockManager.getLock project_id, (err)->
  58. if err?
  59. logger.err err:err, project_id:project_id, source:source, "could not get lock to addFolder"
  60. return callback(err)
  61. EditorController.addFolderWithoutLock project_id, folder_id, folderName, source, (error, folder)->
  62. LockManager.releaseLock project_id, ->
  63. callback(error, folder)
  64. addFolderWithoutLock: (project_id, folder_id, folderName, source, callback = (error, folder)->)->
  65. folderName = folderName.trim()
  66. logger.log {project_id, folder_id, folderName, source}, "sending new folder to project"
  67. Metrics.inc "editor.add-folder"
  68. ProjectEntityHandler.addFolder project_id, folder_id, folderName, (err, folder, folder_id)=>
  69. if err?
  70. logger.err err:err, project_id:project_id, folder_id:folder_id, folderName:folderName, "error adding folder without lock"
  71. return callback(err)
  72. @p.notifyProjectUsersOfNewFolder project_id, folder_id, folder, (error) ->
  73. callback error, folder
  74. mkdirp : (project_id, path, callback)->
  75. LockManager.getLock project_id, (err)->
  76. if err?
  77. logger.err err:err, project_id:project_id, "could not get lock to mkdirp"
  78. return callback(err)
  79. EditorController.mkdirpWithoutLock project_id, path, (err, newFolders, lastFolder)->
  80. LockManager.releaseLock project_id, ->
  81. callback(err, newFolders, lastFolder)
  82. mkdirpWithoutLock: (project_id, path, callback)->
  83. logger.log project_id:project_id, path:path, "making directories if they don't exist"
  84. ProjectEntityHandler.mkdirp project_id, path, (err, newFolders, lastFolder)=>
  85. if err?
  86. logger.err err:err, project_id:project_id, path:path, "error mkdirp without lock"
  87. return callback(err)
  88. self = @
  89. jobs = _.map newFolders, (folder, index)->
  90. return (cb)->
  91. self.p.notifyProjectUsersOfNewFolder project_id, folder.parentFolder_id, folder, cb
  92. async.series jobs, (err)->
  93. callback err, newFolders, lastFolder
  94. deleteEntity : (project_id, entity_id, entityType, source, callback)->
  95. LockManager.getLock project_id, (err)->
  96. if err?
  97. logger.err err:err, project_id:project_id, "could not get lock to deleteEntity"
  98. return callback(err)
  99. EditorController.deleteEntityWithoutLock project_id, entity_id, entityType, source, (err)->
  100. LockManager.releaseLock project_id, ()->
  101. callback(err)
  102. deleteEntityWithoutLock: (project_id, entity_id, entityType, source, callback)->
  103. logger.log {project_id, entity_id, entityType, source}, "start delete process of entity"
  104. Metrics.inc "editor.delete-entity"
  105. ProjectEntityHandler.deleteEntity project_id, entity_id, entityType, (err)->
  106. if err?
  107. logger.err err:err, project_id:project_id, entity_id:entity_id, entityType:entityType, "error deleting entity"
  108. return callback(err)
  109. logger.log project_id:project_id, entity_id:entity_id, entityType:entityType, "telling users entity has been deleted"
  110. EditorRealTimeController.emitToRoom(project_id, 'removeEntity', entity_id, source)
  111. if callback?
  112. callback()
  113. getListOfDocPaths: (project_id, callback)->
  114. ProjectEntityHandler.getAllDocs project_id, (err, docs)->
  115. docList = _.map docs, (doc, path)->
  116. return {_id:doc._id, path:path.substring(1)}
  117. callback(null, docList)
  118. notifyUsersProjectHasBeenDeletedOrRenamed: (project_id, callback)->
  119. EditorRealTimeController.emitToRoom(project_id, 'projectRenamedOrDeletedByExternalSource')
  120. callback()
  121. updateProjectDescription: (project_id, description, callback = ->)->
  122. logger.log project_id:project_id, description:description, "updating project description"
  123. ProjectDetailsHandler.setProjectDescription project_id, description, (err)->
  124. if err?
  125. logger.err err:err, project_id:project_id, description:description, "something went wrong setting the project description"
  126. return callback(err)
  127. EditorRealTimeController.emitToRoom(project_id, 'projectDescriptionUpdated', description)
  128. callback()
  129. deleteProject: (project_id, callback)->
  130. Metrics.inc "editor.delete-project"
  131. logger.log project_id:project_id, "recived message to delete project"
  132. ProjectDeleter.deleteProject project_id, callback
  133. renameEntity: (project_id, entity_id, entityType, newName, callback)->
  134. newName = sanitize.escape(newName)
  135. Metrics.inc "editor.rename-entity"
  136. logger.log entity_id:entity_id, entity_id:entity_id, entity_id:entity_id, "reciving new name for entity for project"
  137. ProjectEntityHandler.renameEntity project_id, entity_id, entityType, newName, ->
  138. if err?
  139. logger.err err:err, project_id:project_id, entity_id:entity_id, entityType:entityType, newName:newName, "error renaming entity"
  140. return callback(err)
  141. if newName.length > 0
  142. EditorRealTimeController.emitToRoom project_id, 'reciveEntityRename', entity_id, newName
  143. callback?()
  144. moveEntity: (project_id, entity_id, folder_id, entityType, callback)->
  145. Metrics.inc "editor.move-entity"
  146. LockManager.getLock project_id, (err)->
  147. if err?
  148. logger.err err:err, project_id:project_id, "could not get lock for move entity"
  149. return callback(err)
  150. ProjectEntityHandler.moveEntity project_id, entity_id, folder_id, entityType, =>
  151. if err?
  152. logger.err err:err, project_id:project_id, entity_id:entity_id, folder_id:folder_id, "error moving entity"
  153. return callback(err)
  154. LockManager.releaseLock project_id, ->
  155. EditorRealTimeController.emitToRoom project_id, 'reciveEntityMove', entity_id, folder_id
  156. callback?()
  157. renameProject: (project_id, newName, callback = (err) ->) ->
  158. ProjectDetailsHandler.renameProject project_id, newName, ->
  159. if err?
  160. logger.err err:err, project_id:project_id, newName:newName, "error renaming project"
  161. return callback(err)
  162. EditorRealTimeController.emitToRoom project_id, 'projectNameUpdated', newName
  163. callback()
  164. setCompiler : (project_id, compiler, callback = (err) ->) ->
  165. ProjectOptionsHandler.setCompiler project_id, compiler, (err) ->
  166. return callback(err) if err?
  167. logger.log compiler:compiler, project_id:project_id, "setting compiler"
  168. EditorRealTimeController.emitToRoom project_id, 'compilerUpdated', compiler
  169. callback()
  170. setSpellCheckLanguage : (project_id, languageCode, callback = (err) ->) ->
  171. ProjectOptionsHandler.setSpellCheckLanguage project_id, languageCode, (err) ->
  172. return callback(err) if err?
  173. logger.log languageCode:languageCode, project_id:project_id, "setting languageCode for spell check"
  174. EditorRealTimeController.emitToRoom project_id, 'spellCheckLanguageUpdated', languageCode
  175. callback()
  176. setPublicAccessLevel : (project_id, newAccessLevel, callback = (err) ->) ->
  177. ProjectDetailsHandler.setPublicAccessLevel project_id, newAccessLevel, (err) ->
  178. return callback(err) if err?
  179. EditorRealTimeController.emitToRoom project_id, 'publicAccessLevelUpdated', newAccessLevel
  180. callback()
  181. setRootDoc: (project_id, newRootDocID, callback = (err) ->) ->
  182. ProjectEntityHandler.setRootDoc project_id, newRootDocID, (err) ->
  183. return callback(err) if err?
  184. EditorRealTimeController.emitToRoom project_id, 'rootDocUpdated', newRootDocID
  185. callback()
  186. p:
  187. notifyProjectUsersOfNewFolder: (project_id, folder_id, folder, callback = (error)->)->
  188. logger.log project_id:project_id, folder:folder, parentFolder_id:folder_id, "sending newly created folder out to users"
  189. EditorRealTimeController.emitToRoom(project_id, "reciveNewFolder", folder_id, folder)
  190. callback()