Google Homeを使って、NASに設置したmp3を再生するシステム(06)～slackとhubotの設定

#!/bin/sh
cd /home/pi/hubot/pibot

sudo cp /mnt/nas_music/raspberrypi/hubotscripts/*.coffee /home/pi/hubot/pibot/scripts
sudo -u pi bin/hubot --adapter slack

sudo chmod +x /home/pi/hubot/pibot/bin/run_hubot.sh

tts@あいうえお@

music@あいうえお@

music@あいうえお@

node go.js music@あいうえお@

console.log(process.argv);

const split_str = "@";

const input = process.argv[2];

const { exec } = require('child_process');

const googlehome = require('./google-home-notifier');
const language = 'ja'; // ここに日本語を表す ja を設定

googlehome.ip(undefined, language);
googlehome.device('Google Nest', language);

// 自分のIPアドレスを取得するためのlinuxコマンドを呼び出す。
var ip = "0.0.0.0";
exec("ip -4 a show wlan0 | grep -oP '(?<=inet\\s)\\d+(\\.\\d+){3}'", (err, stdout, stderr) => {
    ip=stdout.trim();
    console.log(ip);
});

// 指定時間、非同期で待機する関数
async function sleep(waitSec, callbackFunc) {
    return new Promise((resolve, reject) => {
    
        var spanedSec = 0;
        var waitFunc = function () {
    
            spanedSec+=0.1;
    
            if (spanedSec >= waitSec) {
                if (callbackFunc) callbackFunc();
                resolve();
               
            }
            clearTimeout(id);
            id = setTimeout(waitFunc, 100);
        };
        var id = setTimeout(waitFunc, 100);
    });
}

// google-home-notifierのnotify関数を非同期実行
async function notify(str, callback){
    return new Promise((resolve, reject)=>{
        googlehome.notify(str, callback, resolve);
    });
}

// google-home-notifierのplay関数を非同期実行
async function play(str, callback){
    return new Promise((resolve, reject)=>{
        googlehome.play(str, callback, resolve);
    });
}

// メイン関数 非同期実行
async function main_func(){

    // param-1@param-2@param-3の取得
    const splitted_input = input.split(split_str);

    // param-1@param-2@param-3を所定の区切り文字で分割
    const mode = splitted_input[0];
    const message = splitted_input[1];
    const options = splitted_input[2];

    if(mode == "music"){ // 音楽再生モードのとき
        console.log("play music mode");

        // messageに関連するmp3ファイルを読み出す。
        var playFileObj = require('./select_music').selectMusicFile(message);
        console.log(playFileObj);

        var duration = 0;
        var media_data;

        // mp3再生前に読み上げる所定の文字列
        await notify(playFileObj.comment, function(res, d) { console.log(res); duration = d.media.duration; });
        await sleep(duration, null);

        // 変数ipには自分のIPアドレスが入る。
        // 厳密には、IPアドレス取得完了を待ってから変数を使用しなければならない。
        // 前段のnotify関数のawaitで並列でipアドレス取得が十分に間に合うので一旦この方式で進める。
	const dataServerAddress = ip;
	const dataServerPort = 8091;

        // 再生するmp3ファイルのURLを設定する。
        var reqStr = 'http://' + dataServerAddress  + ':' + dataServerPort + '/' + playFileObj.filename;
        console.log(reqStr);

        // 指定したmp3ファイルをgoogle homeから再生する命令。
        await play(reqStr, function(res, d) { console.log(res);media_data = d; duration = d.media.duration; console.log(d);});
        await sleep(duration, null);
        console.log('process.exit(0);');
        process.exit(0);
    }else if(mode == "tts"){ // テキスト読み上げモードのとき
        console.log("text to speech mode");

	await notify(message , function(res, d) { console.log(res); duration = d.media.duration; });
        await sleep(duration, null);
        console.log('process.exit(0);');
        process.exit(0);
    }
}

main_func();
setTimeout(() => {
    console.log('process.exit(1);');
    process.exit(1);
}, 30000);

const musicData = [
	{
		filename: 'example01.mp3',
		comment:'再生前にしゃべります01',
        	keys:[
			'example01',
			'keyword01-01',
			'keyword01-02',
			'keyword01-03',
			'keyword01-04',
			'keyword01-05',
		]
	},
	{
		filename: 'example02.mp3',
		comment:'再生前にしゃべります02',
        	keys:[
			'example02',
			'keyword02-01',
			'keyword02-02',
			'keyword02-03',
			'keyword02-04',
			'keyword02-05',
		]
	},
	{
		filename: 'example03.mp3',
		comment:'再生前にしゃべります03',
        	keys:[
			'example03',
			'keyword03-01',
			'keyword03-02',
			'keyword03-03',
		]
	},
	{
		filename: 'example04.mp3',
		comment:'再生前にしゃべります04',
        	keys:[
			'example04',
			'keyword04-01',
			'keyword04-02',
			'keyword04-03',
			'keyword04-04',
		]
	},
	{
		filename: 'example05.mp3',
		comment:'再生前にしゃべります05',
        	keys:[
			'example05',
			'keyword05-01',
			'keyword05-02',
			'keyword05-03',
			'keyword05-04',
			'keyword05-05',
		]
	},
];

function selectMusicFile(str){
    for(i=0; i < musicData.length; i++){
        if(musicData[i].filename == str || musicData[i].comment == str) return musicData[i];
        var keys = musicData[i].keys;
        for(j=0;j<keys.length; j++){
            if(str == keys[j]){
                return musicData[i];
            }
        }
    }
    return {
        filename:null,
        comment:null,
    };
}

module.exports = (robot) ->
  robot.hear /(.+?)@(.+?)@(.*)(@|$)/i, (res) ->
    res.send "! ! command received ! !"
    res.send res.match[0]
    @exec = require('child_process').exec
    command = "node /home/pi/google-home-notifier/go.js " + res.match[0].replace(' ', '\\ ')
    res.send command
    @exec command, (error, stdout, stderr) ->
  #   msg.send error
      res.send stdout
  #   res.send stderr

robot.hear /(.+?)@(.+?)@(.*)(@|$)/i, (res) ->

command = "node /home/pi/google-home-notifier/go.js " + res.match[0].replace(' ', '\\ ')

res.send command

@exec command, (error, stdout, stderr) ->
  #   msg.send error
      res.send stdout
  #   res.send stderr

sudo reboot

sudo cp /mnt/nas_music/raspberrypi/hubotscripts/*.coffee

tts@これをしゃべります@

music@あいうえお@