package-lock.json

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

package.json

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

src/media.js

@@ -105,8 +105,7 @@ function toBaseSource(rawSource) {
 		if (rawSource.referer) baseSource.referer = rawSource.referer;
 		if (rawSource.host) baseSource.host = rawSource.host;
 		if (rawSource.attempts) baseSource.attempts = rawSource.attempts;
-		if (rawSource.interval) baseSource.interval = rawSource.interval;
-		if (rawSource.concurrency) baseSource.concurrency = rawSource.concurrency;
+		if (rawSource.queueMethod) baseSource.queueMethod = rawSource.queueMethod;
 
 		if (rawSource.credit !== undefined) baseSource.credit = rawSource.credit;
 		if (rawSource.comment) baseSource.comment = rawSource.comment;
@@ -436,8 +435,7 @@ async function fetchHttpSource(source, tempFileTarget, hashStream) {
 		stream: true, // sources are fetched in parallel, don't gobble up memory
 		transforms: [hashStream],
 		destination: tempFileTarget,
-		...(source.interval && { interval: source.interval }),
-		...(source.concurrency && { concurrency: source.concurrency }),
+		queueMethod: source.queueMethod || null, // use http module's default
 	});
 
 	if (!res.ok) {

src/scrapers/hookuphotshot.js

@@ -21,7 +21,7 @@ function scrapeAll(scenes) {
 					avatar: [
 						avatarEl.src.replace(/-\d+x\d+/, ''),
 						avatarEl.src,
-					].map(src => ({ src, interval: 1000, concurrency: 1 })),
+					].map(src => ({ src, queueMethod: '1s' })),
 				}),
 			};
 		}).concat({
@@ -37,14 +37,12 @@ function scrapeAll(scenes) {
 
 		release.poster = {
 			src: query.img('.date-img-swap'),
-			interval: 1000,
-			concurrency: 1,
+			queueMethod: '1s',
 		};
 
 		release.photos = [...Array(photoCount)].map((value, index) => ({
 			src: `${photoPath}/${String(index + 1).padStart(2, '0')}.jpg`,
-			interval: 1000,
-			concurrency: 1,
+			queueMethod: '1s',
 		}));
 
 		// dates appear to be manually curated

src/scrapers/whalemember.js

@@ -28,16 +28,14 @@ function scrapeLatest(html, site) {
 			src: /^http/.test(poster) ? poster : `https:${poster}`,
 			referer: site.url,
 			attempts: 5,
-			interval: 5000,
-			concurrency: 1,
+			queueMethod: '5s',
 		};
 
 		release.photos = Array.from(scene.querySelectorAll('.rollover-thumbs img'), el => ({
 			src: (/^http/.test(el.dataset.src) ? el.dataset.src : `https:${el.dataset.src}`),
 			referer: site.url,
 			attempts: 5,
-			interval: 5000,
-			concurrency: 1,
+			queueMethod: '5s',
 		}));
 
 		if (teaserEl) {
@@ -45,8 +43,7 @@ function scrapeLatest(html, site) {
 				src: teaserEl.dataset.src,
 				referer: site.url,
 				attempts: 5,
-				interval: 5000,
-				concurrency: 1,
+				queueMethod: '5s',
 			};
 		}
 
@@ -79,8 +76,7 @@ function scrapeScene(html, site, url) {
 		src: (/^http/.test(el.src) ? el.src : `https:${el.src}`),
 		referer: site.url,
 		attempts: 5,
-		interval: 5000,
-		concurrency: 1,
+		queueMethod: '5s',
 	}));
 
 	const posterEl = scene.querySelector('#no-player-image');
@@ -92,16 +88,14 @@ function scrapeScene(html, site, url) {
 			src: /^http/.test(posterEl.src) ? posterEl.src : `https:${posterEl.src}`,
 			referer: site.url,
 			attempts: 5,
-			interval: 5000,
-			concurrency: 1,
+			queueMethod: '5s',
 		};
 	} else if (videoEl) {
 		release.poster = {
 			src: /^http/.test(videoEl.poster) ? videoEl.poster : `https:${videoEl.poster}`,
 			referer: site.url,
 			attempts: 5,
-			interval: 5000,
-			concurrency: 1,
+			queueMethod: '5s',
 		};
 	}
 
@@ -110,8 +104,7 @@ function scrapeScene(html, site, url) {
 			src: trailerEl.src,
 			referer: site.url,
 			attempts: 5,
-			interval: 5000,
-			concurrency: 1,
+			queueMethod: '5s',
 		};
 	}