import { connect, IClientOptions, IPublishPacket, Packet } from "mqtt";import { fromEvent } from "rxjs";import { bufferTime, filter, map, takeUntil } from "rxjs/operators";const powerLinesMQTTClient = connect(MQTT_BROKER_URL!, options);const connect$ = fromEvent(powerLinesMQTTClient, "connect");const disconnect$ = fromEvent(powerLinesMQTTClient, "disconnect");const error$ = fromEvent(powerLinesMQTTClient, "error");const message$ = fromEvent(powerLinesMQTTClient, "message");connect$.subscribe(onConnect);disconnect$.subscribe(onDisconnect);error$.subscribe(onError);message$  .pipe(    filter(([topic]: [string, Buffer, IPublishPacket]) => {      Logger.log("debug", `[MQTT] PowerLinesMQTTClient subscribed to ${topic}`);      const { fieldName } = messagesUtils.parseTopic(topic);      if (Object.values(SupportedTopics).includes(fieldName as SupportedTopics)) {        return true;      }      Logger.log(        "warn",        `[MQTT] Warning: this type of messages: ${fieldName} is not handling by PowerLinesMQTTClient`      );      return false;    })  )  .pipe(    map(([topic, payload]): MessageTS => {      const { fieldName, hostName } = messagesUtils.parseTopic(topic);

{  "compilerOptions": {    /* Basic Options */    "target": "es2018",    "module": "esNext",    "lib": ["esnext", "dom"],    "allowJs": true,    "checkJs": false,    "jsx": "preserve",    "incremental": true,    "noEmit": true,    /* Strict Type-Checking Options */    "strict": true,    "noImplicitAny": true,    "strictNullChecks": true,    /* Additional Checks */    "noUnusedLocals": true,    "noUnusedParameters": true,    "noImplicitReturns": false,    "noFallthroughCasesInSwitch": false,    /* Module Resolution Options */    "baseUrl": ".",    "paths": {      /* Support absolute /imports/* with a leading '/' */      "/*": ["*"],      /* Pull in type declarations for Meteor packages from either zodern:types or @types/meteor packages */      "meteor/*": ["node_modules/@types/meteor/*", ".meteor/local/types/packages.d.ts"],      "meteor/mdg:validated-method": [        "@types/meteor/mdg:validated-method",        ".meteor/local/types/packages.d.ts"      ],      "meteor/hwillson:stub-collections": [        "@types/meteor/hwillson:stub-collections",        ".meteor/local/types/packages.d.ts"      ],      "meteor/johanbrook:publication-collector": [        "@types/meteor/johanbrook:publication-collector",        ".meteor/local/types/packages.d.ts"      ],      "meteor/tunguska:reactive-aggregate": [        "@types/meteor/tunguska:reactive-aggregate",        ".meteor/local/types/packages.d.ts"      ],      "meteor/percolate:migrations": [        "@types/meteor/percolate:migrations",        ".meteor/local/types/packages.d.ts"      ],      "meteor/cultofcoders:redis-oplog": [        "@types/meteor/cultofcoders:redis-oplog",        ".meteor/local/types/packages.d.ts"      ],      "*.ts": ["*"]    },    "moduleResolution": "node",    "resolveJsonModule": true,    "types": ["node", "mocha", "@emotion/react/types/css-prop", "meteor", "@types/meteor-roles"],    "esModuleInterop": true,    "preserveSymlinks": true,    "experimentalDecorators": true,    "emitDecoratorMetadata": true  },  "exclude": ["./node_modules/**", "./.meteor/**", "./packages/**"]}