mirror of
https://github.com/oven-sh/bun
synced 2026-02-02 15:08:46 +00:00
node: fix test-file-write-stream3.js (#17933)
This commit is contained in:
Meghan Denny
213
test/js/node/test/parallel/test-file-write-stream3.js
Normal file
213
test/js/node/test/parallel/test-file-write-stream3.js
Normal file
@@ -0,0 +1,213 @@
|
||||
// Copyright Joyent, Inc. and other Node contributors.
|
||||
//
|
||||
// Permission is hereby granted, free of charge, to any person obtaining a
|
||||
// copy of this software and associated documentation files (the
|
||||
// "Software"), to deal in the Software without restriction, including
|
||||
// without limitation the rights to use, copy, modify, merge, publish,
|
||||
// distribute, sublicense, and/or sell copies of the Software, and to permit
|
||||
// persons to whom the Software is furnished to do so, subject to the
|
||||
// following conditions:
|
||||
//
|
||||
// The above copyright notice and this permission notice shall be included
|
||||
// in all copies or substantial portions of the Software.
|
||||
//
|
||||
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS
|
||||
// OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
|
||||
// MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN
|
||||
// NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM,
|
||||
// DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR
|
||||
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
|
||||
// USE OR OTHER DEALINGS IN THE SOFTWARE.
|
||||
|
||||
'use strict';
|
||||
const common = require('../common');
|
||||
const assert = require('assert');
|
||||
const fs = require('fs');
|
||||
|
||||
const tmpdir = require('../common/tmpdir');
|
||||
|
||||
|
||||
const filepath = tmpdir.resolve('write_pos.txt');
|
||||
|
||||
|
||||
const cb_expected = 'write open close write open close write open close ';
|
||||
let cb_occurred = '';
|
||||
|
||||
const fileDataInitial = 'abcdefghijklmnopqrstuvwxyz';
|
||||
|
||||
const fileDataExpected_1 = 'abcdefghijklmnopqrstuvwxyz';
|
||||
const fileDataExpected_2 = 'abcdefghij123456qrstuvwxyz';
|
||||
const fileDataExpected_3 = 'abcdefghij\u2026\u2026qrstuvwxyz';
|
||||
|
||||
|
||||
process.on('exit', function() {
|
||||
if (cb_occurred !== cb_expected) {
|
||||
console.log(' Test callback events missing or out of order:');
|
||||
console.log(` expected: ${cb_expected}`);
|
||||
console.log(` occurred: ${cb_occurred}`);
|
||||
assert.strictEqual(
|
||||
cb_occurred, cb_expected,
|
||||
`events missing or out of order: "${cb_occurred}" !== "${cb_expected}"`);
|
||||
}
|
||||
});
|
||||
|
||||
|
||||
tmpdir.refresh();
|
||||
|
||||
|
||||
function run_test_1() {
|
||||
const options = {};
|
||||
const file = fs.createWriteStream(filepath, options);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
|
||||
file.on('open', function(fd) {
|
||||
cb_occurred += 'open ';
|
||||
});
|
||||
|
||||
file.on('close', function() {
|
||||
cb_occurred += 'close ';
|
||||
console.log(' (debug: bytesWritten ', file.bytesWritten);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
assert.strictEqual(file.bytesWritten, buffer.length);
|
||||
const fileData = fs.readFileSync(filepath, 'utf8');
|
||||
console.log(' (debug: file data ', fileData);
|
||||
console.log(' (debug: expected ', fileDataExpected_1);
|
||||
assert.strictEqual(fileData, fileDataExpected_1);
|
||||
|
||||
run_test_2();
|
||||
});
|
||||
|
||||
file.on('error', function(err) {
|
||||
cb_occurred += 'error ';
|
||||
console.log(' (debug: err event ', err);
|
||||
throw err;
|
||||
});
|
||||
|
||||
const buffer = Buffer.from(fileDataInitial);
|
||||
file.write(buffer);
|
||||
cb_occurred += 'write ';
|
||||
|
||||
file.end();
|
||||
}
|
||||
|
||||
|
||||
function run_test_2() {
|
||||
|
||||
const buffer = Buffer.from('123456');
|
||||
|
||||
const options = { start: 10,
|
||||
flags: 'r+' };
|
||||
const file = fs.createWriteStream(filepath, options);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
|
||||
file.on('open', function(fd) {
|
||||
cb_occurred += 'open ';
|
||||
});
|
||||
|
||||
file.on('close', function() {
|
||||
cb_occurred += 'close ';
|
||||
console.log(' (debug: bytesWritten ', file.bytesWritten);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
assert.strictEqual(file.bytesWritten, buffer.length);
|
||||
const fileData = fs.readFileSync(filepath, 'utf8');
|
||||
console.log(' (debug: file data ', fileData);
|
||||
console.log(' (debug: expected ', fileDataExpected_2);
|
||||
assert.strictEqual(fileData, fileDataExpected_2);
|
||||
|
||||
run_test_3();
|
||||
});
|
||||
|
||||
file.on('error', function(err) {
|
||||
cb_occurred += 'error ';
|
||||
console.log(' (debug: err event ', err);
|
||||
throw err;
|
||||
});
|
||||
|
||||
file.write(buffer);
|
||||
cb_occurred += 'write ';
|
||||
|
||||
file.end();
|
||||
}
|
||||
|
||||
|
||||
function run_test_3() {
|
||||
|
||||
const data = '\u2026\u2026'; // 3 bytes * 2 = 6 bytes in UTF-8
|
||||
|
||||
const options = { start: 10,
|
||||
flags: 'r+' };
|
||||
const file = fs.createWriteStream(filepath, options);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
|
||||
file.on('open', function(fd) {
|
||||
cb_occurred += 'open ';
|
||||
});
|
||||
|
||||
file.on('close', function() {
|
||||
cb_occurred += 'close ';
|
||||
console.log(' (debug: bytesWritten ', file.bytesWritten);
|
||||
console.log(' (debug: start ', file.start);
|
||||
console.log(' (debug: pos ', file.pos);
|
||||
assert.strictEqual(file.bytesWritten, data.length * 3);
|
||||
const fileData = fs.readFileSync(filepath, 'utf8');
|
||||
console.log(' (debug: file data ', fileData);
|
||||
console.log(' (debug: expected ', fileDataExpected_3);
|
||||
assert.strictEqual(fileData, fileDataExpected_3);
|
||||
|
||||
run_test_4();
|
||||
run_test_5();
|
||||
});
|
||||
|
||||
file.on('error', function(err) {
|
||||
cb_occurred += 'error ';
|
||||
console.log(' (debug: err event ', err);
|
||||
throw err;
|
||||
});
|
||||
|
||||
file.write(data, 'utf8');
|
||||
cb_occurred += 'write ';
|
||||
|
||||
file.end();
|
||||
}
|
||||
|
||||
|
||||
const run_test_4 = common.mustCall(function() {
|
||||
// Error: start must be >= zero
|
||||
const fn = () => {
|
||||
fs.createWriteStream(filepath, { start: -5, flags: 'r+' });
|
||||
};
|
||||
// Verify the range of values using a common integer verifier.
|
||||
// Limit Number.MAX_SAFE_INTEGER
|
||||
const err = {
|
||||
code: 'ERR_OUT_OF_RANGE',
|
||||
message: 'The value of "start" is out of range. ' +
|
||||
`It must be >= 0 and <= ${Number.MAX_SAFE_INTEGER}. Received -5`,
|
||||
name: 'RangeError'
|
||||
};
|
||||
assert.throws(fn, err);
|
||||
});
|
||||
|
||||
|
||||
const run_test_5 = common.mustCall(function() {
|
||||
// Error: start must be <= 2 ** 53 - 1
|
||||
const fn = () => {
|
||||
fs.createWriteStream(filepath, { start: 2 ** 53, flags: 'r+' });
|
||||
};
|
||||
// Verify the range of values using a common integer verifier.
|
||||
// Limit Number.MAX_SAFE_INTEGER
|
||||
const err = {
|
||||
code: 'ERR_OUT_OF_RANGE',
|
||||
message: 'The value of "start" is out of range. It must be ' +
|
||||
`>= 0 and <= ${Number.MAX_SAFE_INTEGER}. ` +
|
||||
'Received 9007199254740992',
|
||||
name: 'RangeError'
|
||||
};
|
||||
assert.throws(fn, err);
|
||||
});
|
||||
|
||||
run_test_1();
|
||||
Reference in New Issue
Block a user