thread.js 2.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103
  1. let express = require('express')
  2. let router = express.Router()
  3. const Errors = require('../lib/errors.js')
  4. let { User, Thread, Category } = require('../models')
  5. router.get('/:thread_id', async (req, res) => {
  6. try {
  7. let thread = await Thread.findById(req.params.thread_id, { include: Thread.includeOptions() })
  8. if(!thread) throw Errors.invalidParameter('id', 'thread does not exist')
  9. res.json(thread.toJSON())
  10. } catch (e) {
  11. if(e.name === 'invalidParameter') {
  12. res.status(400)
  13. res.json({
  14. errors: [e]
  15. })
  16. } else {
  17. res.status(500)
  18. res.json({
  19. errors: [Errors.unknown]
  20. })
  21. }
  22. }
  23. })
  24. router.all('*', (req, res, next) => {
  25. if(req.session.loggedIn) {
  26. next()
  27. } else {
  28. res.status(401)
  29. res.json({
  30. errors: [Errors.requestNotAuthorized]
  31. })
  32. }
  33. })
  34. router.post('/', async (req, res) => {
  35. let validationErrors = []
  36. try {
  37. if(req.body.name === undefined) {
  38. validationErrors.push(Errors.missingParameter('name'))
  39. } else if(typeof req.body.name !== 'string') {
  40. validationErrors.push(Errors.invalidParameterType('name', 'string'))
  41. }
  42. if(req.body.category === undefined) {
  43. validationErrors.push(Errors.missingParameter('category'))
  44. } else if(typeof req.body.category !== 'string') {
  45. validationErrors.push(Errors.invalidParameterType('category', 'string'))
  46. }
  47. if(validationErrors.length) throw Errors.VALIDATION_ERROR
  48. let category = await Category.findOne({ where: {
  49. name: req.body.category
  50. }})
  51. if(!category) throw Errors.invalidCategory
  52. let user = await User.findOne({ where: {
  53. username: req.session.username
  54. }})
  55. let thread = await Thread.create({
  56. name: req.body.name
  57. })
  58. await thread.setCategory(category)
  59. await thread.setUser(user)
  60. res.json(await thread.reload({
  61. include: [
  62. { model: User, attributes: ['username', 'createdAt', 'updatedAt', 'id'] },
  63. Category
  64. ]
  65. }))
  66. } catch (e) {
  67. if(e === Errors.VALIDATION_ERROR) {
  68. res.status(400)
  69. res.json({
  70. errors: validationErrors
  71. })
  72. } else if(e === Errors.invalidCategory) {
  73. res.status(400)
  74. res.json({
  75. errors: [Errors.invalidCategory]
  76. })
  77. } else {
  78. console.log(e)
  79. res.status(500)
  80. res.json({
  81. errors: [Errors.unknown]
  82. })
  83. }
  84. }
  85. })
  86. module.exports = router