GladysProject/Gladys

View on GitHub
server/services/mqtt/lib/init.js

Summary

Maintainability
A
30 mins
Test Coverage
const { DEFAULT } = require('./constants');

/**
 * @description Prepares service and starts connection with broker.
 * @example
 * init();
 */
async function init() {
  DEFAULT.TOPICS.forEach((topic) => {
    this.subscribe(topic, this.handleGladysMessage.bind(this));
  });

  const configuration = await this.getConfiguration();

  // Check for container configuration
  await this.updateContainer(configuration);

  await this.connect(configuration);
}

module.exports = {
  init,
};