GladysProject/Gladys

const logger = require('../../utils/logger');
const { ServiceNotConfiguredError } = require('../../utils/coreErrors');
const MessageHandler = require('./lib');

module.exports = function NextcloudTalkService(gladys, serviceId) {
  const axios = require('axios');

  const messageHandler = new MessageHandler(gladys, serviceId, axios);
  /**
   * @public
   * @description This function starts the Nextcloud Talk Service.
   * @example
   * gladys.services.nextcloudTalk.start();
   */
  async function start() {
    logger.info('Starting Nextcloud Talk service');
    const tokens = await gladys.variable.getVariables('NEXTCLOUD_TALK_TOKEN', serviceId);

    if (!tokens || tokens.length === 0) {
      throw new ServiceNotConfiguredError('No Nextcloud token found. Not starting Nextcloud Talk service');
    }
    await messageHandler.connect(tokens);
  }

  /**
   * @public
   * @description This function stops the Nextcloud Talk Service.
   * @example
   * gladys.services.nextcloudTalk.stop();
   */
  async function stop() {
    logger.info('stopping Nextcloud Talk service');
    await messageHandler.disconnect();
  }

  /**
   * @public
   * @description Test if Nextcloud Talk is running.
   * @returns {Promise<boolean>} Returns true if Nextcloud Talk is used.
   * @example
   *  const used = await gladys.services.nextcloudTalk.isUsed();
   */
  async function isUsed() {
    return Object.keys(messageHandler.bots).length > 0;
  }

  return Object.freeze({
    start,
    stop,
    isUsed,
    message: messageHandler,
  });
};