Express examples with Spev 1.0

Signed-off-by: Fabio José <[email protected]>

Author: fabiojose

examples/express-ex/README.md

@@ -6,6 +6,89 @@
 npm start
 ```
 
+## Spec v1.0
+
+
+__A Structured One__
+
+> Payload [example](../payload/v1/structured-event-0.json)
+
+```bash
+curl -X POST \
+     -d'@../payload/v1/structured-event-0.json' \
+     -H'Content-Type:application/cloudevents+json' \
+     http://localhost:3000/v1
+```
+
+__A Structured One with Extension__
+
+> Payload [example](../payload/v1/structured-event-1.json)
+
+```bash
+curl -X POST \
+     -d'@../payload/v1/structured-event-1.json' \
+     -H'Content-Type:application/cloudevents+json' \
+     http://localhost:3000/v1
+```
+
+__A Structured One with Base64 Event Data__
+
+> Payload [example](../payload/v1/structured-event-2.json)
+
+```bash
+curl -X POST \
+     -d'@../payload/v1/structured-event-2.json' \
+     -H'Content-Type:application/cloudevents+json' \
+     http://localhost:3000/v1
+```
+
+__A Binary One__
+
+```bash
+curl -X POST \
+     -d'@../payload/data-0.json' \
+     -H'Content-Type:application/json' \
+     -H'ce-specversion:1.0' \
+     -H'ce-type:com.github.pull.create' \
+     -H'ce-source:https://github.com/cloudevents/spec/pull/123' \
+     -H'ce-id:45c83279-c8a1-4db6-a703-b3768db93887' \
+     -H'ce-time:2019-11-06T11:17:00Z' \
+     http://localhost:3000/v1/binary
+```
+
+__A Binary One with Extension__
+
+```bash
+curl -X POST \
+     -d'@../payload/data-0.json' \
+     -H'Content-Type:application/json' \
+     -H'ce-specversion:1.0' \
+     -H'ce-type:com.github.pull.create' \
+     -H'ce-source:https://github.com/cloudevents/spec/pull/123' \
+     -H'ce-id:45c83279-c8a1-4db6-a703-b3768db93887' \
+     -H'ce-time:2019-11-06T11:17:00Z' \
+     -H'ce-my-extension:extension value' \
+     http://localhost:3000/v1/binary
+```
+
+__A Binary One with Base 64 Encoding__
+
+```bash
+curl -X POST \
+     -d'@../payload/data-1.txt' \
+     -H'Content-Type:application/json' \
+     -H'ce-specversion:1.0' \
+     -H'ce-type:com.github.pull.create' \
+     -H'ce-source:https://github.com/cloudevents/spec/pull/123' \
+     -H'ce-id:45c83279-c8a1-4db6-a703-b3768db93887' \
+     -H'ce-time:2019-11-06T11:17:00Z' \
+     http://localhost:3000/v1/binary
+```
+
+__A Batch One__
+
+TODO
+
 ## Spec v0.3
 
 __A Structured One__

examples/express-ex/index.js

@@ -1,14 +1,18 @@
-var express = require("express");
-var app = express();
+const express = require("express");
+const app = express();
 
 const v03 = require("cloudevents-sdk/v03");
-var unmarshaller03 = new v03.HTTPUnmarshaller();
+const unmarshaller03 = new v03.HTTPUnmarshaller();
 
 const v02 = require("cloudevents-sdk/v02");
-var unmarshaller02 = new v02.HTTPUnmarshaller();
+const unmarshaller02 = new v02.HTTPUnmarshaller();
+
+const v1 = require("cloudevents-sdk/v1");
+const structured1 = new v1.StructuredHTTPReceiver();
+const binary1 = new v1.BinaryHTTPReceiver();
 
 app.use((req, res, next) => {
-    var data="";
+    let data="";
 
     req.setEncoding("utf8");
     req.on("data", function(chunk) {
@@ -21,6 +25,48 @@ app.use((req, res, next) => {
     });
 });
 
+app.post("/v1", function (req, res) {
+  console.log(req.headers);
+  console.log(req.body);
+
+  try {
+    let myevent = structured1.parse(req.body, req.headers);
+    // pretty print
+    console.log("Accepted event:");
+    console.log(JSON.stringify(myevent.format(), null, 2));
+
+    res.status(201)
+          .json(myevent.format());
+
+  } catch (err) {
+    console.error(err);
+    res.status(415)
+          .header("Content-Type", "application/json")
+          .send(JSON.stringify(err));
+  }
+});
+
+app.post("/v1/binary", function (req, res) {
+  console.log(req.headers);
+  console.log(req.body);
+
+  try {
+    let myevent = binary1.parse(req.body, req.headers);
+    // pretty print
+    console.log("Accepted event:");
+    console.log(JSON.stringify(myevent.format(), null, 2));
+
+    res.status(201)
+          .json(myevent.format());
+
+  } catch (err) {
+    console.error(err);
+    res.status(415)
+          .header("Content-Type", "application/json")
+          .send(JSON.stringify(err));
+  }
+});
+
 app.post("/v03", function (req, res) {
   console.log(req.headers);
   console.log(req.body);