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