cloudeventsreciever.js

const app = require("express")();
const { CloudEvent, HTTP } = require("cloudevents");
const bodyParser = require("body-parser");

// support parsing of application/json type post data
app.use(bodyParser.json());
app.use(bodyParser.json({ type: "application/*+json" }));

app.post("/", (req, res) => {
  console.log("HEADERS", req.headers);
  console.log("BODY", req.body);

  const receivedEvent = HTTP.toEvent({ headers: req.headers, body: req.body });
  console.log(receivedEvent);
});

app.listen(3000, () => {
  console.log("Example app listening on port 3000!");
});