google-cast-public-address.js

'use strict';
var Client = require('castv2-client').Client;
var DefaultMediaReceiver = require('castv2-client').DefaultMediaReceiver;
var mdns = require('mdns');
var googletts = require('google-tts-api');
var browser = mdns.createBrowser(mdns.tcp('googlecast'));
var deviceAddress;
var device = function(name) {
  device = name;
  return this;
};

var onDeviceUp = function(host, url, callback) {
  var client = new Client();
  client.connect(host, function() {
    client.launch(DefaultMediaReceiver, function(err, player) {
      var media = {
        contentId: url,
        contentType: 'audio/mp3',
        streamType: 'BUFFERED' // or LIVE
      };
      player.load(media, { autoplay: true }, function(err, status) {
        client.close();
        callback('Device notified');
      });
    });
  });
  client.on('error', function(err) {
    console.log('Error: %s', err.message);
    client.close();
    callback('error');
  });
};

var getSpeechUrl = function(text, host, callback) {
  googletts(text, 'en', 1).then(function (url) {
    onDeviceUp(host, url, function(res){
      callback(res);
    });
  }).catch(function (err) {
    console.error(err.stack);
  });
};

var getResourceUrl = function(path, host, callback) {
  onDeviceUp(host, path, function(res){
    callback(res);
  });
};

var notify = function(message, callback) {
  if (!deviceAddress){
    browser.start();
    browser.on('serviceUp', function(service) {
      console.log('Device "%s" at %s:%d', service.name, service.addresses[0], service.port);
      if (service.name.includes(device.replace(' ', '-'))){
        deviceAddress = service.addresses[0];
        getSpeechUrl(message, deviceAddress, function(res) {
          callback(res);
        });
      }
      browser.stop();
    });
  } else {
    getSpeechUrl(message, deviceAddress, function(res) {
      callback(res);
    });
  }
};

var play = function(url, callback) {
  console.log('play media url:', url);
  if (!deviceAddress){
    browser.start();
    browser.on('serviceUp', function(service) {
      console.log('Device "%s" at %s:%d', service.name, service.addresses[0], service.port);
      if (service.name.includes(device.replace(' ', '-'))){
        deviceAddress = service.addresses[0];
        getResourceUrl(url, deviceAddress, function(res) {
          callback(res);
        });
      }
      browser.stop();
    });
  } else {
    getResourceUrl(url, deviceAddress, function(res) {
      callback(res);
    });
  }
};

exports.device = device;
exports.notify = notify;
exports.play = play;