app.js

/* eslint-disable linebreak-style */
/* eslint-disable camelcase */
/* eslint-disable indent */
/* eslint-disable no-tabs */
/* eslint-disable max-len */
/* eslint-disable object-curly-newline */
/* eslint-disable object-property-newline */
/* eslint-disable quotes */
/* eslint-disable quote-props */
/* eslint-disable consistent-return */

'use strict';


const Homey = require('homey');
const GoogleHomeTTS = require('./lib/GoogleHomeAudioTTS');

class googleTTS extends Homey.App {

    onInit() {
        this.log(`${Homey.manifest.id} running...`);
        this.foundDevices = [];

        this.discoverDevices();
        this.goWithTheFlow();
    }

    findDeviceIP(device) {
        for (const device_data in this.foundDevices)
            if (this.foundDevices[device_data].name == device.name || (this.foundDevices[device_data].id != undefined && this.foundDevices[device_data].id == device.id))
                return { ip: this.foundDevices[device_data].host, port:this.foundDevices[device_data].port };

        return "0.0.0.0";
    }

    async goWithTheFlow() {
        this.homey.flow.getActionCard('tts')
        .registerRunListener((args, state) => {
            return new Promise((resolve, reject) => {
                const device = new GoogleHomeTTS();
                device.setLanguage(args.language);
                if (args.speed) device.setTtsSpeed(args.speed);
                if (args.muted) device.setSendToMuted(args.muted);
                device.setVolume(args.volume)
                device.setTts(args.text);

                if (args.device.name === 'Broadcast') {
                    for (let device_data in this.foundDevices) {
                        if (this.foundDevices[device_data].name !== 'Broadcast') {
                            device.setPort(this.foundDevices[device_data].port);
                            device.setIp(this.foundDevices[device_data].host);
                            device.audio();
                        }
                    }
                } else {
                    let { ip, port } = this.findDeviceIP(args.device);

                    if (ip == undefined || ip == "0.0.0.0") return reject();

                    device.setIp(ip);
                    device.setPort(port);
                    device.audio();
                }
                return resolve();
            });
        })
        .registerArgumentAutocompleteListener('device', (query, args) => {
            const devices = []
            for (const device_data in this.foundDevices)
                if (this.foundDevices[device_data].name.toLowerCase().indexOf(query.toLowerCase()) > -1 || this.foundDevices[device_data].description.toLowerCase().indexOf(query.toLowerCase()) > -1)
                    devices.push(this.foundDevices[device_data]);

            return Promise.resolve(devices);
        })
    }

    async discoverDevices() {
        this.foundDevices['Broadcast'] = {name: 'Broadcast', description: 'Broadcast to all devices'};

        const discoveryStrategy = this.homey.discovery.getStrategy('googlecast');

        discoveryStrategy.on('result', discoveryResult => {
            this.log('discoverDevices : ', discoveryResult.txt.fn, 'on', discoveryResult.address, discoveryResult.port);
            const db = {};
            db.id = discoveryResult.id;
            db.host = discoveryResult.address;
            db.port = discoveryResult.port;
            db.name = discoveryResult.txt.fn;
            db.description = discoveryResult.txt.md;
            this.foundDevices[discoveryResult.id] = db;
        });

        discoveryStrategy.getDiscoveryResults();
    }
}

module.exports = googleTTS;