kbruen/db-vendo-client
1
0
Fork 0
mirror of https://github.com/public-transport/db-vendo-client.git synced 2025-04-20 23:23:56 +03:00
Code Issues Projects Releases Packages 1 Wiki Activity Actions

more reliable setup of proxy agent
Some checks failed
test / lint-and-spellcheck (push) Has been cancelled
Details
test / unit-tests (18.x) (push) Has been cancelled
Details
test / unit-tests (20.x) (push) Has been cancelled
Details
test / unit-tests (22.x) (push) Has been cancelled
Details
test / integration-tests (18.x) (push) Has been cancelled
Details
test / integration-tests (20.x) (push) Has been cancelled
Details
test / integration-tests (22.x) (push) Has been cancelled
Details
test / e2e-tests (18.x) (push) Has been cancelled
Details

Browse source
This commit is contained in:
Traines 2025-03-08 23:12:36 +00:00
parent 960371e2ec
commit 9975a6c9ac
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
lib/request.js
View file

@ -7,15 +7,16 @@ const proxyAddress = typeof process !== 'undefined' && (process.env.HTTPS_PROXY
let getAgent = () => undefined; let getAgent = () => undefined;
if (proxyAddress) { const setupProxy = async () => {
import('https-proxy-agent').then(a => { if (proxyAddress && !getAgent()) {
const a = await import('https-proxy-agent');
const agent = new a.default.HttpsProxyAgent(proxyAddress, { const agent = new a.default.HttpsProxyAgent(proxyAddress, {
keepAlive: true, keepAlive: true,
keepAliveMsecs: 10 * 1000, // 10s keepAliveMsecs: 10 * 1000, // 10s
}); });
getAgent = () => agent; getAgent = () => agent;
}); }
} };
const randomBytesHexString = length => [...Array(length)].map(() => Math.floor(Math.random() * 16) const randomBytesHexString = length => [...Array(length)].map(() => Math.floor(Math.random() * 16)
.toString(16)) .toString(16))
@ -74,6 +75,7 @@ const checkIfResponseIsOk = (_) => {
const request = async (ctx, userAgent, reqData) => { const request = async (ctx, userAgent, reqData) => {
const {profile, opt} = ctx; const {profile, opt} = ctx;
await setupProxy();
const endpoint = reqData.endpoint; const endpoint = reqData.endpoint;
delete reqData.endpoint; delete reqData.endpoint;