docs/middleware/events.js

34 строки
813 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() : {})
}
res.json({})
if (req.hydro.maySend()) {
try {
await req.hydro.publish(hydroNames[fields.type], omit(fields, OMIT_FIELDS))
} catch (err) {
console.error('Failed to submit event to Hydro', err)
}
}
})
export default router