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

Compare commits

base: DebaucheryLibrarian:647e9bb186db3f0b07dce6ed89bf5316457336e8
Branches Tags
DebaucheryLibrarian:master
DebaucheryLibrarian:old
DebaucheryLibrarian:experimental
..
compare: DebaucheryLibrarian:c9b774c4980465b563674f9abd001382043dc239
Branches Tags
DebaucheryLibrarian:master
DebaucheryLibrarian:old
DebaucheryLibrarian:experimental

2 Commits
647e9bb186 ... c9b774c498

Author SHA1 Message Date
DebaucheryLibrarian c9b774c498 1.167.9 2021-02-05 03:13:17 +01:00
DebaucheryLibrarian 3e813ca251 Prevent writing to media hasher when hasher stream has closed. 2021-02-05 03:13:10 +01:00
3 changed files with 8 additions and 4 deletions
Show Stats Expand all files Collapse all files

2
package-lock.json generated
View File

@ -1,6 +1,6 @@
{ {
"name": "traxxx", "name": "traxxx",
"version": "1.167.8", "version": "1.167.9",
"lockfileVersion": 1, "lockfileVersion": 1,
"requires": true, "requires": true,
"dependencies": { "dependencies": {

2
package.json
View File

@ -1,6 +1,6 @@
{ {
"name": "traxxx", "name": "traxxx",
"version": "1.167.8", "version": "1.167.9",
"description": "All the latest porn releases in one place", "description": "All the latest porn releases in one place",
"main": "src/app.js", "main": "src/app.js",
"scripts": { "scripts": {

6
src/media.js
View File

@ -504,10 +504,10 @@ async function fetchSource(source, baseMedia) {
const maxAttempts = source.attempts || 3; const maxAttempts = source.attempts || 3;
logger.silly(`Fetching media from ${source.src}`); logger.silly(`Fetching media from ${source.src}`);
// attempts
async function attempt(attempts = 1) { async function attempt(attempts = 1) {
const hasher = new blake2.Hash('blake2b', { digestLength: 24 }); const hasher = new blake2.Hash('blake2b', { digestLength: 24 });
let hasherReady = true;
hasher.setEncoding('hex'); hasher.setEncoding('hex');
try { try {
@ -519,7 +519,10 @@ async function fetchSource(source, baseMedia) {
hashStream.on('data', (chunk) => { hashStream.on('data', (chunk) => {
size += chunk.length; size += chunk.length;
if (hasherReady) {
hasher.write(chunk); hasher.write(chunk);
}
}); });
const { mimetype } = source.stream const { mimetype } = source.stream
@ -551,6 +554,7 @@ async function fetchSource(source, baseMedia) {
}, },
}; };
} catch (error) { } catch (error) {
hasherReady = false;
hasher.end(); hasher.end();
if (error.code !== 'VERIFY_TYPE') { if (error.code !== 'VERIFY_TYPE') {