From 390eb80abfec037d6e1f1be4e9410aeac723da48 Mon Sep 17 00:00:00 2001
From: Daniel Odendahl Jr <danielbodendahl@gmail.com>
Date: Mon, 16 Oct 2017 14:11:44 +0000
Subject: [PATCH] I don't understand

---
 commands/text-edit/dec-talk.js | 28 +++++++++++++++++-----------
 1 file changed, 17 insertions(+), 11 deletions(-)

diff --git a/commands/text-edit/dec-talk.js b/commands/text-edit/dec-talk.js
index 60edad70..0c4b7e41 100644
--- a/commands/text-edit/dec-talk.js
+++ b/commands/text-edit/dec-talk.js
@@ -1,9 +1,8 @@
 const { Command } = require('discord.js-commando');
 const snekfetch = require('snekfetch');
-const { Readable } = require('stream');
-// const path = require('path');
-// const { promisifyAll } = require('tsubaki');
-// const fs = promisifyAll(require('fs'));
+const path = require('path');
+const { promisifyAll } = require('tsubaki');
+const fs = promisifyAll(require('fs'));
 
 module.exports = class DECTalkCommand extends Command {
 	constructor(client) {
@@ -40,21 +39,28 @@ module.exports = class DECTalkCommand extends Command {
 		}
 		if (!channel.joinable) return msg.say('Your voice channel is not joinable.');
 		if (this.client.voiceConnections.has(channel.guild.id)) return msg.say('I am already playing a sound.');
+		const file = path.join(__dirname, '..', '..', 'assets', `dec-talk ${channel.guild.id}.wav`);
 		try {
 			const connection = await channel.join();
 			const { body } = await snekfetch
 				.get('http://tts.cyzon.us/tts')
 				.query({ text });
-			const stream = new Readable();
-			stream.read = function () {};
-			stream.push(body);
-			const dispatcher = connection.playStream(stream);
-			dispatcher.once('end', () => channel.leave());
-			dispatcher.once('error', () => channel.leave());
+			await fs.writeFileAsync(file, body, { encoding: 'binary' });
+			const dispatcher = connection.playFile(file);
+			dispatcher.once('end', () => this.finish(file, channel));
+			dispatcher.once('error', () => this.finish(file, channel));
 			return null;
 		} catch (err) {
-			channel.leave();
+			await this.finish(file, channel);
 			return msg.say(`Oh no, an error occurred: \`${err.message}\`. Try again later!`);
 		}
 	}
+
+	async finish(file, channel) {
+		try {
+			if (fs.existsSync(file)) await fs.unlinkAsync(file);
+		} finally {
+			channel.leave();
+		}
+	}
 };