rltube-backend/api/server/routes/reviews.js at 6671dd7c34b6aa31b19046aefa9464c25a8aaf54 · RLTube/rltube-backend · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
'use strict'

const database = require('../../database/database')
const db = database.db
const Review = database.models.Review

module.exports = (fastify, opts, next) => {
  // Get all reviews
  fastify.get('/', { schema: opts.schemas.list }, async (req, reply) => {
    const data = await Review.find({}, (err, reviews) => {
      let reviewMap = {}

      reviews.forEach((review) => {
        if (!reviewMap[review.videoUrl]) reviewMap[review.videoUrl] = []
        reviewMap[review.videoUrl].push(review)
	  })

	  return reviewMap
	})

	reply.send(data)
  })

  // Get  reviews by videoUrl
  fastify.get('/:videoUrl', { schema: opts.schemas.get }, async (req, reply) => {
    if (!req.params.videoUrl) {
      req.log.info('redirect on reviews')
      reply.redirect(opts.prefix ? opts.prefix : '/')
      return
    }

    req.log.info('request for video : ' + req.params.videoUrl)

    Review.find({videoUrl: req.params.videoUrl}, (err, reviews) => {
      let reviewMap = {}

      reviews.forEach((review) => {
        reviewMap[review._id] = review
      })

      reply.send(reviewMap)
    })
  })

  // Get a review by reviewId for a videoURL
  fastify.get('/:videoUrl/:reviewId', { schema: opts.schemas.get }, async (req, reply) => {
    if (!req.params.videoUrl) {
      req.log.info('redirect on reviews')
      reply.redirect(opts.prefix ? opts.prefix : '/')
      return
    }

    req.log.info('request for a review  : ' + req.params.reviewId + ' on  a  videoURL' + req.params.videoUrl)

    const data = await Review.find({_id: req.params.reviewId}, (err, reviews) => {
      let reviewMap = {}

      reviews.forEach((review) => {
        reviewMap[review._id] = review
      })

	  return reviewMap
    })
	reply.send(data)
  })

  // Create new review
  fastify.post('/', { schema: opts.schemas.add }, async (req, reply) => {
    let review = new Review(req.body.review)
	const err = await review.save((err) => { return !!err })
	reply.send({ err })
  })

  // Increment vote of a review
  fastify.post('/:reviewId', async (req, reply) => {
      const data = await Review.findByIdAndUpdate(req.params.reviewId , {$inc: {vote: req.body.review.vote}})
    req.log.info('   ====== data.vote: ' + data.vote+ " ========")
    reply.send( data)
  })

  next()
}