arthur/xiao
1
0
Fork 0
mirror of https://github.com/arthur-pbty/xiao.git synced 2026-06-25 22:32:50 +02:00
Code Issues Packages Projects Releases Wiki Activity

Streams?

Browse Source
This commit is contained in:
Daniel Odendahl Jr
2017-10-16 13:59:18 +00:00
parent 052884bbd2
commit 036812f0fb
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
commands/text-edit/dec-talk.js
+9 -2
View File
@@ -1,5 +1,9 @@
const { Command } = require('discord.js-commando'); const { Command } = require('discord.js-commando');
const snekfetch = require('snekfetch'); const snekfetch = require('snekfetch');
const { Readable } = require('stream');
// const path = require('path');
// const { promisifyAll } = require('tsubaki');
// const fs = promisifyAll(require('fs'));
module.exports = class DECTalkCommand extends Command { module.exports = class DECTalkCommand extends Command {
constructor(client) { constructor(client) {
@@ -38,10 +42,13 @@ module.exports = class DECTalkCommand extends Command {
if (this.client.voiceConnections.has(channel.guild.id)) return msg.say('I am already playing a sound.'); if (this.client.voiceConnections.has(channel.guild.id)) return msg.say('I am already playing a sound.');
try { try {
const connection = await channel.join(); const connection = await channel.join();
const body = snekfetch const { body } = await snekfetch
.get('http://tts.cyzon.us/tts') .get('http://tts.cyzon.us/tts')
.query({ text }); .query({ text });
const dispatcher = connection.playStream(body); const stream = new Readable();
stream.read = function () {};
stream.push(body);
const dispatcher = connection.playStream(stream);
dispatcher.once('end', () => channel.leave()); dispatcher.once('end', () => channel.leave());
dispatcher.once('error', () => channel.leave()); dispatcher.once('error', () => channel.leave());
return null; return null;