stream: write should throw on unknown encoding

Validate encoding passed to write(chunk, encoding, cb) and
throw if it is invalid.

PR-URL: #33075
Reviewed-By: James M Snell <[email protected]>
Reviewed-By: Matteo Collina <[email protected]>

Author: ronag

Diff for: lib/_stream_writable.js

@@ -268,6 +268,8 @@ Writable.prototype.write = function(chunk, encoding, cb) {
   } else {
     if (!encoding)
       encoding = state.defaultEncoding;
+    else if (encoding !== 'buffer' && !Buffer.isEncoding(encoding))
+      throw new ERR_UNKNOWN_ENCODING(encoding);
     if (typeof cb !== 'function')
       cb = nop;
   }

Diff for: test/parallel/test-stream-writable-write-error.js

@@ -4,17 +4,17 @@ const assert = require('assert');
 
 const { Writable } = require('stream');
 
-function expectError(w, arg, code, sync) {
+function expectError(w, args, code, sync) {
   if (sync) {
     if (code) {
-      assert.throws(() => w.write(arg), { code });
+      assert.throws(() => w.write(...args), { code });
     } else {
-      w.write(arg);
+      w.write(...args);
     }
   } else {
     let errorCalled = false;
     let ticked = false;
-    w.write(arg, common.mustCall((err) => {
+    w.write(...args, common.mustCall((err) => {
       assert.strictEqual(ticked, true);
       assert.strictEqual(errorCalled, false);
       assert.strictEqual(err.code, code);
@@ -34,7 +34,7 @@ function test(autoDestroy) {
       _write() {}
     });
     w.end();
-    expectError(w, 'asd', 'ERR_STREAM_WRITE_AFTER_END');
+    expectError(w, ['asd'], 'ERR_STREAM_WRITE_AFTER_END');
   }
 
   {
@@ -50,15 +50,24 @@ function test(autoDestroy) {
       autoDestroy,
       _write() {}
     });
-    expectError(w, null, 'ERR_STREAM_NULL_VALUES', true);
+    expectError(w, [null], 'ERR_STREAM_NULL_VALUES', true);
   }
 
   {
     const w = new Writable({
       autoDestroy,
       _write() {}
     });
-    expectError(w, {}, 'ERR_INVALID_ARG_TYPE', true);
+    expectError(w, [{}], 'ERR_INVALID_ARG_TYPE', true);
+  }
+
+  {
+    const w = new Writable({
+      decodeStrings: false,
+      autoDestroy,
+      _write() {}
+    });
+    expectError(w, ['asd', 'noencoding'], 'ERR_UNKNOWN_ENCODING', true);
   }
 }