From 06486cfa14073563aeb2edd24bbdda0bb48b6b62 Mon Sep 17 00:00:00 2001
From: Trivikram <16024985+trivikr@users.noreply.github.com>
Date: Sun, 18 Feb 2018 13:39:06 -0800
Subject: [PATCH] test: http2 compat response.write() error checks

---
 ...http2-compat-serverresponse-write-no-cb.js | 95 -------------------
 .../test-http2-compat-serverresponse-write.js | 52 ++++++++++
 2 files changed, 52 insertions(+), 95 deletions(-)
 delete mode 100644 test/parallel/test-http2-compat-serverresponse-write-no-cb.js
 create mode 100644 test/parallel/test-http2-compat-serverresponse-write.js

diff --git a/test/parallel/test-http2-compat-serverresponse-write-no-cb.js b/test/parallel/test-http2-compat-serverresponse-write-no-cb.js
deleted file mode 100644
index a62bb1b0ac78f1..00000000000000
--- a/test/parallel/test-http2-compat-serverresponse-write-no-cb.js
+++ /dev/null
@@ -1,95 +0,0 @@
-'use strict';
-
-const { mustCall,
-        mustNotCall,
-        expectsError,
-        hasCrypto, skip } = require('../common');
-if (!hasCrypto)
-  skip('missing crypto');
-const { createServer, connect } = require('http2');
-
-// Http2ServerResponse.write does not imply there is a callback
-
-{
-  const server = createServer();
-  server.listen(0, mustCall(() => {
-    const port = server.address().port;
-    const url = `http://localhost:${port}`;
-    const client = connect(url, mustCall(() => {
-      const request = client.request();
-      request.resume();
-      request.on('end', mustCall());
-      request.on('close', mustCall(() => {
-        client.close();
-      }));
-    }));
-
-    server.once('request', mustCall((request, response) => {
-      client.destroy();
-      response.stream.session.on('close', mustCall(() => {
-        response.on('error', mustNotCall());
-        expectsError(
-          () => { response.write('muahaha'); },
-          {
-            code: 'ERR_HTTP2_INVALID_STREAM'
-          }
-        );
-        server.close();
-      }));
-    }));
-  }));
-}
-
-{
-  const server = createServer();
-  server.listen(0, mustCall(() => {
-    const port = server.address().port;
-    const url = `http://localhost:${port}`;
-    const client = connect(url, mustCall(() => {
-      const request = client.request();
-      request.resume();
-      request.on('end', mustCall());
-      request.on('close', mustCall(() => client.close()));
-    }));
-
-    server.once('request', mustCall((request, response) => {
-      client.destroy();
-      response.stream.session.on('close', mustCall(() => {
-        expectsError(
-          () => response.write('muahaha'),
-          {
-            code: 'ERR_HTTP2_INVALID_STREAM'
-          }
-        );
-        server.close();
-      }));
-    }));
-  }));
-}
-
-{
-  const server = createServer();
-  server.listen(0, mustCall(() => {
-    const port = server.address().port;
-    const url = `http://localhost:${port}`;
-    const client = connect(url, mustCall(() => {
-      const request = client.request();
-      request.resume();
-      request.on('end', mustCall());
-      request.on('close', mustCall(() => client.close()));
-    }));
-
-    server.once('request', mustCall((request, response) => {
-      response.stream.session.on('close', mustCall(() => {
-        expectsError(
-          () => response.write('muahaha', 'utf8'),
-          {
-            code: 'ERR_HTTP2_INVALID_STREAM'
-          }
-        );
-        server.close();
-      }));
-      client.destroy();
-    }));
-  }));
-}
diff --git a/test/parallel/test-http2-compat-serverresponse-write.js b/test/parallel/test-http2-compat-serverresponse-write.js
new file mode 100644
index 00000000000000..af3029835eaecb
--- /dev/null
+++ b/test/parallel/test-http2-compat-serverresponse-write.js
@@ -0,0 +1,52 @@
+'use strict';
+
+const {
+  mustCall,
+  mustNotCall,
+  expectsError,
+  hasCrypto,
+  skip
+} = require('../common');
+if (!hasCrypto)
+  skip('missing crypto');
+const { createServer, connect } = require('http2');
+const assert = require('assert');
+
+const server = createServer();
+server.listen(0, mustCall(() => {
+  const port = server.address().port;
+  const url = `http://localhost:${port}`;
+  const client = connect(url, mustCall(() => {
+    const request = client.request();
+    request.resume();
+    request.on('end', mustCall());
+    request.on('close', mustCall(() => {
+      client.close();
+    }));
+  }));
+
+  server.once('request', mustCall((request, response) => {
+    // response.write() returns true
+    assert(response.write('muahaha', 'utf8', mustCall()));
+
+    response.stream.close(0, mustCall(() => {
+      response.on('error', mustNotCall());
+
+      // response.write() without cb returns error
+      expectsError(
+        () => { response.write('muahaha'); },
+        {
+          type: Error,
+          code: 'ERR_HTTP2_INVALID_STREAM',
+          message: 'The stream has been destroyed'
+        }
+      );
+
+      // response.write() with cb returns falsy value
+      assert(!response.write('muahaha', mustCall()));
+
+      client.destroy();
+      server.close();
+    }));
+  }));
+}));