EditorController.coffee 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203
  1. logger = require('logger-sharelatex')
  2. Metrics = require('metrics-sharelatex')
  3. sanitize = require('sanitizer')
  4. ProjectEntityUpdateHandler = require('../Project/ProjectEntityUpdateHandler')
  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. PublicAccessLevels = require("../Authorization/PublicAccessLevels")
  12. _ = require('underscore')
  13. module.exports = EditorController =
  14. addDoc: (project_id, folder_id, docName, docLines, source, user_id, callback = (error, doc)->)->
  15. docName = docName.trim()
  16. logger.log {project_id, folder_id, docName, source}, "sending new doc to project"
  17. Metrics.inc "editor.add-doc"
  18. ProjectEntityUpdateHandler.addDoc project_id, folder_id, docName, docLines, user_id, (err, doc, folder_id)=>
  19. if err?
  20. logger.err err:err, project_id:project_id, docName:docName, "error adding doc without lock"
  21. return callback(err)
  22. EditorRealTimeController.emitToRoom(project_id, 'reciveNewDoc', folder_id, doc, source)
  23. callback(err, doc)
  24. addFile: (project_id, folder_id, fileName, fsPath, source, user_id, callback = (error, file)->)->
  25. fileName = fileName.trim()
  26. logger.log {project_id, folder_id, fileName, fsPath}, "sending new file to project"
  27. Metrics.inc "editor.add-file"
  28. ProjectEntityUpdateHandler.addFile project_id, folder_id, fileName, fsPath, user_id, (err, fileRef, folder_id)=>
  29. if err?
  30. logger.err err:err, project_id:project_id, folder_id:folder_id, fileName:fileName, "error adding file without lock"
  31. return callback(err)
  32. EditorRealTimeController.emitToRoom(project_id, 'reciveNewFile', folder_id, fileRef, source)
  33. callback(err, fileRef)
  34. upsertDoc: (project_id, folder_id, docName, docLines, source, user_id, callback = (err)->)->
  35. ProjectEntityUpdateHandler.upsertDoc project_id, folder_id, docName, docLines, source, user_id, (err, doc, didAddNewDoc) ->
  36. if didAddNewDoc
  37. EditorRealTimeController.emitToRoom(project_id, 'reciveNewDoc', folder_id, doc, source)
  38. callback err, doc
  39. upsertFile: (project_id, folder_id, fileName, fsPath, source, user_id, callback = (err, file) ->) ->
  40. ProjectEntityUpdateHandler.upsertFile project_id, folder_id, fileName, fsPath, user_id, (err, file, didAddFile) ->
  41. return callback(err) if err?
  42. if didAddFile
  43. EditorRealTimeController.emitToRoom project_id, 'reciveNewFile', folder_id, file, source
  44. callback null, file
  45. upsertDocWithPath: (project_id, elementPath, docLines, source, user_id, callback) ->
  46. ProjectEntityUpdateHandler.upsertDocWithPath project_id, elementPath, docLines, source, user_id, (err, doc, didAddNewDoc, newFolders, lastFolder) ->
  47. return callback(err) if err?
  48. EditorController._notifyProjectUsersOfNewFolders project_id, newFolders, (err) ->
  49. return callback(err) if err?
  50. if didAddNewDoc
  51. EditorRealTimeController.emitToRoom project_id, 'reciveNewDoc', lastFolder._id, doc, source
  52. callback()
  53. upsertFileWithPath: (project_id, elementPath, fsPath, source, user_id, callback) ->
  54. ProjectEntityUpdateHandler.upsertFileWithPath project_id, elementPath, fsPath, user_id, (err, file, didAddFile, newFolders, lastFolder) ->
  55. return callback(err) if err?
  56. EditorController._notifyProjectUsersOfNewFolders project_id, newFolders, (err) ->
  57. return callback(err) if err?
  58. if didAddFile
  59. EditorRealTimeController.emitToRoom project_id, 'reciveNewFile', lastFolder._id, file, source
  60. callback()
  61. addFolder : (project_id, folder_id, folderName, source, callback = (error, folder)->)->
  62. folderName = folderName.trim()
  63. logger.log {project_id, folder_id, folderName, source}, "sending new folder to project"
  64. Metrics.inc "editor.add-folder"
  65. ProjectEntityUpdateHandler.addFolder project_id, folder_id, folderName, (err, folder, folder_id)=>
  66. if err?
  67. logger.err err:err, project_id:project_id, source:source, "could not add folder"
  68. return callback(err)
  69. EditorController._notifyProjectUsersOfNewFolder project_id, folder_id, folder, (err) ->
  70. return callback(err) if err?
  71. callback null, folder
  72. mkdirp : (project_id, path, callback = (error, newFolders, lastFolder)->)->
  73. logger.log project_id:project_id, path:path, "making directories if they don't exist"
  74. ProjectEntityUpdateHandler.mkdirp project_id, path, (err, newFolders, lastFolder)=>
  75. if err?
  76. logger.err err:err, project_id:project_id, "could not mkdirp"
  77. return callback(err)
  78. EditorController._notifyProjectUsersOfNewFolders project_id, newFolders, (err) ->
  79. return callback(err) if err?
  80. callback null, newFolders, lastFolder
  81. deleteEntity : (project_id, entity_id, entityType, source, userId, callback = (error)->)->
  82. logger.log {project_id, entity_id, entityType, source}, "start delete process of entity"
  83. Metrics.inc "editor.delete-entity"
  84. ProjectEntityUpdateHandler.deleteEntity project_id, entity_id, entityType, userId, (err)->
  85. if err?
  86. logger.err {err, project_id, entity_id, entityType}, "could not delete entity"
  87. return callback(err)
  88. logger.log {project_id, entity_id, entityType}, "telling users entity has been deleted"
  89. EditorRealTimeController.emitToRoom(project_id, 'removeEntity', entity_id, source)
  90. callback()
  91. deleteEntityWithPath: (project_id, path, source, user_id, callback) ->
  92. ProjectEntityUpdateHandler.deleteEntityWithPath project_id, path, user_id, (err, entity_id) ->
  93. return callback(err) if err?
  94. EditorRealTimeController.emitToRoom(project_id, 'removeEntity', entity_id, source)
  95. callback null, entity_id
  96. notifyUsersProjectHasBeenDeletedOrRenamed: (project_id, callback)->
  97. EditorRealTimeController.emitToRoom(project_id, 'projectRenamedOrDeletedByExternalSource')
  98. callback()
  99. updateProjectDescription: (project_id, description, callback = ->)->
  100. logger.log project_id:project_id, description:description, "updating project description"
  101. ProjectDetailsHandler.setProjectDescription project_id, description, (err)->
  102. if err?
  103. logger.err err:err, project_id:project_id, description:description, "something went wrong setting the project description"
  104. return callback(err)
  105. EditorRealTimeController.emitToRoom(project_id, 'projectDescriptionUpdated', description)
  106. callback()
  107. deleteProject: (project_id, callback)->
  108. Metrics.inc "editor.delete-project"
  109. logger.log project_id:project_id, "recived message to delete project"
  110. ProjectDeleter.deleteProject project_id, callback
  111. renameEntity: (project_id, entity_id, entityType, newName, userId, callback = (error) ->)->
  112. newName = sanitize.escape(newName)
  113. Metrics.inc "editor.rename-entity"
  114. logger.log entity_id:entity_id, entity_id:entity_id, entity_id:entity_id, "reciving new name for entity for project"
  115. ProjectEntityUpdateHandler.renameEntity project_id, entity_id, entityType, newName, userId, (err) ->
  116. if err?
  117. logger.err err:err, project_id:project_id, entity_id:entity_id, entityType:entityType, newName:newName, "error renaming entity"
  118. return callback(err)
  119. if newName.length > 0
  120. EditorRealTimeController.emitToRoom project_id, 'reciveEntityRename', entity_id, newName
  121. callback()
  122. moveEntity: (project_id, entity_id, folder_id, entityType, userId, callback = (error) ->)->
  123. Metrics.inc "editor.move-entity"
  124. ProjectEntityUpdateHandler.moveEntity project_id, entity_id, folder_id, entityType, userId, (err) ->
  125. if err?
  126. logger.err err:err, project_id:project_id, entity_id:entity_id, folder_id:folder_id, "error moving entity"
  127. return callback(err)
  128. EditorRealTimeController.emitToRoom project_id, 'reciveEntityMove', entity_id, folder_id
  129. callback()
  130. renameProject: (project_id, newName, callback = (err) ->) ->
  131. ProjectDetailsHandler.renameProject project_id, newName, (err) ->
  132. if err?
  133. logger.err err:err, project_id:project_id, newName:newName, "error renaming project"
  134. return callback(err)
  135. EditorRealTimeController.emitToRoom project_id, 'projectNameUpdated', newName
  136. callback()
  137. setCompiler : (project_id, compiler, callback = (err) ->) ->
  138. ProjectOptionsHandler.setCompiler project_id, compiler, (err) ->
  139. return callback(err) if err?
  140. logger.log compiler:compiler, project_id:project_id, "setting compiler"
  141. EditorRealTimeController.emitToRoom project_id, 'compilerUpdated', compiler
  142. callback()
  143. setSpellCheckLanguage : (project_id, languageCode, callback = (err) ->) ->
  144. ProjectOptionsHandler.setSpellCheckLanguage project_id, languageCode, (err) ->
  145. return callback(err) if err?
  146. logger.log languageCode:languageCode, project_id:project_id, "setting languageCode for spell check"
  147. EditorRealTimeController.emitToRoom project_id, 'spellCheckLanguageUpdated', languageCode
  148. callback()
  149. setPublicAccessLevel : (project_id, newAccessLevel, callback = (err) ->) ->
  150. ProjectDetailsHandler.setPublicAccessLevel project_id, newAccessLevel, (err) ->
  151. return callback(err) if err?
  152. EditorRealTimeController.emitToRoom(
  153. project_id,
  154. 'project:publicAccessLevel:changed',
  155. {newAccessLevel}
  156. )
  157. if newAccessLevel == PublicAccessLevels.TOKEN_BASED
  158. ProjectDetailsHandler.ensureTokensArePresent project_id, (err, tokens) ->
  159. return callback(err) if err?
  160. EditorRealTimeController.emitToRoom(
  161. project_id,
  162. 'project:tokens:changed',
  163. {tokens}
  164. )
  165. callback()
  166. else
  167. callback()
  168. setRootDoc: (project_id, newRootDocID, callback = (err) ->) ->
  169. ProjectEntityUpdateHandler.setRootDoc project_id, newRootDocID, (err) ->
  170. return callback(err) if err?
  171. EditorRealTimeController.emitToRoom project_id, 'rootDocUpdated', newRootDocID
  172. callback()
  173. _notifyProjectUsersOfNewFolders: (project_id, folders, callback = (error)->)->
  174. async.eachSeries folders,
  175. (folder, cb) -> EditorController._notifyProjectUsersOfNewFolder project_id, folder.parentFolder_id, folder, cb
  176. callback
  177. _notifyProjectUsersOfNewFolder: (project_id, folder_id, folder, callback = (error)->)->
  178. logger.log project_id:project_id, folder:folder, parentFolder_id:folder_id, "sending newly created folder out to users"
  179. EditorRealTimeController.emitToRoom(project_id, "reciveNewFolder", folder_id, folder)
  180. callback()