Official CloudEvents' SDK for JavaScript.
NOTE: This SDK is still considered work in progress, things might (and will) break with every update.
Checkout the changelog to see what's going on!
Before create an awesome PR, please read our guidelines.
To see working examples, point to examples.
all the API developed before, for 0.1, 0.2 and 0.3, works as the same.
Checkout the new expressive additions.
There is full example: typescript-ex
import Cloudevent, {
event,
StructuredHTTPEmitter,
BinaryHTTPEmitter,
StructuredHTTPReceiver,
BinaryHTTPReceiver
} from 'cloudevents-sdk/v1';
let myevent: Cloudevent = event()
.source('/source')
.type('type')
.dataContentType('text/plain')
.dataschema('http://d.schema.com/my.json')
.subject('cha.json')
.data('my-data')
.addExtension("my-ext", "0x600");
// . . .
0.x.p
: wherex
relates to spec version andp
relates to fixes, releases and breaking changes
x.M.p
: wherex
relates to spec version,M
relates to minor andp
relates to fixes. See semver
This CloudEvents SDK requires nodejs 6.11+
npm install cloudevents-sdk
These are the supported specifications by this version.
Specifications | v0.1 | v0.2 | v0.3 | v1.0 |
---|---|---|---|---|
CloudEvents | yes | yes | yes | yes |
HTTP Transport Binding - Structured | yes | yes | yes | yes |
HTTP Transport Binding - Binary | yes | yes | yes | yes |
JSON Event Format | yes | yes | yes | yes |
What | v0.1 | v0.2 | v0.3 | v1.0 |
---|---|---|---|---|
Create events | yes | yes | yes | yes |
Emit Structured events over HTTP | yes | yes | yes | yes |
Emit Binary events over HTTP | yes | yes | yes | yes |
JSON Event Format | yes | yes | yes | yes |
Receive Structured events over HTTP | no | yes | yes | yes |
Receive Binary events over HTTP | no | yes | yes | yes |
If you want old examples, they are here
const v1 = require("cloudevents-sdk/v1");
/*
* Creating an event
*/
let myevent = v1.event()
.type("com.github.pull.create")
.source("urn:event:from:myapi/resourse/123");
const v1 = require("cloudevents-sdk/v1");
/*
* Creating an event
*/
let myevent = v1.event()
.type("com.github.pull.create")
.source("urn:event:from:myapi/resourse/123");
/*
* Format the payload and return it
*/
let formatted = myevent.format();
const v1 = require("cloudevents-sdk/v1");
/*
* Creating an event
*/
let myevent = v1.event()
.type("com.github.pull.create")
.source("urn:event:from:myapi/resourse/123");
// The binding configuration using POST
let config = {
method: "POST",
url : "https://myserver.com"
};
// The binding instance
let binding = new v1.StructuredHTTPEmitter(config);
// Emit the event using Promise
binding.emit(myevent)
.then(response => {
// Treat the response
console.log(response.data);
}).catch(err => {
// Deal with errors
console.error(err);
});
You can choose any framework for port binding. But, use the StructuredHTTPReceiver or BinaryHTTPReceiver to process the HTTP Payload and HTTP Headers, extracting the CloudEvents.
😃 Checkout the full working example: here.
// some parts were removed //
const v1 = require("cloudevents-sdk/v1");
const receiver = new v1.StructuredHTTPReceiver();
// some parts were removed //
app.post("/", (req, res) => {
try {
let myevent = receiver.parse(req.body, req.headers);
// TODO use the event
res.status(201).send("Event Accepted");
} catch(err) {
// TODO deal with errors
console.error(err);
res.status(415)
.header("Content-Type", "application/json")
.send(JSON.stringify(err));
}
});
├── index.js
├── ext
├── lib
│ ├── bindings
│ │ └── http
│ ├── cloudevent.js
│ ├── formats
│ │ └── json
│ └── specs
├── LICENSE
├── package.json
├── README.md
index.js
: library exportsext
: external stuff, e.g, Cloud Events JSONSchemalib/bindings
: every binding implementation goes herelib/bindings/http
: every http binding implementation goes herelib/cloudevent.js
: implementation of Cloudevent, an interfacelib/formats/
: every format implementation goes herelib/specs/
: every spec implementation goes here
The unit test checks the result of formatted payload and the constraints.
npm test
/*
* Format the payload and return an Object.
*/
Object Cloudevent.format()
/*
* Format the payload as String.
*/
String Cloudevent.toString()
Every formatter class must implement these methods to work properly.
/*
* Format the Cloudevent payload argument and return an Object.
*/
Object Formatter.format(Object)
/*
* Format the Cloudevent payload as String.
*/
String Formatter.toString(Object)
Every Parser class must implement these methods to work properly.
/*
* The default constructor with Parser as decorator
*/
Parser(Parser)
/*
* Try to parse the payload to some event format
*/
Object Parser.parse(payload)
Every Spec class must implement these methods to work properly.
/*
* The constructor must receives the Cloudevent type.
*/
Spec(Cloudevent)
/*
* Checks the spec constraints, throwing an error if do not pass.
* @throws Error when it is an invalid event
*/
Spec.check()
/*
* Checks if the argument pass through the spec constraints
* @throws Error when it is an invalid event
*/
Spec.check(Object)
Every Binding class must implement these methods to work properly.
Following we have the signature for the binding to emit Cloudevents.
/*
* The constructor must receives the map of configurations.
*/
Binding(config)
/*
* Emits the event using an instance of Cloudevent.
*/
Binding.emit(cloudevent)
Following we have the signature for the binding to receive Cloudevents.
/*
* The constructor must receives the map of configurations.
*/
Receiver(config)
/*
* Checks if some Object and a Map of headers
* follows the binding definition, throwing an error if did not follow
*/
Receiver.check(Object, Map)
/*
* Checks and parse as Cloudevent
*/
Cloudevent Receiver.parse(Object, Map)
See how to implement the method injection here
Learn about Builder Design Pattern
Check out the produced event payload using this tool