Compare commits
6 Commits
Author | SHA1 | Date | |
---|---|---|---|
376225888c | |||
63e8660f6c | |||
2358b1d48f | |||
9db29bacc2 | |||
5f27b6834c | |||
6717ecf80c |
@ -48,7 +48,7 @@ testLTS:
|
||||
coverage: /\d+.?\d+?\%\s*coverage/
|
||||
tags:
|
||||
- docker
|
||||
- notpriv
|
||||
- priv
|
||||
|
||||
testBuild:
|
||||
stage: test
|
||||
|
2
package-lock.json
generated
2
package-lock.json
generated
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@pushrocks/smartrequest",
|
||||
"version": "1.1.17",
|
||||
"version": "1.1.20",
|
||||
"lockfileVersion": 1,
|
||||
"requires": true,
|
||||
"dependencies": {
|
||||
|
@ -1,6 +1,6 @@
|
||||
{
|
||||
"name": "@pushrocks/smartrequest",
|
||||
"version": "1.1.17",
|
||||
"version": "1.1.20",
|
||||
"private": false,
|
||||
"description": "dropin replacement for request",
|
||||
"main": "dist/index.js",
|
||||
|
@ -55,6 +55,16 @@ const parseSocketPathAndRoute = (stringToParseArg: string) => {
|
||||
};
|
||||
};
|
||||
|
||||
const httpAgent = new plugins.http.Agent({
|
||||
keepAlive: true,
|
||||
keepAliveMsecs: 600000
|
||||
});
|
||||
|
||||
const httpsAgent = new plugins.https.Agent({
|
||||
keepAlive: true,
|
||||
keepAliveMsecs: 600000
|
||||
});
|
||||
|
||||
export let request = async (
|
||||
domainArg: string,
|
||||
optionsArg: interfaces.ISmartRequestOptions = {},
|
||||
@ -64,6 +74,7 @@ export let request = async (
|
||||
|
||||
// merge options
|
||||
const defaultOptions: interfaces.ISmartRequestOptions = {
|
||||
// agent: agent,
|
||||
autoJsonParse: true
|
||||
};
|
||||
|
||||
@ -88,11 +99,15 @@ export let request = async (
|
||||
optionsArg.path = detailedUnixPath.path;
|
||||
}
|
||||
|
||||
// TODO: support tcp sockets
|
||||
|
||||
// lets determine the request module to use
|
||||
const requestModule = (() => {
|
||||
if (parsedUrl.protocol === 'https:') {
|
||||
optionsArg.agent = httpsAgent;
|
||||
return plugins.https;
|
||||
} else if (parsedUrl.protocol === 'http:') {
|
||||
optionsArg.agent = httpAgent;
|
||||
return plugins.http;
|
||||
} else {
|
||||
throw new Error(`unsupported protocol: ${parsedUrl.protocol}`);
|
||||
|
Reference in New Issue
Block a user