diff --git a/modules/file_handler.js b/modules/file_handler.js index 4422bd9..239d448 100644 --- a/modules/file_handler.js +++ b/modules/file_handler.js @@ -216,6 +216,20 @@ const readJson = async (path) => { } }; +/** + * Converts a stream to a buffer + * @param {ReadableStream} stream + * @returns {Promise} + */ +const getBufferFromStream = async (stream) => new Promise((res, rej) => { + const buffers = []; + stream.on('data', (chunk) => buffers.push(chunk)); + stream.on('end', () => { + res(Buffer.concat(buffers)); + }); + stream.on('error', (error) => rej(error)); +}); + module.exports = { cleanPath, copyFiles, @@ -230,4 +244,5 @@ module.exports = { renameFile, writeFile, writeJson, + getBufferFromStream, };