admin.js

const express = require('express')
const route = express.Router()
const encRedisClient = require('./cache/setup')

const init = connection => {
  route.get('/', (req, res) => {
    res.send('Olá Administrador')
  })

  route.get('/games', async (req, res) => {
    const [rows, fields] = await connection.execute('SELECT games.team_a, games.team_b, games.id, games.result_a, games.result_b FROM `games`')

    res.render('admin/games', {
      games: rows
    })
  })

  route.post('/games', async (req, res) => {
    const {
      team_a: teamA,
      team_b: teamB
    } = req.body
    await connection.execute('INSERT INTO `games` (games.team_a, games.team_b) VALUES (?, ?)', [
      teamA,
      teamB
    ])

    res.redirect('/admin/games')
  })

  route.post('/games/results', async (req, res) => {
    const games = []
    Object
      .keys(req.body)
      .forEach(game => {
        const parts = game.split('_')
        const results = {
          game_id: parseInt(parts[1]),
          result_a: parseInt(req.body[game].team_a),
          result_b: parseInt(req.body[game].team_b)
        }
        games.push(results)
      })

    for (let i = 0; i < games.length; i++) {
      const game = games[i]

      await connection.execute('UPDATE `games` SET games.result_a = ?, games.result_b = ? WHERE games.id = ?', [
        game.result_a,
        game.result_b,
        game.game_id
      ])

      const [guessings] = await connection.execute('SELECT guessings.id, guessings.game_id, guessings.group_id, guessings.user_id, guessings.result_a, guessings.result_b, guessings.score FROM `guessings` WHERE guessings.game_id = ?', [
        game.game_id
      ])

      const batch = guessings.map(guess => {
        let score = 0

        if (guess.result_a === game.result_a && guess.result_b === game.result_b) {
          score = 100
        } else if (guess.result_a === game.result_a || guess.result_b === game.result_b) {
          score += 25
          if (guess.result_a < guess.result_b && game.result_a < game.result_b) {
            score += 25
          } else if (guess.result_a > guess.result_b && game.result_a > game.result_b) {
            score += 25
          }
        } else if ((guess.result_a < guess.result_b && game.result_a < game.result_b) || (guess.result_a > guess.result_b && game.result_a > game.result_b)) {
          score += 25
        }

        return connection.execute('UPDATE `guessings` SET guessings.score = ? WHERE guessings.id = ?', [
          score,
          guess.id
        ])
      })

      await Promise.all(batch)

      const [groups] = await connection.execute('SELECT groups.id, groups.name, SUM(guessings.score) as score FROM `groups` LEFT JOIN guessings ON guessings.group_id = groups.id GROUP BY groups.id ORDER BY score DESC')
      await encRedisClient.setexAsync('groupsRanking', 84600, groups, (err) => {
        if (err) {
          console.log(err.message)
        }
      })

      const [users] = await connection.execute('SELECT users.id, users.name, SUM(guessings.score) as score FROM `users` LEFT JOIN guessings on guessings.user_id = users.id GROUP BY users.id ORDER BY score DESC')
      await encRedisClient.setexAsync('usersRanking', 84600, users, (err) => {
        if (err) {
          console.log(err.message)
        }
      })

      await encRedisClient.setAsync('invalidatedCache', true, (err) => {
        if (err) {
          console.log(err.message)
        }
      })
    }

    res.redirect('/admin/games')
  })

  route.get('/games/delete/:id', async (req, res) => {
    await connection.execute('DELETE FROM `games` WHERE games.id = ? LIMIT 1', [
      req.params.id
    ])

    res.redirect('/admin/games')
  })

  return route
}

module.exports = init