summaryrefslogtreecommitdiff
path: root/tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js
diff options
context:
space:
mode:
Diffstat (limited to 'tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js')
-rw-r--r--tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js66
1 files changed, 66 insertions, 0 deletions
diff --git a/tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js b/tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js
new file mode 100644
index 000000000..00958457f
--- /dev/null
+++ b/tests/node_compat/test/parallel/test-fs-write-stream-autoclose-option.js
@@ -0,0 +1,66 @@
+// deno-fmt-ignore-file
+// deno-lint-ignore-file
+
+// Copyright Joyent and Node contributors. All rights reserved. MIT license.
+// Taken from Node 18.12.1
+// This file is automatically generated by `tools/node_compat/setup.ts`. Do not modify this file manually.
+
+'use strict';
+const common = require('../common');
+const assert = require('assert');
+const path = require('path');
+const fs = require('fs');
+
+const tmpdir = require('../common/tmpdir');
+
+const file = path.join(tmpdir.path, 'write-autoclose-opt1.txt');
+tmpdir.refresh();
+let stream = fs.createWriteStream(file, { flags: 'w+', autoClose: false });
+stream.write('Test1');
+stream.end();
+stream.on('finish', common.mustCall(function() {
+ stream.on('close', common.mustNotCall());
+ process.nextTick(common.mustCall(function() {
+ assert.strictEqual(stream.closed, false);
+ assert.notStrictEqual(stream.fd, null);
+ next();
+ }));
+}));
+
+function next() {
+ // This will tell us if the fd is usable again or not
+ stream = fs.createWriteStream(null, { fd: stream.fd, start: 0 });
+ stream.write('Test2');
+ stream.end();
+ stream.on('finish', common.mustCall(function() {
+ assert.strictEqual(stream.closed, false);
+ stream.on('close', common.mustCall(function() {
+ assert.strictEqual(stream.fd, null);
+ assert.strictEqual(stream.closed, true);
+ process.nextTick(next2);
+ }));
+ }));
+}
+
+function next2() {
+ // This will test if after reusing the fd data is written properly
+ fs.readFile(file, function(err, data) {
+ assert.ifError(err);
+ assert.strictEqual(data.toString(), 'Test2');
+ process.nextTick(common.mustCall(next3));
+ });
+}
+
+function next3() {
+ // This is to test success scenario where autoClose is true
+ const stream = fs.createWriteStream(file, { autoClose: true });
+ stream.write('Test3');
+ stream.end();
+ stream.on('finish', common.mustCall(function() {
+ assert.strictEqual(stream.closed, false);
+ stream.on('close', common.mustCall(function() {
+ assert.strictEqual(stream.fd, null);
+ assert.strictEqual(stream.closed, true);
+ }));
+ }));
+}