dca7e56c3d
* Add more info to hydro failures * Clean up * Update hydro.js * Move hydro names to event schema file * Update hydro.js
34 lines
900 B
JavaScript
34 lines
900 B
JavaScript
import express from 'express'
|
|
import { omit } from 'lodash-es'
|
|
import Ajv from 'ajv'
|
|
import addFormats from 'ajv-formats'
|
|
import { eventSchema, hydroNames } from '../lib/schema-event.js'
|
|
|
|
const OMIT_FIELDS = ['type']
|
|
|
|
const ajv = new Ajv()
|
|
addFormats(ajv)
|
|
|
|
const router = express.Router()
|
|
|
|
router.post('/', async function postEvents(req, res, next) {
|
|
const isDev = process.env.NODE_ENV === 'development'
|
|
const fields = omit(req.body, '_csrf')
|
|
|
|
if (!ajv.validate(eventSchema, fields)) {
|
|
return res.status(400).json(isDev ? ajv.errorsText() : {})
|
|
}
|
|
|
|
if (req.hydro.maySend()) {
|
|
// intentionally don't await this async request
|
|
// so that the http response afterwards is sent immediately
|
|
req.hydro.publish(hydroNames[fields.type], omit(fields, OMIT_FIELDS)).catch((e) => {
|
|
if (isDev) console.error(e)
|
|
})
|
|
}
|
|
|
|
return res.status(200).json({})
|
|
})
|
|
|
|
export default router
|