Catching unhandled errors

Amit-A · Dec 22, 2019 · 79960d1 · 79960d1
1 parent 95b9567
commit 79960d1
Showing 1 changed file with 26 additions and 10 deletions.
diff --git a/lib/index.js b/lib/index.js
@@ -52,15 +52,23 @@ formidable.IncomingForm.prototype.parse = function(req, cb) {
 
   // handling serverless cases
   if (Buffer.isBuffer(req.rawBody)) { // firebase
-    // parse headers
-    this.writeHeaders(req.headers);
-    // parse body
-    this.write(req.rawBody);
+    try {
+      // parse headers
+      this.writeHeaders(req.headers);
+      // parse body
+      this.write(req.rawBody);
+    } catch (err) {
+      this._error(err);
+    }
   } else if (Buffer.isBuffer(req.body)) { // body parser
-    // parse headers
-    this.writeHeaders(req.headers);
-    // parse body
-    this.write(req.body);
+    try {
+      // parse headers
+      this.writeHeaders(req.headers);
+      // parse body
+      this.write(req.body);
+    } catch (err) {
+      this._error(err);
+    }
   } else {
     // standard formidable parse prototype (not serverless)...
 
@@ -93,7 +101,11 @@ formidable.IncomingForm.prototype.parse = function(req, cb) {
     };
 
     // parse headers
-    this.writeHeaders(req.headers);
+    try {
+      this.writeHeaders(req.headers);
+    } catch (err) {
+      this._error(err);
+    }
 
     // start listening for data...
 
@@ -103,7 +115,11 @@ formidable.IncomingForm.prototype.parse = function(req, cb) {
     });
 
     req.on('data', function (buffer) {
-      self.write(buffer);
+      try {
+        self.write(buffer);
+      } catch (err) {
+        self._error(err);
+      }
     });
   }
   return this;