diff --git a/examples/express-ex/index.js b/examples/express-ex/index.js index cc8e2349..10ef8605 100644 --- a/examples/express-ex/index.js +++ b/examples/express-ex/index.js @@ -1,17 +1,29 @@ /* eslint-disable */ const express = require("express"); -const { Receiver } = require("cloudevents"); +const { CloudEvent, HTTP } = require("cloudevents"); const app = express(); -const bodyParser = require('body-parser') -app.use(bodyParser.json()) + +app.use((req, res, next) => { + let data = ""; + + req.setEncoding("utf8"); + req.on("data", function (chunk) { + data += chunk; + }); + + req.on("end", function () { + req.body = data; + next(); + }); +}); app.post("/", (req, res) => { console.log("HEADERS", req.headers); console.log("BODY", req.body); try { - const event = Receiver.accept(req.headers, req.body); + const event = HTTP.toEvent({ headers: req.headers, body: req.body }); // respond as an event const responseEventMessage = new CloudEvent({ source: '/', diff --git a/examples/express-ex/package.json b/examples/express-ex/package.json index 74fa5232..963560aa 100644 --- a/examples/express-ex/package.json +++ b/examples/express-ex/package.json @@ -14,8 +14,7 @@ "author": "fabiojose@gmail.com", "license": "Apache-2.0", "dependencies": { - "body-parser": "^1.19.0", - "cloudevents": "^3.1.0", + "cloudevents": "^4.0.0", "express": "^4.17.1" } }