Moved the broker login to another file

app/src/broker.ts

@@ -0,0 +1,51 @@
+import Redis from "ioredis";
+
+abstract class Broker {
+ abstract onMessage(callback: Function): void;
+
+ abstract publishMessage(topic: string | null, message: any): void;
+
+ abstract quit(): void
+}
+
+class RedisBroker extends Broker {
+ redis: Redis
+ channel: string
+ hasSubscribed: boolean = false
+
+ constructor(connectionString: string, channel: string) {
+ super();
+ this.channel = channel
+ this.redis = new Redis({
+ host: connectionString.split(":")[0],
+ port: parseInt(connectionString.split(":")[1]),
+ });
+ }
+
+ publishMessage(topic: string, message: object) {
+ this.redis.publish(this.channel, JSON.stringify({
+ topic,
+ payload: message
+ }));
+ }
+
+ onMessage(callback: Function) {
+ if (!this.hasSubscribed) {
+ this.redis.subscribe(this.channel);
+ }
+ this.redis.on("message", (channel, message) => {
+ const parsedMessage = JSON.parse(message)
+ const {topic, payload} = parsedMessage;
+ callback(topic, payload);
+ }
+ );
+ }
+
+ quit() {
+ this.redis.quit()
+ }
+}
+
+export {
+ RedisBroker, Broker
+}

app/src/pubsuby.ts

@@ -1,50 +1,5 @@
-import Redis from "ioredis";
+import {Broker} from "./broker";
 
-abstract class Broker {
- abstract onMessage(callback: Function): void;
-
- abstract publishMessage(topic: string | null, message: any): void;
-
- abstract quit(): void
-}
-
-class RedisBroker extends Broker {
- redis: Redis
- channel: string
- hasSubscribed: boolean = false
-
- constructor(connectionString: string, channel: string) {
- super();
- this.channel = channel
- this.redis = new Redis({
- host: connectionString.split(":")[0],
- port: parseInt(connectionString.split(":")[1]),
- });
- }
-
- publishMessage(topic: string, message: object) {
- this.redis.publish(this.channel, JSON.stringify({
- topic,
- payload: message
- }));
- }
-
- onMessage(callback: Function) {
- if (!this.hasSubscribed) {
- this.redis.subscribe(this.channel);
- }
- this.redis.on("message", (channel, message) => {
- const parsedMessage = JSON.parse(message)
- const {topic, payload} = parsedMessage;
- callback(topic, payload);
- }
- );
- }
-
- quit() {
- this.redis.quit()
- }
-}
 
 class Pubsuby {
  broker: Broker;
@@ -80,6 +35,5 @@ class PubsubyConfig {
 
 export {
  Pubsuby,
- PubsubyConfig,
- RedisBroker
+ PubsubyConfig
 }

app/src/server.ts

@@ -1,9 +1,10 @@
 import express from "express";
-import {Pubsuby, RedisBroker} from "./pubsuby";
+import {Pubsuby} from "./pubsuby";
 import expressWs from 'express-ws'
 import {listify} from "./utils";
 import {requiredSecretApiKey} from "./middlewares";
 import Config from "./config";
+import {RedisBroker} from "./broker";
 
 let wsInstance = expressWs(express());
 let {app} = wsInstance;