chore: PubSub naming

nmshd · Nov 21, 2023 · a79cf85 · a79cf85
1 parent 3949b65
commit a79cf85
Show file tree

Hide file tree

Showing 5 changed files with 13 additions and 13 deletions.
diff --git a/.dev/pubsub/samplePubsubPublisher.ts b/.dev/pubsub/samplePubsubPublisher.ts
@@ -1,13 +1,13 @@
 import { PubSub } from "@google-cloud/pubsub";
 
-const pubsub = new 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 topic = pubSub.topic(topicName!);
 
     const topicExists = (await topic.exists())[0];
     if (!topicExists) throw new Error(`Topic ${topicName} does not exist.`);

diff --git a/.dev/pubsub/samplePubsubReader.ts b/.dev/pubsub/samplePubsubReader.ts
@@ -1,13 +1,13 @@
 import { PubSub } from "@google-cloud/pubsub";
 
-const pubsub = new 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 topic = pubSub.topic(topicName!);
 
     const topicExists = (await topic.exists())[0];
     if (!topicExists) throw new Error(`Topic ${topicName} does not exist.`);

diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -2,7 +2,7 @@
 
 ## 3.6.0
 
--   new module: 'pubsubPublisher' (see https://enmeshed.eu/operate/configuration#pubsubPublisher for more details on how to configure it)
+-   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

diff --git a/config/default.json b/config/default.json
@@ -101,10 +101,10 @@
             "displayName": "AMQP Publisher",
             "location": "amqpPublisher/AMQPPublisherModule"
         },
-        "pubsubPublisher": {
+        "PubSubPublisher": {
             "enabled": false,
             "displayName": "PubSub Publisher",
-            "location": "pubsubPublisher/PubsubPublisherModule",
+            "location": "pubSubPublisher/PubSubPublisherModule",
             "projectId": "",
             "topic": "",
             "keyFile": ""

diff --git a/.../pubsubPublisher/PubsubPublisherModule.ts → .../pubSubPublisher/PubSubPublisherModule.ts b/.../pubsubPublisher/PubsubPublisherModule.ts → .../pubSubPublisher/PubSubPublisherModule.ts
@@ -3,27 +3,27 @@ import { DataEvent, Event } from "@js-soft/ts-utils";
 import { DataEvent as RuntimeDataEvent } from "@nmshd/runtime";
 import { ConnectorRuntimeModule, ConnectorRuntimeModuleConfiguration } from "../../ConnectorRuntimeModule";
 
-export interface PubsubPublisherModuleConfiguration extends ConnectorRuntimeModuleConfiguration {
+export interface PubSubPublisherModuleConfiguration extends ConnectorRuntimeModuleConfiguration {
     projectId: string;
     topicName: string;
     keyFile: string;
 }
 
-export default class PubsubPublisherModule extends ConnectorRuntimeModule<PubsubPublisherModuleConfiguration> {
-    private pubsub: PubSub;
+export default class PubSubPublisherModule extends ConnectorRuntimeModule<PubSubPublisherModuleConfiguration> {
+    private pubSub: PubSub;
     private topic: Topic;
 
     public async init(): Promise<void> {
         if (!this.configuration.projectId) throw new Error("Cannot start the module, the projectId is not defined.");
         if (!this.configuration.topicName) throw new Error("Cannot start the module, the topic is not defined.");
         if (!this.configuration.keyFile) throw new Error("Cannot start the module, the keyFile is not defined.");
 
-        this.pubsub = new PubSub({
+        this.pubSub = new PubSub({
             projectId: this.configuration.projectId,
             keyFile: this.configuration.keyFile
         });
 
-        this.topic = this.pubsub.topic(this.configuration.topicName);
+        this.topic = this.pubSub.topic(this.configuration.topicName);
         this.logger.info("Checking if topic exists...");
 
         const topicExists = (await this.topic.exists())[0];
@@ -49,6 +49,6 @@ export default class PubsubPublisherModule extends ConnectorRuntimeModule<Pubsub
     public async stop(): Promise<void> {
         this.unsubscribeFromAllEvents();
 
-        await this.pubsub.close().catch((e) => this.logger.error("Could not close the pubsub", e));
+        await this.pubSub.close().catch((e) => this.logger.error("Could not close the PubSub object", e));
     }
 }