Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
c6fa540543 | |||
1891b54389 | |||
fee8443af1 | |||
c48f956ae3 | |||
4a4b64a2c4 | |||
43d4b47782 |
4
package-lock.json
generated
4
package-lock.json
generated
@ -1,12 +1,12 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "2.0.4",
|
"version": "2.0.7",
|
||||||
"lockfileVersion": 2,
|
"lockfileVersion": 2,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"packages": {
|
"packages": {
|
||||||
"": {
|
"": {
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "2.0.4",
|
"version": "2.0.7",
|
||||||
"license": "MIT",
|
"license": "MIT",
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
"@pushrocks/smartpromise": "^3.1.7",
|
"@pushrocks/smartpromise": "^3.1.7",
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "2.0.4",
|
"version": "2.0.7",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "dropin replacement for request",
|
"description": "dropin replacement for request",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
|
@ -3,6 +3,6 @@
|
|||||||
*/
|
*/
|
||||||
export const commitinfo = {
|
export const commitinfo = {
|
||||||
name: '@pushrocks/smartrequest',
|
name: '@pushrocks/smartrequest',
|
||||||
version: '2.0.4',
|
version: '2.0.7',
|
||||||
description: 'dropin replacement for request'
|
description: 'dropin replacement for request'
|
||||||
}
|
}
|
||||||
|
@ -59,17 +59,18 @@ const parseSocketPathAndRoute = (stringToParseArg: string) => {
|
|||||||
*/
|
*/
|
||||||
const httpAgent = new plugins.agentkeepalive({
|
const httpAgent = new plugins.agentkeepalive({
|
||||||
keepAlive: true,
|
keepAlive: true,
|
||||||
maxFreeSockets: 1,
|
maxFreeSockets: 10,
|
||||||
maxSockets: 100,
|
maxSockets: 100,
|
||||||
maxTotalSockets: 1000,
|
maxTotalSockets: 1000,
|
||||||
|
timeout: 60000,
|
||||||
});
|
});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* a custom http agent to make sure we can set custom keepAlive options for speedy subsequent calls
|
* a custom http agent to make sure we can set custom keepAlive options for speedy subsequent calls
|
||||||
*/
|
*/
|
||||||
const httpAgentKeepAliveFalse = new plugins.https.Agent({
|
const httpAgentKeepAliveFalse = new plugins.agentkeepalive({
|
||||||
maxFreeSockets: 0,
|
keepAlive: false,
|
||||||
keepAlive: false
|
timeout: 60000
|
||||||
});
|
});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -77,17 +78,18 @@ const httpAgentKeepAliveFalse = new plugins.https.Agent({
|
|||||||
*/
|
*/
|
||||||
const httpsAgent = new plugins.agentkeepalive.HttpsAgent({
|
const httpsAgent = new plugins.agentkeepalive.HttpsAgent({
|
||||||
keepAlive: true,
|
keepAlive: true,
|
||||||
maxFreeSockets: 1,
|
maxFreeSockets: 10,
|
||||||
maxSockets: 100,
|
maxSockets: 100,
|
||||||
maxTotalSockets: 1000,
|
maxTotalSockets: 1000,
|
||||||
|
timeout: 60000
|
||||||
});
|
});
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* a custom https agent to make sure we can set custom keepAlive options for speedy subsequent calls
|
* a custom https agent to make sure we can set custom keepAlive options for speedy subsequent calls
|
||||||
*/
|
*/
|
||||||
const httpsAgentKeepAliveFalse = new plugins.agentkeepalive.HttpsAgent({
|
const httpsAgentKeepAliveFalse = new plugins.agentkeepalive.HttpsAgent({
|
||||||
maxFreeSockets: 0,
|
keepAlive: false,
|
||||||
keepAlive: false
|
timeout: 60000
|
||||||
});
|
});
|
||||||
|
|
||||||
export let request = async (
|
export let request = async (
|
||||||
@ -185,6 +187,7 @@ export let request = async (
|
|||||||
// lets handle an error
|
// lets handle an error
|
||||||
requestToFire.on('error', (e) => {
|
requestToFire.on('error', (e) => {
|
||||||
console.error(e);
|
console.error(e);
|
||||||
|
requestToFire.destroy();
|
||||||
});
|
});
|
||||||
|
|
||||||
const result = await done.promise;
|
const result = await done.promise;
|
||||||
|
Reference in New Issue
Block a user