Add web publish endpoint

CodeCommission · Dec 10, 2017 · ad6cac7 · ad6cac7
1 parent 5a6b4b5
commit ad6cac7
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "subscriptions-transport-sse",
-  "version": "0.7.7",
+  "version": "0.7.8",
   "author": "Mike Bild <mike.bild@googlemail.com>",
   "license": "MIT",
   "homepage": "https://github.com/mikebild/subscriptions-transport-sse#readme",

diff --git a/src/express.js b/src/express.js
@@ -67,12 +67,12 @@ export function SubscriptionServer(subscriptionOptions, connectionOptions) {
     });
 
     connectionOptions.express.post(
-      `${connectionOptions.path}/publish/:id`,
+      `${connectionOptions.path}/publish/:topic?`,
       (req, res) => {
-        const connectionSubscriptionId = req.params.id;
+        const topic = req.params.topic || 'event-web-publish';
         const data = req.body || {};
         res.setHeader('Content-Type', 'application/json');
-        emitter.emit(`event-${connectionSubscriptionId}`, null, {data});
+        subscriptionOptions.subscriptionManager.pubsub.publish(topic, data);
         res.sendStatus(202);
       }
     );