chore: release 1.0.0

examples/express-ex/discovery.js

@@ -0,0 +1,61 @@
+/* eslint-disable */
+
+const express = require("express");
+const { DiscoveryService } = require("cloudevents");
+const app = express();
+const bodyParser = require("body-parser");
+app.use(bodyParser.json());
+
+DiscoveryService.registerService({
+  url: "https://example.com/services/widgetService",
+  name: "com.example.services.widgetService",
+  specversions: ["1.0"],
+  subscriptionurl: "https://events.example.com",
+  protocols: ["HTTP"],
+  types: [
+    {
+      type: "com.example.widget.create",
+    },
+    {
+      type: "com.example.widget.delete",
+    },
+  ],
+});
+DiscoveryService.registerService({
+  url: "https://example.com/services/catService",
+  name: "com.example.services.catService",
+  specversions: ["1.0"],
+  subscriptionurl: "https://cats.example.com",
+  protocols: ["HTTP"],
+  types: [
+    {
+      type: "com.example.cats.buy",
+    },
+    {
+      type: "com.example.cats.adopt",
+    },
+    {
+      type: "com.example.cats.feed",
+    },
+    {
+      type: "com.example.cats.give",
+    },
+    {
+      // Just to play with discovery service
+      type: "com.example.widget.create",
+    },
+  ],
+});
+
+// Serve the discovery service for our services
+DiscoveryService.express(app);
+// Create a anonymous mapping of cloud events for example
+DiscoveryService.express(app, "/anonymous", (name, type, req) => {
+  // A true life example would have only one call to express and check req for permission
+  // Only give access to the catService and widgetCreate if anonymous
+  return name === "com.example.widget.create" || name === "com.example.services.catService";
+});
+
+app.listen(3000, () => {
+  console.log("Example app listening on port 3000!");
+});

examples/express-ex/index.js

@@ -1,50 +1,11 @@
 /* eslint-disable */
 
 const express = require("express");
-const { Receiver, DiscoveryService } = require("cloudevents");
+const { Receiver } = require("cloudevents");
 const app = express();
 const bodyParser = require("body-parser");
 app.use(bodyParser.json());
 
-DiscoveryService.registerService({
-  url: "https://example.com/services/widgetService",
-  name: "com.example.services.widgetService",
-  specversions: ["1.0"],
-  subscriptionurl: "https://events.example.com",
-  protocols: ["HTTP"],
-  types: [
-    {
-      type: "com.example.widget.create",
-      type: "com.example.widget.delete",
-    },
-  ],
-});
-DiscoveryService.registerService({
-  url: "https://example.com/services/catService",
-  name: "com.example.services.catService",
-  specversions: ["1.0"],
-  subscriptionurl: "https://cats.example.com",
-  protocols: ["HTTP"],
-  types: [
-    {
-      type: "com.example.cats.buy",
-      type: "com.example.cats.adopt",
-      type: "com.example.cats.feed",
-      type: "com.example.cats.give",
-      // Just to play with discovery service
-      type: "com.example.widget.create",
-    },
-  ],
-});
-
-DiscoveryService.express(app);
-// Create a anonymous mapping of cloud events for example
-DiscoveryService.express(app, "/anonymous", (name, type, req) => {
-  // A true life example would have only one call to express and check req for permission
-  // Only give access to the catService and widgetCreate if anonymous
-  return name === "com.example.widget.create" || name === "com.example.services.catService";
-});
-
 app.post("/", (req, res) => {
   console.log("HEADERS", req.headers);
   console.log("BODY", req.body);

package.json

@@ -1,6 +1,6 @@
 {
   "name": "cloudevents",
-  "version": "3.1.0",
+  "version": "1.0.0",
   "description": "CloudEvents SDK for JavaScript",
   "main": "dist/index.js",
   "scripts": {

src/discovery/index.ts

@@ -1,5 +1,16 @@
 import { CloudEventV1Service } from "../";
 
+interface RequestHandler {
+  (
+    req: { query: { matching: string }; url: string },
+    res: {
+      end: () => void;
+      status: (
+        code: number,
+      ) => { json: (obj: Record<string, unknown> | CloudEventV1Service[]) => string; end: () => void };
+    },
+  ): void;
+}
 /**
  * DiscoveryService to implement the discovery spec:
  *