Skip to content

Commit

Permalink
Fix handling of FormData errors
Browse files Browse the repository at this point in the history
When a file cannot be uploaded (e.g. becase it does not exist), report
the error via callback/promise.

Before this change, FormData errors were reported via "error" event
on the request. In promise mode, such error was caught by `.then()`
handler in a way that shadowed the actual error reported by `.end()`.
In callback mode, such error was not caught at all and crashed the
process on an unhandled error.

With this change in place, FormData errors finish the request and pass
the error directly to the callback.
  • Loading branch information
bajtos committed Mar 14, 2019
1 parent 0f0949f commit e6ffbde
Show file tree
Hide file tree
Showing 3 changed files with 39 additions and 18 deletions.
8 changes: 7 additions & 1 deletion lib/node/index.js
Original file line number Diff line number Diff line change
Expand Up @@ -264,7 +264,13 @@ Request.prototype._getFormData = function() {
if (!this._formData) {
this._formData = new FormData();
this._formData.on('error', err => {
this.emit('error', err);
debug('FormData error', err);
if (this.called) {
// The request has already finished and the callback was called.
// Silently ignore the error.
return;
}
this.callback(err);
this.abort();
});
}
Expand Down
1 change: 0 additions & 1 deletion lib/request-base.js
Original file line number Diff line number Diff line change
Expand Up @@ -242,7 +242,6 @@ RequestBase.prototype.then = function then(resolve, reject) {
console.warn("Warning: superagent request was sent twice, because both .end() and .then() were called. Never call .end() if you use promises");
}
this._fullfilledPromise = new Promise((innerResolve, innerReject) => {
self.on('error', innerReject);
self.on('abort', () => {
const err = new Error('Aborted');
err.code = "ABORTED";
Expand Down
48 changes: 32 additions & 16 deletions test/node/multipart.js
Original file line number Diff line number Diff line change
Expand Up @@ -73,31 +73,49 @@ describe("Multipart", () => {
});

describe("when a file does not exist", () => {
it("should emit an error", done => {
it("should fail the request with an error", done => {
const req = request.post(`${base}/echo`);

req.attach("name", "foo");
req.attach("name2", "bar");
req.attach("name3", "baz");

req.on("error", err => {
req.end((err, res) => {
assert.ok(!!err, "Request should have failed.");
err.code.should.equal("ENOENT");
err.message.should.containEql("ENOENT");
err.path.should.equal("foo");
done();
});

req.end((err, res) => {
if (err) return done(err);
assert(0, "end() was called");
});
});

it("promise should fail", () => {
request.post('nevermind')
.field({a:1,b:2})
.attach('c', 'does-not-exist.txt')
.then(() => assert.fail("It should not allow this"))
.catch(() => true);
return request.post(`${base}/echo`)
.field({a:1,b:2})
.attach('c', 'does-not-exist.txt')
.then(
res => assert.fail("It should not allow this"),
err => {
err.code.should.equal("ENOENT");
err.path.should.equal("does-not-exist.txt");
});
});

it("should report ECONNREFUSED via the callback", done => {
request.post('http://127.0.0.1:1') // nobody is listening there
.attach("name", "file-does-not-exist")
.end((err, res) => {
assert.ok(!!err, "Request should have failed");
err.code.should.equal("ECONNREFUSED");
done();
});
});
it("should report ECONNREFUSED via Promise", () => {
return request.post('http://127.0.0.1:1') // nobody is listening there
.attach("name", "file-does-not-exist")
.then(
res => assert.fail("Request should have failed"),
err => err.code.should.equal("ECONNREFUSED"));
});
});
});
Expand Down Expand Up @@ -143,13 +161,11 @@ describe("Multipart", () => {
request
.post(`${base}/echo`)
.attach("filedata", "test/node/fixtures/non-existent-file.ext")
.on("error", err => {
.end((err, res) => {
assert.ok(!!err, "Request should have failed.");
err.code.should.equal("ENOENT");
err.path.should.equal("test/node/fixtures/non-existent-file.ext");
done();
})
.end((err, res) => {
done(new Error("Request should have been aborted earlier!"));
});
});
});
Expand Down

0 comments on commit e6ffbde

Please sign in to comment.