import {RestApplication} from '@loopback/rest';
import {MqttComponent} from 'lb4-extension-mqtt';
 
const app = new RestApplication();
// Keep in mind that some extra configuration is required
// as shown in the following steps
app.component(MqttComponent);

const config: MqttServerConfig = {
  protocol: process.env.MQTT_PROTOCOL || 'amqp://',
  vhost: process.env.MQTT_VHOST || 'someVhost',
  host: process.env.MQTT_HOST || 'localhost',
  port: process.env.MQTT_PORT === undefined ? 8883 : +process.env.MQTT_PORT,
  user: process.env.MQTT_USER || 'user',
  pass: process.env.MQTT_PASS || 'pass',
};
 
this.bind(MqttBinding.CONFIG).to(config);

import {MqttBinding} from 'lb4-extension-mqtt/dist10';
 
class CheckMqttComponent {
  // This will inject the MqttComponent's provider
  constructor(@inject(MqttBinding.MQTT_PROVIDER) public provider: Message[]) {}
 
  getMessages(): Message[] {
    // This will return a list of all received messages
    // since the last time you called this function
    return this.provider;
  }
}
 
class SomeOtherClass {
  constructor(
    @inject(CoreBindings.APPLICATION_INSTANCE) private app: Application,
  ) {
    this.checkForNewMqttMessages();
  }
 
  private checkForNewMqttMessages() {
    setInterval(async () => {
      const checkMqttComponent: CheckMqttComponent = new CheckMqttComponent(
        await this.app.get(MqttBinding.MQTT_PROVIDER),
      );
 
      const messages: Message[] = checkMqttComponent.getMessages();
      for (let message of messages) {
        // Do something amazing with it!
      }
    }, 15000);
  }
}