SIGSEV/Starveller

import _ from 'lodash'
import express from 'express'

import './db'
import config from 'config'
import * as repo from 'api/Repo.service'
import { toObj, lightRepo, fullRepo } from 'api/transformRepo'
import { getBars } from 'core/helpers/repos'

const router = express.Router()

const barsRepo = r => ({ ...r, bars: getBars(r, 30) })

router.get('/repos', (req, res) => {
  repo.getAll()
    .then(repos => repos.filter(r => r.summary.starsCount < 40000))
    .then(repos => _.orderBy(repos, 'summary.starsCount', 'desc').slice(0, 10))
    .then(repos => res.send(repos.map(_.flow(toObj, lightRepo))))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.get('/trending', (req, res) => {
  repo.getTrending()
    .then(repos => repos.map(_.flow(toObj, barsRepo, lightRepo)))
    .then(repos => res.send(repos))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.get('/featured', (req, res) => {
  repo.getFeatured()
    .then(repos => repos.map(_.flow(toObj, barsRepo, lightRepo)))
    .then(repos => res.send(repos))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.post('/repos', (req, res) => {
  repo.ask(req.body.name)
    .then(_.flow(toObj, lightRepo))
    .then(repo => res.send(repo))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.put('/repos/:id/refresh', (req, res) => {
  if (config.env === 'production') { return res.status(401).end() }

  repo.refreshOne(req.body.name, req.body.full)
    .then(_.flow(toObj, fullRepo))
    .then(repo => res.send(repo))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.put('/repos', (req, res) => {
  response(repo.createRepo.bind(this, req.body.name), res)
})

router.delete('/repos', (req, res) => {
  if (config.env === 'production') { return res.status(401).end() }

  repo.removeByName(req.body.name)
    .then(() => res.sendStatus(200))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.get('/repos/:user/:repo', (req, res) => {
  const name = `${req.params.user}/${req.params.repo}`

  repo.checkRefresh(name)
    .then(() => repo.ask(name))
    .then(_.flow(toObj, fullRepo))
    .then(repo => res.send(repo))
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.get('/repos/:user/:repo/badge', (req, res) => {
  const name = `${req.params.user}/${req.params.repo}`

  repo.checkRefresh(name)
    .then(() => repo.ask(name))
    .then(() => repo.getRanking(name))
    .then(rank => {
      res.sendFile(`${rank}.svg`, { root: `${__dirname}/../client/assets/badges` })
    })
    .catch(err => res.status(err.code || 500).send({ message: err.message }))
})

router.post('/repos/:user/:repo/events', (req) => {
  const name = `${req.params.user}/${req.params.repo}`
  response(repo.createEvent.bind(this, { name, data: req.body }))
})

function response (fn, res) {
  fn()
    .then(data => { res.status(200).send(data) })
    .catch(err => {
      const { stack, message } = err
      /* eslint-disable no-console */
      console.log(stack)
      /* eslint-enable no-console */
      res.status(400).send({ message })
    })
}

export default router