Receive research results with webhooks

import express from 'express';

const app = express();
const port = process.env.PORT || 3000;
const webhookSecret = process.env.WEBHOOK_SECRET;

app.use(express.json());

app.post('/webhooks/research-results', (req, res) => {
  const receivedSecret = req.header('x-seamless-webhook-secret');

  if (!receivedSecret || receivedSecret !== webhookSecret) {
    return res.status(401).json({ message: 'Invalid webhook secret' });
  }

  if (!req.body || typeof req.body !== 'object' || Array.isArray(req.body)) {
    return res.status(400).json({ message: 'Invalid JSON payload' });
  }

  try {
    console.log('Webhook received:', JSON.stringify(req.body, null, 2));
    return res.status(200).json({ received: true });
  } catch (error) {
    console.error('Webhook processing failed:', error);
    return res.status(500).json({ message: 'Webhook processing failed' });
  }
});

app.use((error, req, res, next) => {
  if (error instanceof SyntaxError && 'body' in error) {
    return res.status(400).json({ message: 'Malformed JSON body' });
  }
  return next(error);
});

app.listen(port, () => {
  console.log(`Webhook receiver listening on port ${port}`);
});