1.1.29

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartrequest",
-  "version": "1.1.25",
+  "version": "1.1.29",
   "lockfileVersion": 1,
   "requires": true,
   "dependencies": {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pushrocks/smartrequest",
-  "version": "1.1.25",
+  "version": "1.1.29",
   "private": false,
   "description": "dropin replacement for request",
   "main": "dist/index.js",

ts/smartrequest.request.ts

@@ -66,8 +66,9 @@ const httpAgent = new plugins.http.Agent({
  * a custom http agent to make sure we can set custom keepAlive options for speedy subsequent calls
  */
 const httpAgentKeepAliveFalse = new plugins.http.Agent({
+  maxFreeSockets: 0,
   keepAlive: false,
-  keepAliveMsecs: 600000
+  keepAliveMsecs: 0
 });
 
 /**
@@ -82,8 +83,9 @@ const httpsAgent = new plugins.https.Agent({
  * a custom https agent to make sure we can set custom keepAlive options for speedy subsequent calls
  */
 const httpsAgentKeepAliveFalse = new plugins.https.Agent({
+  maxFreeSockets: 0,
   keepAlive: false,
-  keepAliveMsecs: 600000
+  keepAliveMsecs: 0
 });
 
 export let request = async (
@@ -128,33 +130,40 @@ export let request = async (
       case parsedUrl.protocol === 'https:' && optionsArg.keepAlive:
         optionsArg.agent = httpsAgent;
         return plugins.https;
-      case parsedUrl.protocol === 'https:' && !optionsArg.keepAlive:
+      case parsedUrl.protocol === 'https:' && (!optionsArg.keepAlive):
         optionsArg.agent = httpsAgentKeepAliveFalse;
         return plugins.https;
       case parsedUrl.protocol === 'http:' && optionsArg.keepAlive:
         optionsArg.agent = httpAgent;
         return plugins.http;
-      case parsedUrl.protocol === 'http:' && !optionsArg.keepAlive:
+      case parsedUrl.protocol === 'http:' && (!optionsArg.keepAlive):
         optionsArg.agent = httpAgentKeepAliveFalse;
         return plugins.http;
     }
   })() as typeof plugins.https;
 
   // lets perform the actual request
-  const requestToFire = requestModule.request(optionsArg);
+  const requestToFire = requestModule.request(optionsArg, async response => {
+    if (streamArg) {
+      done.resolve(response);
+    } else {
+      const builtResponse = await buildUtf8Response(response, optionsArg.autoJsonParse);
+      done.resolve(builtResponse);
+    }
+  });
 
   // lets write the requestBody
   if (optionsArg.requestBody) {
-    if (!(optionsArg.requestBody instanceof plugins.formData)) {
+    if (optionsArg.requestBody instanceof plugins.formData) {
+      optionsArg.requestBody.pipe(requestToFire).on('finish', event => {
+        requestToFire.end();
+      });
+    } else {
       if (typeof optionsArg.requestBody !== 'string') {
         optionsArg.requestBody = JSON.stringify(optionsArg.requestBody);
       }
       requestToFire.write(optionsArg.requestBody);
       requestToFire.end();
-    } else if (optionsArg.requestBody instanceof plugins.formData) {
-      optionsArg.requestBody.pipe(requestToFire).on('finish', event => {
-        requestToFire.end();
-      });
     }
   } else {
     requestToFire.end();
@@ -165,16 +174,6 @@ export let request = async (
     console.error(e);
   });
 
-  // lets handle the response
-  requestToFire.on('response', async response => {
-    if (streamArg) {
-      done.resolve(response);
-    } else {
-      const builtResponse = await buildUtf8Response(response, optionsArg.autoJsonParse);
-      done.resolve(builtResponse);
-    }
-  });
-
   const result = await done.promise;
   return result;
 };