package-lock.json

@@ -1,11 +1,11 @@
 {
     "name": "traxxx",
-    "version": "1.184.2",
+    "version": "1.184.1",
     "lockfileVersion": 2,
     "requires": true,
     "packages": {
         "": {
-            "version": "1.184.2",
+            "version": "1.184.1",
             "license": "ISC",
             "dependencies": {
                 "@casl/ability": "^5.2.2",

package.json

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

src/utils/http.js

@@ -1,7 +1,6 @@
 'use strict';
 
 const config = require('config');
-const Promise = require('bluebird');
 const bhttp = require('bhttp');
 const util = require('util');
 const stream = require('stream');
@@ -16,12 +15,7 @@ const argv = require('../argv');
 const pipeline = util.promisify(stream.pipeline);
 const limiters = {};
 
-Promise.config({
-	cancellation: true,
-});
-
 const defaultOptions = {
-	timeout: 60000,
 	encodeJSON: true,
 	headers: {
 		'user-agent': 'Mozilla/5.0 (X11; Ubuntu; Linux x86_64; rv:15.0) Gecko/20100101 Firefox/15.0.1',
@@ -73,7 +67,6 @@ function getLimiter(options = {}, url) {
 		limiters[interval][concurrency] = new Bottleneck({
 			minTime: interval,
 			maxConcurrent: concurrency,
-			timeout: (options.timeout || defaultOptions.timeout) + 10000, // timeout 10 seconds after bhttp should
 		});
 	}
 
@@ -90,7 +83,7 @@ async function request(method = 'get', url, body, requestOptions = {}, limiter)
 			...defaultOptions.headers,
 			...requestOptions.headers,
 		},
-		responseTimeout: requestOptions.responseTimeout || requestOptions.timeout || defaultOptions.timeout,
+		responseTimeout: requestOptions.responseTimeout || requestOptions.timeout || 60000,
 		stream: !!requestOptions.destination,
 		session: null,
 	};
@@ -138,25 +131,10 @@ async function request(method = 'get', url, body, requestOptions = {}, limiter)
 	};
 }
 
-function getTimeout(options, url) {
-	return new Promise((resolve, reject, onCancel) => {
-		const timeoutId = setTimeout(() => {
-			reject(new Error(`URL ${url} timed out`));
-		}, (options?.timeout || defaultOptions.timeout) + 10000);
-
-		onCancel(() => clearTimeout(timeoutId));
-	});
-}
-
 async function scheduleRequest(method = 'get', url, body, options) {
 	const limiter = getLimiter(options, url);
-	const timeout = getTimeout(options, url);
 
-	const result = await limiter.schedule(() => Promise.race([request(method, url, body, options, limiter), timeout]));
-
-	timeout.cancel();
-
-	return result;
+	return limiter.schedule(() => request(method, url, body, options, limiter));
 }
 
 async function get(url, options) {

src/web/postgraphile.js

@@ -45,5 +45,4 @@ module.exports = postgraphile(
 		],
 		pgSettings,
 	},
-	pgSettings,
 );