1.1.11

package-lock.json

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

package.json

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

ts/smartrequest.formdata.ts

@@ -11,25 +11,6 @@ export interface IFormField {
   payload: string;
 }
 
-/**
- * retrieve the FormData headers in reliable way
- * @param formDataArg
- */
-const getFormDataHeaders = (formDataArg: plugins.formData) => {
-  const done = plugins.smartpromise.defer();
-  formDataArg.getLength((err, length) => {
-    if (err) {
-      done.reject(err);
-    }
-    const headers = Object.assign(
-      { "Content-Length": length },
-      formDataArg.getHeaders()
-    );
-    done.resolve(headers);
-  });
-  return done.promise;
-};
-
 const appendFormField = async (
   formDataArg: plugins.formData,
   formDataField: IFormField
@@ -54,10 +35,13 @@ export const postFormData = async (
   for (const formField of payloadArg) {
     await appendFormField(form, formField);
   }
-  const pipeLog: any = async (...args) => {
-    console.log(args);
-  };
-  const requestOptions = Object.assign({}, optionsArg, { requestBody: form });
+  const requestOptions = Object.assign({}, optionsArg, {
+    headers: {
+      ...(optionsArg.headers),
+      ...form.getHeaders()
+    },
+    requestBody: form
+  });
 
   // lets fire the actual request for sending the formdata
   const response = await request(urlArg, requestOptions);

ts/smartrequest.request.ts

@@ -98,7 +98,9 @@ export let request = async (
       request.write(optionsArg.requestBody);
       request.end();
     } else if (optionsArg.requestBody instanceof plugins.formData) {
-      optionsArg.requestBody.pipe(request);
+      optionsArg.requestBody.pipe(request).on('finish', event => {
+        request.end();
+      });
     }
   } else {
     request.end();