Fixes Reflector issues in newer versions of NestJS

.gitignore

@@ -1,5 +1,4 @@
 node_modules
 .idea
-dist
 yarn.lock
 *.tsbuildinfo

dist/client.provider.d.ts

@@ -0,0 +1,2 @@
+import { Provider } from '@nestjs/common';
+export declare function createClientProvider(): Provider;

dist/index.d.ts

@@ -0,0 +1,5 @@
+export * from './mqtt.interface';
+export * from './mqtt.decorator';
+export * from './mqtt.constants';
+export * from './mqtt.module';
+export * from './mqtt.service';

dist/mqtt.constants.d.ts

@@ -0,0 +1,5 @@
+export declare const MQTT_SUBSCRIBE_OPTIONS = "__mqtt_subscribe_options";
+export declare const MQTT_SUBSCRIBER_PARAMS = "__mqtt_subscriber_params";
+export declare const MQTT_CLIENT_INSTANCE = "MQTT_CLIENT_INSTANCE";
+export declare const MQTT_OPTION_PROVIDER = "MQTT_OPTION_PROVIDER";
+export declare const MQTT_LOGGER_PROVIDER = "MQTT_LOGGER_PROVIDER";

dist/mqtt.decorator.d.ts

@@ -0,0 +1,7 @@
+import { CustomDecorator } from '@nestjs/common';
+import { MqttMessageTransformer, MqttSubscribeOptions } from './mqtt.interface';
+export declare function Subscribe(topic: string | string[] | MqttSubscribeOptions): CustomDecorator;
+export declare function Topic(): (target: object, propertyKey: string | symbol, paramIndex: number) => void;
+export declare function Packet(): (target: object, propertyKey: string | symbol, paramIndex: number) => void;
+export declare function Payload(transform?: 'json' | 'text' | MqttMessageTransformer): (target: object, propertyKey: string | symbol, paramIndex: number) => void;
+export declare function Params(): (target: object, propertyKey: string | symbol, paramIndex: number) => void;

dist/mqtt.explorer.d.ts

@@ -0,0 +1,21 @@
+import { Logger, OnModuleInit } from '@nestjs/common';
+import { DiscoveryService, MetadataScanner } from '@nestjs/core';
+import { Client } from 'mqtt';
+import { MqttModuleOptions, MqttSubscribeOptions, MqttSubscriber, MqttSubscriberParameter } from './mqtt.interface';
+export declare class MqttExplorer implements OnModuleInit {
+    private readonly discoveryService;
+    private readonly metadataScanner;
+    private readonly logger;
+    private readonly client;
+    private readonly options;
+    subscribers: MqttSubscriber[];
+    private readonly reflector;
+    constructor(discoveryService: DiscoveryService, metadataScanner: MetadataScanner, logger: Logger, client: Client, options: MqttModuleOptions);
+    onModuleInit(): void;
+    preprocess(options: MqttSubscribeOptions): string | string[];
+    subscribe(options: MqttSubscribeOptions, parameters: MqttSubscriberParameter[], handle: any, provider: any): void;
+    explore(): void;
+    private getSubscriber;
+    private static topicToRegexp;
+    private static matchGroups;
+}