text: const express = require('express');
  const bodyParser = require('body-parser');
  const axios = require('axios');
  const cors = require('cors');
  
  const app = express();
  app.use(cors());
  app.use(bodyParser.json());
  const port = 4003;
  
  app.post('/events', async (req, res) => {
      const { type, data } = req.body;
  
      if (type === 'CommentCreated') {
          const status = data.content.includes('orange')
              ? 'rejected'
              : 'approved';
  
          await axios.post('http://event-bus-srv:4005/events', {
              type: 'CommentModerated',
              data: {
                  id: data.id,
                  postId: data.postId,
                  status,
                  content: data.content,
              },
          });
      }
      
      res.send({});
  });
  
  app.listen(port, () => console.log(`Example app listening on port ${port}!`));
  