user.js 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243
  1. let bcrypt = require('bcryptjs')
  2. let express = require('express')
  3. let router = express.Router()
  4. const Errors = require('../lib/errors.js')
  5. let { User, Post, AdminToken, Thread, Category } = require('../models')
  6. let pagination = require('../lib/pagination.js')
  7. function setUserSession(req, res, username, admin) {
  8. req.session.loggedIn = true
  9. req.session.username = username
  10. res.cookie('username', username)
  11. if(admin) req.session.admin = true
  12. }
  13. router.post('/', async (req, res) => {
  14. let user, adminUser, hash, token
  15. let validationErrors = []
  16. let userParams = {}
  17. try {
  18. //Validations
  19. if(req.body.username === undefined) {
  20. validationErrors.push(Errors.missingParameter('username'))
  21. } else {
  22. if(typeof req.body.username !== 'string') {
  23. validationErrors.push(Errors.invalidParameterType('username', 'string'))
  24. } if(req.body.username.length < 6) {
  25. validationErrors.push(Errors.parameterLengthTooSmall('username', 6))
  26. } if(req.body.username.length > 50) {
  27. validationErrors.push(Errors.parameterLengthTooLarge('username', 50))
  28. }
  29. }
  30. if(req.body.password === undefined) {
  31. validationErrors.push(Errors.missingParameter('password'))
  32. } else {
  33. if(typeof req.body.password !== 'string') {
  34. validationErrors.push(Errors.invalidParameterType('password', 'string'))
  35. } if(req.body.password.length < 6) {
  36. validationErrors.push(Errors.parameterLengthTooSmall('password', 6))
  37. } if(req.body.password.length > 100) {
  38. validationErrors.push(Errors.parameterLengthTooLarge('password', 100))
  39. }
  40. }
  41. if(req.body.token !== undefined && typeof req.body.token !== 'string') {
  42. validationErrors.push(Errors.invalidParameterType('token', 'string'))
  43. }
  44. if(req.body.admin !== undefined && typeof req.body.admin !== 'boolean') {
  45. validationErrors.push(Errors.invalidParameterType('admin', 'boolean'))
  46. }
  47. if(validationErrors.length) throw Errors.VALIDATION_ERROR
  48. if(req.body.admin && !req.body.token) {
  49. adminUser = await User.findOne({ where: {
  50. admin: true
  51. }})
  52. if(adminUser) {
  53. validationErrors.push(Errors.missingParameter('token'))
  54. throw Errors.VALIDATION_ERROR
  55. } else {
  56. userParams.admin = true
  57. }
  58. } else if(req.body.admin && req.body.token) {
  59. token = await AdminToken.findOne({ where: {
  60. token: req.body.token
  61. }})
  62. if(token && token.isValid()) {
  63. userParams.admin = true
  64. } else {
  65. throw Errors.invalidToken
  66. }
  67. }
  68. hash = await bcrypt.hash(req.body.password, 12)
  69. userParams.username = req.body.username
  70. userParams.hash = hash
  71. user = await User.create(userParams)
  72. if(req.body.token) {
  73. await token.destroy()
  74. }
  75. setUserSession(req, res, user.username, userParams.admin)
  76. res.json(user.toJSON())
  77. } catch (err) {
  78. if(err === Errors.VALIDATION_ERROR) {
  79. res.status(400)
  80. res.json({
  81. errors: validationErrors
  82. })
  83. } else if(err.name === 'SequelizeUniqueConstraintError') {
  84. res.status(400)
  85. res.json({
  86. errors: [Errors.accountAlreadyCreated]
  87. })
  88. } else if (err = Errors.invalidToken) {
  89. res.status(401)
  90. res.json({
  91. errors: [Errors.invalidToken]
  92. })
  93. } else {
  94. console.log(e)
  95. res.status(500)
  96. res.json({
  97. errors: [Errors.unknown]
  98. })
  99. }
  100. }
  101. })
  102. router.get('/:username', async (req, res) => {
  103. try {
  104. let queryObj = {
  105. attributes: { exclude: ['hash', 'id'] },
  106. where: { username: req.params.username }
  107. }
  108. if(req.query.posts) {
  109. let { from, limit } = pagination.getPaginationProps(req.query)
  110. queryObj.include = User.includeOptions(from, limit)
  111. let user = await User.findOne(queryObj)
  112. if(!user) throw Errors.accountDoesNotExist
  113. let resUser = user.toJSON()
  114. resUser.meta = {}
  115. let lastPost = user.Posts.slice(-1)[0]
  116. if(!lastPost || lastPost.postNumber+1 === lastPost.Thread.postsCount) {
  117. resUser.meta.nextURL = null
  118. resUser.meta.nextPostsCount = 0
  119. } else {
  120. resUser.meta.nextURL =
  121. `/api/v1/user/${user.username}?posts=true&limit=${limit}&from=${lastPost.postNumber + 1}`
  122. resUser.meta.nextPostsCount = await pagination.getNextCount(
  123. Post, lastPost, limit,
  124. { UserId: user.id }
  125. )
  126. }
  127. res.json(resUser)
  128. } else if(req.query.threads) {
  129. res.redirect('/api/v1/category/ALL?username=' + req.params.username)
  130. } else {
  131. let user = await User.findOne(queryObj)
  132. if(!user) throw Errors.accountDoesNotExist
  133. res.json(user.toJSON())
  134. }
  135. } catch (err) {
  136. if(err === Errors.accountDoesNotExist) {
  137. res.status(400)
  138. res.json({ errors: [err] })
  139. } else {
  140. console.log(err)
  141. res.status(500)
  142. res.json({
  143. errors: [Errors.unknown]
  144. })
  145. }
  146. }
  147. })
  148. router.post('/:username/login', async (req, res) => {
  149. let user, bcryptRes, validationErrors = []
  150. try {
  151. //Validations
  152. if(req.body.password === undefined) {
  153. validationErrors.push(Errors.missingParameter('password'))
  154. } else if(typeof req.body.password !== 'string') {
  155. validationErrors.push(Errors.invalidParameterType('password', 'string'))
  156. }
  157. if(validationErrors.length) throw Errors.VALIDATION_ERROR
  158. user = await User.findOne({
  159. where: {
  160. username: req.params.username,
  161. }
  162. })
  163. if(user) {
  164. bcryptRes = await bcrypt.compare(req.body.password, user.hash)
  165. if(bcryptRes) {
  166. setUserSession(req, res, user.username, user.admin)
  167. res.json({
  168. username: user.username,
  169. success: true
  170. })
  171. } else {
  172. res.status(401)
  173. res.json({
  174. errors: [Errors.invalidLoginCredentials]
  175. })
  176. }
  177. } else {
  178. res.status(401)
  179. res.json({
  180. errors: [Errors.invalidLoginCredentials]
  181. })
  182. }
  183. } catch (err) {
  184. if(err === Errors.VALIDATION_ERROR) {
  185. res.status(400)
  186. res.json({
  187. errors: validationErrors
  188. })
  189. } else {
  190. console.log(err)
  191. res.status(500)
  192. res.json({
  193. errors: [Errors.unknown]
  194. })
  195. }
  196. }
  197. })
  198. router.post('/:username/logout', async (req, res) => {
  199. req.session = null
  200. res.clearCookie('username')
  201. res.json({
  202. success: true
  203. })
  204. })
  205. module.exports = router