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

fix(DataResolver): fix check for readable streams (#7928)

Browse Source
This commit is contained in:
Sam
2022-05-16 06:12:34 -04:00
committed by GitHub
parent 7ce641d33a
commit 28172ca7b5
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/discord.js/src/util/DataResolver.js
View File

@@ -3,7 +3,6 @@
const { Buffer } = require('node:buffer'); const { Buffer } = require('node:buffer');
const fs = require('node:fs/promises'); const fs = require('node:fs/promises');
const path = require('node:path'); const path = require('node:path');
const stream = require('node:stream');
const { fetch } = require('undici'); const { fetch } = require('undici');
const { Error: DiscordError, TypeError } = require('../errors'); const { Error: DiscordError, TypeError } = require('../errors');
const Invite = require('../structures/Invite'); const Invite = require('../structures/Invite');
@@ -107,9 +106,10 @@ class DataResolver extends null {
* @returns {Promise<Buffer>} * @returns {Promise<Buffer>}
*/ */
static async resolveFile(resource) { static async resolveFile(resource) {
if (!resource) return null;
if (Buffer.isBuffer(resource)) return resource; if (Buffer.isBuffer(resource)) return resource;
if (resource instanceof stream.Readable) { if (typeof resource[Symbol.asyncIterator] === 'function') {
const buffers = []; const buffers = [];
for await (const data of resource) buffers.push(data); for await (const data of resource) buffers.push(data);
return Buffer.concat(buffers); return Buffer.concat(buffers);