DebaucheryLibrarian
/
traxxx
2
1
Fork 1
Code Issues 37 Pull Requests 1 Releases Wiki Activity

Using native stream promises for media stream retrieval.

This commit is contained in:
DebaucheryLibrarian 2023-06-11 01:17:37 +02:00
parent 433498eaed
commit bcc183d5b9
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/media.js
View File

@ -24,7 +24,7 @@ const bulkInsert = require('./utils/bulk-insert');
const chunk = require('./utils/chunk'); const chunk = require('./utils/chunk');
const { get } = require('./utils/qu'); const { get } = require('./utils/qu');
const pipeline = util.promisify(stream.pipeline); // const pipeline = util.promisify(stream.pipeline);
const streamQueue = taskQueue(); const streamQueue = taskQueue();
const endpoint = new AWS.Endpoint('s3.eu-central-1.wasabisys.com'); const endpoint = new AWS.Endpoint('s3.eu-central-1.wasabisys.com');
@ -629,7 +629,8 @@ streamQueue.define('fetchStreamSource', async ({ source, tempFileTarget, hashStr
.on('error', (error) => logger.error(`Failed to fetch stream from ${source.stream}: ${error.message}`)) .on('error', (error) => logger.error(`Failed to fetch stream from ${source.stream}: ${error.message}`))
.pipe(); .pipe();
await pipeline(video, hashStream, tempFileTarget); // await pipeline(video, hashStream, tempFileTarget);
await stream.promises.pipeline(video, hashStream, tempFileTarget);
logger.verbose(`Finished fetching stream from ${source.stream}`); logger.verbose(`Finished fetching stream from ${source.stream}`);