Nomchy/discord.js
1
0
Fork 0
mirror of https://github.com/discordjs/discord.js.git synced 2026-03-10 00:23:30 +01:00
Code Issues Packages Projects Releases Wiki Activity

Make FFMPEG error reject encoding

Browse Source
This commit is contained in:
abalabahaha
2016-03-06 13:04:23 -08:00
parent dd6c158250
commit 4e58de8cd6
2 changed files with 28 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
src/Voice/AudioEncoder.js
View File

@@ -63,17 +63,20 @@ export default class AudioEncoder {
this.volume = new VolumeTransformer(options.volume || 1);
var enc = cpoc.spawn(this.getCommand(), [
'-loglevel', '0',
'-hide_banner',
'-i', '-',
'-f', 's16le',
'-ar', '48000',
'-ss', (options.seek || 0),
'-ac', 2,
'pipe:1'
], {stdio: ['pipe', 'pipe', 'ignore']});
]);
stream.pipe(enc.stdin);
enc.stdout.pipe(this.volume);
enc.stderr.on("data", (data) => {
reject(new Error("FFMPEG: " + new Buffer(data).toString().trim()));
});
this.volume.once("readable", () => {
resolve({
@@ -99,16 +102,19 @@ export default class AudioEncoder {
this.volume = new VolumeTransformer(options.volume || 1);
var enc = cpoc.spawn(this.getCommand(), [
'-loglevel', '0',
'-hide_banner',
'-i', file,
'-f', 's16le',
'-ar', '48000',
'-ss', (options.seek || 0),
'-ac', 2,
'pipe:1'
], {stdio: ['pipe', 'pipe', 'ignore']});
]);
enc.stdout.pipe(this.volume);
enc.stderr.on("data", (data) => {
reject(new Error("FFMPEG: " + new Buffer(data).toString().trim()));
});
this.volume.once("readable", () => {
resolve({
@@ -134,15 +140,18 @@ export default class AudioEncoder {
// add options discord.js needs
var options = ffmpegOptions.concat([
'-loglevel', '0',
'-hide_banner',
'-f', 's16le',
'-ar', '48000',
'-ac', 2,
'pipe:1'
]);
var enc = cpoc.spawn(this.getCommand(), options, {stdio: ['pipe', 'pipe', 'ignore']});
var enc = cpoc.spawn(this.getCommand(), options);
enc.stdout.pipe(this.volume);
enc.stderr.on("data", (data) => {
reject(new Error("FFMPEG: " + new Buffer(data).toString().trim()));
});
this.volume.once("readable", () => {
resolve({