如何使文本到语音队列node.js

Question

对于像你们中的某些人这样的专业人士来说，这可能是一件非常简单的事情，我希望您能帮助我，感谢您的时间，谢谢。

我有这个TTS Discord Bot，它可以工作！但是我不知道如何排队额外的传入TTS请求。

当当前TTS播放并提交新请求时，当前TTS将停止并开始执行下一个请求，而无需让当前的TTS完成。

我要做的是排队所有请求，因此每个启动每次播放后都会播放。

有人告诉我使用这个软件包，但我无法弄清楚。

我是一个知识非常有限的菜鸟，所以有人可以添加队列所需的额外行吗？还是提供好指南？

很抱歉太挑剔了，我知道我不应该要求太多，但是我已经在处理这个问题已经好几个星期了，我很拼命。

这是我的代码：

const { getAudioUrl } = require('google-tts-api');

module.exports = {
  name: 'say',
  aliases: ['s'],
  cooldown: 3,
  description: "tts",

  execute: async (message, args, cmd, client, Discord) => {
    console.log('Say command executed');

    if (!args[0]) 
      return message.channel.send('you gotta include a message!');
    
    const string = args.join(' ');

    if (string.length > 200) 
      return message.channel.send('the message cant be more than 200 letters!');
    
    const voiceChannel = message.member.voice.channel;

    if (!voiceChannel) 
      return message.reply('You have to be in a voice channel to send a message!');

    const audioURL = getAudioUrl(string, {
      lang: 'en',
      slow: false,
      host: 'https://translate.google.com',
      timeout: 10000,
    });

    try {
      message.channel.startTyping();

      setTimeout(function () {
        message.channel.send('Speaking your msg...');
        message.channel.stopTyping();
        console.log('Now starting to talk');
      }, 1000);

      voiceChannel.join().then(connection => {
        const dispatcher = connection.play(audioURL);
        dispatcher.on('finish', () => {
          console.log('Done talking');
        });
      });
    }
    catch (e) {
      message.channel.send('Bot error, please try again or try later');
      console.error(e);
    }

    setTimeout(function () {
      voiceChannel.leave();
    }, 240000);
  }
}

Answer 1

使用队列软件包您“按” execute逻辑包裹在功能中。然后将由队列执行该功能。这里棘手的部分是您需要结束调度程序的完成事件处理程序内的执行。您可以引入一个新的承诺，然后将从活动处理程序内部解决。

Here's a rough sketch of the solution:

const { getAudioUrl } = require('google-tts-api');
const queue = require('queue');

// Create the queue where we will push our jobs
const q = queue({ concurrency: 1, autostart: true });

module.exports = {
  name: 'say',
  aliases: ['s'],
  cooldown: 3,
  description: 'tts',

  execute: (message, args, cmd, client, Discord) => {
    // Enqueue task
    q.push(async () => {
      console.log('Say command executed');

      if (!args[0]) {
        return message.channel.send('you gotta include a message!');
      }

      const string = args.join(' ');

      if (string.length > 200) {
        return message.channel.send(
          'the message cant be more than 200 letters!'
        );
      }

      const voiceChannel = message.member.voice.channel;

      if (!voiceChannel) {
        return message.reply(
          'You have to be in a voice channel to send a message!'
        );
      }

      const audioURL = getAudioUrl(string, {
        lang: 'en',
        slow: false,
        host: 'https://translate.google.com',
        timeout: 10000,
      });

      try {
        message.channel.startTyping();

        setTimeout(function () {
          message.channel.send('Speaking your msg...');
          message.channel.stopTyping();
          console.log('Now starting to talk');
        }, 1000);

        const connection = await voiceChannel.join();
        const dispatcher = connection.play(audioURL);
        // Here we need to handle the promise resolution from the nested event handler
        return Promise.new((resolve, reject) => {
          dispatcher.on('finish', () => {
            console.log('Done talking');
            // voiceChannel.leave();
            resolve();
          });
          dispatcher.on('error', (err) => {
            console.log('Some error in dispatcher happenned!', err);
            reject(err);
          });
        });
      } catch (e) {
        message.channel.send('Bot error, please try again or try later');
        console.error(e);
      }

      // This code won't be called
      setTimeout(function () {
        voiceChannel.leave();
      }, 240000);
    });
  },
};

Take this solution with a grain of salt.我不知道您要定位哪种版本的discord.js。另请注意，超时和可能未处理其他错误条件。