cloudevents
/
sdk-javascript
mirror of https://github.com/cloudevents/sdk-javascript.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Expose the /v02 for spec 0.2 and /v03 for spec 0.3 

Signed-off-by: Fabio José <fabiojose@gmail.com>
This commit is contained in:
Fabio José 2019-08-06 11:21:57 -03:00
parent d38c857c03
commit a9dc14f617
1 changed files with 27 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
examples/express-ex/index.js
View File

@ -1,8 +1,11 @@
var express = require("express"); var express = require("express");
var app = express(); var app = express();
const v03 = require("cloudevents-sdk/v02");
var unmarshaller03 = new v03.HTTPUnmarshaller();
const v02 = require("cloudevents-sdk/v02"); const v02 = require("cloudevents-sdk/v02");
var unmarshaller = new v02.HTTPUnmarshaller(); var unmarshaller02 = new v02.HTTPUnmarshaller();
app.use((req, res, next) => { app.use((req, res, next) => {
var data=""; var data="";
@ -18,18 +21,18 @@ app.use((req, res, next) => {
}); });
}); });
app.post("/", function (req, res) { app.post("/v03", function (req, res) {
console.log(req.headers); console.log(req.headers);
console.log(req.body); console.log(req.body);
unmarshaller.unmarshall(req.body, req.headers) unmarshaller03.unmarshall(req.body, req.headers)
.then(cloudevent => { .then(cloudevent => {
// pretty print // pretty print
console.log("Accepted event:"); console.log("Accepted event:");
console.log(JSON.stringify(cloudevent.format(), null, 2)); console.log(JSON.stringify(cloudevent.format(), null, 2));
res.status(201) res.status(201)
.send("Event Created"); .json(cloudevent.format());
}) })
.catch(err => { .catch(err => {
console.error(err); console.error(err);
@ -37,7 +40,27 @@ app.post("/", function (req, res) {
.header("Content-Type", "application/json") .header("Content-Type", "application/json")
.send(JSON.stringify(err)); .send(JSON.stringify(err));
}); });
});
app.post("/v02", function (req, res) {
console.log(req.headers);
console.log(req.body);
unmarshaller02.unmarshall(req.body, req.headers)
.then(cloudevent => {
// pretty print
console.log("Accepted event:");
console.log(JSON.stringify(cloudevent.format(), null, 2));
res.status(201)
.json(cloudevent.format());
})
.catch(err => {
console.error(err);
res.status(415)
.header("Content-Type", "application/json")
.send(JSON.stringify(err));
});
}); });
app.listen(3000, function () { app.listen(3000, function () {