actions.js

"use strict";

class actionsMQTT {
   constructor (app) {
      this.logmodule = app.logmodule;
      this.broker = app.broker;
      this.publishMQTT = null;
      this.sayString = null;
//      this.Homey = require('homey');
      this.Homey = app.homey;
      this.OnInit();
   }

   OnInit() {
      this.registerActions();
   }

   registerActions() {
      const ref = this;
      this.logmodule.writelog("registerActions called");

      // Put all the action trigger here for registering them and executing the action

      //this.publishMQTT = new this.Homey.FlowCardAction('publishMQTT');
      this.publishMQTT = this.Homey.flow.getActionCard('publishMQTT');
      //this.publishMQTT_Adv = new this.Homey.FlowCardAction('publishMQTT_Adv');
      this.publishMQTT_Adv = this.Homey.flow.getActionCard('publishMQTT_Adv');
      //this.sayString = new this.Homey.FlowCardAction('sayString');
      this.sayString = this.Homey.flow.getActionCard('sayString');

      //this.publishMQTT.register();
      //this.publishMQTT_Adv.register();
      //this.sayString.register();

      // Put all the action trigger here for registering them and executing the action
      // Action for sending a message to the broker on the specified topic
      this.publishMQTT.registerRunListener((args, state ) => {
         ref.logmodule.writelog('debug', "Listener publishMQTT called");
         try {
            ref.broker.sendMessageToTopic(args);
            return Promise.resolve( true );
          } catch(err) {
            ref.logmodule.writelog('error', "Error in Listener publishMQTT: " +err);
            return Promise.reject(err);
          }
      })

      this.publishMQTT_Adv.registerRunListener((args, state ) => {
         ref.logmodule.writelog('debug', "Listener publishMQTT_Adv called");
         try {
            ref.broker.sendMessageToTopic(args);
            return Promise.resolve( true );
          } catch(err) {
            ref.logmodule.writelog('error', "Error in Listener publishMQTT_Adv: " +err);
            return Promise.reject(err);
          }
      })

      // Action for speaking out the string recieved from MQTT topic
      this.sayString.registerRunListener((args, state ) => {
         ref.logmodule.writelog('debug', "Listener sayString called");
         try {
            ref.homeySayString(args);
          } catch(err) {
            ref.logmodule.writelog('error', "Error in Listener sayString: " +err);
          }
      })
   }

   homeySayString(args) {
      try {
         this.Homey.speechOutput.say(args.voiceString)
         this.logmodule.writelog("homeySayString: " +args.voiceString);
      } catch(err) {
         this.logmodule.writelog("homeySayString: " +err);
      }
   }
}

module.exports = actionsMQTT;