User.coffee 8.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300
  1. request = require("./request")
  2. _ = require("underscore")
  3. settings = require("settings-sharelatex")
  4. {db, ObjectId} = require("../../../../app/js/infrastructure/mongojs")
  5. UserModel = require("../../../../app/js/models/User").User
  6. UserUpdater = require("../../../../app/js/Features/User/UserUpdater")
  7. AuthenticationManager = require("../../../../app/js/Features/Authentication/AuthenticationManager")
  8. count = 0
  9. class User
  10. constructor: (options = {}) ->
  11. @emails = [
  12. email: "acceptance-test-#{count}@example.com"
  13. createdAt: new Date()
  14. ]
  15. @email = @emails[0].email
  16. @password = "acceptance-test-#{count}-password"
  17. count++
  18. @jar = request.jar()
  19. @request = request.defaults({
  20. jar: @jar
  21. })
  22. setExtraAttributes: (user) ->
  23. throw new Error("User does not exist") unless user?._id?
  24. @id = user._id.toString()
  25. @_id = user._id.toString()
  26. @first_name = user.first_name
  27. @referal_id = user.referal_id
  28. get: (callback = (error, user)->) ->
  29. db.users.findOne { _id: ObjectId(@_id) }, callback
  30. register: (callback = (error, user) ->) ->
  31. return callback(new Error('User already registered')) if @_id?
  32. @getCsrfToken (error) =>
  33. return callback(error) if error?
  34. @request.post {
  35. url: '/register'
  36. json: { @email, @password }
  37. }, (error, response, body) =>
  38. return callback(error) if error?
  39. db.users.findOne { email: @email }, (error, user) =>
  40. return callback(error) if error?
  41. @setExtraAttributes user
  42. callback(null, user)
  43. login: (callback = (error) ->) ->
  44. @loginWith(@email, callback)
  45. loginWith: (email, callback = (error) ->) ->
  46. @ensureUserExists (error) =>
  47. return callback(error) if error?
  48. @getCsrfToken (error) =>
  49. return callback(error) if error?
  50. @request.post {
  51. url: "/login"
  52. json: { email, @password }
  53. }, callback
  54. ensureUserExists: (callback = (error) ->) ->
  55. filter = {@email}
  56. options = {upsert: true, new: true, setDefaultsOnInsert: true}
  57. UserModel.findOneAndUpdate filter, {}, options, (error, user) =>
  58. return callback(error) if error?
  59. AuthenticationManager.setUserPassword user._id, @password, (error) =>
  60. return callback(error) if error?
  61. UserUpdater.updateUser user._id, $set: emails: @emails, (error) =>
  62. return callback(error) if error?
  63. @setExtraAttributes user
  64. callback(null, @password)
  65. setFeatures: (features, callback = (error) ->) ->
  66. update = {}
  67. for key, value of features
  68. update["features.#{key}"] = value
  69. UserModel.update { _id: @id }, update, callback
  70. logout: (callback = (error) ->) ->
  71. @getCsrfToken (error) =>
  72. return callback(error) if error?
  73. @request.get {
  74. url: "/logout"
  75. json:
  76. email: @email
  77. password: @password
  78. }, (error, response, body) =>
  79. return callback(error) if error?
  80. db.users.findOne {email: @email}, (error, user) =>
  81. return callback(error) if error?
  82. @id = user?._id?.toString()
  83. @_id = user?._id?.toString()
  84. callback()
  85. addEmail: (email, callback = (error) ->) ->
  86. @emails.push(email: email, createdAt: new Date())
  87. UserUpdater.addEmailAddress @id, email, callback
  88. ensure_admin: (callback = (error) ->) ->
  89. db.users.update {_id: ObjectId(@id)}, { $set: { isAdmin: true }}, callback
  90. upgradeFeatures: (callback = (error) -> ) ->
  91. features = {
  92. collaborators: -1 # Infinite
  93. versioning: true
  94. dropbox:true
  95. compileTimeout: 60
  96. compileGroup:"priority"
  97. templates: true
  98. references: true
  99. trackChanges: true
  100. trackChangesVisible: true
  101. }
  102. db.users.update {_id: ObjectId(@id)}, { $set: { features: features }}, callback
  103. downgradeFeatures: (callback = (error) -> ) ->
  104. features = {
  105. collaborators: 1
  106. versioning: false
  107. dropbox:false
  108. compileTimeout: 60
  109. compileGroup:"standard"
  110. templates: false
  111. references: false
  112. trackChanges: false
  113. trackChangesVisible: false
  114. }
  115. db.users.update {_id: ObjectId(@id)}, { $set: { features: features }}, callback
  116. defaultFeatures: (callback = (error) -> ) ->
  117. features = settings.defaultFeatures
  118. db.users.update {_id: ObjectId(@id)}, { $set: { features: features }}, callback
  119. full_delete_user: (email, callback = (error) ->) ->
  120. db.users.findOne {email: email}, (error, user) =>
  121. if !user?
  122. return callback()
  123. user_id = user._id
  124. db.projects.remove owner_ref:ObjectId(user_id), {multi:true}, (err)->
  125. if err?
  126. callback(err)
  127. db.users.remove {_id: ObjectId(user_id)}, callback
  128. getProject: (project_id, callback = (error, project)->) ->
  129. db.projects.findOne {_id: ObjectId(project_id.toString())}, callback
  130. createProject: (name, options, callback = (error, oroject_id) ->) ->
  131. if typeof options == "function"
  132. callback = options
  133. options = {}
  134. @request.post {
  135. url: "/project/new",
  136. json: Object.assign({projectName: name}, options)
  137. }, (error, response, body) ->
  138. return callback(error) if error?
  139. if !body?.project_id?
  140. error = new Error("SOMETHING WENT WRONG CREATING PROJECT", response.statusCode, response.headers["location"], body)
  141. callback error
  142. else
  143. callback(null, body.project_id)
  144. deleteProject: (project_id, callback=(error)) ->
  145. @request.delete {
  146. url: "/project/#{project_id}"
  147. }, (error, response, body) ->
  148. return callback(error) if error?
  149. callback(null)
  150. openProject: (project_id, callback=(error)) ->
  151. @request.get {
  152. url: "/project/#{project_id}"
  153. }, (error, response, body) ->
  154. return callback(error) if error?
  155. if response.statusCode != 200
  156. err = new Error("Non-success response when opening project: #{response.statusCode}")
  157. return callback(err)
  158. callback(null)
  159. createDocInProject: (project_id, parent_folder_id, name, callback=(error, doc_id)->) ->
  160. @getCsrfToken (error) =>
  161. return callback(error) if error?
  162. @request.post {
  163. url: "/project/#{project_id}/doc",
  164. json: {
  165. name: name,
  166. parent_folder_id: parent_folder_id
  167. }
  168. }, (error, response, body) =>
  169. callback(null, body._id)
  170. addUserToProject: (project_id, user, privileges, callback = (error, user) ->) ->
  171. if privileges == 'readAndWrite'
  172. updateOp = {$addToSet: {collaberator_refs: user._id.toString()}}
  173. else if privileges == 'readOnly'
  174. updateOp = {$addToSet: {readOnly_refs: user._id.toString()}}
  175. db.projects.update {_id: db.ObjectId(project_id)}, updateOp, (err) ->
  176. callback(err)
  177. makePublic: (project_id, level, callback = (error) ->) ->
  178. @request.post {
  179. url: "/project/#{project_id}/settings/admin",
  180. json:
  181. publicAccessLevel: level
  182. }, (error, response, body) ->
  183. return callback(error) if error?
  184. callback(null)
  185. makePrivate: (project_id, callback = (error) ->) ->
  186. @request.post {
  187. url: "/project/#{project_id}/settings/admin",
  188. json:
  189. publicAccessLevel: 'private'
  190. }, (error, response, body) ->
  191. return callback(error) if error?
  192. callback(null)
  193. makeTokenBased: (project_id, callback = (error) ->) ->
  194. @request.post {
  195. url: "/project/#{project_id}/settings/admin",
  196. json:
  197. publicAccessLevel: 'tokenBased'
  198. }, (error, response, body) ->
  199. return callback(error) if error?
  200. callback(null)
  201. getCsrfToken: (callback = (error) ->) ->
  202. @request.get {
  203. url: "/dev/csrf"
  204. }, (err, response, body) =>
  205. return callback(err) if err?
  206. @csrfToken = body
  207. @request = @request.defaults({
  208. headers:
  209. "x-csrf-token": @csrfToken
  210. })
  211. callback()
  212. changePassword: (callback = (error) ->) ->
  213. @getCsrfToken (error) =>
  214. return callback(error) if error?
  215. @request.post {
  216. url: "/user/password/update"
  217. json:
  218. currentPassword: @password
  219. newPassword1: @password
  220. newPassword2: @password
  221. }, (error, response, body) =>
  222. return callback(error) if error?
  223. db.users.findOne {email: @email}, (error, user) =>
  224. return callback(error) if error?
  225. callback()
  226. getUserSettingsPage: (callback = (error, statusCode) ->) ->
  227. @getCsrfToken (error) =>
  228. return callback(error) if error?
  229. @request.get {
  230. url: "/user/settings"
  231. }, (error, response, body) =>
  232. return callback(error) if error?
  233. callback(null, response.statusCode)
  234. activateSudoMode: (callback = (error)->) ->
  235. @getCsrfToken (error) =>
  236. return callback(error) if error?
  237. @request.post {
  238. uri: '/confirm-password',
  239. json:
  240. password: @password
  241. }, callback
  242. updateSettings: (newSettings, callback = (error, response, body) ->) ->
  243. @getCsrfToken (error) =>
  244. return callback(error) if error?
  245. @request.post {
  246. url: '/user/settings'
  247. json: newSettings
  248. }, callback
  249. getProjectListPage: (callback=(error, statusCode)->) ->
  250. @getCsrfToken (error) =>
  251. return callback(error) if error?
  252. @request.get {
  253. url: "/project"
  254. }, (error, response, body) =>
  255. return callback(error) if error?
  256. callback(null, response.statusCode)
  257. isLoggedIn: (callback = (error, loggedIn) ->) ->
  258. @request.get "/user/personal_info", (error, response, body) ->
  259. return callback(error) if error?
  260. if response.statusCode == 200
  261. return callback(null, true)
  262. else if response.statusCode == 302
  263. return callback(null, false)
  264. else
  265. return callback(new Error("unexpected status code from /user/personal_info: #{response.statusCode}"))
  266. module.exports = User