Compare commits

...

4 Commits

Author SHA1 Message Date
bb0dd6426a 2.0.12 2023-04-19 04:07:44 +02:00
d471376681 fix(core): update 2023-04-19 04:07:44 +02:00
b882922f2b 2.0.11 2022-08-21 14:03:18 +02:00
9a0d35c325 fix(core): update 2022-08-21 14:03:18 +02:00
5 changed files with 4494 additions and 38 deletions

32
package-lock.json generated
View File

@ -1,16 +1,16 @@
{ {
"name": "@pushrocks/smartrequest", "name": "@pushrocks/smartrequest",
"version": "2.0.10", "version": "2.0.12",
"lockfileVersion": 2, "lockfileVersion": 2,
"requires": true, "requires": true,
"packages": { "packages": {
"": { "": {
"name": "@pushrocks/smartrequest", "name": "@pushrocks/smartrequest",
"version": "2.0.10", "version": "2.0.12",
"license": "MIT", "license": "MIT",
"dependencies": { "dependencies": {
"@pushrocks/smartpromise": "^3.1.7", "@pushrocks/smartpromise": "^3.1.7",
"@pushrocks/smarturl": "^3.0.3", "@pushrocks/smarturl": "^3.0.5",
"agentkeepalive": "^4.2.1", "agentkeepalive": "^4.2.1",
"form-data": "^4.0.0" "form-data": "^4.0.0"
}, },
@ -19,7 +19,7 @@
"@gitzone/tsrun": "^1.2.37", "@gitzone/tsrun": "^1.2.37",
"@gitzone/tstest": "^1.0.73", "@gitzone/tstest": "^1.0.73",
"@pushrocks/tapbundle": "^5.0.4", "@pushrocks/tapbundle": "^5.0.4",
"@types/node": "^18.6.4" "@types/node": "^18.7.8"
} }
}, },
"node_modules/@adobe/helix-fetch": { "node_modules/@adobe/helix-fetch": {
@ -1242,9 +1242,9 @@
} }
}, },
"node_modules/@pushrocks/smarturl": { "node_modules/@pushrocks/smarturl": {
"version": "3.0.3", "version": "3.0.5",
"resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarturl/-/smarturl-3.0.3.tgz", "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarturl/-/smarturl-3.0.5.tgz",
"integrity": "sha512-vhDve6S8d5mlQuO5Fk41d+MTpu8s11oxMLvX6OVlHHIPPD2PCkFrBihlcVe/PWudbNBBMYS0CC2t9J8iQvM0BA==", "integrity": "sha512-XKS+GpIOvMhxr855PmO39SOvv/hdhBbLZ45dkAA6uGL3XdW036jAp61nu7qeB3c6FPShCyhJzo2z5x51wW7OwQ==",
"license": "MIT" "license": "MIT"
}, },
"node_modules/@pushrocks/smartxml": { "node_modules/@pushrocks/smartxml": {
@ -1833,9 +1833,9 @@
"license": "MIT" "license": "MIT"
}, },
"node_modules/@types/node": { "node_modules/@types/node": {
"version": "18.6.4", "version": "18.7.8",
"resolved": "https://verdaccio.lossless.one/@types%2fnode/-/node-18.6.4.tgz", "resolved": "https://verdaccio.lossless.one/@types%2fnode/-/node-18.7.8.tgz",
"integrity": "sha512-I4BD3L+6AWiUobfxZ49DlU43gtI+FTHSv9pE2Zekg6KjMpre4ByusaljW3vYSLJrvQ1ck1hUaeVu8HVlY3vzHg==", "integrity": "sha512-/YP55EMK2341JkODUb8DM9O0x1SIz2aBvyF33Uf1c76St3VpsMXEIW0nxuKkq/5cxnbz0RD9cfwNZHEAZQD3ag==",
"dev": true, "dev": true,
"license": "MIT" "license": "MIT"
}, },
@ -9001,9 +9001,9 @@
} }
}, },
"@pushrocks/smarturl": { "@pushrocks/smarturl": {
"version": "3.0.3", "version": "3.0.5",
"resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarturl/-/smarturl-3.0.3.tgz", "resolved": "https://verdaccio.lossless.one/@pushrocks%2fsmarturl/-/smarturl-3.0.5.tgz",
"integrity": "sha512-vhDve6S8d5mlQuO5Fk41d+MTpu8s11oxMLvX6OVlHHIPPD2PCkFrBihlcVe/PWudbNBBMYS0CC2t9J8iQvM0BA==" "integrity": "sha512-XKS+GpIOvMhxr855PmO39SOvv/hdhBbLZ45dkAA6uGL3XdW036jAp61nu7qeB3c6FPShCyhJzo2z5x51wW7OwQ=="
}, },
"@pushrocks/smartxml": { "@pushrocks/smartxml": {
"version": "1.0.6", "version": "1.0.6",
@ -9524,9 +9524,9 @@
"dev": true "dev": true
}, },
"@types/node": { "@types/node": {
"version": "18.6.4", "version": "18.7.8",
"resolved": "https://verdaccio.lossless.one/@types%2fnode/-/node-18.6.4.tgz", "resolved": "https://verdaccio.lossless.one/@types%2fnode/-/node-18.7.8.tgz",
"integrity": "sha512-I4BD3L+6AWiUobfxZ49DlU43gtI+FTHSv9pE2Zekg6KjMpre4ByusaljW3vYSLJrvQ1ck1hUaeVu8HVlY3vzHg==", "integrity": "sha512-/YP55EMK2341JkODUb8DM9O0x1SIz2aBvyF33Uf1c76St3VpsMXEIW0nxuKkq/5cxnbz0RD9cfwNZHEAZQD3ag==",
"dev": true "dev": true
}, },
"@types/parse5": { "@types/parse5": {

View File

@ -1,6 +1,6 @@
{ {
"name": "@pushrocks/smartrequest", "name": "@pushrocks/smartrequest",
"version": "2.0.10", "version": "2.0.12",
"private": false, "private": false,
"description": "dropin replacement for request", "description": "dropin replacement for request",
"main": "dist_ts/index.js", "main": "dist_ts/index.js",
@ -25,17 +25,17 @@
}, },
"homepage": "https://gitlab.com/pushrocks/smartrequest#README", "homepage": "https://gitlab.com/pushrocks/smartrequest#README",
"dependencies": { "dependencies": {
"@pushrocks/smartpromise": "^3.1.7", "@pushrocks/smartpromise": "^4.0.2",
"@pushrocks/smarturl": "^3.0.3", "@pushrocks/smarturl": "^3.0.6",
"agentkeepalive": "^4.2.1", "agentkeepalive": "^4.3.0",
"form-data": "^4.0.0" "form-data": "^4.0.0"
}, },
"devDependencies": { "devDependencies": {
"@gitzone/tsbuild": "^2.1.65", "@gitzone/tsbuild": "^2.1.65",
"@gitzone/tsrun": "^1.2.37", "@gitzone/tsrun": "^1.2.39",
"@gitzone/tstest": "^1.0.73", "@gitzone/tstest": "^1.0.74",
"@pushrocks/tapbundle": "^5.0.4", "@pushrocks/tapbundle": "^5.0.4",
"@types/node": "^18.6.4" "@types/node": "^18.15.11"
}, },
"files": [ "files": [
"ts/**/*", "ts/**/*",

4431
pnpm-lock.yaml generated Normal file

File diff suppressed because it is too large Load Diff

View File

@ -3,6 +3,6 @@
*/ */
export const commitinfo = { export const commitinfo = {
name: '@pushrocks/smartrequest', name: '@pushrocks/smartrequest',
version: '2.0.10', version: '2.0.12',
description: 'dropin replacement for request' description: 'dropin replacement for request'
} }

View File

@ -70,7 +70,7 @@ const httpAgent = new plugins.agentkeepalive({
*/ */
const httpAgentKeepAliveFalse = new plugins.agentkeepalive({ const httpAgentKeepAliveFalse = new plugins.agentkeepalive({
keepAlive: false, keepAlive: false,
timeout: 60000 timeout: 60000,
}); });
/** /**
@ -81,7 +81,7 @@ const httpsAgent = new plugins.agentkeepalive.HttpsAgent({
maxFreeSockets: 10, maxFreeSockets: 10,
maxSockets: 100, maxSockets: 100,
maxTotalSockets: 1000, maxTotalSockets: 1000,
timeout: 60000 timeout: 60000,
}); });
/** /**
@ -89,7 +89,7 @@ const httpsAgent = new plugins.agentkeepalive.HttpsAgent({
*/ */
const httpsAgentKeepAliveFalse = new plugins.agentkeepalive.HttpsAgent({ const httpsAgentKeepAliveFalse = new plugins.agentkeepalive.HttpsAgent({
keepAlive: false, keepAlive: false,
timeout: 60000 timeout: 60000,
}); });
export let request = async ( export let request = async (
@ -132,20 +132,30 @@ export let request = async (
// TODO: support tcp sockets // TODO: support tcp sockets
// lets determine agent
switch (true) {
case !!optionsArg.agent:
break;
case parsedUrl.protocol === 'https:' && optionsArg.keepAlive:
optionsArg.agent = httpsAgent;
break;
case parsedUrl.protocol === 'https:' && !optionsArg.keepAlive:
optionsArg.agent = httpsAgentKeepAliveFalse;
break;
case parsedUrl.protocol === 'http:' && optionsArg.keepAlive:
optionsArg.agent = httpAgent;
break;
case parsedUrl.protocol === 'http:' && !optionsArg.keepAlive:
optionsArg.agent = httpAgentKeepAliveFalse;
break;
}
// lets determine the request module to use // lets determine the request module to use
const requestModule = (() => { const requestModule = (() => {
switch (true) { switch (true) {
case parsedUrl.protocol === 'https:' && optionsArg.keepAlive: case parsedUrl.protocol === 'https:':
optionsArg.agent = httpsAgent;
return plugins.https; return plugins.https;
case parsedUrl.protocol === 'https:' && !optionsArg.keepAlive: case parsedUrl.protocol === 'http:':
optionsArg.agent = httpsAgentKeepAliveFalse;
return plugins.https;
case parsedUrl.protocol === 'http:' && optionsArg.keepAlive:
optionsArg.agent = httpAgent;
return plugins.http;
case parsedUrl.protocol === 'http:' && !optionsArg.keepAlive:
optionsArg.agent = httpAgentKeepAliveFalse;
return plugins.http; return plugins.http;
} }
})() as typeof plugins.https; })() as typeof plugins.https;
@ -194,6 +204,21 @@ export let request = async (
response.on('error', (err) => { response.on('error', (err) => {
console.log(err); console.log(err);
response.destroy(); response.destroy();
}) });
return response; return response;
}; };
export const safeGet = async (urlArg: string) => {
try {
const response = await request(urlArg, {
method: 'GET',
agent: plugins.http.globalAgent,
timeout: 5000,
autoJsonParse: false,
});
return response;
} catch (err) {
console.log(err);
return null;
}
};