Compare commits
4 Commits
Author | SHA1 | Date | |
---|---|---|---|
d204059313 | |||
00210566d5 | |||
14245b2521 | |||
f0fa91e2db |
2
package-lock.json
generated
2
package-lock.json
generated
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "1.1.49",
|
"version": "1.1.51",
|
||||||
"lockfileVersion": 1,
|
"lockfileVersion": 1,
|
||||||
"requires": true,
|
"requires": true,
|
||||||
"dependencies": {
|
"dependencies": {
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "@pushrocks/smartrequest",
|
"name": "@pushrocks/smartrequest",
|
||||||
"version": "1.1.49",
|
"version": "1.1.51",
|
||||||
"private": false,
|
"private": false,
|
||||||
"description": "dropin replacement for request",
|
"description": "dropin replacement for request",
|
||||||
"main": "dist_ts/index.js",
|
"main": "dist_ts/index.js",
|
||||||
|
@ -83,7 +83,7 @@ const httpsAgentKeepAliveFalse = new plugins.https.Agent({
|
|||||||
});
|
});
|
||||||
|
|
||||||
export let request = async (
|
export let request = async (
|
||||||
domainArg: string,
|
urlArg: string,
|
||||||
optionsArg: interfaces.ISmartRequestOptions = {},
|
optionsArg: interfaces.ISmartRequestOptions = {},
|
||||||
responseStreamArg: boolean = false,
|
responseStreamArg: boolean = false,
|
||||||
requestDataFunc: (req: plugins.http.ClientRequest) => void = null
|
requestDataFunc: (req: plugins.http.ClientRequest) => void = null
|
||||||
@ -103,7 +103,7 @@ export let request = async (
|
|||||||
};
|
};
|
||||||
|
|
||||||
// parse url
|
// parse url
|
||||||
const parsedUrl = plugins.url.parse(domainArg);
|
const parsedUrl = plugins.url.parse(urlArg);
|
||||||
optionsArg.hostname = parsedUrl.hostname;
|
optionsArg.hostname = parsedUrl.hostname;
|
||||||
if (parsedUrl.port) {
|
if (parsedUrl.port) {
|
||||||
optionsArg.port = parseInt(parsedUrl.port, 10);
|
optionsArg.port = parseInt(parsedUrl.port, 10);
|
||||||
@ -111,7 +111,7 @@ export let request = async (
|
|||||||
optionsArg.path = parsedUrl.path;
|
optionsArg.path = parsedUrl.path;
|
||||||
|
|
||||||
// determine if unixsock
|
// determine if unixsock
|
||||||
if (testForUnixSock(domainArg)) {
|
if (testForUnixSock(urlArg)) {
|
||||||
const detailedUnixPath = parseSocketPathAndRoute(optionsArg.path);
|
const detailedUnixPath = parseSocketPathAndRoute(optionsArg.path);
|
||||||
optionsArg.socketPath = detailedUnixPath.socketPath;
|
optionsArg.socketPath = detailedUnixPath.socketPath;
|
||||||
optionsArg.path = detailedUnixPath.path;
|
optionsArg.path = detailedUnixPath.path;
|
||||||
@ -137,6 +137,11 @@ export let request = async (
|
|||||||
}
|
}
|
||||||
})() as typeof plugins.https;
|
})() as typeof plugins.https;
|
||||||
|
|
||||||
|
if (!requestModule) {
|
||||||
|
console.error(`The request to ${urlArg} is missing a viable protocol. Must be http or https`);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
// lets perform the actual request
|
// lets perform the actual request
|
||||||
const requestToFire = requestModule.request(optionsArg, async (response) => {
|
const requestToFire = requestModule.request(optionsArg, async (response) => {
|
||||||
if (responseStreamArg) {
|
if (responseStreamArg) {
|
||||||
|
Reference in New Issue
Block a user