server.js

const express = require('express')
const cors = require('cors')
const morgan = require('morgan')
const {initCommuneFields, initCommuneFormat, communesDefaultQuery} = require('./lib/communeHelpers')
const {initDepartementFields} = require('./lib/departementHelpers')
const {initRegionFields} = require('./lib/regionHelpers')
const {formatOne, initLimit} = require('./lib/helpers')
const dbCommunes = require('./lib/communes').getIndexedDb()
const dbDepartements = require('./lib/departements').getIndexedDb()
const dbRegions = require('./lib/regions').getIndexedDb()
const {pick} = require('lodash')

const app = express()
app.use(cors({origin: true}))

if (process.env.NODE_ENV !== 'production') {
  app.use(morgan('dev'))
}

// Inject databases references
app.use((req, res, next) => {
  req.db = {
    communes: dbCommunes,
    departements: dbDepartements,
    regions: dbRegions
  }
  next()
})

/* Communes */
app.get('/communes', initLimit(), initCommuneFields, initCommuneFormat, (req, res) => {
  const query = pick(req.query, 'type', 'code', 'codePostal', 'nom', 'codeDepartement', 'codeRegion', 'boost')
  if (req.query.lat && req.query.lon) {
    const lat = parseFloat(req.query.lat)
    const lon = parseFloat(req.query.lon)
    if (Number.isFinite(lat) &&
      lat >= -90 &&
      lat <= 90 &&
      Number.isFinite(lon) &&
      lon >= -180 &&
      lon <= 180
    ) {
      query.pointInContour = [lon, lat]
    }
  }

  if (query.nom) {
    req.fields.add('_score')
  }

  if (Object.keys(query).length === 0 && (req.outputFormat === 'geojson' || req.fields.has('contour'))) {
    return res.sendStatus(400)
  }

  if (query.type) {
    query.type = query.type.split(',')
  }

  const result = req.applyLimit(dbCommunes.search({...communesDefaultQuery, ...query}))

  if (req.outputFormat === 'geojson') {
    res.send({
      type: 'FeatureCollection',
      features: result.map(commune => formatOne(req, commune))
    })
  } else {
    res.send(result.map(commune => formatOne(req, commune)))
  }
})

app.get('/communes/:code', initCommuneFields, initCommuneFormat, (req, res) => {
  const communes = dbCommunes.search({code: req.params.code})
  if (communes.length === 0) {
    res.sendStatus(404)
  } else {
    res.send(formatOne(req, communes[0]))
  }
})

/* Départements */
app.get('/departements', initLimit(), initDepartementFields, (req, res) => {
  const query = pick(req.query, 'code', 'nom', 'codeRegion')

  if (query.nom) {
    req.fields.add('_score')
  }

  res.send(
    req.applyLimit(dbDepartements.search(query))
      .map(departement => formatOne(req, departement))
  )
})

app.get('/departements/:code', initDepartementFields, (req, res) => {
  const departements = dbDepartements.search({code: req.params.code})
  if (departements.length === 0) {
    res.sendStatus(404)
  } else {
    res.send(formatOne(req, departements[0]))
  }
})

app.get('/departements/:code/communes', initLimit(), initCommuneFields, initCommuneFormat, (req, res) => {
  const departements = dbDepartements.search({code: req.params.code})
  if (departements.length === 0) {
    res.sendStatus(404)
  } else {
    const communes = req.applyLimit(dbCommunes.search({...communesDefaultQuery, codeDepartement: req.params.code}))
    if (req.outputFormat === 'geojson') {
      res.send({
        type: 'FeatureCollection',
        features: communes.map(commune => formatOne(req, commune))
      })
    } else {
      res.send(communes.map(commune => formatOne(req, commune)))
    }
  }
})

/* Régions */
app.get('/regions', initLimit(), initRegionFields, (req, res) => {
  const query = pick(req.query, 'code', 'nom')

  if (query.nom) {
    req.fields.add('_score')
  }

  res.send(
    req.applyLimit(dbRegions.search(query))
      .map(region => formatOne(req, region))
  )
})

app.get('/regions/:code', initRegionFields, (req, res) => {
  const regions = dbRegions.search({code: req.params.code})
  if (regions.length === 0) {
    res.sendStatus(404)
  } else {
    res.send(formatOne(req, regions[0]))
  }
})

app.get('/regions/:code/departements', initLimit(), initDepartementFields, (req, res) => {
  const regions = dbRegions.search({code: req.params.code})
  if (regions.length === 0) {
    res.sendStatus(404)
  } else {
    const departements = req.applyLimit(dbDepartements.search({codeRegion: req.params.code}))
    res.send(departements.map(commune => formatOne(req, commune)))
  }
})

/* Raw data */
app.get('/raw/communes.json', (req, res) => {
  res.download('data/communes.json')
})

app.get('/raw/departements.json', (req, res) => {
  res.download('data/departements.json')
})

app.get('/raw/regions.json', (req, res) => {
  res.download('data/regions.json')
})

/* Definition */
app.get('/definition.yml', (req, res) => {
  res.sendFile(__dirname + '/definition.yml')
})

const port = process.env.PORT || 5000

app.listen(port, () => {
  /* eslint no-console: 0 */
  console.log('Start listening on port %d', port)
})

module.exports = app