From 8ac1d6dde79c425dd2bb3d8d23522b7d9ef6d185 Mon Sep 17 00:00:00 2001
From: DavidCai <davidcai1993@yahoo.com>
Date: Tue, 11 Apr 2017 08:24:42 +0800
Subject: [PATCH] test: add internal/fs tests

---
 .../test-internal-fs-syncwritestream.js       | 66 +++++++++++++++++++
 test/parallel/test-internal-fs.js             | 10 +++
 2 files changed, 76 insertions(+)
 create mode 100644 test/parallel/test-internal-fs-syncwritestream.js
 create mode 100644 test/parallel/test-internal-fs.js

diff --git a/test/parallel/test-internal-fs-syncwritestream.js b/test/parallel/test-internal-fs-syncwritestream.js
new file mode 100644
index 00000000000000..a0e1aedd3b50be
--- /dev/null
+++ b/test/parallel/test-internal-fs-syncwritestream.js
@@ -0,0 +1,66 @@
+// Flags: --expose-internals
+'use strict';
+
+const common = require('../common');
+const assert = require('assert');
+const fs = require('fs');
+const path = require('path');
+const SyncWriteStream = require('internal/fs').SyncWriteStream;
+
+common.refreshTmpDir();
+
+const filename = path.join(common.tmpDir, 'sync-write-stream.txt');
+
+// Verify constructing the instance with defualt options.
+{
+  const stream = new SyncWriteStream(1);
+
+  assert.strictEqual(stream.fd, 1);
+  assert.strictEqual(stream.readable, false);
+  assert.strictEqual(stream.autoClose, true);
+  assert.strictEqual(stream.listenerCount('end'), 1);
+}
+
+// Verify constructing the instance with specified options.
+{
+  const stream = new SyncWriteStream(1, { autoClose: false });
+
+  assert.strictEqual(stream.fd, 1);
+  assert.strictEqual(stream.readable, false);
+  assert.strictEqual(stream.autoClose, false);
+  assert.strictEqual(stream.listenerCount('end'), 1);
+}
+
+// Verfiy that the file will be writen synchronously.
+{
+  const fd = fs.openSync(filename, 'w');
+  const stream = new SyncWriteStream(fd);
+  const chunk = Buffer.from('foo');
+
+  assert.strictEqual(stream._write(chunk, null, common.mustCall(1)), true);
+  assert.strictEqual(fs.readFileSync(filename).equals(chunk), true);
+}
+
+// Verify that the stream will unset the fd after destory().
+{
+  const fd = fs.openSync(filename, 'w');
+  const stream = new SyncWriteStream(fd);
+
+  stream.on('close', common.mustCall(3));
+
+  assert.strictEqual(stream.destroy(), true);
+  assert.strictEqual(stream.fd, null);
+  assert.strictEqual(stream.destroy(), true);
+  assert.strictEqual(stream.destroySoon(), true);
+}
+
+// Verfit that the 'end' event listener will also destroy the stream.
+{
+  const fd = fs.openSync(filename, 'w');
+  const stream = new SyncWriteStream(fd);
+
+  assert.strictEqual(stream.fd, fd);
+
+  stream.emit('end');
+  assert.strictEqual(stream.fd, null);
+}
diff --git a/test/parallel/test-internal-fs.js b/test/parallel/test-internal-fs.js
new file mode 100644
index 00000000000000..7d20365da997a1
--- /dev/null
+++ b/test/parallel/test-internal-fs.js
@@ -0,0 +1,10 @@
+// Flags: --expose-internals
+'use strict';
+
+require('../common');
+const assert = require('assert');
+const fs = require('internal/fs');
+
+assert.doesNotThrow(() => fs.assertEncoding());
+assert.doesNotThrow(() => fs.assertEncoding('utf8'));
+assert.throws(() => fs.assertEncoding('foo'), /^Error: Unknown encoding: foo$/);