feat: log and ignore invalid requests

Author: danieljtrowbridge

src/handler.ts

@@ -2,9 +2,22 @@ import axios from 'axios'
 
 import * as schema from './schema'
 
-export async function handleRawRequest(body: object): Promise<object> {
-  const { url, ...evaluationFunctionRequestData } =
-    schema.TestServerRequestData.parse(body)
+export function parseRequestBody(body: unknown): {
+  url: string
+  evaluationFunctionRequestData: schema.EvaluationFunctionRequestData
+} | null {
+  const parseResult = schema.TestServerRequestData.safeParse(body)
+  if (!parseResult.success) return null
+
+  const { url, ...evaluationFunctionRequestData } = parseResult.data
+  return { url, evaluationFunctionRequestData }
+}
+
+export async function handleRawRequest(body: unknown): Promise<object | null> {
+  const parseResult = parseRequestBody(body)
+  if (parseResult == null) return null
+
+  const { url, evaluationFunctionRequestData } = parseResult
   const response = await axios.post(url, evaluationFunctionRequestData)
   return response.data
 }

src/index.ts

@@ -12,13 +12,22 @@ app.use(cors())
 app.use(express.json())
 
 app.post('/', async (req, res) => {
-  console.log(`Received POST request:`, req.body)
+  console.log(`[INFO] Received POST request:`, req.body)
   const responseData = await handleRawRequest(req.body)
-  res.send(responseData)
+  if (responseData == null) {
+    console.log('[WARN] Invalid request received and ignored.')
+    res.status(400).send()
+  } else {
+    console.log(
+      '[INFO] Received response from evaluation function:',
+      responseData,
+    )
+    res.send(responseData)
+  }
 })
 
 const port = process.env.PORT ?? 3070
 
 app.listen(port, () => {
-  console.log(`Listening on port ${port}`)
+  console.log(`[INFO] Listening on port ${port}`)
 })