examples(nodejs): bump to the latest 3.x version of cloudevents SDK (#2769)

* examples(nodejs): bump to the latest 3.x version of cloudevents SDK

A few changes to the API were made in the recent release of the SDK.
This commit updates the dependency and modifies the source to work
with the new API.

* squash: bump cloudevents to 3.2.0

Signed-off-by: Lance Ball <[email protected]>

* fixup: incorporate PR feedback

Signed-off-by: Lance Ball <[email protected]>

Author: lance

docs/serving/samples/cloudevents/cloudevents-nodejs/index.js

@@ -15,11 +15,10 @@ limitations under the License.
 */
 
 const express = require('express')
-const { CloudEvent, HTTPEmitter, HTTPReceiver } = require('cloudevents-sdk')
+const { CloudEvent, Emitter, HTTP } = require('cloudevents')
 const PORT = process.env.PORT || 8080
 const target = process.env.K_SINK
 const app = express()
-const receiver = new HTTPReceiver()
 
 const main = () => {
   app.listen(PORT, function () {
@@ -41,11 +40,11 @@ const receiveAndSend = (cloudEvent, res) => {
     type: 'dev.knative.docs.sample',
     source: 'https://github.com/knative/docs/docs/serving/samples/cloudevents/cloudevents-nodejs',
     time: new Date(),
-    data: data
+    data
   })
 
   // With only an endpoint URL, this creates a v1 emitter
-  const emitter = new HTTPEmitter({
+  const emitter = new Emitter({
     url: target
   })
 
@@ -55,7 +54,7 @@ const receiveAndSend = (cloudEvent, res) => {
   // Send the new Event to the K_SINK
   emitter.send(newCloudEvent)
     .then((res) => {
-      console.log(`Sent event: ${JSON.stringify(newCloudEvent.format(), null, 2)}`)
+      console.log(`Sent event: ${JSON.stringify(newCloudEvent, null, 2)}`)
       console.log(`K_SINK responded: ${JSON.stringify({ status: res.status, headers: res.headers, data: res.data }, null, 2)}`)
     })
     .catch(console.error)
@@ -64,16 +63,17 @@ const receiveAndSend = (cloudEvent, res) => {
 // receiveAndReply responds with new event
 const receiveAndReply = (cloudEvent, res) => {
   const data = handle(cloudEvent.data)
-  const headers = HTTPEmitter.headers(cloudEvent)
   const newCloudEvent = new CloudEvent({
     type: 'dev.knative.docs.sample',
     source: 'https://github.com/knative/docs/docs/serving/samples/cloudevents/cloudevents-nodejs',
-    time: new Date()
+    time: new Date(),
+    data
   })
 
-  console.log(`Reply event: ${JSON.stringify(newCloudEvent.format(), null, 2)}`)
-  res.set(headers)
-  res.status(200).send(data)
+  console.log(`Reply event: ${JSON.stringify(newCloudEvent, null, 2)}`)
+  const message = HTTP.binary(newCloudEvent);
+  res.set(message.headers)
+  res.status(200).send(message.body)
 }
 
 app.use((req, res, next) => {
@@ -90,8 +90,8 @@ app.use((req, res, next) => {
 
 app.post('/', function (req, res) {
   try {
-    const event = receiver.accept(req.headers, req.body)
-    console.log(`Accepted event: ${JSON.stringify(event.format(), null, 2)}`)
+    const event = HTTP.toEvent({headers: req.headers, body: req.body})
+    console.log(`Accepted event: ${JSON.stringify(event, null, 2)}`)
     target ? receiveAndSend(event, res) : receiveAndReply(event, res)
   } catch (err) {
     console.error(err)

docs/serving/samples/cloudevents/cloudevents-nodejs/package-lock.json

@@ -13,7 +13,7 @@
   "author": "",
   "license": "Apache-2.0",
   "dependencies": {
-    "cloudevents-sdk": "2.0.1",
+    "cloudevents": "^3.2.0",
     "express": "^4.17.1",
     "nodemon": "^2.0.4"
   },