Lib output for arbitrary ffmpeg playback

lib/Voice/AudioEncoder.js

@@ -113,6 +113,33 @@ var AudioEncoder = (function () {
 		});
 	};
 
+	AudioEncoder.prototype.encodeArbitraryFFmpeg = function encodeArbitraryFFmpeg(ffmpegOptions) {
+		var self = this;
+		return new Promise(function (resolve, reject) {
+			// add options discord.js needs
+			var options = ffmpegOptions.concat(['-loglevel', '0', '-f', 's16le', '-ar', '48000', '-ac', 2, 'pipe:1']);
+			var enc = _child_process2["default"].spawn(self.getCommand(), options, { stdio: ['pipe', 'pipe', 'ignore'] });
+
+			enc.stdout.once("readable", function () {
+				resolve({
+					proc: enc,
+					stream: enc.stdout,
+					channels: 2
+				});
+			});
+
+			enc.stdout.on("end", function () {
+				console.log("end");
+				reject("end");
+			});
+
+			enc.stdout.on("close", function () {
+				console.log("close");
+				reject("close");
+			});
+		});
+	};
+
 	return AudioEncoder;
 })();
 

lib/Voice/VoiceConnection.js

@@ -285,14 +285,43 @@ var VoiceConnection = (function (_EventEmitter) {
 		});
 	};
 
-	VoiceConnection.prototype.init = function init() {
+	VoiceConnection.prototype.playArbitraryFFmpeg = function playArbitraryFFmpeg(ffmpegOptions) {
 		var _this3 = this;
 
+		var callback = arguments.length <= 1 || arguments[1] === undefined ? function (err, str) {} : arguments[1];
+
+		var self = this;
+		self.stopPlaying();
+		if (typeof options === "function") {
+			// options is the callback
+			callback = options;
+			options = {};
+		}
+		return new Promise(function (resolve, reject) {
+			_this3.encoder.encodeArbitraryFFmpeg(ffmpegOptions)["catch"](error).then(function (data) {
+				self.streamProc = data.proc;
+				self.instream = data.instream;
+				var intent = self.playStream(data.stream);
+				resolve(intent);
+				callback(null, intent);
+			});
+			function error() {
+				var e = arguments.length <= 0 || arguments[0] === undefined ? true : arguments[0];
+
+				reject(e);
+				callback(e);
+			}
+		});
+	};
+
+	VoiceConnection.prototype.init = function init() {
+		var _this4 = this;
+
 		var self = this;
 		console.log("\n\nendpoint:", this.endpoint, "\n\n");
 		_dns2["default"].lookup(this.endpoint, function (err, address, family) {
-			var vWS = self.vWS = new _ws2["default"]("wss://" + _this3.endpoint, null, { rejectUnauthorized: false });
-			_this3.endpoint = address;
+			var vWS = self.vWS = new _ws2["default"]("wss://" + _this4.endpoint, null, { rejectUnauthorized: false });
+			_this4.endpoint = address;
 			var udpClient = self.udp = _dgram2["default"].createSocket("udp4");
 
 			var firstPacket = true;