Feature/pubsub publisher

.dev/compose.yml

@@ -17,7 +17,7 @@ services:
       - transportLibrary__platformClientSecret
     volumes:
       - ..:/usr/app
-      - ./config.json:/config.json:RO
+      - ./config.json:/config.json:ro
     depends_on:
       - mongo
       - mongo-express
@@ -41,7 +41,7 @@ services:
       - transportLibrary__platformClientSecret
     volumes:
       - ..:/usr/app
-      - ./config.json:/config.json:RO
+      - ./config.json:/config.json:ro
     depends_on:
       - mongo
       - mongo-express

.dev/mq/sampleMQReader.ts

@@ -4,7 +4,7 @@ async function run() {
     const connection = await rabbit.connect("amqp://localhost");
     const channel = await connection.createChannel();
 
-    await this.channel.assertExchange("nmshd", "fanout");
+    await channel.assertExchange("nmshd", "fanout");
 
     const queueName = "myQueue";
 

.dev/pubsub/samplePubsubPublisher.ts

@@ -0,0 +1,19 @@
+import { PubSub } from "@google-cloud/pubsub";
+
+const pubSub = new PubSub({
+    projectId: process.env.PUBSUB_PROJECT_ID,
+    keyFile: process.env.PUBSUB_KEY_FILE
+});
+
+async function run() {
+    const topicName = process.env.PUBSUB_TOPIC_NAME;
+    const topic = pubSub.topic(topicName!);
+
+    const topicExists = (await topic.exists())[0];
+    if (!topicExists) throw new Error(`Topic ${topicName} does not exist.`);
+
+    const x = await topic.publishMessage({ json: { foo: "bar" }, attributes: { namespace: "test" } });
+    console.log(x);
+}
+
+run();

.dev/pubsub/samplePubsubReader.ts

@@ -0,0 +1,28 @@
+import { PubSub } from "@google-cloud/pubsub";
+
+const pubSub = new PubSub({
+    projectId: process.env.PUBSUB_PROJECT_ID,
+    keyFile: process.env.PUBSUB_KEY_FILE
+});
+
+async function run() {
+    const topicName = process.env.PUBSUB_TOPIC_NAME;
+    const topic = pubSub.topic(topicName!);
+
+    const topicExists = (await topic.exists())[0];
+    if (!topicExists) throw new Error(`Topic ${topicName} does not exist.`);
+
+    const subscription = topic.subscription(process.env.PUBSUB_SUBSCRIPTION_NAME!);
+    const subscriptionExists = (await subscription.exists())[0];
+    if (!subscriptionExists) throw new Error(`Subscription ${topicName} does not exist.`);
+
+    subscription.on("message", (message) => {
+        console.log(message.id);
+        console.log(message.data.toString());
+        console.log(message.attributes);
+
+        message.ack();
+    });
+}
+
+run();

CHANGELOG.md

@@ -1,5 +1,10 @@
 # Changelog
 
+## 3.6.0
+
+-   new module: 'PubSubPublisher' (see https://enmeshed.eu/operate/configuration#PubSubPublisher for more details on how to configure it)
+-   upgrade the runtime version to 2.10.0
+
 ## 3.5.6
 
 -> SDK 2.2.4
@@ -42,8 +47,8 @@
 -> SDK 2.2.2
 
 -   upgrade the runtime version to 2.6.1
-    -   support for the new [FreeTextRequestItem](https://enmeshed.eu/integrate/data-model-request-items#freetextrequestitem)
-    -   support for the AttributeValue [Statement](https://enmeshed.eu/integrate/data-model-attribute-values#statement)
+    -   support for the new [FreeTextRequestItem](https://enmeshed.eu/integrate/requests-and-requestitems#freetextrequestitem)
+    -   support for the AttributeValue [Statement](https://enmeshed.eu/integrate/attribute-values#statement)
 
 ## 3.4.0
 
@@ -179,7 +184,7 @@
 
 ## 3.0.4
 
--   upgrade the runtime to version 2.0.1 ([`ProprietaryJSON`](https://enmeshed.eu/integrate/data-model-attribute-values#proprietaryjson) AttributeValueType)
+-   upgrade the runtime to version 2.0.1 ([`ProprietaryJSON`](https://enmeshed.eu/integrate/attribute-values#proprietaryjson) AttributeValueType)
 
 ## 3.0.3
 
@@ -252,7 +257,7 @@
 
 ## 2.3.0
 
--   new module: 'webhooksV2' (see https://enmeshed.eu/integrate/connector-configuration#webhooksV2 for more details on how to configure it)
+-   new module: 'webhooksV2' (see https://enmeshed.eu/operate/configuration#webhooksV2 for more details on how to configure it)
 -   the 'webhooks' module is now deprecated
 
 ## 2.2.1

config/default.json

@@ -100,6 +100,14 @@
             "enabled": false,
             "displayName": "AMQP Publisher",
             "location": "amqpPublisher/AMQPPublisherModule"
+        },
+        "PubSubPublisher": {
+            "enabled": false,
+            "displayName": "PubSub Publisher",
+            "location": "pubSubPublisher/PubSubPublisherModule",
+            "projectId": "",
+            "topic": "",
+            "keyFile": ""
         }
     }
 }

helmChart/README.md

@@ -2,7 +2,7 @@
 
 ## Documentation
 
-You can find a more detailed documentation [in the enmeshed docs](https://enmeshed.eu/integrate/helm-chart).
+You can find a more detailed documentation [in the enmeshed docs](https://enmeshed.eu/operate/setup-with-helm-charts).
 
 ## Usage
 

helmChart/values.yaml

@@ -3,7 +3,7 @@ image:
   tag: ""
 
 # a json or yaml config
-# see https://enmeshed.eu/integrate/connector-configuration for configuration options
+# see https://enmeshed.eu/operate/configuration for configuration options
 config:
   logging:
     appenders:
@@ -30,7 +30,7 @@ pod:
 
   connector:
     # a list of environment variables
-    # see https://enmeshed.eu/integrate/connector-configuration for configuration options
+    # see https://enmeshed.eu/operate/configuration for configuration options
     # can be used for secrets
     # see https://kubernetes.io/docs/reference/kubernetes-api/workload-resources/pod-v1/#environment-variables
     environment: []